lxc_container.c 71.5 KB
Newer Older
1
/*
2
 * Copyright (C) 2008-2012 Red Hat, Inc.
3
 * Copyright (C) 2008 IBM Corp.
4 5 6 7 8
 *
 * lxc_container.c: file description
 *
 * Authors:
 *  David L. Leskovec <dlesko at linux.vnet.ibm.com>
9
 *  Daniel P. Berrange <berrange@redhat.com>
10 11 12 13 14 15 16 17 18 19 20 21
 *
 * 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
22
 * License along with this library.  If not, see
O
Osier Yang 已提交
23
 * <http://www.gnu.org/licenses/>.
24 25 26 27 28 29 30
 */

#include <config.h>

#include <fcntl.h>
#include <limits.h>
#include <stdlib.h>
31
#include <stdio.h>
32 33
#include <sys/ioctl.h>
#include <sys/mount.h>
34
#include <sys/wait.h>
35
#include <sys/stat.h>
36
#include <unistd.h>
37
#include <mntent.h>
38
#include <dirent.h>
39 40
#include <sys/reboot.h>
#include <linux/reboot.h>
41 42 43 44 45 46

/* Yes, we want linux private one, for _syscall2() macro */
#include <linux/unistd.h>

/* For MS_MOVE */
#include <linux/fs.h>
47

48
#if WITH_CAPNG
49
# include <cap-ng.h>
D
Daniel P. Berrange 已提交
50
#endif
51

52
#if WITH_BLKID
53 54 55
# include <blkid/blkid.h>
#endif

56
#include "virerror.h"
57
#include "virlog.h"
58
#include "lxc_container.h"
59
#include "virutil.h"
60
#include "viralloc.h"
61
#include "virnetdevveth.h"
62
#include "viruuid.h"
E
Eric Blake 已提交
63
#include "virfile.h"
64
#include "virusb.h"
65
#include "vircommand.h"
66
#include "virnetdev.h"
67
#include "virprocess.h"
68

69 70
#define VIR_FROM_THIS VIR_FROM_LXC

71 72 73 74 75 76
/*
 * GLibc headers are behind the kernel, so we define these
 * constants if they're not present already.
 */

#ifndef CLONE_NEWPID
77
# define CLONE_NEWPID  0x20000000
78 79
#endif
#ifndef CLONE_NEWUTS
80
# define CLONE_NEWUTS  0x04000000
81 82
#endif
#ifndef CLONE_NEWUSER
83
# define CLONE_NEWUSER 0x10000000
84 85
#endif
#ifndef CLONE_NEWIPC
86
# define CLONE_NEWIPC  0x08000000
87 88
#endif
#ifndef CLONE_NEWNET
89
# define CLONE_NEWNET  0x40000000 /* New network namespace */
90 91 92 93 94 95 96 97
#endif

/* messages between parent and container */
typedef char lxc_message_t;
#define LXC_CONTINUE_MSG 'c'

typedef struct __lxc_child_argv lxc_child_argv_t;
struct __lxc_child_argv {
98
    virDomainDefPtr config;
99
    virSecurityManagerPtr securityDriver;
100
    size_t nveths;
101
    char **veths;
102
    int monitor;
103 104
    char **ttyPaths;
    size_t nttyPaths;
105
    int handshakefd;
106 107
};

108 109 110
static int lxcContainerMountFSBlock(virDomainFSDefPtr fs,
                                    const char *srcprefix);

111

112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170
/*
 * reboot(LINUX_REBOOT_CMD_CAD_ON) will return -EINVAL
 * in a child pid namespace if container reboot support exists.
 * Otherwise, it will either succeed or return -EPERM.
 */
ATTRIBUTE_NORETURN static int
lxcContainerRebootChild(void *argv)
{
    int *cmd = argv;
    int ret;

    ret = reboot(*cmd);
    if (ret == -1 && errno == EINVAL)
        _exit(1);
    _exit(0);
}


static
int lxcContainerHasReboot(void)
{
    int flags = CLONE_NEWPID|CLONE_NEWNS|CLONE_NEWUTS|
        CLONE_NEWIPC|SIGCHLD;
    int cpid;
    char *childStack;
    char *stack;
    char *buf;
    int cmd, v;
    int status;
    char *tmp;

    if (virFileReadAll("/proc/sys/kernel/ctrl-alt-del", 10, &buf) < 0)
        return -1;

    if ((tmp = strchr(buf, '\n')))
        *tmp = '\0';

    if (virStrToLong_i(buf, NULL, 10, &v) < 0) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Malformed ctrl-alt-del setting '%s'"), buf);
        VIR_FREE(buf);
        return -1;
    }
    VIR_FREE(buf);
    cmd = v ? LINUX_REBOOT_CMD_CAD_ON : LINUX_REBOOT_CMD_CAD_OFF;

    if (VIR_ALLOC_N(stack, getpagesize() * 4) < 0) {
        virReportOOMError();
        return -1;
    }

    childStack = stack + (getpagesize() * 4);

    cpid = clone(lxcContainerRebootChild, childStack, flags, &cmd);
    VIR_FREE(stack);
    if (cpid < 0) {
        virReportSystemError(errno, "%s",
                             _("Unable to clone to check reboot support"));
        return -1;
171
    } else if (virProcessWait(cpid, &status) < 0) {
172 173 174 175 176 177 178 179 180 181 182 183 184 185
        return -1;
    }

    if (WEXITSTATUS(status) != 1) {
        VIR_DEBUG("Containerized reboot support is missing "
                  "(kernel probably too old < 3.4)");
        return 0;
    }

    VIR_DEBUG("Containerized reboot support is available");
    return 1;
}


186
/**
187
 * lxcContainerBuildInitCmd:
188
 * @vmDef: pointer to vm definition structure
189
 *
190
 * Build a virCommandPtr for launching the container 'init' process
191
 *
192
 * Returns a virCommandPtr
193
 */
194
static virCommandPtr lxcContainerBuildInitCmd(virDomainDefPtr vmDef)
195
{
196
    char uuidstr[VIR_UUID_STRING_BUFLEN];
197
    virCommandPtr cmd;
198 199 200

    virUUIDFormat(vmDef->uuid, uuidstr);

201 202
    cmd = virCommandNew(vmDef->os.init);

203 204 205
    if (vmDef->os.initargv && vmDef->os.initargv[0])
        virCommandAddArgSet(cmd, (const char **)vmDef->os.initargv);

206 207
    virCommandAddEnvString(cmd, "PATH=/bin:/sbin");
    virCommandAddEnvString(cmd, "TERM=linux");
208
    virCommandAddEnvString(cmd, "container=lxc-libvirt");
209
    virCommandAddEnvPair(cmd, "container_uuid", uuidstr);
210 211
    virCommandAddEnvPair(cmd, "LIBVIRT_LXC_UUID", uuidstr);
    virCommandAddEnvPair(cmd, "LIBVIRT_LXC_NAME", vmDef->name);
212 213
    if (vmDef->os.cmdline)
        virCommandAddEnvPair(cmd, "LIBVIRT_LXC_CMDLINE", vmDef->os.cmdline);
214

215
    return cmd;
216 217 218
}

/**
219
 * lxcContainerSetStdio:
220 221
 * @control: control FD from parent
 * @ttyfd: FD of tty to set as the container console
222 223 224 225 226 227
 *
 * Sets the given tty as the primary conosole for the container as well as
 * stdout, stdin and stderr.
 *
 * Returns 0 on success or -1 in case of error
 */
228
static int lxcContainerSetStdio(int control, int ttyfd, int handshakefd)
229 230
{
    int rc = -1;
231
    int open_max, i;
232 233

    if (setsid() < 0) {
234
        virReportSystemError(errno, "%s",
235
                             _("setsid failed"));
236
        goto cleanup;
237 238 239
    }

    if (ioctl(ttyfd, TIOCSCTTY, NULL) < 0) {
240
        virReportSystemError(errno, "%s",
241
                             _("ioctl(TIOCSTTY) failed"));
242 243 244
        goto cleanup;
    }

245 246
    /* Just in case someone forget to set FD_CLOEXEC, explicitly
     * close all FDs before executing the container */
247
    open_max = sysconf(_SC_OPEN_MAX);
248
    for (i = 0; i < open_max; i++)
249
        if (i != ttyfd && i != control && i != handshakefd) {
250
            int tmpfd = i;
251
            VIR_MASS_CLOSE(tmpfd);
252
        }
253 254

    if (dup2(ttyfd, 0) < 0) {
255
        virReportSystemError(errno, "%s",
256
                             _("dup2(stdin) failed"));
257 258 259 260
        goto cleanup;
    }

    if (dup2(ttyfd, 1) < 0) {
261
        virReportSystemError(errno, "%s",
262
                             _("dup2(stdout) failed"));
263 264 265 266
        goto cleanup;
    }

    if (dup2(ttyfd, 2) < 0) {
267
        virReportSystemError(errno, "%s",
268
                             _("dup2(stderr) failed"));
269 270 271 272 273 274
        goto cleanup;
    }

    rc = 0;

cleanup:
275
    VIR_DEBUG("rc=%d", rc);
276 277 278 279
    return rc;
}

/**
280
 * lxcContainerSendContinue:
281
 * @control: control FD to child
282
 *
283 284
 * Sends the continue message via the socket pair stored in the vm
 * structure.
285 286 287
 *
 * Returns 0 on success or -1 in case of error
 */
288
int lxcContainerSendContinue(int control)
289 290
{
    int rc = -1;
291 292
    lxc_message_t msg = LXC_CONTINUE_MSG;
    int writeCount = 0;
293

294 295 296
    writeCount = safewrite(control, &msg, sizeof(msg));
    if (writeCount != sizeof(msg)) {
        goto error_out;
297 298
    }

299 300 301
    rc = 0;
error_out:
    return rc;
302 303
}

304
/**
305
 * lxcContainerWaitForContinue:
306
 * @control: Control FD from parent
307 308 309 310 311 312 313
 *
 * This function will wait for the container continue message from the
 * parent process.  It will send this message on the socket pair stored in
 * the vm structure once it has completed the post clone container setup.
 *
 * Returns 0 on success or -1 in case of error
 */
314
int lxcContainerWaitForContinue(int control)
315 316 317 318
{
    lxc_message_t msg;
    int readLen;

319
    readLen = saferead(control, &msg, sizeof(msg));
320 321 322 323 324 325 326
    if (readLen != sizeof(msg)) {
        if (readLen >= 0)
            errno = EIO;
        return -1;
    }
    if (msg != LXC_CONTINUE_MSG) {
        errno = EINVAL;
327
        return -1;
328 329
    }

330
    return 0;
331 332
}

333

