summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-16 17:39:13 +0200
committerBjörn Geiger2011-08-16 17:39:13 +0200
commit22edc20871f494d5c2946d3ed7099313d5ae63c2 (patch)
treef4e13b94a58f2eec6cad9a344ce45db7349db543 /gearman
parentverschiedenes (diff)
downloadpoolctrl-22edc20871f494d5c2946d3ed7099313d5ae63c2.tar.gz
poolctrl-22edc20871f494d5c2946d3ed7099313d5ae63c2.tar.xz
poolctrl-22edc20871f494d5c2946d3ed7099313d5ae63c2.zip
minor
Diffstat (limited to 'gearman')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java13
-rw-r--r--gearman/controllerWorker/ControllerWorker/Shutdown.java22
2 files changed, 22 insertions, 13 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 7181cbf..dbd8de9 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -465,8 +465,10 @@ public class Boot extends Thread {
this.errors
.put(clientID,
"The check if a user is working has been failed.");
- // cannot check if user is working, go in
- // errorState
+ /*
+ * cannot check if user is working, go in
+ * errorState
+ */
status.put(clientID, 29);
psJobs.remove(clientID);
}
@@ -506,8 +508,7 @@ public class Boot extends Thread {
this.errors
.put(clientID,
"Sending the restart command has been failed.");
- // cannot send restart command, go in
- // errorState
+ // cannot send restart command, go in errorState
status.put(clientID, 29);
restartJobs.remove(clientID);
}
@@ -591,8 +592,8 @@ public class Boot extends Thread {
System.out.println(ipAddress + " shutdown failed");
this.errors.put(clientID,
"The shutdown has been failed.");
- status.put(clientID, 29); // still alive, go in
- // errorState
+ // still alive, go in errorState
+ status.put(clientID, 29);
pingRestartShutdownJobs.remove(clientID);
}
}
diff --git a/gearman/controllerWorker/ControllerWorker/Shutdown.java b/gearman/controllerWorker/ControllerWorker/Shutdown.java
index a7ea746..352c4ab 100644
--- a/gearman/controllerWorker/ControllerWorker/Shutdown.java
+++ b/gearman/controllerWorker/ControllerWorker/Shutdown.java
@@ -254,8 +254,10 @@ public class Shutdown extends Thread {
this.errors
.put(clientID,
"Sending the shutdown command has been failed.");
- // cannot send shutdown command, go in
- // errorState
+ /*
+ * cannot send shutdown command, go in /
+ * errorState
+ */
status.put(clientID, 12);
doShutdownJobs.remove(clientID);
}
@@ -321,8 +323,10 @@ public class Shutdown extends Thread {
this.errors
.put(clientID,
"Sending the ping after shutdown message has been failed.");
- // sending the ping after shutdown message
- // has been failed
+ /*
+ * sending the ping after shutdown message
+ * has been failed
+ */
status.put(clientID, 12);
pingJobs.remove(clientID);
}
@@ -382,8 +386,10 @@ public class Shutdown extends Thread {
this.errors
.put(clientID,
"The check if a user is working has been failed.");
- // cannot check if user is working, go in
- // errorState
+ /*
+ * cannot check if user is working, go in
+ * errorState
+ */
status.put(clientID, 12);
psJobs.remove(clientID);
}
@@ -394,7 +400,9 @@ public class Shutdown extends Thread {
break;
case 11:
- System.out.println("User is working Logik");
+ this.errors.put(clientID, "The user is working.");
+ // user is working, go in errorState
+ status.put(clientID, 12);
break;