diff options
Diffstat (limited to '')
| -rw-r--r-- | src/fuse/mount.rs | 5 | ||||
| -rw-r--r-- | src/fuse/session.rs | 12 |
2 files changed, 10 insertions, 7 deletions
diff --git a/src/fuse/mount.rs b/src/fuse/mount.rs index ebf7e5d..955b28a 100644 --- a/src/fuse/mount.rs +++ b/src/fuse/mount.rs @@ -1,5 +1,6 @@ use std::{ ffi::{OsStr, OsString}, + io, os::unix::{ ffi::OsStrExt, io::{AsRawFd, IntoRawFd, RawFd}, @@ -17,7 +18,7 @@ use nix::{ use quick_error::quick_error; use super::Start; -use crate::util::{from_nix_error, DumbFd}; +use crate::util::DumbFd; quick_error! { #[derive(Debug)] @@ -131,7 +132,7 @@ where Some(&mut buffer), MsgFlags::empty(), ) - .map_err(from_nix_error)?; + .map_err(io::Error::from)?; let session_fd = match message.cmsgs().next() { Some(ControlMessageOwned::ScmRights(fds)) => fds.into_iter().next(), diff --git a/src/fuse/session.rs b/src/fuse/session.rs index 35ebb69..4a34aae 100644 --- a/src/fuse/session.rs +++ b/src/fuse/session.rs @@ -1,7 +1,8 @@ use std::{ collections::{hash_map, HashMap}, convert::TryInto, - os::unix::io::IntoRawFd, + io, + os::unix::io::{IntoRawFd, RawFd}, sync::{Arc, Mutex}, }; @@ -21,7 +22,7 @@ use smallvec::SmallVec; use crate::{ proto::{self, InHeader}, - util::{display_or, from_nix_error, OutputChain}, + util::{display_or, OutputChain}, Errno, FuseError, FuseResult, Ino, }; @@ -140,7 +141,7 @@ impl<Fs: Fuse> Session<Fs> { IoVec::from_mut_slice(large_buffer), ]; - let bytes = readv(*self.session_fd.get_ref(), &mut io_vecs).map_err(from_nix_error)?; + let bytes = readv(*self.session_fd.get_ref(), &mut io_vecs).map_err(io::Error::from)?; InputBuffer { bytes, data } }; @@ -429,7 +430,8 @@ impl<Fs: Fuse> Session<Fs> { IoVec::from_mut_slice(&mut large_buffer[SBO_SIZE..]), ]; - match readable.try_io(|fd| readv(*fd.get_ref(), &mut io_vecs).map_err(from_nix_error)) { + let mut read = |fd: &AsyncFd<RawFd>| readv(*fd.get_ref(), &mut io_vecs); + match readable.try_io(|fd| read(fd).map_err(io::Error::from)) { Ok(Ok(bytes)) => { if bytes > SBO_SIZE { (&mut large_buffer[..SBO_SIZE]).copy_from_slice(sbo); @@ -479,7 +481,7 @@ impl<Fs: Fuse> Session<Fs> { .map(IoVec::from_slice) .collect(); - let written = writev(*self.session_fd.get_ref(), &buffers).map_err(from_nix_error)?; + let written = writev(*self.session_fd.get_ref(), &buffers).map_err(io::Error::from)?; if written == length as usize { Ok(()) } else { |
