LCOV - code coverage report
Current view: top level - libavfilter - avfilter.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 621 844 73.6 %
Date: 2018-05-20 11:54:08 Functions: 52 61 85.2 %

          Line data    Source code
       1             : /*
       2             :  * filter layer
       3             :  * Copyright (c) 2007 Bobby Bingham
       4             :  *
       5             :  * This file is part of FFmpeg.
       6             :  *
       7             :  * FFmpeg is free software; you can redistribute it and/or
       8             :  * modify it under the terms of the GNU Lesser General Public
       9             :  * License as published by the Free Software Foundation; either
      10             :  * version 2.1 of the License, or (at your option) any later version.
      11             :  *
      12             :  * FFmpeg is distributed in the hope that it will be useful,
      13             :  * but WITHOUT ANY WARRANTY; without even the implied warranty of
      14             :  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
      15             :  * Lesser General Public License for more details.
      16             :  *
      17             :  * You should have received a copy of the GNU Lesser General Public
      18             :  * License along with FFmpeg; if not, write to the Free Software
      19             :  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
      20             :  */
      21             : 
      22             : #include "libavutil/avassert.h"
      23             : #include "libavutil/avstring.h"
      24             : #include "libavutil/buffer.h"
      25             : #include "libavutil/channel_layout.h"
      26             : #include "libavutil/common.h"
      27             : #include "libavutil/eval.h"
      28             : #include "libavutil/hwcontext.h"
      29             : #include "libavutil/imgutils.h"
      30             : #include "libavutil/internal.h"
      31             : #include "libavutil/opt.h"
      32             : #include "libavutil/pixdesc.h"
      33             : #include "libavutil/rational.h"
      34             : #include "libavutil/samplefmt.h"
      35             : #include "libavutil/thread.h"
      36             : 
      37             : #define FF_INTERNAL_FIELDS 1
      38             : #include "framequeue.h"
      39             : 
      40             : #include "audio.h"
      41             : #include "avfilter.h"
      42             : #include "filters.h"
      43             : #include "formats.h"
      44             : #include "internal.h"
      45             : 
      46             : #include "libavutil/ffversion.h"
      47             : const char av_filter_ffversion[] = "FFmpeg version " FFMPEG_VERSION;
      48             : 
      49     1412051 : void ff_tlog_ref(void *ctx, AVFrame *ref, int end)
      50             : {
      51             :     av_unused char buf[16];
      52             :     ff_tlog(ctx,
      53             :             "ref[%p buf:%p data:%p linesize[%d, %d, %d, %d] pts:%"PRId64" pos:%"PRId64,
      54             :             ref, ref->buf, ref->data[0],
      55             :             ref->linesize[0], ref->linesize[1], ref->linesize[2], ref->linesize[3],
      56             :             ref->pts, ref->pkt_pos);
      57             : 
      58     1412051 :     if (ref->width) {
      59             :         ff_tlog(ctx, " a:%d/%d s:%dx%d i:%c iskey:%d type:%c",
      60             :                 ref->sample_aspect_ratio.num, ref->sample_aspect_ratio.den,
      61             :                 ref->width, ref->height,
      62             :                 !ref->interlaced_frame     ? 'P' :         /* Progressive  */
      63             :                 ref->top_field_first ? 'T' : 'B',    /* Top / Bottom */
      64             :                 ref->key_frame,
      65             :                 av_get_picture_type_char(ref->pict_type));
      66             :     }
      67     1412051 :     if (ref->nb_samples) {
      68             :         ff_tlog(ctx, " cl:%"PRId64"d n:%d r:%d",
      69             :                 ref->channel_layout,
      70             :                 ref->nb_samples,
      71             :                 ref->sample_rate);
      72             :     }
      73             : 
      74             :     ff_tlog(ctx, "]%s", end ? "\n" : "");
      75     1412051 : }
      76             : 
      77        5681 : unsigned avfilter_version(void)
      78             : {
      79             :     av_assert0(LIBAVFILTER_VERSION_MICRO >= 100);
      80        5681 :     return LIBAVFILTER_VERSION_INT;
      81             : }
      82             : 
      83        5681 : const char *avfilter_configuration(void)
      84             : {
      85        5681 :     return FFMPEG_CONFIGURATION;
      86             : }
      87             : 
      88           0 : const char *avfilter_license(void)
      89             : {
      90             : #define LICENSE_PREFIX "libavfilter license: "
      91           0 :     return LICENSE_PREFIX FFMPEG_LICENSE + sizeof(LICENSE_PREFIX) - 1;
      92             : }
      93             : 
      94           0 : void ff_command_queue_pop(AVFilterContext *filter)
      95             : {
      96           0 :     AVFilterCommand *c= filter->command_queue;
      97           0 :     av_freep(&c->arg);
      98           0 :     av_freep(&c->command);
      99           0 :     filter->command_queue= c->next;
     100           0 :     av_free(c);
     101           0 : }
     102             : 
     103         139 : int ff_insert_pad(unsigned idx, unsigned *count, size_t padidx_off,
     104             :                    AVFilterPad **pads, AVFilterLink ***links,
     105             :                    AVFilterPad *newpad)
     106             : {
     107             :     AVFilterLink **newlinks;
     108             :     AVFilterPad *newpads;
     109             :     unsigned i;
     110             : 
     111         139 :     idx = FFMIN(idx, *count);
     112             : 
     113         139 :     newpads  = av_realloc_array(*pads,  *count + 1, sizeof(AVFilterPad));
     114         139 :     newlinks = av_realloc_array(*links, *count + 1, sizeof(AVFilterLink*));
     115         139 :     if (newpads)
     116         139 :         *pads  = newpads;
     117         139 :     if (newlinks)
     118         139 :         *links = newlinks;
     119         139 :     if (!newpads || !newlinks)
     120           0 :         return AVERROR(ENOMEM);
     121             : 
     122         139 :     memmove(*pads  + idx + 1, *pads  + idx, sizeof(AVFilterPad)   * (*count - idx));
     123         139 :     memmove(*links + idx + 1, *links + idx, sizeof(AVFilterLink*) * (*count - idx));
     124         139 :     memcpy(*pads + idx, newpad, sizeof(AVFilterPad));
     125         139 :     (*links)[idx] = NULL;
     126             : 
     127         139 :     (*count)++;
     128         139 :     for (i = idx + 1; i < *count; i++)
     129           0 :         if ((*links)[i])
     130           0 :             (*(unsigned *)((uint8_t *) (*links)[i] + padidx_off))++;
     131             : 
     132         139 :     return 0;
     133             : }
     134             : 
     135       22559 : int avfilter_link(AVFilterContext *src, unsigned srcpad,
     136             :                   AVFilterContext *dst, unsigned dstpad)
     137             : {
     138             :     AVFilterLink *link;
     139             : 
     140       22559 :     av_assert0(src->graph);
     141       22559 :     av_assert0(dst->graph);
     142       22559 :     av_assert0(src->graph == dst->graph);
     143             : 
     144       45118 :     if (src->nb_outputs <= srcpad || dst->nb_inputs <= dstpad ||
     145       45118 :         src->outputs[srcpad]      || dst->inputs[dstpad])
     146           0 :         return AVERROR(EINVAL);
     147             : 
     148       22559 :     if (src->output_pads[srcpad].type != dst->input_pads[dstpad].type) {
     149           0 :         av_log(src, AV_LOG_ERROR,
     150             :                "Media type mismatch between the '%s' filter output pad %d (%s) and the '%s' filter input pad %d (%s)\n",
     151           0 :                src->name, srcpad, (char *)av_x_if_null(av_get_media_type_string(src->output_pads[srcpad].type), "?"),
     152           0 :                dst->name, dstpad, (char *)av_x_if_null(av_get_media_type_string(dst-> input_pads[dstpad].type), "?"));
     153           0 :         return AVERROR(EINVAL);
     154             :     }
     155             : 
     156       22559 :     link = av_mallocz(sizeof(*link));
     157       22559 :     if (!link)
     158           0 :         return AVERROR(ENOMEM);
     159             : 
     160       22559 :     src->outputs[srcpad] = dst->inputs[dstpad] = link;
     161             : 
     162       22559 :     link->src     = src;
     163       22559 :     link->dst     = dst;
     164       22559 :     link->srcpad  = &src->output_pads[srcpad];
     165       22559 :     link->dstpad  = &dst->input_pads[dstpad];
     166       22559 :     link->type    = src->output_pads[srcpad].type;
     167             :     av_assert0(AV_PIX_FMT_NONE == -1 && AV_SAMPLE_FMT_NONE == -1);
     168       22559 :     link->format  = -1;
     169       22559 :     ff_framequeue_init(&link->fifo, &src->graph->internal->frame_queues);
     170             : 
     171       22559 :     return 0;
     172             : }
     173             : 
     174       22691 : void avfilter_link_free(AVFilterLink **link)
     175             : {
     176       22691 :     if (!*link)
     177           0 :         return;
     178             : 
     179       22691 :     av_frame_free(&(*link)->partial_buf);
     180       22691 :     ff_framequeue_free(&(*link)->fifo);
     181       22691 :     ff_frame_pool_uninit((FFFramePool**)&(*link)->frame_pool);
     182             : 
     183       22691 :     av_freep(link);
     184             : }
     185             : 
     186             : #if FF_API_FILTER_GET_SET
     187           0 : int avfilter_link_get_channels(AVFilterLink *link)
     188             : {
     189           0 :     return link->channels;
     190             : }
     191             : #endif
     192             : 
     193     3778283 : void ff_filter_set_ready(AVFilterContext *filter, unsigned priority)
     194             : {
     195     3778283 :     filter->ready = FFMAX(filter->ready, priority);
     196     3778283 : }
     197             : 
     198             : /**
     199             :  * Clear frame_blocked_in on all outputs.
     200             :  * This is necessary whenever something changes on input.
     201             :  */
     202     2473184 : static void filter_unblock(AVFilterContext *filter)
     203             : {
     204             :     unsigned i;
     205             : 
     206     4558157 :     for (i = 0; i < filter->nb_outputs; i++)
     207     2084973 :         filter->outputs[i]->frame_blocked_in = 0;
     208     2473184 : }
     209             : 
     210             : 
     211       22251 : void ff_avfilter_link_set_in_status(AVFilterLink *link, int status, int64_t pts)
     212             : {
     213       22251 :     if (link->status_in == status)
     214          27 :         return;
     215       22224 :     av_assert0(!link->status_in);
     216       22224 :     link->status_in = status;
     217       22224 :     link->status_in_pts = pts;
     218       22224 :     link->frame_wanted_out = 0;
     219       22224 :     link->frame_blocked_in = 0;
     220       22224 :     filter_unblock(link->dst);
     221       22224 :     ff_filter_set_ready(link->dst, 200);
     222             : }
     223             : 
     224       16695 : void ff_avfilter_link_set_out_status(AVFilterLink *link, int status, int64_t pts)
     225             : {
     226       16695 :     av_assert0(!link->frame_wanted_out);
     227       16695 :     av_assert0(!link->status_out);
     228       16695 :     link->status_out = status;
     229       16695 :     if (pts != AV_NOPTS_VALUE)
     230       16158 :         ff_update_link_current_pts(link, pts);
     231       16695 :     filter_unblock(link->dst);
     232       16695 :     ff_filter_set_ready(link->src, 200);
     233       16695 : }
     234             : 
     235           0 : void avfilter_link_set_closed(AVFilterLink *link, int closed)
     236             : {
     237           0 :     ff_avfilter_link_set_out_status(link, closed ? AVERROR_EOF : 0, AV_NOPTS_VALUE);
     238           0 : }
     239             : 
     240        2909 : int avfilter_insert_filter(AVFilterLink *link, AVFilterContext *filt,
     241             :                            unsigned filt_srcpad_idx, unsigned filt_dstpad_idx)
     242             : {
     243             :     int ret;
     244        2909 :     unsigned dstpad_idx = link->dstpad - link->dst->input_pads;
     245             : 
     246        5818 :     av_log(link->dst, AV_LOG_VERBOSE, "auto-inserting filter '%s' "
     247             :            "between the filter '%s' and the filter '%s'\n",
     248        5818 :            filt->name, link->src->name, link->dst->name);
     249             : 
     250        2909 :     link->dst->inputs[dstpad_idx] = NULL;
     251        2909 :     if ((ret = avfilter_link(filt, filt_dstpad_idx, link->dst, dstpad_idx)) < 0) {
     252             :         /* failed to link output filter to new filter */
     253           0 :         link->dst->inputs[dstpad_idx] = link;
     254           0 :         return ret;
     255             :     }
     256             : 
     257             :     /* re-hookup the link to the new destination filter we inserted */
     258        2909 :     link->dst                     = filt;
     259        2909 :     link->dstpad                  = &filt->input_pads[filt_srcpad_idx];
     260        2909 :     filt->inputs[filt_srcpad_idx] = link;
     261             : 
     262             :     /* if any information on supported media formats already exists on the
     263             :      * link, we need to preserve that */
     264        2909 :     if (link->out_formats)
     265        2899 :         ff_formats_changeref(&link->out_formats,
     266        2899 :                              &filt->outputs[filt_dstpad_idx]->out_formats);
     267        2909 :     if (link->out_samplerates)
     268         535 :         ff_formats_changeref(&link->out_samplerates,
     269         535 :                              &filt->outputs[filt_dstpad_idx]->out_samplerates);
     270        2909 :     if (link->out_channel_layouts)
     271         535 :         ff_channel_layouts_changeref(&link->out_channel_layouts,
     272         535 :                                      &filt->outputs[filt_dstpad_idx]->out_channel_layouts);
     273             : 
     274        2909 :     return 0;
     275             : }
     276             : 
     277       27994 : int avfilter_config_links(AVFilterContext *filter)
     278             : {
     279             :     int (*config_link)(AVFilterLink *);
     280             :     unsigned i;
     281             :     int ret;
     282             : 
     283       50476 :     for (i = 0; i < filter->nb_inputs; i ++) {
     284       22482 :         AVFilterLink *link = filter->inputs[i];
     285             :         AVFilterLink *inlink;
     286             : 
     287       22482 :         if (!link) continue;
     288       22482 :         if (!link->src || !link->dst) {
     289           0 :             av_log(filter, AV_LOG_ERROR,
     290             :                    "Not all input and output are properly linked (%d).\n", i);
     291           0 :             return AVERROR(EINVAL);
     292             :         }
     293             : 
     294       22482 :         inlink = link->src->nb_inputs ? link->src->inputs[0] : NULL;
     295       22482 :         link->current_pts =
     296       22482 :         link->current_pts_us = AV_NOPTS_VALUE;
     297             : 
     298       22482 :         switch (link->init_state) {
     299          23 :         case AVLINK_INIT:
     300          23 :             continue;
     301           0 :         case AVLINK_STARTINIT:
     302           0 :             av_log(filter, AV_LOG_INFO, "circular filter chain detected\n");
     303           0 :             return 0;
     304       22459 :         case AVLINK_UNINIT:
     305       22459 :             link->init_state = AVLINK_STARTINIT;
     306             : 
     307       22459 :             if ((ret = avfilter_config_links(link->src)) < 0)
     308           0 :                 return ret;
     309             : 
     310       22459 :             if (!(config_link = link->srcpad->config_props)) {
     311       11754 :                 if (link->src->nb_inputs != 1) {
     312           0 :                     av_log(link->src, AV_LOG_ERROR, "Source filters and filters "
     313             :                                                     "with more than one input "
     314             :                                                     "must set config_props() "
     315             :                                                     "callbacks on all outputs\n");
     316           0 :                     return AVERROR(EINVAL);
     317             :                 }
     318       10705 :             } else if ((ret = config_link(link)) < 0) {
     319           0 :                 av_log(link->src, AV_LOG_ERROR,
     320             :                        "Failed to configure output pad on %s\n",
     321           0 :                        link->src->name);
     322           0 :                 return ret;
     323             :             }
     324             : 
     325       22459 :             switch (link->type) {
     326       17622 :             case AVMEDIA_TYPE_VIDEO:
     327       17622 :                 if (!link->time_base.num && !link->time_base.den)
     328       12909 :                     link->time_base = inlink ? inlink->time_base : AV_TIME_BASE_Q;
     329             : 
     330       17622 :                 if (!link->sample_aspect_ratio.num && !link->sample_aspect_ratio.den)
     331        9622 :                     link->sample_aspect_ratio = inlink ?
     332             :                         inlink->sample_aspect_ratio : (AVRational){1,1};
     333             : 
     334       17622 :                 if (inlink) {
     335       13137 :                     if (!link->frame_rate.num && !link->frame_rate.den)
     336       12963 :                         link->frame_rate = inlink->frame_rate;
     337       13137 :                     if (!link->w)
     338        9235 :                         link->w = inlink->w;
     339       13137 :                     if (!link->h)
     340        9235 :                         link->h = inlink->h;
     341        4485 :                 } else if (!link->w || !link->h) {
     342           0 :                     av_log(link->src, AV_LOG_ERROR,
     343             :                            "Video source filters must set their output link's "
     344             :                            "width and height\n");
     345           0 :                     return AVERROR(EINVAL);
     346             :                 }
     347       17622 :                 break;
     348             : 
     349        4837 :             case AVMEDIA_TYPE_AUDIO:
     350        4837 :                 if (inlink) {
     351        3752 :                     if (!link->time_base.num && !link->time_base.den)
     352        2581 :                         link->time_base = inlink->time_base;
     353             :                 }
     354             : 
     355        4837 :                 if (!link->time_base.num && !link->time_base.den)
     356           4 :                     link->time_base = (AVRational) {1, link->sample_rate};
     357             :             }
     358             : 
     359       22459 :             if (link->src->nb_inputs && link->src->inputs[0]->hw_frames_ctx &&
     360           0 :                 !(link->src->filter->flags_internal & FF_FILTER_FLAG_HWFRAME_AWARE)) {
     361           0 :                 av_assert0(!link->hw_frames_ctx &&
     362             :                            "should not be set by non-hwframe-aware filter");
     363           0 :                 link->hw_frames_ctx = av_buffer_ref(link->src->inputs[0]->hw_frames_ctx);
     364           0 :                 if (!link->hw_frames_ctx)
     365           0 :                     return AVERROR(ENOMEM);
     366             :             }
     367             : 
     368       22459 :             if ((config_link = link->dstpad->config_props))
     369        1788 :                 if ((ret = config_link(link)) < 0) {
     370           0 :                     av_log(link->dst, AV_LOG_ERROR,
     371             :                            "Failed to configure input pad on %s\n",
     372           0 :                            link->dst->name);
     373           0 :                     return ret;
     374             :                 }
     375             : 
     376       22459 :             link->init_state = AVLINK_INIT;
     377             :         }
     378             :     }
     379             : 
     380       27994 :     return 0;
     381             : }
     382             : 
     383     3745929 : void ff_tlog_link(void *ctx, AVFilterLink *link, int end)
     384             : {
     385     3745929 :     if (link->type == AVMEDIA_TYPE_VIDEO) {
     386             :         ff_tlog(ctx,
     387             :                 "link[%p s:%dx%d fmt:%s %s->%s]%s",
     388             :                 link, link->w, link->h,
     389             :                 av_get_pix_fmt_name(link->format),
     390             :                 link->src ? link->src->filter->name : "",
     391             :                 link->dst ? link->dst->filter->name : "",
     392             :                 end ? "\n" : "");
     393             :     } else {
     394             :         char buf[128];
     395     2820666 :         av_get_channel_layout_string(buf, sizeof(buf), -1, link->channel_layout);
     396             : 
     397             :         ff_tlog(ctx,
     398             :                 "link[%p r:%d cl:%s fmt:%s %s->%s]%s",
     399             :                 link, (int)link->sample_rate, buf,
     400             :                 av_get_sample_fmt_name(link->format),
     401             :                 link->src ? link->src->filter->name : "",
     402             :                 link->dst ? link->dst->filter->name : "",
     403             :                 end ? "\n" : "");
     404             :     }
     405     3745929 : }
     406             : 
     407      948404 : int ff_request_frame(AVFilterLink *link)
     408             : {
     409      948404 :     FF_TPRINTF_START(NULL, request_frame); ff_tlog_link(NULL, link, 1);
     410             : 
     411             :     av_assert1(!link->dst->filter->activate);
     412      948404 :     if (link->status_out)
     413        1146 :         return link->status_out;
     414      947258 :     if (link->status_in) {
     415       16203 :         if (ff_framequeue_queued_frames(&link->fifo)) {
     416             :             av_assert1(!link->frame_wanted_out);
     417             :             av_assert1(link->dst->ready >= 300);
     418           0 :             return 0;
     419             :         } else {
     420             :             /* Acknowledge status change. Filters using ff_request_frame() will
     421             :                handle the change automatically. Filters can also check the
     422             :                status directly but none do yet. */
     423       16203 :             ff_avfilter_link_set_out_status(link, link->status_in, link->status_in_pts);
     424       16203 :             return link->status_out;
     425             :         }
     426             :     }
     427      931055 :     link->frame_wanted_out = 1;
     428      931055 :     ff_filter_set_ready(link->src, 100);
     429      931055 :     return 0;
     430             : }
     431             : 
     432       16734 : static int64_t guess_status_pts(AVFilterContext *ctx, int status, AVRational link_time_base)
     433             : {
     434             :     unsigned i;
     435       16734 :     int64_t r = INT64_MAX;
     436             : 
     437       33429 :     for (i = 0; i < ctx->nb_inputs; i++)
     438       16695 :         if (ctx->inputs[i]->status_out == status)
     439       16686 :             r = FFMIN(r, av_rescale_q(ctx->inputs[i]->current_pts, ctx->inputs[i]->time_base, link_time_base));
     440       16734 :     if (r < INT64_MAX)
     441       16675 :         return r;
     442          59 :     av_log(ctx, AV_LOG_WARNING, "EOF timestamp not reliable\n");
     443          59 :     for (i = 0; i < ctx->nb_inputs; i++)
     444           0 :         r = FFMIN(r, av_rescale_q(ctx->inputs[i]->status_in_pts, ctx->inputs[i]->time_base, link_time_base));
     445          59 :     if (r < INT64_MAX)
     446           0 :         return r;
     447          59 :     return AV_NOPTS_VALUE;
     448             : }
     449             : 
     450     1303709 : static int ff_request_frame_to_filter(AVFilterLink *link)
     451             : {
     452     1303709 :     int ret = -1;
     453             : 
     454     1303709 :     FF_TPRINTF_START(NULL, request_frame_to_filter); ff_tlog_link(NULL, link, 1);
     455             :     /* Assume the filter is blocked, let the method clear it if not */
     456     1303709 :     link->frame_blocked_in = 1;
     457     1303709 :     if (link->srcpad->request_frame)
     458      574381 :         ret = link->srcpad->request_frame(link);
     459      729328 :     else if (link->src->inputs[0])
     460      729328 :         ret = ff_request_frame(link->src->inputs[0]);
     461     1303709 :     if (ret < 0) {
     462      365879 :         if (ret != AVERROR(EAGAIN) && ret != link->status_in)
     463       16734 :             ff_avfilter_link_set_in_status(link, ret, guess_status_pts(link->src, ret, link->time_base));
     464      365879 :         if (ret == AVERROR_EOF)
     465       16734 :             ret = 0;
     466             :     }
     467     1303709 :     return ret;
     468             : }
     469             : 
     470           0 : int ff_poll_frame(AVFilterLink *link)
     471             : {
     472           0 :     int i, min = INT_MAX;
     473             : 
     474           0 :     if (link->srcpad->poll_frame)
     475           0 :         return link->srcpad->poll_frame(link);
     476             : 
     477           0 :     for (i = 0; i < link->src->nb_inputs; i++) {
     478             :         int val;
     479           0 :         if (!link->src->inputs[i])
     480           0 :             return AVERROR(EINVAL);
     481           0 :         val = ff_poll_frame(link->src->inputs[i]);
     482           0 :         min = FFMIN(min, val);
     483             :     }
     484             : 
     485           0 :     return min;
     486             : }
     487             : 
     488             : static const char *const var_names[] = {
     489             :     "t",
     490             :     "n",
     491             :     "pos",
     492             :     "w",
     493             :     "h",
     494             :     NULL
     495             : };
     496             : 
     497             : enum {
     498             :     VAR_T,
     499             :     VAR_N,
     500             :     VAR_POS,
     501             :     VAR_W,
     502             :     VAR_H,
     503             :     VAR_VARS_NB
     504             : };
     505             : 
     506           4 : static int set_enable_expr(AVFilterContext *ctx, const char *expr)
     507             : {
     508             :     int ret;
     509             :     char *expr_dup;
     510           4 :     AVExpr *old = ctx->enable;
     511             : 
     512           4 :     if (!(ctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE)) {
     513           0 :         av_log(ctx, AV_LOG_ERROR, "Timeline ('enable' option) not supported "
     514           0 :                "with filter '%s'\n", ctx->filter->name);
     515           0 :         return AVERROR_PATCHWELCOME;
     516             :     }
     517             : 
     518           4 :     expr_dup = av_strdup(expr);
     519           4 :     if (!expr_dup)
     520           0 :         return AVERROR(ENOMEM);
     521             : 
     522           4 :     if (!ctx->var_values) {
     523           4 :         ctx->var_values = av_calloc(VAR_VARS_NB, sizeof(*ctx->var_values));
     524           4 :         if (!ctx->var_values) {
     525           0 :             av_free(expr_dup);
     526           0 :             return AVERROR(ENOMEM);
     527             :         }
     528             :     }
     529             : 
     530           4 :     ret = av_expr_parse((AVExpr**)&ctx->enable, expr_dup, var_names,
     531             :                         NULL, NULL, NULL, NULL, 0, ctx->priv);
     532           4 :     if (ret < 0) {
     533           0 :         av_log(ctx->priv, AV_LOG_ERROR,
     534             :                "Error when evaluating the expression '%s' for enable\n",
     535             :                expr_dup);
     536           0 :         av_free(expr_dup);
     537           0 :         return ret;
     538             :     }
     539             : 
     540           4 :     av_expr_free(old);
     541           4 :     av_free(ctx->enable_str);
     542           4 :     ctx->enable_str = expr_dup;
     543           4 :     return 0;
     544             : }
     545             : 
     546     1444152 : void ff_update_link_current_pts(AVFilterLink *link, int64_t pts)
     547             : {
     548     1444152 :     if (pts == AV_NOPTS_VALUE)
     549          30 :         return;
     550     1444122 :     link->current_pts = pts;
     551     1444122 :     link->current_pts_us = av_rescale_q(pts, link->time_base, AV_TIME_BASE_Q);
     552             :     /* TODO use duration */
     553     1444122 :     if (link->graph && link->age_index >= 0)
     554      401134 :         ff_avfilter_graph_update_heap(link->graph, link);
     555             : }
     556             : 
     557           0 : int avfilter_process_command(AVFilterContext *filter, const char *cmd, const char *arg, char *res, int res_len, int flags)
     558             : {
     559           0 :     if(!strcmp(cmd, "ping")){
     560           0 :         char local_res[256] = {0};
     561             : 
     562           0 :         if (!res) {
     563           0 :             res = local_res;
     564           0 :             res_len = sizeof(local_res);
     565             :         }
     566           0 :         av_strlcatf(res, res_len, "pong from:%s %s\n", filter->filter->name, filter->name);
     567           0 :         if (res == local_res)
     568           0 :             av_log(filter, AV_LOG_INFO, "%s", res);
     569           0 :         return 0;
     570           0 :     }else if(!strcmp(cmd, "enable")) {
     571           0 :         return set_enable_expr(filter, arg);
     572           0 :     }else if(filter->filter->process_command) {
     573           0 :         return filter->filter->process_command(filter, cmd, arg, res, res_len, flags);
     574             :     }
     575           0 :     return AVERROR(ENOSYS);
     576             : }
     577             : 
     578       56400 : int avfilter_pad_count(const AVFilterPad *pads)
     579             : {
     580             :     int count;
     581             : 
     582       56400 :     if (!pads)
     583       11228 :         return 0;
     584             : 
     585       90412 :     for (count = 0; pads->name; count++)
     586       45240 :         pads++;
     587       45172 :     return count;
     588             : }
     589             : 
     590         331 : static const char *default_filter_name(void *filter_ctx)
     591             : {
     592         331 :     AVFilterContext *ctx = filter_ctx;
     593         331 :     return ctx->name ? ctx->name : ctx->filter->name;
     594             : }
     595             : 
     596        1253 : static void *filter_child_next(void *obj, void *prev)
     597             : {
     598        1253 :     AVFilterContext *ctx = obj;
     599        1253 :     if (!prev && ctx->filter && ctx->filter->priv_class && ctx->priv)
     600        1253 :         return ctx->priv;
     601           0 :     return NULL;
     602             : }
     603             : 
     604           0 : static const AVClass *filter_child_class_next(const AVClass *prev)
     605             : {
     606           0 :     void *opaque = NULL;
     607           0 :     const AVFilter *f = NULL;
     608             : 
     609             :     /* find the filter that corresponds to prev */
     610           0 :     while (prev && (f = av_filter_iterate(&opaque)))
     611           0 :         if (f->priv_class == prev)
     612           0 :             break;
     613             : 
     614             :     /* could not find filter corresponding to prev */
     615           0 :     if (prev && !f)
     616           0 :         return NULL;
     617             : 
     618             :     /* find next filter with specific options */
     619           0 :     while ((f = av_filter_iterate(&opaque)))
     620           0 :         if (f->priv_class)
     621           0 :             return f->priv_class;
     622             : 
     623           0 :     return NULL;
     624             : }
     625             : 
     626             : #define OFFSET(x) offsetof(AVFilterContext, x)
     627             : #define FLAGS AV_OPT_FLAG_FILTERING_PARAM
     628             : static const AVOption avfilter_options[] = {
     629             :     { "thread_type", "Allowed thread types", OFFSET(thread_type), AV_OPT_TYPE_FLAGS,
     630             :         { .i64 = AVFILTER_THREAD_SLICE }, 0, INT_MAX, FLAGS, "thread_type" },
     631             :         { "slice", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AVFILTER_THREAD_SLICE }, .unit = "thread_type" },
     632             :     { "enable", "set enable expression", OFFSET(enable_str), AV_OPT_TYPE_STRING, {.str=NULL}, .flags = FLAGS },
     633             :     { "threads", "Allowed number of threads", OFFSET(nb_threads), AV_OPT_TYPE_INT,
     634             :         { .i64 = 0 }, 0, INT_MAX, FLAGS },
     635             :     { "extra_hw_frames", "Number of extra hardware frames to allocate for the user",
     636             :         OFFSET(extra_hw_frames), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, FLAGS },
     637             :     { NULL },
     638             : };
     639             : 
     640             : static const AVClass avfilter_class = {
     641             :     .class_name = "AVFilter",
     642             :     .item_name  = default_filter_name,
     643             :     .version    = LIBAVUTIL_VERSION_INT,
     644             :     .category   = AV_CLASS_CATEGORY_FILTER,
     645             :     .child_next = filter_child_next,
     646             :     .child_class_next = filter_child_class_next,
     647             :     .option           = avfilter_options,
     648             : };
     649             : 
     650         401 : static int default_execute(AVFilterContext *ctx, avfilter_action_func *func, void *arg,
     651             :                            int *ret, int nb_jobs)
     652             : {
     653             :     int i;
     654             : 
     655         802 :     for (i = 0; i < nb_jobs; i++) {
     656         401 :         int r = func(ctx, arg, i, nb_jobs);
     657         401 :         if (ret)
     658           0 :             ret[i] = r;
     659             :     }
     660         401 :     return 0;
     661             : }
     662             : 
     663       28200 : AVFilterContext *ff_filter_alloc(const AVFilter *filter, const char *inst_name)
     664             : {
     665             :     AVFilterContext *ret;
     666       28200 :     int preinited = 0;
     667             : 
     668       28200 :     if (!filter)
     669           0 :         return NULL;
     670             : 
     671       28200 :     ret = av_mallocz(sizeof(AVFilterContext));
     672       28200 :     if (!ret)
     673           0 :         return NULL;
     674             : 
     675       28200 :     ret->av_class = &avfilter_class;
     676       28200 :     ret->filter   = filter;
     677       28200 :     ret->name     = inst_name ? av_strdup(inst_name) : NULL;
     678       28200 :     if (filter->priv_size) {
     679       24900 :         ret->priv     = av_mallocz(filter->priv_size);
     680       24900 :         if (!ret->priv)
     681           0 :             goto err;
     682             :     }
     683       28200 :     if (filter->preinit) {
     684          38 :         if (filter->preinit(ret) < 0)
     685           0 :             goto err;
     686          38 :         preinited = 1;
     687             :     }
     688             : 
     689       28200 :     av_opt_set_defaults(ret);
     690       28200 :     if (filter->priv_class) {
     691       24717 :         *(const AVClass**)ret->priv = filter->priv_class;
     692       24717 :         av_opt_set_defaults(ret->priv);
     693             :     }
     694             : 
     695       28200 :     ret->internal = av_mallocz(sizeof(*ret->internal));
     696       28200 :     if (!ret->internal)
     697           0 :         goto err;
     698       28200 :     ret->internal->execute = default_execute;
     699             : 
     700       28200 :     ret->nb_inputs = avfilter_pad_count(filter->inputs);
     701       28200 :     if (ret->nb_inputs ) {
     702       22563 :         ret->input_pads   = av_malloc_array(ret->nb_inputs, sizeof(AVFilterPad));
     703       22563 :         if (!ret->input_pads)
     704           0 :             goto err;
     705       22563 :         memcpy(ret->input_pads, filter->inputs, sizeof(AVFilterPad) * ret->nb_inputs);
     706       22563 :         ret->inputs       = av_mallocz_array(ret->nb_inputs, sizeof(AVFilterLink*));
     707       22563 :         if (!ret->inputs)
     708           0 :             goto err;
     709             :     }
     710             : 
     711       28200 :     ret->nb_outputs = avfilter_pad_count(filter->outputs);
     712       28200 :     if (ret->nb_outputs) {
     713       22609 :         ret->output_pads  = av_malloc_array(ret->nb_outputs, sizeof(AVFilterPad));
     714       22609 :         if (!ret->output_pads)
     715           0 :             goto err;
     716       22609 :         memcpy(ret->output_pads, filter->outputs, sizeof(AVFilterPad) * ret->nb_outputs);
     717       22609 :         ret->outputs      = av_mallocz_array(ret->nb_outputs, sizeof(AVFilterLink*));
     718       22609 :         if (!ret->outputs)
     719           0 :             goto err;
     720             :     }
     721             : 
     722       28200 :     return ret;
     723             : 
     724           0 : err:
     725           0 :     if (preinited)
     726           0 :         filter->uninit(ret);
     727           0 :     av_freep(&ret->inputs);
     728           0 :     av_freep(&ret->input_pads);
     729           0 :     ret->nb_inputs = 0;
     730           0 :     av_freep(&ret->outputs);
     731           0 :     av_freep(&ret->output_pads);
     732           0 :     ret->nb_outputs = 0;
     733           0 :     av_freep(&ret->priv);
     734           0 :     av_freep(&ret->internal);
     735           0 :     av_free(ret);
     736           0 :     return NULL;
     737             : }
     738             : 
     739       45379 : static void free_link(AVFilterLink *link)
     740             : {
     741       45379 :     if (!link)
     742       22688 :         return;
     743             : 
     744       22691 :     if (link->src)
     745       22559 :         link->src->outputs[link->srcpad - link->src->output_pads] = NULL;
     746       22691 :     if (link->dst)
     747       22559 :         link->dst->inputs[link->dstpad - link->dst->input_pads] = NULL;
     748             : 
     749       22691 :     av_buffer_unref(&link->hw_frames_ctx);
     750             : 
     751       22691 :     ff_formats_unref(&link->in_formats);
     752       22691 :     ff_formats_unref(&link->out_formats);
     753       22691 :     ff_formats_unref(&link->in_samplerates);
     754       22691 :     ff_formats_unref(&link->out_samplerates);
     755       22691 :     ff_channel_layouts_unref(&link->in_channel_layouts);
     756       22691 :     ff_channel_layouts_unref(&link->out_channel_layouts);
     757       22691 :     avfilter_link_free(&link);
     758             : }
     759             : 
     760       28200 : void avfilter_free(AVFilterContext *filter)
     761             : {
     762             :     int i;
     763             : 
     764       28200 :     if (!filter)
     765           0 :         return;
     766             : 
     767       28200 :     if (filter->graph)
     768       28200 :         ff_filter_graph_remove_filter(filter->graph, filter);
     769             : 
     770       28200 :     if (filter->filter->uninit)
     771       16287 :         filter->filter->uninit(filter);
     772             : 
     773       50881 :     for (i = 0; i < filter->nb_inputs; i++) {
     774       22681 :         free_link(filter->inputs[i]);
     775             :     }
     776       50898 :     for (i = 0; i < filter->nb_outputs; i++) {
     777       22698 :         free_link(filter->outputs[i]);
     778             :     }
     779             : 
     780       28200 :     if (filter->filter->priv_class)
     781       24717 :         av_opt_free(filter->priv);
     782             : 
     783       28200 :     av_buffer_unref(&filter->hw_device_ctx);
     784             : 
     785       28200 :     av_freep(&filter->name);
     786       28200 :     av_freep(&filter->input_pads);
     787       28200 :     av_freep(&filter->output_pads);
     788       28200 :     av_freep(&filter->inputs);
     789       28200 :     av_freep(&filter->outputs);
     790       28200 :     av_freep(&filter->priv);
     791       56400 :     while(filter->command_queue){
     792           0 :         ff_command_queue_pop(filter);
     793             :     }
     794       28200 :     av_opt_free(filter);
     795       28200 :     av_expr_free(filter->enable);
     796       28200 :     filter->enable = NULL;
     797       28200 :     av_freep(&filter->var_values);
     798       28200 :     av_freep(&filter->internal);
     799       28200 :     av_free(filter);
     800             : }
     801             : 
     802        4656 : int ff_filter_get_nb_threads(AVFilterContext *ctx)
     803             : {
     804        4656 :      if (ctx->nb_threads > 0)
     805           0 :          return FFMIN(ctx->nb_threads, ctx->graph->nb_threads);
     806        4656 :      return ctx->graph->nb_threads;
     807             : }
     808             : 
     809       17977 : static int process_options(AVFilterContext *ctx, AVDictionary **options,
     810             :                            const char *args)
     811             : {
     812       17977 :     const AVOption *o = NULL;
     813       17977 :     int ret, count = 0;
     814       17977 :     char *av_uninit(parsed_key), *av_uninit(value);
     815             :     const char *key;
     816       17977 :     int offset= -1;
     817             : 
     818       17977 :     if (!args)
     819           0 :         return 0;
     820             : 
     821      126302 :     while (*args) {
     822       90348 :         const char *shorthand = NULL;
     823             : 
     824       90348 :         o = av_opt_next(ctx->priv, o);
     825       90348 :         if (o) {
     826       88300 :             if (o->type == AV_OPT_TYPE_CONST || o->offset == offset)
     827       38770 :                 continue;
     828       49530 :             offset = o->offset;
     829       49530 :             shorthand = o->name;
     830             :         }
     831             : 
     832       51578 :         ret = av_opt_get_key_value(&args, "=", ":",
     833             :                                    shorthand ? AV_OPT_FLAG_IMPLICIT_KEY : 0,
     834             :                                    &parsed_key, &value);
     835       51578 :         if (ret < 0) {
     836           0 :             if (ret == AVERROR(EINVAL))
     837           0 :                 av_log(ctx, AV_LOG_ERROR, "No option name near '%s'\n", args);
     838             :             else
     839           0 :                 av_log(ctx, AV_LOG_ERROR, "Unable to parse '%s': %s\n", args,
     840           0 :                        av_err2str(ret));
     841           0 :             return ret;
     842             :         }
     843       51578 :         if (*args)
     844       34670 :             args++;
     845       51578 :         if (parsed_key) {
     846       41705 :             key = parsed_key;
     847       41705 :             while ((o = av_opt_next(ctx->priv, o))); /* discard all remaining shorthand */
     848             :         } else {
     849        9873 :             key = shorthand;
     850             :         }
     851             : 
     852       51578 :         av_log(ctx, AV_LOG_DEBUG, "Setting '%s' to value '%s'\n", key, value);
     853             : 
     854       51578 :         if (av_opt_find(ctx, key, NULL, 0, 0)) {
     855           4 :             ret = av_opt_set(ctx, key, value, 0);
     856           4 :             if (ret < 0) {
     857           0 :                 av_free(value);
     858           0 :                 av_free(parsed_key);
     859           0 :                 return ret;
     860             :             }
     861             :         } else {
     862       51574 :         av_dict_set(options, key, value, 0);
     863       51574 :         if ((ret = av_opt_set(ctx->priv, key, value, AV_OPT_SEARCH_CHILDREN)) < 0) {
     864        5012 :             if (!av_opt_find(ctx->priv, key, NULL, 0, AV_OPT_SEARCH_CHILDREN | AV_OPT_SEARCH_FAKE_OBJ)) {
     865           0 :             if (ret == AVERROR_OPTION_NOT_FOUND)
     866           0 :                 av_log(ctx, AV_LOG_ERROR, "Option '%s' not found\n", key);
     867           0 :             av_free(value);
     868           0 :             av_free(parsed_key);
     869           0 :             return ret;
     870             :             }
     871             :         }
     872             :         }
     873             : 
     874       51578 :         av_free(value);
     875       51578 :         av_free(parsed_key);
     876       51578 :         count++;
     877             :     }
     878             : 
     879       17977 :     if (ctx->enable_str) {
     880           4 :         ret = set_enable_expr(ctx, ctx->enable_str);
     881           4 :         if (ret < 0)
     882           0 :             return ret;
     883             :     }
     884       17977 :     return count;
     885             : }
     886             : 
     887       28200 : int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
     888             : {
     889       28200 :     int ret = 0;
     890             : 
     891       28200 :     ret = av_opt_set_dict(ctx, options);
     892       28200 :     if (ret < 0) {
     893           0 :         av_log(ctx, AV_LOG_ERROR, "Error applying generic filter options.\n");
     894           0 :         return ret;
     895             :     }
     896             : 
     897       28624 :     if (ctx->filter->flags & AVFILTER_FLAG_SLICE_THREADS &&
     898         531 :         ctx->thread_type & ctx->graph->thread_type & AVFILTER_THREAD_SLICE &&
     899         107 :         ctx->graph->internal->thread_execute) {
     900         107 :         ctx->thread_type       = AVFILTER_THREAD_SLICE;
     901         107 :         ctx->internal->execute = ctx->graph->internal->thread_execute;
     902             :     } else {
     903       28093 :         ctx->thread_type = 0;
     904             :     }
     905             : 
     906       28200 :     if (ctx->filter->priv_class) {
     907       24717 :         ret = av_opt_set_dict2(ctx->priv, options, AV_OPT_SEARCH_CHILDREN);
     908       24717 :         if (ret < 0) {
     909           0 :             av_log(ctx, AV_LOG_ERROR, "Error applying options to the filter.\n");
     910           0 :             return ret;
     911             :         }
     912             :     }
     913             : 
     914       28200 :     if (ctx->filter->init_opaque)
     915        5534 :         ret = ctx->filter->init_opaque(ctx, NULL);
     916       22666 :     else if (ctx->filter->init)
     917       13340 :         ret = ctx->filter->init(ctx);
     918        9326 :     else if (ctx->filter->init_dict)
     919        4369 :         ret = ctx->filter->init_dict(ctx, options);
     920             : 
     921       28200 :     return ret;
     922             : }
     923             : 
     924       28200 : int avfilter_init_str(AVFilterContext *filter, const char *args)
     925             : {
     926       28200 :     AVDictionary *options = NULL;
     927             :     AVDictionaryEntry *e;
     928       28200 :     int ret = 0;
     929             : 
     930       28200 :     if (args && *args) {
     931       17977 :         if (!filter->filter->priv_class) {
     932           0 :             av_log(filter, AV_LOG_ERROR, "This filter does not take any "
     933             :                    "options, but options were provided: %s.\n", args);
     934           0 :             return AVERROR(EINVAL);
     935             :         }
     936             : 
     937             : #if FF_API_OLD_FILTER_OPTS_ERROR
     938       30559 :             if (   !strcmp(filter->filter->name, "format")     ||
     939       25164 :                    !strcmp(filter->filter->name, "noformat")   ||
     940       25164 :                    !strcmp(filter->filter->name, "frei0r")     ||
     941       25164 :                    !strcmp(filter->filter->name, "frei0r_src") ||
     942       25164 :                    !strcmp(filter->filter->name, "ocv")        ||
     943       25152 :                    !strcmp(filter->filter->name, "pan")        ||
     944       25132 :                    !strcmp(filter->filter->name, "pp")         ||
     945       17983 :                    !strcmp(filter->filter->name, "aevalsrc")) {
     946             :             /* a hack for compatibility with the old syntax
     947             :              * replace colons with |s */
     948        5421 :             char *copy = av_strdup(args);
     949        5421 :             char *p    = copy;
     950        5421 :             int nb_leading = 0; // number of leading colons to skip
     951        5421 :             int deprecated = 0;
     952             : 
     953        5421 :             if (!copy) {
     954           0 :                 ret = AVERROR(ENOMEM);
     955           0 :                 goto fail;
     956             :             }
     957             : 
     958       10842 :             if (!strcmp(filter->filter->name, "frei0r") ||
     959        5421 :                 !strcmp(filter->filter->name, "ocv"))
     960           0 :                 nb_leading = 1;
     961        5421 :             else if (!strcmp(filter->filter->name, "frei0r_src"))
     962           0 :                 nb_leading = 3;
     963             : 
     964       10842 :             while (nb_leading--) {
     965           0 :                 p = strchr(p, ':');
     966           0 :                 if (!p) {
     967           0 :                     p = copy + strlen(copy);
     968           0 :                     break;
     969             :                 }
     970           0 :                 p++;
     971             :             }
     972             : 
     973        5421 :             deprecated = strchr(p, ':') != NULL;
     974             : 
     975        5421 :             if (!strcmp(filter->filter->name, "aevalsrc")) {
     976           6 :                 deprecated = 0;
     977          12 :                 while ((p = strchr(p, ':')) && p[1] != ':') {
     978           6 :                     const char *epos = strchr(p + 1, '=');
     979           6 :                     const char *spos = strchr(p + 1, ':');
     980           6 :                     const int next_token_is_opt = epos && (!spos || epos < spos);
     981           6 :                     if (next_token_is_opt) {
     982           6 :                         p++;
     983           6 :                         break;
     984             :                     }
     985             :                     /* next token does not contain a '=', assume a channel expression */
     986           0 :                     deprecated = 1;
     987           0 :                     *p++ = '|';
     988             :                 }
     989           6 :                 if (p && *p == ':') { // double sep '::' found
     990           0 :                     deprecated = 1;
     991           0 :                     memmove(p, p + 1, strlen(p));
     992             :                 }
     993             :             } else
     994       10830 :             while ((p = strchr(p, ':')))
     995           0 :                 *p++ = '|';
     996             : 
     997        5421 :             if (deprecated) {
     998           0 :                 av_log(filter, AV_LOG_ERROR, "This syntax is deprecated. Use "
     999             :                        "'|' to separate the list items ('%s' instead of '%s')\n",
    1000             :                        copy, args);
    1001           0 :                 ret = AVERROR(EINVAL);
    1002             :             } else {
    1003        5421 :                 ret = process_options(filter, &options, copy);
    1004             :             }
    1005        5421 :             av_freep(&copy);
    1006             : 
    1007        5421 :             if (ret < 0)
    1008           0 :                 goto fail;
    1009             :         } else
    1010             : #endif
    1011             :         {
    1012       12556 :             ret = process_options(filter, &options, args);
    1013       12556 :             if (ret < 0)
    1014           0 :                 goto fail;
    1015             :         }
    1016             :     }
    1017             : 
    1018       28200 :     ret = avfilter_init_dict(filter, &options);
    1019       28200 :     if (ret < 0)
    1020           0 :         goto fail;
    1021             : 
    1022       28200 :     if ((e = av_dict_get(options, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
    1023           0 :         av_log(filter, AV_LOG_ERROR, "No such option: %s.\n", e->key);
    1024           0 :         ret = AVERROR_OPTION_NOT_FOUND;
    1025           0 :         goto fail;
    1026             :     }
    1027             : 
    1028       56400 : fail:
    1029       28200 :     av_dict_free(&options);
    1030             : 
    1031       28200 :     return ret;
    1032             : }
    1033             : 
    1034       17517 : const char *avfilter_pad_get_name(const AVFilterPad *pads, int pad_idx)
    1035             : {
    1036       17517 :     return pads[pad_idx].name;
    1037             : }
    1038             : 
    1039       22300 : enum AVMediaType avfilter_pad_get_type(const AVFilterPad *pads, int pad_idx)
    1040             : {
    1041       22300 :     return pads[pad_idx].type;
    1042             : }
    1043             : 
    1044      709220 : static int default_filter_frame(AVFilterLink *link, AVFrame *frame)
    1045             : {
    1046      709220 :     return ff_filter_frame(link->dst->outputs[0], frame);
    1047             : }
    1048             : 
    1049     1022214 : static int ff_filter_frame_framed(AVFilterLink *link, AVFrame *frame)
    1050             : {
    1051             :     int (*filter_frame)(AVFilterLink *, AVFrame *);
    1052     1022214 :     AVFilterContext *dstctx = link->dst;
    1053     1022214 :     AVFilterPad *dst = link->dstpad;
    1054             :     int ret;
    1055             : 
    1056     1022214 :     if (!(filter_frame = dst->filter_frame))
    1057      709211 :         filter_frame = default_filter_frame;
    1058             : 
    1059     1022214 :     if (dst->needs_writable) {
    1060        2167 :         ret = ff_inlink_make_frame_writable(link, &frame);
    1061        2167 :         if (ret < 0)
    1062           0 :             goto fail;
    1063             :     }
    1064             : 
    1065     1022214 :     ff_inlink_process_commands(link, frame);
    1066     1022214 :     dstctx->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1067             : 
    1068     1022233 :     if (dstctx->is_disabled &&
    1069          19 :         (dstctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC))
    1070           9 :         filter_frame = default_filter_frame;
    1071     1022214 :     ret = filter_frame(link, frame);
    1072     1022214 :     link->frame_count_out++;
    1073     1022214 :     return ret;
    1074             : 
    1075           0 : fail:
    1076           0 :     av_frame_free(&frame);
    1077           0 :     return ret;
    1078             : }
    1079             : 
    1080     1412051 : int ff_filter_frame(AVFilterLink *link, AVFrame *frame)
    1081             : {
    1082             :     int ret;
    1083     1412051 :     FF_TPRINTF_START(NULL, filter_frame); ff_tlog_link(NULL, link, 1); ff_tlog(NULL, " "); ff_tlog_ref(NULL, frame, 1);
    1084             : 
    1085             :     /* Consistency checks */
    1086     1412051 :     if (link->type == AVMEDIA_TYPE_VIDEO) {
    1087      530005 :         if (strcmp(link->dst->filter->name, "buffersink") &&
    1088      367128 :             strcmp(link->dst->filter->name, "format") &&
    1089      301780 :             strcmp(link->dst->filter->name, "idet") &&
    1090      150877 :             strcmp(link->dst->filter->name, "null") &&
    1091       62008 :             strcmp(link->dst->filter->name, "scale")) {
    1092             :             av_assert1(frame->format                 == link->format);
    1093             :             av_assert1(frame->width               == link->w);
    1094             :             av_assert1(frame->height               == link->h);
    1095             :         }
    1096             :     } else {
    1097     1098271 :         if (frame->format != link->format) {
    1098           0 :             av_log(link->dst, AV_LOG_ERROR, "Format change is not supported\n");
    1099           0 :             goto error;
    1100             :         }
    1101     1098271 :         if (frame->channels != link->channels) {
    1102           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel count change is not supported\n");
    1103           0 :             goto error;
    1104             :         }
    1105     1098271 :         if (frame->channel_layout != link->channel_layout) {
    1106           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel layout change is not supported\n");
    1107           0 :             goto error;
    1108             :         }
    1109     1098271 :         if (frame->sample_rate != link->sample_rate) {
    1110           0 :             av_log(link->dst, AV_LOG_ERROR, "Sample rate change is not supported\n");
    1111           0 :             goto error;
    1112             :         }
    1113             :     }
    1114             : 
    1115     1412051 :     link->frame_blocked_in = link->frame_wanted_out = 0;
    1116     1412051 :     link->frame_count_in++;
    1117     1412051 :     filter_unblock(link->dst);
    1118     1412051 :     ret = ff_framequeue_add(&link->fifo, frame);
    1119     1412051 :     if (ret < 0) {
    1120           0 :         av_frame_free(&frame);
    1121           0 :         return ret;
    1122             :     }
    1123     1412051 :     ff_filter_set_ready(link->dst, 300);
    1124     1412051 :     return 0;
    1125             : 
    1126           0 : error:
    1127           0 :     av_frame_free(&frame);
    1128           0 :     return AVERROR_PATCHWELCOME;
    1129             : }
    1130             : 
    1131     3010935 : static int samples_ready(AVFilterLink *link, unsigned min)
    1132             : {
    1133     5055944 :     return ff_framequeue_queued_frames(&link->fifo) &&
    1134     1023378 :            (ff_framequeue_queued_samples(&link->fifo) >= min ||
    1135         583 :             link->status_in);
    1136             : }
    1137             : 
    1138       48754 : static int take_samples(AVFilterLink *link, unsigned min, unsigned max,
    1139             :                         AVFrame **rframe)
    1140             : {
    1141             :     AVFrame *frame0, *frame, *buf;
    1142             :     unsigned nb_samples, nb_frames, i, p;
    1143             :     int ret;
    1144             : 
    1145             :     /* Note: this function relies on no format changes and must only be
    1146             :        called with enough samples. */
    1147             :     av_assert1(samples_ready(link, link->min_samples));
    1148       48754 :     frame0 = frame = ff_framequeue_peek(&link->fifo, 0);
    1149       48754 :     if (!link->fifo.samples_skipped && frame->nb_samples >= min && frame->nb_samples <= max) {
    1150        4454 :         *rframe = ff_framequeue_take(&link->fifo);
    1151        4454 :         return 0;
    1152             :     }
    1153       44300 :     nb_frames = 0;
    1154       44300 :     nb_samples = 0;
    1155             :     while (1) {
    1156       98560 :         if (nb_samples + frame->nb_samples > max) {
    1157       39708 :             if (nb_samples < min)
    1158       39708 :                 nb_samples = max;
    1159       39708 :             break;
    1160             :         }
    1161       31722 :         nb_samples += frame->nb_samples;
    1162       31722 :         nb_frames++;
    1163       31722 :         if (nb_frames == ff_framequeue_queued_frames(&link->fifo))
    1164        4592 :             break;
    1165       27130 :         frame = ff_framequeue_peek(&link->fifo, nb_frames);
    1166             :     }
    1167             : 
    1168       44300 :     buf = ff_get_audio_buffer(link, nb_samples);
    1169       44300 :     if (!buf)
    1170           0 :         return AVERROR(ENOMEM);
    1171       44300 :     ret = av_frame_copy_props(buf, frame0);
    1172       44300 :     if (ret < 0) {
    1173           0 :         av_frame_free(&buf);
    1174           0 :         return ret;
    1175             :     }
    1176       44300 :     buf->pts = frame0->pts;
    1177             : 
    1178       44300 :     p = 0;
    1179       76022 :     for (i = 0; i < nb_frames; i++) {
    1180       31722 :         frame = ff_framequeue_take(&link->fifo);
    1181       63444 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0,
    1182       63444 :                         frame->nb_samples, link->channels, link->format);
    1183       31722 :         p += frame->nb_samples;
    1184       31722 :         av_frame_free(&frame);
    1185             :     }
    1186       44300 :     if (p < nb_samples) {
    1187       39708 :         unsigned n = nb_samples - p;
    1188       39708 :         frame = ff_framequeue_peek(&link->fifo, 0);
    1189       39708 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0, n,
    1190       39708 :                         link->channels, link->format);
    1191       39708 :         ff_framequeue_skip_samples(&link->fifo, n, link->time_base);
    1192             :     }
    1193             : 
    1194       44300 :     *rframe = buf;
    1195       44300 :     return 0;
    1196             : }
    1197             : 
    1198     1022214 : static int ff_filter_frame_to_filter(AVFilterLink *link)
    1199             : {
    1200     1022214 :     AVFrame *frame = NULL;
    1201     1022214 :     AVFilterContext *dst = link->dst;
    1202             :     int ret;
    1203             : 
    1204             :     av_assert1(ff_framequeue_queued_frames(&link->fifo));
    1205     2044428 :     ret = link->min_samples ?
    1206     1022214 :           ff_inlink_consume_samples(link, link->min_samples, link->max_samples, &frame) :
    1207             :           ff_inlink_consume_frame(link, &frame);
    1208             :     av_assert1(ret);
    1209     1022214 :     if (ret < 0) {
    1210             :         av_assert1(!frame);
    1211           0 :         return ret;
    1212             :     }
    1213             :     /* The filter will soon have received a new frame, that may allow it to
    1214             :        produce one or more: unblock its outputs. */
    1215     1022214 :     filter_unblock(dst);
    1216             :     /* AVFilterPad.filter_frame() expect frame_count_out to have the value
    1217             :        before the frame; ff_filter_frame_framed() will re-increment it. */
    1218     1022214 :     link->frame_count_out--;
    1219     1022214 :     ret = ff_filter_frame_framed(link, frame);
    1220     1022214 :     if (ret < 0 && ret != link->status_out) {
    1221           0 :         ff_avfilter_link_set_out_status(link, ret, AV_NOPTS_VALUE);
    1222             :     } else {
    1223             :         /* Run once again, to see if several frames were available, or if
    1224             :            the input status has also changed, or any other reason. */
    1225     1022214 :         ff_filter_set_ready(dst, 300);
    1226             :     }
    1227     1022214 :     return ret;
    1228             : }
    1229             : 
    1230       16210 : static int forward_status_change(AVFilterContext *filter, AVFilterLink *in)
    1231             : {
    1232       16210 :     unsigned out = 0, progress = 0;
    1233             :     int ret;
    1234             : 
    1235       16210 :     av_assert0(!in->status_out);
    1236       16210 :     if (!filter->nb_outputs) {
    1237             :         /* not necessary with the current API and sinks */
    1238           0 :         return 0;
    1239             :     }
    1240       48625 :     while (!in->status_out) {
    1241       16212 :         if (!filter->outputs[out]->status_in) {
    1242       16205 :             progress++;
    1243       16205 :             ret = ff_request_frame_to_filter(filter->outputs[out]);
    1244       16205 :             if (ret < 0)
    1245           0 :                 return ret;
    1246             :         }
    1247       16212 :         if (++out == filter->nb_outputs) {
    1248       16191 :             if (!progress) {
    1249             :                 /* Every output already closed: input no longer interesting
    1250             :                    (example: overlay in shortest mode, other input closed). */
    1251           7 :                 ff_avfilter_link_set_out_status(in, in->status_in, in->status_in_pts);
    1252           7 :                 return 0;
    1253             :             }
    1254       16184 :             progress = 0;
    1255       16184 :             out = 0;
    1256             :         }
    1257             :     }
    1258       16203 :     ff_filter_set_ready(filter, 200);
    1259       16203 :     return 0;
    1260             : }
    1261             : 
    1262     3368212 : static int ff_filter_activate_default(AVFilterContext *filter)
    1263             : {
    1264             :     unsigned i;
    1265             : 
    1266     5356933 :     for (i = 0; i < filter->nb_inputs; i++) {
    1267     3010935 :         if (samples_ready(filter->inputs[i], filter->inputs[i]->min_samples)) {
    1268     1022214 :             return ff_filter_frame_to_filter(filter->inputs[i]);
    1269             :         }
    1270             :     }
    1271     4317651 :     for (i = 0; i < filter->nb_inputs; i++) {
    1272     1987863 :         if (filter->inputs[i]->status_in && !filter->inputs[i]->status_out) {
    1273             :             av_assert1(!ff_framequeue_queued_frames(&filter->inputs[i]->fifo));
    1274       16210 :             return forward_status_change(filter, filter->inputs[i]);
    1275             :         }
    1276             :     }
    1277     3373465 :     for (i = 0; i < filter->nb_outputs; i++) {
    1278     3618851 :         if (filter->outputs[i]->frame_wanted_out &&
    1279     1287670 :             !filter->outputs[i]->frame_blocked_in) {
    1280     1287504 :             return ff_request_frame_to_filter(filter->outputs[i]);
    1281             :         }
    1282             :     }
    1283     1042284 :     return FFERROR_NOT_READY;
    1284             : }
    1285             : 
    1286             : /*
    1287             :    Filter scheduling and activation
    1288             : 
    1289             :    When a filter is activated, it must:
    1290             :    - if possible, output a frame;
    1291             :    - else, if relevant, forward the input status change;
    1292             :    - else, check outputs for wanted frames and forward the requests.
    1293             : 
    1294             :    The following AVFilterLink fields are used for activation:
    1295             : 
    1296             :    - frame_wanted_out:
    1297             : 
    1298             :      This field indicates if a frame is needed on this input of the
    1299             :      destination filter. A positive value indicates that a frame is needed
    1300             :      to process queued frames or internal data or to satisfy the
    1301             :      application; a zero value indicates that a frame is not especially
    1302             :      needed but could be processed anyway; a negative value indicates that a
    1303             :      frame would just be queued.
    1304             : 
    1305             :      It is set by filters using ff_request_frame() or ff_request_no_frame(),
    1306             :      when requested by the application through a specific API or when it is
    1307             :      set on one of the outputs.
    1308             : 
    1309             :      It is cleared when a frame is sent from the source using
    1310             :      ff_filter_frame().
    1311             : 
    1312             :      It is also cleared when a status change is sent from the source using
    1313             :      ff_avfilter_link_set_in_status().
    1314             : 
    1315             :    - frame_blocked_in:
    1316             : 
    1317             :      This field means that the source filter can not generate a frame as is.
    1318             :      Its goal is to avoid repeatedly calling the request_frame() method on
    1319             :      the same link.
    1320             : 
    1321             :      It is set by the framework on all outputs of a filter before activating it.
    1322             : 
    1323             :      It is automatically cleared by ff_filter_frame().
    1324             : 
    1325             :      It is also automatically cleared by ff_avfilter_link_set_in_status().
    1326             : 
    1327             :      It is also cleared on all outputs (using filter_unblock()) when
    1328             :      something happens on an input: processing a frame or changing the
    1329             :      status.
    1330             : 
    1331             :    - fifo:
    1332             : 
    1333             :      Contains the frames queued on a filter input. If it contains frames and
    1334             :      frame_wanted_out is not set, then the filter can be activated. If that
    1335             :      result in the filter not able to use these frames, the filter must set
    1336             :      frame_wanted_out to ask for more frames.
    1337             : 
    1338             :    - status_in and status_in_pts:
    1339             : 
    1340             :      Status (EOF or error code) of the link and timestamp of the status
    1341             :      change (in link time base, same as frames) as seen from the input of
    1342             :      the link. The status change is considered happening after the frames
    1343             :      queued in fifo.
    1344             : 
    1345             :      It is set by the source filter using ff_avfilter_link_set_in_status().
    1346             : 
    1347             :    - status_out:
    1348             : 
    1349             :      Status of the link as seen from the output of the link. The status
    1350             :      change is considered having already happened.
    1351             : 
    1352             :      It is set by the destination filter using
    1353             :      ff_avfilter_link_set_out_status().
    1354             : 
    1355             :    Filters are activated according to the ready field, set using the
    1356             :    ff_filter_set_ready(). Eventually, a priority queue will be used.
    1357             :    ff_filter_set_ready() is called whenever anything could cause progress to
    1358             :    be possible. Marking a filter ready when it is not is not a problem,
    1359             :    except for the small overhead it causes.
    1360             : 
    1361             :    Conditions that cause a filter to be marked ready are:
    1362             : 
    1363             :    - frames added on an input link;
    1364             : 
    1365             :    - changes in the input or output status of an input link;
    1366             : 
    1367             :    - requests for a frame on an output link;
    1368             : 
    1369             :    - after any actual processing using the legacy methods (filter_frame(),
    1370             :      and request_frame() to acknowledge status changes), to run once more
    1371             :      and check if enough input was present for several frames.
    1372             : 
    1373             :    Exemples of scenarios to consider:
    1374             : 
    1375             :    - buffersrc: activate if frame_wanted_out to notify the application;
    1376             :      activate when the application adds a frame to push it immediately.
    1377             : 
    1378             :    - testsrc: activate only if frame_wanted_out to produce and push a frame.
    1379             : 
    1380             :    - concat (not at stitch points): can process a frame on any output.
    1381             :      Activate if frame_wanted_out on output to forward on the corresponding
    1382             :      input. Activate when a frame is present on input to process it
    1383             :      immediately.
    1384             : 
    1385             :    - framesync: needs at least one frame on each input; extra frames on the
    1386             :      wrong input will accumulate. When a frame is first added on one input,
    1387             :      set frame_wanted_out<0 on it to avoid getting more (would trigger
    1388             :      testsrc) and frame_wanted_out>0 on the other to allow processing it.
    1389             : 
    1390             :    Activation of old filters:
    1391             : 
    1392             :    In order to activate a filter implementing the legacy filter_frame() and
    1393             :    request_frame() methods, perform the first possible of the following
    1394             :    actions:
    1395             : 
    1396             :    - If an input has frames in fifo and frame_wanted_out == 0, dequeue a
    1397             :      frame and call filter_frame().
    1398             : 
    1399             :      Ratinale: filter frames as soon as possible instead of leaving them
    1400             :      queued; frame_wanted_out < 0 is not possible since the old API does not
    1401             :      set it nor provides any similar feedback; frame_wanted_out > 0 happens
    1402             :      when min_samples > 0 and there are not enough samples queued.
    1403             : 
    1404             :    - If an input has status_in set but not status_out, try to call
    1405             :      request_frame() on one of the outputs in the hope that it will trigger
    1406             :      request_frame() on the input with status_in and acknowledge it. This is
    1407             :      awkward and fragile, filters with several inputs or outputs should be
    1408             :      updated to direct activation as soon as possible.
    1409             : 
    1410             :    - If an output has frame_wanted_out > 0 and not frame_blocked_in, call
    1411             :      request_frame().
    1412             : 
    1413             :      Rationale: checking frame_blocked_in is necessary to avoid requesting
    1414             :      repeatedly on a blocked input if another is not blocked (example:
    1415             :      [buffersrc1][testsrc1][buffersrc2][testsrc2]concat=v=2).
    1416             : 
    1417             :      TODO: respect needs_fifo and remove auto-inserted fifos.
    1418             : 
    1419             :  */
    1420             : 
    1421     3766252 : int ff_filter_activate(AVFilterContext *filter)
    1422             : {
    1423             :     int ret;
    1424             : 
    1425             :     /* Generic timeline support is not yet implemented but should be easy */
    1426             :     av_assert1(!(filter->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC &&
    1427             :                  filter->filter->activate));
    1428     3766252 :     filter->ready = 0;
    1429     3766252 :     ret = filter->filter->activate ? filter->filter->activate(filter) :
    1430             :           ff_filter_activate_default(filter);
    1431     3766252 :     if (ret == FFERROR_NOT_READY)
    1432     1042285 :         ret = 0;
    1433     3766252 :     return ret;
    1434             : }
    1435             : 
    1436     2056920 : int ff_inlink_acknowledge_status(AVFilterLink *link, int *rstatus, int64_t *rpts)
    1437             : {
    1438     2056920 :     *rpts = link->current_pts;
    1439     2056920 :     if (ff_framequeue_queued_frames(&link->fifo))
    1440      148550 :         return *rstatus = 0;
    1441     1908370 :     if (link->status_out)
    1442        4648 :         return *rstatus = link->status_out;
    1443     1903722 :     if (!link->status_in)
    1444     1900317 :         return *rstatus = 0;
    1445        3405 :     *rstatus = link->status_out = link->status_in;
    1446        3405 :     ff_update_link_current_pts(link, link->status_in_pts);
    1447        3405 :     *rpts = link->current_pts;
    1448        3405 :     return 1;
    1449             : }
    1450             : 
    1451     3231436 : int ff_inlink_check_available_frame(AVFilterLink *link)
    1452             : {
    1453     3231436 :     return ff_framequeue_queued_frames(&link->fifo) > 0;
    1454             : }
    1455             : 
    1456      248374 : int ff_inlink_check_available_samples(AVFilterLink *link, unsigned min)
    1457             : {
    1458      248374 :     uint64_t samples = ff_framequeue_queued_samples(&link->fifo);
    1459             :     av_assert1(min);
    1460      248374 :     return samples >= min || (link->status_in && samples);
    1461             : }
    1462             : 
    1463     1424589 : static void consume_update(AVFilterLink *link, const AVFrame *frame)
    1464             : {
    1465     1424589 :     ff_update_link_current_pts(link, frame->pts);
    1466     1424589 :     ff_inlink_process_commands(link, frame);
    1467     1424589 :     link->dst->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1468     1424589 :     link->frame_count_out++;
    1469     1424589 : }
    1470             : 
    1471     3230958 : int ff_inlink_consume_frame(AVFilterLink *link, AVFrame **rframe)
    1472             : {
    1473             :     AVFrame *frame;
    1474             : 
    1475     3230958 :     *rframe = NULL;
    1476     3230958 :     if (!ff_inlink_check_available_frame(link))
    1477     1855122 :         return 0;
    1478             : 
    1479     1375836 :     if (link->fifo.samples_skipped) {
    1480           1 :         frame = ff_framequeue_peek(&link->fifo, 0);
    1481           1 :         return ff_inlink_consume_samples(link, frame->nb_samples, frame->nb_samples, rframe);
    1482             :     }
    1483             : 
    1484     1375835 :     frame = ff_framequeue_take(&link->fifo);
    1485     1375835 :     consume_update(link, frame);
    1486     1375835 :     *rframe = frame;
    1487     1375835 :     return 1;
    1488             : }
    1489             : 
    1490      247726 : int ff_inlink_consume_samples(AVFilterLink *link, unsigned min, unsigned max,
    1491             :                             AVFrame **rframe)
    1492             : {
    1493             :     AVFrame *frame;
    1494             :     int ret;
    1495             : 
    1496             :     av_assert1(min);
    1497      247726 :     *rframe = NULL;
    1498      247726 :     if (!ff_inlink_check_available_samples(link, min))
    1499      198972 :         return 0;
    1500       48754 :     if (link->status_in)
    1501          81 :         min = FFMIN(min, ff_framequeue_queued_samples(&link->fifo));
    1502       48754 :     ret = take_samples(link, min, max, &frame);
    1503       48754 :     if (ret < 0)
    1504           0 :         return ret;
    1505       48754 :     consume_update(link, frame);
    1506       48754 :     *rframe = frame;
    1507       48754 :     return 1;
    1508             : }
    1509             : 
    1510        3103 : int ff_inlink_make_frame_writable(AVFilterLink *link, AVFrame **rframe)
    1511             : {
    1512        3103 :     AVFrame *frame = *rframe;
    1513             :     AVFrame *out;
    1514             :     int ret;
    1515             : 
    1516        3103 :     if (av_frame_is_writable(frame))
    1517        2979 :         return 0;
    1518         124 :     av_log(link->dst, AV_LOG_DEBUG, "Copying data in avfilter.\n");
    1519             : 
    1520         124 :     switch (link->type) {
    1521         124 :     case AVMEDIA_TYPE_VIDEO:
    1522         124 :         out = ff_get_video_buffer(link, link->w, link->h);
    1523         124 :         break;
    1524           0 :     case AVMEDIA_TYPE_AUDIO:
    1525           0 :         out = ff_get_audio_buffer(link, frame->nb_samples);
    1526           0 :         break;
    1527           0 :     default:
    1528           0 :         return AVERROR(EINVAL);
    1529             :     }
    1530         124 :     if (!out)
    1531           0 :         return AVERROR(ENOMEM);
    1532             : 
    1533         124 :     ret = av_frame_copy_props(out, frame);
    1534         124 :     if (ret < 0) {
    1535           0 :         av_frame_free(&out);
    1536           0 :         return ret;
    1537             :     }
    1538             : 
    1539         124 :     switch (link->type) {
    1540         124 :     case AVMEDIA_TYPE_VIDEO:
    1541         372 :         av_image_copy(out->data, out->linesize, (const uint8_t **)frame->data, frame->linesize,
    1542         372 :                       frame->format, frame->width, frame->height);
    1543         124 :         break;
    1544           0 :     case AVMEDIA_TYPE_AUDIO:
    1545           0 :         av_samples_copy(out->extended_data, frame->extended_data,
    1546           0 :                         0, 0, frame->nb_samples,
    1547           0 :                         frame->channels,
    1548           0 :                         frame->format);
    1549           0 :         break;
    1550           0 :     default:
    1551           0 :         av_assert0(!"reached");
    1552             :     }
    1553             : 
    1554         124 :     av_frame_free(&frame);
    1555         124 :     *rframe = out;
    1556         124 :     return 0;
    1557             : }
    1558             : 
    1559     2446803 : int ff_inlink_process_commands(AVFilterLink *link, const AVFrame *frame)
    1560             : {
    1561     2446803 :     AVFilterCommand *cmd = link->dst->command_queue;
    1562             : 
    1563     4893606 :     while(cmd && cmd->time <= frame->pts * av_q2d(link->time_base)){
    1564           0 :         av_log(link->dst, AV_LOG_DEBUG,
    1565             :                "Processing command time:%f command:%s arg:%s\n",
    1566             :                cmd->time, cmd->command, cmd->arg);
    1567           0 :         avfilter_process_command(link->dst, cmd->command, cmd->arg, 0, 0, cmd->flags);
    1568           0 :         ff_command_queue_pop(link->dst);
    1569           0 :         cmd= link->dst->command_queue;
    1570             :     }
    1571     2446803 :     return 0;
    1572             : }
    1573             : 
    1574     2446803 : int ff_inlink_evaluate_timeline_at_frame(AVFilterLink *link, const AVFrame *frame)
    1575             : {
    1576     2446803 :     AVFilterContext *dstctx = link->dst;
    1577     2446803 :     int64_t pts = frame->pts;
    1578     2446803 :     int64_t pos = frame->pkt_pos;
    1579             : 
    1580     2446803 :     if (!dstctx->enable_str)
    1581     2446607 :         return 1;
    1582             : 
    1583         196 :     dstctx->var_values[VAR_N] = link->frame_count_out;
    1584         196 :     dstctx->var_values[VAR_T] = pts == AV_NOPTS_VALUE ? NAN : pts * av_q2d(link->time_base);
    1585         196 :     dstctx->var_values[VAR_W] = link->w;
    1586         196 :     dstctx->var_values[VAR_H] = link->h;
    1587         196 :     dstctx->var_values[VAR_POS] = pos == -1 ? NAN : pos;
    1588             : 
    1589         196 :     return fabs(av_expr_eval(dstctx->enable, dstctx->var_values, NULL)) >= 0.5;
    1590             : }
    1591             : 
    1592      357615 : void ff_inlink_request_frame(AVFilterLink *link)
    1593             : {
    1594             :     av_assert1(!link->status_in);
    1595             :     av_assert1(!link->status_out);
    1596      357615 :     link->frame_wanted_out = 1;
    1597      357615 :     ff_filter_set_ready(link->src, 100);
    1598      357615 : }
    1599             : 
    1600          16 : void ff_inlink_set_status(AVFilterLink *link, int status)
    1601             : {
    1602          16 :     if (link->status_out)
    1603          12 :         return;
    1604           4 :     link->frame_wanted_out = 0;
    1605           4 :     link->frame_blocked_in = 0;
    1606           4 :     ff_avfilter_link_set_out_status(link, status, AV_NOPTS_VALUE);
    1607           8 :     while (ff_framequeue_queued_frames(&link->fifo)) {
    1608           0 :            AVFrame *frame = ff_framequeue_take(&link->fifo);
    1609           0 :            av_frame_free(&frame);
    1610             :     }
    1611           4 :     if (!link->status_in)
    1612           3 :         link->status_in = status;
    1613             : }
    1614             : 
    1615        4970 : int ff_outlink_get_status(AVFilterLink *link)
    1616             : {
    1617        4970 :     return link->status_in;
    1618             : }
    1619             : 
    1620           0 : const AVClass *avfilter_get_class(void)
    1621             : {
    1622           0 :     return &avfilter_class;
    1623             : }
    1624             : 
    1625           0 : int ff_filter_init_hw_frames(AVFilterContext *avctx, AVFilterLink *link,
    1626             :                              int default_pool_size)
    1627             : {
    1628             :     AVHWFramesContext *frames;
    1629             : 
    1630             :     // Must already be set by caller.
    1631           0 :     av_assert0(link->hw_frames_ctx);
    1632             : 
    1633           0 :     frames = (AVHWFramesContext*)link->hw_frames_ctx->data;
    1634             : 
    1635           0 :     if (frames->initial_pool_size == 0) {
    1636             :         // Dynamic allocation is necessarily supported.
    1637           0 :     } else if (avctx->extra_hw_frames >= 0) {
    1638           0 :         frames->initial_pool_size += avctx->extra_hw_frames;
    1639             :     } else {
    1640           0 :         frames->initial_pool_size = default_pool_size;
    1641             :     }
    1642             : 
    1643           0 :     return 0;
    1644             : }

Generated by: LCOV version 1.13