qemu_capabilities.c 115.3 KB
Newer Older
1 2 3
/*
 * qemu_capabilities.c: QEMU capabilities generation
 *
4
 * Copyright (C) 2006-2014 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

45
#include <fcntl.h>
46 47 48
#include <sys/stat.h>
#include <unistd.h>
#include <sys/wait.h>
49
#include <stdarg.h>
50 51 52

#define VIR_FROM_THIS VIR_FROM_QEMU

53 54
VIR_LOG_INIT("qemu.qemu_capabilities");

55 56 57 58
/* While not public, these strings must not change. They
 * are used in domain status files which are read on
 * daemon restarts
 */
59
VIR_ENUM_IMPL(virQEMUCaps, QEMU_CAPS_LAST,
60 61 62 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
              "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 */
97
              "vhost-net",
98 99 100 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
              "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",
131 132

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

              "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 已提交
147
              "usb-hub",
148
              "no-shutdown",
149 150

              "cache-unsafe", /* 75 */
151
              "rombar",
J
Jim Fehlig 已提交
152
              "ich9-ahci",
153
              "no-acpi",
154
              "fsdev-readonly",
155

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

              "drive-iotune", /* 85 */
163
              "system_wakeup",
164
              "scsi-disk.channel",
165
              "scsi-block",
166
              "transaction",
167 168 169

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

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

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

186
              "disable-s4", /* 105 */
187
              "usb-redir.filter",
188 189
              "ide-drive.wwn",
              "scsi-disk.wwn",
190
              "seccomp-sandbox",
191 192

              "reboot-timeout", /* 110 */
193
              "dump-guest-core",
194
              "seamless-migration",
195
              "block-commit",
196
              "vnc",
197 198

              "drive-mirror", /* 115 */
199 200
              "usb-redir.bootindex",
              "usb-host.bootindex",
201
              "blockdev-snapshot-sync",
202 203 204 205 206 207
              "qxl",

              "VGA", /* 120 */
              "cirrus-vga",
              "vmware-svga",
              "device-video-primary",
208
              "s390-sclp",
209 210

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

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

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

              "nvram",  /* 140 */
H
Han Cheng 已提交
229 230 231 232 233 234
              "pci-bridge",
              "vfio-pci",
              "vfio-pci.bootindex",
              "scsi-generic",

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

              "vnc-share-policy", /* 150 */
241
              "device-del-event",
242
              "dmi-to-pci-bridge",
243 244
              "i440fx-pci-hole64-size",
              "q35-pci-hole64-size",
245 246

              "usb-storage", /* 155 */
247
              "usb-storage.removable",
248
              "virtio-mmio",
249
              "ich9-intel-hda",
250
              "kvm-pit-lost-tick-policy",
251 252

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

              "usb-kbd", /* 165 */
259
              "host-pci-multidomain",
260
              "msg-timestamp",
261
              "active-commit",
262
              "change-backing-file",
263 264

              "memory-backend-ram", /* 170 */
265
              "numa",
266
              "memory-backend-file",
267
              "usb-audio",
268
              "rtc-reset-reinjection",
269 270

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

              "VGA.vgamem_mb", /* 180 */
              "vmware-svga.vgamem_mb",
              "qxl.vgamem_mb",
              "qxl-vga.vgamem_mb",
280 281
    );

282 283 284 285 286 287 288 289

/*
 * 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.
 */
290
struct _virQEMUCaps {
291 292
    virObject object;

293 294
    bool usedQMP;

295
    char *binary;
296
    time_t ctime;
297

298
    virBitmapPtr flags;
299 300 301

    unsigned int version;
    unsigned int kvmVersion;
302
    char *package;
303

304
    virArch arch;
305 306 307 308 309 310 311

    size_t ncpuDefinitions;
    char **cpuDefinitions;

    size_t nmachineTypes;
    char **machineTypes;
    char **machineAliases;
312
    unsigned int *machineMaxCpus;
313 314
};

315
struct _virQEMUCapsCache {
316 317
    virMutex lock;
    virHashTablePtr binaries;
318
    char *libDir;
319
    char *cacheDir;
320 321
    uid_t runUid;
    gid_t runGid;
322 323
};

324 325 326 327
struct virQEMUCapsSearchData {
    virArch arch;
};

328

329 330
static virClassPtr virQEMUCapsClass;
static void virQEMUCapsDispose(void *obj);
331

332
static int virQEMUCapsOnceInit(void)
333
{
334 335 336 337
    if (!(virQEMUCapsClass = virClassNew(virClassForObject(),
                                         "virQEMUCaps",
                                         sizeof(virQEMUCaps),
                                         virQEMUCapsDispose)))
338 339 340 341 342
        return -1;

    return 0;
}

343
VIR_ONCE_GLOBAL_INIT(virQEMUCaps)
344

345
static virArch virQEMUCapsArchFromString(const char *arch)
346 347 348 349 350 351 352 353 354 355
{
    if (STREQ(arch, "i386"))
        return VIR_ARCH_I686;
    if (STREQ(arch, "arm"))
        return VIR_ARCH_ARMV7L;

    return virArchFromString(arch);
}


356
static const char *virQEMUCapsArchToString(virArch arch)
357 358 359 360 361 362 363 364 365 366
{
    if (arch == VIR_ARCH_I686)
        return "i386";
    else if (arch == VIR_ARCH_ARMV7L)
        return "arm";

    return virArchToString(arch);
}


367
static virCommandPtr
368 369
virQEMUCapsProbeCommand(const char *qemu,
                        virQEMUCapsPtr qemuCaps,
370
                        uid_t runUid, gid_t runGid)
371 372 373
{
    virCommandPtr cmd = virCommandNew(qemu);

374 375
    if (qemuCaps) {
        if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG))
376
            virCommandAddArg(cmd, "-no-user-config");
377
        else if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NODEFCONFIG))
378 379 380 381 382
            virCommandAddArg(cmd, "-nodefconfig");
    }

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
383 384
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
385 386 387 388 389

    return cmd;
}


390
static void
391 392
virQEMUCapsSetDefaultMachine(virQEMUCapsPtr qemuCaps,
                             size_t defIdx)
393
{
394 395
    char *name = qemuCaps->machineTypes[defIdx];
    char *alias = qemuCaps->machineAliases[defIdx];
396
    unsigned int maxCpus = qemuCaps->machineMaxCpus[defIdx];
397 398 399 400 401 402 403

    memmove(qemuCaps->machineTypes + 1,
            qemuCaps->machineTypes,
            sizeof(qemuCaps->machineTypes[0]) * defIdx);
    memmove(qemuCaps->machineAliases + 1,
            qemuCaps->machineAliases,
            sizeof(qemuCaps->machineAliases[0]) * defIdx);
404 405 406
    memmove(qemuCaps->machineMaxCpus + 1,
            qemuCaps->machineMaxCpus,
            sizeof(qemuCaps->machineMaxCpus[0]) * defIdx);
407 408
    qemuCaps->machineTypes[0] = name;
    qemuCaps->machineAliases[0] = alias;
409
    qemuCaps->machineMaxCpus[0] = maxCpus;
410 411
}

412 413 414 415
/* Format is:
 * <machine> <desc> [(default)|(alias of <canonical>)]
 */
static int
416 417
virQEMUCapsParseMachineTypesStr(const char *output,
                                virQEMUCapsPtr qemuCaps)
418 419 420
{
    const char *p = output;
    const char *next;
421
    size_t defIdx = 0;
422 423 424

    do {
        const char *t;
425 426
        char *name;
        char *canonical = NULL;
427 428 429 430 431 432 433 434 435 436

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

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

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

437 438
        if (VIR_STRNDUP(name, p, t - p) < 0)
            return -1;
439 440

        p = t;
441
        if ((t = strstr(p, "(default)")) && (!next || t < next))
442
            defIdx = qemuCaps->nmachineTypes;
443 444 445

        if ((t = strstr(p, "(alias of ")) && (!next || t < next)) {
            p = t + strlen("(alias of ");
446 447
            if (!(t = strchr(p, ')')) || (next && t >= next)) {
                VIR_FREE(name);
448
                continue;
449
            }
450

451
            if (VIR_STRNDUP(canonical, p, t - p) < 0) {
452
                VIR_FREE(name);
453
                return -1;
454 455 456
            }
        }

457
        if (VIR_REALLOC_N(qemuCaps->machineTypes, qemuCaps->nmachineTypes + 1) < 0 ||
458 459
            VIR_REALLOC_N(qemuCaps->machineAliases, qemuCaps->nmachineTypes + 1) < 0 ||
            VIR_REALLOC_N(qemuCaps->machineMaxCpus, qemuCaps->nmachineTypes + 1) < 0) {
460 461
            VIR_FREE(name);
            VIR_FREE(canonical);
462
            return -1;
463
        }
464
        qemuCaps->nmachineTypes++;
465
        if (canonical) {
466 467
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = canonical;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = name;
468
        } else {
469 470
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = name;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = NULL;
471
        }
472 473
        /* When parsing from command line we don't have information about maxCpus */
        qemuCaps->machineMaxCpus[qemuCaps->nmachineTypes-1] = 0;
474 475
    } while ((p = next));

476

477
    if (defIdx)
478
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
479 480 481 482

    return 0;
}

483
static int
484 485
virQEMUCapsProbeMachineTypes(virQEMUCapsPtr qemuCaps,
                             uid_t runUid, gid_t runGid)
486 487
{
    char *output;
488 489
    int ret = -1;
    virCommandPtr cmd;
490
    int status;
491

492 493 494 495
    /* 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.
     */
496
    if (!virFileIsExecutable(qemuCaps->binary)) {
497
        virReportSystemError(errno, _("Cannot find QEMU binary %s"),
498
                             qemuCaps->binary);
499 500 501
        return -1;
    }

502
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
503
    virCommandAddArgList(cmd, "-M", "?", NULL);
504
    virCommandSetOutputBuffer(cmd, &output);
505

506 507
    /* Ignore failure from older qemu that did not understand '-M ?'.  */
    if (virCommandRun(cmd, &status) < 0)
508 509
        goto cleanup;

510
    if (virQEMUCapsParseMachineTypesStr(output, qemuCaps) < 0)
511
        goto cleanup;
512 513 514

    ret = 0;

515
 cleanup:
516 517
    VIR_FREE(output);
    virCommandFree(cmd);
518 519 520 521 522 523

    return ret;
}


typedef int
524 525
(*virQEMUCapsParseCPUModels)(const char *output,
                             virQEMUCapsPtr qemuCaps);
526 527 528 529 530 531 532

/* Format:
 *      <arch> <model>
 * qemu-0.13 encloses some model names in []:
 *      <arch> [<model>]
 */
static int
533 534
virQEMUCapsParseX86Models(const char *output,
                          virQEMUCapsPtr qemuCaps)
535 536 537
{
    const char *p = output;
    const char *next;
538
    int ret = -1;
539 540 541

    do {
        const char *t;
542
        size_t len;
543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559

        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;

560
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
561
            goto cleanup;
562

563 564 565 566
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
567

568 569 570 571
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
572

573
        if (VIR_STRNDUP(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1], p, len) < 0)
574
            goto cleanup;
575 576
    } while ((p = next));

577
    ret = 0;
578

579
 cleanup:
580
    return ret;
581 582
}

