[Telemetry] Reorganize everything.

tools/telemetry/telemetry/core/chrome/inspector_backend.py

 # 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 json
 import logging
 import socket
 import sys
 
-from telemetry import inspector_console
-from telemetry import inspector_page
-from telemetry import inspector_runtime
-from telemetry import inspector_timeline
-from telemetry import png_bitmap
-from telemetry import tab_crash_exception
-from telemetry import util
-from telemetry import websocket
+from telemetry.core import util
+from telemetry.core import exceptions
+from telemetry.core.chrome import inspector_console
+from telemetry.core.chrome import inspector_page
+from telemetry.core.chrome import inspector_runtime
+from telemetry.core.chrome import inspector_timeline
+from telemetry.core.chrome import png_bitmap
+from telemetry.core.chrome import websocket
 
 class InspectorException(Exception):
   pass
 
 class InspectorBackend(object):
   def __init__(self, browser, browser_backend, debugger_url):
     assert debugger_url
     self._browser = browser
     self._browser_backend = browser_backend
     self._debugger_url = debugger_url
@@ skipping 161 matching lines @@
   def DispatchNotifications(self, timeout=10):
     self._Connect()
     self._SetTimeout(timeout)
 
     try:
       data = self._socket.recv()
     except (socket.error, websocket.WebSocketException):
       if self._browser_backend.tab_list_backend.DoesDebuggerUrlExist(
           self._debugger_url):
         return
-      raise tab_crash_exception.TabCrashException()
+      raise exceptions.TabCrashException()
 
     res = json.loads(data)
     logging.debug('got [%s]', data)
     if 'method' in res:
       self._HandleNotification(res)
 
   def _HandleNotification(self, res):
     if (res['method'] == 'Inspector.detached' and
         res.get('params', {}).get('reason','') == 'replaced_with_devtools'):
       self._WaitForInspectorToGoAwayAndReconnect()
@@ skipping 45 matching lines @@
     self.SendAndIgnoreResponse(req)
 
     while True:
       try:
         data = self._socket.recv()
       except (socket.error, websocket.WebSocketException):
         if self._browser_backend.tab_list_backend.DoesDebuggerUrlExist(
             self._debugger_url):
           raise util.TimeoutException(
             'Timed out waiting for reply. This is unusual.')
-        raise tab_crash_exception.TabCrashException()
+        raise exceptions.TabCrashException()
 
       res = json.loads(data)
       logging.debug('got [%s]', data)
       if 'method' in res:
         self._HandleNotification(res)
         continue
 
       if res['id'] != req['id']:
         logging.debug('Dropped reply: %s', json.dumps(res))
         continue
@@ skipping 14 matching lines @@
                                         OnConsoleNotification, OnConsoleClose)
        """
     assert domain_name not in self._domain_handlers
     self._domain_handlers[domain_name] = (notification_handler,
                                           will_close_handler)
 
   def UnregisterDomain(self, domain_name):
     """Unregisters a previously registered domain."""
     assert domain_name in self._domain_handlers
     self._domain_handlers.pop(domain_name)