Change runs to enqueue

5 files changed, 12 insertions, 12 deletions

diff --git a/src/core/client_config/lb_policies/pick_first.c b/src/core/client_config/lb_policies/pick_first.c
index c07cc81b27..75e6c01839 100644
--- a/src/core/client_config/lb_policies/pick_first.c
+++ b/src/core/client_config/lb_policies/pick_first.c
@@ -130,7 +130,7 @@ pf_shutdown (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
     {
       pending_pick *next = pp->next;
       *pp->target = NULL;
-      grpc_closure_list_add (closure_list, pp->on_complete, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 1);
       gpr_free (pp);
       pp = next;
     }
@@ -168,7 +168,7 @@ pf_pick (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol, grpc_pollset * pollset,
     {
       gpr_mu_unlock (&p->mu);
       *target = p->selected;
-      grpc_closure_list_add (closure_list, on_complete, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, on_complete, 1);
     }
   else
     {
@@ -226,7 +226,7 @@ pf_connectivity_changed (grpc_exec_ctx * exec_ctx, void *arg, int iomgr_success)
 	      p->pending_picks = pp->next;
 	      *pp->target = p->selected;
 	      grpc_subchannel_del_interested_party (exec_ctx, p->selected, pp->pollset);
-	      grpc_closure_list_add (closure_list, pp->on_complete, 1);
+	      grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 1);
 	      gpr_free (pp);
 	    }
 	  grpc_subchannel_notify_on_state_change (exec_ctx, p->selected, &p->checking_connectivity, &p->connectivity_changed);
@@ -263,7 +263,7 @@ pf_connectivity_changed (grpc_exec_ctx * exec_ctx, void *arg, int iomgr_success)
 		{
 		  p->pending_picks = pp->next;
 		  *pp->target = NULL;
-		  grpc_closure_list_add (closure_list, pp->on_complete, 1);
+		  grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 1);
 		  gpr_free (pp);
 		}
 	      GRPC_LB_POLICY_UNREF (exec_ctx, &p->base, "pick_first_connectivity");
diff --git a/src/core/client_config/lb_policies/round_robin.c b/src/core/client_config/lb_policies/round_robin.c
index b745628bbc..5f8976396b 100644
--- a/src/core/client_config/lb_policies/round_robin.c
+++ b/src/core/client_config/lb_policies/round_robin.c
@@ -292,7 +292,7 @@ rr_shutdown (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
     {
       p->pending_picks = pp->next;
       *pp->target = NULL;
-      grpc_closure_list_add (closure_list, pp->on_complete, 0);
+      grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 0);
       gpr_free (pp);
     }
   grpc_connectivity_state_set (exec_ctx, &p->state_tracker, GRPC_CHANNEL_FATAL_FAILURE, "shutdown");
@@ -416,7 +416,7 @@ rr_connectivity_changed (grpc_exec_ctx * exec_ctx, void *arg, int iomgr_success)
 		  gpr_log (GPR_DEBUG, "[RR CONN CHANGED] TARGET <-- SUBCHANNEL %p (NODE %p)", selected->subchannel, selected);
 		}
 	      grpc_subchannel_del_interested_party (exec_ctx, selected->subchannel, pp->pollset);
-	      grpc_closure_list_add (closure_list, pp->on_complete, 1);
+	      grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 1);
 	      gpr_free (pp);
 	    }
 	  grpc_subchannel_notify_on_state_change (exec_ctx, p->subchannels[this_idx], this_connectivity, &p->connectivity_changed_cbs[this_idx]);
@@ -458,7 +458,7 @@ rr_connectivity_changed (grpc_exec_ctx * exec_ctx, void *arg, int iomgr_success)
 		{
 		  p->pending_picks = pp->next;
 		  *pp->target = NULL;
-		  grpc_closure_list_add (closure_list, pp->on_complete, 1);
+		  grpc_exec_ctx_enqueue (exec_ctx, pp->on_complete, 1);
 		  gpr_free (pp);
 		}
 	      unref = 1;
diff --git a/src/core/client_config/resolvers/dns_resolver.c b/src/core/client_config/resolvers/dns_resolver.c
index 781f1a9e23..dc8151311a 100644
--- a/src/core/client_config/resolvers/dns_resolver.c
+++ b/src/core/client_config/resolvers/dns_resolver.c
@@ -96,7 +96,7 @@ dns_shutdown (grpc_exec_ctx * exec_ctx, grpc_resolver * resolver)
   if (r->next_completion != NULL)
     {
       *r->target_config = NULL;
-      grpc_closure_list_add (closure_list, r->next_completion, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, r->next_completion, 1);
       r->next_completion = NULL;
     }
   gpr_mu_unlock (&r->mu);
@@ -197,7 +197,7 @@ dns_maybe_finish_next_locked (grpc_exec_ctx * exec_ctx, dns_resolver * r)
 	{
 	  grpc_client_config_ref (r->resolved_config);
 	}
-      grpc_closure_list_add (closure_list, r->next_completion, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, r->next_completion, 1);
       r->next_completion = NULL;
       r->published_version = r->resolved_version;
     }
diff --git a/src/core/client_config/resolvers/sockaddr_resolver.c b/src/core/client_config/resolvers/sockaddr_resolver.c
index 1b2eac997d..f4c958c424 100644
--- a/src/core/client_config/resolvers/sockaddr_resolver.c
+++ b/src/core/client_config/resolvers/sockaddr_resolver.c
@@ -98,7 +98,7 @@ sockaddr_shutdown (grpc_exec_ctx * exec_ctx, grpc_resolver * resolver)
   if (r->next_completion != NULL)
     {
       *r->target_config = NULL;
-      grpc_closure_list_add (closure_list, r->next_completion, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, r->next_completion, 1);
       r->next_completion = NULL;
     }
   gpr_mu_unlock (&r->mu);
@@ -151,7 +151,7 @@ sockaddr_maybe_finish_next_locked (grpc_exec_ctx * exec_ctx, sockaddr_resolver *
       GRPC_LB_POLICY_UNREF (exec_ctx, lb_policy, "sockaddr");
       r->published = 1;
       *r->target_config = cfg;
-      grpc_closure_list_add (closure_list, r->next_completion, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, r->next_completion, 1);
       r->next_completion = NULL;
     }
 }
diff --git a/src/core/client_config/subchannel.c b/src/core/client_config/subchannel.c
index 3db2fae593..b0d71112d0 100644
--- a/src/core/client_config/subchannel.c
+++ b/src/core/client_config/subchannel.c
@@ -627,7 +627,7 @@ publish_transport (grpc_exec_ctx * exec_ctx, grpc_subchannel * c)
   while (w4c != NULL)
     {
       waiting_for_connect *next = w4c->next;
-      grpc_closure_list_add (closure_list, &w4c->continuation, 1);
+      grpc_exec_ctx_enqueue (exec_ctx, &w4c->continuation, 1);
       w4c = next;
     }