Index: Source/core/inspector/InspectorWorkerAgent.cpp |
diff --git a/Source/core/inspector/InspectorWorkerAgent.cpp b/Source/core/inspector/InspectorWorkerAgent.cpp |
index 91a29119bccc792a5800c16a4c090bee566f5a38..3ea2a12f59a96a80b6240833b47e8ca424f70364 100644 |
--- a/Source/core/inspector/InspectorWorkerAgent.cpp |
+++ b/Source/core/inspector/InspectorWorkerAgent.cpp |
@@ -36,11 +36,12 @@ |
#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 { |
@@ -49,10 +50,10 @@ 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++) |
@@ -61,13 +62,13 @@ public: |
} |
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; |
@@ -75,7 +76,7 @@ public: |
m_proxy->connectToInspector(this); |
} |
- void disconnectFromWorkerGlobalScope() |
+ void disconnectFromWorker() |
{ |
if (!m_connected) |
return; |
@@ -84,7 +85,7 @@ public: |
} |
private: |
- // WorkerGlobalScopeProxy::PageInspector implementation |
+ // WorkerInspectorProxy::PageInspector implementation |
virtual void dispatchMessageFromWorker(const String& message) OVERRIDE |
{ |
RefPtr<JSONValue> value = parseJSON(message); |
@@ -97,7 +98,7 @@ private: |
} |
InspectorFrontend::Worker* m_frontend; |
- WorkerGlobalScopeProxy* m_proxy; |
+ WorkerInspectorProxy* m_proxy; |
int m_id; |
bool m_connected; |
static int s_nextId; |
@@ -171,7 +172,7 @@ void InspectorWorkerAgent::connectToWorker(ErrorString* error, int workerId) |
{ |
WorkerFrontendChannel* channel = m_idToChannel.get(workerId); |
if (channel) |
- channel->connectToWorkerGlobalScope(); |
+ channel->connectToWorker(); |
else |
*error = "Worker is gone"; |
} |
@@ -180,7 +181,7 @@ void InspectorWorkerAgent::disconnectFromWorker(ErrorString* error, int workerId |
{ |
WorkerFrontendChannel* channel = m_idToChannel.get(workerId); |
if (channel) |
- channel->disconnectFromWorkerGlobalScope(); |
+ channel->disconnectFromWorker(); |
else |
*error = "Worker is gone"; |
} |
@@ -204,7 +205,7 @@ 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); |
} |
@@ -213,18 +214,18 @@ 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); |
@@ -237,28 +238,28 @@ void InspectorWorkerAgent::workerGlobalScopeTerminated(WorkerGlobalScopeProxy* p |
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); |
} |