From 3ca49d2a1a42dfd80e17f57c69020f5bd793ee14 Mon Sep 17 00:00:00 2001 From: vjpai Date: Thu, 24 Sep 2015 21:55:16 -0700 Subject: Add a todo regarding a C++ block annotation --- test/cpp/end2end/streaming_throughput_test.cc | 2 ++ 1 file changed, 2 insertions(+) (limited to 'test/cpp/end2end/streaming_throughput_test.cc') 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); -- cgit v1.2.3