resample: first resample the data, then apply the new rate

Else we might not have enough input samples for the new rate.
This commit is contained in:
Wim Taymans 2021-01-08 13:17:06 +01:00
parent 4440ede41c
commit 7e9ab8b457

View file

@ -817,14 +817,6 @@ static int impl_node_process(void *object)
flush_in = draining = true; flush_in = draining = true;
} }
if (this->io_rate_match) {
if (SPA_FLAG_IS_SET(this->io_rate_match->flags, SPA_IO_RATE_MATCH_FLAG_ACTIVE)) {
resample_update_rate(&this->resample, this->io_rate_match->rate);
} else {
resample_update_rate(&this->resample, 1.0);
}
}
in_len = (size - inport->offset) / sizeof(float); in_len = (size - inport->offset) / sizeof(float);
out_len = (maxsize - outport->offset) / sizeof(float); out_len = (maxsize - outport->offset) / sizeof(float);
@ -881,6 +873,11 @@ static int impl_node_process(void *object)
} }
if (this->io_rate_match) { if (this->io_rate_match) {
if (SPA_FLAG_IS_SET(this->io_rate_match->flags, SPA_IO_RATE_MATCH_FLAG_ACTIVE)) {
resample_update_rate(&this->resample, this->io_rate_match->rate);
} else {
resample_update_rate(&this->resample, 1.0);
}
this->io_rate_match->delay = resample_delay(&this->resample); this->io_rate_match->delay = resample_delay(&this->resample);
this->io_rate_match->size = resample_in_len(&this->resample, max); this->io_rate_match->size = resample_in_len(&this->resample, max);
} }