Oxidation fuse

.github/workflows/ci-rust.yml

@@ -64,6 +64,11 @@ jobs:
           save-if: ${{ github.ref == 'refs/heads/master' }}
         timeout-minutes: 5
 
+      # Install fio
+      - name: Install fio
+        shell: bash
+        run: apt install fio
+
       # Install cargo nextest command
       - uses: taiki-e/install-action@6801bd56b9711500292d943350f0b1f3559d7acb # pin v2.17.8
         with:
@@ -171,6 +176,12 @@ jobs:
           unzip D:/a/_temp/winfsp-tests.zip -d D:/a/_temp/
           mv 'D:/a/_temp/winfsp-tests-x64.exe' 'C:/Program Files (x86)/WinFsp/bin/'
 
+      # Install fio
+      - name: Install fio
+      if: startsWith(matrix.os, 'macos')
+        shell: bash
+        run: apt install fio
+
       # Install cargo nextest command
       - uses: taiki-e/install-action@6801bd56b9711500292d943350f0b1f3559d7acb # pin v2.17.8
         with:

Cargo.toml

@@ -104,6 +104,7 @@ event-listener = { version = "2.5.3", default-features = false }
 flate2 = { version = "1.0.27", default-features = false }
 flume = { version = "0.10.14", default-features = false }
 fnmatch-regex = { version = "0.2.0", default-features = false }
+fuser = { version = "0.13.0", default-features =  false }
 futures-core = { version = "0.3.28", default-features = false }
 futures-lite = { version = "1.13.0", default-features = false }
 futures = { version = "0.3.28", default-features = false }
@@ -120,6 +121,7 @@ itertools = { version = "0.11.0", default-features = false }
 jni = { version = "0.21.1", default-features = false }
 js-sys = { version = "0.3.64", default-features = false }
 lazy_static = { version = "1.4.0", default-features = false }
+libc = { version = "0.2.147", default-features = false }
 libsodium-sys = { version = "0.2.7", default-features = false }
 libsqlite3-sys = { version = "0.26.0", default-features = false }
 log = { version = "0.4.20", default-features = false }

libparsec/crates/platform_mountpoint/Cargo.toml

@@ -10,16 +10,25 @@ repository.workspace = true
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
-[target.'cfg(target_os = "windows")'.dependencies]
+[target.'cfg(target_family = "windows")'.dependencies]
 winfsp_wrs = { workspace = true }
-once_cell = { workspace = true }
 regex = { workspace = true }
 
+[target.'cfg(target_family = "unix")'.dependencies]
+fuser = { workspace = true }
+libc = { workspace = true }
+
 [dependencies]
 libparsec_types = { workspace = true }
 anyhow = { workspace = true }
 chrono = { workspace = true }
+env_logger = { workspace = true }
+once_cell = { workspace = true }
 thiserror = { workspace = true }
 
-[target.'cfg(target_os = "windows")'.build-dependencies]
+[dev-dependencies]
+libparsec_tests_fixtures = { workspace = true }
+libparsec_tests_macros = { workspace = true }
+
+[target.'cfg(target_family = "windows")'.build-dependencies]
 winfsp_build = { workspace = true }

libparsec/crates/platform_mountpoint/src/error.rs

@@ -12,6 +12,8 @@ pub(crate) enum MountpointError {
     EndOfFile,
     #[error("Name collision")]
     NameCollision,
+    #[error("Name too long")]
+    NameTooLong,
     #[error("Not found")]
     NotFound,
 }

libparsec/crates/platform_mountpoint/src/lib.rs

@@ -4,12 +4,16 @@
 
 mod error;
 mod memfs;
-#[cfg(target_os = "windows")]
+#[cfg(target_family = "unix")]
+mod unix;
+#[cfg(target_family = "windows")]
 mod windows;
 
 use chrono::{DateTime, Utc};
 use std::{collections::HashMap, path::Path};
-#[cfg(target_os = "windows")]
+#[cfg(target_family = "unix")]
+pub use unix::mount;
+#[cfg(target_family = "windows")]
 pub use windows::mount;
 
 use libparsec_types::{EntryID, EntryName, FileDescriptor};

libparsec/crates/platform_mountpoint/src/memfs/mod.rs

@@ -35,7 +35,8 @@ impl Default for MountpointManager {
             PathBuf::from("/"),
             (
                 EntryInfo {
-                    id: EntryID::default(),
+                    // Because fuse root ino is 1
+                    id: EntryID::from(1u128.to_le_bytes()),
                     ty: EntryInfoType::Dir,
                     created: now,
                     updated: now,
@@ -199,7 +200,7 @@ impl MountpointInterface for MountpointManager {
             .to_str()
             .expect("Non utf8 name");
         parent.children.insert(
-            EntryName::try_from(file_name).expect("Should be a valid EntryName"),
+            EntryName::try_from(file_name).map_err(|_| MountpointError::NameTooLong)?,
             id,
         );
 
@@ -387,7 +388,7 @@ impl MountpointInterface for MountpointManager {
                     .to_str()
                     .expect("Non utf8 name"),
             )
-            .expect("Should be a valid EntryName"),
+            .map_err(|_| MountpointError::NameTooLong)?,
             id,
         );