motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-11 03:24:58 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

util/qemu-sockets: Refactor setting client sockopts into a separate function

Browse source 
This is done in preparation for enabling the SO_KEEPALIVE support for
server sockets and adding settings for more TCP keep-alive socket
options.

Signed-off-by: Juraj Marcin <jmarcin@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
This commit is contained in:
Juraj Marcin 2025-05-21 15:52:31 +02:00 • committed by Daniel P. Berrangé
parent 0dc051aa85
commit b8b5278aca
1 changed files with 19 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

25
util/qemu-sockets.c
View file

@ -205,6 +205,22 @@ static int try_bind(int socket, InetSocketAddress *saddr, struct addrinfo *e)
#endif #endif
} }
static int inet_set_sockopts(int sock, InetSocketAddress *saddr, Error **errp)
{
if (saddr->keep_alive) {
int keep_alive = 1;
int ret = setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,
&keep_alive, sizeof(keep_alive));
if (ret < 0) {
error_setg_errno(errp, errno,
"Unable to set keep-alive option on socket");
return -1;
}
}
return 0;
}
static int inet_listen_saddr(InetSocketAddress *saddr, static int inet_listen_saddr(InetSocketAddress *saddr,
int port_offset, int port_offset,
int num, int num,
@ -475,17 +491,10 @@ int inet_connect_saddr(InetSocketAddress *saddr, Error **errp)
return sock; return sock;
} }
if (saddr->keep_alive) { if (inet_set_sockopts(sock, saddr, errp) < 0) {
int val = 1;
int ret = setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,
&val, sizeof(val));
if (ret < 0) {
error_setg_errno(errp, errno, "Unable to set KEEPALIVE");
close(sock); close(sock);
return -1; return -1;
} }
}
return sock; return sock;
} }