Network status update part 2

- only update processed items every 2 seconds
Bitmessage · May 31, 2017 · 2555f69 · 2555f69
1 parent e522f01
commit 2555f69
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/class_objectProcessor.py b/src/class_objectProcessor.py
@@ -181,8 +181,8 @@ def processgetpubkey(self, data):
     def processpubkey(self, data):
         pubkeyProcessingStartTime = time.time()
         shared.numberOfPubkeysProcessed += 1
-        queues.UISignalQueue.put((
-            'updateNumberOfPubkeysProcessed', 'no data'))
+#        queues.UISignalQueue.put((
+#            'updateNumberOfPubkeysProcessed', 'no data'))
         embeddedTime, = unpack('>Q', data[8:16])
         readPosition = 20  # bypass the nonce, time, and object type
         addressVersion, varintLength = decodeVarint(
@@ -330,8 +330,8 @@ def processpubkey(self, data):
     def processmsg(self, data):
         messageProcessingStartTime = time.time()
         shared.numberOfMessagesProcessed += 1
-        queues.UISignalQueue.put((
-            'updateNumberOfMessagesProcessed', 'no data'))
+#        queues.UISignalQueue.put((
+#            'updateNumberOfMessagesProcessed', 'no data'))
         readPosition = 20 # bypass the nonce, time, and object type
         msgVersion, msgVersionLength = decodeVarint(data[readPosition:readPosition + 9])
         if msgVersion != 1:
@@ -600,8 +600,8 @@ def processmsg(self, data):
     def processbroadcast(self, data):
         messageProcessingStartTime = time.time()
         shared.numberOfBroadcastsProcessed += 1
-        queues.UISignalQueue.put((
-            'updateNumberOfBroadcastsProcessed', 'no data'))
+#        queues.UISignalQueue.put((
+#            'updateNumberOfBroadcastsProcessed', 'no data'))
         inventoryHash = calculateInventoryHash(data)
         readPosition = 20  # bypass the nonce, time, and object type
         broadcastVersion, broadcastVersionLength = decodeVarint(