diff options
author | 2017-07-14 16:15:10 -0700 | |
---|---|---|
committer | 2017-08-13 22:30:10 -0700 | |
commit | 41ba268c201bc8c861f1ce929ced0f54c3301b10 (patch) | |
tree | 3d0170ef0b47b36803d69c33dcfff7b6077ef5b5 /test/core/transport | |
parent | a27680b597111bc3ddd1272a21be6d35a296b349 (diff) |
Pull bdp estimation into flowctl module
Diffstat (limited to 'test/core/transport')
-rw-r--r-- | test/core/transport/bdp_estimator_test.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/core/transport/bdp_estimator_test.c b/test/core/transport/bdp_estimator_test.c index e2612c7718..dda48f45b1 100644 --- a/test/core/transport/bdp_estimator_test.c +++ b/test/core/transport/bdp_estimator_test.c @@ -43,12 +43,13 @@ static void test_get_estimate_no_samples(void) { static void add_samples(grpc_bdp_estimator *estimator, int64_t *samples, size_t n) { - GPR_ASSERT(grpc_bdp_estimator_add_incoming_bytes(estimator, 1234567) == true); + grpc_bdp_estimator_add_incoming_bytes(estimator, 1234567); + GPR_ASSERT(grpc_bdp_estimator_need_ping(estimator) == true); grpc_bdp_estimator_schedule_ping(estimator); grpc_bdp_estimator_start_ping(estimator); for (size_t i = 0; i < n; i++) { - GPR_ASSERT(grpc_bdp_estimator_add_incoming_bytes(estimator, samples[i]) == - false); + grpc_bdp_estimator_add_incoming_bytes(estimator, samples[i]); + GPR_ASSERT(grpc_bdp_estimator_need_ping(estimator) == false); } gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), gpr_time_from_millis(1, GPR_TIMESPAN))); |