Searched refs:ingest_thread (Results 1 – 1 of 1) sorted by relevance
2517 port::Thread ingest_thread([&]() { in TEST_P() local2539 ingest_thread.join(); in TEST_P()2605 port::Thread ingest_thread([&]() { in TEST_P() local2617 ingest_thread.join(); in TEST_P()2675 port::Thread ingest_thread([&]() { in TEST_P() local2687 ingest_thread.join(); in TEST_P()2750 port::Thread ingest_thread([&]() { in TEST_P() local2762 ingest_thread.join(); in TEST_P()