Expose Web Animations API to Web Workers

Source/core/workers/WorkerGlobalScope.cpp

 /*
  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
  * Copyright (C) 2009, 2011 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 17 matching lines @@
 #include "config.h"
 #include "core/workers/WorkerGlobalScope.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScheduledAction.h"
 #include "bindings/core/v8/ScriptSourceCode.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "core/dom/ActiveDOMObject.h"
 #include "core/dom/AddConsoleMessageTask.h"
 #include "core/dom/ContextLifecycleNotifier.h"
+#include "core/dom/CrossThreadTask.h"
 #include "core/dom/DOMURL.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/MessagePort.h"
 #include "core/events/ErrorEvent.h"
 #include "core/events/Event.h"
 #include "core/inspector/InspectorConsoleInstrumentation.h"
 #include "core/inspector/ScriptCallStack.h"
 #include "core/inspector/WorkerInspectorController.h"
 #include "core/loader/WorkerThreadableLoader.h"
 #include "core/frame/LocalDOMWindow.h"
@@ skipping 44 matching lines @@
     ScriptWrappable::init(this);
     setClient(this);
     setSecurityOrigin(SecurityOrigin::create(url));
     m_workerClients->reattachThread();
 }
 
 WorkerGlobalScope::~WorkerGlobalScope()
 {
 }
 
+void WorkerGlobalScope::requestAnimationFrame(PassOwnPtr<RequestAnimationFrameCallback> insert)
+{
+    if (!rAFPendingList) {
+        rAFPendingList = adoptPtr(new Vector<OwnPtr<RequestAnimationFrameCallback> >());
+    }
+    rAFPendingList->append(insert);
+}
+
+void WorkerGlobalScope::processRAF(double monotonicAnimationStartTime)
+{
+    postTask(createCrossThreadTask(&WorkerGlobalScope::processRAFOnWorkerThread, this, monotonicAnimationStartTime));
+}
+
+void WorkerGlobalScope::processRAFOnWorkerThread(double monotonicAnimationStartTime)
+{
+    if (!rAFPendingList)
+        return;
+    OwnPtr<Vector<OwnPtr<RequestAnimationFrameCallback> > > oldRAFList = rAFPendingList.release();
+    for (unsigned i = 0; i < oldRAFList->size(); i++) {
+        oldRAFList->at(i)->handleEvent(monotonicAnimationStartTime);
+    }
+}
+
 void WorkerGlobalScope::applyContentSecurityPolicyFromString(const String& policy, ContentSecurityPolicyHeaderType contentSecurityPolicyType)
 {
     setContentSecurityPolicy(ContentSecurityPolicy::create(this));
     contentSecurityPolicy()->didReceiveHeader(policy, contentSecurityPolicyType, ContentSecurityPolicyHeaderSourceHTTP);
 }
 
 ExecutionContext* WorkerGlobalScope::executionContext() const
 {
     return const_cast<WorkerGlobalScope*>(this);
 }
@@ skipping 228 matching lines @@
     visitor->trace(m_location);
     visitor->trace(m_navigator);
     visitor->trace(m_eventQueue);
     visitor->trace(m_workerClients);
     WillBeHeapSupplementable<WorkerGlobalScope>::trace(visitor);
     ExecutionContext::trace(visitor);
     EventTargetWithInlineData::trace(visitor);
 }
 
 } // namespace blink