qemu_capabilities.c 120.1 KB
Newer Older
1 2 3
/*
 * qemu_capabilities.c: QEMU capabilities generation
 *
4
 * Copyright (C) 2006-2015 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 35 36
#include "nodeinfo.h"
#include "cpu/cpu.h"
#include "domain_conf.h"
37
#include "vircommand.h"
38
#include "virbitmap.h"
39
#include "virnodesuspend.h"
40
#include "virnuma.h"
41
#include "qemu_monitor.h"
42
#include "virstring.h"
43
#include "qemu_hostdev.h"
44
#include "qemu_domain.h"
45 46
#define __QEMU_CAPSRIV_H_ALLOW__
#include "qemu_capspriv.h"
47

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

#define VIR_FROM_THIS VIR_FROM_QEMU

56 57
VIR_LOG_INIT("qemu.qemu_capabilities");

58 59 60 61
/* While not public, these strings must not change. They
 * are used in domain status files which are read on
 * daemon restarts
 */
62
VIR_ENUM_IMPL(virQEMUCaps, QEMU_CAPS_LAST,
63 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
              "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 */
100
              "vhost-net",
101 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
              "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",
134 135

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

              "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 已提交
150
              "usb-hub",
151
              "no-shutdown",
152 153

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

              "incoming-defer", /* 200 */
M
Marc-André Lureau 已提交
304
              "virtio-gpu",
305 306
    );

307 308 309 310 311 312 313 314

/*
 * 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.
 */
315
struct _virQEMUCaps {
316 317
    virObject object;

318 319
    bool usedQMP;

320
    char *binary;
321
    time_t ctime;
322

323
    virBitmapPtr flags;
324 325 326

    unsigned int version;
    unsigned int kvmVersion;
327
    char *package;
328

329
    virArch arch;
330 331 332 333 334 335 336

    size_t ncpuDefinitions;
    char **cpuDefinitions;

    size_t nmachineTypes;
    char **machineTypes;
    char **machineAliases;
337
    unsigned int *machineMaxCpus;
338 339
};

340 341 342 343
struct virQEMUCapsSearchData {
    virArch arch;
};

344

345 346
static virClassPtr virQEMUCapsClass;
static void virQEMUCapsDispose(void *obj);
347

348
static int virQEMUCapsOnceInit(void)
349
{
350 351 352 353
    if (!(virQEMUCapsClass = virClassNew(virClassForObject(),
                                         "virQEMUCaps",
                                         sizeof(virQEMUCaps),
                                         virQEMUCapsDispose)))
354 355 356 357 358
        return -1;

    return 0;
}

359
VIR_ONCE_GLOBAL_INIT(virQEMUCaps)
360

361
static virArch virQEMUCapsArchFromString(const char *arch)
362 363 364 365 366
{
    if (STREQ(arch, "i386"))
        return VIR_ARCH_I686;
    if (STREQ(arch, "arm"))
        return VIR_ARCH_ARMV7L;
367 368
    if (STREQ(arch, "or32"))
        return VIR_ARCH_OR32;
369 370 371 372 373

    return virArchFromString(arch);
}


374
static const char *virQEMUCapsArchToString(virArch arch)
375 376 377 378 379
{
    if (arch == VIR_ARCH_I686)
        return "i386";
    else if (arch == VIR_ARCH_ARMV7L)
        return "arm";
380 381
    else if (arch == VIR_ARCH_OR32)
        return "or32";
382 383 384 385

    return virArchToString(arch);
}

386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407
/* 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)
{
    /* Both ppc64 and ppc64le guests can use the ppc64 target */
    if (ARCH_IS_PPC64(guestarch))
        guestarch = VIR_ARCH_PPC64;

    /* armv7l guests on aarch64 hosts can use the aarch64 target
     * i686 guests on x86_64 hosts can use the x86_64 target */
    if ((guestarch == VIR_ARCH_ARMV7L && hostarch == VIR_ARCH_AARCH64) ||
        (guestarch == VIR_ARCH_I686 && hostarch == VIR_ARCH_X86_64)) {
        return hostarch;
    }

    return guestarch;
}
408

409
static virCommandPtr
410 411
virQEMUCapsProbeCommand(const char *qemu,
                        virQEMUCapsPtr qemuCaps,
412
                        uid_t runUid, gid_t runGid)
413 414 415
{
    virCommandPtr cmd = virCommandNew(qemu);

416 417
    if (qemuCaps) {
        if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG))
418
            virCommandAddArg(cmd, "-no-user-config");
419
        else if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NODEFCONFIG))
420 421 422 423 424
            virCommandAddArg(cmd, "-nodefconfig");
    }

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
425 426
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
427 428 429 430 431

    return cmd;
}


432
static void
433 434
virQEMUCapsSetDefaultMachine(virQEMUCapsPtr qemuCaps,
                             size_t defIdx)
435
{
436 437
    char *name = qemuCaps->machineTypes[defIdx];
    char *alias = qemuCaps->machineAliases[defIdx];
438
    unsigned int maxCpus = qemuCaps->machineMaxCpus[defIdx];
439 440 441 442 443 444 445

    memmove(qemuCaps->machineTypes + 1,
            qemuCaps->machineTypes,
            sizeof(qemuCaps->machineTypes[0]) * defIdx);
    memmove(qemuCaps->machineAliases + 1,
            qemuCaps->machineAliases,
            sizeof(qemuCaps->machineAliases[0]) * defIdx);
446 447 448
    memmove(qemuCaps->machineMaxCpus + 1,
            qemuCaps->machineMaxCpus,
            sizeof(qemuCaps->machineMaxCpus[0]) * defIdx);
449 450
    qemuCaps->machineTypes[0] = name;
    qemuCaps->machineAliases[0] = alias;
451
    qemuCaps->machineMaxCpus[0] = maxCpus;
452 453
}

454 455 456 457
/* Format is:
 * <machine> <desc> [(default)|(alias of <canonical>)]
 */
static int
458 459
virQEMUCapsParseMachineTypesStr(const char *output,
                                virQEMUCapsPtr qemuCaps)
460 461 462
{
    const char *p = output;
    const char *next;
463
    size_t defIdx = 0;
464 465 466

    do {
        const char *t;
467 468
        char *name;
        char *canonical = NULL;
469 470 471 472 473 474 475 476 477 478

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

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

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

479 480
        if (VIR_STRNDUP(name, p, t - p) < 0)
            return -1;
481 482

        p = t;
483
        if ((t = strstr(p, "(default)")) && (!next || t < next))
484
            defIdx = qemuCaps->nmachineTypes;
485 486 487

        if ((t = strstr(p, "(alias of ")) && (!next || t < next)) {
            p = t + strlen("(alias of ");
488 489
            if (!(t = strchr(p, ')')) || (next && t >= next)) {
                VIR_FREE(name);
490
                continue;
491
            }
492

493
            if (VIR_STRNDUP(canonical, p, t - p) < 0) {
494
                VIR_FREE(name);
495
                return -1;
496 497 498
            }
        }

499
        if (VIR_REALLOC_N(qemuCaps->machineTypes, qemuCaps->nmachineTypes + 1) < 0 ||
500 501
            VIR_REALLOC_N(qemuCaps->machineAliases, qemuCaps->nmachineTypes + 1) < 0 ||
            VIR_REALLOC_N(qemuCaps->machineMaxCpus, qemuCaps->nmachineTypes + 1) < 0) {
502 503
            VIR_FREE(name);
            VIR_FREE(canonical);
504
            return -1;
505
        }
506
        qemuCaps->nmachineTypes++;
507
        if (canonical) {
508 509
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = canonical;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = name;
510
        } else {
511 512
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = name;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = NULL;
513
        }
514 515
        /* When parsing from command line we don't have information about maxCpus */
        qemuCaps->machineMaxCpus[qemuCaps->nmachineTypes-1] = 0;
516 517
    } while ((p = next));

518

519
    if (defIdx)
520
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
521 522 523 524

    return 0;
}

525
static int
526 527
virQEMUCapsProbeMachineTypes(virQEMUCapsPtr qemuCaps,
                             uid_t runUid, gid_t runGid)
528 529
{
    char *output;
530 531
    int ret = -1;
    virCommandPtr cmd;
532
    int status;
533

534 535 536 537
    /* 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.
     */
538
    if (!virFileIsExecutable(qemuCaps->binary)) {
539
        virReportSystemError(errno, _("Cannot find QEMU binary %s"),
540
                             qemuCaps->binary);
541 542 543
        return -1;
    }

544
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
545
    virCommandAddArgList(cmd, "-M", "?", NULL);
546
    virCommandSetOutputBuffer(cmd, &output);
547

548 549
    /* Ignore failure from older qemu that did not understand '-M ?'.  */
    if (virCommandRun(cmd, &status) < 0)
550 551
        goto cleanup;

552
    if (virQEMUCapsParseMachineTypesStr(output, qemuCaps) < 0)
553
        goto cleanup;
554 555 556

    ret = 0;

557
 cleanup:
558 559
    VIR_FREE(output);
    virCommandFree(cmd);
560 561 562 563 564 565

    return ret;
}


typedef int
566 567
(*virQEMUCapsParseCPUModels)(const char *output,
                             virQEMUCapsPtr qemuCaps);
568 569 570 571 572 573 574

/* Format:
 *      <arch> <model>
 * qemu-0.13 encloses some model names in []:
 *      <arch> [<model>]
 */
static int
575 576
virQEMUCapsParseX86Models(const char *output,
                          virQEMUCapsPtr qemuCaps)
577 578 579
{
    const char *p = output;
    const char *next;
580
    int ret = -1;
581 582 583

    do {
        const char *t;
584
        size_t len;
585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601

        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;

602
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
603
            goto cleanup;
604

605 606 607 608
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
609

610 611 612 613
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
614

615
        if (VIR_STRNDUP(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1], p, len) < 0)
616
            goto cleanup;
617 618
    } while ((p = next));

619
    ret = 0;
620

621
 cleanup:
622
    return ret;
623 624
}

P
Prerna Saxena 已提交
625 626 627 628
/* ppc64 parser.
 * Format : PowerPC <machine> <description>
 */
static int
629 630
virQEMUCapsParsePPCModels(const char *output,
                          virQEMUCapsPtr qemuCaps)
P
Prerna Saxena 已提交
631 632 633
{
    const char *p = output;
    const char *next;
634
    int ret = -1;
P
Prerna Saxena 已提交
635 636 637

    do {
        const char *t;
638
        size_t len;
P
Prerna Saxena 已提交
639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658

        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;

659
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
660
            goto cleanup;
P
Prerna Saxena 已提交
661

662
        len = t - p - 1;
P
Prerna Saxena 已提交
663

664
        if (VIR_STRNDUP(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1], p, len) < 0)
665
            goto cleanup;
P
Prerna Saxena 已提交
666 667
    } while ((p = next));

668
    ret = 0;
P
Prerna Saxena 已提交
669

670
 cleanup:
671
    return ret;
P
Prerna Saxena 已提交
672
}
673

674
static int
675
virQEMUCapsProbeCPUModels(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid)
676 677 678
{
    char *output = NULL;
    int ret = -1;
679
    virQEMUCapsParseCPUModels parse;
680
    virCommandPtr cmd;
681

682
    if (qemuCaps->arch == VIR_ARCH_I686 ||
683
        qemuCaps->arch == VIR_ARCH_X86_64) {
684
        parse = virQEMUCapsParseX86Models;
685
    } else if ARCH_IS_PPC64(qemuCaps->arch) {
686
        parse = virQEMUCapsParsePPCModels;
687
    } else {
688
        VIR_DEBUG("don't know how to parse %s CPU models",
689
                  virArchToString(qemuCaps->arch));
690 691 692
        return 0;
    }

693
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
694
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
695
    virCommandSetOutputBuffer(cmd, &output);
696

697
    if (virCommandRun(cmd, NULL) < 0)
698 699
        goto cleanup;

700
    if (parse(output, qemuCaps) < 0)
701 702 703 704
        goto cleanup;

    ret = 0;

705
 cleanup:
706
    VIR_FREE(output);
707
    virCommandFree(cmd);
708 709 710 711

    return ret;
}

712
static char *
713 714
virQEMUCapsFindBinary(const char *format,
                      const char *archstr)
715
{
716 717
    char *ret = NULL;
    char *binary = NULL;
718

719 720
    if (virAsprintf(&binary, format, archstr) < 0)
        goto out;
721 722 723

    ret = virFindFileInPath(binary);
    VIR_FREE(binary);
724 725
    if (ret && virFileIsExecutable(ret))
        goto out;
726

727
    VIR_FREE(ret);
728

729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751
 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;
752
    }
753

754 755 756 757
    /* Third attempt, i686 only: try 'qemu' */
    if (guestarch == VIR_ARCH_I686) {
        if ((ret = virQEMUCapsFindBinary("%s", "qemu")) != NULL)
            goto out;
758
    }
759

760
 out:
761 762 763
    return ret;
}

764
static int
765 766 767 768
virQEMUCapsInitGuest(virCapsPtr caps,
                     virQEMUCapsCachePtr cache,
                     virArch hostarch,
                     virArch guestarch)
