?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
find_subfiles: select subtitle files matching -slang
[mplayer/greg.git] / libmpdemux / demux_real.c
blob1bdf8ec19b38dcaa8e69559af4393f657a112bd3
1 /*
2 * Real parser & demuxer
3 * copyright (C) 2001 Alex Beregszaszi
4 * copyright (C) 2005, 2006 Roberto Togni
5 * based on FFmpeg's libav/rm.c
6 *
7 * audio codecs: (supported by RealPlayer8 for Linux)
8 * DNET - RealAudio 3.0, really it's AC3 in swapped-byteorder
9 * SIPR - SiproLab's audio codec, ACELP decoder working with MPlayer,
10 * needs fine-tuning too :)
11 * ATRC - RealAudio 8 (ATRAC3) - www.minidisc.org/atrac3_article.pdf,
12 * ACM decoder uploaded, needs some fine-tuning to work
13 * -> RealAudio 8
14 * COOK/COKR - Real Cooker -> RealAudio G2
15 *
16 * video codecs: (supported by RealPlayer8 for Linux)
17 * RV10 - H.263 based, working with libavcodec's decoder
18 * RV20-RV40 - using RealPlayer's codec plugins
19 *
20 * This file is part of MPlayer.
21 *
22 * MPlayer is free software; you can redistribute it and/or modify
23 * it under the terms of the GNU General Public License as published by
24 * the Free Software Foundation; either version 2 of the License, or
25 * (at your option) any later version.
26 *
27 * MPlayer is distributed in the hope that it will be useful,
28 * but WITHOUT ANY WARRANTY; without even the implied warranty of
29 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
30 * GNU General Public License for more details.
31 *
32 * You should have received a copy of the GNU General Public License along
33 * with MPlayer; if not, write to the Free Software Foundation, Inc.,
34 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
35 */
36
37 #include <stdio.h>
38 #include <stdlib.h>
39 #include <unistd.h>
40 #include <inttypes.h>
41
42 #include "config.h"
43 #include "mp_msg.h"
44 #include "mpbswap.h"
45 #include "libavutil/common.h"
46 #include "ffmpeg_files/intreadwrite.h"
47 #include "stream/stream.h"
48 #include "aviprint.h"
49 #include "demuxer.h"
50 #include "stheader.h"
51 #include "demux_real.h"
52
53 //#define mp_dbg(mod,lev, args... ) mp_msg_c((mod<<8)|lev, ## args )
54
55 #define MAX_STREAMS 32
56
57 static unsigned char sipr_swaps[38][2]={
58 {0,63},{1,22},{2,44},{3,90},{5,81},{7,31},{8,86},{9,58},{10,36},{12,68},
59 {13,39},{14,73},{15,53},{16,69},{17,57},{19,88},{20,34},{21,71},{24,46},
60 {25,94},{26,54},{28,75},{29,50},{32,70},{33,92},{35,74},{38,85},{40,56},
61 {42,87},{43,65},{45,59},{48,79},{49,93},{51,89},{55,95},{61,76},{67,83},
62 {77,80} };
63
64 typedef struct {
65 unsigned int timestamp;
66 int offset;
67 // int packetno;
68 // int len; /* only filled by our index generator */
69 // int flags; /* only filled by our index generator */
70 } real_index_table_t;
71
72 typedef struct {
73 /* for seeking */
74 int index_chunk_offset;
75 real_index_table_t *index_table[MAX_STREAMS];
76
77 // int *index_table[MAX_STREAMS];
78 int index_table_size[MAX_STREAMS];
79 int index_malloc_size[MAX_STREAMS];
80 int data_chunk_offset;
81 int num_of_packets;
82 int current_packet;
83
84 // need for seek
85 int audio_need_keyframe;
86 int video_after_seek;
87
88 int current_apacket;
89 int current_vpacket;
90
91 // timestamp correction:
92 int64_t kf_base;// timestamp of the prev. video keyframe
93 unsigned int kf_pts; // timestamp of next video keyframe
94 unsigned int a_pts; // previous audio timestamp
95 double v_pts; // previous video timestamp
96 unsigned long duration;
97
98 /* stream id table */
99 // int last_a_stream;
100 // int a_streams[MAX_STREAMS];
101 // int last_v_stream;
102 // int v_streams[MAX_STREAMS];
103
104 /**
105 * Used to demux multirate files
106 */
107 int is_multirate; ///< != 0 for multirate files
108 int str_data_offset[MAX_STREAMS]; ///< Data chunk offset for every audio/video stream
109 int audio_curpos; ///< Current file position for audio demuxing
110 int video_curpos; ///< Current file position for video demuxing
111 int a_num_of_packets; ///< Number of audio packets
112 int v_num_of_packets; ///< Number of video packets
113 int a_bitrate; ///< Audio bitrate
114 int v_bitrate; ///< Video bitrate
115 int stream_switch; ///< Flag used to switch audio/video demuxing
116
117 /**
118 * Used to reorder audio data
119 */
120 unsigned int intl_id[MAX_STREAMS]; ///< interleaver id, per stream
121 int sub_packet_size[MAX_STREAMS]; ///< sub packet size, per stream
122 int sub_packet_h[MAX_STREAMS]; ///< number of coded frames per block
123 int coded_framesize[MAX_STREAMS]; ///< coded frame size, per stream
124 int audiopk_size[MAX_STREAMS]; ///< audio packet size
125 unsigned char *audio_buf; ///< place to store reordered audio data
126 double *audio_timestamp; ///< timestamp for each audio packet
127 int sub_packet_cnt; ///< number of subpacket already received
128 int audio_filepos; ///< file position of first audio packet in block
129 } real_priv_t;
130
131 //! use at most 200 MB of memory for index, corresponds to around 25 million entries
132 #define MAX_INDEX_ENTRIES (200*1024*1024 / sizeof(real_index_table_t))
133
134 /* originally from FFmpeg */
135 static void get_str(int isbyte, demuxer_t *demuxer, char *buf, int buf_size)
136 {
137 int len;
138
139 if (isbyte)
140 len = stream_read_char(demuxer->stream);
141 else
142 len = stream_read_word(demuxer->stream);
143
144 stream_read(demuxer->stream, buf, (len > buf_size) ? buf_size : len);
145 if (len > buf_size)
146 stream_skip(demuxer->stream, len-buf_size);
147
148 mp_msg(MSGT_DEMUX, MSGL_V, "read_str: %d bytes read\n", len);
149 }
150
151 static void dump_index(demuxer_t *demuxer, int stream_id)
152 {
153 real_priv_t *priv = demuxer->priv;
154 real_index_table_t *index;
155 int i, entries;
156
157 if (!mp_msg_test(MSGT_DEMUX,MSGL_V))
158 return;
159
160 if ((unsigned)stream_id >= MAX_STREAMS)
161 return;
162
163 index = priv->index_table[stream_id];
164 entries = priv->index_table_size[stream_id];
165
166 mp_msg(MSGT_DEMUX, MSGL_V, "Index table for stream %d\n", stream_id);
167 for (i = 0; i < entries; i++)
168 {
169 #if 1
170 mp_msg(MSGT_DEMUX, MSGL_V,"i: %d, pos: %d, timestamp: %u\n", i, index[i].offset, index[i].timestamp);
171 #else
172 mp_msg(MSGT_DEMUX, MSGL_V,"packetno: %x pos: %x len: %x timestamp: %x flags: %x\n",
173 index[i].packetno, index[i].offset, index[i].len, index[i].timestamp,
174 index[i].flags);
175 #endif
176 }
177 }
178
179 static int parse_index_chunk(demuxer_t *demuxer)
180 {
181 real_priv_t *priv = demuxer->priv;
182 int origpos = stream_tell(demuxer->stream);
183 int next_header_pos = priv->index_chunk_offset;
184 int i, entries, stream_id;
185
186 read_index:
187 stream_seek(demuxer->stream, next_header_pos);
188
189 i = stream_read_dword_le(demuxer->stream);
190 if ((i == -256) || (i != MKTAG('I', 'N', 'D', 'X')))
191 {
192 mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no index chunk found on given address (%d)\n",
193 next_header_pos);
194 index_mode = -1;
195 if (i == -256)
196 stream_reset(demuxer->stream);
197 stream_seek(demuxer->stream, origpos);
198 return 0;
199 //goto end;
200 }
201
202 mp_msg(MSGT_DEMUX, MSGL_V,"Reading index table from index chunk (%d)\n",
203 next_header_pos);
204
205 i = stream_read_dword(demuxer->stream);
206 mp_msg(MSGT_DEMUX, MSGL_V,"size: %d bytes\n", i);
207
208 i = stream_read_word(demuxer->stream);
209 if (i != 0)
210 mp_msg(MSGT_DEMUX, MSGL_WARN,"Hmm, index table with unknown version (%d), please report it to MPlayer developers!\n", i);
211
212 entries = stream_read_dword(demuxer->stream);
213 mp_msg(MSGT_DEMUX, MSGL_V,"entries: %d\n", entries);
214
215 stream_id = stream_read_word(demuxer->stream);
216 mp_msg(MSGT_DEMUX, MSGL_V,"stream_id: %d\n", stream_id);
217
218 next_header_pos = stream_read_dword(demuxer->stream);
219 mp_msg(MSGT_DEMUX, MSGL_V,"next_header_pos: %d\n", next_header_pos);
220 if (entries <= 0 || entries > MAX_INDEX_ENTRIES)
221 {
222 if (next_header_pos)
223 goto read_index;
224 i = entries;
225 goto end;
226 }
227
228 priv->index_table_size[stream_id] = entries;
229 priv->index_table[stream_id] = calloc(priv->index_table_size[stream_id], sizeof(real_index_table_t));
230
231 for (i = 0; i < entries; i++)
232 {
233 stream_skip(demuxer->stream, 2); /* version */
234 priv->index_table[stream_id][i].timestamp = stream_read_dword(demuxer->stream);
235 priv->index_table[stream_id][i].offset = stream_read_dword(demuxer->stream);
236 stream_skip(demuxer->stream, 4); /* packetno */
237 // priv->index_table[stream_id][i].packetno = stream_read_dword(demuxer->stream);
238 // printf("Index table: Stream#%d: entry: %d: pos: %d\n",
239 // stream_id, i, priv->index_table[stream_id][i].offset);
240 }
241
242 dump_index(demuxer, stream_id);
243
244 if (next_header_pos > 0)
245 goto read_index;
246
247 end:
248 if (i == -256)
249 stream_reset(demuxer->stream);
250 stream_seek(demuxer->stream, origpos);
251 if (i == -256)
252 return 0;
253 else
254 return 1;
255 }
256
257 #if 1
258
259 static void add_index_item(demuxer_t *demuxer, int stream_id, unsigned int timestamp, int offset)
260 {
261 if ((unsigned)stream_id < MAX_STREAMS)
262 {
263 real_priv_t *priv = demuxer->priv;
264 real_index_table_t *index;
265 if (priv->index_table_size[stream_id] >= MAX_INDEX_ENTRIES) {
266 mp_msg(MSGT_DEMUXER, MSGL_WARN, "Index too large during building\n");
267 return;
268 }
269 if (priv->index_table_size[stream_id] >= priv->index_malloc_size[stream_id])
270 {
271 if (priv->index_malloc_size[stream_id] == 0)
272 priv->index_malloc_size[stream_id] = 2048;
273 else
274 priv->index_malloc_size[stream_id] += priv->index_malloc_size[stream_id] / 2;
275 // in case we have a really large chunk...
276 if (priv->index_table_size[stream_id] >=
277 priv->index_malloc_size[stream_id])
278 priv->index_malloc_size[stream_id] =
279 priv->index_table_size[stream_id] + 1;
280 priv->index_table[stream_id] = realloc(priv->index_table[stream_id], priv->index_malloc_size[stream_id]*sizeof(priv->index_table[0][0]));
281 }
282 if (priv->index_table_size[stream_id] > 0)
283 {
284 index = &priv->index_table[stream_id][priv->index_table_size[stream_id] - 1];
285 if (index->timestamp >= timestamp || index->offset >= offset)
286 return;
287 }
288 index = &priv->index_table[stream_id][priv->index_table_size[stream_id]++];
289 index->timestamp = timestamp;
290 index->offset = offset;
291 }
292 }
293
294 static void add_index_segment(demuxer_t *demuxer, int seek_stream_id, int64_t seek_timestamp)
295 {
296 int tag, len, stream_id, flags;
297 unsigned int timestamp;
298 if (seek_timestamp != -1 && (unsigned)seek_stream_id >= MAX_STREAMS)
299 return;
300 while (1)
301 {
302 demuxer->filepos = stream_tell(demuxer->stream);
303
304 tag = stream_read_dword(demuxer->stream);
305 if (tag == MKTAG('A', 'T', 'A', 'D'))
306 {
307 stream_skip(demuxer->stream, 14);
308 continue; /* skip to next loop */
309 }
310 len = tag & 0xffff;
311 if (tag == -256 || len < 12)
312 break;
313
314 stream_id = stream_read_word(demuxer->stream);
315 timestamp = stream_read_dword(demuxer->stream);
316
317 stream_skip(demuxer->stream, 1); /* reserved */
318 flags = stream_read_char(demuxer->stream);
319
320 if (flags == -256)
321 break;
322
323 if (flags & 2)
324 {
325 add_index_item(demuxer, stream_id, timestamp, demuxer->filepos);
326 if (stream_id == seek_stream_id && timestamp >= seek_timestamp)
327 {
328 stream_seek(demuxer->stream, demuxer->filepos);
329 return;
330 }
331 }
332 // 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);
333 /* skip data */
334 stream_skip(demuxer->stream, len-12);
335 }
336 }
337
338 static int generate_index(demuxer_t *demuxer)
339 {
340 real_priv_t *priv = demuxer->priv;
341 int origpos = stream_tell(demuxer->stream);
342 int data_pos = priv->data_chunk_offset-10;
343 int i;
344 int tag;
345
346 stream_seek(demuxer->stream, data_pos);
347 tag = stream_read_dword(demuxer->stream);
348 if (tag != MKTAG('A', 'T', 'A', 'D'))
349 {
350 mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no data chunk found on given address (%d)\n", data_pos);
351 }
352 else
353 {
354 stream_skip(demuxer->stream, 14);
355 add_index_segment(demuxer, -1, -1);
356 }
357 for (i = 0; i < MAX_STREAMS; i++)
358 {
359 if (priv->index_table_size[i] > 0)
360 {
361 dump_index(demuxer, i);
362 }
363 }
364 stream_reset(demuxer->stream);
365 stream_seek(demuxer->stream, origpos);
366 return 0;
367 }
368
369 #else
370
371 static int generate_index(demuxer_t *demuxer)
372 {
373 real_priv_t *priv = demuxer->priv;
374 int origpos = stream_tell(demuxer->stream);
375 int data_pos = priv->data_chunk_offset-10;
376 int num_of_packets = 0;
377 int i, entries = 0;
378 int len, stream_id = 0, flags;
379 unsigned int timestamp;
380 int tab_pos = 0;
381
382 read_index:
383 stream_seek(demuxer->stream, data_pos);
384
385 i = stream_read_dword_le(demuxer->stream);
386 if ((i == -256) || (i != MKTAG('D', 'A', 'T', 'A')))
387 {
388 mp_msg(MSGT_DEMUX, MSGL_WARN,"Something went wrong, no data chunk found on given address (%d)\n",
389 data_pos);
390 goto end;
391 }
392 stream_skip(demuxer->stream, 4); /* chunk size */
393 stream_skip(demuxer->stream, 2); /* version */
394
395 num_of_packets = stream_read_dword(demuxer->stream);
396 mp_msg(MSGT_DEMUX, MSGL_V,"Generating index table from raw data (pos: 0x%x) for %d packets\n",
397 data_pos, num_of_packets);
398
399 data_pos = stream_read_dword_le(demuxer->stream)-10; /* next data chunk */
400
401 for (i = 0; i < MAX_STREAMS; i++)
402 {
403 priv->index_table_size[i] = num_of_packets;
404 priv->index_table[i] = calloc(priv->index_table_size[i], sizeof(real_index_table_t));
405 // priv->index_table[stream_id] = realloc(priv->index_table[stream_id],
406 // priv->index_table_size[stream_id] * sizeof(real_index_table_t));
407 }
408
409 tab_pos = 0;
410
411 // memset(priv->index_table_size, 0, sizeof(int)*MAX_STREAMS);
412 // memset(priv->index_table, 0, sizeof(real_index_table_t)*MAX_STREAMS);
413
414 while (tab_pos < num_of_packets)
415 {
416 i = stream_read_char(demuxer->stream);
417 if (i == -256)
418 goto end;
419 stream_skip(demuxer->stream, 1);
420 // stream_skip(demuxer->stream, 2); /* version */
421
422 len = stream_read_word(demuxer->stream);
423 stream_id = stream_read_word(demuxer->stream);
424 timestamp = stream_read_dword(demuxer->stream);
425
426 stream_skip(demuxer->stream, 1); /* reserved */
427 flags = stream_read_char(demuxer->stream);
428
429 i = tab_pos;
430
431 // priv->index_table_size[stream_id] = i;
432 // if (priv->index_table[stream_id] == NULL)
433 // priv->index_table[stream_id] = malloc(priv->index_table_size[stream_id] * sizeof(real_index_table_t));
434 // else
435 // priv->index_table[stream_id] = realloc(priv->index_table[stream_id],
436 // priv->index_table_size[stream_id] * sizeof(real_index_table_t));
437
438 priv->index_table[stream_id][i].timestamp = timestamp;
439 priv->index_table[stream_id][i].offset = stream_tell(demuxer->stream)-12;
440 priv->index_table[stream_id][i].len = len;
441 priv->index_table[stream_id][i].packetno = entries;
442 priv->index_table[stream_id][i].flags = flags;
443
444 tab_pos++;
445
446 /* skip data */
447 stream_skip(demuxer->stream, len-12);
448 }
449 dump_index(demuxer, stream_id);
450 if (data_pos)
451 goto read_index;
452
453 end:
454 if (i == -256)
455 stream_reset(demuxer->stream);
456 stream_seek(demuxer->stream, origpos);
457 if (i == -256)
458 return 0;
459 else
460 return 1;
461 }
462 #endif
463
464
465 static int real_check_file(demuxer_t* demuxer)
466 {
467 real_priv_t *priv;
468 int c;
469
470 mp_msg(MSGT_DEMUX,MSGL_V,"Checking for REAL\n");
471
472 c = stream_read_dword_le(demuxer->stream);
473 if (c == -256)
474 return 0; /* EOF */
475 if (c != MKTAG('.', 'R', 'M', 'F'))
476 return 0; /* bad magic */
477
478 priv = calloc(1, sizeof(real_priv_t));
479 demuxer->priv = priv;
480
481 return DEMUXER_TYPE_REAL;
482 }
483
484 #define SKIP_BITS(n) buffer<<=n
485 #define SHOW_BITS(n) ((buffer)>>(32-(n)))
486
487 double real_fix_timestamp(unsigned char *buf, unsigned int timestamp, unsigned int format, int64_t *kf_base, int *kf_pts, double *pts){
488 double v_pts;
489 unsigned char *s = buf + 1 + (*buf+1)*8;
490 uint32_t buffer= (s[0]<<24) + (s[1]<<16) + (s[2]<<8) + s[3];
491 unsigned int kf=timestamp;
492 int pict_type;
493 unsigned int orig_kf;
494
495 if(format==mmioFOURCC('R','V','3','0') || format==mmioFOURCC('R','V','4','0')){
496 if(format==mmioFOURCC('R','V','3','0')){
497 SKIP_BITS(3);
498 pict_type= SHOW_BITS(2);
499 SKIP_BITS(2 + 7);
500 }else{
501 SKIP_BITS(1);
502 pict_type= SHOW_BITS(2);
503 SKIP_BITS(2 + 7 + 3);
504 }
505 orig_kf=
506 kf= SHOW_BITS(13); // kf= 2*SHOW_BITS(12);
507 // if(pict_type==0)
508 if(pict_type<=1){
509 // I frame, sync timestamps:
510 *kf_base=(int64_t)timestamp-kf;
511 mp_msg(MSGT_DEMUX, MSGL_DBG2,"\nTS: base=%08"PRIX64"\n",*kf_base);
512 kf=timestamp;
513 } else {
514 // P/B frame, merge timestamps:
515 int64_t tmp=(int64_t)timestamp-*kf_base;
516 kf|=tmp&(~0x1fff); // combine with packet timestamp
517 if(kf<tmp-4096) kf+=8192; else // workaround wrap-around problems
518 if(kf>tmp+4096) kf-=8192;
519 kf+=*kf_base;
520 }
521 if(pict_type != 3){ // P || I frame -> swap timestamps
522 unsigned int tmp=kf;
523 kf=*kf_pts;
524 *kf_pts=tmp;
525 // if(kf<=tmp) kf=0;
526 }
527 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);
528 }
529 v_pts=kf*0.001f;
530 // if(pts && (v_pts<*pts || !kf)) v_pts=*pts+frametime;
531 if(pts) *pts=v_pts;
532 return v_pts;
533 }
534
535 typedef struct dp_hdr_s {
536 uint32_t chunks; // number of chunks
537 uint32_t timestamp; // timestamp from packet header
538 uint32_t len; // length of actual data
539 uint32_t chunktab; // offset to chunk offset array
540 } dp_hdr_t;
541
542 static void queue_video_packet(real_priv_t *priv, demux_stream_t *ds, demux_packet_t *dp)
543 {
544 dp_hdr_t hdr = *(dp_hdr_t*)dp->buffer;
545 unsigned char *tmp = malloc(8*(1+hdr.chunks));
546 memcpy(tmp, dp->buffer+hdr.chunktab, 8*(1+hdr.chunks));
547 memmove(dp->buffer+1+8*(1+hdr.chunks), dp->buffer+sizeof(dp_hdr_t), hdr.len);
548 memcpy(dp->buffer+1, tmp, 8*(1+hdr.chunks));
549 *dp->buffer = (uint8_t)hdr.chunks;
550 free(tmp);
551
552 if(priv->video_after_seek){
553 priv->kf_base = 0;
554 priv->kf_pts = hdr.timestamp;
555 priv->video_after_seek = 0;
556 }
557 if(hdr.len >= 3) /* this check may be useless */
558 dp->pts = real_fix_timestamp(dp->buffer, hdr.timestamp,
559 ((sh_video_t *)ds->sh)->format,
560 &priv->kf_base, &priv->kf_pts,
561 &priv->v_pts);
562 ds_add_packet(ds, dp);
563 }
564
565 // return value:
566 // 0 = EOF or no stream found
567 // 1 = successfully read a packet
568 static int demux_real_fill_buffer(demuxer_t *demuxer, demux_stream_t *dsds)
569 {
570 real_priv_t *priv = demuxer->priv;
571 demux_stream_t *ds = NULL;
572 int len;
573 unsigned int timestamp;
574 int stream_id;
575 #ifdef CRACK_MATRIX
576 int i;
577 #endif
578 int flags;
579 int version;
580 int reserved;
581 demux_packet_t *dp;
582 int x, sps, cfs, sph, spc, w;
583 int audioreorder_getnextpk = 0;
584
585 // Don't demux video if video codec init failed
586 if (demuxer->video->id >= 0 && !demuxer->video->sh)
587 demuxer->video->id = -2;
588
589 while(!stream_eof(demuxer->stream)){
590
591 /* Handle audio/video demxing switch for multirate files (non-interleaved) */
592 if (priv->is_multirate && priv->stream_switch) {
593 if (priv->current_apacket >= priv->index_table_size[demuxer->audio->id])
594 demuxer->audio->eof = 1;
595 if (priv->current_vpacket >= priv->index_table_size[demuxer->video->id])
596 demuxer->video->eof = 1;
597 if (demuxer->audio->eof && demuxer->video->eof)
598 return 0;
599 else if (!demuxer->audio->eof && demuxer->video->eof)
600 stream_seek(demuxer->stream, priv->audio_curpos); // Get audio
601 else if (demuxer->audio->eof && !demuxer->video->eof)
602 stream_seek(demuxer->stream, priv->video_curpos); // Get video
603 else if (priv->index_table[demuxer->audio->id][priv->current_apacket].timestamp <
604 priv->index_table[demuxer->video->id][priv->current_vpacket].timestamp)
605 stream_seek(demuxer->stream, priv->audio_curpos); // Get audio
606 else
607 stream_seek(demuxer->stream, priv->video_curpos); // Get video
608 priv->stream_switch = 0;
609 }
610
611 demuxer->filepos = stream_tell(demuxer->stream);
612 version = stream_read_word(demuxer->stream); /* version */
613 len = stream_read_word(demuxer->stream);
614 if ((version==0x4441) && (len==0x5441)) { // new data chunk
615 mp_msg(MSGT_DEMUX,MSGL_INFO,"demux_real: New data chunk is coming!!!\n");
616 if (priv->is_multirate)
617 return 0; // EOF
618 stream_skip(demuxer->stream,14);
619 demuxer->filepos = stream_tell(demuxer->stream);
620 version = stream_read_word(demuxer->stream); /* version */
621 len = stream_read_word(demuxer->stream);
622 } else if ((version == 0x494e) && (len == 0x4458)) {
623 mp_msg(MSGT_DEMUX,MSGL_V,"demux_real: Found INDX chunk. EOF.\n");
624 demuxer->stream->eof=1;
625 return 0;
626 }
627
628
629 if (len == -256){ /* EOF */
630 // printf("len==-256!\n");
631 return 0;
632 }
633 if (len < 12){
634 mp_msg(MSGT_DEMUX, MSGL_V,"%08X: packet v%d len=%d \n",(int)demuxer->filepos,(int)version,(int)len);
635 mp_msg(MSGT_DEMUX, MSGL_WARN,"bad packet len (%d)\n", len);
636 if ((unsigned)demuxer->video->id < MAX_STREAMS) {
637 if (priv->current_vpacket + 1 < priv->index_table_size[demuxer->video->id]) {
638 stream_seek(demuxer->stream, priv->index_table[demuxer->video->id][++priv->current_vpacket].offset);
639 }
640 } else if ((unsigned)demuxer->audio->id < MAX_STREAMS) {
641 if (priv->current_apacket + 1 < priv->index_table_size[demuxer->audio->id]) {
642 stream_seek(demuxer->stream, priv->index_table[demuxer->audio->id][++priv->current_apacket].offset);
643 }
644 }
645 continue; //goto loop;
646 }
647
648 stream_id = stream_read_word(demuxer->stream);
649 timestamp = stream_read_dword(demuxer->stream);
650 reserved = stream_read_char(demuxer->stream);
651 flags = stream_read_char(demuxer->stream);
652 /* flags: */
653 /* 0x1 - reliable */
654 /* 0x2 - keyframe */
655
656 if (version == 1) {
657 int tmp;
658 tmp = stream_read_char(demuxer->stream);
659 mp_msg(MSGT_DEMUX, MSGL_DBG2,"Version: %d, skipped byte is %d\n", version, tmp);
660 len--;
661 }
662
663 if (flags & 2)
664 add_index_item(demuxer, stream_id, timestamp, demuxer->filepos);
665
666 // printf("%08X: packet v%d len=%4d id=%d pts=%6d rvd=%d flags=%d \n",
667 // (int)demuxer->filepos,(int)version,(int)len, stream_id,
668 // (int) timestamp, reserved, flags);
669
670 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "\npacket#%d: pos: 0x%0x, len: %d, id: %d, pts: %u, flags: %x rvd:%d\n",
671 priv->current_packet, (int)demuxer->filepos, len, stream_id, timestamp, flags, reserved);
672
673 priv->current_packet++;
674 len -= 12;
675
676 // printf("s_id=%d aid=%d vid=%d \n",stream_id,demuxer->audio->id,demuxer->video->id);
677
678 /* check stream_id: */
679
680 if(demuxer->audio->id==stream_id){
681 if (priv->audio_need_keyframe == 1&& flags != 0x2)
682 goto discard;
683 got_audio:
684 ds=demuxer->audio;
685 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "packet is audio (id: %d)\n", stream_id);
686
687 if (flags & 2) {
688 priv->sub_packet_cnt = 0;
689 audioreorder_getnextpk = 0;
690 }
691
692 // parse audio chunk:
693 {
694 #ifdef CRACK_MATRIX
695 int spos=stream_tell(demuxer->stream);
696 static int cnt=0;
697 static int cnt2=CRACK_MATRIX;
698 #endif
699 if (((sh_audio_t *)ds->sh)->format == mmioFOURCC('M', 'P', '4', 'A')) {
700 uint16_t sub_packet_lengths[16], sub_packets, i;
701 int totlen = 0;
702 /* AAC in Real: several AAC frames in one Real packet. */
703 /* Second byte, upper four bits: number of AAC frames */
704 /* next n * 2 bytes: length of the AAC frames in bytes, BE */
705 if (len < 2)
706 goto discard;
707 sub_packets = (stream_read_word(demuxer->stream) & 0xf0) >> 4;
708 if (len < 2 * sub_packets)
709 goto discard;
710 for (i = 0; i < sub_packets; i++)
711 totlen += sub_packet_lengths[i] = stream_read_word(demuxer->stream);
712 if (len < totlen )
713 goto discard;
714 for (i = 0; i < sub_packets; i++) {
715 demux_packet_t *dp = new_demux_packet(sub_packet_lengths[i]);
716 stream_read(demuxer->stream, dp->buffer, sub_packet_lengths[i]);
717 if (priv->a_pts != timestamp)
718 dp->pts = timestamp / 1000.0;
719 priv->a_pts = timestamp;
720 dp->pos = demuxer->filepos;
721 ds_add_packet(ds, dp);
722 }
723 return 1;
724 }
725 if ((priv->intl_id[stream_id] == mmioFOURCC('I', 'n', 't', '4')) ||
726 (priv->intl_id[stream_id] == mmioFOURCC('g', 'e', 'n', 'r')) ||
727 (priv->intl_id[stream_id] == mmioFOURCC('s', 'i', 'p', 'r'))) {
728 sps = priv->sub_packet_size[stream_id];
729 sph = priv->sub_packet_h[stream_id];
730 cfs = priv->coded_framesize[stream_id];
731 w = priv->audiopk_size[stream_id];
732 spc = priv->sub_packet_cnt;
733 switch (priv->intl_id[stream_id]) {
734 case mmioFOURCC('I', 'n', 't', '4'):
735 if (len < cfs * sph/2)
736 goto discard;
737 for (x = 0; x < sph / 2; x++)
738 stream_read(demuxer->stream, priv->audio_buf + x * 2 * w + spc * cfs, cfs);
739 break;
740 case mmioFOURCC('g', 'e', 'n', 'r'):
741 if (len < w)
742 goto discard;
743 for (x = 0; x < w / sps; x++)
744 stream_read(demuxer->stream, priv->audio_buf + sps * (sph * x + ((sph + 1) / 2) * (spc & 1) +
745 (spc >> 1)), sps);
746 break;
747 case mmioFOURCC('s', 'i', 'p', 'r'):
748 if (len < w)
749 goto discard;
750 stream_read(demuxer->stream, priv->audio_buf + spc * w, w);
751 if (spc == sph - 1) {
752 int n;
753 int bs = sph * w * 2 / 96; // nibbles per subpacket
754 // Perform reordering
755 for(n=0; n < 38; n++) {
756 int j;
757 int i = bs * sipr_swaps[n][0];
758 int o = bs * sipr_swaps[n][1];
759 // swap nibbles of block 'i' with 'o' TODO: optimize
760 for(j = 0;j < bs; j++) {
761 int x = (i & 1) ? (priv->audio_buf[i >> 1] >> 4) : (priv->audio_buf[i >> 1] & 0x0F);
762 int y = (o & 1) ? (priv->audio_buf[o >> 1] >> 4) : (priv->audio_buf[o >> 1] & 0x0F);
763 if(o & 1)
764 priv->audio_buf[o >> 1] = (priv->audio_buf[o >> 1] & 0x0F) | (x << 4);
765 else
766 priv->audio_buf[o >> 1] = (priv->audio_buf[o >> 1] & 0xF0) | x;
767 if(i & 1)
768 priv->audio_buf[i >> 1] = (priv->audio_buf[i >> 1] & 0x0F) | (y << 4);
769 else
770 priv->audio_buf[i >> 1] = (priv->audio_buf[i >> 1] & 0xF0) | y;
771 ++i; ++o;
772 }
773 }
774 }
775 break;
776 }
777 priv->audio_need_keyframe = 0;
778 priv->audio_timestamp[priv->sub_packet_cnt] = (priv->a_pts==timestamp) ? MP_NOPTS_VALUE : (timestamp/1000.0);
779 priv->a_pts = timestamp;
780 if (priv->sub_packet_cnt == 0)
781 priv->audio_filepos = demuxer->filepos;
782 if (++(priv->sub_packet_cnt) < sph)
783 audioreorder_getnextpk = 1;
784 else {
785 int apk_usize = ((sh_audio_t*)ds->sh)->wf->nBlockAlign;
786 audioreorder_getnextpk = 0;
787 priv->sub_packet_cnt = 0;
788 // Release all the audio packets
789 for (x = 0; x < sph*w/apk_usize; x++) {
790 dp = new_demux_packet(apk_usize);
791 memcpy(dp->buffer, priv->audio_buf + x * apk_usize, apk_usize);
792 /* Put timestamp only on packets that correspond to original audio packets in file */
793 if (x * apk_usize % w == 0)
794 dp->pts = priv->audio_timestamp[x * apk_usize / w];
795 dp->pos = priv->audio_filepos; // all equal
796 dp->flags = x ? 0 : 0x10; // Mark first packet as keyframe
797 ds_add_packet(ds, dp);
798 }
799 }
800 } else { // No interleaving
801 dp = new_demux_packet(len);
802 stream_read(demuxer->stream, dp->buffer, len);
803
804 #ifdef CRACK_MATRIX
805 mp_msg(MSGT_DEMUX, MSGL_V,"*** audio block len=%d\n",len);
806 { // HACK - used for reverse engineering the descrambling matrix
807 FILE* f=fopen("test.rm","r+");
808 fseek(f,spos,SEEK_SET);
809 ++cnt;
810 // for(i=0;i<len;i++) dp->buffer[i]=i/0x12;
811 // for(i=0;i<len;i++) dp->buffer[i]=i;
812 // for(i=0;i<len;i++) dp->buffer[i]=cnt;
813 // for(i=0;i<len;i++) dp->buffer[i]=cnt<<4;
814 for(i=0;i<len;i++) dp->buffer[i]=(i==cnt2) ? (cnt+16*(8+cnt)) : 0;
815 if(cnt==6){ cnt=0; ++cnt2; }
816 fwrite(dp->buffer, len, 1, f);
817 fclose(f);
818 if(cnt2>0x150) *((int*)NULL)=1; // sig11 :)
819 }
820 #endif
821 #if 0
822 if( ((sh_audio_t *)ds->sh)->format == 0x2000) {
823 // if DNET, swap bytes, as DNET is byte-swapped AC3:
824 char *ptr = dp->buffer;
825 int i;
826 for (i = 0; i < len; i += 2)
827 {
828 const char tmp = ptr[0];
829 ptr[0] = ptr[1];
830 ptr[1] = tmp;
831 ptr += 2;
832 }
833 }
834 #endif
835 if (priv->audio_need_keyframe == 1) {
836 priv->audio_need_keyframe = 0;
837 } else if(priv->a_pts != timestamp)
838 dp->pts = timestamp/1000.0;
839 priv->a_pts=timestamp;
840 dp->pos = demuxer->filepos;
841 dp->flags = (flags & 0x2) ? 0x10 : 0;
842 ds_add_packet(ds, dp);
843
844 } // codec_id check, codec default case
845 }
846 // we will not use audio index if we use -idx and have a video
847 if(((!demuxer->video->sh && index_mode == 2) || priv->is_multirate) && (unsigned)demuxer->audio->id < MAX_STREAMS) {
848 while (priv->current_apacket + 1 < priv->index_table_size[demuxer->audio->id] &&
849 timestamp > priv->index_table[demuxer->audio->id][priv->current_apacket].timestamp) {
850 priv->current_apacket += 1;
851 priv->stream_switch = 1;
852 }
853 if (priv->stream_switch)
854 priv->audio_curpos = stream_tell(demuxer->stream);
855 }
856
857 // If we're reordering audio packets and we need more data get it
858 if (audioreorder_getnextpk)
859 continue;
860
861 return 1;
862 }
863
864 if(demuxer->video->id==stream_id){
865 got_video:
866 ds=demuxer->video;
867 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "packet is video (id: %d)\n", stream_id);
868
869 // parse video chunk:
870 {
871 // we need a more complicated, 2nd level demuxing, as the video
872 // frames are stored fragmented in the video chunks :(
873 sh_video_t *sh_video = ds->sh;
874 demux_packet_t *dp;
875 unsigned vpkg_header, vpkg_length, vpkg_offset;
876 int vpkg_seqnum=-1;
877 int vpkg_subseq=0;
878
879 while(len>2){
880 dp_hdr_t* dp_hdr;
881 unsigned char* dp_data;
882 uint8_t* extra;
883
884 // printf("xxx len=%d \n",len);
885
886 // read packet header
887 // bit 7: 1=last block in block chain
888 // bit 6: 1=short header (only one block?)
889 vpkg_header=stream_read_char(demuxer->stream); --len;
890 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "hdr: %02X (len=%d) ",vpkg_header,len);
891
892 if (0x40==(vpkg_header&0xc0)) {
893 // seems to be a very short header
894 // 2 bytes, purpose of the second byte yet unknown
895 int bummer;
896 bummer=stream_read_char(demuxer->stream); --len;
897 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "%02X",bummer);
898 vpkg_offset=0;
899 vpkg_length=len;
900 } else {
901
902 if (0==(vpkg_header&0x40)) {
903 // sub-seqnum (bits 0-6: number of fragment. bit 7: ???)
904 vpkg_subseq=stream_read_char(demuxer->stream);
905 --len;
906 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "subseq: %02X ",vpkg_subseq);
907 vpkg_subseq&=0x7f;
908 }
909
910 // size of the complete packet
911 // bit 14 is always one (same applies to the offset)
912 vpkg_length=stream_read_word(demuxer->stream);
913 len-=2;
914 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "l: %02X %02X ",vpkg_length>>8,vpkg_length&0xff);
915 if (!(vpkg_length&0xC000)) {
916 vpkg_length<<=16;
917 vpkg_length|=(uint16_t)stream_read_word(demuxer->stream);
918 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "l+: %02X %02X ",(vpkg_length>>8)&0xff,vpkg_length&0xff);
919 len-=2;
920 } else
921 vpkg_length&=0x3fff;
922
923 // offset of the following data inside the complete packet
924 // Note: if (hdr&0xC0)==0x80 then offset is relative to the
925 // _end_ of the packet, so it's equal to fragment size!!!
926 vpkg_offset=stream_read_word(demuxer->stream);
927 len-=2;
928 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "o: %02X %02X ",vpkg_offset>>8,vpkg_offset&0xff);
929 if (!(vpkg_offset&0xC000)) {
930 vpkg_offset<<=16;
931 vpkg_offset|=(uint16_t)stream_read_word(demuxer->stream);
932 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "o+: %02X %02X ",(vpkg_offset>>8)&0xff,vpkg_offset&0xff);
933 len-=2;
934 } else
935 vpkg_offset&=0x3fff;
936
937 vpkg_seqnum=stream_read_char(demuxer->stream); --len;
938 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "seq: %02X ",vpkg_seqnum);
939 }
940 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "\n");
941 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "blklen=%d\n", len);
942 mp_msg(MSGT_DEMUX,MSGL_DBG2, "block: hdr=0x%0x, len=%d, offset=%d, seqnum=%d\n",
943 vpkg_header, vpkg_length, vpkg_offset, vpkg_seqnum);
944
945 if(ds->asf_packet){
946 dp=ds->asf_packet;
947 dp_hdr=(dp_hdr_t*)dp->buffer;
948 dp_data=dp->buffer+sizeof(dp_hdr_t);
949 extra=dp->buffer+dp_hdr->chunktab;
950 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "we have an incomplete packet (oldseq=%d new=%d)\n",ds->asf_seq,vpkg_seqnum);
951 // we have an incomplete packet:
952 if(ds->asf_seq!=vpkg_seqnum){
953 // this fragment is for new packet, close the old one
954 mp_msg(MSGT_DEMUX,MSGL_DBG2, "closing probably incomplete packet, len: %d \n",dp->len);
955 queue_video_packet(priv, ds, dp);
956 ds->asf_packet=NULL;
957 } else {
958 // append data to it!
959 ++dp_hdr->chunks;
960 mp_msg(MSGT_DEMUX,MSGL_DBG2,"[chunks=%d subseq=%d]\n",dp_hdr->chunks,vpkg_subseq);
961 if(dp_hdr->chunktab+8*(1+dp_hdr->chunks)>dp->len){
962 // increase buffer size, this should not happen!
963 mp_msg(MSGT_DEMUX,MSGL_WARN, "chunktab buffer too small!!!!!\n");
964 dp->len=dp_hdr->chunktab+8*(4+dp_hdr->chunks);
965 dp->buffer=realloc(dp->buffer,dp->len+MP_INPUT_BUFFER_PADDING_SIZE);
966 memset(dp->buffer + dp->len, 0, MP_INPUT_BUFFER_PADDING_SIZE);
967 // re-calc pointers:
968 dp_hdr=(dp_hdr_t*)dp->buffer;
969 dp_data=dp->buffer+sizeof(dp_hdr_t);
970 extra=dp->buffer+dp_hdr->chunktab;
971 }
972 AV_WL32(extra + 8*dp_hdr->chunks + 0, 1);
973 AV_WL32(extra + 8*dp_hdr->chunks + 4, dp_hdr->len);
974 if(0x80==(vpkg_header&0xc0)){
975 // last fragment!
976 if(dp_hdr->len!=vpkg_length-vpkg_offset)
977 mp_msg(MSGT_DEMUX,MSGL_V,"warning! assembled.len=%d frag.len=%d total.len=%d \n",dp->len,vpkg_offset,vpkg_length-vpkg_offset);
978 if (vpkg_offset > dp->len - sizeof(dp_hdr_t) - dp_hdr->len) vpkg_offset = dp->len - sizeof(dp_hdr_t) - dp_hdr->len;
979 stream_read(demuxer->stream, dp_data+dp_hdr->len, vpkg_offset);
980 if((dp_data[dp_hdr->len]&0x20) && (sh_video->format==0x30335652)) --dp_hdr->chunks; else
981 dp_hdr->len+=vpkg_offset;
982 len-=vpkg_offset;
983 mp_dbg(MSGT_DEMUX,MSGL_DBG2, "fragment (%d bytes) appended, %d bytes left\n",vpkg_offset,len);
984 // we know that this is the last fragment -> we can close the packet!
985 queue_video_packet(priv, ds, dp);
986 ds->asf_packet=NULL;
987 // continue parsing
988 continue;
989 }
990 // non-last fragment:
991 if(dp_hdr->len!=vpkg_offset)
992 mp_msg(MSGT_DEMUX,MSGL_V,"warning! assembled.len=%d offset=%d frag.len=%d total.len=%d \n",dp->len,vpkg_offset,len,vpkg_length);
993 if (len > dp->len - sizeof(dp_hdr_t) - dp_hdr->len) len = dp->len - sizeof(dp_hdr_t) - dp_hdr->len;
994 stream_read(demuxer->stream, dp_data+dp_hdr->len, len);
995 if((dp_data[dp_hdr->len]&0x20) && (sh_video->format==0x30335652)) --dp_hdr->chunks; else
996 dp_hdr->len+=len;
997 len=0;
998 break; // no more fragments in this chunk!
999 }
1000 }
1001 // create new packet!
1002 dp = new_demux_packet(sizeof(dp_hdr_t)+vpkg_length+8*(1+2*(vpkg_header&0x3F)));
1003 // the timestamp seems to be in milliseconds
1004 dp->pos = demuxer->filepos;
1005 dp->flags = (flags & 0x2) ? 0x10 : 0;
1006 ds->asf_seq = vpkg_seqnum;
1007 dp_hdr=(dp_hdr_t*)dp->buffer;
1008 dp_hdr->chunks=0;
1009 dp_hdr->timestamp=timestamp;
1010 dp_hdr->chunktab=sizeof(dp_hdr_t)+vpkg_length;
1011 dp_data=dp->buffer+sizeof(dp_hdr_t);
1012 extra=dp->buffer+dp_hdr->chunktab;
1013 AV_WL32(extra, 1); AV_WL32(extra + 4, 0); // offset of the first chunk
1014 if(0x00==(vpkg_header&0xc0)){
1015 // first fragment:
1016 if (len > dp->len - sizeof(dp_hdr_t)) len = dp->len - sizeof(dp_hdr_t);
1017 dp_hdr->len=len;
1018 stream_read(demuxer->stream, dp_data, len);
1019 ds->asf_packet=dp;
1020 len=0;
1021 break;
1022 }
1023 // whole packet (not fragmented):
1024 if (vpkg_length > len) {
1025 mp_msg(MSGT_DEMUX, MSGL_WARN,"\n******** WARNING: vpkg_length=%i > len=%i ********\n", vpkg_length, len);
1026 /*
1027 * To keep the video stream rolling, we need to break
1028 * here. We shouldn't touch len to make sure rest of the
1029 * broken packet is skipped.
1030 */
1031 break;
1032 }
1033 dp_hdr->len=vpkg_length; len-=vpkg_length;
1034 stream_read(demuxer->stream, dp_data, vpkg_length);
1035 queue_video_packet(priv, ds, dp);
1036
1037 } // while(len>0)
1038
1039 if(len){
1040 mp_msg(MSGT_DEMUX, MSGL_WARN,"\n******** !!!!!!!! BUG!! len=%d !!!!!!!!!!! ********\n",len);
1041 if(len>0) stream_skip(demuxer->stream, len);
1042 }
1043 }
1044 if ((unsigned)demuxer->video->id < MAX_STREAMS) {
1045 while (priv->current_vpacket + 1 < priv->index_table_size[demuxer->video->id] &&
1046 timestamp > priv->index_table[demuxer->video->id][priv->current_vpacket + 1].timestamp) {
1047 priv->current_vpacket += 1;
1048 priv->stream_switch = 1;
1049 }
1050 if (priv->stream_switch)
1051 priv->video_curpos = stream_tell(demuxer->stream);
1052 }
1053
1054 return 1;
1055 }
1056
1057 if((unsigned)stream_id<MAX_STREAMS){
1058
1059 if(demuxer->audio->id==-1 && demuxer->a_streams[stream_id]){
1060 sh_audio_t *sh = demuxer->a_streams[stream_id];
1061 demuxer->audio->id=stream_id;
1062 sh->ds=demuxer->audio;
1063 demuxer->audio->sh=sh;
1064 priv->audio_buf = calloc(priv->sub_packet_h[demuxer->audio->id], priv->audiopk_size[demuxer->audio->id]);
1065 priv->audio_timestamp = calloc(priv->sub_packet_h[demuxer->audio->id], sizeof(double));
1066 mp_msg(MSGT_DEMUX,MSGL_V,"Auto-selected RM audio ID = %d\n",stream_id);
1067 goto got_audio;
1068 }
1069
1070 if(demuxer->video->id==-1 && demuxer->v_streams[stream_id]){
1071 sh_video_t *sh = demuxer->v_streams[stream_id];
1072 demuxer->video->id=stream_id;
1073 sh->ds=demuxer->video;
1074 demuxer->video->sh=sh;
1075 mp_msg(MSGT_DEMUX,MSGL_V,"Auto-selected RM video ID = %d\n",stream_id);
1076 goto got_video;
1077 }
1078
1079 }
1080
1081 mp_msg(MSGT_DEMUX,MSGL_DBG2, "unknown stream id (%d)\n", stream_id);
1082 discard:
1083 stream_skip(demuxer->stream, len);
1084 }// goto loop;
1085 return 0;
1086 }
1087
1088 static demuxer_t* demux_open_real(demuxer_t* demuxer)
1089 {
1090 real_priv_t* priv = demuxer->priv;
1091 int num_of_headers;
1092 int a_streams=0;
1093 int v_streams=0;
1094 int i;
1095 int header_size;
1096
1097 header_size = stream_read_dword(demuxer->stream); /* header size */
1098 mp_msg(MSGT_DEMUX,MSGL_V, "real: Header size: %d\n", header_size);
1099 i = stream_read_word(demuxer->stream); /* version */
1100 mp_msg(MSGT_DEMUX,MSGL_V, "real: Header object version: %d\n", i);
1101 if (header_size == 0x10)
1102 i = stream_read_word(demuxer->stream);
1103 else /* we should test header_size here too. */
1104 i = stream_read_dword(demuxer->stream);
1105 mp_msg(MSGT_DEMUX,MSGL_V, "real: File version: %d\n", i);
1106 num_of_headers = stream_read_dword(demuxer->stream);
1107
1108 /* parse chunks */
1109 for (i = 1; i <= num_of_headers; i++)
1110 // for (i = 1; ; i++)
1111 {
1112 int chunk_id, chunk_pos, chunk_size;
1113
1114 chunk_pos = stream_tell(demuxer->stream);
1115 chunk_id = stream_read_dword_le(demuxer->stream);
1116 chunk_size = stream_read_dword(demuxer->stream);
1117
1118 stream_skip(demuxer->stream, 2); /* version */
1119
1120 mp_msg(MSGT_DEMUX,MSGL_V, "Chunk: %.4s (%x) (size: 0x%x, offset: 0x%x)\n",
1121 (char *)&chunk_id, chunk_id, chunk_size, chunk_pos);
1122
1123 if (chunk_id != MKTAG('D', 'A', 'T', 'A') && chunk_size < 10){
1124 mp_msg(MSGT_DEMUX,MSGL_ERR,"demux_real: invalid chunksize! (%d)\n",chunk_size);
1125 break; //return;
1126 }
1127
1128 switch(chunk_id)
1129 {
1130 case MKTAG('P', 'R', 'O', 'P'):
1131 /* Properties header */
1132
1133 stream_skip(demuxer->stream, 4); /* max bitrate */
1134 stream_skip(demuxer->stream, 4); /* avg bitrate */
1135 stream_skip(demuxer->stream, 4); /* max packet size */
1136 stream_skip(demuxer->stream, 4); /* avg packet size */
1137 stream_skip(demuxer->stream, 4); /* nb packets */
1138 priv->duration = stream_read_dword(demuxer->stream)/1000; /* duration */
1139 stream_skip(demuxer->stream, 4); /* preroll */
1140 priv->index_chunk_offset = stream_read_dword(demuxer->stream);
1141 mp_msg(MSGT_DEMUX,MSGL_V,"First index chunk offset: 0x%x\n", priv->index_chunk_offset);
1142 priv->data_chunk_offset = stream_read_dword(demuxer->stream)+10;
1143 mp_msg(MSGT_DEMUX,MSGL_V,"First data chunk offset: 0x%x\n", priv->data_chunk_offset);
1144 stream_skip(demuxer->stream, 2); /* nb streams */
1145 #if 0
1146 stream_skip(demuxer->stream, 2); /* flags */
1147 #else
1148 {
1149 int flags = stream_read_word(demuxer->stream);
1150
1151 if (flags)
1152 {
1153 mp_msg(MSGT_DEMUX,MSGL_V,"Flags (%x): ", flags);
1154 if (flags & 0x1)
1155 mp_msg(MSGT_DEMUX,MSGL_V,"[save allowed] ");
1156 if (flags & 0x2)
1157 mp_msg(MSGT_DEMUX,MSGL_V,"[perfect play (more buffers)] ");
1158 if (flags & 0x4)
1159 mp_msg(MSGT_DEMUX,MSGL_V,"[live broadcast] ");
1160 mp_msg(MSGT_DEMUX,MSGL_V,"\n");
1161 }
1162 }
1163 #endif
1164 break;
1165 case MKTAG('C', 'O', 'N', 'T'):
1166 {
1167 /* Content description header */
1168 char *buf;
1169 int len;
1170
1171 len = stream_read_word(demuxer->stream);
1172 if (len > 0)
1173 {
1174 buf = malloc(len+1);
1175 stream_read(demuxer->stream, buf, len);
1176 buf[len] = 0;
1177 demux_info_add(demuxer, "title", buf);
1178 free(buf);
1179 }
1180
1181 len = stream_read_word(demuxer->stream);
1182 if (len > 0)
1183 {
1184 buf = malloc(len+1);
1185 stream_read(demuxer->stream, buf, len);
1186 buf[len] = 0;
1187 demux_info_add(demuxer, "author", buf);
1188 free(buf);
1189 }
1190
1191 len = stream_read_word(demuxer->stream);
1192 if (len > 0)
1193 {
1194 buf = malloc(len+1);
1195 stream_read(demuxer->stream, buf, len);
1196 buf[len] = 0;
1197 demux_info_add(demuxer, "copyright", buf);
1198 free(buf);
1199 }
1200
1201 len = stream_read_word(demuxer->stream);
1202 if (len > 0)
1203 {
1204 buf = malloc(len+1);
1205 stream_read(demuxer->stream, buf, len);
1206 buf[len] = 0;
1207 demux_info_add(demuxer, "comment", buf);
1208 free(buf);
1209 }
1210 break;
1211 }
1212 case MKTAG('M', 'D', 'P', 'R'):
1213 {
1214 /* Media properties header */
1215 int stream_id;
1216 int bitrate;
1217 int codec_data_size;
1218 int codec_pos;
1219 int tmp;
1220 int len;
1221 char *descr, *mimet = NULL;
1222
1223 stream_id = stream_read_word(demuxer->stream);
1224 mp_msg(MSGT_DEMUX,MSGL_V,"Found new stream (id: %d)\n", stream_id);
1225
1226 stream_skip(demuxer->stream, 4); /* max bitrate */
1227 bitrate = stream_read_dword(demuxer->stream); /* avg bitrate */
1228 stream_skip(demuxer->stream, 4); /* max packet size */
1229 stream_skip(demuxer->stream, 4); /* avg packet size */
1230 stream_skip(demuxer->stream, 4); /* start time */
1231 stream_skip(demuxer->stream, 4); /* preroll */
1232 stream_skip(demuxer->stream, 4); /* duration */
1233
1234 if ((len = stream_read_char(demuxer->stream)) > 0) {
1235 descr = malloc(len+1);
1236 stream_read(demuxer->stream, descr, len);
1237 descr[len] = 0;
1238 mp_msg(MSGT_DEMUX, MSGL_INFO,"Stream description: %s\n", descr);
1239 free(descr);
1240 }
1241 if ((len = stream_read_char(demuxer->stream)) > 0) {
1242 mimet = malloc(len+1);
1243 stream_read(demuxer->stream, mimet, len);
1244 mimet[len] = 0;
1245 mp_msg(MSGT_DEMUX, MSGL_INFO,"Stream mimetype: %s\n", mimet);
1246 }
1247
1248 /* Type specific header */
1249 codec_data_size = stream_read_dword(demuxer->stream);
1250 codec_pos = stream_tell(demuxer->stream);
1251
1252 #ifdef MP_DEBUG
1253 #define stream_skip(st,siz) { int i; for(i=0;i<siz;i++) mp_msg(MSGT_DEMUX,MSGL_V," %02X",stream_read_char(st)); mp_msg(MSGT_DEMUX,MSGL_V,"\n");}
1254 #endif
1255
1256 if (!strncmp(mimet,"audio/",6)) {
1257 if (strstr(mimet,"x-pn-realaudio") || strstr(mimet,"x-pn-multirate-realaudio")) {
1258 tmp = stream_read_dword(demuxer->stream);
1259 if (tmp != MKTAG(0xfd, 'a', 'r', '.'))
1260 {
1261 mp_msg(MSGT_DEMUX,MSGL_V,"Audio: can't find .ra in codec data\n");
1262 } else {
1263 /* audio header */
1264 sh_audio_t *sh = new_sh_audio(demuxer, stream_id);
1265 char buf[128]; /* for codec name */
1266 int frame_size;
1267 int sub_packet_size;
1268 int sub_packet_h;
1269 int version;
1270 int flavor;
1271 int coded_frame_size;
1272 int codecdata_length;
1273 int i;
1274 char *buft;
1275 int hdr_size;
1276 mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "real", stream_id);
1277 mp_msg(MSGT_DEMUX,MSGL_V,"Found audio stream!\n");
1278 version = stream_read_word(demuxer->stream);
1279 mp_msg(MSGT_DEMUX,MSGL_V,"version: %d\n", version);
1280 if (version == 3) {
1281 stream_skip(demuxer->stream, 2);
1282 stream_skip(demuxer->stream, 10);
1283 stream_skip(demuxer->stream, 4);
1284 // Name, author, (c) are also in CONT tag
1285 if ((i = stream_read_char(demuxer->stream)) != 0) {
1286 buft = malloc(i+1);
1287 stream_read(demuxer->stream, buft, i);
1288 buft[i] = 0;
1289 demux_info_add(demuxer, "Name", buft);
1290 free(buft);
1291 }
1292 if ((i = stream_read_char(demuxer->stream)) != 0) {
1293 buft = malloc(i+1);
1294 stream_read(demuxer->stream, buft, i);
1295 buft[i] = 0;
1296 demux_info_add(demuxer, "Author", buft);
1297 free(buft);
1298 }
1299 if ((i = stream_read_char(demuxer->stream)) != 0) {
1300 buft = malloc(i+1);
1301 stream_read(demuxer->stream, buft, i);
1302 buft[i] = 0;
1303 demux_info_add(demuxer, "Copyright", buft);
1304 free(buft);
1305 }
1306 if ((i = stream_read_char(demuxer->stream)) != 0)
1307 mp_msg(MSGT_DEMUX,MSGL_WARN,"Last header byte is not zero!\n");
1308 stream_skip(demuxer->stream, 1);
1309 i = stream_read_char(demuxer->stream);
1310 sh->format = stream_read_dword_le(demuxer->stream);
1311 if (i != 4) {
1312 mp_msg(MSGT_DEMUX,MSGL_WARN,"Audio FourCC size is not 4 (%d), please report to "
1313 "MPlayer developers\n", i);
1314 stream_skip(demuxer->stream, i - 4);
1315 }
1316 if (sh->format != mmioFOURCC('l','p','c','J')) {
1317 mp_msg(MSGT_DEMUX,MSGL_WARN,"Version 3 audio with FourCC %8x, please report to "
1318 "MPlayer developers\n", sh->format);
1319 }
1320 sh->channels = 1;
1321 sh->samplesize = 16;
1322 sh->samplerate = 8000;
1323 frame_size = 240;
1324 strcpy(buf, "14_4");
1325 } else {
1326 stream_skip(demuxer->stream, 2); // 00 00
1327 stream_skip(demuxer->stream, 4); /* .ra4 or .ra5 */
1328 stream_skip(demuxer->stream, 4); // ???
1329 stream_skip(demuxer->stream, 2); /* version (4 or 5) */
1330 hdr_size = stream_read_dword(demuxer->stream); // header size
1331 mp_msg(MSGT_DEMUX,MSGL_V,"header size: %d\n", hdr_size);
1332 flavor = stream_read_word(demuxer->stream);/* codec flavor id */
1333 coded_frame_size = stream_read_dword(demuxer->stream);/* needed by codec */
1334 mp_msg(MSGT_DEMUX,MSGL_V,"coded_frame_size: %d\n", coded_frame_size);
1335 stream_skip(demuxer->stream, 4); // big number
1336 stream_skip(demuxer->stream, 4); // bigger number
1337 stream_skip(demuxer->stream, 4); // 2 || -''-
1338 sub_packet_h = stream_read_word(demuxer->stream);
1339 mp_msg(MSGT_DEMUX,MSGL_V,"sub_packet_h: %d\n", sub_packet_h);
1340 frame_size = stream_read_word(demuxer->stream);
1341 mp_msg(MSGT_DEMUX,MSGL_V,"frame_size: %d\n", frame_size);
1342 sub_packet_size = stream_read_word(demuxer->stream);
1343 mp_msg(MSGT_DEMUX,MSGL_V,"sub_packet_size: %d\n", sub_packet_size);
1344 stream_skip(demuxer->stream, 2); // 0
1345
1346 if (version == 5)
1347 stream_skip(demuxer->stream, 6); //0,srate,0
1348
1349 sh->samplerate = stream_read_word(demuxer->stream);
1350 stream_skip(demuxer->stream, 2); // 0
1351 sh->samplesize = stream_read_word(demuxer->stream)/8;
1352 sh->channels = stream_read_word(demuxer->stream);
1353 mp_msg(MSGT_DEMUX,MSGL_V,"samplerate: %d, channels: %d\n",
1354 sh->samplerate, sh->channels);
1355
1356 if (version == 5)
1357 {
1358 stream_read(demuxer->stream, buf, 4); // interleaver id
1359 priv->intl_id[stream_id] = MKTAG(buf[0], buf[1], buf[2], buf[3]);
1360 stream_read(demuxer->stream, buf, 4); // fourcc
1361 buf[4] = 0;
1362 }
1363 else
1364 {
1365 /* Interleaver id */
1366 get_str(1, demuxer, buf, sizeof(buf));
1367 priv->intl_id[stream_id] = MKTAG(buf[0], buf[1], buf[2], buf[3]);
1368 /* Codec FourCC */
1369 get_str(1, demuxer, buf, sizeof(buf));
1370 }
1371 }
1372
1373 /* Emulate WAVEFORMATEX struct: */
1374 sh->wf = calloc(1, sizeof(*sh->wf));
1375 sh->wf->nChannels = sh->channels;
1376 sh->wf->wBitsPerSample = sh->samplesize*8;
1377 sh->wf->nSamplesPerSec = sh->samplerate;
1378 sh->wf->nAvgBytesPerSec = bitrate/8;
1379 sh->wf->nBlockAlign = frame_size;
1380 sh->wf->cbSize = 0;
1381 sh->format = MKTAG(buf[0], buf[1], buf[2], buf[3]);
1382
1383 switch (sh->format)
1384 {
1385 case MKTAG('d', 'n', 'e', 't'):
1386 mp_msg(MSGT_DEMUX,MSGL_V,"Audio: DNET -> AC3\n");
1387 // sh->format = 0x2000;
1388 break;
1389 case MKTAG('1', '4', '_', '4'):
1390 sh->wf->nBlockAlign = 0x14;
1391 break;
1392
1393 case MKTAG('2', '8', '_', '8'):
1394 sh->wf->nBlockAlign = coded_frame_size;
1395 break;
1396
1397 case MKTAG('s', 'i', 'p', 'r'):
1398 case MKTAG('a', 't', 'r', 'c'):
1399 case MKTAG('c', 'o', 'o', 'k'):
1400 // realaudio codec plugins - common:
1401 stream_skip(demuxer->stream,3); // Skip 3 unknown bytes
1402 if (version==5)
1403 stream_skip(demuxer->stream,1); // Skip 1 additional unknown byte
1404 codecdata_length=stream_read_dword(demuxer->stream);
1405 // Check extradata len, we can't store bigger values in cbSize anyway
1406 if ((unsigned)codecdata_length > 0xffff) {
1407 mp_msg(MSGT_DEMUX,MSGL_ERR,"Extradata too big (%d)\n", codecdata_length);
1408 goto skip_this_chunk;
1409 }
1410 sh->wf->cbSize = codecdata_length;
1411 sh->wf = realloc(sh->wf, sizeof(*sh->wf)+sh->wf->cbSize);
1412 stream_read(demuxer->stream, ((char*)(sh->wf+1)), codecdata_length); // extras
1413 if (priv->intl_id[stream_id] == MKTAG('g', 'e', 'n', 'r'))
1414 sh->wf->nBlockAlign = sub_packet_size;
1415 else
1416 sh->wf->nBlockAlign = coded_frame_size;
1417
1418 break;
1419
1420 case MKTAG('r', 'a', 'a', 'c'):
1421 case MKTAG('r', 'a', 'c', 'p'):
1422 /* This is just AAC. The two or five bytes of */
1423 /* config data needed for libfaad are stored */
1424 /* after the audio headers. */
1425 stream_skip(demuxer->stream,3); // Skip 3 unknown bytes
1426 if (version==5)
1427 stream_skip(demuxer->stream,1); // Skip 1 additional unknown byte
1428 codecdata_length=stream_read_dword(demuxer->stream);
1429 if (codecdata_length>=1) {
1430 sh->codecdata_len = codecdata_length - 1;
1431 sh->codecdata = calloc(sh->codecdata_len, 1);
1432 stream_skip(demuxer->stream, 1);
1433 stream_read(demuxer->stream, sh->codecdata, sh->codecdata_len);
1434 }
1435 sh->format = mmioFOURCC('M', 'P', '4', 'A');
1436 break;
1437 default:
1438 mp_msg(MSGT_DEMUX,MSGL_V,"Audio: Unknown (%s)\n", buf);
1439 }
1440
1441 // Interleaver setup
1442 priv->sub_packet_size[stream_id] = sub_packet_size;
1443 priv->sub_packet_h[stream_id] = sub_packet_h;
1444 priv->coded_framesize[stream_id] = coded_frame_size;
1445 priv->audiopk_size[stream_id] = frame_size;
1446
1447 sh->wf->wFormatTag = sh->format;
1448
1449 mp_msg(MSGT_DEMUX,MSGL_V,"audio fourcc: %.4s (%x)\n", (char *)&sh->format, sh->format);
1450 if ( mp_msg_test(MSGT_DEMUX,MSGL_V) )
1451 print_wave_header(sh->wf, MSGL_V);
1452
1453 /* Select audio stream with highest bitrate if multirate file*/
1454 if (priv->is_multirate && ((demuxer->audio->id == -1) ||
1455 ((demuxer->audio->id >= 0) && priv->a_bitrate && (bitrate > priv->a_bitrate)))) {
1456 demuxer->audio->id = stream_id;
1457 priv->a_bitrate = bitrate;
1458 mp_msg(MSGT_DEMUX,MSGL_DBG2,"Multirate autoselected audio id %d with bitrate %d\n", stream_id, bitrate);
1459 }
1460
1461 if(demuxer->audio->id==stream_id){
1462 sh->ds=demuxer->audio;
1463 demuxer->audio->sh=sh;
1464 priv->audio_buf = calloc(priv->sub_packet_h[demuxer->audio->id], priv->audiopk_size[demuxer->audio->id]);
1465 priv->audio_timestamp = calloc(priv->sub_packet_h[demuxer->audio->id], sizeof(double));
1466 }
1467
1468 ++a_streams;
1469
1470 #ifdef stream_skip
1471 #undef stream_skip
1472 #endif
1473 }
1474 } else if (strstr(mimet,"X-MP3-draft-00")) {
1475 sh_audio_t *sh = new_sh_audio(demuxer, stream_id);
1476 mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "real", stream_id);
1477
1478 /* Emulate WAVEFORMATEX struct: */
1479 sh->wf = calloc(1, sizeof(*sh->wf));
1480 sh->wf->nChannels = 0;//sh->channels;
1481 sh->wf->wBitsPerSample = 16;
1482 sh->wf->nSamplesPerSec = 0;//sh->samplerate;
1483 sh->wf->nAvgBytesPerSec = 0;//bitrate;
1484 sh->wf->nBlockAlign = 0;//frame_size;
1485 sh->wf->cbSize = 0;
1486 sh->wf->wFormatTag = sh->format = mmioFOURCC('a','d','u',0x55);
1487
1488 if(demuxer->audio->id==stream_id){
1489 sh->ds=demuxer->audio;
1490 demuxer->audio->sh=sh;
1491 }
1492
1493 ++a_streams;
1494 } else if (strstr(mimet,"x-ralf-mpeg4")) {
1495 mp_msg(MSGT_DEMUX,MSGL_ERR,"Real lossless audio not supported yet\n");
1496 } else if (strstr(mimet,"x-pn-encrypted-ra")) {
1497 mp_msg(MSGT_DEMUX,MSGL_ERR,"Encrypted audio is not supported\n");
1498 } else {
1499 mp_msg(MSGT_DEMUX,MSGL_V,"Unknown audio stream format\n");
1500 }
1501 } else if (!strncmp(mimet,"video/",6)) {
1502 if (strstr(mimet,"x-pn-realvideo") || strstr(mimet,"x-pn-multirate-realvideo")) {
1503 stream_skip(demuxer->stream, 4); // VIDO length, same as codec_data_size
1504 tmp = stream_read_dword(demuxer->stream);
1505 if(tmp != MKTAG('O', 'D', 'I', 'V'))
1506 {
1507 mp_msg(MSGT_DEMUX,MSGL_V,"Video: can't find VIDO in codec data\n");
1508 } else {
1509 /* video header */
1510 sh_video_t *sh = new_sh_video(demuxer, stream_id);
1511 mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Video stream found, -vid %d\n", "real", stream_id);
1512
1513 sh->format = stream_read_dword_le(demuxer->stream); /* fourcc */
1514 mp_msg(MSGT_DEMUX,MSGL_V,"video fourcc: %.4s (%x)\n", (char *)&sh->format, sh->format);
1515
1516 /* emulate BITMAPINFOHEADER */
1517 sh->bih = calloc(1, sizeof(*sh->bih));
1518 sh->bih->biSize = sizeof(*sh->bih);
1519 sh->disp_w = sh->bih->biWidth = stream_read_word(demuxer->stream);
1520 sh->disp_h = sh->bih->biHeight = stream_read_word(demuxer->stream);
1521 sh->bih->biPlanes = 1;
1522 sh->bih->biBitCount = 24;
1523 sh->bih->biCompression = sh->format;
1524 sh->bih->biSizeImage= sh->bih->biWidth*sh->bih->biHeight*3;
1525
1526 sh->fps = (float) stream_read_word(demuxer->stream);
1527 if (sh->fps<=0) sh->fps=24; // we probably won't even care about fps
1528 sh->frametime = 1.0f/sh->fps;
1529
1530 #if 1
1531 stream_skip(demuxer->stream, 4);
1532 #else
1533 mp_msg(MSGT_DEMUX, MSGL_V,"unknown1: 0x%X \n",stream_read_dword(demuxer->stream));
1534 mp_msg(MSGT_DEMUX, MSGL_V,"unknown2: 0x%X \n",stream_read_word(demuxer->stream));
1535 mp_msg(MSGT_DEMUX, MSGL_V,"unknown3: 0x%X \n",stream_read_word(demuxer->stream));
1536 #endif
1537 // if(sh->format==0x30335652 || sh->format==0x30325652 )
1538 if(1)
1539 {
1540 int tmp=stream_read_word(demuxer->stream);
1541 if(tmp>0){
1542 sh->fps=tmp; sh->frametime = 1.0f/sh->fps;
1543 }
1544 } else {
1545 int fps=stream_read_word(demuxer->stream);
1546 mp_msg(MSGT_DEMUX, MSGL_WARN,"realvid: ignoring FPS = %d\n",fps);
1547 }
1548 stream_skip(demuxer->stream, 2);
1549
1550 {
1551 // read and store codec extradata
1552 unsigned int cnt = codec_data_size - (stream_tell(demuxer->stream) - codec_pos);
1553 if (cnt > 0x7fffffff - sizeof(*sh->bih)) {
1554 mp_msg(MSGT_DEMUX, MSGL_ERR,"Extradata too big (%u)\n", cnt);
1555 } else {
1556 sh->bih = realloc(sh->bih, sizeof(*sh->bih) + cnt);
1557 sh->bih->biSize += cnt;
1558 stream_read(demuxer->stream, ((unsigned char*)(sh->bih+1)), cnt);
1559 }
1560 }
1561 if(sh->format == 0x30315652 && ((unsigned char*)(sh->bih+1))[6] == 0x30)
1562 sh->bih->biCompression = sh->format = mmioFOURCC('R', 'V', '1', '3');
1563
1564 /* Select video stream with highest bitrate if multirate file*/
1565 if (priv->is_multirate && ((demuxer->video->id == -1) ||
1566 ((demuxer->video->id >= 0) && priv->v_bitrate && (bitrate > priv->v_bitrate)))) {
1567 demuxer->video->id = stream_id;
1568 priv->v_bitrate = bitrate;
1569 mp_msg(MSGT_DEMUX,MSGL_DBG2,"Multirate autoselected video id %d with bitrate %d\n", stream_id, bitrate);
1570 }
1571
1572 if(demuxer->video->id==stream_id){
1573 sh->ds=demuxer->video;
1574 demuxer->video->sh=sh;
1575 }
1576
1577 ++v_streams;
1578
1579 }
1580 } else {
1581 mp_msg(MSGT_DEMUX,MSGL_V,"Unknown video stream format\n");
1582 }
1583 } else if (strstr(mimet,"logical-")) {
1584 if (strstr(mimet,"fileinfo")) {
1585 mp_msg(MSGT_DEMUX,MSGL_V,"Got a logical-fileinfo chunk\n");
1586 } else if (strstr(mimet,"-audio") || strstr(mimet,"-video")) {
1587 int i, stream_cnt;
1588 int stream_list[MAX_STREAMS];
1589
1590 priv->is_multirate = 1;
1591 stream_skip(demuxer->stream, 4); // Length of codec data (repeated)
1592 stream_cnt = stream_read_dword(demuxer->stream); // Get number of audio or video streams
1593 if ((unsigned)stream_cnt >= MAX_STREAMS) {
1594 mp_msg(MSGT_DEMUX,MSGL_ERR,"Too many streams in %s. Big troubles ahead.\n", mimet);
1595 goto skip_this_chunk;
1596 }
1597 for (i = 0; i < stream_cnt; i++)
1598 stream_list[i] = stream_read_word(demuxer->stream);
1599 for (i = 0; i < stream_cnt; i++)
1600 if ((unsigned)stream_list[i] >= MAX_STREAMS) {
1601 mp_msg(MSGT_DEMUX,MSGL_ERR,"Stream id out of range: %d. Ignored.\n", stream_list[i]);
1602 stream_skip(demuxer->stream, 4); // Skip DATA offset for broken stream
1603 } else {
1604 priv->str_data_offset[stream_list[i]] = stream_read_dword(demuxer->stream);
1605 mp_msg(MSGT_DEMUX,MSGL_V,"Stream %d with DATA offset 0x%08x\n", stream_list[i], priv->str_data_offset[stream_list[i]]);
1606 }
1607 // Skip the rest of this chunk
1608 } else
1609 mp_msg(MSGT_DEMUX,MSGL_V,"Unknown logical stream\n");
1610 }
1611 else {
1612 mp_msg(MSGT_DEMUX, MSGL_ERR, "Not audio/video stream or unsupported!\n");
1613 }
1614 // break;
1615 // default:
1616 skip_this_chunk:
1617 /* skip codec info */
1618 tmp = stream_tell(demuxer->stream) - codec_pos;
1619 mp_msg(MSGT_DEMUX,MSGL_V,"### skipping %d bytes of codec info\n", codec_data_size - tmp);
1620 #if 0
1621 { int i;
1622 for(i=0;i<codec_data_size - tmp;i++)
1623 mp_msg(MSGT_DEMUX, MSGL_V," %02X",stream_read_char(demuxer->stream));
1624 mp_msg(MSGT_DEMUX, MSGL_V,"\n");
1625 }
1626 #else
1627 stream_skip(demuxer->stream, codec_data_size - tmp);
1628 #endif
1629 free (mimet);
1630 break;
1631 // }
1632 }
1633 case MKTAG('D', 'A', 'T', 'A'):
1634 goto header_end;
1635 case MKTAG('I', 'N', 'D', 'X'):
1636 default:
1637 mp_msg(MSGT_DEMUX,MSGL_V,"Unknown chunk: %x\n", chunk_id);
1638 stream_skip(demuxer->stream, chunk_size - 10);
1639 break;
1640 }
1641 }
1642
1643 header_end:
1644 if(priv->is_multirate) {
1645 mp_msg(MSGT_DEMUX,MSGL_V,"Selected video id %d audio id %d\n", demuxer->video->id, demuxer->audio->id);
1646 /* Perform some sanity checks to avoid checking streams id all over the code*/
1647 if (demuxer->audio->id >= MAX_STREAMS) {
1648 mp_msg(MSGT_DEMUX,MSGL_ERR,"Invalid audio stream %d. No sound will be played.\n", demuxer->audio->id);
1649 demuxer->audio->id = -2;
1650 } else if ((demuxer->audio->id >= 0) && (priv->str_data_offset[demuxer->audio->id] == 0)) {
1651 mp_msg(MSGT_DEMUX,MSGL_ERR,"Audio stream %d not found. No sound will be played.\n", demuxer->audio->id);
1652 demuxer->audio->id = -2;
1653 }
1654 if (demuxer->video->id >= MAX_STREAMS) {
1655 mp_msg(MSGT_DEMUX,MSGL_ERR,"Invalid video stream %d. No video will be played.\n", demuxer->video->id);
1656 demuxer->video->id = -2;
1657 } else if ((demuxer->video->id >= 0) && (priv->str_data_offset[demuxer->video->id] == 0)) {
1658 mp_msg(MSGT_DEMUX,MSGL_ERR,"Video stream %d not found. No video will be played.\n", demuxer->video->id);
1659 demuxer->video->id = -2;
1660 }
1661 }
1662
1663 if(priv->is_multirate && ((demuxer->video->id >= 0) || (demuxer->audio->id >=0))) {
1664 /* If audio or video only, seek to right place and behave like standard file */
1665 if (demuxer->video->id < 0) {
1666 // Stream is audio only, or -novideo
1667 stream_seek(demuxer->stream, priv->data_chunk_offset = priv->str_data_offset[demuxer->audio->id]+10);
1668 priv->is_multirate = 0;
1669 }
1670 if (demuxer->audio->id < 0) {
1671 // Stream is video only, or -nosound
1672 stream_seek(demuxer->stream, priv->data_chunk_offset = priv->str_data_offset[demuxer->video->id]+10);
1673 priv->is_multirate = 0;
1674 }
1675 }
1676
1677 if(!priv->is_multirate) {
1678 // printf("i=%d num_of_headers=%d \n",i,num_of_headers);
1679 priv->num_of_packets = stream_read_dword(demuxer->stream);
1680 stream_skip(demuxer->stream, 4); /* next data header */
1681
1682 mp_msg(MSGT_DEMUX,MSGL_V,"Packets in file: %d\n", priv->num_of_packets);
1683
1684 if (priv->num_of_packets == 0)
1685 priv->num_of_packets = -10;
1686 } else {
1687 priv->audio_curpos = priv->str_data_offset[demuxer->audio->id] + 18;
1688 stream_seek(demuxer->stream, priv->str_data_offset[demuxer->audio->id]+10);
1689 priv->a_num_of_packets=priv->a_num_of_packets = stream_read_dword(demuxer->stream);
1690 priv->video_curpos = priv->str_data_offset[demuxer->video->id] + 18;
1691 stream_seek(demuxer->stream, priv->str_data_offset[demuxer->video->id]+10);
1692 priv->v_num_of_packets = stream_read_dword(demuxer->stream);
1693 priv->stream_switch = 1;
1694 /* Index required for multirate playback, force building if it's not there */
1695 /* but respect user request to force index regeneration */
1696 if (index_mode == -1)
1697 index_mode = 1;
1698 }
1699
1700
1701 priv->audio_need_keyframe = 0;
1702 priv->video_after_seek = 0;
1703
1704 switch (index_mode){
1705 case -1: // untouched
1706 if ((demuxer->stream->flags & MP_STREAM_SEEK) == MP_STREAM_SEEK &&
1707 priv->index_chunk_offset && parse_index_chunk(demuxer))
1708 {
1709 demuxer->seekable = 1;
1710 }
1711 break;
1712 case 1: // use (generate index)
1713 if (priv->index_chunk_offset && parse_index_chunk(demuxer))
1714 {
1715 demuxer->seekable = 1;
1716 } else {
1717 generate_index(demuxer);
1718 demuxer->seekable = 1;
1719 }
1720 break;
1721 case 2: // force generating index
1722 generate_index(demuxer);
1723 demuxer->seekable = 1;
1724 break;
1725 default: // do nothing
1726 break;
1727 }
1728
1729 // detect streams:
1730 if(demuxer->video->id==-1 && v_streams>0){
1731 // find the valid video stream:
1732 if(!ds_fill_buffer(demuxer->video)){
1733 mp_msg(MSGT_DEMUXER, MSGL_INFO, "RM: %s",
1734 mp_gtext("No video stream found.\n"));
1735 }
1736 }
1737 if(demuxer->audio->id==-1 && a_streams>0){
1738 // find the valid audio stream:
1739 if(!ds_fill_buffer(demuxer->audio)){
1740 mp_msg(MSGT_DEMUXER, MSGL_INFO, "RM: %s",
1741 mp_gtext("No audio stream found -> no sound.\n"));
1742 }
1743 }
1744
1745 if(demuxer->video->sh){
1746 sh_video_t *sh=demuxer->video->sh;
1747 mp_msg(MSGT_DEMUX,MSGL_V,"VIDEO: %.4s [%08X,%08X] %dx%d (aspect %4.2f) %4.2f fps\n",
1748 (char *)&sh->format,((unsigned int*)(sh->bih+1))[1],((unsigned int*)(sh->bih+1))[0],
1749 sh->disp_w,sh->disp_h,sh->aspect,sh->fps);
1750 }
1751
1752 if(demuxer->audio->sh){
1753 sh_audio_t *sh=demuxer->audio->sh;
1754 mp_msg(MSGT_DEMUX,MSGL_V,"AUDIO: %.4s [%08X]\n",
1755 (char *)&sh->format,sh->format);
1756 }
1757
1758 return demuxer;
1759 }
1760
1761 static void demux_close_real(demuxer_t *demuxer)
1762 {
1763 int i;
1764 real_priv_t* priv = demuxer->priv;
1765
1766 if (priv){
1767 for(i=0; i<MAX_STREAMS; i++)
1768 free(priv->index_table[i]);
1769 free(priv->audio_buf);
1770 free(priv->audio_timestamp);
1771 free(priv);
1772 }
1773
1774 return;
1775 }
1776
1777 /* please upload RV10 samples WITH INDEX CHUNK */
1778 static void demux_seek_real(demuxer_t *demuxer, float rel_seek_secs, float audio_delay, int flags)
1779 {
1780 real_priv_t *priv = demuxer->priv;
1781 demux_stream_t *d_audio = demuxer->audio;
1782 demux_stream_t *d_video = demuxer->video;
1783 sh_audio_t *sh_audio = d_audio->sh;
1784 sh_video_t *sh_video = d_video->sh;
1785 int vid = d_video->id, aid = d_audio->id;
1786 int next_offset = 0;
1787 int64_t cur_timestamp = 0;
1788 int streams = 0;
1789 int retried = 0;
1790
1791
1792 if (sh_video && (unsigned)vid < MAX_STREAMS && priv->index_table_size[vid])
1793 streams |= 1;
1794 if (sh_audio && (unsigned)aid < MAX_STREAMS && priv->index_table_size[aid])
1795 streams |= 2;
1796
1797 // printf("streams: %d\n", streams);
1798
1799 if (!streams)
1800 return;
1801
1802 if (flags & SEEK_ABSOLUTE)
1803 priv->current_apacket = priv->current_vpacket = 0;
1804 if (flags & SEEK_FACTOR)
1805 rel_seek_secs *= priv->duration;
1806
1807 if ((streams & 1) && priv->current_vpacket >= priv->index_table_size[vid])
1808 priv->current_vpacket = priv->index_table_size[vid] - 1;
1809 if ((streams & 2) && priv->current_apacket >= priv->index_table_size[aid])
1810 priv->current_apacket = priv->index_table_size[aid] - 1;
1811
1812 // if (index_mode == 1 || index_mode == 2) {
1813 if (streams & 1) {// use the video index if we have one
1814 cur_timestamp = priv->index_table[vid][priv->current_vpacket].timestamp;
1815 if (rel_seek_secs > 0)
1816 while ((priv->index_table[vid][priv->current_vpacket].timestamp - cur_timestamp) < rel_seek_secs * 1000){
1817 priv->current_vpacket += 1;
1818 if (priv->current_vpacket >= priv->index_table_size[vid]) {
1819 priv->current_vpacket = priv->index_table_size[vid] - 1;
1820 if (!retried) {
1821 stream_seek(demuxer->stream, priv->index_table[vid][priv->current_vpacket].offset);
1822 add_index_segment(demuxer, vid, cur_timestamp + rel_seek_secs * 1000);
1823 retried = 1;
1824 }
1825 else
1826 break;
1827 }
1828 }
1829 else if (rel_seek_secs < 0) {
1830 while ((cur_timestamp - priv->index_table[vid][priv->current_vpacket].timestamp) < - rel_seek_secs * 1000){
1831 priv->current_vpacket -= 1;
1832 if (priv->current_vpacket < 0) {
1833 priv->current_vpacket = 0;
1834 break;
1835 }
1836 }
1837 }
1838 priv->video_curpos = priv->index_table[vid][priv->current_vpacket].offset;
1839 priv->audio_need_keyframe = !priv->is_multirate;
1840 priv->video_after_seek = 1;
1841 }
1842 if (streams & 2) {
1843 if (!(streams & 1)) {
1844 cur_timestamp =
1845 priv->index_table[aid][priv->current_apacket].timestamp;
1846 }
1847 if (rel_seek_secs > 0)
1848 while ((priv->index_table[aid][priv->current_apacket].timestamp - cur_timestamp) < rel_seek_secs * 1000){
1849 priv->current_apacket += 1;
1850 if (priv->current_apacket >= priv->index_table_size[aid]) {
1851 priv->current_apacket = priv->index_table_size[aid] - 1;
1852 break;
1853 }
1854 }
1855 else if (rel_seek_secs < 0)
1856 while ((cur_timestamp - priv->index_table[aid][priv->current_apacket].timestamp) < - rel_seek_secs * 1000){
1857 priv->current_apacket -= 1;
1858 if (priv->current_apacket < 0) {
1859 priv->current_apacket = 0;
1860 break;
1861 }
1862 }
1863 priv->audio_curpos = priv->index_table[aid][priv->current_apacket].offset;
1864 }
1865 // }
1866 next_offset = streams & 1 ? priv->video_curpos : priv->audio_curpos;
1867 // printf("seek: pos: %d, current packets: a: %d, v: %d\n",
1868 // next_offset, priv->current_apacket, priv->current_vpacket);
1869 if (next_offset)
1870 stream_seek(demuxer->stream, next_offset);
1871
1872 demux_real_fill_buffer(demuxer, NULL);
1873 }
1874
1875 static int demux_real_control(demuxer_t *demuxer, int cmd, void *arg)
1876 {
1877 real_priv_t *priv = demuxer->priv;
1878 unsigned int lastpts = priv->v_pts ? priv->v_pts : priv->a_pts;
1879
1880 switch (cmd) {
1881 case DEMUXER_CTRL_GET_TIME_LENGTH:
1882 if (priv->duration == 0)
1883 return DEMUXER_CTRL_DONTKNOW;
1884
1885 *((double *)arg) = (double)priv->duration;
1886 return DEMUXER_CTRL_OK;
1887
1888 case DEMUXER_CTRL_GET_PERCENT_POS:
1889 if (priv->duration == 0)
1890 return DEMUXER_CTRL_DONTKNOW;
1891
1892 *((int *)arg) = (int)(100 * lastpts / priv->duration);
1893 return DEMUXER_CTRL_OK;
1894
1895 default:
1896 return DEMUXER_CTRL_NOTIMPL;
1897 }
1898 }
1899
1900
1901 const demuxer_desc_t demuxer_desc_real = {
1902 "Realmedia demuxer",
1903 "real",
1904 "REAL",
1905 "Alex Beregszasi, Florian Schneider, A'rpi, Roberto Togni",
1906 "handles new .RMF files",
1907 DEMUXER_TYPE_REAL,
1908 1, // safe autodetect
1909 real_check_file,
1910 demux_real_fill_buffer,
1911 demux_open_real,
1912 demux_close_real,
1913 demux_seek_real,
1914 demux_real_control
1915 };