summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/BootWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/BootWorker.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/BootWorker.java21
1 files changed, 12 insertions, 9 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index 8d3e612..a95f3a5 100755
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.java
@@ -48,10 +48,12 @@ public class BootWorker extends AbstractGearmanFunction {
.getString("gearman.server.host");
int gearmanServerPort = Integer.parseInt(ControllerWorkerMain
.getApplication_ini().getString("gearman.server.port"));
- long waitTime = Long.parseLong(ControllerWorkerMain
- .getApplication_ini().getString("gearman.worker.waitTime"));
- int updateRate = Integer.parseInt(ControllerWorkerMain
- .getApplication_ini().getString("gearman.worker.updateRate"));
+ 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(
"gearman.worker.ps.blacklist");
StringTokenizer blacklistTokenizer = new StringTokenizer(blacklist, ",");
@@ -70,7 +72,8 @@ public class BootWorker extends AbstractGearmanFunction {
}
Boot boot = new Boot(event, clients, eventOS, updateRate, waitTime,
- psWhitelist, psBlacklist, gearmanServerHost, gearmanServerPort);
+ scsavTime, psWhitelist, psBlacklist, gearmanServerHost,
+ gearmanServerPort);
GearmanJobServerConnection gearmanConnection = new GearmanNIOJobServerConnection(
gearmanServerHost, gearmanServerPort);
GearmanClient gearmanClient = new GearmanClientImpl();
@@ -81,8 +84,8 @@ public class BootWorker extends AbstractGearmanFunction {
jsonData.put("eventOS", eventOS);
jsonData.put("clients", jsonClients);
String dataString = JSONValue.toJSONString(jsonData);
- GearmanJob job = GearmanJobImpl.createJob("status", dataString
- .getBytes(), "status" + event);
+ GearmanJob job = GearmanJobImpl.createJob("status", dataString.getBytes(),
+ "status" + event);
gearmanClient.submit(job);
boot.start();
logger.info("Booting of " + event + " started");
@@ -92,8 +95,8 @@ public class BootWorker extends AbstractGearmanFunction {
byte[] exceptions = new byte[0];
int numerator = 0;
int denominator = 0;
- GearmanJobResult gjr = new GearmanJobResultImpl(this.jobHandle, true,
- res.getBytes(), warnings, exceptions, numerator, denominator);
+ GearmanJobResult gjr = new GearmanJobResultImpl(this.jobHandle, true, res
+ .getBytes(), warnings, exceptions, numerator, denominator);
return gjr;
}
} \ No newline at end of file