path: root/plugins/org.eclipse.etrice.generator.c/xtend-gen/org/eclipse/etrice/generator/c/gen/ProtocolClassGen.java

package org.eclipse.etrice.generator.c.gen;

import com.google.inject.Inject;
import com.google.inject.Singleton;
import java.util.HashSet;
import java.util.List;
import org.eclipse.emf.common.util.EList;
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.DetailCode;
import org.eclipse.etrice.core.room.Message;
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.VarDecl;
import org.eclipse.etrice.generator.base.ILogger;
import org.eclipse.etrice.generator.c.gen.CExtensions;
import org.eclipse.etrice.generator.etricegen.Root;
import org.eclipse.etrice.generator.extensions.RoomExtensions;
import org.eclipse.etrice.generator.generic.GenericProtocolClassGenerator;
import org.eclipse.etrice.generator.generic.ProcedureHelpers;
import org.eclipse.etrice.generator.generic.TypeHelpers;
import org.eclipse.xtext.generator.JavaIoFileSystemAccess;
import org.eclipse.xtext.xbase.lib.BooleanExtensions;
import org.eclipse.xtext.xbase.lib.Functions.Function1;
import org.eclipse.xtext.xbase.lib.IterableExtensions;
import org.eclipse.xtext.xbase.lib.ObjectExtensions;
import org.eclipse.xtext.xbase.lib.StringExtensions;
import org.eclipse.xtext.xtend2.lib.StringConcatenation;

@SuppressWarnings("all")
@Singleton
public class ProtocolClassGen extends GenericProtocolClassGenerator {
  @Inject
  private JavaIoFileSystemAccess fileAccess;
  
  @Inject
  private CExtensions stdExt;
  
  @Inject
  private RoomExtensions roomExt;
  
  @Inject
  private ProcedureHelpers helpers;
  
  @Inject
  private TypeHelpers _typeHelpers;
  
  @Inject
  private ILogger logger;
  
