Searched refs:ByteStreamCache (Results 1 – 5 of 5) sorted by relevance
81 ByteStreamCache::ByteStreamCache(OrphanablePtr<ByteStream> underlying_stream) in ByteStreamCache() function in grpc_core::ByteStreamCache88 ByteStreamCache::~ByteStreamCache() { Destroy(); } in ~ByteStreamCache()90 void ByteStreamCache::Destroy() { in Destroy()101 ByteStreamCache::CachingByteStream::CachingByteStream(ByteStreamCache* cache) in CachingByteStream()104 ByteStreamCache::CachingByteStream::~CachingByteStream() {} in ~CachingByteStream()106 void ByteStreamCache::CachingByteStream::Orphan() { in Orphan()114 bool ByteStreamCache::CachingByteStream::Next(size_t max_size_hint, in Next()122 grpc_error* ByteStreamCache::CachingByteStream::Pull(grpc_slice* slice) { in Pull()147 void ByteStreamCache::CachingByteStream::Shutdown(grpc_error* error) { in Shutdown()155 void ByteStreamCache::CachingByteStream::Reset() { in Reset()
122 class ByteStreamCache {126 explicit CachingByteStream(ByteStreamCache* cache);140 ByteStreamCache* cache_;146 explicit ByteStreamCache(OrphanablePtr<ByteStream> underlying_stream);148 ~ByteStreamCache();
133 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()134 ByteStreamCache::CachingByteStream stream(&cache); in TEST()168 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()169 ByteStreamCache::CachingByteStream stream(&cache); in TEST()210 ByteStreamCache cache((OrphanablePtr<ByteStream>(&underlying_stream))); in TEST()211 ByteStreamCache::CachingByteStream stream1(&cache); in TEST()212 ByteStreamCache::CachingByteStream stream2(&cache); in TEST()
64 grpc_core::ManualConstructor<grpc_core::ByteStreamCache> send_message_cache;65 grpc_core::ManualConstructor<grpc_core::ByteStreamCache::CachingByteStream>
856 grpc_core::ManualConstructor<grpc_core::ByteStreamCache::CachingByteStream>987 grpc_core::InlinedVector<grpc_core::ByteStreamCache*, 3>>1034 grpc_core::ByteStreamCache* cache = in maybe_cache_send_ops_for_batch()1035 static_cast<grpc_core::ByteStreamCache*>( in maybe_cache_send_ops_for_batch()1036 gpr_arena_alloc(calld->arena, sizeof(grpc_core::ByteStreamCache))); in maybe_cache_send_ops_for_batch()1037 new (cache) grpc_core::ByteStreamCache( in maybe_cache_send_ops_for_batch()2249 grpc_core::ByteStreamCache* cache = in add_retriable_send_message_op()