integration: fix TestForceNewCluster

This commit is contained in:
Yicheng Qin 2015-01-15 10:42:57 -08:00
parent c4e4a9711f
commit 68fdd70580

View File

@ -159,6 +159,9 @@ func TestForceNewCluster(t *testing.T) {
}
defer c.Members[0].Terminate(t)
// use new http client to init new connection
cc = mustNewHTTPClient(t, []string{c.Members[0].URL()})
kapi = client.NewKeysAPI(cc)
// ensure force restart keep the old data, and new cluster can make progress
ctx, cancel = context.WithTimeout(context.Background(), requestTimeout)
if _, err := kapi.Watch("/foo", resp.Node.ModifiedIndex).Next(ctx); err != nil {