blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Clean up: banking_stage_prepare_sanitized_batch (#28841) 

Use measure! for bank.prepare_sanitized_batch_with_results
This commit is contained in:
apfitzge 2022-11-18 14:04:44 -06:00 committed by GitHub
parent c32377b5af
commit a636038fff
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/banking_stage.rs
View File

@ -1507,9 +1507,9 @@ impl BankingStage {
// Only lock accounts for those transactions are selected for the block; // Only lock accounts for those transactions are selected for the block;
// Once accounts are locked, other threads cannot encode transactions that will modify the // Once accounts are locked, other threads cannot encode transactions that will modify the
// same account state // same account state
let mut lock_time = Measure::start("lock_time"); let (batch, lock_time) = measure!(
let batch = bank.prepare_sanitized_batch_with_results(txs, transactions_qos_results.iter()); bank.prepare_sanitized_batch_with_results(txs, transactions_qos_results.iter())
lock_time.stop(); );
// retryable_txs includes AccountInUse, WouldExceedMaxBlockCostLimit // retryable_txs includes AccountInUse, WouldExceedMaxBlockCostLimit
// WouldExceedMaxAccountCostLimit, WouldExceedMaxVoteCostLimit // WouldExceedMaxAccountCostLimit, WouldExceedMaxVoteCostLimit
@ -1524,10 +1524,8 @@ impl BankingStage {
log_messages_bytes_limit, log_messages_bytes_limit,
); );
let mut unlock_time = Measure::start("unlock_time");
// Once the accounts are new transactions can enter the pipeline to process them // Once the accounts are new transactions can enter the pipeline to process them
drop(batch); let (_, unlock_time) = measure!(drop(batch));
unlock_time.stop();
let ExecuteAndCommitTransactionsOutput { let ExecuteAndCommitTransactionsOutput {
ref mut retryable_transaction_indexes, ref mut retryable_transaction_indexes,