| OLD | NEW |
| 1 # Copyright (C) 2011 Google Inc. All rights reserved. | 1 # Copyright (C) 2011 Google Inc. All rights reserved. |
| 2 # | 2 # |
| 3 # Redistribution and use in source and binary forms, with or without | 3 # Redistribution and use in source and binary forms, with or without |
| 4 # modification, are permitted provided that the following conditions are | 4 # modification, are permitted provided that the following conditions are |
| 5 # met: | 5 # met: |
| 6 # | 6 # |
| 7 # * Redistributions of source code must retain the above copyright | 7 # * Redistributions of source code must retain the above copyright |
| 8 # notice, this list of conditions and the following disclaimer. | 8 # notice, this list of conditions and the following disclaimer. |
| 9 # * Redistributions in binary form must reproduce the above | 9 # * Redistributions in binary form must reproduce the above |
| 10 # copyright notice, this list of conditions and the following disclaimer | 10 # copyright notice, this list of conditions and the following disclaimer |
| (...skipping 292 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 303 self._start(pixel_tests, per_test_args) | 303 self._start(pixel_tests, per_test_args) |
| 304 self._run_post_start_tasks() | 304 self._run_post_start_tasks() |
| 305 | 305 |
| 306 def _setup_environ_for_driver(self, environment): | 306 def _setup_environ_for_driver(self, environment): |
| 307 if self._profiler: | 307 if self._profiler: |
| 308 environment = self._profiler.adjusted_environment(environment) | 308 environment = self._profiler.adjusted_environment(environment) |
| 309 return environment | 309 return environment |
| 310 | 310 |
| 311 def _start(self, pixel_tests, per_test_args, wait_for_ready=True): | 311 def _start(self, pixel_tests, per_test_args, wait_for_ready=True): |
| 312 self.stop() | 312 self.stop() |
| 313 self._driver_tempdir = self._port._filesystem.mkdtemp(prefix='%s-' % sel
f._port.driver_name()) | 313 self._driver_tempdir = self._port.host.filesystem.mkdtemp(prefix='%s-' %
self._port.driver_name()) |
| 314 server_name = self._port.driver_name() | 314 server_name = self._port.driver_name() |
| 315 environment = self._port.setup_environ_for_server() | 315 environment = self._port.setup_environ_for_server() |
| 316 environment = self._setup_environ_for_driver(environment) | 316 environment = self._setup_environ_for_driver(environment) |
| 317 self._crashed_process_name = None | 317 self._crashed_process_name = None |
| 318 self._crashed_pid = None | 318 self._crashed_pid = None |
| 319 self._leaked = False | 319 self._leaked = False |
| 320 self._leak_log = None | 320 self._leak_log = None |
| 321 cmd_line = self.cmd_line(pixel_tests, per_test_args) | 321 cmd_line = self.cmd_line(pixel_tests, per_test_args) |
| 322 self._server_process = self._port._server_process_constructor( | 322 self._server_process = self._port._server_process_constructor( |
| 323 self._port, server_name, cmd_line, environment, more_logging=self._p
ort.get_option("driver_logging")) | 323 self._port, server_name, cmd_line, environment, more_logging=self._p
ort.get_option("driver_logging")) |
| (...skipping 28 matching lines...) Expand all Loading... |
| 352 return self._server_process.pid() | 352 return self._server_process.pid() |
| 353 | 353 |
| 354 def stop(self, timeout_secs=0.0): | 354 def stop(self, timeout_secs=0.0): |
| 355 if self._server_process: | 355 if self._server_process: |
| 356 self._server_process.stop(timeout_secs) | 356 self._server_process.stop(timeout_secs) |
| 357 self._server_process = None | 357 self._server_process = None |
| 358 if self._profiler: | 358 if self._profiler: |
| 359 self._profiler.profile_after_exit() | 359 self._profiler.profile_after_exit() |
| 360 | 360 |
| 361 if self._driver_tempdir: | 361 if self._driver_tempdir: |
| 362 self._port._filesystem.rmtree(str(self._driver_tempdir)) | 362 self._port.host.filesystem.rmtree(str(self._driver_tempdir)) |
| 363 self._driver_tempdir = None | 363 self._driver_tempdir = None |
| 364 | 364 |
| 365 self._current_cmd_line = None | 365 self._current_cmd_line = None |
| 366 | 366 |
| 367 def cmd_line(self, pixel_tests, per_test_args): | 367 def cmd_line(self, pixel_tests, per_test_args): |
| 368 cmd = self._command_wrapper(self._port.get_option('wrapper')) | 368 cmd = self._command_wrapper(self._port.get_option('wrapper')) |
| 369 cmd.append(self._port._path_to_driver()) | 369 cmd.append(self._port._path_to_driver()) |
| 370 if self._no_timeout: | 370 if self._no_timeout: |
| 371 cmd.append('--no-timeout') | 371 cmd.append('--no-timeout') |
| 372 cmd.extend(self._port.get_option('additional_driver_flag', [])) | 372 cmd.extend(self._port.get_option('additional_driver_flag', [])) |
| (...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 544 self.decoded_content = None | 544 self.decoded_content = None |
| 545 self.malloc = None | 545 self.malloc = None |
| 546 self.js_heap = None | 546 self.js_heap = None |
| 547 self.stdin_path = None | 547 self.stdin_path = None |
| 548 | 548 |
| 549 def decode_content(self): | 549 def decode_content(self): |
| 550 if self.encoding == 'base64' and self.content is not None: | 550 if self.encoding == 'base64' and self.content is not None: |
| 551 self.decoded_content = base64.b64decode(self.content) | 551 self.decoded_content = base64.b64decode(self.content) |
| 552 else: | 552 else: |
| 553 self.decoded_content = self.content | 553 self.decoded_content = self.content |
| OLD | NEW |