From 983ca9565ce93fc45a729028de510bc242e7dbfd Mon Sep 17 00:00:00 2001 From: "Xin.Zh" Date: Wed, 31 Jul 2024 14:21:46 +0800 Subject: [PATCH] Update pika_consensus.h --- include/pika_consensus.h | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/include/pika_consensus.h b/include/pika_consensus.h index ba2cf3da3b..bb774b5e3b 100644 --- a/include/pika_consensus.h +++ b/include/pika_consensus.h @@ -170,7 +170,7 @@ class ConsensusCoordinator { pstd::Status InternalAppendLog(const std::shared_ptr& cmd_ptr); pstd::Status InternalAppendBinlog(const std::shared_ptr& cmd_ptr); void InternalApply(const MemLog::LogItem& log); - void InternalApplyFollower(std::shared_ptr cmd_ptr); + void InternalApplyFollower(const std::shared_ptr& cmd_ptr); pstd::Status GetBinlogOffset(const BinlogOffset& start_offset, LogOffset* log_offset); pstd::Status GetBinlogOffset(const BinlogOffset& start_offset, const BinlogOffset& end_offset, @@ -182,6 +182,7 @@ class ConsensusCoordinator { pstd::Status FindLogicOffset(const BinlogOffset& start_offset, uint64_t target_index, LogOffset* found_offset); pstd::Status GetLogsBefore(const BinlogOffset& start_offset, std::vector* hints); + private: // keep members in this class works in order pstd::Mutex order_mu_;