revised to pass compile

OpenAtomFoundation · Jul 31, 2024 · 519598f · 519598f
1 parent de62327
commit 519598f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/pika_consensus.cc b/src/pika_consensus.cc
@@ -424,7 +424,7 @@ uint32_t ConsensusCoordinator::term() {
 }
 
 void ConsensusCoordinator::InternalApplyFollower(const std::shared_ptr<Cmd>& cmd_ptr) {
-  g_pika_rm->ScheduleWriteDBTask(std::move(cmd_ptr), db_name_);
+  g_pika_rm->ScheduleWriteDBTask(cmd_ptr, db_name_);
 }
 
 int ConsensusCoordinator::InitCmd(net::RedisParser* parser, const net::RedisCmdArgsType& argv) {

diff --git a/src/pika_repl_client.cc b/src/pika_repl_client.cc
@@ -105,7 +105,7 @@ void PikaReplClient::ScheduleWriteDBTask(const std::shared_ptr<Cmd>& cmd_ptr, co
   const PikaCmdArgsType& argv = cmd_ptr->argv();
   std::string dispatch_key = argv.size() >= 2 ? argv[1] : argv[0];
   size_t index = GetHashIndexByKey(dispatch_key);
-  auto task_arg = new ReplClientWriteDBTaskArg(std::move(cmd_ptr));
+  auto task_arg = new ReplClientWriteDBTaskArg(cmd_ptr);
 
   IncrAsyncWriteDBTaskCount(db_name, 1);
   std::function<void()> task_finish_call_back = [this, db_name]() { this->DecrAsyncWriteDBTaskCount(db_name, 1); };

diff --git a/src/pika_rm.cc b/src/pika_rm.cc
@@ -683,8 +683,8 @@ void PikaReplicaManager::ScheduleWriteBinlogTask(const std::string& db,
   pika_repl_client_->ScheduleWriteBinlogTask(db, res, conn, res_private_data);
 }
 
-void PikaReplicaManager::ScheduleWriteDBTask(std::shared_ptr<Cmd> cmd_ptr, const std::string& db_name) {
-  pika_repl_client_->ScheduleWriteDBTask(std::move(cmd_ptr), db_name);
+void PikaReplicaManager::ScheduleWriteDBTask(const std::shared_ptr<Cmd>& cmd_ptr, const std::string& db_name) {
+  pika_repl_client_->ScheduleWriteDBTask(cmd_ptr, db_name);
 }
 
 void PikaReplicaManager::ReplServerRemoveClientConn(int fd) { pika_repl_server_->RemoveClientConn(fd); }