qemu_capabilities.c 54.2 KB
Newer Older
1 2 3
/*
 * qemu_capabilities.c: QEMU capabilities generation
 *
4
 * Copyright (C) 2006-2012 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 27 28 29 30
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>

#include "qemu_capabilities.h"
#include "memory.h"
#include "logging.h"
#include "virterror_internal.h"
#include "util.h"
E
Eric Blake 已提交
31
#include "virfile.h"
32 33 34 35
#include "nodeinfo.h"
#include "cpu/cpu.h"
#include "domain_conf.h"
#include "qemu_conf.h"
36
#include "command.h"
37
#include "virnodesuspend.h"
38 39 40 41 42

#include <sys/stat.h>
#include <unistd.h>
#include <sys/wait.h>
#include <sys/utsname.h>
43
#include <stdarg.h>
44 45 46

#define VIR_FROM_THIS VIR_FROM_QEMU

47 48 49 50 51 52 53 54 55 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
/* While not public, these strings must not change. They
 * are used in domain status files which are read on
 * daemon restarts
 */
VIR_ENUM_IMPL(qemuCaps, QEMU_CAPS_LAST,
              "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 */
89
              "vhost-net",
90 91 92 93 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
              "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",
123 124

              "pci-multifunction", /* 60 */
125
              "virtio-blk-pci.ioeventfd",
M
Michal Privoznik 已提交
126
              "sga",
127 128
              "virtio-blk-pci.event_idx",
              "virtio-net-pci.event_idx",
129 130 131 132 133 134 135 136 137 138

              "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 已提交
139
              "usb-hub",
140
              "no-shutdown",
141 142

              "cache-unsafe", /* 75 */
143
              "rombar",
J
Jim Fehlig 已提交
144
              "ich9-ahci",
145
              "no-acpi",
146
              "fsdev-readonly",
147

148
              "virtio-blk-pci.scsi", /* 80 */
149
              "blk-sg-io",
O
Osier Yang 已提交
150
              "drive-copy-on-read",
151
              "cpu-host",
152
              "fsdev-writeout",
153 154

              "drive-iotune", /* 85 */
155
              "system_wakeup",
156
              "scsi-disk.channel",
157
              "scsi-block",
158
              "transaction",
159 160 161

              "block-job-sync", /* 90 */
              "block-job-async",
162
              "scsi-cd",
163
              "ide-cd",
164
              "no-user-config",
M
Marc-André Lureau 已提交
165 166

              "hda-micro", /* 95 */
167
              "dump-guest-memory",
G
Gerd Hoffmann 已提交
168
              "nec-usb-xhci",
169
              "virtio-s390",
170
              "balloon-event",
M
Marc-André Lureau 已提交
171

R
Richa Marwaha 已提交
172
              "bridge", /* 100 */
173 174
              "lsi",
              "virtio-scsi-pci",
V
Viktor Mihajlovski 已提交
175
              "blockio",
176
              "disable-s3",
R
Richa Marwaha 已提交
177

178
              "disable-s4", /* 105 */
179
              "usb-redir.filter",
180 181
              "ide-drive.wwn",
              "scsi-disk.wwn",
182
              "seccomp-sandbox",
183 184

              "reboot-timeout", /* 110 */
185
              "dump-guest-core",
186
              "seamless-migration",
187 188
    );

189 190 191
struct _qemuCaps {
    virObject object;

192 193 194
    char *binary;
    time_t mtime;

195
    virBitmapPtr flags;
196 197 198 199 200 201 202 203 204 205 206 207

    unsigned int version;
    unsigned int kvmVersion;

    char *arch;

    size_t ncpuDefinitions;
    char **cpuDefinitions;

    size_t nmachineTypes;
    char **machineTypes;
    char **machineAliases;
208 209
};

210 211 212 213 214
struct _qemuCapsCache {
    virMutex lock;
    virHashTablePtr binaries;
};

215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230

static virClassPtr qemuCapsClass;
static void qemuCapsDispose(void *obj);

static int qemuCapsOnceInit(void)
{
    if (!(qemuCapsClass = virClassNew("qemuCaps",
                                      sizeof(qemuCaps),
                                      qemuCapsDispose)))
        return -1;

    return 0;
}

VIR_ONCE_GLOBAL_INIT(qemuCaps)

231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266
struct qemu_feature_flags {
    const char *name;
    const int default_on;
    const int toggle;
};

struct qemu_arch_info {
    const char *arch;
    int wordsize;
    const char *machine;
    const char *binary;
    const char *altbinary;
    const struct qemu_feature_flags *flags;
    int nflags;
};

/* Feature flags for the architecture info */
static const struct qemu_feature_flags const arch_info_i686_flags [] = {
    { "pae",  1, 0 },
    { "nonpae",  1, 0 },
    { "acpi", 1, 1 },
    { "apic", 1, 0 },
};

static const struct qemu_feature_flags const arch_info_x86_64_flags [] = {
    { "acpi", 1, 1 },
    { "apic", 1, 0 },
};

/* The archicture tables for supported QEMU archs */
static const struct qemu_arch_info const arch_info_hvm[] = {
    {  "i686",   32, NULL, "qemu",
       "qemu-system-x86_64", arch_info_i686_flags, 4 },
    {  "x86_64", 64, NULL, "qemu-system-x86_64",
       NULL, arch_info_x86_64_flags, 2 },
    {  "arm",    32, NULL, "qemu-system-arm",    NULL, NULL, 0 },
267 268
    {  "microblaze", 32, NULL, "qemu-system-microblaze",   NULL, NULL, 0 },
    {  "microblazeel", 32, NULL, "qemu-system-microblazeel",   NULL, NULL, 0 },
269 270 271 272
    {  "mips",   32, NULL, "qemu-system-mips",   NULL, NULL, 0 },
    {  "mipsel", 32, NULL, "qemu-system-mipsel", NULL, NULL, 0 },
    {  "sparc",  32, NULL, "qemu-system-sparc",  NULL, NULL, 0 },
    {  "ppc",    32, NULL, "qemu-system-ppc",    NULL, NULL, 0 },
P
Prerna Saxena 已提交
273
    {  "ppc64",    64, NULL, "qemu-system-ppc64",    NULL, NULL, 0 },
274 275 276 277 278 279 280 281 282 283
    {  "itanium", 64, NULL, "qemu-system-ia64",  NULL, NULL, 0 },
    {  "s390x",  64, NULL, "qemu-system-s390x",  NULL, NULL, 0 },
};

static const struct qemu_arch_info const arch_info_xen[] = {
    {  "i686",   32, "xenner", "xenner", NULL, arch_info_i686_flags, 4 },
    {  "x86_64", 64, "xenner", "xenner", NULL, arch_info_x86_64_flags, 2 },
};


