summaryrefslogtreecommitdiffstats
path: root/WebCore/dom/WorkerThread.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'WebCore/dom/WorkerThread.cpp')
-rw-r--r--WebCore/dom/WorkerThread.cpp154
1 files changed, 0 insertions, 154 deletions
diff --git a/WebCore/dom/WorkerThread.cpp b/WebCore/dom/WorkerThread.cpp
deleted file mode 100644
index a762e0b..0000000
--- a/WebCore/dom/WorkerThread.cpp
+++ /dev/null
@@ -1,154 +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.
- *
- */
-
-#include "config.h"
-
-#if ENABLE(WORKERS)
-
-#include "WorkerThread.h"
-
-#include "KURL.h"
-#include "PlatformString.h"
-#include "ScriptSourceCode.h"
-#include "ScriptValue.h"
-#include "Worker.h"
-#include "WorkerContext.h"
-#include "WorkerMessagingProxy.h"
-#include "WorkerTask.h"
-
-#include <utility>
-#include <wtf/Noncopyable.h>
-
-namespace WebCore {
-struct WorkerThreadStartupData : Noncopyable {
-public:
- static std::auto_ptr<WorkerThreadStartupData> create(const KURL& scriptURL, const String& userAgent, const String& sourceCode)
- {
- return std::auto_ptr<WorkerThreadStartupData>(new WorkerThreadStartupData(scriptURL, userAgent, sourceCode));
- }
-
- KURL m_scriptURL;
- String m_userAgent;
- String m_sourceCode;
-private:
- WorkerThreadStartupData(const KURL& scriptURL, const String& userAgent, const String& sourceCode);
-};
-
-WorkerThreadStartupData::WorkerThreadStartupData(const KURL& scriptURL, const String& userAgent, const String& sourceCode)
- : m_scriptURL(scriptURL.copy())
- , m_userAgent(userAgent.copy())
- , m_sourceCode(sourceCode.copy())
-{
-}
-
-PassRefPtr<WorkerThread> WorkerThread::create(const KURL& scriptURL, const String& userAgent, const String& sourceCode, WorkerMessagingProxy* messagingProxy)
-{
- return adoptRef(new WorkerThread(scriptURL, userAgent, sourceCode, messagingProxy));
-}
-
-WorkerThread::WorkerThread(const KURL& scriptURL, const String& userAgent, const String& sourceCode, WorkerMessagingProxy* messagingProxy)
- : m_threadID(0)
- , m_messagingProxy(messagingProxy)
- , m_startupData(WorkerThreadStartupData::create(scriptURL, userAgent, sourceCode))
-{
-}
-
-WorkerThread::~WorkerThread()
-{
-}
-
-bool WorkerThread::start()
-{
- // Mutex protection is necessary to ensure that m_threadID is initialized when the thread starts.
- MutexLocker lock(m_threadCreationMutex);
-
- if (m_threadID)
- return true;
-
- m_threadID = createThread(WorkerThread::workerThreadStart, this, "WebCore::Worker");
-
- return m_threadID;
-}
-
-void* WorkerThread::workerThreadStart(void* thread)
-{
- return static_cast<WorkerThread*>(thread)->workerThread();
-}
-
-void* WorkerThread::workerThread()
-{
- {
- MutexLocker lock(m_threadCreationMutex);
- m_workerContext = WorkerContext::create(m_startupData->m_scriptURL, m_startupData->m_userAgent, this);
- if (m_runLoop.terminated()) {
- // The worker was terminated before the thread had a chance to run. Since the context didn't exist yet,
- // forbidExecution() couldn't be called from stop().
- m_workerContext->script()->forbidExecution();
- }
- }
-
- WorkerScriptController* script = m_workerContext->script();
- script->evaluate(ScriptSourceCode(m_startupData->m_sourceCode, m_startupData->m_scriptURL));
- // Free the startup data to cause its member variable deref's happen on the worker's thread (since
- // all ref/derefs of these objects are happening on the thread at this point). Note that
- // WorkerThread::~WorkerThread happens on a different thread where it was created.
- m_startupData.clear();
-
- m_messagingProxy->confirmWorkerThreadMessage(m_workerContext->hasPendingActivity()); // This wasn't really a message, but it counts as one for GC.
-
- // Blocks until terminated.
- m_runLoop.run(m_workerContext.get());
-
- ThreadIdentifier threadID = m_threadID;
-
- m_workerContext->clearScript();
- ASSERT(m_workerContext->hasOneRef());
- // The below assignment will destroy the context, which will in turn notify messaging proxy.
- // We cannot let any objects survive past thread exit, because no other thread will run GC or otherwise destroy them.
- m_workerContext = 0;
-
- // The thread object may be already destroyed from notification now, don't try to access "this".
- detachThread(threadID);
-
- return 0;
-}
-
-void WorkerThread::stop()
-{
- // Mutex protection is necessary because stop() can be called before the context is fully created.
- MutexLocker lock(m_threadCreationMutex);
-
- // Ensure that tasks are being handled by thread event loop. If script execution weren't forbidden, a while(1) loop in JS could keep the thread alive forever.
- if (m_workerContext)
- m_workerContext->script()->forbidExecution();
-
- // FIXME: Rudely killing the thread won't work when we allow nested workers, because they will try to post notifications of their destruction.
- m_runLoop.terminate();
-}
-
-} // namespace WebCore
-
-#endif // ENABLE(WORKERS)