Struct BroadcastNetwork 

pub struct BroadcastNetwork {
    broadcasters: HashMap<String, Broadcaster>,
    message_queue: VecDeque<(String, String, BroadcastMessage)>,
}

Simulates a network of broadcasters for testing.

Fields

broadcasters: HashMap<String, Broadcaster>

Broadcasters indexed by replica ID.

message_queue: VecDeque<(String, String, BroadcastMessage)>

Message queue: (from, to, message).

Implementations

impl BroadcastNetwork

pub fn fully_connected(n: usize) -> Self

Create a fully connected network of n replicas.

pub fn broadcast(&mut self, from: &str, heads: Vec<Hash>)

Broadcast heads from a replica.

fn collect_send_events(&mut self, from: &str)

Collect send events and add to message queue. Only extracts Send events, leaving HeadsReceived events in place.

pub fn deliver_one(&mut self) -> bool

Deliver the next message in the queue.

pub fn deliver_all(&mut self)

Deliver all pending messages.

pub fn broadcaster(&self, id: &str) -> Option<&Broadcaster>

Get a broadcaster by replica ID.

pub fn broadcaster_mut(&mut self, id: &str) -> Option<&mut Broadcaster>

Get a mutable broadcaster by replica ID.

pub fn received_heads(&mut self, id: &str) -> Vec<Hash>

Get all received heads for a replica.

pub fn pending_messages(&self) -> usize

Check how many messages are pending.