Index: build/android/pylib/chrome_test_server_spawner.py |
diff --git a/build/android/pylib/chrome_test_server_spawner.py b/build/android/pylib/chrome_test_server_spawner.py |
index 43405876a1f86b0d5f03bd098d268a35963339f0..08bfb4506a11d433ab172d45c1ffd4179d00ec20 100644 |
--- a/build/android/pylib/chrome_test_server_spawner.py |
+++ b/build/android/pylib/chrome_test_server_spawner.py |
@@ -77,9 +77,9 @@ def _CheckPortStatus(port, expected_status): |
return _WaitUntil(lambda: ports.IsHostPortUsed(port) == expected_status) |
-def _CheckDevicePortStatus(adb, port): |
+def _CheckDevicePortStatus(device, port): |
"""Returns whether the provided port is used.""" |
- return _WaitUntil(lambda: ports.IsDevicePortUsed(adb, port)) |
+ return _WaitUntil(lambda: ports.IsDevicePortUsed(device, port)) |
def _GetServerTypeCommandLine(server_type): |
@@ -102,13 +102,13 @@ def _GetServerTypeCommandLine(server_type): |
class TestServerThread(threading.Thread): |
"""A thread to run the test server in a separate process.""" |
- def __init__(self, ready_event, arguments, adb, tool): |
+ def __init__(self, ready_event, arguments, device, tool): |
"""Initialize TestServerThread with the following argument. |
Args: |
ready_event: event which will be set when the test server is ready. |
arguments: dictionary of arguments to run the test server. |
- adb: instance of AndroidCommands. |
+ device: An instance of DeviceUtils. |
tool: instance of runtime error detection tool. |
""" |
threading.Thread.__init__(self) |
@@ -117,7 +117,7 @@ class TestServerThread(threading.Thread): |
self.ready_event = ready_event |
self.ready_event.clear() |
self.arguments = arguments |
- self.adb = adb |
+ self.device = device |
self.tool = tool |
self.test_server_process = None |
self.is_ready = False |
@@ -252,11 +252,11 @@ class TestServerThread(threading.Thread): |
else: |
self.is_ready = _CheckPortStatus(self.host_port, True) |
if self.is_ready: |
- Forwarder.Map([(0, self.host_port)], self.adb, self.tool) |
+ Forwarder.Map([(0, self.host_port)], self.device, self.tool) |
# Check whether the forwarder is ready on the device. |
self.is_ready = False |
device_port = Forwarder.DevicePortForHostPort(self.host_port) |
- if device_port and _CheckDevicePortStatus(self.adb, device_port): |
+ if device_port and _CheckDevicePortStatus(self.device, device_port): |
self.is_ready = True |
self.forwarder_device_port = device_port |
# Wake up the request handler thread. |
@@ -265,7 +265,7 @@ class TestServerThread(threading.Thread): |
_WaitUntil(lambda: self.stop_flag, max_attempts=sys.maxint) |
if self.process.poll() is None: |
self.process.kill() |
- Forwarder.UnmapDevicePort(self.forwarder_device_port, self.adb) |
+ Forwarder.UnmapDevicePort(self.forwarder_device_port, self.device) |
self.process = None |
self.is_ready = False |
if self.pipe_out: |
@@ -333,7 +333,7 @@ class SpawningServerRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler): |
self.server.test_server_instance = TestServerThread( |
ready_event, |
json.loads(test_server_argument_json), |
- self.server.adb, |
+ self.server.device, |
self.server.tool) |
self.server.test_server_instance.setDaemon(True) |
self.server.test_server_instance.start() |
@@ -401,11 +401,11 @@ class SpawningServerRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler): |
class SpawningServer(object): |
"""The class used to start/stop a http server.""" |
- def __init__(self, test_server_spawner_port, adb, tool): |
+ def __init__(self, test_server_spawner_port, device, tool): |
logging.info('Creating new spawner on port: %d.', test_server_spawner_port) |
self.server = BaseHTTPServer.HTTPServer(('', test_server_spawner_port), |
SpawningServerRequestHandler) |
- self.server.adb = adb |
+ self.server.device = device |
self.server.tool = tool |
self.server.test_server_instance = None |
self.server.build_type = constants.GetBuildType() |