aboutsummaryrefslogtreecommitdiffhomepage
path: root/include/grpc++/impl/rpc_service_method.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/grpc++/impl/rpc_service_method.h')
-rw-r--r--include/grpc++/impl/rpc_service_method.h8
1 files changed, 2 insertions, 6 deletions
diff --git a/include/grpc++/impl/rpc_service_method.h b/include/grpc++/impl/rpc_service_method.h
index 1bf39fca3b..a5e25f9651 100644
--- a/include/grpc++/impl/rpc_service_method.h
+++ b/include/grpc++/impl/rpc_service_method.h
@@ -94,9 +94,7 @@ class RpcMethodHandler : public MethodHandler {
CallOpServerSendStatus> ops;
ops.SendInitialMetadata(param.server_context->initial_metadata_);
if (status.IsOk()) {
- if (!ops.SendMessage(rsp)) {
- status = Status(INTERNAL, "Failed to serialize response");
- }
+ status = ops.SendMessage(rsp);
}
ops.ServerSendStatus(param.server_context->trailing_metadata_, status);
param.call->PerformOps(&ops);
@@ -131,9 +129,7 @@ class ClientStreamingHandler : public MethodHandler {
CallOpServerSendStatus> ops;
ops.SendInitialMetadata(param.server_context->initial_metadata_);
if (status.IsOk()) {
- if (!ops.SendMessage(rsp)) {
- status = Status(INTERNAL, "Failed to serialize response");
- }
+ status = ops.SendMessage(rsp);
}
ops.ServerSendStatus(param.server_context->trailing_metadata_, status);
param.call->PerformOps(&ops);