int nb_samples;
int64_t pts;
int64_t duration;
+ int in_trim;
+ int out_pad;
+ int latency;
} LADSPAContext;
#define OFFSET(x) offsetof(LADSPAContext, x)
{ "n", "set the number of samples per requested frame", OFFSET(nb_samples), AV_OPT_TYPE_INT, {.i64=1024}, 1, INT_MAX, FLAGS },
{ "duration", "set audio duration", OFFSET(duration), AV_OPT_TYPE_DURATION, {.i64=-1}, -1, INT64_MAX, FLAGS },
{ "d", "set audio duration", OFFSET(duration), AV_OPT_TYPE_DURATION, {.i64=-1}, -1, INT64_MAX, FLAGS },
+ { "latency", "enable latency compensation", OFFSET(latency), AV_OPT_TYPE_BOOL, {.i64=0}, 0, 1, FLAGS },
+ { "l", "enable latency compensation", OFFSET(latency), AV_OPT_TYPE_BOOL, {.i64=0}, 0, 1, FLAGS },
{ NULL }
};
AVFILTER_DEFINE_CLASS(ladspa);
+static int find_latency(AVFilterContext *ctx, LADSPAContext *s)
+{
+ int latency = 0;
+
+ for (int ctl = 0; ctl < s->nb_outputcontrols; ctl++) {
+ if (av_strcasecmp("latency", s->desc->PortNames[s->ocmap[ctl]]))
+ continue;
+
+ latency = lrintf(s->octlv[ctl]);
+ break;
+ }
+
+ return latency;
+}
+
static void print_ctl_info(AVFilterContext *ctx, int level,
LADSPAContext *s, int ctl, unsigned long *map,
LADSPA_Data *values, int print)
AVFilterContext *ctx = inlink->dst;
LADSPAContext *s = ctx->priv;
AVFrame *out;
- int i, h, p;
+ int i, h, p, new_out_samples;
av_assert0(in->channels == (s->nb_inputs * s->nb_handles));
if (!s->nb_outputs ||
(av_frame_is_writable(in) && s->nb_inputs == s->nb_outputs &&
+ s->in_trim == 0 && s->out_pad == 0 &&
!(s->desc->Properties & LADSPA_PROPERTY_INPLACE_BROKEN))) {
out = in;
} else {
}
s->desc->run(s->handles[h], in->nb_samples);
+ if (s->latency)
+ s->in_trim = s->out_pad = find_latency(ctx, s);
+ s->latency = 0;
}
for (i = 0; i < s->nb_outputcontrols; i++)
if (out != in)
av_frame_free(&in);
+ new_out_samples = out->nb_samples;
+ if (s->in_trim > 0) {
+ int trim = FFMIN(new_out_samples, s->in_trim);
+
+ new_out_samples -= trim;
+ s->in_trim -= trim;
+ }
+
+ if (new_out_samples <= 0) {
+ av_frame_free(&out);
+ return 0;
+ } else if (new_out_samples < out->nb_samples) {
+ int offset = out->nb_samples - new_out_samples;
+ for (int ch = 0; ch < out->channels; ch++)
+ memmove(out->extended_data[ch], out->extended_data[ch] + sizeof(float) * offset,
+ sizeof(float) * new_out_samples);
+ out->nb_samples = new_out_samples;
+ }
+
return ff_filter_frame(ctx->outputs[0], out);
}
int64_t t;
int i;
- if (ctx->nb_inputs)
- return ff_request_frame(ctx->inputs[0]);
+ if (ctx->nb_inputs) {
+ int ret = ff_request_frame(ctx->inputs[0]);
+
+ if (ret == AVERROR_EOF && s->out_pad > 0) {
+ AVFrame *frame = ff_get_audio_buffer(outlink, FFMIN(2048, s->out_pad));
+ if (!frame)
+ return AVERROR(ENOMEM);
+
+ s->out_pad -= frame->nb_samples;
+ return filter_frame(ctx->inputs[0], frame);
+ }
+ return ret;
+ }
t = av_rescale(s->pts, AV_TIME_BASE, s->sample_rate);
if (s->duration >= 0 && t >= s->duration)
} else {
// argument is a shared object name
char *paths = av_strdup(getenv("LADSPA_PATH"));
+ const char *home_path = getenv("HOME");
const char *separator = ":";
if (paths) {
}
av_free(paths);
- if (!s->dl_handle && (paths = av_asprintf("%s/.ladspa/lib", getenv("HOME")))) {
+ if (!s->dl_handle && home_path && (paths = av_asprintf("%s/.ladspa", home_path))) {
+ s->dl_handle = try_load(paths, s->dl_name);
+ av_free(paths);
+ }
+
+ if (!s->dl_handle && home_path && (paths = av_asprintf("%s/.ladspa/lib", home_path))) {
s->dl_handle = try_load(paths, s->dl_name);
av_free(paths);
}
break;
p = NULL;
- if (sscanf(arg, "c%d=%f", &i, &val) != 2) {
- if (sscanf(arg, "%f", &val) != 1) {
+ if (av_sscanf(arg, "c%d=%f", &i, &val) != 2) {
+ if (av_sscanf(arg, "%f", &val) != 1) {
av_log(ctx, AV_LOG_ERROR, "Invalid syntax.\n");
return AVERROR(EINVAL);
}
ret = ff_add_channel_layout(&layouts, inlayout);
if (ret < 0)
return ret;
- ret = ff_channel_layouts_ref(layouts, &inlink->out_channel_layouts);
+ ret = ff_channel_layouts_ref(layouts, &inlink->outcfg.channel_layouts);
if (ret < 0)
return ret;
if (!s->nb_outputs) {
- ret = ff_channel_layouts_ref(layouts, &outlink->in_channel_layouts);
+ ret = ff_channel_layouts_ref(layouts, &outlink->incfg.channel_layouts);
if (ret < 0)
return ret;
}
ret = ff_add_channel_layout(&layouts, outlayout);
if (ret < 0)
return ret;
- ret = ff_channel_layouts_ref(layouts, &outlink->in_channel_layouts);
+ ret = ff_channel_layouts_ref(layouts, &outlink->incfg.channel_layouts);
if (ret < 0)
return ret;
}
LADSPA_Data value;
unsigned long port;
- if (sscanf(cmd, "c%ld", &port) + sscanf(args, "%f", &value) != 2)
+ if (av_sscanf(cmd, "c%ld", &port) + av_sscanf(args, "%f", &value) != 2)
return AVERROR(EINVAL);
return set_control(ctx, port, value);