diff --git a/curvefs/src/client/kvclient/kvclient_manager.cpp b/curvefs/src/client/kvclient/kvclient_manager.cpp index 2e8b4aff8f..00dcf5936a 100644 --- a/curvefs/src/client/kvclient/kvclient_manager.cpp +++ b/curvefs/src/client/kvclient/kvclient_manager.cpp @@ -53,8 +53,11 @@ bool KVClientManager::Init(const KVClientManagerOpt& config, const std::string& fsName) { client_ = kvclient; kvClientManagerMetric_ = absl::make_unique(fsName); - getQueueSize_.reset("get_queue_size"); //1 - setQueueSize_.reset("set_queue_size"); //1 + brpc::StartDummyServerAt(9000); + getQueueSize_.expose("getQueueSize_"); + setQueueSize_.expose("setQueueSize_"); + getQueueSize_.reset(); + setQueueSize_.reset(); return threadPool_.Start(config.setThreadPooln) == 0; } @@ -66,7 +69,7 @@ void KVClientManager::Uninit() { void KVClientManager::Set(std::shared_ptr task) { threadPool_.Enqueue([task, this]() { std::string error_log; - setQueueSize_ << 1 + setQueueSize_ << 1; task->res = client_->Set(task->key, task->value, task->length, &error_log); if (task->res) { diff --git a/curvefs/src/client/kvclient/kvclient_manager.h b/curvefs/src/client/kvclient/kvclient_manager.h index b74c2872f8..54b0339663 100644 --- a/curvefs/src/client/kvclient/kvclient_manager.h +++ b/curvefs/src/client/kvclient/kvclient_manager.h @@ -30,6 +30,8 @@ #include #include #include +#include "bvar/bvar.h" +#include "brpc/server.h" #include "absl/strings/string_view.h" #include "curvefs/src/client/common/config.h" @@ -37,7 +39,6 @@ #include "curvefs/src/client/metric/client_metric.h" #include "src/common/concurrent/task_thread_pool.h" #include "src/common/s3_adapter.h" -#include "bvar/bvar.h" using curvefs::client::metric::KVClientManagerMetric;