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(FFMAX(streamh->type_size, sizeof(*sh_audio->wf)), 1);
 348   memcpy(sh_audio->wf,buffer,streamh->type_size);
 349   le2me_WAVEFORMATEX(sh_audio->wf);
 350   sh_audio->format=sh_audio->wf->wFormatTag;
 351   if( mp_msg_test(MSGT_HEADER,MSGL_V) ) print_wave_header(sh_audio->wf,MSGL_V);
 352   if(ASF_LOAD_GUID_PREFIX(streamh->concealment)==ASF_GUID_PREFIX_audio_conceal_interleave){
 353     buffer = &hdr[pos];
 354     pos += streamh->stream_size;
 355     if (pos > hdr_len) return 0;
 356     asf->scrambling_h=buffer[0];
 357     asf->scrambling_w=(buffer[2]<<8)|buffer[1];
 358     asf->scrambling_b=(buffer[4]<<8)|buffer[3];
 359     if(asf->scrambling_b>0){
 360       asf->scrambling_w/=asf->scrambling_b;
 361     }
 362   } else {
 363     asf->scrambling_b=asf->scrambling_h=asf->scrambling_w=1;
 364   }
 365   mp_msg(MSGT_HEADER,MSGL_V,"ASF: audio scrambling: %d x %d x %d\n",asf->scrambling_h,asf->scrambling_w,asf->scrambling_b);
 366   return 1;
 367 }
 368
 369 static int find_backwards_asf_guid(char *buf, const char *guid, int cur_pos)
 370 {
 371   int i;
 372   for (i=cur_pos-16; i>0; i--) {
 373     if (memcmp(&buf[i], guid, 16) == 0)
 374       return i + 16 + 8; // point after guid + length
 375   }
 376   return -1;
 377 }
 378
 379 int read_asf_header(demuxer_t *demuxer,struct asf_priv* asf){
 380   int hdr_len = asf->header.objh.size - sizeof(asf->header);
 381   int hdr_skip = 0;
 382   char *hdr = NULL;
 383   char guid_buffer[16];
 384   int pos, start = stream_tell(demuxer->stream);
 385   uint32_t* streams = NULL;
 386   int audio_streams=0;
 387   int video_streams=0;
 388   uint16_t stream_count=0;
 389   int best_video = -1;
 390   int best_audio = -1;
 391   uint64_t data_len;
 392   ASF_stream_header_t *streamh;
 393   uint8_t *buffer;
 394   int audio_pos=0;
 395
 396   if(hdr_len < 0) {
 397     mp_msg(MSGT_HEADER, MSGL_FATAL, "Header size is too small.\n");
 398     return 0;
 399   }
 400
 401   if (hdr_len > 1024 * 1024) {
 402     mp_tmsg(MSGT_HEADER, MSGL_ERR, "FATAL: header size bigger than 1 MB (%d)!\nPlease contact MPlayer authors, and upload/send this file.\n",
 403                         hdr_len);
 404     hdr_skip = hdr_len - 1024 * 1024;
 405     hdr_len = 1024 * 1024;
 406   }
 407   hdr = malloc(hdr_len);
 408   if (!hdr) {
 409     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "Could not allocate %d bytes for header.\n",
 410             hdr_len);
 411     return 0;
 412   }
 413   stream_read(demuxer->stream, hdr, hdr_len);
 414   if (hdr_skip)
 415     stream_skip(demuxer->stream, hdr_skip);
 416   if (stream_eof(demuxer->stream)) {
 417     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "EOF while reading ASF header, broken/incomplete file?\n");
 418     goto err_out;
 419   }
 420
 421   if (is_drm(hdr, hdr_len))
 422     mp_tmsg(MSGT_HEADER, MSGL_FATAL, "This file has been encumbered with DRM encryption, it will not play in MPlayer!\n");
 423
 424   if ((pos = find_asf_guid(hdr, asf_ext_stream_audio, 0, hdr_len)) >= 0)
 425   {
 426     // Special case: found GUID for dvr-ms audio.
 427     // Now skip back to associated stream header.
 428     int sh_pos=0;
 429
 430     sh_pos = find_backwards_asf_guid(hdr, asf_stream_header_guid, pos);
 431
 432     if (sh_pos > 0) {
 433       sh_audio_t *sh_audio;
 434
 435        mp_msg(MSGT_HEADER, MSGL_V, "read_asf_header found dvr-ms audio stream header pos=%d\n", sh_pos);
 436       // found audio stream header - following code reads header and
 437       // initializes audio stream.
 438       audio_pos = pos - 16 - 8;
 439       streamh = (ASF_stream_header_t *)&hdr[sh_pos];
 440       le2me_ASF_stream_header_t(streamh);
 441       audio_pos += 64; //16+16+4+4+4+16+4;
 442       buffer = &hdr[audio_pos];
 443       sh_audio=new_sh_audio(demuxer,streamh->stream_no & 0x7F);
 444       sh_audio->needs_parsing = 1;
 445       mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "asfheader", streamh->stream_no & 0x7F);
 446       ++audio_streams;
 447       if (!asf_init_audio_stream(demuxer, asf, sh_audio, streamh, &audio_pos, &buffer, hdr, hdr_len))
 448         goto len_err_out;
 449       if (!get_ext_stream_properties(hdr, hdr_len, streamh->stream_no, asf, 0))
 450         goto len_err_out;
 451     }
 452   }
 453   // find stream headers
 454   // only reset pos if we didnt find dvr_ms audio stream
 455   // if we did find it then we want to avoid reading its header twice
 456   if (audio_pos == 0)
 457     pos = 0;
 458
 459   while ((pos = find_asf_guid(hdr, asf_stream_header_guid, pos, hdr_len)) >= 0)
 460   {
 461     streamh = (ASF_stream_header_t *)&hdr[pos];
 462     pos += sizeof(ASF_stream_header_t);
 463     if (pos > hdr_len) goto len_err_out;
 464     le2me_ASF_stream_header_t(streamh);
 465     mp_msg(MSGT_HEADER, MSGL_V, "stream type: %s\n",
 466             asf_chunk_type(streamh->type));
 467     mp_msg(MSGT_HEADER, MSGL_V, "stream concealment: %s\n",
 468             asf_chunk_type(streamh->concealment));
 469     mp_msg(MSGT_HEADER, MSGL_V, "type: %d bytes,  stream: %d bytes  ID: %d\n",
 470             (int)streamh->type_size, (int)streamh->stream_size,
 471             (int)streamh->stream_no);
 472     mp_msg(MSGT_HEADER, MSGL_V, "unk1: %lX  unk2: %X\n",
 473             (unsigned long)streamh->unk1, (unsigned int)streamh->unk2);
 474     mp_msg(MSGT_HEADER, MSGL_V, "FILEPOS=0x%X\n", pos + start);
 475     // type-specific data:
 476     buffer = &hdr[pos];
 477     pos += streamh->type_size;
 478     if (pos > hdr_len) goto len_err_out;
 479     switch(ASF_LOAD_GUID_PREFIX(streamh->type)){
 480       case ASF_GUID_PREFIX_audio_stream: {
 481         sh_audio_t* sh_audio=new_sh_audio(demuxer,streamh->stream_no & 0x7F);
 482         mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Audio stream found, -aid %d\n", "asfheader", streamh->stream_no & 0x7F);
 483         ++audio_streams;
 484         if (!asf_init_audio_stream(demuxer, asf, sh_audio, streamh, &pos, &buffer, hdr, hdr_len))
 485           goto len_err_out;
 486         //if(demuxer->audio->id==-1) demuxer->audio->id=streamh.stream_no & 0x7F;
 487         break;
 488         }
 489       case ASF_GUID_PREFIX_video_stream: {
 490         unsigned int len;
 491         float asp_ratio;
 492         sh_video_t* sh_video=new_sh_video(demuxer,streamh->stream_no & 0x7F);
 493         mp_tmsg(MSGT_DEMUX, MSGL_INFO, "[%s] Video stream found, -vid %d\n", "asfheader", streamh->stream_no & 0x7F);
 494         len=streamh->type_size-(4+4+1+2);
 495         ++video_streams;
 496 //        sh_video->bih=malloc(chunksize); memset(sh_video->bih,0,chunksize);
 497         sh_video->bih=calloc((len<sizeof(*sh_video->bih))?sizeof(*sh_video->bih):len,1);
 498         memcpy(sh_video->bih,&buffer[4+4+1+2],len);
 499         le2me_BITMAPINFOHEADER(sh_video->bih);
 500         if (sh_video->bih->biSize > len && sh_video->bih->biSize > sizeof(*sh_video->bih))
 501                 sh_video->bih->biSize = len;
 502         if (sh_video->bih->biCompression == mmioFOURCC('D', 'V', 'R', ' ')) {
 503           //mp_tmsg(MSGT_DEMUXER, MSGL_WARN, "DVR will probably only work with libavformat, try -demuxer 35 if you have problems\n");
 504           //sh_video->fps=(float)sh_video->video.dwRate/(float)sh_video->video.dwScale;
 505           //sh_video->frametime=(float)sh_video->video.dwScale/(float)sh_video->video.dwRate;
 506           asf->asf_frame_state=-1;
 507           asf->asf_frame_start_found=0;
 508           asf->asf_is_dvr_ms=1;
 509           asf->dvr_last_vid_pts=0.0;
 510         } else asf->asf_is_dvr_ms=0;
 511         if (!get_ext_stream_properties(hdr, hdr_len, streamh->stream_no, asf, 1))
 512             goto len_err_out;
 513         if (get_meta(hdr, hdr_len, streamh->stream_no, &asp_ratio)) {
 514           sh_video->aspect = asp_ratio * sh_video->bih->biWidth /
 515             sh_video->bih->biHeight;
 516         }
 517         sh_video->i_bps = asf->bps;
 518
 519         if( mp_msg_test(MSGT_DEMUX,MSGL_V) ) print_video_header(sh_video->bih, MSGL_V);
 520         //asf_video_id=streamh.stream_no & 0x7F;
 521         //if(demuxer->video->id==-1) demuxer->video->id=streamh.stream_no & 0x7F;
 522         break;
 523         }
 524       }
 525       // stream-specific data:
 526       // stream_read(demuxer->stream,(char*) buffer,streamh.stream_size);
 527   }
 528
 529   // find file header
 530   pos = find_asf_guid(hdr, asf_file_header_guid, 0, hdr_len);
 531   if (pos >= 0) {
 532       ASF_file_header_t *fileh = (ASF_file_header_t *)&hdr[pos];
 533       pos += sizeof(ASF_file_header_t);
 534       if (pos > hdr_len) goto len_err_out;
 535       le2me_ASF_file_header_t(fileh);
 536       mp_msg(MSGT_HEADER, MSGL_V, "ASF: packets: %d  flags: %d  "
 537               "max_packet_size: %d  min_packet_size: %d  max_bitrate: %d  "
 538               "preroll: %d\n",
 539               (int)fileh->num_packets, (int)fileh->flags,
 540               (int)fileh->min_packet_size, (int)fileh->max_packet_size,
 541               (int)fileh->max_bitrate, (int)fileh->preroll);
 542       asf->packetsize=fileh->max_packet_size;
 543       asf->packet=malloc(asf->packetsize); // !!!
 544       asf->packetrate=fileh->max_bitrate/8.0/(double)asf->packetsize;
 545       asf->movielength=(fileh->play_duration-10000*fileh->preroll)/10000000.0;
 546   }
 547
 548   // find content header
 549   pos = find_asf_guid(hdr, asf_content_desc_guid, 0, hdr_len);
 550   if (pos >= 0) {
 551         ASF_content_description_t *contenth = (ASF_content_description_t *)&hdr[pos];
 552         char *string=NULL;
 553         uint16_t* wstring = NULL;
 554         uint16_t len;
 555         pos += sizeof(ASF_content_description_t);
 556         if (pos > hdr_len) goto len_err_out;
 557         le2me_ASF_content_description_t(contenth);
 558         mp_msg(MSGT_HEADER,MSGL_V,"\n");
 559         // extract the title
 560         if((len = contenth->title_size) != 0) {
 561           wstring = (uint16_t*)&hdr[pos];
 562           pos += len;
 563           if (pos > hdr_len) goto len_err_out;
 564           if ((string = get_ucs2str(wstring, len))) {
 565             mp_msg(MSGT_HEADER,MSGL_V," Title: %s\n", string);
 566             demux_info_add(demuxer, "title", string);
 567             free(string);
 568           }
 569         }
 570         // extract the author
 571         if((len = contenth->author_size) != 0) {
 572           wstring = (uint16_t*)&hdr[pos];
 573           pos += len;
 574           if (pos > hdr_len) goto len_err_out;
 575           if ((string = get_ucs2str(wstring, len))) {
 576             mp_msg(MSGT_HEADER,MSGL_V," Author: %s\n", string);
 577             demux_info_add(demuxer, "author", string);
 578             free(string);
 579           }
 580         }
 581         // extract the copyright
 582         if((len = contenth->copyright_size) != 0) {
 583           wstring = (uint16_t*)&hdr[pos];
 584           pos += len;
 585           if (pos > hdr_len) goto len_err_out;
 586           if ((string = get_ucs2str(wstring, len))) {
 587             mp_msg(MSGT_HEADER,MSGL_V," Copyright: %s\n", string);
 588             demux_info_add(demuxer, "copyright", string);
 589             free(string);
 590           }
 591         }
 592         // extract the comment
 593         if((len = contenth->comment_size) != 0) {
 594           wstring = (uint16_t*)&hdr[pos];
 595           pos += len;
 596           if (pos > hdr_len) goto len_err_out;
 597           if ((string = get_ucs2str(wstring, len))) {
 598             mp_msg(MSGT_HEADER,MSGL_V," Comment: %s\n", string);
 599             demux_info_add(demuxer, "comments", string);
 600             free(string);
 601           }
 602         }
 603         // extract the rating
 604         if((len = contenth->rating_size) != 0) {
 605           wstring = (uint16_t*)&hdr[pos];
 606           pos += len;
 607           if (pos > hdr_len) goto len_err_out;
 608           if ((string = get_ucs2str(wstring, len))) {
 609             mp_msg(MSGT_HEADER,MSGL_V," Rating: %s\n", string);
 610             free(string);
 611           }
 612         }
 613         mp_msg(MSGT_HEADER,MSGL_V,"\n");
 614   }
 615
 616   // find content header
 617   pos = find_asf_guid(hdr, asf_stream_group_guid, 0, hdr_len);
 618   if (pos >= 0) {
 619         int max_streams = (hdr_len - pos - 2) / 6;
 620         uint16_t stream_id, i;
 621         uint32_t max_bitrate;
 622         char *ptr = &hdr[pos];
 623         mp_msg(MSGT_HEADER,MSGL_V,"============ ASF Stream group == START ===\n");
 624         if(max_streams <= 0) goto len_err_out;
 625         stream_count = AV_RL16(ptr);
 626         ptr += sizeof(uint16_t);
 627         if(stream_count > max_streams) stream_count = max_streams;
 628         if(stream_count > 0)
 629               streams = malloc(2*stream_count*sizeof(uint32_t));
 630         mp_msg(MSGT_HEADER,MSGL_V," stream count=[0x%x][%u]\n", stream_count, stream_count );
 631         for( i=0 ; i<stream_count ; i++ ) {
 632           stream_id = AV_RL16(ptr);
 633           ptr += sizeof(uint16_t);
 634           max_bitrate = AV_RL32(ptr);
 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   data_len = stream_read_qword_le(demuxer->stream);
 655   demuxer->movi_start = stream_tell(demuxer->stream) + 26;
 656   demuxer->movi_end = start + data_len;
 657   mp_msg(MSGT_HEADER, MSGL_V, "Found movie at 0x%X - 0x%X\n",
 658           (int)demuxer->movi_start, (int)demuxer->movi_end);
 659
 660 if(streams) {
 661   // stream selection is done in the network code, it shouldn't be done here
 662   // as the servers often do not care about what we requested.
 663 #if 0
 664   uint32_t vr = 0, ar = 0,i;
 665 #ifdef CONFIG_NETWORKING
 666   if( demuxer->stream->streaming_ctrl!=NULL ) {
 667           if( demuxer->stream->streaming_ctrl->bandwidth!=0 && demuxer->stream->streaming_ctrl->data!=NULL ) {
 668                   best_audio = ((asf_http_streaming_ctrl_t*)demuxer->stream->streaming_ctrl->data)->audio_id;
 669                   best_video = ((asf_http_streaming_ctrl_t*)demuxer->stream->streaming_ctrl->data)->video_id;
 670           }
 671   } else
 672 #endif
 673   for(i = 0; i < stream_count; i++) {
 674     uint32_t id = streams[2*i];
 675     uint32_t rate = streams[2*i+1];
 676     if(demuxer->v_streams[id] && rate > vr) {
 677       vr = rate;
 678       best_video = id;
 679     } else if(demuxer->a_streams[id] && rate > ar) {
 680       ar = rate;
 681       best_audio = id;
 682     }
 683   }
 684 #endif
 685   free(streams);
 686   streams = NULL;
 687 }
 688
 689 mp_msg(MSGT_HEADER,MSGL_V,"ASF: %d audio and %d video streams found\n",audio_streams,video_streams);
 690 if(!audio_streams) demuxer->audio->id=-2;  // nosound
 691 else if(best_audio > 0 && demuxer->audio->id == -1) demuxer->audio->id=best_audio;
 692 if(!video_streams){
 693     if(!audio_streams){
 694         mp_tmsg(MSGT_HEADER,MSGL_ERR,"ASF: no audio or video headers found - broken file?\n");
 695         return 0;
 696     }
 697     demuxer->video->id=-2; // audio-only
 698 } else if (best_video > 0 && demuxer->video->id == -1) demuxer->video->id = best_video;
 699
 700 #if 0
 701 if( mp_msg_test(MSGT_HEADER,MSGL_V) ){
 702     printf("ASF duration: %d\n",(int)fileh.duration);
 703     printf("ASF start pts: %d\n",(int)fileh.start_timestamp);
 704     printf("ASF end pts: %d\n",(int)fileh.end_timestamp);
 705 }
 706 #endif
 707
 708 return 1;
 709
 710 len_err_out:
 711   mp_tmsg(MSGT_HEADER, MSGL_FATAL, "Invalid length in ASF header!\n");
 712 err_out:
 713   free(hdr);
 714   free(streams);
 715   return 0;
 716 }