769
{
770
    size_t i;
771 772
    char *kvmbin = NULL;
    char *binary = NULL;
773 774
    virQEMUCapsPtr qemubinCaps = NULL;
    virQEMUCapsPtr kvmbinCaps = NULL;
775
    bool native_kvm, x86_32on64_kvm, arm_32on64_kvm, ppc64_kvm;
776 777
    int ret = -1;

J
Ján Tomko 已提交
778
    /* Check for existence of base emulator, or alternate base
779 780
     * which can be used with magic cpu choice
     */
781
    binary = virQEMUCapsFindBinaryForArch(hostarch, guestarch);
782

783
    /* Ignore binary if extracting version info fails */
784
    if (binary) {
785
        if (!(qemubinCaps = virQEMUCapsCacheLookup(cache, binary))) {
786 787 788 789
            virResetLastError();
            VIR_FREE(binary);
        }
    }
790 791

    /* qemu-kvm/kvm binaries can only be used if
792
     *  - host & guest arches match
793 794
     *  - hostarch is x86_64 and guest arch is i686 (needs -cpu qemu32)
     *  - hostarch is aarch64 and guest arch is armv7l (needs -cpu aarch64=off)
795
     *  - hostarch and guestarch are both ppc64*
796
     */
797 798 799 800 801
    native_kvm = (hostarch == guestarch);
    x86_32on64_kvm = (hostarch == VIR_ARCH_X86_64 &&
        guestarch == VIR_ARCH_I686);
    arm_32on64_kvm = (hostarch == VIR_ARCH_AARCH64 &&
        guestarch == VIR_ARCH_ARMV7L);
802
    ppc64_kvm = (ARCH_IS_PPC64(hostarch) && ARCH_IS_PPC64(guestarch));
803

804
    if (native_kvm || x86_32on64_kvm || arm_32on64_kvm || ppc64_kvm) {
805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821
        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
         */
        if (arm_32on64_kvm)
            kvmbins[3] = "qemu-system-aarch64";
822

823
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
824 825 826
            if (!kvmbins[i])
                continue;

827
            kvmbin = virFindFileInPath(kvmbins[i]);
828

829 830
            if (!kvmbin)
                continue;
831

832
            if (!(kvmbinCaps = virQEMUCapsCacheLookup(cache, kvmbin))) {
833
                virResetLastError();
834 835 836
                VIR_FREE(kvmbin);
                continue;
            }
837

838 839
            if (!binary) {
                binary = kvmbin;
840
                qemubinCaps = kvmbinCaps;
841
                kvmbin = NULL;
842
                kvmbinCaps = NULL;
843
            }
844
            break;
845 846 847
        }
    }

848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875
    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;

876 877 878
    if (!binary)
        return 0;

879
    if (virFileExists("/dev/kvm") &&
880 881
        (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         virQEMUCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
882
         kvmbin))
883
        haskvm = true;
884

885
    if (virQEMUCapsGetMachineTypesCaps(qemubinCaps, &nmachines, &machines) < 0)
886
        goto cleanup;
887 888 889 890

    /* We register kvm as the base emulator too, since we can
     * just give -no-kvm to disable acceleration if required */
    if ((guest = virCapabilitiesAddGuest(caps,
891
                                         VIR_DOMAIN_OSTYPE_HVM,
892
                                         guestarch,
893 894 895 896
                                         binary,
                                         NULL,
                                         nmachines,
                                         machines)) == NULL)
897
        goto cleanup;
898 899 900 901 902

    machines = NULL;
    nmachines = 0;

    if (caps->host.cpu &&
J
Jiri Denemark 已提交
903
        caps->host.cpu->model &&
904
        virQEMUCapsGetCPUDefinitions(qemubinCaps, NULL) > 0 &&
905
        !virCapabilitiesAddGuestFeature(guest, "cpuselection", true, false))
906
        goto cleanup;
907

908
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_BOOTINDEX) &&
909
        !virCapabilitiesAddGuestFeature(guest, "deviceboot", true, false))
910
        goto cleanup;
911

912 913 914
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_DISK_SNAPSHOT))
        hasdisksnapshot = true;

915 916
    if (!virCapabilitiesAddGuestFeature(guest, "disksnapshot", hasdisksnapshot,
                                        false))
917
        goto cleanup;
918

D
Daniel P. Berrange 已提交
919
    if (virCapabilitiesAddGuestDomain(guest,
920
                                      VIR_DOMAIN_VIRT_QEMU,
D
Daniel P. Berrange 已提交
921 922 923 924
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
925
        goto cleanup;
926

D
Daniel P. Berrange 已提交
927 928
    if (haskvm) {
        virCapsGuestDomainPtr dom;
929

D
Daniel P. Berrange 已提交
930
        if (kvmbin &&
931
            virQEMUCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
932
            goto cleanup;
933

D
Daniel P. Berrange 已提交
934
        if ((dom = virCapabilitiesAddGuestDomain(guest,
935
                                                 VIR_DOMAIN_VIRT_KVM,
D
Daniel P. Berrange 已提交
936 937 938 939
                                                 kvmbin ? kvmbin : binary,
                                                 NULL,
                                                 nmachines,
                                                 machines)) == NULL) {
940
            goto cleanup;
D
Daniel P. Berrange 已提交
941
        }
942

D
Daniel P. Berrange 已提交
943 944
        machines = NULL;
        nmachines = 0;
945 946 947

    }

948 949
    if (((guestarch == VIR_ARCH_I686) ||
         (guestarch == VIR_ARCH_X86_64)) &&
950 951
        (virCapabilitiesAddGuestFeature(guest, "acpi", true, true) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "apic", true, false) == NULL))
952
        goto cleanup;
953

954
    if ((guestarch == VIR_ARCH_I686) &&
955 956
        (virCapabilitiesAddGuestFeature(guest, "pae", true, false) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "nonpae", true, false) == NULL))
957
        goto cleanup;
958 959 960

    ret = 0;

961
 cleanup:
962 963 964

    virCapabilitiesFreeMachines(machines, nmachines);

965
    return ret;
966 967 968 969
}


static int
970 971
virQEMUCapsInitCPU(virCapsPtr caps,
                   virArch arch)
972 973
{
    virCPUDefPtr cpu = NULL;
974
    virCPUDataPtr data = NULL;
975 976 977
    virNodeInfo nodeinfo;
    int ret = -1;

978
    if (VIR_ALLOC(cpu) < 0)
979 980
        goto error;

981 982
    cpu->arch = arch;

983
    if (nodeGetInfo(NULL, &nodeinfo))
984 985 986 987 988 989
        goto error;

    cpu->type = VIR_CPU_TYPE_HOST;
    cpu->sockets = nodeinfo.sockets;
    cpu->cores = nodeinfo.cores;
    cpu->threads = nodeinfo.threads;
J
Jiri Denemark 已提交
990
    caps->host.cpu = cpu;
991

992
    if (!(data = cpuNodeData(arch))
993
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0)
J
Jiri Denemark 已提交
994
        goto cleanup;
995 996 997

    ret = 0;

998
 cleanup:
J
Jiri Denemark 已提交
999
    cpuDataFree(data);
1000 1001 1002

    return ret;

1003
 error:
1004 1005 1006 1007 1008
    virCPUDefFree(cpu);
    goto cleanup;
}


M
Michal Privoznik 已提交
1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031
static int
virQEMUCapsInitPages(virCapsPtr caps)
{
    int ret = -1;
    unsigned int *pages_size = NULL;
    size_t npages;

    if (virNumaGetPages(-1 /* Magic constant for overall info */,
                        &pages_size, NULL, NULL, &npages) < 0)
        goto cleanup;

    caps->host.pagesSize = pages_size;
    pages_size = NULL;
    caps->host.nPagesSize = npages;
    npages = 0;

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


1032
virCapsPtr virQEMUCapsInit(virQEMUCapsCachePtr cache)
1033 1034
{
    virCapsPtr caps;
1035
    size_t i;
T
Tal Kain 已提交
1036
    virArch hostarch = virArchFromHost();
1037

T
Tal Kain 已提交
1038
    if ((caps = virCapabilitiesNew(hostarch,
1039
                                   true, true)) == NULL)
1040
        goto error;
1041 1042 1043 1044 1045

    /* 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
     */
1046
    if (nodeCapsInitNUMA(NULL, caps) < 0) {
1047
        virCapabilitiesFreeNUMAInfo(caps);
1048
        VIR_WARN("Failed to query host NUMA topology, disabling NUMA capabilities");
1049 1050
    }

T
Tal Kain 已提交
1051
    if (virQEMUCapsInitCPU(caps, hostarch) < 0)
1052
        VIR_WARN("Failed to get host CPU");
1053

1054
    /* Add the power management features of the host */
1055
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
1056 1057
        VIR_WARN("Failed to get host power management capabilities");

M
Michal Privoznik 已提交
1058 1059 1060 1061
    /* Add huge pages info */
    if (virQEMUCapsInitPages(caps) < 0)
        VIR_WARN("Failed to get pages info");

1062 1063 1064
    /* Add domain migration transport URIs */
    virCapabilitiesAddHostMigrateTransport(caps, "tcp");
    virCapabilitiesAddHostMigrateTransport(caps, "rdma");
1065

1066 1067 1068 1069
    /* 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
     */
1070
    for (i = 0; i < VIR_ARCH_LAST; i++)
1071
        if (virQEMUCapsInitGuest(caps, cache,
T
Tal Kain 已提交
1072
                                 hostarch,
1073
                                 i) < 0)
1074
            goto error;
1075 1076 1077

    return caps;

1078
 error:
1079
    virObjectUnref(caps);
1080 1081 1082 1083
    return NULL;
}


1084
static int
1085 1086 1087 1088
virQEMUCapsComputeCmdFlags(const char *help,
                           unsigned int version,
                           virQEMUCapsPtr qemuCaps,
                           bool check_yajl ATTRIBUTE_UNUSED)
1089 1090
{
    const char *p;
R
Richa Marwaha 已提交
1091
    const char *fsdev, *netdev;
1092
    const char *cache;
1093 1094

    if (strstr(help, "-no-kvm"))
1095
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
1096
    if (strstr(help, "-enable-kvm"))
1097
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
1098 1099
    if (strstr(help, ",process="))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116

    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, "readonly="))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
    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);

1117 1118 1119
    if ((p = strstr(help, "-vga")) && !strstr(help, "-std-vga")) {
        const char *nl = strstr(p, "\n");
        if (strstr(p, "|qxl"))
1120
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
1121
        if ((p = strstr(p, "|none")) && p < nl)
1122
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
1123 1124
    }
    if (strstr(help, "-spice"))
1125
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
1126
    if (strstr(help, "-vnc"))
1127
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
1128
    if (strstr(help, "seamless-migration="))
1129
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
1130
    if (strstr(help, "boot=on"))
1131
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_BOOT);
1132
    if (strstr(help, "serial=s"))
1133
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
1134
    if (strstr(help, "-pcidevice"))
1135
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCIDEVICE);
1136 1137
    if (strstr(help, "host=[seg:]bus"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
1138
    if (strstr(help, "-mem-path"))
1139
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
1140
    if (strstr(help, "-chardev")) {
1141
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
1142
        if (strstr(help, "-chardev spicevmc"))
1143
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
1144 1145
        if (strstr(help, "-chardev spiceport"))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEPORT);
1146
    }
1147
    if (strstr(help, "-balloon"))
1148
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BALLOON);
1149
    if (strstr(help, "-device")) {
1150
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE);
1151 1152 1153 1154
        /*
         * When -device was introduced, qemu already supported drive's
         * readonly option but didn't advertise that.
         */
1155
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1156 1157
    }
    if (strstr(help, "-nodefconfig"))
1158
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
1159
    if (strstr(help, "-no-user-config"))
1160
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
1161 1162
    /* The trailing ' ' is important to avoid a bogus match */
    if (strstr(help, "-rtc "))
1163
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
1164 1165
    /* to wit */
    if (strstr(help, "-rtc-td-hack"))
1166
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC_TD_HACK);
1167
    if (strstr(help, "-no-hpet"))
1168
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
1169
    if (strstr(help, "-no-acpi"))
1170
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
1171
    if (strstr(help, "-no-kvm-pit-reinjection"))
1172
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
1173
    if (strstr(help, "-tdf"))
1174
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_TDF);
1175
    if (strstr(help, "-enable-nesting"))
1176
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NESTING);
1177
    if (strstr(help, ",menu=on"))
1178
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
1179
    if (strstr(help, ",reboot-timeout=rb_time"))
1180
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_REBOOT_TIMEOUT);
1181 1182
    if (strstr(help, ",splash-time=sp_time"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPLASH_TIMEOUT);
1183
    if ((fsdev = strstr(help, "-fsdev"))) {
1184
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
1185
        if (strstr(fsdev, "readonly"))
1186
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
1187
        if (strstr(fsdev, "writeout"))
1188
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
1189
    }
1190
    if (strstr(help, "-smbios type"))
1191
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
1192
    if (strstr(help, "-sandbox"))
1193
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
1194

R
Richa Marwaha 已提交
1195
    if ((netdev = strstr(help, "-netdev"))) {
1196 1197
        /* Disable -netdev on 0.12 since although it exists,
         * the corresponding netdev_add/remove monitor commands
1198 1199
         * do not, and we need them to be able to do hotplug.
         * But see below about RHEL build. */
R
Richa Marwaha 已提交
1200 1201
        if (version >= 13000) {
            if (strstr(netdev, "bridge"))
1202
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
1203
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
R
Richa Marwaha 已提交
1204
        }
1205 1206 1207
    }

    if (strstr(help, "-sdl"))
1208
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
1209 1210 1211
    if (strstr(help, "cores=") &&
        strstr(help, "threads=") &&
        strstr(help, "sockets="))
1212
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMP_TOPOLOGY);
1213

