Fix transaction count on testnet dashboard

This commit is contained in:
Pankaj Garg 2018-10-23 21:44:14 +00:00 committed by Greg Fitzgerald
parent 0aebbae909
commit a68c99d782
1 changed files with 3 additions and 4 deletions

View File

@ -251,6 +251,7 @@ impl BankingStage {
let bank_starting_tx_count = bank.transaction_count(); let bank_starting_tx_count = bank.transaction_count();
let count = mms.iter().map(|x| x.1.len()).sum(); let count = mms.iter().map(|x| x.1.len()).sum();
let proc_start = Instant::now(); let proc_start = Instant::now();
let mut new_tx_count = 0;
for (msgs, vers) in mms { for (msgs, vers) in mms {
let transactions = Self::deserialize_transactions(&msgs.read().unwrap()); let transactions = Self::deserialize_transactions(&msgs.read().unwrap());
reqs_len += transactions.len(); reqs_len += transactions.len();
@ -270,6 +271,7 @@ impl BankingStage {
}).collect(); }).collect();
debug!("verified transactions {}", transactions.len()); debug!("verified transactions {}", transactions.len());
Self::process_transactions(bank, &transactions, poh)?; Self::process_transactions(bank, &transactions, poh)?;
new_tx_count += transactions.len();
} }
inc_new_counter_info!( inc_new_counter_info!(
@ -287,10 +289,7 @@ impl BankingStage {
(reqs_len as f32) / (total_time_s) (reqs_len as f32) / (total_time_s)
); );
inc_new_counter_info!("banking_stage-process_packets", count); inc_new_counter_info!("banking_stage-process_packets", count);
inc_new_counter_info!( inc_new_counter_info!("banking_stage-process_transactions", new_tx_count);
"banking_stage-process_transactions",
bank.transaction_count() - bank_starting_tx_count
);
Ok(()) Ok(())
} }
} }