LCOV - code coverage report
Current view: top level - src/libavfilter - avfilter.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 624 862 72.4 %
Date: 2017-09-22 00:04:37 Functions: 53 67 79.1 %

          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     1401415 : 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     1401415 :     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     1401415 :     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     1401415 : }
      76             : 
      77        5341 : unsigned avfilter_version(void)
      78             : {
      79             :     av_assert0(LIBAVFILTER_VERSION_MICRO >= 100);
      80        5341 :     return LIBAVFILTER_VERSION_INT;
      81             : }
      82             : 
      83        5341 : const char *avfilter_configuration(void)
      84             : {
      85        5341 :     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       21191 : int avfilter_link(AVFilterContext *src, unsigned srcpad,
     136             :                   AVFilterContext *dst, unsigned dstpad)
     137             : {
     138             :     AVFilterLink *link;
     139             : 
     140       21191 :     av_assert0(src->graph);
     141       21191 :     av_assert0(dst->graph);
     142       21191 :     av_assert0(src->graph == dst->graph);
     143             : 
     144       42382 :     if (src->nb_outputs <= srcpad || dst->nb_inputs <= dstpad ||
     145       42382 :         src->outputs[srcpad]      || dst->inputs[dstpad])
     146           0 :         return AVERROR(EINVAL);
     147             : 
     148       21191 :     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       21191 :     link = av_mallocz(sizeof(*link));
     157       21191 :     if (!link)
     158           0 :         return AVERROR(ENOMEM);
     159             : 
     160       21191 :     src->outputs[srcpad] = dst->inputs[dstpad] = link;
     161             : 
     162       21191 :     link->src     = src;
     163       21191 :     link->dst     = dst;
     164       21191 :     link->srcpad  = &src->output_pads[srcpad];
     165       21191 :     link->dstpad  = &dst->input_pads[dstpad];
     166       21191 :     link->type    = src->output_pads[srcpad].type;
     167             :     av_assert0(AV_PIX_FMT_NONE == -1 && AV_SAMPLE_FMT_NONE == -1);
     168       21191 :     link->format  = -1;
     169       21191 :     ff_framequeue_init(&link->fifo, &src->graph->internal->frame_queues);
     170             : 
     171       21191 :     return 0;
     172             : }
     173             : 
     174       21317 : void avfilter_link_free(AVFilterLink **link)
     175             : {
     176       21317 :     if (!*link)
     177           0 :         return;
     178             : 
     179       21317 :     av_frame_free(&(*link)->partial_buf);
     180       21317 :     ff_framequeue_free(&(*link)->fifo);
     181       21317 :     ff_frame_pool_uninit((FFFramePool**)&(*link)->frame_pool);
     182             : 
     183       21317 :     av_freep(link);
     184             : }
     185             : 
     186           0 : int avfilter_link_get_channels(AVFilterLink *link)
     187             : {
     188           0 :     return link->channels;
     189             : }
     190             : 
     191     3747468 : void ff_filter_set_ready(AVFilterContext *filter, unsigned priority)
     192             : {
     193     3747468 :     filter->ready = FFMAX(filter->ready, priority);
     194     3747468 : }
     195             : 
     196             : /**
     197             :  * Clear frame_blocked_in on all outputs.
     198             :  * This is necessary whenever something changes on input.
     199             :  */
     200     2452383 : static void filter_unblock(AVFilterContext *filter)
     201             : {
     202             :     unsigned i;
     203             : 
     204     4517653 :     for (i = 0; i < filter->nb_outputs; i++)
     205     2065270 :         filter->outputs[i]->frame_blocked_in = 0;
     206     2452383 : }
     207             : 
     208             : 
     209       20909 : void ff_avfilter_link_set_in_status(AVFilterLink *link, int status, int64_t pts)
     210             : {
     211       20909 :     if (link->status_in == status)
     212          21 :         return;
     213       20888 :     av_assert0(!link->status_in);
     214       20888 :     link->status_in = status;
     215       20888 :     link->status_in_pts = pts;
     216       20888 :     link->frame_wanted_out = 0;
     217       20888 :     link->frame_blocked_in = 0;
     218       20888 :     filter_unblock(link->dst);
     219       20888 :     ff_filter_set_ready(link->dst, 200);
     220             : }
     221             : 
     222       15654 : void ff_avfilter_link_set_out_status(AVFilterLink *link, int status, int64_t pts)
     223             : {
     224       15654 :     av_assert0(!link->frame_wanted_out);
     225       15654 :     av_assert0(!link->status_out);
     226       15654 :     link->status_out = status;
     227       15654 :     if (pts != AV_NOPTS_VALUE)
     228       15132 :         ff_update_link_current_pts(link, pts);
     229       15654 :     filter_unblock(link->dst);
     230       15654 :     ff_filter_set_ready(link->src, 200);
     231       15654 : }
     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        2706 : int avfilter_insert_filter(AVFilterLink *link, AVFilterContext *filt,
     239             :                            unsigned filt_srcpad_idx, unsigned filt_dstpad_idx)
     240             : {
     241             :     int ret;
     242        2706 :     unsigned dstpad_idx = link->dstpad - link->dst->input_pads;
     243             : 
     244        5412 :     av_log(link->dst, AV_LOG_VERBOSE, "auto-inserting filter '%s' "
     245             :            "between the filter '%s' and the filter '%s'\n",
     246        5412 :            filt->name, link->src->name, link->dst->name);
     247             : 
     248        2706 :     link->dst->inputs[dstpad_idx] = NULL;
     249        2706 :     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        2706 :     link->dst                     = filt;
     257        2706 :     link->dstpad                  = &filt->input_pads[filt_srcpad_idx];
     258        2706 :     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        2706 :     if (link->out_formats)
     263        2694 :         ff_formats_changeref(&link->out_formats,
     264        2694 :                              &filt->outputs[filt_dstpad_idx]->out_formats);
     265        2706 :     if (link->out_samplerates)
     266         533 :         ff_formats_changeref(&link->out_samplerates,
     267         533 :                              &filt->outputs[filt_dstpad_idx]->out_samplerates);
     268        2706 :     if (link->out_channel_layouts)
     269         533 :         ff_channel_layouts_changeref(&link->out_channel_layouts,
     270         533 :                                      &filt->outputs[filt_dstpad_idx]->out_channel_layouts);
     271             : 
     272        2706 :     return 0;
     273             : }
     274             : 
     275       26400 : int avfilter_config_links(AVFilterContext *filter)
     276             : {
     277             :     int (*config_link)(AVFilterLink *);
     278             :     unsigned i;
     279             :     int ret;
     280             : 
     281       47549 :     for (i = 0; i < filter->nb_inputs; i ++) {
     282       21149 :         AVFilterLink *link = filter->inputs[i];
     283             :         AVFilterLink *inlink;
     284             : 
     285       21149 :         if (!link) continue;
     286       21149 :         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       21149 :         inlink = link->src->nb_inputs ? link->src->inputs[0] : NULL;
     293       21149 :         link->current_pts =
     294       21149 :         link->current_pts_us = AV_NOPTS_VALUE;
     295             : 
     296       21149 :         switch (link->init_state) {
     297          19 :         case AVLINK_INIT:
     298          19 :             continue;
     299           0 :         case AVLINK_STARTINIT:
     300           0 :             av_log(filter, AV_LOG_INFO, "circular filter chain detected\n");
     301           0 :             return 0;
     302       21130 :         case AVLINK_UNINIT:
     303       21130 :             link->init_state = AVLINK_STARTINIT;
     304             : 
     305       21130 :             if ((ret = avfilter_config_links(link->src)) < 0)
     306           0 :                 return ret;
     307             : 
     308       21130 :             if (!(config_link = link->srcpad->config_props)) {
     309       11088 :                 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       10042 :             } 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       21130 :             switch (link->type) {
     324       16319 :             case AVMEDIA_TYPE_VIDEO:
     325       16319 :                 if (!link->time_base.num && !link->time_base.den)
     326       11923 :                     link->time_base = inlink ? inlink->time_base : AV_TIME_BASE_Q;
     327             : 
     328       16319 :                 if (!link->sample_aspect_ratio.num && !link->sample_aspect_ratio.den)
     329        8935 :                     link->sample_aspect_ratio = inlink ?
     330             :                         inlink->sample_aspect_ratio : (AVRational){1,1};
     331             : 
     332       16319 :                 if (inlink) {
     333       12092 :                     if (!link->frame_rate.num && !link->frame_rate.den)
     334       11967 :                         link->frame_rate = inlink->frame_rate;
     335       12092 :                     if (!link->w)
     336        8565 :                         link->w = inlink->w;
     337       12092 :                     if (!link->h)
     338        8565 :                         link->h = inlink->h;
     339        4227 :                 } 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       16319 :                 break;
     346             : 
     347        4811 :             case AVMEDIA_TYPE_AUDIO:
     348        4811 :                 if (inlink) {
     349        3733 :                     if (!link->time_base.num && !link->time_base.den)
     350        2564 :                         link->time_base = inlink->time_base;
     351             :                 }
     352             : 
     353        4811 :                 if (!link->time_base.num && !link->time_base.den)
     354           4 :                     link->time_base = (AVRational) {1, link->sample_rate};
     355             :             }
     356             : 
     357       21130 :             if (link->src->nb_inputs && link->src->inputs[0]->hw_frames_ctx &&
     358           0 :                 !(link->src->filter->flags_internal & FF_FILTER_FLAG_HWFRAME_AWARE)) {
     359           0 :                 av_assert0(!link->hw_frames_ctx &&
     360             :                            "should not be set by non-hwframe-aware filter");
     361           0 :                 link->hw_frames_ctx = av_buffer_ref(link->src->inputs[0]->hw_frames_ctx);
     362           0 :                 if (!link->hw_frames_ctx)
     363           0 :                     return AVERROR(ENOMEM);
     364             :             }
     365             : 
     366       21130 :             if ((config_link = link->dstpad->config_props))
     367        1740 :                 if ((ret = config_link(link)) < 0) {
     368           0 :                     av_log(link->dst, AV_LOG_ERROR,
     369             :                            "Failed to configure input pad on %s\n",
     370           0 :                            link->dst->name);
     371           0 :                     return ret;
     372             :                 }
     373             : 
     374       21130 :             link->init_state = AVLINK_INIT;
     375             :         }
     376             :     }
     377             : 
     378       26400 :     return 0;
     379             : }
     380             : 
     381     3718314 : void ff_tlog_link(void *ctx, AVFilterLink *link, int end)
     382             : {
     383     3718314 :     if (link->type == AVMEDIA_TYPE_VIDEO) {
     384             :         ff_tlog(ctx,
     385             :                 "link[%p s:%dx%d fmt:%s %s->%s]%s",
     386             :                 link, link->w, link->h,
     387             :                 av_get_pix_fmt_name(link->format),
     388             :                 link->src ? link->src->filter->name : "",
     389             :                 link->dst ? link->dst->filter->name : "",
     390             :                 end ? "\n" : "");
     391             :     } else {
     392             :         char buf[128];
     393     2833758 :         av_get_channel_layout_string(buf, sizeof(buf), -1, link->channel_layout);
     394             : 
     395             :         ff_tlog(ctx,
     396             :                 "link[%p r:%d cl:%s fmt:%s %s->%s]%s",
     397             :                 link, (int)link->sample_rate, buf,
     398             :                 av_get_sample_fmt_name(link->format),
     399             :                 link->src ? link->src->filter->name : "",
     400             :                 link->dst ? link->dst->filter->name : "",
     401             :                 end ? "\n" : "");
     402             :     }
     403     3718314 : }
     404             : 
     405      941142 : int ff_request_frame(AVFilterLink *link)
     406             : {
     407      941142 :     FF_TPRINTF_START(NULL, request_frame); ff_tlog_link(NULL, link, 1);
     408             : 
     409             :     av_assert1(!link->dst->filter->activate);
     410      941142 :     if (link->status_out)
     411        1146 :         return link->status_out;
     412      939996 :     if (link->status_in) {
     413       15164 :         if (ff_framequeue_queued_frames(&link->fifo)) {
     414             :             av_assert1(!link->frame_wanted_out);
     415             :             av_assert1(link->dst->ready >= 300);
     416           0 :             return 0;
     417             :         } else {
     418             :             /* Acknowledge status change. Filters using ff_request_frame() will
     419             :                handle the change automatically. Filters can also check the
     420             :                status directly but none do yet. */
     421       15164 :             ff_avfilter_link_set_out_status(link, link->status_in, link->status_in_pts);
     422       15164 :             return link->status_out;
     423             :         }
     424             :     }
     425      924832 :     link->frame_wanted_out = 1;
     426      924832 :     ff_filter_set_ready(link->src, 100);
     427      924832 :     return 0;
     428             : }
     429             : 
     430       15668 : static int64_t guess_status_pts(AVFilterContext *ctx, int status)
     431             : {
     432             :     unsigned i;
     433       15668 :     int64_t r = INT64_MAX;
     434             : 
     435       31319 :     for (i = 0; i < ctx->nb_inputs; i++)
     436       15651 :         if (ctx->inputs[i]->status_out == status)
     437       15640 :             r = FFMIN(r, ctx->inputs[i]->current_pts);
     438       15668 :     if (r < INT64_MAX)
     439       15628 :         return r;
     440          40 :     av_log(ctx, AV_LOG_WARNING, "EOF timestamp not reliable\n");
     441          40 :     for (i = 0; i < ctx->nb_inputs; i++)
     442           0 :         r = FFMIN(r, ctx->inputs[i]->status_in_pts);
     443          40 :     if (r < INT64_MAX)
     444           0 :         return r;
     445          40 :     return AV_NOPTS_VALUE;
     446             : }
     447             : 
     448     1296381 : static int ff_request_frame_to_filter(AVFilterLink *link)
     449             : {
     450     1296381 :     int ret = -1;
     451             : 
     452     1296381 :     FF_TPRINTF_START(NULL, request_frame_to_filter); ff_tlog_link(NULL, link, 1);
     453             :     /* Assume the filter is blocked, let the method clear it if not */
     454     1296381 :     link->frame_blocked_in = 1;
     455     1296381 :     if (link->srcpad->request_frame)
     456      577279 :         ret = link->srcpad->request_frame(link);
     457      719102 :     else if (link->src->inputs[0])
     458      719102 :         ret = ff_request_frame(link->src->inputs[0]);
     459     1296381 :     if (ret < 0) {
     460      364371 :         if (ret != AVERROR(EAGAIN) && ret != link->status_in)
     461       15668 :             ff_avfilter_link_set_in_status(link, ret, guess_status_pts(link->src, ret));
     462      364371 :         if (ret == AVERROR_EOF)
     463       15668 :             ret = 0;
     464             :     }
     465     1296381 :     return ret;
     466             : }
     467             : 
     468           0 : int ff_poll_frame(AVFilterLink *link)
     469             : {
     470           0 :     int i, min = INT_MAX;
     471             : 
     472           0 :     if (link->srcpad->poll_frame)
     473           0 :         return link->srcpad->poll_frame(link);
     474             : 
     475           0 :     for (i = 0; i < link->src->nb_inputs; i++) {
     476             :         int val;
     477           0 :         if (!link->src->inputs[i])
     478           0 :             return AVERROR(EINVAL);
     479           0 :         val = ff_poll_frame(link->src->inputs[i]);
     480           0 :         min = FFMIN(min, val);
     481             :     }
     482             : 
     483           0 :     return min;
     484             : }
     485             : 
     486             : static const char *const var_names[] = {
     487             :     "t",
     488             :     "n",
     489             :     "pos",
     490             :     "w",
     491             :     "h",
     492             :     NULL
     493             : };
     494             : 
     495             : enum {
     496             :     VAR_T,
     497             :     VAR_N,
     498             :     VAR_POS,
     499             :     VAR_W,
     500             :     VAR_H,
     501             :     VAR_VARS_NB
     502             : };
     503             : 
     504           4 : static int set_enable_expr(AVFilterContext *ctx, const char *expr)
     505             : {
     506             :     int ret;
     507             :     char *expr_dup;
     508           4 :     AVExpr *old = ctx->enable;
     509             : 
     510           4 :     if (!(ctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE)) {
     511           0 :         av_log(ctx, AV_LOG_ERROR, "Timeline ('enable' option) not supported "
     512           0 :                "with filter '%s'\n", ctx->filter->name);
     513           0 :         return AVERROR_PATCHWELCOME;
     514             :     }
     515             : 
     516           4 :     expr_dup = av_strdup(expr);
     517           4 :     if (!expr_dup)
     518           0 :         return AVERROR(ENOMEM);
     519             : 
     520           4 :     if (!ctx->var_values) {
     521           4 :         ctx->var_values = av_calloc(VAR_VARS_NB, sizeof(*ctx->var_values));
     522           4 :         if (!ctx->var_values) {
     523           0 :             av_free(expr_dup);
     524           0 :             return AVERROR(ENOMEM);
     525             :         }
     526             :     }
     527             : 
     528           4 :     ret = av_expr_parse((AVExpr**)&ctx->enable, expr_dup, var_names,
     529             :                         NULL, NULL, NULL, NULL, 0, ctx->priv);
     530           4 :     if (ret < 0) {
     531           0 :         av_log(ctx->priv, AV_LOG_ERROR,
     532             :                "Error when evaluating the expression '%s' for enable\n",
     533             :                expr_dup);
     534           0 :         av_free(expr_dup);
     535           0 :         return ret;
     536             :     }
     537             : 
     538           4 :     av_expr_free(old);
     539           4 :     av_free(ctx->enable_str);
     540           4 :     ctx->enable_str = expr_dup;
     541           4 :     return 0;
     542             : }
     543             : 
     544     1432700 : void ff_update_link_current_pts(AVFilterLink *link, int64_t pts)
     545             : {
     546     1432700 :     if (pts == AV_NOPTS_VALUE)
     547          20 :         return;
     548     1432680 :     link->current_pts = pts;
     549     1432680 :     link->current_pts_us = av_rescale_q(pts, link->time_base, AV_TIME_BASE_Q);
     550             :     /* TODO use duration */
     551     1432680 :     if (link->graph && link->age_index >= 0)
     552      400198 :         ff_avfilter_graph_update_heap(link->graph, link);
     553             : }
     554             : 
     555           0 : int avfilter_process_command(AVFilterContext *filter, const char *cmd, const char *arg, char *res, int res_len, int flags)
     556             : {
     557           0 :     if(!strcmp(cmd, "ping")){
     558           0 :         char local_res[256] = {0};
     559             : 
     560           0 :         if (!res) {
     561           0 :             res = local_res;
     562           0 :             res_len = sizeof(local_res);
     563             :         }
     564           0 :         av_strlcatf(res, res_len, "pong from:%s %s\n", filter->filter->name, filter->name);
     565           0 :         if (res == local_res)
     566           0 :             av_log(filter, AV_LOG_INFO, "%s", res);
     567           0 :         return 0;
     568           0 :     }else if(!strcmp(cmd, "enable")) {
     569           0 :         return set_enable_expr(filter, arg);
     570           0 :     }else if(filter->filter->process_command) {
     571           0 :         return filter->filter->process_command(filter, cmd, arg, res, res_len, flags);
     572             :     }
     573           0 :     return AVERROR(ENOSYS);
     574             : }
     575             : 
     576             : static AVFilter *first_filter;
     577             : static AVFilter **last_filter = &first_filter;
     578             : 
     579             : #if !FF_API_NOCONST_GET_NAME
     580             : const
     581             : #endif
     582       26570 : AVFilter *avfilter_get_by_name(const char *name)
     583             : {
     584       26570 :     const AVFilter *f = NULL;
     585             : 
     586       26570 :     if (!name)
     587           0 :         return NULL;
     588             : 
     589     5767413 :     while ((f = avfilter_next(f)))
     590     5740843 :         if (!strcmp(f->name, name))
     591       26570 :             return (AVFilter *)f;
     592             : 
     593           0 :     return NULL;
     594             : }
     595             : 
     596     1720560 : int avfilter_register(AVFilter *filter)
     597             : {
     598     1720560 :     AVFilter **f = last_filter;
     599             : 
     600             :     /* the filter must select generic or internal exclusively */
     601     1720560 :     av_assert0((filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE) != AVFILTER_FLAG_SUPPORT_TIMELINE);
     602             : 
     603     1720560 :     filter->next = NULL;
     604             : 
     605     3441120 :     while(*f || avpriv_atomic_ptr_cas((void * volatile *)f, NULL, filter))
     606           0 :         f = &(*f)->next;
     607     1720560 :     last_filter = &filter->next;
     608             : 
     609     1720560 :     return 0;
     610             : }
     611             : 
     612     5740843 : const AVFilter *avfilter_next(const AVFilter *prev)
     613             : {
     614     5740843 :     return prev ? prev->next : first_filter;
     615             : }
     616             : 
     617             : #if FF_API_OLD_FILTER_REGISTER
     618           0 : AVFilter **av_filter_next(AVFilter **filter)
     619             : {
     620           0 :     return filter ? &(*filter)->next : &first_filter;
     621             : }
     622             : 
     623           0 : void avfilter_uninit(void)
     624             : {
     625           0 : }
     626             : #endif
     627             : 
     628       53108 : int avfilter_pad_count(const AVFilterPad *pads)
     629             : {
     630             :     int count;
     631             : 
     632       53108 :     if (!pads)
     633       10671 :         return 0;
     634             : 
     635       84934 :     for (count = 0; pads->name; count++)
     636       42497 :         pads++;
     637       42437 :     return count;
     638             : }
     639             : 
     640         299 : static const char *default_filter_name(void *filter_ctx)
     641             : {
     642         299 :     AVFilterContext *ctx = filter_ctx;
     643         299 :     return ctx->name ? ctx->name : ctx->filter->name;
     644             : }
     645             : 
     646        1239 : static void *filter_child_next(void *obj, void *prev)
     647             : {
     648        1239 :     AVFilterContext *ctx = obj;
     649        1239 :     if (!prev && ctx->filter && ctx->filter->priv_class && ctx->priv)
     650        1239 :         return ctx->priv;
     651           0 :     return NULL;
     652             : }
     653             : 
     654           0 : static const AVClass *filter_child_class_next(const AVClass *prev)
     655             : {
     656           0 :     const AVFilter *f = NULL;
     657             : 
     658             :     /* find the filter that corresponds to prev */
     659           0 :     while (prev && (f = avfilter_next(f)))
     660           0 :         if (f->priv_class == prev)
     661           0 :             break;
     662             : 
     663             :     /* could not find filter corresponding to prev */
     664           0 :     if (prev && !f)
     665           0 :         return NULL;
     666             : 
     667             :     /* find next filter with specific options */
     668           0 :     while ((f = avfilter_next(f)))
     669           0 :         if (f->priv_class)
     670           0 :             return f->priv_class;
     671             : 
     672           0 :     return NULL;
     673             : }
     674             : 
     675             : #define OFFSET(x) offsetof(AVFilterContext, x)
     676             : #define FLAGS AV_OPT_FLAG_FILTERING_PARAM
     677             : static const AVOption avfilter_options[] = {
     678             :     { "thread_type", "Allowed thread types", OFFSET(thread_type), AV_OPT_TYPE_FLAGS,
     679             :         { .i64 = AVFILTER_THREAD_SLICE }, 0, INT_MAX, FLAGS, "thread_type" },
     680             :         { "slice", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AVFILTER_THREAD_SLICE }, .unit = "thread_type" },
     681             :     { "enable", "set enable expression", OFFSET(enable_str), AV_OPT_TYPE_STRING, {.str=NULL}, .flags = FLAGS },
     682             :     { "threads", "Allowed number of threads", OFFSET(nb_threads), AV_OPT_TYPE_INT,
     683             :         { .i64 = 0 }, 0, INT_MAX, FLAGS },
     684             :     { NULL },
     685             : };
     686             : 
     687             : static const AVClass avfilter_class = {
     688             :     .class_name = "AVFilter",
     689             :     .item_name  = default_filter_name,
     690             :     .version    = LIBAVUTIL_VERSION_INT,
     691             :     .category   = AV_CLASS_CATEGORY_FILTER,
     692             :     .child_next = filter_child_next,
     693             :     .child_class_next = filter_child_class_next,
     694             :     .option           = avfilter_options,
     695             : };
     696             : 
     697         285 : static int default_execute(AVFilterContext *ctx, avfilter_action_func *func, void *arg,
     698             :                            int *ret, int nb_jobs)
     699             : {
     700             :     int i;
     701             : 
     702         570 :     for (i = 0; i < nb_jobs; i++) {
     703         285 :         int r = func(ctx, arg, i, nb_jobs);
     704         285 :         if (ret)
     705           0 :             ret[i] = r;
     706             :     }
     707         285 :     return 0;
     708             : }
     709             : 
     710       26554 : AVFilterContext *ff_filter_alloc(const AVFilter *filter, const char *inst_name)
     711             : {
     712             :     AVFilterContext *ret;
     713       26554 :     int preinited = 0;
     714             : 
     715       26554 :     if (!filter)
     716           0 :         return NULL;
     717             : 
     718       26554 :     ret = av_mallocz(sizeof(AVFilterContext));
     719       26554 :     if (!ret)
     720           0 :         return NULL;
     721             : 
     722       26554 :     ret->av_class = &avfilter_class;
     723       26554 :     ret->filter   = filter;
     724       26554 :     ret->name     = inst_name ? av_strdup(inst_name) : NULL;
     725       26554 :     if (filter->priv_size) {
     726       23300 :         ret->priv     = av_mallocz(filter->priv_size);
     727       23300 :         if (!ret->priv)
     728           0 :             goto err;
     729             :     }
     730       26554 :     if (filter->preinit) {
     731          30 :         if (filter->preinit(ret) < 0)
     732           0 :             goto err;
     733          30 :         preinited = 1;
     734             :     }
     735             : 
     736       26554 :     av_opt_set_defaults(ret);
     737       26554 :     if (filter->priv_class) {
     738       23119 :         *(const AVClass**)ret->priv = filter->priv_class;
     739       23119 :         av_opt_set_defaults(ret->priv);
     740             :     }
     741             : 
     742       26554 :     ret->internal = av_mallocz(sizeof(*ret->internal));
     743       26554 :     if (!ret->internal)
     744           0 :         goto err;
     745       26554 :     ret->internal->execute = default_execute;
     746             : 
     747       26554 :     ret->nb_inputs = avfilter_pad_count(filter->inputs);
     748       26554 :     if (ret->nb_inputs ) {
     749       21200 :         ret->input_pads   = av_malloc_array(ret->nb_inputs, sizeof(AVFilterPad));
     750       21200 :         if (!ret->input_pads)
     751           0 :             goto err;
     752       21200 :         memcpy(ret->input_pads, filter->inputs, sizeof(AVFilterPad) * ret->nb_inputs);
     753       21200 :         ret->inputs       = av_mallocz_array(ret->nb_inputs, sizeof(AVFilterLink*));
     754       21200 :         if (!ret->inputs)
     755           0 :             goto err;
     756             :     }
     757             : 
     758       26554 :     ret->nb_outputs = avfilter_pad_count(filter->outputs);
     759       26554 :     if (ret->nb_outputs) {
     760       21237 :         ret->output_pads  = av_malloc_array(ret->nb_outputs, sizeof(AVFilterPad));
     761       21237 :         if (!ret->output_pads)
     762           0 :             goto err;
     763       21237 :         memcpy(ret->output_pads, filter->outputs, sizeof(AVFilterPad) * ret->nb_outputs);
     764       21237 :         ret->outputs      = av_mallocz_array(ret->nb_outputs, sizeof(AVFilterLink*));
     765       21237 :         if (!ret->outputs)
     766           0 :             goto err;
     767             :     }
     768             : 
     769       26554 :     return ret;
     770             : 
     771           0 : err:
     772           0 :     if (preinited)
     773           0 :         filter->uninit(ret);
     774           0 :     av_freep(&ret->inputs);
     775           0 :     av_freep(&ret->input_pads);
     776           0 :     ret->nb_inputs = 0;
     777           0 :     av_freep(&ret->outputs);
     778           0 :     av_freep(&ret->output_pads);
     779           0 :     ret->nb_outputs = 0;
     780           0 :     av_freep(&ret->priv);
     781           0 :     av_freep(&ret->internal);
     782           0 :     av_free(ret);
     783           0 :     return NULL;
     784             : }
     785             : 
     786             : #if FF_API_AVFILTER_OPEN
     787           0 : int avfilter_open(AVFilterContext **filter_ctx, AVFilter *filter, const char *inst_name)
     788             : {
     789           0 :     *filter_ctx = ff_filter_alloc(filter, inst_name);
     790           0 :     return *filter_ctx ? 0 : AVERROR(ENOMEM);
     791             : }
     792             : #endif
     793             : 
     794       42619 : static void free_link(AVFilterLink *link)
     795             : {
     796       42619 :     if (!link)
     797       21302 :         return;
     798             : 
     799       21317 :     if (link->src)
     800       21191 :         link->src->outputs[link->srcpad - link->src->output_pads] = NULL;
     801       21317 :     if (link->dst)
     802       21191 :         link->dst->inputs[link->dstpad - link->dst->input_pads] = NULL;
     803             : 
     804       21317 :     av_buffer_unref(&link->hw_frames_ctx);
     805             : 
     806       21317 :     ff_formats_unref(&link->in_formats);
     807       21317 :     ff_formats_unref(&link->out_formats);
     808       21317 :     ff_formats_unref(&link->in_samplerates);
     809       21317 :     ff_formats_unref(&link->out_samplerates);
     810       21317 :     ff_channel_layouts_unref(&link->in_channel_layouts);
     811       21317 :     ff_channel_layouts_unref(&link->out_channel_layouts);
     812       21317 :     avfilter_link_free(&link);
     813             : }
     814             : 
     815       26554 : void avfilter_free(AVFilterContext *filter)
     816             : {
     817             :     int i;
     818             : 
     819       26554 :     if (!filter)
     820           0 :         return;
     821             : 
     822       26554 :     if (filter->graph)
     823       26554 :         ff_filter_graph_remove_filter(filter->graph, filter);
     824             : 
     825       26554 :     if (filter->filter->uninit)
     826       15101 :         filter->filter->uninit(filter);
     827             : 
     828       47864 :     for (i = 0; i < filter->nb_inputs; i++) {
     829       21310 :         free_link(filter->inputs[i]);
     830             :     }
     831       47863 :     for (i = 0; i < filter->nb_outputs; i++) {
     832       21309 :         free_link(filter->outputs[i]);
     833             :     }
     834             : 
     835       26554 :     if (filter->filter->priv_class)
     836       23119 :         av_opt_free(filter->priv);
     837             : 
     838       26554 :     av_buffer_unref(&filter->hw_device_ctx);
     839             : 
     840       26554 :     av_freep(&filter->name);
     841       26554 :     av_freep(&filter->input_pads);
     842       26554 :     av_freep(&filter->output_pads);
     843       26554 :     av_freep(&filter->inputs);
     844       26554 :     av_freep(&filter->outputs);
     845       26554 :     av_freep(&filter->priv);
     846       53108 :     while(filter->command_queue){
     847           0 :         ff_command_queue_pop(filter);
     848             :     }
     849       26554 :     av_opt_free(filter);
     850       26554 :     av_expr_free(filter->enable);
     851       26554 :     filter->enable = NULL;
     852       26554 :     av_freep(&filter->var_values);
     853       26554 :     av_freep(&filter->internal);
     854       26554 :     av_free(filter);
     855             : }
     856             : 
     857        2366 : int ff_filter_get_nb_threads(AVFilterContext *ctx)
     858             : {
     859        2366 :      if (ctx->nb_threads > 0)
     860           0 :          return FFMIN(ctx->nb_threads, ctx->graph->nb_threads);
     861        2366 :      return ctx->graph->nb_threads;
     862             : }
     863             : 
     864       16683 : static int process_options(AVFilterContext *ctx, AVDictionary **options,
     865             :                            const char *args)
     866             : {
     867       16683 :     const AVOption *o = NULL;
     868       16683 :     int ret, count = 0;
     869       16683 :     char *av_uninit(parsed_key), *av_uninit(value);
     870             :     const char *key;
     871       16683 :     int offset= -1;
     872             : 
     873       16683 :     if (!args)
     874           0 :         return 0;
     875             : 
     876      118660 :     while (*args) {
     877       85294 :         const char *shorthand = NULL;
     878             : 
     879       85294 :         o = av_opt_next(ctx->priv, o);
     880       85294 :         if (o) {
     881       83246 :             if (o->type == AV_OPT_TYPE_CONST || o->offset == offset)
     882       36573 :                 continue;
     883       46673 :             offset = o->offset;
     884       46673 :             shorthand = o->name;
     885             :         }
     886             : 
     887       48721 :         ret = av_opt_get_key_value(&args, "=", ":",
     888             :                                    shorthand ? AV_OPT_FLAG_IMPLICIT_KEY : 0,
     889             :                                    &parsed_key, &value);
     890       48721 :         if (ret < 0) {
     891           0 :             if (ret == AVERROR(EINVAL))
     892           0 :                 av_log(ctx, AV_LOG_ERROR, "No option name near '%s'\n", args);
     893             :             else
     894           0 :                 av_log(ctx, AV_LOG_ERROR, "Unable to parse '%s': %s\n", args,
     895           0 :                        av_err2str(ret));
     896           0 :             return ret;
     897             :         }
     898       48721 :         if (*args)
     899       33100 :             args++;
     900       48721 :         if (parsed_key) {
     901       39569 :             key = parsed_key;
     902       39569 :             while ((o = av_opt_next(ctx->priv, o))); /* discard all remaining shorthand */
     903             :         } else {
     904        9152 :             key = shorthand;
     905             :         }
     906             : 
     907       48721 :         av_log(ctx, AV_LOG_DEBUG, "Setting '%s' to value '%s'\n", key, value);
     908             : 
     909       48721 :         if (av_opt_find(ctx, key, NULL, 0, 0)) {
     910           4 :             ret = av_opt_set(ctx, key, value, 0);
     911           4 :             if (ret < 0) {
     912           0 :                 av_free(value);
     913           0 :                 av_free(parsed_key);
     914           0 :                 return ret;
     915             :             }
     916             :         } else {
     917       48717 :         av_dict_set(options, key, value, 0);
     918       48717 :         if ((ret = av_opt_set(ctx->priv, key, value, AV_OPT_SEARCH_CHILDREN)) < 0) {
     919        4806 :             if (!av_opt_find(ctx->priv, key, NULL, 0, AV_OPT_SEARCH_CHILDREN | AV_OPT_SEARCH_FAKE_OBJ)) {
     920           0 :             if (ret == AVERROR_OPTION_NOT_FOUND)
     921           0 :                 av_log(ctx, AV_LOG_ERROR, "Option '%s' not found\n", key);
     922           0 :             av_free(value);
     923           0 :             av_free(parsed_key);
     924           0 :             return ret;
     925             :             }
     926             :         }
     927             :         }
     928             : 
     929       48721 :         av_free(value);
     930       48721 :         av_free(parsed_key);
     931       48721 :         count++;
     932             :     }
     933             : 
     934       16683 :     if (ctx->enable_str) {
     935           4 :         ret = set_enable_expr(ctx, ctx->enable_str);
     936           4 :         if (ret < 0)
     937           0 :             return ret;
     938             :     }
     939       16683 :     return count;
     940             : }
     941             : 
     942             : #if FF_API_AVFILTER_INIT_FILTER
     943           0 : int avfilter_init_filter(AVFilterContext *filter, const char *args, void *opaque)
     944             : {
     945           0 :     return avfilter_init_str(filter, args);
     946             : }
     947             : #endif
     948             : 
     949       26554 : int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
     950             : {
     951       26554 :     int ret = 0;
     952             : 
     953       26554 :     ret = av_opt_set_dict(ctx, options);
     954       26554 :     if (ret < 0) {
     955           0 :         av_log(ctx, AV_LOG_ERROR, "Error applying generic filter options.\n");
     956           0 :         return ret;
     957             :     }
     958             : 
     959       26810 :     if (ctx->filter->flags & AVFILTER_FLAG_SLICE_THREADS &&
     960         330 :         ctx->thread_type & ctx->graph->thread_type & AVFILTER_THREAD_SLICE &&
     961          74 :         ctx->graph->internal->thread_execute) {
     962          74 :         ctx->thread_type       = AVFILTER_THREAD_SLICE;
     963          74 :         ctx->internal->execute = ctx->graph->internal->thread_execute;
     964             :     } else {
     965       26480 :         ctx->thread_type = 0;
     966             :     }
     967             : 
     968       26554 :     if (ctx->filter->priv_class) {
     969       23119 :         ret = av_opt_set_dict2(ctx->priv, options, AV_OPT_SEARCH_CHILDREN);
     970       23119 :         if (ret < 0) {
     971           0 :             av_log(ctx, AV_LOG_ERROR, "Error applying options to the filter.\n");
     972           0 :             return ret;
     973             :         }
     974             :     }
     975             : 
     976       26554 :     if (ctx->filter->init_opaque)
     977        5269 :         ret = ctx->filter->init_opaque(ctx, NULL);
     978       21285 :     else if (ctx->filter->init)
     979       12418 :         ret = ctx->filter->init(ctx);
     980        8867 :     else if (ctx->filter->init_dict)
     981        4155 :         ret = ctx->filter->init_dict(ctx, options);
     982             : 
     983       26554 :     return ret;
     984             : }
     985             : 
     986       26554 : int avfilter_init_str(AVFilterContext *filter, const char *args)
     987             : {
     988       26554 :     AVDictionary *options = NULL;
     989             :     AVDictionaryEntry *e;
     990       26554 :     int ret = 0;
     991             : 
     992       26554 :     if (args && *args) {
     993       16683 :         if (!filter->filter->priv_class) {
     994           0 :             av_log(filter, AV_LOG_ERROR, "This filter does not take any "
     995             :                    "options, but options were provided: %s.\n", args);
     996           0 :             return AVERROR(EINVAL);
     997             :         }
     998             : 
     999             : #if FF_API_OLD_FILTER_OPTS || FF_API_OLD_FILTER_OPTS_ERROR
    1000       28539 :             if (   !strcmp(filter->filter->name, "format")     ||
    1001       23712 :                    !strcmp(filter->filter->name, "noformat")   ||
    1002       23712 :                    !strcmp(filter->filter->name, "frei0r")     ||
    1003       23712 :                    !strcmp(filter->filter->name, "frei0r_src") ||
    1004       23712 :                    !strcmp(filter->filter->name, "ocv")        ||
    1005       23706 :                    !strcmp(filter->filter->name, "pan")        ||
    1006       23692 :                    !strcmp(filter->filter->name, "pp")         ||
    1007       16687 :                    !strcmp(filter->filter->name, "aevalsrc")) {
    1008             :             /* a hack for compatibility with the old syntax
    1009             :              * replace colons with |s */
    1010        4845 :             char *copy = av_strdup(args);
    1011        4845 :             char *p    = copy;
    1012        4845 :             int nb_leading = 0; // number of leading colons to skip
    1013        4845 :             int deprecated = 0;
    1014             : 
    1015        4845 :             if (!copy) {
    1016           0 :                 ret = AVERROR(ENOMEM);
    1017           0 :                 goto fail;
    1018             :             }
    1019             : 
    1020        9690 :             if (!strcmp(filter->filter->name, "frei0r") ||
    1021        4845 :                 !strcmp(filter->filter->name, "ocv"))
    1022           0 :                 nb_leading = 1;
    1023        4845 :             else if (!strcmp(filter->filter->name, "frei0r_src"))
    1024           0 :                 nb_leading = 3;
    1025             : 
    1026        9690 :             while (nb_leading--) {
    1027           0 :                 p = strchr(p, ':');
    1028           0 :                 if (!p) {
    1029           0 :                     p = copy + strlen(copy);
    1030           0 :                     break;
    1031             :                 }
    1032           0 :                 p++;
    1033             :             }
    1034             : 
    1035        4845 :             deprecated = strchr(p, ':') != NULL;
    1036             : 
    1037        4845 :             if (!strcmp(filter->filter->name, "aevalsrc")) {
    1038           4 :                 deprecated = 0;
    1039           8 :                 while ((p = strchr(p, ':')) && p[1] != ':') {
    1040           4 :                     const char *epos = strchr(p + 1, '=');
    1041           4 :                     const char *spos = strchr(p + 1, ':');
    1042           4 :                     const int next_token_is_opt = epos && (!spos || epos < spos);
    1043           4 :                     if (next_token_is_opt) {
    1044           4 :                         p++;
    1045           4 :                         break;
    1046             :                     }
    1047             :                     /* next token does not contain a '=', assume a channel expression */
    1048           0 :                     deprecated = 1;
    1049           0 :                     *p++ = '|';
    1050             :                 }
    1051           4 :                 if (p && *p == ':') { // double sep '::' found
    1052           0 :                     deprecated = 1;
    1053           0 :                     memmove(p, p + 1, strlen(p));
    1054             :                 }
    1055             :             } else
    1056        9682 :             while ((p = strchr(p, ':')))
    1057           0 :                 *p++ = '|';
    1058             : 
    1059             : #if FF_API_OLD_FILTER_OPTS
    1060        4845 :             if (deprecated)
    1061           0 :                 av_log(filter, AV_LOG_WARNING, "This syntax is deprecated. Use "
    1062             :                        "'|' to separate the list items.\n");
    1063             : 
    1064        4845 :             av_log(filter, AV_LOG_DEBUG, "compat: called with args=[%s]\n", copy);
    1065        4845 :             ret = process_options(filter, &options, copy);
    1066             : #else
    1067             :             if (deprecated) {
    1068             :                 av_log(filter, AV_LOG_ERROR, "This syntax is deprecated. Use "
    1069             :                        "'|' to separate the list items ('%s' instead of '%s')\n",
    1070             :                        copy, args);
    1071             :                 ret = AVERROR(EINVAL);
    1072             :             } else {
    1073             :                 ret = process_options(filter, &options, copy);
    1074             :             }
    1075             : #endif
    1076        4845 :             av_freep(&copy);
    1077             : 
    1078        4845 :             if (ret < 0)
    1079           0 :                 goto fail;
    1080             :         } else
    1081             : #endif
    1082             :         {
    1083       11838 :             ret = process_options(filter, &options, args);
    1084       11838 :             if (ret < 0)
    1085           0 :                 goto fail;
    1086             :         }
    1087             :     }
    1088             : 
    1089       26554 :     ret = avfilter_init_dict(filter, &options);
    1090       26554 :     if (ret < 0)
    1091           0 :         goto fail;
    1092             : 
    1093       26554 :     if ((e = av_dict_get(options, "", NULL, AV_DICT_IGNORE_SUFFIX))) {
    1094           0 :         av_log(filter, AV_LOG_ERROR, "No such option: %s.\n", e->key);
    1095           0 :         ret = AVERROR_OPTION_NOT_FOUND;
    1096           0 :         goto fail;
    1097             :     }
    1098             : 
    1099       53108 : fail:
    1100       26554 :     av_dict_free(&options);
    1101             : 
    1102       26554 :     return ret;
    1103             : }
    1104             : 
    1105       16303 : const char *avfilter_pad_get_name(const AVFilterPad *pads, int pad_idx)
    1106             : {
    1107       16303 :     return pads[pad_idx].name;
    1108             : }
    1109             : 
    1110       21255 : enum AVMediaType avfilter_pad_get_type(const AVFilterPad *pads, int pad_idx)
    1111             : {
    1112       21255 :     return pads[pad_idx].type;
    1113             : }
    1114             : 
    1115      699812 : static int default_filter_frame(AVFilterLink *link, AVFrame *frame)
    1116             : {
    1117      699812 :     return ff_filter_frame(link->dst->outputs[0], frame);
    1118             : }
    1119             : 
    1120     1014426 : static int ff_filter_frame_framed(AVFilterLink *link, AVFrame *frame)
    1121             : {
    1122             :     int (*filter_frame)(AVFilterLink *, AVFrame *);
    1123     1014426 :     AVFilterContext *dstctx = link->dst;
    1124     1014426 :     AVFilterPad *dst = link->dstpad;
    1125             :     int ret;
    1126             : 
    1127     1014426 :     if (!(filter_frame = dst->filter_frame))
    1128      699803 :         filter_frame = default_filter_frame;
    1129             : 
    1130     1014426 :     if (dst->needs_writable) {
    1131        2167 :         ret = ff_inlink_make_frame_writable(link, &frame);
    1132        2167 :         if (ret < 0)
    1133           0 :             goto fail;
    1134             :     }
    1135             : 
    1136     1014426 :     ff_inlink_process_commands(link, frame);
    1137     1014426 :     dstctx->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1138             : 
    1139     1014445 :     if (dstctx->is_disabled &&
    1140          19 :         (dstctx->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC))
    1141           9 :         filter_frame = default_filter_frame;
    1142     1014426 :     ret = filter_frame(link, frame);
    1143     1014426 :     link->frame_count_out++;
    1144     1014426 :     return ret;
    1145             : 
    1146           0 : fail:
    1147           0 :     av_frame_free(&frame);
    1148           0 :     return ret;
    1149             : }
    1150             : 
    1151     1401415 : int ff_filter_frame(AVFilterLink *link, AVFrame *frame)
    1152             : {
    1153             :     int ret;
    1154     1401415 :     FF_TPRINTF_START(NULL, filter_frame); ff_tlog_link(NULL, link, 1); ff_tlog(NULL, " "); ff_tlog_ref(NULL, frame, 1);
    1155             : 
    1156             :     /* Consistency checks */
    1157     1401415 :     if (link->type == AVMEDIA_TYPE_VIDEO) {
    1158      505212 :         if (strcmp(link->dst->filter->name, "buffersink") &&
    1159      353088 :             strcmp(link->dst->filter->name, "format") &&
    1160      296852 :             strcmp(link->dst->filter->name, "idet") &&
    1161      148413 :             strcmp(link->dst->filter->name, "null") &&
    1162       60496 :             strcmp(link->dst->filter->name, "scale")) {
    1163             :             av_assert1(frame->format                 == link->format);
    1164             :             av_assert1(frame->width               == link->w);
    1165             :             av_assert1(frame->height               == link->h);
    1166             :         }
    1167             :     } else {
    1168     1100852 :         if (frame->format != link->format) {
    1169           0 :             av_log(link->dst, AV_LOG_ERROR, "Format change is not supported\n");
    1170           0 :             goto error;
    1171             :         }
    1172     1100852 :         if (frame->channels != link->channels) {
    1173           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel count change is not supported\n");
    1174           0 :             goto error;
    1175             :         }
    1176     1100852 :         if (frame->channel_layout != link->channel_layout) {
    1177           0 :             av_log(link->dst, AV_LOG_ERROR, "Channel layout change is not supported\n");
    1178           0 :             goto error;
    1179             :         }
    1180     1100852 :         if (frame->sample_rate != link->sample_rate) {
    1181           0 :             av_log(link->dst, AV_LOG_ERROR, "Sample rate change is not supported\n");
    1182           0 :             goto error;
    1183             :         }
    1184             :     }
    1185             : 
    1186     1401415 :     link->frame_blocked_in = link->frame_wanted_out = 0;
    1187     1401415 :     link->frame_count_in++;
    1188     1401415 :     filter_unblock(link->dst);
    1189     1401415 :     ret = ff_framequeue_add(&link->fifo, frame);
    1190     1401415 :     if (ret < 0) {
    1191           0 :         av_frame_free(&frame);
    1192           0 :         return ret;
    1193             :     }
    1194     1401415 :     ff_filter_set_ready(link->dst, 300);
    1195     1401415 :     return 0;
    1196             : 
    1197           0 : error:
    1198           0 :     av_frame_free(&frame);
    1199           0 :     return AVERROR_PATCHWELCOME;
    1200             : }
    1201             : 
    1202     2988663 : static int samples_ready(AVFilterLink *link, unsigned min)
    1203             : {
    1204     5018096 :     return ff_framequeue_queued_frames(&link->fifo) &&
    1205     1015590 :            (ff_framequeue_queued_samples(&link->fifo) >= min ||
    1206         583 :             link->status_in);
    1207             : }
    1208             : 
    1209       48504 : static int take_samples(AVFilterLink *link, unsigned min, unsigned max,
    1210             :                         AVFrame **rframe)
    1211             : {
    1212             :     AVFrame *frame0, *frame, *buf;
    1213             :     unsigned nb_samples, nb_frames, i, p;
    1214             :     int ret;
    1215             : 
    1216             :     /* Note: this function relies on no format changes and must only be
    1217             :        called with enough samples. */
    1218             :     av_assert1(samples_ready(link, link->min_samples));
    1219       48504 :     frame0 = frame = ff_framequeue_peek(&link->fifo, 0);
    1220       48504 :     if (!link->fifo.samples_skipped && frame->nb_samples >= min && frame->nb_samples <= max) {
    1221        4604 :         *rframe = ff_framequeue_take(&link->fifo);
    1222        4604 :         return 0;
    1223             :     }
    1224       43900 :     nb_frames = 0;
    1225       43900 :     nb_samples = 0;
    1226             :     while (1) {
    1227       96772 :         if (nb_samples + frame->nb_samples > max) {
    1228       39307 :             if (nb_samples < min)
    1229       39307 :                 nb_samples = max;
    1230       39307 :             break;
    1231             :         }
    1232       31029 :         nb_samples += frame->nb_samples;
    1233       31029 :         nb_frames++;
    1234       31029 :         if (nb_frames == ff_framequeue_queued_frames(&link->fifo))
    1235        4593 :             break;
    1236       26436 :         frame = ff_framequeue_peek(&link->fifo, nb_frames);
    1237             :     }
    1238             : 
    1239       43900 :     buf = ff_get_audio_buffer(link, nb_samples);
    1240       43900 :     if (!buf)
    1241           0 :         return AVERROR(ENOMEM);
    1242       43900 :     ret = av_frame_copy_props(buf, frame0);
    1243       43900 :     if (ret < 0) {
    1244           0 :         av_frame_free(&buf);
    1245           0 :         return ret;
    1246             :     }
    1247       43900 :     buf->pts = frame0->pts;
    1248             : 
    1249       43900 :     p = 0;
    1250       74929 :     for (i = 0; i < nb_frames; i++) {
    1251       31029 :         frame = ff_framequeue_take(&link->fifo);
    1252       62058 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0,
    1253       62058 :                         frame->nb_samples, link->channels, link->format);
    1254       31029 :         p += frame->nb_samples;
    1255       31029 :         av_frame_free(&frame);
    1256             :     }
    1257       43900 :     if (p < nb_samples) {
    1258       39307 :         unsigned n = nb_samples - p;
    1259       39307 :         frame = ff_framequeue_peek(&link->fifo, 0);
    1260       39307 :         av_samples_copy(buf->extended_data, frame->extended_data, p, 0, n,
    1261       39307 :                         link->channels, link->format);
    1262       39307 :         ff_framequeue_skip_samples(&link->fifo, n, link->time_base);
    1263             :     }
    1264             : 
    1265       43900 :     *rframe = buf;
    1266       43900 :     return 0;
    1267             : }
    1268             : 
    1269     1014426 : static int ff_filter_frame_to_filter(AVFilterLink *link)
    1270             : {
    1271     1014426 :     AVFrame *frame = NULL;
    1272     1014426 :     AVFilterContext *dst = link->dst;
    1273             :     int ret;
    1274             : 
    1275             :     av_assert1(ff_framequeue_queued_frames(&link->fifo));
    1276     2028852 :     ret = link->min_samples ?
    1277     1014426 :           ff_inlink_consume_samples(link, link->min_samples, link->max_samples, &frame) :
    1278             :           ff_inlink_consume_frame(link, &frame);
    1279             :     av_assert1(ret);
    1280     1014426 :     if (ret < 0) {
    1281             :         av_assert1(!frame);
    1282           0 :         return ret;
    1283             :     }
    1284             :     /* The filter will soon have received a new frame, that may allow it to
    1285             :        produce one or more: unblock its outputs. */
    1286     1014426 :     filter_unblock(dst);
    1287             :     /* AVFilterPad.filter_frame() expect frame_count_out to have the value
    1288             :        before the frame; ff_filter_frame_framed() will re-increment it. */
    1289     1014426 :     link->frame_count_out--;
    1290     1014426 :     ret = ff_filter_frame_framed(link, frame);
    1291     1014426 :     if (ret < 0 && ret != link->status_out) {
    1292           0 :         ff_avfilter_link_set_out_status(link, ret, AV_NOPTS_VALUE);
    1293             :     } else {
    1294             :         /* Run once again, to see if several frames were available, or if
    1295             :            the input status has also changed, or any other reason. */
    1296     1014426 :         ff_filter_set_ready(dst, 300);
    1297             :     }
    1298     1014426 :     return ret;
    1299             : }
    1300             : 
    1301       15171 : static int forward_status_change(AVFilterContext *filter, AVFilterLink *in)
    1302             : {
    1303       15171 :     unsigned out = 0, progress = 0;
    1304             :     int ret;
    1305             : 
    1306       15171 :     av_assert0(!in->status_out);
    1307       15171 :     if (!filter->nb_outputs) {
    1308             :         /* not necessary with the current API and sinks */
    1309           0 :         return 0;
    1310             :     }
    1311       45508 :     while (!in->status_out) {
    1312       15173 :         if (!filter->outputs[out]->status_in) {
    1313       15166 :             progress++;
    1314       15166 :             ret = ff_request_frame_to_filter(filter->outputs[out]);
    1315       15166 :             if (ret < 0)
    1316           0 :                 return ret;
    1317             :         }
    1318       15173 :         if (++out == filter->nb_outputs) {
    1319       15156 :             if (!progress) {
    1320             :                 /* Every output already closed: input no longer interesting
    1321             :                    (example: overlay in shortest mode, other input closed). */
    1322           7 :                 ff_avfilter_link_set_out_status(in, in->status_in, in->status_in_pts);
    1323           7 :                 return 0;
    1324             :             }
    1325       15149 :             progress = 0;
    1326       15149 :             out = 0;
    1327             :         }
    1328             :     }
    1329       15164 :     ff_filter_set_ready(filter, 200);
    1330       15164 :     return 0;
    1331             : }
    1332             : 
    1333     3342087 : static int ff_filter_activate_default(AVFilterContext *filter)
    1334             : {
    1335             :     unsigned i;
    1336             : 
    1337     5316324 :     for (i = 0; i < filter->nb_inputs; i++) {
    1338     2988663 :         if (samples_ready(filter->inputs[i], filter->inputs[i]->min_samples)) {
    1339     1014426 :             return ff_filter_frame_to_filter(filter->inputs[i]);
    1340             :         }
    1341             :     }
    1342     4285067 :     for (i = 0; i < filter->nb_inputs; i++) {
    1343     1972577 :         if (filter->inputs[i]->status_in && !filter->inputs[i]->status_out) {
    1344             :             av_assert1(!ff_framequeue_queued_frames(&filter->inputs[i]->fifo));
    1345       15171 :             return forward_status_change(filter, filter->inputs[i]);
    1346             :         }
    1347             :     }
    1348     3345114 :     for (i = 0; i < filter->nb_outputs; i++) {
    1349     3595220 :         if (filter->outputs[i]->frame_wanted_out &&
    1350     1281381 :             !filter->outputs[i]->frame_blocked_in) {
    1351     1281215 :             return ff_request_frame_to_filter(filter->outputs[i]);
    1352             :         }
    1353             :     }
    1354     1031275 :     return FFERROR_NOT_READY;
    1355             : }
    1356             : 
    1357             : /*
    1358             :    Filter scheduling and activation
    1359             : 
    1360             :    When a filter is activated, it must:
    1361             :    - if possible, output a frame;
    1362             :    - else, if relevant, forward the input status change;
    1363             :    - else, check outputs for wanted frames and forward the requests.
    1364             : 
    1365             :    The following AVFilterLink fields are used for activation:
    1366             : 
    1367             :    - frame_wanted_out:
    1368             : 
    1369             :      This field indicates if a frame is needed on this input of the
    1370             :      destination filter. A positive value indicates that a frame is needed
    1371             :      to process queued frames or internal data or to satisfy the
    1372             :      application; a zero value indicates that a frame is not especially
    1373             :      needed but could be processed anyway; a negative value indicates that a
    1374             :      frame would just be queued.
    1375             : 
    1376             :      It is set by filters using ff_request_frame() or ff_request_no_frame(),
    1377             :      when requested by the application through a specific API or when it is
    1378             :      set on one of the outputs.
    1379             : 
    1380             :      It is cleared when a frame is sent from the source using
    1381             :      ff_filter_frame().
    1382             : 
    1383             :      It is also cleared when a status change is sent from the source using
    1384             :      ff_avfilter_link_set_in_status().
    1385             : 
    1386             :    - frame_blocked_in:
    1387             : 
    1388             :      This field means that the source filter can not generate a frame as is.
    1389             :      Its goal is to avoid repeatedly calling the request_frame() method on
    1390             :      the same link.
    1391             : 
    1392             :      It is set by the framework on all outputs of a filter before activating it.
    1393             : 
    1394             :      It is automatically cleared by ff_filter_frame().
    1395             : 
    1396             :      It is also automatically cleared by ff_avfilter_link_set_in_status().
    1397             : 
    1398             :      It is also cleared on all outputs (using filter_unblock()) when
    1399             :      something happens on an input: processing a frame or changing the
    1400             :      status.
    1401             : 
    1402             :    - fifo:
    1403             : 
    1404             :      Contains the frames queued on a filter input. If it contains frames and
    1405             :      frame_wanted_out is not set, then the filter can be activated. If that
    1406             :      result in the filter not able to use these frames, the filter must set
    1407             :      frame_wanted_out to ask for more frames.
    1408             : 
    1409             :    - status_in and status_in_pts:
    1410             : 
    1411             :      Status (EOF or error code) of the link and timestamp of the status
    1412             :      change (in link time base, same as frames) as seen from the input of
    1413             :      the link. The status change is considered happening after the frames
    1414             :      queued in fifo.
    1415             : 
    1416             :      It is set by the source filter using ff_avfilter_link_set_in_status().
    1417             : 
    1418             :    - status_out:
    1419             : 
    1420             :      Status of the link as seen from the output of the link. The status
    1421             :      change is considered having already happened.
    1422             : 
    1423             :      It is set by the destination filter using
    1424             :      ff_avfilter_link_set_out_status().
    1425             : 
    1426             :    Filters are activated according to the ready field, set using the
    1427             :    ff_filter_set_ready(). Eventually, a priority queue will be used.
    1428             :    ff_filter_set_ready() is called whenever anything could cause progress to
    1429             :    be possible. Marking a filter ready when it is not is not a problem,
    1430             :    except for the small overhead it causes.
    1431             : 
    1432             :    Conditions that cause a filter to be marked ready are:
    1433             : 
    1434             :    - frames added on an input link;
    1435             : 
    1436             :    - changes in the input or output status of an input link;
    1437             : 
    1438             :    - requests for a frame on an output link;
    1439             : 
    1440             :    - after any actual processing using the legacy methods (filter_frame(),
    1441             :      and request_frame() to acknowledge status changes), to run once more
    1442             :      and check if enough input was present for several frames.
    1443             : 
    1444             :    Exemples of scenarios to consider:
    1445             : 
    1446             :    - buffersrc: activate if frame_wanted_out to notify the application;
    1447             :      activate when the application adds a frame to push it immediately.
    1448             : 
    1449             :    - testsrc: activate only if frame_wanted_out to produce and push a frame.
    1450             : 
    1451             :    - concat (not at stitch points): can process a frame on any output.
    1452             :      Activate if frame_wanted_out on output to forward on the corresponding
    1453             :      input. Activate when a frame is present on input to process it
    1454             :      immediately.
    1455             : 
    1456             :    - framesync: needs at least one frame on each input; extra frames on the
    1457             :      wrong input will accumulate. When a frame is first added on one input,
    1458             :      set frame_wanted_out<0 on it to avoid getting more (would trigger
    1459             :      testsrc) and frame_wanted_out>0 on the other to allow processing it.
    1460             : 
    1461             :    Activation of old filters:
    1462             : 
    1463             :    In order to activate a filter implementing the legacy filter_frame() and
    1464             :    request_frame() methods, perform the first possible of the following
    1465             :    actions:
    1466             : 
    1467             :    - If an input has frames in fifo and frame_wanted_out == 0, dequeue a
    1468             :      frame and call filter_frame().
    1469             : 
    1470             :      Ratinale: filter frames as soon as possible instead of leaving them
    1471             :      queued; frame_wanted_out < 0 is not possible since the old API does not
    1472             :      set it nor provides any similar feedback; frame_wanted_out > 0 happens
    1473             :      when min_samples > 0 and there are not enough samples queued.
    1474             : 
    1475             :    - If an input has status_in set but not status_out, try to call
    1476             :      request_frame() on one of the outputs in the hope that it will trigger
    1477             :      request_frame() on the input with status_in and acknowledge it. This is
    1478             :      awkward and fragile, filters with several inputs or outputs should be
    1479             :      updated to direct activation as soon as possible.
    1480             : 
    1481             :    - If an output has frame_wanted_out > 0 and not frame_blocked_in, call
    1482             :      request_frame().
    1483             : 
    1484             :      Rationale: checking frame_blocked_in is necessary to avoid requesting
    1485             :      repeatedly on a blocked input if another is not blocked (example:
    1486             :      [buffersrc1][testsrc1][buffersrc2][testsrc2]concat=v=2).
    1487             : 
    1488             :      TODO: respect needs_fifo and remove auto-inserted fifos.
    1489             : 
    1490             :  */
    1491             : 
    1492     3735433 : int ff_filter_activate(AVFilterContext *filter)
    1493             : {
    1494             :     int ret;
    1495             : 
    1496             :     /* Generic timeline support is not yet implemented but should be easy */
    1497             :     av_assert1(!(filter->filter->flags & AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC &&
    1498             :                  filter->filter->activate));
    1499     3735433 :     filter->ready = 0;
    1500     3735433 :     ret = filter->filter->activate ? filter->filter->activate(filter) :
    1501             :           ff_filter_activate_default(filter);
    1502     3735433 :     if (ret == FFERROR_NOT_READY)
    1503     1031276 :         ret = 0;
    1504     3735433 :     return ret;
    1505             : }
    1506             : 
    1507     2041090 : int ff_inlink_acknowledge_status(AVFilterLink *link, int *rstatus, int64_t *rpts)
    1508             : {
    1509     2041090 :     *rpts = link->current_pts;
    1510     2041090 :     if (ff_framequeue_queued_frames(&link->fifo))
    1511      148520 :         return *rstatus = 0;
    1512     1892570 :     if (link->status_out)
    1513        4596 :         return *rstatus = link->status_out;
    1514     1887974 :     if (!link->status_in)
    1515     1884657 :         return *rstatus = 0;
    1516        3317 :     *rstatus = link->status_out = link->status_in;
    1517        3317 :     ff_update_link_current_pts(link, link->status_in_pts);
    1518        3317 :     *rpts = link->current_pts;
    1519        3317 :     return 1;
    1520             : }
    1521             : 
    1522     3204079 : int ff_inlink_check_available_frame(AVFilterLink *link)
    1523             : {
    1524     3204079 :     return ff_framequeue_queued_frames(&link->fifo) > 0;
    1525             : }
    1526             : 
    1527      250180 : int ff_inlink_check_available_samples(AVFilterLink *link, unsigned min)
    1528             : {
    1529      250180 :     uint64_t samples = ff_framequeue_queued_samples(&link->fifo);
    1530             :     av_assert1(min);
    1531      250180 :     return samples >= min || (link->status_in && samples);
    1532             : }
    1533             : 
    1534     1414251 : static void consume_update(AVFilterLink *link, const AVFrame *frame)
    1535             : {
    1536     1414251 :     ff_update_link_current_pts(link, frame->pts);
    1537     1414251 :     ff_inlink_process_commands(link, frame);
    1538     1414251 :     link->dst->is_disabled = !ff_inlink_evaluate_timeline_at_frame(link, frame);
    1539     1414251 :     link->frame_count_out++;
    1540     1414251 : }
    1541             : 
    1542     3204079 : int ff_inlink_consume_frame(AVFilterLink *link, AVFrame **rframe)
    1543             : {
    1544             :     AVFrame *frame;
    1545             : 
    1546     3204079 :     *rframe = NULL;
    1547     3204079 :     if (!ff_inlink_check_available_frame(link))
    1548     1838332 :         return 0;
    1549             : 
    1550     1365747 :     if (link->fifo.samples_skipped) {
    1551           0 :         frame = ff_framequeue_peek(&link->fifo, 0);
    1552           0 :         return ff_inlink_consume_samples(link, frame->nb_samples, frame->nb_samples, rframe);
    1553             :     }
    1554             : 
    1555     1365747 :     frame = ff_framequeue_take(&link->fifo);
    1556     1365747 :     consume_update(link, frame);
    1557     1365747 :     *rframe = frame;
    1558     1365747 :     return 1;
    1559             : }
    1560             : 
    1561      250180 : int ff_inlink_consume_samples(AVFilterLink *link, unsigned min, unsigned max,
    1562             :                             AVFrame **rframe)
    1563             : {
    1564             :     AVFrame *frame;
    1565             :     int ret;
    1566             : 
    1567             :     av_assert1(min);
    1568      250180 :     *rframe = NULL;
    1569      250180 :     if (!ff_inlink_check_available_samples(link, min))
    1570      201676 :         return 0;
    1571       48504 :     if (link->status_in)
    1572          81 :         min = FFMIN(min, ff_framequeue_queued_samples(&link->fifo));
    1573       48504 :     ret = take_samples(link, min, link->max_samples, &frame);
    1574       48504 :     if (ret < 0)
    1575           0 :         return ret;
    1576       48504 :     consume_update(link, frame);
    1577       48504 :     *rframe = frame;
    1578       48504 :     return 1;
    1579             : }
    1580             : 
    1581        3103 : int ff_inlink_make_frame_writable(AVFilterLink *link, AVFrame **rframe)
    1582             : {
    1583        3103 :     AVFrame *frame = *rframe;
    1584             :     AVFrame *out;
    1585             :     int ret;
    1586             : 
    1587        3103 :     if (av_frame_is_writable(frame))
    1588        2979 :         return 0;
    1589         124 :     av_log(link->dst, AV_LOG_DEBUG, "Copying data in avfilter.\n");
    1590             : 
    1591         124 :     switch (link->type) {
    1592         124 :     case AVMEDIA_TYPE_VIDEO:
    1593         124 :         out = ff_get_video_buffer(link, link->w, link->h);
    1594         124 :         break;
    1595           0 :     case AVMEDIA_TYPE_AUDIO:
    1596           0 :         out = ff_get_audio_buffer(link, frame->nb_samples);
    1597           0 :         break;
    1598           0 :     default:
    1599           0 :         return AVERROR(EINVAL);
    1600             :     }
    1601         124 :     if (!out)
    1602           0 :         return AVERROR(ENOMEM);
    1603             : 
    1604         124 :     ret = av_frame_copy_props(out, frame);
    1605         124 :     if (ret < 0) {
    1606           0 :         av_frame_free(&out);
    1607           0 :         return ret;
    1608             :     }
    1609             : 
    1610         124 :     switch (link->type) {
    1611         124 :     case AVMEDIA_TYPE_VIDEO:
    1612         372 :         av_image_copy(out->data, out->linesize, (const uint8_t **)frame->data, frame->linesize,
    1613         372 :                       frame->format, frame->width, frame->height);
    1614         124 :         break;
    1615           0 :     case AVMEDIA_TYPE_AUDIO:
    1616           0 :         av_samples_copy(out->extended_data, frame->extended_data,
    1617           0 :                         0, 0, frame->nb_samples,
    1618           0 :                         frame->channels,
    1619           0 :                         frame->format);
    1620           0 :         break;
    1621           0 :     default:
    1622           0 :         av_assert0(!"reached");
    1623             :     }
    1624             : 
    1625         124 :     av_frame_free(&frame);
    1626         124 :     *rframe = out;
    1627         124 :     return 0;
    1628             : }
    1629             : 
    1630     2428677 : int ff_inlink_process_commands(AVFilterLink *link, const AVFrame *frame)
    1631             : {
    1632     2428677 :     AVFilterCommand *cmd = link->dst->command_queue;
    1633             : 
    1634     4857354 :     while(cmd && cmd->time <= frame->pts * av_q2d(link->time_base)){
    1635           0 :         av_log(link->dst, AV_LOG_DEBUG,
    1636             :                "Processing command time:%f command:%s arg:%s\n",
    1637             :                cmd->time, cmd->command, cmd->arg);
    1638           0 :         avfilter_process_command(link->dst, cmd->command, cmd->arg, 0, 0, cmd->flags);
    1639           0 :         ff_command_queue_pop(link->dst);
    1640           0 :         cmd= link->dst->command_queue;
    1641             :     }
    1642     2428677 :     return 0;
    1643             : }
    1644             : 
    1645     2428677 : int ff_inlink_evaluate_timeline_at_frame(AVFilterLink *link, const AVFrame *frame)
    1646             : {
    1647     2428677 :     AVFilterContext *dstctx = link->dst;
    1648     2428677 :     int64_t pts = frame->pts;
    1649     2428677 :     int64_t pos = frame->pkt_pos;
    1650             : 
    1651     2428677 :     if (!dstctx->enable_str)
    1652     2428481 :         return 1;
    1653             : 
    1654         196 :     dstctx->var_values[VAR_N] = link->frame_count_out;
    1655         196 :     dstctx->var_values[VAR_T] = pts == AV_NOPTS_VALUE ? NAN : pts * av_q2d(link->time_base);
    1656         196 :     dstctx->var_values[VAR_W] = link->w;
    1657         196 :     dstctx->var_values[VAR_H] = link->h;
    1658         196 :     dstctx->var_values[VAR_POS] = pos == -1 ? NAN : pos;
    1659             : 
    1660         196 :     return fabs(av_expr_eval(dstctx->enable, dstctx->var_values, NULL)) >= 0.5;
    1661             : }
    1662             : 
    1663      355089 : void ff_inlink_request_frame(AVFilterLink *link)
    1664             : {
    1665             :     av_assert1(!link->status_in);
    1666             :     av_assert1(!link->status_out);
    1667      355089 :     link->frame_wanted_out = 1;
    1668      355089 :     ff_filter_set_ready(link->src, 100);
    1669      355089 : }
    1670             : 
    1671           0 : void ff_inlink_set_status(AVFilterLink *link, int status)
    1672             : {
    1673           0 :     if (link->status_out)
    1674           0 :         return;
    1675           0 :     link->frame_wanted_out = 0;
    1676           0 :     link->frame_blocked_in = 0;
    1677           0 :     ff_avfilter_link_set_out_status(link, status, AV_NOPTS_VALUE);
    1678           0 :     while (ff_framequeue_queued_frames(&link->fifo)) {
    1679           0 :            AVFrame *frame = ff_framequeue_take(&link->fifo);
    1680           0 :            av_frame_free(&frame);
    1681             :     }
    1682           0 :     if (!link->status_in)
    1683           0 :         link->status_in = status;
    1684             : }
    1685             : 
    1686           0 : int ff_outlink_get_status(AVFilterLink *link)
    1687             : {
    1688           0 :     return link->status_in;
    1689             : }
    1690             : 
    1691           0 : const AVClass *avfilter_get_class(void)
    1692             : {
    1693           0 :     return &avfilter_class;
    1694             : }

Generated by: LCOV version 1.13