[BREAKING] feat: Support passthrough API

.vscode/settings.json

@@ -1,3 +1,3 @@
 {
-    "rust-analyzer.cargo.features": ["serial"]
+    "rust-analyzer.cargo.features": ["serial", "passthrough"]
 }

Cargo.toml

@@ -14,13 +14,13 @@ serial = []
 parallel = ["dep:threadpool"]
 async = ["dep:async-trait", "dep:tokio"]
 deadlock_detection = ["parallel", "dep:parking_lot"]
-
+passthrough = ["fuser/abi-7-40"]
 
 [dependencies]
 # Core dependencies
 log = "0.4"
 libc = "0.2"
-fuser = "0.16"
+fuser = { version = "0.16" }
 bitflags = "2.10"
 
 # Parallel dependencies
@@ -32,10 +32,15 @@ parking_lot = { version = "0.12", features = ["deadlock_detection"], optional =
 # easy_fuser_async_macro = { path = "./easy_fuser_async_macro", optional = true }
 tokio = { version = "1.48", features = ["full"], optional = true }
 async-trait = { version = "0.1.89", optional = true }
+bimap = { version = "0.6.3", features = ["std"] }
 
 [dev-dependencies]
 tempfile = "3.23"
 env_logger = "0.11"
 
 [package.metadata.docs.rs]
 features = ["parallel"]
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/ftp_fs/Cargo.toml

@@ -21,4 +21,8 @@ tempfile = "3.2"
 libunftp = "0.20"
 unftp-sbe-fs = "0.2"
 async-trait = "0.1.68"
-tokio = { version = "1.42", features = ["full"] }
+tokio = { version = "1.42", features = ["full"] }
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/ftp_fs/src/filesystem.rs

@@ -83,8 +83,9 @@ impl FuseHandler<PathBuf> for FtpFs {
         _file_handle: BorrowedFileHandle,
         offset: SeekFrom,
         size: u32,
-        _flags: FUSEOpenFlags,
-        _lock_owner: Option<u64>,
+        _read_flags: FUSEReadFlags,
+        _flags: OpenFlags,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<Vec<u8>> {
         self.with_ftp(|ftp| {
             let mut cursor = ftp.retr_as_buffer(file_id.to_str().unwrap())?;

examples/hello_fs/Cargo.toml

@@ -9,4 +9,8 @@ logging = ["dep:env_logger", "dep:log"]
 [dependencies]
 easy_fuser = { path = "../..", features = ["serial"] }
 log = { version = "0.4", optional = true }
-env_logger = { version = "0.11", optional = true }
+env_logger = { version = "0.11", optional = true }
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/hello_fs/src/main.rs

@@ -33,7 +33,7 @@ const HELLO_DIR_ATTR: (Inode, FileAttribute) = (
 const HELLO_TXT_CONTENT: &str = "Hello World!\n";
 
 const HELLO_TXT_ATTR: (Inode, FileAttribute) = (
-    Inode::from(2),
+    Inode::new(2),
     FileAttribute {
         size: 13,
         blocks: 1,
@@ -110,8 +110,9 @@ impl FuseHandler<Inode> for HelloFS {
         _file_handle: BorrowedFileHandle,
         seek: SeekFrom,
         size: u32,
-        _flags: FUSEOpenFlags,
-        _lock_owner: Option<u64>,
+        _read_flags: FUSEReadFlags,
+        _flags: OpenFlags,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<Vec<u8>> {
         if file_id == HELLO_TXT_ATTR.0 {
             let offset = match seek {

examples/in_memory_fs/Cargo.toml

@@ -11,4 +11,8 @@ logging = ["dep:env_logger", "dep:log"]
 [dependencies]
 easy_fuser = { path = "../..", features = ["parallel"] }
 log = { version = "0.4", optional = true }
-env_logger = { version = "0.11", optional = true }
+env_logger = { version = "0.11", optional = true }
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/in_memory_fs/src/filesystem.rs

@@ -155,11 +155,13 @@ impl FuseHandler<Inode> for InMemoryFS {
         mode: u32,
         _umask: u32,
         _flags: OpenFlags,
+        _helper: CreateHelper<'_>,
     ) -> Result<
         (
             OwnedFileHandle,
             (Inode, FileAttribute),
             FUSEOpenResponseFlags,
+            Option<PassthroughBackingId>,
         ),
         PosixError,
     > {
@@ -204,6 +206,7 @@ impl FuseHandler<Inode> for InMemoryFS {
                 unsafe { OwnedFileHandle::from_raw(0) },
                 (new_inode.clone(), attr),
                 FUSEOpenResponseFlags::empty(),
+                None,
             ))
         } else {
             Err(ErrorKind::FileNotFound.to_error(""))
@@ -260,7 +263,7 @@ impl FuseHandler<Inode> for InMemoryFS {
         _req: &RequestInfo,
         _file_id: Inode,
         _file_handle: BorrowedFileHandle,
-        _lock_owner: u64,
+        _lock_owner: LockOwner,
     ) -> FuseResult<()> {
         Ok(())
     }
@@ -363,8 +366,9 @@ impl FuseHandler<Inode> for InMemoryFS {
         _fh: BorrowedFileHandle,
         offset: SeekFrom,
         size: u32,
-        _flags: FUSEOpenFlags,
-        _lock_owner: Option<u64>,
+        _read_flags: FUSEReadFlags,
+        _flags: OpenFlags,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<Vec<u8>> {
         self.access(req, ino.clone(), AccessMask::CAN_READ)?;
         let fs = self.fs.lock().unwrap();
@@ -579,7 +583,7 @@ impl FuseHandler<Inode> for InMemoryFS {
         data: Vec<u8>,
         _write_flags: FUSEWriteFlags,
         _flags: OpenFlags,
-        _lock_owner: Option<u64>,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<u32> {
         self.access(req, ino.clone(), AccessMask::CAN_WRITE)?;
         let mut fs = self.fs.lock().unwrap();

examples/in_memory_fs/src/main.rs

@@ -1,7 +1,8 @@
 #![doc = include_str!("../README.md")]
 
 use easy_fuser::prelude::*;
-use std::ffi::OsStr;
+use std::fs::File;
+use std::io::Write;
 use std::path::Path;
 
 const README_CONTENT: &[u8] = include_bytes!("../README.md") as &[u8];
@@ -11,38 +12,8 @@ pub use filesystem::InMemoryFS;
 
 fn create_memory_fs() -> InMemoryFS {
     let memoryfs = InMemoryFS::new();
-    #[cfg(feature = "readme")]
-    {
-        // An example of interacting directly with the filesystem
-        let request_info = RequestInfo {
-            id: 0,
-            uid: 0,
-            gid: 0,
-            pid: 0,
-        }; // dummy RequestInfo
-        let (fd, (inode, _), _) = memoryfs
-            .create(
-                &request_info,
-                ROOT_INODE,
-                OsStr::new("README.md"),
-                0o755,
-                0,
-                OpenFlags::empty(),
-            )
-            .unwrap();
-        let _ = memoryfs
-            .write(
-                &request_info,
-                inode,
-                fd.borrow(),
-                SeekFrom::Start(0),
-                README_CONTENT.to_vec(),
-                FUSEWriteFlags::empty(),
-                OpenFlags::empty(),
-                None,
-            )
-            .unwrap();
-    }
+    // NOTE: manual call example here is removed because the [`CreateHelper`]
+    // parameter is not supported
     memoryfs
 }
 
@@ -66,5 +37,15 @@ fn main() {
     let memoryfs = create_memory_fs();
 
     println!("Mounting filesystem...");
-    easy_fuser::mount(memoryfs, Path::new(&mountpoint), &options, 1).unwrap();
+    let session = easy_fuser::spawn_mount(memoryfs, Path::new(&mountpoint), &options, 1).unwrap();
+    // Insert the readme here
+    #[cfg(feature = "readme")]
+    File::create(Path::new(&mountpoint).join("README.md"))
+        .unwrap()
+        .write_all(README_CONTENT)
+        .unwrap();
+    let mut wait_string = String::new();
+    println!("Press Enter to unmount...");
+    std::io::stdin().read_line(&mut wait_string).unwrap();
+    session.unmount_and_join().unwrap();
 }

examples/passthrough_fs/Cargo.toml

@@ -7,4 +7,8 @@ description = "A FUSE passthrough filesystem example using easy_fuser"
 [dependencies]
 easy_fuser = { path = "../..", features = ["parallel"] }
 clap = { version = "4.5", features = ["derive"] }
-ctrlc = "3.4"
+ctrlc = "3.4"
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/random_fs/Cargo.toml

@@ -6,3 +6,7 @@ edition = "2021"
 [dependencies]
 easy_fuser = { path = "../..", features = ["parallel"] }
 rand = "0.8.5"
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/random_fs/src/main.rs

@@ -77,11 +77,13 @@ impl FuseHandler<Inode> for RandomFS {
         _mode: u32,
         _umask: u32,
         _flags: OpenFlags,
+        _helper: CreateHelper<'_>,
     ) -> Result<
         (
             OwnedFileHandle,
             (Inode, FileAttribute),
             FUSEOpenResponseFlags,
+            Option<PassthroughBackingId>,
         ),
         PosixError,
     > {
@@ -93,6 +95,7 @@ impl FuseHandler<Inode> for RandomFS {
             unsafe { OwnedFileHandle::from_raw(0) },
             (ino, attr),
             FUSEOpenResponseFlags::empty(),
+            None,
         ))
     }
 
@@ -171,8 +174,9 @@ impl FuseHandler<Inode> for RandomFS {
         _fh: BorrowedFileHandle,
         offset: SeekFrom,
         size: u32,
-        _flags: FUSEOpenFlags,
-        _lock_owner: Option<u64>,
+        _read_flags: FUSEReadFlags,
+        _flags: OpenFlags,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<Vec<u8>> {
         let mut rng = rand::thread_rng();
         let lines = rng.gen_range(0..81);
@@ -238,7 +242,7 @@ impl FuseHandler<Inode> for RandomFS {
         data: Vec<u8>,
         _write_flags: FUSEWriteFlags,
         _flags: OpenFlags,
-        _lock_owner: Option<u64>,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<u32> {
         Ok(data.len() as u32)
     }

examples/zip_fs/Cargo.toml

@@ -12,3 +12,7 @@ ctrlc = "3.4"
 
 [dev-dependencies]
 tempfile = "3.2"
+
+[patch.crates-io]
+# Bleeding edge patch for FUSE create() passthrough, will be removed when patch is merged
+fuser = { git = "https://github.com/khanhtranngoccva/fuser", branch = "passthrough" }

examples/zip_fs/src/filesystem.rs

@@ -135,8 +135,9 @@ impl FuseHandler<Inode> for ZipFs {
         _file_handle: BorrowedFileHandle,
         seek: SeekFrom,
         size: u32,
-        _flags: FUSEOpenFlags,
-        _lock_owner: Option<u64>,
+        _read_flags: FUSEReadFlags,
+        _flags: OpenFlags,
+        _lock_owner: Option<LockOwner>,
     ) -> FuseResult<Vec<u8>> {
         let InodeInfo {
             parent: _,