gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-03-21 05:44:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

More gossipsub metrics (#6873)

Browse Source 
N/A


  Add metrics that tell us if a duplicate message that we received was from a mesh peer or from a non mesh peer that we requested with iwant message.
This commit is contained in:
Pawan Dhananjay
2025-01-29 11:42:10 -08:00
committed by GitHub
parent 6973184b06
commit e7ea69647a
3 changed files with 63 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
beacon_node/lighthouse_network/gossipsub/src/metrics.rs
View File

@@ -194,6 +194,12 @@ pub(crate) struct Metrics {
/// Number of full messages we received that we previously sent a IDONTWANT for.
idontwant_messages_ignored_per_topic: Family<TopicHash, Counter>,
/// Count of duplicate messages we have received from mesh peers for a given topic.
mesh_duplicates: Family<TopicHash, Counter>,
/// Count of duplicate messages we have received from by requesting them over iwant for a given topic.
iwant_duplicates: Family<TopicHash, Counter>,
/// The size of the priority queue.
priority_queue_size: Histogram,
/// The size of the non-priority queue.
@@ -359,6 +365,16 @@ impl Metrics {
"IDONTWANT messages that were sent but we received the full message regardless"
);
let mesh_duplicates = register_family!(
"mesh_duplicates_per_topic",
"Count of duplicate messages received from mesh peers per topic"
);
let iwant_duplicates = register_family!(
"iwant_duplicates_per_topic",
"Count of duplicate messages received from non-mesh peers that we sent iwants for"
);
let idontwant_bytes = {
let metric = Counter::default();
registry.register(
@@ -425,6 +441,8 @@ impl Metrics {
idontwant_msgs_ids,
idontwant_messages_sent_per_topic,
idontwant_messages_ignored_per_topic,
mesh_duplicates,
iwant_duplicates,
priority_queue_size,
non_priority_queue_size,
}
@@ -597,6 +615,20 @@ impl Metrics {
}
}
/// Register a duplicate message received from a mesh peer.
pub(crate) fn mesh_duplicates(&mut self, topic: &TopicHash) {
if self.register_topic(topic).is_ok() {
self.mesh_duplicates.get_or_create(topic).inc();
}
}
/// Register a duplicate message received from a non-mesh peer on an iwant request.
pub(crate) fn iwant_duplicates(&mut self, topic: &TopicHash) {
if self.register_topic(topic).is_ok() {
self.iwant_duplicates.get_or_create(topic).inc();
}
}
pub(crate) fn register_msg_validation(
&mut self,
topic: &TopicHash,