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

pulse-server: add missing EWOULDBLOCK check

Browse source
This commit is contained in:
Barnabás Pőcze 2021-05-31 20:09:09 +02:00
parent ebed44db79
commit 87c00a6f00
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -244,11 +244,12 @@ static int flush_messages(struct client *client)
while (true) {
res = send(client->source->fd, data, size, MSG_NOSIGNAL | MSG_DONTWAIT);
if (res < 0) {
if (errno == EINTR)
res = -errno;
if (res == -EINTR)
continue;
if (errno != EAGAIN && errno != EWOULDBLOCK)
pw_log_warn("send channel:%d %zu, res %d: %m", m->channel, size, res);
return -errno;
if (res != -EAGAIN && res != -EWOULDBLOCK)
pw_log_warn("send channel:%d %zu, error %d: %m", m->channel, size, res);
return res;
}
client->out_index += res;
break;
@ -5609,7 +5610,7 @@ on_client_data(void *data, int fd, uint32_t mask)
while (true) {
res = do_read(client);
if (res < 0) {
if (res != -EAGAIN)
if (res != -EAGAIN && res != EWOULDBLOCK)
goto error;
break;
}
@ -5623,7 +5624,7 @@ on_client_data(void *data, int fd, uint32_t mask)
int mask = client->source->mask;
SPA_FLAG_CLEAR(mask, SPA_IO_OUT);
pw_loop_update_io(impl->loop, client->source, mask);
} else if (res != -EAGAIN)
} else if (res != -EAGAIN && res != -EWOULDBLOCK)
goto error;
}
return;