fix

OpenAtomFoundation · Jun 19, 2024 · 8bac0c6 · 8bac0c6
1 parent 6a1c80d
commit 8bac0c6
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/src/net/src/holy_thread.cc b/src/net/src/holy_thread.cc
@@ -75,7 +75,6 @@ int HolyThread::StartThread() {
   if (ret) {
     return ret;
   }
-  set_thread_name("HolyThread");
   return ServerThread::StartThread();
 }
 

diff --git a/src/pika_admin.cc b/src/pika_admin.cc
@@ -2313,14 +2313,14 @@ void ConfigCmd::ConfigSet(std::shared_ptr<DB> db) {
     bool SlowCmdPool;
     if (value == "yes") {
       SlowCmdPool = true;
-      g_pika_server->SetSlowCmdThreadPoolFlag(SlowCmdPool);
     } else if (value == "no") {
       SlowCmdPool = false;
     } else {
       res_.AppendStringRaw( "-ERR Invalid argument \'" + value + "\' for CONFIG SET 'slow-cmd-pool'\r\n");
       return;
     }
     g_pika_conf->SetSlowCmdPool(SlowCmdPool);
+    g_pika_server->SetSlowCmdThreadPoolFlag(SlowCmdPool);
     res_.AppendStringRaw("+OK\r\n");
   } else if (set_item == "slowlog-log-slower-than") {
     if ((pstd::string2int(value.data(), value.size(), &ival) == 0) || ival < 0) {

diff --git a/src/rsync_client.cc b/src/rsync_client.cc
@@ -28,6 +28,7 @@ RsyncClient::RsyncClient(const std::string& dir, const std::string& db_name)
       parallel_num_(g_pika_conf->max_rsync_parallel_num()) {
   wo_mgr_.reset(new WaitObjectManager());
   client_thread_ = std::make_unique<RsyncClientThread>(3000, 60, wo_mgr_.get());
+  client_thread_->set_thread_name("RsyncClientThread");
   work_threads_.resize(GetParallelNum());
   finished_work_cnt_.store(0);
 }
@@ -61,7 +62,6 @@ bool RsyncClient::Init() {
   master_ip_ = g_pika_server->master_ip();
   master_port_ = g_pika_server->master_port() + kPortShiftRsync2;
   file_set_.clear();
-  client_thread_->set_thread_name("RsyncClientThread");
   client_thread_->StartThread();
   bool ret = ComparisonUpdate();
   if (!ret) {