mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: mark empty buffers

Browse source 
This makes it use some more optimal paths in the mixer.
This commit is contained in:
Wim Taymans 2025-06-13 18:07:55 +02:00
parent b238060d9b
commit 75034634d0
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1379,6 +1379,7 @@ static void stream_process(void *data)
if (stream->direction == PW_DIRECTION_OUTPUT) { if (stream->direction == PW_DIRECTION_OUTPUT) {
int32_t avail = spa_ringbuffer_get_read_index(&stream->ring, &index); int32_t avail = spa_ringbuffer_get_read_index(&stream->ring, &index);
bool empty = false;
minreq = buffer->requested * stream->frame_size; minreq = buffer->requested * stream->frame_size;
if (minreq == 0) if (minreq == 0)
@ -1391,6 +1392,7 @@ static void stream_process(void *data)
/* underrun, produce a silence buffer */ /* underrun, produce a silence buffer */
size = SPA_MIN(d->maxsize, minreq); size = SPA_MIN(d->maxsize, minreq);
sample_spec_silence(&stream->ss, p, size); sample_spec_silence(&stream->ss, p, size);
empty = true;
if (stream->draining && !stream->corked) { if (stream->draining && !stream->corked) {
stream->draining = false; stream->draining = false;
@ -1406,6 +1408,7 @@ static void stream_process(void *data)
stream->buffer, MAXLENGTH, stream->buffer, MAXLENGTH,
index % MAXLENGTH, index % MAXLENGTH,
p, avail); p, avail);
empty = false;
} }
index += size; index += size;
pd.read_inc = size; pd.read_inc = size;
@ -1446,6 +1449,7 @@ static void stream_process(void *data)
d->chunk->offset = 0; d->chunk->offset = 0;
d->chunk->stride = stream->frame_size; d->chunk->stride = stream->frame_size;
d->chunk->size = size; d->chunk->size = size;
SPA_FLAG_UPDATE(d->chunk->flags, SPA_CHUNK_FLAG_EMPTY, empty);
buffer->size = size / stream->frame_size; buffer->size = size / stream->frame_size;
} else { } else {
int32_t filled = spa_ringbuffer_get_write_index(&stream->ring, &index); int32_t filled = spa_ringbuffer_get_write_index(&stream->ring, &index);