Solved the problem of commandstate statistics duplication (#3028)

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

Author: Mixficsol

.github/workflows/pika.yml

@@ -155,9 +155,7 @@ jobs:
 
       - name: Install Deps
         run: |
-          brew update
-          brew install --overwrite [email protected] autoconf protobuf llvm wget git
-          brew install gcc@10 automake cmake make binutils
+           brew install gcc@10 automake cmake make binutils
 
       - name: Configure CMake
         run: |

conf/pika.conf

@@ -3,8 +3,8 @@
 ###########################
 
 # Pika port, the default value is 9221.
-# [NOTICE] Port Magic offsets of port+1000 / port+10000 are used by Pika at present.
-# Port 9221+10000 is used for Rsync, and port 9221+1000 is used for incr Replication, while the listening port is 9221.
+# [NOTICE] Port Magic offsets of port+1000 / port+10001 are used by Pika at present.
+# Port 9221+10001 is used for Rsync, and port 9221+1000 is used for incr Replication, while the listening port is 9221.
 port : 9221
 
 db-instance-num : 3
@@ -500,7 +500,7 @@ default-slot-num : 1024
 # if auto_tuned is true: Enables dynamic adjustment of rate limit within the range
 #`[rate-limiter-bandwidth / 20, rate-limiter-bandwidth]`, according to the recent demand for background I/O.
 # rate limiter auto tune https://rocksdb.org/blog/2017/12/18/17-auto-tuned-rate-limiter.html. the default value is true.
-#rate-limiter-auto-tuned : true
+#rate-limiter-auto-tuned : yes
 
 ################################## RocksDB Blob Configure #####################
 # rocksdb blob configure

src/pika_client_conn.cc

@@ -371,8 +371,8 @@ bool PikaClientConn::ReadCmdInCache(const net::RedisCmdArgsType& argv, const std
   resp_num--;
   if (read_status) {
     time_stat_->process_done_ts_ = pstd::NowMicros();
-    (*cmdstat_map)[argv[0]].cmd_count.fetch_add(1);
-    (*cmdstat_map)[argv[0]].cmd_time_consuming.fetch_add(time_stat_->total_time());
+    (*cmdstat_map)[opt].cmd_count.fetch_add(1);
+    (*cmdstat_map)[opt].cmd_time_consuming.fetch_add(time_stat_->total_time());
     resp_array.emplace_back(std::make_shared<std::string>(std::move(c_ptr->res().message())));
     TryWriteResp();
   }