[][src]Function tdiag_connect::receive::open_sockets

pub fn open_sockets(
    ip_addr: IpAddr,
    port: u16,
    source_peers: usize
) -> Result<Vec<Option<TcpStream>>, ConnectError>

Listens on 127.0.0.1:8000 and opens source_peers sockets from the computations we're examining (one socket for every worker on the examined computation).

The sockets are wrapped in Some(_) because the result is commonly used as a an argument to make_readers in this module.

The sockets are returned in nonblocking mode.