| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | byte_stream.cc | 37 SliceBufferByteStream::SliceBufferByteStream(grpc_slice_buffer* slice_buffer, in SliceBufferByteStream() function in grpc_core::SliceBufferByteStream
45 SliceBufferByteStream::~SliceBufferByteStream() {} in ~SliceBufferByteStream()
47 void SliceBufferByteStream::Orphan() { in Orphan()
56 bool SliceBufferByteStream::Next(size_t /*max_size_hint*/, in Next()
62 grpc_error* SliceBufferByteStream::Pull(grpc_slice* slice) { in Pull()
70 void SliceBufferByteStream::Shutdown(grpc_error* error) { in Shutdown()
|
| D | byte_stream.h | 90 class SliceBufferByteStream : public ByteStream {
93 SliceBufferByteStream(grpc_slice_buffer* slice_buffer, uint32_t flags);
95 ~SliceBufferByteStream() override;
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | byte_stream.cc | 37 SliceBufferByteStream::SliceBufferByteStream(grpc_slice_buffer* slice_buffer, in SliceBufferByteStream() function in grpc_core::SliceBufferByteStream
45 SliceBufferByteStream::~SliceBufferByteStream() {} in ~SliceBufferByteStream()
47 void SliceBufferByteStream::Orphan() { in Orphan()
56 bool SliceBufferByteStream::Next(size_t max_size_hint, in Next()
62 grpc_error* SliceBufferByteStream::Pull(grpc_slice* slice) { in Pull()
72 void SliceBufferByteStream::Shutdown(grpc_error* error) { in Shutdown()
|
| D | byte_stream.h | 88 class SliceBufferByteStream : public ByteStream {
91 SliceBufferByteStream(grpc_slice_buffer* slice_buffer, uint32_t flags);
93 ~SliceBufferByteStream();
|
| /external/grpc-grpc/test/core/transport/ |
| D | byte_stream_test.cc | 42 TEST(SliceBufferByteStream, Basic) { in TEST() argument
55 SliceBufferByteStream stream(&buffer, 0); in TEST()
74 TEST(SliceBufferByteStream, Shutdown) { in TEST() argument
87 SliceBufferByteStream stream(&buffer, 0); in TEST()
130 SliceBufferByteStream underlying_stream(&buffer, 0); in TEST()
165 SliceBufferByteStream underlying_stream(&buffer, 0); in TEST()
207 SliceBufferByteStream underlying_stream(&buffer, 0); in TEST()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 126 std::aligned_storage<sizeof(SliceBufferByteStream),
127 alignof(SliceBufferByteStream)>::type
278 SliceBufferByteStream(&decompressed_slices, recv_flags); in FinishRecvMessage()
280 reinterpret_cast<SliceBufferByteStream*>(&recv_replacement_stream_)); in FinishRecvMessage()
|
| D | message_compress_filter.cc | 167 std::aligned_storage<sizeof(grpc_core::SliceBufferByteStream),
168 alignof(grpc_core::SliceBufferByteStream)>::type
341 grpc_core::SliceBufferByteStream(&slices_, send_flags); in FinishSendMessage()
343 reinterpret_cast<grpc_core::SliceBufferByteStream*>( in FinishSendMessage()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.h | 116 ManualConstructor<SliceBufferByteStream> send_message_;
|
| D | health_check_client.cc | 184 ManualConstructor<SliceBufferByteStream>* send_message) { in EncodeRequest()
|
| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 66 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream>
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 49 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 72 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 408 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> send_stream; in BM_TransportStreamSend()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 258 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> recv_stream;
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 103 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> recv_stream;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 137 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> sbs;
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 126 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> sbs;
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 184 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> sending_stream;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 223 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> sending_stream;
|