19 #ifndef GRPCPP_IMPL_CODEGEN_BYTE_BUFFER_H
20 #define GRPCPP_IMPL_CODEGEN_BYTE_BUFFER_H
34 class ServerInterface;
36 class ServerInterface;
39 template <
class RequestType,
class ResponseType>
40 class CallbackUnaryHandler;
41 template <
class RequestType,
class ResponseType>
42 class CallbackServerStreamingHandler;
43 template <
class RequestType>
45 template <
class ServiceType,
class RequestType,
class ResponseType>
46 class ServerStreamingHandler;
47 template <::grpc::StatusCode code>
48 class ErrorMethodHandler;
49 class CallOpSendMessage;
51 class CallOpRecvMessage;
52 class CallOpGenericRecvMessage;
53 class ExternalConnectionAcceptorImpl;
55 class DeserializeFuncType;
56 class GrpcByteBufferPeer;
70 static_assert(std::is_same<decltype(slices[0].slice_),
grpc_slice>::value,
71 "Slice must have same representation as grpc_slice");
73 "Slice must have same representation as grpc_slice");
78 "ByteBuffer must have same representation as "
81 "ByteBuffer must have same representation as "
125 Status Dump(std::vector<Slice>* slices)
const;
150 return buffer_ ==
nullptr
158 other->buffer_ = buffer_;
163 bool Valid()
const {
return (buffer_ !=
nullptr); }
172 template <
class RequestType>
175 template <
class ServiceType,
class RequestType,
class ResponseType>
177 template <
class RequestType,
class ResponseType>
179 template <
class RequestType,
class ResponseType>
181 template <StatusCode code>
203 class ByteBufferPointer {
218 ByteBufferPointer bbuf_ptr()
const {
return ByteBufferPointer(
this); }
225 dest->set_buffer(byte_buffer->buffer_);
A sequence of bytes.
Definition: byte_buffer.h:60
void Clear()
Remove all data.
Definition: byte_buffer.h:128
friend class internal::GrpcByteBufferPeer
Definition: byte_buffer.h:187
size_t Length() const
Buffer size in bytes.
Definition: byte_buffer.h:149
void Duplicate()
Make a duplicate copy of the internals of this byte buffer so that we have our own owned version of i...
Definition: byte_buffer.h:140
void Swap(ByteBuffer *other)
Swap the state of *this and *other.
Definition: byte_buffer.h:156
ByteBuffer(const ByteBuffer &buf)
Constuct a byte buffer by referencing elements of existing buffer buf.
Definition: byte_buffer.h:95
Status TrySingleSlice(Slice *slice) const
Definition: byte_buffer_cc.cc:28
ByteBuffer(const Slice *slices, size_t nslices)
Construct buffer from slices, of which there are nslices.
Definition: byte_buffer.h:66
ByteBuffer()
Constuct an empty buffer.
Definition: byte_buffer.h:63
Status DumpToSingleSlice(Slice *slice) const
Dump (read) the buffer contents into slics.
Definition: byte_buffer_cc.cc:44
Status Dump(std::vector< Slice > *slices) const
Dump (read) the buffer contents into slices.
Definition: byte_buffer_cc.cc:59
void Release()
Forget underlying byte buffer without destroying Use this only for un-owned byte buffers.
Definition: byte_buffer.h:146
bool Valid() const
Is this ByteBuffer valid?
Definition: byte_buffer.h:163
~ByteBuffer()
Definition: byte_buffer.h:97
ByteBuffer & operator=(const ByteBuffer &buf)
Wrapper of core function grpc_byte_buffer_copy .
Definition: byte_buffer.h:106
virtual grpc_byte_buffer * grpc_byte_buffer_copy(grpc_byte_buffer *bb)=0
virtual grpc_byte_buffer * grpc_raw_byte_buffer_create(grpc_slice *slice, size_t nslices)=0
virtual const Status & ok()=0
virtual void grpc_byte_buffer_destroy(grpc_byte_buffer *bb)=0
virtual size_t grpc_byte_buffer_length(grpc_byte_buffer *bb) GRPC_MUST_USE_RESULT=0
This is a specialization of the protobuf class ZeroCopyInputStream The principle is to get one chunk ...
Definition: proto_buffer_reader.h:46
This is a specialization of the protobuf class ZeroCopyOutputStream.
Definition: proto_buffer_writer.h:53
static Status Deserialize(ByteBuffer *byte_buffer, ByteBuffer *dest)
Definition: byte_buffer.h:224
static Status Serialize(const ByteBuffer &source, ByteBuffer *buffer, bool *own_buffer)
Definition: byte_buffer.h:228
Defines how to serialize and deserialize some type.
Definition: serialization_traits.h:58
Definition: server_interface.h:59
A wrapper around grpc_slice.
Definition: slice.h:35
Did it work? If it didn't, why?
Definition: status.h:31
static const Status & OK
An OK pre-defined instance.
Definition: status.h:105
Definition: call_op_set.h:526
Definition: call_op_set.h:424
Definition: call_op_set.h:282
Definition: server_callback_handlers.h:444
Definition: server_callback_handlers.h:31
Definition: call_op_set.h:513
General method handler class for errors that prevent real method use e.g., handle unknown method by r...
Definition: method_handler.h:358
Definition: external_connection_acceptor_impl.h:36
A wrapper class of an application provided server streaming handler.
Definition: method_handler.h:189
void * UnaryDeserializeHelper(grpc_byte_buffer *, ::grpc::Status *, RequestType *)
A helper function with reduced templating to do deserializing.
Definition: method_handler.h:80
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
CoreCodegenInterface * g_core_codegen_interface
Null-initializes the global gRPC variables for the codegen library.
Definition: completion_queue.h:96
grpc_slice slice
Definition: server.cc:461
Definition: grpc_types.h:40
A grpc_slice s, if initialized, represents the byte range s.bytes[0..s.length-1].
Definition: slice.h:60