root/usr.sbin/vmctl/main.c
/*      $OpenBSD: main.c,v 1.88 2026/04/01 00:51:50 dv Exp $    */

/*
 * Copyright (c) 2015 Reyk Floeter <reyk@openbsd.org>
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/queue.h>
#include <sys/un.h>

#include <err.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <stdint.h>
#include <limits.h>
#include <string.h>
#include <syslog.h>
#include <unistd.h>
#include <fcntl.h>
#include <util.h>
#include <imsg.h>

#include "vmd.h"
#include "virtio.h"
#include "proc.h"
#include "vmctl.h"

#define RAW_FMT         "raw"
#define QCOW2_FMT       "qcow2"

static const char       *socket_name = SOCKET_NAME;
static int               ctl_sock = -1;
static int               tty_autoconnect = 0;
int                      stat_rflag;
int                      verbose = 0;

__dead void      usage(void);
__dead void      ctl_usage(struct ctl_command *);

int              ctl_console(struct parse_result *, int, char *[]);
int              ctl_convert(const char *, const char *, int, size_t);
int              ctl_create(struct parse_result *, int, char *[]);
int              ctl_load(struct parse_result *, int, char *[]);
int              ctl_log(struct parse_result *, int, char *[]);
int              ctl_reload(struct parse_result *, int, char *[]);
int              ctl_reset(struct parse_result *, int, char *[]);
int              ctl_start(struct parse_result *, int, char *[]);
int              ctl_status(struct parse_result *, int, char *[]);
int              ctl_stop(struct parse_result *, int, char *[]);
int              ctl_waitfor(struct parse_result *, int, char *[]);
int              ctl_pause(struct parse_result *, int, char *[]);
int              ctl_unpause(struct parse_result *, int, char *[]);

struct ctl_command ctl_commands[] = {
        { "console",    CMD_CONSOLE,    ctl_console,    "id" },
        { "create",     CMD_CREATE,     ctl_create,
                "[-b base | -i disk] [-s size] disk", 1 },
        { "load",       CMD_LOAD,       ctl_load,       "filename" },
        { "log",        CMD_LOG,        ctl_log,        "[brief | verbose]" },
        { "pause",      CMD_PAUSE,      ctl_pause,      "id" },
        { "reload",     CMD_RELOAD,     ctl_reload,     "" },
        { "reset",      CMD_RESET,      ctl_reset,      "[all | switches | vms]" },
        { "show",       CMD_STATUS,     ctl_status,     "[id]" },
        { "start",      CMD_START,      ctl_start,
            "[-cL] [-B device] [-b path] [-d disk] [-i count]\n"
            "\t\t[-m size] [-n switch] [-r path] [-t name] id | name",  1},
        { "status",     CMD_STATUS,     ctl_status,     "[-r] [id]" },
        { "stop",       CMD_STOP,       ctl_stop,       "[-fw] [id | -a]" },
        { "unpause",    CMD_UNPAUSE,    ctl_unpause,    "id" },
        { "wait",       CMD_WAITFOR,    ctl_waitfor,    "id" },
        { NULL }
};

__dead void
usage(void)
{
        extern char     *__progname;

        fprintf(stderr, "usage:\t%s [-v] command [arg ...]\n", __progname);

        exit(1);
}

__dead void
ctl_usage(struct ctl_command *ctl)
{
        extern char     *__progname;

        fprintf(stderr, "usage:\t%s [-v] %s %s\n", __progname,
            ctl->name, ctl->usage);
        exit(1);
}

int
main(int argc, char *argv[])
{
        int      ch;

        while ((ch = getopt(argc, argv, "v")) != -1) {
                switch (ch) {
                case 'v':
                        verbose = 1;
                        break;
                default:
                        usage();
                        /* NOTREACHED */
                }
        }
        argc -= optind;
        argv += optind;
        optreset = 1;
        optind = 1;

        if (argc < 1)
                usage();

        return (parse(argc, argv));
}

