xen_sxpr.c 80.5 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
 *
 * Author: Anthony Liguori <aliguori@us.ibm.com>
 * Author: Daniel Veillard <veillard@redhat.com>
 * Author: Markus Groß <gross@univention.de>
 */

#include <config.h>

29 30
#include <regex.h>

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

J
Jim Fehlig 已提交
44
VIR_LOG_INIT("xenconfig.xen_sxpr");
45

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

    *id = -1;
53 54 55 56

    if (!root)
        return -1;

57
    ret = xenGetDomIdFromSxpr(root, id);
58
    sexpr_free(root);
59
    return ret;
60 61
}

P
Philipp Hahn 已提交
62
/* Get a domain id from a S-expression */
63
int xenGetDomIdFromSxpr(const struct sexpr *root, int *id)
64 65
{
    const char * tmp = sexpr_node(root, "domain/domid");
66 67 68

    *id = tmp ? sexpr_int(root, "domain/domid") : -1;
    return 0;
69 70 71 72
}

/*****************************************************************
 ******
P
Philipp Hahn 已提交
73
 ****** Parsing of S-Expression into virDomainDef objects
74 75 76 77
 ******
 *****************************************************************/

/**
P
Philipp Hahn 已提交
78
 * xenParseSxprOS:
79 80
 * @node: the root of the parsed S-Expression
 * @def: the domain config
P
Philipp Hahn 已提交
81
 * @hvm: true or 1 if node contains HVM S-Expression
82 83 84 85 86 87
 *
 * 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ß 已提交
88 89 90
xenParseSxprOS(const struct sexpr *node,
               virDomainDefPtr def,
               int hvm)
91 92
{
    if (hvm) {
93
        if (VIR_ALLOC(def->os.loader) < 0)
94
            goto error;
95 96 97 98
        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)
99
                goto error;
100

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

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

    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) {
162 163
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing kernel & bootloader"));
164 165 166 167 168
        return -1;
    }

    return 0;

169
 error:
170 171 172
    return -1;
}

P
Philipp Hahn 已提交
173 174 175 176 177 178 179 180 181 182

/**
  * 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.
  */
183
virDomainChrDefPtr
M
Markus Groß 已提交
184 185
xenParseSxprChar(const char *value,
                 const char *tty)
186 187 188 189 190
{
    const char *prefix;
    char *tmp;
    virDomainChrDefPtr def;

M
Michal Novotny 已提交
191
    if (!(def = virDomainChrDefNew()))
192 193 194 195 196 197
        return NULL;

    prefix = value;

    if (value[0] == '/') {
        def->source.type = VIR_DOMAIN_CHR_TYPE_DEV;
198 199
        if (VIR_STRDUP(def->source.data.file.path, value) < 0)
            goto error;
200 201 202 203 204 205 206 207 208 209 210
    } 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) {
211 212
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown chr device type '%s'"), prefix);
213 214 215 216 217 218 219
                goto error;
            }
        }
    }

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

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

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

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

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

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

        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) {
262 263
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("malformed char device string"));
264 265 266 267
            goto error;
        }

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

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

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

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

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

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

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

    return def;

314
 error:
315 316 317 318
    virDomainChrDefFree(def);
    return NULL;
}

P
Philipp Hahn 已提交
319

320 321 322 323 324 325 326 327
static const char *vif_bytes_per_sec_re = "^[0-9]+[GMK]?[Bb]/s$";

int
xenParseSxprVifRate(const char *rate, unsigned long long *kbytes_per_sec)
{
    char *trate = NULL;
    char *p;
    regex_t rec;
328
    int err;
329 330 331 332 333 334 335 336 337 338 339
    char *suffix;
    unsigned long long tmp;
    int ret = -1;

    if (VIR_STRDUP(trate, rate) < 0)
        return -1;

    p = strchr(trate, '@');
    if (p != NULL)
        *p = 0;

340 341 342 343 344 345 346 347 348 349
    err = regcomp(&rec, vif_bytes_per_sec_re, REG_EXTENDED|REG_NOSUB);
    if (err != 0) {
        char error[100];
        regerror(err, &rec, error, sizeof(error));
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Failed to compile regular expression '%s': %s"),
                       vif_bytes_per_sec_re, error);
        goto cleanup;
    }

350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379
    if (regexec(&rec, trate, 0, NULL, 0)) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Invalid rate '%s' specified"), rate);
        goto cleanup;
    }

    if (virStrToLong_ull(rate, &suffix, 10, &tmp)) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Failed to parse rate '%s'"), rate);
        goto cleanup;
    }

    if (*suffix == 'G')
       tmp *= 1024 * 1024;
    else if (*suffix == 'M')
       tmp *= 1024;

    if (*suffix == 'b' || *(suffix + 1) == 'b')
       tmp /= 8;

    *kbytes_per_sec = tmp;
    ret = 0;

 cleanup:
    regfree(&rec);
    VIR_FREE(trate);
    return ret;
}


380
/**
P
Philipp Hahn 已提交
381 382 383 384
 * xenParseSxprDisks:
 * @def: the domain config
 * @root: root S-expression
 * @hvm: true or 1 if node contains HVM S-Expression
385
 *
P
Philipp Hahn 已提交
386
 * This parses out block devices from the domain S-expression
387 388 389 390
 *
 * Returns 0 if successful or -1 if failed.
 */
static int
M
Markus Groß 已提交
391 392
xenParseSxprDisks(virDomainDefPtr def,
                  const struct sexpr *root,
393
                  int hvm)
394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409
{
    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 已提交
410
            const char *bootable = NULL;
411 412 413 414 415 416

            /* 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 已提交
417
                bootable = sexpr_node(node, "device/vbd/bootable");
418 419 420 421
            } 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 已提交
422
                bootable = sexpr_node(node, "device/tap2/bootable");
423 424 425 426
            } 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 已提交
427
                bootable = sexpr_node(node, "device/tap/bootable");
428 429
            }

430
            if (!(disk = virDomainDiskDefNew(NULL)))
431
                goto error;
432 433

            if (dst == NULL) {
434 435
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               "%s", _("domain information incomplete, vbd has no dev"));
436 437 438 439 440 441 442 443 444
                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")) {
445 446
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   "%s", _("domain information incomplete, vbd has no src"));
447 448 449 450 451 452 453
                    goto error;
                }
            }

            if (src != NULL) {
                offset = strchr(src, ':');
                if (!offset) {
454 455
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   "%s", _("cannot parse vbd filename, missing driver name"));
456 457 458
                    goto error;
                }

P
Philipp Hahn 已提交
459 460
                if (sexpr_lookup(node, "device/tap2") &&
                    STRPREFIX(src, "tap:")) {
461
                    if (virDomainDiskSetDriver(disk, "tap2") < 0)
462
                        goto error;
P
Philipp Hahn 已提交
463
                } else {
464 465
                    char *tmp;
                    if (VIR_STRNDUP(tmp, src, offset - src) < 0)
466
                        goto error;
467 468
                    if (virDomainDiskSetDriver(disk, tmp) < 0) {
                        VIR_FREE(tmp);
P
Philipp Hahn 已提交
469 470
                        goto error;
                    }
471
                    VIR_FREE(tmp);
472 473 474 475
                }

                src = offset + 1;

476 477
                if (STREQ(virDomainDiskGetDriver(disk), "tap") ||
                    STREQ(virDomainDiskGetDriver(disk), "tap2")) {
478 479
                    char *driverType = NULL;

480 481
                    offset = strchr(src, ':');
                    if (!offset) {
482 483
                        virReportError(VIR_ERR_INTERNAL_ERROR,
                                       "%s", _("cannot parse vbd filename, missing driver type"));
484 485 486
                        goto error;
                    }

487 488
                    if (VIR_STRNDUP(driverType, src, offset - src) < 0)
                        goto error;
489
                    if (STREQ(driverType, "aio"))
490
                        virDomainDiskSetFormat(disk, VIR_STORAGE_FILE_RAW);
491
                    else
492 493
                        virDomainDiskSetFormat(disk,
                                               virStorageFileFormatTypeFromString(driverType));
494
                    VIR_FREE(driverType);
495
                    if (virDomainDiskGetFormat(disk) <= 0) {
496
                        virReportError(VIR_ERR_INTERNAL_ERROR,
497
                                       _("Unknown driver type %s"), src);
498 499 500 501 502 503 504 505 506
                        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 已提交
507
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
508
                } else if (STREQ(virDomainDiskGetDriver(disk), "phy")) {
E
Eric Blake 已提交
509
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_BLOCK);
510
                } else if (STREQ(virDomainDiskGetDriver(disk), "file")) {
E
Eric Blake 已提交
511
                    virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
512 513 514 515 516
                }
            } 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 已提交
517
                virDomainDiskSetType(disk, VIR_STORAGE_TYPE_FILE);
518 519
            }

520
            if (STREQLEN(dst, "ioemu:", 6))
521 522 523
                dst += 6;

            disk->device = VIR_DOMAIN_DISK_DEVICE_DISK;
524 525 526 527 528 529 530 531
            offset = strrchr(dst, ':');
            if (offset) {
                if (STREQ(offset, ":cdrom")) {
                    disk->device = VIR_DOMAIN_DISK_DEVICE_CDROM;
                } else if (STREQ(offset, ":disk")) {
                    /* The default anyway */
                } else {
                    /* Unknown, lets pretend its a disk too */
532
                }
