Function open_sockets

src/sources/timely_logging.rs:195–202

Listens on 127.0.0.1:8000 and opens `source_peers` sockets from the computations we're examining.

(source_peers: usize)

/// Listens on 127.0.0.1:8000 and opens `source_peers` sockets from
/// the computations we're examining.
fn open_sockets(source_peers: usize) -> Arc<Mutex<Vec<Option<TcpStream>>>> {
    let listener = TcpListener::bind("127.0.0.1:8000").unwrap();
    let sockets = (0..source_peers)
        .map(|_| Some(listener.incoming().next().unwrap().unwrap()))
        .collect::<Vec<_>>();

    Arc::new(Mutex::new(sockets))
}

/// Construct replayers that read data from sockets and can stream it
/// into timely dataflow.