Skip to content
Snippets Groups Projects
utils.c 37.1 KiB
Newer Older
  • Learn to ignore specific revisions
  • Fabrice Bellard's avatar
    Fabrice Bellard committed
    /*
     * Various utilities for ffmpeg system
    
     * Copyright (c) 2000, 2001, 2002 Fabrice Bellard
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     *
    
     * This library is free software; you can redistribute it and/or
     * modify it under the terms of the GNU Lesser General Public
     * License as published by the Free Software Foundation; either
     * version 2 of the License, or (at your option) any later version.
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     *
    
     * This library is distributed in the hope that it will be useful,
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     * but WITHOUT ANY WARRANTY; without even the implied warranty of
    
     * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     * Lesser General Public License for more details.
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     *
    
     * You should have received a copy of the GNU Lesser General Public
     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     */
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #include "avformat.h"
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #define strcasecmp _stricmp
    #include <sys/types.h>
    #include <sys/timeb.h>
    
    #elif defined(CONFIG_OS2)
    #include <string.h>
    #define strcasecmp stricmp
    #include <sys/time.h>
    #else
    #include <unistd.h>
    #include <fcntl.h>
    #include <sys/time.h>
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #endif
    
    #include <time.h>
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    
    
    #ifndef HAVE_STRPTIME
    #include "strptime.h"
    #endif
    
    
    AVInputFormat *first_iformat;
    AVOutputFormat *first_oformat;
    
    AVImageFormat *first_image_format;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    
    
    void av_register_input_format(AVInputFormat *format)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
    
        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
        while (*p != NULL) p = &(*p)->next;
        *p = format;
        format->next = NULL;
    }
    
    
    int match_ext(const char *filename, const char *extensions)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
        const char *ext, *p;
        char ext1[32], *q;
    
        ext = strrchr(filename, '.');
        if (ext) {
            ext++;
            p = extensions;
            for(;;) {
                q = ext1;
                while (*p != '\0' && *p != ',') 
                    *q++ = *p++;
                *q = '\0';
                if (!strcasecmp(ext1, ext)) 
                    return 1;
                if (*p == '\0') 
                    break;
                p++;
            }
        }
        return 0;
    }
    
    
    AVOutputFormat *guess_format(const char *short_name, const char *filename, 
                                 const char *mime_type)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        int score_max, score;
    
    
        /* specific test for image sequences */
    
        if (!short_name && filename && 
            filename_number_test(filename) >= 0 &&
            guess_image_format(filename)) {
    
            return guess_format("image", NULL, NULL);
        }
    
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        /* find the proper file type */
        fmt_found = NULL;
        score_max = 0;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        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;
            if (filename && fmt->extensions && 
                match_ext(filename, fmt->extensions)) {
                score += 5;
            }
            if (score > score_max) {
                score_max = score;
                fmt_found = fmt;
            }
            fmt = fmt->next;
        }
        return fmt_found;
    }   
    
    
    AVOutputFormat *guess_stream_format(const char *short_name, const char *filename, 
                                 const char *mime_type)
    {
        AVOutputFormat *fmt = guess_format(short_name, filename, mime_type);
    
        if (fmt) {
            AVOutputFormat *stream_fmt;
            char stream_format_name[64];
    
            snprintf(stream_format_name, sizeof(stream_format_name), "%s_stream", fmt->name);
            stream_fmt = guess_format(stream_format_name, NULL, NULL);
    
            if (stream_fmt)
                fmt = stream_fmt;
        }
    
        return fmt;
    }
    
    
    AVInputFormat *av_find_input_format(const char *short_name)
    {
        AVInputFormat *fmt;
        for(fmt = first_iformat; fmt != NULL; fmt = fmt->next) {
            if (!strcmp(fmt->name, short_name))
                return fmt;
        }
        return NULL;
    }
    
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    /* memory handling */
    
    
    /**
     * Default packet destructor 
     */
    static void av_destruct_packet(AVPacket *pkt)
    {
        av_free(pkt->data);
        pkt->data = NULL; pkt->size = 0;
    }
    
    
    /**
     * Allocate the payload of a packet and intialized its fields to default values.
     *
     * @param pkt packet
     * @param size wanted payload size
     * @return 0 if OK. AVERROR_xxx otherwise.
     */
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    int av_new_packet(AVPacket *pkt, int size)
    {
    
        void *data = av_malloc(size + FF_INPUT_BUFFER_PADDING_SIZE);
        if (!data)
    
        memset(data + size, 0, FF_INPUT_BUFFER_PADDING_SIZE);
    
        av_init_packet(pkt);
        pkt->data = data; 
        pkt->size = size;
        pkt->destruct = av_destruct_packet;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        return 0;
    }
    
    /* fifo handling */
    
    int fifo_init(FifoBuffer *f, int size)
    {
    
        f->buffer = av_malloc(size);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        if (!f->buffer)
            return -1;
        f->end = f->buffer + size;
        f->wptr = f->rptr = f->buffer;
        return 0;
    }
    
    void fifo_free(FifoBuffer *f)
    {
    
        av_free(f->buffer);
    
    int fifo_size(FifoBuffer *f, uint8_t *rptr)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
        int size;
    
        if (f->wptr >= rptr) {
            size = f->wptr - rptr;
        } else {
            size = (f->end - rptr) + (f->wptr - f->buffer);
        }
        return size;
    }
    
    /* get data from the fifo (return -1 if not enough data) */
    
    int fifo_read(FifoBuffer *f, uint8_t *buf, int buf_size, uint8_t **rptr_ptr)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
    
        uint8_t *rptr = *rptr_ptr;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        int size, len;
    
        if (f->wptr >= rptr) {
            size = f->wptr - rptr;
        } else {
            size = (f->end - rptr) + (f->wptr - f->buffer);
        }
        
        if (size < buf_size)
            return -1;
        while (buf_size > 0) {
            len = f->end - rptr;
            if (len > buf_size)
                len = buf_size;
            memcpy(buf, rptr, len);
            buf += len;
            rptr += len;
            if (rptr >= f->end)
                rptr = f->buffer;
            buf_size -= len;
        }
        *rptr_ptr = rptr;
        return 0;
    }
    
    
    void fifo_write(FifoBuffer *f, uint8_t *buf, int size, uint8_t **wptr_ptr)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
        int len;
    
        uint8_t *wptr;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        wptr = *wptr_ptr;
        while (size > 0) {
            len = f->end - wptr;
            if (len > size)
                len = size;
            memcpy(wptr, buf, len);
            wptr += len;
            if (wptr >= f->end)
                wptr = f->buffer;
            buf += len;
            size -= len;
        }
        *wptr_ptr = wptr;
    }
    
    
    int filename_number_test(const char *filename)
    {
        char buf[1024];
        return get_frame_filename(buf, sizeof(buf), filename, 1);
    }
    
    /* guess file format */
    
    AVInputFormat *av_probe_input_format(AVProbeData *pd, int is_opened)
    
    {
        AVInputFormat *fmt1, *fmt;
        int score, score_max;
    
        fmt = NULL;
        score_max = 0;
        for(fmt1 = first_iformat; fmt1 != NULL; fmt1 = fmt1->next) {
            if (!is_opened && !(fmt1->flags & AVFMT_NOFILE))
                continue;
            score = 0;
    
            if (fmt1->read_probe) {
                score = fmt1->read_probe(pd);
            } else if (fmt1->extensions) {
    
                if (match_ext(pd->filename, fmt1->extensions)) {
                    score = 50;
                }
    
            if (score > score_max) {
                score_max = score;
                fmt = fmt1;
            }
        }
        return fmt;
    }
    
    /************************************************************/
    /* input media file */
    
    #define PROBE_BUF_SIZE 2048
    
    /**
     * Open a media file as input. The codec are not opened. Only the file
     * header (if present) is read.
     *
     * @param ic_ptr the opened media file handle is put here
     * @param filename filename to open.
     * @param fmt if non NULL, force the file format to use
     * @param buf_size optional buffer size (zero if default is OK)
     * @param ap additionnal parameters needed when opening the file (NULL if default)
     * @return 0 if OK. AVERROR_xxx otherwise.
     */
    int av_open_input_file(AVFormatContext **ic_ptr, const char *filename, 
                           AVInputFormat *fmt,
                           int buf_size,
                           AVFormatParameters *ap)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
        AVFormatContext *ic = NULL;
        int err;
    
        char buf[PROBE_BUF_SIZE];
        AVProbeData probe_data, *pd = &probe_data;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    
        ic = av_mallocz(sizeof(AVFormatContext));
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
            goto fail;
        }
    
        pstrcpy(ic->filename, sizeof(ic->filename), filename);
        pd->filename = ic->filename;
        pd->buf = buf;
        pd->buf_size = 0;
    
        if (!fmt) {
            /* guess format if no file can be opened  */
    
            fmt = av_probe_input_format(pd, 0);
    
            /* if no file needed do not try to open one */
    
            if (url_fopen(&ic->pb, filename, URL_RDONLY) < 0) {
                err = AVERROR_IO;
    
            if (buf_size > 0) {
                url_setbufsize(&ic->pb, buf_size);
            }
    
            if (!fmt) {
                /* read probe data */
                pd->buf_size = get_buffer(&ic->pb, buf, PROBE_BUF_SIZE);
                url_fseek(&ic->pb, 0, SEEK_SET);
            }
    
            fmt = av_probe_input_format(pd, 1);
    
        }
    
        /* if still no format found, error */
        if (!fmt) {
            err = AVERROR_NOFMT;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        }
    
        /* XXX: suppress this hack for redirectors */
    
        if (fmt == &redir_demux) {
            err = redir_open(ic_ptr, &ic->pb);
            url_fclose(&ic->pb);
            av_free(ic);
            return err;
        }
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    
    
        /* check filename in case of an image number is expected */
        if (ic->iformat->flags & AVFMT_NEEDNUMBER) {
            if (filename_number_test(ic->filename) < 0) { 
                err = AVERROR_NUMEXPECTED;
                goto fail1;
            }
        }
        
    
        if (fmt->priv_data_size > 0) {
            ic->priv_data = av_mallocz(fmt->priv_data_size);
            if (!ic->priv_data) {
                err = AVERROR_NOMEM;
    
            }
        } else
            ic->priv_data = NULL;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        /* default pts settings is MPEG like */
        av_set_pts_info(ic, 33, 1, 90000);
    
    
        err = ic->iformat->read_header(ic, ap);
        if (err < 0)
            goto fail1;
        *ic_ptr = ic;
        return 0;
     fail1:
    
        if (!fmt || !(fmt->flags & AVFMT_NOFILE)) {
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     fail:
    
        av_free(ic);
    
    /**
     * Read a packet from a media file
     * @param s media file handle
     * @param pkt is filled 
     * @return 0 if OK. AVERROR_xxx if error.
     */
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    int av_read_packet(AVFormatContext *s, AVPacket *pkt)
    {
        AVPacketList *pktl;
    
        pktl = s->packet_buffer;
        if (pktl) {
            /* read packet from packet buffer, if there is data */
            *pkt = pktl->pkt;
            s->packet_buffer = pktl->next;
    
            av_free(pktl);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
            return 0;
        } else {
    
            return s->iformat->read_packet(s, pkt);
        }
    }
    
    /* state for codec information */
    #define CSTATE_NOTFOUND    0
    #define CSTATE_DECODING    1
    #define CSTATE_FOUND       2
    
    static int has_codec_parameters(AVCodecContext *enc)
    {
        int val;
        switch(enc->codec_type) {
        case CODEC_TYPE_AUDIO:
            val = enc->sample_rate;
            break;
        case CODEC_TYPE_VIDEO:
            val = enc->width;
            break;
        default:
            val = 1;
            break;
        }
        return (val != 0);
    }
    
    /**
     * Read the beginning of a media file to get stream information. This
     * is useful for file formats with no headers such as MPEG. This
     * function also compute the real frame rate in case of mpeg2 repeat
     * frame mode.
     *
     * @param ic media file handle
     * @return >=0 if OK. AVERROR_xxx if error.  
     */
    int av_find_stream_info(AVFormatContext *ic)
    {
        int i, count, ret, got_picture, size, read_size;
        AVCodec *codec;
        AVStream *st;
        AVPacket *pkt;
    
        AVFrame picture;
    
        AVPacketList *pktl=NULL, **ppktl;
        short samples[AVCODEC_MAX_AUDIO_FRAME_SIZE / 2];
    
        uint8_t *ptr;
    
        int min_read_size, max_read_size;
    
        /* typical mpeg ts rate is 40 Mbits. DVD rate is about 10
    
           Mbits. We read at most 0.2 second of file to find all streams */
    
    
        /* XXX: base it on stream bitrate when possible */
        if (ic->iformat == &mpegts_demux) {
            /* maximum number of bytes we accept to read to find all the streams
               in a file */
    
    
        /* set initial codec state */
        for(i=0;i<ic->nb_streams;i++) {
            st = ic->streams[i];
            if (has_codec_parameters(&st->codec))
                st->codec_info_state = CSTATE_FOUND;
            else
                st->codec_info_state = CSTATE_NOTFOUND;
            st->codec_info_nb_repeat_frames = 0;
            st->codec_info_nb_real_frames = 0;
        }
    
        count = 0;
        read_size = 0;
        ppktl = &ic->packet_buffer;
        for(;;) {
            /* check if one codec still needs to be handled */
            for(i=0;i<ic->nb_streams;i++) {
                st = ic->streams[i];
                if (st->codec_info_state != CSTATE_FOUND)
                    break;
            }
            if (i == ic->nb_streams) {
                /* NOTE: if the format has no header, then we need to read
                   some packets to get most of the streams, so we cannot
                   stop here */
                if (!(ic->iformat->flags & AVFMT_NOHEADER) ||
                    read_size >= min_read_size) {
                    /* if we found the info for all the codecs, we can stop */
                    ret = count;
                    break;
                }
            } else {
                /* we did not get all the codec info, but we read too much data */
                if (read_size >= max_read_size) {
                    ret = count;
                    break;
                }
            }
    
            pktl = av_mallocz(sizeof(AVPacketList));
            if (!pktl) {
                ret = AVERROR_NOMEM;
                break;
            }
    
            /* add the packet in the buffered packet list */
            *ppktl = pktl;
            ppktl = &pktl->next;
    
            /* NOTE: a new stream can be added there if no header in file
               (AVFMT_NOHEADER) */
            pkt = &pktl->pkt;
            if (ic->iformat->read_packet(ic, pkt) < 0) {
                /* EOF or error */
                ret = -1; /* we could not have all the codec parameters before EOF */
                if ((ic->iformat->flags & AVFMT_NOHEADER) &&
                    i == ic->nb_streams)
                    ret = 0;
                break;
            }
            read_size += pkt->size;
    
            /* open new codecs */
            for(i=0;i<ic->nb_streams;i++) {
                st = ic->streams[i];
                if (st->codec_info_state == CSTATE_NOTFOUND) {
                    /* set to found in case of error */
                    st->codec_info_state = CSTATE_FOUND; 
                    codec = avcodec_find_decoder(st->codec.codec_id);
                    if (codec) {
    
                        if(codec->capabilities & CODEC_CAP_TRUNCATED)
                            st->codec.flags |= CODEC_FLAG_TRUNCATED;
    
    
                        ret = avcodec_open(&st->codec, codec);
                        if (ret >= 0)
                            st->codec_info_state = CSTATE_DECODING;
                    }
                }
            }
    
            st = ic->streams[pkt->stream_index];
            if (st->codec_info_state == CSTATE_DECODING) {
                /* decode the data and update codec parameters */
                ptr = pkt->data;
                size = pkt->size;
                while (size > 0) {
                    switch(st->codec.codec_type) {
                    case CODEC_TYPE_VIDEO:
                        ret = avcodec_decode_video(&st->codec, &picture, 
                                                   &got_picture, ptr, size);
                        break;
                    case CODEC_TYPE_AUDIO:
                        ret = avcodec_decode_audio(&st->codec, samples, 
                                                   &got_picture, ptr, size);
                        break;
                    default:
                        ret = -1;
                        break;
                    }
                    if (ret < 0) {
                        /* if error, simply ignore because another packet
                           may be OK */
                        break;
                    }
                    if (got_picture) {
                        /* we got the parameters - now we can stop
                           examining this stream */
                        /* XXX: add a codec info so that we can decide if
                           the codec can repeat frames */
                        if (st->codec.codec_id == CODEC_ID_MPEG1VIDEO && 
                            ic->iformat != &mpegts_demux &&
                            st->codec.sub_id == 2) {
                            /* for mpeg2 video, we want to know the real
                               frame rate, so we decode 40 frames. In mpeg
                               TS case we do not do it because it would be
                               too long */
                            st->codec_info_nb_real_frames++;
    
                            st->codec_info_nb_repeat_frames += st->codec.coded_frame->repeat_pict;
    
    #if 0
                            /* XXX: testing */
                            if ((st->codec_info_nb_real_frames % 24) == 23) {
                                st->codec_info_nb_repeat_frames += 2;
                            }
    #endif
                            /* stop after 40 frames */
                            if (st->codec_info_nb_real_frames >= 40) {
    
                                av_reduce(
                                    &st->r_frame_rate,
                                    &st->r_frame_rate_base,
                                    (int64_t)st->codec.frame_rate * st->codec_info_nb_real_frames,
    
                                    (st->codec_info_nb_real_frames + (st->codec_info_nb_repeat_frames >> 1)) * st->codec.frame_rate_base,
    
                                goto close_codec;
                            }
                        } else {
                        close_codec:
                            st->codec_info_state = CSTATE_FOUND;
                            avcodec_close(&st->codec);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
                            break;
    
                        }
                    }
                    ptr += ret;
                    size -= ret;
                }
            }
            count++;
        }
    
        /* close each codec if there are opened */
        for(i=0;i<ic->nb_streams;i++) {
            st = ic->streams[i];
            if (st->codec_info_state == CSTATE_DECODING)
                avcodec_close(&st->codec);
        }
    
        /* set real frame rate info */
        for(i=0;i<ic->nb_streams;i++) {
            st = ic->streams[i];
            if (st->codec.codec_type == CODEC_TYPE_VIDEO) {
    
                if (!st->r_frame_rate){
                    st->r_frame_rate      = st->codec.frame_rate;
                    st->r_frame_rate_base = st->codec.frame_rate_base;
                }
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        }
    
    /**
     * Close a media file (but not its codecs)
     *
     * @param s media file handle
     */
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    void av_close_input_file(AVFormatContext *s)
    {
        int i;
    
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        for(i=0;i<s->nb_streams;i++) {
    
            av_free(s->streams[i]);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        }
        if (s->packet_buffer) {
            AVPacketList *p, *p1;
            p = s->packet_buffer;
            while (p != NULL) {
                p1 = p->next;
                av_free_packet(&p->pkt);
    
                av_free(p);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
                p = p1;
            }
            s->packet_buffer = NULL;
        }
    
            url_fclose(&s->pb);
        }
    
        av_free(s);
    
    /**
     * Add a new stream to a media file. Can only be called in the
     * read_header function. If the flag AVFMT_NOHEADER is in the format
     * description, then new streams can be added in read_packet too.
     *
     *
     * @param s media file handle
     * @param id file format dependent stream id
     */
    AVStream *av_new_stream(AVFormatContext *s, int id)
    {
        AVStream *st;
    
        if (s->nb_streams >= MAX_STREAMS)
            return NULL;
    
        st = av_mallocz(sizeof(AVStream));
        if (!st)
            return NULL;
    
    Michael Niedermayer's avatar
    Michael Niedermayer committed
        avcodec_get_context_defaults(&st->codec);
    
    
        st->index = s->nb_streams;
        st->id = id;
        s->streams[s->nb_streams++] = st;
        return st;
    }
    
    /************************************************************/
    /* output media file */
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    
    
    int av_set_parameters(AVFormatContext *s, AVFormatParameters *ap)
    {
        int ret;
    
        
        if (s->oformat->priv_data_size > 0) {
            s->priv_data = av_mallocz(s->oformat->priv_data_size);
            if (!s->priv_data)
                return AVERROR_NOMEM;
        } else
            s->priv_data = NULL;
    	
    
        if (s->oformat->set_parameters) {
            ret = s->oformat->set_parameters(s, ap);
            if (ret < 0)
                return ret;
        }
        return 0;
    }
    
    
    /**
     * allocate the stream private data and write the stream header to an
     * output media file
     *
     * @param s media file handle
     * @return 0 if OK. AVERROR_xxx if error.  
     */
    int av_write_header(AVFormatContext *s)
    {
    
        int ret, i;
        AVStream *st;
    
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        /* default pts settings is MPEG like */
        av_set_pts_info(s, 33, 1, 90000);
    
        ret = s->oformat->write_header(s);
        if (ret < 0)
            return ret;
    
        /* init PTS generation */
        for(i=0;i<s->nb_streams;i++) {
            st = s->streams[i];
    
            switch (st->codec.codec_type) {
            case CODEC_TYPE_AUDIO:
                av_frac_init(&st->pts, 0, 0, 
    
                             (int64_t)s->pts_num * st->codec.sample_rate);
    
                break;
            case CODEC_TYPE_VIDEO:
                av_frac_init(&st->pts, 0, 0, 
    
                             (int64_t)s->pts_num * st->codec.frame_rate);
    
     * Write a packet to an output media file. The packet shall contain
     * one audio or video frame.
    
     * @param stream_index stream index
     * @param buf buffer containing the frame data
     * @param size size of buffer
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     * @return < 0 if error, = 0 if OK, 1 if end of stream wanted.
    
    int av_write_frame(AVFormatContext *s, int stream_index, const uint8_t *buf, 
                       int size)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
    
        int64_t pts_mask;
    
    
        st = s->streams[stream_index];
        pts_mask = (1LL << s->pts_wrap_bits) - 1;
        ret = s->oformat->write_packet(s, stream_index, (uint8_t *)buf, size, 
                                       st->pts.val & pts_mask);
        if (ret < 0)
            return ret;
    
        /* update pts */
        switch (st->codec.codec_type) {
        case CODEC_TYPE_AUDIO:
    
            if (st->codec.frame_size <= 1) {
                frame_size = size / st->codec.channels;
                /* specific hack for pcm codecs because no frame size is provided */
    
                switch(st->codec.codec_id) {
    
                case CODEC_ID_PCM_S16LE:
                case CODEC_ID_PCM_S16BE:
                case CODEC_ID_PCM_U16LE:
                case CODEC_ID_PCM_U16BE:
                    frame_size >>= 1;
                    break;
                default:
                    break;
                }
            } else {
                frame_size = st->codec.frame_size;
            }
    
            av_frac_add(&st->pts, 
    
                        (int64_t)s->pts_den * frame_size);
    
            break;
        case CODEC_TYPE_VIDEO:
            av_frac_add(&st->pts, 
    
                        (int64_t)s->pts_den * st->codec.frame_rate_base);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        return ret;
    
    }
    
    /**
     * write the stream trailer to an output media file and and free the
     * file private data.
     *
     * @param s media file handle
     * @return 0 if OK. AVERROR_xxx if error.  */
    int av_write_trailer(AVFormatContext *s)
    {
        int ret;
        ret = s->oformat->write_trailer(s);
        av_freep(&s->priv_data);
        return ret;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    }
    
    /* "user interface" functions */
    
    void dump_format(AVFormatContext *ic,
                     int index, 
                     const char *url,
                     int is_output)
    {
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        char buf[256];
    
        fprintf(stderr, "%s #%d, %s, %s '%s':\n", 
                is_output ? "Output" : "Input",
    
                index, 
                is_output ? ic->oformat->name : ic->iformat->name, 
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
                is_output ? "to" : "from", url);
        for(i=0;i<ic->nb_streams;i++) {
            AVStream *st = ic->streams[i];
            avcodec_string(buf, sizeof(buf), &st->codec, is_output);
    
            fprintf(stderr, "  Stream #%d.%d", index, i);
            /* the pid is an important information, so we display it */
            /* XXX: add a generic system */
            if (is_output)
                flags = ic->oformat->flags;
            else
                flags = ic->iformat->flags;
            if (flags & AVFMT_SHOW_IDS) {
                fprintf(stderr, "[0x%x]", st->id);
            }
            fprintf(stderr, ": %s\n", buf);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        }
    }
    
    typedef struct {
    
        const char *abv;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        int width, height;
    
        int frame_rate, frame_rate_base;
    } AbvEntry;
    
    static AbvEntry frame_abvs[] = {
        { "ntsc",      352, 240, 30000, 1001 },
        { "pal",       352, 288,    25,    1 },
        { "film",      352, 240,    24,    1 },
        { "ntsc-film", 352, 240, 24000, 1001 },
        { "sqcif",     128,  96,     0,    0 },
        { "qcif",      176, 144,     0,    0 },
        { "cif",       352, 288,     0,    0 },
        { "4cif",      704, 576,     0,    0 },
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    };
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    int parse_image_size(int *width_ptr, int *height_ptr, const char *str)
    {
        int i;
    
        int n = sizeof(frame_abvs) / sizeof(AbvEntry);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        const char *p;
        int frame_width = 0, frame_height = 0;
    
        for(i=0;i<n;i++) {
    
            if (!strcmp(frame_abvs[i].abv, str)) {
                frame_width = frame_abvs[i].width;
                frame_height = frame_abvs[i].height;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
                break;
            }
        }
        if (i == n) {
            p = str;
            frame_width = strtol(p, (char **)&p, 10);
            if (*p)
                p++;
            frame_height = strtol(p, (char **)&p, 10);
        }
        if (frame_width <= 0 || frame_height <= 0)
            return -1;
        *width_ptr = frame_width;
        *height_ptr = frame_height;
        return 0;
    }
    
    
    int parse_frame_rate(int *frame_rate, int *frame_rate_base, const char *arg)
    {
        int i;
        char* cp;
       
        /* First, we check our abbreviation table */
        for (i = 0; i < sizeof(frame_abvs)/sizeof(*frame_abvs); ++i)
             if (!strcmp(frame_abvs[i].abv, arg)) {
    	     *frame_rate = frame_abvs[i].frame_rate;
    	     *frame_rate_base = frame_abvs[i].frame_rate_base;
    	     return 0;
    	 }
    
        /* Then, we try to parse it as fraction */
        cp = strchr(arg, '/');
        if (cp) {
            char* cpp;
    	*frame_rate = strtol(arg, &cpp, 10);
    	if (cpp != arg || cpp == cp) 
    	    *frame_rate_base = strtol(cp+1, &cpp, 10);
    	else
    	   *frame_rate = 0;
        } 
        else {
            /* Finally we give up and parse it as double */
            *frame_rate_base = DEFAULT_FRAME_RATE_BASE;
            *frame_rate = (int)(strtod(arg, 0) * (*frame_rate_base) + 0.5);
        }
        if (!*frame_rate || !*frame_rate_base)
            return -1;
        else
            return 0;
    }
    
    
    int64_t av_gettime(void)
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    {
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #ifdef CONFIG_WIN32
        struct _timeb tb;
        _ftime(&tb);
    
        return ((int64_t)tb.time * int64_t_C(1000) + (int64_t)tb.millitm) * int64_t_C(1000);
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #else
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
        struct timeval tv;
        gettimeofday(&tv,NULL);
    
        return (int64_t)tv.tv_sec * 1000000 + tv.tv_usec;
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    #endif
    
    static time_t mktimegm(struct tm *tm)
    {
        time_t t;
    
        int y = tm->tm_year + 1900, m = tm->tm_mon + 1, d = tm->tm_mday;
    
        if (m < 3) {
            m += 12;
            y--;
        }
    
        t = 86400 * 
            (d + (153 * m - 457) / 5 + 365 * y + y / 4 - y / 100 + y / 400 - 719469);
    
        t += 3600 * tm->tm_hour + 60 * tm->tm_min + tm->tm_sec;
    
        return t;
    }
    
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
    /* Syntax:
     * - If not a duration:
     *  [{YYYY-MM-DD|YYYYMMDD}]{T| }{HH[:MM[:SS[.m...]]][Z]|HH[MM[SS[.m...]]][Z]}
    
     * Time is localtime unless Z is suffixed to the end. In this case GMT
    
    Fabrice Bellard's avatar
    Fabrice Bellard committed
     * Return the date in micro seconds since 1970 
     * - If duration:
     *  HH[:MM[:SS[.m...]]]
     *  S+[.m...]
     */