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