#define B 2
#define A 3
+typedef struct ThreadData {
+ AVFrame *in, *out;
+} ThreadData;
+
typedef struct Range {
double shadows;
double midtones;
uint8_t rgba_map[4];
int step;
- int (*clip)(int x);
- void (*apply_lut)(AVFilterContext *ctx, AVFrame *in, AVFrame *out);
+ int (*apply_lut)(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs);
} ColorBalanceContext;
#define OFFSET(x) offsetof(ColorBalanceContext, x)
AV_PIX_FMT_RGB0, AV_PIX_FMT_BGR0,
AV_PIX_FMT_RGB48, AV_PIX_FMT_BGR48,
AV_PIX_FMT_RGBA64, AV_PIX_FMT_BGRA64,
+ AV_PIX_FMT_GBRP, AV_PIX_FMT_GBRAP,
+ AV_PIX_FMT_GBRP9,
+ AV_PIX_FMT_GBRP10, AV_PIX_FMT_GBRAP10,
+ AV_PIX_FMT_GBRP12, AV_PIX_FMT_GBRAP12,
+ AV_PIX_FMT_GBRP14,
+ AV_PIX_FMT_GBRP16, AV_PIX_FMT_GBRAP16,
AV_PIX_FMT_NONE
};
AVFilterFormats *fmts_list = ff_make_format_list(pix_fmts);
return ff_set_common_formats(ctx, fmts_list);
}
-static void apply_lut8(AVFilterContext *ctx, AVFrame *in, AVFrame *out)
+static int apply_lut8_p(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs)
+{
+ ColorBalanceContext *s = ctx->priv;
+ ThreadData *td = arg;
+ AVFrame *in = td->in;
+ AVFrame *out = td->out;
+ const int slice_start = (out->height * jobnr) / nb_jobs;
+ const int slice_end = (out->height * (jobnr+1)) / nb_jobs;
+ const uint8_t *srcg = in->data[0] + slice_start * in->linesize[0];
+ const uint8_t *srcb = in->data[1] + slice_start * in->linesize[1];
+ const uint8_t *srcr = in->data[2] + slice_start * in->linesize[2];
+ const uint8_t *srca = in->data[3] + slice_start * in->linesize[3];
+ uint8_t *dstg = out->data[0] + slice_start * out->linesize[0];
+ uint8_t *dstb = out->data[1] + slice_start * out->linesize[1];
+ uint8_t *dstr = out->data[2] + slice_start * out->linesize[2];
+ uint8_t *dsta = out->data[3] + slice_start * out->linesize[3];
+ int i, j;
+
+ for (i = slice_start; i < slice_end; i++) {
+ for (j = 0; j < out->width; j++) {
+ dstg[j] = s->lut[G][srcg[j]];
+ dstb[j] = s->lut[B][srcb[j]];
+ dstr[j] = s->lut[R][srcr[j]];
+ if (in != out && out->linesize[3])
+ dsta[j] = srca[j];
+ }
+
+ srcg += in->linesize[0];
+ srcb += in->linesize[1];
+ srcr += in->linesize[2];
+ srca += in->linesize[3];
+ dstg += out->linesize[0];
+ dstb += out->linesize[1];
+ dstr += out->linesize[2];
+ dsta += out->linesize[3];
+ }
+
+ return 0;
+}
+
+static int apply_lut16_p(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs)
{
ColorBalanceContext *s = ctx->priv;
+ ThreadData *td = arg;
+ AVFrame *in = td->in;
+ AVFrame *out = td->out;
+ const int slice_start = (out->height * jobnr) / nb_jobs;
+ const int slice_end = (out->height * (jobnr+1)) / nb_jobs;
+ const uint16_t *srcg = (const uint16_t *)in->data[0] + slice_start * in->linesize[0] / 2;
+ const uint16_t *srcb = (const uint16_t *)in->data[1] + slice_start * in->linesize[1] / 2;
+ const uint16_t *srcr = (const uint16_t *)in->data[2] + slice_start * in->linesize[2] / 2;
+ const uint16_t *srca = (const uint16_t *)in->data[3] + slice_start * in->linesize[3] / 2;
+ uint16_t *dstg = (uint16_t *)out->data[0] + slice_start * out->linesize[0] / 2;
+ uint16_t *dstb = (uint16_t *)out->data[1] + slice_start * out->linesize[1] / 2;
+ uint16_t *dstr = (uint16_t *)out->data[2] + slice_start * out->linesize[2] / 2;
+ uint16_t *dsta = (uint16_t *)out->data[3] + slice_start * out->linesize[3] / 2;
+ int i, j;
+
+ for (i = slice_start; i < slice_end; i++) {
+ for (j = 0; j < out->width; j++) {
+ dstg[j] = s->lut[G][srcg[j]];
+ dstb[j] = s->lut[B][srcb[j]];
+ dstr[j] = s->lut[R][srcr[j]];
+ if (in != out && out->linesize[3])
+ dsta[j] = srca[j];
+ }
+
+ srcg += in->linesize[0] / 2;
+ srcb += in->linesize[1] / 2;
+ srcr += in->linesize[2] / 2;
+ srca += in->linesize[3] / 2;
+ dstg += out->linesize[0] / 2;
+ dstb += out->linesize[1] / 2;
+ dstr += out->linesize[2] / 2;
+ dsta += out->linesize[3] / 2;
+ }
+
+ return 0;
+}
+
+static int apply_lut8(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs)
+{
+ ColorBalanceContext *s = ctx->priv;
+ ThreadData *td = arg;
+ AVFrame *in = td->in;
+ AVFrame *out = td->out;
AVFilterLink *outlink = ctx->outputs[0];
- const uint8_t *srcrow = in->data[0];
+ const int slice_start = (out->height * jobnr) / nb_jobs;
+ const int slice_end = (out->height * (jobnr+1)) / nb_jobs;
+ const uint8_t *srcrow = in->data[0] + slice_start * in->linesize[0];
const uint8_t roffset = s->rgba_map[R];
const uint8_t goffset = s->rgba_map[G];
const uint8_t boffset = s->rgba_map[B];
uint8_t *dstrow;
int i, j;
- dstrow = out->data[0];
- for (i = 0; i < outlink->h; i++) {
+ dstrow = out->data[0] + slice_start * out->linesize[0];
+ for (i = slice_start; i < slice_end; i++) {
const uint8_t *src = srcrow;
uint8_t *dst = dstrow;
srcrow += in->linesize[0];
dstrow += out->linesize[0];
}
+
+ return 0;
}
-static void apply_lut16(AVFilterContext *ctx, AVFrame *in, AVFrame *out)
+static int apply_lut16(AVFilterContext *ctx, void *arg, int jobnr, int nb_jobs)
{
ColorBalanceContext *s = ctx->priv;
+ ThreadData *td = arg;
+ AVFrame *in = td->in;
+ AVFrame *out = td->out;
AVFilterLink *outlink = ctx->outputs[0];
- const uint16_t *srcrow = (const uint16_t *)in->data[0];
+ const int slice_start = (out->height * jobnr) / nb_jobs;
+ const int slice_end = (out->height * (jobnr+1)) / nb_jobs;
+ const uint16_t *srcrow = (const uint16_t *)in->data[0] + slice_start * in->linesize[0] / 2;
const uint8_t roffset = s->rgba_map[R];
const uint8_t goffset = s->rgba_map[G];
const uint8_t boffset = s->rgba_map[B];
uint16_t *dstrow;
int i, j;
- dstrow = (uint16_t *)out->data[0];
- for (i = 0; i < outlink->h; i++) {
+ dstrow = (uint16_t *)out->data[0] + slice_start * out->linesize[0] / 2;
+ for (i = slice_start; i < slice_end; i++) {
const uint16_t *src = srcrow;
uint16_t *dst = dstrow;
srcrow += in->linesize[0] / 2;
dstrow += out->linesize[0] / 2;
}
+
+ return 0;
}
static int config_output(AVFilterLink *outlink)
const AVPixFmtDescriptor *desc = av_pix_fmt_desc_get(outlink->format);
const int depth = desc->comp[0].depth;
const int max = 1 << depth;
+ const int planar = av_pix_fmt_count_planes(outlink->format) > 1;
double *shadows, *midtones, *highlights, *buffer;
int i, r, g, b;
- if (max == 256) {
+ if (max == 256 && planar) {
+ s->apply_lut = apply_lut8_p;
+ } else if (planar) {
+ s->apply_lut = apply_lut16_p;
+ } else if (max == 256) {
s->apply_lut = apply_lut8;
} else {
s->apply_lut = apply_lut16;
shadows[i] = low;
midtones[i] = mid;
- highlights[max - i] = low;
+ highlights[max - i - 1] = low;
}
for (i = 0; i < max; i++) {
r = g = b = i;
- r = av_clip_uintp2(r + s->cyan_red.shadows * shadows[r], depth);
- r = av_clip_uintp2(r + s->cyan_red.midtones * midtones[r], depth);
- r = av_clip_uintp2(r + s->cyan_red.highlights * highlights[r], depth);
+ r = av_clip_uintp2_c(r + s->cyan_red.shadows * shadows[r], depth);
+ r = av_clip_uintp2_c(r + s->cyan_red.midtones * midtones[r], depth);
+ r = av_clip_uintp2_c(r + s->cyan_red.highlights * highlights[r], depth);
- g = av_clip_uintp2(g + s->magenta_green.shadows * shadows[g], depth);
- g = av_clip_uintp2(g + s->magenta_green.midtones * midtones[g], depth);
- g = av_clip_uintp2(g + s->magenta_green.highlights * highlights[g], depth);
+ g = av_clip_uintp2_c(g + s->magenta_green.shadows * shadows[g], depth);
+ g = av_clip_uintp2_c(g + s->magenta_green.midtones * midtones[g], depth);
+ g = av_clip_uintp2_c(g + s->magenta_green.highlights * highlights[g], depth);
- b = av_clip_uintp2(b + s->yellow_blue.shadows * shadows[b], depth);
- b = av_clip_uintp2(b + s->yellow_blue.midtones * midtones[b], depth);
- b = av_clip_uintp2(b + s->yellow_blue.highlights * highlights[b], depth);
+ b = av_clip_uintp2_c(b + s->yellow_blue.shadows * shadows[b], depth);
+ b = av_clip_uintp2_c(b + s->yellow_blue.midtones * midtones[b], depth);
+ b = av_clip_uintp2_c(b + s->yellow_blue.highlights * highlights[b], depth);
s->lut[R][i] = r;
s->lut[G][i] = g;
AVFilterContext *ctx = inlink->dst;
ColorBalanceContext *s = ctx->priv;
AVFilterLink *outlink = ctx->outputs[0];
+ ThreadData td;
AVFrame *out;
if (av_frame_is_writable(in)) {
av_frame_copy_props(out, in);
}
- s->apply_lut(ctx, in, out);
+ td.in = in;
+ td.out = out;
+ ctx->internal->execute(ctx, s->apply_lut, &td, NULL, FFMIN(outlink->h, ff_filter_get_nb_threads(ctx)));
if (in != out)
av_frame_free(&in);
.query_formats = query_formats,
.inputs = colorbalance_inputs,
.outputs = colorbalance_outputs,
- .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC,
+ .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC | AVFILTER_FLAG_SLICE_THREADS,
};
projects / ffmpeg / blobdiff