[qemu.git] / qemu-sockets.c

/*
 *  inet and unix socket functions for qemu
 *
 *  (c) 2008 Gerd Hoffmann <kraxel@redhat.com>
 *
 *  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.
 *
 * Contributions after 2012-01-13 are licensed under the terms of the
 * GNU GPL, version 2 or (at your option) any later version.
 */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <unistd.h>

#include "qemu_socket.h"
#include "qemu-common.h" /* for qemu_isdigit */

#ifndef AI_ADDRCONFIG
# define AI_ADDRCONFIG 0
#endif

static const int on=1, off=0;

/* used temporarely until all users are converted to QemuOpts */
static QemuOptsList dummy_opts = {
    .name = "dummy",
    .head = QTAILQ_HEAD_INITIALIZER(dummy_opts.head),
    .desc = {
        {
            .name = "path",
            .type = QEMU_OPT_STRING,
        },{
            .name = "host",
            .type = QEMU_OPT_STRING,
        },{
            .name = "port",
            .type = QEMU_OPT_STRING,
        },{
            .name = "to",
            .type = QEMU_OPT_NUMBER,
        },{
            .name = "ipv4",
            .type = QEMU_OPT_BOOL,
        },{
            .name = "ipv6",
            .type = QEMU_OPT_BOOL,
        },{
            .name = "block",
            .type = QEMU_OPT_BOOL,
        },
        { /* end if list */ }
    },
};

static int inet_getport(struct addrinfo *e)
{
    struct sockaddr_in *i4;
    struct sockaddr_in6 *i6;

    switch (e->ai_family) {
    case PF_INET6:
        i6 = (void*)e->ai_addr;
        return ntohs(i6->sin6_port);
    case PF_INET:
        i4 = (void*)e->ai_addr;
        return ntohs(i4->sin_port);
    default:
        return 0;
    }
}

static void inet_setport(struct addrinfo *e, int port)
{
    struct sockaddr_in *i4;
    struct sockaddr_in6 *i6;

    switch (e->ai_family) {
    case PF_INET6:
        i6 = (void*)e->ai_addr;
        i6->sin6_port = htons(port);
        break;
    case PF_INET:
        i4 = (void*)e->ai_addr;
        i4->sin_port = htons(port);
        break;
    }
}

const char *inet_strfamily(int family)
{
    switch (family) {
    case PF_INET6: return "ipv6";
    case PF_INET:  return "ipv4";
    case PF_UNIX:  return "unix";
    }
    return "unknown";
}

int inet_listen_opts(QemuOpts *opts, int port_offset, Error **errp)
{
    struct addrinfo ai,*res,*e;
    const char *addr;
    char port[33];
    char uaddr[INET6_ADDRSTRLEN+1];
    char uport[33];
    int slisten, rc, to, port_min, port_max, p;

    memset(&ai,0, sizeof(ai));
    ai.ai_flags = AI_PASSIVE | AI_ADDRCONFIG;
    ai.ai_family = PF_UNSPEC;
    ai.ai_socktype = SOCK_STREAM;

    if ((qemu_opt_get(opts, "host") == NULL) ||
        (qemu_opt_get(opts, "port") == NULL)) {
        fprintf(stderr, "%s: host and/or port not specified\n", __FUNCTION__);
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
        return -1;
    }
    pstrcpy(port, sizeof(port), qemu_opt_get(opts, "port"));
    addr = qemu_opt_get(opts, "host");

    to = qemu_opt_get_number(opts, "to", 0);
    if (qemu_opt_get_bool(opts, "ipv4", 0))
        ai.ai_family = PF_INET;
    if (qemu_opt_get_bool(opts, "ipv6", 0))
        ai.ai_family = PF_INET6;

    /* lookup */
    if (port_offset)
        snprintf(port, sizeof(port), "%d", atoi(port) + port_offset);
    rc = getaddrinfo(strlen(addr) ? addr : NULL, port, &ai, &res);
    if (rc != 0) {
        fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
                gai_strerror(rc));
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
        return -1;
    }

    /* create socket + bind */
    for (e = res; e != NULL; e = e->ai_next) {
        getnameinfo((struct sockaddr*)e->ai_addr,e->ai_addrlen,
		        uaddr,INET6_ADDRSTRLEN,uport,32,
		        NI_NUMERICHOST | NI_NUMERICSERV);
        slisten = qemu_socket(e->ai_family, e->ai_socktype, e->ai_protocol);
        if (slisten < 0) {
            fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
                    inet_strfamily(e->ai_family), strerror(errno));
            if (!e->ai_next) {
                error_set(errp, QERR_SOCKET_CREATE_FAILED);
            }
            continue;
        }

        setsockopt(slisten,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));
#ifdef IPV6_V6ONLY
        if (e->ai_family == PF_INET6) {
            /* listen on both ipv4 and ipv6 */
            setsockopt(slisten,IPPROTO_IPV6,IPV6_V6ONLY,(void*)&off,
                sizeof(off));
        }
#endif

        port_min = inet_getport(e);
        port_max = to ? to + port_offset : port_min;
        for (p = port_min; p <= port_max; p++) {
            inet_setport(e, p);
            if (bind(slisten, e->ai_addr, e->ai_addrlen) == 0) {
                goto listen;
            }
            if (p == port_max) {
                fprintf(stderr,"%s: bind(%s,%s,%d): %s\n", __FUNCTION__,
                        inet_strfamily(e->ai_family), uaddr, inet_getport(e),
                        strerror(errno));
                if (!e->ai_next) {
                    error_set(errp, QERR_SOCKET_BIND_FAILED);
                }
            }
        }
        closesocket(slisten);
    }
    fprintf(stderr, "%s: FAILED\n", __FUNCTION__);
    freeaddrinfo(res);
    return -1;

listen:
    if (listen(slisten,1) != 0) {
        error_set(errp, QERR_SOCKET_LISTEN_FAILED);
        perror("listen");
        closesocket(slisten);
        freeaddrinfo(res);
        return -1;
    }
    snprintf(uport, sizeof(uport), "%d", inet_getport(e) - port_offset);
    qemu_opt_set(opts, "host", uaddr);
    qemu_opt_set(opts, "port", uport);
    qemu_opt_set(opts, "ipv6", (e->ai_family == PF_INET6) ? "on" : "off");
    qemu_opt_set(opts, "ipv4", (e->ai_family != PF_INET6) ? "on" : "off");
    freeaddrinfo(res);
    return slisten;
}

