Explorar el Código

Reset the step counter when append entries succeeded.

Jing Yang hace 5 años
padre
commit
eed4e569f4
Se han modificado 1 ficheros con 1 adiciones y 0 borrados
  1. 1 0
      src/lib.rs

+ 1 - 0
src/lib.rs

@@ -660,6 +660,7 @@ impl Raft {
                 if succeeded {
                     let mut rf = rf.lock();
                     rf.next_index[peer_index] = match_index + 1;
+                    rf.current_step[peer_index] = 0;
                     if match_index > rf.match_index[peer_index] {
                         rf.match_index[peer_index] = match_index;
                         if rf.is_leader() && rf.current_term == term {