Browse Source

integration: fix TestForceNewCluster to wait leader

Yicheng Qin 11 years ago
parent
commit
d380be8fa1
1 changed files with 1 additions and 0 deletions
  1. 1 0
      integration/cluster_test.go

+ 1 - 0
integration/cluster_test.go

@@ -158,6 +158,7 @@ func TestForceNewCluster(t *testing.T) {
 		t.Fatalf("unexpected ForceRestart error: %v", err)
 	}
 	defer c.Members[0].Terminate(t)
+	c.waitLeader(t, c.Members[:1])
 
 	// use new http client to init new connection
 	cc = mustNewHTTPClient(t, []string{c.Members[0].URL()})