address @bright-starry-sky's comments

vesoft-inc · Jun 10, 2021 · 77512a4 · 77512a4
1 parent fc86151
commit 77512a4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/kvstore/Listener.cpp b/src/kvstore/Listener.cpp
@@ -237,6 +237,7 @@ std::pair<int64_t, int64_t> Listener::commitSnapshot(const std::vector<std::stri
     }
     if (finished) {
         CHECK(!raftLock_.try_lock());
+        leaderCommitId_ = committedLogId;
         lastApplyLogId_ = committedLogId;
         persist(committedLogId, committedLogTerm, lastApplyLogId_);
         LOG(INFO) << idStr_ << "Listener succeeded apply log to " << lastApplyLogId_;

diff --git a/src/kvstore/Listener.h b/src/kvstore/Listener.h
@@ -110,6 +110,7 @@ class Listener : public raftex::RaftPart {
     }
 
     void cleanup() override {
+        leaderCommitId_ = 0;
         lastApplyLogId_ = 0;
         persist(0, 0, lastApplyLogId_);
     }