diff options
author | Steve Block <steveblock@google.com> | 2011-05-06 11:45:16 +0100 |
---|---|---|
committer | Steve Block <steveblock@google.com> | 2011-05-12 13:44:10 +0100 |
commit | cad810f21b803229eb11403f9209855525a25d57 (patch) | |
tree | 29a6fd0279be608e0fe9ffe9841f722f0f4e4269 /Source/WebCore/plugins/PluginMainThreadScheduler.cpp | |
parent | 121b0cf4517156d0ac5111caf9830c51b69bae8f (diff) | |
download | external_webkit-cad810f21b803229eb11403f9209855525a25d57.zip external_webkit-cad810f21b803229eb11403f9209855525a25d57.tar.gz external_webkit-cad810f21b803229eb11403f9209855525a25d57.tar.bz2 |
Merge WebKit at r75315: Initial merge by git.
Change-Id: I570314b346ce101c935ed22a626b48c2af266b84
Diffstat (limited to 'Source/WebCore/plugins/PluginMainThreadScheduler.cpp')
-rw-r--r-- | Source/WebCore/plugins/PluginMainThreadScheduler.cpp | 116 |
1 files changed, 116 insertions, 0 deletions
diff --git a/Source/WebCore/plugins/PluginMainThreadScheduler.cpp b/Source/WebCore/plugins/PluginMainThreadScheduler.cpp new file mode 100644 index 0000000..7528676 --- /dev/null +++ b/Source/WebCore/plugins/PluginMainThreadScheduler.cpp @@ -0,0 +1,116 @@ +/* + * 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 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 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" +#include "PluginMainThreadScheduler.h" +#include <wtf/StdLibExtras.h> + +namespace WebCore { + +PluginMainThreadScheduler& PluginMainThreadScheduler::scheduler() +{ + DEFINE_STATIC_LOCAL(PluginMainThreadScheduler, scheduler, ()); + + return scheduler; +} + +PluginMainThreadScheduler::PluginMainThreadScheduler() + : m_callPending(false) +{ +} + +void PluginMainThreadScheduler::scheduleCall(NPP npp, MainThreadFunction function, void* userData) +{ + MutexLocker lock(m_queueMutex); + + CallQueueMap::iterator it = m_callQueueMap.find(npp); + if (it == m_callQueueMap.end()) + return; + + it->second.append(Call(function, userData)); + + if (!m_callPending) { + callOnMainThread(mainThreadCallback, this); + m_callPending = true; + } +} + +void PluginMainThreadScheduler::registerPlugin(NPP npp) +{ + MutexLocker lock(m_queueMutex); + + ASSERT(!m_callQueueMap.contains(npp)); + m_callQueueMap.set(npp, Deque<Call>()); +} + +void PluginMainThreadScheduler::unregisterPlugin(NPP npp) +{ + MutexLocker lock(m_queueMutex); + + ASSERT(m_callQueueMap.contains(npp)); + m_callQueueMap.remove(npp); +} + +void PluginMainThreadScheduler::dispatchCallsForPlugin(NPP npp, const Deque<Call>& calls) +{ + Deque<Call>::const_iterator end = calls.end(); + for (Deque<Call>::const_iterator it = calls.begin(); it != end; ++it) { + // Check if the plug-in has been destroyed. + { + MutexLocker lock(m_queueMutex); + if (!m_callQueueMap.contains(npp)) + return; + } + + (*it).performCall(); + } +} + +void PluginMainThreadScheduler::dispatchCalls() +{ + m_queueMutex.lock(); + CallQueueMap copy(m_callQueueMap); + + { + // Empty all the queues in the original map + CallQueueMap::iterator end = m_callQueueMap.end(); + for (CallQueueMap::iterator it = m_callQueueMap.begin(); it != end; ++it) + it->second.clear(); + } + + m_callPending = false; + m_queueMutex.unlock(); + + CallQueueMap::iterator end = copy.end(); + for (CallQueueMap::iterator it = copy.begin(); it != end; ++it) + dispatchCallsForPlugin(it->first, it->second); +} + +void PluginMainThreadScheduler::mainThreadCallback(void* context) +{ + static_cast<PluginMainThreadScheduler*>(context)->dispatchCalls(); +} + +} // namespace WebCore |