int inet_connect_opts(QemuOpts *opts, bool *in_progress, Error **errp)
{
    struct addrinfo ai,*res,*e;
    const char *addr;
    const char *port;
    char uaddr[INET6_ADDRSTRLEN+1];
    char uport[33];
    int sock,rc;
    bool block;

    memset(&ai,0, sizeof(ai));
    ai.ai_flags = AI_CANONNAME | AI_ADDRCONFIG;
    ai.ai_family = PF_UNSPEC;
    ai.ai_socktype = SOCK_STREAM;

    if (in_progress) {
        *in_progress = false;
    }

    addr = qemu_opt_get(opts, "host");
    port = qemu_opt_get(opts, "port");
    block = qemu_opt_get_bool(opts, "block", 0);
    if (addr == NULL || port == NULL) {
        fprintf(stderr, "inet_connect: host and/or port not specified\n");
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
        return -1;
    }

    if (qemu_opt_get_bool(opts, "ipv4", 0))
        ai.ai_family = PF_INET;
    if (qemu_opt_get_bool(opts, "ipv6", 0))
        ai.ai_family = PF_INET6;

    /* lookup */
    if (0 != (rc = getaddrinfo(addr, port, &ai, &res))) {
        fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
                gai_strerror(rc));
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
	return -1;
    }

    for (e = res; e != NULL; e = e->ai_next) {
        if (getnameinfo((struct sockaddr*)e->ai_addr,e->ai_addrlen,
                            uaddr,INET6_ADDRSTRLEN,uport,32,
                            NI_NUMERICHOST | NI_NUMERICSERV) != 0) {
            fprintf(stderr,"%s: getnameinfo: oops\n", __FUNCTION__);
            continue;
        }
        sock = qemu_socket(e->ai_family, e->ai_socktype, e->ai_protocol);
        if (sock < 0) {
            fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
            inet_strfamily(e->ai_family), strerror(errno));
            continue;
        }
        setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));
        if (!block) {
            socket_set_nonblock(sock);
        }
        /* connect to peer */
        do {
            rc = 0;
            if (connect(sock, e->ai_addr, e->ai_addrlen) < 0) {
                rc = -socket_error();
            }
        } while (rc == -EINTR);

  #ifdef _WIN32
        if (!block && (rc == -EINPROGRESS || rc == -EWOULDBLOCK
                       || rc == -WSAEALREADY)) {
  #else
        if (!block && (rc == -EINPROGRESS)) {
  #endif
            if (in_progress) {
                *in_progress = true;
            }
        } else if (rc < 0) {
            if (NULL == e->ai_next)
                fprintf(stderr, "%s: connect(%s,%s,%s,%s): %s\n", __FUNCTION__,
                        inet_strfamily(e->ai_family),
                        e->ai_canonname, uaddr, uport, strerror(errno));
            closesocket(sock);
            continue;
        }
        freeaddrinfo(res);
        return sock;
    }
    error_set(errp, QERR_SOCKET_CONNECT_FAILED);
    freeaddrinfo(res);
    return -1;
}

int inet_dgram_opts(QemuOpts *opts)
{
    struct addrinfo ai, *peer = NULL, *local = NULL;
    const char *addr;
    const char *port;
    char uaddr[INET6_ADDRSTRLEN+1];
    char uport[33];
    int sock = -1, rc;

    /* lookup peer addr */
    memset(&ai,0, sizeof(ai));
    ai.ai_flags = AI_CANONNAME | AI_ADDRCONFIG;
    ai.ai_family = PF_UNSPEC;
    ai.ai_socktype = SOCK_DGRAM;

    addr = qemu_opt_get(opts, "host");
    port = qemu_opt_get(opts, "port");
    if (addr == NULL || strlen(addr) == 0) {
        addr = "localhost";
    }
    if (port == NULL || strlen(port) == 0) {
        fprintf(stderr, "inet_dgram: port not specified\n");
        return -1;
    }

    if (qemu_opt_get_bool(opts, "ipv4", 0))
        ai.ai_family = PF_INET;
    if (qemu_opt_get_bool(opts, "ipv6", 0))
        ai.ai_family = PF_INET6;

    if (0 != (rc = getaddrinfo(addr, port, &ai, &peer))) {
        fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
                gai_strerror(rc));
	return -1;
    }

    /* lookup local addr */
    memset(&ai,0, sizeof(ai));
    ai.ai_flags = AI_PASSIVE;
    ai.ai_family = peer->ai_family;
    ai.ai_socktype = SOCK_DGRAM;

    addr = qemu_opt_get(opts, "localaddr");
    port = qemu_opt_get(opts, "localport");
    if (addr == NULL || strlen(addr) == 0) {
        addr = NULL;
    }
    if (!port || strlen(port) == 0)
        port = "0";

    if (0 != (rc = getaddrinfo(addr, port, &ai, &local))) {
        fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
                gai_strerror(rc));
        return -1;
    }

    /* create socket */
    sock = qemu_socket(peer->ai_family, peer->ai_socktype, peer->ai_protocol);
    if (sock < 0) {
        fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
                inet_strfamily(peer->ai_family), strerror(errno));
        goto err;
    }
    setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));

    /* bind socket */
    if (getnameinfo((struct sockaddr*)local->ai_addr,local->ai_addrlen,
                    uaddr,INET6_ADDRSTRLEN,uport,32,
                    NI_NUMERICHOST | NI_NUMERICSERV) != 0) {
        fprintf(stderr, "%s: getnameinfo: oops\n", __FUNCTION__);
        goto err;
    }
    if (bind(sock, local->ai_addr, local->ai_addrlen) < 0) {
        fprintf(stderr,"%s: bind(%s,%s,%d): OK\n", __FUNCTION__,
                inet_strfamily(local->ai_family), uaddr, inet_getport(local));
        goto err;
    }

    /* connect to peer */
    if (getnameinfo((struct sockaddr*)peer->ai_addr, peer->ai_addrlen,
                    uaddr, INET6_ADDRSTRLEN, uport, 32,
                    NI_NUMERICHOST | NI_NUMERICSERV) != 0) {
        fprintf(stderr, "%s: getnameinfo: oops\n", __FUNCTION__);
        goto err;
    }
    if (connect(sock,peer->ai_addr,peer->ai_addrlen) < 0) {
        fprintf(stderr, "%s: connect(%s,%s,%s,%s): %s\n", __FUNCTION__,
                inet_strfamily(peer->ai_family),
                peer->ai_canonname, uaddr, uport, strerror(errno));
        goto err;
    }

    freeaddrinfo(local);
    freeaddrinfo(peer);
    return sock;

