Experimental: Unmute Audio During Tab Sourced Desktop Share

content/browser/media/capture/web_contents_audio_input_stream.cc

 // Copyright (c) 2013 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/browser/media/capture/web_contents_audio_input_stream.h"
 
 #include <memory>
 #include <string>
 
 #include "base/bind.h"
@@ skipping 69 matching lines @@
   void UnmuteWebContentsAudio();
 
   // AudioMirroringManager::MirroringDestination implementation
   void QueryForMatches(const std::set<SourceFrameRef>& candidates,
                        const MatchesCallback& results_callback) override;
   void QueryForMatchesOnUIThread(const std::set<SourceFrameRef>& candidates,
                                  const MatchesCallback& results_callback);
   media::AudioOutputStream* AddInput(
       const media::AudioParameters& params) override;
 
+  media::AudioPushSink* AddPushInput(
+      const media::AudioParameters& params) override;
+
   // Callback which is run when |stream| is closed.  Deletes |stream|.
   void ReleaseInput(media::VirtualAudioOutputStream* stream);
 
+  void ReleasePushInput(media::LoopbackSink* stream);
+
+  bool IsDuplication() override;
+
   // Called by WebContentsTracker when the target of the audio mirroring has
   // changed.
   void OnTargetChanged(bool had_target);
 
   // Injected dependencies.
   const int initial_render_process_id_;
   const int initial_main_render_frame_id_;
   AudioMirroringManager* const mirroring_manager_;
   const scoped_refptr<WebContentsTracker> tracker_;
   // The AudioInputStream implementation that handles the audio conversion and
@@ skipping 192 matching lines @@
       params,
       mixer_stream_.get(),
       base::Bind(&Impl::ReleaseInput, this));
 }
 
 void WebContentsAudioInputStream::Impl::ReleaseInput(
     media::VirtualAudioOutputStream* stream) {
   delete stream;
 }
 
+media::AudioPushSink* WebContentsAudioInputStream::Impl::AddPushInput(
+    const media::AudioParameters& params) {
+  // Note: The closure created here holds a reference to "this," which will
+  // guarantee the VirtualAudioInputStream (mixer_stream_) outlives the
+  // VirtualAudioOutputStream.
+  return new media::LoopbackSink(params, mixer_stream_.get(),
+                                 base::Bind(&Impl::ReleasePushInput, this));
+}
+
+void WebContentsAudioInputStream::Impl::ReleasePushInput(
+    media::LoopbackSink* stream) {
+  delete stream;
+}
+
+bool WebContentsAudioInputStream::Impl::IsDuplication() {
+  return true;
+}
+
 void WebContentsAudioInputStream::Impl::OnTargetChanged(bool had_target) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   is_target_lost_ = !had_target;
 
   if (state_ == MIRRORING) {
     if (is_target_lost_) {
       ReportError();
       Stop();
     } else {
@@ skipping 69 matching lines @@
 
 bool WebContentsAudioInputStream::GetAutomaticGainControl() {
   return impl_->mixer_stream()->GetAutomaticGainControl();
 }
 
 bool WebContentsAudioInputStream::IsMuted() {
   return false;
 }
 
 }  // namespace content