summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-16 16:27:11 +0200
committerBjörn Geiger2011-08-16 16:27:11 +0200
commit97cad9e018cad7eb242cf849178b160f7badc838 (patch)
treef1bbebf6849eda2d7e955d110a9bf127325fcdc8 /gearman
parentminor (diff)
downloadpoolctrl-97cad9e018cad7eb242cf849178b160f7badc838.tar.gz
poolctrl-97cad9e018cad7eb242cf849178b160f7badc838.tar.xz
poolctrl-97cad9e018cad7eb242cf849178b160f7badc838.zip
minor
Diffstat (limited to 'gearman')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java14
1 files changed, 7 insertions, 7 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 6e6ab50..f004366 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -439,18 +439,18 @@ public class Boot extends Thread {
if (!resultObj.containsKey("err")) {
String ps = resultObj.get("ps").toString();
System.out.println(ps);
- if (ps.equals("is working")) {
+ boolean isWorking = true;
+ if (isWorking) {
System.out.println(ipAddress
+ " is working");
status.put(clientID, 18); // is working
psJobs.remove(clientID);
} else {
- /*
- * System.out.println(ipAddress +
- * " is not working"); status.put(clientID,
- * 13); // is not working
- * psJobs.remove(clientID);
- */
+ System.out.println(ipAddress
+ + " is not working");
+ status.put(clientID, 13); // is not working
+ psJobs.remove(clientID);
+
}
} else {
System.out.println(ipAddress