Make use of CheckCallAndFilter42 for gclient's git fetch.

tests/gclient_scm_test.py

 #!/usr/bin/env python
 # 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.
 
 """Unit tests for gclient_scm.py."""
 
 # pylint: disable=E1103
 
 # Import before super_mox to keep valid references.
@@ skipping 952 matching lines @@
                                 relpath=self.relpath)
     file_list = []
     options.revision = 'unmanaged'
     scm.update(options, (), file_list)
     self.assertEquals(file_list, expected_file_list)
     self.assertEquals(scm.revinfo(options, (), None),
                       '069c602044c5388d2d15c3f875b057c852003458')
     self.checkstdout('________ unmanaged solution; skipping .\n')
 
 
-class GitHungTest(BaseGitWrapperTestCase):
-  def setUp(self):
-    super(GitHungTest, self).setUp()
-    self.old = gclient_scm.gclient_utils.CheckCallAndFilter
-    self.old2 = gclient_scm.gclient_utils.subprocess2.Popen
-    self.options = self.Options()
-    self.options.verbose = False
-    self.scm = gclient_scm.CreateSCM(url=self.url, root_dir=self.root_dir,
-                                     relpath=self.relpath)
-    os.environ['GCLIENT_KILL_GIT_FETCH_AFTER'] = '1.0'
-
-  def tearDown(self):
-    os.environ.pop('GCLIENT_KILL_GIT_FETCH_AFTER')
-    gclient_scm.gclient_utils.CheckCallAndFilter = self.old
-    gclient_scm.gclient_utils.subprocess2.Popen = self.old2
-    super(GitHungTest, self).tearDown()
-
-  def testGitFetchOk(self):
-    def subprocess_git_fetch_run(_, filter_fn, kill_timeout, **__):
-      self.assertEqual(kill_timeout, 1.0)
-      filter_fn('remote: something')
-    gclient_scm.gclient_utils.CheckCallAndFilter = subprocess_git_fetch_run
-    self.scm._Fetch(self.options)
-    self.checkstdout('remote: something\n')
-
-  def testGitFetchHungAndRetry(self):
-    class Process(object):
-      # First process will hang, second process will exit with 0 quickly.
-      cv = threading.Condition()
-      count = -1
-      killed = []
-      def __init__(self):
-        self.count += 1
-        self.stdout = self
-        self.data = list('retry' if self.count > 0 else 'hung')
-        self.data.reverse()
-        self.this_killed = False
-      def read(self, _):
-        if self.data:
-          return self.data.pop()
-        if self.count == 0:
-          # Simulate hung process.
-          with self.cv:
-            self.cv.wait(timeout=0)
-        return ''
-      def kill(self):
-        self.this_killed = True
-        self.killed.append(self.count)
-        with self.cv:
-          self.cv.notify()
-      def wait(self):
-        if self.this_killed:
-          return 1
-        return 0
-
-    gclient_scm.gclient_utils.subprocess2.Popen = lambda *_, **__: Process()
-    self.scm._Capture = lambda *_, **__: None
-    self.scm._Fetch(self.options)
-    self.checkstdout('hung\n')
-
-
 if __name__ == '__main__':
   level = logging.DEBUG if '-v' in sys.argv else logging.FATAL
   logging.basicConfig(
       level=level,
       format='%(asctime).19s %(levelname)s %(filename)s:'
              '%(lineno)s %(message)s')
   unittest.main()
 
 # vim: ts=2:sw=2:tw=80:et: