mirror of
https://git.ffmpeg.org/ffmpeg.git
synced 2024-12-25 08:42:39 +00:00
avfilter/vf_hflip: support slice threading
Signed-off-by: Paul B Mahol <onemda@gmail.com>
This commit is contained in:
parent
2a6a3d4317
commit
0a4aea6db9
@ -75,34 +75,30 @@ static int config_props(AVFilterLink *inlink)
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int filter_frame(AVFilterLink *inlink, AVFrame *in)
|
typedef struct ThreadData {
|
||||||
|
AVFrame *in, *out;
|
||||||
|
} ThreadData;
|
||||||
|
|
||||||
|
static int filter_slice(AVFilterContext *ctx, void *arg, int job, int nb_jobs)
|
||||||
{
|
{
|
||||||
AVFilterContext *ctx = inlink->dst;
|
FlipContext *s = ctx->priv;
|
||||||
FlipContext *s = ctx->priv;
|
ThreadData *td = arg;
|
||||||
AVFilterLink *outlink = ctx->outputs[0];
|
AVFrame *in = td->in;
|
||||||
AVFrame *out;
|
AVFrame *out = td->out;
|
||||||
uint8_t *inrow, *outrow;
|
uint8_t *inrow, *outrow;
|
||||||
int i, j, plane, step;
|
int i, j, plane, step;
|
||||||
|
|
||||||
out = ff_get_video_buffer(outlink, outlink->w, outlink->h);
|
|
||||||
if (!out) {
|
|
||||||
av_frame_free(&in);
|
|
||||||
return AVERROR(ENOMEM);
|
|
||||||
}
|
|
||||||
av_frame_copy_props(out, in);
|
|
||||||
|
|
||||||
/* copy palette if required */
|
|
||||||
if (av_pix_fmt_desc_get(inlink->format)->flags & AV_PIX_FMT_FLAG_PAL)
|
|
||||||
memcpy(out->data[1], in->data[1], AVPALETTE_SIZE);
|
|
||||||
|
|
||||||
for (plane = 0; plane < 4 && in->data[plane] && in->linesize[plane]; plane++) {
|
for (plane = 0; plane < 4 && in->data[plane] && in->linesize[plane]; plane++) {
|
||||||
const int width = s->planewidth[plane];
|
const int width = s->planewidth[plane];
|
||||||
const int height = s->planeheight[plane];
|
const int height = s->planeheight[plane];
|
||||||
|
const int start = (height * job ) / nb_jobs;
|
||||||
|
const int end = (height * (job+1)) / nb_jobs;
|
||||||
|
|
||||||
step = s->max_step[plane];
|
step = s->max_step[plane];
|
||||||
|
|
||||||
outrow = out->data[plane];
|
outrow = out->data[plane] + start * out->linesize[plane];
|
||||||
inrow = in ->data[plane] + (width - 1) * step;
|
inrow = in ->data[plane] + start * in->linesize[plane] + (width - 1) * step;
|
||||||
for (i = 0; i < height; i++) {
|
for (i = start; i < end; i++) {
|
||||||
switch (step) {
|
switch (step) {
|
||||||
case 1:
|
case 1:
|
||||||
for (j = 0; j < width; j++)
|
for (j = 0; j < width; j++)
|
||||||
@ -148,6 +144,30 @@ static int filter_frame(AVFilterLink *inlink, AVFrame *in)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
static int filter_frame(AVFilterLink *inlink, AVFrame *in)
|
||||||
|
{
|
||||||
|
AVFilterContext *ctx = inlink->dst;
|
||||||
|
AVFilterLink *outlink = ctx->outputs[0];
|
||||||
|
ThreadData td;
|
||||||
|
AVFrame *out;
|
||||||
|
|
||||||
|
out = ff_get_video_buffer(outlink, outlink->w, outlink->h);
|
||||||
|
if (!out) {
|
||||||
|
av_frame_free(&in);
|
||||||
|
return AVERROR(ENOMEM);
|
||||||
|
}
|
||||||
|
av_frame_copy_props(out, in);
|
||||||
|
|
||||||
|
/* copy palette if required */
|
||||||
|
if (av_pix_fmt_desc_get(inlink->format)->flags & AV_PIX_FMT_FLAG_PAL)
|
||||||
|
memcpy(out->data[1], in->data[1], AVPALETTE_SIZE);
|
||||||
|
|
||||||
|
td.in = in, td.out = out;
|
||||||
|
ctx->internal->execute(ctx, filter_slice, &td, NULL, FFMIN(outlink->h, ctx->graph->nb_threads));
|
||||||
|
|
||||||
av_frame_free(&in);
|
av_frame_free(&in);
|
||||||
return ff_filter_frame(outlink, out);
|
return ff_filter_frame(outlink, out);
|
||||||
}
|
}
|
||||||
@ -177,4 +197,5 @@ AVFilter avfilter_vf_hflip = {
|
|||||||
.query_formats = query_formats,
|
.query_formats = query_formats,
|
||||||
.inputs = avfilter_vf_hflip_inputs,
|
.inputs = avfilter_vf_hflip_inputs,
|
||||||
.outputs = avfilter_vf_hflip_outputs,
|
.outputs = avfilter_vf_hflip_outputs,
|
||||||
|
.flags = AVFILTER_FLAG_SLICE_THREADS,
|
||||||
};
|
};
|
||||||
|
Loading…
Reference in New Issue
Block a user