Kill forwarder2 host daemon in python_test_sharder.py during setup.

build/android/pylib/host_driven/python_test_sharder.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.
 
 """Takes care of sharding the python-drive tests in multiple devices."""
 
 import copy
 import logging
 import multiprocessing
 
 from pylib.base import base_test_result
 from pylib.base import sharded_tests_queue
+from pylib.forwarder import Forwarder
 
 from python_test_caller import CallPythonTest
 
 
 def SetTestsContainer(tests_container):
   """Sets PythonTestSharder as a top-level field.
 
   PythonTestSharder uses multiprocessing.Pool, which creates a pool of
   processes. This is used to initialize each worker in the pool, ensuring that
   each worker has access to this shared pool of tests.
@@ skipping 90 matching lines @@
       A list of test results aggregated from all test runs.
     """
     logging.warning('*' * 80)
     logging.warning('Sharding in ' + str(len(self.attached_devices)) +
                     ' devices.')
     logging.warning('Note that the output is not synchronized.')
     logging.warning('Look for the "Final result" banner in the end.')
     logging.warning('*' * 80)
     final_results = base_test_result.TestRunResults()
     tests_to_run = self.tests
+
+    Forwarder.KillHost()
+
     for retry in xrange(self.retries):
       logging.warning('Try %d of %d', retry + 1, self.retries)
       self._SetupSharding(self.tests)
       test_runners = self._MakeTestRunners(self.attached_devices)
       logging.warning('Starting...')
       pool = multiprocessing.Pool(len(self.attached_devices),
                                   SetTestsContainer,
                                   [PythonTestSharder.tests_container])
 
       # List of TestRunResults objects from each test execution.
@@ skipping 57 matching lines @@
       available_tests: a list of tests which subclass PythonTestBase.
       failed_test_names: a list of failed test names.
 
     Returns:
       A list of test objects which correspond to test names found in
       failed_test_names, or an empty list if there is no correspondence.
     """
     tests_to_retry = [t for t in available_tests
                       if t.qualified_name in failed_test_names]
     return tests_to_retry