integration: change timeouts for TestWatchWithProgressNotify

a) 2 * progress interval was passing with dropped notifies
b) waitResponse was waiting so long that it expected a dropped notify
This commit is contained in:
Anthony Romano 2016-07-20 11:39:06 -07:00 committed by Gyu-Ho Lee
parent a4e79d7ebf
commit 21092ca715
2 changed files with 2 additions and 2 deletions

View File

@ -487,7 +487,7 @@ func testWatchWithProgressNotify(t *testing.T, watchOnPut bool) {
} else if len(resp.Events) != 0 { // wait for notification otherwise
t.Fatalf("expected no events, but got %+v", resp.Events)
}
case <-time.After(2 * pi):
case <-time.After(time.Duration(1.5 * float64(pi))):
t.Fatalf("watch response expected in %v, but timed out", pi)
}
}

View File

@ -971,7 +971,7 @@ func TestWatchWithProgressNotify(t *testing.T) {
}
// no more notification
rok, resp := waitResponse(wStream, testInterval+time.Second)
rok, resp := waitResponse(wStream, time.Second)
if !rok {
t.Errorf("unexpected pb.WatchResponse is received %+v", resp)
}