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

watcher test: print more info for debugging

Browse Source
This commit is contained in:
Hongchao Deng 2016-04-21 06:40:52 +08:00
parent 5fe6f39141
commit 2bc022aad4
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/storage/etcd3/watcher_test.go
View File

@ -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)