summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-16 13:17:20 +0200
committerBjörn Geiger2011-08-16 13:17:20 +0200
commit756259127cb73210ff52e6ef79d4cd2ede067dd5 (patch)
treec18d60ac39b5fc87550342943b352479e88782ab /gearman
parentMinor (diff)
downloadpoolctrl-756259127cb73210ff52e6ef79d4cd2ede067dd5.tar.gz
poolctrl-756259127cb73210ff52e6ef79d4cd2ede067dd5.tar.xz
poolctrl-756259127cb73210ff52e6ef79d4cd2ede067dd5.zip
kleine Korrektur
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