Searched refs:running_reader_threads (Results 1 – 7 of 7) sorted by relevance
171 EXPECT_EQ(0U, reader_list_.running_reader_threads().size()); in ReadLogMessagesNonBlockingThread()179 for (auto& reader : reader_list_.running_reader_threads()) { in ReleaseAndJoinReaders()188 if (reader_list_.running_reader_threads().size() == 0) { in ReleaseAndJoinReaders()
37 const std::list<std::unique_ptr<LogReaderThread>>& running_reader_threads() const in running_reader_threads() function
40 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init()203 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Clear()244 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune()
109 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Init()189 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in Prune()234 for (const auto& reader_thread : reader_list_->running_reader_threads()) { in UidClear()
373 reader_list_.running_reader_threads().back()->Release(); in End()380 if (reader_list_.running_reader_threads().size() == 0) { in End()
327 if (reader_list_.running_reader_threads().back()->start() == 4) { in TEST_P()352 if (reader_list_.running_reader_threads().back()->start() == 7) { in TEST_P()
140 if (reader_list.running_reader_threads().size() == 0) { in LLVMFuzzerTestOneInput()