diff options
author | Peter Maydell <peter.maydell@linaro.org> | 2017-03-07 07:32:28 +0000 |
---|---|---|
committer | Peter Maydell <peter.maydell@linaro.org> | 2017-03-07 07:32:28 +0000 |
commit | 7dc3bc7a043a0492d5a7ff9a88322ba733830337 (patch) | |
tree | d597190411bf276d0127fdb1c64ba4d4241f87a9 /qga/main.c | |
parent | eba44e9339fc13c36e24c8c59e2b73ea231b46a1 (diff) | |
parent | ec72c0e271f2b13953079a4f4dadb49ac5910b54 (diff) | |
download | qemu-7dc3bc7a043a0492d5a7ff9a88322ba733830337.zip qemu-7dc3bc7a043a0492d5a7ff9a88322ba733830337.tar.gz qemu-7dc3bc7a043a0492d5a7ff9a88322ba733830337.tar.bz2 |
Merge remote-tracking branch 'remotes/mdroth/tags/qga-pull-2017-03-06-tag' into staging
qemu-ga patch queue for 2.9
* fix fsfreeze for filesystems mounted in multiple locations
* fix test failure when running in a chroot
* support for socket-based activation
# gpg: Signature made Mon 06 Mar 2017 07:54:17 GMT
# gpg: using RSA key 0x3353C9CEF108B584
# gpg: Good signature from "Michael Roth <flukshun@gmail.com>"
# gpg: aka "Michael Roth <mdroth@utexas.edu>"
# gpg: aka "Michael Roth <mdroth@linux.vnet.ibm.com>"
# Primary key fingerprint: CEAC C9E1 5534 EBAB B82D 3FA0 3353 C9CE F108 B584
* remotes/mdroth/tags/qga-pull-2017-03-06-tag:
tests: check path to avoid a failing qga/get-vcpus test
qga: ignore EBUSY when freezing a filesystem
qga: add systemd socket activation support
Signed-off-by: Peter Maydell <peter.maydell@linaro.org>
Diffstat (limited to 'qga/main.c')
-rw-r--r-- | qga/main.c | 74 |
1 files changed, 69 insertions, 5 deletions
@@ -28,6 +28,7 @@ #include "qga/channel.h" #include "qemu/bswap.h" #include "qemu/help_option.h" +#include "qemu/sockets.h" #ifdef _WIN32 #include "qga/service-win32.h" #include "qga/vss-win32.h" @@ -185,6 +186,37 @@ void reopen_fd_to_null(int fd) } #endif +/** + * get_listen_fd: + * @consume: true to prevent future calls from succeeding + * + * Fetch a listen file descriptor that was passed via systemd socket + * activation. Use @consume to prevent child processes from thinking a file + * descriptor was passed. + * + * Returns: file descriptor or -1 if no fd was passed + */ +static int get_listen_fd(bool consume) +{ +#ifdef _WIN32 + return -1; /* no fd passing expected, unsetenv(3) not available */ +#else + const char *listen_fds = getenv("LISTEN_FDS"); + int fd = STDERR_FILENO + 1; + + if (!listen_fds || strcmp(listen_fds, "1") != 0) { + return -1; + } + + if (consume) { + unsetenv("LISTEN_FDS"); + } + + qemu_set_cloexec(fd); + return fd; +#endif /* !_WIN32 */ +} + static void usage(const char *cmd) { printf( @@ -649,7 +681,8 @@ static gboolean channel_event_cb(GIOCondition condition, gpointer data) return true; } -static gboolean channel_init(GAState *s, const gchar *method, const gchar *path) +static gboolean channel_init(GAState *s, const gchar *method, const gchar *path, + int listen_fd) { GAChannelMethod channel_method; @@ -667,7 +700,8 @@ static gboolean channel_init(GAState *s, const gchar *method, const gchar *path) return false; } - s->channel = ga_channel_new(channel_method, path, channel_event_cb, s); + s->channel = ga_channel_new(channel_method, path, listen_fd, + channel_event_cb, s); if (!s->channel) { g_critical("failed to create guest agent channel"); return false; @@ -1026,7 +1060,9 @@ static void config_dump(GAConfig *config) g_key_file_set_boolean(keyfile, "general", "daemon", config->daemonize); g_key_file_set_string(keyfile, "general", "method", config->method); - g_key_file_set_string(keyfile, "general", "path", config->channel_path); + if (config->channel_path) { + g_key_file_set_string(keyfile, "general", "path", config->channel_path); + } if (config->log_filepath) { g_key_file_set_string(keyfile, "general", "logfile", config->log_filepath); @@ -1295,7 +1331,9 @@ static int run_agent(GAState *s, GAConfig *config) #endif s->main_loop = g_main_loop_new(NULL, false); - if (!channel_init(ga_state, config->method, config->channel_path)) { + + if (!channel_init(ga_state, config->method, config->channel_path, + get_listen_fd(true))) { g_critical("failed to initialize guest agent channel"); return EXIT_FAILURE; } @@ -1319,6 +1357,7 @@ int main(int argc, char **argv) int ret = EXIT_SUCCESS; GAState *s = g_new0(GAState, 1); GAConfig *config = g_new0(GAConfig, 1); + int listen_fd; config->log_level = G_LOG_LEVEL_ERROR | G_LOG_LEVEL_CRITICAL; @@ -1340,7 +1379,32 @@ int main(int argc, char **argv) config->method = g_strdup("virtio-serial"); } - if (config->channel_path == NULL) { + listen_fd = get_listen_fd(false); + if (listen_fd >= 0) { + SocketAddress *addr; + + g_free(config->method); + g_free(config->channel_path); + config->method = NULL; + config->channel_path = NULL; + + addr = socket_local_address(listen_fd, NULL); + if (addr) { + if (addr->type == SOCKET_ADDRESS_KIND_UNIX) { + config->method = g_strdup("unix-listen"); + } else if (addr->type == SOCKET_ADDRESS_KIND_VSOCK) { + config->method = g_strdup("vsock-listen"); + } + + qapi_free_SocketAddress(addr); + } + + if (!config->method) { + g_critical("unsupported listen fd type"); + ret = EXIT_FAILURE; + goto end; + } + } else if (config->channel_path == NULL) { if (strcmp(config->method, "virtio-serial") == 0) { /* try the default path for the virtio-serial port */ config->channel_path = g_strdup(QGA_VIRTIO_PATH_DEFAULT); |