From 2d761d64a419cfee98bb72d53346d6335862467f Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Sat, 16 Jul 2016 10:24:56 -0700 Subject: [PATCH] etcdserver: set applied index correctly --- etcdserver/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/etcdserver/server.go b/etcdserver/server.go index ec51ca218..28336f593 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -1044,6 +1044,7 @@ func (s *EtcdServer) applyEntryNormal(e *raftpb.Entry) { s.consistIndex.setConsistentIndex(e.Index) shouldApplyV3 = true } + defer s.setAppliedIndex(e.Index) // raft state machine may generate noop entry when leader confirmation. // skip it in advance to avoid some potential bug in the future @@ -1082,7 +1083,6 @@ func (s *EtcdServer) applyEntryNormal(e *raftpb.Entry) { if s.w.IsRegistered(id) || !noSideEffect(&raftReq) { ar = s.applyV3.Apply(&raftReq) } - s.setAppliedIndex(e.Index) if ar == nil { return