533
                offset[0] = '\0';
534 535
            }

536 537
            if (VIR_STRDUP(disk->dst, dst) < 0)
                goto error;
538
            if (virDomainDiskSetSource(disk, src) < 0)
539
                goto error;
540 541 542 543 544 545 546 547 548 549 550 551

            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'))
552
                disk->src->readonly = true;
553 554
            if (mode &&
                strchr(mode, '!'))
555
                disk->src->shared = true;
556 557

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

P
Philipp Hahn 已提交
560 561 562 563 564 565 566
            /* 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;
            }
567 568 569 570 571 572
            disk = NULL;
        }
    }

    return 0;

573
 error:
574 575 576 577 578
    virDomainDiskDefFree(disk);
    return -1;
}


P
Philipp Hahn 已提交
579 580 581 582 583 584 585 586 587
/**
 * 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.
 */
588
static int
M
Markus Groß 已提交
589 590
xenParseSxprNets(virDomainDefPtr def,
                 const struct sexpr *root)
591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606
{
    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)
607
                goto cleanup;
608 609 610 611 612 613

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

614 615 616 617 618
                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;
619
                tmp = sexpr_node(node, "device/vif/ip");
620
                if (tmp && virDomainNetAppendIpAddress(net, tmp, AF_UNSPEC, 0) < 0)
621
                    goto cleanup;
622 623
            } else {
                net->type = VIR_DOMAIN_NET_TYPE_ETHERNET;
624 625
                if (VIR_STRDUP(net->script, tmp2) < 0)
                    goto cleanup;
626
                tmp = sexpr_node(node, "device/vif/ip");
627
                if (tmp && virDomainNetAppendIpAddress(net, tmp, AF_UNSPEC, 0) < 0)
628
                    goto cleanup;
629 630 631
            }

            tmp = sexpr_node(node, "device/vif/vifname");
632 633 634 635
            /* 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) {
636 637
                if (VIR_STRDUP(net->ifname, tmp) < 0)
                    goto cleanup;
638 639
            } else if (def->id != -1) {
                if (virAsprintf(&net->ifname, "vif%d.%d", def->id, vif_index) < 0)
640
                    goto cleanup;
641 642 643 644
            }

            tmp = sexpr_node(node, "device/vif/mac");
            if (tmp) {
645
                if (virMacAddrParse(tmp, &net->mac) < 0) {
646 647
                    virReportError(VIR_ERR_INTERNAL_ERROR,
                                   _("malformed mac address '%s'"), tmp);
648 649 650 651
                    goto cleanup;
                }
            }

652 653
            if (VIR_STRDUP(net->model, model) < 0)
                goto cleanup;
654

655 656 657
            if (!model && type && STREQ(type, "netfront") &&
                VIR_STRDUP(net->model, "netfront") < 0)
                goto cleanup;
658

659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677
            tmp = sexpr_node(node, "device/vif/rate");
            if (tmp) {
                virNetDevBandwidthPtr bandwidth;
                unsigned long long kbytes_per_sec;

                if (xenParseSxprVifRate(tmp, &kbytes_per_sec) < 0)
                    goto cleanup;

                if (VIR_ALLOC(bandwidth) < 0)
                    goto cleanup;
                if (VIR_ALLOC(bandwidth->out) < 0) {
                    VIR_FREE(bandwidth);
                    goto cleanup;
                }

                bandwidth->out->average = kbytes_per_sec;
                net->bandwidth = bandwidth;
            }

678
            if (VIR_APPEND_ELEMENT(def->nets, def->nnets, net) < 0)
679
                goto cleanup;
680 681 682 683 684 685 686

            vif_index++;
        }
    }

    return 0;

687
 cleanup:
688 689 690 691 692
    virDomainNetDefFree(net);
    return -1;
}


P
Philipp Hahn 已提交
693 694 695 696 697 698 699 700 701
/**
 * 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.
 */
702
int
M
Markus Groß 已提交
703 704
xenParseSxprSound(virDomainDefPtr def,
                  const char *str)
705 706
{
    if (STREQ(str, "all")) {
707
        size_t i;
708 709

        /*
710
         * Special compatibility code for Xen with a bogus
711 712
         * sound=all in config.
         *
E
Eric Blake 已提交
713
         * NB deliberately, don't include all possible
714 715 716 717 718 719 720 721 722 723
         * 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)
724
            goto error;
725 726


727
        for (i = 0; i < (VIR_DOMAIN_SOUND_MODEL_ES1370 + 1); i++) {
728 729
            virDomainSoundDefPtr sound;
            if (VIR_ALLOC(sound) < 0)
730
                goto error;
731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746
            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) {
747 748 749
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("Sound model %s too big for destination"),
                               offset);
750 751 752 753
                goto error;
            }

            if (VIR_ALLOC(sound) < 0)
754
                goto error;
755 756 757 758 759 760

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

761
            if (VIR_APPEND_ELEMENT(def->sounds, def->nsounds, sound) < 0) {
762
                virDomainSoundDefFree(sound);
763
                goto error;
764 765 766 767 768 769 770 771
            }

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

    return 0;

772
 error:
773 774 775 776
    return -1;
}


P
Philipp Hahn 已提交
777 778 779 780 781 782 783 784 785
/**
 * 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.
 */
786
static int
M
Markus Groß 已提交
787 788
xenParseSxprUSB(virDomainDefPtr def,
                const struct sexpr *root)
789 790 791 792 793 794 795 796 797 798
{
    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") ||
799 800
                    STREQ(tmp, "mouse") ||
                    STREQ(tmp, "keyboard")) {
801 802
                    virDomainInputDefPtr input;
                    if (VIR_ALLOC(input) < 0)
803
                        goto error;
804 805 806
                    input->bus = VIR_DOMAIN_INPUT_BUS_USB;
                    if (STREQ(tmp, "tablet"))
                        input->type = VIR_DOMAIN_INPUT_TYPE_TABLET;
807
                    else if (STREQ(tmp, "mouse"))
808
                        input->type = VIR_DOMAIN_INPUT_TYPE_MOUSE;
809 810
                    else
                        input->type = VIR_DOMAIN_INPUT_TYPE_KBD;
811

812
                    if (VIR_APPEND_ELEMENT(def->inputs, def->ninputs, input) < 0) {
813
                        VIR_FREE(input);
814
                        goto error;
815 816 817 818 819 820 821 822 823
                    }
                } else {
                    /* XXX Handle other non-input USB devices later */
                }
            }
        }
    }
    return 0;

824
 error:
825 826 827
    return -1;
}

P
Philipp Hahn 已提交
828 829 830 831 832 833 834 835 836 837 838 839

/*
 * xenParseSxprGraphicsOld:
 * @def: the domain config
 * @root: root S-expression
 * @hvm: true or 1 if root contains HVM S-Expression
 * @vncport: VNC port number
 *
 * This parses out VNC devices from the domain S-expression
 *
 * Returns 0 if successful or -1 if failed.
 */
840
static int
M
Markus Groß 已提交
841 842 843
xenParseSxprGraphicsOld(virDomainDefPtr def,
                        const struct sexpr *root,
                        int hvm,
844
                        int vncport)
845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860
{
    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)
861
            goto error;
