dev

plot/refill/ChannelWriter.py

@@ -10,14 +10,14 @@ log = logging.getLogger('writer')
 
 class ChannelWriter(DataWriteStream):
     def write(self, method, params):
-        # self._lock.acquire()
+        self._lock.acquire()
         if method == 'ch_commit':
             self._onCommit(params)
         elif method == 'ch_succ':
             self._onSucc(params)
         elif method == 'ch_fail':
             self._onFail(params)
-        # self._lock.release()
+        self._lock.release()
         pass
 
     def _onCommit(self, params):

plot/refill/DataStream.py

@@ -73,7 +73,7 @@ def span_days(start_time, end_time):
 class DataWriteStream(metaclass=ABCMeta):
     _version = 20200618
     _paths = dict()
-    # _lock = threading.Lock()
+    _lock = threading.Lock()
 
     def __init__(self, hfive):
         self._hfive = hfive

plot/refill/MerchantWriter.py

@@ -10,14 +10,14 @@ log = logging.getLogger('writer')
 
 class MerchantWriter(DataWriteStream):
     def write(self, method, params):
-        # self._lock.acquire()
+        self._lock.acquire()
         if method == 'mch_submit':
             self._onSubmit(params)
         elif method == 'mch_succ':
             self._onSucc(params)
         elif method == 'mch_fail':
             self._onFail(params)
-        # self._lock.release()
+        self._lock.release()
 
     def _onSubmit(self, params):
         def parse(input):

plot/refill/NetchkWriter.py

@@ -12,12 +12,12 @@ log = logging.getLogger('writer')
 
 class NetchkWriter(DataWriteStream):
     def write(self, method, params):
-        # self._lock.acquire()
+        self._lock.acquire()
         if method == 'net_succ':
             self._onSucc(params)
         elif method == 'net_fail':
             self._onFail(params)
-        # self._lock.release()
+        self._lock.release()
 
     def _onSucc(self, params):
         def parse(input):

plot/refill/QueueListener.py

@@ -13,7 +13,7 @@ import logging
 log = logging.getLogger('listener')
 
 class QueueListener(object):
-    _COUNT = 1
+    _COUNT = 8
     _mQueueName = 'REFILL_MONITOR_QUEUE'
     def __init__(self):
         self._mQuit = False