Home
last modified time | relevance | path

Searched refs:n_threads (Results 1 - 7 of 7) sorted by relevance

/5.5.2/kv_engine/engines/ep/tests/module_tests/
H A Dthread_gate.h28 ThreadGate() : n_threads(0) { in ThreadGate()
32 * @param n_threads Total number of threads to wait for.
34 ThreadGate(size_t n_threads_) : n_threads(n_threads_) { in ThreadGate()
44 if (++thread_count != n_threads) { in threadUp()
62 return thread_count == n_threads; in isComplete()
66 const size_t n_threads; member in ThreadGate
H A Dcheckpoint_test.cc227 const size_t n_threads{n_set_threads + n_dcp_threads + 2}; in TYPED_TEST()
228 ThreadGate gate{n_threads}; in TYPED_TEST()
1040 const int n_threads = 8; in TYPED_TEST() local
1048 n_threads * n_items, in TYPED_TEST()
1062 // just do a scatter gather over n_threads in TYPED_TEST()
1063 std::vector<std::vector<std::pair<uint64_t, uint64_t> > > threadData(n_threads); in TYPED_TEST()
1064 for (int ii = 0; ii < n_threads; ii++) { in TYPED_TEST()
1116 /* We should have got (n_threads*n_items + op_ckpt_start) items. */ in TYPED_TEST()
1117 EXPECT_EQ(n_threads*n_items + 1, items.size()); in TYPED_TEST()
/5.5.2/phosphor/tests/include/
H A Dbarrier.h21 : n_threads(0) { in Barrier()
26 * @param n_threads Total number of threads to wait for.
29 : n_threads(n_threads_) { in Barrier()
38 n_threads = n_threads_; in reset()
42 * Wait for n_threads to invoke this function
55 if (++thread_count != n_threads) { in wait()
70 size_t n_threads; member in Barrier
/5.5.2/kv_engine/engines/ep/tests/
H A Dep_testsuite_checkpoint.cc200 const int n_threads = 2; in test_checkpoint_persistence() local
201 cb_thread_t threads[n_threads]; in test_checkpoint_persistence()
204 for (int i = 0; i < n_threads; ++i) { in test_checkpoint_persistence()
209 for (int i = 0; i < n_threads; ++i) { in test_checkpoint_persistence()
H A Dep_perfsuite.cc518 int n_threads, in perf_latency_baseline_multi_thread_bucket()
520 if (n_buckets > n_threads) { in perf_latency_baseline_multi_thread_bucket()
522 fprintf(stderr, "Returning FAIL because n_buckets(%d) > n_threads(%d)\n", in perf_latency_baseline_multi_thread_bucket()
523 n_buckets, n_threads); in perf_latency_baseline_multi_thread_bucket()
531 n_buckets, n_threads, num_docs); in perf_latency_baseline_multi_thread_bucket()
547 std::vector<ThreadArguments> thread_args(n_threads); in perf_latency_baseline_multi_thread_bucket()
548 std::vector<cb_thread_t> threads(n_threads); in perf_latency_baseline_multi_thread_bucket()
553 for (int ii = 0; ii < n_threads; ii++) { in perf_latency_baseline_multi_thread_bucket()
565 for (int i = 0; i < n_threads; i++) { in perf_latency_baseline_multi_thread_bucket()
570 for (int i = 0; i < n_threads; in perf_latency_baseline_multi_thread_bucket()
516 perf_latency_baseline_multi_thread_bucket(engine_test_t* test, int n_buckets, int n_threads, int num_docs) perf_latency_baseline_multi_thread_bucket() argument
606 title << n_buckets << "_buckets_" << n_threads << "_threads_baseline"; perf_latency_baseline_multi_thread_bucket() local
[all...]
H A Dep_testsuite_basic.cc299 const int n_threads = 8; in test_conc_set() local
300 cb_thread_t threads[n_threads]; in test_conc_set()
305 for (int i = 0; i < n_threads; i++) { in test_conc_set()
310 for (int i = 0; i < n_threads; i++) { in test_conc_set()
H A Dep_testsuite.cc1554 const int n_threads = 4; in test_multiple_vb_compactions() local
1555 cb_thread_t threads[n_threads]; in test_multiple_vb_compactions()
1556 struct comp_thread_ctx ctx[n_threads]; in test_multiple_vb_compactions()
1561 for (int i = 0; i < n_threads; i++) { in test_multiple_vb_compactions()
1570 for (int i = 0; i < n_threads; i++) { in test_multiple_vb_compactions()
1632 const int n_threads = 4; in test_multi_vb_compactions_with_workload() local
1633 cb_thread_t threads[n_threads]; in test_multi_vb_compactions_with_workload()
1634 struct comp_thread_ctx ctx[n_threads]; in test_multi_vb_compactions_with_workload()
1636 for (int i = 0; i < n_threads; i++) { in test_multi_vb_compactions_with_workload()
1644 for (int i = 0; i < n_threads; in test_multi_vb_compactions_with_workload()
[all...]

Completed in 49 milliseconds