mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

module-echo-cancel: Run canceller on first frames

Browse source 
Run canceller on the first frames when play delay is not a multiple of
the chunk size.
This commit is contained in:
Jonas Holmberg 2022-10-21 14:53:26 +02:00
parent 71879961db
commit 8092a0a637
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/modules/module-echo-cancel.c
View file

@ -279,11 +279,21 @@ static void process(struct impl *impl)
/* don't run the canceller until play_buffer has been filled, /* don't run the canceller until play_buffer has been filled,
* copy silence to output in the meantime */ * copy silence to output in the meantime */
silence_size = SPA_MIN(size, delay_left * sizeof(float)); silence_size = SPA_MIN(size, delay_left * sizeof(float));
for (i = 0; i < impl->info.channels; i++) { for (i = 0; i < impl->info.channels; i++)
memset(out[i], 0, silence_size); memset(out[i], 0, silence_size);
}
impl->current_delay += silence_size / sizeof(float); impl->current_delay += silence_size / sizeof(float);
pw_log_debug("current_delay %d", impl->current_delay); pw_log_debug("current_delay %d", impl->current_delay);
if (silence_size != size) {
const float *pd[impl->info.channels];
float *o[impl->info.channels];
for (i = 0; i < impl->info.channels; i++) {
pd[i] = play_delayed[i] + delay_left;
o[i] = out[i] + delay_left;
}
spa_audio_aec_run(impl->aec, rec, pd, o, delay_left);
}
} else { } else {
/* run the canceller */ /* run the canceller */
spa_audio_aec_run(impl->aec, rec, play_delayed, out, size / sizeof(float)); spa_audio_aec_run(impl->aec, rec, play_delayed, out, size / sizeof(float));