summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/Boot.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-07-27 12:48:18 +0200
committerBjörn Geiger2011-07-27 12:48:18 +0200
commit4382161dd60a4a2c4c7a8d887b199d9a256fd32c (patch)
treef7203ba35986688252ecfb9d3e5cc0914c556113 /gearman/controllerWorker/ControllerWorker/Boot.java
parentminor (diff)
downloadpoolctrl-4382161dd60a4a2c4c7a8d887b199d9a256fd32c.tar.gz
poolctrl-4382161dd60a4a2c4c7a8d887b199d9a256fd32c.tar.xz
poolctrl-4382161dd60a4a2c4c7a8d887b199d9a256fd32c.zip
kleinen fehler korrigiert
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/Boot.java')
-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 74aa828..1d79366 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -41,6 +41,13 @@ public class Boot extends Thread {
public Boot(String serverAddress, int port,
Vector<HashMap<String, String>> clients, int updateRate) {
+ this.pingJobs = new HashMap<Integer, GearmanJob>();
+ this.wolJobs = new HashMap<Integer, GearmanJob>();
+ this.sshJobs = new HashMap<Integer, GearmanJob>();
+ this.status = new HashMap<Integer, Integer>();
+ this.errors = new HashMap<Integer, Integer>();
+ this.updateRate = updateRate; // updates per second
+ this.updatePeriod = 1000000000L / this.updateRate; // nanoseconds
this.gearmanConnection = new GearmanNIOJobServerConnection(
serverAddress, port);
this.gearmanClient = new GearmanClientImpl();
@@ -52,13 +59,6 @@ public class Boot extends Thread {
}
this.finished = false;
this.error = false;
- this.pingJobs = new HashMap<Integer, GearmanJob>();
- this.wolJobs = new HashMap<Integer, GearmanJob>();
- this.sshJobs = new HashMap<Integer, GearmanJob>();
- this.status = new HashMap<Integer, Integer>();
- this.errors = new HashMap<Integer, Integer>();
- this.updateRate = updateRate; // updates per second
- this.updatePeriod = 1000000000L / this.updateRate; // nanoseconds
}
public void run() {