From 87c69742cd8b47a6dd6cb3d639d917b283309f16 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Tue, 20 Feb 2018 13:43:36 -0500 Subject: [PATCH] log packet encoding errors and warn if the transport is not connected --- lbrynet/dht/protocol.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/lbrynet/dht/protocol.py b/lbrynet/dht/protocol.py index a21585017..4dc2ba176 100644 --- a/lbrynet/dht/protocol.py +++ b/lbrynet/dht/protocol.py @@ -214,8 +214,9 @@ class KademliaProtocol(protocol.DatagramProtocol): try: msgPrimitive = self._encoder.decode(datagram) message = self._translator.fromPrimitive(msgPrimitive) - except (encoding.DecodeError, ValueError): + except (encoding.DecodeError, ValueError) as err: # We received some rubbish here + log.exception("Decode error: %s", err) return except (IndexError, KeyError): log.warning("Couldn't decode dht datagram from %s", address) @@ -359,6 +360,8 @@ class KademliaProtocol(protocol.DatagramProtocol): else: log.error("DHT socket error: %s (%i)", err.message, err.errno) raise err + else: + log.warning("transport not connected!") def _sendResponse(self, contact, rpcID, response): """ Send a RPC response to the specified contact