Lines Matching refs:reader_thread
40 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local
41 reader_thread->TriggerReader(); in Init()
203 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Clear() local
204 if (reader_thread->IsWatching(id)) { in Clear()
205 LOG(WARNING) << "Kicking blocked reader, " << reader_thread->name() in Clear()
207 reader_thread->Release(); in Clear()
244 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune() local
245 if (!reader_thread->IsWatching(id)) { in Prune()
248 if (!oldest || oldest->start() > reader_thread->start() || in Prune()
249 (oldest->start() == reader_thread->start() && in Prune()
250 reader_thread->deadline().time_since_epoch().count() != 0)) { in Prune()
251 oldest = reader_thread.get(); in Prune()