diff options
author | Craig Tiller <ctiller@google.com> | 2015-09-22 10:42:19 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-09-22 10:42:19 -0700 |
commit | 45724b35e411fef7c5da66a74c78428c11d56843 (patch) | |
tree | 9264034aca675c89444e02f72ef58e67d7043604 /test/core/bad_client/bad_client.c | |
parent | 298751c1195523ef6228595043b583c3a6270e08 (diff) |
indent pass to get logical source lines on one physical line
Diffstat (limited to 'test/core/bad_client/bad_client.c')
-rw-r--r-- | test/core/bad_client/bad_client.c | 143 |
1 files changed, 70 insertions, 73 deletions
diff --git a/test/core/bad_client/bad_client.c b/test/core/bad_client/bad_client.c index 7605904411..7661aec656 100644 --- a/test/core/bad_client/bad_client.c +++ b/test/core/bad_client/bad_client.c @@ -45,7 +45,8 @@ #include <grpc/support/sync.h> #include <grpc/support/thd.h> -typedef struct { +typedef struct +{ grpc_server *server; grpc_completion_queue *cq; grpc_bad_client_server_side_validator validator; @@ -53,121 +54,117 @@ typedef struct { gpr_event done_write; } thd_args; -static void thd_func(void *arg) { +static void +thd_func (void *arg) +{ thd_args *a = arg; - a->validator(a->server, a->cq); - gpr_event_set(&a->done_thd, (void *)1); + a->validator (a->server, a->cq); + gpr_event_set (&a->done_thd, (void *) 1); } -static void done_write(void *arg, int success, - grpc_closure_list *closure_list) { +static void +done_write (void *arg, int success, grpc_closure_list * closure_list) +{ thd_args *a = arg; - gpr_event_set(&a->done_write, (void *)1); + gpr_event_set (&a->done_write, (void *) 1); } -static void server_setup_transport(void *ts, grpc_transport *transport, - grpc_mdctx *mdctx) { +static void +server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx) +{ thd_args *a = ts; static grpc_channel_filter const *extra_filters[] = { - &grpc_http_server_filter}; + &grpc_http_server_filter + }; grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; - grpc_server_setup_transport( - a->server, transport, extra_filters, GPR_ARRAY_SIZE(extra_filters), mdctx, - grpc_server_get_channel_args(a->server), &closure_list); - grpc_closure_list_run(&closure_list); + grpc_server_setup_transport (a->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (a->server), &closure_list); + grpc_closure_list_run (&closure_list); } -void grpc_run_bad_client_test(grpc_bad_client_server_side_validator validator, - const char *client_payload, - size_t client_payload_length, gpr_uint32 flags) { +void +grpc_run_bad_client_test (grpc_bad_client_server_side_validator validator, const char *client_payload, size_t client_payload_length, gpr_uint32 flags) +{ grpc_endpoint_pair sfd; thd_args a; gpr_thd_id id; char *hex; grpc_transport *transport; - grpc_mdctx *mdctx = grpc_mdctx_create(); - gpr_slice slice = - gpr_slice_from_copied_buffer(client_payload, client_payload_length); + grpc_mdctx *mdctx = grpc_mdctx_create (); + gpr_slice slice = gpr_slice_from_copied_buffer (client_payload, client_payload_length); gpr_slice_buffer outgoing; grpc_closure done_write_closure; grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; - hex = gpr_dump(client_payload, client_payload_length, - GPR_DUMP_HEX | GPR_DUMP_ASCII); + hex = gpr_dump (client_payload, client_payload_length, GPR_DUMP_HEX | GPR_DUMP_ASCII); /* Add a debug log */ - gpr_log(GPR_INFO, "TEST: %s", hex); + gpr_log (GPR_INFO, "TEST: %s", hex); - gpr_free(hex); + gpr_free (hex); /* Init grpc */ - grpc_init(); + grpc_init (); /* Create endpoints */ - sfd = grpc_iomgr_create_endpoint_pair("fixture", 65536); + sfd = grpc_iomgr_create_endpoint_pair ("fixture", 65536); /* Create server, completion events */ - a.server = grpc_server_create_from_filters(NULL, 0, NULL); - a.cq = grpc_completion_queue_create(NULL); - gpr_event_init(&a.done_thd); - gpr_event_init(&a.done_write); + a.server = grpc_server_create_from_filters (NULL, 0, NULL); + a.cq = grpc_completion_queue_create (NULL); + gpr_event_init (&a.done_thd); + gpr_event_init (&a.done_write); a.validator = validator; - grpc_server_register_completion_queue(a.server, a.cq, NULL); - grpc_server_start(a.server); - transport = - grpc_create_chttp2_transport(NULL, sfd.server, mdctx, 0, &closure_list); - server_setup_transport(&a, transport, mdctx); - grpc_chttp2_transport_start_reading(transport, NULL, 0, &closure_list); - grpc_closure_list_run(&closure_list); + grpc_server_register_completion_queue (a.server, a.cq, NULL); + grpc_server_start (a.server); + transport = grpc_create_chttp2_transport (NULL, sfd.server, mdctx, 0, &closure_list); + server_setup_transport (&a, transport, mdctx); + grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list); + grpc_closure_list_run (&closure_list); /* Bind everything into the same pollset */ - grpc_endpoint_add_to_pollset(sfd.client, grpc_cq_pollset(a.cq), - &closure_list); - grpc_endpoint_add_to_pollset(sfd.server, grpc_cq_pollset(a.cq), - &closure_list); + grpc_endpoint_add_to_pollset (sfd.client, grpc_cq_pollset (a.cq), &closure_list); + grpc_endpoint_add_to_pollset (sfd.server, grpc_cq_pollset (a.cq), &closure_list); /* Check a ground truth */ - GPR_ASSERT(grpc_server_has_open_connections(a.server)); + GPR_ASSERT (grpc_server_has_open_connections (a.server)); /* Start validator */ - gpr_thd_new(&id, thd_func, &a, NULL); + gpr_thd_new (&id, thd_func, &a, NULL); - gpr_slice_buffer_init(&outgoing); - gpr_slice_buffer_add(&outgoing, slice); - grpc_closure_init(&done_write_closure, done_write, &a); + gpr_slice_buffer_init (&outgoing); + gpr_slice_buffer_add (&outgoing, slice); + grpc_closure_init (&done_write_closure, done_write, &a); /* Write data */ - grpc_endpoint_write(sfd.client, &outgoing, &done_write_closure, - &closure_list); - grpc_closure_list_run(&closure_list); + grpc_endpoint_write (sfd.client, &outgoing, &done_write_closure, &closure_list); + grpc_closure_list_run (&closure_list); /* Await completion */ - GPR_ASSERT( - gpr_event_wait(&a.done_write, GRPC_TIMEOUT_SECONDS_TO_DEADLINE(5))); + GPR_ASSERT (gpr_event_wait (&a.done_write, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5))); - if (flags & GRPC_BAD_CLIENT_DISCONNECT) { - grpc_endpoint_shutdown(sfd.client, &closure_list); - grpc_endpoint_destroy(sfd.client, &closure_list); - grpc_closure_list_run(&closure_list); - sfd.client = NULL; - } + if (flags & GRPC_BAD_CLIENT_DISCONNECT) + { + grpc_endpoint_shutdown (sfd.client, &closure_list); + grpc_endpoint_destroy (sfd.client, &closure_list); + grpc_closure_list_run (&closure_list); + sfd.client = NULL; + } - GPR_ASSERT(gpr_event_wait(&a.done_thd, GRPC_TIMEOUT_SECONDS_TO_DEADLINE(5))); + GPR_ASSERT (gpr_event_wait (&a.done_thd, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5))); /* Shutdown */ - if (sfd.client) { - grpc_endpoint_shutdown(sfd.client, &closure_list); - grpc_endpoint_destroy(sfd.client, &closure_list); - grpc_closure_list_run(&closure_list); - } - grpc_server_shutdown_and_notify(a.server, a.cq, NULL); - GPR_ASSERT(grpc_completion_queue_pluck( - a.cq, NULL, GRPC_TIMEOUT_SECONDS_TO_DEADLINE(1), NULL) - .type == GRPC_OP_COMPLETE); - grpc_server_destroy(a.server); - grpc_completion_queue_destroy(a.cq); - gpr_slice_buffer_destroy(&outgoing); - - grpc_closure_list_run(&closure_list); - grpc_shutdown(); + if (sfd.client) + { + grpc_endpoint_shutdown (sfd.client, &closure_list); + grpc_endpoint_destroy (sfd.client, &closure_list); + grpc_closure_list_run (&closure_list); + } + grpc_server_shutdown_and_notify (a.server, a.cq, NULL); + GPR_ASSERT (grpc_completion_queue_pluck (a.cq, NULL, GRPC_TIMEOUT_SECONDS_TO_DEADLINE (1), NULL).type == GRPC_OP_COMPLETE); + grpc_server_destroy (a.server); + grpc_completion_queue_destroy (a.cq); + gpr_slice_buffer_destroy (&outgoing); + + grpc_closure_list_run (&closure_list); + grpc_shutdown (); } |