capabilities.c 30.0 KB
Newer Older
1 2 3
/*
 * capabilities.c: hypervisor capabilities
 *
4
 * Copyright (C) 2006-2008, 2010-2011, 2013 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17
 * Copyright (C) 2006-2008 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
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

24 25
#include <config.h>

26 27
#include <strings.h>

28
#include "capabilities.h"
29
#include "virbuffer.h"
30
#include "viralloc.h"
31
#include "viruuid.h"
32
#include "cpu_conf.h"
33
#include "virerror.h"
34
#include "virstring.h"
35 36 37

#define VIR_FROM_THIS VIR_FROM_CAPABILITIES

38 39
VIR_ENUM_DECL(virCapsHostPMTarget)
VIR_ENUM_IMPL(virCapsHostPMTarget, VIR_NODE_SUSPEND_TARGET_LAST,
40
              "suspend_mem", "suspend_disk", "suspend_hybrid");
41

42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57
static virClassPtr virCapsClass;
static void virCapabilitiesDispose(void *obj);

static int virCapabilitiesOnceInit(void)
{
    if (!(virCapsClass = virClassNew(virClassForObject(),
                                     "virCaps",
                                     sizeof(virCaps),
                                     virCapabilitiesDispose)))
        return -1;

    return 0;
}

VIR_ONCE_GLOBAL_INIT(virCapabilities)

58 59
/**
 * virCapabilitiesNew:
60
 * @hostarch: host machine architecture
61 62
 * @offlineMigrate: non-zero if offline migration is available
 * @liveMigrate: non-zero if live migration is available
63
 *
64 65 66
 * Allocate a new capabilities object
 */
virCapsPtr
67
virCapabilitiesNew(virArch hostarch,
68 69 70 71 72
                   int offlineMigrate,
                   int liveMigrate)
{
    virCapsPtr caps;

73 74 75 76
    if (virCapabilitiesInitialize() < 0)
        return NULL;

    if (!(caps = virObjectNew(virCapsClass)))
77
        return NULL;
78

79
    caps->host.arch = hostarch;
80 81 82 83 84 85
    caps->host.offlineMigrate = offlineMigrate;
    caps->host.liveMigrate = liveMigrate;

    return caps;
}

86 87 88 89 90 91 92 93 94 95 96 97 98 99 100
void
virCapabilitiesClearHostNUMACellCPUTopology(virCapsHostNUMACellCPUPtr cpus,
                                            size_t ncpus)
{
    size_t i;

    if (!cpus)
        return;

    for (i = 0; i < ncpus; i++) {
        virBitmapFree(cpus[i].siblings);
        cpus[i].siblings = NULL;
    }
}

101 102 103
static void
virCapabilitiesFreeHostNUMACell(virCapsHostNUMACellPtr cell)
{
104 105 106
    if (cell == NULL)
        return;

107 108
    virCapabilitiesClearHostNUMACellCPUTopology(cell->cpus, cell->ncpus);

109 110
    VIR_FREE(cell->cpus);
    VIR_FREE(cell);
111 112
}

113 114 115 116 117 118 119 120 121 122
static void
virCapabilitiesFreeGuestMachine(virCapsGuestMachinePtr machine)
{
    if (machine == NULL)
        return;
    VIR_FREE(machine->name);
    VIR_FREE(machine->canonical);
    VIR_FREE(machine);
}

123 124 125
static void
virCapabilitiesFreeGuestDomain(virCapsGuestDomainPtr dom)
{
126
    size_t i;
127 128 129
    if (dom == NULL)
        return;

130 131
    VIR_FREE(dom->info.emulator);
    VIR_FREE(dom->info.loader);
132
    for (i = 0; i < dom->info.nmachines; i++)
133
        virCapabilitiesFreeGuestMachine(dom->info.machines[i]);
134 135
    VIR_FREE(dom->info.machines);
    VIR_FREE(dom->type);
136

137
    VIR_FREE(dom);
138 139 140 141 142
}

static void
virCapabilitiesFreeGuestFeature(virCapsGuestFeaturePtr feature)
{
143 144
    if (feature == NULL)
        return;
145 146
    VIR_FREE(feature->name);
    VIR_FREE(feature);
147 148 149 150 151
}

static void
virCapabilitiesFreeGuest(virCapsGuestPtr guest)
{
152
    size_t i;
153 154 155
    if (guest == NULL)
        return;

156
    VIR_FREE(guest->ostype);
157

158 159
    VIR_FREE(guest->arch.defaultInfo.emulator);
    VIR_FREE(guest->arch.defaultInfo.loader);
160
    for (i = 0; i < guest->arch.defaultInfo.nmachines; i++)
161
        virCapabilitiesFreeGuestMachine(guest->arch.defaultInfo.machines[i]);
162
    VIR_FREE(guest->arch.defaultInfo.machines);
163

164
    for (i = 0; i < guest->arch.ndomains; i++)
165
        virCapabilitiesFreeGuestDomain(guest->arch.domains[i]);
166
    VIR_FREE(guest->arch.domains);
167

168
    for (i = 0; i < guest->nfeatures; i++)
169
        virCapabilitiesFreeGuestFeature(guest->features[i]);
170
    VIR_FREE(guest->features);
171

172
    VIR_FREE(guest);
173 174
}

175 176 177
void
virCapabilitiesFreeNUMAInfo(virCapsPtr caps)
{
178
    size_t i;
179

180
    for (i = 0; i < caps->host.nnumaCell; i++)
181 182
        virCapabilitiesFreeHostNUMACell(caps->host.numaCell[i]);
    VIR_FREE(caps->host.numaCell);
183
    caps->host.nnumaCell = 0;
184
}
185

186 187 188 189 190 191 192 193 194 195 196 197 198 199
static void
virCapabilitiesClearSecModel(virCapsHostSecModelPtr secmodel)
{
    size_t i;
    for (i = 0; i < secmodel->nlabels; i++) {
        VIR_FREE(secmodel->labels[i].type);
        VIR_FREE(secmodel->labels[i].label);
    }

    VIR_FREE(secmodel->labels);
    VIR_FREE(secmodel->model);
    VIR_FREE(secmodel->doi);
}

200 201 202 203
static void
virCapabilitiesDispose(void *object)
{
    virCapsPtr caps = object;
204
    size_t i;
205

206
    for (i = 0; i < caps->nguests; i++)
207
        virCapabilitiesFreeGuest(caps->guests[i]);
208
    VIR_FREE(caps->guests);
209

210
    for (i = 0; i < caps->host.nfeatures; i++)
211 212
        VIR_FREE(caps->host.features[i]);
    VIR_FREE(caps->host.features);
213 214

    virCapabilitiesFreeNUMAInfo(caps);
215

216
    for (i = 0; i < caps->host.nmigrateTrans; i++)
217 218
        VIR_FREE(caps->host.migrateTrans[i]);
    VIR_FREE(caps->host.migrateTrans);
219

220
    for (i = 0; i < caps->host.nsecModels; i++) {
221
        virCapabilitiesClearSecModel(&caps->host.secModels[i]);
222 223 224
    }
    VIR_FREE(caps->host.secModels);

225
    virCPUDefFree(caps->host.cpu);
226 227 228 229 230 231 232 233 234 235 236 237 238 239
}


/**
 * virCapabilitiesAddHostFeature:
 * @caps: capabilities to extend
 * @name: name of new feature
 *
 * Registers a new host CPU feature, eg 'pae', or 'vmx'
 */
int
virCapabilitiesAddHostFeature(virCapsPtr caps,
                              const char *name)
{
E
Eric Blake 已提交
240 241
    if (VIR_RESIZE_N(caps->host.features, caps->host.nfeatures_max,
                     caps->host.nfeatures, 1) < 0)
242 243
        return -1;

244
    if (VIR_STRDUP(caps->host.features[caps->host.nfeatures], name) < 0)
245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261
        return -1;
    caps->host.nfeatures++;

    return 0;
}

/**
 * virCapabilitiesAddHostMigrateTransport:
 * @caps: capabilities to extend
 * @name: name of migration transport
 *
 * Registers a new domain migration transport URI
 */
int
virCapabilitiesAddHostMigrateTransport(virCapsPtr caps,
                                       const char *name)
{
E
Eric Blake 已提交
262 263
    if (VIR_RESIZE_N(caps->host.migrateTrans, caps->host.nmigrateTrans_max,
                     caps->host.nmigrateTrans, 1) < 0)
264 265
        return -1;

266
    if (VIR_STRDUP(caps->host.migrateTrans[caps->host.nmigrateTrans], name) < 0)
267 268 269 270 271 272 273 274 275 276 277 278
        return -1;
    caps->host.nmigrateTrans++;

    return 0;
}


/**
 * virCapabilitiesAddHostNUMACell:
 * @caps: capabilities to extend
 * @num: ID number of NUMA cell
 * @ncpus: number of CPUs in cell
279
 * @cpus: array of CPU definition structures, the pointer is stolen
280 281 282 283 284 285 286 287
 *
 * Registers a new NUMA cell for a host, passing in a
 * array of CPU IDs belonging to the cell
 */
int
virCapabilitiesAddHostNUMACell(virCapsPtr caps,
                               int num,
                               int ncpus,
288
                               unsigned long long mem,
289
                               virCapsHostNUMACellCPUPtr cpus)
290
{
291
    virCapsHostNUMACellPtr cell;
292

E
Eric Blake 已提交
293 294
    if (VIR_RESIZE_N(caps->host.numaCell, caps->host.nnumaCell_max,
                     caps->host.nnumaCell, 1) < 0)
295 296
        return -1;

297
    if (VIR_ALLOC(cell) < 0)
298 299
        return -1;

300 301
    cell->ncpus = ncpus;
    cell->num = num;
302
    cell->mem = mem;
303
    cell->cpus = cpus;
304

E
Eric Blake 已提交
305
    caps->host.numaCell[caps->host.nnumaCell++] = cell;
306 307 308 309

    return 0;
}

310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330

/**
 * virCapabilitiesSetHostCPU:
 * @caps: capabilities to extend
 * @cpu: CPU definition
 *
 * Sets host CPU specification
 */
int
virCapabilitiesSetHostCPU(virCapsPtr caps,
                          virCPUDefPtr cpu)
{
    if (cpu == NULL)
        return -1;

    caps->host.cpu = cpu;

    return 0;
}


331 332 333 334 335 336 337 338 339 340 341 342
/**
 * virCapabilitiesAllocMachines:
 * @machines: machine variants for emulator ('pc', or 'isapc', etc)
 * @nmachines: number of machine variants for emulator
 *
 * Allocate a table of virCapsGuestMachinePtr from the supplied table
 * of machine names.
 */
virCapsGuestMachinePtr *
virCapabilitiesAllocMachines(const char *const *names, int nnames)
{
    virCapsGuestMachinePtr *machines;
343
    size_t i;
344 345 346 347 348 349

    if (VIR_ALLOC_N(machines, nnames) < 0)
        return NULL;

    for (i = 0; i < nnames; i++) {
        if (VIR_ALLOC(machines[i]) < 0 ||
350
            VIR_STRDUP(machines[i]->name, names[i]) < 0) {
351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368
            virCapabilitiesFreeMachines(machines, nnames);
            return NULL;
        }
    }

    return machines;
}

/**
 * virCapabilitiesFreeMachines:
 * @machines: table of vircapsGuestMachinePtr
 *
 * Free a table of virCapsGuestMachinePtr
 */
void
virCapabilitiesFreeMachines(virCapsGuestMachinePtr *machines,
                            int nmachines)
{
369
    size_t i;
370 371 372 373 374 375 376 377
    if (!machines)
        return;
    for (i = 0; i < nmachines && machines[i]; i++) {
        virCapabilitiesFreeGuestMachine(machines[i]);
        machines[i] = NULL;
    }
    VIR_FREE(machines);
}
378 379 380 381 382

/**
 * virCapabilitiesAddGuest:
 * @caps: capabilities to extend
 * @ostype: guest operating system type ('hvm' or 'xen')
383
 * @arch: guest CPU architecture
384 385 386 387 388 389 390 391 392 393 394 395 396
 * @wordsize: number of bits in CPU word
 * @emulator: path to default device emulator for arch/ostype
 * @loader: path to default BIOS loader for arch/ostype
 * @nmachines: number of machine variants for emulator
 * @machines: machine variants for emulator ('pc', or 'isapc', etc)
 *
 * Registers a new guest operating system. This should be
 * followed by registration of at least one domain for
 * running the guest
 */
virCapsGuestPtr
virCapabilitiesAddGuest(virCapsPtr caps,
                        const char *ostype,
397
                        virArch arch,
398 399 400
                        const char *emulator,
                        const char *loader,
                        int nmachines,
401
                        virCapsGuestMachinePtr *machines)
402
{
403
    virCapsGuestPtr guest;
404

405
    if (VIR_ALLOC(guest) < 0)
406
        goto error;
407

408 409
    if (VIR_STRDUP(guest->ostype, ostype) < 0)
        goto error;
410

411 412
    guest->arch.id = arch;
    guest->arch.wordsize = virArchGetWordSize(arch);
413

414 415 416
    if (VIR_STRDUP(guest->arch.defaultInfo.emulator, emulator) < 0 ||
        VIR_STRDUP(guest->arch.defaultInfo.loader, loader) < 0)
        goto error;
417

E
Eric Blake 已提交
418 419
    if (VIR_RESIZE_N(caps->guests, caps->nguests_max,
                     caps->nguests, 1) < 0)
420
        goto error;
E
Eric Blake 已提交
421
    caps->guests[caps->nguests++] = guest;
422

D
Daniel P. Berrange 已提交
423 424 425 426 427
    if (nmachines) {
        guest->arch.defaultInfo.nmachines = nmachines;
        guest->arch.defaultInfo.machines = machines;
    }

428 429
    return guest;

430
error:
431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453
    virCapabilitiesFreeGuest(guest);
    return NULL;
}


