Tab Audio Mirroring: WebContentsAudioInputStream is a new implementation which represents the lifet…

media/audio/audio_input_controller.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 "media/audio/audio_input_controller.h"
 
 #include "base/bind.h"
 #include "base/threading/thread_restrictions.h"
 #include "media/base/limits.h"
 
@@ skipping 83 matching lines @@
   // audio-device thread. Use the provided audio-input device.
   if (!controller->message_loop_->PostTask(FROM_HERE,
           base::Bind(&AudioInputController::DoCreate, controller,
                      base::Unretained(audio_manager), params, device_id))) {
     controller = NULL;
   }
 
   return controller;
 }
 
+// static
+scoped_refptr<AudioInputController> AudioInputController::CreateForStream(
+    AudioManager* audio_manager,
+    EventHandler* event_handler,
+    AudioInputStream* stream,
+    SyncWriter* sync_writer) {
+  DCHECK(audio_manager);
+  DCHECK(sync_writer);
+  DCHECK(stream);
+
+  // Create the AudioInputController object and ensure that it runs on
+  // the audio-manager thread.
+  scoped_refptr<AudioInputController> controller(new AudioInputController(
+      event_handler, sync_writer));
+  controller->message_loop_ = audio_manager->GetMessageLoop();
+
+  if (!controller->message_loop_->PostTask(
+          FROM_HERE,
+          base::Bind(&AudioInputController::DoCreateForStream, controller,
+                     stream))) {
+    controller = NULL;
+  }
+
+  return controller;
+}
+
 void AudioInputController::Record() {
   message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioInputController::DoRecord, this));
 }
 
 void AudioInputController::Close(const base::Closure& closed_task) {
   DCHECK(!closed_task.is_null());
   DCHECK(creator_loop_->BelongsToCurrentThread());
 
   message_loop_->PostTaskAndReply(
       FROM_HERE, base::Bind(&AudioInputController::DoClose, this), closed_task);
 }
 
 void AudioInputController::SetVolume(double volume) {
   message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioInputController::DoSetVolume, this, volume));
 }
 
 void AudioInputController::SetAutomaticGainControl(bool enabled) {
   message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioInputController::DoSetAutomaticGainControl, this, enabled));
 }
 
 void AudioInputController::DoCreate(AudioManager* audio_manager,
                                     const AudioParameters& params,
                                     const std::string& device_id) {
   DCHECK(message_loop_->BelongsToCurrentThread());
+  DoCreateForStream(audio_manager->MakeAudioInputStream(params, device_id));
+}
 
-  stream_ = audio_manager->MakeAudioInputStream(params, device_id);
+void AudioInputController::DoCreateForStream(
+    AudioInputStream* stream_to_control) {
+  DCHECK(message_loop_->BelongsToCurrentThread());
+
+  DCHECK(!stream_);
+  stream_ = stream_to_control;
 
   if (!stream_) {
     // TODO(satish): Define error types.
     handler_->OnError(this, 0);
     return;
   }
 
   if (stream_ && !stream_->Open()) {
     stream_->Close();
     stream_ = NULL;
@@ skipping 167 matching lines @@
 
 void AudioInputController::SetDataIsActive(bool enabled) {
   base::subtle::Release_Store(&data_is_active_, enabled);
 }
 
 bool AudioInputController::GetDataIsActive() {
   return (base::subtle::Acquire_Load(&data_is_active_) != false);
 }
 
 }  // namespace media