Set write to non-blocking in unix::Client::new

Signed-off-by: Jiahao XU <Jiahao_XU@outlook.com>

Author: NobodyXu

src/unix.rs

@@ -40,6 +40,8 @@ impl Client {
             limit -= n;
         }
 
+        set_nonblocking(client.write.as_raw_fd(), false)?;
+
         Ok(client)
     }
 
@@ -64,14 +66,20 @@ impl Client {
                             return Err(err);
                         }
                     }
-                    _ => return Ok(Client::from_fds(pipes[0], pipes[1])),
+                    _ => {
+                        set_nonblocking(pipes[1], true)?;
+                        return Ok(Client::from_fds(pipes[0], pipes[1]));
+                    }
                 }
             }
         }
 
         cvt(libc::pipe(pipes.as_mut_ptr()))?;
         drop(set_cloexec(pipes[0], true));
         drop(set_cloexec(pipes[1], true));
+
+        set_nonblocking(pipes[1], true)?;
+
         Ok(Client::from_fds(pipes[0], pipes[1]))
     }
 
@@ -334,6 +342,16 @@ fn set_cloexec(fd: c_int, set: bool) -> io::Result<()> {
     }
 }
 
+fn set_nonblocking(fd: c_int, set: bool) -> io::Result<()> {
+    let status_flag = if set { libc::O_NONBLOCK } else { 0 };
+
+    unsafe {
+        cvt(libc::fcntl(fd, libc::F_SETFL, status_flag))?;
+    }
+
+    Ok(())
+}
+
 fn cvt(t: c_int) -> io::Result<c_int> {
     if t == -1 {
         Err(io::Error::last_os_error())