summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/Boot.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/Boot.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java268
1 files changed, 126 insertions, 142 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 23f3f39..7857e9b 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -23,7 +23,7 @@ import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
public class Boot extends Thread {
- private static final int INITIAL_STATE = 0;
+ private static final int CLIENT_INITIALIZED = 0;
private static final int PING_INITIALIZED = 1;
private static final int CLIENT_ALIVE = 2;
private static final int CLIENT_NOT_ALIVE = 3;
@@ -141,20 +141,15 @@ public class Boot extends Thread {
long timestamp;
for (Client client : clients) {
- String ipAddress = client.getIp();
- String macAddress = client.getMac();
- int clientID = client.getId();
- int clientState = client.getState();
+ switch (client.getState()) {
- switch (clientState) {
-
- case INITIAL_STATE:
+ case CLIENT_INITIALIZED:
ping(client);
break;
case PING_INITIALIZED:
- GearmanJob pingJob = pingJobs.get(clientID);
+ GearmanJob pingJob = pingJobs.get(client.getId());
if (pingJob != null) {
GearmanJobStatus jobStatus = gearmanClient
.getJobStatus(pingJob);
@@ -169,21 +164,22 @@ public class Boot extends Thread {
String alive = resultObj.get("alive")
.toString();
if (alive.equals("true")) {
- System.out.println(ipAddress + " alive");
+ System.out.println(client.getIp()
+ + " alive");
client.changeState(CLIENT_ALIVE,
"CLIENT_ALIVE",
"The client is alive.");
- pingJobs.remove(clientID);
+ pingJobs.remove(client.getId());
} else if (alive.equals("false")) {
- System.out
- .println(ipAddress + " not alive");
+ System.out.println(client.getIp()
+ + " not alive");
client.changeState(CLIENT_NOT_ALIVE,
"CLIENT_NOT_ALIVE",
"The client is not alive.");
- pingJobs.remove(clientID);
+ pingJobs.remove(client.getId());
}
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Cannot send the ping message.");
client
.setError("Sending the ping message has been failed.");
@@ -192,7 +188,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingJobs.remove(clientID);
+ pingJobs.remove(client.getId());
}
}
}
@@ -211,7 +207,7 @@ public class Boot extends Thread {
break;
case WAKE_ON_LAN_INITIALIZED:
- GearmanJob wolJob = wolJobs.get(clientID);
+ GearmanJob wolJob = wolJobs.get(client.getId());
if (wolJob != null) {
GearmanJobStatus jobStatus = gearmanClient
.getJobStatus(wolJob);
@@ -221,14 +217,14 @@ public class Boot extends Thread {
String result = ByteUtils.fromUTF8Bytes(wolJobRes
.getResults());
if (result.equals("Magic packet send.")) {
- System.out.println(macAddress
+ System.out.println(client.getMac()
+ " Magic packet sent.");
client.changeState(MAGIC_PACKET_SENT,
"MAGIC_PACKET_SENT",
"The Magic packet has been sent.");
- wolJobs.remove(clientID);
+ wolJobs.remove(client.getId());
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Cannot send magic packet.");
client
.setError("Sending the magic packet has been failed.");
@@ -236,7 +232,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- wolJobs.remove(clientID);
+ wolJobs.remove(client.getId());
}
}
}
@@ -246,7 +242,7 @@ public class Boot extends Thread {
case MAGIC_PACKET_SENT:
date = new Date();
timestamp = date.getTime();
- pingWolTime.put(clientID, timestamp);
+ pingWolTime.put(client.getId(), timestamp);
pingWakeOnLan(client);
break;
@@ -257,12 +253,12 @@ public class Boot extends Thread {
break;
case PING_WOL_INITIALIZED:
- GearmanJob pingJobWoL = pingWoLJobs.get(clientID);
+ GearmanJob pingJobWoL = pingWoLJobs.get(client.getId());
if (pingJobWoL != null) {
Date currentDate = new Date();
Long currentTimestamp = currentDate.getTime();
// wait 2 min until WoL - Failed
- Long expectedTimestamp = pingWolTime.get(clientID)
+ Long expectedTimestamp = pingWolTime.get(client.getId())
+ waitTime;
if (expectedTimestamp >= currentTimestamp) {
GearmanJobStatus jobStatus = gearmanClient
@@ -278,17 +274,17 @@ public class Boot extends Thread {
String alive = resultObj.get("alive")
.toString();
if (alive.equals("true")) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is alive after WoL");
// alive, go in successState
client
.changeState(SUCCESS,
"SUCCESS",
"Booting of the client has been finished.");
- pingWoLJobs.remove(clientID);
+ pingWoLJobs.remove(client.getId());
} else if (alive.equals("false")) {
System.out.println("ping again "
- + ipAddress);
+ + client.getIp());
client
.changeState(
PING_WOL_AGAIN,
@@ -297,11 +293,11 @@ public class Boot extends Thread {
+ waitTime
/ 60
+ " minutes has been elapsed");
- pingWoLJobs.remove(clientID);
+ pingWoLJobs.remove(client.getId());
}
} else {
System.out
- .println(ipAddress
+ .println(client.getIp()
+ " Cannot send the ping after wake on LAN message.");
client
.setError("Sending the ping after wake on LAN message has been failed.");
@@ -312,26 +308,26 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingWoLJobs.remove(clientID);
+ pingWoLJobs.remove(client.getId());
}
}
}
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is not alive after WoL");
client.setError("The wake on LAN has been failed.");
// not alive, go in errorState
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingWoLJobs.remove(clientID);
+ pingWoLJobs.remove(client.getId());
}
}
break;
case CHECKOS_INITIALIZED:
- GearmanJob osJob = osJobs.get(clientID);
+ GearmanJob osJob = osJobs.get(client.getId());
if (osJob != null) {
GearmanJobStatus jobStatus = gearmanClient
@@ -356,21 +352,23 @@ public class Boot extends Thread {
"Description").toString();
if (description.equals(bootOS)) {
- System.out.println(ipAddress + " right OS");
+ System.out.println(client.getIp()
+ + " right OS");
// right os, go to successState
client
.changeState(SUCCESS, "SUCCESS",
"Booting of the client has been finished.");
- osJobs.remove(clientID);
+ osJobs.remove(client.getId());
} else {
- System.out.println(ipAddress + " wrong OS");
+ System.out.println(client.getIp()
+ + " wrong OS");
client
.changeState(WRONG_OS, "WRONG_OS",
"The wrong operating system is running.");
- osJobs.remove(clientID);
+ osJobs.remove(client.getId());
}
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Cannot check os");
client
.setError("The check for correct operating system has been failed.");
@@ -378,7 +376,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- osJobs.remove(clientID);
+ osJobs.remove(client.getId());
}
}
}
@@ -392,7 +390,7 @@ public class Boot extends Thread {
break;
case WHO_INITIALIZED:
- GearmanJob whoJob = whoJobs.get(clientID);
+ GearmanJob whoJob = whoJobs.get(client.getId());
if (whoJob != null) {
GearmanJobStatus jobStatus = gearmanClient
@@ -417,24 +415,24 @@ public class Boot extends Thread {
}
if (user.isEmpty()) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " no user is logged in");
// no user is logged in, doing restart
client.changeState(RESTART_CLIENT,
"RESTART_CLIENT",
"No user is logged in.");
- whoJobs.remove(clientID);
+ whoJobs.remove(client.getId());
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " a user is logged in");
client.changeState(A_USER_IS_LOGGED_IN,
"A_USER_IS_LOGGED_IN",
"A user is logged in.");
- whoJobs.remove(clientID);
+ whoJobs.remove(client.getId());
}
} else {
System.out
- .println(ipAddress
+ .println(client.getIp()
+ " Cannot check if a user is logged in.");
client
.setError("The check if a user is logged in has been failed.");
@@ -445,7 +443,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- whoJobs.remove(clientID);
+ whoJobs.remove(client.getId());
}
}
}
@@ -459,7 +457,7 @@ public class Boot extends Thread {
break;
case PS_INITIALIZED:
- GearmanJob psJob = psJobs.get(clientID);
+ GearmanJob psJob = psJobs.get(client.getId());
if (psJob != null) {
GearmanJobStatus jobStatus = gearmanClient
@@ -493,27 +491,27 @@ public class Boot extends Thread {
if (blacklistFound) {
/*
* if (whitelistFound) {
- * System.out.println(ipAddress +
+ * System.out.println(client.getIp() +
* " is not working"); // is not working
- * status.put(clientID, 13);
- * psJobs.remove(clientID); } else {
+ * status.put(client.getId(), 13);
+ * psJobs.remove(client.getId()); } else {
*/
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is working");
client.changeState(USER_IS_WORKING,
"USER_IS_WORKING",
"The user is working.");
- psJobs.remove(clientID);
+ psJobs.remove(client.getId());
// }
} else {
// user is not working, doing restart
client.changeState(RESTART_CLIENT,
"RESTART_CLIENT",
"The user is'nt working.");
- psJobs.remove(clientID);
+ psJobs.remove(client.getId());
}
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Cannot check if user is working.");
client
.setError("The check if a user is working has been failed.");
@@ -524,7 +522,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- psJobs.remove(clientID);
+ psJobs.remove(client.getId());
}
}
}
@@ -538,7 +536,7 @@ public class Boot extends Thread {
break;
case RESTART_INITIALIZED:
- GearmanJob restartJob = restartJobs.get(clientID);
+ GearmanJob restartJob = restartJobs.get(client.getId());
if (restartJob != null) {
GearmanJobStatus jobStatus = gearmanClient
.getJobStatus(restartJob);
@@ -551,14 +549,14 @@ public class Boot extends Thread {
JSONObject resultObj = (JSONObject) JSONValue
.parse(result);
if (!resultObj.containsKey("err")) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Restart command sent");
client.changeState(RESTART_COMMAND_SENT,
"RESTART_COMMAND_SENT",
"The restart command has been sent.");
- restartJobs.remove(clientID);
+ restartJobs.remove(client.getId());
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " Cannot send restart command");
client
.setError("Sending the restart command has been failed.");
@@ -566,7 +564,7 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- restartJobs.remove(clientID);
+ restartJobs.remove(client.getId());
}
}
}
@@ -577,7 +575,7 @@ public class Boot extends Thread {
case RESTART_COMMAND_SENT:
date = new Date();
timestamp = date.getTime();
- pingRestartShutdownTime.put(clientID, timestamp);
+ pingRestartShutdownTime.put(client.getId(), timestamp);
pingRestartShutdown(client);
break;
@@ -589,13 +587,13 @@ public class Boot extends Thread {
case PING_RESTART_SHUTDOWN_INITIALIZED:
GearmanJob pingJobRestartShutdown = pingRestartShutdownJobs
- .get(clientID);
+ .get(client.getId());
if (pingJobRestartShutdown != null) {
Date currentDate = new Date();
Long currentTimestamp = currentDate.getTime();
// wait 2 min until Restart - Failed
- Long expectedTimestamp = pingRestartShutdownTime
- .get(clientID)
+ Long expectedTimestamp = pingRestartShutdownTime.get(client
+ .getId())
+ waitTime;
if (expectedTimestamp >= currentTimestamp) {
GearmanJobStatus jobStatus = gearmanClient
@@ -614,7 +612,7 @@ public class Boot extends Thread {
String alive = resultObj.get("alive")
.toString();
if (alive.equals("true")) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is still alive");
// still alive, ping again
client
@@ -625,22 +623,22 @@ public class Boot extends Thread {
+ waitTime
/ 60
+ " minutes has been elapsed");
- pingRestartShutdownJobs
- .remove(clientID);
+ pingRestartShutdownJobs.remove(client
+ .getId());
} else if (alive.equals("false")) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is down");
// not alive, ping again
client
.changeState(CLIENT_IS_DOWN,
"CLIENT_IS_DOWN",
"The client has been shutted down.");
- pingRestartShutdownJobs
- .remove(clientID);
+ pingRestartShutdownJobs.remove(client
+ .getId());
}
} else {
System.out
- .println(ipAddress
+ .println(client.getIp()
+ " Cannot send the ping after restart message.");
client
.setError("Sending the ping after restart message has been failed.");
@@ -651,25 +649,26 @@ public class Boot extends Thread {
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingRestartShutdownJobs.remove(clientID);
+ pingRestartShutdownJobs.remove(client
+ .getId());
}
}
}
} else {
- System.out.println(ipAddress + " shutdown failed");
+ System.out.println(client.getIp() + " shutdown failed");
client.setError("The shutdown has been failed.");
// still alive, go in errorState
client
.changeState(ERROR, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingRestartShutdownJobs.remove(clientID);
+ pingRestartShutdownJobs.remove(client.getId());
}
}
break;
case USER_IS_WORKING:
- System.out.println(ipAddress + " User has been working");
+ System.out.println(client.getIp() + " User has been working");
client.setError("The user has been working.");
// user has been working, go in errorState
client
@@ -681,7 +680,7 @@ public class Boot extends Thread {
case CLIENT_IS_DOWN:
date = new Date();
timestamp = date.getTime();
- pingRestartBootTime.put(clientID, timestamp);
+ pingRestartBootTime.put(client.getId(), timestamp);
pingRestartBoot(client);
break;
@@ -692,13 +691,14 @@ public class Boot extends Thread {
break;
case PING_RESTART_BOOT_INITIALIZED:
- GearmanJob pingJobRestartBoot = pingRestartBootJobs
- .get(clientID);
+ GearmanJob pingJobRestartBoot = pingRestartBootJobs.get(client
+ .getId());
if (pingJobRestartBoot != null) {
Date currentDate = new Date();
Long currentTimestamp = currentDate.getTime();
// wait 2 min until Restart - Failed
- Long expectedTimestamp = pingRestartBootTime.get(clientID)
+ Long expectedTimestamp = pingRestartBootTime.get(client
+ .getId())
+ waitTime;
if (expectedTimestamp >= currentTimestamp) {
GearmanJobStatus jobStatus = gearmanClient
@@ -716,17 +716,18 @@ public class Boot extends Thread {
String alive = resultObj.get("alive")
.toString();
if (alive.equals("true")) {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is alive after restart");
// alive, go to success state
client
.changeState(SUCCESS,
"SUCCESS",
"Booting of the client has been finished.");
- pingRestartBootJobs.remove(clientID);
+ pingRestartBootJobs.remove(client
+ .getId());
} else if (alive.equals("false")) {
System.out.println("ping again "
- + ipAddress);
+ + client.getIp());
// not alive, ping again
client
.changeState(
@@ -736,11 +737,12 @@ public class Boot extends Thread {
+ waitTime
/ 60
+ " minutes has been elapsed");
- pingRestartBootJobs.remove(clientID);
+ pingRestartBootJobs.remove(client
+ .getId());
}
} else {
System.out
- .println(ipAddress
+ .println(client.getIp()
+ " Cannot send the ping after shutdown message.");
client
.setError("Sending the ping after shutdown message has been failed.");
@@ -755,14 +757,14 @@ public class Boot extends Thread {
}
}
} else {
- System.out.println(ipAddress
+ System.out.println(client.getIp()
+ " is not alive after reboot");
client.setError("The reboot has been failed.");
// not alive, go in errorState
client
.changeState(0, "ERROR",
"Booting of the client has not been finished, due to an error.");
- pingRestartBootJobs.remove(clientID);
+ pingRestartBootJobs.remove(client.getId());
}
}
@@ -770,7 +772,7 @@ public class Boot extends Thread {
case ERROR:
if (!client.isFinished()) {
- System.out.println(ipAddress + " Booting failed"); // errorState
+ System.out.println(client.getIp() + " Booting failed"); // errorState
client.finish();
error = true;
}
@@ -779,7 +781,7 @@ public class Boot extends Thread {
case SUCCESS:
if (!client.isFinished()) {
- System.out.println(ipAddress + " Booting finished"); // successState
+ System.out.println(client.getIp() + " Booting finished"); // successState
client.finish();
}
@@ -805,114 +807,96 @@ public class Boot extends Thread {
}
private void ping(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("ping", ipAddress.getBytes(),
- "ping" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
+ .getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
client.changeState(PING_INITIALIZED, "PING_INITIALIZED",
"The ping has been initialized.");
- pingJobs.put(clientID, job);
- System.out.println("ping " + ipAddress);
+ pingJobs.put(client.getId(), job);
+ System.out.println("ping " + client.getIp());
}
private void pingWakeOnLan(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("ping", ipAddress.getBytes(),
- "ping" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
+ .getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
client.changeState(PING_WOL_INITIALIZED, "PING_WOL_INITIALIZED",
"The ping after wake on LAN has been initialized.");
- pingWoLJobs.put(clientID, job);
- System.out.println("ping " + ipAddress);
+ pingWoLJobs.put(client.getId(), job);
+ System.out.println("ping " + client.getIp());
}
private void pingRestartShutdown(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("ping", ipAddress.getBytes(),
- "ping" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
+ .getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
client.changeState(PING_RESTART_SHUTDOWN_INITIALIZED,
"PING_RESTART_SHUTDOWN_INITIALIZED",
"The ping after shutdown has been initialized.");
- pingRestartShutdownJobs.put(clientID, job);
- System.out.println("ping " + ipAddress);
+ pingRestartShutdownJobs.put(client.getId(), job);
+ System.out.println("ping " + client.getIp());
}
private void pingRestartBoot(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("ping", ipAddress.getBytes(),
- "ping" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
+ .getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
client.changeState(PING_RESTART_BOOT_INITIALIZED,
"PING_RESTART_BOOT_INITIALIZED",
"The ping after reboot has been initialized.");
- pingRestartBootJobs.put(clientID, job);
- System.out.println("ping " + ipAddress);
+ pingRestartBootJobs.put(client.getId(), job);
+ System.out.println("ping " + client.getIp());
}
private void wakeOnLan(Client client) {
- String macAddress = client.getMac();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("wol", macAddress.getBytes(),
- "wol" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("wol", client.getMac()
+ .getBytes(), "wol" + client.getId());
gearmanClient.submit(job);
client.changeState(WAKE_ON_LAN_INITIALIZED, "WAKE_ON_LAN_INITIALIZED",
"The wake on LAN has been initialized.");
- wolJobs.put(clientID, job);
- System.out.println("wake on lan");
+ wolJobs.put(client.getId(), job);
+ System.out.println("wake on lan" + client.getMac());
}
private void checkOS(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("os", ipAddress.getBytes(),
- "os" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("os", client.getIp()
+ .getBytes(), "os" + client.getId());
gearmanClient.submit(job);
client
.changeState(CHECKOS_INITIALIZED, "CHECKOS_INITIALIZED",
"The check for the correct operating system has been initialized.");
- osJobs.put(clientID, job);
- System.out.println("check OS " + ipAddress);
+ osJobs.put(client.getId(), job);
+ System.out.println("check OS " + client.getIp());
}
private void who(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("who", ipAddress.getBytes(),
- "who" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("who", client.getIp()
+ .getBytes(), "who" + client.getId());
gearmanClient.submit(job);
client.changeState(WHO_INITIALIZED, "WHO_INITIALIZED",
"The check if a user is logged in has been initialized.");
- whoJobs.put(clientID, job);
- System.out.println("who " + ipAddress);
+ whoJobs.put(client.getId(), job);
+ System.out.println("who " + client.getIp());
}
private void ps(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("ps", ipAddress.getBytes(),
- "ps" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("ps", client.getIp()
+ .getBytes(), "ps" + client.getId());
gearmanClient.submit(job);
client.changeState(PS_INITIALIZED, "PS_INITIALIZED",
"The check if the user is working has been initialized.");
- psJobs.put(clientID, job);
- System.out.println("ps " + ipAddress);
+ psJobs.put(client.getId(), job);
+ System.out.println("ps " + client.getIp());
}
private void restart(Client client) {
- String ipAddress = client.getIp();
- int clientID = client.getId();
- GearmanJob job = GearmanJobImpl.createJob("restart", ipAddress
- .getBytes(), "restart" + clientID);
+ GearmanJob job = GearmanJobImpl.createJob("restart", client.getIp()
+ .getBytes(), "restart" + client.getId());
gearmanClient.submit(job);
client.changeState(RESTART_INITIALIZED, "RESTART_INITIALIZED",
"A restart of the client has been initialized.");
- restartJobs.put(clientID, job);
- System.out.println("restart " + ipAddress);
+ restartJobs.put(client.getId(), job);
+ System.out.println("restart " + client.getIp());
}
public Boolean isFinished() {