334
/**
335
 * lxcContainerRenameAndEnableInterfaces:
336 337
 * @nveths: number of interfaces
 * @veths: interface names
338
 *
339 340 341
 * This function will rename the interfaces to ethN
 * with id ascending order from zero and enable the
 * renamed interfaces for this container.
342 343 344
 *
 * Returns 0 on success or nonzero in case of error
 */
345
static int lxcContainerRenameAndEnableInterfaces(bool privNet,
346
                                                 size_t nveths,
347
                                                 char **veths)
348 349
{
    int rc = 0;
350
    size_t i;
351
    char *newname = NULL;
352

353
    for (i = 0 ; i < nveths ; i++) {
354
        if (virAsprintf(&newname, "eth%zu", i) < 0) {
355 356
            virReportOOMError();
            rc = -1;
357
            goto error_out;
358
        }
359

360
        VIR_DEBUG("Renaming %s to %s", veths[i], newname);
361
        rc = virNetDevSetName(veths[i], newname);
362
        if (rc < 0)
363 364
            goto error_out;

365
        VIR_DEBUG("Enabling %s", newname);
366
        rc = virNetDevSetOnline(newname, true);
367
        if (rc < 0)
368
            goto error_out;
369

370
        VIR_FREE(newname);
371 372 373
    }

    /* enable lo device only if there were other net devices */
374
    if (veths || privNet)
375
        rc = virNetDevSetOnline("lo", true);
376 377

error_out:
378
    VIR_FREE(newname);
379 380 381
    return rc;
}

382

383
/*_syscall2(int, pivot_root, char *, newroot, const char *, oldroot)*/
384 385 386 387 388 389 390
extern int pivot_root(const char * new_root,const char * put_old);

static int lxcContainerChildMountSort(const void *a, const void *b)
{
  const char **sa = (const char**)a;
  const char **sb = (const char**)b;

E
Eric Blake 已提交
391
  /* Deliberately reversed args - we need to unmount deepest
392 393 394 395
     children first */
  return strcmp(*sb, *sa);
}

396
#ifndef MS_REC
397
# define MS_REC          16384
398 399 400
#endif

#ifndef MNT_DETACH
401
# define MNT_DETACH      0x00000002
402 403 404
#endif

#ifndef MS_PRIVATE
405
# define MS_PRIVATE              (1<<18)
406 407 408
#endif

#ifndef MS_SLAVE
409
# define MS_SLAVE                (1<<19)
410 411
#endif

412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456
static int lxcContainerPrepareRoot(virDomainDefPtr def,
                                   virDomainFSDefPtr root)
{
    char *dst;
    char *tmp;

    if (root->type == VIR_DOMAIN_FS_TYPE_MOUNT)
        return 0;

    if (root->type == VIR_DOMAIN_FS_TYPE_FILE) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("Unexpected root filesystem without loop device"));
        return -1;
    }

    if (root->type != VIR_DOMAIN_FS_TYPE_BLOCK) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Unsupported root filesystem type %s"),
                       virDomainFSTypeToString(root->type));
        return -1;
    }

    if (virAsprintf(&dst, "%s/%s.root",
                    LXC_STATE_DIR, def->name) < 0) {
        virReportOOMError();
        return -1;
    }

    tmp = root->dst;
    root->dst = dst;

    if (lxcContainerMountFSBlock(root, "") < 0) {
        root->dst = tmp;
        VIR_FREE(dst);
        return -1;
    }

    root->dst = tmp;
    root->type = VIR_DOMAIN_FS_TYPE_MOUNT;
    VIR_FREE(root->src);
    root->src = dst;

    return 0;
}

457 458
static int lxcContainerPivotRoot(virDomainFSDefPtr root)
{
459
    int ret;
460
    char *oldroot = NULL, *newroot = NULL;
461

M
Mark McLoughlin 已提交
462 463
    ret = -1;

464 465
    VIR_DEBUG("Pivot via %s", root->src);

466 467
    /* root->parent must be private, so make / private. */
    if (mount("", "/", NULL, MS_PRIVATE|MS_REC, NULL) < 0) {
468
        virReportSystemError(errno, "%s",
469
                             _("Failed to make root private"));
470
        goto err;
471 472
    }

473
    if (virAsprintf(&oldroot, "%s/.oldroot", root->src) < 0) {
474
        virReportOOMError();
475
        goto err;
476 477
    }

478 479
    if (virFileMakePath(oldroot) < 0) {
        virReportSystemError(errno,
480
                             _("Failed to create %s"),
481
                             oldroot);
482 483 484 485 486
        goto err;
    }

    /* Create a tmpfs root since old and new roots must be
     * on separate filesystems */
487
    if (mount("tmprootfs", oldroot, "tmpfs", 0, NULL) < 0) {
488
        virReportSystemError(errno,
489
                             _("Failed to mount empty tmpfs at %s"),
490 491 492
                             oldroot);
        goto err;
    }
M
Mark McLoughlin 已提交
493

494 495
    /* Create a directory called 'new' in tmpfs */
    if (virAsprintf(&newroot, "%s/new", oldroot) < 0) {
496
        virReportOOMError();
497 498 499
        goto err;
    }

500 501
    if (virFileMakePath(newroot) < 0) {
        virReportSystemError(errno,
502
                             _("Failed to create %s"),
503 504 505 506 507 508
                             newroot);
        goto err;
    }

    /* ... and mount our root onto it */
    if (mount(root->src, newroot, NULL, MS_BIND|MS_REC, NULL) < 0) {
509
        virReportSystemError(errno,
510
                             _("Failed to bind new root %s into tmpfs"),
511 512 513 514
                             root->src);
        goto err;
    }

515 516 517 518 519 520 521 522 523
    if (root->readonly) {
        if (mount(root->src, newroot, NULL, MS_BIND|MS_REC|MS_RDONLY|MS_REMOUNT, NULL) < 0) {
            virReportSystemError(errno,
                                 _("Failed to make new root %s readonly"),
                                 root->src);
            goto err;
        }
    }

524 525
    /* Now we chroot into the tmpfs, then pivot into the
     * root->src bind-mounted onto '/new' */
526
    if (chdir(newroot) < 0) {
527
        virReportSystemError(errno,
528
                             _("Failed to chroot into %s"), newroot);
529
        goto err;
530 531 532 533
    }

    /* The old root directory will live at /.oldroot after
     * this and will soon be unmounted completely */
534
    if (pivot_root(".", ".oldroot") < 0) {
535
        virReportSystemError(errno, "%s",
536
                             _("Failed to pivot root"));
537
        goto err;
538 539 540
    }

    /* CWD is undefined after pivot_root, so go to / */
541 542 543
    if (chdir("/") < 0)
        goto err;

M
Mark McLoughlin 已提交
544 545 546
    ret = 0;

err:
547 548 549
    VIR_FREE(oldroot);
    VIR_FREE(newroot);

M
Mark McLoughlin 已提交
550
    return ret;
551 552
}

553

554 555
static int lxcContainerMountBasicFS(bool pivotRoot,
                                    char *sec_mount_options)
556 557
{
    const struct {
558 559 560
        const char *src;
        const char *dst;
        const char *type;
561 562
        const char *opts;
        int mflags;
563
    } mnts[] = {
564
        /* When we want to make a bind mount readonly, for unknown reasons,
565
         * it is currently necessary to bind it once, and then remount the
566
         * bind with the readonly flag. If this is not done, then the original
567
         * mount point in the main OS becomes readonly too which is not what
568 569
         * we want. Hence some things have two entries here.
         */
570 571 572 573 574
        { "proc", "/proc", "proc", NULL, MS_NOSUID|MS_NOEXEC|MS_NODEV },
        { "/proc/sys", "/proc/sys", NULL, NULL, MS_BIND },
        { "/proc/sys", "/proc/sys", NULL, NULL, MS_BIND|MS_REMOUNT|MS_RDONLY },
        { "sysfs", "/sys", "sysfs", NULL, MS_NOSUID|MS_NOEXEC|MS_NODEV },
        { "sysfs", "/sys", "sysfs", NULL, MS_BIND|MS_REMOUNT|MS_RDONLY },
575
#if WITH_SELINUX
576 577
        { SELINUX_MOUNT, SELINUX_MOUNT, "selinuxfs", NULL, MS_NOSUID|MS_NOEXEC|MS_NODEV },
        { SELINUX_MOUNT, SELINUX_MOUNT, NULL, NULL, MS_BIND|MS_REMOUNT|MS_RDONLY },
578
#endif
579
    };
580
    int i, rc = -1;
581
    char *opts = NULL;
582

583
    VIR_DEBUG("Mounting basic filesystems pivotRoot=%d", pivotRoot);
584

585
    for (i = 0 ; i < ARRAY_CARDINALITY(mnts) ; i++) {
586
        const char *srcpath = NULL;
587

588 589
        VIR_DEBUG("Processing %s -> %s",
                  mnts[i].src, mnts[i].dst);
590

591
        srcpath = mnts[i].src;
592 593 594

        /* Skip if mount doesn't exist in source */
        if ((srcpath[0] == '/') &&
595
            (access(srcpath, R_OK) < 0))
596 597
            continue;

598 599 600 601 602 603 604
        if (virFileMakePath(mnts[i].dst) < 0) {
            virReportSystemError(errno,
                                 _("Failed to mkdir %s"),
                                 mnts[i].src);
            goto cleanup;
        }

605 606
        VIR_DEBUG("Mount %s on %s type=%s flags=%x, opts=%s",
                  srcpath, mnts[i].dst, mnts[i].type, mnts[i].mflags, mnts[i].opts);
607
        if (mount(srcpath, mnts[i].dst, mnts[i].type, mnts[i].mflags, mnts[i].opts) < 0) {
608
            virReportSystemError(errno,
609 610 611
                                 _("Failed to mount %s on %s type %s flags=%x opts=%s"),
                                 srcpath, mnts[i].dst, NULLSTR(mnts[i].type),
                                 mnts[i].mflags, NULLSTR(mnts[i].opts));
612
            goto cleanup;
613
        }
614 615
    }

616 617 618 619 620
    if (pivotRoot) {
        /*
         * tmpfs is limited to 64kb, since we only have device nodes in there
         * and don't want to DOS the entire OS RAM usage
         */
621

622
        ignore_value(virAsprintf(&opts,
623
                                 "mode=755,size=65536%s", sec_mount_options));
624
        if (!opts) {
625 626 627 628 629 630 631 632
            virReportOOMError();
            goto cleanup;
        }

        VIR_DEBUG("Mount devfs on /dev type=tmpfs flags=%x, opts=%s",
                  MS_NOSUID, opts);
        if (mount("devfs", "/dev", "tmpfs", MS_NOSUID, opts) < 0) {
            virReportSystemError(errno,
633 634
                                 _("Failed to mount %s on %s type %s (%s)"),
                                 "devfs", "/dev", "tmpfs", opts);
635 636 637 638
            goto cleanup;
        }
    }

639 640 641 642
    rc = 0;

cleanup:
    VIR_DEBUG("rc=%d", rc);
643
    VIR_FREE(opts);
644 645 646
    return rc;
}

