diff options
Diffstat (limited to 'src/demuxers')
| -rw-r--r-- | src/demuxers/Makefile.am | 3 | ||||
| -rw-r--r-- | src/demuxers/demux_mpc.c | 385 | ||||
| -rw-r--r-- | src/demuxers/group_audio.c | 7 | ||||
| -rw-r--r-- | src/demuxers/group_audio.h | 3 |
4 files changed, 395 insertions, 3 deletions
diff --git a/src/demuxers/Makefile.am b/src/demuxers/Makefile.am index 3fc0accec..eff9538b2 100644 --- a/src/demuxers/Makefile.am +++ b/src/demuxers/Makefile.am @@ -121,7 +121,8 @@ xineplug_dmx_audio_la_SOURCES = group_audio.c demux_aud.c demux_aiff.c \ demux_cdda.c demux_mpgaudio.c demux_nsf.c \ demux_realaudio.c demux_snd.c demux_voc.c \ demux_vox.c demux_wav.c demux_ac3.c id3.c \ - demux_aac.c demux_mod.c demux_flac.c + demux_aac.c demux_mod.c demux_flac.c \ + demux_mpc.c xineplug_dmx_audio_la_LIBADD = $(XINE_LIB) $(LIBMODPLUG_LIBS) xineplug_dmx_audio_la_LDFLAGS = -avoid-version -module @XINE_PLUGIN_MIN_SYMS@ diff --git a/src/demuxers/demux_mpc.c b/src/demuxers/demux_mpc.c new file mode 100644 index 000000000..60d651411 --- /dev/null +++ b/src/demuxers/demux_mpc.c @@ -0,0 +1,385 @@ +/* + * Copyright (C) 2005 the xine project + * + * This file is part of xine, a free video player. + * + * xine 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. + * + * xine 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-1307, USA + * + * Musepack demuxer by James Stembridge <jstembridge@gmail.com> + * + * TODO: + * ID3 tag reading + * APE tag reading + * Seeking?? + * + * $Id: + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include <stdio.h> +#include <fcntl.h> +#include <unistd.h> +#include <string.h> +#include <stdlib.h> + +#define LOG_MODULE "demux_mpc" +#define LOG_VERBOSE +/* +#define LOG +*/ + +#include "xine_internal.h" +#include "xineutils.h" +#include "demux.h" +#include "buffer.h" +#include "bswap.h" +#include "group_audio.h" + +/* Note that the header is actually 25 bytes long, so we'd only read 28 + * (because of byte swapping we have to round up to nearest multiple of 4) + * if it weren't for libmusepack reading 32 bytes when it parses the header */ +#define HEADER_SIZE 32 + +typedef struct { + demux_plugin_t demux_plugin; + + xine_stream_t *stream; + fifo_buffer_t *audio_fifo; + input_plugin_t *input; + int status; + + unsigned char header[HEADER_SIZE]; + unsigned int frames; + double samplerate; + unsigned int length; + + unsigned int current_frame; + unsigned int next_frame_bits; +} demux_mpc_t; + +typedef struct { + demux_class_t demux_class; +} demux_mpc_class_t; + + +/* Open a musepack file + * This function is called from the _open() function of this demuxer. + * It returns 1 if the musepack file was opened successfully. */ +static int open_mpc_file(demux_mpc_t *this) { + unsigned char preamble[4]; + unsigned int first_frame_size; + + /* Fetch the file signature */ + if (_x_demux_read_header(this->input, preamble, 4) != 4) + return 0; + + /* Validate signature - We only support SV7 at the moment */ + if ((preamble[0] != 'M') || + (preamble[1] != 'P') || + (preamble[2] != '+') || + (preamble[3] != 0x07)) + return 0; + + /* Read header */ + if (_x_demux_read_header(this->input, this->header, HEADER_SIZE) != HEADER_SIZE) + return 0; + + /* Get frame count */ + this->current_frame = 0; + this->frames = LE_32(&this->header[4]); + lprintf("number of frames: %u\n", this->frames); + + /* Get sample rate */ + switch ((LE_32(&this->header[8]) >> 16) & 0x3) { + case 0: + this->samplerate = 44.1; + break; + case 1: + this->samplerate = 48.0; + break; + case 2: + this->samplerate = 37.8; + break; + case 3: + this->samplerate = 32.0; + break; + default: + break; + } + lprintf("samplerate: %f kHz\n", this->samplerate); + + /* Calculate stream length */ + this->length = (int) ((double) this->frames * 1152 / this->samplerate); + lprintf("stream length: %d ms\n", this->length); + + /* Calculate the number of bits of the first frame that are still be sent */ + first_frame_size = (LE_32(&this->header[24]) >> 4) & 0xFFFFF; + this->next_frame_bits = first_frame_size - 4; + lprintf("first frame size: %u\n", first_frame_size); + + /* Move input to start of data (to nearest multiple of 4) */ + this->input->seek(this->input, 28, SEEK_SET); + + /* Set stream info */ + _x_stream_info_set(this->stream, XINE_STREAM_INFO_HAS_AUDIO, 1); + _x_stream_info_set(this->stream, XINE_STREAM_INFO_AUDIO_FOURCC, ME_32(preamble)); + + return 1; +} + +static int demux_mpc_send_chunk(demux_plugin_t *this_gen) { + demux_mpc_t *this = (demux_mpc_t *) this_gen; + unsigned int bits_to_read, bytes_to_read, extra_bits_read, next_frame_size; + off_t bytes_read; + + buf_element_t *buf = NULL; + + /* Check if we've finished */ + if (this->current_frame++ == this->frames) { + lprintf("all frames read\n"); + this->status = DEMUX_FINISHED; + return this->status; + } + lprintf("current frame: %u\n", this->current_frame); + + /* Get a buffer */ + buf = this->audio_fifo->buffer_pool_alloc (this->audio_fifo); + buf->type = BUF_AUDIO_MPC; + buf->pts = 0; + buf->extra_info->total_time = this->length; + + /* Set normalised position */ + buf->extra_info->input_normpos = + (int) ((double) this->input->get_current_pos(this->input) * 65535 / + this->input->get_length(this->input)); + + /* Set time based on there being 1152 audio frames per frame */ + buf->extra_info->input_time = + (int) ((double) this->current_frame * 1152 / this->samplerate); + + /* Calculate the number of bits that need to be read to finish reading + * the current frame and read the size of the next frame. This number + * has to be rounded up to the nearest 4 bytes on account of the + * byte swapping used */ + bits_to_read = (this->next_frame_bits+20+31) & ~31; + bytes_to_read = bits_to_read / 8; + + /* Check we'll be able to read directly into the buffer */ + if (bytes_to_read > buf->max_size) { + xprintf(this->stream->xine, XINE_VERBOSITY_LOG, + _("demux_mpc: frame too big for buffer")); + this->status = DEMUX_FINISHED; + return this->status; + } + + /* Read data */ + bytes_read = this->input->read(this->input, buf->content, bytes_to_read); + if(bytes_read == 0) { + buf->free_buffer(buf); + this->status = DEMUX_FINISHED; + return this->status; + } else + buf->size = bytes_read; + + /* Read the size of the next frame */ + if (this->current_frame < this->frames) { + /* The number of bits of the next frame we've read */ + extra_bits_read = bits_to_read - (this->next_frame_bits+20); + + if(extra_bits_read <= 12) + next_frame_size = (LE_32(&buf->content[bytes_to_read-4]) >> extra_bits_read) & 0xFFFFF; + else + next_frame_size = ((LE_32(&buf->content[bytes_to_read-8]) << (32-extra_bits_read)) | + (LE_32(&buf->content[bytes_to_read-4]) >> extra_bits_read)) & 0xFFFFF; + + lprintf("next frame size: %u\n", next_frame_size); + + /* The number of bits of the next frame still to read */ + this->next_frame_bits = next_frame_size - extra_bits_read; + } + + /* Each buffer contains at least one frame */ + buf->decoder_flags |= BUF_FLAG_FRAME_END; + + this->audio_fifo->put(this->audio_fifo, buf); + + return this->status; +} + +static void demux_mpc_send_headers(demux_plugin_t *this_gen) { + demux_mpc_t *this = (demux_mpc_t *) this_gen; + buf_element_t *buf; + + this->audio_fifo = this->stream->audio_fifo; + + this->status = DEMUX_OK; + + /* Send start buffers */ + _x_demux_control_start(this->stream); + + /* Send header to decoder */ + if (this->audio_fifo) { + buf = this->audio_fifo->buffer_pool_alloc (this->audio_fifo); + + buf->type = BUF_AUDIO_MPC; + buf->decoder_flags = BUF_FLAG_HEADER|BUF_FLAG_FRAME_END; + buf->decoder_info[0] = this->input->get_length(this->input); + buf->decoder_info[1] = 0; + buf->decoder_info[2] = 0; + buf->decoder_info[3] = 0; + + /* Copy the header */ + buf->size = HEADER_SIZE; + memcpy(buf->content, this->header, buf->size); + + this->audio_fifo->put (this->audio_fifo, buf); + } +} + +static int demux_mpc_seek (demux_plugin_t *this_gen, + off_t start_pos, int start_time, int playing) { + demux_mpc_t *this = (demux_mpc_t *) this_gen; + + /* If thread is not running, initialize demuxer */ + if( !playing ) { + + /* send new pts */ + _x_demux_control_newpts(this->stream, 0, 0); + + this->status = DEMUX_OK; + } + + return this->status; +} + +static void demux_mpc_dispose (demux_plugin_t *this_gen) { + demux_mpc_t *this = (demux_mpc_t *) this_gen; + + free(this); +} + +static int demux_mpc_get_status (demux_plugin_t *this_gen) { + demux_mpc_t *this = (demux_mpc_t *) this_gen; + + return this->status; +} + +static int demux_mpc_get_stream_length (demux_plugin_t *this_gen) { +// demux_mpc_t *this = (demux_mpc_t *) this_gen; + + return 0; +} + +static uint32_t demux_mpc_get_capabilities(demux_plugin_t *this_gen) { + return DEMUX_CAP_NOCAP; +} + +static int demux_mpc_get_optional_data(demux_plugin_t *this_gen, + void *data, int data_type) { + return DEMUX_OPTIONAL_UNSUPPORTED; +} + +static demux_plugin_t *open_plugin (demux_class_t *class_gen, xine_stream_t *stream, + input_plugin_t *input) { + + demux_mpc_t *this; + + this = xine_xmalloc (sizeof (demux_mpc_t)); + this->stream = stream; + this->input = input; + + this->demux_plugin.send_headers = demux_mpc_send_headers; + this->demux_plugin.send_chunk = demux_mpc_send_chunk; + this->demux_plugin.seek = demux_mpc_seek; + this->demux_plugin.dispose = demux_mpc_dispose; + this->demux_plugin.get_status = demux_mpc_get_status; + this->demux_plugin.get_stream_length = demux_mpc_get_stream_length; + this->demux_plugin.get_capabilities = demux_mpc_get_capabilities; + this->demux_plugin.get_optional_data = demux_mpc_get_optional_data; + this->demux_plugin.demux_class = class_gen; + + this->status = DEMUX_FINISHED; + switch (stream->content_detection_method) { + + case METHOD_BY_EXTENSION: { + char *extensions, *mrl; + + mrl = input->get_mrl (input); + extensions = class_gen->get_extensions (class_gen); + + if (!_x_demux_check_extension (mrl, extensions)) { + free (this); + return NULL; + } + } + /* Falling through is intended */ + + case METHOD_BY_CONTENT: + case METHOD_EXPLICIT: + + if (!open_mpc_file(this)) { + free (this); + return NULL; + } + + break; + + default: + free (this); + return NULL; + } + + return &this->demux_plugin; +} + +static char *get_description (demux_class_t *this_gen) { + return "Musepack demux plugin"; +} + +static char *get_identifier (demux_class_t *this_gen) { + return "Musepack"; +} + +static char *get_extensions (demux_class_t *this_gen) { + return "mpc mp+"; +} + +static char *get_mimetypes (demux_class_t *this_gen) { + return NULL; +} + +static void class_dispose (demux_class_t *this_gen) { + demux_mpc_class_t *this = (demux_mpc_class_t *) this_gen; + + free (this); +} + +void *demux_mpc_init_plugin (xine_t *xine, void *data) { + demux_mpc_class_t *this; + + this = xine_xmalloc (sizeof (demux_mpc_class_t)); + + this->demux_class.open_plugin = open_plugin; + this->demux_class.get_description = get_description; + this->demux_class.get_identifier = get_identifier; + this->demux_class.get_mimetypes = get_mimetypes; + this->demux_class.get_extensions = get_extensions; + this->demux_class.dispose = class_dispose; + + return this; +} diff --git a/src/demuxers/group_audio.c b/src/demuxers/group_audio.c index fcafb49bc..2e38eb603 100644 --- a/src/demuxers/group_audio.c +++ b/src/demuxers/group_audio.c @@ -19,7 +19,7 @@ * * This file contains plugin entries for several demuxers used in games * - * $Id: group_audio.c,v 1.15 2004/06/13 21:28:55 miguelfreitas Exp $ + * $Id: group_audio.c,v 1.16 2005/01/14 15:24:23 jstembridge Exp $ */ #ifdef HAVE_CONFIG_H @@ -63,6 +63,10 @@ demuxer_info_t demux_info_mpgaudio = { 0 /* priority */ }; +demuxer_info_t demux_info_mpc = { + 0 /* priority */ +}; + demuxer_info_t demux_info_nsf = { 10 /* priority */ }; @@ -102,6 +106,7 @@ plugin_info_t xine_plugin_info[] = { { PLUGIN_DEMUX, 25, "cdda", XINE_VERSION_CODE, &demux_info_cdda, demux_cdda_init_plugin }, { PLUGIN_DEMUX, 25, "flac", XINE_VERSION_CODE, &demux_info_flac, demux_flac_init_plugin }, { PLUGIN_DEMUX, 25, "mp3", XINE_VERSION_CODE, &demux_info_mpgaudio, demux_mpgaudio_init_class }, + { PLUGIN_DEMUX, 25, "mpc", XINE_VERSION_CODE, &demux_info_mpc, demux_mpc_init_plugin }, { PLUGIN_DEMUX, 25, "nsf", XINE_VERSION_CODE, &demux_info_nsf, demux_nsf_init_plugin }, { PLUGIN_DEMUX, 25, "realaudio", XINE_VERSION_CODE, &demux_info_realaudio, demux_realaudio_init_plugin }, { PLUGIN_DEMUX, 25, "snd", XINE_VERSION_CODE, &demux_info_snd, demux_snd_init_plugin }, diff --git a/src/demuxers/group_audio.h b/src/demuxers/group_audio.h index ced34d682..7badc9339 100644 --- a/src/demuxers/group_audio.h +++ b/src/demuxers/group_audio.h @@ -17,7 +17,7 @@ * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA * - * $Id: group_audio.h,v 1.5 2004/06/11 01:29:49 tmmm Exp $ + * $Id: group_audio.h,v 1.6 2005/01/14 15:24:23 jstembridge Exp $ */ #ifndef HAVE_GROUP_AUDIO_H @@ -32,6 +32,7 @@ void *demux_aiff_init_plugin (xine_t *xine, void *data); void *demux_cdda_init_plugin (xine_t *xine, void *data); void *demux_flac_init_plugin (xine_t *xine, void *data); void *demux_mpgaudio_init_class (xine_t *xine, void *data); +void *demux_mpc_init_plugin (xine_t *xine, void *data); void *demux_nsf_init_plugin (xine_t *xine, void *data); void *demux_realaudio_init_plugin (xine_t *xine, void *data); void *demux_snd_init_plugin (xine_t *xine, void *data); |