4 class LightsController {
6 public static void main(String[] args) throws Exception {
8 LightBulb bulb1 = new LightBulb();
9 LightBulb bulb2 = new LightBulb();
10 LightBulb bulb3 = new LightBulb();
13 List<LightBulb> bulbs = new ArrayList<LightBulb>();
23 IoTString ia1 = new IoTString(a1);
24 IoTString ia2 = new IoTString(a2);
25 IoTString ia3 = new IoTString(a3);
28 List<IoTString> keys = new ArrayList<IoTString>();
35 IoTString iValueA = new IoTString(valueA);
38 String pingTimerKey = "bulbController";
39 IoTString ipingTimerKey = new IoTString(pingTimerKey);
43 System.out.println("Starting System");
49 t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 321, 6000);
50 t1.addLocalCommunication(1000, "192.168.2.50", 6001);
56 for (int i = 0; i < 3; i++) {
57 bulbs.get(i).setColor(0, 100, 100);
63 for (int i = 0; i < 3; i++) {
64 bulbs.get(i).turnOff();
68 for (int i = 0; i < 3; i++) {
69 bulbs.get(i).turnOn();
78 // Table t2 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 400, -1);
86 System.out.println("Loop");
88 String pingTimer = Long.toString(System.currentTimeMillis());
89 IoTString ipingTimer = new IoTString(pingTimer);
92 t1.startTransaction();
93 t1.addKV(ipingTimerKey, ipingTimer);
94 t1.commitTransaction();
97 // t2.startTransaction();
98 // t2.addKV(ipingTimerKey, ipingTimer);
99 // t2.commitTransaction();
107 for (int i = 0; i < 3; i++) {
108 IoTString testValA1 = t1.getCommitted(keys.get(i));
109 if ((testValA1 != null) && (testValA1.equals(iValueA) == true)) {
110 bulbs.get(i).turnOn();
112 bulbs.get(i).turnOff();
121 for (int i = 0; i < 3; i++) {
122 bulbs.get(i).setColor(0, 100, 100);
128 for (int i = 0; i < 3; i++) {
129 bulbs.get(i).turnOff();
133 for (int i = 0; i < 3; i++) {
134 bulbs.get(i).turnOn();