aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/fixtures/h2_sockpair_1byte.c
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 /test/core/end2end/fixtures/h2_sockpair_1byte.c
parent298751c1195523ef6228595043b583c3a6270e08 (diff)
indent pass to get logical source lines on one physical line
Diffstat (limited to 'test/core/end2end/fixtures/h2_sockpair_1byte.c')
-rw-r--r--test/core/end2end/fixtures/h2_sockpair_1byte.c124
1 files changed, 65 insertions, 59 deletions
diff --git a/test/core/end2end/fixtures/h2_sockpair_1byte.c b/test/core/end2end/fixtures/h2_sockpair_1byte.c
index 8a9196d3b6..0e11a944af 100644
--- a/test/core/end2end/fixtures/h2_sockpair_1byte.c
+++ b/test/core/end2end/fixtures/h2_sockpair_1byte.c
@@ -56,112 +56,118 @@
/* chttp2 transport that is immediately available (used for testing
connected_channel without a client_channel */
-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)
+{
grpc_end2end_test_fixture *f = 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(
- f->server, transport, extra_filters, GPR_ARRAY_SIZE(extra_filters), mdctx,
- grpc_server_get_channel_args(f->server), &closure_list);
- grpc_closure_list_run(&closure_list);
+ grpc_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (f->server), &closure_list);
+ grpc_closure_list_run (&closure_list);
}
-typedef struct {
+typedef struct
+{
grpc_end2end_test_fixture *f;
grpc_channel_args *client_args;
} sp_client_setup;
-static void client_setup_transport(void *ts, grpc_transport *transport,
- grpc_mdctx *mdctx,
- grpc_closure_list *closure_list) {
+static void
+client_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx, grpc_closure_list * closure_list)
+{
sp_client_setup *cs = ts;
- const grpc_channel_filter *filters[] = {&grpc_http_client_filter,
- &grpc_compress_filter,
- &grpc_connected_channel_filter};
- size_t nfilters = sizeof(filters) / sizeof(*filters);
- grpc_channel *channel =
- grpc_channel_create_from_filters("socketpair-target", filters, nfilters,
- cs->client_args, mdctx, 1, closure_list);
+ const grpc_channel_filter *filters[] = { &grpc_http_client_filter,
+ &grpc_compress_filter,
+ &grpc_connected_channel_filter
+ };
+ size_t nfilters = sizeof (filters) / sizeof (*filters);
+ grpc_channel *channel = grpc_channel_create_from_filters ("socketpair-target", filters, nfilters,
+ cs->client_args, mdctx, 1, closure_list);
cs->f->client = channel;
- grpc_connected_channel_bind_transport(grpc_channel_get_channel_stack(channel),
- transport);
+ grpc_connected_channel_bind_transport (grpc_channel_get_channel_stack (channel), transport);
}
-static grpc_end2end_test_fixture chttp2_create_fixture_socketpair(
- grpc_channel_args *client_args, grpc_channel_args *server_args) {
- grpc_endpoint_pair *sfd = gpr_malloc(sizeof(grpc_endpoint_pair));
+static grpc_end2end_test_fixture
+chttp2_create_fixture_socketpair (grpc_channel_args * client_args, grpc_channel_args * server_args)
+{
+ grpc_endpoint_pair *sfd = gpr_malloc (sizeof (grpc_endpoint_pair));
grpc_end2end_test_fixture f;
- memset(&f, 0, sizeof(f));
+ memset (&f, 0, sizeof (f));
f.fixture_data = sfd;
- f.cq = grpc_completion_queue_create(NULL);
+ f.cq = grpc_completion_queue_create (NULL);
- *sfd = grpc_iomgr_create_endpoint_pair("fixture", 1);
+ *sfd = grpc_iomgr_create_endpoint_pair ("fixture", 1);
return f;
}
-static void chttp2_init_client_socketpair(grpc_end2end_test_fixture *f,
- grpc_channel_args *client_args) {
+static void
+chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args * client_args)
+{
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_endpoint_pair *sfd = f->fixture_data;
grpc_transport *transport;
- grpc_mdctx *mdctx = grpc_mdctx_create();
+ grpc_mdctx *mdctx = grpc_mdctx_create ();
sp_client_setup cs;
cs.client_args = client_args;
cs.f = f;
- transport = grpc_create_chttp2_transport(client_args, sfd->client, mdctx, 1,
- &closure_list);
- client_setup_transport(&cs, transport, mdctx, &closure_list);
- GPR_ASSERT(f->client);
- grpc_chttp2_transport_start_reading(transport, NULL, 0, &closure_list);
- grpc_closure_list_run(&closure_list);
+ transport = grpc_create_chttp2_transport (client_args, sfd->client, mdctx, 1, &closure_list);
+ client_setup_transport (&cs, transport, mdctx, &closure_list);
+ GPR_ASSERT (f->client);
+ grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_closure_list_run (&closure_list);
}
-static void chttp2_init_server_socketpair(grpc_end2end_test_fixture *f,
- grpc_channel_args *server_args) {
+static void
+chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args * server_args)
+{
grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
grpc_endpoint_pair *sfd = f->fixture_data;
- grpc_mdctx *mdctx = grpc_mdctx_create();
+ grpc_mdctx *mdctx = grpc_mdctx_create ();
grpc_transport *transport;
- GPR_ASSERT(!f->server);
- f->server = grpc_server_create_from_filters(NULL, 0, server_args);
- grpc_server_register_completion_queue(f->server, f->cq, NULL);
- grpc_server_start(f->server);
- transport = grpc_create_chttp2_transport(server_args, sfd->server, mdctx, 0,
- &closure_list);
- server_setup_transport(f, transport, mdctx);
- grpc_chttp2_transport_start_reading(transport, NULL, 0, &closure_list);
- grpc_closure_list_run(&closure_list);
+ GPR_ASSERT (!f->server);
+ f->server = grpc_server_create_from_filters (NULL, 0, server_args);
+ grpc_server_register_completion_queue (f->server, f->cq, NULL);
+ grpc_server_start (f->server);
+ transport = grpc_create_chttp2_transport (server_args, sfd->server, mdctx, 0, &closure_list);
+ server_setup_transport (f, transport, mdctx);
+ grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_closure_list_run (&closure_list);
}
-static void chttp2_tear_down_socketpair(grpc_end2end_test_fixture *f) {
- gpr_free(f->fixture_data);
+static void
+chttp2_tear_down_socketpair (grpc_end2end_test_fixture * f)
+{
+ gpr_free (f->fixture_data);
}
/* All test configurations */
static grpc_end2end_test_config configs[] = {
- {"chttp2/socketpair_one_byte_at_a_time", 0,
- chttp2_create_fixture_socketpair, chttp2_init_client_socketpair,
- chttp2_init_server_socketpair, chttp2_tear_down_socketpair},
+ {"chttp2/socketpair_one_byte_at_a_time", 0,
+ chttp2_create_fixture_socketpair, chttp2_init_client_socketpair,
+ chttp2_init_server_socketpair, chttp2_tear_down_socketpair},
};
-int main(int argc, char **argv) {
+int
+main (int argc, char **argv)
+{
size_t i;
- grpc_test_init(argc, argv);
- grpc_init();
+ grpc_test_init (argc, argv);
+ grpc_init ();
- for (i = 0; i < sizeof(configs) / sizeof(*configs); i++) {
- grpc_end2end_tests(configs[i]);
- }
+ for (i = 0; i < sizeof (configs) / sizeof (*configs); i++)
+ {
+ grpc_end2end_tests (configs[i]);
+ }
- grpc_shutdown();
+ grpc_shutdown ();
return 0;
}