qemu-sockets.c 26.7 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13
/*
 *  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.
14 15 16
 *
 * Contributions after 2012-01-13 are licensed under the terms of the
 * GNU GPL, version 2 or (at your option) any later version.
17
 */
18 19 20 21 22 23 24
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <unistd.h>

25
#include "monitor/monitor.h"
26 27
#include "qemu/sockets.h"
#include "qemu/main-loop.h"
28 29 30 31 32

#ifndef AI_ADDRCONFIG
# define AI_ADDRCONFIG 0
#endif

33 34 35 36
/* used temporarily until all users are converted to QemuOpts */
QemuOptsList socket_optslist = {
    .name = "socket",
    .head = QTAILQ_HEAD_INITIALIZER(socket_optslist.head),
37 38 39 40
    .desc = {
        {
            .name = "path",
            .type = QEMU_OPT_STRING,
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
        },{
            .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,
56 57 58 59 60
        },
        { /* end if list */ }
    },
};

61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94
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;
    }
}

Wenchao Xia's avatar
Wenchao Xia committed
95 96 97 98 99 100 101 102 103 104
NetworkAddressFamily inet_netfamily(int family)
{
    switch (family) {
    case PF_INET6: return NETWORK_ADDRESS_FAMILY_IPV6;
    case PF_INET:  return NETWORK_ADDRESS_FAMILY_IPV4;
    case PF_UNIX:  return NETWORK_ADDRESS_FAMILY_UNIX;
    }
    return NETWORK_ADDRESS_FAMILY_UNKNOWN;
}

105
int inet_listen_opts(QemuOpts *opts, int port_offset, Error **errp)
106 107
{
    struct addrinfo ai,*res,*e;
108
    const char *addr;
109 110 111
    char port[33];
    char uaddr[INET6_ADDRSTRLEN+1];
    char uport[33];
112
    int slisten, rc, to, port_min, port_max, p;
113 114 115 116

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

119 120
    if ((qemu_opt_get(opts, "host") == NULL) ||
        (qemu_opt_get(opts, "port") == NULL)) {
121
        error_setg(errp, "host and/or port not specified");
122
        return -1;
123
    }
124 125
    pstrcpy(port, sizeof(port), qemu_opt_get(opts, "port"));
    addr = qemu_opt_get(opts, "host");
126

127 128
    to = qemu_opt_get_number(opts, "to", 0);
    if (qemu_opt_get_bool(opts, "ipv4", 0))
129
        ai.ai_family = PF_INET;
130
    if (qemu_opt_get_bool(opts, "ipv6", 0))
131 132 133
        ai.ai_family = PF_INET6;

    /* lookup */
134 135 136 137 138 139 140 141 142 143 144 145 146
    if (port_offset) {
        unsigned long long baseport;
        if (parse_uint_full(port, &baseport, 10) < 0) {
            error_setg(errp, "can't convert to a number: %s", port);
            return -1;
        }
        if (baseport > 65535 ||
            baseport + port_offset > 65535) {
            error_setg(errp, "port %s out of range", port);
            return -1;
        }
        snprintf(port, sizeof(port), "%d", (int)baseport + port_offset);
    }
147 148
    rc = getaddrinfo(strlen(addr) ? addr : NULL, port, &ai, &res);
    if (rc != 0) {
149 150
        error_setg(errp, "address resolution failed for %s:%s: %s", addr, port,
                   gai_strerror(rc));
151 152 153 154 155
        return -1;
    }

    /* create socket + bind */
    for (e = res; e != NULL; e = e->ai_next) {
vibi's avatar
vibi committed
156 157 158
        getnameinfo((struct sockaddr*)e->ai_addr,e->ai_addrlen,
		        uaddr,INET6_ADDRSTRLEN,uport,32,
		        NI_NUMERICHOST | NI_NUMERICSERV);
Kevin Wolf's avatar
Kevin Wolf committed
159
        slisten = qemu_socket(e->ai_family, e->ai_socktype, e->ai_protocol);
vibi's avatar
vibi committed
160
        if (slisten < 0) {
161
            if (!e->ai_next) {
162
                error_setg_errno(errp, errno, "Failed to create socket");
163
            }
vibi's avatar
vibi committed
164 165
            continue;
        }
166

167
        socket_set_fast_reuse(slisten);
168 169 170
#ifdef IPV6_V6ONLY
        if (e->ai_family == PF_INET6) {
            /* listen on both ipv4 and ipv6 */
171
            const int off = 0;
172 173
            qemu_setsockopt(slisten, IPPROTO_IPV6, IPV6_V6ONLY, &off,
                            sizeof(off));
174 175 176
        }
#endif

177 178 179 180
        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);
181 182 183
            if (bind(slisten, e->ai_addr, e->ai_addrlen) == 0) {
                goto listen;
            }
184
            if (p == port_max) {
185
                if (!e->ai_next) {
186
                    error_setg_errno(errp, errno, "Failed to bind socket");
187
                }
188 189 190 191 192 193 194 195 196
            }
        }
        closesocket(slisten);
    }
    freeaddrinfo(res);
    return -1;

