Skip to content

Commit

Permalink
Revert "Fix flake 8 style warnings"
Browse files Browse the repository at this point in the history
This reverts commit b8fd431 which
accidentally introduced a regression for some versions of python.

Signed-off-by: Brian Behlendorf <behlendorf1@llnl.gov>
Issue #7929
  • Loading branch information
behlendorf committed Sep 25, 2018
1 parent e897a23 commit a7165d7
Show file tree
Hide file tree
Showing 2 changed files with 35 additions and 37 deletions.
47 changes: 23 additions & 24 deletions tests/test-runner/bin/test-runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
# Copyright (c) 2017 Datto Inc.
#

import configparser
import ConfigParser
import os
import logging
from datetime import datetime
Expand All @@ -27,7 +27,7 @@
from subprocess import PIPE
from subprocess import Popen
from sys import argv
from sys import maxsize
from sys import maxint
from threading import Timer
from time import time

Expand Down Expand Up @@ -204,23 +204,23 @@ def run(self, options):
if needed. Run the command, and update the result object.
"""
if options.dryrun is True:
print(self)
print self
return

privcmd = self.update_cmd_privs(self.pathname, self.user)
try:
old = os.umask(0)
if not os.path.isdir(self.outputdir):
os.makedirs(self.outputdir, mode=0o777)
os.makedirs(self.outputdir, mode=0777)
os.umask(old)
except OSError as e:
except OSError, e:
fail('%s' % e)

self.result.starttime = time()
proc = Popen(privcmd, stdout=PIPE, stderr=PIPE)
# Allow a special timeout value of 0 to mean infinity
if int(self.timeout) == 0:
self.timeout = maxsize
self.timeout = maxint
t = Timer(int(self.timeout), self.kill_cmd, [proc])

try:
Expand Down Expand Up @@ -274,7 +274,7 @@ def log(self, logger, options):
logger.debug('%s%s%s' % (msga, pad, msgb))

lines = sorted(self.result.stdout + self.result.stderr,
key=lambda x: x[0])
cmp=lambda x, y: cmp(x[0], y[0]))

for dt, line in lines:
logger.debug('%s %s' % (dt.strftime("%H:%M:%S.%f ")[:11], line))
Expand Down Expand Up @@ -552,7 +552,7 @@ def read(self, logger, options):
in the 'DEFAULT' section. If the Test or TestGroup passes
verification, add it to the TestRun.
"""
config = configparser.RawConfigParser()
config = ConfigParser.RawConfigParser()
if not len(config.read(options.runfile)):
fail("Coulnd't read config file %s" % options.runfile)

Expand Down Expand Up @@ -608,7 +608,7 @@ def write(self, options):

defaults = dict([(prop, getattr(options, prop)) for prop, _ in
self.defaults])
config = configparser.RawConfigParser(defaults)
config = ConfigParser.RawConfigParser(defaults)

for test in sorted(self.tests.keys()):
config.add_section(test)
Expand Down Expand Up @@ -637,15 +637,14 @@ def complete_outputdirs(self):
"""
done = False
components = 0
tmp_dict = dict(list(self.tests.items()) +
list(self.testgroups.items()))
tmp_dict = dict(self.tests.items() + self.testgroups.items())
total = len(tmp_dict)
base = self.outputdir

while not done:
paths = []
components -= 1
for testfile in list(tmp_dict.keys()):
for testfile in tmp_dict.keys():
uniq = '/'.join(testfile.split('/')[components:]).lstrip('/')
if uniq not in paths:
paths.append(uniq)
Expand Down Expand Up @@ -673,9 +672,9 @@ def setup_logging(self, options):
if options.cmd is not 'wrconfig':
try:
old = os.umask(0)
os.makedirs(self.outputdir, mode=0o777)
os.makedirs(self.outputdir, mode=0777)
os.umask(old)
except OSError as e:
except OSError, e:
fail('%s' % e)
filename = os.path.join(self.outputdir, 'log')

Expand Down Expand Up @@ -708,8 +707,8 @@ def run(self, options):
if not os.path.exists(logsymlink):
os.symlink(self.outputdir, logsymlink)
else:
print('Could not make a symlink to directory %s' % (
self.outputdir))
print 'Could not make a symlink to directory %s' % (
self.outputdir)
iteration = 0
while iteration < options.iterations:
for test in sorted(self.tests.keys()):
Expand All @@ -722,17 +721,17 @@ def summary(self):
if Result.total is 0:
return 2

print('\nResults Summary')
for key in list(Result.runresults.keys()):
print '\nResults Summary'
for key in Result.runresults.keys():
if Result.runresults[key] is not 0:
print('%s\t% 4d' % (key, Result.runresults[key]))
print '%s\t% 4d' % (key, Result.runresults[key])

m, s = divmod(time() - self.starttime, 60)
h, m = divmod(m, 60)
print('\nRunning Time:\t%02d:%02d:%02d' % (h, m, s))
print('Percent passed:\t%.1f%%' % ((float(Result.runresults['PASS']) /
float(Result.total)) * 100))
print('Log directory:\t%s' % self.outputdir)
print '\nRunning Time:\t%02d:%02d:%02d' % (h, m, s)
print 'Percent passed:\t%.1f%%' % ((float(Result.runresults['PASS']) /
float(Result.total)) * 100)
print 'Log directory:\t%s' % self.outputdir

if Result.runresults['FAIL'] > 0:
return 1
Expand Down Expand Up @@ -805,7 +804,7 @@ def find_tests(testrun, options):


def fail(retstr, ret=1):
print('%s: %s' % (argv[0], retstr))
print '%s: %s' % (argv[0], retstr)
exit(ret)


Expand Down
25 changes: 12 additions & 13 deletions tests/test-runner/bin/zts-report.py
Original file line number Diff line number Diff line change
Expand Up @@ -277,15 +277,15 @@


def usage(s):
print(s)
print s
sys.exit(1)


def process_results(pathname):
try:
f = open(pathname)
except IOError as e:
print('Error opening file: %s' % e)
except IOError, e:
print 'Error opening file: %s' % e
sys.exit(1)

prefix = '/zfs-tests/tests/functional/'
Expand Down Expand Up @@ -316,14 +316,14 @@ def process_results(pathname):
results = process_results(sys.argv[1])

if summary['total'] == 0:
print("\n\nNo test results were found.")
print("Log directory: %s" % summary['logfile'])
print "\n\nNo test results were found."
print "Log directory: %s" % summary['logfile']
sys.exit(0)

expected = []
unexpected = []

for test in list(results.keys()):
for test in results.keys():
if results[test] == "PASS":
continue

Expand All @@ -340,7 +340,7 @@ def process_results(pathname):
else:
expected.append(test)

print("\nTests with results other than PASS that are expected:")
print "\nTests with results other than PASS that are expected:"
for test in sorted(expected):
issue_url = 'https://github.com/zfsonlinux/zfs/issues/'

Expand All @@ -366,21 +366,20 @@ def process_results(pathname):
continue
else:
expect = "UNKNOWN REASON"
print(" %s %s (%s)" % (results[test], test, expect))
print " %s %s (%s)" % (results[test], test, expect)

print("\nTests with result of PASS that are unexpected:")
print "\nTests with result of PASS that are unexpected:"
for test in sorted(known.keys()):
# We probably should not be silently ignoring the case
# where "test" is not in "results".
if test not in results or results[test] != "PASS":
continue
print(" %s %s (expected %s)" % (results[test], test,
known[test][0]))
print " %s %s (expected %s)" % (results[test], test, known[test][0])

print("\nTests with results other than PASS that are unexpected:")
print "\nTests with results other than PASS that are unexpected:"
for test in sorted(unexpected):
expect = "PASS" if test not in known else known[test][0]
print(" %s %s (expected %s)" % (results[test], test, expect))
print " %s %s (expected %s)" % (results[test], test, expect)

if len(unexpected) == 0:
sys.exit(0)
Expand Down

0 comments on commit a7165d7

Please sign in to comment.