Struct tcb::graph::middleware::graph::GRAPH

pub struct GRAPH { /* fields omitted */ }

Implementation of the causal delivery algorithm.

Implementations

impl GRAPH

pub fn new(
    peer_index: usize,
    peer_number: usize,
    client: Sender<ClientMessage>,
    configuration: Arc<Configuration>
) -> GRAPH

Builds a new GRAPH struct that implements the causal delivery algorithm.

Arguments

peer_index - Local peer's globally unique id.

peer_number - Number of peers in the group.

client - Channel between the Middleware and the Peer that will be used to send delivered/stable messages to Peer.

configuration - Middleware's configuration file.

pub fn dequeue(&mut self, message: Message)

Handler for a message sent by the Client to be broadcast. This function adds a message to the causal graph.

Arguments

message - Message received from the Client.

pub fn receive(&mut self, message: Message)

Handles a message received from a peer via broadcast.

Arguments

message - Message received from a peer in the group.

pub fn deletestable(&mut self, dot: Dot)

Softly deletes an acked stable message by marking its position in the array available.

Arguments

dot - Dot acked as stable by the Client.