diff options
-rw-r--r-- | configure.ac | 11 | ||||
-rw-r--r-- | plugins/alac/Makefile.am | 22 | ||||
-rw-r--r-- | plugins/alac/README | 43 | ||||
-rw-r--r-- | plugins/alac/alac.c | 1164 | ||||
-rw-r--r-- | plugins/alac/alac_plugin.c | 617 | ||||
-rw-r--r-- | plugins/alac/decomp.h | 13 | ||||
-rw-r--r-- | plugins/alac/demux.c | 730 | ||||
-rw-r--r-- | plugins/alac/demux.h | 62 | ||||
-rw-r--r-- | plugins/alac/stdint_win.h | 14 | ||||
-rw-r--r-- | plugins/alac/stream.c | 179 | ||||
-rw-r--r-- | plugins/alac/stream.h | 39 | ||||
-rwxr-xr-x | scripts/quickinstall.sh | 1 |
12 files changed, 2894 insertions, 1 deletions
diff --git a/configure.ac b/configure.ac index f75e6903..a892413a 100644 --- a/configure.ac +++ b/configure.ac @@ -110,6 +110,7 @@ AC_ARG_ENABLE(shn, [AS_HELP_STRING([--enable-shn ], [build SHN plugin AC_ARG_ENABLE(psf, [AS_HELP_STRING([--enable-psf ], [build AOSDK-based PSF(,QSF,SSF,DSF) plugin (default: auto)])], [enable_psf=$enableval], [enable_psf=yes]) AC_ARG_ENABLE(mono2stereo, [AS_HELP_STRING([--enable-mono2stereo ], [build mono2stereo DSP plugin (default: auto)])], [enable_mono2stereo=$enableval], [enable_mono2stereo=yes]) AC_ARG_ENABLE(shellexecui, [AS_HELP_STRING([--enable-shellexecui ], [build shellexec GTK UI plugin (default: auto)])], [enable_shellexecui=$enableval], [enable_shellexecui=yes]) +AC_ARG_ENABLE(alac, [AS_HELP_STRING([--enable-alac ], [build ALAC plugin (default: auto)])], [enable_alac=$enableval], [enable_alac=yes]) if test "x$enable_staticlink" != "xno" ; then AC_DEFINE_UNQUOTED([STATICLINK], [1], [Define if building static version]) @@ -588,7 +589,12 @@ if test "x$enable_mono2stereo" != "xno" ; then HAVE_MONO2STEREO=yes fi -PLUGINS_DIRS="plugins/lastfm plugins/mpgmad plugins/vorbis plugins/flac plugins/wavpack plugins/sndfile plugins/vfs_curl plugins/cdda plugins/gtkui plugins/alsa plugins/ffmpeg plugins/hotkeys plugins/oss plugins/artwork plugins/adplug plugins/ffap plugins/sid plugins/nullout plugins/supereq plugins/vtx plugins/gme plugins/pulse plugins/notify plugins/musepack plugins/wildmidi plugins/tta plugins/dca plugins/aac plugins/mms plugins/shellexec plugins/dsp_libsrc plugins/m3u plugins/vfs_zip plugins/converter plugins/dumb plugins/shn plugins/ao plugins/mono2stereo plugins/shellexecui" +if test "x$enable_alac" != "xno" ; then + HAVE_ALAC=yes +fi + + +PLUGINS_DIRS="plugins/lastfm plugins/mpgmad plugins/vorbis plugins/flac plugins/wavpack plugins/sndfile plugins/vfs_curl plugins/cdda plugins/gtkui plugins/alsa plugins/ffmpeg plugins/hotkeys plugins/oss plugins/artwork plugins/adplug plugins/ffap plugins/sid plugins/nullout plugins/supereq plugins/vtx plugins/gme plugins/pulse plugins/notify plugins/musepack plugins/wildmidi plugins/tta plugins/dca plugins/aac plugins/mms plugins/shellexec plugins/dsp_libsrc plugins/m3u plugins/vfs_zip plugins/converter plugins/dumb plugins/shn plugins/ao plugins/mono2stereo plugins/shellexecui plugins/alac" AM_CONDITIONAL(HAVE_VORBIS, test "x$HAVE_VORBISPLUGIN" = "xyes") AM_CONDITIONAL(HAVE_FLAC, test "x$HAVE_FLACPLUGIN" = "xyes") @@ -640,6 +646,7 @@ AM_CONDITIONAL(HAVE_MONO2STEREO, test "x$HAVE_MONO2STEREO" = "xyes") AM_CONDITIONAL(HAVE_SHELLEXECUI, test "x$HAVE_SHELLEXECUI" = "xyes") AM_CONDITIONAL(HAVE_SM, test "x$HAVE_SM" = "xyes") AM_CONDITIONAL(HAVE_ICE, test "x$HAVE_ICE" = "xyes") +AM_CONDITIONAL(HAVE_ALAC, test "x$HAVE_ALAC" = "xyes") AC_SUBST(PLUGINS_DIRS) @@ -705,6 +712,7 @@ PRINT_PLUGIN_INFO([dumb],[DUMB module plugin, for MOD, S3M, etc],[test "x$HAVE_D PRINT_PLUGIN_INFO([shn],[SHN plugin based on xmms-shn],[test "x$HAVE_SHN" = "xyes"]) PRINT_PLUGIN_INFO([mono2stereo],[mono2stereo DSP plugin],[test "x$HAVE_MONO2STEREO" = "xyes"]) PRINT_PLUGIN_INFO([shellexecui],[GTK user interface for configuring shellexec plugin],[test "x$HAVE_SHELLEXECUI" = "xyes"]) +PRINT_PLUGIN_INFO([alac],[ALAC plugin],[test "x$HAVE_ALAC" = "xyes"]) echo @@ -751,6 +759,7 @@ plugins/ao/Makefile plugins/shn/Makefile plugins/mono2stereo/Makefile plugins/shellexecui/Makefile +plugins/alac/Makefile intl/Makefile po/Makefile.in deadbeef.desktop diff --git a/plugins/alac/Makefile.am b/plugins/alac/Makefile.am new file mode 100644 index 00000000..0dc48ade --- /dev/null +++ b/plugins/alac/Makefile.am @@ -0,0 +1,22 @@ +if HAVE_ALAC +alacdir = $(libdir)/$(PACKAGE) +pkglib_LTLIBRARIES = alac.la +alac_la_SOURCES = alac_plugin.c\ +alac.c decomp.h demux.c demux.h stream.c stream.h\ +../libmp4ff/mp4atom.c\ +../libmp4ff/mp4ff.c\ +../libmp4ff/mp4meta.c\ +../libmp4ff/mp4sample.c\ +../libmp4ff/mp4tagupdate.c\ +../libmp4ff/mp4util.c\ +../libmp4ff/mp4ff.h\ +../libmp4ff/mp4ffint.h\ +../libmp4ff/mp4ff_int_types.h + +alac_la_LDFLAGS = -module + +alac_la_LIBADD = $(LDADD) $(FAAD2_LIBS) +AM_CFLAGS = $(CFLAGS) -std=c99 -DUSE_MP4FF -DUSE_TAGGING -I../libmp4ff +endif + + diff --git a/plugins/alac/README b/plugins/alac/README new file mode 100644 index 00000000..1b304d2d --- /dev/null +++ b/plugins/alac/README @@ -0,0 +1,43 @@ +INSTALLATION: +------------- + +Simply compile by running 'make' + +USAGE: +------ + +Then run the program, it will give you usage instructions. + +It's really quite trivial to use. + +For example, to decode input.m4a to output.wav: +./alac -f output.wav input.m4a + +Or, as another example, say if you wanted to stream play +http://www.mplayerhq.hu/MPlayer/samples/A-codecs/lossless/luckynight.m4a +and you're system uses the ALSA sound system: +wget -O - http://www.mplayerhq.hu/MPlayer/samples/A-codecs/lossless/luckynight.m4a | ./alac - | aplay + +By default the output file is in WAV format. To output as raw PCM, provide the +-r option on the command line. + +MORE INFORMATION: +----------------- + +Please visit http://crazney.net/programs/itunes/alac.html for more information. + +HELP NEEDED: +------------ +I need help to allow myself to continue hacking on various Apple Audio things, please visit +http://crazney.net/programs/itunes/help.html + +AUTHOR: +------- + +David Hammerton + +CONTRIBUTORS: +------------- + +Cody Brocious + diff --git a/plugins/alac/alac.c b/plugins/alac/alac.c new file mode 100644 index 00000000..469000da --- /dev/null +++ b/plugins/alac/alac.c @@ -0,0 +1,1164 @@ +/* + * ALAC (Apple Lossless Audio Codec) decoder + * Copyright (c) 2005 David Hammerton + * All rights reserved. + * + * This is the actual decoder. + * + * http://crazney.net/programs/itunes/alac.html + * + * Permission is hereby granted, free of charge, to any person + * obtaining a copy of this software and associated documentation + * files (the "Software"), to deal in the Software without + * restriction, including without limitation the rights to use, + * copy, modify, merge, publish, distribute, sublicense, and/or + * sell copies of the Software, and to permit persons to whom the + * Software is furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be + * included in all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES + * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT + * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, + * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING + * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR + * OTHER DEALINGS IN THE SOFTWARE. + * + */ + + +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#ifdef _WIN32 + #include "stdint_win.h" +#else + #include <stdint.h> +#endif + +#include "decomp.h" + +#define _Swap32(v) do { \ + v = (((v) & 0x000000FF) << 0x18) | \ + (((v) & 0x0000FF00) << 0x08) | \ + (((v) & 0x00FF0000) >> 0x08) | \ + (((v) & 0xFF000000) >> 0x18); } while(0) + +#define _Swap16(v) do { \ + v = (((v) & 0x00FF) << 0x08) | \ + (((v) & 0xFF00) >> 0x08); } while (0) + +struct {signed int x:24;} se_struct_24; +#define SignExtend24(val) (se_struct_24.x = val) + +extern int host_bigendian; + +struct alac_file +{ + unsigned char *input_buffer; + int input_buffer_bitaccumulator; /* used so we can do arbitary + bit reads */ + + int samplesize; + int numchannels; + int bytespersample; + + + /* buffers */ + int32_t *predicterror_buffer_a; + int32_t *predicterror_buffer_b; + + int32_t *outputsamples_buffer_a; + int32_t *outputsamples_buffer_b; + + int32_t *uncompressed_bytes_buffer_a; + int32_t *uncompressed_bytes_buffer_b; + + + + /* stuff from setinfo */ + uint32_t setinfo_max_samples_per_frame; /* 0x1000 = 4096 */ /* max samples per frame? */ + uint8_t setinfo_7a; /* 0x00 */ + uint8_t setinfo_sample_size; /* 0x10 */ + uint8_t setinfo_rice_historymult; /* 0x28 */ + uint8_t setinfo_rice_initialhistory; /* 0x0a */ + uint8_t setinfo_rice_kmodifier; /* 0x0e */ + uint8_t setinfo_7f; /* 0x02 */ + uint16_t setinfo_80; /* 0x00ff */ + uint32_t setinfo_82; /* 0x000020e7 */ /* max sample size?? */ + uint32_t setinfo_86; /* 0x00069fe4 */ /* bit rate (avarge)?? */ + uint32_t setinfo_8a_rate; /* 0x0000ac44 */ + /* end setinfo stuff */ + +}; + + +static void allocate_buffers(alac_file *alac) +{ + alac->predicterror_buffer_a = malloc(alac->setinfo_max_samples_per_frame * 4); + alac->predicterror_buffer_b = malloc(alac->setinfo_max_samples_per_frame * 4); + + alac->outputsamples_buffer_a = malloc(alac->setinfo_max_samples_per_frame * 4); + alac->outputsamples_buffer_b = malloc(alac->setinfo_max_samples_per_frame * 4); + + alac->uncompressed_bytes_buffer_a = malloc(alac->setinfo_max_samples_per_frame * 4); + alac->uncompressed_bytes_buffer_b = malloc(alac->setinfo_max_samples_per_frame * 4); +} + +void alac_set_info(alac_file *alac, char *inputbuffer) +{ + char *ptr = inputbuffer; + ptr += 4; /* size */ + ptr += 4; /* frma */ + ptr += 4; /* alac */ + ptr += 4; /* size */ + ptr += 4; /* alac */ + + ptr += 4; /* 0 ? */ + + alac->setinfo_max_samples_per_frame = *(uint32_t*)ptr; /* buffer size / 2 ? */ + if (!host_bigendian) + _Swap32(alac->setinfo_max_samples_per_frame); + ptr += 4; + alac->setinfo_7a = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_sample_size = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_rice_historymult = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_rice_initialhistory = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_rice_kmodifier = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_7f = *(uint8_t*)ptr; + ptr += 1; + alac->setinfo_80 = *(uint16_t*)ptr; + if (!host_bigendian) + _Swap16(alac->setinfo_80); + ptr += 2; + alac->setinfo_82 = *(uint32_t*)ptr; + if (!host_bigendian) + _Swap32(alac->setinfo_82); + ptr += 4; + alac->setinfo_86 = *(uint32_t*)ptr; + if (!host_bigendian) + _Swap32(alac->setinfo_86); + ptr += 4; + alac->setinfo_8a_rate = *(uint32_t*)ptr; + if (!host_bigendian) + _Swap32(alac->setinfo_8a_rate); + ptr += 4; + + allocate_buffers(alac); + +} + +/* stream reading */ + +/* supports reading 1 to 16 bits, in big endian format */ +static uint32_t readbits_16(alac_file *alac, int bits) +{ + uint32_t result; + int new_accumulator; + + result = (alac->input_buffer[0] << 16) | + (alac->input_buffer[1] << 8) | + (alac->input_buffer[2]); + + /* shift left by the number of bits we've already read, + * so that the top 'n' bits of the 24 bits we read will + * be the return bits */ + result = result << alac->input_buffer_bitaccumulator; + + result = result & 0x00ffffff; + + /* and then only want the top 'n' bits from that, where + * n is 'bits' */ + result = result >> (24 - bits); + + new_accumulator = (alac->input_buffer_bitaccumulator + bits); + + /* increase the buffer pointer if we've read over n bytes. */ + alac->input_buffer += (new_accumulator >> 3); + + /* and the remainder goes back into the bit accumulator */ + alac->input_buffer_bitaccumulator = (new_accumulator & 7); + + return result; +} + +/* supports reading 1 to 32 bits, in big endian format */ +static uint32_t readbits(alac_file *alac, int bits) +{ + int32_t result = 0; + + if (bits > 16) + { + bits -= 16; + result = readbits_16(alac, 16) << bits; + } + + result |= readbits_16(alac, bits); + + return result; +} + +/* reads a single bit */ +static int readbit(alac_file *alac) +{ + int result; + int new_accumulator; + + result = alac->input_buffer[0]; + + result = result << alac->input_buffer_bitaccumulator; + + result = result >> 7 & 1; + + new_accumulator = (alac->input_buffer_bitaccumulator + 1); + + alac->input_buffer += (new_accumulator / 8); + + alac->input_buffer_bitaccumulator = (new_accumulator % 8); + + return result; +} + +static void unreadbits(alac_file *alac, int bits) +{ + int new_accumulator = (alac->input_buffer_bitaccumulator - bits); + + alac->input_buffer += (new_accumulator >> 3); + + alac->input_buffer_bitaccumulator = (new_accumulator & 7); + if (alac->input_buffer_bitaccumulator < 0) + alac->input_buffer_bitaccumulator *= -1; +} + +/* various implementations of count_leading_zero: + * the first one is the original one, the simplest and most + * obvious for what it's doing. never use this. + * then there are the asm ones. fill in as necessary + * and finally an unrolled and optimised c version + * to fall back to + */ +#if 0 +/* hideously inefficient. could use a bitmask search, + * alternatively bsr on x86, + */ +static int count_leading_zeros(int32_t input) +{ + int i = 0; + while (!(0x80000000 & input) && i < 32) + { + i++; + input = input << 1; + } + return i; +} +#elif defined(__GNUC__) && (defined(_X86) || defined(__i386) || defined(i386)) +/* for some reason the unrolled version (below) is + * actually faster than this. yay intel! + */ +static int count_leading_zeros(int input) +{ + int output = 0; + if (!input) return 32; + __asm("bsr %1, %0\n" + : "=r" (output) + : "r" (input)); + return (0x1f - output); +} +#elif defined(_MSC_VER) && defined(_M_IX86) +static int count_leading_zeros(int input) +{ + int output = 0; + if (!input) return 32; + __asm + { + mov eax, input; + mov edx, 0x1f; + bsr ecx, eax; + sub edx, ecx; + mov output, edx; + } + return output; +} +#else +#warning using generic count leading zeroes. You may wish to write one for your CPU / compiler +static int count_leading_zeros(int input) +{ + int output = 0; + int curbyte = 0; + + curbyte = input >> 24; + if (curbyte) goto found; + output += 8; + + curbyte = input >> 16; + if (curbyte & 0xff) goto found; + output += 8; + + curbyte = input >> 8; + if (curbyte & 0xff) goto found; + output += 8; + + curbyte = input; + if (curbyte & 0xff) goto found; + output += 8; + + return output; + +found: + if (!(curbyte & 0xf0)) + { + output += 4; + } + else + curbyte >>= 4; + + if (curbyte & 0x8) + return output; + if (curbyte & 0x4) + return output + 1; + if (curbyte & 0x2) + return output + 2; + if (curbyte & 0x1) + return output + 3; + + /* shouldn't get here: */ + return output + 4; +} +#endif + +#define RICE_THRESHOLD 8 // maximum number of bits for a rice prefix. + +int32_t entropy_decode_value(alac_file* alac, + int readSampleSize, + int k, + int rice_kmodifier_mask) +{ + int32_t x = 0; // decoded value + + // read x, number of 1s before 0 represent the rice value. + while (x <= RICE_THRESHOLD && readbit(alac)) + { + x++; + } + + if (x > RICE_THRESHOLD) + { + // read the number from the bit stream (raw value) + int32_t value; + + value = readbits(alac, readSampleSize); + + // mask value + value &= (((uint32_t)0xffffffff) >> (32 - readSampleSize)); + + x = value; + } + else + { + if (k != 1) + { + int extraBits = readbits(alac, k); + + // x = x * (2^k - 1) + x *= (((1 << k) - 1) & rice_kmodifier_mask); + + if (extraBits > 1) + x += extraBits - 1; + else + unreadbits(alac, 1); + } + } + + return x; +} + +void entropy_rice_decode(alac_file* alac, + int32_t* outputBuffer, + int outputSize, + int readSampleSize, + int rice_initialhistory, + int rice_kmodifier, + int rice_historymult, + int rice_kmodifier_mask) +{ + int outputCount; + int history = rice_initialhistory; + int signModifier = 0; + + for (outputCount = 0; outputCount < outputSize; outputCount++) + { + int32_t decodedValue; + int32_t finalValue; + int32_t k; + + k = 31 - rice_kmodifier - count_leading_zeros((history >> 9) + 3); + + if (k < 0) k += rice_kmodifier; + else k = rice_kmodifier; + + // note: don't use rice_kmodifier_mask here (set mask to 0xFFFFFFFF) + decodedValue = entropy_decode_value(alac, readSampleSize, k, 0xFFFFFFFF); + + decodedValue += signModifier; + finalValue = (decodedValue + 1) / 2; // inc by 1 and shift out sign bit + if (decodedValue & 1) // the sign is stored in the low bit + finalValue *= -1; + + outputBuffer[outputCount] = finalValue; + + signModifier = 0; + + // update history + history += (decodedValue * rice_historymult) + - ((history * rice_historymult) >> 9); + + if (decodedValue > 0xFFFF) + history = 0xFFFF; + + // special case, for compressed blocks of 0 + if ((history < 128) && (outputCount + 1 < outputSize)) + { + int32_t blockSize; + + signModifier = 1; + + k = count_leading_zeros(history) + ((history + 16) / 64) - 24; + + // note: blockSize is always 16bit + blockSize = entropy_decode_value(alac, 16, k, rice_kmodifier_mask); + + // got blockSize 0s + if (blockSize > 0) + { + memset(&outputBuffer[outputCount + 1], 0, blockSize * sizeof(*outputBuffer)); + outputCount += blockSize; + } + + if (blockSize > 0xFFFF) + signModifier = 0; + + history = 0; + } + } +} + +#define SIGN_EXTENDED32(val, bits) ((val << (32 - bits)) >> (32 - bits)) + +#define SIGN_ONLY(v) \ + ((v < 0) ? (-1) : \ + ((v > 0) ? (1) : \ + (0))) + +static void predictor_decompress_fir_adapt(int32_t *error_buffer, + int32_t *buffer_out, + int output_size, + int readsamplesize, + int16_t *predictor_coef_table, + int predictor_coef_num, + int predictor_quantitization) +{ + int i; + + /* first sample always copies */ + *buffer_out = *error_buffer; + + if (!predictor_coef_num) + { + if (output_size <= 1) return; + memcpy(buffer_out+1, error_buffer+1, (output_size-1) * 4); + return; + } + + if (predictor_coef_num == 0x1f) /* 11111 - max value of predictor_coef_num */ + { /* second-best case scenario for fir decompression, + * error describes a small difference from the previous sample only + */ + if (output_size <= 1) return; + for (i = 0; i < output_size - 1; i++) + { + int32_t prev_value; + int32_t error_value; + + prev_value = buffer_out[i]; + error_value = error_buffer[i+1]; + buffer_out[i+1] = SIGN_EXTENDED32((prev_value + error_value), readsamplesize); + } + return; + } + + /* read warm-up samples */ + if (predictor_coef_num > 0) + { + int i; + for (i = 0; i < predictor_coef_num; i++) + { + int32_t val; + + val = buffer_out[i] + error_buffer[i+1]; + + val = SIGN_EXTENDED32(val, readsamplesize); + + buffer_out[i+1] = val; + } + } + +#if 0 + /* 4 and 8 are very common cases (the only ones i've seen). these + * should be unrolled and optimised + */ + if (predictor_coef_num == 4) + { + /* FIXME: optimised general case */ + return; + } + + if (predictor_coef_table == 8) + { + /* FIXME: optimised general case */ + return; + } +#endif + + + /* general case */ + if (predictor_coef_num > 0) + { + for (i = predictor_coef_num + 1; + i < output_size; + i++) + { + int j; + int sum = 0; + int outval; + int error_val = error_buffer[i]; + + for (j = 0; j < predictor_coef_num; j++) + { + sum += (buffer_out[predictor_coef_num-j] - buffer_out[0]) * + predictor_coef_table[j]; + } + + outval = (1 << (predictor_quantitization-1)) + sum; + outval = outval >> predictor_quantitization; + outval = outval + buffer_out[0] + error_val; + outval = SIGN_EXTENDED32(outval, readsamplesize); + + buffer_out[predictor_coef_num+1] = outval; + + if (error_val > 0) + { + int predictor_num = predictor_coef_num - 1; + + while (predictor_num >= 0 && error_val > 0) + { + int val = buffer_out[0] - buffer_out[predictor_coef_num - predictor_num]; + int sign = SIGN_ONLY(val); + + predictor_coef_table[predictor_num] -= sign; + + val *= sign; /* absolute value */ + + error_val -= ((val >> predictor_quantitization) * + (predictor_coef_num - predictor_num)); + + predictor_num--; + } + } + else if (error_val < 0) + { + int predictor_num = predictor_coef_num - 1; + + while (predictor_num >= 0 && error_val < 0) + { + int val = buffer_out[0] - buffer_out[predictor_coef_num - predictor_num]; + int sign = - SIGN_ONLY(val); + + predictor_coef_table[predictor_num] -= sign; + + val *= sign; /* neg value */ + + error_val -= ((val >> predictor_quantitization) * + (predictor_coef_num - predictor_num)); + + predictor_num--; + } + } + + buffer_out++; + } + } +} + +void deinterlace_16(int32_t *buffer_a, int32_t *buffer_b, + int16_t *buffer_out, + int numchannels, int numsamples, + uint8_t interlacing_shift, + uint8_t interlacing_leftweight) +{ + int i; + if (numsamples <= 0) return; + + /* weighted interlacing */ + if (interlacing_leftweight) + { + for (i = 0; i < numsamples; i++) + { + int32_t difference, midright; + int16_t left; + int16_t right; + + midright = buffer_a[i]; + difference = buffer_b[i]; + + + right = midright - ((difference * interlacing_leftweight) >> interlacing_shift); + left = right + difference; + + /* output is always little endian */ + if (host_bigendian) + { + _Swap16(left); + _Swap16(right); + } + + buffer_out[i*numchannels] = left; + buffer_out[i*numchannels + 1] = right; + } + + return; + } + + /* otherwise basic interlacing took place */ + for (i = 0; i < numsamples; i++) + { + int16_t left, right; + + left = buffer_a[i]; + right = buffer_b[i]; + + /* output is always little endian */ + if (host_bigendian) + { + _Swap16(left); + _Swap16(right); + } + + buffer_out[i*numchannels] = left; + buffer_out[i*numchannels + 1] = right; + } +} + +void deinterlace_24(int32_t *buffer_a, int32_t *buffer_b, + int uncompressed_bytes, + int32_t *uncompressed_bytes_buffer_a, int32_t *uncompressed_bytes_buffer_b, + void *buffer_out, + int numchannels, int numsamples, + uint8_t interlacing_shift, + uint8_t interlacing_leftweight) +{ + int i; + if (numsamples <= 0) return; + + /* weighted interlacing */ + if (interlacing_leftweight) + { + for (i = 0; i < numsamples; i++) + { + int32_t difference, midright; + int32_t left; + int32_t right; + + midright = buffer_a[i]; + difference = buffer_b[i]; + + right = midright - ((difference * interlacing_leftweight) >> interlacing_shift); + left = right + difference; + + if (uncompressed_bytes) + { + uint32_t mask = ~(0xFFFFFFFF << (uncompressed_bytes * 8)); + left <<= (uncompressed_bytes * 8); + right <<= (uncompressed_bytes * 8); + + left |= uncompressed_bytes_buffer_a[i] & mask; + right |= uncompressed_bytes_buffer_b[i] & mask; + } + + ((uint8_t*)buffer_out)[i * numchannels * 3] = (left) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 1] = (left >> 8) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 2] = (left >> 16) & 0xFF; + + ((uint8_t*)buffer_out)[i * numchannels * 3 + 3] = (right) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 4] = (right >> 8) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 5] = (right >> 16) & 0xFF; + } + + return; + } + + /* otherwise basic interlacing took place */ + for (i = 0; i < numsamples; i++) + { + int32_t left, right; + + left = buffer_a[i]; + right = buffer_b[i]; + + if (uncompressed_bytes) + { + uint32_t mask = ~(0xFFFFFFFF << (uncompressed_bytes * 8)); + left <<= (uncompressed_bytes * 8); + right <<= (uncompressed_bytes * 8); + + left |= uncompressed_bytes_buffer_a[i] & mask; + right |= uncompressed_bytes_buffer_b[i] & mask; + } + + ((uint8_t*)buffer_out)[i * numchannels * 3] = (left) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 1] = (left >> 8) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 2] = (left >> 16) & 0xFF; + + ((uint8_t*)buffer_out)[i * numchannels * 3 + 3] = (right) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 4] = (right >> 8) & 0xFF; + ((uint8_t*)buffer_out)[i * numchannels * 3 + 5] = (right >> 16) & 0xFF; + + } + +} + +void decode_frame(alac_file *alac, + unsigned char *inbuffer, + void *outbuffer, int *outputsize) +{ + int channels; + int32_t outputsamples = alac->setinfo_max_samples_per_frame; + + /* setup the stream */ + alac->input_buffer = inbuffer; + alac->input_buffer_bitaccumulator = 0; + + channels = readbits(alac, 3); + + *outputsize = outputsamples * alac->bytespersample; + + switch(channels) + { + case 0: /* 1 channel */ + { + int hassize; + int isnotcompressed; + int readsamplesize; + + int uncompressed_bytes; + int ricemodifier; + + /* 2^result = something to do with output waiting. + * perhaps matters if we read > 1 frame in a pass? + */ + readbits(alac, 4); + + readbits(alac, 12); /* unknown, skip 12 bits */ + + hassize = readbits(alac, 1); /* the output sample size is stored soon */ + + uncompressed_bytes = readbits(alac, 2); /* number of bytes in the (compressed) stream that are not compressed */ + + isnotcompressed = readbits(alac, 1); /* whether the frame is compressed */ + + if (hassize) + { + /* now read the number of samples, + * as a 32bit integer */ + outputsamples = readbits(alac, 32); + *outputsize = outputsamples * alac->bytespersample; + } + + readsamplesize = alac->setinfo_sample_size - (uncompressed_bytes * 8); + + if (!isnotcompressed) + { /* so it is compressed */ + int16_t predictor_coef_table[32]; + int predictor_coef_num; + int prediction_type; + int prediction_quantitization; + int i; + + /* skip 16 bits, not sure what they are. seem to be used in + * two channel case */ + readbits(alac, 8); + readbits(alac, 8); + + prediction_type = readbits(alac, 4); + prediction_quantitization = readbits(alac, 4); + + ricemodifier = readbits(alac, 3); + predictor_coef_num = readbits(alac, 5); + + /* read the predictor table */ + for (i = 0; i < predictor_coef_num; i++) + { + predictor_coef_table[i] = (int16_t)readbits(alac, 16); + } + + if (uncompressed_bytes) + { + int i; + for (i = 0; i < outputsamples; i++) + { + alac->uncompressed_bytes_buffer_a[i] = readbits(alac, uncompressed_bytes * 8); + } + } + + entropy_rice_decode(alac, + alac->predicterror_buffer_a, + outputsamples, + readsamplesize, + alac->setinfo_rice_initialhistory, + alac->setinfo_rice_kmodifier, + ricemodifier * alac->setinfo_rice_historymult / 4, + (1 << alac->setinfo_rice_kmodifier) - 1); + + if (prediction_type == 0) + { /* adaptive fir */ + predictor_decompress_fir_adapt(alac->predicterror_buffer_a, + alac->outputsamples_buffer_a, + outputsamples, + readsamplesize, + predictor_coef_table, + predictor_coef_num, + prediction_quantitization); + } + else + { + fprintf(stderr, "FIXME: unhandled predicition type: %i\n", prediction_type); + /* i think the only other prediction type (or perhaps this is just a + * boolean?) runs adaptive fir twice.. like: + * predictor_decompress_fir_adapt(predictor_error, tempout, ...) + * predictor_decompress_fir_adapt(predictor_error, outputsamples ...) + * little strange.. + */ + } + + } + else + { /* not compressed, easy case */ + if (alac->setinfo_sample_size <= 16) + { + int i; + for (i = 0; i < outputsamples; i++) + { + int32_t audiobits = readbits(alac, alac->setinfo_sample_size); + + audiobits = SIGN_EXTENDED32(audiobits, alac->setinfo_sample_size); + + alac->outputsamples_buffer_a[i] = audiobits; + } + } + else + { + int i; + for (i = 0; i < outputsamples; i++) + { + int32_t audiobits; + + audiobits = readbits(alac, 16); + /* special case of sign extension.. + * as we'll be ORing the low 16bits into this */ + audiobits = audiobits << (alac->setinfo_sample_size - 16); + audiobits |= readbits(alac, alac->setinfo_sample_size - 16); + audiobits = SignExtend24(audiobits); + + alac->outputsamples_buffer_a[i] = audiobits; + } + } + uncompressed_bytes = 0; // always 0 for uncompressed + } + + switch(alac->setinfo_sample_size) + { + case 16: + { + int i; + for (i = 0; i < outputsamples; i++) + { + int16_t sample = alac->outputsamples_buffer_a[i]; + if (host_bigendian) + _Swap16(sample); + ((int16_t*)outbuffer)[i * alac->numchannels] = sample; + } + break; + } + case 24: + { + int i; + for (i = 0; i < outputsamples; i++) + { + int32_t sample = alac->outputsamples_buffer_a[i]; + + if (uncompressed_bytes) + { + uint32_t mask; + sample = sample << (uncompressed_bytes * 8); + mask = ~(0xFFFFFFFF << (uncompressed_bytes * 8)); + sample |= alac->uncompressed_bytes_buffer_a[i] & mask; + } + + ((uint8_t*)outbuffer)[i * alac->numchannels * 3] = (sample) & 0xFF; + ((uint8_t*)outbuffer)[i * alac->numchannels * 3 + 1] = (sample >> 8) & 0xFF; + ((uint8_t*)outbuffer)[i * alac->numchannels * 3 + 2] = (sample >> 16) & 0xFF; + } + break; + } + case 20: + case 32: + fprintf(stderr, "FIXME: unimplemented sample size %i\n", alac->setinfo_sample_size); + break; + default: + break; + } + break; + } + case 1: /* 2 channels */ + { + int hassize; + int isnotcompressed; + int readsamplesize; + + int uncompressed_bytes; + + uint8_t interlacing_shift; + uint8_t interlacing_leftweight; + + /* 2^result = something to do with output waiting. + * perhaps matters if we read > 1 frame in a pass? + */ + readbits(alac, 4); + + readbits(alac, 12); /* unknown, skip 12 bits */ + + hassize = readbits(alac, 1); /* the output sample size is stored soon */ + + uncompressed_bytes = readbits(alac, 2); /* the number of bytes in the (compressed) stream that are not compressed */ + + isnotcompressed = readbits(alac, 1); /* whether the frame is compressed */ + + if (hassize) + { + /* now read the number of samples, + * as a 32bit integer */ + outputsamples = readbits(alac, 32); + *outputsize = outputsamples * alac->bytespersample; + } + + readsamplesize = alac->setinfo_sample_size - (uncompressed_bytes * 8) + 1; + + if (!isnotcompressed) + { /* compressed */ + int16_t predictor_coef_table_a[32]; + int predictor_coef_num_a; + int prediction_type_a; + int prediction_quantitization_a; + int ricemodifier_a; + + int16_t predictor_coef_table_b[32]; + int predictor_coef_num_b; + int prediction_type_b; + int prediction_quantitization_b; + int ricemodifier_b; + + int i; + + interlacing_shift = readbits(alac, 8); + interlacing_leftweight = readbits(alac, 8); + + /******** channel 1 ***********/ + prediction_type_a = readbits(alac, 4); + prediction_quantitization_a = readbits(alac, 4); + + ricemodifier_a = readbits(alac, 3); + predictor_coef_num_a = readbits(alac, 5); + + /* read the predictor table */ + for (i = 0; i < predictor_coef_num_a; i++) + { + predictor_coef_table_a[i] = (int16_t)readbits(alac, 16); + } + + /******** channel 2 *********/ + prediction_type_b = readbits(alac, 4); + prediction_quantitization_b = readbits(alac, 4); + + ricemodifier_b = readbits(alac, 3); + predictor_coef_num_b = readbits(alac, 5); + + /* read the predictor table */ + for (i = 0; i < predictor_coef_num_b; i++) + { + predictor_coef_table_b[i] = (int16_t)readbits(alac, 16); + } + + /*********************/ + if (uncompressed_bytes) + { /* see mono case */ + int i; + for (i = 0; i < outputsamples; i++) + { + alac->uncompressed_bytes_buffer_a[i] = readbits(alac, uncompressed_bytes * 8); + alac->uncompressed_bytes_buffer_b[i] = readbits(alac, uncompressed_bytes * 8); + } + } + + /* channel 1 */ + entropy_rice_decode(alac, + alac->predicterror_buffer_a, + outputsamples, + readsamplesize, + alac->setinfo_rice_initialhistory, + alac->setinfo_rice_kmodifier, + ricemodifier_a * alac->setinfo_rice_historymult / 4, + (1 << alac->setinfo_rice_kmodifier) - 1); + + if (prediction_type_a == 0) + { /* adaptive fir */ + predictor_decompress_fir_adapt(alac->predicterror_buffer_a, + alac->outputsamples_buffer_a, + outputsamples, + readsamplesize, + predictor_coef_table_a, + predictor_coef_num_a, + prediction_quantitization_a); + } + else + { /* see mono case */ + fprintf(stderr, "FIXME: unhandled predicition type: %i\n", prediction_type_a); + } + + /* channel 2 */ + entropy_rice_decode(alac, + alac->predicterror_buffer_b, + outputsamples, + readsamplesize, + alac->setinfo_rice_initialhistory, + alac->setinfo_rice_kmodifier, + ricemodifier_b * alac->setinfo_rice_historymult / 4, + (1 << alac->setinfo_rice_kmodifier) - 1); + + if (prediction_type_b == 0) + { /* adaptive fir */ + predictor_decompress_fir_adapt(alac->predicterror_buffer_b, + alac->outputsamples_buffer_b, + outputsamples, + readsamplesize, + predictor_coef_table_b, + predictor_coef_num_b, + prediction_quantitization_b); + } + else + { + fprintf(stderr, "FIXME: unhandled predicition type: %i\n", prediction_type_b); + } + } + else + { /* not compressed, easy case */ + if (alac->setinfo_sample_size <= 16) + { + int i; + for (i = 0; i < outputsamples; i++) + { + int32_t audiobits_a, audiobits_b; + + audiobits_a = readbits(alac, alac->setinfo_sample_size); + audiobits_b = readbits(alac, alac->setinfo_sample_size); + + audiobits_a = SIGN_EXTENDED32(audiobits_a, alac->setinfo_sample_size); + audiobits_b = SIGN_EXTENDED32(audiobits_b, alac->setinfo_sample_size); + + alac->outputsamples_buffer_a[i] = audiobits_a; + alac->outputsamples_buffer_b[i] = audiobits_b; + } + } + else + { + int i; + for (i = 0; i < outputsamples; i++) + { + int32_t audiobits_a, audiobits_b; + + audiobits_a = readbits(alac, 16); + audiobits_a = audiobits_a << (alac->setinfo_sample_size - 16); + audiobits_a |= readbits(alac, alac->setinfo_sample_size - 16); + audiobits_a = SignExtend24(audiobits_a); + + audiobits_b = readbits(alac, 16); + audiobits_b = audiobits_b << (alac->setinfo_sample_size - 16); + audiobits_b |= readbits(alac, alac->setinfo_sample_size - 16); + audiobits_b = SignExtend24(audiobits_b); + + alac->outputsamples_buffer_a[i] = audiobits_a; + alac->outputsamples_buffer_b[i] = audiobits_b; + } + } + uncompressed_bytes = 0; // always 0 for uncompressed + interlacing_shift = 0; + interlacing_leftweight = 0; + } + + switch(alac->setinfo_sample_size) + { + case 16: + { + deinterlace_16(alac->outputsamples_buffer_a, + alac->outputsamples_buffer_b, + (int16_t*)outbuffer, + alac->numchannels, + outputsamples, + interlacing_shift, + interlacing_leftweight); + break; + } + case 24: + { + deinterlace_24(alac->outputsamples_buffer_a, + alac->outputsamples_buffer_b, + uncompressed_bytes, + alac->uncompressed_bytes_buffer_a, + alac->uncompressed_bytes_buffer_b, + (int16_t*)outbuffer, + alac->numchannels, + outputsamples, + interlacing_shift, + interlacing_leftweight); + break; + } + case 20: + case 32: + fprintf(stderr, "FIXME: unimplemented sample size %i\n", alac->setinfo_sample_size); + break; + default: + break; + } + + break; + } + } +} + +alac_file *create_alac(int samplesize, int numchannels) +{ + alac_file *newfile = malloc(sizeof(alac_file)); + + newfile->samplesize = samplesize; + newfile->numchannels = numchannels; + newfile->bytespersample = (samplesize / 8) * numchannels; + + return newfile; +} + diff --git a/plugins/alac/alac_plugin.c b/plugins/alac/alac_plugin.c new file mode 100644 index 00000000..fd0d33bb --- /dev/null +++ b/plugins/alac/alac_plugin.c @@ -0,0 +1,617 @@ +/* + ALAC plugin for deadbeef + Copyright (C) 2012 Alexey Yakovenko <waker@users.sourceforge.net> + Uses the reverse engineered ALAC decoder (C) 2005 David Hammerton + All rights reserved. + + Permission is hereby granted, free of charge, to any person + obtaining a copy of this software and associated documentation + files (the "Software"), to deal in the Software without + restriction, including without limitation the rights to use, + copy, modify, merge, publish, distribute, sublicense, and/or + sell copies of the Software, and to permit persons to whom the + Software is furnished to do so, subject to the following conditions: + + The above copyright notice and this permission notice shall be + included in all copies or substantial portions of the Software. + + THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES + OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT + HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, + WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING + FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR + OTHER DEALINGS IN THE SOFTWARE. + */ +#include "../../deadbeef.h" +#ifdef HAVE_CONFIG_H +#include "../../config.h" +#endif +#include <stdlib.h> +#include <string.h> +#include <math.h> +#include "mp4ff.h" +#include "demux.h" +#include "decomp.h" +#include "stream.h" + +#define min(x,y) ((x)<(y)?(x):(y)) +#define max(x,y) ((x)>(y)?(x):(y)) + +#define trace(...) { fprintf(stderr, __VA_ARGS__); } +//#define trace(fmt,...) + +static DB_decoder_t plugin; +DB_functions_t *deadbeef; + +#ifdef WORDS_BIGENDIAN +int host_bigendian = 1; +#else +int host_bigendian = 0; +#endif + +#define BUFFER_SIZE (1024*24) +#define IN_BUFFER_SIZE (1024*80) + +typedef struct { + DB_fileinfo_t info; + DB_FILE *file; + demux_res_t demux_res; + stream_t *stream; + alac_file *alac; + int junk; + char out_buffer[BUFFER_SIZE]; + int out_remaining; + int skipsamples; + int currentsample; + int startsample; + int endsample; + int current_frame; +} alacplug_info_t; + +// allocate codec control structure +static DB_fileinfo_t * +alacplug_open (uint32_t hints) { + DB_fileinfo_t *_info = malloc (sizeof (alacplug_info_t)); + alacplug_info_t *info = (alacplug_info_t *)_info; + memset (info, 0, sizeof (alacplug_info_t)); + return _info; +} + +static uint32_t +alacplug_fs_read (void *user_data, void *buffer, uint32_t length) { + alacplug_info_t *info = user_data; + return deadbeef->fread (buffer, 1, length, info->file); +} + +static uint32_t +alacplug_fs_seek (void *user_data, uint64_t position) { + alacplug_info_t *info = user_data; + return deadbeef->fseek (info->file, position+info->junk, SEEK_SET); +} + +static int +get_sample_info(demux_res_t *demux_res, uint32_t samplenum, + uint32_t *sample_duration, + uint32_t *sample_byte_size) +{ + unsigned int duration_index_accum = 0; + unsigned int duration_cur_index = 0; + + if (samplenum >= demux_res->num_sample_byte_sizes) + { + fprintf(stderr, "sample %i does not exist\n", samplenum); + return 0; + } + + if (!demux_res->num_time_to_samples) + { + fprintf(stderr, "no time to samples\n"); + return 0; + } + while ((demux_res->time_to_sample[duration_cur_index].sample_count + duration_index_accum) + <= samplenum) + { + duration_index_accum += demux_res->time_to_sample[duration_cur_index].sample_count; + duration_cur_index++; + if (duration_cur_index >= demux_res->num_time_to_samples) + { + fprintf(stderr, "sample %i does not have a duration\n", samplenum); + return 0; + } + } + + *sample_duration = demux_res->time_to_sample[duration_cur_index].sample_duration; + *sample_byte_size = demux_res->sample_byte_size[samplenum]; + + return 1; +} + +static int +alacplug_get_totalsamples (demux_res_t *demux_res) { + int totalsamples = 0; + for (int i = 0; i < demux_res->num_sample_byte_sizes; i++) + { + unsigned int thissample_duration = 0; + unsigned int thissample_bytesize = 0; + + get_sample_info(demux_res, i, &thissample_duration, + &thissample_bytesize); + + totalsamples += thissample_duration; + } + return totalsamples; +} + +static int +alacplug_init (DB_fileinfo_t *_info, DB_playItem_t *it) { + alacplug_info_t *info = (alacplug_info_t *)_info; + + deadbeef->pl_lock (); + info->file = deadbeef->fopen (deadbeef->pl_find_meta (it, ":URI")); + deadbeef->pl_unlock (); + if (!info->file) { + return -1; + } + + info->stream = stream_create_file (info->file, 1); + + if (!qtmovie_read(info->stream, &info->demux_res)) { + if (!info->demux_res.format_read || info->demux_res.format != MAKEFOURCC('a','l','a','c')) { + return -1; + } + } + + info->alac = create_alac(info->demux_res.sample_size, info->demux_res.num_channels); + alac_set_info(info->alac, info->demux_res.codecdata); + + int totalsamples = alacplug_get_totalsamples (&info->demux_res); + if (!info->file->vfs->is_streaming ()) { + if (it->endsample > 0) { + info->startsample = it->startsample; + info->endsample = it->endsample; + plugin.seek_sample (_info, 0); + } + else { + info->startsample = 0; + info->endsample = totalsamples-1; + } + } + + _info->plugin = &plugin; + _info->fmt.bps = info->demux_res.sample_size; + _info->fmt.channels = info->demux_res.num_channels; + _info->fmt.samplerate = info->demux_res.sample_rate; + for (int i = 0; i < _info->fmt.channels; i++) { + _info->fmt.channelmask |= 1 << i; + } + + return 0; +} + +static void +alacplug_free (DB_fileinfo_t *_info) { + alacplug_info_t *info = (alacplug_info_t *)_info; + if (info) { + if (info->file) { + deadbeef->fclose (info->file); + } + if (info->stream) { + stream_destroy (info->stream); + } + if (info->alac) { + free (info->alac); + } + free (info); + } +} + +static int +alacplug_read (DB_fileinfo_t *_info, char *bytes, int size) { + alacplug_info_t *info = (alacplug_info_t *)_info; + int samplesize = _info->fmt.channels * _info->fmt.bps / 8; + if (!info->file->vfs->is_streaming ()) { + if (info->currentsample + size / samplesize > info->endsample) { + size = (info->endsample - info->currentsample + 1) * samplesize; + if (size <= 0) { + trace ("alacplug_read: eof (current=%d, total=%d)\n", info->currentsample, info->endsample); + return 0; + } + } + } + int initsize = size; + while (size > 0) { + // handle seeking + if (info->skipsamples > 0 && info->out_remaining > 0) { + int skip = min (info->out_remaining, info->skipsamples); + if (skip < info->out_remaining) { + memmove (info->out_buffer, info->out_buffer + skip * samplesize, (info->out_remaining - skip) * samplesize); + } + info->out_remaining -= skip; + info->skipsamples -= skip; + } + if (info->out_remaining > 0) { + int n = size / samplesize; + n = min (info->out_remaining, n); + + char *src = info->out_buffer; + memcpy (bytes, src, n * samplesize); + bytes += n * samplesize; + src += n * samplesize; + size -= n * samplesize; + + if (n == info->out_remaining) { + info->out_remaining = 0; + } + else { + memmove (info->out_buffer, src, (info->out_remaining - n) * samplesize); + info->out_remaining -= n; + } + continue; + } + + // decode next frame + if (info->current_frame == info->demux_res.num_sample_byte_sizes) { + break; // end of file + } + + uint32_t sample_duration; + uint32_t sample_byte_size; + + int outputBytes; + + /* just get one sample for now */ + if (!get_sample_info(&info->demux_res, info->current_frame, + &sample_duration, &sample_byte_size)) + { + fprintf(stderr, "alac: sample failed\n"); + break; + } + + if (IN_BUFFER_SIZE < sample_byte_size) + { + fprintf(stderr, "alac: buffer too small! (is %i want %i)\n", + IN_BUFFER_SIZE, + sample_byte_size); + break; + } + + char buffer[IN_BUFFER_SIZE]; + stream_read(info->stream, sample_byte_size, buffer); + + outputBytes = BUFFER_SIZE; + decode_frame(info->alac, buffer, info->out_buffer, &outputBytes); + info->current_frame++; + + info->out_remaining += outputBytes / samplesize; + } + + info->currentsample += (initsize-size) / samplesize; + return initsize-size; +} + +static int +alacplug_seek_sample (DB_fileinfo_t *_info, int sample) { + return 0; +#if 0 + alacplug_info_t *info = (alacplug_info_t *)_info; + + sample += info->startsample; + if (info->mp4file) { + int scale = _info->fmt.samplerate / mp4ff_time_scale (info->mp4file, info->mp4track) * info->mp4framesize; + info->mp4sample = sample / scale; + info->skipsamples = sample - info->mp4sample * scale; + } + else { + int skip = deadbeef->junk_get_leading_size (info->file); + if (skip >= 0) { + deadbeef->fseek (info->file, skip, SEEK_SET); + } + else { + deadbeef->fseek (info->file, 0, SEEK_SET); + } + + int res = seek_raw_aac (info, sample); + if (res < 0) { + return -1; + } + info->skipsamples = res; + } + info->remaining = 0; + info->out_remaining = 0; + info->currentsample = sample; + _info->readpos = (float)(info->currentsample - info->startsample) / _info->fmt.samplerate; + return 0; +#endif +} + +static int +alacplug_seek (DB_fileinfo_t *_info, float t) { + return alacplug_seek_sample (_info, t * _info->fmt.samplerate); +} + +static const char *metainfo[] = { + "artist", "artist", + "title", "title", + "album", "album", + "track", "track", + "date", "year", + "genre", "genre", + "comment", "comment", + "performer", "performer", + "album_artist", "band", + "writer", "composer", + "vendor", "vendor", + "disc", "disc", + "compilation", "compilation", + "totaldiscs", "numdiscs", + "copyright", "copyright", + "totaltracks", "numtracks", + "tool", "tool", + NULL +}; + + +/* find a metadata item by name */ +/* returns 0 if item found, 1 if no such item */ +int32_t mp4ff_meta_find_by_name(const mp4ff_t *f, const char *item, char **value); + + +void +alacplug_load_tags (DB_playItem_t *it, mp4ff_t *mp4) { + char *s = NULL; + for (int i = 0; metainfo[i]; i += 2) { + if (mp4ff_meta_find_by_name(mp4, metainfo[i], &s)) { + deadbeef->pl_add_meta (it, metainfo[i+1], s); + free (s); + } + } + if (mp4ff_meta_find_by_name(mp4, "replaygain_track_gain", &s)) { + deadbeef->pl_set_item_replaygain (it, DDB_REPLAYGAIN_TRACKGAIN, atof (s)); + free (s); + } + if (mp4ff_meta_find_by_name(mp4, "replaygain_track_peak", &s)) { + deadbeef->pl_set_item_replaygain (it, DDB_REPLAYGAIN_TRACKPEAK, atof (s)); + free (s); + } + if (mp4ff_meta_find_by_name(mp4, "replaygain_album_gain", &s)) { + deadbeef->pl_set_item_replaygain (it, DDB_REPLAYGAIN_ALBUMGAIN, atof (s)); + free (s); + } + if (mp4ff_meta_find_by_name(mp4, "replaygain_album_peak", &s)) { + deadbeef->pl_set_item_replaygain (it, DDB_REPLAYGAIN_ALBUMPEAK, atof (s)); + free (s); + } +} + +int +alacplug_read_metadata (DB_playItem_t *it) { + deadbeef->pl_lock (); + DB_FILE *fp = deadbeef->fopen (deadbeef->pl_find_meta (it, ":URI")); + deadbeef->pl_unlock (); + if (!fp) { + return -1; + } + + if (fp->vfs->is_streaming ()) { + deadbeef->fclose (fp); + return -1; + } + + alacplug_info_t inf; + memset (&inf, 0, sizeof (inf)); + inf.file = fp; + inf.junk = deadbeef->junk_get_leading_size (fp); + if (inf.junk >= 0) { + deadbeef->fseek (inf.file, inf.junk, SEEK_SET); + } + else { + inf.junk = 0; + } + + mp4ff_callback_t cb = { + .read = alacplug_fs_read, + .write = NULL, + .seek = alacplug_fs_seek, + .truncate = NULL, + .user_data = &inf + }; + + deadbeef->pl_delete_all_meta (it); + + mp4ff_t *mp4 = mp4ff_open_read (&cb); + if (mp4) { + alacplug_load_tags (it, mp4); + mp4ff_close (mp4); + deadbeef->pl_add_meta (it, "title", NULL); + } + /*int apeerr = */deadbeef->junk_apev2_read (it, fp); + /*int v2err = */deadbeef->junk_id3v2_read (it, fp); + /*int v1err = */deadbeef->junk_id3v1_read (it, fp); + deadbeef->pl_add_meta (it, "title", NULL); + deadbeef->fclose (fp); + return 0; +} + +static DB_playItem_t * +alacplug_insert (ddb_playlist_t *plt, DB_playItem_t *after, const char *fname) { + trace ("adding %s\n", fname); + mp4ff_t *mp4 = NULL; + DB_playItem_t *it = NULL; + demux_res_t demux_res; + stream_t *stream; + DB_FILE *fp = deadbeef->fopen (fname); + if (!fp) { + trace ("not found\n"); + return NULL; + } + alacplug_info_t info = {0}; + info.file = fp; + info.junk = deadbeef->junk_get_leading_size (fp); + if (info.junk >= 0) { + trace ("junk: %d\n", info.junk); + deadbeef->fseek (fp, info.junk, SEEK_SET); + } + else { + info.junk = 0; + } + + float duration = -1; + + stream = stream_create_file (fp, 1); + if (!stream) { + trace ("alac: stream_create_file failed\n"); + goto error; + } + + if (!qtmovie_read(stream, &demux_res)) { + if (!demux_res.format_read || demux_res.format != MAKEFOURCC('a','l','a','c')) { + trace ("alac track not found in the file %s\n", fname); + goto error; + } + } + + it = deadbeef->pl_item_alloc_init (fname, plugin.plugin.id); + deadbeef->pl_add_meta (it, ":FILETYPE", "ALAC"); + + int totalsamples = alacplug_get_totalsamples (&demux_res); + duration = totalsamples / (float)demux_res.sample_rate; + + deadbeef->plt_set_item_duration (plt, it, duration); + + // read tags + mp4ff_callback_t cb = { + .read = alacplug_fs_read, + .write = NULL, + .seek = alacplug_fs_seek, + .truncate = NULL, + .user_data = &info + }; + deadbeef->fseek (fp, info.junk, SEEK_SET); + mp4 = mp4ff_open_read (&cb); + if (mp4) { + alacplug_load_tags (it, mp4); + } + + int apeerr = deadbeef->junk_apev2_read (it, fp); + int v2err = deadbeef->junk_id3v2_read (it, fp); + int v1err = deadbeef->junk_id3v1_read (it, fp); + + int64_t fsize = deadbeef->fgetlength (fp); + + deadbeef->fclose (fp); + fp = NULL; + stream_destroy (stream); + stream = NULL; + if (mp4) { + mp4ff_close (mp4); + mp4 = NULL; + } + + if (duration > 0) { + char s[100]; + snprintf (s, sizeof (s), "%lld", fsize); + deadbeef->pl_add_meta (it, ":FILE_SIZE", s); + deadbeef->pl_add_meta (it, ":BPS", "16"); + snprintf (s, sizeof (s), "%d", demux_res.num_channels); + deadbeef->pl_add_meta (it, ":CHANNELS", s); + snprintf (s, sizeof (s), "%d", demux_res.sample_rate); + deadbeef->pl_add_meta (it, ":SAMPLERATE", s); + int br = (int)roundf(fsize / duration * 8 / 1000); + snprintf (s, sizeof (s), "%d", br); + deadbeef->pl_add_meta (it, ":BITRATE", s); + // embedded cue + deadbeef->pl_lock (); + const char *cuesheet = deadbeef->pl_find_meta (it, "cuesheet"); + DB_playItem_t *cue = NULL; + + if (cuesheet) { + cue = deadbeef->plt_insert_cue_from_buffer (plt, after, it, cuesheet, strlen (cuesheet), totalsamples, demux_res.sample_rate); + if (cue) { + deadbeef->pl_item_unref (it); + deadbeef->pl_item_unref (cue); + deadbeef->pl_unlock (); + return cue; + } + } + deadbeef->pl_unlock (); + + cue = deadbeef->plt_insert_cue (plt, after, it, totalsamples, demux_res.sample_rate); + if (cue) { + deadbeef->pl_item_unref (it); + deadbeef->pl_item_unref (cue); + return cue; + } + } + + deadbeef->pl_add_meta (it, "title", NULL); + +success: + after = deadbeef->plt_insert_item (plt, after, it); + deadbeef->pl_item_unref (it); +error: + if (fp) { + deadbeef->fclose (fp); + } + if (mp4) { + mp4ff_close (mp4); + } + return it; +} + +static const char * exts[] = { "mp4", "m4a", NULL }; + +// define plugin interface +static DB_decoder_t plugin = { + .plugin.api_vmajor = 1, + .plugin.api_vminor = 0, + .plugin.version_major = 1, + .plugin.version_minor = 0, + .plugin.type = DB_PLUGIN_DECODER, + .plugin.id = "alac", + .plugin.name = "ALAC player", + .plugin.descr = "plays alac files from MP4 and M4A files", + .plugin.copyright = + "ALAC plugin for deadbeef\n" + "Copyright (C) 2012 Alexey Yakovenko <waker@users.sourceforge.net>\n" + "Uses the reverse engineered ALAC decoder (C) 2005 David Hammerton\n" + "All rights reserved.\n" + "\n" + "Permission is hereby granted, free of charge, to any person\n" + "obtaining a copy of this software and associated documentation\n" + "files (the \"Software\"), to deal in the Software without\n" + "restriction, including without limitation the rights to use,\n" + "copy, modify, merge, publish, distribute, sublicense, and/or\n" + "sell copies of the Software, and to permit persons to whom the\n" + "Software is furnished to do so, subject to the following conditions:\n" + "\n" + "The above copyright notice and this permission notice shall be\n" + "included in all copies or substantial portions of the Software.\n" + "\n" + "THE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\n" + "EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES\n" + "OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\n" + "NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT\n" + "HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,\n" + "WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING\n" + "FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR\n" + "OTHER DEALINGS IN THE SOFTWARE.\n" + , + .plugin.website = "http://deadbeef.sf.net", + .open = alacplug_open, + .init = alacplug_init, + .free = alacplug_free, + .read = alacplug_read, + .seek = alacplug_seek, + .seek_sample = alacplug_seek_sample, + .insert = alacplug_insert, + .read_metadata = alacplug_read_metadata, + .exts = exts, +}; + +DB_plugin_t * +alac_load (DB_functions_t *api) { + deadbeef = api; + return DB_PLUGIN (&plugin); +} diff --git a/plugins/alac/decomp.h b/plugins/alac/decomp.h new file mode 100644 index 00000000..23dbc527 --- /dev/null +++ b/plugins/alac/decomp.h @@ -0,0 +1,13 @@ +#ifndef __ALAC__DECOMP_H +#define __ALAC__DECOMP_H + +typedef struct alac_file alac_file; + +alac_file *create_alac(int samplesize, int numchannels); +void decode_frame(alac_file *alac, + unsigned char *inbuffer, + void *outbuffer, int *outputsize); +void alac_set_info(alac_file *alac, char *inputbuffer); + +#endif /* __ALAC__DECOMP_H */ + diff --git a/plugins/alac/demux.c b/plugins/alac/demux.c new file mode 100644 index 00000000..ae77a9dd --- /dev/null +++ b/plugins/alac/demux.c @@ -0,0 +1,730 @@ +/* + * ALAC (Apple Lossless Audio Codec) decoder + * Copyright (c) 2005 David Hammerton + * All rights reserved. + * + * This is the quicktime container demuxer. + * + * http://crazney.net/programs/itunes/alac.html + * + * Permission is hereby granted, free of charge, to any person + * obtaining a copy of this software and associated documentation + * files (the "Software"), to deal in the Software without + * restriction, including without limitation the rights to use, + * copy, modify, merge, publish, distribute, sublicense, and/or + * sell copies of the Software, and to permit persons to whom the + * Software is furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be + * included in all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES + * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT + * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, + * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING + * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR + * OTHER DEALINGS IN THE SOFTWARE. + * + */ + + +#include <string.h> +#include <stdio.h> +#include <stdlib.h> +#ifdef _WIN32 + #include "stdint_win.h" +#else + #include <stdint.h> +#endif + +#include "stream.h" +#include "demux.h" + +typedef struct +{ + stream_t *stream; + demux_res_t *res; + long saved_mdat_pos; +} qtmovie_t; + + +/* chunk handlers */ +static void read_chunk_ftyp(qtmovie_t *qtmovie, size_t chunk_len) +{ + fourcc_t type; + uint32_t minor_ver; + size_t size_remaining = chunk_len - 8; /* FIXME: can't hardcode 8, size may be 64bit */ + + type = stream_read_uint32(qtmovie->stream); + size_remaining-=4; + if (type != MAKEFOURCC('M','4','A',' ')) + { + fprintf(stderr, "not M4A file\n"); + return; + } + minor_ver = stream_read_uint32(qtmovie->stream); + size_remaining-=4; + + /* compatible brands */ + while (size_remaining) + { + /* unused */ + /*fourcc_t cbrand =*/ stream_read_uint32(qtmovie->stream); + size_remaining-=4; + } +} + +static void read_chunk_tkhd(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +static void read_chunk_mdhd(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +static void read_chunk_edts(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +static void read_chunk_elst(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +/* media handler inside mdia */ +static void read_chunk_hdlr(qtmovie_t *qtmovie, size_t chunk_len) +{ + fourcc_t comptype, compsubtype; + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + int strlen; + char str[256] = {0}; + + /* version */ + stream_read_uint8(qtmovie->stream); + size_remaining -= 1; + /* flags */ + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + size_remaining -= 3; + + /* component type */ + comptype = stream_read_uint32(qtmovie->stream); + compsubtype = stream_read_uint32(qtmovie->stream); + size_remaining -= 8; + + /* component manufacturer */ + stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + + /* flags */ + stream_read_uint32(qtmovie->stream); + stream_read_uint32(qtmovie->stream); + size_remaining -= 8; + + /* name */ + strlen = stream_read_uint8(qtmovie->stream); + stream_read(qtmovie->stream, strlen, str); + size_remaining -= 1 + strlen; + + if (size_remaining) + { + stream_skip(qtmovie->stream, size_remaining); + } + +} + +static int read_chunk_stsd(qtmovie_t *qtmovie, size_t chunk_len) +{ + unsigned int i; + uint32_t numentries; + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + /* version */ + stream_read_uint8(qtmovie->stream); + size_remaining -= 1; + /* flags */ + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + size_remaining -= 3; + + numentries = stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + + if (numentries != 1) + { + fprintf(stderr, "only expecting one entry in sample description atom!\n"); + return 0; + } + + for (i = 0; i < numentries; i++) + { + uint32_t entry_size; + uint16_t version; + + uint32_t entry_remaining; + + entry_size = stream_read_uint32(qtmovie->stream); + qtmovie->res->format = stream_read_uint32(qtmovie->stream); + entry_remaining = entry_size; + entry_remaining -= 8; + + /* sound info: */ + + stream_skip(qtmovie->stream, 6); /* reserved */ + entry_remaining -= 6; + + version = stream_read_uint16(qtmovie->stream); + if (version != 1) + fprintf(stderr, "unknown version??\n"); + entry_remaining -= 2; + + /* revision level */ + stream_read_uint16(qtmovie->stream); + /* vendor */ + stream_read_uint32(qtmovie->stream); + entry_remaining -= 6; + + /* EH?? spec doesn't say theres an extra 16 bits here.. but there is! */ + stream_read_uint16(qtmovie->stream); + entry_remaining -= 2; + + qtmovie->res->num_channels = stream_read_uint16(qtmovie->stream); + + qtmovie->res->sample_size = stream_read_uint16(qtmovie->stream); + entry_remaining -= 4; + + /* compression id */ + stream_read_uint16(qtmovie->stream); + /* packet size */ + stream_read_uint16(qtmovie->stream); + entry_remaining -= 4; + + /* sample rate - 32bit fixed point = 16bit?? */ + qtmovie->res->sample_rate = stream_read_uint16(qtmovie->stream); + entry_remaining -= 2; + + /* skip 2 */ + stream_skip(qtmovie->stream, 2); + entry_remaining -= 2; + + /* remaining is codec data */ + +#if 0 + qtmovie->res->codecdata_len = stream_read_uint32(qtmovie->stream); + if (qtmovie->res->codecdata_len != entry_remaining) + fprintf(stderr, "perhaps not? %i vs %i\n", + qtmovie->res->codecdata_len, entry_remaining); + entry_remaining -= 4; + stream_read_uint32(qtmovie->stream); /* 'alac' */ + entry_remaining -= 4; + + qtmovie->res->codecdata = malloc(qtmovie->res->codecdata_len - 8); + + stream_read(qtmovie->stream, + entry_remaining, + qtmovie->res->codecdata); + entry_remaining = 0; + +#else + /* 12 = audio format atom, 8 = padding */ + qtmovie->res->codecdata_len = entry_remaining + 12 + 8; + qtmovie->res->codecdata = malloc(qtmovie->res->codecdata_len); + memset(qtmovie->res->codecdata, 0, qtmovie->res->codecdata_len); + /* audio format atom */ + ((unsigned int*)qtmovie->res->codecdata)[0] = 0x0c000000; + ((unsigned int*)qtmovie->res->codecdata)[1] = MAKEFOURCC('a','m','r','f'); + ((unsigned int*)qtmovie->res->codecdata)[2] = MAKEFOURCC('c','a','l','a'); + + stream_read(qtmovie->stream, + entry_remaining, + ((char*)qtmovie->res->codecdata) + 12); + entry_remaining -= entry_remaining; + +#endif + if (entry_remaining) + stream_skip(qtmovie->stream, entry_remaining); + + qtmovie->res->format_read = 1; + if (qtmovie->res->format != MAKEFOURCC('a','l','a','c')) + { + /*fprintf(stderr, "expecting 'alac' data format, got %c%c%c%c\n", + SPLITFOURCC(qtmovie->res->format));*/ + return 0; + } + } + + return 1; +} + +static void read_chunk_stts(qtmovie_t *qtmovie, size_t chunk_len) +{ + unsigned int i; + uint32_t numentries; + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + /* version */ + stream_read_uint8(qtmovie->stream); + size_remaining -= 1; + /* flags */ + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + size_remaining -= 3; + + numentries = stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + + qtmovie->res->num_time_to_samples = numentries; + qtmovie->res->time_to_sample = malloc(numentries * sizeof(*qtmovie->res->time_to_sample)); + + for (i = 0; i < numentries; i++) + { + qtmovie->res->time_to_sample[i].sample_count = stream_read_uint32(qtmovie->stream); + qtmovie->res->time_to_sample[i].sample_duration = stream_read_uint32(qtmovie->stream); + size_remaining -= 8; + } + + if (size_remaining) + { + fprintf(stderr, "ehm, size remianing?\n"); + stream_skip(qtmovie->stream, size_remaining); + } +} + +static void read_chunk_stsz(qtmovie_t *qtmovie, size_t chunk_len) +{ + unsigned int i; + uint32_t numentries; + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + /* version */ + stream_read_uint8(qtmovie->stream); + size_remaining -= 1; + /* flags */ + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + stream_read_uint8(qtmovie->stream); + size_remaining -= 3; + + /* default sample size */ + if (stream_read_uint32(qtmovie->stream) != 0) + { + fprintf(stderr, "i was expecting variable samples sizes\n"); + stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + return; + } + size_remaining -= 4; + + numentries = stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + + qtmovie->res->num_sample_byte_sizes = numentries; + qtmovie->res->sample_byte_size = malloc(numentries * sizeof(*qtmovie->res->sample_byte_size)); + + for (i = 0; i < numentries; i++) + { + qtmovie->res->sample_byte_size[i] = stream_read_uint32(qtmovie->stream); + size_remaining -= 4; + } + + if (size_remaining) + { + fprintf(stderr, "ehm, size remianing?\n"); + stream_skip(qtmovie->stream, size_remaining); + } +} + +static int read_chunk_stbl(qtmovie_t *qtmovie, size_t chunk_len) +{ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + while (size_remaining) + { + size_t sub_chunk_len; + fourcc_t sub_chunk_id; + + sub_chunk_len = stream_read_uint32(qtmovie->stream); + if (sub_chunk_len <= 1 || sub_chunk_len > size_remaining) + { + fprintf(stderr, "strange size for chunk inside stbl (%lu) (remaining: %lu)\n", + sub_chunk_len, size_remaining); + return 0; + } + + sub_chunk_id = stream_read_uint32(qtmovie->stream); + + switch (sub_chunk_id) + { + case MAKEFOURCC('s','t','s','d'): + if (read_chunk_stsd(qtmovie, sub_chunk_len) == 0) + return 0; + break; + case MAKEFOURCC('s','t','t','s'): + read_chunk_stts(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('s','t','s','z'): + read_chunk_stsz(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('s','t','s','c'): + case MAKEFOURCC('s','t','c','o'): + /* skip these, no indexing for us! */ + stream_skip(qtmovie->stream, sub_chunk_len - 8); + break; + default: + fprintf(stderr, "(stbl) unknown chunk id: %c%c%c%c\n", + SPLITFOURCC(sub_chunk_id)); + return 0; + } + + size_remaining -= sub_chunk_len; + } + + return 1; +} + +static int read_chunk_minf(qtmovie_t *qtmovie, size_t chunk_len) +{ + size_t dinf_size, stbl_size; + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + /**** SOUND HEADER CHUNK ****/ + if (stream_read_uint32(qtmovie->stream) != 16) + { + fprintf(stderr, "unexpected size in media info\n"); + return 0; + } + if (stream_read_uint32(qtmovie->stream) != MAKEFOURCC('s','m','h','d')) + { + fprintf(stderr, "not a sound header! can't handle this.\n"); + return 0; + } + /* now skip the rest */ + stream_skip(qtmovie->stream, 16 - 8); + size_remaining -= 16; + /****/ + + /**** DINF CHUNK ****/ + dinf_size = stream_read_uint32(qtmovie->stream); + if (stream_read_uint32(qtmovie->stream) != MAKEFOURCC('d','i','n','f')) + { + fprintf(stderr, "expected dinf, didn't get it.\n"); + return 0; + } + /* skip it */ + stream_skip(qtmovie->stream, dinf_size - 8); + size_remaining -= dinf_size; + /****/ + + + /**** SAMPLE TABLE ****/ + stbl_size = stream_read_uint32(qtmovie->stream); + if (stream_read_uint32(qtmovie->stream) != MAKEFOURCC('s','t','b','l')) + { + fprintf(stderr, "expected stbl, didn't get it.\n"); + return 0; + } + if (read_chunk_stbl(qtmovie, stbl_size) == 0) + return 0; + size_remaining -= stbl_size; + + if (size_remaining) + { + fprintf(stderr, "oops\n"); + stream_skip(qtmovie->stream, size_remaining); + } + + return 1; +} + +static int read_chunk_mdia(qtmovie_t *qtmovie, size_t chunk_len) +{ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + while (size_remaining) + { + size_t sub_chunk_len; + fourcc_t sub_chunk_id; + + sub_chunk_len = stream_read_uint32(qtmovie->stream); + if (sub_chunk_len <= 1 || sub_chunk_len > size_remaining) + { + fprintf(stderr, "strange size for chunk inside mdia\n"); + return 0; + } + + sub_chunk_id = stream_read_uint32(qtmovie->stream); + + switch (sub_chunk_id) + { + case MAKEFOURCC('m','d','h','d'): + read_chunk_mdhd(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('h','d','l','r'): + read_chunk_hdlr(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('m','i','n','f'): + if (read_chunk_minf(qtmovie, sub_chunk_len) == 0) + return 0; + break; + default: + fprintf(stderr, "(mdia) unknown chunk id: %c%c%c%c\n", + SPLITFOURCC(sub_chunk_id)); + return 0; + } + + size_remaining -= sub_chunk_len; + } + + return 1; +} + +/* 'trak' - a movie track - contains other atoms */ +static int read_chunk_trak(qtmovie_t *qtmovie, size_t chunk_len) +{ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + while (size_remaining) + { + size_t sub_chunk_len; + fourcc_t sub_chunk_id; + + sub_chunk_len = stream_read_uint32(qtmovie->stream); + if (sub_chunk_len <= 1 || sub_chunk_len > size_remaining) + { + fprintf(stderr, "strange size for chunk inside trak\n"); + return 0; + } + + sub_chunk_id = stream_read_uint32(qtmovie->stream); + + switch (sub_chunk_id) + { + case MAKEFOURCC('t','k','h','d'): + read_chunk_tkhd(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('m','d','i','a'): + if (read_chunk_mdia(qtmovie, sub_chunk_len) == 0) + return 0; + break; + case MAKEFOURCC('e','d','t','s'): + read_chunk_edts(qtmovie, sub_chunk_len); + break; + default: + fprintf(stderr, "(trak) unknown chunk id: %c%c%c%c\n", + SPLITFOURCC(sub_chunk_id)); + return 0; + } + + size_remaining -= sub_chunk_len; + } + + return 1; +} + +/* 'mvhd' movie header atom */ +static void read_chunk_mvhd(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +/* 'udta' user data.. contains tag info */ +static void read_chunk_udta(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +/* 'iods' */ +static void read_chunk_iods(qtmovie_t *qtmovie, size_t chunk_len) +{ + /* don't need anything from here atm, skip */ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + stream_skip(qtmovie->stream, size_remaining); +} + +/* 'moov' movie atom - contains other atoms */ +static int read_chunk_moov(qtmovie_t *qtmovie, size_t chunk_len) +{ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + while (size_remaining) + { + size_t sub_chunk_len; + fourcc_t sub_chunk_id; + + sub_chunk_len = stream_read_uint32(qtmovie->stream); + if (sub_chunk_len <= 1 || sub_chunk_len > size_remaining) + { + fprintf(stderr, "strange size for chunk inside moov\n"); + return 0; + } + + sub_chunk_id = stream_read_uint32(qtmovie->stream); + + switch (sub_chunk_id) + { + case MAKEFOURCC('m','v','h','d'): + read_chunk_mvhd(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('t','r','a','k'): + if (read_chunk_trak(qtmovie, sub_chunk_len) == 0) + return 0; + break; + case MAKEFOURCC('u','d','t','a'): + read_chunk_udta(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('e','l','s','t'): + read_chunk_elst(qtmovie, sub_chunk_len); + break; + case MAKEFOURCC('i','o','d','s'): + read_chunk_iods(qtmovie, sub_chunk_len); + break; + default: + fprintf(stderr, "(moov) unknown chunk id: %c%c%c%c\n", + SPLITFOURCC(sub_chunk_id)); + return 0; + } + + size_remaining -= sub_chunk_len; + } + + return 1; +} + +static void read_chunk_mdat(qtmovie_t *qtmovie, size_t chunk_len, int skip_mdat) +{ + size_t size_remaining = chunk_len - 8; /* FIXME WRONG */ + + if (size_remaining == 0) return; + + qtmovie->res->mdat_len = (uint32_t)size_remaining; + if (skip_mdat) + { + qtmovie->saved_mdat_pos = stream_tell(qtmovie->stream); + stream_skip(qtmovie->stream, size_remaining); + } +#if 0 + qtmovie->res->mdat = malloc(size_remaining); + + stream_read(qtmovie->stream, size_remaining, qtmovie->res->mdat); +#endif +} + +static int set_saved_mdat(qtmovie_t *qtmovie) +{ + if (qtmovie->saved_mdat_pos == -1) + { + fprintf(stderr, "stream contains mdat before moov but is not seekable\n"); + return 0; + } + + if (stream_setpos(qtmovie->stream, qtmovie->saved_mdat_pos)) + { + fprintf(stderr, "error while seeking stream to mdat pos\n"); + return 0; + } + + return 1; +} + +int qtmovie_read(stream_t *file, demux_res_t *demux_res) +{ + int found_moov = 0; + int found_mdat = 0; + qtmovie_t *qtmovie; + + qtmovie = (qtmovie_t*)malloc(sizeof(qtmovie_t)); + + /* construct the stream */ + qtmovie->stream = file; + + qtmovie->res = demux_res; + + memset(demux_res, 0, sizeof(demux_res_t)); + + /* read the chunks */ + while (1) + { + size_t chunk_len; + fourcc_t chunk_id; + + chunk_len = stream_read_uint32(qtmovie->stream); + if (stream_eof(qtmovie->stream)) + { + return 0; + } + + if (chunk_len == 1) + { + fprintf(stderr, "need 64bit support\n"); + return 0; + } + chunk_id = stream_read_uint32(qtmovie->stream); + + switch (chunk_id) + { + case MAKEFOURCC('f','t','y','p'): + read_chunk_ftyp(qtmovie, chunk_len); + break; + case MAKEFOURCC('m','o','o','v'): + if (read_chunk_moov(qtmovie, chunk_len) == 0) + return 0; /* failed to read moov, can't do anything */ + if (found_mdat) + { + return set_saved_mdat(qtmovie); + } + found_moov = 1; + break; + /* if we hit mdat before we've found moov, record the position + * and move on. We can then come back to mdat later. + * This presumes the stream supports seeking backwards. + */ + case MAKEFOURCC('m','d','a','t'): + read_chunk_mdat(qtmovie, chunk_len, !found_moov); + if (found_moov) + return 1; + found_mdat = 1; + break; + + /* these following atoms can be skipped !!!! */ + case MAKEFOURCC('f','r','e','e'): + stream_skip(qtmovie->stream, chunk_len - 8); /* FIXME not 8 */ + break; + default: + fprintf(stderr, "(top) unknown chunk id: %c%c%c%c\n", + SPLITFOURCC(chunk_id)); + return 0; + } + + } + return 0; +} + + diff --git a/plugins/alac/demux.h b/plugins/alac/demux.h new file mode 100644 index 00000000..8447bf84 --- /dev/null +++ b/plugins/alac/demux.h @@ -0,0 +1,62 @@ +#ifndef DEMUX_H +#define DEMUX_H + +#ifdef _WIN32 + #include "stdint_win.h" +#else + #include <stdint.h> +#endif + +#include "stream.h" + +typedef uint32_t fourcc_t; + +typedef struct +{ + int format_read; + + uint16_t num_channels; + uint16_t sample_size; + uint32_t sample_rate; + fourcc_t format; + void *buf; + + struct { + uint32_t sample_count; + uint32_t sample_duration; + } *time_to_sample; + uint32_t num_time_to_samples; + + uint32_t *sample_byte_size; + uint32_t num_sample_byte_sizes; + + uint32_t codecdata_len; + void *codecdata; + + uint32_t mdat_len; +#if 0 + void *mdat; +#endif +} demux_res_t; + +int qtmovie_read(stream_t *stream, demux_res_t *demux_res); + +#ifndef MAKEFOURCC +#define MAKEFOURCC(ch0, ch1, ch2, ch3) ( \ + ( (int32_t)(char)(ch0) << 24 ) | \ + ( (int32_t)(char)(ch1) << 16 ) | \ + ( (int32_t)(char)(ch2) << 8 ) | \ + ( (int32_t)(char)(ch3) ) ) +#endif + +#ifndef SLPITFOURCC +/* splits it into ch0, ch1, ch2, ch3 - use for printf's */ +#define SPLITFOURCC(code) \ + (char)((int32_t)code >> 24), \ + (char)((int32_t)code >> 16), \ + (char)((int32_t)code >> 8), \ + (char)code +#endif + +#endif /* DEMUX_H */ + diff --git a/plugins/alac/stdint_win.h b/plugins/alac/stdint_win.h new file mode 100644 index 00000000..a580eb7f --- /dev/null +++ b/plugins/alac/stdint_win.h @@ -0,0 +1,14 @@ +
+#ifndef ALAC_STDINT_WIN_H__
+#define ALAC_STDINT_WIN_H__
+
+typedef signed char int8_t;
+typedef signed short int16_t;
+typedef signed int int32_t;
+typedef signed __int64 int64_t;
+typedef unsigned char uint8_t;
+typedef unsigned short uint16_t;
+typedef unsigned int uint32_t;
+typedef unsigned __int64 uint64_t;
+
+#endif // ALAC_STDINT_WIN_H__
\ No newline at end of file diff --git a/plugins/alac/stream.c b/plugins/alac/stream.c new file mode 100644 index 00000000..4976a539 --- /dev/null +++ b/plugins/alac/stream.c @@ -0,0 +1,179 @@ +/* + * ALAC (Apple Lossless Audio Codec) decoder + * Copyright (c) 2005 David Hammerton + * All rights reserved. + * + * Basic stream reading + * + * http://crazney.net/programs/itunes/alac.html + * + * Permission is hereby granted, free of charge, to any person + * obtaining a copy of this software and associated documentation + * files (the "Software"), to deal in the Software without + * restriction, including without limitation the rights to use, + * copy, modify, merge, publish, distribute, sublicense, and/or + * sell copies of the Software, and to permit persons to whom the + * Software is furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be + * included in all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES + * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT + * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, + * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING + * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR + * OTHER DEALINGS IN THE SOFTWARE. + * + */ + + +#include <stdlib.h> +#include <errno.h> +#ifdef _WIN32 + #include "stdint_win.h" +#else + #include <stdint.h> +#endif + +#include "stream.h" + +extern DB_functions_t *deadbeef; + +#define _Swap32(v) do { \ + v = (((v) & 0x000000FF) << 0x18) | \ + (((v) & 0x0000FF00) << 0x08) | \ + (((v) & 0x00FF0000) >> 0x08) | \ + (((v) & 0xFF000000) >> 0x18); } while(0) + +#define _Swap16(v) do { \ + v = (((v) & 0x00FF) << 0x08) | \ + (((v) & 0xFF00) >> 0x08); } while (0) + +extern int host_bigendian; + +struct stream_tTAG { + DB_FILE *f; + int bigendian; + int eof; +}; + +void stream_read(stream_t *stream, size_t size, void *buf) +{ + size_t ret; + + ret = deadbeef->fread(buf, 4, size >> 2, stream->f) * 4; + ret += deadbeef->fread((char*)buf + ret, 1, size - ret, stream->f); + + if (ret == 0 && size != 0) stream->eof = 1; +} + +int32_t stream_read_int32(stream_t *stream) +{ + int32_t v; + stream_read(stream, 4, &v); + if ((stream->bigendian && !host_bigendian) || + (!stream->bigendian && host_bigendian)) + { + _Swap32(v); + } + return v; +} + +uint32_t stream_read_uint32(stream_t *stream) +{ + uint32_t v; + stream_read(stream, 4, &v); + if ((stream->bigendian && !host_bigendian) || + (!stream->bigendian && host_bigendian)) + { + _Swap32(v); + } + return v; +} + +int16_t stream_read_int16(stream_t *stream) +{ + int16_t v; + stream_read(stream, 2, &v); + if ((stream->bigendian && !host_bigendian) || + (!stream->bigendian && host_bigendian)) + { + _Swap16(v); + } + return v; +} + +uint16_t stream_read_uint16(stream_t *stream) +{ + uint16_t v; + stream_read(stream, 2, &v); + if ((stream->bigendian && !host_bigendian) || + (!stream->bigendian && host_bigendian)) + { + _Swap16(v); + } + return v; +} + +int8_t stream_read_int8(stream_t *stream) +{ + int8_t v; + stream_read(stream, 1, &v); + return v; +} + +uint8_t stream_read_uint8(stream_t *stream) +{ + uint8_t v; + stream_read(stream, 1, &v); + return v; +} + + +void stream_skip(stream_t *stream, size_t skip) +{ + if (deadbeef->fseek(stream->f, (long)skip, SEEK_CUR) == 0) return; + if (errno == ESPIPE) + { + char *buffer = malloc(skip); + stream_read(stream, skip, buffer); + free(buffer); + } +} + +int stream_eof(stream_t *stream) +{ + return stream->eof; +} + +long stream_tell(stream_t *stream) +{ + return deadbeef->ftell(stream->f); /* returns -1 on error */ +} + +int stream_setpos(stream_t *stream, long pos) +{ + return deadbeef->fseek(stream->f, pos, SEEK_SET); +} + +stream_t *stream_create_file(DB_FILE *file, + int bigendian) +{ + stream_t *new_stream; + + new_stream = (stream_t*)malloc(sizeof(stream_t)); + new_stream->f = file; + new_stream->bigendian = bigendian; + new_stream->eof = 0; + + return new_stream; +} + +void stream_destroy(stream_t *stream) +{ + free(stream); +} + diff --git a/plugins/alac/stream.h b/plugins/alac/stream.h new file mode 100644 index 00000000..ae5881e4 --- /dev/null +++ b/plugins/alac/stream.h @@ -0,0 +1,39 @@ +#ifndef STREAM_H +#define STREAM_H + +/* stream.h */ + +#ifdef _WIN32 + #include "stdint_win.h" +#else + #include <stdint.h> +#endif + +#include "../../deadbeef.h" + +typedef struct stream_tTAG stream_t; + +void stream_read(stream_t *stream, size_t len, void *buf); + +int32_t stream_read_int32(stream_t *stream); +uint32_t stream_read_uint32(stream_t *stream); + +int16_t stream_read_int16(stream_t *stream); +uint16_t stream_read_uint16(stream_t *stream); + +int8_t stream_read_int8(stream_t *stream); +uint8_t stream_read_uint8(stream_t *stream); + +void stream_skip(stream_t *stream, size_t skip); + +int stream_eof(stream_t *stream); + +long stream_tell(stream_t *stream); +int stream_setpos(stream_t *stream, long pos); + +stream_t *stream_create_file(DB_FILE *file, + int bigendian); +void stream_destroy(stream_t *stream); + +#endif /* STREAM_H */ + diff --git a/scripts/quickinstall.sh b/scripts/quickinstall.sh index 7fd71958..ca09088b 100755 --- a/scripts/quickinstall.sh +++ b/scripts/quickinstall.sh @@ -46,3 +46,4 @@ cp ./plugins/converter/.libs/converter_gtk3.so /usr/local/lib/deadbeef/ cp ./plugins/soundtouch/ddb_soundtouch.so /usr/local/lib/deadbeef/ cp ./plugins/vfs_zip/.libs/vfs_zip.so /usr/local/lib/deadbeef/ cp ./plugins/mono2stereo/.libs/ddb_mono2stereo.so /usr/local/lib/deadbeef/ +cp ./plugins/alac/.libs/alac.so /usr/local/lib/deadbeef/ |