Struct Shared

pub struct Shared {
    pub header_map: Arc<HeaderMap>,
    /* private fields */
}

TODO(doc): @quake

Fields

header_map: Arc<HeaderMap>

Implementations

impl Shared

pub fn new( store: ChainDB, tx_pool_controller: TxPoolController, notify_controller: NotifyController, txs_verify_cache: Arc<TokioRwLock<TxVerificationCache>>, consensus: Arc<Consensus>, snapshot_mgr: Arc<SnapshotMgr>, async_handle: Handle, ibd_finished: Arc<AtomicBool>, assume_valid_targets: Arc<Mutex<Option<Vec<H256>>>>, assume_valid_target_specified: Arc<Option<H256>>, header_map: Arc<HeaderMap>, block_status_map: Arc<DashMap<Byte32, BlockStatus>>, ) -> Shared

Construct new Shared

pub fn spawn_freeze(&self) -> Option<FreezerClose>

Spawn freeze background thread that periodically checks and moves ancient data from the kv database into the freezer.

pub fn tx_pool_controller(&self) -> &TxPoolController

TODO(doc): @quake

pub fn txs_verify_cache(&self) -> Arc<TokioRwLock<TxVerificationCache>>

TODO(doc): @quake

pub fn notify_controller(&self) -> &NotifyController

TODO(doc): @quake

pub fn snapshot(&self) -> Guard<Arc<Snapshot>>

TODO(doc): @quake

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

Return arc cloned snapshot

pub fn store_snapshot(&self, snapshot: Arc<Snapshot>)

TODO(doc): @quake

pub fn refresh_snapshot(&self)

TODO(doc): @quake

pub fn new_snapshot( &self, tip_header: HeaderView, total_difficulty: U256, epoch_ext: EpochExt, proposals: ProposalView, ) -> Arc<Snapshot>

TODO(doc): @quake

pub fn consensus(&self) -> &Consensus

TODO(doc): @quake

pub fn cloned_consensus(&self) -> Arc<Consensus>

Return arc cloned consensus re

pub fn async_handle(&self) -> &Handle

Return async runtime handle

pub fn genesis_hash(&self) -> Byte32

TODO(doc): @quake

pub fn store(&self) -> &ChainDB

TODO(doc): @quake

pub fn is_initial_block_download(&self) -> bool

Return whether chain is in initial block download

pub fn get_block_template( &self, bytes_limit: Option<u64>, proposals_limit: Option<u64>, max_version: Option<Version>, ) -> Result<Result<BlockTemplate, AnyError>, AnyError>

Generate and return block_template

pub fn set_unverified_tip(&self, header: HeaderIndex)

pub fn get_unverified_tip(&self) -> HeaderIndex

pub fn header_map(&self) -> &HeaderMap

pub fn remove_header_view(&self, hash: &Byte32)

pub fn block_status_map(&self) -> &DashMap<Byte32, BlockStatus>

pub fn get_block_status(&self, block_hash: &Byte32) -> BlockStatus

pub fn contains_block_status<T: ChainStore>( &self, block_hash: &Byte32, status: BlockStatus, ) -> bool

pub fn insert_block_status(&self, block_hash: Byte32, status: BlockStatus)

pub fn remove_block_status(&self, block_hash: &Byte32)

pub fn assume_valid_targets(&self) -> MutexGuard<'_, Option<Vec<H256>>>

pub fn assume_valid_target_specified(&self) -> Arc<Option<H256>>

Trait Implementations

impl Clone for Shared

fn clone(&self) -> Shared

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.