Searched refs:reader_threads (Results 1 – 10 of 10) sorted by relevance
129 test_.reader_list_.reader_threads().emplace_back(std::move(log_reader)); in TestReaderThread()152 EXPECT_EQ(0U, reader_list_.reader_threads().size()); in ReadLogMessagesNonBlockingThread()160 for (auto& reader : reader_list_.reader_threads()) { in ReleaseAndJoinReaders()169 if (reader_list_.reader_threads().size() == 0) { in ReleaseAndJoinReaders()
40 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()237 for (const auto& reader_thread : reader_list_->reader_threads()) { in Clear()278 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()
109 for (const auto& reader_thread : reader_list_->reader_threads()) { in Init()189 for (const auto& reader_thread : reader_list_->reader_threads()) { in Prune()234 for (const auto& reader_thread : reader_list_->reader_threads()) { in UidClear()
31 std::list<std::unique_ptr<LogReaderThread>>& reader_threads() REQUIRES(logd_lock) { in reader_threads() function
223 reader_list_->reader_threads().emplace_front(std::move(entry)); in onDataAvailable()236 for (const auto& reader : reader_list_->reader_threads()) { in DoSocketDelete()
381 reader_list_.reader_threads().emplace_back(std::move(log_reader)); in PrintAllLogs()395 reader_list_.reader_threads().back()->Release(); in End()402 if (reader_list_.reader_threads().size() == 0) { in End()
107 auto& log_reader_threads = reader_list_->reader_threads(); in ThreadFunction()
327 if (reader_list_.reader_threads().back()->start() == 4) { in TEST_P()352 if (reader_list_.reader_threads().back()->start() == 7) { in TEST_P()
337 for (const auto& reader_thread : reader_list()->reader_threads()) { in Prune()
134 reader_list.reader_threads().emplace_back(std::move(log_reader)); in LLVMFuzzerTestOneInput()141 if (reader_list.reader_threads().size() == 0) { in LLVMFuzzerTestOneInput()