/* * Copyright (C) 2008-2017 Apple Inc. All Rights Reserved. * Copyright (C) 2009 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: * 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. ``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 * 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 "WorkerMessagingProxy.h" #include "CacheStorageProvider.h" #include "ContentSecurityPolicy.h" #include "DOMWindow.h" #include "DedicatedWorkerGlobalScope.h" #include "DedicatedWorkerThread.h" #include "Document.h" #include "ErrorEvent.h" #include "EventNames.h" #include "FetchRequestCredentials.h" #include "LibWebRTCProvider.h" #include "MessageEvent.h" #include "Page.h" #include "ScriptExecutionContext.h" #include "Settings.h" #include "Worker.h" #include "WorkerInspectorProxy.h" #include #include #include #include namespace WebCore { WorkerGlobalScopeProxy& WorkerGlobalScopeProxy::create(Worker& worker) { return *new WorkerMessagingProxy(worker); } WorkerMessagingProxy::WorkerMessagingProxy(Worker& workerObject) : m_scriptExecutionContext(workerObject.scriptExecutionContext()) , m_inspectorProxy(makeUnique(workerObject.identifier())) , m_workerObject(&workerObject) { ASSERT((is(*m_scriptExecutionContext) && isMainThread()) || (is(*m_scriptExecutionContext) && downcast(*m_scriptExecutionContext).thread().thread() == &Thread::current())); // Nobody outside this class ref counts this object. The original ref // is balanced by the deref in workerGlobalScopeDestroyedInternal. } WorkerMessagingProxy::~WorkerMessagingProxy() { ASSERT(!m_workerObject); ASSERT((is(*m_scriptExecutionContext) && isMainThread()) || (is(*m_scriptExecutionContext) && downcast(*m_scriptExecutionContext).thread().thread() == &Thread::current())); } void WorkerMessagingProxy::startWorkerGlobalScope(const URL& scriptURL, const String& name, const String& userAgent, bool isOnline, const ScriptBuffer& sourceCode, const ContentSecurityPolicyResponseHeaders& contentSecurityPolicyResponseHeaders, bool shouldBypassMainWorldContentSecurityPolicy, const CrossOriginEmbedderPolicy& crossOriginEmbedderPolicy, MonotonicTime timeOrigin, ReferrerPolicy referrerPolicy, WorkerType workerType, FetchRequestCredentials credentials, JSC::RuntimeFlags runtimeFlags) { // FIXME: This need to be revisited when we support nested worker one day ASSERT(m_scriptExecutionContext); Document& document = downcast(*m_scriptExecutionContext); WorkerThreadStartMode startMode = m_inspectorProxy->workerStartMode(*m_scriptExecutionContext.get()); String identifier = m_inspectorProxy->identifier(); IDBClient::IDBConnectionProxy* proxy = document.idbConnectionProxy(); SocketProvider* socketProvider = document.socketProvider(); WorkerParameters params = { scriptURL, name, identifier, userAgent, isOnline, contentSecurityPolicyResponseHeaders, shouldBypassMainWorldContentSecurityPolicy, crossOriginEmbedderPolicy, timeOrigin, referrerPolicy, workerType, credentials, document.settingsValues() }; auto thread = DedicatedWorkerThread::create(params, sourceCode, *this, *this, *this, startMode, document.topOrigin(), proxy, socketProvider, runtimeFlags); workerThreadCreated(thread.get()); thread->start(); m_inspectorProxy->workerStarted(m_scriptExecutionContext.get(), thread.ptr(), scriptURL, name); } void WorkerMessagingProxy::postMessageToWorkerObject(MessageWithMessagePorts&& message) { m_scriptExecutionContext->postTask([this, message = WTFMove(message)] (ScriptExecutionContext& context) mutable { Worker* workerObject = this->workerObject(); if (!workerObject || askedToTerminate()) return; auto ports = MessagePort::entanglePorts(context, WTFMove(message.transferredPorts)); ActiveDOMObject::queueTaskToDispatchEvent(*workerObject, TaskSource::PostedMessageQueue, MessageEvent::create(WTFMove(ports), message.message.releaseNonNull())); }); } void WorkerMessagingProxy::postTaskToWorkerObject(Function&& function) { m_scriptExecutionContext->postTask([this, function = WTFMove(function)](auto&) mutable { auto* workerObject = this->workerObject(); if (!workerObject || askedToTerminate()) return; function(*workerObject); }); } void WorkerMessagingProxy::postMessageToWorkerGlobalScope(MessageWithMessagePorts&& message) { postTaskToWorkerGlobalScope([message = WTFMove(message)](auto& scriptContext) mutable { ASSERT_WITH_SECURITY_IMPLICATION(scriptContext.isWorkerGlobalScope()); auto& context = static_cast(scriptContext); auto ports = MessagePort::entanglePorts(scriptContext, WTFMove(message.transferredPorts)); context.dispatchEvent(MessageEvent::create(WTFMove(ports), message.message.releaseNonNull())); context.thread().workerObjectProxy().confirmMessageFromWorkerObject(context.hasPendingActivity()); }); } void WorkerMessagingProxy::postTaskToWorkerGlobalScope(Function&& task) { if (m_askedToTerminate) return; if (!m_workerThread) { m_queuedEarlyTasks.append(makeUnique(WTFMove(task))); return; } ++m_unconfirmedMessageCount; m_workerThread->runLoop().postTask(WTFMove(task)); } void WorkerMessagingProxy::suspendForBackForwardCache() { if (m_workerThread) m_workerThread->suspend(); else m_askedToSuspend = true; } void WorkerMessagingProxy::resumeForBackForwardCache() { if (m_workerThread) m_workerThread->resume(); else m_askedToSuspend = false; } void WorkerMessagingProxy::postTaskToLoader(ScriptExecutionContext::Task&& task) { // FIXME: In case of nested workers, this should go directly to the root Document context. ASSERT(m_scriptExecutionContext->isDocument()); m_scriptExecutionContext->postTask(WTFMove(task)); } RefPtr WorkerMessagingProxy::createCacheStorageConnection() { ASSERT(isMainThread()); auto& document = downcast(*m_scriptExecutionContext); return document.page()->cacheStorageProvider().createCacheStorageConnection(); } RefPtr WorkerMessagingProxy::createRTCDataChannelRemoteHandlerConnection() { ASSERT(isMainThread()); auto& document = downcast(*m_scriptExecutionContext); if (!document.page()) return nullptr; return document.page()->libWebRTCProvider().createRTCDataChannelRemoteHandlerConnection(); } bool WorkerMessagingProxy::postTaskForModeToWorkerOrWorkletGlobalScope(ScriptExecutionContext::Task&& task, const String& mode) { if (m_askedToTerminate) return false; ASSERT(m_workerThread); m_workerThread->runLoop().postTaskForMode(WTFMove(task), mode); return true; } void WorkerMessagingProxy::postExceptionToWorkerObject(const String& errorMessage, int lineNumber, int columnNumber, const String& sourceURL) { m_scriptExecutionContext->postTask([this, errorMessage = errorMessage.isolatedCopy(), sourceURL = sourceURL.isolatedCopy(), lineNumber, columnNumber] (ScriptExecutionContext&) { Worker* workerObject = this->workerObject(); if (!workerObject) return; // We don't bother checking the askedToTerminate() flag here, because exceptions should *always* be reported even if the thread is terminated. // This is intentionally different than the behavior in MessageWorkerTask, because terminated workers no longer deliver messages (section 4.6 of the WebWorker spec), but they do report exceptions. ActiveDOMObject::queueTaskToDispatchEvent(*workerObject, TaskSource::DOMManipulation, ErrorEvent::create(errorMessage, sourceURL, lineNumber, columnNumber, { })); }); } void WorkerMessagingProxy::postMessageToDebugger(const String& message) { RunLoop::main().dispatch([this, protectedThis = makeRef(*this), message = message.isolatedCopy()] { if (!m_mayBeDestroyed) m_inspectorProxy->sendMessageFromWorkerToFrontend(message); }); } void WorkerMessagingProxy::setResourceCachingDisabledByWebInspector(bool disabled) { postTaskToLoader([disabled] (ScriptExecutionContext& context) { ASSERT(isMainThread()); if (auto* page = downcast(context).page()) page->setResourceCachingDisabledByWebInspector(disabled); }); } void WorkerMessagingProxy::workerThreadCreated(DedicatedWorkerThread& workerThread) { m_workerThread = &workerThread; if (m_askedToTerminate) { // Worker.terminate() could be called from JS before the thread was created. m_workerThread->stop(nullptr); } else { if (m_askedToSuspend) { m_askedToSuspend = false; m_workerThread->suspend(); } ASSERT(!m_unconfirmedMessageCount); m_unconfirmedMessageCount = m_queuedEarlyTasks.size(); m_workerThreadHadPendingActivity = true; // Worker initialization means a pending activity. auto queuedEarlyTasks = WTFMove(m_queuedEarlyTasks); for (auto& task : queuedEarlyTasks) m_workerThread->runLoop().postTask(WTFMove(*task)); } } void WorkerMessagingProxy::workerObjectDestroyed() { m_workerObject = nullptr; m_scriptExecutionContext->postTask([this] (ScriptExecutionContext&) { m_mayBeDestroyed = true; if (m_workerThread) terminateWorkerGlobalScope(); else workerGlobalScopeDestroyedInternal(); }); } void WorkerMessagingProxy::notifyNetworkStateChange(bool isOnline) { if (m_askedToTerminate) return; if (!m_workerThread) return; m_workerThread->runLoop().postTask([isOnline] (ScriptExecutionContext& context) { auto& globalScope = downcast(context); globalScope.setIsOnline(isOnline); globalScope.dispatchEvent(Event::create(isOnline ? eventNames().onlineEvent : eventNames().offlineEvent, Event::CanBubble::No, Event::IsCancelable::No)); }); } void WorkerMessagingProxy::workerGlobalScopeDestroyed() { m_scriptExecutionContext->postTask([this] (ScriptExecutionContext&) { workerGlobalScopeDestroyedInternal(); }); } void WorkerMessagingProxy::workerGlobalScopeClosed() { m_scriptExecutionContext->postTask([this] (ScriptExecutionContext&) { terminateWorkerGlobalScope(); }); } void WorkerMessagingProxy::workerGlobalScopeDestroyedInternal() { // This is always the last task to be performed, so the proxy is not needed for communication // in either side any more. However, the Worker object may still exist, and it assumes that the proxy exists, too. m_askedToTerminate = true; m_workerThread = nullptr; m_inspectorProxy->workerTerminated(); // This balances the original ref in construction. if (m_mayBeDestroyed) deref(); } void WorkerMessagingProxy::terminateWorkerGlobalScope() { if (m_askedToTerminate) return; m_askedToTerminate = true; m_inspectorProxy->workerTerminated(); if (m_workerThread) m_workerThread->stop(nullptr); } void WorkerMessagingProxy::confirmMessageFromWorkerObject(bool hasPendingActivity) { m_scriptExecutionContext->postTask([this, hasPendingActivity] (ScriptExecutionContext&) { reportPendingActivityInternal(true, hasPendingActivity); }); } void WorkerMessagingProxy::reportPendingActivity(bool hasPendingActivity) { m_scriptExecutionContext->postTask([this, hasPendingActivity] (ScriptExecutionContext&) { reportPendingActivityInternal(false, hasPendingActivity); }); } void WorkerMessagingProxy::reportPendingActivityInternal(bool confirmingMessage, bool hasPendingActivity) { if (confirmingMessage && !m_askedToTerminate) { ASSERT(m_unconfirmedMessageCount); --m_unconfirmedMessageCount; } m_workerThreadHadPendingActivity = hasPendingActivity; } bool WorkerMessagingProxy::hasPendingActivity() const { return (m_unconfirmedMessageCount || m_workerThreadHadPendingActivity) && !m_askedToTerminate; } } // namespace WebCore