From a4c5325665bc639cfe7abc38832e139c847f19a2 Mon Sep 17 00:00:00 2001 From: vyzo Date: Mon, 25 Nov 2019 13:58:29 +0200 Subject: [PATCH] make connection timeout a variable, set for 30s (instead of 10s) --- gossipsub.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/gossipsub.go b/gossipsub.go index 0e157d4..d07919c 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -46,6 +46,9 @@ var ( // number of active connection attempts for peers obtained through px GossipSubConnectors = 16 + + // timeout for connection attempts + GossipSubConnectionTimeout = 30 * time.Second ) // NewGossipSub returns a new PubSub object using GossipSubRouter as the router. @@ -341,7 +344,7 @@ func (gs *GossipSubRouter) connector() { gs.p.host.Peerstore().AddCertifiedAddrs(ci.srr, peerstore.TempAddrTTL) } - ctx, cancel := context.WithTimeout(gs.p.ctx, 10*time.Second) + ctx, cancel := context.WithTimeout(gs.p.ctx, GossipSubConnectionTimeout) err := gs.p.host.Connect(ctx, peer.AddrInfo{ID: ci.p}) cancel() if err != nil {