Struct ConsensusWriteLockGuard

pub struct ConsensusWriteLockGuard<'a, TYPES: NodeType> {
    lock_guard: RwLockWriteGuard<'a, Consensus<TYPES>>,
}

A thin wrapper around RwLockWriteGuard for Consensus that leaves debug traces when the lock is freed

Fields

lock_guard: RwLockWriteGuard<'a, Consensus<TYPES>>

Inner RwLockWriteGuard

Implementations

impl<'a, TYPES: NodeType> ConsensusWriteLockGuard<'a, TYPES>

pub fn new(lock_guard: RwLockWriteGuard<'a, Consensus<TYPES>>) -> Self

Creates a new instance of ConsensusWriteLockGuard with the same name as parent OuterConsensus

Methods from Deref<Target = Consensus<TYPES>>

pub fn cur_view(&self) -> TYPES::View

Get the current view.

pub fn cur_epoch(&self) -> Option<TYPES::Epoch>

Get the current epoch.

pub fn last_decided_view(&self) -> TYPES::View

Get the last decided view.

pub fn locked_view(&self) -> TYPES::View

Get the locked view.

pub fn high_qc(&self) -> &QuorumCertificate2<TYPES>

Get the high QC.

pub fn transition_qc( &self, ) -> Option<&(QuorumCertificate2<TYPES>, NextEpochQuorumCertificate2<TYPES>)>

Get the transition QC.

pub fn update_highest_block(&mut self, block_number: u64)

Update the highest block number

pub fn update_transition_qc( &mut self, qc: QuorumCertificate2<TYPES>, next_epoch_qc: NextEpochQuorumCertificate2<TYPES>, )

Update the transition QC.

pub fn state_cert(&self) -> Option<&LightClientStateUpdateCertificate<TYPES>>

Get the current light client state certificate

pub fn next_epoch_high_qc(&self) -> Option<&NextEpochQuorumCertificate2<TYPES>>

Get the next epoch high QC.

pub fn validated_state_map(&self) -> &BTreeMap<TYPES::View, View<TYPES>>

Get the validated state map.

pub fn saved_leaves(&self) -> &CommitmentMap<Leaf2<TYPES>>

Get the saved leaves.

pub fn saved_payloads( &self, ) -> &BTreeMap<TYPES::View, Arc<PayloadWithMetadata<TYPES>>>

Get the saved payloads.

pub fn vid_shares(&self) -> &VidShares<TYPES>

Get the vid shares.

pub fn saved_da_certs(&self) -> &HashMap<TYPES::View, DaCertificate2<TYPES>>

Get the saved DA certs.

pub fn last_proposals( &self, ) -> &BTreeMap<TYPES::View, Proposal<TYPES, QuorumProposalWrapper<TYPES>>>

Get the map of our recent proposals

pub fn update_view(&mut self, view_number: TYPES::View) -> Result<()>

Update the current view.

Errors

Can return an error when the new view_number is not higher than the existing view number.

pub async fn parent_leaf_info( &self, leaf: &Leaf2<TYPES>, public_key: &TYPES::SignatureKey, ) -> Option<LeafInfo<TYPES>>

Get the parent Leaf Info from a given leaf and our public key. Returns None if we don’t have the data in out state

pub fn update_epoch(&mut self, epoch_number: TYPES::Epoch) -> Result<()>

Update the current epoch.

Errors

Can return an error when the new epoch_number is not higher than the existing epoch number.

pub fn update_action( &mut self, action: HotShotAction, view: TYPES::View, ) -> bool

Update the last actioned view internally for votes and proposals

Returns true if the action is for a newer view than the last action of that type

pub fn reset_actions(&mut self)

reset last actions to genesis so we can resend events in tests

pub fn update_proposed_view( &mut self, proposal: Proposal<TYPES, QuorumProposalWrapper<TYPES>>, ) -> Result<()>

Update the last proposal.

Errors

Can return an error when the new view_number is not higher than the existing proposed view number.

pub fn update_last_decided_view( &mut self, view_number: TYPES::View, ) -> Result<()>

Update the last decided view.

Errors

Can return an error when the new view_number is not higher than the existing decided view number.

pub fn update_locked_view(&mut self, view_number: TYPES::View) -> Result<()>

Update the locked view.

Errors

Can return an error when the new view_number is not higher than the existing locked view number.

pub fn update_da_view( &mut self, view_number: TYPES::View, epoch: Option<TYPES::Epoch>, payload_commitment: VidCommitment, ) -> Result<()>

Update the validated state map with a new view_number/view combo.

Errors

Can return an error when the new view contains less information than the existing view with the same view number.

pub fn update_leaf( &mut self, leaf: Leaf2<TYPES>, state: Arc<TYPES::ValidatedState>, delta: Option<Arc<<TYPES::ValidatedState as ValidatedState<TYPES>>::Delta>>, ) -> Result<()>

Update the validated state map with a new view_number/view combo.

Errors

Can return an error when the new view contains less information than the existing view with the same view number.

fn update_validated_state_map( &mut self, view_number: TYPES::View, new_view: View<TYPES>, ) -> Result<()>

Update the validated state map with a new view_number/view combo.

Errors

Can return an error when the new view contains less information than the existing view with the same view number.

fn update_saved_leaves(&mut self, leaf: Leaf2<TYPES>)

Update the saved leaves with a new leaf.

pub fn update_saved_payloads( &mut self, view_number: TYPES::View, payload: Arc<PayloadWithMetadata<TYPES>>, ) -> Result<()>

Update the saved payloads with a new encoded transaction.

Errors

Can return an error when there’s an existing payload corresponding to the same view number.

pub fn update_high_qc( &mut self, high_qc: QuorumCertificate2<TYPES>, ) -> Result<()>

Update the high QC if given a newer one.

Errors

Can return an error when the provided high_qc is not newer than the existing entry.

pub fn update_next_epoch_high_qc( &mut self, high_qc: NextEpochQuorumCertificate2<TYPES>, ) -> Result<()>

Update the next epoch high QC if given a newer one.

Errors

Can return an error when the provided high_qc is not newer than the existing entry.

Panics

It can’t actually panic. If the option is None, we will not call unwrap on it.

pub fn reset_high_qc( &mut self, high_qc: QuorumCertificate2<TYPES>, next_epoch_qc: NextEpochQuorumCertificate2<TYPES>, ) -> Result<()>

Resets high qc and next epoch qc to the provided transition qc.

Errors

Can return an error when the provided high_qc is not newer than the existing entry.

pub fn update_state_cert( &mut self, state_cert: LightClientStateUpdateCertificate<TYPES>, ) -> Result<()>

Update the light client state update certificate if given a newer one.

Errors

Can return an error when the provided state_cert is not newer than the existing entry.

pub fn update_vid_shares( &mut self, view_number: TYPES::View, disperse: Proposal<TYPES, VidDisperseShare<TYPES>>, )

Add a new entry to the vid_shares map.

pub fn update_saved_da_certs( &mut self, view_number: TYPES::View, cert: DaCertificate2<TYPES>, )

Add a new entry to the da_certs map.

pub fn visit_leaf_ancestors<F>( &self, start_from: TYPES::View, terminator: Terminator<TYPES::View>, ok_when_finished: bool, f: F, ) -> Result<(), HotShotError<TYPES>>

where F: FnMut(&Leaf2<TYPES>, Arc<<TYPES as NodeType>::ValidatedState>, Option<Arc<<<TYPES as NodeType>::ValidatedState as ValidatedState<TYPES>>::Delta>>) -> bool,

gather information from the parent chain of leaves

Errors

If the leaf or its ancestors are not found in storage

pub fn collect_garbage( &mut self, old_anchor_view: TYPES::View, new_anchor_view: TYPES::View, )

Garbage collects based on state change right now, this removes from both the saved_payloads and validated_state_map fields of Consensus.

Panics

On inconsistent stored entries

pub fn decided_leaf(&self) -> Leaf2<TYPES>

Gets the last decided leaf.

Panics

if the last decided view’s leaf does not exist in the state map or saved leaves, which should never happen.

pub fn undecided_leaves(&self) -> Vec<Leaf2<TYPES>>

pub fn state( &self, view_number: TYPES::View, ) -> Option<&Arc<TYPES::ValidatedState>>

Gets the validated state with the given view number, if in the state map.

pub fn state_and_delta(&self, view_number: TYPES::View) -> StateAndDelta<TYPES>

Gets the validated state and state delta with the given view number, if in the state map.

pub fn decided_state(&self) -> Arc<TYPES::ValidatedState>

Gets the last decided validated state.

Panics

If the last decided view’s state does not exist in the state map, which should never happen.

pub fn is_epoch_transition(&self, leaf_commit: LeafCommitment<TYPES>) -> bool

Returns true if a given leaf is for the epoch transition

pub fn is_high_qc_for_epoch_transition(&self) -> bool

Returns true if our high QC is for one of the epoch transition blocks

pub fn check_eqc( &self, proposed_leaf: &Leaf2<TYPES>, parent_leaf: &Leaf2<TYPES>, ) -> bool

Returns true if the parent_leaf formed an eQC for the previous epoch to the proposed_leaf

pub fn is_high_qc_ge_root_block(&self) -> bool

Returns true if our high QC is for the block equal or greater than the root epoch block

Trait Implementations

impl<TYPES: NodeType> Deref for ConsensusWriteLockGuard<'_, TYPES>

type Target = Consensus<TYPES>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<TYPES: NodeType> DerefMut for ConsensusWriteLockGuard<'_, TYPES>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<TYPES: NodeType> Drop for ConsensusWriteLockGuard<'_, TYPES>

fn drop(&mut self)

Executes the destructor for this type.