err:
    if (-1 != sock)
        closesocket(sock);
    if (local)
        freeaddrinfo(local);
    if (peer)
        freeaddrinfo(peer);
    return -1;
}

/* compatibility wrapper */
static int inet_parse(QemuOpts *opts, const char *str)
{
    const char *optstr, *h;
    char addr[64];
    char port[33];
    int pos;

    /* parse address */
    if (str[0] == ':') {
        /* no host given */
        addr[0] = '\0';
        if (1 != sscanf(str,":%32[^,]%n",port,&pos)) {
            fprintf(stderr, "%s: portonly parse error (%s)\n",
                    __FUNCTION__, str);
            return -1;
        }
    } else if (str[0] == '[') {
        /* IPv6 addr */
        if (2 != sscanf(str,"[%64[^]]]:%32[^,]%n",addr,port,&pos)) {
            fprintf(stderr, "%s: ipv6 parse error (%s)\n",
                    __FUNCTION__, str);
            return -1;
        }
        qemu_opt_set(opts, "ipv6", "on");
    } else if (qemu_isdigit(str[0])) {
        /* IPv4 addr */
        if (2 != sscanf(str,"%64[0-9.]:%32[^,]%n",addr,port,&pos)) {
            fprintf(stderr, "%s: ipv4 parse error (%s)\n",
                    __FUNCTION__, str);
            return -1;
        }
        qemu_opt_set(opts, "ipv4", "on");
    } else {
        /* hostname */
        if (2 != sscanf(str,"%64[^:]:%32[^,]%n",addr,port,&pos)) {
            fprintf(stderr, "%s: hostname parse error (%s)\n",
                    __FUNCTION__, str);
            return -1;
        }
    }
    qemu_opt_set(opts, "host", addr);
    qemu_opt_set(opts, "port", port);

    /* parse options */
    optstr = str + pos;
    h = strstr(optstr, ",to=");
    if (h)
        qemu_opt_set(opts, "to", h+4);
    if (strstr(optstr, ",ipv4"))
        qemu_opt_set(opts, "ipv4", "on");
    if (strstr(optstr, ",ipv6"))
        qemu_opt_set(opts, "ipv6", "on");
    return 0;
}

int inet_listen(const char *str, char *ostr, int olen,
                int socktype, int port_offset, Error **errp)
{
    QemuOpts *opts;
    char *optstr;
    int sock = -1;

    opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
    if (inet_parse(opts, str) == 0) {
        sock = inet_listen_opts(opts, port_offset, errp);
        if (sock != -1 && ostr) {
            optstr = strchr(str, ',');
            if (qemu_opt_get_bool(opts, "ipv6", 0)) {
                snprintf(ostr, olen, "[%s]:%s%s",
                         qemu_opt_get(opts, "host"),
                         qemu_opt_get(opts, "port"),
                         optstr ? optstr : "");
            } else {
                snprintf(ostr, olen, "%s:%s%s",
                         qemu_opt_get(opts, "host"),
                         qemu_opt_get(opts, "port"),
                         optstr ? optstr : "");
            }
        }
    } else {
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
    }
    qemu_opts_del(opts);
    return sock;
}

int inet_connect(const char *str, bool block, bool *in_progress, Error **errp)
{
    QemuOpts *opts;
    int sock = -1;

    opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
    if (inet_parse(opts, str) == 0) {
        if (block) {
            qemu_opt_set(opts, "block", "on");
        }
        sock = inet_connect_opts(opts, in_progress, errp);
    } else {
        error_set(errp, QERR_SOCKET_CREATE_FAILED);
    }
    qemu_opts_del(opts);
    return sock;
}

#ifndef _WIN32

int unix_listen_opts(QemuOpts *opts)
{
    struct sockaddr_un un;
    const char *path = qemu_opt_get(opts, "path");
    int sock, fd;

    sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
    if (sock < 0) {
        perror("socket(unix)");
        return -1;
    }

    memset(&un, 0, sizeof(un));
    un.sun_family = AF_UNIX;
    if (path && strlen(path)) {
        snprintf(un.sun_path, sizeof(un.sun_path), "%s", path);
    } else {
        char *tmpdir = getenv("TMPDIR");
        snprintf(un.sun_path, sizeof(un.sun_path), "%s/qemu-socket-XXXXXX",
                 tmpdir ? tmpdir : "/tmp");
        /*
         * This dummy fd usage silences the mktemp() unsecure warning.
         * Using mkstemp() doesn't make things more secure here
         * though.  bind() complains about existing files, so we have
         * to unlink first and thus re-open the race window.  The
         * worst case possible is bind() failing, i.e. a DoS attack.
         */
        fd = mkstemp(un.sun_path); close(fd);
        qemu_opt_set(opts, "path", un.sun_path);
    }

    unlink(un.sun_path);
    if (bind(sock, (struct sockaddr*) &un, sizeof(un)) < 0) {
        fprintf(stderr, "bind(unix:%s): %s\n", un.sun_path, strerror(errno));
        goto err;
    }
    if (listen(sock, 1) < 0) {
        fprintf(stderr, "listen(unix:%s): %s\n", un.sun_path, strerror(errno));
        goto err;
    }

    return sock;

err:
    closesocket(sock);
    return -1;
}

int unix_connect_opts(QemuOpts *opts)
{
    struct sockaddr_un un;
    const char *path = qemu_opt_get(opts, "path");
    int sock;

    if (NULL == path) {
        fprintf(stderr, "unix connect: no path specified\n");
        return -1;
    }

    sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
    if (sock < 0) {
        perror("socket(unix)");
        return -1;
    }

    memset(&un, 0, sizeof(un));
    un.sun_family = AF_UNIX;
    snprintf(un.sun_path, sizeof(un.sun_path), "%s", path);
    if (connect(sock, (struct sockaddr*) &un, sizeof(un)) < 0) {
        fprintf(stderr, "connect(unix:%s): %s\n", path, strerror(errno));
        close(sock);
	return -1;
    }

    return sock;
}

