Bsd support

.cirrus.yml

@@ -0,0 +1,11 @@
+freebsd_instance:
+  image_family: freebsd-14-3
+
+task:
+  name: FreeBSD
+  setup_script:
+    - pkg install -y pkgconf fusefs-libs fusefs-libs3 rust
+  build_script:
+    - cargo build --features "parallel libfuse"
+  test_script:
+    - cargo test --features "parallel libfuse"

Cargo.toml

@@ -14,13 +14,13 @@ serial = []
 parallel = ["dep:threadpool"]
 async = ["dep:async-trait", "dep:tokio"]
 deadlock_detection = ["parallel", "dep:parking_lot"]
-
+libfuse = ["fuser/libfuse"]
 
 [dependencies]
 # Core dependencies
+fuser = { version = "0.16.0" }
 log = "0.4"
 libc = "0.2"
-fuser = "0.16"
 bitflags = "2.10"
 
 # Parallel dependencies

src/unix_fs/bsd_fs.rs

@@ -1,26 +1,68 @@
 pub use super::bsd_like_fs::*;
-use std::os::fd::*;
+use std::path::Path;
+use std::ffi::{CStr, CString};
+use crate::PosixError;
 
-use std::ffi::c_void;
-
-use libc::{self, c_char, c_int, size_t, ssize_t};
+use libc::{self, c_char, c_int, size_t, ssize_t, off_t, c_void};
 
 use super::{StatFs, cstring_from_path};
 
 pub(super) unsafe fn fallocate(fd: c_int, _mode: c_int, offset: off_t, len: off_t) -> c_int {
-    libc::posix_fallocate(fd, offset, len)
+    unsafe { libc::posix_fallocate(fd, offset, len) }
 }
 
+/// Warning: untested function
 pub(super) unsafe fn setxattr(
     path: *const c_char,
     name: *const c_char,
     value: *const c_void,
-    _size: size_t,
-    _flags: c_int,
+    size: libc::size_t,
+    position: u32,
+    _flags: c_int,           // ignored on FreeBSD
 ) -> c_int {
-    libc::extattr_set_file(path, libc::EXTATTR_NAMESPACE_USER, name, value, size)
-        .try_into()
-        .unwrap()
+    unsafe {
+        if position != 0 {
+            return -libc::EOPNOTSUPP;
+        }
+
+        // Convert C strings → Rust &str (safe failure → EINVAL)
+        let name_str = match CStr::from_ptr(name).to_str() {
+            Ok(s) => s,
+            Err(_) => return -libc::EINVAL,
+        };
+
+        // Map common prefixed names → FreeBSD namespace
+        let (ns, attr_name): (c_int, &str) = if name_str.starts_with("user.") {
+            (libc::EXTATTR_NAMESPACE_USER, &name_str[5..])
+        } else if name_str.starts_with("system.") {
+            (libc::EXTATTR_NAMESPACE_SYSTEM, &name_str[7..])
+        } else if name_str.starts_with("trusted.") {
+            (libc::EXTATTR_NAMESPACE_SYSTEM, &name_str[8..])
+        } else if name_str.starts_with("security.") {
+            (libc::EXTATTR_NAMESPACE_SYSTEM, &name_str[9..])
+        } else {
+            (libc::EXTATTR_NAMESPACE_USER, name_str)
+        };
+
+        let attr_name_c: CString = match CString::new(attr_name) {
+            Ok(c) => c,
+            Err(_) => return -libc::EINVAL,
+        };
+
+        let ret = libc::extattr_set_file(
+            path,
+            ns,
+            attr_name_c.as_ptr(),
+            value as *mut c_void, // FreeBSD wants mutable pointer
+            size,
+        );
+
+        if ret >= 0 {
+            0
+        } else {
+            -(*libc::__error()) // correct FreeBSD way to read errno
+        }
+    }
 }
 
 pub(super) unsafe fn getxattr(
@@ -29,20 +71,20 @@ pub(super) unsafe fn getxattr(
     value: *mut c_void,
     size: size_t,
 ) -> ssize_t {
-    libc::extattr_get_file(path, libc::EXTATTR_NAMESPACE_USER, name, value, size)
+    unsafe { libc::extattr_get_file(path, libc::EXTATTR_NAMESPACE_USER, name, value, size) }
 }
 
 pub(super) unsafe fn listxattr(path: *const c_char, list: *mut c_char, size: size_t) -> ssize_t {
-    libc::extattr_list_file(
+    unsafe { libc::extattr_list_file(
         path,
         libc::EXTATTR_NAMESPACE_USER,
         list as *mut c_void,
         size,
-    )
+    ) }
 }
 
 pub(super) unsafe fn removexattr(path: *const c_char, name: *const c_char) -> c_int {
-    libc::extattr_delete_file(path, libc::EXTATTR_NAMESPACE_USER, name)
+    unsafe { libc::extattr_delete_file(path, libc::EXTATTR_NAMESPACE_USER, name) }
 }
 
 /// Retrieves file system statistics for the specified path.

src/unix_fs/bsd_like_fs.rs

@@ -19,11 +19,11 @@ pub(super) unsafe fn renameat2(
     newpath: *const c_char,
     _flags: c_uint,
 ) -> c_int {
-    libc::renameat(olddirfd, oldpath, newdirfd, newpath)
+    unsafe { libc::renameat(olddirfd, oldpath, newdirfd, newpath) }
 }
 
 pub(super) unsafe fn fdatasync(fd: c_int) -> c_int {
-    libc::fsync(fd)
+    unsafe { libc::fsync(fd) }
 }
 
 /// Copies a range of data from one file to another.

tests/integration_test.rs

@@ -97,9 +97,20 @@ fn test_mirror_fs_operations() {
     }
 
     eprintln!("Unmounting filesystem...");
-    let _ = std::process::Command::new("fusermount")
-        .arg("-u")
-        .arg(&mntpoint)
-        .status();
-    handle.join().unwrap();
+    #[cfg(not(target_os = "freebsd"))]
+    {
+        let _ = std::process::Command::new("fusermount")
+            .arg("-u")
+            .arg(&mntpoint)
+            .status();
+        handle.join().unwrap();
+    }
+    #[cfg(target_os = "freebsd")] // TODO: explore why error: no such file or directory happens there
+    {
+        let _ = std::process::Command::new("umount")
+            .arg(&mntpoint)
+            .status();
+        let _ = handle.join();
+    }
+    drop(mntpoint);
 }

