|
|
|
@ -71,9 +71,8 @@ static void add_test(void) { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/* collect timers. Only the first batch should be ready. */ |
|
|
|
|
GPR_ASSERT(10 == grpc_timer_check(&exec_ctx, |
|
|
|
|
gpr_time_add(start, gpr_time_from_millis( |
|
|
|
|
500, GPR_TIMESPAN)), |
|
|
|
|
GPR_ASSERT(grpc_timer_check( |
|
|
|
|
&exec_ctx, gpr_time_add(start, gpr_time_from_millis(500, GPR_TIMESPAN)), |
|
|
|
|
NULL)); |
|
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
|
|
for (i = 0; i < 20; i++) { |
|
|
|
@ -81,9 +80,9 @@ static void add_test(void) { |
|
|
|
|
GPR_ASSERT(cb_called[i][0] == 0); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(0 == grpc_timer_check(&exec_ctx, |
|
|
|
|
gpr_time_add(start, gpr_time_from_millis( |
|
|
|
|
600, GPR_TIMESPAN)), |
|
|
|
|
GPR_ASSERT(!grpc_timer_check( |
|
|
|
|
&exec_ctx, |
|
|
|
|
gpr_time_add(start, gpr_time_from_millis(600, GPR_TIMESPAN)), |
|
|
|
|
NULL)); |
|
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
|
|
for (i = 0; i < 30; i++) { |
|
|
|
@ -92,9 +91,8 @@ static void add_test(void) { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/* collect the rest of the timers */ |
|
|
|
|
GPR_ASSERT(10 == grpc_timer_check( |
|
|
|
|
&exec_ctx, gpr_time_add(start, gpr_time_from_millis( |
|
|
|
|
1500, GPR_TIMESPAN)), |
|
|
|
|
GPR_ASSERT(grpc_timer_check( |
|
|
|
|
&exec_ctx, gpr_time_add(start, gpr_time_from_millis(1500, GPR_TIMESPAN)), |
|
|
|
|
NULL)); |
|
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
|
|
for (i = 0; i < 30; i++) { |
|
|
|
@ -102,9 +100,9 @@ static void add_test(void) { |
|
|
|
|
GPR_ASSERT(cb_called[i][0] == 0); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(0 == grpc_timer_check(&exec_ctx, |
|
|
|
|
gpr_time_add(start, gpr_time_from_millis( |
|
|
|
|
1600, GPR_TIMESPAN)), |
|
|
|
|
GPR_ASSERT(!grpc_timer_check( |
|
|
|
|
&exec_ctx, |
|
|
|
|
gpr_time_add(start, gpr_time_from_millis(1600, GPR_TIMESPAN)), |
|
|
|
|
NULL)); |
|
|
|
|
for (i = 0; i < 30; i++) { |
|
|
|
|
GPR_ASSERT(cb_called[i][1] == (i < 20)); |
|
|
|
|