[#5873] feat(gvfs-fuse): add debug log for FuseApiHandle

clients/filesystem-fuse/Cargo.toml

@@ -35,6 +35,7 @@ name = "gvfs_fuse"
 [dependencies]
 async-trait = "0.1"
 bytes = "1.6.0"
+chrono = "0.4.39"
 config = "0.13"
 dashmap = "6.1.0"
 fuse3 = { version = "0.8.1", "features" = ["tokio-runtime", "unprivileged"] }
@@ -46,6 +47,7 @@ opendal = { version = "0.46.0", features = ["services-s3"] }
 reqwest = { version = "0.12.9", features = ["json"] }
 serde = { version = "1.0.216", features = ["derive"] }
 tokio = { version = "1.38.0", features = ["full"] }
+tracing = "0.1.41"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 urlencoding = "2.1.3"
 

clients/filesystem-fuse/conf/gvfs_fuse.toml

@@ -20,6 +20,7 @@
 file_mask = 0o600
 dir_mask = 0o700
 fs_type = "memory"
+fuse_debug=true
 
 [fuse.properties]
 

clients/filesystem-fuse/src/config.rs

@@ -265,6 +265,8 @@ pub struct FuseConfig {
     #[serde(default)]
     pub fs_type: String,
     #[serde(default)]
+    pub fuse_debug: bool,
+    #[serde(default)]
     pub config_path: String,
     #[serde(default)]
     pub properties: HashMap<String, String>,

clients/filesystem-fuse/src/filesystem.rs

@@ -145,6 +145,7 @@ pub(crate) trait PathFileSystem: Send + Sync {
 }
 
 // FileSystemContext is the system environment for the fuse file system.
+#[derive(Debug)]
 pub(crate) struct FileSystemContext {
     // system user id
     pub(crate) uid: u32,

clients/filesystem-fuse/src/fuse_api_handle.rs

@@ -53,7 +53,7 @@ impl<T: RawFileSystem> FuseApiHandle<T> {
         }
     }
 
-    async fn get_modified_file_stat(
+    pub async fn get_modified_file_stat(
         &self,
         file_id: u64,
         size: Option<u64>,
@@ -64,15 +64,15 @@ impl<T: RawFileSystem> FuseApiHandle<T> {
 
         if let Some(size) = size {
             file_stat.size = size;
-        };
+        }
 
         if let Some(atime) = atime {
             file_stat.atime = atime;
-        };
+        }
 
         if let Some(mtime) = mtime {
             file_stat.mtime = mtime;
-        };
+        }
 
         Ok(file_stat)
     }
@@ -106,7 +106,7 @@ impl<T: RawFileSystem> Filesystem for FuseApiHandle<T> {
 
     async fn getattr(
         &self,
-        _req: Request,
+        req: Request,
         inode: Inode,
         fh: Option<u64>,
         _flags: u32,
@@ -117,6 +117,7 @@ impl<T: RawFileSystem> Filesystem for FuseApiHandle<T> {
         }
 
         let file_stat = self.fs.stat(inode).await?;
+
         Ok(ReplyAttr {
             ttl: self.default_ttl,
             attr: fstat_to_file_attr(&file_stat, &self.fs_context),
@@ -256,7 +257,7 @@ impl<T: RawFileSystem> Filesystem for FuseApiHandle<T> {
     }
 
     type DirEntryStream<'a>
-        = BoxStream<'a, fuse3::Result<DirectoryEntry>>
+    = BoxStream<'a, fuse3::Result<DirectoryEntry>>
     where
         T: 'a;
 
@@ -336,7 +337,7 @@ impl<T: RawFileSystem> Filesystem for FuseApiHandle<T> {
     }
 
     type DirEntryPlusStream<'a>
-        = BoxStream<'a, fuse3::Result<DirectoryEntryPlus>>
+    = BoxStream<'a, fuse3::Result<DirectoryEntryPlus>>
     where
         T: 'a;