/* compatibility wrapper */
int unix_listen(const char *str, char *ostr, int olen)
{
    QemuOpts *opts;
    char *path, *optstr;
    int sock, len;

    opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);

    optstr = strchr(str, ',');
    if (optstr) {
        len = optstr - str;
        if (len) {
            path = g_malloc(len+1);
            snprintf(path, len+1, "%.*s", len, str);
            qemu_opt_set(opts, "path", path);
            g_free(path);
        }
    } else {
        qemu_opt_set(opts, "path", str);
    }

    sock = unix_listen_opts(opts);

    if (sock != -1 && ostr)
        snprintf(ostr, olen, "%s%s", qemu_opt_get(opts, "path"), optstr ? optstr : "");
    qemu_opts_del(opts);
    return sock;
}

int unix_connect(const char *path)
{
    QemuOpts *opts;
    int sock;

    opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
    qemu_opt_set(opts, "path", path);
    sock = unix_connect_opts(opts);
    qemu_opts_del(opts);
    return sock;
}

#else

int unix_listen_opts(QemuOpts *opts)
{
    fprintf(stderr, "unix sockets are not available on windows\n");
    errno = ENOTSUP;
    return -1;
}

int unix_connect_opts(QemuOpts *opts)
{
    fprintf(stderr, "unix sockets are not available on windows\n");
    errno = ENOTSUP;
    return -1;
}

int unix_listen(const char *path, char *ostr, int olen)
{
    fprintf(stderr, "unix sockets are not available on windows\n");
    errno = ENOTSUP;
    return -1;
}

int unix_connect(const char *path)
{
    fprintf(stderr, "unix sockets are not available on windows\n");
    errno = ENOTSUP;
    return -1;
}

#endif

#ifdef _WIN32
static void socket_cleanup(void)
{
    WSACleanup();
}
#endif

int socket_init(void)
{
#ifdef _WIN32
    WSADATA Data;
    int ret, err;

    ret = WSAStartup(MAKEWORD(2,2), &Data);
    if (ret != 0) {
        err = WSAGetLastError();
        fprintf(stderr, "WSAStartup: %d\n", err);
        return -1;
    }
    atexit(socket_cleanup);
#endif
    return 0;
}
Commit	Line	Data
305b0eb2 AL	1	/*
	2	* inet and unix socket functions for qemu
	3	*
	4	* (c) 2008 Gerd Hoffmann <kraxel@redhat.com>
	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.
e6d91ab6 PB	14	*
	15	* Contributions after 2012-01-13 are licensed under the terms of the
	16	* GNU GPL, version 2 or (at your option) any later version.
305b0eb2	17	*/
d247d25f AL	18	#include <stdio.h>
	19	#include <stdlib.h>
	20	#include <string.h>
	21	#include <ctype.h>
	22	#include <errno.h>
	23	#include <unistd.h>
	24
	25	#include "qemu_socket.h"
47398b9c	26	#include "qemu-common.h" /* for qemu_isdigit */
d247d25f AL	27
	28	#ifndef AI_ADDRCONFIG
	29	# define AI_ADDRCONFIG 0
	30	#endif
	31
d247d25f AL	32	static const int on=1, off=0;
d247d25f AL	33
2af2bf67	34	/* used temporarely until all users are converted to QemuOpts */
c1390903	35	static QemuOptsList dummy_opts = {
2af2bf67	36	.name = "dummy",
72cf2d4f	37	.head = QTAILQ_HEAD_INITIALIZER(dummy_opts.head),
2af2bf67 GH	38	.desc = {
	39	{
	40	.name = "path",
	41	.type = QEMU_OPT_STRING,
f4c94c7c GH	42	},{
	43	.name = "host",
	44	.type = QEMU_OPT_STRING,
	45	},{
	46	.name = "port",
	47	.type = QEMU_OPT_STRING,
	48	},{
	49	.name = "to",
	50	.type = QEMU_OPT_NUMBER,
	51	},{
	52	.name = "ipv4",
	53	.type = QEMU_OPT_BOOL,
	54	},{
	55	.name = "ipv6",
	56	.type = QEMU_OPT_BOOL,
a6ba35b3 AK	57	},{
	58	.name = "block",
	59	.type = QEMU_OPT_BOOL,
2af2bf67 GH	60	},
	61	{ /* end if list */ }
	62	},
	63	};
	64
d247d25f AL	65	static int inet_getport(struct addrinfo *e)
	66	{
	67	struct sockaddr_in *i4;
	68	struct sockaddr_in6 *i6;
	69
	70	switch (e->ai_family) {
	71	case PF_INET6:
	72	i6 = (void*)e->ai_addr;
	73	return ntohs(i6->sin6_port);
	74	case PF_INET:
	75	i4 = (void*)e->ai_addr;
	76	return ntohs(i4->sin_port);
	77	default:
	78	return 0;
	79	}
	80	}
	81
	82	static void inet_setport(struct addrinfo *e, int port)
	83	{
	84	struct sockaddr_in *i4;
	85	struct sockaddr_in6 *i6;
	86
	87	switch (e->ai_family) {
	88	case PF_INET6:
	89	i6 = (void*)e->ai_addr;
	90	i6->sin6_port = htons(port);
	91	break;
	92	case PF_INET:
	93	i4 = (void*)e->ai_addr;
	94	i4->sin_port = htons(port);
	95	break;
	96	}
	97	}
	98
