summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/BootWorker.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-23 13:06:13 +0200
committerBjörn Geiger2011-08-23 13:06:13 +0200
commit7ca240490d0ba6b2da2dd0939fc2659069f2c7a1 (patch)
treeffc6170a2fddb142232106352fdc2c877d463b99 /gearman/controllerWorker/ControllerWorker/BootWorker.java
parentBlack und Whitelist wird nun übergeben (diff)
downloadpoolctrl-7ca240490d0ba6b2da2dd0939fc2659069f2c7a1.tar.gz
poolctrl-7ca240490d0ba6b2da2dd0939fc2659069f2c7a1.tar.xz
poolctrl-7ca240490d0ba6b2da2dd0939fc2659069f2c7a1.zip
blacklist und whitelist wird nun vom worker bearbeitet
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/BootWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/BootWorker.java16
1 files changed, 15 insertions, 1 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index e14e380..22d1e91 100644
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.java
@@ -41,7 +41,21 @@ public class BootWorker extends AbstractGearmanFunction {
clients.add(clientMap);
}
- Boot boot = new Boot(host, port, clients, updateRate, waitTime, eventOS);
+ JSONArray whitelist = (JSONArray) jsonObject.get("whitelist");
+ JSONArray blacklist = (JSONArray) jsonObject.get("blacklist");
+ Vector<String> psWhitelist = new Vector<String>();
+ Vector<String> psBlacklist = new Vector<String>();
+
+ for (Object whiteEntry : whitelist) {
+ psWhitelist.add(whiteEntry.toString());
+ }
+
+ for (Object blackEntry : blacklist) {
+ psBlacklist.add(blackEntry.toString());
+ }
+
+ Boot boot = new Boot(host, port, clients, updateRate, waitTime,
+ eventOS, psWhitelist, psBlacklist);
StatusWorker.BOOTTHREADS.put(event, boot);
boot.start();
System.out.println("Booting started");