| Index: build/android/pylib/base_test_sharder.py
 | 
| diff --git a/build/android/pylib/base_test_sharder.py b/build/android/pylib/base_test_sharder.py
 | 
| index fa05abec4e202b77d422fd2a29bcd5f20dfe996d..1c4559ad4582ddb2d757dd3fc5e5fa4bd27dcdd3 100644
 | 
| --- a/build/android/pylib/base_test_sharder.py
 | 
| +++ b/build/android/pylib/base_test_sharder.py
 | 
| @@ -66,10 +66,13 @@ class BaseTestSharder(object):
 | 
|  
 | 
|    def SetupSharding(self, tests):
 | 
|      """Called before starting the shards."""
 | 
| -    Forwarder.KillHost(self.build_type)
 | 
| +    pass
 | 
|  
 | 
|    def OnTestsCompleted(self, test_runners, test_results):
 | 
|      """Notifies that we completed the tests."""
 | 
| +    pass
 | 
| +
 | 
| +  def _KillHostForwarder(self):
 | 
|      Forwarder.KillHost(self.build_type)
 | 
|  
 | 
|    def RunShardedTests(self):
 | 
| @@ -85,6 +88,7 @@ class BaseTestSharder(object):
 | 
|      logging.warning('Look for the "Final result" banner in the end.')
 | 
|      logging.warning('*' * 80)
 | 
|      final_results = TestResults()
 | 
| +    self._KillHostForwarder()
 | 
|      for retry in xrange(self.retries):
 | 
|        logging.warning('Try %d of %d', retry + 1, self.retries)
 | 
|        self.SetupSharding(self.tests)
 | 
| @@ -142,4 +146,5 @@ class BaseTestSharder(object):
 | 
|        # There's no recovery at this point.
 | 
|        raise Exception('Unrecoverable error while retrying test runs.')
 | 
|      self.OnTestsCompleted(test_runners, final_results)
 | 
| +    self._KillHostForwarder()
 | 
|      return final_results
 | 
| 
 |