gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

adds more metrics for tx counts and batch sizes (#15642) (#15645)

Browse Source 
(cherry picked from commit 0bd0084b0d)

Co-authored-by: behzad nouri <behzadnouri@gmail.com>
This commit is contained in:
mergify[bot]
2021-03-03 01:36:09 +00:00
committed by GitHub
parent 247fa529b0
commit 211a42fb98
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/banking_stage.rs
View File

@ -490,6 +490,7 @@ impl BankingStage {
debug!("num_to_commit: {} ", num_to_commit); debug!("num_to_commit: {} ", num_to_commit);
// unlock all the accounts with errors which are filtered by the above `filter_map` // unlock all the accounts with errors which are filtered by the above `filter_map`
if !processed_transactions.is_empty() { if !processed_transactions.is_empty() {
inc_new_counter_info!("banking_stage-record_count", 1);
inc_new_counter_info!("banking_stage-record_transactions", num_to_commit); inc_new_counter_info!("banking_stage-record_transactions", num_to_commit);
let mut hash_time = Measure::start("record::hash"); let mut hash_time = Measure::start("record::hash");
@ -506,6 +507,11 @@ impl BankingStage {
match res { match res {
Ok(()) => (), Ok(()) => (),
Err(PohRecorderError::MaxHeightReached) => { Err(PohRecorderError::MaxHeightReached) => {
inc_new_counter_info!("banking_stage-max_height_reached", 1);
inc_new_counter_info!(
"banking_stage-max_height_reached_num_to_commit",
num_to_commit
);
// If record errors, add all the committable transactions (the ones // If record errors, add all the committable transactions (the ones
// we just attempted to record) as retryable // we just attempted to record) as retryable
return ( return (
@ -571,6 +577,14 @@ impl BankingStage {
let mut record_time = Measure::start("record_time"); let mut record_time = Measure::start("record_time");
let (num_to_commit, retryable_record_txs) = let (num_to_commit, retryable_record_txs) =
Self::record_transactions(bank.slot(), txs, &results, poh); Self::record_transactions(bank.slot(), txs, &results, poh);
inc_new_counter_info!(
"banking_stage-record_transactions_num_to_commit",
*num_to_commit.as_ref().unwrap_or(&0)
);
inc_new_counter_info!(
"banking_stage-record_transactions_retryable_record_txs",
retryable_record_txs.len()
);
retryable_txs.extend(retryable_record_txs); retryable_txs.extend(retryable_record_txs);
if num_to_commit.is_err() { if num_to_commit.is_err() {
return (num_to_commit, retryable_txs); return (num_to_commit, retryable_txs);