pxcloud/spice
5
0
Fork 0
mirror of https://gitlab.uni-freiburg.de/opensourcevdi/spice synced 2025-12-26 14:41:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

dispatcher: Use socket compatibility layer

Browse Source 
Signed-off-by: Frediano Ziglio <fziglio@redhat.com>
Acked-by: Victor Toso <victortoso@redhat.com>
This commit is contained in:
Frediano Ziglio 2018-06-24 19:10:44 +01:00
parent 5c65107663
commit 3a95e77af2
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/dispatcher.c
View File

@ -113,8 +113,8 @@ dispatcher_finalize(GObject *object)
{
Dispatcher *self = DISPATCHER(object);
g_free(self->priv->messages);
close(self->priv->send_fd);
close(self->priv->recv_fd);
socket_close(self->priv->send_fd);
socket_close(self->priv->recv_fd);
pthread_mutex_destroy(&self->priv->lock);
g_free(self->priv->payload);
G_OBJECT_CLASS(dispatcher_parent_class)->finalize(object);
@ -213,7 +213,7 @@ static int read_safe(int fd, uint8_t *buf, size_t size, int block)
}
}
while (read_size < size) {
ret = read(fd, buf + read_size, size - read_size);
ret = socket_read(fd, buf + read_size, size - read_size);
if (ret == -1) {
if (errno == EINTR) {
spice_debug("EINTR in read");
@ -240,7 +240,7 @@ static int write_safe(int fd, uint8_t *buf, size_t size)
int ret;
while (written_size < size) {
ret = write(fd, buf + written_size, size - written_size);
ret = socket_write(fd, buf + written_size, size - written_size);
if (ret == -1) {
if (errno != EINTR) {
return -1;