oysteikt/mpd
0
0
Fork 0
Code Issues Pull Requests Releases Activity

Merge branch 'shine' of git://github.com/ekroth/mpd

Browse Source
This commit is contained in:
Max Kellermann 2014-01-13 22:54:15 +01:00
commit 07a7fde825
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/encoder/ShineEncoderPlugin.cxx
View File

@ -57,7 +57,7 @@ struct ShineEncoder {
bool Setup(Error &error); bool Setup(Error &error);
bool WriteChunk(bool flush, Error &error); bool WriteChunk(bool flush);
}; };
static constexpr Domain shine_encoder_domain("shine_encoder"); static constexpr Domain shine_encoder_domain("shine_encoder");
@ -142,7 +142,9 @@ shine_encoder_open(Encoder *_encoder, AudioFormat &audio_format, Error &error)
encoder->stereo[0] = new int16_t[encoder->frame_size]; encoder->stereo[0] = new int16_t[encoder->frame_size];
encoder->stereo[1] = new int16_t[encoder->frame_size]; encoder->stereo[1] = new int16_t[encoder->frame_size];
encoder->input_pos = 0; /* workaround for bug:
https://github.com/savonet/shine/issues/11 */
encoder->input_pos = SHINE_MAX_SAMPLES + 1;
encoder->output_buffer.Construct(BUFFER_INIT_SIZE); encoder->output_buffer.Construct(BUFFER_INIT_SIZE);
@ -154,6 +156,12 @@ shine_encoder_close(Encoder *_encoder)
{ {
ShineEncoder *encoder = (ShineEncoder *)_encoder; ShineEncoder *encoder = (ShineEncoder *)_encoder;
if (encoder->input_pos > SHINE_MAX_SAMPLES) {
/* write zero chunk */
encoder->input_pos = 0;
encoder->WriteChunk(true);
}
shine_close(encoder->shine); shine_close(encoder->shine);
delete[] encoder->stereo[0]; delete[] encoder->stereo[0];
delete[] encoder->stereo[1]; delete[] encoder->stereo[1];
@ -161,7 +169,7 @@ shine_encoder_close(Encoder *_encoder)
} }
bool bool
ShineEncoder::WriteChunk(bool flush, gcc_unused Error &error) ShineEncoder::WriteChunk(bool flush)
{ {
if (flush || input_pos == frame_size) { if (flush || input_pos == frame_size) {
long written; long written;
@ -195,6 +203,10 @@ shine_encoder_write(Encoder *_encoder,
length /= sizeof(*data) * encoder->audio_format.channels; length /= sizeof(*data) * encoder->audio_format.channels;
size_t written = 0; size_t written = 0;
if (encoder->input_pos > SHINE_MAX_SAMPLES) {
encoder->input_pos = 0;
}
/* write all data to de-interleaved buffers */ /* write all data to de-interleaved buffers */
while (written < length) { while (written < length) {
for (; for (;
@ -207,7 +219,7 @@ shine_encoder_write(Encoder *_encoder,
encoder->stereo[1][encoder->input_pos] = data[base + 1]; encoder->stereo[1][encoder->input_pos] = data[base + 1];
} }
/* write if chunk is filled */ /* write if chunk is filled */
encoder->WriteChunk(false, error); encoder->WriteChunk(false);
} }
return true; return true;
@ -220,7 +232,7 @@ shine_encoder_flush(Encoder *_encoder, gcc_unused Error &error)
long written; long written;
/* flush buffers and flush shine */ /* flush buffers and flush shine */
encoder->WriteChunk(true, error); encoder->WriteChunk(true);
const uint8_t *data = shine_flush(encoder->shine, &written); const uint8_t *data = shine_flush(encoder->shine, &written);
if (written > 0) if (written > 0)