Skip to content

Commit 0eeef5d

Browse files
committed
fix: don't freeze peers, we never thaw so they get lost
1 parent ff65876 commit 0eeef5d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

bitswap/provider.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -125,9 +125,9 @@ func NewProvider(
125125
network: network.NewFromIpfsHost(host, routing),
126126
blockManager: blockManager,
127127
retriever: retriever,
128-
requestQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})),
129-
responseQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})),
130-
retrievalQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})),
128+
requestQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)),
129+
responseQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)),
130+
retrievalQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)),
131131
}
132132

133133
provider.network.Start(provider)

0 commit comments

Comments
 (0)