862 863 864

        graphics->type = VIR_DOMAIN_GRAPHICS_TYPE_VNC;
        if ((unused && STREQ(unused, "1")) || port == -1)
865
            graphics->data.vnc.autoport = true;
866 867 868
        graphics->data.vnc.port = port;

        if (listenAddr &&
869 870
            virDomainGraphicsListenSetAddress(graphics, 0, listenAddr, -1, true))
            goto error;
871

872 873
        if (VIR_STRDUP(graphics->data.vnc.auth.passwd, vncPasswd) < 0)
            goto error;
874

875 876
        if (VIR_STRDUP(graphics->data.vnc.keymap, keymap) < 0)
            goto error;
877 878

        if (VIR_ALLOC_N(def->graphics, 1) < 0)
879
            goto error;
880 881 882 883 884 885 886 887 888 889
        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)
890
            goto error;
891 892

        graphics->type = VIR_DOMAIN_GRAPHICS_TYPE_SDL;
893 894 895 896
        if (VIR_STRDUP(graphics->data.sdl.display, display) < 0)
            goto error;
        if (VIR_STRDUP(graphics->data.sdl.xauth, xauth) < 0)
            goto error;
897 898

        if (VIR_ALLOC_N(def->graphics, 1) < 0)
899
            goto error;
900 901 902 903 904 905 906
        def->graphics[0] = graphics;
        def->ngraphics = 1;
        graphics = NULL;
    }

    return 0;

907
 error:
908 909 910 911 912
    virDomainGraphicsDefFree(graphics);
    return -1;
}


P
Philipp Hahn 已提交
913 914 915 916 917 918 919 920 921 922
/*
 * 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.
 */
923
static int
M
Markus Groß 已提交
924 925
xenParseSxprGraphicsNew(virDomainDefPtr def,
                        const struct sexpr *root, int vncport)
926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947
{
    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)
948
                goto error;
949 950

            if ((graphics->type = virDomainGraphicsTypeFromString(tmp)) < 0) {
951 952
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown graphics type '%s'"), tmp);
953 954 955 956 957 958
                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");
959 960 961 962
                if (VIR_STRDUP(graphics->data.sdl.display, display) < 0)
                    goto error;
                if (VIR_STRDUP(graphics->data.sdl.xauth, xauth) < 0)
                    goto error;
963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980
            } 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)
981
                    graphics->data.vnc.autoport = true;
982 983 984 985 986 987

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

                if (listenAddr &&
988 989
                    virDomainGraphicsListenSetAddress(graphics, 0, listenAddr, -1, true))
                    goto error;
990

991 992
                if (VIR_STRDUP(graphics->data.vnc.auth.passwd, vncPasswd) < 0)
                    goto error;
993

994 995
                if (VIR_STRDUP(graphics->data.vnc.keymap, keymap) < 0)
                    goto error;
996 997 998
            }

            if (VIR_ALLOC_N(def->graphics, 1) < 0)
999
                goto error;
1000 1001 1002 1003 1004 1005 1006 1007 1008
            def->graphics[0] = graphics;
            def->ngraphics = 1;
            graphics = NULL;
            break;
        }
    }

    return 0;

1009
 error:
1010 1011 1012 1013
    virDomainGraphicsDefFree(graphics);
    return -1;
}

P
Philipp Hahn 已提交
1014

1015
/**
P
Philipp Hahn 已提交
1016 1017
 * xenParseSxprPCI:
 * @def: the domain config
1018 1019
 * @root: root sexpr
 *
P
Philipp Hahn 已提交
1020
 * This parses out PCI devices from the domain sexpr
1021 1022 1023 1024
 *
 * Returns 0 if successful or -1 if failed.
 */
static int
M
Markus Groß 已提交
1025 1026
xenParseSxprPCI(virDomainDefPtr def,
                const struct sexpr *root)
1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041
{
    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 已提交
1042
     * weird world of Xen PCI, once (device ...) covers multiple
1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069
     * 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"))) {
1070 1071
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI domain"));
1072 1073 1074
            goto error;
        }
        if (!(bus = sexpr_node(node, "dev/bus"))) {
1075 1076
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI bus"));
1077 1078 1079
            goto error;
        }
        if (!(slot = sexpr_node(node, "dev/slot"))) {
1080 1081
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI slot"));
1082 1083 1084
            goto error;
        }
        if (!(func = sexpr_node(node, "dev/func"))) {
1085 1086
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("missing PCI func"));
1087 1088 1089 1090
            goto error;
        }

        if (virStrToLong_i(domain, NULL, 0, &domainID) < 0) {
1091 1092
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI domain '%s'"), domain);
1093 1094 1095
            goto error;
        }
        if (virStrToLong_i(bus, NULL, 0, &busID) < 0) {
1096 1097
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI bus '%s'"), bus);
1098 1099 1100
            goto error;
        }
        if (virStrToLong_i(slot, NULL, 0, &slotID) < 0) {
1101 1102
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI slot '%s'"), slot);
1103 1104 1105
            goto error;
        }
        if (virStrToLong_i(func, NULL, 0, &funcID) < 0) {
1106 1107
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("cannot parse PCI func '%s'"), func);
1108 1109 1110
            goto error;
        }

1111 1112
        if (!(dev = virDomainHostdevDefAlloc()))
           goto error;
1113 1114

        dev->mode = VIR_DOMAIN_HOSTDEV_MODE_SUBSYS;
1115
        dev->managed = false;
1116
        dev->source.subsys.type = VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_PCI;
1117 1118 1119 1120
        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;
1121

1122
        if (VIR_APPEND_ELEMENT(def->hostdevs, def->nhostdevs, dev) < 0)
1123
            goto error;
1124 1125 1126 1127
    }

    return 0;

1128
 error:
1129 1130 1131 1132 1133 1134
    virDomainHostdevDefFree(dev);
    return -1;
}


/**
M
Markus Groß 已提交
1135
 * xenParseSxpr:
1136 1137
 * @root: the root of the parsed S-Expression
 * @cpus: set of cpus the domain may be pinned to
P
Philipp Hahn 已提交
1138 1139
 * @tty: the console pty path
 * @vncport: VNC port number
1140
 *
P
Philipp Hahn 已提交
1141 1142
 * Parse the xend S-expression description and turn it into a virDomainDefPtr
 * representing these settings as closely as is practical.
1143
 *
P
Philipp Hahn 已提交
1144 1145
 * Returns the domain config or NULL in case of error.
 *         The caller must free() the returned value.
1146 1147
 */
virDomainDefPtr
M
Markus Groß 已提交
1148
xenParseSxpr(const struct sexpr *root,
1149 1150 1151 1152 1153
             const char *cpus,
             char *tty,
             int vncport,
             virCapsPtr caps,
             virDomainXMLOptionPtr xmlopt)
1154 1155 1156
{
    const char *tmp;
    virDomainDefPtr def;
P
Philipp Hahn 已提交
1157
    int hvm = 0, vmlocaltime;
1158
    unsigned int vcpus;
1159

1160
    if (!(def = virDomainDefNew()))
1161
        goto error;
1162 1163 1164 1165 1166 1167 1168 1169 1170

    tmp = sexpr_node(root, "domain/domid");
    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)
1171
        goto error;
1172
    if (def->name == NULL) {
1173 1174
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing name"));
1175 1176 1177 1178 1179
        goto error;
    }

    tmp = sexpr_node(root, "domain/uuid");
    if (tmp == NULL) {
1180 1181
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("domain information incomplete, missing name"));
1182 1183
        goto error;
    }
1184 1185
    if (virUUIDParse(tmp, def->uuid) < 0)
        goto error;
1186 1187

    if (sexpr_node_copy(root, "domain/description", &def->description) < 0)
1188
        goto error;
