qemu_capabilities.c 175.0 KB
Newer Older
1 2 3
/*
 * qemu_capabilities.c: QEMU capabilities generation
 *
4
 * Copyright (C) 2006-2016 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17
 * Copyright (C) 2006 Daniel P. Berrange
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
18
 * License along with this library.  If not, see
O
Osier Yang 已提交
19
 * <http://www.gnu.org/licenses/>.
20 21 22 23 24 25 26
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>

#include "qemu_capabilities.h"
27
#include "viralloc.h"
28
#include "vircrypto.h"
29
#include "virlog.h"
30
#include "virerror.h"
E
Eric Blake 已提交
31
#include "virfile.h"
32 33
#include "virpidfile.h"
#include "virprocess.h"
34
#include "cpu/cpu.h"
35
#include "cpu/cpu_x86.h"
36
#include "domain_conf.h"
37
#include "vircommand.h"
38
#include "virbitmap.h"
39
#include "virnodesuspend.h"
40
#include "virnuma.h"
41
#include "virhostcpu.h"
42
#include "qemu_monitor.h"
43
#include "virstring.h"
44
#include "qemu_hostdev.h"
45
#include "qemu_domain.h"
46
#define __QEMU_CAPSPRIV_H_ALLOW__
47
#include "qemu_capspriv.h"
48

49
#include <fcntl.h>
50 51 52
#include <sys/stat.h>
#include <unistd.h>
#include <sys/wait.h>
53
#include <stdarg.h>
54 55 56

#define VIR_FROM_THIS VIR_FROM_QEMU

57 58
VIR_LOG_INIT("qemu.qemu_capabilities");

59 60 61 62
/* While not public, these strings must not change. They
 * are used in domain status files which are read on
 * daemon restarts
 */
63
VIR_ENUM_IMPL(virQEMUCaps, QEMU_CAPS_LAST,
64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100
              "kqemu",  /* 0 */
              "vnc-colon",
              "no-reboot",
              "drive",
              "drive-boot",

              "name", /* 5 */
              "uuid",
              "domid",
              "vnet-hdr",
              "migrate-kvm-stdio",

              "migrate-qemu-tcp", /* 10 */
              "migrate-qemu-exec",
              "drive-cache-v2",
              "kvm",
              "drive-format",

              "vga", /* 15 */
              "0.10",
              "pci-device",
              "mem-path",
              "drive-serial",

              "xen-domid", /* 20 */
              "migrate-qemu-unix",
              "chardev",
              "enable-kvm",
              "monitor-json",

              "balloon", /* 25 */
              "device",
              "sdl",
              "smp-topology",
              "netdev",

              "rtc", /* 30 */
101
              "vhost-net",
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134
              "rtc-td-hack",
              "no-hpet",
              "no-kvm-pit",

              "tdf", /* 35 */
              "pci-configfd",
              "nodefconfig",
              "boot-menu",
              "enable-kqemu",

              "fsdev", /* 40 */
              "nesting",
              "name-process",
              "drive-readonly",
              "smbios-type",

              "vga-qxl", /* 45 */
              "spice",
              "vga-none",
              "migrate-qemu-fd",
              "boot-index",

              "hda-duplex", /* 50 */
              "drive-aio",
              "pci-multibus",
              "pci-bootindex",
              "ccid-emulated",

              "ccid-passthru", /* 55 */
              "chardev-spicevmc",
              "device-spicevmc",
              "virtio-tx-alg",
              "device-qxl-vga",
135 136

              "pci-multifunction", /* 60 */
137
              "virtio-blk-pci.ioeventfd",
M
Michal Privoznik 已提交
138
              "sga",
139 140
              "virtio-blk-pci.event_idx",
              "virtio-net-pci.event_idx",
141 142 143 144 145 146 147 148 149 150

              "cache-directsync", /* 65 */
              "piix3-usb-uhci",
              "piix4-usb-uhci",
              "usb-ehci",
              "ich9-usb-ehci1",

              "vt82c686b-usb-uhci", /* 70 */
              "pci-ohci",
              "usb-redir",
M
Marc-André Lureau 已提交
151
              "usb-hub",
152
              "no-shutdown",
153 154

              "cache-unsafe", /* 75 */
155
              "rombar",
J
Jim Fehlig 已提交
156
              "ich9-ahci",
157
              "no-acpi",
158
              "fsdev-readonly",
159

160
              "virtio-blk-pci.scsi", /* 80 */
161
              "blk-sg-io",
O
Osier Yang 已提交
162
              "drive-copy-on-read",
163
              "cpu-host",
164
              "fsdev-writeout",
165 166

              "drive-iotune", /* 85 */
167
              "system_wakeup",
168
              "scsi-disk.channel",
169
              "scsi-block",
170
              "transaction",
171 172 173

              "block-job-sync", /* 90 */
              "block-job-async",
174
              "scsi-cd",
175
              "ide-cd",
176
              "no-user-config",
M
Marc-André Lureau 已提交
177 178

              "hda-micro", /* 95 */
179
              "dump-guest-memory",
G
Gerd Hoffmann 已提交
180
              "nec-usb-xhci",
181
              "virtio-s390",
182
              "balloon-event",
M
Marc-André Lureau 已提交
183

R
Richa Marwaha 已提交
184
              "bridge", /* 100 */
185 186
              "lsi",
              "virtio-scsi-pci",
V
Viktor Mihajlovski 已提交
187
              "blockio",
188
              "disable-s3",
R
Richa Marwaha 已提交
189

190
              "disable-s4", /* 105 */
191
              "usb-redir.filter",
192 193
              "ide-drive.wwn",
              "scsi-disk.wwn",
194
              "seccomp-sandbox",
195 196

              "reboot-timeout", /* 110 */
197
              "dump-guest-core",
198
              "seamless-migration",
199
              "block-commit",
200
              "vnc",
201 202

              "drive-mirror", /* 115 */
203 204
              "usb-redir.bootindex",
              "usb-host.bootindex",
205
              "blockdev-snapshot-sync",
206 207 208 209 210 211
              "qxl",

              "VGA", /* 120 */
              "cirrus-vga",
              "vmware-svga",
              "device-video-primary",
212
              "s390-sclp",
213 214

              "usb-serial", /* 125 */
G
Guannan Ren 已提交
215
              "usb-net",
216
              "add-fd",
217
              "nbd-server",
218 219 220
              "virtio-rng",

              "rng-random", /* 130 */
221
              "rng-egd",
O
Olivia Yin 已提交
222 223
              "virtio-ccw",
              "dtb",
224
              "megasas",
J
Ján Tomko 已提交
225 226

              "ipv6-migration", /* 135 */
227
              "machine-opt",
L
Li Zhang 已提交
228
              "machine-usb-opt",
S
Stefan Berger 已提交
229 230
              "tpm-passthrough",
              "tpm-tis",
231 232

              "nvram",  /* 140 */
H
Han Cheng 已提交
233 234 235 236 237 238
              "pci-bridge",
              "vfio-pci",
              "vfio-pci.bootindex",
              "scsi-generic",

              "scsi-generic.bootindex", /* 145 */
239
              "mem-merge",
240
              "vnc-websocket",
O
Osier Yang 已提交
241
              "drive-discard",
242
              "mlock",
243 244

              "vnc-share-policy", /* 150 */
245
              "device-del-event",
246
              "dmi-to-pci-bridge",
247 248
              "i440fx-pci-hole64-size",
              "q35-pci-hole64-size",
249 250

              "usb-storage", /* 155 */
251
              "usb-storage.removable",
252
              "virtio-mmio",
253
              "ich9-intel-hda",
254
              "kvm-pit-lost-tick-policy",
255 256

              "boot-strict", /* 160 */
257 258
              "pvpanic",
              "enable-fips",
259 260
              "spice-file-xfer-disable",
              "spiceport",
L
Li Zhang 已提交
261 262

              "usb-kbd", /* 165 */
263
              "host-pci-multidomain",
264
              "msg-timestamp",
265
              "active-commit",
266
              "change-backing-file",
267 268

              "memory-backend-ram", /* 170 */
269
              "numa",
270
              "memory-backend-file",
271
              "usb-audio",
272
              "rtc-reset-reinjection",
273 274

              "splash-timeout", /* 175 */
J
John Ferlan 已提交
275
              "iothread",
276
              "migrate-rdma",
277
              "ivshmem",
278
              "drive-iotune-max",
279 280 281 282 283

              "VGA.vgamem_mb", /* 180 */
              "vmware-svga.vgamem_mb",
              "qxl.vgamem_mb",
              "qxl-vga.vgamem_mb",
284
              "pc-dimm",
285 286

              "machine-vmport-opt", /* 185 */
287 288
              "aes-key-wrap",
              "dea-key-wrap",
M
Michal Privoznik 已提交
289
              "pci-serial",
290
              "aarch64-off",
291

J
Ján Tomko 已提交
292
              "vhost-user-multiqueue", /* 190 */
293
              "migration-event",
294
              "gpex-pcihost",
295
              "ioh3420",
296
              "x3130-upstream",
297 298 299

              "xio3130-downstream", /* 195 */
              "rtl8139",
300
              "e1000",
301
              "virtio-net",
302
              "gic-version",
303 304

              "incoming-defer", /* 200 */
M
Marc-André Lureau 已提交
305
              "virtio-gpu",
306
              "virtio-gpu.virgl",
307 308 309 310
              "virtio-keyboard",
              "virtio-mouse",

              "virtio-tablet", /* 205 */
311
              "virtio-input-host",
312
              "chardev-file-append",
313 314
              "ich9-disable-s3",
              "ich9-disable-s4",
315 316

              "vserport-change-event", /* 210 */
317
              "virtio-balloon-pci.deflate-on-oom",
318
              "mptsas1068",
319
              "spice-gl",
320 321 322
              "qxl.vram64_size_mb",

              "qxl-vga.vram64_size_mb", /* 215 */
323
              "chardev-logfile",
324
              "debug-threads",
325
              "secret",
326
              "pxb",
327 328

              "pxb-pcie", /* 220 */
329
              "device-tray-moved-event",
330
              "nec-usb-xhci-ports",
331
              "virtio-scsi-pci.iothread",
332
              "name-guest",
333 334 335

              "qxl.max_outputs", /* 225 */
              "qxl-vga.max_outputs",
336
              "spice-unix",
337
              "drive-detect-zeroes",
B
Boris Fiuczynski 已提交
338
              "tls-creds-x509",
339

B
Boris Fiuczynski 已提交
340
              "display", /* 230 */
J
Ján Tomko 已提交
341
              "intel-iommu",
M
Michal Privoznik 已提交
342
              "smm",
343
              "virtio-pci-disable-legacy",
344
              "query-hotpluggable-cpus",
345 346

              "virtio-net.rx_queue_size", /* 235 */
347
              "machine-iommu",
348
              "virtio-vga",
349
              "drive-iotune-max-length",
350 351 352
              "ivshmem-plain",

              "ivshmem-doorbell", /* 240 */
353
              "query-qmp-schema",
354
              "gluster.debug_level",
355
              "vhost-scsi",
356
              "drive-iotune-group",
357 358

              "query-cpu-model-expansion", /* 245 */
359
              "virtio-net.host_mtu",
360
              "spice-rendernode",
361
              "nvdimm",
362
              "pcie-root-port",
363 364

              "query-cpu-definitions", /* 250 */
365
              "block-write-threshold",
366
              "query-named-block-nodes",
367 368
    );

369

370 371 372 373
struct virQEMUCapsMachineType {
    char *name;
    char *alias;
    unsigned int maxCpus;
374
    bool hotplugCpus;
375
};
376 377 378 379 380 381 382 383 384 385 386

typedef struct _virQEMUCapsHostCPUData virQEMUCapsHostCPUData;
typedef virQEMUCapsHostCPUData *virQEMUCapsHostCPUDataPtr;
struct _virQEMUCapsHostCPUData {
    /* Only the "info" part is stored in the capabilities cache, the rest is
     * re-computed from other fields and external data sources everytime we
     * probe QEMU or load the cache.
     */
    qemuMonitorCPUModelInfoPtr info;
    /* Host CPU definition reported in domain capabilities. */
    virCPUDefPtr reported;
387 388
    /* Migratable host CPU definition used for updating guest CPU. */
    virCPUDefPtr migratable;
389 390 391 392
    /* CPU definition with features detected by libvirt using virCPUGetHost
     * combined with features reported by QEMU. This is used for backward
     * compatible comparison between a guest CPU and a host CPU. */
    virCPUDefPtr full;
393 394
};

395 396 397 398 399 400
/*
 * Update the XML parser/formatter when adding more
 * information to this struct so that it gets cached
 * correctly. It does not have to be ABI-stable, as
 * the cache will be discarded & repopulated if the
 * timestamp on the libvirtd binary changes.
401 402
 *
 * And don't forget to update virQEMUCapsNewCopy.
403
 */
404
struct _virQEMUCaps {
405 406
    virObject object;

407 408
    bool usedQMP;

409
    char *binary;
410
    time_t ctime;
411

412
    virBitmapPtr flags;
413 414 415

    unsigned int version;
    unsigned int kvmVersion;
416
    char *package;
417

418
    virArch arch;
419

420 421
    virDomainCapsCPUModelsPtr kvmCPUModels;
    virDomainCapsCPUModelsPtr tcgCPUModels;
422 423

    size_t nmachineTypes;
424
    struct virQEMUCapsMachineType *machineTypes;
A
Andrea Bolognani 已提交
425 426 427

    size_t ngicCapabilities;
    virGICCapability *gicCapabilities;
428

429 430
    virQEMUCapsHostCPUData kvmCPU;
    virQEMUCapsHostCPUData tcgCPU;
431 432
};

433 434 435 436
struct virQEMUCapsSearchData {
    virArch arch;
};

437

438 439
static virClassPtr virQEMUCapsClass;
static void virQEMUCapsDispose(void *obj);
440

441
static int virQEMUCapsOnceInit(void)
442
{
443 444 445 446
    if (!(virQEMUCapsClass = virClassNew(virClassForObject(),
                                         "virQEMUCaps",
                                         sizeof(virQEMUCaps),
                                         virQEMUCapsDispose)))
447 448 449 450 451
        return -1;

    return 0;
}

452
VIR_ONCE_GLOBAL_INIT(virQEMUCaps)
453

454
static virArch virQEMUCapsArchFromString(const char *arch)
455 456 457 458 459
{
    if (STREQ(arch, "i386"))
        return VIR_ARCH_I686;
    if (STREQ(arch, "arm"))
        return VIR_ARCH_ARMV7L;
460 461
    if (STREQ(arch, "or32"))
        return VIR_ARCH_OR32;
462 463 464 465 466

    return virArchFromString(arch);
}


467
static const char *virQEMUCapsArchToString(virArch arch)
468 469 470 471 472
{
    if (arch == VIR_ARCH_I686)
        return "i386";
    else if (arch == VIR_ARCH_ARMV7L)
        return "arm";
473 474
    else if (arch == VIR_ARCH_OR32)
        return "or32";
475 476 477 478

    return virArchToString(arch);
}

479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501

/* Checks whether a domain with @guest arch can run natively on @host.
 */
static bool
virQEMUCapsGuestIsNative(virArch host,
                         virArch guest)
{
    if (host == guest)
        return true;

    if (host == VIR_ARCH_X86_64 && guest == VIR_ARCH_I686)
        return true;

    if (host == VIR_ARCH_AARCH64 && guest == VIR_ARCH_ARMV7L)
        return true;

    if (ARCH_IS_PPC64(host) && ARCH_IS_PPC64(guest))
        return true;

    return false;
}


502 503 504 505 506 507 508 509 510
/* Given a host and guest architectures, find a suitable QEMU target.
 *
 * This is meant to be used as a second attempt if qemu-system-$guestarch
 * can't be found, eg. on a x86_64 host you want to use qemu-system-i386,
 * if available, instead of qemu-system-x86_64 to run i686 guests */
static virArch
virQEMUCapsFindTarget(virArch hostarch,
                      virArch guestarch)
{
511 512 513
    if (virQEMUCapsGuestIsNative(hostarch, guestarch))
        guestarch = hostarch;

514 515 516 517 518 519
    /* Both ppc64 and ppc64le guests can use the ppc64 target */
    if (ARCH_IS_PPC64(guestarch))
        guestarch = VIR_ARCH_PPC64;

    return guestarch;
}
520

521
static virCommandPtr
522 523
virQEMUCapsProbeCommand(const char *qemu,
                        virQEMUCapsPtr qemuCaps,
524
                        uid_t runUid, gid_t runGid)
525 526 527
{
    virCommandPtr cmd = virCommandNew(qemu);

528 529
    if (qemuCaps) {
        if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG))
530
            virCommandAddArg(cmd, "-no-user-config");
531
        else if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NODEFCONFIG))
532 533 534 535 536
            virCommandAddArg(cmd, "-nodefconfig");
    }

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
537 538
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
539 540 541 542 543

    return cmd;
}


544
static void
545 546
virQEMUCapsSetDefaultMachine(virQEMUCapsPtr qemuCaps,
                             size_t defIdx)
547
{
548
    struct virQEMUCapsMachineType tmp = qemuCaps->machineTypes[defIdx];
549 550 551 552

    memmove(qemuCaps->machineTypes + 1,
            qemuCaps->machineTypes,
            sizeof(qemuCaps->machineTypes[0]) * defIdx);
553 554

    qemuCaps->machineTypes[0] = tmp;
555 556
}

557 558 559 560
/* Format is:
 * <machine> <desc> [(default)|(alias of <canonical>)]
 */
static int
561 562
virQEMUCapsParseMachineTypesStr(const char *output,
                                virQEMUCapsPtr qemuCaps)
563 564 565
{
    const char *p = output;
    const char *next;
566
    size_t defIdx = 0;
567 568 569

    do {
        const char *t;
570 571
        char *name;
        char *canonical = NULL;
572 573 574 575 576 577 578 579 580 581

        if ((next = strchr(p, '\n')))
            ++next;

        if (STRPREFIX(p, "Supported machines are:"))
            continue;

        if (!(t = strchr(p, ' ')) || (next && t >= next))
            continue;

582 583
        if (VIR_STRNDUP(name, p, t - p) < 0)
            return -1;
584 585

        p = t;
586
        if ((t = strstr(p, "(default)")) && (!next || t < next))
587
            defIdx = qemuCaps->nmachineTypes;
588 589 590

        if ((t = strstr(p, "(alias of ")) && (!next || t < next)) {
            p = t + strlen("(alias of ");
591 592
            if (!(t = strchr(p, ')')) || (next && t >= next)) {
                VIR_FREE(name);
593
                continue;
594
            }
595

596
            if (VIR_STRNDUP(canonical, p, t - p) < 0) {
597
                VIR_FREE(name);
598
                return -1;
599 600 601
            }
        }

602
        if (VIR_REALLOC_N(qemuCaps->machineTypes, qemuCaps->nmachineTypes + 1) < 0) {
603 604
            VIR_FREE(name);
            VIR_FREE(canonical);
605
            return -1;
606
        }
607
        qemuCaps->nmachineTypes++;
608
        if (canonical) {
609 610
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].name = canonical;
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].alias = name;
611
        } else {
612 613
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].name = name;
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].alias = NULL;
614
        }
615
        /* When parsing from command line we don't have information about maxCpus */
616
        qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].maxCpus = 0;
617
        qemuCaps->machineTypes[qemuCaps->nmachineTypes-1].hotplugCpus = false;
618 619
    } while ((p = next));

620

621
    if (defIdx)
622
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
623 624 625 626

    return 0;
}

627
static int
628 629
virQEMUCapsProbeMachineTypes(virQEMUCapsPtr qemuCaps,
                             uid_t runUid, gid_t runGid)
630 631
{
    char *output;
632 633
    int ret = -1;
    virCommandPtr cmd;
634
    int status;
635

636 637 638 639
    /* 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.
     */
640
    if (!virFileIsExecutable(qemuCaps->binary)) {
641
        virReportSystemError(errno, _("Cannot find QEMU binary %s"),
642
                             qemuCaps->binary);
643 644 645
        return -1;
    }

646
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
647
    virCommandAddArgList(cmd, "-M", "?", NULL);
648
    virCommandSetOutputBuffer(cmd, &output);
649

650 651
    /* Ignore failure from older qemu that did not understand '-M ?'.  */
    if (virCommandRun(cmd, &status) < 0)
652 653
        goto cleanup;

654
    if (virQEMUCapsParseMachineTypesStr(output, qemuCaps) < 0)
655
        goto cleanup;
656 657 658

    ret = 0;

659
 cleanup:
660 661
    VIR_FREE(output);
    virCommandFree(cmd);
662 663 664 665 666 667

    return ret;
}


typedef int
668 669
(*virQEMUCapsParseCPUModels)(const char *output,
                             virQEMUCapsPtr qemuCaps);
670 671 672 673 674 675 676

/* Format:
 *      <arch> <model>
 * qemu-0.13 encloses some model names in []:
 *      <arch> [<model>]
 */
static int
677 678
virQEMUCapsParseX86Models(const char *output,
                          virQEMUCapsPtr qemuCaps)
679 680 681
{
    const char *p = output;
    const char *next;
682 683 684 685
    virDomainCapsCPUModelsPtr cpus;

    if (!(cpus = virDomainCapsCPUModelsNew(0)))
        return -1;
686 687 688

    do {
        const char *t;
689
        size_t len;
690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706

        if ((next = strchr(p, '\n')))
            next++;

        if (!(t = strchr(p, ' ')) || (next && t >= next))
            continue;

        if (!STRPREFIX(p, "x86"))
            continue;

        p = t;
        while (*p == ' ')
            p++;

        if (*p == '\0' || *p == '\n')
            continue;

707 708 709 710
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
711

712 713 714 715
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
716

J
Jiri Denemark 已提交
717 718
        if (virDomainCapsCPUModelsAdd(cpus, p, len,
                                      VIR_DOMCAPS_CPU_USABLE_UNKNOWN) < 0)
719
            goto error;
720 721
    } while ((p = next));

722 723 724 725 726 727 728 729 730 731
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM)) {
        virDomainCapsCPUModelsPtr kvmCPUs;

        if (!(kvmCPUs = virDomainCapsCPUModelsCopy(cpus)))
            goto error;

        qemuCaps->kvmCPUModels = kvmCPUs;
    }
    qemuCaps->tcgCPUModels = cpus;

732
    return 0;
733

734 735 736
 error:
    virObjectUnref(cpus);
    return -1;
737 738
}

P
Prerna Saxena 已提交
739 740 741 742
/* ppc64 parser.
 * Format : PowerPC <machine> <description>
 */
static int
743 744
virQEMUCapsParsePPCModels(const char *output,
                          virQEMUCapsPtr qemuCaps)
P
Prerna Saxena 已提交
745 746 747
{
    const char *p = output;
    const char *next;
748 749 750 751
    virDomainCapsCPUModelsPtr cpus;

    if (!(cpus = virDomainCapsCPUModelsNew(0)))
        return -1;
P
Prerna Saxena 已提交
752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774

    do {
        const char *t;

        if ((next = strchr(p, '\n')))
            next++;

        if (!STRPREFIX(p, "PowerPC "))
            continue;

        /* Skip the preceding sub-string "PowerPC " */
        p += 8;

        /*Malformed string, does not obey the format 'PowerPC <model> <desc>'*/
        if (!(t = strchr(p, ' ')) || (next && t >= next))
            continue;

        if (*p == '\0')
            break;

        if (*p == '\n')
            continue;

J
Jiri Denemark 已提交
775 776
        if (virDomainCapsCPUModelsAdd(cpus, p, t - p - 1,
                                      VIR_DOMCAPS_CPU_USABLE_UNKNOWN) < 0)
777
            goto error;
P
Prerna Saxena 已提交
778 779
    } while ((p = next));

780 781 782 783 784 785 786 787 788 789
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM)) {
        virDomainCapsCPUModelsPtr kvmCPUs;

        if (!(kvmCPUs = virDomainCapsCPUModelsCopy(cpus)))
            goto error;

        qemuCaps->kvmCPUModels = kvmCPUs;
    }
    qemuCaps->tcgCPUModels = cpus;

790
    return 0;
P
Prerna Saxena 已提交
791

792 793 794
 error:
    virObjectUnref(cpus);
    return -1;
P
Prerna Saxena 已提交
795
}
796

797
static int
798
virQEMUCapsProbeCPUModels(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid)
799 800 801
{
    char *output = NULL;
    int ret = -1;
802
    virQEMUCapsParseCPUModels parse;
803
    virCommandPtr cmd;
804

A
Andrea Bolognani 已提交
805
    if (ARCH_IS_X86(qemuCaps->arch)) {
806
        parse = virQEMUCapsParseX86Models;
A
Andrea Bolognani 已提交
807
    } else if (ARCH_IS_PPC64(qemuCaps->arch)) {
808
        parse = virQEMUCapsParsePPCModels;
809
    } else {
810
        VIR_DEBUG("don't know how to parse %s CPU models",
811
                  virArchToString(qemuCaps->arch));
812 813 814
        return 0;
    }

815
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
816
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
817
    virCommandSetOutputBuffer(cmd, &output);
818

819
    if (virCommandRun(cmd, NULL) < 0)
820 821
        goto cleanup;

822
    if (parse(output, qemuCaps) < 0)
823 824 825 826
        goto cleanup;

    ret = 0;

827
 cleanup:
828
    VIR_FREE(output);
829
    virCommandFree(cmd);
830 831 832 833

    return ret;
}

834
static char *
835 836
virQEMUCapsFindBinary(const char *format,
                      const char *archstr)
837
{
838 839
    char *ret = NULL;
    char *binary = NULL;
840

841 842
    if (virAsprintf(&binary, format, archstr) < 0)
        goto out;
843 844 845

    ret = virFindFileInPath(binary);
    VIR_FREE(binary);
846 847
    if (ret && virFileIsExecutable(ret))
        goto out;
848

849
    VIR_FREE(ret);
850

851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873
 out:
    return ret;
}

static char *
virQEMUCapsFindBinaryForArch(virArch hostarch,
                             virArch guestarch)
{
    char *ret = NULL;
    const char *archstr;
    virArch target;

    /* First attempt: try the guest architecture as it is */
    archstr = virQEMUCapsArchToString(guestarch);
    if ((ret = virQEMUCapsFindBinary("qemu-system-%s", archstr)) != NULL)
        goto out;

    /* Second attempt: try looking up by target instead */
    target = virQEMUCapsFindTarget(hostarch, guestarch);
    if (target != guestarch) {
        archstr = virQEMUCapsArchToString(target);
        if ((ret = virQEMUCapsFindBinary("qemu-system-%s", archstr)) != NULL)
            goto out;
874
    }
875

876 877 878 879
    /* Third attempt, i686 only: try 'qemu' */
    if (guestarch == VIR_ARCH_I686) {
        if ((ret = virQEMUCapsFindBinary("%s", "qemu")) != NULL)
            goto out;
880
    }
881

882
 out:
883 884 885
    return ret;
}

886
static int
887 888 889 890
virQEMUCapsInitGuest(virCapsPtr caps,
                     virQEMUCapsCachePtr cache,
                     virArch hostarch,
                     virArch guestarch)
891
{
892
    size_t i;
893 894
    char *kvmbin = NULL;
    char *binary = NULL;
895 896
    virQEMUCapsPtr qemubinCaps = NULL;
    virQEMUCapsPtr kvmbinCaps = NULL;
897 898
    int ret = -1;

J
Ján Tomko 已提交
899
    /* Check for existence of base emulator, or alternate base
900 901
     * which can be used with magic cpu choice
     */
902
    binary = virQEMUCapsFindBinaryForArch(hostarch, guestarch);
903

904
    /* Ignore binary if extracting version info fails */
905
    if (binary) {
906
        if (!(qemubinCaps = virQEMUCapsCacheLookup(caps, cache, binary))) {
907 908 909 910
            virResetLastError();
            VIR_FREE(binary);
        }
    }
911 912

    /* qemu-kvm/kvm binaries can only be used if
913
     *  - host & guest arches match
914 915
     *  - hostarch is x86_64 and guest arch is i686 (needs -cpu qemu32)
     *  - hostarch is aarch64 and guest arch is armv7l (needs -cpu aarch64=off)
916
     *  - hostarch and guestarch are both ppc64*
917
     */
918
    if (virQEMUCapsGuestIsNative(hostarch, guestarch)) {
919 920 921 922 923 924 925 926 927 928 929 930 931 932 933
        const char *kvmbins[] = {
            "/usr/libexec/qemu-kvm", /* RHEL */
            "qemu-kvm", /* Fedora */
            "kvm", /* Debian/Ubuntu */
            NULL,
        };

        /* x86 32-on-64 can be used with qemu-system-i386 and
         * qemu-system-x86_64, so if we don't find a specific kvm binary,
         * we can just fall back to the host arch native binary and
         * everything works fine.
         *
         * arm is different in that 32-on-64 _only_ works with
         * qemu-system-aarch64. So we have to add it to the kvmbins list
         */
934
        if (hostarch == VIR_ARCH_AARCH64 && guestarch == VIR_ARCH_ARMV7L)
935
            kvmbins[3] = "qemu-system-aarch64";
936

937
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
938 939 940
            if (!kvmbins[i])
                continue;

941
            kvmbin = virFindFileInPath(kvmbins[i]);
942

943 944
            if (!kvmbin)
                continue;
945

946
            if (!(kvmbinCaps = virQEMUCapsCacheLookup(caps, cache, kvmbin))) {
947
                virResetLastError();
948 949 950
                VIR_FREE(kvmbin);
                continue;
            }
951

952 953
            if (!binary) {
                binary = kvmbin;
954
                qemubinCaps = kvmbinCaps;
955
                kvmbin = NULL;
956
                kvmbinCaps = NULL;
957
            }
958
            break;
959 960 961
        }
    }

962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989
    ret = virQEMUCapsInitGuestFromBinary(caps,
                                         binary, qemubinCaps,
                                         kvmbin, kvmbinCaps,
                                         guestarch);

    VIR_FREE(binary);
    VIR_FREE(kvmbin);
    virObjectUnref(qemubinCaps);
    virObjectUnref(kvmbinCaps);

    return ret;
}

int
virQEMUCapsInitGuestFromBinary(virCapsPtr caps,
                               const char *binary,
                               virQEMUCapsPtr qemubinCaps,
                               const char *kvmbin,
                               virQEMUCapsPtr kvmbinCaps,
                               virArch guestarch)
{
    virCapsGuestPtr guest;
    bool haskvm = false;
    virCapsGuestMachinePtr *machines = NULL;
    size_t nmachines = 0;
    int ret = -1;
    bool hasdisksnapshot = false;

990 991 992
    if (!binary)
        return 0;

993
    if (virFileExists("/dev/kvm") &&
994 995
        (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         virQEMUCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
996
         kvmbin))
997
        haskvm = true;
998

999
    if (virQEMUCapsGetMachineTypesCaps(qemubinCaps, &nmachines, &machines) < 0)
1000
        goto cleanup;
1001 1002 1003 1004

    /* We register kvm as the base emulator too, since we can
     * just give -no-kvm to disable acceleration if required */
    if ((guest = virCapabilitiesAddGuest(caps,
1005
                                         VIR_DOMAIN_OSTYPE_HVM,
1006
                                         guestarch,
1007 1008 1009 1010
                                         binary,
                                         NULL,
                                         nmachines,
                                         machines)) == NULL)
1011
        goto cleanup;
1012 1013 1014 1015

    machines = NULL;
    nmachines = 0;

A
Andrea Bolognani 已提交
1016 1017 1018
    /* CPU selection is always available, because all QEMU versions
     * we support can use at least '-cpu host' */
    if (!virCapabilitiesAddGuestFeature(guest, "cpuselection", true, false))
1019
        goto cleanup;
1020

1021
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_BOOTINDEX) &&
1022
        !virCapabilitiesAddGuestFeature(guest, "deviceboot", true, false))
1023
        goto cleanup;
1024

1025 1026 1027
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_DISK_SNAPSHOT))
        hasdisksnapshot = true;

1028 1029
    if (!virCapabilitiesAddGuestFeature(guest, "disksnapshot", hasdisksnapshot,
                                        false))
1030
        goto cleanup;
1031

D
Daniel P. Berrange 已提交
1032
    if (virCapabilitiesAddGuestDomain(guest,
1033
                                      VIR_DOMAIN_VIRT_QEMU,
D
Daniel P. Berrange 已提交
1034 1035 1036 1037
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
1038
        goto cleanup;
1039

D
Daniel P. Berrange 已提交
1040 1041
    if (haskvm) {
        virCapsGuestDomainPtr dom;
1042

D
Daniel P. Berrange 已提交
1043
        if (kvmbin &&
1044
            virQEMUCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
1045
            goto cleanup;
1046

D
Daniel P. Berrange 已提交
1047
        if ((dom = virCapabilitiesAddGuestDomain(guest,
1048
                                                 VIR_DOMAIN_VIRT_KVM,
D
Daniel P. Berrange 已提交
1049 1050 1051 1052
                                                 kvmbin ? kvmbin : binary,
                                                 NULL,
                                                 nmachines,
                                                 machines)) == NULL) {
1053
            goto cleanup;
D
Daniel P. Berrange 已提交
1054
        }
1055

D
Daniel P. Berrange 已提交
1056 1057
        machines = NULL;
        nmachines = 0;
1058
    }
1059

1060 1061 1062
    if ((ARCH_IS_X86(guestarch) || guestarch == VIR_ARCH_AARCH64) &&
        virCapabilitiesAddGuestFeature(guest, "acpi", true, true) == NULL) {
        goto cleanup;
1063 1064
    }

A
Andrea Bolognani 已提交
1065
    if (ARCH_IS_X86(guestarch) &&
1066
        virCapabilitiesAddGuestFeature(guest, "apic", true, false) == NULL) {
1067
        goto cleanup;
1068
    }
1069

1070
    if ((guestarch == VIR_ARCH_I686) &&
1071 1072
        (virCapabilitiesAddGuestFeature(guest, "pae", true, false) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "nonpae", true, false) == NULL))
1073
        goto cleanup;
1074 1075 1076

    ret = 0;

1077
 cleanup:
1078 1079 1080

    virCapabilitiesFreeMachines(machines, nmachines);

1081
    return ret;
1082 1083 1084
}


1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104
virCPUDefPtr
virQEMUCapsProbeHostCPUForEmulator(virCapsPtr caps,
                                   virQEMUCapsPtr qemuCaps,
                                   virDomainVirtType type)
{
    size_t nmodels;
    char **models;
    virCPUDefPtr cpu;

    if (virQEMUCapsGetCPUDefinitions(qemuCaps, type, &models, &nmodels) < 0)
        return NULL;

    cpu = virCPUGetHost(caps->host.arch, VIR_CPU_TYPE_GUEST, NULL,
                        (const char **) models, nmodels);

    virStringListFreeCount(models, nmodels);
    return cpu;
}


1105
virCapsPtr virQEMUCapsInit(virQEMUCapsCachePtr cache)
1106 1107
{
    virCapsPtr caps;
1108
    size_t i;
T
Tal Kain 已提交
1109
    virArch hostarch = virArchFromHost();
1110

T
Tal Kain 已提交
1111
    if ((caps = virCapabilitiesNew(hostarch,
1112
                                   true, true)) == NULL)
1113
        goto error;
1114 1115 1116 1117 1118

    /* Some machines have problematic NUMA toplogy causing
     * unexpected failures. We don't want to break the QEMU
     * driver in this scenario, so log errors & carry on
     */
M
Martin Kletzander 已提交
1119
    if (virCapabilitiesInitNUMA(caps) < 0) {
1120
        virCapabilitiesFreeNUMAInfo(caps);
1121
        VIR_WARN("Failed to query host NUMA topology, disabling NUMA capabilities");
1122 1123
    }

M
Martin Kletzander 已提交
1124
    if (!(caps->host.cpu = virCPUProbeHost(caps->host.arch)))
1125
        VIR_WARN("Failed to get host CPU");
1126

1127
    /* Add the power management features of the host */
1128
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
1129 1130
        VIR_WARN("Failed to get host power management capabilities");

M
Michal Privoznik 已提交
1131
    /* Add huge pages info */
1132
    if (virCapabilitiesInitPages(caps) < 0)
M
Michal Privoznik 已提交
1133 1134
        VIR_WARN("Failed to get pages info");

1135 1136 1137
    /* Add domain migration transport URIs */
    virCapabilitiesAddHostMigrateTransport(caps, "tcp");
    virCapabilitiesAddHostMigrateTransport(caps, "rdma");
1138

1139 1140 1141 1142
    /* QEMU can support pretty much every arch that exists,
     * so just probe for them all - we gracefully fail
     * if a qemu-system-$ARCH binary can't be found
     */
1143
    for (i = 0; i < VIR_ARCH_LAST; i++)
1144
        if (virQEMUCapsInitGuest(caps, cache,
T
Tal Kain 已提交
1145
                                 hostarch,
1146
                                 i) < 0)
1147
            goto error;
1148 1149 1150

    return caps;

1151
 error:
1152
    virObjectUnref(caps);
1153 1154 1155 1156
    return NULL;
}


1157
static int
1158 1159 1160 1161
virQEMUCapsComputeCmdFlags(const char *help,
                           unsigned int version,
                           virQEMUCapsPtr qemuCaps,
                           bool check_yajl ATTRIBUTE_UNUSED)
1162 1163
{
    const char *p;
R
Richa Marwaha 已提交
1164
    const char *fsdev, *netdev;
1165
    const char *cache;
1166 1167

    if (strstr(help, "-no-kvm"))
1168
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
1169
    if (strstr(help, "-enable-kvm"))
1170
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
1171 1172
    if (strstr(help, ",process="))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187

    cache = strstr(help, "cache=");
    if (cache && (p = strchr(cache, ']'))) {
        if (memmem(cache, p - cache, "directsync", sizeof("directsync") - 1))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
        if (memmem(cache, p - cache, "unsafe", sizeof("unsafe") - 1))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
    }
    if (strstr(help, "aio=threads|native"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_AIO);
    if (strstr(help, "copy-on-read=on|off"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
    if (strstr(help, "bps="))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_IOTUNE);

P
Paolo Bonzini 已提交
1188 1189
    if (strstr(help, "-display"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DISPLAY);
1190 1191 1192
    if ((p = strstr(help, "-vga")) && !strstr(help, "-std-vga")) {
        const char *nl = strstr(p, "\n");
        if ((p = strstr(p, "|none")) && p < nl)
1193
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
1194 1195
    }
    if (strstr(help, "-spice"))
1196
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
1197
    if (strstr(help, "-vnc"))
1198
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
1199
    if (strstr(help, "seamless-migration="))
1200
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
1201
    if (strstr(help, "boot=on"))
1202
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_BOOT);
1203
    if (strstr(help, "serial=s"))
1204
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
1205 1206
    if (strstr(help, "host=[seg:]bus"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
1207
    if (strstr(help, "-mem-path"))
1208
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
1209
    if (strstr(help, "-chardev")) {
1210
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
1211
        if (strstr(help, "-chardev spicevmc"))
1212
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
1213 1214
        if (strstr(help, "-chardev spiceport"))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEPORT);
1215
    }
1216
    if (strstr(help, "-nodefconfig"))
1217
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
1218
    if (strstr(help, "-no-user-config"))
1219
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
1220 1221
    /* The trailing ' ' is important to avoid a bogus match */
    if (strstr(help, "-rtc "))
1222
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
1223 1224
    /* to wit */
    if (strstr(help, "-rtc-td-hack"))
1225
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC_TD_HACK);
1226
    if (strstr(help, "-no-hpet"))
1227
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
1228
    if (strstr(help, "-no-acpi"))
1229
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
1230
    if (strstr(help, "-no-kvm-pit-reinjection"))
1231
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
1232
    if (strstr(help, "-tdf"))
1233
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_TDF);
1234
    if (strstr(help, "-enable-nesting"))
1235
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NESTING);
1236
    if (strstr(help, ",menu=on"))
1237
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
1238
    if (strstr(help, ",reboot-timeout=rb_time"))
1239
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_REBOOT_TIMEOUT);
1240 1241
    if (strstr(help, ",splash-time=sp_time"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPLASH_TIMEOUT);
1242
    if ((fsdev = strstr(help, "-fsdev"))) {
1243
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
1244
        if (strstr(fsdev, "readonly"))
1245
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
1246
        if (strstr(fsdev, "writeout"))
1247
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
1248
    }
1249
    if (strstr(help, "-smbios type"))
1250
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
1251
    if (strstr(help, "-sandbox"))
1252
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
1253

R
Richa Marwaha 已提交
1254
    if ((netdev = strstr(help, "-netdev"))) {
1255 1256
        /* Disable -netdev on 0.12 since although it exists,
         * the corresponding netdev_add/remove monitor commands
1257 1258
         * do not, and we need them to be able to do hotplug.
         * But see below about RHEL build. */
R
Richa Marwaha 已提交
1259 1260
        if (version >= 13000) {
            if (strstr(netdev, "bridge"))
1261
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
1262
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
R
Richa Marwaha 已提交
1263
        }
1264 1265 1266
    }

    if (strstr(help, "-sdl"))
1267
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
1268

1269
    if (strstr(help, ",vhost="))
1270
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
1271

1272 1273
    /* Do not use -no-shutdown if qemu doesn't support it or SIGTERM handling
     * is most likely buggy when used with -no-shutdown (which applies for qemu
1274
     * 0.14.* and 0.15.0)
1275
     */
1276
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1277
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
1278

1279
    if (strstr(help, "dump-guest-core=on|off"))
1280
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
1281

O
Olivia Yin 已提交
1282 1283 1284
    if (strstr(help, "-dtb"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);

1285 1286 1287
    if (strstr(help, "-machine"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);

1288 1289 1290
    /* While JSON mode was available in 0.12.0, it was too
     * incomplete to contemplate using. The 0.13.0 release
     * is good enough to use, even though it lacks one or
1291 1292 1293 1294 1295
     * two features. This is also true of versions of qemu
     * built for RHEL, labeled 0.12.1, but with extra text
     * in the help output that mentions that features were
     * backported for libvirt. The benefits of JSON mode now
     * outweigh the downside.
1296
     */
1297
#if WITH_YAJL
1298
    if (version >= 13000) {
1299
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
1300 1301
    } else if (version >= 12000 &&
               strstr(help, "libvirt")) {
1302 1303
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1304
    }
1305 1306 1307 1308 1309
#else
    /* Starting with qemu 0.15 and newer, upstream qemu no longer
     * promises to keep the human interface stable, but requests that
     * we use QMP (the JSON interface) for everything.  If the user
     * forgot to include YAJL libraries when building their own
M
Martin Kletzander 已提交
1310
     * libvirt but is targeting a newer qemu, we are better off
1311
     * telling them to recompile (the spec file includes the
1312
     * dependency, so distros won't hit this).  This check is
1313
     * also in m4/virt-yajl.m4 (see $with_yajl).  */
1314 1315 1316
    if (version >= 15000 ||
        (version >= 12000 && strstr(help, "libvirt"))) {
        if (check_yajl) {
1317 1318 1319
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("this qemu binary requires libvirt to be "
                             "compiled with yajl"));
1320 1321
            return -1;
        }
1322
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1323
    }
E
Eric Blake 已提交
1324
#endif
1325 1326

    if (version >= 13000)
1327
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIFUNCTION);
1328

1329
    if (version >= 1001000) {
J
Ján Tomko 已提交
1330
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
1331 1332
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
    }
J
Ján Tomko 已提交
1333

1334
    return 0;
1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360
}

/* We parse the output of 'qemu -help' to get the QEMU
 * version number. The first bit is easy, just parse
 * 'QEMU PC emulator version x.y.z'
 * or
 * 'QEMU emulator version x.y.z'.
 *
 * With qemu-kvm, however, that is followed by a string
 * in parenthesis as follows:
 *  - qemu-kvm-x.y.z in stable releases
 *  - kvm-XX for kvm versions up to kvm-85
 *  - qemu-kvm-devel-XX for kvm version kvm-86 and later
 *
 * For qemu-kvm versions before 0.10.z, we need to detect
 * the KVM version number for some features. With 0.10.z
 * and later, we just need the QEMU version number and
 * whether it is KVM QEMU or mainline QEMU.
 */
#define QEMU_VERSION_STR_1  "QEMU emulator version"
#define QEMU_VERSION_STR_2  "QEMU PC emulator version"
#define QEMU_KVM_VER_PREFIX "(qemu-kvm-"
#define KVM_VER_PREFIX      "(kvm-"

#define SKIP_BLANKS(p) do { while ((*(p) == ' ') || (*(p) == '\t')) (p)++; } while (0)

1361 1362 1363 1364
int virQEMUCapsParseHelpStr(const char *qemu,
                            const char *help,
                            virQEMUCapsPtr qemuCaps,
                            unsigned int *version,
1365
                            bool *is_kvm,
1366
                            unsigned int *kvm_version,
1367 1368
                            bool check_yajl,
                            const char *qmperr)
1369 1370 1371
{
    unsigned major, minor, micro;
    const char *p = help;
1372
    char *strflags;
1373

1374 1375
    *version = *kvm_version = 0;
    *is_kvm = false;
1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392

    if (STRPREFIX(p, QEMU_VERSION_STR_1))
        p += strlen(QEMU_VERSION_STR_1);
    else if (STRPREFIX(p, QEMU_VERSION_STR_2))
        p += strlen(QEMU_VERSION_STR_2);
    else
        goto fail;

    SKIP_BLANKS(p);

    major = virParseNumber(&p);
    if (major == -1 || *p != '.')
        goto fail;

    ++p;

    minor = virParseNumber(&p);
J
Jiri Denemark 已提交
1393
    if (minor == -1)
1394 1395
        goto fail;

J
Jiri Denemark 已提交
1396 1397 1398 1399 1400 1401 1402 1403
    if (*p != '.') {
        micro = 0;
    } else {
        ++p;
        micro = virParseNumber(&p);
        if (micro == -1)
            goto fail;
    }
1404 1405 1406 1407

    SKIP_BLANKS(p);

    if (STRPREFIX(p, QEMU_KVM_VER_PREFIX)) {
1408
        *is_kvm = true;
1409 1410 1411 1412
        p += strlen(QEMU_KVM_VER_PREFIX);
    } else if (STRPREFIX(p, KVM_VER_PREFIX)) {
        int ret;

1413
        *is_kvm = true;
1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424
        p += strlen(KVM_VER_PREFIX);

        ret = virParseNumber(&p);
        if (ret == -1)
            goto fail;

        *kvm_version = ret;
    }

    *version = (major * 1000 * 1000) + (minor * 1000) + micro;

1425 1426 1427 1428 1429 1430 1431
    if (*version < 12000) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("QEMU version >= 0.12.00 is required, but %d.%d.%d found"),
                       major, minor, micro);
        goto cleanup;
    }

1432 1433 1434 1435
    /* Refuse to parse -help output for QEMU releases >= 1.2.0 that should be
     * using QMP probing.
     */
    if (*version >= 1002000) {
1436 1437 1438 1439 1440 1441 1442 1443 1444
        if (qmperr && *qmperr) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("QEMU / QMP failed: %s"),
                           qmperr);
        } else {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("QEMU %u.%u.%u is too new for help parsing"),
                           major, minor, micro);
        }
1445 1446 1447
        goto cleanup;
    }

1448
    if (virQEMUCapsComputeCmdFlags(help, *version,
1449
                                   qemuCaps, check_yajl) < 0)
1450
        goto cleanup;
1451

1452
    strflags = virBitmapString(qemuCaps->flags);
1453 1454 1455
    VIR_DEBUG("Version %u.%u.%u, cooked version %u, flags %s",
              major, minor, micro, *version, NULLSTR(strflags));
    VIR_FREE(strflags);
1456 1457 1458 1459 1460 1461 1462 1463

    if (*kvm_version)
        VIR_DEBUG("KVM version %d detected", *kvm_version);
    else if (*is_kvm)
        VIR_DEBUG("qemu-kvm version %u.%u.%u detected", major, minor, micro);

    return 0;

1464
 fail:
1465
    p = strchr(help, '\n');
1466 1467
    if (!p)
        p = strchr(help, '\0');
1468

1469 1470 1471
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("cannot parse %s version number in '%.*s'"),
                   qemu, (int) (p - help), help);
1472

1473
 cleanup:
1474 1475 1476
    return -1;
}

1477

1478
struct virQEMUCapsStringFlags {
1479 1480 1481 1482 1483
    const char *value;
    int flag;
};


1484 1485 1486
struct virQEMUCapsStringFlags virQEMUCapsCommands[] = {
    { "system_wakeup", QEMU_CAPS_WAKEUP },
    { "transaction", QEMU_CAPS_TRANSACTION },
1487 1488
    { "block_stream", QEMU_CAPS_BLOCKJOB_SYNC },
    { "block-stream", QEMU_CAPS_BLOCKJOB_ASYNC },
1489 1490 1491 1492 1493 1494 1495 1496 1497
    { "dump-guest-memory", QEMU_CAPS_DUMP_GUEST_MEMORY },
    { "query-spice", QEMU_CAPS_SPICE },
    { "query-kvm", QEMU_CAPS_KVM },
    { "block-commit", QEMU_CAPS_BLOCK_COMMIT },
    { "query-vnc", QEMU_CAPS_VNC },
    { "drive-mirror", QEMU_CAPS_DRIVE_MIRROR },
    { "blockdev-snapshot-sync", QEMU_CAPS_DISK_SNAPSHOT },
    { "add-fd", QEMU_CAPS_ADD_FD },
    { "nbd-server-start", QEMU_CAPS_NBD_SERVER },
1498
    { "change-backing-file", QEMU_CAPS_CHANGE_BACKING_FILE },
1499
    { "rtc-reset-reinjection", QEMU_CAPS_RTC_RESET_REINJECTION },
1500
    { "migrate-incoming", QEMU_CAPS_INCOMING_DEFER },
1501
    { "query-hotpluggable-cpus", QEMU_CAPS_QUERY_HOTPLUGGABLE_CPUS },
1502 1503
    { "query-qmp-schema", QEMU_CAPS_QUERY_QMP_SCHEMA },
    { "query-cpu-model-expansion", QEMU_CAPS_QUERY_CPU_MODEL_EXPANSION},
1504
    { "query-cpu-definitions", QEMU_CAPS_QUERY_CPU_DEFINITIONS},
1505
    { "query-named-block-nodes", QEMU_CAPS_QUERY_NAMED_BLOCK_NODES}
1506 1507
};

1508 1509 1510 1511
struct virQEMUCapsStringFlags virQEMUCapsMigration[] = {
    { "rdma-pin-all", QEMU_CAPS_MIGRATE_RDMA },
};

1512 1513 1514
struct virQEMUCapsStringFlags virQEMUCapsEvents[] = {
    { "BALLOON_CHANGE", QEMU_CAPS_BALLOON_EVENT },
    { "SPICE_MIGRATE_COMPLETED", QEMU_CAPS_SEAMLESS_MIGRATION },
1515
    { "DEVICE_DELETED", QEMU_CAPS_DEVICE_DEL_EVENT },
1516
    { "MIGRATION", QEMU_CAPS_MIGRATION_EVENT },
1517
    { "VSERPORT_CHANGE", QEMU_CAPS_VSERPORT_CHANGE },
1518
    { "DEVICE_TRAY_MOVED", QEMU_CAPS_DEVICE_TRAY_MOVED },
1519
    { "BLOCK_WRITE_THRESHOLD", QEMU_CAPS_BLOCK_WRITE_THRESHOLD },
1520 1521
};

