• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2007, The Android Open Source Project
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  *  * Redistributions of source code must retain the above copyright
8  *    notice, this list of conditions and the following disclaimer.
9  *  * 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 THE COPYRIGHT HOLDERS ``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 THE COPYRIGHT OWNER 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 #include "config.h"
27 #include "JavaSharedClient.h"
28 #include "TimerClient.h"
29 #include "SkDeque.h"
30 #include "SkThread.h"
31 
32 namespace android {
GetTimerClient()33     TimerClient* JavaSharedClient::GetTimerClient()
34     {
35         return gTimerClient;
36     }
37 
GetCookieClient()38     CookieClient* JavaSharedClient::GetCookieClient()
39     {
40         return gCookieClient;
41     }
42 
GetPluginClient()43     PluginClient* JavaSharedClient::GetPluginClient()
44     {
45         return gPluginClient;
46     }
47 
GetKeyGeneratorClient()48     KeyGeneratorClient* JavaSharedClient::GetKeyGeneratorClient()
49     {
50         return gKeyGeneratorClient;
51     }
52 
SetTimerClient(TimerClient * client)53     void JavaSharedClient::SetTimerClient(TimerClient* client)
54     {
55         gTimerClient = client;
56     }
57 
SetCookieClient(CookieClient * client)58     void JavaSharedClient::SetCookieClient(CookieClient* client)
59     {
60         gCookieClient = client;
61     }
62 
SetPluginClient(PluginClient * client)63     void JavaSharedClient::SetPluginClient(PluginClient* client)
64     {
65         gPluginClient = client;
66     }
67 
SetKeyGeneratorClient(KeyGeneratorClient * client)68     void JavaSharedClient::SetKeyGeneratorClient(KeyGeneratorClient* client)
69     {
70         gKeyGeneratorClient = client;
71     }
72 
73     TimerClient*    JavaSharedClient::gTimerClient = NULL;
74     CookieClient*   JavaSharedClient::gCookieClient = NULL;
75     PluginClient*   JavaSharedClient::gPluginClient = NULL;
76     KeyGeneratorClient* JavaSharedClient::gKeyGeneratorClient = NULL;
77 
78     ///////////////////////////////////////////////////////////////////////////
79 
80     struct FuncPtrRec {
81         void (*fProc)(void* payload);
82         void* fPayload;
83     };
84 
85     static SkMutex gFuncPtrQMutex;
86     static SkDeque gFuncPtrQ(sizeof(FuncPtrRec));
87 
EnqueueFunctionPtr(void (* proc)(void * payload),void * payload)88     void JavaSharedClient::EnqueueFunctionPtr(void (*proc)(void* payload),
89                                               void* payload)
90     {
91         gFuncPtrQMutex.acquire();
92 
93         FuncPtrRec* rec = (FuncPtrRec*)gFuncPtrQ.push_back();
94         rec->fProc = proc;
95         rec->fPayload = payload;
96 
97         gFuncPtrQMutex.release();
98 
99         gTimerClient->signalServiceFuncPtrQueue();
100     }
101 
ServiceFunctionPtrQueue()102     void JavaSharedClient::ServiceFunctionPtrQueue()
103     {
104         for (;;) {
105             void (*proc)(void*) = 0;
106             void* payload = 0;
107             const FuncPtrRec* rec;
108 
109             // we have to copy the proc/payload (if present). we do this so we
110             // don't call the proc inside the mutex (possible deadlock!)
111             gFuncPtrQMutex.acquire();
112             rec = (const FuncPtrRec*)gFuncPtrQ.front();
113             if (rec) {
114                 proc = rec->fProc;
115                 payload = rec->fPayload;
116                 gFuncPtrQ.pop_front();
117             }
118             gFuncPtrQMutex.release();
119 
120             if (!rec)
121                 break;
122             proc(payload);
123         }
124     }
125 }
126