[telemetry] Move telemetry/core/chrome/ to telemetry/core/backends/chrome/

tools/telemetry/telemetry/core/chrome/tracing_backend.py

Index: tools/telemetry/telemetry/core/chrome/tracing_backend.py
diff --git a/tools/telemetry/telemetry/core/chrome/tracing_backend.py b/tools/telemetry/telemetry/core/chrome/tracing_backend.py
deleted file mode 100644
index 0c02d2ed5ca590a6fbedd6e71017dccd7a876181..0000000000000000000000000000000000000000
--- a/tools/telemetry/telemetry/core/chrome/tracing_backend.py
+++ /dev/null
@@ -1,132 +0,0 @@
-# Copyright (c) 2012 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 cStringIO
-import json
-import logging
-import socket
-import threading
-
-
-from telemetry.core.chrome import trace_result
-from telemetry.core.chrome import websocket
-from telemetry.core.chrome import websocket_browser_connection as browser_conn
-from telemetry.core.timeline import model
-
-
-class TracingUnsupportedException(Exception):
-  pass
-
-# This class supports legacy format of trace presentation within DevTools
-# protocol, where trace data were sent as JSON-serialized strings. DevTools
-# now send the data as raw objects within the protocol message JSON, so there's
-# no need in extra de-serialization. We might want to remove this in the future.
-class TraceResultImpl(object):
-  def __init__(self, tracing_data):
-    self._tracing_data = tracing_data
-
-  def Serialize(self, f):
-    f.write('{"traceEvents": [')
-    d = self._tracing_data
-    # Note: we're not using ','.join here because the strings that are in the
-    # tracing data are typically many megabytes in size. In the fast case, f is
-    # just a file, so by skipping the in memory step we keep our memory
-    # footprint low and avoid additional processing.
-    if len(d) == 0:
-      pass
-    elif len(d) == 1:
-      f.write(d[0])
-    else:
-      f.write(d[0])
-      for i in range(1, len(d)):
-        f.write(',')
-        f.write(d[i])
-    f.write(']}')
-
-  def AsTimelineModel(self):
-    f = cStringIO.StringIO()
-    self.Serialize(f)
-    return model.TimelineModel(
-      event_data=f.getvalue(),
-      shift_world_to_zero=False)
-
-# RawTraceResultImpl differs from TraceResultImpl above in that
-# data are kept as a list of dicts, not strings.
-class RawTraceResultImpl(object):
-  def __init__(self, tracing_data):
-    self._tracing_data = tracing_data
-
-  def Serialize(self, f):
-    f.write('{"traceEvents":')
-    json.dump(self._tracing_data, f)
-    f.write('}')
-
-  def AsTimelineModel(self):
-    return model.TimelineModel(self._tracing_data)
-
-class TracingBackend(object):
-  def __init__(self, devtools_port):
-    self._conn = browser_conn.WebSocketBrowserConnection(devtools_port)
-    self._thread = None
-    self._tracing_data = []
-
-  def BeginTracing(self, custom_categories=None, timeout=10):
-    self._CheckNotificationSupported()
-    req = {'method': 'Tracing.start'}
-    if custom_categories:
-      req['params'] = {'categories': custom_categories}
-    self._conn.SendRequest(req, timeout)
-    # Tracing.start will send asynchronous notifications containing trace
-    # data, until Tracing.end is called.
-    self._thread = threading.Thread(target=self._TracingReader)
-    self._thread.start()
-
-  def EndTracing(self):
-    req = {'method': 'Tracing.end'}
-    self._conn.SendRequest(req)
-    self._thread.join()
-    self._thread = None
-
-  def GetTraceResultAndReset(self):
-    assert not self._thread
-    if self._tracing_data and type(self._tracing_data[0]) in [str, unicode]:
-      result_impl = TraceResultImpl(self._tracing_data)
-    else:
-      result_impl = RawTraceResultImpl(self._tracing_data)
-    self._tracing_data = []
-    return trace_result.TraceResult(result_impl)
-
-  def _TracingReader(self):
-    while self._conn.socket:
-      try:
-        data = self._conn.socket.recv()
-        if not data:
-          break
-        res = json.loads(data)
-        logging.debug('got [%s]', data)
-        if 'Tracing.dataCollected' == res.get('method'):
-          value = res.get('params', {}).get('value')
-          if type(value) in [str, unicode]:
-            self._tracing_data.append(value)
-          elif type(value) is list:
-            self._tracing_data.extend(value)
-          else:
-            logging.warning('Unexpected type in tracing data')
-        elif 'Tracing.tracingComplete' == res.get('method'):
-          break
-      except (socket.error, websocket.WebSocketException):
-        logging.warning('Timeout waiting for tracing response, unusual.')
-
-  def Close(self):
-    self._conn.Close()
-
-  def _CheckNotificationSupported(self):
-    """Ensures we're running against a compatible version of chrome."""
-    req = {'method': 'Tracing.hasCompleted'}
-    res = self._conn.SyncRequest(req)
-    if res.get('response'):
-      raise TracingUnsupportedException(
-          'Tracing not supported for this browser')
-    elif 'error' in res:
-      return