github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-23 10:32:03 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #91585 from liggitt/pending-pod-timeout

Browse Source 
Add debugging and timeouts to pending pod e2e
This commit is contained in:
Kubernetes Prow Robot 2020-05-30 02:58:08 -07:00 committed by GitHub
commit 6468bfa770
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
test/e2e/node/pods.go
View File

@ -289,7 +289,11 @@ var _ = SIGDescribe("Pods Extended", func() {
}
for event := range w.ResultChan() {
events = append(events, event)
if event.Type == watch.Error {
framework.Logf("watch error seen for %s: %#v", pod.Name, event.Object)
}
if event.Type == watch.Deleted {
framework.Logf("watch delete seen for %s", pod.Name)
break
}
}
@ -301,12 +305,20 @@ var _ = SIGDescribe("Pods Extended", func() {
err := podClient.Delete(context.TODO(), pod.Name, metav1.DeleteOptions{})
framework.ExpectNoError(err, "failed to delete pod")
events, ok := <-ch
if !ok {
continue
}
if len(events) < 2 {
framework.Fail("only got a single event")
var (
events []watch.Event
ok bool
)
select {
case events, ok = <-ch:
if !ok {
continue
}
if len(events) < 2 {
framework.Fail("only got a single event")
}
case <-time.After(5 * time.Minute):
framework.Failf("timed out waiting for watch events for %s", pod.Name)
}
end := time.Now()
@ -381,8 +393,8 @@ var _ = SIGDescribe("Pods Extended", func() {
}
}
func() {
defer lock.Unlock()
lock.Lock()
defer lock.Unlock()
if eventErr != nil {
errs = append(errs, eventErr)