summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-23 13:31:44 +0200
committerBjörn Geiger2011-08-23 13:31:44 +0200
commit926dee1c1c584417d4a37c226e4ba4d0c1025e35 (patch)
tree9e18f59f221cade318762c3d24b5ef06895c442c /gearman/controllerWorker/ControllerWorker
parentBlack und Whitelist nun in der Application.ini (diff)
downloadpoolctrl-926dee1c1c584417d4a37c226e4ba4d0c1025e35.tar.gz
poolctrl-926dee1c1c584417d4a37c226e4ba4d0c1025e35.tar.xz
poolctrl-926dee1c1c584417d4a37c226e4ba4d0c1025e35.zip
Fehler korrigiert
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java13
-rw-r--r--gearman/controllerWorker/ControllerWorker/Shutdown.java13
2 files changed, 26 insertions, 0 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index db30c89..d2e4917 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -476,6 +476,19 @@ public class Boot extends Thread {
status.put(clientID, 13); // is not working
psJobs.remove(clientID);
+ } else {
+ System.out
+ .println(ipAddress
+ + " Cannot check if user is working.");
+ this.errors
+ .put(clientID,
+ "The check if a user is working has been failed.");
+ /*
+ * cannot check if user is working, go in
+ * errorState
+ */
+ status.put(clientID, 29);
+ psJobs.remove(clientID);
}
} else {
System.out.println(ipAddress
diff --git a/gearman/controllerWorker/ControllerWorker/Shutdown.java b/gearman/controllerWorker/ControllerWorker/Shutdown.java
index 77975c3..78ee0c0 100644
--- a/gearman/controllerWorker/ControllerWorker/Shutdown.java
+++ b/gearman/controllerWorker/ControllerWorker/Shutdown.java
@@ -410,6 +410,19 @@ public class Shutdown extends Thread {
+ " is not working");
status.put(clientID, 4); // is not working
psJobs.remove(clientID);
+ } else {
+ System.out
+ .println(ipAddress
+ + " Cannot check if user is working.");
+ this.errors
+ .put(clientID,
+ "The check if a user is working has been failed.");
+ /*
+ * cannot check if user is working, go in
+ * errorState
+ */
+ status.put(clientID, 12);
+ psJobs.remove(clientID);
}
} else {
System.out.println(ipAddress