1214
    if (strstr(help, ",vhost="))
1215
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
1216

1217 1218
    /* 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
1219
     * 0.14.* and 0.15.0)
1220
     */
1221
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1222
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
1223

1224
    if (strstr(help, "dump-guest-core=on|off"))
1225
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
1226

O
Olivia Yin 已提交
1227 1228 1229
    if (strstr(help, "-dtb"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);

1230 1231 1232
    if (strstr(help, "-machine"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);

1233
    if (version >= 11000)
1234
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
1235

1236 1237 1238
    /* 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
1239 1240 1241 1242 1243
     * 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.
1244
     */
1245
#if WITH_YAJL
1246
    if (version >= 13000) {
1247
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
1248 1249
    } else if (version >= 12000 &&
               strstr(help, "libvirt")) {
1250 1251
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1252
    }
1253 1254 1255 1256 1257
#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 已提交
1258
     * libvirt but is targeting a newer qemu, we are better off
1259
     * telling them to recompile (the spec file includes the
1260
     * dependency, so distros won't hit this).  This check is
1261
     * also in m4/virt-yajl.m4 (see $with_yajl).  */
1262 1263 1264
    if (version >= 15000 ||
        (version >= 12000 && strstr(help, "libvirt"))) {
        if (check_yajl) {
1265 1266 1267
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("this qemu binary requires libvirt to be "
                             "compiled with yajl"));
1268 1269
            return -1;
        }
1270
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1271
    }
E
Eric Blake 已提交
1272
#endif
1273 1274

    if (version >= 13000)
1275
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIFUNCTION);
1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287

    /* Although very new versions of qemu advertise the presence of
     * the rombar option in the output of "qemu -device pci-assign,?",
     * this advertisement was added to the code long after the option
     * itself. According to qemu developers, though, rombar is
     * available in all qemu binaries from release 0.12 onward.
     * Setting the capability this way makes it available in more
     * cases where it might be needed, and shouldn't cause any false
     * positives (in the case that it did, qemu would produce an error
     * log and refuse to start, so it would be immediately obvious).
     */
    if (version >= 12000)
1288
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_ROMBAR);
1289 1290

    if (version >= 11000)
1291
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_HOST);
1292

1293
    if (version >= 1001000) {
J
Ján Tomko 已提交
1294
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
1295 1296
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
    }
J
Ján Tomko 已提交
1297

1298
    return 0;
1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324
}

/* 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)

1325 1326 1327 1328
int virQEMUCapsParseHelpStr(const char *qemu,
                            const char *help,
                            virQEMUCapsPtr qemuCaps,
                            unsigned int *version,
1329
                            bool *is_kvm,
1330
                            unsigned int *kvm_version,
1331 1332
                            bool check_yajl,
                            const char *qmperr)
1333 1334 1335
{
    unsigned major, minor, micro;
    const char *p = help;
1336
    char *strflags;
1337

1338 1339
    *version = *kvm_version = 0;
    *is_kvm = false;
1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356

    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 已提交
1357
    if (minor == -1)
1358 1359
        goto fail;

J
Jiri Denemark 已提交
1360 1361 1362 1363 1364 1365 1366 1367
    if (*p != '.') {
        micro = 0;
    } else {
        ++p;
        micro = virParseNumber(&p);
        if (micro == -1)
            goto fail;
    }
1368 1369 1370 1371

    SKIP_BLANKS(p);

    if (STRPREFIX(p, QEMU_KVM_VER_PREFIX)) {
1372
        *is_kvm = true;
1373 1374 1375 1376
        p += strlen(QEMU_KVM_VER_PREFIX);
    } else if (STRPREFIX(p, KVM_VER_PREFIX)) {
        int ret;

1377
        *is_kvm = true;
1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388
        p += strlen(KVM_VER_PREFIX);

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

        *kvm_version = ret;
    }

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

1389 1390 1391 1392 1393 1394 1395
    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;
    }

1396 1397 1398 1399
    /* Refuse to parse -help output for QEMU releases >= 1.2.0 that should be
     * using QMP probing.
     */
    if (*version >= 1002000) {
1400 1401 1402 1403 1404 1405 1406 1407 1408
        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);
        }
1409 1410 1411
        goto cleanup;
    }

1412
    if (virQEMUCapsComputeCmdFlags(help, *version,
1413
                                   qemuCaps, check_yajl) < 0)
1414
        goto cleanup;
1415

1416
    strflags = virBitmapString(qemuCaps->flags);
1417 1418 1419
    VIR_DEBUG("Version %u.%u.%u, cooked version %u, flags %s",
              major, minor, micro, *version, NULLSTR(strflags));
    VIR_FREE(strflags);
1420 1421 1422 1423 1424 1425 1426 1427

    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;

1428
 fail:
1429
    p = strchr(help, '\n');
1430 1431
    if (!p)
        p = strchr(help, '\0');
1432

1433 1434 1435
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("cannot parse %s version number in '%.*s'"),
                   qemu, (int) (p - help), help);
1436

1437
 cleanup:
1438 1439 1440
    return -1;
}

1441

1442
struct virQEMUCapsStringFlags {
1443 1444 1445 1446 1447
    const char *value;
    int flag;
};


1448 1449 1450
struct virQEMUCapsStringFlags virQEMUCapsCommands[] = {
    { "system_wakeup", QEMU_CAPS_WAKEUP },
    { "transaction", QEMU_CAPS_TRANSACTION },
1451 1452
    { "block_stream", QEMU_CAPS_BLOCKJOB_SYNC },
    { "block-stream", QEMU_CAPS_BLOCKJOB_ASYNC },
1453 1454 1455 1456 1457 1458 1459 1460 1461
    { "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 },
1462
    { "change-backing-file", QEMU_CAPS_CHANGE_BACKING_FILE },
1463
    { "rtc-reset-reinjection", QEMU_CAPS_RTC_RESET_REINJECTION },
1464
    { "migrate-incoming", QEMU_CAPS_INCOMING_DEFER },
1465 1466
};

1467 1468 1469 1470
struct virQEMUCapsStringFlags virQEMUCapsMigration[] = {
    { "rdma-pin-all", QEMU_CAPS_MIGRATE_RDMA },
};

1471 1472 1473
struct virQEMUCapsStringFlags virQEMUCapsEvents[] = {
    { "BALLOON_CHANGE", QEMU_CAPS_BALLOON_EVENT },
    { "SPICE_MIGRATE_COMPLETED", QEMU_CAPS_SEAMLESS_MIGRATION },
1474
    { "DEVICE_DELETED", QEMU_CAPS_DEVICE_DEL_EVENT },
1475
    { "MIGRATION", QEMU_CAPS_MIGRATION_EVENT },
1476 1477
};

1478
struct virQEMUCapsStringFlags virQEMUCapsObjectTypes[] = {
1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493
    { "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 },
1494
    { "virtio-blk-ccw", QEMU_CAPS_VIRTIO_CCW },
1495
    { "sclpconsole", QEMU_CAPS_SCLP_S390 },
1496
    { "lsi53c895a", QEMU_CAPS_SCSI_LSI },
1497
    { "virtio-scsi-pci", QEMU_CAPS_VIRTIO_SCSI },
1498 1499
    { "virtio-scsi-s390", QEMU_CAPS_VIRTIO_SCSI },
    { "virtio-scsi-ccw", QEMU_CAPS_VIRTIO_SCSI },
1500
    { "virtio-scsi-device", QEMU_CAPS_VIRTIO_SCSI },
1501
    { "megasas", QEMU_CAPS_SCSI_MEGASAS },
1502 1503
    { "spicevmc", QEMU_CAPS_DEVICE_SPICEVMC },
    { "qxl-vga", QEMU_CAPS_DEVICE_QXL_VGA },
1504
    { "qxl", QEMU_CAPS_DEVICE_QXL },
1505 1506 1507 1508
    { "sga", QEMU_CAPS_SGA },
    { "scsi-block", QEMU_CAPS_SCSI_BLOCK },
    { "scsi-cd", QEMU_CAPS_SCSI_CD },
    { "ide-cd", QEMU_CAPS_IDE_CD },
1509 1510 1511
    { "VGA", QEMU_CAPS_DEVICE_VGA },
    { "cirrus-vga", QEMU_CAPS_DEVICE_CIRRUS_VGA },
    { "vmware-svga", QEMU_CAPS_DEVICE_VMWARE_SVGA },
H
Han Cheng 已提交
1512 1513
    { "usb-serial", QEMU_CAPS_DEVICE_USB_SERIAL },
    { "usb-net", QEMU_CAPS_DEVICE_USB_NET },
1514
    { "virtio-rng-pci", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1515 1516
    { "virtio-rng-s390", QEMU_CAPS_DEVICE_VIRTIO_RNG },
    { "virtio-rng-ccw", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1517
    { "virtio-rng-device", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1518
    { "rng-random", QEMU_CAPS_OBJECT_RNG_RANDOM },
1519
    { "rng-egd", QEMU_CAPS_OBJECT_RNG_EGD },
1520
    { "spapr-nvram", QEMU_CAPS_DEVICE_NVRAM },
1521
    { "pci-bridge", QEMU_CAPS_DEVICE_PCI_BRIDGE },
1522
    { "vfio-pci", QEMU_CAPS_DEVICE_VFIO_PCI },
H
Han Cheng 已提交
1523
    { "scsi-generic", QEMU_CAPS_DEVICE_SCSI_GENERIC },
1524
    { "i82801b11-bridge", QEMU_CAPS_DEVICE_DMI_TO_PCI_BRIDGE },
1525
    { "usb-storage", QEMU_CAPS_DEVICE_USB_STORAGE },
1526
    { "virtio-mmio", QEMU_CAPS_DEVICE_VIRTIO_MMIO },
1527
    { "ich9-intel-hda", QEMU_CAPS_DEVICE_ICH9_INTEL_HDA },
H
Hu Tao 已提交
1528
    { "pvpanic", QEMU_CAPS_DEVICE_PANIC },
L
Li Zhang 已提交
1529
    { "usb-kbd", QEMU_CAPS_DEVICE_USB_KBD },
1530
    { "memory-backend-ram", QEMU_CAPS_OBJECT_MEMORY_RAM },
1531
    { "memory-backend-file", QEMU_CAPS_OBJECT_MEMORY_FILE },
1532
    { "usb-audio", QEMU_CAPS_OBJECT_USB_AUDIO },
J
John Ferlan 已提交
1533
    { "iothread", QEMU_CAPS_OBJECT_IOTHREAD},
1534
    { "ivshmem", QEMU_CAPS_DEVICE_IVSHMEM },
1535
    { "pc-dimm", QEMU_CAPS_DEVICE_PC_DIMM },
M
Michal Privoznik 已提交
1536
    { "pci-serial", QEMU_CAPS_DEVICE_PCI_SERIAL },
1537
    { "gpex-pcihost", QEMU_CAPS_OBJECT_GPEX},
1538
    { "ioh3420", QEMU_CAPS_DEVICE_IOH3420 },
1539
    { "x3130-upstream", QEMU_CAPS_DEVICE_X3130_UPSTREAM },
1540
    { "xio3130-downstream", QEMU_CAPS_DEVICE_XIO3130_DOWNSTREAM },
1541
    { "rtl8139", QEMU_CAPS_DEVICE_RTL8139 },
1542
    { "e1000", QEMU_CAPS_DEVICE_E1000 },
1543 1544 1545 1546
    { "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 已提交
1547 1548
    { "virtio-gpu-pci", QEMU_CAPS_DEVICE_VIRTIO_GPU },
    { "virtio-gpu-device", QEMU_CAPS_DEVICE_VIRTIO_GPU },
1549 1550
};

1551
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBlk[] = {
1552 1553 1554 1555 1556 1557 1558 1559
    { "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 },
};

1560
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioNet[] = {
1561 1562 1563 1564
    { "tx", QEMU_CAPS_VIRTIO_TX_ALG },
    { "event_idx", QEMU_CAPS_VIRTIO_NET_EVENT_IDX },
};

1565
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPCIAssign[] = {
1566
    { "rombar", QEMU_CAPS_PCI_ROMBAR },
1567 1568 1569 1570
    { "configfd", QEMU_CAPS_PCI_CONFIGFD },
    { "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};

1571
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVfioPCI[] = {
1572 1573 1574
    { "bootindex", QEMU_CAPS_VFIO_PCI_BOOTINDEX },
};

1575
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIDisk[] = {
1576 1577 1578 1579
    { "channel", QEMU_CAPS_SCSI_DISK_CHANNEL },
    { "wwn", QEMU_CAPS_SCSI_DISK_WWN },
};

1580
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsIDEDrive[] = {
1581 1582 1583
    { "wwn", QEMU_CAPS_IDE_DRIVE_WWN },
};

1584
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPixx4PM[] = {
1585 1586 1587 1588
    { "disable_s3", QEMU_CAPS_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_DISABLE_S4 },
};

1589
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBRedir[] = {
1590
    { "filter", QEMU_CAPS_USB_REDIR_FILTER },
1591 1592 1593
    { "bootindex", QEMU_CAPS_USB_REDIR_BOOTINDEX },
};

1594
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBHost[] = {
1595
    { "bootindex", QEMU_CAPS_USB_HOST_BOOTINDEX },
1596 1597
};

1598
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIGeneric[] = {
H
Han Cheng 已提交
1599 1600 1601
    { "bootindex", QEMU_CAPS_DEVICE_SCSI_GENERIC_BOOTINDEX },
};

1602
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsI440FXPCIHost[] = {
1603 1604 1605
    { "pci-hole64-size", QEMU_CAPS_I440FX_PCI_HOLE64_SIZE },
};

1606
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQ35PCIHost[] = {
1607 1608 1609
    { "pci-hole64-size", QEMU_CAPS_Q35_PCI_HOLE64_SIZE },
};

1610
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBStorage[] = {
1611 1612 1613
    { "removable", QEMU_CAPS_USB_STORAGE_REMOVABLE },
};

1614 1615 1616 1617
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsKVMPit[] = {
    { "lost_tick_policy", QEMU_CAPS_KVM_PIT_TICK_POLICY },
};

1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633
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 },
};

static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQxlVga[] = {
    { "vgamem_mb", QEMU_CAPS_QXL_VGA_VGAMEM },
};

1634
struct virQEMUCapsObjectTypeProps {
1635
    const char *type;
1636
    struct virQEMUCapsStringFlags *props;
1637 1638 1639
    size_t nprops;
};

1640 1641 1642 1643
static struct virQEMUCapsObjectTypeProps virQEMUCapsObjectProps[] = {
    { "virtio-blk-pci", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-pci", virQEMUCapsObjectPropsVirtioNet,
1644 1645 1646 1647
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-ccw", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-ccw", virQEMUCapsObjectPropsVirtioNet,
1648 1649 1650 1651 1652
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-s390", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-s390", virQEMUCapsObjectPropsVirtioNet,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
1653 1654 1655 1656 1657 1658
    { "pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "kvm-pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "vfio-pci", virQEMUCapsObjectPropsVfioPCI,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVfioPCI) },
1659 1660
    { "scsi-disk", virQEMUCapsObjectPropsSCSIDisk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIDisk) },
1661 1662 1663 1664
    { "ide-drive", virQEMUCapsObjectPropsIDEDrive,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsIDEDrive) },
    { "PIIX4_PM", virQEMUCapsObjectPropsPixx4PM,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPixx4PM) },
1665 1666 1667 1668
    { "usb-redir", virQEMUCapsObjectPropsUSBRedir,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBRedir) },
    { "usb-host", virQEMUCapsObjectPropsUSBHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBHost) },
1669 1670
    { "scsi-generic", virQEMUCapsObjectPropsSCSIGeneric,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIGeneric) },
1671 1672 1673 1674
    { "i440FX-pcihost", virQEMUCapsObjectPropsI440FXPCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsI440FXPCIHost) },
    { "q35-pcihost", virQEMUCapsObjectPropsQ35PCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQ35PCIHost) },
