blob: b8b91d7e2e37c75aaaeacea5314b23adb2dc71f4 (
plain)
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
|
// 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 "chromecast/media/cma/pipeline/audio_pipeline_impl.h"
#include <stddef.h>
#include "base/bind.h"
#include "chromecast/media/cma/base/buffering_defs.h"
#include "chromecast/media/cma/base/cma_logging.h"
#include "chromecast/media/cma/base/coded_frame_provider.h"
#include "chromecast/media/cma/base/decoder_config_adapter.h"
#include "chromecast/public/media/decoder_config.h"
#include "media/base/audio_decoder_config.h"
namespace chromecast {
namespace media {
namespace {
const size_t kMaxAudioFrameSize = 32 * 1024;
}
AudioPipelineImpl::AudioPipelineImpl(
MediaPipelineBackend::AudioDecoder* decoder,
const AvPipelineClient& client)
: AvPipelineImpl(decoder, client), audio_decoder_(decoder) {
DCHECK(audio_decoder_);
}
AudioPipelineImpl::~AudioPipelineImpl() {}
void AudioPipelineImpl::Initialize(
const ::media::AudioDecoderConfig& audio_config,
scoped_ptr<CodedFrameProvider> frame_provider,
const ::media::PipelineStatusCB& status_cb) {
CMALOG(kLogControl) << __FUNCTION__ << " "
<< audio_config.AsHumanReadableString();
if (frame_provider) {
SetCodedFrameProvider(frame_provider.Pass(), kAppAudioBufferSize,
kMaxAudioFrameSize);
}
DCHECK(audio_config.IsValidConfig());
AudioConfig cast_audio_config =
DecoderConfigAdapter::ToCastAudioConfig(kPrimary, audio_config);
if (!audio_decoder_->SetConfig(cast_audio_config)) {
status_cb.Run(::media::PIPELINE_ERROR_INITIALIZATION_FAILED);
return;
}
TransitionToState(kFlushed);
status_cb.Run(::media::PIPELINE_OK);
}
void AudioPipelineImpl::SetVolume(float volume) {
audio_decoder_->SetVolume(volume);
}
void AudioPipelineImpl::OnUpdateConfig(
StreamId id,
const ::media::AudioDecoderConfig& audio_config,
const ::media::VideoDecoderConfig& video_config) {
if (audio_config.IsValidConfig()) {
CMALOG(kLogControl) << __FUNCTION__ << " id:" << id << " "
<< audio_config.AsHumanReadableString();
bool success = audio_decoder_->SetConfig(
DecoderConfigAdapter::ToCastAudioConfig(id, audio_config));
if (!success && !client().playback_error_cb.is_null())
client().playback_error_cb.Run(::media::PIPELINE_ERROR_DECODE);
}
}
void AudioPipelineImpl::UpdateStatistics() {
if (client().statistics_cb.is_null())
return;
MediaPipelineBackend::AudioDecoder::Statistics audio_stats;
audio_decoder_->GetStatistics(&audio_stats);
::media::PipelineStatistics current_stats;
current_stats.audio_bytes_decoded = audio_stats.decoded_bytes;
::media::PipelineStatistics delta_stats;
delta_stats.audio_bytes_decoded =
current_stats.audio_bytes_decoded - previous_stats_.audio_bytes_decoded;
previous_stats_ = current_stats;
client().statistics_cb.Run(delta_stats);
}
} // namespace media
} // namespace chromecast
|
