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

backoff grafting to peers that have pruned us

Browse Source
This commit is contained in:
vyzo 2019-11-22 20:46:13 +02:00
parent 6b80c4078d
commit 85b455fa50
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
gossipsub.go
View File

@ -373,6 +373,15 @@ func (gs *GossipSubRouter) connector() {
} }
} }
func (gs *GossipSubRouter) addBackoff(p peer.ID, topic string) {
backoff, ok := gs.backoff[topic]
if !ok {
backoff = make(map[peer.ID]time.Time)
gs.backoff[topic] = backoff
}
backoff[p] = time.Now().Add(GossipSubPruneBackoff)
}
func (gs *GossipSubRouter) Publish(from peer.ID, msg *pb.Message) { func (gs *GossipSubRouter) Publish(from peer.ID, msg *pb.Message) {
gs.mcache.Put(msg) gs.mcache.Put(msg)