diff options
author | 2015-07-10 15:32:11 -0700 | |
---|---|---|
committer | 2015-07-10 15:32:11 -0700 | |
commit | 69563b912413b3b2a6261a5e5f74a18ef0ce09ab (patch) | |
tree | 7c89e8f48f03349149cf77054bcef8c8758d1e9d /test/cpp/interop/server.cc | |
parent | 8819ac75d9ce7d0f09b0e4aa0c26eedc7a1c23f8 (diff) |
Add timeout interop test case
Diffstat (limited to 'test/cpp/interop/server.cc')
-rw-r--r-- | test/cpp/interop/server.cc | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/test/cpp/interop/server.cc b/test/cpp/interop/server.cc index 22b8910a24..db87872cf5 100644 --- a/test/cpp/interop/server.cc +++ b/test/cpp/interop/server.cc @@ -149,14 +149,12 @@ class TestServiceImpl : public TestService::Service { StreamingOutputCallResponse response; bool write_success = true; while (write_success && stream->Read(&request)) { - response.mutable_payload()->set_type(request.payload().type()); - if (request.response_parameters_size() == 0) { - return Status(grpc::StatusCode::INTERNAL, - "Request does not have response parameters."); + if (request.response_parameters_size() != 0) { + response.mutable_payload()->set_type(request.payload().type()); + response.mutable_payload()->set_body( + grpc::string(request.response_parameters(0).size(), '\0')); + write_success = stream->Write(response); } - response.mutable_payload()->set_body( - grpc::string(request.response_parameters(0).size(), '\0')); - write_success = stream->Write(response); } if (write_success) { return Status::OK; |