647
#if WITH_FUSE
648 649 650 651 652 653 654
static int lxcContainerMountProcFuse(virDomainDefPtr def,
                                     const char *srcprefix)
{
    int ret;
    char *meminfo_path = NULL;

    if ((ret = virAsprintf(&meminfo_path,
655
                           "%s/%s/%s.fuse/meminfo",
656
                           srcprefix ? srcprefix : "", LXC_STATE_DIR,
657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676
                           def->name)) < 0)
        return ret;

    if ((ret = mount(meminfo_path, "/proc/meminfo",
                     NULL, MS_BIND, NULL)) < 0) {
        virReportSystemError(errno,
                             _("Failed to mount %s on /proc/meminfo"),
                             meminfo_path);
    }

    VIR_FREE(meminfo_path);
    return ret;
}
#else
static int lxcContainerMountProcFuse(virDomainDefPtr def ATTRIBUTE_UNUSED,
                                     const char *srcprefix ATTRIBUTE_UNUSED)
{
    return 0;
}
#endif
677

678 679
static int lxcContainerMountFSDevPTS(virDomainDefPtr def,
                                     const char *srcprefix)
680
{
681 682
    int ret;
    char *path = NULL;
683

684 685 686 687 688
    if ((ret = virAsprintf(&path,
                           "%s/%s/%s.devpts",
                           srcprefix ? srcprefix : "", LXC_STATE_DIR,
                           def->name)) < 0)
        return ret;
689

690 691
    if (virFileMakePath("/dev/pts") < 0) {
        virReportSystemError(errno, "%s",
692
                             _("Cannot create /dev/pts"));
693
        goto cleanup;
694
    }
695

696 697 698 699 700 701 702
    VIR_DEBUG("Trying to move %s to /dev/pts", path);

    if ((ret = mount(path, "/dev/pts",
                     NULL, MS_MOVE, NULL)) < 0) {
        virReportSystemError(errno,
                             _("Failed to mount %s on /dev/pts"),
                             path);
703
        goto cleanup;
704
    }
705

706 707
cleanup:
    VIR_FREE(path);
708

709
    return ret;
710 711
}

712
static int lxcContainerPopulateDevices(char **ttyPaths, size_t nttyPaths)
713
{
714
    size_t i;
715 716 717 718 719 720 721 722 723 724 725 726
    const struct {
        int maj;
        int min;
        mode_t mode;
        const char *path;
    } devs[] = {
        { LXC_DEV_MAJ_MEMORY, LXC_DEV_MIN_NULL, 0666, "/dev/null" },
        { LXC_DEV_MAJ_MEMORY, LXC_DEV_MIN_ZERO, 0666, "/dev/zero" },
        { LXC_DEV_MAJ_MEMORY, LXC_DEV_MIN_FULL, 0666, "/dev/full" },
        { LXC_DEV_MAJ_MEMORY, LXC_DEV_MIN_RANDOM, 0666, "/dev/random" },
        { LXC_DEV_MAJ_MEMORY, LXC_DEV_MIN_URANDOM, 0666, "/dev/urandom" },
    };
727 728 729 730 731 732 733 734 735
    const struct {
        const char *src;
        const char *dst;
    } links[] = {
        { "/proc/self/fd/0", "/dev/stdin" },
        { "/proc/self/fd/1", "/dev/stdout" },
        { "/proc/self/fd/2", "/dev/stderr" },
        { "/proc/self/fd", "/dev/fd" },
    };
736 737 738 739

    /* Populate /dev/ with a few important bits */
    for (i = 0 ; i < ARRAY_CARDINALITY(devs) ; i++) {
        dev_t dev = makedev(devs[i].maj, devs[i].min);
740
        if (mknod(devs[i].path, S_IFCHR, dev) < 0 ||
741
            chmod(devs[i].path, devs[i].mode)) {
742
            virReportSystemError(errno,
743
                                 _("Failed to make device %s"),
744
                                 devs[i].path);
745 746 747 748
            return -1;
        }
    }

749 750 751 752 753 754 755 756 757
    for (i = 0 ; i < ARRAY_CARDINALITY(links) ; i++) {
        if (symlink(links[i].src, links[i].dst) < 0) {
            virReportSystemError(errno,
                                 _("Failed to symlink device %s to %s"),
                                 links[i].dst, links[i].src);
            return -1;
        }
    }

758
    if (access("/dev/pts/ptmx", W_OK) == 0) {
759 760 761 762
        /* We have private devpts capability, so bind that */
        if (virFileTouch("/dev/ptmx", 0666) < 0)
            return -1;

S
Serge Hallyn 已提交
763
        if (mount("/dev/pts/ptmx", "/dev/ptmx", "ptmx", MS_BIND, NULL) < 0) {
764
            virReportSystemError(errno, "%s",
765 766 767 768 769 770 771 772 773 774
                                 _("Failed to bind /dev/pts/ptmx on to /dev/ptmx"));
            return -1;
        }
    } else {
        /* Legacy devpts, so we need to just use shared one */
        dev_t dev = makedev(LXC_DEV_MAJ_TTY, LXC_DEV_MIN_PTMX);
        if (mknod("/dev/ptmx", S_IFCHR, dev) < 0 ||
            chmod("/dev/ptmx", 0666)) {
            virReportSystemError(errno, "%s",
                                 _("Failed to make device /dev/ptmx"));
775 776 777 778
            return -1;
        }
    }

779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799
    for (i = 0 ; i < nttyPaths ; i++) {
        char *tty;
        if (virAsprintf(&tty, "/dev/tty%zu", i+1) < 0) {
            virReportOOMError();
            return -1;
        }
        if (symlink(ttyPaths[i], tty) < 0) {
            VIR_FREE(tty);
            virReportSystemError(errno,
                                 _("Failed to symlink %s to %s"),
                                 ttyPaths[i], tty);
            return -1;
        }
        VIR_FREE(tty);
        if (i == 0 &&
            symlink(ttyPaths[i], "/dev/console") < 0) {
            virReportSystemError(errno,
                                 _("Failed to symlink %s to /dev/console"),
                                 ttyPaths[i]);
            return -1;
        }
800
    }
801 802 803 804
    return 0;
}


805 806
static int lxcContainerMountFSBind(virDomainFSDefPtr fs,
                                   const char *srcprefix)
807
{
808 809
    char *src = NULL;
    int ret = -1;
810
    struct stat st;
811 812 813 814 815 816

    if (virAsprintf(&src, "%s%s", srcprefix, fs->src) < 0) {
        virReportOOMError();
        goto cleanup;
    }

817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853
    if (stat(fs->dst, &st) < 0) {
        if (errno != ENOENT) {
            virReportSystemError(errno, _("Unable to stat bind target %s"),
                                 fs->dst);
            goto cleanup;
        }
        /* ENOENT => create the target dir or file */
        if (stat(src, &st) < 0) {
            virReportSystemError(errno, _("Unable to stat bind source %s"),
                                 src);
            goto cleanup;
        }
        if (S_ISDIR(st.st_mode)) {
            if (virFileMakePath(fs->dst) < 0) {
                virReportSystemError(errno,
                                     _("Failed to create %s"),
                                     fs->dst);
                goto cleanup;
            }
        } else {
            /* Create Empty file for target mount point */
            int fd = open(fs->dst, O_WRONLY|O_CREAT|O_NOCTTY|O_NONBLOCK, 0666);
            if (fd < 0) {
                if (errno != EEXIST) {
                    virReportSystemError(errno,
                                         _("Failed to create bind target %s"),
                                         fs->dst);
                    goto cleanup;
                }
            }
            if (VIR_CLOSE(fd) < 0) {
                virReportSystemError(errno,
                                     _("Failed to close bind target %s"),
                                     fs->dst);
                goto cleanup;
            }
        }
854 855 856 857 858 859 860 861 862
    }

    if (mount(src, fs->dst, NULL, MS_BIND, NULL) < 0) {
        virReportSystemError(errno,
                             _("Failed to bind mount directory %s to %s"),
                             src, fs->dst);
        goto cleanup;
    }

863 864
    if (fs->readonly) {
        VIR_DEBUG("Binding %s readonly", fs->dst);
865
        if (mount(src, fs->dst, NULL, MS_BIND|MS_REMOUNT|MS_RDONLY, NULL) < 0) {
866 867 868
            virReportSystemError(errno,
                                 _("Failed to make directory %s readonly"),
                                 fs->dst);
869 870 871 872 873 874 875 876 877 878 879
        }
    }

    ret = 0;

cleanup:
    VIR_FREE(src);
    return ret;
}


880
#ifdef WITH_BLKID
881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950
static int
lxcContainerMountDetectFilesystem(const char *src, char **type)
{
    int fd;
    int ret = -1;
    int rc;
    const char *data = NULL;
    blkid_probe blkid = NULL;

    *type = NULL;

    if ((fd = open(src, O_RDONLY)) < 0) {
        virReportSystemError(errno,
                             _("Unable to open filesystem %s"), src);
        return -1;
    }

    if (!(blkid = blkid_new_probe())) {
        virReportSystemError(errno, "%s",
                             _("Unable to create blkid library handle"));
        goto cleanup;
    }
    if (blkid_probe_set_device(blkid, fd, 0, 0) < 0) {
        virReportSystemError(EINVAL,
                             _("Unable to associate device %s with blkid library"),
                             src);
        goto cleanup;
    }

    blkid_probe_enable_superblocks(blkid, 1);

    blkid_probe_set_superblocks_flags(blkid, BLKID_SUBLKS_TYPE);

    rc = blkid_do_safeprobe(blkid);
    if (rc != 0) {
        if (rc == 1) /* Nothing found, return success with *type == NULL */
            goto done;

        if (rc == -2) {
            virReportSystemError(EINVAL,
                                 _("Too many filesystems detected for %s"),
                                 src);
        } else {
            virReportSystemError(errno,
                                 _("Unable to detect filesystem for %s"),
                                 src);
        }
        goto cleanup;
    }

    if (blkid_probe_lookup_value(blkid, "TYPE", &data, NULL) < 0) {
        virReportSystemError(ENOENT,
                             _("Unable to find filesystem type for %s"),
                             src);
        goto cleanup;
    }

    if (!(*type = strdup(data))) {
        virReportOOMError();
        goto cleanup;
    }

done:
    ret = 0;
cleanup:
    VIR_FORCE_CLOSE(fd);
    if (blkid)
        blkid_free_probe(blkid);
    return ret;
}
951
#else /* ! WITH_BLKID */
952 953 954 955 956 957 958 959
static int
lxcContainerMountDetectFilesystem(const char *src ATTRIBUTE_UNUSED,
                                  char **type)
{
    /* No libblkid, so just return success with no detected type */
    *type = NULL;
    return 0;
}
960
#endif /* ! WITH_BLKID */
961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017

