status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-01-20 18:00:04 +00:00
Code Issues Projects Releases Wiki Activity

triage publish nil peers (issue is on master too but just hidden behind a if/in)

Browse Source
This commit is contained in:
Giovanni Petrantoni 2020-07-01 16:54:28 +09:00
parent f49e59cb4e
commit a976c22dae
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libp2p/protocols/pubsub/gossipsub.nim
View File

@ -499,9 +499,18 @@ method publish*(g: GossipSub,
continue
let peer = g.peers.getOrDefault(p)
if not isNil(peer.peerInfo):
if not isNil(peer) and not isNil(peer.peerInfo):
trace "publish: sending message to peer", peer = p
sent.add(peer.send(@[RPCMsg(messages: @[msg])]))
else:
# Notice this needs a better fix! for now it's a hack
error "publish: peer or peerInfo was nil"
if topic in g.mesh:
g.mesh[topic].excl(p)
if topic in g.fanout:
g.fanout[topic].excl(p)
if topic in g.gossipsub:
g.gossipsub[topic].excl(p)
sent = await allFinished(sent)
checkFutures(sent)