[qemu.git] / qemu-nbd.c

/*
 *  Copyright (C) 2005  Anthony Liguori <[email protected]>
 *
 *  Network Block Device
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; under version 2 of the License.
 *
 *  This program 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 General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, see <http://www.gnu.org/licenses/>.
 */

#include "qemu-common.h"
#include "block/block.h"
#include "block/nbd.h"
#include "qemu/main-loop.h"
#include "block/snapshot.h"

#include <stdarg.h>
#include <stdio.h>
#include <getopt.h>
#include <err.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <signal.h>
#include <libgen.h>
#include <pthread.h>

#define SOCKET_PATH          "/var/lock/qemu-nbd-%s"
#define QEMU_NBD_OPT_CACHE   1
#define QEMU_NBD_OPT_AIO     2
#define QEMU_NBD_OPT_DISCARD 3

static NBDExport *exp;
static int verbose;
static char *srcpath;
static char *sockpath;
static int persistent = 0;
static enum { RUNNING, TERMINATE, TERMINATING, TERMINATED } state;
static int shared = 1;
static int nb_fds;

static void usage(const char *name)
{
    (printf) (
"Usage: %s [OPTIONS] FILE\n"
"QEMU Disk Network Block Device Server\n"
"\n"
"  -h, --help           display this help and exit\n"
"  -V, --version        output version information and exit\n"
"\n"
"Connection properties:\n"
"  -p, --port=PORT      port to listen on (default `%d')\n"
"  -b, --bind=IFACE     interface to bind to (default `0.0.0.0')\n"
"  -k, --socket=PATH    path to the unix socket\n"
"                       (default '"SOCKET_PATH"')\n"
"  -e, --shared=NUM     device can be shared by NUM clients (default '1')\n"
"  -t, --persistent     don't exit on the last connection\n"
"  -v, --verbose        display extra debugging information\n"
"\n"
"Exposing part of the image:\n"
"  -o, --offset=OFFSET  offset into the image\n"
"  -P, --partition=NUM  only expose partition NUM\n"
"\n"
#ifdef __linux__
"Kernel NBD client support:\n"
"  -c, --connect=DEV    connect FILE to the local NBD device DEV\n"
"  -d, --disconnect     disconnect the specified device\n"
"\n"
#endif
"\n"
"Block device options:\n"
"  -f, --format=FORMAT  set image format (raw, qcow2, ...)\n"
"  -r, --read-only      export read-only\n"
"  -s, --snapshot       use FILE as an external snapshot, create a temporary\n"
"                       file with backing_file=FILE, redirect the write to\n"
"                       the temporary one\n"
"  -l, --load-snapshot=SNAPSHOT_PARAM\n"
"                       load an internal snapshot inside FILE and export it\n"
"                       as an read-only device, SNAPSHOT_PARAM format is\n"
"                       'snapshot.id=[ID],snapshot.name=[NAME]', or\n"
"                       '[ID_OR_NAME]'\n"
"  -n, --nocache        disable host cache\n"
"      --cache=MODE     set cache mode (none, writeback, ...)\n"
#ifdef CONFIG_LINUX_AIO
"      --aio=MODE       set AIO mode (native or threads)\n"
#endif
"\n"
"Report bugs to <[email protected]>\n"
    , name, NBD_DEFAULT_PORT, "DEVICE");
}

static void version(const char *name)
{
    printf(
"%s version 0.0.1\n"
"Written by Anthony Liguori.\n"
"\n"
"Copyright (C) 2006 Anthony Liguori <[email protected]>.\n"
"This is free software; see the source for copying conditions.  There is NO\n"
"warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.\n"
    , name);
}

struct partition_record
{
    uint8_t bootable;
    uint8_t start_head;
    uint32_t start_cylinder;
    uint8_t start_sector;
    uint8_t system;
    uint8_t end_head;
    uint8_t end_cylinder;
    uint8_t end_sector;
    uint32_t start_sector_abs;
    uint32_t nb_sectors_abs;
};

static void read_partition(uint8_t *p, struct partition_record *r)
{
    r->bootable = p[0];
    r->start_head = p[1];
    r->start_cylinder = p[3] | ((p[2] << 2) & 0x0300);
    r->start_sector = p[2] & 0x3f;
    r->system = p[4];
    r->end_head = p[5];
    r->end_cylinder = p[7] | ((p[6] << 2) & 0x300);
    r->end_sector = p[6] & 0x3f;
    r->start_sector_abs = p[8] | p[9] << 8 | p[10] << 16 | p[11] << 24;
    r->nb_sectors_abs = p[12] | p[13] << 8 | p[14] << 16 | p[15] << 24;
}

static int find_partition(BlockDriverState *bs, int partition,
                          off_t *offset, off_t *size)
{
    struct partition_record mbr[4];
    uint8_t data[512];
    int i;
    int ext_partnum = 4;
    int ret;

    if ((ret = bdrv_read(bs, 0, data, 1)) < 0) {
        errno = -ret;
        err(EXIT_FAILURE, "error while reading");
    }

    if (data[510] != 0x55 || data[511] != 0xaa) {
        return -EINVAL;
    }

    for (i = 0; i < 4; i++) {
        read_partition(&data[446 + 16 * i], &mbr[i]);

        if (!mbr[i].nb_sectors_abs)
            continue;

        if (mbr[i].system == 0xF || mbr[i].system == 0x5) {
            struct partition_record ext[4];
            uint8_t data1[512];
            int j;

            if ((ret = bdrv_read(bs, mbr[i].start_sector_abs, data1, 1)) < 0) {
                errno = -ret;
                err(EXIT_FAILURE, "error while reading");
            }

            for (j = 0; j < 4; j++) {
                read_partition(&data1[446 + 16 * j], &ext[j]);
                if (!ext[j].nb_sectors_abs)
                    continue;

                if ((ext_partnum + j + 1) == partition) {
                    *offset = (uint64_t)ext[j].start_sector_abs << 9;
                    *size = (uint64_t)ext[j].nb_sectors_abs << 9;
                    return 0;
                }
            }
            ext_partnum += 4;
        } else if ((i + 1) == partition) {
            *offset = (uint64_t)mbr[i].start_sector_abs << 9;
            *size = (uint64_t)mbr[i].nb_sectors_abs << 9;
            return 0;
        }
    }

    return -ENOENT;
}

static void termsig_handler(int signum)
{
    state = TERMINATE;
    qemu_notify_event();
}

static void *show_parts(void *arg)
{
    char *device = arg;
    int nbd;

    /* linux just needs an open() to trigger
     * the partition table update
     * but remember to load the module with max_part != 0 :
     *     modprobe nbd max_part=63
     */
    nbd = open(device, O_RDWR);
    if (nbd >= 0) {
        close(nbd);
    }
    return NULL;
}

static void *nbd_client_thread(void *arg)
{
    char *device = arg;
    off_t size;
    size_t blocksize;
    uint32_t nbdflags;
    int fd, sock;
    int ret;
    pthread_t show_parts_thread;

    sock = unix_socket_outgoing(sockpath);
    if (sock < 0) {
        goto out;
    }

    ret = nbd_receive_negotiate(sock, NULL, &nbdflags,
                                &size, &blocksize);
    if (ret < 0) {
        goto out;
    }

    fd = open(device, O_RDWR);
    if (fd < 0) {
        /* Linux-only, we can use %m in printf.  */
        fprintf(stderr, "Failed to open %s: %m", device);
        goto out;
    }

    ret = nbd_init(fd, sock, nbdflags, size, blocksize);
    if (ret < 0) {
        goto out;
    }

    /* update partition table */
    pthread_create(&show_parts_thread, NULL, show_parts, device);

    if (verbose) {
        fprintf(stderr, "NBD device %s is now connected to %s\n",
                device, srcpath);
    } else {
        /* Close stderr so that the qemu-nbd process exits.  */
        dup2(STDOUT_FILENO, STDERR_FILENO);
    }

    ret = nbd_client(fd);
    if (ret) {
        goto out;
    }
    close(fd);
    kill(getpid(), SIGTERM);
    return (void *) EXIT_SUCCESS;

out:
    kill(getpid(), SIGTERM);
    return (void *) EXIT_FAILURE;
}

static int nbd_can_accept(void *opaque)
{
    return nb_fds < shared;
}

static void nbd_export_closed(NBDExport *exp)
{
    assert(state == TERMINATING);
    state = TERMINATED;
}

static void nbd_client_closed(NBDClient *client)
{
    nb_fds--;
    if (nb_fds == 0 && !persistent && state == RUNNING) {
        state = TERMINATE;
    }
    qemu_notify_event();
    nbd_client_put(client);
}

static void nbd_accept(void *opaque)
{
    int server_fd = (uintptr_t) opaque;
    struct sockaddr_in addr;
    socklen_t addr_len = sizeof(addr);

    int fd = accept(server_fd, (struct sockaddr *)&addr, &addr_len);
    if (state >= TERMINATE) {
        close(fd);
        return;
    }

    if (fd >= 0 && nbd_client_new(exp, fd, nbd_client_closed)) {
        nb_fds++;
    }
}

