utils.c 107 KB
Newer Older
Fabrice Bellard's avatar
Fabrice Bellard committed
1
/*
Diego Biurrun's avatar
Diego Biurrun committed
2
 * various utility functions for use within FFmpeg
Fabrice Bellard's avatar
Fabrice Bellard committed
3
 * Copyright (c) 2000, 2001, 2002 Fabrice Bellard
Fabrice Bellard's avatar
Fabrice Bellard committed
4
 *
5 6 7
 * This file is part of FFmpeg.
 *
 * FFmpeg is free software; you can redistribute it and/or
Fabrice Bellard's avatar
Fabrice Bellard committed
8 9
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
10
 * version 2.1 of the License, or (at your option) any later version.
Fabrice Bellard's avatar
Fabrice Bellard committed
11
 *
12
 * FFmpeg is distributed in the hope that it will be useful,
Fabrice Bellard's avatar
Fabrice Bellard committed
13
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Fabrice Bellard's avatar
Fabrice Bellard committed
14 15
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
Fabrice Bellard's avatar
Fabrice Bellard committed
16
 *
Fabrice Bellard's avatar
Fabrice Bellard committed
17
 * You should have received a copy of the GNU Lesser General Public
18
 * License along with FFmpeg; if not, write to the Free Software
19
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
Fabrice Bellard's avatar
Fabrice Bellard committed
20
 */
Fabrice Bellard's avatar
Fabrice Bellard committed
21
#include "avformat.h"
22
#include "internal.h"
23
#include "libavcodec/opt.h"
24
#include "metadata.h"
25
#include "libavutil/avstring.h"
26
#include "riff.h"
27 28
#include <sys/time.h>
#include <time.h>
29
#include <strings.h>
30

31 32 33
#undef NDEBUG
#include <assert.h>

34 35
/**
 * @file libavformat/utils.c
Diego Biurrun's avatar
Diego Biurrun committed
36
 * various utility functions for use within FFmpeg
37 38
 */

39 40 41 42 43
unsigned avformat_version(void)
{
    return LIBAVFORMAT_VERSION_INT;
}

44
const char *avformat_configuration(void)
45 46 47 48
{
    return FFMPEG_CONFIGURATION;
}

49
const char *avformat_license(void)
50 51 52 53 54
{
#define LICENSE_PREFIX "libavformat license: "
    return LICENSE_PREFIX FFMPEG_LICENSE + sizeof(LICENSE_PREFIX) - 1;
}

55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103
/* fraction handling */

/**
 * f = val + (num / den) + 0.5.
 *
 * 'num' is normalized so that it is such as 0 <= num < den.
 *
 * @param f fractional number
 * @param val integer value
 * @param num must be >= 0
 * @param den must be >= 1
 */
static void av_frac_init(AVFrac *f, int64_t val, int64_t num, int64_t den)
{
    num += (den >> 1);
    if (num >= den) {
        val += num / den;
        num = num % den;
    }
    f->val = val;
    f->num = num;
    f->den = den;
}

/**
 * Fractional addition to f: f = f + (incr / f->den).
 *
 * @param f fractional number
 * @param incr increment, can be positive or negative
 */
static void av_frac_add(AVFrac *f, int64_t incr)
{
    int64_t num, den;

    num = f->num + incr;
    den = f->den;
    if (num < 0) {
        f->val += num / den;
        num = num % den;
        if (num < 0) {
            num += den;
            f->val--;
        }
    } else if (num >= den) {
        f->val += num / den;
        num = num % den;
    }
    f->num = num;
}
104

Diego Biurrun's avatar
Diego Biurrun committed
105
/** head of registered input format linked list */
106
AVInputFormat *first_iformat = NULL;
Diego Biurrun's avatar
Diego Biurrun committed
107
/** head of registered output format linked list */
108
AVOutputFormat *first_oformat = NULL;
Fabrice Bellard's avatar
Fabrice Bellard committed
109

110 111 112 113 114 115 116 117 118 119 120 121
AVInputFormat  *av_iformat_next(AVInputFormat  *f)
{
    if(f) return f->next;
    else  return first_iformat;
}

AVOutputFormat *av_oformat_next(AVOutputFormat *f)
{
    if(f) return f->next;
    else  return first_oformat;
}

122
void av_register_input_format(AVInputFormat *format)
Fabrice Bellard's avatar
Fabrice Bellard committed
123
{
124 125 126 127 128 129 130 131 132 133 134
    AVInputFormat **p;
    p = &first_iformat;
    while (*p != NULL) p = &(*p)->next;
    *p = format;
    format->next = NULL;
}

void av_register_output_format(AVOutputFormat *format)
{
    AVOutputFormat **p;
    p = &first_oformat;
Fabrice Bellard's avatar
Fabrice Bellard committed
135 136 137 138 139
    while (*p != NULL) p = &(*p)->next;
    *p = format;
    format->next = NULL;
}

140
#if LIBAVFORMAT_VERSION_MAJOR < 53
141
int match_ext(const char *filename, const char *extensions)
142 143 144 145 146 147
{
    return av_match_ext(filename, extensions);
}
#endif

int av_match_ext(const char *filename, const char *extensions)
Fabrice Bellard's avatar
Fabrice Bellard committed
148 149 150 151
{
    const char *ext, *p;
    char ext1[32], *q;

Michael Niedermayer's avatar
Michael Niedermayer committed
152 153
    if(!filename)
        return 0;
154

Fabrice Bellard's avatar
Fabrice Bellard committed
155 156 157 158 159 160
    ext = strrchr(filename, '.');
    if (ext) {
        ext++;
        p = extensions;
        for(;;) {
            q = ext1;
161
            while (*p != '\0' && *p != ',' && q-ext1<sizeof(ext1)-1)
Fabrice Bellard's avatar
Fabrice Bellard committed
162 163
                *q++ = *p++;
            *q = '\0';
164
            if (!strcasecmp(ext1, ext))
Fabrice Bellard's avatar
Fabrice Bellard committed
165
                return 1;
166
            if (*p == '\0')
Fabrice Bellard's avatar
Fabrice Bellard committed
167 168 169 170 171 172 173
                break;
            p++;
        }
    }
    return 0;
}

174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191
static int match_format(const char *name, const char *names)
{
    const char *p;
    int len, namelen;

    if (!name || !names)
        return 0;

    namelen = strlen(name);
    while ((p = strchr(names, ','))) {
        len = FFMAX(p - names, namelen);
        if (!strncasecmp(name, names, len))
            return 1;
        names = p+1;
    }
    return !strcasecmp(name, names);
}

192
#if LIBAVFORMAT_VERSION_MAJOR < 53
193
AVOutputFormat *guess_format(const char *short_name, const char *filename,
194
                             const char *mime_type)
195 196 197 198 199 200 201
{
    return av_guess_format(short_name, filename, mime_type);
}
#endif

AVOutputFormat *av_guess_format(const char *short_name, const char *filename,
                                const char *mime_type)
Fabrice Bellard's avatar
Fabrice Bellard committed
202
{
203
    AVOutputFormat *fmt, *fmt_found;
Fabrice Bellard's avatar
Fabrice Bellard committed
204 205
    int score_max, score;

Fabrice Bellard's avatar
Fabrice Bellard committed
206
    /* specific test for image sequences */
207
#if CONFIG_IMAGE2_MUXER
208
    if (!short_name && filename &&
209
        av_filename_number_test(filename) &&
210
        av_guess_image2_codec(filename) != CODEC_ID_NONE) {
211
        return av_guess_format("image2", NULL, NULL);
212
    }
213
#endif
Diego Biurrun's avatar
Diego Biurrun committed
214
    /* Find the proper file type. */
Fabrice Bellard's avatar
Fabrice Bellard committed
215 216
    fmt_found = NULL;
    score_max = 0;
217
    fmt = first_oformat;
Fabrice Bellard's avatar
Fabrice Bellard committed
218 219 220 221 222 223
    while (fmt != NULL) {
        score = 0;
        if (fmt->name && short_name && !strcmp(fmt->name, short_name))
            score += 100;
        if (fmt->mime_type && mime_type && !strcmp(fmt->mime_type, mime_type))
            score += 10;
224
        if (filename && fmt->extensions &&
225
            av_match_ext(filename, fmt->extensions)) {
Fabrice Bellard's avatar
Fabrice Bellard committed
226 227 228 229 230 231 232 233 234
            score += 5;
        }
        if (score > score_max) {
            score_max = score;
            fmt_found = fmt;
        }
        fmt = fmt->next;
    }
    return fmt_found;
235
}
Fabrice Bellard's avatar
Fabrice Bellard committed
236

237
#if LIBAVFORMAT_VERSION_MAJOR < 53
238
AVOutputFormat *guess_stream_format(const char *short_name, const char *filename,
239 240
                             const char *mime_type)
{
241
    AVOutputFormat *fmt = av_guess_format(short_name, filename, mime_type);
242 243 244 245 246 247

    if (fmt) {
        AVOutputFormat *stream_fmt;
        char stream_format_name[64];

        snprintf(stream_format_name, sizeof(stream_format_name), "%s_stream", fmt->name);
248
        stream_fmt = av_guess_format(stream_format_name, NULL, NULL);
249 250 251 252 253 254 255

        if (stream_fmt)
            fmt = stream_fmt;
    }

    return fmt;
}
256
#endif
257

258
enum CodecID av_guess_codec(AVOutputFormat *fmt, const char *short_name,
259 260 261 262
                            const char *filename, const char *mime_type, enum CodecType type){
    if(type == CODEC_TYPE_VIDEO){
        enum CodecID codec_id= CODEC_ID_NONE;

263
#if CONFIG_IMAGE2_MUXER
264
        if(!strcmp(fmt->name, "image2") || !strcmp(fmt->name, "image2pipe")){
265 266
            codec_id= av_guess_image2_codec(filename);
        }
267
#endif
268 269 270 271 272 273 274 275 276
        if(codec_id == CODEC_ID_NONE)
            codec_id= fmt->video_codec;
        return codec_id;
    }else if(type == CODEC_TYPE_AUDIO)
        return fmt->audio_codec;
    else
        return CODEC_ID_NONE;
}

277 278 279 280
AVInputFormat *av_find_input_format(const char *short_name)
{
    AVInputFormat *fmt;
    for(fmt = first_iformat; fmt != NULL; fmt = fmt->next) {
281
        if (match_format(short_name, fmt->name))
282 283 284 285 286
            return fmt;
    }
    return NULL;
}

Fabrice Bellard's avatar
Fabrice Bellard committed
287 288 289
/* memory handling */


Michael Niedermayer's avatar
Michael Niedermayer committed
290 291 292 293 294 295 296 297 298 299 300 301 302
int av_get_packet(ByteIOContext *s, AVPacket *pkt, int size)
{
    int ret= av_new_packet(pkt, size);

    if(ret<0)
        return ret;

    pkt->pos= url_ftell(s);

    ret= get_buffer(s, pkt->data, size);
    if(ret<=0)
        av_free_packet(pkt);
    else
303
        av_shrink_packet(pkt, ret);
Michael Niedermayer's avatar
Michael Niedermayer committed
304 305 306 307

    return ret;
}

308

309
int av_filename_number_test(const char *filename)
310 311
{
    char buf[1024];
312
    return filename && (av_get_frame_filename(buf, sizeof(buf), filename, 1)>=0);
313 314
}

315
static AVInputFormat *av_probe_input_format2(AVProbeData *pd, int is_opened, int *score_max)
316 317
{
    AVInputFormat *fmt1, *fmt;
318
    int score;
319 320 321

    fmt = NULL;
    for(fmt1 = first_iformat; fmt1 != NULL; fmt1 = fmt1->next) {
322
        if (!is_opened == !(fmt1->flags & AVFMT_NOFILE))
323 324
            continue;
        score = 0;
325 326 327
        if (fmt1->read_probe) {
            score = fmt1->read_probe(pd);
        } else if (fmt1->extensions) {
328
            if (av_match_ext(pd->filename, fmt1->extensions)) {
329 330
                score = 50;
            }
331
        }
332 333
        if (score > *score_max) {
            *score_max = score;
334
            fmt = fmt1;
335 336
        }else if (score == *score_max)
            fmt = NULL;
337 338 339 340
    }
    return fmt;
}

341 342 343 344 345
AVInputFormat *av_probe_input_format(AVProbeData *pd, int is_opened){
    int score=0;
    return av_probe_input_format2(pd, is_opened, &score);
}

