fix: fix exit core (OpenAtomFoundation#3050)

* fix exit core
---------

Co-authored-by: wuxianrong <[email protected]>

Author: Mixficsol

conf/pika.conf

@@ -45,9 +45,9 @@ admin-thread-pool-size : 2
 slow-cmd-list :
 
 # List of commands considered as administrative. These commands will be handled by the admin thread pool. Modify this list as needed.
-# Default commands: info, ping, monitor
+# Default commands: info, ping, monitor, auth
 # This parameter is only supported by the CONFIG GET command and not by CONFIG SET.
-admin-cmd-list : info, ping, monitor
+admin-cmd-list : info, ping, monitor, auth
 
 # The number of threads to write DB in slaveNode when replicating.
 # It's preferable to set slave's sync-thread-num value close to master's thread-pool-size.

include/pika_cmd_table_manager.h

@@ -73,7 +73,6 @@ class PikaCmdTableManager {
   */
   std::unordered_map<std::string, CommandStatistics> cmdstat_map_;
   std::unordered_map<std::string, CommandStatistics> slow_command_count_;
-  std::thread reset_thread_;
   std::mutex command_mutex_;
   std::shared_mutex histograms_mutex_;
   std::shared_mutex slow_command_mutex_;

include/pika_server.h

@@ -259,6 +259,7 @@ class PikaServer : public pstd::noncopyable {
   void ResetStat();
   void incr_accumulative_connections();
   void ResetLastSecQuerynum();
+  void ResetCommandCount();
   void UpdateQueryNumAndExecCountDB(const std::string& db_name, const std::string& command, bool is_write);
   std::unordered_map<std::string, uint64_t> ServerExecCountDB();
   std::unordered_map<std::string, QpsStatistic> ServerAllDBStat();

src/pika_cmd_table_manager.cc

@@ -15,14 +15,9 @@
 extern std::unique_ptr<PikaConf> g_pika_conf;
 
 void PikaCmdTableManager::ResetCommandCount() {
-  while (true) {
-    std::this_thread::sleep_for(std::chrono::minutes(1)); 
-    {
-      std::lock_guard<std::mutex> lock(command_mutex_);
-      slow_command_count_.clear();
-      InitHistograms(); 
-    }
-  }
+  std::lock_guard<std::mutex> lock(command_mutex_);
+  slow_command_count_.clear();
+  InitHistograms(); 
 }
 
 void PikaCmdTableManager::InitHistograms() {
@@ -38,7 +33,6 @@ PikaCmdTableManager::PikaCmdTableManager() {
   cmds_ = std::make_unique<CmdTable>();
   cmds_->reserve(300);
   InitHistograms();
-  reset_thread_ = std::thread(&PikaCmdTableManager::ResetCommandCount, this);
 }
 
 void PikaCmdTableManager::InitCmdTable(void) {

src/pika_server.cc

@@ -1033,6 +1033,16 @@ void PikaServer::ResetLastSecQuerynum() {
   statistic_.ResetDBLastSecQuerynum();
 }
 
+void PikaServer::ResetCommandCount() {
+  thread_local uint64_t last_reset_time = 0;
+  auto current_time = pstd::NowMicros();
+  if (current_time - last_reset_time < 60 * 1000 * 1000) {
+    return;
+  }
+  last_reset_time = current_time; 
+  g_pika_cmd_table_manager->ResetCommandCount();
+}
+
 void PikaServer::UpdateQueryNumAndExecCountDB(const std::string& db_name, const std::string& command, bool is_write) {
   std::string cmd(command);
   statistic_.server_stat.qps.querynum++;
@@ -1139,6 +1149,8 @@ void PikaServer::DoTimingTask() {
   ResetLastSecQuerynum();
   // Auto update network instantaneous metric
   AutoUpdateNetworkMetric();
+  // Reset command statistics
+  ResetCommandCount();
   ProcessCronTask();
   UpdateCacheInfo();
   // Print the queue status periodically