diff options
author | 2017-09-13 13:43:39 -0700 | |
---|---|---|
committer | 2017-09-13 13:43:39 -0700 | |
commit | 4a4bd1cd2d18ac24e57be2c82b1ec112a981e6e6 (patch) | |
tree | 278429fa8cd20987360ced56991aff754334f69b /include/grpc++/impl/codegen/method_handler_impl.h | |
parent | 1217c4d0527e5b896f7720fcdbcd3f87ec4c1359 (diff) | |
parent | 4433973242e21db18291263a5b41ee292002eb6f (diff) |
Merge pull request #12214 from vjpai/cereal_eye_sir
Allow SerializationTraits to use grpc::ByteBuffer rather than only grpc_byte_buffer
Diffstat (limited to 'include/grpc++/impl/codegen/method_handler_impl.h')
-rw-r--r-- | include/grpc++/impl/codegen/method_handler_impl.h | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/include/grpc++/impl/codegen/method_handler_impl.h b/include/grpc++/impl/codegen/method_handler_impl.h index 15e24bdcdc..8125e0a651 100644 --- a/include/grpc++/impl/codegen/method_handler_impl.h +++ b/include/grpc++/impl/codegen/method_handler_impl.h @@ -19,6 +19,7 @@ #ifndef GRPCXX_IMPL_CODEGEN_METHOD_HANDLER_IMPL_H #define GRPCXX_IMPL_CODEGEN_METHOD_HANDLER_IMPL_H +#include <grpc++/impl/codegen/byte_buffer.h> #include <grpc++/impl/codegen/core_codegen_interface.h> #include <grpc++/impl/codegen/rpc_service_method.h> #include <grpc++/impl/codegen/sync_stream.h> @@ -37,8 +38,8 @@ class RpcMethodHandler : public MethodHandler { void RunHandler(const HandlerParameter& param) final { RequestType req; - Status status = - SerializationTraits<RequestType>::Deserialize(param.request, &req); + Status status = internal::MessageDeserializer<RequestType>::Deserialize( + param.request, &req); ResponseType rsp; if (status.ok()) { status = func_(service_, param.server_context, &req, &rsp); @@ -123,8 +124,8 @@ class ServerStreamingHandler : public MethodHandler { void RunHandler(const HandlerParameter& param) final { RequestType req; - Status status = - SerializationTraits<RequestType>::Deserialize(param.request, &req); + Status status = internal::MessageDeserializer<RequestType>::Deserialize( + param.request, &req); if (status.ok()) { ServerWriter<ResponseType> writer(param.call, param.server_context); |