[feat][mds] Support file and dir read cache at fuse.

Author: rock-git

src/client/fuse/fuse_op.cpp

@@ -400,11 +400,12 @@ void FuseOpOpen(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info* fi) {
     ReplyError(req, s);
   } else {
     fi->fh = fh;
-    fi->direct_io = FLAGS_client_fuse_file_info_direct_io ? 1 : 0;
+
+    fi->direct_io =
+        (dingofs::IsInternalNode(ino) || FLAGS_client_fuse_file_info_direct_io)
+            ? 1
+            : 0;
     fi->keep_cache = FLAGS_client_fuse_file_info_keep_cache ? 1 : 0;
-    if (dingofs::IsInternalNode(ino)) {
-      fi->direct_io = 1;
-    }
 
     ReplyOpen(req, fi);
   }
@@ -478,6 +479,10 @@ void FuseOpOpenDir(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info* fi) {
     ReplyError(req, s);
   } else {
     fi->fh = fh;
+
+    fi->cache_readdir = FLAGS_client_fuse_file_info_keep_cache ? 1 : 0;
+    fi->keep_cache = FLAGS_client_fuse_file_info_keep_cache ? 1 : 0;
+
     ReplyOpen(req, fi);
   }
 }
@@ -704,6 +709,13 @@ void FuseOpCreate(fuse_req_t req, fuse_ino_t parent, const char* name,
     ReplyError(req, s);
   } else {
     fi->fh = fh;
+
+    fi->direct_io = (dingofs::IsInternalNode(attr.ino) ||
+                     FLAGS_client_fuse_file_info_direct_io)
+                        ? 1
+                        : 0;
+    fi->keep_cache = FLAGS_client_fuse_file_info_keep_cache ? 1 : 0;
+
     ReplyCreate(req, fi, attr);
   }
 }

src/mds/filesystem/store_operation.cc

@@ -1171,11 +1171,12 @@ Status OpenFileOperation::RunInBatch(TxnUPtr& txn, AttrEntry& attr, const std::v
   if (flags_ & O_TRUNC) {
     result_.delta_bytes = -static_cast<int64_t>(attr.length());
     attr.set_length(0);
+
+    attr.set_ctime(std::max(attr.ctime(), GetTime()));
+    attr.set_mtime(std::max(attr.mtime(), GetTime()));
   }
 
   attr.set_atime(std::max(attr.atime(), GetTime()));
-  attr.set_ctime(std::max(attr.ctime(), GetTime()));
-  attr.set_mtime(std::max(attr.mtime(), GetTime()));
 
   // add file session
   txn->Put(MetaCodec::EncodeFileSessionKey(file_session_.fs_id(), file_session_.ino(), file_session_.session_id()),