qemu_capabilities.c 79.1 KB
Newer Older
1 2 3
/*
 * qemu_capabilities.c: QEMU capabilities generation
 *
4
 * Copyright (C) 2006-2013 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 "virlog.h"
29
#include "virerror.h"
30
#include "virutil.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 "qemu_monitor.h"
41
#include "virstring.h"
42

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

#define VIR_FROM_THIS VIR_FROM_QEMU

51 52 53 54
/* While not public, these strings must not change. They
 * are used in domain status files which are read on
 * daemon restarts
 */
55
VIR_ENUM_IMPL(virQEMUCaps, QEMU_CAPS_LAST,
56 57 58 59 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
              "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 */
93
              "vhost-net",
94 95 96 97 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
              "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",
127 128

              "pci-multifunction", /* 60 */
129
              "virtio-blk-pci.ioeventfd",
M
Michal Privoznik 已提交
130
              "sga",
131 132
              "virtio-blk-pci.event_idx",
              "virtio-net-pci.event_idx",
133 134 135 136 137 138 139 140 141 142

              "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 已提交
143
              "usb-hub",
144
              "no-shutdown",
145 146

              "cache-unsafe", /* 75 */
147
              "rombar",
J
Jim Fehlig 已提交
148
              "ich9-ahci",
149
              "no-acpi",
150
              "fsdev-readonly",
151

152
              "virtio-blk-pci.scsi", /* 80 */
153
              "blk-sg-io",
O
Osier Yang 已提交
154
              "drive-copy-on-read",
155
              "cpu-host",
156
              "fsdev-writeout",
157 158

              "drive-iotune", /* 85 */
159
              "system_wakeup",
160
              "scsi-disk.channel",
161
              "scsi-block",
162
              "transaction",
163 164 165

              "block-job-sync", /* 90 */
              "block-job-async",
166
              "scsi-cd",
167
              "ide-cd",
168
              "no-user-config",
M
Marc-André Lureau 已提交
169 170

              "hda-micro", /* 95 */
171
              "dump-guest-memory",
G
Gerd Hoffmann 已提交
172
              "nec-usb-xhci",
173
              "virtio-s390",
174
              "balloon-event",
M
Marc-André Lureau 已提交
175

R
Richa Marwaha 已提交
176
              "bridge", /* 100 */
177 178
              "lsi",
              "virtio-scsi-pci",
V
Viktor Mihajlovski 已提交
179
              "blockio",
180
              "disable-s3",
R
Richa Marwaha 已提交
181

182
              "disable-s4", /* 105 */
183
              "usb-redir.filter",
184 185
              "ide-drive.wwn",
              "scsi-disk.wwn",
186
              "seccomp-sandbox",
187 188

              "reboot-timeout", /* 110 */
189
              "dump-guest-core",
190
              "seamless-migration",
191
              "block-commit",
192
              "vnc",
193 194

              "drive-mirror", /* 115 */
195 196
              "usb-redir.bootindex",
              "usb-host.bootindex",
197
              "blockdev-snapshot-sync",
198 199 200 201 202 203
              "qxl",

              "VGA", /* 120 */
              "cirrus-vga",
              "vmware-svga",
              "device-video-primary",
204
              "s390-sclp",
205 206

              "usb-serial", /* 125 */
G
Guannan Ren 已提交
207
              "usb-net",
208
              "add-fd",
209
              "nbd-server",
210 211 212
              "virtio-rng",

              "rng-random", /* 130 */
213
              "rng-egd",
O
Olivia Yin 已提交
214 215
              "virtio-ccw",
              "dtb",
216
              "megasas",
J
Ján Tomko 已提交
217 218

              "ipv6-migration", /* 135 */
219
              "machine-opt",
L
Li Zhang 已提交
220
              "machine-usb-opt",
S
Stefan Berger 已提交
221 222
              "tpm-passthrough",
              "tpm-tis",
223 224
    );

225
struct _virQEMUCaps {
226 227
    virObject object;

228 229
    bool usedQMP;

230 231 232
    char *binary;
    time_t mtime;

233
    virBitmapPtr flags;
234 235 236 237

    unsigned int version;
    unsigned int kvmVersion;

238
    virArch arch;
239 240 241 242 243 244 245

    size_t ncpuDefinitions;
    char **cpuDefinitions;

    size_t nmachineTypes;
    char **machineTypes;
    char **machineAliases;
246 247
};

248
struct _virQEMUCapsCache {
249 250
    virMutex lock;
    virHashTablePtr binaries;
251
    char *libDir;
252
    char *runDir;
253 254
    uid_t runUid;
    gid_t runGid;
255 256
};

257

258 259
static virClassPtr virQEMUCapsClass;
static void virQEMUCapsDispose(void *obj);
260

261
static int virQEMUCapsOnceInit(void)
262
{
263 264 265 266
    if (!(virQEMUCapsClass = virClassNew(virClassForObject(),
                                         "virQEMUCaps",
                                         sizeof(virQEMUCaps),
                                         virQEMUCapsDispose)))
267 268 269 270 271
        return -1;

    return 0;
}

272
VIR_ONCE_GLOBAL_INIT(virQEMUCaps)
273

274
static virArch virQEMUCapsArchFromString(const char *arch)
275 276 277 278 279 280 281 282 283 284
{
    if (STREQ(arch, "i386"))
        return VIR_ARCH_I686;
    if (STREQ(arch, "arm"))
        return VIR_ARCH_ARMV7L;

    return virArchFromString(arch);
}


285
static const char *virQEMUCapsArchToString(virArch arch)
286 287 288 289 290 291 292 293 294 295
{
    if (arch == VIR_ARCH_I686)
        return "i386";
    else if (arch == VIR_ARCH_ARMV7L)
        return "arm";

    return virArchToString(arch);
}


296
static virCommandPtr
297 298
virQEMUCapsProbeCommand(const char *qemu,
                        virQEMUCapsPtr qemuCaps,
299
                        uid_t runUid, gid_t runGid)
300 301 302
{
    virCommandPtr cmd = virCommandNew(qemu);

303 304
    if (qemuCaps) {
        if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG))
305
            virCommandAddArg(cmd, "-no-user-config");
306
        else if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_NODEFCONFIG))
307 308 309 310 311
            virCommandAddArg(cmd, "-nodefconfig");
    }

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
312 313
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
314 315 316 317 318

    return cmd;
}


319
static void
320 321
virQEMUCapsSetDefaultMachine(virQEMUCapsPtr qemuCaps,
                             size_t defIdx)
322
{
323 324 325 326 327 328 329 330 331 332 333
    char *name = qemuCaps->machineTypes[defIdx];
    char *alias = qemuCaps->machineAliases[defIdx];

    memmove(qemuCaps->machineTypes + 1,
            qemuCaps->machineTypes,
            sizeof(qemuCaps->machineTypes[0]) * defIdx);
    memmove(qemuCaps->machineAliases + 1,
            qemuCaps->machineAliases,
            sizeof(qemuCaps->machineAliases[0]) * defIdx);
    qemuCaps->machineTypes[0] = name;
    qemuCaps->machineAliases[0] = alias;
334 335
}

336 337 338 339
/* Format is:
 * <machine> <desc> [(default)|(alias of <canonical>)]
 */
static int
340 341
virQEMUCapsParseMachineTypesStr(const char *output,
                                virQEMUCapsPtr qemuCaps)
342 343 344
{
    const char *p = output;
    const char *next;
345
    size_t defIdx = 0;
346 347 348

    do {
        const char *t;
349 350
        char *name;
        char *canonical = NULL;
351 352 353 354 355 356 357 358 359 360

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

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

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

361
        if (!(name = strndup(p, t - p)))
362 363 364
            goto no_memory;

        p = t;
365
        if ((t = strstr(p, "(default)")) && (!next || t < next))
366
            defIdx = qemuCaps->nmachineTypes;
367 368 369 370 371 372

        if ((t = strstr(p, "(alias of ")) && (!next || t < next)) {
            p = t + strlen("(alias of ");
            if (!(t = strchr(p, ')')) || (next && t >= next))
                continue;

373 374
            if (!(canonical = strndup(p, t - p))) {
                VIR_FREE(name);
375
                goto no_memory;
376 377 378
            }
        }

379 380
        if (VIR_REALLOC_N(qemuCaps->machineTypes, qemuCaps->nmachineTypes + 1) < 0 ||
            VIR_REALLOC_N(qemuCaps->machineAliases, qemuCaps->nmachineTypes + 1) < 0) {
381 382 383 384
            VIR_FREE(name);
            VIR_FREE(canonical);
            goto no_memory;
        }
385
        qemuCaps->nmachineTypes++;
386
        if (canonical) {
387 388
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = canonical;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = name;
389
        } else {
390 391
            qemuCaps->machineTypes[qemuCaps->nmachineTypes-1] = name;
            qemuCaps->machineAliases[qemuCaps->nmachineTypes-1] = NULL;
392 393 394
        }
    } while ((p = next));

395

396
    if (defIdx)
397
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
398 399 400

    return 0;

401
no_memory:
402 403 404 405
    virReportOOMError();
    return -1;
}

406
static int
407 408
virQEMUCapsProbeMachineTypes(virQEMUCapsPtr qemuCaps,
                             uid_t runUid, gid_t runGid)
