summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
diff options
context:
space:
mode:
authorSebastian Wagner2011-10-18 13:40:44 +0200
committerSebastian Wagner2011-10-18 13:40:44 +0200
commit14eb5b03ded56db1cd5016c5e58bbb4772c99131 (patch)
tree9f827353838fa3c913b192cd762e5e0ed366a84b /gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
parentbugfix (diff)
downloadpoolctrl-14eb5b03ded56db1cd5016c5e58bbb4772c99131.tar.gz
poolctrl-14eb5b03ded56db1cd5016c5e58bbb4772c99131.tar.xz
poolctrl-14eb5b03ded56db1cd5016c5e58bbb4772c99131.zip
some changes
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/ShutdownWorker.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index 631e8b7..65ad5b9 100755
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -49,6 +49,8 @@ public class ShutdownWorker extends AbstractGearmanFunction {
.getApplication_ini().getString("gearman.server.port"));
long waitTime = Long.parseLong(ControllerWorkerMain
.getApplication_ini().getString("gearman.worker.waitTime"));
+ long scsavTime = Integer.parseInt(ControllerWorkerMain
+ .getApplication_ini().getString("gearman.worker.scsavTime"));
int updateRate = Integer.parseInt(ControllerWorkerMain
.getApplication_ini().getString("gearman.worker.updateRate"));
String blacklist = ControllerWorkerMain.getApplication_ini().getString(
@@ -68,7 +70,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
psBlacklist.add(blackEntry);
}
- Shutdown shutdown = new Shutdown(event, clients, updateRate, waitTime,
+ Shutdown shutdown = new Shutdown(event, clients, updateRate, waitTime, scsavTime,
psWhitelist, psBlacklist, gearmanServerHost, gearmanServerPort);
GearmanJobServerConnection gearmanConnection = new GearmanNIOJobServerConnection(
gearmanServerHost, gearmanServerPort);