| Index: build/android/pylib/instrumentation/dispatch.py
|
| diff --git a/build/android/pylib/instrumentation/dispatch.py b/build/android/pylib/instrumentation/dispatch.py
|
| index e4ca2805243c6edb7f02830ae28bd808256ef6df..55b4b93033968f97480d27388fa58b2549c460e6 100644
|
| --- a/build/android/pylib/instrumentation/dispatch.py
|
| +++ b/build/android/pylib/instrumentation/dispatch.py
|
| @@ -2,13 +2,14 @@
|
| # Use of this source code is governed by a BSD-style license that can be
|
| # found in the LICENSE file.
|
|
|
| -"""Dispatches the instrumentation tests."""
|
| +"""Runs the instrumentation tests."""
|
|
|
| import logging
|
| import os
|
|
|
| from pylib import android_commands
|
| from pylib import constants
|
| +from pylib import dispatch
|
| from pylib.base import base_test_result
|
| from pylib.base import shard
|
| from pylib.utils import report_results
|
| @@ -17,8 +18,8 @@ import test_package
|
| import test_runner
|
|
|
|
|
| -def Dispatch(options):
|
| - """Dispatches instrumentation tests onto connected device(s).
|
| +def RunInstrumentationTests(options):
|
| + """Runs instrumentation tests on connected device(s).
|
|
|
| If possible, this method will attempt to shard the tests to
|
| all connected devices. Otherwise, dispatch and run tests on one device.
|
| @@ -40,23 +41,10 @@ def Dispatch(options):
|
| logging.error('No instrumentation tests to run with current args.')
|
| return (base_test_result.TestRunResults(), constants.ERROR_EXIT_CODE)
|
|
|
| - attached_devices = android_commands.GetAttachedDevices()
|
| - if not attached_devices:
|
| - raise Exception('There are no devices online.')
|
| -
|
| - if options.test_device:
|
| - assert options.test_device in attached_devices
|
| - attached_devices = [options.test_device]
|
| -
|
| - if len(attached_devices) > 1 and options.wait_for_debugger:
|
| - logging.warning('Debugger can not be sharded, using first available device')
|
| - attached_devices = attached_devices[:1]
|
|
|
| def TestRunnerFactory(device, shard_index):
|
| return test_runner.TestRunner(
|
| options, device, shard_index, test_pkg, [])
|
|
|
| - return shard.ShardAndRunTests(TestRunnerFactory, attached_devices, tests,
|
| - options.build_type,
|
| - test_timeout=None,
|
| - num_retries=options.num_retries)
|
| + return dispatch.Dispatch(options, tests, TestRunnerFactory,
|
| + distribution='shard')
|
|
|