Searched refs:reader_thread (Results 1 – 2 of 2) sorted by relevance
40 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local41 reader_thread->TriggerReader(); in Init()203 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Clear() local204 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() local245 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()[all …]
109 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init() local110 reader_thread->TriggerReader(); in Init()189 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune() local190 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() local235 if (!reader_thread->IsWatching(log_id)) { in UidClear()[all …]