From: Ali Younis Date: Thu, 18 May 2017 20:02:08 +0000 (-0700) Subject: Changes X-Git-Url: http://demsky.eecs.uci.edu/git/?a=commitdiff_plain;h=60b838f9715c26fc3510d5ed6f62c9ef12d2c839;p=iotcloud.git Changes --- diff --git a/version2/src/java/light_fan_embed_benchmark/Filler.java b/version2/src/java/light_fan_embed_benchmark/Filler.java index e629039..82871f5 100644 --- a/version2/src/java/light_fan_embed_benchmark/Filler.java +++ b/version2/src/java/light_fan_embed_benchmark/Filler.java @@ -1,5 +1,12 @@ + +import java.util.Scanner; +import iotcloud.*; + +import java.util.Scanner; +import iotcloud.*; + import java.util.Scanner; import iotcloud.*; class Filler { diff --git a/version2/src/java/light_fan_embed_benchmark/Filler2.java b/version2/src/java/light_fan_embed_benchmark/Filler2.java new file mode 100644 index 0000000..0e84979 --- /dev/null +++ b/version2/src/java/light_fan_embed_benchmark/Filler2.java @@ -0,0 +1,44 @@ + + + +import java.util.Scanner; +import iotcloud.*; + +import java.util.Scanner; +import iotcloud.*; +class Filler2 { + public static void main(String[] args) throws Exception { + + + Table t1 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 400, -1); + t1.rebuild(); // update + + String valueA = "on"; + String valueB = "off"; + IoTString iValueA = new IoTString(valueA); + IoTString iValueB = new IoTString(valueB); + + + System.out.println("Starting System"); + String a1 = "bulb1"; + IoTString ia1 = new IoTString(a1); + + + while (true) { + + + + // t1.update(); + t1.startTransaction(); + t1.addKV(ia1, iValueB); + t1.commitTransaction(); + + try { + Thread.sleep(500); + } catch (Exception e) { + + } + + } + } +} \ No newline at end of file diff --git a/version2/src/java/light_fan_embed_benchmark/LightsController.java b/version2/src/java/light_fan_embed_benchmark/LightsController.java index 69eed6f..46df781 100644 --- a/version2/src/java/light_fan_embed_benchmark/LightsController.java +++ b/version2/src/java/light_fan_embed_benchmark/LightsController.java @@ -117,6 +117,9 @@ class LightsController { + // Table t2 = new Table("http://dc-6.calit2.uci.edu/test.iotcloud/", "reallysecret", 400, -1); + // t2.rebuild(); + while (true) { @@ -127,11 +130,16 @@ class LightsController { String pingTimer = Long.toString(System.currentTimeMillis()); IoTString ipingTimer = new IoTString(pingTimer); - t1.update(); + // t1.update(); t1.startTransaction(); t1.addKV(ipingTimerKey, ipingTimer); t1.commitTransaction(); + // // t2.update(); + // t2.startTransaction(); + // t2.addKV(ipingTimerKey, ipingTimer); + // t2.commitTransaction(); + diff --git a/version2/src/java/light_fan_embed_benchmark/runFiller2.bash b/version2/src/java/light_fan_embed_benchmark/runFiller2.bash new file mode 100755 index 0000000..7a37caf --- /dev/null +++ b/version2/src/java/light_fan_embed_benchmark/runFiller2.bash @@ -0,0 +1,3 @@ +#!/bin/sh + +java -cp .:../iotcloud/bin Filler2 \ No newline at end of file