summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-16 13:55:37 +0200
committerBjörn Geiger2011-08-16 13:55:37 +0200
commitd66fe3ef1e03210a4a76e2cc2a90a5d28191a615 (patch)
treec56d26d710a23b783a8a9e5e3b376889ca3d9efb /gearman
parentweiteren Fehler korrigiert (diff)
downloadpoolctrl-d66fe3ef1e03210a4a76e2cc2a90a5d28191a615.tar.gz
poolctrl-d66fe3ef1e03210a4a76e2cc2a90a5d28191a615.tar.xz
poolctrl-d66fe3ef1e03210a4a76e2cc2a90a5d28191a615.zip
weiterer Fehelr
Diffstat (limited to 'gearman')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java2
-rw-r--r--gearman/controllerWorker/ControllerWorker/Shutdown.java2
2 files changed, 2 insertions, 2 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 212ec54..f009432 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -73,7 +73,7 @@ public class Boot extends Thread {
this.gearmanClient = new GearmanClientImpl();
gearmanClient.addJobServer(this.gearmanConnection);
this.clients = clients;
- this.waitTime = waitTime;
+ this.waitTime = waitTime * 1000;
for (HashMap<String, String> client : clients) {
int clientID = Integer.parseInt(client.get("id"));
status.put(clientID, 0); // no work
diff --git a/gearman/controllerWorker/ControllerWorker/Shutdown.java b/gearman/controllerWorker/ControllerWorker/Shutdown.java
index 7cc22f6..b7e43cd 100644
--- a/gearman/controllerWorker/ControllerWorker/Shutdown.java
+++ b/gearman/controllerWorker/ControllerWorker/Shutdown.java
@@ -62,7 +62,7 @@ public class Shutdown extends Thread {
serverAddress, port);
this.gearmanClient = new GearmanClientImpl();
gearmanClient.addJobServer(this.gearmanConnection);
- this.waitTime = waitTime;
+ this.waitTime = waitTime * 1000;
this.clients = clients;
for (HashMap<String, String> client : clients) {
int clientID = Integer.parseInt(client.get("id"));