Struct hotshot_task_impls::vote_collection::VoteCollectionTaskState

pub struct VoteCollectionTaskState<TYPES: NodeType, VOTE: Vote<TYPES>, CERT: Certificate<TYPES, VOTE::Commitment, Voteable = VOTE::Commitment> + Debug, V: Versions> {
    pub public_key: TYPES::SignatureKey,
    pub membership: Arc<RwLock<TYPES::Membership>>,
    pub accumulator: Option<VoteAccumulator<TYPES, VOTE, CERT, V>>,
    pub view: TYPES::View,
    pub epoch: TYPES::Epoch,
    pub id: u64,
    pub transition_indicator: EpochTransitionIndicator,
}

Task state for collecting votes of one type and emitting a certificate

Fields

public_key: TYPES::SignatureKey

Public key for this node.

membership: Arc<RwLock<TYPES::Membership>>

Membership for voting

accumulator: Option<VoteAccumulator<TYPES, VOTE, CERT, V>>

accumulator handles aggregating the votes

view: TYPES::View

The view which we are collecting votes for

epoch: TYPES::Epoch

The epoch which we are collecting votes for

id: u64

Node id

transition_indicator: EpochTransitionIndicator

Whether we should check if we are the leader when handling a vote

Implementations

impl<TYPES: NodeType, VOTE: Vote<TYPES> + AggregatableVote<TYPES, VOTE, CERT>, CERT: Certificate<TYPES, VOTE::Commitment, Voteable = VOTE::Commitment> + Clone + Debug, V: Versions> VoteCollectionTaskState<TYPES, VOTE, CERT, V>

pub async fn accumulate_vote( &mut self, vote: &VOTE, sender_epoch: TYPES::Epoch, event_stream: &Sender<Arc<HotShotEvent<TYPES>>>, ) -> Result<Option<CERT>>

Take one vote and accumulate it. Returns either the cert or the updated state after the vote is accumulated

Errors

If are unable to accumulate the vote

Trait Implementations

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, DaData2<TYPES>>, SimpleCertificate<TYPES, DaData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, DaVote2<TYPES>, DaCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<DaCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, NextEpochQuorumData2<TYPES>>, SimpleCertificate<TYPES, NextEpochQuorumData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, NextEpochQuorumVote2<TYPES>, NextEpochQuorumCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<NextEpochQuorumCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, QuorumData2<TYPES>>, SimpleCertificate<TYPES, QuorumData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, QuorumVote2<TYPES>, QuorumCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<QuorumCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, TimeoutData2<TYPES>>, SimpleCertificate<TYPES, TimeoutData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, TimeoutVote2<TYPES>, TimeoutCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<TimeoutCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, UpgradeProposalData<TYPES>>, SimpleCertificate<TYPES, UpgradeProposalData<TYPES>, UpgradeThreshold>> for VoteCollectionTaskState<TYPES, UpgradeVote<TYPES>, UpgradeCertificate<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<UpgradeCertificate<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, ViewSyncCommitData2<TYPES>>, SimpleCertificate<TYPES, ViewSyncCommitData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, ViewSyncCommitVote2<TYPES>, ViewSyncCommitCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ViewSyncCommitCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, ViewSyncFinalizeData2<TYPES>>, SimpleCertificate<TYPES, ViewSyncFinalizeData2<TYPES>, SuccessThreshold>> for VoteCollectionTaskState<TYPES, ViewSyncFinalizeVote2<TYPES>, ViewSyncFinalizeCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ViewSyncFinalizeCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event

impl<TYPES: NodeType, V: Versions> HandleVoteEvent<TYPES, SimpleVote<TYPES, ViewSyncPreCommitData2<TYPES>>, SimpleCertificate<TYPES, ViewSyncPreCommitData2<TYPES>, OneHonestThreshold>> for VoteCollectionTaskState<TYPES, ViewSyncPreCommitVote2<TYPES>, ViewSyncPreCommitCertificate2<TYPES>, V>

fn handle_vote_event<'life0, 'life1, 'async_trait>( &'life0 mut self, event: Arc<HotShotEvent<TYPES>>, sender: &'life1 Sender<Arc<HotShotEvent<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ViewSyncPreCommitCertificate2<TYPES>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a vote event

fn filter(event: Arc<HotShotEvent<TYPES>>) -> bool

Event filter to use for this event