Coordination automata

plugins/core/hu.bme.mit.gamma.expression.model/src/hu/bme/mit/gamma/expression/util/ExpressionUtil.java

@@ -567,6 +567,15 @@ public Set<ValueDeclaration> getReferredValues(Expression expression) {
 		return referred;
 	}
 
+	public EnumerationLiteralDefinition getEnumerationLiteralDefinitionByName(EnumerationTypeDefinition typeDefinition, String name) {
+		for (EnumerationLiteralDefinition literal : typeDefinition.getLiterals()) {
+			if (literal.getName().equals(name)) {
+				return literal;
+			}
+		}
+		throw new IllegalArgumentException("No EnumerationLiteralDefinition found in: " + typeDefinition + " for name: " + name);
+	}
+
 	// Extract parameters
 
 	public List<ConstantDeclaration> extractParameters(ParametricElement parametricElement,
@@ -1271,6 +1280,12 @@ public EnumerationLiteralExpression createEnumerationLiteralExpression(
 		return literalExpression;
 	}
 
+
+	public EnumerationLiteralExpression createEnumerationLiteralExpression(
+			EnumerationTypeDefinition typeDefinition, String name) {
+		return createEnumerationLiteralExpression(getEnumerationLiteralDefinitionByName(typeDefinition, name));
+	}
+
 	public Expression createDefaultExpression(Collection<? extends Expression> expressions) {
 		Expression orExpression = wrapIntoOrExpression(expressions);
 		NotExpression notExpression = createNotExpression(

plugins/core/hu.bme.mit.gamma.statechart.language/src/hu/bme/mit/gamma/statechart/language/StatechartLanguage.xtext

@@ -436,8 +436,9 @@ DeepHistoryState returns DeepHistoryState:
 
 Component returns InterfaceModel::Component:
 	SynchronousComponent |
-	AsynchronousComponent |
-	CoordinationStatechartDefinition
+	AsynchronousComponent | 
+	SynchronousCoordinationStatechartDefinition |
+	AsynchronousCoordinationStatechartDefinition
 ;
 
 SynchronousComponent returns CompositeModel::SynchronousComponent:
@@ -738,7 +739,7 @@ ComponentInstanceReflectiveElementReferenceExpression returns CompositeModel::Co
 
 //
 
-CoordinationStatechartDefinition returns CoordinationStatechartDefinition:
+SynchronousCoordinationStatechartDefinition returns SynchronousCoordinationStatechartDefinition:
 	'@Coordination'
 	(
 		('@RegionSchedule' '=' schedulingOrder=SchedulingOrder)? &
@@ -749,20 +750,90 @@ CoordinationStatechartDefinition returns CoordinationStatechartDefinition:
 			annotations+=StatechartContractAnnotation
 		)*
 	)
-	'statechart' name=ID 
+	'coordination-statechart' name=ID
 	('(' ((parameterDeclarations+=ParameterDeclaration)(',' parameterDeclarations+=ParameterDeclaration)*)? ')')?
-		('[' ((ports+=Port)((',')? ports+=Port)*)? ']')? '{'
-			(
-				variableDeclarations+=VariableDeclaration |
-				timeoutDeclarations+=TimeoutDeclaration |
-				('invariant' invariants+=Expression)
-			)*
-			(
-				regions+=Region |
-				transitions+=Transition
-			)*
-			functionDeclarations+=FunctionDeclaration*
+	('[' ((ports+=Port)((',')? ports+=Port)*)? ']')?
+	'{'
+		(
+			components+=SynchronousComponentInstance |
+			portBindings+=PortBinding |
+			channels+=Channel
+		)*
 	'}'
+	'<'
+		(
+			variableDeclarations+=VariableDeclaration |
+			timeoutDeclarations+=TimeoutDeclaration |
+			('invariant' invariants+=Expression)
+		)*
+		(
+			regions+=Region |
+			coordinationTransitions+=CoordinationTransition
+		)*
+		functionDeclarations+=FunctionDeclaration*
+	'>'
+;
+
+AsynchronousCoordinationStatechartDefinition returns AsynchronousCoordinationStatechartDefinition:
+	'@Coordination'
+	'@Asynchronous'
+	(
+		('@RegionSchedule' '=' schedulingOrder=SchedulingOrder)? &
+		('@OrthogonalRegionSchedule' '=' orthogonalRegionSchedulingOrder=OrthogonalRegionSchedulingOrder)? &
+		('@TransitionPriority' '=' transitionPriority=TransitionPriority)? &
+		('@GuardEvaluation' '=' guardEvaluation=GuardEvaluation)? &
+		(	annotations+=ComponentAnnotation |
+			annotations+=StatechartContractAnnotation
+		)*
+	)
+	'coordination-statechart' name=ID
+	('(' ((parameterDeclarations+=ParameterDeclaration)(',' parameterDeclarations+=ParameterDeclaration)*)? ')')?
+	('[' ((ports+=Port)((',')? ports+=Port)*)? ']')?
+	'{'
+		(
+			components+=AsynchronousComponentInstance |
+			portBindings+=PortBinding |
+			channels+=Channel
+		)*
+	'}'
+	'<'
+		(
+			variableDeclarations+=VariableDeclaration |
+			timeoutDeclarations+=TimeoutDeclaration |
+			('invariant' invariants+=Expression)
+		)*
+		(
+			regions+=Region |
+			coordinationTransitions+=CoordinationTransition
+		)*
+		functionDeclarations+=FunctionDeclaration*
+	'>'
+;
+
+AbstractCoordinationReferenceExpression returns AbstractCoordinationReferenceExpression:
+	SequentialCoordinationReferenceExpression
+	| UnorderedCoordinationReferenceExpression
+;
+
+SequentialCoordinationReferenceExpression returns SequentialCoordinationReferenceExpression:
+	'seq' '{' instances+=ComponentInstanceReferenceExpression((',') instances+=ComponentInstanceReferenceExpression)* '}' | instances+=ComponentInstanceReferenceExpression
+;
+
+UnorderedCoordinationReferenceExpression returns UnorderedCoordinationReferenceExpression:
+	'unord' '{' instances+=ComponentInstanceReferenceExpression ((',') instances+=ComponentInstanceReferenceExpression)* '}'
+;
+
+CoordinationTransition returns CoordinationTransition:
+
+	(annotations+=TransitionAnnotation)*
+	'transition' ('(' priority=INTEGER ')')?
+	'from' sourceState=[StateNode] 'to' targetState=[StateNode]
+
+	('when' trigger=Trigger)?
+	('[' guard=Expression ']')?
+	('execute' coordinatedComponent=AbstractCoordinationReferenceExpression)?
+	('/' ( => effects+=Action)* )?
+
 ;
 
 //

plugins/core/hu.bme.mit.gamma.statechart.language/src/hu/bme/mit/gamma/statechart/language/scoping/StatechartLanguageScopeProvider.java

@@ -74,6 +74,7 @@
 import hu.bme.mit.gamma.statechart.phase.PhaseModelPackage;
 import hu.bme.mit.gamma.statechart.statechart.AnyPortEventReference;
 import hu.bme.mit.gamma.statechart.statechart.CompositeElement;
+import hu.bme.mit.gamma.statechart.statechart.CoordinationStatechartDefinition;
 import hu.bme.mit.gamma.statechart.statechart.PortEventReference;
 import hu.bme.mit.gamma.statechart.statechart.RaiseEventAction;
 import hu.bme.mit.gamma.statechart.statechart.Region;
@@ -367,13 +368,25 @@ public IScope getScope(final EObject context, final EReference reference) {
 				}
 				return scope;
 			}
+//			if (ecoreUtil.hasContainerOfType(context, CoordinationStatechartDefinition.class)) {
+//				CoordinationStatechartDefinition parent = ecoreUtil.getSelfOrContainerOfType(context, CoordinationStatechartDefinition.class);
+//				ComponentInstance component = parent.getCoordinatedComponent();
+//				if (component instanceof AsynchronousComponentInstance) {
+//					return handleTypeDeclarationAndComponentInstanceElementReferences(context, reference, null, ((AsynchronousComponentInstance)component).getType());
+//				}
+//				if (component instanceof SynchronousComponentInstance) {
+//					return handleTypeDeclarationAndComponentInstanceElementReferences(context, reference, null, ((SynchronousComponentInstance)component).getType());
+//				}
+//				return null;
+//			}
+			// 
 		} catch (NullPointerException e) {
 			// Nullptr exception is thrown if the scope turns out to be empty
 			// This can be due to modeling error of the user, e.g., there are no in events on the specified ports
 			return super.getScope(context, reference);
 		} catch (Exception e) {
 			e.printStackTrace();
-		} 
+		}
 		return super.getScope(context, reference);
 	}
 

plugins/core/hu.bme.mit.gamma.statechart.language/src/hu/bme/mit/gamma/statechart/language/validation/StatechartLanguageValidator.java

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (c) 2018-2024 Contributors to the Gamma project
+ * Copyright (c) 2018-2025 Contributors to the Gamma project
  *
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0

plugins/core/hu.bme.mit.gamma.statechart.model/model/statechart.ecore

@@ -164,6 +164,28 @@
     <eStructuralFeatures xsi:type="ecore:EReference" name="timeout" lowerBound="1"
         eType="#//TimeoutDeclaration"/>
   </eClassifiers>
-  <eClassifiers xsi:type="ecore:EClass" name="CoordinationStatechartDefinition" eSuperTypes="#//StatechartDefinition"/>
-  <eClassifiers xsi:type="ecore:EClass" name="CoordinationTransition" eSuperTypes="#//Transition"/>
+  <eClassifiers xsi:type="ecore:EClass" name="CoordinationStatechartDefinition" eSuperTypes="#//StatechartDefinition composite.ecore#//CompositeComponent">
+    <eStructuralFeatures xsi:type="ecore:EReference" name="coordinationTransitions"
+        upperBound="-1" eType="#//CoordinationTransition" containment="true"/>
+  </eClassifiers>
+  <eClassifiers xsi:type="ecore:EClass" name="SynchronousCoordinationStatechartDefinition"
+      eSuperTypes="#//CoordinationStatechartDefinition composite.ecore#//SynchronousComponent composite.ecore#//SynchronousCompositeComponent"/>
+  <eClassifiers xsi:type="ecore:EClass" name="AsynchronousCoordinationStatechartDefinition"
+      eSuperTypes="#//CoordinationStatechartDefinition composite.ecore#//AsynchronousComponent composite.ecore#//AsynchronousCompositeComponent"/>
+  <eClassifiers xsi:type="ecore:EClass" name="CoordinationTransition" eSuperTypes="#//Transition">
+    <eStructuralFeatures xsi:type="ecore:EReference" name="coordinatedComponent" eType="#//AbstractCoordinationReferenceExpression"
+        containment="true"/>
+  </eClassifiers>
+  <eClassifiers xsi:type="ecore:EClass" name="AbstractCoordinationReferenceExpression"
+      abstract="true" eSuperTypes="../../hu.bme.mit.gamma.expression.model/model/expression.ecore#//ReferenceExpression">
+    <eStructuralFeatures xsi:type="ecore:EReference" name="instances" lowerBound="1"
+        upperBound="-1" eType="ecore:EClass composite.ecore#//ComponentInstanceReferenceExpression"
+        containment="true"/>
+  </eClassifiers>
+  <eClassifiers xsi:type="ecore:EClass" name="SequentialCoordinationReferenceExpression"
+      eSuperTypes="#//AbstractCoordinationReferenceExpression"/>
+  <eClassifiers xsi:type="ecore:EClass" name="UnorderedCoordinationReferenceExpression"
+      eSuperTypes="#//AbstractCoordinationReferenceExpression"/>
+  <eClassifiers xsi:type="ecore:EClass" name="CoordinationVariableDeclarationAnnotation"
+      eSuperTypes="../../hu.bme.mit.gamma.expression.model/model/expression.ecore#//VariableDeclarationAnnotation"/>
 </ecore:EPackage>

plugins/core/hu.bme.mit.gamma.statechart.model/model/statechart.genmodel

@@ -397,7 +397,19 @@
     <genClasses ecoreClass="statechart.ecore#//TimeoutReferenceExpression">
       <genFeatures notify="false" createChild="false" propertySortChoices="true" ecoreFeature="ecore:EReference statechart.ecore#//TimeoutReferenceExpression/timeout"/>
     </genClasses>
-    <genClasses ecoreClass="statechart.ecore#//CoordinationStatechartDefinition"/>
-    <genClasses ecoreClass="statechart.ecore#//CoordinationTransition"/>
+    <genClasses ecoreClass="statechart.ecore#//CoordinationStatechartDefinition">
+      <genFeatures notify="false" createChild="false" propertySortChoices="true" ecoreFeature="ecore:EReference statechart.ecore#//CoordinationStatechartDefinition/coordinationTransitions"/>
+    </genClasses>
+    <genClasses ecoreClass="statechart.ecore#//SynchronousCoordinationStatechartDefinition"/>
+    <genClasses ecoreClass="statechart.ecore#//AsynchronousCoordinationStatechartDefinition"/>
+    <genClasses ecoreClass="statechart.ecore#//CoordinationTransition">
+      <genFeatures notify="false" createChild="false" propertySortChoices="true" ecoreFeature="ecore:EReference statechart.ecore#//CoordinationTransition/coordinatedComponent"/>
+    </genClasses>
+    <genClasses image="false" ecoreClass="statechart.ecore#//AbstractCoordinationReferenceExpression">
+      <genFeatures property="None" children="true" createChild="true" ecoreFeature="ecore:EReference statechart.ecore#//AbstractCoordinationReferenceExpression/instances"/>
+    </genClasses>
+    <genClasses ecoreClass="statechart.ecore#//SequentialCoordinationReferenceExpression"/>
+    <genClasses ecoreClass="statechart.ecore#//UnorderedCoordinationReferenceExpression"/>
+    <genClasses ecoreClass="statechart.ecore#//CoordinationVariableDeclarationAnnotation"/>
   </genPackages>
 </genmodel:GenModel>

plugins/core/hu.bme.mit.gamma.statechart.model/src/hu/bme/mit/gamma/statechart/derivedfeatures/StatechartModelDerivedFeatures.java

@@ -48,6 +48,7 @@
 import hu.bme.mit.gamma.expression.model.TypeDeclaration;
 import hu.bme.mit.gamma.expression.model.TypeDefinition;
 import hu.bme.mit.gamma.expression.model.TypeReference;
+import hu.bme.mit.gamma.expression.model.VariableDeclaration;
 import hu.bme.mit.gamma.statechart.composite.AbstractAsynchronousCompositeComponent;
 import hu.bme.mit.gamma.statechart.composite.AbstractSynchronousCompositeComponent;
 import hu.bme.mit.gamma.statechart.composite.AsynchronousAdapter;
@@ -106,11 +107,14 @@
 import hu.bme.mit.gamma.statechart.phase.MissionPhaseAnnotation;
 import hu.bme.mit.gamma.statechart.phase.MissionPhaseStateAnnotation;
 import hu.bme.mit.gamma.statechart.statechart.AnyPortEventReference;
+import hu.bme.mit.gamma.statechart.statechart.AsynchronousCoordinationStatechartDefinition;
 import hu.bme.mit.gamma.statechart.statechart.AsynchronousStatechartDefinition;
 import hu.bme.mit.gamma.statechart.statechart.BinaryTrigger;
 import hu.bme.mit.gamma.statechart.statechart.ChoiceState;
 import hu.bme.mit.gamma.statechart.statechart.ClockTickReference;
 import hu.bme.mit.gamma.statechart.statechart.CompositeElement;
+import hu.bme.mit.gamma.statechart.statechart.CoordinationStatechartDefinition;
+import hu.bme.mit.gamma.statechart.statechart.CoordinationVariableDeclarationAnnotation;
 import hu.bme.mit.gamma.statechart.statechart.DeepHistoryState;
 import hu.bme.mit.gamma.statechart.statechart.EntryState;
 import hu.bme.mit.gamma.statechart.statechart.ForkState;
@@ -130,6 +134,7 @@
 import hu.bme.mit.gamma.statechart.statechart.StateNode;
 import hu.bme.mit.gamma.statechart.statechart.StatechartAnnotation;
 import hu.bme.mit.gamma.statechart.statechart.StatechartDefinition;
+import hu.bme.mit.gamma.statechart.statechart.SynchronousCoordinationStatechartDefinition;
 import hu.bme.mit.gamma.statechart.statechart.SynchronousStatechartDefinition;
 import hu.bme.mit.gamma.statechart.statechart.TimeoutDeclaration;
 import hu.bme.mit.gamma.statechart.statechart.TimeoutEventReference;
@@ -140,6 +145,7 @@
 import hu.bme.mit.gamma.statechart.statechart.UnaryTrigger;
 import hu.bme.mit.gamma.statechart.util.StatechartUtil;
 
