summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-10 14:45:45 +0200
committerBjörn Geiger2011-08-10 14:45:45 +0200
commit3196b2e3132fb93cf33d2d8c740f785db015bca5 (patch)
tree728694f603fefcd4ec86b6a01e58602a8f3dfb62 /gearman/controllerWorker
parentminor (diff)
downloadpoolctrl-3196b2e3132fb93cf33d2d8c740f785db015bca5.tar.gz
poolctrl-3196b2e3132fb93cf33d2d8c740f785db015bca5.tar.xz
poolctrl-3196b2e3132fb93cf33d2d8c740f785db015bca5.zip
minor
Diffstat (limited to 'gearman/controllerWorker')
-rw-r--r--gearman/controllerWorker/ControllerWorker/StatusWorker.java16
1 files changed, 8 insertions, 8 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/StatusWorker.java b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
index 490114e..575a3cc 100644
--- a/gearman/controllerWorker/ControllerWorker/StatusWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
@@ -49,9 +49,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not been finished, due to errors!");
LinkedHashMap<String, String> clientErrors = new LinkedHashMap<String, String>();
for (HashMap<String, String> client : clients) {
- String ipAddress = client.get("ip");
+ String clientID = client.get("id");
String errorText = boot.getError(client);
- clientErrors.put(ipAddress, errorText);
+ clientErrors.put(clientID, errorText);
}
content.put("errors", clientErrors);
res.put(event, content);
@@ -61,9 +61,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not yet been finished!");
LinkedHashMap<String, String> clientStatus = new LinkedHashMap<String, String>();
for (HashMap<String, String> client : clients) {
- String ipAddress = client.get("ip");
+ String clientID = client.get("id");
String statusText = boot.getStatusText(client);
- clientStatus.put(ipAddress, statusText);
+ clientStatus.put(clientID, statusText);
}
content.put("status", clientStatus);
res.put(event, content);
@@ -91,9 +91,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not been finished, due to errors!");
LinkedHashMap<String, String> clientErrors = new LinkedHashMap<String, String>();
for (HashMap<String, String> client : clients) {
- String ipAddress = client.get("ip");
+ String clientID = client.get("id");
String errorText = shutdown.getError(client);
- clientErrors.put(ipAddress, errorText);
+ clientErrors.put(clientID, errorText);
}
content.put("errors", clientErrors);
res.put(event, content);
@@ -103,9 +103,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not yet been finished!");
LinkedHashMap<String, String> clientStatus = new LinkedHashMap<String, String>();
for (HashMap<String, String> client : clients) {
- String ipAddress = client.get("ip");
+ String clientID = client.get("id");
String statusText = shutdown.getStatusText(client);
- clientStatus.put(ipAddress, statusText);
+ clientStatus.put(clientID, statusText);
}
content.put("status", clientStatus);
res.put(event, content);