virsocketaddr.c 34.5 KB
Newer Older
1
/*
2
 * Copyright (C) 2009-2016 Red Hat, Inc.
3 4 5 6 7 8 9 10 11 12 13 14
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
15
 * License along with this library.  If not, see
O
Osier Yang 已提交
16
 * <http://www.gnu.org/licenses/>.
17 18 19 20 21 22 23 24 25 26
 *
 * Authors:
 *     Daniel Veillard <veillard@redhat.com>
 *     Laine Stump <laine@laine.org>
 *     Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>

#include "virsocketaddr.h"
27
#include "virerror.h"
28
#include "virstring.h"
29
#include "viralloc.h"
30
#include "virbuffer.h"
31 32 33 34 35 36 37 38 39 40 41 42 43

#include <netdb.h>

#define VIR_FROM_THIS VIR_FROM_NONE

/*
 * Helpers to extract the IP arrays from the virSocketAddrPtr
 * That part is the less portable of the module
 */
typedef unsigned char virSocketAddrIPv4[4];
typedef virSocketAddrIPv4 *virSocketAddrIPv4Ptr;
typedef unsigned short virSocketAddrIPv6[8];
typedef virSocketAddrIPv6 *virSocketAddrIPv6Ptr;
44 45
typedef unsigned char virSocketAddrIPv6Nibbles[32];
typedef virSocketAddrIPv6Nibbles *virSocketAddrIPv6NibblesPtr;
46

47 48 49 50
static int
virSocketAddrGetIPv4Addr(const virSocketAddr *addr,
                         virSocketAddrIPv4Ptr tab)
{
51
    unsigned long val;
52
    size_t i;
53

54
    if (!addr || !tab || addr->data.stor.ss_family != AF_INET)
55
        return -1;
56 57 58

    val = ntohl(addr->data.inet4.sin_addr.s_addr);

59
    for (i = 0; i < 4; i++) {
60 61 62 63
        (*tab)[3 - i] = val & 0xFF;
        val >>= 8;
    }

64
    return 0;
65 66
}

67 68 69
static int
virSocketAddrGetIPv6Addr(const virSocketAddr *addr, virSocketAddrIPv6Ptr tab)
{
70
    size_t i;
71

72
    if (!addr || !tab || addr->data.stor.ss_family != AF_INET6)
73
        return -1;
74

75
    for (i = 0; i < 8; i++) {
76 77 78 79
        (*tab)[i] = ((addr->data.inet6.sin6_addr.s6_addr[2 * i] << 8) |
                     addr->data.inet6.sin6_addr.s6_addr[2 * i + 1]);
    }

80
    return 0;
81 82
}

83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99
static int
virSocketAddrGetIPv6Nibbles(const virSocketAddr *addr,
                            virSocketAddrIPv6NibblesPtr tab)
{
    size_t i;

    if (!addr || !tab || addr->data.stor.ss_family != AF_INET6)
        return -1;

    for (i = 0; i < 16; i++) {
        (*tab)[2 * i] = addr->data.inet6.sin6_addr.s6_addr[i] >> 4;
        (*tab)[2 * i + 1] = addr->data.inet6.sin6_addr.s6_addr[i] & 0xF;
    }

    return 0;
}

100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128
static int
virSocketAddrParseInternal(struct addrinfo **res,
                           const char *val,
                           int family,
                           bool reportError)
{
    struct addrinfo hints;
    int err;

    if (val == NULL) {
        virReportError(VIR_ERR_INVALID_ARG, "%s", _("Missing address"));
        return -1;
    }

    memset(&hints, 0, sizeof(hints));
    hints.ai_family = family;
    hints.ai_flags = AI_NUMERICHOST;
    if ((err = getaddrinfo(val, NULL, &hints, res)) != 0) {
        if (reportError)
            virReportError(VIR_ERR_SYSTEM_ERROR,
                           _("Cannot parse socket address '%s': %s"),
                           val, gai_strerror(err));

        return -1;
    }

    return 0;
}

129 130 131 132 133 134 135 136 137 138 139
/**
 * virSocketAddrParse:
 * @val: a numeric network address IPv4 or IPv6
 * @addr: where to store the return value, optional.
 * @family: address family to pass down to getaddrinfo
 *
 * Mostly a wrapper for getaddrinfo() extracting the address storage
 * from the numeric string like 1.2.3.4 or 2001:db8:85a3:0:0:8a2e:370:7334
 *
 * Returns the length of the network address or -1 in case of error.
 */
140 141
int virSocketAddrParse(virSocketAddrPtr addr, const char *val, int family)
{
142
    int len;
143
    struct addrinfo *res;
144

145
    if (virSocketAddrParseInternal(&res, val, family, true) < 0)
146 147 148
        return -1;

    if (res == NULL) {
149
        virReportError(VIR_ERR_SYSTEM_ERROR,
150 151 152 153 154 155 156 157 158 159 160 161
                       _("No socket addresses found for '%s'"),
                       val);
        return -1;
    }

    len = res->ai_addrlen;
    if (addr != NULL) {
        memcpy(&addr->data.stor, res->ai_addr, len);
        addr->len = res->ai_addrlen;
    }

    freeaddrinfo(res);
162
    return len;
163 164 165 166 167 168 169 170 171 172 173 174
}

