Struct cfxcore::transaction_pool::TransactionPool

pub struct TransactionPool {
    pub config: TxPoolConfig,
    pub data_man: Arc<BlockDataManager>,
    /* private fields */
}

Fields

config: TxPoolConfig

data_man: Arc<BlockDataManager>

Implementations

impl TransactionPool

pub fn new( config: TxPoolConfig, verification_config: VerificationConfig, data_man: Arc<BlockDataManager>, machine: Arc<Machine> ) -> Self

pub fn machine(&self) -> Arc<Machine>

pub fn get_transaction(&self, tx_hash: &H256) -> Option<Arc<SignedTransaction>>

pub fn get_transaction_by_address2nonce( &self, address: Address, nonce: U256 ) -> Option<Arc<SignedTransaction>>

pub fn check_tx_packed_in_deferred_pool(&self, tx_hash: &H256) -> bool

pub fn get_local_account_info(&self, address: &Address) -> (U256, U256)

pub fn get_next_nonce(&self, address: &Address) -> U256

pub fn get_account_pending_info( &self, address: &Address ) -> Option<(U256, U256, U256, H256)>

pub fn get_account_pending_transactions( &self, address: &Address, maybe_start_nonce: Option<U256>, maybe_limit: Option<usize>, best_height: BlockHeight ) -> StateDbResult<(Vec<Arc<SignedTransaction>>, Option<TransactionStatus>, usize)>

Return (pending_txs, first_tx_status, pending_count).

pub fn get_pending_transaction_hashes_in_evm_pool(&self) -> BTreeSet<H256>

pub fn get_pending_transaction_hashes_in_native_pool(&self) -> BTreeSet<H256>

pub fn get_state_account_info( &self, address: &Address ) -> StateDbResult<(U256, U256)>

pub fn calc_half_block_gas_limit(&self) -> Option<U256>

pub fn insert_new_transactions( &self, transactions: Vec<TransactionWithSignature> ) -> (Vec<Arc<SignedTransaction>>, HashMap<H256, TransactionPoolError>)

Try to insert transactions into transaction pool.

If some tx is already in our tx_cache, it will be ignored and will not be added to returned passed_transactions. If some tx invalid or cannot be inserted to the tx pool, it will be included in the returned failure and will not be propagated.

pub fn insert_new_signed_transactions( &self, signed_transactions: Vec<Arc<SignedTransaction>> ) -> (Vec<Arc<SignedTransaction>>, HashMap<H256, TransactionPoolError>)

Try to insert signed_transaction into transaction pool.

If some tx is already in our tx_cache, it will be ignored and will not be added to returned passed_transactions. If some tx invalid or cannot be inserted to the tx pool, it will be included in the returned failure and will not be propagated.

pub fn add_transaction_with_readiness_check( &self, inner: &mut TransactionPoolInner, account_cache: &StateProvider, transaction: Arc<SignedTransaction>, packed: bool, force: bool ) -> Result<(), TransactionPoolError>

pub fn get_to_be_propagated_transactions( &self ) -> HashMap<H256, Arc<SignedTransaction>>

pub fn set_to_be_propagated_transactions( &self, transactions: HashMap<H256, Arc<SignedTransaction>> )

pub fn remove_to_be_propagated_transactions(&self, tx_hash: &H256)

pub fn recycle_transactions(&self, transactions: Vec<Arc<SignedTransaction>>)

pub fn set_tx_packed(&self, transactions: &Vec<Arc<SignedTransaction>>)

pub fn pack_transactions<'a>( &self, num_txs: usize, block_gas_limit: U256, evm_gas_limit: U256, block_size_limit: usize, best_epoch_height: u64, best_block_number: u64 ) -> Vec<Arc<SignedTransaction>>

pub fn pack_transactions_1559<'a>( &self, num_txs: usize, block_gas_limit: U256, parent_base_price: SpaceMap<U256>, block_size_limit: usize, best_epoch_height: u64, best_block_number: u64 ) -> (Vec<Arc<SignedTransaction>>, SpaceMap<U256>)

pub fn compute_1559_base_price<'a, I>( &self, parent_hash: &H256, block_gas_limit: U256, txs: I ) -> Result<Option<SpaceMap<U256>>, String>

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

pub fn notify_modified_accounts(&self, accounts_from_execution: Vec<Account>)

pub fn clear_tx_pool(&self)

pub fn total_deferred(&self, space: Option<Space>) -> usize

pub fn total_ready_accounts(&self) -> usize

pub fn total_received(&self) -> usize

pub fn total_unpacked(&self) -> usize

pub fn total_pending(&self, space: Option<Space>) -> u64

pub fn total_queued(&self, space: Option<Space>) -> u64

pub fn stats(&self) -> (usize, usize, usize, usize)

stats retrieves the length of ready and deferred pool.

pub fn content( &self, address: Option<Address> ) -> (Vec<Arc<SignedTransaction>>, Vec<Arc<SignedTransaction>>)

content retrieves the ready and deferred transactions.

pub fn notify_new_best_info( &self, best_info: Arc<BestInformation> ) -> StateDbResult<()>

pub fn get_best_info_with_parent_base_price( &self ) -> (Arc<BestInformation>, Option<SpaceMap<U256>>)

pub fn get_best_info_with_packed_transactions( &self, num_txs: usize, block_size_limit: usize, additional_transactions: Vec<Arc<SignedTransaction>> ) -> (Arc<BestInformation>, U256, Vec<Arc<SignedTransaction>>, Option<SpaceMap<U256>>)

pub fn set_best_executed_state_by_epoch( &self, best_executed_epoch: StateIndex ) -> StateDbResult<()>

pub fn ready_for_mining(&self) -> bool

pub fn set_ready_for_mining(&self)

Trait Implementations

impl MallocSizeOf for TransactionPool

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.