| OLD | NEW |
| 1 # Copyright (C) 2010 Google Inc. All rights reserved. | 1 # Copyright (C) 2010 Google Inc. All rights reserved. |
| 2 # Copyright (C) 2010 Gabor Rapcsanyi (rgabor@inf.u-szeged.hu), University of Sze
ged | 2 # Copyright (C) 2010 Gabor Rapcsanyi (rgabor@inf.u-szeged.hu), University of Sze
ged |
| 3 # | 3 # |
| 4 # Redistribution and use in source and binary forms, with or without | 4 # Redistribution and use in source and binary forms, with or without |
| 5 # modification, are permitted provided that the following conditions are | 5 # modification, are permitted provided that the following conditions are |
| 6 # met: | 6 # met: |
| 7 # | 7 # |
| 8 # * Redistributions of source code must retain the above copyright | 8 # * Redistributions of source code must retain the above copyright |
| 9 # notice, this list of conditions and the following disclaimer. | 9 # notice, this list of conditions and the following disclaimer. |
| 10 # * Redistributions in binary form must reproduce the above | 10 # * Redistributions in binary form must reproduce the above |
| (...skipping 212 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 223 return ( | 223 return ( |
| 224 test.startswith(self.HTTP_SUBDIR) or | 224 test.startswith(self.HTTP_SUBDIR) or |
| 225 self._is_websocket_test(test) or | 225 self._is_websocket_test(test) or |
| 226 self._port.TEST_PATH_SEPARATOR + self.HTTP_SUBDIR in test | 226 self._port.TEST_PATH_SEPARATOR + self.HTTP_SUBDIR in test |
| 227 ) | 227 ) |
| 228 | 228 |
| 229 def _is_inspector_test(self, test): | 229 def _is_inspector_test(self, test): |
| 230 return self.INSPECTOR_SUBDIR in test | 230 return self.INSPECTOR_SUBDIR in test |
| 231 | 231 |
| 232 def _is_websocket_test(self, test): | 232 def _is_websocket_test(self, test): |
| 233 if self._port.is_wpt_enabled() and self._port.is_wpt_test(test): | 233 if self._port.should_use_wptserve(test): |
| 234 return False | 234 return False |
| 235 | 235 |
| 236 return self.WEBSOCKET_SUBDIR in test | 236 return self.WEBSOCKET_SUBDIR in test |
| 237 | 237 |
| 238 def _http_tests(self, test_names): | 238 def _http_tests(self, test_names): |
| 239 return set(test for test in test_names if self._is_http_test(test)) | 239 return set(test for test in test_names if self._is_http_test(test)) |
| 240 | 240 |
| 241 def _is_perf_test(self, test): | 241 def _is_perf_test(self, test): |
| 242 return self.PERF_SUBDIR == test or (self.PERF_SUBDIR + self._port.TEST_P
ATH_SEPARATOR) in test | 242 return self.PERF_SUBDIR == test or (self.PERF_SUBDIR + self._port.TEST_P
ATH_SEPARATOR) in test |
| 243 | 243 |
| (...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 362 | 362 |
| 363 test_inputs = [] | 363 test_inputs = [] |
| 364 for _ in xrange(iterations): | 364 for _ in xrange(iterations): |
| 365 for test in tests_to_run: | 365 for test in tests_to_run: |
| 366 for _ in xrange(repeat_each): | 366 for _ in xrange(repeat_each): |
| 367 test_inputs.append(self._test_input_for_file(test)) | 367 test_inputs.append(self._test_input_for_file(test)) |
| 368 return self._runner.run_tests(self._expectations, test_inputs, | 368 return self._runner.run_tests(self._expectations, test_inputs, |
| 369 tests_to_skip, num_workers, retry_attempt) | 369 tests_to_skip, num_workers, retry_attempt) |
| 370 | 370 |
| 371 def _start_servers(self, tests_to_run): | 371 def _start_servers(self, tests_to_run): |
| 372 if self._port.is_wpt_enabled() and any(self._port.is_wpt_test(test) for
test in tests_to_run): | 372 if self._port.is_wptserve_enabled() and any(self._port.is_wptserve_test(
test) for test in tests_to_run): |
| 373 self._printer.write_update('Starting WPTServe ...') | 373 self._printer.write_update('Starting WPTServe ...') |
| 374 self._port.start_wptserve() | 374 self._port.start_wptserve() |
| 375 self._wptserve_started = True | 375 self._wptserve_started = True |
| 376 | 376 |
| 377 if self._port.requires_http_server() or any((self._is_http_test(test) or
self._is_inspector_test(test)) | 377 if self._port.requires_http_server() or any((self._is_http_test(test) or
self._is_inspector_test(test)) |
| 378 for test in tests_to_run): | 378 for test in tests_to_run): |
| 379 self._printer.write_update('Starting HTTP server ...') | 379 self._printer.write_update('Starting HTTP server ...') |
| 380 self._port.start_http_server(additional_dirs={}, number_of_drivers=s
elf._options.max_locked_shards) | 380 self._port.start_http_server(additional_dirs={}, number_of_drivers=s
elf._options.max_locked_shards) |
| 381 self._http_server_started = True | 381 self._http_server_started = True |
| 382 | 382 |
| (...skipping 170 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 553 | 553 |
| 554 stats = {} | 554 stats = {} |
| 555 for result in initial_results.results_by_name.values(): | 555 for result in initial_results.results_by_name.values(): |
| 556 if result.type != test_expectations.SKIP: | 556 if result.type != test_expectations.SKIP: |
| 557 stats[result.test_name] = {'results': (_worker_number(result.wor
ker_name), result.test_number, result.pid, int( | 557 stats[result.test_name] = {'results': (_worker_number(result.wor
ker_name), result.test_number, result.pid, int( |
| 558 result.test_run_time * 1000), int(result.total_run_time * 10
00))} | 558 result.test_run_time * 1000), int(result.total_run_time * 10
00))} |
| 559 stats_trie = {} | 559 stats_trie = {} |
| 560 for name, value in stats.iteritems(): | 560 for name, value in stats.iteritems(): |
| 561 json_results_generator.add_path_to_trie(name, value, stats_trie) | 561 json_results_generator.add_path_to_trie(name, value, stats_trie) |
| 562 return stats_trie | 562 return stats_trie |
| OLD | NEW |