/*
 * This functions attempts to do automatic detection of filesystem
 * type following the same rules as the util-linux 'mount' binary.
 *
 * The main difference is that we don't (currently) try to use
 * libblkid to detect the format first. We go straight to using
 * /etc/filesystems, and then /proc/filesystems
 */
static int lxcContainerMountFSBlockAuto(virDomainFSDefPtr fs,
                                        int fsflags,
                                        const char *src,
                                        const char *srcprefix)
{
    FILE *fp = NULL;
    int ret = -1;
    bool tryProc = false;
    bool gotStar = false;
    char *fslist = NULL;
    char *line = NULL;
    const char *type;

    VIR_DEBUG("src=%s srcprefix=%s dst=%s", src, srcprefix, fs->dst);

    /* First time around we use /etc/filesystems */
retry:
    if (virAsprintf(&fslist, "%s%s",
                    srcprefix, tryProc ? "/proc/filesystems" : "/etc/filesystems") < 0) {
        virReportOOMError();
        goto cleanup;
    }

    VIR_DEBUG("Open fslist %s", fslist);
    if (!(fp = fopen(fslist, "r"))) {
        /* If /etc/filesystems does not exist, then we need to retry
         * with /proc/filesystems next
         */
        if (errno == ENOENT &&
            !tryProc) {
            tryProc = true;
            VIR_FREE(fslist);
            goto retry;
        }

        virReportSystemError(errno,
                             _("Unable to read %s"),
                             fslist);
        goto cleanup;
    }

    while (!feof(fp)) {
        size_t n;
        VIR_FREE(line);
        if (getline(&line, &n, fp) <= 0) {
            if (feof(fp))
                break;

1018 1019 1020
            goto cleanup;
        }

1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033
        if (strstr(line, "nodev"))
            continue;

        type = strchr(line, '\n');
        if (type)
            line[type-line] = '\0';

        type = line;
        virSkipSpaces(&type);

        /*
         * /etc/filesystems is only allowed to contain '*' on the last line
         */
1034
        if (gotStar && !tryProc) {
1035 1036 1037
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("%s has unexpected '*' before last line"),
                           fslist);
1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058
            goto cleanup;
        }

        /* An '*' on the last line in /etc/filesystems
         * means try /proc/filesystems next. We don't
         * jump immediately though, since we need to see
         * if any more lines follow
         */
        if (!tryProc &&
            STREQ(type, "*"))
            gotStar = true;

        VIR_DEBUG("Trying mount %s with %s", src, type);
        if (mount(src, fs->dst, type, fsflags, NULL) < 0) {
            /* These errnos indicate a bogus filesystem type for
             * the image we have, so skip to the next type
             */
            if (errno == EINVAL || errno == ENODEV)
                continue;

            virReportSystemError(errno,
1059
                                 _("Failed to mount device %s to %s"),
1060 1061 1062 1063 1064 1065
                                 src, fs->dst);
            goto cleanup;
        }

        ret = 0;
        break;
1066 1067
    }

1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079
    /* We've got to the end of /etc/filesystems and saw
     * a '*', so we must try /proc/filesystems next
     */
    if (ret != 0 &&
        !tryProc &&
        gotStar) {
        tryProc = true;
        VIR_FREE(fslist);
        VIR_FORCE_FCLOSE(fp);
        goto retry;
    }

1080 1081 1082 1083 1084 1085
    if (ret != 0) {
        virReportSystemError(ENODEV,
                             _("Failed to mount device %s to %s, unable to detect filesystem"),
                             src, fs->dst);
    }

1086 1087 1088 1089
    VIR_DEBUG("Done mounting filesystem ret=%d tryProc=%d", ret, tryProc);

cleanup:
    VIR_FREE(line);
1090
    VIR_FREE(fslist);
1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105
    VIR_FORCE_FCLOSE(fp);
    return ret;
}


/*
 * Mount a block device 'src' on fs->dst, automatically
 * probing for filesystem type
 */
static int lxcContainerMountFSBlockHelper(virDomainFSDefPtr fs,
                                          const char *src,
                                          const char *srcprefix)
{
    int fsflags = 0;
    int ret = -1;
1106 1107
    char *format = NULL;

1108 1109 1110 1111 1112 1113 1114 1115 1116 1117
    if (fs->readonly)
        fsflags |= MS_RDONLY;

    if (virFileMakePath(fs->dst) < 0) {
        virReportSystemError(errno,
                             _("Failed to create %s"),
                             fs->dst);
        goto cleanup;
    }

1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132
    if (lxcContainerMountDetectFilesystem(src, &format) < 0)
        goto cleanup;

    if (format) {
        VIR_DEBUG("Mount %s with detected format %s", src, format);
        if (mount(src, fs->dst, format, fsflags, NULL) < 0) {
            virReportSystemError(errno,
                                 _("Failed to mount device %s to %s as %s"),
                                 src, fs->dst, format);
            goto cleanup;
        }
        ret = 0;
    } else {
        ret = lxcContainerMountFSBlockAuto(fs, fsflags, src, srcprefix);
    }
1133 1134

cleanup:
1135
    VIR_FREE(format);
1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151
    return ret;
}


static int lxcContainerMountFSBlock(virDomainFSDefPtr fs,
                                    const char *srcprefix)
{
    char *src = NULL;
    int ret = -1;

    if (virAsprintf(&src, "%s%s", srcprefix, fs->src) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    ret = lxcContainerMountFSBlockHelper(fs, src, srcprefix);
1152 1153 1154 1155 1156 1157 1158 1159 1160

    VIR_DEBUG("Done mounting filesystem ret=%d", ret);

cleanup:
    VIR_FREE(src);
    return ret;
}


1161 1162
static int lxcContainerMountFSTmpfs(virDomainFSDefPtr fs,
                                    char *sec_mount_options)
1163 1164 1165 1166
{
    int ret = -1;
    char *data = NULL;

1167
    if (virAsprintf(&data,
1168
                    "size=%lldk%s", fs->usage, sec_mount_options) < 0) {
1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203
        virReportOOMError();
        goto cleanup;
    }

    if (virFileMakePath(fs->dst) < 0) {
        virReportSystemError(errno,
                             _("Failed to create %s"),
                             fs->dst);
        goto cleanup;
    }

    if (mount("tmpfs", fs->dst, "tmpfs", MS_NOSUID|MS_NODEV, data) < 0) {
        virReportSystemError(errno,
                             _("Failed to mount directory %s as tmpfs"),
                             fs->dst);
        goto cleanup;
    }

    if (fs->readonly) {
        VIR_DEBUG("Binding %s readonly", fs->dst);
        if (mount(fs->dst, fs->dst, NULL, MS_BIND|MS_REMOUNT|MS_RDONLY, NULL) < 0) {
            virReportSystemError(errno,
                                 _("Failed to make directory %s readonly"),
                                 fs->dst);
        }
    }

    ret = 0;

cleanup:
    VIR_FREE(data);
    return ret;
}


1204
static int lxcContainerMountFS(virDomainFSDefPtr fs,
1205 1206
                               const char *srcprefix,
                               char *sec_mount_options)
1207 1208 1209 1210 1211 1212
{
    switch (fs->type) {
    case VIR_DOMAIN_FS_TYPE_MOUNT:
        if (lxcContainerMountFSBind(fs, srcprefix) < 0)
            return -1;
        break;
1213 1214 1215 1216
    case VIR_DOMAIN_FS_TYPE_BLOCK:
        if (lxcContainerMountFSBlock(fs, srcprefix) < 0)
            return -1;
        break;
1217
    case VIR_DOMAIN_FS_TYPE_RAM:
1218
        if (lxcContainerMountFSTmpfs(fs, sec_mount_options) < 0)
1219 1220
            return -1;
        break;
1221 1222 1223 1224
    case VIR_DOMAIN_FS_TYPE_BIND:
        if (lxcContainerMountFSBind(fs, "") < 0)
            return -1;
        break;
1225
    case VIR_DOMAIN_FS_TYPE_FILE:
1226 1227 1228
        /* We do actually support this, but the lxc controller
         * should have associated the file with a loopback
         * device and changed this to TYPE_BLOCK for us */
1229 1230 1231
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Unexpected filesystem type %s"),
                       virDomainFSTypeToString(fs->type));
1232
        break;
1233
    default:
1234 1235 1236
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Cannot mount filesystem type %s"),
                       virDomainFSTypeToString(fs->type));
1237 1238 1239 1240 1241 1242 1243 1244
        break;
    }
    return 0;
}


static int lxcContainerMountAllFS(virDomainDefPtr vmDef,
                                  const char *dstprefix,
1245 1246
                                  bool skipRoot,
                                  char *sec_mount_options)
1247 1248 1249
{
    size_t i;
    VIR_DEBUG("Mounting %s %d", dstprefix, skipRoot);
1250 1251

    /* Pull in rest of container's mounts */
1252
    for (i = 0 ; i < vmDef->nfss ; i++) {
1253 1254
        if (skipRoot &&
            STREQ(vmDef->fss[i]->dst, "/"))
1255 1256
            continue;

1257
        if (lxcContainerMountFS(vmDef->fss[i], dstprefix, sec_mount_options) < 0)
1258 1259 1260
            return -1;
    }

1261
    VIR_DEBUG("Mounted all filesystems");
1262 1263 1264 1265
    return 0;
}


1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365
static int lxcContainerSetupDisk(virDomainDefPtr vmDef,
                                 virDomainDiskDefPtr def,
                                 const char *dstprefix,
                                 virSecurityManagerPtr securityDriver)
{
    char *src = NULL;
    char *dst = NULL;
    int ret = -1;
    struct stat sb;
    mode_t mode;
    char *tmpsrc = def->src;

    if (def->type != VIR_DOMAIN_DISK_TYPE_BLOCK) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("Can't setup disk for non-block device"));
        goto cleanup;
    }
    if (def->src == NULL) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("Can't setup disk without media"));
        goto cleanup;
    }

    if (virAsprintf(&src, "%s/%s", dstprefix, def->src) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (virAsprintf(&dst, "/dev/%s", def->dst) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (stat(src, &sb) < 0) {
        virReportSystemError(errno,
                             _("Unable to access %s"), def->src);
        goto cleanup;
    }

    if (!S_ISCHR(sb.st_mode) && !S_ISBLK(sb.st_mode)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Disk source %s must be a character/block device"),
                       def->src);
        goto cleanup;
    }

    mode = 0700;
    if (S_ISCHR(sb.st_mode))
        mode |= S_IFCHR;
    else
        mode |= S_IFBLK;

    /* Yes, the device name we're creating may not
     * actually correspond to the major:minor number
     * we're using, but we've no other option at this
     * time. Just have to hope that containerized apps
     * don't get upset that the major:minor is different
     * to that normally implied by the device name
     */
    VIR_DEBUG("Creating dev %s (%d,%d) from %s",
              dst, major(sb.st_rdev), minor(sb.st_rdev), src);
    if (mknod(dst, mode, sb.st_rdev) < 0) {
        virReportSystemError(errno,
                             _("Unable to create device %s"),
                             dst);
        goto cleanup;
    }
    /* Labelling normally operates on src, but we need
     * to actally label the dst here, so hack the config */
    def->src = dst;
    if (virSecurityManagerSetImageLabel(securityDriver, vmDef, def) < 0)
        goto cleanup;

    ret = 0;

cleanup:
    def->src = tmpsrc;
    VIR_FREE(src);
    VIR_FREE(dst);
    return ret;
}

static int lxcContainerSetupAllDisks(virDomainDefPtr vmDef,
                                     const char *dstprefix,
                                     virSecurityManagerPtr securityDriver)
{
    size_t i;
    VIR_DEBUG("Setting up disks %s", dstprefix);

    for (i = 0 ; i < vmDef->ndisks ; i++) {
        if (lxcContainerSetupDisk(vmDef, vmDef->disks[i],
                                  dstprefix, securityDriver) < 0)
            return -1;
    }

    VIR_DEBUG("Setup all disks");
    return 0;
}


1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438
static int lxcContainerSetupHostdevSubsysUSB(virDomainDefPtr vmDef ATTRIBUTE_UNUSED,
                                             virDomainHostdevDefPtr def ATTRIBUTE_UNUSED,
                                             const char *dstprefix ATTRIBUTE_UNUSED,
                                             virSecurityManagerPtr securityDriver ATTRIBUTE_UNUSED)
{
    int ret = -1;
    char *src = NULL;
    char *dstdir = NULL;
    char *dstfile = NULL;
    struct stat sb;
    mode_t mode;

    if (virAsprintf(&dstdir, USB_DEVFS "/%03d",
                    def->source.subsys.u.usb.bus) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (virAsprintf(&dstfile, "%s/%03d",
                    dstdir,
                    def->source.subsys.u.usb.device) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (virAsprintf(&src, "%s/%s", dstprefix, dstfile) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (stat(src, &sb) < 0) {
        virReportSystemError(errno,
                             _("Unable to access %s"), src);
        goto cleanup;
    }

    if (!S_ISCHR(sb.st_mode)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("USB source %s was not a character device"),
                       src);
        goto cleanup;
    }

    mode = 0700 | S_IFCHR;

    if (virFileMakePath(dstdir) < 0) {
        virReportSystemError(errno,
                             _("Unable to create %s"), dstdir);
        goto cleanup;
    }

    VIR_DEBUG("Creating dev %s (%d,%d)",
              dstfile, major(sb.st_rdev), minor(sb.st_rdev));
    if (mknod(dstfile, mode, sb.st_rdev) < 0) {
        virReportSystemError(errno,
                             _("Unable to create device %s"),
                             dstfile);
        goto cleanup;
    }

    if (virSecurityManagerSetHostdevLabel(securityDriver, vmDef, def, NULL) < 0)
        goto cleanup;

    ret = 0;

cleanup:
    VIR_FREE(src);
    VIR_FREE(dstfile);
    VIR_FREE(dstdir);
    return ret;
}


1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496
static int lxcContainerSetupHostdevCapsStorage(virDomainDefPtr vmDef ATTRIBUTE_UNUSED,
                                               virDomainHostdevDefPtr def ATTRIBUTE_UNUSED,
                                               const char *dstprefix ATTRIBUTE_UNUSED,
                                               virSecurityManagerPtr securityDriver ATTRIBUTE_UNUSED)
{
    char *src = NULL;
    int ret = -1;
    struct stat sb;
    mode_t mode;

    if (def->source.caps.u.storage.block == NULL) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("Missing storage host block path"));
        goto cleanup;
    }

    if (virAsprintf(&src, "%s/%s", dstprefix, def->source.caps.u.storage.block) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (stat(src, &sb) < 0) {
        virReportSystemError(errno,
                             _("Unable to access %s"),
                             src);
        goto cleanup;
    }

    if (!S_ISBLK(sb.st_mode)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Storage source %s must be a block device"),
                       def->source.caps.u.storage.block);
        goto cleanup;
    }

    mode = 0700 | S_IFBLK;

    VIR_DEBUG("Creating dev %s (%d,%d)",
              def->source.caps.u.storage.block,
              major(sb.st_rdev), minor(sb.st_rdev));
    if (mknod(def->source.caps.u.storage.block, mode, sb.st_rdev) < 0) {
        virReportSystemError(errno,
                             _("Unable to create device %s"),
                             def->source.caps.u.storage.block);
        goto cleanup;
    }

    if (virSecurityManagerSetHostdevLabel(securityDriver, vmDef, def, NULL) < 0)
        goto cleanup;

    ret = 0;

cleanup:
    VIR_FREE(src);
    return ret;
}


1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554
static int lxcContainerSetupHostdevCapsMisc(virDomainDefPtr vmDef ATTRIBUTE_UNUSED,
                                            virDomainHostdevDefPtr def ATTRIBUTE_UNUSED,
                                            const char *dstprefix ATTRIBUTE_UNUSED,
                                            virSecurityManagerPtr securityDriver ATTRIBUTE_UNUSED)
{
    char *src = NULL;
    int ret = -1;
    struct stat sb;
    mode_t mode;

    if (def->source.caps.u.misc.chardev == NULL) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED, "%s",
                       _("Missing storage host block path"));
        goto cleanup;
    }

    if (virAsprintf(&src, "%s/%s", dstprefix, def->source.caps.u.misc.chardev) < 0) {
        virReportOOMError();
        goto cleanup;
    }

    if (stat(src, &sb) < 0) {
        virReportSystemError(errno,
                             _("Unable to access %s"),
                             src);
        goto cleanup;
    }

    if (!S_ISCHR(sb.st_mode)) {
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Storage source %s must be a character device"),
                       def->source.caps.u.misc.chardev);
        goto cleanup;
    }

    mode = 0700 | S_IFCHR;

    VIR_DEBUG("Creating dev %s (%d,%d)",
              def->source.caps.u.misc.chardev,
              major(sb.st_rdev), minor(sb.st_rdev));
    if (mknod(def->source.caps.u.misc.chardev, mode, sb.st_rdev) < 0) {
        virReportSystemError(errno,
                             _("Unable to create device %s"),
                             def->source.caps.u.misc.chardev);
        goto cleanup;
    }

    if (virSecurityManagerSetHostdevLabel(securityDriver, vmDef, def, NULL) < 0)
        goto cleanup;

    ret = 0;

cleanup:
    VIR_FREE(src);
    return ret;
}


1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572
static int lxcContainerSetupHostdevSubsys(virDomainDefPtr vmDef,
                                          virDomainHostdevDefPtr def,
                                          const char *dstprefix,
                                          virSecurityManagerPtr securityDriver)
{
    switch (def->source.subsys.type) {
    case VIR_DOMAIN_HOSTDEV_SUBSYS_TYPE_USB:
        return lxcContainerSetupHostdevSubsysUSB(vmDef, def, dstprefix, securityDriver);

    default:
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Unsupported host device mode %s"),
                       virDomainHostdevSubsysTypeToString(def->source.subsys.type));
        return -1;
    }
}


1573 1574 1575 1576 1577 1578 1579 1580 1581
static int lxcContainerSetupHostdevCaps(virDomainDefPtr vmDef,
                                        virDomainHostdevDefPtr def,
                                        const char *dstprefix,
                                        virSecurityManagerPtr securityDriver)
{
    switch (def->source.subsys.type) {
    case VIR_DOMAIN_HOSTDEV_CAPS_TYPE_STORAGE:
        return lxcContainerSetupHostdevCapsStorage(vmDef, def, dstprefix, securityDriver);

1582 1583 1584
    case VIR_DOMAIN_HOSTDEV_CAPS_TYPE_MISC:
        return lxcContainerSetupHostdevCapsMisc(vmDef, def, dstprefix, securityDriver);

1585 1586 1587 1588 1589 1590 1591 1592 1593
    default:
        virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                       _("Unsupported host device mode %s"),
                       virDomainHostdevCapsTypeToString(def->source.subsys.type));
        return -1;
    }
}


1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607
static int lxcContainerSetupAllHostdevs(virDomainDefPtr vmDef,
                                        const char *dstprefix,
                                        virSecurityManagerPtr securityDriver)
{
    size_t i;
    VIR_DEBUG("Setting up hostdevs %s", dstprefix);

    for (i = 0 ; i < vmDef->nhostdevs ; i++) {
        virDomainHostdevDefPtr def = vmDef->hostdevs[i];
        switch (def->mode) {
        case VIR_DOMAIN_HOSTDEV_MODE_SUBSYS:
            if (lxcContainerSetupHostdevSubsys(vmDef, def, dstprefix, securityDriver) < 0)
                return -1;
            break;
1608 1609 1610 1611
        case VIR_DOMAIN_HOSTDEV_MODE_CAPABILITIES:
            if (lxcContainerSetupHostdevCaps(vmDef, def, dstprefix, securityDriver) < 0)
                return -1;
            break;
1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624
        default:
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("Unsupported host device mode %s"),
                           virDomainHostdevModeTypeToString(def->mode));
            return -1;
        }
    }

    VIR_DEBUG("Setup all hostdevs");
    return 0;
}


1625 1626 1627
static int lxcContainerGetSubtree(const char *prefix,
                                  char ***mountsret,
                                  size_t *nmountsret)
1628 1629
{
    FILE *procmnt;
1630
    struct mntent mntent;
1631
    char mntbuf[1024];
1632
    int ret = -1;
1633 1634 1635
    char **mounts = NULL;
    size_t nmounts = 0;

1636 1637
    VIR_DEBUG("prefix=%s", prefix);

1638 1639
    *mountsret = NULL;
    *nmountsret = 0;
1640 1641

    if (!(procmnt = setmntent("/proc/mounts", "r"))) {
1642
        virReportSystemError(errno, "%s",
1643
                             _("Failed to read /proc/mounts"));
1644 1645
        return -1;
    }
1646

1647
    while (getmntent_r(procmnt, &mntent, mntbuf, sizeof(mntbuf)) != NULL) {
1648
        VIR_DEBUG("Got %s", mntent.mnt_dir);
1649
        if (!STRPREFIX(mntent.mnt_dir, prefix))
1650 1651 1652
            continue;

        if (VIR_REALLOC_N(mounts, nmounts+1) < 0) {
1653
            virReportOOMError();
1654
            goto cleanup;
1655
        }
1656
        if (!(mounts[nmounts] = strdup(mntent.mnt_dir))) {
1657
            virReportOOMError();
1658
            goto cleanup;
1659
        }
E
Eric Blake 已提交
1660
        nmounts++;
1661
        VIR_DEBUG("Grabbed %s", mntent.mnt_dir);
1662 1663
    }

1664 1665 1666
    if (mounts)
        qsort(mounts, nmounts, sizeof(mounts[0]),
              lxcContainerChildMountSort);
1667

1668 1669
    ret = 0;
cleanup:
1670 1671
    *mountsret = mounts;
    *nmountsret = nmounts;
1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688
    endmntent(procmnt);
    return ret;
}