c9c4b34e	99	const char *inet_strfamily(int family)
d247d25f AL	100	{
	101	switch (family) {
	102	case PF_INET6: return "ipv6";
	103	case PF_INET: return "ipv4";
	104	case PF_UNIX: return "unix";
	105	}
c445321e	106	return "unknown";
d247d25f AL	107	}
d247d25f AL	108
029409e5	109	int inet_listen_opts(QemuOpts opts, int port_offset, Error *errp)
d247d25f AL	110	{
d247d25f AL	111	struct addrinfo ai,res,e;
e5bc776f	112	const char *addr;
d247d25f AL	113	char port[33];
	114	char uaddr[INET6_ADDRSTRLEN+1];
	115	char uport[33];
877691f9	116	int slisten, rc, to, port_min, port_max, p;
d247d25f AL	117
	118	memset(&ai,0, sizeof(ai));
	119	ai.ai_flags = AI_PASSIVE \| AI_ADDRCONFIG;
	120	ai.ai_family = PF_UNSPEC;
e5bc776f	121	ai.ai_socktype = SOCK_STREAM;
d247d25f	122
e23a22e6 JO	123	if ((qemu_opt_get(opts, "host") == NULL) \|\|
e23a22e6 JO	124	(qemu_opt_get(opts, "port") == NULL)) {
e5bc776f	125	fprintf(stderr, "%s: host and/or port not specified\n", __FUNCTION__);
029409e5	126	error_set(errp, QERR_SOCKET_CREATE_FAILED);
e5bc776f	127	return -1;
d247d25f	128	}
e5bc776f GH	129	pstrcpy(port, sizeof(port), qemu_opt_get(opts, "port"));
e5bc776f GH	130	addr = qemu_opt_get(opts, "host");
d247d25f	131
e5bc776f GH	132	to = qemu_opt_get_number(opts, "to", 0);
e5bc776f GH	133	if (qemu_opt_get_bool(opts, "ipv4", 0))
d247d25f	134	ai.ai_family = PF_INET;
e5bc776f	135	if (qemu_opt_get_bool(opts, "ipv6", 0))
d247d25f AL	136	ai.ai_family = PF_INET6;
	137
	138	/* lookup */
	139	if (port_offset)
	140	snprintf(port, sizeof(port), "%d", atoi(port) + port_offset);
	141	rc = getaddrinfo(strlen(addr) ? addr : NULL, port, &ai, &res);
	142	if (rc != 0) {
e5bc776f GH	143	fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
e5bc776f GH	144	gai_strerror(rc));
029409e5	145	error_set(errp, QERR_SOCKET_CREATE_FAILED);
d247d25f AL	146	return -1;
d247d25f AL	147	}
d247d25f AL	148
	149	/* create socket + bind */
	150	for (e = res; e != NULL; e = e->ai_next) {
39b6efc8	151	getnameinfo((struct sockaddr*)e->ai_addr,e->ai_addrlen,
	152	uaddr,INET6_ADDRSTRLEN,uport,32,
	153	NI_NUMERICHOST \| NI_NUMERICSERV);
40ff6d7e	154	slisten = qemu_socket(e->ai_family, e->ai_socktype, e->ai_protocol);
39b6efc8	155	if (slisten < 0) {
d247d25f AL	156	fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
d247d25f AL	157	inet_strfamily(e->ai_family), strerror(errno));
029409e5 AK	158	if (!e->ai_next) {
	159	error_set(errp, QERR_SOCKET_CREATE_FAILED);
	160	}
39b6efc8	161	continue;
39b6efc8	162	}
d247d25f AL	163
	164	setsockopt(slisten,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));
	165	#ifdef IPV6_V6ONLY
	166	if (e->ai_family == PF_INET6) {
	167	/* listen on both ipv4 and ipv6 */
39b6efc8	168	setsockopt(slisten,IPPROTO_IPV6,IPV6_V6ONLY,(void*)&off,
39b6efc8	169	sizeof(off));
d247d25f AL	170	}
	171	#endif
	172
877691f9 MA	173	port_min = inet_getport(e);
	174	port_max = to ? to + port_offset : port_min;
	175	for (p = port_min; p <= port_max; p++) {
	176	inet_setport(e, p);
d247d25f	177	if (bind(slisten, e->ai_addr, e->ai_addrlen) == 0) {
d247d25f AL	178	goto listen;
d247d25f AL	179	}
877691f9	180	if (p == port_max) {
d247d25f AL	181	fprintf(stderr,"%s: bind(%s,%s,%d): %s\n", __FUNCTION__,
	182	inet_strfamily(e->ai_family), uaddr, inet_getport(e),
	183	strerror(errno));
029409e5 AK	184	if (!e->ai_next) {
	185	error_set(errp, QERR_SOCKET_BIND_FAILED);
	186	}
d247d25f	187	}
d247d25f AL	188	}
	189	closesocket(slisten);
	190	}
	191	fprintf(stderr, "%s: FAILED\n", __FUNCTION__);
	192	freeaddrinfo(res);
	193	return -1;
	194
	195	listen:
	196	if (listen(slisten,1) != 0) {
029409e5	197	error_set(errp, QERR_SOCKET_LISTEN_FAILED);
d247d25f AL	198	perror("listen");
d247d25f AL	199	closesocket(slisten);
39b6efc8	200	freeaddrinfo(res);
d247d25f AL	201	return -1;
d247d25f AL	202	}
e5bc776f GH	203	snprintf(uport, sizeof(uport), "%d", inet_getport(e) - port_offset);
	204	qemu_opt_set(opts, "host", uaddr);
	205	qemu_opt_set(opts, "port", uport);
	206	qemu_opt_set(opts, "ipv6", (e->ai_family == PF_INET6) ? "on" : "off");
	207	qemu_opt_set(opts, "ipv4", (e->ai_family != PF_INET6) ? "on" : "off");
d247d25f AL	208	freeaddrinfo(res);
	209	return slisten;
	210	}
	211
