summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/Boot.java
diff options
context:
space:
mode:
authorSebastian Wagner2011-09-05 15:24:17 +0200
committerSebastian Wagner2011-09-05 15:24:17 +0200
commitc050c638d0c8475241ceccf33ee22df1f01181be (patch)
treebfc4364c08382cc85af18854885da1dc2b7c4635 /gearman/controllerWorker/ControllerWorker/Boot.java
parenteventResize- and eventDrop Function added (diff)
downloadpoolctrl-c050c638d0c8475241ceccf33ee22df1f01181be.tar.gz
poolctrl-c050c638d0c8475241ceccf33ee22df1f01181be.tar.xz
poolctrl-c050c638d0c8475241ceccf33ee22df1f01181be.zip
rename eventStates
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/Boot.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/Boot.java38
1 files changed, 19 insertions, 19 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 5ad54e1..56adce6 100644
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -123,12 +123,12 @@ public class Boot extends Thread {
for (Client client : clients) {
switch (client.getState()) {
- case CLIENT_INITIALIZED:
+ case CLIENT_UNKNOWN:
ping(client);
break;
- case PING_INITIALIZED:
+ case CHECK_PING_PROGRESS:
GearmanJob pingJob = pingJobs.get(client.getId());
if (pingJob != null) {
GearmanJobStatus jobStatus = gearmanClient
@@ -174,7 +174,7 @@ public class Boot extends Thread {
break;
- case WAKE_ON_LAN_INITIALIZED:
+ case CHECK_WAKE_ON_LAN_PROGRESS:
GearmanJob wolJob = wolJobs.get(client.getId());
if (wolJob != null) {
GearmanJobStatus jobStatus = gearmanClient
@@ -213,7 +213,7 @@ public class Boot extends Thread {
break;
- case PING_WOL_INITIALIZED:
+ case CHECK_PING_WOL_PROGRESS:
GearmanJob pingJobWoL = pingWoLJobs.get(client.getId());
if (pingJobWoL != null) {
Date currentDate = new Date();
@@ -263,7 +263,7 @@ public class Boot extends Thread {
break;
- case CHECKOS_INITIALIZED:
+ case CHECK_CHECKOS_PROGRESS:
GearmanJob osJob = osJobs.get(client.getId());
if (osJob != null) {
@@ -313,7 +313,7 @@ public class Boot extends Thread {
break;
- case WHO_INITIALIZED:
+ case CHECK_WHO_PROGRESS:
GearmanJob whoJob = whoJobs.get(client.getId());
if (whoJob != null) {
@@ -368,7 +368,7 @@ public class Boot extends Thread {
break;
- case PS_INITIALIZED:
+ case CHECK_PS_PROGRESS:
GearmanJob psJob = psJobs.get(client.getId());
if (psJob != null) {
@@ -435,7 +435,7 @@ public class Boot extends Thread {
break;
- case RESTART_INITIALIZED:
+ case CHECK_RESTART_PROGRESS:
GearmanJob restartJob = restartJobs.get(client.getId());
if (restartJob != null) {
GearmanJobStatus jobStatus = gearmanClient.getJobStatus(restartJob);
@@ -475,7 +475,7 @@ public class Boot extends Thread {
break;
- case PING_RESTART_SHUTDOWN_INITIALIZED:
+ case CHECK_PING_RESTART_SHUTDOWN_PROGRESS:
GearmanJob pingJobRestartShutdown = pingRestartShutdownJobs.get(client.getId());
if (pingJobRestartShutdown != null) {
Date currentDate = new Date();
@@ -546,7 +546,7 @@ public class Boot extends Thread {
break;
- case PING_RESTART_BOOT_INITIALIZED:
+ case CHECK_PING_RESTART_BOOT_PROGRESS:
GearmanJob pingJobRestartBoot = pingRestartBootJobs.get(client
.getId());
if (pingJobRestartBoot != null) {
@@ -651,7 +651,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
.getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.PING_INITIALIZED);
+ client.setState(ClientState.CHECK_PING_PROGRESS);
pingJobs.put(client.getId(), job);
logger.info("ping " + client.getIp());
}
@@ -660,7 +660,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
.getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.PING_WOL_INITIALIZED);
+ client.setState(ClientState.CHECK_PING_WOL_PROGRESS);
pingWoLJobs.put(client.getId(), job);
logger.info("ping " + client.getIp());
}
@@ -669,7 +669,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
.getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.PING_RESTART_SHUTDOWN_INITIALIZED);
+ client.setState(ClientState.CHECK_PING_RESTART_SHUTDOWN_PROGRESS);
pingRestartShutdownJobs.put(client.getId(), job);
logger.info("ping " + client.getIp());
}
@@ -678,7 +678,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("ping", client.getIp()
.getBytes(), "ping" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.PING_RESTART_BOOT_INITIALIZED);
+ client.setState(ClientState.CHECK_PING_RESTART_BOOT_PROGRESS);
pingRestartBootJobs.put(client.getId(), job);
logger.info("ping " + client.getIp());
}
@@ -687,7 +687,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("wol", client.getMac()
.getBytes(), "wol" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.WAKE_ON_LAN_INITIALIZED);
+ client.setState(ClientState.CHECK_WAKE_ON_LAN_PROGRESS);
wolJobs.put(client.getId(), job);
logger.info("wake on lan " + client.getMac());
}
@@ -696,7 +696,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("os", client.getIp()
.getBytes(), "os" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.CHECKOS_INITIALIZED);
+ client.setState(ClientState.CHECK_CHECKOS_PROGRESS);
osJobs.put(client.getId(), job);
logger.info("check OS " + client.getIp());
}
@@ -705,7 +705,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("who", client.getIp()
.getBytes(), "who" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.WHO_INITIALIZED);
+ client.setState(ClientState.CHECK_WHO_PROGRESS);
whoJobs.put(client.getId(), job);
logger.info("who " + client.getIp());
}
@@ -714,7 +714,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("ps", client.getIp()
.getBytes(), "ps" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.PS_INITIALIZED);
+ client.setState(ClientState.CHECK_PS_PROGRESS);
psJobs.put(client.getId(), job);
logger.info("ps " + client.getIp());
}
@@ -723,7 +723,7 @@ public class Boot extends Thread {
GearmanJob job = GearmanJobImpl.createJob("restart", client.getIp()
.getBytes(), "restart" + client.getId());
gearmanClient.submit(job);
- client.setState(ClientState.RESTART_INITIALIZED);
+ client.setState(ClientState.CHECK_RESTART_PROGRESS);
restartJobs.put(client.getId(), job);
logger.info("restart " + client.getIp());
}