version2/src/java/light_fan_embed_benchmark/WemoController.java

   1 import iotcloud.*;
   2 import java.util.*;
   3
   4
   5 class WemoController {
   6     public static void main(String[] args) throws Exception {
   7
   8         Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 351, -1);
   9         t1.rebuild();
  10
  11
  12         String a = "fan";
  13         IoTString ia = new IoTString(a);
  14         t1.createNewKey(ia, 351);
  15
  16
  17         String a1 = "wemo1";
  18         String a2 = "wemo2";
  19
  20         IoTString ia1 = new IoTString(a1);
  21         IoTString ia2 = new IoTString(a2);
  22
  23
  24         List<IoTString> keys = new ArrayList<IoTString>();
  25         keys.add(ia1);
  26         keys.add(ia2);
  27
  28
  29         IoTDeviceAddress devAddr1 = new IoTDeviceAddress("192.168.1.16", 49153, 49153, false, false);
  30         Wemo wemo1 = new Wemo(devAddr1);
  31
  32         IoTDeviceAddress devAddr2 = new IoTDeviceAddress("192.168.1.34", 49154, 49153, false, false);
  33         Wemo wemo2 = new Wemo(devAddr2);
  34
  35         List<Wemo> wemos = new ArrayList<Wemo>();
  36         wemos.add(wemo1);
  37         wemos.add(wemo2);
  38
  39
  40         String pingTimerKey = "wemoController";
  41         IoTString ipingTimerKey = new IoTString(pingTimerKey);
  42
  43
  44         String valueA = "on";
  45         IoTString iValueA = new IoTString(valueA);
  46
  47         System.out.println("Starting System");
  48         int counter = 0;
  49
  50
  51         while (true) {
  52             try {
  53                 counter++;
  54                 if (counter == 10) {
  55                     counter = 0;
  56
  57                     String pingTimer = Long.toString(System.currentTimeMillis());
  58                     IoTString ipingTimer = new IoTString(pingTimer);
  59
  60                     t1.update();
  61                     t1.startTransaction();
  62                     t1.addKV(ipingTimerKey, ipingTimer);
  63                     t1.commitTransaction();
  64                 }
  65
  66
  67                 t1.update();
  68                 Thread.sleep(1000);
  69
  70                 for (int i = 0; i < 2; i++) {
  71                     IoTString testValA1 = t1.getCommitted(keys.get(i));
  72                     if ((testValA1 != null) && (testValA1.equals(iValueA) == true)) {
  73                         wemos.get(i).turnOn();
  74                     } else {
  75                         wemos.get(i).turnOff();
  76                     }
  77                 }
  78
  79             } catch (Error e) {
  80
  81                 Runtime runTime = Runtime.getRuntime();
  82                 runTime.exec("gpio mode 4 out");
  83
  84
  85                 while (true) {
  86                     runTime.exec("gpio write 4 1");
  87                     Thread.sleep(500);
  88                     runTime.exec("gpio write 4 0");
  89                     Thread.sleep(500);
  90                 }
  91             }
  92         }
  93     }
  94 }