]> git.tuebingen.mpg.de Git - paraslash.git/commitdiff
Merge branch 'master' into aac
authorAndre <maan@p133.(none)>
Fri, 12 May 2006 15:00:10 +0000 (17:00 +0200)
committerAndre <maan@p133.(none)>
Fri, 12 May 2006 15:00:10 +0000 (17:00 +0200)
Conflicts:

Makefile.in

Makefile.in looks fine. WTF is git complaining about?

CREDITS
Makefile.in
aacdec.c [new file with mode: 0644]
audiod.h
configure.ac
error.h
filter.h

diff --git a/CREDITS b/CREDITS
index 87dee1e145b5ba7ec7906858850346af2250b87d..13e1dbc6d134c267c4832b675f1f7e9975c452b7 100644 (file)
--- a/CREDITS
+++ b/CREDITS
@@ -7,6 +7,8 @@ software on which this project is based on.
 
 These people include:
 
+M. Bakker (libfaad)
+
 Karl Bartel <karlb@gmx.net> (SFont)
 
 Gerd Becker <gerd.mac@gmx.net> (MacOs testing)
index 8b78decbb56af29ac479e2bf0825b16b745efab4..ee0cca6e466cbb53f4723033d5825e8ea8d59ae6 100644 (file)
@@ -20,7 +20,7 @@ build_date = $(shell date)
 system = $(shell uname -rs)
 cc_version = $(shell $(CC) --version | head -n 1)
 version = @PACKAGE_VERSION@
-codename = sonic convolution
+codename = oriented abstraction
 
 DEBUG_CPPFLAGS += -Wno-sign-compare -g -Wunused -Wundef -W
 
@@ -139,6 +139,9 @@ grab_client.cmdline.h grab_client.cmdline.c: grab_client.ggo
        esac; \
        gengetopt $$O --conf-parser --file-name=$(*F).cmdline --set-package="para_$(subst .cmdline,,$(*F))" --set-version="$V"  < $<
 
+aacdec.o: aacdec.c
+       $(CC) -c $(CPPFLAGS) $(DEBUG_CPPFLAGS) @faad_cppflags@ $<
+
 para_recv: @recv_objs@
        $(CC) @recv_objs@ -o $@ @recv_ldflags@
 
diff --git a/aacdec.c b/aacdec.c
new file mode 100644 (file)
index 0000000..0eab773
--- /dev/null
+++ b/aacdec.c
@@ -0,0 +1,293 @@
+/*
+ * Copyright (C) 2006 Andre Noll <maan@systemlinux.org>
+ *
+ *     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.
+ */
+
+/*
+ * based in parts on libfaad, Copyright (C) 2003-2005 M. Bakker,
+ * Ahead Software AG
+ */
+
+/** \file aacdec.c paraslash's mp3 decoder */
+
+#include "para.h"
+
+#include "list.h"
+#include "filter.h"
+#include "error.h"
+#include <mad.h>
+#include "string.h"
+
+#include <neaacdec.h>
+
+/** the output buffer size */
+#define MAX_CHANNELS 6
+#define AAC_OUTBUF_SIZE (FAAD_MIN_STREAMSIZE * MAX_CHANNELS)
+
+/**
+ * data specific to the aacdec filter
+ *
+ * \sa filter, filter_node
+ */
+struct private_mp4dec_data {
+       NeAACDecHandle decoder;
+       NeAACDecConfigurationPtr config;
+       NeAACDecFrameInfo frame_info;
+       mp4AudioSpecificConfig mp4ASC;
+
+       int initialized;
+       int decoder_length;
+       unsigned char *inbuf;
+       int inbuf_len;
+       int consumed;
+       long unsigned consumed_total;
+
+       unsigned noffsets;
+       unsigned *offset;
+       int offset_pos;
+};
+
+static int read_mp4_descr_length(struct private_mp4dec_data *padd)
+{
+       uint8_t b;
+       uint8_t numBytes = 0;
+       uint32_t length = 0;
+
+       do {
+               b = padd->inbuf[padd->consumed + numBytes];
+               numBytes++;
+               length = (length << 7) | (b & 0x7F);
+       } while
+               ((b & 0x80) && numBytes < 4);
+       padd->consumed += numBytes;
+       return length;
+}
+
+static int find_esds(struct private_mp4dec_data *padd)
+{
+       for (; padd->consumed < padd->inbuf_len; padd->consumed++) {
+               unsigned char *p = padd->inbuf + padd->consumed;
+               int decoder_length;
+
+               if (p[0] != 'e' || p[1] != 's' || p[2] != 'd' || p[3] != 's')
+                       continue;
+               padd->consumed += 8;
+               p = padd->inbuf + padd->consumed;
+               PARA_INFO_LOG("found esds: %d, next: %x\n", padd->consumed, *p);
+               if (*p == 3)
+                       padd->consumed += 8;
+               else
+                       padd->consumed += 6;
+               p = padd->inbuf + padd->consumed;
+               PARA_INFO_LOG("next: %x\n", *p);
+               if (*p != 4)
+                       continue;
+               padd->consumed += 18;
+               p = padd->inbuf + padd->consumed;
+               PARA_INFO_LOG("next: %x\n", *p);
+               if (*p != 5)
+                       continue;
+               padd->consumed++;
+               decoder_length = read_mp4_descr_length(padd);
+               PARA_INFO_LOG("decoder length: %d\n", decoder_length);
+               p = padd->inbuf + padd->consumed;
+               PARA_INFO_LOG("decoder data0: %x\n", *p & 0xff);
+               p++;
+               PARA_INFO_LOG("decoder data1: %x\n", *p & 0xff);
+               return decoder_length;
+       }
+       return -E_ESDS;
+}
+
+static int read_int32(struct private_mp4dec_data *padd, unsigned *result)
+{
+       uint8_t *d = (uint8_t*)(padd->inbuf + padd->consumed);
+       if (padd->consumed + 4 > padd->inbuf_len)
+               return -1;
+       padd->consumed += 4;
+       *result = (d[0] << 24) | (d[1] << 16) | (d[2] << 8) | d[3];
+       return 1;
+}
+
+static int fill_offset_table(struct private_mp4dec_data *padd)
+{
+       int i, ret;
+
+       for (i = padd->offset_pos; i < padd->noffsets; i++) {
+               ret = read_int32(padd, &padd->offset[i]);
+               if (ret < 0)
+                       return -1;
+               PARA_DEBUG_LOG("offset #%d: %d\n", i, padd->offset[i]);
+               padd->offset_pos++;
+       }
+       return 1;
+}
+
+static int find_stco(struct private_mp4dec_data *padd)
+{
+       int ret;
+
+       for (; padd->consumed < padd->inbuf_len; padd->consumed++) {
+               unsigned char *p = padd->inbuf + padd->consumed;
+
+               if (p[0] != 's' || p[1] != 't' || p[2] != 'c' || p[3] != 'o')
+                       continue;
+               PARA_INFO_LOG("found stco: %d\n", padd->consumed);
+               padd->consumed += 8;
+               ret = read_int32(padd, &padd->noffsets);
+               padd->offset = para_malloc(padd->noffsets * sizeof(int));
+               PARA_INFO_LOG("num entries: %d\n", padd->noffsets);
+               return 1;
+       }
+       return -E_STCO;
+}
+
+static ssize_t mp4dec(char *inbuffer, 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, nbytes;
+       unsigned char *p, *outbuffer;
+
+       if (fn->loaded > fn->bufsize * 4 / 5)
+               return 0;
+       if (len < 1000 && !*fci->eof)
+               return 0;
+       padd->consumed = 0;
+       padd->inbuf = (unsigned char*)inbuffer;
+       padd->inbuf_len = len;
+
+       if (!padd->initialized) {
+               padd->decoder_length = find_esds(padd);
+               if (padd->decoder_length < 0) {
+                       ret = NeAACDecInit(padd->decoder, padd->inbuf,
+                               padd->inbuf_len, &rate, &channels);
+                       if (ret < 0) {
+                               ret = E_AACDEC_INIT;
+                               goto out;
+                       }
+                       padd->consumed = ret;
+               } else {
+                       p = padd->inbuf + padd->consumed;
+                       ret = E_AACDEC_INIT;
+                       if (NeAACDecInit2(padd->decoder, p,
+                                       padd->decoder_length, &rate,
+                                       &channels) < 0)
+                               goto out;
+               }
+               fci->samplerate = rate;
+               fci->channels = channels;
+               PARA_INFO_LOG("rate: %u, channels: %d\n", fci->samplerate,
+                       fci->channels);
+               padd->initialized = 1;
+       }
+       if (padd->decoder_length > 0) {
+               padd->consumed = 0;
+               if (!padd->offset_pos) {
+                       ret = len;
+                       if (find_stco(padd) < 0)
+                               goto out;
+               }
+               if (padd->offset_pos < padd->noffsets) {
+                       fill_offset_table(padd);
+                       ret = padd->consumed;
+                       goto out;
+               }
+//             PARA_INFO_LOG("consumed total: %lu, first_chunk: %d\n",
+//                     padd->consumed_total, padd->offset[0]);
+               ret = len;
+               if (padd->consumed_total + len < padd->offset[0])
+                       goto out;
+               if (padd->consumed_total < padd->offset[0])
+                       padd->consumed = padd->offset[0] - padd->consumed_total;
+       }
+       for (; padd->consumed < padd->inbuf_len; padd->consumed++)
+               if ((padd->inbuf[padd->consumed] & 0xfe) == 0x20)
+                       break;
+       if (padd->consumed >= padd->inbuf_len)
+               goto success;
+       p = padd->inbuf + padd->consumed;
+//     PARA_NOTICE_LOG("p[0]: %lx\n", (long unsigned) *p);
+       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",
+                       padd->frame_info.error, padd->consumed_total,
+                       padd->consumed, padd->frame_info.bytesconsumed);
+               PARA_ERROR_LOG("%s\n", NeAACDecGetErrorMessage(
+                       padd->frame_info.error));
+               padd->consumed++; /* catch 21 */
+               goto success;
+       }
+       padd->consumed += padd->frame_info.bytesconsumed;
+       ret = padd->consumed;
+       if (!padd->frame_info.samples)
+               goto out;
+       nbytes = padd->frame_info.samples;
+       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;
+       }
+success:
+       ret = padd->consumed;
+out:
+       if (ret > 0)
+               padd->consumed_total += ret;
+       return ret;
+}
+
+static void mp4dec_open(struct filter_node *fn)
+{
+       fn->private_data = para_calloc(sizeof(struct private_mp4dec_data));
+       struct private_mp4dec_data *padd = fn->private_data;
+
+       fn->bufsize = AAC_OUTBUF_SIZE;
+       fn->buf = para_calloc(fn->bufsize);
+
+       padd->decoder = NeAACDecOpen();
+       padd->config = NeAACDecGetCurrentConfiguration(padd->decoder);
+       padd->config->defObjectType = LC;
+       padd->config->outputFormat = FAAD_FMT_16BIT;
+       padd->config->downMatrix = 0;
+       NeAACDecSetConfiguration(padd->decoder, padd->config);
+}
+
+static void mp4dec_close(struct filter_node *fn)
+{
+       struct private_mp4dec_data *padd = fn->private_data;
+
+       NeAACDecClose(padd->decoder);
+       free(fn->buf);
+       fn->buf = NULL;
+       free(padd);
+       fn->private_data = NULL;
+}
+
+/**
+ * the init function of the mp3dec filter
+ *
+ * \sa filter::init
+ */
+void aacdec_init(struct filter *f)
+{
+       f->open = mp4dec_open;
+       f->convert = mp4dec;
+       f->close = mp4dec_close;
+}
index e6bd9b3314a9e6c2c9b9291a0d1a46057a1274bc..4cd35954f403c37d2f6d4ef7b62f4234bb4281d3 100644 (file)
--- a/audiod.h
+++ b/audiod.h
@@ -3,10 +3,11 @@ int num_filters(int audio_format_num);
 int get_audio_format_num(char *name);
 enum {
        AUDIO_FORMAT_MP3,
-       AUDIO_FORMAT_OGG
+       AUDIO_FORMAT_OGG,
+       AUDIO_FORMAT_AAC,
+       NUM_AUDIO_FORMATS
 };
-#define NUM_AUDIO_FORMATS (AUDIO_FORMAT_OGG + 1)
 extern const char *audio_formats[];
-#define DEFINE_AUDIO_FORMAT_ARRAY const char *audio_formats[] = {"mp3", "ogg", NULL}
+#define DEFINE_AUDIO_FORMAT_ARRAY const char *audio_formats[] = {"mp3", "ogg", "aac", NULL}
 #define MAX_STREAM_SLOTS 5
 
index a28d4114486c0cc476e77a165929bdeb57ea581a..91cd28425e78e81fe88d4d1486bdf94ff32d48e2 100644 (file)
@@ -215,6 +215,33 @@ if test "$have_ogg" = "yes"; then
 else
        AC_MSG_WARN([no ogg vorbis support in para_server/para_filter])
 fi
+########################################################################### faad
+have_faad=yes
+AC_ARG_ENABLE(faad_headers, [AC_HELP_STRING(--enable-faad-headers=dir,
+       [look for neaacdec.h also in dir])])
+if test -n "$enable_faad_headers"; then
+       faad_cppflags="-I$enable_faad_headers"
+       CPPFLAGS="$CPPFLAGS $faad_cppflags"
+fi
+AC_ARG_ENABLE(faad_libs, [AC_HELP_STRING(--enable-fadd-libs=dir,
+       [look for libfaad also in dir])])
+if test -n "$enable_faad_libs"; then
+       faad_libs="-L$enable_faad_libs"
+       LDFLAGS="$LDFLAGS $faad_libs"
+fi
+AC_CHECK_HEADER(neaacdec.h, [], have_faad=no)
+AC_CHECK_LIB([faad], [NeAACDecOpen], [], have_faad=no)
+if test "$have_faad" = "yes"; then
+       AC_DEFINE(HAVE_FAAD, 1, define to 1 if you want to build the aacdec filter)
+       filter_errlist_objs="$filter_errlist_objs aacdec"
+       audiod_errlist_objs="$audiod_errlist_objs aacdec"
+       filter_ldflags="$filter_ldflags $faad_libs -lfaad"
+       audiod_ldflags="$audiod_ldflags $faad_libs -lfaad"
+       AC_SUBST(faad_cppflags)
+       AC_SUBST(faad_libs)
+else
+       AC_MSG_WARN([no aac support in para_audiod/para_filter])
+fi
 ########################################################################### mad
 have_mad="yes"
 AC_CHECK_HEADERS([mad.h], [], [
@@ -364,13 +391,14 @@ AC_SUBST(gui_objs, add_dot_o($gui_objs))
 
 AC_OUTPUT
 AC_MSG_NOTICE([creating Makefile.deps])
-gcc -MM -MG $mysql_cppflags *.c > Makefile.deps
+gcc -MM -MG $mysql_cppflags $faad_cppflags *.c > Makefile.deps
 AC_MSG_NOTICE([
 paraslash configuration:
 ~~~~~~~~~~~~~~~~~~~~~~~~
 mysql support: $have_mysql
 ogg vorbis support: $have_ogg
 mp3dec support (libmad): $have_mad
+aac support (libfaad): $have_faad
 ortp support: $have_ortp
 unix socket credentials: $have_ucred
 supported writers for para_write: $write_writers
diff --git a/error.h b/error.h
index d0c3afc20ed6ea6f026af2119a8cb05f5224de0a..614390f282546a0f2ca7624db8c4964891376b5f 100644 (file)
--- a/error.h
+++ b/error.h
@@ -49,6 +49,7 @@ enum para_subsystem {
        SS_OGG,
        SS_MP3,
        SS_MP3DEC,
+       SS_AACDEC,
        SS_SERVER,
        SS_AFS,
        SS_MYSQL_SELECTOR,
@@ -335,6 +336,12 @@ extern const char **para_errlist[];
 #define WRITE_COMMON_ERRORS \
        PARA_ERROR(WRITE_COMMON_SYNTAX, "syntax error in write option"), \
 
+#define AACDEC_ERRORS \
+       PARA_ERROR(AACDEC_INIT, "failed to init aac decoder"), \
+       PARA_ERROR(ESDS, "did not find esds atom"), \
+       PARA_ERROR(STSZ, "did not find stsz atom"), \
+       PARA_ERROR(STCO, "did not find stco atom"), \
+       PARA_ERROR(AAC_DECODE, "aac decode error"), \
 
 /* these do not need error handling (yet) */
 #define SERVER_ERRORS
@@ -437,6 +444,7 @@ SS_ENUM(WAV);
 SS_ENUM(COMPRESS);
 SS_ENUM(OGGDEC);
 SS_ENUM(MP3DEC);
+SS_ENUM(AACDEC);
 SS_ENUM(FILTER);
 SS_ENUM(MP3);
 SS_ENUM(OGG);
index 70f4f4feb9873a64ac1a2263373ee123e24a1840..2fb9ad175fbeecaf816c4707e79d2fe96091461d 100644 (file)
--- a/filter.h
+++ b/filter.h
@@ -330,6 +330,13 @@ DECLARE_EXTERN_FILTER_INIT(mp3dec);
 #define MP3DEC_FILTER
 #endif
 
+#ifdef HAVE_FAAD
+DECLARE_EXTERN_FILTER_INIT(aacdec);
+#define AACDEC_FILTER FILTER_INIT(aacdec)
+#else
+#define AACDEC_FILTER
+#endif
+
 #ifdef HAVE_OGGVORBIS
 DECLARE_EXTERN_FILTER_INIT(oggdec);
 #define OGGDEC_FILTER FILTER_INIT(oggdec)
@@ -344,6 +351,7 @@ DECLARE_EXTERN_FILTER_INIT(oggdec);
        FILTER_INIT(wav) \
        FILTER_INIT(compress) \
        MP3DEC_FILTER \
+       AACDEC_FILTER \
        OGGDEC_FILTER \
        { .name = NULL } };
 /** \endcond */