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() |