Add a grpc_exec_ctx_invalidate_now at the end of cq_next loop

7 years ago · dc84ed63d7
parent 66b740a8c6
commit dc84ed63d7
1 changed files with 1 additions and 0 deletions
--- a/src/core/lib/surface/completion_queue.cc
+++ b/src/core/lib/surface/completion_queue.cc
@ -972,6 +972,7 @@ static grpc_event cq_next(grpc_completion_queue *cq, gpr_timespec deadline,
      break;
    }
    is_finished_arg.first_loop = false;
+    grpc_exec_ctx_invalidate_now(&exec_ctx);
  }

  if (cq_event_queue_num_items(&cqd->queue) > 0 &&