summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
Diffstat (limited to 'gearman')
-rw-r--r--gearman/controllerWorker/ControllerWorker/StatusWorker.java6
1 files changed, 5 insertions, 1 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/StatusWorker.java b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
index 575a3cc..bcf678d 100644
--- a/gearman/controllerWorker/ControllerWorker/StatusWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
@@ -42,8 +42,9 @@ public class StatusWorker extends AbstractGearmanFunction {
if (boot.isFinished()) {
content.put("result", "Booting of " + event
+ " has been finished!");
- boot = null;
res.put(event, content);
+ BOOTTHREADS.remove(event);
+ boot = null;
} else if (boot.isFinishedWithErrors()) {
content.put("result", "Booting of " + event
+ " has not been finished, due to errors!");
@@ -55,6 +56,7 @@ public class StatusWorker extends AbstractGearmanFunction {
}
content.put("errors", clientErrors);
res.put(event, content);
+ BOOTTHREADS.remove(event);
boot = null;
} else {
content.put("result", "Booting of " + event
@@ -85,6 +87,7 @@ public class StatusWorker extends AbstractGearmanFunction {
content.put("result", "Shutdown of " + event
+ " has been finished!");
res.put(event, content);
+ SHUTDOWNTHREADS.remove(event);
shutdown = null;
} else if (shutdown.isFinishedWithErrors()) {
content.put("result", "Shutdown of " + event
@@ -97,6 +100,7 @@ public class StatusWorker extends AbstractGearmanFunction {
}
content.put("errors", clientErrors);
res.put(event, content);
+ SHUTDOWNTHREADS.remove(event);
shutdown = null;
} else {
content.put("result", "Shutdown of " + event