Browse Source

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
Anthony Romano 9 years ago
parent
commit
8c8742f43c
2 changed files with 2 additions and 2 deletions
  1. 1 1
      clientv3/integration/watch_test.go
  2. 1 1
      integration/v3_watch_test.go

+ 1 - 1
clientv3/integration/watch_test.go

@@ -487,7 +487,7 @@ func testWatchWithProgressNotify(t *testing.T, watchOnPut bool) {
 		} else if len(resp.Events) != 0 { // wait for notification otherwise
 		} else if len(resp.Events) != 0 { // wait for notification otherwise
 			t.Fatalf("expected no events, but got %+v", resp.Events)
 			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)
 		t.Fatalf("watch response expected in %v, but timed out", pi)
 	}
 	}
 }
 }

+ 1 - 1
integration/v3_watch_test.go

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