We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fe7d267 commit 620b386Copy full SHA for 620b386
libp2p/protocols/pubsub/pubsubpeer.nim
@@ -407,7 +407,7 @@ proc stopSendNonPriorityTask*(p: PubSubPeer) =
407
libp2p_gossipsub_priority_queue_size.set(labelValues = [$p.peerId], value = 0)
408
libp2p_gossipsub_non_priority_queue_size.set(labelValues = [$p.peerId], value = 0)
409
410
-proc new(T: typedesc[RpcMessageQueue], maxDurationInNonPriorityQueue = 500.milliseconds): T =
+proc new(T: typedesc[RpcMessageQueue], maxDurationInNonPriorityQueue = 1.seconds): T =
411
return T(
412
sendPriorityQueue: initDeque[Future[void]](),
413
nonPriorityQueue: newAsyncQueue[Ttlmessage](),
0 commit comments