|
|
@@ -161,8 +161,7 @@ impl<Command: ReplicableCommand> Raft<Command> {
|
|
|
let index = rf.log.add_command(term, command);
|
|
|
self.persister.save_state(rf.persisted_state().into());
|
|
|
|
|
|
- // Several attempts have been made to remove the unwrap below.
|
|
|
- let _ = self.sync_log_entries_comms.update_followers(index);
|
|
|
+ self.sync_log_entries_comms.update_followers(index);
|
|
|
|
|
|
log::info!("{:?} started new entry at {} {:?}", self.me, index, term);
|
|
|
Some(IndexTerm::pack(index, term))
|