diff --git a/build.gradle b/build.gradle index a31c9c7e143a9e756d8f3fde0e484ecbd6692b91..f1fccff554c855b567cf46df42bacd48c961f93b 100644 --- a/build.gradle +++ b/build.gradle @@ -230,8 +230,7 @@ task ragConnect(type: JavaExec) { '--tracing=flush', '--experimental-jastadd-329', '--logReads', - '--logWrites', - '--logIncremental' + '--logWrites' ]) } diff --git a/src/main/java/de/tudresden/inf/st/pnml/engine/ros/DiNeRosNode.java b/src/main/java/de/tudresden/inf/st/pnml/engine/ros/DiNeRosNode.java index 425542c1558b67772acd642af7d054cbf6e6fe26..76f99e14b1abfbb9e8ae9236bdcad55981d08bd6 100644 --- a/src/main/java/de/tudresden/inf/st/pnml/engine/ros/DiNeRosNode.java +++ b/src/main/java/de/tudresden/inf/st/pnml/engine/ros/DiNeRosNode.java @@ -72,14 +72,13 @@ public abstract class DiNeRosNode extends AbstractNodeMain { this.connectedNode.shutdown(); } - public void notify(java.lang.String notificationType){ + public synchronized void notify(java.lang.String notificationType){ Set<Transition> signalFilteredTransitions = getSignalFilteredTransitions(); if (notificationType.equals(NOTIFICATION_MARKING_CHANGE)) { onMarkingChangeInternal(signalFilteredTransitions); } else if (notificationType.equals(NOTIFICATION_SIGNAL_CHANGE)) { - System.out.println("NOTIFICATION_SIGNAL_CHANGE"); onSignalChangeInternal(signalFilteredTransitions); } else if (notificationType.equals(NOTIFICATION_WAIT_ENDED)) { onWaitEndedInternal(signalFilteredTransitions); @@ -90,7 +89,7 @@ public abstract class DiNeRosNode extends AbstractNodeMain { } @NotNull - private Set<Transition> getSignalFilteredTransitions() { + protected Set<Transition> getSignalFilteredTransitions() { Set<Transition> signalFilteredTransitions = new HashSet<>(); ClauseValuesDefinition clauseValuesDefinition = new ClauseValuesDefinition(); diff --git a/src/main/java/de/tudresden/inf/st/pnml/engine/testNodes/DinerosTestNode.java b/src/main/java/de/tudresden/inf/st/pnml/engine/testNodes/DinerosTestNode.java index b39ed23d0c285d17eb6669d6ecaf9177b8b2f0f8..d931a9e9f2f02d4506b4168fe71fc879f104d5a0 100644 --- a/src/main/java/de/tudresden/inf/st/pnml/engine/testNodes/DinerosTestNode.java +++ b/src/main/java/de/tudresden/inf/st/pnml/engine/testNodes/DinerosTestNode.java @@ -16,7 +16,7 @@ public class DinerosTestNode extends DiNeRosNode { } public DinerosTestNode(String nodeName, PetriNet petriNet, BalloonMarking marking, BalloonCallbackStorage callbackStorage) { - super(nodeName, petriNet, "localhost:2000", "mqtt"); + super(nodeName, petriNet, "localhost", "mqtt"); this.marking = marking; this.callbackStorage = callbackStorage; } @@ -46,9 +46,8 @@ public class DinerosTestNode extends DiNeRosNode { FiringSelectionSuccess fsc = new FiringSelectionSuccess(); System.out.println("#EnabledTrans: " + marking.enabledBalloonTransitions().size()); - for(Transition t : marking.enabledBalloonTransitions()){ + for(Transition t : getSignalFilteredTransitions()){ System.out.println("Firing transition: " + t.getId()); - //System.out.println(marking.print()); fsc.setTransition(t); break; }