mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-12-21 08:56:56 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: try to flush immediately

Browse source 
When we queued new data and were not flushing already, try to flush
the data immediately.
This commit is contained in:
Wim Taymans 2020-11-16 17:05:11 +01:00
parent 0fada77433
commit 5849bd7c60
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -129,6 +129,7 @@ struct client {
struct spa_list samples; struct spa_list samples;
unsigned int disconnecting:1; unsigned int disconnecting:1;
unsigned int need_flush:1;
}; };
struct buffer_attr { struct buffer_attr {
@ -368,6 +369,7 @@ static int send_message(struct client *client, struct message *m)
mask = client->source->mask; mask = client->source->mask;
if (!SPA_FLAG_IS_SET(mask, SPA_IO_OUT)) { if (!SPA_FLAG_IS_SET(mask, SPA_IO_OUT)) {
client->need_flush = true;
SPA_FLAG_SET(mask, SPA_IO_OUT); SPA_FLAG_SET(mask, SPA_IO_OUT);
pw_loop_update_io(impl->loop, client->source, mask); pw_loop_update_io(impl->loop, client->source, mask);
} }
@ -4757,8 +4759,9 @@ on_client_data(void *data, int fd, uint32_t mask)
} }
} }
} }
if (mask & SPA_IO_OUT) { if (mask & SPA_IO_OUT || client->need_flush) {
pw_log_trace(NAME" %p: can write", impl); pw_log_trace(NAME" %p: can write", impl);
client->need_flush = false;
res = flush_messages(client); res = flush_messages(client);
if (res >= 0) { if (res >= 0) {
int mask = client->source->mask; int mask = client->source->mask;