Struct MajorityAckUniformReliableBroadcast 

pub struct MajorityAckUniformReliableBroadcast<P: Clone, L: VolatileLink<Data<P>> = PerfectLink<Data<P>>> { /* private fields */ }

Broadcast with uniform agreement, resting on a correct majority and on nothing else.

Implementations

impl<P: Clone> MajorityAckUniformReliableBroadcast<P, PerfectLink<Data<P>>>

pub fn new( me: NodeId, members: impl IntoIterator<Item = NodeId>, retransmit: Duration, ) -> Self

Broadcast among members, which must include me.

The guarantees hold while more than half of members are correct. There is no timing parameter, because there is no timeout: nothing here waits on a clock.

impl<P: Clone, L: VolatileLink<Data<P>>> MajorityAckUniformReliableBroadcast<P, L>

pub fn with_link( me: NodeId, members: impl IntoIterator<Item = NodeId>, link: L, ) -> Self

Broadcast among members, over the link supplied.

pub fn delivered_count(&self) -> usize

How many distinct messages have been delivered upward.

pub fn pending_count(&self) -> usize

Messages seen but not yet deliverable.

pub fn acknowledged_by( &self, id: BroadcastId, ) -> impl Iterator<Item = NodeId> + '_

Which processes have relayed id, for tests watching the majority form.

pub fn majority(&self) -> usize

How many processes a message must be relayed by before it can be delivered.

Trait Implementations

impl<P: Debug + Clone, L: Debug + VolatileLink<Data<P>>> Debug for MajorityAckUniformReliableBroadcast<P, L>

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

Formats the value using the given formatter.

impl<P: Clone, L> Protocol for MajorityAckUniformReliableBroadcast<P, L>

where L: VolatileLink<Data<P>>,

type Scope = <L as Protocol>::Scope

No scope conditions: this protocol’s guarantees do not lapse. Whatever the link’s guarantees are conditional on. This layer bridges an ending by resending on the establishment that follows.

type Meta = Infallible

Keeps nothing durably: a crash loses everything this protocol knows.

fn on_scope_event(&mut self, scope: L::Scope, cx: &mut ProtoCx<'_, Self>)

Hand the scope ending down to the link. The trait’s default would drop it.

type Cmd = Cmd<P>

Requests from the layer above.

type Ind = Ind<P>

Indications to the layer above — this protocol delivering on its guarantee.

type Msg = <BestEffortBroadcast<Data<P>, L> as Protocol>::Msg

What crosses the wire to a peer running the same protocol.

type Note = Note

The vocabulary in which this protocol narrates its decisions.

type Entry = Infallible

The durable entries this protocol appends: what accumulates.

fn on_cmd(&mut self, Cmd::Broadcast: Cmd<P>, cx: &mut ProtoCx<'_, Self>)

Handle a request from the layer above.

fn on_msg(&mut self, from: NodeId, msg: Msg<P, L>, cx: &mut ProtoCx<'_, Self>)

Handle a message received from from.

fn on_timer(&mut self, id: TimerId, cx: &mut ProtoCx<'_, Self>)

Handle a timer that fired somewhere in this protocol or in what it composes.

fn on_init( &mut self, _cx: &mut Cx<'_, Self::Msg, Self::Ind, Self::Note, Self::Meta, Self::Entry>, )

Begin, on a first start — when nothing has been written down.

fn on_recovery( &mut self, _cx: &mut Cx<'_, Self::Msg, Self::Ind, Self::Note, Self::Meta, Self::Entry>, )

Resume after a crash, reading what survived.