From 49abef7e1e3cec440646115991b548d86e81260e Mon Sep 17 00:00:00 2001 From: Dr Washington Sanchez Date: Sun, 5 Apr 2020 21:44:13 +1000 Subject: [PATCH] tweak: Extend ticker time for push nodes --- net/retriever/retriever.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/net/retriever/retriever.go b/net/retriever/retriever.go index 97932faf57..a124d9c616 100644 --- a/net/retriever/retriever.go +++ b/net/retriever/retriever.go @@ -115,7 +115,7 @@ func NewMessageRetriever(cfg MRConfig) *MessageRetriever { func (m *MessageRetriever) Run() { dht := time.NewTicker(time.Second * 60) - peers := time.NewTicker(time.Second * 10) + peers := time.NewTicker(time.Second * 60) defer dht.Stop() defer peers.Stop() go m.fetchPointersFromPushNodes() @@ -237,7 +237,7 @@ func (m *MessageRetriever) getPointersFromDataPeersRoutine(peerOut chan ps.PeerI defer wg.Done() ctx, cancel := context.WithTimeout(context.Background(), time.Second*35) defer cancel() - time.Sleep(time.Second*15) + time.Sleep(time.Second * 15) provs, err := ipfs.GetPointersFromPeer(m.routing, ctx, pid, &k) if err != nil { log.Errorf("Could not get pointers from push node because: %v", err)