| Index: content/browser/devtools/shared_worker_devtools_manager.cc
|
| diff --git a/content/browser/devtools/shared_worker_devtools_manager.cc b/content/browser/devtools/shared_worker_devtools_manager.cc
|
| deleted file mode 100644
|
| index eac5114ca2d74855299848d01606ca758ef50ab3..0000000000000000000000000000000000000000
|
| --- a/content/browser/devtools/shared_worker_devtools_manager.cc
|
| +++ /dev/null
|
| @@ -1,248 +0,0 @@
|
| -// Copyright 2014 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.
|
| -
|
| -#include "content/browser/devtools/shared_worker_devtools_manager.h"
|
| -
|
| -#include "content/browser/devtools/devtools_manager_impl.h"
|
| -#include "content/browser/devtools/devtools_protocol.h"
|
| -#include "content/browser/devtools/devtools_protocol_constants.h"
|
| -#include "content/browser/devtools/ipc_devtools_agent_host.h"
|
| -#include "content/browser/shared_worker/shared_worker_instance.h"
|
| -#include "content/common/devtools_messages.h"
|
| -#include "content/public/browser/browser_thread.h"
|
| -#include "content/public/browser/render_process_host.h"
|
| -#include "content/public/browser/worker_service.h"
|
| -#include "ipc/ipc_listener.h"
|
| -
|
| -namespace content {
|
| -
|
| -namespace {
|
| -
|
| -bool SendMessageToWorker(const SharedWorkerDevToolsManager::WorkerId& worker_id,
|
| - IPC::Message* message) {
|
| - RenderProcessHost* host = RenderProcessHost::FromID(worker_id.first);
|
| - if (!host) {
|
| - delete message;
|
| - return false;
|
| - }
|
| - message->set_routing_id(worker_id.second);
|
| - host->Send(message);
|
| - return true;
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -class SharedWorkerDevToolsManager::SharedWorkerDevToolsAgentHost
|
| - : public IPCDevToolsAgentHost,
|
| - public IPC::Listener {
|
| - public:
|
| - explicit SharedWorkerDevToolsAgentHost(WorkerId worker_id)
|
| - : worker_id_(worker_id), worker_attached_(true) {
|
| - AddRef();
|
| - if (RenderProcessHost* host = RenderProcessHost::FromID(worker_id_.first))
|
| - host->AddRoute(worker_id_.second, this);
|
| - }
|
| -
|
| - // IPCDevToolsAgentHost implementation.
|
| - virtual void SendMessageToAgent(IPC::Message* message) OVERRIDE {
|
| - if (worker_attached_)
|
| - SendMessageToWorker(worker_id_, message);
|
| - }
|
| - virtual void OnClientAttached() OVERRIDE {}
|
| - virtual void OnClientDetached() OVERRIDE {}
|
| -
|
| - // IPC::Listener implementation.
|
| - virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(SharedWorkerDevToolsAgentHost, msg)
|
| - IPC_MESSAGE_HANDLER(DevToolsClientMsg_DispatchOnInspectorFrontend,
|
| - OnDispatchOnInspectorFrontend)
|
| - IPC_MESSAGE_HANDLER(DevToolsHostMsg_SaveAgentRuntimeState,
|
| - OnSaveAgentRuntimeState)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - return handled;
|
| - }
|
| -
|
| - void ReattachToWorker(WorkerId worker_id) {
|
| - CHECK(!worker_attached_);
|
| - worker_attached_ = true;
|
| - worker_id_ = worker_id;
|
| - AddRef();
|
| - if (RenderProcessHost* host = RenderProcessHost::FromID(worker_id_.first))
|
| - host->AddRoute(worker_id_.second, this);
|
| - Reattach(state_);
|
| - }
|
| -
|
| - void DetachFromWorker() {
|
| - CHECK(worker_attached_);
|
| - worker_attached_ = false;
|
| - if (RenderProcessHost* host = RenderProcessHost::FromID(worker_id_.first))
|
| - host->RemoveRoute(worker_id_.second);
|
| - Release();
|
| - }
|
| -
|
| - WorkerId worker_id() const { return worker_id_; }
|
| -
|
| - private:
|
| - virtual ~SharedWorkerDevToolsAgentHost() {
|
| - CHECK(!worker_attached_);
|
| - SharedWorkerDevToolsManager::GetInstance()->RemoveInspectedWorkerData(this);
|
| - }
|
| -
|
| - void OnDispatchOnInspectorFrontend(const std::string& message) {
|
| - DevToolsManagerImpl::GetInstance()->DispatchOnInspectorFrontend(this,
|
| - message);
|
| - }
|
| -
|
| - void OnSaveAgentRuntimeState(const std::string& state) { state_ = state; }
|
| -
|
| - WorkerId worker_id_;
|
| - bool worker_attached_;
|
| - std::string state_;
|
| - DISALLOW_COPY_AND_ASSIGN(SharedWorkerDevToolsAgentHost);
|
| -};
|
| -
|
| -// static
|
| -SharedWorkerDevToolsManager* SharedWorkerDevToolsManager::GetInstance() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - return Singleton<SharedWorkerDevToolsManager>::get();
|
| -}
|
| -
|
| -DevToolsAgentHost* SharedWorkerDevToolsManager::GetDevToolsAgentHostForWorker(
|
| - int worker_process_id,
|
| - int worker_route_id) {
|
| - WorkerId id(worker_process_id, worker_route_id);
|
| -
|
| - WorkerInfoMap::iterator it = workers_.find(id);
|
| - if (it == workers_.end())
|
| - return NULL;
|
| -
|
| - WorkerInfo* info = it->second;
|
| - if (info->state() != WORKER_UNINSPECTED)
|
| - return info->agent_host();
|
| -
|
| - SharedWorkerDevToolsAgentHost* agent_host =
|
| - new SharedWorkerDevToolsAgentHost(id);
|
| - info->set_agent_host(agent_host);
|
| - info->set_state(WORKER_INSPECTED);
|
| - return agent_host;
|
| -}
|
| -
|
| -SharedWorkerDevToolsManager::SharedWorkerDevToolsManager() {}
|
| -
|
| -SharedWorkerDevToolsManager::~SharedWorkerDevToolsManager() {}
|
| -
|
| -bool SharedWorkerDevToolsManager::WorkerCreated(
|
| - int worker_process_id,
|
| - int worker_route_id,
|
| - const SharedWorkerInstance& instance) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - const WorkerId id(worker_process_id, worker_route_id);
|
| - WorkerInfoMap::iterator it = FindExistingWorkerInfo(instance);
|
| - if (it == workers_.end()) {
|
| - scoped_ptr<WorkerInfo> info(new WorkerInfo(instance));
|
| - workers_.set(id, info.Pass());
|
| - return false;
|
| - }
|
| - DCHECK_EQ(WORKER_TERMINATED, it->second->state());
|
| - scoped_ptr<WorkerInfo> info = workers_.take_and_erase(it);
|
| - info->set_state(WORKER_PAUSED);
|
| - workers_.set(id, info.Pass());
|
| - return true;
|
| -}
|
| -
|
| -void SharedWorkerDevToolsManager::WorkerDestroyed(int worker_process_id,
|
| - int worker_route_id) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - const WorkerId id(worker_process_id, worker_route_id);
|
| - WorkerInfoMap::iterator it = workers_.find(id);
|
| - DCHECK(it != workers_.end());
|
| - WorkerInfo* info = it->second;
|
| - switch (info->state()) {
|
| - case WORKER_UNINSPECTED:
|
| - workers_.erase(it);
|
| - break;
|
| - case WORKER_INSPECTED: {
|
| - SharedWorkerDevToolsAgentHost* agent_host = info->agent_host();
|
| - if (!agent_host->IsAttached()) {
|
| - scoped_ptr<WorkerInfo> worker_info = workers_.take_and_erase(it);
|
| - agent_host->DetachFromWorker();
|
| - return;
|
| - }
|
| - info->set_state(WORKER_TERMINATED);
|
| - // Client host is debugging this worker agent host.
|
| - std::string notification =
|
| - DevToolsProtocol::CreateNotification(
|
| - devtools::Worker::disconnectedFromWorker::kName, NULL)
|
| - ->Serialize();
|
| - DevToolsManagerImpl::GetInstance()->DispatchOnInspectorFrontend(
|
| - agent_host, notification);
|
| - agent_host->DetachFromWorker();
|
| - break;
|
| - }
|
| - case WORKER_TERMINATED:
|
| - NOTREACHED();
|
| - break;
|
| - case WORKER_PAUSED: {
|
| - scoped_ptr<WorkerInfo> worker_info = workers_.take_and_erase(it);
|
| - worker_info->set_state(WORKER_TERMINATED);
|
| - const WorkerId old_id = worker_info->agent_host()->worker_id();
|
| - workers_.set(old_id, worker_info.Pass());
|
| - break;
|
| - }
|
| - }
|
| -}
|
| -
|
| -void SharedWorkerDevToolsManager::WorkerContextStarted(int worker_process_id,
|
| - int worker_route_id) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - const WorkerId id(worker_process_id, worker_route_id);
|
| - WorkerInfoMap::iterator it = workers_.find(id);
|
| - DCHECK(it != workers_.end());
|
| - WorkerInfo* info = it->second;
|
| - if (info->state() != WORKER_PAUSED)
|
| - return;
|
| - info->agent_host()->ReattachToWorker(id);
|
| - info->set_state(WORKER_INSPECTED);
|
| -}
|
| -
|
| -void SharedWorkerDevToolsManager::RemoveInspectedWorkerData(
|
| - SharedWorkerDevToolsAgentHost* agent_host) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
|
| - const WorkerId id(agent_host->worker_id());
|
| - scoped_ptr<WorkerInfo> worker_info = workers_.take_and_erase(id);
|
| - if (worker_info) {
|
| - DCHECK_EQ(WORKER_TERMINATED, worker_info->state());
|
| - return;
|
| - }
|
| - for (WorkerInfoMap::iterator it = workers_.begin(); it != workers_.end();
|
| - ++it) {
|
| - if (it->second->agent_host() == agent_host) {
|
| - DCHECK_EQ(WORKER_PAUSED, it->second->state());
|
| - SendMessageToWorker(
|
| - it->first,
|
| - new DevToolsAgentMsg_ResumeWorkerContext(it->first.second));
|
| - it->second->set_agent_host(NULL);
|
| - it->second->set_state(WORKER_UNINSPECTED);
|
| - return;
|
| - }
|
| - }
|
| -}
|
| -
|
| -SharedWorkerDevToolsManager::WorkerInfoMap::iterator
|
| -SharedWorkerDevToolsManager::FindExistingWorkerInfo(
|
| - const SharedWorkerInstance& instance) {
|
| - WorkerInfoMap::iterator it = workers_.begin();
|
| - for (; it != workers_.end(); ++it) {
|
| - if (it->second->instance().Matches(instance))
|
| - break;
|
| - }
|
| - return it;
|
| -}
|
| -
|
| -void SharedWorkerDevToolsManager::ResetForTesting() { workers_.clear(); }
|
| -
|
| -} // namespace content
|
|
|