OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ppapi/proxy/ppb_audio_proxy.h" | 5 #include "ppapi/proxy/ppb_audio_proxy.h" |
6 | 6 |
7 #include "base/compiler_specific.h" | 7 #include "base/compiler_specific.h" |
8 #include "base/threading/simple_thread.h" | 8 #include "base/threading/simple_thread.h" |
9 #include "media/audio/shared_memory_util.h" | 9 #include "media/audio/shared_memory_util.h" |
10 #include "ppapi/c/pp_errors.h" | 10 #include "ppapi/c/pp_errors.h" |
11 #include "ppapi/c/ppb_audio.h" | 11 #include "ppapi/c/ppb_audio.h" |
12 #include "ppapi/c/ppb_audio_config.h" | 12 #include "ppapi/c/ppb_audio_config.h" |
13 #include "ppapi/c/ppb_var.h" | 13 #include "ppapi/c/ppb_var.h" |
14 #include "ppapi/c/trusted/ppb_audio_trusted.h" | 14 #include "ppapi/c/trusted/ppb_audio_trusted.h" |
15 #include "ppapi/proxy/enter_proxy.h" | 15 #include "ppapi/proxy/enter_proxy.h" |
16 #include "ppapi/proxy/plugin_dispatcher.h" | 16 #include "ppapi/proxy/plugin_dispatcher.h" |
17 #include "ppapi/proxy/ppapi_messages.h" | 17 #include "ppapi/proxy/ppapi_messages.h" |
18 #include "ppapi/shared_impl/api_id.h" | 18 #include "ppapi/shared_impl/api_id.h" |
19 #include "ppapi/shared_impl/platform_file.h" | 19 #include "ppapi/shared_impl/platform_file.h" |
20 #include "ppapi/shared_impl/ppapi_globals.h" | 20 #include "ppapi/shared_impl/ppapi_globals.h" |
21 #include "ppapi/shared_impl/ppb_audio_shared.h" | 21 #include "ppapi/shared_impl/ppb_audio_shared.h" |
22 #include "ppapi/shared_impl/resource.h" | 22 #include "ppapi/shared_impl/resource.h" |
23 #include "ppapi/thunk/ppb_audio_config_api.h" | 23 #include "ppapi/thunk/ppb_audio_config_api.h" |
24 #include "ppapi/thunk/enter.h" | 24 #include "ppapi/thunk/enter.h" |
25 #include "ppapi/thunk/resource_creation_api.h" | 25 #include "ppapi/thunk/resource_creation_api.h" |
26 #include "ppapi/thunk/thunk.h" | 26 #include "ppapi/thunk/thunk.h" |
27 | 27 |
28 using ppapi::IntToPlatformFile; | 28 using ppapi::IntToPlatformFile; |
| 29 using ppapi::proxy::SerializedHandle; |
29 using ppapi::thunk::EnterResourceNoLock; | 30 using ppapi::thunk::EnterResourceNoLock; |
30 using ppapi::thunk::PPB_Audio_API; | 31 using ppapi::thunk::PPB_Audio_API; |
31 using ppapi::thunk::PPB_AudioConfig_API; | 32 using ppapi::thunk::PPB_AudioConfig_API; |
32 | 33 |
33 namespace ppapi { | 34 namespace ppapi { |
34 namespace proxy { | 35 namespace proxy { |
35 | 36 |
36 class Audio : public Resource, public PPB_Audio_Shared { | 37 class Audio : public Resource, public PPB_Audio_Shared { |
37 public: | 38 public: |
38 Audio(const HostResource& audio_id, | 39 Audio(const HostResource& audio_id, |
(...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
246 result_code = GetAudioConnectedHandles(resource, &socket_handle, | 247 result_code = GetAudioConnectedHandles(resource, &socket_handle, |
247 &shared_memory, | 248 &shared_memory, |
248 &audio_buffer_length); | 249 &audio_buffer_length); |
249 } | 250 } |
250 | 251 |
251 // Send all the values, even on error. This simplifies some of our cleanup | 252 // Send all the values, even on error. This simplifies some of our cleanup |
252 // code since the handles will be in the other process and could be | 253 // code since the handles will be in the other process and could be |
253 // inconvenient to clean up. Our IPC code will automatically handle this for | 254 // inconvenient to clean up. Our IPC code will automatically handle this for |
254 // us, as long as the remote side always closes the handles it receives | 255 // us, as long as the remote side always closes the handles it receives |
255 // (in OnMsgNotifyAudioStreamCreated), even in the failure case. | 256 // (in OnMsgNotifyAudioStreamCreated), even in the failure case. |
256 ppapi::proxy::SerializedHandle fd_wrapper(socket_handle); | 257 SerializedHandle fd_wrapper(SerializedHandle::SOCKET, socket_handle); |
257 | 258 |
258 // Note that we must call TotalSharedMemorySizeInBytes because | 259 // Note that we must call TotalSharedMemorySizeInBytes because |
259 // Audio allocates extra space in shared memory for book-keeping, so the | 260 // Audio allocates extra space in shared memory for book-keeping, so the |
260 // actual size of the shared memory buffer is larger than audio_buffer_length. | 261 // actual size of the shared memory buffer is larger than audio_buffer_length. |
261 // When sending to NaCl, NaClIPCAdapter expects this size to match the size | 262 // When sending to NaCl, NaClIPCAdapter expects this size to match the size |
262 // of the full shared memory buffer. | 263 // of the full shared memory buffer. |
263 ppapi::proxy::SerializedHandle handle_wrapper( | 264 SerializedHandle handle_wrapper( |
264 shared_memory, | 265 shared_memory, |
265 media::TotalSharedMemorySizeInBytes(audio_buffer_length)); | 266 media::TotalSharedMemorySizeInBytes(audio_buffer_length)); |
266 dispatcher()->Send(new PpapiMsg_PPBAudio_NotifyAudioStreamCreated( | 267 dispatcher()->Send(new PpapiMsg_PPBAudio_NotifyAudioStreamCreated( |
267 API_ID_PPB_AUDIO, resource, result_code, fd_wrapper, handle_wrapper)); | 268 API_ID_PPB_AUDIO, resource, result_code, fd_wrapper, handle_wrapper)); |
268 } | 269 } |
269 | 270 |
270 int32_t PPB_Audio_Proxy::GetAudioConnectedHandles( | 271 int32_t PPB_Audio_Proxy::GetAudioConnectedHandles( |
271 const HostResource& resource, | 272 const HostResource& resource, |
272 IPC::PlatformFileForTransit* foreign_socket_handle, | 273 IPC::PlatformFileForTransit* foreign_socket_handle, |
273 base::SharedMemoryHandle* foreign_shared_memory_handle, | 274 base::SharedMemoryHandle* foreign_shared_memory_handle, |
(...skipping 28 matching lines...) Expand all Loading... |
302 if (*foreign_shared_memory_handle == IPC::InvalidPlatformFileForTransit()) | 303 if (*foreign_shared_memory_handle == IPC::InvalidPlatformFileForTransit()) |
303 return PP_ERROR_FAILED; | 304 return PP_ERROR_FAILED; |
304 | 305 |
305 return PP_OK; | 306 return PP_OK; |
306 } | 307 } |
307 | 308 |
308 // Processed in the plugin (message from host). | 309 // Processed in the plugin (message from host). |
309 void PPB_Audio_Proxy::OnMsgNotifyAudioStreamCreated( | 310 void PPB_Audio_Proxy::OnMsgNotifyAudioStreamCreated( |
310 const HostResource& audio_id, | 311 const HostResource& audio_id, |
311 int32_t result_code, | 312 int32_t result_code, |
312 ppapi::proxy::SerializedHandle socket_handle, | 313 SerializedHandle socket_handle, |
313 ppapi::proxy::SerializedHandle handle) { | 314 SerializedHandle handle) { |
314 CHECK(socket_handle.is_socket()); | 315 CHECK(socket_handle.is_socket()); |
315 CHECK(handle.is_shmem()); | 316 CHECK(handle.is_shmem()); |
316 EnterPluginFromHostResource<PPB_Audio_API> enter(audio_id); | 317 EnterPluginFromHostResource<PPB_Audio_API> enter(audio_id); |
317 if (enter.failed() || result_code != PP_OK) { | 318 if (enter.failed() || result_code != PP_OK) { |
318 // The caller may still have given us these handles in the failure case. | 319 // The caller may still have given us these handles in the failure case. |
319 // The easiest way to clean these up is to just put them in the objects | 320 // The easiest way to clean these up is to just put them in the objects |
320 // and then close them. This failure case is not performance critical. | 321 // and then close them. This failure case is not performance critical. |
321 base::SyncSocket temp_socket( | 322 base::SyncSocket temp_socket( |
322 IPC::PlatformFileForTransitToPlatformFile(socket_handle.descriptor())); | 323 IPC::PlatformFileForTransitToPlatformFile(socket_handle.descriptor())); |
323 base::SharedMemory temp_mem(handle.shmem(), false); | 324 base::SharedMemory temp_mem(handle.shmem(), false); |
324 } else { | 325 } else { |
325 // See the comment above about how we must call | 326 // See the comment above about how we must call |
326 // TotalSharedMemorySizeInBytes to get the actual size of the buffer. Here, | 327 // TotalSharedMemorySizeInBytes to get the actual size of the buffer. Here, |
327 // we must call PacketSizeInBytes to get back the size of the audio buffer, | 328 // we must call PacketSizeInBytes to get back the size of the audio buffer, |
328 // excluding the bytes that audio uses for book-keeping. | 329 // excluding the bytes that audio uses for book-keeping. |
329 static_cast<Audio*>(enter.object())->SetStreamInfo( | 330 static_cast<Audio*>(enter.object())->SetStreamInfo( |
330 enter.resource()->pp_instance(), handle.shmem(), | 331 enter.resource()->pp_instance(), handle.shmem(), |
331 media::PacketSizeInBytes(handle.size()), | 332 media::PacketSizeInBytes(handle.size()), |
332 IPC::PlatformFileForTransitToPlatformFile(socket_handle.descriptor())); | 333 IPC::PlatformFileForTransitToPlatformFile(socket_handle.descriptor())); |
333 } | 334 } |
334 } | 335 } |
335 | 336 |
336 } // namespace proxy | 337 } // namespace proxy |
337 } // namespace ppapi | 338 } // namespace ppapi |
OLD | NEW |