aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLuis A. Lozano <llozano@google.com>2016-12-15 23:34:01 -0800
committerChromeOS Commit Bot <chromeos-commit-bot@chromium.org>2017-01-11 09:02:36 +0000
commit70204447c3c103508f1b8e58d59a9b8f165e1c21 (patch)
treef58bf3f3ecf39ac69af7ab4cd7fdbb71cddd40e0
parent8316e3e6a41936eb14a609bb2b04987f13aedb36 (diff)
downloadtoolchain-utils-70204447c3c103508f1b8e58d59a9b8f165e1c21.tar.gz
Fix some lint warning in suite_runner*.
BUG=chromium:632113 TEST=run_tests Change-Id: I9fe070420153f5ae175db86961c95b1686ea7c8f Reviewed-on: https://chromium-review.googlesource.com/421107 Reviewed-by: Caroline Tice <cmtice@chromium.org> Commit-Queue: Luis Lozano <llozano@chromium.org> Tested-by: Luis Lozano <llozano@chromium.org>
-rw-r--r--crosperf/suite_runner.py56
-rwxr-xr-xcrosperf/suite_runner_unittest.py16
2 files changed, 36 insertions, 36 deletions
diff --git a/crosperf/suite_runner.py b/crosperf/suite_runner.py
index 8e9ef457..744d8bb3 100644
--- a/crosperf/suite_runner.py
+++ b/crosperf/suite_runner.py
@@ -50,10 +50,10 @@ class SuiteRunner(object):
log_level='verbose',
cmd_exec=None,
cmd_term=None):
- self._logger = logger_to_use
+ self.logger = logger_to_use
self.log_level = log_level
self._ce = cmd_exec or command_executer.GetCommandExecuter(
- self._logger, log_level=self.log_level)
+ self.logger, log_level=self.log_level)
self._ct = cmd_term or command_executer.CommandTerminator()
def Run(self, machine, label, benchmark, test_args, profiler_args):
@@ -70,15 +70,15 @@ class SuiteRunner(object):
ret_tup = self.Test_That_Run(machine, label, benchmark, test_args,
profiler_args)
if ret_tup[0] != 0:
- self._logger.LogOutput('benchmark %s failed. Retries left: %s' %
- (benchmark.name, benchmark.retries - i))
+ self.logger.LogOutput('benchmark %s failed. Retries left: %s' %
+ (benchmark.name, benchmark.retries - i))
elif i > 0:
- self._logger.LogOutput('benchmark %s succeded after %s retries' %
- (benchmark.name, i))
+ self.logger.LogOutput('benchmark %s succeded after %s retries' %
+ (benchmark.name, i))
break
else:
- self._logger.LogOutput('benchmark %s succeded on first try' %
- benchmark.name)
+ self.logger.LogOutput('benchmark %s succeded on first try' %
+ benchmark.name)
break
return ret_tup
@@ -92,8 +92,8 @@ class SuiteRunner(object):
'fi')
ret, freqs_str, _ = self._ce.CrosRunCommandWOutput(
get_avail_freqs, machine=machine_name, chromeos_root=chromeos_root)
- self._logger.LogFatalIf(ret, 'Could not get available frequencies '
- 'from machine: %s' % machine_name)
+ self.logger.LogFatalIf(ret, 'Could not get available frequencies '
+ 'from machine: %s' % machine_name)
freqs = freqs_str.split()
# We need to make sure that the frequencies are sorted in decreasing
# order
@@ -123,29 +123,29 @@ class SuiteRunner(object):
change_perf_gov = BASH_FOR.format(
list=CPUFREQ_DIRS + 'scaling_governor', body='echo performance > $f')
if self.log_level == 'average':
- self._logger.LogOutput('Pinning governor execution frequencies for %s' %
- machine_name)
+ self.logger.LogOutput('Pinning governor execution frequencies for %s' %
+ machine_name)
ret = self._ce.CrosRunCommand(
' && '.join(('set -e ', change_max_freq, change_min_freq,
change_perf_gov)),
machine=machine_name,
chromeos_root=chromeos_root)
- self._logger.LogFatalIf(ret, 'Could not pin frequencies on machine: %s' %
- machine_name)
+ self.logger.LogFatalIf(ret, 'Could not pin frequencies on machine: %s' %
+ machine_name)
def DecreaseWaitTime(self, machine_name, chromeos_root):
"""Change the ten seconds wait time for pagecycler to two seconds."""
FILE = '/usr/local/telemetry/src/tools/perf/page_sets/page_cycler_story.py'
ret = self._ce.CrosRunCommand(
'ls ' + FILE, machine=machine_name, chromeos_root=chromeos_root)
- self._logger.LogFatalIf(ret, 'Could not find {} on machine: {}'.format(
+ self.logger.LogFatalIf(ret, 'Could not find {} on machine: {}'.format(
FILE, machine_name))
if not ret:
sed_command = 'sed -i "s/_TTI_WAIT_TIME = 10/_TTI_WAIT_TIME = 2/g" '
ret = self._ce.CrosRunCommand(
sed_command + FILE, machine=machine_name, chromeos_root=chromeos_root)
- self._logger.LogFatalIf(ret, 'Could not modify {} on machine: {}'.format(
+ self.logger.LogFatalIf(ret, 'Could not modify {} on machine: {}'.format(
FILE, machine_name))
def RebootMachine(self, machine_name, chromeos_root):
@@ -164,7 +164,7 @@ class SuiteRunner(object):
if test_args:
options += ' %s' % test_args
if profiler_args:
- self._logger.LogFatal('test_that does not support profiler.')
+ self.logger.LogFatal('test_that does not support profiler.')
command = 'rm -rf /usr/local/autotest/results/*'
self._ce.CrosRunCommand(
command, machine=machine, chromeos_root=label.chromeos_root)
@@ -181,8 +181,8 @@ class SuiteRunner(object):
'%s %s %s') %
(TEST_THAT_PATH, autotest_dir, options, machine, benchmark.test_name))
if self.log_level != 'verbose':
- self._logger.LogOutput('Running test.')
- self._logger.LogOutput('CMD: %s' % command)
+ self.logger.LogOutput('Running test.')
+ self.logger.LogOutput('CMD: %s' % command)
# Use --no-ns-pid so that cros_sdk does not create a different
# process namespace and we can kill process created easily by
# their process group.
@@ -201,8 +201,8 @@ class SuiteRunner(object):
def Telemetry_Crosperf_Run(self, machine, label, benchmark, test_args,
profiler_args):
if not os.path.isdir(label.chrome_src):
- self._logger.LogFatal('Cannot find chrome src dir to'
- ' run telemetry: %s' % label.chrome_src)
+ self.logger.LogFatal('Cannot find chrome src dir to'
+ ' run telemetry: %s' % label.chrome_src)
# Check for and remove temporary file that may have been left by
# previous telemetry runs (and which might prevent this run from
@@ -246,8 +246,8 @@ class SuiteRunner(object):
CHROME_MOUNT_DIR,
CHROME_MOUNT_DIR))
if self.log_level != 'verbose':
- self._logger.LogOutput('Running test.')
- self._logger.LogOutput('CMD: %s' % cmd)
+ self.logger.LogOutput('Running test.')
+ self.logger.LogOutput('CMD: %s' % cmd)
return self._ce.ChrootRunCommandWOutput(
label.chromeos_root,
cmd,
@@ -257,14 +257,14 @@ class SuiteRunner(object):
def Telemetry_Run(self, machine, label, benchmark, profiler_args):
telemetry_run_path = ''
if not os.path.isdir(label.chrome_src):
- self._logger.LogFatal('Cannot find chrome src dir to' ' run telemetry.')
+ self.logger.LogFatal('Cannot find chrome src dir to' ' run telemetry.')
else:
telemetry_run_path = os.path.join(label.chrome_src, 'src/tools/perf')
if not os.path.exists(telemetry_run_path):
- self._logger.LogFatal('Cannot find %s directory.' % telemetry_run_path)
+ self.logger.LogFatal('Cannot find %s directory.' % telemetry_run_path)
if profiler_args:
- self._logger.LogFatal('Telemetry does not support the perf profiler.')
+ self.logger.LogFatal('Telemetry does not support the perf profiler.')
# Check for and remove temporary file that may have been left by
# previous telemetry runs (and which might prevent this run from
@@ -285,8 +285,8 @@ class SuiteRunner(object):
'{3} {4}'.format(telemetry_run_path, machine, rsa_key,
benchmark.test_name, benchmark.test_args))
if self.log_level != 'verbose':
- self._logger.LogOutput('Running test.')
- self._logger.LogOutput('CMD: %s' % cmd)
+ self.logger.LogOutput('Running test.')
+ self.logger.LogOutput('CMD: %s' % cmd)
return self._ce.RunCommandWOutput(cmd, print_to_console=False)
def CommandTerminator(self):
diff --git a/crosperf/suite_runner_unittest.py b/crosperf/suite_runner_unittest.py
index 3c36f3c2..b5a0439f 100755
--- a/crosperf/suite_runner_unittest.py
+++ b/crosperf/suite_runner_unittest.py
@@ -225,20 +225,20 @@ class SuiteRunnerTest(unittest.TestCase):
if machine or chroot:
pass
- def FakeLogMsg(fd, termfd, msg, flush):
+ def FakeLogMsg(fd, termfd, msg, flush=True):
if fd or termfd or msg or flush:
pass
save_log_msg = self.real_logger.LogMsg
self.real_logger.LogMsg = FakeLogMsg
- self.runner._logger = self.real_logger
+ self.runner.logger = self.real_logger
self.runner.RebootMachine = FakeRebootMachine
raised_exception = False
try:
self.runner.Test_That_Run('lumpy1.cros', self.mock_label,
self.test_that_bench, '', 'record -a -e cycles')
- except:
+ except SystemExit:
raised_exception = True
self.assertTrue(raised_exception)
@@ -299,7 +299,7 @@ class SuiteRunnerTest(unittest.TestCase):
@mock.patch.object(command_executer.CommandExecuter, 'RunCommandWOutput')
def test_telemetry_run(self, mock_runcmd, mock_exists, mock_isdir):
- def FakeLogMsg(fd, termfd, msg, flush):
+ def FakeLogMsg(fd, termfd, msg, flush=True):
if fd or termfd or msg or flush:
pass
@@ -308,7 +308,7 @@ class SuiteRunnerTest(unittest.TestCase):
mock_runcmd.return_value = 0
self.mock_cmd_exec.RunCommandWOutput = mock_runcmd
- self.runner._logger = self.real_logger
+ self.runner.logger = self.real_logger
profiler_args = ('--profiler=custom_perf --profiler_args=\'perf_options'
'="record -a -e cycles,instructions"\'')
@@ -318,7 +318,7 @@ class SuiteRunnerTest(unittest.TestCase):
try:
self.runner.Telemetry_Run('lumpy1.cros', self.mock_label,
self.telemetry_bench, '')
- except:
+ except SystemExit:
raises_exception = True
self.assertTrue(raises_exception)
@@ -328,7 +328,7 @@ class SuiteRunnerTest(unittest.TestCase):
try:
self.runner.Telemetry_Run('lumpy1.cros', self.mock_label,
self.telemetry_bench, '')
- except:
+ except SystemExit:
raises_exception = True
self.assertTrue(raises_exception)
@@ -338,7 +338,7 @@ class SuiteRunnerTest(unittest.TestCase):
try:
self.runner.Telemetry_Run('lumpy1.cros', self.mock_label,
self.telemetry_bench, profiler_args)
- except:
+ except SystemExit:
raises_exception = True
self.assertTrue(raises_exception)