capabilities.c 31.8 KB
Newer Older
1 2 3
/*
 * capabilities.c: hypervisor capabilities
 *
4
 * Copyright (C) 2006-2014 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
    VIR_FREE(cell->cpus);
110
    VIR_FREE(cell->siblings);
111
    VIR_FREE(cell);
112 113
}

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

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

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

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

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

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

157
    VIR_FREE(guest->ostype);
158

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

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

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

173
    VIR_FREE(guest);
174 175
}

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

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

187 188 189 190 191 192 193 194 195 196 197 198 199 200
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);
}

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

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

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

    virCapabilitiesFreeNUMAInfo(caps);
216

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

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

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


/**
 * 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 已提交
241 242
    if (VIR_RESIZE_N(caps->host.features, caps->host.nfeatures_max,
                     caps->host.nfeatures, 1) < 0)
243 244
        return -1;

245
    if (VIR_STRDUP(caps->host.features[caps->host.nfeatures], name) < 0)
246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
        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 已提交
263 264
    if (VIR_RESIZE_N(caps->host.migrateTrans, caps->host.nmigrateTrans_max,
                     caps->host.nmigrateTrans, 1) < 0)
265 266
        return -1;

267
    if (VIR_STRDUP(caps->host.migrateTrans[caps->host.nmigrateTrans], name) < 0)
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
279
 * @mem: Total size of memory in the NUMA node (in KiB)
280
 * @ncpus: number of CPUs in cell
281
 * @cpus: array of CPU definition structures, the pointer is stolen
282 283
 * @nsiblings: number of sibling NUMA nodes
 * @siblings: info on sibling NUMA nodes
284 285 286 287 288 289 290
 *
 * 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,
291
                               unsigned long long mem,
292 293 294 295
                               int ncpus,
                               virCapsHostNUMACellCPUPtr cpus,
                               int nsiblings,
                               virCapsHostNUMACellSiblingInfoPtr siblings)
296
{
297
    virCapsHostNUMACellPtr cell;
298

E
Eric Blake 已提交
299 300
    if (VIR_RESIZE_N(caps->host.numaCell, caps->host.nnumaCell_max,
                     caps->host.nnumaCell, 1) < 0)
301 302
        return -1;

303
    if (VIR_ALLOC(cell) < 0)
304 305
        return -1;

306 307
    cell->ncpus = ncpus;
    cell->num = num;
308
    cell->mem = mem;
309
    cell->cpus = cpus;
310 311
    cell->siblings = siblings;
    cell->nsiblings = nsiblings;
312

E
Eric Blake 已提交
313
    caps->host.numaCell[caps->host.nnumaCell++] = cell;
314 315 316 317

    return 0;
}

318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338

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


339 340 341 342 343 344 345 346 347 348 349 350
/**
 * 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;
351
    size_t i;
352 353 354 355 356 357

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

    for (i = 0; i < nnames; i++) {
        if (VIR_ALLOC(machines[i]) < 0 ||
358
            VIR_STRDUP(machines[i]->name, names[i]) < 0) {
359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376
            virCapabilitiesFreeMachines(machines, nnames);
            return NULL;
        }
    }

    return machines;
}

/**
 * virCapabilitiesFreeMachines:
 * @machines: table of vircapsGuestMachinePtr
 *
 * Free a table of virCapsGuestMachinePtr
 */
void
virCapabilitiesFreeMachines(virCapsGuestMachinePtr *machines,
                            int nmachines)
{
377
    size_t i;
378 379 380 381 382 383 384 385
    if (!machines)
        return;
    for (i = 0; i < nmachines && machines[i]; i++) {
        virCapabilitiesFreeGuestMachine(machines[i]);
        machines[i] = NULL;
    }
    VIR_FREE(machines);
}
386 387 388 389 390

/**
 * virCapabilitiesAddGuest:
 * @caps: capabilities to extend
 * @ostype: guest operating system type ('hvm' or 'xen')
391
 * @arch: guest CPU architecture
392 393 394 395 396 397 398 399 400 401 402 403 404
 * @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,
405
                        virArch arch,
406 407 408
                        const char *emulator,
                        const char *loader,
                        int nmachines,
409
                        virCapsGuestMachinePtr *machines)
410
{
411
    virCapsGuestPtr guest;
412

413
    if (VIR_ALLOC(guest) < 0)
414
        goto error;
415

416 417
    if (VIR_STRDUP(guest->ostype, ostype) < 0)
        goto error;
418

419 420
    guest->arch.id = arch;
    guest->arch.wordsize = virArchGetWordSize(arch);
421

422 423 424
    if (VIR_STRDUP(guest->arch.defaultInfo.emulator, emulator) < 0 ||
        VIR_STRDUP(guest->arch.defaultInfo.loader, loader) < 0)
        goto error;
425

E
Eric Blake 已提交
426 427
    if (VIR_RESIZE_N(caps->guests, caps->nguests_max,
                     caps->nguests, 1) < 0)
428
        goto error;
E
Eric Blake 已提交
429
    caps->guests[caps->nguests++] = guest;
430

D
Daniel P. Berrange 已提交
431 432 433 434 435
    if (nmachines) {
        guest->arch.defaultInfo.nmachines = nmachines;
        guest->arch.defaultInfo.machines = machines;
    }

436 437
    return guest;

438
 error:
439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461
    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,
462
                              virCapsGuestMachinePtr *machines)
463
{
464
    virCapsGuestDomainPtr dom;
465

466
    if (VIR_ALLOC(dom) < 0)
467
        goto error;
468

469 470 471 472
    if (VIR_STRDUP(dom->type, hvtype) < 0 ||
        VIR_STRDUP(dom->info.emulator, emulator) < 0 ||
        VIR_STRDUP(dom->info.loader, loader) < 0)
        goto error;
473

E
Eric Blake 已提交
474 475
    if (VIR_RESIZE_N(guest->arch.domains, guest->arch.ndomains_max,
                     guest->arch.ndomains, 1) < 0)
476
        goto error;
477 478 479
    guest->arch.domains[guest->arch.ndomains] = dom;
    guest->arch.ndomains++;

D
Daniel P. Berrange 已提交
480 481 482 483
    if (nmachines) {
        dom->info.nmachines = nmachines;
        dom->info.machines = machines;
    }
484 485 486

    return dom;

487
 error:
488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507
    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)
{
508
    virCapsGuestFeaturePtr feature;
509

510
    if (VIR_ALLOC(feature) < 0)
511 512
        goto no_memory;

513
    if (VIR_STRDUP(feature->name, name) < 0)
514 515 516 517
        goto no_memory;
    feature->defaultOn = defaultOn;
    feature->toggle = toggle;

E
Eric Blake 已提交
518 519
    if (VIR_RESIZE_N(guest->features, guest->nfeatures_max,
                     guest->nfeatures, 1) < 0)
520
        goto no_memory;
E
Eric Blake 已提交
521
    guest->features[guest->nfeatures++] = feature;
522 523 524 525 526 527 528 529

    return feature;

 no_memory:
    virCapabilitiesFreeGuestFeature(feature);
    return NULL;
}

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 560 561
/**
 * 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;

562
 no_memory:
563 564 565 566 567
    VIR_FREE(l);
    VIR_FREE(t);
    return -1;
}

568 569 570
/**
 * virCapabilitiesSupportsGuestArch:
 * @caps: capabilities to query
571
 * @arch: Architecture to search for
572 573 574 575 576 577
 *
 * Returns non-zero if the capabilities support the
 * requested architecture
 */
extern int
virCapabilitiesSupportsGuestArch(virCapsPtr caps,
578
                                 virArch arch)
579
{
580
    size_t i;
581
    for (i = 0; i < caps->nguests; i++) {
582
        if (caps->guests[i]->arch.id == arch)
583 584 585 586 587
            return 1;
    }
    return 0;
}

588 589 590 591 592 593 594 595 596 597 598 599 600

/**
 * 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)
{
601
    size_t i;
602
    for (i = 0; i < caps->nguests; i++) {
603 604 605 606 607 608 609
        if (STREQ(caps->guests[i]->ostype, ostype))
            return 1;
    }
    return 0;
}


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


634 635 636 637 638 639 640 641
/**
 * virCapabilitiesDefaultGuestArch:
 * @caps: capabilities to query
 * @ostype: OS type to search for
 *
 * Returns the first architecture able to run the
 * requested operating system type
 */
642
extern virArch
643
virCapabilitiesDefaultGuestArch(virCapsPtr caps,
644 645
                                const char *ostype,
                                const char *domain)
646
{
647
    size_t i, j;
648 649

    /* First try to find one matching host arch */
650
    for (i = 0; i < caps->nguests; i++) {
651
        if (STREQ(caps->guests[i]->ostype, ostype)) {
652
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
653 654 655
                if (STREQ(caps->guests[i]->arch.domains[j]->type, domain) &&
                    caps->guests[i]->arch.id == caps->host.arch)
                    return caps->guests[i]->arch.id;
656 657
            }
        }
658
    }
659 660

    /* Otherwise find the first match */
661
    for (i = 0; i < caps->nguests; i++) {
662
        if (STREQ(caps->guests[i]->ostype, ostype)) {
663
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
664 665 666 667 668 669 670
                if (STREQ(caps->guests[i]->arch.domains[j]->type, domain))
                    return caps->guests[i]->arch.id;
            }
        }
    }

    return VIR_ARCH_NONE;
671 672 673 674 675 676 677
}

/**
 * virCapabilitiesDefaultGuestMachine:
 * @caps: capabilities to query
 * @ostype: OS type to search for
 * @arch: architecture to search for
678
 * @domain: domain type to search for
679 680
 *
 * Returns the first machine variant associated with
681 682
 * the requested operating system type, architecture
 * and domain type
683 684 685 686
 */
extern const char *
virCapabilitiesDefaultGuestMachine(virCapsPtr caps,
                                   const char *ostype,
687
                                   virArch arch,
688
                                   const char *domain)