listen:
    if (listen(slisten,1) != 0) {
197
        error_setg_errno(errp, errno, "Failed to listen on socket");
198
        closesocket(slisten);
vibi's avatar
vibi committed
199
        freeaddrinfo(res);
200 201
        return -1;
    }
202 203 204 205 206
    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");
207 208 209 210
    freeaddrinfo(res);
    return slisten;
}

211 212 213 214 215 216 217 218
#ifdef _WIN32
#define QEMU_SOCKET_RC_INPROGRESS(rc) \
    ((rc) == -EINPROGRESS || (rc) == -EWOULDBLOCK || (rc) == -WSAEALREADY)
#else
#define QEMU_SOCKET_RC_INPROGRESS(rc) \
    ((rc) == -EINPROGRESS)
#endif

219 220 221 222 223 224 225 226 227 228
/* Struct to store connect state for non blocking connect */
typedef struct ConnectState {
    int fd;
    struct addrinfo *addr_list;
    struct addrinfo *current_addr;
    NonBlockingConnectHandler *callback;
    void *opaque;
} ConnectState;

static int inet_connect_addr(struct addrinfo *addr, bool *in_progress,
229
                             ConnectState *connect_state, Error **errp);
230 231

static void wait_for_connect(void *opaque)
232
{
233 234 235 236 237 238 239 240
    ConnectState *s = opaque;
    int val = 0, rc = 0;
    socklen_t valsize = sizeof(val);
    bool in_progress;

    qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL);

    do {
241
        rc = qemu_getsockopt(s->fd, SOL_SOCKET, SO_ERROR, &val, &valsize);
242 243 244 245 246 247 248 249 250 251 252 253 254 255
    } while (rc == -1 && socket_error() == EINTR);

    /* update rc to contain error */
    if (!rc && val) {
        rc = -1;
    }

    /* connect error */
    if (rc < 0) {
        closesocket(s->fd);
        s->fd = rc;
    }

    /* try to connect to the next address on the list */
256 257 258
    if (s->current_addr) {
        while (s->current_addr->ai_next != NULL && s->fd < 0) {
            s->current_addr = s->current_addr->ai_next;
259
            s->fd = inet_connect_addr(s->current_addr, &in_progress, s, NULL);
260 261 262 263
            /* connect in progress */
            if (in_progress) {
                return;
            }
264
        }
265 266

        freeaddrinfo(s->addr_list);
267
    }
268

269 270
    if (s->callback) {
        s->callback(s->fd, s->opaque);
271
    }
272 273 274 275
    g_free(s);
}

static int inet_connect_addr(struct addrinfo *addr, bool *in_progress,
276
                             ConnectState *connect_state, Error **errp)
277 278 279 280
{
    int sock, rc;

    *in_progress = false;
281 282 283

    sock = qemu_socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol);
    if (sock < 0) {
284
        error_setg_errno(errp, errno, "Failed to create socket");
285 286
        return -1;
    }
287
    socket_set_fast_reuse(sock);
