From ceb3e27fff76221ab73e166b0d5dbd6a84a7e148 Mon Sep 17 00:00:00 2001 From: deads2k Date: Thu, 9 Mar 2017 08:44:28 -0500 Subject: [PATCH] add debugging to the client watch test --- test/e2e/generated_clientset.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/test/e2e/generated_clientset.go b/test/e2e/generated_clientset.go index c060a717f68..814b75e8625 100644 --- a/test/e2e/generated_clientset.go +++ b/test/e2e/generated_clientset.go @@ -100,12 +100,19 @@ func observeCreation(w watch.Interface) { } func observeObjectDeletion(w watch.Interface) (obj runtime.Object) { + // output to give us a duration to failure. Maybe we aren't getting the + // full timeout for some reason. My guess would be watch failure + framework.Logf("Starting to observe pod deletion") deleted := false timeout := false timer := time.After(60 * time.Second) for !deleted && !timeout { select { - case event, _ := <-w.ResultChan(): + case event, normal := <-w.ResultChan(): + if !normal { + framework.Failf("The channel was closed unexpectedly") + return + } if event.Type == watch.Deleted { obj = event.Object deleted = true