2

opencurve · Nov 27, 2023 · 41b912b · 41b912b
1 parent 0b9a4d3
commit 41b912b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git 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<KVClientManagerMetric>(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<SetKVCacheTask> 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
@@ -30,14 +30,15 @@
 #include <string>
 #include <thread>
 #include <utility>
+#include "bvar/bvar.h"  
+#include "brpc/server.h"
 
 #include "absl/strings/string_view.h"
 #include "curvefs/src/client/common/config.h"
 #include "curvefs/src/client/kvclient/kvclient.h"
 #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;