Lines Matching refs:reader_thread
109 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local
110 reader_thread->TriggerReader(); in Init()
189 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune() local
190 if (!reader_thread->IsWatching(log_id)) { in Prune()
194 if (reader_thread->deadline().time_since_epoch().count() != 0) { in Prune()
202 reader_thread->TriggerReader(); in Prune()
209 if (reader_thread->start() <= it->highest_sequence_number()) { in Prune()
210 LOG(WARNING) << "Skipping entries from slow reader, " << reader_thread->name() in Prune()
234 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in UidClear() local
235 if (!reader_thread->IsWatching(log_id)) { in UidClear()
239 if (reader_thread->deadline().time_since_epoch().count() != 0) { in UidClear()
240 reader_thread->TriggerReader(); in UidClear()