Home
last modified time | relevance | path

Searched refs:ByteStream (Results 1 – 19 of 19) sorted by relevance

/third_party/grpc/src/core/lib/transport/
Dbyte_stream.h41 class ByteStream : public Orphanable {
43 ~ByteStream() override {} in ~ByteStream()
76 ByteStream(uint32_t length, uint32_t flags) in ByteStream() function
90 class SliceBufferByteStream : public ByteStream {
125 class CachingByteStream : public ByteStream {
147 explicit ByteStreamCache(OrphanablePtr<ByteStream> underlying_stream);
157 OrphanablePtr<ByteStream> underlying_stream_;
Dbyte_stream.cc39 : ByteStream(static_cast<uint32_t>(slice_buffer->length), flags) { in SliceBufferByteStream()
79 ByteStreamCache::ByteStreamCache(OrphanablePtr<ByteStream> underlying_stream) in ByteStreamCache()
100 : ByteStream(cache->length_, cache->flags_), cache_(cache) {} in CachingByteStream()
Dtransport.h258 grpc_core::OrphanablePtr<grpc_core::ByteStream> send_message;
297 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message = nullptr;
/third_party/grpc/src/cpp/common/
Dchannel_filter.h185 grpc_core::OrphanablePtr<grpc_core::ByteStream>* send_message() const { in send_message()
190 grpc_core::OrphanablePtr<grpc_core::ByteStream> send_message) { in set_send_message()
195 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message() const { in recv_message()
200 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message) { in set_recv_message()
/third_party/grpc/test/core/transport/
Dbyte_stream_test.cc135 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()
170 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()
212 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dframe_data.h80 grpc_core::OrphanablePtr<grpc_core::ByteStream>* stream_out);
Dinternal.h211 class Chttp2IncomingByteStream : public ByteStream {
545 grpc_core::OrphanablePtr<grpc_core::ByteStream> fetching_send_message;
557 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message;
Dframe_data.cc95 grpc_core::OrphanablePtr<grpc_core::ByteStream>* stream_out) { in grpc_deframe_unprocessed_incoming_frames()
Dchttp2_transport.cc2915 : ByteStream(frame_size, flags), in Chttp2IncomingByteStream()
/third_party/grpc/src/cpp/ext/filters/census/
Dclient_filter.h93 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message_;
Dserver_filter.h91 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message_;
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h126 OrphanablePtr<ByteStream> recv_message_;
/third_party/flutter/flutter/packages/flutter_tools/lib/src/reporting/
Dcrash_reporting.dart116 final String reportId = await http.ByteStream(resp.stream)
/third_party/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc184 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message = nullptr;
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc121 OrphanablePtr<ByteStream>* recv_message_ = nullptr;
/third_party/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc86 grpc_core::OrphanablePtr<grpc_core::ByteStream>* recv_message;
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc559 grpc_core::OrphanablePtr<grpc_core::ByteStream> recv_stream; in BM_TransportStreamRecv()
/third_party/grpc/src/core/lib/surface/
Dcall.cc225 grpc_core::OrphanablePtr<grpc_core::ByteStream> receiving_stream;
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc628 OrphanablePtr<ByteStream> recv_message;