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
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
14 * COOK/COKR - Real Cooker -> RealAudio G2
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
20 * This file is part of MPlayer.
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.
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.
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.
47 #include "stream/stream.h"
51 #include "demux_real.h"
53 //#define mp_dbg(mod,lev, args... ) mp_msg_c((mod<<8)|lev, ## args )
55 #define MKTAG(a, b, c, d) (a | (b << 8) | (c << 16) | (d << 24))
57 #define MAX_STREAMS 32
59 static unsigned char sipr_swaps
[38][2]={
60 {0,63},{1,22},{2,44},{3,90},{5,81},{7,31},{8,86},{9,58},{10,36},{12,68},
61 {13,39},{14,73},{15,53},{16,69},{17,57},{19,88},{20,34},{21,71},{24,46},
62 {25,94},{26,54},{28,75},{29,50},{32,70},{33,92},{35,74},{38,85},{40,56},
63 {42,87},{43,65},{45,59},{48,79},{49,93},{51,89},{55,95},{61,76},{67,83},
67 unsigned int timestamp
;
70 // int len; /* only filled by our index generator */
71 // int flags; /* only filled by our index generator */
76 int index_chunk_offset
;
77 real_index_table_t
*index_table
[MAX_STREAMS
];
79 // int *index_table[MAX_STREAMS];
80 int index_table_size
[MAX_STREAMS
];
81 int index_malloc_size
[MAX_STREAMS
];
82 int data_chunk_offset
;
87 int audio_need_keyframe
;
93 // timestamp correction:
94 int64_t kf_base
;// timestamp of the prev. video keyframe
95 unsigned int kf_pts
; // timestamp of next video keyframe
96 unsigned int a_pts
; // previous audio timestamp
97 double v_pts
; // previous video timestamp
98 unsigned long duration
;
100 /* stream id table */
101 // int last_a_stream;
102 // int a_streams[MAX_STREAMS];
103 // int last_v_stream;
104 // int v_streams[MAX_STREAMS];
107 * Used to demux multirate files
109 int is_multirate
; ///< != 0 for multirate files
110 int str_data_offset
[MAX_STREAMS
]; ///< Data chunk offset for every audio/video stream
111 int audio_curpos
; ///< Current file position for audio demuxing
112 int video_curpos
; ///< Current file position for video demuxing
113 int a_num_of_packets
; ///< Number of audio packets
114 int v_num_of_packets
; ///< Number of video packets
115 int a_bitrate
; ///< Audio bitrate
116 int v_bitrate
; ///< Video bitrate
117 int stream_switch
; ///< Flag used to switch audio/video demuxing
120 * Used to reorder audio data
122 unsigned int intl_id
[MAX_STREAMS
]; ///< interleaver id, per stream
123 int sub_packet_size
[MAX_STREAMS
]; ///< sub packet size, per stream
124 int sub_packet_h
[MAX_STREAMS
]; ///< number of coded frames per block
125 int coded_framesize
[MAX_STREAMS
]; ///< coded frame size, per stream
126 int audiopk_size
[MAX_STREAMS
]; ///< audio packet size
127 unsigned char *audio_buf
; ///< place to store reordered audio data
128 double *audio_timestamp
; ///< timestamp for each audio packet
129 int sub_packet_cnt
; ///< number of subpacket already received
130 int audio_filepos
; ///< file position of first audio packet in block
133 //! use at most 200 MB of memory for index, corresponds to around 25 million entries
134 #define MAX_INDEX_ENTRIES (200*1024*1024 / sizeof(real_index_table_t))
136 /* originally from FFmpeg */
137 static void get_str(int isbyte
, demuxer_t
*demuxer
, char *buf
, int buf_size
)
142 len
= stream_read_char(demuxer
->stream
);
144 len
= stream_read_word(demuxer
->stream
);
146 stream_read(demuxer
->stream
, buf
, (len
> buf_size
) ? buf_size
: len
);
148 stream_skip(demuxer
->stream
, len
-buf_size
);
150 mp_msg(MSGT_DEMUX
, MSGL_V
, "read_str: %d bytes read\n", len
);
153 static void dump_index(demuxer_t
*demuxer
, int stream_id
)
155 real_priv_t
*priv
= demuxer
->priv
;
156 real_index_table_t
*index
;
159 if (!mp_msg_test(MSGT_DEMUX
,MSGL_V
))
162 if ((unsigned)stream_id
>= MAX_STREAMS
)
165 index
= priv
->index_table
[stream_id
];
166 entries
= priv
->index_table_size
[stream_id
];
168 mp_msg(MSGT_DEMUX
, MSGL_V
, "Index table for stream %d\n", stream_id
);
169 for (i
= 0; i
< entries
; i
++)
172 mp_msg(MSGT_DEMUX
, MSGL_V
,"i: %d, pos: %d, timestamp: %u\n", i
, index
[i
].offset
, index
[i
].timestamp
);
174 mp_msg(MSGT_DEMUX
, MSGL_V
,"packetno: %x pos: %x len: %x timestamp: %x flags: %x\n",
175 index
[i
].packetno
, index
[i
].offset
, index
[i
].len
, index
[i
].timestamp
,
181 static int parse_index_chunk(demuxer_t
*demuxer
)
183 real_priv_t
*priv
= demuxer
->priv
;
184 int origpos
= stream_tell(demuxer
->stream
);
185 int next_header_pos
= priv
->index_chunk_offset
;
186 int i
, entries
, stream_id
;
189 stream_seek(demuxer
->stream
, next_header_pos
);
191 i
= stream_read_dword_le(demuxer
->stream
);
192 if ((i
== -256) || (i
!= MKTAG('I', 'N', 'D', 'X')))
194 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"Something went wrong, no index chunk found on given address (%d)\n",
198 stream_reset(demuxer
->stream
);
199 stream_seek(demuxer
->stream
, origpos
);
204 mp_msg(MSGT_DEMUX
, MSGL_V
,"Reading index table from index chunk (%d)\n",
207 i
= stream_read_dword(demuxer
->stream
);
208 mp_msg(MSGT_DEMUX
, MSGL_V
,"size: %d bytes\n", i
);
210 i
= stream_read_word(demuxer
->stream
);
212 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"Hmm, index table with unknown version (%d), please report it to MPlayer developers!\n", i
);
214 entries
= stream_read_dword(demuxer
->stream
);
215 mp_msg(MSGT_DEMUX
, MSGL_V
,"entries: %d\n", entries
);
217 stream_id
= stream_read_word(demuxer
->stream
);
218 mp_msg(MSGT_DEMUX
, MSGL_V
,"stream_id: %d\n", stream_id
);
220 next_header_pos
= stream_read_dword(demuxer
->stream
);
221 mp_msg(MSGT_DEMUX
, MSGL_V
,"next_header_pos: %d\n", next_header_pos
);
222 if (entries
<= 0 || entries
> MAX_INDEX_ENTRIES
)
230 priv
->index_table_size
[stream_id
] = entries
;
231 priv
->index_table
[stream_id
] = calloc(priv
->index_table_size
[stream_id
], sizeof(real_index_table_t
));
233 for (i
= 0; i
< entries
; i
++)
235 stream_skip(demuxer
->stream
, 2); /* version */
236 priv
->index_table
[stream_id
][i
].timestamp
= stream_read_dword(demuxer
->stream
);
237 priv
->index_table
[stream_id
][i
].offset
= stream_read_dword(demuxer
->stream
);
238 stream_skip(demuxer
->stream
, 4); /* packetno */
239 // priv->index_table[stream_id][i].packetno = stream_read_dword(demuxer->stream);
240 // printf("Index table: Stream#%d: entry: %d: pos: %d\n",
241 // stream_id, i, priv->index_table[stream_id][i].offset);
244 dump_index(demuxer
, stream_id
);
246 if (next_header_pos
> 0)
251 stream_reset(demuxer
->stream
);
252 stream_seek(demuxer
->stream
, origpos
);
261 static void add_index_item(demuxer_t
*demuxer
, int stream_id
, unsigned int timestamp
, int offset
)
263 if ((unsigned)stream_id
< MAX_STREAMS
)
265 real_priv_t
*priv
= demuxer
->priv
;
266 real_index_table_t
*index
;
267 if (priv
->index_table_size
[stream_id
] >= MAX_INDEX_ENTRIES
) {
268 mp_msg(MSGT_DEMUXER
, MSGL_WARN
, "Index too large during building\n");
271 if (priv
->index_table_size
[stream_id
] >= priv
->index_malloc_size
[stream_id
])
273 if (priv
->index_malloc_size
[stream_id
] == 0)
274 priv
->index_malloc_size
[stream_id
] = 2048;
276 priv
->index_malloc_size
[stream_id
] += priv
->index_malloc_size
[stream_id
] / 2;
277 // in case we have a really large chunk...
278 if (priv
->index_table_size
[stream_id
] >=
279 priv
->index_malloc_size
[stream_id
])
280 priv
->index_malloc_size
[stream_id
] =
281 priv
->index_table_size
[stream_id
] + 1;
282 priv
->index_table
[stream_id
] = realloc(priv
->index_table
[stream_id
], priv
->index_malloc_size
[stream_id
]*sizeof(priv
->index_table
[0][0]));
284 if (priv
->index_table_size
[stream_id
] > 0)
286 index
= &priv
->index_table
[stream_id
][priv
->index_table_size
[stream_id
] - 1];
287 if (index
->timestamp
>= timestamp
|| index
->offset
>= offset
)
290 index
= &priv
->index_table
[stream_id
][priv
->index_table_size
[stream_id
]++];
291 index
->timestamp
= timestamp
;
292 index
->offset
= offset
;
296 static void add_index_segment(demuxer_t
*demuxer
, int seek_stream_id
, int64_t seek_timestamp
)
298 int tag
, len
, stream_id
, flags
;
299 unsigned int timestamp
;
300 if (seek_timestamp
!= -1 && (unsigned)seek_stream_id
>= MAX_STREAMS
)
304 demuxer
->filepos
= stream_tell(demuxer
->stream
);
306 tag
= stream_read_dword(demuxer
->stream
);
307 if (tag
== MKTAG('A', 'T', 'A', 'D'))
309 stream_skip(demuxer
->stream
, 14);
310 continue; /* skip to next loop */
313 if (tag
== -256 || len
< 12)
316 stream_id
= stream_read_word(demuxer
->stream
);
317 timestamp
= stream_read_dword(demuxer
->stream
);
319 stream_skip(demuxer
->stream
, 1); /* reserved */
320 flags
= stream_read_char(demuxer
->stream
);
327 add_index_item(demuxer
, stream_id
, timestamp
, demuxer
->filepos
);
328 if (stream_id
== seek_stream_id
&& timestamp
>= seek_timestamp
)
330 stream_seek(demuxer
->stream
, demuxer
->filepos
);
334 // 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);
336 stream_skip(demuxer
->stream
, len
-12);
340 static int generate_index(demuxer_t
*demuxer
)
342 real_priv_t
*priv
= demuxer
->priv
;
343 int origpos
= stream_tell(demuxer
->stream
);
344 int data_pos
= priv
->data_chunk_offset
-10;
348 stream_seek(demuxer
->stream
, data_pos
);
349 tag
= stream_read_dword(demuxer
->stream
);
350 if (tag
!= MKTAG('A', 'T', 'A', 'D'))
352 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"Something went wrong, no data chunk found on given address (%d)\n", data_pos
);
356 stream_skip(demuxer
->stream
, 14);
357 add_index_segment(demuxer
, -1, -1);
359 for (i
= 0; i
< MAX_STREAMS
; i
++)
361 if (priv
->index_table_size
[i
] > 0)
363 dump_index(demuxer
, i
);
366 stream_reset(demuxer
->stream
);
367 stream_seek(demuxer
->stream
, origpos
);
373 static int generate_index(demuxer_t
*demuxer
)
375 real_priv_t
*priv
= demuxer
->priv
;
376 int origpos
= stream_tell(demuxer
->stream
);
377 int data_pos
= priv
->data_chunk_offset
-10;
378 int num_of_packets
= 0;
380 int len
, stream_id
= 0, flags
;
381 unsigned int timestamp
;
385 stream_seek(demuxer
->stream
, data_pos
);
387 i
= stream_read_dword_le(demuxer
->stream
);
388 if ((i
== -256) || (i
!= MKTAG('D', 'A', 'T', 'A')))
390 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"Something went wrong, no data chunk found on given address (%d)\n",
394 stream_skip(demuxer
->stream
, 4); /* chunk size */
395 stream_skip(demuxer
->stream
, 2); /* version */
397 num_of_packets
= stream_read_dword(demuxer
->stream
);
398 mp_msg(MSGT_DEMUX
, MSGL_V
,"Generating index table from raw data (pos: 0x%x) for %d packets\n",
399 data_pos
, num_of_packets
);
401 data_pos
= stream_read_dword_le(demuxer
->stream
)-10; /* next data chunk */
403 for (i
= 0; i
< MAX_STREAMS
; i
++)
405 priv
->index_table_size
[i
] = num_of_packets
;
406 priv
->index_table
[i
] = calloc(priv
->index_table_size
[i
], sizeof(real_index_table_t
));
407 // priv->index_table[stream_id] = realloc(priv->index_table[stream_id],
408 // priv->index_table_size[stream_id] * sizeof(real_index_table_t));
413 // memset(priv->index_table_size, 0, sizeof(int)*MAX_STREAMS);
414 // memset(priv->index_table, 0, sizeof(real_index_table_t)*MAX_STREAMS);
416 while (tab_pos
< num_of_packets
)
418 i
= stream_read_char(demuxer
->stream
);
421 stream_skip(demuxer
->stream
, 1);
422 // stream_skip(demuxer->stream, 2); /* version */
424 len
= stream_read_word(demuxer
->stream
);
425 stream_id
= stream_read_word(demuxer
->stream
);
426 timestamp
= stream_read_dword(demuxer
->stream
);
428 stream_skip(demuxer
->stream
, 1); /* reserved */
429 flags
= stream_read_char(demuxer
->stream
);
433 // priv->index_table_size[stream_id] = i;
434 // if (priv->index_table[stream_id] == NULL)
435 // priv->index_table[stream_id] = malloc(priv->index_table_size[stream_id] * sizeof(real_index_table_t));
437 // priv->index_table[stream_id] = realloc(priv->index_table[stream_id],
438 // priv->index_table_size[stream_id] * sizeof(real_index_table_t));
440 priv
->index_table
[stream_id
][i
].timestamp
= timestamp
;
441 priv
->index_table
[stream_id
][i
].offset
= stream_tell(demuxer
->stream
)-12;
442 priv
->index_table
[stream_id
][i
].len
= len
;
443 priv
->index_table
[stream_id
][i
].packetno
= entries
;
444 priv
->index_table
[stream_id
][i
].flags
= flags
;
449 stream_skip(demuxer
->stream
, len
-12);
451 dump_index(demuxer
, stream_id
);
457 stream_reset(demuxer
->stream
);
458 stream_seek(demuxer
->stream
, origpos
);
467 static int real_check_file(demuxer_t
* demuxer
)
472 mp_msg(MSGT_DEMUX
,MSGL_V
,"Checking for REAL\n");
474 c
= stream_read_dword_le(demuxer
->stream
);
477 if (c
!= MKTAG('.', 'R', 'M', 'F'))
478 return 0; /* bad magic */
480 priv
= malloc(sizeof(real_priv_t
));
481 memset(priv
, 0, sizeof(real_priv_t
));
482 demuxer
->priv
= priv
;
484 return DEMUXER_TYPE_REAL
;
487 void hexdump(char *, unsigned long);
489 #define SKIP_BITS(n) buffer<<=n
490 #define SHOW_BITS(n) ((buffer)>>(32-(n)))
492 double real_fix_timestamp(unsigned char *buf
, unsigned int timestamp
, unsigned int format
, int64_t *kf_base
, int *kf_pts
, double *pts
){
494 unsigned char *s
= buf
+ 1 + (*buf
+1)*8;
495 uint32_t buffer
= (s
[0]<<24) + (s
[1]<<16) + (s
[2]<<8) + s
[3];
496 unsigned int kf
=timestamp
;
498 unsigned int orig_kf
;
500 if(format
==mmioFOURCC('R','V','3','0') || format
==mmioFOURCC('R','V','4','0')){
501 if(format
==mmioFOURCC('R','V','3','0')){
503 pict_type
= SHOW_BITS(2);
507 pict_type
= SHOW_BITS(2);
508 SKIP_BITS(2 + 7 + 3);
511 kf
= SHOW_BITS(13); // kf= 2*SHOW_BITS(12);
514 // I frame, sync timestamps:
515 *kf_base
=(int64_t)timestamp
-kf
;
516 mp_msg(MSGT_DEMUX
, MSGL_DBG2
,"\nTS: base=%08"PRIX64
"\n",*kf_base
);
519 // P/B frame, merge timestamps:
520 int64_t tmp
=(int64_t)timestamp
-*kf_base
;
521 kf
|=tmp
&(~0x1fff); // combine with packet timestamp
522 if(kf
<tmp
-4096) kf
+=8192; else // workaround wrap-around problems
523 if(kf
>tmp
+4096) kf
-=8192;
526 if(pict_type
!= 3){ // P || I frame -> swap timestamps
532 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);
535 // if(pts && (v_pts<*pts || !kf)) v_pts=*pts+frametime;
540 typedef struct dp_hdr_s
{
541 uint32_t chunks
; // number of chunks
542 uint32_t timestamp
; // timestamp from packet header
543 uint32_t len
; // length of actual data
544 uint32_t chunktab
; // offset to chunk offset array
547 static void queue_video_packet(real_priv_t
*priv
, demux_stream_t
*ds
, demux_packet_t
*dp
)
549 dp_hdr_t hdr
= *(dp_hdr_t
*)dp
->buffer
;
550 unsigned char *tmp
= malloc(8*(1+hdr
.chunks
));
551 memcpy(tmp
, dp
->buffer
+hdr
.chunktab
, 8*(1+hdr
.chunks
));
552 memmove(dp
->buffer
+1+8*(1+hdr
.chunks
), dp
->buffer
+sizeof(dp_hdr_t
), hdr
.len
);
553 memcpy(dp
->buffer
+1, tmp
, 8*(1+hdr
.chunks
));
554 *dp
->buffer
= (uint8_t)hdr
.chunks
;
557 if(priv
->video_after_seek
){
559 priv
->kf_pts
= hdr
.timestamp
;
560 priv
->video_after_seek
= 0;
562 if(hdr
.len
>= 3) /* this check may be useless */
563 dp
->pts
= real_fix_timestamp(dp
->buffer
, hdr
.timestamp
,
564 ((sh_video_t
*)ds
->sh
)->format
,
565 &priv
->kf_base
, &priv
->kf_pts
,
567 ds_add_packet(ds
, dp
);
571 // 0 = EOF or no stream found
572 // 1 = successfully read a packet
573 static int demux_real_fill_buffer(demuxer_t
*demuxer
, demux_stream_t
*dsds
)
575 real_priv_t
*priv
= demuxer
->priv
;
576 demux_stream_t
*ds
= NULL
;
578 unsigned int timestamp
;
587 int x
, sps
, cfs
, sph
, spc
, w
;
588 int audioreorder_getnextpk
= 0;
590 // Don't demux video if video codec init failed
591 if (demuxer
->video
->id
>= 0 && !demuxer
->video
->sh
)
592 demuxer
->video
->id
= -2;
594 while(!stream_eof(demuxer
->stream
)){
596 /* Handle audio/video demxing switch for multirate files (non-interleaved) */
597 if (priv
->is_multirate
&& priv
->stream_switch
) {
598 if (priv
->current_apacket
>= priv
->index_table_size
[demuxer
->audio
->id
])
599 demuxer
->audio
->eof
= 1;
600 if (priv
->current_vpacket
>= priv
->index_table_size
[demuxer
->video
->id
])
601 demuxer
->video
->eof
= 1;
602 if (demuxer
->audio
->eof
&& demuxer
->video
->eof
)
604 else if (!demuxer
->audio
->eof
&& demuxer
->video
->eof
)
605 stream_seek(demuxer
->stream
, priv
->audio_curpos
); // Get audio
606 else if (demuxer
->audio
->eof
&& !demuxer
->video
->eof
)
607 stream_seek(demuxer
->stream
, priv
->video_curpos
); // Get video
608 else if (priv
->index_table
[demuxer
->audio
->id
][priv
->current_apacket
].timestamp
<
609 priv
->index_table
[demuxer
->video
->id
][priv
->current_vpacket
].timestamp
)
610 stream_seek(demuxer
->stream
, priv
->audio_curpos
); // Get audio
612 stream_seek(demuxer
->stream
, priv
->video_curpos
); // Get video
613 priv
->stream_switch
= 0;
616 demuxer
->filepos
= stream_tell(demuxer
->stream
);
617 version
= stream_read_word(demuxer
->stream
); /* version */
618 len
= stream_read_word(demuxer
->stream
);
619 if ((version
==0x4441) && (len
==0x5441)) { // new data chunk
620 mp_msg(MSGT_DEMUX
,MSGL_INFO
,"demux_real: New data chunk is coming!!!\n");
621 if (priv
->is_multirate
)
623 stream_skip(demuxer
->stream
,14);
624 demuxer
->filepos
= stream_tell(demuxer
->stream
);
625 version
= stream_read_word(demuxer
->stream
); /* version */
626 len
= stream_read_word(demuxer
->stream
);
627 } else if ((version
== 0x494e) && (len
== 0x4458)) {
628 mp_msg(MSGT_DEMUX
,MSGL_V
,"demux_real: Found INDX chunk. EOF.\n");
629 demuxer
->stream
->eof
=1;
634 if (len
== -256){ /* EOF */
635 // printf("len==-256!\n");
639 mp_msg(MSGT_DEMUX
, MSGL_V
,"%08X: packet v%d len=%d \n",(int)demuxer
->filepos
,(int)version
,(int)len
);
640 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"bad packet len (%d)\n", len
);
641 if ((unsigned)demuxer
->video
->id
< MAX_STREAMS
) {
642 if (priv
->current_vpacket
+ 1 < priv
->index_table_size
[demuxer
->video
->id
]) {
643 stream_seek(demuxer
->stream
, priv
->index_table
[demuxer
->video
->id
][++priv
->current_vpacket
].offset
);
645 } else if ((unsigned)demuxer
->audio
->id
< MAX_STREAMS
) {
646 if (priv
->current_apacket
+ 1 < priv
->index_table_size
[demuxer
->audio
->id
]) {
647 stream_seek(demuxer
->stream
, priv
->index_table
[demuxer
->audio
->id
][++priv
->current_apacket
].offset
);
650 continue; //goto loop;
653 stream_id
= stream_read_word(demuxer
->stream
);
654 timestamp
= stream_read_dword(demuxer
->stream
);
655 reserved
= stream_read_char(demuxer
->stream
);
656 flags
= stream_read_char(demuxer
->stream
);
663 tmp
= stream_read_char(demuxer
->stream
);
664 mp_msg(MSGT_DEMUX
, MSGL_DBG2
,"Version: %d, skipped byte is %d\n", version
, tmp
);
669 add_index_item(demuxer
, stream_id
, timestamp
, demuxer
->filepos
);
671 // printf("%08X: packet v%d len=%4d id=%d pts=%6d rvd=%d flags=%d \n",
672 // (int)demuxer->filepos,(int)version,(int)len, stream_id,
673 // (int) timestamp, reserved, flags);
675 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "\npacket#%d: pos: 0x%0x, len: %d, id: %d, pts: %u, flags: %x rvd:%d\n",
676 priv
->current_packet
, (int)demuxer
->filepos
, len
, stream_id
, timestamp
, flags
, reserved
);
678 priv
->current_packet
++;
681 // printf("s_id=%d aid=%d vid=%d \n",stream_id,demuxer->audio->id,demuxer->video->id);
683 /* check stream_id: */
685 if(demuxer
->audio
->id
==stream_id
){
686 if (priv
->audio_need_keyframe
== 1&& flags
!= 0x2)
690 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "packet is audio (id: %d)\n", stream_id
);
693 priv
->sub_packet_cnt
= 0;
694 audioreorder_getnextpk
= 0;
697 // parse audio chunk:
700 int spos
=stream_tell(demuxer
->stream
);
702 static int cnt2
=CRACK_MATRIX
;
704 if (((sh_audio_t
*)ds
->sh
)->format
== mmioFOURCC('M', 'P', '4', 'A')) {
705 uint16_t sub_packet_lengths
[16], sub_packets
, i
;
707 /* AAC in Real: several AAC frames in one Real packet. */
708 /* Second byte, upper four bits: number of AAC frames */
709 /* next n * 2 bytes: length of the AAC frames in bytes, BE */
712 sub_packets
= (stream_read_word(demuxer
->stream
) & 0xf0) >> 4;
713 if (len
< 2 * sub_packets
)
715 for (i
= 0; i
< sub_packets
; i
++)
716 totlen
+= sub_packet_lengths
[i
] = stream_read_word(demuxer
->stream
);
719 for (i
= 0; i
< sub_packets
; i
++) {
720 demux_packet_t
*dp
= new_demux_packet(sub_packet_lengths
[i
]);
721 stream_read(demuxer
->stream
, dp
->buffer
, sub_packet_lengths
[i
]);
722 if (priv
->a_pts
!= timestamp
)
723 dp
->pts
= timestamp
/ 1000.0;
724 priv
->a_pts
= timestamp
;
725 dp
->pos
= demuxer
->filepos
;
726 ds_add_packet(ds
, dp
);
730 if ((priv
->intl_id
[stream_id
] == mmioFOURCC('I', 'n', 't', '4')) ||
731 (priv
->intl_id
[stream_id
] == mmioFOURCC('g', 'e', 'n', 'r')) ||
732 (priv
->intl_id
[stream_id
] == mmioFOURCC('s', 'i', 'p', 'r'))) {
733 sps
= priv
->sub_packet_size
[stream_id
];
734 sph
= priv
->sub_packet_h
[stream_id
];
735 cfs
= priv
->coded_framesize
[stream_id
];
736 w
= priv
->audiopk_size
[stream_id
];
737 spc
= priv
->sub_packet_cnt
;
738 switch (priv
->intl_id
[stream_id
]) {
739 case mmioFOURCC('I', 'n', 't', '4'):
740 if (len
< cfs
* sph
/2)
742 for (x
= 0; x
< sph
/ 2; x
++)
743 stream_read(demuxer
->stream
, priv
->audio_buf
+ x
* 2 * w
+ spc
* cfs
, cfs
);
745 case mmioFOURCC('g', 'e', 'n', 'r'):
748 for (x
= 0; x
< w
/ sps
; x
++)
749 stream_read(demuxer
->stream
, priv
->audio_buf
+ sps
* (sph
* x
+ ((sph
+ 1) / 2) * (spc
& 1) +
752 case mmioFOURCC('s', 'i', 'p', 'r'):
755 stream_read(demuxer
->stream
, priv
->audio_buf
+ spc
* w
, w
);
756 if (spc
== sph
- 1) {
758 int bs
= sph
* w
* 2 / 96; // nibbles per subpacket
759 // Perform reordering
760 for(n
=0; n
< 38; n
++) {
762 int i
= bs
* sipr_swaps
[n
][0];
763 int o
= bs
* sipr_swaps
[n
][1];
764 // swap nibbles of block 'i' with 'o' TODO: optimize
765 for(j
= 0;j
< bs
; j
++) {
766 int x
= (i
& 1) ? (priv
->audio_buf
[i
>> 1] >> 4) : (priv
->audio_buf
[i
>> 1] & 0x0F);
767 int y
= (o
& 1) ? (priv
->audio_buf
[o
>> 1] >> 4) : (priv
->audio_buf
[o
>> 1] & 0x0F);
769 priv
->audio_buf
[o
>> 1] = (priv
->audio_buf
[o
>> 1] & 0x0F) | (x
<< 4);
771 priv
->audio_buf
[o
>> 1] = (priv
->audio_buf
[o
>> 1] & 0xF0) | x
;
773 priv
->audio_buf
[i
>> 1] = (priv
->audio_buf
[i
>> 1] & 0x0F) | (y
<< 4);
775 priv
->audio_buf
[i
>> 1] = (priv
->audio_buf
[i
>> 1] & 0xF0) | y
;
782 priv
->audio_need_keyframe
= 0;
783 priv
->audio_timestamp
[priv
->sub_packet_cnt
] = (priv
->a_pts
==timestamp
) ? MP_NOPTS_VALUE
: (timestamp
/1000.0);
784 priv
->a_pts
= timestamp
;
785 if (priv
->sub_packet_cnt
== 0)
786 priv
->audio_filepos
= demuxer
->filepos
;
787 if (++(priv
->sub_packet_cnt
) < sph
)
788 audioreorder_getnextpk
= 1;
790 int apk_usize
= ((WAVEFORMATEX
*)((sh_audio_t
*)ds
->sh
)->wf
)->nBlockAlign
;
791 audioreorder_getnextpk
= 0;
792 priv
->sub_packet_cnt
= 0;
793 // Release all the audio packets
794 for (x
= 0; x
< sph
*w
/apk_usize
; x
++) {
795 dp
= new_demux_packet(apk_usize
);
796 memcpy(dp
->buffer
, priv
->audio_buf
+ x
* apk_usize
, apk_usize
);
797 /* Put timestamp only on packets that correspond to original audio packets in file */
798 if (x
* apk_usize
% w
== 0)
799 dp
->pts
= priv
->audio_timestamp
[x
* apk_usize
/ w
];
800 dp
->pos
= priv
->audio_filepos
; // all equal
801 dp
->flags
= x
? 0 : 0x10; // Mark first packet as keyframe
802 ds_add_packet(ds
, dp
);
805 } else { // No interleaving
806 dp
= new_demux_packet(len
);
807 stream_read(demuxer
->stream
, dp
->buffer
, len
);
810 mp_msg(MSGT_DEMUX
, MSGL_V
,"*** audio block len=%d\n",len
);
811 { // HACK - used for reverse engineering the descrambling matrix
812 FILE* f
=fopen("test.rm","r+");
813 fseek(f
,spos
,SEEK_SET
);
815 // for(i=0;i<len;i++) dp->buffer[i]=i/0x12;
816 // for(i=0;i<len;i++) dp->buffer[i]=i;
817 // for(i=0;i<len;i++) dp->buffer[i]=cnt;
818 // for(i=0;i<len;i++) dp->buffer[i]=cnt<<4;
819 for(i
=0;i
<len
;i
++) dp
->buffer
[i
]=(i
==cnt2
) ? (cnt
+16*(8+cnt
)) : 0;
820 if(cnt
==6){ cnt
=0; ++cnt2
; }
821 fwrite(dp
->buffer
, len
, 1, f
);
823 if(cnt2
>0x150) *((int*)NULL
)=1; // sig11 :)
827 if( ((sh_audio_t
*)ds
->sh
)->format
== 0x2000) {
828 // if DNET, swap bytes, as DNET is byte-swapped AC3:
829 char *ptr
= dp
->buffer
;
831 for (i
= 0; i
< len
; i
+= 2)
833 const char tmp
= ptr
[0];
840 if (priv
->audio_need_keyframe
== 1) {
841 priv
->audio_need_keyframe
= 0;
842 } else if(priv
->a_pts
!= timestamp
)
843 dp
->pts
= timestamp
/1000.0;
844 priv
->a_pts
=timestamp
;
845 dp
->pos
= demuxer
->filepos
;
846 dp
->flags
= (flags
& 0x2) ? 0x10 : 0;
847 ds_add_packet(ds
, dp
);
849 } // codec_id check, codec default case
851 // we will not use audio index if we use -idx and have a video
852 if(((!demuxer
->video
->sh
&& index_mode
== 2) || priv
->is_multirate
) && (unsigned)demuxer
->audio
->id
< MAX_STREAMS
) {
853 while (priv
->current_apacket
+ 1 < priv
->index_table_size
[demuxer
->audio
->id
] &&
854 timestamp
> priv
->index_table
[demuxer
->audio
->id
][priv
->current_apacket
].timestamp
) {
855 priv
->current_apacket
+= 1;
856 priv
->stream_switch
= 1;
858 if (priv
->stream_switch
)
859 priv
->audio_curpos
= stream_tell(demuxer
->stream
);
862 // If we're reordering audio packets and we need more data get it
863 if (audioreorder_getnextpk
)
869 if(demuxer
->video
->id
==stream_id
){
872 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "packet is video (id: %d)\n", stream_id
);
874 // parse video chunk:
876 // we need a more complicated, 2nd level demuxing, as the video
877 // frames are stored fragmented in the video chunks :(
878 sh_video_t
*sh_video
= ds
->sh
;
880 unsigned vpkg_header
, vpkg_length
, vpkg_offset
;
886 unsigned char* dp_data
;
889 // printf("xxx len=%d \n",len);
891 // read packet header
892 // bit 7: 1=last block in block chain
893 // bit 6: 1=short header (only one block?)
894 vpkg_header
=stream_read_char(demuxer
->stream
); --len
;
895 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "hdr: %02X (len=%d) ",vpkg_header
,len
);
897 if (0x40==(vpkg_header
&0xc0)) {
898 // seems to be a very short header
899 // 2 bytes, purpose of the second byte yet unknown
901 bummer
=stream_read_char(demuxer
->stream
); --len
;
902 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "%02X",bummer
);
907 if (0==(vpkg_header
&0x40)) {
908 // sub-seqnum (bits 0-6: number of fragment. bit 7: ???)
909 vpkg_subseq
=stream_read_char(demuxer
->stream
);
911 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "subseq: %02X ",vpkg_subseq
);
915 // size of the complete packet
916 // bit 14 is always one (same applies to the offset)
917 vpkg_length
=stream_read_word(demuxer
->stream
);
919 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "l: %02X %02X ",vpkg_length
>>8,vpkg_length
&0xff);
920 if (!(vpkg_length
&0xC000)) {
922 vpkg_length
|=(uint16_t)stream_read_word(demuxer
->stream
);
923 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "l+: %02X %02X ",(vpkg_length
>>8)&0xff,vpkg_length
&0xff);
928 // offset of the following data inside the complete packet
929 // Note: if (hdr&0xC0)==0x80 then offset is relative to the
930 // _end_ of the packet, so it's equal to fragment size!!!
931 vpkg_offset
=stream_read_word(demuxer
->stream
);
933 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "o: %02X %02X ",vpkg_offset
>>8,vpkg_offset
&0xff);
934 if (!(vpkg_offset
&0xC000)) {
936 vpkg_offset
|=(uint16_t)stream_read_word(demuxer
->stream
);
937 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "o+: %02X %02X ",(vpkg_offset
>>8)&0xff,vpkg_offset
&0xff);
942 vpkg_seqnum
=stream_read_char(demuxer
->stream
); --len
;
943 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "seq: %02X ",vpkg_seqnum
);
945 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "\n");
946 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "blklen=%d\n", len
);
947 mp_msg(MSGT_DEMUX
,MSGL_DBG2
, "block: hdr=0x%0x, len=%d, offset=%d, seqnum=%d\n",
948 vpkg_header
, vpkg_length
, vpkg_offset
, vpkg_seqnum
);
952 dp_hdr
=(dp_hdr_t
*)dp
->buffer
;
953 dp_data
=dp
->buffer
+sizeof(dp_hdr_t
);
954 extra
=(uint32_t*)(dp
->buffer
+dp_hdr
->chunktab
);
955 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "we have an incomplete packet (oldseq=%d new=%d)\n",ds
->asf_seq
,vpkg_seqnum
);
956 // we have an incomplete packet:
957 if(ds
->asf_seq
!=vpkg_seqnum
){
958 // this fragment is for new packet, close the old one
959 mp_msg(MSGT_DEMUX
,MSGL_DBG2
, "closing probably incomplete packet, len: %d \n",dp
->len
);
960 queue_video_packet(priv
, ds
, dp
);
963 // append data to it!
965 mp_msg(MSGT_DEMUX
,MSGL_DBG2
,"[chunks=%d subseq=%d]\n",dp_hdr
->chunks
,vpkg_subseq
);
966 if(dp_hdr
->chunktab
+8*(1+dp_hdr
->chunks
)>dp
->len
){
967 // increase buffer size, this should not happen!
968 mp_msg(MSGT_DEMUX
,MSGL_WARN
, "chunktab buffer too small!!!!!\n");
969 dp
->len
=dp_hdr
->chunktab
+8*(4+dp_hdr
->chunks
);
970 dp
->buffer
=realloc(dp
->buffer
,dp
->len
+MP_INPUT_BUFFER_PADDING_SIZE
);
971 memset(dp
->buffer
+ dp
->len
, 0, MP_INPUT_BUFFER_PADDING_SIZE
);
973 dp_hdr
=(dp_hdr_t
*)dp
->buffer
;
974 dp_data
=dp
->buffer
+sizeof(dp_hdr_t
);
975 extra
=(uint32_t*)(dp
->buffer
+dp_hdr
->chunktab
);
977 extra
[2*dp_hdr
->chunks
+0]=le2me_32(1);
978 extra
[2*dp_hdr
->chunks
+1]=le2me_32(dp_hdr
->len
);
979 if(0x80==(vpkg_header
&0xc0)){
981 if(dp_hdr
->len
!=vpkg_length
-vpkg_offset
)
982 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
);
983 if (vpkg_offset
> dp
->len
- sizeof(dp_hdr_t
) - dp_hdr
->len
) vpkg_offset
= dp
->len
- sizeof(dp_hdr_t
) - dp_hdr
->len
;
984 stream_read(demuxer
->stream
, dp_data
+dp_hdr
->len
, vpkg_offset
);
985 if((dp_data
[dp_hdr
->len
]&0x20) && (sh_video
->format
==0x30335652)) --dp_hdr
->chunks
; else
986 dp_hdr
->len
+=vpkg_offset
;
988 mp_dbg(MSGT_DEMUX
,MSGL_DBG2
, "fragment (%d bytes) appended, %d bytes left\n",vpkg_offset
,len
);
989 // we know that this is the last fragment -> we can close the packet!
990 queue_video_packet(priv
, ds
, dp
);
995 // non-last fragment:
996 if(dp_hdr
->len
!=vpkg_offset
)
997 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
);
998 if (len
> dp
->len
- sizeof(dp_hdr_t
) - dp_hdr
->len
) len
= dp
->len
- sizeof(dp_hdr_t
) - dp_hdr
->len
;
999 stream_read(demuxer
->stream
, dp_data
+dp_hdr
->len
, len
);
1000 if((dp_data
[dp_hdr
->len
]&0x20) && (sh_video
->format
==0x30335652)) --dp_hdr
->chunks
; else
1003 break; // no more fragments in this chunk!
1006 // create new packet!
1007 dp
= new_demux_packet(sizeof(dp_hdr_t
)+vpkg_length
+8*(1+2*(vpkg_header
&0x3F)));
1008 // the timestamp seems to be in milliseconds
1009 dp
->pos
= demuxer
->filepos
;
1010 dp
->flags
= (flags
& 0x2) ? 0x10 : 0;
1011 ds
->asf_seq
= vpkg_seqnum
;
1012 dp_hdr
=(dp_hdr_t
*)dp
->buffer
;
1014 dp_hdr
->timestamp
=timestamp
;
1015 dp_hdr
->chunktab
=sizeof(dp_hdr_t
)+vpkg_length
;
1016 dp_data
=dp
->buffer
+sizeof(dp_hdr_t
);
1017 extra
=(uint32_t*)(dp
->buffer
+dp_hdr
->chunktab
);
1018 extra
[0]=le2me_32(1); extra
[1]=0; // offset of the first chunk
1019 if(0x00==(vpkg_header
&0xc0)){
1021 if (len
> dp
->len
- sizeof(dp_hdr_t
)) len
= dp
->len
- sizeof(dp_hdr_t
);
1023 stream_read(demuxer
->stream
, dp_data
, len
);
1028 // whole packet (not fragmented):
1029 if (vpkg_length
> len
) {
1030 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"\n******** WARNING: vpkg_length=%i > len=%i ********\n", vpkg_length
, len
);
1032 * To keep the video stream rolling, we need to break
1033 * here. We shouldn't touch len to make sure rest of the
1034 * broken packet is skipped.
1038 dp_hdr
->len
=vpkg_length
; len
-=vpkg_length
;
1039 stream_read(demuxer
->stream
, dp_data
, vpkg_length
);
1040 queue_video_packet(priv
, ds
, dp
);
1045 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"\n******** !!!!!!!! BUG!! len=%d !!!!!!!!!!! ********\n",len
);
1046 if(len
>0) stream_skip(demuxer
->stream
, len
);
1049 if ((unsigned)demuxer
->video
->id
< MAX_STREAMS
) {
1050 while (priv
->current_vpacket
+ 1 < priv
->index_table_size
[demuxer
->video
->id
] &&
1051 timestamp
> priv
->index_table
[demuxer
->video
->id
][priv
->current_vpacket
+ 1].timestamp
) {
1052 priv
->current_vpacket
+= 1;
1053 priv
->stream_switch
= 1;
1055 if (priv
->stream_switch
)
1056 priv
->video_curpos
= stream_tell(demuxer
->stream
);
1062 if((unsigned)stream_id
<MAX_STREAMS
){
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
);
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
);
1086 mp_msg(MSGT_DEMUX
,MSGL_DBG2
, "unknown stream id (%d)\n", stream_id
);
1088 stream_skip(demuxer
->stream
, len
);
1093 static demuxer_t
* demux_open_real(demuxer_t
* demuxer
)
1095 real_priv_t
* priv
= demuxer
->priv
;
1102 header_size
= stream_read_dword(demuxer
->stream
); /* header size */
1103 mp_msg(MSGT_DEMUX
,MSGL_V
, "real: Header size: %d\n", header_size
);
1104 i
= stream_read_word(demuxer
->stream
); /* version */
1105 mp_msg(MSGT_DEMUX
,MSGL_V
, "real: Header object version: %d\n", i
);
1106 if (header_size
== 0x10)
1107 i
= stream_read_word(demuxer
->stream
);
1108 else /* we should test header_size here too. */
1109 i
= stream_read_dword(demuxer
->stream
);
1110 mp_msg(MSGT_DEMUX
,MSGL_V
, "real: File version: %d\n", i
);
1111 num_of_headers
= stream_read_dword(demuxer
->stream
);
1114 for (i
= 1; i
<= num_of_headers
; i
++)
1115 // for (i = 1; ; i++)
1117 int chunk_id
, chunk_pos
, chunk_size
;
1119 chunk_pos
= stream_tell(demuxer
->stream
);
1120 chunk_id
= stream_read_dword_le(demuxer
->stream
);
1121 chunk_size
= stream_read_dword(demuxer
->stream
);
1123 stream_skip(demuxer
->stream
, 2); /* version */
1125 mp_msg(MSGT_DEMUX
,MSGL_V
, "Chunk: %.4s (%x) (size: 0x%x, offset: 0x%x)\n",
1126 (char *)&chunk_id
, chunk_id
, chunk_size
, chunk_pos
);
1128 if (chunk_id
!= MKTAG('D', 'A', 'T', 'A') && chunk_size
< 10){
1129 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"demux_real: invalid chunksize! (%d)\n",chunk_size
);
1135 case MKTAG('P', 'R', 'O', 'P'):
1136 /* Properties header */
1138 stream_skip(demuxer
->stream
, 4); /* max bitrate */
1139 stream_skip(demuxer
->stream
, 4); /* avg bitrate */
1140 stream_skip(demuxer
->stream
, 4); /* max packet size */
1141 stream_skip(demuxer
->stream
, 4); /* avg packet size */
1142 stream_skip(demuxer
->stream
, 4); /* nb packets */
1143 priv
->duration
= stream_read_dword(demuxer
->stream
)/1000; /* duration */
1144 stream_skip(demuxer
->stream
, 4); /* preroll */
1145 priv
->index_chunk_offset
= stream_read_dword(demuxer
->stream
);
1146 mp_msg(MSGT_DEMUX
,MSGL_V
,"First index chunk offset: 0x%x\n", priv
->index_chunk_offset
);
1147 priv
->data_chunk_offset
= stream_read_dword(demuxer
->stream
)+10;
1148 mp_msg(MSGT_DEMUX
,MSGL_V
,"First data chunk offset: 0x%x\n", priv
->data_chunk_offset
);
1149 stream_skip(demuxer
->stream
, 2); /* nb streams */
1151 stream_skip(demuxer
->stream
, 2); /* flags */
1154 int flags
= stream_read_word(demuxer
->stream
);
1158 mp_msg(MSGT_DEMUX
,MSGL_V
,"Flags (%x): ", flags
);
1160 mp_msg(MSGT_DEMUX
,MSGL_V
,"[save allowed] ");
1162 mp_msg(MSGT_DEMUX
,MSGL_V
,"[perfect play (more buffers)] ");
1164 mp_msg(MSGT_DEMUX
,MSGL_V
,"[live broadcast] ");
1165 mp_msg(MSGT_DEMUX
,MSGL_V
,"\n");
1170 case MKTAG('C', 'O', 'N', 'T'):
1172 /* Content description header */
1176 len
= stream_read_word(demuxer
->stream
);
1179 buf
= malloc(len
+1);
1180 stream_read(demuxer
->stream
, buf
, len
);
1182 demux_info_add(demuxer
, "title", buf
);
1186 len
= stream_read_word(demuxer
->stream
);
1189 buf
= malloc(len
+1);
1190 stream_read(demuxer
->stream
, buf
, len
);
1192 demux_info_add(demuxer
, "author", buf
);
1196 len
= stream_read_word(demuxer
->stream
);
1199 buf
= malloc(len
+1);
1200 stream_read(demuxer
->stream
, buf
, len
);
1202 demux_info_add(demuxer
, "copyright", buf
);
1206 len
= stream_read_word(demuxer
->stream
);
1209 buf
= malloc(len
+1);
1210 stream_read(demuxer
->stream
, buf
, len
);
1212 demux_info_add(demuxer
, "comment", buf
);
1217 case MKTAG('M', 'D', 'P', 'R'):
1219 /* Media properties header */
1222 int codec_data_size
;
1226 char *descr
, *mimet
= NULL
;
1228 stream_id
= stream_read_word(demuxer
->stream
);
1229 mp_msg(MSGT_DEMUX
,MSGL_V
,"Found new stream (id: %d)\n", stream_id
);
1231 stream_skip(demuxer
->stream
, 4); /* max bitrate */
1232 bitrate
= stream_read_dword(demuxer
->stream
); /* avg bitrate */
1233 stream_skip(demuxer
->stream
, 4); /* max packet size */
1234 stream_skip(demuxer
->stream
, 4); /* avg packet size */
1235 stream_skip(demuxer
->stream
, 4); /* start time */
1236 stream_skip(demuxer
->stream
, 4); /* preroll */
1237 stream_skip(demuxer
->stream
, 4); /* duration */
1239 if ((len
= stream_read_char(demuxer
->stream
)) > 0) {
1240 descr
= malloc(len
+1);
1241 stream_read(demuxer
->stream
, descr
, len
);
1243 mp_msg(MSGT_DEMUX
, MSGL_INFO
,"Stream description: %s\n", descr
);
1246 if ((len
= stream_read_char(demuxer
->stream
)) > 0) {
1247 mimet
= malloc(len
+1);
1248 stream_read(demuxer
->stream
, mimet
, len
);
1250 mp_msg(MSGT_DEMUX
, MSGL_INFO
,"Stream mimetype: %s\n", mimet
);
1253 /* Type specific header */
1254 codec_data_size
= stream_read_dword(demuxer
->stream
);
1255 codec_pos
= stream_tell(demuxer
->stream
);
1258 #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 if (!strncmp(mimet
,"audio/",6)) {
1262 if (strstr(mimet
,"x-pn-realaudio") || strstr(mimet
,"x-pn-multirate-realaudio")) {
1263 tmp
= stream_read_dword(demuxer
->stream
);
1264 if (tmp
!= MKTAG(0xfd, 'a', 'r', '.'))
1266 mp_msg(MSGT_DEMUX
,MSGL_V
,"Audio: can't find .ra in codec data\n");
1269 sh_audio_t
*sh
= new_sh_audio(demuxer
, stream_id
);
1270 char buf
[128]; /* for codec name */
1272 int sub_packet_size
;
1276 int coded_frame_size
;
1277 int codecdata_length
;
1281 mp_msg(MSGT_DEMUX
, MSGL_INFO
, MSGTR_AudioID
, "real", stream_id
);
1282 mp_msg(MSGT_DEMUX
,MSGL_V
,"Found audio stream!\n");
1283 version
= stream_read_word(demuxer
->stream
);
1284 mp_msg(MSGT_DEMUX
,MSGL_V
,"version: %d\n", version
);
1286 stream_skip(demuxer
->stream
, 2);
1287 stream_skip(demuxer
->stream
, 10);
1288 stream_skip(demuxer
->stream
, 4);
1289 // Name, author, (c) are also in CONT tag
1290 if ((i
= stream_read_char(demuxer
->stream
)) != 0) {
1292 stream_read(demuxer
->stream
, buft
, i
);
1294 demux_info_add(demuxer
, "Name", buft
);
1297 if ((i
= stream_read_char(demuxer
->stream
)) != 0) {
1299 stream_read(demuxer
->stream
, buft
, i
);
1301 demux_info_add(demuxer
, "Author", buft
);
1304 if ((i
= stream_read_char(demuxer
->stream
)) != 0) {
1306 stream_read(demuxer
->stream
, buft
, i
);
1308 demux_info_add(demuxer
, "Copyright", buft
);
1311 if ((i
= stream_read_char(demuxer
->stream
)) != 0)
1312 mp_msg(MSGT_DEMUX
,MSGL_WARN
,"Last header byte is not zero!\n");
1313 stream_skip(demuxer
->stream
, 1);
1314 i
= stream_read_char(demuxer
->stream
);
1315 sh
->format
= stream_read_dword_le(demuxer
->stream
);
1317 mp_msg(MSGT_DEMUX
,MSGL_WARN
,"Audio FourCC size is not 4 (%d), please report to "
1318 "MPlayer developers\n", i
);
1319 stream_skip(demuxer
->stream
, i
- 4);
1321 if (sh
->format
!= mmioFOURCC('l','p','c','J')) {
1322 mp_msg(MSGT_DEMUX
,MSGL_WARN
,"Version 3 audio with FourCC %8x, please report to "
1323 "MPlayer developers\n", sh
->format
);
1326 sh
->samplesize
= 16;
1327 sh
->samplerate
= 8000;
1329 strcpy(buf
, "14_4");
1331 stream_skip(demuxer
->stream
, 2); // 00 00
1332 stream_skip(demuxer
->stream
, 4); /* .ra4 or .ra5 */
1333 stream_skip(demuxer
->stream
, 4); // ???
1334 stream_skip(demuxer
->stream
, 2); /* version (4 or 5) */
1335 hdr_size
= stream_read_dword(demuxer
->stream
); // header size
1336 mp_msg(MSGT_DEMUX
,MSGL_V
,"header size: %d\n", hdr_size
);
1337 flavor
= stream_read_word(demuxer
->stream
);/* codec flavor id */
1338 coded_frame_size
= stream_read_dword(demuxer
->stream
);/* needed by codec */
1339 mp_msg(MSGT_DEMUX
,MSGL_V
,"coded_frame_size: %d\n", coded_frame_size
);
1340 stream_skip(demuxer
->stream
, 4); // big number
1341 stream_skip(demuxer
->stream
, 4); // bigger number
1342 stream_skip(demuxer
->stream
, 4); // 2 || -''-
1343 sub_packet_h
= stream_read_word(demuxer
->stream
);
1344 mp_msg(MSGT_DEMUX
,MSGL_V
,"sub_packet_h: %d\n", sub_packet_h
);
1345 frame_size
= stream_read_word(demuxer
->stream
);
1346 mp_msg(MSGT_DEMUX
,MSGL_V
,"frame_size: %d\n", frame_size
);
1347 sub_packet_size
= stream_read_word(demuxer
->stream
);
1348 mp_msg(MSGT_DEMUX
,MSGL_V
,"sub_packet_size: %d\n", sub_packet_size
);
1349 stream_skip(demuxer
->stream
, 2); // 0
1352 stream_skip(demuxer
->stream
, 6); //0,srate,0
1354 sh
->samplerate
= stream_read_word(demuxer
->stream
);
1355 stream_skip(demuxer
->stream
, 2); // 0
1356 sh
->samplesize
= stream_read_word(demuxer
->stream
)/8;
1357 sh
->channels
= stream_read_word(demuxer
->stream
);
1358 mp_msg(MSGT_DEMUX
,MSGL_V
,"samplerate: %d, channels: %d\n",
1359 sh
->samplerate
, sh
->channels
);
1363 stream_read(demuxer
->stream
, buf
, 4); // interleaver id
1364 priv
->intl_id
[stream_id
] = MKTAG(buf
[0], buf
[1], buf
[2], buf
[3]);
1365 stream_read(demuxer
->stream
, buf
, 4); // fourcc
1370 /* Interleaver id */
1371 get_str(1, demuxer
, buf
, sizeof(buf
));
1372 priv
->intl_id
[stream_id
] = MKTAG(buf
[0], buf
[1], buf
[2], buf
[3]);
1374 get_str(1, demuxer
, buf
, sizeof(buf
));
1378 /* Emulate WAVEFORMATEX struct: */
1379 sh
->wf
= malloc(sizeof(WAVEFORMATEX
));
1380 memset(sh
->wf
, 0, sizeof(WAVEFORMATEX
));
1381 sh
->wf
->nChannels
= sh
->channels
;
1382 sh
->wf
->wBitsPerSample
= sh
->samplesize
*8;
1383 sh
->wf
->nSamplesPerSec
= sh
->samplerate
;
1384 sh
->wf
->nAvgBytesPerSec
= bitrate
/8;
1385 sh
->wf
->nBlockAlign
= frame_size
;
1387 sh
->format
= MKTAG(buf
[0], buf
[1], buf
[2], buf
[3]);
1391 case MKTAG('d', 'n', 'e', 't'):
1392 mp_msg(MSGT_DEMUX
,MSGL_V
,"Audio: DNET -> AC3\n");
1393 // sh->format = 0x2000;
1395 case MKTAG('1', '4', '_', '4'):
1396 sh
->wf
->nBlockAlign
= 0x14;
1399 case MKTAG('2', '8', '_', '8'):
1400 sh
->wf
->nBlockAlign
= coded_frame_size
;
1403 case MKTAG('s', 'i', 'p', 'r'):
1404 case MKTAG('a', 't', 'r', 'c'):
1405 case MKTAG('c', 'o', 'o', 'k'):
1406 // realaudio codec plugins - common:
1407 stream_skip(demuxer
->stream
,3); // Skip 3 unknown bytes
1409 stream_skip(demuxer
->stream
,1); // Skip 1 additional unknown byte
1410 codecdata_length
=stream_read_dword(demuxer
->stream
);
1411 // Check extradata len, we can't store bigger values in cbSize anyway
1412 if ((unsigned)codecdata_length
> 0xffff) {
1413 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Extradata too big (%d)\n", codecdata_length
);
1414 goto skip_this_chunk
;
1416 sh
->wf
->cbSize
= codecdata_length
;
1417 sh
->wf
= realloc(sh
->wf
, sizeof(WAVEFORMATEX
)+sh
->wf
->cbSize
);
1418 stream_read(demuxer
->stream
, ((char*)(sh
->wf
+1)), codecdata_length
); // extras
1419 if (priv
->intl_id
[stream_id
] == MKTAG('g', 'e', 'n', 'r'))
1420 sh
->wf
->nBlockAlign
= sub_packet_size
;
1422 sh
->wf
->nBlockAlign
= coded_frame_size
;
1426 case MKTAG('r', 'a', 'a', 'c'):
1427 case MKTAG('r', 'a', 'c', 'p'):
1428 /* This is just AAC. The two or five bytes of */
1429 /* config data needed for libfaad are stored */
1430 /* after the audio headers. */
1431 stream_skip(demuxer
->stream
,3); // Skip 3 unknown bytes
1433 stream_skip(demuxer
->stream
,1); // Skip 1 additional unknown byte
1434 codecdata_length
=stream_read_dword(demuxer
->stream
);
1435 if (codecdata_length
>=1) {
1436 sh
->codecdata_len
= codecdata_length
- 1;
1437 sh
->codecdata
= calloc(sh
->codecdata_len
, 1);
1438 stream_skip(demuxer
->stream
, 1);
1439 stream_read(demuxer
->stream
, sh
->codecdata
, sh
->codecdata_len
);
1441 sh
->format
= mmioFOURCC('M', 'P', '4', 'A');
1444 mp_msg(MSGT_DEMUX
,MSGL_V
,"Audio: Unknown (%s)\n", buf
);
1447 // Interleaver setup
1448 priv
->sub_packet_size
[stream_id
] = sub_packet_size
;
1449 priv
->sub_packet_h
[stream_id
] = sub_packet_h
;
1450 priv
->coded_framesize
[stream_id
] = coded_frame_size
;
1451 priv
->audiopk_size
[stream_id
] = frame_size
;
1453 sh
->wf
->wFormatTag
= sh
->format
;
1455 mp_msg(MSGT_DEMUX
,MSGL_V
,"audio fourcc: %.4s (%x)\n", (char *)&sh
->format
, sh
->format
);
1456 if ( mp_msg_test(MSGT_DEMUX
,MSGL_V
) )
1457 print_wave_header(sh
->wf
, MSGL_V
);
1459 /* Select audio stream with highest bitrate if multirate file*/
1460 if (priv
->is_multirate
&& ((demuxer
->audio
->id
== -1) ||
1461 ((demuxer
->audio
->id
>= 0) && priv
->a_bitrate
&& (bitrate
> priv
->a_bitrate
)))) {
1462 demuxer
->audio
->id
= stream_id
;
1463 priv
->a_bitrate
= bitrate
;
1464 mp_msg(MSGT_DEMUX
,MSGL_DBG2
,"Multirate autoselected audio id %d with bitrate %d\n", stream_id
, bitrate
);
1467 if(demuxer
->audio
->id
==stream_id
){
1468 sh
->ds
=demuxer
->audio
;
1469 demuxer
->audio
->sh
=sh
;
1470 priv
->audio_buf
= calloc(priv
->sub_packet_h
[demuxer
->audio
->id
], priv
->audiopk_size
[demuxer
->audio
->id
]);
1471 priv
->audio_timestamp
= calloc(priv
->sub_packet_h
[demuxer
->audio
->id
], sizeof(double));
1480 } else if (strstr(mimet
,"X-MP3-draft-00")) {
1481 sh_audio_t
*sh
= new_sh_audio(demuxer
, stream_id
);
1482 mp_msg(MSGT_DEMUX
, MSGL_INFO
, MSGTR_AudioID
, "real", stream_id
);
1484 /* Emulate WAVEFORMATEX struct: */
1485 sh
->wf
= malloc(sizeof(WAVEFORMATEX
));
1486 memset(sh
->wf
, 0, sizeof(WAVEFORMATEX
));
1487 sh
->wf
->nChannels
= 0;//sh->channels;
1488 sh
->wf
->wBitsPerSample
= 16;
1489 sh
->wf
->nSamplesPerSec
= 0;//sh->samplerate;
1490 sh
->wf
->nAvgBytesPerSec
= 0;//bitrate;
1491 sh
->wf
->nBlockAlign
= 0;//frame_size;
1493 sh
->wf
->wFormatTag
= sh
->format
= mmioFOURCC('a','d','u',0x55);
1495 if(demuxer
->audio
->id
==stream_id
){
1496 sh
->ds
=demuxer
->audio
;
1497 demuxer
->audio
->sh
=sh
;
1501 } else if (strstr(mimet
,"x-ralf-mpeg4")) {
1502 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Real lossless audio not supported yet\n");
1503 } else if (strstr(mimet
,"x-pn-encrypted-ra")) {
1504 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Encrypted audio is not supported\n");
1506 mp_msg(MSGT_DEMUX
,MSGL_V
,"Unknown audio stream format\n");
1508 } else if (!strncmp(mimet
,"video/",6)) {
1509 if (strstr(mimet
,"x-pn-realvideo") || strstr(mimet
,"x-pn-multirate-realvideo")) {
1510 stream_skip(demuxer
->stream
, 4); // VIDO length, same as codec_data_size
1511 tmp
= stream_read_dword(demuxer
->stream
);
1512 if(tmp
!= MKTAG('O', 'D', 'I', 'V'))
1514 mp_msg(MSGT_DEMUX
,MSGL_V
,"Video: can't find VIDO in codec data\n");
1517 sh_video_t
*sh
= new_sh_video(demuxer
, stream_id
);
1518 mp_msg(MSGT_DEMUX
, MSGL_INFO
, MSGTR_VideoID
, "real", stream_id
);
1520 sh
->format
= stream_read_dword_le(demuxer
->stream
); /* fourcc */
1521 mp_msg(MSGT_DEMUX
,MSGL_V
,"video fourcc: %.4s (%x)\n", (char *)&sh
->format
, sh
->format
);
1523 /* emulate BITMAPINFOHEADER */
1524 sh
->bih
= malloc(sizeof(BITMAPINFOHEADER
));
1525 memset(sh
->bih
, 0, sizeof(BITMAPINFOHEADER
));
1526 sh
->bih
->biSize
= sizeof(BITMAPINFOHEADER
);
1527 sh
->disp_w
= sh
->bih
->biWidth
= stream_read_word(demuxer
->stream
);
1528 sh
->disp_h
= sh
->bih
->biHeight
= stream_read_word(demuxer
->stream
);
1529 sh
->bih
->biPlanes
= 1;
1530 sh
->bih
->biBitCount
= 24;
1531 sh
->bih
->biCompression
= sh
->format
;
1532 sh
->bih
->biSizeImage
= sh
->bih
->biWidth
*sh
->bih
->biHeight
*3;
1534 sh
->fps
= (float) stream_read_word(demuxer
->stream
);
1535 if (sh
->fps
<=0) sh
->fps
=24; // we probably won't even care about fps
1536 sh
->frametime
= 1.0f
/sh
->fps
;
1539 stream_skip(demuxer
->stream
, 4);
1541 mp_msg(MSGT_DEMUX
, MSGL_V
,"unknown1: 0x%X \n",stream_read_dword(demuxer
->stream
));
1542 mp_msg(MSGT_DEMUX
, MSGL_V
,"unknown2: 0x%X \n",stream_read_word(demuxer
->stream
));
1543 mp_msg(MSGT_DEMUX
, MSGL_V
,"unknown3: 0x%X \n",stream_read_word(demuxer
->stream
));
1545 // if(sh->format==0x30335652 || sh->format==0x30325652 )
1548 int tmp
=stream_read_word(demuxer
->stream
);
1550 sh
->fps
=tmp
; sh
->frametime
= 1.0f
/sh
->fps
;
1553 int fps
=stream_read_word(demuxer
->stream
);
1554 mp_msg(MSGT_DEMUX
, MSGL_WARN
,"realvid: ignoring FPS = %d\n",fps
);
1556 stream_skip(demuxer
->stream
, 2);
1559 // read and store codec extradata
1560 unsigned int cnt
= codec_data_size
- (stream_tell(demuxer
->stream
) - codec_pos
);
1561 if (cnt
> 0x7fffffff - sizeof(BITMAPINFOHEADER
)) {
1562 mp_msg(MSGT_DEMUX
, MSGL_ERR
,"Extradata too big (%u)\n", cnt
);
1564 sh
->bih
= realloc(sh
->bih
, sizeof(BITMAPINFOHEADER
) + cnt
);
1565 sh
->bih
->biSize
+= cnt
;
1566 stream_read(demuxer
->stream
, ((unsigned char*)(sh
->bih
+1)), cnt
);
1569 if(sh
->format
== 0x30315652 && ((unsigned char*)(sh
->bih
+1))[6] == 0x30)
1570 sh
->bih
->biCompression
= sh
->format
= mmioFOURCC('R', 'V', '1', '3');
1572 /* Select video stream with highest bitrate if multirate file*/
1573 if (priv
->is_multirate
&& ((demuxer
->video
->id
== -1) ||
1574 ((demuxer
->video
->id
>= 0) && priv
->v_bitrate
&& (bitrate
> priv
->v_bitrate
)))) {
1575 demuxer
->video
->id
= stream_id
;
1576 priv
->v_bitrate
= bitrate
;
1577 mp_msg(MSGT_DEMUX
,MSGL_DBG2
,"Multirate autoselected video id %d with bitrate %d\n", stream_id
, bitrate
);
1580 if(demuxer
->video
->id
==stream_id
){
1581 sh
->ds
=demuxer
->video
;
1582 demuxer
->video
->sh
=sh
;
1589 mp_msg(MSGT_DEMUX
,MSGL_V
,"Unknown video stream format\n");
1591 } else if (strstr(mimet
,"logical-")) {
1592 if (strstr(mimet
,"fileinfo")) {
1593 mp_msg(MSGT_DEMUX
,MSGL_V
,"Got a logical-fileinfo chunk\n");
1594 } else if (strstr(mimet
,"-audio") || strstr(mimet
,"-video")) {
1596 int stream_list
[MAX_STREAMS
];
1598 priv
->is_multirate
= 1;
1599 stream_skip(demuxer
->stream
, 4); // Length of codec data (repeated)
1600 stream_cnt
= stream_read_dword(demuxer
->stream
); // Get number of audio or video streams
1601 if ((unsigned)stream_cnt
>= MAX_STREAMS
) {
1602 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Too many streams in %s. Big troubles ahead.\n", mimet
);
1603 goto skip_this_chunk
;
1605 for (i
= 0; i
< stream_cnt
; i
++)
1606 stream_list
[i
] = stream_read_word(demuxer
->stream
);
1607 for (i
= 0; i
< stream_cnt
; i
++)
1608 if ((unsigned)stream_list
[i
] >= MAX_STREAMS
) {
1609 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Stream id out of range: %d. Ignored.\n", stream_list
[i
]);
1610 stream_skip(demuxer
->stream
, 4); // Skip DATA offset for broken stream
1612 priv
->str_data_offset
[stream_list
[i
]] = stream_read_dword(demuxer
->stream
);
1613 mp_msg(MSGT_DEMUX
,MSGL_V
,"Stream %d with DATA offset 0x%08x\n", stream_list
[i
], priv
->str_data_offset
[stream_list
[i
]]);
1615 // Skip the rest of this chunk
1617 mp_msg(MSGT_DEMUX
,MSGL_V
,"Unknown logical stream\n");
1620 mp_msg(MSGT_DEMUX
, MSGL_ERR
, "Not audio/video stream or unsupported!\n");
1625 /* skip codec info */
1626 tmp
= stream_tell(demuxer
->stream
) - codec_pos
;
1627 mp_msg(MSGT_DEMUX
,MSGL_V
,"### skipping %d bytes of codec info\n", codec_data_size
- tmp
);
1630 for(i
=0;i
<codec_data_size
- tmp
;i
++)
1631 mp_msg(MSGT_DEMUX
, MSGL_V
," %02X",stream_read_char(demuxer
->stream
));
1632 mp_msg(MSGT_DEMUX
, MSGL_V
,"\n");
1635 stream_skip(demuxer
->stream
, codec_data_size
- tmp
);
1642 case MKTAG('D', 'A', 'T', 'A'):
1644 case MKTAG('I', 'N', 'D', 'X'):
1646 mp_msg(MSGT_DEMUX
,MSGL_V
,"Unknown chunk: %x\n", chunk_id
);
1647 stream_skip(demuxer
->stream
, chunk_size
- 10);
1653 if(priv
->is_multirate
) {
1654 mp_msg(MSGT_DEMUX
,MSGL_V
,"Selected video id %d audio id %d\n", demuxer
->video
->id
, demuxer
->audio
->id
);
1655 /* Perform some sanity checks to avoid checking streams id all over the code*/
1656 if (demuxer
->audio
->id
>= MAX_STREAMS
) {
1657 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Invalid audio stream %d. No sound will be played.\n", demuxer
->audio
->id
);
1658 demuxer
->audio
->id
= -2;
1659 } else if ((demuxer
->audio
->id
>= 0) && (priv
->str_data_offset
[demuxer
->audio
->id
] == 0)) {
1660 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Audio stream %d not found. No sound will be played.\n", demuxer
->audio
->id
);
1661 demuxer
->audio
->id
= -2;
1663 if (demuxer
->video
->id
>= MAX_STREAMS
) {
1664 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Invalid video stream %d. No video will be played.\n", demuxer
->video
->id
);
1665 demuxer
->video
->id
= -2;
1666 } else if ((demuxer
->video
->id
>= 0) && (priv
->str_data_offset
[demuxer
->video
->id
] == 0)) {
1667 mp_msg(MSGT_DEMUX
,MSGL_ERR
,"Video stream %d not found. No video will be played.\n", demuxer
->video
->id
);
1668 demuxer
->video
->id
= -2;
1672 if(priv
->is_multirate
&& ((demuxer
->video
->id
>= 0) || (demuxer
->audio
->id
>=0))) {
1673 /* If audio or video only, seek to right place and behave like standard file */
1674 if (demuxer
->video
->id
< 0) {
1675 // Stream is audio only, or -novideo
1676 stream_seek(demuxer
->stream
, priv
->data_chunk_offset
= priv
->str_data_offset
[demuxer
->audio
->id
]+10);
1677 priv
->is_multirate
= 0;
1679 if (demuxer
->audio
->id
< 0) {
1680 // Stream is video only, or -nosound
1681 stream_seek(demuxer
->stream
, priv
->data_chunk_offset
= priv
->str_data_offset
[demuxer
->video
->id
]+10);
1682 priv
->is_multirate
= 0;
1686 if(!priv
->is_multirate
) {
1687 // printf("i=%d num_of_headers=%d \n",i,num_of_headers);
1688 priv
->num_of_packets
= stream_read_dword(demuxer
->stream
);
1689 stream_skip(demuxer
->stream
, 4); /* next data header */
1691 mp_msg(MSGT_DEMUX
,MSGL_V
,"Packets in file: %d\n", priv
->num_of_packets
);
1693 if (priv
->num_of_packets
== 0)
1694 priv
->num_of_packets
= -10;
1696 priv
->audio_curpos
= priv
->str_data_offset
[demuxer
->audio
->id
] + 18;
1697 stream_seek(demuxer
->stream
, priv
->str_data_offset
[demuxer
->audio
->id
]+10);
1698 priv
->a_num_of_packets
=priv
->a_num_of_packets
= stream_read_dword(demuxer
->stream
);
1699 priv
->video_curpos
= priv
->str_data_offset
[demuxer
->video
->id
] + 18;
1700 stream_seek(demuxer
->stream
, priv
->str_data_offset
[demuxer
->video
->id
]+10);
1701 priv
->v_num_of_packets
= stream_read_dword(demuxer
->stream
);
1702 priv
->stream_switch
= 1;
1703 /* Index required for multirate playback, force building if it's not there */
1704 /* but respect user request to force index regeneration */
1705 if (index_mode
== -1)
1710 priv
->audio_need_keyframe
= 0;
1711 priv
->video_after_seek
= 0;
1713 switch (index_mode
){
1714 case -1: // untouched
1715 if (priv
->index_chunk_offset
&& parse_index_chunk(demuxer
))
1717 demuxer
->seekable
= 1;
1720 case 1: // use (generate index)
1721 if (priv
->index_chunk_offset
&& parse_index_chunk(demuxer
))
1723 demuxer
->seekable
= 1;
1725 generate_index(demuxer
);
1726 demuxer
->seekable
= 1;
1729 case 2: // force generating index
1730 generate_index(demuxer
);
1731 demuxer
->seekable
= 1;
1733 default: // do nothing
1738 if(demuxer
->video
->id
==-1 && v_streams
>0){
1739 // find the valid video stream:
1740 if(!ds_fill_buffer(demuxer
->video
)){
1741 mp_msg(MSGT_DEMUXER
,MSGL_INFO
,"RM: " MSGTR_MissingVideoStream
);
1744 if(demuxer
->audio
->id
==-1 && a_streams
>0){
1745 // find the valid audio stream:
1746 if(!ds_fill_buffer(demuxer
->audio
)){
1747 mp_msg(MSGT_DEMUXER
,MSGL_INFO
,"RM: " MSGTR_MissingAudioStream
);
1751 if(demuxer
->video
->sh
){
1752 sh_video_t
*sh
=demuxer
->video
->sh
;
1753 mp_msg(MSGT_DEMUX
,MSGL_V
,"VIDEO: %.4s [%08X,%08X] %dx%d (aspect %4.2f) %4.2f fps\n",
1754 (char *)&sh
->format
,((unsigned int*)(sh
->bih
+1))[1],((unsigned int*)(sh
->bih
+1))[0],
1755 sh
->disp_w
,sh
->disp_h
,sh
->aspect
,sh
->fps
);
1758 if(demuxer
->audio
->sh
){
1759 sh_audio_t
*sh
=demuxer
->audio
->sh
;
1760 mp_msg(MSGT_DEMUX
,MSGL_V
,"AUDIO: %.4s [%08X]\n",
1761 (char *)&sh
->format
,sh
->format
);
1767 static void demux_close_real(demuxer_t
*demuxer
)
1770 real_priv_t
* priv
= demuxer
->priv
;
1773 for(i
=0; i
<MAX_STREAMS
; i
++)
1774 if(priv
->index_table
[i
])
1775 free(priv
->index_table
[i
]);
1776 if (priv
->audio_buf
)
1777 free(priv
->audio_buf
);
1778 if (priv
->audio_timestamp
)
1779 free(priv
->audio_timestamp
);
1786 /* please upload RV10 samples WITH INDEX CHUNK */
1787 static void demux_seek_real(demuxer_t
*demuxer
, float rel_seek_secs
, float audio_delay
, int flags
)
1789 real_priv_t
*priv
= demuxer
->priv
;
1790 demux_stream_t
*d_audio
= demuxer
->audio
;
1791 demux_stream_t
*d_video
= demuxer
->video
;
1792 sh_audio_t
*sh_audio
= d_audio
->sh
;
1793 sh_video_t
*sh_video
= d_video
->sh
;
1794 int vid
= d_video
->id
, aid
= d_audio
->id
;
1795 int next_offset
= 0;
1796 int64_t cur_timestamp
= 0;
1801 if (sh_video
&& (unsigned)vid
< MAX_STREAMS
&& priv
->index_table_size
[vid
])
1803 if (sh_audio
&& (unsigned)aid
< MAX_STREAMS
&& priv
->index_table_size
[aid
])
1806 // printf("streams: %d\n", streams);
1811 if (flags
& SEEK_ABSOLUTE
)
1812 priv
->current_apacket
= priv
->current_vpacket
= 0;
1813 if (flags
& SEEK_FACTOR
)
1814 rel_seek_secs
*= priv
->duration
;
1816 if ((streams
& 1) && priv
->current_vpacket
>= priv
->index_table_size
[vid
])
1817 priv
->current_vpacket
= priv
->index_table_size
[vid
] - 1;
1818 if ((streams
& 2) && priv
->current_apacket
>= priv
->index_table_size
[aid
])
1819 priv
->current_apacket
= priv
->index_table_size
[aid
] - 1;
1821 // if (index_mode == 1 || index_mode == 2) {
1822 if (streams
& 1) {// use the video index if we have one
1823 cur_timestamp
= priv
->index_table
[vid
][priv
->current_vpacket
].timestamp
;
1824 if (rel_seek_secs
> 0)
1825 while ((priv
->index_table
[vid
][priv
->current_vpacket
].timestamp
- cur_timestamp
) < rel_seek_secs
* 1000){
1826 priv
->current_vpacket
+= 1;
1827 if (priv
->current_vpacket
>= priv
->index_table_size
[vid
]) {
1828 priv
->current_vpacket
= priv
->index_table_size
[vid
] - 1;
1830 stream_seek(demuxer
->stream
, priv
->index_table
[vid
][priv
->current_vpacket
].offset
);
1831 add_index_segment(demuxer
, vid
, cur_timestamp
+ rel_seek_secs
* 1000);
1838 else if (rel_seek_secs
< 0) {
1839 while ((cur_timestamp
- priv
->index_table
[vid
][priv
->current_vpacket
].timestamp
) < - rel_seek_secs
* 1000){
1840 priv
->current_vpacket
-= 1;
1841 if (priv
->current_vpacket
< 0) {
1842 priv
->current_vpacket
= 0;
1847 priv
->video_curpos
= priv
->index_table
[vid
][priv
->current_vpacket
].offset
;
1848 priv
->audio_need_keyframe
= !priv
->is_multirate
;
1849 priv
->video_after_seek
= 1;
1852 if (!(streams
& 1)) {
1854 priv
->index_table
[aid
][priv
->current_apacket
].timestamp
;
1856 if (rel_seek_secs
> 0)
1857 while ((priv
->index_table
[aid
][priv
->current_apacket
].timestamp
- cur_timestamp
) < rel_seek_secs
* 1000){
1858 priv
->current_apacket
+= 1;
1859 if (priv
->current_apacket
>= priv
->index_table_size
[aid
]) {
1860 priv
->current_apacket
= priv
->index_table_size
[aid
] - 1;
1864 else if (rel_seek_secs
< 0)
1865 while ((cur_timestamp
- priv
->index_table
[aid
][priv
->current_apacket
].timestamp
) < - rel_seek_secs
* 1000){
1866 priv
->current_apacket
-= 1;
1867 if (priv
->current_apacket
< 0) {
1868 priv
->current_apacket
= 0;
1872 priv
->audio_curpos
= priv
->index_table
[aid
][priv
->current_apacket
].offset
;
1875 next_offset
= streams
& 1 ? priv
->video_curpos
: priv
->audio_curpos
;
1876 // printf("seek: pos: %d, current packets: a: %d, v: %d\n",
1877 // next_offset, priv->current_apacket, priv->current_vpacket);
1879 stream_seek(demuxer
->stream
, next_offset
);
1881 demux_real_fill_buffer(demuxer
, NULL
);
1884 static int demux_real_control(demuxer_t
*demuxer
, int cmd
, void *arg
)
1886 real_priv_t
*priv
= demuxer
->priv
;
1887 unsigned int lastpts
= priv
->v_pts
? priv
->v_pts
: priv
->a_pts
;
1890 case DEMUXER_CTRL_GET_TIME_LENGTH
:
1891 if (priv
->duration
== 0)
1892 return DEMUXER_CTRL_DONTKNOW
;
1894 *((double *)arg
) = (double)priv
->duration
;
1895 return DEMUXER_CTRL_OK
;
1897 case DEMUXER_CTRL_GET_PERCENT_POS
:
1898 if (priv
->duration
== 0)
1899 return DEMUXER_CTRL_DONTKNOW
;
1901 *((int *)arg
) = (int)(100 * lastpts
/ priv
->duration
);
1902 return DEMUXER_CTRL_OK
;
1905 return DEMUXER_CTRL_NOTIMPL
;
1910 const demuxer_desc_t demuxer_desc_real
= {
1911 "Realmedia demuxer",
1914 "Alex Beregszasi, Florian Schneider, A'rpi, Roberto Togni",
1915 "handles new .RMF files",
1917 1, // safe autodetect
1919 demux_real_fill_buffer
,