int main(int argc, char **argv)
{
    BlockDriverState *bs;
    BlockDriver *drv;
    off_t dev_offset = 0;
    uint32_t nbdflags = 0;
    bool disconnect = false;
    const char *bindto = "0.0.0.0";
    char *device = NULL;
    int port = NBD_DEFAULT_PORT;
    off_t fd_size;
    QemuOpts *sn_opts = NULL;
    const char *sn_id_or_name = NULL;
    const char *sopt = "hVb:o:p:rsnP:c:dvk:e:f:tl:";
    struct option lopt[] = {
        { "help", 0, NULL, 'h' },
        { "version", 0, NULL, 'V' },
        { "bind", 1, NULL, 'b' },
        { "port", 1, NULL, 'p' },
        { "socket", 1, NULL, 'k' },
        { "offset", 1, NULL, 'o' },
        { "read-only", 0, NULL, 'r' },
        { "partition", 1, NULL, 'P' },
        { "connect", 1, NULL, 'c' },
        { "disconnect", 0, NULL, 'd' },
        { "snapshot", 0, NULL, 's' },
        { "load-snapshot", 1, NULL, 'l' },
        { "nocache", 0, NULL, 'n' },
        { "cache", 1, NULL, QEMU_NBD_OPT_CACHE },
#ifdef CONFIG_LINUX_AIO
        { "aio", 1, NULL, QEMU_NBD_OPT_AIO },
#endif
        { "discard", 1, NULL, QEMU_NBD_OPT_DISCARD },
        { "shared", 1, NULL, 'e' },
        { "format", 1, NULL, 'f' },
        { "persistent", 0, NULL, 't' },
        { "verbose", 0, NULL, 'v' },
        { NULL, 0, NULL, 0 }
    };
    int ch;
    int opt_ind = 0;
    int li;
    char *end;
    int flags = BDRV_O_RDWR;
    int partition = -1;
    int ret;
    int fd;
    bool seen_cache = false;
    bool seen_discard = false;
#ifdef CONFIG_LINUX_AIO
    bool seen_aio = false;
#endif
    pthread_t client_thread;
    const char *fmt = NULL;
    Error *local_err = NULL;

    /* The client thread uses SIGTERM to interrupt the server.  A signal
     * handler ensures that "qemu-nbd -v -c" exits with a nice status code.
     */
    struct sigaction sa_sigterm;
    memset(&sa_sigterm, 0, sizeof(sa_sigterm));
    sa_sigterm.sa_handler = termsig_handler;
    sigaction(SIGTERM, &sa_sigterm, NULL);

    while ((ch = getopt_long(argc, argv, sopt, lopt, &opt_ind)) != -1) {
        switch (ch) {
        case 's':
            flags |= BDRV_O_SNAPSHOT;
            break;
        case 'n':
            optarg = (char *) "none";
            /* fallthrough */
        case QEMU_NBD_OPT_CACHE:
            if (seen_cache) {
                errx(EXIT_FAILURE, "-n and --cache can only be specified once");
            }
            seen_cache = true;
            if (bdrv_parse_cache_flags(optarg, &flags) == -1) {
                errx(EXIT_FAILURE, "Invalid cache mode `%s'", optarg);
            }
            break;
#ifdef CONFIG_LINUX_AIO
        case QEMU_NBD_OPT_AIO:
            if (seen_aio) {
                errx(EXIT_FAILURE, "--aio can only be specified once");
            }
            seen_aio = true;
            if (!strcmp(optarg, "native")) {
                flags |= BDRV_O_NATIVE_AIO;
            } else if (!strcmp(optarg, "threads")) {
                /* this is the default */
            } else {
               errx(EXIT_FAILURE, "invalid aio mode `%s'", optarg);
            }
            break;
#endif
        case QEMU_NBD_OPT_DISCARD:
            if (seen_discard) {
                errx(EXIT_FAILURE, "--discard can only be specified once");
            }
            seen_discard = true;
            if (bdrv_parse_discard_flags(optarg, &flags) == -1) {
                errx(EXIT_FAILURE, "Invalid discard mode `%s'", optarg);
            }
            break;
        case 'b':
            bindto = optarg;
            break;
        case 'p':
            li = strtol(optarg, &end, 0);
            if (*end) {
                errx(EXIT_FAILURE, "Invalid port `%s'", optarg);
            }
            if (li < 1 || li > 65535) {
                errx(EXIT_FAILURE, "Port out of range `%s'", optarg);
            }
            port = (uint16_t)li;
            break;
        case 'o':
                dev_offset = strtoll (optarg, &end, 0);
            if (*end) {
                errx(EXIT_FAILURE, "Invalid offset `%s'", optarg);
            }
            if (dev_offset < 0) {
                errx(EXIT_FAILURE, "Offset must be positive `%s'", optarg);
            }
            break;
        case 'l':
            if (strstart(optarg, SNAPSHOT_OPT_BASE, NULL)) {
                sn_opts = qemu_opts_parse(&internal_snapshot_opts, optarg, 0);
                if (!sn_opts) {
                    errx(EXIT_FAILURE, "Failed in parsing snapshot param `%s'",
                         optarg);
                }
            } else {
                sn_id_or_name = optarg;
            }
            /* fall through */
        case 'r':
            nbdflags |= NBD_FLAG_READ_ONLY;
            flags &= ~BDRV_O_RDWR;
            break;
        case 'P':
            partition = strtol(optarg, &end, 0);
            if (*end)
                errx(EXIT_FAILURE, "Invalid partition `%s'", optarg);
            if (partition < 1 || partition > 8)
                errx(EXIT_FAILURE, "Invalid partition %d", partition);
            break;
        case 'k':
            sockpath = optarg;
            if (sockpath[0] != '/')
                errx(EXIT_FAILURE, "socket path must be absolute\n");
            break;
        case 'd':
            disconnect = true;
            break;
        case 'c':
            device = optarg;
            break;
        case 'e':
            shared = strtol(optarg, &end, 0);
            if (*end) {
                errx(EXIT_FAILURE, "Invalid shared device number '%s'", optarg);
            }
            if (shared < 1) {
                errx(EXIT_FAILURE, "Shared device number must be greater than 0\n");
            }
            break;
        case 'f':
            fmt = optarg;
            break;
	case 't':
	    persistent = 1;
	    break;
        case 'v':
            verbose = 1;
            break;
        case 'V':
            version(argv[0]);
            exit(0);
            break;
        case 'h':
            usage(argv[0]);
            exit(0);
            break;
        case '?':
            errx(EXIT_FAILURE, "Try `%s --help' for more information.",
                 argv[0]);
        }
    }

    if ((argc - optind) != 1) {
        errx(EXIT_FAILURE, "Invalid number of argument.\n"
             "Try `%s --help' for more information.",
             argv[0]);
    }

    if (disconnect) {
        fd = open(argv[optind], O_RDWR);
        if (fd < 0) {
            err(EXIT_FAILURE, "Cannot open %s", argv[optind]);
        }
        nbd_disconnect(fd);

        close(fd);

        printf("%s disconnected\n", argv[optind]);

	return 0;
    }

    if (device && !verbose) {
        int stderr_fd[2];
        pid_t pid;
        int ret;

        if (qemu_pipe(stderr_fd) < 0) {
            err(EXIT_FAILURE, "Error setting up communication pipe");
        }

        /* Now daemonize, but keep a communication channel open to
         * print errors and exit with the proper status code.
         */
        pid = fork();
        if (pid == 0) {
            close(stderr_fd[0]);
            ret = qemu_daemon(1, 0);

            /* Temporarily redirect stderr to the parent's pipe...  */
            dup2(stderr_fd[1], STDERR_FILENO);
            if (ret < 0) {
                err(EXIT_FAILURE, "Failed to daemonize");
            }

            /* ... close the descriptor we inherited and go on.  */
            close(stderr_fd[1]);
        } else {
            bool errors = false;
            char *buf;

            /* In the parent.  Print error messages from the child until
             * it closes the pipe.
             */
            close(stderr_fd[1]);
            buf = g_malloc(1024);
            while ((ret = read(stderr_fd[0], buf, 1024)) > 0) {
                errors = true;
                ret = qemu_write_full(STDERR_FILENO, buf, ret);
                if (ret < 0) {
                    exit(EXIT_FAILURE);
                }
            }
            if (ret < 0) {
                err(EXIT_FAILURE, "Cannot read from daemon");
            }

            /* Usually the daemon should not print any message.
             * Exit with zero status in that case.
             */
            exit(errors);
        }
    }

    if (device != NULL && sockpath == NULL) {
        sockpath = g_malloc(128);
        snprintf(sockpath, 128, SOCKET_PATH, basename(device));
    }

    qemu_init_main_loop();
    bdrv_init();
    atexit(bdrv_close_all);

    if (fmt) {
        drv = bdrv_find_format(fmt);
        if (!drv) {
            errx(EXIT_FAILURE, "Unknown file format '%s'", fmt);
        }
    } else {
        drv = NULL;
    }

    bs = bdrv_new("hda");
    srcpath = argv[optind];
    ret = bdrv_open(&bs, srcpath, NULL, flags, drv, &local_err);
    if (ret < 0) {
        errno = -ret;
        err(EXIT_FAILURE, "Failed to bdrv_open '%s': %s", argv[optind],
            error_get_pretty(local_err));
    }

    if (sn_opts) {
        ret = bdrv_snapshot_load_tmp(bs,
                                     qemu_opt_get(sn_opts, SNAPSHOT_OPT_ID),
                                     qemu_opt_get(sn_opts, SNAPSHOT_OPT_NAME),
                                     &local_err);
    } else if (sn_id_or_name) {
        ret = bdrv_snapshot_load_tmp_by_id_or_name(bs, sn_id_or_name,
                                                   &local_err);
    }
    if (ret < 0) {
        errno = -ret;
        err(EXIT_FAILURE,
            "Failed to load snapshot: %s",
            error_get_pretty(local_err));
    }

    fd_size = bdrv_getlength(bs);

    if (partition != -1) {
        ret = find_partition(bs, partition, &dev_offset, &fd_size);
        if (ret < 0) {
            errno = -ret;
            err(EXIT_FAILURE, "Could not find partition %d", partition);
        }
    }

    exp = nbd_export_new(bs, dev_offset, fd_size, nbdflags, nbd_export_closed);

    if (sockpath) {
        fd = unix_socket_incoming(sockpath);
    } else {
        fd = tcp_socket_incoming(bindto, port);
    }

    if (fd < 0) {
        return 1;
    }

    if (device) {
        int ret;

        ret = pthread_create(&client_thread, NULL, nbd_client_thread, device);
        if (ret != 0) {
            errx(EXIT_FAILURE, "Failed to create client thread: %s",
                 strerror(ret));
        }
    } else {
        /* Shut up GCC warnings.  */
        memset(&client_thread, 0, sizeof(client_thread));
    }

    qemu_set_fd_handler2(fd, nbd_can_accept, nbd_accept, NULL,
                         (void *)(uintptr_t)fd);

    /* now when the initialization is (almost) complete, chdir("/")
     * to free any busy filesystems */
    if (chdir("/") < 0) {
        err(EXIT_FAILURE, "Could not chdir to root directory");
    }

    state = RUNNING;
    do {
        main_loop_wait(false);
        if (state == TERMINATE) {
            state = TERMINATING;
            nbd_export_close(exp);
            nbd_export_put(exp);
            exp = NULL;
        }
    } while (state != TERMINATED);

    bdrv_close(bs);
    if (sockpath) {
        unlink(sockpath);
    }

    if (sn_opts) {
        qemu_opts_del(sn_opts);
    }

    if (device) {
        void *ret;
        pthread_join(client_thread, &ret);
        exit(ret != NULL);
    } else {
        exit(EXIT_SUCCESS);
    }
}
Commit	Line	Data
cd831bd7	1	/*
7a5ca864 FB	2	* Copyright (C) 2005 Anthony Liguori <[email protected]>
	3	*
	4	* Network Block Device
	5	*
	6	* This program is free software; you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License as published by
	8	* the Free Software Foundation; under version 2 of the License.
	9	*
	10	* This program is distributed in the hope that it will be useful,
	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	* GNU General Public License for more details.
	14	*
	15	* You should have received a copy of the GNU General Public License
8167ee88	16	* along with this program; if not, see <http://www.gnu.org/licenses/>.
7a5ca864 FB	17	*/
7a5ca864 FB	18
5a61cb60	19	#include "qemu-common.h"
737e150e PB	20	#include "block/block.h"
737e150e PB	21	#include "block/nbd.h"
6a1751b7	22	#include "qemu/main-loop.h"
8c116b0e	23	#include "block/snapshot.h"
7a5ca864	24
7a5ca864 FB	25	#include <stdarg.h>
	26	#include <stdio.h>
	27	#include <getopt.h>
	28	#include <err.h>
