qemu_capabilities.c 123.4 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
    );

304 305 306 307 308 309 310 311

/*
 * 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.
 */
312
struct _virQEMUCaps {
313 314
    virObject object;

315 316
    bool usedQMP;

317
    char *binary;
318
    time_t ctime;
319

320
    virBitmapPtr flags;
321 322 323

    unsigned int version;
    unsigned int kvmVersion;
324
    char *package;
325

326
    virArch arch;
327 328 329 330 331 332 333

    size_t ncpuDefinitions;
    char **cpuDefinitions;

    size_t nmachineTypes;
    char **machineTypes;
    char **machineAliases;
334
    unsigned int *machineMaxCpus;
335 336
};

337 338 339 340
struct virQEMUCapsSearchData {
    virArch arch;
};

341

342 343
static virClassPtr virQEMUCapsClass;
static void virQEMUCapsDispose(void *obj);
344

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

    return 0;
}

356
VIR_ONCE_GLOBAL_INIT(virQEMUCaps)
357

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

    return virArchFromString(arch);
}


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

    return virArchToString(arch);
}

383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404
/* 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;
}
405

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

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

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
422 423
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
424 425 426 427 428

    return cmd;
}


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

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

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

    do {
        const char *t;
464 465
        char *name;
        char *canonical = NULL;
466 467 468 469 470 471 472 473 474 475

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

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

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

476 477
        if (VIR_STRNDUP(name, p, t - p) < 0)
            return -1;
478 479

        p = t;
480
        if ((t = strstr(p, "(default)")) && (!next || t < next))
481
            defIdx = qemuCaps->nmachineTypes;
482 483 484

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

490
            if (VIR_STRNDUP(canonical, p, t - p) < 0) {
491
                VIR_FREE(name);
492
                return -1;
493 494 495
            }
        }

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

515

516
    if (defIdx)
517
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
518 519 520 521

    return 0;
}

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

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

541
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
542
    virCommandAddArgList(cmd, "-M", "?", NULL);
543
    virCommandSetOutputBuffer(cmd, &output);
544

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

549
    if (virQEMUCapsParseMachineTypesStr(output, qemuCaps) < 0)
550
        goto cleanup;
551 552 553

    ret = 0;

554
 cleanup:
555 556
    VIR_FREE(output);
    virCommandFree(cmd);
557 558 559 560 561 562

    return ret;
}


typedef int
563 564
(*virQEMUCapsParseCPUModels)(const char *output,
                             virQEMUCapsPtr qemuCaps);
565 566 567 568 569 570 571

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

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

        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;

599
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
600
            goto cleanup;
601

602 603 604 605
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
606

607 608 609 610
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
611

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

616
    ret = 0;
617

618
 cleanup:
619
    return ret;
620 621
}

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

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

        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;

656
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
657
            goto cleanup;
P
Prerna Saxena 已提交
658

659
        len = t - p - 1;
P
Prerna Saxena 已提交
660

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

665
    ret = 0;
P
Prerna Saxena 已提交
666

667
 cleanup:
668
    return ret;
P
Prerna Saxena 已提交
669
}
670

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

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

690
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
691
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
692
    virCommandSetOutputBuffer(cmd, &output);
693

694
    if (virCommandRun(cmd, NULL) < 0)
695 696
        goto cleanup;

697
    if (parse(output, qemuCaps) < 0)
698 699 700 701
        goto cleanup;

    ret = 0;

702
 cleanup:
703
    VIR_FREE(output);
704
    virCommandFree(cmd);
705 706 707 708

    return ret;
}

709
static char *
710 711
virQEMUCapsFindBinary(const char *format,
                      const char *archstr)
712
{
713 714
    char *ret = NULL;
    char *binary = NULL;
715

716 717
    if (virAsprintf(&binary, format, archstr) < 0)
        goto out;
718 719 720

    ret = virFindFileInPath(binary);
    VIR_FREE(binary);
721 722
    if (ret && virFileIsExecutable(ret))
        goto out;
723

724
    VIR_FREE(ret);
725

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

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

757
 out:
758 759 760
    return ret;
}

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

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

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

    /* qemu-kvm/kvm binaries can only be used if
789
     *  - host & guest arches match
790 791
     *  - hostarch is x86_64 and guest arch is i686 (needs -cpu qemu32)
     *  - hostarch is aarch64 and guest arch is armv7l (needs -cpu aarch64=off)
792
     */
793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816
    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);

    if (native_kvm || x86_32on64_kvm || arm_32on64_kvm) {
        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";
817

818
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
819 820 821
            if (!kvmbins[i])
                continue;

822
            kvmbin = virFindFileInPath(kvmbins[i]);
823

824 825
            if (!kvmbin)
                continue;
826

827
            if (!(kvmbinCaps = virQEMUCapsCacheLookup(cache, kvmbin))) {
828
                virResetLastError();
829 830 831
                VIR_FREE(kvmbin);
                continue;
            }
832

833 834
            if (!binary) {
                binary = kvmbin;
835
                qemubinCaps = kvmbinCaps;
836
                kvmbin = NULL;
837
                kvmbinCaps = NULL;
838
            }
839
            break;
840 841 842
        }
    }

843 844 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
    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;
    bool haskqemu = false;
    virCapsGuestMachinePtr *machines = NULL;
    size_t nmachines = 0;
    int ret = -1;
    bool hasdisksnapshot = false;

872 873 874
    if (!binary)
        return 0;

875
    if (virFileExists("/dev/kvm") &&
876 877
        (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         virQEMUCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
878
         kvmbin))
879
        haskvm = true;
880

881
    if (virFileExists("/dev/kqemu") &&
882
        virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KQEMU))
883
        haskqemu = true;
J
Jiri Denemark 已提交
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 (haskqemu &&
        virCapabilitiesAddGuestDomain(guest,
929
                                      VIR_DOMAIN_VIRT_KQEMU,
D
Daniel P. Berrange 已提交
930 931 932 933
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
934
        goto cleanup;
935

D
Daniel P. Berrange 已提交
936 937
    if (haskvm) {
        virCapsGuestDomainPtr dom;
938

D
Daniel P. Berrange 已提交
939
        if (kvmbin &&
940
            virQEMUCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
941
            goto cleanup;
942

D
Daniel P. Berrange 已提交
943
        if ((dom = virCapabilitiesAddGuestDomain(guest,
944
                                                 VIR_DOMAIN_VIRT_KVM,
D
Daniel P. Berrange 已提交
945 946 947 948
                                                 kvmbin ? kvmbin : binary,
                                                 NULL,
                                                 nmachines,
                                                 machines)) == NULL) {
949
            goto cleanup;
D
Daniel P. Berrange 已提交
950
        }
951

D
Daniel P. Berrange 已提交
952 953
        machines = NULL;
        nmachines = 0;
954 955 956

    }

957 958
    if (((guestarch == VIR_ARCH_I686) ||
         (guestarch == VIR_ARCH_X86_64)) &&
959 960
        (virCapabilitiesAddGuestFeature(guest, "acpi", true, true) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "apic", true, false) == NULL))
961
        goto cleanup;
962

963
    if ((guestarch == VIR_ARCH_I686) &&
964 965
        (virCapabilitiesAddGuestFeature(guest, "pae", true, false) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "nonpae", true, false) == NULL))
966
        goto cleanup;
967 968 969

    ret = 0;

970
 cleanup:
971 972 973

    virCapabilitiesFreeMachines(machines, nmachines);

974
    return ret;
975 976 977 978
}


static int
979 980
virQEMUCapsInitCPU(virCapsPtr caps,
                   virArch arch)
981 982
{
    virCPUDefPtr cpu = NULL;
983
    virCPUDataPtr data = NULL;
984 985 986
    virNodeInfo nodeinfo;
    int ret = -1;

987
    if (VIR_ALLOC(cpu) < 0)
988 989
        goto error;

990 991
    cpu->arch = arch;

992
    if (nodeGetInfo(NULL, &nodeinfo))
993 994 995 996 997 998
        goto error;

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

1001
    if (!(data = cpuNodeData(arch))
1002
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0)
J
Jiri Denemark 已提交
1003
        goto cleanup;
1004 1005 1006

    ret = 0;

1007
 cleanup:
J
Jiri Denemark 已提交
1008
    cpuDataFree(data);
1009 1010 1011

    return ret;

1012
 error:
1013 1014 1015 1016 1017
    virCPUDefFree(cpu);
    goto cleanup;
}


M
Michal Privoznik 已提交
1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040
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;
}


1041
virCapsPtr virQEMUCapsInit(virQEMUCapsCachePtr cache)
1042 1043
{
    virCapsPtr caps;
1044
    size_t i;
T
Tal Kain 已提交
1045
    virArch hostarch = virArchFromHost();
1046

T
Tal Kain 已提交
1047
    if ((caps = virCapabilitiesNew(hostarch,
1048
                                   true, true)) == NULL)
1049
        goto error;
1050 1051 1052 1053 1054

    /* 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
     */
1055
    if (nodeCapsInitNUMA(NULL, caps) < 0) {
1056
        virCapabilitiesFreeNUMAInfo(caps);
1057
        VIR_WARN("Failed to query host NUMA topology, disabling NUMA capabilities");
1058 1059
    }

T
Tal Kain 已提交
1060
    if (virQEMUCapsInitCPU(caps, hostarch) < 0)
1061
        VIR_WARN("Failed to get host CPU");
1062

1063
    /* Add the power management features of the host */
1064
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
1065 1066
        VIR_WARN("Failed to get host power management capabilities");

M
Michal Privoznik 已提交
1067 1068 1069 1070
    /* Add huge pages info */
    if (virQEMUCapsInitPages(caps) < 0)
        VIR_WARN("Failed to get pages info");

1071 1072 1073
    /* Add domain migration transport URIs */
    virCapabilitiesAddHostMigrateTransport(caps, "tcp");
    virCapabilitiesAddHostMigrateTransport(caps, "rdma");
1074

1075 1076 1077 1078
    /* 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
     */
1079
    for (i = 0; i < VIR_ARCH_LAST; i++)
1080
        if (virQEMUCapsInitGuest(caps, cache,
T
Tal Kain 已提交
1081
                                 hostarch,
1082
                                 i) < 0)
1083
            goto error;
1084 1085 1086

    return caps;

1087
 error:
1088
    virObjectUnref(caps);
1089 1090 1091 1092
    return NULL;
}


1093
static int
1094 1095
virQEMUCapsComputeCmdFlags(const char *help,
                           unsigned int version,
1096
                           bool is_kvm,
1097 1098 1099
                           unsigned int kvm_version,
                           virQEMUCapsPtr qemuCaps,
                           bool check_yajl ATTRIBUTE_UNUSED)
