diff --git a/src/test/net.rs b/src/test/net.rs deleted file mode 100644 index e4db1629f0f0931ce18ed684d655800e9e990a24..0000000000000000000000000000000000000000 --- a/src/test/net.rs +++ /dev/null @@ -1,42 +0,0 @@ -use mio::*; -use std::io::ErrorKind::WouldBlock; -use std::net::SocketAddr; - -fn connection_testing_read( - stream: &mut mio::net::TcpStream, - inbox: &mut Vec, -) -> std::io::Result<()> { - assert!(inbox.is_empty()); - use std::io::Read; - match stream.read_to_end(inbox) { - Ok(0) => unreachable!("Ok(0) on read should return Err instead!"), - Ok(_) => Ok(()), - Err(e) if e.kind() == WouldBlock => Ok(()), - Err(e) => Err(e), - } -} - -#[test] -fn mio_tcp_connect_err() { - let poll = Poll::new().unwrap(); - let mut events = Events::with_capacity(64); - - let addr: SocketAddr = "127.0.0.1:12000".parse().unwrap(); - let mut stream = mio::net::TcpStream::connect(&addr).unwrap(); - poll.register(&stream, Token(0), Ready::all(), PollOpt::edge()).unwrap(); - - let mut v = vec![]; - loop { - poll.poll(&mut events, Some(std::time::Duration::from_secs(2))).unwrap(); - for event in events.iter() { - assert_eq!(event.token(), Token(0)); - println!("readiness {:?}", event.readiness()); - // assert_eq!(event.readiness(), Ready::writable()); - - v.clear(); - println!("{:?}", connection_testing_read(&mut stream, &mut v)); - println!("----------- {:?}", &v); - std::thread::sleep(std::time::Duration::from_secs(1)); - } - } -}