status-im/go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add slack time to prune backoff clearance

Browse Source
This commit is contained in:
vyzo 2020-08-10 13:42:22 +03:00
parent df9592859d
commit f2c25c2228
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gossipsub.go
View File

@ -118,6 +118,10 @@ var (
// before attempting to re-graft. // before attempting to re-graft.
GossipSubPruneBackoff = time.Minute GossipSubPruneBackoff = time.Minute
// GossipSubPruneBackoffSlack is the slack time after expiry of a backoff and before
// attempting a GRAFT.
GossipSubPruneBackoffSlack = time.Second
// GossipSubConnectors controls the number of active connection attempts for peers obtained through PX. // GossipSubConnectors controls the number of active connection attempts for peers obtained through PX.
GossipSubConnectors = 8 GossipSubConnectors = 8
@ -1497,7 +1501,7 @@ func (gs *GossipSubRouter) clearBackoff() {
return return
} }
now := time.Now() now := time.Now().Add(GossipSubPruneBackoffSlack)
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) { if expire.Before(now) {