Remove empty lines from the output while using --jobs.

gclient_utils.py

 # Copyright (c) 2010 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Generic utils."""
 
 import errno
 import logging
 import os
 import Queue
@@ skipping 344 matching lines @@
         obj = new_fileobj.output_buffers[index] = ['']
       else:
         obj = new_fileobj.output_buffers[index]
     finally:
       new_fileobj.lock.release()
 
     # Continue lockless.
     obj[0] += out
     while '\n' in obj[0]:
       line, remaining = obj[0].split('\n', 1)
-      new_fileobj.old_annotated_write('%d>%s\n' % (index, line))
+      if line:
+        new_fileobj.old_annotated_write('%d>%s\n' % (index, line))
       obj[0] = remaining
 
   def full_flush():
     """Flush buffered output."""
     orphans = []
     new_fileobj.lock.acquire()
     try:
       # Detect threads no longer existing.
       indexes = (getattr(t, 'index', None) for t in threading.enumerate())
       indexes = filter(None, indexes)
       for index in new_fileobj.output_buffers:
         if not index in indexes:
           orphans.append((index, new_fileobj.output_buffers[index][0]))
       for orphan in orphans:
         del new_fileobj.output_buffers[orphan[0]]
     finally:
       new_fileobj.lock.release()
 
     # Don't keep the lock while writting. Will append \n when it shouldn't.
     for orphan in orphans:
-      new_fileobj.old_annotated_write('%d>%s\n' % (orphan[0], orphan[1]))
+      if orphan[1]:
+        new_fileobj.old_annotated_write('%d>%s\n' % (orphan[0], orphan[1]))
 
   new_fileobj.write = annotated_write
   new_fileobj.full_flush = full_flush
   return new_fileobj
 
 
 def CheckCallAndFilter(args, stdout=None, filter_fn=None,
                        print_stdout=None, call_filter_on_first_line=False,
                        **kwargs):
   """Runs a command and calls back a filter function if needed.
@@ skipping 292 matching lines @@
         logging.info('Caught exception in thread %s' % self.item.name)
         logging.info(str(sys.exc_info()))
         work_queue.exceptions.put(sys.exc_info())
       logging.info('Task %s done' % self.item.name)
 
       work_queue.ready_cond.acquire()
       try:
         work_queue.ready_cond.notifyAll()
       finally:
         work_queue.ready_cond.release()