1100 1101
{
    const char *p;
R
Richa Marwaha 已提交
1102
    const char *fsdev, *netdev;
1103 1104

    if (strstr(help, "-no-kqemu"))
1105
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KQEMU);
1106
    if (strstr(help, "-enable-kqemu"))
1107
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KQEMU);
1108
    if (strstr(help, "-no-kvm"))
1109
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
1110
    if (strstr(help, "-enable-kvm"))
1111
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
1112
    if (strstr(help, "-no-reboot"))
1113
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_REBOOT);
1114
    if (strstr(help, "-name")) {
1115
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME);
1116
        if (strstr(help, ",process="))
1117
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
1118 1119
    }
    if (strstr(help, "-uuid"))
1120
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_UUID);
1121
    if (strstr(help, "-xen-domid"))
1122
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_XEN_DOMID);
1123
    else if (strstr(help, "-domid"))
1124
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DOMID);
1125
    if (strstr(help, "-drive")) {
1126 1127
        const char *cache = strstr(help, "cache=");

1128
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE);
1129 1130
        if (cache && (p = strchr(cache, ']'))) {
            if (memmem(cache, p - cache, "on|off", sizeof("on|off") - 1) == NULL)
1131
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_V2);
1132
            if (memmem(cache, p - cache, "directsync", sizeof("directsync") - 1))
1133
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
1134
            if (memmem(cache, p - cache, "unsafe", sizeof("unsafe") - 1))
1135
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
1136
        }
1137
        if (strstr(help, "format="))
1138
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT);
1139
        if (strstr(help, "readonly="))
1140
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1141
        if (strstr(help, "aio=threads|native"))
1142
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_AIO);
O
Osier Yang 已提交
1143
        if (strstr(help, "copy-on-read=on|off"))
1144
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
1145
        if (strstr(help, "bps="))
1146
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_IOTUNE);
1147 1148 1149 1150
    }
    if ((p = strstr(help, "-vga")) && !strstr(help, "-std-vga")) {
        const char *nl = strstr(p, "\n");

1151
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA);
1152 1153

        if (strstr(p, "|qxl"))
1154
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
1155
        if ((p = strstr(p, "|none")) && p < nl)
1156
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
1157 1158
    }
    if (strstr(help, "-spice"))
1159
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
1160
    if (strstr(help, "-vnc"))
1161
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
1162
    if (strstr(help, "seamless-migration="))
1163
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
1164
    if (strstr(help, "boot=on"))
1165
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_BOOT);
1166
    if (strstr(help, "serial=s"))
1167
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
1168
    if (strstr(help, "-pcidevice"))
1169
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCIDEVICE);
1170 1171
    if (strstr(help, "host=[seg:]bus"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
1172
    if (strstr(help, "-mem-path"))
1173
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
1174
    if (strstr(help, "-chardev")) {
1175
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
1176
        if (strstr(help, "-chardev spicevmc"))
1177
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
1178 1179
        if (strstr(help, "-chardev spiceport"))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEPORT);
1180
    }
1181
    if (strstr(help, "-balloon"))
1182
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BALLOON);
1183
    if (strstr(help, "-device")) {
1184
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE);
1185 1186 1187 1188
        /*
         * When -device was introduced, qemu already supported drive's
         * readonly option but didn't advertise that.
         */
1189
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1190 1191
    }
    if (strstr(help, "-nodefconfig"))
1192
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
1193
    if (strstr(help, "-no-user-config"))
1194
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
1195 1196
    /* The trailing ' ' is important to avoid a bogus match */
    if (strstr(help, "-rtc "))
1197
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
1198 1199
    /* to wit */
    if (strstr(help, "-rtc-td-hack"))
1200
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC_TD_HACK);
1201
    if (strstr(help, "-no-hpet"))
1202
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
1203
    if (strstr(help, "-no-acpi"))
1204
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
1205
    if (strstr(help, "-no-kvm-pit-reinjection"))
1206
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
1207
    if (strstr(help, "-tdf"))
1208
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_TDF);
1209
    if (strstr(help, "-enable-nesting"))
1210
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NESTING);
1211
    if (strstr(help, ",menu=on"))
1212
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
1213
    if (strstr(help, ",reboot-timeout=rb_time"))
1214
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_REBOOT_TIMEOUT);
1215 1216
    if (strstr(help, ",splash-time=sp_time"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPLASH_TIMEOUT);
1217
    if ((fsdev = strstr(help, "-fsdev"))) {
1218
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
1219
        if (strstr(fsdev, "readonly"))
1220
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
1221
        if (strstr(fsdev, "writeout"))
1222
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
1223
    }
1224
    if (strstr(help, "-smbios type"))
1225
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
1226
    if (strstr(help, "-sandbox"))
1227
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
1228

R
Richa Marwaha 已提交
1229
    if ((netdev = strstr(help, "-netdev"))) {
1230 1231
        /* Disable -netdev on 0.12 since although it exists,
         * the corresponding netdev_add/remove monitor commands
1232 1233
         * do not, and we need them to be able to do hotplug.
         * But see below about RHEL build. */
R
Richa Marwaha 已提交
1234 1235
        if (version >= 13000) {
            if (strstr(netdev, "bridge"))
1236
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
1237
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
R
Richa Marwaha 已提交
1238
        }
1239 1240 1241
    }

    if (strstr(help, "-sdl"))
1242
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
1243 1244 1245
    if (strstr(help, "cores=") &&
        strstr(help, "threads=") &&
        strstr(help, "sockets="))
1246
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMP_TOPOLOGY);
1247 1248

    if (version >= 9000)
1249
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_COLON);
1250 1251

    if (is_kvm && (version >= 10000 || kvm_version >= 74))
1252
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNET_HDR);
1253

1254
    if (strstr(help, ",vhost="))
1255
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
1256

1257 1258
    /* 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
1259
     * 0.14.* and 0.15.0)
1260
     */
1261
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1262
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
1263

1264
    if (strstr(help, "dump-guest-core=on|off"))
1265
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
1266

O
Olivia Yin 已提交
1267 1268 1269
    if (strstr(help, "-dtb"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);

1270 1271 1272
    if (strstr(help, "-machine"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);

1273 1274 1275 1276
    /*
     * Handling of -incoming arg with varying features
     *  -incoming tcp    (kvm >= 79, qemu >= 0.10.0)
     *  -incoming exec   (kvm >= 80, qemu >= 0.10.0)
1277 1278
     *  -incoming unix   (qemu >= 0.12.0)
     *  -incoming fd     (qemu >= 0.12.0)
1279 1280 1281 1282 1283 1284 1285
     *  -incoming stdio  (all earlier kvm)
     *
     * NB, there was a pre-kvm-79 'tcp' support, but it
     * was broken, because it blocked the monitor console
     * while waiting for data, so pretend it doesn't exist
     */
    if (version >= 10000) {
1286 1287
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1288
        if (version >= 12000) {
1289 1290
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_UNIX);
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_FD);
1291
        }
1292
    } else if (kvm_version >= 79) {
1293
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
1294
        if (kvm_version >= 80)
1295
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1296
    } else if (kvm_version > 0) {
1297
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_KVM_STDIO);
1298 1299 1300
    }

    if (version >= 10000)
1301
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_0_10);
1302

1303
    if (version >= 11000)
1304
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
1305

1306 1307 1308
    /* 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
1309 1310 1311 1312 1313
     * 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.
1314
     */
1315
#if WITH_YAJL
1316
    if (version >= 13000) {
1317
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
1318 1319
    } else if (version >= 12000 &&
               strstr(help, "libvirt")) {
1320 1321
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1322
    }
1323 1324 1325 1326 1327
#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 已提交
1328
     * libvirt but is targeting a newer qemu, we are better off
1329
     * telling them to recompile (the spec file includes the
1330
     * dependency, so distros won't hit this).  This check is
1331
     * also in m4/virt-yajl.m4 (see $with_yajl).  */
1332 1333 1334
    if (version >= 15000 ||
        (version >= 12000 && strstr(help, "libvirt"))) {
        if (check_yajl) {
1335 1336 1337
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("this qemu binary requires libvirt to be "
                             "compiled with yajl"));
1338 1339
            return -1;
        }
1340
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1341
    }
E
Eric Blake 已提交
1342
#endif
1343 1344

    if (version >= 13000)
1345
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIFUNCTION);
1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357

    /* 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)
1358
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_ROMBAR);
1359 1360

    if (version >= 11000)
1361
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_HOST);
1362

1363
    if (version >= 1001000) {
J
Ján Tomko 已提交
1364
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
1365 1366
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
    }
J
Ján Tomko 已提交
1367

1368
    return 0;
1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394
}

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

1395 1396 1397 1398
int virQEMUCapsParseHelpStr(const char *qemu,
                            const char *help,
                            virQEMUCapsPtr qemuCaps,
                            unsigned int *version,
1399
                            bool *is_kvm,
1400
                            unsigned int *kvm_version,
1401 1402
                            bool check_yajl,
                            const char *qmperr)
1403 1404 1405
{
    unsigned major, minor, micro;
    const char *p = help;
1406
    char *strflags;
1407

1408 1409
    *version = *kvm_version = 0;
    *is_kvm = false;
1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426

    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 已提交
1427
    if (minor == -1)
1428 1429
        goto fail;

J
Jiri Denemark 已提交
1430 1431 1432 1433 1434 1435 1436 1437
    if (*p != '.') {
        micro = 0;
    } else {
        ++p;
        micro = virParseNumber(&p);
        if (micro == -1)
            goto fail;
    }
1438 1439 1440 1441

    SKIP_BLANKS(p);

    if (STRPREFIX(p, QEMU_KVM_VER_PREFIX)) {
1442
        *is_kvm = true;
1443 1444 1445 1446
        p += strlen(QEMU_KVM_VER_PREFIX);
    } else if (STRPREFIX(p, KVM_VER_PREFIX)) {
        int ret;

1447
        *is_kvm = true;
1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458
        p += strlen(KVM_VER_PREFIX);

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

        *kvm_version = ret;
    }

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

1459 1460 1461 1462
    /* Refuse to parse -help output for QEMU releases >= 1.2.0 that should be
     * using QMP probing.
     */
    if (*version >= 1002000) {
1463 1464 1465 1466 1467 1468 1469 1470 1471
        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);
        }
1472 1473 1474
        goto cleanup;
    }

1475 1476
    if (virQEMUCapsComputeCmdFlags(help, *version, *is_kvm, *kvm_version,
                                   qemuCaps, check_yajl) < 0)
1477
        goto cleanup;
1478

1479
    strflags = virBitmapString(qemuCaps->flags);
1480 1481 1482
    VIR_DEBUG("Version %u.%u.%u, cooked version %u, flags %s",
              major, minor, micro, *version, NULLSTR(strflags));
    VIR_FREE(strflags);
1483 1484 1485 1486 1487 1488 1489 1490

    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;

1491
 fail:
1492
    p = strchr(help, '\n');
1493 1494
    if (!p)
        p = strchr(help, '\0');
1495

1496 1497 1498
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("cannot parse %s version number in '%.*s'"),
                   qemu, (int) (p - help), help);
1499

1500
 cleanup:
1501 1502 1503
    return -1;
}

1504

1505
struct virQEMUCapsStringFlags {
1506 1507 1508 1509 1510
    const char *value;
    int flag;
};


1511 1512 1513
struct virQEMUCapsStringFlags virQEMUCapsCommands[] = {
    { "system_wakeup", QEMU_CAPS_WAKEUP },
    { "transaction", QEMU_CAPS_TRANSACTION },
1514 1515
    { "block_stream", QEMU_CAPS_BLOCKJOB_SYNC },
    { "block-stream", QEMU_CAPS_BLOCKJOB_ASYNC },
1516 1517 1518 1519 1520 1521 1522 1523 1524
    { "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 },
1525
    { "change-backing-file", QEMU_CAPS_CHANGE_BACKING_FILE },
1526
    { "rtc-reset-reinjection", QEMU_CAPS_RTC_RESET_REINJECTION },
1527 1528
};

1529 1530 1531 1532
struct virQEMUCapsStringFlags virQEMUCapsMigration[] = {
    { "rdma-pin-all", QEMU_CAPS_MIGRATE_RDMA },
};

1533 1534 1535
struct virQEMUCapsStringFlags virQEMUCapsEvents[] = {
    { "BALLOON_CHANGE", QEMU_CAPS_BALLOON_EVENT },
    { "SPICE_MIGRATE_COMPLETED", QEMU_CAPS_SEAMLESS_MIGRATION },
1536
    { "DEVICE_DELETED", QEMU_CAPS_DEVICE_DEL_EVENT },
1537
    { "MIGRATION", QEMU_CAPS_MIGRATION_EVENT },
1538 1539
};

1540
struct virQEMUCapsStringFlags virQEMUCapsObjectTypes[] = {
1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555
    { "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 },
1556
    { "virtio-blk-ccw", QEMU_CAPS_VIRTIO_CCW },
1557
    { "sclpconsole", QEMU_CAPS_SCLP_S390 },
1558
    { "lsi53c895a", QEMU_CAPS_SCSI_LSI },
1559
    { "virtio-scsi-pci", QEMU_CAPS_VIRTIO_SCSI },
1560 1561
    { "virtio-scsi-s390", QEMU_CAPS_VIRTIO_SCSI },
    { "virtio-scsi-ccw", QEMU_CAPS_VIRTIO_SCSI },
1562
    { "virtio-scsi-device", QEMU_CAPS_VIRTIO_SCSI },
1563
    { "megasas", QEMU_CAPS_SCSI_MEGASAS },
1564 1565
    { "spicevmc", QEMU_CAPS_DEVICE_SPICEVMC },
    { "qxl-vga", QEMU_CAPS_DEVICE_QXL_VGA },
1566
    { "qxl", QEMU_CAPS_DEVICE_QXL },
1567 1568 1569 1570
    { "sga", QEMU_CAPS_SGA },
    { "scsi-block", QEMU_CAPS_SCSI_BLOCK },
    { "scsi-cd", QEMU_CAPS_SCSI_CD },
    { "ide-cd", QEMU_CAPS_IDE_CD },
1571 1572 1573
    { "VGA", QEMU_CAPS_DEVICE_VGA },
    { "cirrus-vga", QEMU_CAPS_DEVICE_CIRRUS_VGA },
    { "vmware-svga", QEMU_CAPS_DEVICE_VMWARE_SVGA },
H
Han Cheng 已提交
1574 1575
    { "usb-serial", QEMU_CAPS_DEVICE_USB_SERIAL },
    { "usb-net", QEMU_CAPS_DEVICE_USB_NET },
1576
    { "virtio-rng-pci", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1577 1578
    { "virtio-rng-s390", QEMU_CAPS_DEVICE_VIRTIO_RNG },
    { "virtio-rng-ccw", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1579
    { "virtio-rng-device", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1580
    { "rng-random", QEMU_CAPS_OBJECT_RNG_RANDOM },
1581
    { "rng-egd", QEMU_CAPS_OBJECT_RNG_EGD },
1582
    { "spapr-nvram", QEMU_CAPS_DEVICE_NVRAM },
1583
    { "pci-bridge", QEMU_CAPS_DEVICE_PCI_BRIDGE },
1584
    { "vfio-pci", QEMU_CAPS_DEVICE_VFIO_PCI },
H
Han Cheng 已提交
1585
    { "scsi-generic", QEMU_CAPS_DEVICE_SCSI_GENERIC },
1586
    { "i82801b11-bridge", QEMU_CAPS_DEVICE_DMI_TO_PCI_BRIDGE },
1587
    { "usb-storage", QEMU_CAPS_DEVICE_USB_STORAGE },
1588
    { "virtio-mmio", QEMU_CAPS_DEVICE_VIRTIO_MMIO },
1589
    { "ich9-intel-hda", QEMU_CAPS_DEVICE_ICH9_INTEL_HDA },
H
Hu Tao 已提交
1590
    { "pvpanic", QEMU_CAPS_DEVICE_PANIC },
L
Li Zhang 已提交
1591
    { "usb-kbd", QEMU_CAPS_DEVICE_USB_KBD },
1592
    { "memory-backend-ram", QEMU_CAPS_OBJECT_MEMORY_RAM },
1593
    { "memory-backend-file", QEMU_CAPS_OBJECT_MEMORY_FILE },
1594
    { "usb-audio", QEMU_CAPS_OBJECT_USB_AUDIO },
J
John Ferlan 已提交
1595
    { "iothread", QEMU_CAPS_OBJECT_IOTHREAD},
1596
    { "ivshmem", QEMU_CAPS_DEVICE_IVSHMEM },
1597
    { "pc-dimm", QEMU_CAPS_DEVICE_PC_DIMM },
M
Michal Privoznik 已提交
1598
    { "pci-serial", QEMU_CAPS_DEVICE_PCI_SERIAL },
1599
    { "gpex-pcihost", QEMU_CAPS_OBJECT_GPEX},
1600
    { "ioh3420", QEMU_CAPS_DEVICE_IOH3420 },
1601
    { "x3130-upstream", QEMU_CAPS_DEVICE_X3130_UPSTREAM },
1602
    { "xio3130-downstream", QEMU_CAPS_DEVICE_XIO3130_DOWNSTREAM },
1603
    { "rtl8139", QEMU_CAPS_DEVICE_RTL8139 },
1604
    { "e1000", QEMU_CAPS_DEVICE_E1000 },
1605 1606 1607 1608
    { "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 },
1609 1610
};

1611
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBlk[] = {
1612 1613 1614 1615 1616 1617 1618 1619
    { "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 },
};

1620
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioNet[] = {
1621 1622 1623 1624
    { "tx", QEMU_CAPS_VIRTIO_TX_ALG },
    { "event_idx", QEMU_CAPS_VIRTIO_NET_EVENT_IDX },
};

1625
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPCIAssign[] = {
1626
    { "rombar", QEMU_CAPS_PCI_ROMBAR },
1627 1628 1629 1630
    { "configfd", QEMU_CAPS_PCI_CONFIGFD },
    { "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};

1631
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVfioPCI[] = {
1632 1633 1634
    { "bootindex", QEMU_CAPS_VFIO_PCI_BOOTINDEX },
};

1635
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIDisk[] = {
1636 1637 1638 1639
    { "channel", QEMU_CAPS_SCSI_DISK_CHANNEL },
    { "wwn", QEMU_CAPS_SCSI_DISK_WWN },
};

1640
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsIDEDrive[] = {
1641 1642 1643
    { "wwn", QEMU_CAPS_IDE_DRIVE_WWN },
};

1644
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPixx4PM[] = {
1645 1646 1647 1648
    { "disable_s3", QEMU_CAPS_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_DISABLE_S4 },
};

1649
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBRedir[] = {
1650
    { "filter", QEMU_CAPS_USB_REDIR_FILTER },
1651 1652 1653
    { "bootindex", QEMU_CAPS_USB_REDIR_BOOTINDEX },
};

1654
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBHost[] = {
1655
    { "bootindex", QEMU_CAPS_USB_HOST_BOOTINDEX },
1656 1657
};

1658
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIGeneric[] = {
H
Han Cheng 已提交
1659 1660 1661
    { "bootindex", QEMU_CAPS_DEVICE_SCSI_GENERIC_BOOTINDEX },
};

1662
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsI440FXPCIHost[] = {
1663 1664 1665
    { "pci-hole64-size", QEMU_CAPS_I440FX_PCI_HOLE64_SIZE },
};

1666
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQ35PCIHost[] = {
1667 1668 1669
    { "pci-hole64-size", QEMU_CAPS_Q35_PCI_HOLE64_SIZE },
};

1670
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBStorage[] = {
1671 1672 1673
    { "removable", QEMU_CAPS_USB_STORAGE_REMOVABLE },
};

1674 1675 1676 1677
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsKVMPit[] = {
    { "lost_tick_policy", QEMU_CAPS_KVM_PIT_TICK_POLICY },
};

1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693
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 },
};

1694
struct virQEMUCapsObjectTypeProps {
1695
    const char *type;
1696
    struct virQEMUCapsStringFlags *props;
1697 1698 1699
    size_t nprops;
};

1700 1701 1702 1703
static struct virQEMUCapsObjectTypeProps virQEMUCapsObjectProps[] = {
    { "virtio-blk-pci", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-pci", virQEMUCapsObjectPropsVirtioNet,
1704 1705 1706 1707
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-ccw", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-ccw", virQEMUCapsObjectPropsVirtioNet,
1708 1709 1710 1711 1712
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-s390", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-s390", virQEMUCapsObjectPropsVirtioNet,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
1713 1714 1715 1716 1717 1718
    { "pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "kvm-pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "vfio-pci", virQEMUCapsObjectPropsVfioPCI,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVfioPCI) },
1719 1720
    { "scsi-disk", virQEMUCapsObjectPropsSCSIDisk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIDisk) },
1721 1722 1723 1724
    { "ide-drive", virQEMUCapsObjectPropsIDEDrive,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsIDEDrive) },
    { "PIIX4_PM", virQEMUCapsObjectPropsPixx4PM,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPixx4PM) },
1725 1726 1727 1728
    { "usb-redir", virQEMUCapsObjectPropsUSBRedir,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBRedir) },
    { "usb-host", virQEMUCapsObjectPropsUSBHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBHost) },
1729 1730
    { "scsi-generic", virQEMUCapsObjectPropsSCSIGeneric,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIGeneric) },
1731 1732 1733 1734
    { "i440FX-pcihost", virQEMUCapsObjectPropsI440FXPCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsI440FXPCIHost) },
    { "q35-pcihost", virQEMUCapsObjectPropsQ35PCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQ35PCIHost) },
