Struct ethcore::verification::queue::VerificationQueue

pub struct VerificationQueue<K: Kind> { /* private fields */ }

A queue of items to be verified. Sits between network or other I/O and the BlockChain. Keeps them in the same order as inserted, minus invalid items.

Implementations

impl<K: Kind> VerificationQueue<K>

pub fn new(
    config: Config,
    engine: Arc<dyn EthEngine>,
    message_channel: IoChannel<ClientIoMessage>,
    check_seal: bool
) -> Self

Creates a new queue instance.

pub fn clear(&self)

Clear the queue and stop verification activity.

pub fn flush(&self)

Wait for unverified queue to be empty

pub fn status(&self, hash: &H256) -> Status

Check if the item is currently in the queue

pub fn import(&self, input: K::Input) -> Result<H256, (Option<K::Input>, Error)>

Add a block to the queue.

pub fn mark_as_bad(&self, hashes: &[H256])

Mark given item and all its children as bad. pauses verification until complete.

pub fn mark_as_good(&self, hashes: &[H256]) -> bool

Mark given item as processed. Returns true if the queue becomes empty.

pub fn drain(&self, max: usize) -> Vec<K::Verified>

Removes up to max verified items from the queue

pub fn resignal_verification(&self)

release taken signal and call async ClientIoMessage::BlockVerified call to client so that it can continue verification. difference between sync and async is whose thread pool is used.

pub fn reset_verification_ready_signal(&self)

Reset verification ready signal so that it allows other threads to send IoMessage to Client

pub fn is_empty(&self) -> bool

Returns true if there is nothing currently in the queue.

pub fn is_processing_fork(
    &self,
    best_block_hash: &H256,
    chain: &BlockChain
) -> bool

Returns true if there are descendants of the current best block in the processing queue

pub fn queue_info(&self) -> QueueInfo

Get queue status.

pub fn total_difficulty(&self) -> U256

Get the total difficulty of all the blocks in the queue.

pub fn num_verifiers(&self) -> usize

Get the current number of working verifiers.

pub fn collect_garbage(&self)

Optimise memory footprint of the heap fields, and adjust the number of threads to better suit the workload.

Trait Implementations

impl<K: Kind> Drop for VerificationQueue<K>

fn drop(&mut self)

Executes the destructor for this type.