Searched refs:CatStreamDataPtr (Results 1 – 5 of 5) sorted by relevance
36 using CatStreamDataPtr = tlx::CountingPtr<CatStreamData>; typedef126 CatStreamDataPtr GetOrCreateCatStreamData(191 CatStreamDataPtr CatLoopback(size_t stream_id, size_t to_worker_id);202 CatStreamDataPtr IntGetOrCreateCatStreamData(228 const CatStreamDataPtr& stream, PinnedByteBlockPtr&& bytes);
149 using CatStreamDataPtr = tlx::CountingPtr<CatStreamData>; typedef163 explicit CatStream(const CatStreamDataPtr& ptr);195 CatStreamDataPtr ptr_;
189 CatStreamDataPtr Multiplexer::GetOrCreateCatStreamData( in GetOrCreateCatStreamData()203 CatStreamDataPtr Multiplexer::IntGetOrCreateCatStreamData( in IntGetOrCreateCatStreamData()205 CatStreamDataPtr ptr = in IntGetOrCreateCatStreamData()333 CatStreamDataPtr stream = GetOrCreateCatStreamData( in OnMultiplexerHeader()354 CatStreamDataPtr stream = GetOrCreateCatStreamData( in OnMultiplexerHeader()362 CatStreamDataPtr stream = GetOrCreateCatStreamData( in OnMultiplexerHeader()453 const CatStreamDataPtr& stream, PinnedByteBlockPtr&& bytes) { in OnCatStreamBlock()499 CatStreamDataPtr Multiplexer::CatLoopback( in CatLoopback()
59 [p = CatStreamDataPtr(this)](BlockQueue& queue) { in CatStreamData()326 CatStream::CatStream(const CatStreamDataPtr& ptr) in CatStream()
81 [workers_per_host](data::CatStreamDataPtr stream, size_t my_id) { in TEST()92 [workers_per_host](data::CatStreamDataPtr stream, size_t my_id) { in TEST()