mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-01 22:58:50 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

audioadapter: propagate errors from the follower

Browse source
This commit is contained in:
Wim Taymans 2020-09-25 18:24:04 +02:00
parent c2fc8423eb
commit 013e94ee4e
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
spa/plugins/audioconvert/audioadapter.c
View file

@ -914,6 +914,10 @@ static int impl_node_process(void *object)
/* as long as the converter produced something or /* as long as the converter produced something or
* is drained, process the follower. */ * is drained, process the follower. */
fstatus = spa_node_process(this->follower); fstatus = spa_node_process(this->follower);
if (fstatus < 0) {
status = fstatus;
break;
}
/* if the follower doesn't need more data or is /* if the follower doesn't need more data or is
* drained we can stop */ * drained we can stop */
if ((fstatus & SPA_STATUS_NEED_DATA) == 0 || if ((fstatus & SPA_STATUS_NEED_DATA) == 0 ||
@ -948,6 +952,10 @@ static int impl_node_process(void *object)
/* the converter needs more data, schedule the /* the converter needs more data, schedule the
* follower */ * follower */
fstatus = spa_node_process(this->follower); fstatus = spa_node_process(this->follower);
if (fstatus < 0) {
status = fstatus;
break;
}
/* if the follower didn't produce more data /* if the follower didn't produce more data
* we can stop now */ * we can stop now */
if ((fstatus & SPA_STATUS_HAVE_DATA) == 0) if ((fstatus & SPA_STATUS_HAVE_DATA) == 0)