/**
 * virCapabilitiesAddGuestDomain:
 * @guest: guest to support
 * @hvtype: hypervisor type ('xen', 'qemu', 'kvm')
 * @emulator: specialized device emulator for domain
 * @loader: specialized BIOS loader for domain
 * @nmachines: number of machine variants for emulator
 * @machines: specialized machine variants for emulator
 *
 * Registers a virtual domain capable of running a
 * guest operating system
 */
virCapsGuestDomainPtr
virCapabilitiesAddGuestDomain(virCapsGuestPtr guest,
                              const char *hvtype,
                              const char *emulator,
                              const char *loader,
                              int nmachines,
454
                              virCapsGuestMachinePtr *machines)
455
{
456
    virCapsGuestDomainPtr dom;
457

458
    if (VIR_ALLOC(dom) < 0)
459
        goto error;
460

461 462 463 464
    if (VIR_STRDUP(dom->type, hvtype) < 0 ||
        VIR_STRDUP(dom->info.emulator, emulator) < 0 ||
        VIR_STRDUP(dom->info.loader, loader) < 0)
        goto error;
465

E
Eric Blake 已提交
466 467
    if (VIR_RESIZE_N(guest->arch.domains, guest->arch.ndomains_max,
                     guest->arch.ndomains, 1) < 0)
468
        goto error;
469 470 471
    guest->arch.domains[guest->arch.ndomains] = dom;
    guest->arch.ndomains++;

D
Daniel P. Berrange 已提交
472 473 474 475
    if (nmachines) {
        dom->info.nmachines = nmachines;
        dom->info.machines = machines;
    }
476 477 478

    return dom;

479
error:
480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499
    virCapabilitiesFreeGuestDomain(dom);
    return NULL;
}


/**
 * virCapabilitiesAddGuestFeature:
 * @guest: guest to associate feature with
 * @name: name of feature ('pae', 'acpi', 'apic')
 * @defaultOn: non-zero if it defaults to on
 * @toggle: non-zero if its state can be toggled
 *
 * Registers a feature for a guest domain
 */
virCapsGuestFeaturePtr
virCapabilitiesAddGuestFeature(virCapsGuestPtr guest,
                               const char *name,
                               int defaultOn,
                               int toggle)
{
500
    virCapsGuestFeaturePtr feature;
501

502
    if (VIR_ALLOC(feature) < 0)
503 504
        goto no_memory;

505
    if (VIR_STRDUP(feature->name, name) < 0)
506 507 508 509
        goto no_memory;
    feature->defaultOn = defaultOn;
    feature->toggle = toggle;

E
Eric Blake 已提交
510 511
    if (VIR_RESIZE_N(guest->features, guest->nfeatures_max,
                     guest->nfeatures, 1) < 0)
512
        goto no_memory;
E
Eric Blake 已提交
513
    guest->features[guest->nfeatures++] = feature;
514 515 516 517 518 519 520 521

    return feature;

 no_memory:
    virCapabilitiesFreeGuestFeature(feature);
    return NULL;
}

522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559
/**
 * virCapabilitiesHostSecModelAddBaseLabel
 * @secmodel: Security model to add a base label for
 * @type: virtualization type
 * @label: base label
 *
 * Returns non-zero on error.
 */
extern int
virCapabilitiesHostSecModelAddBaseLabel(virCapsHostSecModelPtr secmodel,
                                        const char *type,
                                        const char *label)
{
    char *t = NULL, *l = NULL;

    if (type == NULL || label == NULL)
        return -1;

    if (VIR_STRDUP(t, type) < 0)
        goto no_memory;

    if (VIR_STRDUP(l, label) < 0)
        goto no_memory;

    if (VIR_EXPAND_N(secmodel->labels, secmodel->nlabels, 1) < 0)
        goto no_memory;

    secmodel->labels[secmodel->nlabels - 1].type = t;
    secmodel->labels[secmodel->nlabels - 1].label = l;

    return 0;

no_memory:
    VIR_FREE(l);
    VIR_FREE(t);
    return -1;
}

560 561 562
/**
 * virCapabilitiesSupportsGuestArch:
 * @caps: capabilities to query
563
 * @arch: Architecture to search for
564 565 566 567 568 569
 *
 * Returns non-zero if the capabilities support the
 * requested architecture
 */
extern int
virCapabilitiesSupportsGuestArch(virCapsPtr caps,
570
                                 virArch arch)
