Mercurial > code > home > repos > light9

changeset 1826:d6ec468112cb

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
not sure highwatermark setting did what i wanted Ignore-this: 3a3b2835ea3a30d7fb0e2007a3b06bb2
author drewp@bigasterisk.com
date Sat, 09 Jun 2018 02:01:36 +0000
parents 1692e8aba9f5
children cc65c40802f6
files bin/collector light9/dmxclient.py
diffstat 2 files changed, 2 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/bin/collector	Sat Jun 09 01:59:39 2018 +0000
+++ b/bin/collector	Sat Jun 09 02:01:36 2018 +0000
@@ -49,7 +49,7 @@
     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
--- a/light9/dmxclient.py	Sat Jun 09 01:59:39 2018 +0000
+++ b/light9/dmxclient.py	Sat Jun 09 02:01:36 2018 +0000
@@ -22,7 +22,7 @@
         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):