Bugfix

resetius · Nov 29, 2023 · a21499a · a21499a
1 parent 0945107
commit a21499a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/raft.cpp b/src/raft.cpp
@@ -151,7 +151,7 @@ std::unique_ptr<TResult> TRaft::OnRequestVote(TMessageHolder<TRequestVoteRespons
 }
 
 std::unique_ptr<TResult> TRaft::OnAppendEntries(TMessageHolder<TAppendEntriesRequest> message) {
-    if (message->Term < State->CurrentTerm) {
+    if (message->Term > State->CurrentTerm) {
         auto reply = NewHoldedMessage<TAppendEntriesResponse>();
         reply->Src = Id;
         reply->Dst = message->Src;
@@ -239,7 +239,7 @@ TMessageHolder<TRequestVoteRequest> TRaft::CreateVote() {
     auto mes = NewHoldedMessage(
         TMessageEx {.Src = Id, .Dst = 0, .Term = State->CurrentTerm+1},
         TRequestVoteRequest {
-            .LastLogIndex = State->Log.size(),             
+            .LastLogIndex = State->Log.size(),
             .LastLogTerm = State->Log.empty() ? 0 : State->Log.back()->Term,
             .CandidateId = Id,
         });