chore: update rustix dependency

Cargo.toml

@@ -23,7 +23,7 @@ ssh2 = { version = "0.9.1", optional = true }
 #socket2 = { version = "0.4.0", optional = true }
 
 [target.'cfg(not(windows))'.dependencies]
-rustix = { version = "0.38.0", features = ["fs", "net"] }
+rustix = { version = "1.1.4", features = ["fs", "net"] }
 
 [target.'cfg(windows)'.dependencies]
 cap-std = "3.0.0"

src/fs/file_io_ext.rs

@@ -23,6 +23,15 @@ use rustix::fs::{fallocate, FallocateFlags};
 #[cfg(not(any(windows, target_os = "ios", target_os = "macos", target_os = "redox")))]
 use rustix::io::{preadv, pwritev};
 use std::io::{self, IoSlice, IoSliceMut, Seek, SeekFrom};
+#[cfg(not(any(
+    windows,
+    target_os = "ios",
+    target_os = "macos",
+    target_os = "netbsd",
+    target_os = "openbsd",
+    target_os = "redox",
+)))]
+use std::num::NonZeroU64;
 use std::slice;
 #[cfg(windows)]
 use {cap_fs_ext::Reopen, std::fs, std::os::windows::fs::FileExt};
@@ -420,7 +429,7 @@ impl<T: AsFilelike + IoExt> FileIoExt for T {
             Advice::Random => rustix::fs::Advice::Random,
             Advice::DontNeed => rustix::fs::Advice::DontNeed,
         };
-        Ok(fadvise(self, offset, len, advice)?)
+        Ok(fadvise(self, offset, NonZeroU64::new(len), advice)?)
     }
 
     #[cfg(any(target_os = "ios", target_os = "macos"))]
@@ -529,7 +538,7 @@ impl<T: AsFilelike + IoExt> FileIoExt for T {
         use rustix::io::write;
 
         // On Linux, use `pwritev2`.
-        #[cfg(any(target_os = "android", target_os = "linux"))]
+        #[cfg(target_os = "linux")]
         {
             use rustix::io::{pwritev2, Errno, ReadWriteFlags};
 
@@ -562,7 +571,7 @@ impl<T: AsFilelike + IoExt> FileIoExt for T {
         use rustix::io::writev;
 
         // On Linux, use `pwritev2`.
-        #[cfg(any(target_os = "android", target_os = "linux"))]
+        #[cfg(target_os = "linux")]
         {
             use rustix::io::{pwritev2, Errno, ReadWriteFlags};
 

src/io/is_read_write.rs

@@ -1,6 +1,13 @@
 use std::io;
 #[cfg(not(windows))]
-use {io_lifetimes::AsFilelike, rustix::io::is_read_write};
+use {
+    io_lifetimes::AsFilelike,
+    rustix::{
+        fs::{fcntl_getfl, OFlags},
+        io::Errno,
+        net::{recv, send, RecvFlags, SendFlags},
+    },
+};
 #[cfg(windows)]
 use {
     std::{
@@ -22,7 +29,60 @@ pub trait IsReadWrite {
 impl<T: AsFilelike> IsReadWrite for T {
     #[inline]
     fn is_read_write(&self) -> io::Result<(bool, bool)> {
-        Ok(is_read_write(self)?)
+        is_read_write(self)
+    }
+}
+
+#[cfg(not(windows))]
+#[inline]
+fn is_read_write<Fd: AsFilelike>(fd: Fd) -> io::Result<(bool, bool)> {
+    let (mut read, mut write) = is_file_read_write(&fd)?;
+    let mut not_socket = false;
+
+    if read {
+        let mut buf = [0_u8; 1];
+        match recv(&fd, &mut buf, RecvFlags::PEEK | RecvFlags::DONTWAIT) {
+            Ok((0, _)) => read = false,
+            Ok(_) => (),
+            Err(err) if err == Errno::AGAIN || err == Errno::WOULDBLOCK => (),
+            Err(Errno::NOTSOCK) => not_socket = true,
+            Err(err) => return Err(err.into()),
+        }
+    }
+
+    if write && !not_socket {
+        match send(&fd, &[], SendFlags::DONTWAIT) {
+            Ok(_) => (),
+            Err(err)
+                if err == Errno::AGAIN || err == Errno::WOULDBLOCK || err == Errno::NOTSOCK => {}
+            Err(Errno::PIPE) => write = false,
+            Err(err) => return Err(err.into()),
+        }
+    }
+
+    Ok((read, write))
+}
+
+#[cfg(not(windows))]
+#[inline]
+fn is_file_read_write<Fd: AsFilelike>(fd: Fd) -> io::Result<(bool, bool)> {
+    let mode = fcntl_getfl(fd)?;
+
+    #[cfg(any(
+        target_os = "android",
+        target_os = "emscripten",
+        target_os = "fuchsia",
+        target_os = "linux"
+    ))]
+    if mode.contains(OFlags::PATH) {
+        return Ok((false, false));
+    }
+
+    match mode & OFlags::RWMODE {
+        OFlags::RDONLY => Ok((true, false)),
+        OFlags::RDWR => Ok((true, true)),
+        OFlags::WRONLY => Ok((false, true)),
+        _ => unreachable!(),
     }
 }