light9 Changeset - 5668ad92a98e

Changeset - 5668ad92a98e

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Drew Perttula - 7 years ago 2018-06-08 09:14:36
drewp@bigasterisk.com

bug in collector log
Ignore-this: aa0d13a3d59c156de00d48939af36145

1 file changed with 1 insertions and 1 deletions:

bin/collector

0 comments (0 inline, 0 general)

bin/collector

➞

Show inline comments

@@ @@ -57,25 +57,25 @@ def startZmq(port, collector): @@
             client, clientSession, settings, sendTime = parseJsonMessage(message[0])
             collector.setAttrs(client, clientSession, settings, sendTime)
     s.onPull = onPull
 class WebListeners(object):
     def __init__(self):
         self.clients = []
         self.pendingMessageForDev = {} # dev: (attrs, outputmap)
         self.lastFlush = 0
     def addClient(self, client):
         self.clients.append([client, {}]) # seen = {dev: attrs}
         log.info('added client %s %s', len(clients), client)
+        log.info('added client %s %s', len(self.clients), client)
     def delClient(self, client):
         self.clients = [[c, t] for c, t in self.clients if c != client]
         log.info('delClient %s, %s left', client, len(self.clients))
     def outputAttrsSet(self, dev, attrs, outputMap):
         """called often- don't be slow"""
         self.pendingMessageForDev[dev] = (attrs, outputMap)
         self._flush()
     def _flush(self):

0 comments (0 inline, 0 general)