avoid concurrent join

tikv · Oct 23, 2018 · cb475a5 · cb475a5
1 parent c7ca4fb
commit cb475a5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/server/join.go b/server/join.go
@@ -126,6 +126,9 @@ func PrepareJoinCluster(cfg *Config) error {
 
 	existed := false
 	for _, m := range listResp.Members {
+		if len(m.Name) == 0 {
+			return errors.New("exsist a member that the join is not completed")
+		}
 		if m.Name == cfg.Name {
 			existed = true
 		}
@@ -154,6 +157,9 @@ func PrepareJoinCluster(cfg *Config) error {
 		if memb.ID == addResp.Member.ID {
 			n = cfg.Name
 		}
+		if len(n) == 0 {
+			return errors.New("exsist a member that the join is not completed")
+		}
 		for _, m := range memb.PeerURLs {
 			pds = append(pds, fmt.Sprintf("%s=%s", n, m))
 		}