LCOV - code coverage report
Current view: top level - src - ffmpeg.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 1887 2670 70.7 %
Date: 2017-04-24 03:48:25 Functions: 70 83 84.3 %

          Line data    Source code
       1             : /*
       2             :  * Copyright (c) 2000-2003 Fabrice Bellard
       3             :  *
       4             :  * This file is part of FFmpeg.
       5             :  *
       6             :  * FFmpeg is free software; you can redistribute it and/or
       7             :  * modify it under the terms of the GNU Lesser General Public
       8             :  * License as published by the Free Software Foundation; either
       9             :  * version 2.1 of the License, or (at your option) any later version.
      10             :  *
      11             :  * FFmpeg is distributed in the hope that it will be useful,
      12             :  * but WITHOUT ANY WARRANTY; without even the implied warranty of
      13             :  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      14             :  * Lesser General Public License for more details.
      15             :  *
      16             :  * You should have received a copy of the GNU Lesser General Public
      17             :  * License along with FFmpeg; if not, write to the Free Software
      18             :  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
      19             :  */
      20             : 
      21             : /**
      22             :  * @file
      23             :  * multimedia converter based on the FFmpeg libraries
      24             :  */
      25             : 
      26             : #include "config.h"
      27             : #include <ctype.h>
      28             : #include <string.h>
      29             : #include <math.h>
      30             : #include <stdlib.h>
      31             : #include <errno.h>
      32             : #include <limits.h>
      33             : #include <stdatomic.h>
      34             : #include <stdint.h>
      35             : 
      36             : #if HAVE_IO_H
      37             : #include <io.h>
      38             : #endif
      39             : #if HAVE_UNISTD_H
      40             : #include <unistd.h>
      41             : #endif
      42             : 
      43             : #include "libavformat/avformat.h"
      44             : #include "libavdevice/avdevice.h"
      45             : #include "libswresample/swresample.h"
      46             : #include "libavutil/opt.h"
      47             : #include "libavutil/channel_layout.h"
      48             : #include "libavutil/parseutils.h"
      49             : #include "libavutil/samplefmt.h"
      50             : #include "libavutil/fifo.h"
      51             : #include "libavutil/hwcontext.h"
      52             : #include "libavutil/internal.h"
      53             : #include "libavutil/intreadwrite.h"
      54             : #include "libavutil/dict.h"
      55             : #include "libavutil/display.h"
      56             : #include "libavutil/mathematics.h"
      57             : #include "libavutil/pixdesc.h"
      58             : #include "libavutil/avstring.h"
      59             : #include "libavutil/libm.h"
      60             : #include "libavutil/imgutils.h"
      61             : #include "libavutil/timestamp.h"
      62             : #include "libavutil/bprint.h"
      63             : #include "libavutil/time.h"
      64             : #include "libavutil/threadmessage.h"
      65             : #include "libavcodec/mathops.h"
      66             : #include "libavformat/os_support.h"
      67             : 
      68             : # include "libavfilter/avfilter.h"
      69             : # include "libavfilter/buffersrc.h"
      70             : # include "libavfilter/buffersink.h"
      71             : 
      72             : #if HAVE_SYS_RESOURCE_H
      73             : #include <sys/time.h>
      74             : #include <sys/types.h>
      75             : #include <sys/resource.h>
      76             : #elif HAVE_GETPROCESSTIMES
      77             : #include <windows.h>
      78             : #endif
      79             : #if HAVE_GETPROCESSMEMORYINFO
      80             : #include <windows.h>
      81             : #include <psapi.h>
      82             : #endif
      83             : #if HAVE_SETCONSOLECTRLHANDLER
      84             : #include <windows.h>
      85             : #endif
      86             : 
      87             : 
      88             : #if HAVE_SYS_SELECT_H
      89             : #include <sys/select.h>
      90             : #endif
      91             : 
      92             : #if HAVE_TERMIOS_H
      93             : #include <fcntl.h>
      94             : #include <sys/ioctl.h>
      95             : #include <sys/time.h>
      96             : #include <termios.h>
      97             : #elif HAVE_KBHIT
      98             : #include <conio.h>
      99             : #endif
     100             : 
     101             : #if HAVE_PTHREADS
     102             : #include <pthread.h>
     103             : #endif
     104             : 
     105             : #include <time.h>
     106             : 
     107             : #include "ffmpeg.h"
     108             : #include "cmdutils.h"
     109             : 
     110             : #include "libavutil/avassert.h"
     111             : 
     112             : const char program_name[] = "ffmpeg";
     113             : const int program_birth_year = 2000;
     114             : 
     115             : static FILE *vstats_file;
     116             : 
     117             : const char *const forced_keyframes_const_names[] = {
     118             :     "n",
     119             :     "n_forced",
     120             :     "prev_forced_n",
     121             :     "prev_forced_t",
     122             :     "t",
     123             :     NULL
     124             : };
     125             : 
     126             : static void do_video_stats(OutputStream *ost, int frame_size);
     127             : static int64_t getutime(void);
     128             : static int64_t getmaxrss(void);
     129             : static int ifilter_has_all_input_formats(FilterGraph *fg);
     130             : 
     131             : static int run_as_daemon  = 0;
     132             : static int nb_frames_dup = 0;
     133             : static unsigned dup_warning = 1000;
     134             : static int nb_frames_drop = 0;
     135             : static int64_t decode_error_stat[2];
     136             : 
     137             : static int want_sdp = 1;
     138             : 
     139             : static int current_time;
     140             : AVIOContext *progress_avio = NULL;
     141             : 
     142             : static uint8_t *subtitle_out;
     143             : 
     144             : InputStream **input_streams = NULL;
     145             : int        nb_input_streams = 0;
     146             : InputFile   **input_files   = NULL;
     147             : int        nb_input_files   = 0;
     148             : 
     149             : OutputStream **output_streams = NULL;
     150             : int         nb_output_streams = 0;
     151             : OutputFile   **output_files   = NULL;
     152             : int         nb_output_files   = 0;
     153             : 
     154             : FilterGraph **filtergraphs;
     155             : int        nb_filtergraphs;
     156             : 
     157             : #if HAVE_TERMIOS_H
     158             : 
     159             : /* init terminal so that we can grab keys */
     160             : static struct termios oldtty;
     161             : static int restore_tty;
     162             : #endif
     163             : 
     164             : #if HAVE_PTHREADS
     165             : static void free_input_threads(void);
     166             : #endif
     167             : 
     168             : /* sub2video hack:
     169             :    Convert subtitles to video with alpha to insert them in filter graphs.
     170             :    This is a temporary solution until libavfilter gets real subtitles support.
     171             :  */
     172             : 
     173          90 : static int sub2video_get_blank_frame(InputStream *ist)
     174             : {
     175             :     int ret;
     176          90 :     AVFrame *frame = ist->sub2video.frame;
     177             : 
     178          90 :     av_frame_unref(frame);
     179          90 :     ist->sub2video.frame->width  = ist->dec_ctx->width  ? ist->dec_ctx->width  : ist->sub2video.w;
     180          90 :     ist->sub2video.frame->height = ist->dec_ctx->height ? ist->dec_ctx->height : ist->sub2video.h;
     181          90 :     ist->sub2video.frame->format = AV_PIX_FMT_RGB32;
     182          90 :     if ((ret = av_frame_get_buffer(frame, 32)) < 0)
     183           0 :         return ret;
     184          90 :     memset(frame->data[0], 0, frame->height * frame->linesize[0]);
     185          90 :     return 0;
     186             : }
     187             : 
     188          44 : static void sub2video_copy_rect(uint8_t *dst, int dst_linesize, int w, int h,
     189             :                                 AVSubtitleRect *r)
     190             : {
     191             :     uint32_t *pal, *dst2;
     192             :     uint8_t *src, *src2;
     193             :     int x, y;
     194             : 
     195          44 :     if (r->type != SUBTITLE_BITMAP) {
     196           0 :         av_log(NULL, AV_LOG_WARNING, "sub2video: non-bitmap subtitle\n");
     197           0 :         return;
     198             :     }
     199          44 :     if (r->x < 0 || r->x + r->w > w || r->y < 0 || r->y + r->h > h) {
     200           0 :         av_log(NULL, AV_LOG_WARNING, "sub2video: rectangle (%d %d %d %d) overflowing %d %d\n",
     201             :             r->x, r->y, r->w, r->h, w, h
     202             :         );
     203           0 :         return;
     204             :     }
     205             : 
     206          44 :     dst += r->y * dst_linesize + r->x * 4;
     207          44 :     src = r->data[0];
     208          44 :     pal = (uint32_t *)r->data[1];
     209        1642 :     for (y = 0; y < r->h; y++) {
     210        1598 :         dst2 = (uint32_t *)dst;
     211        1598 :         src2 = src;
     212      480325 :         for (x = 0; x < r->w; x++)
     213      478727 :             *(dst2++) = pal[*(src2++)];
     214        1598 :         dst += dst_linesize;
     215        1598 :         src += r->linesize[0];
     216             :     }
     217             : }
     218             : 
     219         311 : static void sub2video_push_ref(InputStream *ist, int64_t pts)
     220             : {
     221         311 :     AVFrame *frame = ist->sub2video.frame;
     222             :     int i;
     223             : 
     224             :     av_assert1(frame->data[0]);
     225         311 :     ist->sub2video.last_pts = frame->pts = pts;
     226         622 :     for (i = 0; i < ist->nb_filters; i++)
     227         311 :         av_buffersrc_add_frame_flags(ist->filters[i]->filter, frame,
     228             :                                      AV_BUFFERSRC_FLAG_KEEP_REF |
     229             :                                      AV_BUFFERSRC_FLAG_PUSH);
     230         311 : }
     231             : 
     232         117 : void sub2video_update(InputStream *ist, AVSubtitle *sub)
     233             : {
     234         117 :     AVFrame *frame = ist->sub2video.frame;
     235             :     int8_t *dst;
     236             :     int     dst_linesize;
     237             :     int num_rects, i;
     238             :     int64_t pts, end_pts;
     239             : 
     240         117 :     if (!frame)
     241          27 :         return;
     242          90 :     if (sub) {
     243          44 :         pts       = av_rescale_q(sub->pts + sub->start_display_time * 1000LL,
     244          44 :                                  AV_TIME_BASE_Q, ist->st->time_base);
     245          44 :         end_pts   = av_rescale_q(sub->pts + sub->end_display_time   * 1000LL,
     246          44 :                                  AV_TIME_BASE_Q, ist->st->time_base);
     247          44 :         num_rects = sub->num_rects;
     248             :     } else {
     249          46 :         pts       = ist->sub2video.end_pts;
     250          46 :         end_pts   = INT64_MAX;
     251          46 :         num_rects = 0;
     252             :     }
     253          90 :     if (sub2video_get_blank_frame(ist) < 0) {
     254           0 :         av_log(ist->dec_ctx, AV_LOG_ERROR,
     255             :                "Impossible to get a blank canvas.\n");
     256           0 :         return;
     257             :     }
     258          90 :     dst          = frame->data    [0];
     259          90 :     dst_linesize = frame->linesize[0];
     260         134 :     for (i = 0; i < num_rects; i++)
     261          44 :         sub2video_copy_rect(dst, dst_linesize, frame->width, frame->height, sub->rects[i]);
     262          90 :     sub2video_push_ref(ist, pts);
     263          90 :     ist->sub2video.end_pts = end_pts;
     264             : }
     265             : 
     266      376207 : static void sub2video_heartbeat(InputStream *ist, int64_t pts)
     267             : {
     268      376207 :     InputFile *infile = input_files[ist->file_index];
     269             :     int i, j, nb_reqs;
     270             :     int64_t pts2;
     271             : 
     272             :     /* When a frame is read from a file, examine all sub2video streams in
     273             :        the same file and send the sub2video frame again. Otherwise, decoded
     274             :        video frames could be accumulating in the filter graph while a filter
     275             :        (possibly overlay) is desperately waiting for a subtitle frame. */
     276      789973 :     for (i = 0; i < infile->nb_streams; i++) {
     277      413766 :         InputStream *ist2 = input_streams[infile->ist_index + i];
     278      413766 :         if (!ist2->sub2video.frame)
     279      412877 :             continue;
     280             :         /* subtitles seem to be usually muxed ahead of other streams;
     281             :            if not, subtracting a larger time here is necessary */
     282         889 :         pts2 = av_rescale_q(pts, ist->st->time_base, ist2->st->time_base) - 1;
     283             :         /* do not send the heartbeat frame if the subtitle is already ahead */
     284         889 :         if (pts2 <= ist2->sub2video.last_pts)
     285           0 :             continue;
     286         889 :         if (pts2 >= ist2->sub2video.end_pts || !ist2->sub2video.frame->data[0])
     287          44 :             sub2video_update(ist2, NULL);
     288        1778 :         for (j = 0, nb_reqs = 0; j < ist2->nb_filters; j++)
     289         889 :             nb_reqs += av_buffersrc_get_nb_failed_requests(ist2->filters[j]->filter);
     290         889 :         if (nb_reqs)
     291         221 :             sub2video_push_ref(ist2, pts2);
     292             :     }
     293      376207 : }
     294             : 
     295          29 : static void sub2video_flush(InputStream *ist)
     296             : {
     297             :     int i;
     298             : 
     299          29 :     if (ist->sub2video.end_pts < INT64_MAX)
     300          29 :         sub2video_update(ist, NULL);
     301          31 :     for (i = 0; i < ist->nb_filters; i++)
     302           2 :         av_buffersrc_add_frame(ist->filters[i]->filter, NULL);
     303          29 : }
     304             : 
     305             : /* end of sub2video hack */
     306             : 
     307       10311 : static void term_exit_sigsafe(void)
     308             : {
     309             : #if HAVE_TERMIOS_H
     310       10311 :     if(restore_tty)
     311           2 :         tcsetattr (0, TCSANOW, &oldtty);
     312             : #endif
     313       10311 : }
     314             : 
     315       10311 : void term_exit(void)
     316             : {
     317       10311 :     av_log(NULL, AV_LOG_QUIET, "%s", "");
     318       10311 :     term_exit_sigsafe();
     319       10311 : }
     320             : 
     321             : static volatile int received_sigterm = 0;
     322             : static volatile int received_nb_signals = 0;
     323             : static atomic_int transcode_init_done = ATOMIC_VAR_INIT(0);
     324             : static volatile int ffmpeg_exited = 0;
     325             : static int main_return_code = 0;
     326             : 
     327             : static void
     328           0 : sigterm_handler(int sig)
     329             : {
     330           0 :     received_sigterm = sig;
     331           0 :     received_nb_signals++;
     332           0 :     term_exit_sigsafe();
     333           0 :     if(received_nb_signals > 3) {
     334           0 :         write(2/*STDERR_FILENO*/, "Received > 3 system signals, hard exiting\n",
     335             :                            strlen("Received > 3 system signals, hard exiting\n"));
     336             : 
     337           0 :         exit(123);
     338             :     }
     339           0 : }
     340             : 
     341             : #if HAVE_SETCONSOLECTRLHANDLER
     342             : static BOOL WINAPI CtrlHandler(DWORD fdwCtrlType)
     343             : {
     344             :     av_log(NULL, AV_LOG_DEBUG, "\nReceived windows signal %ld\n", fdwCtrlType);
     345             : 
     346             :     switch (fdwCtrlType)
     347             :     {
     348             :     case CTRL_C_EVENT:
     349             :     case CTRL_BREAK_EVENT:
     350             :         sigterm_handler(SIGINT);
     351             :         return TRUE;
     352             : 
     353             :     case CTRL_CLOSE_EVENT:
     354             :     case CTRL_LOGOFF_EVENT:
     355             :     case CTRL_SHUTDOWN_EVENT:
     356             :         sigterm_handler(SIGTERM);
     357             :         /* Basically, with these 3 events, when we return from this method the
     358             :            process is hard terminated, so stall as long as we need to
     359             :            to try and let the main thread(s) clean up and gracefully terminate
     360             :            (we have at most 5 seconds, but should be done far before that). */
     361             :         while (!ffmpeg_exited) {
     362             :             Sleep(0);
     363             :         }
     364             :         return TRUE;
     365             : 
     366             :     default:
     367             :         av_log(NULL, AV_LOG_ERROR, "Received unknown windows signal %ld\n", fdwCtrlType);
     368             :         return FALSE;
     369             :     }
     370             : }
     371             : #endif
     372             : 
     373        5155 : void term_init(void)
     374             : {
     375             : #if HAVE_TERMIOS_H
     376        5155 :     if (!run_as_daemon && stdin_interaction) {
     377             :         struct termios tty;
     378          10 :         if (tcgetattr (0, &tty) == 0) {
     379           1 :             oldtty = tty;
     380           1 :             restore_tty = 1;
     381             : 
     382           1 :             tty.c_iflag &= ~(IGNBRK|BRKINT|PARMRK|ISTRIP
     383             :                              |INLCR|IGNCR|ICRNL|IXON);
     384           1 :             tty.c_oflag |= OPOST;
     385           1 :             tty.c_lflag &= ~(ECHO|ECHONL|ICANON|IEXTEN);
     386           1 :             tty.c_cflag &= ~(CSIZE|PARENB);
     387           1 :             tty.c_cflag |= CS8;
     388           1 :             tty.c_cc[VMIN] = 1;
     389           1 :             tty.c_cc[VTIME] = 0;
     390             : 
     391           1 :             tcsetattr (0, TCSANOW, &tty);
     392             :         }
     393          10 :         signal(SIGQUIT, sigterm_handler); /* Quit (POSIX).  */
     394             :     }
     395             : #endif
     396             : 
     397        5155 :     signal(SIGINT , sigterm_handler); /* Interrupt (ANSI).    */
     398        5155 :     signal(SIGTERM, sigterm_handler); /* Termination (ANSI).  */
     399             : #ifdef SIGXCPU
     400        5155 :     signal(SIGXCPU, sigterm_handler);
     401             : #endif
     402             : #if HAVE_SETCONSOLECTRLHANDLER
     403             :     SetConsoleCtrlHandler((PHANDLER_ROUTINE) CtrlHandler, TRUE);
     404             : #endif
     405        5155 : }
     406             : 
     407             : /* read a key without blocking */
     408          23 : static int read_key(void)
     409             : {
     410             :     unsigned char ch;
     411             : #if HAVE_TERMIOS_H
     412          23 :     int n = 1;
     413             :     struct timeval tv;
     414             :     fd_set rfds;
     415             : 
     416          23 :     FD_ZERO(&rfds);
     417          23 :     FD_SET(0, &rfds);
     418          23 :     tv.tv_sec = 0;
     419          23 :     tv.tv_usec = 0;
     420          23 :     n = select(1, &rfds, NULL, NULL, &tv);
     421          23 :     if (n > 0) {
     422          18 :         n = read(0, &ch, 1);
     423          18 :         if (n == 1)
     424           0 :             return ch;
     425             : 
     426          18 :         return n;
     427             :     }
     428             : #elif HAVE_KBHIT
     429             : #    if HAVE_PEEKNAMEDPIPE
     430             :     static int is_pipe;
     431             :     static HANDLE input_handle;
     432             :     DWORD dw, nchars;
     433             :     if(!input_handle){
     434             :         input_handle = GetStdHandle(STD_INPUT_HANDLE);
     435             :         is_pipe = !GetConsoleMode(input_handle, &dw);
     436             :     }
     437             : 
     438             :     if (is_pipe) {
     439             :         /* When running under a GUI, you will end here. */
     440             :         if (!PeekNamedPipe(input_handle, NULL, 0, NULL, &nchars, NULL)) {
     441             :             // input pipe may have been closed by the program that ran ffmpeg
     442             :             return -1;
     443             :         }
     444             :         //Read it
     445             :         if(nchars != 0) {
     446             :             read(0, &ch, 1);
     447             :             return ch;
     448             :         }else{
     449             :             return -1;
     450             :         }
     451             :     }
     452             : #    endif
     453             :     if(kbhit())
     454             :         return(getch());
     455             : #endif
     456           5 :     return -1;
     457             : }
     458             : 
     459      835609 : static int decode_interrupt_cb(void *ctx)
     460             : {
     461      835609 :     return received_nb_signals > atomic_load(&transcode_init_done);
     462             : }
     463             : 
     464             : const AVIOInterruptCB int_cb = { decode_interrupt_cb, NULL };
     465             : 
     466        5156 : static void ffmpeg_cleanup(int ret)
     467             : {
     468             :     int i, j;
     469             : 
     470        5156 :     if (do_benchmark) {
     471           0 :         int maxrss = getmaxrss() / 1024;
     472           0 :         av_log(NULL, AV_LOG_INFO, "bench: maxrss=%ikB\n", maxrss);
     473             :     }
     474             : 
     475       10238 :     for (i = 0; i < nb_filtergraphs; i++) {
     476        5082 :         FilterGraph *fg = filtergraphs[i];
     477        5082 :         avfilter_graph_free(&fg->graph);
     478       10176 :         for (j = 0; j < fg->nb_inputs; j++) {
     479       10188 :             while (av_fifo_size(fg->inputs[j]->frame_queue)) {
     480             :                 AVFrame *frame;
     481           0 :                 av_fifo_generic_read(fg->inputs[j]->frame_queue, &frame,
     482             :                                      sizeof(frame), NULL);
     483           0 :                 av_frame_free(&frame);
     484             :             }
     485        5094 :             av_fifo_freep(&fg->inputs[j]->frame_queue);
     486        5094 :             if (fg->inputs[j]->ist->sub2video.sub_queue) {
     487           0 :                 while (av_fifo_size(fg->inputs[j]->ist->sub2video.sub_queue)) {
     488             :                     AVSubtitle sub;
     489           0 :                     av_fifo_generic_read(fg->inputs[j]->ist->sub2video.sub_queue,
     490             :                                          &sub, sizeof(sub), NULL);
     491           0 :                     avsubtitle_free(&sub);
     492             :                 }
     493           0 :                 av_fifo_freep(&fg->inputs[j]->ist->sub2video.sub_queue);
     494             :             }
     495        5094 :             av_buffer_unref(&fg->inputs[j]->hw_frames_ctx);
     496        5094 :             av_freep(&fg->inputs[j]->name);
     497        5094 :             av_freep(&fg->inputs[j]);
     498             :         }
     499        5082 :         av_freep(&fg->inputs);
     500       10166 :         for (j = 0; j < fg->nb_outputs; j++) {
     501        5084 :             av_freep(&fg->outputs[j]->name);
     502        5084 :             av_freep(&fg->outputs[j]->formats);
     503        5084 :             av_freep(&fg->outputs[j]->channel_layouts);
     504        5084 :             av_freep(&fg->outputs[j]->sample_rates);
     505        5084 :             av_freep(&fg->outputs[j]);
     506             :         }
     507        5082 :         av_freep(&fg->outputs);
     508        5082 :         av_freep(&fg->graph_desc);
     509             : 
     510        5082 :         av_freep(&filtergraphs[i]);
     511             :     }
     512        5156 :     av_freep(&filtergraphs);
     513             : 
     514        5156 :     av_freep(&subtitle_out);
     515             : 
     516             :     /* close files */
     517       10312 :     for (i = 0; i < nb_output_files; i++) {
     518        5156 :         OutputFile *of = output_files[i];
     519             :         AVFormatContext *s;
     520        5156 :         if (!of)
     521           0 :             continue;
     522        5156 :         s = of->ctx;
     523        5156 :         if (s && s->oformat && !(s->oformat->flags & AVFMT_NOFILE))
     524        5115 :             avio_closep(&s->pb);
     525        5156 :         avformat_free_context(s);
     526        5156 :         av_dict_free(&of->opts);
     527             : 
     528        5156 :         av_freep(&output_files[i]);
     529             :     }
     530       10444 :     for (i = 0; i < nb_output_streams; i++) {
     531        5288 :         OutputStream *ost = output_streams[i];
     532             : 
     533        5288 :         if (!ost)
     534           0 :             continue;
     535             : 
     536        5295 :         for (j = 0; j < ost->nb_bitstream_filters; j++)
     537           7 :             av_bsf_free(&ost->bsf_ctx[j]);
     538        5288 :         av_freep(&ost->bsf_ctx);
     539        5288 :         av_freep(&ost->bsf_extradata_updated);
     540             : 
     541        5288 :         av_frame_free(&ost->filtered_frame);
     542        5288 :         av_frame_free(&ost->last_frame);
     543        5288 :         av_dict_free(&ost->encoder_opts);
     544             : 
     545        5288 :         av_parser_close(ost->parser);
     546        5288 :         avcodec_free_context(&ost->parser_avctx);
     547             : 
     548        5288 :         av_freep(&ost->forced_keyframes);
     549        5288 :         av_expr_free(ost->forced_keyframes_pexpr);
     550        5288 :         av_freep(&ost->avfilter);
     551        5288 :         av_freep(&ost->logfile_prefix);
     552             : 
     553        5288 :         av_freep(&ost->audio_channels_map);
     554        5288 :         ost->audio_channels_mapped = 0;
     555             : 
     556        5288 :         av_dict_free(&ost->sws_dict);
     557             : 
     558        5288 :         avcodec_free_context(&ost->enc_ctx);
     559        5288 :         avcodec_parameters_free(&ost->ref_par);
     560             : 
     561        5288 :         if (ost->muxing_queue) {
     562       10576 :             while (av_fifo_size(ost->muxing_queue)) {
     563             :                 AVPacket pkt;
     564           0 :                 av_fifo_generic_read(ost->muxing_queue, &pkt, sizeof(pkt), NULL);
     565           0 :                 av_packet_unref(&pkt);
     566             :             }
     567        5288 :             av_fifo_freep(&ost->muxing_queue);
     568             :         }
     569             : 
     570        5288 :         av_freep(&output_streams[i]);
     571             :     }
     572             : #if HAVE_PTHREADS
     573        5156 :     free_input_threads();
     574             : #endif
     575       10370 :     for (i = 0; i < nb_input_files; i++) {
     576        5214 :         avformat_close_input(&input_files[i]->ctx);
     577        5214 :         av_freep(&input_files[i]);
     578             :     }
     579       10669 :     for (i = 0; i < nb_input_streams; i++) {
     580        5513 :         InputStream *ist = input_streams[i];
     581             : 
     582        5513 :         av_frame_free(&ist->decoded_frame);
     583        5513 :         av_frame_free(&ist->filter_frame);
     584        5513 :         av_dict_free(&ist->decoder_opts);
     585        5513 :         avsubtitle_free(&ist->prev_sub.subtitle);
     586        5513 :         av_frame_free(&ist->sub2video.frame);
     587        5513 :         av_freep(&ist->filters);
     588        5513 :         av_freep(&ist->hwaccel_device);
     589        5513 :         av_freep(&ist->dts_buffer);
     590             : 
     591        5513 :         avcodec_free_context(&ist->dec_ctx);
     592             : 
     593        5513 :         av_freep(&input_streams[i]);
     594             :     }
     595             : 
     596        5156 :     if (vstats_file) {
     597           0 :         if (fclose(vstats_file))
     598           0 :             av_log(NULL, AV_LOG_ERROR,
     599             :                    "Error closing vstats file, loss of information possible: %s\n",
     600           0 :                    av_err2str(AVERROR(errno)));
     601             :     }
     602        5156 :     av_freep(&vstats_filename);
     603             : 
     604        5156 :     av_freep(&input_streams);
     605        5156 :     av_freep(&input_files);
     606        5156 :     av_freep(&output_streams);
     607        5156 :     av_freep(&output_files);
     608             : 
     609        5156 :     uninit_opts();
     610             : 
     611        5156 :     avformat_network_deinit();
     612             : 
     613        5156 :     if (received_sigterm) {
     614           0 :         av_log(NULL, AV_LOG_INFO, "Exiting normally, received signal %d.\n",
     615             :                (int) received_sigterm);
     616        5156 :     } else if (ret && atomic_load(&transcode_init_done)) {
     617           0 :         av_log(NULL, AV_LOG_INFO, "Conversion failed!\n");
     618             :     }
     619        5156 :     term_exit();
     620        5156 :     ffmpeg_exited = 1;
     621        5156 : }
     622             : 
     623        5214 : void remove_avoptions(AVDictionary **a, AVDictionary *b)
     624             : {
     625        5214 :     AVDictionaryEntry *t = NULL;
     626             : 
     627       26868 :     while ((t = av_dict_get(b, "", t, AV_DICT_IGNORE_SUFFIX))) {
     628       16440 :         av_dict_set(a, t->key, NULL, AV_DICT_MATCH_CASE);
     629             :     }
     630        5214 : }
     631             : 
     632       15446 : void assert_avoptions(AVDictionary *m)
     633             : {
     634             :     AVDictionaryEntry *t;
     635       15446 :     if ((t = av_dict_get(m, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
     636           0 :         av_log(NULL, AV_LOG_FATAL, "Option %s not found.\n", t->key);
     637           0 :         exit_program(1);
     638             :     }
     639       15446 : }
     640             : 
     641           0 : static void abort_codec_experimental(AVCodec *c, int encoder)
     642             : {
     643           0 :     exit_program(1);
     644             : }
     645             : 
     646     2342319 : static void update_benchmark(const char *fmt, ...)
     647             : {
     648     2342319 :     if (do_benchmark_all) {
     649           0 :         int64_t t = getutime();
     650             :         va_list va;
     651             :         char buf[1024];
     652             : 
     653           0 :         if (fmt) {
     654           0 :             va_start(va, fmt);
     655           0 :             vsnprintf(buf, sizeof(buf), fmt, va);
     656           0 :             va_end(va);
     657           0 :             av_log(NULL, AV_LOG_INFO, "bench: %8"PRIu64" %s \n", t - current_time, buf);
     658             :         }
     659           0 :         current_time = t;
     660             :     }
     661     2342319 : }
     662             : 
     663           0 : static void close_all_output_streams(OutputStream *ost, OSTFinished this_stream, OSTFinished others)
     664             : {
     665             :     int i;
     666           0 :     for (i = 0; i < nb_output_streams; i++) {
     667           0 :         OutputStream *ost2 = output_streams[i];
     668           0 :         ost2->finished |= ost == ost2 ? this_stream : others;
     669             :     }
     670           0 : }
     671             : 
     672      404851 : static void write_packet(OutputFile *of, AVPacket *pkt, OutputStream *ost)
     673             : {
     674      404851 :     AVFormatContext *s = of->ctx;
     675      404851 :     AVStream *st = ost->st;
     676             :     int ret;
     677             : 
     678      404851 :     if (!of->header_written) {
     679         270 :         AVPacket tmp_pkt = {0};
     680             :         /* the muxer is not initialized yet, buffer the packet */
     681         270 :         if (!av_fifo_space(ost->muxing_queue)) {
     682          16 :             int new_size = FFMIN(2 * av_fifo_size(ost->muxing_queue),
     683             :                                  ost->max_muxing_queue_size);
     684          16 :             if (new_size <= av_fifo_size(ost->muxing_queue)) {
     685           0 :                 av_log(NULL, AV_LOG_ERROR,
     686             :                        "Too many packets buffered for output stream %d:%d.\n",
     687           0 :                        ost->file_index, ost->st->index);
     688           0 :                 exit_program(1);
     689             :             }
     690          16 :             ret = av_fifo_realloc2(ost->muxing_queue, new_size);
     691          16 :             if (ret < 0)
     692           0 :                 exit_program(1);
     693             :         }
     694         270 :         ret = av_packet_ref(&tmp_pkt, pkt);
     695         270 :         if (ret < 0)
     696           0 :             exit_program(1);
     697         270 :         av_fifo_generic_write(ost->muxing_queue, &tmp_pkt, sizeof(tmp_pkt), NULL);
     698         270 :         av_packet_unref(pkt);
     699         270 :         return;
     700             :     }
     701             : 
     702      785841 :     if ((st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && video_sync_method == VSYNC_DROP) ||
     703      686766 :         (st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO && audio_sync_method < 0))
     704       23321 :         pkt->pts = pkt->dts = AV_NOPTS_VALUE;
     705             : 
     706             :     /*
     707             :      * Audio encoders may split the packets --  #frames in != #packets out.
     708             :      * But there is no reordering, so we can limit the number of output packets
     709             :      * by simply dropping them here.
     710             :      * Counting encoded video frames needs to be done separately because of
     711             :      * reordering, see do_video_out()
     712             :      */
     713      404581 :     if (!(st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && ost->encoding_needed)) {
     714      310194 :         if (ost->frame_number >= ost->max_frames) {
     715         313 :             av_packet_unref(pkt);
     716         313 :             return;
     717             :         }
     718      309881 :         ost->frame_number++;
     719             :     }
     720      404268 :     if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
     721             :         int i;
     722       97973 :         uint8_t *sd = av_packet_get_side_data(pkt, AV_PKT_DATA_QUALITY_STATS,
     723             :                                               NULL);
     724       97973 :         ost->quality = sd ? AV_RL32(sd) : -1;
     725       97973 :         ost->pict_type = sd ? sd[4] : AV_PICTURE_TYPE_NONE;
     726             : 
     727      489865 :         for (i = 0; i<FF_ARRAY_ELEMS(ost->error); i++) {
     728      391892 :             if (sd && i < sd[5])
     729           0 :                 ost->error[i] = AV_RL64(sd + 8 + 8*i);
     730             :             else
     731      391892 :                 ost->error[i] = -1;
     732             :         }
     733             : 
     734       97973 :         if (ost->frame_rate.num && ost->is_cfr) {
     735        8394 :             if (pkt->duration > 0)
     736           0 :                 av_log(NULL, AV_LOG_WARNING, "Overriding packet duration by frame rate, this should not happen\n");
     737        8394 :             pkt->duration = av_rescale_q(1, av_inv_q(ost->frame_rate),
     738             :                                          ost->mux_timebase);
     739             :         }
     740             :     }
     741             : 
     742      404268 :     av_packet_rescale_ts(pkt, ost->mux_timebase, ost->st->time_base);
     743             : 
     744      404268 :     if (!(s->oformat->flags & AVFMT_NOTIMESTAMPS)) {
     745      325855 :         if (pkt->dts != AV_NOPTS_VALUE &&
     746      302015 :             pkt->pts != AV_NOPTS_VALUE &&
     747      150748 :             pkt->dts > pkt->pts) {
     748           0 :             av_log(s, AV_LOG_WARNING, "Invalid DTS: %"PRId64" PTS: %"PRId64" in output stream %d:%d, replacing by guess\n",
     749             :                    pkt->dts, pkt->pts,
     750           0 :                    ost->file_index, ost->st->index);
     751           0 :             pkt->pts =
     752           0 :             pkt->dts = pkt->pts + pkt->dts + ost->last_mux_dts + 1
     753           0 :                      - FFMIN3(pkt->pts, pkt->dts, ost->last_mux_dts + 1)
     754           0 :                      - FFMAX3(pkt->pts, pkt->dts, ost->last_mux_dts + 1);
     755             :         }
     756      348578 :         if ((st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO || st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) &&
     757      324659 :             pkt->dts != AV_NOPTS_VALUE &&
     758      301338 :             !(st->codecpar->codec_id == AV_CODEC_ID_VP9 && ost->stream_copy) &&
     759      150616 :             ost->last_mux_dts != AV_NOPTS_VALUE) {
     760      146788 :             int64_t max = ost->last_mux_dts + !(s->oformat->flags & AVFMT_TS_NONSTRICT);
     761      146788 :             if (pkt->dts < max) {
     762           0 :                 int loglevel = max - pkt->dts > 2 || st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO ? AV_LOG_WARNING : AV_LOG_DEBUG;
     763           0 :                 av_log(s, loglevel, "Non-monotonous DTS in output stream "
     764             :                        "%d:%d; previous: %"PRId64", current: %"PRId64"; ",
     765           0 :                        ost->file_index, ost->st->index, ost->last_mux_dts, pkt->dts);
     766           0 :                 if (exit_on_error) {
     767           0 :                     av_log(NULL, AV_LOG_FATAL, "aborting.\n");
     768           0 :                     exit_program(1);
     769             :                 }
     770           0 :                 av_log(s, loglevel, "changing to %"PRId64". This may result "
     771             :                        "in incorrect timestamps in the output file.\n",
     772             :                        max);
     773           0 :                 if (pkt->pts >= pkt->dts)
     774           0 :                     pkt->pts = FFMAX(pkt->pts, max);
     775           0 :                 pkt->dts = max;
     776             :             }
     777             :         }
     778             :     }
     779      404268 :     ost->last_mux_dts = pkt->dts;
     780             : 
     781      404268 :     ost->data_size += pkt->size;
     782      404268 :     ost->packets_written++;
     783             : 
     784      404268 :     pkt->stream_index = ost->index;
     785             : 
     786      404268 :     if (debug_ts) {
     787           0 :         av_log(NULL, AV_LOG_INFO, "muxer <- type:%s "
     788             :                 "pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s size:%d\n",
     789           0 :                 av_get_media_type_string(ost->enc_ctx->codec_type),
     790           0 :                 av_ts2str(pkt->pts), av_ts2timestr(pkt->pts, &ost->st->time_base),
     791           0 :                 av_ts2str(pkt->dts), av_ts2timestr(pkt->dts, &ost->st->time_base),
     792             :                 pkt->size
     793             :               );
     794             :     }
     795             : 
     796      404268 :     ret = av_interleaved_write_frame(s, pkt);
     797      404268 :     if (ret < 0) {
     798           0 :         print_error("av_interleaved_write_frame()", ret);
     799           0 :         main_return_code = 1;
     800           0 :         close_all_output_streams(ost, MUXER_FINISHED | ENCODER_FINISHED, ENCODER_FINISHED);
     801             :     }
     802      404268 :     av_packet_unref(pkt);
     803             : }
     804             : 
     805        5096 : static void close_output_stream(OutputStream *ost)
     806             : {
     807        5096 :     OutputFile *of = output_files[ost->file_index];
     808             : 
     809        5096 :     ost->finished |= ENCODER_FINISHED;
     810        5096 :     if (of->shortest) {
     811           0 :         int64_t end = av_rescale_q(ost->sync_opts - ost->first_pts, ost->enc_ctx->time_base, AV_TIME_BASE_Q);
     812           0 :         of->recording_time = FFMIN(of->recording_time, end);
     813             :     }
     814        5096 : }
     815             : 
     816      404582 : static void output_packet(OutputFile *of, AVPacket *pkt, OutputStream *ost)
     817             : {
     818      404582 :     int ret = 0;
     819             : 
     820             :     /* apply the output bitstream filters, if any */
     821      404582 :     if (ost->nb_bitstream_filters) {
     822             :         int idx;
     823             : 
     824         309 :         ret = av_bsf_send_packet(ost->bsf_ctx[0], pkt);
     825         309 :         if (ret < 0)
     826           0 :             goto finish;
     827             : 
     828         309 :         idx = 1;
     829        1234 :         while (idx) {
     830             :             /* get a packet from the previous filter up the chain */
     831         617 :             ret = av_bsf_receive_packet(ost->bsf_ctx[idx - 1], pkt);
     832         617 :             if (ret == AVERROR(EAGAIN)) {
     833         308 :                 ret = 0;
     834         308 :                 idx--;
     835         308 :                 continue;
     836         309 :             } else if (ret < 0)
     837           1 :                 goto finish;
     838             :             /* HACK! - aac_adtstoasc updates extradata after filtering the first frame when
     839             :              * the api states this shouldn't happen after init(). Propagate it here to the
     840             :              * muxer and to the next filters in the chain to workaround this.
     841             :              * TODO/FIXME - Make aac_adtstoasc use new packet side data instead of changing
     842             :              * par_out->extradata and adapt muxers accordingly to get rid of this. */
     843         308 :             if (!(ost->bsf_extradata_updated[idx - 1] & 1)) {
     844           7 :                 ret = avcodec_parameters_copy(ost->st->codecpar, ost->bsf_ctx[idx - 1]->par_out);
     845           7 :                 if (ret < 0)
     846           0 :                     goto finish;
     847           7 :                 ost->bsf_extradata_updated[idx - 1] |= 1;
     848             :             }
     849             : 
     850             :             /* send it to the next filter down the chain or to the muxer */
     851         308 :             if (idx < ost->nb_bitstream_filters) {
     852             :                 /* HACK/FIXME! - See above */
     853           0 :                 if (!(ost->bsf_extradata_updated[idx] & 2)) {
     854           0 :                     ret = avcodec_parameters_copy(ost->bsf_ctx[idx]->par_out, ost->bsf_ctx[idx - 1]->par_out);
     855           0 :                     if (ret < 0)
     856           0 :                         goto finish;
     857           0 :                     ost->bsf_extradata_updated[idx] |= 2;
     858             :                 }
     859           0 :                 ret = av_bsf_send_packet(ost->bsf_ctx[idx], pkt);
     860           0 :                 if (ret < 0)
     861           0 :                     goto finish;
     862           0 :                 idx++;
     863             :             } else
     864         308 :                 write_packet(of, pkt, ost);
     865             :         }
     866             :     } else
     867      404273 :         write_packet(of, pkt, ost);
     868             : 
     869             : finish:
     870      404582 :     if (ret < 0 && ret != AVERROR_EOF) {
     871           1 :         av_log(NULL, AV_LOG_ERROR, "Error applying bitstream filters to an output "
     872             :                "packet for stream #%d:%d.\n", ost->file_index, ost->index);
     873           1 :         if(exit_on_error)
     874           0 :             exit_program(1);
     875             :     }
     876      404582 : }
     877             : 
     878      384654 : static int check_recording_time(OutputStream *ost)
     879             : {
     880      384654 :     OutputFile *of = output_files[ost->file_index];
     881             : 
     882      390655 :     if (of->recording_time != INT64_MAX &&
     883        6001 :         av_compare_ts(ost->sync_opts - ost->first_pts, ost->enc_ctx->time_base, of->recording_time,
     884        6001 :                       AV_TIME_BASE_Q) >= 0) {
     885           1 :         close_output_stream(ost);
     886           1 :         return 0;
     887             :     }
     888      384653 :     return 1;
     889             : }
     890             : 
     891      289684 : static void do_audio_out(OutputFile *of, OutputStream *ost,
     892             :                          AVFrame *frame)
     893             : {
     894      289684 :     AVCodecContext *enc = ost->enc_ctx;
     895             :     AVPacket pkt;
     896             :     int ret;
     897             : 
     898      289684 :     av_init_packet(&pkt);
     899      289684 :     pkt.data = NULL;
     900      289684 :     pkt.size = 0;
     901             : 
     902      289684 :     if (!check_recording_time(ost))
     903           0 :         return;
     904             : 
     905      289684 :     if (frame->pts == AV_NOPTS_VALUE || audio_sync_method < 0)
     906         341 :         frame->pts = ost->sync_opts;
     907      289684 :     ost->sync_opts = frame->pts + frame->nb_samples;
     908      289684 :     ost->samples_encoded += frame->nb_samples;
     909      289684 :     ost->frames_encoded++;
     910             : 
     911      289684 :     av_assert0(pkt.size || !pkt.data);
     912      289684 :     update_benchmark(NULL);
     913      289684 :     if (debug_ts) {
     914           0 :         av_log(NULL, AV_LOG_INFO, "encoder <- type:audio "
     915             :                "frame_pts:%s frame_pts_time:%s time_base:%d/%d\n",
     916           0 :                av_ts2str(frame->pts), av_ts2timestr(frame->pts, &enc->time_base),
     917             :                enc->time_base.num, enc->time_base.den);
     918             :     }
     919             : 
     920      289684 :     ret = avcodec_send_frame(enc, frame);
     921      289684 :     if (ret < 0)
     922           0 :         goto error;
     923             : 
     924             :     while (1) {
     925      289665 :         ret = avcodec_receive_packet(enc, &pkt);
     926      579349 :         if (ret == AVERROR(EAGAIN))
     927      289684 :             break;
     928      289665 :         if (ret < 0)
     929           0 :             goto error;
     930             : 
     931      289665 :         update_benchmark("encode_audio %d.%d", ost->file_index, ost->index);
     932             : 
     933      289665 :         av_packet_rescale_ts(&pkt, enc->time_base, ost->mux_timebase);
     934             : 
     935      289665 :         if (debug_ts) {
     936           0 :             av_log(NULL, AV_LOG_INFO, "encoder -> type:audio "
     937             :                    "pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s\n",
     938           0 :                    av_ts2str(pkt.pts), av_ts2timestr(pkt.pts, &enc->time_base),
     939           0 :                    av_ts2str(pkt.dts), av_ts2timestr(pkt.dts, &enc->time_base));
     940             :         }
     941             : 
     942      289665 :         output_packet(of, &pkt, ost);
     943             :     }
     944             : 
     945      289684 :     return;
     946             : error:
     947           0 :     av_log(NULL, AV_LOG_FATAL, "Audio encoding failed\n");
     948           0 :     exit_program(1);
     949             : }
     950             : 
     951         582 : static void do_subtitle_out(OutputFile *of,
     952             :                             OutputStream *ost,
     953             :                             AVSubtitle *sub)
     954             : {
     955         582 :     int subtitle_out_max_size = 1024 * 1024;
     956             :     int subtitle_out_size, nb, i;
     957             :     AVCodecContext *enc;
     958             :     AVPacket pkt;
     959             :     int64_t pts;
     960             : 
     961         582 :     if (sub->pts == AV_NOPTS_VALUE) {
     962           0 :         av_log(NULL, AV_LOG_ERROR, "Subtitle packets must have a pts\n");
     963           0 :         if (exit_on_error)
     964           0 :             exit_program(1);
     965           0 :         return;
     966             :     }
     967             : 
     968         582 :     enc = ost->enc_ctx;
     969             : 
     970         582 :     if (!subtitle_out) {
     971          28 :         subtitle_out = av_malloc(subtitle_out_max_size);
     972          28 :         if (!subtitle_out) {
     973           0 :             av_log(NULL, AV_LOG_FATAL, "Failed to allocate subtitle_out\n");
     974           0 :             exit_program(1);
     975             :         }
     976             :     }
     977             : 
     978             :     /* Note: DVB subtitle need one packet to draw them and one other
     979             :        packet to clear them */
     980             :     /* XXX: signal it in the codec context ? */
     981         582 :     if (enc->codec_id == AV_CODEC_ID_DVB_SUBTITLE)
     982           0 :         nb = 2;
     983             :     else
     984         582 :         nb = 1;
     985             : 
     986             :     /* shift timestamp to honor -ss and make check_recording_time() work with -t */
     987         582 :     pts = sub->pts;
     988         582 :     if (output_files[ost->file_index]->start_time != AV_NOPTS_VALUE)
     989           0 :         pts -= output_files[ost->file_index]->start_time;
     990        1164 :     for (i = 0; i < nb; i++) {
     991         582 :         unsigned save_num_rects = sub->num_rects;
     992             : 
     993         582 :         ost->sync_opts = av_rescale_q(pts, AV_TIME_BASE_Q, enc->time_base);
     994         582 :         if (!check_recording_time(ost))
     995           0 :             return;
     996             : 
     997         582 :         sub->pts = pts;
     998             :         // start_display_time is required to be 0
     999         582 :         sub->pts               += av_rescale_q(sub->start_display_time, (AVRational){ 1, 1000 }, AV_TIME_BASE_Q);
    1000         582 :         sub->end_display_time  -= sub->start_display_time;
    1001         582 :         sub->start_display_time = 0;
    1002         582 :         if (i == 1)
    1003           0 :             sub->num_rects = 0;
    1004             : 
    1005         582 :         ost->frames_encoded++;
    1006             : 
    1007         582 :         subtitle_out_size = avcodec_encode_subtitle(enc, subtitle_out,
    1008             :                                                     subtitle_out_max_size, sub);
    1009         582 :         if (i == 1)
    1010           0 :             sub->num_rects = save_num_rects;
    1011         582 :         if (subtitle_out_size < 0) {
    1012           0 :             av_log(NULL, AV_LOG_FATAL, "Subtitle encoding failed\n");
    1013           0 :             exit_program(1);
    1014             :         }
    1015             : 
    1016         582 :         av_init_packet(&pkt);
    1017         582 :         pkt.data = subtitle_out;
    1018         582 :         pkt.size = subtitle_out_size;
    1019         582 :         pkt.pts  = av_rescale_q(sub->pts, AV_TIME_BASE_Q, ost->mux_timebase);
    1020         582 :         pkt.duration = av_rescale_q(sub->end_display_time, (AVRational){ 1, 1000 }, ost->mux_timebase);
    1021         582 :         if (enc->codec_id == AV_CODEC_ID_DVB_SUBTITLE) {
    1022             :             /* XXX: the pts correction is handled here. Maybe handling
    1023             :                it in the codec would be better */
    1024           0 :             if (i == 0)
    1025           0 :                 pkt.pts += av_rescale_q(sub->start_display_time, (AVRational){ 1, 1000 }, ost->mux_timebase);
    1026             :             else
    1027           0 :                 pkt.pts += av_rescale_q(sub->end_display_time, (AVRational){ 1, 1000 }, ost->mux_timebase);
    1028             :         }
    1029         582 :         pkt.dts = pkt.pts;
    1030         582 :         output_packet(of, &pkt, ost);
    1031             :     }
    1032             : }
    1033             : 
    1034       96554 : static void do_video_out(OutputFile *of,
    1035             :                          OutputStream *ost,
    1036             :                          AVFrame *next_picture,
    1037             :                          double sync_ipts)
    1038             : {
    1039             :     int ret, format_video_sync;
    1040             :     AVPacket pkt;
    1041       96554 :     AVCodecContext *enc = ost->enc_ctx;
    1042       96554 :     AVCodecParameters *mux_par = ost->st->codecpar;
    1043             :     AVRational frame_rate;
    1044             :     int nb_frames, nb0_frames, i;
    1045             :     double delta, delta0;
    1046       96554 :     double duration = 0;
    1047       96554 :     int frame_size = 0;
    1048       96554 :     InputStream *ist = NULL;
    1049       96554 :     AVFilterContext *filter = ost->filter->filter;
    1050             : 
    1051       96554 :     if (ost->source_index >= 0)
    1052       95475 :         ist = input_streams[ost->source_index];
    1053             : 
    1054       96554 :     frame_rate = av_buffersink_get_frame_rate(filter);
    1055       96554 :     if (frame_rate.num > 0 && frame_rate.den > 0)
    1056       96554 :         duration = 1/(av_q2d(frame_rate) * av_q2d(enc->time_base));
    1057             : 
    1058       96554 :     if(ist && ist->st->start_time != AV_NOPTS_VALUE && ist->st->first_dts != AV_NOPTS_VALUE && ost->frame_rate.num)
    1059       61150 :         duration = FFMIN(duration, 1/(av_q2d(ost->frame_rate) * av_q2d(enc->time_base)));
    1060             : 
    1061      193011 :     if (!ost->filters_script &&
    1062      187128 :         !ost->filters &&
    1063       88498 :         next_picture &&
    1064       87436 :         ist &&
    1065       87436 :         lrintf(next_picture->pkt_duration * av_q2d(ist->st->time_base) / av_q2d(enc->time_base)) > 0) {
    1066       82660 :         duration = lrintf(next_picture->pkt_duration * av_q2d(ist->st->time_base) / av_q2d(enc->time_base));
    1067             :     }
    1068             : 
    1069       96554 :     if (!next_picture) {
    1070             :         //end, flushing
    1071        2230 :         nb0_frames = nb_frames = mid_pred(ost->last_nb0_frames[0],
    1072             :                                           ost->last_nb0_frames[1],
    1073             :                                           ost->last_nb0_frames[2]);
    1074             :     } else {
    1075       94324 :         delta0 = sync_ipts - ost->sync_opts; // delta0 is the "drift" between the input frame (next_picture) and where it would fall in the output.
    1076       94324 :         delta  = delta0 + duration;
    1077             : 
    1078             :         /* by default, we output a single frame */
    1079       94324 :         nb0_frames = 0; // tracks the number of times the PREVIOUS frame should be duplicated, mostly for variable framerate (VFR)
    1080       94324 :         nb_frames = 1;
    1081             : 
    1082       94324 :         format_video_sync = video_sync_method;
    1083       94324 :         if (format_video_sync == VSYNC_AUTO) {
    1084       52583 :             if(!strcmp(of->ctx->oformat->name, "avi")) {
    1085       12500 :                 format_video_sync = VSYNC_VFR;
    1086             :             } else
    1087       40083 :                 format_video_sync = (of->ctx->oformat->flags & AVFMT_VARIABLE_FPS) ? ((of->ctx->oformat->flags & AVFMT_NOTIMESTAMPS) ? VSYNC_PASSTHROUGH : VSYNC_VFR) : VSYNC_CFR;
    1088       52583 :             if (   ist
    1089       51521 :                 && format_video_sync == VSYNC_CFR
    1090        8044 :                 && input_files[ist->file_index]->ctx->nb_streams == 1
    1091        7049 :                 && input_files[ist->file_index]->input_ts_offset == 0) {
    1092        7049 :                 format_video_sync = VSYNC_VSCFR;
    1093             :             }
    1094       52583 :             if (format_video_sync == VSYNC_CFR && copy_ts) {
    1095           0 :                 format_video_sync = VSYNC_VSCFR;
    1096             :             }
    1097             :         }
    1098       94324 :         ost->is_cfr = (format_video_sync == VSYNC_CFR || format_video_sync == VSYNC_VSCFR);
    1099             : 
    1100       94324 :         if (delta0 < 0 &&
    1101       10513 :             delta > 0 &&
    1102       10115 :             format_video_sync != VSYNC_PASSTHROUGH &&
    1103             :             format_video_sync != VSYNC_DROP) {
    1104        7347 :             if (delta0 < -0.6) {
    1105         464 :                 av_log(NULL, AV_LOG_WARNING, "Past duration %f too large\n", -delta0);
    1106             :             } else
    1107        6883 :                 av_log(NULL, AV_LOG_DEBUG, "Clipping frame in rate conversion by %f\n", -delta0);
    1108        7347 :             sync_ipts = ost->sync_opts;
    1109        7347 :             duration += delta0;
    1110        7347 :             delta0 = 0;
    1111             :         }
    1112             : 
    1113       94324 :         switch (format_video_sync) {
    1114             :         case VSYNC_VSCFR:
    1115        7049 :             if (ost->frame_number == 0 && delta0 >= 0.5) {
    1116           0 :                 av_log(NULL, AV_LOG_DEBUG, "Not duplicating %d initial frames\n", (int)lrintf(delta0));
    1117           0 :                 delta = duration;
    1118           0 :                 delta0 = 0;
    1119           0 :                 ost->sync_opts = lrint(sync_ipts);
    1120             :             }
    1121             :         case VSYNC_CFR:
    1122             :             // FIXME set to 0.5 after we fix some dts/pts bugs like in avidec.c
    1123        8183 :             if (frame_drop_threshold && delta < frame_drop_threshold && ost->frame_number) {
    1124           0 :                 nb_frames = 0;
    1125        8183 :             } else if (delta < -1.1)
    1126           0 :                 nb_frames = 0;
    1127        8183 :             else if (delta > 1.1) {
    1128         375 :                 nb_frames = lrintf(delta);
    1129         375 :                 if (delta0 > 1.1)
    1130           2 :                     nb0_frames = lrintf(delta0 - 0.6);
    1131             :             }
    1132        8183 :             break;
    1133             :         case VSYNC_VFR:
    1134       44542 :             if (delta <= -0.6)
    1135         145 :                 nb_frames = 0;
    1136       44397 :             else if (delta > 0.6)
    1137       43780 :                 ost->sync_opts = lrint(sync_ipts);
    1138       44542 :             break;
    1139             :         case VSYNC_DROP:
    1140             :         case VSYNC_PASSTHROUGH:
    1141       41599 :             ost->sync_opts = lrint(sync_ipts);
    1142       41599 :             break;
    1143             :         default:
    1144           0 :             av_assert0(0);
    1145             :         }
    1146             :     }
    1147             : 
    1148       96554 :     nb_frames = FFMIN(nb_frames, ost->max_frames - ost->frame_number);
    1149       96554 :     nb0_frames = FFMIN(nb0_frames, nb_frames);
    1150             : 
    1151       96554 :     memmove(ost->last_nb0_frames + 1,
    1152       96554 :             ost->last_nb0_frames,
    1153             :             sizeof(ost->last_nb0_frames[0]) * (FF_ARRAY_ELEMS(ost->last_nb0_frames) - 1));
    1154       96554 :     ost->last_nb0_frames[0] = nb0_frames;
    1155             : 
    1156       96554 :     if (nb0_frames == 0 && ost->last_dropped) {
    1157         145 :         nb_frames_drop++;
    1158         290 :         av_log(NULL, AV_LOG_VERBOSE,
    1159             :                "*** dropping frame %d from stream %d at ts %"PRId64"\n",
    1160         290 :                ost->frame_number, ost->st->index, ost->last_frame->pts);
    1161             :     }
    1162       96554 :     if (nb_frames > (nb0_frames && ost->last_dropped) + (nb_frames > nb0_frames)) {
    1163          49 :         if (nb_frames > dts_error_threshold * 30) {
    1164           0 :             av_log(NULL, AV_LOG_ERROR, "%d frame duplication too large, skipping\n", nb_frames - 1);
    1165           0 :             nb_frames_drop++;
    1166           0 :             return;
    1167             :         }
    1168          49 :         nb_frames_dup += nb_frames - (nb0_frames && ost->last_dropped) - (nb_frames > nb0_frames);
    1169          49 :         av_log(NULL, AV_LOG_VERBOSE, "*** %d dup!\n", nb_frames - 1);
    1170          49 :         if (nb_frames_dup > dup_warning) {
    1171           0 :             av_log(NULL, AV_LOG_WARNING, "More than %d frames duplicated\n", dup_warning);
    1172           0 :             dup_warning *= 10;
    1173             :         }
    1174             :     }
    1175       96554 :     ost->last_dropped = nb_frames == nb0_frames && next_picture;
    1176             : 
    1177             :   /* duplicates frame if needed */
    1178      190941 :   for (i = 0; i < nb_frames; i++) {
    1179             :     AVFrame *in_picture;
    1180       94388 :     av_init_packet(&pkt);
    1181       94388 :     pkt.data = NULL;
    1182       94388 :     pkt.size = 0;
    1183             : 
    1184       94388 :     if (i < nb0_frames && ost->last_frame) {
    1185          69 :         in_picture = ost->last_frame;
    1186             :     } else
    1187       94319 :         in_picture = next_picture;
    1188             : 
    1189       94388 :     if (!in_picture)
    1190           0 :         return;
    1191             : 
    1192       94388 :     in_picture->pts = ost->sync_opts;
    1193             : 
    1194             : #if 1
    1195       94388 :     if (!check_recording_time(ost))
    1196             : #else
    1197             :     if (ost->frame_number >= ost->max_frames)
    1198             : #endif
    1199           1 :         return;
    1200             : 
    1201             : #if FF_API_LAVF_FMT_RAWPICTURE
    1202       94387 :     if (of->ctx->oformat->flags & AVFMT_RAWPICTURE &&
    1203           0 :         enc->codec->id == AV_CODEC_ID_RAWVIDEO) {
    1204             :         /* raw pictures are written as AVPicture structure to
    1205             :            avoid any copies. We support temporarily the older
    1206             :            method. */
    1207           0 :         if (in_picture->interlaced_frame)
    1208           0 :             mux_par->field_order = in_picture->top_field_first ? AV_FIELD_TB:AV_FIELD_BT;
    1209             :         else
    1210           0 :             mux_par->field_order = AV_FIELD_PROGRESSIVE;
    1211           0 :         pkt.data   = (uint8_t *)in_picture;
    1212           0 :         pkt.size   =  sizeof(AVPicture);
    1213           0 :         pkt.pts    = av_rescale_q(in_picture->pts, enc->time_base, ost->mux_timebase);
    1214           0 :         pkt.flags |= AV_PKT_FLAG_KEY;
    1215             : 
    1216           0 :         output_packet(of, &pkt, ost);
    1217             :     } else
    1218             : #endif
    1219             :     {
    1220       94387 :         int forced_keyframe = 0;
    1221             :         double pts_time;
    1222             : 
    1223       95267 :         if (enc->flags & (AV_CODEC_FLAG_INTERLACED_DCT | AV_CODEC_FLAG_INTERLACED_ME) &&
    1224         880 :             ost->top_field_first >= 0)
    1225          25 :             in_picture->top_field_first = !!ost->top_field_first;
    1226             : 
    1227       94387 :         if (in_picture->interlaced_frame) {
    1228        6199 :             if (enc->codec->id == AV_CODEC_ID_MJPEG)
    1229           0 :                 mux_par->field_order = in_picture->top_field_first ? AV_FIELD_TT:AV_FIELD_BB;
    1230             :             else
    1231        6199 :                 mux_par->field_order = in_picture->top_field_first ? AV_FIELD_TB:AV_FIELD_BT;
    1232             :         } else
    1233       88188 :             mux_par->field_order = AV_FIELD_PROGRESSIVE;
    1234             : 
    1235       94387 :         in_picture->quality = enc->global_quality;
    1236       94387 :         in_picture->pict_type = 0;
    1237             : 
    1238      188774 :         pts_time = in_picture->pts != AV_NOPTS_VALUE ?
    1239       94387 :             in_picture->pts * av_q2d(enc->time_base) : NAN;
    1240       94426 :         if (ost->forced_kf_index < ost->forced_kf_count &&
    1241          39 :             in_picture->pts >= ost->forced_kf_pts[ost->forced_kf_index]) {
    1242           2 :             ost->forced_kf_index++;
    1243           2 :             forced_keyframe = 1;
    1244       94385 :         } else if (ost->forced_keyframes_pexpr) {
    1245             :             double res;
    1246           0 :             ost->forced_keyframes_expr_const_values[FKF_T] = pts_time;
    1247           0 :             res = av_expr_eval(ost->forced_keyframes_pexpr,
    1248           0 :                                ost->forced_keyframes_expr_const_values, NULL);
    1249             :             ff_dlog(NULL, "force_key_frame: n:%f n_forced:%f prev_forced_n:%f t:%f prev_forced_t:%f -> res:%f\n",
    1250             :                     ost->forced_keyframes_expr_const_values[FKF_N],
    1251             :                     ost->forced_keyframes_expr_const_values[FKF_N_FORCED],
    1252             :                     ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_N],
    1253             :                     ost->forced_keyframes_expr_const_values[FKF_T],
    1254             :                     ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_T],
    1255             :                     res);
    1256           0 :             if (res) {
    1257           0 :                 forced_keyframe = 1;
    1258           0 :                 ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_N] =
    1259           0 :                     ost->forced_keyframes_expr_const_values[FKF_N];
    1260           0 :                 ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_T] =
    1261           0 :                     ost->forced_keyframes_expr_const_values[FKF_T];
    1262           0 :                 ost->forced_keyframes_expr_const_values[FKF_N_FORCED] += 1;
    1263             :             }
    1264             : 
    1265           0 :             ost->forced_keyframes_expr_const_values[FKF_N] += 1;
    1266       94385 :         } else if (   ost->forced_keyframes
    1267          48 :                    && !strncmp(ost->forced_keyframes, "source", 6)
    1268           0 :                    && in_picture->key_frame==1) {
    1269           0 :             forced_keyframe = 1;
    1270             :         }
    1271             : 
    1272       94387 :         if (forced_keyframe) {
    1273           2 :             in_picture->pict_type = AV_PICTURE_TYPE_I;
    1274           2 :             av_log(NULL, AV_LOG_DEBUG, "Forced keyframe at time %f\n", pts_time);
    1275             :         }
    1276             : 
    1277       94387 :         update_benchmark(NULL);
    1278       94387 :         if (debug_ts) {
    1279           0 :             av_log(NULL, AV_LOG_INFO, "encoder <- type:video "
    1280             :                    "frame_pts:%s frame_pts_time:%s time_base:%d/%d\n",
    1281           0 :                    av_ts2str(in_picture->pts), av_ts2timestr(in_picture->pts, &enc->time_base),
    1282             :                    enc->time_base.num, enc->time_base.den);
    1283             :         }
    1284             : 
    1285       94387 :         ost->frames_encoded++;
    1286             : 
    1287       94387 :         ret = avcodec_send_frame(enc, in_picture);
    1288       94387 :         if (ret < 0)
    1289           0 :             goto error;
    1290             : 
    1291             :         while (1) {
    1292      282775 :             ret = avcodec_receive_packet(enc, &pkt);
    1293      188581 :             update_benchmark("encode_video %d.%d", ost->file_index, ost->index);
    1294      188581 :             if (ret == AVERROR(EAGAIN))
    1295       94387 :                 break;
    1296       94194 :             if (ret < 0)
    1297           0 :                 goto error;
    1298             : 
    1299       94194 :             if (debug_ts) {
    1300           0 :                 av_log(NULL, AV_LOG_INFO, "encoder -> type:video "
    1301             :                        "pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s\n",
    1302           0 :                        av_ts2str(pkt.pts), av_ts2timestr(pkt.pts, &enc->time_base),
    1303           0 :                        av_ts2str(pkt.dts), av_ts2timestr(pkt.dts, &enc->time_base));
    1304             :             }
    1305             : 
    1306       94194 :             if (pkt.pts == AV_NOPTS_VALUE && !(enc->codec->capabilities & AV_CODEC_CAP_DELAY))
    1307           0 :                 pkt.pts = ost->sync_opts;
    1308             : 
    1309       94194 :             av_packet_rescale_ts(&pkt, enc->time_base, ost->mux_timebase);
    1310             : 
    1311       94194 :             if (debug_ts) {
    1312           0 :                 av_log(NULL, AV_LOG_INFO, "encoder -> type:video "
    1313             :                     "pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s\n",
    1314           0 :                     av_ts2str(pkt.pts), av_ts2timestr(pkt.pts, &ost->mux_timebase),
    1315           0 :                     av_ts2str(pkt.dts), av_ts2timestr(pkt.dts, &ost->mux_timebase));
    1316             :             }
    1317             : 
    1318       94194 :             frame_size = pkt.size;
    1319       94194 :             output_packet(of, &pkt, ost);
    1320             : 
    1321             :             /* if two pass, output log */
    1322       94194 :             if (ost->logfile && enc->stats_out) {
    1323           0 :                 fprintf(ost->logfile, "%s", enc->stats_out);
    1324             :             }
    1325             :         }
    1326             :     }
    1327       94387 :     ost->sync_opts++;
    1328             :     /*
    1329             :      * For video, number of frames in == number of packets out.
    1330             :      * But there may be reordering, so we can't throw away frames on encoder
    1331             :      * flush, we need to limit them here, before they go into encoder.
    1332             :      */
    1333       94387 :     ost->frame_number++;
    1334             : 
    1335       94387 :     if (vstats_filename && frame_size)
    1336           0 :         do_video_stats(ost, frame_size);
    1337             :   }
    1338             : 
    1339       96553 :     if (!ost->last_frame)
    1340        4111 :         ost->last_frame = av_frame_alloc();
    1341       96553 :     av_frame_unref(ost->last_frame);
    1342       96553 :     if (next_picture && ost->last_frame)
    1343       94323 :         av_frame_ref(ost->last_frame, next_picture);
    1344             :     else
    1345        2230 :         av_frame_free(&ost->last_frame);
    1346             : 
    1347       96553 :     return;
    1348             : error:
    1349           0 :     av_log(NULL, AV_LOG_FATAL, "Video encoding failed\n");
    1350           0 :     exit_program(1);
    1351             : }
    1352             : 
    1353           0 : static double psnr(double d)
    1354             : {
    1355           0 :     return -10.0 * log10(d);
    1356             : }
    1357             : 
    1358           0 : static void do_video_stats(OutputStream *ost, int frame_size)
    1359             : {
    1360             :     AVCodecContext *enc;
    1361             :     int frame_number;
    1362             :     double ti1, bitrate, avg_bitrate;
    1363             : 
    1364             :     /* this is executed just the first time do_video_stats is called */
    1365           0 :     if (!vstats_file) {
    1366           0 :         vstats_file = fopen(vstats_filename, "w");
    1367           0 :         if (!vstats_file) {
    1368           0 :             perror("fopen");
    1369           0 :             exit_program(1);
    1370             :         }
    1371             :     }
    1372             : 
    1373           0 :     enc = ost->enc_ctx;
    1374           0 :     if (enc->codec_type == AVMEDIA_TYPE_VIDEO) {
    1375           0 :         frame_number = ost->st->nb_frames;
    1376           0 :         if (vstats_version <= 1) {
    1377           0 :             fprintf(vstats_file, "frame= %5d q= %2.1f ", frame_number,
    1378           0 :                     ost->quality / (float)FF_QP2LAMBDA);
    1379             :         } else  {
    1380           0 :             fprintf(vstats_file, "out= %2d st= %2d frame= %5d q= %2.1f ", ost->file_index, ost->index, frame_number,
    1381           0 :                     ost->quality / (float)FF_QP2LAMBDA);
    1382             :         }
    1383             : 
    1384           0 :         if (ost->error[0]>=0 && (enc->flags & AV_CODEC_FLAG_PSNR))
    1385           0 :             fprintf(vstats_file, "PSNR= %6.2f ", psnr(ost->error[0] / (enc->width * enc->height * 255.0 * 255.0)));
    1386             : 
    1387           0 :         fprintf(vstats_file,"f_size= %6d ", frame_size);
    1388             :         /* compute pts value */
    1389           0 :         ti1 = av_stream_get_end_pts(ost->st) * av_q2d(ost->st->time_base);
    1390           0 :         if (ti1 < 0.01)
    1391           0 :             ti1 = 0.01;
    1392             : 
    1393           0 :         bitrate     = (frame_size * 8) / av_q2d(enc->time_base) / 1000.0;
    1394           0 :         avg_bitrate = (double)(ost->data_size * 8) / ti1 / 1000.0;
    1395           0 :         fprintf(vstats_file, "s_size= %8.0fkB time= %0.3f br= %7.1fkbits/s avg_br= %7.1fkbits/s ",
    1396           0 :                (double)ost->data_size / 1024, ti1, bitrate, avg_bitrate);
    1397           0 :         fprintf(vstats_file, "type= %c\n", av_get_picture_type_char(ost->pict_type));
    1398             :     }
    1399           0 : }
    1400             : 
    1401             : static int init_output_stream(OutputStream *ost, char *error, int error_len);
    1402             : 
    1403         191 : static void finish_output_stream(OutputStream *ost)
    1404             : {
    1405         191 :     OutputFile *of = output_files[ost->file_index];
    1406             :     int i;
    1407             : 
    1408         191 :     ost->finished = ENCODER_FINISHED | MUXER_FINISHED;
    1409             : 
    1410         191 :     if (of->shortest) {
    1411           0 :         for (i = 0; i < of->ctx->nb_streams; i++)
    1412           0 :             output_streams[of->ost_index + i]->finished = ENCODER_FINISHED | MUXER_FINISHED;
    1413             :     }
    1414         191 : }
    1415             : 
    1416             : /**
    1417             :  * Get and encode new output from any of the filtergraphs, without causing
    1418             :  * activity.
    1419             :  *
    1420             :  * @return  0 for success, <0 for severe errors
    1421             :  */
    1422      393387 : static int reap_filters(int flush)
    1423             : {
    1424      393387 :     AVFrame *filtered_frame = NULL;
    1425             :     int i;
    1426             : 
    1427             :     /* Reap all buffers present in the buffer sinks */
    1428      800312 :     for (i = 0; i < nb_output_streams; i++) {
    1429      406925 :         OutputStream *ost = output_streams[i];
    1430      406925 :         OutputFile    *of = output_files[ost->file_index];
    1431             :         AVFilterContext *filter;
    1432      406925 :         AVCodecContext *enc = ost->enc_ctx;
    1433      406925 :         int ret = 0;
    1434             : 
    1435      406925 :         if (!ost->filter || !ost->filter->graph->graph)
    1436       35068 :             continue;
    1437      371857 :         filter = ost->filter->filter;
    1438             : 
    1439      371857 :         if (!ost->initialized) {
    1440        5084 :             char error[1024] = "";
    1441        5084 :             ret = init_output_stream(ost, error, sizeof(error));
    1442        5084 :             if (ret < 0) {
    1443           0 :                 av_log(NULL, AV_LOG_ERROR, "Error initializing output stream %d:%d -- %s\n",
    1444             :                        ost->file_index, ost->index, error);
    1445           0 :                 exit_program(1);
    1446             :             }
    1447             :         }
    1448             : 
    1449      371857 :         if (!ost->filtered_frame && !(ost->filtered_frame = av_frame_alloc())) {
    1450           0 :             return AVERROR(ENOMEM);
    1451             :         }
    1452      371857 :         filtered_frame = ost->filtered_frame;
    1453             : 
    1454      384008 :         while (1) {
    1455      755865 :             double float_pts = AV_NOPTS_VALUE; // this is identical to filtered_frame.pts but with higher precision
    1456      755865 :             ret = av_buffersink_get_frame_flags(filter, filtered_frame,
    1457             :                                                AV_BUFFERSINK_FLAG_NO_REQUEST);
    1458      755865 :             if (ret < 0) {
    1459      371857 :                 if (ret != AVERROR(EAGAIN) && ret != AVERROR_EOF) {
    1460           0 :                     av_log(NULL, AV_LOG_WARNING,
    1461           0 :                            "Error in av_buffersink_get_frame_flags(): %s\n", av_err2str(ret));
    1462      371857 :                 } else if (flush && ret == AVERROR_EOF) {
    1463        3321 :                     if (av_buffersink_get_type(filter) == AVMEDIA_TYPE_VIDEO)
    1464        2230 :                         do_video_out(of, ost, NULL, AV_NOPTS_VALUE);
    1465             :                 }
    1466      371857 :                 break;
    1467             :             }
    1468      384008 :             if (ost->finished) {
    1469           0 :                 av_frame_unref(filtered_frame);
    1470           0 :                 continue;
    1471             :             }
    1472      384008 :             if (filtered_frame->pts != AV_NOPTS_VALUE) {
    1473      383667 :                 int64_t start_time = (of->start_time == AV_NOPTS_VALUE) ? 0 : of->start_time;
    1474      383667 :                 AVRational filter_tb = av_buffersink_get_time_base(filter);
    1475      383667 :                 AVRational tb = enc->time_base;
    1476      383667 :                 int extra_bits = av_clip(29 - av_log2(tb.den), 0, 16);
    1477             : 
    1478      383667 :                 tb.den <<= extra_bits;
    1479      383667 :                 float_pts =
    1480      767334 :                     av_rescale_q(filtered_frame->pts, filter_tb, tb) -
    1481      383667 :                     av_rescale_q(start_time, AV_TIME_BASE_Q, tb);
    1482      383667 :                 float_pts /= 1 << extra_bits;
    1483             :                 // avoid exact midoints to reduce the chance of rounding differences, this can be removed in case the fps code is changed to work with integers
    1484      383667 :                 float_pts += FFSIGN(float_pts) * 1.0 / (1<<17);
    1485             : 
    1486      383667 :                 filtered_frame->pts =
    1487      767334 :                     av_rescale_q(filtered_frame->pts, filter_tb, enc->time_base) -
    1488      383667 :                     av_rescale_q(start_time, AV_TIME_BASE_Q, enc->time_base);
    1489             :             }
    1490             :             //if (ost->source_index >= 0)
    1491             :             //    *filtered_frame= *input_streams[ost->source_index]->decoded_frame; //for me_threshold
    1492             : 
    1493      384008 :             switch (av_buffersink_get_type(filter)) {
    1494             :             case AVMEDIA_TYPE_VIDEO:
    1495       94324 :                 if (!ost->frame_aspect_ratio.num)
    1496       94324 :                     enc->sample_aspect_ratio = filtered_frame->sample_aspect_ratio;
    1497             : 
    1498       94324 :                 if (debug_ts) {
    1499           0 :                     av_log(NULL, AV_LOG_INFO, "filter -> pts:%s pts_time:%s exact:%f time_base:%d/%d\n",
    1500           0 :                             av_ts2str(filtered_frame->pts), av_ts2timestr(filtered_frame->pts, &enc->time_base),
    1501             :                             float_pts,
    1502             :                             enc->time_base.num, enc->time_base.den);
    1503             :                 }
    1504             : 
    1505       94324 :                 do_video_out(of, ost, filtered_frame, float_pts);
    1506       94324 :                 break;
    1507             :             case AVMEDIA_TYPE_AUDIO:
    1508      579368 :                 if (!(enc->codec->capabilities & AV_CODEC_CAP_PARAM_CHANGE) &&
    1509      289684 :                     enc->channels != filtered_frame->channels) {
    1510           0 :                     av_log(NULL, AV_LOG_ERROR,
    1511             :                            "Audio filter graph output is not normalized and encoder does not support parameter changes\n");
    1512           0 :                     break;
    1513             :                 }
    1514      289684 :                 do_audio_out(of, ost, filtered_frame);
    1515      289684 :                 break;
    1516             :             default:
    1517             :                 // TODO support subtitle filters
    1518           0 :                 av_assert0(0);
    1519             :             }
    1520             : 
    1521      384008 :             av_frame_unref(filtered_frame);
    1522             :         }
    1523             :     }
    1524             : 
    1525      393387 :     return 0;
    1526             : }
    1527             : 
    1528        5155 : static void print_final_stats(int64_t total_size)
    1529             : {
    1530        5155 :     uint64_t video_size = 0, audio_size = 0, extra_size = 0, other_size = 0;
    1531        5155 :     uint64_t subtitle_size = 0;
    1532        5155 :     uint64_t data_size = 0;
    1533        5155 :     float percent = -1.0;
    1534             :     int i, j;
    1535        5155 :     int pass1_used = 1;
    1536             : 
    1537       10443 :     for (i = 0; i < nb_output_streams; i++) {
    1538        5288 :         OutputStream *ost = output_streams[i];
    1539        5288 :         switch (ost->enc_ctx->codec_type) {
    1540        4109 :             case AVMEDIA_TYPE_VIDEO: video_size += ost->data_size; break;
    1541        1135 :             case AVMEDIA_TYPE_AUDIO: audio_size += ost->data_size; break;
    1542          34 :             case AVMEDIA_TYPE_SUBTITLE: subtitle_size += ost->data_size; break;
    1543          10 :             default:                 other_size += ost->data_size; break;
    1544             :         }
    1545        5288 :         extra_size += ost->enc_ctx->extradata_size;
    1546        5288 :         data_size  += ost->data_size;
    1547        5288 :         if (   (ost->enc_ctx->flags & (AV_CODEC_FLAG_PASS1 | AV_CODEC_FLAG_PASS2))
    1548             :             != AV_CODEC_FLAG_PASS1)
    1549        5288 :             pass1_used = 0;
    1550             :     }
    1551             : 
    1552        5155 :     if (data_size && total_size>0 && total_size >= data_size)
    1553        3520 :         percent = 100.0 * (total_size - data_size) / data_size;
    1554             : 
    1555        5155 :     av_log(NULL, AV_LOG_INFO, "video:%1.0fkB audio:%1.0fkB subtitle:%1.0fkB other streams:%1.0fkB global headers:%1.0fkB muxing overhead: ",
    1556             :            video_size / 1024.0,
    1557             :            audio_size / 1024.0,
    1558             :            subtitle_size / 1024.0,
    1559             :            other_size / 1024.0,
    1560             :            extra_size / 1024.0);
    1561        5155 :     if (percent >= 0.0)
    1562        3520 :         av_log(NULL, AV_LOG_INFO, "%f%%", percent);
    1563             :     else
    1564        1635 :         av_log(NULL, AV_LOG_INFO, "unknown");
    1565        5155 :     av_log(NULL, AV_LOG_INFO, "\n");
    1566             : 
    1567             :     /* print verbose per-stream stats */
    1568       10369 :     for (i = 0; i < nb_input_files; i++) {
    1569        5214 :         InputFile *f = input_files[i];
    1570        5214 :         uint64_t total_packets = 0, total_size = 0;
    1571             : 
    1572        5214 :         av_log(NULL, AV_LOG_VERBOSE, "Input file #%d (%s):\n",
    1573        5214 :                i, f->ctx->filename);
    1574             : 
    1575       10727 :         for (j = 0; j < f->nb_streams; j++) {
    1576        5513 :             InputStream *ist = input_streams[f->ist_index + j];
    1577        5513 :             enum AVMediaType type = ist->dec_ctx->codec_type;
    1578             : 
    1579        5513 :             total_size    += ist->data_size;
    1580        5513 :             total_packets += ist->nb_packets;
    1581             : 
    1582        5513 :             av_log(NULL, AV_LOG_VERBOSE, "  Input stream #%d:%d (%s): ",
    1583             :                    i, j, media_type_string(type));
    1584        5513 :             av_log(NULL, AV_LOG_VERBOSE, "%"PRIu64" packets read (%"PRIu64" bytes); ",
    1585             :                    ist->nb_packets, ist->data_size);
    1586             : 
    1587        5513 :             if (ist->decoding_needed) {
    1588        5120 :                 av_log(NULL, AV_LOG_VERBOSE, "%"PRIu64" frames decoded",
    1589             :                        ist->frames_decoded);
    1590        5120 :                 if (type == AVMEDIA_TYPE_AUDIO)
    1591        1056 :                     av_log(NULL, AV_LOG_VERBOSE, " (%"PRIu64" samples)", ist->samples_decoded);
    1592        5120 :                 av_log(NULL, AV_LOG_VERBOSE, "; ");
    1593             :             }
    1594             : 
    1595        5513 :             av_log(NULL, AV_LOG_VERBOSE, "\n");
    1596             :         }
    1597             : 
    1598        5214 :         av_log(NULL, AV_LOG_VERBOSE, "  Total: %"PRIu64" packets (%"PRIu64" bytes) demuxed\n",
    1599             :                total_packets, total_size);
    1600             :     }
    1601             : 
    1602       10311 :     for (i = 0; i < nb_output_files; i++) {
    1603        5156 :         OutputFile *of = output_files[i];
    1604        5156 :         uint64_t total_packets = 0, total_size = 0;
    1605             : 
    1606        5156 :         av_log(NULL, AV_LOG_VERBOSE, "Output file #%d (%s):\n",
    1607        5156 :                i, of->ctx->filename);
    1608             : 
    1609       10444 :         for (j = 0; j < of->ctx->nb_streams; j++) {
    1610        5288 :             OutputStream *ost = output_streams[of->ost_index + j];
    1611        5288 :             enum AVMediaType type = ost->enc_ctx->codec_type;
    1612             : 
    1613        5288 :             total_size    += ost->data_size;
    1614        5288 :             total_packets += ost->packets_written;
    1615             : 
    1616        5288 :             av_log(NULL, AV_LOG_VERBOSE, "  Output stream #%d:%d (%s): ",
    1617             :                    i, j, media_type_string(type));
    1618        5288 :             if (ost->encoding_needed) {
    1619        5112 :                 av_log(NULL, AV_LOG_VERBOSE, "%"PRIu64" frames encoded",
    1620             :                        ost->frames_encoded);
    1621        5112 :                 if (type == AVMEDIA_TYPE_AUDIO)
    1622        1052 :                     av_log(NULL, AV_LOG_VERBOSE, " (%"PRIu64" samples)", ost->samples_encoded);
    1623        5112 :                 av_log(NULL, AV_LOG_VERBOSE, "; ");
    1624             :             }
    1625             : 
    1626        5288 :             av_log(NULL, AV_LOG_VERBOSE, "%"PRIu64" packets muxed (%"PRIu64" bytes); ",
    1627             :                    ost->packets_written, ost->data_size);
    1628             : 
    1629        5288 :             av_log(NULL, AV_LOG_VERBOSE, "\n");
    1630             :         }
    1631             : 
    1632        5156 :         av_log(NULL, AV_LOG_VERBOSE, "  Total: %"PRIu64" packets (%"PRIu64" bytes) muxed\n",
    1633             :                total_packets, total_size);
    1634             :     }
    1635        5155 :     if(video_size + data_size + audio_size + subtitle_size + extra_size == 0){
    1636           5 :         av_log(NULL, AV_LOG_WARNING, "Output file is empty, nothing was encoded ");
    1637           5 :         if (pass1_used) {
    1638           1 :             av_log(NULL, AV_LOG_WARNING, "\n");
    1639             :         } else {
    1640           4 :             av_log(NULL, AV_LOG_WARNING, "(check -ss / -t / -frames parameters if used)\n");
    1641             :         }
    1642             :     }
    1643        5155 : }
    1644             : 
    1645     2662978 : static void print_report(int is_last_report, int64_t timer_start, int64_t cur_time)
    1646             : {
    1647             :     char buf[1024];
    1648             :     AVBPrint buf_script;
    1649             :     OutputStream *ost;
    1650             :     AVFormatContext *oc;
    1651             :     int64_t total_size;
    1652             :     AVCodecContext *enc;
    1653             :     int frame_number, vid, i;
    1654             :     double bitrate;
    1655             :     double speed;
    1656     2662978 :     int64_t pts = INT64_MIN + 1;
    1657             :     static int64_t last_time = -1;
    1658             :     static int qp_histogram[52];
    1659             :     int hours, mins, secs, us;
    1660             :     int ret;
    1661             :     float t;
    1662             : 
    1663     2662978 :     if (!print_stats && !is_last_report && !progress_avio)
    1664     5312373 :         return;
    1665             : 
    1666        8428 :     if (!is_last_report) {
    1667        3273 :         if (last_time == -1) {
    1668          16 :             last_time = cur_time;
    1669          16 :             return;
    1670             :         }
    1671        3257 :         if ((cur_time - last_time) < 500000)
    1672        3257 :             return;
    1673           0 :         last_time = cur_time;
    1674             :     }
    1675             : 
    1676        5155 :     t = (cur_time-timer_start) / 1000000.0;
    1677             : 
    1678             : 
    1679        5155 :     oc = output_files[0]->ctx;
    1680             : 
    1681        5155 :     total_size = avio_size(oc->pb);
    1682        5155 :     if (total_size <= 0) // FIXME improve avio_size() so it works with non seekable output too
    1683          41 :         total_size = avio_tell(oc->pb);
    1684             : 
    1685        5155 :     buf[0] = '\0';
    1686        5155 :     vid = 0;
    1687        5155 :     av_bprint_init(&buf_script, 0, 1);
    1688       10443 :     for (i = 0; i < nb_output_streams; i++) {
    1689        5288 :         float q = -1;
    1690        5288 :         ost = output_streams[i];
    1691        5288 :         enc = ost->enc_ctx;
    1692        5288 :         if (!ost->stream_copy)
    1693        5113 :             q = ost->quality / (float) FF_QP2LAMBDA;
    1694             : 
    1695        5288 :         if (vid && enc->codec_type == AVMEDIA_TYPE_VIDEO) {
    1696           7 :             snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "q=%2.1f ", q);
    1697           7 :             av_bprintf(&buf_script, "stream_%d_%d_q=%.1f\n",
    1698             :                        ost->file_index, ost->index, q);
    1699             :         }
    1700        5288 :         if (!vid && enc->codec_type == AVMEDIA_TYPE_VIDEO) {
    1701             :             float fps;
    1702             : 
    1703        4102 :             frame_number = ost->frame_number;
    1704        4102 :             fps = t > 1 ? frame_number / t : 0;
    1705        4102 :             snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "frame=%5d fps=%3.*f q=%3.1f ",
    1706             :                      frame_number, fps < 9.95, fps, q);
    1707        4102 :             av_bprintf(&buf_script, "frame=%d\n", frame_number);
    1708        4102 :             av_bprintf(&buf_script, "fps=%.1f\n", fps);
    1709        4102 :             av_bprintf(&buf_script, "stream_%d_%d_q=%.1f\n",
    1710             :                        ost->file_index, ost->index, q);
    1711        4102 :             if (is_last_report)
    1712        4102 :                 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "L");
    1713        4102 :             if (qp_hist) {
    1714             :                 int j;
    1715           0 :                 int qp = lrintf(q);
    1716           0 :                 if (qp >= 0 && qp < FF_ARRAY_ELEMS(qp_histogram))
    1717           0 :                     qp_histogram[qp]++;
    1718           0 :                 for (j = 0; j < 32; j++)
    1719           0 :                     snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "%X", av_log2(qp_histogram[j] + 1));
    1720             :             }
    1721             : 
    1722        4102 :             if ((enc->flags & AV_CODEC_FLAG_PSNR) && (ost->pict_type != AV_PICTURE_TYPE_NONE || is_last_report)) {
    1723             :                 int j;
    1724           0 :                 double error, error_sum = 0;
    1725           0 :                 double scale, scale_sum = 0;
    1726             :                 double p;
    1727           0 :                 char type[3] = { 'Y','U','V' };
    1728           0 :                 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "PSNR=");
    1729           0 :                 for (j = 0; j < 3; j++) {
    1730           0 :                     if (is_last_report) {
    1731           0 :                         error = enc->error[j];
    1732           0 :                         scale = enc->width * enc->height * 255.0 * 255.0 * frame_number;
    1733             :                     } else {
    1734           0 :                         error = ost->error[j];
    1735           0 :                         scale = enc->width * enc->height * 255.0 * 255.0;
    1736             :                     }
    1737           0 :                     if (j)
    1738           0 :                         scale /= 4;
    1739           0 :                     error_sum += error;
    1740           0 :                     scale_sum += scale;
    1741           0 :                     p = psnr(error / scale);
    1742           0 :                     snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "%c:%2.2f ", type[j], p);
    1743           0 :                     av_bprintf(&buf_script, "stream_%d_%d_psnr_%c=%2.2f\n",
    1744           0 :                                ost->file_index, ost->index, type[j] | 32, p);
    1745             :                 }
    1746           0 :                 p = psnr(error_sum / scale_sum);
    1747           0 :                 snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "*:%2.2f ", psnr(error_sum / scale_sum));
    1748           0 :                 av_bprintf(&buf_script, "stream_%d_%d_psnr_all=%2.2f\n",
    1749             :                            ost->file_index, ost->index, p);
    1750             :             }
    1751        4102 :             vid = 1;
    1752             :         }
    1753             :         /* compute min output value */
    1754        5288 :         if (av_stream_get_end_pts(ost->st) != AV_NOPTS_VALUE)
    1755        5288 :             pts = FFMAX(pts, av_rescale_q(av_stream_get_end_pts(ost->st),
    1756             :                                           ost->st->time_base, AV_TIME_BASE_Q));
    1757        5288 :         if (is_last_report)
    1758        5288 :             nb_frames_drop += ost->last_dropped;
    1759             :     }
    1760             : 
    1761        5155 :     secs = FFABS(pts) / AV_TIME_BASE;
    1762        5155 :     us = FFABS(pts) % AV_TIME_BASE;
    1763        5155 :     mins = secs / 60;
    1764        5155 :     secs %= 60;
    1765        5155 :     hours = mins / 60;
    1766        5155 :     mins %= 60;
    1767             : 
    1768        5155 :     bitrate = pts && total_size >= 0 ? total_size * 8 / (pts / 1000.0) : -1;
    1769        5155 :     speed = t != 0.0 ? (double)pts / AV_TIME_BASE / t : -1;
    1770             : 
    1771        5155 :     if (total_size < 0) snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
    1772             :                                  "size=N/A time=");
    1773        5114 :     else                snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
    1774             :                                  "size=%8.0fkB time=", total_size / 1024.0);
    1775        5155 :     if (pts < 0)
    1776           1 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), "-");
    1777        5155 :     snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),
    1778             :              "%02d:%02d:%02d.%02d ", hours, mins, secs,
    1779        5155 :              (100 * us) / AV_TIME_BASE);
    1780             : 
    1781        5155 :     if (bitrate < 0) {
    1782          51 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),"bitrate=N/A");
    1783          51 :         av_bprintf(&buf_script, "bitrate=N/A\n");
    1784             :     }else{
    1785        5104 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf),"bitrate=%6.1fkbits/s", bitrate);
    1786        5104 :         av_bprintf(&buf_script, "bitrate=%6.1fkbits/s\n", bitrate);
    1787             :     }
    1788             : 
    1789        5155 :     if (total_size < 0) av_bprintf(&buf_script, "total_size=N/A\n");
    1790        5114 :     else                av_bprintf(&buf_script, "total_size=%"PRId64"\n", total_size);
    1791        5155 :     av_bprintf(&buf_script, "out_time_ms=%"PRId64"\n", pts);
    1792        5155 :     av_bprintf(&buf_script, "out_time=%02d:%02d:%02d.%06d\n",
    1793             :                hours, mins, secs, us);
    1794             : 
    1795        5155 :     if (nb_frames_dup || nb_frames_drop)
    1796          27 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf), " dup=%d drop=%d",
    1797             :                 nb_frames_dup, nb_frames_drop);
    1798        5155 :     av_bprintf(&buf_script, "dup_frames=%d\n", nb_frames_dup);
    1799        5155 :     av_bprintf(&buf_script, "drop_frames=%d\n", nb_frames_drop);
    1800             : 
    1801        5155 :     if (speed < 0) {
    1802           1 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf)," speed=N/A");
    1803           1 :         av_bprintf(&buf_script, "speed=N/A\n");
    1804             :     } else {
    1805        5154 :         snprintf(buf + strlen(buf), sizeof(buf) - strlen(buf)," speed=%4.3gx", speed);
    1806        5154 :         av_bprintf(&buf_script, "speed=%4.3gx\n", speed);
    1807             :     }
    1808             : 
    1809        5155 :     if (print_stats || is_last_report) {
    1810        5155 :         const char end = is_last_report ? '\n' : '\r';
    1811        5155 :         if (print_stats==1 && AV_LOG_INFO > av_log_get_level()) {
    1812           0 :             fprintf(stderr, "%s    %c", buf, end);
    1813             :         } else
    1814        5155 :             av_log(NULL, AV_LOG_INFO, "%s    %c", buf, end);
    1815             : 
    1816        5155 :     fflush(stderr);
    1817             :     }
    1818             : 
    1819        5155 :     if (progress_avio) {
    1820           0 :         av_bprintf(&buf_script, "progress=%s\n",
    1821             :                    is_last_report ? "end" : "continue");
    1822           0 :         avio_write(progress_avio, buf_script.str,
    1823           0 :                    FFMIN(buf_script.len, buf_script.size - 1));
    1824           0 :         avio_flush(progress_avio);
    1825           0 :         av_bprint_finalize(&buf_script, NULL);
    1826           0 :         if (is_last_report) {
    1827           0 :             if ((ret = avio_closep(&progress_avio)) < 0)
    1828           0 :                 av_log(NULL, AV_LOG_ERROR,
    1829           0 :                        "Error closing progress log, loss of information possible: %s\n", av_err2str(ret));
    1830             :         }
    1831             :     }
    1832             : 
    1833        5155 :     if (is_last_report)
    1834        5155 :         print_final_stats(total_size);
    1835             : }
    1836             : 
    1837        5155 : static void flush_encoders(void)
    1838             : {
    1839             :     int i, ret;
    1840             : 
    1841       10443 :     for (i = 0; i < nb_output_streams; i++) {
    1842        5288 :         OutputStream   *ost = output_streams[i];
    1843        5288 :         AVCodecContext *enc = ost->enc_ctx;
    1844        5288 :         OutputFile      *of = output_files[ost->file_index];
    1845             : 
    1846        5288 :         if (!ost->encoding_needed)
    1847         176 :             continue;
    1848             : 
    1849             :         // Try to enable encoding with no input frames.
    1850             :         // Maybe we should just let encoding fail instead.
    1851        5112 :         if (!ost->initialized) {
    1852           0 :             FilterGraph *fg = ost->filter->graph;
    1853           0 :             char error[1024] = "";
    1854             : 
    1855           0 :             av_log(NULL, AV_LOG_WARNING,
    1856             :                    "Finishing stream %d:%d without any data written to it.\n",
    1857           0 :                    ost->file_index, ost->st->index);
    1858             : 
    1859           0 :             if (ost->filter && !fg->graph) {
    1860             :                 int x;
    1861           0 :                 for (x = 0; x < fg->nb_inputs; x++) {
    1862           0 :                     InputFilter *ifilter = fg->inputs[x];
    1863           0 :                     if (ifilter->format < 0) {
    1864           0 :                         AVCodecParameters *par = ifilter->ist->st->codecpar;
    1865             :                         // We never got any input. Set a fake format, which will
    1866             :                         // come from libavformat.
    1867           0 :                         ifilter->format                 = par->format;
    1868           0 :                         ifilter->sample_rate            = par->sample_rate;
    1869           0 :                         ifilter->channels               = par->channels;
    1870           0 :                         ifilter->channel_layout         = par->channel_layout;
    1871           0 :                         ifilter->width                  = par->width;
    1872           0 :                         ifilter->height                 = par->height;
    1873           0 :                         ifilter->sample_aspect_ratio    = par->sample_aspect_ratio;
    1874             :                     }
    1875             :                 }
    1876             : 
    1877           0 :                 if (!ifilter_has_all_input_formats(fg))
    1878           0 :                     continue;
    1879             : 
    1880           0 :                 ret = configure_filtergraph(fg);
    1881           0 :                 if (ret < 0) {
    1882           0 :                     av_log(NULL, AV_LOG_ERROR, "Error configuring filter graph\n");
    1883           0 :                     exit_program(1);
    1884             :                 }
    1885             : 
    1886           0 :                 finish_output_stream(ost);
    1887             :             }
    1888             : 
    1889           0 :             ret = init_output_stream(ost, error, sizeof(error));
    1890           0 :             if (ret < 0) {
    1891           0 :                 av_log(NULL, AV_LOG_ERROR, "Error initializing output stream %d:%d -- %s\n",
    1892             :                        ost->file_index, ost->index, error);
    1893           0 :                 exit_program(1);
    1894             :             }
    1895             :         }
    1896             : 
    1897        5112 :         if (enc->codec_type == AVMEDIA_TYPE_AUDIO && enc->frame_size <= 1)
    1898         966 :             continue;
    1899             : #if FF_API_LAVF_FMT_RAWPICTURE
    1900        4146 :         if (enc->codec_type == AVMEDIA_TYPE_VIDEO && (of->ctx->oformat->flags & AVFMT_RAWPICTURE) && enc->codec->id == AV_CODEC_ID_RAWVIDEO)
    1901           0 :             continue;
    1902             : #endif
    1903             : 
    1904        4146 :         if (enc->codec_type != AVMEDIA_TYPE_VIDEO && enc->codec_type != AVMEDIA_TYPE_AUDIO)
    1905          28 :             continue;
    1906             : 
    1907         232 :         for (;;) {
    1908        4350 :             const char *desc = NULL;
    1909             :             AVPacket pkt;
    1910             :             int pkt_size;
    1911             : 
    1912        4350 :             switch (enc->codec_type) {
    1913             :             case AVMEDIA_TYPE_AUDIO:
    1914         125 :                 desc   = "audio";
    1915         125 :                 break;
    1916             :             case AVMEDIA_TYPE_VIDEO:
    1917        4225 :                 desc   = "video";
    1918        4225 :                 break;
    1919             :             default:
    1920           0 :                 av_assert0(0);
    1921             :             }
    1922             : 
    1923        4350 :                 av_init_packet(&pkt);
    1924        4350 :                 pkt.data = NULL;
    1925        4350 :                 pkt.size = 0;
    1926             : 
    1927        4350 :                 update_benchmark(NULL);
    1928             : 
    1929        4350 :                 while ((ret = avcodec_receive_packet(enc, &pkt)) == AVERROR(EAGAIN)) {
    1930        4118 :                     ret = avcodec_send_frame(enc, NULL);
    1931        4118 :                     if (ret < 0) {
    1932           0 :                         av_log(NULL, AV_LOG_FATAL, "%s encoding failed: %s\n",
    1933             :                                desc,
    1934           0 :                                av_err2str(ret));
    1935           0 :                         exit_program(1);
    1936             :                     }
    1937             :                 }
    1938             : 
    1939        4350 :                 update_benchmark("flush_%s %d.%d", desc, ost->file_index, ost->index);
    1940        4350 :                 if (ret < 0 && ret != AVERROR_EOF) {
    1941           0 :                     av_log(NULL, AV_LOG_FATAL, "%s encoding failed: %s\n",
    1942             :                            desc,
    1943           0 :                            av_err2str(ret));
    1944           0 :                     exit_program(1);
    1945             :                 }
    1946        4350 :                 if (ost->logfile && enc->stats_out) {
    1947           0 :                     fprintf(ost->logfile, "%s", enc->stats_out);
    1948             :                 }
    1949        4350 :                 if (ret == AVERROR_EOF) {
    1950        4118 :                     break;
    1951             :                 }
    1952         232 :                 if (ost->finished & MUXER_FINISHED) {
    1953           0 :                     av_packet_unref(&pkt);
    1954           0 :                     continue;
    1955             :                 }
    1956         232 :                 av_packet_rescale_ts(&pkt, enc->time_base, ost->mux_timebase);
    1957         232 :                 pkt_size = pkt.size;
    1958         232 :                 output_packet(of, &pkt, ost);
    1959         232 :                 if (ost->enc_ctx->codec_type == AVMEDIA_TYPE_VIDEO && vstats_filename) {
    1960           0 :                     do_video_stats(ost, pkt_size);
    1961             :                 }
    1962             :         }
    1963             :     }
    1964        5155 : }
    1965             : 
    1966             : /*
    1967             :  * Check whether a packet from ist should be written into ost at this time
    1968             :  */
    1969      389611 : static int check_output_constraints(InputStream *ist, OutputStream *ost)
    1970             : {
    1971      389611 :     OutputFile *of = output_files[ost->file_index];
    1972      389611 :     int ist_index  = input_files[ist->file_index]->ist_index + ist->st->index;
    1973             : 
    1974      389611 :     if (ost->source_index != ist_index)
    1975       15755 :         return 0;
    1976             : 
    1977      373856 :     if (ost->finished)
    1978          24 :         return 0;
    1979             : 
    1980      373832 :     if (of->start_time != AV_NOPTS_VALUE && ist->pts < of->start_time)
    1981           0 :         return 0;
    1982             : 
    1983      373832 :     return 1;
    1984             : }
    1985             : 
    1986       19927 : static void do_streamcopy(InputStream *ist, OutputStream *ost, const AVPacket *pkt)
    1987             : {
    1988       19927 :     OutputFile *of = output_files[ost->file_index];
    1989       19927 :     InputFile   *f = input_files [ist->file_index];
    1990       19927 :     int64_t start_time = (of->start_time == AV_NOPTS_VALUE) ? 0 : of->start_time;
    1991       19927 :     int64_t ost_tb_start_time = av_rescale_q(start_time, AV_TIME_BASE_Q, ost->mux_timebase);
    1992             :     AVPicture pict;
    1993             :     AVPacket opkt;
    1994             : 
    1995       19927 :     av_init_packet(&opkt);
    1996             : 
    1997       19938 :     if ((!ost->frame_number && !(pkt->flags & AV_PKT_FLAG_KEY)) &&
    1998          11 :         !ost->copy_initial_nonkeyframes)
    1999          29 :         return;
    2000             : 
    2001       19916 :     if (!ost->frame_number && !ost->copy_prior_start) {
    2002           0 :         int64_t comp_start = start_time;
    2003           0 :         if (copy_ts && f->start_time != AV_NOPTS_VALUE)
    2004           0 :             comp_start = FFMAX(start_time, f->start_time + f->ts_offset);
    2005           0 :         if (pkt->pts == AV_NOPTS_VALUE ?
    2006           0 :             ist->pts < comp_start :
    2007           0 :             pkt->pts < av_rescale_q(comp_start, AV_TIME_BASE_Q, ist->st->time_base))
    2008           0 :             return;
    2009             :     }
    2010             : 
    2011       20332 :     if (of->recording_time != INT64_MAX &&
    2012         416 :         ist->pts >= of->recording_time + start_time) {
    2013           5 :         close_output_stream(ost);
    2014           5 :         return;
    2015             :     }
    2016             : 
    2017       19911 :     if (f->recording_time != INT64_MAX) {
    2018         148 :         start_time = f->ctx->start_time;
    2019         148 :         if (f->start_time != AV_NOPTS_VALUE && copy_ts)
    2020          74 :             start_time += f->start_time;
    2021         148 :         if (ist->pts >= f->recording_time + start_time) {
    2022           2 :             close_output_stream(ost);
    2023           2 :             return;
    2024             :         }
    2025             :     }
    2026             : 
    2027             :     /* force the input stream PTS */
    2028       19909 :     if (ost->enc_ctx->codec_type == AVMEDIA_TYPE_VIDEO)
    2029        3587 :         ost->sync_opts++;
    2030             : 
    2031       19909 :     if (pkt->pts != AV_NOPTS_VALUE)
    2032       19380 :         opkt.pts = av_rescale_q(pkt->pts, ist->st->time_base, ost->mux_timebase) - ost_tb_start_time;
    2033             :     else
    2034         529 :         opkt.pts = AV_NOPTS_VALUE;
    2035             : 
    2036       19909 :     if (pkt->dts == AV_NOPTS_VALUE)
    2037         285 :         opkt.dts = av_rescale_q(ist->dts, AV_TIME_BASE_Q, ost->mux_timebase);
    2038             :     else
    2039       19624 :         opkt.dts = av_rescale_q(pkt->dts, ist->st->time_base, ost->mux_timebase);
    2040       19909 :     opkt.dts -= ost_tb_start_time;
    2041             : 
    2042       19909 :     if (ost->st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO && pkt->dts != AV_NOPTS_VALUE) {
    2043       15802 :         int duration = av_get_audio_frame_duration(ist->dec_ctx, pkt->size);
    2044       15802 :         if(!duration)
    2045        4776 :             duration = ist->dec_ctx->frame_size;
    2046       47406 :         opkt.dts = opkt.pts = av_rescale_delta(ist->st->time_base, pkt->dts,
    2047       15802 :                                                (AVRational){1, ist->dec_ctx->sample_rate}, duration, &ist->filter_in_rescale_delta_last,
    2048       15802 :                                                ost->mux_timebase) - ost_tb_start_time;
    2049             :     }
    2050             : 
    2051       19909 :     opkt.duration = av_rescale_q(pkt->duration, ist->st->time_base, ost->mux_timebase);
    2052             : 
    2053       19909 :     opkt.flags    = pkt->flags;
    2054             :     // FIXME remove the following 2 lines they shall be replaced by the bitstream filters
    2055       19909 :     if (  ost->st->codecpar->codec_id != AV_CODEC_ID_H264
    2056       18370 :        && ost->st->codecpar->codec_id != AV_CODEC_ID_MPEG1VIDEO
    2057       18370 :        && ost->st->codecpar->codec_id != AV_CODEC_ID_MPEG2VIDEO
    2058       18276 :        && ost->st->codecpar->codec_id != AV_CODEC_ID_VC1
    2059       18276 :        ) {
    2060       36552 :         int ret = av_parser_change(ost->parser, ost->parser_avctx,
    2061             :                              &opkt.data, &opkt.size,
    2062       18276 :                              pkt->data, pkt->size,
    2063       18276 :                              pkt->flags & AV_PKT_FLAG_KEY);
    2064       18276 :         if (ret < 0) {
    2065           0 :             av_log(NULL, AV_LOG_FATAL, "av_parser_change failed: %s\n",
    2066           0 :                    av_err2str(ret));
    2067           0 :             exit_program(1);
    2068             :         }
    2069       18276 :         if (ret) {
    2070           0 :             opkt.buf = av_buffer_create(opkt.data, opkt.size, av_buffer_default_free, NULL, 0);
    2071           0 :             if (!opkt.buf)
    2072           0 :                 exit_program(1);
    2073             :         }
    2074             :     } else {
    2075        1633 :         opkt.data = pkt->data;
    2076        1633 :         opkt.size = pkt->size;
    2077             :     }
    2078       19909 :     av_copy_packet_side_data(&opkt, pkt);
    2079             : 
    2080             : #if FF_API_LAVF_FMT_RAWPICTURE
    2081       23496 :     if (ost->st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO &&
    2082        3631 :         ost->st->codecpar->codec_id == AV_CODEC_ID_RAWVIDEO &&
    2083          44 :         (of->ctx->oformat->flags & AVFMT_RAWPICTURE)) {
    2084             :         /* store AVPicture in AVPacket, as expected by the output format */
    2085           0 :         int ret = avpicture_fill(&pict, opkt.data, ost->st->codecpar->format, ost->st->codecpar->width, ost->st->codecpar->height);
    2086           0 :         if (ret < 0) {
    2087           0 :             av_log(NULL, AV_LOG_FATAL, "avpicture_fill failed: %s\n",
    2088           0 :                    av_err2str(ret));
    2089           0 :             exit_program(1);
    2090             :         }
    2091           0 :         opkt.data = (uint8_t *)&pict;
    2092           0 :         opkt.size = sizeof(AVPicture);
    2093           0 :         opkt.flags |= AV_PKT_FLAG_KEY;
    2094             :     }
    2095             : #endif
    2096             : 
    2097       19909 :     output_packet(of, &opkt, ost);
    2098             : }
    2099             : 
    2100        1273 : int guess_input_channel_layout(InputStream *ist)
    2101             : {
    2102        1273 :     AVCodecContext *dec = ist->dec_ctx;
    2103             : 
    2104        1273 :     if (!dec->channel_layout) {
    2105             :         char layout_name[256];
    2106             : 
    2107         718 :         if (dec->channels > ist->guess_layout_max)
    2108           4 :             return 0;
    2109         716 :         dec->channel_layout = av_get_default_channel_layout(dec->channels);
    2110         716 :         if (!dec->channel_layout)
    2111           0 :             return 0;
    2112         716 :         av_get_channel_layout_string(layout_name, sizeof(layout_name),
    2113             :                                      dec->channels, dec->channel_layout);
    2114         716 :         av_log(NULL, AV_LOG_WARNING, "Guessed Channel Layout for Input Stream "
    2115         716 :                "#%d.%d : %s\n", ist->file_index, ist->st->index, layout_name);
    2116             :     }
    2117        1271 :     return 1;
    2118             : }
    2119             : 
    2120      731524 : static void check_decode_result(InputStream *ist, int *got_output, int ret)
    2121             : {
    2122      731524 :     if (*got_output || ret<0)
    2123      377749 :         decode_error_stat[ret<0] ++;
    2124             : 
    2125      731524 :     if (ret < 0 && exit_on_error)
    2126           0 :         exit_program(1);
    2127             : 
    2128      731524 :     if (exit_on_error && *got_output && ist) {
    2129           0 :         if (ist->decoded_frame->decode_error_flags || (ist->decoded_frame->flags & AV_FRAME_FLAG_CORRUPT)) {
    2130           0 :             av_log(NULL, AV_LOG_FATAL, "%s: corrupt decoded frame in stream %d\n", input_files[ist->file_index]->ctx->filename, ist->st->index);
    2131           0 :             exit_program(1);
    2132             :         }
    2133             :     }
    2134      731524 : }
    2135             : 
    2136             : // Filters can be configured only if the formats of all inputs are known.
    2137     2279745 : static int ifilter_has_all_input_formats(FilterGraph *fg)
    2138             : {
    2139             :     int i;
    2140     2328381 :     for (i = 0; i < fg->nb_inputs; i++) {
    2141     4597825 :         if (fg->inputs[i]->format < 0 && (fg->inputs[i]->type == AVMEDIA_TYPE_AUDIO ||
    2142     2274584 :                                           fg->inputs[i]->type == AVMEDIA_TYPE_VIDEO))
    2143     2274605 :             return 0;
    2144             :     }
    2145        5140 :     return 1;
    2146             : }
    2147             : 
    2148      377170 : static int ifilter_send_frame(InputFilter *ifilter, AVFrame *frame)
    2149             : {
    2150      377170 :     FilterGraph *fg = ifilter->graph;
    2151             :     int need_reinit, ret, i;
    2152             : 
    2153             :     /* determine if the parameters for this input changed */
    2154      377170 :     need_reinit = ifilter->format != frame->format;
    2155      754340 :     if (!!ifilter->hw_frames_ctx != !!frame->hw_frames_ctx ||
    2156      377170 :         (ifilter->hw_frames_ctx && ifilter->hw_frames_ctx->data != frame->hw_frames_ctx->data))
    2157           0 :         need_reinit = 1;
    2158             : 
    2159      377170 :     switch (ifilter->ist->st->codecpar->codec_type) {
    2160             :     case AVMEDIA_TYPE_AUDIO:
    2161      847133 :         need_reinit |= ifilter->sample_rate    != frame->sample_rate ||
    2162      564402 :                        ifilter->channels       != frame->channels ||
    2163      281672 :                        ifilter->channel_layout != frame->channel_layout;
    2164      282730 :         break;
    2165             :     case AVMEDIA_TYPE_VIDEO:
    2166      184822 :         need_reinit |= ifilter->width  != frame->width ||
    2167       90382 :                        ifilter->height != frame->height;
    2168       94440 :         break;
    2169             :     }
    2170             : 
    2171      377170 :     if (need_reinit) {
    2172        5129 :         ret = ifilter_parameters_from_frame(ifilter, frame);
    2173        5129 :         if (ret < 0)
    2174           0 :             return ret;
    2175             :     }
    2176             : 
    2177             :     /* (re)init the graph if possible, otherwise buffer the frame and return */
    2178      377170 :     if (need_reinit || !fg->graph) {
    2179       10260 :         for (i = 0; i < fg->nb_inputs; i++) {
    2180        5150 :             if (!ifilter_has_all_input_formats(fg)) {
    2181          19 :                 AVFrame *tmp = av_frame_clone(frame);
    2182          19 :                 if (!tmp)
    2183           0 :                     return AVERROR(ENOMEM);
    2184          19 :                 av_frame_unref(frame);
    2185             : 
    2186          19 :                 if (!av_fifo_space(ifilter->frame_queue)) {
    2187           0 :                     ret = av_fifo_realloc2(ifilter->frame_queue, 2 * av_fifo_size(ifilter->frame_queue));
    2188           0 :                     if (ret < 0) {
    2189           0 :                         av_frame_free(&tmp);
    2190           0 :                         return ret;
    2191             :                     }
    2192             :                 }
    2193          19 :                 av_fifo_generic_write(ifilter->frame_queue, &tmp, sizeof(tmp), NULL);
    2194          19 :                 return 0;
    2195             :             }
    2196             :         }
    2197             : 
    2198        5110 :         ret = reap_filters(1);
    2199        5110 :         if (ret < 0 && ret != AVERROR_EOF) {
    2200             :             char errbuf[128];
    2201           0 :             av_strerror(ret, errbuf, sizeof(errbuf));
    2202             : 
    2203           0 :             av_log(NULL, AV_LOG_ERROR, "Error while filtering: %s\n", errbuf);
    2204           0 :             return ret;
    2205             :         }
    2206             : 
    2207        5110 :         ret = configure_filtergraph(fg);
    2208        5110 :         if (ret < 0) {
    2209           0 :             av_log(NULL, AV_LOG_ERROR, "Error reinitializing filters!\n");
    2210           0 :             return ret;
    2211             :         }
    2212             :     }
    2213             : 
    2214      377151 :     ret = av_buffersrc_add_frame_flags(ifilter->filter, frame, AV_BUFFERSRC_FLAG_PUSH);
    2215      377151 :     if (ret < 0) {
    2216           0 :         if (ret != AVERROR_EOF)
    2217           0 :             av_log(NULL, AV_LOG_ERROR, "Error while filtering: %s\n", av_err2str(ret));
    2218           0 :         return ret;
    2219             :     }
    2220             : 
    2221      377151 :     return 0;
    2222             : }
    2223             : 
    2224        5083 : static int ifilter_send_eof(InputFilter *ifilter)
    2225             : {
    2226             :     int i, j, ret;
    2227             : 
    2228        5083 :     ifilter->eof = 1;
    2229             : 
    2230        5083 :     if (ifilter->filter) {
    2231        5083 :         ret = av_buffersrc_add_frame_flags(ifilter->filter, NULL, AV_BUFFERSRC_FLAG_PUSH);
    2232        5083 :         if (ret < 0)
    2233           0 :             return ret;
    2234             :     } else {
    2235             :         // the filtergraph was never configured
    2236           0 :         FilterGraph *fg = ifilter->graph;
    2237           0 :         for (i = 0; i < fg->nb_inputs; i++)
    2238           0 :             if (!fg->inputs[i]->eof)
    2239           0 :                 break;
    2240           0 :         if (i == fg->nb_inputs) {
    2241             :             // All the input streams have finished without the filtergraph
    2242             :             // ever being configured.
    2243             :             // Mark the output streams as finished.
    2244           0 :             for (j = 0; j < fg->nb_outputs; j++)
    2245           0 :                 finish_output_stream(fg->outputs[j]->ost);
    2246             :         }
    2247             :     }
    2248             : 
    2249        5083 :     return 0;
    2250             : }
    2251             : 
    2252             : // This does not quite work like avcodec_decode_audio4/avcodec_decode_video2.
    2253             : // There is the following difference: if you got a frame, you must call
    2254             : // it again with pkt=NULL. pkt==NULL is treated differently from pkt.size==0
    2255             : // (pkt==NULL means get more output, pkt.size==0 is a flush/drain packet)
    2256      735651 : static int decode(AVCodecContext *avctx, AVFrame *frame, int *got_frame, AVPacket *pkt)
    2257             : {
    2258             :     int ret;
    2259             : 
    2260      735651 :     *got_frame = 0;
    2261             : 
    2262      735651 :     if (pkt) {
    2263      359467 :         ret = avcodec_send_packet(avctx, pkt);
    2264             :         // In particular, we don't expect AVERROR(EAGAIN), because we read all
    2265             :         // decoded frames with avcodec_receive_frame() until done.
    2266      359467 :         if (ret < 0 && ret != AVERROR_EOF)
    2267         379 :             return ret;
    2268             :     }
    2269             : 
    2270      735272 :     ret = avcodec_receive_frame(avctx, frame);
    2271      735272 :     if (ret < 0 && ret != AVERROR(EAGAIN))
    2272        5085 :         return ret;
    2273      730187 :     if (ret >= 0)
    2274      376782 :         *got_frame = 1;
    2275             : 
    2276      730187 :     return 0;
    2277             : }
    2278             : 
    2279      376782 : static int send_frame_to_filters(InputStream *ist, AVFrame *decoded_frame)
    2280             : {
    2281             :     int i, ret;
    2282             :     AVFrame *f;
    2283             : 
    2284             :     av_assert1(ist->nb_filters > 0); /* ensure ret is initialized */
    2285      753952 :     for (i = 0; i < ist->nb_filters; i++) {
    2286      377170 :         if (i < ist->nb_filters - 1) {
    2287         388 :             f = ist->filter_frame;
    2288         388 :             ret = av_frame_ref(f, decoded_frame);
    2289         388 :             if (ret < 0)
    2290           0 :                 break;
    2291             :         } else
    2292      376782 :             f = decoded_frame;
    2293      377170 :         ret = ifilter_send_frame(ist->filters[i], f);
    2294      377170 :         if (ret == AVERROR_EOF)
    2295           0 :             ret = 0; /* ignore */
    2296      377170 :         if (ret < 0) {
    2297           0 :             av_log(NULL, AV_LOG_ERROR,
    2298           0 :                    "Failed to inject frame into filter network: %s\n", av_err2str(ret));
    2299           0 :             break;
    2300             :         }
    2301             :     }
    2302      376782 :     return ret;
    2303             : }
    2304             : 
    2305      538962 : static int decode_audio(InputStream *ist, AVPacket *pkt, int *got_output,
    2306             :                         int *decode_failed)
    2307             : {
    2308             :     AVFrame *decoded_frame;
    2309      538962 :     AVCodecContext *avctx = ist->dec_ctx;
    2310      538962 :     int ret, err = 0;
    2311             :     AVRational decoded_frame_tb;
    2312             : 
    2313      538962 :     if (!ist->decoded_frame && !(ist->decoded_frame = av_frame_alloc()))
    2314           0 :         return AVERROR(ENOMEM);
    2315      538962 :     if (!ist->filter_frame && !(ist->filter_frame = av_frame_alloc()))
    2316           0 :         return AVERROR(ENOMEM);
    2317      538962 :     decoded_frame = ist->decoded_frame;
    2318             : 
    2319      538962 :     update_benchmark(NULL);
    2320      538962 :     ret = decode(avctx, decoded_frame, got_output, pkt);
    2321      538962 :     update_benchmark("decode_audio %d.%d", ist->file_index, ist->st->index);
    2322      538962 :     if (ret < 0)
    2323        1065 :         *decode_failed = 1;
    2324             : 
    2325      538962 :     if (ret >= 0 && avctx->sample_rate <= 0) {
    2326           0 :         av_log(avctx, AV_LOG_ERROR, "Sample rate %d invalid\n", avctx->sample_rate);
    2327           0 :         ret = AVERROR_INVALIDDATA;
    2328             :     }
    2329             : 
    2330      538962 :     if (ret != AVERROR_EOF)
    2331      537907 :         check_decode_result(ist, got_output, ret);
    2332             : 
    2333      538962 :     if (!*got_output || ret < 0)
    2334      256620 :         return ret;
    2335             : 
    2336      282342 :     ist->samples_decoded += decoded_frame->nb_samples;
    2337      282342 :     ist->frames_decoded++;
    2338             : 
    2339             : #if 1
    2340             :     /* increment next_dts to use for the case where the input stream does not
    2341             :        have timestamps or there are multiple frames in the packet */
    2342      564684 :     ist->next_pts += ((int64_t)AV_TIME_BASE * decoded_frame->nb_samples) /
    2343      282342 :                      avctx->sample_rate;
    2344      564684 :     ist->next_dts += ((int64_t)AV_TIME_BASE * decoded_frame->nb_samples) /
    2345      282342 :                      avctx->sample_rate;
    2346             : #endif
    2347             : 
    2348      282342 :     if (decoded_frame->pts != AV_NOPTS_VALUE) {
    2349      254359 :         decoded_frame_tb   = ist->st->time_base;
    2350       27983 :     } else if (pkt && pkt->pts != AV_NOPTS_VALUE) {
    2351           3 :         decoded_frame->pts = pkt->pts;
    2352           3 :         decoded_frame_tb   = ist->st->time_base;
    2353             :     }else {
    2354       27980 :         decoded_frame->pts = ist->dts;
    2355       27980 :         decoded_frame_tb   = AV_TIME_BASE_Q;
    2356             :     }
    2357      282342 :     if (decoded_frame->pts != AV_NOPTS_VALUE)
    2358      564684 :         decoded_frame->pts = av_rescale_delta(decoded_frame_tb, decoded_frame->pts,
    2359      282342 :                                               (AVRational){1, avctx->sample_rate}, decoded_frame->nb_samples, &ist->filter_in_rescale_delta_last,
    2360      282342 :                                               (AVRational){1, avctx->sample_rate});
    2361      282342 :     ist->nb_samples = decoded_frame->nb_samples;
    2362      282342 :     err = send_frame_to_filters(ist, decoded_frame);
    2363             : 
    2364      282342 :     av_frame_unref(ist->filter_frame);
    2365      282342 :     av_frame_unref(decoded_frame);
    2366      282342 :     return err < 0 ? err : ret;
    2367             : }
    2368             : 
    2369      198234 : static int decode_video(InputStream *ist, AVPacket *pkt, int *got_output, int eof,
    2370             :                         int *decode_failed)
    2371             : {
    2372             :     AVFrame *decoded_frame;
    2373      198234 :     int i, ret = 0, err = 0;
    2374             :     int64_t best_effort_timestamp;
    2375      198234 :     int64_t dts = AV_NOPTS_VALUE;
    2376             :     AVPacket avpkt;
    2377             : 
    2378             :     // With fate-indeo3-2, we're getting 0-sized packets before EOF for some
    2379             :     // reason. This seems like a semi-critical bug. Don't trigger EOF, and
    2380             :     // skip the packet.
    2381      198234 :     if (!eof && pkt && pkt->size == 0)
    2382        1545 :         return 0;
    2383             : 
    2384      196689 :     if (!ist->decoded_frame && !(ist->decoded_frame = av_frame_alloc()))
    2385           0 :         return AVERROR(ENOMEM);
    2386      196689 :     if (!ist->filter_frame && !(ist->filter_frame = av_frame_alloc()))
    2387           0 :         return AVERROR(ENOMEM);
    2388      196689 :     decoded_frame = ist->decoded_frame;
    2389      196689 :     if (ist->dts != AV_NOPTS_VALUE)
    2390      196276 :         dts = av_rescale_q(ist->dts, AV_TIME_BASE_Q, ist->st->time_base);
    2391      196689 :     if (pkt) {
    2392      102819 :         avpkt = *pkt;
    2393      102819 :         avpkt.dts = dts; // ffmpeg.c probably shouldn't do this
    2394             :     }
    2395             : 
    2396             :     // The old code used to set dts on the drain packet, which does not work
    2397             :     // with the new API anymore.
    2398      196689 :     if (eof) {
    2399        4595 :         void *new = av_realloc_array(ist->dts_buffer, ist->nb_dts_buffer + 1, sizeof(ist->dts_buffer[0]));
    2400        4595 :         if (!new)
    2401           0 :             return AVERROR(ENOMEM);
    2402        4595 :         ist->dts_buffer = new;
    2403        4595 :         ist->dts_buffer[ist->nb_dts_buffer++] = dts;
    2404             :     }
    2405             : 
    2406      196689 :     update_benchmark(NULL);
    2407      196689 :     ret = decode(ist->dec_ctx, decoded_frame, got_output, pkt ? &avpkt : NULL);
    2408      196689 :     update_benchmark("decode_video %d.%d", ist->file_index, ist->st->index);
    2409      196689 :     if (ret < 0)
    2410        4399 :         *decode_failed = 1;
    2411             : 
    2412             :     // The following line may be required in some cases where there is no parser
    2413             :     // or the parser does not has_b_frames correctly
    2414      196689 :     if (ist->st->codecpar->video_delay < ist->dec_ctx->has_b_frames) {
    2415           2 :         if (ist->dec_ctx->codec_id == AV_CODEC_ID_H264) {
    2416           2 :             ist->st->codecpar->video_delay = ist->dec_ctx->has_b_frames;
    2417             :         } else
    2418           0 :             av_log(ist->dec_ctx, AV_LOG_WARNING,
    2419             :                    "video_delay is larger in decoder than demuxer %d > %d.\n"
    2420             :                    "If you want to help, upload a sample "
    2421             :                    "of this file to ftp://upload.ffmpeg.org/incoming/ "
    2422             :                    "and contact the ffmpeg-devel mailing list. (ffmpeg-devel@ffmpeg.org)\n",
    2423           0 :                    ist->dec_ctx->has_b_frames,
    2424           0 :                    ist->st->codecpar->video_delay);
    2425             :     }
    2426             : 
    2427      196689 :     if (ret != AVERROR_EOF)
    2428      192664 :         check_decode_result(ist, got_output, ret);
    2429             : 
    2430      196689 :     if (*got_output && ret >= 0) {
    2431      188871 :         if (ist->dec_ctx->width  != decoded_frame->width ||
    2432      188860 :             ist->dec_ctx->height != decoded_frame->height ||
    2433       94429 :             ist->dec_ctx->pix_fmt != decoded_frame->format) {
    2434          30 :             av_log(NULL, AV_LOG_DEBUG, "Frame parameters mismatch context %d,%d,%d != %d,%d,%d\n",
    2435             :                 decoded_frame->width,
    2436             :                 decoded_frame->height,
    2437             :                 decoded_frame->format,
    2438          15 :                 ist->dec_ctx->width,
    2439          15 :                 ist->dec_ctx->height,
    2440          15 :                 ist->dec_ctx->pix_fmt);
    2441             :         }
    2442             :     }
    2443             : 
    2444      196689 :     if (!*got_output || ret < 0)
    2445      102249 :         return ret;
    2446             : 
    2447       94440 :     if(ist->top_field_first>=0)
    2448           0 :         decoded_frame->top_field_first = ist->top_field_first;
    2449             : 
    2450       94440 :     ist->frames_decoded++;
    2451             : 
    2452       94440 :     if (ist->hwaccel_retrieve_data && decoded_frame->format == ist->hwaccel_pix_fmt) {
    2453           0 :         err = ist->hwaccel_retrieve_data(ist->dec_ctx, decoded_frame);
    2454           0 :         if (err < 0)
    2455           0 :             goto fail;
    2456             :     }
    2457       94440 :     ist->hwaccel_retrieved_pix_fmt = decoded_frame->format;
    2458             : 
    2459       94440 :     best_effort_timestamp= decoded_frame->best_effort_timestamp;
    2460             : 
    2461       94440 :     if (ist->framerate.num)
    2462         103 :         best_effort_timestamp = ist->cfr_next_pts++;
    2463             : 
    2464       94440 :     if (eof && best_effort_timestamp == AV_NOPTS_VALUE && ist->nb_dts_buffer > 0) {
    2465         519 :         best_effort_timestamp = ist->dts_buffer[0];
    2466             : 
    2467         519 :         for (i = 0; i < ist->nb_dts_buffer - 1; i++)
    2468           0 :             ist->dts_buffer[i] = ist->dts_buffer[i + 1];
    2469         519 :         ist->nb_dts_buffer--;
    2470             :     }
    2471             : 
    2472       94440 :     if(best_effort_timestamp != AV_NOPTS_VALUE) {
    2473       94440 :         int64_t ts = av_rescale_q(decoded_frame->pts = best_effort_timestamp, ist->st->time_base, AV_TIME_BASE_Q);
    2474             : 
    2475       94440 :         if (ts != AV_NOPTS_VALUE)
    2476       94440 :             ist->next_pts = ist->pts = ts;
    2477             :     }
    2478             : 
    2479       94440 :     if (debug_ts) {
    2480           0 :         av_log(NULL, AV_LOG_INFO, "decoder -> ist_index:%d type:video "
    2481             :                "frame_pts:%s frame_pts_time:%s best_effort_ts:%"PRId64" best_effort_ts_time:%s keyframe:%d frame_type:%d time_base:%d/%d\n",
    2482           0 :                ist->st->index, av_ts2str(decoded_frame->pts),
    2483           0 :                av_ts2timestr(decoded_frame->pts, &ist->st->time_base),
    2484             :                best_effort_timestamp,
    2485           0 :                av_ts2timestr(best_effort_timestamp, &ist->st->time_base),
    2486           0 :                decoded_frame->key_frame, decoded_frame->pict_type,
    2487           0 :                ist->st->time_base.num, ist->st->time_base.den);
    2488             :     }
    2489             : 
    2490       94440 :     if (ist->st->sample_aspect_ratio.num)
    2491        4232 :         decoded_frame->sample_aspect_ratio = ist->st->sample_aspect_ratio;
    2492             : 
    2493       94440 :     err = send_frame_to_filters(ist, decoded_frame);
    2494             : 
    2495             : fail:
    2496       94440 :     av_frame_unref(ist->filter_frame);
    2497       94440 :     av_frame_unref(decoded_frame);
    2498       94440 :     return err < 0 ? err : ret;
    2499             : }
    2500             : 
    2501         953 : static int transcode_subtitles(InputStream *ist, AVPacket *pkt, int *got_output,
    2502             :                                int *decode_failed)
    2503             : {
    2504             :     AVSubtitle subtitle;
    2505         953 :     int free_sub = 1;
    2506         953 :     int i, ret = avcodec_decode_subtitle2(ist->dec_ctx,
    2507             :                                           &subtitle, got_output, pkt);
    2508             : 
    2509         953 :     check_decode_result(NULL, got_output, ret);
    2510             : 
    2511         953 :     if (ret < 0 || !*got_output) {
    2512         370 :         *decode_failed = 1;
    2513         370 :         if (!pkt->size)
    2514          29 :             sub2video_flush(ist);
    2515         370 :         return ret;
    2516             :     }
    2517             : 
    2518         583 :     if (ist->fix_sub_duration) {
    2519           0 :         int end = 1;
    2520           0 :         if (ist->prev_sub.got_output) {
    2521           0 :             end = av_rescale(subtitle.pts - ist->prev_sub.subtitle.pts,
    2522             :                              1000, AV_TIME_BASE);
    2523           0 :             if (end < ist->prev_sub.subtitle.end_display_time) {
    2524           0 :                 av_log(ist->dec_ctx, AV_LOG_DEBUG,
    2525             :                        "Subtitle duration reduced from %"PRId32" to %d%s\n",
    2526             :                        ist->prev_sub.subtitle.end_display_time, end,
    2527             :                        end <= 0 ? ", dropping it" : "");
    2528           0 :                 ist->prev_sub.subtitle.end_display_time = end;
    2529             :             }
    2530             :         }
    2531           0 :         FFSWAP(int,        *got_output, ist->prev_sub.got_output);
    2532           0 :         FFSWAP(int,        ret,         ist->prev_sub.ret);
    2533           0 :         FFSWAP(AVSubtitle, subtitle,    ist->prev_sub.subtitle);
    2534           0 :         if (end <= 0)
    2535           0 :             goto out;
    2536             :     }
    2537             : 
    2538         583 :     if (!*got_output)
    2539           0 :         return ret;
    2540             : 
    2541         583 :     if (ist->sub2video.frame) {
    2542          44 :         sub2video_update(ist, &subtitle);
    2543         539 :     } else if (ist->nb_filters) {
    2544           0 :         if (!ist->sub2video.sub_queue)
    2545           0 :             ist->sub2video.sub_queue = av_fifo_alloc(8 * sizeof(AVSubtitle));
    2546           0 :         if (!ist->sub2video.sub_queue)
    2547           0 :             exit_program(1);
    2548           0 :         if (!av_fifo_space(ist->sub2video.sub_queue)) {
    2549           0 :             ret = av_fifo_realloc2(ist->sub2video.sub_queue, 2 * av_fifo_size(ist->sub2video.sub_queue));
    2550           0 :             if (ret < 0)
    2551           0 :                 exit_program(1);
    2552             :         }
    2553           0 :         av_fifo_generic_write(ist->sub2video.sub_queue, &subtitle, sizeof(subtitle), NULL);
    2554           0 :         free_sub = 0;
    2555             :     }
    2556             : 
    2557         583 :     if (!subtitle.num_rects)
    2558           0 :         goto out;
    2559             : 
    2560         583 :     ist->frames_decoded++;
    2561             : 
    2562        1210 :     for (i = 0; i < nb_output_streams; i++) {
    2563         627 :         OutputStream *ost = output_streams[i];
    2564             : 
    2565         627 :         if (!check_output_constraints(ist, ost) || !ost->encoding_needed
    2566         582 :             || ost->enc->type != AVMEDIA_TYPE_SUBTITLE)
    2567          45 :             continue;
    2568             : 
    2569         582 :         do_subtitle_out(output_files[ost->file_index], ost, &subtitle);
    2570             :     }
    2571             : 
    2572             : out:
    2573         583 :     if (free_sub)
    2574         583 :         avsubtitle_free(&subtitle);
    2575         583 :     return ret;
    2576             : }
    2577             : 
    2578        5109 : static int send_filter_eof(InputStream *ist)
    2579             : {
    2580             :     int i, ret;
    2581       10192 :     for (i = 0; i < ist->nb_filters; i++) {
    2582        5083 :         ret = ifilter_send_eof(ist->filters[i]);
    2583        5083 :         if (ret < 0)
    2584           0 :             return ret;
    2585             :     }
    2586        5109 :     return 0;
    2587             : }
    2588             : 
    2589             : /* pkt = NULL means EOF (needed to flush decoder buffers) */
    2590      381915 : static int process_input_packet(InputStream *ist, const AVPacket *pkt, int no_eof)
    2591             : {
    2592      381915 :     int ret = 0, i;
    2593      381915 :     int repeating = 0;
    2594      381915 :     int eof_reached = 0;
    2595             : 
    2596             :     AVPacket avpkt;
    2597      381915 :     if (!ist->saw_first_ts) {
    2598        5275 :         ist->dts = ist->st->avg_frame_rate.num ? - ist->dec_ctx->has_b_frames * AV_TIME_BASE / av_q2d(ist->st->avg_frame_rate) : 0;
    2599        5275 :         ist->pts = 0;
    2600        5275 :         if (pkt && pkt->pts != AV_NOPTS_VALUE && !ist->decoding_needed) {
    2601         135 :             ist->dts += av_rescale_q(pkt->pts, ist->st->time_base, AV_TIME_BASE_Q);
    2602         135 :             ist->pts = ist->dts; //unused but better to set it to a value thats not totally wrong
    2603             :         }
    2604        5275 :         ist->saw_first_ts = 1;
    2605             :     }
    2606             : 
    2607      381915 :     if (ist->next_dts == AV_NOPTS_VALUE)
    2608        5688 :         ist->next_dts = ist->dts;
    2609      381915 :     if (ist->next_pts == AV_NOPTS_VALUE)
    2610        5275 :         ist->next_pts = ist->pts;
    2611             : 
    2612      381915 :     if (!pkt) {
    2613             :         /* EOF handling */
    2614        5708 :         av_init_packet(&avpkt);
    2615        5708 :         avpkt.data = NULL;
    2616        5708 :         avpkt.size = 0;
    2617             :     } else {
    2618      376207 :         avpkt = *pkt;
    2619             :     }
    2620             : 
    2621      381915 :     if (pkt && pkt->dts != AV_NOPTS_VALUE) {
    2622      344968 :         ist->next_dts = ist->dts = av_rescale_q(pkt->dts, ist->st->time_base, AV_TIME_BASE_Q);
    2623      344968 :         if (ist->dec_ctx->codec_type != AVMEDIA_TYPE_VIDEO || !ist->decoding_needed)
    2624      275073 :             ist->next_pts = ist->pts = ist->dts;
    2625             :     }
    2626             : 
    2627             :     // while we have more to decode or while the decoder did output something on EOF
    2628     1140597 :     while (ist->decoding_needed) {
    2629      738732 :         int64_t duration = 0;
    2630      738732 :         int got_output = 0;
    2631      738732 :         int decode_failed = 0;
    2632             : 
    2633      738732 :         ist->pts = ist->next_pts;
    2634      738732 :         ist->dts = ist->next_dts;
    2635             : 
    2636      738732 :         switch (ist->dec_ctx->codec_type) {
    2637             :         case AVMEDIA_TYPE_AUDIO:
    2638      538962 :             ret = decode_audio    (ist, repeating ? NULL : &avpkt, &got_output,
    2639             :                                    &decode_failed);
    2640      538962 :             break;
    2641             :         case AVMEDIA_TYPE_VIDEO:
    2642      198234 :             ret = decode_video    (ist, repeating ? NULL : &avpkt, &got_output, !pkt,
    2643             :                                    &decode_failed);
    2644      198234 :             if (!repeating || !pkt || got_output) {
    2645      104364 :                 if (pkt && pkt->duration) {
    2646       97472 :                     duration = av_rescale_q(pkt->duration, ist->st->time_base, AV_TIME_BASE_Q);
    2647        6892 :                 } else if(ist->dec_ctx->framerate.num != 0 && ist->dec_ctx->framerate.den != 0) {
    2648        5719 :                     int ticks= av_stream_get_parser(ist->st) ? av_stream_get_parser(ist->st)->repeat_pict+1 : ist->dec_ctx->ticks_per_frame;
    2649       11438 :                     duration = ((int64_t)AV_TIME_BASE *
    2650       17157 :                                     ist->dec_ctx->framerate.den * ticks) /
    2651       11438 :                                     ist->dec_ctx->framerate.num / ist->dec_ctx->ticks_per_frame;
    2652             :                 }
    2653             : 
    2654      104364 :                 if(ist->dts != AV_NOPTS_VALUE && duration) {
    2655      103191 :                     ist->next_dts += duration;
    2656             :                 }else
    2657        1173 :                     ist->next_dts = AV_NOPTS_VALUE;
    2658             :             }
    2659             : 
    2660      198234 :             if (got_output)
    2661       94440 :                 ist->next_pts += duration; //FIXME the duration is not correct in some cases
    2662      198234 :             break;
    2663             :         case AVMEDIA_TYPE_SUBTITLE:
    2664        1536 :             if (repeating)
    2665         583 :                 break;
    2666         953 :             ret = transcode_subtitles(ist, &avpkt, &got_output, &decode_failed);
    2667         953 :             if (!pkt && ret >= 0)
    2668          29 :                 ret = AVERROR_EOF;
    2669         953 :             break;
    2670             :         default:
    2671           0 :             return -1;
    2672             :         }
    2673             : 
    2674      738732 :         if (ret == AVERROR_EOF) {
    2675        5109 :             eof_reached = 1;
    2676      367074 :             break;
    2677             :         }
    2678             : 
    2679      733623 :         if (ret < 0) {
    2680         384 :             if (decode_failed) {
    2681         768 :                 av_log(NULL, AV_LOG_ERROR, "Error while decoding stream #%d:%d: %s\n",
    2682         768 :                        ist->file_index, ist->st->index, av_err2str(ret));
    2683             :             } else {
    2684           0 :                 av_log(NULL, AV_LOG_FATAL, "Error while processing the decoded "
    2685           0 :                        "data for stream #%d:%d\n", ist->file_index, ist->st->index);
    2686             :             }
    2687         384 :             if (!decode_failed || exit_on_error)
    2688           0 :                 exit_program(1);
    2689         384 :             break;
    2690             :         }
    2691             : 
    2692      733239 :         if (got_output)
    2693      377365 :             ist->got_output = 1;
    2694             : 
    2695      733239 :         if (!got_output)
    2696      355874 :             break;
    2697             : 
    2698             :         // During draining, we might get multiple output frames in this loop.
    2699             :         // ffmpeg.c does not drain the filter chain on configuration changes,
    2700             :         // which means if we send multiple frames at once to the filters, and
    2701             :         // one of those frames changes configuration, the buffered frames will
    2702             :         // be lost. This can upset certain FATE tests.
    2703             :         // Decode only 1 frame per call on EOF to appease these FATE tests.
    2704             :         // The ideal solution would be to rewrite decoding to use the new
    2705             :         // decoding API in a better way.
    2706      377365 :         if (!pkt)
    2707         598 :             break;
    2708             : 
    2709      376767 :         repeating = 1;
    2710             :     }
    2711             : 
    2712             :     /* after flushing, send an EOF on all the filter inputs attached to the stream */
    2713             :     /* except when looping we need to flush but not to send an EOF */
    2714      381915 :     if (!pkt && ist->decoding_needed && eof_reached && !no_eof) {
    2715        5109 :         int ret = send_filter_eof(ist);
    2716        5109 :         if (ret < 0) {
    2717           0 :             av_log(NULL, AV_LOG_FATAL, "Error marking filters as finished\n");
    2718           0 :             exit_program(1);
    2719             :         }
    2720             :     }
    2721             : 
    2722             :     /* handle stream copy */
    2723      381915 :     if (!ist->decoding_needed) {
    2724       19950 :         ist->dts = ist->next_dts;
    2725       19950 :         switch (ist->dec_ctx->codec_type) {
    2726             :         case AVMEDIA_TYPE_AUDIO:
    2727       31660 :             ist->next_dts += ((int64_t)AV_TIME_BASE * ist->dec_ctx->frame_size) /
    2728       15830 :                              ist->dec_ctx->sample_rate;
    2729       15830 :             break;
    2730             :         case AVMEDIA_TYPE_VIDEO:
    2731        3600 :             if (ist->framerate.num) {
    2732             :                 // TODO: Remove work-around for c99-to-c89 issue 7
    2733          79 :                 AVRational time_base_q = AV_TIME_BASE_Q;
    2734          79 :                 int64_t next_dts = av_rescale_q(ist->next_dts, time_base_q, av_inv_q(ist->framerate));
    2735          79 :                 ist->next_dts = av_rescale_q(next_dts + 1, av_inv_q(ist->framerate), time_base_q);
    2736        3521 :             } else if (pkt->duration) {
    2737        3294 :                 ist->next_dts += av_rescale_q(pkt->duration, ist->st->time_base, AV_TIME_BASE_Q);
    2738         227 :             } else if(ist->dec_ctx->framerate.num != 0) {
    2739         119 :                 int ticks= av_stream_get_parser(ist->st) ? av_stream_get_parser(ist->st)->repeat_pict + 1 : ist->dec_ctx->ticks_per_frame;
    2740         357 :                 ist->next_dts += ((int64_t)AV_TIME_BASE *
    2741         357 :                                   ist->dec_ctx->framerate.den * ticks) /
    2742         238 :                                   ist->dec_ctx->framerate.num / ist->dec_ctx->ticks_per_frame;
    2743             :             }
    2744        3600 :             break;
    2745             :         }
    2746       19950 :         ist->pts = ist->dts;
    2747       19950 :         ist->next_pts = ist->next_dts;
    2748             :     }
    2749      770899 :     for (i = 0; pkt && i < nb_output_streams; i++) {
    2750      388984 :         OutputStream *ost = output_streams[i];
    2751             : 
    2752      388984 :         if (!check_output_constraints(ist, ost) || ost->encoding_needed)
    2753      369057 :             continue;
    2754             : 
    2755       19927 :         do_streamcopy(ist, ost, pkt);
    2756             :     }
    2757             : 
    2758      381915 :     return !eof_reached;
    2759             : }
    2760             : 
    2761           0 : static void print_sdp(void)
    2762             : {
    2763             :     char sdp[16384];
    2764             :     int i;
    2765             :     int j;
    2766             :     AVIOContext *sdp_pb;
    2767             :     AVFormatContext **avc;
    2768             : 
    2769           0 :     for (i = 0; i < nb_output_files; i++) {
    2770           0 :         if (!output_files[i]->header_written)
    2771           0 :             return;
    2772             :     }
    2773             : 
    2774           0 :     avc = av_malloc_array(nb_output_files, sizeof(*avc));
    2775           0 :     if (!avc)
    2776           0 :         exit_program(1);
    2777           0 :     for (i = 0, j = 0; i < nb_output_files; i++) {
    2778           0 :         if (!strcmp(output_files[i]->ctx->oformat->name, "rtp")) {
    2779           0 :             avc[j] = output_files[i]->ctx;
    2780           0 :             j++;
    2781             :         }
    2782             :     }
    2783             : 
    2784           0 :     if (!j)
    2785           0 :         goto fail;
    2786             : 
    2787           0 :     av_sdp_create(avc, j, sdp, sizeof(sdp));
    2788             : 
    2789           0 :     if (!sdp_filename) {
    2790           0 :         printf("SDP:\n%s\n", sdp);
    2791           0 :         fflush(stdout);
    2792             :     } else {
    2793           0 :         if (avio_open2(&sdp_pb, sdp_filename, AVIO_FLAG_WRITE, &int_cb, NULL) < 0) {
    2794           0 :             av_log(NULL, AV_LOG_ERROR, "Failed to open sdp file '%s'\n", sdp_filename);
    2795             :         } else {
    2796           0 :             avio_printf(sdp_pb, "SDP:\n%s", sdp);
    2797           0 :             avio_closep(&sdp_pb);
    2798           0 :             av_freep(&sdp_filename);
    2799             :         }
    2800             :     }
    2801             : 
    2802             : fail:
    2803           0 :     av_freep(&avc);
    2804             : }
    2805             : 
    2806           0 : static const HWAccel *get_hwaccel(enum AVPixelFormat pix_fmt)
    2807             : {
    2808             :     int i;
    2809           0 :     for (i = 0; hwaccels[i].name; i++)
    2810           0 :         if (hwaccels[i].pix_fmt == pix_fmt)
    2811           0 :             return &hwaccels[i];
    2812           0 :     return NULL;
    2813             : }
    2814             : 
    2815         826 : static enum AVPixelFormat get_format(AVCodecContext *s, const enum AVPixelFormat *pix_fmts)
    2816             : {
    2817         826 :     InputStream *ist = s->opaque;
    2818             :     const enum AVPixelFormat *p;
    2819             :     int ret;
    2820             : 
    2821         826 :     for (p = pix_fmts; *p != -1; p++) {
    2822         826 :         const AVPixFmtDescriptor *desc = av_pix_fmt_desc_get(*p);
    2823             :         const HWAccel *hwaccel;
    2824             : 
    2825         826 :         if (!(desc->flags & AV_PIX_FMT_FLAG_HWACCEL))
    2826         826 :             break;
    2827             : 
    2828           0 :         hwaccel = get_hwaccel(*p);
    2829           0 :         if (!hwaccel ||
    2830           0 :             (ist->active_hwaccel_id && ist->active_hwaccel_id != hwaccel->id) ||
    2831           0 :             (ist->hwaccel_id != HWACCEL_AUTO && ist->hwaccel_id != hwaccel->id))
    2832           0 :             continue;
    2833             : 
    2834           0 :         ret = hwaccel->init(s);
    2835           0 :         if (ret < 0) {
    2836           0 :             if (ist->hwaccel_id == hwaccel->id) {
    2837           0 :                 av_log(NULL, AV_LOG_FATAL,
    2838             :                        "%s hwaccel requested for input stream #%d:%d, "
    2839             :                        "but cannot be initialized.\n", hwaccel->name,
    2840           0 :                        ist->file_index, ist->st->index);
    2841           0 :                 return AV_PIX_FMT_NONE;
    2842             :             }
    2843           0 :             continue;
    2844             :         }
    2845             : 
    2846           0 :         if (ist->hw_frames_ctx) {
    2847           0 :             s->hw_frames_ctx = av_buffer_ref(ist->hw_frames_ctx);
    2848           0 :             if (!s->hw_frames_ctx)
    2849           0 :                 return AV_PIX_FMT_NONE;
    2850             :         }
    2851             : 
    2852           0 :         ist->active_hwaccel_id = hwaccel->id;
    2853           0 :         ist->hwaccel_pix_fmt   = *p;
    2854           0 :         break;
    2855             :     }
    2856             : 
    2857         826 :     return *p;
    2858             : }
    2859             : 
    2860      352700 : static int get_buffer(AVCodecContext *s, AVFrame *frame, int flags)
    2861             : {
    2862      352700 :     InputStream *ist = s->opaque;
    2863             : 
    2864      352700 :     if (ist->hwaccel_get_buffer && frame->format == ist->hwaccel_pix_fmt)
    2865           0 :         return ist->hwaccel_get_buffer(s, frame, flags);
    2866             : 
    2867      352700 :     return avcodec_default_get_buffer2(s, frame, flags);
    2868             : }
    2869             : 
    2870        5513 : static int init_input_stream(int ist_index, char *error, int error_len)
    2871             : {
    2872             :     int ret;
    2873        5513 :     InputStream *ist = input_streams[ist_index];
    2874             : 
    2875        5513 :     if (ist->decoding_needed) {
    2876        5120 :         AVCodec *codec = ist->dec;
    2877        5120 :         if (!codec) {
    2878           0 :             snprintf(error, error_len, "Decoder (codec %s) not found for input stream #%d:%d",
    2879           0 :                     avcodec_get_name(ist->dec_ctx->codec_id), ist->file_index, ist->st->index);
    2880           0 :             return AVERROR(EINVAL);
    2881             :         }
    2882             : 
    2883        5120 :         ist->dec_ctx->opaque                = ist;
    2884        5120 :         ist->dec_ctx->get_format            = get_format;
    2885        5120 :         ist->dec_ctx->get_buffer2           = get_buffer;
    2886        5120 :         ist->dec_ctx->thread_safe_callbacks = 1;
    2887             : 
    2888        5120 :         av_opt_set_int(ist->dec_ctx, "refcounted_frames", 1, 0);
    2889        5120 :         if (ist->dec_ctx->codec_id == AV_CODEC_ID_DVB_SUBTITLE &&
    2890           0 :            (ist->decoding_needed & DECODING_FOR_OST)) {
    2891           0 :             av_dict_set(&ist->decoder_opts, "compute_edt", "1", AV_DICT_DONT_OVERWRITE);
    2892           0 :             if (ist->decoding_needed & DECODING_FOR_FILTER)
    2893           0 :                 av_log(NULL, AV_LOG_WARNING, "Warning using DVB subtitles for filtering and output at the same time is not fully supported, also see -compute_edt [0|1]\n");
    2894             :         }
    2895             : 
    2896        5120 :         av_dict_set(&ist->decoder_opts, "sub_text_format", "ass", AV_DICT_DONT_OVERWRITE);
    2897             : 
    2898             :         /* Useful for subtitles retiming by lavf (FIXME), skipping samples in
    2899             :          * audio, and video decoders such as cuvid or mediacodec */
    2900        5120 :         av_codec_set_pkt_timebase(ist->dec_ctx, ist->st->time_base);
    2901             : 
    2902        5120 :         if (!av_dict_get(ist->decoder_opts, "threads", NULL, 0))
    2903          36 :             av_dict_set(&ist->decoder_opts, "threads", "auto", 0);
    2904        5120 :         if ((ret = avcodec_open2(ist->dec_ctx, codec, &ist->decoder_opts)) < 0) {
    2905           0 :             if (ret == AVERROR_EXPERIMENTAL)
    2906           0 :                 abort_codec_experimental(codec, 0);
    2907             : 
    2908           0 :             snprintf(error, error_len,
    2909             :                      "Error while opening decoder for input stream "
    2910             :                      "#%d:%d : %s",
    2911           0 :                      ist->file_index, ist->st->index, av_err2str(ret));
    2912           0 :             return ret;
    2913             :         }
    2914        5120 :         assert_avoptions(ist->decoder_opts);
    2915             :     }
    2916             : 
    2917        5513 :     ist->next_pts = AV_NOPTS_VALUE;
    2918        5513 :     ist->next_dts = AV_NOPTS_VALUE;
    2919             : 
    2920        5513 :     return 0;
    2921             : }
    2922             : 
    2923       10399 : static InputStream *get_input_stream(OutputStream *ost)
    2924             : {
    2925       10399 :     if (ost->source_index >= 0)
    2926       10339 :         return input_streams[ost->source_index];
    2927          60 :     return NULL;
    2928             : }
    2929             : 
    2930           1 : static int compare_int64(const void *a, const void *b)
    2931             : {
    2932           1 :     return FFDIFFSIGN(*(const int64_t *)a, *(const int64_t *)b);
    2933             : }
    2934             : 
    2935             : /* open the muxer when all the streams are initialized */
    2936        5289 : static int check_init_output_file(OutputFile *of, int file_index)
    2937             : {
    2938             :     int ret, i;
    2939             : 
    2940       10685 :     for (i = 0; i < of->ctx->nb_streams; i++) {
    2941        5529 :         OutputStream *ost = output_streams[of->ost_index + i];
    2942        5529 :         if (!ost->initialized)
    2943         133 :             return 0;
    2944             :     }
    2945             : 
    2946        5156 :     of->ctx->interrupt_callback = int_cb;
    2947             : 
    2948        5156 :     ret = avformat_write_header(of->ctx, &of->opts);
    2949        5156 :     if (ret < 0) {
    2950           0 :         av_log(NULL, AV_LOG_ERROR,
    2951             :                "Could not write header for output file #%d "
    2952             :                "(incorrect codec parameters ?): %s\n",
    2953           0 :                file_index, av_err2str(ret));
    2954           0 :         return ret;
    2955             :     }
    2956             :     //assert_avoptions(of->opts);
    2957        5156 :     of->header_written = 1;
    2958             : 
    2959        5156 :     av_dump_format(of->ctx, file_index, of->ctx->filename, 1);
    2960             : 
    2961        5156 :     if (sdp_filename || want_sdp)
    2962           0 :         print_sdp();
    2963             : 
    2964             :     /* flush the muxing queues */
    2965       10444 :     for (i = 0; i < of->ctx->nb_streams; i++) {
    2966        5288 :         OutputStream *ost = output_streams[of->ost_index + i];
    2967             : 
    2968             :         /* try to improve muxing time_base (only possible if nothing has been written yet) */
    2969        5288 :         if (!av_fifo_size(ost->muxing_queue))
    2970        5217 :             ost->mux_timebase = ost->st->time_base;
    2971             : 
    2972       10846 :         while (av_fifo_size(ost->muxing_queue)) {
    2973             :             AVPacket pkt;
    2974         270 :             av_fifo_generic_read(ost->muxing_queue, &pkt, sizeof(pkt), NULL);
    2975         270 :             write_packet(of, &pkt, ost);
    2976             :         }
    2977             :     }
    2978             : 
    2979        5156 :     return 0;
    2980             : }
    2981             : 
    2982        5288 : static int init_output_bsfs(OutputStream *ost)
    2983             : {
    2984             :     AVBSFContext *ctx;
    2985             :     int i, ret;
    2986             : 
    2987        5288 :     if (!ost->nb_bitstream_filters)
    2988        5281 :         return 0;
    2989             : 
    2990          14 :     for (i = 0; i < ost->nb_bitstream_filters; i++) {
    2991           7 :         ctx = ost->bsf_ctx[i];
    2992             : 
    2993          14 :         ret = avcodec_parameters_copy(ctx->par_in,
    2994           7 :                                       i ? ost->bsf_ctx[i - 1]->par_out : ost->st->codecpar);
    2995           7 :         if (ret < 0)
    2996           0 :             return ret;
    2997             : 
    2998           7 :         ctx->time_base_in = i ? ost->bsf_ctx[i - 1]->time_base_out : ost->st->time_base;
    2999             : 
    3000           7 :         ret = av_bsf_init(ctx);
    3001           7 :         if (ret < 0) {
    3002           0 :             av_log(NULL, AV_LOG_ERROR, "Error initializing bitstream filter: %s\n",
    3003           0 :                    ost->bsf_ctx[i]->filter->name);
    3004           0 :             return ret;
    3005             :         }
    3006             :     }
    3007             : 
    3008           7 :     ctx = ost->bsf_ctx[ost->nb_bitstream_filters - 1];
    3009           7 :     ret = avcodec_parameters_copy(ost->st->codecpar, ctx->par_out);
    3010           7 :     if (ret < 0)
    3011           0 :         return ret;
    3012             : 
    3013           7 :     ost->st->time_base = ctx->time_base_out;
    3014             : 
    3015           7 :     return 0;
    3016             : }
    3017             : 
    3018         175 : static int init_output_stream_streamcopy(OutputStream *ost)
    3019             : {
    3020         175 :     OutputFile *of = output_files[ost->file_index];
    3021         175 :     InputStream *ist = get_input_stream(ost);
    3022         175 :     AVCodecParameters *par_dst = ost->st->codecpar;
    3023         175 :     AVCodecParameters *par_src = ost->ref_par;
    3024             :     AVRational sar;
    3025             :     int i, ret;
    3026         175 :     uint32_t codec_tag = par_dst->codec_tag;
    3027             : 
    3028         175 :     av_assert0(ist && !ost->filter);
    3029             : 
    3030         175 :     ret = avcodec_parameters_to_context(ost->enc_ctx, ist->st->codecpar);
    3031         175 :     if (ret >= 0)
    3032         175 :         ret = av_opt_set_dict(ost->enc_ctx, &ost->encoder_opts);
    3033         175 :     if (ret < 0) {
    3034           0 :         av_log(NULL, AV_LOG_FATAL,
    3035             :                "Error setting up codec context options.\n");
    3036           0 :         return ret;
    3037             :     }
    3038         175 :     avcodec_parameters_from_context(par_src, ost->enc_ctx);
    3039             : 
    3040         175 :     if (!codec_tag) {
    3041             :         unsigned int codec_tag_tmp;
    3042         199 :         if (!of->ctx->oformat->codec_tag ||
    3043          37 :             av_codec_get_id (of->ctx->oformat->codec_tag, par_src->codec_tag) == par_src->codec_id ||
    3044          13 :             !av_codec_get_tag2(of->ctx->oformat->codec_tag, par_src->codec_id, &codec_tag_tmp))
    3045         165 :             codec_tag = par_src->codec_tag;
    3046             :     }
    3047             : 
    3048         175 :     ret = avcodec_parameters_copy(par_dst, par_src);
    3049         175 :     if (ret < 0)
    3050           0 :         return ret;
    3051             : 
    3052         175 :     par_dst->codec_tag = codec_tag;
    3053             : 
    3054         175 :     if (!ost->frame_rate.num)
    3055         175 :         ost->frame_rate = ist->framerate;
    3056         175 :     ost->st->avg_frame_rate = ost->frame_rate;
    3057             : 
    3058         175 :     ret = avformat_transfer_internal_stream_timing_info(of->ctx->oformat, ost->st, ist->st, copy_tb);
    3059         175 :     if (ret < 0)
    3060           0 :         return ret;
    3061             : 
    3062             :     // copy timebase while removing common factors
    3063         175 :     if (ost->st->time_base.num <= 0 || ost->st->time_base.den <= 0)
    3064         175 :         ost->st->time_base = av_add_q(av_stream_get_codec_timebase(ost->st), (AVRational){0, 1});
    3065             : 
    3066             :     // copy estimated duration as a hint to the muxer
    3067         175 :     if (ost->st->duration <= 0 && ist->st->duration > 0)
    3068         119 :         ost->st->duration = av_rescale_q(ist->st->duration, ist->st->time_base, ost->st->time_base);
    3069             : 
    3070             :     // copy disposition
    3071         175 :     ost->st->disposition = ist->st->disposition;
    3072             : 
    3073         175 :     if (ist->st->nb_side_data) {
    3074           6 :         for (i = 0; i < ist->st->nb_side_data; i++) {
    3075           3 :             const AVPacketSideData *sd_src = &ist->st->side_data[i];
    3076             :             uint8_t *dst_data;
    3077             : 
    3078           3 :             dst_data = av_stream_new_side_data(ost->st, sd_src->type, sd_src->size);
    3079           3 :             if (!dst_data)
    3080           0 :                 return AVERROR(ENOMEM);
    3081           3 :             memcpy(dst_data, sd_src->data, sd_src->size);
    3082             :         }
    3083             :     }
    3084             : 
    3085         175 :     if (ost->rotate_overridden) {
    3086           1 :         uint8_t *sd = av_stream_new_side_data(ost->st, AV_PKT_DATA_DISPLAYMATRIX,
    3087             :                                               sizeof(int32_t) * 9);
    3088           1 :         if (sd)
    3089           1 :             av_display_rotation_set((int32_t *)sd, -ost->rotate_override_value);
    3090             :     }
    3091             : 
    3092         175 :     ost->parser = av_parser_init(par_dst->codec_id);
    3093         175 :     ost->parser_avctx = avcodec_alloc_context3(NULL);
    3094         175 :     if (!ost->parser_avctx)
    3095           0 :         return AVERROR(ENOMEM);
    3096             : 
    3097         175 :     switch (par_dst->codec_type) {
    3098             :     case AVMEDIA_TYPE_AUDIO:
    3099          83 :         if (audio_volume != 256) {
    3100           0 :             av_log(NULL, AV_LOG_FATAL, "-acodec copy and -vol are incompatible (frames are not decoded)\n");
    3101           0 :             exit_program(1);
    3102             :         }
    3103          83 :         if((par_dst->block_align == 1 || par_dst->block_align == 1152 || par_dst->block_align == 576) && par_dst->codec_id == AV_CODEC_ID_MP3)
    3104           0 :             par_dst->block_align= 0;
    3105          83 :         if(par_dst->codec_id == AV_CODEC_ID_AC3)
    3106           2 :             par_dst->block_align= 0;
    3107          83 :         break;
    3108             :     case AVMEDIA_TYPE_VIDEO:
    3109          77 :         if (ost->frame_aspect_ratio.num) { // overridden by the -aspect cli option
    3110           0 :             sar =
    3111             :                 av_mul_q(ost->frame_aspect_ratio,
    3112           0 :                          (AVRational){ par_dst->height, par_dst->width });
    3113           0 :             av_log(NULL, AV_LOG_WARNING, "Overriding aspect ratio "
    3114             :                    "with stream copy may produce invalid files\n");
    3115             :             }
    3116          77 :         else if (ist->st->sample_aspect_ratio.num)
    3117          27 :             sar = ist->st->sample_aspect_ratio;
    3118             :         else
    3119          50 :             sar = par_src->sample_aspect_ratio;
    3120          77 :         ost->st->sample_aspect_ratio = par_dst->sample_aspect_ratio = sar;
    3121          77 :         ost->st->avg_frame_rate = ist->st->avg_frame_rate;
    3122          77 :         ost->st->r_frame_rate = ist->st->r_frame_rate;
    3123          77 :         break;
    3124             :     }
    3125             : 
    3126         175 :     ost->mux_timebase = ist->st->time_base;
    3127             : 
    3128         175 :     return 0;
    3129             : }
    3130             : 
    3131        5112 : static void set_encoder_id(OutputFile *of, OutputStream *ost)
    3132             : {
    3133             :     AVDictionaryEntry *e;
    3134             : 
    3135             :     uint8_t *encoder_string;
    3136             :     int encoder_string_len;
    3137        5112 :     int format_flags = 0;
    3138        5112 :     int codec_flags = 0;
    3139             : 
    3140        5112 :     if (av_dict_get(ost->st->metadata, "encoder",  NULL, 0))
    3141           0 :         return;
    3142             : 
    3143        5112 :     e = av_dict_get(of->opts, "fflags", NULL, 0);
    3144        5112 :     if (e) {
    3145        4320 :         const AVOption *o = av_opt_find(of->ctx, "fflags", NULL, 0, 0);
    3146        4320 :         if (!o)
    3147           0 :             return;
    3148        4320 :         av_opt_eval_flags(of->ctx, o, e->value, &format_flags);
    3149             :     }
    3150        5112 :     e = av_dict_get(ost->encoder_opts, "flags", NULL, 0);
    3151        5112 :     if (e) {
    3152        4280 :         const AVOption *o = av_opt_find(ost->enc_ctx, "flags", NULL, 0, 0);
    3153        4280 :         if (!o)
    3154           0 :             return;
    3155        4280 :         av_opt_eval_flags(ost->enc_ctx, o, e->value, &codec_flags);
    3156             :     }
    3157             : 
    3158        5112 :     encoder_string_len = sizeof(LIBAVCODEC_IDENT) + strlen(ost->enc->name) + 2;
    3159        5112 :     encoder_string     = av_mallocz(encoder_string_len);
    3160        5112 :     if (!encoder_string)
    3161           0 :         exit_program(1);
    3162             : 
    3163        5112 :     if (!(format_flags & AVFMT_FLAG_BITEXACT) && !(codec_flags & AV_CODEC_FLAG_BITEXACT))
    3164         784 :         av_strlcpy(encoder_string, LIBAVCODEC_IDENT " ", encoder_string_len);
    3165             :     else
    3166        4328 :         av_strlcpy(encoder_string, "Lavc ", encoder_string_len);
    3167        5112 :     av_strlcat(encoder_string, ost->enc->name, encoder_string_len);
    3168        5112 :     av_dict_set(&ost->st->metadata, "encoder",  encoder_string,
    3169             :                 AV_DICT_DONT_STRDUP_VAL | AV_DICT_DONT_OVERWRITE);
    3170             : }
    3171             : 
    3172           1 : static void parse_forced_key_frames(char *kf, OutputStream *ost,
    3173             :                                     AVCodecContext *avctx)
    3174             : {
    3175             :     char *p;
    3176           1 :     int n = 1, i, size, index = 0;
    3177             :     int64_t t, *pts;
    3178             : 
    3179          14 :     for (p = kf; *p; p++)
    3180          13 :         if (*p == ',')
    3181           1 :             n++;
    3182           1 :     size = n;
    3183           1 :     pts = av_malloc_array(size, sizeof(*pts));
    3184           1 :     if (!pts) {
    3185           0 :         av_log(NULL, AV_LOG_FATAL, "Could not allocate forced key frames array.\n");
    3186           0 :         exit_program(1);
    3187             :     }
    3188             : 
    3189           1 :     p = kf;
    3190           3 :     for (i = 0; i < n; i++) {
    3191           2 :         char *next = strchr(p, ',');
    3192             : 
    3193           2 :         if (next)
    3194           1 :             *next++ = 0;
    3195             : 
    3196           2 :         if (!memcmp(p, "chapters", 8)) {
    3197             : 
    3198           0 :             AVFormatContext *avf = output_files[ost->file_index]->ctx;
    3199             :             int j;
    3200             : 
    3201           0 :             if (avf->nb_chapters > INT_MAX - size ||
    3202           0 :                 !(pts = av_realloc_f(pts, size += avf->nb_chapters - 1,
    3203             :                                      sizeof(*pts)))) {
    3204           0 :                 av_log(NULL, AV_LOG_FATAL,
    3205             :                        "Could not allocate forced key frames array.\n");
    3206           0 :                 exit_program(1);
    3207             :             }
    3208           0 :             t = p[8] ? parse_time_or_die("force_key_frames", p + 8, 1) : 0;
    3209           0 :             t = av_rescale_q(t, AV_TIME_BASE_Q, avctx->time_base);
    3210             : 
    3211           0 :             for (j = 0; j < avf->nb_chapters; j++) {
    3212           0 :                 AVChapter *c = avf->chapters[j];
    3213             :                 av_assert1(index < size);
    3214           0 :                 pts[index++] = av_rescale_q(c->start, c->time_base,
    3215           0 :                                             avctx->time_base) + t;
    3216             :             }
    3217             : 
    3218             :         } else {
    3219             : 
    3220           2 :             t = parse_time_or_die("force_key_frames", p, 1);
    3221             :             av_assert1(index < size);
    3222           2 :             pts[index++] = av_rescale_q(t, AV_TIME_BASE_Q, avctx->time_base);
    3223             : 
    3224             :         }
    3225             : 
    3226           2 :         p = next;
    3227             :     }
    3228             : 
    3229           1 :     av_assert0(index == size);
    3230           1 :     qsort(pts, size, sizeof(*pts), compare_int64);
    3231           1 :     ost->forced_kf_count = size;
    3232           1 :     ost->forced_kf_pts   = pts;
    3233           1 : }
    3234             : 
    3235        5112 : static int init_output_stream_encode(OutputStream *ost)
    3236             : {
    3237        5112 :     InputStream *ist = get_input_stream(ost);
    3238        5112 :     AVCodecContext *enc_ctx = ost->enc_ctx;
    3239        5112 :     AVCodecContext *dec_ctx = NULL;
    3240        5112 :     AVFormatContext *oc = output_files[ost->file_index]->ctx;
    3241             :     int j, ret;
    3242             : 
    3243        5112 :     set_encoder_id(output_files[ost->file_index], ost);
    3244             : 
    3245             :     // Muxers use AV_PKT_DATA_DISPLAYMATRIX to signal rotation. On the other
    3246             :     // hand, the legacy API makes demuxers set "rotate" metadata entries,
    3247             :     // which have to be filtered out to prevent leaking them to output files.
    3248        5112 :     av_dict_set(&ost->st->metadata, "rotate", NULL, 0);
    3249             : 
    3250        5112 :     if (ist) {
    3251        5082 :         ost->st->disposition          = ist->st->disposition;
    3252             : 
    3253        5082 :         dec_ctx = ist->dec_ctx;
    3254             : 
    3255        5082 :         enc_ctx->chroma_sample_location = dec_ctx->chroma_sample_location;
    3256             :     } else {
    3257          64 :         for (j = 0; j < oc->nb_streams; j++) {
    3258          34 :             AVStream *st = oc->streams[j];
    3259          34 :             if (st != ost->st && st->codecpar->codec_type == ost->st->codecpar->codec_type)
    3260           0 :                 break;
    3261             :         }
    3262          30 :         if (j == oc->nb_streams)
    3263          53 :             if (ost->st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO ||
    3264          23 :                 ost->st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO)
    3265          30 :                 ost->st->disposition = AV_DISPOSITION_DEFAULT;
    3266             :     }
    3267             : 
    3268        5112 :     if (enc_ctx->codec_type == AVMEDIA_TYPE_VIDEO) {
    3269        4032 :         if (!ost->frame_rate.num)
    3270        4015 :             ost->frame_rate = av_buffersink_get_frame_rate(ost->filter->filter);
    3271        4032 :         if (ist && !ost->frame_rate.num)
    3272           0 :             ost->frame_rate = ist->framerate;
    3273        4032 :         if (ist && !ost->frame_rate.num)
    3274           0 :             ost->frame_rate = ist->st->r_frame_rate;
    3275        4032 :         if (ist && !ost->frame_rate.num) {
    3276           0 :             ost->frame_rate = (AVRational){25, 1};
    3277           0 :             av_log(NULL, AV_LOG_WARNING,
    3278             :                    "No information "
    3279             :                    "about the input framerate is available. Falling "
    3280             :                    "back to a default value of 25fps for output stream #%d:%d. Use the -r option "
    3281             :                    "if you want a different framerate.\n",
    3282             :                    ost->file_index, ost->index);
    3283             :         }
    3284             : //      ost->frame_rate = ist->st->avg_frame_rate.num ? ist->st->avg_frame_rate : (AVRational){25, 1};
    3285        4032 :         if (ost->enc->supported_framerates && !ost->force_fps) {
    3286          49 :             int idx = av_find_nearest_q_idx(ost->frame_rate, ost->enc->supported_framerates);
    3287          49 :             ost->frame_rate = ost->enc->supported_framerates[idx];
    3288             :         }
    3289             :         // reduce frame rate for mpeg4 to be within the spec limits
    3290        4032 :         if (enc_ctx->codec_id == AV_CODEC_ID_MPEG4) {
    3291         116 :             av_reduce(&ost->frame_rate.num, &ost->frame_rate.den,
    3292         116 :                       ost->frame_rate.num, ost->frame_rate.den, 65535);
    3293             :         }
    3294             :     }
    3295             : 
    3296        5112 :     switch (enc_ctx->codec_type) {
    3297             :     case AVMEDIA_TYPE_AUDIO:
    3298        1052 :         enc_ctx->sample_fmt     = av_buffersink_get_format(ost->filter->filter);
    3299        1052 :         if (dec_ctx)
    3300        1045 :             enc_ctx->bits_per_raw_sample = FFMIN(dec_ctx->bits_per_raw_sample,
    3301             :                                                  av_get_bytes_per_sample(enc_ctx->sample_fmt) << 3);
    3302        1052 :         enc_ctx->sample_rate    = av_buffersink_get_sample_rate(ost->filter->filter);
    3303        1052 :         enc_ctx->channel_layout = av_buffersink_get_channel_layout(ost->filter->filter);
    3304        1052 :         enc_ctx->channels       = av_buffersink_get_channels(ost->filter->filter);
    3305        1052 :         enc_ctx->time_base      = (AVRational){ 1, enc_ctx->sample_rate };
    3306        1052 :         break;
    3307             :     case AVMEDIA_TYPE_VIDEO:
    3308        4032 :         enc_ctx->time_base = av_inv_q(ost->frame_rate);
    3309        4032 :         if (!(enc_ctx->time_base.num && enc_ctx->time_base.den))
    3310           0 :             enc_ctx->time_base = av_buffersink_get_time_base(ost->filter->filter);
    3311        4032 :         if (   av_q2d(enc_ctx->time_base) < 0.001 && video_sync_method != VSYNC_PASSTHROUGH
    3312           2 :            && (video_sync_method == VSYNC_CFR || video_sync_method == VSYNC_VSCFR || (video_sync_method == VSYNC_AUTO && !(oc->oformat->flags & AVFMT_VARIABLE_FPS)))){
    3313           0 :             av_log(oc, AV_LOG_WARNING, "Frame rate very high for a muxer not efficiently supporting it.\n"
    3314             :                                        "Please consider specifying a lower framerate, a different muxer or -vsync 2\n");
    3315             :         }
    3316        4032 :         for (j = 0; j < ost->forced_kf_count; j++)
    3317           0 :             ost->forced_kf_pts[j] = av_rescale_q(ost->forced_kf_pts[j],
    3318           0 :                                                  AV_TIME_BASE_Q,
    3319             :                                                  enc_ctx->time_base);
    3320             : 
    3321        4032 :         enc_ctx->width  = av_buffersink_get_w(ost->filter->filter);
    3322        4032 :         enc_ctx->height = av_buffersink_get_h(ost->filter->filter);
    3323        8064 :         enc_ctx->sample_aspect_ratio = ost->st->sample_aspect_ratio =
    3324        4032 :             ost->frame_aspect_ratio.num ? // overridden by the -aspect cli option
    3325        8064 :             av_mul_q(ost->frame_aspect_ratio, (AVRational){ enc_ctx->height, enc_ctx->width }) :
    3326        4032 :             av_buffersink_get_sample_aspect_ratio(ost->filter->filter);
    3327        4032 :         if (!strncmp(ost->enc->name, "libx264", 7) &&
    3328           0 :             enc_ctx->pix_fmt == AV_PIX_FMT_NONE &&
    3329           0 :             av_buffersink_get_format(ost->filter->filter) != AV_PIX_FMT_YUV420P)
    3330           0 :             av_log(NULL, AV_LOG_WARNING,
    3331             :                    "No pixel format specified, %s for H.264 encoding chosen.\n"
    3332             :                    "Use -pix_fmt yuv420p for compatibility with outdated media players.\n",
    3333           0 :                    av_get_pix_fmt_name(av_buffersink_get_format(ost->filter->filter)));
    3334        4069 :         if (!strncmp(ost->enc->name, "mpeg2video", 10) &&
    3335          69 :             enc_ctx->pix_fmt == AV_PIX_FMT_NONE &&
    3336          32 :             av_buffersink_get_format(ost->filter->filter) != AV_PIX_FMT_YUV420P)
    3337           0 :             av_log(NULL, AV_LOG_WARNING,
    3338             :                    "No pixel format specified, %s for MPEG-2 encoding chosen.\n"
    3339             :                    "Use -pix_fmt yuv420p for compatibility with outdated media players.\n",
    3340           0 :                    av_get_pix_fmt_name(av_buffersink_get_format(ost->filter->filter)));
    3341        4032 :         enc_ctx->pix_fmt = av_buffersink_get_format(ost->filter->filter);
    3342        4032 :         if (dec_ctx)
    3343        4009 :             enc_ctx->bits_per_raw_sample = FFMIN(dec_ctx->bits_per_raw_sample,
    3344             :                                                  av_pix_fmt_desc_get(enc_ctx->pix_fmt)->comp[0].depth);
    3345             : 
    3346        4032 :         enc_ctx->framerate = ost->frame_rate;
    3347             : 
    3348        4032 :         ost->st->avg_frame_rate = ost->frame_rate;
    3349             : 
    3350        8041 :         if (!dec_ctx ||
    3351        7441 :             enc_ctx->width   != dec_ctx->width  ||
    3352        6688 :             enc_ctx->height  != dec_ctx->height ||
    3353        3256 :             enc_ctx->pix_fmt != dec_ctx->pix_fmt) {
    3354        2531 :             enc_ctx->bits_per_raw_sample = frame_bits_per_raw_sample;
    3355             :         }
    3356             : 
    3357        4032 :         if (ost->forced_keyframes) {
    3358           1 :             if (!strncmp(ost->forced_keyframes, "expr:", 5)) {
    3359           0 :                 ret = av_expr_parse(&ost->forced_keyframes_pexpr, ost->forced_keyframes+5,
    3360             :                                     forced_keyframes_const_names, NULL, NULL, NULL, NULL, 0, NULL);
    3361           0 :                 if (ret < 0) {
    3362           0 :                     av_log(NULL, AV_LOG_ERROR,
    3363           0 :                            "Invalid force_key_frames expression '%s'\n", ost->forced_keyframes+5);
    3364           0 :                     return ret;
    3365             :                 }
    3366           0 :                 ost->forced_keyframes_expr_const_values[FKF_N] = 0;
    3367           0 :                 ost->forced_keyframes_expr_const_values[FKF_N_FORCED] = 0;
    3368           0 :                 ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_N] = NAN;
    3369           0 :                 ost->forced_keyframes_expr_const_values[FKF_PREV_FORCED_T] = NAN;
    3370             : 
    3371             :             // Don't parse the 'forced_keyframes' in case of 'keep-source-keyframes',
    3372             :             // parse it only for static kf timings
    3373           1 :             } else if(strncmp(ost->forced_keyframes, "source", 6)) {
    3374           1 :                 parse_forced_key_frames(ost->forced_keyframes, ost, ost->enc_ctx);
    3375             :             }
    3376             :         }
    3377        4032 :         break;
    3378             :     case AVMEDIA_TYPE_SUBTITLE:
    3379          28 :         enc_ctx->time_base = AV_TIME_BASE_Q;
    3380          28 :         if (!enc_ctx->width) {
    3381          28 :             enc_ctx->width     = input_streams[ost->source_index]->st->codecpar->width;
    3382          28 :             enc_ctx->height    = input_streams[ost->source_index]->st->codecpar->height;
    3383             :         }
    3384          28 :         break;
    3385             :     case AVMEDIA_TYPE_DATA:
    3386           0 :         break;
    3387             :     default:
    3388           0 :         abort();
    3389             :         break;
    3390             :     }
    3391             : 
    3392        5112 :     ost->mux_timebase = enc_ctx->time_base;
    3393             : 
    3394        5112 :     return 0;
    3395             : }
    3396             : 
    3397        5288 : static int init_output_stream(OutputStream *ost, char *error, int error_len)
    3398             : {
    3399        5288 :     int ret = 0;
    3400             : 
    3401        5288 :     if (ost->encoding_needed) {
    3402        5112 :         AVCodec      *codec = ost->enc;
    3403        5112 :         AVCodecContext *dec = NULL;
    3404             :         InputStream *ist;
    3405             : 
    3406        5112 :         ret = init_output_stream_encode(ost);
    3407        5112 :         if (ret < 0)
    3408           0 :             return ret;
    3409             : 
    3410        5112 :         if ((ist = get_input_stream(ost)))
    3411        5082 :             dec = ist->dec_ctx;
    3412        5112 :         if (dec && dec->subtitle_header) {
    3413             :             /* ASS code assumes this buffer is null terminated so add extra byte. */
    3414          27 :             ost->enc_ctx->subtitle_header = av_mallocz(dec->subtitle_header_size + 1);
    3415          27 :             if (!ost->enc_ctx->subtitle_header)
    3416           0 :                 return AVERROR(ENOMEM);
    3417          27 :             memcpy(ost->enc_ctx->subtitle_header, dec->subtitle_header, dec->subtitle_header_size);
    3418          27 :             ost->enc_ctx->subtitle_header_size = dec->subtitle_header_size;
    3419             :         }
    3420        5112 :         if (!av_dict_get(ost->encoder_opts, "threads", NULL, 0))
    3421        2293 :             av_dict_set(&ost->encoder_opts, "threads", "auto", 0);
    3422        6164 :         if (ost->enc->type == AVMEDIA_TYPE_AUDIO &&
    3423        2065 :             !codec->defaults &&
    3424        1963 :             !av_dict_get(ost->encoder_opts, "b", NULL, 0) &&
    3425         950 :             !av_dict_get(ost->encoder_opts, "ab", NULL, 0))
    3426         950 :             av_dict_set(&ost->encoder_opts, "b", "128000", 0);
    3427             : 
    3428        5112 :         if (ost->filter && av_buffersink_get_hw_frames_ctx(ost->filter->filter) &&
    3429           0 :             ((AVHWFramesContext*)av_buffersink_get_hw_frames_ctx(ost->filter->filter)->data)->format ==
    3430           0 :             av_buffersink_get_format(ost->filter->filter)) {
    3431           0 :             ost->enc_ctx->hw_frames_ctx = av_buffer_ref(av_buffersink_get_hw_frames_ctx(ost->filter->filter));
    3432           0 :             if (!ost->enc_ctx->hw_frames_ctx)
    3433           0 :                 return AVERROR(ENOMEM);
    3434             :         }
    3435             : 
    3436        5112 :         if ((ret = avcodec_open2(ost->enc_ctx, codec, &ost->encoder_opts)) < 0) {
    3437           0 :             if (ret == AVERROR_EXPERIMENTAL)
    3438           0 :                 abort_codec_experimental(codec, 1);
    3439           0 :             snprintf(error, error_len,
    3440             :                      "Error while opening encoder for output stream #%d:%d - "
    3441             :                      "maybe incorrect parameters such as bit_rate, rate, width or height",
    3442             :                     ost->file_index, ost->index);
    3443           0 :             return ret;
    3444             :         }
    3445        6164 :         if (ost->enc->type == AVMEDIA_TYPE_AUDIO &&
    3446        1052 :             !(ost->enc->capabilities & AV_CODEC_CAP_VARIABLE_FRAME_SIZE))
    3447          86 :             av_buffersink_set_frame_size(ost->filter->filter,
    3448          86 :                                             ost->enc_ctx->frame_size);
    3449        5112 :         assert_avoptions(ost->encoder_opts);
    3450        5112 :         if (ost->enc_ctx->bit_rate && ost->enc_ctx->bit_rate < 1000)
    3451           0 :             av_log(NULL, AV_LOG_WARNING, "The bitrate parameter is set too low."
    3452             :                                          " It takes bits/s as argument, not kbits/s\n");
    3453             : 
    3454        5112 :         ret = avcodec_parameters_from_context(ost->st->codecpar, ost->enc_ctx);
    3455        5112 :         if (ret < 0) {
    3456           0 :             av_log(NULL, AV_LOG_FATAL,
    3457             :                    "Error initializing the output stream codec context.\n");
    3458           0 :             exit_program(1);
    3459             :         }
    3460             :         /*
    3461             :          * FIXME: ost->st->codec should't be needed here anymore.
    3462             :          */
    3463        5112 :         ret = avcodec_copy_context(ost->st->codec, ost->enc_ctx);
    3464        5112 :         if (ret < 0)
    3465           0 :             return ret;
    3466             : 
    3467        5112 :         if (ost->enc_ctx->nb_coded_side_data) {
    3468             :             int i;
    3469             : 
    3470         366 :             for (i = 0; i < ost->enc_ctx->nb_coded_side_data; i++) {
    3471         183 :                 const AVPacketSideData *sd_src = &ost->enc_ctx->coded_side_data[i];
    3472             :                 uint8_t *dst_data;
    3473             : 
    3474         183 :                 dst_data = av_stream_new_side_data(ost->st, sd_src->type, sd_src->size);
    3475         183 :                 if (!dst_data)
    3476           0 :                     return AVERROR(ENOMEM);
    3477         183 :                 memcpy(dst_data, sd_src->data, sd_src->size);
    3478             :             }
    3479             :         }
    3480             : 
    3481             :         /*
    3482             :          * Add global input side data. For now this is naive, and copies it
    3483             :          * from the input stream's global side data. All side data should
    3484             :          * really be funneled over AVFrame and libavfilter, then added back to
    3485             :          * packet side data, and then potentially using the first packet for
    3486             :          * global side data.
    3487             :          */
    3488        5112 :         if (ist) {
    3489             :             int i;
    3490        5291 :             for (i = 0; i < ist->st->nb_side_data; i++) {
    3491         209 :                 AVPacketSideData *sd = &ist->st->side_data[i];
    3492         209 :                 uint8_t *dst = av_stream_new_side_data(ost->st, sd->type, sd->size);
    3493         209 :                 if (!dst)
    3494           0 :                     return AVERROR(ENOMEM);
    3495         209 :                 memcpy(dst, sd->data, sd->size);
    3496         209 :                 if (ist->autorotate && sd->type == AV_PKT_DATA_DISPLAYMATRIX)
    3497           0 :                     av_display_rotation_set((uint32_t *)dst, 0);
    3498             :             }
    3499             :         }
    3500             : 
    3501             :         // copy timebase while removing common factors
    3502        5112 :         if (ost->st->time_base.num <= 0 || ost->st->time_base.den <= 0)
    3503        5112 :             ost->st->time_base = av_add_q(ost->enc_ctx->time_base, (AVRational){0, 1});
    3504             : 
    3505             :         // copy estimated duration as a hint to the muxer
    3506        5112 :         if (ost->st->duration <= 0 && ist && ist->st->duration > 0)
    3507        4031 :             ost->st->duration = av_rescale_q(ist->st->duration, ist->st->time_base, ost->st->time_base);
    3508             : 
    3509        5112 :         ost->st->codec->codec= ost->enc_ctx->codec;
    3510         176 :     } else if (ost->stream_copy) {
    3511         175 :         ret = init_output_stream_streamcopy(ost);
    3512         175 :         if (ret < 0)
    3513           0 :             return ret;
    3514             : 
    3515             :         /*
    3516             :          * FIXME: will the codec context used by the parser during streamcopy
    3517             :          * This should go away with the new parser API.
    3518             :          */
    3519         175 :         ret = avcodec_parameters_to_context(ost->parser_avctx, ost->st->codecpar);
    3520         175 :         if (ret < 0)
    3521           0 :             return ret;
    3522             :     }
    3523             : 
    3524             :     // parse user provided disposition, and update stream values
    3525        5288 :     if (ost->disposition) {
    3526             :         static const AVOption opts[] = {
    3527             :             { "disposition"         , NULL, 0, AV_OPT_TYPE_FLAGS, { .i64 = 0 }, INT64_MIN, INT64_MAX, .unit = "flags" },
    3528             :             { "default"             , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_DEFAULT           },    .unit = "flags" },
    3529             :             { "dub"                 , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_DUB               },    .unit = "flags" },
    3530             :             { "original"            , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_ORIGINAL          },    .unit = "flags" },
    3531             :             { "comment"             , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_COMMENT           },    .unit = "flags" },
    3532             :             { "lyrics"              , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_LYRICS            },    .unit = "flags" },
    3533             :             { "karaoke"             , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_KARAOKE           },    .unit = "flags" },
    3534             :             { "forced"              , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_FORCED            },    .unit = "flags" },
    3535             :             { "hearing_impaired"    , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_HEARING_IMPAIRED  },    .unit = "flags" },
    3536             :             { "visual_impaired"     , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_VISUAL_IMPAIRED   },    .unit = "flags" },
    3537             :             { "clean_effects"       , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_CLEAN_EFFECTS     },    .unit = "flags" },
    3538             :             { "captions"            , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_CAPTIONS          },    .unit = "flags" },
    3539             :             { "descriptions"        , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_DESCRIPTIONS      },    .unit = "flags" },
    3540             :             { "metadata"            , NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AV_DISPOSITION_METADATA          },    .unit = "flags" },
    3541             :             { NULL },
    3542             :         };
    3543             :         static const AVClass class = {
    3544             :             .class_name = "",
    3545             :             .item_name  = av_default_item_name,
    3546             :             .option     = opts,
    3547             :             .version    = LIBAVUTIL_VERSION_INT,
    3548             :         };
    3549           0 :         const AVClass *pclass = &class;
    3550             : 
    3551           0 :         ret = av_opt_eval_flags(&pclass, &opts[0], ost->disposition, &ost->st->disposition);
    3552           0 :         if (ret < 0)
    3553           0 :             return ret;
    3554             :     }
    3555             : 
    3556             :     /* initialize bitstream filters for the output stream
    3557             :      * needs to be done here, because the codec id for streamcopy is not
    3558             :      * known until now */
    3559        5288 :     ret = init_output_bsfs(ost);
    3560        5288 :     if (ret < 0)
    3561           0 :         return ret;
    3562             : 
    3563        5288 :     ost->initialized = 1;
    3564             : 
    3565        5288 :     ret = check_init_output_file(output_files[ost->file_index], ost->file_index);
    3566        5288 :     if (ret < 0)
    3567           0 :         return ret;
    3568             : 
    3569        5288 :     return ret;
    3570             : }
    3571             : 
    3572           0 : static void report_new_stream(int input_index, AVPacket *pkt)
    3573             : {
    3574           0 :     InputFile *file = input_files[input_index];
    3575           0 :     AVStream *st = file->ctx->streams[pkt->stream_index];
    3576             : 
    3577           0 :     if (pkt->stream_index < file->nb_streams_warn)
    3578           0 :         return;
    3579           0 :     av_log(file->ctx, AV_LOG_WARNING,
    3580             :            "New %s stream %d:%d at pos:%"PRId64" and DTS:%ss\n",
    3581           0 :            av_get_media_type_string(st->codecpar->codec_type),
    3582             :            input_index, pkt->stream_index,
    3583           0 :            pkt->pos, av_ts2timestr(pkt->dts, &st->time_base));
    3584           0 :     file->nb_streams_warn = pkt->stream_index + 1;
    3585             : }
    3586             : 
    3587        5155 : static int transcode_init(void)
    3588             : {
    3589        5155 :     int ret = 0, i, j, k;
    3590             :     AVFormatContext *oc;
    3591             :     OutputStream *ost;
    3592             :     InputStream *ist;
    3593        5155 :     char error[1024] = {0};
    3594             : 
    3595       10237 :     for (i = 0; i < nb_filtergraphs; i++) {
    3596        5082 :         FilterGraph *fg = filtergraphs[i];
    3597       10166 :         for (j = 0; j < fg->nb_outputs; j++) {
    3598        5084 :             OutputFilter *ofilter = fg->outputs[j];
    3599        5084 :             if (!ofilter->ost || ofilter->ost->source_index >= 0)
    3600        5038 :                 continue;
    3601          46 :             if (fg->nb_inputs != 1)
    3602          30 :                 continue;
    3603          17 :             for (k = nb_input_streams-1; k >= 0 ; k--)
    3604          17 :                 if (fg->inputs[0]->ist == input_streams[k])
    3605          16 :                     break;
    3606          16 :             ofilter->ost->source_index = k;
    3607             :         }
    3608             :     }
    3609             : 
    3610             :     /* init framerate emulation */
    3611       10369 :     for (i = 0; i < nb_input_files; i++) {
    3612        5214 :         InputFile *ifile = input_files[i];
    3613        5214 :         if (ifile->rate_emu)
    3614           0 :             for (j = 0; j < ifile->nb_streams; j++)
    3615           0 :                 input_streams[j + ifile->ist_index]->start = av_gettime_relative();
    3616             :     }
    3617             : 
    3618             :     /* init input streams */
    3619       10668 :     for (i = 0; i < nb_input_streams; i++)
    3620        5513 :         if ((ret = init_input_stream(i, error, sizeof(error))) < 0) {
    3621           0 :             for (i = 0; i < nb_output_streams; i++) {
    3622           0 :                 ost = output_streams[i];
    3623           0 :                 avcodec_close(ost->enc_ctx);
    3624             :             }
    3625           0 :             goto dump_format;
    3626             :         }
    3627             : 
    3628             :     /* open each encoder */
    3629       10443 :     for (i = 0; i < nb_output_streams; i++) {
    3630             :         // skip streams fed from filtergraphs until we have a frame for them
    3631        5288 :         if (output_streams[i]->filter)
    3632        5084 :             continue;
    3633             : 
    3634         204 :         ret = init_output_stream(output_streams[i], error, sizeof(error));
    3635         204 :         if (ret < 0)
    3636           0 :             goto dump_format;
    3637             :     }
    3638             : 
    3639             :     /* discard unused programs */
    3640       10369 :     for (i = 0; i < nb_input_files; i++) {
    3641        5214 :         InputFile *ifile = input_files[i];
    3642        5239 :         for (j = 0; j < ifile->ctx->nb_programs; j++) {
    3643          25 :             AVProgram *p = ifile->ctx->programs[j];
    3644          25 :             int discard  = AVDISCARD_ALL;
    3645             : 
    3646          25 :             for (k = 0; k < p->nb_stream_indexes; k++)
    3647          25 :                 if (!input_streams[ifile->ist_index + p->stream_index[k]]->discard) {
    3648          25 :                     discard = AVDISCARD_DEFAULT;
    3649          25 :                     break;
    3650             :                 }
    3651          25 :             p->discard = discard;
    3652             :         }
    3653             :     }
    3654             : 
    3655             :     /* write headers for files with no streams */
    3656       10311 :     for (i = 0; i < nb_output_files; i++) {
    3657        5156 :         oc = output_files[i]->ctx;
    3658        5156 :         if (oc->oformat->flags & AVFMT_NOSTREAMS && oc->nb_streams == 0) {
    3659           1 :             ret = check_init_output_file(output_files[i], i);
    3660           1 :             if (ret < 0)
    3661           0 :                 goto dump_format;
    3662             :         }
    3663             :     }
    3664             : 
    3665             :  dump_format:
    3666             :     /* dump the stream mapping */
    3667        5155 :     av_log(NULL, AV_LOG_INFO, "Stream mapping:\n");
    3668       10668 :     for (i = 0; i < nb_input_streams; i++) {
    3669        5513 :         ist = input_streams[i];
    3670             : 
    3671       10607 :         for (j = 0; j < ist->nb_filters; j++) {
    3672        5094 :             if (!filtergraph_is_simple(ist->filters[j]->graph)) {
    3673         224 :                 av_log(NULL, AV_LOG_INFO, "  Stream #%d:%d (%s) -> %s",
    3674         168 :                        ist->file_index, ist->st->index, ist->dec ? ist->dec->name : "?",
    3675          56 :                        ist->filters[j]->name);
    3676          56 :                 if (nb_filtergraphs > 1)
    3677           0 :                     av_log(NULL, AV_LOG_INFO, " (graph %d)", ist->filters[j]->graph->index);
    3678          56 :                 av_log(NULL, AV_LOG_INFO, "\n");
    3679             :             }
    3680             :         }
    3681             :     }
    3682             : 
    3683       10443 :     for (i = 0; i < nb_output_streams; i++) {
    3684        5288 :         ost = output_streams[i];
    3685             : 
    3686        5288 :         if (ost->attachment_filename) {
    3687             :             /* an attached file */
    3688           1 :             av_log(NULL, AV_LOG_INFO, "  File %s -> Stream #%d:%d\n",
    3689             :                    ost->attachment_filename, ost->file_index, ost->index);
    3690           1 :             continue;
    3691             :         }
    3692             : 
    3693        5287 :         if (ost->filter && !filtergraph_is_simple(ost->filter->graph)) {
    3694             :             /* output from a complex graph */
    3695          46 :             av_log(NULL, AV_LOG_INFO, "  %s", ost->filter->name);
    3696          46 :             if (nb_filtergraphs > 1)
    3697           0 :                 av_log(NULL, AV_LOG_INFO, " (graph %d)", ost->filter->graph->index);
    3698             : 
    3699          92 :             av_log(NULL, AV_LOG_INFO, " -> Stream #%d:%d (%s)\n", ost->file_index,
    3700          92 :                    ost->index, ost->enc ? ost->enc->name : "?");
    3701          46 :             continue;
    3702             :         }
    3703             : 
    3704       15723 :         av_log(NULL, AV_LOG_INFO, "  Stream #%d:%d -> #%d:%d",
    3705        5241 :                input_streams[ost->source_index]->file_index,
    3706        5241 :                input_streams[ost->source_index]->st->index,
    3707             :                ost->file_index,
    3708             :                ost->index);
    3709        5241 :         if (ost->sync_ist != input_streams[ost->source_index])
    3710           0 :             av_log(NULL, AV_LOG_INFO, " [sync #%d:%d]",
    3711           0 :                    ost->sync_ist->file_index,
    3712           0 :                    ost->sync_ist->st->index);
    3713        5241 :         if (ost->stream_copy)
    3714         175 :             av_log(NULL, AV_LOG_INFO, " (copy)");
    3715             :         else {
    3716        5066 :             const AVCodec *in_codec    = input_streams[ost->source_index]->dec;
    3717        5066 :             const AVCodec *out_codec   = ost->enc;
    3718        5066 :             const char *decoder_name   = "?";
    3719        5066 :             const char *in_codec_name  = "?";
    3720        5066 :             const char *encoder_name   = "?";
    3721        5066 :             const char *out_codec_name = "?";
    3722             :             const AVCodecDescriptor *desc;
    3723             : 
    3724        5066 :             if (in_codec) {
    3725        5066 :                 decoder_name  = in_codec->name;
    3726        5066 :                 desc = avcodec_descriptor_get(in_codec->id);
    3727        5066 :                 if (desc)
    3728        5066 :                     in_codec_name = desc->name;
    3729        5066 :                 if (!strcmp(decoder_name, in_codec_name))
    3730        4915 :                     decoder_name = "native";
    3731             :             }
    3732             : 
    3733        5066 :             if (out_codec) {
    3734        5066 :                 encoder_name   = out_codec->name;
    3735        5066 :                 desc = avcodec_descriptor_get(out_codec->id);
    3736        5066 :                 if (desc)
    3737        5066 :                     out_codec_name = desc->name;
    3738        5066 :                 if (!strcmp(encoder_name, out_codec_name))
    3739        4980 :                     encoder_name = "native";
    3740             :             }
    3741             : 
    3742        5066 :             av_log(NULL, AV_LOG_INFO, " (%s (%s) -> %s (%s))",
    3743             :                    in_codec_name, decoder_name,
    3744             :                    out_codec_name, encoder_name);
    3745             :         }
    3746        5241 :         av_log(NULL, AV_LOG_INFO, "\n");
    3747             :     }
    3748             : 
    3749        5155 :     if (ret) {
    3750           0 :         av_log(NULL, AV_LOG_ERROR, "%s\n", error);
    3751           0 :         return ret;
    3752             :     }
    3753             : 
    3754        5155 :     atomic_store(&transcode_init_done, 1);
    3755             : 
    3756        5155 :     return 0;
    3757             : }
    3758             : 
    3759             : /* Return 1 if there remain streams where more output is wanted, 0 otherwise. */
    3760     2662978 : static int need_output(void)
    3761             : {
    3762             :     int i;
    3763             : 
    3764     2668428 :     for (i = 0; i < nb_output_streams; i++) {
    3765     2663273 :         OutputStream *ost    = output_streams[i];
    3766     2663273 :         OutputFile *of       = output_files[ost->file_index];
    3767     2663273 :         AVFormatContext *os  = output_files[ost->file_index]->ctx;
    3768             : 
    3769     5322998 :         if (ost->finished ||
    3770     5316067 :             (os->pb && avio_tell(os->pb) >= of->limit_filesize))
    3771        3548 :             continue;
    3772     2659725 :         if (ost->frame_number >= ost->max_frames) {
    3773             :             int j;
    3774        3806 :             for (j = 0; j < of->ctx->nb_streams; j++)
    3775        1904 :                 close_output_stream(output_streams[of->ost_index + j]);
    3776        1902 :             continue;
    3777             :         }
    3778             : 
    3779     2657823 :         return 1;
    3780             :     }
    3781             : 
    3782        5155 :     return 0;
    3783             : }
    3784             : 
    3785             : /**
    3786             :  * Select the output stream to process.
    3787             :  *
    3788             :  * @return  selected output stream, or NULL if none available
    3789             :  */
    3790     2657823 : static OutputStream *choose_output(void)
    3791             : {
    3792             :     int i;
    3793     2657823 :     int64_t opts_min = INT64_MAX;
    3794     2657823 :     OutputStream *ost_min = NULL;
    3795             : 
    3796     3054090 :     for (i = 0; i < nb_output_streams; i++) {
    3797     2670862 :         OutputStream *ost = output_streams[i];
    3798     3065216 :         int64_t opts = ost->st->cur_dts == AV_NOPTS_VALUE ? INT64_MIN :
    3799      394354 :                        av_rescale_q(ost->st->cur_dts, ost->st->time_base,
    3800      394354 :                                     AV_TIME_BASE_Q);
    3801     2670862 :         if (ost->st->cur_dts == AV_NOPTS_VALUE)
    3802     2276508 :             av_log(NULL, AV_LOG_DEBUG, "cur_dts is invalid (this is harmless if it occurs once at the start per stream)\n");
    3803             : 
    3804     2670862 :         if (!ost->initialized && !ost->inputs_done)
    3805     2274595 :             return ost;
    3806             : 
    3807      396267 :         if (!ost->finished && opts < opts_min) {
    3808      387899 :             opts_min = opts;
    3809      387899 :             ost_min  = ost->unavailable ? NULL : ost;
    3810             :         }
    3811             :     }
    3812      383228 :     return ost_min;
    3813             : }
    3814             : 
    3815           0 : static void set_tty_echo(int on)
    3816             : {
    3817             : #if HAVE_TERMIOS_H
    3818             :     struct termios tty;
    3819           0 :     if (tcgetattr(0, &tty) == 0) {
    3820           0 :         if (on) tty.c_lflag |= ECHO;
    3821           0 :         else    tty.c_lflag &= ~ECHO;
    3822           0 :         tcsetattr(0, TCSANOW, &tty);
    3823             :     }
    3824             : #endif
    3825           0 : }
    3826             : 
    3827        3269 : static int check_keyboard_interaction(int64_t cur_time)
    3828             : {
    3829             :     int i, ret, key;
    3830             :     static int64_t last_time;
    3831        3269 :     if (received_nb_signals)
    3832           0 :         return AVERROR_EXIT;
    3833             :     /* read_key() returns 0 on EOF */
    3834        3269 :     if(cur_time - last_time >= 100000 && !run_as_daemon){
    3835          23 :         key =  read_key();
    3836          23 :         last_time = cur_time;
    3837             :     }else
    3838        3246 :         key = -1;
    3839        3269 :     if (key == 'q')
    3840           0 :         return AVERROR_EXIT;
    3841        3269 :     if (key == '+') av_log_set_level(av_log_get_level()+10);
    3842        3269 :     if (key == '-') av_log_set_level(av_log_get_level()-10);
    3843        3269 :     if (key == 's') qp_hist     ^= 1;
    3844        3269 :     if (key == 'h'){
    3845           0 :         if (do_hex_dump){
    3846           0 :             do_hex_dump = do_pkt_dump = 0;
    3847           0 :         } else if(do_pkt_dump){
    3848           0 :             do_hex_dump = 1;
    3849             :         } else
    3850           0 :             do_pkt_dump = 1;
    3851           0 :         av_log_set_level(AV_LOG_DEBUG);
    3852             :     }
    3853        3269 :     if (key == 'c' || key == 'C'){
    3854           0 :         char buf[4096], target[64], command[256], arg[256] = {0};
    3855             :         double time;
    3856           0 :         int k, n = 0;
    3857           0 :         fprintf(stderr, "\nEnter command: <target>|all <time>|-1 <command>[ <argument>]\n");
    3858           0 :         i = 0;
    3859           0 :         set_tty_echo(1);
    3860           0 :         while ((k = read_key()) != '\n' && k != '\r' && i < sizeof(buf)-1)
    3861           0 :             if (k > 0)
    3862           0 :                 buf[i++] = k;
    3863           0 :         buf[i] = 0;
    3864           0 :         set_tty_echo(0);
    3865           0 :         fprintf(stderr, "\n");
    3866           0 :         if (k > 0 &&
    3867             :             (n = sscanf(buf, "%63[^ ] %lf %255[^ ] %255[^\n]", target, &time, command, arg)) >= 3) {
    3868           0 :             av_log(NULL, AV_LOG_DEBUG, "Processing command target:%s time:%f command:%s arg:%s",
    3869             :                    target, time, command, arg);
    3870           0 :             for (i = 0; i < nb_filtergraphs; i++) {
    3871           0 :                 FilterGraph *fg = filtergraphs[i];
    3872           0 :                 if (fg->graph) {
    3873           0 :                     if (time < 0) {
    3874           0 :                         ret = avfilter_graph_send_command(fg->graph, target, command, arg, buf, sizeof(buf),
    3875             :                                                           key == 'c' ? AVFILTER_CMD_FLAG_ONE : 0);
    3876           0 :                         fprintf(stderr, "Command reply for stream %d: ret:%d res:\n%s", i, ret, buf);
    3877           0 :                     } else if (key == 'c') {
    3878           0 :                         fprintf(stderr, "Queuing commands only on filters supporting the specific command is unsupported\n");
    3879           0 :                         ret = AVERROR_PATCHWELCOME;
    3880             :                     } else {
    3881           0 :                         ret = avfilter_graph_queue_command(fg->graph, target, command, arg, 0, time);
    3882           0 :                         if (ret < 0)
    3883           0 :                             fprintf(stderr, "Queuing command failed with error %s\n", av_err2str(ret));
    3884             :                     }
    3885             :                 }
    3886             :             }
    3887             :         } else {
    3888           0 :             av_log(NULL, AV_LOG_ERROR,
    3889             :                    "Parse error, at least 3 arguments were expected, "
    3890             :                    "only %d given in string '%s'\n", n, buf);
    3891             :         }
    3892             :     }
    3893        3269 :     if (key == 'd' || key == 'D'){
    3894           0 :         int debug=0;
    3895           0 :         if(key == 'D') {
    3896           0 :             debug = input_streams[0]->st->codec->debug<<1;
    3897           0 :             if(!debug) debug = 1;
    3898           0 :             while(debug & (FF_DEBUG_DCT_COEFF|FF_DEBUG_VIS_QP|FF_DEBUG_VIS_MB_TYPE)) //unsupported, would just crash
    3899           0 :                 debug += debug;
    3900             :         }else{
    3901             :             char buf[32];
    3902           0 :             int k = 0;
    3903           0 :             i = 0;
    3904           0 :             set_tty_echo(1);
    3905           0 :             while ((k = read_key()) != '\n' && k != '\r' && i < sizeof(buf)-1)
    3906           0 :                 if (k > 0)
    3907           0 :                     buf[i++] = k;
    3908           0 :             buf[i] = 0;
    3909           0 :             set_tty_echo(0);
    3910           0 :             fprintf(stderr, "\n");
    3911           0 :             if (k <= 0 || sscanf(buf, "%d", &debug)!=1)
    3912           0 :                 fprintf(stderr,"error parsing debug value\n");
    3913             :         }
    3914           0 :         for(i=0;i<nb_input_streams;i++) {
    3915           0 :             input_streams[i]->st->codec->debug = debug;
    3916             :         }
    3917           0 :         for(i=0;i<nb_output_streams;i++) {
    3918           0 :             OutputStream *ost = output_streams[i];
    3919           0 :             ost->enc_ctx->debug = debug;
    3920             :         }
    3921           0 :         if(debug) av_log_set_level(AV_LOG_DEBUG);
    3922           0 :         fprintf(stderr,"debug=%d\n", debug);
    3923             :     }
    3924        3269 :     if (key == '?'){
    3925           0 :         fprintf(stderr, "key    function\n"
    3926             :                         "?      show this help\n"
    3927             :                         "+      increase verbosity\n"
    3928             :                         "-      decrease verbosity\n"
    3929             :                         "c      Send command to first matching filter supporting it\n"
    3930             :                         "C      Send/Queue command to all matching filters\n"
    3931             :                         "D      cycle through available debug modes\n"
    3932             :                         "h      dump packets/hex press to cycle through the 3 states\n"
    3933             :                         "q      quit\n"
    3934             :                         "s      Show QP histogram\n"
    3935             :         );
    3936             :     }
    3937        3269 :     return 0;
    3938             : }
    3939             : 
    3940             : #if HAVE_PTHREADS
    3941         132 : static void *input_thread(void *arg)
    3942             : {
    3943         132 :     InputFile *f = arg;
    3944         132 :     unsigned flags = f->non_blocking ? AV_THREAD_MESSAGE_NONBLOCK : 0;
    3945         132 :     int ret = 0;
    3946             : 
    3947        6405 :     while (1) {
    3948             :         AVPacket pkt;
    3949        6537 :         ret = av_read_frame(f->ctx, &pkt);
    3950             : 
    3951        6532 :         if (ret == AVERROR(EAGAIN)) {
    3952           0 :             av_usleep(10000);
    3953           0 :             continue;
    3954             :         }
    3955        6532 :         if (ret < 0) {
    3956          44 :             av_thread_message_queue_set_err_recv(f->in_thread_queue, ret);
    3957          43 :             break;
    3958             :         }
    3959        6488 :         ret = av_thread_message_queue_send(f->in_thread_queue, &pkt, flags);
    3960        6493 :         if (flags && ret == AVERROR(EAGAIN)) {
    3961          55 :             flags = 0;
    3962          55 :             ret = av_thread_message_queue_send(f->in_thread_queue, &pkt, flags);
    3963          55 :             av_log(f->ctx, AV_LOG_WARNING,
    3964             :                    "Thread message queue blocking; consider raising the "
    3965             :                    "thread_queue_size option (current value: %d)\n",
    3966             :                    f->thread_queue_size);
    3967             :         }
    3968        6494 :         if (ret < 0) {
    3969          89 :             if (ret != AVERROR_EOF)
    3970           0 :                 av_log(f->ctx, AV_LOG_ERROR,
    3971             :                        "Unable to send packet to main thread: %s\n",
    3972           0 :                        av_err2str(ret));
    3973          89 :             av_packet_unref(&pkt);
    3974          89 :             av_thread_message_queue_set_err_recv(f->in_thread_queue, ret);
    3975          90 :             break;
    3976             :         }
    3977             :     }
    3978             : 
    3979         266 :     return NULL;
    3980             : }
    3981             : 
    3982       15466 : static void free_input_threads(void)
    3983             : {
    3984             :     int i;
    3985             : 
    3986       31108 :     for (i = 0; i < nb_input_files; i++) {
    3987       15642 :         InputFile *f = input_files[i];
    3988             :         AVPacket pkt;
    3989             : 
    3990       15642 :         if (!f || !f->in_thread_queue)
    3991       15509 :             continue;
    3992         133 :         av_thread_message_queue_set_err_send(f->in_thread_queue, AVERROR_EOF);
    3993         955 :         while (av_thread_message_queue_recv(f->in_thread_queue, &pkt, 0) >= 0)
    3994         689 :             av_packet_unref(&pkt);
    3995             : 
    3996         133 :         pthread_join(f->thread, NULL);
    3997         133 :         f->joined = 1;
    3998         133 :         av_thread_message_queue_free(&f->in_thread_queue);
    3999             :     }
    4000       15466 : }
    4001             : 
    4002        5155 : static int init_input_threads(void)
    4003             : {
    4004             :     int i, ret;
    4005             : 
    4006        5155 :     if (nb_input_files == 1)
    4007        5081 :         return 0;
    4008             : 
    4009         207 :     for (i = 0; i < nb_input_files; i++) {
    4010         133 :         InputFile *f = input_files[i];
    4011             : 
    4012         190 :         if (f->ctx->pb ? !f->ctx->pb->seekable :
    4013          57 :             strcmp(f->ctx->iformat->name, "lavfi"))
    4014          56 :             f->non_blocking = 1;
    4015         133 :         ret = av_thread_message_queue_alloc(&f->in_thread_queue,
    4016         133 :                                             f->thread_queue_size, sizeof(AVPacket));
    4017         133 :         if (ret < 0)
    4018           0 :             return ret;
    4019             : 
    4020         133 :         if ((ret = pthread_create(&f->thread, NULL, input_thread, f))) {
    4021           0 :             av_log(NULL, AV_LOG_ERROR, "pthread_create failed: %s. Try to increase `ulimit -v` or decrease `ulimit -s`.\n", strerror(ret));
    4022           0 :             av_thread_message_queue_free(&f->in_thread_queue);
    4023           0 :             return AVERROR(ret);
    4024             :         }
    4025             :     }
    4026          74 :     return 0;
    4027             : }
    4028             : 
    4029     2272484 : static int get_input_packet_mt(InputFile *f, AVPacket *pkt)
    4030             : {
    4031     2272484 :     return av_thread_message_queue_recv(f->in_thread_queue, pkt,
    4032     2272484 :                                         f->non_blocking ?
    4033             :                                         AV_THREAD_MESSAGE_NONBLOCK : 0);
    4034             : }
    4035             : #endif
    4036             : 
    4037     2653678 : static int get_input_packet(InputFile *f, AVPacket *pkt)
    4038             : {
    4039     2653678 :     if (f->rate_emu) {
    4040             :         int i;
    4041           0 :         for (i = 0; i < f->nb_streams; i++) {
    4042           0 :             InputStream *ist = input_streams[f->ist_index + i];
    4043           0 :             int64_t pts = av_rescale(ist->dts, 1000000, AV_TIME_BASE);
    4044           0 :             int64_t now = av_gettime_relative() - ist->start;
    4045           0 :             if (pts > now)
    4046           0 :                 return AVERROR(EAGAIN);
    4047             :         }
    4048             :     }
    4049             : 
    4050             : #if HAVE_PTHREADS
    4051     2653678 :     if (nb_input_files > 1)
    4052     2272484 :         return get_input_packet_mt(f, pkt);
    4053             : #endif
    4054      381194 :     return av_read_frame(f->ctx, pkt);
    4055             : }
    4056             : 
    4057           7 : static int got_eagain(void)
    4058             : {
    4059             :     int i;
    4060           7 :     for (i = 0; i < nb_output_streams; i++)
    4061           7 :         if (output_streams[i]->unavailable)
    4062           7 :             return 1;
    4063           0 :     return 0;
    4064             : }
    4065             : 
    4066      383558 : static void reset_eagain(void)
    4067             : {
    4068             :     int i;
    4069      773357 :     for (i = 0; i < nb_input_files; i++)
    4070      389799 :         input_files[i]->eagain = 0;
    4071      780152 :     for (i = 0; i < nb_output_streams; i++)
    4072      396594 :         output_streams[i]->unavailable = 0;
    4073      383558 : }
    4074             : 
    4075             : // set duration to max(tmp, duration) in a proper time base and return duration's time_base
    4076           0 : static AVRational duration_max(int64_t tmp, int64_t *duration, AVRational tmp_time_base,
    4077             :                                 AVRational time_base)
    4078             : {
    4079             :     int ret;
    4080             : 
    4081           0 :     if (!*duration) {
    4082           0 :         *duration = tmp;
    4083           0 :         return tmp_time_base;
    4084             :     }
    4085             : 
    4086           0 :     ret = av_compare_ts(*duration, time_base, tmp, tmp_time_base);
    4087           0 :     if (ret < 0) {
    4088           0 :         *duration = tmp;
    4089           0 :         return tmp_time_base;
    4090             :     }
    4091             : 
    4092           0 :     return time_base;
    4093             : }
    4094             : 
    4095           0 : static int seek_to_start(InputFile *ifile, AVFormatContext *is)
    4096             : {
    4097             :     InputStream *ist;
    4098             :     AVCodecContext *avctx;
    4099           0 :     int i, ret, has_audio = 0;
    4100           0 :     int64_t duration = 0;
    4101             : 
    4102           0 :     ret = av_seek_frame(is, -1, is->start_time, 0);
    4103           0 :     if (ret < 0)
    4104           0 :         return ret;
    4105             : 
    4106           0 :     for (i = 0; i < ifile->nb_streams; i++) {
    4107           0 :         ist   = input_streams[ifile->ist_index + i];
    4108           0 :         avctx = ist->dec_ctx;
    4109             : 
    4110             :         // flush decoders
    4111           0 :         if (ist->decoding_needed) {
    4112           0 :             process_input_packet(ist, NULL, 1);
    4113           0 :             avcodec_flush_buffers(avctx);
    4114             :         }
    4115             : 
    4116             :         /* duration is the length of the last frame in a stream
    4117             :          * when audio stream is present we don't care about
    4118             :          * last video frame length because it's not defined exactly */
    4119           0 :         if (avctx->codec_type == AVMEDIA_TYPE_AUDIO && ist->nb_samples)
    4120           0 :             has_audio = 1;
    4121             :     }
    4122             : 
    4123           0 :     for (i = 0; i < ifile->nb_streams; i++) {
    4124           0 :         ist   = input_streams[ifile->ist_index + i];
    4125           0 :         avctx = ist->dec_ctx;
    4126             : 
    4127           0 :         if (has_audio) {
    4128           0 :             if (avctx->codec_type == AVMEDIA_TYPE_AUDIO && ist->nb_samples) {
    4129           0 :                 AVRational sample_rate = {1, avctx->sample_rate};
    4130             : 
    4131           0 :                 duration = av_rescale_q(ist->nb_samples, sample_rate, ist->st->time_base);
    4132             :             } else
    4133           0 :                 continue;
    4134             :         } else {
    4135           0 :             if (ist->framerate.num) {
    4136           0 :                 duration = av_rescale_q(1, ist->framerate, ist->st->time_base);
    4137           0 :             } else if (ist->st->avg_frame_rate.num) {
    4138           0 :                 duration = av_rescale_q(1, ist->st->avg_frame_rate, ist->st->time_base);
    4139           0 :             } else duration = 1;
    4140             :         }
    4141           0 :         if (!ifile->duration)
    4142           0 :             ifile->time_base = ist->st->time_base;
    4143             :         /* the total duration of the stream, max_pts - min_pts is
    4144             :          * the duration of the stream without the last frame */
    4145           0 :         duration += ist->max_pts - ist->min_pts;
    4146           0 :         ifile->time_base = duration_max(duration, &ifile->duration, ist->st->time_base,
    4147             :                                         ifile->time_base);
    4148             :     }
    4149             : 
    4150           0 :     if (ifile->loop > 0)
    4151           0 :         ifile->loop--;
    4152             : 
    4153           0 :     return ret;
    4154             : }
    4155             : 
    4156             : /*
    4157             :  * Return
    4158             :  * - 0 -- one packet was read and processed
    4159             :  * - AVERROR(EAGAIN) -- no packets were available for selected file,
    4160             :  *   this function should be called again
    4161             :  * - AVERROR_EOF -- this function should not be called again
    4162             :  */
    4163     2653678 : static int process_input(int file_index)
    4164             : {
    4165     2653678 :     InputFile *ifile = input_files[file_index];
    4166             :     AVFormatContext *is;
    4167             :     InputStream *ist;
    4168             :     AVPacket pkt;
    4169             :     int ret, i, j;
    4170             :     int64_t duration;
    4171             :     int64_t pkt_dts;
    4172             : 
    4173     2653678 :     is  = ifile->ctx;
    4174     2653678 :     ret = get_input_packet(ifile, &pkt);
    4175             : 
    4176     2653678 :     if (ret == AVERROR(EAGAIN)) {
    4177     2266728 :         ifile->eagain = 1;
    4178     2266728 :         return ret;
    4179             :     }
    4180      386950 :     if (ret < 0 && ifile->loop) {
    4181           0 :         if ((ret = seek_to_start(ifile, is)) < 0)
    4182           0 :             return ret;
    4183           0 :         ret = get_input_packet(ifile, &pkt);
    4184           0 :         if (ret == AVERROR(EAGAIN)) {
    4185           0 :             ifile->eagain = 1;
    4186           0 :             return ret;
    4187             :         }
    4188             :     }
    4189      386950 :     if (ret < 0) {
    4190        3399 :         if (ret != AVERROR_EOF) {
    4191          75 :             print_error(is->filename, ret);
    4192          75 :             if (exit_on_error)
    4193           0 :                 exit_program(1);
    4194             :         }
    4195             : 
    4196        6471 :         for (i = 0; i < ifile->nb_streams; i++) {
    4197        3660 :             ist = input_streams[ifile->ist_index + i];
    4198        3660 :             if (ist->decoding_needed) {
    4199        3323 :                 ret = process_input_packet(ist, NULL, 0);
    4200        3323 :                 if (ret>0)
    4201         588 :                     return 0;
    4202             :             }
    4203             : 
    4204             :             /* mark all outputs that don't go through lavfi as finished */
    4205        6397 :             for (j = 0; j < nb_output_streams; j++) {
    4206        3325 :                 OutputStream *ost = output_streams[j];
    4207             : 
    4208        6199 :                 if (ost->source_index == ifile->ist_index + i &&
    4209        5585 :                     (ost->stream_copy || ost->enc->type == AVMEDIA_TYPE_SUBTITLE))
    4210         191 :                     finish_output_stream(ost);
    4211             :             }
    4212             :         }
    4213             : 
    4214        2811 :         ifile->eof_reached = 1;
    4215        2811 :         return AVERROR(EAGAIN);
    4216             :     }
    4217             : 
    4218      383551 :     reset_eagain();
    4219             : 
    4220      383551 :     if (do_pkt_dump) {
    4221           0 :         av_pkt_dump_log2(NULL, AV_LOG_INFO, &pkt, do_hex_dump,
    4222           0 :                          is->streams[pkt.stream_index]);
    4223             :     }
    4224             :     /* the following test is needed in case new streams appear
    4225             :        dynamically in stream : we ignore them */
    4226      383551 :     if (pkt.stream_index >= ifile->nb_streams) {
    4227           0 :         report_new_stream(file_index, &pkt);
    4228           0 :         goto discard_packet;
    4229             :     }
    4230             : 
    4231      383551 :     ist = input_streams[ifile->ist_index + pkt.stream_index];
    4232             : 
    4233      383551 :     ist->data_size += pkt.size;
    4234      383551 :     ist->nb_packets++;
    4235             : 
    4236      383551 :     if (ist->discard)
    4237        7344 :         goto discard_packet;
    4238             : 
    4239      376207 :     if (exit_on_error && (pkt.flags & AV_PKT_FLAG_CORRUPT)) {
    4240           0 :         av_log(NULL, AV_LOG_FATAL, "%s: corrupt input packet in stream %d\n", is->filename, pkt.stream_index);
    4241           0 :         exit_program(1);
    4242             :     }
    4243             : 
    4244      376207 :     if (debug_ts) {
    4245           0 :         av_log(NULL, AV_LOG_INFO, "demuxer -> ist_index:%d type:%s "
    4246             :                "next_dts:%s next_dts_time:%s next_pts:%s next_pts_time:%s pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s off:%s off_time:%s\n",
    4247           0 :                ifile->ist_index + pkt.stream_index, av_get_media_type_string(ist->dec_ctx->codec_type),
    4248           0 :                av_ts2str(ist->next_dts), av_ts2timestr(ist->next_dts, &AV_TIME_BASE_Q),
    4249           0 :                av_ts2str(ist->next_pts), av_ts2timestr(ist->next_pts, &AV_TIME_BASE_Q),
    4250           0 :                av_ts2str(pkt.pts), av_ts2timestr(pkt.pts, &ist->st->time_base),
    4251           0 :                av_ts2str(pkt.dts), av_ts2timestr(pkt.dts, &ist->st->time_base),
    4252           0 :                av_ts2str(input_files[ist->file_index]->ts_offset),
    4253           0 :                av_ts2timestr(input_files[ist->file_index]->ts_offset, &AV_TIME_BASE_Q));
    4254             :     }
    4255             : 
    4256      376207 :     if(!ist->wrap_correction_done && is->start_time != AV_NOPTS_VALUE && ist->st->pts_wrap_bits < 64){
    4257             :         int64_t stime, stime2;
    4258             :         // Correcting starttime based on the enabled streams
    4259             :         // FIXME this ideally should be done before the first use of starttime but we do not know which are the enabled streams at that point.
    4260             :         //       so we instead do it here as part of discontinuity handling
    4261         225 :         if (   ist->next_dts == AV_NOPTS_VALUE
    4262         225 :             && ifile->ts_offset == -is->start_time
    4263         223 :             && (is->iformat->flags & AVFMT_TS_DISCONT)) {
    4264          40 :             int64_t new_start_time = INT64_MAX;
    4265         111 :             for (i=0; i<is->nb_streams; i++) {
    4266          71 :                 AVStream *st = is->streams[i];
    4267          71 :                 if(st->discard == AVDISCARD_ALL || st->start_time == AV_NOPTS_VALUE)
    4268          13 :                     continue;
    4269          58 :                 new_start_time = FFMIN(new_start_time, av_rescale_q(st->start_time, st->time_base, AV_TIME_BASE_Q));
    4270             :             }
    4271          40 :             if (new_start_time > is->start_time) {
    4272           3 :                 av_log(is, AV_LOG_VERBOSE, "Correcting start time by %"PRId64"\n", new_start_time - is->start_time);
    4273           3 :                 ifile->ts_offset = -new_start_time;
    4274             :             }
    4275             :         }
    4276             : 
    4277         225 :         stime = av_rescale_q(is->start_time, AV_TIME_BASE_Q, ist->st->time_base);
    4278         225 :         stime2= stime + (1ULL<<ist->st->pts_wrap_bits);
    4279         225 :         ist->wrap_correction_done = 1;
    4280             : 
    4281         225 :         if(stime2 > stime && pkt.dts != AV_NOPTS_VALUE && pkt.dts > stime + (1LL<<(ist->st->pts_wrap_bits-1))) {
    4282           0 :             pkt.dts -= 1ULL<<ist->st->pts_wrap_bits;
    4283           0 :             ist->wrap_correction_done = 0;
    4284             :         }
    4285         225 :         if(stime2 > stime && pkt.pts != AV_NOPTS_VALUE && pkt.pts > stime + (1LL<<(ist->st->pts_wrap_bits-1))) {
    4286           0 :             pkt.pts -= 1ULL<<ist->st->pts_wrap_bits;
    4287           0 :             ist->wrap_correction_done = 0;
    4288             :         }
    4289             :     }
    4290             : 
    4291             :     /* add the stream-global side data to the first packet */
    4292      376207 :     if (ist->nb_packets == 1) {
    4293        5487 :         for (i = 0; i < ist->st->nb_side_data; i++) {
    4294         212 :             AVPacketSideData *src_sd = &ist->st->side_data[i];
    4295             :             uint8_t *dst_data;
    4296             : 
    4297         212 :             if (src_sd->type == AV_PKT_DATA_DISPLAYMATRIX)
    4298           1 :                 continue;
    4299             : 
    4300         211 :             if (av_packet_get_side_data(&pkt, src_sd->type, NULL))
    4301           0 :                 continue;
    4302             : 
    4303         211 :             dst_data = av_packet_new_side_data(&pkt, src_sd->type, src_sd->size);
    4304         211 :             if (!dst_data)
    4305           0 :                 exit_program(1);
    4306             : 
    4307         211 :             memcpy(dst_data, src_sd->data, src_sd->size);
    4308             :         }
    4309             :     }
    4310             : 
    4311      376207 :     if (pkt.dts != AV_NOPTS_VALUE)
    4312      344968 :         pkt.dts += av_rescale_q(ifile->ts_offset, AV_TIME_BASE_Q, ist->st->time_base);
    4313      376207 :     if (pkt.pts != AV_NOPTS_VALUE)
    4314      342885 :         pkt.pts += av_rescale_q(ifile->ts_offset, AV_TIME_BASE_Q, ist->st->time_base);
    4315             : 
    4316      376207 :     if (pkt.pts != AV_NOPTS_VALUE)
    4317      342885 :         pkt.pts *= ist->ts_scale;
    4318      376207 :     if (pkt.dts != AV_NOPTS_VALUE)
    4319      344968 :         pkt.dts *= ist->ts_scale;
    4320             : 
    4321      376207 :     pkt_dts = av_rescale_q_rnd(pkt.dts, ist->st->time_base, AV_TIME_BASE_Q, AV_ROUND_NEAR_INF|AV_ROUND_PASS_MINMAX);
    4322      649045 :     if ((ist->dec_ctx->codec_type == AVMEDIA_TYPE_VIDEO ||
    4323      647601 :          ist->dec_ctx->codec_type == AVMEDIA_TYPE_AUDIO) &&
    4324      343526 :         pkt_dts != AV_NOPTS_VALUE && ist->next_dts == AV_NOPTS_VALUE && !copy_ts
    4325        5246 :         && (is->iformat->flags & AVFMT_TS_DISCONT) && ifile->last_ts != AV_NOPTS_VALUE) {
    4326          77 :         int64_t delta   = pkt_dts - ifile->last_ts;
    4327         154 :         if (delta < -1LL*dts_delta_threshold*AV_TIME_BASE ||
    4328          77 :             delta >  1LL*dts_delta_threshold*AV_TIME_BASE){
    4329           0 :             ifile->ts_offset -= delta;
    4330           0 :             av_log(NULL, AV_LOG_DEBUG,
    4331             :                    "Inter stream timestamp discontinuity %"PRId64", new offset= %"PRId64"\n",
    4332             :                    delta, ifile->ts_offset);
    4333           0 :             pkt.dts -= av_rescale_q(delta, AV_TIME_BASE_Q, ist->st->time_base);
    4334           0 :             if (pkt.pts != AV_NOPTS_VALUE)
    4335           0 :                 pkt.pts -= av_rescale_q(delta, AV_TIME_BASE_Q, ist->st->time_base);
    4336             :         }
    4337             :     }
    4338             : 
    4339      376207 :     duration = av_rescale_q(ifile->duration, ifile->time_base, ist->st->time_base);
    4340      376207 :     if (pkt.pts != AV_NOPTS_VALUE) {
    4341      342885 :         pkt.pts += duration;
    4342      342885 :         ist->max_pts = FFMAX(pkt.pts, ist->max_pts);
    4343      342885 :         ist->min_pts = FFMIN(pkt.pts, ist->min_pts);
    4344             :     }
    4345             : 
    4346      376207 :     if (pkt.dts != AV_NOPTS_VALUE)
    4347      344968 :         pkt.dts += duration;
    4348             : 
    4349      376207 :     pkt_dts = av_rescale_q_rnd(pkt.dts, ist->st->time_base, AV_TIME_BASE_Q, AV_ROUND_NEAR_INF|AV_ROUND_PASS_MINMAX);
    4350      649045 :     if ((ist->dec_ctx->codec_type == AVMEDIA_TYPE_VIDEO ||
    4351      647601 :          ist->dec_ctx->codec_type == AVMEDIA_TYPE_AUDIO) &&
    4352      681805 :          pkt_dts != AV_NOPTS_VALUE && ist->next_dts != AV_NOPTS_VALUE &&
    4353      338279 :         !copy_ts) {
    4354      338206 :         int64_t delta   = pkt_dts - ist->next_dts;
    4355      338206 :         if (is->iformat->flags & AVFMT_TS_DISCONT) {
    4356       27286 :             if (delta < -1LL*dts_delta_threshold*AV_TIME_BASE ||
    4357       27286 :                 delta >  1LL*dts_delta_threshold*AV_TIME_BASE ||
    4358       13643 :                 pkt_dts + AV_TIME_BASE/10 < FFMAX(ist->pts, ist->dts)) {
    4359           8 :                 ifile->ts_offset -= delta;
    4360           8 :                 av_log(NULL, AV_LOG_DEBUG,
    4361             :                        "timestamp discontinuity %"PRId64", new offset= %"PRId64"\n",
    4362             :                        delta, ifile->ts_offset);
    4363           8 :                 pkt.dts -= av_rescale_q(delta, AV_TIME_BASE_Q, ist->st->time_base);
    4364           8 :                 if (pkt.pts != AV_NOPTS_VALUE)
    4365           8 :                     pkt.pts -= av_rescale_q(delta, AV_TIME_BASE_Q, ist->st->time_base);
    4366             :             }
    4367             :         } else {
    4368      649126 :             if ( delta < -1LL*dts_error_threshold*AV_TIME_BASE ||
    4369      324563 :                  delta >  1LL*dts_error_threshold*AV_TIME_BASE) {
    4370           0 :                 av_log(NULL, AV_LOG_WARNING, "DTS %"PRId64", next:%"PRId64" st:%d invalid dropping\n", pkt.dts, ist->next_dts, pkt.stream_index);
    4371           0 :                 pkt.dts = AV_NOPTS_VALUE;
    4372             :             }
    4373      324563 :             if (pkt.pts != AV_NOPTS_VALUE){
    4374      322539 :                 int64_t pkt_pts = av_rescale_q(pkt.pts, ist->st->time_base, AV_TIME_BASE_Q);
    4375      322539 :                 delta   = pkt_pts - ist->next_dts;
    4376      645078 :                 if ( delta < -1LL*dts_error_threshold*AV_TIME_BASE ||
    4377      322539 :                      delta >  1LL*dts_error_threshold*AV_TIME_BASE) {
    4378           0 :                     av_log(NULL, AV_LOG_WARNING, "PTS %"PRId64", next:%"PRId64" invalid dropping st:%d\n", pkt.pts, ist->next_dts, pkt.stream_index);
    4379           0 :                     pkt.pts = AV_NOPTS_VALUE;
    4380             :                 }
    4381             :             }
    4382             :         }
    4383             :     }
    4384             : 
    4385      376207 :     if (pkt.dts != AV_NOPTS_VALUE)
    4386      344968 :         ifile->last_ts = av_rescale_q(pkt.dts, ist->st->time_base, AV_TIME_BASE_Q);
    4387             : 
    4388      376207 :     if (debug_ts) {
    4389           0 :         av_log(NULL, AV_LOG_INFO, "demuxer+ffmpeg -> ist_index:%d type:%s pkt_pts:%s pkt_pts_time:%s pkt_dts:%s pkt_dts_time:%s off:%s off_time:%s\n",
    4390           0 :                ifile->ist_index + pkt.stream_index, av_get_media_type_string(ist->dec_ctx->codec_type),
    4391           0 :                av_ts2str(pkt.pts), av_ts2timestr(pkt.pts, &ist->st->time_base),
    4392           0 :                av_ts2str(pkt.dts), av_ts2timestr(pkt.dts, &ist->st->time_base),
    4393           0 :                av_ts2str(input_files[ist->file_index]->ts_offset),
    4394           0 :                av_ts2timestr(input_files[ist->file_index]->ts_offset, &AV_TIME_BASE_Q));
    4395             :     }
    4396             : 
    4397      376207 :     sub2video_heartbeat(ist, pkt.pts);
    4398             : 
    4399      376207 :     process_input_packet(ist, &pkt, 0);
    4400             : 
    4401             : discard_packet:
    4402      383551 :     av_packet_unref(&pkt);
    4403             : 
    4404      383551 :     return 0;
    4405             : }
    4406             : 
    4407             : /**
    4408             :  * Perform a step of transcoding for the specified filter graph.
    4409             :  *
    4410             :  * @param[in]  graph     filter graph to consider
    4411             :  * @param[out] best_ist  input stream where a frame would allow to continue
    4412             :  * @return  0 for success, <0 for error
    4413             :  */
    4414      362564 : static int transcode_from_filter(FilterGraph *graph, InputStream **best_ist)
    4415             : {
    4416             :     int i, ret;
    4417      362564 :     int nb_requests, nb_requests_max = 0;
    4418             :     InputFilter *ifilter;
    4419             :     InputStream *ist;
    4420             : 
    4421      362564 :     *best_ist = NULL;
    4422      362564 :     ret = avfilter_graph_request_oldest(graph->graph);
    4423      362564 :     if (ret >= 0)
    4424         956 :         return reap_filters(0);
    4425             : 
    4426      361608 :     if (ret == AVERROR_EOF) {
    4427        3182 :         ret = reap_filters(1);
    4428        6366 :         for (i = 0; i < graph->nb_outputs; i++)
    4429        3184 :             close_output_stream(graph->outputs[i]->ost);
    4430        3182 :         return ret;
    4431             :     }
    4432      358426 :     if (ret != AVERROR(EAGAIN))
    4433           0 :         return ret;
    4434             : 
    4435      721585 :     for (i = 0; i < graph->nb_inputs; i++) {
    4436      363159 :         ifilter = graph->inputs[i];
    4437      363159 :         ist = ifilter->ist;
    4438      726318 :         if (input_files[ist->file_index]->eagain ||
    4439      363159 :             input_files[ist->file_index]->eof_reached)
    4440        1114 :             continue;
    4441      362045 :         nb_requests = av_buffersrc_get_nb_failed_requests(ifilter->filter);
    4442      362045 :         if (nb_requests > nb_requests_max) {
    4443      358426 :             nb_requests_max = nb_requests;
    4444      358426 :             *best_ist = ist;
    4445             :         }
    4446             :     }
    4447             : 
    4448      358426 :     if (!*best_ist)
    4449           0 :         for (i = 0; i < graph->nb_outputs; i++)
    4450           0 :             graph->outputs[i]->ost->unavailable = 1;
    4451             : 
    4452      358426 :     return 0;
    4453             : }
    4454             : 
    4455             : /**
    4456             :  * Run a single step of transcoding.
    4457             :  *
    4458             :  * @return  0 for success, <0 for error
    4459             :  */
    4460     2657823 : static int transcode_step(void)
    4461             : {
    4462             :     OutputStream *ost;
    4463     2657823 :     InputStream  *ist = NULL;
    4464             :     int ret;
    4465             : 
    4466     2657823 :     ost = choose_output();
    4467     2657823 :     if (!ost) {
    4468           7 :         if (got_eagain()) {
    4469           7 :             reset_eagain();
    4470           7 :             av_usleep(10000);
    4471           7 :             return 0;
    4472             :         }
    4473           0 :         av_log(NULL, AV_LOG_VERBOSE, "No more inputs to read from, finishing.\n");
    4474           0 :         return AVERROR_EOF;
    4475             :     }
    4476             : 
    4477     2657816 :     if (ost->filter && !ost->filter->graph->graph) {
    4478     2274595 :         if (ifilter_has_all_input_formats(ost->filter->graph)) {
    4479           9 :             ret = configure_filtergraph(ost->filter->graph);
    4480           9 :             if (ret < 0) {
    4481           0 :                 av_log(NULL, AV_LOG_ERROR, "Error reinitializing filters!\n");
    4482           0 :                 return ret;
    4483             :             }
    4484             :         }
    4485             :     }
    4486             : 
    4487     2657816 :     if (ost->filter && ost->filter->graph->graph) {
    4488      362564 :         if ((ret = transcode_from_filter(ost->filter->graph, &ist)) < 0)
    4489           0 :             return ret;
    4490      720990 :         if (!ist)
    4491        4138 :             return 0;
    4492     2295252 :     } else if (ost->filter) {
    4493             :         int i;
    4494     2318027 :         for (i = 0; i < ost->filter->graph->nb_inputs; i++) {
    4495     2318027 :             InputFilter *ifilter = ost->filter->graph->inputs[i];
    4496     2318027 :             if (!ifilter->ist->got_output && !input_files[ifilter->ist->file_index]->eof_reached) {
    4497     2274586 :                 ist = ifilter->ist;
    4498     2274586 :                 break;
    4499             :             }
    4500             :         }
    4501     2274586 :         if (!ist) {
    4502           0 :             ost->inputs_done = 1;
    4503           0 :             return 0;
    4504             :         }
    4505             :     } else {
    4506       20666 :         av_assert0(ost->source_index >= 0);
    4507       20666 :         ist = input_streams[ost->source_index];
    4508             :     }
    4509             : 
    4510     2653678 :     ret = process_input(ist->file_index);
    4511     2653678 :     if (ret == AVERROR(EAGAIN)) {
    4512     2269539 :         if (input_files[ist->file_index]->eagain)
    4513     2266728 :             ost->unavailable = 1;
    4514     2269539 :         return 0;
    4515             :     }
    4516             : 
    4517      384139 :     if (ret < 0)
    4518           0 :         return ret == AVERROR_EOF ? 0 : ret;
    4519             : 
    4520      384139 :     return reap_filters(0);
    4521             : }
    4522             : 
    4523             : /*
    4524             :  * The following code is the main loop of the file converter
    4525             :  */
    4526        5155 : static int transcode(void)
    4527             : {
    4528             :     int ret, i;
    4529             :     AVFormatContext *os;
    4530             :     OutputStream *ost;
    4531             :     InputStream *ist;
    4532             :     int64_t timer_start;
    4533        5155 :     int64_t total_packets_written = 0;
    4534             : 
    4535        5155 :     ret = transcode_init();
    4536        5155 :     if (ret < 0)
    4537           0 :         goto fail;
    4538             : 
    4539        5155 :     if (stdin_interaction) {
    4540          10 :         av_log(NULL, AV_LOG_INFO, "Press [q] to stop, [?] for help\n");
    4541             :     }
    4542             : 
    4543        5155 :     timer_start = av_gettime_relative();
    4544             : 
    4545             : #if HAVE_PTHREADS
    4546        5155 :     if ((ret = init_input_threads()) < 0)
    4547           0 :         goto fail;
    4548             : #endif
    4549             : 
    4550     2668133 :     while (!received_sigterm) {
    4551     2662978 :         int64_t cur_time= av_gettime_relative();
    4552             : 
    4553             :         /* if 'q' pressed, exits */
    4554     2662978 :         if (stdin_interaction)
    4555        3269 :             if (check_keyboard_interaction(cur_time) < 0)
    4556           0 :                 break;
    4557             : 
    4558             :         /* check if there's any stream where output is still needed */
    4559     2662978 :         if (!need_output()) {
    4560        5155 :             av_log(NULL, AV_LOG_VERBOSE, "No more output streams to write to, finishing.\n");
    4561        5155 :             break;
    4562             :         }
    4563             : 
    4564     2657823 :         ret = transcode_step();
    4565     2657823 :         if (ret < 0 && ret != AVERROR_EOF) {
    4566             :             char errbuf[128];
    4567           0 :             av_strerror(ret, errbuf, sizeof(errbuf));
    4568             : 
    4569           0 :             av_log(NULL, AV_LOG_ERROR, "Error while filtering: %s\n", errbuf);
    4570           0 :             break;
    4571             :         }
    4572             : 
    4573             :         /* dump report by using the output first video and audio streams */
    4574     2657823 :         print_report(0, timer_start, cur_time);
    4575             :     }
    4576             : #if HAVE_PTHREADS
    4577        5155 :     free_input_threads();
    4578             : #endif
    4579             : 
    4580             :     /* at the end of stream, we must flush the decoder buffers */
    4581       10668 :     for (i = 0; i < nb_input_streams; i++) {
    4582        5513 :         ist = input_streams[i];
    4583        5513 :         if (!input_files[ist->file_index]->eof_reached && ist->decoding_needed) {
    4584        2385 :             process_input_packet(ist, NULL, 0);
    4585             :         }
    4586             :     }
    4587        5155 :     flush_encoders();
    4588             : 
    4589        5155 :     term_exit();
    4590             : 
    4591             :     /* write the trailer if needed and close file */
    4592       10311 :     for (i = 0; i < nb_output_files; i++) {
    4593        5156 :         os = output_files[i]->ctx;
    4594        5156 :         if (!output_files[i]->header_written) {
    4595           0 :             av_log(NULL, AV_LOG_ERROR,
    4596             :                    "Nothing was written into output file %d (%s), because "
    4597             :                    "at least one of its streams received no packets.\n",
    4598           0 :                    i, os->filename);
    4599           0 :             continue;
    4600             :         }
    4601        5156 :         if ((ret = av_write_trailer(os)) < 0) {
    4602           0 :             av_log(NULL, AV_LOG_ERROR, "Error writing trailer of %s: %s\n", os->filename, av_err2str(ret));
    4603           0 :             if (exit_on_error)
    4604           0 :                 exit_program(1);
    4605             :         }
    4606             :     }
    4607             : 
    4608             :     /* dump report by using the first video and audio streams */
    4609        5155 :     print_report(1, timer_start, av_gettime_relative());
    4610             : 
    4611             :     /* close each encoder */
    4612       10443 :     for (i = 0; i < nb_output_streams; i++) {
    4613        5288 :         ost = output_streams[i];
    4614        5288 :         if (ost->encoding_needed) {
    4615        5112 :             av_freep(&ost->enc_ctx->stats_in);
    4616             :         }
    4617        5288 :         total_packets_written += ost->packets_written;
    4618             :     }
    4619             : 
    4620        5155 :     if (!total_packets_written && (abort_on_flags & ABORT_ON_FLAG_EMPTY_OUTPUT)) {
    4621           0 :         av_log(NULL, AV_LOG_FATAL, "Empty output\n");
    4622           0 :         exit_program(1);
    4623             :     }
    4624             : 
    4625             :     /* close each decoder */
    4626       10668 :     for (i = 0; i < nb_input_streams; i++) {
    4627        5513 :         ist = input_streams[i];
    4628        5513 :         if (ist->decoding_needed) {
    4629        5120 :             avcodec_close(ist->dec_ctx);
    4630        5120 :             if (ist->hwaccel_uninit)
    4631           0 :                 ist->hwaccel_uninit(ist->dec_ctx);
    4632             :         }
    4633             :     }
    4634             : 
    4635        5155 :     av_buffer_unref(&hw_device_ctx);
    4636             : 
    4637             :     /* finished ! */
    4638        5155 :     ret = 0;
    4639             : 
    4640             :  fail:
    4641             : #if HAVE_PTHREADS
    4642        5155 :     free_input_threads();
    4643             : #endif
    4644             : 
    4645        5155 :     if (output_streams) {
    4646       10442 :         for (i = 0; i < nb_output_streams; i++) {
    4647        5288 :             ost = output_streams[i];
    4648        5288 :             if (ost) {
    4649        5288 :                 if (ost->logfile) {
    4650           0 :                     if (fclose(ost->logfile))
    4651           0 :                         av_log(NULL, AV_LOG_ERROR,
    4652             :                                "Error closing logfile, loss of information possible: %s\n",
    4653           0 :                                av_err2str(AVERROR(errno)));
    4654           0 :                     ost->logfile = NULL;
    4655             :                 }
    4656        5288 :                 av_freep(&ost->forced_kf_pts);
    4657        5288 :                 av_freep(&ost->apad);
    4658        5288 :                 av_freep(&ost->disposition);
    4659        5288 :                 av_dict_free(&ost->encoder_opts);
    4660        5288 :                 av_dict_free(&ost->sws_dict);
    4661        5288 :                 av_dict_free(&ost->swr_opts);
    4662        5288 :                 av_dict_free(&ost->resample_opts);
    4663             :             }
    4664             :         }
    4665             :     }
    4666        5155 :     return ret;
    4667             : }
    4668             : 
    4669             : 
    4670       10310 : static int64_t getutime(void)
    4671             : {
    4672             : #if HAVE_GETRUSAGE
    4673             :     struct rusage rusage;
    4674             : 
    4675       10310 :     getrusage(RUSAGE_SELF, &rusage);
    4676       10310 :     return (rusage.ru_utime.tv_sec * 1000000LL) + rusage.ru_utime.tv_usec;
    4677             : #elif HAVE_GETPROCESSTIMES
    4678             :     HANDLE proc;
    4679             :     FILETIME c, e, k, u;
    4680             :     proc = GetCurrentProcess();
    4681             :     GetProcessTimes(proc, &c, &e, &k, &u);
    4682             :     return ((int64_t) u.dwHighDateTime << 32 | u.dwLowDateTime) / 10;
    4683             : #else
    4684             :     return av_gettime_relative();
    4685             : #endif
    4686             : }
    4687             : 
    4688           0 : static int64_t getmaxrss(void)
    4689             : {
    4690             : #if HAVE_GETRUSAGE && HAVE_STRUCT_RUSAGE_RU_MAXRSS
    4691             :     struct rusage rusage;
    4692           0 :     getrusage(RUSAGE_SELF, &rusage);
    4693           0 :     return (int64_t)rusage.ru_maxrss * 1024;
    4694             : #elif HAVE_GETPROCESSMEMORYINFO
    4695             :     HANDLE proc;
    4696             :     PROCESS_MEMORY_COUNTERS memcounters;
    4697             :     proc = GetCurrentProcess();
    4698             :     memcounters.cb = sizeof(memcounters);
    4699             :     GetProcessMemoryInfo(proc, &memcounters, sizeof(memcounters));
    4700             :     return memcounters.PeakPagefileUsage;
    4701             : #else
    4702             :     return 0;
    4703             : #endif
    4704             : }
    4705             : 
    4706           0 : static void log_callback_null(void *ptr, int level, const char *fmt, va_list vl)
    4707             : {
    4708           0 : }
    4709             : 
    4710        5156 : int main(int argc, char **argv)
    4711             : {
    4712             :     int i, ret;
    4713             :     int64_t ti;
    4714             : 
    4715        5156 :     init_dynload();
    4716             : 
    4717        5156 :     register_exit(ffmpeg_cleanup);
    4718             : 
    4719        5156 :     setvbuf(stderr,NULL,_IONBF,0); /* win32 runtime needs this */
    4720             : 
    4721        5156 :     av_log_set_flags(AV_LOG_SKIP_REPEATED);
    4722        5156 :     parse_loglevel(argc, argv, options);
    4723             : 
    4724        5156 :     if(argc>1 && !strcmp(argv[1], "-d")){
    4725           0 :         run_as_daemon=1;
    4726           0 :         av_log_set_callback(log_callback_null);
    4727           0 :         argc--;
    4728           0 :         argv++;
    4729             :     }
    4730             : 
    4731        5156 :     avcodec_register_all();
    4732             : #if CONFIG_AVDEVICE
    4733        5156 :     avdevice_register_all();
    4734             : #endif
    4735        5156 :     avfilter_register_all();
    4736        5156 :     av_register_all();
    4737        5156 :     avformat_network_init();
    4738             : 
    4739        5156 :     show_banner(argc, argv, options);
    4740             : 
    4741             :     /* parse options and open all input/output files */
    4742        5156 :     ret = ffmpeg_parse_options(argc, argv);
    4743        5155 :     if (ret < 0)
    4744           0 :         exit_program(1);
    4745             : 
    4746        5155 :     if (nb_output_files <= 0 && nb_input_files == 0) {
    4747           0 :         show_usage();
    4748           0 :         av_log(NULL, AV_LOG_WARNING, "Use -h to get full help or, even better, run 'man %s'\n", program_name);
    4749           0 :         exit_program(1);
    4750             :     }
    4751             : 
    4752             :     /* file converter / grab */
    4753        5155 :     if (nb_output_files <= 0) {
    4754           0 :         av_log(NULL, AV_LOG_FATAL, "At least one output file must be specified\n");
    4755           0 :         exit_program(1);
    4756             :     }
    4757             : 
    4758             : //     if (nb_input_files == 0) {
    4759             : //         av_log(NULL, AV_LOG_FATAL, "At least one input file must be specified\n");
    4760             : //         exit_program(1);
    4761             : //     }
    4762             : 
    4763       10311 :     for (i = 0; i < nb_output_files; i++) {
    4764        5156 :         if (strcmp(output_files[i]->ctx->oformat->name, "rtp"))
    4765        5156 :             want_sdp = 0;
    4766             :     }
    4767             : 
    4768        5155 :     current_time = ti = getutime();
    4769        5155 :     if (transcode() < 0)
    4770           0 :         exit_program(1);
    4771        5155 :     ti = getutime() - ti;
    4772        5155 :     if (do_benchmark) {
    4773           0 :         av_log(NULL, AV_LOG_INFO, "bench: utime=%0.3fs\n", ti / 1000000.0);
    4774             :     }
    4775        5155 :     av_log(NULL, AV_LOG_DEBUG, "%"PRIu64" frames successfully decoded, %"PRIu64" decoding errors\n",
    4776             :            decode_error_stat[0], decode_error_stat[1]);
    4777        5155 :     if ((decode_error_stat[0] + decode_error_stat[1]) * max_error_rate < decode_error_stat[1])
    4778           0 :         exit_program(69);
    4779             : 
    4780        5155 :     exit_program(received_nb_signals ? 255 : main_return_code);
    4781             :     return main_return_code;
    4782             : }

Generated by: LCOV version 1.13