fix: don't freeze peers

application-research · Jan 24, 2023 · d6c4231 · d6c4231
1 parent 84f09c6
commit d6c4231
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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)