1522
struct virQEMUCapsStringFlags virQEMUCapsObjectTypes[] = {
1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537
    { "hda-duplex", QEMU_CAPS_HDA_DUPLEX },
    { "hda-micro", QEMU_CAPS_HDA_MICRO },
    { "ccid-card-emulated", QEMU_CAPS_CCID_EMULATED },
    { "ccid-card-passthru", QEMU_CAPS_CCID_PASSTHRU },
    { "piix3-usb-uhci", QEMU_CAPS_PIIX3_USB_UHCI },
    { "piix4-usb-uhci", QEMU_CAPS_PIIX4_USB_UHCI },
    { "usb-ehci", QEMU_CAPS_USB_EHCI },
    { "ich9-usb-ehci1", QEMU_CAPS_ICH9_USB_EHCI1 },
    { "vt82c686b-usb-uhci", QEMU_CAPS_VT82C686B_USB_UHCI },
    { "pci-ohci", QEMU_CAPS_PCI_OHCI },
    { "nec-usb-xhci", QEMU_CAPS_NEC_USB_XHCI },
    { "usb-redir", QEMU_CAPS_USB_REDIR },
    { "usb-hub", QEMU_CAPS_USB_HUB },
    { "ich9-ahci", QEMU_CAPS_ICH9_AHCI },
    { "virtio-blk-s390", QEMU_CAPS_VIRTIO_S390 },
1538
    { "virtio-blk-ccw", QEMU_CAPS_VIRTIO_CCW },
1539
    { "sclpconsole", QEMU_CAPS_SCLP_S390 },
1540
    { "lsi53c895a", QEMU_CAPS_SCSI_LSI },
1541
    { "virtio-scsi-pci", QEMU_CAPS_VIRTIO_SCSI },
1542 1543
    { "virtio-scsi-s390", QEMU_CAPS_VIRTIO_SCSI },
    { "virtio-scsi-ccw", QEMU_CAPS_VIRTIO_SCSI },
1544
    { "virtio-scsi-device", QEMU_CAPS_VIRTIO_SCSI },
1545
    { "megasas", QEMU_CAPS_SCSI_MEGASAS },
1546
    { "spicevmc", QEMU_CAPS_DEVICE_SPICEVMC },
1547
    { "qxl", QEMU_CAPS_DEVICE_QXL },
1548 1549 1550 1551
    { "sga", QEMU_CAPS_SGA },
    { "scsi-block", QEMU_CAPS_SCSI_BLOCK },
    { "scsi-cd", QEMU_CAPS_SCSI_CD },
    { "ide-cd", QEMU_CAPS_IDE_CD },
1552 1553 1554
    { "VGA", QEMU_CAPS_DEVICE_VGA },
    { "cirrus-vga", QEMU_CAPS_DEVICE_CIRRUS_VGA },
    { "vmware-svga", QEMU_CAPS_DEVICE_VMWARE_SVGA },
H
Han Cheng 已提交
1555 1556
    { "usb-serial", QEMU_CAPS_DEVICE_USB_SERIAL },
    { "usb-net", QEMU_CAPS_DEVICE_USB_NET },
1557
    { "virtio-rng-pci", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1558 1559
    { "virtio-rng-s390", QEMU_CAPS_DEVICE_VIRTIO_RNG },
    { "virtio-rng-ccw", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1560
    { "virtio-rng-device", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1561
    { "rng-random", QEMU_CAPS_OBJECT_RNG_RANDOM },
1562
    { "rng-egd", QEMU_CAPS_OBJECT_RNG_EGD },
1563
    { "spapr-nvram", QEMU_CAPS_DEVICE_NVRAM },
1564
    { "pci-bridge", QEMU_CAPS_DEVICE_PCI_BRIDGE },
1565
    { "vfio-pci", QEMU_CAPS_DEVICE_VFIO_PCI },
H
Han Cheng 已提交
1566
    { "scsi-generic", QEMU_CAPS_DEVICE_SCSI_GENERIC },
1567
    { "i82801b11-bridge", QEMU_CAPS_DEVICE_DMI_TO_PCI_BRIDGE },
1568
    { "usb-storage", QEMU_CAPS_DEVICE_USB_STORAGE },
1569
    { "virtio-mmio", QEMU_CAPS_DEVICE_VIRTIO_MMIO },
1570
    { "ich9-intel-hda", QEMU_CAPS_DEVICE_ICH9_INTEL_HDA },
H
Hu Tao 已提交
1571
    { "pvpanic", QEMU_CAPS_DEVICE_PANIC },
L
Li Zhang 已提交
1572
    { "usb-kbd", QEMU_CAPS_DEVICE_USB_KBD },
1573
    { "memory-backend-ram", QEMU_CAPS_OBJECT_MEMORY_RAM },
1574
    { "memory-backend-file", QEMU_CAPS_OBJECT_MEMORY_FILE },
1575
    { "usb-audio", QEMU_CAPS_OBJECT_USB_AUDIO },
J
John Ferlan 已提交
1576
    { "iothread", QEMU_CAPS_OBJECT_IOTHREAD},
1577
    { "ivshmem", QEMU_CAPS_DEVICE_IVSHMEM },
1578
    { "pc-dimm", QEMU_CAPS_DEVICE_PC_DIMM },
M
Michal Privoznik 已提交
1579
    { "pci-serial", QEMU_CAPS_DEVICE_PCI_SERIAL },
1580
    { "gpex-pcihost", QEMU_CAPS_OBJECT_GPEX},
1581
    { "ioh3420", QEMU_CAPS_DEVICE_IOH3420 },
1582
    { "x3130-upstream", QEMU_CAPS_DEVICE_X3130_UPSTREAM },
1583
    { "xio3130-downstream", QEMU_CAPS_DEVICE_XIO3130_DOWNSTREAM },
1584
    { "rtl8139", QEMU_CAPS_DEVICE_RTL8139 },
1585
    { "e1000", QEMU_CAPS_DEVICE_E1000 },
1586 1587 1588 1589
    { "virtio-net-pci", QEMU_CAPS_DEVICE_VIRTIO_NET },
    { "virtio-net-ccw", QEMU_CAPS_DEVICE_VIRTIO_NET },
    { "virtio-net-s390", QEMU_CAPS_DEVICE_VIRTIO_NET },
    { "virtio-net-device", QEMU_CAPS_DEVICE_VIRTIO_NET },
M
Marc-André Lureau 已提交
1590 1591
    { "virtio-gpu-pci", QEMU_CAPS_DEVICE_VIRTIO_GPU },
    { "virtio-gpu-device", QEMU_CAPS_DEVICE_VIRTIO_GPU },
1592
    { "virtio-vga", QEMU_CAPS_DEVICE_VIRTIO_VGA },
1593 1594 1595 1596 1597 1598
    { "virtio-keyboard-device", QEMU_CAPS_VIRTIO_KEYBOARD },
    { "virtio-keyboard-pci", QEMU_CAPS_VIRTIO_KEYBOARD },
    { "virtio-mouse-device", QEMU_CAPS_VIRTIO_MOUSE },
    { "virtio-mouse-pci", QEMU_CAPS_VIRTIO_MOUSE },
    { "virtio-tablet-device", QEMU_CAPS_VIRTIO_TABLET },
    { "virtio-tablet-pci", QEMU_CAPS_VIRTIO_TABLET },
1599 1600
    { "virtio-input-host-device", QEMU_CAPS_VIRTIO_INPUT_HOST },
    { "virtio-input-host-pci", QEMU_CAPS_VIRTIO_INPUT_HOST },
1601
    { "mptsas1068", QEMU_CAPS_SCSI_MPTSAS1068 },
1602
    { "secret", QEMU_CAPS_OBJECT_SECRET },
1603
    { "pxb", QEMU_CAPS_DEVICE_PXB },
1604
    { "pxb-pcie", QEMU_CAPS_DEVICE_PXB_PCIE },
1605
    { "tls-creds-x509", QEMU_CAPS_OBJECT_TLS_CREDS_X509 },
J
Ján Tomko 已提交
1606
    { "intel-iommu", QEMU_CAPS_DEVICE_INTEL_IOMMU },
1607 1608
    { "ivshmem-plain", QEMU_CAPS_DEVICE_IVSHMEM_PLAIN },
    { "ivshmem-doorbell", QEMU_CAPS_DEVICE_IVSHMEM_DOORBELL },
1609
    { "vhost-scsi", QEMU_CAPS_DEVICE_VHOST_SCSI },
1610
    { "nvdimm", QEMU_CAPS_DEVICE_NVDIMM },
1611
    { "pcie-root-port", QEMU_CAPS_DEVICE_PCIE_ROOT_PORT },
1612 1613
};

1614 1615 1616 1617
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBalloon[] = {
    { "deflate-on-oom", QEMU_CAPS_VIRTIO_BALLOON_AUTODEFLATE },
};

1618
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBlk[] = {
1619 1620 1621 1622 1623 1624 1625 1626
    { "multifunction", QEMU_CAPS_PCI_MULTIFUNCTION },
    { "bootindex", QEMU_CAPS_BOOTINDEX },
    { "ioeventfd", QEMU_CAPS_VIRTIO_IOEVENTFD },
    { "event_idx", QEMU_CAPS_VIRTIO_BLK_EVENT_IDX },
    { "scsi", QEMU_CAPS_VIRTIO_BLK_SCSI },
    { "logical_block_size", QEMU_CAPS_BLOCKIO },
};

1627
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioNet[] = {
1628 1629
    { "tx", QEMU_CAPS_VIRTIO_TX_ALG },
    { "event_idx", QEMU_CAPS_VIRTIO_NET_EVENT_IDX },
1630
    { "rx_queue_size", QEMU_CAPS_VIRTIO_NET_RX_QUEUE_SIZE },
1631
    { "host_mtu", QEMU_CAPS_VIRTIO_NET_HOST_MTU },
1632 1633
};

1634 1635 1636 1637
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioSCSI[] = {
    { "iothread", QEMU_CAPS_VIRTIO_SCSI_IOTHREAD },
};

1638
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPCIAssign[] = {
1639 1640 1641 1642
    { "configfd", QEMU_CAPS_PCI_CONFIGFD },
    { "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};

1643
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVfioPCI[] = {
1644 1645 1646
    { "bootindex", QEMU_CAPS_VFIO_PCI_BOOTINDEX },
};

1647
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIDisk[] = {
1648 1649 1650 1651
    { "channel", QEMU_CAPS_SCSI_DISK_CHANNEL },
    { "wwn", QEMU_CAPS_SCSI_DISK_WWN },
};

1652
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsIDEDrive[] = {
1653 1654 1655
    { "wwn", QEMU_CAPS_IDE_DRIVE_WWN },
};

1656
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPiix4PM[] = {
1657 1658
    { "disable_s3", QEMU_CAPS_PIIX_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_PIIX_DISABLE_S4 },
1659 1660
};

1661
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBRedir[] = {
1662
    { "filter", QEMU_CAPS_USB_REDIR_FILTER },
1663 1664 1665
    { "bootindex", QEMU_CAPS_USB_REDIR_BOOTINDEX },
};

1666
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBHost[] = {
1667
    { "bootindex", QEMU_CAPS_USB_HOST_BOOTINDEX },
1668 1669
};

1670
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIGeneric[] = {
H
Han Cheng 已提交
1671 1672 1673
    { "bootindex", QEMU_CAPS_DEVICE_SCSI_GENERIC_BOOTINDEX },
};

1674
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsI440FXPCIHost[] = {
1675 1676 1677
    { "pci-hole64-size", QEMU_CAPS_I440FX_PCI_HOLE64_SIZE },
};

1678
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQ35PCIHost[] = {
1679 1680 1681
    { "pci-hole64-size", QEMU_CAPS_Q35_PCI_HOLE64_SIZE },
};

1682
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBStorage[] = {
1683 1684 1685
    { "removable", QEMU_CAPS_USB_STORAGE_REMOVABLE },
};

1686 1687 1688 1689
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsKVMPit[] = {
    { "lost_tick_policy", QEMU_CAPS_KVM_PIT_TICK_POLICY },
};

1690 1691 1692 1693 1694 1695 1696 1697 1698 1699
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVGA[] = {
    { "vgamem_mb", QEMU_CAPS_VGA_VGAMEM },
};

static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVmwareSvga[] = {
    { "vgamem_mb", QEMU_CAPS_VMWARE_SVGA_VGAMEM },
};

static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQxl[] = {
    { "vgamem_mb", QEMU_CAPS_QXL_VGAMEM },
1700
    { "vram64_size_mb", QEMU_CAPS_QXL_VRAM64 },
1701
    { "max_outputs", QEMU_CAPS_QXL_MAX_OUTPUTS },
1702 1703
};

1704
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioGpu[] = {
1705
    { "virgl", QEMU_CAPS_VIRTIO_GPU_VIRGL },
1706 1707
};

1708 1709 1710 1711 1712
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsICH9[] = {
    { "disable_s3", QEMU_CAPS_ICH9_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_ICH9_DISABLE_S4 },
};

1713 1714 1715 1716
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBNECXHCI[] = {
    { "p3", QEMU_CAPS_NEC_USB_XHCI_PORTS },
};

1717 1718
/* see documentation for virQEMUCapsQMPSchemaGetByPath for the query format */
static struct virQEMUCapsStringFlags virQEMUCapsQMPSchemaQueries[] = {
1719
    { "blockdev-add/arg-type/options/+gluster/debug-level", QEMU_CAPS_GLUSTER_DEBUG_LEVEL},
1720
    { "blockdev-add/arg-type/+gluster/debug", QEMU_CAPS_GLUSTER_DEBUG_LEVEL},
1721 1722
};

1723
struct virQEMUCapsObjectTypeProps {
1724
    const char *type;
1725
    struct virQEMUCapsStringFlags *props;
1726
    size_t nprops;
1727
    int capsCondition;
1728 1729
};

1730 1731
static struct virQEMUCapsObjectTypeProps virQEMUCapsObjectProps[] = {
    { "virtio-blk-pci", virQEMUCapsObjectPropsVirtioBlk,
1732 1733
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk),
      -1 },
1734
    { "virtio-net-pci", virQEMUCapsObjectPropsVirtioNet,
1735 1736
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet),
      -1 },
1737
    { "virtio-scsi-pci", virQEMUCapsObjectPropsVirtioSCSI,
1738 1739
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioSCSI),
      -1 },
1740
    { "virtio-blk-ccw", virQEMUCapsObjectPropsVirtioBlk,
1741 1742
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk),
      -1 },
1743
    { "virtio-net-ccw", virQEMUCapsObjectPropsVirtioNet,
1744 1745
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet),
      -1 },
1746
    { "virtio-scsi-ccw", virQEMUCapsObjectPropsVirtioSCSI,
1747 1748
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioSCSI),
      -1 },
1749
    { "virtio-blk-s390", virQEMUCapsObjectPropsVirtioBlk,
1750 1751
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk),
      -1 },
1752
    { "virtio-net-s390", virQEMUCapsObjectPropsVirtioNet,
1753 1754
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet),
      -1 },
1755
    { "pci-assign", virQEMUCapsObjectPropsPCIAssign,
1756 1757
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign),
      -1 },
1758
    { "kvm-pci-assign", virQEMUCapsObjectPropsPCIAssign,
1759 1760
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign),
      -1 },
1761
    { "vfio-pci", virQEMUCapsObjectPropsVfioPCI,
1762 1763
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVfioPCI),
      -1 },
1764
    { "scsi-disk", virQEMUCapsObjectPropsSCSIDisk,
1765 1766
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIDisk),
      -1 },
1767
    { "ide-drive", virQEMUCapsObjectPropsIDEDrive,
1768 1769
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsIDEDrive),
      -1 },
1770
    { "PIIX4_PM", virQEMUCapsObjectPropsPiix4PM,
1771 1772
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPiix4PM),
      -1 },
1773
    { "usb-redir", virQEMUCapsObjectPropsUSBRedir,
1774 1775
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBRedir),
      -1 },
1776
    { "usb-host", virQEMUCapsObjectPropsUSBHost,
1777 1778
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBHost),
      -1 },
1779
    { "scsi-generic", virQEMUCapsObjectPropsSCSIGeneric,
1780 1781
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIGeneric),
      -1 },
1782
    { "i440FX-pcihost", virQEMUCapsObjectPropsI440FXPCIHost,
1783 1784
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsI440FXPCIHost),
      -1 },
1785
    { "q35-pcihost", virQEMUCapsObjectPropsQ35PCIHost,
1786 1787
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQ35PCIHost),
      -1 },
1788
    { "usb-storage", virQEMUCapsObjectPropsUSBStorage,
1789 1790
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBStorage),
      -1 },
1791
    { "kvm-pit", virQEMUCapsObjectPropsKVMPit,
1792 1793
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsKVMPit),
      -1 },
1794
    { "VGA", virQEMUCapsObjectPropsVGA,
1795 1796
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVGA),
      -1 },
1797
    { "vmware-svga", virQEMUCapsObjectPropsVmwareSvga,
1798 1799
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVmwareSvga),
      -1 },
1800
    { "qxl", virQEMUCapsObjectPropsQxl,
1801 1802
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxl),
      -1 },
1803
    { "virtio-gpu-pci", virQEMUCapsObjectPropsVirtioGpu,
1804 1805
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioGpu),
      -1 },
1806
    { "virtio-gpu-device", virQEMUCapsObjectPropsVirtioGpu,
1807 1808
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioGpu),
      -1 },
1809
    { "ICH9-LPC", virQEMUCapsObjectPropsICH9,
1810 1811
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsICH9),
      -1 },
1812
    { "virtio-balloon-pci", virQEMUCapsObjectPropsVirtioBalloon,
1813 1814
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBalloon),
      -1 },
1815
    { "virtio-balloon-ccw", virQEMUCapsObjectPropsVirtioBalloon,
1816 1817
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBalloon),
      -1 },
1818
    { "virtio-balloon-device", virQEMUCapsObjectPropsVirtioBalloon,
1819 1820
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBalloon),
      -1 },
1821
    { "nec-usb-xhci", virQEMUCapsObjectPropsUSBNECXHCI,
1822 1823
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBNECXHCI),
      -1 },
1824 1825
};

1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853
struct virQEMUCapsPropTypeObjects {
    const char *prop;
    int flag;
    const char **objects;
};

static const char *virQEMUCapsVirtioPCIDisableLegacyObjects[] = {
     "virtio-balloon-pci",
     "virtio-blk-pci",
     "virtio-scsi-pci",
     "virtio-serial-pci",
     "virtio-9p-pci",
     "virtio-net-pci",
     "virtio-rng-pci",
     "virtio-gpu-pci",
     "virtio-input-host-pci",
     "virtio-keyboard-pci",
     "virtio-mouse-pci",
     "virtio-tablet-pci",
     NULL
};

static struct virQEMUCapsPropTypeObjects virQEMUCapsPropObjects[] = {
    { "disable-legacy",
      QEMU_CAPS_VIRTIO_PCI_DISABLE_LEGACY,
      virQEMUCapsVirtioPCIDisableLegacyObjects }
};

1854 1855

static void
1856 1857 1858 1859 1860
virQEMUCapsProcessStringFlags(virQEMUCapsPtr qemuCaps,
                              size_t nflags,
                              struct virQEMUCapsStringFlags *flags,
                              size_t nvalues,
                              char *const*values)
1861 1862
{
    size_t i, j;
1863 1864
    for (i = 0; i < nflags; i++) {
        for (j = 0; j < nvalues; j++) {
1865
            if (STREQ(values[j], flags[i].value)) {
1866
                virQEMUCapsSet(qemuCaps, flags[i].flag);
1867 1868 1869 1870 1871 1872 1873
                break;
            }
        }
    }
}


1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889
static void
virQEMUCapsProcessProps(virQEMUCapsPtr qemuCaps,
                        size_t nprops,
                        struct virQEMUCapsPropTypeObjects *props,
                        const char *object,
                        size_t nvalues,
                        char *const*values)
{
    size_t i, j;

    for (i = 0; i < nprops; i++) {
        if (virQEMUCapsGet(qemuCaps, props[i].flag))
            continue;

        for (j = 0; j < nvalues; j++) {
            if (STREQ(values[j], props[i].prop)) {
1890
                if (virStringListHasString(props[i].objects, object))
1891 1892 1893 1894 1895 1896 1897 1898
                    virQEMUCapsSet(qemuCaps, props[i].flag);
                break;
            }
        }
    }
}


1899 1900 1901
#define OBJECT_TYPE_PREFIX "name \""

static int
1902 1903
virQEMUCapsParseDeviceStrObjectTypes(const char *str,
                                     char ***types)
1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921
{
    const char *tmp = str;
    int ret = -1;
    size_t ntypelist = 0;
    char **typelist = NULL;

    *types = NULL;

    while ((tmp = strstr(tmp, OBJECT_TYPE_PREFIX))) {
        char *end;
        tmp += strlen(OBJECT_TYPE_PREFIX);
        end = strstr(tmp, "\"");
        if (!end) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("Malformed QEMU device list string, missing quote"));
            goto cleanup;
        }

1922
        if (VIR_EXPAND_N(typelist, ntypelist, 1) < 0)
1923
            goto cleanup;
1924
        if (VIR_STRNDUP(typelist[ntypelist - 1], tmp, end-tmp) < 0)
1925 1926 1927 1928 1929 1930
            goto cleanup;
    }

    *types = typelist;
    ret = ntypelist;

1931
 cleanup:
1932
    if (ret < 0)
1933
        virStringListFreeCount(typelist, ntypelist);
1934 1935 1936 1937 1938
    return ret;
}


static int
1939 1940 1941
virQEMUCapsParseDeviceStrObjectProps(const char *str,
                                     const char *type,
                                     char ***props)
1942 1943 1944 1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974
{
    const char *tmp = str;
    int ret = -1;
    size_t nproplist = 0;
    char **proplist = NULL;

    VIR_DEBUG("Extract type %s", type);
    *props = NULL;

    while ((tmp = strchr(tmp, '\n'))) {
        char *end;
        tmp += 1;

        if (*tmp == '\0')
            break;

        if (STRPREFIX(tmp, OBJECT_TYPE_PREFIX))
            continue;

        if (!STRPREFIX(tmp, type))
            continue;

        tmp += strlen(type);
        if (*tmp != '.')
            continue;
        tmp++;

        end = strstr(tmp, "=");
        if (!end) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("Malformed QEMU device list string, missing '='"));
            goto cleanup;
        }
1975
        if (VIR_EXPAND_N(proplist, nproplist, 1) < 0)
1976
            goto cleanup;
1977
        if (VIR_STRNDUP(proplist[nproplist - 1], tmp, end-tmp) < 0)
1978 1979 1980 1981 1982 1983
            goto cleanup;
    }

    *props = proplist;
    ret = nproplist;

1984
 cleanup:
1985
    if (ret < 0)
1986
        virStringListFreeCount(proplist, nproplist);
1987 1988 1989 1990 1991
    return ret;
}


int
1992
virQEMUCapsParseDeviceStr(virQEMUCapsPtr qemuCaps, const char *str)
1993 1994 1995 1996 1997
{
    int nvalues;
    char **values;
    size_t i;

1998
    if ((nvalues = virQEMUCapsParseDeviceStrObjectTypes(str, &values)) < 0)
1999
        return -1;
2000 2001 2002 2003
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
2004
    virStringListFreeCount(values, nvalues);
2005

2006
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
2007 2008 2009 2010
        const char *type = virQEMUCapsObjectProps[i].type;
        if ((nvalues = virQEMUCapsParseDeviceStrObjectProps(str,
                                                            type,
                                                            &values)) < 0)
2011
            return -1;
2012 2013 2014 2015
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
2016
        virStringListFreeCount(values, nvalues);
2017 2018 2019
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2020 2021
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2022 2023 2024 2025 2026

    return 0;
}


E
Eric Blake 已提交
2027
static int
2028 2029
virQEMUCapsExtractDeviceStr(const char *qemu,
                            virQEMUCapsPtr qemuCaps,
2030
                            uid_t runUid, gid_t runGid)
2031
{
E
Eric Blake 已提交
2032
    char *output = NULL;
2033
    virCommandPtr cmd;
E
Eric Blake 已提交
2034
    int ret = -1;
2035

E
Eric Blake 已提交
2036 2037
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
2038 2039
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
2040
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
2041 2042
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
2043
     * if -help includes "device driver,?".  */
2044
    cmd = virQEMUCapsProbeCommand(qemu, qemuCaps, runUid, runGid);
2045 2046 2047 2048 2049 2050
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
2051
                         "-device", "PIIX4_PM,?",
2052
                         "-device", "usb-redir,?",
2053
                         "-device", "ide-drive,?",
2054
                         "-device", "usb-host,?",
H
Han Cheng 已提交
2055
                         "-device", "scsi-generic,?",
2056
                         "-device", "usb-storage,?",
2057 2058 2059 2060
                         "-device", "VGA,?",
                         "-device", "vmware-svga,?",
                         "-device", "qxl,?",
                         "-device", "qxl-vga,?",
2061
                         NULL);
2062
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
2063
    virCommandSetErrorBuffer(cmd, &output);
2064

2065
    if (virCommandRun(cmd, NULL) < 0)
2066 2067
        goto cleanup;

2068
    ret = virQEMUCapsParseDeviceStr(qemuCaps, output);
2069

2070
 cleanup:
E
Eric Blake 已提交
2071
    VIR_FREE(output);
2072
    virCommandFree(cmd);
E
Eric Blake 已提交
2073 2074 2075
    return ret;
}

2076

2077 2078 2079
int virQEMUCapsGetDefaultVersion(virCapsPtr caps,
                                 virQEMUCapsCachePtr capsCache,
                                 unsigned int *version)
2080
{
2081
    virQEMUCapsPtr qemucaps;
T
Tal Kain 已提交
2082
    virArch hostarch;
2083
    virCapsDomainDataPtr capsdata;
2084 2085 2086 2087

    if (*version > 0)
        return 0;

T
Tal Kain 已提交
2088
    hostarch = virArchFromHost();
2089 2090 2091
    if (!(capsdata = virCapabilitiesDomainDataLookup(caps,
            VIR_DOMAIN_OSTYPE_HVM, hostarch, VIR_DOMAIN_VIRT_QEMU,
            NULL, NULL))) {
2092
        virReportError(VIR_ERR_INTERNAL_ERROR,
2093
                       _("Cannot find suitable emulator for %s"),
T
Tal Kain 已提交
2094
                       virArchToString(hostarch));
2095 2096 2097
        return -1;
    }

2098
    qemucaps = virQEMUCapsCacheLookup(caps, capsCache, capsdata->emulator);
2099 2100
    VIR_FREE(capsdata);
    if (!qemucaps)
2101 2102
        return -1;

2103
    *version = virQEMUCapsGetVersion(qemucaps);
2104
    virObjectUnref(qemucaps);
2105 2106
    return 0;
}
2107 2108


2109 2110


2111 2112
virQEMUCapsPtr
virQEMUCapsNew(void)
2113
{
2114
    virQEMUCapsPtr qemuCaps;
2115

2116
    if (virQEMUCapsInitialize() < 0)
2117 2118
        return NULL;

2119
    if (!(qemuCaps = virObjectNew(virQEMUCapsClass)))
2120 2121
        return NULL;

2122
    if (!(qemuCaps->flags = virBitmapNew(QEMU_CAPS_LAST)))
2123
        goto error;
2124

2125
    return qemuCaps;
2126

2127
 error:
2128
    virObjectUnref(qemuCaps);
2129
    return NULL;
2130 2131 2132
}


2133
static int
2134 2135
virQEMUCapsHostCPUDataCopy(virQEMUCapsHostCPUDataPtr dst,
                           virQEMUCapsHostCPUDataPtr src)
2136
{
2137 2138
    if (src->info &&
        !(dst->info = qemuMonitorCPUModelInfoCopy(src->info)))
2139 2140
        return -1;

2141 2142
    if (src->reported &&
        !(dst->reported = virCPUDefCopy(src->reported)))
2143 2144
        return -1;

2145 2146 2147 2148
    if (src->migratable &&
        !(dst->migratable = virCPUDefCopy(src->migratable)))
        return -1;

2149 2150 2151 2152
    if (src->full &&
        !(dst->full = virCPUDefCopy(src->full)))
        return -1;

2153 2154 2155 2156
    return 0;
}


2157
static void
2158
virQEMUCapsHostCPUDataClear(virQEMUCapsHostCPUDataPtr cpuData)
2159
{
2160 2161
    qemuMonitorCPUModelInfoFree(cpuData->info);
    virCPUDefFree(cpuData->reported);
2162
    virCPUDefFree(cpuData->migratable);
2163
    virCPUDefFree(cpuData->full);
2164 2165

    memset(cpuData, 0, sizeof(*cpuData));
2166 2167 2168
}


2169
virQEMUCapsPtr virQEMUCapsNewCopy(virQEMUCapsPtr qemuCaps)
2170
{
2171
    virQEMUCapsPtr ret = virQEMUCapsNew();
2172 2173 2174 2175 2176
    size_t i;

    if (!ret)
        return NULL;

2177 2178
    ret->usedQMP = qemuCaps->usedQMP;

2179 2180 2181 2182 2183
    if (VIR_STRDUP(ret->binary, qemuCaps->binary) < 0)
        goto error;

    ret->ctime = qemuCaps->ctime;

2184
    virBitmapCopy(ret->flags, qemuCaps->flags);
2185

2186 2187
    ret->version = qemuCaps->version;
    ret->kvmVersion = qemuCaps->kvmVersion;
2188 2189 2190 2191

    if (VIR_STRDUP(ret->package, qemuCaps->package) < 0)
        goto error;

2192
    ret->arch = qemuCaps->arch;
2193

2194 2195 2196 2197 2198 2199 2200 2201 2202
    if (qemuCaps->kvmCPUModels) {
        ret->kvmCPUModels = virDomainCapsCPUModelsCopy(qemuCaps->kvmCPUModels);
        if (!ret->kvmCPUModels)
            goto error;
    }

    if (qemuCaps->tcgCPUModels) {
        ret->tcgCPUModels = virDomainCapsCPUModelsCopy(qemuCaps->tcgCPUModels);
        if (!ret->tcgCPUModels)
2203
            goto error;
2204 2205
    }

2206 2207
    if (virQEMUCapsHostCPUDataCopy(&ret->kvmCPU, &qemuCaps->kvmCPU) < 0 ||
        virQEMUCapsHostCPUDataCopy(&ret->tcgCPU, &qemuCaps->tcgCPU) < 0)
2208 2209
        goto error;

2210
    if (VIR_ALLOC_N(ret->machineTypes, qemuCaps->nmachineTypes) < 0)
2211
        goto error;
2212
    ret->nmachineTypes = qemuCaps->nmachineTypes;
2213
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2214 2215
        if (VIR_STRDUP(ret->machineTypes[i].name, qemuCaps->machineTypes[i].name) < 0 ||
            VIR_STRDUP(ret->machineTypes[i].alias, qemuCaps->machineTypes[i].alias) < 0)
2216
            goto error;
2217
        ret->machineTypes[i].maxCpus = qemuCaps->machineTypes[i].maxCpus;
2218
        ret->machineTypes[i].hotplugCpus = qemuCaps->machineTypes[i].hotplugCpus;
2219 2220
    }

