Expose Web Animations API to Web Workers

Source/core/workers/Worker.cpp

 /*
  * Copyright (C) 2008, 2010 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
@@ skipping 11 matching lines @@
  * 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 "core/workers/Worker.h"
 
 #include "bindings/core/v8/ExceptionState.h"
+#include "core/dom/CrossThreadTask.h"
 #include "core/dom/Document.h"
 #include "core/events/MessageEvent.h"
 #include "core/fetch/ResourceFetcher.h"
 #include "core/inspector/InspectorInstrumentation.h"
 #include "core/frame/LocalDOMWindow.h"
 #include "core/frame/UseCounter.h"
+#include "core/page/Page.h"
+#include "core/workers/WorkerGlobalScope.h"
 #include "core/workers/WorkerGlobalScopeProxy.h"
 #include "core/workers/WorkerGlobalScopeProxyProvider.h"
 #include "core/workers/WorkerScriptLoader.h"
 #include "core/workers/WorkerThread.h"
 #include "wtf/MainThread.h"
 
 namespace blink {
 
 inline Worker::Worker(ExecutionContext* context)
     : AbstractWorker(context)
@@ skipping 18 matching lines @@
 
     worker->suspendIfNeeded();
 
     KURL scriptURL = worker->resolveURL(url, exceptionState);
     if (scriptURL.isEmpty())
         return nullptr;
 
     worker->m_scriptLoader = WorkerScriptLoader::create();
     worker->m_scriptLoader->loadAsynchronously(*context, scriptURL, DenyCrossOriginRequests, worker.get());
     worker->m_contextProxy = proxyProvider->createWorkerGlobalScopeProxy(worker.get());
+    worker->context = context;
+
+
     return worker.release();
 }
 
+
 Worker::~Worker()
 {
     ASSERT(isMainThread());
     if (!m_contextProxy)
         return;
     ASSERT(executionContext()); // The context is protected by worker context proxy, so it cannot be destroyed while a Worker exists.
     m_contextProxy->workerObjectDestroyed();
 }
 
 const AtomicString& Worker::interfaceName() const
@@ skipping 46 matching lines @@
         InspectorInstrumentation::scriptImported(executionContext(), m_scriptLoader->identifier(), m_scriptLoader->script());
     }
     m_scriptLoader = nullptr;
 }
 
 void Worker::trace(Visitor* visitor)
 {
     AbstractWorker::trace(visitor);
 }
 
+void Worker::processRAF(double monotonicAnimationStartTime)
+{
+    WorkerMessagingProxy* mp = static_cast<WorkerMessagingProxy*>(m_contextProxy);
+    WorkerGlobalScope* hold = mp->passObject();
+    if (hold) {
+        mp->postTaskToWorkerGlobalScope(createCrossThreadTask(&WorkerGlobalScope::processRAF, AllowCrossThreadAccess(hold), monotonicAnimationStartTime));
+    }
+}
+
 } // namespace blink