Function timely::communication::allocator::zero_copy::initialize::initialize_networking_from_sockets [−][src]
pub fn initialize_networking_from_sockets(
sockets: Vec<Option<TcpStream>, Global>,
my_index: usize,
threads: usize,
log_sender: Box<dyn Fn(CommunicationSetup) + 'static + Sync + Send, Global>
) -> Result<(Vec<TcpBuilder<ProcessBuilder>, Global>, CommsGuard), Error>
Initialize send and recv threads from sockets.
This method is available for users who have already connected sockets and simply wish to construct a vector of process-local allocators connected to instantiated send and recv threads.
It is important that the sockets
argument contain sockets for each remote process, in order, and
with position my_index
set to None
.