FFmpeg
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
avfiltergraph.c
Go to the documentation of this file.
1 /*
2  * filter graphs
3  * Copyright (c) 2008 Vitor Sessak
4  * Copyright (c) 2007 Bobby Bingham
5  *
6  * This file is part of FFmpeg.
7  *
8  * FFmpeg is free software; you can redistribute it and/or
9  * modify it under the terms of the GNU Lesser General Public
10  * License as published by the Free Software Foundation; either
11  * version 2.1 of the License, or (at your option) any later version.
12  *
13  * FFmpeg is distributed in the hope that it will be useful,
14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16  * Lesser General Public License for more details.
17  *
18  * You should have received a copy of the GNU Lesser General Public
19  * License along with FFmpeg; if not, write to the Free Software
20  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
21  */
22 
23 #include "config.h"
24 
25 #include <string.h>
26 
27 #include "libavutil/avassert.h"
28 #include "libavutil/avstring.h"
29 #include "libavutil/bprint.h"
31 #include "libavutil/internal.h"
32 #include "libavutil/opt.h"
33 #include "libavutil/pixdesc.h"
34 
35 #include "avfilter.h"
36 #include "formats.h"
37 #include "internal.h"
38 #include "thread.h"
39 
40 #define OFFSET(x) offsetof(AVFilterGraph, x)
41 #define FLAGS AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
42 static const AVOption filtergraph_options[] = {
43  { "thread_type", "Allowed thread types", OFFSET(thread_type), AV_OPT_TYPE_FLAGS,
44  { .i64 = AVFILTER_THREAD_SLICE }, 0, INT_MAX, FLAGS, "thread_type" },
45  { "slice", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = AVFILTER_THREAD_SLICE }, .flags = FLAGS, .unit = "thread_type" },
46  { "threads", "Maximum number of threads", OFFSET(nb_threads),
47  AV_OPT_TYPE_INT, { .i64 = 0 }, 0, INT_MAX, FLAGS },
48  {"scale_sws_opts" , "default scale filter options" , OFFSET(scale_sws_opts) ,
49  AV_OPT_TYPE_STRING, {.str = NULL}, 0, 0, FLAGS },
50  {"aresample_swr_opts" , "default aresample filter options" , OFFSET(aresample_swr_opts) ,
51  AV_OPT_TYPE_STRING, {.str = NULL}, 0, 0, FLAGS },
52  { NULL },
53 };
54 
55 static const AVClass filtergraph_class = {
56  .class_name = "AVFilterGraph",
57  .item_name = av_default_item_name,
58  .version = LIBAVUTIL_VERSION_INT,
59  .option = filtergraph_options,
60  .category = AV_CLASS_CATEGORY_FILTER,
61 };
62 
63 #if !HAVE_THREADS
65 {
66 }
67 
69 {
70  graph->thread_type = 0;
71  graph->nb_threads = 1;
72  return 0;
73 }
74 #endif
75 
77 {
78  AVFilterGraph *ret = av_mallocz(sizeof(*ret));
79  if (!ret)
80  return NULL;
81 
82  ret->internal = av_mallocz(sizeof(*ret->internal));
83  if (!ret->internal) {
84  av_freep(&ret);
85  return NULL;
86  }
87 
90 
91  return ret;
92 }
93 
95 {
96  int i;
97  for (i = 0; i < graph->nb_filters; i++) {
98  if (graph->filters[i] == filter) {
99  FFSWAP(AVFilterContext*, graph->filters[i],
100  graph->filters[graph->nb_filters - 1]);
101  graph->nb_filters--;
102  return;
103  }
104  }
105 }
106 
108 {
109  if (!*graph)
110  return;
111 
112  while ((*graph)->nb_filters)
113  avfilter_free((*graph)->filters[0]);
114 
115  ff_graph_thread_free(*graph);
116 
117  av_freep(&(*graph)->sink_links);
118 
119  av_freep(&(*graph)->scale_sws_opts);
120  av_freep(&(*graph)->aresample_swr_opts);
121  av_freep(&(*graph)->resample_lavr_opts);
122  av_freep(&(*graph)->filters);
123  av_freep(&(*graph)->internal);
124  av_freep(graph);
125 }
126 
127 #if FF_API_AVFILTER_OPEN
128 int avfilter_graph_add_filter(AVFilterGraph *graph, AVFilterContext *filter)
129 {
131  sizeof(*filters) * (graph->nb_filters + 1));
132  if (!filters)
133  return AVERROR(ENOMEM);
134 
135  graph->filters = filters;
136  graph->filters[graph->nb_filters++] = filter;
137 
138  filter->graph = graph;
139 
140  return 0;
141 }
142 #endif
143 
145  const char *name, const char *args, void *opaque,
146  AVFilterGraph *graph_ctx)
147 {
148  int ret;
149 
150  *filt_ctx = avfilter_graph_alloc_filter(graph_ctx, filt, name);
151  if (!*filt_ctx)
152  return AVERROR(ENOMEM);
153 
154  ret = avfilter_init_str(*filt_ctx, args);
155  if (ret < 0)
156  goto fail;
157 
158  return 0;
159 
160 fail:
161  if (*filt_ctx)
162  avfilter_free(*filt_ctx);
163  *filt_ctx = NULL;
164  return ret;
165 }
166 
168 {
169  graph->disable_auto_convert = flags;
170 }
171 
173  const AVFilter *filter,
174  const char *name)
175 {
177 
178  if (graph->thread_type && !graph->internal->thread_execute) {
179  if (graph->execute) {
180  graph->internal->thread_execute = graph->execute;
181  } else {
182  int ret = ff_graph_thread_init(graph);
183  if (ret < 0) {
184  av_log(graph, AV_LOG_ERROR, "Error initializing threading.\n");
185  return NULL;
186  }
187  }
188  }
189 
190  s = ff_filter_alloc(filter, name);
191  if (!s)
192  return NULL;
193 
194  filters = av_realloc(graph->filters, sizeof(*filters) * (graph->nb_filters + 1));
195  if (!filters) {
196  avfilter_free(s);
197  return NULL;
198  }
199 
200  graph->filters = filters;
201  graph->filters[graph->nb_filters++] = s;
202 
203  s->graph = graph;
204 
205  return s;
206 }
207 
208 /**
209  * Check for the validity of graph.
210  *
211  * A graph is considered valid if all its input and output pads are
212  * connected.
213  *
214  * @return >= 0 in case of success, a negative value otherwise
215  */
216 static int graph_check_validity(AVFilterGraph *graph, AVClass *log_ctx)
217 {
219  int i, j;
220 
221  for (i = 0; i < graph->nb_filters; i++) {
222  const AVFilterPad *pad;
223  filt = graph->filters[i];
224 
225  for (j = 0; j < filt->nb_inputs; j++) {
226  if (!filt->inputs[j] || !filt->inputs[j]->src) {
227  pad = &filt->input_pads[j];
228  av_log(log_ctx, AV_LOG_ERROR,
229  "Input pad \"%s\" with type %s of the filter instance \"%s\" of %s not connected to any source\n",
230  pad->name, av_get_media_type_string(pad->type), filt->name, filt->filter->name);
231  return AVERROR(EINVAL);
232  }
233  }
234 
235  for (j = 0; j < filt->nb_outputs; j++) {
236  if (!filt->outputs[j] || !filt->outputs[j]->dst) {
237  pad = &filt->output_pads[j];
238  av_log(log_ctx, AV_LOG_ERROR,
239  "Output pad \"%s\" with type %s of the filter instance \"%s\" of %s not connected to any destination\n",
240  pad->name, av_get_media_type_string(pad->type), filt->name, filt->filter->name);
241  return AVERROR(EINVAL);
242  }
243  }
244  }
245 
246  return 0;
247 }
248 
249 /**
250  * Configure all the links of graphctx.
251  *
252  * @return >= 0 in case of success, a negative value otherwise
253  */
254 static int graph_config_links(AVFilterGraph *graph, AVClass *log_ctx)
255 {
257  int i, ret;
258 
259  for (i = 0; i < graph->nb_filters; i++) {
260  filt = graph->filters[i];
261 
262  if (!filt->nb_outputs) {
263  if ((ret = avfilter_config_links(filt)))
264  return ret;
265  }
266  }
267 
268  return 0;
269 }
270 
272 {
273  int i;
274 
275  for (i = 0; i < graph->nb_filters; i++)
276  if (graph->filters[i]->name && !strcmp(name, graph->filters[i]->name))
277  return graph->filters[i];
278 
279  return NULL;
280 }
281 
283 {
284  if (!l)
285  return;
286  if (l->nb_channel_layouts) {
287  if (l->all_layouts || l->all_counts)
288  av_log(log, AV_LOG_WARNING, "All layouts set on non-empty list\n");
289  l->all_layouts = l->all_counts = 0;
290  } else {
291  if (l->all_counts && !l->all_layouts)
292  av_log(log, AV_LOG_WARNING, "All counts without all layouts\n");
293  l->all_layouts = 1;
294  }
295 }
296 
298 {
299  int ret, i;
301  AVFilterChannelLayouts *chlayouts;
302  AVFilterFormats *samplerates;
303  enum AVMediaType type = ctx->inputs && ctx->inputs [0] ? ctx->inputs [0]->type :
304  ctx->outputs && ctx->outputs[0] ? ctx->outputs[0]->type :
306 
307  if ((ret = ctx->filter->query_formats(ctx)) < 0) {
308  if (ret != AVERROR(EAGAIN))
309  av_log(ctx, AV_LOG_ERROR, "Query format failed for '%s': %s\n",
310  ctx->name, av_err2str(ret));
311  return ret;
312  }
313 
314  for (i = 0; i < ctx->nb_inputs; i++)
316  for (i = 0; i < ctx->nb_outputs; i++)
318 
319  formats = ff_all_formats(type);
320  if ((ret = ff_set_common_formats(ctx, formats)) < 0)
321  return ret;
322  if (type == AVMEDIA_TYPE_AUDIO) {
323  samplerates = ff_all_samplerates();
324  if ((ret = ff_set_common_samplerates(ctx, samplerates)) < 0)
325  return ret;
326  chlayouts = ff_all_channel_layouts();
327  if ((ret = ff_set_common_channel_layouts(ctx, chlayouts)) < 0)
328  return ret;
329  }
330  return 0;
331 }
332 
334 {
335  int i;
336 
337  for (i = 0; i < f->nb_inputs; i++) {
338  if (!f->inputs[i]->out_formats)
339  return 0;
340  if (f->inputs[i]->type == AVMEDIA_TYPE_AUDIO &&
341  !(f->inputs[i]->out_samplerates &&
342  f->inputs[i]->out_channel_layouts))
343  return 0;
344  }
345  for (i = 0; i < f->nb_outputs; i++) {
346  if (!f->outputs[i]->in_formats)
347  return 0;
348  if (f->outputs[i]->type == AVMEDIA_TYPE_AUDIO &&
349  !(f->outputs[i]->in_samplerates &&
350  f->outputs[i]->in_channel_layouts))
351  return 0;
352  }
353  return 1;
354 }
355 
357 {
358  AVFilterFormats *a = av_memdup(arg, sizeof(*arg));
359  if (a) {
360  a->refcount = 0;
361  a->refs = NULL;
362  a->formats = av_memdup(a->formats, sizeof(*a->formats) * a->nb_formats);
363  if (!a->formats && arg->formats)
364  av_freep(&a);
365  }
366  return a;
367 }
368 
370  AVFilterFormats *b_arg,
371  enum AVMediaType type,
372  int is_sample_rate)
373 {
374  AVFilterFormats *a, *b, *ret;
375  if (a_arg == b_arg)
376  return 1;
377  a = clone_filter_formats(a_arg);
378  b = clone_filter_formats(b_arg);
379 
380  if (!a || !b) {
381  if (a)
382  av_freep(&a->formats);
383  if (b)
384  av_freep(&b->formats);
385 
386  av_freep(&a);
387  av_freep(&b);
388 
389  return 0;
390  }
391 
392  if (is_sample_rate) {
393  ret = ff_merge_samplerates(a, b);
394  } else {
395  ret = ff_merge_formats(a, b, type);
396  }
397  if (ret) {
398  av_freep(&ret->formats);
399  av_freep(&ret->refs);
400  av_freep(&ret);
401  return 1;
402  } else {
403  av_freep(&a->formats);
404  av_freep(&b->formats);
405  av_freep(&a);
406  av_freep(&b);
407  return 0;
408  }
409 }
410 
411 /**
412  * Perform one round of query_formats() and merging formats lists on the
413  * filter graph.
414  * @return >=0 if all links formats lists could be queried and merged;
415  * AVERROR(EAGAIN) some progress was made in the queries or merging
416  * and a later call may succeed;
417  * AVERROR(EIO) (may be changed) plus a log message if no progress
418  * was made and the negotiation is stuck;
419  * a negative error code if some other error happened
420  */
421 static int query_formats(AVFilterGraph *graph, AVClass *log_ctx)
422 {
423  int i, j, ret;
424  int scaler_count = 0, resampler_count = 0;
425  int count_queried = 0; /* successful calls to query_formats() */
426  int count_merged = 0; /* successful merge of formats lists */
427  int count_already_merged = 0; /* lists already merged */
428  int count_delayed = 0; /* lists that need to be merged later */
429 
430  for (i = 0; i < graph->nb_filters; i++) {
431  AVFilterContext *f = graph->filters[i];
432  if (formats_declared(f))
433  continue;
434  if (f->filter->query_formats)
435  ret = filter_query_formats(f);
436  else
437  ret = ff_default_query_formats(f);
438  if (ret < 0 && ret != AVERROR(EAGAIN))
439  return ret;
440  /* note: EAGAIN could indicate a partial success, not counted yet */
441  count_queried += ret >= 0;
442  }
443 
444  /* go through and merge as many format lists as possible */
445  for (i = 0; i < graph->nb_filters; i++) {
446  AVFilterContext *filter = graph->filters[i];
447 
448  for (j = 0; j < filter->nb_inputs; j++) {
449  AVFilterLink *link = filter->inputs[j];
450  int convert_needed = 0;
451 
452  if (!link)
453  continue;
454 
455  if (link->in_formats != link->out_formats
456  && link->in_formats && link->out_formats)
457  if (!can_merge_formats(link->in_formats, link->out_formats,
458  link->type, 0))
459  convert_needed = 1;
460  if (link->type == AVMEDIA_TYPE_AUDIO) {
461  if (link->in_samplerates != link->out_samplerates
462  && link->in_samplerates && link->out_samplerates)
464  link->out_samplerates,
465  0, 1))
466  convert_needed = 1;
467  }
468 
469 #define MERGE_DISPATCH(field, statement) \
470  if (!(link->in_ ## field && link->out_ ## field)) { \
471  count_delayed++; \
472  } else if (link->in_ ## field == link->out_ ## field) { \
473  count_already_merged++; \
474  } else if (!convert_needed) { \
475  count_merged++; \
476  statement \
477  }
478 
479  if (link->type == AVMEDIA_TYPE_AUDIO) {
480  MERGE_DISPATCH(channel_layouts,
482  link->out_channel_layouts))
483  convert_needed = 1;
484  )
485  MERGE_DISPATCH(samplerates,
487  link->out_samplerates))
488  convert_needed = 1;
489  )
490  }
492  if (!ff_merge_formats(link->in_formats, link->out_formats,
493  link->type))
494  convert_needed = 1;
495  )
496 #undef MERGE_DISPATCH
497 
498  if (convert_needed) {
500  AVFilter *filter;
501  AVFilterLink *inlink, *outlink;
502  char scale_args[256];
503  char inst_name[30];
504 
505  /* couldn't merge format lists. auto-insert conversion filter */
506  switch (link->type) {
507  case AVMEDIA_TYPE_VIDEO:
508  if (!(filter = avfilter_get_by_name("scale"))) {
509  av_log(log_ctx, AV_LOG_ERROR, "'scale' filter "
510  "not present, cannot convert pixel formats.\n");
511  return AVERROR(EINVAL);
512  }
513 
514  snprintf(inst_name, sizeof(inst_name), "auto-inserted scaler %d",
515  scaler_count++);
516 
517  if ((ret = avfilter_graph_create_filter(&convert, filter,
518  inst_name, graph->scale_sws_opts, NULL,
519  graph)) < 0)
520  return ret;
521  break;
522  case AVMEDIA_TYPE_AUDIO:
523  if (!(filter = avfilter_get_by_name("aresample"))) {
524  av_log(log_ctx, AV_LOG_ERROR, "'aresample' filter "
525  "not present, cannot convert audio formats.\n");
526  return AVERROR(EINVAL);
527  }
528 
529  snprintf(inst_name, sizeof(inst_name), "auto-inserted resampler %d",
530  resampler_count++);
531  scale_args[0] = '\0';
532  if (graph->aresample_swr_opts)
533  snprintf(scale_args, sizeof(scale_args), "%s",
534  graph->aresample_swr_opts);
535  if ((ret = avfilter_graph_create_filter(&convert, filter,
536  inst_name, graph->aresample_swr_opts,
537  NULL, graph)) < 0)
538  return ret;
539  break;
540  default:
541  return AVERROR(EINVAL);
542  }
543 
544  if ((ret = avfilter_insert_filter(link, convert, 0, 0)) < 0)
545  return ret;
546 
547  if ((ret = filter_query_formats(convert)) < 0)
548  return ret;
549 
550  inlink = convert->inputs[0];
551  outlink = convert->outputs[0];
552  av_assert0( inlink-> in_formats->refcount > 0);
553  av_assert0( inlink->out_formats->refcount > 0);
554  av_assert0(outlink-> in_formats->refcount > 0);
555  av_assert0(outlink->out_formats->refcount > 0);
556  if (outlink->type == AVMEDIA_TYPE_AUDIO) {
557  av_assert0( inlink-> in_samplerates->refcount > 0);
558  av_assert0( inlink->out_samplerates->refcount > 0);
559  av_assert0(outlink-> in_samplerates->refcount > 0);
560  av_assert0(outlink->out_samplerates->refcount > 0);
561  av_assert0( inlink-> in_channel_layouts->refcount > 0);
562  av_assert0( inlink->out_channel_layouts->refcount > 0);
563  av_assert0(outlink-> in_channel_layouts->refcount > 0);
564  av_assert0(outlink->out_channel_layouts->refcount > 0);
565  }
566  if (!ff_merge_formats( inlink->in_formats, inlink->out_formats, inlink->type) ||
567  !ff_merge_formats(outlink->in_formats, outlink->out_formats, outlink->type))
568  ret = AVERROR(ENOSYS);
569  if (inlink->type == AVMEDIA_TYPE_AUDIO &&
571  inlink->out_samplerates) ||
573  inlink->out_channel_layouts)))
574  ret = AVERROR(ENOSYS);
575  if (outlink->type == AVMEDIA_TYPE_AUDIO &&
577  outlink->out_samplerates) ||
579  outlink->out_channel_layouts)))
580  ret = AVERROR(ENOSYS);
581 
582  if (ret < 0) {
583  av_log(log_ctx, AV_LOG_ERROR,
584  "Impossible to convert between the formats supported by the filter "
585  "'%s' and the filter '%s'\n", link->src->name, link->dst->name);
586  return ret;
587  }
588  }
589  }
590  }
591 
592  av_log(graph, AV_LOG_DEBUG, "query_formats: "
593  "%d queried, %d merged, %d already done, %d delayed\n",
594  count_queried, count_merged, count_already_merged, count_delayed);
595  if (count_delayed) {
596  AVBPrint bp;
597 
598  /* if count_queried > 0, one filter at least did set its formats,
599  that will give additional information to its neighbour;
600  if count_merged > 0, one pair of formats lists at least was merged,
601  that will give additional information to all connected filters;
602  in both cases, progress was made and a new round must be done */
603  if (count_queried || count_merged)
604  return AVERROR(EAGAIN);
606  for (i = 0; i < graph->nb_filters; i++)
607  if (!formats_declared(graph->filters[i]))
608  av_bprintf(&bp, "%s%s", bp.len ? ", " : "",
609  graph->filters[i]->name);
610  av_log(graph, AV_LOG_ERROR,
611  "The following filters could not choose their formats: %s\n"
612  "Consider inserting the (a)format filter near their input or "
613  "output.\n", bp.str);
614  return AVERROR(EIO);
615  }
616  return 0;
617 }
618 
619 static int get_fmt_score(enum AVSampleFormat dst_fmt, enum AVSampleFormat src_fmt)
620 {
621  int score = 0;
622 
623  if (av_sample_fmt_is_planar(dst_fmt) != av_sample_fmt_is_planar(src_fmt))
624  score ++;
625 
626  if (av_get_bytes_per_sample(dst_fmt) < av_get_bytes_per_sample(src_fmt)) {
627  score += 100 * (av_get_bytes_per_sample(src_fmt) - av_get_bytes_per_sample(dst_fmt));
628  }else
629  score += 10 * (av_get_bytes_per_sample(dst_fmt) - av_get_bytes_per_sample(src_fmt));
630 
633  score += 20;
634 
637  score += 2;
638 
639  return score;
640 }
641 
643  enum AVSampleFormat src_fmt)
644 {
645  int score1, score2;
646 
647  score1 = get_fmt_score(dst_fmt1, src_fmt);
648  score2 = get_fmt_score(dst_fmt2, src_fmt);
649 
650  return score1 < score2 ? dst_fmt1 : dst_fmt2;
651 }
652 
653 static int pick_format(AVFilterLink *link, AVFilterLink *ref)
654 {
655  if (!link || !link->in_formats)
656  return 0;
657 
658  if (link->type == AVMEDIA_TYPE_VIDEO) {
659  if(ref && ref->type == AVMEDIA_TYPE_VIDEO){
660  int has_alpha= av_pix_fmt_desc_get(ref->format)->nb_components % 2 == 0;
661  enum AVPixelFormat best= AV_PIX_FMT_NONE;
662  int i;
663  for (i=0; i<link->in_formats->nb_formats; i++) {
664  enum AVPixelFormat p = link->in_formats->formats[i];
665  best= av_find_best_pix_fmt_of_2(best, p, ref->format, has_alpha, NULL);
666  }
667  av_log(link->src,AV_LOG_DEBUG, "picking %s out of %d ref:%s alpha:%d\n",
669  av_get_pix_fmt_name(ref->format), has_alpha);
670  link->in_formats->formats[0] = best;
671  }
672  } else if (link->type == AVMEDIA_TYPE_AUDIO) {
673  if(ref && ref->type == AVMEDIA_TYPE_AUDIO){
675  int i;
676  for (i=0; i<link->in_formats->nb_formats; i++) {
677  enum AVSampleFormat p = link->in_formats->formats[i];
678  best = find_best_sample_fmt_of_2(best, p, ref->format);
679  }
680  av_log(link->src,AV_LOG_DEBUG, "picking %s out of %d ref:%s\n",
683  link->in_formats->formats[0] = best;
684  }
685  }
686 
687  link->in_formats->nb_formats = 1;
688  link->format = link->in_formats->formats[0];
689 
690  if (link->type == AVMEDIA_TYPE_AUDIO) {
691  if (!link->in_samplerates->nb_formats) {
692  av_log(link->src, AV_LOG_ERROR, "Cannot select sample rate for"
693  " the link between filters %s and %s.\n", link->src->name,
694  link->dst->name);
695  return AVERROR(EINVAL);
696  }
697  link->in_samplerates->nb_formats = 1;
698  link->sample_rate = link->in_samplerates->formats[0];
699 
700  if (link->in_channel_layouts->all_layouts) {
701  av_log(link->src, AV_LOG_ERROR, "Cannot select channel layout for"
702  " the link between filters %s and %s.\n", link->src->name,
703  link->dst->name);
704  if (!link->in_channel_layouts->all_counts)
705  av_log(link->src, AV_LOG_ERROR, "Unknown channel layouts not "
706  "supported, try specifying a channel layout using "
707  "'aformat=channel_layouts=something'.\n");
708  return AVERROR(EINVAL);
709  }
712  if ((link->channels = FF_LAYOUT2COUNT(link->channel_layout)))
713  link->channel_layout = 0;
714  else
716  }
717 
724 
725  return 0;
726 }
727 
728 #define REDUCE_FORMATS(fmt_type, list_type, list, var, nb, add_format, unref_format) \
729 do { \
730  for (i = 0; i < filter->nb_inputs; i++) { \
731  AVFilterLink *link = filter->inputs[i]; \
732  fmt_type fmt; \
733  \
734  if (!link->out_ ## list || link->out_ ## list->nb != 1) \
735  continue; \
736  fmt = link->out_ ## list->var[0]; \
737  \
738  for (j = 0; j < filter->nb_outputs; j++) { \
739  AVFilterLink *out_link = filter->outputs[j]; \
740  list_type *fmts; \
741  \
742  if (link->type != out_link->type || \
743  out_link->in_ ## list->nb == 1) \
744  continue; \
745  fmts = out_link->in_ ## list; \
746  \
747  if (!out_link->in_ ## list->nb) { \
748  if ((ret = add_format(&out_link->in_ ##list, fmt)) < 0)\
749  return ret; \
750  ret = 1; \
751  break; \
752  } \
753  \
754  for (k = 0; k < out_link->in_ ## list->nb; k++) \
755  if (fmts->var[k] == fmt) { \
756  fmts->var[0] = fmt; \
757  fmts->nb = 1; \
758  ret = 1; \
759  break; \
760  } \
761  } \
762  } \
763 } while (0)
764 
766 {
767  int i, j, k, ret = 0;
768 
770  nb_formats, ff_add_format, ff_formats_unref);
771  REDUCE_FORMATS(int, AVFilterFormats, samplerates, formats,
772  nb_formats, ff_add_format, ff_formats_unref);
773 
774  /* reduce channel layouts */
775  for (i = 0; i < filter->nb_inputs; i++) {
776  AVFilterLink *inlink = filter->inputs[i];
777  uint64_t fmt;
778 
779  if (!inlink->out_channel_layouts ||
781  continue;
782  fmt = inlink->out_channel_layouts->channel_layouts[0];
783 
784  for (j = 0; j < filter->nb_outputs; j++) {
785  AVFilterLink *outlink = filter->outputs[j];
787 
788  fmts = outlink->in_channel_layouts;
789  if (inlink->type != outlink->type || fmts->nb_channel_layouts == 1)
790  continue;
791 
792  if (fmts->all_layouts &&
793  (!FF_LAYOUT2COUNT(fmt) || fmts->all_counts)) {
794  /* Turn the infinite list into a singleton */
795  fmts->all_layouts = fmts->all_counts = 0;
796  if (ff_add_channel_layout(&outlink->in_channel_layouts, fmt) < 0)
797  ret = 1;
798  break;
799  }
800 
801  for (k = 0; k < outlink->in_channel_layouts->nb_channel_layouts; k++) {
802  if (fmts->channel_layouts[k] == fmt) {
803  fmts->channel_layouts[0] = fmt;
804  fmts->nb_channel_layouts = 1;
805  ret = 1;
806  break;
807  }
808  }
809  }
810  }
811 
812  return ret;
813 }
814 
815 static int reduce_formats(AVFilterGraph *graph)
816 {
817  int i, reduced, ret;
818 
819  do {
820  reduced = 0;
821 
822  for (i = 0; i < graph->nb_filters; i++) {
823  if ((ret = reduce_formats_on_filter(graph->filters[i])) < 0)
824  return ret;
825  reduced |= ret;
826  }
827  } while (reduced);
828 
829  return 0;
830 }
831 
833 {
834  AVFilterLink *link = NULL;
835  int sample_rate;
836  int i, j;
837 
838  for (i = 0; i < filter->nb_inputs; i++) {
839  link = filter->inputs[i];
840 
841  if (link->type == AVMEDIA_TYPE_AUDIO &&
842  link->out_samplerates->nb_formats== 1)
843  break;
844  }
845  if (i == filter->nb_inputs)
846  return;
847 
848  sample_rate = link->out_samplerates->formats[0];
849 
850  for (i = 0; i < filter->nb_outputs; i++) {
851  AVFilterLink *outlink = filter->outputs[i];
852  int best_idx, best_diff = INT_MAX;
853 
854  if (outlink->type != AVMEDIA_TYPE_AUDIO ||
855  outlink->in_samplerates->nb_formats < 2)
856  continue;
857 
858  for (j = 0; j < outlink->in_samplerates->nb_formats; j++) {
859  int diff = abs(sample_rate - outlink->in_samplerates->formats[j]);
860 
861  if (diff < best_diff) {
862  best_diff = diff;
863  best_idx = j;
864  }
865  }
866  FFSWAP(int, outlink->in_samplerates->formats[0],
867  outlink->in_samplerates->formats[best_idx]);
868  }
869 }
870 
871 static void swap_samplerates(AVFilterGraph *graph)
872 {
873  int i;
874 
875  for (i = 0; i < graph->nb_filters; i++)
877 }
878 
879 #define CH_CENTER_PAIR (AV_CH_FRONT_LEFT_OF_CENTER | AV_CH_FRONT_RIGHT_OF_CENTER)
880 #define CH_FRONT_PAIR (AV_CH_FRONT_LEFT | AV_CH_FRONT_RIGHT)
881 #define CH_STEREO_PAIR (AV_CH_STEREO_LEFT | AV_CH_STEREO_RIGHT)
882 #define CH_WIDE_PAIR (AV_CH_WIDE_LEFT | AV_CH_WIDE_RIGHT)
883 #define CH_SIDE_PAIR (AV_CH_SIDE_LEFT | AV_CH_SIDE_RIGHT)
884 #define CH_DIRECT_PAIR (AV_CH_SURROUND_DIRECT_LEFT | AV_CH_SURROUND_DIRECT_RIGHT)
885 #define CH_BACK_PAIR (AV_CH_BACK_LEFT | AV_CH_BACK_RIGHT)
886 
887 /* allowable substitutions for channel pairs when comparing layouts,
888  * ordered by priority for both values */
889 static const uint64_t ch_subst[][2] = {
911 };
912 
914 {
915  AVFilterLink *link = NULL;
916  int i, j, k;
917 
918  for (i = 0; i < filter->nb_inputs; i++) {
919  link = filter->inputs[i];
920 
921  if (link->type == AVMEDIA_TYPE_AUDIO &&
923  break;
924  }
925  if (i == filter->nb_inputs)
926  return;
927 
928  for (i = 0; i < filter->nb_outputs; i++) {
929  AVFilterLink *outlink = filter->outputs[i];
930  int best_idx = -1, best_score = INT_MIN, best_count_diff = INT_MAX;
931 
932  if (outlink->type != AVMEDIA_TYPE_AUDIO ||
934  continue;
935 
936  for (j = 0; j < outlink->in_channel_layouts->nb_channel_layouts; j++) {
937  uint64_t in_chlayout = link->out_channel_layouts->channel_layouts[0];
938  uint64_t out_chlayout = outlink->in_channel_layouts->channel_layouts[j];
939  int in_channels = av_get_channel_layout_nb_channels(in_chlayout);
940  int out_channels = av_get_channel_layout_nb_channels(out_chlayout);
941  int count_diff = out_channels - in_channels;
942  int matched_channels, extra_channels;
943  int score = 100000;
944 
945  if (FF_LAYOUT2COUNT(in_chlayout) || FF_LAYOUT2COUNT(out_chlayout)) {
946  /* Compute score in case the input or output layout encodes
947  a channel count; in this case the score is not altered by
948  the computation afterwards, as in_chlayout and
949  out_chlayout have both been set to 0 */
950  if (FF_LAYOUT2COUNT(in_chlayout))
951  in_channels = FF_LAYOUT2COUNT(in_chlayout);
952  if (FF_LAYOUT2COUNT(out_chlayout))
953  out_channels = FF_LAYOUT2COUNT(out_chlayout);
954  score -= 10000 + FFABS(out_channels - in_channels) +
955  (in_channels > out_channels ? 10000 : 0);
956  in_chlayout = out_chlayout = 0;
957  /* Let the remaining computation run, even if the score
958  value is not altered */
959  }
960 
961  /* channel substitution */
962  for (k = 0; k < FF_ARRAY_ELEMS(ch_subst); k++) {
963  uint64_t cmp0 = ch_subst[k][0];
964  uint64_t cmp1 = ch_subst[k][1];
965  if (( in_chlayout & cmp0) && (!(out_chlayout & cmp0)) &&
966  (out_chlayout & cmp1) && (!( in_chlayout & cmp1))) {
967  in_chlayout &= ~cmp0;
968  out_chlayout &= ~cmp1;
969  /* add score for channel match, minus a deduction for
970  having to do the substitution */
971  score += 10 * av_get_channel_layout_nb_channels(cmp1) - 2;
972  }
973  }
974 
975  /* no penalty for LFE channel mismatch */
976  if ( (in_chlayout & AV_CH_LOW_FREQUENCY) &&
977  (out_chlayout & AV_CH_LOW_FREQUENCY))
978  score += 10;
979  in_chlayout &= ~AV_CH_LOW_FREQUENCY;
980  out_chlayout &= ~AV_CH_LOW_FREQUENCY;
981 
982  matched_channels = av_get_channel_layout_nb_channels(in_chlayout &
983  out_chlayout);
984  extra_channels = av_get_channel_layout_nb_channels(out_chlayout &
985  (~in_chlayout));
986  score += 10 * matched_channels - 5 * extra_channels;
987 
988  if (score > best_score ||
989  (count_diff < best_count_diff && score == best_score)) {
990  best_score = score;
991  best_idx = j;
992  best_count_diff = count_diff;
993  }
994  }
995  av_assert0(best_idx >= 0);
996  FFSWAP(uint64_t, outlink->in_channel_layouts->channel_layouts[0],
997  outlink->in_channel_layouts->channel_layouts[best_idx]);
998  }
999 
1000 }
1001 
1003 {
1004  int i;
1005 
1006  for (i = 0; i < graph->nb_filters; i++)
1008 }
1009 
1011 {
1012  AVFilterLink *link = NULL;
1013  int format, bps;
1014  int i, j;
1015 
1016  for (i = 0; i < filter->nb_inputs; i++) {
1017  link = filter->inputs[i];
1018 
1019  if (link->type == AVMEDIA_TYPE_AUDIO &&
1020  link->out_formats->nb_formats == 1)
1021  break;
1022  }
1023  if (i == filter->nb_inputs)
1024  return;
1025 
1026  format = link->out_formats->formats[0];
1027  bps = av_get_bytes_per_sample(format);
1028 
1029  for (i = 0; i < filter->nb_outputs; i++) {
1030  AVFilterLink *outlink = filter->outputs[i];
1031  int best_idx = -1, best_score = INT_MIN;
1032 
1033  if (outlink->type != AVMEDIA_TYPE_AUDIO ||
1034  outlink->in_formats->nb_formats < 2)
1035  continue;
1036 
1037  for (j = 0; j < outlink->in_formats->nb_formats; j++) {
1038  int out_format = outlink->in_formats->formats[j];
1039  int out_bps = av_get_bytes_per_sample(out_format);
1040  int score;
1041 
1042  if (av_get_packed_sample_fmt(out_format) == format ||
1043  av_get_planar_sample_fmt(out_format) == format) {
1044  best_idx = j;
1045  break;
1046  }
1047 
1048  /* for s32 and float prefer double to prevent loss of information */
1049  if (bps == 4 && out_bps == 8) {
1050  best_idx = j;
1051  break;
1052  }
1053 
1054  /* prefer closest higher or equal bps */
1055  score = -abs(out_bps - bps);
1056  if (out_bps >= bps)
1057  score += INT_MAX/2;
1058 
1059  if (score > best_score) {
1060  best_score = score;
1061  best_idx = j;
1062  }
1063  }
1064  av_assert0(best_idx >= 0);
1065  FFSWAP(int, outlink->in_formats->formats[0],
1066  outlink->in_formats->formats[best_idx]);
1067  }
1068 }
1069 
1070 static void swap_sample_fmts(AVFilterGraph *graph)
1071 {
1072  int i;
1073 
1074  for (i = 0; i < graph->nb_filters; i++)
1076 
1077 }
1078 
1079 static int pick_formats(AVFilterGraph *graph)
1080 {
1081  int i, j, ret;
1082  int change;
1083 
1084  do{
1085  change = 0;
1086  for (i = 0; i < graph->nb_filters; i++) {
1087  AVFilterContext *filter = graph->filters[i];
1088  if (filter->nb_inputs){
1089  for (j = 0; j < filter->nb_inputs; j++){
1090  if(filter->inputs[j]->in_formats && filter->inputs[j]->in_formats->nb_formats == 1) {
1091  if ((ret = pick_format(filter->inputs[j], NULL)) < 0)
1092  return ret;
1093  change = 1;
1094  }
1095  }
1096  }
1097  if (filter->nb_outputs){
1098  for (j = 0; j < filter->nb_outputs; j++){
1099  if(filter->outputs[j]->in_formats && filter->outputs[j]->in_formats->nb_formats == 1) {
1100  if ((ret = pick_format(filter->outputs[j], NULL)) < 0)
1101  return ret;
1102  change = 1;
1103  }
1104  }
1105  }
1106  if (filter->nb_inputs && filter->nb_outputs && filter->inputs[0]->format>=0) {
1107  for (j = 0; j < filter->nb_outputs; j++) {
1108  if(filter->outputs[j]->format<0) {
1109  if ((ret = pick_format(filter->outputs[j], filter->inputs[0])) < 0)
1110  return ret;
1111  change = 1;
1112  }
1113  }
1114  }
1115  }
1116  }while(change);
1117 
1118  for (i = 0; i < graph->nb_filters; i++) {
1119  AVFilterContext *filter = graph->filters[i];
1120 
1121  for (j = 0; j < filter->nb_inputs; j++)
1122  if ((ret = pick_format(filter->inputs[j], NULL)) < 0)
1123  return ret;
1124  for (j = 0; j < filter->nb_outputs; j++)
1125  if ((ret = pick_format(filter->outputs[j], NULL)) < 0)
1126  return ret;
1127  }
1128  return 0;
1129 }
1130 
1131 /**
1132  * Configure the formats of all the links in the graph.
1133  */
1134 static int graph_config_formats(AVFilterGraph *graph, AVClass *log_ctx)
1135 {
1136  int ret;
1137 
1138  /* find supported formats from sub-filters, and merge along links */
1139  while ((ret = query_formats(graph, log_ctx)) == AVERROR(EAGAIN))
1140  av_log(graph, AV_LOG_DEBUG, "query_formats not finished\n");
1141  if (ret < 0)
1142  return ret;
1143 
1144  /* Once everything is merged, it's possible that we'll still have
1145  * multiple valid media format choices. We try to minimize the amount
1146  * of format conversion inside filters */
1147  if ((ret = reduce_formats(graph)) < 0)
1148  return ret;
1149 
1150  /* for audio filters, ensure the best format, sample rate and channel layout
1151  * is selected */
1152  swap_sample_fmts(graph);
1153  swap_samplerates(graph);
1154  swap_channel_layouts(graph);
1155 
1156  if ((ret = pick_formats(graph)) < 0)
1157  return ret;
1158 
1159  return 0;
1160 }
1161 
1163  AVClass *log_ctx)
1164 {
1165  unsigned i, j;
1166  int sink_links_count = 0, n = 0;
1167  AVFilterContext *f;
1168  AVFilterLink **sinks;
1169 
1170  for (i = 0; i < graph->nb_filters; i++) {
1171  f = graph->filters[i];
1172  for (j = 0; j < f->nb_inputs; j++) {
1173  f->inputs[j]->graph = graph;
1174  f->inputs[j]->age_index = -1;
1175  }
1176  for (j = 0; j < f->nb_outputs; j++) {
1177  f->outputs[j]->graph = graph;
1178  f->outputs[j]->age_index= -1;
1179  }
1180  if (!f->nb_outputs) {
1181  if (f->nb_inputs > INT_MAX - sink_links_count)
1182  return AVERROR(EINVAL);
1183  sink_links_count += f->nb_inputs;
1184  }
1185  }
1186  sinks = av_calloc(sink_links_count, sizeof(*sinks));
1187  if (!sinks)
1188  return AVERROR(ENOMEM);
1189  for (i = 0; i < graph->nb_filters; i++) {
1190  f = graph->filters[i];
1191  if (!f->nb_outputs) {
1192  for (j = 0; j < f->nb_inputs; j++) {
1193  sinks[n] = f->inputs[j];
1194  f->inputs[j]->age_index = n++;
1195  }
1196  }
1197  }
1198  av_assert0(n == sink_links_count);
1199  graph->sink_links = sinks;
1200  graph->sink_links_count = sink_links_count;
1201  return 0;
1202 }
1203 
1204 static int graph_insert_fifos(AVFilterGraph *graph, AVClass *log_ctx)
1205 {
1206  AVFilterContext *f;
1207  int i, j, ret;
1208  int fifo_count = 0;
1209 
1210  for (i = 0; i < graph->nb_filters; i++) {
1211  f = graph->filters[i];
1212 
1213  for (j = 0; j < f->nb_inputs; j++) {
1214  AVFilterLink *link = f->inputs[j];
1215  AVFilterContext *fifo_ctx;
1216  AVFilter *fifo;
1217  char name[32];
1218 
1219  if (!link->dstpad->needs_fifo)
1220  continue;
1221 
1222  fifo = f->inputs[j]->type == AVMEDIA_TYPE_VIDEO ?
1223  avfilter_get_by_name("fifo") :
1224  avfilter_get_by_name("afifo");
1225 
1226  snprintf(name, sizeof(name), "auto-inserted fifo %d", fifo_count++);
1227 
1228  ret = avfilter_graph_create_filter(&fifo_ctx, fifo, name, NULL,
1229  NULL, graph);
1230  if (ret < 0)
1231  return ret;
1232 
1233  ret = avfilter_insert_filter(link, fifo_ctx, 0, 0);
1234  if (ret < 0)
1235  return ret;
1236  }
1237  }
1238 
1239  return 0;
1240 }
1241 
1242 int avfilter_graph_config(AVFilterGraph *graphctx, void *log_ctx)
1243 {
1244  int ret;
1245 
1246  if ((ret = graph_check_validity(graphctx, log_ctx)))
1247  return ret;
1248  if ((ret = graph_insert_fifos(graphctx, log_ctx)) < 0)
1249  return ret;
1250  if ((ret = graph_config_formats(graphctx, log_ctx)))
1251  return ret;
1252  if ((ret = graph_config_links(graphctx, log_ctx)))
1253  return ret;
1254  if ((ret = graph_config_pointers(graphctx, log_ctx)))
1255  return ret;
1256 
1257  return 0;
1258 }
1259 
1260 int avfilter_graph_send_command(AVFilterGraph *graph, const char *target, const char *cmd, const char *arg, char *res, int res_len, int flags)
1261 {
1262  int i, r = AVERROR(ENOSYS);
1263 
1264  if (!graph)
1265  return r;
1266 
1267  if ((flags & AVFILTER_CMD_FLAG_ONE) && !(flags & AVFILTER_CMD_FLAG_FAST)) {
1268  r = avfilter_graph_send_command(graph, target, cmd, arg, res, res_len, flags | AVFILTER_CMD_FLAG_FAST);
1269  if (r != AVERROR(ENOSYS))
1270  return r;
1271  }
1272 
1273  if (res_len && res)
1274  res[0] = 0;
1275 
1276  for (i = 0; i < graph->nb_filters; i++) {
1277  AVFilterContext *filter = graph->filters[i];
1278  if (!strcmp(target, "all") || (filter->name && !strcmp(target, filter->name)) || !strcmp(target, filter->filter->name)) {
1279  r = avfilter_process_command(filter, cmd, arg, res, res_len, flags);
1280  if (r != AVERROR(ENOSYS)) {
1281  if ((flags & AVFILTER_CMD_FLAG_ONE) || r < 0)
1282  return r;
1283  }
1284  }
1285  }
1286 
1287  return r;
1288 }
1289 
1290 int avfilter_graph_queue_command(AVFilterGraph *graph, const char *target, const char *command, const char *arg, int flags, double ts)
1291 {
1292  int i;
1293 
1294  if(!graph)
1295  return 0;
1296 
1297  for (i = 0; i < graph->nb_filters; i++) {
1298  AVFilterContext *filter = graph->filters[i];
1299  if(filter && (!strcmp(target, "all") || !strcmp(target, filter->name) || !strcmp(target, filter->filter->name))){
1300  AVFilterCommand **queue = &filter->command_queue, *next;
1301  while (*queue && (*queue)->time <= ts)
1302  queue = &(*queue)->next;
1303  next = *queue;
1304  *queue = av_mallocz(sizeof(AVFilterCommand));
1305  (*queue)->command = av_strdup(command);
1306  (*queue)->arg = av_strdup(arg);
1307  (*queue)->time = ts;
1308  (*queue)->flags = flags;
1309  (*queue)->next = next;
1310  if(flags & AVFILTER_CMD_FLAG_ONE)
1311  return 0;
1312  }
1313  }
1314 
1315  return 0;
1316 }
1317 
1318 static void heap_bubble_up(AVFilterGraph *graph,
1319  AVFilterLink *link, int index)
1320 {
1321  AVFilterLink **links = graph->sink_links;
1322 
1323  av_assert0(index >= 0);
1324 
1325  while (index) {
1326  int parent = (index - 1) >> 1;
1327  if (links[parent]->current_pts_us >= link->current_pts_us)
1328  break;
1329  links[index] = links[parent];
1330  links[index]->age_index = index;
1331  index = parent;
1332  }
1333  links[index] = link;
1334  link->age_index = index;
1335 }
1336 
1337 static void heap_bubble_down(AVFilterGraph *graph,
1338  AVFilterLink *link, int index)
1339 {
1340  AVFilterLink **links = graph->sink_links;
1341 
1342  av_assert0(index >= 0);
1343 
1344  while (1) {
1345  int child = 2 * index + 1;
1346  if (child >= graph->sink_links_count)
1347  break;
1348  if (child + 1 < graph->sink_links_count &&
1349  links[child + 1]->current_pts_us < links[child]->current_pts_us)
1350  child++;
1351  if (link->current_pts_us < links[child]->current_pts_us)
1352  break;
1353  links[index] = links[child];
1354  links[index]->age_index = index;
1355  index = child;
1356  }
1357  links[index] = link;
1358  link->age_index = index;
1359 }
1360 
1362 {
1363  heap_bubble_up (graph, link, link->age_index);
1364  heap_bubble_down(graph, link, link->age_index);
1365 }
1366 
1367 
1369 {
1370  AVFilterLink *oldest = graph->sink_links[0];
1371  int r;
1372 
1373  while (graph->sink_links_count) {
1374  oldest = graph->sink_links[0];
1375  r = ff_request_frame(oldest);
1376  if (r != AVERROR_EOF)
1377  break;
1378  av_log(oldest->dst, AV_LOG_DEBUG, "EOF on sink link %s:%s.\n",
1379  oldest->dst ? oldest->dst->name : "unknown",
1380  oldest->dstpad ? oldest->dstpad->name : "unknown");
1381  /* EOF: remove the link from the heap */
1382  if (oldest->age_index < --graph->sink_links_count)
1383  heap_bubble_down(graph, graph->sink_links[graph->sink_links_count],
1384  oldest->age_index);
1385  oldest->age_index = -1;
1386  }
1387  if (!graph->sink_links_count)
1388  return AVERROR_EOF;
1389  av_assert1(oldest->age_index >= 0);
1390  while (oldest->frame_wanted_out) {
1391  r = ff_filter_graph_run_once(graph);
1392  if (r < 0)
1393  return r;
1394  }
1395  return 0;
1396 }
1397 
1399 {
1400  unsigned i, j;
1401  AVFilterContext *f;
1402 
1403  /* TODO: replace scanning the graph with a priority list */
1404  for (i = 0; i < graph->nb_filters; i++) {
1405  f = graph->filters[i];
1406  for (j = 0; j < f->nb_outputs; j++)
1407  if (f->outputs[j]->frame_wanted_in)
1408  return f->outputs[j];
1409  }
1410  for (i = 0; i < graph->nb_filters; i++) {
1411  f = graph->filters[i];
1412  for (j = 0; j < f->nb_outputs; j++)
1413  if (f->outputs[j]->frame_wanted_out)
1414  return f->outputs[j];
1415  }
1416  return NULL;
1417 }
1418 
1420 {
1421  AVFilterLink *link;
1422  int ret;
1423 
1424  link = graph_run_once_find_filter(graph);
1425  if (!link) {
1426  av_log(NULL, AV_LOG_WARNING, "Useless run of a filter graph\n");
1427  return AVERROR(EAGAIN);
1428  }
1429  ret = ff_request_frame_to_filter(link);
1430  if (ret == AVERROR_EOF)
1431  /* local EOF will be forwarded through request_frame() /
1432  set_status() until it reaches the sink */
1433  ret = 0;
1434  return ret < 0 ? ret : 1;
1435 }
AVFilterContext ** filters
Definition: avfilter.h:779
void avfilter_graph_set_auto_convert(AVFilterGraph *graph, unsigned flags)
Enable or disable automatic format conversion inside the graph.
#define NULL
Definition: coverity.c:32
int ff_set_common_channel_layouts(AVFilterContext *ctx, AVFilterChannelLayouts *layouts)
A helper for query_formats() which sets all links to the same list of channel layouts/sample rates...
Definition: formats.c:549
const char * s
Definition: avisynth_c.h:631
void av_bprintf(AVBPrint *buf, const char *fmt,...)
Definition: bprint.c:94
int sink_links_count
Definition: avfilter.h:842
AVFilterContext * ff_filter_alloc(const AVFilter *filter, const char *inst_name)
Allocate a new filter context and return it.
Definition: avfilter.c:645
const AVPixFmtDescriptor * av_pix_fmt_desc_get(enum AVPixelFormat pix_fmt)
Definition: pixdesc.c:2193
int avfilter_graph_queue_command(AVFilterGraph *graph, const char *target, const char *command, const char *arg, int flags, double ts)
Queue a command for one or more filter instances.
int thread_type
Type of multithreading allowed for filters in this graph.
Definition: avfilter.h:797
static void swap_samplerates(AVFilterGraph *graph)
AVOption.
Definition: opt.h:245
static void swap_sample_fmts(AVFilterGraph *graph)
void avfilter_free(AVFilterContext *filter)
Free a filter context.
Definition: avfilter.c:742
static int get_fmt_score(enum AVSampleFormat dst_fmt, enum AVSampleFormat src_fmt)
AVFormatContext * ctx
Definition: movenc-test.c:48
const char * fmt
Definition: avisynth_c.h:632
AVFilterGraph * avfilter_graph_alloc(void)
Allocate a filter graph.
Definition: avfiltergraph.c:76
#define AV_LOG_WARNING
Something somehow does not look correct.
Definition: log.h:182
#define LIBAVUTIL_VERSION_INT
Definition: version.h:70
Main libavfilter public API header.
int avfilter_graph_config(AVFilterGraph *graphctx, void *log_ctx)
Check validity and configure all the links and formats in the graph.
struct AVFilterInOut * next
next input/input in the list, NULL if this is the last
Definition: avfilter.h:963
static int reduce_formats(AVFilterGraph *graph)
void av_opt_set_defaults(void *s)
Set the values of all AVOption fields to their default values.
Definition: opt.c:1258
static const uint64_t ch_subst[][2]
const char * b
Definition: vf_curves.c:109
void avfilter_graph_free(AVFilterGraph **graph)
Free a graph, destroy its links, and set *graph to NULL.
enum AVMediaType type
AVFilterPad type.
Definition: internal.h:64
static int reduce_formats_on_filter(AVFilterContext *filter)
static enum AVSampleFormat formats[]
int(* query_formats)(AVFilterContext *)
Query formats supported by the filter on its inputs and outputs.
Definition: avfilter.h:265
static int graph_insert_fifos(AVFilterGraph *graph, AVClass *log_ctx)
char * scale_sws_opts
sws options to use for the auto-inserted scale filters
Definition: avfilter.h:782
#define AVFILTER_THREAD_SLICE
Process multiple parts of the frame concurrently.
Definition: avfilter.h:300
int av_get_channel_layout_nb_channels(uint64_t channel_layout)
Return the number of channels in the channel layout.
struct AVFilterGraph * graph
filtergraph this filter belongs to
Definition: avfilter.h:322
#define OFFSET(x)
Definition: avfiltergraph.c:40
const char * name
Pad name.
Definition: internal.h:59
static int pick_format(AVFilterLink *link, AVFilterLink *ref)
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Definition: log.h:72
int ff_filter_graph_run_once(AVFilterGraph *graph)
Run one round of processing on a filter graph.
AVFilterLink ** inputs
array of pointers to input links
Definition: avfilter.h:313
char * name
name of this filter instance
Definition: avfilter.h:310
#define av_assert0(cond)
assert() equivalent, that is always enabled.
Definition: avassert.h:37
avfilter_execute_func * execute
This callback may be set by the caller immediately after allocating the graph and before adding any f...
Definition: avfilter.h:830
AVFilterPad * output_pads
array of output pads
Definition: avfilter.h:316
AVOptions.
#define FF_LAYOUT2COUNT(l)
Decode a channel count encoded as a channel layout.
Definition: formats.h:108
AVS_FilterInfo AVS_Value child
Definition: avisynth_c.h:594
struct AVFilterFormats *** refs
references to this list
Definition: formats.h:69
static void filter(int16_t *output, ptrdiff_t out_stride, int16_t *low, ptrdiff_t low_stride, int16_t *high, ptrdiff_t high_stride, int len, uint8_t clip)
Definition: cfhd.c:80
#define AV_CH_LOW_FREQUENCY
int avfilter_graph_create_filter(AVFilterContext **filt_ctx, const AVFilter *filt, const char *name, const char *args, void *opaque, AVFilterGraph *graph_ctx)
Create and add a filter instance into an existing graph.
static int pick_formats(AVFilterGraph *graph)
int nb_threads
Maximum number of threads used by filters in this graph.
Definition: avfilter.h:804
int avfilter_config_links(AVFilterContext *filter)
Negotiate the media format, dimensions, etc of all inputs to a filter.
Definition: avfilter.c:237
#define AVERROR_EOF
End of file.
Definition: error.h:55
AVFilterContext * avfilter_graph_get_filter(AVFilterGraph *graph, const char *name)
Get a filter instance identified by instance name from graph.
enum AVSampleFormat av_get_planar_sample_fmt(enum AVSampleFormat sample_fmt)
Get the planar alternative form of the given sample format.
Definition: samplefmt.c:82
signed 32 bits
Definition: samplefmt.h:62
#define av_log(a,...)
AVFilterFormats * ff_all_formats(enum AVMediaType type)
Return a list of all formats supported by FFmpeg for the given media type.
Definition: formats.c:350
int av_sample_fmt_is_planar(enum AVSampleFormat sample_fmt)
Check if the sample format is planar.
Definition: samplefmt.c:110
A filter pad used for either input or output.
Definition: internal.h:53
unsigned refcount
number of references to this list
Definition: formats.h:68
AVFilterPad * input_pads
array of input pads
Definition: avfilter.h:312
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
Definition: log.h:176
int ff_set_common_formats(AVFilterContext *ctx, AVFilterFormats *formats)
A helper for query_formats() which sets all links to the same list of formats.
Definition: formats.c:568
#define FLAGS
Definition: avfiltergraph.c:41
int ff_add_channel_layout(AVFilterChannelLayouts **l, uint64_t channel_layout)
Definition: formats.c:343
av_default_item_name
#define AVERROR(e)
Definition: error.h:43
const AVClass * av_class
Definition: avfilter.h:778
unsigned nb_outputs
number of output pads
Definition: avfilter.h:318
void av_bprint_init(AVBPrint *buf, unsigned size_init, unsigned size_max)
Definition: bprint.c:69
const char * r
Definition: vf_curves.c:107
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
Definition: log.h:197
uint64_t * channel_layouts
list of channel layouts
Definition: formats.h:86
const char * arg
Definition: jacosubdec.c:66
simple assert() macros that are a bit more flexible than ISO C assert().
int ff_add_format(AVFilterFormats **avff, int64_t fmt)
Add fmt to the list of media formats contained in *avff.
Definition: formats.c:337
const char * av_get_sample_fmt_name(enum AVSampleFormat sample_fmt)
Return the name of sample_fmt, or NULL if sample_fmt is not recognized.
Definition: samplefmt.c:47
static void heap_bubble_down(AVFilterGraph *graph, AVFilterLink *link, int index)
#define REDUCE_FORMATS(fmt_type, list_type, list, var, nb, add_format, unref_format)
AVFilterLink ** sink_links
Private fields.
Definition: avfilter.h:841
#define CH_DIRECT_PAIR
#define fail()
Definition: checkasm.h:81
char all_counts
accept any channel layout or count
Definition: formats.h:89
const AVFilter * avfilter_get_by_name(const char *name)
Get a filter definition matching the given name.
Definition: avfilter.c:519
common internal API header
static int graph_config_formats(AVFilterGraph *graph, AVClass *log_ctx)
Configure the formats of all the links in the graph.
uint8_t nb_components
The number of components each pixel has, (1-4)
Definition: pixdesc.h:83
audio channel layout utility functions
static void sanitize_channel_layouts(void *log, AVFilterChannelLayouts *l)
unsigned nb_inputs
number of input pads
Definition: avfilter.h:314
#define av_assert1(cond)
assert() equivalent, that does not lie in speed critical code.
Definition: avassert.h:53
static void swap_sample_fmts_on_filter(AVFilterContext *filter)
struct AVFilterCommand * next
Definition: internal.h:42
#define CH_CENTER_PAIR
static const AVOption filtergraph_options[]
Definition: avfiltergraph.c:42
#define av_err2str(errnum)
Convenience macro, the return value should be used only directly in function arguments but never stan...
Definition: error.h:119
static int graph_check_validity(AVFilterGraph *graph, AVClass *log_ctx)
Check for the validity of graph.
static int convert(uint8_t x)
Definition: xbmdec.c:29
#define FFABS(a)
Absolute value, Note, INT_MIN / INT64_MIN result in undefined behavior as they are not representable ...
Definition: common.h:72
unsigned nb_formats
number of formats
Definition: formats.h:65
int n
Definition: avisynth_c.h:547
#define AVFILTER_CMD_FLAG_ONE
Stop once a filter understood the command (for target=all for example), fast filters are favored auto...
Definition: avfilter.h:593
#define AV_CH_FRONT_CENTER
static enum AVSampleFormat find_best_sample_fmt_of_2(enum AVSampleFormat dst_fmt1, enum AVSampleFormat dst_fmt2, enum AVSampleFormat src_fmt)
static AVFilterFormats * clone_filter_formats(AVFilterFormats *arg)
AVFilterChannelLayouts * ff_all_channel_layouts(void)
Construct an empty AVFilterChannelLayouts/AVFilterFormats struct – representing any channel layout (w...
Definition: formats.c:401
static int can_merge_formats(AVFilterFormats *a_arg, AVFilterFormats *b_arg, enum AVMediaType type, int is_sample_rate)
#define FF_ARRAY_ELEMS(a)
A list of supported channel layouts.
Definition: formats.h:85
int avfilter_init_str(AVFilterContext *filter, const char *args)
Initialize a filter with the supplied parameters.
Definition: avfilter.c:906
void * av_memdup(const void *p, size_t size)
Duplicate the buffer p.
Definition: mem.c:299
int avfilter_insert_filter(AVFilterLink *link, AVFilterContext *filt, unsigned filt_srcpad_idx, unsigned filt_dstpad_idx)
Insert a filter in the middle of an existing link.
Definition: avfilter.c:200
void ff_graph_thread_free(AVFilterGraph *graph)
Definition: avfiltergraph.c:64
int ff_default_query_formats(AVFilterContext *ctx)
Definition: formats.c:597
sample_rate
#define AV_BPRINT_SIZE_AUTOMATIC
AVSampleFormat
Audio sample formats.
Definition: samplefmt.h:58
static void heap_bubble_up(AVFilterGraph *graph, AVFilterLink *link, int index)
static int formats_declared(AVFilterContext *f)
AVFilterGraphInternal * internal
Opaque object for libavfilter internal use.
Definition: avfilter.h:809
char * av_strdup(const char *s)
Duplicate the string s.
Definition: mem.c:267
int ff_request_frame_to_filter(AVFilterLink *link)
Definition: avfilter.c:380
char all_layouts
accept any known channel layout
Definition: formats.h:88
AVFilterChannelLayouts * ff_merge_channel_layouts(AVFilterChannelLayouts *a, AVFilterChannelLayouts *b)
Return a channel layouts/samplerates list which contains the intersection of the layouts/samplerates ...
Definition: formats.c:166
AVFilterFormats * ff_merge_formats(AVFilterFormats *a, AVFilterFormats *b, enum AVMediaType type)
Return a format list which contains the intersection of the formats of a and b.
Definition: formats.c:92
static const char * format
Definition: movenc-test.c:47
static int command(AVFilterContext *ctx, const char *cmd, const char *arg, char *res, int res_len, int flags)
Definition: vf_drawtext.c:767
void ff_avfilter_graph_update_heap(AVFilterGraph *graph, AVFilterLink *link)
Update the position of a link in the age heap.
void ff_channel_layouts_unref(AVFilterChannelLayouts **ref)
Remove a reference to a channel layouts list.
Definition: formats.c:481
int avfilter_graph_request_oldest(AVFilterGraph *graph)
Request a frame on the oldest sink link.
int avfilter_process_command(AVFilterContext *filter, const char *cmd, const char *arg, char *res, int res_len, int flags)
Make the filter instance process a command.
Definition: avfilter.c:492
GLint GLenum type
Definition: opengl_enc.c:105
Describe the class of an AVClass context structure.
Definition: log.h:67
Filter definition.
Definition: avfilter.h:142
int index
Definition: gxfenc.c:89
#define AVFILTER_CMD_FLAG_FAST
Only execute command when its fast (like a video out that supports contrast adjustment in hw) ...
Definition: avfilter.h:594
#define CH_BACK_PAIR
AVMediaType
Definition: avutil.h:191
void ff_formats_unref(AVFilterFormats **ref)
If *ref is non-NULL, remove *ref as a reference to the format list it currently points to...
Definition: formats.c:476
const char * name
Filter name.
Definition: avfilter.h:146
unsigned nb_filters
Definition: avfilter.h:780
#define snprintf
Definition: snprintf.h:34
AVFilterLink ** outputs
array of pointers to output links
Definition: avfilter.h:317
static void swap_channel_layouts_on_filter(AVFilterContext *filter)
AVFilterFormats * ff_all_samplerates(void)
Definition: formats.c:395
void * av_calloc(size_t nmemb, size_t size)
Allocate a block of nmemb * size bytes with alignment suitable for all memory accesses (including vec...
Definition: mem.c:260
static const int8_t filt[NUMTAPS]
Definition: af_earwax.c:39
const char * av_get_media_type_string(enum AVMediaType media_type)
Return a string describing the media_type enum, NULL if media_type is unknown.
Definition: utils.c:79
static int flags
Definition: cpu.c:47
#define AV_CH_BACK_CENTER
int av_get_bytes_per_sample(enum AVSampleFormat sample_fmt)
Return number of bytes per sample.
Definition: samplefmt.c:104
static int query_formats(AVFilterGraph *graph, AVClass *log_ctx)
Perform one round of query_formats() and merging formats lists on the filter graph.
static AVFilterLink * graph_run_once_find_filter(AVFilterGraph *graph)
int ff_graph_thread_init(AVFilterGraph *graph)
Definition: avfiltergraph.c:68
static int graph_config_links(AVFilterGraph *graph, AVClass *log_ctx)
Configure all the links of graphctx.
static void swap_channel_layouts(AVFilterGraph *graph)
#define MERGE_DISPATCH(field, statement)
enum AVSampleFormat av_get_packed_sample_fmt(enum AVSampleFormat sample_fmt)
Get the packed alternative form of the given sample format.
Definition: samplefmt.c:73
int nb_channel_layouts
number of channel layouts
Definition: formats.h:87
void * av_realloc(void *ptr, size_t size)
Allocate or reallocate a block of memory.
Definition: mem.c:145
#define CH_FRONT_PAIR
struct AVFilterCommand * command_queue
Definition: avfilter.h:356
int avfilter_graph_send_command(AVFilterGraph *graph, const char *target, const char *cmd, const char *arg, char *res, int res_len, int flags)
Send a command to one or more filter instances.
unsigned bps
Definition: movenc.c:1354
enum AVPixelFormat av_find_best_pix_fmt_of_2(enum AVPixelFormat dst_pix_fmt1, enum AVPixelFormat dst_pix_fmt2, enum AVPixelFormat src_pix_fmt, int has_alpha, int *loss_ptr)
Compute what kind of losses will occur when converting from one specific pixel format to another...
Definition: pixdesc.c:2475
static void swap_samplerates_on_filter(AVFilterContext *filter)
char * aresample_swr_opts
swr options to use for the auto-inserted aresample filters, Access ONLY through AVOptions ...
Definition: avfilter.h:832
void ff_filter_graph_remove_filter(AVFilterGraph *graph, AVFilterContext *filter)
Remove a filter from a graph;.
Definition: avfiltergraph.c:94
static av_always_inline int diff(const uint32_t a, const uint32_t b)
avfilter_execute_func * thread_execute
Definition: internal.h:149
AVFilterContext * avfilter_graph_alloc_filter(AVFilterGraph *graph, const AVFilter *filter, const char *name)
Create a new filter instance in a filter graph.
static const struct PPFilter filters[]
Definition: postprocess.c:137
unsigned refcount
number of references to this list
Definition: formats.h:91
A list of supported formats for one end of a filter link.
Definition: formats.h:64
static const AVClass filtergraph_class
Definition: avfiltergraph.c:55
An instance of a filter.
Definition: avfilter.h:305
#define av_freep(p)
#define CH_SIDE_PAIR
double time
time expressed in seconds
Definition: internal.h:38
int needs_fifo
The filter expects a fifo to be inserted on its input link, typically because it has a delay...
Definition: internal.h:136
int ff_request_frame(AVFilterLink *link)
Request an input frame from the filter at the other end of the link.
Definition: avfilter.c:369
#define FFSWAP(type, a, b)
Definition: common.h:99
const char * av_get_pix_fmt_name(enum AVPixelFormat pix_fmt)
Return the short name for a pixel format, NULL in case pix_fmt is unknown.
Definition: pixdesc.c:2109
static int filter_query_formats(AVFilterContext *ctx)
AVFilterFormats * ff_merge_samplerates(AVFilterFormats *a, AVFilterFormats *b)
Definition: formats.c:139
internal API functions
AVPixelFormat
Pixel format.
Definition: pixfmt.h:60
#define CH_WIDE_PAIR
void * av_mallocz(size_t size)
Allocate a block of size bytes with alignment suitable for all memory accesses (including vectors if ...
Definition: mem.c:252
const AVFilter * filter
the AVFilter of which this is an instance
Definition: avfilter.h:308
int ff_set_common_samplerates(AVFilterContext *ctx, AVFilterFormats *samplerates)
Definition: formats.c:556
unsigned disable_auto_convert
Definition: avfilter.h:844
static int graph_config_pointers(AVFilterGraph *graph, AVClass *log_ctx)
const char * name
Definition: opengl_enc.c:103
int * formats
list of media formats
Definition: formats.h:66