Searched refs:kThreads (Results 1 – 4 of 4) sorted by relevance
32 constexpr uint64_t kThreads = 20; variable139 IncrementArgs args[kThreads]; in TestIncrementMultiThread()141 thread_ids.reserve(kThreads); in TestIncrementMultiThread()164 ASSERT_EQ(counter.Load(), kThreads * (kThreads + 1) * (2 * kThreads + 1) / 6); in TestIncrementMultiThread()203 ExchangeArgs args[kThreads]; in TestExchangeMultiThread()205 thread_ids.reserve(kThreads); in TestExchangeMultiThread()230 kThreads * (kThreads + 1) / 2); in TestExchangeMultiThread()331 FlushArgs args[kThreads]; in TestFlushMultithread()333 thread_ids.reserve(kThreads); in TestFlushMultithread()359 constexpr size_t ceil_threads = (kThreads / 2) + kThreads % 2; in TestFlushMultithread()[all …]
33 constexpr uint64_t kThreads = 20; variable163 IncrementArgs args[kThreads]; in TestIncrementMultiThread()165 thread_ids.reserve(kThreads); in TestIncrementMultiThread()166 for (uint64_t i = 0; i < kThreads; ++i) { in TestIncrementMultiThread()170 for (uint64_t i = 0; i < kThreads; ++i) { in TestIncrementMultiThread()189 constexpr size_t amount = (kThreads - 1) * (kThreads); in TestIncrementMultiThread()339 FlushArgs args[kThreads]; in TestFlushMultithread()341 thread_ids.reserve(kThreads); in TestFlushMultithread()342 for (uint64_t i = 0; i < kThreads; ++i) { in TestFlushMultithread()367 constexpr size_t ceil_threads = ((kThreads - 1) / 2 * ((kThreads - 1) / 2 + 1)); in TestFlushMultithread()[all …]
28 constexpr size_t kThreads = 10; variable29 static_assert(kThreads % 2 == 0, "Use even number of threads for simplcity");392 observe_args.reserve(kThreads); in FlushMultithreadTest()393 thread_ids.reserve(kThreads); in FlushMultithreadTest()394 for (size_t thread_index = 0; thread_index < kThreads; ++thread_index) { in FlushMultithreadTest()
143 int kThreads = 5; in blind_write_multithreaded() local144 thrd_t threads[kThreads]; in blind_write_multithreaded()145 deep_sleep_args_t args[kThreads]; in blind_write_multithreaded()146 for (int i = 0; i < kThreads; ++i) { in blind_write_multithreaded()157 for (int i = 0; i < kThreads; ++i) { in blind_write_multithreaded()164 for (int i = 0; i < kThreads; ++i) { in blind_write_multithreaded()
Completed in 17 milliseconds