Struct AA2dPool 

pub struct AA2dPool {
    submission_id: u64,
    independent_transactions: HashMap<AASequenceId, PendingTransaction<CoinbaseTipOrdering<TempoPooledTransaction>>>,
    by_id: BTreeMap<AA2dTransactionId, AA2dInternalTransaction>,
    by_hash: HashMap<TxHash, Arc<ValidPoolTransaction<TempoPooledTransaction>>>,
    address_slots: HashMap<U256, (Address, U256)>,
    config: AA2dPoolConfig,
    metrics: AA2dPoolMetrics,
}

A sub-pool that keeps track of 2D nonce transactions.

It maintains both pending and queued transactions.

A 2d nonce transaction is pending if it dosn’t have a nonce gap for its nonce key, and is queued if its nonce key set has nonce gaps.

This pool relies on state changes to track the nonces.

Limitations

• We assume new AA transactions either create a new nonce key (nonce 0) or use an existing nonce key. To keep track of the known keys by accounts this pool relies on state changes to promote transactions to pending.

Fields

submission_id: u64

Keeps track of transactions inserted in the pool.

This way we can determine when transactions were submitted to the pool.

independent_transactions: HashMap<AASequenceId, PendingTransaction<CoinbaseTipOrdering<TempoPooledTransaction>>>

independent, pending, executable transactions, one per sequence id.

by_id: BTreeMap<AA2dTransactionId, AA2dInternalTransaction>

All transactions that are currently inside the pool grouped by their unique identifier.

by_hash: HashMap<TxHash, Arc<ValidPoolTransaction<TempoPooledTransaction>>>

All transactions by hash.

address_slots: HashMap<U256, (Address, U256)>

Reverse index for the storage slot of an account’s nonce

 mapping(address => mapping(uint256 => uint64)) public nonces

This identifies the account and nonce key based on the slot in the NonceManager.

config: AA2dPoolConfig

Settings for this sub-pool.

metrics: AA2dPoolMetrics

Metrics for tracking pool statistics

Implementations

impl AA2dPool

pub fn new(config: AA2dPoolConfig) -> Self

Creates a new instance with the givenconfig and nonce keys

fn update_metrics(&self)

Updates all metrics to reflect the current state of the pool

pub(crate) fn add_transaction( &mut self, transaction: Arc<ValidPoolTransaction<TempoPooledTransaction>>, on_chain_nonce: u64, ) -> PoolResult<AddedTransaction<TempoPooledTransaction>>

Entrypoint for adding a 2d AA transaction.

on_chain_nonce is expected to be the nonce of the sender at the time of validation. If transaction is using 2D nonces, this is expected to be the nonce corresponding to the transaction’s nonce key.

pub(crate) fn pending_and_queued_txn_count(&self) -> (usize, usize)

Returns how many pending and queued transactions are in the pool.

