diff bin/collector @ 1826:d6ec468112cb

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 0da5fcfe4ea5
children 7772cc48e016
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