571
{
572
    size_t i;
573
    for (i = 0; i < caps->nguests; i++) {
574
        if (caps->guests[i]->arch.id == arch)
575 576 577 578 579
            return 1;
    }
    return 0;
}

580 581 582 583 584 585 586 587 588 589 590 591 592

/**
 * virCapabilitiesSupportsGuestOSType:
 * @caps: capabilities to query
 * @ostype: OS type to search for (eg 'hvm', 'xen')
 *
 * Returns non-zero if the capabilities support the
 * requested operating system type
 */
extern int
virCapabilitiesSupportsGuestOSType(virCapsPtr caps,
                                   const char *ostype)
{
593
    size_t i;
594
    for (i = 0; i < caps->nguests; i++) {
595 596 597 598 599 600 601
        if (STREQ(caps->guests[i]->ostype, ostype))
            return 1;
    }
    return 0;
}


602
/**
603
 * virCapabilitiesSupportsGuestOSTypeArch:
604 605
 * @caps: capabilities to query
 * @ostype: OS type to search for (eg 'hvm', 'xen')
606
 * @arch: Architecture to search for
607 608 609 610 611
 *
 * Returns non-zero if the capabilities support the
 * requested operating system type
 */
extern int
612 613
virCapabilitiesSupportsGuestOSTypeArch(virCapsPtr caps,
                                       const char *ostype,
614
                                       virArch arch)
615
{
616
    size_t i;
617
    for (i = 0; i < caps->nguests; i++) {
618
        if (STREQ(caps->guests[i]->ostype, ostype) &&
619
            caps->guests[i]->arch.id == arch)
620 621 622 623 624 625
            return 1;
    }
    return 0;
}


626 627 628 629 630 631 632 633
/**
 * virCapabilitiesDefaultGuestArch:
 * @caps: capabilities to query
 * @ostype: OS type to search for
 *
 * Returns the first architecture able to run the
 * requested operating system type
 */
634
extern virArch
635
virCapabilitiesDefaultGuestArch(virCapsPtr caps,
636 637
                                const char *ostype,
                                const char *domain)
638
{
639
    size_t i, j;
640 641

    /* First try to find one matching host arch */
642
    for (i = 0; i < caps->nguests; i++) {
643
        if (STREQ(caps->guests[i]->ostype, ostype)) {
644
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
645 646 647
                if (STREQ(caps->guests[i]->arch.domains[j]->type, domain) &&
                    caps->guests[i]->arch.id == caps->host.arch)
                    return caps->guests[i]->arch.id;
648 649
            }
        }
650
    }
651 652

    /* Otherwise find the first match */
653
    for (i = 0; i < caps->nguests; i++) {
654
        if (STREQ(caps->guests[i]->ostype, ostype)) {
655
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
656 657 658 659 660 661 662
                if (STREQ(caps->guests[i]->arch.domains[j]->type, domain))
                    return caps->guests[i]->arch.id;
            }
        }
    }

    return VIR_ARCH_NONE;
663 664 665 666 667 668 669
}

/**
 * virCapabilitiesDefaultGuestMachine:
 * @caps: capabilities to query
 * @ostype: OS type to search for
 * @arch: architecture to search for
670
 * @domain: domain type to search for
671 672
 *
 * Returns the first machine variant associated with
673 674
 * the requested operating system type, architecture
 * and domain type
675 676 677 678
 */
extern const char *
virCapabilitiesDefaultGuestMachine(virCapsPtr caps,
                                   const char *ostype,
679
                                   virArch arch,
680
                                   const char *domain)
681
{
682
    size_t i;
683

684
    for (i = 0; i < caps->nguests; i++) {
685
        virCapsGuestPtr guest = caps->guests[i];
686
        size_t j;
687

688 689
        if (!STREQ(guest->ostype, ostype) ||
            guest->arch.id != arch)
690 691 692
            continue;

        for (j = 0; j < guest->arch.ndomains; j++) {
693
            virCapsGuestDomainPtr dom = guest->arch.domains[j];
694 695 696 697 698 699 700 701 702 703 704

            if (!STREQ(dom->type, domain))
                continue;

            if (!dom->info.nmachines)
                break;

            return dom->info.machines[0]->name;
        }

        if (guest->arch.defaultInfo.nmachines)
705
            return caps->guests[i]->arch.defaultInfo.machines[0]->name;
706
    }
707

708 709 710 711
    return NULL;
}

/**
712
 * virCapabilitiesDefaultGuestEmulator:
713 714 715 716 717 718 719 720 721 722 723 724
 * @caps: capabilities to query
 * @ostype: OS type to search for ('xen', 'hvm')
 * @arch: architecture to search for
 * @domain: domain type ('xen', 'qemu', 'kvm')
 *
 * Returns the first emulator path associated with
 * the requested operating system type, architecture
 * and domain type
 */
