Commit bb04856c authored by Josh Kunz's avatar Josh Kunz

Log msg UUIDs at "info" level

parent 86480b22
......@@ -507,6 +507,7 @@ class Protocol(object):
def _recv_next(self, timeout=None):
msg = self._recv_msg(timeout)
log.info("Recv MSG: {0}".format(hex(msg.uuid)))
message_type = msg.WhichOneof("type")
if message_type == "reply":
return self._handle_reply(msg)
......@@ -525,6 +526,7 @@ class Protocol(object):
if msg.uuid not in self.pending_replies:
self.pending_replies[msg.uuid] = f
self.transport._send_cap_msg(msg.SerializeToString(), CAPNET_ADDR)
log.info("Sent MSG: {0}".format(hex(msg.uuid)))
return f
def _request(self, sub_msg, register_notify=False, **kwargs):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment