| /external/chromium_org/v8/tools/testrunner/local/ |
| H A D | 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/WebKit/Tools/Scripts/webkitpy/layout_tests/controllers/ |
| H A D | 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
[all...] |
| H A D | 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_paralle
[all...] |
| H A D | manager.py | 257 self._port.num_workers(int(self._options.child_processes)), retrying=False)
270 num_workers=1, retrying=True)
321 def _run_tests(self, tests_to_run, tests_to_skip, repeat_each, iterations, num_workers, retrying):
328 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/ |
| H A D | 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/third_party/libvpx/source/libvpx/vp9/decoder/ |
| H A D | vp9_dthread.c | 145 const int num_workers = MIN(pbi->max_threads & ~1, tile_cols); local
161 // The decoder is using num_workers instead of pbi->num_tile_workers
170 for (i = 0; i < num_workers; ++i) {
186 lf_data->num_lf_workers = num_workers;
189 if (i == num_workers - 1) {
197 for (i = 0; i < num_workers; ++i) {
|
| H A D | vp9_decodeframe.c | 1004 const int num_workers = MIN(pbi->max_threads & ~1, tile_cols); local
1038 for (n = 0; n < num_workers; ++n) {
1065 const int group_end = MIN(group_start + num_workers, tile_cols) - 1;
1076 for (i = 0; i < num_workers && n < tile_cols; ++i) {
1093 if (i == num_workers - 1 || n == tile_cols - 1) {
|
| /external/libvpx/libvpx/vp9/decoder/ |
| H A D | 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) {
|
| H A D | 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) {
943 const int group_end = MIN(group_start + num_workers, tile_cols) - 1;
954 for (i = 0; i < num_workers && n < tile_cols; ++i) {
970 if (i == num_workers - 1 || n == tile_cols - 1) {
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/ |
| H A D | 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/ |
| H A D | printing.py | 116 def print_workers_and_shards(self, num_workers, num_shards, num_locked_shards):
118 if num_workers == 1:
122 self._print_default("Running %d %ss in parallel." % (num_workers, driver_name))
157 def _print_worker_statistics(self, run_results, num_workers):
169 self._print_debug(" %6.2f cumulative, %6.2f optimal" % (cuml_time, cuml_time / num_workers))
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/port/ |
| H A D | android.py | 557 num_workers = self.default_child_processes()
560 num_workers = min(num_workers, num_child_processes)
561 if num_workers > 1:
562 pool = ThreadPool(num_workers)
564 pool.map(setup_device, range(num_workers))
587 def num_workers(self, requested_num_workers): member in class:AndroidPort
|
| H A D | base.py | 1027 def num_workers(self, requested_num_workers): member in class:Port
|