Redesign the copresence audio handlers.

components/copresence/mediums/audio/audio_player.cc

-// Copyright 2014 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 "components/copresence/mediums/audio/audio_player.h"
-
-#include <algorithm>
-#include <string>
-
-#include "base/bind.h"
-#include "base/bind_helpers.h"
-#include "base/logging.h"
-#include "base/run_loop.h"
-#include "components/copresence/public/copresence_constants.h"
-#include "content/public/browser/browser_thread.h"
-#include "media/audio/audio_manager.h"
-#include "media/audio/audio_parameters.h"
-#include "media/base/audio_bus.h"
-
-namespace {
-
-const int kDefaultFrameCount = 1024;
-const double kOutputVolumePercent = 1.0f;
-
-}  // namespace
-
-namespace copresence {
-
-// Public methods.
-
-AudioPlayer::AudioPlayer()
-    : is_playing_(false), stream_(NULL), frame_index_(0) {
-}
-
-AudioPlayer::~AudioPlayer() {
-}
-
-void AudioPlayer::Initialize() {
-  media::AudioManager::Get()->GetTaskRunner()->PostTask(
-      FROM_HERE,
-      base::Bind(&AudioPlayer::InitializeOnAudioThread,
-                 base::Unretained(this)));
-}
-
-void AudioPlayer::Play(
-    const scoped_refptr<media::AudioBusRefCounted>& samples) {
-  media::AudioManager::Get()->GetTaskRunner()->PostTask(
-      FROM_HERE,
-      base::Bind(
-          &AudioPlayer::PlayOnAudioThread, base::Unretained(this), samples));
-}
-
-void AudioPlayer::Stop() {
-  media::AudioManager::Get()->GetTaskRunner()->PostTask(
-      FROM_HERE,
-      base::Bind(&AudioPlayer::StopOnAudioThread, base::Unretained(this)));
-}
-
-bool AudioPlayer::IsPlaying() {
-  return is_playing_;
-}
-
-void AudioPlayer::Finalize() {
-  media::AudioManager::Get()->GetTaskRunner()->PostTask(
-      FROM_HERE,
-      base::Bind(&AudioPlayer::FinalizeOnAudioThread, base::Unretained(this)));
-}
-
-// Private methods.
-
-void AudioPlayer::InitializeOnAudioThread() {
-  DCHECK(media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread());
-  stream_ = output_stream_for_testing_
-                ? output_stream_for_testing_.get()
-                : media::AudioManager::Get()->MakeAudioOutputStreamProxy(
-                      media::AudioParameters(
-                          media::AudioParameters::AUDIO_PCM_LOW_LATENCY,
-                          media::CHANNEL_LAYOUT_MONO,
-                          kDefaultSampleRate,
-                          kDefaultBitsPerSample,
-                          kDefaultFrameCount),
-                      std::string());
-
-  if (!stream_ || !stream_->Open()) {
-    LOG(ERROR) << "Failed to open an output stream.";
-    if (stream_) {
-      stream_->Close();
-      stream_ = NULL;
-    }
-    return;
-  }
-  stream_->SetVolume(kOutputVolumePercent);
-}
-
-void AudioPlayer::PlayOnAudioThread(
-    const scoped_refptr<media::AudioBusRefCounted>& samples) {
-  DCHECK(media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread());
-  if (!stream_)
-    return;
-
-  {
-    base::AutoLock al(state_lock_);
-
-    samples_ = samples;
-    frame_index_ = 0;
-
-    if (is_playing_)
-      return;
-  }
-
-  is_playing_ = true;
-  stream_->Start(this);
-}
-
-void AudioPlayer::StopOnAudioThread() {
-  DCHECK(media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread());
-  if (!stream_)
-    return;
-
-  stream_->Stop();
-  is_playing_ = false;
-}
-
-void AudioPlayer::StopAndCloseOnAudioThread() {
-  DCHECK(media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread());
-  if (!stream_)
-    return;
-
-  if (is_playing_)
-    stream_->Stop();
-  stream_->Close();
-  stream_ = NULL;
-
-  is_playing_ = false;
-}
-
-void AudioPlayer::FinalizeOnAudioThread() {
-  DCHECK(media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread());
-  StopAndCloseOnAudioThread();
-  delete this;
-}
-
-int AudioPlayer::OnMoreData(media::AudioBus* dest,
-                            uint32 /* total_bytes_delay */) {
-  base::AutoLock al(state_lock_);
-  // Continuously play our samples till explicitly told to stop.
-  const int leftover_frames = samples_->frames() - frame_index_;
-  const int frames_to_copy = std::min(dest->frames(), leftover_frames);
-
-  samples_->CopyPartialFramesTo(frame_index_, frames_to_copy, 0, dest);
-  frame_index_ += frames_to_copy;
-
-  // If we didn't fill the destination audio bus, wrap around and fill the rest.
-  if (leftover_frames <= dest->frames()) {
-    samples_->CopyPartialFramesTo(
-        0, dest->frames() - frames_to_copy, frames_to_copy, dest);
-    frame_index_ = dest->frames() - frames_to_copy;
-  }
-
-  return dest->frames();
-}
-
-void AudioPlayer::OnError(media::AudioOutputStream* /* stream */) {
-  LOG(ERROR) << "Error during system sound reproduction.";
-  media::AudioManager::Get()->GetTaskRunner()->PostTask(
-      FROM_HERE,
-      base::Bind(&AudioPlayer::StopAndCloseOnAudioThread,
-                 base::Unretained(this)));
-}
-
-void AudioPlayer::FlushAudioLoopForTesting() {
-  if (media::AudioManager::Get()->GetTaskRunner()->BelongsToCurrentThread())
-    return;
-
-  // Queue task on the audio thread, when it is executed, that means we've
-  // successfully executed all the tasks before us.
-  base::RunLoop rl;
-  media::AudioManager::Get()->GetTaskRunner()->PostTaskAndReply(
-      FROM_HERE,
-      base::Bind(base::IgnoreResult(&AudioPlayer::FlushAudioLoopForTesting),
-                 base::Unretained(this)),
-      rl.QuitClosure());
-  rl.Run();
-}
-
-}  // namespace copresence