github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Increase etcd test server up timeout to wait.ForeverTestTimeout

Browse Source
This commit is contained in:
Janet Kuo 2016-05-26 14:35:57 -07:00
parent f24b7a7391
commit 3cc2311c54
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/storage/etcd/testing/utils.go
View File

@ -27,6 +27,8 @@ import (
"testing" "testing"
"time" "time"
"k8s.io/kubernetes/pkg/util/wait"
etcd "github.com/coreos/etcd/client" etcd "github.com/coreos/etcd/client"
"github.com/coreos/etcd/etcdserver" "github.com/coreos/etcd/etcdserver"
"github.com/coreos/etcd/etcdserver/api/v2http" "github.com/coreos/etcd/etcdserver/api/v2http"
@ -186,7 +188,7 @@ func (m *EtcdTestServer) launch(t *testing.T) error {
// waitForEtcd wait until etcd is propagated correctly // waitForEtcd wait until etcd is propagated correctly
func (m *EtcdTestServer) waitUntilUp() error { func (m *EtcdTestServer) waitUntilUp() error {
membersAPI := etcd.NewMembersAPI(m.Client) membersAPI := etcd.NewMembersAPI(m.Client)
for start := time.Now(); time.Since(start) < 5*time.Second; time.Sleep(10 * time.Millisecond) { for start := time.Now(); time.Since(start) < wait.ForeverTestTimeout; time.Sleep(10 * time.Millisecond) {
members, err := membersAPI.List(context.TODO()) members, err := membersAPI.List(context.TODO())
if err != nil { if err != nil {
glog.Errorf("Error when getting etcd cluster members") glog.Errorf("Error when getting etcd cluster members")