github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 05:27:21 +00:00
Code Issues Projects Releases Wiki Activity

Add extra diagnostics to networking e2e test

Browse Source
This commit is contained in:
Satnam Singh 2015-03-20 14:57:50 -07:00
parent fbd362d3c7
commit 2d345cb60a
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
test/e2e/networking.go
View File

@ -150,13 +150,16 @@ var _ = Describe("Networking", func() {
var body []byte var body []byte
for i := 0; i < maxAttempts && !passed; i++ { for i := 0; i < maxAttempts && !passed; i++ {
time.Sleep(2 * time.Second) time.Sleep(2 * time.Second)
Logf("About to make a proxy status call")
start := time.Now()
body, err = c.Get(). body, err = c.Get().
Namespace(ns). Namespace(ns).
Prefix("proxy"). Prefix("proxy").
Resource("services"). Resource("services").
Name(svc.Name). Name(svc.Name).
Suffix("status"). Suffix("status").
Do().Raw() DoRaw()
Logf("Proxy status call returned in %v", time.Since(start))
if err != nil { if err != nil {
Logf("Attempt %v/%v: service/pod still starting. (error: '%v')", i, maxAttempts, err) Logf("Attempt %v/%v: service/pod still starting. (error: '%v')", i, maxAttempts, err)
continue continue
@ -174,7 +177,7 @@ var _ = Describe("Networking", func() {
Namespace(ns).Prefix("proxy"). Namespace(ns).Prefix("proxy").
Resource("services"). Resource("services").
Name(svc.Name).Suffix("read"). Name(svc.Name).Suffix("read").
Do().Raw(); err != nil { DoRaw(); err != nil {
Failf("Failed on attempt %v. Cleaning up. Error reading details: %v", i, err) Failf("Failed on attempt %v. Cleaning up. Error reading details: %v", i, err)
} else { } else {
Failf("Failed on attempt %v. Cleaning up. Details:\n%s", i, string(body)) Failf("Failed on attempt %v. Cleaning up. Details:\n%s", i, string(body))
@ -190,7 +193,7 @@ var _ = Describe("Networking", func() {
Resource("services"). Resource("services").
Name(svc.Name). Name(svc.Name).
Suffix("read"). Suffix("read").
Do().Raw(); err != nil { DoRaw(); err != nil {
Failf("Timed out. Cleaning up. Error reading details: %v", err) Failf("Timed out. Cleaning up. Error reading details: %v", err)
} else { } else {
Failf("Timed out. Cleaning up. Details:\n%s", string(body)) Failf("Timed out. Cleaning up. Details:\n%s", string(body))
@ -212,7 +215,7 @@ var _ = Describe("Networking", func() {
data, err := c.RESTClient.Get(). data, err := c.RESTClient.Get().
Namespace(ns). Namespace(ns).
AbsPath(test.path). AbsPath(test.path).
Do().Raw() DoRaw()
if err != nil { if err != nil {
Failf("Failed: %v\nBody: %s", err, string(data)) Failf("Failed: %v\nBody: %s", err, string(data))
} }