X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=aacdec.c;h=235b292d33168d74150bb8534f03caa0a365ce64;hp=2433b181ef8d7b3730f3e7dd10c1169c55fdc8ce;hb=0845d4aad5a6de08ceeae1700ef86bb38f9dc477;hpb=e19276003c9158fceccae4d7e626cabb2fb5b0dd diff --git a/aacdec.c b/aacdec.c index 2433b181..235b292d 100644 --- a/aacdec.c +++ b/aacdec.c @@ -1,77 +1,76 @@ /* - * Copyright (C) 2006 Andre Noll + * Copyright (C) 2006-2008 Andre Noll * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA. + * Licensed under the GPL v2. For licencing details see COPYING. */ - /* * based in parts on libfaad, Copyright (C) 2003-2005 M. Bakker, * Ahead Software AG */ -/** \file aacdec.c paraslash's mp3 decoder */ +/** \file aacdec.c paraslash's aac (m4a) decoder */ #include "para.h" #include "list.h" +#include "sched.h" #include "filter.h" #include "error.h" #include "string.h" #include "aac.h" /** the output buffer size */ -#define MAX_CHANNELS 6 -#define AAC_OUTBUF_SIZE (FAAD_MIN_STREAMSIZE * MAX_CHANNELS) +#define AAC_OUTBUF_SIZE (32 * 1024) + +/** give up decoding after that many errors */ +#define MAX_ERRORS 20 /** * data specific to the aacdec filter * * \sa filter, filter_node */ -struct private_mp4dec_data { - NeAACDecHandle decoder; +struct private_aacdec_data { + /** the return value of aac_open */ + NeAACDecHandle handle; + /** info about the currently decoded frame */ NeAACDecFrameInfo frame_info; - + /** whether this instance of the aac decoder is already initialized */ int initialized; - int decoder_length; - long unsigned consumed_total; - - long unsigned entry; + /** + * return value of aac_find_esds(). Used to call the right aacdec + * init function + */ + unsigned long decoder_length; + /** number of times the decoder returned an error */ + unsigned error_count; + /** number of bytes already consumed from the imput stream */ + size_t consumed_total; + /** return value of aac_find_entry_point */ + size_t entry; }; -static ssize_t mp4dec(char *input_buffer, size_t len, struct filter_node *fn) +static ssize_t aacdec(char *input_buffer, size_t len, struct filter_node *fn) { - struct private_mp4dec_data *padd = fn->private_data; - struct filter_chain_info *fci = fn->fci; - unsigned long rate = 0; - unsigned char channels = 0; - int i, ret, skip; + struct private_aacdec_data *padd = fn->private_data; + struct filter_chain *fc = fn->fc; + int i, ret; unsigned char *p, *outbuffer; unsigned char *inbuf = (unsigned char*)input_buffer; - size_t consumed = 0; + size_t skip, consumed = 0; - if (fn->loaded > fn->bufsize * 4 / 5) + if (fn->loaded > fn->bufsize * 3 / 5) return 0; - if (len < 1000 && !*fci->eof) + if (len < 2048 && !*fc->input_error) return 0; if (!padd->initialized) { - padd->decoder_length = aac_find_esds(inbuf, len, &skip); - PARA_INFO_LOG("decoder len: %d\n", padd->decoder_length); - if (padd->decoder_length < 0) { - ret = NeAACDecInit(padd->decoder, inbuf, + unsigned long rate = 0; + unsigned char channels = 0; + ret = aac_find_esds(inbuf, len, &skip, &padd->decoder_length); + if (ret < 0) { + PARA_INFO_LOG("%s\n", para_strerror(-ret)); + ret = NeAACDecInit(padd->handle, inbuf, len, &rate, &channels); PARA_INFO_LOG("decoder init: %d\n", ret); if (ret < 0) { @@ -80,32 +79,34 @@ static ssize_t mp4dec(char *input_buffer, size_t len, struct filter_node *fn) } consumed = ret; } else { + PARA_INFO_LOG("decoder len: %lu\n", + padd->decoder_length); consumed += skip; p = inbuf + consumed; ret = -E_AACDEC_INIT; - if (NeAACDecInit2(padd->decoder, p, + if (NeAACDecInit2(padd->handle, p, padd->decoder_length, &rate, &channels) < 0) goto out; } - fci->samplerate = rate; - fci->channels = channels; + fc->samplerate = rate; + fc->channels = channels; PARA_INFO_LOG("rate: %u, channels: %d\n", - fci->samplerate, fci->channels); + fc->samplerate, fc->channels); padd->initialized = 1; } if (padd->decoder_length > 0) { consumed = 0; if (!padd->entry) { - ret = aac_find_stco(inbuf + consumed, len - consumed, - &skip); + ret = aac_find_entry_point(inbuf + consumed, + len - consumed, &skip); if (ret < 0) { ret = len; goto out; } consumed += skip; - padd->entry = aac_read_int32(inbuf + consumed); - PARA_INFO_LOG("entry: %lu\n", padd->entry); + padd->entry = ret; + PARA_INFO_LOG("entry: %zu\n", padd->entry); } ret = len; if (padd->consumed_total + len < padd->entry) @@ -113,17 +114,19 @@ static ssize_t mp4dec(char *input_buffer, size_t len, struct filter_node *fn) if (padd->consumed_total < padd->entry) consumed = padd->entry - padd->consumed_total; } - for (; consumed < len;consumed++) + for (; consumed < len; consumed++) if ((inbuf[consumed] & 0xfe) == 0x20) break; if (consumed >= len) goto success; p = inbuf + consumed; - outbuffer = NeAACDecDecode(padd->decoder, &padd->frame_info, p, + outbuffer = NeAACDecDecode(padd->handle, &padd->frame_info, p, len - consumed); - ret = -E_AAC_DECODE; - if (padd->frame_info.error != 0) { - PARA_ERROR_LOG("frame_error: %d, consumed: %lu + %d + %lu\n", + if (padd->frame_info.error) { + ret = -E_AAC_DECODE; + if (padd->error_count++ > MAX_ERRORS) + goto out; + PARA_ERROR_LOG("frame_error: %d, consumed: %zu + %zd + %lu\n", padd->frame_info.error, padd->consumed_total, consumed, padd->frame_info.bytesconsumed); PARA_ERROR_LOG("%s\n", NeAACDecGetErrorMessage( @@ -131,14 +134,18 @@ static ssize_t mp4dec(char *input_buffer, size_t len, struct filter_node *fn) consumed++; /* catch 21 */ goto success; } + padd->error_count = 0; consumed += padd->frame_info.bytesconsumed; ret = consumed; if (!padd->frame_info.samples) goto out; + ret = -E_AAC_OVERRUN; + if (padd->frame_info.samples * 2 + fn->loaded > fn->bufsize) + goto out; for (i = 0; i < padd->frame_info.samples; i++) { short *s = (short *)outbuffer; - fn->buf[fn->loaded++] = s[i] & 0xff; - fn->buf[fn->loaded++] = (s[i] >> 8) & 0xff; + write_int16_host_endian(fn->buf + fn->loaded, s[i]); + fn->loaded += 2; } success: ret = consumed; @@ -148,21 +155,21 @@ out: return ret; } -static void mp4dec_open(struct filter_node *fn) +static void aacdec_open(struct filter_node *fn) { - fn->private_data = para_calloc(sizeof(struct private_mp4dec_data)); - struct private_mp4dec_data *padd = fn->private_data; + fn->private_data = para_calloc(sizeof(struct private_aacdec_data)); + struct private_aacdec_data *padd = fn->private_data; fn->bufsize = AAC_OUTBUF_SIZE; fn->buf = para_calloc(fn->bufsize); - padd->decoder = aac_open(); + padd->handle = aac_open(); } -static void mp4dec_close(struct filter_node *fn) +static void aacdec_close(struct filter_node *fn) { - struct private_mp4dec_data *padd = fn->private_data; + struct private_aacdec_data *padd = fn->private_data; - NeAACDecClose(padd->decoder); + NeAACDecClose(padd->handle); free(fn->buf); fn->buf = NULL; free(padd); @@ -170,13 +177,15 @@ static void mp4dec_close(struct filter_node *fn) } /** - * the init function of the mp3dec filter + * the init function of the aacdec filter + * + * \param f pointer to the filter struct to initialize * * \sa filter::init */ void aacdec_init(struct filter *f) { - f->open = mp4dec_open; - f->convert = mp4dec; - f->close = mp4dec_close; + f->open = aacdec_open; + f->convert = aacdec; + f->close = aacdec_close; }