409 410
{
    char *output;
411 412
    int ret = -1;
    virCommandPtr cmd;
413
    int status;
414

415 416 417 418
    /* 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.
     */
419
    if (!virFileIsExecutable(qemuCaps->binary)) {
420
        virReportSystemError(errno, _("Cannot find QEMU binary %s"),
421
                             qemuCaps->binary);
422 423 424
        return -1;
    }

425
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
426
    virCommandAddArgList(cmd, "-M", "?", NULL);
427
    virCommandSetOutputBuffer(cmd, &output);
428

429 430
    /* Ignore failure from older qemu that did not understand '-M ?'.  */
    if (virCommandRun(cmd, &status) < 0)
431 432
        goto cleanup;

433
    if (virQEMUCapsParseMachineTypesStr(output, qemuCaps) < 0)
434
        goto cleanup;
435 436 437 438

    ret = 0;

cleanup:
439 440
    VIR_FREE(output);
    virCommandFree(cmd);
441 442 443 444 445 446

    return ret;
}


typedef int
447 448
(*virQEMUCapsParseCPUModels)(const char *output,
                             virQEMUCapsPtr qemuCaps);
449 450 451 452 453 454 455

/* Format:
 *      <arch> <model>
 * qemu-0.13 encloses some model names in []:
 *      <arch> [<model>]
 */
static int
456 457
virQEMUCapsParseX86Models(const char *output,
                          virQEMUCapsPtr qemuCaps)
458 459 460
{
    const char *p = output;
    const char *next;
461
    int ret = -1;
462 463 464

    do {
        const char *t;
465
        size_t len;
466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482

        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;

483
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
484 485 486
            virReportOOMError();
            goto cleanup;
        }
487

488 489 490 491
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
492

493 494 495 496
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
497

498
        if (!(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1] = strndup(p, len))) {
499 500
            virReportOOMError();
            goto cleanup;
501 502 503
        }
    } while ((p = next));

504
    ret = 0;
505

506 507
cleanup:
    return ret;
508 509
}

P
Prerna Saxena 已提交
510 511 512 513
/* ppc64 parser.
 * Format : PowerPC <machine> <description>
 */
static int
514 515
virQEMUCapsParsePPCModels(const char *output,
                          virQEMUCapsPtr qemuCaps)
P
Prerna Saxena 已提交
516 517 518
{
    const char *p = output;
    const char *next;
519
    int ret = -1;
P
Prerna Saxena 已提交
520 521 522

    do {
        const char *t;
523
        size_t len;
P
Prerna Saxena 已提交
524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543

        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;

544
        if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
545 546 547
            virReportOOMError();
            goto cleanup;
        }
P
Prerna Saxena 已提交
548

549
        len = t - p - 1;
P
Prerna Saxena 已提交
550

551
        if (!(qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions - 1] = strndup(p, len))) {
552 553
            virReportOOMError();
            goto cleanup;
P
Prerna Saxena 已提交
554 555 556
        }
    } while ((p = next));

557
    ret = 0;
P
Prerna Saxena 已提交
558

559 560
cleanup:
    return ret;
P
Prerna Saxena 已提交
561
}
562

563
static int
564
virQEMUCapsProbeCPUModels(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid)
565 566 567
{
    char *output = NULL;
    int ret = -1;
568
    virQEMUCapsParseCPUModels parse;
569
    virCommandPtr cmd;
570

571 572 573 574 575
    if (qemuCaps->arch == VIR_ARCH_I686 ||
        qemuCaps->arch == VIR_ARCH_X86_64)
        parse = virQEMUCapsParseX86Models;
    else if (qemuCaps->arch == VIR_ARCH_PPC64)
        parse = virQEMUCapsParsePPCModels;
576
    else {
577
        VIR_DEBUG("don't know how to parse %s CPU models",
578
                  virArchToString(qemuCaps->arch));
579 580 581
        return 0;
    }

582
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, qemuCaps, runUid, runGid);
583
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
584
    virCommandSetOutputBuffer(cmd, &output);
585

586
    if (virCommandRun(cmd, NULL) < 0)
587 588
        goto cleanup;

589
    if (parse(output, qemuCaps) < 0)
590 591 592 593 594 595
        goto cleanup;

    ret = 0;

cleanup:
    VIR_FREE(output);
596
    virCommandFree(cmd);
597 598 599 600 601

    return ret;
}


602
static char *
603 604
virQEMUCapsFindBinaryForArch(virArch hostarch,
                             virArch guestarch)
605 606
{
    char *ret;
607
    const char *archstr = virQEMUCapsArchToString(guestarch);
608
    char *binary;
609

610 611 612 613 614 615 616 617 618 619 620 621 622 623
    if (virAsprintf(&binary, "qemu-system-%s", archstr) < 0) {
        virReportOOMError();
        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");
624 625
        if (ret && !virFileIsExecutable(ret))
            VIR_FREE(ret);
626
    }
627

628 629 630 631 632
    if (guestarch == VIR_ARCH_I686 &&
        !ret) {
        ret = virFindFileInPath("qemu");
        if (ret && !virFileIsExecutable(ret))
            VIR_FREE(ret);
633
    }
634

635 636 637 638 639
    return ret;
}


static bool
640 641
virQEMUCapsIsValidForKVM(virArch hostarch,
                         virArch guestarch)
642
{
643
    if (hostarch == guestarch)
644
        return true;
645 646
    if (hostarch == VIR_ARCH_X86_64 &&
        guestarch == VIR_ARCH_I686)
647 648 649 650
        return true;
    return false;
}

651
static int
652 653 654 655
virQEMUCapsInitGuest(virCapsPtr caps,
                     virQEMUCapsCachePtr cache,
                     virArch hostarch,
                     virArch guestarch)
656 657 658 659 660 661 662 663
{
    virCapsGuestPtr guest;
    int i;
    int haskvm = 0;
    int haskqemu = 0;
    char *kvmbin = NULL;
    char *binary = NULL;
    virCapsGuestMachinePtr *machines = NULL;
664
    size_t nmachines = 0;
665 666
    virQEMUCapsPtr qemubinCaps = NULL;
    virQEMUCapsPtr kvmbinCaps = NULL;
667 668
    int ret = -1;

J
Ján Tomko 已提交
669
    /* Check for existence of base emulator, or alternate base
670 671
     * which can be used with magic cpu choice
     */
672
    binary = virQEMUCapsFindBinaryForArch(hostarch, guestarch);
673

674
    /* Ignore binary if extracting version info fails */
675
    if (binary) {
676
        if (!(qemubinCaps = virQEMUCapsCacheLookup(cache, binary))) {
677 678 679 680
            virResetLastError();
            VIR_FREE(binary);
        }
    }
681 682

    /* qemu-kvm/kvm binaries can only be used if
683 684 685 686 687
     *  - host & guest arches match
     * Or
     *  - hostarch is x86_64 and guest arch is i686
     * The latter simply needs "-cpu qemu32"
     */
688
    if (virQEMUCapsIsValidForKVM(hostarch, guestarch)) {
689 690 691
        const char *const kvmbins[] = { "/usr/libexec/qemu-kvm", /* RHEL */
                                        "qemu-kvm", /* Fedora */
                                        "kvm" }; /* Upstream .spec */
692

693 694
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
            kvmbin = virFindFileInPath(kvmbins[i]);
695

696 697
            if (!kvmbin)
                continue;
698

699
            if (!(kvmbinCaps = virQEMUCapsCacheLookup(cache, kvmbin))) {
700
                virResetLastError();
701 702 703
                VIR_FREE(kvmbin);
                continue;
            }
704

705 706
            if (!binary) {
                binary = kvmbin;
707
                qemubinCaps = kvmbinCaps;
708
                kvmbin = NULL;
709
                kvmbinCaps = NULL;
710
            }
711
            break;
712 713 714 715 716 717
        }
    }

    if (!binary)
        return 0;

718
    if (access("/dev/kvm", F_OK) == 0 &&
719 720
        (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         virQEMUCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
721 722 723 724
         kvmbin))
        haskvm = 1;

    if (access("/dev/kqemu", F_OK) == 0 &&
725
        virQEMUCapsGet(qemubinCaps, QEMU_CAPS_KQEMU))
726
        haskqemu = 1;
J
Jiri Denemark 已提交
727

728
    if (virQEMUCapsGetMachineTypesCaps(qemubinCaps, &nmachines, &machines) < 0)
D
Daniel P. Berrange 已提交
729
        goto error;
730 731 732 733

    /* 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 已提交
734
                                         "hvm",
735
                                         guestarch,
736 737 738 739 740 741 742 743 744 745
                                         binary,
                                         NULL,
                                         nmachines,
                                         machines)) == NULL)
        goto error;

    machines = NULL;
    nmachines = 0;

    if (caps->host.cpu &&
J
Jiri Denemark 已提交
746
        caps->host.cpu->model &&
747
        virQEMUCapsGetCPUDefinitions(qemubinCaps, NULL) > 0 &&
748 749 750
        !virCapabilitiesAddGuestFeature(guest, "cpuselection", 1, 0))
        goto error;

751
    if (virQEMUCapsGet(qemubinCaps, QEMU_CAPS_BOOTINDEX) &&
J
Jiri Denemark 已提交
752
        !virCapabilitiesAddGuestFeature(guest, "deviceboot", 1, 0))
753 754
        goto error;

D
Daniel P. Berrange 已提交
755 756 757 758 759 760 761
    if (virCapabilitiesAddGuestDomain(guest,
                                      "qemu",
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
        goto error;
762

D
Daniel P. Berrange 已提交
763 764 765 766 767 768 769 770
    if (haskqemu &&
        virCapabilitiesAddGuestDomain(guest,
                                      "kqemu",
                                      NULL,
                                      NULL,
                                      0,
                                      NULL) == NULL)
        goto error;
771

D
Daniel P. Berrange 已提交
772 773
    if (haskvm) {
        virCapsGuestDomainPtr dom;
774

D
Daniel P. Berrange 已提交
775
        if (kvmbin &&
776
            virQEMUCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
D
Daniel P. Berrange 已提交
777
            goto error;
778

D
Daniel P. Berrange 已提交
779 780 781 782 783 784 785 786
        if ((dom = virCapabilitiesAddGuestDomain(guest,
                                                 "kvm",
                                                 kvmbin ? kvmbin : binary,
                                                 NULL,
                                                 nmachines,
                                                 machines)) == NULL) {
            goto error;
        }
787

D
Daniel P. Berrange 已提交
788 789
        machines = NULL;
        nmachines = 0;
790 791 792

    }

793 794
    if (((guestarch == VIR_ARCH_I686) ||
         (guestarch == VIR_ARCH_X86_64)) &&
795 796 797 798
        (virCapabilitiesAddGuestFeature(guest, "acpi", 1, 1) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "apic", 1, 0) == NULL))
        goto error;

799
    if ((guestarch == VIR_ARCH_I686) &&
800 801 802
        (virCapabilitiesAddGuestFeature(guest, "pae", 1, 0) == NULL ||
         virCapabilitiesAddGuestFeature(guest, "nonpae", 1, 0) == NULL))
        goto error;
803 804 805 806

    ret = 0;

cleanup:
807 808
    VIR_FREE(binary);
    VIR_FREE(kvmbin);
809 810
    virObjectUnref(qemubinCaps);
    virObjectUnref(kvmbinCaps);
811 812 813 814 815 816 817 818 819 820 821

    return ret;

error:
    virCapabilitiesFreeMachines(machines, nmachines);

    goto cleanup;
}


static int
822 823
virQEMUCapsInitCPU(virCapsPtr caps,
                   virArch arch)
824 825 826 827 828 829
{
    virCPUDefPtr cpu = NULL;
    union cpuData *data = NULL;
    virNodeInfo nodeinfo;
    int ret = -1;

830
    if (VIR_ALLOC(cpu) < 0) {
831 832 833 834
        virReportOOMError();
        goto error;
    }

835 836
    cpu->arch = arch;

837 838 839 840 841 842 843
    if (nodeGetInfo(NULL, &nodeinfo))
        goto error;

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

846
    if (!(data = cpuNodeData(arch))
847
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0)
J
Jiri Denemark 已提交
848
        goto cleanup;
849 850 851 852

    ret = 0;

cleanup:
853
    cpuDataFree(arch, data);
854 855 856 857 858 859 860 861 862

    return ret;

error:
    virCPUDefFree(cpu);
    goto cleanup;
}


863
virCapsPtr virQEMUCapsInit(virQEMUCapsCachePtr cache)
864 865 866
{
    virCapsPtr caps;
    int i;
867 868

    if ((caps = virCapabilitiesNew(virArchFromHost(),
869
                                   1, 1)) == NULL)
870
        goto error;
871 872 873 874 875 876 877

    /* 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);
878
        VIR_WARN("Failed to query host NUMA topology, disabling NUMA capabilities");
879 880
    }

881
    if (virQEMUCapsInitCPU(caps, virArchFromHost()) < 0)
882
        VIR_WARN("Failed to get host CPU");
883

884 885
    /* Add the power management features of the host */

886
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
887 888
        VIR_WARN("Failed to get host power management capabilities");

889 890 891
    virCapabilitiesAddHostMigrateTransport(caps,
                                           "tcp");

892 893 894 895 896
    /* 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
     */
    for (i = 0 ; i < VIR_ARCH_LAST ; i++)
897 898 899
        if (virQEMUCapsInitGuest(caps, cache,
                                 virArchFromHost(),
                                 i) < 0)
900
            goto error;
901 902 903

    return caps;

904
error:
905
    virObjectUnref(caps);
906 907 908 909
    return NULL;
}


910
static int
911 912 913 914 915 916
virQEMUCapsComputeCmdFlags(const char *help,
                           unsigned int version,
                           unsigned int is_kvm,
                           unsigned int kvm_version,
                           virQEMUCapsPtr qemuCaps,
                           bool check_yajl ATTRIBUTE_UNUSED)
917 918
{
    const char *p;
R
Richa Marwaha 已提交
919
    const char *fsdev, *netdev;
920 921

    if (strstr(help, "-no-kqemu"))
922
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KQEMU);
923
    if (strstr(help, "-enable-kqemu"))
924
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KQEMU);
925
    if (strstr(help, "-no-kvm"))
926
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
927
    if (strstr(help, "-enable-kvm"))
928
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
929
    if (strstr(help, "-no-reboot"))
930
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_REBOOT);
931
    if (strstr(help, "-name")) {
932
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME);
933
        if (strstr(help, ",process="))
934
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NAME_PROCESS);
935 936
    }
    if (strstr(help, "-uuid"))
937
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_UUID);
938
    if (strstr(help, "-xen-domid"))
939
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_XEN_DOMID);
940
    else if (strstr(help, "-domid"))
941
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DOMID);
942
    if (strstr(help, "-drive")) {
943 944
        const char *cache = strstr(help, "cache=");

945
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE);
946 947
        if (cache && (p = strchr(cache, ']'))) {
            if (memmem(cache, p - cache, "on|off", sizeof("on|off") - 1) == NULL)
948
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_V2);
949
            if (memmem(cache, p - cache, "directsync", sizeof("directsync") - 1))
950
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_DIRECTSYNC);
951
            if (memmem(cache, p - cache, "unsafe", sizeof("unsafe") - 1))
952
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_CACHE_UNSAFE);
953
        }
954
        if (strstr(help, "format="))
955
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_FORMAT);
956
        if (strstr(help, "readonly="))
957
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
958
        if (strstr(help, "aio=threads|native"))
959
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_AIO);
O
Osier Yang 已提交
960
        if (strstr(help, "copy-on-read=on|off"))
961
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_COPY_ON_READ);
962
        if (strstr(help, "bps="))
963
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_IOTUNE);
964 965 966 967
    }
    if ((p = strstr(help, "-vga")) && !strstr(help, "-std-vga")) {
        const char *nl = strstr(p, "\n");

968
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA);
969 970

        if (strstr(p, "|qxl"))
971
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
972
        if ((p = strstr(p, "|none")) && p < nl)
973
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_NONE);
974 975
    }
    if (strstr(help, "-spice"))
976
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
977
    if (strstr(help, "-vnc"))
978
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
979
    if (strstr(help, "seamless-migration="))
980
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
981
    if (strstr(help, "boot=on"))
982
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_BOOT);
983
    if (strstr(help, "serial=s"))
984
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_SERIAL);
985
    if (strstr(help, "-pcidevice"))
986
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCIDEVICE);
987
    if (strstr(help, "-mem-path"))
988
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MEM_PATH);
989
    if (strstr(help, "-chardev")) {
990
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV);
991
        if (strstr(help, "-chardev spicevmc"))
992
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC);
993
    }
994
    if (strstr(help, "-balloon"))
995
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BALLOON);
996
    if (strstr(help, "-device")) {
997
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE);
998 999 1000 1001
        /*
         * When -device was introduced, qemu already supported drive's
         * readonly option but didn't advertise that.
         */
1002
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_READONLY);
1003 1004
    }
    if (strstr(help, "-nodefconfig"))
1005
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NODEFCONFIG);
1006
    if (strstr(help, "-no-user-config"))
1007
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_USER_CONFIG);
1008 1009
    /* The trailing ' ' is important to avoid a bogus match */
    if (strstr(help, "-rtc "))
1010
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC);
1011 1012
    /* to wit */
    if (strstr(help, "-rtc-td-hack"))
1013
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_RTC_TD_HACK);
1014
    if (strstr(help, "-no-hpet"))
1015
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_HPET);
1016
    if (strstr(help, "-no-acpi"))
1017
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
1018
    if (strstr(help, "-no-kvm-pit-reinjection"))
1019
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
1020
    if (strstr(help, "-tdf"))
1021
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_TDF);
1022
    if (strstr(help, "-enable-nesting"))
1023
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NESTING);
1024
    if (strstr(help, ",menu=on"))
1025
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_BOOT_MENU);
1026
    if (strstr(help, ",reboot-timeout=rb_time"))
1027
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_REBOOT_TIMEOUT);
1028
    if ((fsdev = strstr(help, "-fsdev"))) {
1029
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV);
1030
        if (strstr(fsdev, "readonly"))
1031
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_READONLY);
1032
        if (strstr(fsdev, "writeout"))
1033
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_FSDEV_WRITEOUT);
1034
    }
1035
    if (strstr(help, "-smbios type"))
1036
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMBIOS_TYPE);
1037
    if (strstr(help, "-sandbox"))
1038
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SECCOMP_SANDBOX);
1039

R
Richa Marwaha 已提交
1040
    if ((netdev = strstr(help, "-netdev"))) {
1041 1042
        /* Disable -netdev on 0.12 since although it exists,
         * the corresponding netdev_add/remove monitor commands
1043 1044
         * do not, and we need them to be able to do hotplug.
         * But see below about RHEL build. */
R
Richa Marwaha 已提交
1045 1046
        if (version >= 13000) {
            if (strstr(netdev, "bridge"))
1047 1048
                virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV_BRIDGE);
           virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
R
Richa Marwaha 已提交
1049
        }
1050 1051 1052
    }

    if (strstr(help, "-sdl"))
1053
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SDL);
1054 1055 1056
    if (strstr(help, "cores=") &&
        strstr(help, "threads=") &&
        strstr(help, "sockets="))
1057
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_SMP_TOPOLOGY);
1058 1059

    if (version >= 9000)
1060
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC_COLON);
1061 1062

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

1065
    if (strstr(help, ",vhost=")) {
1066
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VHOST_NET);
1067 1068
    }

1069 1070
    /* 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
1071
     * 0.14.* and 0.15.0)
1072
     */
1073
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1074
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_SHUTDOWN);
1075

1076
    if (strstr(help, "dump-guest-core=on|off"))
1077
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
1078

O
Olivia Yin 已提交
1079 1080 1081
    if (strstr(help, "-dtb"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);

1082 1083 1084
    if (strstr(help, "-machine"))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);

L
Li Zhang 已提交
1085 1086 1087 1088
     /* USB option is supported v1.3.0 onwards */
    if (qemuCaps->version >= 1003000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_USB_OPT);

1089 1090 1091 1092
    /*
     * Handling of -incoming arg with varying features
     *  -incoming tcp    (kvm >= 79, qemu >= 0.10.0)
     *  -incoming exec   (kvm >= 80, qemu >= 0.10.0)
1093 1094
     *  -incoming unix   (qemu >= 0.12.0)
     *  -incoming fd     (qemu >= 0.12.0)
1095 1096 1097 1098 1099 1100 1101
     *  -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) {
1102 1103
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1104
        if (version >= 12000) {
1105 1106
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_UNIX);
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_FD);
1107
        }
1108
    } else if (kvm_version >= 79) {
1109
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_TCP);
1110
        if (kvm_version >= 80)
1111
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_QEMU_EXEC);
1112
    } else if (kvm_version > 0) {
1113
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MIGRATE_KVM_STDIO);
1114 1115 1116
    }

    if (version >= 10000)
1117
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_0_10);
1118

1119
    if (version >= 11000)
1120
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
1121

1122 1123 1124
    /* 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
1125 1126 1127 1128 1129
     * 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.
1130
     */
1131
#if WITH_YAJL
1132
    if (version >= 13000) {
1133
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
1134 1135
    } else if (version >= 12000 &&
               strstr(help, "libvirt")) {
1136 1137
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MONITOR_JSON);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1138
    }
1139 1140 1141 1142 1143 1144 1145
#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
1146
     * dependency, so distros won't hit this).  This check is
1147
     * also in m4/virt-yajl.m4 (see $with_yajl).  */
1148 1149 1150
    if (version >= 15000 ||
        (version >= 12000 && strstr(help, "libvirt"))) {
        if (check_yajl) {
1151 1152 1153
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("this qemu binary requires libvirt to be "
                             "compiled with yajl"));
1154 1155
            return -1;
        }
1156
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NETDEV);
1157
    }
E
Eric Blake 已提交
1158
#endif
1159 1160

    if (version >= 13000)
1161
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIFUNCTION);
1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173

    /* 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)
1174
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_ROMBAR);
1175 1176

    if (version >= 11000)
1177
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_CPU_HOST);
1178

J
Ján Tomko 已提交
1179 1180 1181
    if (version >= 1001000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);

1182
    if (version >= 1002000)
1183
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_DEVICE_VIDEO_PRIMARY);
1184
    return 0;
1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210
}

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

1211 1212 1213 1214 1215 1216 1217
int virQEMUCapsParseHelpStr(const char *qemu,
                            const char *help,
                            virQEMUCapsPtr qemuCaps,
                            unsigned int *version,
                            unsigned int *is_kvm,
                            unsigned int *kvm_version,
                            bool check_yajl)
1218 1219 1220
{
    unsigned major, minor, micro;
    const char *p = help;
1221
    char *strflags;
1222

1223
    *version = *is_kvm = *kvm_version = 0;
1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240

    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 已提交
1241
    if (minor == -1)
1242 1243
        goto fail;

J
Jiri Denemark 已提交
1244 1245 1246 1247 1248 1249 1250 1251
    if (*p != '.') {
        micro = 0;
    } else {
        ++p;
        micro = virParseNumber(&p);
        if (micro == -1)
            goto fail;
    }
1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272

    SKIP_BLANKS(p);

    if (STRPREFIX(p, QEMU_KVM_VER_PREFIX)) {
        *is_kvm = 1;
        p += strlen(QEMU_KVM_VER_PREFIX);
    } else if (STRPREFIX(p, KVM_VER_PREFIX)) {
        int ret;

        *is_kvm = 1;
        p += strlen(KVM_VER_PREFIX);

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

        *kvm_version = ret;
    }

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

1273 1274
    if (virQEMUCapsComputeCmdFlags(help, *version, *is_kvm, *kvm_version,
                                   qemuCaps, check_yajl) < 0)
1275
        goto cleanup;
1276

1277
    strflags = virBitmapString(qemuCaps->flags);
1278 1279 1280
    VIR_DEBUG("Version %u.%u.%u, cooked version %u, flags %s",
              major, minor, micro, *version, NULLSTR(strflags));
    VIR_FREE(strflags);
1281 1282 1283 1284 1285 1286 1287 1288 1289 1290

    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;

fail:
    p = strchr(help, '\n');
1291 1292
    if (!p)
        p = strchr(help, '\0');
1293

1294 1295 1296
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("cannot parse %s version number in '%.*s'"),
                   qemu, (int) (p - help), help);
1297

1298
cleanup:
1299 1300 1301
    return -1;
}

1302

1303
struct virQEMUCapsStringFlags {
1304 1305 1306 1307 1308
    const char *value;
    int flag;
};


1309
struct virQEMUCapsStringFlags virQEMUCapsObjectTypes[] = {
1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324
    { "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 },
1325
    { "virtio-blk-ccw", QEMU_CAPS_VIRTIO_CCW },
1326
    { "sclpconsole", QEMU_CAPS_SCLP_S390 },
1327
    { "lsi53c895a", QEMU_CAPS_SCSI_LSI },
1328
    { "virtio-scsi-pci", QEMU_CAPS_VIRTIO_SCSI },
1329 1330
    { "virtio-scsi-s390", QEMU_CAPS_VIRTIO_SCSI },
    { "virtio-scsi-ccw", QEMU_CAPS_VIRTIO_SCSI },
1331
    { "megasas", QEMU_CAPS_SCSI_MEGASAS },
1332 1333
    { "spicevmc", QEMU_CAPS_DEVICE_SPICEVMC },
    { "qxl-vga", QEMU_CAPS_DEVICE_QXL_VGA },
1334
    { "qxl", QEMU_CAPS_DEVICE_QXL },
1335 1336 1337 1338
    { "sga", QEMU_CAPS_SGA },
    { "scsi-block", QEMU_CAPS_SCSI_BLOCK },
    { "scsi-cd", QEMU_CAPS_SCSI_CD },
    { "ide-cd", QEMU_CAPS_IDE_CD },
1339 1340 1341
    { "VGA", QEMU_CAPS_DEVICE_VGA },
    { "cirrus-vga", QEMU_CAPS_DEVICE_CIRRUS_VGA },
    { "vmware-svga", QEMU_CAPS_DEVICE_VMWARE_SVGA },
G
Guannan Ren 已提交
1342
    { "usb-serial", QEMU_CAPS_DEVICE_USB_SERIAL},
G
Guannan Ren 已提交
1343
    { "usb-net", QEMU_CAPS_DEVICE_USB_NET},
1344
    { "virtio-rng-pci", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1345 1346
    { "virtio-rng-s390", QEMU_CAPS_DEVICE_VIRTIO_RNG },
    { "virtio-rng-ccw", QEMU_CAPS_DEVICE_VIRTIO_RNG },
1347
    { "rng-random", QEMU_CAPS_OBJECT_RNG_RANDOM },
1348
    { "rng-egd", QEMU_CAPS_OBJECT_RNG_EGD },
1349 1350
};

1351
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioBlk[] = {
1352 1353 1354 1355 1356 1357 1358 1359
    { "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 },
};

1360
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsVirtioNet[] = {
1361 1362 1363 1364
    { "tx", QEMU_CAPS_VIRTIO_TX_ALG },
    { "event_idx", QEMU_CAPS_VIRTIO_NET_EVENT_IDX },
};

1365
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPciAssign[] = {
1366
    { "rombar", QEMU_CAPS_PCI_ROMBAR },
1367 1368 1369 1370
    { "configfd", QEMU_CAPS_PCI_CONFIGFD },
    { "bootindex", QEMU_CAPS_PCI_BOOTINDEX },
};

1371
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsScsiDisk[] = {
1372 1373 1374 1375
    { "channel", QEMU_CAPS_SCSI_DISK_CHANNEL },
    { "wwn", QEMU_CAPS_SCSI_DISK_WWN },
};

1376
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsIDEDrive[] = {
1377 1378 1379
    { "wwn", QEMU_CAPS_IDE_DRIVE_WWN },
};

1380
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsPixx4PM[] = {
1381 1382 1383 1384
    { "disable_s3", QEMU_CAPS_DISABLE_S3 },
    { "disable_s4", QEMU_CAPS_DISABLE_S4 },
};

1385
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUsbRedir[] = {
1386
    { "filter", QEMU_CAPS_USB_REDIR_FILTER },
1387 1388 1389
    { "bootindex", QEMU_CAPS_USB_REDIR_BOOTINDEX },
};

1390
static struct virQEMUCapsStringFlags virQEMUCapsObjectPropsUsbHost[] = {
1391
    { "bootindex", QEMU_CAPS_USB_HOST_BOOTINDEX },
1392 1393
};

1394
struct virQEMUCapsObjectTypeProps {
1395
    const char *type;
1396
    struct virQEMUCapsStringFlags *props;
1397 1398 1399
    size_t nprops;
};

1400 1401 1402 1403
static struct virQEMUCapsObjectTypeProps virQEMUCapsObjectProps[] = {
    { "virtio-blk-pci", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-pci", virQEMUCapsObjectPropsVirtioNet,
1404 1405 1406 1407
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-ccw", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-ccw", virQEMUCapsObjectPropsVirtioNet,
1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "virtio-blk-s390", virQEMUCapsObjectPropsVirtioBlk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioBlk) },
    { "virtio-net-s390", virQEMUCapsObjectPropsVirtioNet,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsVirtioNet) },
    { "pci-assign", virQEMUCapsObjectPropsPciAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPciAssign) },
    { "kvm-pci-assign", virQEMUCapsObjectPropsPciAssign,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPciAssign) },
    { "scsi-disk", virQEMUCapsObjectPropsScsiDisk,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsScsiDisk) },
    { "ide-drive", virQEMUCapsObjectPropsIDEDrive,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsIDEDrive) },
    { "PIIX4_PM", virQEMUCapsObjectPropsPixx4PM,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsPixx4PM) },
    { "usb-redir", virQEMUCapsObjectPropsUsbRedir,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUsbRedir) },
    { "usb-host", virQEMUCapsObjectPropsUsbHost,
      ARRAY_CARDINALITY(virQEMUCapsObjectPropsUsbHost) },
1427 1428 1429 1430
};


static void
1431 1432 1433 1434 1435
virQEMUCapsProcessStringFlags(virQEMUCapsPtr qemuCaps,
                              size_t nflags,
                              struct virQEMUCapsStringFlags *flags,
                              size_t nvalues,
                              char *const*values)
1436 1437 1438 1439 1440
{
    size_t i, j;
    for (i = 0 ; i < nflags ; i++) {
        for (j = 0 ; j < nvalues ; j++) {
            if (STREQ(values[j], flags[i].value)) {
1441
                virQEMUCapsSet(qemuCaps, flags[i].flag);
1442 1443 1444 1445 1446 1447 1448 1449
                break;
            }
        }
    }
}


static void
1450 1451
virQEMUCapsFreeStringList(size_t len,
                          char **values)
1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462
{
    size_t i;
    for (i = 0 ; i < len ; i++)
        VIR_FREE(values[i]);
    VIR_FREE(values);
}


#define OBJECT_TYPE_PREFIX "name \""

static int
1463 1464
virQEMUCapsParseDeviceStrObjectTypes(const char *str,
                                     char ***types)
1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497
{
    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;
        }

        if (VIR_EXPAND_N(typelist, ntypelist, 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
        if (!(typelist[ntypelist-1] = strndup(tmp, end-tmp))) {
            virReportOOMError();
            goto cleanup;
        }
    }

    *types = typelist;
    ret = ntypelist;

cleanup:
    if (ret < 0)
1498
        virQEMUCapsFreeStringList(ntypelist, typelist);
1499 1500 1501 1502 1503
    return ret;
}


static int
1504 1505 1506
virQEMUCapsParseDeviceStrObjectProps(const char *str,
                                     const char *type,
                                     char ***props)
1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554
{
    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;
        }
        if (VIR_EXPAND_N(proplist, nproplist, 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
        if (!(proplist[nproplist-1] = strndup(tmp, end-tmp))) {
            virReportOOMError();
            goto cleanup;
        }
    }

    *props = proplist;
    ret = nproplist;

cleanup:
    if (ret < 0)
1555
        virQEMUCapsFreeStringList(nproplist, proplist);
1556 1557 1558 1559 1560
    return ret;
}


int
1561
virQEMUCapsParseDeviceStr(virQEMUCapsPtr qemuCaps, const char *str)
1562 1563 1564 1565 1566
{
    int nvalues;
    char **values;
    size_t i;

1567
    if ((nvalues = virQEMUCapsParseDeviceStrObjectTypes(str, &values)) < 0)
1568
        return -1;
1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

    for (i = 0 ; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
        const char *type = virQEMUCapsObjectProps[i].type;
        if ((nvalues = virQEMUCapsParseDeviceStrObjectProps(str,
                                                            type,
                                                            &values)) < 0)
1580
            return -1;
1581 1582 1583 1584 1585
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
1586 1587 1588
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
1589 1590
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
1591 1592 1593 1594 1595

    return 0;
}


E
Eric Blake 已提交
1596
static int
1597 1598
virQEMUCapsExtractDeviceStr(const char *qemu,
                            virQEMUCapsPtr qemuCaps,
1599
                            uid_t runUid, gid_t runGid)
1600
{
E
Eric Blake 已提交
1601
    char *output = NULL;
1602
    virCommandPtr cmd;
E
Eric Blake 已提交
1603
    int ret = -1;
1604

E
Eric Blake 已提交
1605 1606
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
1607 1608
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
1609
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
1610 1611
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
1612
     * if -help includes "device driver,?".  */
1613
    cmd = virQEMUCapsProbeCommand(qemu, qemuCaps, runUid, runGid);
1614 1615 1616 1617 1618 1619
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
1620
                         "-device", "PIIX4_PM,?",
1621
                         "-device", "usb-redir,?",
1622
                         "-device", "ide-drive,?",
1623
                         "-device", "usb-host,?",
1624
                         NULL);
1625
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
1626
    virCommandSetErrorBuffer(cmd, &output);
1627

1628
    if (virCommandRun(cmd, NULL) < 0)
1629 1630
        goto cleanup;

1631
    ret = virQEMUCapsParseDeviceStr(qemuCaps, output);
1632 1633

cleanup:
E
Eric Blake 已提交
1634
    VIR_FREE(output);
1635
    virCommandFree(cmd);
E
Eric Blake 已提交
1636 1637 1638
    return ret;
}

1639

1640 1641 1642
int virQEMUCapsGetDefaultVersion(virCapsPtr caps,
                                 virQEMUCapsCachePtr capsCache,
                                 unsigned int *version)
1643 1644
{
    const char *binary;
1645
    virQEMUCapsPtr qemucaps;
1646 1647 1648 1649 1650 1651

    if (*version > 0)
        return 0;

    if ((binary = virCapabilitiesDefaultGuestEmulator(caps,
                                                      "hvm",
1652
                                                      virArchFromHost(),
1653
                                                      "qemu")) == NULL) {
1654
        virReportError(VIR_ERR_INTERNAL_ERROR,
1655 1656
                       _("Cannot find suitable emulator for %s"),
                       virArchToString(virArchFromHost()));
1657 1658 1659
        return -1;
    }

1660
    if (!(qemucaps = virQEMUCapsCacheLookup(capsCache, binary)))
1661 1662
        return -1;

1663
    *version = virQEMUCapsGetVersion(qemucaps);
1664
    virObjectUnref(qemucaps);
1665 1666
    return 0;
}
1667 1668


1669 1670


1671 1672
virQEMUCapsPtr
virQEMUCapsNew(void)
1673
{
1674
    virQEMUCapsPtr qemuCaps;
1675

1676
    if (virQEMUCapsInitialize() < 0)
1677 1678
        return NULL;

1679
    if (!(qemuCaps = virObjectNew(virQEMUCapsClass)))
1680 1681
        return NULL;

1682
    if (!(qemuCaps->flags = virBitmapNew(QEMU_CAPS_LAST)))
1683
        goto no_memory;
1684

1685
    return qemuCaps;
1686 1687 1688

no_memory:
    virReportOOMError();
1689
    virObjectUnref(qemuCaps);
1690
    return NULL;
1691 1692 1693
}


1694
virQEMUCapsPtr virQEMUCapsNewCopy(virQEMUCapsPtr qemuCaps)
1695
{
1696
    virQEMUCapsPtr ret = virQEMUCapsNew();
1697 1698 1699 1700 1701
    size_t i;

    if (!ret)
        return NULL;

1702
    virBitmapCopy(ret->flags, qemuCaps->flags);
1703

1704 1705 1706 1707
    ret->usedQMP = qemuCaps->usedQMP;
    ret->version = qemuCaps->version;
    ret->kvmVersion = qemuCaps->kvmVersion;
    ret->arch = qemuCaps->arch;
1708

1709
    if (VIR_ALLOC_N(ret->cpuDefinitions, qemuCaps->ncpuDefinitions) < 0)
1710
        goto no_memory;
1711 1712 1713
    ret->ncpuDefinitions = qemuCaps->ncpuDefinitions;
    for (i = 0 ; i < qemuCaps->ncpuDefinitions ; i++) {
        if (!(ret->cpuDefinitions[i] = strdup(qemuCaps->cpuDefinitions[i])))
1714 1715 1716
            goto no_memory;
    }

1717
    if (VIR_ALLOC_N(ret->machineTypes, qemuCaps->nmachineTypes) < 0)
1718
        goto no_memory;
1719
    if (VIR_ALLOC_N(ret->machineAliases, qemuCaps->nmachineTypes) < 0)
1720
        goto no_memory;
1721 1722 1723
    ret->nmachineTypes = qemuCaps->nmachineTypes;
    for (i = 0 ; i < qemuCaps->nmachineTypes ; i++) {
        if (!(ret->machineTypes[i] = strdup(qemuCaps->machineTypes[i])))
1724
            goto no_memory;
1725 1726
        if (qemuCaps->machineAliases[i] &&
            !(ret->machineAliases[i] = strdup(qemuCaps->machineAliases[i])))
1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738
            goto no_memory;
    }

    return ret;

no_memory:
    virReportOOMError();
    virObjectUnref(ret);
    return NULL;
}


1739
void virQEMUCapsDispose(void *obj)
1740
{
1741
    virQEMUCapsPtr qemuCaps = obj;
1742 1743
    size_t i;

1744 1745 1746
    for (i = 0 ; i < qemuCaps->nmachineTypes ; i++) {
        VIR_FREE(qemuCaps->machineTypes[i]);
        VIR_FREE(qemuCaps->machineAliases[i]);
1747
    }
1748 1749
    VIR_FREE(qemuCaps->machineTypes);
    VIR_FREE(qemuCaps->machineAliases);
1750

1751 1752
    for (i = 0 ; i < qemuCaps->ncpuDefinitions ; i++) {
        VIR_FREE(qemuCaps->cpuDefinitions[i]);
1753
    }
1754
    VIR_FREE(qemuCaps->cpuDefinitions);
1755

1756
    virBitmapFree(qemuCaps->flags);
1757

1758
    VIR_FREE(qemuCaps->binary);
1759 1760
}

1761
void
1762 1763
virQEMUCapsSet(virQEMUCapsPtr qemuCaps,
               enum virQEMUCapsFlags flag)
1764
{
1765
    ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
1766 1767 1768 1769
}


void
1770
virQEMUCapsSetList(virQEMUCapsPtr qemuCaps, ...)
1771 1772 1773 1774
{
    va_list list;
    int flag;

1775
    va_start(list, qemuCaps);
1776
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
1777
        ignore_value(virBitmapSetBit(qemuCaps->flags, flag));
1778
    va_end(list);
1779 1780 1781 1782
}


void
1783 1784
virQEMUCapsClear(virQEMUCapsPtr qemuCaps,
                 enum virQEMUCapsFlags flag)
1785
{
1786
    ignore_value(virBitmapClearBit(qemuCaps->flags, flag));
1787 1788 1789
}


1790
char *virQEMUCapsFlagsString(virQEMUCapsPtr qemuCaps)
1791
{
1792
    return virBitmapString(qemuCaps->flags);
1793 1794 1795 1796
}


bool
1797 1798
virQEMUCapsGet(virQEMUCapsPtr qemuCaps,
               enum virQEMUCapsFlags flag)
1799
{
1800 1801
    bool b;

1802
    if (!qemuCaps || virBitmapGetBit(qemuCaps->flags, flag, &b) < 0)
1803 1804 1805
        return false;
    else
        return b;
1806
}
1807 1808


1809
const char *virQEMUCapsGetBinary(virQEMUCapsPtr qemuCaps)
1810
{
1811
    return qemuCaps->binary;
1812 1813
}

1814
virArch virQEMUCapsGetArch(virQEMUCapsPtr qemuCaps)
1815
{
1816
    return qemuCaps->arch;
1817 1818 1819
}


1820
unsigned int virQEMUCapsGetVersion(virQEMUCapsPtr qemuCaps)
1821
{
1822
    return qemuCaps->version;
1823 1824 1825
}


1826
unsigned int virQEMUCapsGetKVMVersion(virQEMUCapsPtr qemuCaps)
1827
{
1828
    return qemuCaps->kvmVersion;
1829 1830 1831
}


1832 1833
int virQEMUCapsAddCPUDefinition(virQEMUCapsPtr qemuCaps,
                                const char *name)
1834 1835 1836 1837 1838 1839
{
    char *tmp = strdup(name);
    if (!tmp) {
        virReportOOMError();
        return -1;
    }
1840
    if (VIR_EXPAND_N(qemuCaps->cpuDefinitions, qemuCaps->ncpuDefinitions, 1) < 0) {
1841 1842 1843 1844
        VIR_FREE(tmp);
        virReportOOMError();
        return -1;
    }
1845
    qemuCaps->cpuDefinitions[qemuCaps->ncpuDefinitions-1] = tmp;
1846 1847 1848 1849
    return 0;
}


1850 1851
size_t virQEMUCapsGetCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                    char ***names)
1852
{
1853
    if (names)
1854 1855
        *names = qemuCaps->cpuDefinitions;
    return qemuCaps->ncpuDefinitions;
1856 1857 1858
}


1859 1860
size_t virQEMUCapsGetMachineTypes(virQEMUCapsPtr qemuCaps,
                                  char ***names)
1861
{
1862
    if (names)
1863 1864
        *names = qemuCaps->machineTypes;
    return qemuCaps->nmachineTypes;
1865 1866
}

1867 1868 1869
int virQEMUCapsGetMachineTypesCaps(virQEMUCapsPtr qemuCaps,
                                   size_t *nmachines,
                                   virCapsGuestMachinePtr **machines)
1870 1871 1872 1873 1874
{
    size_t i;

    *nmachines = 0;
    *machines = NULL;
1875
    if (VIR_ALLOC_N(*machines, qemuCaps->nmachineTypes) < 0)
1876
        goto no_memory;
1877
    *nmachines = qemuCaps->nmachineTypes;
1878

1879
    for (i = 0 ; i < qemuCaps->nmachineTypes ; i++) {
1880 1881 1882
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
            goto no_memory;
1883 1884
        if (qemuCaps->machineAliases[i]) {
            if (!(mach->name = strdup(qemuCaps->machineAliases[i])))
1885
                goto no_memory;
1886
            if (!(mach->canonical = strdup(qemuCaps->machineTypes[i])))
1887 1888
                goto no_memory;
        } else {
1889
            if (!(mach->name = strdup(qemuCaps->machineTypes[i])))
1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905
                goto no_memory;
        }
        (*machines)[i] = mach;
    }

    return 0;

no_memory:
    virCapabilitiesFreeMachines(*machines, *nmachines);
    *nmachines = 0;
    *machines = NULL;
    return -1;
}



1906

1907 1908
const char *virQEMUCapsGetCanonicalMachine(virQEMUCapsPtr qemuCaps,
                                           const char *name)
1909 1910 1911
{
    size_t i;

1912 1913 1914
    if (!name)
        return NULL;

1915 1916
    for (i = 0 ; i < qemuCaps->nmachineTypes ; i++) {
        if (!qemuCaps->machineAliases[i])
1917
            continue;
1918 1919
        if (STREQ(qemuCaps->machineAliases[i], name))
            return qemuCaps->machineTypes[i];
1920 1921 1922 1923
    }

    return name;
}
1924 1925


1926
static int
1927 1928
virQEMUCapsProbeQMPCommands(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939
{
    char **commands = NULL;
    int ncommands;
    size_t i;

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

    for (i = 0 ; i < ncommands ; i++) {
        char *name = commands[i];
        if (STREQ(name, "system_wakeup"))
1940
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_WAKEUP);
1941
        else if (STREQ(name, "transaction"))
1942
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_TRANSACTION);
1943
        else if (STREQ(name, "block_job_cancel"))
1944
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_BLOCKJOB_SYNC);
1945
        else if (STREQ(name, "block-job-cancel"))
1946
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_BLOCKJOB_ASYNC);
1947
        else if (STREQ(name, "dump-guest-memory"))
1948
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_MEMORY);
1949
        else if (STREQ(name, "query-spice"))
1950
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_SPICE);
1951
        else if (STREQ(name, "query-kvm"))
1952
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_KVM);
1953
        else if (STREQ(name, "block-commit"))
1954
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_BLOCK_COMMIT);
1955
        else if (STREQ(name, "query-vnc"))
1956
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_VNC);
1957
        else if (STREQ(name, "drive-mirror"))
1958
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DRIVE_MIRROR);
1959
        else if (STREQ(name, "blockdev-snapshot-sync"))
1960
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_DISK_SNAPSHOT);
1961
        else if (STREQ(name, "add-fd"))
1962
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_ADD_FD);
1963 1964
        else if (STREQ(name, "nbd-server-start"))
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_NBD_SERVER);
1965 1966 1967 1968
        VIR_FREE(name);
    }
    VIR_FREE(commands);

1969 1970 1971 1972
    /* 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.  */
1973
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_ADD_FD)) {
1974 1975 1976 1977 1978 1979 1980
        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)
1981
            virQEMUCapsClear(qemuCaps, QEMU_CAPS_ADD_FD);
1982 1983 1984
        VIR_FORCE_CLOSE(fd);
    }

1985 1986 1987 1988 1989
    return 0;
}


static int
1990 1991
virQEMUCapsProbeQMPEvents(virQEMUCapsPtr qemuCaps,
                          qemuMonitorPtr mon)
1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003
{
    char **events = NULL;
    int nevents;
    size_t i;

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

    for (i = 0 ; i < nevents ; i++) {
        char *name = events[i];

        if (STREQ(name, "BALLOON_CHANGE"))
2004
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_BALLOON_EVENT);
2005
        if (STREQ(name, "SPICE_MIGRATE_COMPLETED"))
2006
            virQEMUCapsSet(qemuCaps, QEMU_CAPS_SEAMLESS_MIGRATION);
2007 2008 2009 2010 2011 2012 2013 2014
        VIR_FREE(name);
    }
    VIR_FREE(events);

    return 0;
}


2015
static int
2016 2017
virQEMUCapsProbeQMPObjects(virQEMUCapsPtr qemuCaps,
                           qemuMonitorPtr mon)
2018 2019 2020 2021 2022 2023 2024
{
    int nvalues;
    char **values;
    size_t i;

    if ((nvalues = qemuMonitorGetObjectTypes(mon, &values)) < 0)
        return -1;
2025 2026 2027 2028 2029 2030 2031 2032
    virQEMUCapsProcessStringFlags(qemuCaps,
                                  ARRAY_CARDINALITY(virQEMUCapsObjectTypes),
                                  virQEMUCapsObjectTypes,
                                  nvalues, values);
    virQEMUCapsFreeStringList(nvalues, values);

    for (i = 0 ; i < ARRAY_CARDINALITY(virQEMUCapsObjectProps); i++) {
        const char *type = virQEMUCapsObjectProps[i].type;
2033 2034 2035 2036
        if ((nvalues = qemuMonitorGetObjectProps(mon,
                                                 type,
                                                 &values)) < 0)
            return -1;
2037 2038 2039 2040 2041
        virQEMUCapsProcessStringFlags(qemuCaps,
                                      virQEMUCapsObjectProps[i].nprops,
                                      virQEMUCapsObjectProps[i].props,
                                      nvalues, values);
        virQEMUCapsFreeStringList(nvalues, values);
2042 2043 2044
    }

    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
2045 2046
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_CHARDEV_SPICEVMC))
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_DEVICE_SPICEVMC);
2047
    /* If qemu supports newer -device qxl it supports -vga qxl as well */
2048 2049
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE_QXL))
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_VGA_QXL);
2050 2051 2052 2053 2054 2055

    return 0;
}


static int
2056 2057
virQEMUCapsProbeQMPMachineTypes(virQEMUCapsPtr qemuCaps,
                                qemuMonitorPtr mon)
2058 2059 2060 2061 2062
{
    qemuMonitorMachineInfoPtr *machines = NULL;
    int nmachines = 0;
    int ret = -1;
    size_t i;
2063
    size_t defIdx = 0;
2064 2065 2066 2067

    if ((nmachines = qemuMonitorGetMachines(mon, &machines)) < 0)
        goto cleanup;

2068
    if (VIR_ALLOC_N(qemuCaps->machineTypes, nmachines) < 0) {
2069 2070 2071
        virReportOOMError();
        goto cleanup;
    }
2072
    if (VIR_ALLOC_N(qemuCaps->machineAliases, nmachines) < 0) {
2073 2074 2075 2076 2077 2078
        virReportOOMError();
        goto cleanup;
    }

    for (i = 0 ; i < nmachines ; i++) {
        if (machines[i]->alias) {
2079
            if (!(qemuCaps->machineAliases[i] = strdup(machines[i]->alias))) {
2080 2081 2082 2083
                virReportOOMError();
                goto cleanup;
            }
        }
2084
        if (!(qemuCaps->machineTypes[i] = strdup(machines[i]->name))) {
2085 2086 2087
            virReportOOMError();
            goto cleanup;
        }
2088 2089
        if (machines[i]->isDefault)
            defIdx = i;
2090
    }
2091
    qemuCaps->nmachineTypes = nmachines;
2092 2093

    if (defIdx)
2094
        virQEMUCapsSetDefaultMachine(qemuCaps, defIdx);
2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106

    ret = 0;

cleanup:
    for (i = 0 ; i < nmachines ; i++)
        qemuMonitorMachineInfoFree(machines[i]);
    VIR_FREE(machines);
    return ret;
}


static int
2107 2108
virQEMUCapsProbeQMPCPUDefinitions(virQEMUCapsPtr qemuCaps,
                                  qemuMonitorPtr mon)
2109 2110 2111 2112 2113 2114 2115
{
    int ncpuDefinitions;
    char **cpuDefinitions;

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

2116 2117
    qemuCaps->ncpuDefinitions = ncpuDefinitions;
    qemuCaps->cpuDefinitions = cpuDefinitions;
2118 2119 2120 2121

    return 0;
}

2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176
struct tpmTypeToCaps {
    int type;
    enum virQEMUCapsFlags caps;
};

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)
{
    int nentries, i;
    char **entries = NULL;
    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;
}

2177

2178
static int
2179 2180
virQEMUCapsProbeQMPKVMState(virQEMUCapsPtr qemuCaps,
                            qemuMonitorPtr mon)
2181 2182 2183 2184
{
    bool enabled = false;
    bool present = false;

2185
    if (!virQEMUCapsGet(qemuCaps, QEMU_CAPS_KVM))
2186 2187 2188 2189 2190 2191
        return 0;

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

    /* The QEMU_CAPS_KVM flag was initially set according to the QEMU
2192 2193 2194 2195 2196 2197 2198 2199
     * reporting the recognition of 'query-kvm' QMP command. That merely
     * indicates existance of the command though, not whether KVM support
     * 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) {
2200
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
2201
    } else if (!enabled) {
2202 2203
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_KVM);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_ENABLE_KVM);
2204 2205 2206 2207 2208 2209
    }

    return 0;
}


2210 2211
int virQEMUCapsProbeQMP(virQEMUCapsPtr qemuCaps,
                        qemuMonitorPtr mon)
2212
{
2213
    VIR_DEBUG("qemuCaps=%p mon=%p", qemuCaps, mon);
2214

2215
    if (qemuCaps->usedQMP)
2216 2217
        return 0;

2218
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
2219 2220
        return -1;

2221
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
2222 2223 2224 2225 2226 2227
        return -1;

    return 0;
}


2228 2229
#define QEMU_SYSTEM_PREFIX "qemu-system-"

2230
static int
2231
virQEMUCapsInitHelp(virQEMUCapsPtr qemuCaps, uid_t runUid, gid_t runGid)
2232
{
2233
    virCommandPtr cmd = NULL;
2234 2235
    unsigned int is_kvm;
    char *help = NULL;
2236 2237
    int ret = -1;
    const char *tmp;
2238

2239
    VIR_DEBUG("qemuCaps=%p", qemuCaps);
2240

2241
    tmp = strstr(qemuCaps->binary, QEMU_SYSTEM_PREFIX);
2242 2243
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
2244

2245
        qemuCaps->arch = virQEMUCapsArchFromString(tmp);
2246
    } else {
2247
        qemuCaps->arch = virArchFromHost();
2248 2249
    }

2250
    cmd = virQEMUCapsProbeCommand(qemuCaps->binary, NULL, runUid, runGid);
2251 2252 2253 2254
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
2255
        goto cleanup;
2256

2257 2258 2259 2260 2261 2262
    if (virQEMUCapsParseHelpStr(qemuCaps->binary,
                                help, qemuCaps,
                                &qemuCaps->version,
                                &is_kvm,
                                &qemuCaps->kvmVersion,
                                false) < 0)
2263
        goto cleanup;
2264 2265

    /* Currently only x86_64 and i686 support PCI-multibus. */
2266 2267 2268
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
        qemuCaps->arch == VIR_ARCH_I686) {
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
2269 2270 2271
    } else {
        /* -no-acpi is not supported on other archs
         * even if qemu reports it in -help */
2272
        virQEMUCapsClear(qemuCaps, QEMU_CAPS_NO_ACPI);
2273
    }
2274

2275
    /* virQEMUCapsExtractDeviceStr will only set additional caps if qemu
2276
     * understands the 0.13.0+ notion of "-device driver,".  */
2277
    if (virQEMUCapsGet(qemuCaps, QEMU_CAPS_DEVICE) &&
2278
        strstr(help, "-device driver,?") &&
2279 2280
        virQEMUCapsExtractDeviceStr(qemuCaps->binary,
                                    qemuCaps, runUid, runGid) < 0) {
2281
        goto cleanup;
2282
    }
2283

2284
    if (virQEMUCapsProbeCPUModels(qemuCaps, runUid, runGid) < 0)
2285
        goto cleanup;
2286

2287
    if (virQEMUCapsProbeMachineTypes(qemuCaps, runUid, runGid) < 0)
2288
        goto cleanup;
2289

2290
    ret = 0;
2291
cleanup:
2292
    virCommandFree(cmd);
2293
    VIR_FREE(help);
2294 2295 2296 2297
    return ret;
}


2298 2299
static void virQEMUCapsMonitorNotify(qemuMonitorPtr mon ATTRIBUTE_UNUSED,
                                     virDomainObjPtr vm ATTRIBUTE_UNUSED)
2300 2301 2302 2303
{
}

static qemuMonitorCallbacks callbacks = {
2304 2305
    .eofNotify = virQEMUCapsMonitorNotify,
    .errorNotify = virQEMUCapsMonitorNotify,
2306 2307 2308 2309 2310 2311 2312
};


/* Capabilities that we assume are always enabled
 * for QEMU >= 1.2.0
 */
static void
2313
virQEMUCapsInitQMPBasic(virQEMUCapsPtr qemuCaps)
2314
{
2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363
    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_NO_HPET);
    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);
2364
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_KVM_PIT);
O
Olivia Yin 已提交
2365
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DTB);
J
Ján Tomko 已提交
2366
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_IPV6_MIGRATION);
2367 2368
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_OPT);
    virQEMUCapsSet(qemuCaps, QEMU_CAPS_DUMP_GUEST_CORE);
2369 2370 2371 2372
}


static int
2373 2374 2375 2376
virQEMUCapsInitQMP(virQEMUCapsPtr qemuCaps,
                   const char *libDir,
                   uid_t runUid,
                   gid_t runGid)
