light9 Changeset - 5c8b6cd330da

Changeset - 5c8b6cd330da

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

drewp@bigasterisk.com - 6 years ago 2019-06-08 09:18:33
drewp@bigasterisk.com

fix artnet setup
Ignore-this: b6a4f26b87bb2e61e3391d620c5d1462

1 file changed with 3 insertions and 6 deletions:

bin/collector

0 comments (0 inline, 0 general)

bin/collector

➞

Show inline comments

@@ @@ -18,25 +18,25 @@ import cyclone.web, cyclone.websocket @@
 from greplin import scales
 from cycloneerr import PrettyErrorHandler
 from light9 import networking
 from light9.collector.collector import Collector
 from light9.collector.weblisteners import WebListeners
 from greplin.scales.cyclonehandler import StatsHandler
 from light9.namespaces import L9
 from light9.zmqtransport import parseJsonMessage, startZmq
 from rdfdb.syncedgraph import SyncedGraph
 from standardservice.scalessetup import gatherProcessStats
-from light9.collector.output import Udmx, ArtnetDmx, DummyOutput  # noqa
 from light9.collector.output import ArtnetDmx, DummyOutput  # noqa
 class Updates(cyclone.websocket.WebSocketHandler):
     def connectionMade(self, *args, **kwargs):
         log.info('socket connect %s', self)
         self.settings.listeners.addClient(self)
     def connectionLost(self, reason):
         self.settings.listeners.delClient(self)
     def messageReceived(self, message):
@@ @@ -57,31 +57,28 @@ class Attrs(PrettyErrorHandler, cyclone. @@
         stats.setAttrFps.mark()
         with stats.setAttr.time():
             client, clientSession, settings, sendTime = parseJsonMessage(
                 self.request.body)
             self.settings.collector.setAttrs(client, clientSession, settings,
                                              sendTime)
             self.set_status(202)
 def launch(graph, doLoadTest=False):
     try:
         # todo: drive outputs with config files
-        rate = 20  # On udmx, 22 breaks. 28 breaks. 30 breaks.
         rate = 30
         outputs = [
             #Udmx(L9['output/dmxB/'], bus=1, address=None, lastDmxChannel=221, rate=rate),
             ArtnetDmx(L9['output/dmxA/'], host='127.0.0.1', port=6445, rate=rate),
             #DummyOutput(L9['output/dmxA/']),
             DummyOutput(L9['output/dmxA/']),
             ArtnetDmx(L9['output/dmxB/'], rate=rate),
+        ]
     except Exception:
         log.error("setting up outputs:")
         traceback.print_exc()
         raise
     listeners = WebListeners()
     c: Collector = Collector(graph, outputs, listeners)
     startZmq(networking.collectorZmq.port, c)
     reactor.listenTCP(networking.collector.port,
                       cyclone.web.Application(handlers=[

0 comments (0 inline, 0 general)