update

opencurve · Dec 7, 2023 · 84de2b8 · 84de2b8
1 parent 3b74f6b
commit 84de2b8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/curvefs/src/client/kvclient/kvclient_manager.cpp b/curvefs/src/client/kvclient/kvclient_manager.cpp
@@ -62,9 +62,9 @@ void KVClientManager::Uninit() {
 }
 
 void KVClientManager::Set(std::shared_ptr<SetKVCacheTask> task) {
-    threadPool_.Enqueue([task, this]() {
+     kvClientManagerMetric_->setQueueSize << 1;
+     threadPool_.Enqueue([task, this]() {
         std::string error_log;
-        kvClientManagerMetric_->setQueueSize << 1;
         task->res =
             client_->Set(task->key, task->value, task->length, &error_log);
         kvClientManagerMetric_->setQueueSize << -1;
@@ -98,10 +98,10 @@ void UpdateHitMissMetric(memcached_return_t retCode,
 }
 
 void KVClientManager::Get(std::shared_ptr<GetKVCacheTask> task) {
-    threadPool_.Enqueue([task, this]() {
+     kvClientManagerMetric_->getQueueSize << 1;
+     threadPool_.Enqueue([task, this]() {
         std::string error_log;
         memcached_return_t retCode;
-        kvClientManagerMetric_->getQueueSize << 1;
         task->res = client_->Get(task->key, task->value, task->offset,
                                  task->valueLength, &error_log, &task->length,
                                  &retCode);