P
Prerna Saxena 已提交
583 584 585 586
/* ppc64 parser.
 * Format : PowerPC <machine> <description>
 */
static int
587 588
virQEMUCapsParsePPCModels(const char *output,
                          virQEMUCapsPtr qemuCaps)
P
Prerna Saxena 已提交
589 590 591
{
    const char *p = output;
    const char *next;
592
    int ret = -1;
P
Prerna Saxena 已提交
593 594 595

    do {
        const char *t;
596
        size_t len;
P
Prerna Saxena 已提交
597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616

        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;

617
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0)
618
            goto cleanup;
P
Prerna Saxena 已提交
619

620
        len = t - p - 1;
P
Prerna Saxena 已提交
621

622
        if (VIR_STRNDUP(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1], p, len) < 0)
623
            goto cleanup;
P
Prerna Saxena 已提交
624 625
    } while ((p = next));

626
    ret = 0;
P
Prerna Saxena 已提交
627

628
 cleanup:
629
    return ret;
P
Prerna Saxena 已提交
630
}
631

632
static int
633
virQEMUCapsProbeCPUModels(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid)
634 635 636
{
    char *output = NULL;
    int ret = -1;
637
    virQEMUCapsParseCPUModels parse;
638
    virCommandPtr cmd;
639

640
    if (qemuCaps->arch == VIR_ARCH_I686 ||
641
        qemuCaps->arch == VIR_ARCH_X86_64) {
642
        parse = virQEMUCapsParseX86Models;
643
    } else if ARCH_IS_PPC64(qemuCaps->arch) {
644
        parse = virQEMUCapsParsePPCModels;
645
    } else {
646
        VIR_DEBUG("don't know how to parse %s CPU models",
647
                  virArchToString(qemuCaps->arch));
648 649 650
        return 0;
    }

651
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
652
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
653
    virCommandSetOutputBuffer(cmd, &output);
654

655
    if (virCommandRun(cmd, NULL) < 0)
656 657
        goto cleanup;

658
    if (parse(output, qemuCaps) < 0)
659 660 661 662
        goto cleanup;

    ret = 0;

663
 cleanup:
664
    VIR_FREE(output);
665
    virCommandFree(cmd);
666 667 668 669 670

    return ret;
}


671
static char *
672 673
virQEMUCapsFindBinaryForArch(virArch hostarch,
                             virArch guestarch)
674 675
{
    char *ret;
676
    const char *archstr = virQEMUCapsArchToString(guestarch);
677
    char *binary;
678

679
    if (virAsprintf(&binary, "qemu-system-%s", archstr) < 0)
680 681 682 683 684 685 686 687 688 689 690
        return NULL;

    ret = virFindFileInPath(binary);
    VIR_FREE(binary);
    if (ret && !virFileIsExecutable(ret))
        VIR_FREE(ret);

    if (guestarch == VIR_ARCH_I686 &&
        !ret &&
        hostarch == VIR_ARCH_X86_64) {
        ret = virFindFileInPath("qemu-system-x86_64");
691 692
        if (ret && !virFileIsExecutable(ret))
            VIR_FREE(ret);
693
    }
694

695 696 697 698 699
    if (guestarch == VIR_ARCH_I686 &&
        !ret) {
        ret = virFindFileInPath("qemu");
        if (ret && !virFileIsExecutable(ret))
            VIR_FREE(ret);
700
    }
701

702 703 704 705 706
    return ret;
}


static bool
707 708
virQEMUCapsIsValidForKVM(virArch hostarch,
                         virArch guestarch)
709
{
710
    if (hostarch == guestarch)
711
        return true;
712 713
    if (hostarch == VIR_ARCH_X86_64 &&
        guestarch == VIR_ARCH_I686)
714 715 716 717
        return true;
    return false;
}

718
static int
719 720 721 722
virQEMUCapsInitGuest(virCapsPtr caps,
                     virQEMUCapsCachePtr cache,
                     virArch hostarch,
                     virArch guestarch)
723
{
724
    size_t i;
725 726
    char *kvmbin = NULL;
    char *binary = NULL;
727 728
    virQEMUCapsPtr qemubinCaps = NULL;
    virQEMUCapsPtr kvmbinCaps = NULL;
729 730
    int ret = -1;

J
Ján Tomko 已提交
731
    /* Check for existence of base emulator, or alternate base
732 733
     * which can be used with magic cpu choice
     */
734
    binary = virQEMUCapsFindBinaryForArch(hostarch, guestarch);
735

736
    /* Ignore binary if extracting version info fails */
737
    if (binary) {
738
        if (!(qemubinCaps = virQEMUCapsCacheLookup(cache, binary))) {
739 740 741 742
            virResetLastError();
            VIR_FREE(binary);
        }
    }
743 744

    /* qemu-kvm/kvm binaries can only be used if
745 746 747 748 749
     *  - host & guest arches match
     * Or
     *  - hostarch is x86_64 and guest arch is i686
     * The latter simply needs "-cpu qemu32"
     */
750
    if (virQEMUCapsIsValidForKVM(hostarch, guestarch)) {
751 752 753
        const char *const kvmbins[] = { "/usr/libexec/qemu-kvm", /* RHEL */
                                        "qemu-kvm", /* Fedora */
                                        "kvm" }; /* Upstream .spec */
754

755 756
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
            kvmbin = virFindFileInPath(kvmbins[i]);
757

758 759
            if (!kvmbin)
                continue;
760

761
            if (!(kvmbinCaps = virQEMUCapsCacheLookup(cache, kvmbin))) {
762
                virResetLastError();
763 764 765
                VIR_FREE(kvmbin);
                continue;
            }
766

767 768
            if (!binary) {
                binary = kvmbin;
769
                qemubinCaps = kvmbinCaps;
770
                kvmbin = NULL;
771
                kvmbinCaps = NULL;
772
            }
773
            break;
774 775 776
        }
    }

777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805
    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;

806 807 808
    if (!binary)
        return 0;

809
    if (virFileExists("/dev/kvm") &&
810 811
        (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         virQEMUCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
812
         kvmbin))
813
        haskvm = true;
814

815
    if (virFileExists("/dev/kqemu") &&
816
        virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KQEMU))
817
        haskqemu = true;
J
Jiri Denemark 已提交
818

819
    if (virQEMUCapsGetMachineTypesCaps(qemubinCaps, &nmachines, &machines) < 0)
820
        goto cleanup;
821 822 823 824

    /* We register kvm as the base emulator too, since we can
     * just give -no-kvm to disable acceleration if required */
    if ((guest = virCapabilitiesAddGuest(caps,
D
Daniel P. Berrange 已提交
825
                                         "hvm",
826
                                         guestarch,
827 828 829 830
                                         binary,
                                         NULL,
                                         nmachines,
                                         machines)) == NULL)
831
        goto cleanup;
832 833 834 835 836

    machines = NULL;
    nmachines = 0;

    if (caps->host.cpu &&
J
Jiri Denemark 已提交
837
        caps->host.cpu->model &&
838
        virQEMUCapsGetCPUDefinitions(qemubinCaps, NULL) > 0 &&
839
        !virCapabilitiesAddGuestFeature(guest, "cpuselection", true, false))
840
        goto cleanup;
841

842
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_BOOTINDEX) &&
843
        !virCapabilitiesAddGuestFeature(guest, "deviceboot", true, false))
844
        goto cleanup;
845

846 847 848
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_DISK_SNAPSHOT))
        hasdisksnapshot = true;

849 850
    if (!virCapabilitiesAddGuestFeature(guest, "disksnapshot", hasdisksnapshot,
                                        false))
851
        goto cleanup;
852

D
Daniel P. Berrange 已提交
853 854 855 856 857 858
    if (virCapabilitiesAddGuestDomain(guest,
                                      "qemu",
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
859
        goto cleanup;
860

D
Daniel P. Berrange 已提交
861 862 863 864 865 866 867
    if (haskqemu &&
        virCapabilitiesAddGuestDomain(guest,
                                      "kqemu",
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
868
        goto cleanup;
869

D
Daniel P. Berrange 已提交
870 871
    if (haskvm) {
        virCapsGuestDomainPtr dom;
872

D
Daniel P. Berrange 已提交
873
        if (kvmbin &&
874
            virQEMUCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
875
            goto cleanup;
876

D
Daniel P. Berrange 已提交
877 878 879 880 881 882
        if ((dom = virCapabilitiesAddGuestDomain(guest,
                                                 "kvm",
                                                 kvmbin ? kvmbin : binary,
                                                 NULL,
                                                 nmachines,
                                                 machines)) == NULL) {
883
            goto cleanup;
D
Daniel P. Berrange 已提交
884
        }
885

D
Daniel P. Berrange 已提交
886 887
        machines = NULL;
        nmachines = 0;
888 889 890

    }

891 892
    if (((guestarch == VIR_ARCH_I686) ||
         (guestarch == VIR_ARCH_X86_64)) &&
893 894
        (virCapabilitiesAddGuestFeature(guest, "acpi", true, true) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "apic", true, false) == NULL))
895
        goto cleanup;
896

897
    if ((guestarch == VIR_ARCH_I686) &&
898 899
        (virCapabilitiesAddGuestFeature(guest, "pae", true, false) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "nonpae", true, false) == NULL))
900
        goto cleanup;
901 902 903

    ret = 0;

904
 cleanup:
905 906 907

    virCapabilitiesFreeMachines(machines, nmachines);

908
    return ret;
909 910 911 912
}


static int
913 914
virQEMUCapsInitCPU(virCapsPtr caps,
                   virArch arch)
915 916
{
    virCPUDefPtr cpu = NULL;
917
    virCPUDataPtr data = NULL;
918 919 920
    virNodeInfo nodeinfo;
    int ret = -1;

921
    if (VIR_ALLOC(cpu) < 0)
922 923
        goto error;

924 925
    cpu->arch = arch;

926
    if (nodeGetInfo(&nodeinfo))
927 928 929 930 931 932
        goto error;

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

935
    if (!(data = cpuNodeData(arch))
936
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0)
J
Jiri Denemark 已提交
937
        goto cleanup;
938 939 940

    ret = 0;

941
 cleanup:
J
Jiri Denemark 已提交
942
    cpuDataFree(data);
943 944 945

    return ret;

946
 error:
947 948 949 950 951
    virCPUDefFree(cpu);
    goto cleanup;
}


M
Michal Privoznik 已提交
952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974
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;
}


975
virCapsPtr virQEMUCapsInit(virQEMUCapsCachePtr cache)
976 977
{
    virCapsPtr caps;
978
    size_t i;
T
Tal Kain 已提交
979
    virArch hostarch = virArchFromHost();
980

T
Tal Kain 已提交
981
    if ((caps = virCapabilitiesNew(hostarch,
982
                                   true, true)) == NULL)
983
        goto error;
984 985 986 987 988 989 990

    /* 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
     */
    if (nodeCapsInitNUMA(caps) < 0) {
        virCapabilitiesFreeNUMAInfo(caps);
991
        VIR_WARN("Failed to query host NUMA topology, disabling NUMA capabilities");
992 993
    }

T
Tal Kain 已提交
994
    if (virQEMUCapsInitCPU(caps, hostarch) < 0)
995
        VIR_WARN("Failed to get host CPU");
996

997
    /* Add the power management features of the host */
998
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
999 1000
        VIR_WARN("Failed to get host power management capabilities");

M
Michal Privoznik 已提交
1001 1002 1003 1004
    /* Add huge pages info */
    if (virQEMUCapsInitPages(caps) < 0)
        VIR_WARN("Failed to get pages info");

1005 1006 1007
    /* Add domain migration transport URIs */
    virCapabilitiesAddHostMigrateTransport(caps, "tcp");
    virCapabilitiesAddHostMigrateTransport(caps, "rdma");
1008

1009 1010 1011 1012
    /* 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
     */
1013
    for (i = 0; i < VIR_ARCH_LAST; i++)
1014
        if (virQEMUCapsInitGuest(caps, cache,
T
Tal Kain 已提交
1015
                                 hostarch,
1016
                                 i) < 0)
1017
            goto error;
1018 1019 1020

    return caps;

1021
 error:
1022
    virObjectUnref(caps);
1023 1024 1025 1026
    return NULL;
}


1027
static int
1028 1029
virQEMUCapsComputeCmdFlags(const char *help,
                           unsigned int version,
1030
                           bool is_kvm,
1031 1032 1033
                           unsigned int kvm_version,
                           virQEMUCapsPtr qemuCaps,
                           bool check_yajl ATTRIBUTE_UNUSED)
1034 1035
{
    const char *p;
R
Richa Marwaha 已提交
1036
    const char *fsdev, *netdev;
1037 1038

    if (strstr(help, "-no-kqemu"))
1039
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KQEMU);
1040
    if (strstr(help, "-enable-kqemu"))
1041
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KQEMU);
1042
    if (strstr(help, "-no-kvm"))