288
    if (connect_state != NULL) {
289
        qemu_set_nonblock(sock);
290 291 292 293 294 295 296 297 298
    }
    /* connect to peer */
    do {
        rc = 0;
        if (connect(sock, addr->ai_addr, addr->ai_addrlen) < 0) {
            rc = -socket_error();
        }
    } while (rc == -EINTR);

299 300 301 302 303
    if (connect_state != NULL && QEMU_SOCKET_RC_INPROGRESS(rc)) {
        connect_state->fd = sock;
        qemu_set_fd_handler2(sock, NULL, NULL, wait_for_connect,
                             connect_state);
        *in_progress = true;
304
    } else if (rc < 0) {
305
        error_setg_errno(errp, errno, "Failed to connect socket");
306 307 308 309 310 311 312 313 314 315
        closesocket(sock);
        return -1;
    }
    return sock;
}

static struct addrinfo *inet_parse_connect_opts(QemuOpts *opts, Error **errp)
{
    struct addrinfo ai, *res;
    int rc;
316 317
    const char *addr;
    const char *port;
318

319
    memset(&ai, 0, sizeof(ai));
320

321 322
    ai.ai_flags = AI_CANONNAME | AI_ADDRCONFIG;
    ai.ai_family = PF_UNSPEC;
323
    ai.ai_socktype = SOCK_STREAM;
324

325 326 327
    addr = qemu_opt_get(opts, "host");
    port = qemu_opt_get(opts, "port");
    if (addr == NULL || port == NULL) {
328
        error_setg(errp, "host and/or port not specified");
329
        return NULL;
330 331
    }

332
    if (qemu_opt_get_bool(opts, "ipv4", 0)) {
333
        ai.ai_family = PF_INET;
334 335
    }
    if (qemu_opt_get_bool(opts, "ipv6", 0)) {
336
        ai.ai_family = PF_INET6;
337
    }
338 339

    /* lookup */
340 341
    rc = getaddrinfo(addr, port, &ai, &res);
    if (rc != 0) {
342 343
        error_setg(errp, "address resolution failed for %s:%s: %s", addr, port,
                   gai_strerror(rc));
344 345 346 347 348
        return NULL;
    }
    return res;
}

349 350 351 352 353 354
/**
 * Create a socket and connect it to an address.
 *
 * @opts: QEMU options, recognized parameters strings "host" and "port",
 *        bools "ipv4" and "ipv6".
 * @errp: set on error
355 356
 * @callback: callback function for non-blocking connect
 * @opaque: opaque for callback function
357 358
 *
 * Returns: -1 on error, file descriptor on success.
359 360 361 362
 *
 * If @callback is non-null, the connect is non-blocking.  If this
 * function succeeds, callback will be called when the connection
 * completes, with the file descriptor on success, or -1 on error.
363
 */
364 365
int inet_connect_opts(QemuOpts *opts, Error **errp,
                      NonBlockingConnectHandler *callback, void *opaque)
366
{
367
    Error *local_err = NULL;
368 369
    struct addrinfo *res, *e;
    int sock = -1;
370 371
    bool in_progress;
    ConnectState *connect_state = NULL;
372 373 374 375 376 377

    res = inet_parse_connect_opts(opts, errp);
    if (!res) {
        return -1;
    }

378 379 380 381 382
    if (callback != NULL) {
        connect_state = g_malloc0(sizeof(*connect_state));
        connect_state->addr_list = res;
        connect_state->callback = callback;
        connect_state->opaque = opaque;
383 384 385
    }

    for (e = res; e != NULL; e = e->ai_next) {
386 387
        error_free(local_err);
        local_err = NULL;
388 389 390
        if (connect_state != NULL) {
            connect_state->current_addr = e;
        }
391 392
        sock = inet_connect_addr(e, &in_progress, connect_state, &local_err);
        if (sock >= 0) {
393
            break;
394
        }
395
    }
396 397 398 399 400 401 402 403 404 405 406

    if (sock < 0) {
        error_propagate(errp, local_err);
    } else if (in_progress) {
        /* wait_for_connect() will do the rest */
        return sock;
    } else {
        if (callback) {
            callback(sock, opaque);
        }
    }
407
    g_free(connect_state);
408
    freeaddrinfo(res);
409
    return sock;
410 411
}

412
int inet_dgram_opts(QemuOpts *opts, Error **errp)
413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430
{
    struct addrinfo ai, *peer = NULL, *local = NULL;
    const char *addr;
    const char *port;
    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) {
431
        error_setg(errp, "remote port not specified");
432 433 434 435 436 437 438 439 440
        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))) {
441 442
        error_setg(errp, "address resolution failed for %s:%s: %s", addr, port,
                   gai_strerror(rc));
443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460
	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))) {
461 462
        error_setg(errp, "address resolution failed for %s:%s: %s", addr, port,
                   gai_strerror(rc));
463
        goto err;
464 465 466
    }

    /* create socket */
Kevin Wolf's avatar
Kevin Wolf committed
467
    sock = qemu_socket(peer->ai_family, peer->ai_socktype, peer->ai_protocol);
468
    if (sock < 0) {
469
        error_setg_errno(errp, errno, "Failed to create socket");
470 471
        goto err;
    }
472
    socket_set_fast_reuse(sock);
473 474 475

    /* bind socket */
    if (bind(sock, local->ai_addr, local->ai_addrlen) < 0) {
476
        error_setg_errno(errp, errno, "Failed to bind socket");
477 478 479 480 481
        goto err;
    }

    /* connect to peer */
    if (connect(sock,peer->ai_addr,peer->ai_addrlen) < 0) {
482
        error_setg_errno(errp, errno, "Failed to connect socket");
483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499
        goto err;
    }

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

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

500
/* compatibility wrapper */
501
InetSocketAddress *inet_parse(const char *str, Error **errp)
502
{
503
    InetSocketAddress *addr;
504
    const char *optstr, *h;
505
    char host[64];
506
    char port[33];
507
    int to;
508 509
    int pos;

510 511
    addr = g_new0(InetSocketAddress, 1);

512 513 514
    /* parse address */
    if (str[0] == ':') {
        /* no host given */
515 516
        host[0] = '\0';
        if (1 != sscanf(str, ":%32[^,]%n", port, &pos)) {
517
            error_setg(errp, "error parsing port in address '%s'", str);
518
            goto fail;
519 520 521
        }
    } else if (str[0] == '[') {
        /* IPv6 addr */
522
        if (2 != sscanf(str, "[%64[^]]]:%32[^,]%n", host, port, &pos)) {
523
            error_setg(errp, "error parsing IPv6 address '%s'", str);
524
            goto fail;
525
        }
526
        addr->ipv6 = addr->has_ipv6 = true;
527
    } else {
528
        /* hostname or IPv4 addr */
529
        if (2 != sscanf(str, "%64[^:]:%32[^,]%n", host, port, &pos)) {
530
            error_setg(errp, "error parsing address '%s'", str);
531
            goto fail;
532
        }
533 534 535
        if (host[strspn(host, "0123456789.")] == '\0') {
            addr->ipv4 = addr->has_ipv4 = true;
        }
536
    }
537 538 539

    addr->host = g_strdup(host);
    addr->port = g_strdup(port);
540 541 542 543

    /* parse options */
    optstr = str + pos;
    h = strstr(optstr, ",to=");
544
    if (h) {
545 546 547
        h += 4;
        if (sscanf(h, "%d%n", &to, &pos) != 1 ||
            (h[pos] != '\0' && h[pos] != ',')) {
548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566
            error_setg(errp, "error parsing to= argument");
            goto fail;
        }
        addr->has_to = true;
        addr->to = to;
    }
    if (strstr(optstr, ",ipv4")) {
        addr->ipv4 = addr->has_ipv4 = true;
    }
    if (strstr(optstr, ",ipv6")) {
        addr->ipv6 = addr->has_ipv6 = true;
    }
    return addr;

fail:
    qapi_free_InetSocketAddress(addr);
    return NULL;
}

