Struct TxpoolManager 

struct TxpoolManager {
    current_txs: IndexMap<[u8; 32], TxInfo>,
    tx_timeouts: DelayQueue<[u8; 32]>,
    txpool_write_handle: TxpoolWriteHandle,
    txpool_read_handle: TxpoolReadHandle,
    dandelion_pool_manager: DandelionPoolService<DandelionTx, [u8; 32], CrossNetworkInternalPeerId>,
    promote_tx_channel: UnboundedReceiver<[u8; 32]>,
    diffuse_service: DiffuseService<ClearNet>,
    config: TxpoolConfig,
}

Fields

current_txs: IndexMap<[u8; 32], TxInfo>

tx_timeouts: DelayQueue<[u8; 32]>

A DelayQueue for waiting on tx timeouts.

Timeouts can be for re-relaying or removal from the pool.

txpool_write_handle: TxpoolWriteHandle

txpool_read_handle: TxpoolReadHandle

dandelion_pool_manager: DandelionPoolService<DandelionTx, [u8; 32], CrossNetworkInternalPeerId>

promote_tx_channel: UnboundedReceiver<[u8; 32]>

The channel the dandelion manager will use to communicate that a tx should be promoted to the public pool.

diffuse_service: DiffuseService<ClearNet>

The DiffuseService to diffuse txs to the p2p network.

Used for re-relays.

config: TxpoolConfig

Implementations

impl TxpoolManager

async fn remove_tx_from_pool(&mut self, tx: [u8; 32], remove_from_db: bool)

Removes a transaction from the tx-pool manager, and optionally the database too.

Panics

This function will panic if the tx is not in the tx-pool manager.

async fn rerelay_tx(&mut self, tx: [u8; 32])

Re-relay a tx to the network.

Panics

This function will panic if the tx is not in the tx-pool.

async fn handle_tx_timeout(&mut self, tx: [u8; 32])

Handles a transaction timeout, be either rebroadcasting or dropping the tx from the pool. If a rebroadcast happens, this function will handle adding another timeout to the queue.

fn track_tx(&mut self, tx: [u8; 32], weight: usize, fee: u64, private: bool)

Adds a tx to the tx-pool manager.

async fn handle_incoming_tx( &mut self, tx: TransactionVerificationData, state: TxState<CrossNetworkInternalPeerId>, )

Handles an incoming tx, adding it to the pool and routing it.

async fn promote_tx(&mut self, tx: [u8; 32])

Promote a tx to the public pool.

async fn new_block(&mut self, spent_key_images: Vec<[u8; 32]>)

Handles removing all transactions that have been included/double spent in an incoming block.

async fn run( self, tx_rx: Receiver<(TransactionVerificationData, TxState<CrossNetworkInternalPeerId>)>, block_rx: Receiver<(Vec<[u8; 32]>, Sender<()>)>, )

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: 400 bytes