Prevent shutdown kick-spam

8 years ago · f809ca334c
parent 1e960fc80a
commit f809ca334c
1 changed files with 2 additions and 1 deletions
--- a/src/core/lib/surface/completion_queue.c
+++ b/src/core/lib/surface/completion_queue.c
@ -864,7 +864,8 @@ static grpc_event cq_next(grpc_completion_queue *cq, gpr_timespec deadline,
  grpc_exec_ctx_finish(&exec_ctx);
  GPR_ASSERT(is_finished_arg.stolen_completion == NULL);

-  if (cq_event_queue_num_items(&cqd->queue) > 0) {
+  if (cq_event_queue_num_items(&cqd->queue) > 0 &&
+      gpr_atm_no_barrier_load(&cqd->shutdown) == 0) {
    gpr_mu_lock(cqd->mu);
    cq->poller_vtable->kick(POLLSET_FROM_CQ(cq), NULL);
    gpr_mu_unlock(cqd->mu);