summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/Boot.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/Boot.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/Boot.java14
1 files changed, 11 insertions, 3 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/Boot.java b/gearman/controllerWorker/ControllerWorker/Boot.java
index 6731e28..594f5de 100755
--- a/gearman/controllerWorker/ControllerWorker/Boot.java
+++ b/gearman/controllerWorker/ControllerWorker/Boot.java
@@ -29,6 +29,7 @@ public class Boot extends Thread {
private static final Logger logger = ControllerWorkerMain.getLogger();
private String eventName;
+ private Boolean force;
private Vector<Client> clients;
private String bootOS;
private final int updateRate;
@@ -42,11 +43,12 @@ public class Boot extends Thread {
private Boolean finished;
private Boolean error;
- public Boot(String eventName, Vector<Client> clients, String bootOS,
- int updateRate, long waitTime, long scsavTime,
+ public Boot(String eventName, Boolean force, Vector<Client> clients,
+ String bootOS, int updateRate, long waitTime, long scsavTime,
Vector<String> psWhitelist, Vector<String> psBlacklist,
String gearmanServerAddress, int gearmanServerPort) {
this.eventName = eventName;
+ this.force = force;
this.clients = clients;
this.bootOS = bootOS;
this.waitTime = waitTime * 1000;
@@ -172,7 +174,13 @@ public class Boot extends Thread {
break;
case A_USER_IS_LOGGED_IN:
- ps(client);
+ if (force) {
+ logger.info(client.getIp() + " force is enabled");
+ // is not working
+ client.setState(ClientState.RESTART_CLIENT, gearmanClient);
+ } else {
+ ps(client);
+ }
break;