status-im/nim-libp2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-libp2p.git synced 2025-02-22 09:38:18 +00:00
Code Issues Projects Releases Wiki Activity

increase maxDurationInNonPriorityQueue to 1s

Browse Source
This commit is contained in:
Diego 2024-02-01 00:14:06 +01:00
parent 0d0ef3519f
commit f6775d2843
No known key found for this signature in database
GPG Key ID: C9DAC9BF68D1F806
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/protocols/pubsub/pubsubpeer.nim
View File

@ -417,7 +417,7 @@ proc stopSendNonPriorityTask*(p: PubSubPeer) =
libp2p_gossipsub_priority_queue_size.set(labelValues = [$p.peerId], value = 0)
libp2p_gossipsub_non_priority_queue_size.set(labelValues = [$p.peerId], value = 0)
proc new(T: typedesc[RpcMessageQueue], maxDurationInNonPriorityQueue = 500.milliseconds): T =
proc new(T: typedesc[RpcMessageQueue], maxDurationInNonPriorityQueue = 1.seconds): T =
return T(
sendPriorityQueue: initDeque[Future[void]](),
nonPriorityQueue: newAsyncQueue[Ttlmessage](),