Implement AsFd for all fd types

rt/src/fs/mod.rs

@@ -2,6 +2,7 @@
 //!
 //! To open a [`File`] use [`File::open`] or [`OpenOptions`].
 
+use std::os::fd::{AsFd, BorrowedFd};
 use std::path::PathBuf;
 use std::time::SystemTime;
 use std::{fmt, io};
@@ -231,6 +232,12 @@ impl File {
 impl_read!(File, &File);
 impl_write!(File, &File);
 
+impl AsFd for File {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 impl fmt::Debug for File {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.fd.fmt(f)

rt/src/fs/watch.rs

@@ -84,7 +84,7 @@ use std::borrow::Cow;
 use std::collections::HashMap;
 use std::ffi::{CString, OsStr, OsString};
 use std::mem::{size_of, take};
-use std::os::fd::{AsFd, AsRawFd, RawFd};
+use std::os::fd::{AsFd, AsRawFd, BorrowedFd, RawFd};
 use std::path::{Path, PathBuf};
 use std::{fmt, io, ptr};
 
@@ -191,6 +191,12 @@ impl Watch {
     }
 }
 
+impl AsFd for Watch {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 /// Iterator behind [`Watch::events`].
 pub struct Events<'w> {
     /// `Watch::Watching`.

rt/src/net/tcp/listener.rs

@@ -2,6 +2,7 @@
 
 use std::async_iter::AsyncIterator;
 use std::net::SocketAddr;
+use std::os::fd::{AsFd, BorrowedFd};
 use std::pin::Pin;
 use std::task::{self, Poll};
 use std::{fmt, io};
@@ -239,6 +240,12 @@ impl<'a> AsyncIterator for Incoming<'a> {
     }
 }
 
+impl AsFd for TcpListener {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 impl fmt::Debug for TcpListener {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.fd.fmt(f)

rt/src/net/tcp/stream.rs

@@ -2,6 +2,7 @@
 
 use std::io;
 use std::net::{Shutdown, SocketAddr};
+use std::os::fd::{AsFd, BorrowedFd};
 
 use a10::{AsyncFd, Extract};
 use socket2::{Domain, Protocol, SockRef, Type};
@@ -375,3 +376,9 @@ impl TcpStream {
 
 impl_read!(TcpStream, &TcpStream);
 impl_write!(TcpStream, &TcpStream);
+
+impl AsFd for TcpStream {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}

rt/src/net/udp.rs

@@ -4,6 +4,7 @@
 
 use std::marker::PhantomData;
 use std::net::SocketAddr;
+use std::os::fd::{AsFd, BorrowedFd};
 use std::{fmt, io};
 
 use a10::{AsyncFd, Extract};
@@ -287,6 +288,12 @@ impl UdpSocket<Connected> {
     }
 }
 
+impl<M> AsFd for UdpSocket<M> {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 impl<M> fmt::Debug for UdpSocket<M> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.fd.fmt(f)

rt/src/net/uds/datagram.rs

@@ -2,7 +2,7 @@
 
 use std::marker::PhantomData;
 use std::net::Shutdown;
-use std::os::fd::IntoRawFd;
+use std::os::fd::{AsFd, BorrowedFd, IntoRawFd};
 use std::{fmt, io};
 
 use a10::{AsyncFd, Extract};
@@ -267,6 +267,12 @@ impl UnixDatagram<Connected> {
     }
 }
 
+impl<M> AsFd for UnixDatagram<M> {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 impl<M> fmt::Debug for UnixDatagram<M> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.fd.fmt(f)

rt/src/net/uds/listener.rs

@@ -1,6 +1,7 @@
 //! Module with [`UnixListener`] and related types.
 
 use std::async_iter::AsyncIterator;
+use std::os::fd::{AsFd, BorrowedFd};
 use std::pin::Pin;
 use std::task::{self, Poll};
 use std::{fmt, io};
@@ -215,6 +216,12 @@ impl<'a> AsyncIterator for Incoming<'a> {
     }
 }
 
+impl AsFd for UnixListener {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 impl fmt::Debug for UnixListener {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.fd.fmt(f)

rt/src/net/uds/stream.rs

@@ -2,7 +2,7 @@
 
 use std::io;
 use std::net::Shutdown;
-use std::os::fd::IntoRawFd;
+use std::os::fd::{AsFd, BorrowedFd, IntoRawFd};
 
 use a10::{AsyncFd, Extract};
 use socket2::{Domain, SockRef, Type};
@@ -310,3 +310,9 @@ impl UnixStream {
 
 impl_read!(UnixStream, &UnixStream);
 impl_write!(UnixStream, &UnixStream);
+
+impl AsFd for UnixStream {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}

rt/src/pipe.rs

@@ -86,7 +86,7 @@
 //! ```
 
 use std::io;
-use std::os::fd::{IntoRawFd, RawFd};
+use std::os::fd::{AsFd, BorrowedFd, IntoRawFd, RawFd};
 use std::process::{ChildStderr, ChildStdin, ChildStdout};
 
 use a10::AsyncFd;
@@ -140,6 +140,12 @@ impl Sender {
 
 impl_write!(Sender, &Sender);
 
+impl AsFd for Sender {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}
+
 /// Receiving end of an Unix pipe.
 ///
 /// Created by calling [`new`] or converted from [`ChildStdout`] or
@@ -172,3 +178,9 @@ impl Receiver {
 }
 
 impl_read!(Receiver, &Receiver);
+
+impl AsFd for Receiver {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        self.fd.as_fd()
+    }
+}