Apply log entries on rsm for followers

resetius · Dec 23, 2024 · ffc7eca · ffc7eca
1 parent 3bb7b4d
commit ffc7eca
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/raft.cpp b/src/raft.cpp
@@ -235,6 +235,7 @@ void TRaft::OnAppendEntries(ITimeSource::Time now, TMessageHolder<TAppendEntries
     (*VolatileState)
         .SetCommitIndex(commitIndex)
         .SetElectionDue(MakeElection(now));
+
     Become(EState::FOLLOWER);
     Nodes[reply->Dst]->Send(std::move(reply));
 }
@@ -407,6 +408,8 @@ void TRaft::FollowerTimeout(ITimeSource::Time now) {
     if (VolatileState->ElectionDue <= now) {
         Become(EState::CANDIDATE);
     }
+
+    ProcessCommitted();
 }
 
 void TRaft::CandidateTimeout(ITimeSource::Time now) {

diff --git a/src/server.cpp b/src/server.cpp
@@ -164,7 +164,8 @@ void TRaftServer<TSocket>::DebugPrint() {
         std::cout << "Leader, "
             << "Term: " << state->CurrentTerm << ", "
             << "Index: " << state->Log.size() << ", "
-            << "CommitIndex: " << volatileState->CommitIndex << ", ";
+            << "CommitIndex: " << volatileState->CommitIndex << ", "
+            << "LastApplied: " << volatileState->LastApplied << ", ";
         std::cout << "Delay: ";
         for (auto [id, index] : volatileState->MatchIndex) {
             std::cout << id << ":" << (state->Log.size() - index) << " ";
@@ -183,12 +184,14 @@ void TRaftServer<TSocket>::DebugPrint() {
             << "Term: " << state->CurrentTerm << ", "
             << "Index: " << state->Log.size() << ", "
             << "CommitIndex: " << volatileState->CommitIndex << ", "
+            << "LastApplied: " << volatileState->LastApplied << ", "
             << "\n";
     } else if (Raft->CurrentStateName() == EState::FOLLOWER) {
         std::cout << "Follower, "
             << "Term: " << state->CurrentTerm << ", "
             << "Index: " << state->Log.size() << ", "
             << "CommitIndex: " << volatileState->CommitIndex << ", "
+            << "LastApplied: " << volatileState->LastApplied << ", "
             << "\n";
     }
 }