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