mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-31 22:25:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: write captured data in fragsize chunks

Browse source 
Keep on queuing chunks of fragsize length until we read all the
captured data. Else we would fall behind and really never catch
up.
This commit is contained in:
Wim Taymans 2021-02-09 17:37:41 +01:00
parent 739f3b9f7f
commit d60f2b9b92
1 changed files with 21 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1455,7 +1455,7 @@ do_process_done(struct spa_loop *loop,
struct client *client = stream->client;
struct impl *impl = client->impl;
const struct process_data *pd = data;
uint32_t index;
uint32_t index, towrite;
int32_t avail;
stream->timestamp = pd->pwt.now;
@ -1513,25 +1513,28 @@ do_process_done(struct spa_loop *loop,
avail = stream->attr.fragsize;
index = stream->write_index - avail;
}
else if (avail > (int32_t)stream->attr.fragsize) {
pw_log_debug(NAME" %p: [%s] limit avail:%d > frag:%u",
stream, client->name, avail, stream->attr.fragsize);
avail = stream->attr.fragsize;
while (avail > 0) {
towrite = avail;
if (towrite > stream->attr.fragsize)
towrite = stream->attr.fragsize;
msg = message_alloc(impl, stream->channel, towrite);
if (msg == NULL)
return -errno;
spa_ringbuffer_read_data(&stream->ring,
stream->buffer, stream->attr.maxlength,
index % stream->attr.maxlength,
msg->data, towrite);
send_message(client, msg);
index += towrite;
avail -= towrite;
}
msg = message_alloc(impl, stream->channel, avail);
if (msg == NULL)
return -errno;
spa_ringbuffer_read_data(&stream->ring,
stream->buffer, stream->attr.maxlength,
index % stream->attr.maxlength,
msg->data, avail);
stream->read_index = index + avail;
stream->read_index = index;
spa_ringbuffer_read_update(&stream->ring, stream->read_index);
send_message(client, msg);
}
}
return 0;