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

add logs for processMessages task

Browse Source
This commit is contained in:
Diego 2024-01-25 13:48:34 +01:00
parent 878362b03f
commit 36d9ec7e48
No known key found for this signature in database
GPG Key ID: C9DAC9BF68D1F806
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -387,11 +387,13 @@ proc processMessages(p: PubSubPeer) {.async.} =
await sendMsg(message)
proc startProcessingMessages(p: PubSubPeer) =
debug "starting processing messages", p
if p.rpcmessagequeue.queueProcessingTask.isNil:
p.rpcmessagequeue.queueProcessingTask = p.processMessages()
proc stopProcessingMessages*(p: PubSubPeer) =
if not p.rpcmessagequeue.queueProcessingTask.isNil:
debug "stopping processing messages", p
p.rpcmessagequeue.queueProcessingTask.cancel()
p.rpcmessagequeue.queueProcessingTask = nil
p.rpcmessagequeue.priorityQueue.clear()