From 36d9ec7e4819cd0564a38fde7deeb6a89db50f8c Mon Sep 17 00:00:00 2001
From: Diego <diego@status.im>
Date: Thu, 25 Jan 2024 13:48:34 +0100
Subject: [PATCH] add logs for processMessages task

---
 libp2p/protocols/pubsub/pubsubpeer.nim | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/libp2p/protocols/pubsub/pubsubpeer.nim b/libp2p/protocols/pubsub/pubsubpeer.nim
index eef69fc07..2785fd03f 100644
--- a/libp2p/protocols/pubsub/pubsubpeer.nim
+++ b/libp2p/protocols/pubsub/pubsubpeer.nim
@@ -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()