Struct Channels 

pub struct Channels { /* private fields */ }

The communication channels for one party. These also keep track of how many bytes are sent.

Implementations

impl Channels

pub fn new( id: usize, senders: Vec<Sender<Message>>, receiver: Receiver<Message>, latency: Duration, seconds_per_byte: Duration, ) -> Self

Contructs a new channel with communication overhead.

pub fn receive(&mut self, from_id: &usize) -> DelayedByteIterator

Blocks until this party receives a message from the party with from_id. A message is a vector of bytes Vec<u8>. This can be achieved for example using bincode serialization. The simulated delays are planned in such a way that they mimick the given bandwidth and latency constraints in the case where messages are scheduled optimally.

pub fn send(&mut self, message: &[u8], to_id: &usize)

Sends a vector of bytes to the party with to_id and keeps track of the number of bits sent to this party.

pub fn broadcast(&mut self, message: &[u8])

Broadcasts a message (a vector of bytes) to all parties and keeps track of the number of bits sent.