pub struct QuorumVoteTaskState<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> {Show 15 fields
pub public_key: TYPES::SignatureKey,
pub private_key: <TYPES::SignatureKey as SignatureKey>::PrivateKey,
pub consensus: OuterConsensus<TYPES>,
pub instance_state: Arc<TYPES::InstanceState>,
pub latest_voted_view: TYPES::View,
pub vote_dependencies: BTreeMap<TYPES::View, JoinHandle<()>>,
pub network: Arc<I::Network>,
pub membership: Arc<TYPES::Membership>,
pub drb_computations: BTreeMap<TYPES::Epoch, JoinHandle<DrbResult>>,
pub output_event_stream: Sender<Event<TYPES>>,
pub id: u64,
pub consensus_metrics: Arc<ConsensusMetricsValue>,
pub storage: Arc<RwLock<I::Storage>>,
pub upgrade_lock: UpgradeLock<TYPES, V>,
pub epoch_height: u64,
}
Expand description
The state for the quorum vote task.
Contains all of the information for the quorum vote.
Fields§
§public_key: TYPES::SignatureKey
Public key.
private_key: <TYPES::SignatureKey as SignatureKey>::PrivateKey
Private Key.
consensus: OuterConsensus<TYPES>
Reference to consensus. The replica will require a write lock on this.
instance_state: Arc<TYPES::InstanceState>
Immutable instance state
latest_voted_view: TYPES::View
Latest view number that has been voted for.
vote_dependencies: BTreeMap<TYPES::View, JoinHandle<()>>
Table for the in-progress dependency tasks.
network: Arc<I::Network>
The underlying network
membership: Arc<TYPES::Membership>
Membership for Quorum certs/votes and DA committee certs/votes.
drb_computations: BTreeMap<TYPES::Epoch, JoinHandle<DrbResult>>
Table for the in-progress DRB computation tasks.
output_event_stream: Sender<Event<TYPES>>
Output events to application
id: u64
The node’s id
consensus_metrics: Arc<ConsensusMetricsValue>
The consensus metrics
storage: Arc<RwLock<I::Storage>>
Reference to the storage.
upgrade_lock: UpgradeLock<TYPES, V>
Lock for a decided upgrade
epoch_height: u64
Number of blocks in an epoch, zero means there are no epochs
Implementations§
source§impl<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> QuorumVoteTaskState<TYPES, I, V>
impl<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> QuorumVoteTaskState<TYPES, I, V>
sourcefn create_event_dependency(
&self,
dependency_type: VoteDependency,
view_number: TYPES::View,
event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>,
) -> EventDependency<Arc<HotShotEvent<TYPES>>>
fn create_event_dependency( &self, dependency_type: VoteDependency, view_number: TYPES::View, event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>, ) -> EventDependency<Arc<HotShotEvent<TYPES>>>
Create an event dependency.
sourcefn create_dependency_task_if_new(
&mut self,
view_number: TYPES::View,
event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>,
event_sender: &Sender<Arc<HotShotEvent<TYPES>>>,
event: Option<Arc<HotShotEvent<TYPES>>>,
)
fn create_dependency_task_if_new( &mut self, view_number: TYPES::View, event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>, event_sender: &Sender<Arc<HotShotEvent<TYPES>>>, event: Option<Arc<HotShotEvent<TYPES>>>, )
Create and store an AndDependency
combining EventDependency
s associated with the
given view number if it doesn’t exist.
sourceasync fn update_latest_voted_view(&mut self, new_view: TYPES::View) -> bool
async fn update_latest_voted_view(&mut self, new_view: TYPES::View) -> bool
Update the latest voted view number.
sourcepub async fn handle(
&mut self,
event: Arc<HotShotEvent<TYPES>>,
event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>,
event_sender: Sender<Arc<HotShotEvent<TYPES>>>,
) -> Result<()>
pub async fn handle( &mut self, event: Arc<HotShotEvent<TYPES>>, event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>, event_sender: Sender<Arc<HotShotEvent<TYPES>>>, ) -> Result<()>
Handle a vote dependent event received on the event stream
sourceasync fn handle_eqc_voting(
&self,
proposal: &Proposal<TYPES, QuorumProposal2<TYPES>>,
parent_leaf: &Leaf2<TYPES>,
event_sender: Sender<Arc<HotShotEvent<TYPES>>>,
event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>,
)
async fn handle_eqc_voting( &self, proposal: &Proposal<TYPES, QuorumProposal2<TYPES>>, parent_leaf: &Leaf2<TYPES>, event_sender: Sender<Arc<HotShotEvent<TYPES>>>, event_receiver: Receiver<Arc<HotShotEvent<TYPES>>>, )
Handles voting for the last block in the epoch to form the Extended QC.
Trait Implementations§
source§impl<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> TaskState for QuorumVoteTaskState<TYPES, I, V>
impl<TYPES: NodeType, I: NodeImplementation<TYPES>, V: Versions> TaskState for QuorumVoteTaskState<TYPES, I, V>
source§type Event = HotShotEvent<TYPES>
type Event = HotShotEvent<TYPES>
source§fn handle_event<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
event: Arc<Self::Event>,
sender: &'life1 Sender<Arc<Self::Event>>,
receiver: &'life2 Receiver<Arc<Self::Event>>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn handle_event<'life0, 'life1, 'life2, 'async_trait>(
&'life0 mut self,
event: Arc<Self::Event>,
sender: &'life1 Sender<Arc<Self::Event>>,
receiver: &'life2 Receiver<Arc<Self::Event>>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
source§fn cancel_subtasks(&mut self)
fn cancel_subtasks(&mut self)
Auto Trait Implementations§
impl<TYPES, I, V> Freeze for QuorumVoteTaskState<TYPES, I, V>where
<TYPES as NodeType>::SignatureKey: Freeze,
<<TYPES as NodeType>::SignatureKey as SignatureKey>::PrivateKey: Freeze,
<TYPES as NodeType>::View: Freeze,
impl<TYPES, I, V> !RefUnwindSafe for QuorumVoteTaskState<TYPES, I, V>
impl<TYPES, I, V> Send for QuorumVoteTaskState<TYPES, I, V>
impl<TYPES, I, V> Sync for QuorumVoteTaskState<TYPES, I, V>
impl<TYPES, I, V> Unpin for QuorumVoteTaskState<TYPES, I, V>where
<TYPES as NodeType>::SignatureKey: Unpin,
<<TYPES as NodeType>::SignatureKey as SignatureKey>::PrivateKey: Unpin,
<TYPES as NodeType>::View: Unpin,
V: Unpin,
impl<TYPES, I, V> !UnwindSafe for QuorumVoteTaskState<TYPES, I, V>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.