2221 2222 2223 2224 2225 2226
    if (VIR_ALLOC_N(ret->gicCapabilities, qemuCaps->ngicCapabilities) < 0)
        goto error;
    ret->ngicCapabilities = qemuCaps->ngicCapabilities;
    for (i = 0; i < qemuCaps->ngicCapabilities; i++)
        ret->gicCapabilities[i] = qemuCaps->gicCapabilities[i];

2227 2228
    return ret;

2229
 error:
2230 2231 2232 2233 2234
    virObjectUnref(ret);
    return NULL;
}


2235
void virQEMUCapsDispose(void *obj)
2236
{
2237
    virQEMUCapsPtr qemuCaps = obj;
2238 2239
    size_t i;

2240
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2241 2242
        VIR_FREE(qemuCaps->machineTypes[i].name);
        VIR_FREE(qemuCaps->machineTypes[i].alias);
2243
    }
2244
    VIR_FREE(qemuCaps->machineTypes);
2245

2246 2247
    virObjectUnref(qemuCaps->kvmCPUModels);
    virObjectUnref(qemuCaps->tcgCPUModels);
2248

2249
    virBitmapFree(qemuCaps->flags);
2250

2251
    VIR_FREE(qemuCaps->package);
2252
    VIR_FREE(qemuCaps->binary);
A
Andrea Bolognani 已提交
2253 2254

    VIR_FREE(qemuCaps->gicCapabilities);
2255

2256 2257
    virQEMUCapsHostCPUDataClear(&qemuCaps->kvmCPU);
    virQEMUCapsHostCPUDataClear(&qemuCaps->tcgCPU);
2258 2259
}

2260
void
2261
virQEMUCapsSet(virQEMUCapsPtr qemuCaps,
2262
               virQEMUCapsFlags flag)
2263
{
2264
    ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2265 2266 2267 2268
}


void
2269
virQEMUCapsSetList(virQEMUCapsPtr qemuCaps, ...)
2270 2271 2272 2273
{
    va_list list;
    int flag;

2274
    va_start(list, qemuCaps);
2275
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
2276
        ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2277
    va_end(list);
2278 2279 2280 2281
}


void
2282
virQEMUCapsClear(virQEMUCapsPtr qemuCaps,
2283
                 virQEMUCapsFlags flag)
2284
{
2285
    ignore_value(virBitmapClearBit(qemuCaps->flags, flag));
2286 2287 2288
}


2289
char *virQEMUCapsFlagsString(virQEMUCapsPtr qemuCaps)
2290
{
2291
    return virBitmapString(qemuCaps->flags);
2292 2293 2294 2295
}


bool
2296
virQEMUCapsGet(virQEMUCapsPtr qemuCaps,
2297
               virQEMUCapsFlags flag)
2298
{
J
Ján Tomko 已提交
2299
    return qemuCaps && virBitmapIsBitSet(qemuCaps->flags, flag);
2300
}
2301 2302


D
Daniel P. Berrange 已提交
2303 2304 2305
bool virQEMUCapsHasPCIMultiBus(virQEMUCapsPtr qemuCaps,
                               virDomainDefPtr def)
{
2306 2307 2308
    /* x86_64 and i686 support PCI-multibus on all machine types
     * since forever */
    if (ARCH_IS_X86(qemuCaps->arch))
D
Daniel P. Berrange 已提交
2309 2310 2311
        return true;

    if (def->os.arch == VIR_ARCH_PPC ||
2312
        ARCH_IS_PPC64(def->os.arch)) {
D
Daniel P. Berrange 已提交
2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348
        /*
         * Usage of pci.0 naming:
         *
         *    ref405ep: no pci
         *       taihu: no pci
         *      bamboo: 1.1.0
         *       mac99: 2.0.0
         *     g3beige: 2.0.0
         *        prep: 1.4.0
         *     pseries: 2.0.0
         *   mpc8544ds: forever
         * virtex-m507: no pci
         *     ppce500: 1.6.0
         */

        if (qemuCaps->version >= 2000000)
            return true;

        if (qemuCaps->version >= 1006000 &&
            STREQ(def->os.machine, "ppce500"))
            return true;

        if (qemuCaps->version >= 1004000 &&
            STREQ(def->os.machine, "prep"))
            return true;

        if (qemuCaps->version >= 1001000 &&
            STREQ(def->os.machine, "bamboo"))
            return true;

        if (STREQ(def->os.machine, "mpc8544ds"))
            return true;

        return false;
    }

2349 2350 2351
    /* If 'virt' supports PCI, it supports multibus.
     * No extra conditions here for simplicity.
     */
2352
    if (qemuDomainIsVirt(def))
2353
        return true;
2354

D
Daniel P. Berrange 已提交
2355 2356 2357 2358
    return false;
}


2359
const char *virQEMUCapsGetBinary(virQEMUCapsPtr qemuCaps)
2360
{
2361
    return qemuCaps->binary;
2362 2363
}

2364 2365 2366 2367 2368 2369 2370 2371 2372

void
virQEMUCapsSetArch(virQEMUCapsPtr qemuCaps,
                   virArch arch)
{
    qemuCaps->arch = arch;
}


2373
virArch virQEMUCapsGetArch(virQEMUCapsPtr qemuCaps)
2374
{
2375
    return qemuCaps->arch;
2376 2377 2378
}


2379 2380 2381 2382 2383 2384 2385 2386
void
virQEMUCapsSetVersion(virQEMUCapsPtr qemuCaps,
                      unsigned int version)
{
    qemuCaps->version = version;
}


2387
unsigned int virQEMUCapsGetVersion(virQEMUCapsPtr qemuCaps)
2388
{
2389
    return qemuCaps->version;
2390 2391 2392
}


2393
unsigned int virQEMUCapsGetKVMVersion(virQEMUCapsPtr qemuCaps)
2394
{
2395
    return qemuCaps->kvmVersion;
2396 2397 2398
}


2399 2400 2401 2402 2403 2404
const char *virQEMUCapsGetPackage(virQEMUCapsPtr qemuCaps)
{
    return qemuCaps->package;
}


2405 2406
int
virQEMUCapsAddCPUDefinitions(virQEMUCapsPtr qemuCaps,
2407
                             virDomainVirtType type,
2408
                             const char **name,
2409 2410
                             size_t count,
                             virDomainCapsCPUUsable usable)
2411
{
2412
    size_t i;
2413
    virDomainCapsCPUModelsPtr cpus = NULL;
2414

2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428
    if (type == VIR_DOMAIN_VIRT_KVM && qemuCaps->kvmCPUModels)
        cpus = qemuCaps->kvmCPUModels;
    else if (type == VIR_DOMAIN_VIRT_QEMU && qemuCaps->tcgCPUModels)
        cpus = qemuCaps->tcgCPUModels;

    if (!cpus) {
        if (!(cpus = virDomainCapsCPUModelsNew(count)))
            return -1;

        if (type == VIR_DOMAIN_VIRT_KVM)
            qemuCaps->kvmCPUModels = cpus;
        else
            qemuCaps->tcgCPUModels = cpus;
    }
2429 2430

    for (i = 0; i < count; i++) {
2431
        if (virDomainCapsCPUModelsAdd(cpus, name[i], -1, usable) < 0)
2432
            return -1;
2433
    }
2434

2435 2436 2437 2438
    return 0;
}


2439 2440
int
virQEMUCapsGetCPUDefinitions(virQEMUCapsPtr qemuCaps,
2441
                             virDomainVirtType type,
2442 2443
                             char ***names,
                             size_t *count)
2444
{
2445 2446
    size_t i;
    char **models = NULL;
2447
    virDomainCapsCPUModelsPtr cpus;
2448 2449 2450 2451 2452

    *count = 0;
    if (names)
        *names = NULL;

2453 2454 2455 2456 2457 2458
    if (type == VIR_DOMAIN_VIRT_KVM)
        cpus = qemuCaps->kvmCPUModels;
    else
        cpus = qemuCaps->tcgCPUModels;

    if (!cpus)
2459 2460
        return 0;

2461
    if (names && VIR_ALLOC_N(models, cpus->nmodels) < 0)
2462 2463
        return -1;

2464 2465
    for (i = 0; i < cpus->nmodels; i++) {
        virDomainCapsCPUModelPtr cpu = cpus->models + i;
2466 2467 2468 2469
        if (models && VIR_STRDUP(models[i], cpu->name) < 0)
            goto error;
    }

2470
    if (names)
2471
        *names = models;
2472
    *count = cpus->nmodels;
2473 2474 2475
    return 0;

 error:
2476
    virStringListFreeCount(models, i);
2477
    return -1;
2478 2479 2480
}


2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491
static virQEMUCapsHostCPUDataPtr
virQEMUCapsGetHostCPUData(virQEMUCapsPtr qemuCaps,
                          virDomainVirtType type)
{
    if (type == VIR_DOMAIN_VIRT_KVM)
        return &qemuCaps->kvmCPU;
    else
        return &qemuCaps->tcgCPU;
}


2492
virCPUDefPtr
2493
virQEMUCapsGetHostModel(virQEMUCapsPtr qemuCaps,
2494 2495
                        virDomainVirtType type,
                        virQEMUCapsHostCPUType cpuType)
2496
{
2497 2498
    virQEMUCapsHostCPUDataPtr cpuData = virQEMUCapsGetHostCPUData(qemuCaps, type);

2499 2500 2501
    switch (cpuType) {
    case VIR_QEMU_CAPS_HOST_CPU_REPORTED:
        return cpuData->reported;
2502 2503 2504

    case VIR_QEMU_CAPS_HOST_CPU_MIGRATABLE:
        return cpuData->migratable;
2505 2506 2507 2508 2509

    case VIR_QEMU_CAPS_HOST_CPU_FULL:
        /* 'full' is non-NULL only if we have data from both QEMU and
         * virCPUGetHost */
        return cpuData->full ? cpuData->full : cpuData->reported;
2510 2511 2512
    }

    return NULL;
2513 2514 2515
}


2516 2517 2518
static void
virQEMUCapsSetHostModel(virQEMUCapsPtr qemuCaps,
                        virDomainVirtType type,
2519
                        virCPUDefPtr reported,
2520 2521
                        virCPUDefPtr migratable,
                        virCPUDefPtr full)
2522
{
2523 2524
    virQEMUCapsHostCPUDataPtr cpuData = virQEMUCapsGetHostCPUData(qemuCaps, type);

2525 2526
    cpuData->reported = reported;
    cpuData->migratable = migratable;
2527
    cpuData->full = full;
2528 2529 2530
}


2531 2532 2533 2534 2535 2536
bool
virQEMUCapsIsCPUModeSupported(virQEMUCapsPtr qemuCaps,
                              virCapsPtr caps,
                              virDomainVirtType type,
                              virCPUMode mode)
{
2537 2538
    virDomainCapsCPUModelsPtr cpus;

2539 2540 2541 2542 2543 2544
    switch (mode) {
    case VIR_CPU_MODE_HOST_PASSTHROUGH:
        return type == VIR_DOMAIN_VIRT_KVM &&
               virQEMUCapsGuestIsNative(caps->host.arch, qemuCaps->arch);

    case VIR_CPU_MODE_HOST_MODEL:
2545 2546
        return !!virQEMUCapsGetHostModel(qemuCaps, type,
                                         VIR_QEMU_CAPS_HOST_CPU_REPORTED);
2547 2548

    case VIR_CPU_MODE_CUSTOM:
2549 2550 2551 2552 2553
        if (type == VIR_DOMAIN_VIRT_KVM)
            cpus = qemuCaps->kvmCPUModels;
        else
            cpus = qemuCaps->tcgCPUModels;
        return cpus && cpus->nmodels > 0;
2554 2555 2556 2557 2558 2559 2560 2561 2562

    case VIR_CPU_MODE_LAST:
        break;
    }

    return false;
}


2563 2564 2565
int virQEMUCapsGetMachineTypesCaps(virQEMUCapsPtr qemuCaps,
                                   size_t *nmachines,
                                   virCapsGuestMachinePtr **machines)
2566 2567 2568 2569
{
    size_t i;

    *machines = NULL;
2570
    *nmachines = qemuCaps->nmachineTypes;
2571

2572 2573 2574 2575
    if (*nmachines &&
        VIR_ALLOC_N(*machines, qemuCaps->nmachineTypes) < 0)
        goto error;

2576
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2577 2578
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
2579
            goto error;
2580
        (*machines)[i] = mach;
2581 2582 2583
        if (qemuCaps->machineTypes[i].alias) {
            if (VIR_STRDUP(mach->name, qemuCaps->machineTypes[i].alias) < 0 ||
                VIR_STRDUP(mach->canonical, qemuCaps->machineTypes[i].name) < 0)
2584
                goto error;
2585
        } else {
2586
            if (VIR_STRDUP(mach->name, qemuCaps->machineTypes[i].name) < 0)
2587
                goto error;
2588
        }
2589
        mach->maxCpus = qemuCaps->machineTypes[i].maxCpus;
2590 2591
    }

2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629
    /* Make sure all canonical machine types also have their own entry so that
     * /capabilities/guest/arch[@name='...']/machine/text() XPath selects all
     * supported machine types.
     */
    i = 0;
    while (i < *nmachines) {
        size_t j;
        bool found = false;
        virCapsGuestMachinePtr machine = (*machines)[i];

        if (!machine->canonical) {
            i++;
            continue;
        }

        for (j = 0; j < *nmachines; j++) {
            if (STREQ(machine->canonical, (*machines)[j]->name)) {
                found = true;
                break;
            }
        }

        if (!found) {
            virCapsGuestMachinePtr mach;
            if (VIR_ALLOC(mach) < 0)
                goto error;
            if (VIR_INSERT_ELEMENT_COPY(*machines, i, *nmachines, mach) < 0) {
                VIR_FREE(mach);
                goto error;
            }
            if (VIR_STRDUP(mach->name, machine->canonical) < 0)
                goto error;
            mach->maxCpus = machine->maxCpus;
            i++;
        }
        i++;
    }

2630 2631
    return 0;

2632
 error:
2633 2634 2635 2636 2637 2638 2639 2640
    virCapabilitiesFreeMachines(*machines, *nmachines);
    *nmachines = 0;
    *machines = NULL;
    return -1;
}



2641

2642 2643
const char *virQEMUCapsGetCanonicalMachine(virQEMUCapsPtr qemuCaps,
                                           const char *name)
2644 2645 2646
{
    size_t i;

2647 2648 2649
    if (!name)
        return NULL;

2650
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2651
        if (!qemuCaps->machineTypes[i].alias)
2652
            continue;
2653 2654
        if (STREQ(qemuCaps->machineTypes[i].alias, name))
            return qemuCaps->machineTypes[i].name;
2655 2656 2657 2658
    }

    return name;
}
2659 2660


2661 2662 2663 2664 2665 2666 2667 2668 2669
int virQEMUCapsGetMachineMaxCpus(virQEMUCapsPtr qemuCaps,
                                 const char *name)
{
    size_t i;

    if (!name)
        return 0;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2670
        if (!qemuCaps->machineTypes[i].maxCpus)
2671
            continue;
2672 2673
        if (STREQ(qemuCaps->machineTypes[i].name, name))
            return qemuCaps->machineTypes[i].maxCpus;
2674 2675 2676 2677 2678 2679
    }

    return 0;
}


2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693
bool virQEMUCapsGetMachineHotplugCpus(virQEMUCapsPtr qemuCaps,
                                      const char *name)
{
    size_t i;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
        if (STREQ_NULLABLE(qemuCaps->machineTypes[i].name, name))
            return qemuCaps->machineTypes[i].hotplugCpus;
    }

    return false;
}


2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717
/**
 * virQEMUCapsSetGICCapabilities:
 * @qemuCaps: QEMU capabilities
 * @capabilities: GIC capabilities
 * @ncapabilities: number of GIC capabilities
 *
 * Set the GIC capabilities for @qemuCaps.
 *
 * The ownership of @capabilities is taken away from the caller, ie. this
 * function will not make a copy of @capabilities, so releasing that memory
 * after it's been called is a bug.
 */
void
virQEMUCapsSetGICCapabilities(virQEMUCapsPtr qemuCaps,
                              virGICCapability *capabilities,
                              size_t ncapabilities)
{
    VIR_FREE(qemuCaps->gicCapabilities);

    qemuCaps->gicCapabilities = capabilities;
    qemuCaps->ngicCapabilities = ncapabilities;
}


2718
static int
2719 2720
virQEMUCapsProbeQMPCommands(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2721 2722 2723 2724 2725 2726 2727
{
    char **commands = NULL;
    int ncommands;

    if ((ncommands = qemuMonitorGetCommands(mon, &commands)) < 0)
        return -1;

2728 2729 2730 2731
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsCommands),
                                  virQEMUCapsCommands,
                                  ncommands, commands);
2732
    virStringListFreeCount(commands, ncommands);
2733

2734 2735 2736 2737
    /* QMP add-fd was introduced in 1.2, but did not support
     * management control of set numbering, and did not have a
     * counterpart -add-fd command line option.  We require the
     * add-fd features from 1.3 or later.  */
2738
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ADD_FD)) {
2739 2740 2741 2742 2743 2744 2745
        int fd = open("/dev/null", O_RDONLY);
        if (fd < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("unable to probe for add-fd"));
            return -1;
        }
        if (qemuMonitorAddFd(mon, 0, fd, "/dev/null") < 0)
2746
            virQEMUCapsClear(qemuCaps, QEMU_CAPS_ADD_FD);
2747 2748 2749
        VIR_FORCE_CLOSE(fd);
    }

2750 2751 2752 2753 2754 2755
    /* Probe for active commit of qemu 2.1 (for now, we are choosing
     * to ignore the fact that qemu 2.0 can also do active commit) */
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_BLOCK_COMMIT) &&
        qemuMonitorSupportsActiveCommit(mon))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ACTIVE_COMMIT);

2756 2757 2758 2759 2760
    return 0;
}


static int
2761 2762
virQEMUCapsProbeQMPEvents(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
2763 2764 2765 2766 2767 2768 2769
{
    char **events = NULL;
    int nevents;

    if ((nevents = qemuMonitorGetEvents(mon, &events)) < 0)
        return -1;

2770 2771 2772 2773
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsEvents),
                                  virQEMUCapsEvents,
                                  nevents, events);
2774
    virStringListFreeCount(events, nevents);
2775 2776 2777 2778 2779

    return 0;
}


2780
static int
2781 2782
virQEMUCapsProbeQMPObjects(virQEMUCapsPtr qemuCaps,
                           qemuMonitorPtr mon)
2783 2784 2785 2786 2787 2788 2789
{
    int nvalues;
    char **values;
    size_t i;

    if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
        return -1;
2790 2791 2792 2793
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
2794
    virStringListFreeCount(values, nvalues);
2795

2796
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
2797
        const char *type = virQEMUCapsObjectProps[i].type;
2798 2799 2800 2801 2802
        int cap = virQEMUCapsObjectProps[i].capsCondition;

        if (cap >= 0 && !virQEMUCapsGet(qemuCaps, cap))
            continue;

2803 2804 2805 2806
        if ((nvalues = qemuMonitorGetObjectProps(mon,
                                                 type,
                                                 &values)) < 0)
            return -1;
2807 2808 2809 2810
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
2811 2812 2813 2814
        virQEMUCapsProcessProps(qemuCaps,
                                ARRAY_CARDINALITY(virQEMUCapsPropObjects),
                                virQEMUCapsPropObjects, type,
                                nvalues, values);
2815
        virStringListFreeCount(values, nvalues);
2816 2817 2818
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2819 2820
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2821 2822 2823 2824 2825 2826

    return 0;
}


static int
2827 2828
virQEMUCapsProbeQMPMachineTypes(virQEMUCapsPtr qemuCaps,
                                qemuMonitorPtr mon)
2829 2830 2831 2832 2833
{
    qemuMonitorMachineInfoPtr *machines = NULL;
    int nmachines = 0;
    int ret = -1;
    size_t i;
2834
    size_t defIdx = 0;
2835 2836

    if ((nmachines = qemuMonitorGetMachines(mon, &machines)) < 0)
2837
        return -1;
2838

2839
    if (VIR_ALLOC_N(qemuCaps->machineTypes, nmachines) < 0)
2840 2841
        goto cleanup;

2842
    for (i = 0; i < nmachines; i++) {
2843
        struct virQEMUCapsMachineType *mach;
2844 2845
        if (STREQ(machines[i]->name, "none"))
            continue;
2846 2847 2848 2849 2850

        mach = &(qemuCaps->machineTypes[qemuCaps->nmachineTypes++]);

        if (VIR_STRDUP(mach->alias, machines[i]->alias) < 0 ||
            VIR_STRDUP(mach->name, machines[i]->name) < 0)
2851
            goto cleanup;
2852 2853

        mach->maxCpus = machines[i]->maxCpus;
2854
        mach->hotplugCpus = machines[i]->hotplugCpus;
2855

2856
        if (machines[i]->isDefault)
2857
            defIdx = qemuCaps->nmachineTypes - 1;
2858
    }
2859 2860

    if (defIdx)
2861
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
2862 2863 2864

    ret = 0;

2865
 cleanup:
2866
    for (i = 0; i < nmachines; i++)
2867 2868 2869 2870 2871 2872 2873
        qemuMonitorMachineInfoFree(machines[i]);
    VIR_FREE(machines);
    return ret;
}


static int
2874
virQEMUCapsProbeQMPCPUDefinitions(virQEMUCapsPtr qemuCaps,
2875 2876
                                  qemuMonitorPtr mon,
                                  bool tcg)
2877
{
2878
    virDomainCapsCPUModelsPtr models;
2879 2880 2881 2882
    qemuMonitorCPUDefInfoPtr *cpus;
    int ncpus;
    int ret = -1;
    size_t i;
2883

2884 2885 2886
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_QUERY_CPU_DEFINITIONS))
        return 0;

2887
    if ((ncpus = qemuMonitorGetCPUDefinitions(mon, &cpus)) < 0)
2888 2889
        return -1;

2890
    if (!(models = virDomainCapsCPUModelsNew(ncpus)))
2891
        goto cleanup;
2892

2893 2894 2895 2896 2897
    if (tcg || !virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
        qemuCaps->tcgCPUModels = models;
    else
        qemuCaps->kvmCPUModels = models;

2898
    for (i = 0; i < ncpus; i++) {
2899 2900 2901 2902 2903 2904 2905 2906
        virDomainCapsCPUUsable usable = VIR_DOMCAPS_CPU_USABLE_UNKNOWN;

        if (cpus[i]->usable == VIR_TRISTATE_BOOL_YES)
            usable = VIR_DOMCAPS_CPU_USABLE_YES;
        else if (cpus[i]->usable == VIR_TRISTATE_BOOL_NO)
            usable = VIR_DOMCAPS_CPU_USABLE_NO;

        if (virDomainCapsCPUModelsAddSteal(models, &cpus[i]->name, usable) < 0)
2907 2908 2909 2910 2911 2912 2913 2914 2915 2916
            goto cleanup;
    }

    ret = 0;

 cleanup:
    for (i = 0; i < ncpus; i++)
        qemuMonitorCPUDefInfoFree(cpus[i]);
    VIR_FREE(cpus);
    return ret;
2917 2918
}

2919 2920
static int
virQEMUCapsProbeQMPHostCPU(virQEMUCapsPtr qemuCaps,
2921 2922
                           qemuMonitorPtr mon,
                           bool tcg)
2923
{
2924
    qemuMonitorCPUModelInfoPtr modelInfo = NULL;
2925 2926
    qemuMonitorCPUModelInfoPtr nonMigratable = NULL;
    virHashTablePtr hash = NULL;
2927
    const char *model;
2928
    qemuMonitorCPUModelExpansionType type;
2929 2930
    virDomainVirtType virtType;
    virQEMUCapsHostCPUDataPtr cpuData;
2931
    int ret = -1;
2932 2933

    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_QUERY_CPU_MODEL_EXPANSION))
2934 2935
        return 0;

2936
    if (tcg || !virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM)) {
2937
        virtType = VIR_DOMAIN_VIRT_QEMU;
2938 2939
        model = "max";
    } else {
2940
        virtType = VIR_DOMAIN_VIRT_KVM;
2941 2942 2943
        model = "host";
    }

2944 2945
    cpuData = virQEMUCapsGetHostCPUData(qemuCaps, virtType);

2946 2947 2948 2949 2950 2951 2952 2953 2954 2955
    /* Some x86_64 features defined in cpu_map.xml use spelling which differ
     * from the one preferred by QEMU. Static expansion would give us only the
     * preferred spelling, thus we need to do a full expansion on the result of
     * the initial static expansion to get all variants of all features.
     */
    if (ARCH_IS_X86(qemuCaps->arch))
        type = QEMU_MONITOR_CPU_MODEL_EXPANSION_STATIC_FULL;
    else
        type = QEMU_MONITOR_CPU_MODEL_EXPANSION_STATIC;

2956 2957
    if (qemuMonitorGetCPUModelExpansion(mon, type, model, true, &modelInfo) < 0)
        goto cleanup;
2958 2959

    /* Try to check migratability of each feature. */
2960
    if (modelInfo &&
2961 2962
        qemuMonitorGetCPUModelExpansion(mon, type, model, false,
                                        &nonMigratable) < 0)
2963
        goto cleanup;
2964 2965 2966 2967 2968 2969 2970

    if (nonMigratable) {
        qemuMonitorCPUPropertyPtr prop;
        qemuMonitorCPUPropertyPtr nmProp;
        size_t i;

        if (!(hash = virHashCreate(0, NULL)))
2971
            goto cleanup;
2972

2973 2974
        for (i = 0; i < modelInfo->nprops; i++) {
            prop = modelInfo->props + i;
2975
            if (virHashAddEntry(hash, prop->name, prop) < 0)
2976
                goto cleanup;
2977 2978 2979 2980 2981 2982 2983 2984 2985
        }

        for (i = 0; i < nonMigratable->nprops; i++) {
            nmProp = nonMigratable->props + i;
            if (!(prop = virHashLookup(hash, nmProp->name)) ||
                prop->type != QEMU_MONITOR_CPU_PROPERTY_BOOLEAN ||
                prop->type != nmProp->type)
                continue;

2986
            if (prop->value.boolean) {
2987
                prop->migratable = VIR_TRISTATE_BOOL_YES;
2988 2989 2990 2991
            } else if (nmProp->value.boolean) {
                prop->value.boolean = true;
                prop->migratable = VIR_TRISTATE_BOOL_NO;
            }
2992 2993
        }

2994
        modelInfo->migratability = true;
2995 2996
    }

2997
    VIR_STEAL_PTR(cpuData->info, modelInfo);
2998 2999 3000 3001 3002
    ret = 0;

 cleanup:
    virHashFree(hash);
    qemuMonitorCPUModelInfoFree(nonMigratable);
3003
    qemuMonitorCPUModelInfoFree(modelInfo);
3004 3005

    return ret;
3006 3007
}

3008 3009
struct tpmTypeToCaps {
    int type;
3010
    virQEMUCapsFlags caps;
3011 3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030
};

static const struct tpmTypeToCaps virQEMUCapsTPMTypesToCaps[] = {
    {
        .type = VIR_DOMAIN_TPM_TYPE_PASSTHROUGH,
        .caps = QEMU_CAPS_DEVICE_TPM_PASSTHROUGH,
    },
};

