1 # Copyright 2013 The Chromium Authors. All rights reserved.
2 # Use of this source code is governed by a BSD-style license that can be
3 # found in the LICENSE file.
5 """Generates test runner factory and tests for performance tests."""
13 from pylib
import constants
14 from pylib
import forwarder
15 from pylib
.device
import device_list
16 from pylib
.device
import device_utils
17 from pylib
.perf
import test_runner
18 from pylib
.utils
import test_environment
22 devices_path
= os
.path
.join(os
.environ
.get('CHROMIUM_OUT_DIR', 'out'),
23 device_list
.LAST_DEVICES_FILENAME
)
25 devices
= [device_utils
.DeviceUtils(s
)
26 for s
in device_list
.GetPersistentDeviceList(devices_path
)]
28 logging
.error('Unable to find %s [%s]', devices_path
, e
)
29 devices
= device_utils
.DeviceUtils
.HealthyDevices()
30 return sorted(devices
)
33 def _GetStepsDictFromSingleStep(test_options
):
34 # Running a single command, build the tests structure.
40 'cmd': test_options
.single_step
47 def _GetStepsDict(test_options
):
48 if test_options
.single_step
:
49 return _GetStepsDictFromSingleStep(test_options
)
50 if test_options
.steps
:
51 with
file(test_options
.steps
, 'r') as f
:
54 # Already using the new format.
55 assert steps
['version'] == 1
59 def Setup(test_options
):
60 """Create and return the test runner factory and tests.
63 test_options: A PerformanceOptions object.
66 A tuple of (TestRunnerFactory, tests, devices).
68 # TODO(bulach): remove this once the bot side lands. BUG=318369
69 constants
.SetBuildType('Release')
70 if os
.path
.exists(constants
.PERF_OUTPUT_DIR
):
71 shutil
.rmtree(constants
.PERF_OUTPUT_DIR
)
72 os
.makedirs(constants
.PERF_OUTPUT_DIR
)
74 # Before running the tests, kill any leftover server.
75 test_environment
.CleanupLeftoverProcesses()
77 # We want to keep device affinity, so return all devices ever seen.
78 all_devices
= _GetAllDevices()
80 steps_dict
= _GetStepsDict(test_options
)
81 sorted_step_names
= sorted(steps_dict
['steps'].keys())
83 if test_options
.test_filter
:
84 sorted_step_names
= fnmatch
.filter(sorted_step_names
,
85 test_options
.test_filter
)
88 if test_options
.flaky_steps
:
89 with
file(test_options
.flaky_steps
, 'r') as f
:
90 flaky_steps
= json
.load(f
)
92 def TestRunnerFactory(device
, shard_index
):
93 return test_runner
.TestRunner(
94 test_options
, device
, shard_index
, len(all_devices
),
95 steps_dict
, flaky_steps
)
97 return (TestRunnerFactory
, sorted_step_names
, all_devices
)