Enum TransitionFrontierSyncState

pub enum TransitionFrontierSyncState {
    Idle,
    Init {
        time: Timestamp,
        best_tip: ArcBlockWithHash,
        root_block: ArcBlockWithHash,
        blocks_inbetween: Vec<StateHash>,
    },
    StakingLedgerPending(TransitionFrontierSyncLedgerPending),
    StakingLedgerSuccess {
        time: Timestamp,
        best_tip: ArcBlockWithHash,
        root_block: ArcBlockWithHash,
        blocks_inbetween: Vec<StateHash>,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    NextEpochLedgerPending(TransitionFrontierSyncLedgerPending),
    NextEpochLedgerSuccess {
        time: Timestamp,
        best_tip: ArcBlockWithHash,
        root_block: ArcBlockWithHash,
        blocks_inbetween: Vec<StateHash>,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    RootLedgerPending(TransitionFrontierSyncLedgerPending),
    RootLedgerSuccess {
        time: Timestamp,
        best_tip: ArcBlockWithHash,
        root_block: ArcBlockWithHash,
        blocks_inbetween: Vec<StateHash>,
        root_block_updates: Vec<ArcBlockWithHash>,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    BlocksPending {
        time: Timestamp,
        chain: Vec<TransitionFrontierSyncBlockState>,
        root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    BlocksSuccess {
        time: Timestamp,
        chain: Vec<AppliedBlock>,
        root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    CommitPending {
        time: Timestamp,
        chain: Vec<AppliedBlock>,
        root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    CommitSuccess {
        time: Timestamp,
        chain: Vec<AppliedBlock>,
        root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates,
        needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>,
    },
    Synced {
        time: Timestamp,
    },
}

Variants

Idle

Init

Fields

time: Timestamp

best_tip: ArcBlockWithHash

root_block: ArcBlockWithHash

blocks_inbetween: Vec<StateHash>

StakingLedgerPending(TransitionFrontierSyncLedgerPending)

StakingLedgerSuccess

Fields

time: Timestamp

best_tip: ArcBlockWithHash

root_block: ArcBlockWithHash

blocks_inbetween: Vec<StateHash>

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

NextEpochLedgerPending(TransitionFrontierSyncLedgerPending)

NextEpochLedgerSuccess

Fields

time: Timestamp

best_tip: ArcBlockWithHash

root_block: ArcBlockWithHash

blocks_inbetween: Vec<StateHash>

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

RootLedgerPending(TransitionFrontierSyncLedgerPending)

RootLedgerSuccess

Fields

time: Timestamp

best_tip: ArcBlockWithHash

root_block: ArcBlockWithHash

blocks_inbetween: Vec<StateHash>

root_block_updates: Vec<ArcBlockWithHash>

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

BlocksPending

Fields

time: Timestamp

chain: Vec<TransitionFrontierSyncBlockState>

root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates

Snarked ledger updates/transitions that happened while we were synchronizing blocks. If those updates do happen, we need to create those snarked ledgers from the closest snarked ledger that we have in the service already synchronized.

Contains a map where the key is the new snarked ledger and the value is more info required to construct that ledger.

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

BlocksSuccess

Fields

time: Timestamp

chain: Vec<AppliedBlock>

root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

CommitPending

Fields

time: Timestamp

chain: Vec<AppliedBlock>

root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

CommitSuccess

Fields

time: Timestamp

chain: Vec<AppliedBlock>

root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates

needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>

Synced

Fields

time: Timestamp

Implementations

impl TransitionFrontierSyncState

pub fn is_pending(&self) -> bool

If the synchronization process has started but is not yet complete

pub fn is_commit_pending(&self) -> bool

pub fn is_synced(&self) -> bool

If the synchronization process is complete

pub fn time(&self) -> Option<Timestamp>

pub fn root_block(&self) -> Option<&ArcBlockWithHash>

pub fn best_tip(&self) -> Option<&ArcBlockWithHash>

pub fn ledger(&self) -> Option<&TransitionFrontierSyncLedgerState>

pub fn ledger_mut(&mut self) -> Option<&mut TransitionFrontierSyncLedgerState>

pub fn ledger_target(&self) -> Option<SyncLedgerTarget>

pub fn ledger_target_kind(&self) -> Option<SyncLedgerTargetKind>

pub fn is_ledger_sync_complete(&self) -> bool

True if the synchronization of the target ledger is complete.

Epoch ledgers only require the snarked ledger to be synchronized, but the ledger at the root of the transition frontier also requires the staging ledger to be synchronized.

pub fn blocks_iter( &self, ) -> impl Iterator<Item = &TransitionFrontierSyncBlockState>

pub fn pending_count(&self) -> usize

pub fn blocks_fetch_retry_iter(&self) -> impl '_ + Iterator<Item = StateHash>

pub fn blocks_fetch_next(&self) -> Option<StateHash>

pub fn block_state( &self, hash: &StateHash, ) -> Option<&TransitionFrontierSyncBlockState>

pub fn block_state_mut( &mut self, hash: &StateHash, ) -> Option<&mut TransitionFrontierSyncBlockState>

pub fn is_fetch_pending_from_peer( &self, hash: &StateHash, peer_id: &PeerId, rpc_id: P2pRpcId, ) -> bool

pub fn blocks_fetch_from_peer_pending_rpc_ids<'a>( &'a self, peer_id: &'a PeerId, ) -> impl 'a + Iterator<Item = P2pRpcId>

pub fn blocks_apply_pending(&self) -> Option<&ArcBlockWithHash>

pub fn blocks_apply_next(&self) -> Option<(&ArcBlockWithHash, &AppliedBlock)>

pub fn sync_phase(&self) -> SyncPhase

impl TransitionFrontierSyncState

pub fn reducer( state_context: Substate<'_, Self>, action: TransitionFrontierSyncActionWithMetaRef<'_>, best_chain: &[AppliedBlock], )

Trait Implementations

impl Clone for TransitionFrontierSyncState

fn clone(&self) -> TransitionFrontierSyncState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransitionFrontierSyncState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TransitionFrontierSyncState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for TransitionFrontierSyncState

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Serialize for TransitionFrontierSyncState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl SubstateAccess<TransitionFrontierSyncState> for State

fn substate(&self) -> SubstateResult<&TransitionFrontierSyncState>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> SubstateResult<&mut TransitionFrontierSyncState>

Attempts to obtain a mutable reference to the substate.