Commit56ed20a

committed

Prevent Raft followers from applying entries which they have not received yet.

1 parent1552662 commit56ed20aCopy full SHA for 56ed20a

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -320,7 +320,7 @@ bool raft_peer_up(raft_t r, int id, char *host, int port, bool self) {`
`320`	`320`	`staticintraft_apply(raft_traft) {`
`321`	`321`	`intapplied_now=0;`
`322`	`322`	`raft_log_t*l=&raft->log;`
`323`		`-while (l->applied<l->acked) {`
	`323`	`+while ((l->applied<l->acked)&& (l->applied <=RAFT_LOG_LAST_INDEX(raft))) {`
`324`	`324`	`raft_entry_t*e=&RAFT_LOG(raft,l->applied);`
`325`	`325`	`assert(e->update.len==e->bytes);`
`326`	`326`	`raft->config.applier(raft->config.userdata,e->update, false);`

Comments

(0)