Merge pull request #5082 from Gerharddc/tuntap-update

embassy-net-tuntap: update async-io

1 files changed, 10 insertions, 2 deletions

diff --git a/embassy-net-tuntap/src/lib.rs b/embassy-net-tuntap/src/lib.rs
index 2ff23f462..33a251248 100644
--- a/embassy-net-tuntap/src/lib.rs
+++ b/embassy-net-tuntap/src/lib.rs
@@ -2,7 +2,9 @@
 #![doc = include_str!("../README.md")]
 use std::io;
 use std::io::{Read, Write};
+use std::os::fd::AsFd;
 use std::os::unix::io::{AsRawFd, RawFd};
+use std::os::unix::prelude::BorrowedFd;
 use std::task::Context;
 
 use async_io::Async;
@@ -69,6 +71,12 @@ impl AsRawFd for TunTap {
     }
 }
 
+impl AsFd for TunTap {
+    fn as_fd(&self) -> BorrowedFd<'_> {
+        unsafe { BorrowedFd::borrow_raw(self.fd) }
+    }
+}
+
 impl TunTap {
     /// Create a new TUN/TAP device.
     pub fn new(name: &str) -> io::Result<TunTap> {
@@ -164,7 +172,7 @@ impl Driver for TunTapDevice {
     fn receive(&mut self, cx: &mut Context) -> Option<(Self::RxToken<'_>, Self::TxToken<'_>)> {
         let mut buf = vec![0; self.device.get_ref().mtu];
         loop {
-            match self.device.get_mut().read(&mut buf) {
+            match unsafe { self.device.get_mut() }.read(&mut buf) {
                 Ok(n) => {
                     buf.truncate(n);
                     return Some((
@@ -233,7 +241,7 @@ impl<'a> embassy_net_driver::TxToken for TxToken<'a> {
         let result = f(&mut buffer);
 
         // todo handle WouldBlock with async
-        match self.device.get_mut().write(&buffer) {
+        match unsafe { self.device.get_mut() }.write(&buffer) {
             Ok(_) => {}
             Err(e) if e.kind() == io::ErrorKind::WouldBlock => info!("transmit WouldBlock"),
             Err(e) => panic!("transmit error: {:?}", e),