1735 1736
    { "usb-storage", virQEMUCapsObjectPropsUSBStorage,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBStorage) },
1737 1738
    { "kvm-pit", virQEMUCapsObjectPropsKVMPit,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsKVMPit) },
1739 1740 1741 1742 1743 1744 1745 1746
    { "VGA", virQEMUCapsObjectPropsVGA,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVGA) },
    { "vmware-svga", virQEMUCapsObjectPropsVmwareSvga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVmwareSvga) },
    { "qxl", virQEMUCapsObjectPropsQxl,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxl) },
    { "qxl-vga", virQEMUCapsObjectPropsQxlVga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxlVga) },
1747 1748 1749 1750
};


static void
1751 1752 1753 1754 1755
virQEMUCapsProcessStringFlags(virQEMUCapsPtr qemuCaps,
                              size_t nflags,
                              struct virQEMUCapsStringFlags *flags,
                              size_t nvalues,
                              char *const*values)
1756 1757
{
    size_t i, j;
1758 1759
    for (i = 0; i < nflags; i++) {
        for (j = 0; j < nvalues; j++) {
1760
            if (STREQ(values[j], flags[i].value)) {
1761
                virQEMUCapsSet(qemuCaps, flags[i].flag);
1762 1763 1764 1765 1766 1767 1768 1769
                break;
            }
        }
    }
}


static void
1770 1771
virQEMUCapsFreeStringList(size_t len,
                          char **values)
1772 1773
{
    size_t i;
1774 1775
    if (!values)
        return;
1776
    for (i = 0; i < len; i++)
1777 1778 1779 1780 1781 1782 1783 1784
        VIR_FREE(values[i]);
    VIR_FREE(values);
}


#define OBJECT_TYPE_PREFIX "name \""

static int
1785 1786
virQEMUCapsParseDeviceStrObjectTypes(const char *str,
                                     char ***types)
1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804
{
    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;
        }

1805
        if (VIR_EXPAND_N(typelist, ntypelist, 1) < 0)
1806
            goto cleanup;
1807
        if (VIR_STRNDUP(typelist[ntypelist - 1], tmp, end-tmp) < 0)
1808 1809 1810 1811 1812 1813
            goto cleanup;
    }

    *types = typelist;
    ret = ntypelist;

1814
 cleanup:
1815
    if (ret < 0)
1816
        virQEMUCapsFreeStringList(ntypelist, typelist);
1817 1818 1819 1820 1821
    return ret;
}


static int
1822 1823 1824
virQEMUCapsParseDeviceStrObjectProps(const char *str,
                                     const char *type,
                                     char ***props)
1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857
{
    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;
        }
1858
        if (VIR_EXPAND_N(proplist, nproplist, 1) < 0)
1859
            goto cleanup;
1860
        if (VIR_STRNDUP(proplist[nproplist - 1], tmp, end-tmp) < 0)
1861 1862 1863 1864 1865 1866
            goto cleanup;
    }

    *props = proplist;
    ret = nproplist;

1867
 cleanup:
1868
    if (ret < 0)
1869
        virQEMUCapsFreeStringList(nproplist, proplist);
1870 1871 1872 1873 1874
    return ret;
}


int
1875
virQEMUCapsParseDeviceStr(virQEMUCapsPtr qemuCaps, const char *str)
1876 1877 1878 1879 1880
{
    int nvalues;
    char **values;
    size_t i;

1881
    if ((nvalues = virQEMUCapsParseDeviceStrObjectTypes(str, &values)) < 0)
1882
        return -1;
1883 1884 1885 1886 1887 1888
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

1889
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
1890 1891 1892 1893
        const char *type = virQEMUCapsObjectProps[i].type;
        if ((nvalues = virQEMUCapsParseDeviceStrObjectProps(str,
                                                            type,
                                                            &values)) < 0)
1894
            return -1;
1895 1896 1897 1898 1899
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
1900 1901 1902
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
1903 1904
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
1905 1906 1907 1908 1909

    return 0;
}


E
Eric Blake 已提交
1910
static int
1911 1912
virQEMUCapsExtractDeviceStr(const char *qemu,
                            virQEMUCapsPtr qemuCaps,
1913
                            uid_t runUid, gid_t runGid)
1914
{
E
Eric Blake 已提交
1915
    char *output = NULL;
1916
    virCommandPtr cmd;
E
Eric Blake 已提交
1917
    int ret = -1;
1918

E
Eric Blake 已提交
1919 1920
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
1921 1922
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
1923
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
1924 1925
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
1926
     * if -help includes "device driver,?".  */
1927
    cmd = virQEMUCapsProbeCommand(qemu, qemuCaps, runUid, runGid);
1928 1929 1930 1931 1932 1933
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
1934
                         "-device", "PIIX4_PM,?",
1935
                         "-device", "usb-redir,?",
1936
                         "-device", "ide-drive,?",
1937
                         "-device", "usb-host,?",
H
Han Cheng 已提交
1938
                         "-device", "scsi-generic,?",
1939
                         "-device", "usb-storage,?",
1940 1941 1942 1943
                         "-device", "VGA,?",
                         "-device", "vmware-svga,?",
                         "-device", "qxl,?",
                         "-device", "qxl-vga,?",
1944
                         NULL);
1945
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
1946
    virCommandSetErrorBuffer(cmd, &output);
1947

1948
    if (virCommandRun(cmd, NULL) < 0)
1949 1950
        goto cleanup;

1951
    ret = virQEMUCapsParseDeviceStr(qemuCaps, output);
1952

1953
 cleanup:
E
Eric Blake 已提交
1954
    VIR_FREE(output);
1955
    virCommandFree(cmd);
E
Eric Blake 已提交
1956 1957 1958
    return ret;
}

1959

1960 1961 1962
int virQEMUCapsGetDefaultVersion(virCapsPtr caps,
                                 virQEMUCapsCachePtr capsCache,
                                 unsigned int *version)
1963
{
1964
    virQEMUCapsPtr qemucaps;
T
Tal Kain 已提交
1965
    virArch hostarch;
1966
    virCapsDomainDataPtr capsdata;
1967 1968 1969 1970

    if (*version > 0)
        return 0;

T
Tal Kain 已提交
1971
    hostarch = virArchFromHost();
1972 1973 1974
    if (!(capsdata = virCapabilitiesDomainDataLookup(caps,
            VIR_DOMAIN_OSTYPE_HVM, hostarch, VIR_DOMAIN_VIRT_QEMU,
            NULL, NULL))) {
1975
        virReportError(VIR_ERR_INTERNAL_ERROR,
1976
                       _("Cannot find suitable emulator for %s"),
T
Tal Kain 已提交
1977
                       virArchToString(hostarch));
1978 1979 1980
        return -1;
    }

1981 1982 1983
    qemucaps = virQEMUCapsCacheLookup(capsCache, capsdata->emulator);
    VIR_FREE(capsdata);
    if (!qemucaps)
1984 1985
        return -1;

1986
    *version = virQEMUCapsGetVersion(qemucaps);
1987
    virObjectUnref(qemucaps);
1988 1989
    return 0;
}
1990 1991


1992 1993


1994 1995
virQEMUCapsPtr
virQEMUCapsNew(void)
1996
{
1997
    virQEMUCapsPtr qemuCaps;
1998

1999
    if (virQEMUCapsInitialize() < 0)
2000 2001
        return NULL;

2002
    if (!(qemuCaps = virObjectNew(virQEMUCapsClass)))
2003 2004
        return NULL;

2005
    if (!(qemuCaps->flags = virBitmapNew(QEMU_CAPS_LAST)))
2006
        goto error;
2007

2008
    return qemuCaps;
2009

2010
 error:
2011
    virObjectUnref(qemuCaps);
2012
    return NULL;
2013 2014 2015
}


2016
virQEMUCapsPtr virQEMUCapsNewCopy(virQEMUCapsPtr qemuCaps)
2017
{
2018
    virQEMUCapsPtr ret = virQEMUCapsNew();
2019 2020 2021 2022 2023
    size_t i;

    if (!ret)
        return NULL;

2024
    virBitmapCopy(ret->flags, qemuCaps->flags);
2025

2026 2027 2028
    ret->usedQMP = qemuCaps->usedQMP;
    ret->version = qemuCaps->version;
    ret->kvmVersion = qemuCaps->kvmVersion;
2029 2030 2031 2032

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

2033
    ret->arch = qemuCaps->arch;
2034

2035
    if (VIR_ALLOC_N(ret->cpuDefinitions, qemuCaps->ncpuDefinitions) < 0)
2036
        goto error;
2037
    ret->ncpuDefinitions = qemuCaps->ncpuDefinitions;
2038
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
2039 2040
        if (VIR_STRDUP(ret->cpuDefinitions[i], qemuCaps->cpuDefinitions[i]) < 0)
            goto error;
2041 2042
    }

2043
    if (VIR_ALLOC_N(ret->machineTypes, qemuCaps->nmachineTypes) < 0)
2044
        goto error;
2045
    if (VIR_ALLOC_N(ret->machineAliases, qemuCaps->nmachineTypes) < 0)
2046
        goto error;
2047
    if (VIR_ALLOC_N(ret->machineMaxCpus, qemuCaps->nmachineTypes) < 0)
2048
        goto error;
2049
    ret->nmachineTypes = qemuCaps->nmachineTypes;
2050
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2051 2052 2053
        if (VIR_STRDUP(ret->machineTypes[i], qemuCaps->machineTypes[i]) < 0 ||
            VIR_STRDUP(ret->machineAliases[i], qemuCaps->machineAliases[i]) < 0)
            goto error;
2054
        ret->machineMaxCpus[i] = qemuCaps->machineMaxCpus[i];
2055 2056 2057 2058
    }

    return ret;

2059
 error:
2060 2061 2062 2063 2064
    virObjectUnref(ret);
    return NULL;
}


2065
void virQEMUCapsDispose(void *obj)
2066
{
2067
    virQEMUCapsPtr qemuCaps = obj;
2068 2069
    size_t i;

2070
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2071 2072
        VIR_FREE(qemuCaps->machineTypes[i]);
        VIR_FREE(qemuCaps->machineAliases[i]);
2073
    }
2074 2075
    VIR_FREE(qemuCaps->machineTypes);
    VIR_FREE(qemuCaps->machineAliases);
2076
    VIR_FREE(qemuCaps->machineMaxCpus);
2077

2078
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
2079 2080
        VIR_FREE(qemuCaps->cpuDefinitions[i]);
    VIR_FREE(qemuCaps->cpuDefinitions);
2081

2082
    virBitmapFree(qemuCaps->flags);
2083

2084
    VIR_FREE(qemuCaps->package);
2085
    VIR_FREE(qemuCaps->binary);
2086 2087
}

2088
void
2089
virQEMUCapsSet(virQEMUCapsPtr qemuCaps,
2090
               virQEMUCapsFlags flag)
2091
{
2092
    ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2093 2094 2095 2096
}


void
2097
virQEMUCapsSetList(virQEMUCapsPtr qemuCaps, ...)
2098 2099 2100 2101
{
    va_list list;
    int flag;

2102
    va_start(list, qemuCaps);
2103
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
2104
        ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2105
    va_end(list);
2106 2107 2108 2109
}


void
2110
virQEMUCapsClear(virQEMUCapsPtr qemuCaps,
2111
                 virQEMUCapsFlags flag)
2112
{
2113
    ignore_value(virBitmapClearBit(qemuCaps->flags, flag));
2114 2115 2116
}


2117
char *virQEMUCapsFlagsString(virQEMUCapsPtr qemuCaps)
2118
{
2119
    return virBitmapString(qemuCaps->flags);
2120 2121 2122 2123
}


bool
2124
virQEMUCapsGet(virQEMUCapsPtr qemuCaps,
2125
               virQEMUCapsFlags flag)
2126
{
J
Ján Tomko 已提交
2127
    return qemuCaps && virBitmapIsBitSet(qemuCaps->flags, flag);
2128
}
2129 2130


D
Daniel P. Berrange 已提交
2131 2132 2133 2134 2135 2136 2137 2138 2139
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 ||
2140
        ARCH_IS_PPC64(def->os.arch)) {
D
Daniel P. Berrange 已提交
2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176
        /*
         * 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;
    }

2177 2178 2179 2180 2181 2182 2183 2184
    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 已提交
2185 2186 2187 2188
    return false;
}


2189
const char *virQEMUCapsGetBinary(virQEMUCapsPtr qemuCaps)
2190
{
2191
    return qemuCaps->binary;
2192 2193
}

2194
virArch virQEMUCapsGetArch(virQEMUCapsPtr qemuCaps)
2195
{
2196
    return qemuCaps->arch;
2197 2198 2199
}


2200
unsigned int virQEMUCapsGetVersion(virQEMUCapsPtr qemuCaps)
2201
{
2202
    return qemuCaps->version;
2203 2204 2205
}


2206
unsigned int virQEMUCapsGetKVMVersion(virQEMUCapsPtr qemuCaps)
2207
{
2208
    return qemuCaps->kvmVersion;
2209 2210 2211
}


2212 2213 2214 2215 2216 2217
const char *virQEMUCapsGetPackage(virQEMUCapsPtr qemuCaps)
{
    return qemuCaps->package;
}


2218 2219
int virQEMUCapsAddCPUDefinition(virQEMUCapsPtr qemuCaps,
                                const char *name)
2220
{
2221 2222 2223
    char *tmp;

    if (VIR_STRDUP(tmp, name) < 0)
2224
        return -1;
2225
    if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
2226 2227 2228
        VIR_FREE(tmp);
        return -1;
    }
2229
    qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions-1] = tmp;
2230 2231 2232 2233
    return 0;
}


2234 2235
size_t virQEMUCapsGetCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                    char ***names)
2236
{
2237
    if (names)
2238 2239
        *names = qemuCaps->cpuDefinitions;
    return qemuCaps->ncpuDefinitions;
2240 2241 2242
}


2243 2244
size_t virQEMUCapsGetMachineTypes(virQEMUCapsPtr qemuCaps,
                                  char ***names)
2245
{
2246
    if (names)
2247 2248
        *names = qemuCaps->machineTypes;
    return qemuCaps->nmachineTypes;
2249 2250
}

2251 2252 2253
int virQEMUCapsGetMachineTypesCaps(virQEMUCapsPtr qemuCaps,
                                   size_t *nmachines,
                                   virCapsGuestMachinePtr **machines)
2254 2255 2256 2257
{
    size_t i;

    *machines = NULL;
2258
    *nmachines = qemuCaps->nmachineTypes;
2259

2260 2261 2262 2263
    if (*nmachines &&
        VIR_ALLOC_N(*machines, qemuCaps->nmachineTypes) < 0)
        goto error;

2264
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2265 2266
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
2267
            goto error;
2268
        (*machines)[i] = mach;
2269
        if (qemuCaps->machineAliases[i]) {
2270 2271 2272
            if (VIR_STRDUP(mach->name, qemuCaps->machineAliases[i]) < 0 ||
                VIR_STRDUP(mach->canonical, qemuCaps->machineTypes[i]) < 0)
                goto error;
2273
        } else {
2274 2275
            if (VIR_STRDUP(mach->name, qemuCaps->machineTypes[i]) < 0)
                goto error;
2276
        }
2277
        mach->maxCpus = qemuCaps->machineMaxCpus[i];
2278 2279
    }

2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317
    /* 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++;
    }

2318 2319
    return 0;

2320
 error:
2321 2322 2323 2324 2325 2326 2327 2328
    virCapabilitiesFreeMachines(*machines, *nmachines);
    *nmachines = 0;
    *machines = NULL;
    return -1;
}



2329

2330 2331
const char *virQEMUCapsGetCanonicalMachine(virQEMUCapsPtr qemuCaps,
                                           const char *name)
2332 2333 2334
{
    size_t i;

2335 2336 2337
    if (!name)
        return NULL;

2338
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2339
        if (!qemuCaps->machineAliases[i])
2340
            continue;
2341 2342
        if (STREQ(qemuCaps->machineAliases[i], name))
            return qemuCaps->machineTypes[i];
2343 2344 2345 2346
    }

    return name;
}
2347 2348


2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367
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;
}


2368
static int
2369 2370
virQEMUCapsProbeQMPCommands(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2371 2372 2373 2374 2375 2376 2377
{
    char **commands = NULL;
    int ncommands;

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

2378 2379 2380 2381 2382
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsCommands),
                                  virQEMUCapsCommands,
                                  ncommands, commands);
    virQEMUCapsFreeStringList(ncommands, commands);
2383

2384 2385 2386 2387
    /* 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.  */
2388
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ADD_FD)) {
2389 2390 2391 2392 2393 2394 2395
        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)
2396
            virQEMUCapsClear(qemuCaps, QEMU_CAPS_ADD_FD);
2397 2398 2399
        VIR_FORCE_CLOSE(fd);
    }

2400 2401 2402 2403 2404 2405
    /* 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);

2406 2407 2408 2409 2410
    return 0;
}


static int
2411 2412
virQEMUCapsProbeQMPEvents(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
2413 2414 2415 2416 2417 2418 2419
{
    char **events = NULL;
    int nevents;

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

2420 2421 2422 2423 2424
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsEvents),
                                  virQEMUCapsEvents,
                                  nevents, events);
    virQEMUCapsFreeStringList(nevents, events);
2425 2426 2427 2428 2429

    return 0;
}


2430
static int
2431 2432
virQEMUCapsProbeQMPObjects(virQEMUCapsPtr qemuCaps,
                           qemuMonitorPtr mon)
2433 2434 2435 2436 2437 2438 2439
{
    int nvalues;
    char **values;
    size_t i;

    if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
        return -1;
2440 2441 2442 2443 2444 2445
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

2446
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
2447
        const char *type = virQEMUCapsObjectProps[i].type;
2448 2449 2450 2451
        if ((nvalues = qemuMonitorGetObjectProps(mon,
                                                 type,
                                                 &values)) < 0)
            return -1;
2452 2453 2454 2455 2456
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
2457 2458 2459
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2460 2461
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2462
    /* If qemu supports newer -device qxl it supports -vga qxl as well */
2463 2464
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_QXL))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
2465 2466 2467 2468 2469 2470

    return 0;
}


static int
2471 2472
virQEMUCapsProbeQMPMachineTypes(virQEMUCapsPtr qemuCaps,
                                qemuMonitorPtr mon)
2473 2474 2475 2476 2477
{
    qemuMonitorMachineInfoPtr *machines = NULL;
    int nmachines = 0;
    int ret = -1;
    size_t i;
2478
    size_t defIdx = 0;
2479 2480

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

2483
    if (VIR_ALLOC_N(qemuCaps->machineTypes, nmachines) < 0)
2484
        goto cleanup;
2485
    if (VIR_ALLOC_N(qemuCaps->machineAliases, nmachines) < 0)
2486
        goto cleanup;
2487
    if (VIR_ALLOC_N(qemuCaps->machineMaxCpus, nmachines) < 0)
2488
        goto cleanup;
2489

2490
    for (i = 0; i < nmachines; i++) {
2491 2492
        if (STREQ(machines[i]->name, "none"))
            continue;
2493 2494 2495 2496 2497
        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)
2498
            goto cleanup;
2499
        if (machines[i]->isDefault)
2500
            defIdx = qemuCaps->nmachineTypes - 1;
2501 2502
        qemuCaps->machineMaxCpus[qemuCaps->nmachineTypes - 1] =
            machines[i]->maxCpus;
2503
    }
2504 2505

    if (defIdx)
2506
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
2507 2508 2509

    ret = 0;

2510
 cleanup:
2511
    for (i = 0; i < nmachines; i++)
2512 2513 2514 2515 2516 2517 2518
        qemuMonitorMachineInfoFree(machines[i]);
    VIR_FREE(machines);
    return ret;
}


static int
2519 2520
virQEMUCapsProbeQMPCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                  qemuMonitorPtr mon)
2521 2522 2523 2524 2525 2526 2527
{
    int ncpuDefinitions;
    char **cpuDefinitions;

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

2528 2529
    qemuCaps->ncpuDefinitions = ncpuDefinitions;
    qemuCaps->cpuDefinitions = cpuDefinitions;
2530 2531 2532 2533

    return 0;
}

2534 2535
struct tpmTypeToCaps {
    int type;
2536
    virQEMUCapsFlags caps;
2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556
};

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)
{
2557 2558
    int nentries;
    size_t i;
2559
    char **entries = NULL;
S
Stefan Berger 已提交
2560

2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590
    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;
}

2591

2592
static int
2593 2594
virQEMUCapsProbeQMPKVMState(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2595 2596 2597 2598
{
    bool enabled = false;
    bool present = false;

2599
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
2600 2601 2602 2603 2604 2605
        return 0;

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

    /* The QEMU_CAPS_KVM flag was initially set according to the QEMU
2606
     * reporting the recognition of 'query-kvm' QMP command. That merely
N
Nehal J Wani 已提交
2607
     * indicates existence of the command though, not whether KVM support
2608 2609 2610 2611 2612 2613
     * 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) {
2614
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
2615
    } else if (!enabled) {
2616 2617
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
2618 2619 2620 2621 2622
    }

    return 0;
}

2623 2624 2625 2626 2627 2628 2629 2630
struct virQEMUCapsCommandLineProps {
    const char *option;
    const char *param;
    int flag;
};

static struct virQEMUCapsCommandLineProps virQEMUCapsCommandLine[] = {
    { "machine", "mem-merge", QEMU_CAPS_MEM_MERGE },
2631
    { "machine", "vmport", QEMU_CAPS_MACHINE_VMPORT_OPT },
O
Osier Yang 已提交
2632
    { "drive", "discard", QEMU_CAPS_DRIVE_DISCARD },
2633
    { "realtime", "mlock", QEMU_CAPS_MLOCK },
2634
    { "boot-opts", "strict", QEMU_CAPS_BOOT_STRICT },
2635
    { "boot-opts", "reboot-timeout", QEMU_CAPS_REBOOT_TIMEOUT },
2636
    { "boot-opts", "splash-time", QEMU_CAPS_SPLASH_TIMEOUT },
2637
    { "spice", "disable-agent-file-xfer", QEMU_CAPS_SPICE_FILE_XFER_DISABLE },
2638
    { "msg", "timestamp", QEMU_CAPS_MSG_TIMESTAMP },
2639
    { "numa", NULL, QEMU_CAPS_NUMA },
2640
    { "drive", "throttling.bps-total-max", QEMU_CAPS_DRIVE_IOTUNE_MAX},
2641 2642
    { "machine", "aes-key-wrap", QEMU_CAPS_AES_KEY_WRAP },
    { "machine", "dea-key-wrap", QEMU_CAPS_DEA_KEY_WRAP },
2643 2644 2645 2646 2647 2648
};

static int
virQEMUCapsProbeQMPCommandLine(virQEMUCapsPtr qemuCaps,
                               qemuMonitorPtr mon)
{
2649
    bool found = false;
2650 2651 2652 2653 2654 2655 2656
    int nvalues;
    char **values;
    size_t i, j;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsCommandLine); i++) {
        if ((nvalues = qemuMonitorGetCommandLineOptionParameters(mon,
                                                                 virQEMUCapsCommandLine[i].option,
2657 2658
                                                                 &values,
                                                                 &found)) < 0)
2659
            return -1;
2660 2661 2662 2663

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

2664
        for (j = 0; j < nvalues; j++) {
2665
            if (STREQ_NULLABLE(virQEMUCapsCommandLine[i].param, values[j])) {
2666 2667 2668 2669 2670 2671 2672 2673 2674
                virQEMUCapsSet(qemuCaps, virQEMUCapsCommandLine[i].flag);
                break;
            }
        }
        virStringFreeList(values);
    }

    return 0;
}
2675

2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694
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;
}

2695 2696
int virQEMUCapsProbeQMP(virQEMUCapsPtr qemuCaps,
                        qemuMonitorPtr mon)
2697
{
2698
    VIR_DEBUG("qemuCaps=%p mon=%p", qemuCaps, mon);
2699

2700
    if (qemuCaps->usedQMP)
2701 2702
        return 0;

2703
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
2704 2705
        return -1;

2706
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
2707 2708 2709 2710 2711 2712
        return -1;

    return 0;
}


2713 2714 2715 2716 2717 2718
/*
 * Parsing a doc that looks like
 *
 * <qemuCaps>
 *   <qemuctime>234235253</qemuctime>
 *   <selfctime>234235253</selfctime>
2719
 *   <selfvers>1002016</selfvers>
2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731
 *   <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,
2732 2733
                     time_t *qemuctime, time_t *selfctime,
                     unsigned long *selfvers)
2734 2735 2736 2737 2738 2739 2740
{
    xmlDocPtr doc = NULL;
    int ret = -1;
    size_t i;
    int n;
    xmlNodePtr *nodes = NULL;
    xmlXPathContextPtr ctxt = NULL;
J
Ján Tomko 已提交
2741
    char *str = NULL;
2742
    long long int l;
2743
    unsigned long lu;
2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776

    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;

2777 2778 2779 2780
    *selfvers = 0;
    if (virXPathULong("string(./selfvers)", ctxt, &lu) == 0)
        *selfvers = lu;

2781 2782 2783 2784 2785 2786 2787 2788 2789 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 2815 2816 2817 2818 2819 2820 2821
    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;
    }

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

2825 2826 2827 2828 2829 2830 2831 2832 2833 2834
    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 已提交
2835
    VIR_FREE(str);
2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848

    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 已提交
2849
            if (!(qemuCaps->cpuDefinitions[i] = virXMLPropString(nodes[i], "name"))) {
2850 2851 2852 2853 2854 2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874
                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 已提交
2875
            if (!(qemuCaps->machineTypes[i] = virXMLPropString(nodes[i], "name"))) {
2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888
                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 已提交
2889
            VIR_FREE(str);
2890 2891 2892 2893 2894
        }
    }
    VIR_FREE(nodes);

    ret = 0;
2895
 cleanup:
J
Ján Tomko 已提交
2896
    VIR_FREE(str);
2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907
    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 已提交
2908
    char *xml = NULL;
2909 2910 2911 2912
    int ret = -1;
    size_t i;

    virBufferAddLit(&buf, "<qemuCaps>\n");
2913
    virBufferAdjustIndent(&buf, 2);
2914

2915
    virBufferAsprintf(&buf, "<qemuctime>%llu</qemuctime>\n",
2916
                      (long long)qemuCaps->ctime);
2917
    virBufferAsprintf(&buf, "<selfctime>%llu</selfctime>\n",
2918
                      (long long)virGetSelfLastChanged());
2919 2920
    virBufferAsprintf(&buf, "<selfvers>%lu</selfvers>\n",
                      (unsigned long)LIBVIR_VERSION_NUMBER);
2921 2922

    if (qemuCaps->usedQMP)
2923
        virBufferAddLit(&buf, "<usedQMP/>\n");
2924 2925 2926

    for (i = 0; i < QEMU_CAPS_LAST; i++) {
        if (virQEMUCapsGet(qemuCaps, i)) {
2927
            virBufferAsprintf(&buf, "<flag name='%s'/>\n",
2928 2929 2930 2931
                              virQEMUCapsTypeToString(i));
        }
    }

2932
    virBufferAsprintf(&buf, "<version>%d</version>\n",
2933 2934
                      qemuCaps->version);

2935
    virBufferAsprintf(&buf, "<kvmVersion>%d</kvmVersion>\n",
2936 2937
                      qemuCaps->kvmVersion);

2938 2939 2940 2941
    if (qemuCaps->package)
        virBufferAsprintf(&buf, "<package>%s</package>\n",
                          qemuCaps->package);

2942
    virBufferAsprintf(&buf, "<arch>%s</arch>\n",
2943 2944 2945
                      virArchToString(qemuCaps->arch));

    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
2946
        virBufferEscapeString(&buf, "<cpu name='%s'/>\n",
2947 2948 2949 2950
                              qemuCaps->cpuDefinitions[i]);
    }

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2951
        virBufferEscapeString(&buf, "<machine name='%s'",
2952 2953 2954 2955 2956 2957 2958 2959
                              qemuCaps->machineTypes[i]);
        if (qemuCaps->machineAliases[i])
            virBufferEscapeString(&buf, " alias='%s'",
                              qemuCaps->machineAliases[i]);
        virBufferAsprintf(&buf, " maxCpus='%u'/>\n",
                          qemuCaps->machineMaxCpus[i]);
    }

2960
    virBufferAdjustIndent(&buf, -2);
2961 2962
    virBufferAddLit(&buf, "</qemuCaps>\n");

2963
    if (virBufferCheckError(&buf) < 0)
2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001 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
        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;
3031
    VIR_FREE(qemuCaps->package);
3032 3033 3034
    qemuCaps->arch = VIR_ARCH_NONE;
    qemuCaps->usedQMP = false;

3035
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
3036 3037 3038 3039 3040 3041 3042 3043 3044 3045
        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 已提交
3046
    VIR_FREE(qemuCaps->machineMaxCpus);
3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060
    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;
3061
    unsigned long selfvers;
3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089 3090 3091 3092 3093

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

3094 3095
    if (virQEMUCapsLoadCache(qemuCaps, capsfile, &qemuctime, &selfctime,
                             &selfvers) < 0) {
3096 3097 3098 3099 3100 3101 3102 3103 3104 3105
        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;
    }

3106
    /* Discard cache if QEMU binary or libvirtd changed */
3107
    if (qemuctime != qemuCaps->ctime ||
3108 3109
        selfctime != virGetSelfLastChanged() ||
        selfvers != LIBVIR_VERSION_NUMBER) {
3110
        VIR_DEBUG("Outdated cached capabilities '%s' for '%s' "
3111
                  "(%lld vs %lld, %lld vs %lld, %lu vs %lu)",
3112 3113
                  capsfile, qemuCaps->binary,
                  (long long)qemuctime, (long long)qemuCaps->ctime,
3114 3115
                  (long long)selfctime, (long long)virGetSelfLastChanged(),
                  selfvers, (unsigned long)LIBVIR_VERSION_NUMBER);
3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134
        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;
}


3135 3136
#define QEMU_SYSTEM_PREFIX "qemu-system-"

3137
static int
3138
virQEMUCapsInitHelp(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid, const char *qmperr)
3139
{
3140
    virCommandPtr cmd = NULL;
3141
    bool is_kvm;
3142
    char *help = NULL;
3143 3144
    int ret = -1;
    const char *tmp;
3145

3146
    VIR_DEBUG("qemuCaps=%p", qemuCaps);
3147

3148
    tmp = strstr(qemuCaps->binary, QEMU_SYSTEM_PREFIX);
3149 3150
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
3151

3152
        qemuCaps->arch = virQEMUCapsArchFromString(tmp);
3153
    } else {
3154
        qemuCaps->arch = virArchFromHost();
3155 3156
    }

3157
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, NULL, runUid, runGid);
3158 3159 3160 3161
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
3162
        goto cleanup;
3163

3164 3165 3166 3167 3168
    if (virQEMUCapsParseHelpStr(qemuCaps->binary,
                                help, qemuCaps,
                                &qemuCaps->version,
                                &is_kvm,
                                &qemuCaps->kvmVersion,
3169 3170
                                false,
                                qmperr) < 0)
3171
        goto cleanup;
3172

D
Daniel P. Berrange 已提交
3173 3174 3175 3176 3177 3178 3179
    /* 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
     */
3180
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
D
Daniel P. Berrange 已提交
3181
        qemuCaps->arch == VIR_ARCH_I686)
