dev

plot/refill/WriterConsumer.py

@@ -10,14 +10,14 @@ class WriterConsumer(Thread):
         self._messages = Queue(1000000)
         self._stopped = False
         self._handler = handler
-        self._max_threshold  = 10000
+        self._max_threshold  = 5000
         self._max_batch_size = 200000
         self._name = name
 
     def run(self):
         while True:
             size = self._messages.qsize()
-            # log.debug("%s messages size=%d", self._name, size)
+            log.debug("%s messages size=%d", self._name, size)
             if size > self._max_threshold:
                 self._batch()
             else: