diff options
| -rw-r--r-- | src/core/client_config/subchannel.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/core/client_config/subchannel.c b/src/core/client_config/subchannel.c index 7bd6717a3d..a0d21d99eb 100644 --- a/src/core/client_config/subchannel.c +++ b/src/core/client_config/subchannel.c @@ -241,10 +241,8 @@ static void start_connect(grpc_subchannel *c) { static void continue_creating_call(void *arg, int iomgr_success) { waiting_for_connect *w4c = arg; - grpc_subchannel_create_call(w4c->subchannel, - &w4c->initial_op, - w4c->target, - w4c->notify); + grpc_subchannel_create_call(w4c->subchannel, &w4c->initial_op, w4c->target, + w4c->notify); grpc_subchannel_unref(w4c->subchannel); gpr_free(w4c); } @@ -344,7 +342,8 @@ static void on_state_changed(void *p, int iomgr_success) { memset(&op, 0, sizeof(op)); op.connectivity_state = &sw->connectivity_state; op.on_connectivity_state_change = &sw->closure; - elem = grpc_channel_stack_element(CHANNEL_STACK_FROM_CONNECTION(c->active), 0); + elem = grpc_channel_stack_element( + CHANNEL_STACK_FROM_CONNECTION(c->active), 0); elem->filter->start_transport_op(elem, &op); /* early out */ gpr_mu_unlock(mu); @@ -433,7 +432,8 @@ static void publish_transport(grpc_subchannel *c) { memset(&op, 0, sizeof(op)); op.connectivity_state = &sw->connectivity_state; op.on_connectivity_state_change = &sw->closure; - elem = grpc_channel_stack_element(CHANNEL_STACK_FROM_CONNECTION(c->active), 0); + elem = + grpc_channel_stack_element(CHANNEL_STACK_FROM_CONNECTION(c->active), 0); elem->filter->start_transport_op(elem, &op); /* signal completion */ |