diff options
author | 2017-06-19 16:53:43 -0700 | |
---|---|---|
committer | 2017-06-20 17:16:01 -0700 | |
commit | 1def5a181d30dbeefb1e7c35fe5d50207188eafe (patch) | |
tree | ec9d772968f6af8e1c3c5f77fd9c152132f9f6f1 /test | |
parent | 4fb156acda099679d3f8f9e9faf64cd57290adef (diff) |
Fix max_message_length
Diffstat (limited to 'test')
-rw-r--r-- | test/core/end2end/tests/max_message_length.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/test/core/end2end/tests/max_message_length.c b/test/core/end2end/tests/max_message_length.c index f65edab865..a4262df120 100644 --- a/test/core/end2end/tests/max_message_length.c +++ b/test/core/end2end/tests/max_message_length.c @@ -83,11 +83,11 @@ static void drain_cq(grpc_completion_queue *cq) { static void shutdown_server(grpc_end2end_test_fixture *f) { if (!f->server) return; - 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), - NULL) - .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), NULL); + GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); + GPR_ASSERT(ev.tag == tag(1000)); grpc_server_destroy(f->server); f->server = NULL; } |