int
parse(int argc, char *argv[])
{
        struct ctl_command      *ctl = NULL;
        struct parse_result      res;
        int                      i;

        memset(&res, 0, sizeof(res));
        res.nifs = -1;

        for (i = 0; ctl_commands[i].name != NULL; i++) {
                if (strncmp(ctl_commands[i].name,
                    argv[0], strlen(argv[0])) == 0) {
                        if (ctl != NULL) {
                                fprintf(stderr,
                                    "ambiguous argument: %s\n", argv[0]);
                                usage();
                        }
                        ctl = &ctl_commands[i];
                }
        }

        if (ctl == NULL) {
                fprintf(stderr, "unknown argument: %s\n", argv[0]);
                usage();
        }

        res.action = ctl->action;
        res.ctl = ctl;

        if (!ctl->has_pledge) {
                /* pledge(2) default if command doesn't have its own pledge */
                if (pledge("stdio rpath exec unix getpw unveil", NULL) == -1)
                        err(1, "pledge");
        }
        if (ctl->main(&res, argc, argv) != 0)
                exit(1);

        if (ctl_sock != -1) {
                close(ibuf->fd);
                free(ibuf);
        }

        return (0);
}

int
vmmaction(struct parse_result *res)
{
        struct sockaddr_un       sun;
        struct imsg              imsg;
        int                      done = 0;
        int                      n;
        int                      ret, action;
        unsigned int             flags;
        uint32_t                 type;

        if (ctl_sock == -1) {
                if (unveil(SOCKET_NAME, "w") == -1)
                        err(1, "unveil %s", SOCKET_NAME);
                if ((ctl_sock = socket(AF_UNIX,
                    SOCK_STREAM|SOCK_CLOEXEC, 0)) == -1)
                        err(1, "socket");

                memset(&sun, 0, sizeof(sun));
                sun.sun_family = AF_UNIX;
                strlcpy(sun.sun_path, socket_name, sizeof(sun.sun_path));

                if (connect(ctl_sock,
                    (struct sockaddr *)&sun, sizeof(sun)) == -1)
                        err(1, "connect: %s", socket_name);

                if ((ibuf = malloc(sizeof(struct imsgbuf))) == NULL)
                        err(1, "malloc");
                if (imsgbuf_init(ibuf, ctl_sock) == -1)
                        err(1, "imsgbuf_init");
                imsgbuf_allow_fdpass(ibuf);
        }

        switch (res->action) {
        case CMD_START:
                ret = vm_start(res->id, res->name, res->size, res->nifs,
                    res->nets, res->ndisks, res->disks, res->disktypes,
                    res->path, res->isopath, res->instance, res->bootdevice);
                if (ret) {
                        errno = ret;
                        err(1, "start VM operation failed");
                }
                break;
        case CMD_STOP:
                terminate_vm(res->id, res->name, res->flags);
                break;
        case CMD_STATUS:
        case CMD_CONSOLE:
        case CMD_STOPALL:
                get_info_vm(res->id, res->name, res->action, res->flags);
                break;
        case CMD_LOAD:
                imsg_compose(ibuf, IMSG_VMDOP_LOAD, 0, 0, -1,
                    res->path, strlen(res->path) + 1);
                break;
        case CMD_LOG:
                imsg_compose(ibuf, IMSG_CTL_VERBOSE, 0, 0, -1,
                    &res->verbose, sizeof(res->verbose));
                break;
        case CMD_RELOAD:
                imsg_compose(ibuf, IMSG_VMDOP_RELOAD, 0, 0, -1, NULL, 0);
                break;
        case CMD_RESET:
                imsg_compose(ibuf, IMSG_CTL_RESET, 0, 0, -1,
                    &res->mode, sizeof(res->mode));
                break;
        case CMD_WAITFOR:
                waitfor_vm(res->id, res->name);
                break;
        case CMD_PAUSE:
                pause_vm(res->id, res->name);
                break;
        case CMD_UNPAUSE:
                unpause_vm(res->id, res->name);
                break;
        case CMD_CREATE:
        case NONE:
                /* The action is not expected here */
                errx(1, "invalid action %u", res->action);
                break;
        }

        action = res->action;
        flags = res->flags;
        parse_free(res);

        if (imsgbuf_flush(ibuf) == -1)
                err(1, "write error");

        while (!done) {
                if ((n = imsgbuf_read(ibuf)) == -1)
                        err(1, "read error");
                if (n == 0)
                        errx(1, "pipe closed");

                while (!done) {
                        if ((n = imsg_get(ibuf, &imsg)) == -1)
                                errx(1, "imsg_get error");
                        if (n == 0)
                                break;

                        type = imsg_get_type(&imsg);
                        if (type == IMSG_CTL_FAIL) {
                                if (imsg_get_len(&imsg) == sizeof(ret))
                                        ret = imsg_int_read(&imsg);
                                else
                                        ret = 0;
                                if (ret != 0) {
                                        errno = ret;
                                        err(1, "command failed");
                                } else
                                        errx(1, "command failed");
                        }

                        ret = 0;
                        switch (action) {
                        case CMD_START:
                                done = vm_start_complete(&imsg, &ret,
                                    tty_autoconnect);
                                break;
                        case CMD_WAITFOR:
                                flags = VMOP_WAIT;
                                /* FALLTHROUGH */
                        case CMD_STOP:
                                done = terminate_vm_complete(&imsg, &ret,
                                    flags);
                                break;
                        case CMD_CONSOLE:
                        case CMD_STATUS:
                        case CMD_STOPALL:
                                done = add_info(&imsg, &ret);
                                break;
                        case CMD_PAUSE:
                                done = pause_vm_complete(&imsg, &ret);
                                break;
                        case CMD_UNPAUSE:
                                done = unpause_vm_complete(&imsg, &ret);
                                break;
                        default:
                                done = 1;
                                break;
                        }

                        imsg_free(&imsg);
                }
        }

        if (ret)
                return (1);
        else
                return (0);
}

