Integrate HTMLMediaElement with Web Audio API's MediaElementAudioSourceNode

content/renderer/media/audio_renderer_impl.cc

 // Copyright (c) 2011 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_renderer_impl.h"
 
 #include <math.h>
 
 #include <algorithm>
 
@@ skipping 17 matching lines @@
   // with the AUDIO_PCM_LINEAR flag.
   const size_t kNominalBufferSize = 2048;
 
   if (sample_rate <= 48000)
     return kNominalBufferSize;
   else if (sample_rate <= 96000)
     return kNominalBufferSize * 2;
   return kNominalBufferSize * 4;
 }
 
-AudioRendererImpl::AudioRendererImpl()
+AudioRendererImpl::AudioRendererImpl(media::AudioRendererSink* sink)
     : AudioRendererBase(),
       bytes_per_second_(0),
-      stopped_(false) {
-  // We create the AudioDevice here because it must be created in the
-  // main thread.  But we don't yet know the audio format (sample-rate, etc.)
-  // at this point.  Later, when OnInitialize() is called, we have
-  // the audio format information and call the AudioDevice::Initialize()
-  // method to fully initialize it.
-  audio_device_ = new AudioDevice();
+      stopped_(false),
+      sink_(sink),
+      is_initialized_(false) {
 }
 
 AudioRendererImpl::~AudioRendererImpl() {
 }
 
 base::TimeDelta AudioRendererImpl::ConvertToDuration(int bytes) {
   if (bytes_per_second_) {
     return base::TimeDelta::FromMicroseconds(
         base::Time::kMicrosecondsPerSecond * bytes / bytes_per_second_);
   }
@@ skipping 25 matching lines @@
   // Please see: http://code.google.com/p/chromium/issues/detail?id=103627
   // for more details.
   audio_parameters_ = AudioParameters(AudioParameters::AUDIO_PCM_LINEAR,
                                       channel_layout,
                                       sample_rate,
                                       bits_per_channel,
                                       0);
 
   bytes_per_second_ = audio_parameters_.GetBytesPerSecond();
 
-  DCHECK(audio_device_.get());
+  DCHECK(sink_.get());
 
-  if (!audio_device_->IsInitialized()) {
-    audio_device_->Initialize(
+  if (!is_initialized_) {
+    sink_->Initialize(
         GetBufferSizeForSampleRate(sample_rate),
         audio_parameters_.channels,
         audio_parameters_.sample_rate,
         audio_parameters_.format,
         this);
 
-    audio_device_->Start();
+    sink_->Start();
+    is_initialized_ = true;
+    return true;
   }
 
-  return true;
+  return false;
 }
 
 void AudioRendererImpl::OnStop() {
   if (stopped_)
     return;
 
-  DCHECK(audio_device_.get());
-  audio_device_->Stop();
+  DCHECK(sink_.get());
+  sink_->Stop();
 
   stopped_ = true;
 }
 
 void AudioRendererImpl::SetPlaybackRate(float rate) {
   DCHECK_LE(0.0f, rate);
 
   // Handle the case where we stopped due to IO message loop dying.
   if (stopped_) {
     AudioRendererBase::SetPlaybackRate(rate);
@@ skipping 37 matching lines @@
   if (GetPlaybackRate() != 0.0f) {
     DoPlay();
   } else {
     DoPause();
   }
 }
 
 void AudioRendererImpl::SetVolume(float volume) {
   if (stopped_)
     return;
-  DCHECK(audio_device_.get());
-  audio_device_->SetVolume(volume);
+  DCHECK(sink_.get());
+  sink_->SetVolume(volume);
 }
 
 void AudioRendererImpl::DoPlay() {
   earliest_end_time_ = base::Time::Now();
-  DCHECK(audio_device_.get());
-  audio_device_->Play();
+  DCHECK(sink_.get());
+  sink_->Play();
 }
 
 void AudioRendererImpl::DoPause() {
-  DCHECK(audio_device_.get());
-  audio_device_->Pause(false);
+  DCHECK(sink_.get());
+  sink_->Pause(false);
 }
 
 void AudioRendererImpl::DoSeek() {
   earliest_end_time_ = base::Time::Now();
 
   // Pause and flush the stream when we seek to a new location.
-  DCHECK(audio_device_.get());
-  audio_device_->Pause(true);
+  DCHECK(sink_.get());
+  sink_->Pause(true);
 }
 
 size_t AudioRendererImpl::Render(const std::vector<float*>& audio_data,
                                  size_t number_of_frames,
                                  size_t audio_delay_milliseconds) {
   if (stopped_ || GetPlaybackRate() == 0.0f) {
     // Output silence if stopped.
     for (size_t i = 0; i < audio_data.size(); ++i)
       memset(audio_data[i], 0, sizeof(float) * number_of_frames);
     return 0;
@@ skipping 39 matching lines @@
     // If FillBuffer() didn't give us enough data then zero out the remainder.
     if (filled_frames < number_of_frames) {
       int frames_to_zero = number_of_frames - filled_frames;
       memset(audio_data[channel_index] + filled_frames,
              0,
              sizeof(float) * frames_to_zero);
     }
   }
   return filled_frames;
 }