Эх сурвалжийг харах

Move GRPC_CLOSURE_RUN to GRPC_CLOSURE_SCHED

- As here we want it to be scheduled for execution later.
Karthik Ravi Shankar 6 жил өмнө
parent
commit
ccc105f3fd

+ 6 - 5
src/core/lib/surface/completion_queue.cc

@@ -861,7 +861,7 @@ static void cq_end_op_for_callback(
     grpc_core::ApplicationCallbackExecCtx::Enqueue(functor,
                                                    (error == GRPC_ERROR_NONE));
   } else {
-    GRPC_CLOSURE_RUN(
+    GRPC_CLOSURE_SCHED(
         GRPC_CLOSURE_CREATE(
             functor_callback, functor,
             grpc_core::Executor::Scheduler(grpc_core::ExecutorJobType::SHORT)),
@@ -1352,10 +1352,11 @@ static void cq_finish_shutdown_callback(grpc_completion_queue* cq) {
   GPR_ASSERT(cqd->shutdown_called);
 
   cq->poller_vtable->shutdown(POLLSET_FROM_CQ(cq), &cq->pollset_shutdown_done);
-  GRPC_CLOSURE_RUN(GRPC_CLOSURE_CREATE(functor_callback, callback,
-                                       grpc_core::Executor::Scheduler(
-                                           grpc_core::ExecutorJobType::SHORT)),
-                   GRPC_ERROR_NONE);
+  GRPC_CLOSURE_SCHED(
+      GRPC_CLOSURE_CREATE(
+          functor_callback, callback,
+          grpc_core::Executor::Scheduler(grpc_core::ExecutorJobType::SHORT)),
+      GRPC_ERROR_NONE);
 }
 
 static void cq_shutdown_callback(grpc_completion_queue* cq) {