const struct tpmTypeToCaps virQEMUCapsTPMModelsToCaps[] = {
    {
        .type = VIR_DOMAIN_TPM_MODEL_TIS,
        .caps = QEMU_CAPS_DEVICE_TPM_TIS,
    },
};

static int
virQEMUCapsProbeQMPTPM(virQEMUCapsPtr qemuCaps,
                       qemuMonitorPtr mon)
{
3031 3032
    int nentries;
    size_t i;
3033
    char **entries = NULL;
S
Stefan Berger 已提交
3034

3035 3036 3037 3038 3039 3040 3041
    if ((nentries = qemuMonitorGetTPMModels(mon, &entries)) < 0)
        return -1;

    if (nentries > 0) {
        for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsTPMModelsToCaps); i++) {
            const char *needle = virDomainTPMModelTypeToString(
                virQEMUCapsTPMModelsToCaps[i].type);
3042
            if (virStringListHasString((const char **) entries, needle))
3043 3044 3045 3046
                virQEMUCapsSet(qemuCaps,
                               virQEMUCapsTPMModelsToCaps[i].caps);
        }
    }
3047
    virStringListFree(entries);
3048 3049 3050 3051 3052 3053 3054 3055

    if ((nentries = qemuMonitorGetTPMTypes(mon, &entries)) < 0)
        return -1;

    if (nentries > 0) {
        for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsTPMTypesToCaps); i++) {
            const char *needle = virDomainTPMBackendTypeToString(
                virQEMUCapsTPMTypesToCaps[i].type);
3056
            if (virStringListHasString((const char **) entries, needle))
3057 3058 3059
                virQEMUCapsSet(qemuCaps, virQEMUCapsTPMTypesToCaps[i].caps);
        }
    }
3060
    virStringListFree(entries);
3061 3062 3063 3064

    return 0;
}

3065

3066
static int
3067 3068
virQEMUCapsProbeQMPKVMState(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
3069 3070 3071 3072
{
    bool enabled = false;
    bool present = false;

3073
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
3074 3075 3076 3077 3078 3079
        return 0;

    if (qemuMonitorGetKVMState(mon, &enabled, &present) < 0)
        return -1;

    /* The QEMU_CAPS_KVM flag was initially set according to the QEMU
3080
     * reporting the recognition of 'query-kvm' QMP command. That merely
N
Nehal J Wani 已提交
3081
     * indicates existence of the command though, not whether KVM support
3082 3083 3084 3085 3086 3087
     * is actually available, nor whether it is enabled by default.
     *
     * If it is not present we need to clear the flag, and if it is
     * not enabled by default we need to change the flag.
     */
    if (!present) {
3088
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
3089
    } else if (!enabled) {
3090 3091
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
3092 3093 3094 3095 3096
    }

    return 0;
}

3097 3098 3099 3100 3101 3102 3103 3104
struct virQEMUCapsCommandLineProps {
    const char *option;
    const char *param;
    int flag;
};

static struct virQEMUCapsCommandLineProps virQEMUCapsCommandLine[] = {
    { "machine", "mem-merge", QEMU_CAPS_MEM_MERGE },
3105
    { "machine", "vmport", QEMU_CAPS_MACHINE_VMPORT_OPT },
O
Osier Yang 已提交
3106
    { "drive", "discard", QEMU_CAPS_DRIVE_DISCARD },
3107
    { "drive", "detect-zeroes", QEMU_CAPS_DRIVE_DETECT_ZEROES },
3108
    { "realtime", "mlock", QEMU_CAPS_REALTIME_MLOCK },
3109
    { "boot-opts", "strict", QEMU_CAPS_BOOT_STRICT },
3110
    { "boot-opts", "reboot-timeout", QEMU_CAPS_REBOOT_TIMEOUT },
3111
    { "boot-opts", "splash-time", QEMU_CAPS_SPLASH_TIMEOUT },
3112
    { "spice", "disable-agent-file-xfer", QEMU_CAPS_SPICE_FILE_XFER_DISABLE },
3113
    { "msg", "timestamp", QEMU_CAPS_MSG_TIMESTAMP },
3114
    { "numa", NULL, QEMU_CAPS_NUMA },
3115
    { "drive", "throttling.bps-total-max", QEMU_CAPS_DRIVE_IOTUNE_MAX},
3116 3117
    { "machine", "aes-key-wrap", QEMU_CAPS_AES_KEY_WRAP },
    { "machine", "dea-key-wrap", QEMU_CAPS_DEA_KEY_WRAP },
3118
    { "chardev", "append", QEMU_CAPS_CHARDEV_FILE_APPEND },
3119
    { "spice", "gl", QEMU_CAPS_SPICE_GL },
3120
    { "chardev", "logfile", QEMU_CAPS_CHARDEV_LOGFILE },
3121
    { "name", "debug-threads", QEMU_CAPS_NAME_DEBUG_THREADS },
3122
    { "name", "guest", QEMU_CAPS_NAME_GUEST },
3123
    { "spice", "unix", QEMU_CAPS_SPICE_UNIX },
3124
    { "drive", "throttling.bps-total-max-length", QEMU_CAPS_DRIVE_IOTUNE_MAX_LENGTH },
3125
    { "drive", "throttling.group", QEMU_CAPS_DRIVE_IOTUNE_GROUP },
3126
    { "spice", "rendernode", QEMU_CAPS_SPICE_RENDERNODE },
3127 3128 3129 3130 3131 3132
};

static int
virQEMUCapsProbeQMPCommandLine(virQEMUCapsPtr qemuCaps,
                               qemuMonitorPtr mon)
{
3133
    bool found = false;
3134 3135 3136 3137 3138 3139 3140
    int nvalues;
    char **values;
    size_t i, j;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsCommandLine); i++) {
        if ((nvalues = qemuMonitorGetCommandLineOptionParameters(mon,
                                                                 virQEMUCapsCommandLine[i].option,
3141 3142
                                                                 &values,
                                                                 &found)) < 0)
3143
            return -1;
3144 3145 3146 3147

        if (found && !virQEMUCapsCommandLine[i].param)
            virQEMUCapsSet(qemuCaps, virQEMUCapsCommandLine[i].flag);

3148
        for (j = 0; j < nvalues; j++) {
3149
            if (STREQ_NULLABLE(virQEMUCapsCommandLine[i].param, values[j])) {
3150 3151 3152 3153
                virQEMUCapsSet(qemuCaps, virQEMUCapsCommandLine[i].flag);
                break;
            }
        }
3154
        virStringListFree(values);
3155 3156 3157 3158
    }

    return 0;
}
3159

3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 3170 3171 3172 3173
static int
virQEMUCapsProbeQMPMigrationCapabilities(virQEMUCapsPtr qemuCaps,
                                         qemuMonitorPtr mon)
{
    char **caps = NULL;
    int ncaps;

    if ((ncaps = qemuMonitorGetMigrationCapabilities(mon, &caps)) < 0)
        return -1;

    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsMigration),
                                  virQEMUCapsMigration,
                                  ncaps, caps);
3174
    virStringListFreeCount(caps, ncaps);
3175 3176 3177 3178

    return 0;
}

A
Andrea Bolognani 已提交
3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198
/**
 * virQEMUCapsProbeQMPGICCapabilities:
 * @qemuCaps: QEMU binary capabilities
 * @mon: QEMU monitor
 *
 * Use @mon to obtain information about the GIC capabilities for the
 * corresponding QEMU binary, and store them in @qemuCaps.
 *
 * Returns: 0 on success, <0 on failure
 */
static int
virQEMUCapsProbeQMPGICCapabilities(virQEMUCapsPtr qemuCaps,
                                   qemuMonitorPtr mon)
{
    virGICCapability *caps = NULL;
    int ncaps;

    if ((ncaps = qemuMonitorGetGICCapabilities(mon, &caps)) < 0)
        return -1;

3199
    virQEMUCapsSetGICCapabilities(qemuCaps, caps, ncaps);
A
Andrea Bolognani 已提交
3200 3201 3202 3203

    return 0;
}

3204

3205 3206
static bool
virQEMUCapsCPUFilterFeatures(const char *name,
3207
                             void *opaque)
3208
{
3209 3210 3211 3212 3213
    virQEMUCapsPtr qemuCaps = opaque;

    if (!ARCH_IS_X86(qemuCaps->arch))
        return true;

3214 3215 3216 3217 3218 3219 3220 3221 3222
    if (STREQ(name, "cmt") ||
        STREQ(name, "mbm_total") ||
        STREQ(name, "mbm_local"))
        return false;

    return true;
}


3223 3224 3225 3226 3227 3228 3229
/**
 * Returns  0 when host CPU model provided by QEMU was filled in qemuCaps,
 *          1 when the caller should fall back to using virCapsPtr->host.cpu,
 *         -1 on error.
 */
static int
virQEMUCapsInitCPUModelS390(virQEMUCapsPtr qemuCaps,
3230
                            qemuMonitorCPUModelInfoPtr modelInfo,
3231 3232
                            virCPUDefPtr cpu,
                            bool migratable)
3233
{
3234
    size_t i;
3235

3236
    if (!modelInfo) {
3237
        virReportError(VIR_ERR_INTERNAL_ERROR,
3238 3239 3240 3241
                       _("missing host CPU model info from QEMU capabilities "
                         "for binary %s"),
                       qemuCaps->binary);
        return -1;
3242
    }
J
Jiri Denemark 已提交
3243

3244 3245
    if (VIR_STRDUP(cpu->model, modelInfo->name) < 0 ||
        VIR_ALLOC_N(cpu->features, modelInfo->nprops) < 0)
3246
        return -1;
3247 3248 3249 3250 3251

    cpu->nfeatures_max = modelInfo->nprops;
    cpu->nfeatures = 0;

    for (i = 0; i < modelInfo->nprops; i++) {
3252 3253
        virCPUFeatureDefPtr feature = cpu->features + cpu->nfeatures;
        qemuMonitorCPUPropertyPtr prop = modelInfo->props + i;
3254

3255 3256
        if (prop->type != QEMU_MONITOR_CPU_PROPERTY_BOOLEAN)
            continue;
3257

3258 3259
        if (VIR_STRDUP(feature->name, prop->name) < 0)
            return -1;
3260 3261 3262 3263 3264 3265

        if (!prop->value.boolean ||
            (migratable && prop->migratable == VIR_TRISTATE_BOOL_NO))
            feature->policy = VIR_CPU_FEATURE_DISABLE;
        else
            feature->policy = VIR_CPU_FEATURE_REQUIRE;
3266 3267 3268
        cpu->nfeatures++;
    }

3269 3270
    return 0;
}
3271

3272

3273 3274 3275 3276 3277 3278 3279 3280
/**
 * Returns  0 when host CPU model provided by QEMU was filled in qemuCaps,
 *          1 when the caller should fall back to using virCapsPtr->host.cpu,
 *         -1 on error.
 */
static int
virQEMUCapsInitCPUModelX86(virQEMUCapsPtr qemuCaps,
                           virDomainVirtType type,
3281
                           qemuMonitorCPUModelInfoPtr model,
3282 3283
                           virCPUDefPtr cpu,
                           bool migratable)
3284 3285 3286 3287 3288 3289 3290 3291 3292 3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303
{
    virCPUDataPtr data = NULL;
    unsigned long long sigFamily = 0;
    unsigned long long sigModel = 0;
    size_t nmodels = 0;
    char **models = NULL;
    int ret = -1;
    size_t i;

    if (!model)
        return 1;

    if (!(data = virCPUDataNew(VIR_ARCH_X86_64)))
        goto cleanup;

    for (i = 0; i < model->nprops; i++) {
        qemuMonitorCPUPropertyPtr prop = model->props + i;

        switch (prop->type) {
        case QEMU_MONITOR_CPU_PROPERTY_BOOLEAN:
3304 3305 3306 3307 3308
            if (!prop->value.boolean ||
                (migratable && prop->migratable == VIR_TRISTATE_BOOL_NO))
                continue;

            if (virCPUx86DataAddFeature(data, prop->name) < 0)
3309
                goto cleanup;
3310

3311 3312 3313 3314 3315 3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343 3344 3345 3346
            break;

        case QEMU_MONITOR_CPU_PROPERTY_STRING:
            if (STREQ(prop->name, "vendor") &&
                virCPUx86DataSetVendor(data, prop->value.string) < 0)
                goto cleanup;
            break;

        case QEMU_MONITOR_CPU_PROPERTY_NUMBER:
            if (STREQ(prop->name, "family"))
                sigFamily = prop->value.number;
            else if (STREQ(prop->name, "model"))
                sigModel = prop->value.number;
            break;

        case QEMU_MONITOR_CPU_PROPERTY_LAST:
            break;
        }
    }

    if (virCPUx86DataSetSignature(data, sigFamily, sigModel) < 0)
        goto cleanup;

    if (virQEMUCapsGetCPUDefinitions(qemuCaps, type, &models, &nmodels) < 0 ||
        cpuDecode(cpu, data, (const char **) models, nmodels, NULL) < 0)
        goto cleanup;

    ret = 0;

 cleanup:
    virCPUDataFree(data);
    virStringListFreeCount(models, nmodels);
    return ret;
}


3347 3348
/**
 * Returns  0 when host CPU model provided by QEMU was filled in qemuCaps,
3349
 *          1 when the caller should fall back to other methods
3350 3351
 *         -1 on error.
 */
3352
int
3353
virQEMUCapsInitCPUModel(virQEMUCapsPtr qemuCaps,
3354
                        virDomainVirtType type,
3355 3356
                        virCPUDefPtr cpu,
                        bool migratable)
3357
{
3358
    virQEMUCapsHostCPUDataPtr cpuData = virQEMUCapsGetHostCPUData(qemuCaps, type);
3359 3360
    int ret = 1;

3361
    if (migratable && cpuData->info && !cpuData->info->migratability)
3362 3363
        return 1;

3364 3365 3366 3367 3368 3369 3370
    if (ARCH_IS_S390(qemuCaps->arch)) {
        ret = virQEMUCapsInitCPUModelS390(qemuCaps, cpuData->info,
                                          cpu, migratable);
    } else if (ARCH_IS_X86(qemuCaps->arch)) {
        ret = virQEMUCapsInitCPUModelX86(qemuCaps, type, cpuData->info,
                                         cpu, migratable);
    }
3371

3372 3373 3374
    if (ret == 0)
        cpu->fallback = VIR_CPU_FALLBACK_FORBID;

3375
    return ret;
3376 3377 3378
}


3379 3380 3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395
static virCPUDefPtr
virQEMUCapsNewHostCPUModel(void)
{
    virCPUDefPtr cpu;

    if (VIR_ALLOC(cpu) < 0)
        return NULL;

    cpu->type = VIR_CPU_TYPE_GUEST;
    cpu->mode = VIR_CPU_MODE_CUSTOM;
    cpu->match = VIR_CPU_MATCH_EXACT;
    cpu->fallback = VIR_CPU_FALLBACK_ALLOW;

    return cpu;
}


3396 3397
void
virQEMUCapsInitHostCPUModel(virQEMUCapsPtr qemuCaps,
3398 3399
                            virCapsPtr caps,
                            virDomainVirtType type)
3400 3401
{
    virCPUDefPtr cpu = NULL;
3402
    virCPUDefPtr migCPU = NULL;
3403
    virCPUDefPtr hostCPU = NULL;
3404 3405
    virCPUDefPtr fullCPU = NULL;
    size_t i;
3406
    int rc;
3407

3408 3409 3410
    if (!caps || !virQEMUCapsGuestIsNative(caps->host.arch, qemuCaps->arch))
        return;

3411
    if (!(cpu = virQEMUCapsNewHostCPUModel()))
3412 3413
        goto error;

3414
    if ((rc = virQEMUCapsInitCPUModel(qemuCaps, type, cpu, false)) < 0) {
3415 3416
        goto error;
    } else if (rc == 1) {
3417
        VIR_DEBUG("No host CPU model info from QEMU; probing host CPU directly");
3418

3419 3420 3421
        hostCPU = virQEMUCapsProbeHostCPUForEmulator(caps, qemuCaps, type);
        if (!hostCPU ||
            virCPUDefCopyModelFilter(cpu, hostCPU, true,
3422 3423
                                     virQEMUCapsCPUFilterFeatures,
                                     qemuCaps) < 0)
3424
            goto error;
3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436
    } else if (type == VIR_DOMAIN_VIRT_KVM &&
               virCPUGetHostIsSupported(qemuCaps->arch)) {
        if (!(fullCPU = virCPUGetHost(qemuCaps->arch, VIR_CPU_TYPE_GUEST,
                                      NULL, NULL, 0)))
            goto error;

        for (i = 0; i < cpu->nfeatures; i++) {
            if (cpu->features[i].policy == VIR_CPU_FEATURE_REQUIRE &&
                virCPUDefUpdateFeature(fullCPU, cpu->features[i].name,
                                       VIR_CPU_FEATURE_REQUIRE) < 0)
                goto error;
        }
3437 3438
    }

3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 3449 3450 3451
    if (!(migCPU = virQEMUCapsNewHostCPUModel()))
        goto error;

    if ((rc = virQEMUCapsInitCPUModel(qemuCaps, type, migCPU, true)) < 0) {
        goto error;
    } else if (rc == 1) {
        VIR_DEBUG("CPU migratability not provided by QEMU");

        virCPUDefFree(migCPU);
        if (!(migCPU = virCPUCopyMigratable(qemuCaps->arch, cpu)))
            goto error;
    }

3452
    virQEMUCapsSetHostModel(qemuCaps, type, cpu, migCPU, fullCPU);
3453

3454 3455
 cleanup:
    virCPUDefFree(hostCPU);
3456 3457 3458 3459
    return;

 error:
    virCPUDefFree(cpu);
3460
    virCPUDefFree(migCPU);
3461
    virCPUDefFree(fullCPU);
3462
    virResetLastError();
3463
    goto cleanup;
3464 3465 3466
}


3467 3468 3469 3470 3471
void
virQEMUCapsSetCPUModelInfo(virQEMUCapsPtr qemuCaps,
                           virDomainVirtType type,
                           qemuMonitorCPUModelInfoPtr modelInfo)
{
3472 3473 3474
    virQEMUCapsHostCPUDataPtr cpuData = virQEMUCapsGetHostCPUData(qemuCaps, type);

    cpuData->info = modelInfo;
3475 3476 3477
}


3478 3479
static int
virQEMUCapsLoadHostCPUModelInfo(virQEMUCapsPtr qemuCaps,
3480 3481
                                xmlXPathContextPtr ctxt,
                                virDomainVirtType virtType)
3482 3483 3484
{
    char *str = NULL;
    xmlNodePtr hostCPUNode;
3485
    xmlNodePtr *nodes = NULL;
3486 3487 3488 3489 3490
    xmlNodePtr oldnode = ctxt->node;
    qemuMonitorCPUModelInfoPtr hostCPU = NULL;
    int ret = -1;
    size_t i;
    int n;
3491
    int val;
3492

3493 3494 3495 3496 3497 3498
    if (virtType == VIR_DOMAIN_VIRT_KVM)
        hostCPUNode = virXPathNode("./hostCPU[@type='kvm']", ctxt);
    else
        hostCPUNode = virXPathNode("./hostCPU[@type='tcg']", ctxt);

    if (!hostCPUNode) {
3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512
        ret = 0;
        goto cleanup;
    }

    if (VIR_ALLOC(hostCPU) < 0)
        goto cleanup;

    if (!(hostCPU->name = virXMLPropString(hostCPUNode, "model"))) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("missing host CPU model name in QEMU "
                         "capabilities cache"));
        goto cleanup;
    }

3513 3514 3515 3516 3517 3518 3519 3520 3521
    if (!(str = virXMLPropString(hostCPUNode, "migratability")) ||
        (val = virTristateBoolTypeFromString(str)) <= 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("invalid migratability value for host CPU model"));
        goto cleanup;
    }
    hostCPU->migratability = val == VIR_TRISTATE_BOOL_YES;
    VIR_FREE(str);

3522 3523
    ctxt->node = hostCPUNode;

3524
    if ((n = virXPathNodeSet("./property", ctxt, &nodes)) > 0) {
3525 3526 3527 3528 3529 3530
        if (VIR_ALLOC_N(hostCPU->props, n) < 0)
            goto cleanup;

        hostCPU->nprops = n;

        for (i = 0; i < n; i++) {
3531 3532 3533 3534 3535
            qemuMonitorCPUPropertyPtr prop = hostCPU->props + i;

            ctxt->node = nodes[i];

            if (!(prop->name = virXMLPropString(ctxt->node, "name"))) {
3536 3537
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing 'name' attribute for a host CPU"
3538
                                 " model property in QEMU capabilities cache"));
3539 3540 3541
                goto cleanup;
            }

3542
            if (!(str = virXMLPropString(ctxt->node, "type")) ||
3543
                (val = qemuMonitorCPUPropertyTypeFromString(str)) < 0) {
3544
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
3545 3546
                               _("missing or invalid CPU model property type "
                                 "in QEMU capabilities cache"));
3547 3548 3549
                goto cleanup;
            }
            VIR_FREE(str);
3550

3551
            prop->type = val;
3552 3553 3554 3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 3573 3574 3575 3576 3577 3578 3579 3580 3581 3582
            switch (prop->type) {
            case QEMU_MONITOR_CPU_PROPERTY_BOOLEAN:
                if (virXPathBoolean("./@value='true'", ctxt))
                    prop->value.boolean = true;
                break;

            case QEMU_MONITOR_CPU_PROPERTY_STRING:
                prop->value.string = virXMLPropString(ctxt->node, "value");
                if (!prop->value.string) {
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   _("invalid string value for '%s' host CPU "
                                     "model property in QEMU capabilities cache"),
                                   prop->name);
                    goto cleanup;
                }
                break;

            case QEMU_MONITOR_CPU_PROPERTY_NUMBER:
                if (virXPathLongLong("string(./@value)", ctxt,
                                     &prop->value.number) < 0) {
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   _("invalid number value for '%s' host CPU "
                                     "model property in QEMU capabilities cache"),
                                   prop->name);
                    goto cleanup;
                }
                break;

            case QEMU_MONITOR_CPU_PROPERTY_LAST:
                break;
            }
3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595

            if ((str = virXMLPropString(ctxt->node, "migratable"))) {
                if ((val = virTristateBoolTypeFromString(str)) <= 0) {
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   _("unknown migratable value for '%s' host "
                                     "CPU model property"),
                                   prop->name);
                    goto cleanup;
                }

                prop->migratable = val;
                VIR_FREE(str);
            }
3596 3597 3598
        }
    }

3599
    virQEMUCapsSetCPUModelInfo(qemuCaps, virtType, hostCPU);
3600 3601 3602 3603 3604 3605
    hostCPU = NULL;
    ret = 0;

 cleanup:
    ctxt->node = oldnode;
    VIR_FREE(str);
3606
    VIR_FREE(nodes);
3607 3608 3609 3610 3611
    qemuMonitorCPUModelInfoFree(hostCPU);
    return ret;
}


3612 3613
static int
virQEMUCapsLoadCPUModels(virQEMUCapsPtr qemuCaps,
3614 3615
                         xmlXPathContextPtr ctxt,
                         virDomainVirtType type)
3616
{
3617
    virDomainCapsCPUModelsPtr cpus = NULL;
3618 3619 3620 3621 3622 3623
    xmlNodePtr *nodes = NULL;
    char *str = NULL;
    size_t i;
    int n;
    int ret = -1;

3624 3625 3626 3627 3628 3629
    if (type == VIR_DOMAIN_VIRT_KVM)
        n = virXPathNodeSet("./cpu[@type='kvm']", ctxt, &nodes);
    else
        n = virXPathNodeSet("./cpu[@type='tcg']", ctxt, &nodes);

    if (n < 0) {
3630 3631 3632 3633 3634 3635 3636 3637 3638 3639
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("failed to parse qemu capabilities cpus"));
        goto cleanup;
    }

    if (n == 0) {
        ret = 0;
        goto cleanup;
    }

3640
    if (!(cpus = virDomainCapsCPUModelsNew(n)))
3641 3642
        goto cleanup;

3643 3644 3645 3646 3647
    if (type == VIR_DOMAIN_VIRT_KVM)
        qemuCaps->kvmCPUModels = cpus;
    else
        qemuCaps->tcgCPUModels = cpus;

3648
    for (i = 0; i < n; i++) {
3649 3650 3651 3652 3653 3654 3655 3656 3657 3658
        int usable = VIR_DOMCAPS_CPU_USABLE_UNKNOWN;

        if ((str = virXMLPropString(nodes[i], "usable")) &&
            (usable = virDomainCapsCPUUsableTypeFromString(str)) < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown value '%s' in attribute 'usable'"), str);
            goto cleanup;
        }
        VIR_FREE(str);

3659 3660 3661 3662 3663 3664
        if (!(str = virXMLPropString(nodes[i], "name"))) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("missing cpu name in QEMU capabilities cache"));
            goto cleanup;
        }

3665
        if (virDomainCapsCPUModelsAddSteal(cpus, &str, usable) < 0)
3666 3667 3668 3669 3670 3671 3672 3673 3674 3675 3676 3677
            goto cleanup;
    }

    ret = 0;

 cleanup:
    VIR_FREE(nodes);
    VIR_FREE(str);
    return ret;
}


3678 3679 3680 3681 3682 3683
/*
 * Parsing a doc that looks like
 *
 * <qemuCaps>
 *   <qemuctime>234235253</qemuctime>
 *   <selfctime>234235253</selfctime>
3684
 *   <selfvers>1002016</selfvers>
3685 3686 3687 3688 3689 3690
 *   <usedQMP/>
 *   <flag name='foo'/>
 *   <flag name='bar'/>
 *   ...
 *   <cpu name="pentium3"/>
 *   ...
3691
 *   <machine name="pc-1.0" alias="pc" hotplugCpus='yes' maxCpus="4"/>
3692 3693 3694
 *   ...
 * </qemuCaps>
 */
3695
int
3696 3697 3698 3699
virQEMUCapsLoadCache(virCapsPtr caps,
                     virQEMUCapsPtr qemuCaps,
                     const char *filename,
                     time_t *selfctime,
3700
                     unsigned long *selfvers)
3701 3702 3703 3704 3705 3706 3707
{
    xmlDocPtr doc = NULL;
    int ret = -1;
    size_t i;
    int n;
    xmlNodePtr *nodes = NULL;
    xmlXPathContextPtr ctxt = NULL;
J
Ján Tomko 已提交
3708
    char *str = NULL;
3709
    long long int l;
3710
    unsigned long lu;
3711 3712 3713 3714 3715 3716 3717 3718 3719 3720 3721 3722 3723 3724 3725 3726 3727 3728 3729 3730 3731 3732 3733 3734

    if (!(doc = virXMLParseFile(filename)))
        goto cleanup;

    if (!(ctxt = xmlXPathNewContext(doc))) {
        virReportOOMError();
        goto cleanup;
    }

    ctxt->node = xmlDocGetRootElement(doc);

    if (STRNEQ((const char *)ctxt->node->name, "qemuCaps")) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("unexpected root element <%s>, "
                         "expecting <qemuCaps>"),
                       ctxt->node->name);
        goto cleanup;
    }

    if (virXPathLongLong("string(./qemuctime)", ctxt, &l) < 0) {
        virReportError(VIR_ERR_XML_ERROR, "%s",
                       _("missing qemuctime in QEMU capabilities XML"));
        goto cleanup;
    }
3735
    qemuCaps->ctime = (time_t)l;
