From 360f166f5af3f191722f6475a57b4ead5bdc3844 Mon Sep 17 00:00:00 2001
From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com>
Date: Sat, 14 Nov 2020 21:09:43 +0000
Subject: [PATCH] Add counter metrics to rpc-subscriptions (#13596) (#13598)

(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 7c38833aa1..fa5438af50 100644
--- a/core/src/rpc_subscriptions.rs
+++ b/core/src/rpc_subscriptions.rs
@@ -772,6 +772,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);
                         }
                     }
@@ -782,6 +783,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(),
@@ -796,6 +798,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);
                         }
                     }
@@ -936,6 +939,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),