Mojofication of the Chrome Audio Rendering Prototype

media/audio/audio_output_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_output_controller.h"
 
 #include <stdint.h>
 
 #include <limits>
 
@@ skipping 53 matching lines @@
   if (!params.IsValid() || !audio_manager)
     return NULL;
 
   scoped_refptr<AudioOutputController> controller(new AudioOutputController(
       audio_manager, event_handler, params, output_device_id, sync_reader));
   controller->message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioOutputController::DoCreate, controller, false));
   return controller;
 }
 
+scoped_refptr<AudioOutputController> AudioOutputController::Create(
+    AudioManager* audio_manager,
+    EventHandler* event_handler,
+    const AudioParameters& params,
+    const std::string& output_device_id,
+    SyncReader* sync_reader,
+    content::mojom::AudioOutputStreamPtr stream,
+    const content::mojom::AudioOutput::CreateStreamCallback& callback) {
+  DCHECK(audio_manager);
+  DCHECK(sync_reader);
+
+  if (!params.IsValid() || !audio_manager)
+    return NULL;
+
+  scoped_refptr<AudioOutputController> controller(new AudioOutputController(
+      audio_manager, event_handler, params, output_device_id, sync_reader));
+  controller->stream_ptr_ = std::move(stream);
+
+  controller->message_loop_->PostTask(
+      FROM_HERE, base::Bind(&AudioOutputController::DoCreateMojo, controller,
+                            false, callback));
+  return controller;
+}
+
 void AudioOutputController::Play() {
   message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioOutputController::DoPlay, this));
 }
 
 void AudioOutputController::Pause() {
   message_loop_->PostTask(FROM_HERE, base::Bind(
       &AudioOutputController::DoPause, this));
 }
 
@@ skipping 63 matching lines @@
   stream_->SetVolume(volume_);
 
   // Finally set the state to kCreated.
   state_ = kCreated;
 
   // And then report we have been created if we haven't done so already.
   if (!is_for_device_change)
     handler_->OnCreated();
 }
 
+void AudioOutputController::DoCreateMojo(
+    bool is_for_device_change,
+    const content::mojom::AudioOutput::CreateStreamCallback& callback) {
+  DCHECK(message_loop_->BelongsToCurrentThread());
+  SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioOutputController.CreateTime");
+  TRACE_EVENT0("audio", "AudioOutputController::DoCreate");
+
+  // Close() can be called before DoCreate() is executed.
+  if (state_ == kClosed)
+    return;
+
+  DoStopCloseAndClearStream();  // Calls RemoveOutputDeviceChangeListener().
+  DCHECK_EQ(kEmpty, state_);
+
+  stream_ = diverting_to_stream_ ? diverting_to_stream_
+                                 : audio_manager_->MakeAudioOutputStreamProxy(
+                                       params_, output_device_id_);
+  if (!stream_) {
+    state_ = kError;
+    handler_->OnError();
+    return;
+  }
+
+  if (!stream_->Open()) {
+    DoStopCloseAndClearStream();
+    state_ = kError;
+    handler_->OnError();
+    return;
+  }
+
+  // Everything started okay, so re-register for state change callbacks if
+  // stream_ was created via AudioManager.
+  if (stream_ != diverting_to_stream_)
+    audio_manager_->AddOutputDeviceChangeListener(this);
+
+  // We have successfully opened the stream. Set the initial volume.
+  stream_->SetVolume(volume_);
+
+  // Finally set the state to kCreated.
+  state_ = kCreated;
+
+  // And then report we have been created if we haven't done so already.
+  if (!is_for_device_change)
+    handler_->OnCreated(std::move(stream_ptr_), callback);
+}
+
 void AudioOutputController::DoPlay() {
   DCHECK(message_loop_->BelongsToCurrentThread());
   SCOPED_UMA_HISTOGRAM_TIMER("Media.AudioOutputController.PlayTime");
   TRACE_EVENT0("audio", "AudioOutputController::DoPlay");
 
   // We can start from created or paused state.
   if (state_ != kCreated && state_ != kPaused)
     return;
 
   // Ask for first packet.
@@ skipping 261 matching lines @@
   DCHECK(message_loop_->BelongsToCurrentThread());
 
   // If we should be playing and we haven't, that's a wedge.
   if (state_ == kPlaying) {
     UMA_HISTOGRAM_BOOLEAN("Media.AudioOutputControllerPlaybackStartupSuccess",
                           base::AtomicRefCountIsOne(&on_more_io_data_called_));
   }
 }
 
 }  // namespace media