mirrors/librempeg
1
0
Fork 0
mirror of https://github.com/librempeg/librempeg synced 2024-11-23 03:28:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

avfilter/af_dynaudnorm: add support for filtering non-writable frames

Browse Source 
Previously it would continue processing frame even if call
to make frame writable failed.
This commit is contained in:
Paul B Mahol 2021-10-05 16:21:50 +02:00
parent fcbaeefb45
commit 38b9dc98a8
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
libavfilter/af_dynaudnorm.c
View File

@ -668,11 +668,13 @@ static void analyze_frame(DynamicAudioNormalizerContext *s, AVFrame *frame)
}
}
static void amplify_frame(DynamicAudioNormalizerContext *s, AVFrame *frame, int enabled)
static void amplify_frame(DynamicAudioNormalizerContext *s, AVFrame *in,
AVFrame *frame, int enabled)
{
int c, i;
for (c = 0; c < s->channels; c++) {
const double *src_ptr = (const double *)in->extended_data[c];
double *dst_ptr = (double *)frame->extended_data[c];
double current_amplification_factor;
@ -683,7 +685,7 @@ static void amplify_frame(DynamicAudioNormalizerContext *s, AVFrame *frame, int
current_amplification_factor, i,
frame->nb_samples);
dst_ptr[i] *= amplification_factor;
dst_ptr[i] = src_ptr[i] * amplification_factor;
}
s->prev_amplification_factor[c] = current_amplification_factor;
@ -700,18 +702,31 @@ static int filter_frame(AVFilterLink *inlink, AVFrame *in)
while (((s->queue.available >= s->filter_size) ||
(s->eof && s->queue.available)) &&
!cqueue_empty(s->gain_history_smoothed[0])) {
AVFrame *out = ff_bufqueue_get(&s->queue);
AVFrame *in = ff_bufqueue_get(&s->queue);
AVFrame *out;
double is_enabled;
cqueue_dequeue(s->is_enabled, &is_enabled);
amplify_frame(s, out, is_enabled > 0.);
if (av_frame_is_writable(in)) {
out = in;
} else {
out = ff_get_audio_buffer(outlink, in->nb_samples);
if (!out) {
av_frame_free(&in);
return AVERROR(ENOMEM);
}
av_frame_copy_props(out, in);
}
amplify_frame(s, in, out, is_enabled > 0.);
s->pts = out->pts + av_rescale_q(out->nb_samples, av_make_q(1, outlink->sample_rate),
outlink->time_base);
if (out != in)
av_frame_free(&in);
ret = ff_filter_frame(outlink, out);
}
av_frame_make_writable(in);
analyze_frame(s, in);
if (!s->eof) {
ff_bufqueue_add(ctx, &s->queue, in);