From 313fed375cd1ff631ac1511cf444cf1aeeda0e81 Mon Sep 17 00:00:00 2001 From: Stephen Akridge Date: Thu, 19 Jul 2018 15:38:35 -0700 Subject: [PATCH] Add counter for tx count and limit error messages --- src/bank.rs | 9 ++++++++- src/banking_stage.rs | 5 +++++ 2 files changed, 13 insertions(+), 1 deletion(-) diff --git a/src/bank.rs b/src/bank.rs index f4a85d17fc..e41b3488a0 100644 --- a/src/bank.rs +++ b/src/bank.rs @@ -307,13 +307,20 @@ impl Bank { ); let mut tx_count = 0; + let mut err_count = 0; for r in &res { if r.is_ok() { tx_count += 1; } else { - info!("tx error: {:?}", r); + if err_count == 0 { + info!("tx error: {:?}", r); + } + err_count += 1; } } + if err_count > 0 { + info!("{} errors of {} txs", err_count, err_count + tx_count); + } self.transaction_count .fetch_add(tx_count, Ordering::Relaxed); res diff --git a/src/banking_stage.rs b/src/banking_stage.rs index a0bf61984e..f3d976b109 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -88,6 +88,7 @@ impl BankingStage { timing::duration_as_ms(&recv_start.elapsed()), mms.len(), ); + let bank_starting_tx_count = bank.transaction_count(); let count = mms.iter().map(|x| x.1.len()).sum(); let proc_start = Instant::now(); for (msgs, vers) in mms { @@ -125,6 +126,10 @@ impl BankingStage { (reqs_len as f32) / (total_time_s) ); inc_new_counter!("banking_stage-process_packets", count); + inc_new_counter!( + "banking_stage-process_transactions", + bank.transaction_count() - bank_starting_tx_count + ); Ok(()) } }