diff --git a/src/net/src/holy_thread.cc b/src/net/src/holy_thread.cc index ee42c47070..cb12906880 100644 --- 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 index 1f8c51bc29..c47a90649b 100644 --- a/src/pika_admin.cc +++ b/src/pika_admin.cc @@ -2313,7 +2313,6 @@ void ConfigCmd::ConfigSet(std::shared_ptr db) { bool SlowCmdPool; if (value == "yes") { SlowCmdPool = true; - g_pika_server->SetSlowCmdThreadPoolFlag(SlowCmdPool); } else if (value == "no") { SlowCmdPool = false; } else { @@ -2321,6 +2320,7 @@ void ConfigCmd::ConfigSet(std::shared_ptr db) { 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 index 3a184c72c3..7def7cbadc 100644 --- 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(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) {