cd831bd7	29	#include <sys/types.h>
7a5ca864 FB	30	#include <sys/socket.h>
	31	#include <netinet/in.h>
	32	#include <netinet/tcp.h>
	33	#include <arpa/inet.h>
cd831bd7	34	#include <signal.h>
2bff4b6f	35	#include <libgen.h>
a517e88b	36	#include <pthread.h>
cd831bd7	37
ded9d2d5 PB	38	#define SOCKET_PATH "/var/lock/qemu-nbd-%s"
	39	#define QEMU_NBD_OPT_CACHE 1
	40	#define QEMU_NBD_OPT_AIO 2
	41	#define QEMU_NBD_OPT_DISCARD 3
7a5ca864	42
af49bbbe	43	static NBDExport *exp;
b1d8e52e	44	static int verbose;
a517e88b PB	45	static char *srcpath;
a517e88b PB	46	static char *sockpath;
7860a380 PB	47	static int persistent = 0;
7860a380 PB	48	static enum { RUNNING, TERMINATE, TERMINATING, TERMINATED } state;
a61c6782 PB	49	static int shared = 1;
a61c6782 PB	50	static int nb_fds;
7a5ca864 FB	51
	52	static void usage(const char *name)
	53	{
b033cd86	54	(printf) (
7a5ca864 FB	55	"Usage: %s [OPTIONS] FILE\n"
	56	"QEMU Disk Network Block Device Server\n"
	57	"\n"
b033cd86 PB	58	" -h, --help display this help and exit\n"
	59	" -V, --version output version information and exit\n"
	60	"\n"
	61	"Connection properties:\n"
c2e2872b	62	" -p, --port=PORT port to listen on (default `%d')\n"
7a5ca864	63	" -b, --bind=IFACE interface to bind to (default `0.0.0.0')\n"
cd831bd7 TS	64	" -k, --socket=PATH path to the unix socket\n"
cd831bd7 TS	65	" (default '"SOCKET_PATH"')\n"
3b05a8e9	66	" -e, --shared=NUM device can be shared by NUM clients (default '1')\n"
75818250	67	" -t, --persistent don't exit on the last connection\n"
7a5ca864	68	" -v, --verbose display extra debugging information\n"
7a5ca864	69	"\n"
b033cd86 PB	70	"Exposing part of the image:\n"
	71	" -o, --offset=OFFSET offset into the image\n"
	72	" -P, --partition=NUM only expose partition NUM\n"
	73	"\n"
	74	#ifdef __linux__
	75	"Kernel NBD client support:\n"
	76	" -c, --connect=DEV connect FILE to the local NBD device DEV\n"
	77	" -d, --disconnect disconnect the specified device\n"
	78	"\n"
	79	#endif
	80	"\n"
	81	"Block device options:\n"
4323fdcf	82	" -f, --format=FORMAT set image format (raw, qcow2, ...)\n"
b033cd86	83	" -r, --read-only export read-only\n"
8c116b0e WX	84	" -s, --snapshot use FILE as an external snapshot, create a temporary\n"
	85	" file with backing_file=FILE, redirect the write to\n"
	86	" the temporary one\n"
	87	" -l, --load-snapshot=SNAPSHOT_PARAM\n"
	88	" load an internal snapshot inside FILE and export it\n"
	89	" as an read-only device, SNAPSHOT_PARAM format is\n"
	90	" 'snapshot.id=[ID],snapshot.name=[NAME]', or\n"
	91	" '[ID_OR_NAME]'\n"
b033cd86	92	" -n, --nocache disable host cache\n"
39a5235c PB	93	" --cache=MODE set cache mode (none, writeback, ...)\n"
	94	#ifdef CONFIG_LINUX_AIO
	95	" --aio=MODE set AIO mode (native or threads)\n"
	96	#endif
b033cd86 PB	97	"\n"
b033cd86 PB	98	"Report bugs to <[email protected]>\n"
c2e2872b	99	, name, NBD_DEFAULT_PORT, "DEVICE");
7a5ca864 FB	100	}
	101
	102	static void version(const char *name)
	103	{
	104	printf(
315bc7aa	105	"%s version 0.0.1\n"
7a5ca864 FB	106	"Written by Anthony Liguori.\n"
	107	"\n"
	108	"Copyright (C) 2006 Anthony Liguori <[email protected]>.\n"
	109	"This is free software; see the source for copying conditions. There is NO\n"
	110	"warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.\n"
315bc7aa	111	, name);
7a5ca864 FB	112	}
	113
	114	struct partition_record
	115	{
	116	uint8_t bootable;
	117	uint8_t start_head;
	118	uint32_t start_cylinder;
	119	uint8_t start_sector;
	120	uint8_t system;
	121	uint8_t end_head;
	122	uint8_t end_cylinder;
	123	uint8_t end_sector;
	124	uint32_t start_sector_abs;
	125	uint32_t nb_sectors_abs;
	126	};
	127
	128	static void read_partition(uint8_t p, struct partition_record r)
	129	{
	130	r->bootable = p[0];
	131	r->start_head = p[1];
	132	r->start_cylinder = p[3] \| ((p[2] << 2) & 0x0300);
	133	r->start_sector = p[2] & 0x3f;
	134	r->system = p[4];
	135	r->end_head = p[5];
	136	r->end_cylinder = p[7] \| ((p[6] << 2) & 0x300);
	137	r->end_sector = p[6] & 0x3f;
	138	r->start_sector_abs = p[8] \| p[9] << 8 \| p[10] << 16 \| p[11] << 24;
	139	r->nb_sectors_abs = p[12] \| p[13] << 8 \| p[14] << 16 \| p[15] << 24;
	140	}
	141
	142	static int find_partition(BlockDriverState *bs, int partition,
	143	off_t offset, off_t size)
	144	{
	145	struct partition_record mbr[4];
	146	uint8_t data[512];
	147	int i;
	148	int ext_partnum = 4;
cb7cf0e3	149	int ret;
7a5ca864	150
cb7cf0e3 RO	151	if ((ret = bdrv_read(bs, 0, data, 1)) < 0) {
	152	errno = -ret;
	153	err(EXIT_FAILURE, "error while reading");
	154	}
7a5ca864 FB	155
7a5ca864 FB	156	if (data[510] != 0x55 \|\| data[511] != 0xaa) {
185b4338	157	return -EINVAL;
7a5ca864 FB	158	}
	159
	160	for (i = 0; i < 4; i++) {
	161	read_partition(&data[446 + 16 * i], &mbr[i]);
	162
	163	if (!mbr[i].nb_sectors_abs)
	164	continue;
	165
	166	if (mbr[i].system == 0xF \|\| mbr[i].system == 0x5) {
	167	struct partition_record ext[4];
	168	uint8_t data1[512];
	169	int j;
	170
cb7cf0e3 RO	171	if ((ret = bdrv_read(bs, mbr[i].start_sector_abs, data1, 1)) < 0) {
	172	errno = -ret;
	173	err(EXIT_FAILURE, "error while reading");
	174	}
7a5ca864 FB	175
	176	for (j = 0; j < 4; j++) {
	177	read_partition(&data1[446 + 16 * j], &ext[j]);
	178	if (!ext[j].nb_sectors_abs)
	179	continue;
	180
	181	if ((ext_partnum + j + 1) == partition) {
	182	*offset = (uint64_t)ext[j].start_sector_abs << 9;
	183	*size = (uint64_t)ext[j].nb_sectors_abs << 9;
	184	return 0;
	185	}
	186	}
	187	ext_partnum += 4;
	188	} else if ((i + 1) == partition) {
	189	*offset = (uint64_t)mbr[i].start_sector_abs << 9;
	190	*size = (uint64_t)mbr[i].nb_sectors_abs << 9;
	191	return 0;
	192	}
	193	}
	194
185b4338	195	return -ENOENT;
7a5ca864 FB	196	}
7a5ca864 FB	197
bb345110 PB	198	static void termsig_handler(int signum)
bb345110 PB	199	{
7860a380	200	state = TERMINATE;
a61c6782	201	qemu_notify_event();
bb345110 PB	202	}
bb345110 PB	203
a517e88b	204	static void show_parts(void arg)
cd831bd7	205	{
a6ac2313	206	char *device = arg;
a517e88b PB	207	int nbd;
	208
	209	/* linux just needs an open() to trigger
	210	* the partition table update
	211	* but remember to load the module with max_part != 0 :
	212	* modprobe nbd max_part=63
	213	*/
	214	nbd = open(device, O_RDWR);
fc19f8a0	215	if (nbd >= 0) {
a517e88b PB	216	close(nbd);
	217	}
	218	return NULL;
	219	}