tests/offset_test.rs

@@ -95,9 +95,20 @@ fn test_mirror_fs_file_offsets() {
     }
 
     eprintln!("Unmounting filesystem...");
-    let _ = std::process::Command::new("fusermount")
-        .arg("-u")
-        .arg(&mntpoint)
-        .status();
-    handle.join().unwrap();
+    #[cfg(not(target_os = "freebsd"))]
+    {
+        let _ = std::process::Command::new("fusermount")
+            .arg("-u")
+            .arg(&mntpoint)
+            .status();
+        handle.join().unwrap();
+    }
+    #[cfg(target_os = "freebsd")] // TODO: explore why error: no such file or directory happens there
+    {
+        let _ = std::process::Command::new("umount")
+            .arg(&mntpoint)
+            .status();
+        let _ = handle.join();
+    }
+    drop(mntpoint);
 }

tests/test_recursion.rs

@@ -75,9 +75,21 @@ fn test_mirror_fs_recursion() {
     println!("Test passed: No infinite recursion detected.");
 
     eprintln!("Unmounting filesystem...");
-    let _ = std::process::Command::new("fusermount")
-        .arg("-u")
-        .arg(&mntpoint)
-        .status();
-    handle.join().unwrap();
+    #[cfg(not(target_os = "freebsd"))]
+    {
+        let _ = std::process::Command::new("fusermount")
+            .arg("-u")
+            .arg(&mntpoint)
+            .status();
+        handle.join().unwrap();
+    }
+    #[cfg(target_os = "freebsd")] // TODO: explore why error: no such file or directory happens there
+    {
+        let _ = std::process::Command::new("umount")
+            .arg(&mntpoint)
+            .status();
+        let _ = handle.join();
+    }
+    drop(mntpoint);
+
 }