use last_data_committed_lsn

eBay · Sep 10, 2024 · f6108de · f6108de
1 parent c9ada64
commit f6108de
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/tests/test_raft_repl_dev.cpp b/src/tests/test_raft_repl_dev.cpp
@@ -235,9 +235,7 @@ class TestReplicatedDB : public homestore::ReplDevListener {
     void write_snapshot_data(shared< snapshot_context > context, shared< snapshot_data > snp_data) override {
         auto s = std::dynamic_pointer_cast< nuraft_snapshot_context >(context)->nuraft_snapshot();
         if (snp_data->offset == 0) {
-            auto last_committed_idx =
-                std::dynamic_pointer_cast< RaftReplDev >(repl_dev())->raft_server()->get_committed_log_idx();
-            snp_data->offset = last_committed_idx + 1;
+            snp_data->offset = last_data_committed_lsn + 1;
             LOGINFOMOD(replication, "[Replica={}] Save logical snapshot callback return obj_id={}",
                        g_helper->replica_num(), snp_data->offset);
             return;