From ef77a9816ef9f50aa89c03d867c0b1012ccf3f29 Mon Sep 17 00:00:00 2001 From: lakshyacis Date: Thu, 5 Sep 2019 14:36:44 +0530 Subject: [PATCH] invthread pylint fixes --- src/network/invthread.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/src/network/invthread.py b/src/network/invthread.py index d0dbb387..cf202012 100644 --- a/src/network/invthread.py +++ b/src/network/invthread.py @@ -1,3 +1,7 @@ +""" +src/network/invthread.py +======================== +""" import Queue import random from time import time @@ -32,9 +36,13 @@ def handleExpiredDandelion(expired): class InvThread(StoppableThread): + """A thread to manage inventory""" + name = "InvBroadcaster" - def handleLocallyGenerated(self, stream, hashId): + @staticmethod + def handleLocallyGenerated(stream, hashId): + """Locally generated inventory items require special handling""" Dandelion().addHash(hashId, stream=stream) for connection in \ BMConnectionPool().inboundConnections.values() + \ @@ -43,8 +51,8 @@ class InvThread(StoppableThread): continue connection.objectsNewToThem[hashId] = time() - def run(self): - while not state.shutdown: + def run(self): # pylint: disable=too-many-branches + while not state.shutdown: # pylint: disable=too-many-nested-blocks chunk = [] while True: # Dandelion fluff trigger by expiration