| Index: tools/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| diff --git a/tools/telemetry/telemetry/internal/forwarders/cros_forwarder.py b/tools/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| deleted file mode 100644
|
| index d8a9ab32065379a7ca16b3e71b36ef13aa29cc98..0000000000000000000000000000000000000000
|
| --- a/tools/telemetry/telemetry/internal/forwarders/cros_forwarder.py
|
| +++ /dev/null
|
| @@ -1,61 +0,0 @@
|
| -# Copyright 2014 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 logging
|
| -import subprocess
|
| -
|
| -from telemetry.core import util
|
| -from telemetry.internal import forwarders
|
| -from telemetry.internal.forwarders import do_nothing_forwarder
|
| -
|
| -
|
| -class CrOsForwarderFactory(forwarders.ForwarderFactory):
|
| -
|
| - def __init__(self, cri):
|
| - super(CrOsForwarderFactory, self).__init__()
|
| - self._cri = cri
|
| -
|
| - # pylint: disable=arguments-differ
|
| - def Create(self, port_pairs, use_remote_port_forwarding=True):
|
| - if self._cri.local:
|
| - return do_nothing_forwarder.DoNothingForwarder(port_pairs)
|
| - return CrOsSshForwarder(self._cri, use_remote_port_forwarding, port_pairs)
|
| -
|
| -
|
| -class CrOsSshForwarder(forwarders.Forwarder):
|
| -
|
| - def __init__(self, cri, use_remote_port_forwarding, port_pairs):
|
| - super(CrOsSshForwarder, self).__init__(port_pairs)
|
| - self._cri = cri
|
| - self._proc = None
|
| - forwarding_args = self._ForwardingArgs(
|
| - use_remote_port_forwarding, self.host_ip, port_pairs)
|
| - self._proc = subprocess.Popen(
|
| - self._cri.FormSSHCommandLine(['sleep', '999999999'], forwarding_args),
|
| - stdout=subprocess.PIPE,
|
| - stderr=subprocess.PIPE,
|
| - stdin=subprocess.PIPE,
|
| - shell=False)
|
| - util.WaitFor(
|
| - lambda: self._cri.IsHTTPServerRunningOnPort(self.host_port), 60)
|
| - logging.debug('Server started on %s:%d', self.host_ip, self.host_port)
|
| -
|
| - # pylint: disable=unused-argument
|
| - @staticmethod
|
| - def _ForwardingArgs(use_remote_port_forwarding, host_ip, port_pairs):
|
| - if use_remote_port_forwarding:
|
| - arg_format = '-R{pp.remote_port}:{host_ip}:{pp.local_port}'
|
| - else:
|
| - arg_format = '-L{pp.local_port}:{host_ip}:{pp.remote_port}'
|
| - return [arg_format.format(**locals()) for pp in port_pairs if pp]
|
| -
|
| - @property
|
| - def host_port(self):
|
| - return self._port_pairs.http.remote_port
|
| -
|
| - def Close(self):
|
| - if self._proc:
|
| - self._proc.kill()
|
| - self._proc = None
|
| - super(CrOsSshForwarder, self).Close()
|
|
|