138 lines
2.9 KiB
C++
138 lines
2.9 KiB
C++
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
// Copyright The Music Player Daemon Project
|
|
|
|
/*
|
|
* Common data structures and functions used by FLAC and OggFLAC
|
|
*/
|
|
|
|
#include "FlacCommon.hxx"
|
|
#include "lib/xiph/FlacStreamMetadata.hxx"
|
|
#include "Log.hxx"
|
|
#include "input/InputStream.hxx"
|
|
|
|
#include <exception>
|
|
|
|
bool
|
|
FlacDecoder::Initialize(unsigned sample_rate, unsigned bits_per_sample,
|
|
unsigned channels, FLAC__uint64 total_frames) noexcept
|
|
{
|
|
assert(!initialized);
|
|
assert(!unsupported);
|
|
|
|
try {
|
|
pcm_import.Open(sample_rate, bits_per_sample,
|
|
channels);
|
|
} catch (...) {
|
|
LogError(std::current_exception());
|
|
unsupported = true;
|
|
return false;
|
|
}
|
|
|
|
const auto audio_format = pcm_import.GetAudioFormat();
|
|
|
|
const auto duration = total_frames > 0
|
|
? SignedSongTime::FromScale<uint64_t>(total_frames,
|
|
audio_format.sample_rate)
|
|
: SignedSongTime::Negative();
|
|
|
|
GetClient()->Ready(audio_format,
|
|
GetInputStream().IsSeekable(),
|
|
duration);
|
|
|
|
initialized = true;
|
|
return true;
|
|
}
|
|
|
|
inline void
|
|
FlacDecoder::OnStreamInfo(const FLAC__StreamMetadata_StreamInfo &stream_info) noexcept
|
|
{
|
|
if (initialized)
|
|
return;
|
|
|
|
Initialize(stream_info.sample_rate,
|
|
stream_info.bits_per_sample,
|
|
stream_info.channels,
|
|
stream_info.total_samples);
|
|
}
|
|
|
|
inline void
|
|
FlacDecoder::OnVorbisComment(const FLAC__StreamMetadata_VorbisComment &vc) noexcept
|
|
{
|
|
ReplayGainInfo rgi;
|
|
if (flac_parse_replay_gain(rgi, vc))
|
|
GetClient()->SubmitReplayGain(&rgi);
|
|
|
|
if (auto mix_ramp = flac_parse_mixramp(vc);
|
|
mix_ramp.IsDefined())
|
|
GetClient()->SubmitMixRamp(std::move(mix_ramp));
|
|
|
|
tag = flac_vorbis_comments_to_tag(&vc);
|
|
}
|
|
|
|
void
|
|
FlacDecoder::OnMetadata(const FLAC__StreamMetadata &metadata) noexcept
|
|
{
|
|
if (unsupported)
|
|
return;
|
|
|
|
switch (metadata.type) {
|
|
case FLAC__METADATA_TYPE_STREAMINFO:
|
|
OnStreamInfo(metadata.data.stream_info);
|
|
break;
|
|
|
|
case FLAC__METADATA_TYPE_VORBIS_COMMENT:
|
|
OnVorbisComment(metadata.data.vorbis_comment);
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
inline bool
|
|
FlacDecoder::OnFirstFrame(const FLAC__FrameHeader &header) noexcept
|
|
{
|
|
if (unsupported)
|
|
return false;
|
|
|
|
return Initialize(header.sample_rate,
|
|
header.bits_per_sample,
|
|
header.channels,
|
|
/* unknown duration */
|
|
0);
|
|
}
|
|
|
|
FLAC__uint64
|
|
FlacDecoder::GetDeltaPosition(const FLAC__StreamDecoder &sd)
|
|
{
|
|
FLAC__uint64 nbytes;
|
|
if (!FLAC__stream_decoder_get_decode_position(&sd, &nbytes))
|
|
return 0;
|
|
|
|
if (position > 0 && nbytes > position) {
|
|
nbytes -= position;
|
|
position += nbytes;
|
|
} else {
|
|
position = nbytes;
|
|
nbytes = 0;
|
|
}
|
|
|
|
return nbytes;
|
|
}
|
|
|
|
FLAC__StreamDecoderWriteStatus
|
|
FlacDecoder::OnWrite(const FLAC__Frame &frame,
|
|
const FLAC__int32 *const buf[],
|
|
FLAC__uint64 nbytes) noexcept
|
|
{
|
|
if (!initialized && !OnFirstFrame(frame.header))
|
|
return FLAC__STREAM_DECODER_WRITE_STATUS_ABORT;
|
|
|
|
chunk = pcm_import.Import(buf, frame.header.blocksize);
|
|
|
|
kbit_rate = nbytes * 8 * frame.header.sample_rate /
|
|
(1000 * frame.header.blocksize);
|
|
|
|
return FLAC__STREAM_DECODER_WRITE_STATUS_CONTINUE;
|
|
}
|