PeerStreamer

/*

 * FFplay : Simple Media Player based on the ffmpeg libraries

 * Copyright (c) 2003 Fabrice Bellard

 *

 * This file is part of FFmpeg.

 *

 * FFmpeg 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.1 of the License, or (at your option) any later version.

 *

 * FFmpeg is distributed in the hope that it will be useful,

 * 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.

 *

 * You should have received a copy of the GNU Lesser General Public

 * License along with FFmpeg; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

 */

#include "config.h"

#include <math.h>

#include <limits.h>

#include "libavutil/avstring.h"

#include "libavutil/pixdesc.h"

#include "libavformat/avformat.h"

#include "libavdevice/avdevice.h"

#include "libswscale/swscale.h"

#include "libavcodec/audioconvert.h"

#include "libavcodec/colorspace.h"

#include "libavcodec/opt.h"

#include "cmdutils.h"

#include <SDL.h>

#include <SDL_thread.h>

#ifdef __MINGW32__

#undef main /* We don't want SDL to override our main() */

#endif

#undef exit

#undef printf

#undef fprintf

const char program_name[] = "FFplay";

const int program_birth_year = 2003;

//#define DEBUG_SYNC

#define MAX_QUEUE_SIZE (15 * 1024 * 1024)

#define MIN_AUDIOQ_SIZE (20 * 16 * 1024)

#define MIN_FRAMES 5

/* SDL audio buffer size, in samples. Should be small to have precise

   A/V sync as SDL does not have hardware buffer fullness info. */

#define SDL_AUDIO_BUFFER_SIZE 1024

/* no AV sync correction is done if below the AV sync threshold */

#define AV_SYNC_THRESHOLD 0.01

/* no AV correction is done if too big error */

#define AV_NOSYNC_THRESHOLD 10.0

/* maximum audio speed change to get correct sync */

#define SAMPLE_CORRECTION_PERCENT_MAX 10

/* we use about AUDIO_DIFF_AVG_NB A-V differences to make the average */

#define AUDIO_DIFF_AVG_NB   20

/* NOTE: the size must be big enough to compensate the hardware audio buffersize size */

#define SAMPLE_ARRAY_SIZE (2*65536)

static int sws_flags = SWS_BICUBIC;

typedef struct PacketQueue {

    AVPacketList *first_pkt, *last_pkt;

    int nb_packets;

    int size;

    int abort_request;

    SDL_mutex *mutex;

    SDL_cond *cond;

} PacketQueue;

#define VIDEO_PICTURE_QUEUE_SIZE 1

#define SUBPICTURE_QUEUE_SIZE 4

typedef struct VideoPicture {

    double pts;                                  ///<presentation time stamp for this picture

    SDL_Overlay *bmp;

    int width, height; /* source height & width */

    int allocated;

    SDL_TimerID timer_id;

} VideoPicture;

typedef struct SubPicture {

    double pts; /* presentation time stamp for this picture */

    AVSubtitle sub;

} SubPicture;

enum {

    AV_SYNC_AUDIO_MASTER, /* default choice */

    AV_SYNC_VIDEO_MASTER,

    AV_SYNC_EXTERNAL_CLOCK, /* synchronize to an external clock */

};

typedef struct VideoState {

    SDL_Thread *parse_tid;

    SDL_Thread *video_tid;

    AVInputFormat *iformat;

    int no_background;

    int abort_request;

    int paused;

    int last_paused;

    int seek_req;

    int seek_flags;

    int64_t seek_pos;

    int64_t seek_rel;

    int read_pause_return;

    AVFormatContext *ic;

    int dtg_active_format;

    int audio_stream;

    int av_sync_type;

    double external_clock; /* external clock base */

    int64_t external_clock_time;

    double audio_clock;

    double audio_diff_cum; /* used for AV difference average computation */

    double audio_diff_avg_coef;

    double audio_diff_threshold;

    int audio_diff_avg_count;

    AVStream *audio_st;

    PacketQueue audioq;

    int audio_hw_buf_size;

    /* samples output by the codec. we reserve more space for avsync

       compensation */

    DECLARE_ALIGNED(16,uint8_t,audio_buf1)[(AVCODEC_MAX_AUDIO_FRAME_SIZE * 3) / 2];

    DECLARE_ALIGNED(16,uint8_t,audio_buf2)[(AVCODEC_MAX_AUDIO_FRAME_SIZE * 3) / 2];

    uint8_t *audio_buf;

    unsigned int audio_buf_size; /* in bytes */

    int audio_buf_index; /* in bytes */

    AVPacket audio_pkt_temp;

    AVPacket audio_pkt;

    enum SampleFormat audio_src_fmt;

    AVAudioConvert *reformat_ctx;

    int show_audio; /* if true, display audio samples */

    int16_t sample_array[SAMPLE_ARRAY_SIZE];

    int sample_array_index;

    int last_i_start;

    SDL_Thread *subtitle_tid;

    int subtitle_stream;

    int subtitle_stream_changed;

    AVStream *subtitle_st;

    PacketQueue subtitleq;

    SubPicture subpq[SUBPICTURE_QUEUE_SIZE];

    int subpq_size, subpq_rindex, subpq_windex;

    SDL_mutex *subpq_mutex;

    SDL_cond *subpq_cond;

    double frame_timer;

    double frame_last_pts;

    double frame_last_delay;

    double video_clock;                          ///<pts of last decoded frame / predicted pts of next decoded frame

    int video_stream;

    AVStream *video_st;

    PacketQueue videoq;

    double video_current_pts;                    ///<current displayed pts (different from video_clock if frame fifos are used)

    double video_current_pts_drift;              ///<video_current_pts - time (av_gettime) at which we updated video_current_pts - used to have running video pts

    VideoPicture pictq[VIDEO_PICTURE_QUEUE_SIZE];

    int pictq_size, pictq_rindex, pictq_windex;

    SDL_mutex *pictq_mutex;

    SDL_cond *pictq_cond;

    struct SwsContext *img_convert_ctx;

    //    QETimer *video_timer;

    char filename[1024];

    int width, height, xleft, ytop;

    int64_t faulty_pts;

    int64_t faulty_dts;

    int64_t last_dts_for_fault_detection;

    int64_t last_pts_for_fault_detection;

} VideoState;