cd831bd7	220
a517e88b PB	221	static void nbd_client_thread(void arg)
a517e88b PB	222	{
a6ac2313	223	char *device = arg;
a517e88b PB	224	off_t size;
	225	size_t blocksize;
	226	uint32_t nbdflags;
a6ac2313	227	int fd, sock;
a517e88b PB	228	int ret;
	229	pthread_t show_parts_thread;
	230
dc10e8b3	231	sock = unix_socket_outgoing(sockpath);
fc19f8a0	232	if (sock < 0) {
dc10e8b3 SH	233	goto out;
dc10e8b3 SH	234	}
a517e88b PB	235
	236	ret = nbd_receive_negotiate(sock, NULL, &nbdflags,
	237	&size, &blocksize);
fc19f8a0	238	if (ret < 0) {
a517e88b PB	239	goto out;
	240	}
	241
a6ac2313	242	fd = open(device, O_RDWR);
fc19f8a0	243	if (fd < 0) {
a6ac2313 PB	244	/* Linux-only, we can use %m in printf. */
	245	fprintf(stderr, "Failed to open %s: %m", device);
	246	goto out;
	247	}
	248
a517e88b	249	ret = nbd_init(fd, sock, nbdflags, size, blocksize);
fc19f8a0	250	if (ret < 0) {
a517e88b PB	251	goto out;
	252	}
	253
	254	/* update partition table */
a6ac2313	255	pthread_create(&show_parts_thread, NULL, show_parts, device);
a517e88b	256
c1f8fdc3 PB	257	if (verbose) {
	258	fprintf(stderr, "NBD device %s is now connected to %s\n",
	259	device, srcpath);
	260	} else {
	261	/* Close stderr so that the qemu-nbd process exits. */
	262	dup2(STDOUT_FILENO, STDERR_FILENO);
	263	}
a517e88b PB	264
	265	ret = nbd_client(fd);
	266	if (ret) {
	267	goto out;
cd831bd7	268	}
a517e88b PB	269	close(fd);
	270	kill(getpid(), SIGTERM);
	271	return (void *) EXIT_SUCCESS;
	272
	273	out:
	274	kill(getpid(), SIGTERM);
	275	return (void *) EXIT_FAILURE;
cd831bd7 TS	276	}
cd831bd7 TS	277
a61c6782 PB	278	static int nbd_can_accept(void *opaque)
	279	{
	280	return nb_fds < shared;
	281	}
	282
