From 5006b79203ab5e6d089ed748be0068162f1b8f50 Mon Sep 17 00:00:00 2001 From: Diego Date: Wed, 31 Jan 2024 23:59:05 +0100 Subject: [PATCH] add metric --- libp2p/protocols/pubsub/pubsubpeer.nim | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/libp2p/protocols/pubsub/pubsubpeer.nim b/libp2p/protocols/pubsub/pubsubpeer.nim index 58100961b4..bc0013c45e 100644 --- a/libp2p/protocols/pubsub/pubsubpeer.nim +++ b/libp2p/protocols/pubsub/pubsubpeer.nim @@ -35,6 +35,9 @@ when defined(libp2p_expensive_metrics): declareGauge(libp2p_gossipsub_priority_queue_size, "the number of messages in the priority queue", labels = ["id"]) declareGauge(libp2p_gossipsub_non_priority_queue_size, "the number of messages in the non-priority queue", labels = ["id"]) + declareCounter(libp2p_gossipsub_non_priority_msgs_dropped, "the number of dropped messages in the non-priority queue", labels = ["id"]) + + type PeerRateLimitError* = object of CatchableError @@ -383,6 +386,7 @@ proc sendNonPriorityTask(p: PubSubPeer) {.async.} = when defined(libp2p_expensive_metrics): libp2p_gossipsub_non_priority_queue_size.dec(labelValues = [$p.peerId]) if Moment.now() - ttlMsg.ttl >= p.rpcmessagequeue.maxDurationInNonPriorityQueue: + libp2p_gossipsub_non_priority_msgs_dropped.inc(labelValues = [$p.peerId]) continue await p.sendMsg(ttlMsg.msg)