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

pulse-server: hand out silence when corked

Browse source 
In the corked state we simply hand out silence and don't try to
consume data from our ringbuffer.
Also set the corked state before syncing this with the data thread.

Fixes #662
This commit is contained in:
Wim Taymans 2021-02-02 10:42:34 +01:00
parent a18a8c9e32
commit 748e205453
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/modules/module-protocol-pulse/pulse-server.c
View file

@ -1559,7 +1559,7 @@ static void stream_process(void *data)
else
minreq = SPA_MAX(stream->minblock, stream->attr.minreq);
if (avail < (int32_t)minreq) {
if (avail < (int32_t)minreq || stream->corked) {
/* underrun, produce a silence buffer */
size = SPA_MIN(buf->datas[0].maxsize, minreq);
memset(p, 0, size);
@ -1571,7 +1571,7 @@ static void stream_process(void *data)
pd.underrun_for = size;
pd.underrun = true;
}
if (stream->attr.prebuf == 0) {
if (stream->attr.prebuf == 0 && !stream->corked) {
pd.missing = size;
pd.playing_for = size;
pd.read_index += size;
@ -2685,8 +2685,8 @@ static int do_cork_stream(struct client *client, uint32_t command, uint32_t tag,
if (stream == NULL || stream->type == STREAM_TYPE_UPLOAD)
return -ENOENT;
pw_stream_set_active(stream->stream, !cork);
stream->corked = cork;
pw_stream_set_active(stream->stream, !cork);
if (cork) {
stream->is_underrun = true;
} else {