Skip to content
This repository was archived by the owner on Mar 28, 2023. It is now read-only.

Commit 082d7a0

Browse files
committed
tweak: Extend ticker time for push nodes
1 parent 574cbc9 commit 082d7a0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: net/retriever/retriever.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ func NewMessageRetriever(cfg MRConfig) *MessageRetriever {
115115

116116
func (m *MessageRetriever) Run() {
117117
dht := time.NewTicker(time.Second * 60)
118-
peers := time.NewTicker(time.Second * 10)
118+
peers := time.NewTicker(time.Second * 60)
119119
defer dht.Stop()
120120
defer peers.Stop()
121121
go m.fetchPointersFromPushNodes()
@@ -237,7 +237,7 @@ func (m *MessageRetriever) getPointersFromDataPeersRoutine(peerOut chan ps.PeerI
237237
defer wg.Done()
238238
ctx, cancel := context.WithTimeout(context.Background(), time.Second*35)
239239
defer cancel()
240-
time.Sleep(time.Second*15)
240+
time.Sleep(time.Second * 15)
241241
provs, err := ipfs.GetPointersFromPeer(m.routing, ctx, pid, &k)
242242
if err != nil {
243243
log.Errorf("Could not get pointers from push node because: %v", err)

0 commit comments

Comments
 (0)