Struct cfxcore::consensus::pos_handler::PosHandler

pub struct PosHandler {
    pub conf: PosConfiguration,
    /* private fields */
}

Fields

conf: PosConfiguration

Implementations

impl PosHandler

pub fn new( network: Option<Arc<NetworkService>>, conf: PosConfiguration, enable_height: u64 ) -> Self

pub fn initialize(&self, consensus: Arc<ConsensusGraph>) -> Result<(), String>

pub fn config(&self) -> &PosConfiguration

pub fn pos_option(&self) -> Option<&Box<dyn PosInterface>>

pub fn is_enabled_at_height(&self, height: u64) -> bool

pub fn is_committed(&self, h: &PosBlockId) -> bool

pub fn verify_against_predecessors( &self, me: &PosBlockId, preds: &Vec<PosBlockId> ) -> bool

Check if me is equal to or extends preds (parent and referees).

Since committed PoS blocks form a chain, and no pos block should be skipped, we only need to check if the round of me is equal to or plus one compared with the predecessors’ rounds.

Return false if me or preds contains non-existent PoS blocks.

pub fn get_pivot_decision(&self, h: &PosBlockId) -> Option<H256>

pub fn get_latest_pos_reference(&self) -> PosBlockId

pub fn get_pos_view(&self, h: &PosBlockId) -> Option<u64>

pub fn get_unlock_nodes( &self, h: &PosBlockId, parent_pos_ref: &PosBlockId ) -> Vec<(NodeId, u64)>

pub fn get_disputed_nodes( &self, h: &PosBlockId, parent_pos_ref: &PosBlockId ) -> Vec<NodeId>

pub fn get_reward_distribution_event( &self, h: &PosBlockId, parent_pos_ref: &PosBlockId ) -> Option<Vec<(u64, RewardDistributionEventV2)>>

pub fn pos_ledger_db(&self) -> &Arc<PosLedgerDB>

pub fn consensus_db(&self) -> &Arc<ConsensusDB>

pub fn cached_db(&self) -> &Arc<CachedPosLedgerDB>

pub fn stop(&self) -> Option<(Weak<PosLedgerDB>, Weak<ConsensusDB>)>

impl PosHandler

The functions used in tests to construct attack cases

pub fn force_vote_proposal(&self, block_id: H256) -> Result<()>

pub fn force_propose( &self, round: U64, parent_block_id: H256, payload: Vec<TransactionPayload> ) -> Result<()>

pub fn trigger_timeout(&self, timeout_type: String) -> Result<()>

pub fn force_sign_pivot_decision( &self, pivot_decision: PivotBlockDecision ) -> Result<()>

pub fn get_chosen_proposal(&self) -> Result<Option<Block>>

pub fn stop_election(&self) -> Result<Option<Round>>

pub fn start_voting(&self, initialize: bool) -> Result<()>

pub fn stop_voting(&self) -> Result<()>

pub fn voting_status(&self) -> Result<bool>