19 #ifndef GRPCPP_IMPL_CODEGEN_PROTO_UTILS_H
20 #define GRPCPP_IMPL_CODEGEN_PROTO_UTILS_H
22 #include <type_traits>
44 template <
class ProtoBufferWriter,
class T>
49 "ProtoBufferWriter must be a subclass of "
50 "::protobuf::io::ZeroCopyOutputStream");
52 int byte_size =
static_cast<int>(msg.ByteSizeLong());
54 Slice slice(byte_size);
57 const_cast<uint8_t*
>(slice.
begin())));
64 return msg.SerializeToZeroCopyStream(&writer)
70 template <
class ProtoBufferReader,
class T>
75 "ProtoBufferReader must be a subclass of "
76 "::protobuf::io::ZeroCopyInputStream");
77 if (buffer ==
nullptr) {
86 if (!msg->ParseFromZeroCopyStream(&reader)) {
96 #ifdef GRPC_OPEN_SOURCE_PROTO
101 class SerializationTraits<
102 T, typename
std::enable_if<
103 std::is_base_of<grpc::protobuf::MessageLite, T>::value>::type> {
106 ByteBuffer* bb,
bool* own_buffer) {
107 return GenericSerialize<ProtoBufferWriter, T>(msg, bb, own_buffer);
110 static Status Deserialize(ByteBuffer* buffer,
112 return GenericDeserialize<ProtoBufferReader, T>(buffer, msg);
A sequence of bytes.
Definition: byte_buffer.h:60
void Clear()
Remove all data.
Definition: byte_buffer.h:128
void Swap(ByteBuffer *other)
Swap the state of *this and *other.
Definition: byte_buffer.h:156
virtual const Status & ok()=0
This is a specialization of the protobuf class ZeroCopyInputStream The principle is to get one chunk ...
Definition: proto_buffer_reader.h:46
Status status() const
Returns the status of the buffer reader.
Definition: proto_buffer_reader.h:96
This is a specialization of the protobuf class ZeroCopyOutputStream.
Definition: proto_buffer_writer.h:53
A wrapper around grpc_slice.
Definition: slice.h:35
const uint8_t * begin() const
Raw pointer to the beginning (first element) of the slice.
Definition: slice.h:110
const uint8_t * end() const
Raw pointer to the end (one byte past the last element) of the slice.
Definition: slice.h:113
Did it work? If it didn't, why?
Definition: status.h:31
bool ok() const
Is the status OK?
Definition: status.h:118
#define GRPC_SLICE_INLINED_SIZE
Definition: slice.h:47
#define GPR_CODEGEN_ASSERT(x)
Codegen specific version of GPR_ASSERT.
Definition: core_codegen_interface.h:146
::google::protobuf::io::ZeroCopyOutputStream ZeroCopyOutputStream
Definition: config_protobuf.h:98
::google::protobuf::io::ZeroCopyInputStream ZeroCopyInputStream
Definition: config_protobuf.h:99
::google::protobuf::util::Status Status
Definition: config_protobuf.h:91
::google::protobuf::MessageLite MessageLite
Definition: config_protobuf.h:77
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
Status GenericSerialize(const grpc::protobuf::MessageLite &msg, ByteBuffer *bb, bool *own_buffer)
Definition: proto_utils.h:45
Status GenericDeserialize(ByteBuffer *buffer, grpc::protobuf::MessageLite *msg)
Definition: proto_utils.h:71
const int kProtoBufferWriterMaxBufferLength
Definition: proto_buffer_writer.h:44
CoreCodegenInterface * g_core_codegen_interface
Definition: completion_queue.h:96
@ INTERNAL
Internal errors.
Definition: status_code_enum.h:119
Definition: async_unary_call.h:398