light9 Changeset - c33158b367a5

Changeset - c33158b367a5

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Drew Perttula - 11 years ago 2014-06-02 06:04:19
drewp@bigasterisk.com

inputdemo reports latency of posting each point. takes curve uri on cmdline
Ignore-this: 640cf036dfb5f5ae956be1cde5190846

1 file changed with 8 insertions and 5 deletions:

bin/inputdemo

0 comments (0 inline, 0 general)

bin/inputdemo

➞

Show inline comments

 #!bin/python
 import sys
 sys.path.append('/usr/lib/python2.7/dist-packages') # For gtk
 from twisted.internet import gtk3reactor
 gtk3reactor.install()
 from twisted.internet import reactor
 from rdflib import URIRef
 import optparse, logging, urllib
+import optparse, logging, urllib, time
 from gi.repository import Gtk
 from run_local import log
 from light9 import showconfig, networking
 from light9.rdfdb import clientsession
 from light9.rdfdb.syncedgraph import SyncedGraph
 import cyclone.httpclient
 class App(object):
     def __init__(self):
         parser = optparse.OptionParser()
         parser.set_usage("%prog [opts]")
+        parser.set_usage("%prog [opts] [curve uri]")
         parser.add_option("--debug", action="store_true",
                           help="log at DEBUG")
         clientsession.add_option(parser)
         opts, args = parser.parse_args()
         log.setLevel(logging.DEBUG if opts.debug else logging.INFO)
         self.session = clientsession.getUri('inputdemo', opts)
         self.graph = SyncedGraph("inputdemo")
         self.graph.initiallySynced.addCallback(lambda _: self.launch())
         self.curve = URIRef('http://light9.bigasterisk.com/show/dance2014/song1/curve/c-1401259747.675542')
+        self.curve = args[0] if args else URIRef('http://light9.bigasterisk.com/show/dance2014/song1/curve/c-1401259747.675542')
         print "sending points on curve %s" % self.curve
         reactor.run()
     def launch(self):
         win = Gtk.Window()
         slider = Gtk.Scale.new_with_range(orientation=Gtk.Orientation.VERTICAL,
                                           min=0, max=1, step=.001)
         slider.props.inverted = True
         slider.connect('value-changed', self.onChanged)
         win.add(slider)
         win.parse_geometry('50x250')
         win.connect("delete-event", lambda *a: reactor.crash())
         win.connect("destroy", lambda *a: reactor.crash())
         win.show_all()
     def onChanged(self, scale):
         f = cyclone.httpclient.fetch(
             networking.curveCalc.path('liveInputPoint'),
             method='POST', timeout=1,
             postdata=urllib.urlencode({'curve': self.curve,
                                        'value': str(scale.get_value())}))
             postdata=urllib.urlencode({
                 'curve': self.curve,
                 'value': str(scale.get_value()),
             }))
         @f.addCallback
         def cb(result):
             if result.code // 100 != 2:
                 log.error("curveCalc said %s: %s", result.code, result.body)
             print "posted in %.1f ms" % (1000 * (time.time() - t1))
         @f.addErrback
         def eb(err):
             print "err", err
 App()

0 comments (0 inline, 0 general)