We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 362c94b commit 4158849Copy full SHA for 4158849
libp2p/protocols/pubsub/pubsubpeer.nim
@@ -370,10 +370,10 @@ proc clearSendPriorityQueue(p: PubSubPeer) =
370
371
proc sendNonPriorityTask(p: PubSubPeer) {.async.} =
372
while true:
373
- let msg = await p.rpcmessagequeue.nonPriorityQueue.popFirst()
374
while p.rpcmessagequeue.sendPriorityQueue.len > 0:
375
await p.rpcmessagequeue.sendPriorityQueue[0]
376
p.clearSendPriorityQueue()
+ let msg = await p.rpcmessagequeue.nonPriorityQueue.popFirst()
377
when defined(libp2p_expensive_metrics):
378
libp2p_gossipsub_non_priority_queue_size.dec(labelValues = [$p.peerId])
379
await p.sendMsg(msg)
0 commit comments