[fix] metric latnecy error

Signed-off-by: Cyber-SiKu <Cyber-SiKu@outlook.com>
opencurve · Oct 16, 2023 · 2216ba1 · 2216ba1
1 parent 92f1e1a
commit 2216ba1
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 4 deletions.
diff --git a/curvefs/src/client/kvclient/kvclient_manager.h b/curvefs/src/client/kvclient/kvclient_manager.h
@@ -64,7 +64,12 @@ struct SetKVCacheTask {
     explicit SetKVCacheTask(
         const std::string& k, const char* val, const uint64_t len,
         SetKVCacheDone done = [](const std::shared_ptr<SetKVCacheTask>&) {})
-        : key(k), value(val), length(len), res(false), done(std::move(done)) {}
+        : key(k),
+          value(val),
+          length(len),
+          res(false),
+          done(std::move(done)),
+          timer(butil::Timer::STARTED) {}
 };
 
 struct GetKVCacheTask {
@@ -84,7 +89,8 @@ struct GetKVCacheTask {
           offset(off),
           length(len),
           res(false),
-          done(std::move(done)) {}
+          done(std::move(done)),
+          timer(butil::Timer::STARTED) {}
 };
 
 class KVClientManager {

diff --git a/curvefs/src/client/s3/disk_cache_manager_impl.cpp b/curvefs/src/client/s3/disk_cache_manager_impl.cpp
@@ -98,6 +98,7 @@ int DiskCacheManagerImpl::WriteClosure(
      // set the returned value
     // it is need in CallBack
     context->retCode = ret;
+    context->timer.stop();
     context->cb(context);
     VLOG(9) << "WriteClosure end, name: " << context->key;
     return 0;

diff --git a/src/common/s3_adapter.h b/src/common/s3_adapter.h
@@ -142,7 +142,8 @@ struct GetObjectAsyncContext : public Aws::Client::AsyncCallerContext {
           offset(offset),
           len(len),
           cb(std::move(cb)),
-          type(type) {}
+          type(type),
+          timer(butil::Timer::STARTED) {}
 };
 
 /*
@@ -171,7 +172,8 @@ struct PutObjectAsyncContext : public Aws::Client::AsyncCallerContext {
           buffer(buffer),
           bufferSize(bufferSize),
           cb(std::move(cb)),
-          type(type) {}
+          type(type),
+          timer(butil::Timer::STARTED) {}
 };
 
 class S3Adapter {