Removed exec_ctx from cq_alarm's functions

2 files changed, 13 insertions, 11 deletions

diff --git a/src/core/surface/completion_queue.c b/src/core/surface/completion_queue.c
index 368838860f..31ec1b68da 100644
--- a/src/core/surface/completion_queue.c
+++ b/src/core/surface/completion_queue.c
@@ -365,27 +365,30 @@ static void cq_alarm_cb(grpc_exec_ctx *exec_ctx, void *arg, int success) {
             do_nothing_end_completion, NULL, &cq_alarm->completion);
 }
 
-grpc_cq_alarm *grpc_cq_alarm_create(grpc_exec_ctx *exec_ctx,
-                                    grpc_completion_queue *cq,
+grpc_cq_alarm *grpc_cq_alarm_create(grpc_completion_queue *cq,
                                     gpr_timespec deadline, void *tag) {
     grpc_cq_alarm *cq_alarm = gpr_malloc(sizeof(grpc_cq_alarm));
+    grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
 
     GRPC_CQ_INTERNAL_REF(cq, "cq_alarm");
     cq_alarm->cq = cq;
     cq_alarm->tag = tag;
 
-    grpc_alarm_init(exec_ctx, &cq_alarm->alarm, deadline, cq_alarm_cb, cq_alarm,
+    grpc_alarm_init(&exec_ctx, &cq_alarm->alarm, deadline, cq_alarm_cb, cq_alarm,
                     gpr_now(GPR_CLOCK_MONOTONIC));
     grpc_cq_begin_op(cq);
+    grpc_exec_ctx_finish(&exec_ctx);
     return cq_alarm;
 }
 
-void grpc_cq_alarm_cancel(grpc_exec_ctx *exec_ctx, grpc_cq_alarm *cq_alarm) {
-    grpc_alarm_cancel(exec_ctx, &cq_alarm->alarm);
+void grpc_cq_alarm_cancel(grpc_cq_alarm *cq_alarm) {
+    grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
+    grpc_alarm_cancel(&exec_ctx, &cq_alarm->alarm);
+    grpc_exec_ctx_finish(&exec_ctx);
 }
 
-void grpc_cq_alarm_destroy(grpc_exec_ctx *exec_ctx, grpc_cq_alarm *cq_alarm) {
-    grpc_cq_alarm_cancel(exec_ctx, cq_alarm);
+void grpc_cq_alarm_destroy(grpc_cq_alarm *cq_alarm) {
+    grpc_cq_alarm_cancel(cq_alarm);
     GRPC_CQ_INTERNAL_UNREF(cq_alarm->cq, "cq_alarm");
     gpr_free(cq_alarm);
 }
diff --git a/src/core/surface/completion_queue.h b/src/core/surface/completion_queue.h
index ab5b87c5c8..12a7e9a147 100644
--- a/src/core/surface/completion_queue.h
+++ b/src/core/surface/completion_queue.h
@@ -99,15 +99,14 @@ int grpc_cq_is_server_cq(grpc_completion_queue *cc);
  * Once the alarm expires (at \a deadline) or it's cancelled (see ...), an event
  * with tag \a tag will be added to \a cq. If the alarm expired, the event's
  * success bit will be true, false otherwise (ie, upon cancellation). */
-grpc_cq_alarm *grpc_cq_alarm_create(grpc_exec_ctx *exec_ctx,
-                                    grpc_completion_queue *cq,
+grpc_cq_alarm *grpc_cq_alarm_create(grpc_completion_queue *cq,
                                     gpr_timespec deadline, void *tag);
 
 /** Cancel a completion queue alarm. Calling this function ove an alarm that has
  * already run has no effect. */
-void grpc_cq_alarm_cancel(grpc_exec_ctx *exec_ctx, grpc_cq_alarm *cq_alarm);
+void grpc_cq_alarm_cancel(grpc_cq_alarm *cq_alarm);
 
 /** Destroy the given completion queue alarm, cancelling it in the process. */
-void grpc_cq_alarm_destroy(grpc_exec_ctx *exec_ctx, grpc_cq_alarm *cq_alarm);
+void grpc_cq_alarm_destroy(grpc_cq_alarm *cq_alarm);
 
 #endif /* GRPC_INTERNAL_CORE_SURFACE_COMPLETION_QUEUE_H */