1043
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
1044
    if (strstr(help, "-enable-kvm"))
1045
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
1046
    if (strstr(help, "-no-reboot"))
1047
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_REBOOT);
1048
    if (strstr(help, "-name")) {
1049
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME);
1050
        if (strstr(help, ",process="))
1051
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
1052 1053
    }
    if (strstr(help, "-uuid"))
1054
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_UUID);
1055
    if (strstr(help, "-xen-domid"))
1056
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_XEN_DOMID);
1057
    else if (strstr(help, "-domid"))
1058
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DOMID);
1059
    if (strstr(help, "-drive")) {
1060 1061
        const char *cache = strstr(help, "cache=");

1062
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE);
1063 1064
        if (cache && (p = strchr(cache, ']'))) {
            if (memmem(cache, p - cache, "on|off", sizeof("on|off") - 1) == NULL)
1065
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_V2);
1066
            if (memmem(cache, p - cache, "directsync", sizeof("directsync") - 1))
1067
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
1068
            if (memmem(cache, p - cache, "unsafe", sizeof("unsafe") - 1))
1069
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
1070
        }
1071
        if (strstr(help, "format="))
1072
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT);
1073
        if (strstr(help, "readonly="))
1074
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1075
        if (strstr(help, "aio=threads|native"))
1076
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_AIO);
O
Osier Yang 已提交
1077
        if (strstr(help, "copy-on-read=on|off"))
1078
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
1079
        if (strstr(help, "bps="))
1080
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_IOTUNE);
1081 1082 1083 1084
    }
    if ((p = strstr(help, "-vga")) && !strstr(help, "-std-vga")) {
        const char *nl = strstr(p, "\n");

1085
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA);
1086 1087

        if (strstr(p, "|qxl"))
1088
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
1089
        if ((p = strstr(p, "|none")) && p < nl)
1090
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
1091 1092
    }
    if (strstr(help, "-spice"))
1093
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
1094
    if (strstr(help, "-vnc"))
1095
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
1096
    if (strstr(help, "seamless-migration="))
1097
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
1098
    if (strstr(help, "boot=on"))
1099
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_BOOT);
1100
    if (strstr(help, "serial=s"))
1101
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
1102
    if (strstr(help, "-pcidevice"))
1103
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCIDEVICE);
1104 1105
    if (strstr(help, "host=[seg:]bus"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
1106
    if (strstr(help, "-mem-path"))
1107
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
1108
    if (strstr(help, "-chardev")) {
1109
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
1110
        if (strstr(help, "-chardev spicevmc"))
1111
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
1112 1113
        if (strstr(help, "-chardev spiceport"))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEPORT);
1114
    }
1115
    if (strstr(help, "-balloon"))
1116
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BALLOON);
1117
    if (strstr(help, "-device")) {
1118
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE);
1119 1120 1121 1122
        /*
         * When -device was introduced, qemu already supported drive's
         * readonly option but didn't advertise that.
         */
1123
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1124 1125
    }
    if (strstr(help, "-nodefconfig"))
1126
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
1127
    if (strstr(help, "-no-user-config"))
1128
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
1129 1130
    /* The trailing ' ' is important to avoid a bogus match */
    if (strstr(help, "-rtc "))
1131
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
1132 1133
    /* to wit */
    if (strstr(help, "-rtc-td-hack"))
1134
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC_TD_HACK);
1135
    if (strstr(help, "-no-hpet"))
1136
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
1137
    if (strstr(help, "-no-acpi"))
1138
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
1139
    if (strstr(help, "-no-kvm-pit-reinjection"))
1140
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
1141
    if (strstr(help, "-tdf"))
1142
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_TDF);
1143
    if (strstr(help, "-enable-nesting"))
1144
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NESTING);
1145
    if (strstr(help, ",menu=on"))
1146
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
1147
    if (strstr(help, ",reboot-timeout=rb_time"))
1148
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_REBOOT_TIMEOUT);
1149 1150
    if (strstr(help, ",splash-time=sp_time"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPLASH_TIMEOUT);
1151
    if ((fsdev = strstr(help, "-fsdev"))) {
1152
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
1153
        if (strstr(fsdev, "readonly"))
1154
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
1155
        if (strstr(fsdev, "writeout"))
1156
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
1157
    }
1158
    if (strstr(help, "-smbios type"))
1159
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
1160
    if (strstr(help, "-sandbox"))
1161
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
1162

R
Richa Marwaha 已提交
1163
    if ((netdev = strstr(help, "-netdev"))) {
1164 1165
        /* Disable -netdev on 0.12 since although it exists,
         * the corresponding netdev_add/remove monitor commands
1166 1167
         * do not, and we need them to be able to do hotplug.
         * But see below about RHEL build. */
R
Richa Marwaha 已提交
1168 1169
        if (version >= 13000) {
            if (strstr(netdev, "bridge"))
1170 1171
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
           virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
R
Richa Marwaha 已提交
1172
        }
1173 1174 1175
    }

    if (strstr(help, "-sdl"))
1176
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
1177 1178 1179
    if (strstr(help, "cores=") &&
        strstr(help, "threads=") &&
        strstr(help, "sockets="))
1180
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMP_TOPOLOGY);
1181 1182

    if (version >= 9000)
1183
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_COLON);
1184 1185

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

1188
    if (strstr(help, ",vhost="))
1189
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
1190

1191 1192
    /* 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
1193
     * 0.14.* and 0.15.0)
1194
     */
1195
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1196
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
1197

1198
    if (strstr(help, "dump-guest-core=on|off"))
1199
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
1200

O
Olivia Yin 已提交
1201 1202 1203
    if (strstr(help, "-dtb"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);

1204 1205 1206
    if (strstr(help, "-machine"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);

1207 1208 1209 1210
    /*
     * Handling of -incoming arg with varying features
     *  -incoming tcp    (kvm >= 79, qemu >= 0.10.0)
     *  -incoming exec   (kvm >= 80, qemu >= 0.10.0)
1211 1212
     *  -incoming unix   (qemu >= 0.12.0)
     *  -incoming fd     (qemu >= 0.12.0)
1213 1214 1215 1216 1217 1218 1219
     *  -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) {
1220 1221
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1222
        if (version >= 12000) {
1223 1224
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_UNIX);
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_FD);
1225
        }
1226
    } else if (kvm_version >= 79) {
1227
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
1228
        if (kvm_version >= 80)
1229
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1230
    } else if (kvm_version > 0) {
1231
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_KVM_STDIO);
1232 1233 1234
    }

    if (version >= 10000)
1235
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_0_10);
1236

1237
    if (version >= 11000)
1238
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
1239

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

    if (version >= 13000)
1279
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIFUNCTION);
1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291

    /* 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)
1292
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_ROMBAR);
1293 1294

    if (version >= 11000)
1295
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_HOST);
1296

1297
    if (version >= 1001000) {
J
Ján Tomko 已提交
1298
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
1299 1300
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
    }
J
Ján Tomko 已提交
1301

1302
    return 0;
1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328
}

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

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

1342 1343
    *version = *kvm_version = 0;
    *is_kvm = false;
1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360

    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 已提交
1361
    if (minor == -1)
1362 1363
        goto fail;

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

    SKIP_BLANKS(p);

    if (STRPREFIX(p, QEMU_KVM_VER_PREFIX)) {
1376
        *is_kvm = true;
1377 1378 1379 1380
        p += strlen(QEMU_KVM_VER_PREFIX);
    } else if (STRPREFIX(p, KVM_VER_PREFIX)) {
        int ret;

1381
        *is_kvm = true;
1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392
        p += strlen(KVM_VER_PREFIX);

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

        *kvm_version = ret;
    }

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

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

1409 1410
    if (virQEMUCapsComputeCmdFlags(help, *version, *is_kvm, *kvm_version,
                                   qemuCaps, check_yajl) < 0)
1411
        goto cleanup;
1412

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

    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;

1425
 fail:
1426
    p = strchr(help, '\n');
1427 1428
    if (!p)
        p = strchr(help, '\0');
1429

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

1434
 cleanup:
1435 1436 1437
    return -1;
}

1438

1439
struct virQEMUCapsStringFlags {
1440 1441 1442 1443 1444
    const char *value;
    int flag;
};


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

1463 1464 1465 1466
struct virQEMUCapsStringFlags virQEMUCapsMigration[] = {
    { "rdma-pin-all", QEMU_CAPS_MIGRATE_RDMA },
};

1467 1468 1469
struct virQEMUCapsStringFlags virQEMUCapsEvents[] = {
    { "BALLOON_CHANGE", QEMU_CAPS_BALLOON_EVENT },
    { "SPICE_MIGRATE_COMPLETED", QEMU_CAPS_SEAMLESS_MIGRATION },
1470
    { "DEVICE_DELETED", QEMU_CAPS_DEVICE_DEL_EVENT },
1471 1472
};

1473
struct virQEMUCapsStringFlags virQEMUCapsObjectTypes[] = {
1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488
    { "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 },
1489
    { "virtio-blk-ccw", QEMU_CAPS_VIRTIO_CCW },
1490
    { "sclpconsole", QEMU_CAPS_SCLP_S390 },
1491
    { "lsi53c895a", QEMU_CAPS_SCSI_LSI },
1492
    { "virtio-scsi-pci", QEMU_CAPS_VIRTIO_SCSI },
1493 1494
    { "virtio-scsi-s390", QEMU_CAPS_VIRTIO_SCSI },
    { "virtio-scsi-ccw", QEMU_CAPS_VIRTIO_SCSI },
1495
    { "megasas", QEMU_CAPS_SCSI_MEGASAS },
1496 1497
    { "spicevmc", QEMU_CAPS_DEVICE_SPICEVMC },
    { "qxl-vga", QEMU_CAPS_DEVICE_QXL_VGA },
1498
    { "qxl", QEMU_CAPS_DEVICE_QXL },
1499 1500 1501 1502
    { "sga", QEMU_CAPS_SGA },
    { "scsi-block", QEMU_CAPS_SCSI_BLOCK },
    { "scsi-cd", QEMU_CAPS_SCSI_CD },
    { "ide-cd", QEMU_CAPS_IDE_CD },
1503 1504 1505
    { "VGA", QEMU_CAPS_DEVICE_VGA },
    { "cirrus-vga", QEMU_CAPS_DEVICE_CIRRUS_VGA },
    { "vmware-svga", QEMU_CAPS_DEVICE_VMWARE_SVGA },
H
Han Cheng 已提交
1506 1507
    { "usb-serial", QEMU_CAPS_DEVICE_USB_SERIAL },
    { "usb-net", QEMU_CAPS_DEVICE_USB_NET },
1508
    { "virtio-rng-pci", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1509 1510
    { "virtio-rng-s390", QEMU_CAPS_DEVICE_VIRTIO_RNG },
    { "virtio-rng-ccw", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1511
    { "rng-random", QEMU_CAPS_OBJECT_RNG_RANDOM },
1512
    { "rng-egd", QEMU_CAPS_OBJECT_RNG_EGD },
1513
    { "spapr-nvram", QEMU_CAPS_DEVICE_NVRAM },
1514
    { "pci-bridge", QEMU_CAPS_DEVICE_PCI_BRIDGE },
1515
    { "vfio-pci", QEMU_CAPS_DEVICE_VFIO_PCI },
H
Han Cheng 已提交
1516
    { "scsi-generic", QEMU_CAPS_DEVICE_SCSI_GENERIC },
1517
    { "i82801b11-bridge", QEMU_CAPS_DEVICE_DMI_TO_PCI_BRIDGE },
1518
    { "usb-storage", QEMU_CAPS_DEVICE_USB_STORAGE },
1519
    { "virtio-mmio", QEMU_CAPS_DEVICE_VIRTIO_MMIO },
1520
    { "ich9-intel-hda", QEMU_CAPS_DEVICE_ICH9_INTEL_HDA },
H
Hu Tao 已提交
1521
    { "pvpanic", QEMU_CAPS_DEVICE_PANIC },
L
Li Zhang 已提交
1522
    { "usb-kbd", QEMU_CAPS_DEVICE_USB_KBD },
1523
    { "memory-backend-ram", QEMU_CAPS_OBJECT_MEMORY_RAM },
1524
    { "memory-backend-file", QEMU_CAPS_OBJECT_MEMORY_FILE },
1525
    { "usb-audio", QEMU_CAPS_OBJECT_USB_AUDIO },
J
John Ferlan 已提交
1526
    { "iothread", QEMU_CAPS_OBJECT_IOTHREAD},
1527
    { "ivshmem", QEMU_CAPS_DEVICE_IVSHMEM },
1528 1529
};

1530
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBlk[] = {
1531 1532 1533 1534 1535 1536 1537 1538
    { "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 },
};

1539
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioNet[] = {
1540 1541 1542 1543
    { "tx", QEMU_CAPS_VIRTIO_TX_ALG },
    { "event_idx", QEMU_CAPS_VIRTIO_NET_EVENT_IDX },
};

1544
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPCIAssign[] = {
1545
    { "rombar", QEMU_CAPS_PCI_ROMBAR },
1546 1547 1548 1549
    { "configfd", QEMU_CAPS_PCI_CONFIGFD },
    { "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};

1550
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVfioPCI[] = {
1551 1552 1553
    { "bootindex", QEMU_CAPS_VFIO_PCI_BOOTINDEX },
};

1554
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIDisk[] = {
1555 1556 1557 1558
    { "channel", QEMU_CAPS_SCSI_DISK_CHANNEL },
    { "wwn", QEMU_CAPS_SCSI_DISK_WWN },
};

1559
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsIDEDrive[] = {
1560 1561 1562
    { "wwn", QEMU_CAPS_IDE_DRIVE_WWN },
};

1563
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPixx4PM[] = {
1564 1565 1566 1567
    { "disable_s3", QEMU_CAPS_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_DISABLE_S4 },
};

1568
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBRedir[] = {
1569
    { "filter", QEMU_CAPS_USB_REDIR_FILTER },
1570 1571 1572
    { "bootindex", QEMU_CAPS_USB_REDIR_BOOTINDEX },
};

1573
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBHost[] = {
1574
    { "bootindex", QEMU_CAPS_USB_HOST_BOOTINDEX },
1575 1576
};

1577
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsSCSIGeneric[] = {
H
Han Cheng 已提交
1578 1579 1580
    { "bootindex", QEMU_CAPS_DEVICE_SCSI_GENERIC_BOOTINDEX },
};

1581
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsI440FXPCIHost[] = {
1582 1583 1584
    { "pci-hole64-size", QEMU_CAPS_I440FX_PCI_HOLE64_SIZE },
};

1585
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsQ35PCIHost[] = {
1586 1587 1588
    { "pci-hole64-size", QEMU_CAPS_Q35_PCI_HOLE64_SIZE },
};

1589
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUSBStorage[] = {
1590 1591 1592
    { "removable", QEMU_CAPS_USB_STORAGE_REMOVABLE },
};

1593 1594 1595 1596
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsKVMPit[] = {
    { "lost_tick_policy", QEMU_CAPS_KVM_PIT_TICK_POLICY },
};

1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612
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 },
};

1613
struct virQEMUCapsObjectTypeProps {
1614
    const char *type;
1615
    struct virQEMUCapsStringFlags *props;
1616 1617 1618
    size_t nprops;
};

1619 1620 1621 1622
static struct virQEMUCapsObjectTypeProps virQEMUCapsObjectProps[] = {
    { "virtio-blk-pci", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-pci", virQEMUCapsObjectPropsVirtioNet,
1623 1624 1625 1626
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-ccw", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-ccw", virQEMUCapsObjectPropsVirtioNet,
1627 1628 1629 1630 1631
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-s390", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-s390", virQEMUCapsObjectPropsVirtioNet,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
1632 1633 1634 1635 1636 1637
    { "pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "kvm-pci-assign", virQEMUCapsObjectPropsPCIAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPCIAssign) },
    { "vfio-pci", virQEMUCapsObjectPropsVfioPCI,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVfioPCI) },
1638 1639
    { "scsi-disk", virQEMUCapsObjectPropsSCSIDisk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIDisk) },
1640 1641 1642 1643
    { "ide-drive", virQEMUCapsObjectPropsIDEDrive,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsIDEDrive) },
    { "PIIX4_PM", virQEMUCapsObjectPropsPixx4PM,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPixx4PM) },
1644 1645 1646 1647
    { "usb-redir", virQEMUCapsObjectPropsUSBRedir,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBRedir) },
    { "usb-host", virQEMUCapsObjectPropsUSBHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBHost) },
1648 1649
    { "scsi-generic", virQEMUCapsObjectPropsSCSIGeneric,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsSCSIGeneric) },
1650 1651 1652 1653
    { "i440FX-pcihost", virQEMUCapsObjectPropsI440FXPCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsI440FXPCIHost) },
    { "q35-pcihost", virQEMUCapsObjectPropsQ35PCIHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQ35PCIHost) },
1654 1655
    { "usb-storage", virQEMUCapsObjectPropsUSBStorage,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUSBStorage) },
1656 1657
    { "kvm-pit", virQEMUCapsObjectPropsKVMPit,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsKVMPit) },
1658 1659 1660 1661 1662 1663 1664 1665
    { "VGA", virQEMUCapsObjectPropsVGA,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVGA) },
    { "vmware-svga", virQEMUCapsObjectPropsVmwareSvga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVmwareSvga) },
    { "qxl", virQEMUCapsObjectPropsQxl,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxl) },
    { "qxl-vga", virQEMUCapsObjectPropsQxlVga,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsQxlVga) },
1666 1667 1668 1669
};


static void
1670 1671 1672 1673 1674
virQEMUCapsProcessStringFlags(virQEMUCapsPtr qemuCaps,
                              size_t nflags,
                              struct virQEMUCapsStringFlags *flags,
                              size_t nvalues,
                              char *const*values)
1675 1676
{
    size_t i, j;
1677 1678
    for (i = 0; i < nflags; i++) {
        for (j = 0; j < nvalues; j++) {
1679
            if (STREQ(values[j], flags[i].value)) {
1680
                virQEMUCapsSet(qemuCaps, flags[i].flag);
1681 1682 1683 1684 1685 1686 1687 1688
                break;
            }
        }
    }
}


static void
1689 1690
virQEMUCapsFreeStringList(size_t len,
                          char **values)
1691 1692
{
    size_t i;
1693
    for (i = 0; i < len; i++)
1694 1695 1696 1697 1698 1699 1700 1701
        VIR_FREE(values[i]);
    VIR_FREE(values);
}


#define OBJECT_TYPE_PREFIX "name \""

static int
1702 1703
virQEMUCapsParseDeviceStrObjectTypes(const char *str,
                                     char ***types)
1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721
{
    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;
        }

1722
        if (VIR_EXPAND_N(typelist, ntypelist, 1) < 0)
1723
            goto cleanup;
1724
        if (VIR_STRNDUP(typelist[ntypelist - 1], tmp, end-tmp) < 0)
1725 1726 1727 1728 1729 1730
            goto cleanup;
    }

    *types = typelist;
    ret = ntypelist;

1731
 cleanup:
1732
    if (ret < 0)
1733
        virQEMUCapsFreeStringList(ntypelist, typelist);
1734 1735 1736 1737 1738
    return ret;
}


static int
1739 1740 1741
virQEMUCapsParseDeviceStrObjectProps(const char *str,
                                     const char *type,
                                     char ***props)
1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774
{
    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;
        }
1775
        if (VIR_EXPAND_N(proplist, nproplist, 1) < 0)
1776
            goto cleanup;
1777
        if (VIR_STRNDUP(proplist[nproplist - 1], tmp, end-tmp) < 0)
1778 1779 1780 1781 1782 1783
            goto cleanup;
    }

    *props = proplist;
    ret = nproplist;

1784
 cleanup:
1785
    if (ret < 0 && proplist)
1786
        virQEMUCapsFreeStringList(nproplist, proplist);
1787 1788 1789 1790 1791
    return ret;
}


int
1792
virQEMUCapsParseDeviceStr(virQEMUCapsPtr qemuCaps, const char *str)
1793 1794 1795 1796 1797
{
    int nvalues;
    char **values;
    size_t i;

1798
    if ((nvalues = virQEMUCapsParseDeviceStrObjectTypes(str, &values)) < 0)
1799
        return -1;
1800 1801 1802 1803 1804 1805
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

1806
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
1807 1808 1809 1810
        const char *type = virQEMUCapsObjectProps[i].type;
        if ((nvalues = virQEMUCapsParseDeviceStrObjectProps(str,
                                                            type,
                                                            &values)) < 0)
1811
            return -1;
1812 1813 1814 1815 1816
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
1817 1818 1819
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
1820 1821
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
1822 1823 1824 1825 1826

    return 0;
}


E
Eric Blake 已提交
1827
static int
1828 1829
virQEMUCapsExtractDeviceStr(const char *qemu,
                            virQEMUCapsPtr qemuCaps,
1830
                            uid_t runUid, gid_t runGid)
1831
{
E
Eric Blake 已提交
1832
    char *output = NULL;
1833
    virCommandPtr cmd;
E
Eric Blake 已提交
1834
    int ret = -1;
1835

E
Eric Blake 已提交
1836 1837
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
1838 1839
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
1840
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
1841 1842
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
1843
     * if -help includes "device driver,?".  */
1844
    cmd = virQEMUCapsProbeCommand(qemu, qemuCaps, runUid, runGid);
1845 1846 1847 1848 1849 1850
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
1851
                         "-device", "PIIX4_PM,?",
1852
                         "-device", "usb-redir,?",
1853
                         "-device", "ide-drive,?",
1854
                         "-device", "usb-host,?",
H
Han Cheng 已提交
1855
                         "-device", "scsi-generic,?",
1856
                         "-device", "usb-storage,?",
1857 1858 1859 1860
                         "-device", "VGA,?",
                         "-device", "vmware-svga,?",
                         "-device", "qxl,?",
                         "-device", "qxl-vga,?",
1861
                         NULL);
1862
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
1863
    virCommandSetErrorBuffer(cmd, &output);
1864

1865
    if (virCommandRun(cmd, NULL) < 0)
1866 1867
        goto cleanup;

1868
    ret = virQEMUCapsParseDeviceStr(qemuCaps, output);
1869

1870
 cleanup:
E
Eric Blake 已提交
1871
    VIR_FREE(output);
1872
    virCommandFree(cmd);
E
Eric Blake 已提交
1873 1874 1875
    return ret;
}