1675 1676
    { "usb-storage", virQEMUCapsObjectPropsUSBStorage,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBStorage) },
1677 1678
    { "kvm-pit", virQEMUCapsObjectPropsKVMPit,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsKVMPit) },
1679 1680 1681 1682 1683 1684 1685 1686
    { "VGA", virQEMUCapsObjectPropsVGA,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVGA) },
    { "vmware-svga", virQEMUCapsObjectPropsVmwareSvga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVmwareSvga) },
    { "qxl", virQEMUCapsObjectPropsQxl,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxl) },
    { "qxl-vga", virQEMUCapsObjectPropsQxlVga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxlVga) },
1687 1688 1689 1690
};


static void
1691 1692 1693 1694 1695
virQEMUCapsProcessStringFlags(virQEMUCapsPtr qemuCaps,
                              size_t nflags,
                              struct virQEMUCapsStringFlags *flags,
                              size_t nvalues,
                              char *const*values)
1696 1697
{
    size_t i, j;
1698 1699
    for (i = 0; i < nflags; i++) {
        for (j = 0; j < nvalues; j++) {
1700
            if (STREQ(values[j], flags[i].value)) {
1701
                virQEMUCapsSet(qemuCaps, flags[i].flag);
1702 1703 1704 1705 1706 1707 1708 1709
                break;
            }
        }
    }
}


static void
1710 1711
virQEMUCapsFreeStringList(size_t len,
                          char **values)
1712 1713
{
    size_t i;
1714 1715
    if (!values)
        return;
1716
    for (i = 0; i < len; i++)
1717 1718 1719 1720 1721 1722 1723 1724
        VIR_FREE(values[i]);
    VIR_FREE(values);
}


#define OBJECT_TYPE_PREFIX "name \""

static int
1725 1726
virQEMUCapsParseDeviceStrObjectTypes(const char *str,
                                     char ***types)
1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744
{
    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;
        }

1745
        if (VIR_EXPAND_N(typelist, ntypelist, 1) < 0)
1746
            goto cleanup;
1747
        if (VIR_STRNDUP(typelist[ntypelist - 1], tmp, end-tmp) < 0)
1748 1749 1750 1751 1752 1753
            goto cleanup;
    }

    *types = typelist;
    ret = ntypelist;

1754
 cleanup:
1755
    if (ret < 0)
1756
        virQEMUCapsFreeStringList(ntypelist, typelist);
1757 1758 1759 1760 1761
    return ret;
}


static int
1762 1763 1764
virQEMUCapsParseDeviceStrObjectProps(const char *str,
                                     const char *type,
                                     char ***props)
1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797
{
    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;
        }
1798
        if (VIR_EXPAND_N(proplist, nproplist, 1) < 0)
1799
            goto cleanup;
1800
        if (VIR_STRNDUP(proplist[nproplist - 1], tmp, end-tmp) < 0)
1801 1802 1803 1804 1805 1806
            goto cleanup;
    }

    *props = proplist;
    ret = nproplist;

1807
 cleanup:
1808
    if (ret < 0)
1809
        virQEMUCapsFreeStringList(nproplist, proplist);
1810 1811 1812 1813 1814
    return ret;
}


int
1815
virQEMUCapsParseDeviceStr(virQEMUCapsPtr qemuCaps, const char *str)
1816 1817 1818 1819 1820
{
    int nvalues;
    char **values;
    size_t i;

1821
    if ((nvalues = virQEMUCapsParseDeviceStrObjectTypes(str, &values)) < 0)
1822
        return -1;
1823 1824 1825 1826 1827 1828
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

1829
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
1830 1831 1832 1833
        const char *type = virQEMUCapsObjectProps[i].type;
        if ((nvalues = virQEMUCapsParseDeviceStrObjectProps(str,
                                                            type,
                                                            &values)) < 0)
1834
            return -1;
1835 1836 1837 1838 1839
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
1840 1841 1842
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
1843 1844
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
1845 1846 1847 1848 1849

    return 0;
}


E
Eric Blake 已提交
1850
static int
1851 1852
virQEMUCapsExtractDeviceStr(const char *qemu,
                            virQEMUCapsPtr qemuCaps,
1853
                            uid_t runUid, gid_t runGid)
1854
{
E
Eric Blake 已提交
1855
    char *output = NULL;
1856
    virCommandPtr cmd;
E
Eric Blake 已提交
1857
    int ret = -1;
1858

E
Eric Blake 已提交
1859 1860
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
1861 1862
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
1863
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
1864 1865
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
1866
     * if -help includes "device driver,?".  */
1867
    cmd = virQEMUCapsProbeCommand(qemu, qemuCaps, runUid, runGid);
1868 1869 1870 1871 1872 1873
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
1874
                         "-device", "PIIX4_PM,?",
1875
                         "-device", "usb-redir,?",
1876
                         "-device", "ide-drive,?",
1877
                         "-device", "usb-host,?",
H
Han Cheng 已提交
1878
                         "-device", "scsi-generic,?",
1879
                         "-device", "usb-storage,?",
1880 1881 1882 1883
                         "-device", "VGA,?",
                         "-device", "vmware-svga,?",
                         "-device", "qxl,?",
                         "-device", "qxl-vga,?",
1884
                         NULL);
1885
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
1886
    virCommandSetErrorBuffer(cmd, &output);
1887

1888
    if (virCommandRun(cmd, NULL) < 0)
1889 1890
        goto cleanup;

1891
    ret = virQEMUCapsParseDeviceStr(qemuCaps, output);
1892

1893
 cleanup:
E
Eric Blake 已提交
1894
    VIR_FREE(output);
1895
    virCommandFree(cmd);
E
Eric Blake 已提交
1896 1897 1898
    return ret;
}

1899

1900 1901 1902
int virQEMUCapsGetDefaultVersion(virCapsPtr caps,
                                 virQEMUCapsCachePtr capsCache,
                                 unsigned int *version)
1903
{
1904
    virQEMUCapsPtr qemucaps;
T
Tal Kain 已提交
1905
    virArch hostarch;
1906
    virCapsDomainDataPtr capsdata;
1907 1908 1909 1910

    if (*version > 0)
        return 0;

T
Tal Kain 已提交
1911
    hostarch = virArchFromHost();
1912 1913 1914
    if (!(capsdata = virCapabilitiesDomainDataLookup(caps,
            VIR_DOMAIN_OSTYPE_HVM, hostarch, VIR_DOMAIN_VIRT_QEMU,
            NULL, NULL))) {
1915
        virReportError(VIR_ERR_INTERNAL_ERROR,
1916
                       _("Cannot find suitable emulator for %s"),
T
Tal Kain 已提交
1917
                       virArchToString(hostarch));
1918 1919 1920
        return -1;
    }

1921 1922 1923
    qemucaps = virQEMUCapsCacheLookup(capsCache, capsdata->emulator);
    VIR_FREE(capsdata);
    if (!qemucaps)
1924 1925
        return -1;

1926
    *version = virQEMUCapsGetVersion(qemucaps);
1927
    virObjectUnref(qemucaps);
1928 1929
    return 0;
}
1930 1931


1932 1933


1934 1935
virQEMUCapsPtr
virQEMUCapsNew(void)
1936
{
1937
    virQEMUCapsPtr qemuCaps;
1938

1939
    if (virQEMUCapsInitialize() < 0)
1940 1941
        return NULL;

1942
    if (!(qemuCaps = virObjectNew(virQEMUCapsClass)))
1943 1944
        return NULL;

1945
    if (!(qemuCaps->flags = virBitmapNew(QEMU_CAPS_LAST)))
1946
        goto error;
1947

1948
    return qemuCaps;
1949

1950
 error:
1951
    virObjectUnref(qemuCaps);
1952
    return NULL;
1953 1954 1955
}


1956
virQEMUCapsPtr virQEMUCapsNewCopy(virQEMUCapsPtr qemuCaps)
1957
{
1958
    virQEMUCapsPtr ret = virQEMUCapsNew();
1959 1960 1961 1962 1963
    size_t i;

    if (!ret)
        return NULL;

1964
    virBitmapCopy(ret->flags, qemuCaps->flags);
1965

1966 1967 1968
    ret->usedQMP = qemuCaps->usedQMP;
    ret->version = qemuCaps->version;
    ret->kvmVersion = qemuCaps->kvmVersion;
1969 1970 1971 1972

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

1973
    ret->arch = qemuCaps->arch;
1974

1975
    if (VIR_ALLOC_N(ret->cpuDefinitions, qemuCaps->ncpuDefinitions) < 0)
1976
        goto error;
1977
    ret->ncpuDefinitions = qemuCaps->ncpuDefinitions;
1978
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
1979 1980
        if (VIR_STRDUP(ret->cpuDefinitions[i], qemuCaps->cpuDefinitions[i]) < 0)
            goto error;
1981 1982
    }

1983
    if (VIR_ALLOC_N(ret->machineTypes, qemuCaps->nmachineTypes) < 0)
1984
        goto error;
1985
    if (VIR_ALLOC_N(ret->machineAliases, qemuCaps->nmachineTypes) < 0)
1986
        goto error;
1987
    if (VIR_ALLOC_N(ret->machineMaxCpus, qemuCaps->nmachineTypes) < 0)
1988
        goto error;
1989
    ret->nmachineTypes = qemuCaps->nmachineTypes;
1990
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
1991 1992 1993
        if (VIR_STRDUP(ret->machineTypes[i], qemuCaps->machineTypes[i]) < 0 ||
            VIR_STRDUP(ret->machineAliases[i], qemuCaps->machineAliases[i]) < 0)
            goto error;
1994
        ret->machineMaxCpus[i] = qemuCaps->machineMaxCpus[i];
1995 1996 1997 1998
    }

    return ret;

1999
 error:
2000 2001 2002 2003 2004
    virObjectUnref(ret);
    return NULL;
}


2005
void virQEMUCapsDispose(void *obj)
2006
{
2007
    virQEMUCapsPtr qemuCaps = obj;
2008 2009
    size_t i;

2010
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2011 2012
        VIR_FREE(qemuCaps->machineTypes[i]);
        VIR_FREE(qemuCaps->machineAliases[i]);
2013
    }
2014 2015
    VIR_FREE(qemuCaps->machineTypes);
    VIR_FREE(qemuCaps->machineAliases);
2016
    VIR_FREE(qemuCaps->machineMaxCpus);
2017

