summaryrefslogtreecommitdiff
path: root/src/fuse
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/fuse/mount.rs5
-rw-r--r--src/fuse/session.rs12
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 {