pub enum DisputeCoordinatorMessage {
ImportStatements {
candidate_receipt: CandidateReceipt<H256>,
session: u32,
statements: Vec<(SignedDisputeStatement, ValidatorIndex), Global>,
pending_confirmation: Option<Sender<ImportStatementsResult>>,
},
RecentDisputes(Sender<Vec<(u32, CandidateHash, DisputeStatus), Global>>),
ActiveDisputes(Sender<Vec<(u32, CandidateHash, DisputeStatus), Global>>),
QueryCandidateVotes(Vec<(u32, CandidateHash), Global>, Sender<Vec<(u32, CandidateHash, CandidateVotes), Global>>),
IssueLocalStatement(u32, CandidateHash, CandidateReceipt<H256>, bool),
DetermineUndisputedChain {
base: (u32, H256),
block_descriptions: Vec<BlockDescription, Global>,
tx: Sender<(u32, H256)>,
},
}
Expand description
Messages received by the dispute coordinator subsystem.
NOTE: Any response oneshots might get cancelled if the DisputeCoordinator
was not yet
properly initialized for some reason.
Variants§
ImportStatements
Fields
candidate_receipt: CandidateReceipt<H256>
The candidate receipt itself.
statements: Vec<(SignedDisputeStatement, ValidatorIndex), Global>
Statements, with signatures checked, by validators participating in disputes.
The validator index passed alongside each statement should correspond to the index of the validator in the set.
pending_confirmation: Option<Sender<ImportStatementsResult>>
Inform the requester once we finished importing (if a sender was provided).
This is:
- we discarded the votes because
- they were ancient or otherwise invalid (result:
InvalidImport
) - or we were not able to recover availability for an unknown candidate (result:
InvalidImport
) - or were known already (in that case the result will still be
ValidImport
)
- they were ancient or otherwise invalid (result:
- or we recorded them because (
ValidImport
)- we cast our own vote already on that dispute
- or we have approval votes on that candidate
- or other explicit votes on that candidate already recorded
- or recovered availability for the candidate
- or the imported statements are backing/approval votes, which are always accepted.
Import statements by validators about a candidate.
The subsystem will silently discard ancient statements or sets of only dispute-specific statements for candidates that are previously unknown to the subsystem. The former is simply because ancient data is not relevant and the latter is as a DoS prevention mechanism. Both backing and approval statements already undergo anti-DoS procedures in their respective subsystems, but statements cast specifically for disputes are not necessarily relevant to any candidate the system is already aware of and thus present a DoS vector. Our expectation is that nodes will notify each other of disputes over the network by providing (at least) 2 conflicting statements, of which one is either a backing or validation statement.
This does not do any checking of the message signature.
RecentDisputes(Sender<Vec<(u32, CandidateHash, DisputeStatus), Global>>)
Fetch a list of all recent disputes the coordinator is aware of. These are disputes which have occurred any time in recent sessions, and which may have already concluded.
ActiveDisputes(Sender<Vec<(u32, CandidateHash, DisputeStatus), Global>>)
Fetch a list of all active disputes that the coordinator is aware of. These disputes are either not yet concluded or recently concluded.
QueryCandidateVotes(Vec<(u32, CandidateHash), Global>, Sender<Vec<(u32, CandidateHash, CandidateVotes), Global>>)
Get candidate votes for a candidate.
IssueLocalStatement(u32, CandidateHash, CandidateReceipt<H256>, bool)
Sign and issue local dispute votes. A value of true
indicates validity, and false
invalidity.
DetermineUndisputedChain
Fields
block_descriptions: Vec<BlockDescription, Global>
Descriptions of all the blocks counting upwards from the block after the base number
Determine the highest undisputed block within the given chain, based on where candidates
were included. If even the base block should not be finalized due to a dispute,
then None
should be returned on the channel.
The block descriptions begin counting upwards from the block after the given base_number
. The base_number
is typically the number of the last finalized block but may be slightly higher. This block
is inevitably going to be finalized so it is not accounted for by this function.
Trait Implementations§
source§impl AssociateOutgoing for DisputeCoordinatorMessage
impl AssociateOutgoing for DisputeCoordinatorMessage
§type OutgoingMessages = DisputeCoordinatorOutgoingMessages
type OutgoingMessages = DisputeCoordinatorOutgoingMessages
Self
.source§impl Debug for DisputeCoordinatorMessage
impl Debug for DisputeCoordinatorMessage
source§impl From<DisputeCoordinatorMessage> for AllMessages
impl From<DisputeCoordinatorMessage> for AllMessages
source§fn from(message: DisputeCoordinatorMessage) -> AllMessages
fn from(message: DisputeCoordinatorMessage) -> AllMessages
source§impl From<DisputeCoordinatorMessage> for ApprovalVotingOutgoingMessages
impl From<DisputeCoordinatorMessage> for ApprovalVotingOutgoingMessages
source§fn from(message: DisputeCoordinatorMessage) -> ApprovalVotingOutgoingMessages
fn from(message: DisputeCoordinatorMessage) -> ApprovalVotingOutgoingMessages
source§impl From<DisputeCoordinatorMessage> for DisputeDistributionOutgoingMessages
impl From<DisputeCoordinatorMessage> for DisputeDistributionOutgoingMessages
source§fn from(
message: DisputeCoordinatorMessage
) -> DisputeDistributionOutgoingMessages
fn from( message: DisputeCoordinatorMessage ) -> DisputeDistributionOutgoingMessages
source§impl From<DisputeCoordinatorMessage> for ProvisionerOutgoingMessages
impl From<DisputeCoordinatorMessage> for ProvisionerOutgoingMessages
source§fn from(message: DisputeCoordinatorMessage) -> ProvisionerOutgoingMessages
fn from(message: DisputeCoordinatorMessage) -> ProvisionerOutgoingMessages
Auto Trait Implementations§
impl !RefUnwindSafe for DisputeCoordinatorMessage
impl Send for DisputeCoordinatorMessage
impl Sync for DisputeCoordinatorMessage
impl Unpin for DisputeCoordinatorMessage
impl !UnwindSafe for DisputeCoordinatorMessage
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
source§impl<T> CheckedConversion for T
impl<T> CheckedConversion for T
source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere T: Any,
source§fn into_any(self: Box<T, Global>) -> Box<dyn Any, Global>
fn into_any(self: Box<T, Global>) -> Box<dyn Any, Global>
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
.source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.source§impl<T> FmtForward for T
impl<T> FmtForward for T
source§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.source§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.source§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.source§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.source§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.source§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.source§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.source§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.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T, Outer> IsWrappedBy<Outer> for Twhere
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,
impl<T, Outer> IsWrappedBy<Outer> for Twhere Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,
source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere T: ?Sized,
source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere Self: Sized,
source§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 moresource§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 moresource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere
Self: Borrow<B>,
B: 'a + ?Sized,
R: 'a,
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> Rwhere Self: Borrow<B>, B: 'a + ?Sized, R: 'a,
source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> Rwhere
Self: BorrowMut<B>,
B: 'a + ?Sized,
R: 'a,
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> Rwhere Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,
source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere
Self: AsRef<U>,
U: 'a + ?Sized,
R: 'a,
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> Rwhere Self: AsRef<U>, U: 'a + ?Sized, R: 'a,
self
, then passes self.as_ref()
into the pipe function.source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere
Self: AsMut<U>,
U: 'a + ?Sized,
R: 'a,
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> Rwhere Self: AsMut<U>, U: 'a + ?Sized, R: 'a,
self
, then passes self.as_mut()
into the pipe
function.source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
source§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere Self: UniqueSaturatedFrom<T>,
source§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere Self: UniqueSaturatedInto<T>,
T
. Read moresource§impl<T> Tap for T
impl<T> Tap for T
source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Selfwhere Self: Borrow<B>, B: ?Sized,
Borrow<B>
of a value. Read moresource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere Self: BorrowMut<B>, B: ?Sized,
BorrowMut<B>
of a value. Read moresource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Selfwhere Self: AsRef<R>, R: ?Sized,
AsRef<R>
view of a value. Read moresource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere Self: AsMut<R>, R: ?Sized,
AsMut<R>
view of a value. Read moresource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Selfwhere
Self: Deref<Target = T>,
T: ?Sized,
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Selfwhere Self: Deref<Target = T>, T: ?Sized,
Deref::Target
of a value. Read moresource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere
Self: DerefMut<Target = T> + Deref,
T: ?Sized,
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Selfwhere Self: DerefMut<Target = T> + Deref, T: ?Sized,
Deref::Target
of a value. Read moresource§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.source§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.source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Selfwhere
Self: Borrow<B>,
B: ?Sized,
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Selfwhere Self: Borrow<B>, B: ?Sized,
.tap_borrow()
only in debug builds, and is erased in release
builds.source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere
Self: BorrowMut<B>,
B: ?Sized,
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Selfwhere Self: BorrowMut<B>, B: ?Sized,
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Selfwhere
Self: AsRef<R>,
R: ?Sized,
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Selfwhere Self: AsRef<R>, R: ?Sized,
.tap_ref()
only in debug builds, and is erased in release
builds.source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere
Self: AsMut<R>,
R: ?Sized,
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Selfwhere Self: AsMut<R>, R: ?Sized,
.tap_ref_mut()
only in debug builds, and is erased in release
builds.source§impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
impl<S, T> UncheckedInto<T> for Swhere T: UncheckedFrom<S>,
source§fn unchecked_into(self) -> T
fn unchecked_into(self) -> T
unchecked_from
.source§impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,
impl<T, S> UniqueSaturatedInto<T> for Swhere T: Bounded, S: TryInto<T>,
source§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
T
.