extern const char *
virCapabilitiesDefaultGuestEmulator(virCapsPtr caps,
                                    const char *ostype,
725
                                    virArch arch,
726 727
                                    const char *domain)
{
728
    size_t i, j;
729
    for (i = 0; i < caps->nguests; i++) {
730 731
        char *emulator;
        if (STREQ(caps->guests[i]->ostype, ostype) &&
732
            caps->guests[i]->arch.id == arch) {
733
            emulator = caps->guests[i]->arch.defaultInfo.emulator;
734
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
735 736 737 738 739 740 741 742 743 744 745
                if (STREQ(caps->guests[i]->arch.domains[j]->type, domain)) {
                    if (caps->guests[i]->arch.domains[j]->info.emulator)
                        emulator = caps->guests[i]->arch.domains[j]->info.emulator;
                }
            }
            return emulator;
        }
    }
    return NULL;
}

746
static int
747 748 749 750
virCapabilitiesFormatNUMATopology(virBufferPtr xml,
                                  size_t ncells,
                                  virCapsHostNUMACellPtr *cells)
{
751 752
    size_t i;
    size_t j;
753
    char *siblings;
754 755 756 757 758

    virBufferAddLit(xml, "    <topology>\n");
    virBufferAsprintf(xml, "      <cells num='%zu'>\n", ncells);
    for (i = 0; i < ncells; i++) {
        virBufferAsprintf(xml, "        <cell id='%d'>\n", cells[i]->num);
759 760 761 762 763 764 765

        /* Print out the numacell memory total if it is available */
        if (cells[i]->mem)
            virBufferAsprintf(xml,
                              "          <memory unit='KiB'>%llu</memory>\n",
                              cells[i]->mem);

766
        virBufferAsprintf(xml, "          <cpus num='%d'>\n", cells[i]->ncpus);
767 768
        for (j = 0; j < cells[i]->ncpus; j++) {
            virBufferAsprintf(xml, "            <cpu id='%d'",
769
                              cells[i]->cpus[j].id);
770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786

            if (cells[i]->cpus[j].siblings) {
                if (!(siblings = virBitmapFormat(cells[i]->cpus[j].siblings))) {
                    virReportOOMError();
                    return -1;
                }

                virBufferAsprintf(xml,
                                  " socket_id='%d' core_id='%d' siblings='%s'",
                                  cells[i]->cpus[j].socket_id,
                                  cells[i]->cpus[j].core_id,
                                  siblings);
                VIR_FREE(siblings);
            }
            virBufferAddLit(xml, "/>\n");
        }

787 788 789 790 791
        virBufferAddLit(xml, "          </cpus>\n");
        virBufferAddLit(xml, "        </cell>\n");
    }
    virBufferAddLit(xml, "      </cells>\n");
    virBufferAddLit(xml, "    </topology>\n");
792 793

    return 0;
794
}
795 796 797 798 799 800 801 802 803 804 805 806

/**
 * virCapabilitiesFormatXML:
 * @caps: capabilities to format
 *
 * Convert the capabilities object into an XML representation
 *
 * Returns the XML document as a string
 */
