diff --git a/gossip/src/crds.rs b/gossip/src/crds.rs index b3b94b4f8b8a84..bd42292a90514e 100644 --- a/gossip/src/crds.rs +++ b/gossip/src/crds.rs @@ -670,7 +670,7 @@ impl Default for CrdsDataStats { } impl CrdsDataStats { - fn record_insert(&mut self, entry: &VersionedCrdsValue) { + fn record_insert(&mut self, entry: &VersionedCrdsValue, route: GossipRoute) { self.counts[Self::ordinal(entry)] += 1; if let CrdsData::Vote(_, vote) = &entry.value.data { if let Some(slot) = vote.slot() { @@ -679,7 +679,9 @@ impl CrdsDataStats { } } - if should_report_message_signature(&entry.value.signature) { + if matches!(route, GossipRoute::PushMessage) + && should_report_message_signature(&entry.value.signature) + { datapoint_info!( "gossip_crds_sample", ( @@ -724,8 +726,8 @@ impl CrdsStats { match route { GossipRoute::LocalMessage => (), GossipRoute::PullRequest => (), - GossipRoute::PushMessage => self.push.record_insert(entry), - GossipRoute::PullResponse => self.pull.record_insert(entry), + GossipRoute::PushMessage => self.push.record_insert(entry, route), + GossipRoute::PullResponse => self.pull.record_insert(entry, route), } }