567
static void inet_addr_to_opts(QemuOpts *opts, const InetSocketAddress *addr)
568 569 570 571 572 573 574 575 576 577 578 579 580 581 582
{
    bool ipv4 = addr->ipv4 || !addr->has_ipv4;
    bool ipv6 = addr->ipv6 || !addr->has_ipv6;

    if (!ipv4 || !ipv6) {
        qemu_opt_set_bool(opts, "ipv4", ipv4);
        qemu_opt_set_bool(opts, "ipv6", ipv6);
    }
    if (addr->has_to) {
        char to[20];
        snprintf(to, sizeof(to), "%d", addr->to);
        qemu_opt_set(opts, "to", to);
    }
    qemu_opt_set(opts, "host", addr->host);
    qemu_opt_set(opts, "port", addr->port);
583 584
}

585
int inet_listen(const char *str, char *ostr, int olen,
586
                int socktype, int port_offset, Error **errp)
587 588 589 590
{
    QemuOpts *opts;
    char *optstr;
    int sock = -1;
591
    InetSocketAddress *addr;
592

593 594
    addr = inet_parse(str, errp);
    if (addr != NULL) {
595
        opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
596 597
        inet_addr_to_opts(opts, addr);
        qapi_free_InetSocketAddress(addr);
598
        sock = inet_listen_opts(opts, port_offset, errp);
599 600 601 602 603 604 605 606 607 608 609 610 611 612
        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 : "");
            }
        }
613
        qemu_opts_del(opts);
614 615 616 617
    }
    return sock;
}

618 619 620 621 622 623 624 625 626
/**
 * Create a blocking socket and connect it to an address.
 *
 * @str: address string
 * @errp: set in case of an error
 *
 * Returns -1 in case of error, file descriptor on success
 **/
int inet_connect(const char *str, Error **errp)
627 628 629
{
    QemuOpts *opts;
    int sock = -1;
630
    InetSocketAddress *addr;
631

632 633
    addr = inet_parse(str, errp);
    if (addr != NULL) {
634
        opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
635 636
        inet_addr_to_opts(opts, addr);
        qapi_free_InetSocketAddress(addr);
637
        sock = inet_connect_opts(opts, errp, NULL, NULL);
638
        qemu_opts_del(opts);
639 640 641 642 643 644
    }
    return sock;
}

/**
 * Create a non-blocking socket and connect it to an address.
645 646
 * Calls the callback function with fd in case of success or -1 in case of
 * error.
647 648
 *
 * @str: address string
649 650 651
 * @callback: callback function that is called when connect completes,
 *            cannot be NULL.
 * @opaque: opaque for callback function
652 653
 * @errp: set in case of an error
 *
654
 * Returns: -1 on immediate error, file descriptor on success.
655
 **/
656 657 658
int inet_nonblocking_connect(const char *str,
                             NonBlockingConnectHandler *callback,
                             void *opaque, Error **errp)
659 660 661
{
    QemuOpts *opts;
    int sock = -1;
662
    InetSocketAddress *addr;
663

664 665
    g_assert(callback != NULL);

666 667
    addr = inet_parse(str, errp);
    if (addr != NULL) {
668
        opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
669 670
        inet_addr_to_opts(opts, addr);
        qapi_free_InetSocketAddress(addr);
671
        sock = inet_connect_opts(opts, errp, callback, opaque);
672
        qemu_opts_del(opts);
673
    }
674 675 676
    return sock;
}

677 678
#ifndef _WIN32

679
int unix_listen_opts(QemuOpts *opts, Error **errp)
680 681
{
    struct sockaddr_un un;
682 683
    const char *path = qemu_opt_get(opts, "path");
    int sock, fd;
684

Kevin Wolf's avatar
Kevin Wolf committed
685
    sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
686
    if (sock < 0) {
687
        error_setg_errno(errp, errno, "Failed to create socket");
vibi's avatar
vibi committed
688
        return -1;
689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706
    }

    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);
707
        qemu_opt_set(opts, "path", un.sun_path);
708 709 710 711
    }

    unlink(un.sun_path);
    if (bind(sock, (struct sockaddr*) &un, sizeof(un)) < 0) {
712
        error_setg_errno(errp, errno, "Failed to bind socket");
713 714 715
        goto err;
    }
    if (listen(sock, 1) < 0) {
716
        error_setg_errno(errp, errno, "Failed to listen on socket");
717 718 719 720 721 722 723 724 725 726
        goto err;
    }

    return sock;

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