/*
 * virSocketAddrParseIPv4:
 * @val: an IPv4 numeric address
 * @addr: the location to store the result
 *
 * Extract the address storage from an IPv4 numeric address
 *
 * Returns the length of the network address or -1 in case of error.
 */
int
175 176
virSocketAddrParseIPv4(virSocketAddrPtr addr, const char *val)
{
177 178 179 180 181 182 183 184 185 186 187 188 189
    return virSocketAddrParse(addr, val, AF_INET);
}

/*
 * virSocketAddrParseIPv6:
 * @val: an IPv6 numeric address
 * @addr: the location to store the result
 *
 * Extract the address storage from an IPv6 numeric address
 *
 * Returns the length of the network address or -1 in case of error.
 */
int
190 191
virSocketAddrParseIPv6(virSocketAddrPtr addr, const char *val)
{
192 193 194
    return virSocketAddrParse(addr, val, AF_INET6);
}

195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210
/*
 * virSocketAddrSetIPv4AddrNetOrder:
 * @addr: the location to store the result
 * @val: the 32bit integer in network byte order representing the IPv4 address
 *
 * Set the IPv4 address given an integer in network order. This function does not
 * touch any previously set port.
 */
void
virSocketAddrSetIPv4AddrNetOrder(virSocketAddrPtr addr, uint32_t val)
{
    addr->data.stor.ss_family = AF_INET;
    addr->data.inet4.sin_addr.s_addr = val;
    addr->len = sizeof(struct sockaddr_in);
}

211 212 213 214 215 216 217 218 219 220 221
/*
 * virSocketAddrSetIPv4Addr:
 * @addr: the location to store the result
 * @val: the 32bit integer in host byte order representing the IPv4 address
 *
 * Set the IPv4 address given an integer in host order. This function does not
 * touch any previously set port.
 */
void
virSocketAddrSetIPv4Addr(virSocketAddrPtr addr, uint32_t val)
{
222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237
    virSocketAddrSetIPv4AddrNetOrder(addr, htonl(val));
}

/*
 * virSocketAddrSetIPv6AddrNetOrder:
 * @addr: the location to store the result
 * @val: the 128bit integer in network byte order representing the IPv6 address
 *
 * Set the IPv6 address given an integer in network order. This function does not
 * touch any previously set port.
 */
void virSocketAddrSetIPv6AddrNetOrder(virSocketAddrPtr addr, uint32_t val[4])
{
    addr->data.stor.ss_family = AF_INET6;
    memcpy(addr->data.inet6.sin6_addr.s6_addr, val, 4 * sizeof(*val));
    addr->len = sizeof(struct sockaddr_in6);
238 239
}

240 241 242 243 244 245 246 247 248 249
/*
 * virSocketAddrSetIPv6Addr:
 * @addr: the location to store the result
 * @val: the 128bit integer in host byte order representing the IPv6 address
 *
 * Set the IPv6 address given an integer in host order. This function does not
 * touch any previously set port.
 */
void virSocketAddrSetIPv6Addr(virSocketAddrPtr addr, uint32_t val[4])
{
250 251 252 253 254 255 256
    size_t i = 0;
    uint32_t host_val[4];

    for (i = 0; i < 4; i++)
        host_val[i] = htonl(val[i]);

    virSocketAddrSetIPv6AddrNetOrder(addr, host_val);
257 258
}

259 260 261 262 263 264 265 266 267
/*
 * virSocketAddrEqual:
 * @s1: the location of the one IP address
 * @s2: the location of the other IP address
 *
 * Compare two IP addresses for equality. Two addresses are equal
 * if their IP addresses and ports are equal.
 */
bool
268
virSocketAddrEqual(const virSocketAddr *s1, const virSocketAddr *s2)
269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284
{
    if (s1->data.stor.ss_family != s2->data.stor.ss_family)
        return false;

    switch (s1->data.stor.ss_family) {
    case AF_INET:
        return (memcmp(&s1->data.inet4.sin_addr.s_addr,
                       &s2->data.inet4.sin_addr.s_addr,
                       sizeof(s1->data.inet4.sin_addr.s_addr)) == 0 &&
                s1->data.inet4.sin_port == s2->data.inet4.sin_port);
    case AF_INET6:
        return (memcmp(&s1->data.inet6.sin6_addr.s6_addr,
                       &s2->data.inet6.sin6_addr.s6_addr,
                       sizeof(s1->data.inet6.sin6_addr.s6_addr)) == 0 &&
                s1->data.inet6.sin6_port == s2->data.inet6.sin6_port);
    }
285 286 287 288 289 290 291 292 293
    return false;
}

/*
 * virSocketAddrIsPrivate:
 * @s: the location of the IP address
 *
 * Return true if this address is in its family's defined
 * "private/local" address space. For IPv4, private addresses are in
294
 * the range of 192.168.0.0/16, 172.16.0.0/12, or 10.0.0.0/8.  For
295 296 297 298 299 300
 * IPv6, local addresses are in the range of FC00::/7 or FEC0::/10
 * (that last one is deprecated, but still in use).
 *
 * See RFC1918, RFC3484, and RFC4193 for details.
 */
bool
301
virSocketAddrIsPrivate(const virSocketAddr *addr)
302 303 304 305 306 307 308
{
    unsigned long val;

    switch (addr->data.stor.ss_family) {
    case AF_INET:
       val = ntohl(addr->data.inet4.sin_addr.s_addr);

309 310 311
       return ((val & 0xFFFF0000) == ((192UL << 24) + (168 << 16)) ||
               (val & 0xFFF00000) == ((172UL << 24) + (16  << 16)) ||
               (val & 0xFF000000) == ((10UL  << 24)));
312 313 314 315 316 317

    case AF_INET6:
        return ((addr->data.inet6.sin6_addr.s6_addr[0] & 0xFE) == 0xFC ||
                ((addr->data.inet6.sin6_addr.s6_addr[0] & 0xFF) == 0xFE &&
                 (addr->data.inet6.sin6_addr.s6_addr[1] & 0xC0) == 0xC0));
    }
318 319 320
    return false;
}

321 322 323 324 325 326 327
/*
 * virSocketAddrIsWildcard:
 * @addr: address to check
 *
 * Check if passed address is a variant of ANYCAST address.
 */
bool
328
virSocketAddrIsWildcard(const virSocketAddr *addr)
329
{
330
    struct in_addr tmp = { .s_addr = INADDR_ANY };
331 332
    switch (addr->data.stor.ss_family) {
    case AF_INET:
333
        return memcmp(&addr->data.inet4.sin_addr.s_addr, &tmp.s_addr,
334 335
                      sizeof(addr->data.inet4.sin_addr.s_addr)) == 0;
    case AF_INET6:
336
        return IN6_IS_ADDR_UNSPECIFIED(&addr->data.inet6.sin6_addr);
337 338 339 340
    }
    return false;
}

341 342 343 344 345 346 347 348 349
/*
 * virSocketAddrFormat:
 * @addr: an initialized virSocketAddrPtr
 *
 * Returns a string representation of the given address
 * Returns NULL on any error
 * Caller must free the returned string
 */
char *
350 351
virSocketAddrFormat(const virSocketAddr *addr)
{
352 353 354 355 356 357 358 359 360 361
    return virSocketAddrFormatFull(addr, false, NULL);
}


/*
 * virSocketAddrFormatFull:
 * @addr: an initialized virSocketAddrPtr
 * @withService: if true, then service info is appended
 * @separator: separator between hostname & service.
 *
362 363 364 365 366
 * Returns a string representation of the given address. If a format conforming
 * to URI specification is required, NULL should be passed to separator.
 * Set @separator only if non-URI format is required, e.g. passing ';' for
 * @separator if the address should be used with SASL.
 * Caller must free the returned string.
367 368
 */
char *
369
virSocketAddrFormatFull(const virSocketAddr *addr,
370 371 372 373 374 375 376 377
                        bool withService,
                        const char *separator)
{
    char host[NI_MAXHOST], port[NI_MAXSERV];
    char *addrstr;
    int err;

    if (addr == NULL) {
378
        virReportError(VIR_ERR_INVALID_ARG, "%s", _("Missing address"));
379 380 381 382 383 384 385 386 387
        return NULL;
    }

    /* Short-circuit since getnameinfo doesn't work
     * nicely for UNIX sockets */
    if (addr->data.sa.sa_family == AF_UNIX) {
        if (withService) {
            if (virAsprintf(&addrstr, "127.0.0.1%s0",
                            separator ? separator : ":") < 0)
388
                goto error;
389
        } else {
390 391
            if (VIR_STRDUP(addrstr, "127.0.0.1") < 0)
                goto error;
392 393 394 395 396 397 398 399 400
        }
        return addrstr;
    }

    if ((err = getnameinfo(&addr->data.sa,
                           addr->len,
                           host, sizeof(host),
                           port, sizeof(port),
                           NI_NUMERICHOST | NI_NUMERICSERV)) != 0) {
401
        virReportError(VIR_ERR_SYSTEM_ERROR,
402 403 404 405 406 407
                       _("Cannot convert socket address to string: %s"),
                       gai_strerror(err));
        return NULL;
    }

    if (withService) {
408 409 410 411 412 413 414 415 416 417 418 419 420
        char *ipv6_host = NULL;
        /* sasl_new_client demands the socket address to be in an odd format:
         * a.b.c.d;port or e:f:g:h:i:j:k:l;port, so use square brackets for
         * IPv6 only if no separator is passed to the function
         */
        if (!separator && VIR_SOCKET_ADDR_FAMILY(addr) == AF_INET6) {
            if (virAsprintf(&ipv6_host, "[%s]", host) < 0)
                goto error;
        }

        if (virAsprintf(&addrstr, "%s%s%s",
                        ipv6_host ? ipv6_host : host,
                        separator ? separator : ":", port) == -1)
421
            goto error;
422 423

        VIR_FREE(ipv6_host);
424
    } else {
425 426
        if (VIR_STRDUP(addrstr, host) < 0)
            goto error;
427 428 429 430
    }

    return addrstr;

431
 error:
432 433 434 435 436 437 438 439 440 441 442 443 444 445
    return NULL;
}


/*
 * virSocketAddrSetPort:
 * @addr: an initialized virSocketAddrPtr
 * @port: the port number to set
 *
 * Set the transport layer port of the given virtSocketAddr
 *
 * Returns 0 on success, -1 on failure
 */
int
446 447
virSocketAddrSetPort(virSocketAddrPtr addr, int port)
{
448 449 450 451 452
    if (addr == NULL)
        return -1;

    port = htons(port);

453
    if (addr->data.stor.ss_family == AF_INET) {
454
        addr->data.inet4.sin_port = port;
455
    } else if (addr->data.stor.ss_family == AF_INET6) {
456
        addr->data.inet6.sin6_port = port;
457
    } else {
458 459 460 461 462 463 464 465 466 467 468 469 470 471
        return -1;
    }

    return 0;
}

/*
 * virSocketGetPort:
 * @addr: an initialized virSocketAddrPtr
 *
 * Returns the transport layer port of the given virtSocketAddr
 * Returns -1 if @addr is invalid
 */
int
472 473
virSocketAddrGetPort(virSocketAddrPtr addr)
{
474 475 476
    if (addr == NULL)
        return -1;

477
    if (addr->data.stor.ss_family == AF_INET) {
478
        return ntohs(addr->data.inet4.sin_port);
479
    } else if (addr->data.stor.ss_family == AF_INET6) {
480 481 482 483 484 485 486 487 488 489 490 491 492 493
        return ntohs(addr->data.inet6.sin6_port);
    }

    return -1;
}

/**
 * virSocketAddrIsNetmask:
 * @netmask: the netmask address
 *
 * Check that @netmask is a proper network mask
 *
 * Returns 0 in case of success and -1 in case of error
 */
494 495
int virSocketAddrIsNetmask(virSocketAddrPtr netmask)
{
496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513
    int n = virSocketAddrGetNumNetmaskBits(netmask);
    if (n < 0)
        return -1;
    return 0;
}

/**
 * virSocketAddrMask:
 * @addr: address that needs to be masked
 * @netmask: the netmask address
 * @network: where to store the result, can be same as @addr
 *
 * Mask off the host bits of @addr according to @netmask, turning it
 * into a network address.
 *
 * Returns 0 in case of success, or -1 on error.
 */
int
514 515 516
virSocketAddrMask(const virSocketAddr *addr,
                  const virSocketAddr *netmask,
                  virSocketAddrPtr network)
517
{
518
    memset(network, 0, sizeof(*network));
519 520 521 522 523 524 525 526 527 528 529 530 531 532 533
    if (addr->data.stor.ss_family != netmask->data.stor.ss_family) {
        network->data.stor.ss_family = AF_UNSPEC;
        return -1;
    }

    if (addr->data.stor.ss_family == AF_INET) {
        network->data.inet4.sin_addr.s_addr
            = (addr->data.inet4.sin_addr.s_addr
               & netmask->data.inet4.sin_addr.s_addr);
        network->data.inet4.sin_port = 0;
        network->data.stor.ss_family = AF_INET;
        network->len = addr->len;
        return 0;
    }
    if (addr->data.stor.ss_family == AF_INET6) {
534 535 536 537 538
        size_t i;
        for (i = 0; i < 16; i++) {
            network->data.inet6.sin6_addr.s6_addr[i]
                = (addr->data.inet6.sin6_addr.s6_addr[i]
                   & netmask->data.inet6.sin6_addr.s6_addr[i]);
539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560
        }
        network->data.inet6.sin6_port = 0;
        network->data.stor.ss_family = AF_INET6;
        network->len = addr->len;
        return 0;
    }
    network->data.stor.ss_family = AF_UNSPEC;
    return -1;
}

/**
 * virSocketAddrMaskByPrefix:
 * @addr: address that needs to be masked
 * @prefix: prefix (# of 1 bits) of netmask to apply
 * @network: where to store the result, can be same as @addr
 *
 * Mask off the host bits of @addr according to @prefix, turning it
 * into a network address.
 *
 * Returns 0 in case of success, or -1 on error.
 */
int
561 562 563
virSocketAddrMaskByPrefix(const virSocketAddr *addr,
                          unsigned int prefix,
                          virSocketAddrPtr network)
564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579
{
    virSocketAddr netmask;

    if (virSocketAddrPrefixToNetmask(prefix, &netmask,
                                     addr->data.stor.ss_family) < 0) {
        network->data.stor.ss_family = AF_UNSPEC;
        return -1;
    }

    return virSocketAddrMask(addr, &netmask, network);
}

/**
 * virSocketAddrBroadcast:
 * @addr: address that needs to be turned into broadcast address (IPv4 only)
 * @netmask: the netmask address
J
Ján Tomko 已提交
580
 * @broadcast: virSocketAddr to receive the broadcast address
581 582 583 584 585 586 587
 *
 * Mask ON the host bits of @addr according to @netmask, turning it
 * into a broadcast address.
 *
 * Returns 0 in case of success, or -1 on error.
 */
int
588 589 590
virSocketAddrBroadcast(const virSocketAddr *addr,
                       const virSocketAddr *netmask,
                       virSocketAddrPtr broadcast)
591
{
592 593
    memset(broadcast, 0, sizeof(*broadcast));

594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611
    if ((addr->data.stor.ss_family != AF_INET) ||
        (netmask->data.stor.ss_family != AF_INET)) {
        broadcast->data.stor.ss_family = AF_UNSPEC;
        return -1;
    }

    broadcast->data.stor.ss_family = AF_INET;
    broadcast->len = addr->len;
    broadcast->data.inet4.sin_addr.s_addr
        = (addr->data.inet4.sin_addr.s_addr
           | ~netmask->data.inet4.sin_addr.s_addr);
    return 0;
}

/**
 * virSocketAddrBroadcastByPrefix:
 * @addr: address that needs to be turned into broadcast address (IPv4 only)
 * @prefix: prefix (# of 1 bits) of netmask to apply
J
Ján Tomko 已提交
612
 * @broadcast: virSocketAddr to receive the broadcast address
613 614 615 616 617 618 619
 *
 * Mask off the host bits of @addr according to @prefix, turning it
 * into a network address.
 *
 * Returns 0 in case of success, or -1 on error.
 */
int
620 621 622
virSocketAddrBroadcastByPrefix(const virSocketAddr *addr,
                               unsigned int prefix,
                               virSocketAddrPtr broadcast)
623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645
{
    virSocketAddr netmask;

    if (virSocketAddrPrefixToNetmask(prefix, &netmask,
                                     addr->data.stor.ss_family) < 0)
        return -1;

    return virSocketAddrBroadcast(addr, &netmask, broadcast);
}

/**
 * virSocketCheckNetmask:
 * @addr1: a first network address
 * @addr2: a second network address
 * @netmask: the netmask address
 *
 * Check that @addr1 and @addr2 pertain to the same @netmask address
 * range and returns the size of the range
 *
 * Returns 1 in case of success and 0 in case of failure and
 *         -1 in case of error
 */
int virSocketAddrCheckNetmask(virSocketAddrPtr addr1, virSocketAddrPtr addr2,
646 647
                              virSocketAddrPtr netmask)
{
648
    size_t i;
649 650

    if ((addr1 == NULL) || (addr2 == NULL) || (netmask == NULL))
651
        return -1;
652 653
    if ((addr1->data.stor.ss_family != addr2->data.stor.ss_family) ||
        (addr1->data.stor.ss_family != netmask->data.stor.ss_family))
654
        return -1;
655 656

    if (virSocketAddrIsNetmask(netmask) != 0)
657
        return -1;
658 659 660 661 662 663 664

    if (addr1->data.stor.ss_family == AF_INET) {
        virSocketAddrIPv4 t1, t2, tm;

        if ((virSocketAddrGetIPv4Addr(addr1, &t1) < 0) ||
            (virSocketAddrGetIPv4Addr(addr2, &t2) < 0) ||
            (virSocketAddrGetIPv4Addr(netmask, &tm) < 0))
665
            return -1;
666

667
        for (i = 0; i < 4; i++) {
668
            if ((t1[i] & tm[i]) != (t2[i] & tm[i]))
669
                return 0;
670 671 672 673 674 675 676 677
        }

    } else if (addr1->data.stor.ss_family == AF_INET6) {
        virSocketAddrIPv6 t1, t2, tm;

        if ((virSocketAddrGetIPv6Addr(addr1, &t1) < 0) ||
            (virSocketAddrGetIPv6Addr(addr2, &t2) < 0) ||
            (virSocketAddrGetIPv6Addr(netmask, &tm) < 0))
678
            return -1;
679

680
        for (i = 0; i < 8; i++) {
681
            if ((t1[i] & tm[i]) != (t2[i] & tm[i]))
682
                return 0;
683 684 685
        }

    } else {
686
        return -1;
687
    }
688
    return 1;
689 690 691 692 693 694
}

/**
 * virSocketGetRange:
 * @start: start of an IP range
 * @end: end of an IP range
695 696
 * @network: IP address of network that should completely contain this range
 * @prefix: prefix of the network
697
 *
698 699 700 701 702
 * Check the order of the 2 addresses and compute the range, this will
 * return 1 for identical addresses. Errors can come from incompatible
 * addresses type, excessive range (>= 2^^16) where the two addresses
 * are unrelated, inverted start and end, or a range that is not
 * within network/prefix.
703 704 705
 *
 * Returns the size of the range or -1 in case of failure
 */
706 707 708
int
virSocketAddrGetRange(virSocketAddrPtr start, virSocketAddrPtr end,
                      virSocketAddrPtr network, int prefix)
709
{
710 711
    int ret = 0;
    size_t i;
712
    virSocketAddr netmask;
713
    char *startStr = NULL, *endStr = NULL, *netStr = NULL;
714

715
    if (start == NULL || end == NULL) {
716
        virReportError(VIR_ERR_INTERNAL_ERROR,
717
                       _("NULL argument - %p %p"), start, end);
718 719 720 721 722
        goto error;
    }

    startStr = virSocketAddrFormat(start);
    endStr = virSocketAddrFormat(end);
723
    if (!startStr || !endStr)
724
        goto error; /*error already reported */
725

726
    if (VIR_SOCKET_ADDR_FAMILY(start) != VIR_SOCKET_ADDR_FAMILY(end)) {
727
        virReportError(VIR_ERR_INTERNAL_ERROR,
728 729
                       _("mismatch of address family in range %s - %s"),
                       startStr, endStr);
730 731
        goto error;
    }
732

733 734 735 736 737 738
    if (network) {
        /* some checks can only be done if we have details of the
         * network the range should be within
         */
        if (!(netStr = virSocketAddrFormat(network)))
            goto error;
739

740
        if (VIR_SOCKET_ADDR_FAMILY(start) != VIR_SOCKET_ADDR_FAMILY(network)) {
741
            virReportError(VIR_ERR_INTERNAL_ERROR,
742 743 744
                           _("mismatch of address family in "
                             "range %s - %s for network %s"),
                           startStr, endStr, netStr);
745 746
            goto error;
        }
747

748 749 750
        if (prefix < 0 ||
            virSocketAddrPrefixToNetmask(prefix, &netmask,
                                         VIR_SOCKET_ADDR_FAMILY(network)) < 0) {
751
            virReportError(VIR_ERR_INTERNAL_ERROR,
752 753 754
                           _("bad prefix %d for network %s when "
                             " checking range %s - %s"),
                           prefix, netStr, startStr, endStr);
755 756 757
            goto error;
        }

758 759 760
        /* both start and end of range need to be within network */
        if (virSocketAddrCheckNetmask(start, network, &netmask) <= 0 ||
            virSocketAddrCheckNetmask(end, network, &netmask) <= 0) {
761
            virReportError(VIR_ERR_INTERNAL_ERROR,
762 763
                           _("range %s - %s is not entirely within "
                             "network %s/%d"),
764 765 766
                           startStr, endStr, netStr, prefix);
            goto error;
        }
767

768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809
        if (VIR_SOCKET_ADDR_IS_FAMILY(start, AF_INET)) {
            virSocketAddr netaddr, broadcast;

            if (virSocketAddrBroadcast(network, &netmask, &broadcast) < 0 ||
                virSocketAddrMask(network, &netmask, &netaddr) < 0) {
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("failed to construct broadcast or network "
                                 "address for network %s/%d"),
                               netStr, prefix);
                goto error;
            }

            /* Don't allow the start of the range to be the network
             * address (usually "...0") or the end of the range to be the
             * broadcast address (usually "...255"). (the opposite also
             * isn't allowed, but checking for that is implicit in all the
             * other combined checks) (IPv6 doesn't have broadcast and
             * network addresses, so this check is only done for IPv4)
             */
            if (virSocketAddrEqual(start, &netaddr)) {
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("start of range %s - %s in network %s/%d "
                                 "is the network address"),
                               startStr, endStr, netStr, prefix);
                goto error;
            }

            if (virSocketAddrEqual(end, &broadcast)) {
                virReportError(VIR_ERR_INTERNAL_ERROR,
                               _("end of range %s - %s in network %s/%d "
                                 "is the broadcast address"),
                               startStr, endStr, netStr, prefix);
                goto error;
            }
        }
    }

    if (VIR_SOCKET_ADDR_IS_FAMILY(start, AF_INET)) {
        virSocketAddrIPv4 t1, t2;

        if (virSocketAddrGetIPv4Addr(start, &t1) < 0 ||
            virSocketAddrGetIPv4Addr(end, &t2) < 0) {
810 811
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("failed to get IPv4 address "
812 813
                             "for start or end of range %s - %s"),
                           startStr, endStr);
814 815
            goto error;
        }
816

817 818
        /* legacy check that everything except the last two bytes
         * are the same
819
         */
820
        for (i = 0; i < 2; i++) {
821 822
            if (t1[i] != t2[i]) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
823 824
                           _("range %s - %s is too large (> 65535)"),
                           startStr, endStr);
825 826
            goto error;
            }
827 828
        }
        ret = (t2[2] - t1[2]) * 256 + (t2[3] - t1[3]);
829 830
        if (ret < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
831 832
                           _("range %s - %s is reversed "),
                           startStr, endStr);
833 834
            goto error;
        }
835
        ret++;
836
    } else if (VIR_SOCKET_ADDR_IS_FAMILY(start, AF_INET6)) {
837 838
        virSocketAddrIPv6 t1, t2;

839 840
        if (virSocketAddrGetIPv6Addr(start, &t1) < 0 ||
            virSocketAddrGetIPv6Addr(end, &t2) < 0) {
841 842
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("failed to get IPv6 address "
843 844
                             "for start or end of range %s - %s"),
                           startStr, endStr);
845 846
            goto error;
        }
847

848 849 850
        /* legacy check that everything except the last two bytes are
         * the same
         */
851
        for (i = 0; i < 7; i++) {
852 853
            if (t1[i] != t2[i]) {
                virReportError(VIR_ERR_INTERNAL_ERROR,
854 855
                               _("range %s - %s is too large (> 65535)"),
                               startStr, endStr);
856 857
                goto error;
            }
858 859
        }
        ret = t2[7] - t1[7];
860 861
        if (ret < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
862 863
                           _("range %s - %s start larger than end"),
                           startStr, endStr);
864 865
            goto error;
        }
866 867
        ret++;
    } else {
868 869
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("unsupported address family "
870 871
                         "for range %s - %s, must be ipv4 or ipv6"),
                       startStr, endStr);
872
        goto error;
873
    }
874

875 876 877 878
 cleanup:
    VIR_FREE(startStr);
    VIR_FREE(endStr);
    VIR_FREE(netStr);
879
    return ret;
880 881 882 883

 error:
    ret = -1;
    goto cleanup;
884 885 886 887 888 889 890 891 892 893 894 895
}


/**
 * virSocketAddrGetNumNetmaskBits
 * @netmask: the presumed netmask
 *
 * Get the number of netmask bits in a netmask.
 *
 * Returns the number of bits in the netmask or -1 if an error occurred
 * or the netmask is invalid.
 */
896
int virSocketAddrGetNumNetmaskBits(const virSocketAddr *netmask)
897
{
898
    size_t i, j;
899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919
    int c = 0;

    if (netmask->data.stor.ss_family == AF_INET) {
        virSocketAddrIPv4 tm;
        uint8_t bit;

        if (virSocketAddrGetIPv4Addr(netmask, &tm) < 0)
            return -1;

        for (i = 0; i < 4; i++)
            if (tm[i] == 0xff)
                c += 8;
            else
                break;

        if (c == 8 * 4)
            return c;

        j = i << 3;
        while (j < (8 * 4)) {
            bit = 1 << (7 - (j & 7));
920
            if ((tm[j >> 3] & bit))
921
                c++;
922
            else
923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953
                break;
            j++;
        }

        while (j < (8 * 4)) {
            bit = 1 << (7 - (j & 7));
            if ((tm[j >> 3] & bit))
                return -1;
            j++;
        }

        return c;
    } else if (netmask->data.stor.ss_family == AF_INET6) {
        virSocketAddrIPv6 tm;
        uint16_t bit;

        if (virSocketAddrGetIPv6Addr(netmask, &tm) < 0)
            return -1;

        for (i = 0; i < 8; i++)
            if (tm[i] == 0xffff)
                c += 16;
            else
                break;

        if (c == 16 * 8)
            return c;

        j = i << 4;
        while (j < (16 * 8)) {
            bit = 1 << (15 - (j & 0xf));
954
            if ((tm[j >> 4] & bit))
955
                c++;
956
            else
957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005
                break;
            j++;
        }

        while (j < (16 * 8)) {
            bit = 1 << (15 - (j & 0xf));
            if ((tm[j >> 4]) & bit)
                return -1;
            j++;
        }

        return c;
    }
    return -1;
}

/**
 * virSocketPrefixToNetmask:
 * @prefix: number of 1 bits to put in the netmask
 * @netmask: address to fill in with the desired netmask
 * @family: family of the address (AF_INET or AF_INET6 only)
 *
 * given @prefix and @family, fill in @netmask with a netmask
 * (eg 255.255.255.0).
 *
 * Returns 0 on success or -1 on error.
 */

int
virSocketAddrPrefixToNetmask(unsigned int prefix,
                             virSocketAddrPtr netmask,
                             int family)
{
    int result = -1;

    netmask->data.stor.ss_family = AF_UNSPEC; /* assume failure */

    if (family == AF_INET) {
        int ip;

        if (prefix > 32)
            goto error;

        ip = prefix ? ~((1 << (32 - prefix)) - 1) : 0;
        netmask->data.inet4.sin_addr.s_addr = htonl(ip);
        netmask->data.stor.ss_family = AF_INET;
        result = 0;

    } else if (family == AF_INET6) {
1006
        size_t i = 0;
1007 1008 1009 1010 1011 1012

        if (prefix > 128)
            goto error;

        while (prefix >= 8) {
            /* do as much as possible an entire byte at a time */
1013
            netmask->data.inet6.sin6_addr.s6_addr[i++] = 0xff;
1014 1015 1016 1017
            prefix -= 8;
        }
        if (prefix > 0) {
            /* final partial byte */
1018
            netmask->data.inet6.sin6_addr.s6_addr[i++]
1019 1020
                = ~((1 << (8 - prefix)) -1);
        }
1021
        while (i < 16) {
1022
            /* zerofill remainder in case it wasn't initialized */
1023
            netmask->data.inet6.sin6_addr.s6_addr[i++] = 0;
1024 1025 1026 1027 1028
        }
        netmask->data.stor.ss_family = AF_INET6;
        result = 0;
    }

1029
 error:
1030
    return result;
1031 1032 1033
 }

/**
1034
 * virSocketAddrGetIPPrefix:
1035 1036 1037 1038 1039 1040 1041 1042
 * @address: network address
 * @netmask: netmask for this network
 * @prefix: prefix if specified instead of netmask
 *
 * Returns prefix value on success or -1 on error.
 */

