Searched refs:stream_buffer_caches_ (Results 1 – 2 of 2) sorted by relevance
121 if (stream_buffer_caches_.find(reg_info.stream_id) != in RegisterStream()122 stream_buffer_caches_.end()) { in RegisterStream()208 for (auto& [stream_id, stream_buffer_cache] : stream_buffer_caches_) { in NotifyFlushingAll()256 stream_buffer_caches_[reg_info.stream_id] = std::move(stream_buffer_cache); in AddStreamBufferCacheLocked()281 for (auto& [stream_id, cache] : stream_buffer_caches_) { in WorkloadThreadLoop()621 if (stream_buffer_caches_.find(stream_id) == stream_buffer_caches_.end()) { in GetStreamBufferCache()626 *stream_buffer_cache = stream_buffer_caches_[stream_id].get(); in GetStreamBufferCache()
292 std::map<int32_t, std::unique_ptr<StreamBufferCache>> stream_buffer_caches_; variable