aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/h2_ssl_cert_test.cc
diff options
context:
space:
mode:
authorGravatar Yash Tibrewal <yashkt@google.com>2018-03-20 19:43:17 -0700
committerGravatar Yash Tibrewal <yashkt@google.com>2018-03-20 19:43:17 -0700
commit717fff3faf0aa884e1fdec754db1f426a84b77a5 (patch)
treee49bcdf32b4c7dc30b4539a5035bc98f5bb4eeb0 /test/core/end2end/h2_ssl_cert_test.cc
parenteb8af5c733ad4bf18620f0828be95d4ce0ba738f (diff)
Use same queue for batch ops and for shutdown in h2_ssl_cert_test
Diffstat (limited to 'test/core/end2end/h2_ssl_cert_test.cc')
-rw-r--r--test/core/end2end/h2_ssl_cert_test.cc16
1 files changed, 5 insertions, 11 deletions
diff --git a/test/core/end2end/h2_ssl_cert_test.cc b/test/core/end2end/h2_ssl_cert_test.cc
index 9e2082ce9d..e7c5bba5ec 100644
--- a/test/core/end2end/h2_ssl_cert_test.cc
+++ b/test/core/end2end/h2_ssl_cert_test.cc
@@ -57,8 +57,6 @@ static grpc_end2end_test_fixture chttp2_create_fixture_secure_fullstack(
f.fixture_data = ffd;
f.cq = grpc_completion_queue_create_for_next(nullptr);
- f.shutdown_cq = grpc_completion_queue_create_for_pluck(nullptr);
-
return f;
}
@@ -283,14 +281,11 @@ static void shutdown_server(grpc_end2end_test_fixture* f) {
* thread for the server to poll the completion queue while the shutdown
* progresses.)
*/
- GPR_ASSERT(grpc_completion_queue_next(
- f->cq, grpc_timeout_milliseconds_to_deadline(100), nullptr)
- .type == GRPC_QUEUE_TIMEOUT);
- grpc_server_shutdown_and_notify(f->server, f->shutdown_cq, tag(1000));
- GPR_ASSERT(grpc_completion_queue_pluck(f->shutdown_cq, tag(1000),
- grpc_timeout_seconds_to_deadline(5),
- nullptr)
- .type == GRPC_OP_COMPLETE);
+ grpc_server_shutdown_and_notify(f->server, f->cq, tag(1000));
+ grpc_event ev = grpc_completion_queue_next(
+ f->cq, grpc_timeout_seconds_to_deadline(5), nullptr);
+ ASSERT_EQ(ev.type, GRPC_OP_COMPLETE);
+ ASSERT_EQ(ev.tag, tag(1000));
grpc_server_destroy(f->server);
f->server = nullptr;
}
@@ -308,7 +303,6 @@ static void end_test(grpc_end2end_test_fixture* f) {
grpc_completion_queue_shutdown(f->cq);
drain_cq(f->cq);
grpc_completion_queue_destroy(f->cq);
- grpc_completion_queue_destroy(f->shutdown_cq);
}
static void simple_request_body(grpc_end2end_test_fixture f,