address @bright-starry-sky's comments

vesoft-inc · Jun 10, 2021 · bca0ce3 · bca0ce3
1 parent 3d4fe5b
commit bca0ce3
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
@@ -238,6 +238,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
@@ -111,6 +111,7 @@ class Listener : public raftex::RaftPart {
     }
 
     void cleanup() override {
+        leaderCommitId_ = 0;
         lastApplyLogId_ = 0;
         persist(0, 0, lastApplyLogId_);
     }