Apply PR feedback: update error msg
This commit is contained in:
parent
e51d376d5e
commit
74092c1371
@ -588,7 +588,7 @@ class GossipSub(IPubsubRouter):
|
|||||||
# 3) Get the stream to this peer
|
# 3) Get the stream to this peer
|
||||||
if sender_peer_id not in self.pubsub.peers:
|
if sender_peer_id not in self.pubsub.peers:
|
||||||
logger.debug(
|
logger.debug(
|
||||||
"Fail to responed to iwant request from %s: peer disconnected",
|
"Fail to responed to iwant request from %s: peer record not exist",
|
||||||
sender_peer_id,
|
sender_peer_id,
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
@ -700,7 +700,7 @@ class GossipSub(IPubsubRouter):
|
|||||||
# Get stream for peer from pubsub
|
# Get stream for peer from pubsub
|
||||||
if to_peer not in self.pubsub.peers:
|
if to_peer not in self.pubsub.peers:
|
||||||
logger.debug(
|
logger.debug(
|
||||||
"Fail to emit control message to %s: peer disconnected", to_peer
|
"Fail to emit control message to %s: peer record not exist", to_peer
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
peer_stream = self.pubsub.peers[to_peer]
|
peer_stream = self.pubsub.peers[to_peer]
|
||||||
|
Loading…
x
Reference in New Issue
Block a user