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

Commit f1f154a

Browse files
committed
tweak: Increase offline message scanning frequency + reduce timeout ctx
1 parent e7e1f3a commit f1f154a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

net/retriever/retriever.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ func NewMessageRetriever(cfg MRConfig) *MessageRetriever {
9797

9898
func (m *MessageRetriever) Run() {
9999
dht := time.NewTicker(time.Hour)
100-
peers := time.NewTicker(time.Minute * 10)
100+
peers := time.NewTicker(time.Second * 10)
101101
defer dht.Stop()
102102
defer peers.Stop()
103103
go m.fetchPointersFromDHT()
@@ -243,7 +243,7 @@ func (m *MessageRetriever) fetchIPFS(pid peer.ID, n *core.IpfsNode, addr ma.Mult
243243
var err error
244244

245245
go func() {
246-
ciphertext, err = ipfs.Cat(n, addr.String(), time.Minute*5)
246+
ciphertext, err = ipfs.Cat(n, addr.String(), time.Second*5)
247247
c <- struct{}{}
248248
}()
249249

0 commit comments

Comments
 (0)