2018
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
2019 2020
        VIR_FREE(qemuCaps->cpuDefinitions[i]);
    VIR_FREE(qemuCaps->cpuDefinitions);
2021

2022
    virBitmapFree(qemuCaps->flags);
2023

2024
    VIR_FREE(qemuCaps->package);
2025
    VIR_FREE(qemuCaps->binary);
2026 2027
}

2028
void
2029
virQEMUCapsSet(virQEMUCapsPtr qemuCaps,
2030
               virQEMUCapsFlags flag)
2031
{
2032
    ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2033 2034 2035 2036
}


void
2037
virQEMUCapsSetList(virQEMUCapsPtr qemuCaps, ...)
2038 2039 2040 2041
{
    va_list list;
    int flag;

2042
    va_start(list, qemuCaps);
2043
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
2044
        ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2045
    va_end(list);
2046 2047 2048 2049
}


void
2050
virQEMUCapsClear(virQEMUCapsPtr qemuCaps,
2051
                 virQEMUCapsFlags flag)
2052
{
2053
    ignore_value(virBitmapClearBit(qemuCaps->flags, flag));
2054 2055 2056
}


2057
char *virQEMUCapsFlagsString(virQEMUCapsPtr qemuCaps)
2058
{
2059
    return virBitmapString(qemuCaps->flags);
2060 2061 2062 2063
}


bool
2064
virQEMUCapsGet(virQEMUCapsPtr qemuCaps,
2065
               virQEMUCapsFlags flag)
2066
{
J
Ján Tomko 已提交
2067
    return qemuCaps && virBitmapIsBitSet(qemuCaps->flags, flag);
2068
}
2069 2070


D
Daniel P. Berrange 已提交
2071 2072 2073 2074 2075 2076 2077 2078 2079
bool virQEMUCapsHasPCIMultiBus(virQEMUCapsPtr qemuCaps,
                               virDomainDefPtr def)
{
    bool hasMultiBus = virQEMUCapsGet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);

    if (hasMultiBus)
        return true;

    if (def->os.arch == VIR_ARCH_PPC ||
2080
        ARCH_IS_PPC64(def->os.arch)) {
D
Daniel P. Berrange 已提交
2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116
        /*
         * 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;
    }

2117 2118 2119 2120 2121 2122 2123 2124
    if (ARCH_IS_ARM(def->os.arch)) {
        /* If 'virt' supports PCI, it supports multibus.
         * No extra conditions here for simplicity.
         */
        if (STREQ(def->os.machine, "virt"))
            return true;
    }

D
Daniel P. Berrange 已提交
2125 2126 2127 2128
    return false;
}


2129
const char *virQEMUCapsGetBinary(virQEMUCapsPtr qemuCaps)
2130
{
2131
    return qemuCaps->binary;
2132 2133
}

2134
virArch virQEMUCapsGetArch(virQEMUCapsPtr qemuCaps)
2135
{
2136
    return qemuCaps->arch;
2137 2138 2139
}


2140
unsigned int virQEMUCapsGetVersion(virQEMUCapsPtr qemuCaps)
2141
{
2142
    return qemuCaps->version;
2143 2144 2145
}


2146
unsigned int virQEMUCapsGetKVMVersion(virQEMUCapsPtr qemuCaps)
2147
{
2148
    return qemuCaps->kvmVersion;
2149 2150 2151
}


2152 2153 2154 2155 2156 2157
const char *virQEMUCapsGetPackage(virQEMUCapsPtr qemuCaps)
{
    return qemuCaps->package;
}


2158 2159
int virQEMUCapsAddCPUDefinition(virQEMUCapsPtr qemuCaps,
                                const char *name)
2160
{
2161 2162 2163
    char *tmp;

    if (VIR_STRDUP(tmp, name) < 0)
2164
        return -1;
2165
    if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
2166 2167 2168
        VIR_FREE(tmp);
        return -1;
    }
2169
    qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions-1] = tmp;
2170 2171 2172 2173
    return 0;
}


2174 2175
size_t virQEMUCapsGetCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                    char ***names)
2176
{
2177
    if (names)
2178 2179
        *names = qemuCaps->cpuDefinitions;
    return qemuCaps->ncpuDefinitions;
2180 2181 2182
}


2183 2184
size_t virQEMUCapsGetMachineTypes(virQEMUCapsPtr qemuCaps,
                                  char ***names)
2185
{
2186
    if (names)
2187 2188
        *names = qemuCaps->machineTypes;
    return qemuCaps->nmachineTypes;
2189 2190
}

2191 2192 2193
int virQEMUCapsGetMachineTypesCaps(virQEMUCapsPtr qemuCaps,
                                   size_t *nmachines,
                                   virCapsGuestMachinePtr **machines)
2194 2195 2196 2197
{
    size_t i;

    *machines = NULL;
2198
    *nmachines = qemuCaps->nmachineTypes;
2199

2200 2201 2202 2203
    if (*nmachines &&
        VIR_ALLOC_N(*machines, qemuCaps->nmachineTypes) < 0)
        goto error;

2204
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2205 2206
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
2207
            goto error;
2208
        (*machines)[i] = mach;
2209
        if (qemuCaps->machineAliases[i]) {
2210 2211 2212
            if (VIR_STRDUP(mach->name, qemuCaps->machineAliases[i]) < 0 ||
                VIR_STRDUP(mach->canonical, qemuCaps->machineTypes[i]) < 0)
                goto error;
2213
        } else {
2214 2215
            if (VIR_STRDUP(mach->name, qemuCaps->machineTypes[i]) < 0)
                goto error;
2216
        }
2217
        mach->maxCpus = qemuCaps->machineMaxCpus[i];
2218 2219
    }

2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257
    /* 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++;
    }

2258 2259
    return 0;

2260
 error:
2261 2262 2263 2264 2265 2266 2267 2268
    virCapabilitiesFreeMachines(*machines, *nmachines);
    *nmachines = 0;
    *machines = NULL;
    return -1;
}



2269

2270 2271
const char *virQEMUCapsGetCanonicalMachine(virQEMUCapsPtr qemuCaps,
                                           const char *name)
2272 2273 2274
{
    size_t i;

2275 2276 2277
    if (!name)
        return NULL;

2278
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2279
        if (!qemuCaps->machineAliases[i])
2280
            continue;
2281 2282
        if (STREQ(qemuCaps->machineAliases[i], name))
            return qemuCaps->machineTypes[i];
2283 2284 2285 2286
    }

    return name;
}
2287 2288


2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307
int virQEMUCapsGetMachineMaxCpus(virQEMUCapsPtr qemuCaps,
                                 const char *name)
{
    size_t i;

    if (!name)
        return 0;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
        if (!qemuCaps->machineMaxCpus[i])
            continue;
        if (STREQ(qemuCaps->machineTypes[i], name))
            return qemuCaps->machineMaxCpus[i];
    }

    return 0;
}


2308
static int
2309 2310
virQEMUCapsProbeQMPCommands(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2311 2312 2313 2314 2315 2316 2317
{
    char **commands = NULL;
    int ncommands;

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

2318 2319 2320 2321 2322
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsCommands),
                                  virQEMUCapsCommands,
                                  ncommands, commands);
    virQEMUCapsFreeStringList(ncommands, commands);
2323

2324 2325 2326 2327
    /* 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.  */
2328
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ADD_FD)) {
2329 2330 2331 2332 2333 2334 2335
        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)
2336
            virQEMUCapsClear(qemuCaps, QEMU_CAPS_ADD_FD);
2337 2338 2339
        VIR_FORCE_CLOSE(fd);
    }

2340 2341 2342 2343 2344 2345
    /* 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);

2346 2347 2348 2349 2350
    return 0;
}


static int
2351 2352
virQEMUCapsProbeQMPEvents(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
2353 2354 2355 2356 2357 2358 2359
{
    char **events = NULL;
    int nevents;

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

2360 2361 2362 2363 2364
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsEvents),
                                  virQEMUCapsEvents,
                                  nevents, events);
    virQEMUCapsFreeStringList(nevents, events);
2365 2366 2367 2368 2369

    return 0;
}


2370
static int
2371 2372
virQEMUCapsProbeQMPObjects(virQEMUCapsPtr qemuCaps,
                           qemuMonitorPtr mon)
2373 2374 2375 2376 2377 2378 2379
{
    int nvalues;
    char **values;
    size_t i;

    if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
        return -1;
2380 2381 2382 2383 2384 2385
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

2386
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
2387
        const char *type = virQEMUCapsObjectProps[i].type;
2388 2389 2390 2391
        if ((nvalues = qemuMonitorGetObjectProps(mon,
                                                 type,
                                                 &values)) < 0)
            return -1;
2392 2393 2394 2395 2396
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
2397 2398 2399
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2400 2401
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2402
    /* If qemu supports newer -device qxl it supports -vga qxl as well */
2403 2404
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_QXL))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
2405 2406 2407 2408 2409 2410

    return 0;
}


static int
2411 2412
virQEMUCapsProbeQMPMachineTypes(virQEMUCapsPtr qemuCaps,
                                qemuMonitorPtr mon)
2413 2414 2415 2416 2417
{
    qemuMonitorMachineInfoPtr *machines = NULL;
    int nmachines = 0;
    int ret = -1;
    size_t i;
2418
    size_t defIdx = 0;
2419 2420

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

2423
    if (VIR_ALLOC_N(qemuCaps->machineTypes, nmachines) < 0)
2424
        goto cleanup;
2425
    if (VIR_ALLOC_N(qemuCaps->machineAliases, nmachines) < 0)
2426
        goto cleanup;
2427
    if (VIR_ALLOC_N(qemuCaps->machineMaxCpus, nmachines) < 0)
2428
        goto cleanup;
2429

2430
    for (i = 0; i < nmachines; i++) {
2431 2432
        if (STREQ(machines[i]->name, "none"))
            continue;
2433 2434 2435 2436 2437
        qemuCaps->nmachineTypes++;
        if (VIR_STRDUP(qemuCaps->machineAliases[qemuCaps->nmachineTypes -1],
                       machines[i]->alias) < 0 ||
            VIR_STRDUP(qemuCaps->machineTypes[qemuCaps->nmachineTypes - 1],
                       machines[i]->name) < 0)
2438
            goto cleanup;
2439
        if (machines[i]->isDefault)
2440
            defIdx = qemuCaps->nmachineTypes - 1;
2441 2442
        qemuCaps->machineMaxCpus[qemuCaps->nmachineTypes - 1] =
            machines[i]->maxCpus;
2443
    }
2444 2445

    if (defIdx)
2446
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
2447 2448 2449

    ret = 0;

2450
 cleanup:
2451
    for (i = 0; i < nmachines; i++)
2452 2453 2454 2455 2456 2457 2458
        qemuMonitorMachineInfoFree(machines[i]);
    VIR_FREE(machines);
    return ret;
}


static int
2459 2460
virQEMUCapsProbeQMPCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                  qemuMonitorPtr mon)
2461 2462 2463 2464 2465 2466 2467
{
    int ncpuDefinitions;
    char **cpuDefinitions;

    if ((ncpuDefinitions = qemuMonitorGetCPUDefinitions(mon, &cpuDefinitions)) < 0)
        return -1;

2468 2469
    qemuCaps->ncpuDefinitions = ncpuDefinitions;
    qemuCaps->cpuDefinitions = cpuDefinitions;
2470 2471 2472 2473

    return 0;
}

2474 2475
struct tpmTypeToCaps {
    int type;
2476
    virQEMUCapsFlags caps;
2477 2478 2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496
};

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)
{
2497 2498
    int nentries;
    size_t i;
2499
    char **entries = NULL;
S
Stefan Berger 已提交
2500

2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530
    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);
            if (virStringArrayHasString(entries, needle))
                virQEMUCapsSet(qemuCaps,
                               virQEMUCapsTPMModelsToCaps[i].caps);
        }
    }
    virStringFreeList(entries);

    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);
            if (virStringArrayHasString(entries, needle))
                virQEMUCapsSet(qemuCaps, virQEMUCapsTPMTypesToCaps[i].caps);
        }
    }
    virStringFreeList(entries);

    return 0;
}

2531

