[qemu.git] / qemu-sockets.c

/*
 *  inet and unix socket functions for qemu
 *
 *  (c) 2008 Gerd Hoffmann <[email protected]>
 *
 *  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.
 */
#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,
        },
        { /* 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)
{
    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__);
        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));
        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));
            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));
            }
        }
        closesocket(slisten);
    }
    fprintf(stderr, "%s: FAILED\n", __FUNCTION__);
    freeaddrinfo(res);
    return -1;

listen:
    if (listen(slisten,1) != 0) {
        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)
{
    struct addrinfo ai,*res,*e;
    const char *addr;
    const char *port;
    char uaddr[INET6_ADDRSTRLEN+1];
    char uport[33];
    int sock,rc;

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

    addr = qemu_opt_get(opts, "host");
    port = qemu_opt_get(opts, "port");
    if (addr == NULL || port == NULL) {
        fprintf(stderr, "inet_connect: host and/or 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;

    /* lookup */
    if (0 != (rc = getaddrinfo(addr, port, &ai, &res))) {
        fprintf(stderr,"getaddrinfo(%s,%s): %s\n", addr, port,
                gai_strerror(rc));
	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));

        /* connect to peer */
        if (connect(sock,e->ai_addr,e->ai_addrlen) < 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;
    }
    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)
{
    QemuOpts *opts;
    char *optstr;
    int sock = -1;

    opts = qemu_opts_create(&dummy_opts, NULL, 0);
    if (inet_parse(opts, str) == 0) {
        sock = inet_listen_opts(opts, port_offset);
        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 : "");
            }
        }
    }
    qemu_opts_del(opts);
    return sock;
}

int inet_connect(const char *str, int socktype)
{
    QemuOpts *opts;
    int sock = -1;

    opts = qemu_opts_create(&dummy_opts, NULL, 0);
    if (inet_parse(opts, str) == 0)
        sock = inet_connect_opts(opts);
    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);

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