1876

1877 1878 1879
int virQEMUCapsGetDefaultVersion(virCapsPtr caps,
                                 virQEMUCapsCachePtr capsCache,
                                 unsigned int *version)
1880 1881
{
    const char *binary;
1882
    virQEMUCapsPtr qemucaps;
T
Tal Kain 已提交
1883
    virArch hostarch;
1884 1885 1886 1887

    if (*version > 0)
        return 0;

T
Tal Kain 已提交
1888
    hostarch = virArchFromHost();
1889 1890
    if ((binary = virCapabilitiesDefaultGuestEmulator(caps,
                                                      "hvm",
T
Tal Kain 已提交
1891
                                                      hostarch,
1892
                                                      "qemu")) == NULL) {
1893
        virReportError(VIR_ERR_INTERNAL_ERROR,
1894
                       _("Cannot find suitable emulator for %s"),
T
Tal Kain 已提交
1895
                       virArchToString(hostarch));
1896 1897 1898
        return -1;
    }

1899
    if (!(qemucaps = virQEMUCapsCacheLookup(capsCache, binary)))
1900 1901
        return -1;

1902
    *version = virQEMUCapsGetVersion(qemucaps);
1903
    virObjectUnref(qemucaps);
1904 1905
    return 0;
}
1906 1907


1908 1909


1910 1911
virQEMUCapsPtr
virQEMUCapsNew(void)
1912
{
1913
    virQEMUCapsPtr qemuCaps;
1914

1915
    if (virQEMUCapsInitialize() < 0)
1916 1917
        return NULL;

1918
    if (!(qemuCaps = virObjectNew(virQEMUCapsClass)))
1919 1920
        return NULL;

1921
    if (!(qemuCaps->flags = virBitmapNew(QEMU_CAPS_LAST)))
1922
        goto error;
1923

1924
    return qemuCaps;
1925

1926
 error:
1927
    virObjectUnref(qemuCaps);
1928
    return NULL;
1929 1930 1931
}


1932
virQEMUCapsPtr virQEMUCapsNewCopy(virQEMUCapsPtr qemuCaps)
1933
{
1934
    virQEMUCapsPtr ret = virQEMUCapsNew();
1935 1936 1937 1938 1939
    size_t i;

    if (!ret)
        return NULL;

1940
    virBitmapCopy(ret->flags, qemuCaps->flags);
1941

1942 1943 1944
    ret->usedQMP = qemuCaps->usedQMP;
    ret->version = qemuCaps->version;
    ret->kvmVersion = qemuCaps->kvmVersion;
1945 1946 1947 1948

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

1949
    ret->arch = qemuCaps->arch;
1950

1951
    if (VIR_ALLOC_N(ret->cpuDefinitions, qemuCaps->ncpuDefinitions) < 0)
1952
        goto error;
1953
    ret->ncpuDefinitions = qemuCaps->ncpuDefinitions;
1954
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
1955 1956
        if (VIR_STRDUP(ret->cpuDefinitions[i], qemuCaps->cpuDefinitions[i]) < 0)
            goto error;
1957 1958
    }

1959
    if (VIR_ALLOC_N(ret->machineTypes, qemuCaps->nmachineTypes) < 0)
1960
        goto error;
1961
    if (VIR_ALLOC_N(ret->machineAliases, qemuCaps->nmachineTypes) < 0)
1962
        goto error;
1963
    if (VIR_ALLOC_N(ret->machineMaxCpus, qemuCaps->nmachineTypes) < 0)
1964
        goto error;
1965
    ret->nmachineTypes = qemuCaps->nmachineTypes;
1966
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
1967 1968 1969
        if (VIR_STRDUP(ret->machineTypes[i], qemuCaps->machineTypes[i]) < 0 ||
            VIR_STRDUP(ret->machineAliases[i], qemuCaps->machineAliases[i]) < 0)
            goto error;
1970
        ret->machineMaxCpus[i] = qemuCaps->machineMaxCpus[i];
1971 1972 1973 1974
    }

    return ret;

1975
 error:
1976 1977 1978 1979 1980
    virObjectUnref(ret);
    return NULL;
}


1981
void virQEMUCapsDispose(void *obj)
1982
{
1983
    virQEMUCapsPtr qemuCaps = obj;
1984 1985
    size_t i;

1986
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
1987 1988
        VIR_FREE(qemuCaps->machineTypes[i]);
        VIR_FREE(qemuCaps->machineAliases[i]);
1989
    }
1990 1991
    VIR_FREE(qemuCaps->machineTypes);
    VIR_FREE(qemuCaps->machineAliases);
1992
    VIR_FREE(qemuCaps->machineMaxCpus);
1993

1994
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
1995 1996
        VIR_FREE(qemuCaps->cpuDefinitions[i]);
    VIR_FREE(qemuCaps->cpuDefinitions);
1997

1998
    virBitmapFree(qemuCaps->flags);
1999

2000
    VIR_FREE(qemuCaps->package);
2001
    VIR_FREE(qemuCaps->binary);
2002 2003
}

2004
void
2005
virQEMUCapsSet(virQEMUCapsPtr qemuCaps,
2006
               virQEMUCapsFlags flag)
2007
{
2008
    ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2009 2010 2011 2012
}


void
2013
virQEMUCapsSetList(virQEMUCapsPtr qemuCaps, ...)
2014 2015 2016 2017
{
    va_list list;
    int flag;

2018
    va_start(list, qemuCaps);
2019
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
2020
        ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
2021
    va_end(list);
2022 2023 2024 2025
}


void
2026
virQEMUCapsClear(virQEMUCapsPtr qemuCaps,
2027
                 virQEMUCapsFlags flag)
2028
{
2029
    ignore_value(virBitmapClearBit(qemuCaps->flags, flag));
2030 2031 2032
}


2033
char *virQEMUCapsFlagsString(virQEMUCapsPtr qemuCaps)
2034
{
2035
    return virBitmapString(qemuCaps->flags);
2036 2037 2038 2039
}


bool
2040
virQEMUCapsGet(virQEMUCapsPtr qemuCaps,
2041
               virQEMUCapsFlags flag)
2042
{
2043 2044
    bool b;

2045
    if (!qemuCaps || virBitmapGetBit(qemuCaps->flags, flag, &b) < 0)
2046 2047 2048
        return false;
    else
        return b;
2049
}
2050 2051


D
Daniel P. Berrange 已提交
2052 2053 2054 2055 2056 2057 2058 2059 2060
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 ||
2061
        ARCH_IS_PPC64(def->os.arch)) {
D
Daniel P. Berrange 已提交
2062 2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101
        /*
         * 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;
    }

    return false;
}


2102
const char *virQEMUCapsGetBinary(virQEMUCapsPtr qemuCaps)
2103
{
2104
    return qemuCaps->binary;
2105 2106
}

2107
virArch virQEMUCapsGetArch(virQEMUCapsPtr qemuCaps)
2108
{
2109
    return qemuCaps->arch;
2110 2111 2112
}


2113
unsigned int virQEMUCapsGetVersion(virQEMUCapsPtr qemuCaps)
2114
{
2115
    return qemuCaps->version;
2116 2117 2118
}


2119
unsigned int virQEMUCapsGetKVMVersion(virQEMUCapsPtr qemuCaps)
2120
{
2121
    return qemuCaps->kvmVersion;
2122 2123 2124
}


2125 2126 2127 2128 2129 2130
const char *virQEMUCapsGetPackage(virQEMUCapsPtr qemuCaps)
{
    return qemuCaps->package;
}


2131 2132
int virQEMUCapsAddCPUDefinition(virQEMUCapsPtr qemuCaps,
                                const char *name)
2133
{
2134 2135 2136
    char *tmp;

    if (VIR_STRDUP(tmp, name) < 0)
2137
        return -1;
2138
    if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
2139 2140 2141
        VIR_FREE(tmp);
        return -1;
    }
2142
    qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions-1] = tmp;
2143 2144 2145 2146
    return 0;
}


2147 2148
size_t virQEMUCapsGetCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                    char ***names)
2149
{
2150
    if (names)
2151 2152
        *names = qemuCaps->cpuDefinitions;
    return qemuCaps->ncpuDefinitions;
2153 2154 2155
}


2156 2157
size_t virQEMUCapsGetMachineTypes(virQEMUCapsPtr qemuCaps,
                                  char ***names)
2158
{
2159
    if (names)
2160 2161
        *names = qemuCaps->machineTypes;
    return qemuCaps->nmachineTypes;
2162 2163
}

2164 2165 2166
int virQEMUCapsGetMachineTypesCaps(virQEMUCapsPtr qemuCaps,
                                   size_t *nmachines,
                                   virCapsGuestMachinePtr **machines)
2167 2168 2169 2170
{
    size_t i;

    *machines = NULL;
2171
    *nmachines = qemuCaps->nmachineTypes;
2172

2173 2174 2175 2176
    if (*nmachines &&
        VIR_ALLOC_N(*machines, qemuCaps->nmachineTypes) < 0)
        goto error;

2177
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2178 2179
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
2180
            goto error;
2181
        (*machines)[i] = mach;
2182
        if (qemuCaps->machineAliases[i]) {
2183 2184 2185
            if (VIR_STRDUP(mach->name, qemuCaps->machineAliases[i]) < 0 ||
                VIR_STRDUP(mach->canonical, qemuCaps->machineTypes[i]) < 0)
                goto error;
2186
        } else {
2187 2188
            if (VIR_STRDUP(mach->name, qemuCaps->machineTypes[i]) < 0)
                goto error;
2189
        }
2190
        mach->maxCpus = qemuCaps->machineMaxCpus[i];
2191 2192 2193 2194
    }

    return 0;

2195
 error:
2196 2197 2198 2199 2200 2201 2202 2203
    virCapabilitiesFreeMachines(*machines, *nmachines);
    *nmachines = 0;
    *machines = NULL;
    return -1;
}



2204

2205 2206
const char *virQEMUCapsGetCanonicalMachine(virQEMUCapsPtr qemuCaps,
                                           const char *name)
2207 2208 2209
{
    size_t i;

2210 2211 2212
    if (!name)
        return NULL;

2213
    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2214
        if (!qemuCaps->machineAliases[i])
2215
            continue;
2216 2217
        if (STREQ(qemuCaps->machineAliases[i], name))
            return qemuCaps->machineTypes[i];
2218 2219 2220 2221
    }

    return name;
}
2222 2223


2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242
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;
}


2243
static int
2244 2245
virQEMUCapsProbeQMPCommands(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2246 2247 2248 2249 2250 2251 2252
{
    char **commands = NULL;
    int ncommands;

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

2253 2254 2255 2256 2257
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsCommands),
                                  virQEMUCapsCommands,
                                  ncommands, commands);
    virQEMUCapsFreeStringList(ncommands, commands);
2258

2259 2260 2261 2262
    /* 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.  */
2263
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ADD_FD)) {
2264 2265 2266 2267 2268 2269 2270
        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)
