Searched refs:stream_buffer_caches_ (Results 1 – 2 of 2) sorted by relevance
109 if (stream_buffer_caches_.find(reg_info.stream_id) != in RegisterStream()110 stream_buffer_caches_.end()) { in RegisterStream()181 for (auto& [stream_id, stream_buffer_cache] : stream_buffer_caches_) { in NotifyFlushingAll()221 stream_buffer_caches_[reg_info.stream_id] = std::move(stream_buffer_cache); in AddStreamBufferCacheLocked()246 for (auto& [stream_id, cache] : stream_buffer_caches_) { in WorkloadThreadLoop()577 if (stream_buffer_caches_.find(stream_id) == stream_buffer_caches_.end()) { in GetStreamBufferCache()582 *stream_buffer_cache = stream_buffer_caches_[stream_id].get(); in GetStreamBufferCache()
287 std::map<int32_t, std::unique_ptr<StreamBufferCache>> stream_buffer_caches_; variable