[feat][mds] Adjust Open rpc log print.

Author: rock-git

scripts/dev/deploy.sh

@@ -16,7 +16,7 @@ eval set -- "${FLAGS_ARGV}"
 echo "role: ${FLAGS_role}"
 echo "parameters: ${FLAGS_parameters}"
 
-BASE_DIR=$(dirname $(cd $(dirname $0); pwd))
+BASE_DIR=$(dirname $(dirname $(cd $(dirname $0); pwd)))
 DIST_DIR=$BASE_DIR/dist
 
 if [ ! -d "$DIST_DIR" ]; then

scripts/dev/start.sh

@@ -18,9 +18,11 @@ eval set -- "${FLAGS_ARGV}"
 
 echo "start role(${FLAGS_role}) server num(${FLAGS_server_num})"
 
-BASE_DIR=$(dirname $(cd $(dirname $0); pwd))
+BASE_DIR=$(dirname $(dirname $(cd $(dirname $0); pwd)))
 DIST_DIR=$BASE_DIR/dist
 
+
+
 function set_ulimit() {
     NUM_FILE=1048576
     NUM_PROC=4194304

scripts/dev/start_fuse.sh

@@ -40,7 +40,7 @@ fi
 
 echo "start fuse fsname(${FLAGS_fsname}) fstype(${FLAGS_fstype}) mountpoint(${FLAGS_mountpoint})"
 
-BASE_DIR=$(dirname $(cd $(dirname $0); pwd))
+BASE_DIR=$(dirname $(dirname $(cd $(dirname $0); pwd)))
 FUSE_BASE_DIR=$BASE_DIR/dist/fuse
 FUSE_BIN_PATH=$FUSE_BASE_DIR/bin/dingo-fuse
 FUSE_CONF_DIR=$FUSE_BASE_DIR/conf

scripts/dev/stop.sh

@@ -15,7 +15,7 @@ eval set -- "${FLAGS_ARGV}"
 
 echo "stop role(${FLAGS_role}) server num(${FLAGS_server_num})"
 
-BASE_DIR=$(dirname $(cd $(dirname $0); pwd))
+BASE_DIR=$(dirname $(dirname $(cd $(dirname $0); pwd)))
 DIST_DIR=$BASE_DIR/dist
 
 

src/client/vfs/meta/v2/rpc.h

@@ -209,6 +209,26 @@ inline std::string DescribeReadSliceResponse(
   return oss.str();
 }
 
+// print OpenResponse
+inline std::string DescribeOpenResponse(pb::mds::OpenResponse& response) {
+  std::ostringstream oss;
+  oss << response.info().ShortDebugString()
+      << " session_id:" << response.session_id() << " inode("
+      << response.inode().ShortDebugString() << ") chunks[";
+  for (const auto& chunk : response.chunks()) {
+    std::vector<uint64_t> slice_ids;
+    slice_ids.reserve(chunk.slices().size());
+    for (const auto& slice : chunk.slices()) {
+      slice_ids.push_back(slice.id());
+    }
+    oss << fmt::format("({},{} slice_ids{}),", chunk.index(), chunk.version(),
+                       slice_ids);
+  }
+
+  oss << "]";
+  return oss.str();
+}
+
 template <typename Request, typename Response>
 Status RPC::SendRequest(const EndPoint& endpoint,
                         const std::string& service_name,
@@ -269,21 +289,31 @@ Status RPC::SendRequest(const EndPoint& endpoint,
     }
 
     if (response.error().errcode() == pb::error::OK) {
-      if constexpr (!std::is_same_v<Response, pb::mds::ReadSliceResponse>) {
+      if constexpr (std::is_same_v<Response, pb::mds::ReadSliceResponse>) {
         LOG(INFO) << fmt::format(
             "[meta.rpc][{}][{}][{}us] success, retry({}) request({}) "
             "response({}) doing({}).",
             EndPointToStr(endpoint), api_name, elapsed_us, retry,
-            request.ShortDebugString(), response.ShortDebugString(),
+            request.ShortDebugString(), DescribeReadSliceResponse(response),
             DoingReqCount());
+
+      } else if constexpr (std::is_same_v<Response, pb::mds::OpenResponse>) {
+        LOG(INFO) << fmt::format(
+            "[meta.rpc][{}][{}][{}us] success, retry({}) request({}) "
+            "response({}) doing({}).",
+            EndPointToStr(endpoint), api_name, elapsed_us, retry,
+            request.ShortDebugString(), DescribeOpenResponse(response),
+            DoingReqCount());
+
       } else {
         LOG(INFO) << fmt::format(
             "[meta.rpc][{}][{}][{}us] success, retry({}) request({}) "
             "response({}) doing({}).",
             EndPointToStr(endpoint), api_name, elapsed_us, retry,
-            request.ShortDebugString(), DescribeReadSliceResponse(response),
+            request.ShortDebugString(), response.ShortDebugString(),
             DoingReqCount());
       }
+
       return Status::OK();
     }