X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=aacdec.c;h=235b292d33168d74150bb8534f03caa0a365ce64;hp=9cc9755f219ae357113084177abbae73bd895973;hb=53a27fb91166a7734f0768721b2cef91f0f6172e;hpb=72c44464f1fd0cf0c253da784027fe6143bff536 diff --git a/aacdec.c b/aacdec.c index 9cc9755f..235b292d 100644 --- a/aacdec.c +++ b/aacdec.c @@ -1,173 +1,175 @@ /* - * 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; - unsigned char *inbuf; - int inbuf_len; - int consumed; - 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 *inbuffer, 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 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; - padd->consumed = 0; - padd->inbuf = (unsigned char*)inbuffer; - padd->inbuf_len = len; if (!padd->initialized) { - padd->decoder_length = aac_find_esds(padd->inbuf, padd->inbuf_len, - &skip); - PARA_INFO_LOG("decoder len: %d\n", padd->decoder_length); - if (padd->decoder_length < 0) { - ret = NeAACDecInit(padd->decoder, padd->inbuf, - padd->inbuf_len, &rate, &channels); + 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) { ret = -E_AACDEC_INIT; goto out; } - padd->consumed = ret; + consumed = ret; } else { - padd->consumed += skip; - p = padd->inbuf + padd->consumed; + 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) { - padd->consumed = 0; + consumed = 0; if (!padd->entry) { - ret = aac_find_stco(padd->inbuf + padd->consumed, - padd->inbuf_len - padd->consumed, &skip); + ret = aac_find_entry_point(inbuf + consumed, + len - consumed, &skip); if (ret < 0) { ret = len; goto out; } - padd->consumed += skip; - padd->entry = aac_read_int32(padd->inbuf + padd->consumed); - PARA_INFO_LOG("entry: %lu\n", padd->entry); + consumed += skip; + padd->entry = ret; + PARA_INFO_LOG("entry: %zu\n", padd->entry); } ret = len; if (padd->consumed_total + len < padd->entry) goto out; if (padd->consumed_total < padd->entry) - padd->consumed = padd->entry - padd->consumed_total; + consumed = padd->entry - padd->consumed_total; } - for (; padd->consumed < padd->inbuf_len; padd->consumed++) - if ((padd->inbuf[padd->consumed] & 0xfe) == 0x20) + for (; consumed < len; consumed++) + if ((inbuf[consumed] & 0xfe) == 0x20) break; - if (padd->consumed >= padd->inbuf_len) + if (consumed >= len) goto success; - p = padd->inbuf + padd->consumed; - outbuffer = NeAACDecDecode(padd->decoder, &padd->frame_info, p, - len - padd->consumed); - ret = -E_AAC_DECODE; - if (padd->frame_info.error != 0) { - PARA_ERROR_LOG("frame_error: %d, consumed: %lu + %d + %lu\n", + p = inbuf + consumed; + outbuffer = NeAACDecDecode(padd->handle, &padd->frame_info, p, + len - consumed); + 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, - padd->consumed, padd->frame_info.bytesconsumed); + consumed, padd->frame_info.bytesconsumed); PARA_ERROR_LOG("%s\n", NeAACDecGetErrorMessage( padd->frame_info.error)); - padd->consumed++; /* catch 21 */ + consumed++; /* catch 21 */ goto success; } - padd->consumed += padd->frame_info.bytesconsumed; - ret = padd->consumed; + 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 = padd->consumed; + ret = consumed; out: if (ret > 0) padd->consumed_total += ret; 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); @@ -175,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; }