| /external/ltp/testcases/kernel/io/direct_io/ |
| D | dma_thread_diotest.c | 134 static int workers; variable
231 workers = sysconf(_SC_NPROCESSORS_ONLN); in main()
232 if (workers > MAX_WORKERS) in main()
233 workers = MAX_WORKERS; in main()
260 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
270 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
277 worker[workers - 1].length = in dma_thread_diotest_verify()
278 READSIZE - PAGE_SIZE * (workers - 1); in dma_thread_diotest_verify()
288 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
298 for (j = 0; j < workers; j++) { in dma_thread_diotest_verify()
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 102 VPxWorker workers[kNumWorkers]; in TEST_P() local
107 vpx_get_worker_interface()->init(&workers[n]); in TEST_P()
109 workers[n].hook = ThreadHook; in TEST_P()
110 workers[n].data1 = &hook_data[n]; in TEST_P()
111 workers[n].data2 = &return_value[n]; in TEST_P()
116 EXPECT_NE(vpx_get_worker_interface()->reset(&workers[n]), 0); in TEST_P()
121 Run(&workers[n]); in TEST_P()
125 vpx_get_worker_interface()->end(&workers[n]); in TEST_P()
|
| /external/autotest/client/site_tests/power_HotCPUSuspend/ |
| D | power_HotCPUSuspend.py | 73 workers = max(16, cpus * 2)
74 pool = multiprocessing.Pool(workers)
78 logging.info('starting %d workers', workers)
79 results = [pool.apply_async(cpu_stress) for _ in xrange(workers)]
104 logging.info('killing %d workers', workers)
|
| /external/autotest/client/tests/stress/ |
| D | control | 22 -c, --cpu N spawn N workers spinning on sqrt()
23 -i, --io N spawn N workers spinning on sync()
24 -m, --vm N spawn N workers spinning on malloc()/free()
29 -d, --hdd N spawn N workers spinning on write()/unlink()
31 --hdd-noclean do not unlink files created by hdd workers
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/util/ |
| D | VersionInfoTest.java | 367 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
371 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
372 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
376 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
377 workers[i].start(); in TestMultiThread()
381 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
383 workers[i].join(); in TestMultiThread()
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/util/ |
| D | VersionInfoTest.java | 368 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
372 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
373 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
377 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
378 workers[i].start(); in TestMultiThread()
382 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
384 workers[i].join(); in TestMultiThread()
|
| /external/jemalloc/msvc/projects/vc2015/test_threads/ |
| D | test_threads.cpp | 31 vector<thread> workers; in test_threads() local
41 workers.emplace_back([tid=i]() { in test_threads()
76 for (thread& t : workers) { in test_threads()
|
| /external/boringssl/src/util/ |
| D | generate-coverage.sh | 39 go run "$SRC/util/all_tests.go" -build-dir "$BUILD" -callgrind -num-workers 16
45 go test -shim-path "$BUILD/ssl/test/bssl_shim" -num-workers 1
|
| /external/compiler-rt/lib/asan/tests/ |
| D | asan_mac_test.cc | 176 pthread_t workers[kNumWorkers], forker; in TEST() local
178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0); in TEST()
182 PTHREAD_JOIN(workers[i], 0); in TEST()
|
| /external/llvm/lib/Fuzzer/ |
| D | FuzzerDriver.cpp | 289 if (Flags.jobs > 0 && Flags.workers == 0) { in FuzzerDriver()
290 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs); in FuzzerDriver()
291 if (Flags.workers > 1) in FuzzerDriver()
292 Printf("Running %d workers\n", Flags.workers); in FuzzerDriver()
295 if (Flags.workers > 0 && Flags.jobs > 0) in FuzzerDriver()
296 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs); in FuzzerDriver()
|
| /external/libvpx/libvpx/vp9/encoder/ |
| D | vp9_ethread.c | 87 CHECK_MEM_ERROR(cm, cpi->workers, in create_enc_workers()
88 vpx_malloc(allocated_workers * sizeof(*cpi->workers))); in create_enc_workers()
94 VPxWorker *const worker = &cpi->workers[i]; in create_enc_workers()
137 VPxWorker *const worker = &cpi->workers[i]; in launch_enc_workers()
145 VPxWorker *const worker = &cpi->workers[i]; in launch_enc_workers()
159 VPxWorker *const worker = &cpi->workers[i]; in launch_enc_workers()
209 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
643 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_row_mt()
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
| D | stress2.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member
340 pthread_create(&(cd->workers[i]), &ta, worker, arg); in cellmanager()
387 ret = pthread_cancel(cd->workers[randval]); in cellmanager()
404 ret = pthread_join(cd->workers[i], &w_ret); in cellmanager()
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_wait/ |
| D | stress.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member
340 pthread_create(&(cd->workers[i]), &ta, worker, arg); in cellmanager()
387 ret = pthread_cancel(cd->workers[randval]); in cellmanager()
404 ret = pthread_join(cd->workers[i], &w_ret); in cellmanager()
|
| D | stress2.c | 191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member
340 pthread_create(&(cd->workers[i]), &ta, worker, arg); in cellmanager()
387 ret = pthread_cancel(cd->workers[randval]); in cellmanager()
404 ret = pthread_join(cd->workers[i], &w_ret); in cellmanager()
|
| /external/libvpx/libvpx/vp9/common/ |
| D | vp9_thread_common.c | 154 VPxWorker *workers, int nworkers, in loop_filter_rows_mt() argument
183 VPxWorker *const worker = &workers[i]; in loop_filter_rows_mt()
206 winterface->sync(&workers[i]); in loop_filter_rows_mt()
213 int partial_frame, VPxWorker *workers, in vp9_loop_filter_frame_mt() argument
230 workers, num_workers, lf_sync); in vp9_loop_filter_frame_mt()
|
| D | vp9_thread_common.h | 53 int partial_frame, VPxWorker *workers,
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | Invoker.java | 1095 List<TestMethodWithDataProviderMethodWorker> workers = Lists.newArrayList(); in invokeTestMethods() local
1109 workers.add(w); in invokeTestMethods()
1115 List<List<ITestResult>> r = ps.submitTasksAndWait(workers); in invokeTestMethods()
1313 List<IWorker<ITestNGMethod>> workers = Lists.newArrayList(); in invokePooledTestMethods() local
1323 workers.add(new SingleTestMethodWorker(this, in invokePooledTestMethods()
1331 return runWorkers(testMethod, workers, testMethod.getThreadPoolSize(), groupMethods, suite, in invokePooledTestMethods()
1427 List<IWorker<ITestNGMethod>> workers, in runWorkers() argument
1444 for(IWorker<ITestNGMethod> tmw : workers) { in runWorkers()
1451 ThreadUtil.execute(workers, threadPoolSize, maxTimeOut, true); in runWorkers()
1457 for (IWorker<ITestNGMethod> tmw : workers) { in runWorkers()
|
| /external/fio/examples/ |
| D | e4defrag.fio | 18 # Run e4defrag and aio-dio workers in parallel
|
| D | e4defrag2.fio | 50 # Run random e4defrag and various aio workers in parallel
|
| /external/autotest/server/cros/clique_lib/ |
| D | clique_runner.py | 161 def _are_all_conn_workers_healthy(workers, aps, assoc_params_list, job): argument
175 for worker, ap, assoc_params in zip(workers, aps, assoc_params_list):
|
| /external/webrtc/third_party/gtest-parallel/ |
| D | gtest-parallel | 391 workers = [start_daemon(worker) for i in range(options.workers)] variable
393 [t.join() for t in workers]
|
| /external/libpcap/ |
| D | README | 6 tcpdump-workers@lists.tcpdump.org
91 to the address "tcpdump-workers@lists.tcpdump.org". Bugs, support
|
| /external/boringssl/src/ |
| D | FUZZING.md | 26 ./fuzz/cert -max_len=10000 -jobs=32 -workers=32 ../fuzz/cert_corpus/
29 The arguments to `jobs` and `workers` should be the number of cores that you wish to dedicate to fu…
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/timezone/ |
| D | TimeZoneRegressionTest.java | 1198 Thread[] workers = new Thread[20]; in TestT7107() local
1199 for (int i = 0 ; i < workers.length; i++) { in TestT7107()
1200 workers[i] = new Thread(new Runnable() { in TestT7107()
1212 for (Thread wk : workers) { in TestT7107()
1215 for (Thread wk : workers) { in TestT7107()
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/timezone/ |
| D | TimeZoneRegressionTest.java | 1199 Thread[] workers = new Thread[20]; in TestT7107() local
1200 for (int i = 0 ; i < workers.length; i++) { in TestT7107()
1201 workers[i] = new Thread(new Runnable() { in TestT7107()
1213 for (Thread wk : workers) { in TestT7107()
1216 for (Thread wk : workers) { in TestT7107()
|