2 * Copyright (C) 2008 Apple Inc. All Rights Reserved.
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions
7 * 1. Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer.
9 * 2. Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution.
13 * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY
14 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
15 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR
17 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
18 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
19 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
20 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
21 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 #include "PluginMainThreadScheduler.h"
28 #include <wtf/StdLibExtras.h>
32 PluginMainThreadScheduler& PluginMainThreadScheduler::scheduler()
34 DEFINE_STATIC_LOCAL(PluginMainThreadScheduler, scheduler, ());
39 PluginMainThreadScheduler::PluginMainThreadScheduler()
40 : m_callPending(false)
44 void PluginMainThreadScheduler::scheduleCall(NPP npp, MainThreadFunction function, void* userData)
46 MutexLocker lock(m_queueMutex);
48 CallQueueMap::iterator it = m_callQueueMap.find(npp);
49 if (it == m_callQueueMap.end())
52 it->second.append(Call(function, userData));
55 callOnMainThread(mainThreadCallback, this);
60 void PluginMainThreadScheduler::registerPlugin(NPP npp)
62 MutexLocker lock(m_queueMutex);
64 ASSERT(!m_callQueueMap.contains(npp));
65 m_callQueueMap.set(npp, Deque<Call>());
68 void PluginMainThreadScheduler::unregisterPlugin(NPP npp)
70 MutexLocker lock(m_queueMutex);
72 ASSERT(m_callQueueMap.contains(npp));
73 m_callQueueMap.remove(npp);
76 void PluginMainThreadScheduler::dispatchCallsForPlugin(NPP npp, const Deque<Call>& calls)
78 Deque<Call>::const_iterator end = calls.end();
79 for (Deque<Call>::const_iterator it = calls.begin(); it != end; ++it) {
80 // Check if the plug-in has been destroyed.
82 MutexLocker lock(m_queueMutex);
83 if (!m_callQueueMap.contains(npp))
91 void PluginMainThreadScheduler::dispatchCalls()
94 CallQueueMap copy(m_callQueueMap);
97 // Empty all the queues in the original map
98 CallQueueMap::iterator end = m_callQueueMap.end();
99 for (CallQueueMap::iterator it = m_callQueueMap.begin(); it != end; ++it)
103 m_callPending = false;
104 m_queueMutex.unlock();
106 CallQueueMap::iterator end = copy.end();
107 for (CallQueueMap::iterator it = copy.begin(); it != end; ++it)
108 dispatchCallsForPlugin(it->first, it->second);
111 void PluginMainThreadScheduler::mainThreadCallback(void* context)
113 static_cast<PluginMainThreadScheduler*>(context)->dispatchCalls();
116 } // namespace WebCore