Create "git cache" command.

gclient_scm.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.
 
 """Gclient-specific SCM-specific operations."""
 
 import collections
 import logging
 import os
 import posixpath
 import re
 import sys
 import tempfile
 import threading
-import time
 import urlparse
 
 import download_from_google_storage
 import gclient_utils
 import scm
 import subprocess2
 
 
 THIS_FILE_PATH = os.path.abspath(__file__)
 
@@ skipping 109 matching lines @@
     if not command in commands:
       raise gclient_utils.Error('Unknown command %s' % command)
 
     if not command in dir(self):
       raise gclient_utils.Error('Command %s not implemented in %s wrapper' % (
           command, self.__class__.__name__))
 
     return getattr(self, command)(options, args, file_list)
 
 
-class GitFilter(object):
-  """A filter_fn implementation for quieting down git output messages.
-
-  Allows a custom function to skip certain lines (predicate), and will throttle
-  the output of percentage completed lines to only output every X seconds.
-  """
-  PERCENT_RE = re.compile('.* ([0-9]{1,2})% .*')
-
-  def __init__(self, time_throttle=0, predicate=None):
-    """
-    Args:
-      time_throttle (int): GitFilter will throttle 'noisy' output (such as the
-        XX% complete messages) to only be printed at least |time_throttle|
-        seconds apart.
-      predicate (f(line)): An optional function which is invoked for every line.
-        The line will be skipped if predicate(line) returns False.
-    """
-    self.last_time = 0
-    self.time_throttle = time_throttle
-    self.predicate = predicate
-
-  def __call__(self, line):
-    # git uses an escape sequence to clear the line; elide it.
-    esc = line.find(unichr(033))
-    if esc > -1:
-      line = line[:esc]
-    if self.predicate and not self.predicate(line):
-      return
-    now = time.time()
-    match = self.PERCENT_RE.match(line)
-    if not match:
-      self.last_time = 0
-    if (now - self.last_time) >= self.time_throttle:
-      self.last_time = now
-      print line
-
-
 class GitWrapper(SCMWrapper):
   """Wrapper for Git"""
   name = 'git'
   remote = 'origin'
 
   cache_dir = None
   # If a given cache is used in a solution more than once, prevent multiple
   # threads from updating it simultaneously.
   cache_locks = collections.defaultdict(threading.Lock)
 
@@ skipping 833 matching lines @@
       if fetch:
         fetch_cmd = ['-c', 'core.deltaBaseCacheLimit=2g', 'fetch', self.remote]
         if options.verbose:
           fetch_cmd.append('--verbose')
         self._Run(fetch_cmd, options, retry=True)
 
   def _Run(self, args, options, **kwargs):
     kwargs.setdefault('cwd', self.checkout_path)
     git_filter = not options.verbose
     if git_filter:
-      kwargs['filter_fn'] = GitFilter(kwargs.get('filter_fn'))
+      kwargs['filter_fn'] = gclient_utils.GitFilter(kwargs.get('filter_fn'))
       kwargs.setdefault('print_stdout', False)
       # Don't prompt for passwords; just fail quickly and noisily.
       # By default, git will use an interactive terminal prompt when a username/
       # password is needed.  That shouldn't happen in the chromium workflow,
       # and if it does, then gclient may hide the prompt in the midst of a flood
       # of terminal spew.  The only indication that something has gone wrong
       # will be when gclient hangs unresponsively.  Instead, we disable the
       # password prompt and simply allow git to fail noisily.  The error
       # message produced by git will be copied to gclient's output.
       env = kwargs.get('env') or kwargs.setdefault('env', os.environ.copy())
@@ skipping 424 matching lines @@
       new_command.append('--force')
       if command[0] != 'checkout' and scm.SVN.AssertVersion('1.6')[0]:
         new_command.extend(('--accept', 'theirs-conflict'))
     elif options.manually_grab_svn_rev:
       new_command.append('--force')
       if command[0] != 'checkout' and scm.SVN.AssertVersion('1.6')[0]:
         new_command.extend(('--accept', 'postpone'))
     elif command[0] != 'checkout' and scm.SVN.AssertVersion('1.6')[0]:
       new_command.extend(('--accept', 'postpone'))
     return new_command