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

pub fn initialize_networking_from_sockets<S>(
    sockets: Vec<Option<S>>,
    my_index: usize,
    threads: usize,
    log_sender: Arc<dyn Fn(CommunicationSetup) -> Option<Logger<CommunicationEvent>> + Sync + Send>,
) -> Result<(Vec<TcpBuilder<ProcessBuilder>>, CommsGuard), Error>
where
    S: Stream + 'static,

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.