From de2aa898a72bcd02c6c399d0540c9ad76fc39fac Mon Sep 17 00:00:00 2001
From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com>
Date: Fri, 22 Oct 2021 05:03:26 +0000
Subject: [PATCH] Add counter for new transactions in SendTransactionService
 (#20852) (#20859)

* Add counter for inserted transactions

* Add counter for tx recv

(cherry picked from commit 8959d5e21ce3ae9e50cc59ae1e0b7b227b4eaba8)

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

diff --git a/rpc/src/send_transaction_service.rs b/rpc/src/send_transaction_service.rs
index 03df7195cf..0e72a9f41b 100644
--- a/rpc/src/send_transaction_service.rs
+++ b/rpc/src/send_transaction_service.rs
@@ -190,6 +190,7 @@ impl SendTransactionService {
                     Err(RecvTimeoutError::Disconnected) => break,
                     Err(RecvTimeoutError::Timeout) => {}
                     Ok(transaction_info) => {
+                        inc_new_counter_info!("send_transaction_service-recv-tx", 1);
                         let addresses = leader_info.as_ref().map(|leader_info| {
                             leader_info.get_leader_tpus(config.leader_forward_count)
                         });
@@ -210,6 +211,7 @@ impl SendTransactionService {
                             );
                         }
                         if transactions.len() < MAX_TRANSACTION_QUEUE_SIZE {
+                            inc_new_counter_info!("send_transaction_service-insert-tx", 1);
                             transactions.insert(transaction_info.signature, transaction_info);
                         } else {
                             datapoint_warn!("send_transaction_service-queue-overflow");