| 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 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 46 | 46 |
| 47 | 47 |
| 48 class _PHASES(object): | 48 class _PHASES(object): |
| 49 WIPE = 'wipe' | 49 WIPE = 'wipe' |
| 50 PROPERTIES = 'properties' | 50 PROPERTIES = 'properties' |
| 51 FINISH = 'finish' | 51 FINISH = 'finish' |
| 52 | 52 |
| 53 ALL = [WIPE, PROPERTIES, FINISH] | 53 ALL = [WIPE, PROPERTIES, FINISH] |
| 54 | 54 |
| 55 | 55 |
| 56 def ProvisionDevices(options): | 56 def ProvisionDevices(args): |
| 57 devices = device_utils.DeviceUtils.HealthyDevices() | 57 if args.blacklist_file: |
| 58 if options.device: | 58 blacklist = device_blacklist.Blacklist(args.blacklist_file) |
| 59 devices = [d for d in devices if d == options.device] | 59 else: |
| 60 # TODO(jbudorick): Remove once the bots have switched over. |
| 61 blacklist = device_blacklist.Blacklist(device_blacklist.BLACKLIST_JSON) |
| 62 |
| 63 devices = device_utils.DeviceUtils.HealthyDevices(blacklist) |
| 64 if args.device: |
| 65 devices = [d for d in devices if d == args.device] |
| 60 if not devices: | 66 if not devices: |
| 61 raise device_errors.DeviceUnreachableError(options.device) | 67 raise device_errors.DeviceUnreachableError(args.device) |
| 62 | 68 |
| 63 parallel_devices = device_utils.DeviceUtils.parallel(devices) | 69 parallel_devices = device_utils.DeviceUtils.parallel(devices) |
| 64 parallel_devices.pMap(ProvisionDevice, options) | 70 parallel_devices.pMap(ProvisionDevice, blacklist, args) |
| 65 if options.auto_reconnect: | 71 if args.auto_reconnect: |
| 66 _LaunchHostHeartbeat() | 72 _LaunchHostHeartbeat() |
| 67 blacklist = device_blacklist.ReadBlacklist() | 73 blacklisted_devices = blacklist.Read() |
| 68 if options.output_device_blacklist: | 74 if args.output_device_blacklist: |
| 69 with open(options.output_device_blacklist, 'w') as f: | 75 with open(args.output_device_blacklist, 'w') as f: |
| 70 json.dump(blacklist, f) | 76 json.dump(blacklisted_devices, f) |
| 71 if all(d in blacklist for d in devices): | 77 if all(d in blacklisted_devices for d in devices): |
| 72 raise device_errors.NoDevicesError | 78 raise device_errors.NoDevicesError |
| 73 return 0 | 79 return 0 |
| 74 | 80 |
| 75 | 81 |
| 76 def ProvisionDevice(device, options): | 82 def ProvisionDevice(device, blacklist, options): |
| 77 if options.reboot_timeout: | 83 if options.reboot_timeout: |
| 78 reboot_timeout = options.reboot_timeout | 84 reboot_timeout = options.reboot_timeout |
| 79 elif (device.build_version_sdk >= | 85 elif (device.build_version_sdk >= |
| 80 constants.ANDROID_SDK_VERSION_CODES.LOLLIPOP): | 86 constants.ANDROID_SDK_VERSION_CODES.LOLLIPOP): |
| 81 reboot_timeout = _DEFAULT_TIMEOUTS.LOLLIPOP | 87 reboot_timeout = _DEFAULT_TIMEOUTS.LOLLIPOP |
| 82 else: | 88 else: |
| 83 reboot_timeout = _DEFAULT_TIMEOUTS.PRE_LOLLIPOP | 89 reboot_timeout = _DEFAULT_TIMEOUTS.PRE_LOLLIPOP |
| 84 | 90 |
| 85 def should_run_phase(phase_name): | 91 def should_run_phase(phase_name): |
| 86 return not options.phases or phase_name in options.phases | 92 return not options.phases or phase_name in options.phases |
| (...skipping 16 matching lines...) Expand all Loading... |
| 103 if should_run_phase(_PHASES.PROPERTIES): | 109 if should_run_phase(_PHASES.PROPERTIES): |
| 104 run_phase(SetProperties) | 110 run_phase(SetProperties) |
| 105 | 111 |
| 106 if should_run_phase(_PHASES.FINISH): | 112 if should_run_phase(_PHASES.FINISH): |
| 107 run_phase(FinishProvisioning, reboot=False) | 113 run_phase(FinishProvisioning, reboot=False) |
| 108 | 114 |
| 109 except (errors.WaitForResponseTimedOutError, | 115 except (errors.WaitForResponseTimedOutError, |
| 110 device_errors.CommandTimeoutError): | 116 device_errors.CommandTimeoutError): |
| 111 logging.exception('Timed out waiting for device %s. Adding to blacklist.', | 117 logging.exception('Timed out waiting for device %s. Adding to blacklist.', |
| 112 str(device)) | 118 str(device)) |
| 113 device_blacklist.ExtendBlacklist([str(device)]) | 119 blacklist.Extend([str(device)]) |
| 114 | 120 |
| 115 except device_errors.CommandFailedError: | 121 except device_errors.CommandFailedError: |
| 116 logging.exception('Failed to provision device %s. Adding to blacklist.', | 122 logging.exception('Failed to provision device %s. Adding to blacklist.', |
| 117 str(device)) | 123 str(device)) |
| 118 device_blacklist.ExtendBlacklist([str(device)]) | 124 blacklist.Extend([str(device)]) |
| 119 | 125 |
| 120 | 126 |
| 121 def WipeDevice(device, options): | 127 def WipeDevice(device, options): |
| 122 """Wipes data from device, keeping only the adb_keys for authorization. | 128 """Wipes data from device, keeping only the adb_keys for authorization. |
| 123 | 129 |
| 124 After wiping data on a device that has been authorized, adb can still | 130 After wiping data on a device that has been authorized, adb can still |
| 125 communicate with the device, but after reboot the device will need to be | 131 communicate with the device, but after reboot the device will need to be |
| 126 re-authorized because the adb keys file is stored in /data/misc/adb/. | 132 re-authorized because the adb keys file is stored in /data/misc/adb/. |
| 127 Thus, adb_keys file is rewritten so the device does not need to be | 133 Thus, adb_keys file is rewritten so the device does not need to be |
| 128 re-authorized. | 134 re-authorized. |
| (...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 310 # --min-battery-level 95 | 316 # --min-battery-level 95 |
| 311 # Some perf bots run benchmarks with USB charging disabled which leads | 317 # Some perf bots run benchmarks with USB charging disabled which leads |
| 312 # to gradual draining of the battery. We must wait for a full charge | 318 # to gradual draining of the battery. We must wait for a full charge |
| 313 # before starting a run in order to keep the devices online. | 319 # before starting a run in order to keep the devices online. |
| 314 | 320 |
| 315 parser = argparse.ArgumentParser( | 321 parser = argparse.ArgumentParser( |
| 316 description='Provision Android devices with settings required for bots.') | 322 description='Provision Android devices with settings required for bots.') |
| 317 parser.add_argument('-d', '--device', metavar='SERIAL', | 323 parser.add_argument('-d', '--device', metavar='SERIAL', |
| 318 help='the serial number of the device to be provisioned' | 324 help='the serial number of the device to be provisioned' |
| 319 ' (the default is to provision all devices attached)') | 325 ' (the default is to provision all devices attached)') |
| 326 parser.add_argument('--blacklist-file', help='Device blacklist JSON file.') |
| 320 parser.add_argument('--phase', action='append', choices=_PHASES.ALL, | 327 parser.add_argument('--phase', action='append', choices=_PHASES.ALL, |
| 321 dest='phases', | 328 dest='phases', |
| 322 help='Phases of provisioning to run. ' | 329 help='Phases of provisioning to run. ' |
| 323 '(If omitted, all phases will be run.)') | 330 '(If omitted, all phases will be run.)') |
| 324 parser.add_argument('--skip-wipe', action='store_true', default=False, | 331 parser.add_argument('--skip-wipe', action='store_true', default=False, |
| 325 help="don't wipe device data during provisioning") | 332 help="don't wipe device data during provisioning") |
| 326 parser.add_argument('--reboot-timeout', metavar='SECS', type=int, | 333 parser.add_argument('--reboot-timeout', metavar='SECS', type=int, |
| 327 help='when wiping the device, max number of seconds to' | 334 help='when wiping the device, max number of seconds to' |
| 328 ' wait after each reboot ' | 335 ' wait after each reboot ' |
| 329 '(default: %s)' % _DEFAULT_TIMEOUTS.HELP_TEXT) | 336 '(default: %s)' % _DEFAULT_TIMEOUTS.HELP_TEXT) |
| (...skipping 27 matching lines...) Expand all Loading... |
| 357 args = parser.parse_args() | 364 args = parser.parse_args() |
| 358 constants.SetBuildType(args.target) | 365 constants.SetBuildType(args.target) |
| 359 | 366 |
| 360 run_tests_helper.SetLogLevel(args.verbose) | 367 run_tests_helper.SetLogLevel(args.verbose) |
| 361 | 368 |
| 362 return ProvisionDevices(args) | 369 return ProvisionDevices(args) |
| 363 | 370 |
| 364 | 371 |
| 365 if __name__ == '__main__': | 372 if __name__ == '__main__': |
| 366 sys.exit(main()) | 373 sys.exit(main()) |
| OLD | NEW |