2271
            virQEMUCapsClear(qemuCaps, QEMU_CAPS_ADD_FD);
2272 2273 2274
        VIR_FORCE_CLOSE(fd);
    }

2275 2276 2277 2278 2279 2280
    /* 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);

2281 2282 2283 2284 2285
    return 0;
}


static int
2286 2287
virQEMUCapsProbeQMPEvents(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
2288 2289 2290 2291 2292 2293 2294
{
    char **events = NULL;
    int nevents;

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

2295 2296 2297 2298 2299
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsEvents),
                                  virQEMUCapsEvents,
                                  nevents, events);
    virQEMUCapsFreeStringList(nevents, events);
2300 2301 2302 2303 2304

    return 0;
}


2305
static int
2306 2307
virQEMUCapsProbeQMPObjects(virQEMUCapsPtr qemuCaps,
                           qemuMonitorPtr mon)
2308 2309 2310 2311 2312 2313 2314
{
    int nvalues;
    char **values;
    size_t i;

    if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
        return -1;
2315 2316 2317 2318 2319 2320
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

2321
    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
2322
        const char *type = virQEMUCapsObjectProps[i].type;
2323 2324 2325 2326
        if ((nvalues = qemuMonitorGetObjectProps(mon,
                                                 type,
                                                 &values)) < 0)
            return -1;
2327 2328 2329 2330 2331
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
2332 2333 2334
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2335 2336
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2337
    /* If qemu supports newer -device qxl it supports -vga qxl as well */
2338 2339
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_QXL))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
2340 2341 2342 2343 2344 2345

    return 0;
}


static int
2346 2347
virQEMUCapsProbeQMPMachineTypes(virQEMUCapsPtr qemuCaps,
                                qemuMonitorPtr mon)
2348 2349 2350 2351 2352
{
    qemuMonitorMachineInfoPtr *machines = NULL;
    int nmachines = 0;
    int ret = -1;
    size_t i;
2353
    size_t defIdx = 0;
2354 2355

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

2358
    if (VIR_ALLOC_N(qemuCaps->machineTypes, nmachines) < 0)
2359
        goto cleanup;
2360
    if (VIR_ALLOC_N(qemuCaps->machineAliases, nmachines) < 0)
2361
        goto cleanup;
2362
    if (VIR_ALLOC_N(qemuCaps->machineMaxCpus, nmachines) < 0)
2363
        goto cleanup;
2364

2365
    for (i = 0; i < nmachines; i++) {
2366 2367
        if (STREQ(machines[i]->name, "none"))
            continue;
2368 2369 2370 2371 2372
        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)
2373
            goto cleanup;
2374
        if (machines[i]->isDefault)
2375
            defIdx = qemuCaps->nmachineTypes - 1;
2376 2377
        qemuCaps->machineMaxCpus[qemuCaps->nmachineTypes - 1] =
            machines[i]->maxCpus;
2378
    }
2379 2380

    if (defIdx)
2381
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
2382 2383 2384

    ret = 0;

2385
 cleanup:
2386
    for (i = 0; i < nmachines; i++)
2387 2388 2389 2390 2391 2392 2393
        qemuMonitorMachineInfoFree(machines[i]);
    VIR_FREE(machines);
    return ret;
}


static int
2394 2395
virQEMUCapsProbeQMPCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                  qemuMonitorPtr mon)
2396 2397 2398 2399 2400 2401 2402
{
    int ncpuDefinitions;
    char **cpuDefinitions;

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

2403 2404
    qemuCaps->ncpuDefinitions = ncpuDefinitions;
    qemuCaps->cpuDefinitions = cpuDefinitions;
2405 2406 2407 2408

    return 0;
}

2409 2410
struct tpmTypeToCaps {
    int type;
2411
    virQEMUCapsFlags caps;
2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431
};

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)
{
2432 2433
    int nentries;
    size_t i;
2434
    char **entries = NULL;
S
Stefan Berger 已提交
2435

2436 2437 2438 2439 2440 2441 2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465
    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;
}

2466

2467
static int
2468 2469
virQEMUCapsProbeQMPKVMState(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2470 2471 2472 2473
{
    bool enabled = false;
    bool present = false;

2474
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
2475 2476 2477 2478 2479 2480
        return 0;

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

    /* The QEMU_CAPS_KVM flag was initially set according to the QEMU
2481
     * reporting the recognition of 'query-kvm' QMP command. That merely
N
Nehal J Wani 已提交
2482
     * indicates existence of the command though, not whether KVM support
2483 2484 2485 2486 2487 2488
     * 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) {
2489
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
2490
    } else if (!enabled) {
2491 2492
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
2493 2494 2495 2496 2497
    }

    return 0;
}

2498 2499 2500 2501 2502 2503 2504 2505
struct virQEMUCapsCommandLineProps {
    const char *option;
    const char *param;
    int flag;
};

static struct virQEMUCapsCommandLineProps virQEMUCapsCommandLine[] = {
    { "machine", "mem-merge", QEMU_CAPS_MEM_MERGE },
O
Osier Yang 已提交
2506
    { "drive", "discard", QEMU_CAPS_DRIVE_DISCARD },
2507
    { "realtime", "mlock", QEMU_CAPS_MLOCK },
2508
    { "boot-opts", "strict", QEMU_CAPS_BOOT_STRICT },
2509
    { "boot-opts", "reboot-timeout", QEMU_CAPS_REBOOT_TIMEOUT },
2510
    { "boot-opts", "splash-time", QEMU_CAPS_SPLASH_TIMEOUT },
2511
    { "spice", "disable-agent-file-xfer", QEMU_CAPS_SPICE_FILE_XFER_DISABLE },
2512
    { "msg", "timestamp", QEMU_CAPS_MSG_TIMESTAMP },
2513
    { "numa", NULL, QEMU_CAPS_NUMA },
2514
    { "drive", "throttling.bps-total-max", QEMU_CAPS_DRIVE_IOTUNE_MAX},
2515 2516 2517 2518 2519 2520
};

static int
virQEMUCapsProbeQMPCommandLine(virQEMUCapsPtr qemuCaps,
                               qemuMonitorPtr mon)
{
2521
    bool found = false;
2522 2523 2524 2525 2526 2527 2528
    int nvalues;
    char **values;
    size_t i, j;

    for (i = 0; i < ARRAY_CARDINALITY(virQEMUCapsCommandLine); i++) {
        if ((nvalues = qemuMonitorGetCommandLineOptionParameters(mon,
                                                                 virQEMUCapsCommandLine[i].option,
2529 2530
                                                                 &values,
                                                                 &found)) < 0)
2531
            return -1;
2532 2533 2534 2535

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

2536
        for (j = 0; j < nvalues; j++) {
2537
            if (STREQ_NULLABLE(virQEMUCapsCommandLine[i].param, values[j])) {
2538 2539 2540 2541 2542 2543 2544 2545 2546
                virQEMUCapsSet(qemuCaps, virQEMUCapsCommandLine[i].flag);
                break;
            }
        }
        virStringFreeList(values);
    }

    return 0;
}
2547

2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566
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;
}

2567 2568
int virQEMUCapsProbeQMP(virQEMUCapsPtr qemuCaps,
                        qemuMonitorPtr mon)
2569
{
2570
    VIR_DEBUG("qemuCaps=%p mon=%p", qemuCaps, mon);
2571

2572
    if (qemuCaps->usedQMP)
2573 2574
        return 0;

2575
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
2576 2577
        return -1;

2578
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
2579 2580 2581 2582 2583 2584
        return -1;

    return 0;
}


2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610
/*
 * Parsing a doc that looks like
 *
 * <qemuCaps>
 *   <qemuctime>234235253</qemuctime>
 *   <selfctime>234235253</selfctime>
 *   <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,
                     time_t *qemuctime, time_t *selfctime)
{
    xmlDocPtr doc = NULL;
    int ret = -1;
    size_t i;
    int n;
    xmlNodePtr *nodes = NULL;
    xmlXPathContextPtr ctxt = NULL;
J
Ján Tomko 已提交
2611
    char *str = NULL;
2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636 2637 2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686
    long long int l;

    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;

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

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

2690 2691 2692 2693 2694 2695 2696 2697 2698 2699
    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 已提交
2700
    VIR_FREE(str);
2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713

    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 已提交
2714
            if (!(qemuCaps->cpuDefinitions[i] = virXMLPropString(nodes[i], "name"))) {
2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739
                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 已提交
2740
            if (!(qemuCaps->machineTypes[i] = virXMLPropString(nodes[i], "name"))) {
2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753
                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 已提交
2754
            VIR_FREE(str);
2755 2756 2757 2758 2759
        }
    }
    VIR_FREE(nodes);

    ret = 0;
2760
 cleanup:
J
Ján Tomko 已提交
2761
    VIR_FREE(str);
2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772
    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 已提交
2773
    char *xml = NULL;
2774 2775 2776 2777
    int ret = -1;
    size_t i;

    virBufferAddLit(&buf, "<qemuCaps>\n");
2778
    virBufferAdjustIndent(&buf, 2);
2779

2780
    virBufferAsprintf(&buf, "<qemuctime>%llu</qemuctime>\n",
2781
                      (long long)qemuCaps->ctime);
2782
    virBufferAsprintf(&buf, "<selfctime>%llu</selfctime>\n",
2783 2784 2785
                      (long long)virGetSelfLastChanged());

    if (qemuCaps->usedQMP)
2786
        virBufferAddLit(&buf, "<usedQMP/>\n");
2787 2788 2789

    for (i = 0; i < QEMU_CAPS_LAST; i++) {
        if (virQEMUCapsGet(qemuCaps, i)) {
2790
            virBufferAsprintf(&buf, "<flag name='%s'/>\n",
2791 2792 2793 2794
                              virQEMUCapsTypeToString(i));
        }
    }

2795
    virBufferAsprintf(&buf, "<version>%d</version>\n",
2796 2797
                      qemuCaps->version);

2798
    virBufferAsprintf(&buf, "<kvmVersion>%d</kvmVersion>\n",
2799 2800
                      qemuCaps->kvmVersion);

2801 2802 2803 2804
    if (qemuCaps->package)
        virBufferAsprintf(&buf, "<package>%s</package>\n",
                          qemuCaps->package);

2805
    virBufferAsprintf(&buf, "<arch>%s</arch>\n",
2806 2807 2808
                      virArchToString(qemuCaps->arch));

    for (i = 0; i < qemuCaps->ncpuDefinitions; i++) {
2809
        virBufferEscapeString(&buf, "<cpu name='%s'/>\n",
2810 2811 2812 2813
                              qemuCaps->cpuDefinitions[i]);
    }

    for (i = 0; i < qemuCaps->nmachineTypes; i++) {
2814
        virBufferEscapeString(&buf, "<machine name='%s'",
2815 2816 2817 2818 2819 2820 2821 2822
                              qemuCaps->machineTypes[i]);
        if (qemuCaps->machineAliases[i])
            virBufferEscapeString(&buf, " alias='%s'",
                              qemuCaps->machineAliases[i]);
        virBufferAsprintf(&buf, " maxCpus='%u'/>\n",
                          qemuCaps->machineMaxCpus[i]);
    }

2823
    virBufferAdjustIndent(&buf, -2);
2824 2825
    virBufferAddLit(&buf, "</qemuCaps>\n");

2826
    if (virBufferCheckError(&buf) < 0)
2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 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 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893
        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;
2894
    VIR_FREE(qemuCaps->package);
2895 2896 2897
    qemuCaps->arch = VIR_ARCH_NONE;
    qemuCaps->usedQMP = false;

2898
    for (i = 0; i < qemuCaps->ncpuDefinitions; i++)
2899 2900 2901 2902 2903 2904 2905 2906 2907 2908
        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 已提交
2909
    VIR_FREE(qemuCaps->machineMaxCpus);
2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993
    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;

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

    if (virQEMUCapsLoadCache(qemuCaps, capsfile, &qemuctime, &selfctime) < 0) {
        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;
    }

    /* Discard if cache is older that QEMU binary */
    if (qemuctime != qemuCaps->ctime ||
        selfctime < virGetSelfLastChanged()) {
        VIR_DEBUG("Outdated cached capabilities '%s' for '%s' "
                  "(%lld vs %lld, %lld vs %lld)",
                  capsfile, qemuCaps->binary,
                  (long long)qemuctime, (long long)qemuCaps->ctime,
                  (long long)selfctime, (long long)virGetSelfLastChanged());
        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;
}


2994 2995
#define QEMU_SYSTEM_PREFIX "qemu-system-"

2996
static int
2997
virQEMUCapsInitHelp(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid, const char *qmperr)
2998
{
2999
    virCommandPtr cmd = NULL;
3000
    bool is_kvm;
3001
    char *help = NULL;
3002 3003
    int ret = -1;
    const char *tmp;
3004

3005
    VIR_DEBUG("qemuCaps=%p", qemuCaps);
3006

3007
    tmp = strstr(qemuCaps->binary, QEMU_SYSTEM_PREFIX);
3008 3009
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
3010

3011
        qemuCaps->arch = virQEMUCapsArchFromString(tmp);
3012
    } else {
3013
        qemuCaps->arch = virArchFromHost();
3014 3015
    }

3016
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, NULL, runUid, runGid);
3017 3018 3019 3020
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
3021
        goto cleanup;
3022

3023 3024 3025 3026 3027
    if (virQEMUCapsParseHelpStr(qemuCaps->binary,
                                help, qemuCaps,
                                &qemuCaps->version,
                                &is_kvm,
                                &qemuCaps->kvmVersion,
3028 3029
                                false,
                                qmperr) < 0)
3030
        goto cleanup;
3031

D
Daniel P. Berrange 已提交
3032 3033 3034 3035 3036 3037 3038
    /* 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
     */
3039
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
D
Daniel P. Berrange 已提交
3040
        qemuCaps->arch == VIR_ARCH_I686)
3041
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
D
Daniel P. Berrange 已提交
3042 3043 3044 3045 3046

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

3049
    /* virQEMUCapsExtractDeviceStr will only set additional caps if qemu
3050
     * understands the 0.13.0+ notion of "-device driver,".  */
3051
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
3052
        strstr(help, "-device driver,?") &&
3053 3054
        virQEMUCapsExtractDeviceStr(qemuCaps->binary,
                                    qemuCaps, runUid, runGid) < 0) {
3055
        goto cleanup;
3056
    }
3057

3058
    if (virQEMUCapsProbeCPUModels(qemuCaps, runUid, runGid) < 0)
3059
        goto cleanup;
3060

3061
    if (virQEMUCapsProbeMachineTypes(qemuCaps, runUid, runGid) < 0)
3062
        goto cleanup;
3063

3064
    ret = 0;
3065
 cleanup:
3066
    virCommandFree(cmd);
3067
    VIR_FREE(help);
3068 3069 3070 3071
    return ret;
}


3072
static void virQEMUCapsMonitorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
3073 3074
                                     virDomainObjPtr vm ATTRIBUTE_UNUSED,
                                     void *opaque ATTRIBUTE_UNUSED)
3075 3076 3077 3078
{
}

static qemuMonitorCallbacks callbacks = {
3079 3080
    .eofNotify = virQEMUCapsMonitorNotify,
    .errorNotify = virQEMUCapsMonitorNotify,
3081 3082 3083 3084 3085 3086 3087
};


/* Capabilities that we assume are always enabled
 * for QEMU >= 1.2.0
 */
static void
3088
virQEMUCapsInitQMPBasic(virQEMUCapsPtr qemuCaps)
3089
{
3090 3091 3092 3093 3094 3095 3096 3097 3098 3099 3100 3101 3102 3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114 3115 3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134 3135 3136 3137
    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 已提交
3138
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);
J
Ján Tomko 已提交
3139
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
3140 3141
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
3142
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_SHARE_POLICY);
3143
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_HOST_PCI_MULTIDOMAIN);
3144 3145
}

3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164
/* 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 已提交
3165 3166 3167 3168 3169 3170 3171 3172
    /* 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
3173 3174 3175 3176 3177
     */
    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 已提交
3178
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
3179 3180 3181 3182 3183
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
    }

    ret = 0;

3184
 cleanup:
3185 3186 3187
    VIR_FREE(archstr);
    return ret;
}
3188

3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212 3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 3226
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;
3227
    qemuCaps->package = package;
3228 3229 3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242
    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);

3243 3244 3245 3246 3247 3248
    /* -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);

3249 3250 3251 3252 3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267
    if (qemuCaps->version >= 1006000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE_VIDEO_PRIMARY);

    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;
3268 3269
    if (virQEMUCapsProbeQMPMigrationCapabilities(qemuCaps, mon) < 0)
        goto cleanup;
3270 3271

    ret = 0;
3272
 cleanup:
3273 3274 3275
    return ret;
}

3276
static int
3277 3278 3279
virQEMUCapsInitQMP(virQEMUCapsPtr qemuCaps,
                   const char *libDir,
                   uid_t runUid,
3280 3281
                   gid_t runGid,
                   char **qmperr)
3282 3283 3284 3285 3286 3287 3288 3289
{
    int ret = -1;
    virCommandPtr cmd = NULL;
    qemuMonitorPtr mon = NULL;
    int status = 0;
    virDomainChrSourceDef config;
    char *monarg = NULL;
    char *monpath = NULL;
3290
    char *pidfile = NULL;
3291
    pid_t pid = 0;
3292 3293
    virDomainObjPtr vm = NULL;
    virDomainXMLOptionPtr xmlopt = NULL;
3294

3295 3296 3297
    /* the ".sock" sufix is important to avoid a possible clash with a qemu
     * domain called "capabilities"
     */
3298
    if (virAsprintf(&monpath, "%s/%s", libDir, "capabilities.monitor.sock") < 0)
3299
        goto cleanup;
3300
    if (virAsprintf(&monarg, "unix:%s,server,nowait", monpath) < 0)
3301 3302
        goto cleanup;

3303 3304
    /* ".pidfile" suffix is used rather than ".pid" to avoid a possible clash
     * with a qemu domain called "capabilities"
3305 3306 3307
     * 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
3308
     */
3309
    if (virAsprintf(&pidfile, "%s/%s", libDir, "capabilities.pidfile") < 0)
3310 3311
        goto cleanup;

3312 3313 3314 3315 3316
    memset(&config, 0, sizeof(config));
    config.type = VIR_DOMAIN_CHR_TYPE_UNIX;
    config.data.nix.path = monpath;
    config.data.nix.listen = false;

3317 3318
    virPidFileForceCleanupPath(pidfile);

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

3321 3322 3323 3324 3325 3326 3327
    /*
     * 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.
     */
3328
    cmd = virCommandNewArgList(qemuCaps->binary,
3329 3330 3331 3332 3333 3334
                               "-S",
                               "-no-user-config",
                               "-nodefaults",
                               "-nographic",
                               "-M", "none",
                               "-qmp", monarg,
3335 3336
                               "-pidfile", pidfile,
                               "-daemonize",
3337 3338 3339
                               NULL);
    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
3340 3341
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
3342

3343 3344
    virCommandSetErrorBuffer(cmd, qmperr);

3345
    /* Log, but otherwise ignore, non-zero status.  */
3346 3347 3348 3349 3350
    if (virCommandRun(cmd, &status) < 0)
        goto cleanup;

    if (status != 0) {
        ret = 0;
3351 3352
        VIR_DEBUG("QEMU %s exited with status %d: %s",
                  qemuCaps->binary, status, *qmperr);
3353 3354 3355
        goto cleanup;
    }

3356 3357 3358 3359 3360 3361
    if (virPidFileReadPath(pidfile, &pid) < 0) {
        VIR_DEBUG("Failed to read pidfile %s", pidfile);
        ret = 0;
        goto cleanup;
    }

3362 3363 3364 3365 3366
    if (!(xmlopt = virDomainXMLOptionNew(NULL, NULL, NULL)) ||
        !(vm = virDomainObjNew(xmlopt)))
        goto cleanup;

    vm->pid = pid;
3367

3368
    if (!(mon = qemuMonitorOpen(vm, &config, true, &callbacks, NULL))) {
3369
        ret = 0;
3370
        goto cleanup;
3371
    }
3372

3373
    virObjectLock(mon);
3374

3375
    if (virQEMUCapsInitQMPMonitor(qemuCaps, mon) < 0)
3376
        goto cleanup;
3377 3378 3379

    ret = 0;

3380
 cleanup:
3381
    if (mon)
3382
        virObjectUnlock(mon);
3383 3384
    qemuMonitorClose(mon);
    virCommandAbort(cmd);
3385
    virCommandFree(cmd);
3386
    VIR_FREE(monarg);
3387 3388
    if (monpath)
        ignore_value(unlink(monpath));
3389
    VIR_FREE(monpath);
3390 3391
    virObjectUnref(vm);
    virObjectUnref(xmlopt);
3392

3393
    if (pid != 0) {
3394 3395
        char ebuf[1024];

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

        VIR_FREE(*qmperr);
3403 3404
    }
    if (pidfile) {
3405 3406 3407
        unlink(pidfile);
        VIR_FREE(pidfile);
    }
3408 3409 3410 3411
    return ret;
}


3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423
#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();

