Merge pull request #2665 from xiaost/fix-minor-bug-in-etcdserver-send

etcdserver: fix minor bug in EtcdServer.send
This commit is contained in:
Xiang Li 2015-04-13 07:27:12 -07:00
commit f480a8b051

View File

@ -650,9 +650,9 @@ func (s *EtcdServer) publish(retryInterval time.Duration) {
}
func (s *EtcdServer) send(ms []raftpb.Message) {
for _, m := range ms {
if !s.Cluster.IsIDRemoved(types.ID(m.To)) {
m.To = 0
for i, _ := range ms {
if s.Cluster.IsIDRemoved(types.ID(ms[i].To)) {
ms[i].To = 0
}
}
s.r.transport.Send(ms)