2377 2378 2379 2380 2381
{
    int ret = -1;
    virCommandPtr cmd = NULL;
    qemuMonitorPtr mon = NULL;
    int major, minor, micro;
2382
    char *package = NULL;
2383 2384 2385 2386
    int status = 0;
    virDomainChrSourceDef config;
    char *monarg = NULL;
    char *monpath = NULL;
2387
    char *pidfile = NULL;
2388
    char *archstr;
2389 2390
    pid_t pid = 0;
    virDomainObj vm;
2391

2392 2393 2394
    /* the ".sock" sufix is important to avoid a possible clash with a qemu
     * domain called "capabilities"
     */
2395 2396 2397 2398 2399 2400 2401 2402 2403
    if (virAsprintf(&monpath, "%s/%s", libDir, "capabilities.monitor.sock") < 0) {
        virReportOOMError();
        goto cleanup;
    }
    if (virAsprintf(&monarg, "unix:%s,server,nowait", monpath) < 0) {
        virReportOOMError();
        goto cleanup;
    }

2404 2405
    /* ".pidfile" suffix is used rather than ".pid" to avoid a possible clash
     * with a qemu domain called "capabilities"
2406 2407 2408
     * 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
2409
     */
2410
    if (virAsprintf(&pidfile, "%s/%s", libDir, "capabilities.pidfile") < 0) {
2411 2412 2413 2414
        virReportOOMError();
        goto cleanup;
    }

2415 2416 2417 2418 2419
    memset(&config, 0, sizeof(config));
    config.type = VIR_DOMAIN_CHR_TYPE_UNIX;
    config.data.nix.path = monpath;
    config.data.nix.listen = false;

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

2422 2423 2424 2425 2426 2427 2428
    /*
     * 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.
     */
2429
    cmd = virCommandNewArgList(qemuCaps->binary,
2430 2431 2432 2433 2434 2435
                               "-S",
                               "-no-user-config",
                               "-nodefaults",
                               "-nographic",
                               "-M", "none",
                               "-qmp", monarg,
2436 2437
                               "-pidfile", pidfile,
                               "-daemonize",
2438 2439 2440
                               NULL);
    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);
2441 2442
    virCommandSetGID(cmd, runGid);
    virCommandSetUID(cmd, runUid);
2443 2444 2445 2446 2447 2448

    if (virCommandRun(cmd, &status) < 0)
        goto cleanup;

    if (status != 0) {
        ret = 0;
2449
        VIR_DEBUG("QEMU %s exited with status %d", qemuCaps->binary, status);
2450 2451 2452
        goto cleanup;
    }

2453 2454 2455 2456 2457 2458 2459 2460 2461 2462
    if (virPidFileReadPath(pidfile, &pid) < 0) {
        VIR_DEBUG("Failed to read pidfile %s", pidfile);
        ret = 0;
        goto cleanup;
    }

    memset(&vm, 0, sizeof(vm));
    vm.pid = pid;

    if (!(mon = qemuMonitorOpen(&vm, &config, true, &callbacks))) {
2463
        ret = 0;
2464
        goto cleanup;
2465
    }
2466

2467
    virObjectLock(mon);
2468 2469 2470 2471 2472 2473 2474 2475 2476 2477 2478 2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489

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

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

2496 2497
    qemuCaps->version = major * 1000000 + minor * 1000 + micro;
    qemuCaps->usedQMP = true;
2498

2499
    virQEMUCapsInitQMPBasic(qemuCaps);
2500

L
Li Zhang 已提交
2501 2502 2503 2504
    /* USB option is supported v1.3.0 onwards */
    if (qemuCaps->version >= 1003000)
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_MACHINE_USB_OPT);

2505
    if (!(archstr = qemuMonitorGetTargetArch(mon)))
2506 2507
        goto cleanup;

2508
    if ((qemuCaps->arch = virQEMUCapsArchFromString(archstr)) == VIR_ARCH_NONE) {
2509 2510 2511 2512 2513 2514
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unknown QEMU arch %s"), archstr);
        VIR_FREE(archstr);
        goto cleanup;
    }
    VIR_FREE(archstr);
2515

2516
    /* Currently only x86_64 and i686 support PCI-multibus and -no-acpi. */
2517 2518 2519 2520
    if (qemuCaps->arch == VIR_ARCH_X86_64 ||
        qemuCaps->arch == VIR_ARCH_I686) {
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_PCI_MULTIBUS);
        virQEMUCapsSet(qemuCaps, QEMU_CAPS_NO_ACPI);
2521
    }
2522

2523
    if (virQEMUCapsProbeQMPCommands(qemuCaps, mon) < 0)
2524
        goto cleanup;
2525
    if (virQEMUCapsProbeQMPEvents(qemuCaps, mon) < 0)
2526
        goto cleanup;
2527
    if (virQEMUCapsProbeQMPObjects(qemuCaps, mon) < 0)
2528
        goto cleanup;
2529
    if (virQEMUCapsProbeQMPMachineTypes(qemuCaps, mon) < 0)
2530
        goto cleanup;
2531
    if (virQEMUCapsProbeQMPCPUDefinitions(qemuCaps, mon) < 0)
2532
        goto cleanup;
2533
    if (virQEMUCapsProbeQMPKVMState(qemuCaps, mon) < 0)
2534
        goto cleanup;
2535 2536
    if (virQEMUCapsProbeQMPTPM(qemuCaps, mon) < 0)
        goto cleanup;
2537 2538 2539 2540 2541

    ret = 0;

cleanup:
    if (mon)
2542
        virObjectUnlock(mon);
2543 2544
    qemuMonitorClose(mon);
    virCommandAbort(cmd);
2545
    virCommandFree(cmd);
2546 2547
    VIR_FREE(monarg);
    VIR_FREE(monpath);
2548
    VIR_FREE(package);
2549

2550
    if (pid != 0) {
2551 2552
        char ebuf[1024];

2553 2554 2555 2556 2557 2558 2559
        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)));
    }
    if (pidfile) {
2560 2561 2562
        unlink(pidfile);
        VIR_FREE(pidfile);
    }
2563 2564 2565 2566
    return ret;
}


2567 2568 2569 2570
virQEMUCapsPtr virQEMUCapsNewForBinary(const char *binary,
                                       const char *libDir,
                                       uid_t runUid,
                                       gid_t runGid)
2571
{
2572
    virQEMUCapsPtr qemuCaps = virQEMUCapsNew();
2573 2574 2575
    struct stat sb;
    int rv;

2576
    if (!(qemuCaps->binary = strdup(binary)))
2577 2578 2579 2580 2581 2582 2583 2584 2585
        goto no_memory;

    /* We would also want to check faccessat if we cared about ACLs,
     * but we don't.  */
    if (stat(binary, &sb) < 0) {
        virReportSystemError(errno, _("Cannot check QEMU binary %s"),
                             binary);
        goto error;
    }
2586
    qemuCaps->mtime = sb.st_mtime;
2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597

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

2598
    if ((rv = virQEMUCapsInitQMP(qemuCaps, libDir, runUid, runGid)) < 0)
2599 2600
        goto error;

2601 2602
    if (!qemuCaps->usedQMP &&
        virQEMUCapsInitHelp(qemuCaps, runUid, runGid) < 0)
2603 2604
        goto error;

2605
    return qemuCaps;
2606 2607 2608 2609

no_memory:
    virReportOOMError();
error:
2610 2611
    virObjectUnref(qemuCaps);
    qemuCaps = NULL;
2612
    return NULL;
2613 2614 2615
}


2616
bool virQEMUCapsIsValid(virQEMUCapsPtr qemuCaps)
2617 2618 2619
{
    struct stat sb;

2620
    if (!qemuCaps->binary)
2621 2622
        return true;

2623
    if (stat(qemuCaps->binary, &sb) < 0)
2624 2625
        return false;

2626
    return sb.st_mtime == qemuCaps->mtime;
2627
}
2628 2629 2630


static void
2631
virQEMUCapsHashDataFree(void *payload, const void *key ATTRIBUTE_UNUSED)
2632 2633 2634 2635 2636
{
    virObjectUnref(payload);
}


2637 2638 2639 2640
virQEMUCapsCachePtr
virQEMUCapsCacheNew(const char *libDir,
                    uid_t runUid,
                    gid_t runGid)
2641
{
2642
    virQEMUCapsCachePtr cache;
2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655

    if (VIR_ALLOC(cache) < 0) {
        virReportOOMError();
        return NULL;
    }

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

2656
    if (!(cache->binaries = virHashCreate(10, virQEMUCapsHashDataFree)))
2657
        goto error;
2658
    if (!(cache->libDir = strdup(libDir))) {
2659 2660 2661
        virReportOOMError();
        goto error;
    }
2662

2663 2664 2665
    cache->runUid = runUid;
    cache->runGid = runGid;

2666 2667 2668
    return cache;

error:
2669
    virQEMUCapsCacheFree(cache);
2670 2671 2672 2673
    return NULL;
}


2674 2675
virQEMUCapsPtr
virQEMUCapsCacheLookup(virQEMUCapsCachePtr cache, const char *binary)
2676
{
2677
    virQEMUCapsPtr ret = NULL;
2678 2679 2680
    virMutexLock(&cache->lock);
    ret = virHashLookup(cache->binaries, binary);
    if (ret &&
2681
        !virQEMUCapsIsValid(ret)) {
2682 2683 2684 2685 2686 2687 2688 2689
        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);
2690 2691
        ret = virQEMUCapsNewForBinary(binary, cache->libDir,
                                      cache->runUid, cache->runGid);
2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707
        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;
}


2708 2709
virQEMUCapsPtr
virQEMUCapsCacheLookupCopy(virQEMUCapsCachePtr cache, const char *binary)
2710
{
2711 2712
    virQEMUCapsPtr qemuCaps = virQEMUCapsCacheLookup(cache, binary);
    virQEMUCapsPtr ret;
2713

2714
    if (!qemuCaps)
2715 2716
        return NULL;

2717 2718
    ret = virQEMUCapsNewCopy(qemuCaps);
    virObjectUnref(qemuCaps);
2719 2720 2721 2722 2723
    return ret;
}


void
2724
virQEMUCapsCacheFree(virQEMUCapsCachePtr cache)
2725 2726 2727 2728
{
    if (!cache)
        return;

2729
    VIR_FREE(cache->libDir);
2730 2731 2732 2733
    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}
2734 2735

bool
2736
virQEMUCapsUsedQMP(virQEMUCapsPtr qemuCaps)
2737
{
2738
    return qemuCaps->usedQMP;
2739
}