logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-04 13:53:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

clear peerPromises map when fullfilling a promise

Browse Source
This commit is contained in:
vyzo 2021-10-29 11:42:20 +03:00
parent cee11bb0e4
commit 85a1f01869
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
gossip_tracer.go
View File

@ -118,11 +118,19 @@ var _ RawTracer = (*gossipTracer)(nil)
func (gt *gossipTracer) fulfillPromise(msg *Message) {
mid := gt.msgID(msg.Message)
p := msg.ReceivedFrom
gt.Lock()
defer gt.Unlock()
delete(gt.promises, mid)
peerPromises, ok := gt.peerPromises[p]
if ok {
delete(peerPromises, mid)
if len(peerPromises) == 0 {
delete(gt.peerPromises, p)
}
}
}
func (gt *gossipTracer) DeliverMessage(msg *Message) {