Struct timely_communication::allocator::binary::Binary

pub struct Binary {
    pub inner: Process,
    pub index: usize,
    pub peers: usize,
    pub allocated: usize,
    pub readers: Vec<Sender<((usize, usize), Sender<Vec<u8>>)>>,
    pub senders: Vec<Sender<(MessageHeader, Vec<u8>)>>,
    pub log_sender: Arc<Fn(CommsSetup) -> CommsLogger + Send + Sync>,
}

Fields

inner: Process

index: usize

peers: usize

allocated: usize

readers: Vec<Sender<((usize, usize), Sender<Vec<u8>>)>>

senders: Vec<Sender<(MessageHeader, Vec<u8>)>>

log_sender: Arc<Fn(CommsSetup) -> CommsLogger + Send + Sync>

Methods

impl Binary

pub fn inner<'a>(&'a mut self) -> &'a mut Process

Trait Implementations

impl Allocate for Binary

fn index(&self) -> usize

The index of the worker out of (0..self.peers()).

fn peers(&self) -> usize

The number of workers.

fn allocate<T: Data>(
    &mut self
) -> (Vec<Box<Push<T>>>, Box<Pull<T>>, Option<usize>)

Constructs several send endpoints and one receive endpoint.