void
parse_free(struct parse_result *res)
{
        size_t   i;

        free(res->name);
        free(res->path);
        free(res->isopath);
        free(res->instance);
        for (i = 0; i < res->ndisks; i++)
                free(res->disks[i]);
        free(res->disks);
        free(res->disktypes);
        memset(res, 0, sizeof(*res));
}

int
parse_ifs(struct parse_result *res, char *word, int val)
{
        const char      *error;

        if (word != NULL) {
                val = strtonum(word, 1, INT_MAX, &error);
                if (error != NULL)  {
                        warnx("count is %s: %s", error, word);
                        return (-1);
                }
        }
        res->nifs = val;

        return (0);
}

int
parse_network(struct parse_result *res, char *word)
{
        char            **nets;
        char            *s;

        if ((nets = reallocarray(res->nets, res->nnets + 1,
            sizeof(char *))) == NULL) {
                warn("reallocarray");
                return (-1);
        }
        if ((s = strdup(word)) == NULL) {
                warn("strdup");
                return (-1);
        }
        nets[res->nnets] = s;
        res->nets = nets;
        res->nnets++;

        return (0);
}

void
parse_size(struct parse_result *res, char *word, const char *type)
{
        char             result[FMT_SCALED_STRSIZE];
        long long        val = 0;

        if (word != NULL) {
                if (scan_scaled(word, &val) != 0)
                        err(1, "invalid %s size: %s", type, word);
        }

        if (val < (1024 * 1024))
                errx(1, "%s size must be at least 1MB", type);

        if (strcmp("memory", type) == 0 && val > VMM_MAX_VM_MEM_SIZE) {
                if (fmt_scaled(VMM_MAX_VM_MEM_SIZE, result) == 0)
                        errx(1, "memory size too large (limit is %s)", result);
                else
                        errx(1, "memory size too large");
        }

        /* Round down to the megabyte. */
        res->size = (val / (1024 * 1024)) * (1024 * 1024);

        if (res->size != (size_t)val) {
                if (fmt_scaled(res->size, result) == 0)
                        warnx("%s size rounded to %s", type, result);
                else
                        warnx("%s size rounded to %zuB", type, res->size);
        }
}

int
parse_disktype(const char *s, const char **ret)
{
        char             buf[BUFSIZ];
        const char      *ext;
        int              fd;
        ssize_t          len;

        *ret = s;

        /* Try to parse the explicit format (qcow2:disk.qc2) */
        if (strstr(s, RAW_FMT) == s && *(s + strlen(RAW_FMT)) == ':') {
                *ret = s + strlen(RAW_FMT) + 1;
                return (VMDF_RAW);
        }
        if (strstr(s, QCOW2_FMT) == s && *(s + strlen(QCOW2_FMT)) == ':') {
                *ret = s + strlen(QCOW2_FMT) + 1;
                return (VMDF_QCOW2);
        }

        /* Or try to derive the format from the file signature */
        if ((fd = open(s, O_RDONLY)) != -1) {
                len = read(fd, buf, sizeof(buf));
                close(fd);

                if (len >= (ssize_t)strlen(VM_MAGIC_QCOW) &&
                    strncmp(buf, VM_MAGIC_QCOW,
                    strlen(VM_MAGIC_QCOW)) == 0) {
                        /* Return qcow2, the version will be checked later */
                        return (VMDF_QCOW2);
                }
        }

        /*
         * Use the extension as a last option.  This is needed for
         * 'vmctl create' as the file, and the signature, doesn't
         * exist yet.
         */
        if ((ext = strrchr(s, '.')) != NULL && *(++ext) != '\0') {
                if (strcasecmp(ext, RAW_FMT) == 0)
                        return (VMDF_RAW);
                else if (strcasecmp(ext, QCOW2_FMT) == 0)
                        return (VMDF_QCOW2);
        }

        /* Fallback to raw */
        return (VMDF_RAW);
}

int
parse_disk(struct parse_result *res, char *word, int type)
{
        char            **disks;
        int             *disktypes;
        char            *s;

        if ((disks = reallocarray(res->disks, res->ndisks + 1,
            sizeof(char *))) == NULL) {
                warn("reallocarray");
                return (-1);
        }
        if ((disktypes = reallocarray(res->disktypes, res->ndisks + 1,
            sizeof(int))) == NULL) {
                warn("reallocarray");
                return -1;
        }
        if ((s = strdup(word)) == NULL) {
                warn("strdup");
                return (-1);
        }
        disks[res->ndisks] = s;
        disktypes[res->ndisks] = type;
        res->disks = disks;
        res->disktypes = disktypes;
        res->ndisks++;

        return (0);
}

int
parse_vmid(struct parse_result *res, char *word, int needname)
{
        const char      *error;
        uint32_t         id;

        if (word == NULL) {
                warnx("missing vmid argument");
                return (-1);
        }
        if (*word == '-') {
                /* don't print a warning to allow command line options */
                return (-1);
        }
        id = strtonum(word, 0, UINT32_MAX, &error);
        if (error == NULL) {
                if (needname) {
                        warnx("invalid vm name");
                        return (-1);
                } else {
                        res->id = id;
                        res->name = NULL;
                }
        } else {
                if (strlen(word) >= VMM_MAX_NAME_LEN) {
                        warnx("name too long");
                        return (-1);
                }
                res->id = 0;
                if ((res->name = strdup(word)) == NULL)
                        errx(1, "strdup");
        }

        return (0);
}

int
parse_instance(struct parse_result *res, char *word)
{
        if (strlen(word) >= VMM_MAX_NAME_LEN) {
                warnx("instance vm name too long");
                return (-1);
        }
        res->id = 0;
        if ((res->instance = strdup(word)) == NULL)
                errx(1, "strdup");

        return (0);
}

int
ctl_create(struct parse_result *res, int argc, char *argv[])
{
        int              ch, ret, type;
        const char      *disk, *format, *base = NULL, *input = NULL;

        while ((ch = getopt(argc, argv, "b:i:s:")) != -1) {
                switch (ch) {
                case 'b':
                        base = optarg;
                        break;
                case 'i':
                        input = optarg;
                        break;
                case 's':
                        parse_size(res, optarg, "disk");
                        break;
                default:
                        ctl_usage(res->ctl);
                        /* NOTREACHED */
                }
        }
        argc -= optind;
        argv += optind;

        if (argc != 1)
                ctl_usage(res->ctl);

        type = parse_disktype(argv[0], &disk);

        if (pledge("stdio rpath wpath cpath", NULL) == -1)
                err(1, "pledge");

        if (input) {
                if (base && input)
                        errx(1, "conflicting -b and -i arguments");
                return ctl_convert(input, disk, type, res->size);
        }

        if (base && type != VMDF_QCOW2)
                errx(1, "base images require qcow2 disk format");
        if (res->size == 0 && !base) {
                fprintf(stderr, "could not create %s: missing size argument\n",
                    disk);
                ctl_usage(res->ctl);
        }

        if ((ret = create_imagefile(type, disk, base, res->size, &format)) != 0) {
                errno = ret;
                err(1, "create imagefile operation failed");
        } else
                warnx("%s imagefile created", format);

        return (0);
}

