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

Add counter metrics to rpc-subscriptions (#13596) (#13597)

Browse Source 
(cherry picked from commit 88ae321d3f)

Co-authored-by: Tyera Eulberg <teulberg@gmail.com>
This commit is contained in:
mergify[bot]
2020-11-14 20:53:38 +00:00
committed by GitHub
parent 41eab22117
commit 965e6dfc9a
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/rpc_subscriptions.rs
View File

@ -777,6 +777,7 @@ impl RpcSubscriptions {
debug!("slot notify: {:?}", slot_info); debug!("slot notify: {:?}", slot_info);
let subscriptions = subscriptions.slot_subscriptions.read().unwrap(); let subscriptions = subscriptions.slot_subscriptions.read().unwrap();
for (_, sink) in subscriptions.iter() { for (_, sink) in subscriptions.iter() {
inc_new_counter_info!("rpc-subscription-notify-slot", 1);
notifier.notify(slot_info, sink); notifier.notify(slot_info, sink);
} }
} }
@ -787,6 +788,7 @@ impl RpcSubscriptions {
debug!("vote notify: {:?}", vote_info); debug!("vote notify: {:?}", vote_info);
let subscriptions = subscriptions.vote_subscriptions.read().unwrap(); let subscriptions = subscriptions.vote_subscriptions.read().unwrap();
for (_, sink) in subscriptions.iter() { for (_, sink) in subscriptions.iter() {
inc_new_counter_info!("rpc-subscription-notify-vote", 1);
notifier.notify( notifier.notify(
RpcVote { RpcVote {
slots: vote_info.slots.clone(), slots: vote_info.slots.clone(),
@ -801,6 +803,7 @@ impl RpcSubscriptions {
debug!("root notify: {:?}", root); debug!("root notify: {:?}", root);
let subscriptions = subscriptions.root_subscriptions.read().unwrap(); let subscriptions = subscriptions.root_subscriptions.read().unwrap();
for (_, sink) in subscriptions.iter() { for (_, sink) in subscriptions.iter() {
inc_new_counter_info!("rpc-subscription-notify-root", 1);
notifier.notify(root, sink); notifier.notify(root, sink);
} }
} }
@ -941,6 +944,7 @@ impl RpcSubscriptions {
num_signatures_notified, num_signatures_notified,
signatures_time, signatures_time,
); );
inc_new_counter_info!("rpc-subscription-notify-bank-or-gossip", total_notified);
datapoint_info!( datapoint_info!(
"rpc_subscriptions", "rpc_subscriptions",
("source", source.to_string(), String), ("source", source.to_string(), String),