# HG changeset patch
# User Drew Perttula <drewp@bigasterisk.com>
# Date 1465839398 0
# Node ID 649d482737e06661428fe68dcd233bc84bbb29f1
# Parent  31612b323436111c1b5e2eb87bfef1025876de94
start of a collector --loadtest mode
Ignore-this: be1e42cfb4c30f2467e429da1b4a05e0

diff -r 31612b323436 -r 649d482737e0 bin/collector
--- a/bin/collector	Mon Jun 13 11:12:07 2016 +0000
+++ b/bin/collector	Mon Jun 13 17:36:38 2016 +0000
@@ -59,7 +59,7 @@
             collector.setAttrs()
     s.onPull = onPull
 
-def launch(graph):
+def launch(graph, doLoadTest=False):
 
     # todo: drive outputs with config files
     outputs = [
@@ -76,18 +76,42 @@
                       interface='::')
     log.info('serving http on %s, zmq on %s', networking.collector.port,
              networking.collectorZmq.port)
-    
+    if doLoadTest:
+        loadTest()
+
+
+def loadTest():
+    from light9.effect.sequencer import sendToCollector
+    import time
+    session = "loadtest%s" % time.time()
+    offset = 0
+    for i in range(2000):
+        reactor.callLater(offset, sendToCollector, "http://dash:8200/live/", session,
+                    [["http://light9.bigasterisk.com/device/backlight1","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/backlight2","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/backlight3","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/backlight4","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/backlight5","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/down2","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/down3","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/down4","http://light9.bigasterisk.com/color","#ffffff"],
+                     ["http://light9.bigasterisk.com/device/backlight5","http://light9.bigasterisk.com/uv",0.011]])
+        offset += .005
+
+    reactor.callLater(offset, reactor.stop)
     
 def main():
     parser = optparse.OptionParser()
     parser.add_option("-v", "--verbose", action="store_true",
                       help="logging.DEBUG")
+    parser.add_option("--loadtest", action="store_true",
+                      help="call myself with some synthetic load then exit")
     (options, args) = parser.parse_args()
     log.setLevel(logging.DEBUG if options.verbose else logging.INFO)
 
     graph = SyncedGraph(networking.rdfdb.url, "collector")
 
-    graph.initiallySynced.addCallback(lambda _: launch(graph))
+    graph.initiallySynced.addCallback(lambda _: launch(graph, options.loadtest))
     reactor.run()
 
 if __name__ == '__main__':
diff -r 31612b323436 -r 649d482737e0 light9/effect/sequencer.py
--- a/light9/effect/sequencer.py	Mon Jun 13 11:12:07 2016 +0000
+++ b/light9/effect/sequencer.py	Mon Jun 13 17:36:38 2016 +0000
@@ -29,7 +29,9 @@
     return treq.put(networking.collector.path('attrs'),
                     data=json.dumps({'settings': settings,
                                      'client': client,
-                                     'clientSession': session}))
+                                     'clientSession': session,
+                                     'sendTime': time.time(),
+                                 }))
 
 
 class Note(object):