int
ctl_convert(const char *srcfile, const char *dstfile, int dsttype, size_t dstsize)
{
        struct {
                int                      fd;
                int                      type;
                struct virtio_backing    file;
                const char              *disk;
                off_t                    size;
        }        src, dst;
        int              ret;
        const char      *format, *errstr = NULL;
        uint8_t         *buf = NULL, *zerobuf = NULL;
        size_t           buflen;
        ssize_t          len, rlen;
        off_t            off;

        memset(&src, 0, sizeof(src));
        memset(&dst, 0, sizeof(dst));

        src.type = parse_disktype(srcfile, &src.disk);
        dst.type = dsttype;
        dst.disk = dstfile;

        if ((src.fd = open_imagefile(src.type, src.disk, O_RDONLY,
            &src.file, &src.size)) == -1) {
                errstr = "failed to open source image file";
                goto done;
        }

        if (dstsize == 0)
                dstsize = src.size;
        if (dstsize < (size_t)src.size) {
                errstr = "size cannot be smaller than input disk size";
                goto done;
        }

        /* align to megabytes */
        dst.size = ALIGNSZ(dstsize, 1048576);

        if ((ret = create_imagefile(dst.type, dst.disk, NULL, dst.size,
            &format)) != 0) {
                errstr = "failed to create destination image file";
                goto done;
        }

        if ((dst.fd = open_imagefile(dst.type, dst.disk, O_RDWR,
            &dst.file, &dst.size)) == -1) {
                errstr = "failed to open destination image file";
                goto done;
        }

        if (pledge("stdio", NULL) == -1)
                err(1, "pledge");

        /*
         * Use 64k buffers by default.  This could also be adjusted to
         * the backend cluster size.
         */
        buflen = 1 << 16;
        if ((buf = calloc(1, buflen)) == NULL ||
            (zerobuf = calloc(1, buflen)) == NULL) {
                errstr = "failed to allocated buffers";
                goto done;
        }

        for (off = 0; off < dst.size; off += len) {
                /* Read input from the source image */
                if (off < src.size) {
                        len = MIN((off_t)buflen, src.size - off);
                        if ((rlen = src.file.pread(src.file.p,
                            buf, (size_t)len, off)) != len) {
                                errno = EIO;
                                errstr = "failed to read from source";
                                goto done;
                        }
                } else
                        len = 0;

                /* and pad the remaining bytes */
                if (len < (ssize_t)buflen) {
                        log_debug("%s: padding %zd zero bytes at offset %lld",
                            format, buflen - len, off + len);
                        memset(buf + len, 0, buflen - len);
                        len = buflen;
                }

                /*
                 * No need to copy empty buffers.  This allows the backend,
                 * sparse files or QCOW2 images, to save space in the
                 * destination file.
                 */
                if (memcmp(buf, zerobuf, buflen) == 0)
                        continue;

                log_debug("%s: writing %zd of %lld bytes at offset %lld",
                    format, len, dst.size, off);

                if ((rlen = dst.file.pwrite(dst.file.p,
                    buf, (size_t)len, off)) != len) {
                        errno = EIO;
                        errstr = "failed to write to destination";
                        goto done;
                }
        }

        if (dstsize < (size_t)dst.size)
                warnx("destination size rounded to %lld megabytes",
                    dst.size / 1048576);

 done:
        free(buf);
        free(zerobuf);
        if (src.file.p != NULL)
                src.file.close(src.file.p, 0);
        if (dst.file.p != NULL)
                dst.file.close(dst.file.p, 0);
        if (errstr != NULL)
                errx(1, "%s", errstr);
        else
                warnx("%s imagefile created", format);

        return (0);
}