static int lxcContainerUnmountSubtree(const char *prefix,
                                      bool isOldRootFS)
{
    char **mounts = NULL;
    size_t nmounts = 0;
    size_t i;
    int saveErrno;
    const char *failedUmount = NULL;
    int ret = -1;

    VIR_DEBUG("Unmount subtreee from %s", prefix);

    if (lxcContainerGetSubtree(prefix, &mounts, &nmounts) < 0)
1689
        goto cleanup;
1690
    for (i = 0 ; i < nmounts ; i++) {
1691
        VIR_DEBUG("Umount %s", mounts[i]);
1692
        if (umount(mounts[i]) < 0) {
1693 1694 1695
            char ebuf[1024];
            failedUmount = mounts[i];
            saveErrno = errno;
1696
            VIR_WARN("Failed to unmount '%s', trying to detach subtree '%s': %s",
1697 1698 1699
                     failedUmount, mounts[nmounts-1],
                     virStrerror(errno, ebuf, sizeof(ebuf)));
            break;
1700 1701
        }
    }
1702 1703

    if (failedUmount) {
1704
        /* This detaches the subtree */
1705 1706
        if (umount2(mounts[nmounts-1], MNT_DETACH) < 0) {
            virReportSystemError(saveErrno,
1707
                                 _("Failed to unmount '%s' and could not detach subtree '%s'"),
1708 1709 1710 1711
                                 failedUmount, mounts[nmounts-1]);
            goto cleanup;
        }
        /* This unmounts the tmpfs on which the old root filesystem was hosted */
1712 1713
        if (isOldRootFS &&
            umount(mounts[nmounts-1]) < 0) {
1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725
            virReportSystemError(saveErrno,
                                 _("Failed to unmount '%s' and could not unmount old root '%s'"),
                                 failedUmount, mounts[nmounts-1]);
            goto cleanup;
        }
    }

    ret = 0;

cleanup:
    for (i = 0 ; i < nmounts ; i++)
        VIR_FREE(mounts[i]);
1726 1727
    VIR_FREE(mounts);

1728
    return ret;
1729 1730 1731
}


1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754
struct lxcContainerCGroup {
    const char *dir;
    const char *linkDest;
};


static void lxcContainerCGroupFree(struct lxcContainerCGroup *mounts,
                                   size_t nmounts)
{
    size_t i;

    if (!mounts)
        return;

    for (i = 0 ; i < nmounts ; i++) {
        VIR_FREE(mounts[i].dir);
        VIR_FREE(mounts[i].linkDest);
    }
    VIR_FREE(mounts);
}


static int lxcContainerIdentifyCGroups(struct lxcContainerCGroup **mountsret,
1755 1756
                                       size_t *nmountsret,
                                       char **root)
1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769
{
    FILE *procmnt = NULL;
    struct mntent mntent;
    struct dirent *dent;
    char mntbuf[1024];
    int ret = -1;
    struct lxcContainerCGroup *mounts = NULL;
    size_t nmounts = 0;
    DIR *dh = NULL;
    char *path = NULL;

    *mountsret = NULL;
    *nmountsret = 0;
1770
    *root = NULL;
1771

1772
    VIR_DEBUG("Finding cgroups mount points of type cgroup");
1773 1774 1775 1776 1777 1778 1779 1780 1781

    if (!(procmnt = setmntent("/proc/mounts", "r"))) {
        virReportSystemError(errno, "%s",
                             _("Failed to read /proc/mounts"));
        return -1;
    }

    while (getmntent_r(procmnt, &mntent, mntbuf, sizeof(mntbuf)) != NULL) {
        VIR_DEBUG("Got %s", mntent.mnt_dir);
1782
        if (STRNEQ(mntent.mnt_type, "cgroup"))
1783 1784
            continue;

1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799
        if (!*root) {
            char *tmp;
            if (!(*root = strdup(mntent.mnt_dir))) {
                virReportOOMError();
                goto cleanup;
            }
            tmp = strrchr(*root, '/');
            *tmp = '\0';
        } else if (!STRPREFIX(mntent.mnt_dir, *root)) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Cgroup %s is not mounted under %s"),
                           mntent.mnt_dir, *root);
            goto cleanup;
        }

1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812
        /* Skip named mounts with no controller since they're
         * for application use only ie systemd */
        if (strstr(mntent.mnt_opts, "name="))
            continue;

        if (VIR_EXPAND_N(mounts, nmounts, 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
        if (!(mounts[nmounts-1].dir = strdup(mntent.mnt_dir))) {
            virReportOOMError();
            goto cleanup;
        }
1813
        VIR_DEBUG("Grabbed '%s'", mntent.mnt_dir);
1814 1815
    }

1816 1817 1818 1819 1820 1821
    if (!*root) {
        VIR_DEBUG("No mounted cgroups found");
        ret = 0;
        goto cleanup;
    }

1822 1823
    VIR_DEBUG("Checking for symlinks in %s", *root);
    if (!(dh = opendir(*root))) {
1824 1825
        virReportSystemError(errno,
                             _("Unable to read directory %s"),
1826
                             *root);
1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839
        goto cleanup;
    }

    while ((dent = readdir(dh)) != NULL) {
        ssize_t rv;
        /* The cgroups links are just relative to the local
         * dir so we don't need a large buf */
        char linkbuf[100];

        if (dent->d_name[0] == '.')
            continue;

        VIR_DEBUG("Checking entry %s", dent->d_name);
1840
        if (virAsprintf(&path, "%s/%s", *root, dent->d_name) < 0) {
1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879
            virReportOOMError();
            goto cleanup;
        }

        if ((rv = readlink(path, linkbuf, sizeof(linkbuf)-1)) < 0) {
            if (errno != EINVAL) {
                virReportSystemError(errno,
                                     _("Unable to resolve link %s"),
                                     path);
                VIR_FREE(path);
                goto cleanup;
            }
            /* Ok not a link */
            VIR_FREE(path);
        } else {
            linkbuf[rv] = '\0';
            VIR_DEBUG("Got a link %s to %s", path, linkbuf);
            if (VIR_EXPAND_N(mounts, nmounts, 1) < 0) {
                virReportOOMError();
                goto cleanup;
            }
            if (!(mounts[nmounts-1].linkDest = strdup(linkbuf))) {
                virReportOOMError();
                goto cleanup;
            }
            mounts[nmounts-1].dir = path;
            path = NULL;
        }
    }

    *mountsret = mounts;
    *nmountsret = nmounts;
    ret = 0;

cleanup:
    closedir(dh);
    endmntent(procmnt);
    VIR_FREE(path);

1880
    if (ret < 0) {
1881
        lxcContainerCGroupFree(mounts, nmounts);
1882 1883
        VIR_FREE(*root);
    }
1884 1885 1886 1887 1888
    return ret;
}


static int lxcContainerMountCGroups(struct lxcContainerCGroup *mounts,
1889
                                    size_t nmounts,
1890 1891
                                    const char *root,
                                    char *sec_mount_options)
1892 1893
{
    size_t i;
1894
    char *opts = NULL;
1895

1896
    VIR_DEBUG("Mounting cgroups at '%s'", root);
1897

1898
    if (virFileMakePath(root) < 0) {
1899 1900
        virReportSystemError(errno,
                             _("Unable to create directory %s"),
1901
                             root);
1902 1903 1904
        return -1;
    }

1905
    if (virAsprintf(&opts,
1906
                    "mode=755,size=65536%s", sec_mount_options) < 0) {
1907 1908 1909 1910
        virReportOOMError();
        return -1;
    }

1911
    if (mount("tmpfs", root, "tmpfs", MS_NOSUID|MS_NODEV|MS_NOEXEC, opts) < 0) {
1912
        VIR_FREE(opts);
1913 1914
        virReportSystemError(errno,
                             _("Failed to mount %s on %s type %s"),
1915
                             "tmpfs", root, "tmpfs");
1916 1917
        return -1;
    }
1918
    VIR_FREE(opts);
1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939

    for (i = 0 ; i < nmounts ; i++) {
        if (mounts[i].linkDest) {
            VIR_DEBUG("Link mount point '%s' to '%s'",
                      mounts[i].dir, mounts[i].linkDest);
            if (symlink(mounts[i].linkDest, mounts[i].dir) < 0) {
                virReportSystemError(errno,
                                     _("Unable to symlink directory %s to %s"),
                                     mounts[i].dir, mounts[i].linkDest);
                return -1;
            }
        } else {
            VIR_DEBUG("Create mount point '%s'", mounts[i].dir);
            if (virFileMakePath(mounts[i].dir) < 0) {
                virReportSystemError(errno,
                                     _("Unable to create directory %s"),
                                     mounts[i].dir);
                return -1;
            }

            if (mount("cgroup", mounts[i].dir, "cgroup",
1940
                      0, mounts[i].dir + strlen(root) + 1) < 0) {
1941
                virReportSystemError(errno,
1942 1943
                                     _("Failed to mount cgroup on '%s'"),
                                     mounts[i].dir);
1944 1945 1946 1947 1948 1949 1950 1951 1952
                return -1;
            }
        }
    }

    return 0;
}


1953 1954 1955 1956 1957
/* Got a FS mapped to /, we're going the pivot_root
 * approach to do a better-chroot-than-chroot
 * this is based on this thread http://lkml.org/lkml/2008/3/5/29
 */
static int lxcContainerSetupPivotRoot(virDomainDefPtr vmDef,
1958 1959
                                      virDomainFSDefPtr root,
                                      char **ttyPaths,
1960
                                      size_t nttyPaths,
1961
                                      virSecurityManagerPtr securityDriver)
