| /** |
| * Copyright (c) 2011 Draeger Medical GmbH (http://www.draeger.com). |
| * 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: |
| * Peter Karlitschek (initial contribution) |
| */ |
| package org.eclipse.etrice.generator.cpp.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.List; |
| import org.eclipse.emf.common.util.EList; |
| import org.eclipse.etrice.core.fsm.fSM.DetailCode; |
| import org.eclipse.etrice.core.genmodel.etricegen.Root; |
| import org.eclipse.etrice.core.genmodel.fsm.base.ILogger; |
| import org.eclipse.etrice.core.room.Attribute; |
| import org.eclipse.etrice.core.room.CommunicationType; |
| import org.eclipse.etrice.core.room.DataClass; |
| import org.eclipse.etrice.core.room.DataType; |
| 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.PortOperation; |
| import org.eclipse.etrice.core.room.ProtocolClass; |
| import org.eclipse.etrice.core.room.RefableType; |
| import org.eclipse.etrice.core.room.RoomModel; |
| import org.eclipse.etrice.core.room.SAP; |
| import org.eclipse.etrice.core.room.SPP; |
| import org.eclipse.etrice.core.room.VarDecl; |
| import org.eclipse.etrice.generator.base.GlobalGeneratorSettings; |
| import org.eclipse.etrice.generator.cpp.Main; |
| import org.eclipse.etrice.generator.cpp.gen.CppExtensions; |
| import org.eclipse.etrice.generator.cpp.gen.Initialization; |
| import org.eclipse.etrice.generator.fsm.base.FileSystemHelpers; |
| import org.eclipse.etrice.generator.fsm.base.IGeneratorFileIo; |
| import org.eclipse.etrice.generator.generic.GenericProtocolClassGenerator; |
| 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.Extension; |
| import org.eclipse.xtext.xbase.lib.Functions.Function1; |
| import org.eclipse.xtext.xbase.lib.IterableExtensions; |
| import org.eclipse.xtext.xbase.lib.ListExtensions; |
| |
| @Singleton |
| @SuppressWarnings("all") |
| public class ProtocolClassGen extends GenericProtocolClassGenerator { |
| @Inject |
| private IGeneratorFileIo fileIO; |
| |
| @Inject |
| @Extension |
| private CppExtensions stdExt; |
| |
| @Inject |
| @Extension |
| private RoomExtensions roomExt; |
| |
| @Inject |
| @Extension |
| private ProcedureHelpers helpers; |
| |
| @Inject |
| @Extension |
| private TypeHelpers _typeHelpers; |
| |
| @Inject |
| @Extension |
| private FileSystemHelpers _fileSystemHelpers; |
| |
| @Inject |
| private Initialization initHelper; |
| |
| @Inject |
| private ILogger logger; |
| |
| public void doGenerate(final Root root) { |
| EList<ProtocolClass> _usedProtocolClasses = root.getUsedProtocolClasses(); |
| final Function1<ProtocolClass, Boolean> _function = new Function1<ProtocolClass, Boolean>() { |
| public Boolean apply(final ProtocolClass cl) { |
| return Boolean.valueOf(ProtocolClassGen.this._fileSystemHelpers.isValidGenerationLocation(cl)); |
| } |
| }; |
| Iterable<ProtocolClass> _filter = IterableExtensions.<ProtocolClass>filter(_usedProtocolClasses, _function); |
| for (final ProtocolClass pc : _filter) { |
| { |
| String _generationTargetPath = this.roomExt.getGenerationTargetPath(pc); |
| String _path = this.roomExt.getPath(pc); |
| final String path = (_generationTargetPath + _path); |
| String _generationInfoPath = this.roomExt.getGenerationInfoPath(pc); |
| String _path_1 = this.roomExt.getPath(pc); |
| final String infopath = (_generationInfoPath + _path_1); |
| CommunicationType _commType = pc.getCommType(); |
| if (_commType != null) { |
| switch (_commType) { |
| case EVENT_DRIVEN: |
| String _cppHeaderFileName = this.stdExt.getCppHeaderFileName(pc); |
| CharSequence _generateHeaderFile = this.generateHeaderFile(root, pc); |
| this.fileIO.generateFile("generating ProtocolClass declaration", path, infopath, _cppHeaderFileName, _generateHeaderFile); |
| String _cppSourceFileName = this.stdExt.getCppSourceFileName(pc); |
| CharSequence _generateSourceFile = this.generateSourceFile(root, pc); |
| this.fileIO.generateFile("generating ProtocolClass implementation", path, infopath, _cppSourceFileName, _generateSourceFile); |
| break; |
| case DATA_DRIVEN: |
| String _cppHeaderFileName_1 = this.stdExt.getCppHeaderFileName(pc); |
| CharSequence _generateDataDrivenHeaderFile = this.generateDataDrivenHeaderFile(root, pc); |
| this.fileIO.generateFile("generating ProtocolClass declaration", path, infopath, _cppHeaderFileName_1, _generateDataDrivenHeaderFile); |
| String _cppSourceFileName_1 = this.stdExt.getCppSourceFileName(pc); |
| CharSequence _generateDataDrivenSourceFile = this.generateDataDrivenSourceFile(root, pc); |
| this.fileIO.generateFile("generating ProtocolClass implementation", path, infopath, _cppSourceFileName_1, _generateDataDrivenSourceFile); |
| break; |
| case SYNCHRONOUS: |
| this.logger.logError("synchronous protocols not supported yet", pc); |
| break; |
| default: |
| break; |
| } |
| } |
| } |
| } |
| } |
| |
| protected CharSequence generateHeaderFile(final Root root, final ProtocolClass pc) { |
| 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 ProtocolClass "); |
| String _name = pc.getName(); |
| _builder.append(_name, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardBegin = this.stdExt.generateIncludeGuardBegin(pc, ""); |
| _builder.append(_generateIncludeGuardBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/InterfaceItemBase.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/PortBase.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/ReplicatedInterfaceItemBase.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/ReplicatedPortBase.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/etDatatypesCpp.hpp\""); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| EList<DataClass> _referencedDataClasses = root.getReferencedDataClasses(pc); |
| for(final DataClass dataClass : _referencedDataClasses) { |
| _builder.append("#include \""); |
| String _path = this.roomExt.getPath(dataClass); |
| _builder.append(_path, ""); |
| String _name_1 = dataClass.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append(".h\""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| DetailCode _userCode1 = pc.getUserCode1(); |
| CharSequence _userCode = this.helpers.userCode(_userCode1); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| String _generateNamespaceBegin = this.stdExt.generateNamespaceBegin(pc); |
| _builder.append(_generateNamespaceBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("class "); |
| String _name_2 = pc.getName(); |
| _builder.append(_name_2, ""); |
| _builder.append(" {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("public:"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("/* message IDs */"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| String _genMessageIDs = this.genMessageIDs(pc); |
| _builder.append(_genMessageIDs, "\t\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| CharSequence _userCode_1 = this.helpers.userCode(pc, 2); |
| _builder.append(_userCode_1, "\t\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static bool isValidEvtID(int evtId) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("return ((MSG_MIN < evtId) && (evtId < MSG_MAX));"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static bool isValidOutgoingEvtID(int evtId) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("return ((MSG_MIN < evtId) && (evtId < "); |
| { |
| EList<Message> _incomingMessages = pc.getIncomingMessages(); |
| int _size = _incomingMessages.size(); |
| boolean _equals = (_size == 0); |
| if (_equals) { |
| _builder.append("MSG_MAX"); |
| } else { |
| _builder.append("IN_"); |
| EList<Message> _incomingMessages_1 = pc.getIncomingMessages(); |
| Message _get = _incomingMessages_1.get(0); |
| String _name_3 = _get.getName(); |
| _builder.append(_name_3, "\t\t\t"); |
| } |
| } |
| _builder.append("));"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static bool isValidIncomingEvtID(int evtId) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("return (("); |
| { |
| EList<Message> _incomingMessages_2 = pc.getIncomingMessages(); |
| int _size_1 = _incomingMessages_2.size(); |
| boolean _equals_1 = (_size_1 == 0); |
| if (_equals_1) { |
| _builder.append("MSG_MAX"); |
| } else { |
| _builder.append("IN_"); |
| EList<Message> _incomingMessages_3 = pc.getIncomingMessages(); |
| Message _get_1 = _incomingMessages_3.get(0); |
| String _name_4 = _get_1.getName(); |
| _builder.append(_name_4, "\t\t\t"); |
| } |
| } |
| _builder.append(" <= evtId) && (evtId < MSG_MAX));"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static const std::string& getMessageString(int msg_id);"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("private:"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static const std::string s_messageStrings[];"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| CharSequence _portClassDeclaration = this.portClassDeclaration(pc, false); |
| _builder.append(_portClassDeclaration, ""); |
| _builder.newLineIfNotEmpty(); |
| CharSequence _portClassDeclaration_1 = this.portClassDeclaration(pc, true); |
| _builder.append(_portClassDeclaration_1, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| String _generateNamespaceEnd = this.stdExt.generateNamespaceEnd(pc); |
| _builder.append(_generateNamespaceEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardEnd = this.stdExt.generateIncludeGuardEnd(pc, ""); |
| _builder.append(_generateIncludeGuardEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| return _builder; |
| } |
| |
| protected CharSequence portClassDeclaration(final ProtocolClass pc, final boolean conj) { |
| CharSequence _xblockexpression = null; |
| { |
| PortClass pclass = this.roomExt.getPortClass(pc, conj); |
| String portClassName = this.roomExt.getPortClassName(pc, conj); |
| String replPortClassName = this.roomExt.getPortClassName(pc, conj, true); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("// "); |
| { |
| if (conj) { |
| _builder.append("conjugated "); |
| } |
| } |
| _builder.append("port class"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("class "); |
| _builder.append(portClassName, ""); |
| _builder.append(" : public etRuntime::PortBase {"); |
| _builder.newLineIfNotEmpty(); |
| { |
| boolean _notEquals = (!Objects.equal(pclass, null)); |
| if (_notEquals) { |
| _builder.append("\t"); |
| DetailCode _userCode = pclass.getUserCode(); |
| CharSequence _userCode_1 = this.helpers.userCode(_userCode); |
| _builder.append(_userCode_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append(" "); |
| _builder.append("public:"); |
| _builder.newLine(); |
| _builder.append("\t "); |
| _builder.append(portClassName, "\t "); |
| _builder.append("(etRuntime::IInterfaceItemOwner* actor, const std::string& name, int localId);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t "); |
| _builder.append(portClassName, "\t "); |
| _builder.append("(etRuntime::IInterfaceItemOwner* actor, const std::string& name, int localId, int idx);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| _builder.append("\t"); |
| _builder.append("virtual void destroy();"); |
| _builder.newLine(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t "); |
| _builder.append("virtual void receive(const etRuntime::Message* m);"); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| boolean _notEquals_1 = (!Objects.equal(pclass, null)); |
| if (_notEquals_1) { |
| _builder.append("\t"); |
| EList<Attribute> _attributes = pclass.getAttributes(); |
| CharSequence _attributes_1 = this.helpers.attributes(_attributes); |
| _builder.append(_attributes_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| EList<PortOperation> _operations = pclass.getOperations(); |
| CharSequence _operationsDeclaration = this.helpers.operationsDeclaration(_operations, portClassName); |
| _builder.append(_operationsDeclaration, "\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t "); |
| _builder.append("// sent messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allMessages = this._roomHelpers.getAllMessages(pc, conj); |
| for(final Message m : _allMessages) { |
| _builder.append("\t"); |
| CharSequence _messageSignature = this.messageSignature(m); |
| _builder.append(_messageSignature, "\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("// "); |
| { |
| if (conj) { |
| _builder.append("conjugated "); |
| } |
| } |
| _builder.append("replicated port class"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("class "); |
| _builder.append(replPortClassName, ""); |
| _builder.append(" : public etRuntime::ReplicatedPortBase {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("public:"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append(replPortClassName, "\t\t"); |
| _builder.append("(etRuntime::IInterfaceItemOwner* actor, const std::string& name, int localId);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("int getReplication() const { return getNInterfaceItems(); }"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("int getIndexOf(const etRuntime::InterfaceItemBase& ifitem) const { return ifitem.getIdx(); }"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append(portClassName, "\t\t"); |
| _builder.append("& get(int idx) const { return *dynamic_cast<"); |
| _builder.append(portClassName, "\t\t"); |
| _builder.append("*>(getInterfaceItem(idx)); }"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| if (conj) { |
| _builder.append("\t\t"); |
| _builder.append("// incoming messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| for(final Message m_1 : _allIncomingMessages) { |
| _builder.append("\t\t"); |
| CharSequence _messageSignature_1 = this.messageSignature(m_1); |
| _builder.append(_messageSignature_1, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| } else { |
| _builder.append("\t\t"); |
| _builder.append("// outgoing messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allOutgoingMessages = this._roomHelpers.getAllOutgoingMessages(pc); |
| for(final Message m_2 : _allOutgoingMessages) { |
| _builder.append("\t\t"); |
| CharSequence _messageSignature_2 = this.messageSignature(m_2); |
| _builder.append(_messageSignature_2, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| } |
| } |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("protected:"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("virtual etRuntime::InterfaceItemBase* createInterfaceItem(etRuntime::IInterfaceItemOwner* rcv, const std::string& name, int lid, int idx) {"); |
| _builder.newLine(); |
| _builder.append("\t\t\t"); |
| _builder.append("return new "); |
| _builder.append(portClassName, "\t\t\t"); |
| _builder.append("(rcv, name, lid, idx);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| protected CharSequence generateSourceFile(final Root root, final ProtocolClass pc) { |
| 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 ProtocolClass "); |
| String _name = pc.getName(); |
| _builder.append(_name, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include \""); |
| String _cppHeaderFileName = this.stdExt.getCppHeaderFileName(pc); |
| _builder.append(_cppHeaderFileName, ""); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("#include \"common/debugging/DebuggingService.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/messaging/AbstractMessageReceiver.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/messaging/Address.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/messaging/Message.h\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/IEventReceiver.h\""); |
| _builder.newLine(); |
| _builder.append("#include <iterator>"); |
| _builder.newLine(); |
| _builder.append("#include <vector>"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("using namespace etRuntime;"); |
| _builder.newLine(); |
| _builder.newLine(); |
| String _generateNamespaceBegin = this.stdExt.generateNamespaceBegin(pc); |
| _builder.append(_generateNamespaceBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _userCode = this.helpers.userCode(pc, 3); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("/* message names as strings for debugging (generate MSC) */"); |
| _builder.newLine(); |
| _builder.append("const std::string "); |
| String _name_1 = pc.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append("::s_messageStrings[] = {\"MIN\", "); |
| { |
| List<Message> _allOutgoingMessages = this._roomHelpers.getAllOutgoingMessages(pc); |
| for(final Message m : _allOutgoingMessages) { |
| _builder.append("\""); |
| String _name_2 = m.getName(); |
| _builder.append(_name_2, ""); |
| _builder.append("\","); |
| } |
| } |
| _builder.append(" "); |
| { |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| for(final Message m_1 : _allIncomingMessages) { |
| _builder.append("\""); |
| String _name_3 = m_1.getName(); |
| _builder.append(_name_3, ""); |
| _builder.append("\","); |
| } |
| } |
| _builder.append("\"MAX\"};"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("const std::string& "); |
| String _name_4 = pc.getName(); |
| _builder.append(_name_4, ""); |
| _builder.append("::getMessageString(int msg_id) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("if ((MSG_MIN < msg_id ) && ( msg_id < MSG_MAX )) {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("return s_messageStrings[msg_id];"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("} else {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("// id out of range"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("static const std::string errorMsg = \"Message ID out of range\";"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("return errorMsg;"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| CharSequence _portClassImplementation = this.portClassImplementation(pc, false); |
| _builder.append(_portClassImplementation, ""); |
| _builder.newLineIfNotEmpty(); |
| CharSequence _portClassImplementation_1 = this.portClassImplementation(pc, true); |
| _builder.append(_portClassImplementation_1, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| String _generateNamespaceEnd = this.stdExt.generateNamespaceEnd(pc); |
| _builder.append(_generateNamespaceEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| return _builder; |
| } |
| |
| protected CharSequence portClassImplementation(final ProtocolClass pc, final boolean conj) { |
| CharSequence _xblockexpression = null; |
| { |
| PortClass pclass = this.roomExt.getPortClass(pc, conj); |
| String portClassName = this.roomExt.getPortClassName(pc, conj); |
| String replPortClassName = this.roomExt.getPortClassName(pc, conj, true); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("// "); |
| { |
| if (conj) { |
| _builder.append("conjugated "); |
| } |
| } |
| _builder.append("port class"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append(portClassName, ""); |
| _builder.append("::"); |
| _builder.append(portClassName, ""); |
| _builder.append("(IInterfaceItemOwner* actor, const std::string& name, int localId)"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| CharSequence _generateConstructorInitalizerList = this.generateConstructorInitalizerList(pclass, "0"); |
| _builder.append(_generateConstructorInitalizerList, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("{"); |
| _builder.newLine(); |
| { |
| GlobalGeneratorSettings _settings = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation = _settings.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation) { |
| _builder.append("\t"); |
| _builder.append("DebuggingService::getInstance().addPortInstance(*this);"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append(portClassName, ""); |
| _builder.append("::"); |
| _builder.append(portClassName, ""); |
| _builder.append("(IInterfaceItemOwner* actor, const std::string& name, int localId, int idx)"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| CharSequence _generateConstructorInitalizerList_1 = this.generateConstructorInitalizerList(pclass, "idx"); |
| _builder.append(_generateConstructorInitalizerList_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("{"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| { |
| boolean _notEquals = (!Objects.equal(pclass, null)); |
| if (_notEquals) { |
| EList<Attribute> _attributes = pclass.getAttributes(); |
| CharSequence _genExtraInitializers = this.initHelper.genExtraInitializers(_attributes); |
| _builder.append(_genExtraInitializers, "\t"); |
| } |
| } |
| _builder.newLineIfNotEmpty(); |
| { |
| GlobalGeneratorSettings _settings_1 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_1 = _settings_1.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_1) { |
| _builder.append("\t"); |
| _builder.append("DebuggingService::getInstance().addPortInstance(*this);"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("}"); |
| _builder.newLine(); |
| { |
| GlobalGeneratorSettings _settings_2 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_2 = _settings_2.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_2) { |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(portClassName, ""); |
| _builder.append("::destroy() {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("DebuggingService::getInstance().removePortInstance(*this);"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("PortBase::destroy();"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("void "); |
| _builder.append(portClassName, ""); |
| _builder.append("::receive(const Message* msg) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("// TODO JH further"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("if (! "); |
| String _name = pc.getName(); |
| _builder.append(_name, "\t"); |
| _builder.append("::"); |
| { |
| if (conj) { |
| _builder.append("isValidOutgoingEvtID"); |
| } else { |
| _builder.append("isValidIncomingEvtID"); |
| } |
| } |
| _builder.append("(msg->getEvtId())) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("std::cout << \"unknown\" << std::endl;"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| GlobalGeneratorSettings _settings_3 = Main.getSettings(); |
| boolean _isGenerateMSCInstrumentation_3 = _settings_3.isGenerateMSCInstrumentation(); |
| if (_isGenerateMSCInstrumentation_3) { |
| _builder.append("\t"); |
| _builder.append("DebuggingService::getInstance().addMessageAsyncIn(getPeerAddress(), getAddress(), "); |
| String _name_1 = pc.getName(); |
| _builder.append(_name_1, "\t"); |
| _builder.append("::getMessageString(msg->getEvtId()));"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| { |
| boolean _handlesReceive = this.roomExt.handlesReceive(pc, conj); |
| if (_handlesReceive) { |
| _builder.append("\t"); |
| _builder.append("switch (msg->getEvtId()) {"); |
| _builder.newLine(); |
| { |
| List<MessageHandler> _receiveHandlers = this.roomExt.getReceiveHandlers(pc, conj); |
| for(final MessageHandler hdlr : _receiveHandlers) { |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("case "); |
| String _name_2 = pc.getName(); |
| _builder.append(_name_2, "\t\t"); |
| _builder.append("::"); |
| Message _msg = hdlr.getMsg(); |
| String _codeName = this.roomExt.getCodeName(_msg); |
| _builder.append(_codeName, "\t\t"); |
| _builder.append(":"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("{"); |
| _builder.newLine(); |
| { |
| DetailCode _detailCode = hdlr.getDetailCode(); |
| EList<String> _lines = _detailCode.getLines(); |
| for(final String command : _lines) { |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t\t"); |
| _builder.append(command, "\t\t\t\t"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("default:"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("\t"); |
| _builder.append("getActor()->receiveEvent(this, msg->getEvtId(),\tmsg->getData());"); |
| _builder.newLine(); |
| { |
| boolean _handlesReceive_1 = this.roomExt.handlesReceive(pc, conj); |
| if (_handlesReceive_1) { |
| _builder.append("\t"); |
| _builder.append("\t\t"); |
| _builder.append("break;"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| boolean _notEquals_1 = (!Objects.equal(pclass, null)); |
| if (_notEquals_1) { |
| EList<PortOperation> _operations = pclass.getOperations(); |
| CharSequence _operationsImplementation = this.helpers.operationsImplementation(_operations, portClassName); |
| _builder.append(_operationsImplementation, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("// sent messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allMessages = this._roomHelpers.getAllMessages(pc, conj); |
| for(final Message m : _allMessages) { |
| String _name_3 = pc.getName(); |
| CharSequence _sendMessage = this.sendMessage(m, _name_3, portClassName, conj); |
| _builder.append(_sendMessage, ""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append("// "); |
| { |
| if (conj) { |
| _builder.append("conjugated "); |
| } |
| } |
| _builder.append("replicated port class"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("//------------------------------------------------------------------------------------------------------------"); |
| _builder.newLine(); |
| _builder.append(replPortClassName, ""); |
| _builder.append("::"); |
| _builder.append(replPortClassName, ""); |
| _builder.append("(IInterfaceItemOwner* actor, const std::string& name, int localId) :"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("ReplicatedPortBase(actor, name, localId)"); |
| _builder.newLine(); |
| _builder.append("{"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| { |
| if (conj) { |
| _builder.append("// incoming messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| for(final Message m_1 : _allIncomingMessages) { |
| CharSequence _messageSignatureDefinition = this.messageSignatureDefinition(m_1, replPortClassName); |
| _builder.append(_messageSignatureDefinition, ""); |
| _builder.append("{"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("for (std::vector<etRuntime::InterfaceItemBase*>::iterator it = getItems().begin(); it != getItems().end(); ++it) {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("(dynamic_cast<"); |
| _builder.append(portClassName, "\t\t"); |
| _builder.append("*>(*it))->"); |
| CharSequence _messageCall = this.messageCall(m_1); |
| _builder.append(_messageCall, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| } else { |
| _builder.append("// outgoing messages"); |
| _builder.newLine(); |
| { |
| List<Message> _allOutgoingMessages = this._roomHelpers.getAllOutgoingMessages(pc); |
| for(final Message m_2 : _allOutgoingMessages) { |
| CharSequence _messageSignatureDefinition_1 = this.messageSignatureDefinition(m_2, replPortClassName); |
| _builder.append(_messageSignatureDefinition_1, ""); |
| _builder.append("{"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("for (std::vector<etRuntime::InterfaceItemBase*>::iterator it = getItems().begin(); it != getItems().end(); ++it) {"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("(dynamic_cast<"); |
| _builder.append(portClassName, "\t\t"); |
| _builder.append("*>(*it))->"); |
| CharSequence _messageCall_1 = this.messageCall(m_2); |
| _builder.append(_messageCall_1, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| } |
| } |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private CharSequence generateConstructorInitalizerList(final PortClass pc, final String index) { |
| CharSequence _xblockexpression = null; |
| { |
| @Extension |
| final Initialization initHelper = this.initHelper; |
| final List<CharSequence> initList = CollectionLiterals.<CharSequence>newArrayList(); |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("PortBase(actor, name, localId, "); |
| _builder.append(index, ""); |
| _builder.append(")"); |
| initList.add(_builder.toString()); |
| boolean _notEquals = (!Objects.equal(pc, null)); |
| if (_notEquals) { |
| EList<Attribute> _attributes = pc.getAttributes(); |
| final Function1<Attribute, String> _function = new Function1<Attribute, String>() { |
| public String apply(final Attribute it) { |
| StringConcatenation _builder = new StringConcatenation(); |
| String _name = it.getName(); |
| _builder.append(_name, ""); |
| _builder.append("("); |
| String _initializerListValue = initHelper.getInitializerListValue(it); |
| _builder.append(_initializerListValue, ""); |
| _builder.append(")"); |
| return _builder.toString(); |
| } |
| }; |
| List<String> _map = ListExtensions.<Attribute, String>map(_attributes, _function); |
| Iterables.<CharSequence>addAll(initList, _map); |
| } |
| _xblockexpression = initHelper.generateCtorInitializerList(initList); |
| } |
| return _xblockexpression; |
| } |
| |
| protected CharSequence messageCall(final Message m) { |
| StringConcatenation _builder = new StringConcatenation(); |
| String _name = m.getName(); |
| _builder.append(_name, ""); |
| _builder.append("("); |
| { |
| VarDecl _data = m.getData(); |
| boolean _notEquals = (!Objects.equal(_data, null)); |
| if (_notEquals) { |
| _builder.append(" "); |
| VarDecl _data_1 = m.getData(); |
| String _name_1 = _data_1.getName(); |
| _builder.append(_name_1, ""); |
| } |
| } |
| _builder.append(")"); |
| return _builder; |
| } |
| |
| protected CharSequence messageSignature(final Message m) { |
| StringConcatenation _builder = new StringConcatenation(); |
| { |
| boolean _isPriv = m.isPriv(); |
| if (_isPriv) { |
| _builder.append("private:"); |
| } else { |
| _builder.append("public:"); |
| } |
| } |
| _builder.append(" void "); |
| String _name = m.getName(); |
| _builder.append(_name, ""); |
| _builder.append("("); |
| { |
| VarDecl _data = m.getData(); |
| boolean _notEquals = (!Objects.equal(_data, null)); |
| if (_notEquals) { |
| VarDecl _data_1 = m.getData(); |
| RefableType _refType = _data_1.getRefType(); |
| String _signatureString = this.helpers.signatureString(_refType); |
| _builder.append(_signatureString, ""); |
| _builder.append(" "); |
| VarDecl _data_2 = m.getData(); |
| String _name_1 = _data_2.getName(); |
| _builder.append(_name_1, ""); |
| } |
| } |
| _builder.append(")"); |
| return _builder; |
| } |
| |
| protected CharSequence messageSignatureDefinition(final Message m, final String classPrefix) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("void "); |
| _builder.append(classPrefix, ""); |
| _builder.append("::"); |
| String _name = m.getName(); |
| _builder.append(_name, ""); |
| _builder.append("("); |
| { |
| VarDecl _data = m.getData(); |
| boolean _notEquals = (!Objects.equal(_data, null)); |
| if (_notEquals) { |
| VarDecl _data_1 = m.getData(); |
| RefableType _refType = _data_1.getRefType(); |
| String _signatureString = this.helpers.signatureString(_refType); |
| _builder.append(_signatureString, ""); |
| _builder.append(" "); |
| VarDecl _data_2 = m.getData(); |
| String _name_1 = _data_2.getName(); |
| _builder.append(_name_1, ""); |
| } |
| } |
| _builder.append(")"); |
| return _builder; |
| } |
| |
| protected CharSequence sendMessage(final Message m, final String portClassName, final String classPrefix, final boolean conj) { |
| CharSequence _xblockexpression = null; |
| { |
| String _xifexpression = null; |
| if (conj) { |
| _xifexpression = "IN"; |
| } else { |
| _xifexpression = "OUT"; |
| } |
| String dir = _xifexpression; |
| MessageHandler hdlr = this.roomExt.getSendHandler(m, conj); |
| String _xifexpression_1 = null; |
| VarDecl _data = m.getData(); |
| boolean _notEquals = (!Objects.equal(_data, null)); |
| if (_notEquals) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append(", "); |
| { |
| VarDecl _data_1 = m.getData(); |
| RefableType _refType = _data_1.getRefType(); |
| boolean _isRef = _refType.isRef(); |
| if (_isRef) { |
| VarDecl _data_2 = m.getData(); |
| String _name = _data_2.getName(); |
| _builder.append(_name, ""); |
| } else { |
| _builder.append("&"); |
| VarDecl _data_3 = m.getData(); |
| String _name_1 = _data_3.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append(", sizeof("); |
| VarDecl _data_4 = m.getData(); |
| RefableType _refType_1 = _data_4.getRefType(); |
| DataType _type = _refType_1.getType(); |
| String _typeName = this._typeHelpers.typeName(_type); |
| _builder.append(_typeName, ""); |
| _builder.append(")"); |
| } |
| } |
| _xifexpression_1 = _builder.toString(); |
| } |
| final String dataArg = _xifexpression_1; |
| StringConcatenation _builder_1 = new StringConcatenation(); |
| _builder_1.append("new Message(getPeerAddress(), "); |
| _builder_1.append(portClassName, ""); |
| _builder_1.append("::"); |
| _builder_1.append(dir, ""); |
| _builder_1.append("_"); |
| String _name_2 = m.getName(); |
| _builder_1.append(_name_2, ""); |
| String _elvis = null; |
| if (dataArg != null) { |
| _elvis = dataArg; |
| } else { |
| _elvis = ""; |
| } |
| _builder_1.append(_elvis, ""); |
| _builder_1.append(")"); |
| final String message = _builder_1.toString(); |
| StringConcatenation _builder_2 = new StringConcatenation(); |
| CharSequence _messageSignatureDefinition = this.messageSignatureDefinition(m, classPrefix); |
| _builder_2.append(_messageSignatureDefinition, ""); |
| _builder_2.append(" {"); |
| _builder_2.newLineIfNotEmpty(); |
| { |
| boolean _notEquals_1 = (!Objects.equal(hdlr, null)); |
| if (_notEquals_1) { |
| _builder_2.append("\t"); |
| { |
| DetailCode _detailCode = hdlr.getDetailCode(); |
| EList<String> _lines = _detailCode.getLines(); |
| for(final String command : _lines) { |
| _builder_2.append("\t"); |
| _builder_2.append(command, "\t"); |
| _builder_2.newLineIfNotEmpty(); |
| } |
| } |
| } else { |
| _builder_2.append("\t"); |
| _builder_2.append("DebuggingService::getInstance().addMessageAsyncOut(getAddress(), getPeerAddress(),"); |
| _builder_2.newLine(); |
| _builder_2.append("\t"); |
| _builder_2.append("\t"); |
| _builder_2.append(portClassName, "\t\t"); |
| _builder_2.append("::getMessageString("); |
| _builder_2.append(portClassName, "\t\t"); |
| _builder_2.append("::"); |
| _builder_2.append(dir, "\t\t"); |
| _builder_2.append("_"); |
| String _name_3 = m.getName(); |
| _builder_2.append(_name_3, "\t\t"); |
| _builder_2.append("));"); |
| _builder_2.newLineIfNotEmpty(); |
| _builder_2.append("\t"); |
| _builder_2.append("if (getPeerAddress().isValid()){"); |
| _builder_2.newLine(); |
| _builder_2.append("\t"); |
| _builder_2.append("\t"); |
| _builder_2.append("getPeerMsgReceiver()->receive("); |
| _builder_2.append(message, "\t\t"); |
| _builder_2.append(");"); |
| _builder_2.newLineIfNotEmpty(); |
| _builder_2.append("\t"); |
| _builder_2.append("}"); |
| _builder_2.newLine(); |
| } |
| } |
| _builder_2.append("}"); |
| _builder_2.newLine(); |
| _xblockexpression = _builder_2; |
| } |
| return _xblockexpression; |
| } |
| |
| protected CharSequence generateDataDrivenHeaderFile(final Root root, final ProtocolClass pc) { |
| CharSequence _xblockexpression = null; |
| { |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| return Boolean.valueOf((!Objects.equal(_data, null))); |
| } |
| }; |
| final Iterable<Message> sentMsgs = IterableExtensions.<Message>filter(_allIncomingMessages, _function); |
| final EList<RoomModel> models = root.getReferencedModels(pc); |
| 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 ProtocolClass "); |
| String _name = pc.getName(); |
| _builder.append(_name, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardBegin = this.stdExt.generateIncludeGuardBegin(pc, ""); |
| _builder.append(_generateIncludeGuardBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("#include \"common/etDatatypesCpp.hpp\""); |
| _builder.newLine(); |
| _builder.append("#include \"common/modelbase/DataPort.h\""); |
| _builder.newLine(); |
| { |
| EList<DataClass> _referencedDataClasses = root.getReferencedDataClasses(pc); |
| for(final DataClass dataClass : _referencedDataClasses) { |
| _builder.append("#include \""); |
| String _path = this.roomExt.getPath(dataClass); |
| _builder.append(_path, ""); |
| String _name_1 = dataClass.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append(".h\""); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| DetailCode _userCode1 = pc.getUserCode1(); |
| CharSequence _userCode = this.helpers.userCode(_userCode1); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| String _generateNamespaceBegin = this.stdExt.generateNamespaceBegin(pc); |
| _builder.append(_generateNamespaceBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("class "); |
| String _name_2 = pc.getName(); |
| _builder.append(_name_2, ""); |
| _builder.append(" {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| DetailCode _userCode2 = pc.getUserCode2(); |
| CharSequence _userCode_1 = this.helpers.userCode(_userCode2); |
| _builder.append(_userCode_1, "\t"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// send port holds data"); |
| _builder.newLine(); |
| _builder.append("class "); |
| String _portClassName = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName, ""); |
| _builder.append(" : public etRuntime::DataSendPort {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("public:"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| String _portClassName_1 = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName_1, "\t"); |
| _builder.append("(etRuntime::IRTObject* parent, const std::string& name, int localId);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("// getters and setters"); |
| _builder.newLine(); |
| { |
| for(final Message msg : sentMsgs) { |
| _builder.append("\t"); |
| _builder.append("void "); |
| String _name_3 = msg.getName(); |
| _builder.append(_name_3, "\t"); |
| _builder.append("("); |
| VarDecl _data = msg.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| String _typeName = this._typeHelpers.typeName(_type); |
| _builder.append(_typeName, "\t"); |
| _builder.append(" "); |
| String _name_4 = msg.getName(); |
| _builder.append(_name_4, "\t"); |
| _builder.append(") {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("m_"); |
| String _name_5 = msg.getName(); |
| _builder.append(_name_5, "\t\t"); |
| _builder.append(" = "); |
| String _name_6 = msg.getName(); |
| _builder.append(_name_6, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| VarDecl _data_1 = msg.getData(); |
| RefableType _refType_1 = _data_1.getRefType(); |
| DataType _type_1 = _refType_1.getType(); |
| String _typeName_1 = this._typeHelpers.typeName(_type_1); |
| _builder.append(_typeName_1, "\t"); |
| _builder.append(" "); |
| String _name_7 = msg.getName(); |
| _builder.append(_name_7, "\t"); |
| _builder.append("() const {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("\t"); |
| _builder.append("return m_"); |
| String _name_8 = msg.getName(); |
| _builder.append(_name_8, "\t\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("private:"); |
| _builder.newLine(); |
| { |
| for(final Message msg_1 : sentMsgs) { |
| _builder.append("\t"); |
| VarDecl _data_2 = msg_1.getData(); |
| RefableType _refType_2 = _data_2.getRefType(); |
| DataType _type_2 = _refType_2.getType(); |
| String _typeName_2 = this._typeHelpers.typeName(_type_2); |
| _builder.append(_typeName_2, "\t"); |
| _builder.append(" m_"); |
| String _name_9 = msg_1.getName(); |
| _builder.append(_name_9, "\t"); |
| _builder.append(";"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// receive port accesses send port"); |
| _builder.newLine(); |
| _builder.append("class "); |
| String _portClassName_2 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_2, ""); |
| _builder.append(" : public etRuntime::DataReceivePort {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("public:"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| String _portClassName_3 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_3, "\t"); |
| _builder.append("(etRuntime::IRTObject* parent, const std::string& name, int localId);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("// getters"); |
| _builder.newLine(); |
| { |
| for(final Message msg_2 : sentMsgs) { |
| _builder.append("\t"); |
| VarDecl _data_3 = msg_2.getData(); |
| RefableType _refType_3 = _data_3.getRefType(); |
| DataType _type_3 = _refType_3.getType(); |
| String _typeName_3 = this._typeHelpers.typeName(_type_3); |
| _builder.append(_typeName_3, "\t"); |
| _builder.append(" "); |
| String _name_10 = msg_2.getName(); |
| _builder.append(_name_10, "\t"); |
| _builder.append("() const;"); |
| _builder.newLineIfNotEmpty(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("protected:"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("virtual void connect(etRuntime::DataSendPort* dataSendPort);"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("private:"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| String _portClassName_4 = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName_4, "\t"); |
| _builder.append("* m_peer;"); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| String _generateNamespaceEnd = this.stdExt.generateNamespaceEnd(pc); |
| _builder.append(_generateNamespaceEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateIncludeGuardEnd = this.stdExt.generateIncludeGuardEnd(pc, ""); |
| _builder.append(_generateIncludeGuardEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| protected CharSequence generateDataDrivenSourceFile(final Root root, final ProtocolClass pc) { |
| CharSequence _xblockexpression = null; |
| { |
| List<Message> _allIncomingMessages = this._roomHelpers.getAllIncomingMessages(pc); |
| final Function1<Message, Boolean> _function = new Function1<Message, Boolean>() { |
| public Boolean apply(final Message m) { |
| VarDecl _data = m.getData(); |
| return Boolean.valueOf((!Objects.equal(_data, null))); |
| } |
| }; |
| final Iterable<Message> sentMsgs = IterableExtensions.<Message>filter(_allIncomingMessages, _function); |
| final EList<RoomModel> models = root.getReferencedModels(pc); |
| 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 ProtocolClass "); |
| String _name = pc.getName(); |
| _builder.append(_name, " "); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append("*"); |
| _builder.newLine(); |
| _builder.append(" "); |
| _builder.append("*/"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("#include \""); |
| String _cppHeaderFileName = this.stdExt.getCppHeaderFileName(pc); |
| _builder.append(_cppHeaderFileName, ""); |
| _builder.append("\""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("using namespace etRuntime;"); |
| _builder.newLine(); |
| _builder.newLine(); |
| String _generateNamespaceBegin = this.stdExt.generateNamespaceBegin(pc); |
| _builder.append(_generateNamespaceBegin, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| DetailCode _userCode3 = pc.getUserCode3(); |
| CharSequence _userCode = this.helpers.userCode(_userCode3); |
| _builder.append(_userCode, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _builder.append("// send port holds data"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// constructor"); |
| _builder.newLine(); |
| String _portClassName = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName, ""); |
| _builder.append("::"); |
| String _portClassName_1 = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName_1, ""); |
| _builder.append("(IRTObject* parent, const std::string& name, int localId) :"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("DataSendPort(parent, name, localId)"); |
| _builder.newLine(); |
| _builder.append("{"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// receive port accesses send port"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// constructor"); |
| _builder.newLine(); |
| String _portClassName_2 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_2, ""); |
| _builder.append("::"); |
| String _portClassName_3 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_3, ""); |
| _builder.append("(IRTObject* parent, const std::string& name, int localId) :"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t\t"); |
| _builder.append("DataReceivePort(parent, name, localId),"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("m_peer(0)"); |
| _builder.newLine(); |
| _builder.append("{"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| _builder.append("// getters"); |
| _builder.newLine(); |
| { |
| for(final Message msg : sentMsgs) { |
| VarDecl _data = msg.getData(); |
| RefableType _refType = _data.getRefType(); |
| DataType _type = _refType.getType(); |
| String _typeName = this._typeHelpers.typeName(_type); |
| _builder.append(_typeName, ""); |
| _builder.append(" "); |
| String _portClassName_4 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_4, ""); |
| _builder.append("::"); |
| String _name_1 = msg.getName(); |
| _builder.append(_name_1, ""); |
| _builder.append("() const {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("// TODO needs default value"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("//if (m_peer == 0)"); |
| _builder.newLine(); |
| _builder.append("\t"); |
| _builder.append("/*\treturn "); |
| VarDecl _data_1 = msg.getData(); |
| RefableType _refType_1 = _data_1.getRefType(); |
| DataType _type_1 = _refType_1.getType(); |
| String _defaultValue = this.stdExt.defaultValue(_type_1); |
| _builder.append(_defaultValue, "\t"); |
| _builder.append("; */"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("return m_peer->"); |
| String _name_2 = msg.getName(); |
| _builder.append(_name_2, "\t"); |
| _builder.append("();"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("}"); |
| _builder.newLine(); |
| } |
| } |
| _builder.newLine(); |
| _builder.append("void "); |
| String _portClassName_5 = this.roomExt.getPortClassName(pc, false); |
| _builder.append(_portClassName_5, ""); |
| _builder.append("::connect(DataSendPort* dataSendPort) {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| String _portClassName_6 = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName_6, "\t"); |
| _builder.append("* peer = dynamic_cast<"); |
| String _portClassName_7 = this.roomExt.getPortClassName(pc, true); |
| _builder.append(_portClassName_7, "\t"); |
| _builder.append("*>(dataSendPort);"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append("\t"); |
| _builder.append("if (peer != 0)"); |
| _builder.newLine(); |
| _builder.append("\t\t"); |
| _builder.append("m_peer = peer;"); |
| _builder.newLine(); |
| _builder.append("}"); |
| _builder.newLine(); |
| _builder.newLine(); |
| String _generateNamespaceEnd = this.stdExt.generateNamespaceEnd(pc); |
| _builder.append(_generateNamespaceEnd, ""); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| public String getMessageID(final Message msg, final InterfaceItem item) { |
| if ((item instanceof Port)) { |
| Port p = ((Port) item); |
| String _xifexpression = null; |
| boolean _isConjugated = p.isConjugated(); |
| if (_isConjugated) { |
| _xifexpression = "OUT_"; |
| } else { |
| _xifexpression = "IN_"; |
| } |
| String direction = _xifexpression; |
| GeneralProtocolClass _protocol = p.getProtocol(); |
| String _name = _protocol.getName(); |
| String _name_1 = msg.getName(); |
| String _plus = (direction + _name_1); |
| return this.enumInUse(_name, _plus); |
| } else { |
| if ((item instanceof SAP)) { |
| SAP sap = ((SAP) item); |
| ProtocolClass _protocol_1 = sap.getProtocol(); |
| String _name_2 = _protocol_1.getName(); |
| String _name_3 = msg.getName(); |
| String _plus_1 = ("OUT_" + _name_3); |
| return this.enumInUse(_name_2, _plus_1); |
| } else { |
| if ((item instanceof SPP)) { |
| SPP spp = ((SPP) item); |
| ProtocolClass _protocol_2 = spp.getProtocol(); |
| String _name_4 = _protocol_2.getName(); |
| String _name_5 = msg.getName(); |
| String _plus_2 = ("IN_" + _name_5); |
| return this.enumInUse(_name_4, _plus_2); |
| } |
| } |
| } |
| return "unknown interface item"; |
| } |
| |
| protected String enumInUse(final String namespace, final String member) { |
| return ((namespace + "::") + member); |
| } |
| } |