7860a380 PB	283	static void nbd_export_closed(NBDExport *exp)
	284	{
	285	assert(state == TERMINATING);
	286	state = TERMINATED;
	287	}
	288
1743b515	289	static void nbd_client_closed(NBDClient *client)
a61c6782	290	{
1743b515	291	nb_fds--;
7860a380 PB	292	if (nb_fds == 0 && !persistent && state == RUNNING) {
	293	state = TERMINATE;
	294	}
1743b515	295	qemu_notify_event();
7860a380	296	nbd_client_put(client);
a61c6782 PB	297	}
	298
	299	static void nbd_accept(void *opaque)
	300	{
	301	int server_fd = (uintptr_t) opaque;
	302	struct sockaddr_in addr;
	303	socklen_t addr_len = sizeof(addr);
	304
	305	int fd = accept(server_fd, (struct sockaddr *)&addr, &addr_len);
7860a380 PB	306	if (state >= TERMINATE) {
	307	close(fd);
	308	return;
	309	}
	310
fc19f8a0	311	if (fd >= 0 && nbd_client_new(exp, fd, nbd_client_closed)) {
a61c6782 PB	312	nb_fds++;
	313	}
	314	}
	315
7a5ca864 FB	316	int main(int argc, char **argv)
	317	{
	318	BlockDriverState *bs;
e6b63677	319	BlockDriver *drv;
7a5ca864	320	off_t dev_offset = 0;
b90fb4b8	321	uint32_t nbdflags = 0;
cd831bd7	322	bool disconnect = false;
7a5ca864	323	const char *bindto = "0.0.0.0";
a6ac2313	324	char *device = NULL;
c2e2872b	325	int port = NBD_DEFAULT_PORT;
7a5ca864	326	off_t fd_size;
8c116b0e WX	327	QemuOpts *sn_opts = NULL;
	328	const char *sn_id_or_name = NULL;
	329	const char *sopt = "hVb:o:p:rsnP:c:dvk:e:f:tl:";
7a5ca864	330	struct option lopt[] = {
660f11be BS	331	{ "help", 0, NULL, 'h' },
	332	{ "version", 0, NULL, 'V' },
	333	{ "bind", 1, NULL, 'b' },
	334	{ "port", 1, NULL, 'p' },
	335	{ "socket", 1, NULL, 'k' },
	336	{ "offset", 1, NULL, 'o' },
	337	{ "read-only", 0, NULL, 'r' },
	338	{ "partition", 1, NULL, 'P' },
	339	{ "connect", 1, NULL, 'c' },
	340	{ "disconnect", 0, NULL, 'd' },
	341	{ "snapshot", 0, NULL, 's' },
8c116b0e	342	{ "load-snapshot", 1, NULL, 'l' },
660f11be	343	{ "nocache", 0, NULL, 'n' },
39a5235c PB	344	{ "cache", 1, NULL, QEMU_NBD_OPT_CACHE },
	345	#ifdef CONFIG_LINUX_AIO
	346	{ "aio", 1, NULL, QEMU_NBD_OPT_AIO },
	347	#endif
ded9d2d5	348	{ "discard", 1, NULL, QEMU_NBD_OPT_DISCARD },
660f11be	349	{ "shared", 1, NULL, 'e' },
e6b63677	350	{ "format", 1, NULL, 'f' },
660f11be BS	351	{ "persistent", 0, NULL, 't' },
	352	{ "verbose", 0, NULL, 'v' },
	353	{ NULL, 0, NULL, 0 }
7a5ca864 FB	354	};
	355	int ch;
	356	int opt_ind = 0;
	357	int li;
	358	char *end;
f5edb014	359	int flags = BDRV_O_RDWR;
7a5ca864	360	int partition = -1;
cd831bd7	361	int ret;
3b05a8e9	362	int fd;
39a5235c	363	bool seen_cache = false;
ded9d2d5	364	bool seen_discard = false;
39a5235c PB	365	#ifdef CONFIG_LINUX_AIO
	366	bool seen_aio = false;
	367	#endif
a517e88b	368	pthread_t client_thread;
e6b63677	369	const char *fmt = NULL;
34b5d2c6	370	Error *local_err = NULL;
7a5ca864	371
a517e88b PB	372	/* The client thread uses SIGTERM to interrupt the server. A signal
	373	* handler ensures that "qemu-nbd -v -c" exits with a nice status code.
	374	*/
bb345110	375	struct sigaction sa_sigterm;
bb345110 PB	376	memset(&sa_sigterm, 0, sizeof(sa_sigterm));
	377	sa_sigterm.sa_handler = termsig_handler;
	378	sigaction(SIGTERM, &sa_sigterm, NULL);
	379
7a5ca864 FB	380	while ((ch = getopt_long(argc, argv, sopt, lopt, &opt_ind)) != -1) {
	381	switch (ch) {
	382	case 's':
2f726488 TS	383	flags \|= BDRV_O_SNAPSHOT;
	384	break;
	385	case 'n':
39a5235c PB	386	optarg = (char *) "none";
	387	/* fallthrough */
	388	case QEMU_NBD_OPT_CACHE:
	389	if (seen_cache) {
	390	errx(EXIT_FAILURE, "-n and --cache can only be specified once");
	391	}
	392	seen_cache = true;
	393	if (bdrv_parse_cache_flags(optarg, &flags) == -1) {
	394	errx(EXIT_FAILURE, "Invalid cache mode `%s'", optarg);
	395	}
7a5ca864	396	break;
39a5235c PB	397	#ifdef CONFIG_LINUX_AIO
	398	case QEMU_NBD_OPT_AIO:
	399	if (seen_aio) {
	400	errx(EXIT_FAILURE, "--aio can only be specified once");
	401	}
	402	seen_aio = true;
	403	if (!strcmp(optarg, "native")) {
	404	flags \|= BDRV_O_NATIVE_AIO;
	405	} else if (!strcmp(optarg, "threads")) {
	406	/* this is the default */
	407	} else {
	408	errx(EXIT_FAILURE, "invalid aio mode `%s'", optarg);
	409	}
	410	break;
	411	#endif
ded9d2d5 PB	412	case QEMU_NBD_OPT_DISCARD:
	413	if (seen_discard) {
	414	errx(EXIT_FAILURE, "--discard can only be specified once");
	415	}
	416	seen_discard = true;
	417	if (bdrv_parse_discard_flags(optarg, &flags) == -1) {
	418	errx(EXIT_FAILURE, "Invalid discard mode `%s'", optarg);
	419	}
	420	break;
7a5ca864 FB	421	case 'b':
	422	bindto = optarg;
	423	break;
	424	case 'p':
	425	li = strtol(optarg, &end, 0);
	426	if (*end) {
b6353bea	427	errx(EXIT_FAILURE, "Invalid port `%s'", optarg);
7a5ca864 FB	428	}
7a5ca864 FB	429	if (li < 1 \|\| li > 65535) {
b6353bea	430	errx(EXIT_FAILURE, "Port out of range `%s'", optarg);
7a5ca864 FB	431	}
	432	port = (uint16_t)li;
	433	break;
	434	case 'o':
	435	dev_offset = strtoll (optarg, &end, 0);
	436	if (*end) {
b6353bea	437	errx(EXIT_FAILURE, "Invalid offset `%s'", optarg);
7a5ca864 FB	438	}
7a5ca864 FB	439	if (dev_offset < 0) {
b6353bea	440	errx(EXIT_FAILURE, "Offset must be positive `%s'", optarg);
7a5ca864 FB	441	}
7a5ca864 FB	442	break;
8c116b0e WX	443	case 'l':
	444	if (strstart(optarg, SNAPSHOT_OPT_BASE, NULL)) {
	445	sn_opts = qemu_opts_parse(&internal_snapshot_opts, optarg, 0);
	446	if (!sn_opts) {
	447	errx(EXIT_FAILURE, "Failed in parsing snapshot param `%s'",
	448	optarg);
	449	}
	450	} else {
	451	sn_id_or_name = optarg;
	452	}
	453	/* fall through */
7a5ca864	454	case 'r':
b90fb4b8	455	nbdflags \|= NBD_FLAG_READ_ONLY;
07108b29	456	flags &= ~BDRV_O_RDWR;
7a5ca864 FB	457	break;
	458	case 'P':
	459	partition = strtol(optarg, &end, 0);
	460	if (*end)
b6353bea	461	errx(EXIT_FAILURE, "Invalid partition `%s'", optarg);
7a5ca864	462	if (partition < 1 \|\| partition > 8)
b6353bea	463	errx(EXIT_FAILURE, "Invalid partition %d", partition);
7a5ca864	464	break;
cd831bd7	465	case 'k':
b32f6c28 PB	466	sockpath = optarg;
b32f6c28 PB	467	if (sockpath[0] != '/')
b6353bea	468	errx(EXIT_FAILURE, "socket path must be absolute\n");
cd831bd7 TS	469	break;
	470	case 'd':
	471	disconnect = true;
	472	break;
	473	case 'c':
	474	device = optarg;
	475	break;
3b05a8e9 TS	476	case 'e':
	477	shared = strtol(optarg, &end, 0);
	478	if (*end) {
b6353bea	479	errx(EXIT_FAILURE, "Invalid shared device number '%s'", optarg);
3b05a8e9 TS	480	}
3b05a8e9 TS	481	if (shared < 1) {
b6353bea	482	errx(EXIT_FAILURE, "Shared device number must be greater than 0\n");
3b05a8e9 TS	483	}
3b05a8e9 TS	484	break;
e6b63677 DB	485	case 'f':
	486	fmt = optarg;
	487	break;
75818250 TS	488	case 't':
	489	persistent = 1;
	490	break;
7a5ca864 FB	491	case 'v':
	492	verbose = 1;
	493	break;
	494	case 'V':
	495	version(argv[0]);
	496	exit(0);
	497	break;
	498	case 'h':
	499	usage(argv[0]);
	500	exit(0);
	501	break;
	502	case '?':
b6353bea	503	errx(EXIT_FAILURE, "Try `%s --help' for more information.",
7a5ca864 FB	504	argv[0]);
	505	}
	506	}
	507
	508	if ((argc - optind) != 1) {
b6353bea	509	errx(EXIT_FAILURE, "Invalid number of argument.\n"
7a5ca864 FB	510	"Try `%s --help' for more information.",
	511	argv[0]);
	512	}
	513
cd831bd7 TS	514	if (disconnect) {
cd831bd7 TS	515	fd = open(argv[optind], O_RDWR);
fc19f8a0	516	if (fd < 0) {
cb7cf0e3	517	err(EXIT_FAILURE, "Cannot open %s", argv[optind]);
fc19f8a0	518	}
cd831bd7 TS	519	nbd_disconnect(fd);
	520
	521	close(fd);
	522
	523	printf("%s disconnected\n", argv[optind]);
	524
	525	return 0;
	526	}
	527
c1f8fdc3 PB	528	if (device && !verbose) {
	529	int stderr_fd[2];
	530	pid_t pid;
	531	int ret;
	532
fc19f8a0	533	if (qemu_pipe(stderr_fd) < 0) {
c1f8fdc3 PB	534	err(EXIT_FAILURE, "Error setting up communication pipe");
	535	}
	536
	537	/* Now daemonize, but keep a communication channel open to
	538	* print errors and exit with the proper status code.
	539	*/
	540	pid = fork();
	541	if (pid == 0) {
	542	close(stderr_fd[0]);
9faf31b6	543	ret = qemu_daemon(1, 0);
c1f8fdc3 PB	544
	545	/* Temporarily redirect stderr to the parent's pipe... */
	546	dup2(stderr_fd[1], STDERR_FILENO);
fc19f8a0	547	if (ret < 0) {
c1f8fdc3 PB	548	err(EXIT_FAILURE, "Failed to daemonize");
	549	}
	550
	551	/* ... close the descriptor we inherited and go on. */
	552	close(stderr_fd[1]);
	553	} else {
	554	bool errors = false;
	555	char *buf;
	556
	557	/* In the parent. Print error messages from the child until
	558	* it closes the pipe.
	559	*/
	560	close(stderr_fd[1]);
	561	buf = g_malloc(1024);
	562	while ((ret = read(stderr_fd[0], buf, 1024)) > 0) {
	563	errors = true;
	564	ret = qemu_write_full(STDERR_FILENO, buf, ret);
fc19f8a0	565	if (ret < 0) {
c1f8fdc3 PB	566	exit(EXIT_FAILURE);
	567	}
	568	}
fc19f8a0	569	if (ret < 0) {
c1f8fdc3 PB	570	err(EXIT_FAILURE, "Cannot read from daemon");
	571	}
	572
	573	/* Usually the daemon should not print any message.
	574	* Exit with zero status in that case.
	575	*/
	576	exit(errors);
	577	}
	578	}
	579
a6ac2313 PB	580	if (device != NULL && sockpath == NULL) {
	581	sockpath = g_malloc(128);
	582	snprintf(sockpath, 128, SOCKET_PATH, basename(device));
cd831bd7 TS	583	}
cd831bd7 TS	584
7e7f4a0e	585	qemu_init_main_loop();
802ddc37 PB	586	bdrv_init();
	587	atexit(bdrv_close_all);
	588
e6b63677 DB	589	if (fmt) {
	590	drv = bdrv_find_format(fmt);
	591	if (!drv) {
	592	errx(EXIT_FAILURE, "Unknown file format '%s'", fmt);
	593	}
	594	} else {
	595	drv = NULL;
	596	}
	597
802ddc37 PB	598	bs = bdrv_new("hda");
802ddc37 PB	599	srcpath = argv[optind];
f67503e5	600	ret = bdrv_open(&bs, srcpath, NULL, flags, drv, &local_err);
e6b63677	601	if (ret < 0) {
802ddc37	602	errno = -ret;
34b5d2c6 HR	603	err(EXIT_FAILURE, "Failed to bdrv_open '%s': %s", argv[optind],
34b5d2c6 HR	604	error_get_pretty(local_err));
802ddc37 PB	605	}
802ddc37 PB	606
8c116b0e WX	607	if (sn_opts) {
	608	ret = bdrv_snapshot_load_tmp(bs,
	609	qemu_opt_get(sn_opts, SNAPSHOT_OPT_ID),
	610	qemu_opt_get(sn_opts, SNAPSHOT_OPT_NAME),
	611	&local_err);
	612	} else if (sn_id_or_name) {
	613	ret = bdrv_snapshot_load_tmp_by_id_or_name(bs, sn_id_or_name,
	614	&local_err);
	615	}
	616	if (ret < 0) {
	617	errno = -ret;
	618	err(EXIT_FAILURE,
	619	"Failed to load snapshot: %s",
	620	error_get_pretty(local_err));
	621	}
	622
38ceff04	623	fd_size = bdrv_getlength(bs);
802ddc37	624
185b4338 PB	625	if (partition != -1) {
	626	ret = find_partition(bs, partition, &dev_offset, &fd_size);
	627	if (ret < 0) {
	628	errno = -ret;
	629	err(EXIT_FAILURE, "Could not find partition %d", partition);
	630	}
802ddc37 PB	631	}
802ddc37 PB	632
7860a380	633	exp = nbd_export_new(bs, dev_offset, fd_size, nbdflags, nbd_export_closed);
3b05a8e9	634
b32f6c28	635	if (sockpath) {
a61c6782	636	fd = unix_socket_incoming(sockpath);
cd831bd7	637	} else {
a61c6782	638	fd = tcp_socket_incoming(bindto, port);
cd831bd7 TS	639	}
cd831bd7 TS	640
fc19f8a0	641	if (fd < 0) {
7a5ca864	642	return 1;
a61c6782	643	}
f1ef5555 PB	644
	645	if (device) {
	646	int ret;
	647
a6ac2313	648	ret = pthread_create(&client_thread, NULL, nbd_client_thread, device);
f1ef5555 PB	649	if (ret != 0) {
	650	errx(EXIT_FAILURE, "Failed to create client thread: %s",
	651	strerror(ret));
	652	}
	653	} else {
	654	/* Shut up GCC warnings. */
	655	memset(&client_thread, 0, sizeof(client_thread));
	656	}
	657
a61c6782 PB	658	qemu_set_fd_handler2(fd, nbd_can_accept, nbd_accept, NULL,
a61c6782 PB	659	(void *)(uintptr_t)fd);
7a5ca864	660
9faf31b6 MT	661	/* now when the initialization is (almost) complete, chdir("/")
	662	* to free any busy filesystems */
	663	if (chdir("/") < 0) {
	664	err(EXIT_FAILURE, "Could not chdir to root directory");
	665	}
	666
7860a380	667	state = RUNNING;
3b05a8e9	668	do {
a61c6782	669	main_loop_wait(false);
7860a380 PB	670	if (state == TERMINATE) {
	671	state = TERMINATING;
	672	nbd_export_close(exp);
	673	nbd_export_put(exp);
	674	exp = NULL;
	675	}
	676	} while (state != TERMINATED);
7a5ca864	677
a4aab7b4	678	bdrv_close(bs);
b32f6c28 PB	679	if (sockpath) {
	680	unlink(sockpath);
	681	}
7a5ca864	682
8c116b0e WX	683	if (sn_opts) {
	684	qemu_opts_del(sn_opts);
	685	}
	686
a517e88b PB	687	if (device) {
	688	void *ret;
	689	pthread_join(client_thread, &ret);
	690	exit(ret != NULL);
	691	} else {
	692	exit(EXIT_SUCCESS);
	693	}
7a5ca864	694	}