| Index: telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| diff --git a/telemetry/telemetry/internal/forwarders/cros_forwarder.py b/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| index 86c5a7aa654168b9486d8159aa39ad155e6f6a3b..4316954559177e6428cc5584d4359be3ea1fd13a 100644
|
| --- a/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| +++ b/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| @@ -5,10 +5,11 @@
|
| import logging
|
| import subprocess
|
|
|
| -from telemetry.core import util
|
| from telemetry.internal import forwarders
|
| from telemetry.internal.forwarders import do_nothing_forwarder
|
|
|
| +import py_utils
|
| +
|
|
|
| class CrOsForwarderFactory(forwarders.ForwarderFactory):
|
|
|
| @@ -37,7 +38,7 @@ class CrOsSshForwarder(forwarders.Forwarder):
|
| stderr=subprocess.PIPE,
|
| stdin=subprocess.PIPE,
|
| shell=False)
|
| - util.WaitFor(
|
| + py_utils.WaitFor(
|
| lambda: self._cri.IsHTTPServerRunningOnPort(self.host_port), 60)
|
| logging.debug('Server started on %s:%d', self.host_ip, self.host_port)
|
|
|
|
|