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

fix backoff slack time

Browse Source
This commit is contained in:
vyzo 2020-08-10 14:26:15 +03:00
parent 8c08ebaecb
commit 46536eccc4
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
gossipsub.go
View File

@ -1497,10 +1497,11 @@ func (gs *GossipSubRouter) clearBackoff() {
return return
} }
now := time.Now().Add(2 * GossipSubHeartbeatInterval) now := time.Now()
for topic, backoff := range gs.backoff { for topic, backoff := range gs.backoff {
for p, expire := range backoff { for p, expire := range backoff {
if expire.Before(now) { // add some slack time to the expiration
if expire.Add(2 * GossipSubHeartbeatInterval).Before(now) {
delete(backoff, p) delete(backoff, p)
} }
} }