Log more info when peer is lost during request

ethereum · Sep 26, 2018 · f562759 · f562759
1 parent 76d43ea
commit f562759
Showing 1 changed file with 6 additions and 2 deletions.
diff --git 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'<ResponseCandidateStream({self._peer!s}, {self.response_msg_type!r})>'