2532
static int
2533 2534
virQEMUCapsProbeQMPKVMState(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2535 2536 2537 2538
{
    bool enabled = false;
    bool present = false;

2539
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
2540 2541 2542 2543 2544 2545
        return 0;

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

    /* The QEMU_CAPS_KVM flag was initially set according to the QEMU
2546
     * reporting the recognition of 'query-kvm' QMP command. That merely
N
Nehal J Wani 已提交
2547
     * indicates existence of the command though, not whether KVM support
2548 2549 2550 2551 2552 2553
     * 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) {
2554
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
2555
    } else if (!enabled) {
2556 2557
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
2558 2559 2560 2561 2562
    }

    return 0;
}

2563 2564 2565 2566 2567 2568 2569 2570
struct virQEMUCapsCommandLineProps {
    const char *option;
    const char *param;
    int flag;
};

static struct virQEMUCapsCommandLineProps virQEMUCapsCommandLine[] = {
    { "machine", "mem-merge", QEMU_CAPS_MEM_MERGE },
2571
    { "machine", "vmport", QEMU_CAPS_MACHINE_VMPORT_OPT },
O
Osier Yang 已提交
2572
    { "drive", "discard", QEMU_CAPS_DRIVE_DISCARD },
2573
    { "realtime", "mlock", QEMU_CAPS_MLOCK },
2574
    { "boot-opts", "strict", QEMU_CAPS_BOOT_STRICT },
2575
    { "boot-opts", "reboot-timeout", QEMU_CAPS_REBOOT_TIMEOUT },
2576
    { "boot-opts", "splash-time", QEMU_CAPS_SPLASH_TIMEOUT },
2577
    { "spice", "disable-agent-file-xfer", QEMU_CAPS_SPICE_FILE_XFER_DISABLE },
2578
    { "msg", "timestamp", QEMU_CAPS_MSG_TIMESTAMP },
2579
    { "numa", NULL, QEMU_CAPS_NUMA },
2580
    { "drive", "throttling.bps-total-max", QEMU_CAPS_DRIVE_IOTUNE_MAX},
2581 2582
    { "machine", "aes-key-wrap", QEMU_CAPS_AES_KEY_WRAP },
    { "machine", "dea-key-wrap", QEMU_CAPS_DEA_KEY_WRAP },
2583 2584 2585 2586 2587 2588
};

static int
virQEMUCapsProbeQMPCommandLine(virQEMUCapsPtr qemuCaps,
                               qemuMonitorPtr mon)
{
2589
    bool found = false;
2590 2591 2592 2593 2594 2595 2596
    int nvalues;
    char **values;
    size_t i, j;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsCommandLine); i++) {
        if ((nvalues = qemuMonitorGetCommandLineOptionParameters(mon,
                                                                 virQEMUCapsCommandLine[i].option,
2597 2598
                                                                 &values,
                                                                 &found)) < 0)
2599
            return -1;
2600 2601 2602 2603

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

2604
        for (j = 0; j < nvalues; j++) {
2605
            if (STREQ_NULLABLE(virQEMUCapsCommandLine[i].param, values[j])) {
2606 2607 2608 2609 2610 2611 2612 2613 2614
                virQEMUCapsSet(qemuCaps, virQEMUCapsCommandLine[i].flag);
                break;
            }
        }
        virStringFreeList(values);
    }

    return 0;
}
2615

2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634
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);
    virQEMUCapsFreeStringList(ncaps, caps);

    return 0;
}

2635 2636
int virQEMUCapsProbeQMP(virQEMUCapsPtr qemuCaps,
                        qemuMonitorPtr mon)
2637
{
2638
    VIR_DEBUG("qemuCaps=%p mon=%p", qemuCaps, mon);
2639

2640
    if (qemuCaps->usedQMP)
2641 2642
        return 0;

2643
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
2644 2645
        return -1;

2646
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
2647 2648 2649 2650 2651 2652
        return -1;

    return 0;
}


2653 2654 2655 2656 2657 2658
/*
 * Parsing a doc that looks like
 *
 * <qemuCaps>
 *   <qemuctime>234235253</qemuctime>
 *   <selfctime>234235253</selfctime>
2659
 *   <selfvers>1002016</selfvers>
2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671
 *   <usedQMP/>
 *   <flag name='foo'/>
 *   <flag name='bar'/>
 *   ...
 *   <cpu name="pentium3"/>
 *   ...
 *   <machine name="pc-1.0" alias="pc" maxCpus="4"/>
 *   ...
 * </qemuCaps>
 */
static int
virQEMUCapsLoadCache(virQEMUCapsPtr qemuCaps, const char *filename,
2672 2673
                     time_t *qemuctime, time_t *selfctime,
                     unsigned long *selfvers)
2674 2675 2676 2677 2678 2679 2680
{
    xmlDocPtr doc = NULL;
    int ret = -1;
    size_t i;
    int n;
    xmlNodePtr *nodes = NULL;
    xmlXPathContextPtr ctxt = NULL;
J
Ján Tomko 已提交
2681
    char *str = NULL;
2682
    long long int l;
2683
    unsigned long lu;
2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716

    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;
    }
    *qemuctime = (time_t)l;

    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;

2717 2718 2719 2720
    *selfvers = 0;
    if (virXPathULong("string(./selfvers)", ctxt, &lu) == 0)
        *selfvers = lu;

2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761
    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);
    if (n > 0) {
        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;
            }
            VIR_FREE(str);
            virQEMUCapsSet(qemuCaps, flag);
        }
    }
    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;
    }

2762 2763 2764
    /* Don't check for NULL, since it is optional and thus may be missing */
    qemuCaps->package = virXPathString("string(./package)", ctxt);

2765 2766 2767 2768 2769 2770 2771 2772 2773 2774
    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 已提交
2775
    VIR_FREE(str);
2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788

    if ((n = virXPathNodeSet("./cpu", ctxt, &nodes)) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("failed to parse qemu capabilities cpus"));
        goto cleanup;
    }
    if (n > 0) {
        qemuCaps->ncpuDefinitions = n;
        if (VIR_ALLOC_N(qemuCaps->cpuDefinitions,
                        qemuCaps->ncpuDefinitions) < 0)
            goto cleanup;

        for (i = 0; i < n; i++) {
J
Ján Tomko 已提交
2789
            if (!(qemuCaps->cpuDefinitions[i] = virXMLPropString(nodes[i], "name"))) {
2790 2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing cpu name in QEMU capabilities cache"));
                goto cleanup;
            }
        }
    }
    VIR_FREE(nodes);


    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;
        if (VIR_ALLOC_N(qemuCaps->machineTypes,
                        qemuCaps->nmachineTypes) < 0 ||
            VIR_ALLOC_N(qemuCaps->machineAliases,
                        qemuCaps->nmachineTypes) < 0 ||
            VIR_ALLOC_N(qemuCaps->machineMaxCpus,
                        qemuCaps->nmachineTypes) < 0)
            goto cleanup;

        for (i = 0; i < n; i++) {
J
Ján Tomko 已提交
2815
            if (!(qemuCaps->machineTypes[i] = virXMLPropString(nodes[i], "name"))) {
2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("missing machine name in QEMU capabilities cache"));
                goto cleanup;
            }
            qemuCaps->machineAliases[i] = virXMLPropString(nodes[i], "alias");

            str = virXMLPropString(nodes[i], "maxCpus");
            if (str &&
                virStrToLong_ui(str, NULL, 10, &(qemuCaps->machineMaxCpus[i])) < 0) {
                virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                               _("malformed machine cpu count in QEMU capabilities cache"));
                goto cleanup;
            }
J
Ján Tomko 已提交
2829
            VIR_FREE(str);
2830 2831 2832 2833 2834
        }
    }
    VIR_FREE(nodes);

    ret = 0;
2835
 cleanup:
J
Ján Tomko 已提交
2836
    VIR_FREE(str);
2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847
    VIR_FREE(nodes);
    xmlXPathFreeContext(ctxt);
    xmlFreeDoc(doc);
    return ret;
}


static int
virQEMUCapsSaveCache(virQEMUCapsPtr qemuCaps, const char *filename)
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
M
Michal Privoznik 已提交
2848
    char *xml = NULL;
2849 2850 2851 2852
    int ret = -1;
    size_t i;

    virBufferAddLit(&buf, "<qemuCaps>\n");
2853
    virBufferAdjustIndent(&buf, 2);
2854

2855
    virBufferAsprintf(&buf, "<qemuctime>%llu</qemuctime>\n",
2856
                      (long long)qemuCaps->ctime);
2857
    virBufferAsprintf(&buf, "<selfctime>%llu</selfctime>\n",
2858
                      (long long)virGetSelfLastChanged());
2859 2860
    virBufferAsprintf(&buf, "<selfvers>%lu</selfvers>\n",
                      (unsigned long)LIBVIR_VERSION_NUMBER);
2861 2862

    if (qemuCaps->usedQMP)
2863
        virBufferAddLit(&buf, "<usedQMP/>\n");
2864 2865 2866

    for (i = 0; i < QEMU_CAPS_LAST; i++) {
        if (virQEMUCapsGet(qemuCaps, i)) {
2867
            virBufferAsprintf(&buf, "<flag name='%s'/>\n",
2868 2869 2870 2871
                              virQEMUCapsTypeToString(i));
        }
    }

2872
    virBufferAsprintf(&buf, "<version>%d</version>\n",
2873 2874
                      qemuCaps->version);

2875
    virBufferAsprintf(&buf, "<kvmVersion>%d</kvmVersion>\n",
2876 2877
                      qemuCaps->kvmVersion);

2878 2879 2880 2881
    if (qemuCaps->package)
        virBufferAsprintf(&buf, "<package>%s</package>\n",
                          qemuCaps->package);

2882
    virBufferAsprintf(&buf, "<arch>%s</arch>\n",
2883 2884 2885
                      virArchToString(qemuCaps->arch));

    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
2886
        virBufferEscapeString(&buf, "<cpu name='%s'/>\n",
2887 2888 2889 2890
                              qemuCaps->cpuDefinitions[i]);
    }

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2891
        virBufferEscapeString(&buf, "<machine name='%s'",
2892 2893 2894 2895 2896 2897 2898 2899
                              qemuCaps->machineTypes[i]);
        if (qemuCaps->machineAliases[i])
            virBufferEscapeString(&buf, " alias='%s'",
                              qemuCaps->machineAliases[i]);
        virBufferAsprintf(&buf, " maxCpus='%u'/>\n",
                          qemuCaps->machineMaxCpus[i]);
    }

2900
    virBufferAdjustIndent(&buf, -2);
2901 2902
    virBufferAddLit(&buf, "</qemuCaps>\n");

2903
    if (virBufferCheckError(&buf) < 0)
2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970
        goto cleanup;

    xml = virBufferContentAndReset(&buf);

    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;
2971
    VIR_FREE(qemuCaps->package);
2972 2973 2974
    qemuCaps->arch = VIR_ARCH_NONE;
    qemuCaps->usedQMP = false;

2975
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
2976 2977 2978 2979 2980 2981 2982 2983 2984 2985
        VIR_FREE(qemuCaps->cpuDefinitions[i]);
    VIR_FREE(qemuCaps->cpuDefinitions);
    qemuCaps->ncpuDefinitions = 0;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
        VIR_FREE(qemuCaps->machineTypes[i]);
        VIR_FREE(qemuCaps->machineAliases[i]);
    }
    VIR_FREE(qemuCaps->machineTypes);
    VIR_FREE(qemuCaps->machineAliases);
J
Ján Tomko 已提交
2986
    VIR_FREE(qemuCaps->machineMaxCpus);
2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000
    qemuCaps->nmachineTypes = 0;
}


static int
virQEMUCapsInitCached(virQEMUCapsPtr qemuCaps, const char *cacheDir)
{
    char *capsdir = NULL;
    char *capsfile = NULL;
    int ret = -1;
    char *binaryhash = NULL;
    struct stat sb;
    time_t qemuctime;
    time_t selfctime;
3001
    unsigned long selfvers;
3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030 3031 3032 3033

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

3034 3035
    if (virQEMUCapsLoadCache(qemuCaps, capsfile, &qemuctime, &selfctime,
                             &selfvers) < 0) {
3036 3037 3038 3039 3040 3041 3042 3043 3044 3045
        virErrorPtr err = virGetLastError();
        VIR_WARN("Failed to load cached caps from '%s' for '%s': %s",
                 capsfile, qemuCaps->binary, err ? NULLSTR(err->message) :
                 _("unknown error"));
        virResetLastError();
        ret = 0;
        virQEMUCapsReset(qemuCaps);
        goto cleanup;
    }

3046
    /* Discard cache if QEMU binary or libvirtd changed */
3047
    if (qemuctime != qemuCaps->ctime ||
3048 3049
        selfctime != virGetSelfLastChanged() ||
        selfvers != LIBVIR_VERSION_NUMBER) {
3050
        VIR_DEBUG("Outdated cached capabilities '%s' for '%s' "
3051
                  "(%lld vs %lld, %lld vs %lld, %lu vs %lu)",
3052 3053
                  capsfile, qemuCaps->binary,
                  (long long)qemuctime, (long long)qemuCaps->ctime,
3054 3055
                  (long long)selfctime, (long long)virGetSelfLastChanged(),
                  selfvers, (unsigned long)LIBVIR_VERSION_NUMBER);
3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074
        ignore_value(unlink(capsfile));
        virQEMUCapsReset(qemuCaps);
        ret = 0;
        goto cleanup;
    }

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

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


3075 3076
#define QEMU_SYSTEM_PREFIX "qemu-system-"

3077
static int
3078
virQEMUCapsInitHelp(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid, const char *qmperr)
3079
{
3080
    virCommandPtr cmd = NULL;
3081
    bool is_kvm;
3082
    char *help = NULL;
3083 3084
    int ret = -1;
    const char *tmp;
3085

3086
    VIR_DEBUG("qemuCaps=%p", qemuCaps);
3087

3088
    tmp = strstr(qemuCaps->binary, QEMU_SYSTEM_PREFIX);
3089 3090
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
3091

3092
        qemuCaps->arch = virQEMUCapsArchFromString(tmp);
3093
    } else {
3094
        qemuCaps->arch = virArchFromHost();
3095 3096
    }

3097
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, NULL, runUid, runGid);
3098 3099 3100 3101
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
3102
        goto cleanup;
3103

3104 3105 3106 3107 3108
    if (virQEMUCapsParseHelpStr(qemuCaps->binary,
                                help, qemuCaps,
                                &qemuCaps->version,
                                &is_kvm,
                                &qemuCaps->kvmVersion,
3109 3110
                                false,
                                qmperr) < 0)
