10:21 a.m.
From: "Daniel P. Berrange" <berrange(a)redhat.com>
Start a QEMU process using
$QEMU -S -no-user-config -nodefconfig -nodefaults \
-nographic -M none -qmp stdio
and talk QMP over stdio to discover what capabilities the
binary supports. This works for QEMU 1.2.0 or later and
for older QEMU automatically fallback to the old approach
of parsing -help and related command line args.
Signed-off-by: Daniel P. Berrange <berrange(a)redhat.com>
---
src/qemu/qemu_capabilities.c | 413 +++++++++++++++++++++++++++++++++++++++----
src/qemu/qemu_capabilities.h | 2 +-
2 files changed, 377 insertions(+), 38 deletions(-)
diff --git a/src/qemu/qemu_capabilities.c b/src/qemu/qemu_capabilities.c
index 17fbd7a..b15b90e 100644
--- a/src/qemu/qemu_capabilities.c
+++ b/src/qemu/qemu_capabilities.c
@@ -35,6 +35,7 @@
#include "command.h"
#include "bitmap.h"
#include "virnodesuspend.h"
+#include "qemu_monitor.h"
#include <sys/stat.h>
#include <unistd.h>
@@ -182,6 +183,8 @@ VIR_ENUM_IMPL(qemuCaps, QEMU_CAPS_LAST,
struct _qemuCaps {
virObject object;
+ bool usedQMP;
+
char *binary;
time_t mtime;
@@ -1269,6 +1272,7 @@ static struct qemuCapsStringFlags qemuCapsObjectPropsVirtioNet[] =
{
};
static struct qemuCapsStringFlags qemuCapsObjectPropsPciAssign[] = {
+ { "rombar", QEMU_CAPS_PCI_ROMBAR },
{ "configfd", QEMU_CAPS_PCI_CONFIGFD },
{ "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};
@@ -1834,6 +1838,10 @@ qemuCapsProbeQMPCommands(qemuCapsPtr caps,
qemuCapsSet(caps, QEMU_CAPS_BLOCKJOB_ASYNC);
else if (STREQ(name, "dump-guest-memory"))
qemuCapsSet(caps, QEMU_CAPS_DUMP_GUEST_MEMORY);
+ else if (STREQ(name, "query-spice"))
+ qemuCapsSet(caps, QEMU_CAPS_SPICE);
+ else if (STREQ(name, "query-kvm"))
+ qemuCapsSet(caps, QEMU_CAPS_KVM);
VIR_FREE(name);
}
VIR_FREE(commands);
@@ -1866,11 +1874,117 @@ qemuCapsProbeQMPEvents(qemuCapsPtr caps,
}
+static int
+qemuCapsProbeQMPObjects(qemuCapsPtr caps,
+ qemuMonitorPtr mon)
+{
+ int nvalues;
+ char **values;
+ size_t i;
+
+ if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
+ return -1;
+ qemuCapsProcessStringFlags(caps,
+ ARRAY_CARDINALITY(qemuCapsObjectTypes),
+ qemuCapsObjectTypes,
+ nvalues, values);
+ qemuCapsFreeStringList(nvalues, values);
+
+ for (i = 0 ; i < ARRAY_CARDINALITY(qemuCapsObjectProps); i++) {
+ const char *type = qemuCapsObjectProps[i].type;
+ if ((nvalues = qemuMonitorGetObjectProps(mon,
+ type,
+ &values)) < 0)
+ return -1;
+ qemuCapsProcessStringFlags(caps,
+ qemuCapsObjectProps[i].nprops,
+ qemuCapsObjectProps[i].props,
+ nvalues, values);
+ qemuCapsFreeStringList(nvalues, values);
+ }
+
+ /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
+ if (qemuCapsGet(caps, QEMU_CAPS_CHARDEV_SPICEVMC))
+ qemuCapsClear(caps, QEMU_CAPS_DEVICE_SPICEVMC);
+
+ return 0;
+}
+
+
+static int
+qemuCapsProbeQMPMachineTypes(qemuCapsPtr caps,
+ qemuMonitorPtr mon)
+{
+ qemuMonitorMachineInfoPtr *machines = NULL;
+ int nmachines = 0;
+ int ret = -1;
+ size_t i;
+
+ if ((nmachines = qemuMonitorGetMachines(mon, &machines)) < 0)
+ goto cleanup;
+
+ if (VIR_ALLOC_N(caps->machineTypes, nmachines) < 0) {
+ virReportOOMError();
+ goto cleanup;
+ }
+ if (VIR_ALLOC_N(caps->machineAliases, nmachines) < 0) {
+ virReportOOMError();
+ goto cleanup;
+ }
+
+ for (i = 0 ; i < nmachines ; i++) {
+ if (machines[i]->alias) {
+ if (!(caps->machineAliases[i] = strdup(machines[i]->name))) {
+ virReportOOMError();
+ goto cleanup;
+ }
+ if (!(caps->machineTypes[i] = strdup(machines[i]->alias))) {
+ virReportOOMError();
+ goto cleanup;
+ }
+ } else {
+ if (!(caps->machineTypes[i] = strdup(machines[i]->name))) {
+ virReportOOMError();
+ goto cleanup;
+ }
+ }
+ }
+
+ ret = 0;
+
+cleanup:
+ for (i = 0 ; i < nmachines ; i++)
+ qemuMonitorMachineInfoFree(machines[i]);
+ VIR_FREE(machines);
+ return ret;
+}
+
+
+static int
+qemuCapsProbeQMPCPUDefinitions(qemuCapsPtr caps,
+ qemuMonitorPtr mon)
+{
+ int ncpuDefinitions;
+ char **cpuDefinitions;
+
+ if ((ncpuDefinitions = qemuMonitorGetCPUDefinitions(mon, &cpuDefinitions)) <
0)
+ return -1;
+
+ caps->ncpuDefinitions = ncpuDefinitions;
+ caps->cpuDefinitions = cpuDefinitions;
+
+ return 0;
+}
+
+
int qemuCapsProbeQMP(qemuCapsPtr caps,
qemuMonitorPtr mon)
{
VIR_DEBUG("caps=%p mon=%p", caps, mon);
+ if (caps->usedQMP)
+ return 0;
+
if (qemuCapsProbeQMPCommands(caps, mon) < 0)
return -1;
@@ -1883,20 +1997,19 @@ int qemuCapsProbeQMP(qemuCapsPtr caps,
#define QEMU_SYSTEM_PREFIX "qemu-system-"
-qemuCapsPtr qemuCapsNewForBinary(const char *binary)
+static int
+qemuCapsInitHelp(qemuCapsPtr caps)
{
- qemuCapsPtr caps = qemuCapsNew();
- const char *tmp;
- struct utsname ut;
+ virCommandPtr cmd = NULL;
unsigned int is_kvm;
char *help = NULL;
- virCommandPtr cmd = NULL;
- struct stat sb;
+ int ret = -1;
+ const char *tmp;
+ struct utsname ut;
- if (!(caps->binary = strdup(binary)))
- goto no_memory;
+ VIR_DEBUG("caps=%p", caps);
- tmp = strstr(binary, QEMU_SYSTEM_PREFIX);
+ tmp = strstr(caps->binary, QEMU_SYSTEM_PREFIX);
if (tmp) {
tmp += strlen(QEMU_SYSTEM_PREFIX);
@@ -1907,39 +2020,25 @@ qemuCapsPtr qemuCapsNewForBinary(const char *binary)
uname_normalize(&ut);
tmp = ut.machine;
}
- if (!(caps->arch = strdup(tmp)))
- goto no_memory;
-
- /* We would also want to check faccessat if we cared about ACLs,
- * but we don't. */
- if (stat(binary, &sb) < 0) {
- virReportSystemError(errno, _("Cannot check QEMU binary %s"),
- binary);
- goto error;
- }
- caps->mtime = sb.st_mtime;
-
- /* Make sure the binary we are about to try exec'ing exists.
- * Technically we could catch the exec() failure, but that's
- * in a sub-process so it's hard to feed back a useful error.
- */
- if (!virFileIsExecutable(binary)) {
- goto error;
+ if (!(caps->arch = strdup(tmp))) {
+ virReportOOMError();
+ goto cleanup;
}
- cmd = qemuCapsProbeCommand(binary, NULL);
+ cmd = qemuCapsProbeCommand(caps->binary, NULL);
virCommandAddArgList(cmd, "-help", NULL);
virCommandSetOutputBuffer(cmd, &help);
if (virCommandRun(cmd, NULL) < 0)
- goto error;
+ goto cleanup;
- if (qemuCapsParseHelpStr(binary, help, caps,
+ if (qemuCapsParseHelpStr(caps->binary,
+ help, caps,
&caps->version,
&is_kvm,
&caps->kvmVersion,
false) < 0)
- goto error;
+ goto cleanup;
/* Currently only x86_64 and i686 support PCI-multibus. */
if (STREQLEN(caps->arch, "x86_64", 6) ||
@@ -1956,18 +2055,252 @@ qemuCapsPtr qemuCapsNewForBinary(const char *binary)
* understands the 0.13.0+ notion of "-device driver,". */
if (qemuCapsGet(caps, QEMU_CAPS_DEVICE) &&
strstr(help, "-device driver,?") &&
- qemuCapsExtractDeviceStr(binary, caps) < 0)
- goto error;
+ qemuCapsExtractDeviceStr(caps->binary, caps) < 0)
+ goto cleanup;
if (qemuCapsProbeCPUModels(caps) < 0)
- goto error;
+ goto cleanup;
if (qemuCapsProbeMachineTypes(caps) < 0)
- goto error;
+ goto cleanup;
+
+ ret = 0;
+cleanup:
+ virCommandFree(cmd);
+ return ret;
+}
+
+
+
+static void qemuCapsMonitorEOFNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
+ virDomainObjPtr vm ATTRIBUTE_UNUSED)
+{
+}
+
+static void qemuCapsMonitorErrorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
+ virDomainObjPtr vm ATTRIBUTE_UNUSED)
+{
+}
+
+static qemuMonitorCallbacks callbacks = {
+ .eofNotify = qemuCapsMonitorEOFNotify,
+ .errorNotify = qemuCapsMonitorErrorNotify,
+};
+
+
+/* Capabilities that we assume are always enabled
+ * for QEMU >= 1.2.0
+ */
+static void
+qemuCapsInitQMPBasic(qemuCapsPtr caps)
+{
+ qemuCapsSet(caps, QEMU_CAPS_VNC_COLON);
+ qemuCapsSet(caps, QEMU_CAPS_NO_REBOOT);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE);
+ qemuCapsSet(caps, QEMU_CAPS_NAME);
+ qemuCapsSet(caps, QEMU_CAPS_UUID);
+ qemuCapsSet(caps, QEMU_CAPS_VNET_HDR);
+ qemuCapsSet(caps, QEMU_CAPS_MIGRATE_QEMU_TCP);
+ qemuCapsSet(caps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_CACHE_V2);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_FORMAT);
+ qemuCapsSet(caps, QEMU_CAPS_VGA);
+ qemuCapsSet(caps, QEMU_CAPS_0_10);
+ qemuCapsSet(caps, QEMU_CAPS_MEM_PATH);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_SERIAL);
+ qemuCapsSet(caps, QEMU_CAPS_MIGRATE_QEMU_UNIX);
+ qemuCapsSet(caps, QEMU_CAPS_CHARDEV);
+ qemuCapsSet(caps, QEMU_CAPS_ENABLE_KVM);
+ qemuCapsSet(caps, QEMU_CAPS_MONITOR_JSON);
+ qemuCapsSet(caps, QEMU_CAPS_BALLOON);
+ qemuCapsSet(caps, QEMU_CAPS_DEVICE);
+ qemuCapsSet(caps, QEMU_CAPS_SDL);
+ qemuCapsSet(caps, QEMU_CAPS_SMP_TOPOLOGY);
+ qemuCapsSet(caps, QEMU_CAPS_NETDEV);
+ qemuCapsSet(caps, QEMU_CAPS_RTC);
+ qemuCapsSet(caps, QEMU_CAPS_VHOST_NET);
+ qemuCapsSet(caps, QEMU_CAPS_NO_HPET);
+ qemuCapsSet(caps, QEMU_CAPS_NODEFCONFIG);
+ qemuCapsSet(caps, QEMU_CAPS_BOOT_MENU);
+ qemuCapsSet(caps, QEMU_CAPS_FSDEV);
+ qemuCapsSet(caps, QEMU_CAPS_NESTING);
+ qemuCapsSet(caps, QEMU_CAPS_NAME_PROCESS);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_READONLY);
+ qemuCapsSet(caps, QEMU_CAPS_SMBIOS_TYPE);
+ qemuCapsSet(caps, QEMU_CAPS_VGA_NONE);
+ qemuCapsSet(caps, QEMU_CAPS_MIGRATE_QEMU_FD);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_AIO);
+ qemuCapsSet(caps, QEMU_CAPS_CHARDEV_SPICEVMC);
+ qemuCapsSet(caps, QEMU_CAPS_DEVICE_QXL_VGA);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
+ qemuCapsSet(caps, QEMU_CAPS_NO_SHUTDOWN);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
+ qemuCapsSet(caps, QEMU_CAPS_NO_ACPI);
+ qemuCapsSet(caps, QEMU_CAPS_FSDEV_READONLY);
+ qemuCapsSet(caps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_COPY_ON_READ);
+ qemuCapsSet(caps, QEMU_CAPS_CPU_HOST);
+ qemuCapsSet(caps, QEMU_CAPS_FSDEV_WRITEOUT);
+ qemuCapsSet(caps, QEMU_CAPS_DRIVE_IOTUNE);
+ qemuCapsSet(caps, QEMU_CAPS_WAKEUP);
+ qemuCapsSet(caps, QEMU_CAPS_NO_USER_CONFIG);
+ qemuCapsSet(caps, QEMU_CAPS_NETDEV_BRIDGE);
+}
+
+/*
+ * Returns -1 on fatal error, 0 on success
+ */
+static int
+qemuCapsInitQMP(qemuCapsPtr caps)
+{
+ int ret = -1;
+ virCommandPtr cmd = NULL;
+ virDomainObjPtr vm = NULL;
+ int socks[2] = { -1, -1 };
+ qemuMonitorPtr mon = NULL;
+ int major, minor, micro;
+ char *package;
+
+ VIR_DEBUG("caps=%p", caps);
+
+ if (socketpair(PF_UNIX, SOCK_STREAM, 0, socks) < 0) {
+ virReportSystemError(errno, "%s",
+ _("unable to create socket pair"));
+ goto cleanup;
+ }
+
+ if (!(vm = virDomainObjNew(NULL)))
+ goto cleanup;
+
+ cmd = virCommandNewArgList(caps->binary,
+ "-S",
+ "-no-user-config",
+ "-nodefconfig",
+ "-nodefaults",
+ "-nographic",
+ "-M", "none",
+ "-qmp", "stdio",
+ NULL);
+ virCommandAddEnvPassCommon(cmd);
+ virCommandSetInputFD(cmd, socks[1]);
+ virCommandSetOutputFD(cmd, &socks[1]);
+ virCommandClearCaps(cmd);
+
+ if (virCommandRunAsync(cmd, NULL) < 0)
+ goto cleanup;
+
+ VIR_FORCE_CLOSE(socks[1]);
+
+ if (!(mon = qemuMonitorOpenFD(vm, socks[0], true, &callbacks)))
+ goto cleanup;
+ socks[0] = -1;
+
+ qemuMonitorLock(mon);
+ if (qemuMonitorSetCapabilities(mon) < 0) {
+ virErrorPtr err = virGetLastError();
+ VIR_DEBUG("Failed to set monitor capabilities %s",
+ err ? err->message : "<unknown problem>");
+ ret = 0;
+ goto cleanup;
+ }
+
+ if (qemuMonitorGetVersion(mon,
+ &major, &minor, µ,
+ &package) < 0) {
+ virErrorPtr err = virGetLastError();
+ VIR_DEBUG("Failed to query monitor version %s",
+ err ? err->message : "<unknown problem>");
+ ret = 0;
+ goto cleanup;
+ }
+
+ VIR_DEBUG("Got version %d.%d.%d (%s)",
+ major, minor, micro, NULLSTR(package));
+
+ if (!(major >= 1 && minor >= 1 && micro >= 90)) {
+ VIR_DEBUG("Not new enough for QMP capabilities detection");
+ ret = 0;
+ goto cleanup;
+ }
+
+ caps->usedQMP = true;
+
+ qemuCapsInitQMPBasic(caps);
+
+ if (!(caps->arch = qemuMonitorGetTargetArch(mon)))
+ goto cleanup;
+
+ /* Currently only x86_64 and i686 support PCI-multibus. */
+ if (STREQLEN(caps->arch, "x86_64", 6) ||
+ STREQLEN(caps->arch, "i686", 4)) {
+ qemuCapsSet(caps, QEMU_CAPS_PCI_MULTIBUS);
+ }
+
+ /* S390 and probably other archs do not support no-acpi -
+ maybe the qemu option parsing should be re-thought. */
+ if (STRPREFIX(caps->arch, "s390"))
+ qemuCapsClear(caps, QEMU_CAPS_NO_ACPI);
+
+ if (qemuCapsProbeQMPCommands(caps, mon) < 0)
+ goto cleanup;
+ if (qemuCapsProbeQMPEvents(caps, mon) < 0)
+ goto cleanup;
+ if (qemuCapsProbeQMPObjects(caps, mon) < 0)
+ goto cleanup;
+ if (qemuCapsProbeQMPMachineTypes(caps, mon) < 0)
+ goto cleanup;
+ if (qemuCapsProbeQMPCPUDefinitions(caps, mon) < 0)
+ goto cleanup;
+
+ ret = 0;
cleanup:
- VIR_FREE(help);
+ if (mon)
+ qemuMonitorUnlock(mon);
+ qemuMonitorClose(mon);
+ virCommandAbort(cmd);
+ VIR_FORCE_CLOSE(socks[0]);
+ virObjectUnref(vm);
virCommandFree(cmd);
+ return ret;
+}
+
+
+qemuCapsPtr qemuCapsNewForBinary(const char *binary)
+{
+ qemuCapsPtr caps = qemuCapsNew();
+ struct stat sb;
+ int rv;
+
+ if (!(caps->binary = strdup(binary)))
+ goto no_memory;
+
+ /* We would also want to check faccessat if we cared about ACLs,
+ * but we don't. */
+ if (stat(binary, &sb) < 0) {
+ virReportSystemError(errno, _("Cannot check QEMU binary %s"),
+ binary);
+ goto error;
+ }
+ caps->mtime = sb.st_mtime;
+
+ /* Make sure the binary we are about to try exec'ing exists.
+ * Technically we could catch the exec() failure, but that's
+ * in a sub-process so it's hard to feed back a useful error.
+ */
+ if (!virFileIsExecutable(binary)) {
+ virReportSystemError(errno, _("QEMU binary %s is not executable"),
+ binary);
+ goto error;
+ }
+
+ if ((rv = qemuCapsInitQMP(caps)) < 0)
+ goto error;
+
+ if (!caps->usedQMP &&
+ qemuCapsInitHelp(caps) < 0)
+ goto error;
+
return caps;
no_memory:
@@ -1975,7 +2308,7 @@ no_memory:
error:
virObjectUnref(caps);
caps = NULL;
- goto cleanup;
+ return NULL;
}
@@ -1993,6 +2326,12 @@ bool qemuCapsIsValid(qemuCapsPtr caps)
}
+bool qemuCapsUsedQMP(qemuCapsPtr caps)
+{
+ return caps->usedQMP;
+}
+
+
static void
qemuCapsHashDataFree(void *payload, const void *key ATTRIBUTE_UNUSED)
{
diff --git a/src/qemu/qemu_capabilities.h b/src/qemu/qemu_capabilities.h
index 4f1bf2b..7de8247 100644
--- a/src/qemu/qemu_capabilities.h
+++ b/src/qemu/qemu_capabilities.h
@@ -192,7 +192,7 @@ int qemuCapsGetMachineTypesCaps(qemuCapsPtr caps,
virCapsGuestMachinePtr **machines);
bool qemuCapsIsValid(qemuCapsPtr caps);
-
+bool qemuCapsUsedQMP(qemuCapsPtr caps);
qemuCapsCachePtr qemuCapsCacheNew(void);
qemuCapsPtr qemuCapsCacheLookup(qemuCapsCachePtr cache, const char *binary);
--
1.7.11.4