Function timely_communication::allocator::zero_copy::initialize::initialize_networking_from_sockets

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

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.