mirror of https://github.com/xemu-project/xemu.git
libqtest: Fix possible deadlock in qtest initialization
'socket_accept' waits for QEMU to init its unix socket. If QEMU encounters an error during command line parsing, it can exit before initializing the communication channel. Using a timeout for sockets fixes the issue. Reviewed-by: Eric Blake <eblake@redhat.com> Signed-off-by: Marcel Apfelbaum <marcel.a@redhat.com> Reviewed-by: Stefan Hajnoczi <stefanha@redhat.com> Signed-off-by: Andreas Färber <afaerber@suse.de>
This commit is contained in:
parent
d2f69df746
commit
f8762027a3
|
@ -34,6 +34,7 @@
|
||||||
#include "qapi/qmp/json-parser.h"
|
#include "qapi/qmp/json-parser.h"
|
||||||
|
|
||||||
#define MAX_IRQ 256
|
#define MAX_IRQ 256
|
||||||
|
#define SOCKET_TIMEOUT 5
|
||||||
|
|
||||||
QTestState *global_qtest;
|
QTestState *global_qtest;
|
||||||
|
|
||||||
|
@ -78,12 +79,16 @@ static int socket_accept(int sock)
|
||||||
struct sockaddr_un addr;
|
struct sockaddr_un addr;
|
||||||
socklen_t addrlen;
|
socklen_t addrlen;
|
||||||
int ret;
|
int ret;
|
||||||
|
struct timeval timeout = { .tv_sec = SOCKET_TIMEOUT,
|
||||||
|
.tv_usec = 0 };
|
||||||
|
|
||||||
|
setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, (void *)&timeout,
|
||||||
|
sizeof(timeout));
|
||||||
|
|
||||||
addrlen = sizeof(addr);
|
addrlen = sizeof(addr);
|
||||||
do {
|
do {
|
||||||
ret = accept(sock, (struct sockaddr *)&addr, &addrlen);
|
ret = accept(sock, (struct sockaddr *)&addr, &addrlen);
|
||||||
} while (ret == -1 && errno == EINTR);
|
} while (ret == -1 && errno == EINTR);
|
||||||
g_assert_no_errno(ret);
|
|
||||||
close(sock);
|
close(sock);
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
|
@ -147,12 +152,16 @@ QTestState *qtest_init(const char *extra_args)
|
||||||
}
|
}
|
||||||
|
|
||||||
s->fd = socket_accept(sock);
|
s->fd = socket_accept(sock);
|
||||||
|
if (s->fd >= 0) {
|
||||||
s->qmp_fd = socket_accept(qmpsock);
|
s->qmp_fd = socket_accept(qmpsock);
|
||||||
|
}
|
||||||
unlink(socket_path);
|
unlink(socket_path);
|
||||||
unlink(qmp_socket_path);
|
unlink(qmp_socket_path);
|
||||||
g_free(socket_path);
|
g_free(socket_path);
|
||||||
g_free(qmp_socket_path);
|
g_free(qmp_socket_path);
|
||||||
|
|
||||||
|
g_assert(s->fd >= 0 && s->qmp_fd >= 0);
|
||||||
|
|
||||||
s->rx = g_string_new("");
|
s->rx = g_string_new("");
|
||||||
for (i = 0; i < MAX_IRQ; i++) {
|
for (i = 0; i < MAX_IRQ; i++) {
|
||||||
s->irq_level[i] = false;
|
s->irq_level[i] = false;
|
||||||
|
|
Loading…
Reference in New Issue