소스 검색

etcdserver: not add self to transporter based on local ID

If this is decided by local name, it comes to trouble if the name is
duplicate in the cluster.
Yicheng Qin 11 년 전
부모
커밋
7840d49ae0
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      etcdserver/server.go

+ 1 - 1
etcdserver/server.go

@@ -253,7 +253,7 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
 	tr := rafthttp.NewTransporter(cfg.Transport, id, cfg.Cluster.ID(), srv, srv.errorc, sstats, lstats)
 	// add all the remote members into sendhub
 	for _, m := range cfg.Cluster.Members() {
-		if m.Name != cfg.Name {
+		if m.ID != id {
 			tr.AddPeer(m.ID, m.PeerURLs)
 		}
 	}