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)