aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/tests
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-05-28 12:44:27 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-05-28 12:44:27 -0700
commit44883302c32773bc3959ddf06c46727acb7cc328 (patch)
tree36ab395d6f92934e1a71b47c7eb5d9440e1dfe15 /test/core/end2end/tests
parent0f29c4d375203019da5417ee8577f8cbb996e133 (diff)
Remove condition variable from pollset
Diffstat (limited to 'test/core/end2end/tests')
-rw-r--r--test/core/end2end/tests/cancel_in_a_vacuum.c5
1 files changed, 4 insertions, 1 deletions
diff --git a/test/core/end2end/tests/cancel_in_a_vacuum.c b/test/core/end2end/tests/cancel_in_a_vacuum.c
index 1b235b78e9..c380b79b94 100644
--- a/test/core/end2end/tests/cancel_in_a_vacuum.c
+++ b/test/core/end2end/tests/cancel_in_a_vacuum.c
@@ -46,6 +46,8 @@
enum { TIMEOUT = 200000 };
+static void *tag(gpr_intptr t) { return (void *)t; }
+
static grpc_end2end_test_fixture begin_test(grpc_end2end_test_config config,
const char *test_name,
grpc_channel_args *client_args,
@@ -73,7 +75,8 @@ static void drain_cq(grpc_completion_queue *cq) {
static void shutdown_server(grpc_end2end_test_fixture *f) {
if (!f->server) return;
- grpc_server_shutdown(f->server);
+ grpc_server_shutdown_and_notify(f->server, tag(1000));
+ GPR_ASSERT(grpc_completion_queue_pluck(f->cq, tag(1000), GRPC_TIMEOUT_SECONDS_TO_DEADLINE(5)).type == GRPC_OP_COMPLETE);
grpc_server_destroy(f->server);
f->server = NULL;
}