xen_sxpr.c 85.6 KB
Newer Older
1 2 3
/*
 * xen_sxpr.c: Xen SEXPR parsing functions
 *
4
 * Copyright (C) 2010-2014 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17 18
 * Copyright (C) 2011 Univention GmbH
 * Copyright (C) 2005 Anthony Liguori <aliguori@us.ibm.com>
 *
 * 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
19
 * License along with this library.  If not, see
O
Osier Yang 已提交
20
 * <http://www.gnu.org/licenses/>.
21 22 23 24 25 26 27 28 29
 *
 * Author: Anthony Liguori <aliguori@us.ibm.com>
 * Author: Daniel Veillard <veillard@redhat.com>
 * Author: Markus Groß <gross@univention.de>
 */

#include <config.h>

#include "internal.h"
30
#include "virerror.h"
31
#include "virconf.h"
32
#include "viralloc.h"
33
#include "verify.h"
34
#include "viruuid.h"
35
#include "virlog.h"
36 37 38
#include "count-one-bits.h"
#include "xenxs_private.h"
#include "xen_sxpr.h"
39
#include "virstoragefile.h"
40
#include "virstring.h"
41

J
Jim Fehlig 已提交
42
VIR_LOG_INIT("xenconfig.xen_sxpr");
43

P
Philipp Hahn 已提交
44
/* Get a domain id from a S-expression string */
45
int xenGetDomIdFromSxprString(const char *sexpr, int xendConfigVersion, int *id)
46 47
{
    struct sexpr *root = string2sexpr(sexpr);
48 49 50
    int ret;

    *id = -1;
51 52 53 54

    if (!root)
        return -1;

55
    ret = xenGetDomIdFromSxpr(root, xendConfigVersion, id);
56
    sexpr_free(root);
57
    return ret;
58 59
}

P
Philipp Hahn 已提交
60
/* Get a domain id from a S-expression */
61
int xenGetDomIdFromSxpr(const struct sexpr *root, int xendConfigVersion, int *id)
62 63
{
    const char * tmp = sexpr_node(root, "domain/domid");
64
    if (tmp == NULL && xendConfigVersion < XEND_CONFIG_VERSION_3_0_4) { /* domid was mandatory */
65 66
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing id"));
67
        return -1;
68
    } else {
69 70
        *id = tmp ? sexpr_int(root, "domain/domid") : -1;
        return 0;
71 72 73 74 75
    }
}

/*****************************************************************
 ******
P
Philipp Hahn 已提交
76
 ****** Parsing of S-Expression into virDomainDef objects
77 78 79 80
 ******
 *****************************************************************/

/**
P
Philipp Hahn 已提交
81
 * xenParseSxprOS:
82 83
 * @node: the root of the parsed S-Expression
 * @def: the domain config
P
Philipp Hahn 已提交
84
 * @hvm: true or 1 if node contains HVM S-Expression
85 86 87 88 89 90
 *
 * Parse the xend sexp for description of os and append it to buf.
 *
 * Returns 0 in case of success and -1 in case of error
 */
static int
M
Markus Groß 已提交
91 92 93
xenParseSxprOS(const struct sexpr *node,
               virDomainDefPtr def,
               int hvm)
94 95
{
    if (hvm) {
96
        if (VIR_ALLOC(def->os.loader) < 0)
97
            goto error;
98 99 100 101
        if (sexpr_node_copy(node, "domain/image/hvm/loader", &def->os.loader->path) < 0)
            goto error;
        if (def->os.loader->path == NULL) {
            if (sexpr_node_copy(node, "domain/image/hvm/kernel", &def->os.loader->path) < 0)
102
                goto error;
103

104
            if (def->os.loader->path == NULL) {
105 106
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               "%s", _("domain information incomplete, missing HVM loader"));
107
                return -1;
108 109 110
            }
        } else {
            if (sexpr_node_copy(node, "domain/image/hvm/kernel", &def->os.kernel) < 0)
111
                goto error;
112
            if (sexpr_node_copy(node, "domain/image/hvm/ramdisk", &def->os.initrd) < 0)
113
                goto error;
114
            if (sexpr_node_copy(node, "domain/image/hvm/args", &def->os.cmdline) < 0)
115
                goto error;
116
            if (sexpr_node_copy(node, "domain/image/hvm/root", &def->os.root) < 0)
117
                goto error;
118 119 120
        }
    } else {
        if (sexpr_node_copy(node, "domain/image/linux/kernel", &def->os.kernel) < 0)
121
            goto error;
122
        if (sexpr_node_copy(node, "domain/image/linux/ramdisk", &def->os.initrd) < 0)
123
            goto error;
124
        if (sexpr_node_copy(node, "domain/image/linux/args", &def->os.cmdline) < 0)
125
            goto error;
126
        if (sexpr_node_copy(node, "domain/image/linux/root", &def->os.root) < 0)
127
            goto error;
128 129 130 131 132
    }

    /* If HVM kenrel == loader, then old xend, so kill off kernel */
    if (hvm &&
        def->os.kernel &&
133
        STREQ(def->os.kernel, def->os.loader->path)) {
134 135
        VIR_FREE(def->os.kernel);
    }
136 137 138 139 140 141
    /* Drop kernel argument that has no value */
    if (hvm &&
        def->os.kernel && *def->os.kernel == '\0' &&
        def->os.loader) {
        VIR_FREE(def->os.kernel);
    }
142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164

    if (!def->os.kernel &&
        hvm) {
        const char *boot = sexpr_node(node, "domain/image/hvm/boot");
        if ((boot != NULL) && (boot[0] != 0)) {
            while (*boot &&
                   def->os.nBootDevs < VIR_DOMAIN_BOOT_LAST) {
                if (*boot == 'a')
                    def->os.bootDevs[def->os.nBootDevs++] = VIR_DOMAIN_BOOT_FLOPPY;
                else if (*boot == 'c')
                    def->os.bootDevs[def->os.nBootDevs++] = VIR_DOMAIN_BOOT_DISK;
                else if (*boot == 'd')
                    def->os.bootDevs[def->os.nBootDevs++] = VIR_DOMAIN_BOOT_CDROM;
                else if (*boot == 'n')
                    def->os.bootDevs[def->os.nBootDevs++] = VIR_DOMAIN_BOOT_NET;
                boot++;
            }
        }
    }

    if (!hvm &&
        !def->os.kernel &&
        !def->os.bootloader) {
165 166
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing kernel & bootloader"));
167 168 169 170 171
        return -1;
    }

    return 0;

172
 error:
173 174 175
    return -1;
}

P
Philipp Hahn 已提交
176 177 178 179 180 181 182 183 184 185

/**
  * xenParseSxprChar:
  * @value: A string describing a character device.
  * @tty: the console pty path
  *
  * Parse the xend S-expression for description of a character device.
  *
  * Returns a character device object or NULL in case of failure.
  */
186
virDomainChrDefPtr
M
Markus Groß 已提交
187 188
xenParseSxprChar(const char *value,
                 const char *tty)
189 190 191 192 193
{
    const char *prefix;
    char *tmp;
    virDomainChrDefPtr def;

M
Michal Novotny 已提交
194
    if (!(def = virDomainChrDefNew()))
195 196 197 198 199 200
        return NULL;

    prefix = value;

    if (value[0] == '/') {
        def->source.type = VIR_DOMAIN_CHR_TYPE_DEV;
201 202
        if (VIR_STRDUP(def->source.data.file.path, value) < 0)
            goto error;
203 204 205 206 207 208 209 210 211 212 213
    } else {
        if ((tmp = strchr(value, ':')) != NULL) {
            *tmp = '\0';
            value = tmp + 1;
        }

        if (STRPREFIX(prefix, "telnet")) {
            def->source.type = VIR_DOMAIN_CHR_TYPE_TCP;
            def->source.data.tcp.protocol = VIR_DOMAIN_CHR_TCP_PROTOCOL_TELNET;
        } else {
            if ((def->source.type = virDomainChrTypeFromString(prefix)) < 0) {
214 215
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown chr device type '%s'"), prefix);
216 217 218 219 220 221 222
                goto error;
            }
        }
    }

    switch (def->source.type) {
    case VIR_DOMAIN_CHR_TYPE_PTY:
223 224
        if (VIR_STRDUP(def->source.data.file.path, tty) < 0)
            goto error;
225 226 227 228
        break;

    case VIR_DOMAIN_CHR_TYPE_FILE:
    case VIR_DOMAIN_CHR_TYPE_PIPE:
229 230
        if (VIR_STRDUP(def->source.data.file.path, value) < 0)
            goto error;
231 232 233 234 235 236 237 238
        break;

    case VIR_DOMAIN_CHR_TYPE_TCP:
    {
        const char *offset = strchr(value, ':');
        const char *offset2;

        if (offset == NULL) {
239 240
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("malformed char device string"));
241 242 243 244
            goto error;
        }

        if (offset != value &&
245 246
            VIR_STRNDUP(def->source.data.tcp.host, value, offset - value) < 0)
            goto error;
247 248

        offset2 = strchr(offset, ',');
249 250
        offset++;
        if (VIR_STRNDUP(def->source.data.tcp.service, offset,
251
                        offset2 ? offset2 - offset : -1) < 0)
252
            goto error;
253 254 255 256 257 258 259 260 261 262 263 264

        if (offset2 && strstr(offset2, ",server"))
            def->source.data.tcp.listen = true;
    }
    break;

    case VIR_DOMAIN_CHR_TYPE_UDP:
    {
        const char *offset = strchr(value, ':');
        const char *offset2, *offset3;

        if (offset == NULL) {
265 266
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("malformed char device string"));
267 268 269 270
            goto error;
        }

        if (offset != value &&
271 272
            VIR_STRNDUP(def->source.data.udp.connectHost, value, offset - value) < 0)
            goto error;
273 274 275

        offset2 = strchr(offset, '@');
        if (offset2 != NULL) {
276 277 278
            if (VIR_STRNDUP(def->source.data.udp.connectService,
                            offset + 1, offset2 - offset - 1) < 0)
                goto error;
279 280 281

            offset3 = strchr(offset2, ':');
            if (offset3 == NULL) {
282 283
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               "%s", _("malformed char device string"));
284 285 286 287
                goto error;
            }

            if (offset3 > (offset2 + 1) &&
288 289 290
                VIR_STRNDUP(def->source.data.udp.bindHost,
                            offset2 + 1, offset3 - offset2 - 1) < 0)
                goto error;
291

292 293
            if (VIR_STRDUP(def->source.data.udp.bindService, offset3 + 1) < 0)
                goto error;
294
        } else {
295 296
            if (VIR_STRDUP(def->source.data.udp.connectService, offset + 1) < 0)
                goto error;
297 298 299 300 301 302 303
        }
    }
    break;

    case VIR_DOMAIN_CHR_TYPE_UNIX:
    {
        const char *offset = strchr(value, ',');
304
        if (VIR_STRNDUP(def->source.data.nix.path, value,
305
                        offset ? offset - value : -1) < 0)
306
            goto error;
307 308 309 310 311 312 313 314 315 316

        if (offset != NULL &&
            strstr(offset, ",server") != NULL)
            def->source.data.nix.listen = true;
    }
    break;
    }

    return def;

317
 error:
318 319 320 321
    virDomainChrDefFree(def);
    return NULL;
}

P
Philipp Hahn 已提交
322

323
/**
P
Philipp Hahn 已提交
324 325 326 327
 * xenParseSxprDisks:
 * @def: the domain config
 * @root: root S-expression
 * @hvm: true or 1 if node contains HVM S-Expression
328 329
 * @xendConfigVersion: version of xend
 *
P
Philipp Hahn 已提交
330
 * This parses out block devices from the domain S-expression
331 332 333 334
 *
 * Returns 0 if successful or -1 if failed.
 */
static int
M
Markus Groß 已提交
335 336 337 338
xenParseSxprDisks(virDomainDefPtr def,
                  const struct sexpr *root,
                  int hvm,
                  int xendConfigVersion)
339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354
{
    const struct sexpr *cur, *node;
    virDomainDiskDefPtr disk = NULL;

    for (cur = root; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        node = cur->u.s.car;
        /* Normally disks are in a (device (vbd ...)) block
           but blktap disks ended up in a differently named
           (device (tap ....)) block.... */
        if (sexpr_lookup(node, "device/vbd") ||
            sexpr_lookup(node, "device/tap") ||
            sexpr_lookup(node, "device/tap2")) {
            char *offset;
            const char *src = NULL;
            const char *dst = NULL;
            const char *mode = NULL;
P
Philipp Hahn 已提交
355
            const char *bootable = NULL;
356 357 358 359 360 361

            /* Again dealing with (vbd...) vs (tap ...) differences */
            if (sexpr_lookup(node, "device/vbd")) {
                src = sexpr_node(node, "device/vbd/uname");
                dst = sexpr_node(node, "device/vbd/dev");
                mode = sexpr_node(node, "device/vbd/mode");
P
Philipp Hahn 已提交
362
                bootable = sexpr_node(node, "device/vbd/bootable");
363 364 365 366
            } else if (sexpr_lookup(node, "device/tap2")) {
                src = sexpr_node(node, "device/tap2/uname");
                dst = sexpr_node(node, "device/tap2/dev");
                mode = sexpr_node(node, "device/tap2/mode");
P
Philipp Hahn 已提交
367
                bootable = sexpr_node(node, "device/tap2/bootable");
368 369 370 371
            } else {
                src = sexpr_node(node, "device/tap/uname");
                dst = sexpr_node(node, "device/tap/dev");
                mode = sexpr_node(node, "device/tap/mode");
P
Philipp Hahn 已提交
372
                bootable = sexpr_node(node, "device/tap/bootable");
373 374
            }

375
            if (!(disk = virDomainDiskDefNew(NULL)))
376
                goto error;
377 378

            if (dst == NULL) {
379 380
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               "%s", _("domain information incomplete, vbd has no dev"));
381 382 383 384 385 386 387 388 389
                goto error;
            }

            if (src == NULL) {
                /* There is a case without the uname to the CD-ROM device */
                offset = strchr(dst, ':');
                if (!offset ||
                    !hvm ||
                    STRNEQ(offset, ":cdrom")) {
390 391
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   "%s", _("domain information incomplete, vbd has no src"));
392 393 394 395 396 397 398
                    goto error;
                }
            }

            if (src != NULL) {
                offset = strchr(src, ':');
                if (!offset) {
399 400
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   "%s", _("cannot parse vbd filename, missing driver name"));
401 402 403
                    goto error;
                }

P
Philipp Hahn 已提交
404 405
                if (sexpr_lookup(node, "device/tap2") &&
                    STRPREFIX(src, "tap:")) {
406
                    if (virDomainDiskSetDriver(disk, "tap2") < 0)
407
                        goto error;
P
Philipp Hahn 已提交
408
                } else {
409 410
                    char *tmp;
                    if (VIR_STRNDUP(tmp, src, offset - src) < 0)
411
                        goto error;
412 413
                    if (virDomainDiskSetDriver(disk, tmp) < 0) {
                        VIR_FREE(tmp);
P
Philipp Hahn 已提交
414 415
                        goto error;
                    }
416
                    VIR_FREE(tmp);
417 418 419 420
                }

                src = offset + 1;

421 422
                if (STREQ(virDomainDiskGetDriver(disk), "tap") ||
                    STREQ(virDomainDiskGetDriver(disk), "tap2")) {
423 424
                    char *driverType = NULL;

425 426
                    offset = strchr(src, ':');
                    if (!offset) {
427 428
                        virReportError(VIR_ERR_INTERNAL_ERROR,
                                       "%s", _("cannot parse vbd filename, missing driver type"));
429 430 431
                        goto error;
                    }

432 433
                    if (VIR_STRNDUP(driverType, src, offset - src) < 0)
                        goto error;
434
                    if (STREQ(driverType, "aio"))
435
                        virDomainDiskSetFormat(disk, VIR_STORAGE_FILE_RAW);
436
                    else
437 438
                        virDomainDiskSetFormat(disk,
                                               virStorageFileFormatTypeFromString(driverType));
439
                    VIR_FREE(driverType);
440
                    if (virDomainDiskGetFormat(disk) <= 0) {
441
                        virReportError(VIR_ERR_INTERNAL_ERROR,
442
                                       _("Unknown driver type %s"), src);
443 444 445 446 447 448 449 450 451
                        goto error;
                    }

                    src = offset + 1;
                    /* Its possible to use blktap driver for block devs
                       too, but kinda pointless because blkback is better,
                       so we assume common case here. If blktap becomes
                       omnipotent, we can revisit this, perhaps stat()'ing
                       the src file in question */
E
Eric Blake 已提交
452
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
453
                } else if (STREQ(virDomainDiskGetDriver(disk), "phy")) {
E
Eric Blake 已提交
454
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_BLOCK);
455
                } else if (STREQ(virDomainDiskGetDriver(disk), "file")) {
E
Eric Blake 已提交
456
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
457 458 459 460 461
                }
            } else {
                /* No CDROM media so can't really tell. We'll just
                   call if a FILE for now and update when media
                   is inserted later */
E
Eric Blake 已提交
462
                virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
463 464
            }

465
            if (STREQLEN(dst, "ioemu:", 6))
466 467 468 469
                dst += 6;

            disk->device = VIR_DOMAIN_DISK_DEVICE_DISK;
            /* New style disk config from Xen >= 3.0.3 */
470
            if (xendConfigVersion >= XEND_CONFIG_VERSION_3_0_3) {
471 472
                offset = strrchr(dst, ':');
                if (offset) {
473
                    if (STREQ(offset, ":cdrom")) {
474
                        disk->device = VIR_DOMAIN_DISK_DEVICE_CDROM;
475
                    } else if (STREQ(offset, ":disk")) {
476 477 478 479 480 481 482 483
                        /* The default anyway */
                    } else {
                        /* Unknown, lets pretend its a disk too */
                    }
                    offset[0] = '\0';
                }
            }

484 485
            if (VIR_STRDUP(disk->dst, dst) < 0)
                goto error;
486
            if (virDomainDiskSetSource(disk, src) < 0)
487
                goto error;
488 489 490 491 492 493 494 495 496 497 498 499

            if (STRPREFIX(disk->dst, "xvd"))
                disk->bus = VIR_DOMAIN_DISK_BUS_XEN;
            else if (STRPREFIX(disk->dst, "hd"))
                disk->bus = VIR_DOMAIN_DISK_BUS_IDE;
            else if (STRPREFIX(disk->dst, "sd"))
                disk->bus = VIR_DOMAIN_DISK_BUS_SCSI;
            else
                disk->bus = VIR_DOMAIN_DISK_BUS_IDE;

            if (mode &&
                strchr(mode, 'r'))
500
                disk->src->readonly = true;
501 502
            if (mode &&
                strchr(mode, '!'))
503
                disk->src->shared = true;
504 505

            if (VIR_REALLOC_N(def->disks, def->ndisks+1) < 0)
506
                goto error;
507

P
Philipp Hahn 已提交
508 509 510 511 512 513 514
            /* re-order disks if there is a bootable device */
            if (STREQ_NULLABLE(bootable, "1")) {
                def->disks[def->ndisks++] = def->disks[0];
                def->disks[0] = disk;
            } else {
                def->disks[def->ndisks++] = disk;
            }
515 516 517 518 519 520
            disk = NULL;
        }
    }

    return 0;

521
 error:
522 523 524 525 526
    virDomainDiskDefFree(disk);
    return -1;
}


P
Philipp Hahn 已提交
527 528 529 530 531 532 533 534 535
/**
 * xenParseSxprNets:
 * @def: the domain config
 * @root: root S-expression
 *
 * This parses out network devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
536
static int
M
Markus Groß 已提交
537 538
xenParseSxprNets(virDomainDefPtr def,
                 const struct sexpr *root)
539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554
{
    virDomainNetDefPtr net = NULL;
    const struct sexpr *cur, *node;
    const char *tmp;
    int vif_index = 0;

    for (cur = root; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        node = cur->u.s.car;
        if (sexpr_lookup(node, "device/vif")) {
            const char *tmp2, *model, *type;
            tmp2 = sexpr_node(node, "device/vif/script");
            tmp = sexpr_node(node, "device/vif/bridge");
            model = sexpr_node(node, "device/vif/model");
            type = sexpr_node(node, "device/vif/type");

            if (VIR_ALLOC(net) < 0)
555
                goto cleanup;
556 557 558 559 560 561

            if (tmp != NULL ||
                (tmp2 != NULL && STREQ(tmp2, DEFAULT_VIF_SCRIPT))) {
                net->type = VIR_DOMAIN_NET_TYPE_BRIDGE;
                /* XXX virtual network reverse resolve */

562 563 564 565 566
                if (VIR_STRDUP(net->data.bridge.brname, tmp) < 0)
                    goto cleanup;
                if (net->type == VIR_DOMAIN_NET_TYPE_BRIDGE &&
                    VIR_STRDUP(net->script, tmp2) < 0)
                    goto cleanup;
567
                tmp = sexpr_node(node, "device/vif/ip");
568
                if (tmp && virDomainNetAppendIpAddress(net, tmp, AF_UNSPEC, 0) < 0)
569
                    goto cleanup;
570 571
            } else {
                net->type = VIR_DOMAIN_NET_TYPE_ETHERNET;
572 573
                if (VIR_STRDUP(net->script, tmp2) < 0)
                    goto cleanup;
574
                tmp = sexpr_node(node, "device/vif/ip");
575
                if (tmp && virDomainNetAppendIpAddress(net, tmp, AF_UNSPEC, 0) < 0)
576
                    goto cleanup;
577 578 579
            }

            tmp = sexpr_node(node, "device/vif/vifname");
580 581 582 583
            /* If vifname is specified in xend config, include it in net
             * definition regardless of domain state.  If vifname is not
             * specified, only generate one if domain is active (id != -1). */
            if (tmp) {
584 585
                if (VIR_STRDUP(net->ifname, tmp) < 0)
                    goto cleanup;
586 587
            } else if (def->id != -1) {
                if (virAsprintf(&net->ifname, "vif%d.%d", def->id, vif_index) < 0)
588
                    goto cleanup;
589 590 591 592
            }

            tmp = sexpr_node(node, "device/vif/mac");
            if (tmp) {
593
                if (virMacAddrParse(tmp, &net->mac) < 0) {
594 595
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   _("malformed mac address '%s'"), tmp);
596 597 598 599
                    goto cleanup;
                }
            }

600 601
            if (VIR_STRDUP(net->model, model) < 0)
                goto cleanup;
602

603 604 605
            if (!model && type && STREQ(type, "netfront") &&
                VIR_STRDUP(net->model, "netfront") < 0)
                goto cleanup;
606

607
            if (VIR_APPEND_ELEMENT(def->nets, def->nnets, net) < 0)
608
                goto cleanup;
609 610 611 612 613 614 615

            vif_index++;
        }
    }

    return 0;

616
 cleanup:
617 618 619 620 621
    virDomainNetDefFree(net);
    return -1;
}


P
Philipp Hahn 已提交
622 623 624 625 626 627 628 629 630
/**
 * xenParseSxprSound:
 * @def: the domain config
 * @str: comma separated list of sound models
 *
 * This parses out sound devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
631
int
M
Markus Groß 已提交
632 633
xenParseSxprSound(virDomainDefPtr def,
                  const char *str)
634 635
{
    if (STREQ(str, "all")) {
636
        size_t i;
637 638

        /*
639
         * Special compatibility code for Xen with a bogus
640 641
         * sound=all in config.
         *
E
Eric Blake 已提交
642
         * NB deliberately, don't include all possible
643 644 645 646 647 648 649 650 651 652
         * sound models anymore, just the 2 that were
         * historically present in Xen's QEMU.
         *
         * ie just es1370 + sb16.
         *
         * Hence use of MODEL_ES1370 + 1, instead of MODEL_LAST
         */

        if (VIR_ALLOC_N(def->sounds,
                        VIR_DOMAIN_SOUND_MODEL_ES1370 + 1) < 0)
653
            goto error;
654 655


656
        for (i = 0; i < (VIR_DOMAIN_SOUND_MODEL_ES1370 + 1); i++) {
657 658
            virDomainSoundDefPtr sound;
            if (VIR_ALLOC(sound) < 0)
659
                goto error;
660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675
            sound->model = i;
            def->sounds[def->nsounds++] = sound;
        }
    } else {
        char model[10];
        const char *offset = str, *offset2;

        do {
            int len;
            virDomainSoundDefPtr sound;
            offset2 = strchr(offset, ',');
            if (offset2)
                len = (offset2 - offset);
            else
                len = strlen(offset);
            if (virStrncpy(model, offset, len, sizeof(model)) == NULL) {
676 677 678
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("Sound model %s too big for destination"),
                               offset);
679 680 681 682
                goto error;
            }

            if (VIR_ALLOC(sound) < 0)
683
                goto error;
684 685 686 687 688 689

            if ((sound->model = virDomainSoundModelTypeFromString(model)) < 0) {
                VIR_FREE(sound);
                goto error;
            }

690
            if (VIR_APPEND_ELEMENT(def->sounds, def->nsounds, sound) < 0) {
691
                virDomainSoundDefFree(sound);
692
                goto error;
693 694 695 696 697 698 699 700
            }

            offset = offset2 ? offset2 + 1 : NULL;
        } while (offset);
    }

    return 0;

701
 error:
702 703 704 705
    return -1;
}


P
Philipp Hahn 已提交
706 707 708 709 710 711 712 713 714
/**
 * xenParseSxprUSB:
 * @def: the domain config
 * @root: root S-expression
 *
 * This parses out USB devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
715
static int
M
Markus Groß 已提交
716 717
xenParseSxprUSB(virDomainDefPtr def,
                const struct sexpr *root)
718 719 720 721 722 723 724 725 726 727
{
    struct sexpr *cur, *node;
    const char *tmp;

    for (cur = sexpr_lookup(root, "domain/image/hvm"); cur && cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        node = cur->u.s.car;
        if (sexpr_lookup(node, "usbdevice")) {
            tmp = sexpr_node(node, "usbdevice");
            if (tmp && *tmp) {
                if (STREQ(tmp, "tablet") ||
728 729
                    STREQ(tmp, "mouse") ||
                    STREQ(tmp, "keyboard")) {
730 731
                    virDomainInputDefPtr input;
                    if (VIR_ALLOC(input) < 0)
732
                        goto error;
733 734 735
                    input->bus = VIR_DOMAIN_INPUT_BUS_USB;
                    if (STREQ(tmp, "tablet"))
                        input->type = VIR_DOMAIN_INPUT_TYPE_TABLET;
736
                    else if (STREQ(tmp, "mouse"))
737
                        input->type = VIR_DOMAIN_INPUT_TYPE_MOUSE;
738 739
                    else
                        input->type = VIR_DOMAIN_INPUT_TYPE_KBD;
740

741
                    if (VIR_APPEND_ELEMENT(def->inputs, def->ninputs, input) < 0) {
742
                        VIR_FREE(input);
743
                        goto error;
744 745 746 747 748 749 750 751 752
                    }
                } else {
                    /* XXX Handle other non-input USB devices later */
                }
            }
        }
    }
    return 0;

753
 error:
754 755 756
    return -1;
}

P
Philipp Hahn 已提交
757 758 759 760 761 762 763 764 765 766 767 768 769

/*
 * xenParseSxprGraphicsOld:
 * @def: the domain config
 * @root: root S-expression
 * @hvm: true or 1 if root contains HVM S-Expression
 * @xendConfigVersion: version of xend
 * @vncport: VNC port number
 *
 * This parses out VNC devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
770
static int
M
Markus Groß 已提交
771 772 773 774
xenParseSxprGraphicsOld(virDomainDefPtr def,
                        const struct sexpr *root,
                        int hvm,
                        int xendConfigVersion, int vncport)
775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790
{
    const char *tmp;
    virDomainGraphicsDefPtr graphics = NULL;

    if ((tmp = sexpr_fmt_node(root, "domain/image/%s/vnc", hvm ? "hvm" : "linux")) &&
        tmp[0] == '1') {
        /* Graphics device (HVM, or old (pre-3.0.4) style PV VNC config) */
        int port;
        const char *listenAddr = sexpr_fmt_node(root, "domain/image/%s/vnclisten", hvm ? "hvm" : "linux");
        const char *vncPasswd = sexpr_fmt_node(root, "domain/image/%s/vncpasswd", hvm ? "hvm" : "linux");
        const char *keymap = sexpr_fmt_node(root, "domain/image/%s/keymap", hvm ? "hvm" : "linux");
        const char *unused = sexpr_fmt_node(root, "domain/image/%s/vncunused", hvm ? "hvm" : "linux");

        port = vncport;

        if (VIR_ALLOC(graphics) < 0)
791
            goto error;
792 793 794 795 796

        graphics->type = VIR_DOMAIN_GRAPHICS_TYPE_VNC;
        /* For Xen >= 3.0.3, don't generate a fixed port mapping
         * because it will almost certainly be wrong ! Just leave
         * it as -1 which lets caller see that the VNC server isn't
J
Ján Tomko 已提交
797
         * present yet. Subsequent dumps of the XML will eventually
798 799
         * find the port in XenStore once VNC server has started
         */
800
        if (port == -1 && xendConfigVersion < XEND_CONFIG_VERSION_3_0_3)
801 802 803
            port = 5900 + def->id;

        if ((unused && STREQ(unused, "1")) || port == -1)
804
            graphics->data.vnc.autoport = true;
805 806 807
        graphics->data.vnc.port = port;

        if (listenAddr &&
808 809
            virDomainGraphicsListenSetAddress(graphics, 0, listenAddr, -1, true))
            goto error;
810

811 812
        if (VIR_STRDUP(graphics->data.vnc.auth.passwd, vncPasswd) < 0)
            goto error;
813

814 815
        if (VIR_STRDUP(graphics->data.vnc.keymap, keymap) < 0)
            goto error;
816 817

        if (VIR_ALLOC_N(def->graphics, 1) < 0)
818
            goto error;
819 820 821 822 823 824 825 826 827 828
        def->graphics[0] = graphics;
        def->ngraphics = 1;
        graphics = NULL;
    } else if ((tmp = sexpr_fmt_node(root, "domain/image/%s/sdl", hvm ? "hvm" : "linux")) &&
               tmp[0] == '1') {
        /* Graphics device (HVM, or old (pre-3.0.4) style PV sdl config) */
        const char *display = sexpr_fmt_node(root, "domain/image/%s/display", hvm ? "hvm" : "linux");
        const char *xauth = sexpr_fmt_node(root, "domain/image/%s/xauthority", hvm ? "hvm" : "linux");

        if (VIR_ALLOC(graphics) < 0)
829
            goto error;
830 831

        graphics->type = VIR_DOMAIN_GRAPHICS_TYPE_SDL;
832 833 834 835
        if (VIR_STRDUP(graphics->data.sdl.display, display) < 0)
            goto error;
        if (VIR_STRDUP(graphics->data.sdl.xauth, xauth) < 0)
            goto error;
836 837

        if (VIR_ALLOC_N(def->graphics, 1) < 0)
838
            goto error;
839 840 841 842 843 844 845
        def->graphics[0] = graphics;
        def->ngraphics = 1;
        graphics = NULL;
    }

    return 0;

846
 error:
847 848 849 850 851
    virDomainGraphicsDefFree(graphics);
    return -1;
}


P
Philipp Hahn 已提交
852 853 854 855 856 857 858 859 860 861
/*
 * xenParseSxprGraphicsNew:
 * @def: the domain config
 * @root: root S-expression
 * @vncport: VNC port number
 *
 * This parses out VNC devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
862
static int
M
Markus Groß 已提交
863 864
xenParseSxprGraphicsNew(virDomainDefPtr def,
                        const struct sexpr *root, int vncport)
865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886
{
    virDomainGraphicsDefPtr graphics = NULL;
    const struct sexpr *cur, *node;
    const char *tmp;

    /* append network devices and framebuffer */
    for (cur = root; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        node = cur->u.s.car;
        if (sexpr_lookup(node, "device/vfb")) {
            /* New style graphics config for PV guests in >= 3.0.4,
             * or for HVM guests in >= 3.0.5 */
            if (sexpr_node(node, "device/vfb/type")) {
                tmp = sexpr_node(node, "device/vfb/type");
            } else if (sexpr_node(node, "device/vfb/vnc")) {
                tmp = "vnc";
            } else if (sexpr_node(node, "device/vfb/sdl")) {
                tmp = "sdl";
            } else {
                tmp = "unknown";
            }

            if (VIR_ALLOC(graphics) < 0)
887
                goto error;
888 889

            if ((graphics->type = virDomainGraphicsTypeFromString(tmp)) < 0) {
890 891
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown graphics type '%s'"), tmp);
892 893 894 895 896 897
                goto error;
            }

            if (graphics->type == VIR_DOMAIN_GRAPHICS_TYPE_SDL) {
                const char *display = sexpr_node(node, "device/vfb/display");
                const char *xauth = sexpr_node(node, "device/vfb/xauthority");
898 899 900 901
                if (VIR_STRDUP(graphics->data.sdl.display, display) < 0)
                    goto error;
                if (VIR_STRDUP(graphics->data.sdl.xauth, xauth) < 0)
                    goto error;
902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919
            } else {
                int port;
                const char *listenAddr = sexpr_node(node, "device/vfb/vnclisten");
                const char *vncPasswd = sexpr_node(node, "device/vfb/vncpasswd");
                const char *keymap = sexpr_node(node, "device/vfb/keymap");
                const char *unused = sexpr_node(node, "device/vfb/vncunused");

                port = vncport;

                /* Didn't find port entry in xenstore */
                if (port == -1) {
                    const char *str = sexpr_node(node, "device/vfb/vncdisplay");
                    int val;
                    if (str != NULL && virStrToLong_i(str, NULL, 0, &val) == 0)
                        port = val;
                }

                if ((unused && STREQ(unused, "1")) || port == -1)
920
                    graphics->data.vnc.autoport = true;
921 922 923 924 925 926

                if (port >= 0 && port < 5900)
                    port += 5900;
                graphics->data.vnc.port = port;

                if (listenAddr &&
927 928
                    virDomainGraphicsListenSetAddress(graphics, 0, listenAddr, -1, true))
                    goto error;
929

930 931
                if (VIR_STRDUP(graphics->data.vnc.auth.passwd, vncPasswd) < 0)
                    goto error;
932

933 934
                if (VIR_STRDUP(graphics->data.vnc.keymap, keymap) < 0)
                    goto error;
935 936 937
            }

            if (VIR_ALLOC_N(def->graphics, 1) < 0)
938
                goto error;
939 940 941 942 943 944 945 946 947
            def->graphics[0] = graphics;
            def->ngraphics = 1;
            graphics = NULL;
            break;
        }
    }

    return 0;

948
 error:
949 950 951 952
    virDomainGraphicsDefFree(graphics);
    return -1;
}

P
Philipp Hahn 已提交
953

954
/**
P
Philipp Hahn 已提交
955 956
 * xenParseSxprPCI:
 * @def: the domain config
957 958
 * @root: root sexpr
 *
P
Philipp Hahn 已提交
959
 * This parses out PCI devices from the domain sexpr
960 961 962 963
 *
 * Returns 0 if successful or -1 if failed.
 */
static int
M
Markus Groß 已提交
964 965
xenParseSxprPCI(virDomainDefPtr def,
                const struct sexpr *root)
966 967 968 969 970 971 972 973 974 975 976 977 978 979 980
{
    const struct sexpr *cur, *tmp = NULL, *node;
    virDomainHostdevDefPtr dev = NULL;

    /*
     * With the (domain ...) block we have the following odd setup
     *
     * (device
     *    (pci
     *       (dev (domain 0x0000) (bus 0x00) (slot 0x1b) (func 0x0))
     *       (dev (domain 0x0000) (bus 0x00) (slot 0x13) (func 0x0))
     *    )
     * )
     *
     * Normally there is one (device ...) block per device, but in
E
Eric Blake 已提交
981
     * weird world of Xen PCI, once (device ...) covers multiple
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
     * devices.
     */

    for (cur = root; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        node = cur->u.s.car;
        if ((tmp = sexpr_lookup(node, "device/pci")) != NULL)
            break;
    }

    if (!tmp)
        return 0;

    for (cur = tmp; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
        const char *domain = NULL;
        const char *bus = NULL;
        const char *slot = NULL;
        const char *func = NULL;
        int domainID;
        int busID;
        int slotID;
        int funcID;

        node = cur->u.s.car;
        if (!sexpr_lookup(node, "dev"))
            continue;

        if (!(domain = sexpr_node(node, "dev/domain"))) {
1009 1010
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI domain"));
1011 1012 1013
            goto error;
        }
        if (!(bus = sexpr_node(node, "dev/bus"))) {
1014 1015
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI bus"));
1016 1017 1018
            goto error;
        }
        if (!(slot = sexpr_node(node, "dev/slot"))) {
1019 1020
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI slot"));
1021 1022 1023
            goto error;
        }
        if (!(func = sexpr_node(node, "dev/func"))) {
1024 1025
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI func"));
1026 1027 1028 1029
            goto error;
        }

        if (virStrToLong_i(domain, NULL, 0, &domainID) < 0) {
1030 1031
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI domain '%s'"), domain);
1032 1033 1034
            goto error;
        }
        if (virStrToLong_i(bus, NULL, 0, &busID) < 0) {
1035 1036
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI bus '%s'"), bus);
1037 1038 1039
            goto error;
        }
        if (virStrToLong_i(slot, NULL, 0, &slotID) < 0) {
1040 1041
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI slot '%s'"), slot);
1042 1043 1044
            goto error;
        }
        if (virStrToLong_i(func, NULL, 0, &funcID) < 0) {
1045 1046
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI func '%s'"), func);
1047 1048 1049
            goto error;
        }

1050 1051
        if (!(dev = virDomainHostdevDefAlloc()))
           goto error;
1052 1053

        dev->mode = VIR_DOMAIN_HOSTDEV_MODE_SUBSYS;
1054
        dev->managed = false;
1055
        dev->source.subsys.type = VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI;
1056 1057 1058 1059
        dev->source.subsys.u.pci.addr.domain = domainID;
        dev->source.subsys.u.pci.addr.bus = busID;
        dev->source.subsys.u.pci.addr.slot = slotID;
        dev->source.subsys.u.pci.addr.function = funcID;
1060

1061
        if (VIR_APPEND_ELEMENT(def->hostdevs, def->nhostdevs, dev) < 0)
1062
            goto error;
1063 1064 1065 1066
    }

    return 0;

1067
 error:
1068 1069 1070 1071 1072 1073
    virDomainHostdevDefFree(dev);
    return -1;
}


/**
M
Markus Groß 已提交
1074
 * xenParseSxpr:
1075 1076 1077
 * @root: the root of the parsed S-Expression
 * @xendConfigVersion: version of xend
 * @cpus: set of cpus the domain may be pinned to
P
Philipp Hahn 已提交
1078 1079
 * @tty: the console pty path
 * @vncport: VNC port number
1080
 *
P
Philipp Hahn 已提交
1081 1082
 * Parse the xend S-expression description and turn it into a virDomainDefPtr
 * representing these settings as closely as is practical.
1083
 *
P
Philipp Hahn 已提交
1084 1085
 * Returns the domain config or NULL in case of error.
 *         The caller must free() the returned value.
1086 1087
 */
virDomainDefPtr
M
Markus Groß 已提交
1088 1089 1090
xenParseSxpr(const struct sexpr *root,
             int xendConfigVersion,
             const char *cpus, char *tty, int vncport)
1091 1092 1093
{
    const char *tmp;
    virDomainDefPtr def;
P
Philipp Hahn 已提交
1094
    int hvm = 0, vmlocaltime;
1095

1096
    if (!(def = virDomainDefNew()))
1097
        goto error;
1098 1099

    tmp = sexpr_node(root, "domain/domid");
1100
    if (tmp == NULL && xendConfigVersion < XEND_CONFIG_VERSION_3_0_4) { /* domid was mandatory */
1101 1102
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing id"));
1103 1104 1105 1106 1107 1108 1109 1110 1111
        goto error;
    }
    def->virtType = VIR_DOMAIN_VIRT_XEN;
    if (tmp)
        def->id = sexpr_int(root, "domain/domid");
    else
        def->id = -1;

    if (sexpr_node_copy(root, "domain/name", &def->name) < 0)
1112
        goto error;
1113
    if (def->name == NULL) {
1114 1115
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing name"));
1116 1117 1118 1119 1120
        goto error;
    }

    tmp = sexpr_node(root, "domain/uuid");
    if (tmp == NULL) {
1121 1122
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing name"));
1123 1124
        goto error;
    }
1125 1126
    if (virUUIDParse(tmp, def->uuid) < 0)
        goto error;
1127 1128

    if (sexpr_node_copy(root, "domain/description", &def->description) < 0)
1129
        goto error;
1130 1131 1132 1133 1134

    hvm = sexpr_lookup(root, "domain/image/hvm") ? 1 : 0;
    if (!hvm) {
        if (sexpr_node_copy(root, "domain/bootloader",
                            &def->os.bootloader) < 0)
1135
            goto error;
1136 1137 1138

        if (!def->os.bootloader &&
            sexpr_has(root, "domain/bootloader") &&
1139 1140
            VIR_STRDUP(def->os.bootloader, "") < 0)
            goto error;
1141 1142 1143 1144

        if (def->os.bootloader &&
            sexpr_node_copy(root, "domain/bootloader_args",
                            &def->os.bootloaderArgs) < 0)
1145
            goto error;
1146 1147
    }

1148
    def->os.type = (hvm ? VIR_DOMAIN_OSTYPE_HVM : VIR_DOMAIN_OSTYPE_LINUX);
1149 1150 1151

    if (def->id != 0) {
        if (sexpr_lookup(root, "domain/image")) {
M
Markus Groß 已提交
1152
            if (xenParseSxprOS(root, def, hvm) < 0)
1153 1154 1155 1156
                goto error;
        }
    }

1157
    virDomainDefSetMemoryTotal(def, (sexpr_u64(root, "domain/maxmem") << 10));
1158
    def->mem.cur_balloon = (sexpr_u64(root, "domain/memory") << 10);
1159 1160 1161

    if (def->mem.cur_balloon > virDomainDefGetMemoryActual(def))
        def->mem.cur_balloon = virDomainDefGetMemoryActual(def);
1162 1163

    if (cpus != NULL) {
H
Hu Tao 已提交
1164
        if (virBitmapParse(cpus, 0, &def->cpumask,
1165
                           VIR_DOMAIN_CPUMASK_LEN) < 0)
1166
            goto error;
1167 1168 1169 1170 1171 1172 1173

        if (virBitmapIsAllClear(def->cpumask)) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("Invalid value of 'cpumask': %s"),
                           cpus);
            goto error;
        }
1174 1175 1176 1177 1178 1179 1180 1181 1182 1183
    }

    def->maxvcpus = sexpr_int(root, "domain/vcpus");
    def->vcpus = count_one_bits_l(sexpr_u64(root, "domain/vcpu_avail"));
    if (!def->vcpus || def->maxvcpus < def->vcpus)
        def->vcpus = def->maxvcpus;

    tmp = sexpr_node(root, "domain/on_poweroff");
    if (tmp != NULL) {
        if ((def->onPoweroff = virDomainLifecycleTypeFromString(tmp)) < 0) {
1184 1185
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1186 1187
            goto error;
        }
1188
    } else {
1189
        def->onPoweroff = VIR_DOMAIN_LIFECYCLE_DESTROY;
1190
    }
1191 1192 1193 1194

    tmp = sexpr_node(root, "domain/on_reboot");
    if (tmp != NULL) {
        if ((def->onReboot = virDomainLifecycleTypeFromString(tmp)) < 0) {
1195 1196
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1197 1198
            goto error;
        }
1199
    } else {
1200
        def->onReboot = VIR_DOMAIN_LIFECYCLE_RESTART;
1201
    }
1202 1203 1204 1205

    tmp = sexpr_node(root, "domain/on_crash");
    if (tmp != NULL) {
        if ((def->onCrash = virDomainLifecycleCrashTypeFromString(tmp)) < 0) {
1206 1207
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1208 1209
            goto error;
        }
1210
    } else {
1211
        def->onCrash = VIR_DOMAIN_LIFECYCLE_CRASH_DESTROY;
1212
    }
1213 1214 1215

    if (hvm) {
        if (sexpr_int(root, "domain/image/hvm/acpi"))
J
Ján Tomko 已提交
1216
            def->features[VIR_DOMAIN_FEATURE_ACPI] = VIR_TRISTATE_SWITCH_ON;
1217
        if (sexpr_int(root, "domain/image/hvm/apic"))
J
Ján Tomko 已提交
1218
            def->features[VIR_DOMAIN_FEATURE_APIC] = VIR_TRISTATE_SWITCH_ON;
1219
        if (sexpr_int(root, "domain/image/hvm/pae"))
J
Ján Tomko 已提交
1220
            def->features[VIR_DOMAIN_FEATURE_PAE] = VIR_TRISTATE_SWITCH_ON;
1221
        if (sexpr_int(root, "domain/image/hvm/hap"))
J
Ján Tomko 已提交
1222
            def->features[VIR_DOMAIN_FEATURE_HAP] = VIR_TRISTATE_SWITCH_ON;
1223
        if (sexpr_int(root, "domain/image/hvm/viridian"))
J
Ján Tomko 已提交
1224
            def->features[VIR_DOMAIN_FEATURE_VIRIDIAN] = VIR_TRISTATE_SWITCH_ON;
P
Philipp Hahn 已提交
1225
    }
1226

P
Philipp Hahn 已提交
1227 1228 1229 1230 1231 1232
    /* 12aaf4a2486b (3.0.3) added a second low-priority 'localtime' setting */
    vmlocaltime = sexpr_int(root, "domain/localtime");
    if (hvm) {
        const char *value = sexpr_node(root, "domain/image/hvm/localtime");
        if (value) {
            if (virStrToLong_i(value, NULL, 0, &vmlocaltime) < 0) {
1233 1234
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown localtime offset %s"), value);
P
Philipp Hahn 已提交
1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253
                goto error;
            }
        }
        /* only managed HVM domains since 3.1.0 have persistent rtc_timeoffset */
        if (xendConfigVersion < XEND_CONFIG_VERSION_3_1_0) {
            if (vmlocaltime)
                def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME;
            else
                def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_UTC;
            def->clock.data.utc_reset = true;
        } else {
            int rtc_offset;
            def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_VARIABLE;
            rtc_offset =  sexpr_int(root, "domain/image/hvm/rtc_timeoffset");
            def->clock.data.variable.adjustment = rtc_offset;
            def->clock.data.variable.basis = vmlocaltime ?
                VIR_DOMAIN_CLOCK_BASIS_LOCALTIME :
                VIR_DOMAIN_CLOCK_BASIS_UTC;
        }
1254 1255 1256 1257 1258

        if (sexpr_lookup(root, "domain/image/hvm/hpet")) {
            virDomainTimerDefPtr timer;

            if (VIR_ALLOC_N(def->clock.timers, 1) < 0 ||
1259
                VIR_ALLOC(timer) < 0)
1260 1261 1262 1263 1264 1265 1266 1267 1268
                goto error;

            timer->name = VIR_DOMAIN_TIMER_NAME_HPET;
            timer->present = sexpr_int(root, "domain/image/hvm/hpet");
            timer->tickpolicy = -1;

            def->clock.ntimers = 1;
            def->clock.timers[0] = timer;
        }
P
Philipp Hahn 已提交
1269 1270 1271 1272
    } else {
        const char *value = sexpr_node(root, "domain/image/linux/localtime");
        if (value) {
            if (virStrToLong_i(value, NULL, 0, &vmlocaltime) < 0) {
1273 1274
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown localtime offset %s"), value);
P
Philipp Hahn 已提交
1275 1276 1277 1278 1279
                goto error;
            }
        }
        /* PV domains do not have an emulated RTC and the offset is fixed. */
        if (vmlocaltime)
1280
            def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME;
P
Philipp Hahn 已提交
1281 1282 1283 1284
        else
            def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_UTC;
        def->clock.data.utc_reset = true;
    } /* !hvm */
1285 1286 1287 1288 1289

    if (sexpr_node_copy(root, hvm ?
                        "domain/image/hvm/device_model" :
                        "domain/image/linux/device_model",
                        &def->emulator) < 0)
1290
        goto error;
1291 1292

    /* append block devices */
M
Markus Groß 已提交
1293
    if (xenParseSxprDisks(def, root, hvm, xendConfigVersion) < 0)
1294 1295
        goto error;

M
Markus Groß 已提交
1296
    if (xenParseSxprNets(def, root) < 0)
1297 1298
        goto error;

M
Markus Groß 已提交
1299
    if (xenParseSxprPCI(def, root) < 0)
1300 1301 1302
        goto error;

    /* New style graphics device config */
M
Markus Groß 已提交
1303
    if (xenParseSxprGraphicsNew(def, root, vncport) < 0)
1304 1305 1306 1307
        goto error;

    /* Graphics device (HVM <= 3.0.4, or PV <= 3.0.3) vnc config */
    if ((def->ngraphics == 0) &&
M
Markus Groß 已提交
1308
        xenParseSxprGraphicsOld(def, root, hvm, xendConfigVersion,
1309 1310 1311 1312 1313 1314
                                      vncport) < 0)
        goto error;


    /* Old style cdrom config from Xen <= 3.0.2 */
    if (hvm &&
1315
        xendConfigVersion == XEND_CONFIG_VERSION_3_0_2) {
1316 1317 1318
        tmp = sexpr_node(root, "domain/image/hvm/cdrom");
        if ((tmp != NULL) && (tmp[0] != 0)) {
            virDomainDiskDefPtr disk;
1319
            if (!(disk = virDomainDiskDefNew(NULL)))
1320
                goto error;
1321
            if (virDomainDiskSetSource(disk, tmp) < 0) {
1322
                virDomainDiskDefFree(disk);
1323
                goto error;
1324
            }
E
Eric Blake 已提交
1325
            virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
1326
            disk->device = VIR_DOMAIN_DISK_DEVICE_CDROM;
1327
            if (VIR_STRDUP(disk->dst, "hdc") < 0) {
1328
                virDomainDiskDefFree(disk);
1329
                goto error;
1330
            }
1331
            if (virDomainDiskSetDriver(disk, "file") < 0) {
1332
                virDomainDiskDefFree(disk);
1333
                goto error;
1334 1335
            }
            disk->bus = VIR_DOMAIN_DISK_BUS_IDE;
1336
            disk->src->readonly = true;
1337

1338
            if (VIR_APPEND_ELEMENT(def->disks, def->ndisks, disk) < 0) {
1339
                virDomainDiskDefFree(disk);
1340
                goto error;
1341 1342 1343 1344 1345 1346 1347 1348
            }
        }
    }


    /* Floppy disk config */
    if (hvm) {
        const char *const fds[] = { "fda", "fdb" };
1349
        size_t i;
1350
        for (i = 0; i < ARRAY_CARDINALITY(fds); i++) {
1351 1352 1353
            tmp = sexpr_fmt_node(root, "domain/image/hvm/%s", fds[i]);
            if ((tmp != NULL) && (tmp[0] != 0)) {
                virDomainDiskDefPtr disk;
1354
                if (!(disk = virDomainDiskDefNew(NULL)))
1355
                    goto error;
1356
                if (virDomainDiskSetSource(disk, tmp) < 0) {
1357
                    virDomainDiskDefFree(disk);
1358
                    goto error;
1359
                }
E
Eric Blake 已提交
1360
                virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
1361
                disk->device = VIR_DOMAIN_DISK_DEVICE_FLOPPY;
1362
                if (VIR_STRDUP(disk->dst, fds[i]) < 0) {
1363
                    virDomainDiskDefFree(disk);
1364
                    goto error;
1365
                }
1366
                if (virDomainDiskSetSource(disk, "file") < 0) {
1367
                    virDomainDiskDefFree(disk);
1368
                    goto error;
1369 1370 1371
                }
                disk->bus = VIR_DOMAIN_DISK_BUS_FDC;

1372
                if (VIR_APPEND_ELEMENT(def->disks, def->ndisks, disk) < 0) {
1373
                    virDomainDiskDefFree(disk);
1374
                    goto error;
1375 1376 1377 1378 1379 1380 1381
                }
            }
        }
    }

    /* in case of HVM we have USB device emulation */
    if (hvm &&
M
Markus Groß 已提交
1382
        xenParseSxprUSB(def, root) < 0)
1383 1384 1385 1386
        goto error;

    /* Character device config */
    if (hvm) {
1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404
        const struct sexpr *serial_root;
        bool have_multiple_serials = false;

        serial_root = sexpr_lookup(root, "domain/image/hvm/serial");
        if (serial_root) {
            const struct sexpr *cur, *node, *cur2;
            int ports_skipped = 0;

            for (cur = serial_root; cur->kind == SEXPR_CONS; cur = cur->u.s.cdr) {
                node = cur->u.s.car;

                for (cur2 = node; cur2->kind == SEXPR_CONS; cur2 = cur2->u.s.cdr) {
                    tmp = cur2->u.s.car->u.value;

                    if (tmp && STRNEQ(tmp, "none")) {
                        virDomainChrDefPtr chr;
                        if ((chr = xenParseSxprChar(tmp, tty)) == NULL)
                            goto error;
1405 1406 1407
                        chr->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_SERIAL;
                        chr->target.port = def->nserials + ports_skipped;
                        if (VIR_APPEND_ELEMENT(def->serials, def->nserials, chr) < 0) {
1408
                            virDomainChrDefFree(chr);
1409
                            goto error;
1410 1411 1412 1413 1414 1415 1416
                        }
                    }
                    else
                        ports_skipped++;

                    have_multiple_serials = true;
                }
1417 1418
            }
        }
1419 1420 1421 1422 1423 1424 1425

        if (!have_multiple_serials) {
            tmp = sexpr_node(root, "domain/image/hvm/serial");
            if (tmp && STRNEQ(tmp, "none")) {
                virDomainChrDefPtr chr;
                if ((chr = xenParseSxprChar(tmp, tty)) == NULL)
                    goto error;
1426 1427 1428
                chr->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_SERIAL;
                chr->target.port = 0;
                if (VIR_APPEND_ELEMENT(def->serials, def->nserials, chr) < 0) {
1429
                    virDomainChrDefFree(chr);
1430
                    goto error;
1431 1432 1433 1434
                }
            }
        }

1435 1436 1437 1438
        tmp = sexpr_node(root, "domain/image/hvm/parallel");
        if (tmp && STRNEQ(tmp, "none")) {
            virDomainChrDefPtr chr;
            /* XXX does XenD stuff parallel port tty info into xenstore somewhere ? */
M
Markus Groß 已提交
1439
            if ((chr = xenParseSxprChar(tmp, NULL)) == NULL)
1440
                goto error;
1441 1442 1443
            chr->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_PARALLEL;
            chr->target.port = 0;
            if (VIR_APPEND_ELEMENT(def->parallels, def->nparallels, chr) < 0) {
1444
                virDomainChrDefFree(chr);
1445
                goto error;
1446 1447
            }
        }
1448
    } else if (def->id != 0) {
1449
        if (VIR_ALLOC_N(def->consoles, 1) < 0)
1450
            goto error;
1451
        def->nconsoles = 1;
1452
        /* Fake a paravirt console, since that's not in the sexpr */
1453
        if (!(def->consoles[0] = xenParseSxprChar("pty", tty)))
1454
            goto error;
1455 1456 1457
        def->consoles[0]->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_CONSOLE;
        def->consoles[0]->target.port = 0;
        def->consoles[0]->targetType = VIR_DOMAIN_CHR_CONSOLE_TARGET_TYPE_XEN;
1458 1459 1460 1461 1462 1463 1464 1465
    }
    VIR_FREE(tty);


    /* Sound device config */
    if (hvm &&
        (tmp = sexpr_node(root, "domain/image/hvm/soundhw")) != NULL &&
        *tmp) {
M
Markus Groß 已提交
1466
        if (xenParseSxprSound(def, tmp) < 0)
1467 1468 1469 1470 1471
            goto error;
    }

    return def;

1472
 error:
1473 1474 1475 1476 1477
    VIR_FREE(tty);
    virDomainDefFree(def);
    return NULL;
}

P
Philipp Hahn 已提交
1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491

/**
 * xenParseSxprString:
 * @sexpr: the root of the parsed S-Expression
 * @xendConfigVersion: version of xend
 * @tty: the console pty path
 * @vncport: VNC port number
 *
 * Parse the xend S-expression description and turn it into a virDomainDefPtr
 * representing these settings as closely as is practical.
 *
 * Returns the domain config or NULL in case of error.
 *         The caller must free() the returned value.
 */
1492
virDomainDefPtr
M
Markus Groß 已提交
1493
xenParseSxprString(const char *sexpr,
1494 1495 1496 1497 1498 1499 1500 1501
                         int xendConfigVersion, char *tty, int vncport)
{
    struct sexpr *root = string2sexpr(sexpr);
    virDomainDefPtr def;

    if (!root)
        return NULL;

M
Markus Groß 已提交
1502
    def = xenParseSxpr(root, xendConfigVersion, NULL, tty, vncport);
1503 1504 1505 1506

    sexpr_free(root);

    return def;
1507 1508 1509 1510 1511 1512 1513 1514 1515 1516
}

/************************************************************************
 *                                                                      *
 * Converter functions to go from the XML tree to an S-Expr for Xen     *
 *                                                                      *
 ************************************************************************/


/**
P
Philipp Hahn 已提交
1517 1518 1519
 * xenFormatSxprGraphicsNew:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
1520
 *
P
Philipp Hahn 已提交
1521 1522
 * Convert the graphics part of the domain description into a S-expression
 * in buf. (HVM > 3.0.4 or PV > 3.0.3)
1523 1524 1525 1526
 *
 * Returns 0 in case of success, -1 in case of error
 */
static int
M
Markus Groß 已提交
1527 1528
xenFormatSxprGraphicsNew(virDomainGraphicsDefPtr def,
                         virBufferPtr buf)
1529
{
1530 1531
    const char *listenAddr;

1532 1533
    if (def->type != VIR_DOMAIN_GRAPHICS_TYPE_SDL &&
        def->type != VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
1534 1535 1536
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected graphics type %d"),
                       def->type);
1537 1538 1539 1540 1541 1542 1543 1544 1545
        return -1;
    }

    virBufferAddLit(buf, "(device (vkbd))");
    virBufferAddLit(buf, "(device (vfb ");

    if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_SDL) {
        virBufferAddLit(buf, "(type sdl)");
        if (def->data.sdl.display)
1546
            virBufferAsprintf(buf, "(display '%s')", def->data.sdl.display);
1547
        if (def->data.sdl.xauth)
1548
            virBufferAsprintf(buf, "(xauthority '%s')", def->data.sdl.xauth);
1549 1550 1551 1552 1553 1554
    } else if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
        virBufferAddLit(buf, "(type vnc)");
        if (def->data.vnc.autoport) {
            virBufferAddLit(buf, "(vncunused 1)");
        } else {
            virBufferAddLit(buf, "(vncunused 0)");
1555
            virBufferAsprintf(buf, "(vncdisplay %d)", def->data.vnc.port-5900);
1556 1557
        }

1558 1559 1560
        listenAddr = virDomainGraphicsListenGetAddress(def, 0);
        if (listenAddr)
            virBufferAsprintf(buf, "(vnclisten '%s')", listenAddr);
1561
        if (def->data.vnc.auth.passwd)
1562
            virBufferAsprintf(buf, "(vncpasswd '%s')", def->data.vnc.auth.passwd);
1563
        if (def->data.vnc.keymap)
1564
            virBufferAsprintf(buf, "(keymap '%s')", def->data.vnc.keymap);
1565 1566 1567 1568 1569 1570 1571 1572
    }

    virBufferAddLit(buf, "))");

    return 0;
}


P
Philipp Hahn 已提交
1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583
/**
 * xenFormatSxprGraphicsOld:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 * @xendConfigVersion: version of xend
 *
 * Convert the graphics part of the domain description into a S-expression
 * in buf. (HVM <= 3.0.4 or PV <= 3.0.3)
 *
 * Returns 0 in case of success, -1 in case of error
 */
1584
static int
M
Markus Groß 已提交
1585 1586 1587
xenFormatSxprGraphicsOld(virDomainGraphicsDefPtr def,
                         virBufferPtr buf,
                         int xendConfigVersion)
1588
{
1589 1590
    const char *listenAddr;

1591 1592
    if (def->type != VIR_DOMAIN_GRAPHICS_TYPE_SDL &&
        def->type != VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
1593 1594 1595
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected graphics type %d"),
                       def->type);
1596 1597 1598 1599 1600 1601
        return -1;
    }

    if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_SDL) {
        virBufferAddLit(buf, "(sdl 1)");
        if (def->data.sdl.display)
1602
            virBufferAsprintf(buf, "(display '%s')", def->data.sdl.display);
1603
        if (def->data.sdl.xauth)
1604
            virBufferAsprintf(buf, "(xauthority '%s')", def->data.sdl.xauth);
1605 1606
    } else if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
        virBufferAddLit(buf, "(vnc 1)");
1607
        if (xendConfigVersion >= XEND_CONFIG_VERSION_3_0_3) {
1608 1609 1610 1611
            if (def->data.vnc.autoport) {
                virBufferAddLit(buf, "(vncunused 1)");
            } else {
                virBufferAddLit(buf, "(vncunused 0)");
1612
                virBufferAsprintf(buf, "(vncdisplay %d)", def->data.vnc.port-5900);
1613 1614
            }

1615 1616 1617
            listenAddr = virDomainGraphicsListenGetAddress(def, 0);
            if (listenAddr)
                virBufferAsprintf(buf, "(vnclisten '%s')", listenAddr);
1618
            if (def->data.vnc.auth.passwd)
1619
                virBufferAsprintf(buf, "(vncpasswd '%s')", def->data.vnc.auth.passwd);
1620
            if (def->data.vnc.keymap)
1621
                virBufferAsprintf(buf, "(keymap '%s')", def->data.vnc.keymap);
1622 1623 1624 1625 1626 1627 1628

        }
    }

    return 0;
}

P
Philipp Hahn 已提交
1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639

/**
 * xenFormatSxprChr:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 *
 * Convert the character device part of the domain config into a S-expression
 * in buf.
 *
 * Returns 0 in case of success, -1 in case of error
 */
1640
int
M
Markus Groß 已提交
1641 1642
xenFormatSxprChr(virDomainChrDefPtr def,
                 virBufferPtr buf)
1643 1644 1645 1646
{
    const char *type = virDomainChrTypeToString(def->source.type);

    if (!type) {
1647 1648
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("unexpected chr device type"));
1649 1650 1651 1652 1653 1654 1655 1656
        return -1;
    }

    switch (def->source.type) {
    case VIR_DOMAIN_CHR_TYPE_NULL:
    case VIR_DOMAIN_CHR_TYPE_STDIO:
    case VIR_DOMAIN_CHR_TYPE_VC:
    case VIR_DOMAIN_CHR_TYPE_PTY:
1657
        virBufferAdd(buf, type, -1);
1658 1659 1660 1661
        break;

    case VIR_DOMAIN_CHR_TYPE_FILE:
    case VIR_DOMAIN_CHR_TYPE_PIPE:
1662
        virBufferAsprintf(buf, "%s:", type);
1663 1664 1665 1666 1667 1668 1669 1670
        virBufferEscapeSexpr(buf, "%s", def->source.data.file.path);
        break;

    case VIR_DOMAIN_CHR_TYPE_DEV:
        virBufferEscapeSexpr(buf, "%s", def->source.data.file.path);
        break;

    case VIR_DOMAIN_CHR_TYPE_TCP:
1671
        virBufferAsprintf(buf, "%s:%s:%s%s",
1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683
                          (def->source.data.tcp.protocol
                           == VIR_DOMAIN_CHR_TCP_PROTOCOL_RAW ?
                           "tcp" : "telnet"),
                          (def->source.data.tcp.host ?
                           def->source.data.tcp.host : ""),
                          (def->source.data.tcp.service ?
                           def->source.data.tcp.service : ""),
                          (def->source.data.tcp.listen ?
                           ",server,nowait" : ""));
        break;

    case VIR_DOMAIN_CHR_TYPE_UDP:
1684
        virBufferAsprintf(buf, "%s:%s:%s@%s:%s", type,
1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695
                          (def->source.data.udp.connectHost ?
                           def->source.data.udp.connectHost : ""),
                          (def->source.data.udp.connectService ?
                           def->source.data.udp.connectService : ""),
                          (def->source.data.udp.bindHost ?
                           def->source.data.udp.bindHost : ""),
                          (def->source.data.udp.bindService ?
                           def->source.data.udp.bindService : ""));
        break;

    case VIR_DOMAIN_CHR_TYPE_UNIX:
1696
        virBufferAsprintf(buf, "%s:", type);
1697 1698 1699 1700
        virBufferEscapeSexpr(buf, "%s", def->source.data.nix.path);
        if (def->source.data.nix.listen)
            virBufferAddLit(buf, ",server,nowait");
        break;
1701 1702

    default:
1703 1704
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("unsupported chr device type '%s'"), type);
1705
        return -1;
1706 1707
    }

1708
    if (virBufferCheckError(buf) < 0)
1709 1710 1711 1712 1713 1714 1715
        return -1;

    return 0;
}


/**
P
Philipp Hahn 已提交
1716 1717 1718 1719
 * xenFormatSxprDisk:
 * @node: node containing the disk description
 * @buf: a buffer for the result S-expression
 * @hvm: true or 1 if domain is HVM
1720
 * @xendConfigVersion: xend configuration file format
P
Philipp Hahn 已提交
1721
 * @isAttach: create expression for device attach (1).
1722
 *
P
Philipp Hahn 已提交
1723
 * Convert the disk device part of the domain config into a S-expresssion in buf.
1724 1725 1726 1727
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
1728
xenFormatSxprDisk(virDomainDiskDefPtr def,
M
Markus Groß 已提交
1729 1730 1731 1732
                  virBufferPtr buf,
                  int hvm,
                  int xendConfigVersion,
                  int isAttach)
1733
{
1734 1735 1736
    const char *src = virDomainDiskGetSource(def);
    const char *driver = virDomainDiskGetDriver(def);

1737 1738 1739 1740 1741 1742
    /* Xend (all versions) put the floppy device config
     * under the hvm (image (os)) block
     */
    if (hvm &&
        def->device == VIR_DOMAIN_DISK_DEVICE_FLOPPY) {
        if (isAttach) {
1743
            virReportError(VIR_ERR_INVALID_ARG,
1744
                           _("Cannot directly attach floppy %s"), src);
1745 1746 1747 1748 1749 1750 1751 1752
            return -1;
        }
        return 0;
    }

    /* Xend <= 3.0.2 doesn't include cdrom config here */
    if (hvm &&
        def->device == VIR_DOMAIN_DISK_DEVICE_CDROM &&
1753
        xendConfigVersion == XEND_CONFIG_VERSION_3_0_2) {
1754
        if (isAttach) {
1755
            virReportError(VIR_ERR_INVALID_ARG,
1756
                           _("Cannot directly attach CDROM %s"), src);
1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767
            return -1;
        }
        return 0;
    }

    if (!isAttach)
        virBufferAddLit(buf, "(device ");

    /* Normally disks are in a (device (vbd ...)) block
     * but blktap disks ended up in a differently named
     * (device (tap ....)) block.... */
1768
    if (STREQ_NULLABLE(driver, "tap")) {
1769
        virBufferAddLit(buf, "(tap ");
1770
    } else if (STREQ_NULLABLE(driver, "tap2")) {
1771 1772 1773 1774 1775 1776 1777
        virBufferAddLit(buf, "(tap2 ");
    } else {
        virBufferAddLit(buf, "(vbd ");
    }

    if (hvm) {
        /* Xend <= 3.0.2 wants a ioemu: prefix on devices for HVM */
1778
        if (xendConfigVersion == XEND_CONFIG_VERSION_3_0_2) {
1779 1780 1781 1782
            virBufferEscapeSexpr(buf, "(dev 'ioemu:%s')", def->dst);
        } else {
            /* But newer does not */
            virBufferEscapeSexpr(buf, "(dev '%s:", def->dst);
1783
            virBufferAsprintf(buf, "%s')",
1784 1785 1786 1787 1788 1789 1790 1791 1792
                              def->device == VIR_DOMAIN_DISK_DEVICE_CDROM ?
                              "cdrom" : "disk");
        }
    } else if (def->device == VIR_DOMAIN_DISK_DEVICE_CDROM) {
        virBufferEscapeSexpr(buf, "(dev '%s:cdrom')", def->dst);
    } else {
        virBufferEscapeSexpr(buf, "(dev '%s')", def->dst);
    }

1793 1794 1795 1796
    if (src) {
        if (driver) {
            if (STREQ(driver, "tap") ||
                STREQ(driver, "tap2")) {
1797
                const char *type;
1798
                int format = virDomainDiskGetFormat(def);
1799

1800
                if (!format || format == VIR_STORAGE_FILE_RAW)
1801
                    type = "aio";
1802
                else
1803 1804
                    type = virStorageFileFormatTypeToString(format);
                virBufferEscapeSexpr(buf, "(uname '%s:", driver);
1805
                virBufferEscapeSexpr(buf, "%s:", type);
1806
                virBufferEscapeSexpr(buf, "%s')", src);
1807
            } else {
1808 1809
                virBufferEscapeSexpr(buf, "(uname '%s:", driver);
                virBufferEscapeSexpr(buf, "%s')", src);
1810 1811
            }
        } else {
1812 1813
            int type = virDomainDiskGetType(def);

E
Eric Blake 已提交
1814
            if (type == VIR_STORAGE_TYPE_FILE) {
1815
                virBufferEscapeSexpr(buf, "(uname 'file:%s')", src);
E
Eric Blake 已提交
1816
            } else if (type == VIR_STORAGE_TYPE_BLOCK) {
1817 1818
                if (src[0] == '/')
                    virBufferEscapeSexpr(buf, "(uname 'phy:%s')", src);
1819 1820
                else
                    virBufferEscapeSexpr(buf, "(uname 'phy:/dev/%s')",
1821
                                         src);
1822
            } else {
1823 1824
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                               _("unsupported disk type %s"),
E
Eric Blake 已提交
1825
                               virStorageTypeToString(type));
1826 1827 1828 1829 1830
                return -1;
            }
        }
    }

1831
    if (def->src->readonly)
1832
        virBufferAddLit(buf, "(mode 'r')");
1833
    else if (def->src->shared)
1834 1835 1836
        virBufferAddLit(buf, "(mode 'w!')");
    else
        virBufferAddLit(buf, "(mode 'w')");
1837
    if (def->transient) {
1838
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
1839
                       _("transient disks not supported yet"));
1840 1841
        return -1;
    }
1842 1843 1844 1845 1846 1847 1848 1849 1850 1851

    if (!isAttach)
        virBufferAddLit(buf, ")");

    virBufferAddLit(buf, ")");

    return 0;
}

/**
P
Philipp Hahn 已提交
1852 1853 1854 1855 1856
 * xenFormatSxprNet:
 * @conn: connection
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 * @hvm: true or 1 if domain is HVM
1857
 * @xendConfigVersion: xend configuration file format
P
Philipp Hahn 已提交
1858
 * @isAttach: create expression for device attach (1).
1859
 *
P
Philipp Hahn 已提交
1860
 * Convert the interface description of the domain config into a S-expression in buf.
1861 1862 1863 1864 1865 1866 1867
 * This is a temporary interface as the S-Expr interface
 * will be replaced by XML-RPC in the future. However the XML format should
 * stay valid over time.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
M
Markus Groß 已提交
1868 1869 1870 1871 1872 1873
xenFormatSxprNet(virConnectPtr conn,
                 virDomainNetDefPtr def,
                 virBufferPtr buf,
                 int hvm,
                 int xendConfigVersion,
                 int isAttach)
1874 1875
{
    const char *script = DEFAULT_VIF_SCRIPT;
1876
    char macaddr[VIR_MAC_STRING_BUFLEN];
1877 1878 1879 1880

    if (def->type != VIR_DOMAIN_NET_TYPE_BRIDGE &&
        def->type != VIR_DOMAIN_NET_TYPE_NETWORK &&
        def->type != VIR_DOMAIN_NET_TYPE_ETHERNET) {
1881 1882
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unsupported network type %d"), def->type);
1883 1884
        return -1;
    }
1885 1886 1887
    if (def->script &&
        def->type != VIR_DOMAIN_NET_TYPE_BRIDGE &&
        def->type != VIR_DOMAIN_NET_TYPE_ETHERNET) {
1888 1889 1890
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("scripts are not supported on interfaces of type %s"),
                       virDomainNetTypeToString(def->type));
1891 1892
        return -1;
    }
1893 1894 1895 1896 1897 1898

    if (!isAttach)
        virBufferAddLit(buf, "(device ");

    virBufferAddLit(buf, "(vif ");

1899
    virBufferAsprintf(buf, "(mac '%s')", virMacAddrFormat(&def->mac, macaddr));
1900 1901 1902 1903

    switch (def->type) {
    case VIR_DOMAIN_NET_TYPE_BRIDGE:
        virBufferEscapeSexpr(buf, "(bridge '%s')", def->data.bridge.brname);
1904 1905
        if (def->script)
            script = def->script;
1906 1907

        virBufferEscapeSexpr(buf, "(script '%s')", script);
1908
        if (def->nips == 1) {
1909 1910 1911
            char *ipStr = virSocketAddrFormat(&def->ips[0]->address);
            virBufferEscapeSexpr(buf, "(ip '%s')", ipStr);
            VIR_FREE(ipStr);
1912 1913 1914 1915
        } else if (def->nips > 1) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("Driver does not support setting multiple IP addresses"));
            return -1;
1916
        }
1917 1918 1919 1920 1921 1922 1923 1924 1925
        break;

    case VIR_DOMAIN_NET_TYPE_NETWORK:
    {
        virNetworkPtr network =
            virNetworkLookupByName(conn, def->data.network.name);
        char *bridge;

        if (!network) {
1926 1927
            virReportError(VIR_ERR_NO_NETWORK, "%s",
                           def->data.network.name);
1928 1929 1930 1931
            return -1;
        }

        bridge = virNetworkGetBridgeName(network);
1932
        virObjectUnref(network);
1933
        if (!bridge) {
1934 1935 1936
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("network %s is not active"),
                           def->data.network.name);
1937 1938 1939 1940 1941 1942 1943 1944 1945
            return -1;
        }
        virBufferEscapeSexpr(buf, "(bridge '%s')", bridge);
        virBufferEscapeSexpr(buf, "(script '%s')", script);
        VIR_FREE(bridge);
    }
    break;

    case VIR_DOMAIN_NET_TYPE_ETHERNET:
1946
        if (def->script)
1947
            virBufferEscapeSexpr(buf, "(script '%s')",
1948
                                 def->script);
1949
        if (def->nips == 1) {
1950 1951 1952
            char *ipStr = virSocketAddrFormat(&def->ips[0]->address);
            virBufferEscapeSexpr(buf, "(ip '%s')", ipStr);
            VIR_FREE(ipStr);
1953 1954 1955 1956
        } else if (def->nips > 1) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("Driver does not support setting multiple IP addresses"));
            return -1;
1957
        }
1958 1959
        break;

M
Michele Paolino 已提交
1960
    case VIR_DOMAIN_NET_TYPE_VHOSTUSER:
1961 1962 1963 1964
    case VIR_DOMAIN_NET_TYPE_USER:
    case VIR_DOMAIN_NET_TYPE_SERVER:
    case VIR_DOMAIN_NET_TYPE_CLIENT:
    case VIR_DOMAIN_NET_TYPE_MCAST:
1965
    case VIR_DOMAIN_NET_TYPE_UDP:
1966 1967
    case VIR_DOMAIN_NET_TYPE_INTERNAL:
    case VIR_DOMAIN_NET_TYPE_DIRECT:
1968
    case VIR_DOMAIN_NET_TYPE_HOSTDEV:
1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979
    case VIR_DOMAIN_NET_TYPE_LAST:
        break;
    }

    if (def->ifname != NULL &&
        !STRPREFIX(def->ifname, "vif"))
        virBufferEscapeSexpr(buf, "(vifname '%s')", def->ifname);

    if (!hvm) {
        if (def->model != NULL)
            virBufferEscapeSexpr(buf, "(model '%s')", def->model);
1980
    } else {
1981 1982
        if (def->model != NULL && STREQ(def->model, "netfront")) {
            virBufferAddLit(buf, "(type netfront)");
1983
        } else {
1984
            if (def->model != NULL)
1985 1986 1987 1988 1989
                virBufferEscapeSexpr(buf, "(model '%s')", def->model);
            /*
             * apparently (type ioemu) breaks paravirt drivers on HVM so skip
             * this from XEND_CONFIG_MAX_VERS_NET_TYPE_IOEMU
             */
1990
            if (xendConfigVersion <= XEND_CONFIG_MAX_VERS_NET_TYPE_IOEMU)
1991 1992
                virBufferAddLit(buf, "(type ioemu)");
        }
1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003
    }

    if (!isAttach)
        virBufferAddLit(buf, ")");

    virBufferAddLit(buf, ")");

    return 0;
}


P
Philipp Hahn 已提交
2004 2005 2006 2007 2008 2009 2010 2011 2012
/**
 * xenFormatSxprPCI:
 * @def: the device config
 * @buf: a buffer for the result S-expression
 *
 * Convert a single PCI device part of the domain config into a S-expresssion in buf.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
2013
static void
M
Markus Groß 已提交
2014 2015
xenFormatSxprPCI(virDomainHostdevDefPtr def,
                 virBufferPtr buf)
2016
{
2017
    virBufferAsprintf(buf, "(dev (domain 0x%04x)(bus 0x%02x)(slot 0x%02x)(func 0x%x))",
2018 2019 2020 2021
                      def->source.subsys.u.pci.addr.domain,
                      def->source.subsys.u.pci.addr.bus,
                      def->source.subsys.u.pci.addr.slot,
                      def->source.subsys.u.pci.addr.function);
2022 2023
}

P
Philipp Hahn 已提交
2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034

/**
 * xenFormatSxprOnePCI:
 * @def: the device config
 * @buf: a buffer for the result S-expression
 * @detach: create expression for device detach (1).
 *
 * Convert a single PCI device part of the domain config into a S-expresssion in buf.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
2035
int
M
Markus Groß 已提交
2036 2037 2038
xenFormatSxprOnePCI(virDomainHostdevDefPtr def,
                    virBufferPtr buf,
                    int detach)
2039 2040
{
    if (def->managed) {
2041 2042
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("managed PCI devices not supported with XenD"));
2043 2044 2045 2046
        return -1;
    }

    virBufferAddLit(buf, "(pci ");
M
Markus Groß 已提交
2047
    xenFormatSxprPCI(def, buf);
2048 2049 2050 2051 2052 2053 2054 2055 2056
    if (detach)
        virBufferAddLit(buf, "(state 'Closing')");
    else
        virBufferAddLit(buf, "(state 'Initialising')");
    virBufferAddLit(buf, ")");

    return 0;
}

P
Philipp Hahn 已提交
2057 2058 2059 2060 2061 2062 2063 2064 2065 2066

/**
 * xenFormatSxprAllPCI:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 *
 * Convert all PCI device parts of the domain config into a S-expresssion in buf.
 *
 * Returns 0 in case of success, -1 in case of error.
 */
2067
static int
M
Markus Groß 已提交
2068 2069
xenFormatSxprAllPCI(virDomainDefPtr def,
                    virBufferPtr buf)
2070 2071
{
    int hasPCI = 0;
2072
    size_t i;
2073

2074
    for (i = 0; i < def->nhostdevs; i++)
2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096
        if (def->hostdevs[i]->mode == VIR_DOMAIN_HOSTDEV_MODE_SUBSYS &&
            def->hostdevs[i]->source.subsys.type == VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI)
            hasPCI = 1;

    if (!hasPCI)
        return 0;

    /*
     * With the (domain ...) block we have the following odd setup
     *
     * (device
     *    (pci
     *       (dev (domain 0x0000) (bus 0x00) (slot 0x1b) (func 0x0))
     *       (dev (domain 0x0000) (bus 0x00) (slot 0x13) (func 0x0))
     *    )
     * )
     *
     * Normally there is one (device ...) block per device, but in the
     * weird world of Xen PCI, one (device ...) covers multiple devices.
     */

    virBufferAddLit(buf, "(device (pci ");
2097
    for (i = 0; i < def->nhostdevs; i++) {
2098 2099 2100
        if (def->hostdevs[i]->mode == VIR_DOMAIN_HOSTDEV_MODE_SUBSYS &&
            def->hostdevs[i]->source.subsys.type == VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI) {
            if (def->hostdevs[i]->managed) {
2101 2102
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("managed PCI devices not supported with XenD"));
2103 2104 2105
                return -1;
            }

M
Markus Groß 已提交
2106
            xenFormatSxprPCI(def->hostdevs[i], buf);
2107 2108 2109 2110 2111 2112 2113
        }
    }
    virBufferAddLit(buf, "))");

    return 0;
}

P
Philipp Hahn 已提交
2114 2115 2116 2117 2118 2119 2120 2121 2122 2123

/**
 * xenFormatSxprSound:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 *
 * Convert all sound device parts of the domain config into S-expression in buf.
 *
 * Returns 0 if successful or -1 if failed.
 */
2124
int
M
Markus Groß 已提交
2125 2126
xenFormatSxprSound(virDomainDefPtr def,
                   virBufferPtr buf)
2127 2128
{
    const char *str;
2129
    size_t i;
2130

2131
    for (i = 0; i < def->nsounds; i++) {
2132
        if (!(str = virDomainSoundModelTypeToString(def->sounds[i]->model))) {
2133 2134 2135
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unexpected sound model %d"),
                           def->sounds[i]->model);
2136 2137 2138 2139 2140 2141 2142
            return -1;
        }
        if (i)
            virBufferAddChar(buf, ',');
        virBufferEscapeSexpr(buf, "%s", str);
    }

2143
    if (virBufferCheckError(buf) < 0)
2144 2145 2146 2147 2148 2149
        return -1;

    return 0;
}


P
Philipp Hahn 已提交
2150 2151 2152 2153 2154 2155 2156 2157 2158
/**
 * xenFormatSxprInput:
 * @input: the input config
 * @buf: a buffer for the result S-expression
 *
 * Convert all input device parts of the domain config into S-expression in buf.
 *
 * Returns 0 if successful or -1 if failed.
 */
2159
static int
M
Markus Groß 已提交
2160 2161
xenFormatSxprInput(virDomainInputDefPtr input,
                   virBufferPtr buf)
2162 2163 2164 2165 2166
{
    if (input->bus != VIR_DOMAIN_INPUT_BUS_USB)
        return 0;

    if (input->type != VIR_DOMAIN_INPUT_TYPE_MOUSE &&
2167 2168
        input->type != VIR_DOMAIN_INPUT_TYPE_TABLET &&
        input->type != VIR_DOMAIN_INPUT_TYPE_KBD) {
2169 2170
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected input type %d"), input->type);
2171 2172 2173
        return -1;
    }

2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184
    switch (input->type) {
        case VIR_DOMAIN_INPUT_TYPE_MOUSE:
            virBufferAsprintf(buf, "(usbdevice %s)", "mouse");
            break;
        case VIR_DOMAIN_INPUT_TYPE_TABLET:
            virBufferAsprintf(buf, "(usbdevice %s)", "tablet");
            break;
        case VIR_DOMAIN_INPUT_TYPE_KBD:
            virBufferAsprintf(buf, "(usbdevice %s)", "keyboard");
            break;
    }
2185 2186 2187 2188 2189 2190 2191 2192 2193 2194

    return 0;
}


/* Computing the vcpu_avail bitmask works because MAX_VIRT_CPUS is
   either 32, or 64 on a platform where long is big enough.  */
verify(MAX_VIRT_CPUS <= sizeof(1UL) * CHAR_BIT);

/**
M
Markus Groß 已提交
2195
 * xenFormatSxpr:
2196 2197 2198 2199
 * @conn: pointer to the hypervisor connection
 * @def: domain config definition
 * @xendConfigVersion: xend configuration file format
 *
P
Philipp Hahn 已提交
2200
 * Generate an S-expression representing the domain configuration.
2201 2202 2203 2204 2205
 *
 * Returns the 0 terminated S-Expr string or NULL in case of error.
 *         the caller must free() the returned value.
 */
char *
M
Markus Groß 已提交
2206 2207 2208
xenFormatSxpr(virConnectPtr conn,
              virDomainDefPtr def,
              int xendConfigVersion)
2209 2210 2211 2212 2213
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
    char uuidstr[VIR_UUID_STRING_BUFLEN];
    const char *tmp;
    char *bufout;
2214 2215
    int hvm = 0, vmlocaltime = -1;
    size_t i;
P
Philipp Hahn 已提交
2216
    bool in_image = false;
2217

2218
    VIR_DEBUG("Formatting domain sexpr");
2219 2220 2221

    virBufferAddLit(&buf, "(vm ");
    virBufferEscapeSexpr(&buf, "(name '%s')", def->name);
2222
    virBufferAsprintf(&buf, "(memory %llu)(maxmem %llu)",
2223
                      VIR_DIV_UP(def->mem.cur_balloon, 1024),
2224
                      VIR_DIV_UP(virDomainDefGetMemoryActual(def), 1024));
2225
    virBufferAsprintf(&buf, "(vcpus %u)", def->maxvcpus);
2226 2227 2228
    /* Computing the vcpu_avail bitmask works because MAX_VIRT_CPUS is
       either 32, or 64 on a platform where long is big enough.  */
    if (def->vcpus < def->maxvcpus)
2229
        virBufferAsprintf(&buf, "(vcpu_avail %lu)", (1UL << def->vcpus) - 1);
2230 2231

    if (def->cpumask) {
H
Hu Tao 已提交
2232
        char *ranges = virBitmapFormat(def->cpumask);
2233 2234 2235 2236 2237 2238 2239
        if (ranges == NULL)
            goto error;
        virBufferEscapeSexpr(&buf, "(cpus '%s')", ranges);
        VIR_FREE(ranges);
    }

    virUUIDFormat(def->uuid, uuidstr);
2240
    virBufferAsprintf(&buf, "(uuid '%s')", uuidstr);
2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255

    if (def->description)
        virBufferEscapeSexpr(&buf, "(description '%s')", def->description);

    if (def->os.bootloader) {
        if (def->os.bootloader[0])
            virBufferEscapeSexpr(&buf, "(bootloader '%s')", def->os.bootloader);
        else
            virBufferAddLit(&buf, "(bootloader)");

        if (def->os.bootloaderArgs)
            virBufferEscapeSexpr(&buf, "(bootloader_args '%s')", def->os.bootloaderArgs);
    }

    if (!(tmp = virDomainLifecycleTypeToString(def->onPoweroff))) {
2256 2257
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onPoweroff);
2258 2259
        goto error;
    }
2260
    virBufferAsprintf(&buf, "(on_poweroff '%s')", tmp);
2261 2262

    if (!(tmp = virDomainLifecycleTypeToString(def->onReboot))) {
2263 2264
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onReboot);
2265 2266
        goto error;
    }
2267
    virBufferAsprintf(&buf, "(on_reboot '%s')", tmp);
2268 2269

    if (!(tmp = virDomainLifecycleCrashTypeToString(def->onCrash))) {
2270 2271
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onCrash);
2272 2273
        goto error;
    }
2274
    virBufferAsprintf(&buf, "(on_crash '%s')", tmp);
2275

2276
    if (def->os.type == VIR_DOMAIN_OSTYPE_HVM)
P
Philipp Hahn 已提交
2277
        hvm = 1;
