diff --git a/curvefs/src/client/kvclient/kvclient_manager.cpp b/curvefs/src/client/kvclient/kvclient_manager.cpp index 864d2e38bd..d59d9f101f 100644 --- a/curvefs/src/client/kvclient/kvclient_manager.cpp +++ b/curvefs/src/client/kvclient/kvclient_manager.cpp @@ -62,8 +62,8 @@ void KVClientManager::Uninit() { } void KVClientManager::Set(std::shared_ptr task) { - kvClientManagerMetric_->setQueueSize << 1; - threadPool_.Enqueue([task, this]() { + kvClientManagerMetric_->setQueueSize << 1; + threadPool_.Enqueue([task, this]() { std::string error_log; task->res = client_->Set(task->key, task->value, task->length, &error_log);