diff --git a/test/cpp/interop/client.cc b/test/cpp/interop/client.cc index ed410c9ef0ecaff799a6b87ccd8c14130f1408ab..48143b2e53a5d1cbb70c2c2c24f587bd9277bf4b 100644 --- a/test/cpp/interop/client.cc +++ b/test/cpp/interop/client.cc @@ -74,7 +74,7 @@ DEFINE_string(test_case, "large_unary", "jwt_token_creds: large_unary with JWT token auth; " "oauth2_auth_token: raw oauth2 access token auth; " "per_rpc_creds: raw oauth2 access token on a single rpc; " - "status_code_and_message: verify status code & message; " + "status_code_and_message: verify status code & message; " "all : all of above."); DEFINE_string(default_service_account, "", "Email of GCE default service account"); diff --git a/test/cpp/interop/interop_client.cc b/test/cpp/interop/interop_client.cc index 7ad0f31575e34cf3629bd85e0016f677ca0e6cef..a43225011e35faf90924f37f246aebc3fba865d4 100644 --- a/test/cpp/interop/interop_client.cc +++ b/test/cpp/interop/interop_client.cc @@ -122,7 +122,7 @@ void InteropClient::PerformLargeCompressedUnary(SimpleRequest* request, grpc::string payload(kLargeRequestSize, '\0'); request->mutable_payload()->set_body(payload.c_str(), kLargeRequestSize); - Status s = stub->CompressedUnaryCall(&context, *request, response); + Status s = stub->UnaryCall(&context, *request, response); // Compression related checks. GPR_ASSERT(request->response_compression() == diff --git a/test/cpp/interop/server.cc b/test/cpp/interop/server.cc index ac0a2e512bfbfca5a402475617a1dcaa37b8a6a0..2ea8794e5adfc20180e26d6066d657be7e21647d 100644 --- a/test/cpp/interop/server.cc +++ b/test/cpp/interop/server.cc @@ -43,6 +43,7 @@ #include <grpc/grpc.h> #include <grpc/support/log.h> #include <grpc/support/useful.h> + #include <grpc++/config.h> #include <grpc++/server.h> #include <grpc++/server_builder.h> @@ -140,6 +141,7 @@ class TestServiceImpl : public TestService::Service { Status UnaryCall(ServerContext* context, const SimpleRequest* request, SimpleResponse* response) { + SetResponseCompression(context, *request); if (request->has_response_size() && request->response_size() > 0) { if (!SetPayload(request->response_type(), request->response_size(), response->mutable_payload())) { @@ -148,21 +150,14 @@ class TestServiceImpl : public TestService::Service { } if (request->has_response_status()) { - return Status(static_cast<grpc::StatusCode> - (request->response_status().code()), - request->response_status().message()); + return Status( + static_cast<grpc::StatusCode>(request->response_status().code()), + request->response_status().message()); } return Status::OK; } - Status CompressedUnaryCall(ServerContext* context, - const SimpleRequest* request, - SimpleResponse* response) { - SetResponseCompression(context, *request); - return UnaryCall(context, request, response); - } - Status StreamingOutputCall( ServerContext* context, const StreamingOutputCallRequest* request, ServerWriter<StreamingOutputCallResponse>* writer) { @@ -183,13 +178,6 @@ class TestServiceImpl : public TestService::Service { } } - Status CompressedStreamingOutputCall( - ServerContext* context, const StreamingOutputCallRequest* request, - ServerWriter<StreamingOutputCallResponse>* writer) { - SetResponseCompression(context, *request); - return StreamingOutputCall(context, request, writer); - } - Status StreamingInputCall(ServerContext* context, ServerReader<StreamingInputCallRequest>* reader, StreamingInputCallResponse* response) { diff --git a/test/proto/test.proto b/test/proto/test.proto index 574c6a5b50e48c263fc47e70cf2ad855715ee521..368522dc4c925d67390b1efdd2c52216aa5bf8d2 100644 --- a/test/proto/test.proto +++ b/test/proto/test.proto @@ -48,9 +48,6 @@ service TestService { // TODO(Issue 527): Describe required server behavior. rpc UnaryCall(SimpleRequest) returns (SimpleResponse); - // One request followed by one compressed response. - rpc CompressedUnaryCall(SimpleRequest) returns (SimpleResponse); - // One request followed by a sequence of responses (streamed download). // The server returns the payload with client desired type and sizes. rpc StreamingOutputCall(StreamingOutputCallRequest)