  public void doGenerate(final Root root) {
    EList<ProtocolClass> _usedProtocolClasses = root.getUsedProtocolClasses();
    for (final ProtocolClass pc : _usedProtocolClasses) {
      {
        String _generationTargetPath = this.roomExt.getGenerationTargetPath(pc);
        String _path = this.roomExt.getPath(pc);
        String _operator_plus = StringExtensions.operator_plus(_generationTargetPath, _path);
        String path = _operator_plus;
        String _cHeaderFileName = this.stdExt.getCHeaderFileName(pc);
        String _operator_plus_1 = StringExtensions.operator_plus("generating ProtocolClass header \'", _cHeaderFileName);
        String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, "\' in \'");
        String _operator_plus_3 = StringExtensions.operator_plus(_operator_plus_2, path);
        String _operator_plus_4 = StringExtensions.operator_plus(_operator_plus_3, "\'");
        this.logger.logInfo(_operator_plus_4);
        this.fileAccess.setOutputPath(path);
        String _cHeaderFileName_1 = this.stdExt.getCHeaderFileName(pc);
        StringConcatenation _generateHeaderFile = this.generateHeaderFile(root, pc);
        this.fileAccess.generateFile(_cHeaderFileName_1, _generateHeaderFile);
        String _cSourceFileName = this.stdExt.getCSourceFileName(pc);
        String _operator_plus_5 = StringExtensions.operator_plus("generating ProtocolClass source \'", _cSourceFileName);
        String _operator_plus_6 = StringExtensions.operator_plus(_operator_plus_5, "\' in \'");
        String _operator_plus_7 = StringExtensions.operator_plus(_operator_plus_6, path);
        String _operator_plus_8 = StringExtensions.operator_plus(_operator_plus_7, "\'");
        this.logger.logInfo(_operator_plus_8);
        this.fileAccess.setOutputPath(path);
        String _cSourceFileName_1 = this.stdExt.getCSourceFileName(pc);
        StringConcatenation _generateSourceFile = this.generateSourceFile(root, pc);
        this.fileAccess.generateFile(_cSourceFileName_1, _generateSourceFile);
      }
    }
  }
  
  private StringConcatenation 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();
    String _name_1 = pc.getName();
    StringConcatenation _generateIncludeGuardBegin = this.stdExt.generateIncludeGuardBegin(_name_1);
    _builder.append(_generateIncludeGuardBegin, "");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    _builder.append("#include \"etDatatypes.h\"");
    _builder.newLine();
    _builder.append("#include \"modelbase/etPort.h\"");
    _builder.newLine();
    _builder.newLine();
    DetailCode _userCode1 = pc.getUserCode1();
    StringConcatenation _userCode = this.helpers.userCode(_userCode1);
    _builder.append(_userCode, "");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    {
      HashSet<DataClass> _referencedDataClasses = root.getReferencedDataClasses(pc);
      for(final DataClass dataClass : _referencedDataClasses) {
        _builder.append("#include \"");
        String _name_2 = dataClass.getName();
        _builder.append(_name_2, "");
        _builder.append(".h\"");
        _builder.newLineIfNotEmpty();
      }
    }
    _builder.newLine();
    {
      CommunicationType _commType = pc.getCommType();
      boolean _operator_equals = ObjectExtensions.operator_equals(_commType, CommunicationType.EVENT_DRIVEN);
      if (_operator_equals) {
        _builder.newLine();
        _builder.append("/* message IDs */");
        _builder.newLine();
        String _genMessageIDs = this.genMessageIDs(pc);
        _builder.append(_genMessageIDs, "");
        _builder.newLineIfNotEmpty();
        _builder.newLine();
        _builder.append("/*--------------------- port structs and methods */");
        _builder.newLine();
        StringConcatenation _portClassHeader = this.portClassHeader(pc, ((Boolean)false));
        _builder.append(_portClassHeader, "");
        _builder.newLineIfNotEmpty();
        StringConcatenation _portClassHeader_1 = this.portClassHeader(pc, ((Boolean)true));
        _builder.append(_portClassHeader_1, "");
        _builder.newLineIfNotEmpty();
      } else {
        CommunicationType _commType_1 = pc.getCommType();
        boolean _operator_equals_1 = ObjectExtensions.operator_equals(_commType_1, CommunicationType.DATA_DRIVEN);
        if (_operator_equals_1) {
          _builder.append("/*--------------------- port structs and methods */");
          _builder.newLine();
          StringConcatenation _genDataDrivenPortHeaders = this.genDataDrivenPortHeaders(pc);
          _builder.append(_genDataDrivenPortHeaders, "");
          _builder.newLineIfNotEmpty();
        } else {
          CommunicationType _commType_2 = pc.getCommType();
          boolean _operator_equals_2 = ObjectExtensions.operator_equals(_commType_2, CommunicationType.SYNCHRONOUS);
          if (_operator_equals_2) {
            _builder.append("#error \"synchronoue protocols not implemented yet\"");
            _builder.newLine();
          }
        }
      }
    }
    _builder.newLine();
    _builder.append("/*--------------------- debug helpers */");
    _builder.newLine();
    _builder.newLine();
    _builder.append("/* get message string for message id */");
    _builder.newLine();
    _builder.append("const char* ");
    String _name_3 = pc.getName();
    _builder.append(_name_3, "");
    _builder.append("_getMessageString(int msg_id);");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    DetailCode _userCode2 = pc.getUserCode2();
    StringConcatenation _userCode_1 = this.helpers.userCode(_userCode2);
    _builder.append(_userCode_1, "");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    String _name_4 = pc.getName();
    StringConcatenation _generateIncludeGuardEnd = this.stdExt.generateIncludeGuardEnd(_name_4);
    _builder.append(_generateIncludeGuardEnd, "");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    return _builder;
  }
  
  private StringConcatenation 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 _cHeaderFileName = this.stdExt.getCHeaderFileName(pc);
    _builder.append(_cHeaderFileName, "");
    _builder.append("\"");
    _builder.newLineIfNotEmpty();
    _builder.append("#include \"debugging/etMSCLogger.h\"");
    _builder.newLine();
    _builder.newLine();
    DetailCode _userCode3 = pc.getUserCode3();
    StringConcatenation _userCode = this.helpers.userCode(_userCode3);
    _builder.append(_userCode, "");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    _builder.append("/*--------------------- port methods */");
    _builder.newLine();
    {
      CommunicationType _commType = pc.getCommType();
      boolean _operator_equals = ObjectExtensions.operator_equals(_commType, CommunicationType.EVENT_DRIVEN);
      if (_operator_equals) {
        StringConcatenation _portClassSource = this.portClassSource(pc, ((Boolean)false));
        _builder.append(_portClassSource, "");
        _builder.newLineIfNotEmpty();
        StringConcatenation _portClassSource_1 = this.portClassSource(pc, ((Boolean)true));
        _builder.append(_portClassSource_1, "");
        _builder.newLineIfNotEmpty();
        _builder.newLine();
        _builder.append("/*--------------------- debug helpers */");
        _builder.newLine();
        StringConcatenation _generateDebugHelpersImplementation = this.generateDebugHelpersImplementation(root, pc);
        _builder.append(_generateDebugHelpersImplementation, "");
        _builder.newLineIfNotEmpty();
      } else {
        CommunicationType _commType_1 = pc.getCommType();
        boolean _operator_equals_1 = ObjectExtensions.operator_equals(_commType_1, CommunicationType.DATA_DRIVEN);
        if (_operator_equals_1) {
          StringConcatenation _genDataDrivenPortSources = this.genDataDrivenPortSources(pc);
          _builder.append(_genDataDrivenPortSources, "");
          _builder.newLineIfNotEmpty();
        } else {
          CommunicationType _commType_2 = pc.getCommType();
          boolean _operator_equals_2 = ObjectExtensions.operator_equals(_commType_2, CommunicationType.SYNCHRONOUS);
          if (_operator_equals_2) {
            _builder.append("#error \"synchronoue protocols not implemented yet\"");
            _builder.newLine();
          }
        }
      }
    }
    return _builder;
  }
  
  private StringConcatenation portClassHeader(final ProtocolClass pc, final Boolean conj) {
    StringConcatenation _xblockexpression = null;
    {
      String _portClassName = this.roomExt.getPortClassName(pc, conj);
      String portClassName = _portClassName;
      String _portClassName_1 = this.roomExt.getPortClassName(pc, conj, true);
      String replPortClassName = _portClassName_1;
      List<Message> _xifexpression = null;
      if (conj) {
        List<Message> _allIncomingMessages = this.roomExt.getAllIncomingMessages(pc);
        _xifexpression = _allIncomingMessages;
      } else {
        List<Message> _allOutgoingMessages = this.roomExt.getAllOutgoingMessages(pc);
        _xifexpression = _allOutgoingMessages;
      }
      List<Message> messages = _xifexpression;
      StringConcatenation _builder = new StringConcatenation();
      _builder.newLine();
      _builder.append("\t");
      _builder.append("typedef etPort ");
      _builder.append(portClassName, "	");
      _builder.append(";");
      _builder.newLineIfNotEmpty();
      _builder.append("\t");
      _builder.append("typedef etReplPort ");
      _builder.append(replPortClassName, "	");
      _builder.append(";");
      _builder.newLineIfNotEmpty();
      _builder.append("\t");
      _builder.newLine();
      {
        for(final Message message : messages) {
          _builder.append("\t");
          VarDecl _data = message.getData();
          boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data, null);
          boolean hasData = _operator_notEquals;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _xifexpression_1 = null;
          if (hasData) {
            VarDecl _data_1 = message.getData();
            RefableType _refType = _data_1.getRefType();
            DataType _type = _refType.getType();
            String _typeName = this._typeHelpers.typeName(_type);
            _xifexpression_1 = _typeName;
          } else {
            _xifexpression_1 = "";
          }
          String typeName = _xifexpression_1;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _xifexpression_2 = null;
          boolean _operator_and = false;
          if (!hasData) {
            _operator_and = false;
          } else {
            VarDecl _data_2 = message.getData();
            RefableType _refType_1 = _data_2.getRefType();
            DataType _type_1 = _refType_1.getType();
            boolean _operator_not = BooleanExtensions.operator_not((_type_1 instanceof PrimitiveType));
            _operator_and = BooleanExtensions.operator_and(hasData, _operator_not);
          }
          if (_operator_and) {
            _xifexpression_2 = "*";
          } else {
            _xifexpression_2 = "";
          }
          String refp = _xifexpression_2;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _xifexpression_3 = null;
          if (hasData) {
            String _operator_plus = StringExtensions.operator_plus(", ", typeName);
            String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, refp);
            String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, " data");
            _xifexpression_3 = _operator_plus_2;
          } else {
            _xifexpression_3 = "";
          }
          String data = _xifexpression_3;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _name = message.getName();
          String _messageSignature = this.messageSignature(portClassName, _name, "", data);
          _builder.append(_messageSignature, "	");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _name_1 = message.getName();
          String _messageSignature_1 = this.messageSignature(replPortClassName, _name_1, "_broadcast", data);
          _builder.append(_messageSignature_1, "	");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _name_2 = message.getName();
          String _operator_plus_3 = StringExtensions.operator_plus(", int idx", data);
          String _messageSignature_2 = this.messageSignature(replPortClassName, _name_2, "", _operator_plus_3);
          _builder.append(_messageSignature_2, "	");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
        }
      }
      _xblockexpression = (_builder);
    }
    return _xblockexpression;
  }
  
  private StringConcatenation genDataDrivenPortHeaders(final ProtocolClass pc) {
    StringConcatenation _xblockexpression = null;
    {
      List<Message> _allIncomingMessages = this.roomExt.getAllIncomingMessages(pc);
      final Function1<Message,Boolean> _function = new Function1<Message,Boolean>() {
          public Boolean apply(final Message m) {
            VarDecl _data = m.getData();
            boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data, null);
            return ((Boolean)_operator_notEquals);
          }
        };
      Iterable<Message> _filter = IterableExtensions.<Message>filter(_allIncomingMessages, _function);
      Iterable<Message> sentMsgs = _filter;
      StringConcatenation _builder = new StringConcatenation();
      _builder.append("/* data driven send port (conjugated) */");
      _builder.newLine();
      _builder.append("typedef struct {");
      _builder.newLine();
      {
        for(final Message msg : sentMsgs) {
          _builder.append("\t");
          VarDecl _data = msg.getData();
          RefableType _refType = _data.getRefType();
          DataType _type = _refType.getType();
          String _typeName = this._typeHelpers.typeName(_type);
          String typeName = _typeName;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          String _xifexpression = null;
          VarDecl _data_1 = msg.getData();
          RefableType _refType_1 = _data_1.getRefType();
          boolean _isRef = _refType_1.isRef();
          if (_isRef) {
            _xifexpression = "*";
          } else {
            _xifexpression = "";
          }
          String refp = _xifexpression;
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append(typeName, "	");
          _builder.append(refp, "	");
          _builder.append(" ");
          String _name = msg.getName();
          _builder.append(_name, "	");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
        }
      }
      _builder.append("}");
      _builder.newLine();
      String _portClassName = this.roomExt.getPortClassName(pc, true);
      _builder.append(_portClassName, "");
      _builder.append(";");
      _builder.newLineIfNotEmpty();
      _builder.newLine();
      _builder.append("/* data driven receive port (regular) */");
      _builder.newLine();
      _builder.append("typedef struct {");
      _builder.newLine();
      _builder.append("\t");
      _builder.append("const ");
      String _portClassName_1 = this.roomExt.getPortClassName(pc, true);
      _builder.append(_portClassName_1, "	");
      _builder.append("* peer;");
      _builder.newLineIfNotEmpty();
      _builder.append("}");
      _builder.newLine();
      String _portClassName_2 = this.roomExt.getPortClassName(pc, false);
      _builder.append(_portClassName_2, "");
      _builder.append(";");
      _builder.newLineIfNotEmpty();
      _builder.newLine();
      {
        for(final Message message : sentMsgs) {
          VarDecl _data_2 = message.getData();
          boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data_2, null);
          boolean hasData = _operator_notEquals;
          _builder.newLineIfNotEmpty();
          String _xifexpression_1 = null;
          if (hasData) {
            VarDecl _data_3 = message.getData();
            RefableType _refType_2 = _data_3.getRefType();
            DataType _type_1 = _refType_2.getType();
            String _typeName_1 = this._typeHelpers.typeName(_type_1);
            _xifexpression_1 = _typeName_1;
          } else {
            _xifexpression_1 = "";
          }
          String typeName_1 = _xifexpression_1;
          _builder.newLineIfNotEmpty();
          String _xifexpression_2 = null;
          boolean _operator_and = false;
          if (!hasData) {
            _operator_and = false;
          } else {
            VarDecl _data_4 = message.getData();
            RefableType _refType_3 = _data_4.getRefType();
            DataType _type_2 = _refType_3.getType();
            boolean _operator_not = BooleanExtensions.operator_not((_type_2 instanceof PrimitiveType));
            _operator_and = BooleanExtensions.operator_and(hasData, _operator_not);
          }
          if (_operator_and) {
            _xifexpression_2 = "*";
          } else {
            _xifexpression_2 = "";
          }
          String refp_1 = _xifexpression_2;
          _builder.newLineIfNotEmpty();
          String _xifexpression_3 = null;
          if (hasData) {
            String _operator_plus = StringExtensions.operator_plus(", ", typeName_1);
            String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, refp_1);
            String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, " data");
            _xifexpression_3 = _operator_plus_2;
          } else {
            _xifexpression_3 = "";
          }
          String data = _xifexpression_3;
          _builder.newLineIfNotEmpty();
          String _portClassName_3 = this.roomExt.getPortClassName(pc, true);
          String _name_1 = message.getName();
          String _messageSetterSignature = this.messageSetterSignature(_portClassName_3, _name_1, data);
          _builder.append(_messageSetterSignature, "");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
          String _portClassName_4 = this.roomExt.getPortClassName(pc, false);
          String _name_2 = message.getName();
          String _messageGetterSignature = this.messageGetterSignature(_portClassName_4, _name_2, typeName_1);
          _builder.append(_messageGetterSignature, "");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
          _builder.newLine();
        }
      }
      _xblockexpression = (_builder);
    }
    return _xblockexpression;
  }
  
  private StringConcatenation genDataDrivenPortSources(final ProtocolClass pc) {
    StringConcatenation _xblockexpression = null;
    {
      List<Message> _allIncomingMessages = this.roomExt.getAllIncomingMessages(pc);
      final Function1<Message,Boolean> _function = new Function1<Message,Boolean>() {
          public Boolean apply(final Message m) {
            VarDecl _data = m.getData();
            boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data, null);
            return ((Boolean)_operator_notEquals);
          }
        };
      Iterable<Message> _filter = IterableExtensions.<Message>filter(_allIncomingMessages, _function);
      Iterable<Message> messages = _filter;
      StringConcatenation _builder = new StringConcatenation();
      {
        for(final Message message : messages) {
          VarDecl _data = message.getData();
          RefableType _refType = _data.getRefType();
          DataType _type = _refType.getType();
          String _typeName = this._typeHelpers.typeName(_type);
          String typeName = _typeName;
          _builder.newLineIfNotEmpty();
          String _xifexpression = null;
          VarDecl _data_1 = message.getData();
          RefableType _refType_1 = _data_1.getRefType();
          DataType _type_1 = _refType_1.getType();
          boolean _operator_not = BooleanExtensions.operator_not((_type_1 instanceof PrimitiveType));
          if (_operator_not) {
            _xifexpression = "*";
          } else {
            _xifexpression = "";
          }
          String refp = _xifexpression;
          _builder.newLineIfNotEmpty();
          String _xifexpression_1 = null;
          VarDecl _data_2 = message.getData();
          RefableType _refType_2 = _data_2.getRefType();
          DataType _type_2 = _refType_2.getType();
          if ((_type_2 instanceof PrimitiveType)) {
            _xifexpression_1 = "&";
          } else {
            _xifexpression_1 = "";
          }
          String refa = _xifexpression_1;
          _builder.newLineIfNotEmpty();
          String _operator_plus = StringExtensions.operator_plus(", ", typeName);
          String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, refp);
          String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, " data");
          String data = _operator_plus_2;
          _builder.newLineIfNotEmpty();
          String _portClassName = this.roomExt.getPortClassName(pc, true);
          String _name = message.getName();
          String _messageSetterSignature = this.messageSetterSignature(_portClassName, _name, data);
          _builder.append(_messageSetterSignature, "");
          _builder.append(" {");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("self->");
          String _name_1 = message.getName();
          _builder.append(_name_1, "	");
          _builder.append(" = data;");
          _builder.newLineIfNotEmpty();
          _builder.append("}");
          _builder.newLine();
          String _portClassName_1 = this.roomExt.getPortClassName(pc, false);
          String _name_2 = message.getName();
          String _messageGetterSignature = this.messageGetterSignature(_portClassName_1, _name_2, typeName);
          _builder.append(_messageGetterSignature, "");
          _builder.append(" {");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("return self->peer->");
          String _name_3 = message.getName();
          _builder.append(_name_3, "	");
          _builder.append(";");
          _builder.newLineIfNotEmpty();
          _builder.append("}");
          _builder.newLine();
          _builder.newLine();
        }
      }
      _xblockexpression = (_builder);
    }
    return _xblockexpression;
  }
  
  private StringConcatenation portClassSource(final ProtocolClass pc, final Boolean conj) {
    StringConcatenation _xblockexpression = null;
    {
      String _portClassName = this.roomExt.getPortClassName(pc, conj);
      String portClassName = _portClassName;
      String _portClassName_1 = this.roomExt.getPortClassName(pc, conj, true);
      String replPortClassName = _portClassName_1;
      List<Message> _xifexpression = null;
      if (conj) {
        List<Message> _allIncomingMessages = this.roomExt.getAllIncomingMessages(pc);
        _xifexpression = _allIncomingMessages;
      } else {
        List<Message> _allOutgoingMessages = this.roomExt.getAllOutgoingMessages(pc);
        _xifexpression = _allOutgoingMessages;
      }
      List<Message> messages = _xifexpression;
      String _xifexpression_1 = null;
      if (conj) {
        _xifexpression_1 = "IN_";
      } else {
        _xifexpression_1 = "OUT_";
      }
      String dir = _xifexpression_1;
      StringConcatenation _builder = new StringConcatenation();
      {
        for(final Message message : messages) {
          VarDecl _data = message.getData();
          boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data, null);
          boolean hasData = _operator_notEquals;
          _builder.newLineIfNotEmpty();
          String _xifexpression_2 = null;
          if (hasData) {
            VarDecl _data_1 = message.getData();
            RefableType _refType = _data_1.getRefType();
            DataType _type = _refType.getType();
            String _typeName = this._typeHelpers.typeName(_type);
            _xifexpression_2 = _typeName;
          } else {
            _xifexpression_2 = "";
          }
          String typeName = _xifexpression_2;
          _builder.newLineIfNotEmpty();
          String _xifexpression_3 = null;
          boolean _operator_and = false;
          if (!hasData) {
            _operator_and = false;
          } else {
            VarDecl _data_2 = message.getData();
            RefableType _refType_1 = _data_2.getRefType();
            DataType _type_1 = _refType_1.getType();
            boolean _operator_not = BooleanExtensions.operator_not((_type_1 instanceof PrimitiveType));
            _operator_and = BooleanExtensions.operator_and(hasData, _operator_not);
          }
          if (_operator_and) {
            _xifexpression_3 = "*";
          } else {
            _xifexpression_3 = "";
          }
          String refp = _xifexpression_3;
          _builder.newLineIfNotEmpty();
          String _xifexpression_4 = null;
          boolean _operator_and_1 = false;
          if (!hasData) {
            _operator_and_1 = false;
          } else {
            VarDecl _data_3 = message.getData();
            RefableType _refType_2 = _data_3.getRefType();
            DataType _type_2 = _refType_2.getType();
            _operator_and_1 = BooleanExtensions.operator_and(hasData, (_type_2 instanceof PrimitiveType));
          }
          if (_operator_and_1) {
            _xifexpression_4 = "&";
          } else {
            _xifexpression_4 = "";
          }
          String refa = _xifexpression_4;
          _builder.newLineIfNotEmpty();
          String _xifexpression_5 = null;
          if (hasData) {
            String _operator_plus = StringExtensions.operator_plus(", ", typeName);
            String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, refp);
            String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, " data");
            _xifexpression_5 = _operator_plus_2;
          } else {
            _xifexpression_5 = "";
          }
          String data = _xifexpression_5;
          _builder.newLineIfNotEmpty();
          _builder.newLine();
          String _name = message.getName();
          String _messageSignature = this.messageSignature(portClassName, _name, "", data);
          _builder.append(_messageSignature, "");
          _builder.append(" {");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\"");
          _builder.append(portClassName, "	");
          _builder.append("\", \"");
          String _name_1 = message.getName();
          _builder.append(_name_1, "	");
          _builder.append("\")");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("if (self->receiveMessageFunc!=NULL) {");
          _builder.newLine();
          _builder.append("\t\t");
          String _name_2 = pc.getName();
          String _name_3 = message.getName();
          String _operator_plus_3 = StringExtensions.operator_plus(dir, _name_3);
          String _memberInUse = this.stdExt.memberInUse(_name_2, _operator_plus_3);
          String _operator_plus_4 = StringExtensions.operator_plus(refa, "data");
          String _sendMessageCall = this.sendMessageCall(hasData, "self", _memberInUse, typeName, _operator_plus_4);
          _builder.append(_sendMessageCall, "		");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("}");
          _builder.newLine();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_EXIT");
          _builder.newLine();
          _builder.append("}");
          _builder.newLine();
          _builder.newLine();
          String _name_4 = message.getName();
          String _messageSignature_1 = this.messageSignature(replPortClassName, _name_4, "_broadcast", data);
          _builder.append(_messageSignature_1, "");
          _builder.append(" {");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("int i;");
          _builder.newLine();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\"");
          _builder.append(replPortClassName, "	");
          _builder.append("\", \"");
          String _name_5 = message.getName();
          _builder.append(_name_5, "	");
          _builder.append("\")");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("for (i=0; i<self->size; ++i) {");
          _builder.newLine();
          _builder.append("\t\t");
          String _name_6 = pc.getName();
          String _name_7 = message.getName();
          String _operator_plus_5 = StringExtensions.operator_plus(dir, _name_7);
          String _memberInUse_1 = this.stdExt.memberInUse(_name_6, _operator_plus_5);
          String _operator_plus_6 = StringExtensions.operator_plus(refa, "data");
          String _sendMessageCall_1 = this.sendMessageCall(hasData, "(etPort*)(&self->ports[i])", _memberInUse_1, typeName, _operator_plus_6);
          _builder.append(_sendMessageCall_1, "		");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("}");
          _builder.newLine();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_EXIT");
          _builder.newLine();
          _builder.append("}");
          _builder.newLine();
          _builder.newLine();
          String _name_8 = message.getName();
          String _operator_plus_7 = StringExtensions.operator_plus(", int idx", data);
          String _messageSignature_2 = this.messageSignature(replPortClassName, _name_8, "", _operator_plus_7);
          _builder.append(_messageSignature_2, "");
          _builder.append(" {");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_ENTRY(\"");
          _builder.append(replPortClassName, "	");
          _builder.append("\", \"");
          String _name_9 = message.getName();
          _builder.append(_name_9, "	");
          _builder.append("\")");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("if (0<=idx && idx<self->size) {");
          _builder.newLine();
          _builder.append("\t\t");
          String _name_10 = pc.getName();
          String _name_11 = message.getName();
          String _operator_plus_8 = StringExtensions.operator_plus(dir, _name_11);
          String _memberInUse_2 = this.stdExt.memberInUse(_name_10, _operator_plus_8);
          String _operator_plus_9 = StringExtensions.operator_plus(refa, "data");
          String _sendMessageCall_2 = this.sendMessageCall(hasData, "(etPort*)(&self->ports[idx])", _memberInUse_2, typeName, _operator_plus_9);
          _builder.append(_sendMessageCall_2, "		");
          _builder.newLineIfNotEmpty();
          _builder.append("\t");
          _builder.append("}");
          _builder.newLine();
          _builder.append("\t");
          _builder.append("ET_MSC_LOGGER_SYNC_EXIT");
          _builder.newLine();
          _builder.append("}");
          _builder.newLine();
        }
      }
      _xblockexpression = (_builder);
    }
    return _xblockexpression;
  }
  
  private String sendMessageCall(final boolean hasData, final String self, final String msg, final String typeName, final String data) {
    String _xifexpression = null;
    if (hasData) {
      String _operator_plus = StringExtensions.operator_plus("etPort_sendMessage(", self);
      String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, ", ");
      String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, msg);
      String _operator_plus_3 = StringExtensions.operator_plus(_operator_plus_2, ", sizeof(");
      String _operator_plus_4 = StringExtensions.operator_plus(_operator_plus_3, typeName);
      String _operator_plus_5 = StringExtensions.operator_plus(_operator_plus_4, "), ");
      String _operator_plus_6 = StringExtensions.operator_plus(_operator_plus_5, data);
      String _operator_plus_7 = StringExtensions.operator_plus(_operator_plus_6, ");");
      _xifexpression = _operator_plus_7;
    } else {
      String _operator_plus_8 = StringExtensions.operator_plus("etPort_sendMessage(", self);
      String _operator_plus_9 = StringExtensions.operator_plus(_operator_plus_8, ", ");
      String _operator_plus_10 = StringExtensions.operator_plus(_operator_plus_9, msg);
      String _operator_plus_11 = StringExtensions.operator_plus(_operator_plus_10, ", 0, NULL);");
      _xifexpression = _operator_plus_11;
    }
    return _xifexpression;
  }
  
  private String messageSignature(final String className, final String messageName, final String methodSuffix, final String data) {
    String _operator_plus = StringExtensions.operator_plus("void ", className);
    String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, "_");
    String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, messageName);
    String _operator_plus_3 = StringExtensions.operator_plus(_operator_plus_2, methodSuffix);
    String _operator_plus_4 = StringExtensions.operator_plus(_operator_plus_3, "(const ");
    String _operator_plus_5 = StringExtensions.operator_plus(_operator_plus_4, className);
    String _operator_plus_6 = StringExtensions.operator_plus(_operator_plus_5, "* self");
    String _operator_plus_7 = StringExtensions.operator_plus(_operator_plus_6, data);
    String _operator_plus_8 = StringExtensions.operator_plus(_operator_plus_7, ")");
    return _operator_plus_8;
  }
  
  private String messageSetterSignature(final String className, final String messageName, final String data) {
    String _operator_plus = StringExtensions.operator_plus("void ", className);
    String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, "_");
    String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, messageName);
    String _operator_plus_3 = StringExtensions.operator_plus(_operator_plus_2, "_set(");
    String _operator_plus_4 = StringExtensions.operator_plus(_operator_plus_3, className);
    String _operator_plus_5 = StringExtensions.operator_plus(_operator_plus_4, "* self");
    String _operator_plus_6 = StringExtensions.operator_plus(_operator_plus_5, data);
    String _operator_plus_7 = StringExtensions.operator_plus(_operator_plus_6, ")");
    return _operator_plus_7;
  }
  
  private String messageGetterSignature(final String className, final String messageName, final String type) {
    String _operator_plus = StringExtensions.operator_plus(type, " ");
    String _operator_plus_1 = StringExtensions.operator_plus(_operator_plus, className);
    String _operator_plus_2 = StringExtensions.operator_plus(_operator_plus_1, "_");
    String _operator_plus_3 = StringExtensions.operator_plus(_operator_plus_2, messageName);
    String _operator_plus_4 = StringExtensions.operator_plus(_operator_plus_3, "_get(const ");
    String _operator_plus_5 = StringExtensions.operator_plus(_operator_plus_4, className);
    String _operator_plus_6 = StringExtensions.operator_plus(_operator_plus_5, "* const self)");
    return _operator_plus_6;
  }
  
  private StringConcatenation messageCall(final Message m) {
    StringConcatenation _builder = new StringConcatenation();
    String _name = m.getName();
    _builder.append(_name, "");
    _builder.append("(");
    {
      VarDecl _data = m.getData();
      boolean _operator_notEquals = ObjectExtensions.operator_notEquals(_data, null);
      if (_operator_notEquals) {
        _builder.append(" ");
        VarDecl _data_1 = m.getData();
        String _name_1 = _data_1.getName();
        _builder.append(_name_1, "");
      }
    }
    _builder.append(")");
    _builder.newLineIfNotEmpty();
    return _builder;
  }
  
  private StringConcatenation generateDebugHelpersImplementation(final Root root, final ProtocolClass pc) {
    StringConcatenation _builder = new StringConcatenation();
    _builder.newLine();
    _builder.append("/* message names as strings for debugging (generate MSC) */");
    _builder.newLine();
    _builder.append("static const char* ");
    String _name = pc.getName();
    _builder.append(_name, "");
    _builder.append("_messageStrings[] = {\"MIN\", ");
    {
      List<Message> _allOutgoingMessages = this.roomExt.getAllOutgoingMessages(pc);
      for(final Message m : _allOutgoingMessages) {
        _builder.append("\"");
        String _name_1 = m.getName();
        _builder.append(_name_1, "");
        _builder.append("\",");
      }
    }
    {
      List<Message> _allIncomingMessages = this.roomExt.getAllIncomingMessages(pc);
      for(final Message m_1 : _allIncomingMessages) {
        _builder.append("\"");
        String _name_2 = m_1.getName();
        _builder.append(_name_2, "");
        _builder.append("\", ");
      }
    }
    _builder.append("\"MAX\"};");
    _builder.newLineIfNotEmpty();
    _builder.newLine();
    _builder.append("const char* ");
    String _name_3 = pc.getName();
    _builder.append(_name_3, "");
    _builder.append("_getMessageString(int msg_id) {");
    _builder.newLineIfNotEmpty();
    _builder.append("\t");
    _builder.append("if (msg_id<");
    String _name_4 = pc.getName();
    _builder.append(_name_4, "	");
    _builder.append("_MSG_MIN || msg_id>");
    String _name_5 = pc.getName();
    _builder.append(_name_5, "	");
    _builder.append("_MSG_MAX+1){");
    _builder.newLineIfNotEmpty();
    _builder.append("\t\t");
    _builder.append("/* id out of range */");
    _builder.newLine();
    _builder.append("\t\t");
    _builder.append("return \"Message ID out of range\";");
    _builder.newLine();
    _builder.append("\t");
    _builder.append("}");
    _builder.newLine();
    _builder.append("\t");
    _builder.append("else{");
    _builder.newLine();
    _builder.append("\t\t");
    _builder.append("return ");
    String _name_6 = pc.getName();
    _builder.append(_name_6, "		");
    _builder.append("_messageStrings[msg_id];");
    _builder.newLineIfNotEmpty();
    _builder.append("\t");
    _builder.append("}");
    _builder.newLine();
    _builder.append("}");
    _builder.newLine();
    return _builder;
  }
}