284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303
static virCommandPtr
qemuCapsProbeCommand(const char *qemu,
                     qemuCapsPtr caps)
{
    virCommandPtr cmd = virCommandNew(qemu);

    if (caps) {
        if (qemuCapsGet(caps, QEMU_CAPS_NO_USER_CONFIG))
            virCommandAddArg(cmd, "-no-user-config");
        else if (qemuCapsGet(caps, QEMU_CAPS_NODEFCONFIG))
            virCommandAddArg(cmd, "-nodefconfig");
    }

    virCommandAddEnvPassCommon(cmd);
    virCommandClearCaps(cmd);

    return cmd;
}


304 305 306 307 308
/* Format is:
 * <machine> <desc> [(default)|(alias of <canonical>)]
 */
static int
qemuCapsParseMachineTypesStr(const char *output,
309
                             qemuCapsPtr caps)
310 311 312
{
    const char *p = output;
    const char *next;
313
    size_t defIdx = 0;
314 315 316

    do {
        const char *t;
317 318
        char *name;
        char *canonical = NULL;
319 320 321 322 323 324 325 326 327 328

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

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

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

329
        if (!(name = strndup(p, t - p)))
330 331 332
            goto no_memory;

        p = t;
333 334
        if (!(t = strstr(p, "(default)")) && (!next || t < next))
            defIdx = caps->nmachineTypes;
335 336 337 338 339 340

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

341 342
            if (!(canonical = strndup(p, t - p))) {
                VIR_FREE(name);
343
                goto no_memory;
344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359
            }
        }

        if (VIR_REALLOC_N(caps->machineTypes, caps->nmachineTypes + 1) < 0 ||
            VIR_REALLOC_N(caps->machineAliases, caps->nmachineTypes + 1) < 0) {
            VIR_FREE(name);
            VIR_FREE(canonical);
            goto no_memory;
        }
        caps->nmachineTypes++;
        if (canonical) {
            caps->machineTypes[caps->nmachineTypes-1] = canonical;
            caps->machineAliases[caps->nmachineTypes-1] = name;
        } else {
            caps->machineTypes[caps->nmachineTypes-1] = name;
            caps->machineAliases[caps->nmachineTypes-1] = NULL;
360 361 362
        }
    } while ((p = next));

363 364 365 366 367 368 369 370 371 372 373 374 375

    if (defIdx != 0) {
        char *name = caps->machineTypes[defIdx];
        char *alias = caps->machineAliases[defIdx];
        memmove(caps->machineTypes + 1,
                caps->machineTypes,
                sizeof(caps->machineTypes[0]) * defIdx);
        memmove(caps->machineAliases + 1,
                caps->machineAliases,
                sizeof(caps->machineAliases[0]) * defIdx);
        caps->machineTypes[0] = name;
        caps->machineAliases[0] = alias;
    }
376 377 378

    return 0;

379
no_memory:
380 381 382 383
    virReportOOMError();
    return -1;
}

384 385
static int
qemuCapsProbeMachineTypes(qemuCapsPtr caps)
386 387
{
    char *output;
388 389
    int ret = -1;
    virCommandPtr cmd;
390
    int status;
391

392 393 394 395
    /* 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.
     */
396 397 398
    if (!virFileIsExecutable(caps->binary)) {
        virReportSystemError(errno, _("Cannot find QEMU binary %s"),
                             caps->binary);
399 400 401
        return -1;
    }

402
    cmd = qemuCapsProbeCommand(caps->binary, caps);
403
    virCommandAddArgList(cmd, "-M", "?", NULL);
404
    virCommandSetOutputBuffer(cmd, &output);
405

406 407
    /* Ignore failure from older qemu that did not understand '-M ?'.  */
    if (virCommandRun(cmd, &status) < 0)
408 409
        goto cleanup;

410
    if (qemuCapsParseMachineTypesStr(output, caps) < 0)
411
        goto cleanup;
412 413 414 415

    ret = 0;

cleanup:
416 417
    VIR_FREE(output);
    virCommandFree(cmd);
418 419 420 421 422 423 424

    return ret;
}


typedef int
(*qemuCapsParseCPUModels)(const char *output,
425
                          qemuCapsPtr caps);
426 427 428 429 430 431 432 433

/* Format:
 *      <arch> <model>
 * qemu-0.13 encloses some model names in []:
 *      <arch> [<model>]
 */
static int
qemuCapsParseX86Models(const char *output,
434
                       qemuCapsPtr caps)
