Index: third_party/WebKit/Source/core/workers/WorkerThread.h |
diff --git a/third_party/WebKit/Source/core/workers/WorkerThread.h b/third_party/WebKit/Source/core/workers/WorkerThread.h |
deleted file mode 100644 |
index f25b045fdb2a6db91e986ef9a5ed13fe30430ab4..0000000000000000000000000000000000000000 |
--- a/third_party/WebKit/Source/core/workers/WorkerThread.h |
+++ /dev/null |
@@ -1,189 +0,0 @@ |
-/* |
- * Copyright (C) 2008 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 COMPUTER, 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 COMPUTER, 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. |
- * |
- */ |
- |
-#ifndef WorkerThread_h |
-#define WorkerThread_h |
- |
-#include "core/CoreExport.h" |
-#include "core/dom/ExecutionContextTask.h" |
-#include "core/frame/csp/ContentSecurityPolicy.h" |
-#include "core/workers/WorkerGlobalScope.h" |
-#include "core/workers/WorkerLoaderProxy.h" |
-#include "platform/WebThreadSupportingGC.h" |
-#include "platform/weborigin/SecurityOrigin.h" |
-#include "wtf/Forward.h" |
-#include "wtf/OwnPtr.h" |
-#include "wtf/PassRefPtr.h" |
-#include "wtf/RefCounted.h" |
-#include <v8.h> |
- |
-namespace blink { |
- |
-class WaitableEvent; |
-class WorkerGlobalScope; |
-class WorkerInspectorController; |
-class WorkerMicrotaskRunner; |
-class WorkerReportingProxy; |
-class WorkerThreadStartupData; |
- |
-enum WorkerThreadStartMode { |
- DontPauseWorkerGlobalScopeOnStart, |
- PauseWorkerGlobalScopeOnStart |
-}; |
- |
-// TODO(sadrul): Rename to WorkerScript. |
-class CORE_EXPORT WorkerThread : public RefCounted<WorkerThread> { |
-public: |
- virtual ~WorkerThread(); |
- |
- // Called on the main thread. |
- void start(PassOwnPtr<WorkerThreadStartupData>); |
- void terminate(); |
- |
- // Returns the thread this worker runs on. Some implementations can create |
- // a new thread on the first call (e.g. shared, dedicated workers), whereas |
- // some implementations can use an existing thread that is already being |
- // used by other workers (e.g. compositor workers). |
- virtual WebThreadSupportingGC& backingThread() = 0; |
- |
- virtual void didStartWorkerThread(); |
- virtual void willStopWorkerThread(); |
- |
- v8::Isolate* isolate() const { return m_isolate; } |
- |
- // Can be used to wait for this worker thread to shut down. |
- // (This is signaled on the main thread, so it's assumed to be waited on |
- // the worker context thread) |
- WaitableEvent* shutdownEvent() { return m_shutdownEvent.get(); } |
- |
- // Called in shutdown sequence. Internally calls terminate() (or |
- // terminateInternal) and wait (by *blocking* the calling thread) until the |
- // worker(s) is/are shut down. |
- void terminateAndWait(); |
- static void terminateAndWaitForAllWorkers(); |
- |
- bool isCurrentThread(); |
- WorkerLoaderProxy* workerLoaderProxy() const |
- { |
- RELEASE_ASSERT(m_workerLoaderProxy); |
- return m_workerLoaderProxy.get(); |
- } |
- |
- WorkerReportingProxy& workerReportingProxy() const { return m_workerReportingProxy; } |
- |
- void postTask(const WebTraceLocation&, PassOwnPtr<ExecutionContextTask>); |
- void appendDebuggerTask(PassOwnPtr<WebTaskRunner::Task>); |
- |
- enum WaitMode { WaitForTask, DontWaitForTask }; |
- enum TaskQueueResult { |
- Terminated, // Queue was destroyed while waiting for a task. |
- Timeout, // Timeout was specified and it expired. |
- TaskReceived, // A task was successfully received and returned. |
- }; |
- TaskQueueResult runDebuggerTask(WaitMode = WaitForTask); |
- |
- // These methods should be called if the holder of the thread is |
- // going to call runDebuggerTask in a loop. |
- void willRunDebuggerTasks(); |
- void didRunDebuggerTasks(); |
- |
- // Can be called only on the worker thread, WorkerGlobalScope is not thread safe. |
- WorkerGlobalScope* workerGlobalScope(); |
- |
- // Returns true once one of the terminate* methods is called. |
- bool terminated(); |
- |
- // Number of active worker threads. |
- static unsigned workerThreadCount(); |
- |
- PlatformThreadId platformThreadId(); |
- |
- void interruptAndDispatchInspectorCommands(); |
- void setWorkerInspectorController(WorkerInspectorController*); |
- |
-protected: |
- WorkerThread(PassRefPtr<WorkerLoaderProxy>, WorkerReportingProxy&); |
- |
- // Factory method for creating a new worker context for the thread. |
- virtual PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(PassOwnPtr<WorkerThreadStartupData>) = 0; |
- |
- virtual void postInitialize() { } |
- |
- // Both of these methods are called in the worker thread. |
- virtual void initializeBackingThread(); |
- virtual void shutdownBackingThread(); |
- |
- virtual v8::Isolate* initializeIsolate(); |
- virtual void willDestroyIsolate(); |
- virtual void destroyIsolate(); |
- virtual void terminateV8Execution(); |
- |
-private: |
- class DebuggerTaskQueue; |
- friend class WorkerMicrotaskRunner; |
- |
- WebTaskRunner::Task* createWorkerThreadTask(PassOwnPtr<ExecutionContextTask>, bool isInstrumented); |
- |
- // Called on the main thread. |
- void terminateInternal(); |
- |
- // Called on the worker thread. |
- void initialize(PassOwnPtr<WorkerThreadStartupData>); |
- void shutdown(); |
- void performTask(PassOwnPtr<ExecutionContextTask>, bool isInstrumented); |
- void performShutdownTask(); |
- void postDelayedTask(const WebTraceLocation&, PassOwnPtr<ExecutionContextTask>, long long delayMs); |
- |
- bool m_started; |
- bool m_terminated; |
- bool m_shutdown; |
- OwnPtr<DebuggerTaskQueue> m_debuggerTaskQueue; |
- OwnPtr<WebThread::TaskObserver> m_microtaskRunner; |
- |
- RefPtr<WorkerLoaderProxy> m_workerLoaderProxy; |
- WorkerReportingProxy& m_workerReportingProxy; |
- RawPtr<WebScheduler> m_webScheduler; // Not owned. |
- |
- RefPtrWillBePersistent<WorkerInspectorController> m_workerInspectorController; |
- Mutex m_workerInspectorControllerMutex; |
- |
- // This lock protects |m_workerGlobalScope|, |m_terminated|, |m_shutdown|, |m_isolate| and |m_microtaskRunner|. |
- Mutex m_threadStateMutex; |
- |
- RefPtrWillBePersistent<WorkerGlobalScope> m_workerGlobalScope; |
- |
- v8::Isolate* m_isolate; |
- |
- // Used to signal thread shutdown. |
- OwnPtr<WaitableEvent> m_shutdownEvent; |
- |
- // Used to signal thread termination. |
- OwnPtr<WaitableEvent> m_terminationEvent; |
-}; |
- |
-} // namespace blink |
- |
-#endif // WorkerThread_h |