server: not set participant status for peer that points to itself

This commit is contained in:
Yicheng Qin 2014-08-04 23:24:32 -07:00
parent 01fdaea8a6
commit 394893ff92

View File

@ -357,7 +357,9 @@ func (p *participant) apply(ents []raft.Entry) {
log.Printf("id=%x participant.cluster.addNode peerAddErr=\"%v\"\n", p.id, err)
break
}
peer.participate()
if p.id != cfg.NodeId {
peer.participate()
}
pp := path.Join(v2machineKVPrefix, fmt.Sprint(cfg.NodeId))
p.Store.Set(pp, false, fmt.Sprintf("raft=%v&etcd=%v", cfg.Addr, string(cfg.Context)), store.Permanent)
if p.id == cfg.NodeId {