anza-xyz-agave/accounts-db/benches/bench_lock_accounts.rs

use {
    criterion::{black_box, criterion_group, criterion_main, Criterion, Throughput},
    itertools::iproduct,
    solana_accounts_db::{accounts::Accounts, accounts_db::AccountsDb},
    solana_instruction::{AccountMeta, Instruction},
    solana_pubkey::Pubkey,
    solana_sdk_ids::system_program,
    solana_transaction::{
        sanitized::{SanitizedTransaction, MAX_TX_ACCOUNT_LOCKS},
        Transaction,
    },
    std::sync::Arc,
};

#[cfg(not(any(target_env = "msvc", target_os = "freebsd")))]
#[global_allocator]
static GLOBAL: jemallocator::Jemalloc = jemallocator::Jemalloc;

// simultaneous transactions locked
const BATCH_SIZES: [usize; 3] = [1, 32, 64];

// locks acquired per transaction
const LOCK_COUNTS: [usize; 2] = [2, 64];

// total transactions per run
const TOTAL_TRANSACTIONS: usize = 1024;

fn create_test_transactions(lock_count: usize, read_conflicts: bool) -> Vec<SanitizedTransaction> {
    // keys available to be shared between transactions, depending on mode
    // currently, we test batches with no conflicts and batches with reader/reader conflicts
    // in the future with SIMD83, we will also test reader/writer and writer/writer conflicts
    let shared_pubkeys: Vec<_> = (0..lock_count).map(|_| Pubkey::new_unique()).collect();
    let mut transactions = vec![];

    for _ in 0..TOTAL_TRANSACTIONS {
        let mut account_metas = vec![];

        #[allow(clippy::needless_range_loop)]
        for i in 0..lock_count {
            // `lock_accounts()` distinguishes writable from readonly, so give transactions an even split
            // signer doesn't matter for locking but `sanitize()` expects to see at least one
            let account_meta = if i == 0 {
                AccountMeta::new(Pubkey::new_unique(), true)
            } else if i % 2 == 0 {
                AccountMeta::new(Pubkey::new_unique(), false)
            } else if read_conflicts {
                AccountMeta::new_readonly(shared_pubkeys[i], false)
            } else {
                AccountMeta::new_readonly(Pubkey::new_unique(), false)
            };

            account_metas.push(account_meta);
        }

        let instruction = Instruction::new_with_bincode(system_program::id(), &(), account_metas);
        let transaction = Transaction::new_with_payer(&[instruction], None);

        transactions.push(SanitizedTransaction::from_transaction_for_tests(
            transaction,
        ));
    }

    transactions
}

fn bench_entry_lock_accounts(c: &mut Criterion) {
    let mut group = c.benchmark_group("bench_lock_accounts");

    for (batch_size, lock_count, read_conflicts, relax_intrabatch_account_locks) in
        iproduct!(BATCH_SIZES, LOCK_COUNTS, [false, true], [false, true])
    {
        let name = format!(
            "batch_size_{batch_size}_locks_count_{lock_count}{}{}",
            if read_conflicts {
                "_read_conflicts"
            } else {
                ""
            },
            if relax_intrabatch_account_locks {
                "_simd83"
            } else {
                "_old"
            },
        );

        let accounts_db = AccountsDb::new_single_for_tests();
        let accounts = Accounts::new(Arc::new(accounts_db));

        let transactions = create_test_transactions(lock_count, read_conflicts);
        group.throughput(Throughput::Elements(transactions.len() as u64));
        let transaction_batches: Vec<_> = transactions.chunks(batch_size).collect();
        let batch_results = vec![Ok(()); batch_size].into_iter();

        group.bench_function(name.as_str(), move |b| {
            b.iter(|| {
                for batch in &transaction_batches {
                    let results = accounts.lock_accounts(
                        black_box(batch.iter()),
                        batch_results.clone(),
                        MAX_TX_ACCOUNT_LOCKS,
                        relax_intrabatch_account_locks,
                    );
                    accounts.unlock_accounts(batch.iter().zip(&results));
                }
            })
        });
    }
}

criterion_group!(benches, bench_entry_lock_accounts);
criterion_main!(benches);