diff options
Diffstat (limited to 'opendc-simulator/opendc-simulator-flow/src/main/java/org')
| -rw-r--r-- | opendc-simulator/opendc-simulator-flow/src/main/java/org/opendc/simulator/engine/graph/FlowNode.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/opendc-simulator/opendc-simulator-flow/src/main/java/org/opendc/simulator/engine/graph/FlowNode.java b/opendc-simulator/opendc-simulator-flow/src/main/java/org/opendc/simulator/engine/graph/FlowNode.java index 6ee947bc..b2827130 100644 --- a/opendc-simulator/opendc-simulator-flow/src/main/java/org/opendc/simulator/engine/graph/FlowNode.java +++ b/opendc-simulator/opendc-simulator-flow/src/main/java/org/opendc/simulator/engine/graph/FlowNode.java @@ -157,6 +157,11 @@ public abstract class FlowNode { * Update the state of the stage. */ public void update(long now) { + if (this.nodeState == NodeState.CLOSED) { + this.deadline = Long.MAX_VALUE; + return; + } + this.nodeState = NodeState.UPDATING; long newDeadline = this.deadline; |
