feat(bin/ofs): privileged mount (#4507)

* feat: privileged mount

* chore

bin/ofs/Cargo.toml

@@ -39,13 +39,13 @@ fuse3 = { "version" = "0.7.1", "features" = ["tokio-runtime", "unprivileged"] }
 futures-util = "0.3.30"
 libc = "0.2.151"
 log = "0.4.21"
-nix = { version = "0.27.1", features = ["user"] }
+nix = { version = "0.28.0", features = ["user"] }
 opendal = { version = "0.45.1", path = "../../core" }
 sharded-slab = "0.1.7"
-tokio = { version = "1.37", features = [
+tokio = { version = "1.37.0", features = [
   "fs",
   "macros",
-  "rt-multi-thread",
+  "rt",
   "io-std",
   "signal",
 ] }

bin/ofs/src/bin/ofs.rs

@@ -18,7 +18,8 @@
 use anyhow::Result;
 use clap::Parser;
 
-#[tokio::main]
+// FIXME: https://github.com/apache/opendal/issues/4512
+#[tokio::main(flavor = "current_thread")]
 async fn main() -> Result<()> {
     let cfg = ofs::Config::parse();
 

bin/ofs/src/lib.rs

@@ -77,12 +77,20 @@ async fn execute_inner(args: Args) -> Result<()> {
     mount_option.uid(uid.into());
     mount_option.gid(gid.into());
     mount_option.no_open_dir_support(true);
+    mount_option.read_only(true);
 
     let adapter = fuse::Fuse::new(args.backend, uid.into(), gid.into());
 
-    let mut mount_handle = Session::new(mount_option)
-        .mount_with_unprivileged(adapter, args.mount_path)
-        .await?;
+    let session = Session::new(mount_option);
+
+    let mut mount_handle = if uid.is_root() {
+        session.mount(adapter, args.mount_path).await?
+    } else {
+        log::warn!("unprivileged mount may not detect external unmount, tracking issue: https://github.com/Sherlock-Holo/fuse3/issues/72");
+        session
+            .mount_with_unprivileged(adapter, args.mount_path)
+            .await?
+    };
 
     let handle = &mut mount_handle;