diff --git a/src/lib/replication/repl_dev/raft_repl_dev.cpp b/src/lib/replication/repl_dev/raft_repl_dev.cpp index 3fd68ee24..b8ea8a8fd 100644 --- a/src/lib/replication/repl_dev/raft_repl_dev.cpp +++ b/src/lib/replication/repl_dev/raft_repl_dev.cpp @@ -1570,7 +1570,7 @@ void RaftReplDev::create_snp_resync_data(raft_buf_ptr_t& data_out) { std::memcpy(data_out->data_begin(), &msg, msg_size); } -bool RaftReplDev::apply_snp_resync_data(nuraft::buffer& data) { +bool RaftReplDev::save_snp_resync_data(nuraft::buffer& data) { auto msg = r_cast< snp_repl_dev_data* >(data.data_begin()); if (msg->magic_num != HOMESTORE_RESYNC_DATA_MAGIC || msg->protocol_version != HOMESTORE_RESYNC_DATA_PROTOCOL_VERSION_V1) { diff --git a/src/lib/replication/repl_dev/raft_repl_dev.h b/src/lib/replication/repl_dev/raft_repl_dev.h index 5e66e18f8..619da7843 100644 --- a/src/lib/replication/repl_dev/raft_repl_dev.h +++ b/src/lib/replication/repl_dev/raft_repl_dev.h @@ -324,7 +324,7 @@ class RaftReplDev : public ReplDev, void replace_member(repl_req_ptr_t rreq); void reset_quorum_size(uint32_t commit_quorum); void create_snp_resync_data(raft_buf_ptr_t& data_out); - bool apply_snp_resync_data(nuraft::buffer& data); + bool save_snp_resync_data(nuraft::buffer& data); }; } // namespace homestore diff --git a/src/lib/replication/repl_dev/raft_state_machine.cpp b/src/lib/replication/repl_dev/raft_state_machine.cpp index 77fd54501..e0193ef03 100644 --- a/src/lib/replication/repl_dev/raft_state_machine.cpp +++ b/src/lib/replication/repl_dev/raft_state_machine.cpp @@ -354,9 +354,9 @@ void RaftStateMachine::save_logical_snp_obj(nuraft::snapshot& s, ulong& obj_id, bool is_last_obj) { if (is_hs_snp_obj(obj_id)) { // Homestore preserved msg - if (m_rd.apply_snp_resync_data(data)) { + if (m_rd.save_snp_resync_data(data)) { obj_id = snp_obj_id_type_app; - LOGDEBUG("apply_snp_resync_data success, next obj_id={}", obj_id); + LOGDEBUG("save_snp_resync_data success, next obj_id={}", obj_id); } return; }