diff options
Diffstat (limited to 'test/core/end2end/multiple_server_queues_test.c')
| -rw-r--r-- | test/core/end2end/multiple_server_queues_test.c | 43 |
1 files changed, 21 insertions, 22 deletions
diff --git a/test/core/end2end/multiple_server_queues_test.c b/test/core/end2end/multiple_server_queues_test.c index 4d68a2d40d..5e2eaf4ae9 100644 --- a/test/core/end2end/multiple_server_queues_test.c +++ b/test/core/end2end/multiple_server_queues_test.c @@ -34,31 +34,30 @@ #include <grpc/grpc.h> #include "test/core/util/test_config.h" -int -main (int argc, char **argv) -{ +int main(int argc, char **argv) { grpc_completion_queue *cq1; grpc_completion_queue *cq2; grpc_server *server; - grpc_test_init (argc, argv); - grpc_init (); - cq1 = grpc_completion_queue_create (NULL); - cq2 = grpc_completion_queue_create (NULL); - server = grpc_server_create (NULL, NULL); - grpc_server_register_completion_queue (server, cq1, NULL); - grpc_server_add_insecure_http2_port (server, "[::]:0"); - grpc_server_register_completion_queue (server, cq2, NULL); - grpc_server_start (server); - grpc_server_shutdown_and_notify (server, cq2, NULL); - grpc_completion_queue_next (cq2, gpr_inf_future (GPR_CLOCK_REALTIME), NULL); /* cue queue hang */ - grpc_completion_queue_shutdown (cq1); - grpc_completion_queue_shutdown (cq2); - grpc_completion_queue_next (cq1, gpr_inf_future (GPR_CLOCK_REALTIME), NULL); - grpc_completion_queue_next (cq2, gpr_inf_future (GPR_CLOCK_REALTIME), NULL); - grpc_server_destroy (server); - grpc_completion_queue_destroy (cq1); - grpc_completion_queue_destroy (cq2); - grpc_shutdown (); + grpc_test_init(argc, argv); + grpc_init(); + cq1 = grpc_completion_queue_create(NULL); + cq2 = grpc_completion_queue_create(NULL); + server = grpc_server_create(NULL, NULL); + grpc_server_register_completion_queue(server, cq1, NULL); + grpc_server_add_insecure_http2_port(server, "[::]:0"); + grpc_server_register_completion_queue(server, cq2, NULL); + grpc_server_start(server); + grpc_server_shutdown_and_notify(server, cq2, NULL); + grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), + NULL); /* cue queue hang */ + grpc_completion_queue_shutdown(cq1); + grpc_completion_queue_shutdown(cq2); + grpc_completion_queue_next(cq1, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); + grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); + grpc_server_destroy(server); + grpc_completion_queue_destroy(cq1); + grpc_completion_queue_destroy(cq2); + grpc_shutdown(); return 0; } |