435 436 437
{
    const char *p = output;
    const char *next;
438
    int ret = -1;
439 440 441

    do {
        const char *t;
442
        size_t len;
443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459

        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;

460 461 462 463
        if (VIR_EXPAND_N(caps->cpuDefinitions, caps->ncpuDefinitions, 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
464

465 466 467 468
        if (next)
            len = next - p - 1;
        else
            len = strlen(p);
469

470 471 472 473
        if (len > 2 && *p == '[' && p[len - 1] == ']') {
            p++;
            len -= 2;
        }
474

475 476 477
        if (!(caps->cpuDefinitions[caps->ncpuDefinitions - 1] = strndup(p, len))) {
            virReportOOMError();
            goto cleanup;
478 479 480
        }
    } while ((p = next));

481
    ret = 0;
482

483 484
cleanup:
    return ret;
485 486
}

P
Prerna Saxena 已提交
487 488 489 490 491
/* ppc64 parser.
 * Format : PowerPC <machine> <description>
 */
static int
qemuCapsParsePPCModels(const char *output,
492
                       qemuCapsPtr caps)
P
Prerna Saxena 已提交
493 494 495
{
    const char *p = output;
    const char *next;
496
    int ret = -1;
P
Prerna Saxena 已提交
497 498 499

    do {
        const char *t;
500
        size_t len;
P
Prerna Saxena 已提交
501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520

        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;

521 522 523 524
        if (VIR_EXPAND_N(caps->cpuDefinitions, caps->ncpuDefinitions, 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
P
Prerna Saxena 已提交
525

526
        len = t - p - 1;
P
Prerna Saxena 已提交
527

528 529 530
        if (!(caps->cpuDefinitions[caps->ncpuDefinitions - 1] = strndup(p, len))) {
            virReportOOMError();
            goto cleanup;
P
Prerna Saxena 已提交
531 532 533
        }
    } while ((p = next));

534
    ret = 0;
P
Prerna Saxena 已提交
535

536 537
cleanup:
    return ret;
P
Prerna Saxena 已提交
538
}
539

540 541
static int
qemuCapsProbeCPUModels(qemuCapsPtr caps)
542 543 544 545
{
    char *output = NULL;
    int ret = -1;
    qemuCapsParseCPUModels parse;
546
    virCommandPtr cmd;
547

548 549
    if (STREQ(caps->arch, "i686") ||
        STREQ(caps->arch, "x86_64"))
550
        parse = qemuCapsParseX86Models;
551
    else if (STREQ(caps->arch, "ppc64"))
P
Prerna Saxena 已提交
552
        parse = qemuCapsParsePPCModels;
553
    else {
554 555
        VIR_DEBUG("don't know how to parse %s CPU models",
                  caps->arch);
556 557 558
        return 0;
    }

559
    cmd = qemuCapsProbeCommand(caps->binary, caps);
560
    virCommandAddArgList(cmd, "-cpu", "?", NULL);
561
    virCommandSetOutputBuffer(cmd, &output);
562

563
    if (virCommandRun(cmd, NULL) < 0)
564 565
        goto cleanup;

566
    if (parse(output, caps) < 0)
567 568 569 570 571 572
        goto cleanup;

    ret = 0;

cleanup:
    VIR_FREE(output);
573
    virCommandFree(cmd);
574 575 576 577 578 579 580

    return ret;
}


static int
qemuCapsInitGuest(virCapsPtr caps,
581
                  qemuCapsCachePtr cache,
582 583 584 585 586 587 588 589 590 591 592
                  const char *hostmachine,
                  const struct qemu_arch_info *info,
                  int hvm)
{
    virCapsGuestPtr guest;
    int i;
    int haskvm = 0;
    int haskqemu = 0;
    char *kvmbin = NULL;
    char *binary = NULL;
    virCapsGuestMachinePtr *machines = NULL;
593
    size_t nmachines = 0;
594 595
    qemuCapsPtr qemubinCaps = NULL;
    qemuCapsPtr kvmbinCaps = NULL;
596 597 598 599 600 601 602
    int ret = -1;

    /* Check for existance of base emulator, or alternate base
     * which can be used with magic cpu choice
     */
    binary = virFindFileInPath(info->binary);

E
Eric Blake 已提交
603
    if (binary == NULL || !virFileIsExecutable(binary)) {
604 605 606 607
        VIR_FREE(binary);
        binary = virFindFileInPath(info->altbinary);
    }

608
    /* Ignore binary if extracting version info fails */
609 610 611 612 613 614
    if (binary) {
        if (!(qemubinCaps = qemuCapsCacheLookup(cache, binary))) {
            virResetLastError();
            VIR_FREE(binary);
        }
    }
615 616

    /* qemu-kvm/kvm binaries can only be used if
617 618 619 620 621 622 623
     *  - host & guest arches match
     * Or
     *  - hostarch is x86_64 and guest arch is i686
     * The latter simply needs "-cpu qemu32"
     */
    if (STREQ(info->arch, hostmachine) ||
        (STREQ(hostmachine, "x86_64") && STREQ(info->arch, "i686"))) {
624 625 626
        const char *const kvmbins[] = { "/usr/libexec/qemu-kvm", /* RHEL */
                                        "qemu-kvm", /* Fedora */
                                        "kvm" }; /* Upstream .spec */
627

628 629
        for (i = 0; i < ARRAY_CARDINALITY(kvmbins); ++i) {
            kvmbin = virFindFileInPath(kvmbins[i]);
630

631 632
            if (!kvmbin)
                continue;
633

634 635
            if (!(kvmbinCaps = qemuCapsCacheLookup(cache, kvmbin))) {
                virResetLastError();
636 637 638
                VIR_FREE(kvmbin);
                continue;
            }
639

640 641
            if (!binary) {
                binary = kvmbin;
642
                qemubinCaps = kvmbinCaps;
643
                kvmbin = NULL;
644
                kvmbinCaps = NULL;
645
            }
646
            break;
647 648 649 650 651 652
        }
    }

    if (!binary)
        return 0;

653
    if (access("/dev/kvm", F_OK) == 0 &&
654 655
        (qemuCapsGet(qemubinCaps, QEMU_CAPS_KVM) ||
         qemuCapsGet(qemubinCaps, QEMU_CAPS_ENABLE_KVM) ||
656 657 658 659
         kvmbin))
        haskvm = 1;

    if (access("/dev/kqemu", F_OK) == 0 &&
660
        qemuCapsGet(qemubinCaps, QEMU_CAPS_KQEMU))
661
        haskqemu = 1;
J
Jiri Denemark 已提交
662

663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684
    if (info->machine) {
        virCapsGuestMachinePtr machine;

        if (VIR_ALLOC(machine) < 0) {
            goto no_memory;
        }

        if (!(machine->name = strdup(info->machine))) {
            VIR_FREE(machine);
            goto no_memory;
        }

        nmachines = 1;

        if (VIR_ALLOC_N(machines, nmachines) < 0) {
            VIR_FREE(machine->name);
            VIR_FREE(machine);
            goto no_memory;
        }

        machines[0] = machine;
    } else {
685
        if (qemuCapsGetMachineTypesCaps(qemubinCaps, &nmachines, &machines) < 0)
686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704
            goto error;
    }

    /* We register kvm as the base emulator too, since we can
     * just give -no-kvm to disable acceleration if required */
    if ((guest = virCapabilitiesAddGuest(caps,
                                         hvm ? "hvm" : "xen",
                                         info->arch,
                                         info->wordsize,
                                         binary,
                                         NULL,
                                         nmachines,
                                         machines)) == NULL)
        goto error;

    machines = NULL;
    nmachines = 0;

    if (caps->host.cpu &&
705
        qemuCapsGetCPUDefinitions(qemubinCaps, NULL) > 0 &&
706 707 708
        !virCapabilitiesAddGuestFeature(guest, "cpuselection", 1, 0))
        goto error;

709
    if (qemuCapsGet(qemubinCaps, QEMU_CAPS_BOOTINDEX) &&
J
Jiri Denemark 已提交
710
        !virCapabilitiesAddGuestFeature(guest, "deviceboot", 1, 0))
711 712
        goto error;

713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733
    if (hvm) {
        if (virCapabilitiesAddGuestDomain(guest,
                                          "qemu",
                                          NULL,
                                          NULL,
                                          0,
                                          NULL) == NULL)
            goto error;

        if (haskqemu &&
            virCapabilitiesAddGuestDomain(guest,
                                          "kqemu",
                                          NULL,
                                          NULL,
                                          0,
                                          NULL) == NULL)
            goto error;

        if (haskvm) {
            virCapsGuestDomainPtr dom;

734 735 736
            if (kvmbin &&
                qemuCapsGetMachineTypesCaps(kvmbinCaps, &nmachines, &machines) < 0)
                goto error;
737 738 739

            if ((dom = virCapabilitiesAddGuestDomain(guest,
                                                     "kvm",
740
                                                     kvmbin ? kvmbin : binary,
741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773
                                                     NULL,
                                                     nmachines,
                                                     machines)) == NULL) {
                goto error;
            }

            machines = NULL;
            nmachines = 0;

        }
    } else {
        if (virCapabilitiesAddGuestDomain(guest,
                                          "kvm",
                                          NULL,
                                          NULL,
                                          0,
                                          NULL) == NULL)
            goto error;
    }

    if (info->nflags) {
        for (i = 0 ; i < info->nflags ; i++) {
            if (virCapabilitiesAddGuestFeature(guest,
                                               info->flags[i].name,
                                               info->flags[i].default_on,
                                               info->flags[i].toggle) == NULL)
                goto error;
        }
    }

    ret = 0;

cleanup:
774 775
    VIR_FREE(binary);
    VIR_FREE(kvmbin);
776 777
    virObjectUnref(qemubinCaps);
    virObjectUnref(kvmbinCaps);
778 779 780 781 782 783 784 785 786 787 788 789 790 791 792

    return ret;

no_memory:
    virReportOOMError();

error:
    virCapabilitiesFreeMachines(machines, nmachines);

    goto cleanup;
}


static int
qemuCapsInitCPU(virCapsPtr caps,
793
                const char *arch)
794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832
{
    virCPUDefPtr cpu = NULL;
    union cpuData *data = NULL;
    virNodeInfo nodeinfo;
    int ret = -1;

    if (VIR_ALLOC(cpu) < 0
        || !(cpu->arch = strdup(arch))) {
        virReportOOMError();
        goto error;
    }

    if (nodeGetInfo(NULL, &nodeinfo))
        goto error;

    cpu->type = VIR_CPU_TYPE_HOST;
    cpu->sockets = nodeinfo.sockets;
    cpu->cores = nodeinfo.cores;
    cpu->threads = nodeinfo.threads;

    if (!(data = cpuNodeData(arch))
        || cpuDecode(cpu, data, NULL, 0, NULL) < 0)
        goto error;

    caps->host.cpu = cpu;

    ret = 0;

cleanup:
    cpuDataFree(arch, data);

    return ret;

error:
    virCPUDefFree(cpu);
    goto cleanup;
}


833 834 835 836 837 838
static int qemuDefaultConsoleType(const char *ostype ATTRIBUTE_UNUSED)
{
    return VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_SERIAL;
}


839
virCapsPtr qemuCapsInit(qemuCapsCachePtr cache)
840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861
{
    struct utsname utsname;
    virCapsPtr caps;
    int i;
    char *xenner = NULL;

    /* Really, this never fails - look at the man-page. */
    uname (&utsname);

    if ((caps = virCapabilitiesNew(utsname.machine,
                                   1, 1)) == NULL)
        goto no_memory;

    /* Using KVM's mac prefix for QEMU too */
    virCapabilitiesSetMacPrefix(caps, (unsigned char[]){ 0x52, 0x54, 0x00 });

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

865 866
    if (qemuCapsInitCPU(caps, utsname.machine) < 0)
        VIR_WARN("Failed to get host CPU");
867

868 869
    /* Add the power management features of the host */

870
    if (virNodeSuspendGetTargetMask(&caps->host.powerMgmt) < 0)
871 872
        VIR_WARN("Failed to get host power management capabilities");

873 874 875 876 877
    virCapabilitiesAddHostMigrateTransport(caps,
                                           "tcp");

    /* First the pure HVM guests */
    for (i = 0 ; i < ARRAY_CARDINALITY(arch_info_hvm) ; i++)
878
        if (qemuCapsInitGuest(caps, cache,
879 880 881 882 883 884 885
                              utsname.machine,
                              &arch_info_hvm[i], 1) < 0)
            goto no_memory;

    /* Then possibly the Xen paravirt guests (ie Xenner */
    xenner = virFindFileInPath("xenner");

E
Eric Blake 已提交
886
    if (xenner != NULL && virFileIsExecutable(xenner) == 0 &&
887 888 889 890 891 892
        access("/dev/kvm", F_OK) == 0) {
        for (i = 0 ; i < ARRAY_CARDINALITY(arch_info_xen) ; i++)
            /* Allow Xen 32-on-32, 32-on-64 and 64-on-64 */
            if (STREQ(arch_info_xen[i].arch, utsname.machine) ||
                (STREQ(utsname.machine, "x86_64") &&
                 STREQ(arch_info_xen[i].arch, "i686"))) {
893
                if (qemuCapsInitGuest(caps, cache,
894 895 896 897 898 899 900 901 902 903 904
                                      utsname.machine,
                                      &arch_info_xen[i], 0) < 0)
                    goto no_memory;
            }
    }

    VIR_FREE(xenner);

    /* QEMU Requires an emulator in the XML */
    virCapabilitiesSetEmulatorRequired(caps);

905
    caps->defaultConsoleTargetType = qemuDefaultConsoleType;
906 907 908 909 910 911 912 913 914 915

    return caps;

 no_memory:
    VIR_FREE(xenner);
    virCapabilitiesFree(caps);
    return NULL;
}


916
static int
917 918 919
qemuCapsComputeCmdFlags(const char *help,
                        unsigned int version,
                        unsigned int is_kvm,
920
                        unsigned int kvm_version,
921
                        qemuCapsPtr caps,
922
                        bool check_yajl ATTRIBUTE_UNUSED)
923 924
{
    const char *p;
R
Richa Marwaha 已提交
925
    const char *fsdev, *netdev;
926 927

    if (strstr(help, "-no-kqemu"))
928
        qemuCapsSet(caps, QEMU_CAPS_KQEMU);
929
    if (strstr(help, "-enable-kqemu"))
930
        qemuCapsSet(caps, QEMU_CAPS_ENABLE_KQEMU);
931
    if (strstr(help, "-no-kvm"))
932
        qemuCapsSet(caps, QEMU_CAPS_KVM);
933
    if (strstr(help, "-enable-kvm"))
934
        qemuCapsSet(caps, QEMU_CAPS_ENABLE_KVM);
935
    if (strstr(help, "-no-reboot"))
936
        qemuCapsSet(caps, QEMU_CAPS_NO_REBOOT);
937
    if (strstr(help, "-name")) {
938
        qemuCapsSet(caps, QEMU_CAPS_NAME);
939
        if (strstr(help, ",process="))
940
            qemuCapsSet(caps, QEMU_CAPS_NAME_PROCESS);
941 942
    }
    if (strstr(help, "-uuid"))
943
        qemuCapsSet(caps, QEMU_CAPS_UUID);
944
    if (strstr(help, "-xen-domid"))
945
        qemuCapsSet(caps, QEMU_CAPS_XEN_DOMID);
946
    else if (strstr(help, "-domid"))
947
        qemuCapsSet(caps, QEMU_CAPS_DOMID);
948
    if (strstr(help, "-drive")) {
949 950
        const char *cache = strstr(help, "cache=");

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

974
        qemuCapsSet(caps, QEMU_CAPS_VGA);
975 976

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

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

    if (strstr(help, "-sdl"))
1057
        qemuCapsSet(caps, QEMU_CAPS_SDL);
1058 1059 1060
    if (strstr(help, "cores=") &&
        strstr(help, "threads=") &&
        strstr(help, "sockets="))
1061
        qemuCapsSet(caps, QEMU_CAPS_SMP_TOPOLOGY);
1062 1063

    if (version >= 9000)
1064
        qemuCapsSet(caps, QEMU_CAPS_VNC_COLON);
1065 1066

    if (is_kvm && (version >= 10000 || kvm_version >= 74))
1067
        qemuCapsSet(caps, QEMU_CAPS_VNET_HDR);
1068

1069
    if (strstr(help, ",vhost=")) {
1070
        qemuCapsSet(caps, QEMU_CAPS_VHOST_NET);
1071 1072
    }

1073 1074
    /* 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
1075
     * 0.14.* and 0.15.0)
1076
     */
1077
    if (strstr(help, "-no-shutdown") && (version < 14000 || version > 15000))
1078
        qemuCapsSet(caps, QEMU_CAPS_NO_SHUTDOWN);
1079

1080 1081 1082
    if (strstr(help, "dump-guest-core=on|off"))
        qemuCapsSet(caps, QEMU_CAPS_DUMP_GUEST_CORE);

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

    if (version >= 10000)
1111
        qemuCapsSet(caps, QEMU_CAPS_0_10);
1112

1113
    if (version >= 11000)
1114
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_BLK_SG_IO);
1115

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

    if (version >= 13000)
1155
        qemuCapsSet(caps, QEMU_CAPS_PCI_MULTIFUNCTION);
1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167

    /* 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)
1168
        qemuCapsSet(caps, QEMU_CAPS_PCI_ROMBAR);
1169 1170

    if (version >= 11000)
1171
        qemuCapsSet(caps, QEMU_CAPS_CPU_HOST);
1172
    return 0;
1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200
}

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

int qemuCapsParseHelpStr(const char *qemu,
                         const char *help,
1201
                         qemuCapsPtr caps,
1202 1203
                         unsigned int *version,
                         unsigned int *is_kvm,
1204 1205
                         unsigned int *kvm_version,
                         bool check_yajl)
1206 1207 1208
{
    unsigned major, minor, micro;
    const char *p = help;
1209
    char *strflags;
1210

1211
    *version = *is_kvm = *kvm_version = 0;
1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228

    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 已提交
1229
    if (minor == -1)
1230 1231
        goto fail;

J
Jiri Denemark 已提交
1232 1233 1234 1235 1236 1237 1238 1239
    if (*p != '.') {
        micro = 0;
    } else {
        ++p;
        micro = virParseNumber(&p);
        if (micro == -1)
            goto fail;
    }
1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260

    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;

1261
    if (qemuCapsComputeCmdFlags(help, *version, *is_kvm, *kvm_version,
1262
                                caps, check_yajl) < 0)
1263
        goto cleanup;
1264

1265
    strflags = virBitmapString(caps->flags);
1266 1267 1268
    VIR_DEBUG("Version %u.%u.%u, cooked version %u, flags %s",
              major, minor, micro, *version, NULLSTR(strflags));
    VIR_FREE(strflags);
1269 1270 1271 1272 1273 1274 1275 1276 1277 1278

    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');
1279 1280
    if (!p)
        p = strchr(help, '\0');
1281

1282 1283 1284
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("cannot parse %s version number in '%.*s'"),
                   qemu, (int) (p - help), help);
1285

1286
cleanup:
1287 1288 1289
    return -1;
}

E
Eric Blake 已提交
1290 1291
static int
qemuCapsExtractDeviceStr(const char *qemu,
1292
                         qemuCapsPtr caps)
1293
{
E
Eric Blake 已提交
1294
    char *output = NULL;
1295
    virCommandPtr cmd;
E
Eric Blake 已提交
1296
    int ret = -1;
1297

E
Eric Blake 已提交
1298 1299
    /* Cram together all device-related queries into one invocation;
     * the output format makes it possible to distinguish what we
1300 1301
     * need.  With qemu 0.13.0 and later, unrecognized '-device
     * bogus,?' cause an error in isolation, but are silently ignored
1302
     * in combination with '-device ?'.  Upstream qemu 0.12.x doesn't
1303 1304
     * understand '-device name,?', and always exits with status 1 for
     * the simpler '-device ?', so this function is really only useful
1305
     * if -help includes "device driver,?".  */
1306
    cmd = qemuCapsProbeCommand(qemu, caps);
1307 1308 1309 1310 1311 1312
    virCommandAddArgList(cmd,
                         "-device", "?",
                         "-device", "pci-assign,?",
                         "-device", "virtio-blk-pci,?",
                         "-device", "virtio-net-pci,?",
                         "-device", "scsi-disk,?",
1313
                         "-device", "PIIX4_PM,?",
1314
                         "-device", "usb-redir,?",
1315
                         "-device", "ide-drive,?",
1316
                         NULL);
1317
    /* qemu -help goes to stdout, but qemu -device ? goes to stderr.  */
E
Eric Blake 已提交
1318
    virCommandSetErrorBuffer(cmd, &output);
1319

1320
    if (virCommandRun(cmd, NULL) < 0)
1321 1322
        goto cleanup;

1323
    ret = qemuCapsParseDeviceStr(output, caps);
1324 1325

cleanup:
E
Eric Blake 已提交
1326
    VIR_FREE(output);
1327
    virCommandFree(cmd);
E
Eric Blake 已提交
1328 1329 1330 1331 1332
    return ret;
}


int
1333
qemuCapsParseDeviceStr(const char *str, qemuCapsPtr caps)
E
Eric Blake 已提交
1334
{
1335 1336
    /* Which devices exist. */
    if (strstr(str, "name \"hda-duplex\""))
1337
        qemuCapsSet(caps, QEMU_CAPS_HDA_DUPLEX);
M
Marc-André Lureau 已提交
1338
    if (strstr(str, "name \"hda-micro\""))
1339
        qemuCapsSet(caps, QEMU_CAPS_HDA_MICRO);
1340
    if (strstr(str, "name \"ccid-card-emulated\""))
1341
        qemuCapsSet(caps, QEMU_CAPS_CCID_EMULATED);
1342
    if (strstr(str, "name \"ccid-card-passthru\""))
1343
        qemuCapsSet(caps, QEMU_CAPS_CCID_PASSTHRU);
1344 1345

    if (strstr(str, "name \"piix3-usb-uhci\""))
1346
        qemuCapsSet(caps, QEMU_CAPS_PIIX3_USB_UHCI);
1347
    if (strstr(str, "name \"piix4-usb-uhci\""))
1348
        qemuCapsSet(caps, QEMU_CAPS_PIIX4_USB_UHCI);
1349
    if (strstr(str, "name \"usb-ehci\""))
1350
        qemuCapsSet(caps, QEMU_CAPS_USB_EHCI);
1351
    if (strstr(str, "name \"ich9-usb-ehci1\""))
1352
        qemuCapsSet(caps, QEMU_CAPS_ICH9_USB_EHCI1);
1353
    if (strstr(str, "name \"vt82c686b-usb-uhci\""))
1354
        qemuCapsSet(caps, QEMU_CAPS_VT82C686B_USB_UHCI);
1355
    if (strstr(str, "name \"pci-ohci\""))
1356
        qemuCapsSet(caps, QEMU_CAPS_PCI_OHCI);
G
Gerd Hoffmann 已提交
1357
    if (strstr(str, "name \"nec-usb-xhci\""))
1358
        qemuCapsSet(caps, QEMU_CAPS_NEC_USB_XHCI);
1359
    if (strstr(str, "name \"usb-redir\""))
1360
        qemuCapsSet(caps, QEMU_CAPS_USB_REDIR);
1361
    if (strstr(str, "usb-redir.filter"))
1362
        qemuCapsSet(caps, QEMU_CAPS_USB_REDIR_FILTER);
M
Marc-André Lureau 已提交
1363
    if (strstr(str, "name \"usb-hub\""))
1364
        qemuCapsSet(caps, QEMU_CAPS_USB_HUB);
J
Jim Fehlig 已提交
1365
    if (strstr(str, "name \"ich9-ahci\""))
1366
        qemuCapsSet(caps, QEMU_CAPS_ICH9_AHCI);
1367 1368 1369
    if (strstr(str, "name \"virtio-blk-s390\"") ||
        strstr(str, "name \"virtio-net-s390\"") ||
        strstr(str, "name \"virtio-serial-s390\""))
1370
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_S390);
1371

1372
    if (strstr(str, "name \"lsi53c895a\""))
1373
        qemuCapsSet(caps, QEMU_CAPS_SCSI_LSI);
1374
    if (strstr(str, "name \"virtio-scsi-pci\""))
1375
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_SCSI_PCI);
1376

1377
    /* Prefer -chardev spicevmc (detected earlier) over -device spicevmc */
1378
    if (!qemuCapsGet(caps, QEMU_CAPS_CHARDEV_SPICEVMC) &&
1379
        strstr(str, "name \"spicevmc\""))
1380
        qemuCapsSet(caps, QEMU_CAPS_DEVICE_SPICEVMC);
1381 1382

    /* Features of given devices. */
E
Eric Blake 已提交
1383
    if (strstr(str, "pci-assign.configfd"))
1384
        qemuCapsSet(caps, QEMU_CAPS_PCI_CONFIGFD);
1385
    if (strstr(str, "virtio-blk-pci.multifunction"))
1386
        qemuCapsSet(caps, QEMU_CAPS_PCI_MULTIFUNCTION);
1387
    if (strstr(str, "virtio-blk-pci.bootindex")) {
1388
        qemuCapsSet(caps, QEMU_CAPS_BOOTINDEX);
1389
        if (strstr(str, "pci-assign.bootindex"))
1390
            qemuCapsSet(caps, QEMU_CAPS_PCI_BOOTINDEX);
1391
    }
1392
    if (strstr(str, "virtio-net-pci.tx="))
1393
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_TX_ALG);
1394
    if (strstr(str, "name \"qxl-vga\""))
1395
        qemuCapsSet(caps, QEMU_CAPS_DEVICE_QXL_VGA);
1396
    if (strstr(str, "virtio-blk-pci.ioeventfd"))
1397
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_IOEVENTFD);
M
Michal Privoznik 已提交
1398
    if (strstr(str, "name \"sga\""))
1399
        qemuCapsSet(caps, QEMU_CAPS_SGA);
1400
    if (strstr(str, "virtio-blk-pci.event_idx"))
1401
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_BLK_EVENT_IDX);
1402
    if (strstr(str, "virtio-net-pci.event_idx"))
