From 9a8408a092202ee111bb66e830414c3fd6f221fc Mon Sep 17 00:00:00 2001 From: James Shubin Date: Fri, 20 Apr 2018 21:07:26 -0400 Subject: [PATCH] engine: Small fixes --- engine/graph/state.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/engine/graph/state.go b/engine/graph/state.go index ff453e06..8fa1d654 100644 --- a/engine/graph/state.go +++ b/engine/graph/state.go @@ -69,11 +69,11 @@ type State struct { eventsLock *sync.Mutex // lock around sending and closing of events channel eventsDone bool // is channel closed? - // output is the channel that the engine listens on for events from the - // Watch loop for that resource. The event is nil normally, except when - // events are sent on this channel from the engine. This only happens - // as a signaling mechanism when Watch has shutdown and we want to - // notify the Process loop which reads from this. + // outputChan is the channel that the engine listens on for events from + // the Watch loop for that resource. The event is nil normally, except + // when events are sent on this channel from the engine. This only + // happens as a signaling mechanism when Watch has shutdown and we want + // to notify the Process loop which reads from this. outputChan chan error // outgoing from resource wg *sync.WaitGroup @@ -336,6 +336,7 @@ func (obj *State) event() error { case event.EventPoke: // we're trying to send an event, so swallow the // poke: it's what we wanted to have happen here + continue case event.EventStart: return fmt.Errorf("unexpected start") case event.EventPause: