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