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

updates for dispatching replies from udp handler

Browse source
This commit is contained in:
Blake J. Harnden 2018-03-16 12:18:15 -07:00
parent 76524abbc2
commit 7260f823cb
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
daemon/core/corehandlers.py
View file

@ -458,7 +458,7 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
:param message: message for replies :param message: message for replies
:return: nothing :return: nothing
""" """
logger.info("replies to dispatch: %s", replies) logger.info("dispatching replies")
for reply in replies: for reply in replies:
message_type, message_flags, message_length = coreapi.CoreMessage.unpack_header(reply) message_type, message_flags, message_length = coreapi.CoreMessage.unpack_header(reply)
try: try:
@ -472,12 +472,12 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
reply_message = "CoreMessage (type %d flags %d length %d)" % ( reply_message = "CoreMessage (type %d flags %d length %d)" % (
message_type, message_flags, message_length) message_type, message_flags, message_length)
logger.info("reply to %s: \n%s", self.request.getpeername(), reply_message) logger.info("dispatch reply:\n%s", reply_message)
try: try:
self.sendall(reply) self.sendall(reply)
except IOError: except IOError:
logger.exception("Error sending reply data") logger.exception("error dispatching reply")
def handle(self): def handle(self):
""" """