#include "internal.h"
#include "video.h"
#include "framesync.h"
+#include "maskedclamp.h"
#define OFFSET(x) offsetof(MaskedClampContext, x)
-#define FLAGS AV_OPT_FLAG_FILTERING_PARAM|AV_OPT_FLAG_VIDEO_PARAM
+#define FLAGS AV_OPT_FLAG_FILTERING_PARAM|AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_RUNTIME_PARAM
+
+typedef struct ThreadData {
+ AVFrame *b, *o, *m, *d;
+} ThreadData;
typedef struct MaskedClampContext {
const AVClass *class;
int depth;
FFFrameSync fs;
- void (*maskedclamp)(const uint8_t *bsrc, const uint8_t *osrc,
- const uint8_t *msrc, uint8_t *dst,
- ptrdiff_t blinesize, ptrdiff_t darklinesize,
- ptrdiff_t brightlinesize, ptrdiff_t destlinesize,
- int w, int h, int undershoot, int overshoot);
+ MaskedClampDSPContext dsp;
} MaskedClampContext;
static const AVOption maskedclamp_options[] = {
AV_PIX_FMT_YUV420P16, AV_PIX_FMT_YUV422P16, AV_PIX_FMT_YUV444P16,
AV_PIX_FMT_YUVA420P9, AV_PIX_FMT_YUVA422P9, AV_PIX_FMT_YUVA444P9,
AV_PIX_FMT_YUVA420P10, AV_PIX_FMT_YUVA422P10, AV_PIX_FMT_YUVA444P10,
+ AV_PIX_FMT_YUVA422P12, AV_PIX_FMT_YUVA444P12,
AV_PIX_FMT_YUVA420P16, AV_PIX_FMT_YUVA422P16, AV_PIX_FMT_YUVA444P16,
AV_PIX_FMT_GBRP, AV_PIX_FMT_GBRP9, AV_PIX_FMT_GBRP10,
AV_PIX_FMT_GBRP12, AV_PIX_FMT_GBRP14, AV_PIX_FMT_GBRP16,
AV_PIX_FMT_GBRAP, AV_PIX_FMT_GBRAP10, AV_PIX_FMT_GBRAP12, AV_PIX_FMT_GBRAP16,
- AV_PIX_FMT_GRAY8, AV_PIX_FMT_GRAY9, AV_PIX_FMT_GRAY10, AV_PIX_FMT_GRAY12, AV_PIX_FMT_GRAY16,
+ AV_PIX_FMT_GRAY8, AV_PIX_FMT_GRAY9, AV_PIX_FMT_GRAY10, AV_PIX_FMT_GRAY12, AV_PIX_FMT_GRAY14, AV_PIX_FMT_GRAY16,
AV_PIX_FMT_NONE
};
return ff_set_common_formats(ctx, ff_make_format_list(pix_fmts));
}
+static int maskedclamp_slice(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs)
+{
+ MaskedClampContext *s = ctx->priv;
+ ThreadData *td = arg;
+ int p;
+
+ for (p = 0; p < s->nb_planes; p++) {
+ const ptrdiff_t blinesize = td->b->linesize[p];
+ const ptrdiff_t brightlinesize = td->m->linesize[p];
+ const ptrdiff_t darklinesize = td->o->linesize[p];
+ const ptrdiff_t dlinesize = td->d->linesize[p];
+ const int w = s->width[p];
+ const int h = s->height[p];
+ const int slice_start = (h * jobnr) / nb_jobs;
+ const int slice_end = (h * (jobnr+1)) / nb_jobs;
+ const uint8_t *bsrc = td->b->data[p] + slice_start * blinesize;
+ const uint8_t *darksrc = td->o->data[p] + slice_start * darklinesize;
+ const uint8_t *brightsrc = td->m->data[p] + slice_start * brightlinesize;
+ uint8_t *dst = td->d->data[p] + slice_start * dlinesize;
+ const int undershoot = s->undershoot;
+ const int overshoot = s->overshoot;
+ int y;
+
+ if (!((1 << p) & s->planes)) {
+ av_image_copy_plane(dst, dlinesize, bsrc, blinesize,
+ s->linesize[p], slice_end - slice_start);
+ continue;
+ }
+
+ for (y = slice_start; y < slice_end; y++) {
+ s->dsp.maskedclamp(bsrc, dst, darksrc, brightsrc, w, undershoot, overshoot);
+
+ dst += dlinesize;
+ bsrc += blinesize;
+ darksrc += darklinesize;
+ brightsrc += brightlinesize;
+ }
+ }
+
+ return 0;
+}
+
static int process_frame(FFFrameSync *fs)
{
AVFilterContext *ctx = fs->parent;
if (!out)
return AVERROR(ENOMEM);
} else {
- int p;
+ ThreadData td;
out = ff_get_video_buffer(outlink, outlink->w, outlink->h);
if (!out)
return AVERROR(ENOMEM);
av_frame_copy_props(out, base);
- for (p = 0; p < s->nb_planes; p++) {
- if (!((1 << p) & s->planes)) {
- av_image_copy_plane(out->data[p], out->linesize[p], base->data[p], base->linesize[p],
- s->linesize[p], s->height[p]);
- continue;
- }
-
- s->maskedclamp(base->data[p], dark->data[p],
- bright->data[p], out->data[p],
- base->linesize[p], dark->linesize[p],
- bright->linesize[p], out->linesize[p],
- s->width[p], s->height[p],
- s->undershoot, s->overshoot);
- }
+ td.b = base;
+ td.o = dark;
+ td.m = bright;
+ td.d = out;
+
+ ctx->internal->execute(ctx, maskedclamp_slice, &td, NULL, FFMIN(s->height[0],
+ ff_filter_get_nb_threads(ctx)));
}
out->pts = av_rescale_q(s->fs.pts, s->fs.time_base, outlink->time_base);
return ff_filter_frame(outlink, out);
}
-static void maskedclamp8(const uint8_t *bsrc, const uint8_t *darksrc,
- const uint8_t *brightsrc, uint8_t *dst,
- ptrdiff_t blinesize, ptrdiff_t darklinesize,
- ptrdiff_t brightlinesize, ptrdiff_t dlinesize,
- int w, int h,
- int undershoot, int overshoot)
-{
- int x, y;
-
- for (y = 0; y < h; y++) {
- for (x = 0; x < w; x++) {
- if (bsrc[x] < darksrc[x] - undershoot)
- dst[x] = darksrc[x] - undershoot;
- else if (bsrc[x] > brightsrc[x] + overshoot)
- dst[x] = brightsrc[x] + overshoot;
- else
- dst[x] = bsrc[x];
- }
-
- dst += dlinesize;
- bsrc += blinesize;
- darksrc += darklinesize;
- brightsrc += brightlinesize;
- }
+#define MASKEDCLAMP(type, name) \
+static void maskedclamp##name(const uint8_t *bbsrc, uint8_t *ddst, \
+ const uint8_t *ddarksrc, const uint8_t *bbrightsrc, \
+ int w, int undershoot, int overshoot) \
+{ \
+ const type *bsrc = (const type *)bbsrc; \
+ const type *darksrc = (const type *)ddarksrc; \
+ const type *brightsrc = (const type *)bbrightsrc; \
+ type *dst = (type *)ddst; \
+ \
+ for (int x = 0; x < w; x++) { \
+ dst[x] = FFMAX(bsrc[x], darksrc[x] - undershoot); \
+ dst[x] = FFMIN(dst[x], brightsrc[x] + overshoot); \
+ } \
}
-static void maskedclamp16(const uint8_t *bbsrc, const uint8_t *oosrc,
- const uint8_t *mmsrc, uint8_t *ddst,
- ptrdiff_t blinesize, ptrdiff_t darklinesize,
- ptrdiff_t brightlinesize, ptrdiff_t dlinesize,
- int w, int h,
- int undershoot, int overshoot)
-{
- const uint16_t *bsrc = (const uint16_t *)bbsrc;
- const uint16_t *darksrc = (const uint16_t *)oosrc;
- const uint16_t *brightsrc = (const uint16_t *)mmsrc;
- uint16_t *dst = (uint16_t *)ddst;
- int x, y;
-
- dlinesize /= 2;
- blinesize /= 2;
- darklinesize /= 2;
- brightlinesize /= 2;
-
- for (y = 0; y < h; y++) {
- for (x = 0; x < w; x++) {
- if (bsrc[x] < darksrc[x] - undershoot)
- dst[x] = darksrc[x] - undershoot;
- else if (bsrc[x] > brightsrc[x] + overshoot)
- dst[x] = brightsrc[x] + overshoot;
- else
- dst[x] = bsrc[x];
- }
-
- dst += dlinesize;
- bsrc += blinesize;
- darksrc += darklinesize;
- brightsrc += brightlinesize;
- }
-}
+MASKEDCLAMP(uint8_t, 8)
+MASKEDCLAMP(uint16_t, 16)
static int config_input(AVFilterLink *inlink)
{
s->width[0] = s->width[3] = inlink->w;
s->depth = desc->comp[0].depth;
+ s->undershoot = FFMIN(s->undershoot, (1 << s->depth) - 1);
+ s->overshoot = FFMIN(s->overshoot, (1 << s->depth) - 1);
- if (desc->comp[0].depth == 8)
- s->maskedclamp = maskedclamp8;
+ if (s->depth <= 8)
+ s->dsp.maskedclamp = maskedclamp8;
else
- s->maskedclamp = maskedclamp16;
+ s->dsp.maskedclamp = maskedclamp16;
+
+ if (ARCH_X86)
+ ff_maskedclamp_init_x86(&s->dsp, s->depth);
return 0;
}
outlink->w = base->w;
outlink->h = base->h;
- outlink->time_base = base->time_base;
outlink->sample_aspect_ratio = base->sample_aspect_ratio;
outlink->frame_rate = base->frame_rate;
s->fs.opaque = s;
s->fs.on_event = process_frame;
- return ff_framesync_configure(&s->fs);
+ ret = ff_framesync_configure(&s->fs);
+ outlink->time_base = s->fs.time_base;
+
+ return ret;
}
static int activate(AVFilterContext *ctx)
{ NULL }
};
-AVFilter ff_vf_maskedclamp = {
+const AVFilter ff_vf_maskedclamp = {
.name = "maskedclamp",
.description = NULL_IF_CONFIG_SMALL("Clamp first stream with second stream and third stream."),
.priv_size = sizeof(MaskedClampContext),
.inputs = maskedclamp_inputs,
.outputs = maskedclamp_outputs,
.priv_class = &maskedclamp_class,
- .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_INTERNAL,
+ .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_INTERNAL | AVFILTER_FLAG_SLICE_THREADS,
+ .process_command = ff_filter_process_command,
};
projects / ffmpeg / blobdiff