|
|
@ -333,11 +333,11 @@ grpc_event grpc_completion_queue_next(grpc_completion_queue *cc, |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
grpc_exec_ctx_flush(&exec_ctx); |
|
|
|
grpc_exec_ctx_flush(&exec_ctx); |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
continue; |
|
|
|
} else { |
|
|
|
} |
|
|
|
|
|
|
|
grpc_pollset_work(&exec_ctx, &cc->pollset, &worker, now, |
|
|
|
grpc_pollset_work(&exec_ctx, &cc->pollset, &worker, now, |
|
|
|
iteration_deadline); |
|
|
|
iteration_deadline); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
GRPC_SURFACE_TRACE_RETURNED_EVENT(cc, &ret); |
|
|
|
GRPC_SURFACE_TRACE_RETURNED_EVENT(cc, &ret); |
|
|
|
GRPC_CQ_INTERNAL_UNREF(cc, "next"); |
|
|
|
GRPC_CQ_INTERNAL_UNREF(cc, "next"); |
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
|
grpc_exec_ctx_finish(&exec_ctx); |
|
|
@ -450,10 +450,10 @@ grpc_event grpc_completion_queue_pluck(grpc_completion_queue *cc, void *tag, |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
grpc_exec_ctx_flush(&exec_ctx); |
|
|
|
grpc_exec_ctx_flush(&exec_ctx); |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); |
|
|
|
continue; |
|
|
|
} else { |
|
|
|
} |
|
|
|
|
|
|
|
grpc_pollset_work(&exec_ctx, &cc->pollset, &worker, now, |
|
|
|
grpc_pollset_work(&exec_ctx, &cc->pollset, &worker, now, |
|
|
|
iteration_deadline); |
|
|
|
iteration_deadline); |
|
|
|
|
|
|
|
} |
|
|
|
del_plucker(cc, tag, &worker); |
|
|
|
del_plucker(cc, tag, &worker); |
|
|
|
} |
|
|
|
} |
|
|
|
done: |
|
|
|
done: |
|
|
|