Chromium Code Reviews| Index: ppapi/shared_impl/ppb_audio_shared.cc |
| diff --git a/ppapi/shared_impl/ppb_audio_shared.cc b/ppapi/shared_impl/ppb_audio_shared.cc |
| index ced11466970c6e2ba26eb9d87fb3f1c94d49993b..b448011974cf9bbc9930ee48aa2f4b98b07f9223 100644 |
| --- a/ppapi/shared_impl/ppb_audio_shared.cc |
| +++ b/ppapi/shared_impl/ppb_audio_shared.cc |
| @@ -5,18 +5,18 @@ |
| #include "ppapi/shared_impl/ppb_audio_shared.h" |
| #include "base/logging.h" |
| +#include "ppapi/nacl_irt/irt_ppapi.h" |
| #include "ppapi/shared_impl/ppapi_globals.h" |
| #include "ppapi/shared_impl/ppb_audio_config_shared.h" |
| #include "ppapi/shared_impl/proxy_lock.h" |
| namespace ppapi { |
| -#if defined(OS_NACL) |
| namespace { |
| +bool thread_functions_set = false; |
| // Because this is static, the function pointers will be NULL initially. |
| PP_ThreadFunctions thread_functions; |
| } |
| -#endif // defined(OS_NACL) |
| AudioCallbackCombined::AudioCallbackCombined() |
| : callback_1_0_(NULL), callback_(NULL) {} |
| @@ -50,10 +50,8 @@ void AudioCallbackCombined::Run(void* sample_buffer, |
| PPB_Audio_Shared::PPB_Audio_Shared() |
| : playing_(false), |
| shared_memory_size_(0), |
| -#if defined(OS_NACL) |
| thread_id_(0), |
| thread_active_(false), |
| -#endif |
| user_data_(NULL), |
| client_buffer_size_bytes_(0), |
| bytes_per_second_(0), |
| @@ -77,9 +75,8 @@ void PPB_Audio_Shared::SetStartPlaybackState() { |
| DCHECK(!playing_); |
| #if !defined(OS_NACL) |
| DCHECK(!audio_thread_.get()); |
| -#else |
| - DCHECK(!thread_active_); |
| #endif |
| + DCHECK(!thread_active_); |
| // If the socket doesn't exist, that means that the plugin has started before |
| // the browser has had a chance to create all the shared memory info and |
| // notify us. This is a common case. In this case, we just set the playing_ |
| @@ -138,21 +135,25 @@ void PPB_Audio_Shared::StartThread() { |
| // start up quickly enough. |
| memset(shared_memory_->memory(), 0, shared_memory_size_); |
| memset(client_buffer_.get(), 0, client_buffer_size_bytes_); |
| + |
| + if (thread_functions_set) { |
|
Mark Seaborn
2014/03/20 23:23:30
PPB_Audio is meant to fail under NaCl (for both SF
hidehiko
2014/04/21 14:47:40
Done.
|
| + // Use NaCl's special API for IRT code that creates threads that call back |
| + // into user code. |
| + if (NULL == thread_functions.thread_create || |
| + NULL == thread_functions.thread_join) |
| + return; |
| + |
| + int result = thread_functions.thread_create(&thread_id_, CallRun, this); |
| + DCHECK_EQ(result, 0); |
| + thread_active_ = true; |
| + return; |
| + } |
| + |
| #if !defined(OS_NACL) |
| DCHECK(!audio_thread_.get()); |
| audio_thread_.reset( |
| new base::DelegateSimpleThread(this, "plugin_audio_thread")); |
| audio_thread_->Start(); |
| -#else |
| - // Use NaCl's special API for IRT code that creates threads that call back |
| - // into user code. |
| - if (NULL == thread_functions.thread_create || |
| - NULL == thread_functions.thread_join) |
| - return; |
| - |
| - int result = thread_functions.thread_create(&thread_id_, CallRun, this); |
| - DCHECK_EQ(result, 0); |
| - thread_active_ = true; |
| #endif |
| } |
| @@ -169,22 +170,22 @@ void PPB_Audio_Shared::StopThread() { |
| base::Unretained(audio_thread_.get()))); |
| audio_thread_.reset(); |
| } |
| -#else |
| +#endif |
| if (thread_active_) { |
| // See comment above about why we unlock here. |
| int result = CallWhileUnlocked(thread_functions.thread_join, thread_id_); |
| DCHECK_EQ(0, result); |
| thread_active_ = false; |
| } |
| -#endif |
| } |
| -#if defined(OS_NACL) |
| // static |
| void PPB_Audio_Shared::SetThreadFunctions( |
| const struct PP_ThreadFunctions* functions) { |
| + DCHECK(!thread_functions_set); |
| DCHECK(thread_functions.thread_create == NULL); |
| DCHECK(thread_functions.thread_join == NULL); |
| + thread_functions_set = true; |
| thread_functions = *functions; |
| } |
| @@ -193,7 +194,6 @@ void PPB_Audio_Shared::CallRun(void* self) { |
| PPB_Audio_Shared* audio = static_cast<PPB_Audio_Shared*>(self); |
| audio->Run(); |
| } |
| -#endif |
| void PPB_Audio_Shared::Run() { |
| int pending_data = 0; |