Use multiple shared memory buffers cyclically for audio capture.

content/renderer/pepper/pepper_platform_audio_input_impl.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/pepper/pepper_platform_audio_input_impl.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/message_loop_proxy.h"
 #include "build/build_config.h"
@@ skipping 46 matching lines @@
 
   // Called on the main thread to stop all audio callbacks. We must only change
   // the client on the main thread, and the delegates from the I/O thread.
   client_ = NULL;
   ChildProcess::current()->io_message_loop()->PostTask(
       FROM_HERE,
       base::Bind(&PepperPlatformAudioInputImpl::ShutDownOnIOThread, this));
 }
 
 void PepperPlatformAudioInputImpl::OnStreamCreated(
-    base::SharedMemoryHandle handle,
     base::SyncSocket::Handle socket_handle,
-    int length) {
-#if defined(OS_WIN)
-  DCHECK(handle);
-  DCHECK(socket_handle);
-#else
-  DCHECK_NE(-1, handle.fd);
-  DCHECK_NE(-1, socket_handle);
-#endif
-  DCHECK(length);
+    int total_handles) {
+  DCHECK_NE(socket_handle, base::SyncSocket::kInvalidHandle);
+  DCHECK_EQ(total_handles, 1);
 
   if (base::MessageLoopProxy::current() != main_message_loop_proxy_) {
     // No need to check |shutdown_called_| here. If shutdown has occurred,
     // |client_| will be NULL and the handles will be cleaned up on the main
     // thread.
     main_message_loop_proxy_->PostTask(
         FROM_HERE,
         base::Bind(&PepperPlatformAudioInputImpl::OnStreamCreated, this,
-                   handle, socket_handle, length));
+                   socket_handle, total_handles));
   } else {
     // Must dereference the client only on the main thread. Shutdown may have
     // occurred while the request was in-flight, so we need to NULL check.
     if (client_) {
-      client_->StreamCreated(handle, length, socket_handle);
+      socket_handle_ = socket_handle;
     } else {
       // Clean up the handles.
       base::SyncSocket temp_socket(socket_handle);
+    }
+  }
+}
+
+void PepperPlatformAudioInputImpl::OnSharedMemoryCreated(
+    base::SharedMemoryHandle handle,
+    int length,
+    int index) {
+  DCHECK(base::SharedMemory::IsHandleValid(handle));
+  DCHECK(length);
+  DCHECK_NE(socket_handle_, base::SyncSocket::kInvalidHandle);
+
+  if (base::MessageLoopProxy::current() != main_message_loop_proxy_) {
+    // No need to check |shutdown_called_| here. If shutdown has occurred,
+    // |client_| will be NULL and the handles will be cleaned up on the main
+    // thread.
+    main_message_loop_proxy_->PostTask(
+        FROM_HERE,
+        base::Bind(&PepperPlatformAudioInputImpl::OnSharedMemoryCreated, this,
+                   handle, length, index));
+  } else {
+    // Must dereference the client only on the main thread. Shutdown may have
+    // occurred while the request was in-flight, so we need to NULL check.
+    if (client_) {
+      client_->StreamCreated(handle, length, socket_handle_);
+    } else {
+      // Clean up the handles.
       base::SharedMemory temp_shared_memory(handle, false);
     }
   }
 }
 
 void PepperPlatformAudioInputImpl::OnVolume(double volume) {}
 
 void PepperPlatformAudioInputImpl::OnStateChanged(
     media::AudioInputIPCDelegate::State state) {
 }
 
 void PepperPlatformAudioInputImpl::OnDeviceReady(const std::string& device_id) {
   DCHECK(ChildProcess::current()->io_message_loop_proxy()->
       BelongsToCurrentThread());
 
   if (shutdown_called_)
     return;
 
   if (device_id.empty()) {
     main_message_loop_proxy_->PostTask(
         FROM_HERE,
         base::Bind(&PepperPlatformAudioInputImpl::NotifyStreamCreationFailed,
                    this));
   } else {
     // We will be notified by OnStreamCreated().
-    ipc_->CreateStream(stream_id_, params_, device_id, false);
+    ipc_->CreateStream(stream_id_, params_, device_id, false, 1);
   }
 }
 
 void PepperPlatformAudioInputImpl::OnIPCClosed() {
   ipc_ = NULL;
 }
 
 PepperPlatformAudioInputImpl::~PepperPlatformAudioInputImpl() {
   // Make sure we have been shut down. Warning: this may happen on the I/O
   // thread!
   // Although these members should be accessed on a specific thread (either the
   // main thread or the I/O thread), it should be fine to examine their value
   // here.
   DCHECK_EQ(0, stream_id_);
   DCHECK(!client_);
   DCHECK(label_.empty());
   DCHECK(shutdown_called_);
 }
 
 PepperPlatformAudioInputImpl::PepperPlatformAudioInputImpl()
     : client_(NULL),
+      socket_handle_(base::SyncSocket::kInvalidHandle),
       stream_id_(0),
       render_view_id_(MSG_ROUTING_NONE),
       main_message_loop_proxy_(base::MessageLoopProxy::current()),
       shutdown_called_(false) {
   ipc_ = RenderThreadImpl::current()->audio_input_message_filter();
 }
 
 bool PepperPlatformAudioInputImpl::Initialize(
     const base::WeakPtr<PepperPluginDelegateImpl>& plugin_delegate,
     const std::string& device_id,
@@ skipping 37 matching lines @@
     return;
 
   // Make sure we don't call init more than once.
   DCHECK_EQ(0, stream_id_);
   stream_id_ = ipc_->AddDelegate(this);
   DCHECK_NE(0, stream_id_);
 
   if (!session_id) {
     // We will be notified by OnStreamCreated().
     ipc_->CreateStream(stream_id_, params_,
-        media::AudioManagerBase::kDefaultDeviceId, false);
+        media::AudioManagerBase::kDefaultDeviceId, false, 1);
   } else {
     // We will be notified by OnDeviceReady().
     ipc_->StartDevice(stream_id_, session_id);
   }
 }
 
 void PepperPlatformAudioInputImpl::StartCaptureOnIOThread() {
   DCHECK(ChildProcess::current()->io_message_loop_proxy()->
       BelongsToCurrentThread());
 
@@ skipping 70 matching lines @@
 }
 
 void PepperPlatformAudioInputImpl::NotifyStreamCreationFailed() {
   DCHECK(main_message_loop_proxy_->BelongsToCurrentThread());
 
   if (client_)
     client_->StreamCreationFailed();
 }
 
 }  // namespace content