LCOV - code coverage report
Current view: top level - src/libavfilter - avfilter.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 603 811 74.4 %
Date: 2017-03-25 17:02:41 Functions: 52 64 81.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/atomic.h"
      23             : #include "libavutil/avassert.h"
      24             : #include "libavutil/avstring.h"
      25             : #include "libavutil/buffer.h"
      26             : #include "libavutil/channel_layout.h"
      27             : #include "libavutil/common.h"
      28             : #include "libavutil/eval.h"
      29             : #include "libavutil/hwcontext.h"
      30             : #include "libavutil/imgutils.h"
      31             : #include "libavutil/internal.h"
      32             : #include "libavutil/opt.h"
      33             : #include "libavutil/pixdesc.h"
      34             : #include "libavutil/rational.h"
      35             : #include "libavutil/samplefmt.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     1394640 : 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, av_frame_get_pkt_pos(ref));
      57             : 
      58     1394640 :     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     1394640 :     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     1394640 : }
      76             : 
      77        5200 : unsigned avfilter_version(void)
      78             : {
      79             :     av_assert0(LIBAVFILTER_VERSION_MICRO >= 100);
      80        5200 :     return LIBAVFILTER_VERSION_INT;
      81             : }
      82             : 
      83        5200 : const char *avfilter_configuration(void)
      84             : {
      85        5200 :     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         122 : 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         122 :     idx = FFMIN(idx, *count);
     112             : 
     113         122 :     newpads  = av_realloc_array(*pads,  *count + 1, sizeof(AVFilterPad));
     114         122 :     newlinks = av_realloc_array(*links, *count + 1, sizeof(AVFilterLink*));
     115         122 :     if (newpads)
     116         122 :         *pads  = newpads;
     117         122 :     if (newlinks)
     118         122 :         *links = newlinks;
     119         122 :     if (!newpads || !newlinks)
     120           0 :         return AVERROR(ENOMEM);
     121             : 
     122         122 :     memmove(*pads  + idx + 1, *pads  + idx, sizeof(AVFilterPad)   * (*count - idx));
     123         122 :     memmove(*links + idx + 1, *links + idx, sizeof(AVFilterLink*) * (*count - idx));
     124         122 :     memcpy(*pads + idx, newpad, sizeof(AVFilterPad));
     125         122 :     (*links)[idx] = NULL;
     126             : 
     127         122 :     (*count)++;
     128         122 :     for (i = idx + 1; i < *count; i++)
     129           0 :         if ((*links)[i])
     130           0 :             (*(unsigned *)((uint8_t *) (*links)[i] + padidx_off))++;
     131             : 
     132         122 :     return 0;
     133             : }
     134             : 
     135       20633 : int avfilter_link(AVFilterContext *src, unsigned srcpad,
     136             :                   AVFilterContext *dst, unsigned dstpad)
     137             : {
     138             :     AVFilterLink *link;
     139             : 
     140       20633 :     av_assert0(src->graph);
     141       20633 :     av_assert0(dst->graph);
     142       20633 :     av_assert0(src->graph == dst->graph);
     143             : 
     144       41266 :     if (src->nb_outputs <= srcpad || dst->nb_inputs <= dstpad ||
     145       41266 :         src->outputs[srcpad]      || dst->inputs[dstpad])
     146           0 :         return AVERROR(EINVAL);
     147             : 
     148       20633 :     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       20633 :     link = av_mallocz(sizeof(*link));
     157       20633 :     if (!link)
     158           0 :         return AVERROR(ENOMEM);
     159             : 
     160       20633 :     src->outputs[srcpad] = dst->inputs[dstpad] = link;
     161             : 
     162       20633 :     link->src     = src;
     163       20633 :     link->dst     = dst;
     164       20633 :     link->srcpad  = &src->output_pads[srcpad];
     165       20633 :     link->dstpad  = &dst->input_pads[dstpad];
     166       20633 :     link->type    = src->output_pads[srcpad].type;
     167             :     av_assert0(AV_PIX_FMT_NONE == -1 && AV_SAMPLE_FMT_NONE == -1);
     168       20633 :     link->format  = -1;
     169       20633 :     ff_framequeue_init(&link->fifo, &src->graph->internal->frame_queues);
     170             : 
     171       20633 :     return 0;
     172             : }
     173             : 
     174       20747 : void avfilter_link_free(AVFilterLink **link)
     175             : {
     176       20747 :     if (!*link)
     177           0 :         return;
     178             : 
     179       20747 :     av_frame_free(&(*link)->partial_buf);
     180       20747 :     ff_framequeue_free(&(*link)->fifo);
     181       20747 :     ff_frame_pool_uninit((FFFramePool**)&(*link)->frame_pool);
     182             : 
     183       20747 :     av_freep(link);
     184             : }
     185             : 
     186           0 : int avfilter_link_get_channels(AVFilterLink *link)
     187             : {
     188           0 :     return link->channels;
     189             : }
     190             : 
     191     3730691 : void ff_filter_set_ready(AVFilterContext *filter, unsigned priority)
     192             : {
     193     3730691 :     filter->ready = FFMAX(filter->ready, priority);
     194     3730691 : }
     195             : 
     196             : /**
     197             :  * Clear frame_blocked_in on all outputs.
     198             :  * This is necessary whenever something changes on input.
     199             :  */
     200     2442815 : static void filter_unblock(AVFilterContext *filter)
     201             : {
     202             :     unsigned i;
     203             : 
     204     4500606 :     for (i = 0; i < filter->nb_outputs; i++)
     205     2057791 :         filter->outputs[i]->frame_blocked_in = 0;
     206     2442815 : }
     207             : 
     208             : 
     209       20367 : void ff_avfilter_link_set_in_status(AVFilterLink *link, int status, int64_t pts)
     210             : {
     211       20367 :     if (link->status_in == status)
     212           2 :         return;
     213       20365 :     av_assert0(!link->status_in);
     214       20365 :     link->status_in = status;
     215       20365 :     link->status_in_pts = pts;
     216       20365 :     link->frame_wanted_out = 0;
     217       20365 :     link->frame_blocked_in = 0;
     218       20365 :     filter_unblock(link->dst);
     219       20365 :     ff_filter_set_ready(link->dst, 200);
     220             : }
     221             : 
     222       15303 : void ff_avfilter_link_set_out_status(AVFilterLink *link, int status, int64_t pts)
     223             : {
     224       15303 :     av_assert0(!link->frame_wanted_out);
     225       15303 :     av_assert0(!link->status_out);
     226       15303 :     link->status_out = status;
     227       15303 :     if (pts != AV_NOPTS_VALUE)
     228           0 :         ff_update_link_current_pts(link, pts);
     229       15303 :     filter_unblock(link->dst);
     230       15303 :     ff_filter_set_ready(link->src, 200);
     231       15303 : }
     232             : 
     233           0 : void avfilter_link_set_closed(AVFilterLink *link, int closed)
     234             : {
     235           0 :     ff_avfilter_link_set_out_status(link, closed ? AVERROR_EOF : 0, AV_NOPTS_VALUE);
     236           0 : }
     237             : 
     238        2628 : int avfilter_insert_filter(AVFilterLink *link, AVFilterContext *filt,
     239             :                            unsigned filt_srcpad_idx, unsigned filt_dstpad_idx)
     240             : {
     241             :     int ret;
     242        2628 :     unsigned dstpad_idx = link->dstpad - link->dst->input_pads;
     243             : 
     244        5256 :     av_log(link->dst, AV_LOG_VERBOSE, "auto-inserting filter '%s' "
     245             :            "between the filter '%s' and the filter '%s'\n",
     246        5256 :            filt->name, link->src->name, link->dst->name);
     247             : 
     248        2628 :     link->dst->inputs[dstpad_idx] = NULL;
     249        2628 :     if ((ret = avfilter_link(filt, filt_dstpad_idx, link->dst, dstpad_idx)) < 0) {
     250             :         /* failed to link output filter to new filter */
     251           0 :         link->dst->inputs[dstpad_idx] = link;
     252           0 :         return ret;
     253             :     }
     254             : 
     255             :     /* re-hookup the link to the new destination filter we inserted */
     256        2628 :     link->dst                     = filt;
     257        2628 :     link->dstpad                  = &filt->input_pads[filt_srcpad_idx];
     258        2628 :     filt->inputs[filt_srcpad_idx] = link;
     259             : 
     260             :     /* if any information on supported media formats already exists on the
     261             :      * link, we need to preserve that */
     262        2628 :     if (link->out_formats)
     263        2616 :         ff_formats_changeref(&link->out_formats,
     264        2616 :                              &filt->outputs[filt_dstpad_idx]->out_formats);
     265        2628 :     if (link->out_samplerates)
     266         530 :         ff_formats_changeref(&link->out_samplerates,
     267         530 :                              &filt->outputs[filt_dstpad_idx]->out_samplerates);
     268        2628 :     if (link->out_channel_layouts)
     269         530 :         ff_channel_layouts_changeref(&link->out_channel_layouts,
     270         530 :                                      &filt->outputs[filt_dstpad_idx]->out_channel_layouts);
     271             : 
     272        2628 :     return 0;
     273             : }
     274             : 
     275       25710 : int avfilter_config_links(AVFilterContext *filter)
     276             : {
     277             :     int (*config_link)(AVFilterLink *);
     278             :     unsigned i;
     279             :     int ret;
     280             : 
     281       46303 :     for (i = 0; i < filter->nb_inputs; i ++) {
     282       20593 :         AVFilterLink *link = filter->inputs[i];
     283             :         AVFilterLink *inlink;
     284             : 
     285       20593 :         if (!link) continue;
     286       20593 :         if (!link->src || !link->dst) {
     287           0 :             av_log(filter, AV_LOG_ERROR,
     288             :                    "Not all input and output are properly linked (%d).\n", i);
     289           0 :             return AVERROR(EINVAL);
     290             :         }
     291             : 
     292       20593 :         inlink = link->src->nb_inputs ? link->src->inputs[0] : NULL;
     293       20593 :         link->current_pts =
     294       20593 :         link->current_pts_us = AV_NOPTS_VALUE;
     295             : 
     296       20593 :         switch (link->init_state) {
     297             :         case AVLINK_INIT:
     298          17 :             continue;
     299             :         case AVLINK_STARTINIT:
     300           0 :             av_log(filter, AV_LOG_INFO, "circular filter chain detected\n");
     301           0 :             return 0;
     302             :         case AVLINK_UNINIT:
     303       20576 :             link->init_state = AVLINK_STARTINIT;
     304             : 
     305       20576 :             if ((ret = avfilter_config_links(link->src)) < 0)
     306           0 :                 return ret;
     307             : 
     308       20576 :             if (!(config_link = link->srcpad->config_props)) {
     309       10809 :                 if (link->src->nb_inputs != 1) {
     310           0 :                     av_log(link->src, AV_LOG_ERROR, "Source filters and filters "
     311             :                                                     "with more than one input "
     312             :                                                     "must set config_props() "
     313             :                                                     "callbacks on all outputs\n");
     314           0 :                     return AVERROR(EINVAL);
     315             :                 }
     316        9767 :             } else if ((ret = config_link(link)) < 0) {
     317           0 :                 av_log(link->src, AV_LOG_ERROR,
     318             :                        "Failed to configure output pad on %s\n",
     319           0 :                        link->src->name);
     320           0 :                 return ret;
     321             :             }
     322             : 
     323       20576 :             switch (link->type) {
     324             :             case AVMEDIA_TYPE_VIDEO:
     325       15802 :                 if (!link->time_base.num && !link->time_base.den)
     326       11582 :                     link->time_base = inlink ? inlink->time_base : AV_TIME_BASE_Q;
     327             : 
     328       15802 :                 if (!link->sample_aspect_ratio.num && !link->sample_aspect_ratio.den)
     329        8638 :                     link->sample_aspect_ratio = inlink ?
     330             :                         inlink->sample_aspect_ratio : (AVRational){1,1};
     331             : 
     332       15802 :                 if (inlink) {
     333       11711 :                     if (!link->frame_rate.num && !link->frame_rate.den)
     334       11615 :                         link->frame_rate = inlink->frame_rate;
     335       11711 :                     if (!link->w)
     336        8310 :                         link->w = inlink->w;
     337       11711 :                     if (!link->h)
     338        8310 :                         link->h = inlink->h;
     339        4091 :                 } else if (!link->w || !link->h) {
     340           0 :                     av_log(link->src, AV_LOG_ERROR,
     341             :                            "Video source filters must set their output link's "
     342             :                            "width and height\n");
     343           0 :                     return AVERROR(EINVAL);
     344             :                 }
     345       15802 :                 break;
     346             : 
     347             :             case AVMEDIA_TYPE_AUDIO:
     348        4774 :                 if (inlink) {
     349        3706 :                     if (!link->time_base.num && !link->time_base.den)
     350        2539 :                         link->time_base = inlink->time_base;
     351             :                 }
     352             : 
     353        4774 :                 if (!link->time_base.num && !link->time_base.den)
     354           4 :                     link->time_base = (AVRational) {1, link->sample_rate};
     355             :             }
     356             : 
     357       20576 :             if (link->src->nb_inputs && link->src->inputs[0]->hw_frames_ctx &&
     358           0 :                 !link->hw_frames_ctx) {
     359           0 :                 AVHWFramesContext *input_ctx = (AVHWFramesContext*)link->src->inputs[0]->hw_frames_ctx->data;
     360             : 
     361           0 :                 if (input_ctx->format == link->format) {
     362           0 :                     link->hw_frames_ctx = av_buffer_ref(link->src->inputs[0]->hw_frames_ctx);
     363           0 :                     if (!link->hw_frames_ctx)
     364           0 :                         return AVERROR(ENOMEM);
     365             :                 }
     366             :             }
     367             : 
     368       20576 :             if ((config_link = link->dstpad->config_props))
     369        1696 :                 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       20576 :             link->init_state = AVLINK_INIT;
     377             :         }
     378             :     }
     379             : 
     380       25710 :     return 0;
     381             : }
     382             : 
     383     3703881 : void ff_tlog_link(void *ctx, AVFilterLink *link, int end)
     384             : {
     385     3703881 :     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     2828703 :         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     3703881 : }
     406             : 
     407      938920 : int ff_request_frame(AVFilterLink *link)
     408             : {
     409      938920 :     FF_TPRINTF_START(NULL, request_frame); ff_tlog_link(NULL, link, 1);
     410             : 
     411             :     av_assert1(!link->dst->filter->activate);
     412      938920 :     if (link->status_out)
     413        1143 :         return link->status_out;
     414      937777 :     if (link->status_in) {
     415       14817 :         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       14817 :             ff_avfilter_link_set_out_status(link, link->status_in, link->status_in_pts);
     424       14817 :             return link->status_out;
     425             :         }
     426             :     }
     427      922960 :     link->frame_wanted_out = 1;
     428      922960 :     ff_filter_set_ready(link->src, 100);
     429      922960 :     return 0;
     430             : }
     431             : 
     432     1292335 : static int ff_request_frame_to_filter(AVFilterLink *link)
     433             : {
     434     1292335 :     int ret = -1;
     435             : 
     436     1292335 :     FF_TPRINTF_START(NULL, request_frame_to_filter); ff_tlog_link(NULL, link, 1);
     437             :     /* Assume the filter is blocked, let the method clear it if not */
     438     1292335 :     link->frame_blocked_in = 1;
     439     1292335 :     if (link->srcpad->request_frame)
     440      579307 :         ret = link->srcpad->request_frame(link);
     441      713028 :     else if (link->src->inputs[0])
     442      713028 :         ret = ff_request_frame(link->src->inputs[0]);
     443     1292335 :     if (ret < 0) {
     444      362389 :         if (ret != AVERROR(EAGAIN) && ret != link->status_in)
     445       15288 :             ff_avfilter_link_set_in_status(link, ret, AV_NOPTS_VALUE);
     446      362389 :         if (ret == AVERROR_EOF)
     447       15288 :             ret = 0;
     448             :     }
     449     1292335 :     return ret;
     450             : }
     451             : 
     452           0 : int ff_poll_frame(AVFilterLink *link)
     453             : {
     454           0 :     int i, min = INT_MAX;
     455             : 
     456           0 :     if (link->srcpad->poll_frame)
     457           0 :         return link->srcpad->poll_frame(link);
     458             : 
     459           0 :     for (i = 0; i < link->src->nb_inputs; i++) {
     460             :         int val;
     461           0 :         if (!link->src->inputs[i])
     462           0 :             return AVERROR(EINVAL);
     463           0 :         val = ff_poll_frame(link->src->inputs[i]);
     464           0 :         min = FFMIN(min, val);
     465             :     }
     466             : 
     467           0 :     return min;
     468             : }
     469             : 
     470             : static const char *const var_names[] = {
     471             :     "t",
     472             :     "n",
     473             :     "pos",
     474             :     "w",
     475             :     "h",
     476             :     NULL
     477             : };
     478             : 
     479             : enum {
     480             :     VAR_T,
     481             :     VAR_N,
     482             :     VAR_POS,
     483             :     VAR_W,
     484             :     VAR_H,
     485             :     VAR_VARS_NB
     486             : };
     487             : 
     488           3 : static int set_enable_expr(AVFilterContext *ctx, const char *expr)
     489             : {
     490             :     int ret;
     491             :     char *expr_dup;
     492           3 :     AVExpr *old = ctx->enable;
     493             : 
     494           3 :     if (!(ctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE)) {
     495           0 :         av_log(ctx, AV_LOG_ERROR, "Timeline ('enable' option) not supported "
     496           0 :                "with filter '%s'\n", ctx->filter->name);
     497           0 :         return AVERROR_PATCHWELCOME;
     498             :     }
     499             : 
     500           3 :     expr_dup = av_strdup(expr);
     501           3 :     if (!expr_dup)
     502           0 :         return AVERROR(ENOMEM);
     503             : 
     504           3 :     if (!ctx->var_values) {
     505           3 :         ctx->var_values = av_calloc(VAR_VARS_NB, sizeof(*ctx->var_values));
     506           3 :         if (!ctx->var_values) {
     507           0 :             av_free(expr_dup);
     508           0 :             return AVERROR(ENOMEM);
     509             :         }
     510             :     }
     511             : 
     512           3 :     ret = av_expr_parse((AVExpr**)&ctx->enable, expr_dup, var_names,
     513             :                         NULL, NULL, NULL, NULL, 0, ctx->priv);
     514           3 :     if (ret < 0) {
     515           0 :         av_log(ctx->priv, AV_LOG_ERROR,
     516             :                "Error when evaluating the expression '%s' for enable\n",
     517             :                expr_dup);
     518           0 :         av_free(expr_dup);
     519           0 :         return ret;
     520             :     }
     521             : 
     522           3 :     av_expr_free(old);
     523           3 :     av_free(ctx->enable_str);
     524           3 :     ctx->enable_str = expr_dup;
     525           3 :     return 0;
     526             : }
     527             : 
     528     1404544 : void ff_update_link_current_pts(AVFilterLink *link, int64_t pts)
     529             : {
     530     1404544 :     if (pts == AV_NOPTS_VALUE)
     531        4220 :         return;
     532     1400324 :     link->current_pts = pts;
     533     1400324 :     link->current_pts_us = av_rescale_q(pts, link->time_base, AV_TIME_BASE_Q);
     534             :     /* TODO use duration */
     535     1400324 :     if (link->graph && link->age_index >= 0)
     536      388499 :         ff_avfilter_graph_update_heap(link->graph, link);
     537             : }
     538             : 
     539           0 : int avfilter_process_command(AVFilterContext *filter, const char *cmd, const char *arg, char *res, int res_len, int flags)
     540             : {
     541           0 :     if(!strcmp(cmd, "ping")){
     542           0 :         char local_res[256] = {0};
     543             : 
     544           0 :         if (!res) {
     545           0 :             res = local_res;
     546           0 :             res_len = sizeof(local_res);
     547             :         }
     548           0 :         av_strlcatf(res, res_len, "pong from:%s %s\n", filter->filter->name, filter->name);
     549           0 :         if (res == local_res)
     550           0 :             av_log(filter, AV_LOG_INFO, "%s", res);
     551           0 :         return 0;
     552           0 :     }else if(!strcmp(cmd, "enable")) {
     553           0 :         return set_enable_expr(filter, arg);
     554           0 :     }else if(filter->filter->process_command) {
     555           0 :         return filter->filter->process_command(filter, cmd, arg, res, res_len, flags);
     556             :     }
     557           0 :     return AVERROR(ENOSYS);
     558             : }
     559             : 
     560             : static AVFilter *first_filter;
     561             : static AVFilter **last_filter = &first_filter;
     562             : 
     563             : #if !FF_API_NOCONST_GET_NAME
     564             : const
     565             : #endif
     566       25862 : AVFilter *avfilter_get_by_name(const char *name)
     567             : {
     568       25862 :     const AVFilter *f = NULL;
     569             : 
     570       25862 :     if (!name)
     571           0 :         return NULL;
     572             : 
     573     5214251 :     while ((f = avfilter_next(f)))
     574     5188389 :         if (!strcmp(f->name, name))
     575       25862 :             return (AVFilter *)f;
     576             : 
     577           0 :     return NULL;
     578             : }
     579             : 
     580     1567200 : int avfilter_register(AVFilter *filter)
     581             : {
     582     1567200 :     AVFilter **f = last_filter;
     583             : 
     584             :     /* the filter must select generic or internal exclusively */
     585     1567200 :     av_assert0((filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE) != AVFILTER_FLAG_SUPPORT_TIMELINE);
     586             : 
     587     1567200 :     filter->next = NULL;
     588             : 
     589     3134400 :     while(*f || avpriv_atomic_ptr_cas((void * volatile *)f, NULL, filter))
     590           0 :         f = &(*f)->next;
     591     1567200 :     last_filter = &filter->next;
     592             : 
     593     1567200 :     return 0;
     594             : }
     595             : 
     596     5188389 : const AVFilter *avfilter_next(const AVFilter *prev)
     597             : {
     598     5188389 :     return prev ? prev->next : first_filter;
     599             : }
     600             : 
     601             : #if FF_API_OLD_FILTER_REGISTER
     602           0 : AVFilter **av_filter_next(AVFilter **filter)
     603             : {
     604           0 :     return filter ? &(*filter)->next : &first_filter;
     605             : }
     606             : 
     607           0 : void avfilter_uninit(void)
     608             : {
     609           0 : }
     610             : #endif
     611             : 
     612       51692 : int avfilter_pad_count(const AVFilterPad *pads)
     613             : {
     614             :     int count;
     615             : 
     616       51692 :     if (!pads)
     617       10378 :         return 0;
     618             : 
     619       82674 :     for (count = 0; pads->name; count++)
     620       41360 :         pads++;
     621       41314 :     return count;
     622             : }
     623             : 
     624         255 : static const char *default_filter_name(void *filter_ctx)
     625             : {
     626         255 :     AVFilterContext *ctx = filter_ctx;
     627         255 :     return ctx->name ? ctx->name : ctx->filter->name;
     628             : }
     629             : 
     630        1225 : static void *filter_child_next(void *obj, void *prev)
     631             : {
     632        1225 :     AVFilterContext *ctx = obj;
     633        1225 :     if (!prev && ctx->filter && ctx->filter->priv_class && ctx->priv)
     634        1225 :         return ctx->priv;
     635           0 :     return NULL;
     636             : }
     637             : 
     638           0 : static const AVClass *filter_child_class_next(const AVClass *prev)
     639             : {
     640           0 :     const AVFilter *f = NULL;
     641             : 
     642             :     /* find the filter that corresponds to prev */
     643           0 :     while (prev && (f = avfilter_next(f)))
     644           0 :         if (f->priv_class == prev)
     645           0 :             break;
     646             : 
     647             :     /* could not find filter corresponding to prev */
     648           0 :     if (prev && !f)
     649           0 :         return NULL;
     650             : 
     651             :     /* find next filter with specific options */
     652           0 :     while ((f = avfilter_next(f)))
     653           0 :         if (f->priv_class)
     654           0 :             return f->priv_class;
     655             : 
     656           0 :     return NULL;
     657             : }
     658             : 
     659             : #define OFFSET(x) offsetof(AVFilterContext, x)
     660             : #define FLAGS AV_OPT_FLAG_FILTERING_PARAM
     661             : static const AVOption avfilter_options[] = {
     662             :     { "thread_type", "Allowed thread types", OFFSET(thread_type), AV_OPT_TYPE_FLAGS,
     663             :         { .i64 = AVFILTER_THREAD_SLICE }, 0, INT_MAX, FLAGS, "thread_type" },
     664             :         { "slice", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AVFILTER_THREAD_SLICE }, .unit = "thread_type" },
     665             :     { "enable", "set enable expression", OFFSET(enable_str), AV_OPT_TYPE_STRING, {.str=NULL}, .flags = FLAGS },
     666             :     { "threads", "Allowed number of threads", OFFSET(nb_threads), AV_OPT_TYPE_INT,
     667             :         { .i64 = 0 }, 0, INT_MAX, FLAGS },
     668             :     { NULL },
     669             : };
     670             : 
     671             : static const AVClass avfilter_class = {
     672             :     .class_name = "AVFilter",
     673             :     .item_name  = default_filter_name,
     674             :     .version    = LIBAVUTIL_VERSION_INT,
     675             :     .category   = AV_CLASS_CATEGORY_FILTER,
     676             :     .child_next = filter_child_next,
     677             :     .child_class_next = filter_child_class_next,
     678             :     .option           = avfilter_options,
     679             : };
     680             : 
     681         283 : static int default_execute(AVFilterContext *ctx, avfilter_action_func *func, void *arg,
     682             :                            int *ret, int nb_jobs)
     683             : {
     684             :     int i;
     685             : 
     686         566 :     for (i = 0; i < nb_jobs; i++) {
     687         283 :         int r = func(ctx, arg, i, nb_jobs);
     688         283 :         if (ret)
     689           0 :             ret[i] = r;
     690             :     }
     691         283 :     return 0;
     692             : }
     693             : 
     694       25846 : AVFilterContext *ff_filter_alloc(const AVFilter *filter, const char *inst_name)
     695             : {
     696             :     AVFilterContext *ret;
     697             : 
     698       25846 :     if (!filter)
     699           0 :         return NULL;
     700             : 
     701       25846 :     ret = av_mallocz(sizeof(AVFilterContext));
     702       25846 :     if (!ret)
     703           0 :         return NULL;
     704             : 
     705       25846 :     ret->av_class = &avfilter_class;
     706       25846 :     ret->filter   = filter;
     707       25846 :     ret->name     = inst_name ? av_strdup(inst_name) : NULL;
     708       25846 :     if (filter->priv_size) {
     709       22660 :         ret->priv     = av_mallocz(filter->priv_size);
     710       22660 :         if (!ret->priv)
     711           0 :             goto err;
     712             :     }
     713             : 
     714       25846 :     av_opt_set_defaults(ret);
     715       25846 :     if (filter->priv_class) {
     716       22481 :         *(const AVClass**)ret->priv = filter->priv_class;
     717       22481 :         av_opt_set_defaults(ret->priv);
     718             :     }
     719             : 
     720       25846 :     ret->internal = av_mallocz(sizeof(*ret->internal));
     721       25846 :     if (!ret->internal)
     722           0 :         goto err;
     723       25846 :     ret->internal->execute = default_execute;
     724             : 
     725       25846 :     ret->nb_inputs = avfilter_pad_count(filter->inputs);
     726       25846 :     if (ret->nb_inputs ) {
     727       20648 :         ret->input_pads   = av_malloc_array(ret->nb_inputs, sizeof(AVFilterPad));
     728       20648 :         if (!ret->input_pads)
     729           0 :             goto err;
     730       20648 :         memcpy(ret->input_pads, filter->inputs, sizeof(AVFilterPad) * ret->nb_inputs);
     731       20648 :         ret->inputs       = av_mallocz_array(ret->nb_inputs, sizeof(AVFilterLink*));
     732       20648 :         if (!ret->inputs)
     733           0 :             goto err;
     734             :     }
     735             : 
     736       25846 :     ret->nb_outputs = avfilter_pad_count(filter->outputs);
     737       25846 :     if (ret->nb_outputs) {
     738       20666 :         ret->output_pads  = av_malloc_array(ret->nb_outputs, sizeof(AVFilterPad));
     739       20666 :         if (!ret->output_pads)
     740           0 :             goto err;
     741       20666 :         memcpy(ret->output_pads, filter->outputs, sizeof(AVFilterPad) * ret->nb_outputs);
     742       20666 :         ret->outputs      = av_mallocz_array(ret->nb_outputs, sizeof(AVFilterLink*));
     743       20666 :         if (!ret->outputs)
     744           0 :             goto err;
     745             :     }
     746             : 
     747       25846 :     return ret;
     748             : 
     749             : err:
     750           0 :     av_freep(&ret->inputs);
     751           0 :     av_freep(&ret->input_pads);
     752           0 :     ret->nb_inputs = 0;
     753           0 :     av_freep(&ret->outputs);
     754           0 :     av_freep(&ret->output_pads);
     755           0 :     ret->nb_outputs = 0;
     756           0 :     av_freep(&ret->priv);
     757           0 :     av_freep(&ret->internal);
     758           0 :     av_free(ret);
     759           0 :     return NULL;
     760             : }
     761             : 
     762             : #if FF_API_AVFILTER_OPEN
     763           0 : int avfilter_open(AVFilterContext **filter_ctx, AVFilter *filter, const char *inst_name)
     764             : {
     765           0 :     *filter_ctx = ff_filter_alloc(filter, inst_name);
     766           0 :     return *filter_ctx ? 0 : AVERROR(ENOMEM);
     767             : }
     768             : #endif
     769             : 
     770       41482 : static void free_link(AVFilterLink *link)
     771             : {
     772       41482 :     if (!link)
     773       20735 :         return;
     774             : 
     775       20747 :     if (link->src)
     776       20633 :         link->src->outputs[link->srcpad - link->src->output_pads] = NULL;
     777       20747 :     if (link->dst)
     778       20633 :         link->dst->inputs[link->dstpad - link->dst->input_pads] = NULL;
     779             : 
     780       20747 :     av_buffer_unref(&link->hw_frames_ctx);
     781             : 
     782       20747 :     ff_formats_unref(&link->in_formats);
     783       20747 :     ff_formats_unref(&link->out_formats);
     784       20747 :     ff_formats_unref(&link->in_samplerates);
     785       20747 :     ff_formats_unref(&link->out_samplerates);
     786       20747 :     ff_channel_layouts_unref(&link->in_channel_layouts);
     787       20747 :     ff_channel_layouts_unref(&link->out_channel_layouts);
     788       20747 :     avfilter_link_free(&link);
     789             : }
     790             : 
     791       25846 : void avfilter_free(AVFilterContext *filter)
     792             : {
     793             :     int i;
     794             : 
     795       25846 :     if (!filter)
     796           0 :         return;
     797             : 
     798       25846 :     if (filter->graph)
     799       25846 :         ff_filter_graph_remove_filter(filter->graph, filter);
     800             : 
     801       25846 :     if (filter->filter->uninit)
     802       14626 :         filter->filter->uninit(filter);
     803             : 
     804       46592 :     for (i = 0; i < filter->nb_inputs; i++) {
     805       20746 :         free_link(filter->inputs[i]);
     806             :     }
     807       46582 :     for (i = 0; i < filter->nb_outputs; i++) {
     808       20736 :         free_link(filter->outputs[i]);
     809             :     }
     810             : 
     811       25846 :     if (filter->filter->priv_class)
     812       22481 :         av_opt_free(filter->priv);
     813             : 
     814       25846 :     av_buffer_unref(&filter->hw_device_ctx);
     815             : 
     816       25846 :     av_freep(&filter->name);
     817       25846 :     av_freep(&filter->input_pads);
     818       25846 :     av_freep(&filter->output_pads);
     819       25846 :     av_freep(&filter->inputs);
     820       25846 :     av_freep(&filter->outputs);
     821       25846 :     av_freep(&filter->priv);
     822       51692 :     while(filter->command_queue){
     823           0 :         ff_command_queue_pop(filter);
     824             :     }
     825       25846 :     av_opt_free(filter);
     826       25846 :     av_expr_free(filter->enable);
     827       25846 :     filter->enable = NULL;
     828       25846 :     av_freep(&filter->var_values);
     829       25846 :     av_freep(&filter->internal);
     830       25846 :     av_free(filter);
     831             : }
     832             : 
     833        2362 : int ff_filter_get_nb_threads(AVFilterContext *ctx)
     834             : {
     835        2362 :      if (ctx->nb_threads > 0)
     836           0 :          return FFMIN(ctx->nb_threads, ctx->graph->nb_threads);
     837        2362 :      return ctx->graph->nb_threads;
     838             : }
     839             : 
     840       16195 : static int process_options(AVFilterContext *ctx, AVDictionary **options,
     841             :                            const char *args)
     842             : {
     843       16195 :     const AVOption *o = NULL;
     844       16195 :     int ret, count = 0;
     845       16195 :     char *av_uninit(parsed_key), *av_uninit(value);
     846             :     const char *key;
     847       16195 :     int offset= -1;
     848             : 
     849       16195 :     if (!args)
     850           0 :         return 0;
     851             : 
     852      115288 :     while (*args) {
     853       82898 :         const char *shorthand = NULL;
     854             : 
     855       82898 :         o = av_opt_next(ctx->priv, o);
     856       82898 :         if (o) {
     857       80851 :             if (o->type == AV_OPT_TYPE_CONST || o->offset == offset)
     858       35429 :                 continue;
     859       45422 :             offset = o->offset;
     860       45422 :             shorthand = o->name;
     861             :         }
     862             : 
     863       47469 :         ret = av_opt_get_key_value(&args, "=", ":",
     864             :                                    shorthand ? AV_OPT_FLAG_IMPLICIT_KEY : 0,
     865             :                                    &parsed_key, &value);
     866       47469 :         if (ret < 0) {
     867           0 :             if (ret == AVERROR(EINVAL))
     868           0 :                 av_log(ctx, AV_LOG_ERROR, "No option name near '%s'\n", args);
     869             :             else
     870           0 :                 av_log(ctx, AV_LOG_ERROR, "Unable to parse '%s': %s\n", args,
     871           0 :                        av_err2str(ret));
     872           0 :             return ret;
     873             :         }
     874       47469 :         if (*args)
     875       32326 :             args++;
     876       47469 :         if (parsed_key) {
     877       38615 :             key = parsed_key;
     878       38615 :             while ((o = av_opt_next(ctx->priv, o))); /* discard all remaining shorthand */
     879             :         } else {
     880        8854 :             key = shorthand;
     881             :         }
     882             : 
     883       47469 :         av_log(ctx, AV_LOG_DEBUG, "Setting '%s' to value '%s'\n", key, value);
     884             : 
     885       47469 :         if (av_opt_find(ctx, key, NULL, 0, 0)) {
     886           3 :             ret = av_opt_set(ctx, key, value, 0);
     887           3 :             if (ret < 0) {
     888           0 :                 av_free(value);
     889           0 :                 av_free(parsed_key);
     890           0 :                 return ret;
     891             :             }
     892             :         } else {
     893       47466 :         av_dict_set(options, key, value, 0);
     894       47466 :         if ((ret = av_opt_set(ctx->priv, key, value, 0)) < 0) {
     895        4739 :             if (!av_opt_find(ctx->priv, key, NULL, 0, AV_OPT_SEARCH_CHILDREN | AV_OPT_SEARCH_FAKE_OBJ)) {
     896           0 :             if (ret == AVERROR_OPTION_NOT_FOUND)
     897           0 :                 av_log(ctx, AV_LOG_ERROR, "Option '%s' not found\n", key);
     898           0 :             av_free(value);
     899           0 :             av_free(parsed_key);
     900           0 :             return ret;
     901             :             }
     902             :         }
     903             :         }
     904             : 
     905       47469 :         av_free(value);
     906       47469 :         av_free(parsed_key);
     907       47469 :         count++;
     908             :     }
     909             : 
     910       16195 :     if (ctx->enable_str) {
     911           3 :         ret = set_enable_expr(ctx, ctx->enable_str);
     912           3 :         if (ret < 0)
     913           0 :             return ret;
     914             :     }
     915       16195 :     return count;
     916             : }
     917             : 
     918             : #if FF_API_AVFILTER_INIT_FILTER
     919           0 : int avfilter_init_filter(AVFilterContext *filter, const char *args, void *opaque)
     920             : {
     921           0 :     return avfilter_init_str(filter, args);
     922             : }
     923             : #endif
     924             : 
     925       25846 : int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
     926             : {
     927       25846 :     int ret = 0;
     928             : 
     929       25846 :     ret = av_opt_set_dict(ctx, options);
     930       25846 :     if (ret < 0) {
     931           0 :         av_log(ctx, AV_LOG_ERROR, "Error applying generic filter options.\n");
     932           0 :         return ret;
     933             :     }
     934             : 
     935       26100 :     if (ctx->filter->flags & AVFILTER_FLAG_SLICE_THREADS &&
     936         328 :         ctx->thread_type & ctx->graph->thread_type & AVFILTER_THREAD_SLICE &&
     937          74 :         ctx->graph->internal->thread_execute) {
     938          74 :         ctx->thread_type       = AVFILTER_THREAD_SLICE;
     939          74 :         ctx->internal->execute = ctx->graph->internal->thread_execute;
     940             :     } else {
     941       25772 :         ctx->thread_type = 0;
     942             :     }
     943             : 
     944       25846 :     if (ctx->filter->priv_class) {
     945       22481 :         ret = av_opt_set_dict(ctx->priv, options);
     946       22481 :         if (ret < 0) {
     947           0 :             av_log(ctx, AV_LOG_ERROR, "Error applying options to the filter.\n");
     948           0 :             return ret;
     949             :         }
     950             :     }
     951             : 
     952       25846 :     if (ctx->filter->init_opaque)
     953        5134 :         ret = ctx->filter->init_opaque(ctx, NULL);
     954       20712 :     else if (ctx->filter->init)
     955       12051 :         ret = ctx->filter->init(ctx);
     956        8661 :     else if (ctx->filter->init_dict)
     957        4066 :         ret = ctx->filter->init_dict(ctx, options);
     958             : 
     959       25846 :     return ret;
     960             : }
     961             : 
     962       25846 : int avfilter_init_str(AVFilterContext *filter, const char *args)
     963             : {
     964       25846 :     AVDictionary *options = NULL;
     965             :     AVDictionaryEntry *e;
     966       25846 :     int ret = 0;
     967             : 
     968       25846 :     if (args && *args) {
     969       16195 :         if (!filter->filter->priv_class) {
     970           0 :             av_log(filter, AV_LOG_ERROR, "This filter does not take any "
     971             :                    "options, but options were provided: %s.\n", args);
     972           0 :             return AVERROR(EINVAL);
     973             :         }
     974             : 
     975             : #if FF_API_OLD_FILTER_OPTS || FF_API_OLD_FILTER_OPTS_ERROR
     976       27743 :             if (   !strcmp(filter->filter->name, "format")     ||
     977       23096 :                    !strcmp(filter->filter->name, "noformat")   ||
     978       23096 :                    !strcmp(filter->filter->name, "frei0r")     ||
     979       23096 :                    !strcmp(filter->filter->name, "frei0r_src") ||
     980       23096 :                    !strcmp(filter->filter->name, "ocv")        ||
     981       23092 :                    !strcmp(filter->filter->name, "pan")        ||
     982       23080 :                    !strcmp(filter->filter->name, "pp")         ||
     983       16199 :                    !strcmp(filter->filter->name, "aevalsrc")) {
     984             :             /* a hack for compatibility with the old syntax
     985             :              * replace colons with |s */
     986        4663 :             char *copy = av_strdup(args);
     987        4663 :             char *p    = copy;
     988        4663 :             int nb_leading = 0; // number of leading colons to skip
     989        4663 :             int deprecated = 0;
     990             : 
     991        4663 :             if (!copy) {
     992           0 :                 ret = AVERROR(ENOMEM);
     993           0 :                 goto fail;
     994             :             }
     995             : 
     996        9326 :             if (!strcmp(filter->filter->name, "frei0r") ||
     997        4663 :                 !strcmp(filter->filter->name, "ocv"))
     998           0 :                 nb_leading = 1;
     999        4663 :             else if (!strcmp(filter->filter->name, "frei0r_src"))
    1000           0 :                 nb_leading = 3;
    1001             : 
    1002        9326 :             while (nb_leading--) {
    1003           0 :                 p = strchr(p, ':');
    1004           0 :                 if (!p) {
    1005           0 :                     p = copy + strlen(copy);
    1006           0 :                     break;
    1007             :                 }
    1008           0 :                 p++;
    1009             :             }
    1010             : 
    1011        4663 :             deprecated = strchr(p, ':') != NULL;
    1012             : 
    1013        4663 :             if (!strcmp(filter->filter->name, "aevalsrc")) {
    1014           4 :                 deprecated = 0;
    1015           8 :                 while ((p = strchr(p, ':')) && p[1] != ':') {
    1016           1 :                     const char *epos = strchr(p + 1, '=');
    1017           1 :                     const char *spos = strchr(p + 1, ':');
    1018           1 :                     const int next_token_is_opt = epos && (!spos || epos < spos);
    1019           1 :                     if (next_token_is_opt) {
    1020           1 :                         p++;
    1021           1 :                         break;
    1022             :                     }
    1023             :                     /* next token does not contain a '=', assume a channel expression */
    1024           0 :                     deprecated = 1;
    1025           0 :                     *p++ = '|';
    1026             :                 }
    1027           4 :                 if (p && *p == ':') { // double sep '::' found
    1028           3 :                     deprecated = 1;
    1029           3 :                     memmove(p, p + 1, strlen(p));
    1030             :                 }
    1031             :             } else
    1032        9318 :             while ((p = strchr(p, ':')))
    1033           0 :                 *p++ = '|';
    1034             : 
    1035             : #if FF_API_OLD_FILTER_OPTS
    1036        4663 :             if (deprecated)
    1037           3 :                 av_log(filter, AV_LOG_WARNING, "This syntax is deprecated. Use "
    1038             :                        "'|' to separate the list items.\n");
    1039             : 
    1040        4663 :             av_log(filter, AV_LOG_DEBUG, "compat: called with args=[%s]\n", copy);
    1041        4663 :             ret = process_options(filter, &options, copy);
    1042             : #else
    1043             :             if (deprecated) {
    1044             :                 av_log(filter, AV_LOG_ERROR, "This syntax is deprecated. Use "
    1045             :                        "'|' to separate the list items ('%s' instead of '%s')\n",
    1046             :                        copy, args);
    1047             :                 ret = AVERROR(EINVAL);
    1048             :             } else {
    1049             :                 ret = process_options(filter, &options, copy);
    1050             :             }
    1051             : #endif
    1052        4663 :             av_freep(&copy);
    1053             : 
    1054        4663 :             if (ret < 0)
    1055           0 :                 goto fail;
    1056             :         } else
    1057             : #endif
    1058             :         {
    1059       11532 :             ret = process_options(filter, &options, args);
    1060       11532 :             if (ret < 0)
    1061           0 :                 goto fail;
    1062             :         }
    1063             :     }
    1064             : 
    1065       25846 :     ret = avfilter_init_dict(filter, &options);
    1066       25846 :     if (ret < 0)
    1067           0 :         goto fail;
    1068             : 
    1069       25846 :     if ((e = av_dict_get(options, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
    1070           0 :         av_log(filter, AV_LOG_ERROR, "No such option: %s.\n", e->key);
    1071           0 :         ret = AVERROR_OPTION_NOT_FOUND;
    1072           0 :         goto fail;
    1073             :     }
    1074             : 
    1075             : fail:
    1076       25846 :     av_dict_free(&options);
    1077             : 
    1078       25846 :     return ret;
    1079             : }
    1080             : 
    1081       14778 : const char *avfilter_pad_get_name(const AVFilterPad *pads, int pad_idx)
    1082             : {
    1083       14778 :     return pads[pad_idx].name;
    1084             : }
    1085             : 
    1086       20712 : enum AVMediaType avfilter_pad_get_type(const AVFilterPad *pads, int pad_idx)
    1087             : {
    1088       20712 :     return pads[pad_idx].type;
    1089             : }
    1090             : 
    1091      695697 : static int default_filter_frame(AVFilterLink *link, AVFrame *frame)
    1092             : {
    1093      695697 :     return ff_filter_frame(link->dst->outputs[0], frame);
    1094             : }
    1095             : 
    1096     1012507 : static int ff_filter_frame_framed(AVFilterLink *link, AVFrame *frame)
    1097             : {
    1098             :     int (*filter_frame)(AVFilterLink *, AVFrame *);
    1099     1012507 :     AVFilterContext *dstctx = link->dst;
    1100     1012507 :     AVFilterPad *dst = link->dstpad;
    1101             :     int ret;
    1102             : 
    1103     1012507 :     if (!(filter_frame = dst->filter_frame))
    1104      695691 :         filter_frame = default_filter_frame;
    1105             : 
    1106     1012507 :     if (dst->needs_writable) {
    1107        2998 :         ret = ff_inlink_make_frame_writable(link, &frame);
    1108        2998 :         if (ret < 0)
    1109           0 :             goto fail;
    1110             :     }
    1111             : 
    1112     1012507 :     ff_inlink_process_commands(link, frame);
    1113     1012507 :     dstctx->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1114             : 
    1115     1012523 :     if (dstctx->is_disabled &&
    1116          16 :         (dstctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC))
    1117           6 :         filter_frame = default_filter_frame;
    1118     1012507 :     ret = filter_frame(link, frame);
    1119     1012507 :     link->frame_count_out++;
    1120     1012507 :     return ret;
    1121             : 
    1122             : fail:
    1123           0 :     av_frame_free(&frame);
    1124           0 :     return ret;
    1125             : }
    1126             : 
    1127     1394640 : int ff_filter_frame(AVFilterLink *link, AVFrame *frame)
    1128             : {
    1129             :     int ret;
    1130     1394640 :     FF_TPRINTF_START(NULL, filter_frame); ff_tlog_link(NULL, link, 1); ff_tlog(NULL, " "); ff_tlog_ref(NULL, frame, 1);
    1131             : 
    1132             :     /* Consistency checks */
    1133     1394640 :     if (link->type == AVMEDIA_TYPE_VIDEO) {
    1134      498690 :         if (strcmp(link->dst->filter->name, "buffersink") &&
    1135      348598 :             strcmp(link->dst->filter->name, "format") &&
    1136      293376 :             strcmp(link->dst->filter->name, "idet") &&
    1137      146675 :             strcmp(link->dst->filter->name, "null") &&
    1138       59502 :             strcmp(link->dst->filter->name, "scale")) {
    1139             :             av_assert1(frame->format                 == link->format);
    1140             :             av_assert1(frame->width               == link->w);
    1141             :             av_assert1(frame->height               == link->h);
    1142             :         }
    1143             :     } else {
    1144     1097847 :         if (frame->format != link->format) {
    1145           0 :             av_log(link->dst, AV_LOG_ERROR, "Format change is not supported\n");
    1146           0 :             goto error;
    1147             :         }
    1148     1097847 :         if (av_frame_get_channels(frame) != link->channels) {
    1149           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel count change is not supported\n");
    1150           0 :             goto error;
    1151             :         }
    1152     1097847 :         if (frame->channel_layout != link->channel_layout) {
    1153           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel layout change is not supported\n");
    1154           0 :             goto error;
    1155             :         }
    1156     1097847 :         if (frame->sample_rate != link->sample_rate) {
    1157           0 :             av_log(link->dst, AV_LOG_ERROR, "Sample rate change is not supported\n");
    1158           0 :             goto error;
    1159             :         }
    1160             :     }
    1161             : 
    1162     1394640 :     link->frame_blocked_in = link->frame_wanted_out = 0;
    1163     1394640 :     link->frame_count_in++;
    1164     1394640 :     filter_unblock(link->dst);
    1165     1394640 :     ret = ff_framequeue_add(&link->fifo, frame);
    1166     1394640 :     if (ret < 0) {
    1167           0 :         av_frame_free(&frame);
    1168           0 :         return ret;
    1169             :     }
    1170     1394640 :     ff_filter_set_ready(link->dst, 300);
    1171     1394640 :     return 0;
    1172             : 
    1173             : error:
    1174           0 :     av_frame_free(&frame);
    1175           0 :     return AVERROR_PATCHWELCOME;
    1176             : }
    1177             : 
    1178     2987712 : static int samples_ready(AVFilterLink *link, unsigned min)
    1179             : {
    1180     5013307 :     return ff_framequeue_queued_frames(&link->fifo) &&
    1181     1013671 :            (ff_framequeue_queued_samples(&link->fifo) >= min ||
    1182         583 :             link->status_in);
    1183             : }
    1184             : 
    1185       42367 : static int take_samples(AVFilterLink *link, unsigned min, unsigned max,
    1186             :                         AVFrame **rframe)
    1187             : {
    1188             :     AVFrame *frame0, *frame, *buf;
    1189             :     unsigned nb_samples, nb_frames, i, p;
    1190             :     int ret;
    1191             : 
    1192             :     /* Note: this function relies on no format changes and must only be
    1193             :        called with enough samples. */
    1194             :     av_assert1(samples_ready(link, link->min_samples));
    1195       42367 :     frame0 = frame = ff_framequeue_peek(&link->fifo, 0);
    1196       42367 :     if (frame->nb_samples >= min && frame->nb_samples < max) {
    1197          28 :         *rframe = ff_framequeue_take(&link->fifo);
    1198          28 :         return 0;
    1199             :     }
    1200       42339 :     nb_frames = 0;
    1201       42339 :     nb_samples = 0;
    1202             :     while (1) {
    1203       95211 :         if (nb_samples + frame->nb_samples > max) {
    1204       33170 :             if (nb_samples < min)
    1205       33170 :                 nb_samples = max;
    1206       33170 :             break;
    1207             :         }
    1208       35605 :         nb_samples += frame->nb_samples;
    1209       35605 :         nb_frames++;
    1210       35605 :         if (nb_frames == ff_framequeue_queued_frames(&link->fifo))
    1211        9169 :             break;
    1212       26436 :         frame = ff_framequeue_peek(&link->fifo, nb_frames);
    1213             :     }
    1214             : 
    1215       42339 :     buf = ff_get_audio_buffer(link, nb_samples);
    1216       42339 :     if (!buf)
    1217           0 :         return AVERROR(ENOMEM);
    1218       42339 :     ret = av_frame_copy_props(buf, frame0);
    1219       42339 :     if (ret < 0) {
    1220           0 :         av_frame_free(&buf);
    1221           0 :         return ret;
    1222             :     }
    1223       42339 :     buf->pts = frame0->pts;
    1224             : 
    1225       42339 :     p = 0;
    1226       77944 :     for (i = 0; i < nb_frames; i++) {
    1227       35605 :         frame = ff_framequeue_take(&link->fifo);
    1228       71210 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0,
    1229       71210 :                         frame->nb_samples, link->channels, link->format);
    1230       35605 :         p += frame->nb_samples;
    1231       35605 :         av_frame_free(&frame);
    1232             :     }
    1233       42339 :     if (p < nb_samples) {
    1234       33170 :         unsigned n = nb_samples - p;
    1235       33170 :         frame = ff_framequeue_peek(&link->fifo, 0);
    1236       33170 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0, n,
    1237       33170 :                         link->channels, link->format);
    1238       33170 :         ff_framequeue_skip_samples(&link->fifo, n, link->time_base);
    1239             :     }
    1240             : 
    1241       42339 :     *rframe = buf;
    1242       42339 :     return 0;
    1243             : }
    1244             : 
    1245     1012507 : static int ff_filter_frame_to_filter(AVFilterLink *link)
    1246             : {
    1247     1012507 :     AVFrame *frame = NULL;
    1248     1012507 :     AVFilterContext *dst = link->dst;
    1249             :     int ret;
    1250             : 
    1251             :     av_assert1(ff_framequeue_queued_frames(&link->fifo));
    1252     2025014 :     ret = link->min_samples ?
    1253     1012507 :           ff_inlink_consume_samples(link, link->min_samples, link->max_samples, &frame) :
    1254             :           ff_inlink_consume_frame(link, &frame);
    1255             :     av_assert1(ret);
    1256     1012507 :     if (ret < 0) {
    1257             :         av_assert1(!frame);
    1258           0 :         return ret;
    1259             :     }
    1260             :     /* The filter will soon have received a new frame, that may allow it to
    1261             :        produce one or more: unblock its outputs. */
    1262     1012507 :     filter_unblock(dst);
    1263             :     /* AVFilterPad.filter_frame() expect frame_count_out to have the value
    1264             :        before the frame; ff_filter_frame_framed() will re-increment it. */
    1265     1012507 :     link->frame_count_out--;
    1266     1012507 :     ret = ff_filter_frame_framed(link, frame);
    1267     1012507 :     if (ret < 0 && ret != link->status_out) {
    1268           0 :         ff_avfilter_link_set_out_status(link, ret, AV_NOPTS_VALUE);
    1269             :     } else {
    1270             :         /* Run once again, to see if several frames were available, or if
    1271             :            the input status has also changed, or any other reason. */
    1272     1012507 :         ff_filter_set_ready(dst, 300);
    1273             :     }
    1274     1012507 :     return ret;
    1275             : }
    1276             : 
    1277       14825 : static int forward_status_change(AVFilterContext *filter, AVFilterLink *in)
    1278             : {
    1279       14825 :     unsigned out = 0, progress = 0;
    1280             :     int ret;
    1281             : 
    1282       14825 :     av_assert0(!in->status_out);
    1283       14825 :     if (!filter->nb_outputs) {
    1284             :         /* not necessary with the current API and sinks */
    1285           0 :         return 0;
    1286             :     }
    1287       44471 :     while (!in->status_out) {
    1288       14829 :         if (!filter->outputs[out]->status_in) {
    1289       14821 :             progress++;
    1290       14821 :             ret = ff_request_frame_to_filter(filter->outputs[out]);
    1291       14821 :             if (ret < 0)
    1292           0 :                 return ret;
    1293             :         }
    1294       14829 :         if (++out == filter->nb_outputs) {
    1295       14812 :             if (!progress) {
    1296             :                 /* Every output already closed: input no longer interesting
    1297             :                    (example: overlay in shortest mode, other input closed). */
    1298           8 :                 ff_avfilter_link_set_out_status(in, in->status_in, in->status_in_pts);
    1299           8 :                 return 0;
    1300             :             }
    1301       14804 :             progress = 0;
    1302       14804 :             out = 0;
    1303             :         }
    1304             :     }
    1305       14817 :     ff_filter_set_ready(filter, 200);
    1306       14817 :     return 0;
    1307             : }
    1308             : 
    1309             : #define FFERROR_NOT_READY FFERRTAG('N','R','D','Y')
    1310             : 
    1311     3332812 : static int ff_filter_activate_default(AVFilterContext *filter)
    1312             : {
    1313             :     unsigned i;
    1314             : 
    1315     5308017 :     for (i = 0; i < filter->nb_inputs; i++) {
    1316     2987712 :         if (samples_ready(filter->inputs[i], filter->inputs[i]->min_samples)) {
    1317     1012507 :             return ff_filter_frame_to_filter(filter->inputs[i]);
    1318             :         }
    1319             :     }
    1320     4277682 :     for (i = 0; i < filter->nb_inputs; i++) {
    1321     1972202 :         if (filter->inputs[i]->status_in && !filter->inputs[i]->status_out) {
    1322             :             av_assert1(!ff_framequeue_queued_frames(&filter->inputs[i]->fifo));
    1323       14825 :             return forward_status_change(filter, filter->inputs[i]);
    1324             :         }
    1325             :     }
    1326     3334493 :     for (i = 0; i < filter->nb_outputs; i++) {
    1327     3584130 :         if (filter->outputs[i]->frame_wanted_out &&
    1328     1277603 :             !filter->outputs[i]->frame_blocked_in) {
    1329     1277514 :             return ff_request_frame_to_filter(filter->outputs[i]);
    1330             :         }
    1331             :     }
    1332     1027966 :     return FFERROR_NOT_READY;
    1333             : }
    1334             : 
    1335             : /*
    1336             :    Filter scheduling and activation
    1337             : 
    1338             :    When a filter is activated, it must:
    1339             :    - if possible, output a frame;
    1340             :    - else, if relevant, forward the input status change;
    1341             :    - else, check outputs for wanted frames and forward the requests.
    1342             : 
    1343             :    The following AVFilterLink fields are used for activation:
    1344             : 
    1345             :    - frame_wanted_out:
    1346             : 
    1347             :      This field indicates if a frame is needed on this input of the
    1348             :      destination filter. A positive value indicates that a frame is needed
    1349             :      to process queued frames or internal data or to satisfy the
    1350             :      application; a zero value indicates that a frame is not especially
    1351             :      needed but could be processed anyway; a negative value indicates that a
    1352             :      frame would just be queued.
    1353             : 
    1354             :      It is set by filters using ff_request_frame() or ff_request_no_frame(),
    1355             :      when requested by the application through a specific API or when it is
    1356             :      set on one of the outputs.
    1357             : 
    1358             :      It is cleared when a frame is sent from the source using
    1359             :      ff_filter_frame().
    1360             : 
    1361             :      It is also cleared when a status change is sent from the source using
    1362             :      ff_avfilter_link_set_in_status().
    1363             : 
    1364             :    - frame_blocked_in:
    1365             : 
    1366             :      This field means that the source filter can not generate a frame as is.
    1367             :      Its goal is to avoid repeatedly calling the request_frame() method on
    1368             :      the same link.
    1369             : 
    1370             :      It is set by the framework on all outputs of a filter before activating it.
    1371             : 
    1372             :      It is automatically cleared by ff_filter_frame().
    1373             : 
    1374             :      It is also automatically cleared by ff_avfilter_link_set_in_status().
    1375             : 
    1376             :      It is also cleared on all outputs (using filter_unblock()) when
    1377             :      something happens on an input: processing a frame or changing the
    1378             :      status.
    1379             : 
    1380             :    - fifo:
    1381             : 
    1382             :      Contains the frames queued on a filter input. If it contains frames and
    1383             :      frame_wanted_out is not set, then the filter can be activated. If that
    1384             :      result in the filter not able to use these frames, the filter must set
    1385             :      frame_wanted_out to ask for more frames.
    1386             : 
    1387             :    - status_in and status_in_pts:
    1388             : 
    1389             :      Status (EOF or error code) of the link and timestamp of the status
    1390             :      change (in link time base, same as frames) as seen from the input of
    1391             :      the link. The status change is considered happening after the frames
    1392             :      queued in fifo.
    1393             : 
    1394             :      It is set by the source filter using ff_avfilter_link_set_in_status().
    1395             : 
    1396             :    - status_out:
    1397             : 
    1398             :      Status of the link as seen from the output of the link. The status
    1399             :      change is considered having already happened.
    1400             : 
    1401             :      It is set by the destination filter using
    1402             :      ff_avfilter_link_set_out_status().
    1403             : 
    1404             :    Filters are activated according to the ready field, set using the
    1405             :    ff_filter_set_ready(). Eventually, a priority queue will be used.
    1406             :    ff_filter_set_ready() is called whenever anything could cause progress to
    1407             :    be possible. Marking a filter ready when it is not is not a problem,
    1408             :    except for the small overhead it causes.
    1409             : 
    1410             :    Conditions that cause a filter to be marked ready are:
    1411             : 
    1412             :    - frames added on an input link;
    1413             : 
    1414             :    - changes in the input or output status of an input link;
    1415             : 
    1416             :    - requests for a frame on an output link;
    1417             : 
    1418             :    - after any actual processing using the legacy methods (filter_frame(),
    1419             :      and request_frame() to acknowledge status changes), to run once more
    1420             :      and check if enough input was present for several frames.
    1421             : 
    1422             :    Exemples of scenarios to consider:
    1423             : 
    1424             :    - buffersrc: activate if frame_wanted_out to notify the application;
    1425             :      activate when the application adds a frame to push it immediately.
    1426             : 
    1427             :    - testsrc: activate only if frame_wanted_out to produce and push a frame.
    1428             : 
    1429             :    - concat (not at stitch points): can process a frame on any output.
    1430             :      Activate if frame_wanted_out on output to forward on the corresponding
    1431             :      input. Activate when a frame is present on input to process it
    1432             :      immediately.
    1433             : 
    1434             :    - framesync: needs at least one frame on each input; extra frames on the
    1435             :      wrong input will accumulate. When a frame is first added on one input,
    1436             :      set frame_wanted_out<0 on it to avoid getting more (would trigger
    1437             :      testsrc) and frame_wanted_out>0 on the other to allow processing it.
    1438             : 
    1439             :    Activation of old filters:
    1440             : 
    1441             :    In order to activate a filter implementing the legacy filter_frame() and
    1442             :    request_frame() methods, perform the first possible of the following
    1443             :    actions:
    1444             : 
    1445             :    - If an input has frames in fifo and frame_wanted_out == 0, dequeue a
    1446             :      frame and call filter_frame().
    1447             : 
    1448             :      Ratinale: filter frames as soon as possible instead of leaving them
    1449             :      queued; frame_wanted_out < 0 is not possible since the old API does not
    1450             :      set it nor provides any similar feedback; frame_wanted_out > 0 happens
    1451             :      when min_samples > 0 and there are not enough samples queued.
    1452             : 
    1453             :    - If an input has status_in set but not status_out, try to call
    1454             :      request_frame() on one of the outputs in the hope that it will trigger
    1455             :      request_frame() on the input with status_in and acknowledge it. This is
    1456             :      awkward and fragile, filters with several inputs or outputs should be
    1457             :      updated to direct activation as soon as possible.
    1458             : 
    1459             :    - If an output has frame_wanted_out > 0 and not frame_blocked_in, call
    1460             :      request_frame().
    1461             : 
    1462             :      Rationale: checking frame_blocked_in is necessary to avoid requesting
    1463             :      repeatedly on a blocked input if another is not blocked (example:
    1464             :      [buffersrc1][testsrc1][buffersrc2][testsrc2]concat=v=2).
    1465             : 
    1466             :      TODO: respect needs_fifo and remove auto-inserted fifos.
    1467             : 
    1468             :  */
    1469             : 
    1470     3719589 : int ff_filter_activate(AVFilterContext *filter)
    1471             : {
    1472             :     int ret;
    1473             : 
    1474             :     /* Generic timeline support is not yet implemented but should be easy */
    1475             :     av_assert1(!(filter->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC &&
    1476             :                  filter->filter->activate));
    1477     3719589 :     filter->ready = 0;
    1478     3719589 :     ret = filter->filter->activate ? filter->filter->activate(filter) :
    1479             :           ff_filter_activate_default(filter);
    1480     3719589 :     if (ret == FFERROR_NOT_READY)
    1481     1027966 :         ret = 0;
    1482     3719589 :     return ret;
    1483             : }
    1484             : 
    1485     2024204 : int ff_inlink_acknowledge_status(AVFilterLink *link, int *rstatus, int64_t *rpts)
    1486             : {
    1487     2024204 :     *rpts = link->current_pts;
    1488     2024204 :     if (ff_framequeue_queued_frames(&link->fifo))
    1489      148520 :         return *rstatus = 0;
    1490     1875684 :     if (link->status_out)
    1491        3628 :         return *rstatus = link->status_out;
    1492     1872056 :     if (!link->status_in)
    1493     1868861 :         return *rstatus = 0;
    1494        3195 :     *rstatus = link->status_out = link->status_in;
    1495        3195 :     ff_update_link_current_pts(link, link->status_in_pts);
    1496        3195 :     *rpts = link->current_pts;
    1497        3195 :     return 1;
    1498             : }
    1499             : 
    1500     3181510 : int ff_inlink_check_available_frame(AVFilterLink *link)
    1501             : {
    1502     3181510 :     return ff_framequeue_queued_frames(&link->fifo) > 0;
    1503             : }
    1504             : 
    1505      244043 : int ff_inlink_check_available_samples(AVFilterLink *link, unsigned min)
    1506             : {
    1507      244043 :     uint64_t samples = ff_framequeue_queued_samples(&link->fifo);
    1508             :     av_assert1(min);
    1509      244043 :     return samples >= min || (link->status_in && samples);
    1510             : }
    1511             : 
    1512     1401349 : static void consume_update(AVFilterLink *link, const AVFrame *frame)
    1513             : {
    1514     1401349 :     ff_update_link_current_pts(link, frame->pts);
    1515     1401349 :     ff_inlink_process_commands(link, frame);
    1516     1401349 :     link->dst->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1517     1401349 :     link->frame_count_out++;
    1518     1401349 : }
    1519             : 
    1520     3181510 : int ff_inlink_consume_frame(AVFilterLink *link, AVFrame **rframe)
    1521             : {
    1522             :     AVFrame *frame;
    1523             : 
    1524     3181510 :     *rframe = NULL;
    1525     3181510 :     if (!ff_inlink_check_available_frame(link))
    1526     1822528 :         return 0;
    1527     1358982 :     frame = ff_framequeue_take(&link->fifo);
    1528     1358982 :     consume_update(link, frame);
    1529     1358982 :     *rframe = frame;
    1530     1358982 :     return 1;
    1531             : }
    1532             : 
    1533      244043 : int ff_inlink_consume_samples(AVFilterLink *link, unsigned min, unsigned max,
    1534             :                             AVFrame **rframe)
    1535             : {
    1536             :     AVFrame *frame;
    1537             :     int ret;
    1538             : 
    1539             :     av_assert1(min);
    1540      244043 :     *rframe = NULL;
    1541      244043 :     if (!ff_inlink_check_available_samples(link, min))
    1542      201676 :         return 0;
    1543       42367 :     if (link->status_in)
    1544          81 :         min = FFMIN(min, ff_framequeue_queued_samples(&link->fifo));
    1545       42367 :     ret = take_samples(link, min, link->max_samples, &frame);
    1546       42367 :     if (ret < 0)
    1547           0 :         return ret;
    1548       42367 :     consume_update(link, frame);
    1549       42367 :     *rframe = frame;
    1550       42367 :     return 1;
    1551             : }
    1552             : 
    1553        2998 : int ff_inlink_make_frame_writable(AVFilterLink *link, AVFrame **rframe)
    1554             : {
    1555        2998 :     AVFrame *frame = *rframe;
    1556             :     AVFrame *out;
    1557             :     int ret;
    1558             : 
    1559        2998 :     if (av_frame_is_writable(frame))
    1560        2676 :         return 0;
    1561         322 :     av_log(link->dst, AV_LOG_DEBUG, "Copying data in avfilter.\n");
    1562             : 
    1563         322 :     switch (link->type) {
    1564             :     case AVMEDIA_TYPE_VIDEO:
    1565         322 :         out = ff_get_video_buffer(link, link->w, link->h);
    1566         322 :         break;
    1567             :     case AVMEDIA_TYPE_AUDIO:
    1568           0 :         out = ff_get_audio_buffer(link, frame->nb_samples);
    1569           0 :         break;
    1570             :     default:
    1571           0 :         return AVERROR(EINVAL);
    1572             :     }
    1573         322 :     if (!out)
    1574           0 :         return AVERROR(ENOMEM);
    1575             : 
    1576         322 :     ret = av_frame_copy_props(out, frame);
    1577         322 :     if (ret < 0) {
    1578           0 :         av_frame_free(&out);
    1579           0 :         return ret;
    1580             :     }
    1581             : 
    1582         322 :     switch (link->type) {
    1583             :     case AVMEDIA_TYPE_VIDEO:
    1584         966 :         av_image_copy(out->data, out->linesize, (const uint8_t **)frame->data, frame->linesize,
    1585         966 :                       frame->format, frame->width, frame->height);
    1586         322 :         break;
    1587             :     case AVMEDIA_TYPE_AUDIO:
    1588           0 :         av_samples_copy(out->extended_data, frame->extended_data,
    1589           0 :                         0, 0, frame->nb_samples,
    1590             :                         av_frame_get_channels(frame),
    1591           0 :                         frame->format);
    1592           0 :         break;
    1593             :     default:
    1594           0 :         av_assert0(!"reached");
    1595             :     }
    1596             : 
    1597         322 :     av_frame_free(&frame);
    1598         322 :     *rframe = out;
    1599         322 :     return 0;
    1600             : }
    1601             : 
    1602     2413856 : int ff_inlink_process_commands(AVFilterLink *link, const AVFrame *frame)
    1603             : {
    1604     2413856 :     AVFilterCommand *cmd = link->dst->command_queue;
    1605             : 
    1606     4827712 :     while(cmd && cmd->time <= frame->pts * av_q2d(link->time_base)){
    1607           0 :         av_log(link->dst, AV_LOG_DEBUG,
    1608             :                "Processing command time:%f command:%s arg:%s\n",
    1609             :                cmd->time, cmd->command, cmd->arg);
    1610           0 :         avfilter_process_command(link->dst, cmd->command, cmd->arg, 0, 0, cmd->flags);
    1611           0 :         ff_command_queue_pop(link->dst);
    1612           0 :         cmd= link->dst->command_queue;
    1613             :     }
    1614     2413856 :     return 0;
    1615             : }
    1616             : 
    1617     2413856 : int ff_inlink_evaluate_timeline_at_frame(AVFilterLink *link, const AVFrame *frame)
    1618             : {
    1619     2413856 :     AVFilterContext *dstctx = link->dst;
    1620     2413856 :     int64_t pts = frame->pts;
    1621     2413856 :     int64_t pos = av_frame_get_pkt_pos(frame);
    1622             : 
    1623     2413856 :     if (!dstctx->enable_str)
    1624     2413670 :         return 1;
    1625             : 
    1626         186 :     dstctx->var_values[VAR_N] = link->frame_count_out;
    1627         186 :     dstctx->var_values[VAR_T] = pts == AV_NOPTS_VALUE ? NAN : pts * av_q2d(link->time_base);
    1628         186 :     dstctx->var_values[VAR_W] = link->w;
    1629         186 :     dstctx->var_values[VAR_H] = link->h;
    1630         186 :     dstctx->var_values[VAR_POS] = pos == -1 ? NAN : pos;
    1631             : 
    1632         186 :     return fabs(av_expr_eval(dstctx->enable, dstctx->var_values, NULL)) >= 0.5;
    1633             : }
    1634             : 
    1635      350099 : void ff_inlink_request_frame(AVFilterLink *link)
    1636             : {
    1637             :     av_assert1(!link->status_in);
    1638             :     av_assert1(!link->status_out);
    1639      350099 :     link->frame_wanted_out = 1;
    1640      350099 :     ff_filter_set_ready(link->src, 100);
    1641      350099 : }
    1642             : 
    1643           0 : const AVClass *avfilter_get_class(void)
    1644             : {
    1645           0 :     return &avfilter_class;
    1646             : }

Generated by: LCOV version 1.13