[FFmpeg-devel] [PATCH 28/35] avfilter/avfilter: Avoid allocation for AVFilterInternal
Andreas Rheinhardt
andreas.rheinhardt at outlook.com
Sun Feb 11 01:04:04 EET 2024
To do this, allocate AVFilterInternal jointly with AVFilterContext
and rename it to FFFilterContext in the process (similarly to
AVStream/FFStream).
Signed-off-by: Andreas Rheinhardt <andreas.rheinhardt at outlook.com>
---
libavfilter/avfilter.c | 22 ++++++++++------------
libavfilter/avfilter.h | 7 -------
libavfilter/graphparser.c | 2 +-
libavfilter/internal.h | 16 +++++++++++++---
4 files changed, 24 insertions(+), 23 deletions(-)
diff --git a/libavfilter/avfilter.c b/libavfilter/avfilter.c
index befcda48cb..dbe6409274 100644
--- a/libavfilter/avfilter.c
+++ b/libavfilter/avfilter.c
@@ -159,7 +159,7 @@ int avfilter_link(AVFilterContext *src, unsigned srcpad,
src->outputs[srcpad] || dst->inputs[dstpad])
return AVERROR(EINVAL);
- if (!src->internal->initialized || !dst->internal->initialized) {
+ if (!fffilterctx(src)->initialized || !fffilterctx(dst)->initialized) {
av_log(src, AV_LOG_ERROR, "Filters must be initialized before linking.\n");
return AVERROR(EINVAL);
}
@@ -651,15 +651,17 @@ static int default_execute(AVFilterContext *ctx, avfilter_action_func *func, voi
AVFilterContext *ff_filter_alloc(const AVFilter *filter, const char *inst_name)
{
+ FFFilterContext *ctx;
AVFilterContext *ret;
int preinited = 0;
if (!filter)
return NULL;
- ret = av_mallocz(sizeof(AVFilterContext));
- if (!ret)
+ ctx = av_mallocz(sizeof(*ctx));
+ if (!ctx)
return NULL;
+ ret = &ctx->p;
ret->av_class = &avfilter_class;
ret->filter = filter;
@@ -681,10 +683,7 @@ AVFilterContext *ff_filter_alloc(const AVFilter *filter, const char *inst_name)
av_opt_set_defaults(ret->priv);
}
- ret->internal = av_mallocz(sizeof(*ret->internal));
- if (!ret->internal)
- goto err;
- ret->internal->execute = default_execute;
+ ctx->execute = default_execute;
ret->nb_inputs = filter->nb_inputs;
if (ret->nb_inputs ) {
@@ -718,7 +717,6 @@ err:
av_freep(&ret->output_pads);
ret->nb_outputs = 0;
av_freep(&ret->priv);
- av_freep(&ret->internal);
av_free(ret);
return NULL;
}
@@ -790,7 +788,6 @@ void avfilter_free(AVFilterContext *filter)
av_expr_free(filter->enable);
filter->enable = NULL;
av_freep(&filter->var_values);
- av_freep(&filter->internal);
av_free(filter);
}
@@ -874,9 +871,10 @@ int ff_filter_process_command(AVFilterContext *ctx, const char *cmd,
int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
{
+ FFFilterContext *ctxi = fffilterctx(ctx);
int ret = 0;
- if (ctx->internal->initialized) {
+ if (ctxi->initialized) {
av_log(ctx, AV_LOG_ERROR, "Filter already initialized\n");
return AVERROR(EINVAL);
}
@@ -891,7 +889,7 @@ int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
ctx->thread_type & ctx->graph->thread_type & AVFILTER_THREAD_SLICE &&
ctx->graph->internal->thread_execute) {
ctx->thread_type = AVFILTER_THREAD_SLICE;
- ctx->internal->execute = ctx->graph->internal->thread_execute;
+ ctxi->execute = ctx->graph->internal->thread_execute;
} else {
ctx->thread_type = 0;
}
@@ -907,7 +905,7 @@ int avfilter_init_dict(AVFilterContext *ctx, AVDictionary **options)
return ret;
}
- ctx->internal->initialized = 1;
+ ctxi->initialized = 1;
return 0;
}
diff --git a/libavfilter/avfilter.h b/libavfilter/avfilter.h
index a5d9398c9a..a3725b1516 100644
--- a/libavfilter/avfilter.h
+++ b/libavfilter/avfilter.h
@@ -403,8 +403,6 @@ unsigned avfilter_filter_pad_count(const AVFilter *filter, int is_output);
*/
#define AVFILTER_THREAD_SLICE (1 << 0)
-typedef struct AVFilterInternal AVFilterInternal;
-
/** An instance of a filter */
struct AVFilterContext {
const AVClass *av_class; ///< needed for av_log() and filters common options
@@ -443,11 +441,6 @@ struct AVFilterContext {
*/
int thread_type;
- /**
- * An opaque struct for libavfilter internal use.
- */
- AVFilterInternal *internal;
-
struct AVFilterCommand *command_queue;
char *enable_str; ///< enable expression string
diff --git a/libavfilter/graphparser.c b/libavfilter/graphparser.c
index 96ef6b15bf..229e647c0a 100644
--- a/libavfilter/graphparser.c
+++ b/libavfilter/graphparser.c
@@ -626,7 +626,7 @@ int avfilter_graph_segment_init(AVFilterGraphSegment *seg, int flags)
if (p->filter_name)
return fail_creation_pending(seg, p->filter_name, __func__);
- if (!p->filter || p->filter->internal->initialized)
+ if (!p->filter || fffilterctx(p->filter)->initialized)
continue;
ret = avfilter_init_dict(p->filter, NULL);
diff --git a/libavfilter/internal.h b/libavfilter/internal.h
index a6cdf9994c..3d46923cad 100644
--- a/libavfilter/internal.h
+++ b/libavfilter/internal.h
@@ -133,18 +133,28 @@ struct AVFilterGraphInternal {
FFFrameQueueGlobal frame_queues;
};
-struct AVFilterInternal {
+typedef struct FFFilterContext {
+ /**
+ * The public AVFilterContext. See avfilter.h for it.
+ */
+ AVFilterContext p;
+
avfilter_execute_func *execute;
// 1 when avfilter_init_*() was successfully called on this filter
// 0 otherwise
int initialized;
-};
+} FFFilterContext;
+
+static inline FFFilterContext *fffilterctx(AVFilterContext *ctx)
+{
+ return (FFFilterContext*)ctx;
+}
static av_always_inline int ff_filter_execute(AVFilterContext *ctx, avfilter_action_func *func,
void *arg, int *ret, int nb_jobs)
{
- return ctx->internal->execute(ctx, func, arg, ret, nb_jobs);
+ return fffilterctx(ctx)->execute(ctx, func, arg, ret, nb_jobs);
}
enum FilterFormatsState {
--
2.34.1
More information about the ffmpeg-devel
mailing list