From e946b39960c8d3e495a2f79ec43a23badd53a1db Mon Sep 17 00:00:00 2001 From: James Shubin Date: Sat, 20 Jan 2024 01:49:07 -0500 Subject: [PATCH] engine: graph: Set closed flag when resume signal closes We had this backwards. Woops... --- engine/graph/actions.go | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/engine/graph/actions.go b/engine/graph/actions.go index 7ed2780c..fb092ead 100644 --- a/engine/graph/actions.go +++ b/engine/graph/actions.go @@ -459,7 +459,10 @@ Loop: // we are paused now, and waiting for resume or exit... select { - case _, closed = <-obj.state[vertex].resumeSignal: // channel closes + case _, ok := <-obj.state[vertex].resumeSignal: // channel closes + if !ok { + closed = true + } // resumed! // pass through to allow a Process to try to run // TODO: consider adding this fast pause here... @@ -525,7 +528,10 @@ Loop: break LimitWait } select { - case _, closed = <-obj.state[vertex].resumeSignal: // channel closes + case _, ok := <-obj.state[vertex].resumeSignal: // channel closes + if !ok { + closed = true + } // resumed! } } @@ -581,7 +587,10 @@ Loop: break RetryWait } select { - case _, closed = <-obj.state[vertex].resumeSignal: // channel closes + case _, ok := <-obj.state[vertex].resumeSignal: // channel closes + if !ok { + closed = true + } // resumed! } }