[Android] Move base tests classes to pylib/base

build/android/pylib/base/base_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.
 
 
-import android_commands
 import logging
 import multiprocessing
 
-from android_commands import errors
-from forwarder import Forwarder
-from test_result import TestResults
+from pylib import android_commands
+from pylib.base.test_result import TestResults
+from pylib.forwarder import Forwarder
 
 
 def _ShardedTestRunnable(test):
   """Standalone function needed by multiprocessing.Pool."""
   log_format = '[' + test.device + '] # %(asctime)-15s: %(message)s'
   if logging.getLogger().handlers:
     logging.getLogger().handlers[0].setFormatter(logging.Formatter(log_format))
   else:
     logging.basicConfig(format=log_format)
   # Handle SystemExit here since python has a bug to exit current process
@@ skipping 72 matching lines @@
       test_runners = []
 
       # Try to create N shards, and retrying on failure.
       try:
         for index, device in enumerate(self.attached_devices):
           logging.warning('*' * 80)
           logging.warning('Creating shard %d for %s', index, device)
           logging.warning('*' * 80)
           test_runner = self.CreateShardedTestRunner(device, index)
           test_runners += [test_runner]
-      except errors.DeviceUnresponsiveError as e:
+      except android_commands.errors.DeviceUnresponsiveError as e:
         logging.critical('****Failed to create a shard: [%s]', e)
         self.attached_devices.remove(device)
         continue
 
       logging.warning('Starting...')
       pool = multiprocessing.Pool(len(self.attached_devices),
                                   SetTestsContainer,
                                   [BaseTestSharder.tests_container])
       # map can't handle KeyboardInterrupt exception. It's a python bug.
       # So use map_async instead.
       async_results = pool.map_async(_ShardedTestRunnable, test_runners)
       try:
         results_lists = async_results.get(999999)
-      except errors.DeviceUnresponsiveError as e:
+      except android_commands.errors.DeviceUnresponsiveError as e:
         logging.critical('****Failed to run test: [%s]', e)
         self.attached_devices = android_commands.GetAttachedDevices()
         continue
       test_results = TestResults.FromTestResults(results_lists)
       # Re-check the attached devices for some devices may
       # become offline
       retry_devices = set(android_commands.GetAttachedDevices())
       # Remove devices that had exceptions.
       retry_devices -= TestResults.DeviceExceptions(results_lists)
       # Retry on devices that didn't have any exception.
@@ skipping 14 matching lines @@
           self.tests += [t.name]
         if not self.tests:
           break
     else:
       # We ran out retries, possibly out of healthy devices.
       # 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