Skip to content

Commit

Permalink
Solved a small bug that let FlowNodes update while they are in a clos…
Browse files Browse the repository at this point in the history
…ed state. (#283)
  • Loading branch information
DanteNiewenhuis authored Dec 12, 2024
1 parent 8bbc3de commit f55aaed
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -245,6 +245,9 @@ public void addSupplierEdge(FlowEdge supplierEdge) {
*/
@Override
public void removeSupplierEdge(FlowEdge supplierEdge) {
if (this.machineEdge == null) {
return;
}
this.stopWorkload();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -157,6 +157,11 @@ public void invalidate() {
* 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;
Expand Down

0 comments on commit f55aaed

Please sign in to comment.