Searched refs:blocking_reader (Results 1 – 1 of 1) sorted by relevance
319 auto blocking_reader = TestReaderThread({.non_block = false}, *this); in TEST_P() local364 CompareLogMessages(expected_log_messages, blocking_reader.read_log_messages()); in TEST_P()388 auto blocking_reader = TestReaderThread({.non_block = false, .tail = kTailCount}, *this); in TEST_P() local398 if (blocking_reader.read_log_messages().size() == expected_log_messages.size()) { in TEST_P()399 CompareLogMessages(expected_log_messages, blocking_reader.read_log_messages()); in TEST_P()416 if (blocking_reader.read_log_messages().size() == expected_log_messages.size()) { in TEST_P()417 CompareLogMessages(expected_log_messages, blocking_reader.read_log_messages()); in TEST_P()426 CompareLogMessages(expected_log_messages, blocking_reader.read_log_messages()); in TEST_P()443 auto blocking_reader = TestReaderThread({.non_block = false, .tail = kTailCount}, *this); in TEST_P() local452 if (blocking_reader.read_log_messages().size() == expected_log_messages.size()) { in TEST_P()[all …]