|
|
|
@ -255,8 +255,8 @@ static void pollset_set_test_basic() { |
|
|
|
|
make_test_fds_readable(tfds, num_fds); |
|
|
|
|
|
|
|
|
|
gpr_mu_lock(pollsets[i].mu); |
|
|
|
|
deadline = |
|
|
|
|
grpc_timespec_to_millis(grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
deadline = grpc_timespec_to_millis_round_up( |
|
|
|
|
grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
GPR_ASSERT(GRPC_ERROR_NONE == |
|
|
|
|
grpc_pollset_work(&exec_ctx, pollsets[i].ps, &worker, deadline)); |
|
|
|
|
gpr_mu_unlock(pollsets[i].mu); |
|
|
|
@ -337,7 +337,8 @@ void pollset_set_test_dup_fds() { |
|
|
|
|
make_test_fds_readable(tfds, num_fds); |
|
|
|
|
|
|
|
|
|
gpr_mu_lock(pollset.mu); |
|
|
|
|
deadline = grpc_timespec_to_millis(grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
deadline = grpc_timespec_to_millis_round_up( |
|
|
|
|
grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
GPR_ASSERT(GRPC_ERROR_NONE == |
|
|
|
|
grpc_pollset_work(&exec_ctx, pollset.ps, &worker, deadline)); |
|
|
|
|
gpr_mu_unlock(pollset.mu); |
|
|
|
@ -405,7 +406,8 @@ void pollset_set_test_empty_pollset() { |
|
|
|
|
make_test_fds_readable(tfds, num_fds); |
|
|
|
|
|
|
|
|
|
gpr_mu_lock(pollsets[0].mu); |
|
|
|
|
deadline = grpc_timespec_to_millis(grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
deadline = grpc_timespec_to_millis_round_up( |
|
|
|
|
grpc_timeout_milliseconds_to_deadline(2)); |
|
|
|
|
GPR_ASSERT(GRPC_ERROR_NONE == |
|
|
|
|
grpc_pollset_work(&exec_ctx, pollsets[0].ps, &worker, deadline)); |
|
|
|
|
gpr_mu_unlock(pollsets[0].mu); |
|
|
|
|