From 756259127cb73210ff52e6ef79d4cd2ede067dd5 Mon Sep 17 00:00:00 2001 From: Björn Geiger Date: Tue, 16 Aug 2011 13:17:20 +0200 Subject: kleine Korrektur --- gearman/controllerWorker/ControllerWorker/StatusWorker.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'gearman') 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 -- cgit v1.2.3-55-g7522