3182
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
D
Daniel P. Berrange 已提交
3183 3184 3185 3186 3187

    /* -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)
3188
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_NO_ACPI);
3189

3190
    /* virQEMUCapsExtractDeviceStr will only set additional caps if qemu
3191
     * understands the 0.13.0+ notion of "-device driver,".  */
3192
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
3193
        strstr(help, "-device driver,?") &&
3194 3195
        virQEMUCapsExtractDeviceStr(qemuCaps->binary,
                                    qemuCaps, runUid, runGid) < 0) {
3196
        goto cleanup;
3197
    }
3198

3199
    if (virQEMUCapsProbeCPUModels(qemuCaps, runUid, runGid) < 0)
3200
        goto cleanup;
3201

3202
    if (virQEMUCapsProbeMachineTypes(qemuCaps, runUid, runGid) < 0)
3203
        goto cleanup;
3204

3205
    ret = 0;
3206
 cleanup:
3207
    virCommandFree(cmd);
3208
    VIR_FREE(help);
3209 3210 3211 3212
    return ret;
}


3213
static void virQEMUCapsMonitorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
3214 3215
                                     virDomainObjPtr vm ATTRIBUTE_UNUSED,
                                     void *opaque ATTRIBUTE_UNUSED)
3216 3217 3218 3219
{
}

static qemuMonitorCallbacks callbacks = {
3220 3221
    .eofNotify = virQEMUCapsMonitorNotify,
    .errorNotify = virQEMUCapsMonitorNotify,
3222 3223 3224 3225 3226 3227 3228
};


/* Capabilities that we assume are always enabled
 * for QEMU >= 1.2.0
 */
static void
3229
virQEMUCapsInitQMPBasic(virQEMUCapsPtr qemuCaps)
3230
{
3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242 3243 3244 3245 3246 3247 3248 3249 3250 3251 3252 3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274 3275 3276 3277 3278
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_COLON);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_REBOOT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_UUID);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNET_HDR);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_V2);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_0_10);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_UNIX);
    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_MIGRATE_QEMU_FD);
    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 已提交
3279
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);
J
Ján Tomko 已提交
3280
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
3281 3282
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
3283
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
3284
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
3285 3286
}

3287 3288 3289 3290 3291 3292 3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305
/* 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 已提交
3306 3307 3308 3309 3310 3311 3312 3313
    /* 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
3314 3315 3316 3317 3318
     */
    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 已提交
3319
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
3320 3321 3322 3323 3324
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
    }

    ret = 0;

3325
 cleanup:
3326 3327 3328
    VIR_FREE(archstr);
    return ret;
}
3329

3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343 3344 3345 3346 3347 3348 3349 3350 3351 3352 3353 3354 3355 3356 3357 3358 3359 3360 3361 3362 3363 3364 3365 3366 3367
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;
3368
    qemuCaps->package = package;
3369 3370 3371 3372 3373 3374 3375 3376 3377 3378 3379 3380 3381 3382 3383
    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);

3384 3385 3386 3387 3388 3389
    /* -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);

3390 3391 3392
    if (qemuCaps->version >= 1006000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE_VIDEO_PRIMARY);

3393 3394 3395 3396
    /* vmport option is supported v2.2.0 onwards */
    if (qemuCaps->version >= 2002000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_VMPORT_OPT);

3397 3398 3399 3400 3401 3402
    /* -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);

3403 3404 3405
    /* 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 已提交
3406
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOSTUSER_MULTIQUEUE);
3407

3408 3409 3410 3411
    /* Since 2.4.50 ARM virt machine supports gic-version option */
    if (qemuCaps->version >= 2004050)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACH_VIRT_GIC_VERSION);

3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427
    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;
3428 3429
    if (virQEMUCapsProbeQMPMigrationCapabilities(qemuCaps, mon) < 0)
        goto cleanup;
3430 3431

    ret = 0;
3432
 cleanup:
3433 3434 3435
    return ret;
}

3436
static int
3437 3438 3439
virQEMUCapsInitQMP(virQEMUCapsPtr qemuCaps,
                   const char *libDir,
                   uid_t runUid,
3440 3441
                   gid_t runGid,
                   char **qmperr)
3442 3443 3444 3445 3446 3447 3448 3449
{
    int ret = -1;
    virCommandPtr cmd = NULL;
    qemuMonitorPtr mon = NULL;
    int status = 0;
    virDomainChrSourceDef config;
    char *monarg = NULL;
    char *monpath = NULL;
3450
    char *pidfile = NULL;
3451
    pid_t pid = 0;
3452 3453
    virDomainObjPtr vm = NULL;
    virDomainXMLOptionPtr xmlopt = NULL;
3454

3455 3456 3457
    /* the ".sock" sufix is important to avoid a possible clash with a qemu
     * domain called "capabilities"
     */
3458
    if (virAsprintf(&monpath, "%s/%s", libDir, "capabilities.monitor.sock") < 0)
3459
        goto cleanup;
3460
    if (virAsprintf(&monarg, "unix:%s,server,nowait", monpath) < 0)
3461 3462
        goto cleanup;

3463 3464
    /* ".pidfile" suffix is used rather than ".pid" to avoid a possible clash
     * with a qemu domain called "capabilities"
3465 3466 3467
     * 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
3468
     */
3469
    if (virAsprintf(&pidfile, "%s/%s", libDir, "capabilities.pidfile") < 0)
3470 3471
        goto cleanup;

3472 3473 3474 3475 3476
    memset(&config, 0, sizeof(config));
    config.type = VIR_DOMAIN_CHR_TYPE_UNIX;
    config.data.nix.path = monpath;
    config.data.nix.listen = false;

3477 3478
    virPidFileForceCleanupPath(pidfile);

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

3481 3482 3483 3484 3485 3486 3487
    /*
     * 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.
     */
3488
    cmd = virCommandNewArgList(qemuCaps->binary,
3489 3490 3491 3492 3493 3494
                               "-S",
                               "-no-user-config",
                               "-nodefaults",
                               "-nographic",
                               "-M", "none",
                               "-qmp", monarg,
3495 3496
                               "-pidfile", pidfile,
                               "-daemonize",
3497 3498 3499
                               NULL);
    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
3500 3501
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
3502

3503 3504
    virCommandSetErrorBuffer(cmd, qmperr);

3505
    /* Log, but otherwise ignore, non-zero status.  */
3506 3507 3508 3509 3510
    if (virCommandRun(cmd, &status) < 0)
        goto cleanup;

    if (status != 0) {
        ret = 0;
3511 3512
        VIR_DEBUG("QEMU %s exited with status %d: %s",
                  qemuCaps->binary, status, *qmperr);
3513 3514 3515
        goto cleanup;
    }

3516 3517 3518 3519 3520 3521
    if (virPidFileReadPath(pidfile, &pid) < 0) {
        VIR_DEBUG("Failed to read pidfile %s", pidfile);
        ret = 0;
        goto cleanup;
    }

3522 3523 3524 3525 3526
    if (!(xmlopt = virDomainXMLOptionNew(NULL, NULL, NULL)) ||
        !(vm = virDomainObjNew(xmlopt)))
        goto cleanup;

    vm->pid = pid;
3527

3528
    if (!(mon = qemuMonitorOpen(vm, &config, true, &callbacks, NULL))) {
3529
        ret = 0;
3530
        goto cleanup;
3531
    }
3532

3533
    virObjectLock(mon);
3534

3535
    if (virQEMUCapsInitQMPMonitor(qemuCaps, mon) < 0)
3536
        goto cleanup;
3537 3538 3539

    ret = 0;

3540
 cleanup:
3541
    if (mon)
3542
        virObjectUnlock(mon);
3543 3544
    qemuMonitorClose(mon);
    virCommandAbort(cmd);
3545
    virCommandFree(cmd);
3546
    VIR_FREE(monarg);
3547 3548
    if (monpath)
        ignore_value(unlink(monpath));
3549
    VIR_FREE(monpath);
M
Michal Privoznik 已提交
3550
    virDomainObjEndAPI(&vm);
3551
    virObjectUnref(xmlopt);
3552

3553
    if (pid != 0) {
3554 3555
        char ebuf[1024];

3556 3557 3558 3559 3560
        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)));
3561 3562

        VIR_FREE(*qmperr);
3563 3564
    }
    if (pidfile) {
3565 3566 3567
        unlink(pidfile);
        VIR_FREE(pidfile);
    }
3568 3569 3570 3571
    return ret;
}


3572 3573 3574 3575 3576 3577 3578 3579 3580 3581 3582 3583
#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();

3584
    virLogMessage(&virLogSelf,
3585 3586 3587 3588 3589 3590 3591 3592 3593
                  VIR_LOG_WARN,
                  __FILE__, __LINE__, __func__,
                  meta,
                  _("Failed to probe capabilities for %s: %s"),
                  binary, err && err->message ? err->message :
                  _("unknown failure"));
}


3594 3595
virQEMUCapsPtr virQEMUCapsNewForBinary(const char *binary,
                                       const char *libDir,
3596
                                       const char *cacheDir,
3597 3598
                                       uid_t runUid,
                                       gid_t runGid)
