aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/hybrid_end2end_test.cc
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-05-21 12:43:17 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-05-21 12:43:17 -0700
commite76528ce267e06024224ad52d2874384df26d0a1 (patch)
tree1ab7c02951f3e34b3aa6db365b2916ee3db86c05 /test/cpp/end2end/hybrid_end2end_test.cc
parent4265fa1e66b72c2ccf2e3c5fecc4b2012b0637c3 (diff)
Revert "Remove spam"
Diffstat (limited to 'test/cpp/end2end/hybrid_end2end_test.cc')
-rw-r--r--test/cpp/end2end/hybrid_end2end_test.cc17
1 files changed, 13 insertions, 4 deletions
diff --git a/test/cpp/end2end/hybrid_end2end_test.cc b/test/cpp/end2end/hybrid_end2end_test.cc
index a19fccbb6b..b4270070e2 100644
--- a/test/cpp/end2end/hybrid_end2end_test.cc
+++ b/test/cpp/end2end/hybrid_end2end_test.cc
@@ -217,8 +217,7 @@ class HybridEnd2endTest : public ::testing::Test {
}
// Create a separate cq for each potential handler.
for (int i = 0; i < 5; i++) {
- cqs_.push_back(
- builder.AddCompletionQueue(i == num_cqs_frequently_polled - 1));
+ cqs_.push_back(builder.AddCompletionQueue(i == num_cqs_frequently_polled - 1));
}
server_ = builder.BuildAndStart();
}
@@ -511,12 +510,22 @@ TEST_F(HybridEnd2endTest, GenericEchoAsyncRequestStreamResponseStream) {
SetUpServer(&service, nullptr, &generic_service, 3);
ResetStub();
std::thread generic_handler_thread([this, &generic_service] {
+ gpr_log(GPR_DEBUG, "t0 start");
HandleGenericCall(&generic_service, cqs_[0].get());
+ gpr_log(GPR_DEBUG, "t0 done");
});
std::thread request_stream_handler_thread(
- [this, &service] { HandleClientStreaming(&service, cqs_[1].get()); });
+ [this, &service] {
+ gpr_log(GPR_DEBUG, "t1 start");
+ HandleClientStreaming(&service, cqs_[1].get());
+ gpr_log(GPR_DEBUG, "t1 done");
+ });
std::thread response_stream_handler_thread(
- [this, &service] { HandleServerStreaming(&service, cqs_[2].get()); });
+ [this, &service] {
+ gpr_log(GPR_DEBUG, "t2 start");
+ HandleServerStreaming(&service, cqs_[2].get());
+ gpr_log(GPR_DEBUG, "t2 done");
+ });
TestAllMethods();
generic_handler_thread.join();
request_stream_handler_thread.join();