346
static int set_codec_from_probe_data(AVFormatContext *s, AVStream *st, AVProbeData *pd, int score)
347 348 349 350 351
{
    AVInputFormat *fmt;
    fmt = av_probe_input_format2(pd, 1, &score);

    if (fmt) {
352 353
        av_log(s, AV_LOG_DEBUG, "Probe with size=%d, packets=%d detected %s with score=%d\n",
               pd->buf_size, MAX_PROBE_PACKETS - st->probe_packets, fmt->name, score);
354
        if (!strcmp(fmt->name, "mp3")) {
355
            st->codec->codec_id = CODEC_ID_MP3;
356 357
            st->codec->codec_type = CODEC_TYPE_AUDIO;
        } else if (!strcmp(fmt->name, "ac3")) {
358
            st->codec->codec_id = CODEC_ID_AC3;
359
            st->codec->codec_type = CODEC_TYPE_AUDIO;
360 361 362
        } else if (!strcmp(fmt->name, "eac3")) {
            st->codec->codec_id = CODEC_ID_EAC3;
            st->codec->codec_type = CODEC_TYPE_AUDIO;
363
        } else if (!strcmp(fmt->name, "mpegvideo")) {
364
            st->codec->codec_id = CODEC_ID_MPEG2VIDEO;
365
            st->codec->codec_type = CODEC_TYPE_VIDEO;
366 367 368
        } else if (!strcmp(fmt->name, "m4v")) {
            st->codec->codec_id = CODEC_ID_MPEG4;
            st->codec->codec_type = CODEC_TYPE_VIDEO;
369
        } else if (!strcmp(fmt->name, "h264")) {
370
            st->codec->codec_id = CODEC_ID_H264;
371
            st->codec->codec_type = CODEC_TYPE_VIDEO;
Baptiste Coudurier's avatar
Baptiste Coudurier committed
372 373 374
        } else if (!strcmp(fmt->name, "dts")) {
            st->codec->codec_id = CODEC_ID_DTS;
            st->codec->codec_type = CODEC_TYPE_AUDIO;
375
        }
376 377 378 379
    }
    return !!fmt;
}

380 381
/************************************************************/
/* input media file */
382

383
/**
384
 * Open a media file from an IO stream. 'fmt' must be specified.
385
 */
386 387
int av_open_input_stream(AVFormatContext **ic_ptr,
                         ByteIOContext *pb, const char *filename,
388 389 390 391
                         AVInputFormat *fmt, AVFormatParameters *ap)
{
    int err;
    AVFormatContext *ic;
392 393 394 395 396 397
    AVFormatParameters default_ap;

    if(!ap){
        ap=&default_ap;
        memset(ap, 0, sizeof(default_ap));
    }
398

399
    if(!ap->prealloced_context)
400
        ic = avformat_alloc_context();
401 402
    else
        ic = *ic_ptr;
403
    if (!ic) {
404
        err = AVERROR(ENOMEM);
405 406 407
        goto fail;
    }
    ic->iformat = fmt;
408
    ic->pb = pb;
409 410
    ic->duration = AV_NOPTS_VALUE;
    ic->start_time = AV_NOPTS_VALUE;
Måns Rullgård's avatar
Måns Rullgård committed
411
    av_strlcpy(ic->filename, filename, sizeof(ic->filename));
412 413 414 415 416

    /* allocate private data */
    if (fmt->priv_data_size > 0) {
        ic->priv_data = av_mallocz(fmt->priv_data_size);
        if (!ic->priv_data) {
417
            err = AVERROR(ENOMEM);
418 419 420 421 422 423
            goto fail;
        }
    } else {
        ic->priv_data = NULL;
    }

424
    if (ic->iformat->read_header) {
425 426 427
        err = ic->iformat->read_header(ic, ap);
        if (err < 0)
            goto fail;
428
    }
429

430
    if (pb && !ic->data_offset)
431
        ic->data_offset = url_ftell(ic->pb);
432

433 434 435 436
#if LIBAVFORMAT_VERSION_MAJOR < 53
    ff_metadata_demux_compat(ic);
#endif

437 438
    ic->raw_packet_buffer_remaining_size = RAW_PACKET_BUFFER_SIZE;

439 440 441 442
    *ic_ptr = ic;
    return 0;
 fail:
    if (ic) {
443
        int i;
444
        av_freep(&ic->priv_data);
445 446 447 448 449 450 451 452
        for(i=0;i<ic->nb_streams;i++) {
            AVStream *st = ic->streams[i];
            if (st) {
                av_free(st->priv_data);
                av_free(st->codec->extradata);
            }
            av_free(st);
        }
453 454 455 456 457 458
    }
    av_free(ic);
    *ic_ptr = NULL;
    return err;
}

Diego Biurrun's avatar
Diego Biurrun committed
459
/** size of probe buffer, for guessing file type from file contents */
460
#define PROBE_BUF_MIN 2048
461
#define PROBE_BUF_MAX (1<<20)
462

463
int av_open_input_file(AVFormatContext **ic_ptr, const char *filename,
464 465 466
                       AVInputFormat *fmt,
                       int buf_size,
                       AVFormatParameters *ap)
Fabrice Bellard's avatar
Fabrice Bellard committed
467
{
468
    int err, probe_size;
469
    AVProbeData probe_data, *pd = &probe_data;
470
    ByteIOContext *pb = NULL;
471
    void *logctx= ap && ap->prealloced_context ? *ic_ptr : NULL;
472

473 474 475
    pd->filename = "";
    if (filename)
        pd->filename = filename;
476
    pd->buf = NULL;
477 478 479
    pd->buf_size = 0;

    if (!fmt) {
Diego Biurrun's avatar
Diego Biurrun committed
480
        /* guess format if no file can be opened */
481
        fmt = av_probe_input_format(pd, 0);
Fabrice Bellard's avatar
Fabrice Bellard committed
482 483
    }

Diego Biurrun's avatar
Diego Biurrun committed
484
    /* Do not open file if the format does not need it. XXX: specific
Fabrice Bellard's avatar
Fabrice Bellard committed
485
       hack needed to handle RTSP/TCP */
486
    if (!fmt || !(fmt->flags & AVFMT_NOFILE)) {
Fabrice Bellard's avatar
Fabrice Bellard committed
487
        /* if no file needed do not try to open one */
488
        if ((err=url_fopen(&pb, filename, URL_RDONLY)) < 0) {
489
            goto fail;
490
        }
491
        if (buf_size > 0) {
492
            url_setbufsize(pb, buf_size);
493
        }
494 495

        for(probe_size= PROBE_BUF_MIN; probe_size<=PROBE_BUF_MAX && !fmt; probe_size<<=1){
496
            int score= probe_size < PROBE_BUF_MAX ? AVPROBE_SCORE_MAX/4 : 0;
497
            /* read probe data */
498
            pd->buf= av_realloc(pd->buf, probe_size + AVPROBE_PADDING_SIZE);
499
            pd->buf_size = get_buffer(pb, pd->buf, probe_size);
500 501 502 503 504 505

            if ((int)pd->buf_size < 0) {
                err = pd->buf_size;
                goto fail;
            }

506
            memset(pd->buf+pd->buf_size, 0, AVPROBE_PADDING_SIZE);
507
            if (url_fseek(pb, 0, SEEK_SET) < 0) {
508
                url_fclose(pb);
509
                if (url_fopen(&pb, filename, URL_RDONLY) < 0) {
510
                    pb = NULL;
511
                    err = AVERROR(EIO);
512 513 514
                    goto fail;
                }
            }
515
            /* guess file format */
516
            fmt = av_probe_input_format2(pd, 1, &score);
517 518
            if(fmt){
                if(score <= AVPROBE_SCORE_MAX/4){ //this can only be true in the last iteration
519
                    av_log(logctx, AV_LOG_WARNING, "Format detected only with low score of %d, misdetection possible!\n", score);
520
                }else
521
                    av_log(logctx, AV_LOG_DEBUG, "Probed with size=%d and score=%d\n", probe_size, score);
522
            }
523
        }
524
        av_freep(&pd->buf);
525 526 527 528 529
    }

    /* if still no format found, error */
    if (!fmt) {
        err = AVERROR_NOFMT;
530
        goto fail;
Fabrice Bellard's avatar
Fabrice Bellard committed
531
    }
532

Diego Biurrun's avatar
Diego Biurrun committed
533
    /* check filename in case an image number is expected */
534
    if (fmt->flags & AVFMT_NEEDNUMBER) {
535
        if (!av_filename_number_test(filename)) {
Fabrice Bellard's avatar
Fabrice Bellard committed
536
            err = AVERROR_NUMEXPECTED;
537
            goto fail;
Fabrice Bellard's avatar
Fabrice Bellard committed
538 539
        }
    }
540 541 542
    err = av_open_input_stream(ic_ptr, pb, filename, fmt, ap);
    if (err)
        goto fail;
543
    return 0;
Fabrice Bellard's avatar
Fabrice Bellard committed
544
 fail:
545
    av_freep(&pd->buf);
546
    if (pb)
547
        url_fclose(pb);
548 549 550
    if (ap && ap->prealloced_context)
        av_free(*ic_ptr);
    *ic_ptr = NULL;
551
    return err;
552

Fabrice Bellard's avatar
Fabrice Bellard committed
553 554
}

555 556
/*******************************************************/

557 558 559
static AVPacket *add_to_pktbuf(AVPacketList **packet_buffer, AVPacket *pkt,
                               AVPacketList **plast_pktl){
    AVPacketList *pktl = av_mallocz(sizeof(AVPacketList));
560 561 562
    if (!pktl)
        return NULL;

563 564 565 566 567
    if (*packet_buffer)
        (*plast_pktl)->next = pktl;
    else
        *packet_buffer = pktl;

568 569 570 571 572 573
    /* add the packet in the buffered packet list */
    *plast_pktl = pktl;
    pktl->pkt= *pkt;
    return &pktl->pkt;
}

Fabrice Bellard's avatar
Fabrice Bellard committed
574
int av_read_packet(AVFormatContext *s, AVPacket *pkt)
575
{
576
    int ret, i;
577
    AVStream *st;
578 579 580 581 582 583

    for(;;){
        AVPacketList *pktl = s->raw_packet_buffer;

        if (pktl) {
            *pkt = pktl->pkt;
584
            if(s->streams[pkt->stream_index]->codec->codec_id != CODEC_ID_PROBE ||
585 586 587 588 589
               !s->streams[pkt->stream_index]->probe_packets ||
               s->raw_packet_buffer_remaining_size < pkt->size){
                AVProbeData *pd = &s->streams[pkt->stream_index]->probe_data;
                av_freep(&pd->buf);
                pd->buf_size = 0;
590
                s->raw_packet_buffer = pktl->next;
591
                s->raw_packet_buffer_remaining_size += pkt->size;
592 593 594 595 596
                av_free(pktl);
                return 0;
            }
        }

Michael Niedermayer's avatar
indent  
Michael Niedermayer committed
597 598
        av_init_packet(pkt);
        ret= s->iformat->read_packet(s, pkt);
599 600 601 602 603 604 605
        if (ret < 0) {
            if (!pktl || ret == AVERROR(EAGAIN))
                return ret;
            for (i = 0; i < s->nb_streams; i++)
                s->streams[i]->probe_packets = 0;
            continue;
        }
Michael Niedermayer's avatar
indent  
Michael Niedermayer committed
606
        st= s->streams[pkt->stream_index];
607

Michael Niedermayer's avatar
indent  
Michael Niedermayer committed
608 609 610 611 612 613 614 615 616 617 618
        switch(st->codec->codec_type){
        case CODEC_TYPE_VIDEO:
            if(s->video_codec_id)   st->codec->codec_id= s->video_codec_id;
            break;
        case CODEC_TYPE_AUDIO:
            if(s->audio_codec_id)   st->codec->codec_id= s->audio_codec_id;
            break;
        case CODEC_TYPE_SUBTITLE:
            if(s->subtitle_codec_id)st->codec->codec_id= s->subtitle_codec_id;
            break;
        }
619

620 621
        if(!pktl && (st->codec->codec_id != CODEC_ID_PROBE ||
                     !st->probe_packets))
622 623
            return ret;

624
        add_to_pktbuf(&s->raw_packet_buffer, pkt, &s->raw_packet_buffer_end);
625
        s->raw_packet_buffer_remaining_size -= pkt->size;
626

627 628
        if(st->codec->codec_id == CODEC_ID_PROBE){
            AVProbeData *pd = &st->probe_data;
629
            av_log(s, AV_LOG_DEBUG, "probing stream %d\n", st->index);
630 631
            --st->probe_packets;

632 633 634 635 636
            pd->buf = av_realloc(pd->buf, pd->buf_size+pkt->size+AVPROBE_PADDING_SIZE);
            memcpy(pd->buf+pd->buf_size, pkt->data, pkt->size);
            pd->buf_size += pkt->size;
            memset(pd->buf+pd->buf_size, 0, AVPROBE_PADDING_SIZE);

637
            if(av_log2(pd->buf_size) != av_log2(pd->buf_size - pkt->size)){
638
                set_codec_from_probe_data(s, st, pd, 1);
Michael Niedermayer's avatar
indent  
Michael Niedermayer committed
639 640 641
                if(st->codec->codec_id != CODEC_ID_PROBE){
                    pd->buf_size=0;
                    av_freep(&pd->buf);
642
                    av_log(s, AV_LOG_DEBUG, "probed stream %d\n", st->index);
Michael Niedermayer's avatar
indent  
Michael Niedermayer committed
643
                }
644
            }
645 646
        }
    }
647 648 649 650
}

