Searched refs:reader_thread (Results 1 – 4 of 4) sorted by relevance
44 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init() local45 reader_thread->triggerReader_Locked(); in Init()131 for (const auto& reader_thread : reader_list_->reader_threads()) { in NotifyReadersOfPrune() local132 auto& state = reinterpret_cast<SerializedFlushToState&>(reader_thread->flush_to_state()); in NotifyReadersOfPrune()141 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune() local142 if (!reader_thread->IsWatching(log_id)) { in Prune()145 if (!oldest || oldest->start() > reader_thread->start() || in Prune()146 (oldest->start() == reader_thread->start() && in Prune()147 reader_thread->deadline().time_since_epoch().count() != 0)) { in Prune()148 oldest = reader_thread.get(); in Prune()[all …]
39 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init() local40 reader_thread->triggerReader_Locked(); 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_Locked(); in Clear()280 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune() local281 if (!reader_thread->IsWatching(id)) { in Prune()284 if (!oldest || oldest->start() > reader_thread->start() || in Prune()285 (oldest->start() == reader_thread->start() && in Prune()[all …]
339 for (const auto& reader_thread : reader_list()->reader_threads()) { in Prune() local340 if (!reader_thread->IsWatching(id)) { in Prune()343 if (!oldest || oldest->start() > reader_thread->start() || in Prune()344 (oldest->start() == reader_thread->start() && in Prune()345 reader_thread->deadline().time_since_epoch().count() != 0)) { in Prune()346 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()