diff --git a/core/src/banking_stage.rs b/core/src/banking_stage.rs index 496ac991e2f31e..f55b7b3d47f84c 100644 --- a/core/src/banking_stage.rs +++ b/core/src/banking_stage.rs @@ -988,13 +988,11 @@ impl BankingStage { }; } - let sanitized_txs = batch.sanitized_transactions(); let (commit_time_us, commit_transaction_statuses) = if executed_transactions_count != 0 { Committer::commit_transactions( batch, &mut loaded_transactions, execution_results, - sanitized_txs, starting_transaction_index, bank, &mut pre_balance_info, @@ -1021,7 +1019,7 @@ impl BankingStage { load_execute_time.as_us(), record_time.as_us(), commit_time_us, - sanitized_txs.len(), + batch.sanitized_transactions().len(), ); debug!( diff --git a/core/src/banking_stage/committer.rs b/core/src/banking_stage/committer.rs index b2cf27f1052dc9..4791730e702ff5 100644 --- a/core/src/banking_stage/committer.rs +++ b/core/src/banking_stage/committer.rs @@ -15,7 +15,7 @@ use { transaction_batch::TransactionBatch, vote_sender_types::ReplayVoteSender, }, - solana_sdk::{saturating_add_assign, transaction::SanitizedTransaction}, + solana_sdk::saturating_add_assign, solana_transaction_status::token_balances::TransactionTokenBalancesSet, std::sync::Arc, }; @@ -34,7 +34,6 @@ impl Committer { batch: &TransactionBatch, loaded_transactions: &mut [TransactionLoadResult], execution_results: Vec, - sanitized_txs: &[SanitizedTransaction], starting_transaction_index: Option, bank: &Arc, pre_balance_info: &mut PreBalanceInfo, @@ -55,7 +54,7 @@ impl Committer { bank.last_blockhash_and_lamports_per_signature(); let (tx_results, commit_time_us) = measure_us!(bank.commit_transactions( - sanitized_txs, + batch.sanitized_transactions(), loaded_transactions, execution_results, last_blockhash, @@ -84,7 +83,11 @@ impl Committer { .collect(); let (_, find_and_send_votes_us) = measure_us!({ - bank_utils::find_and_send_votes(sanitized_txs, &tx_results, Some(replay_vote_sender)); + bank_utils::find_and_send_votes( + batch.sanitized_transactions(), + &tx_results, + Some(replay_vote_sender), + ); Self::collect_balances_and_send_status_batch( transaction_status_sender, tx_results,