Bläddra i källkod

Restrict next_index to be non-zero.

Otherwise we start with a install snapshot request at the beginning of
the term.
Jing Yang 3 år sedan
förälder
incheckning
aac1aed60b
1 ändrade filer med 1 tillägg och 0 borttagningar
  1. 1 0
      src/sync_log_entries.rs

+ 1 - 0
src/sync_log_entries.rs

@@ -45,6 +45,7 @@ impl SyncLogEntriesComms {
     }
 
     pub fn reset_progress(&self, term: Term, index: Index) {
+        let index = std::cmp::max(index, 1);
         let _ = self.tx.send(Event::NewTerm(term, index));
     }