mirror of
https://gitlab.freedesktop.org/pipewire/pipewire.git
synced 2025-11-04 13:30:12 -05:00
pulse-server: don't underrun when draining
This commit is contained in:
parent
3960a88478
commit
98b1b8090d
1 changed files with 7 additions and 5 deletions
|
|
@ -1276,13 +1276,15 @@ static void stream_process(void *data)
|
||||||
int32_t avail = spa_ringbuffer_get_read_index(&stream->ring, &pd.read_index);
|
int32_t avail = spa_ringbuffer_get_read_index(&stream->ring, &pd.read_index);
|
||||||
if (avail <= 0) {
|
if (avail <= 0) {
|
||||||
/* underrun */
|
/* underrun */
|
||||||
if (stream->drain_tag)
|
|
||||||
pw_stream_flush(stream->stream, true);
|
|
||||||
|
|
||||||
size = buf->datas[0].maxsize;
|
size = buf->datas[0].maxsize;
|
||||||
memset(p, 0, size);
|
memset(p, 0, size);
|
||||||
pd.underrun_for = size;
|
|
||||||
pd.underrun = true;
|
if (stream->drain_tag)
|
||||||
|
pw_stream_flush(stream->stream, true);
|
||||||
|
else {
|
||||||
|
pd.underrun_for = size;
|
||||||
|
pd.underrun = true;
|
||||||
|
}
|
||||||
} else if (avail > MAXLENGTH) {
|
} else if (avail > MAXLENGTH) {
|
||||||
/* overrun, handled by other side */
|
/* overrun, handled by other side */
|
||||||
pw_log_warn(NAME" %p: overrun", stream);
|
pw_log_warn(NAME" %p: overrun", stream);
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue