Home
last modified time | relevance | path

Searched refs:num_workers (Results 1 – 11 of 11) sorted by relevance

/external/libvpx/libvpx/vp9/encoder/
Dvp9_ethread.c45 t += cpi->num_workers) { in enc_worker_hook()
71 const int num_workers = VPXMIN(cpi->oxcf.max_threads, tile_cols); in vp9_encode_tiles_mt() local
77 if (cpi->num_workers == 0) { in vp9_encode_tiles_mt()
78 int allocated_workers = num_workers; in vp9_encode_tiles_mt()
98 ++cpi->num_workers; in vp9_encode_tiles_mt()
132 for (i = 0; i < num_workers; i++) { in vp9_encode_tiles_mt()
170 for (i = 0; i < num_workers; i++) { in vp9_encode_tiles_mt()
177 if (i == cpi->num_workers - 1) in vp9_encode_tiles_mt()
184 for (i = 0; i < num_workers; i++) { in vp9_encode_tiles_mt()
189 for (i = 0; i < num_workers; i++) { in vp9_encode_tiles_mt()
[all …]
Dvp9_picklpf.c45 if (cpi->num_workers > 1) in try_filter_frame()
48 cpi->workers, cpi->num_workers, &cpi->lf_row_sync); in try_filter_frame()
Dvp9_encoder.h502 int num_workers; member
Dvp9_encoder.c2037 for (t = 0; t < cpi->num_workers; ++t) { in vp9_remove_compressor()
2045 if (t < cpi->num_workers - 1) { in vp9_remove_compressor()
2054 if (cpi->num_workers > 1) in vp9_remove_compressor()
2787 if (cpi->num_workers > 1)
2790 cpi->workers, cpi->num_workers,
/external/autotest/client/virt/
Dvirt_scheduler.py11 def __init__(self, tests, num_workers, total_cpus, total_mem, bindir): argument
22 self.num_workers = num_workers
27 self.s2w = [os.pipe() for i in range(num_workers)]
28 self.w2s = [os.pipe() for i in range(num_workers)]
36 self.worker_dicts = [{"env": "env%d" % i} for i in range(num_workers)]
102 used_cpus = [0] * self.num_workers
103 used_mem = [0] * self.num_workers
226 if len(idle_workers) == self.num_workers:
/external/libvpx/libvpx/vp9/common/
Dvp9_thread_common.c110 mi_row += lf_sync->num_workers * MI_BLOCK_SIZE) { in thread_loop_filter_rows()
167 const int num_workers = VPXMIN(nworkers, tile_cols); in loop_filter_rows_mt() local
171 num_workers > lf_sync->num_workers) { in loop_filter_rows_mt()
173 vp9_loop_filter_alloc(lf_sync, cm, sb_rows, cm->width, num_workers); in loop_filter_rows_mt()
187 for (i = 0; i < num_workers; ++i) { in loop_filter_rows_mt()
202 if (i == num_workers - 1) { in loop_filter_rows_mt()
210 for (i = 0; i < num_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()
256 int width, int num_workers) { in vp9_loop_filter_alloc() argument
[all …]
Dvp9_thread_common.h39 int num_workers; member
44 int width, int num_workers);
55 VPxWorker *workers, int num_workers,
/external/v8/tools/testrunner/local/
Dpool.py76 def __init__(self, num_workers, heartbeat_timeout=30): argument
77 self.num_workers = num_workers
115 for w in xrange(self.num_workers):
149 while self.count < self.num_workers * self.BUFFER_FACTOR:
/external/pdfium/testing/tools/
Drun_corpus_tests.py132 if options.num_workers > 1 and len(test_cases) > 1:
134 pool = multiprocessing.Pool(options.num_workers)
/external/autotest/client/tests/kvm/
Dcontrol.parallel187 num_workers = total_cpus
190 s = virt_scheduler.scheduler(tests, num_workers, total_cpus, total_mem, pwd)
192 *[(s.worker, i, job.run_test) for i in range(num_workers)])
/external/libvpx/libvpx/vp9/decoder/
Dvp9_decodeframe.c1637 const int num_workers = VPXMIN(pbi->max_threads, tile_cols); in decode_tiles_mt() local
1667 for (n = 0; n < num_workers; ++n) { in decode_tiles_mt()
1696 if (num_workers == tile_cols) { in decode_tiles_mt()
1722 for (n = 0; n < num_workers; ++n) { in decode_tiles_mt()
1730 const int base = tile_cols / num_workers; in decode_tiles_mt()
1731 const int remain = tile_cols % num_workers; in decode_tiles_mt()
1734 for (n = 0; n < num_workers; ++n) { in decode_tiles_mt()
1735 const int count = base + (remain + n) / num_workers; in decode_tiles_mt()
1745 if (n == num_workers - 1) { in decode_tiles_mt()
1767 for (n = 0; n < num_workers; ++n) { in decode_tiles_mt()