+
 public class StatechartModelDerivedFeatures extends ActionModelDerivedFeatures {
 
 	protected static final StatechartUtil statechartUtil = StatechartUtil.INSTANCE;
@@ -1876,10 +1882,7 @@ public static List<Port> getAllBoundSimplePorts(Component component) {
 	public static List<Port> getAllBoundSimplePorts(Port port) {
 		List<Port> simplePorts = new ArrayList<Port>();
 		Component component = getContainingComponent(port);
-		if (component instanceof StatechartDefinition) {
-			simplePorts.add(port);
-		}
-		else if (component instanceof CompositeComponent composite) {
+		if (component instanceof CompositeComponent composite) {
 			for (PortBinding portBinding : composite.getPortBindings()) {
 				if (portBinding.getCompositeSystemPort() == port) {
 					// Makes sense only if the containment hierarchy is a tree structure
@@ -1890,6 +1893,9 @@ else if (component instanceof CompositeComponent composite) {
 				}
 			}
 		}
+		else if (component instanceof StatechartDefinition) {
+			simplePorts.add(port);
+		}
 		// Note that one port can be in the list multiple times iff the component is NOT unfolded
 		return simplePorts;
 	}
@@ -2150,6 +2156,12 @@ public static List<? extends ComponentInstance> getDerivedComponents(CompositeCo
 		if (composite instanceof AbstractAsynchronousCompositeComponent asynchronousCompositeComponent) {
 			return asynchronousCompositeComponent.getComponents();
 		}
+		if (composite instanceof SynchronousCoordinationStatechartDefinition synchronousCoordinationStatechart) {
+			return synchronousCoordinationStatechart.getComponents();
+		}
+		if (composite instanceof AsynchronousCoordinationStatechartDefinition asynchronousCoordinationStatechart) {
+			return asynchronousCoordinationStatechart.getComponents();
+		}
 		throw new IllegalArgumentException("Not known type: " + composite);
 	}
 
@@ -2304,6 +2316,11 @@ public static List<Transition> getNonTrappingOutgoingTransitions(StateNode node)
 
 	public static List<Transition> getOutgoingTransitions(StateNode node) {
 		StatechartDefinition statechart = getContainingStatechart(node);
+		if (statechart instanceof CoordinationStatechartDefinition) {
+			// TODO CoordinationStatechart Validation
+			return ((CoordinationStatechartDefinition) statechart).getCoordinationTransitions().stream().filter(it -> it.getSourceState() == node)
+					.collect(Collectors.toList());
+		}
 		return statechart.getTransitions().stream().filter(it -> it.getSourceState() == node)
 				.collect(Collectors.toList());
 	}
@@ -2351,6 +2368,12 @@ public static List<Transition> getOutgoingTransitionsUntilState(StateNode node)
 
 	public static List<Transition> getIncomingTransitions(StateNode node) {
 		StatechartDefinition statechart = getContainingStatechart(node);
+		if (statechart instanceof CoordinationStatechartDefinition) {
+			// TODO CoordinationStatechart Validation
+			return ((CoordinationStatechartDefinition) statechart).getCoordinationTransitions().stream().filter(it -> it.getTargetState() == node)
+					.collect(Collectors.toList());
+		}
+
 		return statechart.getTransitions().stream().filter(it -> it.getTargetState() == node)
 				.collect(Collectors.toList());
 	}
@@ -2359,6 +2382,12 @@ public static List<Transition> getAllIncomingTransitions(StateNode node) {
 		List<StateNode> allStateNodes = ecoreUtil
 				.getSelfAndAllContentsOfType(node, StateNode.class);
 		StatechartDefinition statechart = getContainingStatechart(node);
+		if (statechart instanceof CoordinationStatechartDefinition) {
+			// TODO CoordinationStatechart Validation
+			return ((CoordinationStatechartDefinition) statechart).getCoordinationTransitions().stream()
+					.filter(it -> allStateNodes.contains(it.getTargetState()))
+					.collect(Collectors.toList());
+		}
 		return statechart.getTransitions().stream()
 				.filter(it -> allStateNodes.contains(it.getTargetState()))
 				.collect(Collectors.toList());
@@ -3788,4 +3817,11 @@ public static List<Expression> mapInterfaceInvariantsToPort(Port port) {
 		return interfaceInvariants;
 	}
 
+	// Coordination
+
+	public static List<VariableDeclaration> getCoordinationVariables(StatechartDefinition statechart) {
+		return filterVariablesByAnnotation(statechart.getVariableDeclarations(),
+				CoordinationVariableDeclarationAnnotation.class);
+	}
+
 }

plugins/core/hu.bme.mit.gamma.statechart.model/src/hu/bme/mit/gamma/statechart/util/StatechartModelValidator.java

@@ -107,6 +107,7 @@
 import hu.bme.mit.gamma.statechart.statechart.ChoiceState;
 import hu.bme.mit.gamma.statechart.statechart.ClockTickReference;
 import hu.bme.mit.gamma.statechart.statechart.ComplexTrigger;
+import hu.bme.mit.gamma.statechart.statechart.CoordinationTransition;
 import hu.bme.mit.gamma.statechart.statechart.EntryState;
 import hu.bme.mit.gamma.statechart.statechart.ForkState;
 import hu.bme.mit.gamma.statechart.statechart.InitialState;
@@ -706,6 +707,10 @@ public Collection<ValidationResultMessage> checkElseTransitionPriority(Transitio
 
 	public Collection<ValidationResultMessage> checkTransitionTriggers(Transition transition) {
 		Collection<ValidationResultMessage> validationResultMessages = new ArrayList<ValidationResultMessage>();
+		if (transition instanceof CoordinationTransition) {
+			// TODO
+			return validationResultMessages;		
+		}
 		if (!StatechartModelDerivedFeatures.needsTrigger(transition)) {
 			return validationResultMessages;
 		}