| /* |
| * Copyright 2007, The Android Open Source Project |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * * Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * * 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 THE COPYRIGHT HOLDERS ``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 THE COPYRIGHT OWNER 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 "FileSystemClient.h" |
| #include "JavaSharedClient.h" |
| #include "TimerClient.h" |
| #include "SkDeque.h" |
| #include "SkThread.h" |
| |
| namespace android { |
| TimerClient* JavaSharedClient::GetTimerClient() |
| { |
| return gTimerClient; |
| } |
| |
| CookieClient* JavaSharedClient::GetCookieClient() |
| { |
| return gCookieClient; |
| } |
| |
| PluginClient* JavaSharedClient::GetPluginClient() |
| { |
| return gPluginClient; |
| } |
| |
| KeyGeneratorClient* JavaSharedClient::GetKeyGeneratorClient() |
| { |
| return gKeyGeneratorClient; |
| } |
| |
| FileSystemClient* JavaSharedClient::GetFileSystemClient() |
| { |
| return gFileSystemClient; |
| } |
| |
| void JavaSharedClient::SetTimerClient(TimerClient* client) |
| { |
| gTimerClient = client; |
| } |
| |
| void JavaSharedClient::SetCookieClient(CookieClient* client) |
| { |
| gCookieClient = client; |
| } |
| |
| void JavaSharedClient::SetPluginClient(PluginClient* client) |
| { |
| gPluginClient = client; |
| } |
| |
| void JavaSharedClient::SetKeyGeneratorClient(KeyGeneratorClient* client) |
| { |
| gKeyGeneratorClient = client; |
| } |
| |
| void JavaSharedClient::SetFileSystemClient(FileSystemClient* client) |
| { |
| gFileSystemClient = client; |
| } |
| |
| TimerClient* JavaSharedClient::gTimerClient = NULL; |
| CookieClient* JavaSharedClient::gCookieClient = NULL; |
| PluginClient* JavaSharedClient::gPluginClient = NULL; |
| KeyGeneratorClient* JavaSharedClient::gKeyGeneratorClient = NULL; |
| FileSystemClient* JavaSharedClient::gFileSystemClient = NULL; |
| |
| /////////////////////////////////////////////////////////////////////////// |
| |
| struct FuncPtrRec { |
| void (*fProc)(void* payload); |
| void* fPayload; |
| }; |
| |
| static SkMutex gFuncPtrQMutex; |
| static SkDeque gFuncPtrQ(sizeof(FuncPtrRec)); |
| |
| void JavaSharedClient::EnqueueFunctionPtr(void (*proc)(void* payload), |
| void* payload) |
| { |
| gFuncPtrQMutex.acquire(); |
| |
| FuncPtrRec* rec = (FuncPtrRec*)gFuncPtrQ.push_back(); |
| rec->fProc = proc; |
| rec->fPayload = payload; |
| |
| gFuncPtrQMutex.release(); |
| |
| gTimerClient->signalServiceFuncPtrQueue(); |
| } |
| |
| void JavaSharedClient::ServiceFunctionPtrQueue() |
| { |
| // Don't let execution block the WebViewCore thread for too long. |
| void (*proc)(void*) = 0; |
| void* payload = 0; |
| const FuncPtrRec* rec; |
| |
| // we have to copy the proc/payload (if present). we do this so we |
| // don't call the proc inside the mutex (possible deadlock!) |
| gFuncPtrQMutex.acquire(); |
| rec = (const FuncPtrRec*)gFuncPtrQ.front(); |
| if (rec) { |
| proc = rec->fProc; |
| payload = rec->fPayload; |
| gFuncPtrQ.pop_front(); |
| } |
| bool scheduleAdditionalCall = (gFuncPtrQ.count() > 0); |
| gFuncPtrQMutex.release(); |
| |
| if (rec) |
| proc(payload); |
| if (scheduleAdditionalCall) |
| gTimerClient->signalServiceFuncPtrQueue(); |
| } |
| } |