Skip to content

Commit

Permalink
tests: update Nix to 0.22.0 (#3951)
Browse files Browse the repository at this point in the history
  • Loading branch information
asomers authored and hawkw committed Nov 16, 2021
1 parent 75cd90c commit ba3b5bd
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 16 deletions.
2 changes: 1 addition & 1 deletion tokio/Cargo.toml
Expand Up @@ -109,7 +109,7 @@ signal-hook-registry = { version = "1.1.1", optional = true }

[target.'cfg(unix)'.dev-dependencies]
libc = { version = "0.2.42" }
nix = { version = "0.19.0" }
nix = { version = "0.22.0" }

[target.'cfg(windows)'.dependencies.winapi]
version = "0.3.8"
Expand Down
17 changes: 2 additions & 15 deletions tokio/tests/io_async_fd.rs
Expand Up @@ -13,7 +13,6 @@ use std::{
task::{Context, Waker},
};

use nix::errno::Errno;
use nix::unistd::{close, read, write};

use futures::{poll, FutureExt};
Expand Down Expand Up @@ -56,10 +55,6 @@ impl TestWaker {
}
}

fn is_blocking(e: &nix::Error) -> bool {
Some(Errno::EAGAIN) == e.as_errno()
}

#[derive(Debug)]
struct FileDescriptor {
fd: RawFd,
Expand All @@ -73,11 +68,7 @@ impl AsRawFd for FileDescriptor {

impl Read for &FileDescriptor {
fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
match read(self.fd, buf) {
Ok(n) => Ok(n),
Err(e) if is_blocking(&e) => Err(ErrorKind::WouldBlock.into()),
Err(e) => Err(io::Error::new(ErrorKind::Other, e)),
}
read(self.fd, buf).map_err(io::Error::from)
}
}

Expand All @@ -89,11 +80,7 @@ impl Read for FileDescriptor {

impl Write for &FileDescriptor {
fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
match write(self.fd, buf) {
Ok(n) => Ok(n),
Err(e) if is_blocking(&e) => Err(ErrorKind::WouldBlock.into()),
Err(e) => Err(io::Error::new(ErrorKind::Other, e)),
}
write(self.fd, buf).map_err(io::Error::from)
}

fn flush(&mut self) -> io::Result<()> {
Expand Down

0 comments on commit ba3b5bd

Please sign in to comment.