OSDN Git Service

Merge remote-tracking branch 'qatar/master'
[coroid/ffmpeg_saccubus.git] / ffplay.c
1 /*
2  * ffplay : Simple Media Player based on the FFmpeg libraries
3  * Copyright (c) 2003 Fabrice Bellard
4  *
5  * This file is part of FFmpeg.
6  *
7  * FFmpeg is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Lesser General Public
9  * License as published by the Free Software Foundation; either
10  * version 2.1 of the License, or (at your option) any later version.
11  *
12  * FFmpeg is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * Lesser General Public License for more details.
16  *
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
20  */
21
22 #include "config.h"
23 #include <inttypes.h>
24 #include <math.h>
25 #include <limits.h>
26 #include "libavutil/avstring.h"
27 #include "libavutil/colorspace.h"
28 #include "libavutil/mathematics.h"
29 #include "libavutil/pixdesc.h"
30 #include "libavutil/imgutils.h"
31 #include "libavutil/dict.h"
32 #include "libavutil/parseutils.h"
33 #include "libavutil/samplefmt.h"
34 #include "libavutil/avassert.h"
35 #include "libavformat/avformat.h"
36 #include "libavdevice/avdevice.h"
37 #include "libswscale/swscale.h"
38 #include "libavcodec/audioconvert.h"
39 #include "libavutil/opt.h"
40 #include "libavcodec/avfft.h"
41
42 #if CONFIG_AVFILTER
43 # include "libavfilter/avcodec.h"
44 # include "libavfilter/avfilter.h"
45 # include "libavfilter/avfiltergraph.h"
46 # include "libavfilter/vsink_buffer.h"
47 #endif
48
49 #include <SDL.h>
50 #include <SDL_thread.h>
51
52 #include "cmdutils.h"
53
54 #include <unistd.h>
55 #include <assert.h>
56
57 const char program_name[] = "ffplay";
58 const int program_birth_year = 2003;
59
60 #define MAX_QUEUE_SIZE (15 * 1024 * 1024)
61 #define MIN_AUDIOQ_SIZE (20 * 16 * 1024)
62 #define MIN_FRAMES 5
63
64 /* SDL audio buffer size, in samples. Should be small to have precise
65    A/V sync as SDL does not have hardware buffer fullness info. */
66 #define SDL_AUDIO_BUFFER_SIZE 1024
67
68 /* no AV sync correction is done if below the AV sync threshold */
69 #define AV_SYNC_THRESHOLD 0.01
70 /* no AV correction is done if too big error */
71 #define AV_NOSYNC_THRESHOLD 10.0
72
73 #define FRAME_SKIP_FACTOR 0.05
74
75 /* maximum audio speed change to get correct sync */
76 #define SAMPLE_CORRECTION_PERCENT_MAX 10
77
78 /* we use about AUDIO_DIFF_AVG_NB A-V differences to make the average */
79 #define AUDIO_DIFF_AVG_NB   20
80
81 /* NOTE: the size must be big enough to compensate the hardware audio buffersize size */
82 #define SAMPLE_ARRAY_SIZE (2*65536)
83
84 static int sws_flags = SWS_BICUBIC;
85
86 typedef struct PacketQueue {
87     AVPacketList *first_pkt, *last_pkt;
88     int nb_packets;
89     int size;
90     int abort_request;
91     SDL_mutex *mutex;
92     SDL_cond *cond;
93 } PacketQueue;
94
95 #define VIDEO_PICTURE_QUEUE_SIZE 2
96 #define SUBPICTURE_QUEUE_SIZE 4
97
98 typedef struct VideoPicture {
99     double pts;                                  ///<presentation time stamp for this picture
100     double target_clock;                         ///<av_gettime() time at which this should be displayed ideally
101     double duration;                             ///<expected duration of the frame
102     int64_t pos;                                 ///<byte position in file
103     SDL_Overlay *bmp;
104     int width, height; /* source height & width */
105     int allocated;
106     enum PixelFormat pix_fmt;
107
108 #if CONFIG_AVFILTER
109     AVFilterBufferRef *picref;
110 #endif
111 } VideoPicture;
112
113 typedef struct SubPicture {
114     double pts; /* presentation time stamp for this picture */
115     AVSubtitle sub;
116 } SubPicture;
117
118 enum {
119     AV_SYNC_AUDIO_MASTER, /* default choice */
120     AV_SYNC_VIDEO_MASTER,
121     AV_SYNC_EXTERNAL_CLOCK, /* synchronize to an external clock */
122 };
123
124 typedef struct VideoState {
125     SDL_Thread *read_tid;
126     SDL_Thread *video_tid;
127     SDL_Thread *refresh_tid;
128     AVInputFormat *iformat;
129     int no_background;
130     int abort_request;
131     int paused;
132     int last_paused;
133     int seek_req;
134     int seek_flags;
135     int64_t seek_pos;
136     int64_t seek_rel;
137     int read_pause_return;
138     AVFormatContext *ic;
139
140     int audio_stream;
141
142     int av_sync_type;
143     double external_clock; /* external clock base */
144     int64_t external_clock_time;
145
146     double audio_clock;
147     double audio_diff_cum; /* used for AV difference average computation */
148     double audio_diff_avg_coef;
149     double audio_diff_threshold;
150     int audio_diff_avg_count;
151     AVStream *audio_st;
152     PacketQueue audioq;
153     int audio_hw_buf_size;
154     /* samples output by the codec. we reserve more space for avsync
155        compensation */
156     DECLARE_ALIGNED(16,uint8_t,audio_buf1)[(AVCODEC_MAX_AUDIO_FRAME_SIZE * 3) / 2];
157     DECLARE_ALIGNED(16,uint8_t,audio_buf2)[(AVCODEC_MAX_AUDIO_FRAME_SIZE * 3) / 2];
158     uint8_t *audio_buf;
159     unsigned int audio_buf_size; /* in bytes */
160     int audio_buf_index; /* in bytes */
161     int audio_write_buf_size;
162     AVPacket audio_pkt_temp;
163     AVPacket audio_pkt;
164     enum AVSampleFormat audio_src_fmt;
165     AVAudioConvert *reformat_ctx;
166     double audio_current_pts;
167     double audio_current_pts_drift;
168
169     enum ShowMode {
170         SHOW_MODE_NONE = -1, SHOW_MODE_VIDEO = 0, SHOW_MODE_WAVES, SHOW_MODE_RDFT, SHOW_MODE_NB
171     } show_mode;
172     int16_t sample_array[SAMPLE_ARRAY_SIZE];
173     int sample_array_index;
174     int last_i_start;
175     RDFTContext *rdft;
176     int rdft_bits;
177     FFTSample *rdft_data;
178     int xpos;
179
180     SDL_Thread *subtitle_tid;
181     int subtitle_stream;
182     int subtitle_stream_changed;
183     AVStream *subtitle_st;
184     PacketQueue subtitleq;
185     SubPicture subpq[SUBPICTURE_QUEUE_SIZE];
186     int subpq_size, subpq_rindex, subpq_windex;
187     SDL_mutex *subpq_mutex;
188     SDL_cond *subpq_cond;
189
190     double frame_timer;
191     double frame_last_pts;
192     double frame_last_delay;
193     double video_clock;                          ///<pts of last decoded frame / predicted pts of next decoded frame
194     int video_stream;
195     AVStream *video_st;
196     PacketQueue videoq;
197     double video_current_pts;                    ///<current displayed pts (different from video_clock if frame fifos are used)
198     double video_current_pts_drift;              ///<video_current_pts - time (av_gettime) at which we updated video_current_pts - used to have running video pts
199     int64_t video_current_pos;                   ///<current displayed file pos
200     VideoPicture pictq[VIDEO_PICTURE_QUEUE_SIZE];
201     int pictq_size, pictq_rindex, pictq_windex;
202     SDL_mutex *pictq_mutex;
203     SDL_cond *pictq_cond;
204 #if !CONFIG_AVFILTER
205     struct SwsContext *img_convert_ctx;
206 #endif
207
208     char filename[1024];
209     int width, height, xleft, ytop;
210     int step;
211
212 #if CONFIG_AVFILTER
213     AVFilterContext *out_video_filter;          ///<the last filter in the video chain
214 #endif
215
216     float skip_frames;
217     float skip_frames_index;
218     int refresh;
219 } VideoState;
220
221 static int opt_help(const char *opt, const char *arg);
222
223 /* options specified by the user */
224 static AVInputFormat *file_iformat;
225 static const char *input_filename;
226 static const char *window_title;
227 static int fs_screen_width;
228 static int fs_screen_height;
229 static int screen_width = 0;
230 static int screen_height = 0;
231 static int audio_disable;
232 static int video_disable;
233 static int wanted_stream[AVMEDIA_TYPE_NB]={
234     [AVMEDIA_TYPE_AUDIO]=-1,
235     [AVMEDIA_TYPE_VIDEO]=-1,
236     [AVMEDIA_TYPE_SUBTITLE]=-1,
237 };
238 static int seek_by_bytes=-1;
239 static int display_disable;
240 static int show_status = 1;
241 static int av_sync_type = AV_SYNC_AUDIO_MASTER;
242 static int64_t start_time = AV_NOPTS_VALUE;
243 static int64_t duration = AV_NOPTS_VALUE;
244 static int thread_count = 1;
245 static int workaround_bugs = 1;
246 static int fast = 0;
247 static int genpts = 0;
248 static int lowres = 0;
249 static int idct = FF_IDCT_AUTO;
250 static enum AVDiscard skip_frame= AVDISCARD_DEFAULT;
251 static enum AVDiscard skip_idct= AVDISCARD_DEFAULT;
252 static enum AVDiscard skip_loop_filter= AVDISCARD_DEFAULT;
253 static int error_recognition = FF_ER_CAREFUL;
254 static int error_concealment = 3;
255 static int decoder_reorder_pts= -1;
256 static int autoexit;
257 static int exit_on_keydown;
258 static int exit_on_mousedown;
259 static int loop=1;
260 static int framedrop=-1;
261 static enum ShowMode show_mode = SHOW_MODE_NONE;
262
263 static int rdftspeed=20;
264 #if CONFIG_AVFILTER
265 static char *vfilters = NULL;
266 #endif
267
268 /* current context */
269 static int is_full_screen;
270 static int64_t audio_callback_time;
271
272 static AVPacket flush_pkt;
273
274 #define FF_ALLOC_EVENT   (SDL_USEREVENT)
275 #define FF_REFRESH_EVENT (SDL_USEREVENT + 1)
276 #define FF_QUIT_EVENT    (SDL_USEREVENT + 2)
277
278 static SDL_Surface *screen;
279
280 static int packet_queue_put(PacketQueue *q, AVPacket *pkt)
281 {
282     AVPacketList *pkt1;
283
284     /* duplicate the packet */
285     if (pkt!=&flush_pkt && av_dup_packet(pkt) < 0)
286         return -1;
287
288     pkt1 = av_malloc(sizeof(AVPacketList));
289     if (!pkt1)
290         return -1;
291     pkt1->pkt = *pkt;
292     pkt1->next = NULL;
293
294
295     SDL_LockMutex(q->mutex);
296
297     if (!q->last_pkt)
298
299         q->first_pkt = pkt1;
300     else
301         q->last_pkt->next = pkt1;
302     q->last_pkt = pkt1;
303     q->nb_packets++;
304     q->size += pkt1->pkt.size + sizeof(*pkt1);
305     /* XXX: should duplicate packet data in DV case */
306     SDL_CondSignal(q->cond);
307
308     SDL_UnlockMutex(q->mutex);
309     return 0;
310 }
311
312 /* packet queue handling */
313 static void packet_queue_init(PacketQueue *q)
314 {
315     memset(q, 0, sizeof(PacketQueue));
316     q->mutex = SDL_CreateMutex();
317     q->cond = SDL_CreateCond();
318     packet_queue_put(q, &flush_pkt);
319 }
320
321 static void packet_queue_flush(PacketQueue *q)
322 {
323     AVPacketList *pkt, *pkt1;
324
325     SDL_LockMutex(q->mutex);
326     for(pkt = q->first_pkt; pkt != NULL; pkt = pkt1) {
327         pkt1 = pkt->next;
328         av_free_packet(&pkt->pkt);
329         av_freep(&pkt);
330     }
331     q->last_pkt = NULL;
332     q->first_pkt = NULL;
333     q->nb_packets = 0;
334     q->size = 0;
335     SDL_UnlockMutex(q->mutex);
336 }
337
338 static void packet_queue_end(PacketQueue *q)
339 {
340     packet_queue_flush(q);
341     SDL_DestroyMutex(q->mutex);
342     SDL_DestroyCond(q->cond);
343 }
344
345 static void packet_queue_abort(PacketQueue *q)
346 {
347     SDL_LockMutex(q->mutex);
348
349     q->abort_request = 1;
350
351     SDL_CondSignal(q->cond);
352
353     SDL_UnlockMutex(q->mutex);
354 }
355
356 /* return < 0 if aborted, 0 if no packet and > 0 if packet.  */
357 static int packet_queue_get(PacketQueue *q, AVPacket *pkt, int block)
358 {
359     AVPacketList *pkt1;
360     int ret;
361
362     SDL_LockMutex(q->mutex);
363
364     for(;;) {
365         if (q->abort_request) {
366             ret = -1;
367             break;
368         }
369
370         pkt1 = q->first_pkt;
371         if (pkt1) {
372             q->first_pkt = pkt1->next;
373             if (!q->first_pkt)
374                 q->last_pkt = NULL;
375             q->nb_packets--;
376             q->size -= pkt1->pkt.size + sizeof(*pkt1);
377             *pkt = pkt1->pkt;
378             av_free(pkt1);
379             ret = 1;
380             break;
381         } else if (!block) {
382             ret = 0;
383             break;
384         } else {
385             SDL_CondWait(q->cond, q->mutex);
386         }
387     }
388     SDL_UnlockMutex(q->mutex);
389     return ret;
390 }
391
392 static inline void fill_rectangle(SDL_Surface *screen,
393                                   int x, int y, int w, int h, int color)
394 {
395     SDL_Rect rect;
396     rect.x = x;
397     rect.y = y;
398     rect.w = w;
399     rect.h = h;
400     SDL_FillRect(screen, &rect, color);
401 }
402
403 #define ALPHA_BLEND(a, oldp, newp, s)\
404 ((((oldp << s) * (255 - (a))) + (newp * (a))) / (255 << s))
405
406 #define RGBA_IN(r, g, b, a, s)\
407 {\
408     unsigned int v = ((const uint32_t *)(s))[0];\
409     a = (v >> 24) & 0xff;\
410     r = (v >> 16) & 0xff;\
411     g = (v >> 8) & 0xff;\
412     b = v & 0xff;\
413 }
414
415 #define YUVA_IN(y, u, v, a, s, pal)\
416 {\
417     unsigned int val = ((const uint32_t *)(pal))[*(const uint8_t*)(s)];\
418     a = (val >> 24) & 0xff;\
419     y = (val >> 16) & 0xff;\
420     u = (val >> 8) & 0xff;\
421     v = val & 0xff;\
422 }
423
424 #define YUVA_OUT(d, y, u, v, a)\
425 {\
426     ((uint32_t *)(d))[0] = (a << 24) | (y << 16) | (u << 8) | v;\
427 }
428
429
430 #define BPP 1
431
432 static void blend_subrect(AVPicture *dst, const AVSubtitleRect *rect, int imgw, int imgh)
433 {
434     int wrap, wrap3, width2, skip2;
435     int y, u, v, a, u1, v1, a1, w, h;
436     uint8_t *lum, *cb, *cr;
437     const uint8_t *p;
438     const uint32_t *pal;
439     int dstx, dsty, dstw, dsth;
440
441     dstw = av_clip(rect->w, 0, imgw);
442     dsth = av_clip(rect->h, 0, imgh);
443     dstx = av_clip(rect->x, 0, imgw - dstw);
444     dsty = av_clip(rect->y, 0, imgh - dsth);
445     lum = dst->data[0] + dsty * dst->linesize[0];
446     cb = dst->data[1] + (dsty >> 1) * dst->linesize[1];
447     cr = dst->data[2] + (dsty >> 1) * dst->linesize[2];
448
449     width2 = ((dstw + 1) >> 1) + (dstx & ~dstw & 1);
450     skip2 = dstx >> 1;
451     wrap = dst->linesize[0];
452     wrap3 = rect->pict.linesize[0];
453     p = rect->pict.data[0];
454     pal = (const uint32_t *)rect->pict.data[1];  /* Now in YCrCb! */
455
456     if (dsty & 1) {
457         lum += dstx;
458         cb += skip2;
459         cr += skip2;
460
461         if (dstx & 1) {
462             YUVA_IN(y, u, v, a, p, pal);
463             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
464             cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);
465             cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);
466             cb++;
467             cr++;
468             lum++;
469             p += BPP;
470         }
471         for(w = dstw - (dstx & 1); w >= 2; w -= 2) {
472             YUVA_IN(y, u, v, a, p, pal);
473             u1 = u;
474             v1 = v;
475             a1 = a;
476             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
477
478             YUVA_IN(y, u, v, a, p + BPP, pal);
479             u1 += u;
480             v1 += v;
481             a1 += a;
482             lum[1] = ALPHA_BLEND(a, lum[1], y, 0);
483             cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);
484             cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);
485             cb++;
486             cr++;
487             p += 2 * BPP;
488             lum += 2;
489         }
490         if (w) {
491             YUVA_IN(y, u, v, a, p, pal);
492             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
493             cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);
494             cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);
495             p++;
496             lum++;
497         }
498         p += wrap3 - dstw * BPP;
499         lum += wrap - dstw - dstx;
500         cb += dst->linesize[1] - width2 - skip2;
501         cr += dst->linesize[2] - width2 - skip2;
502     }
503     for(h = dsth - (dsty & 1); h >= 2; h -= 2) {
504         lum += dstx;
505         cb += skip2;
506         cr += skip2;
507
508         if (dstx & 1) {
509             YUVA_IN(y, u, v, a, p, pal);
510             u1 = u;
511             v1 = v;
512             a1 = a;
513             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
514             p += wrap3;
515             lum += wrap;
516             YUVA_IN(y, u, v, a, p, pal);
517             u1 += u;
518             v1 += v;
519             a1 += a;
520             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
521             cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);
522             cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);
523             cb++;
524             cr++;
525             p += -wrap3 + BPP;
526             lum += -wrap + 1;
527         }
528         for(w = dstw - (dstx & 1); w >= 2; w -= 2) {
529             YUVA_IN(y, u, v, a, p, pal);
530             u1 = u;
531             v1 = v;
532             a1 = a;
533             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
534
535             YUVA_IN(y, u, v, a, p + BPP, pal);
536             u1 += u;
537             v1 += v;
538             a1 += a;
539             lum[1] = ALPHA_BLEND(a, lum[1], y, 0);
540             p += wrap3;
541             lum += wrap;
542
543             YUVA_IN(y, u, v, a, p, pal);
544             u1 += u;
545             v1 += v;
546             a1 += a;
547             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
548
549             YUVA_IN(y, u, v, a, p + BPP, pal);
550             u1 += u;
551             v1 += v;
552             a1 += a;
553             lum[1] = ALPHA_BLEND(a, lum[1], y, 0);
554
555             cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 2);
556             cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 2);
557
558             cb++;
559             cr++;
560             p += -wrap3 + 2 * BPP;
561             lum += -wrap + 2;
562         }
563         if (w) {
564             YUVA_IN(y, u, v, a, p, pal);
565             u1 = u;
566             v1 = v;
567             a1 = a;
568             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
569             p += wrap3;
570             lum += wrap;
571             YUVA_IN(y, u, v, a, p, pal);
572             u1 += u;
573             v1 += v;
574             a1 += a;
575             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
576             cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u1, 1);
577             cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v1, 1);
578             cb++;
579             cr++;
580             p += -wrap3 + BPP;
581             lum += -wrap + 1;
582         }
583         p += wrap3 + (wrap3 - dstw * BPP);
584         lum += wrap + (wrap - dstw - dstx);
585         cb += dst->linesize[1] - width2 - skip2;
586         cr += dst->linesize[2] - width2 - skip2;
587     }
588     /* handle odd height */
589     if (h) {
590         lum += dstx;
591         cb += skip2;
592         cr += skip2;
593
594         if (dstx & 1) {
595             YUVA_IN(y, u, v, a, p, pal);
596             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
597             cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);
598             cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);
599             cb++;
600             cr++;
601             lum++;
602             p += BPP;
603         }
604         for(w = dstw - (dstx & 1); w >= 2; w -= 2) {
605             YUVA_IN(y, u, v, a, p, pal);
606             u1 = u;
607             v1 = v;
608             a1 = a;
609             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
610
611             YUVA_IN(y, u, v, a, p + BPP, pal);
612             u1 += u;
613             v1 += v;
614             a1 += a;
615             lum[1] = ALPHA_BLEND(a, lum[1], y, 0);
616             cb[0] = ALPHA_BLEND(a1 >> 2, cb[0], u, 1);
617             cr[0] = ALPHA_BLEND(a1 >> 2, cr[0], v, 1);
618             cb++;
619             cr++;
620             p += 2 * BPP;
621             lum += 2;
622         }
623         if (w) {
624             YUVA_IN(y, u, v, a, p, pal);
625             lum[0] = ALPHA_BLEND(a, lum[0], y, 0);
626             cb[0] = ALPHA_BLEND(a >> 2, cb[0], u, 0);
627             cr[0] = ALPHA_BLEND(a >> 2, cr[0], v, 0);
628         }
629     }
630 }
631
632 static void free_subpicture(SubPicture *sp)
633 {
634     avsubtitle_free(&sp->sub);
635 }
636
637 static void video_image_display(VideoState *is)
638 {
639     VideoPicture *vp;
640     SubPicture *sp;
641     AVPicture pict;
642     float aspect_ratio;
643     int width, height, x, y;
644     SDL_Rect rect;
645     int i;
646
647     vp = &is->pictq[is->pictq_rindex];
648     if (vp->bmp) {
649 #if CONFIG_AVFILTER
650          if (vp->picref->video->sample_aspect_ratio.num == 0)
651              aspect_ratio = 0;
652          else
653              aspect_ratio = av_q2d(vp->picref->video->sample_aspect_ratio);
654 #else
655
656         /* XXX: use variable in the frame */
657         if (is->video_st->sample_aspect_ratio.num)
658             aspect_ratio = av_q2d(is->video_st->sample_aspect_ratio);
659         else if (is->video_st->codec->sample_aspect_ratio.num)
660             aspect_ratio = av_q2d(is->video_st->codec->sample_aspect_ratio);
661         else
662             aspect_ratio = 0;
663 #endif
664         if (aspect_ratio <= 0.0)
665             aspect_ratio = 1.0;
666         aspect_ratio *= (float)vp->width / (float)vp->height;
667
668         if (is->subtitle_st) {
669             if (is->subpq_size > 0) {
670                 sp = &is->subpq[is->subpq_rindex];
671
672                 if (vp->pts >= sp->pts + ((float) sp->sub.start_display_time / 1000)) {
673                     SDL_LockYUVOverlay (vp->bmp);
674
675                     pict.data[0] = vp->bmp->pixels[0];
676                     pict.data[1] = vp->bmp->pixels[2];
677                     pict.data[2] = vp->bmp->pixels[1];
678
679                     pict.linesize[0] = vp->bmp->pitches[0];
680                     pict.linesize[1] = vp->bmp->pitches[2];
681                     pict.linesize[2] = vp->bmp->pitches[1];
682
683                     for (i = 0; i < sp->sub.num_rects; i++)
684                         blend_subrect(&pict, sp->sub.rects[i],
685                                       vp->bmp->w, vp->bmp->h);
686
687                     SDL_UnlockYUVOverlay (vp->bmp);
688                 }
689             }
690         }
691
692
693         /* XXX: we suppose the screen has a 1.0 pixel ratio */
694         height = is->height;
695         width = ((int)rint(height * aspect_ratio)) & ~1;
696         if (width > is->width) {
697             width = is->width;
698             height = ((int)rint(width / aspect_ratio)) & ~1;
699         }
700         x = (is->width - width) / 2;
701         y = (is->height - height) / 2;
702         is->no_background = 0;
703         rect.x = is->xleft + x;
704         rect.y = is->ytop  + y;
705         rect.w = FFMAX(width,  1);
706         rect.h = FFMAX(height, 1);
707         SDL_DisplayYUVOverlay(vp->bmp, &rect);
708     }
709 }
710
711 static inline int compute_mod(int a, int b)
712 {
713     return a < 0 ? a%b + b : a%b;
714 }
715
716 static void video_audio_display(VideoState *s)
717 {
718     int i, i_start, x, y1, y, ys, delay, n, nb_display_channels;
719     int ch, channels, h, h2, bgcolor, fgcolor;
720     int16_t time_diff;
721     int rdft_bits, nb_freq;
722
723     for(rdft_bits=1; (1<<rdft_bits)<2*s->height; rdft_bits++)
724         ;
725     nb_freq= 1<<(rdft_bits-1);
726
727     /* compute display index : center on currently output samples */
728     channels = s->audio_st->codec->channels;
729     nb_display_channels = channels;
730     if (!s->paused) {
731         int data_used= s->show_mode == SHOW_MODE_WAVES ? s->width : (2*nb_freq);
732         n = 2 * channels;
733         delay = s->audio_write_buf_size;
734         delay /= n;
735
736         /* to be more precise, we take into account the time spent since
737            the last buffer computation */
738         if (audio_callback_time) {
739             time_diff = av_gettime() - audio_callback_time;
740             delay -= (time_diff * s->audio_st->codec->sample_rate) / 1000000;
741         }
742
743         delay += 2*data_used;
744         if (delay < data_used)
745             delay = data_used;
746
747         i_start= x = compute_mod(s->sample_array_index - delay * channels, SAMPLE_ARRAY_SIZE);
748         if (s->show_mode == SHOW_MODE_WAVES) {
749             h= INT_MIN;
750             for(i=0; i<1000; i+=channels){
751                 int idx= (SAMPLE_ARRAY_SIZE + x - i) % SAMPLE_ARRAY_SIZE;
752                 int a= s->sample_array[idx];
753                 int b= s->sample_array[(idx + 4*channels)%SAMPLE_ARRAY_SIZE];
754                 int c= s->sample_array[(idx + 5*channels)%SAMPLE_ARRAY_SIZE];
755                 int d= s->sample_array[(idx + 9*channels)%SAMPLE_ARRAY_SIZE];
756                 int score= a-d;
757                 if(h<score && (b^c)<0){
758                     h= score;
759                     i_start= idx;
760                 }
761             }
762         }
763
764         s->last_i_start = i_start;
765     } else {
766         i_start = s->last_i_start;
767     }
768
769     bgcolor = SDL_MapRGB(screen->format, 0x00, 0x00, 0x00);
770     if (s->show_mode == SHOW_MODE_WAVES) {
771         fill_rectangle(screen,
772                        s->xleft, s->ytop, s->width, s->height,
773                        bgcolor);
774
775         fgcolor = SDL_MapRGB(screen->format, 0xff, 0xff, 0xff);
776
777         /* total height for one channel */
778         h = s->height / nb_display_channels;
779         /* graph height / 2 */
780         h2 = (h * 9) / 20;
781         for(ch = 0;ch < nb_display_channels; ch++) {
782             i = i_start + ch;
783             y1 = s->ytop + ch * h + (h / 2); /* position of center line */
784             for(x = 0; x < s->width; x++) {
785                 y = (s->sample_array[i] * h2) >> 15;
786                 if (y < 0) {
787                     y = -y;
788                     ys = y1 - y;
789                 } else {
790                     ys = y1;
791                 }
792                 fill_rectangle(screen,
793                                s->xleft + x, ys, 1, y,
794                                fgcolor);
795                 i += channels;
796                 if (i >= SAMPLE_ARRAY_SIZE)
797                     i -= SAMPLE_ARRAY_SIZE;
798             }
799         }
800
801         fgcolor = SDL_MapRGB(screen->format, 0x00, 0x00, 0xff);
802
803         for(ch = 1;ch < nb_display_channels; ch++) {
804             y = s->ytop + ch * h;
805             fill_rectangle(screen,
806                            s->xleft, y, s->width, 1,
807                            fgcolor);
808         }
809         SDL_UpdateRect(screen, s->xleft, s->ytop, s->width, s->height);
810     }else{
811         nb_display_channels= FFMIN(nb_display_channels, 2);
812         if(rdft_bits != s->rdft_bits){
813             av_rdft_end(s->rdft);
814             av_free(s->rdft_data);
815             s->rdft = av_rdft_init(rdft_bits, DFT_R2C);
816             s->rdft_bits= rdft_bits;
817             s->rdft_data= av_malloc(4*nb_freq*sizeof(*s->rdft_data));
818         }
819         {
820             FFTSample *data[2];
821             for(ch = 0;ch < nb_display_channels; ch++) {
822                 data[ch] = s->rdft_data + 2*nb_freq*ch;
823                 i = i_start + ch;
824                 for(x = 0; x < 2*nb_freq; x++) {
825                     double w= (x-nb_freq)*(1.0/nb_freq);
826                     data[ch][x]= s->sample_array[i]*(1.0-w*w);
827                     i += channels;
828                     if (i >= SAMPLE_ARRAY_SIZE)
829                         i -= SAMPLE_ARRAY_SIZE;
830                 }
831                 av_rdft_calc(s->rdft, data[ch]);
832             }
833             //least efficient way to do this, we should of course directly access it but its more than fast enough
834             for(y=0; y<s->height; y++){
835                 double w= 1/sqrt(nb_freq);
836                 int a= sqrt(w*sqrt(data[0][2*y+0]*data[0][2*y+0] + data[0][2*y+1]*data[0][2*y+1]));
837                 int b= (nb_display_channels == 2 ) ? sqrt(w*sqrt(data[1][2*y+0]*data[1][2*y+0]
838                        + data[1][2*y+1]*data[1][2*y+1])) : a;
839                 a= FFMIN(a,255);
840                 b= FFMIN(b,255);
841                 fgcolor = SDL_MapRGB(screen->format, a, b, (a+b)/2);
842
843                 fill_rectangle(screen,
844                             s->xpos, s->height-y, 1, 1,
845                             fgcolor);
846             }
847         }
848         SDL_UpdateRect(screen, s->xpos, s->ytop, 1, s->height);
849         s->xpos++;
850         if(s->xpos >= s->width)
851             s->xpos= s->xleft;
852     }
853 }
854
855 static void stream_close(VideoState *is)
856 {
857     VideoPicture *vp;
858     int i;
859     /* XXX: use a special url_shutdown call to abort parse cleanly */
860     is->abort_request = 1;
861     SDL_WaitThread(is->read_tid, NULL);
862     SDL_WaitThread(is->refresh_tid, NULL);
863
864     /* free all pictures */
865     for(i=0;i<VIDEO_PICTURE_QUEUE_SIZE; i++) {
866         vp = &is->pictq[i];
867 #if CONFIG_AVFILTER
868         if (vp->picref) {
869             avfilter_unref_buffer(vp->picref);
870             vp->picref = NULL;
871         }
872 #endif
873         if (vp->bmp) {
874             SDL_FreeYUVOverlay(vp->bmp);
875             vp->bmp = NULL;
876         }
877     }
878     SDL_DestroyMutex(is->pictq_mutex);
879     SDL_DestroyCond(is->pictq_cond);
880     SDL_DestroyMutex(is->subpq_mutex);
881     SDL_DestroyCond(is->subpq_cond);
882 #if !CONFIG_AVFILTER
883     if (is->img_convert_ctx)
884         sws_freeContext(is->img_convert_ctx);
885 #endif
886     av_free(is);
887 }
888
889 static void do_exit(VideoState *is)
890 {
891     if (is) {
892         stream_close(is);
893     }
894     av_lockmgr_register(NULL);
895     uninit_opts();
896 #if CONFIG_AVFILTER
897     avfilter_uninit();
898 #endif
899     if (show_status)
900         printf("\n");
901     SDL_Quit();
902     av_log(NULL, AV_LOG_QUIET, "%s", "");
903     exit(0);
904 }
905
906 static int video_open(VideoState *is){
907     int flags = SDL_HWSURFACE|SDL_ASYNCBLIT|SDL_HWACCEL;
908     int w,h;
909
910     if(is_full_screen) flags |= SDL_FULLSCREEN;
911     else               flags |= SDL_RESIZABLE;
912
913     if (is_full_screen && fs_screen_width) {
914         w = fs_screen_width;
915         h = fs_screen_height;
916     } else if(!is_full_screen && screen_width){
917         w = screen_width;
918         h = screen_height;
919 #if CONFIG_AVFILTER
920     }else if (is->out_video_filter && is->out_video_filter->inputs[0]){
921         w = is->out_video_filter->inputs[0]->w;
922         h = is->out_video_filter->inputs[0]->h;
923 #else
924     }else if (is->video_st && is->video_st->codec->width){
925         w = is->video_st->codec->width;
926         h = is->video_st->codec->height;
927 #endif
928     } else {
929         w = 640;
930         h = 480;
931     }
932     if(screen && is->width == screen->w && screen->w == w
933        && is->height== screen->h && screen->h == h)
934         return 0;
935
936 #ifndef __APPLE__
937     screen = SDL_SetVideoMode(w, h, 0, flags);
938 #else
939     /* setting bits_per_pixel = 0 or 32 causes blank video on OS X */
940     screen = SDL_SetVideoMode(w, h, 24, flags);
941 #endif
942     if (!screen) {
943         fprintf(stderr, "SDL: could not set video mode - exiting\n");
944         do_exit(is);
945     }
946     if (!window_title)
947         window_title = input_filename;
948     SDL_WM_SetCaption(window_title, window_title);
949
950     is->width = screen->w;
951     is->height = screen->h;
952
953     return 0;
954 }
955
956 /* display the current picture, if any */
957 static void video_display(VideoState *is)
958 {
959     if(!screen)
960         video_open(is);
961     if (is->audio_st && is->show_mode != SHOW_MODE_VIDEO)
962         video_audio_display(is);
963     else if (is->video_st)
964         video_image_display(is);
965 }
966
967 static int refresh_thread(void *opaque)
968 {
969     VideoState *is= opaque;
970     while(!is->abort_request){
971         SDL_Event event;
972         event.type = FF_REFRESH_EVENT;
973         event.user.data1 = opaque;
974         if(!is->refresh){
975             is->refresh=1;
976             SDL_PushEvent(&event);
977         }
978         //FIXME ideally we should wait the correct time but SDLs event passing is so slow it would be silly
979         usleep(is->audio_st && is->show_mode != SHOW_MODE_VIDEO ? rdftspeed*1000 : 5000);
980     }
981     return 0;
982 }
983
984 /* get the current audio clock value */
985 static double get_audio_clock(VideoState *is)
986 {
987     if (is->paused) {
988         return is->audio_current_pts;
989     } else {
990         return is->audio_current_pts_drift + av_gettime() / 1000000.0;
991     }
992 }
993
994 /* get the current video clock value */
995 static double get_video_clock(VideoState *is)
996 {
997     if (is->paused) {
998         return is->video_current_pts;
999     } else {
1000         return is->video_current_pts_drift + av_gettime() / 1000000.0;
1001     }
1002 }
1003
1004 /* get the current external clock value */
1005 static double get_external_clock(VideoState *is)
1006 {
1007     int64_t ti;
1008     ti = av_gettime();
1009     return is->external_clock + ((ti - is->external_clock_time) * 1e-6);
1010 }
1011
1012 /* get the current master clock value */
1013 static double get_master_clock(VideoState *is)
1014 {
1015     double val;
1016
1017     if (is->av_sync_type == AV_SYNC_VIDEO_MASTER) {
1018         if (is->video_st)
1019             val = get_video_clock(is);
1020         else
1021             val = get_audio_clock(is);
1022     } else if (is->av_sync_type == AV_SYNC_AUDIO_MASTER) {
1023         if (is->audio_st)
1024             val = get_audio_clock(is);
1025         else
1026             val = get_video_clock(is);
1027     } else {
1028         val = get_external_clock(is);
1029     }
1030     return val;
1031 }
1032
1033 /* seek in the stream */
1034 static void stream_seek(VideoState *is, int64_t pos, int64_t rel, int seek_by_bytes)
1035 {
1036     if (!is->seek_req) {
1037         is->seek_pos = pos;
1038         is->seek_rel = rel;
1039         is->seek_flags &= ~AVSEEK_FLAG_BYTE;
1040         if (seek_by_bytes)
1041             is->seek_flags |= AVSEEK_FLAG_BYTE;
1042         is->seek_req = 1;
1043     }
1044 }
1045
1046 /* pause or resume the video */
1047 static void stream_toggle_pause(VideoState *is)
1048 {
1049     if (is->paused) {
1050         is->frame_timer += av_gettime() / 1000000.0 + is->video_current_pts_drift - is->video_current_pts;
1051         if(is->read_pause_return != AVERROR(ENOSYS)){
1052             is->video_current_pts = is->video_current_pts_drift + av_gettime() / 1000000.0;
1053         }
1054         is->video_current_pts_drift = is->video_current_pts - av_gettime() / 1000000.0;
1055     }
1056     is->paused = !is->paused;
1057 }
1058
1059 static double compute_target_time(double frame_current_pts, VideoState *is)
1060 {
1061     double delay, sync_threshold, diff;
1062
1063     /* compute nominal delay */
1064     delay = frame_current_pts - is->frame_last_pts;
1065     if (delay <= 0 || delay >= 10.0) {
1066         /* if incorrect delay, use previous one */
1067         delay = is->frame_last_delay;
1068     } else {
1069         is->frame_last_delay = delay;
1070     }
1071     is->frame_last_pts = frame_current_pts;
1072
1073     /* update delay to follow master synchronisation source */
1074     if (((is->av_sync_type == AV_SYNC_AUDIO_MASTER && is->audio_st) ||
1075          is->av_sync_type == AV_SYNC_EXTERNAL_CLOCK)) {
1076         /* if video is slave, we try to correct big delays by
1077            duplicating or deleting a frame */
1078         diff = get_video_clock(is) - get_master_clock(is);
1079
1080         /* skip or repeat frame. We take into account the
1081            delay to compute the threshold. I still don't know
1082            if it is the best guess */
1083         sync_threshold = FFMAX(AV_SYNC_THRESHOLD, delay);
1084         if (fabs(diff) < AV_NOSYNC_THRESHOLD) {
1085             if (diff <= -sync_threshold)
1086                 delay = 0;
1087             else if (diff >= sync_threshold)
1088                 delay = 2 * delay;
1089         }
1090     }
1091     is->frame_timer += delay;
1092
1093     av_dlog(NULL, "video: delay=%0.3f pts=%0.3f A-V=%f\n",
1094             delay, frame_current_pts, -diff);
1095
1096     return is->frame_timer;
1097 }
1098
1099 /* called to display each frame */
1100 static void video_refresh(void *opaque)
1101 {
1102     VideoState *is = opaque;
1103     VideoPicture *vp;
1104
1105     SubPicture *sp, *sp2;
1106
1107     if (is->video_st) {
1108 retry:
1109         if (is->pictq_size == 0) {
1110             //nothing to do, no picture to display in the que
1111         } else {
1112             double time= av_gettime()/1000000.0;
1113             double next_target;
1114             /* dequeue the picture */
1115             vp = &is->pictq[is->pictq_rindex];
1116
1117             if(time < vp->target_clock)
1118                 return;
1119             /* update current video pts */
1120             is->video_current_pts = vp->pts;
1121             is->video_current_pts_drift = is->video_current_pts - time;
1122             is->video_current_pos = vp->pos;
1123             if(is->pictq_size > 1){
1124                 VideoPicture *nextvp= &is->pictq[(is->pictq_rindex+1)%VIDEO_PICTURE_QUEUE_SIZE];
1125                 assert(nextvp->target_clock >= vp->target_clock);
1126                 next_target= nextvp->target_clock;
1127             }else{
1128                 next_target= vp->target_clock + vp->duration;
1129             }
1130             if((framedrop>0 || (framedrop && is->audio_st)) && time > next_target){
1131                 is->skip_frames *= 1.0 + FRAME_SKIP_FACTOR;
1132                 if(is->pictq_size > 1 || time > next_target + 0.5){
1133                     /* update queue size and signal for next picture */
1134                     if (++is->pictq_rindex == VIDEO_PICTURE_QUEUE_SIZE)
1135                         is->pictq_rindex = 0;
1136
1137                     SDL_LockMutex(is->pictq_mutex);
1138                     is->pictq_size--;
1139                     SDL_CondSignal(is->pictq_cond);
1140                     SDL_UnlockMutex(is->pictq_mutex);
1141                     goto retry;
1142                 }
1143             }
1144
1145             if(is->subtitle_st) {
1146                 if (is->subtitle_stream_changed) {
1147                     SDL_LockMutex(is->subpq_mutex);
1148
1149                     while (is->subpq_size) {
1150                         free_subpicture(&is->subpq[is->subpq_rindex]);
1151
1152                         /* update queue size and signal for next picture */
1153                         if (++is->subpq_rindex == SUBPICTURE_QUEUE_SIZE)
1154                             is->subpq_rindex = 0;
1155
1156                         is->subpq_size--;
1157                     }
1158                     is->subtitle_stream_changed = 0;
1159
1160                     SDL_CondSignal(is->subpq_cond);
1161                     SDL_UnlockMutex(is->subpq_mutex);
1162                 } else {
1163                     if (is->subpq_size > 0) {
1164                         sp = &is->subpq[is->subpq_rindex];
1165
1166                         if (is->subpq_size > 1)
1167                             sp2 = &is->subpq[(is->subpq_rindex + 1) % SUBPICTURE_QUEUE_SIZE];
1168                         else
1169                             sp2 = NULL;
1170
1171                         if ((is->video_current_pts > (sp->pts + ((float) sp->sub.end_display_time / 1000)))
1172                                 || (sp2 && is->video_current_pts > (sp2->pts + ((float) sp2->sub.start_display_time / 1000))))
1173                         {
1174                             free_subpicture(sp);
1175
1176                             /* update queue size and signal for next picture */
1177                             if (++is->subpq_rindex == SUBPICTURE_QUEUE_SIZE)
1178                                 is->subpq_rindex = 0;
1179
1180                             SDL_LockMutex(is->subpq_mutex);
1181                             is->subpq_size--;
1182                             SDL_CondSignal(is->subpq_cond);
1183                             SDL_UnlockMutex(is->subpq_mutex);
1184                         }
1185                     }
1186                 }
1187             }
1188
1189             /* display picture */
1190             if (!display_disable)
1191                 video_display(is);
1192
1193             /* update queue size and signal for next picture */
1194             if (++is->pictq_rindex == VIDEO_PICTURE_QUEUE_SIZE)
1195                 is->pictq_rindex = 0;
1196
1197             SDL_LockMutex(is->pictq_mutex);
1198             is->pictq_size--;
1199             SDL_CondSignal(is->pictq_cond);
1200             SDL_UnlockMutex(is->pictq_mutex);
1201         }
1202     } else if (is->audio_st) {
1203         /* draw the next audio frame */
1204
1205         /* if only audio stream, then display the audio bars (better
1206            than nothing, just to test the implementation */
1207
1208         /* display picture */
1209         if (!display_disable)
1210             video_display(is);
1211     }
1212     if (show_status) {
1213         static int64_t last_time;
1214         int64_t cur_time;
1215         int aqsize, vqsize, sqsize;
1216         double av_diff;
1217
1218         cur_time = av_gettime();
1219         if (!last_time || (cur_time - last_time) >= 30000) {
1220             aqsize = 0;
1221             vqsize = 0;
1222             sqsize = 0;
1223             if (is->audio_st)
1224                 aqsize = is->audioq.size;
1225             if (is->video_st)
1226                 vqsize = is->videoq.size;
1227             if (is->subtitle_st)
1228                 sqsize = is->subtitleq.size;
1229             av_diff = 0;
1230             if (is->audio_st && is->video_st)
1231                 av_diff = get_audio_clock(is) - get_video_clock(is);
1232             printf("%7.2f A-V:%7.3f s:%3.1f aq=%5dKB vq=%5dKB sq=%5dB f=%"PRId64"/%"PRId64"   \r",
1233                    get_master_clock(is),
1234                    av_diff,
1235                    FFMAX(is->skip_frames-1, 0),
1236                    aqsize / 1024,
1237                    vqsize / 1024,
1238                    sqsize,
1239                    is->video_st ? is->video_st->codec->pts_correction_num_faulty_dts : 0,
1240                    is->video_st ? is->video_st->codec->pts_correction_num_faulty_pts : 0);
1241             fflush(stdout);
1242             last_time = cur_time;
1243         }
1244     }
1245 }
1246
1247 /* allocate a picture (needs to do that in main thread to avoid
1248    potential locking problems */
1249 static void alloc_picture(void *opaque)
1250 {
1251     VideoState *is = opaque;
1252     VideoPicture *vp;
1253
1254     vp = &is->pictq[is->pictq_windex];
1255
1256     if (vp->bmp)
1257         SDL_FreeYUVOverlay(vp->bmp);
1258
1259 #if CONFIG_AVFILTER
1260     if (vp->picref)
1261         avfilter_unref_buffer(vp->picref);
1262     vp->picref = NULL;
1263
1264     vp->width   = is->out_video_filter->inputs[0]->w;
1265     vp->height  = is->out_video_filter->inputs[0]->h;
1266     vp->pix_fmt = is->out_video_filter->inputs[0]->format;
1267 #else
1268     vp->width   = is->video_st->codec->width;
1269     vp->height  = is->video_st->codec->height;
1270     vp->pix_fmt = is->video_st->codec->pix_fmt;
1271 #endif
1272
1273     vp->bmp = SDL_CreateYUVOverlay(vp->width, vp->height,
1274                                    SDL_YV12_OVERLAY,
1275                                    screen);
1276     if (!vp->bmp || vp->bmp->pitches[0] < vp->width) {
1277         /* SDL allocates a buffer smaller than requested if the video
1278          * overlay hardware is unable to support the requested size. */
1279         fprintf(stderr, "Error: the video system does not support an image\n"
1280                         "size of %dx%d pixels. Try using -lowres or -vf \"scale=w:h\"\n"
1281                         "to reduce the image size.\n", vp->width, vp->height );
1282         do_exit(is);
1283     }
1284
1285     SDL_LockMutex(is->pictq_mutex);
1286     vp->allocated = 1;
1287     SDL_CondSignal(is->pictq_cond);
1288     SDL_UnlockMutex(is->pictq_mutex);
1289 }
1290
1291 static int queue_picture(VideoState *is, AVFrame *src_frame, double pts1, int64_t pos)
1292 {
1293     VideoPicture *vp;
1294     double frame_delay, pts = pts1;
1295
1296     /* compute the exact PTS for the picture if it is omitted in the stream
1297      * pts1 is the dts of the pkt / pts of the frame */
1298     if (pts != 0) {
1299         /* update video clock with pts, if present */
1300         is->video_clock = pts;
1301     } else {
1302         pts = is->video_clock;
1303     }
1304     /* update video clock for next frame */
1305     frame_delay = av_q2d(is->video_st->codec->time_base);
1306     /* for MPEG2, the frame can be repeated, so we update the
1307        clock accordingly */
1308     frame_delay += src_frame->repeat_pict * (frame_delay * 0.5);
1309     is->video_clock += frame_delay;
1310
1311 #if defined(DEBUG_SYNC) && 0
1312     printf("frame_type=%c clock=%0.3f pts=%0.3f\n",
1313            av_get_picture_type_char(src_frame->pict_type), pts, pts1);
1314 #endif
1315
1316     /* wait until we have space to put a new picture */
1317     SDL_LockMutex(is->pictq_mutex);
1318
1319     if(is->pictq_size>=VIDEO_PICTURE_QUEUE_SIZE && !is->refresh)
1320         is->skip_frames= FFMAX(1.0 - FRAME_SKIP_FACTOR, is->skip_frames * (1.0-FRAME_SKIP_FACTOR));
1321
1322     while (is->pictq_size >= VIDEO_PICTURE_QUEUE_SIZE &&
1323            !is->videoq.abort_request) {
1324         SDL_CondWait(is->pictq_cond, is->pictq_mutex);
1325     }
1326     SDL_UnlockMutex(is->pictq_mutex);
1327
1328     if (is->videoq.abort_request)
1329         return -1;
1330
1331     vp = &is->pictq[is->pictq_windex];
1332
1333     vp->duration = frame_delay;
1334
1335     /* alloc or resize hardware picture buffer */
1336     if (!vp->bmp ||
1337 #if CONFIG_AVFILTER
1338         vp->width  != is->out_video_filter->inputs[0]->w ||
1339         vp->height != is->out_video_filter->inputs[0]->h) {
1340 #else
1341         vp->width != is->video_st->codec->width ||
1342         vp->height != is->video_st->codec->height) {
1343 #endif
1344         SDL_Event event;
1345
1346         vp->allocated = 0;
1347
1348         /* the allocation must be done in the main thread to avoid
1349            locking problems */
1350         event.type = FF_ALLOC_EVENT;
1351         event.user.data1 = is;
1352         SDL_PushEvent(&event);
1353
1354         /* wait until the picture is allocated */
1355         SDL_LockMutex(is->pictq_mutex);
1356         while (!vp->allocated && !is->videoq.abort_request) {
1357             SDL_CondWait(is->pictq_cond, is->pictq_mutex);
1358         }
1359         SDL_UnlockMutex(is->pictq_mutex);
1360
1361         if (is->videoq.abort_request)
1362             return -1;
1363     }
1364
1365     /* if the frame is not skipped, then display it */
1366     if (vp->bmp) {
1367         AVPicture pict;
1368 #if CONFIG_AVFILTER
1369         if(vp->picref)
1370             avfilter_unref_buffer(vp->picref);
1371         vp->picref = src_frame->opaque;
1372 #endif
1373
1374         /* get a pointer on the bitmap */
1375         SDL_LockYUVOverlay (vp->bmp);
1376
1377         memset(&pict,0,sizeof(AVPicture));
1378         pict.data[0] = vp->bmp->pixels[0];
1379         pict.data[1] = vp->bmp->pixels[2];
1380         pict.data[2] = vp->bmp->pixels[1];
1381
1382         pict.linesize[0] = vp->bmp->pitches[0];
1383         pict.linesize[1] = vp->bmp->pitches[2];
1384         pict.linesize[2] = vp->bmp->pitches[1];
1385
1386 #if CONFIG_AVFILTER
1387         //FIXME use direct rendering
1388         av_picture_copy(&pict, (AVPicture *)src_frame,
1389                         vp->pix_fmt, vp->width, vp->height);
1390 #else
1391         sws_flags = av_get_int(sws_opts, "sws_flags", NULL);
1392         is->img_convert_ctx = sws_getCachedContext(is->img_convert_ctx,
1393             vp->width, vp->height, vp->pix_fmt, vp->width, vp->height,
1394             PIX_FMT_YUV420P, sws_flags, NULL, NULL, NULL);
1395         if (is->img_convert_ctx == NULL) {
1396             fprintf(stderr, "Cannot initialize the conversion context\n");
1397             exit(1);
1398         }
1399         sws_scale(is->img_convert_ctx, src_frame->data, src_frame->linesize,
1400                   0, vp->height, pict.data, pict.linesize);
1401 #endif
1402         /* update the bitmap content */
1403         SDL_UnlockYUVOverlay(vp->bmp);
1404
1405         vp->pts = pts;
1406         vp->pos = pos;
1407
1408         /* now we can update the picture count */
1409         if (++is->pictq_windex == VIDEO_PICTURE_QUEUE_SIZE)
1410             is->pictq_windex = 0;
1411         SDL_LockMutex(is->pictq_mutex);
1412         vp->target_clock= compute_target_time(vp->pts, is);
1413
1414         is->pictq_size++;
1415         SDL_UnlockMutex(is->pictq_mutex);
1416     }
1417     return 0;
1418 }
1419
1420 static int get_video_frame(VideoState *is, AVFrame *frame, int64_t *pts, AVPacket *pkt)
1421 {
1422     int got_picture, i;
1423
1424     if (packet_queue_get(&is->videoq, pkt, 1) < 0)
1425         return -1;
1426
1427     if (pkt->data == flush_pkt.data) {
1428         avcodec_flush_buffers(is->video_st->codec);
1429
1430         SDL_LockMutex(is->pictq_mutex);
1431         //Make sure there are no long delay timers (ideally we should just flush the que but thats harder)
1432         for (i = 0; i < VIDEO_PICTURE_QUEUE_SIZE; i++) {
1433             is->pictq[i].target_clock= 0;
1434         }
1435         while (is->pictq_size && !is->videoq.abort_request) {
1436             SDL_CondWait(is->pictq_cond, is->pictq_mutex);
1437         }
1438         is->video_current_pos = -1;
1439         SDL_UnlockMutex(is->pictq_mutex);
1440
1441         is->frame_last_pts = AV_NOPTS_VALUE;
1442         is->frame_last_delay = 0;
1443         is->frame_timer = (double)av_gettime() / 1000000.0;
1444         is->skip_frames = 1;
1445         is->skip_frames_index = 0;
1446         return 0;
1447     }
1448
1449     avcodec_decode_video2(is->video_st->codec, frame, &got_picture, pkt);
1450
1451     if (got_picture) {
1452         if (decoder_reorder_pts == -1) {
1453             *pts = frame->best_effort_timestamp;
1454         } else if (decoder_reorder_pts) {
1455             *pts = frame->pkt_pts;
1456         } else {
1457             *pts = frame->pkt_dts;
1458         }
1459
1460         if (*pts == AV_NOPTS_VALUE) {
1461             *pts = 0;
1462         }
1463
1464         is->skip_frames_index += 1;
1465         if(is->skip_frames_index >= is->skip_frames){
1466             is->skip_frames_index -= FFMAX(is->skip_frames, 1.0);
1467             return 1;
1468         }
1469
1470     }
1471     return 0;
1472 }
1473
1474 #if CONFIG_AVFILTER
1475 typedef struct {
1476     VideoState *is;
1477     AVFrame *frame;
1478     int use_dr1;
1479 } FilterPriv;
1480
1481 static int input_get_buffer(AVCodecContext *codec, AVFrame *pic)
1482 {
1483     AVFilterContext *ctx = codec->opaque;
1484     AVFilterBufferRef  *ref;
1485     int perms = AV_PERM_WRITE;
1486     int i, w, h, stride[4];
1487     unsigned edge;
1488     int pixel_size;
1489
1490     av_assert0(codec->flags & CODEC_FLAG_EMU_EDGE);
1491
1492     if (codec->codec->capabilities & CODEC_CAP_NEG_LINESIZES)
1493         perms |= AV_PERM_NEG_LINESIZES;
1494
1495     if(pic->buffer_hints & FF_BUFFER_HINTS_VALID) {
1496         if(pic->buffer_hints & FF_BUFFER_HINTS_READABLE) perms |= AV_PERM_READ;
1497         if(pic->buffer_hints & FF_BUFFER_HINTS_PRESERVE) perms |= AV_PERM_PRESERVE;
1498         if(pic->buffer_hints & FF_BUFFER_HINTS_REUSABLE) perms |= AV_PERM_REUSE2;
1499     }
1500     if(pic->reference) perms |= AV_PERM_READ | AV_PERM_PRESERVE;
1501
1502     w = codec->width;
1503     h = codec->height;
1504
1505     if(av_image_check_size(w, h, 0, codec))
1506         return -1;
1507
1508     avcodec_align_dimensions2(codec, &w, &h, stride);
1509     edge = codec->flags & CODEC_FLAG_EMU_EDGE ? 0 : avcodec_get_edge_width();
1510     w += edge << 1;
1511     h += edge << 1;
1512
1513     if(!(ref = avfilter_get_video_buffer(ctx->outputs[0], perms, w, h)))
1514         return -1;
1515
1516     pixel_size = av_pix_fmt_descriptors[ref->format].comp[0].step_minus1+1;
1517     ref->video->w = codec->width;
1518     ref->video->h = codec->height;
1519     for(i = 0; i < 4; i ++) {
1520         unsigned hshift = (i == 1 || i == 2) ? av_pix_fmt_descriptors[ref->format].log2_chroma_w : 0;
1521         unsigned vshift = (i == 1 || i == 2) ? av_pix_fmt_descriptors[ref->format].log2_chroma_h : 0;
1522
1523         if (ref->data[i]) {
1524             ref->data[i]    += ((edge * pixel_size) >> hshift) + ((edge * ref->linesize[i]) >> vshift);
1525         }
1526         pic->data[i]     = ref->data[i];
1527         pic->linesize[i] = ref->linesize[i];
1528     }
1529     pic->opaque = ref;
1530     pic->age    = INT_MAX;
1531     pic->type   = FF_BUFFER_TYPE_USER;
1532     pic->reordered_opaque = codec->reordered_opaque;
1533     if(codec->pkt) pic->pkt_pts = codec->pkt->pts;
1534     else           pic->pkt_pts = AV_NOPTS_VALUE;
1535     return 0;
1536 }
1537
1538 static void input_release_buffer(AVCodecContext *codec, AVFrame *pic)
1539 {
1540     memset(pic->data, 0, sizeof(pic->data));
1541     avfilter_unref_buffer(pic->opaque);
1542 }
1543
1544 static int input_reget_buffer(AVCodecContext *codec, AVFrame *pic)
1545 {
1546     AVFilterBufferRef *ref = pic->opaque;
1547
1548     if (pic->data[0] == NULL) {
1549         pic->buffer_hints |= FF_BUFFER_HINTS_READABLE;
1550         return codec->get_buffer(codec, pic);
1551     }
1552
1553     if ((codec->width != ref->video->w) || (codec->height != ref->video->h) ||
1554         (codec->pix_fmt != ref->format)) {
1555         av_log(codec, AV_LOG_ERROR, "Picture properties changed.\n");
1556         return -1;
1557     }
1558
1559     pic->reordered_opaque = codec->reordered_opaque;
1560     if(codec->pkt) pic->pkt_pts = codec->pkt->pts;
1561     else           pic->pkt_pts = AV_NOPTS_VALUE;
1562     return 0;
1563 }
1564
1565 static int input_init(AVFilterContext *ctx, const char *args, void *opaque)
1566 {
1567     FilterPriv *priv = ctx->priv;
1568     AVCodecContext *codec;
1569     if(!opaque) return -1;
1570
1571     priv->is = opaque;
1572     codec    = priv->is->video_st->codec;
1573     codec->opaque = ctx;
1574     if((codec->codec->capabilities & CODEC_CAP_DR1)
1575     ) {
1576         av_assert0(codec->flags & CODEC_FLAG_EMU_EDGE);
1577         priv->use_dr1 = 1;
1578         codec->get_buffer     = input_get_buffer;
1579         codec->release_buffer = input_release_buffer;
1580         codec->reget_buffer   = input_reget_buffer;
1581         codec->thread_safe_callbacks = 1;
1582     }
1583
1584     priv->frame = avcodec_alloc_frame();
1585
1586     return 0;
1587 }
1588
1589 static void input_uninit(AVFilterContext *ctx)
1590 {
1591     FilterPriv *priv = ctx->priv;
1592     av_free(priv->frame);
1593 }
1594
1595 static int input_request_frame(AVFilterLink *link)
1596 {
1597     FilterPriv *priv = link->src->priv;
1598     AVFilterBufferRef *picref;
1599     int64_t pts = 0;
1600     AVPacket pkt;
1601     int ret;
1602
1603     while (!(ret = get_video_frame(priv->is, priv->frame, &pts, &pkt)))
1604         av_free_packet(&pkt);
1605     if (ret < 0)
1606         return -1;
1607
1608     if(priv->use_dr1 && priv->frame->opaque) {
1609         picref = avfilter_ref_buffer(priv->frame->opaque, ~0);
1610     } else {
1611         picref = avfilter_get_video_buffer(link, AV_PERM_WRITE, link->w, link->h);
1612         av_image_copy(picref->data, picref->linesize,
1613                       priv->frame->data, priv->frame->linesize,
1614                       picref->format, link->w, link->h);
1615     }
1616     av_free_packet(&pkt);
1617
1618     avfilter_copy_frame_props(picref, priv->frame);
1619     picref->pts = pts;
1620
1621     avfilter_start_frame(link, picref);
1622     avfilter_draw_slice(link, 0, link->h, 1);
1623     avfilter_end_frame(link);
1624
1625     return 0;
1626 }
1627
1628 static int input_query_formats(AVFilterContext *ctx)
1629 {
1630     FilterPriv *priv = ctx->priv;
1631     enum PixelFormat pix_fmts[] = {
1632         priv->is->video_st->codec->pix_fmt, PIX_FMT_NONE
1633     };
1634
1635     avfilter_set_common_pixel_formats(ctx, avfilter_make_format_list(pix_fmts));
1636     return 0;
1637 }
1638
1639 static int input_config_props(AVFilterLink *link)
1640 {
1641     FilterPriv *priv  = link->src->priv;
1642     AVStream *s = priv->is->video_st;
1643
1644     link->w = s->codec->width;
1645     link->h = s->codec->height;
1646     link->sample_aspect_ratio = s->sample_aspect_ratio.num ?
1647         s->sample_aspect_ratio : s->codec->sample_aspect_ratio;
1648     link->time_base = s->time_base;
1649
1650     return 0;
1651 }
1652
1653 static AVFilter input_filter =
1654 {
1655     .name      = "ffplay_input",
1656
1657     .priv_size = sizeof(FilterPriv),
1658
1659     .init      = input_init,
1660     .uninit    = input_uninit,
1661
1662     .query_formats = input_query_formats,
1663
1664     .inputs    = (AVFilterPad[]) {{ .name = NULL }},
1665     .outputs   = (AVFilterPad[]) {{ .name = "default",
1666                                     .type = AVMEDIA_TYPE_VIDEO,
1667                                     .request_frame = input_request_frame,
1668                                     .config_props  = input_config_props, },
1669                                   { .name = NULL }},
1670 };
1671
1672 static int configure_video_filters(AVFilterGraph *graph, VideoState *is, const char *vfilters)
1673 {
1674     char sws_flags_str[128];
1675     int ret;
1676     enum PixelFormat pix_fmts[] = { PIX_FMT_YUV420P, PIX_FMT_NONE };
1677     AVFilterContext *filt_src = NULL, *filt_out = NULL;
1678     snprintf(sws_flags_str, sizeof(sws_flags_str), "flags=%d", sws_flags);
1679     graph->scale_sws_opts = av_strdup(sws_flags_str);
1680
1681     if ((ret = avfilter_graph_create_filter(&filt_src, &input_filter, "src",
1682                                             NULL, is, graph)) < 0)
1683         return ret;
1684     if ((ret = avfilter_graph_create_filter(&filt_out, avfilter_get_by_name("buffersink"), "out",
1685                                             NULL, pix_fmts, graph)) < 0)
1686         return ret;
1687
1688     if(vfilters) {
1689         AVFilterInOut *outputs = avfilter_inout_alloc();
1690         AVFilterInOut *inputs  = avfilter_inout_alloc();
1691
1692         outputs->name    = av_strdup("in");
1693         outputs->filter_ctx = filt_src;
1694         outputs->pad_idx = 0;
1695         outputs->next    = NULL;
1696
1697         inputs->name    = av_strdup("out");
1698         inputs->filter_ctx = filt_out;
1699         inputs->pad_idx = 0;
1700         inputs->next    = NULL;
1701
1702         if ((ret = avfilter_graph_parse(graph, vfilters, &inputs, &outputs, NULL)) < 0)
1703             return ret;
1704     } else {
1705         if ((ret = avfilter_link(filt_src, 0, filt_out, 0)) < 0)
1706             return ret;
1707     }
1708
1709     if ((ret = avfilter_graph_config(graph, NULL)) < 0)
1710         return ret;
1711
1712     is->out_video_filter = filt_out;
1713
1714     return ret;
1715 }
1716
1717 #endif  /* CONFIG_AVFILTER */
1718
1719 static int video_thread(void *arg)
1720 {
1721     VideoState *is = arg;
1722     AVFrame *frame= avcodec_alloc_frame();
1723     int64_t pts_int = AV_NOPTS_VALUE, pos = -1;
1724     double pts;
1725     int ret;
1726
1727 #if CONFIG_AVFILTER
1728     AVFilterGraph *graph = avfilter_graph_alloc();
1729     AVFilterContext *filt_out = NULL;
1730     int last_w = is->video_st->codec->width;
1731     int last_h = is->video_st->codec->height;
1732
1733     if ((ret = configure_video_filters(graph, is, vfilters)) < 0)
1734         goto the_end;
1735     filt_out = is->out_video_filter;
1736 #endif
1737
1738     for(;;) {
1739 #if !CONFIG_AVFILTER
1740         AVPacket pkt;
1741 #else
1742         AVFilterBufferRef *picref;
1743         AVRational tb = filt_out->inputs[0]->time_base;
1744 #endif
1745         while (is->paused && !is->videoq.abort_request)
1746             SDL_Delay(10);
1747 #if CONFIG_AVFILTER
1748         if (   last_w != is->video_st->codec->width
1749             || last_h != is->video_st->codec->height) {
1750             av_log(NULL, AV_LOG_INFO, "Frame changed from size:%dx%d to size:%dx%d\n",
1751                    last_w, last_h, is->video_st->codec->width, is->video_st->codec->height);
1752             avfilter_graph_free(&graph);
1753             graph = avfilter_graph_alloc();
1754             if ((ret = configure_video_filters(graph, is, vfilters)) < 0)
1755                 goto the_end;
1756             filt_out = is->out_video_filter;
1757             last_w = is->video_st->codec->width;
1758             last_h = is->video_st->codec->height;
1759         }
1760         ret = av_vsink_buffer_get_video_buffer_ref(filt_out, &picref, 0);
1761         if (picref) {
1762             avfilter_fill_frame_from_video_buffer_ref(frame, picref);
1763             pts_int = picref->pts;
1764             pos     = picref->pos;
1765             frame->opaque = picref;
1766         }
1767
1768         if (av_cmp_q(tb, is->video_st->time_base)) {
1769             av_unused int64_t pts1 = pts_int;
1770             pts_int = av_rescale_q(pts_int, tb, is->video_st->time_base);
1771             av_dlog(NULL, "video_thread(): "
1772                     "tb:%d/%d pts:%"PRId64" -> tb:%d/%d pts:%"PRId64"\n",
1773                     tb.num, tb.den, pts1,
1774                     is->video_st->time_base.num, is->video_st->time_base.den, pts_int);
1775         }
1776 #else
1777         ret = get_video_frame(is, frame, &pts_int, &pkt);
1778         pos = pkt.pos;
1779         av_free_packet(&pkt);
1780 #endif
1781
1782         if (ret < 0) goto the_end;
1783
1784 #if CONFIG_AVFILTER
1785         if (!picref)
1786             continue;
1787 #endif
1788
1789         pts = pts_int*av_q2d(is->video_st->time_base);
1790
1791         ret = queue_picture(is, frame, pts, pos);
1792
1793         if (ret < 0)
1794             goto the_end;
1795
1796         if (is->step)
1797             stream_toggle_pause(is);
1798     }
1799  the_end:
1800 #if CONFIG_AVFILTER
1801     avfilter_graph_free(&graph);
1802 #endif
1803     av_free(frame);
1804     return 0;
1805 }
1806
1807 static int subtitle_thread(void *arg)
1808 {
1809     VideoState *is = arg;
1810     SubPicture *sp;
1811     AVPacket pkt1, *pkt = &pkt1;
1812     int got_subtitle;
1813     double pts;
1814     int i, j;
1815     int r, g, b, y, u, v, a;
1816
1817     for(;;) {
1818         while (is->paused && !is->subtitleq.abort_request) {
1819             SDL_Delay(10);
1820         }
1821         if (packet_queue_get(&is->subtitleq, pkt, 1) < 0)
1822             break;
1823
1824         if(pkt->data == flush_pkt.data){
1825             avcodec_flush_buffers(is->subtitle_st->codec);
1826             continue;
1827         }
1828         SDL_LockMutex(is->subpq_mutex);
1829         while (is->subpq_size >= SUBPICTURE_QUEUE_SIZE &&
1830                !is->subtitleq.abort_request) {
1831             SDL_CondWait(is->subpq_cond, is->subpq_mutex);
1832         }
1833         SDL_UnlockMutex(is->subpq_mutex);
1834
1835         if (is->subtitleq.abort_request)
1836             return 0;
1837
1838         sp = &is->subpq[is->subpq_windex];
1839
1840        /* NOTE: ipts is the PTS of the _first_ picture beginning in
1841            this packet, if any */
1842         pts = 0;
1843         if (pkt->pts != AV_NOPTS_VALUE)
1844             pts = av_q2d(is->subtitle_st->time_base)*pkt->pts;
1845
1846         avcodec_decode_subtitle2(is->subtitle_st->codec, &sp->sub,
1847                                  &got_subtitle, pkt);
1848
1849         if (got_subtitle && sp->sub.format == 0) {
1850             sp->pts = pts;
1851
1852             for (i = 0; i < sp->sub.num_rects; i++)
1853             {
1854                 for (j = 0; j < sp->sub.rects[i]->nb_colors; j++)
1855                 {
1856                     RGBA_IN(r, g, b, a, (uint32_t*)sp->sub.rects[i]->pict.data[1] + j);
1857                     y = RGB_TO_Y_CCIR(r, g, b);
1858                     u = RGB_TO_U_CCIR(r, g, b, 0);
1859                     v = RGB_TO_V_CCIR(r, g, b, 0);
1860                     YUVA_OUT((uint32_t*)sp->sub.rects[i]->pict.data[1] + j, y, u, v, a);
1861                 }
1862             }
1863
1864             /* now we can update the picture count */
1865             if (++is->subpq_windex == SUBPICTURE_QUEUE_SIZE)
1866                 is->subpq_windex = 0;
1867             SDL_LockMutex(is->subpq_mutex);
1868             is->subpq_size++;
1869             SDL_UnlockMutex(is->subpq_mutex);
1870         }
1871         av_free_packet(pkt);
1872     }
1873     return 0;
1874 }
1875
1876 /* copy samples for viewing in editor window */
1877 static void update_sample_display(VideoState *is, short *samples, int samples_size)
1878 {
1879     int size, len;
1880
1881     size = samples_size / sizeof(short);
1882     while (size > 0) {
1883         len = SAMPLE_ARRAY_SIZE - is->sample_array_index;
1884         if (len > size)
1885             len = size;
1886         memcpy(is->sample_array + is->sample_array_index, samples, len * sizeof(short));
1887         samples += len;
1888         is->sample_array_index += len;
1889         if (is->sample_array_index >= SAMPLE_ARRAY_SIZE)
1890             is->sample_array_index = 0;
1891         size -= len;
1892     }
1893 }
1894
1895 /* return the new audio buffer size (samples can be added or deleted
1896    to get better sync if video or external master clock) */
1897 static int synchronize_audio(VideoState *is, short *samples,
1898                              int samples_size1, double pts)
1899 {
1900     int n, samples_size;
1901     double ref_clock;
1902
1903     n = 2 * is->audio_st->codec->channels;
1904     samples_size = samples_size1;
1905
1906     /* if not master, then we try to remove or add samples to correct the clock */
1907     if (((is->av_sync_type == AV_SYNC_VIDEO_MASTER && is->video_st) ||
1908          is->av_sync_type == AV_SYNC_EXTERNAL_CLOCK)) {
1909         double diff, avg_diff;
1910         int wanted_size, min_size, max_size, nb_samples;
1911
1912         ref_clock = get_master_clock(is);
1913         diff = get_audio_clock(is) - ref_clock;
1914
1915         if (diff < AV_NOSYNC_THRESHOLD) {
1916             is->audio_diff_cum = diff + is->audio_diff_avg_coef * is->audio_diff_cum;
1917             if (is->audio_diff_avg_count < AUDIO_DIFF_AVG_NB) {
1918                 /* not enough measures to have a correct estimate */
1919                 is->audio_diff_avg_count++;
1920             } else {
1921                 /* estimate the A-V difference */
1922                 avg_diff = is->audio_diff_cum * (1.0 - is->audio_diff_avg_coef);
1923
1924                 if (fabs(avg_diff) >= is->audio_diff_threshold) {
1925                     wanted_size = samples_size + ((int)(diff * is->audio_st->codec->sample_rate) * n);
1926                     nb_samples = samples_size / n;
1927
1928                     min_size = ((nb_samples * (100 - SAMPLE_CORRECTION_PERCENT_MAX)) / 100) * n;
1929                     max_size = ((nb_samples * (100 + SAMPLE_CORRECTION_PERCENT_MAX)) / 100) * n;
1930                     if (wanted_size < min_size)
1931                         wanted_size = min_size;
1932                     else if (wanted_size > max_size)
1933                         wanted_size = max_size;
1934
1935                     /* add or remove samples to correction the synchro */
1936                     if (wanted_size < samples_size) {
1937                         /* remove samples */
1938                         samples_size = wanted_size;
1939                     } else if (wanted_size > samples_size) {
1940                         uint8_t *samples_end, *q;
1941                         int nb;
1942
1943                         /* add samples */
1944                         nb = (samples_size - wanted_size);
1945                         samples_end = (uint8_t *)samples + samples_size - n;
1946                         q = samples_end + n;
1947                         while (nb > 0) {
1948                             memcpy(q, samples_end, n);
1949                             q += n;
1950                             nb -= n;
1951                         }
1952                         samples_size = wanted_size;
1953                     }
1954                 }
1955 #if 0
1956                 printf("diff=%f adiff=%f sample_diff=%d apts=%0.3f vpts=%0.3f %f\n",
1957                        diff, avg_diff, samples_size - samples_size1,
1958                        is->audio_clock, is->video_clock, is->audio_diff_threshold);
1959 #endif
1960             }
1961         } else {
1962             /* too big difference : may be initial PTS errors, so
1963                reset A-V filter */
1964             is->audio_diff_avg_count = 0;
1965             is->audio_diff_cum = 0;
1966         }
1967     }
1968
1969     return samples_size;
1970 }
1971
1972 /* decode one audio frame and returns its uncompressed size */
1973 static int audio_decode_frame(VideoState *is, double *pts_ptr)
1974 {
1975     AVPacket *pkt_temp = &is->audio_pkt_temp;
1976     AVPacket *pkt = &is->audio_pkt;
1977     AVCodecContext *dec= is->audio_st->codec;
1978     int n, len1, data_size;
1979     double pts;
1980
1981     for(;;) {
1982         /* NOTE: the audio packet can contain several frames */
1983         while (pkt_temp->size > 0) {
1984             data_size = sizeof(is->audio_buf1);
1985             len1 = avcodec_decode_audio3(dec,
1986                                         (int16_t *)is->audio_buf1, &data_size,
1987                                         pkt_temp);
1988             if (len1 < 0) {
1989                 /* if error, we skip the frame */
1990                 pkt_temp->size = 0;
1991                 break;
1992             }
1993
1994             pkt_temp->data += len1;
1995             pkt_temp->size -= len1;
1996             if (data_size <= 0)
1997                 continue;
1998
1999             if (dec->sample_fmt != is->audio_src_fmt) {
2000                 if (is->reformat_ctx)
2001                     av_audio_convert_free(is->reformat_ctx);
2002                 is->reformat_ctx= av_audio_convert_alloc(AV_SAMPLE_FMT_S16, 1,
2003                                                          dec->sample_fmt, 1, NULL, 0);
2004                 if (!is->reformat_ctx) {
2005                     fprintf(stderr, "Cannot convert %s sample format to %s sample format\n",
2006                         av_get_sample_fmt_name(dec->sample_fmt),
2007                         av_get_sample_fmt_name(AV_SAMPLE_FMT_S16));
2008                         break;
2009                 }
2010                 is->audio_src_fmt= dec->sample_fmt;
2011             }
2012
2013             if (is->reformat_ctx) {
2014                 const void *ibuf[6]= {is->audio_buf1};
2015                 void *obuf[6]= {is->audio_buf2};
2016                 int istride[6]= {av_get_bytes_per_sample(dec->sample_fmt)};
2017                 int ostride[6]= {2};
2018                 int len= data_size/istride[0];
2019                 if (av_audio_convert(is->reformat_ctx, obuf, ostride, ibuf, istride, len)<0) {
2020                     printf("av_audio_convert() failed\n");
2021                     break;
2022                 }
2023                 is->audio_buf= is->audio_buf2;
2024                 /* FIXME: existing code assume that data_size equals framesize*channels*2
2025                           remove this legacy cruft */
2026                 data_size= len*2;
2027             }else{
2028                 is->audio_buf= is->audio_buf1;
2029             }
2030
2031             /* if no pts, then compute it */
2032             pts = is->audio_clock;
2033             *pts_ptr = pts;
2034             n = 2 * dec->channels;
2035             is->audio_clock += (double)data_size /
2036                 (double)(n * dec->sample_rate);
2037 #ifdef DEBUG
2038             {
2039                 static double last_clock;
2040                 printf("audio: delay=%0.3f clock=%0.3f pts=%0.3f\n",
2041                        is->audio_clock - last_clock,
2042                        is->audio_clock, pts);
2043                 last_clock = is->audio_clock;
2044             }
2045 #endif
2046             return data_size;
2047         }
2048
2049         /* free the current packet */
2050         if (pkt->data)
2051             av_free_packet(pkt);
2052
2053         if (is->paused || is->audioq.abort_request) {
2054             return -1;
2055         }
2056
2057         /* read next packet */
2058         if (packet_queue_get(&is->audioq, pkt, 1) < 0)
2059             return -1;
2060         if(pkt->data == flush_pkt.data){
2061             avcodec_flush_buffers(dec);
2062             continue;
2063         }
2064
2065         pkt_temp->data = pkt->data;
2066         pkt_temp->size = pkt->size;
2067
2068         /* if update the audio clock with the pts */
2069         if (pkt->pts != AV_NOPTS_VALUE) {
2070             is->audio_clock = av_q2d(is->audio_st->time_base)*pkt->pts;
2071         }
2072     }
2073 }
2074
2075 /* prepare a new audio buffer */
2076 static void sdl_audio_callback(void *opaque, Uint8 *stream, int len)
2077 {
2078     VideoState *is = opaque;
2079     int audio_size, len1;
2080     int bytes_per_sec;
2081     double pts;
2082
2083     audio_callback_time = av_gettime();
2084
2085     while (len > 0) {
2086         if (is->audio_buf_index >= is->audio_buf_size) {
2087            audio_size = audio_decode_frame(is, &pts);
2088            if (audio_size < 0) {
2089                 /* if error, just output silence */
2090                is->audio_buf = is->audio_buf1;
2091                is->audio_buf_size = 1024;
2092                memset(is->audio_buf, 0, is->audio_buf_size);
2093            } else {
2094                if (is->show_mode != SHOW_MODE_VIDEO)
2095                    update_sample_display(is, (int16_t *)is->audio_buf, audio_size);
2096                audio_size = synchronize_audio(is, (int16_t *)is->audio_buf, audio_size,
2097                                               pts);
2098                is->audio_buf_size = audio_size;
2099            }
2100            is->audio_buf_index = 0;
2101         }
2102         len1 = is->audio_buf_size - is->audio_buf_index;
2103         if (len1 > len)
2104             len1 = len;
2105         memcpy(stream, (uint8_t *)is->audio_buf + is->audio_buf_index, len1);
2106         len -= len1;
2107         stream += len1;
2108         is->audio_buf_index += len1;
2109     }
2110     bytes_per_sec = is->audio_st->codec->sample_rate *
2111             2 * is->audio_st->codec->channels;
2112     is->audio_write_buf_size = is->audio_buf_size - is->audio_buf_index;
2113     /* Let's assume the audio driver that is used by SDL has two periods. */
2114     is->audio_current_pts = is->audio_clock - (double)(2 * is->audio_hw_buf_size + is->audio_write_buf_size) / bytes_per_sec;
2115     is->audio_current_pts_drift = is->audio_current_pts - audio_callback_time / 1000000.0;
2116 }
2117
2118 /* open a given stream. Return 0 if OK */
2119 static int stream_component_open(VideoState *is, int stream_index)
2120 {
2121     AVFormatContext *ic = is->ic;
2122     AVCodecContext *avctx;
2123     AVCodec *codec;
2124     SDL_AudioSpec wanted_spec, spec;
2125     AVDictionary *opts;
2126     AVDictionaryEntry *t = NULL;
2127
2128     if (stream_index < 0 || stream_index >= ic->nb_streams)
2129         return -1;
2130     avctx = ic->streams[stream_index]->codec;
2131
2132     opts = filter_codec_opts(codec_opts, avctx->codec_id, ic, ic->streams[stream_index]);
2133
2134     /* prepare audio output */
2135     if (avctx->codec_type == AVMEDIA_TYPE_AUDIO) {
2136         if (avctx->channels > 0) {
2137             avctx->request_channels = FFMIN(2, avctx->channels);
2138         } else {
2139             avctx->request_channels = 2;
2140         }
2141     }
2142
2143     codec = avcodec_find_decoder(avctx->codec_id);
2144     if (!codec)
2145         return -1;
2146
2147     avctx->workaround_bugs = workaround_bugs;
2148     avctx->lowres = lowres;
2149     if(lowres) avctx->flags |= CODEC_FLAG_EMU_EDGE;
2150     avctx->idct_algo= idct;
2151     if(fast) avctx->flags2 |= CODEC_FLAG2_FAST;
2152     avctx->skip_frame= skip_frame;
2153     avctx->skip_idct= skip_idct;
2154     avctx->skip_loop_filter= skip_loop_filter;
2155     avctx->error_recognition= error_recognition;
2156     avctx->error_concealment= error_concealment;
2157     avctx->thread_count= thread_count;
2158
2159     if(codec->capabilities & CODEC_CAP_DR1)
2160         avctx->flags |= CODEC_FLAG_EMU_EDGE;
2161
2162     if (!codec ||
2163         avcodec_open2(avctx, codec, &opts) < 0)
2164         return -1;
2165     if ((t = av_dict_get(opts, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
2166         av_log(NULL, AV_LOG_ERROR, "Option %s not found.\n", t->key);
2167         return AVERROR_OPTION_NOT_FOUND;
2168     }
2169
2170     /* prepare audio output */
2171     if (avctx->codec_type == AVMEDIA_TYPE_AUDIO) {
2172         if(avctx->sample_rate <= 0 || avctx->channels <= 0){
2173             fprintf(stderr, "Invalid sample rate or channel count\n");
2174             return -1;
2175         }
2176         wanted_spec.freq = avctx->sample_rate;
2177         wanted_spec.format = AUDIO_S16SYS;
2178         wanted_spec.channels = avctx->channels;
2179         wanted_spec.silence = 0;
2180         wanted_spec.samples = SDL_AUDIO_BUFFER_SIZE;
2181         wanted_spec.callback = sdl_audio_callback;
2182         wanted_spec.userdata = is;
2183         if (SDL_OpenAudio(&wanted_spec, &spec) < 0) {
2184             fprintf(stderr, "SDL_OpenAudio: %s\n", SDL_GetError());
2185             return -1;
2186         }
2187         is->audio_hw_buf_size = spec.size;
2188         is->audio_src_fmt= AV_SAMPLE_FMT_S16;
2189     }
2190
2191     ic->streams[stream_index]->discard = AVDISCARD_DEFAULT;
2192     switch(avctx->codec_type) {
2193     case AVMEDIA_TYPE_AUDIO:
2194         is->audio_stream = stream_index;
2195         is->audio_st = ic->streams[stream_index];
2196         is->audio_buf_size = 0;
2197         is->audio_buf_index = 0;
2198
2199         /* init averaging filter */
2200         is->audio_diff_avg_coef = exp(log(0.01) / AUDIO_DIFF_AVG_NB);
2201         is->audio_diff_avg_count = 0;
2202         /* since we do not have a precise anough audio fifo fullness,
2203            we correct audio sync only if larger than this threshold */
2204         is->audio_diff_threshold = 2.0 * SDL_AUDIO_BUFFER_SIZE / avctx->sample_rate;
2205
2206         memset(&is->audio_pkt, 0, sizeof(is->audio_pkt));
2207         packet_queue_init(&is->audioq);
2208         SDL_PauseAudio(0);
2209         break;
2210     case AVMEDIA_TYPE_VIDEO:
2211         is->video_stream = stream_index;
2212         is->video_st = ic->streams[stream_index];
2213
2214         packet_queue_init(&is->videoq);
2215         is->video_tid = SDL_CreateThread(video_thread, is);
2216         break;
2217     case AVMEDIA_TYPE_SUBTITLE:
2218         is->subtitle_stream = stream_index;
2219         is->subtitle_st = ic->streams[stream_index];
2220         packet_queue_init(&is->subtitleq);
2221
2222         is->subtitle_tid = SDL_CreateThread(subtitle_thread, is);
2223         break;
2224     default:
2225         break;
2226     }
2227     return 0;
2228 }
2229
2230 static void stream_component_close(VideoState *is, int stream_index)
2231 {
2232     AVFormatContext *ic = is->ic;
2233     AVCodecContext *avctx;
2234
2235     if (stream_index < 0 || stream_index >= ic->nb_streams)
2236         return;
2237     avctx = ic->streams[stream_index]->codec;
2238
2239     switch(avctx->codec_type) {
2240     case AVMEDIA_TYPE_AUDIO:
2241         packet_queue_abort(&is->audioq);
2242
2243         SDL_CloseAudio();
2244
2245         packet_queue_end(&is->audioq);
2246         if (is->reformat_ctx)
2247             av_audio_convert_free(is->reformat_ctx);
2248         is->reformat_ctx = NULL;
2249         break;
2250     case AVMEDIA_TYPE_VIDEO:
2251         packet_queue_abort(&is->videoq);
2252
2253         /* note: we also signal this mutex to make sure we deblock the
2254            video thread in all cases */
2255         SDL_LockMutex(is->pictq_mutex);
2256         SDL_CondSignal(is->pictq_cond);
2257         SDL_UnlockMutex(is->pictq_mutex);
2258
2259         SDL_WaitThread(is->video_tid, NULL);
2260
2261         packet_queue_end(&is->videoq);
2262         break;
2263     case AVMEDIA_TYPE_SUBTITLE:
2264         packet_queue_abort(&is->subtitleq);
2265
2266         /* note: we also signal this mutex to make sure we deblock the
2267            video thread in all cases */
2268         SDL_LockMutex(is->subpq_mutex);
2269         is->subtitle_stream_changed = 1;
2270
2271         SDL_CondSignal(is->subpq_cond);
2272         SDL_UnlockMutex(is->subpq_mutex);
2273
2274         SDL_WaitThread(is->subtitle_tid, NULL);
2275
2276         packet_queue_end(&is->subtitleq);
2277         break;
2278     default:
2279         break;
2280     }
2281
2282     ic->streams[stream_index]->discard = AVDISCARD_ALL;
2283     avcodec_close(avctx);
2284     switch(avctx->codec_type) {
2285     case AVMEDIA_TYPE_AUDIO:
2286         is->audio_st = NULL;
2287         is->audio_stream = -1;
2288         break;
2289     case AVMEDIA_TYPE_VIDEO:
2290         is->video_st = NULL;
2291         is->video_stream = -1;
2292         break;
2293     case AVMEDIA_TYPE_SUBTITLE:
2294         is->subtitle_st = NULL;
2295         is->subtitle_stream = -1;
2296         break;
2297     default:
2298         break;
2299     }
2300 }
2301
2302 /* since we have only one decoding thread, we can use a global
2303    variable instead of a thread local variable */
2304 static VideoState *global_video_state;
2305
2306 static int decode_interrupt_cb(void)
2307 {
2308     return (global_video_state && global_video_state->abort_request);
2309 }
2310
2311 /* this thread gets the stream from the disk or the network */
2312 static int read_thread(void *arg)
2313 {
2314     VideoState *is = arg;
2315     AVFormatContext *ic = NULL;
2316     int err, i, ret;
2317     int st_index[AVMEDIA_TYPE_NB];
2318     AVPacket pkt1, *pkt = &pkt1;
2319     int eof=0;
2320     int pkt_in_play_range = 0;
2321     AVDictionaryEntry *t;
2322     AVDictionary **opts;
2323     int orig_nb_streams;
2324
2325     memset(st_index, -1, sizeof(st_index));
2326     is->video_stream = -1;
2327     is->audio_stream = -1;
2328     is->subtitle_stream = -1;
2329
2330     global_video_state = is;
2331     avio_set_interrupt_cb(decode_interrupt_cb);
2332
2333     err = avformat_open_input(&ic, is->filename, is->iformat, &format_opts);
2334     if (err < 0) {
2335         print_error(is->filename, err);
2336         ret = -1;
2337         goto fail;
2338     }
2339     if ((t = av_dict_get(format_opts, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
2340         av_log(NULL, AV_LOG_ERROR, "Option %s not found.\n", t->key);
2341         ret = AVERROR_OPTION_NOT_FOUND;
2342         goto fail;
2343     }
2344     is->ic = ic;
2345
2346     if(genpts)
2347         ic->flags |= AVFMT_FLAG_GENPTS;
2348
2349     opts = setup_find_stream_info_opts(ic, codec_opts);
2350     orig_nb_streams = ic->nb_streams;
2351
2352     err = avformat_find_stream_info(ic, opts);
2353     if (err < 0) {
2354         fprintf(stderr, "%s: could not find codec parameters\n", is->filename);
2355         ret = -1;
2356         goto fail;
2357     }
2358     for (i = 0; i < orig_nb_streams; i++)
2359         av_dict_free(&opts[i]);
2360     av_freep(&opts);
2361
2362     if(ic->pb)
2363         ic->pb->eof_reached= 0; //FIXME hack, ffplay maybe should not use url_feof() to test for the end
2364
2365     if(seek_by_bytes<0)
2366         seek_by_bytes= !!(ic->iformat->flags & AVFMT_TS_DISCONT);
2367
2368     /* if seeking requested, we execute it */
2369     if (start_time != AV_NOPTS_VALUE) {
2370         int64_t timestamp;
2371
2372         timestamp = start_time;
2373         /* add the stream start time */
2374         if (ic->start_time != AV_NOPTS_VALUE)
2375             timestamp += ic->start_time;
2376         ret = avformat_seek_file(ic, -1, INT64_MIN, timestamp, INT64_MAX, 0);
2377         if (ret < 0) {
2378             fprintf(stderr, "%s: could not seek to position %0.3f\n",
2379                     is->filename, (double)timestamp / AV_TIME_BASE);
2380         }
2381     }
2382
2383     for (i = 0; i < ic->nb_streams; i++)
2384         ic->streams[i]->discard = AVDISCARD_ALL;
2385     if (!video_disable)
2386         st_index[AVMEDIA_TYPE_VIDEO] =
2387             av_find_best_stream(ic, AVMEDIA_TYPE_VIDEO,
2388                                 wanted_stream[AVMEDIA_TYPE_VIDEO], -1, NULL, 0);
2389     if (!audio_disable)
2390         st_index[AVMEDIA_TYPE_AUDIO] =
2391             av_find_best_stream(ic, AVMEDIA_TYPE_AUDIO,
2392                                 wanted_stream[AVMEDIA_TYPE_AUDIO],
2393                                 st_index[AVMEDIA_TYPE_VIDEO],
2394                                 NULL, 0);
2395     if (!video_disable)
2396         st_index[AVMEDIA_TYPE_SUBTITLE] =
2397             av_find_best_stream(ic, AVMEDIA_TYPE_SUBTITLE,
2398                                 wanted_stream[AVMEDIA_TYPE_SUBTITLE],
2399                                 (st_index[AVMEDIA_TYPE_AUDIO] >= 0 ?
2400                                  st_index[AVMEDIA_TYPE_AUDIO] :
2401                                  st_index[AVMEDIA_TYPE_VIDEO]),
2402                                 NULL, 0);
2403     if (show_status) {
2404         av_dump_format(ic, 0, is->filename, 0);
2405     }
2406
2407     is->show_mode = show_mode;
2408
2409     /* open the streams */
2410     if (st_index[AVMEDIA_TYPE_AUDIO] >= 0) {
2411         stream_component_open(is, st_index[AVMEDIA_TYPE_AUDIO]);
2412     }
2413
2414     ret=-1;
2415     if (st_index[AVMEDIA_TYPE_VIDEO] >= 0) {
2416         ret= stream_component_open(is, st_index[AVMEDIA_TYPE_VIDEO]);
2417     }
2418     is->refresh_tid = SDL_CreateThread(refresh_thread, is);
2419     if (is->show_mode == SHOW_MODE_NONE)
2420         is->show_mode = ret >= 0 ? SHOW_MODE_VIDEO : SHOW_MODE_RDFT;
2421
2422     if (st_index[AVMEDIA_TYPE_SUBTITLE] >= 0) {
2423         stream_component_open(is, st_index[AVMEDIA_TYPE_SUBTITLE]);
2424     }
2425
2426     if (is->video_stream < 0 && is->audio_stream < 0) {
2427         fprintf(stderr, "%s: could not open codecs\n", is->filename);
2428         ret = -1;
2429         goto fail;
2430     }
2431
2432     for(;;) {
2433         if (is->abort_request)
2434             break;
2435         if (is->paused != is->last_paused) {
2436             is->last_paused = is->paused;
2437             if (is->paused)
2438                 is->read_pause_return= av_read_pause(ic);
2439             else
2440                 av_read_play(ic);
2441         }
2442 #if CONFIG_RTSP_DEMUXER
2443         if (is->paused && !strcmp(ic->iformat->name, "rtsp")) {
2444             /* wait 10 ms to avoid trying to get another packet */
2445             /* XXX: horrible */
2446             SDL_Delay(10);
2447             continue;
2448         }
2449 #endif
2450         if (is->seek_req) {
2451             int64_t seek_target= is->seek_pos;
2452             int64_t seek_min= is->seek_rel > 0 ? seek_target - is->seek_rel + 2: INT64_MIN;
2453             int64_t seek_max= is->seek_rel < 0 ? seek_target - is->seek_rel - 2: INT64_MAX;
2454 //FIXME the +-2 is due to rounding being not done in the correct direction in generation
2455 //      of the seek_pos/seek_rel variables
2456
2457             ret = avformat_seek_file(is->ic, -1, seek_min, seek_target, seek_max, is->seek_flags);
2458             if (ret < 0) {
2459                 fprintf(stderr, "%s: error while seeking\n", is->ic->filename);
2460             }else{
2461                 if (is->audio_stream >= 0) {
2462                     packet_queue_flush(&is->audioq);
2463                     packet_queue_put(&is->audioq, &flush_pkt);
2464                 }
2465                 if (is->subtitle_stream >= 0) {
2466                     packet_queue_flush(&is->subtitleq);
2467                     packet_queue_put(&is->subtitleq, &flush_pkt);
2468                 }
2469                 if (is->video_stream >= 0) {
2470                     packet_queue_flush(&is->videoq);
2471                     packet_queue_put(&is->videoq, &flush_pkt);
2472                 }
2473             }
2474             is->seek_req = 0;
2475             eof= 0;
2476         }
2477
2478         /* if the queue are full, no need to read more */
2479         if (   is->audioq.size + is->videoq.size + is->subtitleq.size > MAX_QUEUE_SIZE
2480             || (   (is->audioq   .size  > MIN_AUDIOQ_SIZE || is->audio_stream<0)
2481                 && (is->videoq   .nb_packets > MIN_FRAMES || is->video_stream<0)
2482                 && (is->subtitleq.nb_packets > MIN_FRAMES || is->subtitle_stream<0))) {
2483             /* wait 10 ms */
2484             SDL_Delay(10);
2485             continue;
2486         }
2487         if(eof) {
2488             if(is->video_stream >= 0){
2489                 av_init_packet(pkt);
2490                 pkt->data=NULL;
2491                 pkt->size=0;
2492                 pkt->stream_index= is->video_stream;
2493                 packet_queue_put(&is->videoq, pkt);
2494             }
2495             SDL_Delay(10);
2496             if(is->audioq.size + is->videoq.size + is->subtitleq.size ==0){
2497                 if(loop!=1 && (!loop || --loop)){
2498                     stream_seek(is, start_time != AV_NOPTS_VALUE ? start_time : 0, 0, 0);
2499                 }else if(autoexit){
2500                     ret=AVERROR_EOF;
2501                     goto fail;
2502                 }
2503             }
2504             eof=0;
2505             continue;
2506         }
2507         ret = av_read_frame(ic, pkt);
2508         if (ret < 0) {
2509             if (ret == AVERROR_EOF || url_feof(ic->pb))
2510                 eof=1;
2511             if (ic->pb && ic->pb->error)
2512                 break;
2513             SDL_Delay(100); /* wait for user event */
2514             continue;
2515         }
2516         /* check if packet is in play range specified by user, then queue, otherwise discard */
2517         pkt_in_play_range = duration == AV_NOPTS_VALUE ||
2518                 (pkt->pts - ic->streams[pkt->stream_index]->start_time) *
2519                 av_q2d(ic->streams[pkt->stream_index]->time_base) -
2520                 (double)(start_time != AV_NOPTS_VALUE ? start_time : 0)/1000000
2521                 <= ((double)duration/1000000);
2522         if (pkt->stream_index == is->audio_stream && pkt_in_play_range) {
2523             packet_queue_put(&is->audioq, pkt);
2524         } else if (pkt->stream_index == is->video_stream && pkt_in_play_range) {
2525             packet_queue_put(&is->videoq, pkt);
2526         } else if (pkt->stream_index == is->subtitle_stream && pkt_in_play_range) {
2527             packet_queue_put(&is->subtitleq, pkt);
2528         } else {
2529             av_free_packet(pkt);
2530         }
2531     }
2532     /* wait until the end */
2533     while (!is->abort_request) {
2534         SDL_Delay(100);
2535     }
2536
2537     ret = 0;
2538  fail:
2539     /* disable interrupting */
2540     global_video_state = NULL;
2541
2542     /* close each stream */
2543     if (is->audio_stream >= 0)
2544         stream_component_close(is, is->audio_stream);
2545     if (is->video_stream >= 0)
2546         stream_component_close(is, is->video_stream);
2547     if (is->subtitle_stream >= 0)
2548         stream_component_close(is, is->subtitle_stream);
2549     if (is->ic) {
2550         av_close_input_file(is->ic);
2551         is->ic = NULL; /* safety */
2552     }
2553     avio_set_interrupt_cb(NULL);
2554
2555     if (ret != 0) {
2556         SDL_Event event;
2557
2558         event.type = FF_QUIT_EVENT;
2559         event.user.data1 = is;
2560         SDL_PushEvent(&event);
2561     }
2562     return 0;
2563 }
2564
2565 static VideoState *stream_open(const char *filename, AVInputFormat *iformat)
2566 {
2567     VideoState *is;
2568
2569     is = av_mallocz(sizeof(VideoState));
2570     if (!is)
2571         return NULL;
2572     av_strlcpy(is->filename, filename, sizeof(is->filename));
2573     is->iformat = iformat;
2574     is->ytop = 0;
2575     is->xleft = 0;
2576
2577     /* start video display */
2578     is->pictq_mutex = SDL_CreateMutex();
2579     is->pictq_cond = SDL_CreateCond();
2580
2581     is->subpq_mutex = SDL_CreateMutex();
2582     is->subpq_cond = SDL_CreateCond();
2583
2584     is->av_sync_type = av_sync_type;
2585     is->read_tid = SDL_CreateThread(read_thread, is);
2586     if (!is->read_tid) {
2587         av_free(is);
2588         return NULL;
2589     }
2590     return is;
2591 }
2592
2593 static void stream_cycle_channel(VideoState *is, int codec_type)
2594 {
2595     AVFormatContext *ic = is->ic;
2596     int start_index, stream_index;
2597     AVStream *st;
2598
2599     if (codec_type == AVMEDIA_TYPE_VIDEO)
2600         start_index = is->video_stream;
2601     else if (codec_type == AVMEDIA_TYPE_AUDIO)
2602         start_index = is->audio_stream;
2603     else
2604         start_index = is->subtitle_stream;
2605     if (start_index < (codec_type == AVMEDIA_TYPE_SUBTITLE ? -1 : 0))
2606         return;
2607     stream_index = start_index;
2608     for(;;) {
2609         if (++stream_index >= is->ic->nb_streams)
2610         {
2611             if (codec_type == AVMEDIA_TYPE_SUBTITLE)
2612             {
2613                 stream_index = -1;
2614                 goto the_end;
2615             } else
2616                 stream_index = 0;
2617         }
2618         if (stream_index == start_index)
2619             return;
2620         st = ic->streams[stream_index];
2621         if (st->codec->codec_type == codec_type) {
2622             /* check that parameters are OK */
2623             switch(codec_type) {
2624             case AVMEDIA_TYPE_AUDIO:
2625                 if (st->codec->sample_rate != 0 &&
2626                     st->codec->channels != 0)
2627                     goto the_end;
2628                 break;
2629             case AVMEDIA_TYPE_VIDEO:
2630             case AVMEDIA_TYPE_SUBTITLE:
2631                 goto the_end;
2632             default:
2633                 break;
2634             }
2635         }
2636     }
2637  the_end:
2638     stream_component_close(is, start_index);
2639     stream_component_open(is, stream_index);
2640 }
2641
2642
2643 static void toggle_full_screen(VideoState *is)
2644 {
2645     is_full_screen = !is_full_screen;
2646     video_open(is);
2647 }
2648
2649 static void toggle_pause(VideoState *is)
2650 {
2651     stream_toggle_pause(is);
2652     is->step = 0;
2653 }
2654
2655 static void step_to_next_frame(VideoState *is)
2656 {
2657     /* if the stream is paused unpause it, then step */
2658     if (is->paused)
2659         stream_toggle_pause(is);
2660     is->step = 1;
2661 }
2662
2663 static void toggle_audio_display(VideoState *is)
2664 {
2665     int bgcolor = SDL_MapRGB(screen->format, 0x00, 0x00, 0x00);
2666     is->show_mode = (is->show_mode + 1) % SHOW_MODE_NB;
2667     fill_rectangle(screen,
2668                 is->xleft, is->ytop, is->width, is->height,
2669                 bgcolor);
2670     SDL_UpdateRect(screen, is->xleft, is->ytop, is->width, is->height);
2671 }
2672
2673 /* handle an event sent by the GUI */
2674 static void event_loop(VideoState *cur_stream)
2675 {
2676     SDL_Event event;
2677     double incr, pos, frac;
2678
2679     for(;;) {
2680         double x;
2681         SDL_WaitEvent(&event);
2682         switch(event.type) {
2683         case SDL_KEYDOWN:
2684             if (exit_on_keydown) {
2685                 do_exit(cur_stream);
2686                 break;
2687             }
2688             switch(event.key.keysym.sym) {
2689             case SDLK_ESCAPE:
2690             case SDLK_q:
2691                 do_exit(cur_stream);
2692                 break;
2693             case SDLK_f:
2694                 toggle_full_screen(cur_stream);
2695                 break;
2696             case SDLK_p:
2697             case SDLK_SPACE:
2698                 toggle_pause(cur_stream);
2699                 break;
2700             case SDLK_s: //S: Step to next frame
2701                 step_to_next_frame(cur_stream);
2702                 break;
2703             case SDLK_a:
2704                 stream_cycle_channel(cur_stream, AVMEDIA_TYPE_AUDIO);
2705                 break;
2706             case SDLK_v:
2707                 stream_cycle_channel(cur_stream, AVMEDIA_TYPE_VIDEO);
2708                 break;
2709             case SDLK_t:
2710                 stream_cycle_channel(cur_stream, AVMEDIA_TYPE_SUBTITLE);
2711                 break;
2712             case SDLK_w:
2713                 toggle_audio_display(cur_stream);
2714                 break;
2715             case SDLK_LEFT:
2716                 incr = -10.0;
2717                 goto do_seek;
2718             case SDLK_RIGHT:
2719                 incr = 10.0;
2720                 goto do_seek;
2721             case SDLK_UP:
2722                 incr = 60.0;
2723                 goto do_seek;
2724             case SDLK_DOWN:
2725                 incr = -60.0;
2726             do_seek:
2727                 if (seek_by_bytes) {
2728                     if (cur_stream->video_stream >= 0 && cur_stream->video_current_pos>=0){
2729                         pos= cur_stream->video_current_pos;
2730                     }else if(cur_stream->audio_stream >= 0 && cur_stream->audio_pkt.pos>=0){
2731                         pos= cur_stream->audio_pkt.pos;
2732                     }else
2733                         pos = avio_tell(cur_stream->ic->pb);
2734                     if (cur_stream->ic->bit_rate)
2735                         incr *= cur_stream->ic->bit_rate / 8.0;
2736                     else
2737                         incr *= 180000.0;
2738                     pos += incr;
2739                     stream_seek(cur_stream, pos, incr, 1);
2740                 } else {
2741                     pos = get_master_clock(cur_stream);
2742                     pos += incr;
2743                     stream_seek(cur_stream, (int64_t)(pos * AV_TIME_BASE), (int64_t)(incr * AV_TIME_BASE), 0);
2744                 }
2745                 break;
2746             default:
2747                 break;
2748             }
2749             break;
2750         case SDL_MOUSEBUTTONDOWN:
2751             if (exit_on_mousedown) {
2752                 do_exit(cur_stream);
2753                 break;
2754             }
2755         case SDL_MOUSEMOTION:
2756             if(event.type ==SDL_MOUSEBUTTONDOWN){
2757                 x= event.button.x;
2758             }else{
2759                 if(event.motion.state != SDL_PRESSED)
2760                     break;
2761                 x= event.motion.x;
2762             }
2763             if(seek_by_bytes || cur_stream->ic->duration<=0){
2764                 uint64_t size=  avio_size(cur_stream->ic->pb);
2765                 stream_seek(cur_stream, size*x/cur_stream->width, 0, 1);
2766             }else{
2767                 int64_t ts;
2768                 int ns, hh, mm, ss;
2769                 int tns, thh, tmm, tss;
2770                 tns = cur_stream->ic->duration/1000000LL;
2771                 thh = tns/3600;
2772                 tmm = (tns%3600)/60;
2773                 tss = (tns%60);
2774                 frac = x/cur_stream->width;
2775                 ns = frac*tns;
2776                 hh = ns/3600;
2777                 mm = (ns%3600)/60;
2778                 ss = (ns%60);
2779                 fprintf(stderr, "Seek to %2.0f%% (%2d:%02d:%02d) of total duration (%2d:%02d:%02d)       \n", frac*100,
2780                         hh, mm, ss, thh, tmm, tss);
2781                 ts = frac*cur_stream->ic->duration;
2782                 if (cur_stream->ic->start_time != AV_NOPTS_VALUE)
2783                     ts += cur_stream->ic->start_time;
2784                 stream_seek(cur_stream, ts, 0, 0);
2785             }
2786             break;
2787         case SDL_VIDEORESIZE:
2788             screen = SDL_SetVideoMode(event.resize.w, event.resize.h, 0,
2789                                       SDL_HWSURFACE|SDL_RESIZABLE|SDL_ASYNCBLIT|SDL_HWACCEL);
2790             screen_width = cur_stream->width = event.resize.w;
2791             screen_height= cur_stream->height= event.resize.h;
2792             break;
2793         case SDL_QUIT:
2794         case FF_QUIT_EVENT:
2795             do_exit(cur_stream);
2796             break;
2797         case FF_ALLOC_EVENT:
2798             video_open(event.user.data1);
2799             alloc_picture(event.user.data1);
2800             break;
2801         case FF_REFRESH_EVENT:
2802             video_refresh(event.user.data1);
2803             cur_stream->refresh=0;
2804             break;
2805         default:
2806             break;
2807         }
2808     }
2809 }
2810
2811 static int opt_frame_size(const char *opt, const char *arg)
2812 {
2813     av_log(NULL, AV_LOG_WARNING, "Option -s is deprecated, use -video_size.\n");
2814     return opt_default("video_size", arg);
2815 }
2816
2817 static int opt_width(const char *opt, const char *arg)
2818 {
2819     screen_width = parse_number_or_die(opt, arg, OPT_INT64, 1, INT_MAX);
2820     return 0;
2821 }
2822
2823 static int opt_height(const char *opt, const char *arg)
2824 {
2825     screen_height = parse_number_or_die(opt, arg, OPT_INT64, 1, INT_MAX);
2826     return 0;
2827 }
2828
2829 static int opt_format(const char *opt, const char *arg)
2830 {
2831     file_iformat = av_find_input_format(arg);
2832     if (!file_iformat) {
2833         fprintf(stderr, "Unknown input format: %s\n", arg);
2834         return AVERROR(EINVAL);
2835     }
2836     return 0;
2837 }
2838
2839 static int opt_frame_pix_fmt(const char *opt, const char *arg)
2840 {
2841     av_log(NULL, AV_LOG_WARNING, "Option -pix_fmt is deprecated, use -pixel_format.\n");
2842     return opt_default("pixel_format", arg);
2843 }
2844
2845 static int opt_sync(const char *opt, const char *arg)
2846 {
2847     if (!strcmp(arg, "audio"))
2848         av_sync_type = AV_SYNC_AUDIO_MASTER;
2849     else if (!strcmp(arg, "video"))
2850         av_sync_type = AV_SYNC_VIDEO_MASTER;
2851     else if (!strcmp(arg, "ext"))
2852         av_sync_type = AV_SYNC_EXTERNAL_CLOCK;
2853     else {
2854         fprintf(stderr, "Unknown value for %s: %s\n", opt, arg);
2855         exit(1);
2856     }
2857     return 0;
2858 }
2859
2860 static int opt_seek(const char *opt, const char *arg)
2861 {
2862     start_time = parse_time_or_die(opt, arg, 1);
2863     return 0;
2864 }
2865
2866 static int opt_duration(const char *opt, const char *arg)
2867 {
2868     duration = parse_time_or_die(opt, arg, 1);
2869     return 0;
2870 }
2871
2872 static int opt_thread_count(const char *opt, const char *arg)
2873 {
2874     thread_count= parse_number_or_die(opt, arg, OPT_INT64, 0, INT_MAX);
2875 #if !HAVE_THREADS
2876     fprintf(stderr, "Warning: not compiled with thread support, using thread emulation\n");
2877 #endif
2878     return 0;
2879 }
2880
2881 static int opt_show_mode(const char *opt, const char *arg)
2882 {
2883     show_mode = !strcmp(arg, "video") ? SHOW_MODE_VIDEO :
2884                 !strcmp(arg, "waves") ? SHOW_MODE_WAVES :
2885                 !strcmp(arg, "rdft" ) ? SHOW_MODE_RDFT  :
2886                 parse_number_or_die(opt, arg, OPT_INT, 0, SHOW_MODE_NB-1);
2887     return 0;
2888 }
2889
2890 static int opt_input_file(const char *opt, const char *filename)
2891 {
2892     if (input_filename) {
2893         fprintf(stderr, "Argument '%s' provided as input filename, but '%s' was already specified.\n",
2894                 filename, input_filename);
2895         exit(1);
2896     }
2897     if (!strcmp(filename, "-"))
2898         filename = "pipe:";
2899     input_filename = filename;
2900     return 0;
2901 }
2902
2903 static const OptionDef options[] = {
2904 #include "cmdutils_common_opts.h"
2905     { "x", HAS_ARG, {(void*)opt_width}, "force displayed width", "width" },
2906     { "y", HAS_ARG, {(void*)opt_height}, "force displayed height", "height" },
2907     { "s", HAS_ARG | OPT_VIDEO, {(void*)opt_frame_size}, "set frame size (WxH or abbreviation)", "size" },
2908     { "fs", OPT_BOOL, {(void*)&is_full_screen}, "force full screen" },
2909     { "an", OPT_BOOL, {(void*)&audio_disable}, "disable audio" },
2910     { "vn", OPT_BOOL, {(void*)&video_disable}, "disable video" },
2911     { "ast", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&wanted_stream[AVMEDIA_TYPE_AUDIO]}, "select desired audio stream", "stream_number" },
2912     { "vst", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&wanted_stream[AVMEDIA_TYPE_VIDEO]}, "select desired video stream", "stream_number" },
2913     { "sst", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&wanted_stream[AVMEDIA_TYPE_SUBTITLE]}, "select desired subtitle stream", "stream_number" },
2914     { "ss", HAS_ARG, {(void*)&opt_seek}, "seek to a given position in seconds", "pos" },
2915     { "t", HAS_ARG, {(void*)&opt_duration}, "play  \"duration\" seconds of audio/video", "duration" },
2916     { "bytes", OPT_INT | HAS_ARG, {(void*)&seek_by_bytes}, "seek by bytes 0=off 1=on -1=auto", "val" },
2917     { "nodisp", OPT_BOOL, {(void*)&display_disable}, "disable graphical display" },
2918     { "f", HAS_ARG, {(void*)opt_format}, "force format", "fmt" },
2919     { "pix_fmt", HAS_ARG | OPT_EXPERT | OPT_VIDEO, {(void*)opt_frame_pix_fmt}, "set pixel format", "format" },
2920     { "stats", OPT_BOOL | OPT_EXPERT, {(void*)&show_status}, "show status", "" },
2921     { "bug", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&workaround_bugs}, "workaround bugs", "" },
2922     { "fast", OPT_BOOL | OPT_EXPERT, {(void*)&fast}, "non spec compliant optimizations", "" },
2923     { "genpts", OPT_BOOL | OPT_EXPERT, {(void*)&genpts}, "generate pts", "" },
2924     { "drp", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&decoder_reorder_pts}, "let decoder reorder pts 0=off 1=on -1=auto", ""},
2925     { "lowres", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&lowres}, "", "" },
2926     { "skiploop", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&skip_loop_filter}, "", "" },
2927     { "skipframe", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&skip_frame}, "", "" },
2928     { "skipidct", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&skip_idct}, "", "" },
2929     { "idct", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&idct}, "set idct algo",  "algo" },
2930     { "er", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&error_recognition}, "set error detection threshold (0-4)",  "threshold" },
2931     { "ec", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&error_concealment}, "set error concealment options",  "bit_mask" },
2932     { "sync", HAS_ARG | OPT_EXPERT, {(void*)opt_sync}, "set audio-video sync. type (type=audio/video/ext)", "type" },
2933     { "threads", HAS_ARG | OPT_EXPERT, {(void*)opt_thread_count}, "thread count", "count" },
2934     { "autoexit", OPT_BOOL | OPT_EXPERT, {(void*)&autoexit}, "exit at the end", "" },
2935     { "exitonkeydown", OPT_BOOL | OPT_EXPERT, {(void*)&exit_on_keydown}, "exit on key down", "" },
2936     { "exitonmousedown", OPT_BOOL | OPT_EXPERT, {(void*)&exit_on_mousedown}, "exit on mouse down", "" },
2937     { "loop", OPT_INT | HAS_ARG | OPT_EXPERT, {(void*)&loop}, "set number of times the playback shall be looped", "loop count" },
2938     { "framedrop", OPT_BOOL | OPT_EXPERT, {(void*)&framedrop}, "drop frames when cpu is too slow", "" },
2939     { "window_title", OPT_STRING | HAS_ARG, {(void*)&window_title}, "set window title", "window title" },
2940 #if CONFIG_AVFILTER
2941     { "vf", OPT_STRING | HAS_ARG, {(void*)&vfilters}, "video filters", "filter list" },
2942 #endif
2943     { "rdftspeed", OPT_INT | HAS_ARG| OPT_AUDIO | OPT_EXPERT, {(void*)&rdftspeed}, "rdft speed", "msecs" },
2944     { "showmode", HAS_ARG, {(void*)opt_show_mode}, "select show mode (0 = video, 1 = waves, 2 = RDFT)", "mode" },
2945     { "default", HAS_ARG | OPT_AUDIO | OPT_VIDEO | OPT_EXPERT, {(void*)opt_default}, "generic catch all option", "" },
2946     { "i", HAS_ARG, {(void *)opt_input_file}, "read specified file", "input_file"},
2947     { NULL, },
2948 };
2949
2950 static void show_usage(void)
2951 {
2952     printf("Simple media player\n");
2953     printf("usage: %s [options] input_file\n", program_name);
2954     printf("\n");
2955 }
2956
2957 static int opt_help(const char *opt, const char *arg)
2958 {
2959     av_log_set_callback(log_callback_help);
2960     show_usage();
2961     show_help_options(options, "Main options:\n",
2962                       OPT_EXPERT, 0);
2963     show_help_options(options, "\nAdvanced options:\n",
2964                       OPT_EXPERT, OPT_EXPERT);
2965     printf("\n");
2966     av_opt_show2(avcodec_opts[0], NULL,
2967                  AV_OPT_FLAG_DECODING_PARAM, 0);
2968     printf("\n");
2969     av_opt_show2(avformat_opts, NULL,
2970                  AV_OPT_FLAG_DECODING_PARAM, 0);
2971 #if !CONFIG_AVFILTER
2972     printf("\n");
2973     av_opt_show2(sws_opts, NULL,
2974                  AV_OPT_FLAG_ENCODING_PARAM, 0);
2975 #endif
2976     printf("\nWhile playing:\n"
2977            "q, ESC              quit\n"
2978            "f                   toggle full screen\n"
2979            "p, SPC              pause\n"
2980            "a                   cycle audio channel\n"
2981            "v                   cycle video channel\n"
2982            "t                   cycle subtitle channel\n"
2983            "w                   show audio waves\n"
2984            "s                   activate frame-step mode\n"
2985            "left/right          seek backward/forward 10 seconds\n"
2986            "down/up             seek backward/forward 1 minute\n"
2987            "mouse click         seek to percentage in file corresponding to fraction of width\n"
2988            );
2989     return 0;
2990 }
2991
2992 static int lockmgr(void **mtx, enum AVLockOp op)
2993 {
2994    switch(op) {
2995       case AV_LOCK_CREATE:
2996           *mtx = SDL_CreateMutex();
2997           if(!*mtx)
2998               return 1;
2999           return 0;
3000       case AV_LOCK_OBTAIN:
3001           return !!SDL_LockMutex(*mtx);
3002       case AV_LOCK_RELEASE:
3003           return !!SDL_UnlockMutex(*mtx);
3004       case AV_LOCK_DESTROY:
3005           SDL_DestroyMutex(*mtx);
3006           return 0;
3007    }
3008    return 1;
3009 }
3010
3011 /* Called from the main */
3012 int main(int argc, char **argv)
3013 {
3014     int flags;
3015     VideoState *is;
3016
3017     av_log_set_flags(AV_LOG_SKIP_REPEATED);
3018
3019     /* register all codecs, demux and protocols */
3020     avcodec_register_all();
3021 #if CONFIG_AVDEVICE
3022     avdevice_register_all();
3023 #endif
3024 #if CONFIG_AVFILTER
3025     avfilter_register_all();
3026 #endif
3027     av_register_all();
3028
3029     init_opts();
3030
3031     show_banner();
3032
3033     parse_options(argc, argv, options, opt_input_file);
3034
3035     if (!input_filename) {
3036         show_usage();
3037         fprintf(stderr, "An input file must be specified\n");
3038         fprintf(stderr, "Use -h to get full help or, even better, run 'man %s'\n", program_name);
3039         exit(1);
3040     }
3041
3042     if (display_disable) {
3043         video_disable = 1;
3044     }
3045     flags = SDL_INIT_VIDEO | SDL_INIT_AUDIO | SDL_INIT_TIMER;
3046     if (audio_disable)
3047         flags &= ~SDL_INIT_AUDIO;
3048 #if !defined(__MINGW32__) && !defined(__APPLE__)
3049     flags |= SDL_INIT_EVENTTHREAD; /* Not supported on Windows or Mac OS X */
3050 #endif
3051     if (SDL_Init (flags)) {
3052         fprintf(stderr, "Could not initialize SDL - %s\n", SDL_GetError());
3053         fprintf(stderr, "(Did you set the DISPLAY variable?)\n");
3054         exit(1);
3055     }
3056
3057     if (!display_disable) {
3058 #if HAVE_SDL_VIDEO_SIZE
3059         const SDL_VideoInfo *vi = SDL_GetVideoInfo();
3060         fs_screen_width = vi->current_w;
3061         fs_screen_height = vi->current_h;
3062 #endif
3063     }
3064
3065     SDL_EventState(SDL_ACTIVEEVENT, SDL_IGNORE);
3066     SDL_EventState(SDL_SYSWMEVENT, SDL_IGNORE);
3067     SDL_EventState(SDL_USEREVENT, SDL_IGNORE);
3068
3069     if (av_lockmgr_register(lockmgr)) {
3070         fprintf(stderr, "Could not initialize lock manager!\n");
3071         do_exit(NULL);
3072     }
3073
3074     av_init_packet(&flush_pkt);
3075     flush_pkt.data= "FLUSH";
3076
3077     is = stream_open(input_filename, file_iformat);
3078     if (!is) {
3079         fprintf(stderr, "Failed to initialize VideoState!\n");
3080         do_exit(NULL);
3081     }
3082
3083     event_loop(is);
3084
3085     /* never returns */
3086
3087     return 0;
3088 }