Function timely::communication::allocator::zero_copy::initialize::initialize_networking_from_sockets

pub fn initialize_networking_from_sockets(
    sockets: Vec<Option<TcpStream>>, 
    my_index: usize, 
    threads: usize, 
    log_sender: Box<dyn Fn(CommunicationSetup) + 'static + Send + Sync>
) -> Result<(Vec<TcpBuilder<ProcessBuilder>>, 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.