DXR is a code search and navigation tool aimed at making sense of large projects. It supports full-text and regex searches as well as structural queries.

Mercurial (3dc70a33491f)

VCS Links

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42
extern crate tokio;
extern crate futures;

use std::thread;
use std::net;

use futures::future;
use futures::prelude::*;
use futures::sync::oneshot;
use tokio::net::TcpListener;
use tokio::reactor::Reactor;

#[test]
fn tcp_doesnt_block() {
    let core = Reactor::new().unwrap();
    let handle = core.handle();
    let listener = net::TcpListener::bind("127.0.0.1:0").unwrap();
    let listener = TcpListener::from_std(listener, &handle).unwrap();
    drop(core);
    assert!(listener.incoming().wait().next().unwrap().is_err());
}

#[test]
fn drop_wakes() {
    let core = Reactor::new().unwrap();
    let handle = core.handle();
    let listener = net::TcpListener::bind("127.0.0.1:0").unwrap();
    let listener = TcpListener::from_std(listener, &handle).unwrap();
    let (tx, rx) = oneshot::channel::<()>();
    let t = thread::spawn(move || {
        let incoming = listener.incoming();
        let new_socket = incoming.into_future().map_err(|_| ());
        let drop_tx = future::lazy(|| {
            drop(tx);
            future::ok(())
        });
        assert!(new_socket.join(drop_tx).wait().is_err());
    });
    drop(rx.wait());
    drop(core);
    t.join().unwrap();
}