| /external/ot-br-posix/tests/rest/ |
| D | test_rest.py | 59 def create_multi_thread(func, url, thread_num, response_data): argument
60 threads = [None] * thread_num
62 for i in range(thread_num):
299 def node_test(thread_num): argument
302 response_data = [None] * thread_num
304 create_multi_thread(get_data_from_url, url, thread_num, response_data)
308 print(" /node : all {}, valid {} ".format(thread_num, valid))
311 def node_rloc_test(thread_num): argument
314 response_data = [None] * thread_num
316 create_multi_thread(get_data_from_url, url, thread_num, response_data)
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/tm/ |
| D | tm-tmspr.c | 95 int thread_num; in test_tmspr() local
102 thread_num = 10 * sysconf(_SC_NPROCESSORS_ONLN); in test_tmspr()
104 thread = malloc(thread_num * sizeof(pthread_t)); in test_tmspr()
109 for (i = 0; i < thread_num; i += 2) { in test_tmspr()
115 for (i = 1; i < thread_num; i += 2) { in test_tmspr()
120 for (i = 0; i < thread_num; i++) { in test_tmspr()
|
| /external/rust/crates/jni/tests/ |
| D | jni_global_refs.rs | 39 for thread_num in 2..9 { in global_ref_works_in_other_threads()
40 let barrier = Arc::new(Barrier::new(thread_num)); in global_ref_works_in_other_threads()
42 for _ in 0..thread_num { in global_ref_works_in_other_threads()
67 let expected = (ITERS_PER_THREAD * thread_num) as jint; in global_ref_works_in_other_threads()
|
| D | executor.rs | 52 fn test_concurrent_threads(executor: Executor, thread_num: usize) { in test_concurrent_threads()
56 let barrier = Arc::new(Barrier::new(thread_num)); in test_concurrent_threads()
59 for _ in 0..thread_num { in test_concurrent_threads()
73 let expected = (ITERS_PER_THREAD * thread_num) as jint; in test_concurrent_threads()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_barrier_wait/ |
| D | 2-1.c | 45 int thread_num = *(int *)arg; in fn_chld() local
47 printf("child[%d]: barrier wait\n", thread_num); in fn_chld()
52 "return code : %d\n", thread_num, rc); in fn_chld()
57 thread_num); in fn_chld()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | interarrival.h | 93 int64_t next(int thread_num) { in next() argument
94 auto ret = *(thread_posns_[thread_num]++); in next()
95 if (thread_posns_[thread_num] == random_table_.end()) in next()
96 thread_posns_[thread_num] = random_table_.begin(); in next()
|
| /external/cronet/net/base/ |
| D | network_activity_monitor_unittest.cc | 52 size_t thread_num = i % threads.size(); in TEST_F() local
53 threads[thread_num]->task_runner()->PostTask( in TEST_F()
56 threads[thread_num]->task_runner()->PostTask( in TEST_F()
|
| /external/perfetto/src/base/ |
| D | watchdog_unittest.cc | 147 auto thread_fn = [&mutex, &cv, &quit, &expected_tid](size_t thread_num) { in TEST() argument
148 if (thread_num == kKillThreadNum) { in TEST()
|
| /external/tensorflow/tensorflow/core/data/ |
| D | dataset_test_base.cc | 376 Status DatasetOpsTestBase::InitThreadPool(int thread_num) { in InitThreadPool() argument
377 if (thread_num < 1) { in InitThreadPool()
379 "The `thread_num` argument should be positive but got: ", thread_num); in InitThreadPool()
382 Env::Default(), ThreadOptions(), "test_thread_pool", thread_num); in InitThreadPool()
|
| D | dataset_test_base.h | 696 Status InitThreadPool(int thread_num);
|
| /external/google-breakpad/src/processor/ |
| D | stackwalk_common.cc | 624 static void PrintStackMachineReadable(int thread_num, const CallStack *stack) { in PrintStackMachineReadable() argument
628 printf("%d%c%d%c", thread_num, kOutputSeparator, frame_index, in PrintStackMachineReadable()
|
| /external/stressapptest/src/ |
| D | worker.cc | 2461 int thread_num, in CpuCacheCoherencyThread() argument
2466 cc_thread_num_ = thread_num; in CpuCacheCoherencyThread()
|