727 728
int unix_connect_opts(QemuOpts *opts, Error **errp,
                      NonBlockingConnectHandler *callback, void *opaque)
729 730
{
    struct sockaddr_un un;
731
    const char *path = qemu_opt_get(opts, "path");
732 733
    ConnectState *connect_state = NULL;
    int sock, rc;
734

Gonglei's avatar
Gonglei committed
735
    if (path == NULL) {
736
        error_setg(errp, "unix connect: no path specified");
737 738 739
        return -1;
    }

Kevin Wolf's avatar
Kevin Wolf committed
740
    sock = qemu_socket(PF_UNIX, SOCK_STREAM, 0);
741
    if (sock < 0) {
742
        error_setg_errno(errp, errno, "Failed to create socket");
vibi's avatar
vibi committed
743
        return -1;
744
    }
745 746 747 748
    if (callback != NULL) {
        connect_state = g_malloc0(sizeof(*connect_state));
        connect_state->callback = callback;
        connect_state->opaque = opaque;
749
        qemu_set_nonblock(sock);
750
    }
751 752 753 754

    memset(&un, 0, sizeof(un));
    un.sun_family = AF_UNIX;
    snprintf(un.sun_path, sizeof(un.sun_path), "%s", path);
755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776

    /* connect to peer */
    do {
        rc = 0;
        if (connect(sock, (struct sockaddr *) &un, sizeof(un)) < 0) {
            rc = -socket_error();
        }
    } while (rc == -EINTR);

    if (connect_state != NULL && QEMU_SOCKET_RC_INPROGRESS(rc)) {
        connect_state->fd = sock;
        qemu_set_fd_handler2(sock, NULL, NULL, wait_for_connect,
                             connect_state);
        return sock;
    } else if (rc >= 0) {
        /* non blocking socket immediate success, call callback */
        if (callback != NULL) {
            callback(sock, opaque);
        }
    }

    if (rc < 0) {
777
        error_setg_errno(errp, -rc, "Failed to connect socket");
778
        close(sock);
779
        sock = -1;
780 781
    }

782
    g_free(connect_state);
783 784 785
    return sock;
}

786 787 788 789
#else

int unix_listen_opts(QemuOpts *opts, Error **errp)
{
790
    error_setg(errp, "unix sockets are not available on windows");
791 792 793 794
    errno = ENOTSUP;
    return -1;
}

795 796
int unix_connect_opts(QemuOpts *opts, Error **errp,
                      NonBlockingConnectHandler *callback, void *opaque)
797
{
798
    error_setg(errp, "unix sockets are not available on windows");
799 800 801 802 803
    errno = ENOTSUP;
    return -1;
}
#endif

804
/* compatibility wrapper */
805
int unix_listen(const char *str, char *ostr, int olen, Error **errp)
806 807 808 809 810
{
    QemuOpts *opts;
    char *path, *optstr;
    int sock, len;

811
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
812 813 814 815 816

    optstr = strchr(str, ',');
    if (optstr) {
        len = optstr - str;
        if (len) {
817
            path = g_malloc(len+1);
818 819
            snprintf(path, len+1, "%.*s", len, str);
            qemu_opt_set(opts, "path", path);
820
            g_free(path);
821 822 823 824 825
        }
    } else {
        qemu_opt_set(opts, "path", str);
    }

826
    sock = unix_listen_opts(opts, errp);
827 828 829 830 831 832 833

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

834
int unix_connect(const char *path, Error **errp)
835 836 837 838
{
    QemuOpts *opts;
    int sock;

839
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
840
    qemu_opt_set(opts, "path", path);
841 842 843 844 845 846 847 848 849 850 851 852 853 854 855
    sock = unix_connect_opts(opts, errp, NULL, NULL);
    qemu_opts_del(opts);
    return sock;
}


int unix_nonblocking_connect(const char *path,
                             NonBlockingConnectHandler *callback,
                             void *opaque, Error **errp)
{
    QemuOpts *opts;
    int sock = -1;

    g_assert(callback != NULL);

856
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
857 858
    qemu_opt_set(opts, "path", path);
    sock = unix_connect_opts(opts, errp, callback, opaque);
859 860 861 862
    qemu_opts_del(opts);
    return sock;
}

863 864
SocketAddress *socket_parse(const char *str, Error **errp)
{
865
    SocketAddress *addr;
866

867
    addr = g_new0(SocketAddress, 1);
868 869
    if (strstart(str, "unix:", NULL)) {
        if (str[5] == '\0') {
870
            error_setg(errp, "invalid Unix socket address");
871 872 873 874 875 876 877 878
            goto fail;
        } else {
            addr->kind = SOCKET_ADDRESS_KIND_UNIX;
            addr->q_unix = g_new(UnixSocketAddress, 1);
            addr->q_unix->path = g_strdup(str + 5);
        }
    } else if (strstart(str, "fd:", NULL)) {
        if (str[3] == '\0') {
879
            error_setg(errp, "invalid file descriptor address");
880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905
            goto fail;
        } else {
            addr->kind = SOCKET_ADDRESS_KIND_FD;
            addr->fd = g_new(String, 1);
            addr->fd->str = g_strdup(str + 3);
        }
    } else {
        addr->kind = SOCKET_ADDRESS_KIND_INET;
        addr->inet = inet_parse(str, errp);
        if (addr->inet == NULL) {
            goto fail;
        }
    }
    return addr;

fail:
    qapi_free_SocketAddress(addr);
    return NULL;
}

int socket_connect(SocketAddress *addr, Error **errp,
                   NonBlockingConnectHandler *callback, void *opaque)
{
    QemuOpts *opts;
    int fd;

906
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
907 908 909 910 911 912 913 914 915 916 917 918 919
    switch (addr->kind) {
    case SOCKET_ADDRESS_KIND_INET:
        inet_addr_to_opts(opts, addr->inet);
        fd = inet_connect_opts(opts, errp, callback, opaque);
        break;

    case SOCKET_ADDRESS_KIND_UNIX:
        qemu_opt_set(opts, "path", addr->q_unix->path);
        fd = unix_connect_opts(opts, errp, callback, opaque);
        break;

    case SOCKET_ADDRESS_KIND_FD:
        fd = monitor_get_fd(cur_mon, addr->fd->str, errp);
920
        if (fd >= 0 && callback) {
921
            qemu_set_nonblock(fd);
922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937
            callback(fd, opaque);
        }
        break;

    default:
        abort();
    }
    qemu_opts_del(opts);
    return fd;
}

int socket_listen(SocketAddress *addr, Error **errp)
{
    QemuOpts *opts;
    int fd;

938
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960
    switch (addr->kind) {
    case SOCKET_ADDRESS_KIND_INET:
        inet_addr_to_opts(opts, addr->inet);
        fd = inet_listen_opts(opts, 0, errp);
        break;

    case SOCKET_ADDRESS_KIND_UNIX:
        qemu_opt_set(opts, "path", addr->q_unix->path);
        fd = unix_listen_opts(opts, errp);
        break;

    case SOCKET_ADDRESS_KIND_FD:
        fd = monitor_get_fd(cur_mon, addr->fd->str, errp);
        break;

    default:
        abort();
    }
    qemu_opts_del(opts);
    return fd;
}

961 962 963 964 965
int socket_dgram(SocketAddress *remote, SocketAddress *local, Error **errp)
{
    QemuOpts *opts;
    int fd;

966
    opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
967 968
    switch (remote->kind) {
    case SOCKET_ADDRESS_KIND_INET:
969
        inet_addr_to_opts(opts, remote->inet);
970 971 972 973 974 975 976 977 978
        if (local) {
            qemu_opt_set(opts, "localaddr", local->inet->host);
            qemu_opt_set(opts, "localport", local->inet->port);
        }
        fd = inet_dgram_opts(opts, errp);
        break;

    default:
        error_setg(errp, "socket type unsupported for datagram");
979
        fd = -1;
980 981 982 983
    }
    qemu_opts_del(opts);
    return fd;
}