Mercurial > code > home > repos > light9
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