aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/streaming_throughput_test.cc
diff options
context:
space:
mode:
authorGravatar vjpai <vpai@google.com>2015-09-24 21:55:16 -0700
committerGravatar vjpai <vpai@google.com>2015-09-24 21:55:16 -0700
commit3ca49d2a1a42dfd80e17f57c69020f5bd793ee14 (patch)
tree3ec476fde171acfafbe6f6c812e493d3e2345c9b /test/cpp/end2end/streaming_throughput_test.cc
parent2a42e55bb993a8ce4cbb795e8eedf38668a47710 (diff)
Add a todo regarding a C++ block annotation
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);