[WIP][worklets] ThreadedWorkletGlobalScope + AnimationWorkletGlobalScope

third_party/WebKit/Source/core/workers/ThreadedWorkletObjectProxy.cpp

 /*
- * Copyright (C) 2009 Google Inc. All rights reserved.
+ * Copyright (C) 2013 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
  * copyright notice, this list of conditions and the following disclaimer
  * in the documentation and/or other materials provided with the
  * distribution.
  *     * Neither the name of Google Inc. nor the names of its
  * contributors may be used to endorse or promote products derived from
  * this software without specific prior written permission.
  *
  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND 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 THE COPYRIGHT
  * OWNER 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 "modules/webdatabase/SQLTransactionClient.h"
+#include "core/workers/ThreadedWorkletObjectProxy.h"
 
+#include "bindings/core/v8/SerializedScriptValue.h"
+#include "bindings/core/v8/SourceLocation.h"
+#include "core/dom/Document.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/dom/ExecutionContextTask.h"
-#include "modules/webdatabase/Database.h"
-#include "modules/webdatabase/DatabaseContext.h"
-#include "platform/weborigin/SecurityOrigin.h"
-#include "public/platform/Platform.h"
-#include "public/platform/WebDatabaseObserver.h"
-#include "public/platform/WebSecurityOrigin.h"
-#include "public/platform/WebTraceLocation.h"
+#include "core/inspector/ConsoleMessage.h"
+#include "core/workers/ThreadedWorkletMessagingProxy.h"
 #include "wtf/Functional.h"
+#include "wtf/PtrUtil.h"
+#include <memory>
 
 namespace blink {
 
-namespace {
-
-void databaseModified(const WebSecurityOrigin& origin, const String& databaseName)
+std::unique_ptr<ThreadedWorkletObjectProxy> ThreadedWorkletObjectProxy::create(ThreadedWorkletMessagingProxy* messagingProxy)
 {
-    if (Platform::current()->databaseObserver())
-        Platform::current()->databaseObserver()->databaseModified(origin, databaseName);
+    DCHECK(messagingProxy);
+    return wrapUnique(new ThreadedWorkletObjectProxy(messagingProxy));
 }
 
-void databaseModifiedCrossThread(const String& originString, const String& databaseName)
+void ThreadedWorkletObjectProxy::postTaskToMainExecutionContext(std::unique_ptr<ExecutionContextTask> task)
 {
-    databaseModified(WebSecurityOrigin::createFromString(originString), databaseName);
+    getExecutionContext()->postTask(BLINK_FROM_HERE, std::move(task));
 }
 
-} // namespace
-
-void SQLTransactionClient::didCommitWriteTransaction(Database* database)
+void ThreadedWorkletObjectProxy::reportPendingActivity(bool hasPendingActivity)
 {
-    String databaseName = database->stringIdentifier();
-    ExecutionContext* executionContext = database->getDatabaseContext()->getExecutionContext();
-    if (!executionContext->isContextThread()) {
-        executionContext->postTask(BLINK_FROM_HERE, createCrossThreadTask(&databaseModifiedCrossThread, executionContext->getSecurityOrigin()->toRawString(), databaseName));
-    } else {
-        databaseModified(WebSecurityOrigin(executionContext->getSecurityOrigin()), databaseName);
-    }
+    getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&ThreadedWorkletMessagingProxy::reportPendingActivity, crossThreadUnretained(m_messagingProxy), hasPendingActivity));
 }
 
-bool SQLTransactionClient::didExceedQuota(Database* database)
+void ThreadedWorkletObjectProxy::reportConsoleMessage(MessageSource source, MessageLevel level, const String& message, SourceLocation* location)
 {
-    // Chromium does not allow users to manually change the quota for an origin (for now, at least).
-    // Don't do anything.
-    ASSERT(database->getDatabaseContext()->getExecutionContext()->isContextThread());
-    return false;
+    getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&ThreadedWorkletMessagingProxy::reportConsoleMessage, crossThreadUnretained(m_messagingProxy), source, level, message, passed(location->clone())));
+}
+
+void ThreadedWorkletObjectProxy::postMessageToPageInspector(const String& message)
+{
+    ExecutionContext* context = getExecutionContext();
+    if (context->isDocument())
+        toDocument(context)->postInspectorTask(BLINK_FROM_HERE, createCrossThreadTask(&ThreadedWorkletMessagingProxy::postMessageToPageInspector, crossThreadUnretained(m_messagingProxy), message));
+}
+
+void ThreadedWorkletObjectProxy::workerGlobalScopeClosed()
+{
+    getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&ThreadedWorkletMessagingProxy::terminateWorkletGlobalScope, crossThreadUnretained(m_messagingProxy)));
+}
+
+void ThreadedWorkletObjectProxy::workerThreadTerminated()
+{
+    // This will terminate the MessagingProxy.
+    getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&ThreadedWorkletMessagingProxy::workerThreadTerminated, crossThreadUnretained(m_messagingProxy)));
+}
+
+ThreadedWorkletObjectProxy::ThreadedWorkletObjectProxy(ThreadedWorkletMessagingProxy* messagingProxy)
+    : m_messagingProxy(messagingProxy)
+{
+}
+
+ExecutionContext* ThreadedWorkletObjectProxy::getExecutionContext() const
+{
+    DCHECK(m_messagingProxy);
+    return m_messagingProxy->getExecutionContext();
 }
 
 } // namespace blink