aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/surface/server.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-07-09 13:48:11 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-07-09 13:48:11 -0700
commit12cf537a72468edd3860127c0eb37abd78120e34 (patch)
tree1fb0a94d534de5526c68308cc951f0ef46ba5b8c /src/core/surface/server.c
parentc012258eb8bb0ef76ada117cbebcd458fc884f32 (diff)
clang-format affected files
Diffstat (limited to 'src/core/surface/server.c')
-rw-r--r--src/core/surface/server.c22
1 files changed, 10 insertions, 12 deletions
diff --git a/src/core/surface/server.c b/src/core/surface/server.c
index ff02428c49..32e5058b4d 100644
--- a/src/core/surface/server.c
+++ b/src/core/surface/server.c
@@ -267,7 +267,8 @@ static void send_shutdown(grpc_channel *channel, int send_goaway,
}
static void channel_broadcaster_shutdown(channel_broadcaster *cb,
- int send_goaway, int force_disconnect) {
+ int send_goaway,
+ int force_disconnect) {
size_t i;
for (i = 0; i < cb->num_channels; i++) {
@@ -484,13 +485,9 @@ static void maybe_finish_shutdown(grpc_server *server) {
server->shutdown_published = 1;
for (i = 0; i < server->num_shutdown_tags; i++) {
server_ref(server);
- grpc_cq_end_op(server->shutdown_tags[i].cq,
- server->shutdown_tags[i].tag,
- 1,
- done_shutdown_event,
- server,
- &server->shutdown_tags[i].completion
- );
+ grpc_cq_end_op(server->shutdown_tags[i].cq, server->shutdown_tags[i].tag, 1,
+ done_shutdown_event, server,
+ &server->shutdown_tags[i].completion);
}
}
@@ -1167,8 +1164,7 @@ static void begin_call(grpc_server *server, call_data *calld,
}
GRPC_CALL_INTERNAL_REF(calld->call, "server");
- grpc_call_start_ioreq_and_call_back(calld->call, req, r - req, publish,
- rc);
+ grpc_call_start_ioreq_and_call_back(calld->call, req, r - req, publish, rc);
}
static void done_request_event(void *req, grpc_cq_completion *c) {
@@ -1185,7 +1181,8 @@ static void fail_call(grpc_server *server, requested_call *rc) {
rc->data.registered.initial_metadata->count = 0;
break;
}
- grpc_cq_end_op(rc->cq_for_notification, rc->tag, 0, done_request_event, rc, &rc->completion);
+ grpc_cq_end_op(rc->cq_for_notification, rc->tag, 0, done_request_event, rc,
+ &rc->completion);
}
static void publish_registered_or_batch(grpc_call *call, int success,
@@ -1194,7 +1191,8 @@ static void publish_registered_or_batch(grpc_call *call, int success,
grpc_call_stack_element(grpc_call_get_call_stack(call), 0);
requested_call *rc = prc;
call_data *calld = elem->call_data;
- grpc_cq_end_op(calld->cq_new, rc->tag, success, done_request_event, rc, &rc->completion);
+ grpc_cq_end_op(calld->cq_new, rc->tag, success, done_request_event, rc,
+ &rc->completion);
GRPC_CALL_INTERNAL_UNREF(call, "server", 0);
}