timely::communication::allocator::zero_copy::initialize

Function initialize_networking

Source 
pub fn initialize_networking<P>(
    addresses: Vec<String>,
    my_index: usize,
    threads: usize,
    noisy: bool,
    refill: BytesRefill,
    log_sender: Arc<dyn Fn(CommunicationSetup) -> Option<Logger<CapacityContainerBuilder<Vec<(Duration, CommunicationEvent)>>>> + Send + Sync>,
) -> Result<(Vec<TcpBuilder<<P as PeerBuilder>::Peer>>, CommsGuard), Error>
where
    P: PeerBuilder,
Expand description

Initializes network connections