50
50
from datetime import datetime
51
51
from Queue import Queue , Empty
52
52
53
+ try :
54
+ reduce # Python 2
55
+ except NameError : # Python 3
56
+ from functools import reduce
57
+
58
+ try :
59
+ xrange # Python 2
60
+ except NameError :
61
+ xrange = range # Python 3
62
+
53
63
logger = logging .getLogger ('testrunner' )
54
64
skip_regex = re .compile (r'# SKIP\S*\s+(.*)' , re .IGNORECASE )
55
65
@@ -110,9 +120,9 @@ def Run(self, tasks):
110
120
for thread in threads :
111
121
# Use a timeout so that signals (ctrl-c) will be processed.
112
122
thread .join (timeout = 10000000 )
113
- except (KeyboardInterrupt , SystemExit ), e :
123
+ except (KeyboardInterrupt , SystemExit ) as e :
114
124
self .shutdown_event .set ()
115
- except Exception , e :
125
+ except Exception as e :
116
126
# If there's an exception we schedule an interruption for any
117
127
# remaining threads.
118
128
self .shutdown_event .set ()
@@ -149,7 +159,7 @@ def RunSingle(self, parallel, thread_id):
149
159
output = case .Run ()
150
160
output .diagnostic .append ('ECONNREFUSED received, test retried' )
151
161
case .duration = (datetime .now () - start )
152
- except IOError , e :
162
+ except IOError as e :
153
163
return
154
164
if self .shutdown_event .is_set ():
155
165
return
@@ -600,7 +610,7 @@ def Win32SetErrorMode(mode):
600
610
prev_error_mode = SEM_INVALID_VALUE
601
611
try :
602
612
import ctypes
603
- prev_error_mode = ctypes .windll .kernel32 .SetErrorMode (mode );
613
+ prev_error_mode = ctypes .windll .kernel32 .SetErrorMode (mode )
604
614
except ImportError :
605
615
pass
606
616
return prev_error_mode
@@ -619,15 +629,15 @@ def KillTimedOutProcess(context, pid):
619
629
def RunProcess (context , timeout , args , ** rest ):
620
630
if context .verbose : print ("#" , " " .join (args ))
621
631
popen_args = args
622
- prev_error_mode = SEM_INVALID_VALUE ;
632
+ prev_error_mode = SEM_INVALID_VALUE
623
633
if utils .IsWindows ():
624
634
if context .suppress_dialogs :
625
635
# Try to change the error mode to avoid dialogs on fatal errors. Don't
626
636
# touch any existing error mode flags by merging the existing error mode.
627
637
# See http://blogs.msdn.com/oldnewthing/archive/2004/07/27/198410.aspx.
628
- error_mode = SEM_NOGPFAULTERRORBOX ;
629
- prev_error_mode = Win32SetErrorMode (error_mode );
630
- Win32SetErrorMode (error_mode | prev_error_mode );
638
+ error_mode = SEM_NOGPFAULTERRORBOX
639
+ prev_error_mode = Win32SetErrorMode (error_mode )
640
+ Win32SetErrorMode (error_mode | prev_error_mode )
631
641
632
642
faketty = rest .pop ('faketty' , False )
633
643
pty_out = rest .pop ('pty_out' )
@@ -696,7 +706,7 @@ def CheckedUnlink(name):
696
706
while True :
697
707
try :
698
708
os .unlink (name )
699
- except OSError , e :
709
+ except OSError as e :
700
710
# On Windows unlink() fails if another process (typically a virus scanner
701
711
# or the indexing service) has the file open. Those processes keep a
702
712
# file open for a short time only, so yield and try again; it'll succeed.
@@ -765,8 +775,8 @@ def disableCoreFiles():
765
775
else :
766
776
os .close (fd_out )
767
777
os .close (fd_err )
768
- output = file (outname ).read ()
769
- errors = file (errname ).read ()
778
+ output = open (outname ).read ()
779
+ errors = open (errname ).read ()
770
780
CheckedUnlink (outname )
771
781
CheckedUnlink (errname )
772
782
0 commit comments