aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/fixtures
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:55:42 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:55:42 -0700
commite7db29f8c74da29d88c1f373ae52a27982eb2c87 (patch)
tree14b82655da1213051cbd3060ad2720ee2fd388f4 /test/core/end2end/fixtures
parentf5768a6765cae20477f36b346ce18bfb44fe2e25 (diff)
Move argument passing to start of list
Diffstat (limited to 'test/core/end2end/fixtures')
-rw-r--r--test/core/end2end/fixtures/h2_sockpair+trace.c12
-rw-r--r--test/core/end2end/fixtures/h2_sockpair.c12
-rw-r--r--test/core/end2end/fixtures/h2_sockpair_1byte.c12
3 files changed, 18 insertions, 18 deletions
diff --git a/test/core/end2end/fixtures/h2_sockpair+trace.c b/test/core/end2end/fixtures/h2_sockpair+trace.c
index be189a6540..59eb025957 100644
--- a/test/core/end2end/fixtures/h2_sockpair+trace.c
+++ b/test/core/end2end/fixtures/h2_sockpair+trace.c
@@ -65,7 +65,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
&grpc_http_server_filter
};
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_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_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (&exec_ctx, f->server));
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -118,10 +118,10 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, client_args, sfd->client, mdctx, 1);
+ client_setup_transport (&exec_ctx, &cs, transport, mdctx);
GPR_ASSERT (f->client);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -136,9 +136,9 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, server_args, sfd->server, mdctx, 0);
server_setup_transport (f, transport, mdctx);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}
diff --git a/test/core/end2end/fixtures/h2_sockpair.c b/test/core/end2end/fixtures/h2_sockpair.c
index d11cdef9c3..613772f27b 100644
--- a/test/core/end2end/fixtures/h2_sockpair.c
+++ b/test/core/end2end/fixtures/h2_sockpair.c
@@ -64,7 +64,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
&grpc_http_server_filter
};
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_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_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (&exec_ctx, f->server));
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -117,10 +117,10 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, client_args, sfd->client, mdctx, 1);
+ client_setup_transport (&exec_ctx, &cs, transport, mdctx);
GPR_ASSERT (f->client);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -135,9 +135,9 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, server_args, sfd->server, mdctx, 0);
server_setup_transport (f, transport, mdctx);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}
diff --git a/test/core/end2end/fixtures/h2_sockpair_1byte.c b/test/core/end2end/fixtures/h2_sockpair_1byte.c
index c54fabc011..9ad36ed79c 100644
--- a/test/core/end2end/fixtures/h2_sockpair_1byte.c
+++ b/test/core/end2end/fixtures/h2_sockpair_1byte.c
@@ -64,7 +64,7 @@ server_setup_transport (void *ts, grpc_transport * transport, grpc_mdctx * mdctx
&grpc_http_server_filter
};
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_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_server_setup_transport (f->server, transport, extra_filters, GPR_ARRAY_SIZE (extra_filters), mdctx, grpc_server_get_channel_args (&exec_ctx, f->server));
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -117,10 +117,10 @@ chttp2_init_client_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, client_args, sfd->client, mdctx, 1);
+ client_setup_transport (&exec_ctx, &cs, transport, mdctx);
GPR_ASSERT (f->client);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}
@@ -135,9 +135,9 @@ chttp2_init_server_socketpair (grpc_end2end_test_fixture * f, grpc_channel_args
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);
+ transport = grpc_create_chttp2_transport (&exec_ctx, server_args, sfd->server, mdctx, 0);
server_setup_transport (f, transport, mdctx);
- grpc_chttp2_transport_start_reading (transport, NULL, 0, &closure_list);
+ grpc_chttp2_transport_start_reading (&exec_ctx, transport, NULL, 0);
grpc_exec_ctx_finish (&exec_ctx);
}