aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/client_config/lb_policy.h
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:42:19 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:42:19 -0700
commit45724b35e411fef7c5da66a74c78428c11d56843 (patch)
tree9264034aca675c89444e02f72ef58e67d7043604 /src/core/client_config/lb_policy.h
parent298751c1195523ef6228595043b583c3a6270e08 (diff)
indent pass to get logical source lines on one physical line
Diffstat (limited to 'src/core/client_config/lb_policy.h')
-rw-r--r--src/core/client_config/lb_policy.h67
1 files changed, 23 insertions, 44 deletions
diff --git a/src/core/client_config/lb_policy.h b/src/core/client_config/lb_policy.h
index 5e3c016eb2..d530e5b7e1 100644
--- a/src/core/client_config/lb_policy.h
+++ b/src/core/client_config/lb_policy.h
@@ -42,41 +42,35 @@
typedef struct grpc_lb_policy grpc_lb_policy;
typedef struct grpc_lb_policy_vtable grpc_lb_policy_vtable;
-typedef void (*grpc_lb_completion)(void *cb_arg, grpc_subchannel *subchannel,
- grpc_status_code status, const char *errmsg);
+typedef void (*grpc_lb_completion) (void *cb_arg, grpc_subchannel * subchannel, grpc_status_code status, const char *errmsg);
-struct grpc_lb_policy {
+struct grpc_lb_policy
+{
const grpc_lb_policy_vtable *vtable;
gpr_refcount refs;
};
-struct grpc_lb_policy_vtable {
- void (*destroy)(grpc_lb_policy *policy, grpc_closure_list *closure_list);
+struct grpc_lb_policy_vtable
+{
+ void (*destroy) (grpc_lb_policy * policy, grpc_closure_list * closure_list);
- void (*shutdown)(grpc_lb_policy *policy, grpc_closure_list *closure_list);
+ void (*shutdown) (grpc_lb_policy * policy, grpc_closure_list * closure_list);
/** implement grpc_lb_policy_pick */
- void (*pick)(grpc_lb_policy *policy, grpc_pollset *pollset,
- grpc_metadata_batch *initial_metadata, grpc_subchannel **target,
- grpc_closure *on_complete, grpc_closure_list *closure_list);
+ void (*pick) (grpc_lb_policy * policy, grpc_pollset * pollset, grpc_metadata_batch * initial_metadata, grpc_subchannel ** target, grpc_closure * on_complete, grpc_closure_list * closure_list);
/** try to enter a READY connectivity state */
- void (*exit_idle)(grpc_lb_policy *policy, grpc_closure_list *closure_list);
+ void (*exit_idle) (grpc_lb_policy * policy, grpc_closure_list * closure_list);
/** broadcast a transport op to all subchannels */
- void (*broadcast)(grpc_lb_policy *policy, grpc_transport_op *op,
- grpc_closure_list *closure_list);
+ void (*broadcast) (grpc_lb_policy * policy, grpc_transport_op * op, grpc_closure_list * closure_list);
/** check the current connectivity of the lb_policy */
- grpc_connectivity_state (*check_connectivity)(
- grpc_lb_policy *policy, grpc_closure_list *closure_list);
+ grpc_connectivity_state (*check_connectivity) (grpc_lb_policy * policy, grpc_closure_list * closure_list);
/** call notify when the connectivity state of a channel changes from *state.
Updates *state with the new state of the policy */
- void (*notify_on_state_change)(grpc_lb_policy *policy,
- grpc_connectivity_state *state,
- grpc_closure *closure,
- grpc_closure_list *closure_list);
+ void (*notify_on_state_change) (grpc_lb_policy * policy, grpc_connectivity_state * state, grpc_closure * closure, grpc_closure_list * closure_list);
};
#ifdef GRPC_LB_POLICY_REFCOUNT_DEBUG
@@ -84,48 +78,33 @@ struct grpc_lb_policy_vtable {
grpc_lb_policy_ref((p), __FILE__, __LINE__, (r))
#define GRPC_LB_POLICY_UNREF(p, r, cl) \
grpc_lb_policy_unref((p), (cl), __FILE__, __LINE__, (r))
-void grpc_lb_policy_ref(grpc_lb_policy *policy, const char *file, int line,
- const char *reason);
-void grpc_lb_policy_unref(grpc_lb_policy *policy,
- grpc_closure_list *closure_list, const char *file,
- int line, const char *reason);
+void grpc_lb_policy_ref (grpc_lb_policy * policy, const char *file, int line, const char *reason);
+void grpc_lb_policy_unref (grpc_lb_policy * policy, grpc_closure_list * closure_list, const char *file, int line, const char *reason);
#else
#define GRPC_LB_POLICY_REF(p, r) grpc_lb_policy_ref((p))
#define GRPC_LB_POLICY_UNREF(p, r, cl) grpc_lb_policy_unref((p), (cl))
-void grpc_lb_policy_ref(grpc_lb_policy *policy);
-void grpc_lb_policy_unref(grpc_lb_policy *policy,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_ref (grpc_lb_policy * policy);
+void grpc_lb_policy_unref (grpc_lb_policy * policy, grpc_closure_list * closure_list);
#endif
/** called by concrete implementations to initialize the base struct */
-void grpc_lb_policy_init(grpc_lb_policy *policy,
- const grpc_lb_policy_vtable *vtable);
+void grpc_lb_policy_init (grpc_lb_policy * policy, const grpc_lb_policy_vtable * vtable);
/** Start shutting down (fail any pending picks) */
-void grpc_lb_policy_shutdown(grpc_lb_policy *policy,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_shutdown (grpc_lb_policy * policy, grpc_closure_list * closure_list);
/** Given initial metadata in \a initial_metadata, find an appropriate
target for this rpc, and 'return' it by calling \a on_complete after setting
\a target.
Picking can be asynchronous. Any IO should be done under \a pollset. */
-void grpc_lb_policy_pick(grpc_lb_policy *policy, grpc_pollset *pollset,
- grpc_metadata_batch *initial_metadata,
- grpc_subchannel **target, grpc_closure *on_complete,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_pick (grpc_lb_policy * policy, grpc_pollset * pollset, grpc_metadata_batch * initial_metadata, grpc_subchannel ** target, grpc_closure * on_complete, grpc_closure_list * closure_list);
-void grpc_lb_policy_broadcast(grpc_lb_policy *policy, grpc_transport_op *op,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_broadcast (grpc_lb_policy * policy, grpc_transport_op * op, grpc_closure_list * closure_list);
-void grpc_lb_policy_exit_idle(grpc_lb_policy *policy,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_exit_idle (grpc_lb_policy * policy, grpc_closure_list * closure_list);
-void grpc_lb_policy_notify_on_state_change(grpc_lb_policy *policy,
- grpc_connectivity_state *state,
- grpc_closure *closure,
- grpc_closure_list *closure_list);
+void grpc_lb_policy_notify_on_state_change (grpc_lb_policy * policy, grpc_connectivity_state * state, grpc_closure * closure, grpc_closure_list * closure_list);
-grpc_connectivity_state grpc_lb_policy_check_connectivity(
- grpc_lb_policy *policy, grpc_closure_list *closure_list);
+grpc_connectivity_state grpc_lb_policy_check_connectivity (grpc_lb_policy * policy, grpc_closure_list * closure_list);
#endif /* GRPC_INTERNAL_CORE_CONFIG_LB_POLICY_H */