Remove dead peer if floodsub write stream fail

2019-12-17 18:48:25 +08:00 · 2019-12-17 18:48:25 +08:00 · 474ed41652
commit 474ed41652
parent 009df257bc
1 changed files with 1 additions and 0 deletions
--- a/libp2p/pubsub/floodsub.py
+++ b/libp2p/pubsub/floodsub.py
@ -98,6 +98,7 @@ class FloodSub(IPubsubRouter):
                await stream.write(encode_varint_prefixed(rpc_msg.SerializeToString()))
            except StreamClosed:
                logger.debug("Fail to publish message to %s: stream closed", peer_id)
+                self.pubsub._handle_dead_peer(peer_id)

    async def join(self, topic: str) -> None:
        """