gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add pull request count metrics (#10421)

Browse Source
This commit is contained in:
sakridge
2020-06-05 09:36:31 -07:00
committed by GitHub
parent 31e20eff82
commit 3d2230f1a9
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/cluster_info.rs
View File

@ -231,6 +231,7 @@ struct GossipStats {
epoch_slots_push: Counter, epoch_slots_push: Counter,
push_message: Counter, push_message: Counter,
new_pull_requests: Counter, new_pull_requests: Counter,
new_pull_requests_count: Counter,
mark_pull_request: Counter, mark_pull_request: Counter,
skip_pull_response_shred_version: Counter, skip_pull_response_shred_version: Counter,
skip_pull_shred_version: Counter, skip_pull_shred_version: Counter,
@ -1353,6 +1354,9 @@ impl ClusterInfo {
.collect() .collect()
}; };
self.append_entrypoint_to_pulls(&mut pulls); self.append_entrypoint_to_pulls(&mut pulls);
self.stats
.new_pull_requests_count
.add_relaxed(pulls.len() as u64);
pulls pulls
.into_iter() .into_iter()
.map(|(peer, filter, gossip, self_info)| { .map(|(peer, filter, gossip, self_info)| {
@ -2112,7 +2116,7 @@ impl ClusterInfo {
), ),
); );
datapoint_info!( datapoint_info!(
"cluster_info_shred_version_skip", "cluster_info_stats4",
( (
"skip_push_message_shred_version", "skip_push_message_shred_version",
self.stats.skip_push_message_shred_version.clear(), self.stats.skip_push_message_shred_version.clear(),
@ -2138,6 +2142,11 @@ impl ClusterInfo {
self.stats.push_message_value_count.clear(), self.stats.push_message_value_count.clear(),
i64 i64
), ),
(
"new_pull_requests_count",
self.stats.new_pull_requests_count.clear(),
i64
),
); );
*last_print = Instant::now(); *last_print = Instant::now();