OLD | NEW |
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # | 2 # |
3 # Copyright (c) 2013 The Chromium Authors. All rights reserved. | 3 # Copyright (c) 2013 The Chromium Authors. All rights reserved. |
4 # Use of this source code is governed by a BSD-style license that can be | 4 # Use of this source code is governed by a BSD-style license that can be |
5 # found in the LICENSE file. | 5 # found in the LICENSE file. |
6 | 6 |
7 """Provisions Android devices with settings required for bots. | 7 """Provisions Android devices with settings required for bots. |
8 | 8 |
9 Usage: | 9 Usage: |
10 ./provision_devices.py [-d <device serial number>] | 10 ./provision_devices.py [-d <device serial number>] |
(...skipping 17 matching lines...) Expand all Loading... |
28 | 28 |
29 sys.path.append(os.path.join(constants.DIR_SOURCE_ROOT, | 29 sys.path.append(os.path.join(constants.DIR_SOURCE_ROOT, |
30 'third_party', 'android_testrunner')) | 30 'third_party', 'android_testrunner')) |
31 import errors | 31 import errors |
32 | 32 |
33 def KillHostHeartbeat(): | 33 def KillHostHeartbeat(): |
34 ps = subprocess.Popen(['ps', 'aux'], stdout = subprocess.PIPE) | 34 ps = subprocess.Popen(['ps', 'aux'], stdout = subprocess.PIPE) |
35 stdout, _ = ps.communicate() | 35 stdout, _ = ps.communicate() |
36 matches = re.findall('\\n.*host_heartbeat.*', stdout) | 36 matches = re.findall('\\n.*host_heartbeat.*', stdout) |
37 for match in matches: | 37 for match in matches: |
38 print 'An instance of host heart beart running... will kill' | 38 logging.info('An instance of host heart beart running... will kill') |
39 pid = re.findall('(\d+)', match)[0] | 39 pid = re.findall('(\d+)', match)[0] |
40 subprocess.call(['kill', str(pid)]) | 40 subprocess.call(['kill', str(pid)]) |
41 | 41 |
42 | 42 |
43 def LaunchHostHeartbeat(): | 43 def LaunchHostHeartbeat(): |
44 # Kill if existing host_heartbeat | 44 # Kill if existing host_heartbeat |
45 KillHostHeartbeat() | 45 KillHostHeartbeat() |
46 # Launch a new host_heartbeat | 46 # Launch a new host_heartbeat |
47 print 'Spawning host heartbeat...' | 47 logging.info('Spawning host heartbeat...') |
48 subprocess.Popen([os.path.join(constants.DIR_SOURCE_ROOT, | 48 subprocess.Popen([os.path.join(constants.DIR_SOURCE_ROOT, |
49 'build/android/host_heartbeat.py')]) | 49 'build/android/host_heartbeat.py')]) |
50 | 50 |
51 | 51 |
52 def PushAndLaunchAdbReboot(devices, target): | 52 def PushAndLaunchAdbReboot(devices, target): |
53 """Pushes and launches the adb_reboot binary on the device. | 53 """Pushes and launches the adb_reboot binary on the device. |
54 | 54 |
55 Arguments: | 55 Arguments: |
56 devices: The list of serial numbers of the device to which the | 56 devices: The list of serial numbers of the device to which the |
57 adb_reboot binary should be pushed. | 57 adb_reboot binary should be pushed. |
58 target : The build target (example, Debug or Release) which helps in | 58 target : The build target (example, Debug or Release) which helps in |
59 locating the adb_reboot binary. | 59 locating the adb_reboot binary. |
60 """ | 60 """ |
61 for device_serial in devices: | 61 for device_serial in devices: |
62 print 'Will push and launch adb_reboot on %s' % device_serial | 62 logging.info('Will push and launch adb_reboot on %s' % device_serial) |
63 device = device_utils.DeviceUtils(device_serial) | 63 device = device_utils.DeviceUtils(device_serial) |
64 # Kill if adb_reboot is already running. | 64 # Kill if adb_reboot is already running. |
65 try: | 65 try: |
66 # Don't try to kill adb_reboot more than once. We don't expect it to be | 66 # Don't try to kill adb_reboot more than once. We don't expect it to be |
67 # running at all. | 67 # running at all. |
68 device.KillAll('adb_reboot', blocking=True, timeout=2, retries=0) | 68 device.KillAll('adb_reboot', blocking=True, timeout=2, retries=0) |
69 except device_errors.CommandFailedError: | 69 except device_errors.CommandFailedError: |
70 # We can safely ignore the exception because we don't expect adb_reboot | 70 # We can safely ignore the exception because we don't expect adb_reboot |
71 # to be running. | 71 # to be running. |
72 pass | 72 pass |
73 # Push adb_reboot | 73 # Push adb_reboot |
74 print ' Pushing adb_reboot ...' | 74 logging.info(' Pushing adb_reboot ...') |
75 adb_reboot = os.path.join(constants.DIR_SOURCE_ROOT, | 75 adb_reboot = os.path.join(constants.DIR_SOURCE_ROOT, |
76 'out/%s/adb_reboot' % target) | 76 'out/%s/adb_reboot' % target) |
77 device.PushChangedFiles(adb_reboot, '/data/local/tmp/') | 77 device.PushChangedFiles(adb_reboot, '/data/local/tmp/') |
78 # Launch adb_reboot | 78 # Launch adb_reboot |
79 print ' Launching adb_reboot ...' | 79 logging.info(' Launching adb_reboot ...') |
80 device.old_interface.GetAndroidToolStatusAndOutput( | 80 device.old_interface.GetAndroidToolStatusAndOutput( |
81 '/data/local/tmp/adb_reboot') | 81 '/data/local/tmp/adb_reboot') |
82 LaunchHostHeartbeat() | 82 LaunchHostHeartbeat() |
83 | 83 |
84 | 84 |
85 def _ConfigureLocalProperties(device, is_perf): | 85 def _ConfigureLocalProperties(device, is_perf): |
86 """Set standard readonly testing device properties prior to reboot.""" | 86 """Set standard readonly testing device properties prior to reboot.""" |
87 local_props = [ | 87 local_props = [ |
88 'ro.monkey=1', | 88 'ro.monkey=1', |
89 'ro.test_harness=1', | 89 'ro.test_harness=1', |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
153 except errors.DeviceUnresponsiveError: | 153 except errors.DeviceUnresponsiveError: |
154 pass | 154 pass |
155 for device_serial in devices_to_reboot: | 155 for device_serial in devices_to_reboot: |
156 device.WaitUntilFullyBooted(timeout=90) | 156 device.WaitUntilFullyBooted(timeout=90) |
157 | 157 |
158 | 158 |
159 def ProvisionDevice(device_serial, is_perf, disable_location): | 159 def ProvisionDevice(device_serial, is_perf, disable_location): |
160 device = device_utils.DeviceUtils(device_serial) | 160 device = device_utils.DeviceUtils(device_serial) |
161 device.old_interface.EnableAdbRoot() | 161 device.old_interface.EnableAdbRoot() |
162 _ConfigureLocalProperties(device, is_perf) | 162 _ConfigureLocalProperties(device, is_perf) |
163 device_settings_map = device_settings.DETERMINISTIC_DEVICE_SETTINGS | 163 device_settings.ConfigureContentSettings( |
| 164 device, device_settings.DETERMINISTIC_DEVICE_SETTINGS) |
164 if disable_location: | 165 if disable_location: |
165 device_settings_map.update(device_settings.DISABLE_LOCATION_SETTING) | 166 device_settings.ConfigureContentSettings( |
| 167 device, device_settings.DISABLE_LOCATION_SETTINGS) |
166 else: | 168 else: |
167 device_settings_map.update(device_settings.ENABLE_LOCATION_SETTING) | 169 device_settings.ConfigureContentSettings( |
168 device_settings.ConfigureContentSettingsDict(device, device_settings_map) | 170 device, device_settings.ENABLE_LOCATION_SETTINGS) |
169 device_settings.SetLockScreenSettings(device) | 171 device_settings.SetLockScreenSettings(device) |
170 if is_perf: | 172 if is_perf: |
171 # TODO(tonyg): We eventually want network on. However, currently radios | 173 # TODO(tonyg): We eventually want network on. However, currently radios |
172 # can cause perfbots to drain faster than they charge. | 174 # can cause perfbots to drain faster than they charge. |
173 device_settings.ConfigureContentSettingsDict( | 175 device_settings.ConfigureContentSettings( |
174 device, device_settings.NETWORK_DISABLED_SETTINGS) | 176 device, device_settings.NETWORK_DISABLED_SETTINGS) |
175 # Some perf bots run benchmarks with USB charging disabled which leads | 177 # Some perf bots run benchmarks with USB charging disabled which leads |
176 # to gradual draining of the battery. We must wait for a full charge | 178 # to gradual draining of the battery. We must wait for a full charge |
177 # before starting a run in order to keep the devices online. | 179 # before starting a run in order to keep the devices online. |
178 try: | 180 try: |
179 battery_info = device.old_interface.GetBatteryInfo() | 181 battery_info = device.old_interface.GetBatteryInfo() |
180 except Exception as e: | 182 except Exception as e: |
181 battery_info = {} | 183 battery_info = {} |
182 logging.error('Unable to obtain battery info for %s, %s', | 184 logging.error('Unable to obtain battery info for %s, %s', |
183 device_serial, e) | 185 device_serial, e) |
(...skipping 23 matching lines...) Expand all Loading... |
207 | 209 |
208 # Wipe devices (unless --skip-wipe was specified) | 210 # Wipe devices (unless --skip-wipe was specified) |
209 if not options.skip_wipe: | 211 if not options.skip_wipe: |
210 WipeDevicesIfPossible(devices) | 212 WipeDevicesIfPossible(devices) |
211 | 213 |
212 bad_devices = [] | 214 bad_devices = [] |
213 # Provision devices | 215 # Provision devices |
214 for device_serial in devices: | 216 for device_serial in devices: |
215 try: | 217 try: |
216 ProvisionDevice(device_serial, is_perf, options.disable_location) | 218 ProvisionDevice(device_serial, is_perf, options.disable_location) |
217 except errors.WaitForResponseTimedOutError: | 219 except (errors.WaitForResponseTimedOutError, |
| 220 device_errors.CommandTimeoutError): |
218 logging.info('Timed out waiting for device %s. Adding to blacklist.', | 221 logging.info('Timed out waiting for device %s. Adding to blacklist.', |
219 device_serial) | 222 device_serial) |
220 bad_devices.append(device_serial) | 223 bad_devices.append(device_serial) |
221 # Device black list is reset by bb_device_status_check.py per build. | 224 # Device black list is reset by bb_device_status_check.py per build. |
222 device_blacklist.ExtendBlacklist([device_serial]) | 225 device_blacklist.ExtendBlacklist([device_serial]) |
| 226 except device_errors.CommandFailedError: |
| 227 logging.info('Failed to provision device %s. Adding to blacklist.', |
| 228 device_serial) |
| 229 bad_devices.append(device_serial) |
| 230 device_blacklist.ExtendBlacklist([device_serial]) |
223 devices = [device for device in devices if device not in bad_devices] | 231 devices = [device for device in devices if device not in bad_devices] |
224 | 232 |
225 # If there are no good devices | 233 # If there are no good devices |
226 if not devices: | 234 if not devices: |
227 raise device_errors.NoDevicesError | 235 raise device_errors.NoDevicesError |
228 | 236 |
229 try: | 237 try: |
230 device_utils.DeviceUtils.parallel(devices).Reboot(True) | 238 device_utils.DeviceUtils.parallel(devices).Reboot(True) |
231 except errors.DeviceUnresponsiveError: | 239 except errors.DeviceUnresponsiveError: |
232 pass | 240 pass |
233 | 241 |
234 bad_devices = [] | 242 bad_devices = [] |
235 for device_serial in devices: | 243 for device_serial in devices: |
236 device = device_utils.DeviceUtils(device_serial) | 244 device = device_utils.DeviceUtils(device_serial) |
237 try: | 245 try: |
238 device.WaitUntilFullyBooted(timeout=90) | 246 device.WaitUntilFullyBooted(timeout=90) |
239 (_, prop) = device.old_interface.GetShellCommandStatusAndOutput('getprop') | 247 (_, prop) = device.old_interface.GetShellCommandStatusAndOutput('getprop') |
240 for p in prop: | 248 for p in prop: |
241 print p | 249 logging.info(p) |
242 except errors.WaitForResponseTimedOutError: | 250 except (errors.WaitForResponseTimedOutError, |
| 251 device_errors.CommandTimeoutError): |
243 logging.info('Timed out waiting for device %s. Adding to blacklist.', | 252 logging.info('Timed out waiting for device %s. Adding to blacklist.', |
244 device_serial) | 253 device_serial) |
245 bad_devices.append(device_serial) | 254 bad_devices.append(device_serial) |
246 # Device black list is reset by bb_device_status_check.py per build. | 255 # Device black list is reset by bb_device_status_check.py per build. |
247 device_blacklist.ExtendBlacklist([device_serial]) | 256 device_blacklist.ExtendBlacklist([device_serial]) |
| 257 except device_errors.CommandFailedError: |
| 258 logging.info('Failed to provision device %s. Adding to blacklist.', |
| 259 device_serial) |
| 260 bad_devices.append(device_serial) |
| 261 device_blacklist.ExtendBlacklist([device_serial]) |
248 devices = [device for device in devices if device not in bad_devices] | 262 devices = [device for device in devices if device not in bad_devices] |
249 | 263 |
250 # If there are no good devices | 264 # If there are no good devices |
251 if not devices: | 265 if not devices: |
252 raise device_errors.NoDevicesError | 266 raise device_errors.NoDevicesError |
253 | 267 |
254 if options.auto_reconnect: | 268 if options.auto_reconnect: |
255 PushAndLaunchAdbReboot(devices, options.target) | 269 PushAndLaunchAdbReboot(devices, options.target) |
256 | 270 |
257 | 271 |
(...skipping 19 matching lines...) Expand all Loading... |
277 | 291 |
278 if args: | 292 if args: |
279 print >> sys.stderr, 'Unused args %s' % args | 293 print >> sys.stderr, 'Unused args %s' % args |
280 return 1 | 294 return 1 |
281 | 295 |
282 ProvisionDevices(options) | 296 ProvisionDevices(options) |
283 | 297 |
284 | 298 |
285 if __name__ == '__main__': | 299 if __name__ == '__main__': |
286 sys.exit(main(sys.argv)) | 300 sys.exit(main(sys.argv)) |
OLD | NEW |