Index: Source/core/workers/WorkerThread.h |
diff --git a/Source/core/workers/WorkerThread.h b/Source/core/workers/WorkerThread.h |
deleted file mode 100644 |
index 38352bd1ad6fdb55dd0929b8f73310c828f44454..0000000000000000000000000000000000000000 |
--- a/Source/core/workers/WorkerThread.h |
+++ /dev/null |
@@ -1,171 +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/MessageQueue.h" |
-#include "wtf/OwnPtr.h" |
-#include "wtf/PassRefPtr.h" |
-#include "wtf/RefCounted.h" |
-#include <v8.h> |
- |
-namespace blink { |
- |
-class WebWaitableEvent; |
-class WorkerGlobalScope; |
-class WorkerInspectorController; |
-class WorkerReportingProxy; |
-class WorkerSharedTimer; |
-class WorkerThreadShutdownFinishTask; |
-class WorkerThreadStartupData; |
-class WorkerThreadTask; |
- |
-enum WorkerThreadStartMode { |
- DontPauseWorkerGlobalScopeOnStart, |
- PauseWorkerGlobalScopeOnStart |
-}; |
- |
-// TODO(sadrul): Rename to WorkerScript. |
-class CORE_EXPORT WorkerThread : public RefCounted<WorkerThread> { |
-public: |
- virtual ~WorkerThread(); |
- |
- virtual void start(); |
- virtual void stop(); |
- |
- // 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 didStartRunLoop(); |
- virtual void didStopRunLoop(); |
- |
- v8::Isolate* isolate() const { return m_isolate; } |
- |
- // Can be used to wait for this worker thread to shut down. |
- // (This is signalled on the main thread, so it's assumed to be waited on the worker context thread) |
- WebWaitableEvent* shutdownEvent() { return m_shutdownEvent.get(); } |
- |
- WebWaitableEvent* terminationEvent() { return m_terminationEvent.get(); } |
- 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 postDebuggerTask(const WebTraceLocation&, PassOwnPtr<ExecutionContextTask>); |
- |
- enum WaitMode { WaitForMessage, DontWaitForMessage }; |
- MessageQueueWaitResult runDebuggerTask(WaitMode = WaitForMessage); |
- |
- // These methods should be called if the holder of the thread is |
- // going to call runDebuggerTask in a loop. |
- void willEnterNestedLoop(); |
- void didLeaveNestedLoop(); |
- |
- WorkerGlobalScope* workerGlobalScope() const { return m_workerGlobalScope.get(); } |
- bool terminated(); |
- |
- // Number of active worker threads. |
- static unsigned workerThreadCount(); |
- |
- PlatformThreadId platformThreadId(); |
- |
- void interruptAndDispatchInspectorCommands(); |
- void setWorkerInspectorController(WorkerInspectorController*); |
- |
-protected: |
- WorkerThread(PassRefPtr<WorkerLoaderProxy>, WorkerReportingProxy&, PassOwnPtr<WorkerThreadStartupData>); |
- |
- // Factory method for creating a new worker context for the thread. |
- virtual PassRefPtrWillBeRawPtr<WorkerGlobalScope> createWorkerGlobalScope(PassOwnPtr<WorkerThreadStartupData>) = 0; |
- |
- virtual void postInitialize() { } |
- |
- virtual v8::Isolate* initializeIsolate(); |
- virtual void willDestroyIsolate(); |
- virtual void destroyIsolate(); |
- virtual void terminateV8Execution(); |
- |
-private: |
- friend class WorkerSharedTimer; |
- friend class WorkerThreadShutdownFinishTask; |
- |
- void stopInShutdownSequence(); |
- void stopInternal(); |
- |
- void initialize(); |
- void cleanup(); |
- void idleHandler(); |
- void postDelayedTask(PassOwnPtr<ExecutionContextTask>, long long delayMs); |
- void postDelayedTask(const WebTraceLocation&, PassOwnPtr<ExecutionContextTask>, long long delayMs); |
- |
- bool m_started; |
- bool m_terminated; |
- MessageQueue<WorkerThreadTask> m_debuggerMessageQueue; |
- OwnPtr<WebThread::TaskObserver> m_microtaskRunner; |
- |
- RefPtr<WorkerLoaderProxy> m_workerLoaderProxy; |
- WorkerReportingProxy& m_workerReportingProxy; |
- |
- RefPtrWillBePersistent<WorkerInspectorController> m_workerInspectorController; |
- Mutex m_workerInspectorControllerMutex; |
- |
- Mutex m_threadCreationMutex; |
- RefPtrWillBePersistent<WorkerGlobalScope> m_workerGlobalScope; |
- OwnPtr<WorkerThreadStartupData> m_startupData; |
- |
- v8::Isolate* m_isolate; |
- OwnPtr<V8IsolateInterruptor> m_interruptor; |
- |
- // Used to signal thread shutdown. |
- OwnPtr<WebWaitableEvent> m_shutdownEvent; |
- |
- // Used to signal thread termination. |
- OwnPtr<WebWaitableEvent> m_terminationEvent; |
-}; |
- |
-} // namespace blink |
- |
-#endif // WorkerThread_h |