3424
    virLogMessage(&virLogSelf,
3425 3426 3427 3428 3429 3430 3431 3432 3433
                  VIR_LOG_WARN,
                  __FILE__, __LINE__, __func__,
                  meta,
                  _("Failed to probe capabilities for %s: %s"),
                  binary, err && err->message ? err->message :
                  _("unknown failure"));
}


3434 3435
virQEMUCapsPtr virQEMUCapsNewForBinary(const char *binary,
                                       const char *libDir,
3436
                                       const char *cacheDir,
3437 3438
                                       uid_t runUid,
                                       gid_t runGid)
3439
{
3440
    virQEMUCapsPtr qemuCaps;
3441 3442
    struct stat sb;
    int rv;
3443
    char *qmperr = NULL;
3444

3445 3446 3447
    if (!(qemuCaps = virQEMUCapsNew()))
        goto error;

3448 3449
    if (VIR_STRDUP(qemuCaps->binary, binary) < 0)
        goto error;
3450 3451 3452 3453 3454 3455 3456 3457

    /* 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;
    }
3458
    qemuCaps->ctime = sb.st_ctime;
3459 3460 3461 3462 3463 3464 3465 3466 3467 3468 3469

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

3470
    if ((rv = virQEMUCapsInitCached(qemuCaps, cacheDir)) < 0)
3471 3472
        goto error;

3473
    if (rv == 0) {
3474
        if (virQEMUCapsInitQMP(qemuCaps, libDir, runUid, runGid, &qmperr) < 0) {
3475 3476 3477 3478 3479
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (!qemuCaps->usedQMP &&
3480
            virQEMUCapsInitHelp(qemuCaps, runUid, runGid, qmperr) < 0) {
3481 3482 3483 3484 3485 3486
            virQEMUCapsLogProbeFailure(binary);
            goto error;
        }

        if (virQEMUCapsRememberCached(qemuCaps, cacheDir) < 0)
            goto error;
3487
    }
3488

3489
    VIR_FREE(qmperr);
3490
    return qemuCaps;
3491

3492
 error:
3493
    VIR_FREE(qmperr);
3494 3495
    virObjectUnref(qemuCaps);
    qemuCaps = NULL;
3496
    return NULL;
3497 3498 3499
}


3500
bool virQEMUCapsIsValid(virQEMUCapsPtr qemuCaps)
3501 3502 3503
{
    struct stat sb;

3504
    if (!qemuCaps->binary)
3505 3506
        return true;

3507
    if (stat(qemuCaps->binary, &sb) < 0)
3508 3509
        return false;

3510
    return sb.st_ctime == qemuCaps->ctime;
3511
}
3512 3513


3514 3515
virQEMUCapsCachePtr
virQEMUCapsCacheNew(const char *libDir,
3516
                    const char *cacheDir,
3517 3518
                    uid_t runUid,
                    gid_t runGid)
3519
{
3520
    virQEMUCapsCachePtr cache;
3521

3522
    if (VIR_ALLOC(cache) < 0)
3523 3524 3525 3526 3527 3528 3529 3530 3531
        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 已提交
3532
    if (!(cache->binaries = virHashCreate(10, virObjectFreeHashData)))
3533
        goto error;
3534
    if (VIR_STRDUP(cache->libDir, libDir) < 0)
3535
        goto error;
3536 3537
    if (VIR_STRDUP(cache->cacheDir, cacheDir) < 0)
        goto error;
3538

3539 3540 3541
    cache->runUid = runUid;
    cache->runGid = runGid;

3542 3543
    return cache;

3544
 error:
3545
    virQEMUCapsCacheFree(cache);
3546 3547 3548 3549
    return NULL;
}


3550 3551
virQEMUCapsPtr
virQEMUCapsCacheLookup(virQEMUCapsCachePtr cache, const char *binary)
3552
{
3553
    virQEMUCapsPtr ret = NULL;
3554 3555 3556
    virMutexLock(&cache->lock);
    ret = virHashLookup(cache->binaries, binary);
    if (ret &&
3557
        !virQEMUCapsIsValid(ret)) {
3558 3559 3560 3561 3562 3563 3564 3565
        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);
3566
        ret = virQEMUCapsNewForBinary(binary, cache->libDir,
3567
                                      cache->cacheDir,
3568
                                      cache->runUid, cache->runGid);
3569 3570 3571 3572 3573 3574 3575 3576 3577 3578 3579 3580 3581 3582 3583 3584
        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;
}


3585 3586
virQEMUCapsPtr
virQEMUCapsCacheLookupCopy(virQEMUCapsCachePtr cache, const char *binary)
3587
{
3588 3589
    virQEMUCapsPtr qemuCaps = virQEMUCapsCacheLookup(cache, binary);
    virQEMUCapsPtr ret;
3590

3591
    if (!qemuCaps)
3592 3593
        return NULL;

3594 3595
    ret = virQEMUCapsNewCopy(qemuCaps);
    virObjectUnref(qemuCaps);
3596 3597 3598 3599
    return ret;
}


3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614 3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628
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;
    struct virQEMUCapsSearchData data = { .arch = arch };

    virMutexLock(&cache->lock);
    ret = virHashSearch(cache->binaries, virQEMUCapsCompareArch, &data);
    VIR_DEBUG("Returning caps %p for arch %s", ret, virArchToString(arch));
    virObjectRef(ret);
    virMutexUnlock(&cache->lock);

    return ret;
}


3629
void
3630
virQEMUCapsCacheFree(virQEMUCapsCachePtr cache)
3631 3632 3633 3634
{
    if (!cache)
        return;

3635
    VIR_FREE(cache->libDir);
3636
    VIR_FREE(cache->cacheDir);
3637 3638 3639 3640
    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}
3641 3642

bool
3643
virQEMUCapsUsedQMP(virQEMUCapsPtr qemuCaps)
3644
{
3645
    return qemuCaps->usedQMP;
3646
}
3647 3648 3649 3650

bool
virQEMUCapsSupportsChardev(virDomainDefPtr def,
                           virQEMUCapsPtr qemuCaps,
3651
                           virDomainChrDefPtr chr)
3652 3653 3654 3655 3656
{
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV) ||
        !virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE))
        return false;

3657
    if ((def->os.arch == VIR_ARCH_PPC) || ARCH_IS_PPC64(def->os.arch)) {
3658 3659 3660 3661 3662
        /* 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);
    }

3663
    if ((def->os.arch != VIR_ARCH_ARMV7L) && (def->os.arch != VIR_ARCH_AARCH64))
3664
        return true;
3665

3666 3667 3668 3669 3670 3671
    /* 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));
3672
}
3673 3674 3675 3676 3677 3678 3679 3680 3681 3682 3683 3684 3685 3686


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;
}
3687 3688 3689 3690 3691 3692 3693 3694 3695


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


3698
static int
3699
virQEMUCapsFillDomainLoaderCaps(virQEMUCapsPtr qemuCaps,
3700 3701 3702
                                virDomainCapsLoaderPtr capsLoader,
                                char **loader,
                                size_t nloader)
3703
{
3704 3705
    size_t i;

3706
    capsLoader->device.supported = true;
3707

3708
    if (VIR_ALLOC_N(capsLoader->values.values, nloader) < 0)
3709 3710
        return -1;

3711 3712
    for (i = 0; i < nloader; i++) {
        const char *filename = loader[i];
3713 3714 3715 3716 3717 3718

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

3719
        if (VIR_STRDUP(capsLoader->values.values[capsLoader->values.nvalues],
3720 3721
                       filename) < 0)
            return -1;
3722
        capsLoader->values.nvalues++;
3723 3724
    }

3725
    VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
3726 3727
                             VIR_DOMAIN_LOADER_TYPE_ROM);

M
Michal Privoznik 已提交
3728
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE) &&
3729
        virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT))
3730
        VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->type,
3731 3732 3733 3734
                                 VIR_DOMAIN_LOADER_TYPE_PFLASH);


    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DRIVE_READONLY))
3735
        VIR_DOMAIN_CAPS_ENUM_SET(capsLoader->readonly,
3736 3737
                                 VIR_TRISTATE_BOOL_YES,
                                 VIR_TRISTATE_BOOL_NO);
3738
    return 0;
3739 3740 3741
}


3742
static int
3743 3744
virQEMUCapsFillDomainOSCaps(virQEMUCapsPtr qemuCaps,
                            virDomainCapsOSPtr os,
3745 3746
                            char **loader,
                            size_t nloader)
3747
{
3748
    virDomainCapsLoaderPtr capsLoader = &os->loader;
3749 3750

    os->device.supported = true;
M
Michal Privoznik 已提交
3751
    if (virQEMUCapsFillDomainLoaderCaps(qemuCaps, capsLoader,
3752
                                        loader, nloader) < 0)
3753 3754
        return -1;
    return 0;
3755 3756 3757
}


3758
static int
3759 3760 3761 3762 3763 3764 3765 3766 3767 3768 3769 3770 3771 3772 3773 3774 3775 3776 3777 3778 3779 3780
virQEMUCapsFillDomainDeviceDiskCaps(virQEMUCapsPtr qemuCaps,
                                    virDomainCapsDeviceDiskPtr disk)
{
    disk->device.supported = true;
    /* QEMU supports all of these */
    VIR_DOMAIN_CAPS_ENUM_SET(disk->diskDevice,
                             VIR_DOMAIN_DISK_DEVICE_DISK,
                             VIR_DOMAIN_DISK_DEVICE_CDROM,
                             VIR_DOMAIN_DISK_DEVICE_FLOPPY);

    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_FDC,
                             VIR_DOMAIN_DISK_BUS_SCSI,
                             VIR_DOMAIN_DISK_BUS_VIRTIO,
                             /* VIR_DOMAIN_DISK_BUS_SD */);

    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_USB_STORAGE))
        VIR_DOMAIN_CAPS_ENUM_SET(disk->bus, VIR_DOMAIN_DISK_BUS_USB);
3781
    return 0;
3782 3783 3784
}


3785
static int
3786 3787 3788 3789 3790 3791 3792 3793 3794 3795 3796 3797 3798 3799 3800 3801 3802 3803 3804 3805 3806 3807 3808 3809 3810 3811 3812 3813 3814 3815 3816 3817 3818 3819 3820 3821 3822 3823 3824 3825 3826 3827 3828 3829
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);
    }
3830
    return 0;
3831 3832 3833
}


3834
int
3835
virQEMUCapsFillDomainCaps(virDomainCapsPtr domCaps,
3836
                          virQEMUCapsPtr qemuCaps,
3837 3838
                          char **loader,
                          size_t nloader)
3839
{
3840
    virDomainCapsOSPtr os = &domCaps->os;
3841 3842 3843 3844 3845 3846
    virDomainCapsDeviceDiskPtr disk = &domCaps->disk;
    virDomainCapsDeviceHostdevPtr hostdev = &domCaps->hostdev;
    int maxvcpus = virQEMUCapsGetMachineMaxCpus(qemuCaps, domCaps->machine);

    domCaps->maxvcpus = maxvcpus;

M
Michal Privoznik 已提交
3847
    if (virQEMUCapsFillDomainOSCaps(qemuCaps, os,
3848
                                    loader, nloader) < 0 ||
3849 3850 3851 3852
        virQEMUCapsFillDomainDeviceDiskCaps(qemuCaps, disk) < 0 ||
        virQEMUCapsFillDomainDeviceHostdevCaps(qemuCaps, hostdev) < 0)
        return -1;
    return 0;
3853
}