int
ctl_status(struct parse_result *res, int argc, char *argv[])
{
        int ch;

        while ((ch = getopt(argc, argv, "r")) != -1) {
                switch (ch) {
                case 'r':
                        stat_rflag = 1;
                        break;
                default:
                        ctl_usage(res->ctl);
                        /* NOTREACHED */
                }
        }
        argc -= optind;
        argv += optind;

        if (argc == 1) {
                if (parse_vmid(res, argv[0], 0) == -1)
                        errx(1, "invalid id: %s", argv[0]);
        } else if (argc > 1)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_load(struct parse_result *res, int argc, char *argv[])
{
        if (argc != 2)
                ctl_usage(res->ctl);

        if ((res->path = strdup(argv[1])) == NULL)
                err(1, "strdup");

        return (vmmaction(res));
}

int
ctl_log(struct parse_result *res, int argc, char *argv[])
{
        if (argc != 2)
                ctl_usage(res->ctl);

        if (strncasecmp("brief", argv[1], strlen(argv[1])) == 0)
                res->verbose = 0;
        else if (strncasecmp("verbose", argv[1], strlen(argv[1])) == 0)
                res->verbose = 2;
        else
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_reload(struct parse_result *res, int argc, char *argv[])
{
        if (argc != 1)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_reset(struct parse_result *res, int argc, char *argv[])
{
        if (argc == 2) {
                if (strcasecmp("all", argv[1]) == 0)
                        res->mode = CONFIG_ALL;
                else if (strcasecmp("vms", argv[1]) == 0)
                        res->mode = CONFIG_VMS;
                else if (strcasecmp("switches", argv[1]) == 0)
                        res->mode = CONFIG_SWITCHES;
                else
                        ctl_usage(res->ctl);
        } else if (argc > 2)
                ctl_usage(res->ctl);

        if (res->mode == 0)
                res->mode = CONFIG_ALL;

        return (vmmaction(res));
}

int
ctl_start(struct parse_result *res, int argc, char *argv[])
{
        int              ch, i, type;
        char             path[PATH_MAX];
        const char      *s;

        /* We may require sendfd */
        if (pledge("stdio rpath exec unix getpw unveil sendfd", NULL) == -1)
                err(1, "pledge");

        while ((ch = getopt(argc, argv, "b:B:cd:i:Lm:n:r:t:")) != -1) {
                switch (ch) {
                case 'b':
                        if (res->path)
                                errx(1, "boot image specified multiple times");
                        if (realpath(optarg, path) == NULL)
                                err(1, "invalid boot image path");
                        if ((res->path = strdup(path)) == NULL)
                                errx(1, "strdup");
                        break;
                case 'B':
                        if (res->bootdevice)
                                errx(1, "boot device specified multiple times");
                        if (strcmp("disk", optarg) == 0)
                                res->bootdevice = VMBOOTDEV_DISK;
                        else if (strcmp("cdrom", optarg) == 0)
                                res->bootdevice = VMBOOTDEV_CDROM;
                        else if (strcmp("net", optarg) == 0)
                                res->bootdevice = VMBOOTDEV_NET;
                        else
                                errx(1, "unknown boot device %s", optarg);
                        break;
                case 'r':
                        if (res->isopath)
                                errx(1, "iso image specified multiple times");
                        if (realpath(optarg, path) == NULL)
                                err(1, "invalid iso image path: %s", optarg);
                        if ((res->isopath = strdup(path)) == NULL)
                                errx(1, "strdup");
                        break;
                case 'c':
                        tty_autoconnect = 1;
                        break;
                case 'L':
                        if (parse_network(res, ".") != 0)
                                errx(1, "invalid network: %s", optarg);
                        break;
                case 'm':
                        if (res->size)
                                errx(1, "memory specified multiple times");
                        parse_size(res, optarg, "memory");
                        break;
                case 'n':
                        if (parse_network(res, optarg) != 0)
                                errx(1, "invalid network: %s", optarg);
                        break;
                case 'd':
                        type = parse_disktype(optarg, &s);
                        if (realpath(s, path) == NULL)
                                err(1, "invalid disk path: %s", s);
                        if (parse_disk(res, path, type) != 0)
                                errx(1, "invalid disk: %s", optarg);
                        break;
                case 'i':
                        if (res->nifs != -1)
                                errx(1, "interfaces specified multiple times");
                        if (parse_ifs(res, optarg, 0) != 0)
                                errx(1, "invalid interface count: %s", optarg);
                        break;
                case 't':
                        if (parse_instance(res, optarg) == -1)
                                errx(1, "invalid name: %s", optarg);
                        break;
                default:
                        ctl_usage(res->ctl);
                        /* NOTREACHED */
                }
        }
        argc -= optind;
        argv += optind;

        if (argc != 1)
                ctl_usage(res->ctl);

        if (parse_vmid(res, argv[0], 0) == -1)
                errx(1, "invalid id: %s", argv[0]);

        for (i = res->nnets; i < res->nifs; i++) {
                /* Add interface that is not attached to a switch */
                if (parse_network(res, "") == -1)
                        return (-1);
        }
        if (res->nnets > res->nifs)
                res->nifs = res->nnets;

        return (vmmaction(res));
}

int
ctl_stop(struct parse_result *res, int argc, char *argv[])
{
        int              ch;

        while ((ch = getopt(argc, argv, "afw")) != -1) {
                switch (ch) {
                case 'f':
                        res->flags |= VMOP_FORCE;
                        break;
                case 'w':
                        res->flags |= VMOP_WAIT;
                        break;
                case 'a':
                        res->action = CMD_STOPALL;
                        break;
                default:
                        ctl_usage(res->ctl);
                        /* NOTREACHED */
                }
        }
        argc -= optind;
        argv += optind;

        if (res->action == CMD_STOPALL) {
                if (argc != 0)
                        ctl_usage(res->ctl);
        } else {
                if (argc != 1)
                        ctl_usage(res->ctl);
                if (parse_vmid(res, argv[0], 0) == -1)
                        errx(1, "invalid id: %s", argv[0]);
        }

        return (vmmaction(res));
}

int
ctl_console(struct parse_result *res, int argc, char *argv[])
{
        if (argc == 2) {
                if (parse_vmid(res, argv[1], 0) == -1)
                        errx(1, "invalid id: %s", argv[1]);
        } else if (argc != 2)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_waitfor(struct parse_result *res, int argc, char *argv[])
{
        if (argc == 2) {
                if (parse_vmid(res, argv[1], 0) == -1)
                        errx(1, "invalid id: %s", argv[1]);
        } else if (argc != 2)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_pause(struct parse_result *res, int argc, char *argv[])
{
        if (argc == 2) {
                if (parse_vmid(res, argv[1], 0) == -1)
                        errx(1, "invalid id: %s", argv[1]);
        } else if (argc != 2)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

int
ctl_unpause(struct parse_result *res, int argc, char *argv[])
{
        if (argc == 2) {
                if (parse_vmid(res, argv[1], 0) == -1)
                        errx(1, "invalid id: %s", argv[1]);
        } else if (argc != 2)
                ctl_usage(res->ctl);

        return (vmmaction(res));
}

__dead void
ctl_openconsole(const char *name)
{
        closefrom(STDERR_FILENO + 1);
        if (unveil(VMCTL_CU, "x") == -1)
                err(1, "unveil %s", VMCTL_CU);
        execl(VMCTL_CU, VMCTL_CU, "-r", "-l", name, "-s", "115200",
            (char *)NULL);
        err(1, "failed to open the console");
}

__dead void
fatal(const char *msg, ...)
{
        va_list ap;

        va_start(ap, msg);
        verr(1, msg, ap);
        va_end(ap);
}

__dead void
fatalx(const char *msg, ...)
{
        va_list ap;

        va_start(ap, msg);
        verrx(1, msg, ap);
        va_end(ap);
}

void
log_debug(const char *msg, ...)
{
        va_list ap;

        if (!verbose)
                return;

        va_start(ap, msg);
        vwarnx(msg, ap);
        va_end(ap);
}

void
log_warn(const char *msg, ...)
{
        va_list ap;

        va_start(ap, msg);
        vwarn(msg, ap);
        va_end(ap);
}


void
log_warnx(const char *msg, ...)
{
        va_list ap;

        va_start(ap, msg);
        vwarnx(msg, ap);
        va_end(ap);
}