kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Deflake TestPrepareRun 

Kubernetes-commit: ba4aade23a76969d7598fb7ac170891c183e7327
This commit is contained in:
Jordan Liggitt 2021-03-06 19:46:00 -05:00 committed by Kubernetes Publisher
parent 1cafa89bf5
commit a70d9c48f0
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/server/genericapiserver_test.go
View File

@ -40,6 +40,7 @@ import (
"k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/apimachinery/pkg/runtime/serializer"
utilruntime "k8s.io/apimachinery/pkg/util/runtime" utilruntime "k8s.io/apimachinery/pkg/util/runtime"
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/sets"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/apimachinery/pkg/version" "k8s.io/apimachinery/pkg/version"
"k8s.io/apiserver/pkg/apis/example" "k8s.io/apiserver/pkg/apis/example"
examplev1 "k8s.io/apiserver/pkg/apis/example/v1" examplev1 "k8s.io/apiserver/pkg/apis/example/v1"
@ -320,6 +321,7 @@ func TestPrepareRun(t *testing.T) {
server := httptest.NewServer(s.Handler.Director) server := httptest.NewServer(s.Handler.Director)
defer server.Close() defer server.Close()
done := make(chan struct{}) done := make(chan struct{})
defer close(done)
s.PrepareRun() s.PrepareRun()
s.RunPostStartHooks(done) s.RunPostStartHooks(done)
@ -329,10 +331,19 @@ func TestPrepareRun(t *testing.T) {
assert.NoError(err) assert.NoError(err)
assert.Equal(http.StatusOK, resp.StatusCode) assert.Equal(http.StatusOK, resp.StatusCode)
// healthz checks are installed in PrepareRun // wait for health (max-in-flight-filter is initialized asynchronously, can take a few milliseconds to initialize)
resp, err = http.Get(server.URL + "/healthz") assert.NoError(wait.PollImmediate(100*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) {
assert.NoError(err) // healthz checks are installed in PrepareRun
assert.Equal(http.StatusOK, resp.StatusCode) resp, err = http.Get(server.URL + "/healthz")
assert.NoError(err)
data, _ := ioutil.ReadAll(resp.Body)
if http.StatusOK != resp.StatusCode {
t.Logf("got %d", resp.StatusCode)
t.Log(string(data))
return false, nil
}
return true, nil
}))
resp, err = http.Get(server.URL + "/healthz/ping") resp, err = http.Get(server.URL + "/healthz/ping")
assert.NoError(err) assert.NoError(err)
assert.Equal(http.StatusOK, resp.StatusCode) assert.Equal(http.StatusOK, resp.StatusCode)