Lines Matching refs:threads
270 std::vector<port::Thread> threads; in TEST_F() local
296 if (threads.empty()) { in TEST_F()
298 threads.emplace_back(write_slowdown_func); in TEST_F()
301 threads.emplace_back(write_no_slowdown_func); in TEST_F()
317 for (auto& t : threads) { in TEST_F()
331 std::vector<port::Thread> threads; in TEST_F() local
350 if (threads.empty()) { in TEST_F()
352 threads.emplace_back(write_no_slowdown_func); in TEST_F()
375 for (auto& t : threads) { in TEST_F()
387 std::vector<port::Thread> threads; in TEST_F() local
418 if (threads.empty()) { in TEST_F()
420 threads.emplace_back(write_slowdown_func); in TEST_F()
423 threads.emplace_back(write_no_slowdown_func); in TEST_F()
430 threads.emplace_back(wakeup_writer); in TEST_F()
444 for (auto& t : threads) { in TEST_F()
906 std::vector<port::Thread> threads; in TEST_F() local
922 threads.emplace_back(fill_memtable_func); in TEST_F()
925 for (auto& t : threads) { in TEST_F()
3849 std::vector<port::Thread> threads; in TEST_F() local
3852 threads.emplace_back([&] { Put("a", "b"); }); in TEST_F()
3854 threads.emplace_back([&] { Flush(); }); in TEST_F()
3861 for (auto& t : threads) { in TEST_F()
3877 std::vector<port::Thread> threads; in TEST_F() local
3878 threads.emplace_back([&] { in TEST_F()
3885 threads.emplace_back([&] { in TEST_F()
3894 threads.emplace_back([&] { in TEST_F()
3899 for (auto& t : threads) { in TEST_F()
5896 std::vector<port::Thread> threads; in TEST_F() local
5897 threads.emplace_back([&]() { Compact("a", "z"); }); in TEST_F()
5910 for (auto& t : threads) { in TEST_F()
6408 std::vector<port::Thread> threads; in TEST_F() local
6411 threads.emplace_back([&]() { in TEST_F()
6422 for (auto& t : threads) { in TEST_F()