int
1043
virSocketAddrGetIPPrefix(const virSocketAddr *address,
1044
                         const virSocketAddr *netmask,
1045 1046 1047 1048
                         int prefix)
{
    if (prefix > 0) {
        return prefix;
1049
    } else if (netmask && VIR_SOCKET_ADDR_VALID(netmask)) {
1050
        return virSocketAddrGetNumNetmaskBits(netmask);
1051
    } else if (address && VIR_SOCKET_ADDR_IS_FAMILY(address, AF_INET)) {
1052 1053 1054 1055 1056 1057 1058
        /* Return the natural prefix for the network's ip address.
         * On Linux we could use the IN_CLASSx() macros, but those
         * aren't guaranteed on all platforms, so we just deal with
         * the bits ourselves.
         */
        unsigned char octet
            = ntohl(address->data.inet4.sin_addr.s_addr) >> 24;
1059 1060 1061 1062 1063 1064

        /* If address is 0.0.0.0, we surely want to have 0 prefix for
         * the default route. */
        if (address->data.inet4.sin_addr.s_addr == 0)
            return 0;

1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075
        if ((octet & 0x80) == 0) {
            /* Class A network */
            return 8;
        } else if ((octet & 0xC0) == 0x80) {
            /* Class B network */
            return 16;
        } else if ((octet & 0xE0) == 0xC0) {
            /* Class C network */
            return 24;
        }
        return -1;
1076
    } else if (address && VIR_SOCKET_ADDR_IS_FAMILY(address, AF_INET6)) {
1077
        if (virSocketAddrIsWildcard(address))
1078
            return 0;
1079 1080 1081 1082 1083 1084 1085 1086 1087
        return 64;
    }

    /* When none of the three (address/netmask/prefix) is given, 0 is
     * returned rather than error, because this is a valid
     * expectation, e.g. for the address/prefix used for a default
     * route (the destination of a default route is 0.0.0.0/0).
     */
    return 0;
1088
}
1089 1090

/**
1091
 * virSocketAddrNumericFamily:
1092 1093
 * @address: address to check
 *
1094
 * Check if passed address is an IP address in numeric format.
1095
 *
1096 1097
 * Returns: AF_INET or AF_INET6 if @address is an numeric IP address,
 *          -1 otherwise.
1098
 */
1099 1100
int
virSocketAddrNumericFamily(const char *address)
1101 1102 1103 1104 1105
{
    struct addrinfo *res;
    unsigned short family;

    if (virSocketAddrParseInternal(&res, address, AF_UNSPEC, false) < 0)
1106
        return -1;
1107 1108 1109

    family = res->ai_addr->sa_family;
    freeaddrinfo(res);
1110
    return family;
1111
}
1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124

/**
 * virSocketAddrIsNumericLocalhost:
 * @address: address to check
 *
 * Check if passed address is a numeric 'localhost' address.
 *
 * Returns: true if @address is a numeric 'localhost' address,
 *          false otherwise
 */
bool
virSocketAddrIsNumericLocalhost(const char *addr)
{
R
Roman Bogorodskiy 已提交
1125
    virSocketAddr res;
1126 1127
    struct in_addr tmp = { .s_addr = htonl(INADDR_LOOPBACK) };

R
Roman Bogorodskiy 已提交
1128 1129
    if (virSocketAddrParse(&res, addr, AF_UNSPEC) < 0)
        return false;
1130

R
Roman Bogorodskiy 已提交
1131
    switch (res.data.stor.ss_family) {
1132
    case AF_INET:
R
Roman Bogorodskiy 已提交
1133 1134
        return memcmp(&res.data.inet4.sin_addr.s_addr, &tmp.s_addr,
                     sizeof(res.data.inet4.sin_addr.s_addr)) == 0;
1135
    case AF_INET6:
R
Roman Bogorodskiy 已提交
1136
        return IN6_IS_ADDR_LOOPBACK(&res.data.inet6.sin6_addr);
1137
    }
1138

R
Roman Bogorodskiy 已提交
1139
    return false;
1140
}
1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205


/**
 * virSocketAddrPTRDomain:
 *
 * Create PTR domain which corresponds to @addr/@prefix. Both IPv4 and IPv6
 * addresses are supported, but @prefix must be divisible by 8 for IPv4 and
 * divisible by 4 for IPv6, otherwise -2 will be returned.
 *
 * Returns -2 if the PTR record cannot be automatically created,
 *         -1 on error,
  *         0 on success.
 */
int
virSocketAddrPTRDomain(const virSocketAddr *addr,
                       unsigned int prefix,
                       char **ptr)
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
    size_t i;
    int ret = -1;

    if (VIR_SOCKET_ADDR_IS_FAMILY(addr, AF_INET)) {
        virSocketAddrIPv4 ip;

        if (prefix == 0 || prefix >= 32 || prefix % 8 != 0)
            goto unsupported;

        if (virSocketAddrGetIPv4Addr(addr, &ip) < 0)
            goto cleanup;

        for (i = prefix / 8; i > 0; i--)
            virBufferAsprintf(&buf, "%u.", ip[i - 1]);

        virBufferAddLit(&buf, VIR_SOCKET_ADDR_IPV4_ARPA);
    } else if (VIR_SOCKET_ADDR_IS_FAMILY(addr, AF_INET6)) {
        virSocketAddrIPv6Nibbles ip;

        if (prefix == 0 || prefix >= 128 || prefix % 4 != 0)
            goto unsupported;

        if (virSocketAddrGetIPv6Nibbles(addr, &ip) < 0)
            goto cleanup;

        for (i = prefix / 4; i > 0; i--)
            virBufferAsprintf(&buf, "%x.", ip[i - 1]);

        virBufferAddLit(&buf, VIR_SOCKET_ADDR_IPV6_ARPA);
    } else {
        goto unsupported;
    }

    if (!(*ptr = virBufferContentAndReset(&buf)))
        goto cleanup;

    ret = 0;

 cleanup:
    virBufferFreeAndReset(&buf);
    return ret;

 unsupported:
    ret = -2;
    goto cleanup;
}