Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 1 | # Copyright (c) 2013 The Chromium OS 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. |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 4 | import functools |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 5 | import logging |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 6 | import os |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 7 | import re |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 8 | import stat |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 9 | import sys |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 10 | import time |
| 11 | |
| 12 | import common |
| 13 | |
| 14 | from autotest_lib.client.common_lib import error |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 15 | from autotest_lib.client.common_lib.cros import dev_server |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 16 | from autotest_lib.client.common_lib.cros import retry |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 17 | from autotest_lib.server import autoserv_parser |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 18 | from autotest_lib.server import constants as server_constants |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 19 | from autotest_lib.server import utils |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 20 | from autotest_lib.server.cros.dynamic_suite import constants |
Simran Basi | 724b8a5 | 2013-09-30 11:19:31 -0700 | [diff] [blame] | 21 | from autotest_lib.server.hosts import abstract_ssh |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 22 | from autotest_lib.server.hosts import teststation_host |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 23 | |
| 24 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 25 | ADB_CMD = 'adb' |
| 26 | FASTBOOT_CMD = 'fastboot' |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 27 | SHELL_CMD = 'shell' |
Filipe Brandenburger | 3436339 | 2015-08-13 14:57:45 -0700 | [diff] [blame] | 28 | # Some devices have no serial, then `adb serial` has output such as: |
| 29 | # (no serial number) device |
| 30 | # ?????????? device |
| 31 | DEVICE_NO_SERIAL_MSG = '(no serial number)' |
| 32 | DEVICE_NO_SERIAL_TAG = '<NO_SERIAL>' |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 33 | # Regex to find an adb device. Examples: |
| 34 | # 0146B5580B01801B device |
| 35 | # 018e0ecb20c97a62 device |
| 36 | # 172.22.75.141:5555 device |
Filipe Brandenburger | 3436339 | 2015-08-13 14:57:45 -0700 | [diff] [blame] | 37 | DEVICE_FINDER_REGEX = ('^(?P<SERIAL>([\w]+)|(\d{1,3}.\d{1,3}.\d{1,3}.\d{1,3})|' + |
| 38 | re.escape(DEVICE_NO_SERIAL_MSG) + |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 39 | ')([:]5555)?[ \t]+(?:device|fastboot)') |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 40 | CMD_OUTPUT_PREFIX = 'ADB_CMD_OUTPUT' |
| 41 | CMD_OUTPUT_REGEX = ('(?P<OUTPUT>[\s\S]*)%s:(?P<EXIT_CODE>\d{1,3})' % |
| 42 | CMD_OUTPUT_PREFIX) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 43 | RELEASE_FILE = 'ro.build.version.release' |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 44 | BOARD_FILE = 'ro.product.device' |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 45 | TMP_DIR = '/data/local/tmp' |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 46 | # Regex to pull out file type, perms and symlink. Example: |
Kevin Cheng | aaabd0c | 2015-11-10 16:05:04 -0800 | [diff] [blame] | 47 | # lrwxrwx--- 1 6 root system 2015-09-12 19:21 blah_link -> ./blah |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 48 | FILE_INFO_REGEX = '^(?P<TYPE>[dl-])(?P<PERMS>[rwx-]{9})' |
| 49 | FILE_SYMLINK_REGEX = '^.*-> (?P<SYMLINK>.+)' |
| 50 | # List of the perm stats indexed by the order they are listed in the example |
| 51 | # supplied above. |
| 52 | FILE_PERMS_FLAGS = [stat.S_IRUSR, stat.S_IWUSR, stat.S_IXUSR, |
| 53 | stat.S_IRGRP, stat.S_IWGRP, stat.S_IXGRP, |
| 54 | stat.S_IROTH, stat.S_IWOTH, stat.S_IXOTH] |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 55 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 56 | # Default maximum number of seconds to wait for a device to be down. |
| 57 | DEFAULT_WAIT_DOWN_TIME_SECONDS = 10 |
| 58 | # Default maximum number of seconds to wait for a device to be up. |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 59 | DEFAULT_WAIT_UP_TIME_SECONDS = 300 |
| 60 | # Maximum number of seconds to wait for a device to be up after it's wiped. |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 61 | WAIT_UP_AFTER_WIPE_TIME_SECONDS = 1200 |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 62 | |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 63 | OS_TYPE_ANDROID = 'android' |
| 64 | OS_TYPE_BRILLO = 'brillo' |
| 65 | |
| 66 | # Regex to parse devserver url to get the detailed build information. Sample |
| 67 | # url: http://$devserver:8080/static/branch/target/build_id |
| 68 | DEVSERVER_URL_REGEX = ('.*/(?P<BRANCH>([^/]+))/(?P<BOARD>([^/]+))-' |
| 69 | '(?P<BUILD_TYPE>([^/]+))/(?P<BUILD_ID>([^/]+))/*') |
| 70 | |
| 71 | ANDROID_IMAGE_FILE_FMT = '%(board)s-img-%(build_id)s.zip' |
| 72 | ANDROID_BOOTLOADER = 'bootloader.img' |
| 73 | ANDROID_RADIO = 'radio.img' |
| 74 | ANDROID_BOOT = 'boot.img' |
| 75 | ANDROID_SYSTEM = 'system.img' |
| 76 | ANDROID_VENDOR = 'vendor.img' |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 77 | BRILLO_VENDOR_PARTITIONS_FILE_FMT = ( |
| 78 | '%(board)s-vendor_partitions-%(build_id)s.zip') |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 79 | |
| 80 | # Image files not inside the image zip file. These files should be downloaded |
| 81 | # directly from devserver. |
| 82 | ANDROID_STANDALONE_IMAGES = [ANDROID_BOOTLOADER, ANDROID_RADIO] |
| 83 | # Image files that are packaged in a zip file, e.g., shamu-img-123456.zip |
| 84 | ANDROID_ZIPPED_IMAGES = [ANDROID_BOOT, ANDROID_SYSTEM, ANDROID_VENDOR] |
| 85 | # All image files to be flashed to an Android device. |
| 86 | ANDROID_IMAGES = ANDROID_STANDALONE_IMAGES + ANDROID_ZIPPED_IMAGES |
| 87 | |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 88 | # Command to provision a Brillo device. |
| 89 | # os_image_dir: The full path of the directory that contains all the Android image |
| 90 | # files (from the image zip file). |
| 91 | # vendor_partition_dir: The full path of the directory that contains all the |
| 92 | # Brillo vendor partitions, and provision-device script. |
| 93 | BRILLO_PROVISION_CMD = ( |
| 94 | 'ANDROID_PROVISION_OS_PARTITIONS=%(os_image_dir)s ' |
| 95 | 'ANDROID_PROVISION_VENDOR_PARTITIONS=%(vendor_partition_dir)s ' |
| 96 | '%(vendor_partition_dir)s/provision-device') |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 97 | |
| 98 | class AndroidInstallError(error.InstallError): |
| 99 | """Generic error for Android installation related exceptions.""" |
| 100 | |
| 101 | |
Simran Basi | 724b8a5 | 2013-09-30 11:19:31 -0700 | [diff] [blame] | 102 | class ADBHost(abstract_ssh.AbstractSSHHost): |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 103 | """This class represents a host running an ADB server.""" |
| 104 | |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 105 | _LABEL_FUNCTIONS = [] |
| 106 | _DETECTABLE_LABELS = [] |
| 107 | label_decorator = functools.partial(utils.add_label_detector, |
| 108 | _LABEL_FUNCTIONS, |
| 109 | _DETECTABLE_LABELS) |
| 110 | |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 111 | _parser = autoserv_parser.autoserv_parser |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 112 | |
beeps | 46dadc9 | 2013-11-07 14:07:10 -0800 | [diff] [blame] | 113 | @staticmethod |
| 114 | def check_host(host, timeout=10): |
| 115 | """ |
| 116 | Check if the given host is an adb host. |
| 117 | |
Simran Basi | 14622bb | 2015-11-25 13:23:40 -0800 | [diff] [blame] | 118 | If SSH connectivity can't be established, check_host will try to use |
| 119 | user 'adb' as well. If SSH connectivity still can't be established |
| 120 | then the original SSH user is restored. |
| 121 | |
beeps | 46dadc9 | 2013-11-07 14:07:10 -0800 | [diff] [blame] | 122 | @param host: An ssh host representing a device. |
| 123 | @param timeout: The timeout for the run command. |
| 124 | |
| 125 | |
| 126 | @return: True if the host device has adb. |
| 127 | |
| 128 | @raises AutoservRunError: If the command failed. |
| 129 | @raises AutoservSSHTimeout: Ssh connection has timed out. |
| 130 | """ |
Dan Shi | 64e130f | 2015-12-16 14:45:44 -0800 | [diff] [blame] | 131 | # host object may not have user attribute if it's a LocalHost object. |
| 132 | current_user = host.user if hasattr(host, 'user') else None |
beeps | 46dadc9 | 2013-11-07 14:07:10 -0800 | [diff] [blame] | 133 | try: |
Simran Basi | 14622bb | 2015-11-25 13:23:40 -0800 | [diff] [blame] | 134 | if not (host.hostname == 'localhost' or |
| 135 | host.verify_ssh_user_access()): |
Simran Basi | 1621c63 | 2015-10-14 12:22:23 -0700 | [diff] [blame] | 136 | host.user = 'adb' |
Simran Basi | 933c8af | 2015-04-29 14:05:07 -0700 | [diff] [blame] | 137 | result = host.run( |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 138 | 'test -f %s' % server_constants.ANDROID_TESTER_FILEFLAG, |
Simran Basi | 933c8af | 2015-04-29 14:05:07 -0700 | [diff] [blame] | 139 | timeout=timeout) |
beeps | 46dadc9 | 2013-11-07 14:07:10 -0800 | [diff] [blame] | 140 | except (error.AutoservRunError, error.AutoservSSHTimeout): |
Dan Shi | 64e130f | 2015-12-16 14:45:44 -0800 | [diff] [blame] | 141 | if current_user is not None: |
| 142 | host.user = current_user |
beeps | 46dadc9 | 2013-11-07 14:07:10 -0800 | [diff] [blame] | 143 | return False |
| 144 | return result.exit_status == 0 |
| 145 | |
| 146 | |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 147 | # TODO(garnold) Remove the 'serials' argument once all clients are made to |
| 148 | # not use it. |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 149 | def _initialize(self, hostname='localhost', serials=None, |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 150 | adb_serial=None, fastboot_serial=None, |
Kevin Cheng | 549beb4 | 2015-11-18 11:42:25 -0800 | [diff] [blame] | 151 | device_hostname=None, teststation=None, *args, **dargs): |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 152 | """Initialize an ADB Host. |
| 153 | |
| 154 | This will create an ADB Host. Hostname should always refer to the |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 155 | test station connected to an Android DUT. This will be the DUT |
| 156 | to test with. If there are multiple, serial must be specified or an |
| 157 | exception will be raised. If device_hostname is supplied then all |
| 158 | ADB commands will run over TCP/IP. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 159 | |
| 160 | @param hostname: Hostname of the machine running ADB. |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 161 | @param serials: DEPRECATED (to be removed) |
| 162 | @param adb_serial: An ADB device serial. If None, assume a single |
| 163 | device is attached (and fail otherwise). |
| 164 | @param fastboot_serial: A fastboot device serial. If None, defaults to |
| 165 | the ADB serial (or assumes a single device if |
| 166 | the latter is None). |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 167 | @param device_hostname: Hostname or IP of the android device we want to |
| 168 | interact with. If supplied all ADB interactions |
| 169 | run over TCP/IP. |
Kevin Cheng | 549beb4 | 2015-11-18 11:42:25 -0800 | [diff] [blame] | 170 | @param teststation: The teststation object ADBHost should use. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 171 | """ |
Simran Basi | 1bf60eb | 2015-12-01 16:39:29 -0800 | [diff] [blame] | 172 | # Sets up the is_client_install_supported field. |
| 173 | super(ADBHost, self)._initialize(hostname=hostname, |
| 174 | is_client_install_supported=False, |
| 175 | *args, **dargs) |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 176 | if device_hostname and (adb_serial or fastboot_serial): |
| 177 | raise error.AutoservError( |
| 178 | 'TCP/IP and USB modes are mutually exclusive') |
| 179 | |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 180 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 181 | self.tmp_dirs = [] |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 182 | self._device_hostname = device_hostname |
| 183 | self._use_tcpip = False |
Simran Basi | 1bf60eb | 2015-12-01 16:39:29 -0800 | [diff] [blame] | 184 | # TODO (sbasi/kevcheng): Once the teststation host is committed, |
| 185 | # refactor the serial retrieval. |
| 186 | adb_serial = adb_serial or self.host_attributes.get('serials', None) |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 187 | self.adb_serial = adb_serial |
| 188 | self.fastboot_serial = fastboot_serial or adb_serial |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 189 | self.teststation = (teststation if teststation |
| 190 | else teststation_host.create_teststationhost(hostname=hostname)) |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 191 | |
| 192 | msg ='Initializing ADB device on host: %s' % hostname |
| 193 | if self._device_hostname: |
| 194 | msg += ', device hostname: %s' % self._device_hostname |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 195 | if self.adb_serial: |
| 196 | msg += ', ADB serial: %s' % self.adb_serial |
| 197 | if self.fastboot_serial: |
| 198 | msg += ', fastboot serial: %s' % self.fastboot_serial |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 199 | logging.debug(msg) |
| 200 | |
Roshan Pius | 4d7540c | 2015-12-16 13:30:32 -0800 | [diff] [blame] | 201 | self._reset_adbd_connection() |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 202 | self._os_type = None |
| 203 | |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 204 | |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 205 | def _connect_over_tcpip_as_needed(self): |
| 206 | """Connect to the ADB device over TCP/IP if so configured.""" |
| 207 | if not self._device_hostname: |
| 208 | return |
| 209 | logging.debug('Connecting to device over TCP/IP') |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 210 | if self._device_hostname == self.adb_serial: |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 211 | # We previously had a connection to this device, restart the ADB |
| 212 | # server. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 213 | self.adb_run('kill-server') |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 214 | # Ensure that connection commands don't run over TCP/IP. |
| 215 | self._use_tcpip = False |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 216 | self.adb_run('tcpip 5555', timeout=10, ignore_timeout=True) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 217 | time.sleep(2) |
| 218 | try: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 219 | self.adb_run('connect %s' % self._device_hostname) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 220 | except (error.AutoservRunError, error.CmdError) as e: |
| 221 | raise error.AutoservError('Failed to connect via TCP/IP: %s' % e) |
| 222 | # Allow ADB a bit of time after connecting before interacting with the |
| 223 | # device. |
| 224 | time.sleep(5) |
| 225 | # Switch back to using TCP/IP. |
| 226 | self._use_tcpip = True |
| 227 | |
| 228 | |
Roshan Pius | 4d7540c | 2015-12-16 13:30:32 -0800 | [diff] [blame] | 229 | def _restart_adbd_with_root_permissions(self): |
| 230 | """Restarts the adb daemon with root permissions.""" |
| 231 | self.adb_run('root') |
| 232 | # TODO(ralphnathan): Remove this sleep once b/19749057 is resolved. |
| 233 | time.sleep(1) |
| 234 | self.adb_run('wait-for-device') |
| 235 | |
| 236 | |
| 237 | def _reset_adbd_connection(self): |
| 238 | """Resets adbd connection to the device after a reboot/initialization""" |
| 239 | self._restart_adbd_with_root_permissions() |
| 240 | self._connect_over_tcpip_as_needed() |
| 241 | |
| 242 | |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 243 | # pylint: disable=missing-docstring |
Gilad Arnold | f17f6fd | 2015-11-12 14:44:07 -0800 | [diff] [blame] | 244 | def adb_run(self, command, **kwargs): |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 245 | """Runs an adb command. |
| 246 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 247 | This command will launch on the test station. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 248 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 249 | Refer to _device_run method for docstring for parameters. |
| 250 | """ |
Gilad Arnold | f17f6fd | 2015-11-12 14:44:07 -0800 | [diff] [blame] | 251 | return self._device_run(ADB_CMD, command, **kwargs) |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 252 | |
| 253 | |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 254 | # pylint: disable=missing-docstring |
Gilad Arnold | f17f6fd | 2015-11-12 14:44:07 -0800 | [diff] [blame] | 255 | def fastboot_run(self, command, **kwargs): |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 256 | """Runs an fastboot command. |
| 257 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 258 | This command will launch on the test station. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 259 | |
| 260 | Refer to _device_run method for docstring for parameters. |
| 261 | """ |
Gilad Arnold | f17f6fd | 2015-11-12 14:44:07 -0800 | [diff] [blame] | 262 | return self._device_run(FASTBOOT_CMD, command, **kwargs) |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 263 | |
| 264 | |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 265 | def _device_run(self, function, command, shell=False, |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 266 | timeout=3600, ignore_status=False, ignore_timeout=False, |
| 267 | stdout=utils.TEE_TO_LOGS, stderr=utils.TEE_TO_LOGS, |
| 268 | connect_timeout=30, options='', stdin=None, verbose=True, |
| 269 | require_sudo=False, args=()): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 270 | """Runs a command named `function` on the test station. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 271 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 272 | This command will launch on the test station. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 273 | |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 274 | @param command: Command to run. |
| 275 | @param shell: If true the command runs in the adb shell otherwise if |
| 276 | False it will be passed directly to adb. For example |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 277 | reboot with shell=False will call 'adb reboot'. This |
| 278 | option only applies to function adb. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 279 | @param timeout: Time limit in seconds before attempting to |
| 280 | kill the running process. The run() function |
| 281 | will take a few seconds longer than 'timeout' |
| 282 | to complete if it has to kill the process. |
| 283 | @param ignore_status: Do not raise an exception, no matter |
| 284 | what the exit code of the command is. |
| 285 | @param ignore_timeout: Bool True if command timeouts should be |
| 286 | ignored. Will return None on command timeout. |
| 287 | @param stdout: Redirect stdout. |
| 288 | @param stderr: Redirect stderr. |
| 289 | @param connect_timeout: Connection timeout (in seconds) |
| 290 | @param options: String with additional ssh command options |
| 291 | @param stdin: Stdin to pass (a string) to the executed command |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 292 | @param require_sudo: True to require sudo to run the command. Default is |
| 293 | False. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 294 | @param args: Sequence of strings to pass as arguments to command by |
| 295 | quoting them in " and escaping their contents if |
| 296 | necessary. |
| 297 | |
| 298 | @returns a CMDResult object. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 299 | """ |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 300 | if function == ADB_CMD: |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 301 | serial = self.adb_serial |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 302 | elif function == FASTBOOT_CMD: |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 303 | serial = self.fastboot_serial |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 304 | else: |
| 305 | raise NotImplementedError('Mode %s is not supported' % function) |
| 306 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 307 | if function != ADB_CMD and shell: |
| 308 | raise error.CmdError('shell option is only applicable to `adb`.') |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 309 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 310 | cmd = '%s%s ' % ('sudo -n ' if require_sudo else '', function) |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 311 | |
| 312 | if serial: |
| 313 | cmd += '-s %s ' % serial |
| 314 | elif self._use_tcpip: |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 315 | cmd += '-s %s:5555 ' % self._device_hostname |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 316 | |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 317 | if shell: |
| 318 | cmd += '%s ' % SHELL_CMD |
| 319 | cmd += command |
| 320 | |
Roshan Pius | 58e5dd3 | 2015-10-16 15:16:42 -0700 | [diff] [blame] | 321 | if verbose: |
| 322 | logging.debug('Command: %s', cmd) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 323 | |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 324 | return self.teststation.run(cmd, timeout=timeout, |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 325 | ignore_status=ignore_status, |
| 326 | ignore_timeout=ignore_timeout, stdout_tee=stdout, |
| 327 | stderr_tee=stderr, options=options, stdin=stdin, |
| 328 | connect_timeout=connect_timeout, args=args) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 329 | |
| 330 | |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 331 | @label_decorator() |
Christopher Wiley | 8e6b08e | 2013-10-11 12:34:26 -0700 | [diff] [blame] | 332 | def get_board(self): |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 333 | """Determine the correct board label for the device. |
| 334 | |
| 335 | @returns a string representing this device's board. |
| 336 | """ |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 337 | board = self.run_output('getprop %s' % BOARD_FILE) |
| 338 | board_os = self.get_os_type() |
Kevin Cheng | 49f7b81 | 2015-12-15 15:24:23 -0800 | [diff] [blame] | 339 | return constants.BOARD_PREFIX + '-'.join([board_os, board]) |
Christopher Wiley | 8e6b08e | 2013-10-11 12:34:26 -0700 | [diff] [blame] | 340 | |
| 341 | |
Christopher Wiley | 08849d5 | 2013-11-22 08:57:58 -0800 | [diff] [blame] | 342 | def job_start(self): |
| 343 | """ |
| 344 | Disable log collection on adb_hosts. |
| 345 | |
| 346 | TODO(sbasi): crbug.com/305427 |
Christopher Wiley | 08849d5 | 2013-11-22 08:57:58 -0800 | [diff] [blame] | 347 | """ |
| 348 | |
| 349 | |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 350 | def run(self, command, timeout=3600, ignore_status=False, |
| 351 | ignore_timeout=False, stdout_tee=utils.TEE_TO_LOGS, |
| 352 | stderr_tee=utils.TEE_TO_LOGS, connect_timeout=30, options='', |
Roshan Pius | 58e5dd3 | 2015-10-16 15:16:42 -0700 | [diff] [blame] | 353 | stdin=None, verbose=True, args=()): |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 354 | """Run a command on the adb device. |
| 355 | |
| 356 | The command given will be ran directly on the adb device; for example |
| 357 | 'ls' will be ran as: 'abd shell ls' |
| 358 | |
| 359 | @param command: The command line string. |
| 360 | @param timeout: Time limit in seconds before attempting to |
| 361 | kill the running process. The run() function |
| 362 | will take a few seconds longer than 'timeout' |
| 363 | to complete if it has to kill the process. |
| 364 | @param ignore_status: Do not raise an exception, no matter |
| 365 | what the exit code of the command is. |
| 366 | @param ignore_timeout: Bool True if command timeouts should be |
| 367 | ignored. Will return None on command timeout. |
| 368 | @param stdout_tee: Redirect stdout. |
| 369 | @param stderr_tee: Redirect stderr. |
| 370 | @param connect_timeout: Connection timeout (in seconds). |
| 371 | @param options: String with additional ssh command options. |
| 372 | @param stdin: Stdin to pass (a string) to the executed command |
| 373 | @param args: Sequence of strings to pass as arguments to command by |
| 374 | quoting them in " and escaping their contents if |
| 375 | necessary. |
| 376 | |
| 377 | @returns A CMDResult object or None if the call timed out and |
| 378 | ignore_timeout is True. |
| 379 | |
| 380 | @raises AutoservRunError: If the command failed. |
| 381 | @raises AutoservSSHTimeout: Ssh connection has timed out. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 382 | """ |
Filipe Brandenburger | 68a8007 | 2015-07-14 10:39:33 -0700 | [diff] [blame] | 383 | command = ('"%s; echo %s:\$?"' % |
| 384 | (utils.sh_escape(command), CMD_OUTPUT_PREFIX)) |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 385 | result = self.adb_run( |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 386 | command, shell=True, timeout=timeout, |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 387 | ignore_status=ignore_status, ignore_timeout=ignore_timeout, |
| 388 | stdout=stdout_tee, stderr=stderr_tee, |
| 389 | connect_timeout=connect_timeout, options=options, stdin=stdin, |
Roshan Pius | 58e5dd3 | 2015-10-16 15:16:42 -0700 | [diff] [blame] | 390 | verbose=verbose, args=args) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 391 | if not result: |
| 392 | # In case of timeouts. |
| 393 | return None |
| 394 | |
| 395 | parse_output = re.match(CMD_OUTPUT_REGEX, result.stdout) |
Roshan Pius | 5ba5d18 | 2015-10-28 09:19:41 -0700 | [diff] [blame] | 396 | if not parse_output and not ignore_status: |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 397 | raise error.AutoservRunError( |
Roshan Pius | 5ba5d18 | 2015-10-28 09:19:41 -0700 | [diff] [blame] | 398 | 'Failed to parse the exit code for command: %s' % |
| 399 | command, result) |
| 400 | elif parse_output: |
| 401 | result.stdout = parse_output.group('OUTPUT') |
| 402 | result.exit_status = int(parse_output.group('EXIT_CODE')) |
| 403 | if result.exit_status != 0 and not ignore_status: |
| 404 | raise error.AutoservRunError(command, result) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 405 | return result |
| 406 | |
| 407 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 408 | def wait_up(self, timeout=DEFAULT_WAIT_UP_TIME_SECONDS, command=ADB_CMD): |
| 409 | """Wait until the remote host is up or the timeout expires. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 410 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 411 | Overrides wait_down from AbstractSSHHost. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 412 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 413 | @param timeout: Time limit in seconds before returning even if the host |
| 414 | is not up. |
| 415 | @param command: The command used to test if a device is up, i.e., |
| 416 | accessible by the given command. Default is set to `adb`. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 417 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 418 | @returns True if the host was found to be up before the timeout expires, |
| 419 | False otherwise. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 420 | """ |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 421 | @retry.retry(error.TimeoutException, timeout_min=timeout/60.0, |
| 422 | delay_sec=1) |
| 423 | def _wait_up(): |
| 424 | if not self.is_up(command=command): |
| 425 | raise error.TimeoutException('Device is still down.') |
| 426 | return True |
| 427 | |
| 428 | try: |
| 429 | _wait_up() |
| 430 | logging.debug('Host %s is now up, and can be accessed by %s.', |
| 431 | self.hostname, command) |
| 432 | return True |
| 433 | except error.TimeoutException: |
| 434 | logging.debug('Host %s is still down after waiting %d seconds', |
| 435 | self.hostname, timeout) |
| 436 | return False |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 437 | |
| 438 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 439 | def wait_down(self, timeout=DEFAULT_WAIT_DOWN_TIME_SECONDS, |
| 440 | warning_timer=None, old_boot_id=None, command=ADB_CMD): |
| 441 | """Wait till the host goes down, i.e., not accessible by given command. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 442 | |
| 443 | Overrides wait_down from AbstractSSHHost. |
| 444 | |
| 445 | @param timeout: Time in seconds to wait for the host to go down. |
| 446 | @param warning_timer: Time limit in seconds that will generate |
| 447 | a warning if the host is not down yet. |
| 448 | Currently ignored. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 449 | @param old_boot_id: Not applicable for adb_host. |
| 450 | @param command: `adb`, test if the device can be accessed by adb |
| 451 | command, or `fastboot`, test if the device can be accessed by |
| 452 | fastboot command. Default is set to `adb`. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 453 | |
| 454 | @returns True if the device goes down before the timeout, False |
| 455 | otherwise. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 456 | """ |
| 457 | @retry.retry(error.TimeoutException, timeout_min=timeout/60.0, |
| 458 | delay_sec=1) |
| 459 | def _wait_down(): |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 460 | if self.is_up(command=command): |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 461 | raise error.TimeoutException('Device is still up.') |
| 462 | return True |
| 463 | |
| 464 | try: |
| 465 | _wait_down() |
| 466 | logging.debug('Host %s is now down', self.hostname) |
| 467 | return True |
| 468 | except error.TimeoutException: |
| 469 | logging.debug('Host %s is still up after waiting %d seconds', |
| 470 | self.hostname, timeout) |
| 471 | return False |
| 472 | |
| 473 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 474 | def reboot(self): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 475 | """Reboot the android device via adb. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 476 | |
| 477 | @raises AutoservRebootError if reboot failed. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 478 | """ |
| 479 | # Not calling super.reboot() as we want to reboot the ADB device not |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 480 | # the test station we are running ADB on. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 481 | self.adb_run('reboot', timeout=10, ignore_timeout=True) |
| 482 | if not self.wait_down(): |
| 483 | raise error.AutoservRebootError( |
| 484 | 'ADB Device is still up after reboot') |
| 485 | if not self.wait_up(): |
| 486 | raise error.AutoservRebootError( |
| 487 | 'ADB Device failed to return from reboot.') |
Roshan Pius | 4d7540c | 2015-12-16 13:30:32 -0800 | [diff] [blame] | 488 | self._reset_adbd_connection() |
Roshan Pius | 50c1f9c | 2015-11-30 11:37:49 -0800 | [diff] [blame] | 489 | |
| 490 | |
Ralph Nathan | b45eb67 | 2015-11-18 20:04:39 -0800 | [diff] [blame] | 491 | def remount(self): |
| 492 | """Remounts paritions on the device read-write. |
| 493 | |
| 494 | Specifically, the /system, /vendor (if present) and /oem (if present) |
| 495 | partitions on the device are remounted read-write. |
| 496 | """ |
Ralph Nathan | b45eb67 | 2015-11-18 20:04:39 -0800 | [diff] [blame] | 497 | self.adb_run('remount') |
| 498 | |
| 499 | |
Kevin Cheng | 549beb4 | 2015-11-18 11:42:25 -0800 | [diff] [blame] | 500 | @staticmethod |
| 501 | def parse_device_serials(devices_output): |
| 502 | """Return a list of parsed serials from the output. |
| 503 | |
| 504 | @param devices_output: Output from either an adb or fastboot command. |
| 505 | |
| 506 | @returns List of device serials |
| 507 | """ |
| 508 | devices = [] |
| 509 | for line in devices_output.splitlines(): |
| 510 | match = re.search(DEVICE_FINDER_REGEX, line) |
| 511 | if match: |
| 512 | serial = match.group('SERIAL') |
| 513 | if serial == DEVICE_NO_SERIAL_MSG or re.match(r'^\?+$', serial): |
| 514 | serial = DEVICE_NO_SERIAL_TAG |
| 515 | logging.debug('Found Device: %s', serial) |
| 516 | devices.append(serial) |
| 517 | return devices |
| 518 | |
| 519 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 520 | def _get_devices(self, use_adb): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 521 | """Get a list of devices currently attached to the test station. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 522 | |
| 523 | @params use_adb: True to get adb accessible devices. Set to False to |
| 524 | get fastboot accessible devices. |
| 525 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 526 | @returns a list of devices attached to the test station. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 527 | """ |
| 528 | if use_adb: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 529 | result = self.adb_run('devices') |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 530 | else: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 531 | result = self.fastboot_run('devices') |
Kevin Cheng | 549beb4 | 2015-11-18 11:42:25 -0800 | [diff] [blame] | 532 | return self.parse_device_serials(result.stdout) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 533 | |
| 534 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 535 | def adb_devices(self): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 536 | """Get a list of devices currently attached to the test station and |
| 537 | accessible with the adb command.""" |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 538 | devices = self._get_devices(use_adb=True) |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 539 | if self.adb_serial is None and len(devices) > 1: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 540 | raise error.AutoservError( |
| 541 | 'Not given ADB serial but multiple devices detected') |
| 542 | return devices |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 543 | |
| 544 | |
| 545 | def fastboot_devices(self): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 546 | """Get a list of devices currently attached to the test station and |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 547 | accessible by fastboot command. |
| 548 | """ |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 549 | devices = self._get_devices(use_adb=False) |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 550 | if self.fastboot_serial is None and len(devices) > 1: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 551 | raise error.AutoservError( |
| 552 | 'Not given fastboot serial but multiple devices detected') |
| 553 | return devices |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 554 | |
| 555 | |
| 556 | def is_up(self, timeout=0, command=ADB_CMD): |
| 557 | """Determine if the specified adb device is up with expected mode. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 558 | |
| 559 | @param timeout: Not currently used. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 560 | @param command: `adb`, the device can be accessed by adb command, |
| 561 | or `fastboot`, the device can be accessed by fastboot command. |
| 562 | Default is set to `adb`. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 563 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 564 | @returns True if the device is detectable by given command, False |
| 565 | otherwise. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 566 | |
| 567 | """ |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 568 | if command == ADB_CMD: |
| 569 | devices = self.adb_devices() |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 570 | serial = self.adb_serial |
Kris Rambish | de8f9d1 | 2015-12-16 12:42:41 -0800 | [diff] [blame] | 571 | # ADB has a device state, if the device is not online, no |
| 572 | # subsequent ADB command will complete. |
| 573 | if len(devices) == 0 or not self.is_device_ready(): |
| 574 | logging.debug('Waiting for device to enter the ready state.') |
| 575 | return False |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 576 | elif command == FASTBOOT_CMD: |
| 577 | devices = self.fastboot_devices() |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 578 | serial = self.fastboot_serial |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 579 | else: |
Gilad Arnold | 2cfa552 | 2015-10-30 13:58:02 -0700 | [diff] [blame] | 580 | raise NotImplementedError('Mode %s is not supported' % command) |
| 581 | |
| 582 | return bool(devices and (not serial or serial in devices)) |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 583 | |
| 584 | |
| 585 | def close(self): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 586 | """Close the ADBHost object. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 587 | |
| 588 | Called as the test ends. Will return the device to USB mode and kill |
| 589 | the ADB server. |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 590 | """ |
| 591 | if self._use_tcpip: |
| 592 | # Return the device to usb mode. |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 593 | self.adb_run('usb') |
Christopher Wiley | 08849d5 | 2013-11-22 08:57:58 -0800 | [diff] [blame] | 594 | # TODO(sbasi) Originally, we would kill the server after each test to |
| 595 | # reduce the opportunity for bad server state to hang around. |
| 596 | # Unfortunately, there is a period of time after each kill during which |
| 597 | # the Android device becomes unusable, and if we start the next test |
| 598 | # too quickly, we'll get an error complaining about no ADB device |
| 599 | # attached. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 600 | #self.adb_run('kill-server') |
Roshan Pius | 3994260 | 2015-12-17 13:42:07 -0800 | [diff] [blame] | 601 | # |close| the associated teststation as well. |
| 602 | self.teststation.close() |
Simran Basi | 431010f | 2013-09-04 10:42:41 -0700 | [diff] [blame] | 603 | return super(ADBHost, self).close() |
Kris Rambish | 60461dc | 2014-03-11 11:10:18 -0700 | [diff] [blame] | 604 | |
| 605 | |
| 606 | def syslog(self, message, tag='autotest'): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 607 | """Logs a message to syslog on the device. |
Kris Rambish | 60461dc | 2014-03-11 11:10:18 -0700 | [diff] [blame] | 608 | |
| 609 | @param message String message to log into syslog |
| 610 | @param tag String tag prefix for syslog |
| 611 | |
| 612 | """ |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 613 | self.run('log -t "%s" "%s"' % (tag, message)) |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 614 | |
| 615 | |
| 616 | def get_autodir(self): |
| 617 | """Return the directory to install autotest for client side tests.""" |
| 618 | return '/data/autotest' |
| 619 | |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 620 | |
Kris Rambish | de8f9d1 | 2015-12-16 12:42:41 -0800 | [diff] [blame] | 621 | def is_device_ready(self): |
| 622 | """Return the if the device is ready for ADB commands.""" |
| 623 | dev_state = self.adb_run('get-state').stdout.strip() |
| 624 | logging.debug('Current device state: %s', dev_state) |
| 625 | return dev_state == 'device' |
| 626 | |
| 627 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 628 | def verify_connectivity(self): |
| 629 | """Verify we can connect to the device.""" |
Kris Rambish | de8f9d1 | 2015-12-16 12:42:41 -0800 | [diff] [blame] | 630 | if not self.is_device_ready(): |
| 631 | raise error.AutoservHostError('device state is not in the ' |
| 632 | '\'device\' state.') |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 633 | |
| 634 | |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 635 | def verify_software(self): |
| 636 | """Verify working software on an adb_host. |
| 637 | |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 638 | TODO (crbug.com/532222): Actually implement this method. |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 639 | """ |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 640 | # Check if adb and fastboot are present. |
| 641 | self.teststation.run('which adb') |
| 642 | self.teststation.run('which fastboot') |
| 643 | self.teststation.run('which unzip') |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 644 | |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 645 | |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 646 | def verify_job_repo_url(self, tag=''): |
| 647 | """Make sure job_repo_url of this host is valid. |
| 648 | |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 649 | TODO (crbug.com/532223): Actually implement this method. |
Simran Basi | d3ba3fb | 2015-09-11 14:35:07 -0700 | [diff] [blame] | 650 | |
| 651 | @param tag: The tag from the server job, in the format |
| 652 | <job_id>-<user>/<hostname>, or <hostless> for a server job. |
| 653 | """ |
| 654 | return |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 655 | |
| 656 | |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 657 | def send_file(self, source, dest, delete_dest=False, |
| 658 | preserve_symlinks=False): |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 659 | """Copy files from the drone to the device. |
| 660 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 661 | Just a note, there is the possibility the test station is localhost |
| 662 | which makes some of these steps redundant (e.g. creating tmp dir) but |
| 663 | that scenario will undoubtedly be a development scenario (test station |
| 664 | is also the moblab) and not the typical live test running scenario so |
| 665 | the redundancy I think is harmless. |
| 666 | |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 667 | @param source: The file/directory on the drone to send to the device. |
| 668 | @param dest: The destination path on the device to copy to. |
| 669 | @param delete_dest: A flag set to choose whether or not to delete |
| 670 | dest on the device if it exists. |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 671 | @param preserve_symlinks: Controls if symlinks on the source will be |
| 672 | copied as such on the destination or |
| 673 | transformed into the referenced |
| 674 | file/directory. |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 675 | """ |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 676 | # If we need to preserve symlinks, let's check if the source is a |
| 677 | # symlink itself and if so, just create it on the device. |
| 678 | if preserve_symlinks: |
| 679 | symlink_target = None |
| 680 | try: |
| 681 | symlink_target = os.readlink(source) |
| 682 | except OSError: |
| 683 | # Guess it's not a symlink. |
| 684 | pass |
| 685 | |
| 686 | if symlink_target is not None: |
| 687 | # Once we create the symlink, let's get out of here. |
| 688 | self.run('ln -s %s %s' % (symlink_target, dest)) |
| 689 | return |
| 690 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 691 | # Stage the files on the test station. |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 692 | tmp_dir = self.teststation.get_tmp_dir() |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 693 | src_path = os.path.join(tmp_dir, os.path.basename(dest)) |
| 694 | # Now copy the file over to the test station so you can reference the |
| 695 | # file in the push command. |
| 696 | self.teststation.send_file(source, src_path, |
| 697 | preserve_symlinks=preserve_symlinks) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 698 | |
| 699 | if delete_dest: |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 700 | self.run('rm -rf %s' % dest) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 701 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 702 | self.adb_run('push %s %s' % (src_path, dest)) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 703 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 704 | # Cleanup the test station. |
| 705 | try: |
| 706 | self.teststation.run('rm -rf %s' % tmp_dir) |
| 707 | except (error.AutoservRunError, error.AutoservSSHTimeout) as e: |
| 708 | logging.warn('failed to remove dir %s: %s', tmp_dir, e) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 709 | |
| 710 | |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 711 | def _get_file_info(self, dest): |
| 712 | """Get permission and possible symlink info about file on the device. |
| 713 | |
| 714 | These files are on the device so we only have shell commands (via adb) |
| 715 | to get the info we want. We'll use 'ls' to get it all. |
| 716 | |
| 717 | @param dest: File to get info about. |
| 718 | |
| 719 | @returns a dict of the file permissions and symlink. |
| 720 | """ |
Kevin Cheng | aaabd0c | 2015-11-10 16:05:04 -0800 | [diff] [blame] | 721 | # Grab file info. |
| 722 | file_info = self.run_output('ls -l %s' % dest) |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 723 | symlink = None |
| 724 | perms = 0 |
| 725 | match = re.match(FILE_INFO_REGEX, file_info) |
| 726 | if match: |
| 727 | # Check if it's a symlink and grab the linked dest if it is. |
| 728 | if match.group('TYPE') == 'l': |
| 729 | symlink_match = re.match(FILE_SYMLINK_REGEX, file_info) |
| 730 | if symlink_match: |
| 731 | symlink = symlink_match.group('SYMLINK') |
| 732 | |
| 733 | # Set the perms. |
| 734 | for perm, perm_flag in zip(match.group('PERMS'), FILE_PERMS_FLAGS): |
| 735 | if perm != '-': |
| 736 | perms |= perm_flag |
| 737 | |
| 738 | return {'perms': perms, |
| 739 | 'symlink': symlink} |
| 740 | |
| 741 | |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 742 | def get_file(self, source, dest, delete_dest=False, preserve_perm=True, |
| 743 | preserve_symlinks=False): |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 744 | """Copy files from the device to the drone. |
| 745 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 746 | Just a note, there is the possibility the test station is localhost |
| 747 | which makes some of these steps redundant (e.g. creating tmp dir) but |
| 748 | that scenario will undoubtedly be a development scenario (test station |
| 749 | is also the moblab) and not the typical live test running scenario so |
| 750 | the redundancy I think is harmless. |
| 751 | |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 752 | @param source: The file/directory on the device to copy back to the |
| 753 | drone. |
| 754 | @param dest: The destination path on the drone to copy to. |
| 755 | @param delete_dest: A flag set to choose whether or not to delete |
| 756 | dest on the drone if it exists. |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 757 | @param preserve_perm: Tells get_file() to try to preserve the sources |
| 758 | permissions on files and dirs. |
| 759 | @param preserve_symlinks: Try to preserve symlinks instead of |
| 760 | transforming them into files/dirs on copy. |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 761 | """ |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 762 | # Stage the files on the test station. |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 763 | tmp_dir = self.teststation.get_tmp_dir() |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 764 | dest_path = os.path.join(tmp_dir, os.path.basename(source)) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 765 | |
| 766 | if delete_dest: |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 767 | self.teststation.run('rm -rf %s' % dest) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 768 | |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 769 | source_info = {} |
| 770 | if preserve_symlinks or preserve_perm: |
| 771 | source_info = self._get_file_info(source) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 772 | |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 773 | # If we want to preserve symlinks, just create it here, otherwise pull |
| 774 | # the file off the device. |
| 775 | if preserve_symlinks and source_info['symlink']: |
| 776 | os.symlink(source_info['symlink'], dest) |
| 777 | else: |
Roshan Pius | 9556714 | 2015-11-03 09:56:08 -0800 | [diff] [blame] | 778 | self.adb_run('pull %s %s' % (source, dest_path)) |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 779 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 780 | # Copy over the file from the test station and clean up. |
| 781 | self.teststation.get_file(dest_path, dest) |
| 782 | try: |
| 783 | self.teststation.run('rm -rf %s' % tmp_dir) |
| 784 | except (error.AutoservRunError, error.AutoservSSHTimeout) as e: |
| 785 | logging.warn('failed to remove dir %s: %s', tmp_dir, e) |
Kevin Cheng | 92fe6ae | 2015-10-21 11:45:34 -0700 | [diff] [blame] | 786 | |
| 787 | if preserve_perm: |
| 788 | os.chmod(dest, source_info['perms']) |
Kevin Cheng | 018db35 | 2015-09-20 02:22:08 -0700 | [diff] [blame] | 789 | |
| 790 | |
| 791 | def get_release_version(self): |
| 792 | """Get the release version from the RELEASE_FILE on the device. |
| 793 | |
| 794 | @returns The release string in the RELEASE_FILE. |
| 795 | |
| 796 | """ |
| 797 | return self.run_output('getprop %s' % RELEASE_FILE) |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 798 | |
| 799 | |
| 800 | def get_tmp_dir(self, parent=''): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 801 | """Return a suitable temporary directory on the device. |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 802 | |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 803 | We ensure this is a subdirectory of /data/local/tmp. |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 804 | |
| 805 | @param parent: Parent directory of the returned tmp dir. |
| 806 | |
Kevin Cheng | 3a4a57a | 2015-09-30 12:09:50 -0700 | [diff] [blame] | 807 | @returns a path to the temp directory on the host. |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 808 | """ |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 809 | # TODO(kevcheng): Refactor the cleanup of tmp dir to be inherited |
| 810 | # from the parent. |
Simran Basi | 38f7ddf | 2015-09-18 12:25:03 -0700 | [diff] [blame] | 811 | if not parent.startswith(TMP_DIR): |
| 812 | parent = os.path.join(TMP_DIR, parent.lstrip(os.path.sep)) |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 813 | self.run('mkdir -p %s' % parent) |
| 814 | tmp_dir = self.run_output('mktemp -d -p %s' % parent) |
| 815 | self.tmp_dirs.append(tmp_dir) |
| 816 | return tmp_dir |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 817 | |
| 818 | |
| 819 | def get_platform(self): |
| 820 | """Determine the correct platform label for this host. |
| 821 | |
| 822 | TODO (crbug.com/536250): Figure out what we want to do for adb_host's |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 823 | get_platform. |
Simran Basi | 1b02376 | 2015-09-25 12:12:20 -0700 | [diff] [blame] | 824 | |
| 825 | @returns a string representing this host's platform. |
| 826 | """ |
| 827 | return 'adb' |
| 828 | |
| 829 | |
Gilad Arnold | a76bef0 | 2015-09-29 13:55:15 -0700 | [diff] [blame] | 830 | def get_os_type(self): |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 831 | """Get the OS type of the DUT, e.g., android or brillo. |
| 832 | """ |
| 833 | if not self._os_type: |
| 834 | if self.run_output('getprop ro.product.brand') == 'Brillo': |
| 835 | self._os_type = OS_TYPE_BRILLO |
| 836 | else: |
| 837 | self._os_type = OS_TYPE_ANDROID |
| 838 | |
| 839 | return self._os_type |
Gilad Arnold | e452b1f | 2015-10-06 08:48:34 -0700 | [diff] [blame] | 840 | |
| 841 | |
| 842 | def _forward(self, reverse, args): |
| 843 | """Execute a forwarding command. |
| 844 | |
| 845 | @param reverse: Whether this is reverse forwarding (Boolean). |
| 846 | @param args: List of command arguments. |
| 847 | """ |
| 848 | cmd = '%s %s' % ('reverse' if reverse else 'forward', ' '.join(args)) |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 849 | self.adb_run(cmd) |
Gilad Arnold | e452b1f | 2015-10-06 08:48:34 -0700 | [diff] [blame] | 850 | |
| 851 | |
| 852 | def add_forwarding(self, src, dst, reverse=False, rebind=True): |
| 853 | """Forward a port between the ADB host and device. |
| 854 | |
| 855 | Port specifications are any strings accepted as such by ADB, for |
| 856 | example 'tcp:8080'. |
| 857 | |
| 858 | @param src: Port specification to forward from. |
| 859 | @param dst: Port specification to forward to. |
| 860 | @param reverse: Do reverse forwarding from device to host (Boolean). |
| 861 | @param rebind: Allow rebinding an already bound port (Boolean). |
| 862 | """ |
| 863 | args = [] |
| 864 | if not rebind: |
| 865 | args.append('--no-rebind') |
| 866 | args += [src, dst] |
| 867 | self._forward(reverse, args) |
| 868 | |
| 869 | |
| 870 | def remove_forwarding(self, src=None, reverse=False): |
| 871 | """Removes forwarding on port. |
| 872 | |
| 873 | @param src: Port specification, or None to remove all forwarding. |
| 874 | @param reverse: Whether this is reverse forwarding (Boolean). |
| 875 | """ |
| 876 | args = [] |
| 877 | if src is None: |
| 878 | args.append('--remove-all') |
| 879 | else: |
| 880 | args += ['--remove', src] |
| 881 | self._forward(reverse, args) |
Roshan Pius | 58e5dd3 | 2015-10-16 15:16:42 -0700 | [diff] [blame] | 882 | |
| 883 | |
| 884 | def rpc_port_forward(self, port, local_port): |
| 885 | """ |
| 886 | Forwards a port securely through a tunnel process from the server |
| 887 | to the DUT for RPC server connection. |
| 888 | Add a 'ADB forward' rule to forward the RPC packets from the AdbHost |
| 889 | to the DUT. |
| 890 | |
| 891 | @param port: remote port on the DUT. |
| 892 | @param local_port: local forwarding port. |
| 893 | |
| 894 | @return: the tunnel process. |
| 895 | """ |
| 896 | self.add_forwarding('tcp:%s' % port, 'tcp:%s' % port) |
| 897 | return super(ADBHost, self).rpc_port_forward(port, local_port) |
| 898 | |
| 899 | |
| 900 | def rpc_port_disconnect(self, tunnel_proc, port): |
| 901 | """ |
| 902 | Disconnects a previously forwarded port from the server to the DUT for |
| 903 | RPC server connection. |
| 904 | Remove the previously added 'ADB forward' rule to forward the RPC |
| 905 | packets from the AdbHost to the DUT. |
| 906 | |
| 907 | @param tunnel_proc: the original tunnel process returned from |
| 908 | |rpc_port_forward|. |
| 909 | @param port: remote port on the DUT. |
| 910 | |
| 911 | """ |
| 912 | self.remove_forwarding('tcp:%s' % port) |
| 913 | super(ADBHost, self).rpc_port_disconnect(tunnel_proc, port) |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 914 | |
| 915 | |
| 916 | def ensure_bootloader_mode(self): |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 917 | """Ensure the device is in bootloader mode. |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 918 | |
| 919 | @raise: error.AutoservError if the device failed to reboot into |
| 920 | bootloader mode. |
| 921 | """ |
| 922 | if self.is_up(command=FASTBOOT_CMD): |
| 923 | return |
| 924 | self.adb_run('reboot bootloader') |
| 925 | if not self.wait_up(command=FASTBOOT_CMD): |
| 926 | raise error.AutoservError( |
| 927 | 'The device failed to reboot into bootloader mode.') |
| 928 | |
| 929 | |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 930 | def ensure_adb_mode(self, timeout=DEFAULT_WAIT_UP_TIME_SECONDS): |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 931 | """Ensure the device is up and can be accessed by adb command. |
| 932 | |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 933 | @param timeout: Time limit in seconds before returning even if the host |
| 934 | is not up. |
| 935 | |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 936 | @raise: error.AutoservError if the device failed to reboot into |
| 937 | adb mode. |
| 938 | """ |
| 939 | if self.is_up(): |
| 940 | return |
| 941 | self.fastboot_run('reboot') |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 942 | if not self.wait_up(timeout=timeout): |
Dan Shi | 6ea3e1c | 2015-10-28 15:19:04 -0700 | [diff] [blame] | 943 | raise error.AutoservError( |
| 944 | 'The device failed to reboot into adb mode.') |
Roshan Pius | 4d7540c | 2015-12-16 13:30:32 -0800 | [diff] [blame] | 945 | self._reset_adbd_connection() |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 946 | |
| 947 | |
| 948 | @classmethod |
| 949 | def _get_build_info_from_build_url(cls, build_url): |
| 950 | """Get the Android build information from the build url. |
| 951 | |
| 952 | @param build_url: The url to use for downloading Android artifacts. |
| 953 | pattern: http://$devserver:###/static/branch/target/build_id |
| 954 | |
| 955 | @return: A dictionary of build information, including keys: board, |
| 956 | branch, target, build_id. |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 957 | @raise AndroidInstallError: If failed to parse build_url. |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 958 | """ |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 959 | if not build_url: |
| 960 | raise AndroidInstallError('Need build_url to download image files.') |
| 961 | |
| 962 | try: |
| 963 | match = re.match(DEVSERVER_URL_REGEX, build_url) |
| 964 | return {'board': match.group('BOARD'), |
| 965 | 'branch': match.group('BRANCH'), |
| 966 | 'target': ('%s-%s' % (match.group('BOARD'), |
| 967 | match.group('BUILD_TYPE'))), |
| 968 | 'build_id': match.group('BUILD_ID')} |
| 969 | except (AttributeError, IndexError, ValueError) as e: |
| 970 | raise AndroidInstallError( |
| 971 | 'Failed to parse build url: %s\nError: %s' % (build_url, e)) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 972 | |
| 973 | |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 974 | @retry.retry(error.AutoservRunError, timeout_min=10) |
| 975 | def _download_file(self, build_url, file, dest_dir): |
| 976 | """Download the given file from the build url. |
| 977 | |
| 978 | @param build_url: The url to use for downloading Android artifacts. |
| 979 | pattern: http://$devserver:###/static/branch/target/build_id |
| 980 | @param file: Name of the file to be downloaded, e.g., boot.img. |
| 981 | @param dest_dir: Destination folder for the file to be downloaded to. |
| 982 | """ |
| 983 | src_url = os.path.join(build_url, file) |
| 984 | dest_file = os.path.join(dest_dir, file) |
| 985 | try: |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 986 | self.teststation.run('wget -q -O "%s" "%s"' % (dest_file, src_url)) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 987 | except: |
| 988 | # Delete the destination file if download failed. |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 989 | self.teststation.run('rm -f "%s"' % dest_file) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 990 | raise |
| 991 | |
| 992 | |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 993 | def stage_android_image_files(self, build_url): |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 994 | """Download required image files from the given build_url to a local |
| 995 | directory in the machine runs fastboot command. |
| 996 | |
| 997 | @param build_url: The url to use for downloading Android artifacts. |
| 998 | pattern: http://$devserver:###/static/branch/target/build_id |
| 999 | |
| 1000 | @return: Path to the directory contains image files. |
| 1001 | """ |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1002 | build_info = self._get_build_info_from_build_url(build_url) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1003 | |
| 1004 | zipped_image_file = ANDROID_IMAGE_FILE_FMT % build_info |
Kevin Cheng | 85e864a | 2015-11-30 11:49:34 -0800 | [diff] [blame] | 1005 | image_dir = self.teststation.get_tmp_dir() |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1006 | image_files = [zipped_image_file] + ANDROID_STANDALONE_IMAGES |
| 1007 | |
| 1008 | try: |
| 1009 | for image_file in image_files: |
| 1010 | self._download_file(build_url, image_file, image_dir) |
| 1011 | |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 1012 | self.teststation.run('unzip "%s/%s" -x -d "%s"' % |
| 1013 | (image_dir, zipped_image_file, image_dir)) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1014 | |
| 1015 | return image_dir |
| 1016 | except: |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 1017 | self.teststation.run('rm -rf %s' % image_dir) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1018 | raise |
| 1019 | |
| 1020 | |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1021 | def stage_brillo_image_files(self, build_url): |
| 1022 | """Download required brillo image files from the given build_url to a |
| 1023 | local directory in the machine runs fastboot command. |
| 1024 | |
| 1025 | @param build_url: The url to use for downloading Android artifacts. |
| 1026 | pattern: http://$devserver:###/static/branch/target/build_id |
| 1027 | |
| 1028 | @return: Path to the directory contains image files. |
| 1029 | """ |
| 1030 | build_info = self._get_build_info_from_build_url(build_url) |
| 1031 | |
| 1032 | zipped_image_file = ANDROID_IMAGE_FILE_FMT % build_info |
| 1033 | vendor_partitions_file = BRILLO_VENDOR_PARTITIONS_FILE_FMT % build_info |
| 1034 | image_dir = self.teststation.get_tmp_dir() |
| 1035 | image_files = [zipped_image_file, vendor_partitions_file] |
| 1036 | |
| 1037 | try: |
| 1038 | for image_file in image_files: |
| 1039 | self._download_file(build_url, image_file, image_dir) |
| 1040 | |
| 1041 | self.teststation.run('unzip "%s/%s" -x -d "%s"' % |
| 1042 | (image_dir, zipped_image_file, image_dir)) |
| 1043 | self.teststation.run('unzip "%s/%s" -x -d "%s"' % |
| 1044 | (image_dir, vendor_partitions_file, |
| 1045 | os.path.join(image_dir, 'vendor'))) |
| 1046 | return image_dir |
| 1047 | except: |
| 1048 | self.teststation.run('rm -rf %s' % image_dir) |
| 1049 | raise |
| 1050 | |
| 1051 | |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 1052 | def stage_build_for_install(self, build_name): |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1053 | """Stage a build on a devserver and return the build_url and devserver. |
| 1054 | |
| 1055 | @param build_name: a name like git-master/shamu-userdebug/2040953 |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1056 | |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1057 | @returns a tuple with an update URL like: |
| 1058 | http://172.22.50.122:8080/git-master/shamu-userdebug/2040953 |
| 1059 | and the devserver instance. |
| 1060 | """ |
| 1061 | logging.info('Staging build for installation: %s', build_name) |
Dan Shi | 216389c | 2015-12-22 11:03:06 -0800 | [diff] [blame] | 1062 | devserver = dev_server.AndroidBuildServer.resolve(build_name, |
| 1063 | self.hostname) |
Dan Shi | ba94353 | 2015-12-03 08:58:00 -0800 | [diff] [blame] | 1064 | build_name = devserver.translate(build_name) |
| 1065 | branch, target, build_id = utils.parse_android_build(build_name) |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1066 | is_brillo = self.get_os_type() == OS_TYPE_BRILLO |
| 1067 | devserver.trigger_download(target, build_id, branch, is_brillo, |
| 1068 | synchronous=False) |
Dan Shi | f2fd076 | 2015-12-01 10:09:32 -0800 | [diff] [blame] | 1069 | return '%s/static/%s' % (devserver.url(), build_name), devserver |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1070 | |
| 1071 | |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 1072 | def install_android(self, build_url, build_local_path=None, wipe=True, |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1073 | flash_all=False): |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1074 | """Install the Android DUT. |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1075 | |
| 1076 | Following are the steps used here to provision an android device: |
| 1077 | 1. If build_local_path is not set, download the image zip file, e.g., |
| 1078 | shamu-img-2284311.zip, unzip it. |
| 1079 | 2. Run fastboot to install following artifacts: |
| 1080 | bootloader, radio, boot, system, vendor(only if exists) |
| 1081 | |
| 1082 | Repair is not supported for Android devices yet. |
| 1083 | |
| 1084 | @param build_url: The url to use for downloading Android artifacts. |
| 1085 | pattern: http://$devserver:###/static/$build |
| 1086 | @param build_local_path: The path to a local folder that contains the |
| 1087 | image files needed to provision the device. Note that the folder |
| 1088 | is in the machine running adb command, rather than the drone. |
| 1089 | @param wipe: If true, userdata will be wiped before flashing. |
| 1090 | @param flash_all: If True, all img files found in img_path will be |
| 1091 | flashed. Otherwise, only boot and system are flashed. |
| 1092 | |
| 1093 | @raises AndroidInstallError if any error occurs. |
| 1094 | """ |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1095 | # If the build is not staged in local server yet, clean up the temp |
| 1096 | # folder used to store image files after the provision is completed. |
| 1097 | delete_build_folder = bool(not build_local_path) |
| 1098 | |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1099 | if not build_url and self._parser.options.image: |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 1100 | build_url, _ = self.stage_build_for_install( |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1101 | self._parser.options.image) |
| 1102 | |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1103 | try: |
| 1104 | # Download image files needed for provision to a local directory. |
| 1105 | if not build_local_path: |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1106 | build_local_path = self.stage_android_image_files(build_url) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1107 | |
| 1108 | # Device needs to be in bootloader mode for flashing. |
| 1109 | self.ensure_bootloader_mode() |
| 1110 | |
| 1111 | if wipe: |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 1112 | self.fastboot_run('-w') |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1113 | |
| 1114 | # Get all *.img file in the build_local_path. |
| 1115 | list_file_cmd = 'ls -d %s' % os.path.join(build_local_path, '*.img') |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 1116 | image_files = self.teststation.run( |
| 1117 | list_file_cmd).stdout.strip().split() |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1118 | images = dict([(os.path.basename(f), f) for f in image_files]) |
| 1119 | for image, image_file in images.items(): |
| 1120 | if image not in ANDROID_IMAGES: |
| 1121 | continue |
| 1122 | logging.info('Flashing %s...', image_file) |
| 1123 | self.fastboot_run('flash %s %s' % (image[:-4], image_file)) |
| 1124 | if image == ANDROID_BOOTLOADER: |
| 1125 | self.fastboot_run('reboot-bootloader') |
| 1126 | self.wait_up(command=FASTBOOT_CMD) |
| 1127 | except Exception as e: |
| 1128 | logging.error('Install Android build failed with error: %s', e) |
| 1129 | # Re-raise the exception with type of AndroidInstallError. |
| 1130 | raise AndroidInstallError, sys.exc_info()[1], sys.exc_info()[2] |
| 1131 | finally: |
| 1132 | if delete_build_folder: |
Kevin Cheng | 5f6ed6a | 2015-10-28 16:18:12 -0400 | [diff] [blame] | 1133 | self.teststation.run('rm -rf %s' % build_local_path) |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 1134 | timeout = (WAIT_UP_AFTER_WIPE_TIME_SECONDS if wipe else |
| 1135 | DEFAULT_WAIT_UP_TIME_SECONDS) |
| 1136 | self.ensure_adb_mode(timeout=timeout) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1137 | logging.info('Successfully installed Android build staged at %s.', |
| 1138 | build_url) |
| 1139 | |
| 1140 | |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1141 | def install_brillo(self, build_url, build_local_path=None): |
| 1142 | """Install the Brillo DUT. |
| 1143 | |
| 1144 | Following are the steps used here to provision an android device: |
| 1145 | 1. If build_local_path is not set, download the image zip file, e.g., |
| 1146 | dragonboard-img-123456.zip, unzip it. And download the vendor |
| 1147 | partition zip file, e.g., dragonboard-vendor_partitions-123456.zip, |
| 1148 | unzip it to vendor folder. |
| 1149 | 2. Run provision_device script to install OS images and vendor |
| 1150 | partitions. |
| 1151 | |
| 1152 | @param build_url: The url to use for downloading Android artifacts. |
| 1153 | pattern: http://$devserver:###/static/$build |
| 1154 | @param build_local_path: The path to a local folder that contains the |
| 1155 | image files needed to provision the device. Note that the folder |
| 1156 | is in the machine running adb command, rather than the drone. |
| 1157 | |
| 1158 | @raises AndroidInstallError if any error occurs. |
| 1159 | """ |
| 1160 | # If the build is not staged in local server yet, clean up the temp |
| 1161 | # folder used to store image files after the provision is completed. |
| 1162 | delete_build_folder = bool(not build_local_path) |
| 1163 | |
| 1164 | if not build_url and self._parser.options.image: |
Dan Shi | 50a412a | 2016-01-05 10:52:40 -0800 | [diff] [blame^] | 1165 | build_url, _ = self.stage_build_for_install( |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1166 | self._parser.options.image) |
| 1167 | |
| 1168 | try: |
| 1169 | # Download image files needed for provision to a local directory. |
| 1170 | if not build_local_path: |
| 1171 | build_local_path = self.stage_brillo_image_files(build_url) |
| 1172 | |
| 1173 | # Device needs to be in bootloader mode for flashing. |
| 1174 | self.ensure_bootloader_mode() |
| 1175 | |
| 1176 | # Run provision_device command to install image files and vendor |
| 1177 | # partitions. |
| 1178 | vendor_partition_dir = os.path.join(build_local_path, 'vendor') |
| 1179 | cmd = (BRILLO_PROVISION_CMD % |
| 1180 | {'os_image_dir': build_local_path, |
| 1181 | 'vendor_partition_dir': vendor_partition_dir}) |
| 1182 | self.teststation.run(cmd) |
| 1183 | except Exception as e: |
| 1184 | logging.error('Install Brillo build failed with error: %s', e) |
| 1185 | # Re-raise the exception with type of AndroidInstallError. |
| 1186 | raise AndroidInstallError, sys.exc_info()[1], sys.exc_info()[2] |
| 1187 | finally: |
| 1188 | if delete_build_folder: |
| 1189 | self.teststation.run('rm -rf %s' % build_local_path) |
| 1190 | self.ensure_adb_mode() |
| 1191 | logging.info('Successfully installed Android build staged at %s.', |
| 1192 | build_url) |
| 1193 | |
| 1194 | |
Dan Shi | e4e807b | 2015-12-10 09:04:03 -0800 | [diff] [blame] | 1195 | def machine_install(self, build_url=None, build_local_path=None, wipe=True, |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1196 | flash_all=False): |
| 1197 | """Install the DUT. |
| 1198 | |
| 1199 | @param build_url: The url to use for downloading Android artifacts. |
Dan Shi | 225b904 | 2015-11-18 10:25:21 -0800 | [diff] [blame] | 1200 | pattern: http://$devserver:###/static/$build. If build_url is |
| 1201 | set to None, the code may try _parser.options.image to do the |
| 1202 | installation. If none of them is set, machine_install will fail. |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1203 | @param build_local_path: The path to a local directory that contains the |
| 1204 | image files needed to provision the device. |
| 1205 | @param wipe: If true, userdata will be wiped before flashing. |
| 1206 | @param flash_all: If True, all img files found in img_path will be |
| 1207 | flashed. Otherwise, only boot and system are flashed. |
| 1208 | """ |
| 1209 | if self.get_os_type() == OS_TYPE_ANDROID: |
| 1210 | self.install_android( |
| 1211 | build_url=build_url, build_local_path=build_local_path, |
| 1212 | wipe=wipe, flash_all=flash_all) |
Dan Shi | ab99972 | 2015-12-04 14:27:08 -0800 | [diff] [blame] | 1213 | elif self.get_os_type() == OS_TYPE_BRILLO: |
| 1214 | self.install_brillo( |
| 1215 | build_url=build_url, build_local_path=build_local_path) |
Dan Shi | a287217 | 2015-10-31 01:16:51 -0700 | [diff] [blame] | 1216 | else: |
| 1217 | raise error.InstallError( |
| 1218 | 'Installation of os type %s is not supported.' % |
| 1219 | self.get_os_type()) |
Kevin Cheng | d19e6c6 | 2015-10-28 16:39:39 -0700 | [diff] [blame] | 1220 | |
| 1221 | |
| 1222 | def list_files_glob(self, path_glob): |
| 1223 | """Get a list of files on the device given glob pattern path. |
| 1224 | |
| 1225 | @param path_glob: The path glob that we want to return the list of |
| 1226 | files that match the glob. Relative paths will not work as |
| 1227 | expected. Supply an absolute path to get the list of files |
| 1228 | you're hoping for. |
| 1229 | |
| 1230 | @returns List of files that match the path_glob. |
| 1231 | """ |
| 1232 | # This is just in case path_glob has no path separator. |
| 1233 | base_path = os.path.dirname(path_glob) or '.' |
| 1234 | result = self.run('find %s -path \'%s\' -print' % |
| 1235 | (base_path, path_glob)) |
| 1236 | if result.exit_status != 0: |
| 1237 | return [] |
| 1238 | return result.stdout.splitlines() |