Remove windows specific smoke test
This commit is contained in:
parent
b4c4cab666
commit
086abc83f9
73
src/lib.rs
73
src/lib.rs
|
@ -276,79 +276,6 @@ impl AsyncWrite for IpcStream {
|
|||
}
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
#[cfg(windows)]
|
||||
mod tests {
|
||||
extern crate rand;
|
||||
|
||||
use std::thread;
|
||||
use tokio_core::reactor::Core;
|
||||
use tokio_core::io::{self, Io};
|
||||
use futures::{Stream, Future};
|
||||
|
||||
use super::Endpoint;
|
||||
|
||||
fn random_pipe_path() -> String {
|
||||
let num: u64 = self::rand::Rng::gen(&mut rand::thread_rng());
|
||||
format!(r"\\.\pipe\my-pipe-{}", num)
|
||||
}
|
||||
|
||||
pub fn dummy_request(addr: &str, buf: &[u8]) -> Vec<u8> {
|
||||
use miow;
|
||||
use std::io::{Read, Write};
|
||||
use std::fs::OpenOptions;
|
||||
|
||||
miow::pipe::NamedPipe::wait(addr, None).unwrap();
|
||||
let mut f = OpenOptions::new().read(true).write(true).open(addr).unwrap();
|
||||
trace!("Connected");
|
||||
f.write_all(buf).unwrap();
|
||||
f.flush().unwrap();
|
||||
trace!("Wrote");
|
||||
|
||||
let mut buf = vec![0u8; 65536];
|
||||
let sz = f.read(&mut buf).unwrap_or_else(|_| { 0 });
|
||||
(&buf[0..sz]).to_vec()
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn win_smoky() {
|
||||
let path = random_pipe_path(); let path2 = path.clone();
|
||||
|
||||
thread::spawn(move || {
|
||||
let mut core = Core::new().expect("Server event loop should start ok");
|
||||
let endpoint = Endpoint::new(path, &core.handle()).expect("Should be created");
|
||||
let srv = endpoint.incoming()
|
||||
.for_each(|(stream, _)| {
|
||||
trace!("Created connection");
|
||||
let (reader, writer) = stream.split();
|
||||
let buf = [0u8; 6];
|
||||
io::read_exact(reader, buf).and_then(move |(_reader, _buf)| {
|
||||
let mut reply = Vec::new();
|
||||
reply.extend(&_buf[..]);
|
||||
reply.extend(b" - Ok");
|
||||
io::write_all(writer, reply)
|
||||
})
|
||||
.map_err(|e| { trace!("io error: {:?}", e); e })
|
||||
.map(|_| ())
|
||||
; })
|
||||
.map(|_| ())
|
||||
.map_err(|e|{ trace!("io error: {:?}", e); () })
|
||||
.boxed();
|
||||
|
||||
core.run(srv).expect("Server event loop should finish ok");
|
||||
});
|
||||
thread::sleep(::std::time::Duration::from_millis(50));
|
||||
|
||||
let res = dummy_request(&path2, b"Space1");
|
||||
assert_eq!(res, b"Space1 - Ok");
|
||||
|
||||
let res = dummy_request(&path2, b"Space2");
|
||||
assert_eq!(res, b"Space2 - Ok");
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
extern crate rand;
|
||||
|
|
Loading…
Reference in New Issue