char *
virCapabilitiesFormatXML(virCapsPtr caps)
{
807
    virBuffer xml = VIR_BUFFER_INITIALIZER;
808
    size_t i, j, k;
809
    char host_uuid[VIR_UUID_STRING_BUFLEN];
810

811 812
    virBufferAddLit(&xml, "<capabilities>\n\n");
    virBufferAddLit(&xml, "  <host>\n");
813 814
    if (virUUIDIsValid(caps->host.host_uuid)) {
        virUUIDFormat(caps->host.host_uuid, host_uuid);
815
        virBufferAsprintf(&xml,"    <uuid>%s</uuid>\n", host_uuid);
816
    }
817
    virBufferAddLit(&xml, "    <cpu>\n");
818 819 820
    if (caps->host.arch)
        virBufferAsprintf(&xml, "      <arch>%s</arch>\n",
                          virArchToString(caps->host.arch));
821 822

    if (caps->host.nfeatures) {
823
        virBufferAddLit(&xml, "      <features>\n");
824
        for (i = 0; i < caps->host.nfeatures; i++) {
825
            virBufferAsprintf(&xml, "        <%s/>\n",
826
                              caps->host.features[i]);
827
        }
828
        virBufferAddLit(&xml, "      </features>\n");
829
    }
830

831
    virBufferAdjustIndent(&xml, 6);
832
    virCPUDefFormatBuf(&xml, caps->host.cpu, 0);
833
    virBufferAdjustIndent(&xml, -6);
834

835
    virBufferAddLit(&xml, "    </cpu>\n");
836

837 838 839 840 841 842 843 844 845 846
    /* The PM query was successful. */
    if (caps->host.powerMgmt) {
        /* The host supports some PM features. */
        unsigned int pm = caps->host.powerMgmt;
        virBufferAddLit(&xml, "    <power_management>\n");
        while (pm) {
            int bit = ffs(pm) - 1;
            virBufferAsprintf(&xml, "      <%s/>\n",
                              virCapsHostPMTargetTypeToString(bit));
            pm &= ~(1U << bit);
847
        }
848 849 850 851
        virBufferAddLit(&xml, "    </power_management>\n");
    } else {
        /* The host does not support any PM feature. */
        virBufferAddLit(&xml, "    <power_management/>\n");
852 853
    }

854
    if (caps->host.offlineMigrate) {
855 856 857
        virBufferAddLit(&xml, "    <migration_features>\n");
        if (caps->host.liveMigrate)
            virBufferAddLit(&xml, "      <live/>\n");
858
        if (caps->host.nmigrateTrans) {
859
            virBufferAddLit(&xml, "      <uri_transports>\n");
860
            for (i = 0; i < caps->host.nmigrateTrans; i++) {
861
                virBufferAsprintf(&xml, "        <uri_transport>%s</uri_transport>\n",
862
                                      caps->host.migrateTrans[i]);
863
            }
864
            virBufferAddLit(&xml, "      </uri_transports>\n");
865
        }
866
        virBufferAddLit(&xml, "    </migration_features>\n");
867 868
    }

869
    if (caps->host.nnumaCell &&
870
        virCapabilitiesFormatNUMATopology(&xml, caps->host.nnumaCell,
871 872
                                          caps->host.numaCell) < 0)
        return NULL;
873

874
    for (i = 0; i < caps->host.nsecModels; i++) {
875
        virBufferAddLit(&xml, "    <secmodel>\n");
876
        virBufferAsprintf(&xml, "      <model>%s</model>\n",
877
                          caps->host.secModels[i].model);
878
        virBufferAsprintf(&xml, "      <doi>%s</doi>\n",
879
                          caps->host.secModels[i].doi);
880 881 882 883 884
        for (j = 0; j < caps->host.secModels[i].nlabels; j++) {
            virBufferAsprintf(&xml, "      <baselabel type='%s'>%s</baselabel>\n",
                              caps->host.secModels[i].labels[j].type,
                              caps->host.secModels[i].labels[j].label);
        }
885 886 887
        virBufferAddLit(&xml, "    </secmodel>\n");
    }

888
    virBufferAddLit(&xml, "  </host>\n\n");
889 890


891
    for (i = 0; i < caps->nguests; i++) {
892
        virBufferAddLit(&xml, "  <guest>\n");
893
        virBufferAsprintf(&xml, "    <os_type>%s</os_type>\n",
894
                          caps->guests[i]->ostype);
895 896 897
        if (caps->guests[i]->arch.id)
            virBufferAsprintf(&xml, "    <arch name='%s'>\n",
                              virArchToString(caps->guests[i]->arch.id));
898
        virBufferAsprintf(&xml, "      <wordsize>%d</wordsize>\n",
899 900
                          caps->guests[i]->arch.wordsize);
        if (caps->guests[i]->arch.defaultInfo.emulator)
901
            virBufferAsprintf(&xml, "      <emulator>%s</emulator>\n",
902 903
                              caps->guests[i]->arch.defaultInfo.emulator);
            if (caps->guests[i]->arch.defaultInfo.loader)
904
                virBufferAsprintf(&xml, "      <loader>%s</loader>\n",
905
                                  caps->guests[i]->arch.defaultInfo.loader);
906

907
        for (j = 0; j < caps->guests[i]->arch.defaultInfo.nmachines; j++) {
908 909 910
            virCapsGuestMachinePtr machine = caps->guests[i]->arch.defaultInfo.machines[j];
            virBufferAddLit(&xml, "      <machine");
            if (machine->canonical)
911
                virBufferAsprintf(&xml, " canonical='%s'", machine->canonical);
912 913
            if (machine->maxCpus > 0)
                virBufferAsprintf(&xml, " maxCpus='%d'", machine->maxCpus);
914
            virBufferAsprintf(&xml, ">%s</machine>\n", machine->name);
915 916
        }

917
        for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
918
            virBufferAsprintf(&xml, "      <domain type='%s'>\n",
919 920
                                  caps->guests[i]->arch.domains[j]->type);
            if (caps->guests[i]->arch.domains[j]->info.emulator)
921
                virBufferAsprintf(&xml, "        <emulator>%s</emulator>\n",
922 923
                                  caps->guests[i]->arch.domains[j]->info.emulator);
            if (caps->guests[i]->arch.domains[j]->info.loader)
924
                virBufferAsprintf(&xml, "        <loader>%s</loader>\n",
925
                                  caps->guests[i]->arch.domains[j]->info.loader);
926

927
            for (k = 0; k < caps->guests[i]->arch.domains[j]->info.nmachines; k++) {
928
                virCapsGuestMachinePtr machine = caps->guests[i]->arch.domains[j]->info.machines[k];
929
                virBufferAddLit(&xml, "        <machine");
930
                if (machine->canonical)
931
                    virBufferAsprintf(&xml, " canonical='%s'", machine->canonical);
932 933
                if (machine->maxCpus > 0)
                    virBufferAsprintf(&xml, " maxCpus='%d'", machine->maxCpus);
934
                virBufferAsprintf(&xml, ">%s</machine>\n", machine->name);
935
            }
936
            virBufferAddLit(&xml, "      </domain>\n");
937 938
        }

939
        virBufferAddLit(&xml, "    </arch>\n");
940 941

        if (caps->guests[i]->nfeatures) {
942
            virBufferAddLit(&xml, "    <features>\n");
943

944
            for (j = 0; j < caps->guests[i]->nfeatures; j++) {
945 946
                if (STREQ(caps->guests[i]->features[j]->name, "pae") ||
                    STREQ(caps->guests[i]->features[j]->name, "nonpae") ||
947
                    STREQ(caps->guests[i]->features[j]->name, "ia64_be") ||
948 949
                    STREQ(caps->guests[i]->features[j]->name, "cpuselection") ||
                    STREQ(caps->guests[i]->features[j]->name, "deviceboot")) {
950
                    virBufferAsprintf(&xml, "      <%s/>\n",
951
                                      caps->guests[i]->features[j]->name);
952
                } else {
953
                    virBufferAsprintf(&xml, "      <%s default='%s' toggle='%s'/>\n",
954 955 956
                                      caps->guests[i]->features[j]->name,
                                      caps->guests[i]->features[j]->defaultOn ? "on" : "off",
                                      caps->guests[i]->features[j]->toggle ? "yes" : "no");
957 958 959
                }
            }

960
            virBufferAddLit(&xml, "    </features>\n");
961 962
        }

963
        virBufferAddLit(&xml, "  </guest>\n\n");
964 965
    }