1403
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_NET_EVENT_IDX);
1404
    if (strstr(str, "virtio-blk-pci.scsi"))
1405
        qemuCapsSet(caps, QEMU_CAPS_VIRTIO_BLK_SCSI);
1406
    if (strstr(str, "scsi-disk.channel"))
1407
        qemuCapsSet(caps, QEMU_CAPS_SCSI_DISK_CHANNEL);
1408 1409
    if (strstr(str, "scsi-disk.wwn"))
        qemuCapsSet(caps, QEMU_CAPS_SCSI_DISK_WWN);
1410
    if (strstr(str, "scsi-block"))
1411
        qemuCapsSet(caps, QEMU_CAPS_SCSI_BLOCK);
1412
    if (strstr(str, "scsi-cd"))
1413
        qemuCapsSet(caps, QEMU_CAPS_SCSI_CD);
1414
    if (strstr(str, "ide-cd"))
1415
        qemuCapsSet(caps, QEMU_CAPS_IDE_CD);
1416 1417 1418
    if (strstr(str, "ide-drive.wwn"))
        qemuCapsSet(caps, QEMU_CAPS_IDE_DRIVE_WWN);

1419 1420 1421 1422 1423 1424 1425 1426 1427
    /*
     * the iolimit detection is not really straight forward:
     * in qemu this is a capability of the block layer, if
     * present any of -device scsi-disk, virtio-blk-*, ...
     * will offer to specify logical and physical block size
     * and other properties...
     */
    if (strstr(str, ".logical_block_size") &&
        strstr(str, ".physical_block_size"))