3111
        goto cleanup;
3112

D
Daniel P. Berrange 已提交
3113 3114 3115 3116 3117 3118 3119
    /* x86_64 and i686 support PCI-multibus on all machine types
     * since forever. For other architectures, it has been changing
     * across releases, per machine type, so we can't simply detect
     * it here. Thus the rest of the logic is provided in a separate
     * helper virQEMUCapsHasPCIMultiBus() which keys off the machine
     * stored in virDomainDef and QEMU version number
     */
3120
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
D
Daniel P. Berrange 已提交
3121
        qemuCaps->arch == VIR_ARCH_I686)
3122
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
D
Daniel P. Berrange 已提交
3123 3124 3125 3126 3127

    /* -no-acpi is not supported on non-x86
     * even if qemu reports it in -help */
    if (qemuCaps->arch != VIR_ARCH_X86_64 &&
        qemuCaps->arch != VIR_ARCH_I686)
3128
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_NO_ACPI);
3129

3130
    /* virQEMUCapsExtractDeviceStr will only set additional caps if qemu
3131
     * understands the 0.13.0+ notion of "-device driver,".  */
3132
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
3133
        strstr(help, "-device driver,?") &&
3134 3135
        virQEMUCapsExtractDeviceStr(qemuCaps->binary,
                                    qemuCaps, runUid, runGid) < 0) {
3136
        goto cleanup;
3137
    }
3138

3139
    if (virQEMUCapsProbeCPUModels(qemuCaps, runUid, runGid) < 0)
3140
        goto cleanup;
3141

3142
    if (virQEMUCapsProbeMachineTypes(qemuCaps, runUid, runGid) < 0)
3143
        goto cleanup;
3144

3145
    ret = 0;
3146
 cleanup:
3147
    virCommandFree(cmd);
3148
    VIR_FREE(help);
3149 3150 3151 3152
    return ret;
}


3153
static void virQEMUCapsMonitorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
3154 3155
                                     virDomainObjPtr vm ATTRIBUTE_UNUSED,
                                     void *opaque ATTRIBUTE_UNUSED)
3156 3157 3158 3159
{
}

static qemuMonitorCallbacks callbacks = {
3160 3161
    .eofNotify = virQEMUCapsMonitorNotify,
    .errorNotify = virQEMUCapsMonitorNotify,
3162 3163 3164 3165 3166 3167 3168
};


/* Capabilities that we assume are always enabled
 * for QEMU >= 1.2.0
 */
static void
3169
virQEMUCapsInitQMPBasic(virQEMUCapsPtr qemuCaps)
3170
{
3171 3172 3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204
    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_BALLOON);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMP_TOPOLOGY);
    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_DRIVE_READONLY);
    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_DEVICE_QXL_VGA);
    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_VIRTIO_BLK_SG_IO);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_HOST);
    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 已提交
3205
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);
J
Ján Tomko 已提交
3206
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
3207 3208
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
3209
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
3210
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
3211 3212
}

3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231
/* Capabilities that are architecture depending
 * initialized for QEMU.
 */
static int
virQEMUCapsInitArchQMPBasic(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
{
    char *archstr = NULL;
    int ret = -1;

    if (!(archstr = qemuMonitorGetTargetArch(mon)))
        return -1;

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

D
Daniel P. Berrange 已提交
3232 3233 3234 3235 3236 3237 3238 3239
    /* x86_64 and i686 support PCI-multibus on all machine types
     * since forever. For other architectures, it has been changing
     * across releases, per machine type, so we can't simply detect
     * it here. Thus the rest of the logic is provided in a separate
     * helper virQEMUCapsHasPCIMultiBus() which keys off the machine
     * stored in virDomainDef and QEMU version number
     *
     * ACPI/HPET/KVM PIT are also x86 specific
3240 3241 3242 3243 3244
     */
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
        qemuCaps->arch == VIR_ARCH_I686) {
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
J
Ján Tomko 已提交
3245
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
3246 3247 3248 3249 3250
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
    }

    ret = 0;

3251
 cleanup:
3252 3253 3254
    VIR_FREE(archstr);
    return ret;
}
3255

3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274 3275 3276 3277 3278 3279 3280 3281 3282 3283 3284 3285 3286 3287 3288 3289 3290 3291 3292 3293
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) {
        virErrorPtr err = virGetLastError();
        VIR_DEBUG("Failed to set monitor capabilities %s",
                  err ? err->message : "<unknown problem>");
        ret = 0;
        goto cleanup;
    }

    if (qemuMonitorGetVersion(mon,
                              &major, &minor, &micro,
                              &package) < 0) {
        virErrorPtr err = virGetLastError();
        VIR_DEBUG("Failed to query monitor version %s",
                  err ? err->message : "<unknown problem>");
        ret = 0;
        goto cleanup;
    }

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

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

    qemuCaps->version = major * 1000000 + minor * 1000 + micro;
3294
    qemuCaps->package = package;
3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305 3306 3307 3308 3309
    qemuCaps->usedQMP = true;

    virQEMUCapsInitQMPBasic(qemuCaps);

    if (virQEMUCapsInitArchQMPBasic(qemuCaps, mon) < 0)
        goto cleanup;

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

3310 3311 3312 3313 3314 3315
    /* -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);

3316 3317 3318
    if (qemuCaps->version >= 1006000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE_VIDEO_PRIMARY);

3319 3320 3321 3322
    /* vmport option is supported v2.2.0 onwards */
    if (qemuCaps->version >= 2002000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_VMPORT_OPT);

3323 3324 3325 3326 3327 3328
    /* -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);

3329 3330 3331
    /* 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 已提交
3332
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOSTUSER_MULTIQUEUE);
3333

3334 3335 3336 3337
    /* Since 2.4.50 ARM virt machine supports gic-version option */
    if (qemuCaps->version >= 2004050)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACH_VIRT_GIC_VERSION);

3338 3339 3340 3341 3342 3343 3344 3345 3346 3347 3348 3349 3350 3351 3352 3353
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPObjects(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPMachineTypes(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPCPUDefinitions(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPKVMState(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPTPM(qemuCaps, mon) < 0)
        goto cleanup;
    if (virQEMUCapsProbeQMPCommandLine(qemuCaps, mon) < 0)
        goto cleanup;
3354 3355
    if (virQEMUCapsProbeQMPMigrationCapabilities(qemuCaps, mon) < 0)
        goto cleanup;
3356 3357

    ret = 0;
3358
 cleanup:
3359 3360 3361
    return ret;
}

3362
static int
3363 3364 3365
virQEMUCapsInitQMP(virQEMUCapsPtr qemuCaps,
                   const char *libDir,
                   uid_t runUid,
3366 3367
                   gid_t runGid,
                   char **qmperr)
3368 3369 3370 3371 3372 3373 3374 3375
{
    int ret = -1;
    virCommandPtr cmd = NULL;
    qemuMonitorPtr mon = NULL;
    int status = 0;
    virDomainChrSourceDef config;
    char *monarg = NULL;
    char *monpath = NULL;
3376
    char *pidfile = NULL;
3377
    pid_t pid = 0;
3378 3379
    virDomainObjPtr vm = NULL;
    virDomainXMLOptionPtr xmlopt = NULL;
3380

3381 3382 3383
    /* the ".sock" sufix is important to avoid a possible clash with a qemu
     * domain called "capabilities"
     */
3384
    if (virAsprintf(&monpath, "%s/%s", libDir, "capabilities.monitor.sock") < 0)
3385
        goto cleanup;
3386
    if (virAsprintf(&monarg, "unix:%s,server,nowait", monpath) < 0)
3387 3388
        goto cleanup;

3389 3390
    /* ".pidfile" suffix is used rather than ".pid" to avoid a possible clash
     * with a qemu domain called "capabilities"
3391 3392 3393
     * 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
3394
     */
3395
    if (virAsprintf(&pidfile, "%s/%s", libDir, "capabilities.pidfile") < 0)
3396 3397
        goto cleanup;

3398 3399 3400 3401 3402
    memset(&config, 0, sizeof(config));
    config.type = VIR_DOMAIN_CHR_TYPE_UNIX;
    config.data.nix.path = monpath;
    config.data.nix.listen = false;

3403 3404
    virPidFileForceCleanupPath(pidfile);

3405
    VIR_DEBUG("Try to get caps via QMP qemuCaps=%p", qemuCaps);
3406

3407 3408 3409 3410 3411 3412 3413
    /*
     * 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.
     */
3414
    cmd = virCommandNewArgList(qemuCaps->binary,
3415 3416 3417 3418 3419 3420
                               "-S",
                               "-no-user-config",
                               "-nodefaults",
                               "-nographic",
                               "-M", "none",
                               "-qmp", monarg,
3421 3422
                               "-pidfile", pidfile,
                               "-daemonize",
3423 3424 3425
                               NULL);
    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
3426 3427
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
3428

3429 3430
    virCommandSetErrorBuffer(cmd, qmperr);

3431
    /* Log, but otherwise ignore, non-zero status.  */
3432 3433 3434 3435 3436
    if (virCommandRun(cmd, &status) < 0)
        goto cleanup;

    if (status != 0) {
        ret = 0;
3437 3438
        VIR_DEBUG("QEMU %s exited with status %d: %s",
                  qemuCaps->binary, status, *qmperr);
3439 3440 3441
        goto cleanup;
    }

3442 3443 3444 3445 3446 3447
    if (virPidFileReadPath(pidfile, &pid) < 0) {
        VIR_DEBUG("Failed to read pidfile %s", pidfile);
        ret = 0;
        goto cleanup;
    }

3448 3449 3450 3451 3452
    if (!(xmlopt = virDomainXMLOptionNew(NULL, NULL, NULL)) ||
        !(vm = virDomainObjNew(xmlopt)))
        goto cleanup;

    vm->pid = pid;
3453

3454
    if (!(mon = qemuMonitorOpen(vm, &config, true, &callbacks, NULL))) {
3455
        ret = 0;
3456
        goto cleanup;
3457
    }
3458

3459
    virObjectLock(mon);
3460

3461
    if (virQEMUCapsInitQMPMonitor(qemuCaps, mon) < 0)
3462
        goto cleanup;
3463 3464 3465

    ret = 0;

3466
 cleanup:
3467
    if (mon)
3468
        virObjectUnlock(mon);
3469 3470
    qemuMonitorClose(mon);
    virCommandAbort(cmd);
3471
    virCommandFree(cmd);
3472
    VIR_FREE(monarg);
3473 3474
    if (monpath)
        ignore_value(unlink(monpath));
3475
    VIR_FREE(monpath);
M
Michal Privoznik 已提交
3476
    virDomainObjEndAPI(&vm);
3477
    virObjectUnref(xmlopt);
3478

3479
    if (pid != 0) {
3480 3481
        char ebuf[1024];

3482 3483 3484 3485 3486
        VIR_DEBUG("Killing QMP caps process %lld", (long long) pid);
        if (virProcessKill(pid, SIGKILL) < 0 && errno != ESRCH)
            VIR_ERROR(_("Failed to kill process %lld: %s"),
                      (long long) pid,
                      virStrerror(errno, ebuf, sizeof(ebuf)));
3487 3488

        VIR_FREE(*qmperr);
3489 3490
    }
    if (pidfile) {
3491 3492 3493
        unlink(pidfile);
        VIR_FREE(pidfile);
    }
3494 3495 3496 3497
    return ret;
}


3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509
#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 },
    };
    virErrorPtr err = virGetLastError();

3510
    virLogMessage(&virLogSelf,
3511 3512 3513 3514 3515 3516 3517 3518 3519
                  VIR_LOG_WARN,
                  __FILE__, __LINE__, __func__,
                  meta,
                  _("Failed to probe capabilities for %s: %s"),
                  binary, err && err->message ? err->message :
                  _("unknown failure"));
}


3520 3521
virQEMUCapsPtr virQEMUCapsNewForBinary(const char *binary,
                                       const char *libDir,
3522
                                       const char *cacheDir,
3523 3524
                                       uid_t runUid,
                                       gid_t runGid)
