Detect AudioInputStream muting and propagate to MediaStreamAudioSource.

content/renderer/media/audio_input_message_filter.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/media/audio_input_message_filter.h"
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/single_thread_task_runner.h"
@@ skipping 69 matching lines @@
   }
 }
 
 bool AudioInputMessageFilter::OnMessageReceived(const IPC::Message& message) {
   DCHECK(io_task_runner_->BelongsToCurrentThread());
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(AudioInputMessageFilter, message)
     IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyStreamCreated,
                         OnStreamCreated)
     IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyStreamError, OnStreamError)
+    IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyStreamMuted, OnStreamMuted)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 void AudioInputMessageFilter::OnFilterAdded(IPC::Channel* channel) {
   DCHECK(io_task_runner_->BelongsToCurrentThread());
 
   // Captures the sender for IPC.
   sender_ = channel;
@@ skipping 49 matching lines @@
   DCHECK(io_task_runner_->BelongsToCurrentThread());
   media::AudioInputIPCDelegate* delegate = delegates_.Lookup(stream_id);
   if (!delegate) {
     DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
                   << " audio renderer.";
     return;
   }
   delegate->OnError();
 }
 
+void AudioInputMessageFilter::OnStreamMuted(int stream_id, bool is_muted) {
+  DCHECK(io_task_runner_->BelongsToCurrentThread());
+  media::AudioInputIPCDelegate* delegate = delegates_.Lookup(stream_id);
+  if (!delegate) {
+    DLOG(WARNING) << "Got audio stream muted event for a non-existent or "
+                     "removed audio renderer.";
+    return;
+  }
+  delegate->OnMuted(is_muted);
+}
+
 AudioInputMessageFilter::AudioInputIPCImpl::AudioInputIPCImpl(
     const scoped_refptr<AudioInputMessageFilter>& filter,
     int render_frame_id)
     : filter_(filter),
       render_frame_id_(render_frame_id),
       stream_id_(kStreamIDNotSet) {
 }
 
 AudioInputMessageFilter::AudioInputIPCImpl::~AudioInputIPCImpl() {}
 
@@ skipping 42 matching lines @@
 void AudioInputMessageFilter::AudioInputIPCImpl::CloseStream() {
   DCHECK(filter_->io_task_runner_->BelongsToCurrentThread());
   DCHECK_NE(stream_id_, kStreamIDNotSet);
   LogMessage(stream_id_, "CloseStream");
   filter_->Send(new AudioInputHostMsg_CloseStream(stream_id_));
   filter_->delegates_.Remove(stream_id_);
   stream_id_ = kStreamIDNotSet;
 }
 
 }  // namespace content