prevent 'one-plan' loop in shiftJobs

bem-archive · May 4, 2012 · 4fb88de · 4fb88de
1 parent 05aea89
commit 4fb88de
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/workers.js b/lib/workers.js
@@ -149,15 +149,17 @@ module.exports = INHERIT({
      */
     shiftJobFromPlans: function(id) {
         var plan = this.nextOperablePlan(),
-            startId = plan && plan.getId();
+            startId = plan && plan.getId(),
+            donePlans = {};
 
         if (startId) {
             do {
                 if (plan.nextJob(id)) {
                     this.addFinishListener(id, plan.getId());
                 }
+                donePlans[plan.getId()] = 1;
                 plan = this.nextOperablePlan();
-            } while (plan && plan.getId() !== startId);
+            } while (plan && !donePlans[plan.getId()]);
         }
     },