Roll gtest-parallel.

third_party/gtest-parallel/gtest-parallel

 #!/usr/bin/env python2
 # Copyright 2013 Google Inc. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
@@ skipping 86 matching lines @@
   def __init__(self, out_file):
     self.__out_file = out_file
     self.__previous_line_was_transient = False
     self.__width = term_width(out_file)  # Line width, or None if not a tty.
   def transient_line(self, msg):
     if self.__width is None:
       self.__out_file.write(msg + "\n")
     else:
       self.__out_file.write("\r" + msg[:self.__width].ljust(self.__width))
       self.__previous_line_was_transient = True
-  def permanent_line(self, msg):
+  def flush_transient_output(self):
     if self.__previous_line_was_transient:
       self.__out_file.write("\n")
       self.__previous_line_was_transient = False
+  def permanent_line(self, msg):
+    self.flush_transient_output()
     self.__out_file.write(msg + "\n")
 
 stdout_lock = threading.Lock()
 
 class FilterFormat:
   if sys.stdout.isatty():
     # stdout needs to be unbuffered since the output is interactive.
     sys.stdout = os.fdopen(sys.stdout.fileno(), 'w', 0)
 
   out = Outputter(sys.stdout)
@@ skipping 41 matching lines @@
     assert prefix[-1] == ':'
     self.handle_meta(int(prefix[:-1]), output)
     stdout_lock.release()
 
   def end(self):
     if self.failures:
       self.out.permanent_line("FAILED TESTS (%d/%d):"
                               % (len(self.failures), self.total_tests))
       for (binary, test) in self.failures:
         self.out.permanent_line(" " + binary + ": " + test)
+    self.out.flush_transient_output()
 
 class RawFormat:
   def log(self, line):
     stdout_lock.acquire()
     sys.stdout.write(line + "\n")
     sys.stdout.flush()
     stdout_lock.release()
   def logfile(self, job_id, name):
     with open(self.outputs[job_id]) as f:
       for line in f.readlines():
@@ skipping 208 matching lines @@
 [t.join() for t in workers]
 logger.end()
 times.write_to_file(save_file)
 if options.print_test_times:
   ts = sorted((times.get_test_time(test_binary, test), test_binary, test)
               for (_, test_binary, test, _) in tests
               if times.get_test_time(test_binary, test) is not None)
   for (time_ms, test_binary, test) in ts:
     print "%8s %s" % ("%dms" % time_ms, test)
 sys.exit(-signal.SIGINT if sigint_handler.got_sigint() else exit_code)