vacp2p/nim-libp2p
1
0
Fork 0
mirror of https://github.com/vacp2p/nim-libp2p.git synced 2025-03-02 17:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

clean sendPriorityQueue even if there is no non-priority msg

Browse Source
This commit is contained in:
Diego 2024-01-31 12:13:54 +01:00
parent 362c94bf34
commit 4158849521
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

@ -370,10 +370,10 @@ proc clearSendPriorityQueue(p: PubSubPeer) =
proc sendNonPriorityTask(p: PubSubPeer) {.async.} =
while true:
let msg = await p.rpcmessagequeue.nonPriorityQueue.popFirst()
while p.rpcmessagequeue.sendPriorityQueue.len > 0:
await p.rpcmessagequeue.sendPriorityQueue[0]
p.clearSendPriorityQueue()
let msg = await p.rpcmessagequeue.nonPriorityQueue.popFirst()
when defined(libp2p_expensive_metrics):
libp2p_gossipsub_non_priority_queue_size.dec(labelValues = [$p.peerId])
await p.sendMsg(msg)