/* * Copyright (C) 2016 Apple 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: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF * THE POSSIBILITY OF SUCH DAMAGE. */ #include "config.h" #include "WorkerInspectorController.h" #include "CommandLineAPIHost.h" #include "InstrumentingAgents.h" #include "JSMainThreadExecState.h" #include "WebHeapAgent.h" #include "WebInjectedScriptHost.h" #include "WebInjectedScriptManager.h" #include "WorkerConsoleAgent.h" #include "WorkerDebuggerAgent.h" #include "WorkerGlobalScope.h" #include "WorkerRuntimeAgent.h" #include "WorkerThread.h" #include "WorkerToPageFrontendChannel.h" #include #include #include #include #include using namespace JSC; using namespace Inspector; namespace WebCore { WorkerInspectorController::WorkerInspectorController(WorkerGlobalScope& workerGlobalScope) : m_instrumentingAgents(InstrumentingAgents::create(*this)) , m_injectedScriptManager(std::make_unique(*this, WebInjectedScriptHost::create())) , m_frontendRouter(FrontendRouter::create()) , m_backendDispatcher(BackendDispatcher::create(m_frontendRouter.copyRef())) , m_executionStopwatch(Stopwatch::create()) , m_scriptDebugServer(workerGlobalScope) , m_workerGlobalScope(workerGlobalScope) { AgentContext baseContext = { *this, *m_injectedScriptManager, m_frontendRouter.get(), m_backendDispatcher.get(), }; WebAgentContext webContext = { baseContext, m_instrumentingAgents.get(), }; WorkerAgentContext workerContext = { webContext, workerGlobalScope, }; auto heapAgent = std::make_unique(workerContext); m_agents.append(std::make_unique(workerContext)); m_agents.append(std::make_unique(workerContext)); auto consoleAgent = std::make_unique(workerContext, heapAgent.get()); m_instrumentingAgents->setWebConsoleAgent(consoleAgent.get()); m_agents.append(WTFMove(consoleAgent)); m_agents.append(WTFMove(heapAgent)); if (CommandLineAPIHost* commandLineAPIHost = m_injectedScriptManager->commandLineAPIHost()) { commandLineAPIHost->init( nullptr // InspectorAgent , m_instrumentingAgents->webConsoleAgent() , nullptr // InspectorDOMAgent , nullptr // InspectorDOMStorageAgent , nullptr // InspectorDatabaseAgent ); } } WorkerInspectorController::~WorkerInspectorController() { ASSERT(!m_frontendRouter->hasFrontends()); ASSERT(!m_forwardingChannel); m_instrumentingAgents->reset(); } void WorkerInspectorController::workerTerminating() { m_injectedScriptManager->disconnect(); disconnectFrontend(Inspector::DisconnectReason::InspectedTargetDestroyed); m_agents.discardValues(); } void WorkerInspectorController::connectFrontend() { ASSERT(!m_frontendRouter->hasFrontends()); ASSERT(!m_forwardingChannel); m_forwardingChannel = std::make_unique(m_workerGlobalScope); m_frontendRouter->connectFrontend(m_forwardingChannel.get()); m_agents.didCreateFrontendAndBackend(&m_frontendRouter.get(), &m_backendDispatcher.get()); } void WorkerInspectorController::disconnectFrontend(Inspector::DisconnectReason reason) { if (!m_frontendRouter->hasFrontends()) return; ASSERT(m_forwardingChannel); m_agents.willDestroyFrontendAndBackend(reason); m_frontendRouter->disconnectFrontend(m_forwardingChannel.get()); m_forwardingChannel = nullptr; } void WorkerInspectorController::dispatchMessageFromFrontend(const String& message) { m_backendDispatcher->dispatch(message); } InspectorFunctionCallHandler WorkerInspectorController::functionCallHandler() const { return WebCore::functionCallHandlerFromAnyThread; } InspectorEvaluateHandler WorkerInspectorController::evaluateHandler() const { return WebCore::evaluateHandlerFromAnyThread; } VM& WorkerInspectorController::vm() { return m_workerGlobalScope.vm(); } } // namespace WebCore