1189 1190 1191 1192 1193

    hvm = sexpr_lookup(root, "domain/image/hvm") ? 1 : 0;
    if (!hvm) {
        if (sexpr_node_copy(root, "domain/bootloader",
                            &def->os.bootloader) < 0)
1194
            goto error;
1195 1196 1197

        if (!def->os.bootloader &&
            sexpr_has(root, "domain/bootloader") &&
1198 1199
            VIR_STRDUP(def->os.bootloader, "") < 0)
            goto error;
1200 1201 1202 1203

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

1207
    def->os.type = (hvm ? VIR_DOMAIN_OSTYPE_HVM : VIR_DOMAIN_OSTYPE_LINUX);
1208 1209 1210

    if (def->id != 0) {
        if (sexpr_lookup(root, "domain/image")) {
M
Markus Groß 已提交
1211
            if (xenParseSxprOS(root, def, hvm) < 0)
1212 1213 1214 1215
                goto error;
        }
    }

1216
    virDomainDefSetMemoryTotal(def, (sexpr_u64(root, "domain/maxmem") << 10));
1217
    def->mem.cur_balloon = (sexpr_u64(root, "domain/memory") << 10);
1218 1219 1220

    if (def->mem.cur_balloon > virDomainDefGetMemoryActual(def))
        def->mem.cur_balloon = virDomainDefGetMemoryActual(def);
1221 1222

    if (cpus != NULL) {
H
Hu Tao 已提交
1223
        if (virBitmapParse(cpus, 0, &def->cpumask,
1224
                           VIR_DOMAIN_CPUMASK_LEN) < 0)
1225
            goto error;
1226 1227 1228 1229 1230 1231 1232

        if (virBitmapIsAllClear(def->cpumask)) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("Invalid value of 'cpumask': %s"),
                           cpus);
            goto error;
        }
1233 1234
    }

1235 1236
    if (virDomainDefSetVcpusMax(def, sexpr_int(root, "domain/vcpus")) < 0)
        goto error;
1237 1238 1239 1240 1241 1242 1243

    vcpus = count_one_bits_l(sexpr_u64(root, "domain/vcpu_avail"));
    if (!vcpus || virDomainDefGetVcpusMax(def) < vcpus)
        vcpus = virDomainDefGetVcpusMax(def);

    if (virDomainDefSetVcpus(def, vcpus) < 0)
        goto error;
1244 1245 1246 1247

    tmp = sexpr_node(root, "domain/on_poweroff");
    if (tmp != NULL) {
        if ((def->onPoweroff = virDomainLifecycleTypeFromString(tmp)) < 0) {
1248 1249
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1250 1251
            goto error;
        }
1252
    } else {
1253
        def->onPoweroff = VIR_DOMAIN_LIFECYCLE_DESTROY;
1254
    }
1255 1256 1257 1258

    tmp = sexpr_node(root, "domain/on_reboot");
    if (tmp != NULL) {
        if ((def->onReboot = virDomainLifecycleTypeFromString(tmp)) < 0) {
1259 1260
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1261 1262
            goto error;
        }
1263
    } else {
1264
        def->onReboot = VIR_DOMAIN_LIFECYCLE_RESTART;
1265
    }
1266 1267 1268 1269

    tmp = sexpr_node(root, "domain/on_crash");
    if (tmp != NULL) {
        if ((def->onCrash = virDomainLifecycleCrashTypeFromString(tmp)) < 0) {
1270 1271
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unknown lifecycle type %s"), tmp);
1272 1273
            goto error;
        }
1274
    } else {
1275
        def->onCrash = VIR_DOMAIN_LIFECYCLE_CRASH_DESTROY;
1276
    }
1277 1278 1279

    if (hvm) {
        if (sexpr_int(root, "domain/image/hvm/acpi"))
J
Ján Tomko 已提交
1280
            def->features[VIR_DOMAIN_FEATURE_ACPI] = VIR_TRISTATE_SWITCH_ON;
1281
        if (sexpr_int(root, "domain/image/hvm/apic"))
J
Ján Tomko 已提交
1282
            def->features[VIR_DOMAIN_FEATURE_APIC] = VIR_TRISTATE_SWITCH_ON;
1283
        if (sexpr_int(root, "domain/image/hvm/pae"))
J
Ján Tomko 已提交
1284
            def->features[VIR_DOMAIN_FEATURE_PAE] = VIR_TRISTATE_SWITCH_ON;
1285
        if (sexpr_int(root, "domain/image/hvm/hap"))
J
Ján Tomko 已提交
1286
            def->features[VIR_DOMAIN_FEATURE_HAP] = VIR_TRISTATE_SWITCH_ON;
1287
        if (sexpr_int(root, "domain/image/hvm/viridian"))
J
Ján Tomko 已提交
1288
            def->features[VIR_DOMAIN_FEATURE_VIRIDIAN] = VIR_TRISTATE_SWITCH_ON;
P
Philipp Hahn 已提交
1289
    }
1290

P
Philipp Hahn 已提交
1291 1292 1293 1294
    /* 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");
1295 1296
        int rtc_offset;

P
Philipp Hahn 已提交
1297 1298
        if (value) {
            if (virStrToLong_i(value, NULL, 0, &vmlocaltime) < 0) {
1299 1300
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown localtime offset %s"), value);
P
Philipp Hahn 已提交
1301 1302 1303
                goto error;
            }
        }
1304 1305 1306 1307 1308 1309
        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;
1310 1311 1312 1313 1314

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

            if (VIR_ALLOC_N(def->clock.timers, 1) < 0 ||
1315
                VIR_ALLOC(timer) < 0)
1316 1317 1318 1319 1320
                goto error;

            timer->name = VIR_DOMAIN_TIMER_NAME_HPET;
            timer->present = sexpr_int(root, "domain/image/hvm/hpet");
            timer->tickpolicy = -1;
1321 1322
            timer->mode = -1;
            timer->track = -1;
1323 1324 1325 1326

            def->clock.ntimers = 1;
            def->clock.timers[0] = timer;
        }
P
Philipp Hahn 已提交
1327 1328 1329 1330
    } else {
        const char *value = sexpr_node(root, "domain/image/linux/localtime");
        if (value) {
            if (virStrToLong_i(value, NULL, 0, &vmlocaltime) < 0) {
1331 1332
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("unknown localtime offset %s"), value);
P
Philipp Hahn 已提交
1333 1334 1335 1336 1337
                goto error;
            }
        }
        /* PV domains do not have an emulated RTC and the offset is fixed. */
        if (vmlocaltime)
1338
            def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME;
P
Philipp Hahn 已提交
1339 1340 1341 1342
        else
            def->clock.offset = VIR_DOMAIN_CLOCK_OFFSET_UTC;
        def->clock.data.utc_reset = true;
    } /* !hvm */
1343 1344 1345 1346 1347

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

    /* append block devices */
1351
    if (xenParseSxprDisks(def, root, hvm) < 0)
1352 1353
        goto error;

M
Markus Groß 已提交
1354
    if (xenParseSxprNets(def, root) < 0)
1355 1356
        goto error;

M
Markus Groß 已提交
1357
    if (xenParseSxprPCI(def, root) < 0)
1358 1359 1360
        goto error;

    /* New style graphics device config */
M
Markus Groß 已提交
1361
    if (xenParseSxprGraphicsNew(def, root, vncport) < 0)
1362 1363 1364 1365
        goto error;

    /* Graphics device (HVM <= 3.0.4, or PV <= 3.0.3) vnc config */
    if ((def->ngraphics == 0) &&
1366
        xenParseSxprGraphicsOld(def, root, hvm, vncport) < 0)
1367 1368 1369 1370
        goto error;

    /* in case of HVM we have USB device emulation */
    if (hvm &&
M
Markus Groß 已提交
1371
        xenParseSxprUSB(def, root) < 0)
1372 1373 1374 1375
        goto error;

    /* Character device config */
    if (hvm) {
1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393
        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;
1394 1395 1396
                        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) {
1397
                            virDomainChrDefFree(chr);
1398
                            goto error;
1399 1400 1401 1402 1403 1404 1405
                        }
                    }
                    else
                        ports_skipped++;

                    have_multiple_serials = true;
                }
1406 1407
            }
        }
1408 1409 1410 1411 1412 1413 1414

        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;
1415 1416 1417
                chr->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_SERIAL;
                chr->target.port = 0;
                if (VIR_APPEND_ELEMENT(def->serials, def->nserials, chr) < 0) {
1418
                    virDomainChrDefFree(chr);
1419
                    goto error;
1420 1421 1422 1423
                }
            }
        }

1424 1425 1426 1427
        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ß 已提交
1428
            if ((chr = xenParseSxprChar(tmp, NULL)) == NULL)
1429
                goto error;
