Searched defs:workers (Results 1 - 18 of 18) sorted by relevance

/external/jemalloc/msvc/projects/vc2015/test_threads/
H A Dtest_threads.cpp31 vector<thread> workers; local
41 workers.emplace_back([tid=i]() {
76 for (thread& t : workers) {
/external/compiler-rt/lib/asan/tests/
H A Dasan_mac_test.cc176 pthread_t workers[kNumWorkers], forker; local
178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0);
182 PTHREAD_JOIN(workers[i], 0);
/external/libvpx/libvpx/test/
H A Dvp9_thread_test.cc102 VPxWorker workers[kNumWorkers]; local
107 vpx_get_worker_interface()->init(&workers[n]);
109 workers[n].hook = ThreadHook;
110 workers[n].data1 = &hook_data[n];
111 workers[n].data2 = &return_value[n];
116 EXPECT_NE(vpx_get_worker_interface()->reset(&workers[n]), 0);
121 Run(&workers[n]);
125 vpx_get_worker_interface()->end(&workers[n]);
197 // Note any worker that requires synchronization between other workers will
/external/libvpx/libvpx/vp9/common/
H A Dvp9_thread_common.c154 VPxWorker *workers, int nworkers,
178 // workers on cores equal to the number of tile columns. Then if the decoder
181 // then the number of workers used by the loopfilter should be revisited.
183 VPxWorker *const worker = &workers[i];
206 winterface->sync(&workers[i]);
213 int partial_frame, VPxWorker *workers,
230 workers, num_workers, lf_sync);
151 loop_filter_rows_mt(YV12_BUFFER_CONFIG *frame, VP9_COMMON *cm, struct macroblockd_plane planes[MAX_MB_PLANE], int start, int stop, int y_only, VPxWorker *workers, int nworkers, VP9LfSync *lf_sync) argument
210 vp9_loop_filter_frame_mt(YV12_BUFFER_CONFIG *frame, VP9_COMMON *cm, struct macroblockd_plane planes[MAX_MB_PLANE], int frame_filter_level, int y_only, int partial_frame, VPxWorker *workers, int num_workers, VP9LfSync *lf_sync) argument
/external/ltp/testcases/kernel/io/direct_io/
H A Ddma_thread_diotest.c134 static int workers; variable
231 workers = sysconf(_SC_NPROCESSORS_ONLN);
232 if (workers > MAX_WORKERS)
233 workers = MAX_WORKERS;
260 for (j = 0; j < workers; j++) {
270 for (j = 0; j < workers; j++) {
277 worker[workers - 1].length =
278 READSIZE - PAGE_SIZE * (workers - 1);
288 for (j = 0; j < workers; j++) {
298 for (j = 0; j < workers;
[all...]
/external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/
H A Dstress2.c191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata
337 /* create the workers */
340 pthread_create(&(cd->workers[i]), &ta, worker, arg);
356 /* wait for the workers to be ready */
387 ret = pthread_cancel(cd->workers[randval]);
404 ret = pthread_join(cd->workers[i], &w_ret);
/external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_wait/
H A Dstress.c191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata
337 /* create the workers */
340 pthread_create(&(cd->workers[i]), &ta, worker, arg);
356 /* wait for the workers to be ready */
387 ret = pthread_cancel(cd->workers[randval]);
404 ret = pthread_join(cd->workers[i], &w_ret);
H A Dstress2.c191 pthread_t workers[NCHILDREN * SCALABILITY_FACTOR + 2]; member in struct:celldata
337 /* create the workers */
340 pthread_create(&(cd->workers[i]), &ta, worker, arg);
356 /* wait for the workers to be ready */
387 ret = pthread_cancel(cd->workers[randval]);
404 ret = pthread_join(cd->workers[i], &w_ret);
/external/testng/src/main/java/org/testng/internal/
H A DInvoker.java1095 List<TestMethodWithDataProviderMethodWorker> workers = Lists.newArrayList();
1109 workers.add(w);
1115 List<List<ITestResult>> r = ps.submitTasksAndWait(workers);
1311 // Create the workers
1313 List<IWorker<ITestNGMethod>> workers = Lists.newArrayList();
1323 workers.add(new SingleTestMethodWorker(this,
1331 return runWorkers(testMethod, workers, testMethod.getThreadPoolSize(), groupMethods, suite,
1427 List<IWorker<ITestNGMethod>> workers,
1444 for(IWorker<ITestNGMethod> tmw : workers) {
1451 ThreadUtil.execute(workers, threadPoolSiz
1426 runWorkers(ITestNGMethod testMethod, List<IWorker<ITestNGMethod>> workers, int threadPoolSize, ConfigurationGroupMethods groupMethods, XmlSuite suite, Map<String, String> parameters) argument
[all...]
/external/testng/src/main/java/org/testng/
H A DTestRunner.java669 List<IWorker<ITestNGMethod>> workers = Lists.newArrayList();
674 workers.add(new IWorker<ITestNGMethod>() {
728 runJUnitWorkers(workers);
820 * Create a list of workers to run the methods passed in parameter.
839 * Create workers for parallel="classes" and similar cases.
900 * Create workers for parallel="instances".
994 // Invoke the workers
999 private void runJUnitWorkers(List<? extends IWorker<ITestNGMethod>> workers) { argument
1003 for (IWorker<ITestNGMethod> tmw : workers) {
/external/libvpx/libvpx/vp9/encoder/
H A Dvp9_encoder.h681 VPxWorker *workers; member in struct:VP9_COMP
/external/caliper/lib/
H A Djersey-client-1.11.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...
/external/robolectric/v3/runtime/
H A Dandroid-all-4.2.2_r1.2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.3_r2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.1.2_r1-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.4_r1-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...
H A Dandroid-all-5.0.0_r2-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...
H A Dandroid-all-5.1.1_r9-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...

Completed in 3478 milliseconds