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

Unified Diff: tools/telemetry/telemetry/internal/forwarders/cros_forwarder.py

Issue 1647513002: Delete tools/telemetry. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 11 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
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()

Powered by Google App Engine
This is Rietveld 408576698