1430 1431 1432
            chr->deviceType = VIR_DOMAIN_CHR_DEVICE_TYPE_PARALLEL;
            chr->target.port = 0;
            if (VIR_APPEND_ELEMENT(def->parallels, def->nparallels, chr) < 0) {
1433
                virDomainChrDefFree(chr);
1434
                goto error;
1435 1436
            }
        }
1437
    } else if (def->id != 0) {
1438
        if (VIR_ALLOC_N(def->consoles, 1) < 0)
1439
            goto error;
1440
        def->nconsoles = 1;
1441
        /* Fake a paravirt console, since that's not in the sexpr */
1442
        if (!(def->consoles[0] = xenParseSxprChar("pty", tty)))
1443
            goto error;
1444 1445 1446
        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;
1447 1448 1449 1450 1451 1452 1453 1454
    }
    VIR_FREE(tty);


    /* Sound device config */
    if (hvm &&
        (tmp = sexpr_node(root, "domain/image/hvm/soundhw")) != NULL &&
        *tmp) {
M
Markus Groß 已提交
1455
        if (xenParseSxprSound(def, tmp) < 0)
1456 1457 1458
            goto error;
    }

1459 1460 1461 1462
    if (virDomainDefPostParse(def, caps, VIR_DOMAIN_DEF_PARSE_ABI_UPDATE,
                              xmlopt) < 0)
        goto error;

1463 1464
    return def;

1465
 error:
1466 1467 1468 1469 1470
    VIR_FREE(tty);
    virDomainDefFree(def);
    return NULL;
}

P
Philipp Hahn 已提交
1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483

/**
 * xenParseSxprString:
 * @sexpr: the root of the parsed S-Expression
 * @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.
 */
1484
virDomainDefPtr
M
Markus Groß 已提交
1485
xenParseSxprString(const char *sexpr,
1486 1487 1488 1489
                   char *tty,
                   int vncport,
                   virCapsPtr caps,
                   virDomainXMLOptionPtr xmlopt)
1490 1491 1492 1493 1494 1495 1496
{
    struct sexpr *root = string2sexpr(sexpr);
    virDomainDefPtr def;

    if (!root)
        return NULL;

1497
    def = xenParseSxpr(root, NULL, tty, vncport, caps, xmlopt);
1498 1499 1500
    sexpr_free(root);

    return def;
1501 1502 1503 1504 1505 1506 1507 1508 1509 1510
}

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


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

1526 1527
    if (def->type != VIR_DOMAIN_GRAPHICS_TYPE_SDL &&
        def->type != VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
1528 1529 1530
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected graphics type %d"),
                       def->type);
1531 1532 1533 1534 1535 1536 1537 1538 1539
        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)
1540
            virBufferAsprintf(buf, "(display '%s')", def->data.sdl.display);
1541
        if (def->data.sdl.xauth)
1542
            virBufferAsprintf(buf, "(xauthority '%s')", def->data.sdl.xauth);
1543 1544 1545 1546 1547 1548
    } 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)");
1549
            virBufferAsprintf(buf, "(vncdisplay %d)", def->data.vnc.port-5900);
1550 1551
        }

1552 1553 1554
        listenAddr = virDomainGraphicsListenGetAddress(def, 0);
        if (listenAddr)
            virBufferAsprintf(buf, "(vnclisten '%s')", listenAddr);
1555
        if (def->data.vnc.auth.passwd)
1556
            virBufferAsprintf(buf, "(vncpasswd '%s')", def->data.vnc.auth.passwd);
1557
        if (def->data.vnc.keymap)
1558
            virBufferAsprintf(buf, "(keymap '%s')", def->data.vnc.keymap);
1559 1560 1561 1562 1563 1564 1565 1566
    }

    virBufferAddLit(buf, "))");

    return 0;
}


P
Philipp Hahn 已提交
1567 1568 1569 1570 1571 1572 1573 1574 1575 1576
/**
 * xenFormatSxprGraphicsOld:
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 *
 * 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
 */
1577
static int
1578
xenFormatSxprGraphicsOld(virDomainGraphicsDefPtr def, virBufferPtr buf)
1579
{
1580 1581
    const char *listenAddr;

1582 1583
    if (def->type != VIR_DOMAIN_GRAPHICS_TYPE_SDL &&
        def->type != VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
1584 1585 1586
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected graphics type %d"),
                       def->type);
1587 1588 1589 1590 1591 1592
        return -1;
    }

    if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_SDL) {
        virBufferAddLit(buf, "(sdl 1)");
        if (def->data.sdl.display)
1593
            virBufferAsprintf(buf, "(display '%s')", def->data.sdl.display);
1594
        if (def->data.sdl.xauth)
1595
            virBufferAsprintf(buf, "(xauthority '%s')", def->data.sdl.xauth);
1596 1597
    } else if (def->type == VIR_DOMAIN_GRAPHICS_TYPE_VNC) {
        virBufferAddLit(buf, "(vnc 1)");
1598 1599 1600 1601 1602
        if (def->data.vnc.autoport) {
            virBufferAddLit(buf, "(vncunused 1)");
        } else {
            virBufferAddLit(buf, "(vncunused 0)");
            virBufferAsprintf(buf, "(vncdisplay %d)", def->data.vnc.port-5900);
1603
        }
1604 1605 1606 1607 1608 1609 1610 1611

        listenAddr = virDomainGraphicsListenGetAddress(def, 0);
        if (listenAddr)
            virBufferAsprintf(buf, "(vnclisten '%s')", listenAddr);
        if (def->data.vnc.auth.passwd)
            virBufferAsprintf(buf, "(vncpasswd '%s')", def->data.vnc.auth.passwd);
        if (def->data.vnc.keymap)
            virBufferAsprintf(buf, "(keymap '%s')", def->data.vnc.keymap);
1612 1613 1614 1615 1616
    }

    return 0;
}

P
Philipp Hahn 已提交
1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627

/**
 * 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
 */
1628
int
M
Markus Groß 已提交
1629 1630
xenFormatSxprChr(virDomainChrDefPtr def,
                 virBufferPtr buf)
