Searched refs:reader_thread (Results 1 – 4 of 4) sorted by relevance
109 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init() local110 reader_thread->TriggerReader(); in Init()189 for (const auto& reader_thread : reader_list_->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_->reader_threads()) { in UidClear() local235 if (!reader_thread->IsWatching(log_id)) { in UidClear()[all …]
40 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init() local41 reader_thread->TriggerReader(); in Init()237 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear() local238 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() local279 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()[all …]
337 for (const auto& reader_thread : reader_list()->reader_threads()) { in Prune() local338 if (!reader_thread->IsWatching(id)) { in Prune()341 if (!oldest || oldest->start() > reader_thread->start() || in Prune()342 (oldest->start() == reader_thread->start() && in Prune()343 reader_thread->deadline().time_since_epoch().count() != 0)) { in Prune()344 oldest = reader_thread.get(); in Prune()
107 Thread* reader_thread = NULL; variable215 reader_thread = new Thread("hci_sock_reader"); in hci_initialize()216 reader_thread->Start(); in hci_initialize()217 reader_thread->task_runner()->PostTask( in hci_initialize()238 if (reader_thread != NULL) { in hci_close()239 reader_thread->Stop(); in hci_close()240 delete reader_thread; in hci_close()241 reader_thread = NULL; in hci_close()