DevTools: Extract WorkerInspectorProxy interface from WorkerGlobalScopeProxy.

Source/core/inspector/InspectorWorkerAgent.cpp

 /*
  * Copyright (C) 2011 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 18 matching lines @@
  */
 
 #include "config.h"
 
 #include "core/inspector/InspectorWorkerAgent.h"
 
 #include "core/InspectorFrontend.h"
 #include "core/inspector/InspectorState.h"
 #include "core/inspector/InstrumentingAgents.h"
 #include "core/inspector/JSONParser.h"
-#include "core/workers/WorkerGlobalScopeProxy.h"
+#include "core/workers/WorkerInspectorProxy.h"
 #include "platform/JSONValues.h"
 #include "platform/weborigin/KURL.h"
 #include "wtf/PassOwnPtr.h"
 #include "wtf/RefPtr.h"
+#include "wtf/text/WTFString.h"
 
 namespace blink {
 
 namespace WorkerAgentState {
 static const char workerInspectionEnabled[] = "workerInspectionEnabled";
 static const char autoconnectToWorkers[] = "autoconnectToWorkers";
 };
 
-class InspectorWorkerAgent::WorkerFrontendChannel FINAL : public WorkerGlobalScopeProxy::PageInspector {
+class InspectorWorkerAgent::WorkerFrontendChannel FINAL : public WorkerInspectorProxy::PageInspector {
     WTF_MAKE_FAST_ALLOCATED;
 public:
-    explicit WorkerFrontendChannel(InspectorFrontend::Worker* frontend, WorkerGlobalScopeProxy* proxy)
+    explicit WorkerFrontendChannel(InspectorFrontend::Worker* frontend, WorkerInspectorProxy* proxy)
         : m_frontend(frontend)
         , m_proxy(proxy)
         , m_id(s_nextId++)
         , m_connected(false)
     {
     }
     virtual ~WorkerFrontendChannel()
     {
-        disconnectFromWorkerGlobalScope();
+        disconnectFromWorker();
     }
 
     int id() const { return m_id; }
-    WorkerGlobalScopeProxy* proxy() const { return m_proxy; }
+    WorkerInspectorProxy* proxy() const { return m_proxy; }
 
-    void connectToWorkerGlobalScope()
+    void connectToWorker()
     {
         if (m_connected)
             return;
         m_connected = true;
         m_proxy->connectToInspector(this);
     }
 
-    void disconnectFromWorkerGlobalScope()
+    void disconnectFromWorker()
     {
         if (!m_connected)
             return;
         m_connected = false;
         m_proxy->disconnectFromInspector();
     }
 
 private:
-    // WorkerGlobalScopeProxy::PageInspector implementation
+    // WorkerInspectorProxy::PageInspector implementation
     virtual void dispatchMessageFromWorker(const String& message) OVERRIDE
     {
         RefPtr<JSONValue> value = parseJSON(message);
         if (!value)
             return;
         RefPtr<JSONObject> messageObject = value->asObject();
         if (!messageObject)
             return;
         m_frontend->dispatchMessageFromWorker(m_id, messageObject);
     }
 
     InspectorFrontend::Worker* m_frontend;
-    WorkerGlobalScopeProxy* m_proxy;
+    WorkerInspectorProxy* m_proxy;
     int m_id;
     bool m_connected;
     static int s_nextId;
 };
 
 int InspectorWorkerAgent::WorkerFrontendChannel::s_nextId = 1;
 
 PassOwnPtrWillBeRawPtr<InspectorWorkerAgent> InspectorWorkerAgent::create()
 {
     return adoptPtrWillBeNoop(new InspectorWorkerAgent());
@@ skipping 53 matching lines @@
 
 void InspectorWorkerAgent::canInspectWorkers(ErrorString*, bool* result)
 {
     *result = true;
 }
 
 void InspectorWorkerAgent::connectToWorker(ErrorString* error, int workerId)
 {
     WorkerFrontendChannel* channel = m_idToChannel.get(workerId);
     if (channel)
-        channel->connectToWorkerGlobalScope();
+        channel->connectToWorker();
     else
         *error = "Worker is gone";
 }
 
 void InspectorWorkerAgent::disconnectFromWorker(ErrorString* error, int workerId)
 {
     WorkerFrontendChannel* channel = m_idToChannel.get(workerId);
     if (channel)
-        channel->disconnectFromWorkerGlobalScope();
+        channel->disconnectFromWorker();
     else
         *error = "Worker is gone";
 }
 
 void InspectorWorkerAgent::sendMessageToWorker(ErrorString* error, int workerId, const RefPtr<JSONObject>& message)
 {
     WorkerFrontendChannel* channel = m_idToChannel.get(workerId);
     if (channel)
         channel->proxy()->sendMessageToInspector(message->toJSONString());
     else
         *error = "Worker is gone";
 }
 
 void InspectorWorkerAgent::setAutoconnectToWorkers(ErrorString*, bool value)
 {
     m_state->setBoolean(WorkerAgentState::autoconnectToWorkers, value);
 }
 
 void InspectorWorkerAgent::setTracingSessionId(const String& sessionId)
 {
     m_tracingSessionId = sessionId;
     if (sessionId.isEmpty())
         return;
-    for (DedicatedWorkers::iterator it = m_dedicatedWorkers.begin(); it != m_dedicatedWorkers.end(); ++it)
+    for (WorkerIds::iterator it = m_workerIds.begin(); it != m_workerIds.end(); ++it)
         it->key->writeTimelineStartedEvent(sessionId);
 }
 
 bool InspectorWorkerAgent::shouldPauseDedicatedWorkerOnStart()
 {
     return m_state->getBoolean(WorkerAgentState::autoconnectToWorkers);
 }
 
-void InspectorWorkerAgent::didStartWorkerGlobalScope(WorkerGlobalScopeProxy* workerGlobalScopeProxy, const KURL& url)
+void InspectorWorkerAgent::didStartWorker(WorkerInspectorProxy* workerInspectorProxy, const KURL& url)
 {
-    m_dedicatedWorkers.set(workerGlobalScopeProxy, url.string());
+    m_workerIds.set(workerInspectorProxy, url.string());
     if (m_frontend && m_state->getBoolean(WorkerAgentState::workerInspectionEnabled))
-        createWorkerFrontendChannel(workerGlobalScopeProxy, url.string());
+        createWorkerFrontendChannel(workerInspectorProxy, url.string());
     if (!m_tracingSessionId.isEmpty())
-        workerGlobalScopeProxy->writeTimelineStartedEvent(m_tracingSessionId);
+        workerInspectorProxy->writeTimelineStartedEvent(m_tracingSessionId);
 }
 
-void InspectorWorkerAgent::workerGlobalScopeTerminated(WorkerGlobalScopeProxy* proxy)
+void InspectorWorkerAgent::workerTerminated(WorkerInspectorProxy* proxy)
 {
-    m_dedicatedWorkers.remove(proxy);
+    m_workerIds.remove(proxy);
     for (WorkerChannels::iterator it = m_idToChannel.begin(); it != m_idToChannel.end(); ++it) {
         if (proxy == it->value->proxy()) {
             m_frontend->workerTerminated(it->key);
             delete it->value;
             m_idToChannel.remove(it);
             return;
         }
     }
 }
 
 void InspectorWorkerAgent::createWorkerFrontendChannelsForExistingWorkers()
 {
-    for (DedicatedWorkers::iterator it = m_dedicatedWorkers.begin(); it != m_dedicatedWorkers.end(); ++it)
+    for (WorkerIds::iterator it = m_workerIds.begin(); it != m_workerIds.end(); ++it)
         createWorkerFrontendChannel(it->key, it->value);
 }
 
 void InspectorWorkerAgent::destroyWorkerFrontendChannels()
 {
     for (WorkerChannels::iterator it = m_idToChannel.begin(); it != m_idToChannel.end(); ++it) {
-        it->value->disconnectFromWorkerGlobalScope();
+        it->value->disconnectFromWorker();
         delete it->value;
     }
     m_idToChannel.clear();
 }
 
-void InspectorWorkerAgent::createWorkerFrontendChannel(WorkerGlobalScopeProxy* workerGlobalScopeProxy, const String& url)
+void InspectorWorkerAgent::createWorkerFrontendChannel(WorkerInspectorProxy* workerInspectorProxy, const String& url)
 {
-    WorkerFrontendChannel* channel = new WorkerFrontendChannel(m_frontend, workerGlobalScopeProxy);
+    WorkerFrontendChannel* channel = new WorkerFrontendChannel(m_frontend, workerInspectorProxy);
     m_idToChannel.set(channel->id(), channel);
 
     ASSERT(m_frontend);
     bool autoconnectToWorkers = m_state->getBoolean(WorkerAgentState::autoconnectToWorkers);
     if (autoconnectToWorkers)
-        channel->connectToWorkerGlobalScope();
+        channel->connectToWorker();
     m_frontend->workerCreated(channel->id(), url, autoconnectToWorkers);
 }
 
 } // namespace blink