float h_pos, v_pos;
float h_ipos, v_ipos;
+ int pos_h[4], pos_v[4];
+
const AVPixFmtDescriptor *desc;
int nb_planes;
int bytes;
AV_PIX_FMT_YUV420P14, AV_PIX_FMT_YUV422P14, AV_PIX_FMT_YUV444P14,
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_YUVA422P12, AV_PIX_FMT_YUVA444P12,
AV_PIX_FMT_YUVA420P10, AV_PIX_FMT_YUVA422P10, AV_PIX_FMT_YUVA444P10,
AV_PIX_FMT_YUVA420P16, AV_PIX_FMT_YUVA422P16, AV_PIX_FMT_YUVA444P16,
AV_PIX_FMT_GBRP, AV_PIX_FMT_GBRP9, AV_PIX_FMT_GBRP10,
return ff_set_common_formats(ctx, fmts_list);
}
-static void scroll(ScrollContext *s, AVFrame *in, AVFrame *out)
+typedef struct ThreadData {
+ AVFrame *in, *out;
+} ThreadData;
+
+static int scroll_slice(AVFilterContext *ctx, void *arg, int jobnr,
+ int nb_jobs)
{
+ ScrollContext *s = ctx->priv;
+ ThreadData *td = arg;
+ AVFrame *in = td->in;
+ AVFrame *out = td->out;
+
+ for (int p = 0; p < s->nb_planes; p++) {
+ const uint8_t *src = in->data[p];
+ const int h = s->planeheight[p];
+ const int w = s->planewidth[p] * s->bytes;
+ const int slice_start = (h * jobnr) / nb_jobs;
+ const int slice_end = (h * (jobnr+1)) / nb_jobs;
+ uint8_t *dst = out->data[p] + slice_start * out->linesize[p];
+
+ for (int y = slice_start; y < slice_end; y++) {
+ int yy = (y + s->pos_v[p]) % h;
+ const uint8_t *ssrc = src + yy * in->linesize[p];
+
+ if (s->pos_h[p] < w)
+ memcpy(dst, ssrc + s->pos_h[p], w - s->pos_h[p]);
+ if (s->pos_h[p] > 0)
+ memcpy(dst + w - s->pos_h[p], ssrc, s->pos_h[p]);
+
+ dst += out->linesize[p];
+ }
+ }
+
+ return 0;
+}
+
+static void scroll(AVFilterContext *ctx, AVFrame *in, AVFrame *out)
+{
+ ScrollContext *s = ctx->priv;
+ ThreadData td;
int h_pos, v_pos;
- int pos_h[4], pos_v[4];
s->h_pos = fmodf(s->h_pos, in->width);
s->v_pos = fmodf(s->v_pos, in->height);
if (v_pos < 0)
v_pos += in->height;
- pos_v[1] = pos_v[2] = AV_CEIL_RSHIFT(v_pos, s->desc->log2_chroma_h);
- pos_v[0] = pos_v[3] = v_pos;
- pos_h[1] = pos_h[2] = AV_CEIL_RSHIFT(h_pos, s->desc->log2_chroma_w) * s->bytes;
- pos_h[0] = pos_h[3] = h_pos * s->bytes;
+ s->pos_v[1] = s->pos_v[2] = AV_CEIL_RSHIFT(v_pos, s->desc->log2_chroma_h);
+ s->pos_v[0] = s->pos_v[3] = v_pos;
+ s->pos_h[1] = s->pos_h[2] = AV_CEIL_RSHIFT(h_pos, s->desc->log2_chroma_w) * s->bytes;
+ s->pos_h[0] = s->pos_h[3] = h_pos * s->bytes;
- for (int p = 0; p < s->nb_planes; p++) {
- const uint8_t *src = in->data[p];
- uint8_t *dst = out->data[p];
- const int h = s->planeheight[p];
- const int w = s->planewidth[p] * s->bytes;
-
- for (int y = 0; y < h; y++) {
- int yy = (y + pos_v[p]) % h;
- const uint8_t *ssrc = src + yy * in->linesize[p];
-
- if (pos_h[p] < w)
- memcpy(dst, ssrc + pos_h[p], w - pos_h[p]);
- if (pos_h[p] > 0)
- memcpy(dst + w - pos_h[p], ssrc, pos_h[p]);
-
- dst += out->linesize[p];
- }
- }
+ td.in = in; td.out = out;
+ ctx->internal->execute(ctx, scroll_slice, &td, NULL,
+ FFMIN(out->height, ff_filter_get_nb_threads(ctx)));
s->h_pos += s->h_speed * in->width;
s->v_pos += s->v_speed * in->height;
static int filter_frame(AVFilterLink *inlink, AVFrame *in)
{
AVFilterContext *ctx = inlink->dst;
- ScrollContext *s = ctx->priv;
AVFilterLink *outlink = ctx->outputs[0];
AVFrame *out;
}
av_frame_copy_props(out, in);
- scroll(s, in, out);
+ scroll(ctx, in, out);
av_frame_free(&in);
return ff_filter_frame(outlink, out);
#define OFFSET(x) offsetof(ScrollContext, x)
#define FLAGS AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_FILTERING_PARAM
+#define VFT AV_OPT_FLAG_VIDEO_PARAM|AV_OPT_FLAG_FILTERING_PARAM|AV_OPT_FLAG_RUNTIME_PARAM
static const AVOption scroll_options[] = {
- { "horizontal", "set the horizontal scrolling speed", OFFSET(h_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., FLAGS },
- { "h", "set the horizontal scrolling speed", OFFSET(h_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., FLAGS },
- { "vertical", "set the vertical scrolling speed", OFFSET(v_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., FLAGS },
- { "v", "set the vertical scrolling speed", OFFSET(v_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., FLAGS },
+ { "horizontal", "set the horizontal scrolling speed", OFFSET(h_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., VFT },
+ { "h", "set the horizontal scrolling speed", OFFSET(h_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., VFT },
+ { "vertical", "set the vertical scrolling speed", OFFSET(v_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., VFT },
+ { "v", "set the vertical scrolling speed", OFFSET(v_speed), AV_OPT_TYPE_FLOAT, {.dbl=0.}, -1., 1., VFT },
{ "hpos", "set initial horizontal position", OFFSET(h_ipos), AV_OPT_TYPE_FLOAT, {.dbl=0.}, 0, 1., FLAGS },
{ "vpos", "set initial vertical position", OFFSET(v_ipos), AV_OPT_TYPE_FLOAT, {.dbl=0.}, 0, 1., FLAGS },
{ NULL }
{ NULL }
};
-AVFilter ff_vf_scroll = {
+const AVFilter ff_vf_scroll = {
.name = "scroll",
.description = NULL_IF_CONFIG_SMALL("Scroll input video."),
.priv_size = sizeof(ScrollContext),
.query_formats = query_formats,
.inputs = scroll_inputs,
.outputs = scroll_outputs,
- .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC,
+ .flags = AVFILTER_FLAG_SUPPORT_TIMELINE_GENERIC | AVFILTER_FLAG_SLICE_THREADS,
+ .process_command = ff_filter_process_command,
};
projects / ffmpeg / blobdiff