blob: 1cfafeb1f318e3be90bae7be09c61062563090e3 [file] [log] [blame]
# Copyright (c) 2013 The Chromium OS Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.
# Expects to be run in an environment with sudo and no interactive password
# prompt, such as within the Chromium OS development chroot.
"""This file provides core logic for servo verify/repair process."""
import httplib
import logging
import socket
import time
import xmlrpclib
from autotest_lib.client.bin import utils
from autotest_lib.client.common_lib import error
from autotest_lib.client.common_lib import global_config
from autotest_lib.client.common_lib.cros import autoupdater
from autotest_lib.client.common_lib.cros import dev_server
from autotest_lib.client.common_lib.cros import retry
from autotest_lib.server import site_utils as server_site_utils
from autotest_lib.server.cros.servo import servo
from autotest_lib.server.hosts import ssh_host
from autotest_lib.site_utils.graphite import stats
from autotest_lib.site_utils.rpm_control_system import rpm_client
class ServoHostException(error.AutoservError):
"""This is the base class for exceptions raised by ServoHost."""
class ServoHostVerifyFailure(ServoHostException):
"""Raised when servo verification fails."""
class ServoHostRepairFailure(ServoHostException):
"""Raised when a repair method fails to repair a servo host."""
class ServoHostRepairMethodNA(ServoHostException):
"""Raised when a repair method is not applicable."""
class ServoHostRepairTotalFailure(ServoHostException):
"""Raised if all attempts to repair a servo host fail."""
def make_servo_hostname(dut_hostname):
"""Given a DUT's hostname, return the hostname of its servo.
@param dut_hostname: hostname of a DUT.
@return hostname of the DUT's servo.
host_parts = dut_hostname.split('.')
host_parts[0] = host_parts[0] + '-servo'
return '.'.join(host_parts)
class ServoHost(ssh_host.SSHHost):
"""Host class for a host that controls a servo, e.g. beaglebone."""
# Timeout for getting the value of 'pwr_button'.
# Timeout for rebooting servo host.
# Delay after rebooting for servod to become fully functional.
# Servod process name.
_timer = stats.Timer('servo_host')
def _initialize(self, servo_host='localhost', servo_port=9999,
*args, **dargs):
"""Initialize a ServoHost instance.
A ServoHost instance represents a host that controls a servo.
@param servo_host: Name of the host where the servod process
is running.
@param servo_port: Port the servod process is listening on.
super(ServoHost, self)._initialize(hostname=servo_host,
*args, **dargs)
self._is_in_lab = utils.host_is_in_lab_zone(self.hostname)
self._is_localhost = (self.hostname == 'localhost')
remote = 'http://%s:%s' % (self.hostname, servo_port)
self._servod_server = xmlrpclib.ServerProxy(remote)
# Commands on the servo host must be run by the superuser. Our account
# on Beaglebone is root, but locally we might be running as a
# different user. If so - `sudo ' will have to be added to the
# commands.
if self._is_localhost:
self._sudo_required = utils.system_output('id -u') != '0'
self._sudo_required = False
def is_in_lab(self):
"""Check whether the servo host is a lab device.
@returns: True if the servo host is in Cros Lab, otherwise False.
return self._is_in_lab
def is_localhost(self):
"""Checks whether the servo host points to localhost.
@returns: True if it points to localhost, otherwise False.
return self._is_localhost
def get_servod_server_proxy(self):
"""Return a proxy that can be used to communicate with servod server.
@returns: An xmlrpclib.ServerProxy that is connected to the servod
server on the host.
return self._servod_server
def get_wait_up_processes(self):
"""Get the list of local processes to wait for in wait_up.
Override get_wait_up_processes in
Wait for servod process to go up. Called by base class when
rebooting the device.
processes = [self.SERVOD_PROCESS]
return processes
def _is_cros_host(self):
"""Check if a servo host is running chromeos.
@return: True if the servo host is running chromeos.
False if it isn't, or we don't have enough information.
result ='grep -q CHROMEOS /etc/lsb-release',
ignore_status=True, timeout=10)
except (error.AutoservRunError, error.AutoservSSHTimeout):
return False
return result.exit_status == 0
def make_ssh_command(self, user='root', port=22, opts='', hosts_file=None,
connect_timeout=None, alive_interval=None):
"""Override default make_ssh_command to use tuned options.
Tuning changes:
- ConnectTimeout=30; maximum of 30 seconds allowed for an SSH
connection failure. Consistency with
- ServerAliveInterval=180; which causes SSH to ping connection every
180 seconds. In conjunction with ServerAliveCountMax ensures
that if the connection dies, Autotest will bail out quickly.
- ServerAliveCountMax=3; consistency with
- ConnectAttempts=4; reduce flakiness in connection errors;
consistency with
- UserKnownHostsFile=/dev/null; we don't care about the keys.
- SSH protocol forced to 2; needed for ServerAliveInterval.
@param user User name to use for the ssh connection.
@param port Port on the target host to use for ssh connection.
@param opts Additional options to the ssh command.
@param hosts_file Ignored.
@param connect_timeout Ignored.
@param alive_interval Ignored.
@returns: An ssh command with the requested settings.
base_command = ('/usr/bin/ssh -a -x %s -o StrictHostKeyChecking=no'
' -o UserKnownHostsFile=/dev/null -o BatchMode=yes'
' -o ConnectTimeout=30 -o ServerAliveInterval=180'
' -o ServerAliveCountMax=3 -o ConnectionAttempts=4'
' -o Protocol=2 -l %s -p %d')
return base_command % (opts, user, port)
def _make_scp_cmd(self, sources, dest):
"""Format scp command.
Given a list of source paths and a destination path, produces the
appropriate scp command for encoding it. Remote paths must be
pre-encoded. Overrides _make_scp_cmd in AbstractSSHHost
to allow additional ssh options.
@param sources: A list of source paths to copy from.
@param dest: Destination path to copy to.
@returns: An scp command that copies |sources| on local machine to
|dest| on the remote servo host.
command = ('scp -rq %s -o BatchMode=yes -o StrictHostKeyChecking=no '
'-o UserKnownHostsFile=/dev/null -P %d %s "%s"')
return command % (self.master_ssh_option,
self.port, ' '.join(sources), dest)
def run(self, command, timeout=3600, ignore_status=False,
stdout_tee=utils.TEE_TO_LOGS, stderr_tee=utils.TEE_TO_LOGS,
connect_timeout=30, options='', stdin=None, verbose=True, args=()):
"""Run a command on the servo host.
Extends method `run` in SSHHost. If the servo host is a remote device,
it will call `run` in SSHost without changing anything.
If the servo host is 'localhost', it will call utils.system_output.
@param command: The command line string.
@param timeout: Time limit in seconds before attempting to
kill the running process. The run() function
will take a few seconds longer than 'timeout'
to complete if it has to kill the process.
@param ignore_status: Do not raise an exception, no matter
what the exit code of the command is.
@param stdout_tee/stderr_tee: Where to tee the stdout/stderr.
@param connect_timeout: SSH connection timeout (in seconds)
Ignored if host is 'localhost'.
@param options: String with additional ssh command options
Ignored if host is 'localhost'.
@param stdin: Stdin to pass (a string) to the executed command.
@param verbose: Log the commands.
@param args: Sequence of strings to pass as arguments to command by
quoting them in " and escaping their contents if necessary.
@returns: A utils.CmdResult object.
@raises AutoservRunError if the command failed.
@raises AutoservSSHTimeout SSH connection has timed out. Only applies
when servo host is not 'localhost'.
run_args = {'command': command, 'timeout': timeout,
'ignore_status': ignore_status, 'stdout_tee': stdout_tee,
'stderr_tee': stderr_tee, 'stdin': stdin,
'verbose': verbose, 'args': args}
if self.is_localhost():
if self._sudo_required:
run_args['command'] = 'sudo -n %s' % command
except error.CmdError as e:
raise error.AutoservRunError('command execution error',
run_args['connect_timeout'] = connect_timeout
run_args['options'] = options
return super(ServoHost, self).run(**run_args)
def _check_servod(self):
"""A sanity check of the servod state."""
msg_prefix = 'Servod error: %s'
error_msg = None
timeout, _ = retry.timeout(
self._servod_server.get, args=('pwr_button', ),
if timeout:
error_msg = msg_prefix % 'Request timed out.'
except (socket.error, xmlrpclib.Error, httplib.BadStatusLine) as e:
error_msg = msg_prefix % e
if error_msg:
raise ServoHostVerifyFailure(error_msg)
def _check_servo_host_usb(self):
"""A sanity check of the USB device.
Sometimes the usb gets wedged due to a kernel bug on the beaglebone.
A symptom is the presence of /dev/sda without /dev/sda1. The check
here ensures that if /dev/sda exists, /dev/sda1 must also exist.
@raises ServoHostVerifyFailure if /dev/sda exists without /dev/sda1 on
the beaglebone.
# The following test exits with a non-zero code
# and raises AutoserverRunError if error is detected.'test ! -b /dev/sda -o -b /dev/sda1')
except (error.AutoservRunError, error.AutoservSSHTimeout) as e:
raise ServoHostVerifyFailure(
'USB sanity check on %s failed: %s' % (self.hostname, e))
def _update_image(self):
"""Update the image on the servo host, if needed.
This method does nothing for servo hosts that are not running chromeos.
If the host is running chromeos, and a newer image is available on the
devserver, trigger a download and apply it in the background. If an
update has already been downloaded and applied, reboot the servo host
into the new image. If update_engine_client is in the process of
applying an update that was triggered on a previous invocation, do
@raises dev_server.DevServerException: If all the devservers are down.
@raises site_utils.ParseBuildNameException: If the devserver returns
an invalid build name.
@raises autoupdater.ChromiumOSError: If something goes wrong in the
checking update engine client status or applying an update.
@raises AutoservRunError: If the update_engine_client isn't present on
the host, and the host is a cros_host.
#TODO(beeps): Remove this check once all servo hosts are using chromeos.
if not self._is_cros_host():'Not attempting an update, either %s is not running '
'chromeos or we cannot find enough information about '
'the host.', self.hostname)
update_branch = global_config.global_config.get_config_value(
'CROS', 'servo_builder')
ds = dev_server.ImageServer.resolve(self.hostname)
latest_build = ds.get_latest_build_in_server(target=update_branch)
# We might have just purged all the beaglebone builds on the devserver
# after having triggered a download the last time we verified this
# beaglebone, so we still need to reboot if necessary.
if latest_build is None:
logging.debug('Could not find any builds for %s on %s',
update_branch, ds.url())
url = ds.url()
latest_build_number = None
latest_build = '%s/%s' % (update_branch, latest_build)
latest_build_number = server_site_utils.ParseBuildName(
url = ds.get_update_url(latest_build)
updater = autoupdater.ChromiumOSUpdater(update_url=url, host=self)
current_build_number = updater.get_build_id()
status = updater.check_update_status()
if status == autoupdater.UPDATER_NEED_REBOOT:'Rebooting beaglebone host %s with build %s',
self.hostname, current_build_number)
kwargs = {
'reboot_cmd': ('((reboot & sleep 10; reboot -f &) '
'</dev/null >/dev/null 2>&1 &)'),
'fastsync': True,
'label': None,
'wait': True,
current_build_number = updater.get_build_id()'servo host %s back from reboot, with build %s',
self.hostname, current_build_number)
if status in autoupdater.UPDATER_PROCESSING_UPDATE:'servo host %s already processing an update, update '
'engine client status=%s', self.hostname, status)
elif (latest_build_number and
current_build_number != latest_build_number):'Using devserver url: %s to trigger update on '
'servo host %s, from %s to %s', url, self.hostname,
current_build_number, latest_build_number)
except autoupdater.RootFSUpdateError as e:
trigger_download_status = 'failed with %s' % str(e)
trigger_download_status = 'passed''Triggered download and update %s for %s, '
'update engine currently in status %s',
trigger_download_status, self.hostname,
else:'servo host %s does not require an update.',
def verify_software(self):
"""Update the servo host and verify it's in a good state.
It overrides the base class function for verify_software.
If an update is available, downloads and applies it. Then verifies:
1) Whether basic servo command can run successfully.
2) Whether USB is in a good state.
@raises ServoHostVerifyFailure if servo host does not pass the checks.
"""'Applying an update to the servo host, if necessary.')
self._update_image()'Verifying servo host %s with sanity checks.',
self._check_servo_host_usb()'Sanity checks pass on servo host %s', self.hostname)
def _repair_with_sysrq_reboot(self):
"""Reboot with magic SysRq key."""
reboot_cmd='echo "b" > /proc/sysrq-trigger &',
def has_power(self):
"""Return whether or not the servo host is powered by PoE."""
# TODO(fdeng): See
# For now, assume all servo hosts in the lab have power.
return self.is_in_lab()
def power_cycle(self):
"""Cycle power to this host via PoE if it is a lab device.
@raises ServoHostRepairFailure if it fails to power cycle the
servo host.
if self.has_power():
rpm_client.set_power(self.hostname, 'CYCLE')
except (socket.error, xmlrpclib.Error,
rpm_client.RemotePowerException) as e:
raise ServoHostRepairFailure(
'Power cycling %s failed: %s' % (self.hostname, e))
else:'Skipping power cycling, not a lab device.')
def _powercycle_to_repair(self):
"""Power cycle the servo host using PoE.
@raises ServoHostRepairFailure if it fails to fix the servo host.
@raises ServoHostRepairMethodNA if it does not support power.
if not self.has_power():
raise ServoHostRepairMethodNA('%s does not support power.' %
self.hostname)'Attempting repair via PoE powercycle.')
failed_cycles = 0
while not self.wait_up(timeout=self.REBOOT_TIMEOUT_SECS):
failed_cycles += 1
if failed_cycles >= self._MAX_POWER_CYCLE_ATTEMPTS:
raise ServoHostRepairFailure(
'Powercycled host %s %d times; device did not come back'
' online.' % (self.hostname, failed_cycles))
self.power_cycle()'Powercycling was successful after %d failures.',
# Allow some time for servod to get started.
def repair_full(self):
"""Attempt to repair servo host.
This overrides the base class function for repair.
Note if the host is not in Cros Lab, the repair procedure
will be skipped.
@raises ServoHostRepairTotalFailure if all attempts fail.
if not self.is_in_lab():
logging.warn('Skip repairing servo host %s: Not a lab device.',
return'Attempting to repair servo host %s.', self.hostname)
repair_funcs = [self._repair_with_sysrq_reboot,
errors = []
for repair_func in repair_funcs:
counter_prefix = 'servo_host_repair.%s.' % repair_func.__name__
stats.Counter(counter_prefix + 'SUCCEEDED').increment()
except ServoHostRepairMethodNA as e:
logging.warn('Repair method NA: %s', e)
stats.Counter(counter_prefix + 'RepairNA').increment()
except Exception as e:
logging.warn('Failed to repair servo: %s', e)
stats.Counter(counter_prefix + 'FAILED').increment()
raise ServoHostRepairTotalFailure(
'All attempts at repairing the servo failed:\n%s' %
def create_healthy_servo_object(self):
"""Create a servo.Servo object.
Create a servo.Servo object. If the servo host is in Cros Lab,
this method will first verify the servo host and attempt to repair it if
error is detected.
@raises ServoHostRepairTotalFailure if it fails to fix the servo host.
@raises AutoservSshPermissionDeniedError if the DUT is not ssh-able
due to permission error.
if self.is_in_lab():
except (error.AutoservSSHTimeout,
except error.AutoservSshPermissionDeniedError:
return servo.Servo(servo_host=self)