3599
{
3600
    virQEMUCapsPtr qemuCaps;
3601 3602
    struct stat sb;
    int rv;
3603
    char *qmperr = NULL;
3604

3605 3606 3607
    if (!(qemuCaps = virQEMUCapsNew()))
        goto error;

3608 3609
    if (VIR_STRDUP(qemuCaps->binary, binary) < 0)
        goto error;
3610 3611 3612 3613 3614 3615 3616 3617

    /* 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;
    }
3618
    qemuCaps->ctime = sb.st_ctime;
3619 3620 3621 3622 3623 3624 3625 3626 3627 3628 3629

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

3630
    if ((rv = virQEMUCapsInitCached(qemuCaps, cacheDir)) < 0)
3631 3632
        goto error;

3633
    if (rv == 0) {
3634
        if (virQEMUCapsInitQMP(qemuCaps, libDir, runUid, runGid, &qmperr) < 0) {
3635 3636 3637 3638 3639
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (!qemuCaps->usedQMP &&
3640
            virQEMUCapsInitHelp(qemuCaps, runUid, runGid, qmperr) < 0) {
3641 3642 3643 3644 3645 3646
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (virQEMUCapsRememberCached(qemuCaps, cacheDir) < 0)
            goto error;
3647
    }
3648

3649
    VIR_FREE(qmperr);
3650
    return qemuCaps;
3651

3652
 error:
3653
    VIR_FREE(qmperr);
3654 3655
    virObjectUnref(qemuCaps);
    qemuCaps = NULL;
3656
    return NULL;
3657 3658 3659
}


3660
bool virQEMUCapsIsValid(virQEMUCapsPtr qemuCaps)
3661 3662 3663
{
    struct stat sb;

3664
    if (!qemuCaps->binary)
3665 3666
        return true;

3667
    if (stat(qemuCaps->binary, &sb) < 0)
3668 3669
        return false;

3670
    return sb.st_ctime == qemuCaps->ctime;
3671
}
3672 3673


3674 3675 3676 3677 3678 3679 3680 3681 3682 3683 3684 3685 3686 3687 3688 3689 3690 3691 3692 3693 3694 3695 3696 3697 3698 3699 3700 3701 3702 3703 3704 3705 3706 3707 3708 3709
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]);
    }

}


3710 3711
virQEMUCapsCachePtr
virQEMUCapsCacheNew(const char *libDir,
3712
                    const char *cacheDir,
3713 3714
                    uid_t runUid,
                    gid_t runGid)
3715
{
3716
    virQEMUCapsCachePtr cache;
3717

3718
    if (VIR_ALLOC(cache) < 0)
3719 3720 3721 3722 3723 3724 3725 3726 3727
        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 已提交
3728
    if (!(cache->binaries = virHashCreate(10, virObjectFreeHashData)))
3729
        goto error;
3730
    if (VIR_STRDUP(cache->libDir, libDir) < 0)
3731
        goto error;
3732 3733
    if (VIR_STRDUP(cache->cacheDir, cacheDir) < 0)
        goto error;
3734

3735 3736 3737
    cache->runUid = runUid;
    cache->runGid = runGid;

3738 3739
    return cache;

3740
 error:
3741
    virQEMUCapsCacheFree(cache);
3742 3743 3744
    return NULL;
}

3745
const char *qemuTestCapsName;
3746

3747 3748
virQEMUCapsPtr
virQEMUCapsCacheLookup(virQEMUCapsCachePtr cache, const char *binary)
3749
{
3750
    virQEMUCapsPtr ret = NULL;
3751 3752 3753 3754 3755

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

3756 3757 3758
    virMutexLock(&cache->lock);
    ret = virHashLookup(cache->binaries, binary);
    if (ret &&
3759
        !virQEMUCapsIsValid(ret)) {
3760 3761 3762 3763 3764 3765 3766 3767
        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);
3768
        ret = virQEMUCapsNewForBinary(binary, cache->libDir,
3769
                                      cache->cacheDir,
3770
                                      cache->runUid, cache->runGid);
3771 3772 3773 3774 3775 3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786
        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;
}


3787
virQEMUCapsPtr
3788 3789
virQEMUCapsCacheLookupCopy(virQEMUCapsCachePtr cache,
                           const char *binary,
3790
                           const char *machineType)
3791
{
3792 3793
    virQEMUCapsPtr qemuCaps = virQEMUCapsCacheLookup(cache, binary);
    virQEMUCapsPtr ret;
3794

3795
    if (!qemuCaps)
3796 3797
        return NULL;

3798 3799
    ret = virQEMUCapsNewCopy(qemuCaps);
    virObjectUnref(qemuCaps);
3800
    virQEMUCapsFilterByMachineType(ret, machineType);
3801 3802 3803 3804
    return ret;
}


3805 3806 3807 3808 3809 3810 3811 3812 3813 3814 3815 3816 3817 3818 3819 3820 3821
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;
3822
    virArch target;
3823 3824 3825 3826
    struct virQEMUCapsSearchData data = { .arch = arch };

    virMutexLock(&cache->lock);
    ret = virHashSearch(cache->binaries, virQEMUCapsCompareArch, &data);
3827 3828 3829 3830 3831 3832 3833 3834 3835
    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);
        }
    }
3836 3837 3838
    virObjectRef(ret);
    virMutexUnlock(&cache->lock);

3839 3840
    VIR_DEBUG("Returning caps %p for arch %s", ret, virArchToString(arch));

3841 3842 3843 3844
    return ret;
}


3845
void
3846
virQEMUCapsCacheFree(virQEMUCapsCachePtr cache)
3847 3848 3849 3850
{
    if (!cache)
        return;

3851
    VIR_FREE(cache->libDir);
3852
    VIR_FREE(cache->cacheDir);
3853 3854 3855 3856
    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}
3857 3858

bool
3859
virQEMUCapsUsedQMP(virQEMUCapsPtr qemuCaps)
3860
{
3861
    return qemuCaps->usedQMP;
3862
}
3863 3864 3865 3866

bool
virQEMUCapsSupportsChardev(virDomainDefPtr def,
                           virQEMUCapsPtr qemuCaps,
3867
                           virDomainChrDefPtr chr)
3868 3869 3870 3871 3872
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV) ||
        !virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE))
        return false;

3873
    if ((def->os.arch == VIR_ARCH_PPC) || ARCH_IS_PPC64(def->os.arch)) {
3874 3875 3876 3877 3878
        /* 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);
    }

3879
    if ((def->os.arch != VIR_ARCH_ARMV7L) && (def->os.arch != VIR_ARCH_AARCH64))
3880
        return true;
3881

3882 3883 3884 3885 3886 3887
    /* 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));
3888
}
3889 3890


3891 3892 3893 3894 3895 3896 3897 3898 3899 3900 3901 3902 3903
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");
}


3904 3905 3906 3907 3908 3909 3910 3911 3912 3913 3914 3915
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;
}
3916 3917 3918 3919 3920 3921 3922 3923 3924


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


3927
static int
3928
virQEMUCapsFillDomainLoaderCaps(virQEMUCapsPtr qemuCaps,
3929 3930 3931
                                virDomainCapsLoaderPtr capsLoader,
                                char **loader,
                                size_t nloader)
3932
{
3933 3934
    size_t i;

3935
    capsLoader->device.supported = true;
3936

3937
    if (VIR_ALLOC_N(capsLoader->values.values, nloader) < 0)
3938 3939
        return -1;

3940 3941
    for (i = 0; i < nloader; i++) {
        const char *filename = loader[i];
3942 3943 3944 3945 3946 3947

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

3948
        if (VIR_STRDUP(capsLoader->values.values[capsLoader->values.nvalues],
3949 3950
                       filename) < 0)
            return -1;
3951
        capsLoader->values.nvalues++;
3952 3953
    }

3954
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
3955 3956
                             VIR_DOMAIN_LOADER_TYPE_ROM);

M
Michal Privoznik 已提交
3957
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE) &&
3958
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT))
3959
        VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
3960 3961 3962 3963
                                 VIR_DOMAIN_LOADER_TYPE_PFLASH);


    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE_READONLY))
3964
        VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->readonly,
3965 3966
                                 VIR_TRISTATE_BOOL_YES,
                                 VIR_TRISTATE_BOOL_NO);
3967
    return 0;
3968 3969 3970
}


3971
static int
3972 3973
virQEMUCapsFillDomainOSCaps(virQEMUCapsPtr qemuCaps,
                            virDomainCapsOSPtr os,
3974 3975
                            char **loader,
                            size_t nloader)
3976
{
3977
    virDomainCapsLoaderPtr capsLoader = &os->loader;
3978 3979

    os->device.supported = true;
M
Michal Privoznik 已提交
3980
    if (virQEMUCapsFillDomainLoaderCaps(qemuCaps, capsLoader,
3981
                                        loader, nloader) < 0)
3982 3983
        return -1;
    return 0;
3984 3985 3986
}


3987
static int
3988
virQEMUCapsFillDomainDeviceDiskCaps(virQEMUCapsPtr qemuCaps,
3989
                                    const char *machine,
3990 3991 3992 3993 3994 3995
                                    virDomainCapsDeviceDiskPtr disk)
{
    disk->device.supported = true;
    /* QEMU supports all of these */
    VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice,
                             VIR_DOMAIN_DISK_DEVICE_DISK,
3996 3997 3998 3999 4000
                             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);
4001 4002 4003 4004 4005 4006 4007 4008 4009 4010

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

4011 4012 4013 4014
    /* 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);

4015 4016
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_USB_STORAGE))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_USB);
4017
    return 0;
4018 4019 4020
}


4021
static int
4022 4023 4024 4025 4026 4027 4028 4029 4030 4031 4032 4033 4034 4035 4036 4037 4038 4039 4040 4041 4042 4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055 4056 4057 4058 4059 4060 4061 4062 4063 4064 4065
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);
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE) &&
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
        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);
    }
4066
    return 0;
4067 4068 4069
}


4070
int
4071
virQEMUCapsFillDomainCaps(virDomainCapsPtr domCaps,
4072
                          virQEMUCapsPtr qemuCaps,
4073 4074
                          char **loader,
                          size_t nloader)
4075
{
4076
    virDomainCapsOSPtr os = &domCaps->os;
4077 4078 4079 4080 4081 4082
    virDomainCapsDeviceDiskPtr disk = &domCaps->disk;
    virDomainCapsDeviceHostdevPtr hostdev = &domCaps->hostdev;
    int maxvcpus = virQEMUCapsGetMachineMaxCpus(qemuCaps, domCaps->machine);

    domCaps->maxvcpus = maxvcpus;

M
Michal Privoznik 已提交
4083
    if (virQEMUCapsFillDomainOSCaps(qemuCaps, os,
4084
                                    loader, nloader) < 0 ||
4085
        virQEMUCapsFillDomainDeviceDiskCaps(qemuCaps, domCaps->machine, disk) < 0 ||
4086 4087 4088
        virQEMUCapsFillDomainDeviceHostdevCaps(qemuCaps, hostdev) < 0)
        return -1;
    return 0;
4089
}