Struct tcb::vv::middleware::version_vector::VV

pub struct VV {
    pub V: VersionVector,
    pub R: VersionVector,
    pub DQ: Vec<QueueNode>,
    pub M: Vec<VersionVector>,
    pub M_entry_row_num: VersionVector,
    pub SV: VersionVector,
    pub SMap: HashMap<Dot, StableDot>,
    pub ctr: usize,
    pub peer_index: usize,
    pub client: Sender<MiddlewareClient>,
    pub configuration: Arc<Configuration>,
    pub peer_number: usize,
}

Implementation of the causal delivery algorithm.

Fields

V: VersionVector

R: VersionVector

DQ: Vec<QueueNode>

M: Vec<VersionVector>

M_entry_row_num: VersionVector

SV: VersionVector

SMap: HashMap<Dot, StableDot>

ctr: usize

peer_index: usize

client: Sender<MiddlewareClient>

configuration: Arc<Configuration>

peer_number: usize

Implementations

impl VV

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

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

Arguments

peer_number - Number of peers in the group.

peer_index - Local peer's globally unique id.

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, j: usize, message: Message)

Handles a message received from a peer via broadcast.

Arguments

j - Sender id

message - Message received from a peer in the group.