aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/streaming_throughput_test.cc
diff options
context:
space:
mode:
Diffstat (limited to 'test/cpp/end2end/streaming_throughput_test.cc')
-rw-r--r--test/cpp/end2end/streaming_throughput_test.cc2
1 files changed, 2 insertions, 0 deletions
diff --git a/test/cpp/end2end/streaming_throughput_test.cc b/test/cpp/end2end/streaming_throughput_test.cc
index 63d49c0425..d64d96fe93 100644
--- a/test/cpp/end2end/streaming_throughput_test.cc
+++ b/test/cpp/end2end/streaming_throughput_test.cc
@@ -103,6 +103,7 @@ class TestServiceImpl : public ::grpc::cpp::test::util::TestService::Service {
EchoResponse response;
response.set_message(kLargeString);
while (!should_exit->load()) {
+ // TODO(vpai): Decide if the below requires blocking annotation
std::this_thread::sleep_for(std::chrono::milliseconds(1));
stream->Write(response);
}
@@ -117,6 +118,7 @@ class TestServiceImpl : public ::grpc::cpp::test::util::TestService::Service {
std::thread sender(std::bind(&TestServiceImpl::BidiStream_Sender, stream, &should_exit));
while (stream->Read(&request)) {
+ // TODO(vpai): Decide if the below requires blocking annotation
std::this_thread::sleep_for(std::chrono::milliseconds(3));
}
should_exit.store(true);