1631 1632 1633 1634
{
    const char *type = virDomainChrTypeToString(def->source.type);

    if (!type) {
1635 1636
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("unexpected chr device type"));
1637 1638 1639 1640 1641 1642 1643 1644
        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:
1645
        virBufferAdd(buf, type, -1);
1646 1647 1648 1649
        break;

    case VIR_DOMAIN_CHR_TYPE_FILE:
    case VIR_DOMAIN_CHR_TYPE_PIPE:
1650
        virBufferAsprintf(buf, "%s:", type);
1651 1652 1653 1654 1655 1656 1657 1658
        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:
1659
        virBufferAsprintf(buf, "%s:%s:%s%s",
1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671
                          (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:
1672
        virBufferAsprintf(buf, "%s:%s:%s@%s:%s", type,
1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683
                          (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:
1684
        virBufferAsprintf(buf, "%s:", type);
1685 1686 1687 1688
        virBufferEscapeSexpr(buf, "%s", def->source.data.nix.path);
        if (def->source.data.nix.listen)
            virBufferAddLit(buf, ",server,nowait");
        break;
1689 1690

    default:
1691 1692
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("unsupported chr device type '%s'"), type);
1693
        return -1;
1694 1695
    }

1696
    if (virBufferCheckError(buf) < 0)
1697 1698 1699 1700 1701 1702 1703
        return -1;

    return 0;
}


/**
P
Philipp Hahn 已提交
1704 1705 1706 1707 1708
 * xenFormatSxprDisk:
 * @node: node containing the disk description
 * @buf: a buffer for the result S-expression
 * @hvm: true or 1 if domain is HVM
 * @isAttach: create expression for device attach (1).
1709
 *
P
Philipp Hahn 已提交
1710
 * Convert the disk device part of the domain config into a S-expresssion in buf.
1711 1712 1713 1714
 *
 * Returns 0 in case of success, -1 in case of error.
 */
int
1715
xenFormatSxprDisk(virDomainDiskDefPtr def,
M
Markus Groß 已提交
1716 1717 1718
                  virBufferPtr buf,
                  int hvm,
                  int isAttach)
1719
{
1720 1721 1722
    const char *src = virDomainDiskGetSource(def);
    const char *driver = virDomainDiskGetDriver(def);

1723 1724 1725 1726 1727 1728
    /* 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) {
1729
            virReportError(VIR_ERR_INVALID_ARG,
1730
                           _("Cannot directly attach floppy %s"), src);
1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741
            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.... */
1742
    if (STREQ_NULLABLE(driver, "tap")) {
1743
        virBufferAddLit(buf, "(tap ");
1744
    } else if (STREQ_NULLABLE(driver, "tap2")) {
1745 1746 1747 1748 1749 1750
        virBufferAddLit(buf, "(tap2 ");
    } else {
        virBufferAddLit(buf, "(vbd ");
    }

    if (hvm) {
1751 1752 1753 1754
        virBufferEscapeSexpr(buf, "(dev '%s:", def->dst);
        virBufferAsprintf(buf, "%s')",
                          def->device == VIR_DOMAIN_DISK_DEVICE_CDROM ?
                          "cdrom" : "disk");
1755 1756 1757 1758 1759 1760
    } else if (def->device == VIR_DOMAIN_DISK_DEVICE_CDROM) {
        virBufferEscapeSexpr(buf, "(dev '%s:cdrom')", def->dst);
    } else {
        virBufferEscapeSexpr(buf, "(dev '%s')", def->dst);
    }

1761 1762 1763 1764
    if (src) {
        if (driver) {
            if (STREQ(driver, "tap") ||
                STREQ(driver, "tap2")) {
1765
                const char *type;
1766
                int format = virDomainDiskGetFormat(def);
1767

1768
                if (!format || format == VIR_STORAGE_FILE_RAW)
1769
                    type = "aio";
1770
                else
1771 1772
                    type = virStorageFileFormatTypeToString(format);
                virBufferEscapeSexpr(buf, "(uname '%s:", driver);
1773
                virBufferEscapeSexpr(buf, "%s:", type);
1774
                virBufferEscapeSexpr(buf, "%s')", src);
1775
            } else {
1776 1777
                virBufferEscapeSexpr(buf, "(uname '%s:", driver);
                virBufferEscapeSexpr(buf, "%s')", src);
1778 1779
            }
        } else {
1780 1781
            int type = virDomainDiskGetType(def);

E
Eric Blake 已提交
1782
            if (type == VIR_STORAGE_TYPE_FILE) {
1783
                virBufferEscapeSexpr(buf, "(uname 'file:%s')", src);
E
Eric Blake 已提交
1784
            } else if (type == VIR_STORAGE_TYPE_BLOCK) {
1785 1786
                if (src[0] == '/')
                    virBufferEscapeSexpr(buf, "(uname 'phy:%s')", src);
1787 1788
                else
                    virBufferEscapeSexpr(buf, "(uname 'phy:/dev/%s')",
1789
                                         src);
1790
            } else {
1791 1792
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                               _("unsupported disk type %s"),
E
Eric Blake 已提交
1793
                               virStorageTypeToString(type));
1794 1795 1796 1797 1798
                return -1;
            }
        }
    }

1799
    if (def->src->readonly)
1800
        virBufferAddLit(buf, "(mode 'r')");
1801
    else if (def->src->shared)
1802 1803 1804
        virBufferAddLit(buf, "(mode 'w!')");
    else
        virBufferAddLit(buf, "(mode 'w')");
1805
    if (def->transient) {
1806
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
1807
                       _("transient disks not supported yet"));
1808 1809
        return -1;
    }
1810 1811 1812 1813 1814 1815 1816 1817 1818 1819

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

    virBufferAddLit(buf, ")");

    return 0;
}

/**
P
Philipp Hahn 已提交
1820 1821 1822 1823 1824 1825
 * xenFormatSxprNet:
 * @conn: connection
 * @def: the domain config
 * @buf: a buffer for the result S-expression
 * @hvm: true or 1 if domain is HVM
 * @isAttach: create expression for device attach (1).
1826
 *
P
Philipp Hahn 已提交
1827
 * Convert the interface description of the domain config into a S-expression in buf.
1828 1829 1830 1831 1832 1833 1834
 * 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ß 已提交
1835 1836 1837 1838 1839
xenFormatSxprNet(virConnectPtr conn,
                 virDomainNetDefPtr def,
                 virBufferPtr buf,
                 int hvm,
                 int isAttach)
1840 1841
{
    const char *script = DEFAULT_VIF_SCRIPT;
1842
    char macaddr[VIR_MAC_STRING_BUFLEN];
1843 1844 1845 1846

    if (def->type != VIR_DOMAIN_NET_TYPE_BRIDGE &&
        def->type != VIR_DOMAIN_NET_TYPE_NETWORK &&
        def->type != VIR_DOMAIN_NET_TYPE_ETHERNET) {
1847 1848
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unsupported network type %d"), def->type);
1849 1850
        return -1;
    }
1851 1852 1853
    if (def->script &&
        def->type != VIR_DOMAIN_NET_TYPE_BRIDGE &&
        def->type != VIR_DOMAIN_NET_TYPE_ETHERNET) {
1854 1855 1856
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("scripts are not supported on interfaces of type %s"),
                       virDomainNetTypeToString(def->type));
1857 1858
        return -1;
    }
1859 1860 1861 1862 1863 1864

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

    virBufferAddLit(buf, "(vif ");

1865
    virBufferAsprintf(buf, "(mac '%s')", virMacAddrFormat(&def->mac, macaddr));
1866

1867 1868 1869
    if (def->bandwidth && def->bandwidth->out && def->bandwidth->out->average)
        virBufferAsprintf(buf, "(rate '%lluKB/s')", def->bandwidth->out->average);

1870 1871 1872
    switch (def->type) {
    case VIR_DOMAIN_NET_TYPE_BRIDGE:
        virBufferEscapeSexpr(buf, "(bridge '%s')", def->data.bridge.brname);
1873 1874
        if (def->script)
            script = def->script;
1875 1876

        virBufferEscapeSexpr(buf, "(script '%s')", script);
1877
        if (def->nips == 1) {
1878 1879 1880
            char *ipStr = virSocketAddrFormat(&def->ips[0]->address);
            virBufferEscapeSexpr(buf, "(ip '%s')", ipStr);
            VIR_FREE(ipStr);
1881 1882 1883 1884
        } else if (def->nips > 1) {
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                           _("Driver does not support setting multiple IP addresses"));
            return -1;
1885
        }
1886 1887 1888 1889 1890 1891 1892 1893 1894
        break;

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

        if (!network) {
1895 1896
            virReportError(VIR_ERR_NO_NETWORK, "%s",
                           def->data.network.name);
1897 1898 1899 1900
            return -1;
        }

        bridge = virNetworkGetBridgeName(network);
1901
        virObjectUnref(network);
1902
        if (!bridge) {
1903 1904 1905
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("network %s is not active"),
                           def->data.network.name);
1906 1907 1908 1909 1910 1911 1912 1913 1914
            return -1;
        }
        virBufferEscapeSexpr(buf, "(bridge '%s')", bridge);
        virBufferEscapeSexpr(buf, "(script '%s')", script);
        VIR_FREE(bridge);
    }
    break;

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

M
Michele Paolino 已提交
1929
    case VIR_DOMAIN_NET_TYPE_VHOSTUSER:
1930 1931 1932 1933
    case VIR_DOMAIN_NET_TYPE_USER:
    case VIR_DOMAIN_NET_TYPE_SERVER:
    case VIR_DOMAIN_NET_TYPE_CLIENT:
    case VIR_DOMAIN_NET_TYPE_MCAST:
1934
    case VIR_DOMAIN_NET_TYPE_UDP:
1935 1936
    case VIR_DOMAIN_NET_TYPE_INTERNAL:
    case VIR_DOMAIN_NET_TYPE_DIRECT:
1937
    case VIR_DOMAIN_NET_TYPE_HOSTDEV:
1938 1939 1940 1941 1942 1943 1944 1945 1946 1947 1948
    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);
1949
    } else {
1950 1951
        if (def->model != NULL && STREQ(def->model, "netfront")) {
            virBufferAddLit(buf, "(type netfront)");
1952
        } else {
1953
            if (def->model != NULL)
1954 1955
                virBufferEscapeSexpr(buf, "(model '%s')", def->model);
        }
1956 1957 1958 1959 1960 1961 1962 1963 1964 1965 1966
    }

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

    virBufferAddLit(buf, ")");

    return 0;
}


P
Philipp Hahn 已提交
1967 1968 1969 1970 1971 1972 1973 1974 1975
/**
 * 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.
 */
