From b7b0e5dd1ea45995cf8e3ab6da808829d45a0956 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 | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/libp2p/protocols/pubsub/pubsubpeer.nim b/libp2p/protocols/pubsub/pubsubpeer.nim index 58100961b4..5c1cad6b16 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,8 @@ 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: + when defined(libp2p_expensive_metrics): + libp2p_gossipsub_non_priority_msgs_dropped.inc(labelValues = [$p.peerId]) continue await p.sendMsg(ttlMsg.msg)