1962
{
1963 1964 1965
    struct lxcContainerCGroup *mounts = NULL;
    size_t nmounts = 0;
    int ret = -1;
1966 1967 1968 1969 1970
    char *cgroupRoot = NULL;
    char *sec_mount_options;

    if (!(sec_mount_options = virSecurityManagerGetMountOptions(securityDriver, vmDef)))
        return -1;
1971 1972 1973

    /* Before pivoting we need to identify any
     * cgroups controllers that are mounted */
1974
    if (lxcContainerIdentifyCGroups(&mounts, &nmounts, &cgroupRoot) < 0)
1975
        goto cleanup;
1976

1977 1978 1979 1980
    /* Ensure the root filesystem is mounted */
    if (lxcContainerPrepareRoot(vmDef, root) < 0)
        goto cleanup;

1981
    /* Gives us a private root, leaving all parent OS mounts on /.oldroot */
1982
    if (lxcContainerPivotRoot(root) < 0)
1983
        goto cleanup;
1984

1985
#if WITH_SELINUX
1986 1987 1988
    /* Some versions of Linux kernel don't let you overmount
     * the selinux filesystem, so make sure we kill it first
     */
1989 1990
    if (STREQ(root->src, "/") &&
        lxcContainerUnmountSubtree(SELINUX_MOUNT, false) < 0)
1991 1992 1993
        goto cleanup;
#endif

1994 1995
    /* If we have the root source being '/', then we need to
     * get rid of any existing stuff under /proc, /sys & /tmp.
1996 1997
     * We need new namespace aware versions of those. We must
     * do /proc last otherwise we won't find /proc/mounts :-) */
1998 1999 2000 2001
    if (STREQ(root->src, "/") &&
        (lxcContainerUnmountSubtree("/sys", false) < 0 ||
         lxcContainerUnmountSubtree("/dev", false) < 0 ||
         lxcContainerUnmountSubtree("/proc", false) < 0))
2002 2003
        goto cleanup;

2004
    /* Mounts the core /proc, /sys, etc filesystems */
2005
    if (lxcContainerMountBasicFS(true, sec_mount_options) < 0)
2006 2007
        goto cleanup;

2008 2009 2010 2011
    /* Mounts /proc/meminfo etc sysinfo */
    if (lxcContainerMountProcFuse(vmDef, "/.oldroot") < 0)
        goto cleanup;

2012 2013
    /* Now we can re-mount the cgroups controllers in the
     * same configuration as before */
2014 2015
    if (lxcContainerMountCGroups(mounts, nmounts,
                                 cgroupRoot, sec_mount_options) < 0)
2016
        goto cleanup;
2017

2018
    /* Mounts /dev/pts */
2019
    if (lxcContainerMountFSDevPTS(vmDef, "/.oldroot") < 0)
2020
        goto cleanup;
2021

2022
    /* Populates device nodes in /dev/ */
2023
    if (lxcContainerPopulateDevices(ttyPaths, nttyPaths) < 0)
2024
        goto cleanup;
2025

2026
    /* Sets up any non-root mounts from guest config */
2027
    if (lxcContainerMountAllFS(vmDef, "/.oldroot", true, sec_mount_options) < 0)
2028
        goto cleanup;
2029

2030 2031 2032 2033
    /* Sets up any extra disks from guest config */
    if (lxcContainerSetupAllDisks(vmDef, "/.oldroot", securityDriver) < 0)
        goto cleanup;

2034 2035 2036 2037 2038
    /* Sets up any extra host devices from guest config */
    if (lxcContainerSetupAllHostdevs(vmDef, "/.oldroot", securityDriver) < 0)
        goto cleanup;

   /* Gets rid of all remaining mounts from host OS, including /.oldroot itself */
2039
    if (lxcContainerUnmountSubtree("/.oldroot", true) < 0)
2040
        goto cleanup;
2041

2042 2043 2044 2045
    ret = 0;

cleanup:
    lxcContainerCGroupFree(mounts, nmounts);
2046
    VIR_FREE(cgroupRoot);
2047
    VIR_FREE(sec_mount_options);
2048
    return ret;
2049 2050
}

2051

2052 2053
/* Nothing mapped to /, we're using the main root,
   but with extra stuff mapped in */
2054
static int lxcContainerSetupExtraMounts(virDomainDefPtr vmDef,
2055
                                        virDomainFSDefPtr root,
2056
                                        virSecurityManagerPtr securityDriver)
2057
{
2058 2059 2060
    int ret = -1;
    struct lxcContainerCGroup *mounts = NULL;
    size_t nmounts = 0;
2061 2062
    char *cgroupRoot = NULL;
    char *sec_mount_options;
2063

2064
    VIR_DEBUG("def=%p", vmDef);
2065 2066 2067 2068

    if (!(sec_mount_options = virSecurityManagerGetMountOptions(securityDriver, vmDef)))
        return -1;

2069 2070 2071 2072 2073
    /*
     * This makes sure that any new filesystems in the
     * host OS propagate to the container, but any
     * changes in the container are private
     */
2074
    if (mount("", "/", NULL, MS_SLAVE|MS_REC, NULL) < 0) {
2075
        virReportSystemError(errno, "%s",
2076
                             _("Failed to make / slave"));
2077
        goto cleanup;
2078
    }
2079

2080 2081 2082 2083
    if (root && root->readonly) {
        if (mount("", "/", NULL, MS_BIND|MS_REC|MS_RDONLY|MS_REMOUNT, NULL) < 0) {
            virReportSystemError(errno, "%s",
                                 _("Failed to make root readonly"));
2084
            goto cleanup;
2085 2086 2087
        }
    }

2088
    VIR_DEBUG("Mounting config FS");
2089
    if (lxcContainerMountAllFS(vmDef, "", false, sec_mount_options) < 0)
2090
        goto cleanup;
2091

2092 2093
    /* Before replacing /sys we need to identify any
     * cgroups controllers that are mounted */
2094
    if (lxcContainerIdentifyCGroups(&mounts, &nmounts, &cgroupRoot) < 0)
2095
        goto cleanup;
2096

2097
#if WITH_SELINUX
2098 2099 2100 2101 2102 2103 2104
    /* Some versions of Linux kernel don't let you overmount
     * the selinux filesystem, so make sure we kill it first
     */
    if (lxcContainerUnmountSubtree(SELINUX_MOUNT, false) < 0)
        goto cleanup;
#endif

2105 2106 2107 2108 2109
    /* Gets rid of any existing stuff under /proc, since we need new
     * namespace aware versions of those. We must do /proc second
     * otherwise we won't find /proc/mounts :-) */
    if (lxcContainerUnmountSubtree("/sys", false) < 0 ||
        lxcContainerUnmountSubtree("/proc", false) < 0)
2110
        goto cleanup;
2111

2112
    /* Mounts the core /proc, /sys, etc filesystems */
2113
    if (lxcContainerMountBasicFS(false, sec_mount_options) < 0)
2114 2115
        goto cleanup;

2116
    /* Mounts /proc/meminfo etc sysinfo */
2117
    if (lxcContainerMountProcFuse(vmDef, NULL) < 0)
2118 2119
        goto cleanup;

2120 2121
    /* Now we can re-mount the cgroups controllers in the
     * same configuration as before */
2122 2123
    if (lxcContainerMountCGroups(mounts, nmounts,
                                 cgroupRoot, sec_mount_options) < 0)
2124
        goto cleanup;
2125

2126
    VIR_DEBUG("Mounting completed");
2127 2128 2129 2130 2131

    ret = 0;

cleanup:
    lxcContainerCGroupFree(mounts, nmounts);
2132
    VIR_FREE(cgroupRoot);
2133
    VIR_FREE(sec_mount_options);
2134
    return ret;
2135 2136
}

2137 2138 2139 2140 2141 2142 2143 2144

static int lxcContainerResolveSymlinks(virDomainDefPtr vmDef)
{
    char *newroot;
    size_t i;

    for (i = 0 ; i < vmDef->nfss ; i++) {
        virDomainFSDefPtr fs = vmDef->fss[i];
2145 2146
        if (!fs->src)
            continue;
2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158
        if (virFileResolveAllLinks(fs->src, &newroot) < 0)
            return -1;

        VIR_DEBUG("Resolved '%s' to %s", fs->src, newroot);

        VIR_FREE(fs->src);
        fs->src = newroot;
    }

    return 0;
}

2159
static int lxcContainerSetupMounts(virDomainDefPtr vmDef,
2160 2161
                                   virDomainFSDefPtr root,
                                   char **ttyPaths,
2162 2163
                                   size_t nttyPaths,
                                   virSecurityManagerPtr securityDriver)
2164
{
2165 2166 2167
    if (lxcContainerResolveSymlinks(vmDef) < 0)
        return -1;

2168
    if (root && root->src)
2169 2170
        return  lxcContainerSetupPivotRoot(vmDef, root, ttyPaths, nttyPaths,
                                           securityDriver);
2171
    else
2172 2173
        return lxcContainerSetupExtraMounts(vmDef, root,
                                            securityDriver);
2174 2175
}

D
Daniel P. Berrange 已提交
2176 2177 2178 2179 2180 2181

/*
 * This is running as the 'init' process insid the container.
 * It removes some capabilities that could be dangerous to
 * host system, since they are not currently "containerized"
 */
E
Eric Blake 已提交
2182
static int lxcContainerDropCapabilities(bool keepReboot ATTRIBUTE_UNUSED)
2183
{
2184
#if WITH_CAPNG
D
Daniel P. Berrange 已提交
2185 2186 2187 2188 2189 2190 2191 2192 2193
    int ret;

    capng_get_caps_process();

    if ((ret = capng_updatev(CAPNG_DROP,
                             CAPNG_EFFECTIVE | CAPNG_PERMITTED |
                             CAPNG_INHERITABLE | CAPNG_BOUNDING_SET,
                             CAP_SYS_MODULE, /* No kernel module loading */
                             CAP_SYS_TIME, /* No changing the clock */
2194
                             CAP_MKNOD, /* No creating device nodes */
D
Daniel P. Berrange 已提交
2195 2196
                             CAP_AUDIT_CONTROL, /* No messing with auditing status */
                             CAP_MAC_ADMIN, /* No messing with LSM config */
2197
                             keepReboot ? -1 : CAP_SYS_BOOT, /* No use of reboot */
2198
                             -1)) < 0) {
2199 2200
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Failed to remove capabilities: %d"), ret);
D
Daniel P. Berrange 已提交
2201 2202
        return -1;
    }
2203

D
Daniel P. Berrange 已提交
2204
    if ((ret = capng_apply(CAPNG_SELECT_BOTH)) < 0) {
2205 2206
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Failed to apply capabilities: %d"), ret);
D
Daniel P. Berrange 已提交
2207
        return -1;
2208
    }
D
Daniel P. Berrange 已提交
2209

2210 2211 2212 2213 2214
    /* We do not need to call capng_lock() in this case. The bounding
     * set restriction will prevent them reacquiring sys_boot/module/time,
     * etc which is all that matters for the container. Once inside the
     * container it is fine for SECURE_NOROOT / SECURE_NO_SETUID_FIXUP to
     * be unmasked  - they can never escape the bounding set. */
D
Daniel P. Berrange 已提交
2215 2216

#else
2217
    VIR_WARN("libcap-ng support not compiled in, unable to clear capabilities");
D
Daniel Veillard 已提交
2218
#endif
2219 2220 2221 2222
    return 0;
}


