diff options
author | Yang Gao <yangg@google.com> | 2015-02-18 16:01:13 -0800 |
---|---|---|
committer | Yang Gao <yangg@google.com> | 2015-02-18 16:01:13 -0800 |
commit | d9f3dfe7ebb251baab7494f5512c5fa68399ae7a (patch) | |
tree | 32007f224f72365bcda80ac7e6c92b30dbf40dd4 /test | |
parent | 646f60153a83a8fc7d733d36d7bf933811e1c8ea (diff) | |
parent | 2627e4e0a917cc438bff186d0bea2bee030ac98a (diff) |
Merge pull request #581 from ctiller/an-update-on-c++
Server side cancellation receive support for C++
Diffstat (limited to 'test')
-rw-r--r-- | test/cpp/end2end/async_end2end_test.cc | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/test/cpp/end2end/async_end2end_test.cc b/test/cpp/end2end/async_end2end_test.cc index fe31289661..79160bfaa5 100644 --- a/test/cpp/end2end/async_end2end_test.cc +++ b/test/cpp/end2end/async_end2end_test.cc @@ -91,7 +91,17 @@ class AsyncEnd2endTest : public ::testing::Test { server_ = builder.BuildAndStart(); } - void TearDown() override { server_->Shutdown(); } + void TearDown() override { + server_->Shutdown(); + void* ignored_tag; + bool ignored_ok; + cli_cq_.Shutdown(); + srv_cq_.Shutdown(); + while (cli_cq_.Next(&ignored_tag, &ignored_ok)) + ; + while (srv_cq_.Next(&ignored_tag, &ignored_ok)) + ; + } void ResetStub() { std::shared_ptr<ChannelInterface> channel = |