1428
        qemuCapsSet(caps, QEMU_CAPS_BLOCKIO);
1429
    if (strstr(str, "PIIX4_PM.disable_s3="))
1430
        qemuCapsSet(caps, QEMU_CAPS_DISABLE_S3);
1431
    if (strstr(str, "PIIX4_PM.disable_s4="))
1432
        qemuCapsSet(caps, QEMU_CAPS_DISABLE_S4);
E
Eric Blake 已提交
1433 1434

    return 0;
1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451
}


static void
uname_normalize (struct utsname *ut)
{
    uname(ut);

    /* Map i386, i486, i586 to i686.  */
    if (ut->machine[0] == 'i' &&
        ut->machine[1] != '\0' &&
        ut->machine[2] == '8' &&
        ut->machine[3] == '6' &&
        ut->machine[4] == '\0')
        ut->machine[1] = '6';
}

1452 1453 1454
int qemuCapsGetDefaultVersion(virCapsPtr caps,
                              qemuCapsCachePtr capsCache,
                              unsigned int *version)
1455 1456 1457
{
    const char *binary;
    struct utsname ut;
1458
    qemuCapsPtr qemucaps;
1459 1460 1461 1462 1463 1464 1465 1466 1467

    if (*version > 0)
        return 0;

    uname_normalize(&ut);
    if ((binary = virCapabilitiesDefaultGuestEmulator(caps,
                                                      "hvm",
                                                      ut.machine,
                                                      "qemu")) == NULL) {
1468 1469
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Cannot find suitable emulator for %s"), ut.machine);
1470 1471 1472
        return -1;
    }

1473
    if (!(qemucaps = qemuCapsCacheLookup(capsCache, binary)))
1474 1475
        return -1;

1476 1477
    *version = qemuCapsGetVersion(qemucaps);
    virObjectUnref(qemucaps);
1478 1479
    return 0;
}
1480 1481


