Index: tools/telemetry/telemetry/core/chrome/websocket_browser_connection.py |
diff --git a/tools/telemetry/telemetry/core/chrome/websocket_browser_connection.py b/tools/telemetry/telemetry/core/chrome/websocket_browser_connection.py |
deleted file mode 100644 |
index efaba9c4f778eea266184c8bb4ca029c6e8ceb0f..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/telemetry/core/chrome/websocket_browser_connection.py |
+++ /dev/null |
@@ -1,59 +0,0 @@ |
-# Copyright 2013 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 json |
-import logging |
-import socket |
- |
-from telemetry.core import util |
-from telemetry.core.chrome import websocket |
- |
-class WebSocketBrowserConnection(object): |
- """Represents a websocket connection to the browser for backends |
- which use one.""" |
- |
- def __init__(self, devtools_port): |
- debugger_url = 'ws://localhost:%i/devtools/browser' % devtools_port |
- self._socket = websocket.create_connection(debugger_url) |
- self._next_request_id = 0 |
- self._cur_socket_timeout = 0 |
- |
- def Close(self): |
- if self._socket: |
- self._socket.close() |
- self._socket = None |
- |
- def SendRequest(self, req, timeout=10): |
- self._SetTimeout(timeout) |
- req['id'] = self._next_request_id |
- self._next_request_id += 1 |
- data = json.dumps(req) |
- logging.debug('will send [%s]', data) |
- self._socket.send(data) |
- |
- def SyncRequest(self, req, timeout=10): |
- self.SendRequest(req, timeout) |
- while True: |
- try: |
- data = self._socket.recv() |
- except (socket.error, websocket.WebSocketException): |
- raise util.TimeoutException( |
- "Timed out waiting for reply. This is unusual.") |
- res = json.loads(data) |
- logging.debug('got [%s]', data) |
- if res['id'] != req['id']: |
- logging.debug('Dropped reply: %s', json.dumps(res)) |
- continue |
- return res |
- |
- @property |
- def socket(self): |
- """Returns the socket for raw access. Please be sure you know what |
- you are doing.""" |
- return self._socket |
- |
- def _SetTimeout(self, timeout): |
- if self._cur_socket_timeout != timeout: |
- self._socket.settimeout(timeout) |
- self._cur_socket_timeout = timeout |