Associate audio streams with their source/destination RenderView.

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"
 #include "content/common/child_process.h"
 #include "content/common/media/audio_messages.h"
+#include "content/renderer/media/audio_input_message_filter.h"
 #include "content/renderer/pepper/pepper_plugin_delegate_impl.h"
 #include "content/renderer/render_thread_impl.h"
 #include "media/audio/audio_manager_base.h"
 
 namespace content {
 
 // static
 PepperPlatformAudioInputImpl* PepperPlatformAudioInputImpl::Create(
     const base::WeakPtr<PepperPluginDelegateImpl>& plugin_delegate,
     const std::string& device_id,
@@ skipping 108 matching lines @@
   // here.
   DCHECK_EQ(0, stream_id_);
   DCHECK(!client_);
   DCHECK(label_.empty());
   DCHECK(shutdown_called_);
 }
 
 PepperPlatformAudioInputImpl::PepperPlatformAudioInputImpl()
     : client_(NULL),
       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,
     int sample_rate,
     int frames_per_buffer,
     webkit::ppapi::PluginDelegate::PlatformAudioInputClient* client) {
   DCHECK(main_message_loop_proxy_->BelongsToCurrentThread());
 
   if (!plugin_delegate || !client)
     return false;
 
   plugin_delegate_ = plugin_delegate;
+  render_view_id_ = plugin_delegate_->GetRoutingID();
   client_ = client;
 
   params_.Reset(media::AudioParameters::AUDIO_PCM_LINEAR,
                 media::CHANNEL_LAYOUT_MONO, sample_rate, 16, frames_per_buffer);
 
   if (device_id.empty()) {
     // Use the default device.
     ChildProcess::current()->io_message_loop()->PostTask(
         FROM_HERE,
         base::Bind(&PepperPlatformAudioInputImpl::InitializeOnIOThread,
@@ skipping 27 matching lines @@
   } else {
     // We will be notified by OnDeviceReady().
     ipc_->StartDevice(stream_id_, session_id);
   }
 }
 
 void PepperPlatformAudioInputImpl::StartCaptureOnIOThread() {
   DCHECK(ChildProcess::current()->io_message_loop_proxy()->
       BelongsToCurrentThread());
 
-  if (stream_id_)
+  if (stream_id_) {
+    ipc_->AssociateStreamWithConsumer(stream_id_, render_view_id_);
     ipc_->RecordStream(stream_id_);
+  }
 }
 
 void PepperPlatformAudioInputImpl::StopCaptureOnIOThread() {
   DCHECK(ChildProcess::current()->io_message_loop_proxy()->
       BelongsToCurrentThread());
 
   // TODO(yzshen): We cannot re-start capturing if the stream is closed.
   if (stream_id_)
     ipc_->CloseStream(stream_id_);
 }
@@ skipping 56 matching lines @@
 }
 
 void PepperPlatformAudioInputImpl::NotifyStreamCreationFailed() {
   DCHECK(main_message_loop_proxy_->BelongsToCurrentThread());
 
   if (client_)
     client_->StreamCreationFailed();
 }
 
 }  // namespace content