light9 Changeset - d6ec468112cb

Changeset - d6ec468112cb

Parent rev.

Child rev.

[Not reviewed]

default

0 2 0

drewp@bigasterisk.com - 7 years ago 2018-06-09 02:01:36
drewp@bigasterisk.com

not sure highwatermark setting did what i wanted
Ignore-this: 3a3b2835ea3a30d7fb0e2007a3b06bb2

2 files changed with 2 insertions and 2 deletions:

bin/collector

light9/dmxclient.py

0 comments (0 inline, 0 general)

bin/collector

➞

Show inline comments

@@ @@ -49,7 +49,7 @@ def startZmq(port, collector): @@
     log.info('creating zmq endpoint at %r', addr)
     e = ZmqEndpoint('bind', addr)
     class Pull(ZmqPullConnection):
         highWaterMark = 3
+        #highWaterMark = 3
         def onPull(self, message):
             with stats.setAttr.time():
                 # todo: new compressed protocol where you send all URIs up

light9/dmxclient.py

➞

Show inline comments

@@ @@ -22,7 +22,7 @@ class TwistedZmqClient(object): @@
         zf = ZmqFactory()
         e = ZmqEndpoint('connect', 'tcp://%s:%s' % (service.host, service.port))
         class Push(ZmqPushConnection):
-            highWaterMark = 3
+            pass # highWaterMark = 3000
         self.conn = Push(zf, e)
     def send(self, clientid, levellist):

0 comments (0 inline, 0 general)