19 #ifndef GRPC_CORE_LIB_TRANSPORT_BYTE_STREAM_H
20 #define GRPC_CORE_LIB_TRANSPORT_BYTE_STREAM_H
30 #define GRPC_WRITE_INTERNAL_COMPRESS (0x80000000u)
34 #define GRPC_WRITE_INTERNAL_TEST_ONLY_WAS_COMPRESSED (0x40000000u)
36 #define GRPC_WRITE_INTERNAL_USED_MASK \
37 (GRPC_WRITE_INTERNAL_COMPRESS | GRPC_WRITE_INTERNAL_TEST_ONLY_WAS_COMPRESSED)
70 uint32_t
length()
const {
return length_; }
71 uint32_t
flags()
const {
return flags_; }
80 const uint32_t length_;
Definition: byte_stream.h:125
grpc_error_handle Pull(grpc_slice *slice) override
Definition: byte_stream.cc:120
~CachingByteStream() override
Definition: byte_stream.cc:102
bool Next(size_t max_size_hint, grpc_closure *on_complete) override
Definition: byte_stream.cc:112
void Reset()
Definition: byte_stream.cc:153
void Shutdown(grpc_error_handle error) override
Definition: byte_stream.cc:145
void Orphan() override
Definition: byte_stream.cc:104
CachingByteStream(ByteStreamCache *cache)
Definition: byte_stream.cc:99
Definition: byte_stream.h:123
ByteStreamCache(OrphanablePtr< ByteStream > underlying_stream)
Definition: byte_stream.cc:79
~ByteStreamCache()
Definition: byte_stream.cc:86
grpc_slice_buffer * cache_buffer()
Definition: byte_stream.h:154
void Destroy()
Definition: byte_stream.cc:88
Definition: byte_stream.h:41
~ByteStream() override
Definition: byte_stream.h:43
ByteStream(uint32_t length, uint32_t flags)
Definition: byte_stream.h:76
virtual bool Next(size_t max_size_hint, grpc_closure *on_complete)=0
virtual grpc_error_handle Pull(grpc_slice *slice)=0
virtual void Shutdown(grpc_error_handle error)=0
uint32_t flags() const
Definition: byte_stream.h:71
void set_flags(uint32_t flags)
Definition: byte_stream.h:73
uint32_t length() const
Definition: byte_stream.h:70
Definition: orphanable.h:42
Definition: byte_stream.h:90
SliceBufferByteStream(grpc_slice_buffer *slice_buffer, uint32_t flags)
Definition: byte_stream.cc:37
grpc_error_handle Pull(grpc_slice *slice) override
Definition: byte_stream.cc:62
~SliceBufferByteStream() override
Definition: byte_stream.cc:45
void Shutdown(grpc_error_handle error) override
Definition: byte_stream.cc:70
bool Next(size_t max_size_hint, grpc_closure *on_complete) override
Definition: byte_stream.cc:56
void Orphan() override
Definition: byte_stream.cc:47
#define GRPC_ERROR_NONE
The following "special" errors can be propagated without allocating memory.
Definition: error.h:228
grpc_error_handle error
Definition: lame_client.cc:54
Round Robin Policy.
Definition: backend_metric.cc:26
std::unique_ptr< T, Deleter > OrphanablePtr
Definition: orphanable.h:67
grpc_slice slice
Definition: server.cc:461
A closure over a grpc_iomgr_cb_func.
Definition: closure.h:56
Definition: error_internal.h:41
Represents an expandable array of slices, to be interpreted as a single item.
Definition: slice.h:78
A grpc_slice s, if initialized, represents the byte range s.bytes[0..s.length-1].
Definition: slice.h:60