966
    virBufferAddLit(&xml, "</capabilities>\n");
967

968 969
    if (virBufferError(&xml)) {
        virBufferFreeAndReset(&xml);
970
        return NULL;
971
    }
972

973
    return virBufferContentAndReset(&xml);
974
}
975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038

/* get the maximum ID of cpus in the host */
static unsigned int
virCapabilitiesGetHostMaxcpu(virCapsPtr caps)
{
    unsigned int maxcpu = 0;
    size_t node;
    size_t cpu;

    for (node = 0; node < caps->host.nnumaCell; node++) {
        virCapsHostNUMACellPtr cell = caps->host.numaCell[node];

        for (cpu = 0; cpu < cell->ncpus; cpu++) {
            if (cell->cpus[cpu].id > maxcpu)
                maxcpu = cell->cpus[cpu].id;
        }
    }

    return maxcpu;
}

/* set cpus of a numa node in the bitmask */
static int
virCapabilitiesGetCpusForNode(virCapsPtr caps,
                              size_t node,
                              virBitmapPtr cpumask)
{
    virCapsHostNUMACellPtr cell = caps->host.numaCell[node];
    size_t cpu;

    for (cpu = 0; cpu < cell->ncpus; cpu++) {
        if (virBitmapSetBit(cpumask, cell->cpus[cpu].id) < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Cpu '%u' in node '%zu' is out of range "
                             "of the provided bitmap"),
                           cell->cpus[cpu].id, node);
            return -1;
        }
    }

    return 0;
}

virBitmapPtr
virCapabilitiesGetCpusForNodemask(virCapsPtr caps,
                                  virBitmapPtr nodemask)
{
    virBitmapPtr ret = NULL;
    unsigned int maxcpu = virCapabilitiesGetHostMaxcpu(caps);
    ssize_t node = -1;

    if (!(ret = virBitmapNew(maxcpu + 1)))
        return NULL;


    while ((node = virBitmapNextSetBit(nodemask, node)) >= 0) {
        if (virCapabilitiesGetCpusForNode(caps, node, ret) < 0) {
            virBitmapFree(ret);
            return NULL;
        }
    }

    return ret;
}