1976
static void
M
Markus Groß 已提交
1977 1978
xenFormatSxprPCI(virDomainHostdevDefPtr def,
                 virBufferPtr buf)
1979
{
1980
    virBufferAsprintf(buf, "(dev (domain 0x%04x)(bus 0x%02x)(slot 0x%02x)(func 0x%x))",
1981 1982 1983 1984
                      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);
1985 1986
}

P
Philipp Hahn 已提交
1987 1988 1989 1990 1991 1992 1993 1994 1995 1996 1997

/**
 * 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.
 */
1998
int
M
Markus Groß 已提交
1999 2000 2001
xenFormatSxprOnePCI(virDomainHostdevDefPtr def,
                    virBufferPtr buf,
                    int detach)
2002 2003
{
    if (def->managed) {
2004 2005
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("managed PCI devices not supported with XenD"));
2006 2007 2008 2009
        return -1;
    }

    virBufferAddLit(buf, "(pci ");
M
Markus Groß 已提交
2010
    xenFormatSxprPCI(def, buf);
2011 2012 2013 2014 2015 2016 2017 2018 2019
    if (detach)
        virBufferAddLit(buf, "(state 'Closing')");
    else
        virBufferAddLit(buf, "(state 'Initialising')");
    virBufferAddLit(buf, ")");

    return 0;
}

P
Philipp Hahn 已提交
2020 2021 2022 2023 2024 2025 2026 2027 2028 2029

/**
 * 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.
 */
2030
static int
M
Markus Groß 已提交
2031 2032
xenFormatSxprAllPCI(virDomainDefPtr def,
                    virBufferPtr buf)
2033 2034
{
    int hasPCI = 0;
2035
    size_t i;
2036

2037
    for (i = 0; i < def->nhostdevs; i++)
2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052 2053 2054 2055 2056 2057 2058 2059
        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 ");
2060
    for (i = 0; i < def->nhostdevs; i++) {
2061 2062 2063
        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) {
2064 2065
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("managed PCI devices not supported with XenD"));
2066 2067 2068
                return -1;
            }

M
Markus Groß 已提交
2069
            xenFormatSxprPCI(def->hostdevs[i], buf);
2070 2071 2072 2073 2074 2075 2076
        }
    }
    virBufferAddLit(buf, "))");

    return 0;
}

P
Philipp Hahn 已提交
2077 2078 2079 2080 2081 2082 2083 2084 2085 2086

/**
 * 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.
 */
2087
int
M
Markus Groß 已提交
2088 2089
xenFormatSxprSound(virDomainDefPtr def,
                   virBufferPtr buf)
2090 2091
{
    const char *str;
2092
    size_t i;
2093

2094
    for (i = 0; i < def->nsounds; i++) {
2095
        if (!(str = virDomainSoundModelTypeToString(def->sounds[i]->model))) {
2096 2097 2098
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("unexpected sound model %d"),
                           def->sounds[i]->model);
2099 2100 2101 2102 2103 2104 2105
            return -1;
        }
        if (i)
            virBufferAddChar(buf, ',');
        virBufferEscapeSexpr(buf, "%s", str);
    }

2106
    if (virBufferCheckError(buf) < 0)
2107 2108 2109 2110 2111 2112
        return -1;

    return 0;
}


P
Philipp Hahn 已提交
2113 2114 2115 2116 2117 2118 2119 2120 2121
/**
 * 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.
 */
2122
static int
M
Markus Groß 已提交
2123 2124
xenFormatSxprInput(virDomainInputDefPtr input,
                   virBufferPtr buf)
2125 2126 2127 2128 2129
{
    if (input->bus != VIR_DOMAIN_INPUT_BUS_USB)
        return 0;

    if (input->type != VIR_DOMAIN_INPUT_TYPE_MOUSE &&
2130 2131
        input->type != VIR_DOMAIN_INPUT_TYPE_TABLET &&
        input->type != VIR_DOMAIN_INPUT_TYPE_KBD) {
2132 2133
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected input type %d"), input->type);
2134 2135 2136
        return -1;
    }

2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147
    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;
    }
2148 2149 2150 2151 2152 2153 2154 2155 2156 2157

    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ß 已提交
2158
 * xenFormatSxpr:
2159 2160 2161
 * @conn: pointer to the hypervisor connection
 * @def: domain config definition
 *
P
Philipp Hahn 已提交
2162
 * Generate an S-expression representing the domain configuration.
2163 2164 2165 2166 2167
 *
 * Returns the 0 terminated S-Expr string or NULL in case of error.
 *         the caller must free() the returned value.
 */
char *
2168
xenFormatSxpr(virConnectPtr conn, virDomainDefPtr def)
2169 2170 2171 2172 2173
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
    char uuidstr[VIR_UUID_STRING_BUFLEN];
    const char *tmp;
    char *bufout;
2174 2175
    int hvm = 0, vmlocaltime = -1;
    size_t i;
P
Philipp Hahn 已提交
2176
    bool in_image = false;
2177

2178
    VIR_DEBUG("Formatting domain sexpr");
2179 2180 2181

    virBufferAddLit(&buf, "(vm ");
    virBufferEscapeSexpr(&buf, "(name '%s')", def->name);
2182
    virBufferAsprintf(&buf, "(memory %llu)(maxmem %llu)",
2183
                      VIR_DIV_UP(def->mem.cur_balloon, 1024),
2184
                      VIR_DIV_UP(virDomainDefGetMemoryActual(def), 1024));
2185
    virBufferAsprintf(&buf, "(vcpus %u)", virDomainDefGetVcpusMax(def));
2186 2187
    /* Computing the vcpu_avail bitmask works because MAX_VIRT_CPUS is
       either 32, or 64 on a platform where long is big enough.  */
2188
    if (virDomainDefHasVcpusOffline(def))
2189 2190
        virBufferAsprintf(&buf, "(vcpu_avail %lu)",
                          (1UL << virDomainDefGetVcpus(def)) - 1);
2191 2192

    if (def->cpumask) {
H
Hu Tao 已提交
2193
        char *ranges = virBitmapFormat(def->cpumask);
2194 2195 2196 2197 2198 2199 2200
        if (ranges == NULL)
            goto error;
        virBufferEscapeSexpr(&buf, "(cpus '%s')", ranges);
        VIR_FREE(ranges);
    }

    virUUIDFormat(def->uuid, uuidstr);
2201
    virBufferAsprintf(&buf, "(uuid '%s')", uuidstr);
2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216

    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))) {
2217 2218
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onPoweroff);
2219 2220
        goto error;
    }
2221
    virBufferAsprintf(&buf, "(on_poweroff '%s')", tmp);
2222 2223

    if (!(tmp = virDomainLifecycleTypeToString(def->onReboot))) {
2224 2225
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onReboot);
2226 2227
        goto error;
    }
2228
    virBufferAsprintf(&buf, "(on_reboot '%s')", tmp);
2229 2230

    if (!(tmp = virDomainLifecycleCrashTypeToString(def->onCrash))) {
2231 2232
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unexpected lifecycle value %d"), def->onCrash);
2233 2234
        goto error;
    }
2235
    virBufferAsprintf(&buf, "(on_crash '%s')", tmp);
2236

2237
    if (def->os.type == VIR_DOMAIN_OSTYPE_HVM)
P
Philipp Hahn 已提交
2238
        hvm = 1;