2223
/**
2224 2225
 * lxcContainerChild:
 * @data: pointer to container arguments
2226 2227 2228 2229 2230 2231 2232 2233 2234
 *
 * This function is run in the process clone()'d in lxcStartContainer.
 * Perform a number of container setup tasks:
 *     Setup container file system
 *     mount container /proca
 * Then exec's the container init
 *
 * Returns 0 on success or -1 in case of error
 */
2235
static int lxcContainerChild(void *data)
2236
{
2237
    lxc_child_argv_t *argv = data;
2238
    virDomainDefPtr vmDef = argv->config;
2239
    int ttyfd = -1;
2240
    int ret = -1;
2241
    char *ttyPath = NULL;
2242
    virDomainFSDefPtr root;
2243
    virCommandPtr cmd = NULL;
2244
    int hasReboot;
2245 2246

    if (NULL == vmDef) {
2247 2248
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("lxcChild() passed invalid vm definition"));
2249
        goto cleanup;
2250 2251
    }

2252 2253 2254
    if ((hasReboot = lxcContainerHasReboot()) < 0)
        goto cleanup;

2255 2256 2257
    cmd = lxcContainerBuildInitCmd(vmDef);
    virCommandWriteArgLog(cmd, 1);

2258
    root = virDomainGetRootFilesystem(vmDef);
2259

2260 2261
    if (argv->nttyPaths) {
        if (root) {
2262 2263 2264 2265 2266
            const char *tty = argv->ttyPaths[0];
            if (STRPREFIX(tty, "/dev/pts/"))
                tty += strlen("/dev/pts/");
            if (virAsprintf(&ttyPath, "%s/%s.devpts/%s",
                            LXC_STATE_DIR, vmDef->name, tty) < 0) {
2267 2268 2269 2270 2271 2272 2273 2274
                virReportOOMError();
                goto cleanup;
            }
        } else {
            if (!(ttyPath = strdup(argv->ttyPaths[0]))) {
                virReportOOMError();
                goto cleanup;
            }
2275 2276
        }
    } else {
2277
        if (!(ttyPath = strdup("/dev/null"))) {
2278
            virReportOOMError();
2279
            goto cleanup;
2280 2281
        }
    }
2282

2283
    VIR_DEBUG("Container TTY path: %s", ttyPath);
2284 2285

    ttyfd = open(ttyPath, O_RDWR|O_NOCTTY);
2286
    if (ttyfd < 0) {
2287
        virReportSystemError(errno,
2288
                             _("Failed to open tty %s"),
2289
                             ttyPath);
2290
        goto cleanup;
2291
    }
2292

2293 2294 2295
    if (lxcContainerSetupMounts(vmDef, root,
                                argv->ttyPaths, argv->nttyPaths,
                                argv->securityDriver) < 0)
2296
        goto cleanup;
2297

2298 2299 2300 2301 2302 2303 2304
    if (!virFileExists(vmDef->os.init)) {
        virReportSystemError(errno,
                    _("cannot find init path '%s' relative to container root"),
                    vmDef->os.init);
        goto cleanup;
    }

2305
    /* Wait for interface devices to show up */
2306 2307 2308
    if (lxcContainerWaitForContinue(argv->monitor) < 0) {
        virReportSystemError(errno, "%s",
                             _("Failed to read the container continue message"));
2309
        goto cleanup;
2310 2311
    }
    VIR_DEBUG("Received container continue message");
2312

2313
    /* rename and enable interfaces */
2314 2315 2316
    if (lxcContainerRenameAndEnableInterfaces(!!(vmDef->features &
                                                 (1 << VIR_DOMAIN_FEATURE_PRIVNET)),
                                              argv->nveths,
2317
                                              argv->veths) < 0) {
2318
        goto cleanup;
2319
    }
2320

2321
    /* drop a set of root capabilities */
2322
    if (lxcContainerDropCapabilities(!!hasReboot) < 0)
2323
        goto cleanup;
2324

2325 2326 2327 2328 2329 2330
    if (lxcContainerSendContinue(argv->handshakefd) < 0) {
        virReportSystemError(errno, "%s",
                            _("failed to send continue signal to controller"));
        goto cleanup;
    }

2331 2332 2333 2334
    VIR_DEBUG("Setting up security labeling");
    if (virSecurityManagerSetProcessLabel(argv->securityDriver, vmDef) < 0)
        goto cleanup;

2335 2336 2337 2338
    if (lxcContainerSetStdio(argv->monitor, ttyfd, argv->handshakefd) < 0) {
        goto cleanup;
    }

2339
    ret = 0;
2340
cleanup:
2341 2342
    VIR_FREE(ttyPath);
    VIR_FORCE_CLOSE(ttyfd);
2343
    VIR_FORCE_CLOSE(argv->monitor);
2344
    VIR_FORCE_CLOSE(argv->handshakefd);
2345 2346

    if (ret == 0) {
E
Eric Blake 已提交
2347
        /* this function will only return if an error occurred */
2348 2349 2350
        ret = virCommandExec(cmd);
    }

2351 2352
    virCommandFree(cmd);
    return ret;
2353
}
2354

2355 2356
static int userns_supported(void)
{
2357 2358 2359 2360 2361 2362
#if 1
    /*
     * put off using userns until uid mapping is implemented
     */
    return 0;
#else
2363
    return lxcContainerAvailable(LXC_CONTAINER_FEATURE_USER) == 0;
2364
#endif
2365 2366
}

2367
virArch lxcContainerGetAlt32bitArch(virArch arch)
2368 2369 2370
{
    /* Any Linux 64bit arch which has a 32bit
     * personality available should be listed here */
2371 2372 2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386
    if (arch == VIR_ARCH_X86_64)
        return VIR_ARCH_I686;
    if (arch == VIR_ARCH_S390X)
        return VIR_ARCH_S390;
    if (arch == VIR_ARCH_PPC64)
        return VIR_ARCH_PPC;
    if (arch == VIR_ARCH_PARISC64)
        return VIR_ARCH_PARISC;
    if (arch == VIR_ARCH_SPARC64)
        return VIR_ARCH_SPARC;
    if (arch == VIR_ARCH_MIPS64)
        return VIR_ARCH_MIPS;
    if (arch == VIR_ARCH_MIPS64EL)
        return VIR_ARCH_MIPSEL;

    return VIR_ARCH_NONE;
2387 2388 2389
}


2390 2391
/**
 * lxcContainerStart:
2392 2393 2394 2395 2396
 * @def: pointer to virtual machine structure
 * @nveths: number of interfaces
 * @veths: interface names
 * @control: control FD to the container
 * @ttyPath: path of tty to set as the container console
2397 2398 2399 2400 2401
 *
 * Starts a container process by calling clone() with the namespace flags
 *
 * Returns PID of container on success or -1 in case of error
 */
2402
int lxcContainerStart(virDomainDefPtr def,
2403
                      virSecurityManagerPtr securityDriver,
2404
                      size_t nveths,
2405
                      char **veths,
2406
                      int control,
2407
                      int handshakefd,
2408 2409
                      char **ttyPaths,
                      size_t nttyPaths)
2410 2411
{
    pid_t pid;
E
Eric Blake 已提交
2412
    int cflags;
2413 2414
    int stacksize = getpagesize() * 4;
    char *stack, *stacktop;
2415 2416
    lxc_child_argv_t args = { def, securityDriver,
                              nveths, veths, control,
2417
                              ttyPaths, nttyPaths, handshakefd};
2418 2419 2420

    /* allocate a stack for the container */
    if (VIR_ALLOC_N(stack, stacksize) < 0) {
2421
        virReportOOMError();
2422 2423 2424 2425
        return -1;
    }
    stacktop = stack + stacksize;

E
Eric Blake 已提交
2426
    cflags = CLONE_NEWPID|CLONE_NEWNS|CLONE_NEWUTS|CLONE_NEWIPC|SIGCHLD;
2427

2428
    if (userns_supported()) {
2429
        VIR_DEBUG("Enable user namespaces");
E
Eric Blake 已提交
2430
        cflags |= CLONE_NEWUSER;
2431
    }
2432

2433 2434
    if (def->nets != NULL ||
        (def->features & (1 << VIR_DOMAIN_FEATURE_PRIVNET))) {
2435
        VIR_DEBUG("Enable network namespaces");
E
Eric Blake 已提交
2436
        cflags |= CLONE_NEWNET;
2437
    }
2438

E
Eric Blake 已提交
2439
    pid = clone(lxcContainerChild, stacktop, cflags, &args);
2440
    VIR_FREE(stack);
2441
    VIR_DEBUG("clone() completed, new container PID is %d", pid);
2442 2443

    if (pid < 0) {
2444
        virReportSystemError(errno, "%s",
2445
                             _("Failed to run clone container"));
2446 2447 2448 2449 2450 2451
        return -1;
    }

    return pid;
}

2452 2453
ATTRIBUTE_NORETURN static int
lxcContainerDummyChild(void *argv ATTRIBUTE_UNUSED)
2454 2455 2456 2457 2458 2459
{
    _exit(0);
}

int lxcContainerAvailable(int features)
{
2460
    int flags = CLONE_NEWPID|CLONE_NEWNS|CLONE_NEWUTS|
2461 2462 2463 2464 2465
        CLONE_NEWIPC|SIGCHLD;
    int cpid;
    char *childStack;
    char *stack;

2466 2467 2468
    if (features & LXC_CONTAINER_FEATURE_USER)
        flags |= CLONE_NEWUSER;

2469 2470 2471 2472
    if (features & LXC_CONTAINER_FEATURE_NET)
        flags |= CLONE_NEWNET;

    if (VIR_ALLOC_N(stack, getpagesize() * 4) < 0) {
2473
        VIR_DEBUG("Unable to allocate stack");
2474 2475 2476 2477 2478 2479 2480 2481
        return -1;
    }

    childStack = stack + (getpagesize() * 4);

    cpid = clone(lxcContainerDummyChild, childStack, flags, NULL);
    VIR_FREE(stack);
    if (cpid < 0) {
2482
        char ebuf[1024] ATTRIBUTE_UNUSED;
2483
        VIR_DEBUG("clone call returned %s, container support is not enabled",
2484
                  virStrerror(errno, ebuf, sizeof(ebuf)));
2485
        return -1;
2486
    } else if (virProcessWait(cpid, NULL) < 0) {
E
Eric Blake 已提交
2487
        return -1;
2488 2489
    }

G
Gao feng 已提交
2490
    VIR_DEBUG("container support is enabled");
2491
    return 0;
2492
}