Home
last modified time | relevance | path

Searched refs:kNumThreads (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/logging/
Denv_logger_test.cc138 const int kNumThreads = 5; in TEST_F() local
140 for (int ii = 0; ii < kNumThreads; ++ii) { in TEST_F()
153 kNumIter * kNumThreads); in TEST_F()
/rocksdb-6.9/db/
Ddb_write_test.cc135 constexpr int kNumThreads = 5; in TEST_P() local
154 while (ready_count < kNumThreads) { in TEST_P()
160 for (int i = 0; i < kNumThreads; i++) { in TEST_P()
180 for (int i = 0; i < kNumThreads; i++) { in TEST_P()
Ddb_test.cc2365 static const int kNumThreads = 10; variable
2372 std::atomic<int> counter[kNumThreads];
2373 std::atomic<bool> thread_done[kNumThreads];
2470 ASSERT_LT(w, kNumThreads); in MTThreadBody()
2525 for (int id = 0; id < kNumThreads; id++) { in TEST_P()
2531 MTThread thread[kNumThreads]; in TEST_P()
2532 for (int id = 0; id < kNumThreads; id++) { in TEST_P()
2544 for (int id = 0; id < kNumThreads; id++) { in TEST_P()
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_transaction_test.cc147 const uint32_t kNumThreads = 10; in TEST_P() local
164 for (uint32_t k = 0; k < kNumKeys * kNumThreads; k++) { in TEST_P()
190 owned_keys.insert(keys[rnd.Uniform(kNumKeys * kNumThreads)]); in TEST_P()
308 for (uint32_t i = 0; i < kNumThreads; i++) { in TEST_P()
/rocksdb-6.9/util/
Dthread_local_test.cc464 static const int kNumThreads = 16; in TEST_F() local
468 Params params(&mu, &cv, nullptr, kNumThreads, unref); in TEST_F()
508 ASSERT_EQ(sum, kNumThreads * kItersPerThread); in TEST_F()