From 6a73bf767bf45ef61b0cf0b1b290db8327bfc4bb Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Thu, 7 Oct 2021 22:27:48 +0000 Subject: [PATCH] adds metrics for number of nodes vs number of pubkeys (backport #20512) (#20524) * adds metrics for number of nodes vs number of pubkeys (#20512) (cherry picked from commit 0da661de62d2028d799613e10c6a420b7edb87b2) # Conflicts: # gossip/src/cluster_info_metrics.rs * removes backport merge conflicts Co-authored-by: behzad nouri --- gossip/src/cluster_info_metrics.rs | 4 +++- gossip/src/crds.rs | 7 ++++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/gossip/src/cluster_info_metrics.rs b/gossip/src/cluster_info_metrics.rs index b3c228ed6f..054e48219d 100644 --- a/gossip/src/cluster_info_metrics.rs +++ b/gossip/src/cluster_info_metrics.rs @@ -163,11 +163,12 @@ pub(crate) fn submit_gossip_stats( gossip: &RwLock, stakes: &HashMap, ) { - let (table_size, num_nodes, purged_values_size, failed_inserts_size) = { + let (table_size, num_nodes, num_pubkeys, purged_values_size, failed_inserts_size) = { let gossip = gossip.read().unwrap(); ( gossip.crds.len(), gossip.crds.num_nodes(), + gossip.crds.num_pubkeys(), gossip.crds.num_purged(), gossip.pull.failed_inserts.len(), ) @@ -192,6 +193,7 @@ pub(crate) fn submit_gossip_stats( ("failed_inserts_size", failed_inserts_size as i64, i64), ("num_nodes", num_nodes as i64, i64), ("num_nodes_staked", num_nodes_staked as i64, i64), + ("num_pubkeys", num_pubkeys, i64), ); datapoint_info!( "cluster_info_stats2", diff --git a/gossip/src/crds.rs b/gossip/src/crds.rs index fcba2230c6..59bf942ded 100644 --- a/gossip/src/crds.rs +++ b/gossip/src/crds.rs @@ -319,8 +319,13 @@ impl Crds { .map(move |i| self.table.index(*i)) } - /// Returns number of known pubkeys (network size). + /// Returns number of known contact-infos (network size). pub(crate) fn num_nodes(&self) -> usize { + self.nodes.len() + } + + /// Returns number of unique pubkeys. + pub(crate) fn num_pubkeys(&self) -> usize { self.records.len() }