02a08fef	212	int inet_connect_opts(QemuOpts opts, bool in_progress, Error **errp)
d247d25f AL	213	{
d247d25f AL	214	struct addrinfo ai,res,e;
f4c94c7c GH	215	const char *addr;
f4c94c7c GH	216	const char *port;
d247d25f AL	217	char uaddr[INET6_ADDRSTRLEN+1];
	218	char uport[33];
	219	int sock,rc;
a6ba35b3	220	bool block;
d247d25f AL	221
	222	memset(&ai,0, sizeof(ai));
	223	ai.ai_flags = AI_CANONNAME \| AI_ADDRCONFIG;
	224	ai.ai_family = PF_UNSPEC;
f4c94c7c	225	ai.ai_socktype = SOCK_STREAM;
d247d25f	226
02a08fef LC	227	if (in_progress) {
	228	*in_progress = false;
	229	}
	230
f4c94c7c GH	231	addr = qemu_opt_get(opts, "host");
f4c94c7c GH	232	port = qemu_opt_get(opts, "port");
a6ba35b3	233	block = qemu_opt_get_bool(opts, "block", 0);
f4c94c7c GH	234	if (addr == NULL \|\| port == NULL) {
f4c94c7c GH	235	fprintf(stderr, "inet_connect: host and/or port not specified\n");
a6ba35b3	236	error_set(errp, QERR_SOCKET_CREATE_FAILED);
f4c94c7c	237	return -1;
d247d25f AL	238	}
d247d25f AL	239
f4c94c7c	240	if (qemu_opt_get_bool(opts, "ipv4", 0))
d247d25f	241	ai.ai_family = PF_INET;
f4c94c7c	242	if (qemu_opt_get_bool(opts, "ipv6", 0))
d247d25f AL	243	ai.ai_family = PF_INET6;
	244
	245	/* lookup */
	246	if (0 != (rc = getaddrinfo(addr, port, &ai, &res))) {
f4c94c7c GH	247	fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
f4c94c7c GH	248	gai_strerror(rc));
a6ba35b3	249	error_set(errp, QERR_SOCKET_CREATE_FAILED);
d247d25f AL	250	return -1;
d247d25f AL	251	}
d247d25f AL	252
d247d25f AL	253	for (e = res; e != NULL; e = e->ai_next) {
39b6efc8	254	if (getnameinfo((struct sockaddr*)e->ai_addr,e->ai_addrlen,
	255	uaddr,INET6_ADDRSTRLEN,uport,32,
	256	NI_NUMERICHOST \| NI_NUMERICSERV) != 0) {
d247d25f	257	fprintf(stderr,"%s: getnameinfo: oops\n", __FUNCTION__);
39b6efc8	258	continue;
39b6efc8	259	}
40ff6d7e	260	sock = qemu_socket(e->ai_family, e->ai_socktype, e->ai_protocol);
39b6efc8	261	if (sock < 0) {
d247d25f	262	fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
39b6efc8	263	inet_strfamily(e->ai_family), strerror(errno));
	264	continue;
	265	}
d247d25f	266	setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));
a6ba35b3 AK	267	if (!block) {
	268	socket_set_nonblock(sock);
	269	}
39b6efc8	270	/* connect to peer */
a6ba35b3 AK	271	do {
	272	rc = 0;
	273	if (connect(sock, e->ai_addr, e->ai_addrlen) < 0) {
	274	rc = -socket_error();
	275	}
	276	} while (rc == -EINTR);
	277
	278	#ifdef _WIN32
	279	if (!block && (rc == -EINPROGRESS \|\| rc == -EWOULDBLOCK
	280	\|\| rc == -WSAEALREADY)) {
	281	#else
	282	if (!block && (rc == -EINPROGRESS)) {
	283	#endif
02a08fef LC	284	if (in_progress) {
	285	*in_progress = true;
	286	}
a6ba35b3	287	} else if (rc < 0) {
136faa36	288	if (NULL == e->ai_next)
d247d25f AL	289	fprintf(stderr, "%s: connect(%s,%s,%s,%s): %s\n", __FUNCTION__,
	290	inet_strfamily(e->ai_family),
	291	e->ai_canonname, uaddr, uport, strerror(errno));
	292	closesocket(sock);
39b6efc8	293	continue;
39b6efc8	294	}
d247d25f	295	freeaddrinfo(res);
39b6efc8	296	return sock;
d247d25f	297	}
a6ba35b3	298	error_set(errp, QERR_SOCKET_CONNECT_FAILED);
d247d25f AL	299	freeaddrinfo(res);
	300	return -1;
	301	}
	302
7e1b35b4 GH	303	int inet_dgram_opts(QemuOpts *opts)
	304	{
	305	struct addrinfo ai, peer = NULL, local = NULL;
	306	const char *addr;
	307	const char *port;
	308	char uaddr[INET6_ADDRSTRLEN+1];
	309	char uport[33];
	310	int sock = -1, rc;
	311
	312	/* lookup peer addr */
	313	memset(&ai,0, sizeof(ai));
	314	ai.ai_flags = AI_CANONNAME \| AI_ADDRCONFIG;
	315	ai.ai_family = PF_UNSPEC;
	316	ai.ai_socktype = SOCK_DGRAM;
	317
	318	addr = qemu_opt_get(opts, "host");
	319	port = qemu_opt_get(opts, "port");
	320	if (addr == NULL \|\| strlen(addr) == 0) {
	321	addr = "localhost";
	322	}
	323	if (port == NULL \|\| strlen(port) == 0) {
	324	fprintf(stderr, "inet_dgram: port not specified\n");
	325	return -1;
	326	}
	327
	328	if (qemu_opt_get_bool(opts, "ipv4", 0))
	329	ai.ai_family = PF_INET;
	330	if (qemu_opt_get_bool(opts, "ipv6", 0))
	331	ai.ai_family = PF_INET6;
	332
	333	if (0 != (rc = getaddrinfo(addr, port, &ai, &peer))) {
	334	fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
	335	gai_strerror(rc));
	336	return -1;
	337	}
7e1b35b4 GH	338
	339	/* lookup local addr */
	340	memset(&ai,0, sizeof(ai));
	341	ai.ai_flags = AI_PASSIVE;
	342	ai.ai_family = peer->ai_family;
	343	ai.ai_socktype = SOCK_DGRAM;
	344
	345	addr = qemu_opt_get(opts, "localaddr");
	346	port = qemu_opt_get(opts, "localport");
	347	if (addr == NULL \|\| strlen(addr) == 0) {
	348	addr = NULL;
	349	}
	350	if (!port \|\| strlen(port) == 0)
	351	port = "0";
	352
	353	if (0 != (rc = getaddrinfo(addr, port, &ai, &local))) {
	354	fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
	355	gai_strerror(rc));
	356	return -1;
	357	}
