Struct ckb_tx_pool::pool::TxPool

pub struct TxPool {
    pub recent_reject: Option<RecentReject>,
    /* private fields */
}

Tx-pool implementation

Fields

recent_reject: Option<RecentReject>

record recent reject

Implementations

impl TxPool

pub fn new(
    config: TxPoolConfig,
    snapshot: Arc<Snapshot>,
    last_txs_updated_at: Arc<AtomicU64>
) -> TxPool

Create new TxPool

pub fn snapshot(&self) -> &Snapshot

Tx-pool owned snapshot, it may not consistent with chain cause tx-pool update snapshot asynchronously

pub fn cloned_snapshot(&self) -> Arc<Snapshot>

Makes a clone of the Arc

pub fn reach_size_limit(&self, tx_size: usize) -> bool

Whether Tx-pool reach size limit

pub fn reach_cycles_limit(&self, cycles: Cycle) -> bool

Whether Tx-pool reach cycles limit

pub fn update_statics_for_add_tx(&mut self, tx_size: usize, cycles: Cycle)

Update size and cycles statics for add tx

pub fn update_statics_for_remove_tx(&mut self, tx_size: usize, cycles: Cycle)

Update size and cycles statics for remove tx cycles overflow is possible, currently obtaining cycles is not accurate

pub fn add_pending(&mut self, entry: TxEntry) -> bool

Add tx to pending pool If did have this value present, false is returned.

pub fn add_gap(&mut self, entry: TxEntry) -> bool

Add tx which proposed but still uncommittable to gap pool

pub fn add_proposed(&mut self, entry: TxEntry) -> Result<bool, Reject>

Add tx to proposed pool

pub fn get_last_txs_updated_at(&self) -> u64

Get last txs in tx-pool update timestamp

pub fn contains_proposal_id(&self, id: &ProposalShortId) -> bool

Returns true if the tx-pool contains a tx with specified id.

pub fn get_tx_with_cycles(
    &self,
    id: &ProposalShortId
) -> Option<(TransactionView, Cycle)>

Returns tx with cycles corresponding to the id.

pub fn get_tx(&self, id: &ProposalShortId) -> Option<&TransactionView>

Returns tx corresponding to the id.

pub fn get_tx_from_pending_or_else_gap(
    &self,
    id: &ProposalShortId
) -> Option<&TransactionView>

Returns tx from pending and gap corresponding to the id. RPC

pub fn get_proposals(
    &self,
    limit: usize,
    exclusion: &HashSet<ProposalShortId>
) -> HashSet<ProposalShortId>

Get to-be-proposal transactions that may be included in the next block.

pub fn get_tx_from_pool_or_store(
    &self,
    proposal_id: &ProposalShortId
) -> Option<TransactionView>

Returns tx from tx-pool or storage corresponding to the id.