Mercurial > code > home > repos > light9
view bin/clientdemo @ 1436:d0d5900a8031
collector run the blocking dmx output calls in another thread, so they don't add delay to our http server
Ignore-this: b5385085b654e1ac0b8018e6813f36e
author | drewp@bigasterisk.com |
---|---|
date | Sat, 11 Jun 2016 20:30:34 +0000 |
parents | a38955ba6f40 |
children | 6fa4288da8a6 |
line wrap: on
line source
#!bin/python import os, sys sys.path.append(".") from twisted.internet import reactor import cyclone.web, cyclone.httpclient, logging from rdflib import Namespace, Literal, URIRef from light9 import networking from light9.rdfdb.patch import Patch from light9.rdfdb.syncedgraph import SyncedGraph if __name__ == "__main__": logging.basicConfig(level=logging.DEBUG) log = logging.getLogger() g = SyncedGraph(networking.rdfdb.url, "clientdemo") from light9.Submaster import PersistentSubmaster sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools")) #get sub to show its updating name, then push that all the way into KC gui so we can see just names refresh in there L9 = Namespace("http://light9.bigasterisk.com/") def updateDemoValue(): v = list(g.objects(L9['demo'], L9['is'])) print "demo value is %r" % v g.addHandler(updateDemoValue) def adj(): g.patch(Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()), L9['clientdemo'])], delQuads=[])) reactor.callLater(2, adj) reactor.run()