libmpdemux/asfheader.c

   1 /*
   2  * This file is part of MPlayer.
   3  *
   4  * MPlayer is free software; you can redistribute it and/or modify
   5  * it under the terms of the GNU General Public License as published by
   6  * the Free Software Foundation; either version 2 of the License, or
   7  * (at your option) any later version.
   8  *
   9  * MPlayer is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12  * GNU General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU General Public License along
  15  * with MPlayer; if not, write to the Free Software Foundation, Inc.,
  16  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  17  */
  18
  19 // .asf fileformat docs from http://divx.euro.ru
  20
  21 #include <stdio.h>
  22 #include <stdlib.h>
  23 #include <unistd.h>
  24
  25 #include "config.h"
  26 #include "libavutil/common.h"
  27 #include "ffmpeg_files/intreadwrite.h"
  28 #include "mp_msg.h"
  29
  30 #include "stream/stream.h"
  31 #include "aviprint.h"
  32 #include "demuxer.h"
  33 #include "stheader.h"
  34
  35 #include "asf.h"
  36 #include "asfguid.h"
  37 #include "asfheader.h"
  38
  39 typedef struct {
  40   // must be 0 for metadata record, might be non-zero for metadata lib record
  41   uint16_t lang_list_index;
  42   uint16_t stream_num;
  43   uint16_t name_length;
  44   uint16_t data_type;
  45   uint32_t data_length;
  46   uint16_t* name;
  47   void* data;
  48 } ASF_meta_record_t;
  49
  50 static char* get_ucs2str(const uint16_t* inbuf, uint16_t inlen)
  51 {
  52   char* outbuf = calloc(inlen, 2);
  53   char* q;
  54   int i;
  55
  56   if (!outbuf) {
  57     mp_tmsg(MSGT_HEADER, MSGL_ERR, "Memory allocation failed.\n");
  58     return NULL;
  59   }
  60   q = outbuf;
  61   for (i = 0; i < inlen / 2; i++) {
  62     uint8_t tmp;
  63     PUT_UTF8(AV_RL16(&inbuf[i]), tmp, *q++ = tmp;)
  64   }
  65   return outbuf;
  66 }
  67
  68 static const char* asf_chunk_type(unsigned char* guid) {
  69   static char tmp[60];
  70   char *p;
  71   int i;
  72
  73   switch(ASF_LOAD_GUID_PREFIX(guid)){
  74     case ASF_GUID_PREFIX_audio_stream:
  75       return "guid_audio_stream";
  76     case ASF_GUID_PREFIX_ext_audio_stream:
  77       return "guid_ext_audio_stream";
  78     case ASF_GUID_PREFIX_ext_stream_embed_stream_header:
  79       return "guid_ext_stream_embed_stream_header";
  80     case ASF_GUID_PREFIX_video_stream:
  81       return "guid_video_stream";
  82     case ASF_GUID_PREFIX_audio_conceal_none:
  83       return "guid_audio_conceal_none";
  84     case ASF_GUID_PREFIX_audio_conceal_interleave:
  85       return "guid_audio_conceal_interleave";
  86     case ASF_GUID_PREFIX_header:
  87       return "guid_header";
  88     case ASF_GUID_PREFIX_data_chunk:
  89       return "guid_data_chunk";
  90     case ASF_GUID_PREFIX_index_chunk:
  91       return "guid_index_chunk";
  92     case ASF_GUID_PREFIX_stream_header:
  93       return "guid_stream_header";
  94     case ASF_GUID_PREFIX_header_2_0:
  95       return "guid_header_2_0";
  96     case ASF_GUID_PREFIX_file_header:
  97       return "guid_file_header";
  98     case ASF_GUID_PREFIX_content_desc:
  99       return "guid_content_desc";
 100     case ASF_GUID_PREFIX_dvr_ms_timing_rep_data:
 101       return "guid_dvr_ms_timing_rep_data";
 102     case ASF_GUID_PREFIX_dvr_ms_vid_frame_rep_data:
 103       return "guid_dvr_ms_vid_frame_rep_data";
 104     default:
 105       strcpy(tmp, "unknown guid ");
 106       p = tmp + strlen(tmp);
 107       for (i = 0; i < 16; i++) {
 108         if ((1 << i) & ((1<<4) | (1<<6) | (1<<8))) *p++ = '-';
 109         sprintf(p, "%02x", guid[i]);
 110         p += 2;
 111       }
 112       return tmp;
 113   }
 114 }
 115
 116 int asf_check_header(demuxer_t *demuxer){
 117   unsigned char asfhdrguid[16]={0x30,0x26,0xB2,0x75,0x8E,0x66,0xCF,0x11,0xA6,0xD9,0x00,0xAA,0x00,0x62,0xCE,0x6C};
 118   struct asf_priv* asf = calloc(1,sizeof(*asf));
 119   asf->scrambling_h=asf->scrambling_w=asf->scrambling_b=1;
 120   stream_read(demuxer->stream,(char*) &asf->header,sizeof(asf->header)); // header obj
 121   le2me_ASF_header_t(&asf->header);                     // swap to machine endian
 122 //  for(i=0;i<16;i++) printf(" %02X",temp[i]);printf("\n");
 123 //  for(i=0;i<16;i++) printf(" %02X",asfhdrguid[i]);printf("\n");
 124   if(memcmp(asfhdrguid,asf->header.objh.guid,16)){
 125     mp_msg(MSGT_HEADER,MSGL_V,"ASF_check: not ASF guid!\n");
 126     free(asf);
 127     return 0; // not ASF guid
 128   }
 129   if(asf->header.cno>256){
 130     mp_msg(MSGT_HEADER,MSGL_V,"ASF_check: invalid subchunks_no %d\n",(int) asf->header.cno);
 131     free(asf);
 132     return 0; // invalid header???
 133   }
 134   demuxer->priv = asf;
 135   return DEMUXER_TYPE_ASF;
 136 }
 137
 138 static int get_ext_stream_properties(char *buf, int buf_len, int stream_num, struct asf_priv* asf, int is_video)
 139 {
 140   int pos=0;
 141   uint8_t *buffer = &buf[0];
 142   uint64_t avg_ft;
 143   unsigned bitrate;
 144
 145   while ((pos = find_asf_guid(buf, asf_ext_stream_header, pos, buf_len)) >= 0) {
 146     int this_stream_num, stnamect, payct, i;
 147     int buf_max_index=pos+50;
 148     if (buf_max_index > buf_len) return 0;
 149     buffer = &buf[pos];
 150
 151     // the following info is available
 152     // some of it may be useful but we're skipping it for now
 153     // starttime(8 bytes), endtime(8),
 154     // leak-datarate(4), bucket-datasize(4), init-bucket-fullness(4),
 155     // alt-leak-datarate(4), alt-bucket-datasize(4), alt-init-bucket-fullness(4),
 156     // max-object-size(4),
 157     // flags(4) (reliable,seekable,no_cleanpoints?,resend-live-cleanpoints, rest of bits reserved)
 158
 159     buffer += 8+8;
 160     bitrate = AV_RL32(buffer);
 161     buffer += 8*4;
 162     this_stream_num=AV_RL16(buffer);buffer+=2;
 163
 164     if (this_stream_num == stream_num) {
 165       buf_max_index+=14;
 166       if (buf_max_index > buf_len) return 0;
 167       buffer+=2; //skip stream-language-id-index
 168       avg_ft = AV_RL64(buffer); // provided in 100ns units
 169       buffer+=8;
 170       asf->bps = bitrate / 8;
 171
 172       // after this are values for stream-name-count and
 173       // payload-extension-system-count
 174       // followed by associated info for each
 175       stnamect = AV_RL16(buffer);buffer+=2;
 176       payct = AV_RL16(buffer);buffer+=2;
 177
 178       // need to read stream names if present in order
 179       // to get lengths - values are ignored for now
 180       for (i=0; i<stnamect; i++) {
 181         int stream_name_len;
 182         buf_max_index+=4;
 183         if (buf_max_index > buf_len) return 0;
 184         buffer+=2; //language_id_index
 185         stream_name_len = AV_RL16(buffer);buffer+=2;
 186         buffer+=stream_name_len; //stream_name
 187         buf_max_index+=stream_name_len;
 188         if (buf_max_index > buf_len) return 0;
 189       }
 190
 191       if (is_video) {
 192         asf->vid_repdata_count = payct;
 193         asf->vid_repdata_sizes = malloc(payct*sizeof(int));
 194       } else {
 195         asf->aud_repdata_count = payct;
 196         asf->aud_repdata_sizes = malloc(payct*sizeof(int));
 197       }
 198
 199       for (i=0; i<payct; i++) {
 200         int payload_len;
 201         buf_max_index+=22;
 202         if (buf_max_index > buf_len) return 0;
 203         // Each payload extension definition starts with a GUID.
 204         // In dvr-ms files one of these indicates the presence an
 205         // extension that contains pts values and this is always present
 206         // in the video and audio streams.
 207         // Another GUID indicates the presence of an extension
 208         // that contains useful video frame demuxing information.
 209         // Note that the extension data in each packet does not contain
 210         // these GUIDs and that this header section defines the order the data
 211         // will appear in.
 212         if (memcmp(buffer, asf_dvr_ms_timing_rep_data, 16) == 0) {
 213           if (is_video)
 214             asf->vid_ext_timing_index = i;
 215           else
 216             asf->aud_ext_timing_index = i;
 217         } else if (is_video && memcmp(buffer, asf_dvr_ms_vid_frame_rep_data, 16) == 0)
 218           asf->vid_ext_frame_index = i;
 219         buffer+=16;
 220
 221         payload_len = AV_RL16(buffer);buffer+=2;
 222
 223         if (is_video)
 224           asf->vid_repdata_sizes[i] = payload_len;
 225         else
 226           asf->aud_repdata_sizes[i] = payload_len;
 227         buffer+=4;//sys_len
 228       }
 229
 230       return 1;
 231     }
 232   }
 233   return 1;
 234 }
 235
 236 #define CHECKDEC(l, n) if (((l) -= (n)) < 0) return 0
 237 static char* read_meta_record(ASF_meta_record_t* dest, char* buf,
 238     int* buf_len)
 239 {
 240   CHECKDEC(*buf_len, 2 + 2 + 2 + 2 + 4);
 241   dest->lang_list_index = AV_RL16(buf);
 242   dest->stream_num = AV_RL16(&buf[2]);
 243   dest->name_length = AV_RL16(&buf[4]);
 244   dest->data_type = AV_RL16(&buf[6]);
 245   dest->data_length = AV_RL32(&buf[8]);
 246   buf += 2 + 2 + 2 + 2 + 4;
 247   CHECKDEC(*buf_len, dest->name_length);
 248   dest->name = (uint16_t*)buf;
 249   buf += dest->name_length;
 250   CHECKDEC(*buf_len, dest->data_length);
 251   dest->data = buf;
 252   buf += dest->data_length;
 253   return buf;
 254 }
 255
 256 static int get_meta(char *buf, int buf_len, int this_stream_num,
 257     float* asp_ratio)
 258 {
 259   int pos = 0;
 260   uint16_t records_count;
 261   uint16_t x = 0, y = 0;
 262
 263   if ((pos = find_asf_guid(buf, asf_metadata_header, pos, buf_len)) < 0)
 264     return 0;
 265
 266   CHECKDEC(buf_len, pos);
 267   buf += pos;
 268   CHECKDEC(buf_len, 2);
 269   records_count = AV_RL16(buf);
 270   buf += 2;
 271
 272   while (records_count--) {
 273     ASF_meta_record_t record_entry;
 274     char* name;
 275
 276     if (!(buf = read_meta_record(&record_entry, buf, &buf_len)))
 277         return 0;
 278     /* reserved, must be zero */
 279     if (record_entry.lang_list_index)
 280       continue;
 281     /* match stream number: 0 to match all */
 282     if (record_entry.stream_num && record_entry.stream_num != this_stream_num)
 283       continue;
 284     if (!(name = get_ucs2str(record_entry.name, record_entry.name_length))) {
 285       mp_tmsg(MSGT_HEADER, MSGL_ERR, "Memory allocation failed.\n");
 286       continue;
 287     }
 288     if (strcmp(name, "AspectRatioX") == 0)
 289       x = AV_RL16(record_entry.data);
 290     else if (strcmp(name, "AspectRatioY") == 0)
 291       y = AV_RL16(record_entry.data);
 292     free(name);
 293   }
 294   if (x && y) {
 295     *asp_ratio = (float)x / (float)y;
 296     return 1;
 297   }
 298   return 0;
 299 }
 300
 301 static int is_drm(char* buf, int buf_len)
 302 {
 303   uint32_t data_len, type_len, key_len, url_len;
 304   int pos = find_asf_guid(buf, asf_content_encryption, 0, buf_len);
 305
 306   if (pos < 0)
 307     return 0;
 308
 309   CHECKDEC(buf_len, pos + 4);
 310   buf += pos;
 311   data_len = AV_RL32(buf);
 312   buf += 4;
 313   CHECKDEC(buf_len, data_len);
 314   buf += data_len;
 315   type_len = AV_RL32(buf);
 316   if (type_len < 4)
 317     return 0;
 318   CHECKDEC(buf_len, 4 + type_len + 4);
 319   buf += 4;
 320
 321   if (buf[0] != 'D' || buf[1] != 'R' || buf[2] != 'M' || buf[3] != '\0')
 322     return 0;
 323
 324   buf += type_len;
 325   key_len = AV_RL32(buf);
 326   CHECKDEC(buf_len, key_len + 4);
 327   buf += 4;
 328
 329   buf[key_len - 1] = '\0';
 330   mp_msg(MSGT_HEADER, MSGL_V, "DRM Key ID: %s\n", buf);
 331
 332   buf += key_len;
 333   url_len = AV_RL32(buf);
 334   CHECKDEC(buf_len, url_len);
 335   buf += 4;
 336
 337   buf[url_len - 1] = '\0';
 338   mp_tmsg(MSGT_HEADER, MSGL_INFO, "DRM License URL: %s\n", buf);
 339   return 1;
 340 }
 341
 342 static int asf_init_audio_stream(demuxer_t *demuxer,struct asf_priv* asf, sh_audio_t* sh_audio, ASF_stream_header_t *streamh, int *ppos, uint8_t** buf, char *hdr, unsigned int hdr_len)
 343 {
 344   uint8_t *buffer = *buf;
 345   int pos = *ppos;
 346
 347   sh_audio->wf=calloc((streamh->type_size<sizeof(WAVEFORMATEX))?sizeof(WAVEFORMATEX):streamh->type_size,1);
 348   memcpy(sh_audio->wf,buffer,streamh->type_size);
 349   le2me_WAVEFORMATEX(sh_audio->wf);
 350   if( mp_msg_test(MSGT_HEADER,MSGL_V) ) print_wave_header(sh_audio->wf,MSGL_V);
 351   if(ASF_LOAD_GUID_PREFIX(streamh->concealment)==ASF_GUID_PREFIX_audio_conceal_interleave){
 352     buffer = &hdr[pos];
 353     pos += streamh->stream_size;
 354     if (pos > hdr_len) return 0;
 355     asf->scrambling_h=buffer[0];
 356     asf->scrambling_w=(buffer[2]<<8)|buffer[1];
 357     asf->scrambling_b=(buffer[4]<<8)|buffer[3];
 358     if(asf->scrambling_b>0){
 359       asf->scrambling_w/=asf->scrambling_b;
 360     }
 361   } else {
 362     asf->scrambling_b=asf->scrambling_h=asf->scrambling_w=1;
 363   }
 364   mp_msg(MSGT_HEADER,MSGL_V,"ASF: audio scrambling: %d x %d x %d\n",asf->scrambling_h,asf->scrambling_w,asf->scrambling_b);
 365   return 1;
 366 }
 367
 368 static int find_backwards_asf_guid(char *buf, const char *guid, int cur_pos)
 369 {
 370   int i;
 371   for (i=cur_pos-16; i>0; i--) {
 372     if (memcmp(&buf[i], guid, 16) == 0)
 373       return i + 16 + 8; // point after guid + length
 374   }
 375   return -1;
 376 }
 377
 378 int read_asf_header(demuxer_t *demuxer,struct asf_priv* asf){
 379   int hdr_len = asf->header.objh.size - sizeof(asf->header);
 380   int hdr_skip = 0;
 381   char *hdr = NULL;
 382   char guid_buffer[16];
 383   int pos, start = stream_tell(demuxer->stream);
 384   uint32_t* streams = NULL;
 385   int audio_streams=0;
 386   int video_streams=0;
 387   uint16_t stream_count=0;
 388   int best_video = -1;
 389   int best_audio = -1;
 390   uint64_t data_len;
 391   ASF_stream_header_t *streamh;
 392   uint8_t *buffer;
 393   int audio_pos=0;
 394
 395   if(hdr_len < 0) {
 396     mp_msg(MSGT_HEADER, MSGL_FATAL, "Header size is too small.\n");
 397     return 0;
 398   }
 399
 400   if (hdr_len > 1024 * 1024) {
 401     mp_tmsg(MSGT_HEADER, MSGL_ERR, "FATAL: header size bigger than 1 MB (%d)!\nPlease contact MPlayer authors, and upload/send this file.\n",
 402                         hdr_len);
 403     hdr_skip = hdr_len - 1024 * 1024;
 404     hdr_len = 1024 * 1024;
 405   }
 406   hdr = malloc(hdr_len);
 407   if (!hdr) {
 408     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "Could not allocate %d bytes for header.\n",
 409             hdr_len);
 410     return 0;
 411   }
 412   stream_read(demuxer->stream, hdr, hdr_len);
 413   if (hdr_skip)
 414     stream_skip(demuxer->stream, hdr_skip);
 415   if (stream_eof(demuxer->stream)) {
 416     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "EOF while reading ASF header, broken/incomplete file?\n");
 417     goto err_out;
 418   }
 419
 420   if (is_drm(hdr, hdr_len))
 421     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "This file has been encumbered with DRM encryption, it will not play in MPlayer!\n");
 422
 423   if ((pos = find_asf_guid(hdr, asf_ext_stream_audio, 0, hdr_len)) >= 0)
 424   {
 425     // Special case: found GUID for dvr-ms audio.
 426     // Now skip back to associated stream header.
 427     int sh_pos=0;
 428
 429     sh_pos = find_backwards_asf_guid(hdr, asf_stream_header_guid, pos);
 430
 431     if (sh_pos > 0) {
 432       sh_audio_t *sh_audio;
 433
 434        mp_msg(MSGT_HEADER, MSGL_V, "read_asf_header found dvr-ms audio stream header pos=%d\n", sh_pos);
 435       // found audio stream header - following code reads header and
 436       // initializes audio stream.
 437       audio_pos = pos - 16 - 8;
 438       streamh = (ASF_stream_header_t *)&hdr[sh_pos];
 439       le2me_ASF_stream_header_t(streamh);
 440       audio_pos += 64; //16+16+4+4+4+16+4;
 441       buffer = &hdr[audio_pos];
 442       sh_audio=new_sh_audio(demuxer,streamh->stream_no & 0x7F);
 443       sh_audio->needs_parsing = 1;
 444       mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "asfheader", streamh->stream_no & 0x7F);
 445       ++audio_streams;
 446       if (!asf_init_audio_stream(demuxer, asf, sh_audio, streamh, &audio_pos, &buffer, hdr, hdr_len))
 447         goto len_err_out;
 448       if (!get_ext_stream_properties(hdr, hdr_len, streamh->stream_no, asf, 0))
 449         goto len_err_out;
 450     }
 451   }
 452   // find stream headers
 453   // only reset pos if we didnt find dvr_ms audio stream
 454   // if we did find it then we want to avoid reading its header twice
 455   if (audio_pos == 0)
 456     pos = 0;
 457
 458   while ((pos = find_asf_guid(hdr, asf_stream_header_guid, pos, hdr_len)) >= 0)
 459   {
 460     streamh = (ASF_stream_header_t *)&hdr[pos];
 461     pos += sizeof(ASF_stream_header_t);
 462     if (pos > hdr_len) goto len_err_out;
 463     le2me_ASF_stream_header_t(streamh);
 464     mp_msg(MSGT_HEADER, MSGL_V, "stream type: %s\n",
 465             asf_chunk_type(streamh->type));
 466     mp_msg(MSGT_HEADER, MSGL_V, "stream concealment: %s\n",
 467             asf_chunk_type(streamh->concealment));
 468     mp_msg(MSGT_HEADER, MSGL_V, "type: %d bytes,  stream: %d bytes  ID: %d\n",
 469             (int)streamh->type_size, (int)streamh->stream_size,
 470             (int)streamh->stream_no);
 471     mp_msg(MSGT_HEADER, MSGL_V, "unk1: %lX  unk2: %X\n",
 472             (unsigned long)streamh->unk1, (unsigned int)streamh->unk2);
 473     mp_msg(MSGT_HEADER, MSGL_V, "FILEPOS=0x%X\n", pos + start);
 474     // type-specific data:
 475     buffer = &hdr[pos];
 476     pos += streamh->type_size;
 477     if (pos > hdr_len) goto len_err_out;
 478     switch(ASF_LOAD_GUID_PREFIX(streamh->type)){
 479       case ASF_GUID_PREFIX_audio_stream: {
 480         sh_audio_t* sh_audio=new_sh_audio(demuxer,streamh->stream_no & 0x7F);
 481         mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "asfheader", streamh->stream_no & 0x7F);
 482         ++audio_streams;
 483         if (!asf_init_audio_stream(demuxer, asf, sh_audio, streamh, &pos, &buffer, hdr, hdr_len))
 484           goto len_err_out;
 485         //if(demuxer->audio->id==-1) demuxer->audio->id=streamh.stream_no & 0x7F;
 486         break;
 487         }
 488       case ASF_GUID_PREFIX_video_stream: {
 489         unsigned int len;
 490         float asp_ratio;
 491         sh_video_t* sh_video=new_sh_video(demuxer,streamh->stream_no & 0x7F);
 492         mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Video stream found, -vid %d\n", "asfheader", streamh->stream_no & 0x7F);
 493         len=streamh->type_size-(4+4+1+2);
 494         ++video_streams;
 495 //        sh_video->bih=malloc(chunksize); memset(sh_video->bih,0,chunksize);
 496         sh_video->bih=calloc((len<sizeof(BITMAPINFOHEADER))?sizeof(BITMAPINFOHEADER):len,1);
 497         memcpy(sh_video->bih,&buffer[4+4+1+2],len);
 498         le2me_BITMAPINFOHEADER(sh_video->bih);
 499         if (sh_video->bih->biSize > len && sh_video->bih->biSize > sizeof(BITMAPINFOHEADER))
 500                 sh_video->bih->biSize = len;
 501         if (sh_video->bih->biCompression == mmioFOURCC('D', 'V', 'R', ' ')) {
 502           //mp_tmsg(MSGT_DEMUXER, MSGL_WARN, "DVR will probably only work with libavformat, try -demuxer 35 if you have problems\n");
 503           //sh_video->fps=(float)sh_video->video.dwRate/(float)sh_video->video.dwScale;
 504           //sh_video->frametime=(float)sh_video->video.dwScale/(float)sh_video->video.dwRate;
 505           asf->asf_frame_state=-1;
 506           asf->asf_frame_start_found=0;
 507           asf->asf_is_dvr_ms=1;
 508           asf->dvr_last_vid_pts=0.0;
 509         } else asf->asf_is_dvr_ms=0;
 510         if (!get_ext_stream_properties(hdr, hdr_len, streamh->stream_no, asf, 1))
 511             goto len_err_out;
 512         if (get_meta(hdr, hdr_len, streamh->stream_no, &asp_ratio)) {
 513           sh_video->aspect = asp_ratio * sh_video->bih->biWidth /
 514             sh_video->bih->biHeight;
 515         }
 516         sh_video->i_bps = asf->bps;
 517
 518         if( mp_msg_test(MSGT_DEMUX,MSGL_V) ) print_video_header(sh_video->bih, MSGL_V);
 519         //asf_video_id=streamh.stream_no & 0x7F;
 520         //if(demuxer->video->id==-1) demuxer->video->id=streamh.stream_no & 0x7F;
 521         break;
 522         }
 523       }
 524       // stream-specific data:
 525       // stream_read(demuxer->stream,(char*) buffer,streamh.stream_size);
 526   }
 527
 528   // find file header
 529   pos = find_asf_guid(hdr, asf_file_header_guid, 0, hdr_len);
 530   if (pos >= 0) {
 531       ASF_file_header_t *fileh = (ASF_file_header_t *)&hdr[pos];
 532       pos += sizeof(ASF_file_header_t);
 533       if (pos > hdr_len) goto len_err_out;
 534       le2me_ASF_file_header_t(fileh);
 535       mp_msg(MSGT_HEADER, MSGL_V, "ASF: packets: %d  flags: %d  "
 536               "max_packet_size: %d  min_packet_size: %d  max_bitrate: %d  "
 537               "preroll: %d\n",
 538               (int)fileh->num_packets, (int)fileh->flags,
 539               (int)fileh->min_packet_size, (int)fileh->max_packet_size,
 540               (int)fileh->max_bitrate, (int)fileh->preroll);
 541       asf->packetsize=fileh->max_packet_size;
 542       asf->packet=malloc(asf->packetsize); // !!!
 543       asf->packetrate=fileh->max_bitrate/8.0/(double)asf->packetsize;
 544       asf->movielength=(fileh->play_duration-10000*fileh->preroll)/10000000.0;
 545   }
 546
 547   // find content header
 548   pos = find_asf_guid(hdr, asf_content_desc_guid, 0, hdr_len);
 549   if (pos >= 0) {
 550         ASF_content_description_t *contenth = (ASF_content_description_t *)&hdr[pos];
 551         char *string=NULL;
 552         uint16_t* wstring = NULL;
 553         uint16_t len;
 554         pos += sizeof(ASF_content_description_t);
 555         if (pos > hdr_len) goto len_err_out;
 556         le2me_ASF_content_description_t(contenth);
 557         mp_msg(MSGT_HEADER,MSGL_V,"\n");
 558         // extract the title
 559         if((len = contenth->title_size) != 0) {
 560           wstring = (uint16_t*)&hdr[pos];
 561           pos += len;
 562           if (pos > hdr_len) goto len_err_out;
 563           if ((string = get_ucs2str(wstring, len))) {
 564             mp_msg(MSGT_HEADER,MSGL_V," Title: %s\n", string);
 565             demux_info_add(demuxer, "title", string);
 566             free(string);
 567           }
 568         }
 569         // extract the author
 570         if((len = contenth->author_size) != 0) {
 571           wstring = (uint16_t*)&hdr[pos];
 572           pos += len;
 573           if (pos > hdr_len) goto len_err_out;
 574           if ((string = get_ucs2str(wstring, len))) {
 575             mp_msg(MSGT_HEADER,MSGL_V," Author: %s\n", string);
 576             demux_info_add(demuxer, "author", string);
 577             free(string);
 578           }
 579         }
 580         // extract the copyright
 581         if((len = contenth->copyright_size) != 0) {
 582           wstring = (uint16_t*)&hdr[pos];
 583           pos += len;
 584           if (pos > hdr_len) goto len_err_out;
 585           if ((string = get_ucs2str(wstring, len))) {
 586             mp_msg(MSGT_HEADER,MSGL_V," Copyright: %s\n", string);
 587             demux_info_add(demuxer, "copyright", string);
 588             free(string);
 589           }
 590         }
 591         // extract the comment
 592         if((len = contenth->comment_size) != 0) {
 593           wstring = (uint16_t*)&hdr[pos];
 594           pos += len;
 595           if (pos > hdr_len) goto len_err_out;
 596           if ((string = get_ucs2str(wstring, len))) {
 597             mp_msg(MSGT_HEADER,MSGL_V," Comment: %s\n", string);
 598             demux_info_add(demuxer, "comments", string);
 599             free(string);
 600           }
 601         }
 602         // extract the rating
 603         if((len = contenth->rating_size) != 0) {
 604           wstring = (uint16_t*)&hdr[pos];
 605           pos += len;
 606           if (pos > hdr_len) goto len_err_out;
 607           if ((string = get_ucs2str(wstring, len))) {
 608             mp_msg(MSGT_HEADER,MSGL_V," Rating: %s\n", string);
 609             free(string);
 610           }
 611         }
 612         mp_msg(MSGT_HEADER,MSGL_V,"\n");
 613   }
 614
 615   // find content header
 616   pos = find_asf_guid(hdr, asf_stream_group_guid, 0, hdr_len);
 617   if (pos >= 0) {
 618         int max_streams = (hdr_len - pos - 2) / 6;
 619         uint16_t stream_id, i;
 620         uint32_t max_bitrate;
 621         char *ptr = &hdr[pos];
 622         mp_msg(MSGT_HEADER,MSGL_V,"============ ASF Stream group == START ===\n");
 623         if(max_streams <= 0) goto len_err_out;
 624         stream_count = AV_RL16(ptr);
 625         ptr += sizeof(uint16_t);
 626         if(stream_count > max_streams) stream_count = max_streams;
 627         if(stream_count > 0)
 628               streams = malloc(2*stream_count*sizeof(uint32_t));
 629         mp_msg(MSGT_HEADER,MSGL_V," stream count=[0x%x][%u]\n", stream_count, stream_count );
 630         for( i=0 ; i<stream_count ; i++ ) {
 631           stream_id = AV_RL16(ptr);
 632           ptr += sizeof(uint16_t);
 633           memcpy(&max_bitrate, ptr, sizeof(uint32_t));// workaround unaligment bug on sparc
 634           max_bitrate = le2me_32(max_bitrate);
 635           ptr += sizeof(uint32_t);
 636           mp_msg(MSGT_HEADER,MSGL_V,"   stream id=[0x%x][%u]\n", stream_id, stream_id );
 637           mp_msg(MSGT_HEADER,MSGL_V,"   max bitrate=[0x%x][%u]\n", max_bitrate, max_bitrate );
 638           streams[2*i] = stream_id;
 639           streams[2*i+1] = max_bitrate;
 640         }
 641         mp_msg(MSGT_HEADER,MSGL_V,"============ ASF Stream group == END ===\n");
 642   }
 643   free(hdr);
 644   hdr = NULL;
 645   start = stream_tell(demuxer->stream); // start of first data chunk
 646   stream_read(demuxer->stream, guid_buffer, 16);
 647   if (memcmp(guid_buffer, asf_data_chunk_guid, 16) != 0) {
 648     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "No data chunk following header!\n");
 649     free(streams);
 650     streams = NULL;
 651     return 0;
 652   }
 653   // read length of chunk
 654   stream_read(demuxer->stream, (char *)&data_len, sizeof(data_len));
 655   data_len = le2me_64(data_len);
 656   demuxer->movi_start = stream_tell(demuxer->stream) + 26;
 657   demuxer->movi_end = start + data_len;
 658   mp_msg(MSGT_HEADER, MSGL_V, "Found movie at 0x%X - 0x%X\n",
 659           (int)demuxer->movi_start, (int)demuxer->movi_end);
 660
 661 if(streams) {
 662   // stream selection is done in the network code, it shouldn't be done here
 663   // as the servers often do not care about what we requested.
 664 #if 0
 665   uint32_t vr = 0, ar = 0,i;
 666 #ifdef CONFIG_NETWORK
 667   if( demuxer->stream->streaming_ctrl!=NULL ) {
 668           if( demuxer->stream->streaming_ctrl->bandwidth!=0 && demuxer->stream->streaming_ctrl->data!=NULL ) {
 669                   best_audio = ((asf_http_streaming_ctrl_t*)demuxer->stream->streaming_ctrl->data)->audio_id;
 670                   best_video = ((asf_http_streaming_ctrl_t*)demuxer->stream->streaming_ctrl->data)->video_id;
 671           }
 672   } else
 673 #endif
 674   for(i = 0; i < stream_count; i++) {
 675     uint32_t id = streams[2*i];
 676     uint32_t rate = streams[2*i+1];
 677     if(demuxer->v_streams[id] && rate > vr) {
 678       vr = rate;
 679       best_video = id;
 680     } else if(demuxer->a_streams[id] && rate > ar) {
 681       ar = rate;
 682       best_audio = id;
 683     }
 684   }
 685 #endif
 686   free(streams);
 687   streams = NULL;
 688 }
 689
 690 mp_msg(MSGT_HEADER,MSGL_V,"ASF: %d audio and %d video streams found\n",audio_streams,video_streams);
 691 if(!audio_streams) demuxer->audio->id=-2;  // nosound
 692 else if(best_audio > 0 && demuxer->audio->id == -1) demuxer->audio->id=best_audio;
 693 if(!video_streams){
 694     if(!audio_streams){
 695         mp_tmsg(MSGT_HEADER,MSGL_ERR,"ASF: no audio or video headers found - broken file?\n");
 696         return 0;
 697     }
 698     demuxer->video->id=-2; // audio-only
 699 } else if (best_video > 0 && demuxer->video->id == -1) demuxer->video->id = best_video;
 700
 701 #if 0
 702 if( mp_msg_test(MSGT_HEADER,MSGL_V) ){
 703     printf("ASF duration: %d\n",(int)fileh.duration);
 704     printf("ASF start pts: %d\n",(int)fileh.start_timestamp);
 705     printf("ASF end pts: %d\n",(int)fileh.end_timestamp);
 706 }
 707 #endif
 708
 709 return 1;
 710
 711 len_err_out:
 712   mp_tmsg(MSGT_HEADER, MSGL_FATAL, "Invalid length in ASF header!\n");
 713 err_out:
 714   if (hdr) free(hdr);
 715   if (streams) free(streams);
 716   return 0;
 717 }