From f562759f913accbf45f4375f5d51e03c49ba036a Mon Sep 17 00:00:00 2001 From: Jason Carver Date: Tue, 25 Sep 2018 17:10:35 -0700 Subject: [PATCH] Log more info when peer is lost during request --- trinity/protocol/common/managers.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/trinity/protocol/common/managers.py b/trinity/protocol/common/managers.py index 26a3b43da6..5bbc9c9aec 100644 --- a/trinity/protocol/common/managers.py +++ b/trinity/protocol/common/managers.py @@ -176,13 +176,17 @@ async def _cleanup(self) -> None: if self.pending_request is not None: self.logger.debug("Stream %r shutting down, cancelling the pending request", self) _, future = self.pending_request - future.set_exception(PeerConnectionLost("Pending request can't complete: peer is gone")) + future.set_exception(PeerConnectionLost( + f"Pending request can't complete: {self} is shutting down" + )) def deregister_peer(self, peer: BasePeer) -> None: if self.pending_request is not None: self.logger.debug("Peer stream %r shutting down, cancelling the pending request", self) _, future = self.pending_request - future.set_exception(PeerConnectionLost("Pending request can't complete: peer is gone")) + future.set_exception(PeerConnectionLost( + f"Pending request can't complete: {self} peer went offline" + )) def __repr__(self) -> str: return f''