diff options
Diffstat (limited to 'libmpdemux/demux_real.c')
| -rw-r--r-- | libmpdemux/demux_real.c | 1916 |
1 files changed, 0 insertions, 1916 deletions
diff --git a/libmpdemux/demux_real.c b/libmpdemux/demux_real.c deleted file mode 100644 index 8f598aa3d5..0000000000 --- a/libmpdemux/demux_real.c +++ /dev/null @@ -1,1916 +0,0 @@ -/* - * Real parser & demuxer - * copyright (C) 2001 Alex Beregszaszi - * copyright (C) 2005, 2006 Roberto Togni - * based on FFmpeg's libav/rm.c - * - * audio codecs: (supported by RealPlayer8 for Linux) - * DNET - RealAudio 3.0, really it's AC3 in swapped-byteorder - * SIPR - SiproLab's audio codec, ACELP decoder working with MPlayer, - * needs fine-tuning too :) - * ATRC - RealAudio 8 (ATRAC3) - www.minidisc.org/atrac3_article.pdf, - * ACM decoder uploaded, needs some fine-tuning to work - * -> RealAudio 8 - * COOK/COKR - Real Cooker -> RealAudio G2 - * - * video codecs: (supported by RealPlayer8 for Linux) - * RV10 - H.263 based, working with libavcodec's decoder - * RV20-RV40 - using RealPlayer's codec plugins - * - * This file is part of MPlayer. - * - * MPlayer 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. - * - * MPlayer 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 MPlayer; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - */ - -#include <stdio.h> -#include <stdlib.h> -#include <unistd.h> -#include <inttypes.h> - -#include <libavutil/intreadwrite.h> -#include <libavutil/common.h> - -#include "config.h" -#include "mp_msg.h" -#include "mpbswap.h" -#include "stream/stream.h" -#include "aviprint.h" -#include "demuxer.h" -#include "stheader.h" -#include "demux_real.h" - -//#define mp_dbg(mod,lev, args... ) mp_msg_c((mod<<8)|lev, ## args ) - -#define MAX_STREAMS 32 - -static unsigned char sipr_swaps[38][2]={ - {0,63},{1,22},{2,44},{3,90},{5,81},{7,31},{8,86},{9,58},{10,36},{12,68}, - {13,39},{14,73},{15,53},{16,69},{17,57},{19,88},{20,34},{21,71},{24,46}, - {25,94},{26,54},{28,75},{29,50},{32,70},{33,92},{35,74},{38,85},{40,56}, - {42,87},{43,65},{45,59},{48,79},{49,93},{51,89},{55,95},{61,76},{67,83}, - {77,80} }; - -typedef struct { - unsigned int timestamp; - int offset; -// int packetno; -// int len; /* only filled by our index generator */ -// int flags; /* only filled by our index generator */ -} real_index_table_t; - -typedef struct { - /* for seeking */ - int index_chunk_offset; - real_index_table_t *index_table[MAX_STREAMS]; - -// int *index_table[MAX_STREAMS]; - int index_table_size[MAX_STREAMS]; - int index_malloc_size[MAX_STREAMS]; - int data_chunk_offset; - int num_of_packets; - int current_packet; - -// need for seek - int audio_need_keyframe; - int video_after_seek; - - int current_apacket; - int current_vpacket; - - // timestamp correction: - int64_t kf_base;// timestamp of the prev. video keyframe - unsigned int kf_pts; // timestamp of next video keyframe - unsigned int a_pts; // previous audio timestamp - double v_pts; // previous video timestamp - unsigned long duration; - - /* stream id table */ -// int last_a_stream; -// int a_streams[MAX_STREAMS]; -// int last_v_stream; -// int v_streams[MAX_STREAMS]; - - /** - * Used to demux multirate files - */ - int is_multirate; ///< != 0 for multirate files - int str_data_offset[MAX_STREAMS]; ///< Data chunk offset for every audio/video stream - int audio_curpos; ///< Current file position for audio demuxing - int video_curpos; ///< Current file position for video demuxing - int a_num_of_packets; ///< Number of audio packets - int v_num_of_packets; ///< Number of video packets - int a_bitrate; ///< Audio bitrate - int v_bitrate; ///< Video bitrate - int stream_switch; ///< Flag used to switch audio/video demuxing - - /** - * Used to reorder audio data - */ - unsigned int intl_id[MAX_STREAMS]; ///< interleaver id, per stream - int sub_packet_size[MAX_STREAMS]; ///< sub packet size, per stream - int sub_packet_h[MAX_STREAMS]; ///< number of coded frames per block - int coded_framesize[MAX_STREAMS]; ///< coded frame size, per stream - int audiopk_size[MAX_STREAMS]; ///< audio packet size - unsigned char *audio_buf; ///< place to store reordered audio data - double *audio_timestamp; ///< timestamp for each audio packet - int sub_packet_cnt; ///< number of subpacket already received - int audio_filepos; ///< file position of first audio packet in block -} real_priv_t; - -//! use at most 200 MB of memory for index, corresponds to around 25 million entries -#define MAX_INDEX_ENTRIES (200*1024*1024 / sizeof(real_index_table_t)) - -/* originally from FFmpeg */ -static void get_str(int isbyte, demuxer_t *demuxer, char *buf, int buf_size) -{ - int len; - - if (isbyte) - len = stream_read_char(demuxer->stream); - else - len = stream_read_word(demuxer->stream); - - stream_read(demuxer->stream, buf, (len > buf_size) ? buf_size : len); - if (len > buf_size) - stream_skip(demuxer->stream, len-buf_size); - - mp_msg(MSGT_DEMUX, MSGL_V, "read_str: %d bytes read\n", len); -} - -static void dump_index(demuxer_t *demuxer, int stream_id) -{ - real_priv_t *priv = demuxer->priv; - real_index_table_t *index; - int i, entries; - - if (!mp_msg_test(MSGT_DEMUX,MSGL_V)) - return; - - if ((unsigned)stream_id >= MAX_STREAMS) - return; - - index = priv->index_table[stream_id]; - entries = priv->index_table_size[stream_id]; - - mp_msg(MSGT_DEMUX, MSGL_V, "Index table for stream %d\n", stream_id); - for (i = 0; i < entries; i++) - { -#if 1 - mp_msg(MSGT_DEMUX, MSGL_V,"i: %d, pos: %d, timestamp: %u\n", i, index[i].offset, index[i].timestamp); -#else - mp_msg(MSGT_DEMUX, MSGL_V,"packetno: %x pos: %x len: %x timestamp: %x flags: %x\n", - index[i].packetno, index[i].offset, index[i].len, index[i].timestamp, - index[i].flags); -#endif - } -} - -static int parse_index_chunk(demuxer_t *demuxer) -{ - real_priv_t *priv = demuxer->priv; - int origpos = stream_tell(demuxer->stream); - int next_header_pos = priv->index_chunk_offset; - int i, entries, stream_id; - -read_index: - stream_seek(demuxer->stream, next_header_pos); - - i = stream_read_dword_le(demuxer->stream); - if ((i == -256) || (i != MKTAG('I', 'N', 'D', 'X'))) - { - mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no index chunk found on given address (%d)\n", - next_header_pos); - index_mode = -1; - if (i == -256) - stream_reset(demuxer->stream); - stream_seek(demuxer->stream, origpos); - return 0; - //goto end; - } - - mp_msg(MSGT_DEMUX, MSGL_V,"Reading index table from index chunk (%d)\n", - next_header_pos); - - i = stream_read_dword(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_V,"size: %d bytes\n", i); - - i = stream_read_word(demuxer->stream); - if (i != 0) - mp_msg(MSGT_DEMUX, MSGL_WARN,"Hmm, index table with unknown version (%d), please report it to MPlayer developers!\n", i); - - entries = stream_read_dword(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_V,"entries: %d\n", entries); - - stream_id = stream_read_word(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_V,"stream_id: %d\n", stream_id); - - next_header_pos = stream_read_dword(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_V,"next_header_pos: %d\n", next_header_pos); - if (entries <= 0 || entries > MAX_INDEX_ENTRIES) - { - if (next_header_pos) - goto read_index; - i = entries; - goto end; - } - - priv->index_table_size[stream_id] = entries; - priv->index_table[stream_id] = calloc(priv->index_table_size[stream_id], sizeof(real_index_table_t)); - - for (i = 0; i < entries; i++) - { - stream_skip(demuxer->stream, 2); /* version */ - priv->index_table[stream_id][i].timestamp = stream_read_dword(demuxer->stream); - priv->index_table[stream_id][i].offset = stream_read_dword(demuxer->stream); - stream_skip(demuxer->stream, 4); /* packetno */ -// priv->index_table[stream_id][i].packetno = stream_read_dword(demuxer->stream); -// printf("Index table: Stream#%d: entry: %d: pos: %d\n", -// stream_id, i, priv->index_table[stream_id][i].offset); - } - - dump_index(demuxer, stream_id); - - if (next_header_pos > 0) - goto read_index; - -end: - if (i == -256) - stream_reset(demuxer->stream); - stream_seek(demuxer->stream, origpos); - if (i == -256) - return 0; - else - return 1; -} - -#if 1 - -static void add_index_item(demuxer_t *demuxer, int stream_id, unsigned int timestamp, int offset) -{ - if ((unsigned)stream_id < MAX_STREAMS) - { - real_priv_t *priv = demuxer->priv; - real_index_table_t *index; - if (priv->index_table_size[stream_id] >= MAX_INDEX_ENTRIES) { - mp_msg(MSGT_DEMUXER, MSGL_WARN, "Index too large during building\n"); - return; - } - if (priv->index_table_size[stream_id] >= priv->index_malloc_size[stream_id]) - { - if (priv->index_malloc_size[stream_id] == 0) - priv->index_malloc_size[stream_id] = 2048; - else - priv->index_malloc_size[stream_id] += priv->index_malloc_size[stream_id] / 2; - // in case we have a really large chunk... - if (priv->index_table_size[stream_id] >= - priv->index_malloc_size[stream_id]) - priv->index_malloc_size[stream_id] = - priv->index_table_size[stream_id] + 1; - priv->index_table[stream_id] = realloc(priv->index_table[stream_id], priv->index_malloc_size[stream_id]*sizeof(priv->index_table[0][0])); - } - if (priv->index_table_size[stream_id] > 0) - { - index = &priv->index_table[stream_id][priv->index_table_size[stream_id] - 1]; - if (index->timestamp >= timestamp || index->offset >= offset) - return; - } - index = &priv->index_table[stream_id][priv->index_table_size[stream_id]++]; - index->timestamp = timestamp; - index->offset = offset; - } -} - -static void add_index_segment(demuxer_t *demuxer, int seek_stream_id, int64_t seek_timestamp) -{ - int tag, len, stream_id, flags; - unsigned int timestamp; - if (seek_timestamp != -1 && (unsigned)seek_stream_id >= MAX_STREAMS) - return; - while (1) - { - demuxer->filepos = stream_tell(demuxer->stream); - - tag = stream_read_dword(demuxer->stream); - if (tag == MKTAG('A', 'T', 'A', 'D')) - { - stream_skip(demuxer->stream, 14); - continue; /* skip to next loop */ - } - len = tag & 0xffff; - if (tag == -256 || len < 12) - break; - - stream_id = stream_read_word(demuxer->stream); - timestamp = stream_read_dword(demuxer->stream); - - stream_skip(demuxer->stream, 1); /* reserved */ - flags = stream_read_char(demuxer->stream); - - if (flags == -256) - break; - - if (flags & 2) - { - add_index_item(demuxer, stream_id, timestamp, demuxer->filepos); - if (stream_id == seek_stream_id && timestamp >= seek_timestamp) - { - stream_seek(demuxer->stream, demuxer->filepos); - return; - } - } - // printf("Index: stream=%d packet=%d timestamp=%u len=%d flags=0x%x datapos=0x%x\n", stream_id, entries, timestamp, len, flags, index->offset); - /* skip data */ - stream_skip(demuxer->stream, len-12); - } -} - -static int generate_index(demuxer_t *demuxer) -{ - real_priv_t *priv = demuxer->priv; - int origpos = stream_tell(demuxer->stream); - int data_pos = priv->data_chunk_offset-10; - int i; - int tag; - - stream_seek(demuxer->stream, data_pos); - tag = stream_read_dword(demuxer->stream); - if (tag != MKTAG('A', 'T', 'A', 'D')) - { - mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no data chunk found on given address (%d)\n", data_pos); - } - else - { - stream_skip(demuxer->stream, 14); - add_index_segment(demuxer, -1, -1); - } - for (i = 0; i < MAX_STREAMS; i++) - { - if (priv->index_table_size[i] > 0) - { - dump_index(demuxer, i); - } - } - stream_reset(demuxer->stream); - stream_seek(demuxer->stream, origpos); - return 0; -} - -#else - -static int generate_index(demuxer_t *demuxer) -{ - real_priv_t *priv = demuxer->priv; - int origpos = stream_tell(demuxer->stream); - int data_pos = priv->data_chunk_offset-10; - int num_of_packets = 0; - int i, entries = 0; - int len, stream_id = 0, flags; - unsigned int timestamp; - int tab_pos = 0; - -read_index: - stream_seek(demuxer->stream, data_pos); - - i = stream_read_dword_le(demuxer->stream); - if ((i == -256) || (i != MKTAG('D', 'A', 'T', 'A'))) - { - mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no data chunk found on given address (%d)\n", - data_pos); - goto end; - } - stream_skip(demuxer->stream, 4); /* chunk size */ - stream_skip(demuxer->stream, 2); /* version */ - - num_of_packets = stream_read_dword(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_V,"Generating index table from raw data (pos: 0x%x) for %d packets\n", - data_pos, num_of_packets); - - data_pos = stream_read_dword_le(demuxer->stream)-10; /* next data chunk */ - - for (i = 0; i < MAX_STREAMS; i++) - { - priv->index_table_size[i] = num_of_packets; - priv->index_table[i] = calloc(priv->index_table_size[i], sizeof(real_index_table_t)); -// priv->index_table[stream_id] = realloc(priv->index_table[stream_id], -// priv->index_table_size[stream_id] * sizeof(real_index_table_t)); - } - - tab_pos = 0; - -// memset(priv->index_table_size, 0, sizeof(int)*MAX_STREAMS); -// memset(priv->index_table, 0, sizeof(real_index_table_t)*MAX_STREAMS); - - while (tab_pos < num_of_packets) - { - i = stream_read_char(demuxer->stream); - if (i == -256) - goto end; - stream_skip(demuxer->stream, 1); -// stream_skip(demuxer->stream, 2); /* version */ - - len = stream_read_word(demuxer->stream); - stream_id = stream_read_word(demuxer->stream); - timestamp = stream_read_dword(demuxer->stream); - - stream_skip(demuxer->stream, 1); /* reserved */ - flags = stream_read_char(demuxer->stream); - - i = tab_pos; - -// priv->index_table_size[stream_id] = i; -// if (priv->index_table[stream_id] == NULL) -// priv->index_table[stream_id] = malloc(priv->index_table_size[stream_id] * sizeof(real_index_table_t)); -// else -// priv->index_table[stream_id] = realloc(priv->index_table[stream_id], -// priv->index_table_size[stream_id] * sizeof(real_index_table_t)); - - priv->index_table[stream_id][i].timestamp = timestamp; - priv->index_table[stream_id][i].offset = stream_tell(demuxer->stream)-12; - priv->index_table[stream_id][i].len = len; - priv->index_table[stream_id][i].packetno = entries; - priv->index_table[stream_id][i].flags = flags; - - tab_pos++; - - /* skip data */ - stream_skip(demuxer->stream, len-12); - } - dump_index(demuxer, stream_id); - if (data_pos) - goto read_index; - -end: - if (i == -256) - stream_reset(demuxer->stream); - stream_seek(demuxer->stream, origpos); - if (i == -256) - return 0; - else - return 1; -} -#endif - - -static int real_check_file(demuxer_t* demuxer) -{ - real_priv_t *priv; - int c; - - mp_msg(MSGT_DEMUX,MSGL_V,"Checking for REAL\n"); - - c = stream_read_dword_le(demuxer->stream); - if (c == -256) - return 0; /* EOF */ - if (c != MKTAG('.', 'R', 'M', 'F')) - return 0; /* bad magic */ - - priv = calloc(1, sizeof(real_priv_t)); - demuxer->priv = priv; - - return DEMUXER_TYPE_REAL; -} - -#define SKIP_BITS(n) buffer<<=n -#define SHOW_BITS(n) ((buffer)>>(32-(n))) - -double real_fix_timestamp(unsigned char *buf, unsigned int timestamp, unsigned int format, int64_t *kf_base, int *kf_pts, double *pts){ - double v_pts; - unsigned char *s = buf + 1 + (*buf+1)*8; - uint32_t buffer= (s[0]<<24) + (s[1]<<16) + (s[2]<<8) + s[3]; - unsigned int kf=timestamp; - int pict_type; - unsigned int orig_kf; - - if(format==mmioFOURCC('R','V','3','0') || format==mmioFOURCC('R','V','4','0')){ - if(format==mmioFOURCC('R','V','3','0')){ - SKIP_BITS(3); - pict_type= SHOW_BITS(2); - SKIP_BITS(2 + 7); - }else{ - SKIP_BITS(1); - pict_type= SHOW_BITS(2); - SKIP_BITS(2 + 7 + 3); - } - orig_kf= - kf= SHOW_BITS(13); // kf= 2*SHOW_BITS(12); -// if(pict_type==0) - if(pict_type<=1){ - // I frame, sync timestamps: - *kf_base=(int64_t)timestamp-kf; - mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: base=%08"PRIX64"\n",*kf_base); - kf=timestamp; - } else { - // P/B frame, merge timestamps: - int64_t tmp=(int64_t)timestamp-*kf_base; - kf|=tmp&(~0x1fff); // combine with packet timestamp - if(kf<tmp-4096) kf+=8192; else // workaround wrap-around problems - if(kf>tmp+4096) kf-=8192; - kf+=*kf_base; - } - if(pict_type != 3){ // P || I frame -> swap timestamps - unsigned int tmp=kf; - kf=*kf_pts; - *kf_pts=tmp; -// if(kf<=tmp) kf=0; - } - mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: %08X -> %08X (%04X) %d %02X %02X %02X %02X %5u\n",timestamp,kf,orig_kf,pict_type,s[0],s[1],s[2],s[3],pts?kf-(unsigned int)(*pts*1000.0):0); - } - v_pts=kf*0.001f; -// if(pts && (v_pts<*pts || !kf)) v_pts=*pts+frametime; - if(pts) *pts=v_pts; - return v_pts; -} - -typedef struct dp_hdr_s { - uint32_t chunks; // number of chunks - uint32_t timestamp; // timestamp from packet header - uint32_t len; // length of actual data - uint32_t chunktab; // offset to chunk offset array -} dp_hdr_t; - -static void queue_video_packet(real_priv_t *priv, demux_stream_t *ds, demux_packet_t *dp) -{ - dp_hdr_t hdr = *(dp_hdr_t*)dp->buffer; - unsigned char *tmp = malloc(8*(1+hdr.chunks)); - memcpy(tmp, dp->buffer+hdr.chunktab, 8*(1+hdr.chunks)); - memmove(dp->buffer+1+8*(1+hdr.chunks), dp->buffer+sizeof(dp_hdr_t), hdr.len); - memcpy(dp->buffer+1, tmp, 8*(1+hdr.chunks)); - *dp->buffer = (uint8_t)hdr.chunks; - free(tmp); - - if(priv->video_after_seek){ - priv->kf_base = 0; - priv->kf_pts = hdr.timestamp; - priv->video_after_seek = 0; - } - if(hdr.len >= 3) /* this check may be useless */ - dp->pts = real_fix_timestamp(dp->buffer, hdr.timestamp, - ((sh_video_t *)ds->sh)->format, - &priv->kf_base, &priv->kf_pts, - &priv->v_pts); - ds_add_packet(ds, dp); -} - -// return value: -// 0 = EOF or no stream found -// 1 = successfully read a packet -static int demux_real_fill_buffer(demuxer_t *demuxer, demux_stream_t *dsds) -{ - real_priv_t *priv = demuxer->priv; - demux_stream_t *ds = NULL; - int len; - unsigned int timestamp; - int stream_id; -#ifdef CRACK_MATRIX - int i; -#endif - int flags; - int version; - int reserved av_unused; - demux_packet_t *dp; - int x, sps, cfs, sph, spc, w; - int audioreorder_getnextpk = 0; - - // Don't demux video if video codec init failed - if (demuxer->video->id >= 0 && !demuxer->video->sh) - demuxer->video->id = -2; - - while(!stream_eof(demuxer->stream)){ - - /* Handle audio/video demxing switch for multirate files (non-interleaved) */ - if (priv->is_multirate && priv->stream_switch) { - if (priv->current_apacket >= priv->index_table_size[demuxer->audio->id]) - demuxer->audio->eof = 1; - if (priv->current_vpacket >= priv->index_table_size[demuxer->video->id]) - demuxer->video->eof = 1; - if (demuxer->audio->eof && demuxer->video->eof) - return 0; - else if (!demuxer->audio->eof && demuxer->video->eof) - stream_seek(demuxer->stream, priv->audio_curpos); // Get audio - else if (demuxer->audio->eof && !demuxer->video->eof) - stream_seek(demuxer->stream, priv->video_curpos); // Get video - else if (priv->index_table[demuxer->audio->id][priv->current_apacket].timestamp < - priv->index_table[demuxer->video->id][priv->current_vpacket].timestamp) - stream_seek(demuxer->stream, priv->audio_curpos); // Get audio - else - stream_seek(demuxer->stream, priv->video_curpos); // Get video - priv->stream_switch = 0; - } - - demuxer->filepos = stream_tell(demuxer->stream); - version = stream_read_word(demuxer->stream); /* version */ - len = stream_read_word(demuxer->stream); - if ((version==0x4441) && (len==0x5441)) { // new data chunk - mp_msg(MSGT_DEMUX,MSGL_INFO,"demux_real: New data chunk is coming!!!\n"); - if (priv->is_multirate) - return 0; // EOF - stream_skip(demuxer->stream,14); - demuxer->filepos = stream_tell(demuxer->stream); - version = stream_read_word(demuxer->stream); /* version */ - len = stream_read_word(demuxer->stream); - } else if ((version == 0x494e) && (len == 0x4458)) { - mp_msg(MSGT_DEMUX,MSGL_V,"demux_real: Found INDX chunk. EOF.\n"); - demuxer->stream->eof=1; - return 0; - } - - - if (len == -256){ /* EOF */ -// printf("len==-256!\n"); - return 0; - } - if (len < 12){ - mp_msg(MSGT_DEMUX, MSGL_V,"%08X: packet v%d len=%d \n",(int)demuxer->filepos,(int)version,(int)len); - mp_msg(MSGT_DEMUX, MSGL_WARN,"bad packet len (%d)\n", len); - if ((unsigned)demuxer->video->id < MAX_STREAMS) { - if (priv->current_vpacket + 1 < priv->index_table_size[demuxer->video->id]) { - stream_seek(demuxer->stream, priv->index_table[demuxer->video->id][++priv->current_vpacket].offset); - } - } else if ((unsigned)demuxer->audio->id < MAX_STREAMS) { - if (priv->current_apacket + 1 < priv->index_table_size[demuxer->audio->id]) { - stream_seek(demuxer->stream, priv->index_table[demuxer->audio->id][++priv->current_apacket].offset); - } - } - continue; //goto loop; - } - - stream_id = stream_read_word(demuxer->stream); - timestamp = stream_read_dword(demuxer->stream); - reserved = stream_read_char(demuxer->stream); - flags = stream_read_char(demuxer->stream); - /* flags: */ - /* 0x1 - reliable */ - /* 0x2 - keyframe */ - - if (version == 1) { - int tmp; - tmp = stream_read_char(demuxer->stream); - mp_msg(MSGT_DEMUX, MSGL_DBG2,"Version: %d, skipped byte is %d\n", version, tmp); - len--; - } - - if (flags & 2) - add_index_item(demuxer, stream_id, timestamp, demuxer->filepos); - -// printf("%08X: packet v%d len=%4d id=%d pts=%6d rvd=%d flags=%d \n", -// (int)demuxer->filepos,(int)version,(int)len, stream_id, -// (int) timestamp, reserved, flags); - - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "\npacket#%d: pos: 0x%0x, len: %d, id: %d, pts: %u, flags: %x rvd:%d\n", - priv->current_packet, (int)demuxer->filepos, len, stream_id, timestamp, flags, reserved); - - priv->current_packet++; - len -= 12; - -// printf("s_id=%d aid=%d vid=%d \n",stream_id,demuxer->audio->id,demuxer->video->id); - - /* check stream_id: */ - - if(demuxer->audio->id==stream_id){ - if (priv->audio_need_keyframe == 1&& flags != 0x2) - goto discard; -got_audio: - ds=demuxer->audio; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "packet is audio (id: %d)\n", stream_id); - - if (flags & 2) { - priv->sub_packet_cnt = 0; - audioreorder_getnextpk = 0; - } - - // parse audio chunk: - { -#ifdef CRACK_MATRIX - int spos=stream_tell(demuxer->stream); - static int cnt=0; - static int cnt2=CRACK_MATRIX; -#endif - if (((sh_audio_t *)ds->sh)->format == mmioFOURCC('M', 'P', '4', 'A')) { - uint16_t sub_packet_lengths[16], sub_packets, i; - int totlen = 0; - /* AAC in Real: several AAC frames in one Real packet. */ - /* Second byte, upper four bits: number of AAC frames */ - /* next n * 2 bytes: length of the AAC frames in bytes, BE */ - if (len < 2) - goto discard; - sub_packets = (stream_read_word(demuxer->stream) & 0xf0) >> 4; - if (len < 2 * sub_packets) - goto discard; - for (i = 0; i < sub_packets; i++) - totlen += sub_packet_lengths[i] = stream_read_word(demuxer->stream); - if (len < totlen ) - goto discard; - for (i = 0; i < sub_packets; i++) { - demux_packet_t *dp = new_demux_packet(sub_packet_lengths[i]); - stream_read(demuxer->stream, dp->buffer, sub_packet_lengths[i]); - if (priv->a_pts != timestamp) - dp->pts = timestamp / 1000.0; - priv->a_pts = timestamp; - dp->pos = demuxer->filepos; - ds_add_packet(ds, dp); - } - return 1; - } - if ((priv->intl_id[stream_id] == mmioFOURCC('I', 'n', 't', '4')) || - (priv->intl_id[stream_id] == mmioFOURCC('g', 'e', 'n', 'r')) || - (priv->intl_id[stream_id] == mmioFOURCC('s', 'i', 'p', 'r'))) { - sps = priv->sub_packet_size[stream_id]; - sph = priv->sub_packet_h[stream_id]; - cfs = priv->coded_framesize[stream_id]; - w = priv->audiopk_size[stream_id]; - spc = priv->sub_packet_cnt; - switch (priv->intl_id[stream_id]) { - case mmioFOURCC('I', 'n', 't', '4'): - if (len < cfs * sph/2) - goto discard; - for (x = 0; x < sph / 2; x++) - stream_read(demuxer->stream, priv->audio_buf + x * 2 * w + spc * cfs, cfs); - break; - case mmioFOURCC('g', 'e', 'n', 'r'): - if (len < w) - goto discard; - for (x = 0; x < w / sps; x++) - stream_read(demuxer->stream, priv->audio_buf + sps * (sph * x + ((sph + 1) / 2) * (spc & 1) + - (spc >> 1)), sps); - break; - case mmioFOURCC('s', 'i', 'p', 'r'): - if (len < w) - goto discard; - stream_read(demuxer->stream, priv->audio_buf + spc * w, w); - if (spc == sph - 1) { - int n; - int bs = sph * w * 2 / 96; // nibbles per subpacket - // Perform reordering - for(n=0; n < 38; n++) { - int j; - int i = bs * sipr_swaps[n][0]; - int o = bs * sipr_swaps[n][1]; - // swap nibbles of block 'i' with 'o' TODO: optimize - for(j = 0;j < bs; j++) { - int x = (i & 1) ? (priv->audio_buf[i >> 1] >> 4) : (priv->audio_buf[i >> 1] & 0x0F); - int y = (o & 1) ? (priv->audio_buf[o >> 1] >> 4) : (priv->audio_buf[o >> 1] & 0x0F); - if(o & 1) - priv->audio_buf[o >> 1] = (priv->audio_buf[o >> 1] & 0x0F) | (x << 4); - else - priv->audio_buf[o >> 1] = (priv->audio_buf[o >> 1] & 0xF0) | x; - if(i & 1) - priv->audio_buf[i >> 1] = (priv->audio_buf[i >> 1] & 0x0F) | (y << 4); - else - priv->audio_buf[i >> 1] = (priv->audio_buf[i >> 1] & 0xF0) | y; - ++i; ++o; - } - } - } - break; - } - priv->audio_need_keyframe = 0; - priv->audio_timestamp[priv->sub_packet_cnt] = (priv->a_pts==timestamp) ? MP_NOPTS_VALUE : (timestamp/1000.0); - priv->a_pts = timestamp; - if (priv->sub_packet_cnt == 0) - priv->audio_filepos = demuxer->filepos; - if (++(priv->sub_packet_cnt) < sph) - audioreorder_getnextpk = 1; - else { - int apk_usize = ((sh_audio_t*)ds->sh)->wf->nBlockAlign; - audioreorder_getnextpk = 0; - priv->sub_packet_cnt = 0; - // Release all the audio packets - for (x = 0; x < sph*w/apk_usize; x++) { - dp = new_demux_packet(apk_usize); - memcpy(dp->buffer, priv->audio_buf + x * apk_usize, apk_usize); - /* Put timestamp only on packets that correspond to original audio packets in file */ - if (x * apk_usize % w == 0) - dp->pts = priv->audio_timestamp[x * apk_usize / w]; - dp->pos = priv->audio_filepos; // all equal - dp->keyframe = !x; // Mark first packet as keyframe - ds_add_packet(ds, dp); - } - } - } else { // No interleaving - dp = new_demux_packet(len); - stream_read(demuxer->stream, dp->buffer, len); - -#ifdef CRACK_MATRIX - mp_msg(MSGT_DEMUX, MSGL_V,"*** audio block len=%d\n",len); - { // HACK - used for reverse engineering the descrambling matrix - FILE* f=fopen("test.rm","r+"); - fseek(f,spos,SEEK_SET); - ++cnt; -// for(i=0;i<len;i++) dp->buffer[i]=i/0x12; -// for(i=0;i<len;i++) dp->buffer[i]=i; -// for(i=0;i<len;i++) dp->buffer[i]=cnt; -// for(i=0;i<len;i++) dp->buffer[i]=cnt<<4; - for(i=0;i<len;i++) dp->buffer[i]=(i==cnt2) ? (cnt+16*(8+cnt)) : 0; - if(cnt==6){ cnt=0; ++cnt2; } - fwrite(dp->buffer, len, 1, f); - fclose(f); - if(cnt2>0x150) *((int*)NULL)=1; // sig11 :) - } -#endif -#if 0 - if( ((sh_audio_t *)ds->sh)->format == 0x2000) { - // if DNET, swap bytes, as DNET is byte-swapped AC3: - char *ptr = dp->buffer; - int i; - for (i = 0; i < len; i += 2) - { - const char tmp = ptr[0]; - ptr[0] = ptr[1]; - ptr[1] = tmp; - ptr += 2; - } - } -#endif - if (priv->audio_need_keyframe == 1) { - priv->audio_need_keyframe = 0; - } else if(priv->a_pts != timestamp) - dp->pts = timestamp/1000.0; - priv->a_pts=timestamp; - dp->pos = demuxer->filepos; - dp->keyframe = flags & 0x2; - ds_add_packet(ds, dp); - - } // codec_id check, codec default case - } -// we will not use audio index if we use -idx and have a video - if(((!demuxer->video->sh && index_mode == 2) || priv->is_multirate) && (unsigned)demuxer->audio->id < MAX_STREAMS) { - while (priv->current_apacket + 1 < priv->index_table_size[demuxer->audio->id] && - timestamp > priv->index_table[demuxer->audio->id][priv->current_apacket].timestamp) { - priv->current_apacket += 1; - priv->stream_switch = 1; - } - if (priv->stream_switch) - priv->audio_curpos = stream_tell(demuxer->stream); - } - - // If we're reordering audio packets and we need more data get it - if (audioreorder_getnextpk) - continue; - - return 1; - } - - if(demuxer->video->id==stream_id){ -got_video: - ds=demuxer->video; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "packet is video (id: %d)\n", stream_id); - - // parse video chunk: - { - // we need a more complicated, 2nd level demuxing, as the video - // frames are stored fragmented in the video chunks :( - sh_video_t *sh_video = ds->sh; - demux_packet_t *dp; - unsigned vpkg_header, vpkg_length, vpkg_offset; - int vpkg_seqnum=-1; - int vpkg_subseq=0; - - while(len>2){ - dp_hdr_t* dp_hdr; - unsigned char* dp_data; - uint8_t* extra; - -// printf("xxx len=%d \n",len); - - // read packet header - // bit 7: 1=last block in block chain - // bit 6: 1=short header (only one block?) - vpkg_header=stream_read_char(demuxer->stream); --len; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "hdr: %02X (len=%d) ",vpkg_header,len); - - if (0x40==(vpkg_header&0xc0)) { - // seems to be a very short header - // 2 bytes, purpose of the second byte yet unknown - int bummer av_unused; - bummer=stream_read_char(demuxer->stream); --len; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "%02X",bummer); - vpkg_offset=0; - vpkg_length=len; - } else { - - if (0==(vpkg_header&0x40)) { - // sub-seqnum (bits 0-6: number of fragment. bit 7: ???) - vpkg_subseq=stream_read_char(demuxer->stream); - --len; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "subseq: %02X ",vpkg_subseq); - vpkg_subseq&=0x7f; - } - - // size of the complete packet - // bit 14 is always one (same applies to the offset) - vpkg_length=stream_read_word(demuxer->stream); - len-=2; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "l: %02X %02X ",vpkg_length>>8,vpkg_length&0xff); - if (!(vpkg_length&0xC000)) { - vpkg_length<<=16; - vpkg_length|=(uint16_t)stream_read_word(demuxer->stream); - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "l+: %02X %02X ",(vpkg_length>>8)&0xff,vpkg_length&0xff); - len-=2; - } else - vpkg_length&=0x3fff; - - // offset of the following data inside the complete packet - // Note: if (hdr&0xC0)==0x80 then offset is relative to the - // _end_ of the packet, so it's equal to fragment size!!! - vpkg_offset=stream_read_word(demuxer->stream); - len-=2; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "o: %02X %02X ",vpkg_offset>>8,vpkg_offset&0xff); - if (!(vpkg_offset&0xC000)) { - vpkg_offset<<=16; - vpkg_offset|=(uint16_t)stream_read_word(demuxer->stream); - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "o+: %02X %02X ",(vpkg_offset>>8)&0xff,vpkg_offset&0xff); - len-=2; - } else - vpkg_offset&=0x3fff; - - vpkg_seqnum=stream_read_char(demuxer->stream); --len; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "seq: %02X ",vpkg_seqnum); - } - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "\n"); - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "blklen=%d\n", len); - mp_msg(MSGT_DEMUX,MSGL_DBG2, "block: hdr=0x%0x, len=%d, offset=%d, seqnum=%d\n", - vpkg_header, vpkg_length, vpkg_offset, vpkg_seqnum); - - if(ds->asf_packet){ - dp=ds->asf_packet; - dp_hdr=(dp_hdr_t*)dp->buffer; - dp_data=dp->buffer+sizeof(dp_hdr_t); - extra=dp->buffer+dp_hdr->chunktab; - mp_dbg(MSGT_DEMUX,MSGL_DBG2, "we have an incomplete packet (oldseq=%d new=%d)\n",ds->asf_seq,vpkg_seqnum); - // we have an incomplete packet: - if(ds->asf_seq!=vpkg_seqnum){ - // this fragment is for new packet, close the old one - mp_msg(MSGT_DEMUX,MSGL_DBG2, "closing probably incomplete packet, len: %d \n",dp->len); - queue_video_packet(priv, ds, dp); - ds->asf_packet=NULL; - } else { - // append data to it! - ++dp_hdr->chunks; - mp_msg(MSGT_DEMUX,MSGL_DBG2,"[chunks=%d subseq=%d]\n",dp_hdr->chunks,vpkg_subseq); - if(dp_hdr->chunktab+8*(1+dp_hdr->chunks)>dp->len){ - // increase buffer size, this should not happen! - mp_msg(MSGT_DEMUX,MSGL_WARN, "chunktab buffer too small!!!!!\n"); - dp->len=dp_hdr->chunktab+8*(4+dp_hdr->chunks); - dp->buffer=realloc(dp->buffer,dp->len+MP_INPUT_BUFFER_PADDING_SIZE); - memset(dp->buffer + dp->len, 0, MP_INPUT_BUFFER_PADDING_SIZE); - // re-calc pointers: - |