Skip to main content

initialize_networking_inner

mz_cluster::communication

Function initialize_networking_inner 

Source 
fn initialize_networking_inner<S>(
    sockets: Vec<Option<S>>,
    process: usize,
    workers: usize,
    refill: BytesRefill,
    enable_zero_copy_binary: bool,
) -> Result<(Vec<AllocatorBuilder>, Box<dyn Any + Send>), Error>
where
    S: Stream + 'static,