3736 3737 3738 3739 3740 3741 3742 3743

    if (virXPathLongLong("string(./selfctime)", ctxt, &l) < 0) {
        virReportError(VIR_ERR_XML_ERROR, "%s",
                       _("missing selfctime in QEMU capabilities XML"));
        goto cleanup;
    }
    *selfctime = (time_t)l;

3744 3745 3746 3747
    *selfvers = 0;
    if (virXPathULong("string(./selfvers)", ctxt, &lu) == 0)
        *selfvers = lu;

3748 3749 3750 3751 3752 3753 3754 3755 3756
    qemuCaps->usedQMP = virXPathBoolean("count(./usedQMP) > 0",
                                        ctxt) > 0;

    if ((n = virXPathNodeSet("./flag", ctxt, &nodes)) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("failed to parse qemu capabilities flags"));
        goto cleanup;
    }
    VIR_DEBUG("Got flags %d", n);
3757 3758 3759 3760 3761 3762 3763 3764 3765 3766 3767 3768
    for (i = 0; i < n; i++) {
        int flag;
        if (!(str = virXMLPropString(nodes[i], "name"))) {
            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                           _("missing flag name in QEMU capabilities cache"));
            goto cleanup;
        }
        flag = virQEMUCapsTypeFromString(str);
        if (flag < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Unknown qemu capabilities flag %s"), str);
            goto cleanup;
3769
        }
3770 3771
        VIR_FREE(str);
        virQEMUCapsSet(qemuCaps, flag);
3772 3773 3774 3775 3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786
    }
    VIR_FREE(nodes);

    if (virXPathUInt("string(./version)", ctxt, &qemuCaps->version) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("missing version in QEMU capabilities cache"));
        goto cleanup;
    }

    if (virXPathUInt("string(./kvmVersion)", ctxt, &qemuCaps->kvmVersion) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("missing version in QEMU capabilities cache"));
        goto cleanup;
    }

3787 3788 3789 3790 3791 3792
    if (virXPathBoolean("boolean(./package)", ctxt) > 0) {
        qemuCaps->package = virXPathString("string(./package)", ctxt);
        if (!qemuCaps->package &&
            VIR_STRDUP(qemuCaps->package, "") < 0)
            goto cleanup;
    }
3793

3794 3795 3796 3797 3798 3799 3800 3801 3802 3803
    if (!(str = virXPathString("string(./arch)", ctxt))) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("missing arch in QEMU capabilities cache"));
        goto cleanup;
    }
    if (!(qemuCaps->arch = virArchFromString(str))) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unknown arch %s in QEMU capabilities cache"), str);
        goto cleanup;
    }
J
Ján Tomko 已提交
3804
    VIR_FREE(str);
3805

3806 3807
    if (virQEMUCapsLoadHostCPUModelInfo(qemuCaps, ctxt, VIR_DOMAIN_VIRT_KVM) < 0 ||
        virQEMUCapsLoadHostCPUModelInfo(qemuCaps, ctxt, VIR_DOMAIN_VIRT_QEMU) < 0)
3808 3809
        goto cleanup;

3810 3811
    if (virQEMUCapsLoadCPUModels(qemuCaps, ctxt, VIR_DOMAIN_VIRT_KVM) < 0 ||
        virQEMUCapsLoadCPUModels(qemuCaps, ctxt, VIR_DOMAIN_VIRT_QEMU) < 0)
3812 3813 3814 3815 3816 3817 3818 3819 3820
        goto cleanup;

    if ((n = virXPathNodeSet("./machine", ctxt, &nodes)) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("failed to parse qemu capabilities machines"));
        goto cleanup;
    }
    if (n > 0) {
        qemuCaps->nmachineTypes = n;
3821
        if (VIR_ALLOC_N(qemuCaps->machineTypes, qemuCaps->nmachineTypes) < 0)
3822 3823 3824
            goto cleanup;

        for (i = 0; i < n; i++) {
3825
            if (!(qemuCaps->machineTypes[i].name = virXMLPropString(nodes[i], "name"))) {
3826 3827 3828 3829
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing machine name in QEMU capabilities cache"));
                goto cleanup;
            }
3830
            qemuCaps->machineTypes[i].alias = virXMLPropString(nodes[i], "alias");
3831 3832 3833

            str = virXMLPropString(nodes[i], "maxCpus");
            if (str &&
3834
                virStrToLong_ui(str, NULL, 10, &(qemuCaps->machineTypes[i].maxCpus)) < 0) {
3835 3836 3837 3838
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("malformed machine cpu count in QEMU capabilities cache"));
                goto cleanup;
            }
J
Ján Tomko 已提交
3839
            VIR_FREE(str);
3840 3841 3842 3843 3844

            str = virXMLPropString(nodes[i], "hotplugCpus");
            if (STREQ_NULLABLE(str, "yes"))
                qemuCaps->machineTypes[i].hotplugCpus = true;
            VIR_FREE(str);
3845 3846 3847 3848
        }
    }
    VIR_FREE(nodes);

A
Andrea Bolognani 已提交
3849 3850 3851 3852 3853 3854 3855 3856 3857 3858 3859 3860 3861 3862 3863 3864 3865 3866 3867 3868 3869 3870 3871 3872 3873 3874 3875 3876 3877 3878 3879 3880 3881 3882 3883 3884 3885 3886 3887 3888 3889 3890 3891 3892 3893 3894 3895 3896 3897 3898 3899 3900 3901 3902 3903 3904 3905 3906 3907 3908 3909 3910 3911 3912 3913 3914
    if ((n = virXPathNodeSet("./gic", ctxt, &nodes)) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("failed to parse qemu capabilities gic"));
        goto cleanup;
    }
    if (n > 0) {
        unsigned int uintValue;
        bool boolValue;

        qemuCaps->ngicCapabilities = n;
        if (VIR_ALLOC_N(qemuCaps->gicCapabilities, n) < 0)
            goto cleanup;

        for (i = 0; i < n; i++) {
            virGICCapabilityPtr cap = &qemuCaps->gicCapabilities[i];

            if (!(str = virXMLPropString(nodes[i], "version"))) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing GIC version "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            if (virStrToLong_ui(str, NULL, 10, &uintValue) < 0) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("malformed GIC version "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            cap->version = uintValue;
            VIR_FREE(str);

            if (!(str = virXMLPropString(nodes[i], "kernel"))) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing in-kernel GIC information "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            if (!(boolValue = STREQ(str, "yes")) && STRNEQ(str, "no")) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("malformed in-kernel GIC information "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            if (boolValue)
                cap->implementation |= VIR_GIC_IMPLEMENTATION_KERNEL;
            VIR_FREE(str);

            if (!(str = virXMLPropString(nodes[i], "emulated"))) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing emulated GIC information "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            if (!(boolValue = STREQ(str, "yes")) && STRNEQ(str, "no")) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("malformed emulated GIC information "
                                 "in QEMU capabilities cache"));
                goto cleanup;
            }
            if (boolValue)
                cap->implementation |= VIR_GIC_IMPLEMENTATION_EMULATED;
            VIR_FREE(str);
        }
    }
    VIR_FREE(nodes);

3915 3916
    virQEMUCapsInitHostCPUModel(qemuCaps, caps, VIR_DOMAIN_VIRT_KVM);
    virQEMUCapsInitHostCPUModel(qemuCaps, caps, VIR_DOMAIN_VIRT_QEMU);
3917

3918
    ret = 0;
3919
 cleanup:
J
Ján Tomko 已提交
3920
    VIR_FREE(str);
3921 3922 3923 3924 3925 3926 3927
    VIR_FREE(nodes);
    xmlXPathFreeContext(ctxt);
    xmlFreeDoc(doc);
    return ret;
}


3928 3929
static void
virQEMUCapsFormatHostCPUModelInfo(virQEMUCapsPtr qemuCaps,
3930 3931
                                  virBufferPtr buf,
                                  virDomainVirtType type)
3932
{
3933 3934 3935
    virQEMUCapsHostCPUDataPtr cpuData = virQEMUCapsGetHostCPUData(qemuCaps, type);
    qemuMonitorCPUModelInfoPtr model = cpuData->info;
    const char *typeStr = type == VIR_DOMAIN_VIRT_KVM ? "kvm" : "tcg";
3936 3937
    size_t i;

3938 3939 3940
    if (!model)
        return;

3941 3942 3943 3944
    virBufferAsprintf(buf,
                      "<hostCPU type='%s' model='%s' migratability='%s'>\n",
                      typeStr, model->name,
                      model->migratability ? "yes" : "no");
3945 3946 3947
    virBufferAdjustIndent(buf, 2);

    for (i = 0; i < model->nprops; i++) {
3948 3949 3950 3951 3952 3953 3954 3955 3956 3957 3958 3959 3960 3961 3962 3963 3964 3965 3966 3967 3968 3969 3970
        qemuMonitorCPUPropertyPtr prop = model->props + i;

        virBufferAsprintf(buf, "<property name='%s' type='%s' ",
                          prop->name,
                          qemuMonitorCPUPropertyTypeToString(prop->type));

        switch (prop->type) {
        case QEMU_MONITOR_CPU_PROPERTY_BOOLEAN:
            virBufferAsprintf(buf, "value='%s'",
                              prop->value.boolean ? "true" : "false");
            break;

        case QEMU_MONITOR_CPU_PROPERTY_STRING:
            virBufferEscapeString(buf, "value='%s'", prop->value.string);
            break;

        case QEMU_MONITOR_CPU_PROPERTY_NUMBER:
            virBufferAsprintf(buf, "value='%lld'", prop->value.number);
            break;

        case QEMU_MONITOR_CPU_PROPERTY_LAST:
            break;
        }
3971 3972 3973 3974 3975

        if (prop->migratable > 0)
            virBufferAsprintf(buf, " migratable='%s'",
                              virTristateBoolTypeToString(prop->migratable));

3976
        virBufferAddLit(buf, "/>\n");
3977 3978 3979 3980 3981 3982 3983
    }

    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</hostCPU>\n");
}


3984 3985
static void
virQEMUCapsFormatCPUModels(virQEMUCapsPtr qemuCaps,
3986 3987
                           virBufferPtr buf,
                           virDomainVirtType type)
3988
{
3989 3990
    virDomainCapsCPUModelsPtr cpus;
    const char *typeStr;
3991 3992
    size_t i;

3993 3994 3995 3996 3997 3998 3999 4000 4001 4002 4003 4004
    if (type == VIR_DOMAIN_VIRT_KVM) {
        typeStr = "kvm";
        cpus = qemuCaps->kvmCPUModels;
    } else {
        typeStr = "tcg";
        cpus = qemuCaps->tcgCPUModels;
    }

    if (!cpus)
        return;

    for (i = 0; i < cpus->nmodels; i++) {
4005 4006
        virDomainCapsCPUModelPtr cpu = cpus->models + i;

4007
        virBufferAsprintf(buf, "<cpu type='%s' ", typeStr);
4008 4009 4010 4011 4012 4013
        virBufferEscapeString(buf, "name='%s'", cpu->name);
        if (cpu->usable) {
            virBufferAsprintf(buf, " usable='%s'",
                              virDomainCapsCPUUsableTypeToString(cpu->usable));
        }
        virBufferAddLit(buf, "/>\n");
4014 4015 4016 4017
    }
}


4018
char *
4019 4020 4021
virQEMUCapsFormatCache(virQEMUCapsPtr qemuCaps,
                       time_t selfCTime,
                       unsigned long selfVersion)
4022 4023
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
4024
    char *ret = NULL;
4025 4026 4027
    size_t i;

    virBufferAddLit(&buf, "<qemuCaps>\n");
4028
    virBufferAdjustIndent(&buf, 2);
4029

4030
    virBufferAsprintf(&buf, "<qemuctime>%llu</qemuctime>\n",
4031
                      (long long) qemuCaps->ctime);
4032
    virBufferAsprintf(&buf, "<selfctime>%llu</selfctime>\n",
4033
                      (long long) selfCTime);
4034
    virBufferAsprintf(&buf, "<selfvers>%lu</selfvers>\n",
4035
                      (unsigned long) selfVersion);
4036 4037

    if (qemuCaps->usedQMP)
4038
        virBufferAddLit(&buf, "<usedQMP/>\n");
4039 4040 4041

    for (i = 0; i < QEMU_CAPS_LAST; i++) {
        if (virQEMUCapsGet(qemuCaps, i)) {
4042
            virBufferAsprintf(&buf, "<flag name='%s'/>\n",
4043 4044 4045 4046
                              virQEMUCapsTypeToString(i));
        }
    }

4047
    virBufferAsprintf(&buf, "<version>%d</version>\n",
4048 4049
                      qemuCaps->version);

4050
    virBufferAsprintf(&buf, "<kvmVersion>%d</kvmVersion>\n",
4051 4052
                      qemuCaps->kvmVersion);

4053 4054 4055 4056
    if (qemuCaps->package)
        virBufferAsprintf(&buf, "<package>%s</package>\n",
                          qemuCaps->package);

4057
    virBufferAsprintf(&buf, "<arch>%s</arch>\n",
4058 4059
                      virArchToString(qemuCaps->arch));

4060 4061
    virQEMUCapsFormatHostCPUModelInfo(qemuCaps, &buf, VIR_DOMAIN_VIRT_KVM);
    virQEMUCapsFormatHostCPUModelInfo(qemuCaps, &buf, VIR_DOMAIN_VIRT_QEMU);
4062

4063 4064
    virQEMUCapsFormatCPUModels(qemuCaps, &buf, VIR_DOMAIN_VIRT_KVM);
    virQEMUCapsFormatCPUModels(qemuCaps, &buf, VIR_DOMAIN_VIRT_QEMU);
4065 4066

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
4067
        virBufferEscapeString(&buf, "<machine name='%s'",
4068 4069
                              qemuCaps->machineTypes[i].name);
        if (qemuCaps->machineTypes[i].alias)
4070
            virBufferEscapeString(&buf, " alias='%s'",
4071
                              qemuCaps->machineTypes[i].alias);
4072 4073
        if (qemuCaps->machineTypes[i].hotplugCpus)
            virBufferAddLit(&buf, " hotplugCpus='yes'");
4074
        virBufferAsprintf(&buf, " maxCpus='%u'/>\n",
4075
                          qemuCaps->machineTypes[i].maxCpus);
4076 4077
    }

A
Andrea Bolognani 已提交
4078 4079 4080 4081 4082 4083 4084 4085 4086 4087 4088 4089 4090 4091 4092 4093
    for (i = 0; i < qemuCaps->ngicCapabilities; i++) {
        virGICCapabilityPtr cap;
        bool kernel;
        bool emulated;

        cap = &qemuCaps->gicCapabilities[i];
        kernel = (cap->implementation & VIR_GIC_IMPLEMENTATION_KERNEL);
        emulated = (cap->implementation & VIR_GIC_IMPLEMENTATION_EMULATED);

        virBufferAsprintf(&buf,
                          "<gic version='%d' kernel='%s' emulated='%s'/>\n",
                          cap->version,
                          kernel ? "yes" : "no",
                          emulated ? "yes" : "no");
    }

4094
    virBufferAdjustIndent(&buf, -2);
4095 4096
    virBufferAddLit(&buf, "</qemuCaps>\n");

4097 4098 4099 4100 4101 4102 4103 4104 4105 4106 4107 4108
    if (virBufferCheckError(&buf) == 0)
        ret = virBufferContentAndReset(&buf);

    return ret;
}


static int
virQEMUCapsSaveCache(virQEMUCapsPtr qemuCaps, const char *filename)
{
    char *xml = NULL;
    int ret = -1;
4109

4110 4111 4112
    xml = virQEMUCapsFormatCache(qemuCaps,
                                 virGetSelfLastChanged(),
                                 LIBVIR_VERSION_NUMBER);
4113 4114 4115 4116 4117 4118 4119 4120 4121 4122 4123 4124 4125 4126 4127 4128 4129 4130 4131 4132 4133 4134 4135 4136 4137 4138 4139 4140 4141 4142 4143 4144 4145 4146 4147 4148 4149 4150 4151 4152 4153 4154 4155 4156 4157 4158 4159 4160 4161 4162 4163 4164 4165 4166 4167 4168 4169 4170 4171 4172 4173 4174 4175 4176

    if (virFileWriteStr(filename, xml, 0600) < 0) {
        virReportSystemError(errno,
                             _("Failed to save '%s' for '%s'"),
                             filename, qemuCaps->binary);
        goto cleanup;
    }

    VIR_DEBUG("Saved caps '%s' for '%s' with (%lld, %lld)",
              filename, qemuCaps->binary,
              (long long)qemuCaps->ctime,
              (long long)virGetSelfLastChanged());

    ret = 0;
 cleanup:
    VIR_FREE(xml);
    return ret;
}

static int
virQEMUCapsRememberCached(virQEMUCapsPtr qemuCaps, const char *cacheDir)
{
    char *capsdir = NULL;
    char *capsfile = NULL;
    int ret = -1;
    char *binaryhash = NULL;

    if (virAsprintf(&capsdir, "%s/capabilities", cacheDir) < 0)
        goto cleanup;

    if (virCryptoHashString(VIR_CRYPTO_HASH_SHA256,
                            qemuCaps->binary,
                            &binaryhash) < 0)
        goto cleanup;

    if (virAsprintf(&capsfile, "%s/%s.xml", capsdir, binaryhash) < 0)
        goto cleanup;

    if (virFileMakePath(capsdir) < 0) {
        virReportSystemError(errno,
                             _("Unable to create directory '%s'"),
                             capsdir);
        goto cleanup;
    }

    if (virQEMUCapsSaveCache(qemuCaps, capsfile) < 0)
        goto cleanup;

    ret = 0;
 cleanup:
    VIR_FREE(binaryhash);
    VIR_FREE(capsfile);
    VIR_FREE(capsdir);
    return ret;
}


static void
virQEMUCapsReset(virQEMUCapsPtr qemuCaps)
{
    size_t i;

    virBitmapClearAll(qemuCaps->flags);
    qemuCaps->version = qemuCaps->kvmVersion = 0;
4177
    VIR_FREE(qemuCaps->package);
4178 4179 4180
    qemuCaps->arch = VIR_ARCH_NONE;
    qemuCaps->usedQMP = false;

4181 4182 4183 4184
    virObjectUnref(qemuCaps->kvmCPUModels);
    qemuCaps->kvmCPUModels = NULL;
    virObjectUnref(qemuCaps->tcgCPUModels);
    qemuCaps->tcgCPUModels = NULL;
4185 4186

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
4187 4188
        VIR_FREE(qemuCaps->machineTypes[i].name);
        VIR_FREE(qemuCaps->machineTypes[i].alias);
4189 4190 4191
    }
    VIR_FREE(qemuCaps->machineTypes);
    qemuCaps->nmachineTypes = 0;
A
Andrea Bolognani 已提交
4192 4193 4194

    VIR_FREE(qemuCaps->gicCapabilities);
    qemuCaps->ngicCapabilities = 0;
4195

4196 4197
    virQEMUCapsHostCPUDataClear(&qemuCaps->kvmCPU);
    virQEMUCapsHostCPUDataClear(&qemuCaps->tcgCPU);
4198 4199 4200 4201
}


static int
4202 4203
virQEMUCapsInitCached(virCapsPtr caps,
                      virQEMUCapsPtr qemuCaps,
4204 4205 4206
                      const char *cacheDir,
                      uid_t runUid,
                      gid_t runGid)
4207 4208 4209 4210 4211 4212
{
    char *capsdir = NULL;
    char *capsfile = NULL;
    int ret = -1;
    char *binaryhash = NULL;
    struct stat sb;
4213
    time_t qemuctime = qemuCaps->ctime;
4214
    time_t selfctime;
4215
    unsigned long selfvers;
4216 4217 4218 4219 4220 4221 4222 4223 4224 4225 4226 4227 4228 4229 4230 4231 4232 4233 4234 4235 4236 4237 4238 4239 4240 4241 4242 4243 4244 4245 4246 4247

    if (virAsprintf(&capsdir, "%s/capabilities", cacheDir) < 0)
        goto cleanup;

    if (virCryptoHashString(VIR_CRYPTO_HASH_SHA256,
                            qemuCaps->binary,
                            &binaryhash) < 0)
        goto cleanup;

    if (virAsprintf(&capsfile, "%s/%s.xml", capsdir, binaryhash) < 0)
        goto cleanup;

    if (virFileMakePath(capsdir) < 0) {
        virReportSystemError(errno,
                             _("Unable to create directory '%s'"),
                             capsdir);
        goto cleanup;
    }

    if (stat(capsfile, &sb) < 0) {
        if (errno == ENOENT) {
            VIR_DEBUG("No cached capabilities '%s' for '%s'",
                      capsfile, qemuCaps->binary);
            ret = 0;
            goto cleanup;
        }
        virReportSystemError(errno,
                             _("Unable to access cache '%s' for '%s'"),
                             capsfile, qemuCaps->binary);
        goto cleanup;
    }

4248
    if (virQEMUCapsLoadCache(caps, qemuCaps, capsfile,
4249
                             &selfctime, &selfvers) < 0) {
4250
        VIR_WARN("Failed to load cached caps from '%s' for '%s': %s",
4251
                 capsfile, qemuCaps->binary, virGetLastErrorMessage());
4252
        virResetLastError();
4253
        goto discard;
4254 4255
    }

4256
    if (!virQEMUCapsIsValid(qemuCaps, qemuctime, runUid, runGid))
4257 4258
        goto discard;

4259
    /* Discard cache if QEMU binary or libvirtd changed */
4260
    if (selfctime != virGetSelfLastChanged() ||
4261
        selfvers != LIBVIR_VERSION_NUMBER) {
4262 4263 4264
        VIR_DEBUG("Outdated capabilities for '%s': libvirt changed "
                  "(%lld vs %lld, %lu vs %lu)",
                  qemuCaps->binary,
4265 4266
                  (long long)selfctime, (long long)virGetSelfLastChanged(),
                  selfvers, (unsigned long)LIBVIR_VERSION_NUMBER);
4267
        goto discard;
4268 4269 4270 4271 4272 4273 4274 4275
    }

    VIR_DEBUG("Loaded '%s' for '%s' ctime %lld usedQMP=%d",
              capsfile, qemuCaps->binary,
              (long long)qemuCaps->ctime, qemuCaps->usedQMP);

    ret = 1;
 cleanup:
4276
    qemuCaps->ctime = qemuctime;
4277 4278 4279 4280
    VIR_FREE(binaryhash);
    VIR_FREE(capsfile);
    VIR_FREE(capsdir);
    return ret;
4281 4282 4283 4284 4285 4286 4287 4288

 discard:
    VIR_DEBUG("Dropping cached capabilities '%s' for '%s'",
              capsfile, qemuCaps->binary);
    ignore_value(unlink(capsfile));
    virQEMUCapsReset(qemuCaps);
    ret = 0;
    goto cleanup;
4289 4290 4291
}


4292 4293
#define QEMU_SYSTEM_PREFIX "qemu-system-"

4294
static int
4295
virQEMUCapsInitHelp(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid, const char *qmperr)
4296
{
4297
    virCommandPtr cmd = NULL;
4298
    bool is_kvm;
4299
    char *help = NULL;
4300 4301
    int ret = -1;
    const char *tmp;
4302

4303
    VIR_DEBUG("qemuCaps=%p", qemuCaps);
4304

4305
    tmp = strstr(qemuCaps->binary, QEMU_SYSTEM_PREFIX);
4306 4307
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
4308

4309
        qemuCaps->arch = virQEMUCapsArchFromString(tmp);
4310
    } else {
4311
        qemuCaps->arch = virArchFromHost();
4312 4313
    }

4314
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, NULL, runUid, runGid);
4315 4316 4317 4318
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
4319
        goto cleanup;
4320

4321 4322 4323 4324 4325
    if (virQEMUCapsParseHelpStr(qemuCaps->binary,
                                help, qemuCaps,
                                &qemuCaps->version,
                                &is_kvm,
                                &qemuCaps->kvmVersion,
4326 4327
                                false,
                                qmperr) < 0)
4328
        goto cleanup;
4329

4330 4331 4332 4333 4334 4335 4336
    /* Older QEMU versions reported -no-acpi in the output of -help even
     * though it was not supported by the architecture. The issue has since
     * been fixed, but to maintain compatibility with all release we still
     * need to filter out the capability for architectures that we know
     * don't support the feature, eg. anything but x86 and aarch64 */
    if (!ARCH_IS_X86(qemuCaps->arch) &&
        qemuCaps->arch != VIR_ARCH_AARCH64) {
4337
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_NO_ACPI);
4338
    }
4339

4340
    /* virQEMUCapsExtractDeviceStr will only set additional caps if qemu
4341
     * understands the 0.13.0+ notion of "-device driver,".  */
J
Ján Tomko 已提交
4342
    if (strstr(help, "-device driver,?") &&
4343 4344
        virQEMUCapsExtractDeviceStr(qemuCaps->binary,
                                    qemuCaps, runUid, runGid) < 0) {
4345
        goto cleanup;
4346
    }
4347

4348
    if (virQEMUCapsProbeCPUModels(qemuCaps, runUid, runGid) < 0)
4349
        goto cleanup;
4350

4351
    if (virQEMUCapsProbeMachineTypes(qemuCaps, runUid, runGid) < 0)
4352
        goto cleanup;
4353

4354
    ret = 0;
4355
 cleanup:
4356
    virCommandFree(cmd);
4357
    VIR_FREE(help);
4358 4359 4360 4361
    return ret;
}


4362
static void virQEMUCapsMonitorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
4363 4364
                                     virDomainObjPtr vm ATTRIBUTE_UNUSED,
                                     void *opaque ATTRIBUTE_UNUSED)
4365 4366 4367 4368
{
}

static qemuMonitorCallbacks callbacks = {
4369 4370
    .eofNotify = virQEMUCapsMonitorNotify,
    .errorNotify = virQEMUCapsMonitorNotify,
4371 4372 4373 4374 4375 4376 4377
};


/* Capabilities that we assume are always enabled
 * for QEMU >= 1.2.0
 */
static void
4378
virQEMUCapsInitQMPBasic(virQEMUCapsPtr qemuCaps)
4379
{
4380 4381 4382 4383 4384 4385 4386 4387 4388 4389 4390 4391 4392 4393 4394 4395 4396 4397 4398 4399 4400 4401 4402 4403 4404 4405 4406
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_AIO);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_IOTUNE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_WAKEUP);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
O
Olivia Yin 已提交
4407
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);
J
Ján Tomko 已提交
4408
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
4409 4410
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
4411
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
4412
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
P
Paolo Bonzini 已提交
4413
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DISPLAY);
4414 4415
}

4416 4417 4418 4419 4420 4421 4422 4423 4424

/**
 * virQEMUCapsInitQMPArch:
 * @qemuCaps: QEMU capabilities
 * @mon: QEMU monitor
 *
 * Initialize the architecture for @qemuCaps by asking @mon.
 *
 * Returns: 0 on success, <0 on failure
4425 4426
 */
static int
4427
virQEMUCapsInitQMPArch(virQEMUCapsPtr qemuCaps,
4428 4429 4430 4431 4432 4433
                            qemuMonitorPtr mon)
{
    char *archstr = NULL;
    int ret = -1;

    if (!(archstr = qemuMonitorGetTargetArch(mon)))
4434
        goto cleanup;
4435 4436 4437 4438 4439 4440 4441

    if ((qemuCaps->arch = virQEMUCapsArchFromString(archstr)) == VIR_ARCH_NONE) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unknown QEMU arch %s"), archstr);
        goto cleanup;
    }

4442 4443 4444 4445 4446 4447 4448 4449 4450 4451 4452 4453 4454 4455
    ret = 0;

 cleanup:
    VIR_FREE(archstr);
    return ret;
}


/**
 * virQEMUCapsInitQMPBasicArch:
 * @qemuCaps: QEMU capabilities
 *
 * Initialize @qemuCaps with basic architecture-dependent capabilities.
 */
4456
void
4457 4458
virQEMUCapsInitQMPBasicArch(virQEMUCapsPtr qemuCaps)
{
4459 4460 4461
    /* ACPI only works on x86 and aarch64 */
    if (ARCH_IS_X86(qemuCaps->arch) ||
        qemuCaps->arch == VIR_ARCH_AARCH64) {
4462
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
4463 4464 4465 4466
    }

    /* HPET and KVM PIT are x86 specific */
    if (ARCH_IS_X86(qemuCaps->arch)) {
J
Ján Tomko 已提交
4467
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
4468 4469 4470
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
    }
}
4471

4472 4473 4474 4475 4476 4477 4478 4479 4480 4481 4482 4483 4484 4485 4486 4487 4488 4489 4490 4491 4492 4493 4494 4495 4496 4497 4498 4499 4500 4501 4502 4503 4504 4505 4506 4507 4508 4509 4510 4511

/**
 * virQEMUCapsQMPSchemaObjectGetType:
 * @field: name of the object containing the requested type
 * @name: name of the requested type
 * @namefield: name of the object property holding @name
 *
 * Helper that selects the type of a QMP schema object member or it's variant
 * member. Returns the type string on success or NULL on error.
 */
static const char *
virQEMUCapsQMPSchemaObjectGetType(const char *field,
                                  const char *name,
                                  const char *namefield,
                                  virJSONValuePtr elem)
{
    virJSONValuePtr arr;
    virJSONValuePtr cur;
    const char *curname;
    const char *type;
    size_t i;

    if (!(arr = virJSONValueObjectGetArray(elem, field)))
        return NULL;

    for (i = 0; i < virJSONValueArraySize(arr); i++) {
        if (!(cur = virJSONValueArrayGet(arr, i)) ||
            !(curname = virJSONValueObjectGetString(cur, namefield)) ||
            !(type = virJSONValueObjectGetString(cur, "type")))
            continue;

        if (STREQ(name, curname))
            return type;
    }

    return NULL;
}


static virJSONValuePtr
4512
virQEMUCapsQMPSchemaTraverse(const char *baseName,
4513 4514 4515 4516 4517 4518 4519
                             char **query,
                             virHashTablePtr schema)
{
    virJSONValuePtr base;
    const char *metatype;

    do {
4520
        if (!(base = virHashLookup(schema, baseName)))
4521 4522 4523 4524 4525 4526 4527 4528 4529 4530
            return NULL;

        if (!*query)
            return base;

        if (!(metatype = virJSONValueObjectGetString(base, "meta-type")))
            return NULL;

        /* flatten arrays by default */
        if (STREQ(metatype, "array")) {
4531
            if (!(baseName = virJSONValueObjectGetString(base, "element-type")))
4532 4533 4534 4535 4536
                return NULL;

            continue;
        } else if (STREQ(metatype, "object")) {
            if (**query == '+')
4537
                baseName = virQEMUCapsQMPSchemaObjectGetType("variants",
4538 4539 4540
                                                             *query + 1,
                                                             "case", base);
            else
4541
                baseName = virQEMUCapsQMPSchemaObjectGetType("members",
4542 4543 4544
                                                             *query,
                                                             "name", base);

4545
            if (!baseName)
4546 4547 4548
                return NULL;
        } else if (STREQ(metatype, "command") ||
                   STREQ(metatype, "event")) {
4549
            if (!(baseName = virJSONValueObjectGetString(base, *query)))
4550 4551 4552 4553 4554 4555 4556 4557 4558 4559 4560 4561 4562 4563 4564 4565 4566 4567 4568 4569 4570 4571 4572 4573 4574 4575 4576 4577 4578 4579 4580 4581 4582 4583 4584 4585 4586 4587 4588 4589 4590 4591 4592 4593 4594 4595 4596 4597 4598 4599 4600 4601 4602 4603 4604 4605
                return NULL;
        } else {
            /* alternates, basic types and enums can't be entered */
            return NULL;
        }

        query++;
    } while (*query);

    return base;
}


/**
 * virQEMUCapsQMPSchemaGetByPath:
 * @query: string specifying the required data type (see below)
 * @schema: hash table containing the schema data
 * @entry: filled with the located schema object requested by @query
 *
 * Retrieves the requested schema entry specified by @query to @entry. The
 * @query parameter has the following syntax which is very closely tied to the
 * qemu schema syntax entries separated by slashes with a few special characters:
 *
 * "command_or_event/attribute/subattribute/+variant_discriminator/subattribute"
 *
 * command_or_event: name of the event or attribute to introspect
 * attribute: selects whether arguments or return type should be introspected
 *            ("arg-type" or "ret-type" for commands, "arg-type" for events)
 * subattribute: specifies member name of object types
 * +variant_discriminator: In the case of unionized objects, select a
 *                         specific case to introspect.
 *
 * Array types are automatically flattened to the singular type. Alternate
 * types are currently not supported.
 *
 * The above types can be chained arbitrarily using slashes to construct any
 * path into the schema tree.
 *
 * Returns 0 on success (including if the requested schema was not found) and
 * fills @entry appropriately. On failure returns -1 and sets an appropriate
 * error message.
 */
static int
virQEMUCapsQMPSchemaGetByPath(const char *query,
                              virHashTablePtr schema,
                              virJSONValuePtr *entry)
{
    char **elems = NULL;

    *entry = NULL;

    if (!(elems = virStringSplit(query, "/", 0)))
        return -1;

    if (!*elems) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s", _("malformed query string"));
4606
        virStringListFree(elems);
4607 4608 4609 4610 4611
        return -1;
    }

    *entry = virQEMUCapsQMPSchemaTraverse(*elems, elems + 1, schema);

4612
    virStringListFree(elems);
4613 4614 4615 4616 4617 4618 4619 4620 4621 4622 4623 4624 4625 4626 4627 4628 4629 4630 4631 4632 4633 4634 4635 4636 4637 4638 4639 4640 4641 4642 4643 4644 4645 4646 4647 4648 4649 4650 4651 4652
    return 0;
}


static bool
virQEMUCapsQMPSchemaQueryPath(const char *query,
                              virHashTablePtr schema)
{
    virJSONValuePtr entry;

    if (virQEMUCapsQMPSchemaGetByPath(query, schema, &entry))
        return false;

    return !!entry;
}


static int
virQEMUCapsProbeQMPSchemaCapabilities(virQEMUCapsPtr qemuCaps,
                                      qemuMonitorPtr mon)
{
    struct virQEMUCapsStringFlags *entry;
    virHashTablePtr schema;
    size_t i;

    if (!(schema = qemuMonitorQueryQMPSchema(mon)))
        return -1;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsQMPSchemaQueries); i++) {
        entry = virQEMUCapsQMPSchemaQueries + i;

        if (virQEMUCapsQMPSchemaQueryPath(entry->value, schema))
            virQEMUCapsSet(qemuCaps, entry->flag);
    }

    virHashFree(schema);
    return 0;
}


4653 4654 4655 4656 4657 4658 4659 4660 4661 4662 4663 4664
int
virQEMUCapsInitQMPMonitor(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
{
    int ret = -1;
    int major, minor, micro;
    char *package = NULL;

    /* @mon is supposed to be locked by callee */

    if (qemuMonitorSetCapabilities(mon) < 0) {
        VIR_DEBUG("Failed to set monitor capabilities %s",
4665
                  virGetLastErrorMessage());
4666 4667 4668 4669 4670 4671 4672 4673
        ret = 0;
        goto cleanup;
    }

    if (qemuMonitorGetVersion(mon,
                              &major, &minor, &micro,
                              &package) < 0) {
        VIR_DEBUG("Failed to query monitor version %s",
4674
                  virGetLastErrorMessage());
4675 4676 4677 4678 4679 4680 4681 4682 4683 4684 4685 4686 4687 4688
        ret = 0;
        goto cleanup;
    }

    VIR_DEBUG("Got version %d.%d.%d (%s)",
              major, minor, micro, NULLSTR(package));

    if (major < 1 || (major == 1 && minor < 2)) {
        VIR_DEBUG("Not new enough for QMP capabilities detection");
        ret = 0;
        goto cleanup;
    }

    qemuCaps->version = major * 1000000 + minor * 1000 + micro;
4689
    qemuCaps->package = package;
4690 4691 4692 4693
    qemuCaps->usedQMP = true;

    virQEMUCapsInitQMPBasic(qemuCaps);

4694
    if (virQEMUCapsInitQMPArch(qemuCaps, mon) < 0)
4695 4696
        goto cleanup;

4697 4698
    virQEMUCapsInitQMPBasicArch(qemuCaps);

4699 4700 4701 4702 4703 4704 4705 4706
    /* USB option is supported v1.3.0 onwards */
    if (qemuCaps->version >= 1003000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_USB_OPT);

    /* WebSockets were introduced between 1.3.0 and 1.3.1 */
    if (qemuCaps->version >= 1003001)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_WEBSOCKET);

4707 4708 4709 4710 4711 4712
    /* -chardev spiceport is supported from 1.4.0, but usable through
     * qapi only since 1.5.0, however, it still cannot be queried
     * for as a capability */
    if (qemuCaps->version >= 1005000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEPORT);

4713 4714 4715
    if (qemuCaps->version >= 1006000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE_VIDEO_PRIMARY);

4716 4717 4718 4719
    /* vmport option is supported v2.2.0 onwards */
    if (qemuCaps->version >= 2002000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_VMPORT_OPT);

4720 4721 4722 4723 4724 4725
    /* -cpu ...,aarch64=off supported in v2.3.0 and onwards. But it
       isn't detectable via qmp at this point */
    if (qemuCaps->arch == VIR_ARCH_AARCH64 &&
        qemuCaps->version >= 2003000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_AARCH64_OFF);

4726 4727 4728
    /* vhost-user supports multi-queue from v2.4.0 onwards,
     * but there is no way to query for that capability */
    if (qemuCaps->version >= 2004000)
J
Ján Tomko 已提交
4729
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOSTUSER_MULTIQUEUE);
4730

M
Michal Privoznik 已提交
4731 4732 4733 4734
    /* smm option is supported from v2.4.0 */
    if (qemuCaps->version >= 2004000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_SMM_OPT);

4735 4736 4737 4738
    /* Since 2.4.50 ARM virt machine supports gic-version option */
    if (qemuCaps->version >= 2004050)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACH_VIRT_GIC_VERSION);

4739 4740
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
        goto cleanup;
J
Jiri Denemark 已提交
4741 4742 4743 4744 4745

    /* Some capabilities may differ depending on KVM state */
    if (virQEMUCapsProbeQMPKVMState(qemuCaps, mon) < 0)
        goto cleanup;

4746 4747 4748 4749 4750 4751
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPObjects(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPMachineTypes(qemuCaps, mon) < 0)
        goto cleanup;
4752
    if (virQEMUCapsProbeQMPCPUDefinitions(qemuCaps, mon, false) < 0)
4753 4754 4755 4756 4757
        goto cleanup;
    if (virQEMUCapsProbeQMPTPM(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPCommandLine(qemuCaps, mon) < 0)
        goto cleanup;
4758 4759
    if (virQEMUCapsProbeQMPMigrationCapabilities(qemuCaps, mon) < 0)
        goto cleanup;
4760 4761 4762
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_QUERY_QMP_SCHEMA) &&
        virQEMUCapsProbeQMPSchemaCapabilities(qemuCaps, mon) < 0)
        goto cleanup;
4763
    if (virQEMUCapsProbeQMPHostCPU(qemuCaps, mon, false) < 0)
4764
        goto cleanup;
4765

4766 4767 4768 4769 4770 4771 4772 4773 4774 4775 4776
    /* 'intel-iommu' shows up as a device since 2.2.0, but can
     * not be used with -device until 2.7.0. Before that it
     * requires -machine iommu=on. So we must clear the device
     * capability we detected on older QEMUs
     */
    if (qemuCaps->version < 2007000 &&
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_INTEL_IOMMU)) {
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_INTEL_IOMMU);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_IOMMU);
    }

A
Andrea Bolognani 已提交
4777 4778 4779 4780 4781 4782
    /* GIC capabilities, eg. available GIC versions */
    if ((qemuCaps->arch == VIR_ARCH_AARCH64 ||
         qemuCaps->arch == VIR_ARCH_ARMV7L) &&
        virQEMUCapsProbeQMPGICCapabilities(qemuCaps, mon) < 0)
        goto cleanup;

4783 4784 4785 4786 4787 4788 4789
    /* Prealloc on NVDIMMs is broken on older QEMUs leading to
     * user data corruption. If we are dealing with such version
     * of QEMU pretend we don't know how to NVDIMM. */
    if (qemuCaps->version < 2009000 &&
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_NVDIMM))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_NVDIMM);

4790
    ret = 0;
4791
 cleanup:
4792 4793 4794
    return ret;
}

4795

4796 4797 4798 4799 4800 4801 4802 4803 4804 4805 4806 4807 4808
int
virQEMUCapsInitQMPMonitorTCG(virQEMUCapsPtr qemuCaps ATTRIBUTE_UNUSED,
                             qemuMonitorPtr mon)
{
    int ret = -1;

    if (qemuMonitorSetCapabilities(mon) < 0) {
        VIR_DEBUG("Failed to set monitor capabilities %s",
                  virGetLastErrorMessage());
        ret = 0;
        goto cleanup;
    }

4809 4810 4811
    if (virQEMUCapsProbeQMPCPUDefinitions(qemuCaps, mon, true) < 0)
        goto cleanup;

4812 4813 4814
    if (virQEMUCapsProbeQMPHostCPU(qemuCaps, mon, true) < 0)
        goto cleanup;

4815 4816 4817 4818 4819 4820
    ret = 0;
 cleanup:
    return ret;
}


4821 4822 4823 4824 4825 4826 4827 4828 4829 4830 4831 4832
typedef struct _virQEMUCapsInitQMPCommand virQEMUCapsInitQMPCommand;
typedef virQEMUCapsInitQMPCommand *virQEMUCapsInitQMPCommandPtr;
struct _virQEMUCapsInitQMPCommand {
    char *binary;
    uid_t runUid;
    gid_t runGid;
    char **qmperr;
    char *monarg;
    char *monpath;
    char *pidfile;
    virCommandPtr cmd;
    qemuMonitorPtr mon;
4833
    virDomainChrSourceDef config;
4834 4835 4836 4837 4838 4839 4840 4841 4842 4843 4844 4845 4846 4847 4848 4849 4850 4851 4852 4853 4854 4855 4856 4857 4858 4859 4860 4861 4862 4863 4864 4865 4866 4867 4868 4869 4870 4871 4872 4873 4874 4875 4876 4877 4878 4879 4880 4881 4882 4883 4884 4885 4886 4887 4888 4889 4890 4891 4892 4893 4894 4895 4896 4897 4898 4899 4900 4901 4902 4903 4904 4905
    pid_t pid;
    virDomainObjPtr vm;
};


static void
virQEMUCapsInitQMPCommandAbort(virQEMUCapsInitQMPCommandPtr cmd)
{
    if (cmd->mon)
        virObjectUnlock(cmd->mon);
    qemuMonitorClose(cmd->mon);
    cmd->mon = NULL;

    virCommandAbort(cmd->cmd);
    virCommandFree(cmd->cmd);
    cmd->cmd = NULL;

    if (cmd->monpath)
        ignore_value(unlink(cmd->monpath));

    virDomainObjEndAPI(&cmd->vm);

    if (cmd->pid != 0) {
        char ebuf[1024];

        VIR_DEBUG("Killing QMP caps process %lld", (long long) cmd->pid);
        if (virProcessKill(cmd->pid, SIGKILL) < 0 && errno != ESRCH)
            VIR_ERROR(_("Failed to kill process %lld: %s"),
                      (long long) cmd->pid,
                      virStrerror(errno, ebuf, sizeof(ebuf)));

        VIR_FREE(*cmd->qmperr);
    }
    if (cmd->pidfile)
        unlink(cmd->pidfile);
    cmd->pid = 0;
}


static void
virQEMUCapsInitQMPCommandFree(virQEMUCapsInitQMPCommandPtr cmd)
{
    if (!cmd)
        return;

    virQEMUCapsInitQMPCommandAbort(cmd);
    VIR_FREE(cmd->binary);
    VIR_FREE(cmd->monpath);
    VIR_FREE(cmd->monarg);
    VIR_FREE(cmd->pidfile);
    VIR_FREE(cmd);
}


static virQEMUCapsInitQMPCommandPtr
virQEMUCapsInitQMPCommandNew(char *binary,
                             const char *libDir,
                             uid_t runUid,
                             gid_t runGid,
                             char **qmperr)
{
    virQEMUCapsInitQMPCommandPtr cmd = NULL;

    if (VIR_ALLOC(cmd) < 0)
        goto error;

    if (VIR_STRDUP(cmd->binary, binary) < 0)
        goto error;

    cmd->runUid = runUid;
    cmd->runGid = runGid;
    cmd->qmperr = qmperr;
4906

4907 4908 4909
    /* the ".sock" sufix is important to avoid a possible clash with a qemu
     * domain called "capabilities"
     */
4910 4911 4912 4913 4914
    if (virAsprintf(&cmd->monpath, "%s/%s", libDir,
                    "capabilities.monitor.sock") < 0)
        goto error;
    if (virAsprintf(&cmd->monarg, "unix:%s,server,nowait", cmd->monpath) < 0)
        goto error;
4915

4916 4917
    /* ".pidfile" suffix is used rather than ".pid" to avoid a possible clash
     * with a qemu domain called "capabilities"
4918 4919 4920
     * Normally we'd use runDir for pid files, but because we're using
     * -daemonize we need QEMU to be allowed to create them, rather
     * than libvirtd. So we're using libDir which QEMU can write to
4921
     */
4922 4923
    if (virAsprintf(&cmd->pidfile, "%s/%s", libDir, "capabilities.pidfile") < 0)
        goto error;
4924

4925
    virPidFileForceCleanupPath(cmd->pidfile);
4926

4927 4928 4929
    cmd->config.type = VIR_DOMAIN_CHR_TYPE_UNIX;
    cmd->config.data.nix.path = cmd->monpath;
    cmd->config.data.nix.listen = false;
4930

4931 4932 4933 4934 4935 4936 4937 4938 4939 4940 4941 4942 4943
    return cmd;

 error:
    virQEMUCapsInitQMPCommandFree(cmd);
    return NULL;
}


/* Returns -1 on fatal error,
 *          0 on success,
 *          1 when probing QEMU failed
 */
static int
4944 4945
virQEMUCapsInitQMPCommandRun(virQEMUCapsInitQMPCommandPtr cmd,
                             bool forceTCG)
4946 4947
{
    virDomainXMLOptionPtr xmlopt = NULL;
4948
    const char *machine;
4949 4950 4951
    int status = 0;
    int ret = -1;

4952 4953 4954 4955 4956 4957 4958
    if (forceTCG)
        machine = "none,accel=tcg";
    else
        machine = "none,accel=kvm:tcg";

    VIR_DEBUG("Try to probe capabilities of '%s' via QMP, machine %s",
              cmd->binary, machine);
4959

4960 4961 4962 4963 4964 4965 4966
    /*
     * We explicitly need to use -daemonize here, rather than
     * virCommandDaemonize, because we need to synchronize
     * with QEMU creating its monitor socket API. Using
     * daemonize guarantees control won't return to libvirt
     * until the socket is present.
     */
4967 4968 4969 4970 4971
    cmd->cmd = virCommandNewArgList(cmd->binary,
                                    "-S",
                                    "-no-user-config",
                                    "-nodefaults",
                                    "-nographic",
4972
                                    "-machine", machine,
4973 4974 4975 4976 4977 4978 4979 4980 4981 4982
                                    "-qmp", cmd->monarg,
                                    "-pidfile", cmd->pidfile,
                                    "-daemonize",
                                    NULL);
    virCommandAddEnvPassCommon(cmd->cmd);
    virCommandClearCaps(cmd->cmd);
    virCommandSetGID(cmd->cmd, cmd->runGid);
    virCommandSetUID(cmd->cmd, cmd->runUid);

    virCommandSetErrorBuffer(cmd->cmd, cmd->qmperr);
4983

4984
    /* Log, but otherwise ignore, non-zero status.  */
4985
    if (virCommandRun(cmd->cmd, &status) < 0)
4986 4987 4988
        goto cleanup;

    if (status != 0) {
4989
        VIR_DEBUG("QEMU %s exited with status %d: %s",
4990 4991
                  cmd->binary, status, *cmd->qmperr);
        goto ignore;
4992 4993
    }

4994 4995 4996
    if (virPidFileReadPath(cmd->pidfile, &cmd->pid) < 0) {
        VIR_DEBUG("Failed to read pidfile %s", cmd->pidfile);
        goto ignore;
4997 4998
    }

4999
    if (!(xmlopt = virDomainXMLOptionNew(NULL, NULL, NULL)) ||
5000
        !(cmd->vm = virDomainObjNew(xmlopt)))
5001 5002
        goto cleanup;

5003
    cmd->vm->pid = cmd->pid;
5004

5005
    if (!(cmd->mon = qemuMonitorOpen(cmd->vm, &cmd->config, true,
5006
                                     0, &callbacks, NULL)))
5007
        goto ignore;
5008

5009
    virObjectLock(cmd->mon);
5010 5011 5012

    ret = 0;

5013
 cleanup:
5014 5015
    if (!cmd->mon)
        virQEMUCapsInitQMPCommandAbort(cmd);
5016
    virObjectUnref(xmlopt);
5017

5018
    return ret;
5019

5020 5021 5022 5023
 ignore:
    ret = 1;
    goto cleanup;
}
5024

5025 5026 5027 5028 5029 5030 5031 5032 5033 5034 5035 5036 5037 5038 5039 5040

static int
virQEMUCapsInitQMP(virQEMUCapsPtr qemuCaps,
                   const char *libDir,
                   uid_t runUid,
                   gid_t runGid,
                   char **qmperr)
{
    virQEMUCapsInitQMPCommandPtr cmd = NULL;
    int ret = -1;
    int rc;

    if (!(cmd = virQEMUCapsInitQMPCommandNew(qemuCaps->binary, libDir,
                                             runUid, runGid, qmperr)))
        goto cleanup;

5041
    if ((rc = virQEMUCapsInitQMPCommandRun(cmd, false)) != 0) {
5042 5043 5044
        if (rc == 1)
            ret = 0;
        goto cleanup;
5045
    }
5046 5047 5048 5049

    if (virQEMUCapsInitQMPMonitor(qemuCaps, cmd->mon) < 0)
        goto cleanup;

5050 5051 5052 5053 5054 5055 5056 5057 5058 5059 5060 5061
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM)) {
        virQEMUCapsInitQMPCommandAbort(cmd);
        if ((rc = virQEMUCapsInitQMPCommandRun(cmd, true)) != 0) {
            if (rc == 1)
                ret = 0;
            goto cleanup;
        }

        if (virQEMUCapsInitQMPMonitorTCG(qemuCaps, cmd->mon) < 0)
            goto cleanup;
    }

5062 5063 5064 5065
    ret = 0;

 cleanup:
    virQEMUCapsInitQMPCommandFree(cmd);
5066 5067 5068 5069
    return ret;
}


5070 5071 5072 5073 5074 5075 5076 5077 5078 5079 5080
#define MESSAGE_ID_CAPS_PROBE_FAILURE "8ae2f3fb-2dbe-498e-8fbd-012d40afa361"

static void
virQEMUCapsLogProbeFailure(const char *binary)
{
    virLogMetadata meta[] = {
        { .key = "MESSAGE_ID", .s = MESSAGE_ID_CAPS_PROBE_FAILURE, .iv = 0 },
        { .key = "LIBVIRT_QEMU_BINARY", .s = binary, .iv = 0 },
        { .key = NULL },
    };

5081
    virLogMessage(&virLogSelf,
5082 5083 5084 5085
                  VIR_LOG_WARN,
                  __FILE__, __LINE__, __func__,
                  meta,
                  _("Failed to probe capabilities for %s: %s"),
5086
                  binary, virGetLastErrorMessage());
5087 5088 5089
}


5090
virQEMUCapsPtr
5091
virQEMUCapsNewForBinaryInternal(virCapsPtr caps,
5092
                                const char *binary,
5093 5094 5095 5096 5097
                                const char *libDir,
                                const char *cacheDir,
                                uid_t runUid,
                                gid_t runGid,
                                bool qmpOnly)
5098
{
5099
    virQEMUCapsPtr qemuCaps;
5100 5101
    struct stat sb;
    int rv;
5102
    char *qmperr = NULL;
5103

5104 5105 5106
    if (!(qemuCaps = virQEMUCapsNew()))
        goto error;

5107 5108
    if (VIR_STRDUP(qemuCaps->binary, binary) < 0)
        goto error;
5109 5110 5111 5112 5113 5114 5115 5116

    /* 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;
    }
5117
    qemuCaps->ctime = sb.st_ctime;
5118 5119 5120 5121 5122 5123 5124 5125 5126 5127 5128

    /* 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;
    }

5129 5130
    if (!cacheDir)
        rv = 0;
5131 5132
    else if ((rv = virQEMUCapsInitCached(caps, qemuCaps, cacheDir,
                                         runUid, runGid)) < 0)
5133 5134
        goto error;

5135
    if (rv == 0) {
5136
        if (virQEMUCapsInitQMP(qemuCaps, libDir, runUid, runGid, &qmperr) < 0) {
5137 5138 5139 5140
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

5141 5142 5143 5144 5145 5146 5147 5148
        if (qmpOnly && !qemuCaps->usedQMP) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Failed to probe QEMU binary with QMP: %s"),
                           qmperr ? qmperr : _("unknown error"));
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

5149
        if (!qemuCaps->usedQMP &&
5150
            virQEMUCapsInitHelp(qemuCaps, runUid, runGid, qmperr) < 0) {
5151 5152 5153 5154
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

5155 5156
        if (cacheDir &&
            virQEMUCapsRememberCached(qemuCaps, cacheDir) < 0)
5157
            goto error;
5158

5159 5160
        virQEMUCapsInitHostCPUModel(qemuCaps, caps, VIR_DOMAIN_VIRT_KVM);
        virQEMUCapsInitHostCPUModel(qemuCaps, caps, VIR_DOMAIN_VIRT_QEMU);
5161
    }
5162

5163
 cleanup:
5164
    VIR_FREE(qmperr);
5165
    return qemuCaps;
5166

5167
 error:
5168 5169
    virObjectUnref(qemuCaps);
    qemuCaps = NULL;
5170
    goto cleanup;
5171 5172
}

5173
static virQEMUCapsPtr
5174 5175
virQEMUCapsNewForBinary(virCapsPtr caps,
                        const char *binary,
5176 5177 5178 5179 5180
                        const char *libDir,
                        const char *cacheDir,
                        uid_t runUid,
                        gid_t runGid)
{
5181
    return virQEMUCapsNewForBinaryInternal(caps, binary, libDir, cacheDir,
5182 5183 5184
                                           runUid, runGid, false);
}

5185

5186 5187
bool
virQEMUCapsIsValid(virQEMUCapsPtr qemuCaps,
5188 5189 5190
                   time_t qemuctime,
                   uid_t runUid,
                   gid_t runGid)
5191
{
5192 5193
    bool kvmUsable;

5194
    if (!qemuCaps->binary)
5195 5196
        return true;

J
Jiri Denemark 已提交
5197
    if (!qemuctime) {
5198 5199 5200 5201 5202 5203 5204 5205 5206
        struct stat sb;

        if (stat(qemuCaps->binary, &sb) < 0) {
            char ebuf[1024];
            VIR_DEBUG("Failed to stat QEMU binary '%s': %s",
                      qemuCaps->binary,
                      virStrerror(errno, ebuf, sizeof(ebuf)));
            return false;
        }
J
Jiri Denemark 已提交
5207
        qemuctime = sb.st_ctime;
5208 5209
    }

J
Jiri Denemark 已提交
5210
    if (qemuctime != qemuCaps->ctime) {
5211 5212 5213
        VIR_DEBUG("Outdated capabilities for '%s': QEMU binary changed "
                  "(%lld vs %lld)",
                  qemuCaps->binary,
J
Jiri Denemark 已提交
5214
                  (long long) qemuctime, (long long) qemuCaps->ctime);
5215
        return false;
5216
    }
5217

5218 5219 5220 5221 5222 5223 5224 5225 5226 5227 5228 5229 5230 5231 5232 5233 5234 5235 5236 5237
    kvmUsable = virFileAccessibleAs("/dev/kvm", R_OK | W_OK,
                                    runUid, runGid) == 0;

    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM) &&
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_ENABLE_KVM) &&
        kvmUsable) {
        VIR_DEBUG("KVM was not enabled when probing '%s', "
                  "but it should be usable now",
                  qemuCaps->binary);
        return false;
    }

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM) &&
        !kvmUsable) {
        VIR_DEBUG("KVM was enabled when probing '%s', "
                  "but it is not available now",
                  qemuCaps->binary);
        return false;
    }

5238
    return true;
5239
}
5240 5241


5242 5243 5244 5245 5246 5247 5248 5249 5250 5251 5252 5253 5254 5255 5256 5257 5258 5259 5260 5261 5262 5263 5264 5265 5266 5267 5268 5269 5270 5271 5272 5273 5274
struct virQEMUCapsMachineTypeFilter {
    const char *machineType;
    virQEMUCapsFlags *flags;
    size_t nflags;
};

static const struct virQEMUCapsMachineTypeFilter virQEMUCapsMachineFilter[] = {
    /* { "blah", virQEMUCapsMachineBLAHFilter,
         ARRAY_CARDINALITY(virQEMUCapsMachineBLAHFilter) }, */
    { "", NULL, 0 },
};


