|
|
@ -111,8 +111,8 @@ int main(int argc, char **argv) { |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&sync.pollset)); |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&sync.pollset)); |
|
|
|
while (!sync.is_done) { |
|
|
|
while (!sync.is_done) { |
|
|
|
grpc_pollset_worker worker; |
|
|
|
grpc_pollset_worker worker; |
|
|
|
grpc_pollset_work(&sync.pollset, &worker, |
|
|
|
grpc_pollset_work(&sync.pollset, &worker, gpr_now(GPR_CLOCK_MONOTONIC), |
|
|
|
gpr_inf_future(GPR_CLOCK_REALTIME)); |
|
|
|
gpr_inf_future(GPR_CLOCK_MONOTONIC)); |
|
|
|
} |
|
|
|
} |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&sync.pollset)); |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&sync.pollset)); |
|
|
|
|
|
|
|
|
|
|
|