feat: add overlay

cnpm · Feb 22, 2024 · f62cd2c · f62cd2c
1 parent c54c446
commit f62cd2c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/passthrough/sync_io.rs b/src/passthrough/sync_io.rs
@@ -365,6 +365,7 @@ impl<S: BitmapSlice + Send + Sync> FileSystem for PassthroughFs<S> {
         let data = self.inode_map.get(parent)?;
 
         let res = {
+            #[cfg(target_os = "linux")]
             let (_uid, _gid) = set_creds(ctx.uid, ctx.gid)?;
 
             let file = data.get_file()?;
@@ -509,6 +510,7 @@ impl<S: BitmapSlice + Send + Sync> FileSystem for PassthroughFs<S> {
         let dir_file = dir.get_file()?;
 
         let new_file = {
+            #[cfg(target_os = "linux")]
             let (_uid, _gid) = set_creds(ctx.uid, ctx.gid)?;
 
             let flags = self.get_writeback_open_flags(args.flags as i32);
@@ -532,6 +534,7 @@ impl<S: BitmapSlice + Send + Sync> FileSystem for PassthroughFs<S> {
                     None
                 };
 
+                #[cfg(target_os = "linux")]
                 let (_uid, _gid) = set_creds(ctx.uid, ctx.gid)?;
                 self.open_inode(entry.inode, args.flags as i32)?
             }
@@ -946,6 +949,7 @@ impl<S: BitmapSlice + Send + Sync> FileSystem for PassthroughFs<S> {
         let pathname = data.get_path()?;
 
         let res = {
+            #[cfg(target_os = "linux")]
             let (_uid, _gid) = set_creds(ctx.uid, ctx.gid)?;
 
             // Safe because this doesn't modify any memory and we check the return value.
@@ -1031,6 +1035,7 @@ impl<S: BitmapSlice + Send + Sync> FileSystem for PassthroughFs<S> {
         let data = self.inode_map.get(parent)?;
 
         let res = {
+            #[cfg(target_os = "linux")]
             let (_uid, _gid) = set_creds(ctx.uid, ctx.gid)?;
 
             let file = data.get_file()?;

diff --git a/src/transport/fusedev/fuse_t_session.rs b/src/transport/fusedev/fuse_t_session.rs
@@ -260,10 +260,10 @@ impl FuseChannel {
     }
 
     fn read(&mut self, len: usize, offset: usize) -> Result<()> {
-        let read_buf = &mut self.buf[offset..offset + len];
         let mut total: usize = 0;
         let fd = self.file.as_raw_fd();
         while total < len {
+            let read_buf = &mut self.buf[offset + total..offset + len];
             match read(fd, read_buf) {
                 Ok(size) => {
                     total += size;
@@ -409,6 +409,7 @@ fn fuse_kern_mount(
             let mut cmd = Command::new(FUSE_NFSSRV_PATH);
             cmd.arg("--noatime=true")
                 .arg("--dontbrowse=true")
+                .arg("--rwsize=262144")
                 // .arg("-d")
                 // .arg("-c")
                 .args(["--volname", &format!("{}-{}", fsname, subtype)]);