From aec37fce450d384fe26c03254f0d3f6dd006f528 Mon Sep 17 00:00:00 2001
From: Anatoly Ikorsky <aikorsky@gmail.com>
Date: Sat, 6 Apr 2019 06:52:00 -0700
Subject: [PATCH] Add test for read/write with zero timeout

---
 src/lib.rs | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 51 insertions(+)

diff --git a/src/lib.rs b/src/lib.rs
index 7a037570..c195c651 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -1681,3 +1681,54 @@ fn cancel_io_server_write_on_timeout() {
 
     handle.join().unwrap();
 }
+
+#[test]
+fn zero_timeout_read() {
+    use std::io::{BufRead, BufReader, ErrorKind, Write};
+    use std::sync::{atomic::{AtomicBool, Ordering}, Arc};
+
+    let read_timeout = Arc::new(AtomicBool::new(false));
+
+    let handle = ::std::thread::spawn({
+        let read_timeout = read_timeout.clone();
+        move || {
+            let server = PipeOptions::new(r"\\.\pipe\ztimeout").single().unwrap();
+            let mut server = server.wait().unwrap();
+            server.set_write_timeout(Some(Duration::from_millis(0)));
+            loop {
+                match server.write(b"line\n") {
+                    Ok(_) => (),
+                    Err(ref err)
+                        if err.kind() == ErrorKind::TimedOut =>
+                    {
+                        if read_timeout.load(Ordering::Relaxed) {
+                            server.disconnect().unwrap();
+                            break;
+                        }
+                    }
+                    Err(err) => panic!("Write error: {:?}", err),
+                }
+            }
+        }
+    });
+
+    ::std::thread::sleep(Duration::from_secs(1));
+
+    let mut client = PipeClient::connect(r"\\.\pipe\ztimeout").unwrap();
+    client.set_read_timeout(Some(Duration::from_millis(0)));
+
+    let mut reader = BufReader::new(client);
+    let mut line = String::new();
+    loop {
+        match reader.read_line(&mut line) {
+            Ok(_) => line.clear(),
+            Err(ref err) if err.kind() == ErrorKind::TimedOut => {
+                read_timeout.store(true, Ordering::Relaxed);
+            },
+            Err(ref err) if err.raw_os_error() == Some(233) => break,
+            Err(err) => panic!("Read error: {:?}", err),
+        }
+    }
+
+    handle.join().unwrap();
+}