pub(crate) fn get_transactions_by_origin_iter( &self, origin: TransactionOrigin, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns all transactions that where submitted with the given [TransactionOrigin]

pub(crate) fn get_pending_transactions_by_origin_iter( &self, origin: TransactionOrigin, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns all transactions that where submitted with the given [TransactionOrigin]

pub(crate) fn get_transactions_by_sender_iter( &self, sender: Address, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns all transactions of the address

pub(crate) fn all_transaction_hashes_iter(&self) -> impl Iterator<Item = TxHash>

Returns an iterator over all transaction hashes in this pool

pub(crate) fn queued_transactions( &self, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns all transactions from that are queued.

pub(crate) fn pending_transactions( &self, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns all transactions that are pending.

pub(crate) fn best_transactions(&self) -> BestAA2dTransactions

Returns the best, executable transactions for this sub-pool

pub(crate) fn get( &self, tx_hash: &TxHash, ) -> Option<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns the transaction by hash.

pub(crate) fn get_all<'a, I>( &self, tx_hashes: I, ) -> Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

where I: Iterator<Item = &'a TxHash> + 'a,

Returns the transaction by hash.

pub(crate) fn get_all_iter<'a, I>( &'a self, tx_hashes: I, ) -> impl Iterator<Item = &'a Arc<ValidPoolTransaction<TempoPooledTransaction>>> + 'a

where I: IntoIterator<Item = &'a TxHash> + 'a,

Returns an iterator over all the matching transactions.

pub(crate) fn senders_iter(&self) -> impl Iterator<Item = &Address>

Returns an iterator over all senders in this pool.

fn descendant_txs_mut<'a, 'b: 'a>( &'a mut self, id: &'b AA2dTransactionId, ) -> impl Iterator<Item = (&'a AA2dTransactionId, &'a mut AA2dInternalTransaction)> + 'a

Returns all mutable transactions that follow after the given id but have the same sender.

NOTE: The range is inclusive: if the transaction that belongs to id it field be the first value.

fn descendant_txs_exclusive<'a, 'b: 'a>( &'a self, id: &'b AA2dTransactionId, ) -> impl Iterator<Item = (&'a AA2dTransactionId, &'a AA2dInternalTransaction)> + 'a

Returns all transactions that follow after the given id and have the same sender.

NOTE: The range is exclusive

fn remove_transaction_by_id( &mut self, id: &AA2dTransactionId, ) -> Option<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Removes the transaction with the given id from all sets.

This does not shift the independent transaction forward or mark descendants as pending.

fn remove_independent( &mut self, id: &AA2dTransactionId, ) -> Option<PendingTransaction<CoinbaseTipOrdering<TempoPooledTransaction>>>

Removes the independent transaction if it matches the given id.

pub(crate) fn remove_transactions<'a, I>( &mut self, tx_hashes: I, ) -> Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

where I: Iterator<Item = &'a TxHash> + 'a,

Removes the transaction by its hash from all internal sets.

fn remove_transaction_by_hash( &mut self, tx_hash: &B256, ) -> Option<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Removes the transaction by its hash from all internal sets.

This does not shift the independent transaction forward or mark descendants as pending.

pub(crate) fn remove_transactions_and_descendants<'a, I>( &mut self, hashes: I, ) -> Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

where I: Iterator<Item = &'a TxHash> + 'a,

Removes and returns all matching transactions and their dependent transactions from the pool.

pub(crate) fn remove_transactions_by_sender( &mut self, sender_id: Address, ) -> Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Removes all transactions from the given sender.

fn remove_descendants( &mut self, tx: &AA2dTransactionId, removed: &mut Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>, )

Removes only the descendants of the given transaction from this pool.

All removed transactions are added to the removed vec.

pub(crate) fn on_nonce_changes( &mut self, on_chain_ids: HashMap<AASequenceId, u64>, ) -> (Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>, Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>)

Updates the internal state based on the state changes of the NonceManager [NONCE_PRECOMPILE_ADDRESS].

This takes a vec of changed AASequenceId with their current on chain nonce.

This will prune mined transactions and promote unblocked transactions if any, returns (promoted, mined)

fn discard(&mut self) -> Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Removes stale transactions if the pool is above capacity.

pub fn metrics(&self) -> &AA2dPoolMetrics

Returns a reference to the metrics for this pool

pub(crate) fn contains(&self, tx_hash: &TxHash) -> bool

Returns true if the transaction with the given hash is already included in this pool.

pub(crate) fn pooled_transactions_hashes_iter( &self, ) -> impl Iterator<Item = TxHash>

Returns hashes of transactions in the pool that can be propagated.

pub(crate) fn pooled_transactions_iter( &self, ) -> impl Iterator<Item = Arc<ValidPoolTransaction<TempoPooledTransaction>>>

Returns transactions in the pool that can be propagated

const fn next_id(&mut self) -> u64

fn record_2d_slot(&mut self, transaction: &TempoPooledTransaction)

Caches the 2D nonce key slot for the given sender and nonce key.

pub(crate) fn on_state_updates( &mut self, state: &HashMap<Address, BundleAccount>, ) -> (Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>, Vec<Arc<ValidPoolTransaction<TempoPooledTransaction>>>)

Processes state updates and updates internal state accordingly.

Trait Implementations

impl Debug for AA2dPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AA2dPool

fn default() -> Self

Returns the “default value” for a type.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 336 bytes