OLD | NEW |
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 2 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
5 | 5 |
6 """Runs the whole set unit tests on swarm.""" | 6 """Runs the whole set unit tests on swarm.""" |
7 | 7 |
8 import datetime | 8 import datetime |
9 import glob | 9 import glob |
10 import getpass | 10 import getpass |
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
133 self.progress.update_item( | 133 self.progress.update_item( |
134 'Failed %s:\n%s' % (step_name, stdout), index=1) | 134 'Failed %s:\n%s' % (step_name, stdout), index=1) |
135 return (test_name, platform, stdout) | 135 return (test_name, platform, stdout) |
136 self.progress.update_item('Passed %s' % step_name, index=1) | 136 self.progress.update_item('Passed %s' % step_name, index=1) |
137 return None | 137 return None |
138 | 138 |
139 | 139 |
140 def run_swarm_tests_on_swarm(oses, tests, logs, isolate_server, swarm_server): | 140 def run_swarm_tests_on_swarm(oses, tests, logs, isolate_server, swarm_server): |
141 runs = len(tests) * len(oses) | 141 runs = len(tests) * len(oses) |
142 total = 3 * runs | 142 total = 3 * runs |
143 progress = threading_utils.Progress(total) | 143 columns = [('index', 0), ('size', total)] |
| 144 progress = threading_utils.Progress(columns) |
144 progress.use_cr_only = False | 145 progress.use_cr_only = False |
145 tempdir = tempfile.mkdtemp(prefix='swarm_client_tests') | 146 tempdir = tempfile.mkdtemp(prefix='swarm_client_tests') |
146 try: | 147 try: |
147 with threading_utils.ThreadPoolWithProgress( | 148 with threading_utils.ThreadPoolWithProgress( |
148 progress, runs, runs, total) as pool: | 149 progress, runs, runs, total) as pool: |
149 start = time.time() | 150 start = time.time() |
150 runner = Runner( | 151 runner = Runner( |
151 isolate_server, swarm_server, pool.add_task, progress, tempdir) | 152 isolate_server, swarm_server, pool.add_task, progress, tempdir) |
152 for test in tests: | 153 for test in tests: |
153 for platform in oses: | 154 for platform in oses: |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
239 return run_swarm_tests_on_swarm( | 240 return run_swarm_tests_on_swarm( |
240 oses, | 241 oses, |
241 tests, | 242 tests, |
242 options.logs, | 243 options.logs, |
243 options.isolate_server, | 244 options.isolate_server, |
244 options.swarming) | 245 options.swarming) |
245 | 246 |
246 | 247 |
247 if __name__ == '__main__': | 248 if __name__ == '__main__': |
248 sys.exit(main()) | 249 sys.exit(main()) |
OLD | NEW |