static void show_help(void);

static int audio_write_get_buf_size(VideoState *is);

/* options specified by the user */

static AVInputFormat *file_iformat;

static const char *input_filename;

static int fs_screen_width;

static int fs_screen_height;

static int screen_width = 0;

static int screen_height = 0;

static int frame_width = 0;

static int frame_height = 0;

static enum PixelFormat frame_pix_fmt = PIX_FMT_NONE;

static int audio_disable;

static int video_disable;

static int wanted_audio_stream= 0;

static int wanted_video_stream= 0;

static int wanted_subtitle_stream= -1;

static int seek_by_bytes;

static int display_disable;

static int show_status = 1;

static int av_sync_type = AV_SYNC_AUDIO_MASTER;

static int64_t start_time = AV_NOPTS_VALUE;

static int debug = 0;

static int debug_mv = 0;

static int step = 0;

static int thread_count = 1;

static int workaround_bugs = 1;

static int fast = 0;

static int genpts = 0;

static int lowres = 0;

static int idct = FF_IDCT_AUTO;

static enum AVDiscard skip_frame= AVDISCARD_DEFAULT;

static enum AVDiscard skip_idct= AVDISCARD_DEFAULT;

static enum AVDiscard skip_loop_filter= AVDISCARD_DEFAULT;

static int error_recognition = FF_ER_CAREFUL;

static int error_concealment = 3;

static int decoder_reorder_pts= -1;

/* current context */

static int is_full_screen;

static VideoState *cur_stream;

static int64_t audio_callback_time;

static AVPacket flush_pkt;

#define FF_ALLOC_EVENT   (SDL_USEREVENT)

#define FF_REFRESH_EVENT (SDL_USEREVENT + 1)

#define FF_QUIT_EVENT    (SDL_USEREVENT + 2)

static SDL_Surface *screen;

static int packet_queue_put(PacketQueue *q, AVPacket *pkt);

/* packet queue handling */

static void packet_queue_init(PacketQueue *q)

{

    memset(q, 0, sizeof(PacketQueue));

    q->mutex = SDL_CreateMutex();

    q->cond = SDL_CreateCond();

    packet_queue_put(q, &flush_pkt);

}

static void packet_queue_flush(PacketQueue *q)

{

    AVPacketList *pkt, *pkt1;

    SDL_LockMutex(q->mutex);

    for(pkt = q->first_pkt; pkt != NULL; pkt = pkt1) {

        pkt1 = pkt->next;

        av_free_packet(&pkt->pkt);

        av_freep(&pkt);

    }

    q->last_pkt = NULL;

    q->first_pkt = NULL;

    q->nb_packets = 0;

    q->size = 0;

    SDL_UnlockMutex(q->mutex);

}

static void packet_queue_end(PacketQueue *q)

{

    packet_queue_flush(q);

    SDL_DestroyMutex(q->mutex);

    SDL_DestroyCond(q->cond);

}

static int packet_queue_put(PacketQueue *q, AVPacket *pkt)

{

    AVPacketList *pkt1;

    /* duplicate the packet */

    if (pkt!=&flush_pkt && av_dup_packet(pkt) < 0)

        return -1;

    pkt1 = av_malloc(sizeof(AVPacketList));

    if (!pkt1)

        return -1;

    pkt1->pkt = *pkt;

    pkt1->next = NULL;

    SDL_LockMutex(q->mutex);

    if (!q->last_pkt)

        q->first_pkt = pkt1;

    else

        q->last_pkt->next = pkt1;

    q->last_pkt = pkt1;

    q->nb_packets++;

    q->size += pkt1->pkt.size + sizeof(*pkt1);

    /* XXX: should duplicate packet data in DV case */

    SDL_CondSignal(q->cond);

    SDL_UnlockMutex(q->mutex);

    return 0;

}

static void packet_queue_abort(PacketQueue *q)

{

    SDL_LockMutex(q->mutex);

    q->abort_request = 1;

    SDL_CondSignal(q->cond);

    SDL_UnlockMutex(q->mutex);

}

/* return < 0 if aborted, 0 if no packet and > 0 if packet.  */

static int packet_queue_get(PacketQueue *q, AVPacket *pkt, int block)

{

    AVPacketList *pkt1;

    int ret;

    SDL_LockMutex(q->mutex);

    for(;;) {

        if (q->abort_request) {

            ret = -1;

            break;

        }

        pkt1 = q->first_pkt;

        if (pkt1) {

            q->first_pkt = pkt1->next;

            if (!q->first_pkt)

                q->last_pkt = NULL;

            q->nb_packets--;

            q->size -= pkt1->pkt.size + sizeof(*pkt1);

            *pkt = pkt1->pkt;

            av_free(pkt1);

            ret = 1;

            break;

        } else if (!block) {

            ret = 0;

            break;

        } else {

            SDL_CondWait(q->cond, q->mutex);

        }

    }

    SDL_UnlockMutex(q->mutex);

    return ret;

}

static inline void fill_rectangle(SDL_Surface *screen,

                                  int x, int y, int w, int h, int color)

{

    SDL_Rect rect;

    rect.x = x;

    rect.y = y;

    rect.w = w;

    rect.h = h;

    SDL_FillRect(screen, &rect, color);

}

#if 0

/* draw only the border of a rectangle */

void fill_border(VideoState *s, int x, int y, int w, int h, int color)

{

    int w1, w2, h1, h2;

    /* fill the background */

    w1 = x;

    if (w1 < 0)

        w1 = 0;

    w2 = s->width - (x + w);

    if (w2 < 0)

        w2 = 0;

    h1 = y;

    if (h1 < 0)

        h1 = 0;

    h2 = s->height - (y + h);

    if (h2 < 0)

        h2 = 0;

    fill_rectangle(screen,

                   s->xleft, s->ytop,

                   w1, s->height,

                   color);

    fill_rectangle(screen,

                   s->xleft + s->width - w2, s->ytop,

                   w2, s->height,

                   color);

    fill_rectangle(screen,

                   s->xleft + w1, s->ytop,

                   s->width - w1 - w2, h1,

                   color);

    fill_rectangle(screen,

                   s->xleft + w1, s->ytop + s->height - h2,

                   s->width - w1 - w2, h2,

                   color);

}

#endif

#define ALPHA_BLEND(a, oldp, newp, s)\

((((oldp << s) * (255 - (a))) + (newp * (a))) / (255 << s))

#define RGBA_IN(r, g, b, a, s)\

{\

    unsigned int v = ((const uint32_t *)(s))[0];\

    a = (v >> 24) & 0xff;\

    r = (v >> 16) & 0xff;\

    g = (v >> 8) & 0xff;\

    b = v & 0xff;\

}

#define YUVA_IN(y, u, v, a, s, pal)\

{\

    unsigned int val = ((const uint32_t *)(pal))[*(const uint8_t*)(s)];\

    a = (val >> 24) & 0xff;\

    y = (val >> 16) & 0xff;\

    u = (val >> 8) & 0xff;\

    v = val & 0xff;\

}

#define YUVA_OUT(d, y, u, v, a)\

{\

    ((uint32_t *)(d))[0] = (a << 24) | (y << 16) | (u << 8) | v;\

}

#define BPP 1

static void blend_subrect(AVPicture *dst, const AVSubtitleRect *rect, int imgw, int imgh)

{

    int wrap, wrap3, width2, skip2;

    int y, u, v, a, u1, v1, a1, w, h;

    uint8_t *lum, *cb, *cr;

    const uint8_t *p;

    const uint32_t *pal;

    int dstx, dsty, dstw, dsth;

    dstw = av_clip(rect->w, 0, imgw);

    dsth = av_clip(rect->h, 0, imgh);

    dstx = av_clip(rect->x, 0, imgw - dstw);

    dsty = av_clip(rect->y, 0, imgh - dsth);

    lum = dst->data[0] + dsty * dst->linesize[0];

    cb = dst->data[1] + (dsty >> 1) * dst->linesize[1];

    cr = dst->data[2] + (dsty >> 1) * dst->linesize[2];

    width2 = ((dstw + 1) >> 1) + (dstx & ~dstw & 1);

    skip2 = dstx >> 1;

    wrap = dst->linesize[0];

    wrap3 = rect->pict.linesize[0];

    p = rect->pict.data[0];

    pal = (const uint32_t *)rect->pict.data[1];  /* Now in YCrCb! */

    if (dsty & 1) {

        lum += dstx;

        cb += skip2;

        cr += skip2;

        if (dstx & 1) {

            YUVA_IN(y, u, v, a, p, pal);

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);

            cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);

            cb++;

            cr++;

            lum++;

            p += BPP;

        }

        for(w = dstw - (dstx & 1); w >= 2; w -= 2) {

            YUVA_IN(y, u, v, a, p, pal);

            u1 = u;

            v1 = v;

            a1 = a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            YUVA_IN(y, u, v, a, p + BPP, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[1] = ALPHA_BLEND(a, lum[1], y, 0);

            cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);

            cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);

            cb++;

            cr++;

            p += 2 * BPP;

            lum += 2;

        }

        if (w) {

            YUVA_IN(y, u, v, a, p, pal);

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);

            cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);

            p++;

            lum++;

        }

        p += wrap3 - dstw * BPP;

        lum += wrap - dstw - dstx;

        cb += dst->linesize[1] - width2 - skip2;

        cr += dst->linesize[2] - width2 - skip2;

    }

    for(h = dsth - (dsty & 1); h >= 2; h -= 2) {

        lum += dstx;

        cb += skip2;

        cr += skip2;

        if (dstx & 1) {

            YUVA_IN(y, u, v, a, p, pal);

            u1 = u;

            v1 = v;

            a1 = a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            p += wrap3;

            lum += wrap;

            YUVA_IN(y, u, v, a, p, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);

            cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);

            cb++;

            cr++;

            p += -wrap3 + BPP;

            lum += -wrap + 1;

        }

        for(w = dstw - (dstx & 1); w >= 2; w -= 2) {

            YUVA_IN(y, u, v, a, p, pal);

            u1 = u;

            v1 = v;

            a1 = a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            YUVA_IN(y, u, v, a, p + BPP, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[1] = ALPHA_BLEND(a, lum[1], y, 0);

            p += wrap3;

            lum += wrap;

            YUVA_IN(y, u, v, a, p, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            YUVA_IN(y, u, v, a, p + BPP, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[1] = ALPHA_BLEND(a, lum[1], y, 0);

            cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 2);

            cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 2);

            cb++;

            cr++;

            p += -wrap3 + 2 * BPP;

            lum += -wrap + 2;

        }

        if (w) {

            YUVA_IN(y, u, v, a, p, pal);

            u1 = u;

            v1 = v;

            a1 = a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            p += wrap3;

            lum += wrap;

            YUVA_IN(y, u, v, a, p, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);

            cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);

            cb++;

            cr++;

            p += -wrap3 + BPP;

            lum += -wrap + 1;

        }

        p += wrap3 + (wrap3 - dstw * BPP);

        lum += wrap + (wrap - dstw - dstx);

        cb += dst->linesize[1] - width2 - skip2;

        cr += dst->linesize[2] - width2 - skip2;

    }

    /* handle odd height */

    if (h) {

        lum += dstx;

        cb += skip2;

        cr += skip2;

        if (dstx & 1) {

            YUVA_IN(y, u, v, a, p, pal);

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);

            cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);

            cb++;

            cr++;

            lum++;

            p += BPP;

        }

        for(w = dstw - (dstx & 1); w >= 2; w -= 2) {

            YUVA_IN(y, u, v, a, p, pal);

            u1 = u;

            v1 = v;

            a1 = a;

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            YUVA_IN(y, u, v, a, p + BPP, pal);

            u1 += u;

            v1 += v;

            a1 += a;

            lum[1] = ALPHA_BLEND(a, lum[1], y, 0);

            cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u, 1);

            cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v, 1);

            cb++;

            cr++;

            p += 2 * BPP;

            lum += 2;

        }

        if (w) {

            YUVA_IN(y, u, v, a, p, pal);

            lum[0] = ALPHA_BLEND(a, lum[0], y, 0);

            cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);

            cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);

        }

    }

}