7e1b35b4 GH	358
7e1b35b4 GH	359	/* create socket */
40ff6d7e	360	sock = qemu_socket(peer->ai_family, peer->ai_socktype, peer->ai_protocol);
7e1b35b4 GH	361	if (sock < 0) {
	362	fprintf(stderr,"%s: socket(%s): %s\n", __FUNCTION__,
	363	inet_strfamily(peer->ai_family), strerror(errno));
	364	goto err;
	365	}
	366	setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(void*)&on,sizeof(on));
	367
	368	/* bind socket */
	369	if (getnameinfo((struct sockaddr*)local->ai_addr,local->ai_addrlen,
	370	uaddr,INET6_ADDRSTRLEN,uport,32,
	371	NI_NUMERICHOST \| NI_NUMERICSERV) != 0) {
	372	fprintf(stderr, "%s: getnameinfo: oops\n", __FUNCTION__);
	373	goto err;
	374	}
	375	if (bind(sock, local->ai_addr, local->ai_addrlen) < 0) {
	376	fprintf(stderr,"%s: bind(%s,%s,%d): OK\n", __FUNCTION__,
	377	inet_strfamily(local->ai_family), uaddr, inet_getport(local));
	378	goto err;
	379	}
	380
	381	/* connect to peer */
	382	if (getnameinfo((struct sockaddr*)peer->ai_addr, peer->ai_addrlen,
	383	uaddr, INET6_ADDRSTRLEN, uport, 32,
	384	NI_NUMERICHOST \| NI_NUMERICSERV) != 0) {
	385	fprintf(stderr, "%s: getnameinfo: oops\n", __FUNCTION__);
	386	goto err;
	387	}
	388	if (connect(sock,peer->ai_addr,peer->ai_addrlen) < 0) {
	389	fprintf(stderr, "%s: connect(%s,%s,%s,%s): %s\n", __FUNCTION__,
	390	inet_strfamily(peer->ai_family),
	391	peer->ai_canonname, uaddr, uport, strerror(errno));
	392	goto err;
	393	}
	394
	395	freeaddrinfo(local);
	396	freeaddrinfo(peer);
	397	return sock;
	398
	399	err:
	400	if (-1 != sock)
	401	closesocket(sock);
	402	if (local)
	403	freeaddrinfo(local);
	404	if (peer)
	405	freeaddrinfo(peer);
	406	return -1;
	407	}
	408
f4c94c7c GH	409	/* compatibility wrapper */
	410	static int inet_parse(QemuOpts opts, const char str)
	411	{
	412	const char optstr, h;
	413	char addr[64];
	414	char port[33];
	415	int pos;
	416
	417	/* parse address */
	418	if (str[0] == ':') {
	419	/* no host given */
	420	addr[0] = '\0';
	421	if (1 != sscanf(str,":%32[^,]%n",port,&pos)) {
	422	fprintf(stderr, "%s: portonly parse error (%s)\n",
	423	__FUNCTION__, str);
	424	return -1;
	425	}
	426	} else if (str[0] == '[') {
	427	/* IPv6 addr */
	428	if (2 != sscanf(str,"[%64[^]]]:%32[^,]%n",addr,port,&pos)) {
	429	fprintf(stderr, "%s: ipv6 parse error (%s)\n",
	430	__FUNCTION__, str);
	431	return -1;
	432	}
2198a62e	433	qemu_opt_set(opts, "ipv6", "on");
f4c94c7c GH	434	} else if (qemu_isdigit(str[0])) {
	435	/* IPv4 addr */
	436	if (2 != sscanf(str,"%64[0-9.]:%32[^,]%n",addr,port,&pos)) {
	437	fprintf(stderr, "%s: ipv4 parse error (%s)\n",
	438	__FUNCTION__, str);
	439	return -1;
	440	}
2198a62e	441	qemu_opt_set(opts, "ipv4", "on");
f4c94c7c GH	442	} else {
	443	/* hostname */
	444	if (2 != sscanf(str,"%64[^:]:%32[^,]%n",addr,port,&pos)) {
	445	fprintf(stderr, "%s: hostname parse error (%s)\n",
	446	__FUNCTION__, str);
	447	return -1;
	448	}
	449	}
	450	qemu_opt_set(opts, "host", addr);
	451	qemu_opt_set(opts, "port", port);
	452
	453	/* parse options */
	454	optstr = str + pos;
	455	h = strstr(optstr, ",to=");
	456	if (h)
	457	qemu_opt_set(opts, "to", h+4);
	458	if (strstr(optstr, ",ipv4"))
2198a62e	459	qemu_opt_set(opts, "ipv4", "on");
f4c94c7c	460	if (strstr(optstr, ",ipv6"))
2198a62e	461	qemu_opt_set(opts, "ipv6", "on");
f4c94c7c GH	462	return 0;
	463	}
	464
e5bc776f	465	int inet_listen(const char str, char ostr, int olen,
029409e5	466	int socktype, int port_offset, Error **errp)
e5bc776f GH	467	{
	468	QemuOpts *opts;
	469	char *optstr;
	470	int sock = -1;
	471
8be7e7e4	472	opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
e5bc776f	473	if (inet_parse(opts, str) == 0) {
029409e5	474	sock = inet_listen_opts(opts, port_offset, errp);
e5bc776f GH	475	if (sock != -1 && ostr) {
	476	optstr = strchr(str, ',');
	477	if (qemu_opt_get_bool(opts, "ipv6", 0)) {
	478	snprintf(ostr, olen, "[%s]:%s%s",
	479	qemu_opt_get(opts, "host"),
	480	qemu_opt_get(opts, "port"),
	481	optstr ? optstr : "");
	482	} else {
	483	snprintf(ostr, olen, "%s:%s%s",
	484	qemu_opt_get(opts, "host"),
	485	qemu_opt_get(opts, "port"),
	486	optstr ? optstr : "");
	487	}
	488	}
029409e5 AK	489	} else {
029409e5 AK	490	error_set(errp, QERR_SOCKET_CREATE_FAILED);
e5bc776f GH	491	}
	492	qemu_opts_del(opts);
	493	return sock;
	494	}
	495
02a08fef	496	int inet_connect(const char str, bool block, bool in_progress, Error **errp)
f4c94c7c GH	497	{
	498	QemuOpts *opts;
	499	int sock = -1;
	500
8be7e7e4	501	opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
a6ba35b3 AK	502	if (inet_parse(opts, str) == 0) {
	503	if (block) {
	504	qemu_opt_set(opts, "block", "on");
	505	}
02a08fef	506	sock = inet_connect_opts(opts, in_progress, errp);
a6ba35b3 AK	507	} else {
	508	error_set(errp, QERR_SOCKET_CREATE_FAILED);
	509	}
f4c94c7c GH	510	qemu_opts_del(opts);
	511	return sock;
	512	}
	513