/**********************************************************/

651
/**
Diego Biurrun's avatar
Diego Biurrun committed
652
 * Get the number of samples of an audio frame. Return -1 on error.
653
 */
654 655 656 657
static int get_audio_frame_size(AVCodecContext *enc, int size)
{
    int frame_size;

658 659 660
    if(enc->codec_id == CODEC_ID_VORBIS)
        return -1;

661
    if (enc->frame_size <= 1) {
662 663 664
        int bits_per_sample = av_get_bits_per_sample(enc->codec_id);

        if (bits_per_sample) {
665 666
            if (enc->channels == 0)
                return -1;
667
            frame_size = (size << 3) / (bits_per_sample * enc->channels);
668
        } else {
669 670 671
            /* used for example by ADPCM codecs */
            if (enc->bit_rate == 0)
                return -1;
672
            frame_size = ((int64_t)size * 8 * enc->sample_rate) / enc->bit_rate;
673 674 675 676 677 678 679 680
        }
    } else {
        frame_size = enc->frame_size;
    }
    return frame_size;
}


681
/**
Diego Biurrun's avatar
Diego Biurrun committed
682
 * Return the frame duration in seconds. Return 0 if not available.
683
 */
684
static void compute_frame_duration(int *pnum, int *pden, AVStream *st,
685 686 687 688 689 690
                                   AVCodecParserContext *pc, AVPacket *pkt)
{
    int frame_size;

    *pnum = 0;
    *pden = 0;
691
    switch(st->codec->codec_type) {
692
    case CODEC_TYPE_VIDEO:
Michael Niedermayer's avatar
Michael Niedermayer committed
693
        if(st->time_base.num*1000LL > st->time_base.den){
694 695
            *pnum = st->time_base.num;
            *pden = st->time_base.den;
696 697 698
        }else if(st->codec->time_base.num*1000LL > st->codec->time_base.den){
            *pnum = st->codec->time_base.num;
            *pden = st->codec->time_base.den;
699
            if (pc && pc->repeat_pict) {
700
                *pnum = (*pnum) * (1 + pc->repeat_pict);
701
            }
702 703 704
        }
        break;
    case CODEC_TYPE_AUDIO:
705
        frame_size = get_audio_frame_size(st->codec, pkt->size);
706 707 708
        if (frame_size < 0)
            break;
        *pnum = frame_size;
709
        *pden = st->codec->sample_rate;
710 711 712 713 714 715
        break;
    default:
        break;
    }
}

716 717 718 719 720 721 722 723 724 725 726
static int is_intra_only(AVCodecContext *enc){
    if(enc->codec_type == CODEC_TYPE_AUDIO){
        return 1;
    }else if(enc->codec_type == CODEC_TYPE_VIDEO){
        switch(enc->codec_id){
        case CODEC_ID_MJPEG:
        case CODEC_ID_MJPEGB:
        case CODEC_ID_LJPEG:
        case CODEC_ID_RAWVIDEO:
        case CODEC_ID_DVVIDEO:
        case CODEC_ID_HUFFYUV:
Loren Merritt's avatar
Loren Merritt committed
727
        case CODEC_ID_FFVHUFF:
728 729 730
        case CODEC_ID_ASV1:
        case CODEC_ID_ASV2:
        case CODEC_ID_VCR1:
Baptiste Coudurier's avatar
Baptiste Coudurier committed
731
        case CODEC_ID_DNXHD:
732
        case CODEC_ID_JPEG2000:
733 734 735 736 737 738 739
            return 1;
        default: break;
        }
    }
    return 0;
}

740 741 742
static void update_initial_timestamps(AVFormatContext *s, int stream_index,
                                      int64_t dts, int64_t pts)
{
743 744 745
    AVStream *st= s->streams[stream_index];
    AVPacketList *pktl= s->packet_buffer;

746
    if(st->first_dts != AV_NOPTS_VALUE || dts == AV_NOPTS_VALUE || st->cur_dts == AV_NOPTS_VALUE)
747 748 749 750 751 752 753 754 755 756 757 758 759 760
        return;

    st->first_dts= dts - st->cur_dts;
    st->cur_dts= dts;

    for(; pktl; pktl= pktl->next){
        if(pktl->pkt.stream_index != stream_index)
            continue;
        //FIXME think more about this check
        if(pktl->pkt.pts != AV_NOPTS_VALUE && pktl->pkt.pts == pktl->pkt.dts)
            pktl->pkt.pts += st->first_dts;

        if(pktl->pkt.dts != AV_NOPTS_VALUE)
            pktl->pkt.dts += st->first_dts;
761 762 763

        if(st->start_time == AV_NOPTS_VALUE && pktl->pkt.pts != AV_NOPTS_VALUE)
            st->start_time= pktl->pkt.pts;
764
    }
765 766
    if (st->start_time == AV_NOPTS_VALUE)
        st->start_time = pts;
767 768
}

