From 6cfbf2c124f5f4ae83ff081cc40834e1d4424aff Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Wed, 2 Oct 2019 15:43:00 -0600 Subject: [PATCH] don't send messages to self --- libp2p/protocols/pubsub/floodsub.nim | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/libp2p/protocols/pubsub/floodsub.nim b/libp2p/protocols/pubsub/floodsub.nim index 7d5bf3d..b9b65da 100644 --- a/libp2p/protocols/pubsub/floodsub.nim +++ b/libp2p/protocols/pubsub/floodsub.nim @@ -69,6 +69,7 @@ proc rpcHandler(f: FloodSub, # send subscriptions to every peer for p in f.peers.values: + # if p.id != peer.id: await p.send(@[RPCMsg(subscriptions: m.subscriptions)]) var toSendPeers: HashSet[string] = initSet[string]() @@ -82,7 +83,8 @@ proc rpcHandler(f: FloodSub, # forward the message to all peers interested in it for p in toSendPeers: - await f.peers[p].send(@[RPCMsg(messages: m.messages)]) + if f.peers[p].id != peer.id: + await f.peers[p].send(@[RPCMsg(messages: m.messages)]) proc handleConn(f: FloodSub, conn: Connection) {.async, gcsafe.} =