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:45:28 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:45:28 -0700
commit1be70ccdb84ec41975cc018f6b2a2a89cf5072ee (patch)
treed4e6890ca32762bf786e2b801d3c26b27ec707ee /src/core/client_config/lb_policies/pick_first.c
parent45724b35e411fef7c5da66a74c78428c11d56843 (diff)
Move arguments to the start of lists
Diffstat (limited to 'src/core/client_config/lb_policies/pick_first.c')
-rw-r--r--src/core/client_config/lb_policies/pick_first.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/core/client_config/lb_policies/pick_first.c b/src/core/client_config/lb_policies/pick_first.c
index b8991dfaa7..02aaac1dc3 100644
--- a/src/core/client_config/lb_policies/pick_first.c
+++ b/src/core/client_config/lb_policies/pick_first.c
@@ -79,7 +79,7 @@ typedef struct
} pick_first_lb_policy;
static void
-del_interested_parties_locked (pick_first_lb_policy * p, grpc_closure_list * closure_list)
+del_interested_parties_locked (grpc_exec_ctx * exec_ctx, pick_first_lb_policy * p)
{
pending_pick *pp;
for (pp = p->pending_picks; pp; pp = pp->next)
@@ -89,7 +89,7 @@ del_interested_parties_locked (pick_first_lb_policy * p, grpc_closure_list * clo
}
static void
-add_interested_parties_locked (pick_first_lb_policy * p, grpc_closure_list * closure_list)
+add_interested_parties_locked (grpc_exec_ctx * exec_ctx, pick_first_lb_policy * p)
{
pending_pick *pp;
for (pp = p->pending_picks; pp; pp = pp->next)
@@ -99,7 +99,7 @@ add_interested_parties_locked (pick_first_lb_policy * p, grpc_closure_list * clo
}
void
-pf_destroy (grpc_lb_policy * pol, grpc_closure_list * closure_list)
+pf_destroy (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
size_t i;
@@ -115,7 +115,7 @@ pf_destroy (grpc_lb_policy * pol, grpc_closure_list * closure_list)
}
void
-pf_shutdown (grpc_lb_policy * pol, grpc_closure_list * closure_list)
+pf_shutdown (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
pending_pick *pp;
@@ -137,7 +137,7 @@ pf_shutdown (grpc_lb_policy * pol, grpc_closure_list * closure_list)
}
static void
-start_picking (pick_first_lb_policy * p, grpc_closure_list * closure_list)
+start_picking (grpc_exec_ctx * exec_ctx, pick_first_lb_policy * p)
{
p->started_picking = 1;
p->checking_subchannel = 0;
@@ -147,7 +147,7 @@ start_picking (pick_first_lb_policy * p, grpc_closure_list * closure_list)
}
void
-pf_exit_idle (grpc_lb_policy * pol, grpc_closure_list * closure_list)
+pf_exit_idle (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
gpr_mu_lock (&p->mu);
@@ -159,7 +159,7 @@ pf_exit_idle (grpc_lb_policy * pol, grpc_closure_list * closure_list)
}
void
-pf_pick (grpc_lb_policy * pol, grpc_pollset * pollset, grpc_metadata_batch * initial_metadata, grpc_subchannel ** target, grpc_closure * on_complete, grpc_closure_list * closure_list)
+pf_pick (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol, grpc_pollset * pollset, grpc_metadata_batch * initial_metadata, grpc_subchannel ** target, grpc_closure * on_complete)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
pending_pick *pp;
@@ -188,7 +188,7 @@ pf_pick (grpc_lb_policy * pol, grpc_pollset * pollset, grpc_metadata_batch * ini
}
static void
-pf_connectivity_changed (void *arg, int iomgr_success, grpc_closure_list * closure_list)
+pf_connectivity_changed (grpc_exec_ctx * exec_ctx, void *arg, int iomgr_success)
{
pick_first_lb_policy *p = arg;
pending_pick *pp;
@@ -283,7 +283,7 @@ pf_connectivity_changed (void *arg, int iomgr_success, grpc_closure_list * closu
}
static void
-pf_broadcast (grpc_lb_policy * pol, grpc_transport_op * op, grpc_closure_list * closure_list)
+pf_broadcast (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol, grpc_transport_op * op)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
size_t i;
@@ -309,7 +309,7 @@ pf_broadcast (grpc_lb_policy * pol, grpc_transport_op * op, grpc_closure_list *
}
static grpc_connectivity_state
-pf_check_connectivity (grpc_lb_policy * pol, grpc_closure_list * closure_list)
+pf_check_connectivity (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
grpc_connectivity_state st;
@@ -320,7 +320,7 @@ pf_check_connectivity (grpc_lb_policy * pol, grpc_closure_list * closure_list)
}
void
-pf_notify_on_state_change (grpc_lb_policy * pol, grpc_connectivity_state * current, grpc_closure * notify, grpc_closure_list * closure_list)
+pf_notify_on_state_change (grpc_exec_ctx * exec_ctx, grpc_lb_policy * pol, grpc_connectivity_state * current, grpc_closure * notify)
{
pick_first_lb_policy *p = (pick_first_lb_policy *) pol;
gpr_mu_lock (&p->mu);