void
virQEMUCapsFilterByMachineType(virQEMUCapsPtr qemuCaps,
                               const char *machineType)
{
    size_t i;

    if (!machineType)
        return;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsMachineFilter); i++) {
        const struct virQEMUCapsMachineTypeFilter *filter = &virQEMUCapsMachineFilter[i];
        size_t j;

        if (STRNEQ(filter->machineType, machineType))
            continue;

        for (j = 0; j < filter->nflags; j++)
            virQEMUCapsClear(qemuCaps, filter->flags[j]);
    }

5275 5276
    if (!virQEMUCapsGetMachineHotplugCpus(qemuCaps, machineType))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_QUERY_HOTPLUGGABLE_CPUS);
5277 5278 5279
}


5280 5281
virQEMUCapsCachePtr
virQEMUCapsCacheNew(const char *libDir,
5282
                    const char *cacheDir,
5283 5284
                    uid_t runUid,
                    gid_t runGid)
5285
{
5286
    virQEMUCapsCachePtr cache;
5287

5288
    if (VIR_ALLOC(cache) < 0)
5289 5290 5291 5292 5293 5294 5295 5296 5297
        return NULL;

    if (virMutexInit(&cache->lock) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("Unable to initialize mutex"));
        VIR_FREE(cache);
        return NULL;
    }

E
Eric Blake 已提交
5298
    if (!(cache->binaries = virHashCreate(10, virObjectFreeHashData)))
5299
        goto error;
5300
    if (VIR_STRDUP(cache->libDir, libDir) < 0)
5301
        goto error;
5302 5303
    if (VIR_STRDUP(cache->cacheDir, cacheDir) < 0)
        goto error;
5304

5305 5306 5307
    cache->runUid = runUid;
    cache->runGid = runGid;

5308 5309
    return cache;

5310
 error:
5311
    virQEMUCapsCacheFree(cache);
5312 5313 5314
    return NULL;
}

5315 5316 5317 5318 5319 5320 5321 5322 5323 5324 5325 5326 5327 5328 5329 5330 5331 5332 5333 5334 5335 5336 5337 5338 5339 5340 5341 5342 5343 5344 5345

static void ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) ATTRIBUTE_NONNULL(3)
virQEMUCapsCacheValidate(virQEMUCapsCachePtr cache,
                         const char *binary,
                         virCapsPtr caps,
                         virQEMUCapsPtr *qemuCaps)
{
    if (*qemuCaps &&
        !virQEMUCapsIsValid(*qemuCaps, 0, cache->runUid, cache->runGid)) {
        VIR_DEBUG("Cached capabilities %p no longer valid for %s",
                  *qemuCaps, binary);
        virHashRemoveEntry(cache->binaries, binary);
        *qemuCaps = NULL;
    }

    if (!*qemuCaps) {
        VIR_DEBUG("Creating capabilities for %s", binary);
        *qemuCaps = virQEMUCapsNewForBinary(caps, binary,
                                            cache->libDir, cache->cacheDir,
                                            cache->runUid, cache->runGid);
        if (*qemuCaps) {
            VIR_DEBUG("Caching capabilities %p for %s", *qemuCaps, binary);
            if (virHashAddEntry(cache->binaries, binary, *qemuCaps) < 0) {
                virObjectUnref(*qemuCaps);
                *qemuCaps = NULL;
            }
        }
    }
}


5346
virQEMUCapsPtr
5347 5348 5349
virQEMUCapsCacheLookup(virCapsPtr caps,
                       virQEMUCapsCachePtr cache,
                       const char *binary)
5350
{
5351
    virQEMUCapsPtr ret = NULL;
5352

5353
    virMutexLock(&cache->lock);
5354

5355
    ret = virHashLookup(cache->binaries, binary);
5356
    virQEMUCapsCacheValidate(cache, binary, caps, &ret);
5357
    virObjectRef(ret);
5358

5359
    virMutexUnlock(&cache->lock);
5360 5361

    VIR_DEBUG("Returning caps %p for %s", ret, binary);
5362 5363 5364 5365
    return ret;
}


5366
virQEMUCapsPtr
5367 5368
virQEMUCapsCacheLookupCopy(virCapsPtr caps,
                           virQEMUCapsCachePtr cache,
5369
                           const char *binary,
5370
                           const char *machineType)
5371
{
5372
    virQEMUCapsPtr qemuCaps = virQEMUCapsCacheLookup(caps, cache, binary);
5373
    virQEMUCapsPtr ret;
5374

5375
    if (!qemuCaps)
5376 5377
        return NULL;

5378 5379
    ret = virQEMUCapsNewCopy(qemuCaps);
    virObjectUnref(qemuCaps);
5380 5381 5382 5383

    if (!ret)
        return NULL;

5384
    virQEMUCapsFilterByMachineType(ret, machineType);
5385 5386 5387 5388
    return ret;
}


5389 5390 5391 5392 5393 5394 5395 5396 5397 5398 5399 5400 5401
static int
virQEMUCapsCompareArch(const void *payload,
                       const void *name ATTRIBUTE_UNUSED,
                       const void *opaque)
{
    struct virQEMUCapsSearchData *data = (struct virQEMUCapsSearchData *) opaque;
    const virQEMUCaps *qemuCaps = payload;

    return qemuCaps->arch == data->arch;
}


virQEMUCapsPtr
5402 5403
virQEMUCapsCacheLookupByArch(virCapsPtr caps,
                             virQEMUCapsCachePtr cache,
5404 5405 5406
                             virArch arch)
{
    virQEMUCapsPtr ret = NULL;
5407
    virArch target;
5408 5409 5410 5411
    struct virQEMUCapsSearchData data = { .arch = arch };

    virMutexLock(&cache->lock);
    ret = virHashSearch(cache->binaries, virQEMUCapsCompareArch, &data);
5412 5413 5414 5415 5416 5417 5418 5419 5420
    if (!ret) {
        /* If the first attempt at finding capabilities has failed, try
         * again using the QEMU target as lookup key instead */
        target = virQEMUCapsFindTarget(virArchFromHost(), data.arch);
        if (target != data.arch) {
            data.arch = target;
            ret = virHashSearch(cache->binaries, virQEMUCapsCompareArch, &data);
        }
    }
5421 5422 5423 5424 5425 5426 5427 5428 5429 5430 5431 5432 5433 5434 5435 5436

    if (ret) {
        char *binary;

        if (VIR_STRDUP(binary, ret->binary) < 0) {
            ret = NULL;
        } else {
            virQEMUCapsCacheValidate(cache, binary, caps, &ret);
            VIR_FREE(binary);
        }
    } else {
        virReportError(VIR_ERR_INVALID_ARG,
                       _("unable to find any emulator to serve '%s' "
                         "architecture"), virArchToString(arch));
    }

5437 5438 5439
    virObjectRef(ret);
    virMutexUnlock(&cache->lock);

5440 5441
    VIR_DEBUG("Returning caps %p for arch %s", ret, virArchToString(arch));

5442 5443 5444 5445
    return ret;
}


5446
void
5447
virQEMUCapsCacheFree(virQEMUCapsCachePtr cache)
5448 5449 5450 5451
{
    if (!cache)
        return;

5452
    VIR_FREE(cache->libDir);
5453
    VIR_FREE(cache->cacheDir);
5454 5455 5456 5457
    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}
5458

5459 5460

bool
5461
virQEMUCapsSupportsChardev(const virDomainDef *def,
5462
                           virQEMUCapsPtr qemuCaps,
5463
                           virDomainChrDefPtr chr)
5464
{
J
Ján Tomko 已提交
5465
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV))
5466 5467
        return false;

5468
    if ((def->os.arch == VIR_ARCH_PPC) || ARCH_IS_PPC64(def->os.arch)) {
5469
        if (!qemuDomainIsPSeries(def))
S
Shivaprasad G Bhat 已提交
5470
            return false;
5471
        /* only pseries need -device spapr-vty with -chardev */
S
Shivaprasad G Bhat 已提交
5472 5473 5474
        if (chr->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_SERIAL &&
            chr->info.type != VIR_DOMAIN_DEVICE_ADDRESS_TYPE_SPAPRVIO)
            return false;
5475 5476
    }

5477
    if ((def->os.arch != VIR_ARCH_ARMV7L) && (def->os.arch != VIR_ARCH_AARCH64))
5478
        return true;
5479

5480 5481 5482 5483 5484 5485
    /* This may not be true for all ARM machine types, but at least
     * the only supported non-virtio serial devices of vexpress and versatile
     * don't have the -chardev property wired up. */
    return (chr->info.type == VIR_DOMAIN_DEVICE_ADDRESS_TYPE_VIRTIO_MMIO ||
            (chr->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE &&
             chr->targetType == VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_VIRTIO));
5486
}
5487 5488


5489 5490 5491 5492 5493 5494 5495
bool
virQEMUCapsSupportsVmport(virQEMUCapsPtr qemuCaps,
                          const virDomainDef *def)
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_MACHINE_VMPORT_OPT))
        return false;

5496 5497
    return qemuDomainIsI440FX(def) ||
        qemuDomainIsQ35(def) ||
5498 5499 5500 5501
        STREQ(def->os.machine, "isapc");
}


M
Michal Privoznik 已提交
5502 5503 5504 5505 5506 5507 5508
bool
virQEMUCapsSupportsSMM(virQEMUCapsPtr qemuCaps,
                       const virDomainDef *def)
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_MACHINE_SMM_OPT))
        return false;

5509
    return qemuDomainIsQ35(def);
M
Michal Privoznik 已提交
5510 5511 5512
}


5513 5514 5515 5516 5517 5518 5519
bool
virQEMUCapsIsMachineSupported(virQEMUCapsPtr qemuCaps,
                              const char *canonical_machine)
{
    size_t i;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
5520
        if (STREQ(canonical_machine, qemuCaps->machineTypes[i].name))
5521 5522 5523 5524
            return true;
    }
    return false;
}
5525 5526 5527 5528 5529 5530 5531


const char *
virQEMUCapsGetDefaultMachine(virQEMUCapsPtr qemuCaps)
{
    if (!qemuCaps->nmachineTypes)
        return NULL;
5532
    return qemuCaps->machineTypes[0].name;
5533
}
5534 5535


5536
static int
5537
virQEMUCapsFillDomainLoaderCaps(virDomainCapsLoaderPtr capsLoader,
5538 5539
                                virFirmwarePtr *firmwares,
                                size_t nfirmwares)
5540
{
5541 5542
    size_t i;

5543
    capsLoader->supported = true;
5544

5545
    if (VIR_ALLOC_N(capsLoader->values.values, nfirmwares) < 0)
5546 5547
        return -1;

5548 5549
    for (i = 0; i < nfirmwares; i++) {
        const char *filename = firmwares[i]->name;
5550 5551 5552 5553 5554 5555

        if (!virFileExists(filename)) {
            VIR_DEBUG("loader filename=%s does not exist", filename);
            continue;
        }

5556
        if (VIR_STRDUP(capsLoader->values.values[capsLoader->values.nvalues],
5557 5558
                       filename) < 0)
            return -1;
5559
        capsLoader->values.nvalues++;
5560 5561
    }

5562
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
5563 5564
                             VIR_DOMAIN_LOADER_TYPE_ROM);

5565 5566
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
                             VIR_DOMAIN_LOADER_TYPE_PFLASH);
5567 5568


5569 5570 5571
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->readonly,
                             VIR_TRISTATE_BOOL_YES,
                             VIR_TRISTATE_BOOL_NO);
5572
    return 0;
5573 5574 5575
}


5576
static int
5577
virQEMUCapsFillDomainOSCaps(virDomainCapsOSPtr os,
5578 5579
                            virFirmwarePtr *firmwares,
                            size_t nfirmwares)
5580
{
5581
    virDomainCapsLoaderPtr capsLoader = &os->loader;
5582

5583
    os->supported = true;
5584
    if (virQEMUCapsFillDomainLoaderCaps(capsLoader, firmwares, nfirmwares) < 0)
5585 5586
        return -1;
    return 0;
5587 5588 5589
}


5590 5591 5592 5593 5594
static int
virQEMUCapsFillDomainCPUCaps(virCapsPtr caps,
                             virQEMUCapsPtr qemuCaps,
                             virDomainCapsPtr domCaps)
{
5595 5596
    if (virQEMUCapsIsCPUModeSupported(qemuCaps, caps, domCaps->virttype,
                                      VIR_CPU_MODE_HOST_PASSTHROUGH))
5597 5598
        domCaps->cpu.hostPassthrough = true;

5599
    if (virQEMUCapsIsCPUModeSupported(qemuCaps, caps, domCaps->virttype,
5600
                                      VIR_CPU_MODE_HOST_MODEL)) {
5601 5602
        virCPUDefPtr cpu = virQEMUCapsGetHostModel(qemuCaps, domCaps->virttype,
                                                   VIR_QEMU_CAPS_HOST_CPU_REPORTED);
5603 5604
        domCaps->cpu.hostModel = virCPUDefCopy(cpu);
    }
5605 5606 5607 5608 5609

    if (virQEMUCapsIsCPUModeSupported(qemuCaps, caps, domCaps->virttype,
                                      VIR_CPU_MODE_CUSTOM)) {
        virDomainCapsCPUModelsPtr filtered = NULL;
        char **models = NULL;
5610
        const char *blacklist[] = { "host", NULL };
5611

J
Jiri Denemark 已提交
5612
        if (virCPUGetModels(domCaps->arch, &models) >= 0) {
5613 5614 5615 5616 5617 5618 5619 5620
            virDomainCapsCPUModelsPtr cpus;

            if (domCaps->virttype == VIR_DOMAIN_VIRT_KVM)
                cpus = qemuCaps->kvmCPUModels;
            else
                cpus = qemuCaps->tcgCPUModels;

            filtered = virDomainCapsCPUModelsFilter(cpus,
5621 5622
                                                    (const char **) models,
                                                    blacklist);
5623
            virStringListFree(models);
5624 5625
        }
        domCaps->cpu.custom = filtered;
5626
    }
5627 5628 5629 5630 5631

    return 0;
}


5632
static int
5633
virQEMUCapsFillDomainDeviceDiskCaps(virQEMUCapsPtr qemuCaps,
5634
                                    const char *machine,
5635 5636
                                    virDomainCapsDeviceDiskPtr disk)
{
5637
    disk->supported = true;
5638 5639 5640
    /* QEMU supports all of these */
    VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice,
                             VIR_DOMAIN_DISK_DEVICE_DISK,
5641 5642
                             VIR_DOMAIN_DISK_DEVICE_CDROM,
                             VIR_DOMAIN_DISK_DEVICE_LUN);
5643 5644

    /* PowerPC pseries based VMs do not support floppy device */
5645
    if (!qemuDomainMachineIsPSeries(machine, qemuCaps->arch))
5646
        VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice, VIR_DOMAIN_DISK_DEVICE_FLOPPY);
5647

5648 5649 5650
    if (qemuDomainMachineHasBuiltinIDE(machine))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_IDE);

5651 5652 5653 5654 5655
    VIR_DOMAIN_CAPS_ENUM_SET(disk->bus,
                             VIR_DOMAIN_DISK_BUS_SCSI,
                             VIR_DOMAIN_DISK_BUS_VIRTIO,
                             /* VIR_DOMAIN_DISK_BUS_SD */);

5656
    /* PowerPC pseries based VMs do not support floppy device */
5657
    if (!qemuDomainMachineIsPSeries(machine, qemuCaps->arch))
5658 5659
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_FDC);

5660 5661
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_USB_STORAGE))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_USB);
5662 5663 5664 5665

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ICH9_AHCI))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_SATA);

5666
    return 0;
5667 5668 5669
}


5670 5671 5672 5673 5674 5675 5676 5677 5678 5679 5680 5681 5682 5683 5684 5685 5686
static int
virQEMUCapsFillDomainDeviceGraphicsCaps(virQEMUCapsPtr qemuCaps,
                                        virDomainCapsDeviceGraphicsPtr dev)
{
    dev->supported = true;

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_SDL))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->type, VIR_DOMAIN_GRAPHICS_TYPE_SDL);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_VNC))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->type, VIR_DOMAIN_GRAPHICS_TYPE_VNC);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_SPICE))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->type, VIR_DOMAIN_GRAPHICS_TYPE_SPICE);

    return 0;
}


5687 5688 5689 5690 5691 5692 5693 5694 5695 5696 5697 5698
static int
virQEMUCapsFillDomainDeviceVideoCaps(virQEMUCapsPtr qemuCaps,
                                     virDomainCapsDeviceVideoPtr dev)
{
    dev->supported = true;

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_VGA))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->modelType, VIR_DOMAIN_VIDEO_TYPE_VGA);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_CIRRUS_VGA))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->modelType, VIR_DOMAIN_VIDEO_TYPE_CIRRUS);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_VMWARE_SVGA))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->modelType, VIR_DOMAIN_VIDEO_TYPE_VMVGA);
5699
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_QXL))
5700 5701 5702 5703 5704 5705 5706 5707
        VIR_DOMAIN_CAPS_ENUM_SET(dev->modelType, VIR_DOMAIN_VIDEO_TYPE_QXL);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_VIRTIO_GPU))
        VIR_DOMAIN_CAPS_ENUM_SET(dev->modelType, VIR_DOMAIN_VIDEO_TYPE_VIRTIO);

    return 0;
}


5708
static int
5709 5710 5711 5712 5713 5714
virQEMUCapsFillDomainDeviceHostdevCaps(virQEMUCapsPtr qemuCaps,
                                       virDomainCapsDeviceHostdevPtr hostdev)
{
    bool supportsPassthroughKVM = qemuHostdevHostSupportsPassthroughLegacy();
    bool supportsPassthroughVFIO = qemuHostdevHostSupportsPassthroughVFIO();

5715
    hostdev->supported = true;
5716 5717 5718 5719 5720 5721 5722 5723 5724 5725 5726 5727 5728
    /* VIR_DOMAIN_HOSTDEV_MODE_CAPABILITIES is for containers only */
    VIR_DOMAIN_CAPS_ENUM_SET(hostdev->mode,
                             VIR_DOMAIN_HOSTDEV_MODE_SUBSYS);

    VIR_DOMAIN_CAPS_ENUM_SET(hostdev->startupPolicy,
                             VIR_DOMAIN_STARTUP_POLICY_DEFAULT,
                             VIR_DOMAIN_STARTUP_POLICY_MANDATORY,
                             VIR_DOMAIN_STARTUP_POLICY_REQUISITE,
                             VIR_DOMAIN_STARTUP_POLICY_OPTIONAL);

    VIR_DOMAIN_CAPS_ENUM_SET(hostdev->subsysType,
                             VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB,
                             VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI);
J
Ján Tomko 已提交
5729
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_SCSI_GENERIC))
5730 5731 5732 5733 5734 5735 5736 5737 5738 5739 5740 5741 5742 5743
        VIR_DOMAIN_CAPS_ENUM_SET(hostdev->subsysType,
                                 VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_SCSI);

    /* No virDomainHostdevCapsType for QEMU */
    virDomainCapsEnumClear(&hostdev->capsType);

    virDomainCapsEnumClear(&hostdev->pciBackend);
    if (supportsPassthroughVFIO &&
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_VFIO_PCI)) {
        VIR_DOMAIN_CAPS_ENUM_SET(hostdev->pciBackend,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_DEFAULT,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_VFIO);
    }

J
Ján Tomko 已提交
5744
    if (supportsPassthroughKVM) {
5745 5746 5747 5748
        VIR_DOMAIN_CAPS_ENUM_SET(hostdev->pciBackend,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_DEFAULT,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_KVM);
    }
5749
    return 0;
5750 5751 5752
}


5753 5754 5755 5756 5757 5758 5759 5760 5761 5762 5763 5764 5765 5766 5767 5768 5769 5770 5771 5772 5773 5774 5775 5776 5777 5778 5779 5780 5781 5782 5783 5784 5785 5786 5787 5788 5789 5790
/**
 * virQEMUCapsSupportsGICVersion:
 * @qemuCaps: QEMU capabilities
 * @virtType: domain type
 * @version: GIC version
 *
 * Checks the QEMU binary with capabilities @qemuCaps supports a specific
 * GIC version for a domain of type @virtType.
 *
 * Returns: true if the binary supports the requested GIC version, false
 *          otherwise
 */
bool
virQEMUCapsSupportsGICVersion(virQEMUCapsPtr qemuCaps,
                              virDomainVirtType virtType,
                              virGICVersion version)
{
    size_t i;

    for (i = 0; i < qemuCaps->ngicCapabilities; i++) {
        virGICCapabilityPtr cap = &(qemuCaps->gicCapabilities[i]);

        if (cap->version != version)
            continue;

        if (virtType == VIR_DOMAIN_VIRT_KVM &&
            cap->implementation & VIR_GIC_IMPLEMENTATION_KERNEL)
            return true;

        if (virtType == VIR_DOMAIN_VIRT_QEMU &&
            cap->implementation & VIR_GIC_IMPLEMENTATION_EMULATED)
            return true;
    }

    return false;
}


5791 5792 5793 5794 5795 5796 5797 5798 5799 5800 5801 5802 5803 5804 5805 5806 5807 5808 5809 5810 5811 5812 5813 5814
/**
 * virQEMUCapsFillDomainFeatureGICCaps:
 * @qemuCaps: QEMU capabilities
 * @domCaps: domain capabilities
 *
 * Take the information about GIC capabilities that has been obtained
 * using the 'query-gic-capabilities' QMP command and stored in @qemuCaps
 * and convert it to a form suitable for @domCaps.
 *
 * @qemuCaps contains complete information about the GIC capabilities for
 * the corresponding QEMU binary, stored as custom objects; @domCaps, on
 * the other hand, should only contain information about the GIC versions
 * available for the specific combination of architecture, machine type
 * and virtualization type. Moreover, a common format is used to store
 * information about enumerations in @domCaps, so further processing is
 * required.
 *
 * Returns: 0 on success, <0 on failure
 */
static int
virQEMUCapsFillDomainFeatureGICCaps(virQEMUCapsPtr qemuCaps,
                                    virDomainCapsPtr domCaps)
{
    virDomainCapsFeatureGICPtr gic = &domCaps->gic;
5815
    virGICVersion version;
5816 5817 5818 5819 5820 5821 5822 5823 5824

    if (domCaps->arch != VIR_ARCH_ARMV7L &&
        domCaps->arch != VIR_ARCH_AARCH64)
        return 0;

    if (STRNEQ(domCaps->machine, "virt") &&
        !STRPREFIX(domCaps->machine, "virt-"))
        return 0;

5825 5826 5827 5828 5829 5830
    for (version = VIR_GIC_VERSION_LAST - 1;
         version > VIR_GIC_VERSION_NONE;
         version--) {
        if (!virQEMUCapsSupportsGICVersion(qemuCaps,
                                           domCaps->virttype,
                                           version))
5831 5832 5833 5834
            continue;

        gic->supported = true;
        VIR_DOMAIN_CAPS_ENUM_SET(gic->version,
5835
                                 version);
5836 5837 5838 5839 5840 5841
    }

    return 0;
}


5842
int
5843 5844
virQEMUCapsFillDomainCaps(virCapsPtr caps,
                          virDomainCapsPtr domCaps,
5845
                          virQEMUCapsPtr qemuCaps,
5846
                          virFirmwarePtr *firmwares,
5847
                          size_t nfirmwares)
5848
{
5849
    virDomainCapsOSPtr os = &domCaps->os;
5850 5851
    virDomainCapsDeviceDiskPtr disk = &domCaps->disk;
    virDomainCapsDeviceHostdevPtr hostdev = &domCaps->hostdev;
5852
    virDomainCapsDeviceGraphicsPtr graphics = &domCaps->graphics;
5853
    virDomainCapsDeviceVideoPtr video = &domCaps->video;
5854

5855 5856
    domCaps->maxvcpus = virQEMUCapsGetMachineMaxCpus(qemuCaps,
                                                     domCaps->machine);
5857
    if (domCaps->virttype == VIR_DOMAIN_VIRT_KVM) {
5858 5859 5860 5861 5862 5863
        int hostmaxvcpus;

        if ((hostmaxvcpus = virHostCPUGetKVMMaxVCPUs()) < 0)
            return -1;

        domCaps->maxvcpus = MIN(domCaps->maxvcpus, hostmaxvcpus);
5864
    }
5865

5866
    if (virQEMUCapsFillDomainOSCaps(os, firmwares, nfirmwares) < 0 ||
5867
        virQEMUCapsFillDomainCPUCaps(caps, qemuCaps, domCaps) < 0 ||
5868 5869 5870
        virQEMUCapsFillDomainDeviceDiskCaps(qemuCaps,
                                            domCaps->machine, disk) < 0 ||
        virQEMUCapsFillDomainDeviceGraphicsCaps(qemuCaps, graphics) < 0 ||
5871
        virQEMUCapsFillDomainDeviceVideoCaps(qemuCaps, video) < 0 ||
5872 5873
        virQEMUCapsFillDomainDeviceHostdevCaps(qemuCaps, hostdev) < 0 ||
        virQEMUCapsFillDomainFeatureGICCaps(qemuCaps, domCaps) < 0)
5874 5875
        return -1;
    return 0;
5876
}