aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2008-11-11 21:15:01 +0100
committerMax Kellermann <max@duempel.org>2008-11-11 21:15:01 +0100
commit7b575b55c2c1184e9131888a49dfacf81cdca32c (patch)
tree8c6c3fb09cd021888c2776b3c4936085a305d3c2 /src
parent67814eddff6f19b88ec0a1086bc242b029c20edc (diff)
downloadmpd-7b575b55c2c1184e9131888a49dfacf81cdca32c.tar.gz
mpd-7b575b55c2c1184e9131888a49dfacf81cdca32c.tar.xz
mpd-7b575b55c2c1184e9131888a49dfacf81cdca32c.zip
ogg: flush buffer after every ov_read() call
Don't let the buffer grow until it is full, flush it whenever there is data available.
Diffstat (limited to 'src')
-rw-r--r--src/decoder/oggvorbis_plugin.c35
1 files changed, 10 insertions, 25 deletions
diff --git a/src/decoder/oggvorbis_plugin.c b/src/decoder/oggvorbis_plugin.c
index 965242f10..32742142a 100644
--- a/src/decoder/oggvorbis_plugin.c
+++ b/src/decoder/oggvorbis_plugin.c
@@ -208,7 +208,6 @@ oggvorbis_decode(struct decoder *decoder, struct input_stream *inStream)
long ret;
#define OGG_CHUNK_SIZE 4096
char chunk[OGG_CHUNK_SIZE];
- int chunkpos = 0;
long bitRate = 0;
long test;
struct replay_gain_info *replayGainInfo = NULL;
@@ -264,13 +263,12 @@ oggvorbis_decode(struct decoder *decoder, struct input_stream *inStream)
if (decoder_get_command(decoder) == DECODE_COMMAND_SEEK) {
double seek_where = decoder_seek_where(decoder);
if (0 == ov_time_seek_page(&vf, seek_where)) {
- chunkpos = 0;
decoder_command_finished(decoder);
} else
decoder_seek_error(decoder);
}
- ret = ov_read(&vf, chunk + chunkpos,
- OGG_CHUNK_SIZE - chunkpos,
+
+ ret = ov_read(&vf, chunk, sizeof(chunk),
OGG_DECODE_USE_BIGENDIAN, 2, 1, &current_section);
if (current_section != prev_section) {
/*printf("new song!\n"); */
@@ -308,28 +306,15 @@ oggvorbis_decode(struct decoder *decoder, struct input_stream *inStream)
break;
}
- chunkpos += ret;
+ if ((test = ov_bitrate_instant(&vf)) > 0)
+ bitRate = test / 1000;
- if (chunkpos >= OGG_CHUNK_SIZE) {
- if ((test = ov_bitrate_instant(&vf)) > 0) {
- bitRate = test / 1000;
- }
- decoder_data(decoder, inStream,
- chunk, chunkpos,
- ov_pcm_tell(&vf) / audio_format.sample_rate,
- bitRate, replayGainInfo);
- chunkpos = 0;
- if (decoder_get_command(decoder) == DECODE_COMMAND_STOP)
- break;
- }
- }
-
- if (decoder_get_command(decoder) == DECODE_COMMAND_NONE &&
- chunkpos > 0) {
- decoder_data(decoder, NULL,
- chunk, chunkpos,
- ov_time_tell(&vf), bitRate,
- replayGainInfo);
+ decoder_data(decoder, inStream,
+ chunk, ret,
+ ov_pcm_tell(&vf) / audio_format.sample_rate,
+ bitRate, replayGainInfo);
+ if (decoder_get_command(decoder) == DECODE_COMMAND_STOP)
+ break;
}
if (replayGainInfo)