diff options
Diffstat (limited to 'test/cpp/end2end/streaming_throughput_test.cc')
-rw-r--r-- | test/cpp/end2end/streaming_throughput_test.cc | 2 |
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); |