| Index: media/filters/buffered_audio_tracker.cc
|
| diff --git a/media/filters/buffered_audio_tracker.cc b/media/filters/buffered_audio_tracker.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..f55ee784c49986c9986bac9c89871e9a9cc4e30c
|
| --- /dev/null
|
| +++ b/media/filters/buffered_audio_tracker.cc
|
| @@ -0,0 +1,100 @@
|
| +// 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 "media/filters/buffered_audio_tracker.h"
|
| +
|
| +#include "base/logging.h"
|
| +
|
| +namespace media {
|
| +
|
| +BufferedAudioTracker::BufferedAudioTracker(int sample_rate)
|
| + : sample_rate_(sample_rate) {
|
| +}
|
| +
|
| +BufferedAudioTracker::~BufferedAudioTracker() {
|
| +}
|
| +
|
| +void BufferedAudioTracker::AudioCallbackFired(int delay_frames) {
|
| + if (buffered_audio_.empty())
|
| + return;
|
| +
|
| + size_t i = buffered_audio_.size() - 1;
|
| + while (true) {
|
| + if (buffered_audio_[i].frames <= delay_frames) {
|
| + // Reached the end before accounting for all of |delay_frames|. This means
|
| + // we haven't written enough audio data yet to account for hardware delay.
|
| + // In this case, do nothing.
|
| + if (i == 0)
|
| + return;
|
| +
|
| + // Keep accounting for |delay_frames|.
|
| + delay_frames -= buffered_audio_[i].frames;
|
| + --i;
|
| + continue;
|
| + }
|
| +
|
| + // All of |delay_frames| has been accounted for: adjust amount of frames
|
| + // left in current buffer. All preceeding elements with index < |i| should
|
| + // be considered played out and hence discared.
|
| + buffered_audio_[i].frames = delay_frames;
|
| + break;
|
| + }
|
| +
|
| + // At this point |i| points at what will be the new head of |buffered_audio_|
|
| + // however if it contains no audio it should be removed as well.
|
| + if (buffered_audio_[i].frames == 0)
|
| + ++i;
|
| +
|
| + buffered_audio_.erase(buffered_audio_.begin(), buffered_audio_.begin() + i);
|
| +}
|
| +
|
| +base::TimeDelta BufferedAudioTracker::BufferedTime() const {
|
| + base::TimeDelta buffered_time;
|
| +
|
| + for (size_t i = 0; i < buffered_audio_.size(); ++i) {
|
| + // Skip over silence.
|
| + if (buffered_audio_[i].playback_rate == 0)
|
| + continue;
|
| +
|
| + // Multiply by playback rate as frames represent time-scaled audio.
|
| + buffered_time += base::TimeDelta::FromMicroseconds(
|
| + base::Time::kMicrosecondsPerSecond * buffered_audio_[i].frames *
|
| + buffered_audio_[i].playback_rate / sample_rate_);
|
| + }
|
| +
|
| + return buffered_time;
|
| +}
|
| +
|
| +void BufferedAudioTracker::WroteAudio(int frames, float playback_rate) {
|
| + CHECK_GT(playback_rate, 0);
|
| + CHECK_GT(frames, 0);
|
| +
|
| + // Avoid creating extra elements where possible.
|
| + if (!buffered_audio_.empty() &&
|
| + buffered_audio_.back().playback_rate == playback_rate) {
|
| + buffered_audio_.back().frames += frames;
|
| + return;
|
| + }
|
| +
|
| + buffered_audio_.push_back(BufferedAudio(frames, playback_rate));
|
| +}
|
| +
|
| +void BufferedAudioTracker::WroteSilence(int frames) {
|
| + CHECK_GT(frames, 0);
|
| +
|
| + // Avoid creating extra elements where possible.
|
| + if (!buffered_audio_.empty() && buffered_audio_.back().playback_rate == 0) {
|
| + buffered_audio_.back().frames += frames;
|
| + return;
|
| + }
|
| +
|
| + buffered_audio_.push_back(BufferedAudio(frames, 0));
|
| +}
|
| +
|
| +BufferedAudioTracker::BufferedAudio::BufferedAudio(int frames,
|
| + float playback_rate)
|
| + : frames(frames), playback_rate(playback_rate) {
|
| +}
|
| +
|
| +} // namespace media
|
|
|