mirror of
https://github.com/ntex-rs/ntex.git
synced 2025-04-03 21:07:39 +03:00
wip
This commit is contained in:
parent
a42137f52c
commit
9de591c399
2 changed files with 3 additions and 1 deletions
|
@ -195,6 +195,7 @@ impl Accept {
|
|||
loop {
|
||||
println!("------- ACCEPT LOOP");
|
||||
if let Err(e) = self.poller.wait(&mut events, None) {
|
||||
println!("------- ACCEPT LOOP ERR: {:?}", e);
|
||||
if e.kind() == io::ErrorKind::Interrupted {
|
||||
continue;
|
||||
} else {
|
||||
|
@ -202,6 +203,7 @@ impl Accept {
|
|||
}
|
||||
}
|
||||
|
||||
println!("------- ACCEPTING");
|
||||
for event in events.iter() {
|
||||
println!("------- ACCEPTED {:?}", event);
|
||||
let readd = self.accept(event.key);
|
||||
|
|
|
@ -457,7 +457,7 @@ async fn test_h2_client_drop() -> io::Result<()> {
|
|||
|
||||
let result = timeout(Millis(250), srv.srequest(Method::GET, "/").send()).await;
|
||||
assert!(result.is_err());
|
||||
sleep(Millis(150)).await;
|
||||
sleep(Millis(250)).await;
|
||||
assert_eq!(count.load(Ordering::Relaxed), 1);
|
||||
Ok(())
|
||||
}
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue