From 8814195cf532fd0a38d37d23feff0f182b51f6dc Mon Sep 17 00:00:00 2001 From: Rod Vagg Date: Wed, 25 Jan 2023 08:48:09 +1100 Subject: [PATCH] fix: don't freeze peers --- bitswap/provider.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/bitswap/provider.go b/bitswap/provider.go index 8c4f256..a084157 100644 --- a/bitswap/provider.go +++ b/bitswap/provider.go @@ -127,9 +127,9 @@ func NewProvider( network: network.NewFromIpfsHost(host, routing), blockManager: blockManager, retriever: retriever, - requestQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})), - responseQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})), - retrievalQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{})), + requestQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)), + responseQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)), + retrievalQueue: peertaskqueue.New(peertaskqueue.TaskMerger(&overwriteTaskMerger{}), peertaskqueue.IgnoreFreezing(true)), } provider.network.Start(provider)