769 770 771
static void update_initial_durations(AVFormatContext *s, AVStream *st, AVPacket *pkt)
{
    AVPacketList *pktl= s->packet_buffer;
772 773 774 775 776 777 778 779 780 781 782 783 784 785 786
    int64_t cur_dts= 0;

    if(st->first_dts != AV_NOPTS_VALUE){
        cur_dts= st->first_dts;
        for(; pktl; pktl= pktl->next){
            if(pktl->pkt.stream_index == pkt->stream_index){
                if(pktl->pkt.pts != pktl->pkt.dts || pktl->pkt.dts != AV_NOPTS_VALUE || pktl->pkt.duration)
                    break;
                cur_dts -= pkt->duration;
            }
        }
        pktl= s->packet_buffer;
        st->first_dts = cur_dts;
    }else if(st->cur_dts)
        return;
787 788 789 790

    for(; pktl; pktl= pktl->next){
        if(pktl->pkt.stream_index != pkt->stream_index)
            continue;
791 792
        if(pktl->pkt.pts == pktl->pkt.dts && pktl->pkt.dts == AV_NOPTS_VALUE
           && !pktl->pkt.duration){
793
            pktl->pkt.dts= cur_dts;
794
            if(!st->codec->has_b_frames)
795 796
                pktl->pkt.pts= cur_dts;
            cur_dts += pkt->duration;
797 798 799 800
            pktl->pkt.duration= pkt->duration;
        }else
            break;
    }
801 802
    if(st->first_dts == AV_NOPTS_VALUE)
        st->cur_dts= cur_dts;
803 804
}

805
static void compute_pkt_fields(AVFormatContext *s, AVStream *st,
806 807
                               AVCodecParserContext *pc, AVPacket *pkt)
{
808
    int num, den, presentation_delayed, delay, i;
809
    int64_t offset;
810

811 812 813
    if((s->flags & AVFMT_FLAG_IGNDTS) && pkt->pts != AV_NOPTS_VALUE)
        pkt->dts= AV_NOPTS_VALUE;

814
    if (st->codec->codec_id != CODEC_ID_H264 && pc && pc->pict_type == FF_B_TYPE)
815
        //FIXME Set low_delay = 0 when has_b_frames = 1
816 817
        st->codec->has_b_frames = 1;

818 819 820 821 822 823 824 825 826
    /* do we have a video B-frame ? */
    delay= st->codec->has_b_frames;
    presentation_delayed = 0;
    /* XXX: need has_b_frame, but cannot get it if the codec is
        not initialized */
    if (delay &&
        pc && pc->pict_type != FF_B_TYPE)
        presentation_delayed = 1;

827 828 829 830 831
    if(pkt->pts != AV_NOPTS_VALUE && pkt->dts != AV_NOPTS_VALUE && pkt->dts > pkt->pts && st->pts_wrap_bits<63
       /*&& pkt->dts-(1LL<<st->pts_wrap_bits) < pkt->pts*/){
        pkt->dts -= 1LL<<st->pts_wrap_bits;
    }

832 833 834 835
    // some mpeg2 in mpeg-ps lack dts (issue171 / input_file.mpg)
    // we take the conservative approach and discard both
    // Note, if this is misbehaving for a H.264 file then possibly presentation_delayed is not set correctly.
    if(delay==1 && pkt->dts == pkt->pts && pkt->dts != AV_NOPTS_VALUE && presentation_delayed){
836
        av_log(s, AV_LOG_WARNING, "invalid dts/pts combination\n");
837 838 839
        pkt->dts= pkt->pts= AV_NOPTS_VALUE;
    }

840
    if (pkt->duration == 0) {
841
        compute_frame_duration(&num, &den, st, pc, pkt);
842
        if (den && num) {
843
            pkt->duration = av_rescale(1, num * (int64_t)st->time_base.den, den * (int64_t)st->time_base.num);
844

845
            if(pkt->duration != 0 && s->packet_buffer)