| /** |
| * Copyright (c) 2019 fortiss GmbH |
| * 2020 Johannes Kepler University Linz |
| * |
| * This program and the accompanying materials are made available under the |
| * terms of the Eclipse Public License 2.0 which is available at |
| * http://www.eclipse.org/legal/epl-2.0. |
| * |
| * SPDX-License-Identifier: EPL-2.0 |
| * |
| * Contributors: |
| * Martin Jobst - initial API and implementation and/or initial documentation |
| * Alois Zoitl - fixed adapter and fb number generation in connection lists |
| */ |
| package org.eclipse.fordiac.ide.export.forte_ng.composite; |
| |
| import com.google.common.base.Objects; |
| import com.google.common.collect.Iterables; |
| import java.nio.file.Path; |
| import java.util.ArrayList; |
| import java.util.Arrays; |
| import java.util.HashSet; |
| import java.util.List; |
| import org.eclipse.emf.common.util.EList; |
| import org.eclipse.emf.ecore.EObject; |
| import org.eclipse.fordiac.ide.export.forte_ng.ForteFBTemplate; |
| import org.eclipse.fordiac.ide.model.libraryElement.AdapterFB; |
| import org.eclipse.fordiac.ide.model.libraryElement.AdapterFBType; |
| import org.eclipse.fordiac.ide.model.libraryElement.CompositeFBType; |
| import org.eclipse.fordiac.ide.model.libraryElement.Connection; |
| import org.eclipse.fordiac.ide.model.libraryElement.DataConnection; |
| import org.eclipse.fordiac.ide.model.libraryElement.EventConnection; |
| import org.eclipse.fordiac.ide.model.libraryElement.FBNetworkElement; |
| import org.eclipse.fordiac.ide.model.libraryElement.FBType; |
| import org.eclipse.fordiac.ide.model.libraryElement.IInterfaceElement; |
| import org.eclipse.fordiac.ide.model.libraryElement.VarDeclaration; |
| import org.eclipse.xtend.lib.annotations.AccessorType; |
| import org.eclipse.xtend.lib.annotations.Accessors; |
| import org.eclipse.xtend2.lib.StringConcatenation; |
| import org.eclipse.xtext.xbase.lib.Functions.Function1; |
| import org.eclipse.xtext.xbase.lib.IterableExtensions; |
| import org.eclipse.xtext.xbase.lib.Pure; |
| |
| @SuppressWarnings("all") |
| public class CompositeFBImplTemplate extends ForteFBTemplate { |
| @Accessors(AccessorType.PROTECTED_GETTER) |
| private CompositeFBType type; |
| |
| private ArrayList<FBNetworkElement> fbs = new ArrayList<FBNetworkElement>(); |
| |
| private int numCompFBParams = 0; |
| |
| private int eConnNumber = 0; |
| |
| private int fannedOutEventConns = 0; |
| |
| private int dataConnNumber = 0; |
| |
| private int fannedOutDataConns = 0; |
| |
| public CompositeFBImplTemplate(final CompositeFBType type, final String name, final Path prefix) { |
| super(name, prefix); |
| this.type = type; |
| final Function1<FBNetworkElement, Boolean> _function = (FBNetworkElement it) -> { |
| FBType _type = it.getType(); |
| return Boolean.valueOf((!(_type instanceof AdapterFBType))); |
| }; |
| Iterables.<FBNetworkElement>addAll(this.fbs, IterableExtensions.<FBNetworkElement>filter(type.getFBNetwork().getNetworkElements(), _function)); |
| } |
| |
| @Override |
| public CharSequence generate() { |
| StringConcatenation _builder = new StringConcatenation(); |
| CharSequence _generateHeader = this.generateHeader(); |
| _builder.append(_generateHeader); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateImplIncludes = this.generateImplIncludes(); |
| _builder.append(_generateImplIncludes); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateFBDefinition = this.generateFBDefinition(); |
| _builder.append(_generateFBDefinition); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateFBInterfaceDefinition = this.generateFBInterfaceDefinition(); |
| _builder.append(_generateFBInterfaceDefinition); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateFBInterfaceSpecDefinition = this.generateFBInterfaceSpecDefinition(); |
| _builder.append(_generateFBInterfaceSpecDefinition); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| CharSequence _generateFBNetwork = this.generateFBNetwork(); |
| _builder.append(_generateFBNetwork); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| return _builder; |
| } |
| |
| protected CharSequence generateFBNetwork() { |
| StringConcatenation _builder = new StringConcatenation(); |
| { |
| final Function1<FBNetworkElement, Boolean> _function = (FBNetworkElement it) -> { |
| FBType _type = it.getType(); |
| return Boolean.valueOf((!(_type instanceof AdapterFBType))); |
| }; |
| boolean _exists = IterableExtensions.<FBNetworkElement>exists(this.type.getFBNetwork().getNetworkElements(), _function); |
| if (_exists) { |
| _builder.append("const SCFB_FBInstanceData "); |
| CharSequence _fBClassName = this.getFBClassName(); |
| _builder.append(_fBClassName); |
| _builder.append("::scm_astInternalFBs[] = {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| { |
| boolean _hasElements = false; |
| for(final FBNetworkElement elem : this.fbs) { |
| if (!_hasElements) { |
| _hasElements = true; |
| } else { |
| _builder.appendImmediate(",\n", " "); |
| } |
| _builder.append("{"); |
| CharSequence _fORTEString = this.getFORTEString(elem.getName()); |
| _builder.append(_fORTEString, " "); |
| _builder.append(", "); |
| CharSequence _fORTEString_1 = this.getFORTEString(elem.getType().getName()); |
| _builder.append(_fORTEString_1, " "); |
| _builder.append("}"); |
| } |
| } |
| _builder.newLineIfNotEmpty(); |
| _builder.append("};"); |
| _builder.newLine(); |
| } |
| } |
| _builder.newLine(); |
| CharSequence _exportFBParams = this.exportFBParams(this.type.getFBNetwork().getNetworkElements()); |
| _builder.append(_exportFBParams); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| { |
| boolean _isEmpty = this.type.getFBNetwork().getEventConnections().isEmpty(); |
| boolean _not = (!_isEmpty); |
| if (_not) { |
| StringBuilder _exportEventConns = this.exportEventConns(this.type.getFBNetwork().getEventConnections()); |
| _builder.append(_exportEventConns); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| } |
| } |
| { |
| boolean _isEmpty_1 = this.type.getFBNetwork().getDataConnections().isEmpty(); |
| boolean _not_1 = (!_isEmpty_1); |
| if (_not_1) { |
| StringBuilder _exportDataConns = this.exportDataConns(this.type.getFBNetwork().getDataConnections()); |
| _builder.append(_exportDataConns); |
| _builder.newLineIfNotEmpty(); |
| _builder.newLine(); |
| } |
| } |
| CharSequence _generateFBNDataStruct = this.generateFBNDataStruct(); |
| _builder.append(_generateFBNDataStruct); |
| _builder.newLineIfNotEmpty(); |
| return _builder; |
| } |
| |
| protected CharSequence generateFBNDataStruct() { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("const SCFB_FBNData "); |
| CharSequence _fBClassName = this.getFBClassName(); |
| _builder.append(_fBClassName); |
| _builder.append("::scm_stFBNData = {"); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| int _size = this.fbs.size(); |
| _builder.append(_size, " "); |
| _builder.append(", "); |
| { |
| boolean _isEmpty = this.fbs.isEmpty(); |
| boolean _not = (!_isEmpty); |
| if (_not) { |
| _builder.append("scm_astInternalFBs"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append(this.eConnNumber, " "); |
| _builder.append(", "); |
| { |
| if ((0 != this.eConnNumber)) { |
| _builder.append("scm_astEventConnections"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append(this.fannedOutEventConns, " "); |
| _builder.append(", "); |
| { |
| if ((0 != this.fannedOutEventConns)) { |
| _builder.append("scm_astFannedOutEventConnections"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append(this.dataConnNumber, " "); |
| _builder.append(", "); |
| { |
| if ((0 != this.dataConnNumber)) { |
| _builder.append("scm_astDataConnections"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append(this.fannedOutDataConns, " "); |
| _builder.append(", "); |
| { |
| if ((0 != this.fannedOutDataConns)) { |
| _builder.append("scm_astFannedOutDataConnections"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.append(","); |
| _builder.newLineIfNotEmpty(); |
| _builder.append(" "); |
| _builder.append(this.numCompFBParams, " "); |
| _builder.append(", "); |
| { |
| if ((0 != this.numCompFBParams)) { |
| _builder.append("scm_astParamters"); |
| } else { |
| _builder.append("nullptr"); |
| } |
| } |
| _builder.newLineIfNotEmpty(); |
| _builder.append("};"); |
| _builder.newLine(); |
| _builder.newLine(); |
| return _builder; |
| } |
| |
| protected String generateConnectionPortID(final IInterfaceElement iface, final FBNetworkElement elem) { |
| String _xifexpression = null; |
| boolean _contains = this.type.getFBNetwork().getNetworkElements().contains(elem); |
| if (_contains) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("GENERATE_CONNECTION_PORT_ID_2_ARG("); |
| CharSequence _fORTEString = this.getFORTEString(elem.getName()); |
| _builder.append(_fORTEString); |
| _builder.append(", "); |
| CharSequence _fORTEString_1 = this.getFORTEString(iface.getName()); |
| _builder.append(_fORTEString_1); |
| _builder.append("), "); |
| CharSequence _fbId = this.fbId(elem); |
| _builder.append(_fbId); |
| _xifexpression = _builder.toString(); |
| } else { |
| StringConcatenation _builder_1 = new StringConcatenation(); |
| _builder_1.append("GENERATE_CONNECTION_PORT_ID_1_ARG("); |
| CharSequence _fORTEString_2 = this.getFORTEString(iface.getName()); |
| _builder_1.append(_fORTEString_2); |
| _builder_1.append("), -1"); |
| _xifexpression = _builder_1.toString(); |
| } |
| return _xifexpression; |
| } |
| |
| protected CharSequence _fbId(final FBNetworkElement elem) { |
| StringConcatenation _builder = new StringConcatenation(); |
| int _indexOf = this.fbs.indexOf(elem); |
| _builder.append(_indexOf); |
| return _builder; |
| } |
| |
| protected CharSequence _fbId(final AdapterFB elem) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("CCompositeFB::scm_nAdapterMarker | "); |
| { |
| boolean _isPlug = elem.isPlug(); |
| if (_isPlug) { |
| int _plugIndex = this.getPlugIndex(elem); |
| _builder.append(_plugIndex); |
| } else { |
| int _indexOf = this.type.getInterfaceList().getSockets().indexOf(elem.getAdapterDecl()); |
| _builder.append(_indexOf); |
| } |
| } |
| return _builder; |
| } |
| |
| protected int getPlugIndex(final AdapterFB elem) { |
| int _size = this.type.getInterfaceList().getSockets().size(); |
| int _indexOf = this.type.getInterfaceList().getPlugs().indexOf(elem.getAdapterDecl()); |
| return (_size + _indexOf); |
| } |
| |
| protected StringBuilder exportEventConns(final EList<EventConnection> eConns) { |
| StringBuilder _xblockexpression = null; |
| { |
| StringBuilder retVal = new StringBuilder(); |
| HashSet<Connection> conSet = new HashSet<Connection>(); |
| StringBuilder fannedOutConns = new StringBuilder(); |
| CharSequence _fBClassName = this.getFBClassName(); |
| String _plus = ("const SCFB_FBConnectionData " + _fBClassName); |
| String _plus_1 = (_plus + "::scm_astEventConnections[] = {\n"); |
| retVal.append(_plus_1); |
| for (final Connection eConn : eConns) { |
| boolean _contains = conSet.contains(eConn); |
| boolean _not = (!_contains); |
| if (_not) { |
| conSet.add(eConn); |
| retVal.append(this.getConnListEntry(eConn)); |
| int _size = eConn.getSource().getOutputConnections().size(); |
| boolean _greaterThan = (_size > 1); |
| if (_greaterThan) { |
| final Function1<Connection, Boolean> _function = (Connection it) -> { |
| boolean _equals = Objects.equal(it, eConn); |
| return Boolean.valueOf((!_equals)); |
| }; |
| Iterable<Connection> _filter = IterableExtensions.<Connection>filter(eConn.getSource().getOutputConnections(), _function); |
| for (final Connection fannedConn : _filter) { |
| { |
| conSet.add(fannedConn); |
| fannedOutConns.append(this.genFannedOutConnString(fannedConn, this.eConnNumber)); |
| this.fannedOutEventConns++; |
| } |
| } |
| } |
| this.eConnNumber++; |
| } |
| } |
| retVal.append("};\n"); |
| CharSequence _fBClassName_1 = this.getFBClassName(); |
| String _plus_2 = ("\nconst SCFB_FBFannedOutConnectionData " + _fBClassName_1); |
| String _plus_3 = (_plus_2 + "::scm_astFannedOutEventConnections[] = {\n"); |
| retVal.append(_plus_3); |
| if ((0 != this.fannedOutEventConns)) { |
| retVal.append(fannedOutConns); |
| } |
| _xblockexpression = retVal.append("};\n"); |
| } |
| return _xblockexpression; |
| } |
| |
| protected StringBuilder exportDataConns(final EList<DataConnection> dataConns) { |
| StringBuilder _xblockexpression = null; |
| { |
| StringBuilder retVal = new StringBuilder(); |
| HashSet<Connection> conSet = new HashSet<Connection>(); |
| StringBuilder fannedOutConns = new StringBuilder(); |
| CharSequence _fBClassName = this.getFBClassName(); |
| String _plus = ("const SCFB_FBConnectionData " + _fBClassName); |
| String _plus_1 = (_plus + "::scm_astDataConnections[] = {\n"); |
| retVal.append(_plus_1); |
| for (final DataConnection dConn : dataConns) { |
| boolean _contains = conSet.contains(dConn); |
| boolean _not = (!_contains); |
| if (_not) { |
| final Connection primConn = this.getPrimaryDataConn(dConn); |
| conSet.add(primConn); |
| retVal.append(this.getConnListEntry(primConn)); |
| int _size = primConn.getSource().getOutputConnections().size(); |
| boolean _greaterThan = (_size > 1); |
| if (_greaterThan) { |
| final Function1<Connection, Boolean> _function = (Connection it) -> { |
| boolean _equals = Objects.equal(it, primConn); |
| return Boolean.valueOf((!_equals)); |
| }; |
| Iterable<Connection> _filter = IterableExtensions.<Connection>filter(primConn.getSource().getOutputConnections(), _function); |
| for (final Connection fannedConn : _filter) { |
| { |
| conSet.add(fannedConn); |
| if ((this.hasCFBInterfaceDestination(fannedConn) && this.hasCFBInterfaceDestination(primConn))) { |
| fannedOutConns.append("#error a fanout to several composite FB\'s outputs is currently not supported: "); |
| List<String> _errors = this.getErrors(); |
| String _name = this.getName(); |
| String _plus_2 = (" - " + _name); |
| String _plus_3 = (_plus_2 + " FORTE does currently not allow that a data a composite\'s data connection may be connected to several data outputs of the composite FB."); |
| _errors.add(_plus_3); |
| } |
| fannedOutConns.append(this.genFannedOutConnString(fannedConn, this.dataConnNumber)); |
| this.fannedOutEventConns++; |
| } |
| } |
| } |
| this.dataConnNumber++; |
| } |
| } |
| retVal.append("};\n"); |
| CharSequence _fBClassName_1 = this.getFBClassName(); |
| String _plus_2 = ("\nconst SCFB_FBFannedOutConnectionData " + _fBClassName_1); |
| String _plus_3 = (_plus_2 + "::scm_astFannedOutDataConnections[] = {\n"); |
| retVal.append(_plus_3); |
| if ((0 != this.fannedOutDataConns)) { |
| retVal.append(fannedOutConns); |
| } |
| _xblockexpression = retVal.append("};\n"); |
| } |
| return _xblockexpression; |
| } |
| |
| protected CharSequence getConnListEntry(final Connection con) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append(" "); |
| _builder.append("{"); |
| String _generateConnectionPortID = this.generateConnectionPortID(con.getSource(), con.getSourceElement()); |
| _builder.append(_generateConnectionPortID, " "); |
| _builder.append(", "); |
| String _generateConnectionPortID_1 = this.generateConnectionPortID(con.getDestination(), con.getDestinationElement()); |
| _builder.append(_generateConnectionPortID_1, " "); |
| _builder.append("},"); |
| _builder.newLineIfNotEmpty(); |
| return _builder; |
| } |
| |
| protected CharSequence genFannedOutConnString(final Connection con, final int connNum) { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append(" "); |
| _builder.append("{"); |
| _builder.append(connNum, " "); |
| _builder.append(", "); |
| String _generateConnectionPortID = this.generateConnectionPortID(con.getDestination(), con.getDestinationElement()); |
| _builder.append(_generateConnectionPortID, " "); |
| _builder.append("},"); |
| _builder.newLineIfNotEmpty(); |
| return _builder; |
| } |
| |
| private Connection getPrimaryDataConn(final DataConnection dataConn) { |
| EList<Connection> _outputConnections = dataConn.getSource().getOutputConnections(); |
| for (final Connection dc : _outputConnections) { |
| boolean _hasCFBInterfaceDestination = this.hasCFBInterfaceDestination(dc); |
| if (_hasCFBInterfaceDestination) { |
| return dc; |
| } |
| } |
| return dataConn; |
| } |
| |
| private boolean hasCFBInterfaceDestination(final Connection conn) { |
| IInterfaceElement _destination = null; |
| if (conn!=null) { |
| _destination=conn.getDestination(); |
| } |
| EObject _eContainer = null; |
| if (_destination!=null) { |
| _eContainer=_destination.eContainer(); |
| } |
| EObject _eContainer_1 = null; |
| if (_eContainer!=null) { |
| _eContainer_1=_eContainer.eContainer(); |
| } |
| return (_eContainer_1 instanceof CompositeFBType); |
| } |
| |
| protected CharSequence exportFBParams(final EList<FBNetworkElement> fbs) { |
| CharSequence _xblockexpression = null; |
| { |
| StringBuilder retVal = new StringBuilder(); |
| for (final FBNetworkElement fb : fbs) { |
| final Function1<VarDeclaration, Boolean> _function = (VarDeclaration it) -> { |
| return Boolean.valueOf(((it.getValue() != null) && (!it.getValue().getValue().isEmpty()))); |
| }; |
| Iterable<VarDeclaration> _filter = IterableExtensions.<VarDeclaration>filter(fb.getInterface().getInputVars(), _function); |
| for (final VarDeclaration v : _filter) { |
| { |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append(" "); |
| _builder.append("{"); |
| CharSequence _fbId = this.fbId(fb); |
| _builder.append(_fbId, " "); |
| _builder.append(", g_nStringId"); |
| String _name = v.getName(); |
| _builder.append(_name, " "); |
| _builder.append(", \""); |
| String _paramValue = this.getParamValue(v); |
| _builder.append(_paramValue, " "); |
| _builder.append("\"},"); |
| _builder.newLineIfNotEmpty(); |
| retVal.append(_builder); |
| this.numCompFBParams++; |
| } |
| } |
| } |
| StringConcatenation _builder = new StringConcatenation(); |
| _builder.append("const SCFB_FBParameter "); |
| CharSequence _fBClassName = this.getFBClassName(); |
| _builder.append(_fBClassName); |
| _builder.append("::scm_astParamters[] = {"); |
| _builder.newLineIfNotEmpty(); |
| { |
| if ((0 != this.numCompFBParams)) { |
| String _string = retVal.toString(); |
| _builder.append(_string); |
| } |
| } |
| _builder.newLineIfNotEmpty(); |
| _builder.append("};"); |
| _xblockexpression = _builder; |
| } |
| return _xblockexpression; |
| } |
| |
| private String getParamValue(final VarDeclaration v) { |
| return v.getValue().getValue().replace("\"", "\\\""); |
| } |
| |
| protected CharSequence fbId(final FBNetworkElement elem) { |
| if (elem instanceof AdapterFB) { |
| return _fbId((AdapterFB)elem); |
| } else if (elem != null) { |
| return _fbId(elem); |
| } else { |
| throw new IllegalArgumentException("Unhandled parameter types: " + |
| Arrays.<Object>asList(elem).toString()); |
| } |
| } |
| |
| @Pure |
| @Override |
| protected CompositeFBType getType() { |
| return this.type; |
| } |
| } |
