Skip to content

K
k3s
Commit f8d4f615 authored by k8s-merge-robot's avatar k8s-merge-robot
Browse files
Options

Merge pull request #24570 from hongchaodeng/w

Automatic merge from submit-queue watcher test: print more info for debugging ref: #24528 This will print out more info to dig out the root cause.
parents 1f8bd21a 2bc022aa
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 2 deletions
pkg/storage/etcd3/watcher_test.go
View file @ f8d4f615
...@@ -199,9 +199,16 @@ func testCheckResult(t *testing.T, i int, expectEventType watch.EventType, w wat ...@@ -199,9 +199,16 @@ func testCheckResult(t *testing.T, i int, expectEventType watch.EventType, w wat
func testCheckStop(t *testing.T, i int, w watch.Interface) { func testCheckStop(t *testing.T, i int, w watch.Interface) {
select { select {
case _, ok := <-w.ResultChan(): case e, ok := <-w.ResultChan():
if ok { if ok {
t.Errorf("#%d: ResultChan should have been closed", i) var obj string
switch e.Object.(type) {
case *api.Pod:
obj = e.Object.(*api.Pod).Name
case *unversioned.Status:
obj = e.Object.(*unversioned.Status).Message
}
t.Errorf("#%d: ResultChan should have been closed. Event: %s. Object: %s", i, e.Type, obj)
} }
case <-time.After(wait.ForeverTestTimeout): case <-time.After(wait.ForeverTestTimeout):
t.Errorf("#%d: time out after waiting 1s on ResultChan", i) t.Errorf("#%d: time out after waiting 1s on ResultChan", i)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment