Proxmox-Port/qemu
1
0
Fork 0
mirror of https://github.com/qemu/qemu.git synced 2025-08-05 10:37:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

qtest resource cleanup patches

Browse Source 
-----BEGIN PGP SIGNATURE-----
 Version: GnuPG v1
 
 iQEcBAABAgAGBQJS8KTYAAoJEJykq7OBq3PIpmcH/3zOwl8/m2ciW5gD7STsZIxc
 zch9zk0dgcb3u9EQgjchI4J9d+0C1Ql1vBW/k7cSPUrCuB7YbaE580v2x9XQ/tqr
 dI2vd4NfBc2WoQerpH7YYG50ujyxOyIM4UJVPhasBqhphiZNkqLHK9C9f4H29nT1
 TARX6XKKNQZ0ljEHjx/8TBqJWs/dxX7mdIns4t05CbDHY7d59qJVkv8cBV038r+i
 mmEOJqVwNkpbMZM510oobRJoOhNRN3slrSQRuskPI3wjWbRlZkFzQbYzaLepSyo6
 ErI014sEelEzucQgtGPKv5vVMSV6ZAuxewKsg+PbrZYX++6CF7KildbsrM6ADek=
 =FkAl
 -----END PGP SIGNATURE-----

Merge remote-tracking branch 'remotes/stefanha/tags/qtest-for-peter' into staging

qtest resource cleanup patches

# gpg: Signature made Tue 04 Feb 2014 08:29:12 GMT using RSA key ID 81AB73C8
# gpg: Good signature from "Stefan Hajnoczi <stefanha@redhat.com>"
# gpg:                 aka "Stefan Hajnoczi <stefanha@gmail.com>"
# gpg: WARNING: This key is not certified with a trusted signature!
# gpg:          There is no indication that the signature belongs to the owner.
# Primary key fingerprint: 8695 A8BF D3F9 7CDA AC35  775A 9CA4 ABB3 81AB 73C8

* remotes/stefanha/tags/qtest-for-peter:
  qtest: unlink UNIX domain sockets after connecting
  qtest: unlink QEMU pid file after startup

Signed-off-by: Peter Maydell <peter.maydell@linaro.org>
This commit is contained in:
Peter Maydell 2014-02-07 16:03:13 +00:00
commit 91abb80b5f
1 changed files with 23 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
tests/libqtest.c
View File

@ -43,9 +43,8 @@ struct QTestState
int qmp_fd; int qmp_fd;
bool irq_level[MAX_IRQ]; bool irq_level[MAX_IRQ];
GString *rx; GString *rx;
gchar *pid_file; /* QEMU PID file */
int child_pid; /* Child process created to execute QEMU */ int child_pid; /* Child process created to execute QEMU */
char *socket_path, *qmp_socket_path; pid_t qemu_pid; /* QEMU process spawned by our child */
}; };
#define g_assert_no_errno(ret) do { \ #define g_assert_no_errno(ret) do { \
@ -90,13 +89,13 @@ static int socket_accept(int sock)
return ret; return ret;
} }
static pid_t qtest_qemu_pid(QTestState *s) static pid_t read_pid_file(const char *pid_file)
{ {
FILE *f; FILE *f;
char buffer[1024]; char buffer[1024];
pid_t pid = -1; pid_t pid = -1;
f = fopen(s->pid_file, "r"); f = fopen(pid_file, "r");
if (f) { if (f) {
if (fgets(buffer, sizeof(buffer), f)) { if (fgets(buffer, sizeof(buffer), f)) {
pid = atoi(buffer); pid = atoi(buffer);
@ -110,6 +109,8 @@ QTestState *qtest_init(const char *extra_args)
{ {
QTestState *s; QTestState *s;
int sock, qmpsock, i; int sock, qmpsock, i;
gchar *socket_path;
gchar *qmp_socket_path;
gchar *pid_file; gchar *pid_file;
gchar *command; gchar *command;
const char *qemu_binary; const char *qemu_binary;
@ -120,12 +121,12 @@ QTestState *qtest_init(const char *extra_args)
s = g_malloc(sizeof(*s)); s = g_malloc(sizeof(*s));
s->socket_path = g_strdup_printf("/tmp/qtest-%d.sock", getpid()); socket_path = g_strdup_printf("/tmp/qtest-%d.sock", getpid());
s->qmp_socket_path = g_strdup_printf("/tmp/qtest-%d.qmp", getpid()); qmp_socket_path = g_strdup_printf("/tmp/qtest-%d.qmp", getpid());
pid_file = g_strdup_printf("/tmp/qtest-%d.pid", getpid()); pid_file = g_strdup_printf("/tmp/qtest-%d.pid", getpid());
sock = init_socket(s->socket_path); sock = init_socket(socket_path);
qmpsock = init_socket(s->qmp_socket_path); qmpsock = init_socket(qmp_socket_path);
pid = fork(); pid = fork();
if (pid == 0) { if (pid == 0) {
@ -136,8 +137,8 @@ QTestState *qtest_init(const char *extra_args)
"-pidfile %s " "-pidfile %s "
"-machine accel=qtest " "-machine accel=qtest "
"-display none " "-display none "
"%s", qemu_binary, s->socket_path, "%s", qemu_binary, socket_path,
s->qmp_socket_path, pid_file, qmp_socket_path, pid_file,
extra_args ?: ""); extra_args ?: "");
execlp("/bin/sh", "sh", "-c", command, NULL); execlp("/bin/sh", "sh", "-c", command, NULL);
exit(1); exit(1);
@ -145,9 +146,12 @@ QTestState *qtest_init(const char *extra_args)
s->fd = socket_accept(sock); s->fd = socket_accept(sock);
s->qmp_fd = socket_accept(qmpsock); s->qmp_fd = socket_accept(qmpsock);
unlink(socket_path);
unlink(qmp_socket_path);
g_free(socket_path);
g_free(qmp_socket_path);
s->rx = g_string_new(""); s->rx = g_string_new("");
s->pid_file = pid_file;
s->child_pid = pid; s->child_pid = pid;
for (i = 0; i < MAX_IRQ; i++) { for (i = 0; i < MAX_IRQ; i++) {
s->irq_level[i] = false; s->irq_level[i] = false;
@ -157,8 +161,12 @@ QTestState *qtest_init(const char *extra_args)
qtest_qmp_discard_response(s, ""); qtest_qmp_discard_response(s, "");
qtest_qmp_discard_response(s, "{ 'execute': 'qmp_capabilities' }"); qtest_qmp_discard_response(s, "{ 'execute': 'qmp_capabilities' }");
s->qemu_pid = read_pid_file(pid_file);
unlink(pid_file);
g_free(pid_file);
if (getenv("QTEST_STOP")) { if (getenv("QTEST_STOP")) {
kill(qtest_qemu_pid(s), SIGSTOP); kill(s->qemu_pid, SIGSTOP);
} }
return s; return s;
@ -168,21 +176,14 @@ void qtest_quit(QTestState *s)
{ {
int status; int status;
pid_t pid = qtest_qemu_pid(s); if (s->qemu_pid != -1) {
if (pid != -1) { kill(s->qemu_pid, SIGTERM);
kill(pid, SIGTERM); waitpid(s->qemu_pid, &status, 0);
waitpid(pid, &status, 0);
} }
close(s->fd); close(s->fd);
close(s->qmp_fd); close(s->qmp_fd);
g_string_free(s->rx, true); g_string_free(s->rx, true);
unlink(s->pid_file);
unlink(s->socket_path);
unlink(s->qmp_socket_path);
g_free(s->pid_file);
g_free(s->socket_path);
g_free(s->qmp_socket_path);
g_free(s); g_free(s);
} }