689
{
690
    size_t i;
691

692
    for (i = 0; i < caps->nguests; i++) {
693
        virCapsGuestPtr guest = caps->guests[i];
694
        size_t j;
695

696 697
        if (!STREQ(guest->ostype, ostype) ||
            guest->arch.id != arch)
698 699 700
            continue;

        for (j = 0; j < guest->arch.ndomains; j++) {
701
            virCapsGuestDomainPtr dom = guest->arch.domains[j];
702 703 704 705 706 707 708 709 710 711 712

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

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

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

        if (guest->arch.defaultInfo.nmachines)
713
            return caps->guests[i]->arch.defaultInfo.machines[0]->name;
714
    }
715

716 717 718 719
    return NULL;
}

/**
720
 * virCapabilitiesDefaultGuestEmulator:
721 722 723 724 725 726 727 728 729 730 731 732
 * @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,
733
                                    virArch arch,
734 735
                                    const char *domain)
{
736
    size_t i, j;
737
    for (i = 0; i < caps->nguests; i++) {
738 739
        char *emulator;
        if (STREQ(caps->guests[i]->ostype, ostype) &&
740
            caps->guests[i]->arch.id == arch) {
741
            emulator = caps->guests[i]->arch.defaultInfo.emulator;
742
            for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
743 744 745 746 747 748 749 750 751 752 753
                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;
}

754
static int
755
virCapabilitiesFormatNUMATopology(virBufferPtr buf,
756 757 758
                                  size_t ncells,
                                  virCapsHostNUMACellPtr *cells)
{
759 760
    size_t i;
    size_t j;
761
    char *siblings;
762

763 764 765 766
    virBufferAddLit(buf, "<topology>\n");
    virBufferAdjustIndent(buf, 2);
    virBufferAsprintf(buf, "<cells num='%zu'>\n", ncells);
    virBufferAdjustIndent(buf, 2);
767
    for (i = 0; i < ncells; i++) {
768 769
        virBufferAsprintf(buf, "<cell id='%d'>\n", cells[i]->num);
        virBufferAdjustIndent(buf, 2);
770 771 772

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

776 777 778 779 780 781 782 783 784 785 786 787
        if (cells[i]->nsiblings) {
            virBufferAddLit(buf, "<distances>\n");
            virBufferAdjustIndent(buf, 2);
            for (j = 0; j < cells[i]->nsiblings; j++) {
                virBufferAsprintf(buf, "<sibling id='%d' value='%d'/>\n",
                                  cells[i]->siblings[j].node,
                                  cells[i]->siblings[j].distance);
            }
            virBufferAdjustIndent(buf, -2);
            virBufferAddLit(buf, "</distances>\n");
        }

788 789
        virBufferAsprintf(buf, "<cpus num='%d'>\n", cells[i]->ncpus);
        virBufferAdjustIndent(buf, 2);
790
        for (j = 0; j < cells[i]->ncpus; j++) {
791
            virBufferAsprintf(buf, "<cpu id='%d'", cells[i]->cpus[j].id);
792 793

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

797
                virBufferAsprintf(buf,
798 799 800 801 802 803
                                  " socket_id='%d' core_id='%d' siblings='%s'",
                                  cells[i]->cpus[j].socket_id,
                                  cells[i]->cpus[j].core_id,
                                  siblings);
                VIR_FREE(siblings);
            }
804
            virBufferAddLit(buf, "/>\n");
805
        }
806 807 808 809
        virBufferAdjustIndent(buf, -2);
        virBufferAddLit(buf, "</cpus>\n");
        virBufferAdjustIndent(buf, -2);
        virBufferAddLit(buf, "</cell>\n");
810
    }
811 812 813 814
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</cells>\n");
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</topology>\n");
815
    return 0;
816
}
817 818 819 820 821 822 823 824 825 826 827 828

/**
 * virCapabilitiesFormatXML:
 * @caps: capabilities to format
 *
 * Convert the capabilities object into an XML representation
 *
 * Returns the XML document as a string
 */
char *
virCapabilitiesFormatXML(virCapsPtr caps)
{
829
    virBuffer buf = VIR_BUFFER_INITIALIZER;
830
    size_t i, j, k;
831
    char host_uuid[VIR_UUID_STRING_BUFLEN];
832

833 834 835 836
    virBufferAddLit(&buf, "<capabilities>\n\n");
    virBufferAdjustIndent(&buf, 2);
    virBufferAddLit(&buf, "<host>\n");
    virBufferAdjustIndent(&buf, 2);
837 838
    if (virUUIDIsValid(caps->host.host_uuid)) {
        virUUIDFormat(caps->host.host_uuid, host_uuid);
839
        virBufferAsprintf(&buf, "<uuid>%s</uuid>\n", host_uuid);
840
    }
841 842 843
    virBufferAddLit(&buf, "<cpu>\n");
    virBufferAdjustIndent(&buf, 2);

844
    if (caps->host.arch)
845
        virBufferAsprintf(&buf, "<arch>%s</arch>\n",
846
                          virArchToString(caps->host.arch));
847
    if (caps->host.nfeatures) {
848 849
        virBufferAddLit(&buf, "<features>\n");
        virBufferAdjustIndent(&buf, 2);
850
        for (i = 0; i < caps->host.nfeatures; i++) {
851
            virBufferAsprintf(&buf, "<%s/>\n",
852
                              caps->host.features[i]);
853
        }
854 855
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</features>\n");
856
    }
857
    virCPUDefFormatBuf(&buf, caps->host.cpu, 0);
858

859 860
    virBufferAdjustIndent(&buf, -2);
    virBufferAddLit(&buf, "</cpu>\n");
861

862 863 864 865
    /* The PM query was successful. */
    if (caps->host.powerMgmt) {
        /* The host supports some PM features. */
        unsigned int pm = caps->host.powerMgmt;
866 867
        virBufferAddLit(&buf, "<power_management>\n");
        virBufferAdjustIndent(&buf, 2);
868 869
        while (pm) {
            int bit = ffs(pm) - 1;
870
            virBufferAsprintf(&buf, "<%s/>\n",
871 872
                              virCapsHostPMTargetTypeToString(bit));
            pm &= ~(1U << bit);
873
        }
874 875
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</power_management>\n");
876 877
    } else {
        /* The host does not support any PM feature. */
878
        virBufferAddLit(&buf, "<power_management/>\n");
879 880
    }

881
    if (caps->host.offlineMigrate) {
882 883
        virBufferAddLit(&buf, "<migration_features>\n");
        virBufferAdjustIndent(&buf, 2);
884
        if (caps->host.liveMigrate)
885
            virBufferAddLit(&buf, "<live/>\n");
886
        if (caps->host.nmigrateTrans) {
887 888
            virBufferAddLit(&buf, "<uri_transports>\n");
            virBufferAdjustIndent(&buf, 2);
889
            for (i = 0; i < caps->host.nmigrateTrans; i++) {
890
                virBufferAsprintf(&buf, "<uri_transport>%s</uri_transport>\n",
891
                                      caps->host.migrateTrans[i]);
892
            }
893 894
            virBufferAdjustIndent(&buf, -2);
            virBufferAddLit(&buf, "</uri_transports>\n");
895
        }
896 897
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</migration_features>\n");
898 899
    }

900
    if (caps->host.nnumaCell &&
901
        virCapabilitiesFormatNUMATopology(&buf, caps->host.nnumaCell,
902 903
                                          caps->host.numaCell) < 0)
        return NULL;
904

905
    for (i = 0; i < caps->host.nsecModels; i++) {
906 907 908
        virBufferAddLit(&buf, "<secmodel>\n");
        virBufferAdjustIndent(&buf, 2);
        virBufferAsprintf(&buf, "<model>%s</model>\n",
909
                          caps->host.secModels[i].model);
910
        virBufferAsprintf(&buf, "<doi>%s</doi>\n",
911
                          caps->host.secModels[i].doi);
912
        for (j = 0; j < caps->host.secModels[i].nlabels; j++) {
913
            virBufferAsprintf(&buf, "<baselabel type='%s'>%s</baselabel>\n",
914 915 916
                              caps->host.secModels[i].labels[j].type,
                              caps->host.secModels[i].labels[j].label);
        }
917 918
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</secmodel>\n");
919 920
    }

921 922
    virBufferAdjustIndent(&buf, -2);
    virBufferAddLit(&buf, "</host>\n\n");
923 924


925
    for (i = 0; i < caps->nguests; i++) {
926 927 928
        virBufferAddLit(&buf, "<guest>\n");
        virBufferAdjustIndent(&buf, 2);
        virBufferAsprintf(&buf, "<os_type>%s</os_type>\n",
929
                          caps->guests[i]->ostype);
930
        if (caps->guests[i]->arch.id)
931
            virBufferAsprintf(&buf, "<arch name='%s'>\n",
932
                              virArchToString(caps->guests[i]->arch.id));
933 934
        virBufferAdjustIndent(&buf, 2);
        virBufferAsprintf(&buf, "<wordsize>%d</wordsize>\n",
935 936
                          caps->guests[i]->arch.wordsize);
        if (caps->guests[i]->arch.defaultInfo.emulator)
937
            virBufferAsprintf(&buf, "<emulator>%s</emulator>\n",
938 939
                              caps->guests[i]->arch.defaultInfo.emulator);
            if (caps->guests[i]->arch.defaultInfo.loader)
940
                virBufferAsprintf(&buf, "<loader>%s</loader>\n",
941
                                  caps->guests[i]->arch.defaultInfo.loader);
942

943
        for (j = 0; j < caps->guests[i]->arch.defaultInfo.nmachines; j++) {
944
            virCapsGuestMachinePtr machine = caps->guests[i]->arch.defaultInfo.machines[j];
945
            virBufferAddLit(&buf, "<machine");
946
            if (machine->canonical)
947
                virBufferAsprintf(&buf, " canonical='%s'", machine->canonical);
948
            if (machine->maxCpus > 0)
949 950
                virBufferAsprintf(&buf, " maxCpus='%d'", machine->maxCpus);
            virBufferAsprintf(&buf, ">%s</machine>\n", machine->name);
951 952
        }

953
        for (j = 0; j < caps->guests[i]->arch.ndomains; j++) {
954
            virBufferAsprintf(&buf, "<domain type='%s'>\n",
955
                                  caps->guests[i]->arch.domains[j]->type);
956
            virBufferAdjustIndent(&buf, 2);
957
            if (caps->guests[i]->arch.domains[j]->info.emulator)
958
                virBufferAsprintf(&buf, "<emulator>%s</emulator>\n",
959 960
                                  caps->guests[i]->arch.domains[j]->info.emulator);
            if (caps->guests[i]->arch.domains[j]->info.loader)
961
                virBufferAsprintf(&buf, "<loader>%s</loader>\n",
962
                                  caps->guests[i]->arch.domains[j]->info.loader);
963

964
            for (k = 0; k < caps->guests[i]->arch.domains[j]->info.nmachines; k++) {
965
                virCapsGuestMachinePtr machine = caps->guests[i]->arch.domains[j]->info.machines[k];
966
                virBufferAddLit(&buf, "<machine");
967
                if (machine->canonical)
968
                    virBufferAsprintf(&buf, " canonical='%s'", machine->canonical);
969
                if (machine->maxCpus > 0)
970 971
                    virBufferAsprintf(&buf, " maxCpus='%d'", machine->maxCpus);
                virBufferAsprintf(&buf, ">%s</machine>\n", machine->name);
972
            }
973 974
            virBufferAdjustIndent(&buf, -2);
            virBufferAddLit(&buf, "</domain>\n");
975 976
        }

977 978
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</arch>\n");
979 980

        if (caps->guests[i]->nfeatures) {
981 982
            virBufferAddLit(&buf, "<features>\n");
            virBufferAdjustIndent(&buf, 2);
983

984
            for (j = 0; j < caps->guests[i]->nfeatures; j++) {
985 986
                if (STREQ(caps->guests[i]->features[j]->name, "pae") ||
                    STREQ(caps->guests[i]->features[j]->name, "nonpae") ||
987
                    STREQ(caps->guests[i]->features[j]->name, "ia64_be") ||
988 989
                    STREQ(caps->guests[i]->features[j]->name, "cpuselection") ||
                    STREQ(caps->guests[i]->features[j]->name, "deviceboot")) {
990
                    virBufferAsprintf(&buf, "<%s/>\n",
991
                                      caps->guests[i]->features[j]->name);
992
                } else {
993
                    virBufferAsprintf(&buf, "<%s default='%s' toggle='%s'/>\n",
994 995 996
                                      caps->guests[i]->features[j]->name,
                                      caps->guests[i]->features[j]->defaultOn ? "on" : "off",
                                      caps->guests[i]->features[j]->toggle ? "yes" : "no");
997 998 999
                }
            }

1000 1001
            virBufferAdjustIndent(&buf, -2);
            virBufferAddLit(&buf, "</features>\n");
1002
        }
1003 1004
        virBufferAdjustIndent(&buf, -2);
        virBufferAddLit(&buf, "</guest>\n\n");
1005
    }
1006 1007
    virBufferAdjustIndent(&buf, -2);
    virBufferAddLit(&buf, "</capabilities>\n");
1008

1009 1010
    if (virBufferError(&buf)) {
        virBufferFreeAndReset(&buf);
1011
        return NULL;
1012
    }
1013

1014
    return virBufferContentAndReset(&buf);
1015
}
1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042

/* 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)
{
1043
    virCapsHostNUMACellPtr cell = NULL;
1044
    size_t cpu;
1045
    size_t i;
1046
    /* The numa node numbers can be non-contiguous. Ex: 0,1,16,17. */
1047 1048 1049
    for (i = 0; i < caps->host.nnumaCell; i++) {
        if (caps->host.numaCell[i]->num == node) {
            cell = caps->host.numaCell[i];
1050 1051 1052
            break;
        }
    }
1053

1054
    for (cpu = 0; cell && cpu < cell->ncpus; cpu++) {
1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087
        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;
}