From 965e6dfc9a08d6bd36d5dd2173135b237617e442 Mon Sep 17 00:00:00 2001
From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com>
Date: Sat, 14 Nov 2020 20:53:38 +0000
Subject: [PATCH] Add counter metrics to rpc-subscriptions (#13596) (#13597)

(cherry picked from commit 88ae321d3fd1e22910552a48ec4557084a879dd1)

Co-authored-by: Tyera Eulberg <teulberg@gmail.com>
---
 core/src/rpc_subscriptions.rs | 4 ++++
 1 file changed, 4 insertions(+)

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