aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/client_config/lb_policies/pick_first.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:48:23 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:48:23 -0700
commit8ad03754ec6775fa4055644d43f06b748cc03d98 (patch)
tree25fb47ffea567cad2ae466a8a8d45bcec87b5b1d /src/core/client_config/lb_policies/pick_first.c
parent9f7dc3a4e5c3eeb6524472c6dc694f0600d03688 (diff)
Change runs to enqueue
Diffstat (limited to 'src/core/client_config/lb_policies/pick_first.c')
-rw-r--r--src/core/client_config/lb_policies/pick_first.c8
1 files changed, 4 insertions, 4 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");