1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
// 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 "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),
error_cb_(base::Bind(
&AudioRendererMixerInput::OnRenderError, base::Unretained(this))) {
}
AudioRendererMixerInput::~AudioRendererMixerInput() {
// Mixer is no longer safe to use after |remove_mixer_cb_| has been called.
if (initialized_)
remove_mixer_cb_.Run(params_);
}
void AudioRendererMixerInput::Initialize(
const AudioParameters& params,
AudioRendererSink::RenderCallback* callback) {
DCHECK(!initialized_);
params_ = params;
mixer_ = get_mixer_cb_.Run(params_);
callback_ = callback;
initialized_ = true;
}
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.
if (!playing_)
return;
mixer_->RemoveMixerInput(this);
playing_ = false;
}
void AudioRendererMixerInput::Play() {
DCHECK(initialized_);
if (playing_)
return;
mixer_->AddMixerInput(this, error_cb_);
playing_ = true;
}
void AudioRendererMixerInput::Pause() {
DCHECK(initialized_);
if (!playing_)
return;
mixer_->RemoveMixerInput(this);
playing_ = false;
}
bool AudioRendererMixerInput::SetVolume(double volume) {
volume_ = volume;
return true;
}
double AudioRendererMixerInput::ProvideInput(AudioBus* audio_bus,
base::TimeDelta buffer_delay) {
int frames_filled = callback_->Render(
audio_bus, static_cast<int>(buffer_delay.InMillisecondsF() + 0.5));
// AudioConverter expects unfilled frames to be zeroed.
if (frames_filled < audio_bus->frames()) {
audio_bus->ZeroFramesPartial(
frames_filled, audio_bus->frames() - frames_filled);
}
return frames_filled > 0 ? volume_ : 0;
}
void AudioRendererMixerInput::OnRenderError() {
callback_->OnRenderError();
}
} // namespace media
|