3525
{
3526
    virQEMUCapsPtr qemuCaps;
3527 3528
    struct stat sb;
    int rv;
3529
    char *qmperr = NULL;
3530

3531 3532 3533
    if (!(qemuCaps = virQEMUCapsNew()))
        goto error;

3534 3535
    if (VIR_STRDUP(qemuCaps->binary, binary) < 0)
        goto error;
3536 3537 3538 3539 3540 3541 3542 3543

    /* 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;
    }
3544
    qemuCaps->ctime = sb.st_ctime;
3545 3546 3547 3548 3549 3550 3551 3552 3553 3554 3555

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

3556
    if ((rv = virQEMUCapsInitCached(qemuCaps, cacheDir)) < 0)
3557 3558
        goto error;

3559
    if (rv == 0) {
3560
        if (virQEMUCapsInitQMP(qemuCaps, libDir, runUid, runGid, &qmperr) < 0) {
3561 3562 3563 3564 3565
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (!qemuCaps->usedQMP &&
3566
            virQEMUCapsInitHelp(qemuCaps, runUid, runGid, qmperr) < 0) {
3567 3568 3569 3570 3571 3572
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (virQEMUCapsRememberCached(qemuCaps, cacheDir) < 0)
            goto error;
3573
    }
3574

3575
    VIR_FREE(qmperr);
3576
    return qemuCaps;
3577

3578
 error:
3579
    VIR_FREE(qmperr);
3580 3581
    virObjectUnref(qemuCaps);
    qemuCaps = NULL;
3582
    return NULL;
3583 3584 3585
}


3586
bool virQEMUCapsIsValid(virQEMUCapsPtr qemuCaps)
3587 3588 3589
{
    struct stat sb;

3590
    if (!qemuCaps->binary)
3591 3592
        return true;

3593
    if (stat(qemuCaps->binary, &sb) < 0)
3594 3595
        return false;

3596
    return sb.st_ctime == qemuCaps->ctime;
3597
}
3598 3599


3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614 3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628 3629 3630 3631 3632 3633 3634 3635
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]);
    }

}


3636 3637
virQEMUCapsCachePtr
virQEMUCapsCacheNew(const char *libDir,
3638
                    const char *cacheDir,
3639 3640
                    uid_t runUid,
                    gid_t runGid)
3641
{
3642
    virQEMUCapsCachePtr cache;
3643

3644
    if (VIR_ALLOC(cache) < 0)
3645 3646 3647 3648 3649 3650 3651 3652 3653
        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 已提交
3654
    if (!(cache->binaries = virHashCreate(10, virObjectFreeHashData)))
3655
        goto error;
3656
    if (VIR_STRDUP(cache->libDir, libDir) < 0)
3657
        goto error;
3658 3659
    if (VIR_STRDUP(cache->cacheDir, cacheDir) < 0)
        goto error;
3660

3661 3662 3663
    cache->runUid = runUid;
    cache->runGid = runGid;

3664 3665
    return cache;

3666
 error:
3667
    virQEMUCapsCacheFree(cache);
3668 3669 3670
    return NULL;
}

3671
const char *qemuTestCapsName;
3672

3673 3674
virQEMUCapsPtr
virQEMUCapsCacheLookup(virQEMUCapsCachePtr cache, const char *binary)
3675
{
3676
    virQEMUCapsPtr ret = NULL;
3677 3678 3679 3680 3681

    /* This is used only by test suite!!! */
    if (qemuTestCapsName)
        binary = qemuTestCapsName;

3682 3683 3684
    virMutexLock(&cache->lock);
    ret = virHashLookup(cache->binaries, binary);
    if (ret &&
3685
        !virQEMUCapsIsValid(ret)) {
3686 3687 3688 3689 3690 3691 3692 3693
        VIR_DEBUG("Cached capabilities %p no longer valid for %s",
                  ret, binary);
        virHashRemoveEntry(cache->binaries, binary);
        ret = NULL;
    }
    if (!ret) {
        VIR_DEBUG("Creating capabilities for %s",
                  binary);
3694
        ret = virQEMUCapsNewForBinary(binary, cache->libDir,
3695
                                      cache->cacheDir,
3696
                                      cache->runUid, cache->runGid);
3697 3698 3699 3700 3701 3702 3703 3704 3705 3706 3707 3708 3709 3710 3711 3712
        if (ret) {
            VIR_DEBUG("Caching capabilities %p for %s",
                      ret, binary);
            if (virHashAddEntry(cache->binaries, binary, ret) < 0) {
                virObjectUnref(ret);
                ret = NULL;
            }
        }
    }
    VIR_DEBUG("Returning caps %p for %s", ret, binary);
    virObjectRef(ret);
    virMutexUnlock(&cache->lock);
    return ret;
}


3713
virQEMUCapsPtr
3714 3715
virQEMUCapsCacheLookupCopy(virQEMUCapsCachePtr cache,
                           const char *binary,
3716
                           const char *machineType)
3717
{
3718 3719
    virQEMUCapsPtr qemuCaps = virQEMUCapsCacheLookup(cache, binary);
    virQEMUCapsPtr ret;
3720

3721
    if (!qemuCaps)
3722 3723
        return NULL;

3724 3725
    ret = virQEMUCapsNewCopy(qemuCaps);
    virObjectUnref(qemuCaps);
3726
    virQEMUCapsFilterByMachineType(ret, machineType);
3727 3728 3729 3730
    return ret;
}


3731 3732 3733 3734 3735 3736 3737 3738 3739 3740 3741 3742 3743 3744 3745 3746 3747
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
virQEMUCapsCacheLookupByArch(virQEMUCapsCachePtr cache,
                             virArch arch)
{
    virQEMUCapsPtr ret = NULL;
3748
    virArch target;
3749 3750 3751 3752
    struct virQEMUCapsSearchData data = { .arch = arch };

    virMutexLock(&cache->lock);
    ret = virHashSearch(cache->binaries, virQEMUCapsCompareArch, &data);
3753 3754 3755 3756 3757 3758 3759 3760 3761
    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);
        }
    }
3762 3763 3764
    virObjectRef(ret);
    virMutexUnlock(&cache->lock);

3765 3766
    VIR_DEBUG("Returning caps %p for arch %s", ret, virArchToString(arch));

3767 3768 3769 3770
    return ret;
}


3771
void
3772
virQEMUCapsCacheFree(virQEMUCapsCachePtr cache)
3773 3774 3775 3776
{
    if (!cache)
        return;

3777
    VIR_FREE(cache->libDir);
3778
    VIR_FREE(cache->cacheDir);
3779 3780 3781 3782
    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}
3783

3784 3785 3786 3787

bool
virQEMUCapsSupportsChardev(virDomainDefPtr def,
                           virQEMUCapsPtr qemuCaps,
3788
                           virDomainChrDefPtr chr)
3789 3790 3791 3792 3793
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV) ||
        !virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE))
        return false;

3794
    if ((def->os.arch == VIR_ARCH_PPC) || ARCH_IS_PPC64(def->os.arch)) {
3795 3796 3797 3798 3799
        /* only pseries need -device spapr-vty with -chardev */
        return (chr->deviceType == VIR_DOMAIN_CHR_DEVICE_TYPE_SERIAL &&
                chr->info.type == VIR_DOMAIN_DEVICE_ADDRESS_TYPE_SPAPRVIO);
    }

3800
    if ((def->os.arch != VIR_ARCH_ARMV7L) && (def->os.arch != VIR_ARCH_AARCH64))
3801
        return true;
3802

3803 3804 3805 3806 3807 3808
    /* 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));
3809
}
3810 3811


3812 3813 3814 3815 3816 3817 3818 3819 3820 3821 3822 3823 3824
bool
virQEMUCapsSupportsVmport(virQEMUCapsPtr qemuCaps,
                          const virDomainDef *def)
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_MACHINE_VMPORT_OPT))
        return false;

    return qemuDomainMachineIsI440FX(def) ||
        qemuDomainMachineIsQ35(def) ||
        STREQ(def->os.machine, "isapc");
}


3825 3826 3827 3828 3829 3830 3831 3832 3833 3834 3835 3836
bool
virQEMUCapsIsMachineSupported(virQEMUCapsPtr qemuCaps,
                              const char *canonical_machine)
{
    size_t i;

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
        if (STREQ(canonical_machine, qemuCaps->machineTypes[i]))
            return true;
    }
    return false;
}
3837 3838 3839 3840 3841 3842 3843 3844 3845


const char *
virQEMUCapsGetDefaultMachine(virQEMUCapsPtr qemuCaps)
{
    if (!qemuCaps->nmachineTypes)
        return NULL;
    return qemuCaps->machineTypes[0];
}
3846 3847


3848
static int
3849
virQEMUCapsFillDomainLoaderCaps(virQEMUCapsPtr qemuCaps,
3850 3851 3852
                                virDomainCapsLoaderPtr capsLoader,
                                char **loader,
                                size_t nloader)
3853
{
3854 3855
    size_t i;

3856
    capsLoader->device.supported = true;
3857

3858
    if (VIR_ALLOC_N(capsLoader->values.values, nloader) < 0)
3859 3860
        return -1;

3861 3862
    for (i = 0; i < nloader; i++) {
        const char *filename = loader[i];
3863 3864 3865 3866 3867 3868

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

3869
        if (VIR_STRDUP(capsLoader->values.values[capsLoader->values.nvalues],
3870 3871
                       filename) < 0)
            return -1;
3872
        capsLoader->values.nvalues++;
3873 3874
    }

3875
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
3876 3877
                             VIR_DOMAIN_LOADER_TYPE_ROM);

3878 3879
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
                             VIR_DOMAIN_LOADER_TYPE_PFLASH);
3880 3881 3882


    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE_READONLY))
3883
        VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->readonly,
3884 3885
                                 VIR_TRISTATE_BOOL_YES,
                                 VIR_TRISTATE_BOOL_NO);
3886
    return 0;
3887 3888 3889
}


3890
static int
3891 3892
virQEMUCapsFillDomainOSCaps(virQEMUCapsPtr qemuCaps,
                            virDomainCapsOSPtr os,
3893 3894
                            char **loader,
                            size_t nloader)
3895
{
3896
    virDomainCapsLoaderPtr capsLoader = &os->loader;
3897 3898

    os->device.supported = true;
M
Michal Privoznik 已提交
3899
    if (virQEMUCapsFillDomainLoaderCaps(qemuCaps, capsLoader,
3900
                                        loader, nloader) < 0)
3901 3902
        return -1;
    return 0;
3903 3904 3905
}


3906
static int
3907
virQEMUCapsFillDomainDeviceDiskCaps(virQEMUCapsPtr qemuCaps,
3908
                                    const char *machine,
3909 3910 3911 3912 3913 3914
                                    virDomainCapsDeviceDiskPtr disk)
{
    disk->device.supported = true;
    /* QEMU supports all of these */
    VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice,
                             VIR_DOMAIN_DISK_DEVICE_DISK,
3915 3916 3917 3918 3919
                             VIR_DOMAIN_DISK_DEVICE_CDROM);

    /* PowerPC pseries based VMs do not support floppy device */
    if (!(ARCH_IS_PPC64(qemuCaps->arch) && STRPREFIX(machine, "pseries")))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice, VIR_DOMAIN_DISK_DEVICE_FLOPPY);
3920 3921 3922 3923 3924 3925 3926 3927 3928 3929

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_VIRTIO_BLK_SG_IO))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice, VIR_DOMAIN_DISK_DEVICE_LUN);

    VIR_DOMAIN_CAPS_ENUM_SET(disk->bus,
                             VIR_DOMAIN_DISK_BUS_IDE,
                             VIR_DOMAIN_DISK_BUS_SCSI,
                             VIR_DOMAIN_DISK_BUS_VIRTIO,
                             /* VIR_DOMAIN_DISK_BUS_SD */);

3930 3931 3932 3933
    /* PowerPC pseries based VMs do not support floppy device */
    if (!(ARCH_IS_PPC64(qemuCaps->arch) && STRPREFIX(machine, "pseries")))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_FDC);

3934 3935
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_USB_STORAGE))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_USB);
3936
    return 0;
3937 3938 3939
}


3940
static int
3941 3942 3943 3944 3945 3946 3947 3948 3949 3950 3951 3952 3953 3954 3955 3956 3957 3958 3959 3960
virQEMUCapsFillDomainDeviceHostdevCaps(virQEMUCapsPtr qemuCaps,
                                       virDomainCapsDeviceHostdevPtr hostdev)
{
    bool supportsPassthroughKVM = qemuHostdevHostSupportsPassthroughLegacy();
    bool supportsPassthroughVFIO = qemuHostdevHostSupportsPassthroughVFIO();

    hostdev->device.supported = true;
    /* 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);
3961
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
3962 3963 3964 3965 3966 3967 3968 3969 3970 3971 3972 3973 3974 3975 3976 3977 3978 3979 3980 3981 3982 3983
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_SCSI_GENERIC))
        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);
    }

    if (supportsPassthroughKVM &&
        (virQEMUCapsGet(qemuCaps, QEMU_CAPS_PCIDEVICE) ||
         virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE))) {
        VIR_DOMAIN_CAPS_ENUM_SET(hostdev->pciBackend,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_DEFAULT,
                                 VIR_DOMAIN_HOSTDEV_PCI_BACKEND_KVM);
    }
3984
    return 0;
3985 3986 3987
}


3988
int
3989
virQEMUCapsFillDomainCaps(virDomainCapsPtr domCaps,
3990
                          virQEMUCapsPtr qemuCaps,
3991 3992
                          char **loader,
                          size_t nloader)
3993
{
3994
    virDomainCapsOSPtr os = &domCaps->os;
3995 3996 3997 3998 3999 4000
    virDomainCapsDeviceDiskPtr disk = &domCaps->disk;
    virDomainCapsDeviceHostdevPtr hostdev = &domCaps->hostdev;
    int maxvcpus = virQEMUCapsGetMachineMaxCpus(qemuCaps, domCaps->machine);

    domCaps->maxvcpus = maxvcpus;

M
Michal Privoznik 已提交
4001
    if (virQEMUCapsFillDomainOSCaps(qemuCaps, os,
4002
                                    loader, nloader) < 0 ||
4003
        virQEMUCapsFillDomainDeviceDiskCaps(qemuCaps, domCaps->machine, disk) < 0 ||
4004 4005 4006
        virQEMUCapsFillDomainDeviceHostdevCaps(qemuCaps, hostdev) < 0)
        return -1;
    return 0;
4007
}