|
|
@ -927,10 +927,10 @@ static grpc_error *pollset_work(grpc_exec_ctx *exec_ctx, grpc_pollset *pollset, |
|
|
|
#define WORKER_PTR (&worker) |
|
|
|
#define WORKER_PTR (&worker) |
|
|
|
#endif |
|
|
|
#endif |
|
|
|
if (GRPC_TRACER_ON(grpc_polling_trace)) { |
|
|
|
if (GRPC_TRACER_ON(grpc_polling_trace)) { |
|
|
|
gpr_log(GPR_DEBUG, "PS:%p work hdl=%p worker=%p now=%" PRIdPTR " deadline=%" PRIdPTR " kwp=%d pollable=%p", |
|
|
|
gpr_log(GPR_DEBUG, "PS:%p work hdl=%p worker=%p now=%" PRIdPTR |
|
|
|
pollset, worker_hdl, WORKER_PTR,grpc_exec_ctx_now(exec_ctx), |
|
|
|
" deadline=%" PRIdPTR " kwp=%d pollable=%p", |
|
|
|
deadline, pollset->kicked_without_poller, |
|
|
|
pollset, worker_hdl, WORKER_PTR, grpc_exec_ctx_now(exec_ctx), |
|
|
|
pollset->active_pollable); |
|
|
|
deadline, pollset->kicked_without_poller, pollset->active_pollable); |
|
|
|
} |
|
|
|
} |
|
|
|
static const char *err_desc = "pollset_work"; |
|
|
|
static const char *err_desc = "pollset_work"; |
|
|
|
grpc_error *error = GRPC_ERROR_NONE; |
|
|
|
grpc_error *error = GRPC_ERROR_NONE; |
|
|
@ -943,9 +943,8 @@ static grpc_error *pollset_work(grpc_exec_ctx *exec_ctx, grpc_pollset *pollset, |
|
|
|
GPR_ASSERT(!pollset->shutdown_closure); |
|
|
|
GPR_ASSERT(!pollset->shutdown_closure); |
|
|
|
gpr_mu_unlock(&pollset->mu); |
|
|
|
gpr_mu_unlock(&pollset->mu); |
|
|
|
if (pollset->event_cursor == pollset->event_count) { |
|
|
|
if (pollset->event_cursor == pollset->event_count) { |
|
|
|
append_error(&error, |
|
|
|
append_error(&error, pollset_epoll(exec_ctx, pollset, |
|
|
|
pollset_epoll(exec_ctx, pollset, WORKER_PTR->pollable_obj, |
|
|
|
WORKER_PTR->pollable_obj, deadline), |
|
|
|
deadline), |
|
|
|
|
|
|
|
err_desc); |
|
|
|
err_desc); |
|
|
|
} |
|
|
|
} |
|
|
|
append_error(&error, pollset_process_events(exec_ctx, pollset, false), |
|
|
|
append_error(&error, pollset_process_events(exec_ctx, pollset, false), |
|
|
|