Lines Matching refs:reader_thread
40 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init() local
41 reader_thread->TriggerReader(); in Init()
237 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear() local
238 if (reader_thread->IsWatching(id)) { in Clear()
239 LOG(WARNING) << "Kicking blocked reader, " << reader_thread->name() in Clear()
241 reader_thread->Release(); in Clear()
278 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune() local
279 if (!reader_thread->IsWatching(id)) { in Prune()
282 if (!oldest || oldest->start() > reader_thread->start() || in Prune()
283 (oldest->start() == reader_thread->start() && in Prune()
284 reader_thread->deadline().time_since_epoch().count() != 0)) { in Prune()
285 oldest = reader_thread.get(); in Prune()