Bitmessage/PyBitmessage-2024-12-03
Archived
2
0
Fork 0
Code Issues 168 Pull Requests 53 Actions Packages Projects Releases 5 Wiki Activity

Remove obsolete code in cleaner thread

Browse Source
This commit is contained in:
Peter Šurda 2017-11-22 21:13:35 +01:00
parent 6ca3460090
commit 44dd08a228
Signed by: PeterSurda
GPG Key ID: 0C5F50C0B5F37D87
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/class_singleCleaner.py
View File

@ -63,8 +63,6 @@ class singleCleaner(threading.Thread, StoppableThread):
Inventory().flush() Inventory().flush()
queues.UISignalQueue.put(('updateStatusBar', '')) queues.UISignalQueue.put(('updateStatusBar', ''))
protocol.broadcastToSendDataQueues((
0, 'pong', 'no data')) # commands the sendData threads to send out a pong message if they haven't sent anything else in the last five minutes. The socket timeout-time is 10 minutes.
# If we are running as a daemon then we are going to fill up the UI # If we are running as a daemon then we are going to fill up the UI
# queue which will never be handled by a UI. We should clear it to # queue which will never be handled by a UI. We should clear it to
# save memory. # save memory.
@ -127,10 +125,10 @@ class singleCleaner(threading.Thread, StoppableThread):
os._exit(0) os._exit(0)
shared.needToWriteKnownNodesToDisk = False shared.needToWriteKnownNodesToDisk = False
# clear download queues # # clear download queues
for thread in threading.enumerate(): # for thread in threading.enumerate():
if thread.isAlive() and hasattr(thread, 'downloadQueue'): # if thread.isAlive() and hasattr(thread, 'downloadQueue'):
thread.downloadQueue.clear() # thread.downloadQueue.clear()
# inv/object tracking # inv/object tracking
for connection in BMConnectionPool().inboundConnections.values() + BMConnectionPool().outboundConnections.values(): for connection in BMConnectionPool().inboundConnections.values() + BMConnectionPool().outboundConnections.values():