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.java51
1 files changed, 17 insertions, 34 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Shutdown.java b/gearman/controllerWorker/ControllerWorker/Shutdown.java
index b174156..1058464 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[] statusText;
private HashMap<Integer, GearmanJob> pingJobs;
private HashMap<Integer, GearmanJob> whoJobs;
@@ -35,7 +36,7 @@ public class Shutdown extends Thread {
private HashMap<Integer, GearmanJob> pingShutdownJobs;
private HashMap<Integer, GearmanJob> sshJobs;
private HashMap<Integer, Integer> status;
- private HashMap<Integer, Integer> errors;
+ private HashMap<Integer, String> errors;
private HashMap<Integer, Long> pingShutdownTime;
private Vector<HashMap<String, String>> clients;
@@ -50,7 +51,7 @@ public class Shutdown extends Thread {
this.shutdownJobs = new HashMap<Integer, GearmanJob>();
this.sshJobs = new HashMap<Integer, GearmanJob>();
this.status = new HashMap<Integer, Integer>();
- this.errors = new HashMap<Integer, Integer>();
+ this.errors = new HashMap<Integer, String>();
this.updateRate = updateRate; // updates per second
this.updatePeriod = 1000000000L / this.updateRate; // nanoseconds
this.gearmanConnection = new GearmanNIOJobServerConnection(
@@ -64,6 +65,8 @@ public class Shutdown extends Thread {
}
this.finished = false;
this.error = false;
+ this.statusText = new String[20];
+ this.statusText[0] = "The shutdown process of the client has been started.";
}
public void run() {
@@ -298,40 +301,16 @@ public class Shutdown extends Thread {
System.out.println("ssh " + ipAddress);
}
- public Vector<HashMap<String, String>> getClients() {
- return clients;
- }
-
- public GearmanClient getGearmanClient() {
- return gearmanClient;
- }
-
- public GearmanJobServerConnection getGearmanConnection() {
- return gearmanConnection;
- }
-
- public HashMap<Integer, GearmanJob> getPingJobs() {
- return pingJobs;
- }
-
- public HashMap<Integer, GearmanJob> getSshJobs() {
- return sshJobs;
- }
-
- public HashMap<Integer, GearmanJob> getWhoJobs() {
- return whoJobs;
- }
-
- public HashMap<Integer, GearmanJob> getShutdownJobs() {
- return shutdownJobs;
- }
-
- public HashMap<Integer, Integer> getStatus() {
- return status;
+ public String getStatusText(HashMap<String, String> client) {
+ int clientID = Integer.parseInt(client.get("id"));
+ int clientStatus = this.status.get(clientID);
+ return this.statusText[clientStatus];
}
- public HashMap<Integer, Integer> getErrors() {
- return errors;
+ public String getError(HashMap<String, String> client) {
+ int clientID = Integer.parseInt(client.get("id"));
+ String clientError = this.errors.get(clientID);
+ return clientError;
}
public Boolean isFinished() {
@@ -341,4 +320,8 @@ public class Shutdown extends Thread {
public Boolean isFinishedWithErrors() {
return finished && error;
}
+
+ public Vector<HashMap<String, String>> getClients() {
+ return clients;
+ }
} \ No newline at end of file