git.sesse.net Git - vlc/blob - modules/demux/real.c

   1 /*****************************************************************************
   2  * real.c: Real demuxer.
   3  *****************************************************************************
   4  * Copyright (C) 2004, 2006-2007 the VideoLAN team
   5  * $Id$
   6  *
   7  * Authors: Laurent Aimar <fenrir@via.ecp.fr>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  22  *****************************************************************************/
  23
  24 /**
  25  * Status of this demuxer:
  26  * Real Media format
  27  * -----------------
  28  *
  29  * version v3 w/ 14_4/lpcJ is ok.
  30  * version v4/5: - atrac3 is ok.
  31  *               - cook is ok.
  32  *               - raac, racp are ok.
  33  *               - dnet is twisted "The byte order of the data is reversed
  34  *                                  from standard AC3"
  35  *               - 28_8 seem problematic.
  36  *               - sipr should be fine, but our decoder suxx :)
  37  *               - ralf is unsupported, but hardly any sample exist.
  38  *               - mp3 is unsupported, one sample exists...
  39  *
  40  * Real Audio Only
  41  * ---------------
  42  * v3 and v4/5 headers are parsed.
  43  * Doesn't work yet...
  44  */
  45
  46 /*****************************************************************************
  47  * Preamble
  48  *****************************************************************************/
  49
  50 #ifdef HAVE_CONFIG_H
  51 # include "config.h"
  52 #endif
  53
  54 #include <vlc_common.h>
  55 #include <vlc_plugin.h>
  56
  57 #include <vlc_demux.h>
  58 #include <vlc_charset.h>
  59 #include <vlc_meta.h>
  60
  61 /*****************************************************************************
  62  * Module descriptor
  63  *****************************************************************************/
  64 static int  Open    ( vlc_object_t * );
  65 static void Close  ( vlc_object_t * );
  66
  67 vlc_module_begin ()
  68     set_description( N_("Real demuxer" ) )
  69     set_capability( "demux", 0 )
  70     set_category( CAT_INPUT )
  71     set_subcategory( SUBCAT_INPUT_DEMUX )
  72     set_callbacks( Open, Close )
  73     add_shortcut( "real" )
  74     add_shortcut( "rm" )
  75 vlc_module_end ()
  76
  77 /*****************************************************************************
  78  * Local prototypes
  79  *****************************************************************************/
  80
  81 typedef struct
  82 {
  83     int         i_id;
  84     es_format_t fmt;
  85
  86     es_out_id_t *p_es;
  87
  88     int         i_frame;
  89     block_t     *p_frame;
  90
  91     int         i_subpacket_h;
  92     int         i_subpacket_size;
  93     int         i_coded_frame_size;
  94     int         i_frame_size;
  95
  96     int         i_subpacket;
  97     int         i_subpackets;
  98     block_t     **p_subpackets;
  99     int64_t     *p_subpackets_timecode;
 100     int         i_out_subpacket;
 101
 102 } real_track_t;
 103
 104 typedef struct
 105 {
 106     uint32_t file_offset;
 107     uint32_t time_offset;
 108     uint32_t frame_index;
 109 } rm_index_t;
 110
 111 struct demux_sys_t
 112 {
 113     int64_t  i_data_offset;
 114     int64_t  i_data_size;
 115     uint32_t i_data_packets_count;
 116     uint32_t i_data_packets;
 117     int64_t  i_data_offset_next;
 118
 119     bool     b_is_real_audio;
 120
 121     int  i_our_duration;
 122     int  i_mux_rate;
 123
 124     char* psz_title;
 125     char* psz_artist;
 126     char* psz_copyright;
 127     char* psz_description;
 128
 129     int          i_track;
 130     real_track_t **track;
 131
 132     uint8_t buffer[65536];
 133
 134     int64_t     i_pcr;
 135     vlc_meta_t *p_meta;
 136
 137     int64_t     i_index_offset;
 138     int         b_seek;
 139     rm_index_t *p_index;
 140 };
 141
 142 static int Demux( demux_t *p_demux );
 143 static int Control( demux_t *p_demux, int i_query, va_list args );
 144
 145 static int HeaderRead( demux_t *p_demux );
 146 static const uint8_t * MetaRead( demux_t *p_demux, const uint8_t *p_peek );
 147 static int ReadCodecSpecificData( demux_t *p_demux, int i_len, int i_num );
 148
 149 /*****************************************************************************
 150  * Open
 151  *****************************************************************************/
 152 static int Open( vlc_object_t *p_this )
 153 {
 154     demux_t     *p_demux = (demux_t*)p_this;
 155     demux_sys_t *p_sys;
 156
 157     const uint8_t *p_peek;
 158     bool           b_is_real_audio = false;
 159
 160     if( stream_Peek( p_demux->s, &p_peek, 10 ) < 10 ) return VLC_EGENERIC;
 161
 162     /* Real Audio */
 163     if( !memcmp( p_peek, ".ra", 3 ) )
 164     {
 165         msg_Err( p_demux, ".ra files unsuported" );
 166         b_is_real_audio = true;
 167     }
 168     /* Real Media Format */
 169     else if( memcmp( p_peek, ".RMF", 4 ) ) return VLC_EGENERIC;
 170
 171     /* Fill p_demux field */
 172     p_demux->pf_demux = Demux;
 173     p_demux->pf_control = Control;
 174
 175     p_demux->p_sys = p_sys = malloc( sizeof( demux_sys_t ) );
 176     if( p_sys == NULL )
 177         return VLC_ENOMEM;
 178
 179     memset( p_sys, 0, sizeof( demux_sys_t ) );
 180
 181     p_sys->i_data_offset = 0;
 182     p_sys->i_track = 0;
 183     p_sys->track   = NULL;
 184     p_sys->i_pcr   = 1;
 185
 186     p_sys->b_seek  = 0;
 187     p_sys->b_is_real_audio = b_is_real_audio;
 188
 189     /* Parse the headers */
 190     /* Real Audio files */
 191     if( b_is_real_audio )
 192     {
 193         ReadCodecSpecificData( p_demux, 32, 0 ); /* At least 32 */
 194         return VLC_EGENERIC;                     /* We don't know how to read
 195                                                     correctly the data yet */
 196     }
 197     /* RMF files */
 198     else if( HeaderRead( p_demux ) )
 199     {
 200         int i;
 201         msg_Err( p_demux, "invalid header" );
 202         for( i = 0; i < p_sys->i_track; i++ )
 203         {
 204             real_track_t *tk = p_sys->track[i];
 205
 206             if( tk->p_es )
 207             {
 208                 es_out_Del( p_demux->out, tk->p_es );
 209             }
 210             free( tk );
 211         }
 212         if( p_sys->i_track > 0 )
 213         {
 214             free( p_sys->track );
 215         }
 216         free( p_sys );
 217         return VLC_EGENERIC;
 218     }
 219
 220     return VLC_SUCCESS;
 221 }
 222
 223 /*****************************************************************************
 224  * Close
 225  *****************************************************************************/
 226 static void Close( vlc_object_t *p_this )
 227 {
 228     demux_t *p_demux = (demux_t*)p_this;
 229     demux_sys_t *p_sys = p_demux->p_sys;
 230     int i;
 231
 232     for( i = 0; i < p_sys->i_track; i++ )
 233     {
 234         real_track_t *tk = p_sys->track[i];
 235         int j = tk->i_subpackets;
 236
 237         if( tk->p_frame ) block_Release( tk->p_frame );
 238         es_format_Clean( &tk->fmt );
 239
 240         while(  j-- )
 241         {
 242             if( tk->p_subpackets[ j ] )
 243                 block_Release( tk->p_subpackets[ j ] );
 244         }
 245         if( tk->i_subpackets )
 246         {
 247             free( tk->p_subpackets );
 248             free( tk->p_subpackets_timecode );
 249         }
 250
 251         free( tk );
 252     }
 253
 254     free( p_sys->psz_title );
 255     free( p_sys->psz_artist );
 256     free( p_sys->psz_copyright );
 257     free( p_sys->psz_description );
 258     free( p_sys->p_index );
 259
 260     if( p_sys->i_track > 0 ) free( p_sys->track );
 261     free( p_sys );
 262 }
 263
 264
 265 /*****************************************************************************
 266  * Demux:
 267  *****************************************************************************/
 268 static int Demux( demux_t *p_demux )
 269 {
 270     demux_sys_t *p_sys = p_demux->p_sys;
 271     uint8_t     header[18];
 272     int         i_id, i_flags, i;
 273     unsigned int i_size;
 274     int64_t     i_pts;
 275     real_track_t *tk = NULL;
 276     bool  b_selected;
 277
 278     if( p_sys->i_data_packets >= p_sys->i_data_packets_count &&
 279         p_sys->i_data_packets_count )
 280     {
 281         if( stream_Read( p_demux->s, header, 18 ) < 18 )
 282         {
 283             return 0;
 284         }
 285         if( strncmp( (char *)header, "DATA", 4 ) )
 286         {
 287             return 0;
 288         }
 289         p_sys->i_data_offset = stream_Tell( p_demux->s ) - 18;
 290         p_sys->i_data_size   = GetDWBE( &header[4] );
 291         p_sys->i_data_packets_count = GetDWBE( &header[10] );
 292         p_sys->i_data_packets = 0;
 293         p_sys->i_data_offset_next = GetDWBE( &header[14] );
 294
 295         msg_Dbg( p_demux, "entering new DATA packets=%d next=%u",
 296                  p_sys->i_data_packets_count,
 297                  (uint32_t)p_sys->i_data_offset_next );
 298     }
 299
 300     if( stream_Read( p_demux->s, header, 12 ) < 12 ) return 0;
 301
 302     //    int i_version = GetWBE( &header[0] );
 303     i_size = GetWBE( &header[2] ) - 12;
 304     i_id   = GetWBE( &header[4] );
 305     i_pts  = 1000 * GetDWBE( &header[6] );
 306     i_pts += 1000; /* Avoid 0 pts */
 307     i_flags= header[11]; /* flags 0x02 -> keyframe */
 308
 309     msg_Dbg( p_demux, "packet %d size=%d id=%d pts=%u",
 310              p_sys->i_data_packets, i_size, i_id, (uint32_t)(i_pts/1000) );
 311
 312     p_sys->i_data_packets++;
 313
 314     if( i_size == 0 )
 315     {
 316         msg_Err( p_demux, "Got a NUKK size to read. (Invalid format?)" );
 317         return 1;
 318     }
 319
 320     if( i_size > sizeof(p_sys->buffer) )
 321     {
 322         msg_Err( p_demux, "Got a size to read bigger than our buffer. (Invalid format?)" );
 323         return 1;
 324     }
 325
 326     stream_Read( p_demux->s, p_sys->buffer, i_size );
 327
 328     for( i = 0; i < p_sys->i_track; i++ )
 329     {
 330         if( p_sys->track[i]->i_id == i_id ) tk = p_sys->track[i];
 331     }
 332
 333     if( tk == NULL )
 334     {
 335         msg_Warn( p_demux, "unknown track id(0x%x)", i_id );
 336         return 1;
 337     }
 338     es_out_Control( p_demux->out, ES_OUT_GET_ES_STATE, tk->p_es, &b_selected );
 339
 340     if( tk->fmt.i_cat == VIDEO_ES && b_selected )
 341     {
 342         uint8_t *p = p_sys->buffer;
 343
 344         while( p < &p_sys->buffer[i_size - 2] )
 345         {
 346             uint8_t h = *p++;
 347             int     i_len = 0;
 348             int     i_copy;
 349             int     i_subseq = 0;
 350             int     i_seqnum = 0;
 351             int     i_offset = 0;
 352
 353             if( (h&0xc0) == 0x40 )
 354             {
 355                 /* Short header */
 356                 p++;
 357                 i_len = &p_sys->buffer[i_size] - p;
 358             }
 359             else
 360             {
 361                 if( (h&0x40) == 0 )
 362                 {
 363                     i_subseq = (*p++)&0x7f;
 364                 }
 365                 i_len = (p[0] << 8)|p[1]; p += 2;
 366                 if( (i_len&0xc000) == 0 )
 367                 {
 368                     i_len <<= 16;
 369                     i_len |= (p[0] << 8)|p[1]; p += 2;
 370                     i_len &= 0x3fffffff;
 371                 }
 372                 else
 373                 {
 374                     i_len &= 0x3fff;
 375                 }
 376
 377                 i_offset = (p[0] << 8)|p[1]; p += 2;
 378                 if( (i_offset&0xc000) == 0 )
 379                 {
 380                     i_offset <<= 16;
 381                     i_offset |= (p[0] << 8)|p[1]; p += 2;
 382                     i_offset &= 0x3fffffff;
 383                 }
 384                 else
 385                 {
 386                     i_offset &= 0x3fff;
 387                 }
 388                 i_seqnum = *p++;
 389             }
 390
 391             i_copy = i_len - i_offset;
 392             if( i_copy > &p_sys->buffer[i_size] - p )
 393             {
 394                 i_copy = &p_sys->buffer[i_size] - p;
 395             }
 396             else if( i_copy < 0 )
 397             {
 398                 break;
 399             }
 400
 401             msg_Dbg( p_demux, "    - len=%d offset=%d size=%d subseq=%d seqnum=%d",
 402                      i_len, i_offset, i_copy, i_subseq, i_seqnum );
 403
 404             if( (h&0xc0) == 0x80 )
 405             {
 406                 /* last fragment -> fixes */
 407                 i_copy = i_offset;
 408                 i_offset = i_len - i_copy;
 409                 msg_Dbg( p_demux, "last fixing copy=%d offset=%d",
 410                          i_copy, i_offset );
 411             }
 412
 413             if( tk->p_frame &&
 414                 ( tk->p_frame->i_dts != i_pts ||
 415                   tk->i_frame != i_len ) )
 416             {
 417                 msg_Dbg( p_demux, "sending size=%zu", tk->p_frame->i_buffer );
 418
 419                 es_out_Send( p_demux->out, tk->p_es, tk->p_frame );
 420
 421                 tk->i_frame = 0;
 422                 tk->p_frame = NULL;
 423             }
 424
 425             if( (h&0xc0) != 0x80 && (h&0xc0) != 0x00 && !tk->p_frame )
 426             {
 427                 /* no fragment */
 428                 i_len = i_copy;
 429                 i_offset = 0;
 430             }
 431
 432
 433             if( tk->p_frame == NULL )
 434             {
 435                 msg_Dbg( p_demux, "new frame size=%d", i_len );
 436                 tk->i_frame = i_len;
 437                 if( !( tk->p_frame = block_New( p_demux, i_len + 8 + 1000) ) )
 438                 {
 439                     return -1;
 440                 }
 441                 memset( &tk->p_frame->p_buffer[8], 0, i_len );
 442                 tk->p_frame->i_dts = i_pts;
 443                 tk->p_frame->i_pts = i_pts;
 444
 445                 ((uint32_t*)tk->p_frame->p_buffer)[0] = i_len;  /* len */
 446                 ((uint32_t*)tk->p_frame->p_buffer)[1] = 0;      /* chunk counts */
 447             }
 448
 449             if( i_offset < tk->i_frame)
 450             {
 451                 int i_ck = ((uint32_t*)tk->p_frame->p_buffer)[1]++;
 452
 453                 msg_Dbg( p_demux, "copying new buffer n=%d offset=%d copy=%d",
 454                          i_ck, i_offset, i_copy );
 455
 456                 ((uint32_t*)(tk->p_frame->p_buffer+i_len+8))[i_ck*2 +0 ] = 1;
 457                 ((uint32_t*)(tk->p_frame->p_buffer+i_len+8))[i_ck*2 +1 ] = i_offset;
 458
 459
 460                 memcpy( &tk->p_frame->p_buffer[i_offset + 8], p, i_copy );
 461             }
 462
 463             p += i_copy;
 464
 465             if( (h&0xc0) != 0x80 )
 466             {
 467                 break;
 468             }
 469
 470 #if 0
 471             if( tk->p_frame )
 472             {
 473                 /* append data */
 474                 int i_ck = ((uint32_t*)tk->p_frame->p_buffer)[1]++;
 475
 476                 if( (h&0xc0) == 0x80 )
 477                 {
 478                     /* last fragment */
 479                     i_copy = i_offset;
 480                     i_offset = i_len - i_offset;
 481
 482                     ((uint32_t*)(tk->p_frame->p_buffer+i_len+8))[i_ck] = i_offset;
 483                     memcpy( &tk->p_frame->p_buffer[i_offset+ 8], p, i_copy );
 484                     p += i_copy;
 485
 486                     if( p_sys->i_pcr < tk->p_frame->i_dts )
 487                     {
 488                         p_sys->i_pcr = tk->p_frame->i_dts;
 489                         es_out_Control( p_demux->out, ES_OUT_SET_PCR,
 490                                         (int64_t)p_sys->i_pcr );
 491                     }
 492                     es_out_Send( p_demux->out, tk->p_es, tk->p_frame );
 493
 494                     tk->i_frame = 0;
 495                     tk->p_frame = NULL;
 496
 497                     continue;
 498                 }
 499
 500                 ((uint32_t*)(tk->p_frame->p_buffer+i_len+8))[i_ck] = i_offset;
 501                 memcpy( &tk->p_frame->p_buffer[i_offset + 8], p, i_copy );
 502                 break;
 503             }
 504
 505             if( (h&0xc0) != 0x00 )
 506             {
 507                 block_t *p_frame;
 508
 509                 /* not fragmented */
 510                 if( !( p_frame = block_New( p_demux, i_copy + 8 + 8 ) ) )
 511                 {
 512                     return -1;
 513                 }
 514                 p_frame->i_dts = i_pts;
 515                 p_frame->i_pts = i_pts;
 516
 517                 ((uint32_t*)p_frame->p_buffer)[0] = i_copy;
 518                 ((uint32_t*)p_frame->p_buffer)[1] = 1;
 519                 ((uint32_t*)(p_frame->p_buffer+i_copy+8))[0] = 0;
 520                 memcpy( &p_frame->p_buffer[8], p, i_copy );
 521
 522                 p += i_copy;
 523
 524                 if( p_sys->i_pcr < p_frame->i_dts )
 525                 {
 526                     p_sys->i_pcr = p_frame->i_dts;
 527                     es_out_Control( p_demux->out, ES_OUT_SET_PCR,
 528                                     (int64_t)p_sys->i_pcr );
 529                 }
 530                 es_out_Send( p_demux->out, tk->p_es, p_frame );
 531             }
 532             else
 533             {
 534                 /* First fragment */
 535                 tk->i_frame = i_len;
 536                 if( !( tk->p_frame = block_New( p_demux, i_len + 8 + 1000) ) )
 537                 {
 538                     return -1;
 539                 }
 540                 memset( &tk->p_frame->p_buffer[8], 0, i_len );
 541                 tk->p_frame->i_dts = i_pts;
 542                 tk->p_frame->i_pts = i_pts;
 543
 544                 ((uint32_t*)tk->p_frame->p_buffer)[0] = i_len;  /* len */
 545                 ((uint32_t*)tk->p_frame->p_buffer)[1] = 1;      /* chunk counts */
 546                 ((uint32_t*)(tk->p_frame->p_buffer+i_len+8))[0] = i_offset;
 547                 memcpy( &tk->p_frame->p_buffer[i_offset + 8], p, i_copy );
 548
 549                 break;
 550             }
 551 #endif
 552         }
 553     }
 554     else if( tk->fmt.i_cat == AUDIO_ES && b_selected )
 555     {
 556         if( tk->fmt.i_codec == VLC_FOURCC( 'c', 'o', 'o', 'k' ) ||
 557             tk->fmt.i_codec == VLC_FOURCC( 'a', 't', 'r', 'c') ||
 558             tk->fmt.i_codec == VLC_FOURCC( 's', 'i', 'p', 'r') ||
 559             tk->fmt.i_codec == VLC_FOURCC( '2', '8', '_', '8') )
 560         {
 561             uint8_t *p_buf = p_sys->buffer;
 562             int y = tk->i_subpacket / ( tk->i_frame_size /tk->i_subpacket_size);
 563             int i_index, i;
 564
 565             /* Sanity check */
 566             if( i_flags & 2 || ( p_sys->b_seek ) )
 567             {
 568                 y = tk->i_subpacket = 0;
 569                 tk->i_out_subpacket = 0;
 570                 p_sys->b_seek = 0;
 571             }
 572
 573             if( tk->fmt.i_codec == VLC_FOURCC( 'c', 'o', 'o', 'k' ) ||
 574                 tk->fmt.i_codec == VLC_FOURCC( 'a', 't', 'r', 'c' ))
 575             {
 576                 int num = tk->i_frame_size / tk->i_subpacket_size;
 577                 for( i = 0; i <  num; i++ )
 578                 {
 579                     block_t *p_block = block_New( p_demux, tk->i_subpacket_size );
 580                     memcpy( p_block->p_buffer, p_buf, tk->i_subpacket_size );
 581                     p_buf += tk->i_subpacket_size;
 582
 583                     i_index = tk->i_subpacket_h * i +
 584                         ((tk->i_subpacket_h + 1) / 2) * (y&1) + (y>>1);
 585
 586                     if ( tk->p_subpackets[i_index]  != NULL )
 587                     {
 588                         msg_Dbg(p_demux, "p_subpackets[ %d ] not null!",  i_index );
 589                         free( tk->p_subpackets[i_index] );
 590                     }
 591
 592                     tk->p_subpackets[i_index] = p_block;
 593                     tk->i_subpacket++;
 594                     p_block->i_dts = p_block->i_pts = 0;
 595                 }
 596                 tk->p_subpackets_timecode[tk->i_subpacket - num] = i_pts;
 597             }
 598
 599             if( tk->fmt.i_codec == VLC_FOURCC( '2', '8', '_', '8' ) ||
 600                 tk->fmt.i_codec == VLC_FOURCC( 's', 'i', 'p', 'r' ) )
 601             for( i = 0; i < tk->i_subpacket_h / 2; i++ )
 602             {
 603                 block_t *p_block = block_New( p_demux, tk->i_coded_frame_size);
 604                 memcpy( p_block->p_buffer, p_buf, tk->i_coded_frame_size );
 605                 p_buf += tk->i_coded_frame_size;
 606
 607                 i_index = (i * 2 * tk->i_frame_size) /
 608                     tk->i_coded_frame_size + y;
 609
 610                 p_block->i_dts = p_block->i_pts = i_pts;
 611                 tk->p_subpackets[i_index] = p_block;
 612                 tk->i_subpacket++;
 613             }
 614
 615             while( tk->i_out_subpacket != tk->i_subpackets &&
 616                    tk->p_subpackets[tk->i_out_subpacket] )
 617             {
 618                 /* Set the PCR */
 619 #if 0
 620                 if (tk->i_out_subpacket == 0)
 621                 {
 622                     p_sys->i_pcr = tk->p_subpackets[tk->i_out_subpacket]->i_dts;
 623                     es_out_Control( p_demux->out, ES_OUT_SET_PCR,
 624                             (int64_t)p_sys->i_pcr );
 625                 }
 626
 627                 block_t *p_block = tk->p_subpackets[tk->i_out_subpacket];
 628                 tk->p_subpackets[tk->i_out_subpacket] = 0;
 629
 630                 if( tk->i_out_subpacket ) p_block->i_dts = p_block->i_pts = 0;
 631 #endif
 632
 633                 block_t *p_block = tk->p_subpackets[tk->i_out_subpacket];
 634                 tk->p_subpackets[tk->i_out_subpacket] = 0;
 635                 if ( tk->p_subpackets_timecode[tk->i_out_subpacket]  )
 636                 {
 637                     p_block->i_dts = p_block->i_pts =
 638                         tk->p_subpackets_timecode[tk->i_out_subpacket];
 639                     tk->p_subpackets_timecode[tk->i_out_subpacket] = 0;
 640
 641                     p_sys->i_pcr = p_block->i_dts;
 642                     es_out_Control( p_demux->out, ES_OUT_SET_PCR,
 643                             (int64_t)p_sys->i_pcr );
 644                 }
 645                 es_out_Send( p_demux->out, tk->p_es, p_block );
 646
 647                 tk->i_out_subpacket++;
 648             }
 649
 650             if( tk->i_subpacket == tk->i_subpackets &&
 651                 tk->i_out_subpacket != tk->i_subpackets )
 652             {
 653                 msg_Warn( p_demux, "i_subpacket != i_out_subpacket, "
 654                           "this shouldn't happen" );
 655             }
 656
 657             if( tk->i_subpacket == tk->i_subpackets )
 658             {
 659                 tk->i_subpacket = 0;
 660                 tk->i_out_subpacket = 0;
 661             }
 662         }
 663         else
 664         {
 665             /* Set PCR */
 666             if( p_sys->i_pcr < i_pts )
 667             {
 668                 p_sys->i_pcr = i_pts;
 669                 es_out_Control( p_demux->out, ES_OUT_SET_PCR,
 670                         (int64_t)p_sys->i_pcr );
 671             }
 672
 673             if( tk->fmt.i_codec == VLC_FOURCC( 'm','p','4','a' ) )
 674             {
 675                 int     i_sub = (p_sys->buffer[1] >> 4)&0x0f;
 676                 uint8_t *p_sub = &p_sys->buffer[2+2*i_sub];
 677
 678                 int i;
 679                 for( i = 0; i < i_sub; i++ )
 680                 {
 681                     int i_sub_size = GetWBE( &p_sys->buffer[2+i*2]);
 682                     block_t *p_block = block_New( p_demux, i_sub_size );
 683                     if( p_block )
 684                     {
 685                         memcpy( p_block->p_buffer, p_sub, i_sub_size );
 686                         p_sub += i_sub_size;
 687
 688                         p_block->i_dts =
 689                             p_block->i_pts = ( i == 0 ? i_pts : 0 );
 690
 691                         es_out_Send( p_demux->out, tk->p_es, p_block );
 692                     }
 693                 }
 694             }
 695             else
 696             {
 697                 block_t *p_block = block_New( p_demux, i_size );
 698
 699                 if( tk->fmt.i_codec == VLC_FOURCC( 'a', '5', '2', ' ' ) )
 700                 {
 701                     uint8_t *src = p_sys->buffer;
 702                     uint8_t *dst = p_block->p_buffer;
 703
 704                     /* byte swap data */
 705                     while( dst < &p_block->p_buffer[i_size- 1])
 706                     {
 707                         *dst++ = src[1];
 708                         *dst++ = src[0];
 709
 710                         src += 2;
 711                     }
 712                 }
 713                 else
 714                 {
 715                     memcpy( p_block->p_buffer, p_sys->buffer, i_size );
 716                 }
 717                 p_block->i_dts = p_block->i_pts = i_pts;
 718                 es_out_Send( p_demux->out, tk->p_es, p_block );
 719             }
 720         }
 721     }
 722
 723
 724     return 1;
 725 }
 726
 727 /*****************************************************************************
 728  * Control:
 729  *****************************************************************************/
 730 static int Control( demux_t *p_demux, int i_query, va_list args )
 731 {
 732     demux_sys_t *p_sys = p_demux->p_sys;
 733     double f, *pf;
 734     int64_t i64;
 735     rm_index_t * p_index;
 736     int64_t *pi64;
 737
 738     switch( i_query )
 739     {
 740         case DEMUX_GET_POSITION:
 741             pf = (double*) va_arg( args, double* );
 742
 743             if( p_sys->i_our_duration > 0 )
 744             {
 745                 *pf = (double)p_sys->i_pcr / 1000.0 / p_sys->i_our_duration;
 746                 return VLC_SUCCESS;
 747             }
 748
 749             /* read stream size maybe failed in rtsp streaming,
 750                so use duration to determin the position at first  */
 751             i64 = stream_Size( p_demux->s );
 752             if( i64 > 0 )
 753             {
 754                 *pf = (double)1.0*stream_Tell( p_demux->s ) / (double)i64;
 755             }
 756             else
 757             {
 758                 *pf = 0.0;
 759             }
 760             return VLC_SUCCESS;
 761
 762         case DEMUX_GET_TIME:
 763             pi64 = (int64_t*)va_arg( args, int64_t * );
 764
 765             if( p_sys->i_our_duration > 0 )
 766             {
 767                 *pi64 = p_sys->i_pcr;
 768                 return VLC_SUCCESS;
 769             }
 770
 771             /* same as GET_POSTION */
 772             i64 = stream_Size( p_demux->s );
 773             if( p_sys->i_our_duration > 0 && i64 > 0 )
 774             {
 775                 *pi64 = (int64_t)( 1000.0 * p_sys->i_our_duration * stream_Tell( p_demux->s ) / i64 );
 776                 return VLC_SUCCESS;
 777             }
 778
 779             *pi64 = 0;
 780             return VLC_EGENERIC;
 781
 782         case DEMUX_SET_POSITION:
 783             f = (double) va_arg( args, double );
 784             i64 = (int64_t) ( stream_Size( p_demux->s ) * f );
 785
 786             if ( p_sys->i_index_offset == 0 && i64 != 0 )
 787             {
 788                 msg_Err(p_demux,"Seek No Index Real File failed!" );
 789                 return VLC_EGENERIC; // no index!
 790             }
 791             if ( i64 == 0 )
 792             {
 793                 /* it is a rtsp stream , it is specials in access/rtsp/... */
 794                 msg_Dbg(p_demux, "Seek in real rtsp stream!");
 795                 p_sys->i_pcr = (int64_t)1000 * ( p_sys->i_our_duration * f  );
 796
 797                 p_sys->b_seek = 1;
 798
 799                 return stream_Seek( p_demux->s, p_sys->i_pcr );
 800             }
 801
 802             if ( p_sys->i_index_offset > 0 )
 803             {
 804                 p_index = p_sys->p_index;
 805                 while( p_index->file_offset !=0 )
 806                 {
 807                     if ( p_index->file_offset > i64 )
 808                     {
 809                         msg_Dbg( p_demux, "Seek Real find! %d %d %d",
 810                                  p_index->time_offset, p_index->file_offset,
 811                                  (uint32_t) i64 );
 812                         if ( p_index != p_sys->p_index ) p_index --;
 813                         i64 = p_index->file_offset;
 814                         break;
 815                     }
 816                     p_index++;
 817                 }
 818
 819                 p_sys->i_pcr = 1000 * (int64_t) p_index->time_offset;
 820
 821                 return stream_Seek( p_demux->s, i64 );
 822             }
 823         case DEMUX_SET_TIME:
 824             i64 = (int64_t) va_arg( args, int64_t ) / 1000;
 825
 826             p_index = p_sys->p_index;
 827             while( p_index->file_offset !=0 )
 828             {
 829                 if ( p_index->time_offset > i64 )
 830                 {
 831                     if ( p_index != p_sys->p_index )
 832                         p_index --;
 833                     i64 = p_index->file_offset;
 834                     break;
 835                 }
 836                 p_index++;
 837             }
 838
 839             p_sys->i_pcr = 1000 * (int64_t) p_index->time_offset;
 840
 841             return stream_Seek( p_demux->s, i64 );
 842
 843         case DEMUX_GET_LENGTH:
 844             pi64 = (int64_t*)va_arg( args, int64_t * );
 845
 846             /* the commented following lines are fen's implementation, which doesn't seem to
 847              * work for one reason or another -- FK */
 848             /*if( p_sys->i_mux_rate > 0 )
 849             {
 850                 *pi64 = (int64_t)1000000 * ( stream_Size( p_demux->s ) / 50 ) / p_sys->i_mux_rate;
 851                 return VLC_SUCCESS;
 852             }*/
 853             if( p_sys->i_our_duration > 0 )
 854             {
 855                 /* our stored duration is in ms, so... */
 856                 *pi64 = (int64_t)1000 * p_sys->i_our_duration;
 857
 858                 return VLC_SUCCESS;
 859             }
 860             *pi64 = 0;
 861             return VLC_EGENERIC;
 862
 863         case DEMUX_GET_META:
 864         {
 865             vlc_meta_t *p_meta = (vlc_meta_t*)va_arg( args, vlc_meta_t* );
 866
 867             /* the core will crash if we provide NULL strings, so check
 868              * every string first */
 869             if( p_sys->psz_title )
 870                 vlc_meta_SetTitle( p_meta, p_sys->psz_title );
 871             if( p_sys->psz_artist )
 872                 vlc_meta_SetArtist( p_meta, p_sys->psz_artist );
 873             if( p_sys->psz_copyright )
 874                 vlc_meta_SetCopyright( p_meta, p_sys->psz_copyright );
 875             if( p_sys->psz_description )
 876                 vlc_meta_SetDescription( p_meta, p_sys->psz_description );
 877             return VLC_SUCCESS;
 878         }
 879
 880         case DEMUX_GET_FPS:
 881         default:
 882             return VLC_EGENERIC;
 883     }
 884     return VLC_EGENERIC;
 885 }
 886
 887 /*****************************************************************************
 888  * ReadRealIndex:
 889  *****************************************************************************/
 890
 891 static void ReadRealIndex( demux_t *p_demux )
 892 {
 893     demux_sys_t *p_sys = p_demux->p_sys;
 894     uint8_t       buffer[100];
 895     uint32_t      i_id;
 896     uint32_t      i_size;
 897     int           i_version;
 898     unsigned int  i;
 899
 900     uint32_t      i_index_count;
 901
 902     if ( p_sys->i_index_offset == 0 )
 903         return;
 904
 905     stream_Seek( p_demux->s, p_sys->i_index_offset );
 906
 907     if ( stream_Read( p_demux->s, buffer, 20 ) < 20 )
 908         return ;
 909
 910     i_id = VLC_FOURCC( buffer[0], buffer[1], buffer[2], buffer[3] );
 911     i_size      = GetDWBE( &buffer[4] );
 912     i_version   = GetWBE( &buffer[8] );
 913
 914     msg_Dbg( p_demux, "Real index %4.4s size=%d version=%d",
 915                  (char*)&i_id, i_size, i_version );
 916
 917     if( (i_size < 20) && (i_id != VLC_FOURCC('I','N','D','X')) )
 918         return;
 919
 920     i_index_count = GetDWBE( &buffer[10] );
 921
 922     msg_Dbg( p_demux, "Real Index : num : %d ", i_index_count );
 923
 924     if( i_index_count > ( 0xffffffff / sizeof( rm_index_t ) ) )
 925         return;
 926
 927     if( GetDWBE( &buffer[16] ) > 0 )
 928         msg_Dbg( p_demux, "Real Index: Does next index exist? %d ",
 929                         GetDWBE( &buffer[16] )  );
 930
 931     p_sys->p_index = malloc( ( i_index_count + 1 ) * sizeof( rm_index_t ) );
 932     if( p_sys->p_index == NULL )
 933         return;
 934
 935     for( i=0; i<i_index_count; i++ )
 936     {
 937         if( stream_Read( p_demux->s, buffer, 14 ) < 14 )
 938             return ;
 939
 940         if( GetWBE( &buffer[0] ) != 0 )
 941         {
 942             msg_Dbg( p_demux, "Real Index: invaild version of index entry %d ",
 943                               GetWBE( &buffer[0] ) );
 944             return;
 945         }
 946
 947         p_sys->p_index[i].time_offset = GetDWBE( &buffer[2] );
 948         p_sys->p_index[i].file_offset = GetDWBE( &buffer[6] );
 949         p_sys->p_index[i].frame_index = GetDWBE( &buffer[10] );
 950         msg_Dbg( p_demux,
 951                  "Real Index: time %"PRIu32" file %"PRIu32" frame %"PRIu32,
 952                  p_sys->p_index[i].time_offset,
 953                  p_sys->p_index[i].file_offset,
 954                  p_sys->p_index[i].frame_index );
 955     }
 956     memset( p_sys->p_index + i_index_count, 0, sizeof( rm_index_t ) );
 957 }
 958
 959 /*****************************************************************************
 960  * HeaderRead:
 961  *****************************************************************************/
 962 static int HeaderRead( demux_t *p_demux )
 963 {
 964     demux_sys_t *p_sys = p_demux->p_sys;
 965     uint8_t header[100];    /* FIXME */
 966
 967     uint32_t    i_id;
 968     uint32_t    i_size;
 969     int64_t     i_skip;
 970     int         i_version;
 971     p_sys->p_meta = vlc_meta_New();
 972
 973     for( ;; )
 974     {
 975         /* Read the header */
 976         if( stream_Read( p_demux->s, header, 10 ) < 10 )
 977         {
 978             return VLC_EGENERIC;
 979         }
 980         i_id        = VLC_FOURCC( header[0], header[1], header[2], header[3] );
 981         i_size      = GetDWBE( &header[4] );
 982         i_version   = GetWBE( &header[8] );
 983
 984         msg_Dbg( p_demux, "object %4.4s size=%d version=%d",
 985                  (char*)&i_id, i_size, i_version );
 986
 987         if( i_size < 10 && i_id != VLC_FOURCC('D','A','T','A') )
 988         {
 989             msg_Dbg( p_demux, "invalid size for object %4.4s", (char*)&i_id );
 990             return VLC_EGENERIC;
 991         }
 992         i_skip = i_size - 10;
 993
 994         if( i_id == VLC_FOURCC('.','R','M','F') )
 995         {
 996             if( stream_Read( p_demux->s, header, 8 ) < 8 ) return VLC_EGENERIC;
 997             msg_Dbg( p_demux, "    - file version=0x%x num headers=%d",
 998                      GetDWBE( &header[0] ), GetDWBE( &header[4] ) );
 999
1000             i_skip -= 8;
1001         }
1002         else if( i_id == VLC_FOURCC('P','R','O','P') )
1003         {
1004             int i_flags;
1005
1006             if( stream_Read(p_demux->s, header, 40) < 40 ) return VLC_EGENERIC;
1007
1008             msg_Dbg( p_demux, "    - max bitrate=%d avg bitrate=%d",
1009                      GetDWBE(&header[0]), GetDWBE(&header[4]) );
1010             msg_Dbg( p_demux, "    - max packet size=%d avg bitrate=%d",
1011                      GetDWBE(&header[8]), GetDWBE(&header[12]) );
1012             msg_Dbg( p_demux, "    - packets count=%d", GetDWBE(&header[16]) );
1013             msg_Dbg( p_demux, "    - duration=%d ms", GetDWBE(&header[20]) );
1014             msg_Dbg( p_demux, "    - preroll=%d ms", GetDWBE(&header[24]) );
1015             msg_Dbg( p_demux, "    - index offset=%d", GetDWBE(&header[28]) );
1016             msg_Dbg( p_demux, "    - data offset=%d", GetDWBE(&header[32]) );
1017             msg_Dbg( p_demux, "    - num streams=%d", GetWBE(&header[36]) );
1018
1019             /* set the duration for export in control */
1020             p_sys->i_our_duration = (int)GetDWBE(&header[20]);
1021
1022             p_sys->i_index_offset = GetDWBE(&header[28]);
1023
1024             i_flags = GetWBE(&header[38]);
1025             msg_Dbg( p_demux, "    - flags=0x%x %s%s%s",
1026                      i_flags,
1027                      i_flags&0x0001 ? "PN_SAVE_ENABLED " : "",
1028                      i_flags&0x0002 ? "PN_PERFECT_PLAY_ENABLED " : "",
1029                      i_flags&0x0004 ? "PN_LIVE_BROADCAST" : "" );
1030             i_skip -= 40;
1031         }
1032         else if( i_id == VLC_FOURCC('C','O','N','T') )
1033         {
1034             int i_len;
1035             char *psz;
1036
1037             /* FIXME FIXME: should convert from whatever the character
1038              * encoding of the input meta data is to UTF-8. */
1039
1040             stream_Read( p_demux->s, header, 2 );
1041             if( ( i_len = GetWBE( header ) ) > 0 )
1042             {
1043                 psz = malloc( i_len + 1 );
1044                 stream_Read( p_demux->s, psz, i_len );
1045                 psz[i_len] = '\0';
1046
1047                 EnsureUTF8( psz );
1048                 msg_Dbg( p_demux, "    - title=`%s'", psz );
1049                 p_sys->psz_title = psz;
1050                 i_skip -= i_len;
1051             }
1052             i_skip -= 2;
1053
1054             stream_Read( p_demux->s, header, 2 );
1055             if( ( i_len = GetWBE( header ) ) > 0 )
1056             {
1057                 psz = malloc( i_len + 1 );
1058                 stream_Read( p_demux->s, psz, i_len );
1059                 psz[i_len] = '\0';
1060
1061                 EnsureUTF8( psz );
1062                 msg_Dbg( p_demux, "    - author=`%s'", psz );
1063                 p_sys->psz_artist = psz;
1064                 i_skip -= i_len;
1065             }
1066             i_skip -= 2;
1067
1068             stream_Read( p_demux->s, header, 2 );
1069             if( ( i_len = GetWBE( header ) ) > 0 )
1070             {
1071                 psz = malloc( i_len + 1 );
1072                 stream_Read( p_demux->s, psz, i_len );
1073                 psz[i_len] = '\0';
1074
1075                 EnsureUTF8( psz );
1076                 msg_Dbg( p_demux, "    - copyright=`%s'", psz );
1077                 p_sys->psz_copyright = psz;
1078                 i_skip -= i_len;
1079             }
1080             i_skip -= 2;
1081
1082             stream_Read( p_demux->s, header, 2 );
1083             if( ( i_len = GetWBE( header ) ) > 0 )
1084             {
1085                 psz = malloc( i_len + 1 );
1086                 stream_Read( p_demux->s, psz, i_len );
1087                 psz[i_len] = '\0';
1088
1089                 EnsureUTF8( psz );
1090                 msg_Dbg( p_demux, "    - comment=`%s'", psz );
1091                 p_sys->psz_description = psz;
1092                 i_skip -= i_len;
1093             }
1094             i_skip -= 2;
1095         }
1096         else if( i_id == VLC_FOURCC('M','D','P','R') )
1097         {
1098             /* Media properties header */
1099             int  i_num;
1100             int  i_len;
1101             char *psz;
1102
1103             if( stream_Read(p_demux->s, header, 30) < 30 ) return VLC_EGENERIC;
1104             i_num = GetWBE( header );
1105             msg_Dbg( p_demux, "    - id=0x%x", i_num );
1106             msg_Dbg( p_demux, "    - max bitrate=%d avg bitrate=%d",
1107                      GetDWBE(&header[2]), GetDWBE(&header[6]) );
1108             msg_Dbg( p_demux, "    - max packet size=%d avg packet size=%d",
1109                      GetDWBE(&header[10]), GetDWBE(&header[14]) );
1110             msg_Dbg( p_demux, "    - start time=%d", GetDWBE(&header[18]) );
1111             msg_Dbg( p_demux, "    - preroll=%d", GetDWBE(&header[22]) );
1112             msg_Dbg( p_demux, "    - duration=%d", GetDWBE(&header[26]) );
1113
1114             i_skip -= 30;
1115
1116             stream_Read( p_demux->s, header, 1 );
1117             if( ( i_len = header[0] ) > 0 )
1118             {
1119                 psz = malloc( i_len + 1 );
1120                 stream_Read( p_demux->s, psz, i_len );
1121                 psz[i_len] = '\0';
1122
1123                 msg_Dbg( p_demux, "    - name=`%s'", psz );
1124                 free( psz );
1125                 i_skip -= i_len;
1126             }
1127             i_skip--;
1128
1129             stream_Read( p_demux->s, header, 1 );
1130             if( ( i_len = header[0] ) > 0 )
1131             {
1132                 psz = malloc( i_len + 1 );
1133                 stream_Read( p_demux->s, psz, i_len );
1134                 psz[i_len] = '\0';
1135
1136                 msg_Dbg( p_demux, "    - mime=`%s'", psz );
1137                 free( psz );
1138                 i_skip -= i_len;
1139             }
1140             i_skip--;
1141
1142             stream_Read( p_demux->s, header, 4 );
1143             if( ( i_len = GetDWBE( header ) ) > 0 )
1144             {
1145                 ReadCodecSpecificData( p_demux, i_len, i_num );
1146                 stream_Read( p_demux->s, NULL, i_len );
1147
1148                 i_skip -= i_len;
1149             }
1150             i_skip -= 4;
1151         }
1152         else if( i_id == VLC_FOURCC('D','A','T','A') )
1153         {
1154             stream_Read( p_demux->s, header, 8 );
1155
1156             p_sys->i_data_offset    = stream_Tell( p_demux->s ) - 10;
1157             p_sys->i_data_size      = i_size;
1158             p_sys->i_data_packets_count = GetDWBE( header );
1159             p_sys->i_data_packets   = 0;
1160             p_sys->i_data_offset_next = GetDWBE( &header[4] );
1161
1162             msg_Dbg( p_demux, "    - packets count=%d next=%u",
1163                      p_sys->i_data_packets_count,
1164                      (uint32_t)p_sys->i_data_offset_next );
1165
1166             /* we have finished the header */
1167             break;
1168         }
1169         else
1170         {
1171             /* unknow header */
1172             msg_Dbg( p_demux, "unknown chunk" );
1173         }
1174
1175         if( i_skip < 0 ) return VLC_EGENERIC;
1176         stream_Read( p_demux->s, NULL, i_skip );
1177     }
1178
1179     /* TODO read index if possible */
1180
1181     if ( p_sys->i_index_offset > 0 )
1182     {
1183         int64_t pos;
1184         pos = stream_Tell( p_demux->s );
1185         ReadRealIndex( p_demux );
1186         stream_Seek( p_demux->s, pos );
1187     }
1188
1189     return VLC_SUCCESS;
1190 }
1191
1192 static const uint8_t * MetaRead( demux_t *p_demux, const uint8_t *p_peek )
1193 {
1194     demux_sys_t *p_sys = p_demux->p_sys;
1195
1196     int i_len;
1197     char *psz;
1198
1199     /* Title */
1200     i_len = *p_peek ; p_peek++;
1201     if( i_len > 0 )
1202     {
1203         psz = malloc( i_len + 1 );
1204         memcpy( psz, p_peek, i_len );
1205         psz[i_len] = '\0';
1206
1207         EnsureUTF8( psz );
1208         msg_Dbg( p_demux, "    - title=`%s'", psz );
1209         p_sys->psz_title = psz;
1210     }
1211     p_peek += i_len;
1212
1213     /* Authors */
1214     i_len = *p_peek ; p_peek++;
1215     if( i_len > 0 )
1216     {
1217         psz = malloc( i_len + 1 );
1218         memcpy( psz, p_peek, i_len );
1219         psz[i_len] = '\0';
1220
1221         EnsureUTF8( psz );
1222         msg_Dbg( p_demux, "    - artist=`%s'", psz );
1223         p_sys->psz_artist = psz;
1224     }
1225     p_peek += i_len;
1226
1227     /* Copyright */
1228     i_len = *p_peek ; p_peek++;
1229     if( i_len > 0 )
1230     {
1231         psz = malloc( i_len + 1 );
1232         memcpy( psz, p_peek, i_len );
1233         psz[i_len] = '\0';
1234
1235         EnsureUTF8( psz );
1236         msg_Dbg( p_demux, "    - Copyright=`%s'", psz );
1237         p_sys->psz_copyright = psz;
1238     }
1239     p_peek += i_len;
1240
1241     /* Comment */
1242     i_len = *p_peek ; p_peek++;
1243     if( i_len > 0 )
1244     {
1245         psz = malloc( i_len + 1 );
1246         memcpy( psz, p_peek, i_len );
1247         psz[i_len] = '\0';
1248
1249         EnsureUTF8( psz );
1250         msg_Dbg( p_demux, "    - Comment=`%s'", psz );
1251         p_sys->psz_description = psz;
1252     }
1253     p_peek += i_len;
1254
1255     return p_peek;
1256 }
1257
1258
1259 static int ReadCodecSpecificData( demux_t *p_demux, int i_len, int i_num )
1260 {
1261     demux_sys_t *p_sys = p_demux->p_sys;
1262     es_format_t fmt;
1263     real_track_t *tk;
1264     const uint8_t *p_peek;
1265
1266     msg_Dbg( p_demux, "    - specific data len=%d", i_len );
1267     if( stream_Peek(p_demux->s, &p_peek, i_len) < i_len ) return VLC_EGENERIC;
1268
1269     if( ( i_len >= 8 ) && !memcmp( &p_peek[4], "VIDO", 4 ) )
1270     {
1271         es_format_Init( &fmt, VIDEO_ES, VLC_FOURCC( p_peek[8], p_peek[9],
1272                         p_peek[10], p_peek[11] ) );
1273         fmt.video.i_width = GetWBE( &p_peek[12] );
1274         fmt.video.i_height= GetWBE( &p_peek[14] );
1275
1276         fmt.i_extra = 8;
1277         fmt.p_extra = malloc( 8 );
1278         ((uint32_t*)fmt.p_extra)[0] = GetDWBE( &p_peek[26] );
1279         ((uint32_t*)fmt.p_extra)[1] = GetDWBE( &p_peek[30] );
1280
1281         msg_Dbg( p_demux, "    - video 0x%08x 0x%08x",
1282                  ((uint32_t*)fmt.p_extra)[0], ((uint32_t*)fmt.p_extra)[1] );
1283
1284         if( GetDWBE( &p_peek[30] ) == 0x10003000 ||
1285             GetDWBE( &p_peek[30] ) == 0x10003001 )
1286         {
1287             fmt.i_codec = VLC_FOURCC( 'R','V','1','3' );
1288         }
1289         else if( GetDWBE( &p_peek[30] ) == 0x20001000 ||
1290                  GetDWBE( &p_peek[30] ) == 0x20100001 ||
1291                  GetDWBE( &p_peek[30] ) == 0x20200002 )
1292         {
1293             fmt.i_codec = VLC_FOURCC( 'R','V','2','0' );
1294         }
1295         else if( GetDWBE( &p_peek[30] ) == 0x30202002 )
1296         {
1297             fmt.i_codec = VLC_FOURCC( 'R','V','3','0' );
1298         }
1299         else if( GetDWBE( &p_peek[30] ) == 0x40000000 )
1300         {
1301             fmt.i_codec = VLC_FOURCC( 'R','V','4','0' );
1302         }
1303
1304         msg_Dbg( p_demux, "    - video %4.4s %dx%d",
1305                  (char*)&fmt.i_codec, fmt.video.i_width, fmt.video.i_height );
1306
1307         tk = malloc( sizeof( real_track_t ) );
1308         tk->i_out_subpacket = 0;
1309         tk->i_subpacket = 0;
1310         tk->i_subpackets = 0;
1311         tk->p_subpackets = NULL;
1312         tk->p_subpackets_timecode = NULL;
1313         tk->i_id = i_num;
1314         tk->fmt = fmt;
1315         tk->i_frame = 0;
1316         tk->p_frame = NULL;
1317         tk->p_es = es_out_Add( p_demux->out, &fmt );
1318
1319         TAB_APPEND( p_sys->i_track, p_sys->track, tk );
1320     }
1321     else if( !strncmp( (char *)p_peek, ".ra\xfd", 4 ) )
1322     {
1323         int i_header_size = 0;
1324         int i_flavor = 0;
1325         int i_coded_frame_size = 0;
1326         int i_subpacket_h = 0;
1327         int i_frame_size = 0;
1328         int i_subpacket_size = 0;
1329         char p_genr[4];
1330         int i_version = GetWBE( &p_peek[4] );   /* [0..3] = '.','r','a',0xfd */
1331         msg_Dbg( p_demux, "    - audio version=%d", i_version );
1332
1333         p_peek += 6;                                          /* 4 + version */
1334         es_format_Init( &fmt, AUDIO_ES, 0 );
1335
1336         if( i_version == 3 ) /* RMF version 3 or .ra version 3 */
1337         {
1338             i_header_size = GetWBE( p_peek ); p_peek += 2;  /* Size from now */
1339             p_peek += 10;                                         /* Unknown */
1340
1341             msg_Dbg( p_demux, "Data Size: %i", GetDWBE( p_peek ) );
1342             p_peek += 4;                                        /* Data Size */
1343
1344             /* Meta Datas */
1345             p_peek = MetaRead( p_demux, p_peek );
1346
1347             p_peek ++;                                            /* Unknown */
1348             p_peek ++;                                  /* FourCC length = 4 */
1349             memcpy( (char *)&fmt.i_codec, p_peek, 4 ); p_peek += 4; /* FourCC*/
1350
1351             fmt.audio.i_channels = 1;      /* This is always the case in rm3 */
1352             fmt.audio.i_rate = 8000;
1353
1354             msg_Dbg( p_demux, "    - audio codec=%4.4s channels=%d rate=%dHz",
1355                  (char*)&fmt.i_codec, fmt.audio.i_channels, fmt.audio.i_rate );
1356         }
1357         else  /* RMF version 4/5 or .ra version 4 */
1358         {
1359             p_peek += 2;                                            /* 00 00 */
1360             p_peek += 4;                                     /* .ra4 or .ra5 */
1361             p_peek += 4;                                        /* data size */
1362             p_peek += 2;                                 /* version (4 or 5) */
1363             i_header_size = GetDWBE( p_peek ); p_peek += 4;   /* header size */
1364             i_flavor = GetWBE( p_peek ); p_peek += 2;        /* codec flavor */
1365             i_coded_frame_size = GetDWBE( p_peek ); p_peek += 4; /* coded frame size*/
1366             p_peek += 4;                                               /* ?? */
1367             p_peek += 4;                                               /* ?? */
1368             p_peek += 4;                                               /* ?? */
1369             i_subpacket_h = GetWBE( p_peek ); p_peek += 2;              /* 1 */
1370             i_frame_size = GetWBE( p_peek ); p_peek += 2;      /* frame size */
1371             i_subpacket_size = GetWBE( p_peek ); p_peek += 2;  /* subpacket_size */
1372             if( (!i_subpacket_size && !p_sys->b_is_real_audio )
1373                 || !i_frame_size || !i_coded_frame_size )
1374                  return VLC_EGENERIC;
1375             p_peek += 2;                                               /* ?? */
1376
1377             if( i_version == 5 ) p_peek += 6;                 /* 0, srate, 0 */
1378
1379             fmt.audio.i_rate = GetWBE( p_peek ); p_peek += 2;  /* Sample Rate */
1380             p_peek += 2;                                                /* ?? */
1381             fmt.audio.i_bitspersample = GetWBE( p_peek ); p_peek += 2;/* Sure?*/
1382             fmt.audio.i_channels = GetWBE( p_peek ); p_peek += 2; /* Channels */
1383             fmt.audio.i_blockalign = i_frame_size;
1384
1385             if( i_version == 5 )
1386             {
1387                 memcpy( (char *)p_genr, p_peek, 4 ); p_peek += 4;    /* genr */
1388                 memcpy( (char *)&fmt.i_codec, p_peek, 4 ); p_peek += 4;
1389             }
1390             else /* version 4 */
1391             {
1392                 p_peek += 1 + p_peek[0];   /* Inteleaver ID string and lenth */
1393                 memcpy( (char *)&fmt.i_codec, p_peek + 1, 4 );     /* FourCC */
1394                 p_peek += 1 + p_peek[0];
1395             }
1396
1397             msg_Dbg( p_demux, "    - audio codec=%4.4s channels=%d rate=%dHz",
1398                  (char*)&fmt.i_codec, fmt.audio.i_channels, fmt.audio.i_rate );
1399
1400             p_peek += 3;                                               /* ?? */
1401
1402             if( p_sys->b_is_real_audio )
1403             {
1404                 p_peek = MetaRead( p_demux, p_peek );
1405             }
1406             else
1407             {
1408                 if( i_version == 5 ) p_peek++;
1409                 /* Extra Data then: DWord + byte[] */
1410                 fmt.i_extra = GetDWBE( p_peek ); p_peek += 4;
1411             }
1412         }
1413
1414         switch( fmt.i_codec )
1415         {
1416         case VLC_FOURCC('l','p','c','J'):
1417             fmt.i_codec = VLC_FOURCC( '1','4','_','4' );
1418         case VLC_FOURCC('1','4','_','4'):
1419             fmt.audio.i_blockalign = 0x14 ;
1420             break;
1421
1422         case VLC_FOURCC('2','8','_','8'):
1423             fmt.i_extra = 0;
1424             fmt.audio.i_blockalign = i_coded_frame_size;
1425             break;
1426
1427         case VLC_FOURCC( 'd','n','e','t' ):
1428             fmt.i_codec = VLC_FOURCC( 'a','5','2',' ' );
1429             break;
1430
1431         case VLC_FOURCC( 'r','a','a','c' ):
1432         case VLC_FOURCC( 'r','a','c','p' ):
1433             fmt.i_codec = VLC_FOURCC( 'm','p','4','a' );
1434
1435             if( fmt.i_extra > 0 ) { fmt.i_extra--; p_peek++; }
1436             if( fmt.i_extra > 0 )
1437             {
1438                 fmt.p_extra = malloc( fmt.i_extra );
1439                 if( fmt.p_extra == NULL )
1440                 {
1441                     msg_Err( p_demux, "Error in the extra data" );
1442                     return VLC_EGENERIC;
1443                 }
1444                 memcpy( fmt.p_extra, p_peek, fmt.i_extra );
1445             }
1446             break;
1447
1448         case VLC_FOURCC('s','i','p','r'):
1449             fmt.audio.i_flavor = i_flavor;
1450         case VLC_FOURCC('c','o','o','k'):
1451         case VLC_FOURCC('a','t','r','c'):
1452             if( !memcmp( p_genr, "genr", 4 ) )
1453                 fmt.audio.i_blockalign = i_subpacket_size;
1454             else
1455                 fmt.audio.i_blockalign = i_coded_frame_size;
1456
1457             if( fmt.i_extra > 0 )
1458             {
1459                 fmt.p_extra = malloc( fmt.i_extra );
1460                 if( fmt.p_extra == NULL )
1461                 {
1462                     msg_Err( p_demux, "Error in the extra data" );
1463                     return VLC_EGENERIC;
1464                 }
1465                 memcpy( fmt.p_extra, p_peek, fmt.i_extra );
1466             }
1467             break;
1468
1469         case VLC_FOURCC('r','a','l','f'):
1470             msg_Dbg( p_demux, "    - audio codec not supported=%4.4s",
1471                      (char*)&fmt.i_codec );
1472             break;
1473
1474         default:
1475             msg_Dbg( p_demux, "    - unknown audio codec=%4.4s",
1476                      (char*)&fmt.i_codec );
1477             break;
1478         }
1479
1480         if( fmt.i_codec != 0 )
1481         {
1482             msg_Dbg( p_demux, "        - extra data=%d", fmt.i_extra );
1483
1484             tk = malloc( sizeof( real_track_t ) );
1485             if( !tk )
1486                 return VLC_ENOMEM;
1487             tk->i_id = i_num;
1488             tk->fmt = fmt;
1489             tk->i_frame = 0;
1490             tk->p_frame = NULL;
1491
1492             tk->i_subpacket_h = i_subpacket_h;
1493             tk->i_subpacket_size = i_subpacket_size;
1494             tk->i_coded_frame_size = i_coded_frame_size;
1495             tk->i_frame_size = i_frame_size;
1496
1497             tk->i_out_subpacket = 0;
1498             tk->i_subpacket = 0;
1499             tk->i_subpackets = 0;
1500             tk->p_subpackets = NULL;
1501             tk->p_subpackets_timecode = NULL;
1502             if( fmt.i_codec == VLC_FOURCC('c','o','o','k')
1503              || fmt.i_codec == VLC_FOURCC('a','t','r','c') )
1504             {
1505                 tk->i_subpackets =
1506                     i_subpacket_h * i_frame_size / tk->i_subpacket_size;
1507                 tk->p_subpackets =
1508                     calloc( tk->i_subpackets, sizeof(block_t *) );
1509                 tk->p_subpackets_timecode =
1510                     calloc( tk->i_subpackets , sizeof( int64_t ) );
1511             }
1512             else if( fmt.i_codec == VLC_FOURCC('2','8','_','8') )
1513             {
1514                 tk->i_subpackets =
1515                     i_subpacket_h * i_frame_size / tk->i_coded_frame_size;
1516                 tk->p_subpackets =
1517                     calloc( tk->i_subpackets, sizeof(block_t *) );
1518                 tk->p_subpackets_timecode =
1519                     calloc( tk->i_subpackets , sizeof( int64_t ) );
1520             }
1521
1522             /* Check if the calloc went correctly */
1523             if( !tk->p_subpackets && !tk->p_subpackets_timecode)
1524             {
1525                 free( tk->p_subpackets_timecode );
1526                 free( tk->p_subpackets );
1527                 free( tk );
1528                 msg_Err( p_demux, "Can't alloc subpacket" );
1529                 return VLC_EGENERIC;
1530             }
1531
1532             tk->p_es = es_out_Add( p_demux->out, &fmt );
1533
1534             TAB_APPEND( p_sys->i_track, p_sys->track, tk );
1535         }
1536     }
1537
1538     return VLC_SUCCESS;
1539 }
1540