Add more flushes to gclient_utils

gclient_utils.py

 # Copyright (c) 2012 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 codecs
 import cStringIO
 import datetime
 import logging
@@ skipping 806 matching lines @@
         # We need to poll here otherwise Ctrl-C isn't processed.
         try:
           self.ready_cond.wait(10)
           # If we haven't printed to terminal for a while, but we have received
           # spew from a suprocess, let the user know we're still progressing.
           now = datetime.datetime.now()
           if (now - self.last_join > datetime.timedelta(seconds=60) and
               self.last_subproc_output > self.last_join):
             if self.progress:
               print >> sys.stdout, ''
+              sys.stdout.flush()
             elapsed = Elapsed()
             print >> sys.stdout, '[%s] Still working on:' % elapsed
+            sys.stdout.flush()
             for task in self.running:
               print >> sys.stdout, '[%s]   %s' % (elapsed, task.item.name)
+              sys.stdout.flush()
         except KeyboardInterrupt:
           # Help debugging by printing some information:
           print >> sys.stderr, (
               ('\nAllowed parallel jobs: %d\n# queued: %d\nRan: %s\n'
                 'Running: %d') % (
               self.jobs,
               len(self.queued),
               ', '.join(self.ran),
               len(self.running)))
           for i in self.queued:
@@ skipping 239 matching lines @@
 def DefaultIndexPackConfig(url=''):
   """Return reasonable default values for configuring git-index-pack.
 
   Experiments suggest that higher values for pack.threads don't improve
   performance."""
   cache_limit = DefaultDeltaBaseCacheLimit()
   result = ['-c', 'core.deltaBaseCacheLimit=%s' % cache_limit]
   if url in THREADED_INDEX_PACK_BLACKLIST:
     result.extend(['-c', 'pack.threads=1'])
   return result