aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/bad_client/bad_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/core/bad_client/bad_client.c')
-rw-r--r--test/core/bad_client/bad_client.c12
1 files changed, 3 insertions, 9 deletions
diff --git a/test/core/bad_client/bad_client.c b/test/core/bad_client/bad_client.c
index fd37fce976..747ce4050b 100644
--- a/test/core/bad_client/bad_client.c
+++ b/test/core/bad_client/bad_client.c
@@ -65,15 +65,14 @@ static void done_write(void *arg, int success, grpc_call_list *call_list) {
}
static void server_setup_transport(void *ts, grpc_transport *transport,
- grpc_mdctx *mdctx,
- grpc_workqueue *workqueue) {
+ grpc_mdctx *mdctx) {
thd_args *a = ts;
static grpc_channel_filter const *extra_filters[] = {
&grpc_http_server_filter};
grpc_call_list call_list = GRPC_CALL_LIST_INIT;
grpc_server_setup_transport(
a->server, transport, extra_filters, GPR_ARRAY_SIZE(extra_filters), mdctx,
- workqueue, grpc_server_get_channel_args(a->server), &call_list);
+ grpc_server_get_channel_args(a->server), &call_list);
grpc_call_list_run(&call_list);
}
@@ -90,7 +89,6 @@ void grpc_run_bad_client_test(grpc_bad_client_server_side_validator validator,
gpr_slice_from_copied_buffer(client_payload, client_payload_length);
gpr_slice_buffer outgoing;
grpc_closure done_write_closure;
- grpc_workqueue *workqueue;
grpc_call_list call_list = GRPC_CALL_LIST_INIT;
hex = gpr_dump(client_payload, client_payload_length,
@@ -104,9 +102,6 @@ void grpc_run_bad_client_test(grpc_bad_client_server_side_validator validator,
/* Init grpc */
grpc_init();
- workqueue = grpc_workqueue_create(&call_list);
- grpc_call_list_run(&call_list);
-
/* Create endpoints */
sfd = grpc_iomgr_create_endpoint_pair("fixture", 65536);
@@ -120,7 +115,7 @@ void grpc_run_bad_client_test(grpc_bad_client_server_side_validator validator,
grpc_server_start(a.server);
transport =
grpc_create_chttp2_transport(NULL, sfd.server, mdctx, 0, &call_list);
- server_setup_transport(&a, transport, mdctx, workqueue);
+ server_setup_transport(&a, transport, mdctx);
grpc_chttp2_transport_start_reading(transport, NULL, 0, &call_list);
grpc_call_list_run(&call_list);
@@ -169,7 +164,6 @@ void grpc_run_bad_client_test(grpc_bad_client_server_side_validator validator,
grpc_completion_queue_destroy(a.cq);
gpr_slice_buffer_destroy(&outgoing);
- GRPC_WORKQUEUE_UNREF(workqueue, "destroy", &call_list);
grpc_call_list_run(&call_list);
grpc_shutdown();
}