| /external/v8/test/mjsunit/harmony/ |
| D | futex.js | 183 var workers = [];
185 workers[id] = new Worker(workerScript);
186 workers[id].postMessage({sab: sab, id: id}, [sab]);
202 assertEquals(Atomics.OK, workers[id].getMessage());
203 workers[id].terminate();
216 assertEquals(Atomics.OK, workers[waitingId].getMessage());
217 workers[waitingId].terminate();
250 var workers = [];
252 workers[id] = new Worker(workerScript);
253 workers[id].postMessage({sab: sab, id: id}, [sab]);
[all …]
|
| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/x509/ |
| D | PolicyQualifierInfoTest.java | 152 Thread[] workers = new Thread[workersNumber]; in testMtByteArray() local
154 workers[i] = new TestWorker1(i); in testMtByteArray()
157 workers[i].start(); in testMtByteArray()
160 workers[i].join(); in testMtByteArray()
171 Thread[] workers = new Thread[workersNumber]; in testMtInputStream() local
173 workers[i] = new TestWorker2(i); in testMtInputStream()
176 workers[i].start(); in testMtInputStream()
179 workers[i].join(); in testMtInputStream()
|
| /external/v8/test/mjsunit/ |
| D | d8-worker-sharedarraybuffer.js | 86 var workers = [];
88 workers[id] = new Worker(workerScript);
89 workers[id].postMessage({sab: sab, id: id}, [sab]);
98 assertEquals(id, workers[id].getMessage());
99 workers[id].terminate();
|
| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 106 VPxWorker workers[kNumWorkers]; in TEST_P() local
111 vpx_get_worker_interface()->init(&workers[n]); in TEST_P()
113 workers[n].hook = ThreadHook; in TEST_P()
114 workers[n].data1 = &hook_data[n]; in TEST_P()
115 workers[n].data2 = &return_value[n]; in TEST_P()
120 EXPECT_NE(vpx_get_worker_interface()->reset(&workers[n]), 0); in TEST_P()
125 Run(&workers[n]); in TEST_P()
129 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/libvpx/libvpx/vp9/encoder/ |
| D | vp9_ethread.c | 87 CHECK_MEM_ERROR(cm, cpi->workers, in vp9_encode_tiles_mt()
88 vpx_malloc(allocated_workers * sizeof(*cpi->workers))); in vp9_encode_tiles_mt()
95 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
133 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
171 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
185 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
190 VPxWorker *const worker = &cpi->workers[i]; in vp9_encode_tiles_mt()
|
| /external/chromium-trace/catapult/third_party/typ/typ/ |
| D | pool.py | 65 self.workers = []
76 self.workers.append(w)
91 for _ in self.workers:
111 for w in self.workers:
119 for w in self.workers:
133 for w in self.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 | 353 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
357 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
358 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
362 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
363 workers[i].start(); in TestMultiThread()
367 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
369 workers[i].join(); in TestMultiThread()
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/util/ |
| D | VersionInfoTest.java | 357 GetInstanceWorker[] workers = new GetInstanceWorker[numThreads]; in TestMultiThread() local
361 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
362 workers[i] = new GetInstanceWorker(i, results[i]); in TestMultiThread()
366 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
367 workers[i].start(); in TestMultiThread()
371 for (int i = 0; i < workers.length; i++) { in TestMultiThread()
373 workers[i].join(); in TestMultiThread()
|
| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/asn1/der/ |
| D | DerUTCTimeEDTest.java | 124 Thread[] workers = new Thread[workersNumber]; in testMt() local
126 workers[i] = new TestWorker(); in testMt()
129 workers[i].start(); in testMt()
132 workers[i].join(); in testMt()
|
| /external/chromium-trace/catapult/third_party/Paste/paste/debug/ |
| D | watchthreads.py | 209 workers = thread_pool.worker_tracker.items()
210 workers.sort(key=lambda v: v[1][0])
212 for thread_id, (time_started, worker_environ) in workers:
228 actual_workers=len(thread_pool.workers),
229 nworkers_used=len(workers),
|
| /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/llvm/lib/Fuzzer/ |
| D | FuzzerDriver.cpp | 237 if (Flags.jobs > 0 && Flags.workers == 0) { in FuzzerDriver()
238 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs); in FuzzerDriver()
239 if (Flags.workers > 1) in FuzzerDriver()
240 Printf("Running %d workers\n", Flags.workers); in FuzzerDriver()
243 if (Flags.workers > 0 && Flags.jobs > 0) in FuzzerDriver()
244 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs); in FuzzerDriver()
|
| /external/chromium-trace/catapult/third_party/Paste/paste/ |
| D | httpserver.py | 597 self.workers = []
655 for worker in self.workers:
675 if (len(self.workers) > self.nworkers
682 len(self.workers)-self.nworkers, len(self.idle_workers))
685 for i in range(len(self.workers) - self.nworkers):
696 for worker in self.workers:
743 if thread_obj in self.workers:
744 self.workers.remove(thread_obj)
776 for worker in self.workers:
870 self.workers.append(thread_obj)
[all …]
|
| /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/chromium-trace/catapult/third_party/gsutil/third_party/boto/bin/ |
| D | mturk | 327 def notify_workers(subject, text, workers): argument
328 con.notify_workers(workers, subject, text)
330 def give_qualification(qualification, workers, value = 1, notify = True): argument
331 for w in workers:
335 def revoke_qualification(qualification, workers, message = None): argument
336 for w in workers:
|
| /external/skia/site/dev/testing/ |
| D | ct.md | 82 …workers using the master scripts [here](https://skia.googlesource.com/buildbot/+/master/ct/go/mast…
84 4. The workers execute the task using the worker scripts [here](https://skia.googlesource.com/build…
86 … master scripts periodically check the workers to see when they are done with the requested task. …
|
| /external/libvpx/libvpx/vp9/common/ |
| D | vp9_thread_common.c | 159 VPxWorker *workers, int nworkers, in loop_filter_rows_mt() argument
188 VPxWorker *const worker = &workers[i]; in loop_filter_rows_mt()
211 winterface->sync(&workers[i]); in loop_filter_rows_mt()
220 VPxWorker *workers, int num_workers, in vp9_loop_filter_frame_mt() argument
237 y_only, workers, num_workers, lf_sync); in vp9_loop_filter_frame_mt()
|
| D | vp9_thread_common.h | 55 VPxWorker *workers, int num_workers,
|
| /external/chromium-trace/catapult/third_party/Paste/docs/modules/ |
| D | debug.watchthreads.txt | 1 :mod:`paste.debug.watchthreads` -- watch thread workers in paste.httpserver
|
| /external/boringssl/src/ |
| D | FUZZING.md | 26 ./fuzz/cert -max_len=4000 -jobs=32 -workers=32 ../fuzz/cert_corpus/
29 …cient for the formats that we wish to fuzz. The arguments to `jobs` and `workers` should be the nu…
|
| /external/v8/test/mjsunit/regress/ |
| D | regress-441099.js | 33 }},moduleContextCreatedCallbacks:[],workers:[],init:function () { property
|
| /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
|