summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/Shutdown.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/Shutdown.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Shutdown.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Shutdown.java b/gearman/controllerWorker/ControllerWorker/Shutdown.java
index c981a61..ca474ac 100644
--- a/gearman/controllerWorker/ControllerWorker/Shutdown.java
+++ b/gearman/controllerWorker/ControllerWorker/Shutdown.java
@@ -28,6 +28,7 @@ public class Shutdown extends Thread {
private Boolean error;
private final int updateRate;
private final long updatePeriod;
+ private String bootOS;
private HashMap<Integer, GearmanJob> pingJobs;
private HashMap<Integer, GearmanJob> whoJobs;
@@ -44,7 +45,7 @@ public class Shutdown extends Thread {
private GearmanClient gearmanClient;
public Shutdown(String serverAddress, int port,
- Vector<HashMap<String, String>> clients, int updateRate) {
+ Vector<HashMap<String, String>> clients, int updateRate, String bootOS) {
this.pingJobs = new HashMap<Integer, GearmanJob>();
this.whoJobs = new HashMap<Integer, GearmanJob>();
this.shutdownJobs = new HashMap<Integer, GearmanJob>();
@@ -64,6 +65,7 @@ public class Shutdown extends Thread {
}
this.finished = false;
this.error = false;
+ this.bootOS = bootOS;
}
public void run() {
@@ -139,7 +141,7 @@ public class Shutdown extends Thread {
break;
case 2:
- woh(client);
+ who(client);
break;
@@ -235,7 +237,7 @@ public class Shutdown extends Thread {
System.out.println("ping " + ipAddress);
}
- private void woh(HashMap<String, String> client) {
+ private void who(HashMap<String, String> client) {
String ipAddress = client.get("ip");
int clientID = Integer.parseInt(client.get("id"));