d247d25f AL	514	#ifndef _WIN32
d247d25f AL	515
62b6adfb	516	int unix_listen_opts(QemuOpts *opts)
d247d25f AL	517	{
d247d25f AL	518	struct sockaddr_un un;
62b6adfb GH	519	const char *path = qemu_opt_get(opts, "path");
62b6adfb GH	520	int sock, fd;
d247d25f	521
40ff6d7e	522	sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
d247d25f	523	if (sock < 0) {
39b6efc8	524	perror("socket(unix)");
39b6efc8	525	return -1;
d247d25f AL	526	}
d247d25f AL	527
d247d25f AL	528	memset(&un, 0, sizeof(un));
	529	un.sun_family = AF_UNIX;
	530	if (path && strlen(path)) {
	531	snprintf(un.sun_path, sizeof(un.sun_path), "%s", path);
	532	} else {
	533	char *tmpdir = getenv("TMPDIR");
	534	snprintf(un.sun_path, sizeof(un.sun_path), "%s/qemu-socket-XXXXXX",
	535	tmpdir ? tmpdir : "/tmp");
	536	/*
	537	* This dummy fd usage silences the mktemp() unsecure warning.
	538	* Using mkstemp() doesn't make things more secure here
	539	* though. bind() complains about existing files, so we have
	540	* to unlink first and thus re-open the race window. The
	541	* worst case possible is bind() failing, i.e. a DoS attack.
	542	*/
	543	fd = mkstemp(un.sun_path); close(fd);
62b6adfb	544	qemu_opt_set(opts, "path", un.sun_path);
d247d25f	545	}
d247d25f AL	546
	547	unlink(un.sun_path);
	548	if (bind(sock, (struct sockaddr*) &un, sizeof(un)) < 0) {
	549	fprintf(stderr, "bind(unix:%s): %s\n", un.sun_path, strerror(errno));
	550	goto err;
	551	}
	552	if (listen(sock, 1) < 0) {
	553	fprintf(stderr, "listen(unix:%s): %s\n", un.sun_path, strerror(errno));
	554	goto err;
	555	}
	556
d247d25f AL	557	return sock;
	558
	559	err:
d247d25f AL	560	closesocket(sock);
	561	return -1;
	562	}
	563
2af2bf67	564	int unix_connect_opts(QemuOpts *opts)
d247d25f AL	565	{
d247d25f AL	566	struct sockaddr_un un;
2af2bf67	567	const char *path = qemu_opt_get(opts, "path");
d247d25f AL	568	int sock;
d247d25f AL	569
2af2bf67 GH	570	if (NULL == path) {
	571	fprintf(stderr, "unix connect: no path specified\n");
	572	return -1;
	573	}
	574
40ff6d7e	575	sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
d247d25f	576	if (sock < 0) {
39b6efc8	577	perror("socket(unix)");
39b6efc8	578	return -1;
d247d25f AL	579	}
	580
	581	memset(&un, 0, sizeof(un));
	582	un.sun_family = AF_UNIX;
	583	snprintf(un.sun_path, sizeof(un.sun_path), "%s", path);
	584	if (connect(sock, (struct sockaddr*) &un, sizeof(un)) < 0) {
	585	fprintf(stderr, "connect(unix:%s): %s\n", path, strerror(errno));
9d947472	586	close(sock);
d247d25f AL	587	return -1;
	588	}
	589
d247d25f AL	590	return sock;
	591	}
	592
2af2bf67	593	/* compatibility wrapper */
62b6adfb GH	594	int unix_listen(const char str, char ostr, int olen)
	595	{
	596	QemuOpts *opts;
	597	char path, optstr;
	598	int sock, len;
	599
8be7e7e4	600	opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
62b6adfb GH	601
	602	optstr = strchr(str, ',');
	603	if (optstr) {
	604	len = optstr - str;
	605	if (len) {
7267c094	606	path = g_malloc(len+1);
62b6adfb GH	607	snprintf(path, len+1, "%.*s", len, str);
62b6adfb GH	608	qemu_opt_set(opts, "path", path);
7267c094	609	g_free(path);
62b6adfb GH	610	}
	611	} else {
	612	qemu_opt_set(opts, "path", str);
	613	}
	614
	615	sock = unix_listen_opts(opts);
	616
	617	if (sock != -1 && ostr)
	618	snprintf(ostr, olen, "%s%s", qemu_opt_get(opts, "path"), optstr ? optstr : "");
	619	qemu_opts_del(opts);
	620	return sock;
	621	}
	622
2af2bf67 GH	623	int unix_connect(const char *path)
	624	{
	625	QemuOpts *opts;
	626	int sock;
	627
8be7e7e4	628	opts = qemu_opts_create(&dummy_opts, NULL, 0, NULL);
2af2bf67 GH	629	qemu_opt_set(opts, "path", path);
	630	sock = unix_connect_opts(opts);
	631	qemu_opts_del(opts);
	632	return sock;
	633	}
	634
d247d25f AL	635	#else
d247d25f AL	636
108af7b9 GH	637	int unix_listen_opts(QemuOpts *opts)
	638	{
	639	fprintf(stderr, "unix sockets are not available on windows\n");
b82eac92	640	errno = ENOTSUP;
108af7b9 GH	641	return -1;
	642	}
	643
	644	int unix_connect_opts(QemuOpts *opts)
	645	{
	646	fprintf(stderr, "unix sockets are not available on windows\n");
b82eac92	647	errno = ENOTSUP;
108af7b9 GH	648	return -1;
	649	}
	650
d247d25f AL	651	int unix_listen(const char path, char ostr, int olen)
	652	{
	653	fprintf(stderr, "unix sockets are not available on windows\n");
b82eac92	654	errno = ENOTSUP;
d247d25f AL	655	return -1;
	656	}
	657
	658	int unix_connect(const char *path)
	659	{
	660	fprintf(stderr, "unix sockets are not available on windows\n");
b82eac92	661	errno = ENOTSUP;
d247d25f AL	662	return -1;
	663	}
	664
	665	#endif
0706a4dc PB	666
	667	#ifdef _WIN32
	668	static void socket_cleanup(void)
	669	{
	670	WSACleanup();
	671	}
	672	#endif
	673
	674	int socket_init(void)
	675	{
	676	#ifdef _WIN32
	677	WSADATA Data;
	678	int ret, err;
	679
	680	ret = WSAStartup(MAKEWORD(2,2), &Data);
	681	if (ret != 0) {
	682	err = WSAGetLastError();
	683	fprintf(stderr, "WSAStartup: %d\n", err);
	684	return -1;
	685	}
	686	atexit(socket_cleanup);
	687	#endif
	688	return 0;
	689	}