forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore(windows): poll core again to drop window socket

Browse Source
This commit is contained in:
Sean McArthur
2017-12-18 16:53:45 -08:00
parent 7d3abfbcf3
commit 5d5045d698
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tests/server.rs
View File

@@ -11,7 +11,7 @@ use futures::future::{self, FutureResult, Either};
use futures::sync::oneshot; use futures::sync::oneshot;
use tokio_core::net::TcpListener; use tokio_core::net::TcpListener;
use tokio_core::reactor::Core; use tokio_core::reactor::{Core, Timeout};
use tokio_io::{AsyncRead, AsyncWrite}; use tokio_io::{AsyncRead, AsyncWrite};
use std::net::{TcpStream, SocketAddr}; use std::net::{TcpStream, SocketAddr};
@@ -658,6 +658,12 @@ fn disable_keep_alive_post_request() {
assert!(!dropped.load()); assert!(!dropped.load());
core.run(fut).unwrap(); core.run(fut).unwrap();
// we must poll the Core one more time in order for Windows to drop
// the read-blocked socket.
//
// See https://github.com/carllerche/mio/issues/776
let timeout = Timeout::new(Duration::from_millis(10), &core.handle()).unwrap();
core.run(timeout).unwrap();
assert!(dropped.load()); assert!(dropped.load());
child.join().unwrap(); child.join().unwrap();
} }