Fix possible peer deadlock when peer completes.

onyx-platform · Oct 1, 2014 · 33ff91e · 33ff91e
1 parent b4cf752
commit 33ff91e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/onyx/coordinator/impl.clj b/src/onyx/coordinator/impl.clj
@@ -179,9 +179,9 @@
 
         (when (and (zero? n) (not complete?))
           (release-waiting-nodes! sync (:task-node peer-state))
-          (complete-task sync (:task-node peer-state))
-          (extensions/write-node sync cooldown-node {:completed? true}))
+          (complete-task sync (:task-node peer-state)))
 
+        (extensions/write-node sync cooldown-node {:completed? complete?})
         {:n-peers n :peer-state peer-state})
       (do (extensions/write-node sync cooldown-node {:completed? true})
           {:n-peers n :peer-state peer-state}))))