From d1cf354162e2b28e6f178b31166333ccf53dc3d9 Mon Sep 17 00:00:00 2001 From: John Rushford Date: Wed, 20 Dec 2017 13:05:36 -0700 Subject: [PATCH] Infinite loop in ExecuteOnNode() when all nodes error. --- node_manager.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/node_manager.go b/node_manager.go index 0945900..7b09263 100644 --- a/node_manager.go +++ b/node_manager.go @@ -67,6 +67,10 @@ func (nm *defaultNodeManager) ExecuteOnNode(nodes []*Node, command Command, prev break } + if err != nil { + return executed, err + } + nm.RLock() if startingIndex == nm.nodeIndex { nm.RUnlock()