Просмотр исходного кода

Refuse to append entries when the RPC is inconsistent.

Jing Yang 4 лет назад
Родитель
Сommit
c57b6dd644
1 измененных файлов с 6 добавлено и 0 удалено
  1. 6 0
      src/process_append_entries.rs

+ 6 - 0
src/process_append_entries.rs

@@ -67,6 +67,12 @@ where
                 "Entries in AppendEntries request shows index mismatch",
                 "Entries in AppendEntries request shows index mismatch",
                 &rf
                 &rf
             );
             );
+
+            return AppendEntriesReply {
+                term: args.term,
+                success: false,
+                committed: Some(rf.log.first_after(rf.commit_index).into()),
+            };
         }
         }
 
 
         // COMMIT_INDEX_INVARIANT: Before this loop, we can safely assume that
         // COMMIT_INDEX_INVARIANT: Before this loop, we can safely assume that