Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(211)

Unified Diff: devil/devil/android/sdk/adb_wrapper.py

Issue 2420253003: Revert of [devil] Pick a free port for adb daemon server when port 5037 is in used (Closed)
Patch Set: Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: devil/devil/android/sdk/adb_wrapper.py
diff --git a/devil/devil/android/sdk/adb_wrapper.py b/devil/devil/android/sdk/adb_wrapper.py
index 5159a4fe7960103bfda84330b94cb00e5c8fa29d..924aaa649b60138896d7edf64b612b9a020cf5af 100644
--- a/devil/devil/android/sdk/adb_wrapper.py
+++ b/devil/devil/android/sdk/adb_wrapper.py
@@ -15,7 +15,6 @@
import os
import posixpath
import re
-import socket
import subprocess
from devil import devil_env
@@ -41,15 +40,6 @@
_READY_STATE = 'device'
_VERITY_DISABLE_RE = re.compile('Verity (already)? disabled')
_VERITY_ENABLE_RE = re.compile('Verity (already)? enabled')
-
-
-def _GetFreePort():
- s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
- s.bind(('', 0))
- s.listen(1)
- port = s.getsockname()[1]
- s.close()
- return port
def VerifyLocalFileExists(path):
@@ -236,15 +226,12 @@
return cls._adb_version.read()
@classmethod
- def _BuildAdbCmd(cls, args, device_serial, cpu_affinity=None,
- use_random_port=False):
+ def _BuildAdbCmd(cls, args, device_serial, cpu_affinity=None):
if cpu_affinity is not None:
cmd = ['taskset', '-c', str(cpu_affinity)]
else:
cmd = []
cmd.append(cls.GetAdbPath())
- if use_random_port:
- cmd.extend(['-P', str(_GetFreePort())])
if device_serial is not None:
cmd.extend(['-s', device_serial])
cmd.extend(args)
@@ -252,13 +239,13 @@
# pylint: disable=unused-argument
@classmethod
- def _RunAdbCmdWithouRetries(cls, args, timeout=None, retries=None,
- device_serial=None, check_error=True,
- cpu_affinity=None, use_random_port=False):
+ @decorators.WithTimeoutAndConditionalRetries(_ShouldRetryAdbCmd)
+ def _RunAdbCmd(cls, args, timeout=None, retries=None, device_serial=None,
+ check_error=True, cpu_affinity=None):
+ # pylint: disable=no-member
try:
status, output = cmd_helper.GetCmdStatusAndOutputWithTimeout(
- cls._BuildAdbCmd(args, device_serial, cpu_affinity=cpu_affinity,
- use_random_port=use_random_port),
+ cls._BuildAdbCmd(args, device_serial, cpu_affinity=cpu_affinity),
timeout_retry.CurrentTimeoutThreadGroup().GetRemainingTime())
except OSError as e:
if e.errno in (errno.ENOENT, errno.ENOEXEC):
@@ -276,22 +263,6 @@
raise device_errors.AdbCommandFailedError(args, output)
return output
# pylint: enable=unused-argument
-
- @classmethod
- @decorators.WithTimeoutAndConditionalRetries(_ShouldRetryAdbCmd)
- def _RunAdbCmd(cls, args, timeout=None, retries=None, device_serial=None,
- check_error=True, cpu_affinity=None):
- try:
- return cls._RunAdbCmdWithouRetries(
- args, timeout, retries, device_serial, check_error, cpu_affinity)
- except device_errors.AdbCommandFailedError as err:
- if 'Address already in use' in err.output:
- return cls._RunAdbCmdWithouRetries(
- args, timeout, retries, device_serial, check_error, cpu_affinity,
- use_random_port=True)
- else:
- raise
-
def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True):
"""Runs an adb command on the device associated with this object.
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698