1 /*
2  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
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.
12  *
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.
24  */
25 
26 #ifndef PluginMainThreadScheduler_h
27 #define PluginMainThreadScheduler_h
28 
29 #include <wtf/Deque.h>
30 #include <wtf/HashMap.h>
31 #include <wtf/MainThread.h>
32 #include <wtf/Threading.h>
33 
34 typedef struct _NPP NPP_t;
35 typedef NPP_t* NPP;
36 
37 namespace WebCore {
38 
39 class PluginMainThreadScheduler {
40     WTF_MAKE_NONCOPYABLE(PluginMainThreadScheduler); WTF_MAKE_FAST_ALLOCATED;
41 public:
42     typedef void MainThreadFunction(void*);
43 
44     static PluginMainThreadScheduler& scheduler();
45 
46     void scheduleCall(NPP, MainThreadFunction*, void* userData);
47 
48     void registerPlugin(NPP);
49     void unregisterPlugin(NPP);
50 
51 private:
52     PluginMainThreadScheduler();
53     void dispatchCalls();
54 
55     class Call;
56 
57     void dispatchCallsForPlugin(NPP, const Deque<Call>& calls);
58     typedef HashMap<NPP, Deque<Call> > CallQueueMap;
59 
60     static void mainThreadCallback(void* context);
61 
62     class Call {
63     public:
Call(MainThreadFunction * function,void * userData)64         Call(MainThreadFunction* function, void* userData)
65             : m_function(function)
66             , m_userData(userData)
67         {
68         }
69 
performCall()70         void performCall() const
71         {
72             m_function(m_userData);
73         }
74 
75     private:
76         MainThreadFunction* m_function;
77         void* m_userData;
78     };
79 
80     bool m_callPending;
81     CallQueueMap m_callQueueMap;
82     Mutex m_queueMutex;
83 };
84 
85 } // namespace WebCore
86 
87 #endif // PluginMainThreadScheduler_h
88