| /** |
| * Copyright (c) 2011 protos software gmbh (http://www.protos.de). |
| * All rights reserved. This program and the accompanying materials |
| * are made available under the terms of the Eclipse Public License v1.0 |
| * which accompanies this distribution, and is available at |
| * http://www.eclipse.org/legal/epl-v10.html |
| * |
| * CONTRIBUTORS: |
| * Henrik Rentz-Reichert (initial contribution) |
| * Thomas Schuetz (changed for C code generator) |
| */ |
| package org.eclipse.etrice.generator.c.gen; |
| |
| import com.google.common.base.Objects; |
| import com.google.common.collect.Iterables; |
| import com.google.inject.Inject; |
| import com.google.inject.Singleton; |
| import java.util.ArrayList; |
| import java.util.Collection; |
| import java.util.HashMap; |
| import java.util.HashSet; |
| import java.util.List; |
| import java.util.Set; |
| import org.eclipse.emf.common.util.EList; |
| import org.eclipse.emf.common.util.TreeIterator; |
| import org.eclipse.emf.ecore.EObject; |
| import org.eclipse.emf.ecore.EStructuralFeature; |
| import org.eclipse.etrice.core.common.base.Annotation; |
| import org.eclipse.etrice.core.common.base.LiteralType; |
| import org.eclipse.etrice.core.common.converter.TimeConverter; |
| import org.eclipse.etrice.core.etmap.util.ETMapUtil; |
| import org.eclipse.etrice.core.etphys.eTPhys.ExecMode; |
| import org.eclipse.etrice.core.etphys.eTPhys.NodeClass; |
| import org.eclipse.etrice.core.etphys.eTPhys.NodeRef; |
| import org.eclipse.etrice.core.etphys.eTPhys.PhysicalThread; |
| import org.eclipse.etrice.core.fsm.fSM.ComponentCommunicationType; |
| import org.eclipse.etrice.core.fsm.fSM.DetailCode; |
| import org.eclipse.etrice.core.genmodel.etricegen.ActorInstance; |
| import org.eclipse.etrice.core.genmodel.etricegen.ExpandedActorClass; |
| import org.eclipse.etrice.core.genmodel.etricegen.InterfaceItemInstance; |
| import org.eclipse.etrice.core.genmodel.etricegen.PortInstance; |
| import org.eclipse.etrice.core.genmodel.etricegen.Root; |
| import org.eclipse.etrice.core.genmodel.etricegen.StructureInstance; |
| import org.eclipse.etrice.core.genmodel.etricegen.SubSystemInstance; |
| import org.eclipse.etrice.core.genmodel.fsm.base.ILogger; |
| import org.eclipse.etrice.core.genmodel.fsm.fsmgen.IDiagnostician; |
| import org.eclipse.etrice.core.room.ActorClass; |
| import org.eclipse.etrice.core.room.Attribute; |
| import org.eclipse.etrice.core.room.CommunicationType; |
| import org.eclipse.etrice.core.room.DataType; |
| import org.eclipse.etrice.core.room.EnumerationType; |
| import org.eclipse.etrice.core.room.GeneralProtocolClass; |
| import org.eclipse.etrice.core.room.InterfaceItem; |
| import org.eclipse.etrice.core.room.Message; |
| import org.eclipse.etrice.core.room.MessageHandler; |
| import org.eclipse.etrice.core.room.Port; |
| import org.eclipse.etrice.core.room.PortClass; |
| import org.eclipse.etrice.core.room.PrimitiveType; |
| import org.eclipse.etrice.core.room.ProtocolClass; |
| import org.eclipse.etrice.core.room.RefableType; |
| import org.eclipse.etrice.core.room.SAP; |
| import org.eclipse.etrice.core.room.SPP; |
| import org.eclipse.etrice.core.room.SubSystemClass; |
| import org.eclipse.etrice.core.room.VarDecl; |
| import org.eclipse.etrice.core.room.util.RoomHelpers; |
| import org.eclipse.etrice.generator.base.GlobalGeneratorSettings; |
| import org.eclipse.etrice.generator.c.Main; |
| import org.eclipse.etrice.generator.c.gen.CExtensions; |
| import org.eclipse.etrice.generator.c.gen.Initialization; |
| import org.eclipse.etrice.generator.fsm.base.IGeneratorFileIo; |
| import org.eclipse.etrice.generator.fsm.base.IntelligentSeparator; |
| import org.eclipse.etrice.generator.generic.ILanguageExtension; |
| import org.eclipse.etrice.generator.generic.ProcedureHelpers; |
| import org.eclipse.etrice.generator.generic.RoomExtensions; |
| import org.eclipse.etrice.generator.generic.TypeHelpers; |
| import org.eclipse.xtend2.lib.StringConcatenation; |
| import org.eclipse.xtext.xbase.lib.CollectionLiterals; |
| import org.eclipse.xtext.xbase.lib.Conversions; |
| import org.eclipse.xtext.xbase.lib.Extension; |
| import org.eclipse.xtext.xbase.lib.Functions.Function1; |
| import org.eclipse.xtext.xbase.lib.IntegerRange; |
| import org.eclipse.xtext.xbase.lib.IterableExtensions; |
| import org.eclipse.xtext.xbase.lib.ListExtensions; |
| |
| @Singleton |
| @SuppressWarnings("all") |
| public class NodeGen { |
| @Inject |
| @Extension |
| private RoomHelpers _roomHelpers; |
| |
| @Inject |
| @Extension |
| private CExtensions _cExtensions; |
| |
| @Inject |
| @Extension |
| private RoomExtensions _roomExtensions; |
| |
| @Inject |
| @Extension |
| private TypeHelpers _typeHelpers; |
| |
| @Inject |
| @Extension |
| private ProcedureHelpers helpers; |
| |
| @Inject |
| private IGeneratorFileIo fileIO; |
| |
| @Inject |
| private Initialization attrInitGenAddon; |
| |
| @Inject |
| private ILanguageExtension languageExt; |
| |
| @Inject |
| private IDiagnostician diagnostician; |
| |
| @Inject |
| private ILogger logger; |
| |
| public void doGenerate(final Root root) { |
| Collection<NodeRef> _nodeRefs = ETMapUtil.getNodeRefs(); |
| for (final NodeRef nr : _nodeRefs) { |
| List<String> _subSystemInstancePaths = ETMapUtil.getSubSystemInstancePaths(nr); |
| for (final String instpath : _subSystemInstancePaths) { |
| { |
| StructureInstance _instance = root.getInstance(instpath); |
| final SubSystemInstance ssi = ((SubSystemInstance) _instance); |
| boolean _notEquals = (!Objects.equal(ssi, null)); |
| if (_notEquals) { |
| SubSystemClass _subSystemClass = ssi.getSubSystemClass(); |
| String _generationTargetPath = this._roomExtensions.getGenerationTargetPath(_subSystemClass); |
| SubSystemClass _subSystemClass_1 = ssi.getSubSystemClass(); |
| String _path = this._roomExtensions.getPath(_subSystemClass_1); |
| final String filepath = (_generationTargetPath + _path); |
| SubSystemClass _subSystemClass_2 = ssi.getSubSystemClass(); |
| String _generationInfoPath = this._roomExtensions.getGenerationInfoPath(_subSystemClass_2); |
| SubSystemClass _subSystemClass_3 = ssi.getSubSystemClass(); |
| String _path_1 = this._roomExtensions.getPath(_subSystemClass_3); |
| final String infopath = (_generationInfoPath + _path_1); |
| String file = this._cExtensions.getCHeaderFileName(nr, ssi); |
| this.checkDataPorts(ssi); |
| final Set<PhysicalThread> usedThreads = ETMapUtil.getUsedThreads(nr, ssi); |
| CharSequence _generateHeaderFile = this.generateHeaderFile(root, ssi); |
| this.fileIO.generateFile("generating Node declaration", filepath, infopath, file, _generateHeaderFile); |
| String _cSourceFileName = this._cExtensions.getCSourceFileName(nr, ssi); |
| file = _cSourceFileName; |
| CharSequence _generateSourceFile = this.generateSourceFile(root, ssi, usedThreads); |
| this.fileIO.generateFile("generating Node implementation", filepath, infopath, file, _generateSourceFile); |
| String _instSourceFileName = this._cExtensions.getInstSourceFileName(nr, ssi); |
| file = _instSourceFileName; |
| CharSequence _generateInstanceFile = this.generateInstanceFile(root, ssi, usedThreads); |
| this.fileIO.generateFile("generating Node instance file", filepath, infopath, file, _generateInstanceFile); |
| String _dispSourceFileName = this._cExtensions.getDispSourceFileName(nr, ssi); |
| file = _dispSourceFileName; |
| CharSequence _generateDispatcherFile = this.generateDispatcherFile(root, ssi, usedThreads); |
| this.fileIO.generateFile("generating Node dispatcher file", filepath, infopath, file, _generateDispatcherFile); |
| } |
| } |
| } |
| } |
| } |
| |
| private CharSequence generateHeaderFile(final Root root, final SubSystemInstance ssi) { |
| CharSequence _xblockexpression = null; |
| { |
| final NodeRef nr = ETMapUtil.getNodeRef(ssi); |
| final SubSystemClass ssc = ssi.getSubSystemClass(); |
| String _name = nr.getName(); |
| String _plus = (_name + "_"); |
| String _name_1 = ssi.getName(); |
| final String clsname = (_plus + _name_1); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* @author generated by eTrice"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* Header File of Node "); |
| String _name_2 = nr.getName(); |
| _builder.append(_name_2, " "); |
| _builder.append(" with SubSystem "); |
| String _name_3 = ssi.getName(); |
| _builder.append(_name_3, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardBegin = this._cExtensions.generateIncludeGuardBegin(clsname); |
| _builder.append(_generateIncludeGuardBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("#include \"etDatatypes.h\""); |
| _builder.newLine(); |
| _builder.newLine(); |
| DetailCode _userCode1 = ssc.getUserCode1(); |
| CharSequence _userCode = this.helpers.userCode(_userCode1); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("/* lifecycle functions"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* init -> start -> run (loop) -> stop -> destroy"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_init(void);\t\t/* lifecycle init \t */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_start(void);\t/* lifecycle start \t */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_run(etBool runAsTest);\t\t/* lifecycle run \t */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_stop(void); \t/* lifecycle stop\t */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_destroy(void); \t/* lifecycle destroy */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_shutdown(void); /* shutdown the dispatcher loop */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| DetailCode _userCode2 = ssc.getUserCode2(); |
| CharSequence _userCode_1 = this.helpers.userCode(_userCode2); |
| _builder.append(_userCode_1, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardEnd = this._cExtensions.generateIncludeGuardEnd(clsname); |
| _builder.append(_generateIncludeGuardEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence generateSourceFile(final Root root, final SubSystemInstance ssi, final Collection<PhysicalThread> usedThreads) { |
| CharSequence _xblockexpression = null; |
| { |
| final NodeRef nr = ETMapUtil.getNodeRef(ssi); |
| final SubSystemClass ssc = ssi.getSubSystemClass(); |
| String _name = nr.getName(); |
| String _plus = (_name + "_"); |
| String _name_1 = ssi.getName(); |
| final String clsname = (_plus + _name_1); |
| NodeClass _type = nr.getType(); |
| EList<PhysicalThread> _threads = _type.getThreads(); |
| final Function1<PhysicalThread, Boolean> _function = new Function1<PhysicalThread, Boolean>() { |
| @Override |
| public Boolean apply(final PhysicalThread t) { |
| return Boolean.valueOf(usedThreads.contains(t)); |
| } |
| }; |
| final Iterable<PhysicalThread> threads = IterableExtensions.<PhysicalThread>filter(_threads, _function); |
| final boolean logData = (Main.getSettings().isGenerateDataInstrumentation() && this._roomHelpers.isAnnotationPresent(ssc.getAnnotations(), "DataLogging")); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* @author generated by eTrice"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* Source File of Node "); |
| String _name_2 = nr.getName(); |
| _builder.append(_name_2, " "); |
| _builder.append(" with SubSystem "); |
| String _name_3 = ssi.getName(); |
| _builder.append(_name_3, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include <stdio.h>"); |
| _builder.newLine(); |
| _builder.append("#include <string.h>"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include \""); |
| String _cHeaderFileName = this._cExtensions.getCHeaderFileName(nr, ssi); |
| _builder.append(_cHeaderFileName, ""); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("#include \"debugging/etLogger.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"debugging/etMSCLogger.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"debugging/etDataLogger.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"messaging/etSystemProtocol.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"osal/etTimer.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"osal/etSema.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"runtime/etRuntime.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"etRuntimeConfig.h\""); |
| _builder.newLine(); |
| _builder.newLine(); |
| DetailCode _userCode3 = ssc.getUserCode3(); |
| CharSequence _userCode = this.helpers.userCode(_userCode3); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("/* data for Node "); |
| String _name_4 = nr.getName(); |
| _builder.append(_name_4, ""); |
| _builder.append(" with SubSystem "); |
| String _name_5 = ssi.getName(); |
| _builder.append(_name_5, ""); |
| _builder.append(" */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("typedef struct "); |
| _builder.append(clsname, ""); |
| _builder.append(" {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("char *name;"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("volatile int shutdownRequest;"); |
| _builder.newLine(); |
| _builder.append("} "); |
| _builder.append(clsname, ""); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("static "); |
| _builder.append(clsname, ""); |
| _builder.append(" "); |
| _builder.append(clsname, ""); |
| _builder.append("Inst = {\""); |
| _builder.append(clsname, ""); |
| _builder.append("\", 0};"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_initActorInstances(void);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_constructActorInstances(void);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("/* include instances for all classes */"); |
| _builder.newLine(); |
| _builder.append("#include \""); |
| String _instSourceFileName = this._cExtensions.getInstSourceFileName(nr, ssi); |
| _builder.append(_instSourceFileName, ""); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("#include \""); |
| String _dispSourceFileName = this._cExtensions.getDispSourceFileName(nr, ssi); |
| _builder.append(_dispSourceFileName, ""); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_initMessageServices(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"initMessageServices\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("{"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("etTime interval;"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("/* initialization of all message services */"); |
| _builder.newLine(); |
| { |
| for(final PhysicalThread thread : threads) { |
| { |
| if ((Objects.equal(thread.getExecmode(), ExecMode.POLLED) || Objects.equal(thread.getExecmode(), ExecMode.MIXED))) { |
| _builder.append("\t\t"); |
| _builder.append("interval.sec = "); |
| long _time = thread.getTime(); |
| long _split = TimeConverter.split(_time, TimeConverter.SEC, true); |
| _builder.append(_split, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("interval.nSec = "); |
| long _time_1 = thread.getTime(); |
| long _split_1 = TimeConverter.split(_time_1, TimeConverter.MILLI_SEC, false); |
| _builder.append(_split_1, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("etMessageService_init("); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("&msgService_"); |
| String _name_6 = thread.getName(); |
| _builder.append(_name_6, "\t\t\t"); |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("msgBuffer_"); |
| String _name_7 = thread.getName(); |
| _builder.append(_name_7, "\t\t\t"); |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| String _name_8 = thread.getName(); |
| String _upperCase = _name_8.toUpperCase(); |
| _builder.append(_upperCase, "\t\t\t"); |
| _builder.append("_POOL_SIZE,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| String _name_9 = thread.getName(); |
| String _upperCase_1 = _name_9.toUpperCase(); |
| _builder.append(_upperCase_1, "\t\t\t"); |
| _builder.append("_BLOCK_SIZE,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| int _stacksize = thread.getStacksize(); |
| _builder.append(_stacksize, "\t\t\t"); |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| long _prio = thread.getPrio(); |
| _builder.append(_prio, "\t\t\t"); |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("interval,"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("MsgDispatcher_"); |
| String _name_10 = thread.getName(); |
| _builder.append(_name_10, "\t\t\t"); |
| _builder.append("_receiveMessage,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("EXECMODE_"); |
| ExecMode _execmode = thread.getExecmode(); |
| String _string = _execmode.toString(); |
| String _upperCase_2 = _string.toUpperCase(); |
| _builder.append(_upperCase_2, "\t\t\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_startMessageServices(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"startMessageServices\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| final Function1<PhysicalThread, Long> _function_1 = new Function1<PhysicalThread, Long>() { |
| @Override |
| public Long apply(final PhysicalThread it) { |
| return Long.valueOf(it.getPrio()); |
| } |
| }; |
| List<PhysicalThread> _sortBy = IterableExtensions.<PhysicalThread, Long>sortBy(threads, _function_1); |
| List<PhysicalThread> _reverse = ListExtensions.<PhysicalThread>reverse(_sortBy); |
| for(final PhysicalThread thread_1 : _reverse) { |
| _builder.append("\t"); |
| _builder.append("etMessageService_start(&msgService_"); |
| String _name_11 = thread_1.getName(); |
| _builder.append(_name_11, "\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_stopMessageServices(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"stopMessageServices\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| for(final PhysicalThread thread_2 : threads) { |
| _builder.append("\t"); |
| _builder.append("etMessageService_stop(&msgService_"); |
| String _name_12 = thread_2.getName(); |
| _builder.append(_name_12, "\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_destroyMessageServices(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"destroyMessageServices\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| for(final PhysicalThread thread_3 : threads) { |
| _builder.append("\t"); |
| _builder.append("etMessageService_destroy(&msgService_"); |
| String _name_13 = thread_3.getName(); |
| _builder.append(_name_13, "\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_init(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"init\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("etLogger_logInfoF(\"%s_init\", "); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.name);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* construct all actors */"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_constructActorInstances();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* initialization of all message services */"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_initMessageServices();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* init all actors */"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_initActorInstances();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| if (logData) { |
| { |
| for(final PhysicalThread thread_4 : threads) { |
| _builder.append("\t"); |
| _builder.append("MsgDispatcher_"); |
| String _name_14 = thread_4.getName(); |
| _builder.append(_name_14, "\t"); |
| _builder.append("_logDataHeaders();"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| { |
| for(final PhysicalThread thread_5 : threads) { |
| _builder.append("\t"); |
| _builder.append("MsgDispatcher_"); |
| String _name_15 = thread_5.getName(); |
| _builder.append(_name_15, "\t"); |
| _builder.append("_logData();"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_start(void) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"start\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("etLogger_logInfoF(\"%s_start\", "); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.name);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_startMessageServices();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_run(etBool runAsTest) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("#ifdef ET_RUNNER_ACTIVATE"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"run\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("if (runAsTest) {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("etSema_waitForWakeup(etRuntime_getTerminateSemaphore());"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("else {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("printf(\"type quit to exit\\n\");"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("fflush(stdout);"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("while (ET_TRUE) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("char line[64];"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("if (fgets(line, 64, stdin) != NULL) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t\t"); |
| _builder.append("if (strncmp(line, \"quit\", 4)==0)"); |
| _builder.newLine(); |
| _builder.append("\t\t\t\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("#endif"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_stop(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"stop\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("etLogger_logInfoF(\"%s_stop\", "); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.name);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_stopMessageServices();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_destroy(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"destroy\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("etLogger_logInfoF(\"%s_destroy\", "); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.name);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai : _allContainedInstances) { |
| _builder.append("\t"); |
| ActorClass _actorClass = ai.getActorClass(); |
| String _path = ai.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| String _plus_1 = ("&" + _pathName); |
| String _invokeUserStructor = this.helpers.invokeUserStructor(_actorClass, _plus_1, false); |
| _builder.append(_invokeUserStructor, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("_destroyMessageServices();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(clsname, ""); |
| _builder.append("_shutdown(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"shutdown\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("etLogger_logInfoF(\"%s_shutdown\", "); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.name);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append(clsname, "\t"); |
| _builder.append("Inst.shutdownRequest = 1;"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_constructActorInstances(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"constructActorInstances\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances_1 = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai_1 : _allContainedInstances_1) { |
| _builder.append("\t"); |
| ActorClass _actorClass_1 = ai_1.getActorClass(); |
| String _path_1 = ai_1.getPath(); |
| String _pathName_1 = this._roomExtensions.getPathName(_path_1); |
| String _plus_2 = ("&" + _pathName_1); |
| String _invokeUserStructor_1 = this.helpers.invokeUserStructor(_actorClass_1, _plus_2, true); |
| _builder.append(_invokeUserStructor_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("static void "); |
| _builder.append(clsname, ""); |
| _builder.append("_initActorInstances(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\""); |
| _builder.append(clsname, "\t"); |
| _builder.append("\", \"initActorInstances\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances_2 = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai_2 : _allContainedInstances_2) { |
| _builder.append("\t"); |
| ActorClass _actorClass_2 = ai_2.getActorClass(); |
| String _name_16 = _actorClass_2.getName(); |
| _builder.append(_name_16, "\t"); |
| _builder.append("_init(&"); |
| String _path_2 = ai_2.getPath(); |
| String _pathName_2 = this._roomExtensions.getPathName(_path_2); |
| _builder.append(_pathName_2, "\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence generateInstanceFile(final Root root, final SubSystemInstance ssi, final Collection<PhysicalThread> usedThreads) { |
| CharSequence _xblockexpression = null; |
| { |
| final NodeRef nr = ETMapUtil.getNodeRef(ssi); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* @author generated by eTrice"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* Instance File of Node "); |
| String _name = nr.getName(); |
| _builder.append(_name, " "); |
| _builder.append(" with SubSystem "); |
| String _name_1 = ssi.getName(); |
| _builder.append(_name_1, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("* - instantiation of all actor instances and port instances"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* - configuration of data and connection of ports"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include \"messaging/etMessageService.h\""); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("/* include all referenced ActorClasses */"); |
| _builder.newLine(); |
| { |
| SubSystemClass _subSystemClass = ssi.getSubSystemClass(); |
| EList<ActorClass> _referencedActorClasses = root.getReferencedActorClasses(_subSystemClass); |
| for(final ActorClass actorClass : _referencedActorClasses) { |
| _builder.append("#include "); |
| String _includePath = this._cExtensions.getIncludePath(actorClass); |
| _builder.append(_includePath, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("/* include all referenced ProtcolClasses */"); |
| _builder.newLine(); |
| { |
| SubSystemClass _subSystemClass_1 = ssi.getSubSystemClass(); |
| EList<ProtocolClass> _referencedProtocolClasses = root.getReferencedProtocolClasses(_subSystemClass_1); |
| for(final ProtocolClass protocolClass : _referencedProtocolClasses) { |
| _builder.append("#include "); |
| String _includePath_1 = this._cExtensions.getIncludePath(protocolClass); |
| _builder.append(_includePath_1, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("/* instantiation of message services and message buffers */"); |
| _builder.newLine(); |
| { |
| NodeClass _type = nr.getType(); |
| EList<PhysicalThread> _threads = _type.getThreads(); |
| final Function1<PhysicalThread, Boolean> _function = new Function1<PhysicalThread, Boolean>() { |
| @Override |
| public Boolean apply(final PhysicalThread t) { |
| return Boolean.valueOf(usedThreads.contains(t)); |
| } |
| }; |
| Iterable<PhysicalThread> _filter = IterableExtensions.<PhysicalThread>filter(_threads, _function); |
| for(final PhysicalThread thread : _filter) { |
| _builder.append("/* "); |
| String _name_2 = thread.getName(); |
| _builder.append(_name_2, ""); |
| _builder.append(" */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("#define "); |
| String _name_3 = thread.getName(); |
| String _upperCase = _name_3.toUpperCase(); |
| _builder.append(_upperCase, ""); |
| _builder.append("_POOL_SIZE\t\t"); |
| int _msgpoolsize = thread.getMsgpoolsize(); |
| _builder.append(_msgpoolsize, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("#define "); |
| String _name_4 = thread.getName(); |
| String _upperCase_1 = _name_4.toUpperCase(); |
| _builder.append(_upperCase_1, ""); |
| _builder.append("_BLOCK_SIZE\t"); |
| int _msgblocksize = thread.getMsgblocksize(); |
| _builder.append(_msgblocksize, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("static uint8 msgBuffer_"); |
| String _name_5 = thread.getName(); |
| _builder.append(_name_5, ""); |
| _builder.append("["); |
| String _name_6 = thread.getName(); |
| String _upperCase_2 = _name_6.toUpperCase(); |
| _builder.append(_upperCase_2, ""); |
| _builder.append("_POOL_SIZE * "); |
| String _name_7 = thread.getName(); |
| String _upperCase_3 = _name_7.toUpperCase(); |
| _builder.append(_upperCase_3, ""); |
| _builder.append("_BLOCK_SIZE];"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("static etMessageService msgService_"); |
| String _name_8 = thread.getName(); |
| _builder.append(_name_8, ""); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("/* declarations of all ActorClass instances (const and variable structs) */"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("/* forward declaration of variable actor structs */"); |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai : _allContainedInstances) { |
| _builder.append("static "); |
| ActorClass _actorClass = ai.getActorClass(); |
| String _name_9 = _actorClass.getName(); |
| _builder.append(_name_9, ""); |
| _builder.append(" "); |
| String _path = ai.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| _builder.append(_pathName, ""); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("/* forward declaration of variable port structs */"); |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances_1 = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai_1 : _allContainedInstances_1) { |
| { |
| EList<InterfaceItemInstance> _orderedIfItemInstances = ai_1.getOrderedIfItemInstances(); |
| boolean _isEmpty = _orderedIfItemInstances.isEmpty(); |
| if (_isEmpty) { |
| _builder.append("/* nothing to do */"); |
| _builder.newLine(); |
| } else { |
| { |
| EList<InterfaceItemInstance> _orderedIfItemInstances_1 = ai_1.getOrderedIfItemInstances(); |
| for(final InterfaceItemInstance pi : _orderedIfItemInstances_1) { |
| { |
| ProtocolClass _protocol = pi.getProtocol(); |
| boolean _isConjugated = this._roomExtensions.isConjugated(pi); |
| PortClass _portClass = this._roomExtensions.getPortClass(_protocol, _isConjugated); |
| EList<Attribute> _attributes = null; |
| if (_portClass!=null) { |
| _attributes=_portClass.getAttributes(); |
| } |
| int _size = 0; |
| if (_attributes!=null) { |
| _size=_attributes.size(); |
| } |
| boolean _greaterThan = (_size > 0); |
| if (_greaterThan) { |
| _builder.append("static "); |
| ProtocolClass _protocol_1 = pi.getProtocol(); |
| boolean _isConjugated_1 = this._roomExtensions.isConjugated(pi); |
| String _portClassName = this._roomExtensions.getPortClassName(_protocol_1, _isConjugated_1); |
| _builder.append(_portClassName, ""); |
| _builder.append("_var "); |
| String _path_1 = pi.getPath(); |
| String _pathName_1 = this._roomExtensions.getPathName(_path_1); |
| _builder.append(_pathName_1, ""); |
| _builder.append("_var"); |
| { |
| boolean _isReplicated = pi.isReplicated(); |
| if (_isReplicated) { |
| _builder.append("["); |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| int _size_1 = _peers.size(); |
| _builder.append(_size_1, ""); |
| _builder.append("]"); |
| } |
| } |
| _builder.append("={"); |
| _builder.newLineIfNotEmpty(); |
| { |
| int _xifexpression = (int) 0; |
| EList<InterfaceItemInstance> _peers_1 = pi.getPeers(); |
| int _size_2 = _peers_1.size(); |
| boolean _equals = (_size_2 == 0); |
| if (_equals) { |
| _xifexpression = 1; |
| } else { |
| EList<InterfaceItemInstance> _peers_2 = pi.getPeers(); |
| _xifexpression = _peers_2.size(); |
| } |
| IntegerRange _upTo = new IntegerRange(1, _xifexpression); |
| boolean _hasElements = false; |
| for(final Integer i : _upTo) { |
| if (!_hasElements) { |
| _hasElements = true; |
| } else { |
| _builder.appendImmediate(", ", "\t"); |
| } |
| _builder.append("\t"); |
| InterfaceItem _interfaceItem = pi.getInterfaceItem(); |
| PortClass _portClass_1 = this._roomHelpers.getPortClass(_interfaceItem); |
| EList<Attribute> _attributes_1 = _portClass_1.getAttributes(); |
| CharSequence _generateAttributeInit = this.attrInitGenAddon.generateAttributeInit(pi, _attributes_1); |
| _builder.append(_generateAttributeInit, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t\t\t\t\t\t"); |
| } |
| } |
| _builder.append("};"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| { |
| EList<ActorInstance> _allContainedInstances_2 = ssi.getAllContainedInstances(); |
| for(final ActorInstance ai_2 : _allContainedInstances_2) { |
| _builder.newLine(); |
| _builder.append("/* instance "); |
| String _path_2 = ai_2.getPath(); |
| String _pathName_2 = this._roomExtensions.getPathName(_path_2); |
| _builder.append(_pathName_2, ""); |
| _builder.append(" */"); |
| _builder.newLineIfNotEmpty(); |
| { |
| if (((!Main.getSettings().isGenerateMSCInstrumentation()) && ai_2.getOrderedIfItemInstances().isEmpty())) { |
| _builder.append("/* no ports/saps/services - nothing to initialize statically */"); |
| _builder.newLine(); |
| } else { |
| CharSequence _genActorInstanceInitializer = this.genActorInstanceInitializer(root, ai_2); |
| _builder.append(_genActorInstanceInitializer, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence genActorInstanceInitializer(final Root root, final ActorInstance ai) { |
| CharSequence _xblockexpression = null; |
| { |
| String _path = ai.getPath(); |
| final String instName = this._roomExtensions.getPathName(_path); |
| final ArrayList<InterfaceItemInstance> replEventItems = new ArrayList<InterfaceItemInstance>(); |
| EList<InterfaceItemInstance> _orderedIfItemInstances = ai.getOrderedIfItemInstances(); |
| final Function1<InterfaceItemInstance, Boolean> _function = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance e) { |
| return Boolean.valueOf(e.isReplicated()); |
| } |
| }; |
| Iterable<InterfaceItemInstance> _filter = IterableExtensions.<InterfaceItemInstance>filter(_orderedIfItemInstances, _function); |
| Iterables.<InterfaceItemInstance>addAll(replEventItems, _filter); |
| final Function1<InterfaceItemInstance, Boolean> _function_1 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance e) { |
| EList<InterfaceItemInstance> _peers = e.getPeers(); |
| boolean _isEmpty = _peers.isEmpty(); |
| return Boolean.valueOf((!_isEmpty)); |
| } |
| }; |
| InterfaceItemInstance _findFirst = IterableExtensions.<InterfaceItemInstance>findFirst(replEventItems, _function_1); |
| final boolean haveReplSubItems = (!Objects.equal(_findFirst, null)); |
| final Function1<InterfaceItemInstance, Boolean> _function_2 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance i) { |
| InterfaceItem _interfaceItem = i.getInterfaceItem(); |
| return Boolean.valueOf((_interfaceItem instanceof Port)); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> replEventPorts = IterableExtensions.<InterfaceItemInstance>filter(replEventItems, _function_2); |
| final Function1<InterfaceItemInstance, Boolean> _function_3 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance i) { |
| InterfaceItem _interfaceItem = i.getInterfaceItem(); |
| return Boolean.valueOf((_interfaceItem instanceof SPP)); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> replEventSPPs = IterableExtensions.<InterfaceItemInstance>filter(replEventItems, _function_3); |
| EList<InterfaceItemInstance> _orderedIfItemInstances_1 = ai.getOrderedIfItemInstances(); |
| final Function1<InterfaceItemInstance, Boolean> _function_4 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance e) { |
| return Boolean.valueOf(e.isSimple()); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> simplePorts = IterableExtensions.<InterfaceItemInstance>filter(_orderedIfItemInstances_1, _function_4); |
| final ArrayList<InterfaceItemInstance> simpleEventItems = new ArrayList<InterfaceItemInstance>(); |
| final Function1<InterfaceItemInstance, Boolean> _function_5 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance p) { |
| ProtocolClass _protocol = p.getProtocol(); |
| CommunicationType _commType = _protocol.getCommType(); |
| return Boolean.valueOf(Objects.equal(_commType, CommunicationType.EVENT_DRIVEN)); |
| } |
| }; |
| Iterable<InterfaceItemInstance> _filter_1 = IterableExtensions.<InterfaceItemInstance>filter(simplePorts, _function_5); |
| Iterables.<InterfaceItemInstance>addAll(simpleEventItems, _filter_1); |
| final Function1<InterfaceItemInstance, Boolean> _function_6 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance i) { |
| InterfaceItem _interfaceItem = i.getInterfaceItem(); |
| return Boolean.valueOf((_interfaceItem instanceof Port)); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> simpleEventPorts = IterableExtensions.<InterfaceItemInstance>filter(simpleEventItems, _function_6); |
| final Function1<InterfaceItemInstance, Boolean> _function_7 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance i) { |
| InterfaceItem _interfaceItem = i.getInterfaceItem(); |
| return Boolean.valueOf((_interfaceItem instanceof SAP)); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> simpleEventSAPs = IterableExtensions.<InterfaceItemInstance>filter(simpleEventItems, _function_7); |
| final Function1<InterfaceItemInstance, Boolean> _function_8 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance p) { |
| ProtocolClass _protocol = p.getProtocol(); |
| CommunicationType _commType = _protocol.getCommType(); |
| return Boolean.valueOf(Objects.equal(_commType, CommunicationType.DATA_DRIVEN)); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> dataPorts = IterableExtensions.<InterfaceItemInstance>filter(simplePorts, _function_8); |
| final Function1<InterfaceItemInstance, Boolean> _function_9 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance p) { |
| return Boolean.valueOf(((p instanceof PortInstance) && (!((PortInstance) p).getPort().isConjugated()))); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> recvPorts = IterableExtensions.<InterfaceItemInstance>filter(dataPorts, _function_9); |
| final Function1<InterfaceItemInstance, Boolean> _function_10 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance p) { |
| return Boolean.valueOf(((p instanceof PortInstance) && ((PortInstance) p).getPort().isConjugated())); |
| } |
| }; |
| final Iterable<InterfaceItemInstance> sendPorts = IterableExtensions.<InterfaceItemInstance>filter(dataPorts, _function_10); |
| final HashMap<InterfaceItemInstance, Integer> offsets = new HashMap<InterfaceItemInstance, Integer>(); |
| int offset = 0; |
| for (final InterfaceItemInstance p : replEventItems) { |
| { |
| offsets.put(p, Integer.valueOf(offset)); |
| EList<InterfaceItemInstance> _peers = p.getPeers(); |
| int _size = _peers.size(); |
| int _plus = (offset + _size); |
| offset = _plus; |
| } |
| } |
| String _xifexpression = null; |
| if (haveReplSubItems) { |
| _xifexpression = (instName + "_repl_sub_ports"); |
| } else { |
| _xifexpression = "NULL"; |
| } |
| String replSubPortsArray = _xifexpression; |
| final boolean haveConstData = ((((!simpleEventItems.isEmpty()) || (!IterableExtensions.isEmpty(recvPorts))) || (!replEventItems.isEmpty())) || Main.getSettings().isGenerateMSCInstrumentation()); |
| final IntelligentSeparator sep = new IntelligentSeparator(","); |
| String _xifexpression_1 = null; |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| _xifexpression_1 = "/*const*/"; |
| } else { |
| _xifexpression_1 = "const"; |
| } |
| final String const_ = _xifexpression_1; |
| StringConcatenation _builder = new StringConcatenation(); |
| { |
| GlobalGeneratorSettings _settings_1 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_1 = _settings_1.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_1) { |
| CharSequence _genPeerPortArrays = this.genPeerPortArrays(root, ai); |
| _builder.append(_genPeerPortArrays, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| { |
| if (haveReplSubItems) { |
| _builder.append("static const etReplSubPort "); |
| _builder.append(replSubPortsArray, ""); |
| _builder.append("["); |
| _builder.append(offset, ""); |
| _builder.append("] = {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("/* Replicated Sub Ports: {varData, msgService, peerAddress, localId, index} */"); |
| _builder.newLine(); |
| { |
| final Function1<InterfaceItemInstance, Boolean> _function_11 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance e) { |
| EList<InterfaceItemInstance> _peers = e.getPeers(); |
| boolean _isEmpty = _peers.isEmpty(); |
| return Boolean.valueOf((!_isEmpty)); |
| } |
| }; |
| Iterable<InterfaceItemInstance> _filter_2 = IterableExtensions.<InterfaceItemInstance>filter(replEventItems, _function_11); |
| boolean _hasElements = false; |
| for(final InterfaceItemInstance pi : _filter_2) { |
| if (!_hasElements) { |
| _hasElements = true; |
| } else { |
| _builder.appendImmediate(",", "\t"); |
| } |
| _builder.append("\t"); |
| String _genReplSubPortInitializers = this.genReplSubPortInitializers(root, ai, pi); |
| _builder.append(_genReplSubPortInitializers, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("};"); |
| _builder.newLine(); |
| } |
| } |
| { |
| if (haveConstData) { |
| _builder.append("static "); |
| _builder.append(const_, ""); |
| _builder.append(" "); |
| ActorClass _actorClass = ai.getActorClass(); |
| String _name = _actorClass.getName(); |
| _builder.append(_name, ""); |
| _builder.append("_const "); |
| _builder.append(instName, ""); |
| _builder.append("_const = {"); |
| _builder.newLineIfNotEmpty(); |
| { |
| GlobalGeneratorSettings _settings_2 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_2 = _settings_2.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_2) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| _builder.append("\""); |
| String _path_1 = ai.getPath(); |
| _builder.append(_path_1, "\t"); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("/* Ports: {varData, msgService, peerAddress, localId} */"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* simple ports */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_1 : simpleEventPorts) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| String _genPortInitializer = this.genPortInitializer(root, ai, pi_1); |
| _builder.append(_genPortInitializer, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* data receive ports */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_2 : recvPorts) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| String _genRecvPortInitializer = this.genRecvPortInitializer(root, ai, pi_2); |
| _builder.append(_genRecvPortInitializer, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* saps */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_3 : simpleEventSAPs) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| String _genPortInitializer_1 = this.genPortInitializer(root, ai, pi_3); |
| _builder.append(_genPortInitializer_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* replicated ports */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_4 : replEventPorts) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| _builder.append("{"); |
| EList<InterfaceItemInstance> _peers = pi_4.getPeers(); |
| int _size = _peers.size(); |
| _builder.append(_size, "\t"); |
| _builder.append(", "); |
| _builder.append(replSubPortsArray, "\t"); |
| _builder.append("+"); |
| Integer _get = offsets.get(pi_4); |
| _builder.append(_get, "\t"); |
| _builder.append("}"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* services */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_5 : replEventSPPs) { |
| _builder.append("\t"); |
| _builder.append(sep, "\t"); |
| _builder.append("{"); |
| EList<InterfaceItemInstance> _peers_1 = pi_5.getPeers(); |
| int _size_1 = _peers_1.size(); |
| _builder.append(_size_1, "\t"); |
| _builder.append(", "); |
| _builder.append(replSubPortsArray, "\t"); |
| _builder.append("+"); |
| Integer _get_1 = offsets.get(pi_5); |
| _builder.append(_get_1, "\t"); |
| _builder.append("}"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("};"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("static "); |
| ActorClass _actorClass_1 = ai.getActorClass(); |
| String _name_1 = _actorClass_1.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append(" "); |
| _builder.append(instName, ""); |
| _builder.append(" = {"); |
| _builder.newLineIfNotEmpty(); |
| { |
| if (haveConstData) { |
| _builder.append("\t"); |
| _builder.append("&"); |
| _builder.append(instName, "\t"); |
| _builder.append("_const,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("/* data send ports */"); |
| _builder.newLine(); |
| { |
| for(final InterfaceItemInstance pi_6 : sendPorts) { |
| _builder.append("\t"); |
| CharSequence _genSendPortInitializer = this.genSendPortInitializer(pi_6); |
| _builder.append(_genSendPortInitializer, "\t"); |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* attributes */"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| ActorClass _actorClass_2 = ai.getActorClass(); |
| List<Attribute> _allAttributes = this._roomHelpers.getAllAttributes(_actorClass_2); |
| CharSequence _generateAttributeInit = this.attrInitGenAddon.generateAttributeInit(ai, _allAttributes); |
| _builder.append(_generateAttributeInit, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/* state and history are initialized in init function */"); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence genPeerPortArrays(final Root root, final ActorInstance ai) { |
| CharSequence _xblockexpression = null; |
| { |
| EList<InterfaceItemInstance> _orderedIfItemInstances = ai.getOrderedIfItemInstances(); |
| final Function1<InterfaceItemInstance, Boolean> _function = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance e) { |
| return Boolean.valueOf((e.isSimple() && (e instanceof PortInstance))); |
| } |
| }; |
| Iterable<InterfaceItemInstance> _filter = IterableExtensions.<InterfaceItemInstance>filter(_orderedIfItemInstances, _function); |
| final Function1<InterfaceItemInstance, PortInstance> _function_1 = new Function1<InterfaceItemInstance, PortInstance>() { |
| @Override |
| public PortInstance apply(final InterfaceItemInstance inst) { |
| return ((PortInstance) inst); |
| } |
| }; |
| final Iterable<PortInstance> simplePorts = IterableExtensions.<InterfaceItemInstance, PortInstance>map(_filter, _function_1); |
| final Function1<PortInstance, Boolean> _function_2 = new Function1<PortInstance, Boolean>() { |
| @Override |
| public Boolean apply(final PortInstance p) { |
| return Boolean.valueOf((p.getPort().isConjugated() && Objects.equal(p.getProtocol().getCommType(), CommunicationType.DATA_DRIVEN))); |
| } |
| }; |
| final Iterable<PortInstance> sendPorts = IterableExtensions.<PortInstance>filter(simplePorts, _function_2); |
| final Function1<PortInstance, Boolean> _function_3 = new Function1<PortInstance, Boolean>() { |
| @Override |
| public Boolean apply(final PortInstance p) { |
| Port _port = p.getPort(); |
| List<Message> _outgoing = NodeGen.this._roomHelpers.getOutgoing(_port); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| return Boolean.valueOf((NodeGen.this._typeHelpers.isEnumeration(m.getData().getRefType().getType()) || NodeGen.this._typeHelpers.isBoolean(m.getData().getRefType().getType()))); |
| } |
| }; |
| Iterable<Message> _filter = IterableExtensions.<Message>filter(_outgoing, _function); |
| boolean _isEmpty = IterableExtensions.isEmpty(_filter); |
| return Boolean.valueOf((!_isEmpty)); |
| } |
| }; |
| final Iterable<PortInstance> loggedPorts = IterableExtensions.<PortInstance>filter(sendPorts, _function_3); |
| StringConcatenation _builder = new StringConcatenation(); |
| { |
| boolean _isEmpty = IterableExtensions.isEmpty(loggedPorts); |
| boolean _not = (!_isEmpty); |
| if (_not) { |
| _builder.append("#ifdef ET_ASYNC_MSC_LOGGER_ACTIVATE"); |
| _builder.newLine(); |
| { |
| for(final PortInstance pi : loggedPorts) { |
| _builder.append("static const char* "); |
| String _path = pi.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| _builder.append(_pathName, ""); |
| _builder.append("_peers["); |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| int _size = _peers.size(); |
| int _plus = (_size + 1); |
| _builder.append(_plus, ""); |
| _builder.append("] = {"); |
| _builder.newLineIfNotEmpty(); |
| { |
| EList<InterfaceItemInstance> _peers_1 = pi.getPeers(); |
| for(final InterfaceItemInstance peer : _peers_1) { |
| _builder.append("\t"); |
| _builder.append("\""); |
| EObject _eContainer = peer.eContainer(); |
| String _path_1 = ((ActorInstance) _eContainer).getPath(); |
| _builder.append(_path_1, "\t"); |
| _builder.append("\","); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("NULL"); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("#endif"); |
| _builder.newLine(); |
| } |
| } |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private String genPortInitializer(final Root root, final ActorInstance ai, final InterfaceItemInstance pi) { |
| String _xblockexpression = null; |
| { |
| int _xifexpression = (int) 0; |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| boolean _isEmpty = _peers.isEmpty(); |
| if (_isEmpty) { |
| _xifexpression = 0; |
| } else { |
| EList<InterfaceItemInstance> _peers_1 = pi.getPeers(); |
| InterfaceItemInstance _get = _peers_1.get(0); |
| _xifexpression = _get.getObjId(); |
| } |
| final int objId = _xifexpression; |
| int _xifexpression_1 = (int) 0; |
| EList<InterfaceItemInstance> _peers_2 = pi.getPeers(); |
| boolean _isEmpty_1 = _peers_2.isEmpty(); |
| if (_isEmpty_1) { |
| _xifexpression_1 = 0; |
| } else { |
| EList<InterfaceItemInstance> _peers_3 = pi.getPeers(); |
| InterfaceItemInstance _get_1 = _peers_3.get(0); |
| EList<InterfaceItemInstance> _peers_4 = _get_1.getPeers(); |
| _xifexpression_1 = _peers_4.indexOf(pi); |
| } |
| final int idx = _xifexpression_1; |
| String _xifexpression_2 = null; |
| EList<InterfaceItemInstance> _peers_5 = pi.getPeers(); |
| boolean _isEmpty_2 = _peers_5.isEmpty(); |
| if (_isEmpty_2) { |
| _xifexpression_2 = "NULL"; |
| } else { |
| EList<InterfaceItemInstance> _peers_6 = pi.getPeers(); |
| InterfaceItemInstance _get_2 = _peers_6.get(0); |
| EObject _eContainer = _get_2.eContainer(); |
| ETMapUtil.MappedThread _mappedThread = ETMapUtil.getMappedThread(((ActorInstance) _eContainer)); |
| PhysicalThread _thread = _mappedThread.getThread(); |
| String _name = _thread.getName(); |
| _xifexpression_2 = ("&msgService_" + _name); |
| } |
| final String msgSvc = _xifexpression_2; |
| String myInst = ""; |
| String peerInst = ""; |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| EObject _eContainer_1 = pi.eContainer(); |
| String _path = ((ActorInstance) _eContainer_1).getPath(); |
| String _plus = ("\n#ifdef ET_ASYNC_MSC_LOGGER_ACTIVATE\n,\"" + _path); |
| String _plus_1 = (_plus + "\","); |
| myInst = _plus_1; |
| String _xifexpression_3 = null; |
| EList<InterfaceItemInstance> _peers_7 = pi.getPeers(); |
| boolean _isEmpty_3 = _peers_7.isEmpty(); |
| boolean _not = (!_isEmpty_3); |
| if (_not) { |
| EList<InterfaceItemInstance> _peers_8 = pi.getPeers(); |
| InterfaceItemInstance _get_3 = _peers_8.get(0); |
| EObject _eContainer_2 = _get_3.eContainer(); |
| String _path_1 = ((ActorInstance) _eContainer_2).getPath(); |
| String _plus_2 = ("\"" + _path_1); |
| _xifexpression_3 = (_plus_2 + "\"\n#endif\n"); |
| } else { |
| _xifexpression_3 = "\n#endif\n"; |
| } |
| peerInst = _xifexpression_3; |
| } |
| String _interfaceItemInstanceData = this.getInterfaceItemInstanceData(pi); |
| String _plus_3 = ("{" + _interfaceItemInstanceData); |
| String _plus_4 = (_plus_3 + ", "); |
| String _plus_5 = (_plus_4 + msgSvc); |
| String _plus_6 = (_plus_5 + ", "); |
| String _plus_7 = (_plus_6 + Integer.valueOf((objId + idx))); |
| String _plus_8 = (_plus_7 + "+BASE_ADDRESS, "); |
| ExpandedActorClass _expandedActorClass = root.getExpandedActorClass(ai); |
| InterfaceItem _interfaceItem = pi.getInterfaceItem(); |
| int _interfaceItemLocalId = _expandedActorClass.getInterfaceItemLocalId(_interfaceItem); |
| int _plus_9 = (_interfaceItemLocalId + 1); |
| String _plus_10 = (_plus_8 + Integer.valueOf(_plus_9)); |
| String _plus_11 = (_plus_10 + myInst); |
| String _plus_12 = (_plus_11 + peerInst); |
| String _plus_13 = (_plus_12 + "} /* Port "); |
| String _name_1 = pi.getName(); |
| String _plus_14 = (_plus_13 + _name_1); |
| _xblockexpression = (_plus_14 + " */"); |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence genSendPortInitializer(final InterfaceItemInstance pi) { |
| CharSequence _xblockexpression = null; |
| { |
| Port _port = ((PortInstance) pi).getPort(); |
| GeneralProtocolClass _protocol = _port.getProtocol(); |
| final ProtocolClass pc = ((ProtocolClass) _protocol); |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| return Boolean.valueOf((!Objects.equal(_data, null))); |
| } |
| }; |
| Iterable<Message> messages = IterableExtensions.<Message>filter(_allIncomingMessages, _function); |
| final Function1<Message, Boolean> _function_1 = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| return Boolean.valueOf(NodeGen.this._typeHelpers.isEnumeration(_type)); |
| } |
| }; |
| final Iterable<Message> enumMsgs = IterableExtensions.<Message>filter(messages, _function_1); |
| final Function1<Message, Boolean> _function_2 = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| return Boolean.valueOf(NodeGen.this._typeHelpers.isBoolean(_type)); |
| } |
| }; |
| final Iterable<Message> boolMsgs = IterableExtensions.<Message>filter(messages, _function_2); |
| final boolean usesMSC = (Main.getSettings().isGenerateMSCInstrumentation() && (!(IterableExtensions.isEmpty(enumMsgs) && IterableExtensions.isEmpty(boolMsgs)))); |
| EObject _eContainer = pi.eContainer(); |
| final String instName = ((ActorInstance) _eContainer).getPath(); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("{"); |
| _builder.newLine(); |
| { |
| EList<Message> _incomingMessages = pc.getIncomingMessages(); |
| boolean _hasElements = false; |
| for(final Message m : _incomingMessages) { |
| if (!_hasElements) { |
| _hasElements = true; |
| } else { |
| _builder.appendImmediate(",", "\t"); |
| } |
| _builder.append("\t"); |
| VarDecl _data = m.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| String _defaultValue = this._cExtensions.defaultValue(_type); |
| _builder.append(_defaultValue, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| { |
| if (usesMSC) { |
| _builder.append("\t"); |
| _builder.append("#ifdef ET_ASYNC_MSC_LOGGER_ACTIVATE"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append(", \""); |
| _builder.append(instName, "\t\t"); |
| _builder.append("\","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| String _path = pi.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| _builder.append(_pathName, "\t\t"); |
| _builder.append("_peers"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("#endif"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("} /* send port "); |
| String _name = pi.getName(); |
| _builder.append(_name, ""); |
| _builder.append(" */"); |
| _builder.newLineIfNotEmpty(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private String getInterfaceItemInstanceData(final InterfaceItemInstance pi) { |
| ProtocolClass _protocol = pi.getProtocol(); |
| boolean _isConjugated = this._roomExtensions.isConjugated(pi); |
| PortClass _portClass = this._roomExtensions.getPortClass(_protocol, _isConjugated); |
| boolean _equals = Objects.equal(_portClass, null); |
| if (_equals) { |
| return "NULL"; |
| } |
| ProtocolClass _protocol_1 = pi.getProtocol(); |
| boolean _isConjugated_1 = this._roomExtensions.isConjugated(pi); |
| PortClass _portClass_1 = this._roomExtensions.getPortClass(_protocol_1, _isConjugated_1); |
| EList<Attribute> _attributes = _portClass_1.getAttributes(); |
| boolean _isEmpty = _attributes.isEmpty(); |
| if (_isEmpty) { |
| return "NULL"; |
| } else { |
| String _path = pi.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| String _plus = ("&" + _pathName); |
| return (_plus + "_var"); |
| } |
| } |
| |
| private String genRecvPortInitializer(final Root root, final ActorInstance ai, final InterfaceItemInstance pi) { |
| String _xblockexpression = null; |
| { |
| InterfaceItem _interfaceItem = pi.getInterfaceItem(); |
| List<Message> _incoming = this._roomHelpers.getIncoming(_interfaceItem); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| return Boolean.valueOf((!Objects.equal(_data, null))); |
| } |
| }; |
| Iterable<Message> sentMsgs = IterableExtensions.<Message>filter(_incoming, _function); |
| final Function1<Message, Boolean> _function_1 = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| return Boolean.valueOf(NodeGen.this._typeHelpers.isEnumeration(_type)); |
| } |
| }; |
| final Iterable<Message> enumMsgs = IterableExtensions.<Message>filter(sentMsgs, _function_1); |
| final Function1<Message, Boolean> _function_2 = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| return Boolean.valueOf(NodeGen.this._typeHelpers.isBoolean(_type)); |
| } |
| }; |
| final Iterable<Message> boolMsgs = IterableExtensions.<Message>filter(sentMsgs, _function_2); |
| final boolean usesMSC = (Main.getSettings().isGenerateMSCInstrumentation() && (!(IterableExtensions.isEmpty(enumMsgs) && IterableExtensions.isEmpty(boolMsgs)))); |
| String enumVal = ""; |
| if (usesMSC) { |
| String _path = ai.getPath(); |
| String _plus = ("\n, \"" + _path); |
| String _plus_1 = (_plus + "\""); |
| enumVal = _plus_1; |
| for (final Message msg : enumMsgs) { |
| VarDecl _data = msg.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| String _defaultValue = this._cExtensions.defaultValue(_type); |
| String _plus_2 = ((enumVal + "\n, ") + _defaultValue); |
| enumVal = _plus_2; |
| } |
| for (final Message msg_1 : boolMsgs) { |
| VarDecl _data_1 = msg_1.getData(); |
| RefableType _refType_1 = _data_1.getRefType(); |
| DataType _type_1 = _refType_1.getType(); |
| String _defaultValue_1 = this._cExtensions.defaultValue(_type_1); |
| String _plus_3 = ((enumVal + "\n, ") + _defaultValue_1); |
| enumVal = _plus_3; |
| } |
| enumVal = (("\n#ifdef ET_ASYNC_MSC_LOGGER_ACTIVATE" + enumVal) + "\n#endif\n"); |
| } |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| boolean _isEmpty = _peers.isEmpty(); |
| if (_isEmpty) { |
| return (("{NULL" + enumVal) + "}"); |
| } |
| EList<InterfaceItemInstance> _peers_1 = pi.getPeers(); |
| InterfaceItemInstance peer = _peers_1.get(0); |
| EList<InterfaceItemInstance> _peers_2 = pi.getPeers(); |
| InterfaceItemInstance _get = _peers_2.get(0); |
| EObject _eContainer = _get.eContainer(); |
| ActorInstance peerInst = ((ActorInstance) _eContainer); |
| String _path_1 = peerInst.getPath(); |
| String instName = this._roomExtensions.getPathName(_path_1); |
| String _name = peer.getName(); |
| String _plus_4 = ((("{&" + instName) + ".") + _name); |
| String _plus_5 = (_plus_4 + enumVal); |
| _xblockexpression = (_plus_5 + "}"); |
| } |
| return _xblockexpression; |
| } |
| |
| private String genReplSubPortInitializers(final Root root, final ActorInstance ai, final InterfaceItemInstance pi) { |
| String result = ""; |
| String _xifexpression = null; |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| EObject _eContainer = pi.eContainer(); |
| String _path = ((ActorInstance) _eContainer).getPath(); |
| String _plus = ("\n#ifdef ET_ASYNC_MSC_LOGGER_ACTIVATE\n,\"" + _path); |
| _xifexpression = (_plus + "\"\n"); |
| } else { |
| _xifexpression = ""; |
| } |
| final String myInst = _xifexpression; |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| for (final InterfaceItemInstance p : _peers) { |
| { |
| EList<InterfaceItemInstance> _peers_1 = pi.getPeers(); |
| final int idx = _peers_1.indexOf(p); |
| String _xifexpression_1 = null; |
| EList<InterfaceItemInstance> _peers_2 = pi.getPeers(); |
| int _size = _peers_2.size(); |
| int _minus = (_size - 1); |
| boolean _lessThan = (idx < _minus); |
| if (_lessThan) { |
| _xifexpression_1 = ","; |
| } else { |
| _xifexpression_1 = ""; |
| } |
| final String comma = _xifexpression_1; |
| EObject _eContainer_1 = p.eContainer(); |
| ETMapUtil.MappedThread _mappedThread = ETMapUtil.getMappedThread(((ActorInstance) _eContainer_1)); |
| PhysicalThread _thread = _mappedThread.getThread(); |
| final String thread = _thread.getName(); |
| String iiiD = this.getInterfaceItemInstanceData(pi); |
| String _xifexpression_2 = null; |
| GlobalGeneratorSettings _settings_1 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_1 = _settings_1.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_1) { |
| EObject _eContainer_2 = p.eContainer(); |
| String _path_1 = ((ActorInstance) _eContainer_2).getPath(); |
| String _plus_1 = (",\"" + _path_1); |
| _xifexpression_2 = (_plus_1 + "\"\n#endif\n"); |
| } else { |
| _xifexpression_2 = ""; |
| } |
| final String peerInst = _xifexpression_2; |
| String _xifexpression_3 = null; |
| boolean _equals = iiiD.equals("NULL"); |
| if (_equals) { |
| _xifexpression_3 = (iiiD + ","); |
| } else { |
| _xifexpression_3 = (((iiiD + "[") + Integer.valueOf(idx)) + "],"); |
| } |
| iiiD = _xifexpression_3; |
| int _objId = p.getObjId(); |
| String _plus_2 = ((((((result + |
| "{{") + iiiD) + "&msgService_") + thread) + ", ") + Integer.valueOf(_objId)); |
| String _plus_3 = (_plus_2 + "+BASE_ADDRESS, "); |
| ExpandedActorClass _expandedActorClass = root.getExpandedActorClass(ai); |
| InterfaceItem _interfaceItem = pi.getInterfaceItem(); |
| int _interfaceItemLocalId = _expandedActorClass.getInterfaceItemLocalId(_interfaceItem); |
| int _plus_4 = (_interfaceItemLocalId + 1); |
| String _plus_5 = (_plus_3 + Integer.valueOf(_plus_4)); |
| String _plus_6 = (_plus_5 + myInst); |
| String _plus_7 = (_plus_6 + peerInst); |
| String _plus_8 = (_plus_7 + "},"); |
| String _plus_9 = (_plus_8 + Integer.valueOf(idx)); |
| String _plus_10 = (_plus_9 + "}"); |
| String _plus_11 = (_plus_10 + comma); |
| String _plus_12 = (_plus_11 + " /* Repl Sub Port "); |
| String _name = pi.getName(); |
| String _plus_13 = (_plus_12 + _name); |
| String _plus_14 = (_plus_13 + " idx +"); |
| String _plus_15 = (_plus_14 + Integer.valueOf(idx)); |
| String _plus_16 = (_plus_15 + "*/\n"); |
| result = _plus_16; |
| } |
| } |
| return result; |
| } |
| |
| private CharSequence generateDispatcherFile(final Root root, final SubSystemInstance ssi, final Collection<PhysicalThread> usedThreads) { |
| CharSequence _xblockexpression = null; |
| { |
| final NodeRef nr = ETMapUtil.getNodeRef(ssi); |
| final boolean logData = (Main.getSettings().isGenerateDataInstrumentation() && this._roomHelpers.isAnnotationPresent(ssi.getSubSystemClass().getAnnotations(), "DataLogging")); |
| ArrayList<PortInstance> _xifexpression = null; |
| if (logData) { |
| _xifexpression = this.loggedPorts(ssi); |
| } else { |
| _xifexpression = CollectionLiterals.<PortInstance>newArrayList(); |
| } |
| final ArrayList<PortInstance> loggedPorts = _xifexpression; |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* @author generated by eTrice"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* Dispatcher File of Node "); |
| String _name = nr.getName(); |
| _builder.append(_name, " "); |
| _builder.append(" with SubSystem "); |
| String _name_1 = ssi.getName(); |
| _builder.append(_name_1, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("* contains a generated message dispatcher (receiveMessage) for each MessageService (Thread)"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include \"messaging/etMessageReceiver.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"debugging/etLogger.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"debugging/etMSCLogger.h\""); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| NodeClass _type = nr.getType(); |
| EList<PhysicalThread> _threads = _type.getThreads(); |
| final Function1<PhysicalThread, Boolean> _function = new Function1<PhysicalThread, Boolean>() { |
| @Override |
| public Boolean apply(final PhysicalThread t) { |
| return Boolean.valueOf(usedThreads.contains(t)); |
| } |
| }; |
| Iterable<PhysicalThread> _filter = IterableExtensions.<PhysicalThread>filter(_threads, _function); |
| boolean _hasElements = false; |
| for(final PhysicalThread thread : _filter) { |
| if (!_hasElements) { |
| _hasElements = true; |
| } else { |
| _builder.appendImmediate("\n", ""); |
| } |
| EList<ActorInstance> _allContainedInstances = ssi.getAllContainedInstances(); |
| final Function1<ActorInstance, Boolean> _function_1 = new Function1<ActorInstance, Boolean>() { |
| @Override |
| public Boolean apply(final ActorInstance ai) { |
| ETMapUtil.MappedThread _mappedThread = ETMapUtil.getMappedThread(ai); |
| PhysicalThread _thread = _mappedThread.getThread(); |
| return Boolean.valueOf(Objects.equal(_thread, thread)); |
| } |
| }; |
| final Iterable<ActorInstance> instancesOnThread = IterableExtensions.<ActorInstance>filter(_allContainedInstances, _function_1); |
| _builder.newLineIfNotEmpty(); |
| final Function1<ActorInstance, Boolean> _function_2 = new Function1<ActorInstance, Boolean>() { |
| @Override |
| public Boolean apply(final ActorInstance ai) { |
| return Boolean.valueOf((Objects.equal(ai.getActorClass().getCommType(), ComponentCommunicationType.EVENT_DRIVEN) || Objects.equal(ai.getActorClass().getCommType(), ComponentCommunicationType.ASYNCHRONOUS))); |
| } |
| }; |
| final Iterable<ActorInstance> dispatchedInstances = IterableExtensions.<ActorInstance>filter(instancesOnThread, _function_2); |
| _builder.newLineIfNotEmpty(); |
| final Function1<ActorInstance, Boolean> _function_3 = new Function1<ActorInstance, Boolean>() { |
| @Override |
| public Boolean apply(final ActorInstance ai) { |
| return Boolean.valueOf((Objects.equal(ai.getActorClass().getCommType(), ComponentCommunicationType.DATA_DRIVEN) || Objects.equal(ai.getActorClass().getCommType(), ComponentCommunicationType.ASYNCHRONOUS))); |
| } |
| }; |
| final Iterable<ActorInstance> executedInstances = IterableExtensions.<ActorInstance>filter(instancesOnThread, _function_3); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| int _size = IterableExtensions.size(executedInstances); |
| boolean _greaterThan = (_size > 0); |
| if (_greaterThan) { |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* generated execute function for all cyclic execute calls for the async or datadriven actor instances of thread \""); |
| String _name_2 = thread.getName(); |
| _builder.append(_name_2, " "); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.append("static void MsgDispatcher_"); |
| String _name_3 = thread.getName(); |
| _builder.append(_name_3, ""); |
| _builder.append("_poll(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\"MsgDispatcher_"); |
| String _name_4 = thread.getName(); |
| _builder.append(_name_4, "\t"); |
| _builder.append("\", \"execute\")"); |
| _builder.newLineIfNotEmpty(); |
| { |
| for(final ActorInstance ai : executedInstances) { |
| _builder.append("\t"); |
| ActorClass _actorClass = ai.getActorClass(); |
| String _name_5 = _actorClass.getName(); |
| _builder.append(_name_5, "\t"); |
| _builder.append("_execute((void*)&"); |
| String _path = ai.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| _builder.append(_pathName, "\t"); |
| _builder.append(");"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| { |
| if (logData) { |
| _builder.append("static void MsgDispatcher_"); |
| String _name_6 = thread.getName(); |
| _builder.append(_name_6, ""); |
| _builder.append("_logDataHeaders(void){"); |
| _builder.newLineIfNotEmpty(); |
| { |
| for(final PortInstance pi : loggedPorts) { |
| _builder.append("\t"); |
| _builder.append("ET_DATA_LOGGER_LOG_STRING(\""); |
| String _path_1 = pi.getPath(); |
| _builder.append(_path_1, "\t"); |
| _builder.append("\")"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("static void MsgDispatcher_"); |
| String _name_7 = thread.getName(); |
| _builder.append(_name_7, ""); |
| _builder.append("_logData(void){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_DATA_LOGGER_NEW_ROW"); |
| _builder.newLine(); |
| { |
| for(final PortInstance pi_1 : loggedPorts) { |
| _builder.append("\t"); |
| String _createLoggerCall = this.createLoggerCall(pi_1); |
| _builder.append(_createLoggerCall, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| _builder.append("/**"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("* generated dispatch function for all messages for the thread \""); |
| String _name_8 = thread.getName(); |
| _builder.append(_name_8, " "); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.append("static etBool MsgDispatcher_"); |
| String _name_9 = thread.getName(); |
| _builder.append(_name_9, ""); |
| _builder.append("_receiveMessage(const etMessage* msg){"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\"MsgDispatcher_"); |
| String _name_10 = thread.getName(); |
| _builder.append(_name_10, "\t"); |
| _builder.append("\", \"receiveMessage\")"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("switch(msg->address){"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("case MESSAGESERVICE_ADDRESS:"); |
| _builder.newLine(); |
| { |
| boolean _isEmpty = IterableExtensions.isEmpty(executedInstances); |
| boolean _not = (!_isEmpty); |
| if (_not) { |
| _builder.append("\t\t\t"); |
| _builder.append("if (msg->evtID == etSystemProtocol_IN_poll) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("\t"); |
| _builder.append("MsgDispatcher_"); |
| String _name_11 = thread.getName(); |
| _builder.append(_name_11, "\t\t\t\t"); |
| _builder.append("_poll();"); |
| _builder.newLineIfNotEmpty(); |
| { |
| if (logData) { |
| _builder.append("\t\t\t"); |
| _builder.append("\t"); |
| _builder.append("MsgDispatcher_"); |
| String _name_12 = thread.getName(); |
| _builder.append(_name_12, "\t\t\t\t"); |
| _builder.append("_logData();"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("else"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t\t\t"); |
| _builder.append("if (msg->evtID == etSystemProtocol_IN_terminate)"); |
| _builder.newLine(); |
| _builder.append("\t\t\t\t"); |
| _builder.append("return ET_FALSE;"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| { |
| for(final ActorInstance ai_1 : dispatchedInstances) { |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("/* interface items of "); |
| String _path_2 = ai_1.getPath(); |
| _builder.append(_path_2, "\t\t"); |
| _builder.append(" */"); |
| _builder.newLineIfNotEmpty(); |
| { |
| EList<InterfaceItemInstance> _orderedIfItemInstances = ai_1.getOrderedIfItemInstances(); |
| final Function1<InterfaceItemInstance, Boolean> _function_4 = new Function1<InterfaceItemInstance, Boolean>() { |
| @Override |
| public Boolean apply(final InterfaceItemInstance p) { |
| ProtocolClass _protocol = p.getProtocol(); |
| CommunicationType _commType = _protocol.getCommType(); |
| return Boolean.valueOf(Objects.equal(_commType, CommunicationType.EVENT_DRIVEN)); |
| } |
| }; |
| Iterable<InterfaceItemInstance> _filter_1 = IterableExtensions.<InterfaceItemInstance>filter(_orderedIfItemInstances, _function_4); |
| for(final InterfaceItemInstance pi_2 : _filter_1) { |
| { |
| boolean _isReplicated = pi_2.isReplicated(); |
| if (_isReplicated) { |
| { |
| EList<InterfaceItemInstance> _peers = pi_2.getPeers(); |
| for(final InterfaceItemInstance peer : _peers) { |
| _builder.append("\t\t"); |
| _builder.append("case "); |
| int _objId = pi_2.getObjId(); |
| EList<InterfaceItemInstance> _peers_1 = pi_2.getPeers(); |
| int _indexOf = _peers_1.indexOf(peer); |
| int _plus = (_objId + _indexOf); |
| _builder.append(_plus, "\t\t"); |
| _builder.append("+BASE_ADDRESS:"); |
| _builder.newLineIfNotEmpty(); |
| { |
| ProtocolClass _protocol = pi_2.getProtocol(); |
| boolean _isConjugated = this._roomExtensions.isConjugated(pi_2); |
| boolean _handlesReceive = this._roomExtensions.handlesReceive(_protocol, _isConjugated); |
| if (_handlesReceive) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("switch (msg->evtID){"); |
| _builder.newLine(); |
| { |
| ProtocolClass _protocol_1 = pi_2.getProtocol(); |
| boolean _isConjugated_1 = this._roomExtensions.isConjugated(pi_2); |
| List<MessageHandler> _receiveHandlers = this._roomExtensions.getReceiveHandlers(_protocol_1, _isConjugated_1); |
| for(final MessageHandler h : _receiveHandlers) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("case "); |
| ProtocolClass _protocol_2 = pi_2.getProtocol(); |
| String _name_13 = _protocol_2.getName(); |
| _builder.append(_name_13, "\t\t\t\t"); |
| _builder.append("_"); |
| Message _msg = h.getMsg(); |
| String _codeName = this._roomExtensions.getCodeName(_msg); |
| _builder.append(_codeName, "\t\t\t\t"); |
| _builder.append(":"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| ProtocolClass _protocol_3 = pi_2.getProtocol(); |
| boolean _isConjugated_2 = this._roomExtensions.isConjugated(pi_2); |
| String _portClassName = this._roomExtensions.getPortClassName(_protocol_3, _isConjugated_2); |
| _builder.append(_portClassName, "\t\t\t\t\t"); |
| _builder.append("_"); |
| Message _msg_1 = h.getMsg(); |
| String _name_14 = _msg_1.getName(); |
| _builder.append(_name_14, "\t\t\t\t\t"); |
| _builder.append("_receiveHandler((etPort *)&"); |
| String _path_3 = ai_1.getPath(); |
| String _pathName_1 = this._roomExtensions.getPathName(_path_3); |
| _builder.append(_pathName_1, "\t\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_15 = pi_2.getName(); |
| _builder.append(_name_15, "\t\t\t\t\t"); |
| _builder.append(".ports["); |
| EList<InterfaceItemInstance> _peers_2 = pi_2.getPeers(); |
| int _indexOf_1 = _peers_2.indexOf(peer); |
| _builder.append(_indexOf_1, "\t\t\t\t\t"); |
| _builder.append("],msg,(void*)&"); |
| String _path_4 = ai_1.getPath(); |
| String _pathName_2 = this._roomExtensions.getPathName(_path_4); |
| _builder.append(_pathName_2, "\t\t\t\t\t"); |
| _builder.append(","); |
| ActorClass _actorClass_1 = ai_1.getActorClass(); |
| String _name_16 = _actorClass_1.getName(); |
| _builder.append(_name_16, "\t\t\t\t\t"); |
| _builder.append("_receiveMessage);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("default: "); |
| ActorClass _actorClass_2 = ai_1.getActorClass(); |
| String _name_17 = _actorClass_2.getName(); |
| _builder.append(_name_17, "\t\t\t\t"); |
| _builder.append("_receiveMessage((void*)&"); |
| String _path_5 = ai_1.getPath(); |
| String _pathName_3 = this._roomExtensions.getPathName(_path_5); |
| _builder.append(_pathName_3, "\t\t\t\t"); |
| _builder.append(",(etPort*)&"); |
| String _path_6 = ai_1.getPath(); |
| String _pathName_4 = this._roomExtensions.getPathName(_path_6); |
| _builder.append(_pathName_4, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_18 = pi_2.getName(); |
| _builder.append(_name_18, "\t\t\t\t"); |
| _builder.append(".ports["); |
| EList<InterfaceItemInstance> _peers_3 = pi_2.getPeers(); |
| int _indexOf_2 = _peers_3.indexOf(peer); |
| _builder.append(_indexOf_2, "\t\t\t\t"); |
| _builder.append("], msg);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| } else { |
| { |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_ASYNC_IN("); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| String _path_7 = ai_1.getPath(); |
| String _pathName_5 = this._roomExtensions.getPathName(_path_7); |
| _builder.append(_pathName_5, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_19 = pi_2.getName(); |
| _builder.append(_name_19, "\t\t\t\t"); |
| _builder.append(".ports["); |
| EList<InterfaceItemInstance> _peers_4 = pi_2.getPeers(); |
| int _indexOf_3 = _peers_4.indexOf(peer); |
| _builder.append(_indexOf_3, "\t\t\t\t"); |
| _builder.append("].port.peerInstName,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| ProtocolClass _protocol_4 = pi_2.getProtocol(); |
| String _name_20 = _protocol_4.getName(); |
| _builder.append(_name_20, "\t\t\t\t"); |
| _builder.append("_getMessageString(msg->evtID),"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| String _path_8 = ai_1.getPath(); |
| String _pathName_6 = this._roomExtensions.getPathName(_path_8); |
| _builder.append(_pathName_6, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_21 = pi_2.getName(); |
| _builder.append(_name_21, "\t\t\t\t"); |
| _builder.append(".ports["); |
| EList<InterfaceItemInstance> _peers_5 = pi_2.getPeers(); |
| int _indexOf_4 = _peers_5.indexOf(peer); |
| _builder.append(_indexOf_4, "\t\t\t\t"); |
| _builder.append("].port.myInstName"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append(")"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| ActorClass _actorClass_3 = ai_1.getActorClass(); |
| String _name_22 = _actorClass_3.getName(); |
| _builder.append(_name_22, "\t\t\t"); |
| _builder.append("_receiveMessage((void*)&"); |
| String _path_9 = ai_1.getPath(); |
| String _pathName_7 = this._roomExtensions.getPathName(_path_9); |
| _builder.append(_pathName_7, "\t\t\t"); |
| _builder.append(",&"); |
| String _path_10 = ai_1.getPath(); |
| String _pathName_8 = this._roomExtensions.getPathName(_path_10); |
| _builder.append(_pathName_8, "\t\t\t"); |
| _builder.append("_const."); |
| String _name_23 = pi_2.getName(); |
| _builder.append(_name_23, "\t\t\t"); |
| _builder.append(".ports["); |
| EList<InterfaceItemInstance> _peers_6 = pi_2.getPeers(); |
| int _indexOf_5 = _peers_6.indexOf(peer); |
| _builder.append(_indexOf_5, "\t\t\t"); |
| _builder.append("].port, msg);"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| } |
| } |
| } else { |
| _builder.append("\t\t"); |
| _builder.append("case "); |
| int _objId_1 = pi_2.getObjId(); |
| _builder.append(_objId_1, "\t\t"); |
| _builder.append("+BASE_ADDRESS:"); |
| _builder.newLineIfNotEmpty(); |
| { |
| ProtocolClass _protocol_5 = pi_2.getProtocol(); |
| boolean _isConjugated_3 = this._roomExtensions.isConjugated(pi_2); |
| boolean _handlesReceive_1 = this._roomExtensions.handlesReceive(_protocol_5, _isConjugated_3); |
| if (_handlesReceive_1) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("switch (msg->evtID){"); |
| _builder.newLine(); |
| { |
| ProtocolClass _protocol_6 = pi_2.getProtocol(); |
| boolean _isConjugated_4 = this._roomExtensions.isConjugated(pi_2); |
| List<MessageHandler> _receiveHandlers_1 = this._roomExtensions.getReceiveHandlers(_protocol_6, _isConjugated_4); |
| for(final MessageHandler h_1 : _receiveHandlers_1) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("case "); |
| ProtocolClass _protocol_7 = pi_2.getProtocol(); |
| String _name_24 = _protocol_7.getName(); |
| _builder.append(_name_24, "\t\t\t\t"); |
| _builder.append("_"); |
| Message _msg_2 = h_1.getMsg(); |
| String _codeName_1 = this._roomExtensions.getCodeName(_msg_2); |
| _builder.append(_codeName_1, "\t\t\t\t"); |
| _builder.append(":"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| ProtocolClass _protocol_8 = pi_2.getProtocol(); |
| boolean _isConjugated_5 = this._roomExtensions.isConjugated(pi_2); |
| String _portClassName_1 = this._roomExtensions.getPortClassName(_protocol_8, _isConjugated_5); |
| _builder.append(_portClassName_1, "\t\t\t\t\t"); |
| _builder.append("_"); |
| Message _msg_3 = h_1.getMsg(); |
| String _name_25 = _msg_3.getName(); |
| _builder.append(_name_25, "\t\t\t\t\t"); |
| _builder.append("_receiveHandler((etPort *)&"); |
| String _path_11 = ai_1.getPath(); |
| String _pathName_9 = this._roomExtensions.getPathName(_path_11); |
| _builder.append(_pathName_9, "\t\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_26 = pi_2.getName(); |
| _builder.append(_name_26, "\t\t\t\t\t"); |
| _builder.append(",msg,(void*)&"); |
| String _path_12 = ai_1.getPath(); |
| String _pathName_10 = this._roomExtensions.getPathName(_path_12); |
| _builder.append(_pathName_10, "\t\t\t\t\t"); |
| _builder.append(","); |
| ActorClass _actorClass_4 = ai_1.getActorClass(); |
| String _name_27 = _actorClass_4.getName(); |
| _builder.append(_name_27, "\t\t\t\t\t"); |
| _builder.append("_receiveMessage);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("default: "); |
| ActorClass _actorClass_5 = ai_1.getActorClass(); |
| String _name_28 = _actorClass_5.getName(); |
| _builder.append(_name_28, "\t\t\t\t"); |
| _builder.append("_receiveMessage((void*)&"); |
| String _path_13 = ai_1.getPath(); |
| String _pathName_11 = this._roomExtensions.getPathName(_path_13); |
| _builder.append(_pathName_11, "\t\t\t\t"); |
| _builder.append(",(etPort*)&"); |
| String _path_14 = ai_1.getPath(); |
| String _pathName_12 = this._roomExtensions.getPathName(_path_14); |
| _builder.append(_pathName_12, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_29 = pi_2.getName(); |
| _builder.append(_name_29, "\t\t\t\t"); |
| _builder.append(", msg);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| } else { |
| { |
| GlobalGeneratorSettings _settings_1 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_1 = _settings_1.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_1) { |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_ASYNC_IN("); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("((etPort*)&"); |
| String _path_15 = ai_1.getPath(); |
| String _pathName_13 = this._roomExtensions.getPathName(_path_15); |
| _builder.append(_pathName_13, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_30 = pi_2.getName(); |
| _builder.append(_name_30, "\t\t\t\t"); |
| _builder.append(")->peerInstName,"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| ProtocolClass _protocol_9 = pi_2.getProtocol(); |
| String _name_31 = _protocol_9.getName(); |
| _builder.append(_name_31, "\t\t\t\t"); |
| _builder.append("_getMessageString(msg->evtID),"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("((etPort*)&"); |
| String _path_16 = ai_1.getPath(); |
| String _pathName_14 = this._roomExtensions.getPathName(_path_16); |
| _builder.append(_pathName_14, "\t\t\t\t"); |
| _builder.append("_const."); |
| String _name_32 = pi_2.getName(); |
| _builder.append(_name_32, "\t\t\t\t"); |
| _builder.append(")->myInstName"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append(")"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| ActorClass _actorClass_6 = ai_1.getActorClass(); |
| String _name_33 = _actorClass_6.getName(); |
| _builder.append(_name_33, "\t\t\t"); |
| _builder.append("_receiveMessage((void*)&"); |
| String _path_17 = ai_1.getPath(); |
| String _pathName_15 = this._roomExtensions.getPathName(_path_17); |
| _builder.append(_pathName_15, "\t\t\t"); |
| _builder.append(",(etPort*)&"); |
| String _path_18 = ai_1.getPath(); |
| String _pathName_16 = this._roomExtensions.getPathName(_path_18); |
| _builder.append(_pathName_16, "\t\t\t"); |
| _builder.append("_const."); |
| String _name_34 = pi_2.getName(); |
| _builder.append(_name_34, "\t\t\t"); |
| _builder.append(", msg);"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t\t"); |
| _builder.append("\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| } |
| } |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("default:"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("etLogger_logErrorF(\"MessageService_"); |
| String _name_35 = thread.getName(); |
| _builder.append(_name_35, "\t\t\t"); |
| _builder.append("_receiveMessage: address %d does not exist \", msg->address);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("ET_MSC_LOGGER_SYNC_EXIT"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("return ET_TRUE;"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private String createLoggerCall(final PortInstance pi) { |
| String _xblockexpression = null; |
| { |
| ProtocolClass _protocol = pi.getProtocol(); |
| EList<Message> _incomingMessages = _protocol.getIncomingMessages(); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| return Boolean.valueOf(((!Objects.equal(m.getData(), null)) && NodeGen.this._typeHelpers.isEnumerationOrPrimitive(m.getData().getRefType().getType()))); |
| } |
| }; |
| Iterable<Message> _filter = IterableExtensions.<Message>filter(_incomingMessages, _function); |
| final Message msg = ((Message[])Conversions.unwrapArray(_filter, Message.class))[0]; |
| EObject _eContainer = pi.eContainer(); |
| final ActorInstance ai = ((ActorInstance) _eContainer); |
| String _path = ai.getPath(); |
| String _pathName = this._roomExtensions.getPathName(_path); |
| String _plus = (_pathName + "."); |
| String _name = pi.getName(); |
| String _plus_1 = (_plus + _name); |
| String _plus_2 = (_plus_1 + "."); |
| String _name_1 = msg.getName(); |
| final String data = (_plus_2 + _name_1); |
| LiteralType _xifexpression = null; |
| VarDecl _data = msg.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| if ((_type instanceof EnumerationType)) { |
| _xifexpression = LiteralType.INT; |
| } else { |
| VarDecl _data_1 = msg.getData(); |
| RefableType _refType_1 = _data_1.getRefType(); |
| DataType _type_1 = _refType_1.getType(); |
| _xifexpression = ((PrimitiveType) _type_1).getType(); |
| } |
| final LiteralType type = _xifexpression; |
| String _switchResult = null; |
| if (type != null) { |
| switch (type) { |
| case BOOL: |
| _switchResult = (("ET_DATA_LOGGER_LOG_BOOL((int)" + data) + ")"); |
| break; |
| case CHAR: |
| _switchResult = (("ET_DATA_LOGGER_LOG_INT((int)" + data) + ")"); |
| break; |
| case INT: |
| _switchResult = (("ET_DATA_LOGGER_LOG_INT((int)" + data) + ")"); |
| break; |
| case REAL: |
| _switchResult = (("ET_DATA_LOGGER_LOG_DOUBLE((double)" + data) + ")"); |
| break; |
| default: |
| _switchResult = "internal error: unknown primitive type"; |
| break; |
| } |
| } else { |
| _switchResult = "internal error: unknown primitive type"; |
| } |
| _xblockexpression = _switchResult; |
| } |
| return _xblockexpression; |
| } |
| |
| private ArrayList<PortInstance> loggedPorts(final SubSystemInstance ssi) { |
| final ArrayList<PortInstance> result = CollectionLiterals.<PortInstance>newArrayList(); |
| SubSystemClass _subSystemClass = ssi.getSubSystemClass(); |
| EList<Annotation> _annotations = _subSystemClass.getAnnotations(); |
| boolean _isAnnotationPresent = this._roomHelpers.isAnnotationPresent(_annotations, "DataLogging"); |
| if (_isAnnotationPresent) { |
| this.logger.logInfo("Data Logging is configured by annotation"); |
| SubSystemClass _subSystemClass_1 = ssi.getSubSystemClass(); |
| EList<Annotation> _annotations_1 = _subSystemClass_1.getAnnotations(); |
| final String filters = this._roomHelpers.getAttribute(_annotations_1, "DataLogging", "pathlist"); |
| final String[] filterList = filters.split(","); |
| for (final String filter : filterList) { |
| this.logger.logInfo((" filter: " + filter)); |
| } |
| final ArrayList<String> notLogged = CollectionLiterals.<String>newArrayList(); |
| this.logger.logInfo(" logged ports:"); |
| TreeIterator<EObject> iter = ssi.eAllContents(); |
| while (iter.hasNext()) { |
| { |
| final EObject obj = iter.next(); |
| if ((obj instanceof PortInstance)) { |
| final PortInstance pi = ((PortInstance) obj); |
| Port _port = pi.getPort(); |
| boolean _isRelay = this._roomHelpers.isRelay(_port); |
| boolean _not = (!_isRelay); |
| if (_not) { |
| ProtocolClass _protocol = pi.getProtocol(); |
| CommunicationType _commType = _protocol.getCommType(); |
| boolean _equals = Objects.equal(_commType, CommunicationType.DATA_DRIVEN); |
| if (_equals) { |
| Port _port_1 = pi.getPort(); |
| boolean _isConjugated = _port_1.isConjugated(); |
| if (_isConjugated) { |
| final String path = pi.getPath(); |
| boolean matched = false; |
| boolean primitive = false; |
| for (final String filter_1 : filterList) { |
| boolean _matches = path.matches(filter_1); |
| if (_matches) { |
| matched = true; |
| ProtocolClass _protocol_1 = pi.getProtocol(); |
| EList<Message> _incomingMessages = _protocol_1.getIncomingMessages(); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| @Override |
| public Boolean apply(final Message m) { |
| return Boolean.valueOf(((!Objects.equal(m.getData(), null)) && NodeGen.this._typeHelpers.isEnumerationOrPrimitive(m.getData().getRefType().getType()))); |
| } |
| }; |
| Iterable<Message> _filter = IterableExtensions.<Message>filter(_incomingMessages, _function); |
| boolean _isEmpty = IterableExtensions.isEmpty(_filter); |
| boolean _not_1 = (!_isEmpty); |
| if (_not_1) { |
| result.add(pi); |
| primitive = true; |
| String _path = pi.getPath(); |
| String _plus = (" data driven port " + _path); |
| String _plus_1 = (_plus + " (matched "); |
| String _plus_2 = (_plus_1 + filter_1); |
| String _plus_3 = (_plus_2 + ")"); |
| this.logger.logInfo(_plus_3); |
| } |
| } |
| } |
| if ((!primitive)) { |
| if (matched) { |
| String _path_1 = pi.getPath(); |
| String _plus_4 = (" data driven port " + _path_1); |
| String _plus_5 = (_plus_4 + " (matched but contains no primitive data)"); |
| notLogged.add(_plus_5); |
| } else { |
| String _path_2 = pi.getPath(); |
| String _plus_6 = (" data driven port " + _path_2); |
| String _plus_7 = (_plus_6 + " (no match found)"); |
| notLogged.add(_plus_7); |
| } |
| } |
| } else { |
| String _path_3 = pi.getPath(); |
| String _plus_8 = (" data driven port " + _path_3); |
| String _plus_9 = (_plus_8 + " (receive port)"); |
| notLogged.add(_plus_9); |
| } |
| } |
| } |
| } |
| } |
| } |
| this.logger.logInfo(" NOT logged ports:"); |
| for (final String nl : notLogged) { |
| this.logger.logInfo(nl); |
| } |
| } |
| return result; |
| } |
| |
| private void checkDataPorts(final SubSystemInstance comp) { |
| final HashSet<String> found = new HashSet<String>(); |
| EList<ActorInstance> _allContainedInstances = comp.getAllContainedInstances(); |
| for (final ActorInstance ai : _allContainedInstances) { |
| { |
| final int thread = ai.getThreadId(); |
| EList<InterfaceItemInstance> _orderedIfItemInstances = ai.getOrderedIfItemInstances(); |
| for (final InterfaceItemInstance pi : _orderedIfItemInstances) { |
| ProtocolClass _protocol = pi.getProtocol(); |
| CommunicationType _commType = _protocol.getCommType(); |
| boolean _equals = Objects.equal(_commType, CommunicationType.DATA_DRIVEN); |
| if (_equals) { |
| EList<InterfaceItemInstance> _peers = pi.getPeers(); |
| for (final InterfaceItemInstance peer : _peers) { |
| { |
| EObject _eContainer = peer.eContainer(); |
| final ActorInstance peer_ai = ((ActorInstance) _eContainer); |
| final int peer_thread = peer_ai.getThreadId(); |
| if ((thread != peer_thread)) { |
| final String path = pi.getPath(); |
| final String ppath = peer.getPath(); |
| String _xifexpression = null; |
| int _compareTo = path.compareTo(ppath); |
| boolean _lessThan = (_compareTo < 0); |
| if (_lessThan) { |
| _xifexpression = ((path + " and ") + ppath); |
| } else { |
| _xifexpression = ((ppath + " and ") + path); |
| } |
| final String pair = _xifexpression; |
| boolean _contains = found.contains(pair); |
| boolean _not = (!_contains); |
| if (_not) { |
| found.add(pair); |
| InterfaceItem _interfaceItem = pi.getInterfaceItem(); |
| InterfaceItem _interfaceItem_1 = pi.getInterfaceItem(); |
| EStructuralFeature _eContainingFeature = _interfaceItem_1.eContainingFeature(); |
| this.diagnostician.error((pair + ": data ports placed on different threads (not supported yet)"), _interfaceItem, _eContainingFeature); |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
| } |