static void free_subpicture(SubPicture *sp)

{

    int i;

    for (i = 0; i < sp->sub.num_rects; i++)

    {

        av_freep(&sp->sub.rects[i]->pict.data[0]);

        av_freep(&sp->sub.rects[i]->pict.data[1]);

        av_freep(&sp->sub.rects[i]);

    }

    av_free(sp->sub.rects);

    memset(&sp->sub, 0, sizeof(AVSubtitle));

}

static void video_image_display(VideoState *is)

{

    VideoPicture *vp;

    SubPicture *sp;

    AVPicture pict;

    float aspect_ratio;

    int width, height, x, y;

    SDL_Rect rect;

    int i;

    vp = &is->pictq[is->pictq_rindex];

    if (vp->bmp) {

        /* XXX: use variable in the frame */

        if (is->video_st->sample_aspect_ratio.num)

            aspect_ratio = av_q2d(is->video_st->sample_aspect_ratio);

        else if (is->video_st->codec->sample_aspect_ratio.num)

            aspect_ratio = av_q2d(is->video_st->codec->sample_aspect_ratio);

        else

            aspect_ratio = 0;

        if (aspect_ratio <= 0.0)

            aspect_ratio = 1.0;

        aspect_ratio *= (float)is->video_st->codec->width / is->video_st->codec->height;

        /* if an active format is indicated, then it overrides the

           mpeg format */

#if 0

        if (is->video_st->codec->dtg_active_format != is->dtg_active_format) {

            is->dtg_active_format = is->video_st->codec->dtg_active_format;

            printf("dtg_active_format=%d\n", is->dtg_active_format);

        }

#endif

#if 0

        switch(is->video_st->codec->dtg_active_format) {

        case FF_DTG_AFD_SAME:

        default:

            /* nothing to do */

            break;

        case FF_DTG_AFD_4_3:

            aspect_ratio = 4.0 / 3.0;

            break;

        case FF_DTG_AFD_16_9:

            aspect_ratio = 16.0 / 9.0;

            break;

        case FF_DTG_AFD_14_9:

            aspect_ratio = 14.0 / 9.0;

            break;

        case FF_DTG_AFD_4_3_SP_14_9:

            aspect_ratio = 14.0 / 9.0;

            break;

        case FF_DTG_AFD_16_9_SP_14_9:

            aspect_ratio = 14.0 / 9.0;

            break;

        case FF_DTG_AFD_SP_4_3:

            aspect_ratio = 4.0 / 3.0;

            break;

        }

#endif

        if (is->subtitle_st)

        {

            if (is->subpq_size > 0)

            {

                sp = &is->subpq[is->subpq_rindex];

                if (vp->pts >= sp->pts + ((float) sp->sub.start_display_time / 1000))

                {

                    SDL_LockYUVOverlay (vp->bmp);

                    pict.data[0] = vp->bmp->pixels[0];

                    pict.data[1] = vp->bmp->pixels[2];

                    pict.data[2] = vp->bmp->pixels[1];

                    pict.linesize[0] = vp->bmp->pitches[0];

                    pict.linesize[1] = vp->bmp->pitches[2];

                    pict.linesize[2] = vp->bmp->pitches[1];

                    for (i = 0; i < sp->sub.num_rects; i++)

                        blend_subrect(&pict, sp->sub.rects[i],

                                      vp->bmp->w, vp->bmp->h);

                    SDL_UnlockYUVOverlay (vp->bmp);

                }

            }

        }

        /* XXX: we suppose the screen has a 1.0 pixel ratio */

        height = is->height;

        width = ((int)rint(height * aspect_ratio)) & ~1;

        if (width > is->width) {

            width = is->width;

            height = ((int)rint(width / aspect_ratio)) & ~1;

        }

        x = (is->width - width) / 2;

        y = (is->height - height) / 2;

        if (!is->no_background) {

            /* fill the background */

            //            fill_border(is, x, y, width, height, QERGB(0x00, 0x00, 0x00));

        } else {

            is->no_background = 0;

        }

        rect.x = is->xleft + x;

        rect.y = is->ytop  + y;

        rect.w = width;

        rect.h = height;

        SDL_DisplayYUVOverlay(vp->bmp, &rect);

    } else {

#if 0

        fill_rectangle(screen,

                       is->xleft, is->ytop, is->width, is->height,

                       QERGB(0x00, 0x00, 0x00));

#endif

    }

}

static inline int compute_mod(int a, int b)

{

    a = a % b;

    if (a >= 0)

        return a;

    else

        return a + b;

}

static void video_audio_display(VideoState *s)

{

    int i, i_start, x, y1, y, ys, delay, n, nb_display_channels;

    int ch, channels, h, h2, bgcolor, fgcolor;

    int16_t time_diff;

    /* compute display index : center on currently output samples */

    channels = s->audio_st->codec->channels;

    nb_display_channels = channels;

    if (!s->paused) {

        n = 2 * channels;

        delay = audio_write_get_buf_size(s);

        delay /= n;

        /* to be more precise, we take into account the time spent since

           the last buffer computation */

        if (audio_callback_time) {

            time_diff = av_gettime() - audio_callback_time;

            delay += (time_diff * s->audio_st->codec->sample_rate) / 1000000;

        }

        delay -= s->width / 2;

        if (delay < s->width)

            delay = s->width;

        i_start= x = compute_mod(s->sample_array_index - delay * channels, SAMPLE_ARRAY_SIZE);

        h= INT_MIN;

        for(i=0; i<1000; i+=channels){

            int idx= (SAMPLE_ARRAY_SIZE + x - i) % SAMPLE_ARRAY_SIZE;

            int a= s->sample_array[idx];

            int b= s->sample_array[(idx + 4*channels)%SAMPLE_ARRAY_SIZE];

            int c= s->sample_array[(idx + 5*channels)%SAMPLE_ARRAY_SIZE];

            int d= s->sample_array[(idx + 9*channels)%SAMPLE_ARRAY_SIZE];

            int score= a-d;

            if(h<score && (b^c)<0){

                h= score;

                i_start= idx;

            }

        }

        s->last_i_start = i_start;

    } else {

        i_start = s->last_i_start;

    }

    bgcolor = SDL_MapRGB(screen->format, 0x00, 0x00, 0x00);

    fill_rectangle(screen,

                   s->xleft, s->ytop, s->width, s->height,

                   bgcolor);

    fgcolor = SDL_MapRGB(screen->format, 0xff, 0xff, 0xff);

    /* total height for one channel */

    h = s->height / nb_display_channels;

    /* graph height / 2 */

    h2 = (h * 9) / 20;

    for(ch = 0;ch < nb_display_channels; ch++) {

        i = i_start + ch;

        y1 = s->ytop + ch * h + (h / 2); /* position of center line */

        for(x = 0; x < s->width; x++) {

            y = (s->sample_array[i] * h2) >> 15;

            if (y < 0) {

                y = -y;

                ys = y1 - y;

            } else {

                ys = y1;

            }

            fill_rectangle(screen,

                           s->xleft + x, ys, 1, y,

                           fgcolor);

            i += channels;

            if (i >= SAMPLE_ARRAY_SIZE)

                i -= SAMPLE_ARRAY_SIZE;

        }

    }

    fgcolor = SDL_MapRGB(screen->format, 0x00, 0x00, 0xff);

    for(ch = 1;ch < nb_display_channels; ch++) {

        y = s->ytop + ch * h;

        fill_rectangle(screen,

                       s->xleft, y, s->width, 1,

                       fgcolor);

    }

    SDL_UpdateRect(screen, s->xleft, s->ytop, s->width, s->height);

}

static int video_open(VideoState *is){

    int flags = SDL_HWSURFACE|SDL_ASYNCBLIT|SDL_HWACCEL;

    int w,h;

    if(is_full_screen) flags |= SDL_FULLSCREEN;

    else               flags |= SDL_RESIZABLE;

    if (is_full_screen && fs_screen_width) {

        w = fs_screen_width;

        h = fs_screen_height;

    } else if(!is_full_screen && screen_width){

        w = screen_width;

        h = screen_height;

    }else if (is->video_st && is->video_st->codec->width){

        w = is->video_st->codec->width;

        h = is->video_st->codec->height;

    } else {

        w = 640;

        h = 480;

    }

#ifndef __APPLE__

    screen = SDL_SetVideoMode(w, h, 0, flags);

#else

    /* setting bits_per_pixel = 0 or 32 causes blank video on OS X */

    screen = SDL_SetVideoMode(w, h, 24, flags);

#endif

    if (!screen) {

        fprintf(stderr, "SDL: could not set video mode - exiting\n");

        return -1;

    }

    SDL_WM_SetCaption("FFplay", "FFplay");

    is->width = screen->w;

    is->height = screen->h;

    return 0;

}

/* display the current picture, if any */

static void video_display(VideoState *is)

{

    if(!screen)

        video_open(cur_stream);

    if (is->audio_st && is->show_audio)

        video_audio_display(is);

    else if (is->video_st)

        video_image_display(is);

}

static Uint32 sdl_refresh_timer_cb(Uint32 interval, void *opaque)

{

    SDL_Event event;

    event.type = FF_REFRESH_EVENT;

    event.user.data1 = opaque;

    SDL_PushEvent(&event);

    return 0; /* 0 means stop timer */

}

/* schedule a video refresh in 'delay' ms */

static SDL_TimerID schedule_refresh(VideoState *is, int delay)

{

    if(!delay) delay=1; //SDL seems to be buggy when the delay is 0

    return SDL_AddTimer(delay, sdl_refresh_timer_cb, is);

}

/* get the current audio clock value */

static double get_audio_clock(VideoState *is)

{

    double pts;

    int hw_buf_size, bytes_per_sec;

    pts = is->audio_clock;

    hw_buf_size = audio_write_get_buf_size(is);

    bytes_per_sec = 0;

    if (is->audio_st) {

        bytes_per_sec = is->audio_st->codec->sample_rate *

            2 * is->audio_st->codec->channels;

    }

    if (bytes_per_sec)

        pts -= (double)hw_buf_size / bytes_per_sec;

    return pts;

}

/* get the current video clock value */

static double get_video_clock(VideoState *is)

{

    if (is->paused) {

        return is->video_current_pts;

    } else {

        return is->video_current_pts_drift + av_gettime() / 1000000.0;

    }

}

/* get the current external clock value */

static double get_external_clock(VideoState *is)

{

    int64_t ti;

    ti = av_gettime();

    return is->external_clock + ((ti - is->external_clock_time) * 1e-6);

}

/* get the current master clock value */

static double get_master_clock(VideoState *is)

{

    double val;

    if (is->av_sync_type == AV_SYNC_VIDEO_MASTER) {

        if (is->video_st)

            val = get_video_clock(is);

        else

            val = get_audio_clock(is);

    } else if (is->av_sync_type == AV_SYNC_AUDIO_MASTER) {

        if (is->audio_st)

            val = get_audio_clock(is);

        else

            val = get_video_clock(is);

    } else {

        val = get_external_clock(is);

    }

    return val;

}

/* seek in the stream */

static void stream_seek(VideoState *is, int64_t pos, int64_t rel, int seek_by_bytes)

{

    if (!is->seek_req) {

        is->seek_pos = pos;

        is->seek_rel = rel;

        if (seek_by_bytes)

            is->seek_flags |= AVSEEK_FLAG_BYTE;

        is->seek_req = 1;

    }

}

/* pause or resume the video */

static void stream_pause(VideoState *is)

{

    if (is->paused) {

        is->frame_timer += av_gettime() / 1000000.0 + is->video_current_pts_drift - is->video_current_pts;

        if(is->read_pause_return != AVERROR(ENOSYS)){

            is->video_current_pts = is->video_current_pts_drift + av_gettime() / 1000000.0;

        }

        is->video_current_pts_drift = is->video_current_pts - av_gettime() / 1000000.0;

    }

    is->paused = !is->paused;

}

static double compute_frame_delay(double frame_current_pts, VideoState *is)

{

    double actual_delay, delay, sync_threshold, ref_clock, diff;

    /* compute nominal delay */

    delay = frame_current_pts - is->frame_last_pts;

    if (delay <= 0 || delay >= 10.0) {

        /* if incorrect delay, use previous one */

        delay = is->frame_last_delay;

    } else {

        is->frame_last_delay = delay;

    }

    is->frame_last_pts = frame_current_pts;

    /* update delay to follow master synchronisation source */

    if (((is->av_sync_type == AV_SYNC_AUDIO_MASTER && is->audio_st) ||

         is->av_sync_type == AV_SYNC_EXTERNAL_CLOCK)) {

        /* if video is slave, we try to correct big delays by

           duplicating or deleting a frame */

        ref_clock = get_master_clock(is);

        diff = frame_current_pts - ref_clock;

        /* skip or repeat frame. We take into account the

           delay to compute the threshold. I still don't know

           if it is the best guess */

        sync_threshold = FFMAX(AV_SYNC_THRESHOLD, delay);

        if (fabs(diff) < AV_NOSYNC_THRESHOLD) {

            if (diff <= -sync_threshold)

                delay = 0;

            else if (diff >= sync_threshold)

                delay = 2 * delay;

        }

    }

    is->frame_timer += delay;

    /* compute the REAL delay (we need to do that to avoid

       long term errors */

    actual_delay = is->frame_timer - (av_gettime() / 1000000.0);

    if (actual_delay < 0.010) {

        /* XXX: should skip picture */

        actual_delay = 0.010;

    }

#if defined(DEBUG_SYNC)

    printf("video: delay=%0.3f actual_delay=%0.3f pts=%0.3f A-V=%f\n",

            delay, actual_delay, frame_current_pts, -diff);

#endif

    return actual_delay;

}

/* called to display each frame */

static void video_refresh_timer(void *opaque)

{

    VideoState *is = opaque;

    VideoPicture *vp;

    SubPicture *sp, *sp2;

    if (is->video_st) {

        if (is->pictq_size == 0) {

//            fprintf(stderr, "Internal error detected in the SDL timer\n");

        } else {

            /* dequeue the picture */

            vp = &is->pictq[is->pictq_rindex];

            /* update current video pts */

            is->video_current_pts = vp->pts;

            is->video_current_pts_drift = is->video_current_pts - av_gettime() / 1000000.0;

            if(is->subtitle_st) {

                if (is->subtitle_stream_changed) {

                    SDL_LockMutex(is->subpq_mutex);

                    while (is->subpq_size) {

                        free_subpicture(&is->subpq[is->subpq_rindex]);

                        /* update queue size and signal for next picture */

                        if (++is->subpq_rindex == SUBPICTURE_QUEUE_SIZE)

                            is->subpq_rindex = 0;

                        is->subpq_size--;

                    }

                    is->subtitle_stream_changed = 0;

                    SDL_CondSignal(is->subpq_cond);

                    SDL_UnlockMutex(is->subpq_mutex);

                } else {

                    if (is->subpq_size > 0) {

                        sp = &is->subpq[is->subpq_rindex];

                        if (is->subpq_size > 1)

                            sp2 = &is->subpq[(is->subpq_rindex + 1) % SUBPICTURE_QUEUE_SIZE];

                        else

                            sp2 = NULL;

                        if ((is->video_current_pts > (sp->pts + ((float) sp->sub.end_display_time / 1000)))

                                || (sp2 && is->video_current_pts > (sp2->pts + ((float) sp2->sub.start_display_time / 1000))))

                        {

                            free_subpicture(sp);

                            /* update queue size and signal for next picture */

                            if (++is->subpq_rindex == SUBPICTURE_QUEUE_SIZE)

                                is->subpq_rindex = 0;

                            SDL_LockMutex(is->subpq_mutex);

                            is->subpq_size--;

                            SDL_CondSignal(is->subpq_cond);

                            SDL_UnlockMutex(is->subpq_mutex);

                        }

                    }

                }

            }

            /* display picture */

            video_display(is);

            /* update queue size and signal for next picture */

            if (++is->pictq_rindex == VIDEO_PICTURE_QUEUE_SIZE)

                is->pictq_rindex = 0;

            SDL_LockMutex(is->pictq_mutex);

            vp->timer_id= 0;

            is->pictq_size--;

            SDL_CondSignal(is->pictq_cond);

            SDL_UnlockMutex(is->pictq_mutex);

        }

    } else if (is->audio_st) {

        /* draw the next audio frame */

        schedule_refresh(is, 40);

        /* if only audio stream, then display the audio bars (better

           than nothing, just to test the implementation */

        /* display picture */

        video_display(is);

    } else {

        schedule_refresh(is, 100);

    }

    if (show_status) {

        static int64_t last_time;

        int64_t cur_time;

        int aqsize, vqsize, sqsize;

        double av_diff;

        cur_time = av_gettime();

        if (!last_time || (cur_time - last_time) >= 30000) {

            aqsize = 0;

            vqsize = 0;

            sqsize = 0;

            if (is->audio_st)

                aqsize = is->audioq.size;

            if (is->video_st)

                vqsize = is->videoq.size;

            if (is->subtitle_st)

                sqsize = is->subtitleq.size;

            av_diff = 0;

            if (is->audio_st && is->video_st)

                av_diff = get_audio_clock(is) - get_video_clock(is);

            printf("%7.2f A-V:%7.3f aq=%5dKB vq=%5dKB sq=%5dB f=%Ld/%Ld   \r",

                   get_master_clock(is), av_diff, aqsize / 1024, vqsize / 1024, sqsize, is->faulty_dts, is->faulty_pts);

            fflush(stdout);

            last_time = cur_time;

        }

    }

}

/* allocate a picture (needs to do that in main thread to avoid

   potential locking problems */

static void alloc_picture(void *opaque)

{

    VideoState *is = opaque;

    VideoPicture *vp;

    vp = &is->pictq[is->pictq_windex];

    if (vp->bmp)

        SDL_FreeYUVOverlay(vp->bmp);

    vp->bmp = SDL_CreateYUVOverlay(is->video_st->codec->width,

                                   is->video_st->codec->height,

                                   SDL_YV12_OVERLAY,

                                   screen);

    vp->width = is->video_st->codec->width;

    vp->height = is->video_st->codec->height;

    SDL_LockMutex(is->pictq_mutex);

    vp->allocated = 1;

    SDL_CondSignal(is->pictq_cond);

    SDL_UnlockMutex(is->pictq_mutex);

}

/**

 *

 * @param pts the dts of the pkt / pts of the frame and guessed if not known

 */

static int queue_picture(VideoState *is, AVFrame *src_frame, double pts)

{

    VideoPicture *vp;

    int dst_pix_fmt;

    /* wait until we have space to put a new picture */

    SDL_LockMutex(is->pictq_mutex);

    while (is->pictq_size >= VIDEO_PICTURE_QUEUE_SIZE &&

           !is->videoq.abort_request) {

        SDL_CondWait(is->pictq_cond, is->pictq_mutex);

    }

    SDL_UnlockMutex(is->pictq_mutex);

    if (is->videoq.abort_request)

        return -1;

    vp = &is->pictq[is->pictq_windex];

    /* alloc or resize hardware picture buffer */

    if (!vp->bmp ||

        vp->width != is->video_st->codec->width ||

        vp->height != is->video_st->codec->height) {

        SDL_Event event;

        vp->allocated = 0;

        /* the allocation must be done in the main thread to avoid

           locking problems */

        event.type = FF_ALLOC_EVENT;

        event.user.data1 = is;

        SDL_PushEvent(&event);

        /* wait until the picture is allocated */

        SDL_LockMutex(is->pictq_mutex);

        while (!vp->allocated && !is->videoq.abort_request) {

            SDL_CondWait(is->pictq_cond, is->pictq_mutex);

        }

        SDL_UnlockMutex(is->pictq_mutex);

        if (is->videoq.abort_request)

            return -1;

    }

    /* if the frame is not skipped, then display it */

    if (vp->bmp) {

        AVPicture pict;

        /* get a pointer on the bitmap */

        SDL_LockYUVOverlay (vp->bmp);

        dst_pix_fmt = PIX_FMT_YUV420P;

        memset(&pict,0,sizeof(AVPicture));

        pict.data[0] = vp->bmp->pixels[0];

        pict.data[1] = vp->bmp->pixels[2];

        pict.data[2] = vp->bmp->pixels[1];

        pict.linesize[0] = vp->bmp->pitches[0];

        pict.linesize[1] = vp->bmp->pitches[2];

        pict.linesize[2] = vp->bmp->pitches[1];

        sws_flags = av_get_int(sws_opts, "sws_flags", NULL);

        is->img_convert_ctx = sws_getCachedContext(is->img_convert_ctx,

            is->video_st->codec->width, is->video_st->codec->height,

            is->video_st->codec->pix_fmt,

            is->video_st->codec->width, is->video_st->codec->height,

            dst_pix_fmt, sws_flags, NULL, NULL, NULL);

        if (is->img_convert_ctx == NULL) {

            fprintf(stderr, "Cannot initialize the conversion context\n");

            exit(1);

        }

        sws_scale(is->img_convert_ctx, src_frame->data, src_frame->linesize,

                  0, is->video_st->codec->height, pict.data, pict.linesize);

        /* update the bitmap content */

        SDL_UnlockYUVOverlay(vp->bmp);

        vp->pts = pts;

        /* now we can update the picture count */

        if (++is->pictq_windex == VIDEO_PICTURE_QUEUE_SIZE)

            is->pictq_windex = 0;

        SDL_LockMutex(is->pictq_mutex);

        is->pictq_size++;

        //We must schedule in a mutex as we must store the timer id before the timer dies or might end up freeing a alraedy freed id

        vp->timer_id= schedule_refresh(is, (int)(compute_frame_delay(vp->pts, is) * 1000 + 0.5));

        SDL_UnlockMutex(is->pictq_mutex);

    }

    return 0;

}

/**

 * compute the exact PTS for the picture if it is omitted in the stream

 * @param pts1 the dts of the pkt / pts of the frame

 */

static int output_picture2(VideoState *is, AVFrame *src_frame, double pts1)

{

    double frame_delay, pts;

    pts = pts1;

    if (pts != 0) {

        /* update video clock with pts, if present */

        is->video_clock = pts;

    } else {

        pts = is->video_clock;

    }

    /* update video clock for next frame */

    frame_delay = av_q2d(is->video_st->codec->time_base);

    /* for MPEG2, the frame can be repeated, so we update the

       clock accordingly */

    frame_delay += src_frame->repeat_pict * (frame_delay * 0.5);

    is->video_clock += frame_delay;

#if defined(DEBUG_SYNC) && 0

    {

        int ftype;

        if (src_frame->pict_type == FF_B_TYPE)

            ftype = 'B';

        else if (src_frame->pict_type == FF_I_TYPE)

            ftype = 'I';

        else

            ftype = 'P';

        printf("frame_type=%c clock=%0.3f pts=%0.3f\n",

               ftype, pts, pts1);

    }

#endif

    return queue_picture(is, src_frame, pts);

}

static int video_thread(void *arg)

{

    VideoState *is = arg;

    AVPacket pkt1, *pkt = &pkt1;

    int len1, got_picture, i;

    AVFrame *frame= avcodec_alloc_frame();

    double pts;

    for(;;) {

        while (is->paused && !is->videoq.abort_request) {

            SDL_Delay(10);

        }

        if (packet_queue_get(&is->videoq, pkt, 1) < 0)

            break;

        if(pkt->data == flush_pkt.data){

            avcodec_flush_buffers(is->video_st->codec);

            SDL_LockMutex(is->pictq_mutex);

            //Make sure there are no long delay timers (ideally we should just flush the que but thats harder)

            for(i=0; i<VIDEO_PICTURE_QUEUE_SIZE; i++){

                if(is->pictq[i].timer_id){

                    SDL_RemoveTimer(is->pictq[i].timer_id);

                    is->pictq[i].timer_id=0;

                    schedule_refresh(is, 1);

                }

            }