Renderer side audio device change wip...

media/base/audio_renderer_mixer_input.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/base/audio_renderer_mixer_input.h"
 
+#include "base/bind.h"
 #include "base/logging.h"
+#include "base/message_loop.h"
 #include "media/base/audio_renderer_mixer.h"
 
 namespace media {
 
 AudioRendererMixerInput::AudioRendererMixerInput(
     const GetMixerCB& get_mixer_cb, const RemoveMixerCB& remove_mixer_cb)
     : playing_(false),
       initialized_(false),
       volume_(1.0f),
       get_mixer_cb_(get_mixer_cb),
       remove_mixer_cb_(remove_mixer_cb),
       mixer_(NULL),
       callback_(NULL),
       current_audio_delay_milliseconds_(0) {
 }
 
 AudioRendererMixerInput::~AudioRendererMixerInput() {
-  // Mixer is no longer safe to use after |remove_mixer_cb_| has been called.
-  if (initialized_)
-    remove_mixer_cb_.Run(params_);
+  // |mixer_| is no longer safe to use after |remove_mixer_cb_| has been called.
+  if (initialized_) {
+    remove_mixer_cb_.Run(mixer_);
+    mixer_ = NULL;
+  }
 }
 
 void AudioRendererMixerInput::Initialize(
     const AudioParameters& params,
     AudioRendererSink::RenderCallback* callback) {
   DCHECK(!initialized_);
   params_ = params;
   mixer_ = get_mixer_cb_.Run(params_);
   callback_ = callback;
   initialized_ = true;
+
+  started_on_message_loop_ = base::MessageLoopProxy::current();
 }
 
 void AudioRendererMixerInput::Start() {
   DCHECK(initialized_);
   DCHECK(!playing_);
 }
 
 void AudioRendererMixerInput::Stop() {
   // Stop() may be called at any time, if Pause() hasn't been called we need to
   // remove our mixer input before shutdown.
@@ skipping 41 matching lines @@
         frames_filled, audio_bus->frames() - frames_filled);
   }
 
   return frames_filled > 0 ? volume_ : 0;
 }
 
 void AudioRendererMixerInput::OnRenderError() {
   callback_->OnRenderError();
 }
 
+void AudioRendererMixerInput::OnDeviceChange() {
+  LOG(ERROR) << "DEVICE CHANGE SENT";
+  started_on_message_loop_->PostTask(FROM_HERE, base::Bind(
+      &AudioRendererMixerInput::UpdateMixer, this));
+}
+
+void AudioRendererMixerInput::UpdateMixer() {
+  DCHECK(mixer_);
+  LOG(ERROR) << "AudioRendererMixerInput::kDeviceChange";
+
+  // First see if a new mixer is actually necessary.
+  AudioRendererMixer* new_mixer = get_mixer_cb_.Run(params_);
+  if (new_mixer == mixer_) {
+    remove_mixer_cb_.Run(new_mixer);
+    return;
+  }
+
+  LOG(ERROR) << "new mixer time!";
+  if (playing_)
+    mixer_->RemoveMixerInput(this);
+  remove_mixer_cb_.Run(mixer_);
+  mixer_ = new_mixer;
+  if (playing_)
+    mixer_->AddMixerInput(this);
+}
+
 }  // namespace media