afonso/core-extra
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

updated tcp handler to not timeout and block waiting for messages

Browse source
This commit is contained in:
Blake J. Harnden 2018-03-16 13:01:05 -07:00
parent ee5bbdd949
commit 0e38304b18
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
daemon/core/corehandlers.py
View file

@ -426,11 +426,8 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
:return: nothing :return: nothing
""" """
while not self.done: while not self.done:
try: message = self.message_queue.get()
message = self.message_queue.get(timeout=5)
self.handle_message(message) self.handle_message(message)
except Queue.Empty:
logger.debug("timeout getting message")
def handle_message(self, message): def handle_message(self, message):
""" """