1482 1483 1484


qemuCapsPtr
1485 1486
qemuCapsNew(void)
{
1487
    qemuCapsPtr caps;
1488

1489 1490 1491 1492 1493 1494
    if (qemuCapsInitialize() < 0)
        return NULL;

    if (!(caps = virObjectNew(qemuCapsClass)))
        return NULL;

1495
    if (!(caps->flags = virBitmapNew(QEMU_CAPS_LAST)))
1496
        goto no_memory;
1497 1498

    return caps;
1499 1500 1501 1502 1503

no_memory:
    virReportOOMError();
    virObjectUnref(caps);
    return NULL;
1504 1505 1506
}


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
qemuCapsPtr qemuCapsNewCopy(qemuCapsPtr caps)
{
    qemuCapsPtr ret = qemuCapsNew();
    size_t i;

    if (!ret)
        return NULL;

    virBitmapCopy(ret->flags, caps->flags);

    ret->version = caps->version;
    ret->kvmVersion = caps->kvmVersion;

    if (caps->arch &&
        !(ret->arch = strdup(caps->arch)))
        goto no_memory;

    if (VIR_ALLOC_N(ret->cpuDefinitions, caps->ncpuDefinitions) < 0)
        goto no_memory;
    ret->ncpuDefinitions = caps->ncpuDefinitions;
    for (i = 0 ; i < caps->ncpuDefinitions ; i++) {
        if (!(ret->cpuDefinitions[i] = strdup(caps->cpuDefinitions[i])))
            goto no_memory;
    }

    if (VIR_ALLOC_N(ret->machineTypes, caps->nmachineTypes) < 0)
        goto no_memory;
    if (VIR_ALLOC_N(ret->machineAliases, caps->nmachineTypes) < 0)
        goto no_memory;
    ret->nmachineTypes = caps->nmachineTypes;
    for (i = 0 ; i < caps->nmachineTypes ; i++) {
        if (!(ret->machineTypes[i] = strdup(caps->machineTypes[i])))
            goto no_memory;
        if (caps->machineAliases[i] &&
            !(ret->machineAliases[i] = strdup(caps->machineAliases[i])))
            goto no_memory;
    }

    return ret;

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


1554 1555 1556
void qemuCapsDispose(void *obj)
{
    qemuCapsPtr caps = obj;
1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571
    size_t i;

    VIR_FREE(caps->arch);

    for (i = 0 ; i < caps->nmachineTypes ; i++) {
        VIR_FREE(caps->machineTypes[i]);
        VIR_FREE(caps->machineAliases[i]);
    }
    VIR_FREE(caps->machineTypes);
    VIR_FREE(caps->machineAliases);

    for (i = 0 ; i < caps->ncpuDefinitions ; i++) {
        VIR_FREE(caps->cpuDefinitions[i]);
    }
    VIR_FREE(caps->cpuDefinitions);
1572 1573

    virBitmapFree(caps->flags);
1574 1575

    VIR_FREE(caps->binary);
1576 1577
}

1578
void
1579
qemuCapsSet(qemuCapsPtr caps,
1580 1581
            enum qemuCapsFlags flag)
{
1582
    ignore_value(virBitmapSetBit(caps->flags, flag));
1583 1584 1585 1586
}


void
1587
qemuCapsSetList(qemuCapsPtr caps, ...)
1588 1589 1590 1591 1592 1593
{
    va_list list;
    int flag;

    va_start(list, caps);
    while ((flag = va_arg(list, int)) < QEMU_CAPS_LAST)
1594
        ignore_value(virBitmapSetBit(caps->flags, flag));
1595
    va_end(list);
1596 1597 1598 1599
}


void
1600
qemuCapsClear(qemuCapsPtr caps,
1601 1602
              enum qemuCapsFlags flag)
{
1603 1604 1605 1606 1607 1608 1609
    ignore_value(virBitmapClearBit(caps->flags, flag));
}


char *qemuCapsFlagsString(qemuCapsPtr caps)
{
    return virBitmapString(caps->flags);
1610 1611 1612 1613
}


bool
1614
qemuCapsGet(qemuCapsPtr caps,
1615 1616
            enum qemuCapsFlags flag)
{
1617 1618
    bool b;

1619
    if (!caps || virBitmapGetBit(caps->flags, flag, &b) < 0)
1620 1621 1622
        return false;
    else
        return b;
1623
}
1624 1625


1626 1627 1628 1629 1630
const char *qemuCapsGetBinary(qemuCapsPtr caps)
{
    return caps->binary;
}

1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648
const char *qemuCapsGetArch(qemuCapsPtr caps)
{
    return caps->arch;
}


unsigned int qemuCapsGetVersion(qemuCapsPtr caps)
{
    return caps->version;
}


unsigned int qemuCapsGetKVMVersion(qemuCapsPtr caps)
{
    return caps->kvmVersion;
}


1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666
int qemuCapsAddCPUDefinition(qemuCapsPtr caps,
                             const char *name)
{
    char *tmp = strdup(name);
    if (!tmp) {
        virReportOOMError();
        return -1;
    }
    if (VIR_EXPAND_N(caps->cpuDefinitions, caps->ncpuDefinitions, 1) < 0) {
        VIR_FREE(tmp);
        virReportOOMError();
        return -1;
    }
    caps->cpuDefinitions[caps->ncpuDefinitions-1] = tmp;
    return 0;
}


1667 1668 1669
size_t qemuCapsGetCPUDefinitions(qemuCapsPtr caps,
                                 char ***names)
{
1670 1671
    if (names)
        *names = caps->cpuDefinitions;
1672 1673 1674 1675 1676 1677 1678
    return caps->ncpuDefinitions;
}


size_t qemuCapsGetMachineTypes(qemuCapsPtr caps,
                               char ***names)
{
1679 1680
    if (names)
        *names = caps->machineTypes;
1681 1682 1683
    return caps->nmachineTypes;
}

1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722
int qemuCapsGetMachineTypesCaps(qemuCapsPtr caps,
                                size_t *nmachines,
                                virCapsGuestMachinePtr **machines)
{
    size_t i;

    *nmachines = 0;
    *machines = NULL;
    if (VIR_ALLOC_N(*machines, caps->nmachineTypes) < 0)
        goto no_memory;
    *nmachines = caps->nmachineTypes;

    for (i = 0 ; i < caps->nmachineTypes ; i++) {
        virCapsGuestMachinePtr mach;
        if (VIR_ALLOC(mach) < 0)
            goto no_memory;
        if (caps->machineAliases[i]) {
            if (!(mach->name = strdup(caps->machineAliases[i])))
                goto no_memory;
            if (!(mach->canonical = strdup(caps->machineTypes[i])))
                goto no_memory;
        } else {
            if (!(mach->name = strdup(caps->machineTypes[i])))
                goto no_memory;
        }
        (*machines)[i] = mach;
    }

    return 0;

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



1723 1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738

const char *qemuCapsGetCanonicalMachine(qemuCapsPtr caps,
                                        const char *name)

{
    size_t i;

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

    return name;
}
1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758


#define QEMU_SYSTEM_PREFIX "qemu-system-"

qemuCapsPtr qemuCapsNewForBinary(const char *binary)
{
    qemuCapsPtr caps = qemuCapsNew();
    const char *tmp;
    struct utsname ut;
    unsigned int is_kvm;
    char *help = NULL;
    virCommandPtr cmd = NULL;
    struct stat sb;

    if (!(caps->binary = strdup(binary)))
        goto no_memory;

    tmp = strstr(binary, QEMU_SYSTEM_PREFIX);
    if (tmp) {
        tmp += strlen(QEMU_SYSTEM_PREFIX);
1759 1760 1761 1762

        /* For historical compat we use 'itanium' as arch name */
        if (STREQ(tmp, "ia64"))
            tmp = "itanium";
1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818
    } else {
        uname_normalize(&ut);
        tmp = ut.machine;
    }
    if (!(caps->arch = strdup(tmp)))
        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;
    }
    caps->mtime = sb.st_mtime;

    /* 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)) {
        goto error;
    }

    cmd = qemuCapsProbeCommand(binary, NULL);
    virCommandAddArgList(cmd, "-help", NULL);
    virCommandSetOutputBuffer(cmd, &help);

    if (virCommandRun(cmd, NULL) < 0)
        goto error;

    if (qemuCapsParseHelpStr(binary, help, caps,
                             &caps->version,
                             &is_kvm,
                             &caps->kvmVersion,
                             false) < 0)
        goto error;

    /* Currently only x86_64 and i686 support PCI-multibus. */
    if (STREQLEN(caps->arch, "x86_64", 6) ||
        STREQLEN(caps->arch, "i686", 4)) {
        qemuCapsSet(caps, QEMU_CAPS_PCI_MULTIBUS);
    }

    /* S390 and probably other archs do not support no-acpi -
       maybe the qemu option parsing should be re-thought. */
    if (STRPREFIX(caps->arch, "s390"))
        qemuCapsClear(caps, QEMU_CAPS_NO_ACPI);

    /* qemuCapsExtractDeviceStr will only set additional caps if qemu
     * understands the 0.13.0+ notion of "-device driver,".  */
    if (qemuCapsGet(caps, QEMU_CAPS_DEVICE) &&
        strstr(help, "-device driver,?") &&
        qemuCapsExtractDeviceStr(binary, caps) < 0)
        goto error;

1819
    if (qemuCapsProbeCPUModels(caps) < 0)
1820 1821
        goto error;

1822
    if (qemuCapsProbeMachineTypes(caps) < 0)
1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850
        goto error;

cleanup:
    VIR_FREE(help);
    virCommandFree(cmd);
    return caps;

no_memory:
    virReportOOMError();
error:
    virObjectUnref(caps);
    caps = NULL;
    goto cleanup;
}


bool qemuCapsIsValid(qemuCapsPtr caps)
{
    struct stat sb;

    if (!caps->binary)
        return true;

    if (stat(caps->binary, &sb) < 0)
        return false;

    return sb.st_mtime == caps->mtime;
}
1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945


static void
qemuCapsHashDataFree(void *payload, const void *key ATTRIBUTE_UNUSED)
{
    virObjectUnref(payload);
}


qemuCapsCachePtr
qemuCapsCacheNew(void)
{
    qemuCapsCachePtr cache;

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

    if (!(cache->binaries = virHashCreate(10, qemuCapsHashDataFree)))
        goto error;

    return cache;

error:
    qemuCapsCacheFree(cache);
    return NULL;
}


qemuCapsPtr
qemuCapsCacheLookup(qemuCapsCachePtr cache, const char *binary)
{
    qemuCapsPtr ret = NULL;
    virMutexLock(&cache->lock);
    ret = virHashLookup(cache->binaries, binary);
    if (ret &&
        !qemuCapsIsValid(ret)) {
        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);
        ret = qemuCapsNewForBinary(binary);
        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;
}


qemuCapsPtr
qemuCapsCacheLookupCopy(qemuCapsCachePtr cache, const char *binary)
{
    qemuCapsPtr caps = qemuCapsCacheLookup(cache, binary);
    qemuCapsPtr ret;

    if (!caps)
        return NULL;

    ret = qemuCapsNewCopy(caps);
    virObjectUnref(caps);
    return ret;
}


void
qemuCapsCacheFree(qemuCapsCachePtr cache)
{
    if (!cache)
        return;

    virHashFree(cache->binaries);
    virMutexDestroy(&cache->lock);
    VIR_FREE(cache);
}