2239 2240 2241 2242 2243 2244

    if (!def->os.bootloader) {
        if (hvm)
            virBufferAddLit(&buf, "(image (hvm ");
        else
            virBufferAddLit(&buf, "(image (linux ");
P
Philipp Hahn 已提交
2245
        in_image = true;
2246 2247 2248

        if (hvm &&
            def->os.loader == NULL) {
2249
            virReportError(VIR_ERR_INTERNAL_ERROR,
E
Eric Blake 已提交
2250
                           "%s", _("no HVM domain loader"));
2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265
            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)
2266
                virBufferEscapeSexpr(&buf, "(loader '%s')", def->os.loader->path);
2267
            else
2268
                virBufferEscapeSexpr(&buf, "(kernel '%s')", def->os.loader->path);
2269

2270
            virBufferAsprintf(&buf, "(vcpus %u)", virDomainDefGetVcpusMax(def));
2271
            if (virDomainDefHasVcpusOffline(def))
2272
                virBufferAsprintf(&buf, "(vcpu_avail %lu)",
2273
                                  (1UL << virDomainDefGetVcpus(def)) - 1);
2274

2275
            for (i = 0; i < def->os.nBootDevs; i++) {
2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297
                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';
            }
2298
            virBufferAsprintf(&buf, "(boot %s)", bootorder);
2299

J
Ján Tomko 已提交
2300
            if (def->features[VIR_DOMAIN_FEATURE_ACPI] == VIR_TRISTATE_SWITCH_ON)
2301
                virBufferAddLit(&buf, "(acpi 1)");
J
Ján Tomko 已提交
2302
            if (def->features[VIR_DOMAIN_FEATURE_APIC] == VIR_TRISTATE_SWITCH_ON)
2303
                virBufferAddLit(&buf, "(apic 1)");
J
Ján Tomko 已提交
2304
            if (def->features[VIR_DOMAIN_FEATURE_PAE] == VIR_TRISTATE_SWITCH_ON)
2305
                virBufferAddLit(&buf, "(pae 1)");
J
Ján Tomko 已提交
2306
            if (def->features[VIR_DOMAIN_FEATURE_HAP] == VIR_TRISTATE_SWITCH_ON)
2307
                virBufferAddLit(&buf, "(hap 1)");
J
Ján Tomko 已提交
2308
            if (def->features[VIR_DOMAIN_FEATURE_VIRIDIAN] == VIR_TRISTATE_SWITCH_ON)
2309
                virBufferAddLit(&buf, "(viridian 1)");
2310 2311 2312

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

2313
            for (i = 0; i < def->ninputs; i++)
M
Markus Groß 已提交
2314
                if (xenFormatSxprInput(def->inputs[i], &buf) < 0)
2315 2316 2317 2318
                    goto error;

            if (def->parallels) {
                virBufferAddLit(&buf, "(parallel ");
M
Markus Groß 已提交
2319
                if (xenFormatSxprChr(def->parallels[0], &buf) < 0)
2320 2321 2322 2323 2324 2325
                    goto error;
                virBufferAddLit(&buf, ")");
            } else {
                virBufferAddLit(&buf, "(parallel none)");
            }
            if (def->serials) {
2326
                if ((def->nserials > 1) || (def->serials[0]->target.port != 0)) {
2327 2328
                    int maxport = -1, port;
                    size_t j = 0;
2329 2330 2331 2332 2333 2334

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

2335
                    for (port = 0; port <= maxport; port++) {
2336 2337
                        virDomainChrDefPtr chr = NULL;

2338
                        if (port)
2339 2340
                            virBufferAddLit(&buf, " ");
                        for (j = 0; j < def->nserials; j++) {
2341
                            if (def->serials[j]->target.port == port) {
2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353
                                chr = def->serials[j];
                                break;
                            }
                        }
                        if (chr) {
                            if (xenFormatSxprChr(chr, &buf) < 0)
                                goto error;
                        } else {
                            virBufferAddLit(&buf, "none");
                        }
                    }
                    virBufferAddLit(&buf, "))");
2354
                } else {
2355 2356 2357 2358 2359
                    virBufferAddLit(&buf, "(serial ");
                    if (xenFormatSxprChr(def->serials[0], &buf) < 0)
                        goto error;
                    virBufferAddLit(&buf, ")");
                }
2360 2361 2362 2363 2364 2365
            } else {
                virBufferAddLit(&buf, "(serial none)");
            }

            if (def->sounds) {
                virBufferAddLit(&buf, "(soundhw '");
M
Markus Groß 已提交
2366
                if (xenFormatSxprSound(def, &buf) < 0)
2367 2368 2369
                    goto error;
                virBufferAddLit(&buf, "')");
            }
P
Philipp Hahn 已提交
2370
        } /* hvm */
2371 2372

        /* get the device emulation model */
2373
        if (def->emulator && hvm)
2374 2375
            virBufferEscapeSexpr(&buf, "(device_model '%s')", def->emulator);

2376 2377 2378 2379 2380 2381 2382 2383 2384
        /* 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;
            }
        }
2385

2386
        /* PV graphics for xen <= 3.0.4, or HVM graphics */
2387
        if (hvm) {
2388
            if ((def->ngraphics == 1) &&
2389
                xenFormatSxprGraphicsOld(def->graphics[0], &buf) < 0)
2390 2391
                goto error;
        }
2392 2393 2394
    } else {
        /* PV domains accept kernel cmdline args */
        if (def->os.cmdline) {
P
Philipp Hahn 已提交
2395 2396
            virBufferEscapeSexpr(&buf, "(image (linux (args '%s')", def->os.cmdline);
            in_image = true;
2397
        }
P
Philipp Hahn 已提交
2398 2399
    } /* os.bootloader */

2400 2401 2402 2403 2404 2405 2406 2407 2408 2409
    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;
P
Philipp Hahn 已提交
2410
        switch (def->clock.offset) {
2411 2412 2413 2414
        case VIR_DOMAIN_CLOCK_OFFSET_VARIABLE:
            vmlocaltime = (int)def->clock.data.variable.basis;
            rtc_timeoffset = def->clock.data.variable.adjustment;
            break;
P
Philipp Hahn 已提交
2415
        case VIR_DOMAIN_CLOCK_OFFSET_UTC:
2416 2417 2418 2419 2420
            if (def->clock.data.utc_reset) {
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("unsupported clock adjustment='reset'"));
                goto error;
            }
P
Philipp Hahn 已提交
2421
            vmlocaltime = 0;
2422
            rtc_timeoffset = 0;
P
Philipp Hahn 已提交
2423 2424
            break;
        case VIR_DOMAIN_CLOCK_OFFSET_LOCALTIME:
2425 2426 2427 2428 2429
            if (def->clock.data.utc_reset) {
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                               _("unsupported clock adjustment='reset'"));
                goto error;
            }
P
Philipp Hahn 已提交
2430
            vmlocaltime = 1;
2431
            rtc_timeoffset = 0;
P
Philipp Hahn 已提交
2432 2433
            break;
        default:
2434 2435 2436
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("unsupported clock offset='%s'"),
                           virDomainClockOffsetTypeToString(def->clock.offset));
P
Philipp Hahn 已提交
2437 2438
            goto error;
        }
2439
        virBufferAsprintf(&buf, "(rtc_timeoffset %d)", rtc_timeoffset);
P
Philipp Hahn 已提交
2440
    } else {
2441 2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453
        /* >=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:
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("unsupported clock offset='%s'"),
                           virDomainClockOffsetTypeToString(def->clock.offset));
            goto error;
P
Philipp Hahn 已提交
2454
        }
2455 2456 2457 2458
    } /* !hvm */
    /* default post-XenD-3.1 location: */
    virBufferAsprintf(&buf, "(localtime %d)", vmlocaltime);

P
Philipp Hahn 已提交
2459 2460 2461 2462 2463 2464 2465 2466
    if (in_image) {
        /* closes (image(hvm|linux */
        virBufferAddLit(&buf, "))");
        in_image = false;
    }
    /* pre-XenD-3.1 and compatibility location */
    virBufferAsprintf(&buf, "(localtime %d)", vmlocaltime);

2467

2468
    for (i = 0; i < def->ndisks; i++)
2469
        if (xenFormatSxprDisk(def->disks[i], &buf, hvm, 0) < 0)
2470 2471
            goto error;

2472
    for (i = 0; i < def->nnets; i++)
2473
        if (xenFormatSxprNet(conn, def->nets[i], &buf, hvm, 0) < 0)
2474 2475
            goto error;

M
Markus Groß 已提交
2476
    if (xenFormatSxprAllPCI(def, &buf) < 0)
2477 2478
        goto error;

2479
    /* New style PV graphics config xen >= 3.0.4 */
2480
    if (!hvm) {
2481
        if ((def->ngraphics == 1) &&
M
Markus Groß 已提交
2482
            xenFormatSxprGraphicsNew(def->graphics[0], &buf) < 0)
2483 2484 2485 2486 2487
            goto error;
    }

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

2488
    if (virBufferCheckError(&buf) < 0)
2489 2490 2491 2492 2493 2494
        goto error;

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

2495
 error:
2496 2497 2498
    virBufferFreeAndReset(&buf);
    return NULL;
}