2278 2279 2280 2281 2282 2283

    if (!def->os.bootloader) {
        if (hvm)
            virBufferAddLit(&buf, "(image (hvm ");
        else
            virBufferAddLit(&buf, "(image (linux ");
P
Philipp Hahn 已提交
2284
        in_image = true;
2285 2286 2287

        if (hvm &&
            def->os.loader == NULL) {
2288
            virReportError(VIR_ERR_INTERNAL_ERROR,
E
Eric Blake 已提交
2289
                           "%s", _("no HVM domain loader"));
2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304
            goto error;
        }

        if (def->os.kernel)
            virBufferEscapeSexpr(&buf, "(kernel '%s')", def->os.kernel);
        if (def->os.initrd)
            virBufferEscapeSexpr(&buf, "(ramdisk '%s')", def->os.initrd);
        if (def->os.root)
            virBufferEscapeSexpr(&buf, "(root '%s')", def->os.root);
        if (def->os.cmdline)
            virBufferEscapeSexpr(&buf, "(args '%s')", def->os.cmdline);

        if (hvm) {
            char bootorder[VIR_DOMAIN_BOOT_LAST+1];
            if (def->os.kernel)
2305
                virBufferEscapeSexpr(&buf, "(loader '%s')", def->os.loader->path);
2306
            else
2307
                virBufferEscapeSexpr(&buf, "(kernel '%s')", def->os.loader->path);
2308

2309
            virBufferAsprintf(&buf, "(vcpus %u)", def->maxvcpus);
2310
            if (def->vcpus < def->maxvcpus)
2311
                virBufferAsprintf(&buf, "(vcpu_avail %lu)",
2312 2313
                                  (1UL << def->vcpus) - 1);

2314
            for (i = 0; i < def->os.nBootDevs; i++) {
2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336
                switch (def->os.bootDevs[i]) {
                case VIR_DOMAIN_BOOT_FLOPPY:
                    bootorder[i] = 'a';
                    break;
                default:
                case VIR_DOMAIN_BOOT_DISK:
                    bootorder[i] = 'c';
                    break;
                case VIR_DOMAIN_BOOT_CDROM:
                    bootorder[i] = 'd';
                    break;
                case VIR_DOMAIN_BOOT_NET:
                    bootorder[i] = 'n';
                    break;
                }
            }
            if (def->os.nBootDevs == 0) {
                bootorder[0] = 'c';
                bootorder[1] = '\0';
            } else {
                bootorder[def->os.nBootDevs] = '\0';
            }
2337
            virBufferAsprintf(&buf, "(boot %s)", bootorder);
2338 2339

            /* some disk devices are defined here */
2340
            for (i = 0; i < def->ndisks; i++) {
2341 2342
                const char *src = virDomainDiskGetSource(def->disks[i]);

2343 2344 2345
                switch (def->disks[i]->device) {
                case VIR_DOMAIN_DISK_DEVICE_CDROM:
                    /* Only xend <= 3.0.2 wants cdrom config here */
2346
                    if (xendConfigVersion != XEND_CONFIG_VERSION_3_0_2)
2347
                        break;
2348
                    if (!STREQ(def->disks[i]->dst, "hdc") || !src)
2349 2350
                        break;

2351
                    virBufferEscapeSexpr(&buf, "(cdrom '%s')", src);
2352 2353 2354 2355 2356
                    break;

                case VIR_DOMAIN_DISK_DEVICE_FLOPPY:
                    /* all xend versions define floppies here */
                    virBufferEscapeSexpr(&buf, "(%s ", def->disks[i]->dst);
2357
                    virBufferEscapeSexpr(&buf, "'%s')", src);
2358 2359 2360 2361 2362 2363 2364
                    break;

                default:
                    break;
                }
            }

J
Ján Tomko 已提交
2365
            if (def->features[VIR_DOMAIN_FEATURE_ACPI] == VIR_TRISTATE_SWITCH_ON)
2366
                virBufferAddLit(&buf, "(acpi 1)");
J
Ján Tomko 已提交
2367
            if (def->features[VIR_DOMAIN_FEATURE_APIC] == VIR_TRISTATE_SWITCH_ON)
2368
                virBufferAddLit(&buf, "(apic 1)");
J
Ján Tomko 已提交
2369
            if (def->features[VIR_DOMAIN_FEATURE_PAE] == VIR_TRISTATE_SWITCH_ON)
2370
                virBufferAddLit(&buf, "(pae 1)");
J
Ján Tomko 已提交
2371
            if (def->features[VIR_DOMAIN_FEATURE_HAP] == VIR_TRISTATE_SWITCH_ON)
2372
                virBufferAddLit(&buf, "(hap 1)");
J
Ján Tomko 已提交
2373
            if (def->features[VIR_DOMAIN_FEATURE_VIRIDIAN] == VIR_TRISTATE_SWITCH_ON)
2374
                virBufferAddLit(&buf, "(viridian 1)");
2375 2376 2377

            virBufferAddLit(&buf, "(usb 1)");

2378
            for (i = 0; i < def->ninputs; i++)
M
Markus Groß 已提交
2379
                if (xenFormatSxprInput(def->inputs[i], &buf) < 0)
2380 2381 2382 2383
                    goto error;

            if (def->parallels) {
                virBufferAddLit(&buf, "(parallel ");
M
Markus Groß 已提交
2384
                if (xenFormatSxprChr(def->parallels[0], &buf) < 0)
2385 2386 2387 2388 2389 2390
                    goto error;
                virBufferAddLit(&buf, ")");
            } else {
                virBufferAddLit(&buf, "(parallel none)");
            }
            if (def->serials) {
2391
                if ((def->nserials > 1) || (def->serials[0]->target.port != 0)) {
2392 2393
                    int maxport = -1, port;
                    size_t j = 0;
2394 2395 2396 2397 2398 2399

                    virBufferAddLit(&buf, "(serial (");
                    for (i = 0; i < def->nserials; i++)
                        if (def->serials[i]->target.port > maxport)
                            maxport = def->serials[i]->target.port;

2400
                    for (port = 0; port <= maxport; port++) {
2401 2402
                        virDomainChrDefPtr chr = NULL;

2403
                        if (port)
2404 2405
                            virBufferAddLit(&buf, " ");
                        for (j = 0; j < def->nserials; j++) {
2406
                            if (def->serials[j]->target.port == port) {
2407 2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418
                                chr = def->serials[j];
                                break;
                            }
                        }
                        if (chr) {
                            if (xenFormatSxprChr(chr, &buf) < 0)
                                goto error;
                        } else {
                            virBufferAddLit(&buf, "none");
                        }
                    }
                    virBufferAddLit(&buf, "))");
2419
                } else {
2420 2421 2422 2423 2424
                    virBufferAddLit(&buf, "(serial ");
                    if (xenFormatSxprChr(def->serials[0], &buf) < 0)
                        goto error;
                    virBufferAddLit(&buf, ")");
                }
2425 2426 2427 2428 2429 2430
            } else {
                virBufferAddLit(&buf, "(serial none)");
            }

            if (def->sounds) {
                virBufferAddLit(&buf, "(soundhw '");
M
Markus Groß 已提交
2431
                if (xenFormatSxprSound(def, &buf) < 0)
2432 2433 2434
                    goto error;
                virBufferAddLit(&buf, "')");
            }
P
Philipp Hahn 已提交
2435
        } /* hvm */
2436 2437

        /* get the device emulation model */
2438
        if (def->emulator && (hvm || xendConfigVersion >= XEND_CONFIG_VERSION_3_0_4))
2439 2440
            virBufferEscapeSexpr(&buf, "(device_model '%s')", def->emulator);

2441 2442 2443 2444 2445 2446 2447 2448 2449
        /* look for HPET in order to override the hypervisor/xend default */
        for (i = 0; i < def->clock.ntimers; i++) {
            if (def->clock.timers[i]->name == VIR_DOMAIN_TIMER_NAME_HPET &&
                def->clock.timers[i]->present != -1) {
                virBufferAsprintf(&buf, "(hpet %d)",
                                  def->clock.timers[i]->present);
                break;
            }
        }
2450

2451 2452
        /* PV graphics for xen <= 3.0.4, or HVM graphics */
        if (hvm || (xendConfigVersion < XEND_CONFIG_MIN_VERS_PVFB_NEWCONF)) {
2453
            if ((def->ngraphics == 1) &&
M
Markus Groß 已提交
2454 2455
                xenFormatSxprGraphicsOld(def->graphics[0],
                                         &buf, xendConfigVersion) < 0)
2456 2457
                goto error;
        }
2458 2459 2460
    } else {
        /* PV domains accept kernel cmdline args */
        if (def->os.cmdline) {
P
Philipp Hahn 已提交
2461 2462
            virBufferEscapeSexpr(&buf, "(image (linux (args '%s')", def->os.cmdline);
            in_image = true;
2463
        }
P
Philipp Hahn 已提交
2464 2465 2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476
    } /* os.bootloader */


    if (xendConfigVersion < XEND_CONFIG_VERSION_3_1_0) {
        /* <3.1: UTC and LOCALTIME */
        switch (def->clock.offset) {
        case VIR_DOMAIN_CLOCK_OFFSET_UTC:
            vmlocaltime = 0;
            break;
        case VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME:
            vmlocaltime = 1;
            break;
        default:
2477 2478 2479
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("unsupported clock offset='%s'"),
                           virDomainClockOffsetTypeToString(def->clock.offset));
P
Philipp Hahn 已提交
2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499
            goto error;
        }
    } else {
        if (!in_image) {
            if (hvm)
                virBufferAddLit(&buf, "(image (hvm ");
            else
                virBufferAddLit(&buf, "(image (linux ");
            in_image = true;
        }
        if (hvm) {
            /* >=3.1 HV: VARIABLE */
            int rtc_timeoffset;
            switch (def->clock.offset) {
            case VIR_DOMAIN_CLOCK_OFFSET_VARIABLE:
                vmlocaltime = (int)def->clock.data.variable.basis;
                rtc_timeoffset = def->clock.data.variable.adjustment;
                break;
            case VIR_DOMAIN_CLOCK_OFFSET_UTC:
                if (def->clock.data.utc_reset) {
2500
                    virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
2501
                                   _("unsupported clock adjustment='reset'"));
P
Philipp Hahn 已提交
2502 2503 2504 2505 2506 2507 2508
                    goto error;
                }
                vmlocaltime = 0;
                rtc_timeoffset = 0;
                break;
            case VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME:
                if (def->clock.data.utc_reset) {
2509
                    virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
2510
                                   _("unsupported clock adjustment='reset'"));
P
Philipp Hahn 已提交
2511 2512 2513 2514 2515 2516
                    goto error;
                }
                vmlocaltime = 1;
                rtc_timeoffset = 0;
                break;
            default:
2517 2518 2519
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                               _("unsupported clock offset='%s'"),
                               virDomainClockOffsetTypeToString(def->clock.offset));
P
Philipp Hahn 已提交
2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532
                goto error;
            }
            virBufferAsprintf(&buf, "(rtc_timeoffset %d)", rtc_timeoffset);
        } else {
            /* >=3.1 PV: UTC and LOCALTIME */
            switch (def->clock.offset) {
            case VIR_DOMAIN_CLOCK_OFFSET_UTC:
                vmlocaltime = 0;
                break;
            case VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME:
                vmlocaltime = 1;
                break;
            default:
2533 2534 2535
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                               _("unsupported clock offset='%s'"),
                               virDomainClockOffsetTypeToString(def->clock.offset));
P
Philipp Hahn 已提交
2536 2537 2538 2539 2540
                goto error;
            }
        } /* !hvm */
        /* default post-XenD-3.1 location: */
        virBufferAsprintf(&buf, "(localtime %d)", vmlocaltime);
2541
    }
P
Philipp Hahn 已提交
2542 2543 2544 2545 2546 2547 2548 2549
    if (in_image) {
        /* closes (image(hvm|linux */
        virBufferAddLit(&buf, "))");
        in_image = false;
    }
    /* pre-XenD-3.1 and compatibility location */
    virBufferAsprintf(&buf, "(localtime %d)", vmlocaltime);

2550

2551
    for (i = 0; i < def->ndisks; i++)
2552
        if (xenFormatSxprDisk(def->disks[i],
M
Markus Groß 已提交
2553
                              &buf, hvm, xendConfigVersion, 0) < 0)
2554 2555
            goto error;

2556
    for (i = 0; i < def->nnets; i++)
M
Markus Groß 已提交
2557 2558
        if (xenFormatSxprNet(conn, def->nets[i],
                             &buf, hvm, xendConfigVersion, 0) < 0)
2559 2560
            goto error;

M
Markus Groß 已提交
2561
    if (xenFormatSxprAllPCI(def, &buf) < 0)
2562 2563
        goto error;

2564 2565
    /* New style PV graphics config xen >= 3.0.4 */
    if (!hvm && (xendConfigVersion >= XEND_CONFIG_MIN_VERS_PVFB_NEWCONF)) {
2566
        if ((def->ngraphics == 1) &&
M
Markus Groß 已提交
2567
            xenFormatSxprGraphicsNew(def->graphics[0], &buf) < 0)
2568 2569 2570 2571 2572
            goto error;
    }

    virBufferAddLit(&buf, ")"); /* closes (vm */

2573
    if (virBufferCheckError(&buf) < 0)
2574 2575 2576 2577 2578 2579
        goto error;

    bufout = virBufferContentAndReset(&buf);
    VIR_DEBUG("Formatted sexpr: \n%s", bufout);
    return bufout;

2580
 error:
2581 2582 2583
    virBufferFreeAndReset(&buf);
    return NULL;
}