From 519598f5115eccbcbf97e6466791092091aa3700 Mon Sep 17 00:00:00 2001 From: cheniujh <1271435567@qq.com> Date: Wed, 31 Jul 2024 14:45:59 +0800 Subject: [PATCH] revised to pass compile --- src/pika_consensus.cc | 2 +- src/pika_repl_client.cc | 2 +- src/pika_rm.cc | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/pika_consensus.cc b/src/pika_consensus.cc index cffeea117c..89f10e0317 100644 --- 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_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 index cc34c2817a..77e3a60f78 100644 --- a/src/pika_repl_client.cc +++ b/src/pika_repl_client.cc @@ -105,7 +105,7 @@ void PikaReplClient::ScheduleWriteDBTask(const std::shared_ptr& 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 task_finish_call_back = [this, db_name]() { this->DecrAsyncWriteDBTaskCount(db_name, 1); }; diff --git a/src/pika_rm.cc b/src/pika_rm.cc index 217effafa1..9df7b82101 100644 --- 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_ptr, const std::string& db_name) { - pika_repl_client_->ScheduleWriteDBTask(std::move(cmd_ptr), db_name); +void PikaReplicaManager::ScheduleWriteDBTask(const std::shared_ptr& 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); }