Explorar o código

server: apply ents when loading log

Yicheng Qin %!s(int64=11) %!d(string=hai) anos
pai
achega
ffa5eb08c3
Modificáronse 1 ficheiros con 1 adicións e 0 borrados
  1. 1 0
      etcd/participant.go

+ 1 - 0
etcd/participant.go

@@ -130,6 +130,7 @@ func newParticipant(id int64, pubAddr string, raftPubAddr string, dir string, cl
 		}
 		p.id = n.Id
 		p.node.Node = raft.Recover(n.Id, n.Ents, n.State, defaultHeartbeat, defaultElection)
+		p.apply(p.node.Next())
 		log.Printf("id=%x participant.load path=%s\n", p.id, walPath)
 	}
 	p.w = w