| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/controllers/ |
| layout_test_runner_unittest.py | 54 def print_workers_and_shards(self, num_workers, num_shards, num_locked_shards):
107 runner.run_tests(expectations, test_inputs, set(), num_workers=1, retrying=False)
179 def get_shards(self, num_workers, fully_parallel, run_singly, test_list=None, max_locked_shards=1):
184 num_workers, fully_parallel, run_singly)
195 locked, unlocked = self.get_shards(num_workers=2, fully_parallel=False, run_singly=False)
217 locked, unlocked = self.get_shards(num_workers=2, fully_parallel=True, max_locked_shards=2, run_singly=False)
236 locked, unlocked = self.get_shards(num_workers=1, fully_parallel=False, run_singly=False)
255 locked, unlocked = self.get_shards(num_workers=1, fully_parallel=False, run_singly=False,
261 locked, unlocked = self.get_shards(num_workers=1, fully_parallel=False, run_singly=False,
267 locked, unlocked = self.get_shards(num_workers=4, fully_parallel=False, max_locked_shards=2, run_singly=False
[all...] |
| layout_test_runner.py | 79 def run_tests(self, expectations, test_inputs, tests_to_skip, num_workers, retrying):
108 num_workers = min(num_workers, len(all_shards))
109 self._printer.print_workers_and_shards(num_workers, len(all_shards), len(locked_shards))
114 self._printer.write_update('Starting %s ...' % grammar.pluralize('worker', num_workers))
118 with message_pool.get(self, self._worker_factory, num_workers, self._port.host) as pool:
122 num_workers -= len(self._shards_to_redo)
123 if num_workers > 0:
124 with message_pool.get(self, self._worker_factory, num_workers, self._port.host) as pool:
365 def shard_tests(self, test_inputs, num_workers, fully_parallel, run_singly)
[all...] |
| manager.py | 221 self._port.num_workers(int(self._options.child_processes)), retrying=False)
234 num_workers=1, retrying=True)
277 def _run_tests(self, tests_to_run, tests_to_skip, repeat_each, iterations, num_workers, retrying):
284 return self._runner.run_tests(self._expectations, test_inputs, tests_to_skip, num_workers, retrying)
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/test/ |
| runner.py | 50 def run(self, test_names, num_workers):
53 num_workers = min(num_workers, len(test_names))
54 with message_pool.get(self, self.worker_factory, num_workers) as pool:
|
| /external/chromium_org/v8/tools/testrunner/local/ |
| pool.py | 54 def __init__(self, num_workers):
55 self.num_workers = num_workers
79 for w in xrange(self.num_workers):
104 while self.count < self.num_workers * self.BUFFER_FACTOR:
|
| /external/chromium_org/third_party/libvpx/source/libvpx/vp9/decoder/ |
| vp9_dthread.c | 144 const int num_workers = MIN(pbi->max_threads & ~1, tile_cols); local
171 // The decoder is using num_workers instead of pbi->num_tile_workers
180 for (i = 0; i < num_workers; ++i) {
196 lf_data->num_lf_workers = num_workers;
199 if (i == num_workers - 1) {
207 for (i = 0; i < num_workers; ++i) {
|
| vp9_decodeframe.c | 899 const int num_workers = MIN(pbi->max_threads & ~1, tile_cols); local
933 for (n = 0; n < num_workers; ++n) {
[all...] |
| /external/libvpx/libvpx/vp9/decoder/ |
| vp9_dthread.c | 143 const int num_workers = MIN(pbi->oxcf.max_threads & ~1, tile_cols); local
173 // The decoder is using num_workers instead of pbi->num_tile_workers
182 for (i = 0; i < num_workers; ++i) {
198 lf_data->num_lf_workers = num_workers;
201 if (i == num_workers - 1) {
209 for (i = 0; i < num_workers; ++i) {
|
| vp9_decodeframe.c | 876 const int num_workers = MIN(pbi->oxcf.max_threads & ~1, tile_cols); local
910 for (n = 0; n < num_workers; ++n) {
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/ |
| message_pool.py | 59 def get(caller, worker_factory, num_workers, host=None):
61 return _MessagePool(caller, worker_factory, num_workers, host)
65 def __init__(self, caller, worker_factory, num_workers, host=None):
68 self._num_workers = num_workers
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/views/ |
| printing.py | 115 def print_workers_and_shards(self, num_workers, num_shards, num_locked_shards):
117 if num_workers == 1:
121 self._print_default("Running %d %ss in parallel." % (num_workers, driver_name))
156 def _print_worker_statistics(self, run_results, num_workers):
168 self._print_debug(" %6.2f cumulative, %6.2f optimal" % (cuml_time, cuml_time / num_workers))
|
| /hardware/intel/common/omx-components/videocodec/libvpx_internal/libvpx/vp9/decoder/ |
| vp9_decodeframe.c | 878 const int num_workers = MIN(pbi->oxcf.max_threads & ~1, tile_cols); local
887 if (num_workers > pbi->num_tile_workers) {
891 num_workers * sizeof(*pbi->tile_workers)));
892 for (i = pbi->num_tile_workers; i < num_workers; ++i) {
900 if (i < num_workers - 1 && !vp9_worker_reset(worker)) {
941 const int group_end = MIN(group_start + num_workers, tile_cols) - 1;
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/port/ |
| android.py | 555 num_workers = self.default_child_processes()
558 num_workers = min(num_workers, num_child_processes)
559 if num_workers > 1:
560 pool = ThreadPool(num_workers)
562 pool.map(setup_device, range(num_workers))
585 def num_workers(self, requested_num_workers): member in class:AndroidPort
[all...] |
| base.py | 1004 def num_workers(self, requested_num_workers): member in class:Port
[all...] |
