Merge github.com:grpc/grpc into connected-subchannel
diff --git a/tools/run_tests/jobset.py b/tools/run_tests/jobset.py
index fb80c8d..b8a180d 100755
--- a/tools/run_tests/jobset.py
+++ b/tools/run_tests/jobset.py
@@ -43,11 +43,23 @@
_DEFAULT_MAX_JOBS = 16 * multiprocessing.cpu_count()
_MAX_RESULT_SIZE = 8192
+def platform_string():
+ if platform.system() == 'Windows':
+ return 'windows'
+ elif platform.system()[:7] == 'MSYS_NT':
+ return 'windows'
+ elif platform.system() == 'Darwin':
+ return 'mac'
+ elif platform.system() == 'Linux':
+ return 'linux'
+ else:
+ return 'posix'
+
# setup a signal handler so that signal.pause registers 'something'
# when a child finishes
# not using futures and threading to avoid a dependency on subprocess32
-if platform.system() == 'Windows':
+if platform_string() == 'windows':
pass
else:
have_alarm = False
@@ -99,7 +111,7 @@
message.old_tag = tag
message.old_msg = msg
try:
- if platform.system() == 'Windows' or not sys.stdout.isatty():
+ if platform_string() == 'windows' or not sys.stdout.isatty():
if explanatory_text:
print explanatory_text
print '%s: %s' % (tag, msg)
@@ -361,10 +373,10 @@
self._running.remove(job)
if dead: return
if (not self._travis):
- rstr = '' if self._remaining is None else ', %d remaining' % self._remaining
- message('WAITING', '%d jobs running, %d complete, %d failed%s' % (
- len(self._running), self._completed, self._failures, rstr))
- if platform.system() == 'Windows':
+ rstr = '' if self._remaining is None else '%d queued, ' % self._remaining
+ message('WAITING', '%s%d jobs running, %d complete, %d failed' % (
+ rstr, len(self._running), self._completed, self._failures))
+ if platform_string() == 'windows':
time.sleep(0.1)
else:
global have_alarm