From 8c08ebaecb02f7faee5d2e3b947ef31f304db696 Mon Sep 17 00:00:00 2001 From: vyzo Date: Mon, 10 Aug 2020 14:16:23 +0300 Subject: [PATCH] use the heartbeat interval for slack time --- gossipsub.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/gossipsub.go b/gossipsub.go index 33eeeac..7ebdacd 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -118,10 +118,6 @@ var ( // before attempting to re-graft. 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 = 8 @@ -1501,7 +1497,7 @@ func (gs *GossipSubRouter) clearBackoff() { return } - now := time.Now().Add(GossipSubPruneBackoffSlack) + now := time.Now().Add(2 * GossipSubHeartbeatInterval) for topic, backoff := range gs.backoff { for p, expire := range backoff { if expire.Before(now) {