src/inet.c

   1 /*
   2  *
   3  *  Connection Manager
   4  *
   5  *  Copyright (C) 2007-2013  Intel Corporation. All rights reserved.
   6  *  Copyright (C) 2003-2005  Go-Core Project
   7  *  Copyright (C) 2003-2006  Helsinki University of Technology
   8  *
   9  *  This program is free software; you can redistribute it and/or modify
  10  *  it under the terms of the GNU General Public License version 2 as
  11  *  published by the Free Software Foundation.
  12  *
  13  *  This program is distributed in the hope that it will be useful,
  14  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  15  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16  *  GNU General Public License for more details.
  17  *
  18  *  You should have received a copy of the GNU General Public License
  19  *  along with this program; if not, write to the Free Software
  20  *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  21  *
  22  */
  23
  24 #ifdef HAVE_CONFIG_H
  25 #include <config.h>
  26 #endif
  27
  28 #define _GNU_SOURCE
  29 #include <stdio.h>
  30 #include <errno.h>
  31 #include <unistd.h>
  32 #include <stdlib.h>
  33 #include <string.h>
  34 #include <sys/stat.h>
  35 #include <sys/ioctl.h>
  36 #include <sys/socket.h>
  37 #include <linux/sockios.h>
  38 #include <netdb.h>
  39 #include <arpa/inet.h>
  40 #include <net/route.h>
  41 #include <net/ethernet.h>
  42 #include <net/if.h>
  43 #include <net/if_arp.h>
  44 #include <netinet/icmp6.h>
  45 #include <fcntl.h>
  46 #include <linux/if_tun.h>
  47 #include <ctype.h>
  48 #include <ifaddrs.h>
  49 #include <linux/fib_rules.h>
  50
  51 #include "connman.h"
  52 #include <gdhcp/gdhcp.h>
  53
  54 #define NLMSG_TAIL(nmsg)                                \
  55         ((struct rtattr *) (((uint8_t*) (nmsg)) +       \
  56         NLMSG_ALIGN((nmsg)->nlmsg_len)))
  57
  58 int __connman_inet_rtnl_addattr_l(struct nlmsghdr *n, size_t max_length,
  59                                 int type, const void *data, size_t data_length)
  60 {
  61         size_t length;
  62         struct rtattr *rta;
  63
  64         length = RTA_LENGTH(data_length);
  65
  66         if (NLMSG_ALIGN(n->nlmsg_len) + RTA_ALIGN(length) > max_length)
  67                 return -E2BIG;
  68
  69         rta = NLMSG_TAIL(n);
  70         rta->rta_type = type;
  71         rta->rta_len = length;
  72         memcpy(RTA_DATA(rta), data, data_length);
  73         n->nlmsg_len = NLMSG_ALIGN(n->nlmsg_len) + RTA_ALIGN(length);
  74
  75         return 0;
  76 }
  77
  78 int __connman_inet_modify_address(int cmd, int flags,
  79                                 int index, int family,
  80                                 const char *address,
  81                                 const char *peer,
  82                                 unsigned char prefixlen,
  83                                 const char *broadcast)
  84 {
  85         uint8_t request[NLMSG_ALIGN(sizeof(struct nlmsghdr)) +
  86                         NLMSG_ALIGN(sizeof(struct ifaddrmsg)) +
  87                         RTA_LENGTH(sizeof(struct in6_addr)) +
  88                         RTA_LENGTH(sizeof(struct in6_addr))];
  89
  90         struct nlmsghdr *header;
  91         struct sockaddr_nl nl_addr;
  92         struct ifaddrmsg *ifaddrmsg;
  93         struct in6_addr ipv6_addr;
  94         struct in_addr ipv4_addr, ipv4_dest, ipv4_bcast;
  95         int sk, err;
  96
  97         DBG("cmd %#x flags %#x index %d family %d address %s peer %s "
  98                 "prefixlen %hhu broadcast %s", cmd, flags, index, family,
  99                 address, peer, prefixlen, broadcast);
 100
 101         if (!address)
 102                 return -EINVAL;
 103
 104         if (family != AF_INET && family != AF_INET6)
 105                 return -EINVAL;
 106
 107         memset(&request, 0, sizeof(request));
 108
 109         header = (struct nlmsghdr *)request;
 110         header->nlmsg_len = NLMSG_LENGTH(sizeof(struct ifaddrmsg));
 111         header->nlmsg_type = cmd;
 112         header->nlmsg_flags = NLM_F_REQUEST | flags;
 113         header->nlmsg_seq = 1;
 114
 115         ifaddrmsg = NLMSG_DATA(header);
 116         ifaddrmsg->ifa_family = family;
 117         ifaddrmsg->ifa_prefixlen = prefixlen;
 118         ifaddrmsg->ifa_flags = IFA_F_PERMANENT;
 119         ifaddrmsg->ifa_scope = RT_SCOPE_UNIVERSE;
 120         ifaddrmsg->ifa_index = index;
 121
 122         if (family == AF_INET) {
 123                 if (inet_pton(AF_INET, address, &ipv4_addr) < 1)
 124                         return -1;
 125
 126                 if (broadcast)
 127                         inet_pton(AF_INET, broadcast, &ipv4_bcast);
 128                 else
 129                         ipv4_bcast.s_addr = ipv4_addr.s_addr |
 130                                 htonl(0xfffffffflu >> prefixlen);
 131
 132                 if (peer) {
 133                         if (inet_pton(AF_INET, peer, &ipv4_dest) < 1)
 134                                 return -1;
 135
 136                         err = __connman_inet_rtnl_addattr_l(header,
 137                                                         sizeof(request),
 138                                                         IFA_ADDRESS,
 139                                                         &ipv4_dest,
 140                                                         sizeof(ipv4_dest));
 141                         if (err < 0)
 142                                 return err;
 143                 }
 144
 145                 err = __connman_inet_rtnl_addattr_l(header,
 146                                                 sizeof(request),
 147                                                 IFA_LOCAL,
 148                                                 &ipv4_addr,
 149                                                 sizeof(ipv4_addr));
 150                 if (err < 0)
 151                         return err;
 152
 153                 err = __connman_inet_rtnl_addattr_l(header,
 154                                                 sizeof(request),
 155                                                 IFA_BROADCAST,
 156                                                 &ipv4_bcast,
 157                                                 sizeof(ipv4_bcast));
 158                 if (err < 0)
 159                         return err;
 160
 161         } else if (family == AF_INET6) {
 162                 if (inet_pton(AF_INET6, address, &ipv6_addr) < 1)
 163                         return -1;
 164
 165                 err = __connman_inet_rtnl_addattr_l(header,
 166                                                 sizeof(request),
 167                                                 IFA_LOCAL,
 168                                                 &ipv6_addr,
 169                                                 sizeof(ipv6_addr));
 170                 if (err < 0)
 171                         return err;
 172         }
 173
 174         sk = socket(AF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, NETLINK_ROUTE);
 175         if (sk < 0)
 176                 return -errno;
 177
 178         memset(&nl_addr, 0, sizeof(nl_addr));
 179         nl_addr.nl_family = AF_NETLINK;
 180
 181         if ((err = sendto(sk, request, header->nlmsg_len, 0,
 182                         (struct sockaddr *) &nl_addr, sizeof(nl_addr))) < 0)
 183                 goto done;
 184
 185         err = 0;
 186
 187 done:
 188         close(sk);
 189
 190         return err;
 191 }
 192
 193 int connman_inet_ifindex(const char *name)
 194 {
 195         struct ifreq ifr;
 196         int sk, err;
 197
 198         if (!name)
 199                 return -1;
 200
 201         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 202         if (sk < 0)
 203                 return -1;
 204
 205         memset(&ifr, 0, sizeof(ifr));
 206         strncpy(ifr.ifr_name, name, sizeof(ifr.ifr_name) - 1);
 207
 208         err = ioctl(sk, SIOCGIFINDEX, &ifr);
 209
 210         close(sk);
 211
 212         if (err < 0)
 213                 return -1;
 214
 215         return ifr.ifr_ifindex;
 216 }
 217
 218 char *connman_inet_ifname(int index)
 219 {
 220         struct ifreq ifr;
 221         int sk, err;
 222
 223         if (index < 0)
 224                 return NULL;
 225
 226         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 227         if (sk < 0)
 228                 return NULL;
 229
 230         memset(&ifr, 0, sizeof(ifr));
 231         ifr.ifr_ifindex = index;
 232
 233         err = ioctl(sk, SIOCGIFNAME, &ifr);
 234
 235         close(sk);
 236
 237         if (err < 0)
 238                 return NULL;
 239
 240         return g_strdup(ifr.ifr_name);
 241 }
 242
 243 int connman_inet_ifup(int index)
 244 {
 245         struct ifreq ifr;
 246         int sk, err;
 247
 248         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 249         if (sk < 0)
 250                 return -errno;
 251
 252         memset(&ifr, 0, sizeof(ifr));
 253         ifr.ifr_ifindex = index;
 254
 255         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 256                 err = -errno;
 257                 goto done;
 258         }
 259
 260         if (ioctl(sk, SIOCGIFFLAGS, &ifr) < 0) {
 261                 err = -errno;
 262                 goto done;
 263         }
 264
 265         if (ifr.ifr_flags & IFF_UP) {
 266                 err = -EALREADY;
 267                 goto done;
 268         }
 269
 270         ifr.ifr_flags |= (IFF_UP|IFF_DYNAMIC);
 271
 272         if (ioctl(sk, SIOCSIFFLAGS, &ifr) < 0) {
 273                 err = -errno;
 274                 goto done;
 275         }
 276
 277         err = 0;
 278
 279 done:
 280         close(sk);
 281
 282         return err;
 283 }
 284
 285 int connman_inet_ifdown(int index)
 286 {
 287         struct ifreq ifr, addr_ifr;
 288         struct sockaddr_in *addr;
 289         int sk, err;
 290
 291         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 292         if (sk < 0)
 293                 return -errno;
 294
 295         memset(&ifr, 0, sizeof(ifr));
 296         ifr.ifr_ifindex = index;
 297
 298         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 299                 err = -errno;
 300                 goto done;
 301         }
 302
 303         if (ioctl(sk, SIOCGIFFLAGS, &ifr) < 0) {
 304                 err = -errno;
 305                 goto done;
 306         }
 307
 308         memset(&addr_ifr, 0, sizeof(addr_ifr));
 309         memcpy(&addr_ifr.ifr_name, &ifr.ifr_name, sizeof(ifr.ifr_name) - 1);
 310         addr = (struct sockaddr_in *)&addr_ifr.ifr_addr;
 311         addr->sin_family = AF_INET;
 312         if (ioctl(sk, SIOCSIFADDR, &addr_ifr) < 0)
 313                 connman_warn("Could not clear IPv4 address index %d", index);
 314
 315         if (!(ifr.ifr_flags & IFF_UP)) {
 316                 err = -EALREADY;
 317                 goto done;
 318         }
 319
 320         ifr.ifr_flags = (ifr.ifr_flags & ~IFF_UP) | IFF_DYNAMIC;
 321
 322         if (ioctl(sk, SIOCSIFFLAGS, &ifr) < 0)
 323                 err = -errno;
 324         else
 325                 err = 0;
 326
 327 done:
 328         close(sk);
 329
 330         return err;
 331 }
 332
 333 #if defined TIZEN_EXT
 334 void connman_inet_update_device_ident(struct connman_device *device)
 335 {
 336         int index;
 337         enum connman_device_type type;
 338         char *ident = NULL, *addr = NULL;
 339
 340         index = connman_device_get_index(device);
 341         type = connman_device_get_type(device);
 342
 343         switch (type) {
 344         case CONNMAN_DEVICE_TYPE_UNKNOWN:
 345                 return;
 346         case CONNMAN_DEVICE_TYPE_ETHERNET:
 347         case CONNMAN_DEVICE_TYPE_GADGET:
 348         case CONNMAN_DEVICE_TYPE_WIFI:
 349                 addr = index2addr(index);
 350                 break;
 351         case CONNMAN_DEVICE_TYPE_BLUETOOTH:
 352         case CONNMAN_DEVICE_TYPE_CELLULAR:
 353         case CONNMAN_DEVICE_TYPE_GPS:
 354         case CONNMAN_DEVICE_TYPE_VENDOR:
 355                 break;
 356         }
 357
 358         switch (type) {
 359         case CONNMAN_DEVICE_TYPE_UNKNOWN:
 360         case CONNMAN_DEVICE_TYPE_VENDOR:
 361         case CONNMAN_DEVICE_TYPE_GPS:
 362                 break;
 363         case CONNMAN_DEVICE_TYPE_ETHERNET:
 364         case CONNMAN_DEVICE_TYPE_GADGET:
 365                 ident = index2ident(index, NULL);
 366                 break;
 367         case CONNMAN_DEVICE_TYPE_WIFI:
 368                 ident = index2ident(index, NULL);
 369                 break;
 370         case CONNMAN_DEVICE_TYPE_BLUETOOTH:
 371                 break;
 372         case CONNMAN_DEVICE_TYPE_CELLULAR:
 373                 ident = index2ident(index, NULL);
 374                 break;
 375         }
 376
 377         if (ident != NULL) {
 378                 connman_device_set_ident(device, ident);
 379                 g_free(ident);
 380         }
 381
 382         if (addr != NULL) {
 383                 connman_device_set_string(device, "Address", addr);
 384                 g_free(addr);
 385         }
 386 }
 387 #endif
 388
 389 struct in6_ifreq {
 390         struct in6_addr ifr6_addr;
 391         __u32 ifr6_prefixlen;
 392         unsigned int ifr6_ifindex;
 393 };
 394
 395 int connman_inet_set_ipv6_address(int index,
 396                 struct connman_ipaddress *ipaddress)
 397 {
 398         int err;
 399         unsigned char prefix_len;
 400         const char *address;
 401
 402         if (!ipaddress->local)
 403                 return 0;
 404
 405         prefix_len = ipaddress->prefixlen;
 406         address = ipaddress->local;
 407
 408         DBG("index %d address %s prefix_len %d", index, address, prefix_len);
 409
 410         err = __connman_inet_modify_address(RTM_NEWADDR,
 411                                 NLM_F_REPLACE | NLM_F_ACK, index, AF_INET6,
 412                                 address, NULL, prefix_len, NULL);
 413         if (err < 0) {
 414                 connman_error("%s: %s", __func__, strerror(-err));
 415                 return err;
 416         }
 417
 418         return 0;
 419 }
 420
 421 int connman_inet_set_address(int index, struct connman_ipaddress *ipaddress)
 422 {
 423         int err;
 424         unsigned char prefix_len;
 425         const char *address, *broadcast, *peer;
 426
 427         if (!ipaddress->local)
 428                 return -1;
 429
 430         prefix_len = ipaddress->prefixlen;
 431         address = ipaddress->local;
 432         broadcast = ipaddress->broadcast;
 433         peer = ipaddress->peer;
 434
 435         DBG("index %d address %s prefix_len %d", index, address, prefix_len);
 436
 437         err = __connman_inet_modify_address(RTM_NEWADDR,
 438                                 NLM_F_REPLACE | NLM_F_ACK, index, AF_INET,
 439                                 address, peer, prefix_len, broadcast);
 440         if (err < 0) {
 441                 connman_error("%s: %s", __func__, strerror(-err));
 442                 return err;
 443         }
 444
 445         return 0;
 446 }
 447
 448 int connman_inet_clear_ipv6_address(int index, const char *address,
 449                                                         int prefix_len)
 450 {
 451         int err;
 452
 453         DBG("index %d address %s prefix_len %d", index, address, prefix_len);
 454
 455         if (!address)
 456                 return -EINVAL;
 457
 458         err = __connman_inet_modify_address(RTM_DELADDR, 0, index, AF_INET6,
 459                                 address, NULL, prefix_len, NULL);
 460         if (err < 0) {
 461                 connman_error("%s: %s", __func__, strerror(-err));
 462                 return err;
 463         }
 464
 465         return 0;
 466 }
 467
 468 int connman_inet_clear_address(int index, struct connman_ipaddress *ipaddress)
 469 {
 470         int err;
 471         unsigned char prefix_len;
 472         const char *address, *broadcast, *peer;
 473
 474         prefix_len = ipaddress->prefixlen;
 475         address = ipaddress->local;
 476         broadcast = ipaddress->broadcast;
 477         peer = ipaddress->peer;
 478
 479         DBG("index %d address %s prefix_len %d peer %s broadcast %s", index,
 480                 address, prefix_len, peer, broadcast);
 481
 482         if (!address)
 483                 return -EINVAL;
 484
 485         err = __connman_inet_modify_address(RTM_DELADDR, 0, index, AF_INET,
 486                                 address, peer, prefix_len, broadcast);
 487         if (err < 0) {
 488                 connman_error("%s: %s", __func__, strerror(-err));
 489                 return err;
 490         }
 491
 492         return 0;
 493 }
 494
 495 int connman_inet_add_host_route(int index, const char *host,
 496                                 const char *gateway)
 497 {
 498         return connman_inet_add_network_route(index, host, gateway, NULL);
 499 }
 500
 501 int connman_inet_del_host_route(int index, const char *host)
 502 {
 503         return connman_inet_del_network_route(index, host);
 504 }
 505
 506 int connman_inet_add_network_route(int index, const char *host,
 507                                         const char *gateway,
 508                                         const char *netmask)
 509 {
 510         struct ifreq ifr;
 511         struct rtentry rt;
 512         struct sockaddr_in addr;
 513         int sk, err = 0;
 514
 515         DBG("index %d host %s gateway %s netmask %s", index,
 516                 host, gateway, netmask);
 517
 518         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 519         if (sk < 0) {
 520                 err = -errno;
 521                 goto out;
 522         }
 523
 524         memset(&ifr, 0, sizeof(ifr));
 525         ifr.ifr_ifindex = index;
 526
 527         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 528                 err = -errno;
 529                 close(sk);
 530                 goto out;
 531         }
 532
 533         DBG("ifname %s", ifr.ifr_name);
 534
 535         memset(&rt, 0, sizeof(rt));
 536         rt.rt_flags = RTF_UP;
 537         if (gateway)
 538                 rt.rt_flags |= RTF_GATEWAY;
 539         if (!netmask)
 540                 rt.rt_flags |= RTF_HOST;
 541
 542         memset(&addr, 0, sizeof(addr));
 543         addr.sin_family = AF_INET;
 544         addr.sin_addr.s_addr = inet_addr(host);
 545         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 546
 547         memset(&addr, 0, sizeof(addr));
 548         addr.sin_family = AF_INET;
 549         if (gateway)
 550                 addr.sin_addr.s_addr = inet_addr(gateway);
 551         else
 552                 addr.sin_addr.s_addr = INADDR_ANY;
 553         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
 554
 555         memset(&addr, 0, sizeof(addr));
 556         addr.sin_family = AF_INET;
 557         addr.sin_addr.s_addr = INADDR_ANY;
 558         if (netmask)
 559                 addr.sin_addr.s_addr = inet_addr(netmask);
 560         else
 561                 addr.sin_addr.s_addr = INADDR_ANY;
 562         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
 563
 564         rt.rt_dev = ifr.ifr_name;
 565
 566         if (ioctl(sk, SIOCADDRT, &rt) < 0 && errno != EEXIST)
 567                 err = -errno;
 568
 569         close(sk);
 570
 571 out:
 572         if (err < 0)
 573                 connman_error("Adding host route failed (%s)",
 574                                                         strerror(-err));
 575
 576         return err;
 577 }
 578
 579 int connman_inet_del_network_route(int index, const char *host)
 580 {
 581         struct ifreq ifr;
 582         struct rtentry rt;
 583         struct sockaddr_in addr;
 584         int sk, err = 0;
 585
 586         DBG("index %d host %s", index, host);
 587
 588         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 589         if (sk < 0) {
 590                 err = -errno;
 591                 goto out;
 592         }
 593
 594         memset(&ifr, 0, sizeof(ifr));
 595         ifr.ifr_ifindex = index;
 596
 597         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 598                 err = -errno;
 599                 close(sk);
 600                 goto out;
 601         }
 602
 603         DBG("ifname %s", ifr.ifr_name);
 604
 605         memset(&rt, 0, sizeof(rt));
 606         rt.rt_flags = RTF_UP | RTF_HOST;
 607
 608         memset(&addr, 0, sizeof(addr));
 609         addr.sin_family = AF_INET;
 610         addr.sin_addr.s_addr = inet_addr(host);
 611         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 612
 613         rt.rt_dev = ifr.ifr_name;
 614
 615         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
 616                 err = -errno;
 617
 618         close(sk);
 619
 620 out:
 621         if (err < 0)
 622                 connman_error("Deleting host route failed (%s)",
 623                                                         strerror(-err));
 624
 625         return err;
 626 }
 627
 628 int connman_inet_del_ipv6_network_route(int index, const char *host,
 629                                                 unsigned char prefix_len)
 630 {
 631         struct in6_rtmsg rt;
 632         int sk, err = 0;
 633
 634         DBG("index %d host %s", index, host);
 635
 636         if (!host)
 637                 return -EINVAL;
 638
 639         memset(&rt, 0, sizeof(rt));
 640
 641         rt.rtmsg_dst_len = prefix_len;
 642
 643         if (inet_pton(AF_INET6, host, &rt.rtmsg_dst) < 0) {
 644                 err = -errno;
 645                 goto out;
 646         }
 647
 648         rt.rtmsg_flags = RTF_UP | RTF_HOST;
 649
 650         rt.rtmsg_metric = 1;
 651         rt.rtmsg_ifindex = index;
 652
 653         sk = socket(AF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 654         if (sk < 0) {
 655                 err = -errno;
 656                 goto out;
 657         }
 658
 659         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
 660                 err = -errno;
 661
 662         close(sk);
 663
 664 out:
 665         if (err < 0)
 666                 connman_error("Del IPv6 host route error (%s)",
 667                                                 strerror(-err));
 668
 669         return err;
 670 }
 671
 672 int connman_inet_del_ipv6_host_route(int index, const char *host)
 673 {
 674         return connman_inet_del_ipv6_network_route(index, host, 128);
 675 }
 676
 677 int connman_inet_add_ipv6_network_route(int index, const char *host,
 678                                         const char *gateway,
 679                                         unsigned char prefix_len)
 680 {
 681         struct in6_rtmsg rt;
 682         int sk, err = 0;
 683
 684         DBG("index %d host %s gateway %s", index, host, gateway);
 685
 686         if (!host)
 687                 return -EINVAL;
 688
 689         memset(&rt, 0, sizeof(rt));
 690
 691         rt.rtmsg_dst_len = prefix_len;
 692
 693         if (inet_pton(AF_INET6, host, &rt.rtmsg_dst) < 0) {
 694                 err = -errno;
 695                 goto out;
 696         }
 697
 698         rt.rtmsg_flags = RTF_UP | RTF_HOST;
 699
 700         if (gateway) {
 701                 rt.rtmsg_flags |= RTF_GATEWAY;
 702                 inet_pton(AF_INET6, gateway, &rt.rtmsg_gateway);
 703         }
 704
 705         rt.rtmsg_metric = 1;
 706         rt.rtmsg_ifindex = index;
 707
 708         sk = socket(AF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 709         if (sk < 0) {
 710                 err = -errno;
 711                 goto out;
 712         }
 713
 714         if (ioctl(sk, SIOCADDRT, &rt) < 0 && errno != EEXIST)
 715                 err = -errno;
 716
 717         close(sk);
 718
 719 out:
 720         if (err < 0)
 721                 connman_error("Set IPv6 host route error (%s)",
 722                                                 strerror(-err));
 723
 724         return err;
 725 }
 726
 727 int connman_inet_add_ipv6_host_route(int index, const char *host,
 728                                         const char *gateway)
 729 {
 730         return connman_inet_add_ipv6_network_route(index, host, gateway, 128);
 731 }
 732
 733 int connman_inet_clear_ipv6_gateway_address(int index, const char *gateway)
 734 {
 735         struct in6_rtmsg rt;
 736         int sk, err = 0;
 737
 738         DBG("index %d gateway %s", index, gateway);
 739
 740         if (!gateway)
 741                 return -EINVAL;
 742
 743         memset(&rt, 0, sizeof(rt));
 744
 745         if (inet_pton(AF_INET6, gateway, &rt.rtmsg_gateway) < 0) {
 746                 err = -errno;
 747                 goto out;
 748         }
 749
 750         rt.rtmsg_flags = RTF_UP | RTF_GATEWAY;
 751         rt.rtmsg_metric = 1;
 752         rt.rtmsg_dst_len = 0;
 753         rt.rtmsg_ifindex = index;
 754
 755         sk = socket(AF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 756         if (sk < 0) {
 757                 err = -errno;
 758                 goto out;
 759         }
 760
 761         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
 762                 err = -errno;
 763
 764         close(sk);
 765
 766 out:
 767         if (err < 0)
 768                 connman_error("Clear default IPv6 gateway error (%s)",
 769                                                 strerror(-err));
 770
 771         return err;
 772 }
 773
 774 int connman_inet_set_gateway_interface(int index)
 775 {
 776         struct ifreq ifr;
 777         struct rtentry rt;
 778         struct sockaddr_in addr;
 779         int sk, err = 0;
 780
 781         DBG("index %d", index);
 782
 783         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 784         if (sk < 0) {
 785                 err = -errno;
 786                 goto out;
 787         }
 788
 789         memset(&ifr, 0, sizeof(ifr));
 790         ifr.ifr_ifindex = index;
 791
 792         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 793                 err = -errno;
 794                 close(sk);
 795                 goto out;
 796         }
 797
 798         DBG("ifname %s", ifr.ifr_name);
 799
 800         memset(&rt, 0, sizeof(rt));
 801         rt.rt_flags = RTF_UP;
 802
 803         memset(&addr, 0, sizeof(addr));
 804         addr.sin_family = AF_INET;
 805         addr.sin_addr.s_addr = INADDR_ANY;
 806
 807         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
 808         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 809         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
 810
 811         rt.rt_dev = ifr.ifr_name;
 812
 813         if (ioctl(sk, SIOCADDRT, &rt) < 0 && errno != EEXIST)
 814                 err = -errno;
 815
 816         close(sk);
 817
 818 out:
 819         if (err < 0)
 820                 connman_error("Setting default interface route failed (%s)",
 821                                                         strerror(-err));
 822
 823         return err;
 824 }
 825
 826 int connman_inet_set_ipv6_gateway_interface(int index)
 827 {
 828         struct ifreq ifr;
 829         struct rtentry rt;
 830         struct sockaddr_in6 addr;
 831         const struct in6_addr any = IN6ADDR_ANY_INIT;
 832         int sk, err = 0;
 833
 834         DBG("index %d", index);
 835
 836         sk = socket(PF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 837         if (sk < 0) {
 838                 err = -errno;
 839                 goto out;
 840         }
 841
 842         memset(&ifr, 0, sizeof(ifr));
 843         ifr.ifr_ifindex = index;
 844
 845         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 846                 err = -errno;
 847                 close(sk);
 848                 goto out;
 849         }
 850
 851         DBG("ifname %s", ifr.ifr_name);
 852
 853         memset(&rt, 0, sizeof(rt));
 854         rt.rt_flags = RTF_UP;
 855
 856         memset(&addr, 0, sizeof(addr));
 857         addr.sin6_family = AF_INET6;
 858         addr.sin6_addr = any;
 859
 860         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
 861         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 862         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
 863
 864         rt.rt_dev = ifr.ifr_name;
 865
 866         if (ioctl(sk, SIOCADDRT, &rt) < 0 && errno != EEXIST)
 867                 err = -errno;
 868
 869         close(sk);
 870
 871 out:
 872         if (err < 0)
 873                 connman_error("Setting default interface route failed (%s)",
 874                                                         strerror(-err));
 875
 876         return err;
 877 }
 878
 879 int connman_inet_clear_gateway_address(int index, const char *gateway)
 880 {
 881         struct ifreq ifr;
 882         struct rtentry rt;
 883         struct sockaddr_in addr;
 884         int sk, err = 0;
 885
 886         DBG("index %d gateway %s", index, gateway);
 887
 888         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 889         if (sk < 0) {
 890                 err = -errno;
 891                 goto out;
 892         }
 893
 894         memset(&ifr, 0, sizeof(ifr));
 895         ifr.ifr_ifindex = index;
 896
 897         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 898                 err = -errno;
 899                 close(sk);
 900                 goto out;
 901         }
 902
 903         DBG("ifname %s", ifr.ifr_name);
 904
 905         memset(&rt, 0, sizeof(rt));
 906         rt.rt_flags = RTF_UP | RTF_GATEWAY;
 907
 908         memset(&addr, 0, sizeof(addr));
 909         addr.sin_family = AF_INET;
 910         addr.sin_addr.s_addr = INADDR_ANY;
 911         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 912
 913         memset(&addr, 0, sizeof(addr));
 914         addr.sin_family = AF_INET;
 915         addr.sin_addr.s_addr = inet_addr(gateway);
 916         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
 917
 918         memset(&addr, 0, sizeof(addr));
 919         addr.sin_family = AF_INET;
 920         addr.sin_addr.s_addr = INADDR_ANY;
 921         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
 922
 923         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
 924                 err = -errno;
 925
 926         close(sk);
 927
 928 out:
 929         if (err < 0)
 930                 connman_error("Removing default gateway route failed (%s)",
 931                                                         strerror(-err));
 932
 933         return err;
 934 }
 935
 936 int connman_inet_clear_gateway_interface(int index)
 937 {
 938         struct ifreq ifr;
 939         struct rtentry rt;
 940         struct sockaddr_in addr;
 941         int sk, err = 0;
 942
 943         DBG("index %d", index);
 944
 945         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 946         if (sk < 0) {
 947                 err = -errno;
 948                 goto out;
 949         }
 950
 951         memset(&ifr, 0, sizeof(ifr));
 952         ifr.ifr_ifindex = index;
 953
 954         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
 955                 err = -errno;
 956                 close(sk);
 957                 goto out;
 958         }
 959
 960         DBG("ifname %s", ifr.ifr_name);
 961
 962         memset(&rt, 0, sizeof(rt));
 963         rt.rt_flags = RTF_UP;
 964
 965         memset(&addr, 0, sizeof(addr));
 966         addr.sin_family = AF_INET;
 967         addr.sin_addr.s_addr = INADDR_ANY;
 968
 969         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
 970         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
 971         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
 972
 973         rt.rt_dev = ifr.ifr_name;
 974
 975         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
 976                 err = -errno;
 977
 978         close(sk);
 979
 980 out:
 981         if (err < 0)
 982                 connman_error("Removing default interface route failed (%s)",
 983                                                         strerror(-err));
 984
 985         return err;
 986 }
 987
 988 int connman_inet_clear_ipv6_gateway_interface(int index)
 989 {
 990         struct ifreq ifr;
 991         struct rtentry rt;
 992         struct sockaddr_in6 addr;
 993         const struct in6_addr any = IN6ADDR_ANY_INIT;
 994         int sk, err = 0;
 995
 996         DBG("index %d", index);
 997
 998         sk = socket(PF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
 999         if (sk < 0) {
1000                 err = -errno;
1001                 goto out;
1002         }
1003
1004         memset(&ifr, 0, sizeof(ifr));
1005         ifr.ifr_ifindex = index;
1006
1007         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
1008                 err = -errno;
1009                 close(sk);
1010                 goto out;
1011         }
1012
1013         DBG("ifname %s", ifr.ifr_name);
1014
1015         memset(&rt, 0, sizeof(rt));
1016         rt.rt_flags = RTF_UP;
1017
1018         memset(&addr, 0, sizeof(addr));
1019         addr.sin6_family = AF_INET6;
1020         addr.sin6_addr = any;
1021
1022         memcpy(&rt.rt_genmask, &addr, sizeof(rt.rt_genmask));
1023         memcpy(&rt.rt_dst, &addr, sizeof(rt.rt_dst));
1024         memcpy(&rt.rt_gateway, &addr, sizeof(rt.rt_gateway));
1025
1026         rt.rt_dev = ifr.ifr_name;
1027
1028         if (ioctl(sk, SIOCDELRT, &rt) < 0 && errno != ESRCH)
1029                 err = -errno;
1030
1031         close(sk);
1032
1033 out:
1034         if (err < 0)
1035                 connman_error("Removing default interface route failed (%s)",
1036                                                         strerror(-err));
1037
1038         return err;
1039 }
1040
1041 bool connman_inet_compare_subnet(int index, const char *host)
1042 {
1043         struct ifreq ifr;
1044         struct in_addr _host_addr;
1045         in_addr_t host_addr, netmask_addr, if_addr;
1046         struct sockaddr_in *netmask, *addr;
1047         int sk;
1048
1049         DBG("host %s", host);
1050
1051         if (!host)
1052                 return false;
1053
1054         if (inet_aton(host, &_host_addr) == 0)
1055                 return -1;
1056         host_addr = _host_addr.s_addr;
1057
1058         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
1059         if (sk < 0)
1060                 return false;
1061
1062         memset(&ifr, 0, sizeof(ifr));
1063         ifr.ifr_ifindex = index;
1064
1065         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
1066                 close(sk);
1067                 return false;
1068         }
1069
1070         if (ioctl(sk, SIOCGIFNETMASK, &ifr) < 0) {
1071                 close(sk);
1072                 return false;
1073         }
1074
1075         netmask = (struct sockaddr_in *)&ifr.ifr_netmask;
1076         netmask_addr = netmask->sin_addr.s_addr;
1077
1078         if (ioctl(sk, SIOCGIFADDR, &ifr) < 0) {
1079                 close(sk);
1080                 return false;
1081         }
1082
1083         close(sk);
1084
1085         addr = (struct sockaddr_in *)&ifr.ifr_addr;
1086         if_addr = addr->sin_addr.s_addr;
1087
1088         return ((if_addr & netmask_addr) == (host_addr & netmask_addr));
1089 }
1090
1091 int connman_inet_remove_from_bridge(int index, const char *bridge)
1092 {
1093         struct ifreq ifr;
1094         int sk, err = 0;
1095
1096         if (!bridge)
1097                 return -EINVAL;
1098
1099         sk = socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0);
1100         if (sk < 0) {
1101                 err = -errno;
1102                 goto out;
1103         }
1104
1105         memset(&ifr, 0, sizeof(ifr));
1106         strncpy(ifr.ifr_name, bridge, sizeof(ifr.ifr_name) - 1);
1107         ifr.ifr_ifindex = index;
1108
1109         if (ioctl(sk, SIOCBRDELIF, &ifr) < 0)
1110                 err = -errno;
1111
1112         close(sk);
1113
1114 out:
1115         if (err < 0)
1116                 connman_error("Remove interface from bridge error %s",
1117                                                         strerror(-err));
1118
1119         return err;
1120 }
1121
1122 int connman_inet_add_to_bridge(int index, const char *bridge)
1123 {
1124         struct ifreq ifr;
1125         int sk, err = 0;
1126
1127         if (!bridge)
1128                 return -EINVAL;
1129
1130         sk = socket(AF_INET, SOCK_STREAM | SOCK_CLOEXEC, 0);
1131         if (sk < 0) {
1132                 err = -errno;
1133                 goto out;
1134         }
1135
1136         memset(&ifr, 0, sizeof(ifr));
1137         strncpy(ifr.ifr_name, bridge, sizeof(ifr.ifr_name) - 1);
1138         ifr.ifr_ifindex = index;
1139
1140         if (ioctl(sk, SIOCBRADDIF, &ifr) < 0)
1141                 err = -errno;
1142
1143         close(sk);
1144
1145 out:
1146         if (err < 0)
1147                 connman_error("Add interface to bridge error %s",
1148                                                         strerror(-err));
1149
1150         return err;
1151 }
1152
1153 int connman_inet_set_mtu(int index, int mtu)
1154 {
1155         struct ifreq ifr;
1156         int sk, err;
1157
1158         sk = socket(AF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
1159         if (sk < 0)
1160                 return sk;
1161
1162         memset(&ifr, 0, sizeof(ifr));
1163         ifr.ifr_ifindex = index;
1164
1165         err = ioctl(sk, SIOCGIFNAME, &ifr);
1166         if (err == 0) {
1167                 ifr.ifr_mtu = mtu;
1168                 err = ioctl(sk, SIOCSIFMTU, &ifr);
1169         }
1170
1171         close(sk);
1172         return err;
1173 }
1174
1175 int connman_inet_setup_tunnel(char *tunnel, int mtu)
1176 {
1177         struct ifreq ifr;
1178         int sk, err, index;
1179         __u32 mask;
1180         __u32 flags;
1181
1182         if (!tunnel)
1183                 return -EINVAL;
1184
1185         sk = socket(AF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
1186         if (sk < 0)
1187                 return sk;
1188
1189         index = if_nametoindex(tunnel);
1190
1191         err = connman_inet_set_mtu(index, mtu);
1192         if (err != 0)
1193                 goto done;
1194
1195         memset(&ifr, 0, sizeof(ifr));
1196         strncpy(ifr.ifr_name, tunnel, sizeof(ifr.ifr_name) - 1);
1197         err = ioctl(sk, SIOCGIFFLAGS, &ifr);
1198         if (err)
1199                 goto done;
1200
1201         mask = IFF_UP;
1202         flags = IFF_UP;
1203
1204         if ((ifr.ifr_flags ^ flags) & mask) {
1205                 ifr.ifr_flags &= ~mask;
1206                 ifr.ifr_flags |= mask & flags;
1207                 err = ioctl(sk, SIOCSIFFLAGS, &ifr);
1208                 if (err)
1209                         connman_error("SIOCSIFFLAGS failed: %s",
1210                                                         strerror(errno));
1211         }
1212
1213 done:
1214         close(sk);
1215         return err;
1216 }
1217
1218 int connman_inet_create_tunnel(char **iface)
1219 {
1220         struct ifreq ifr;
1221         int i, fd;
1222
1223         fd = open("/dev/net/tun", O_RDWR | O_CLOEXEC);
1224         if (fd < 0) {
1225                 i = -errno;
1226                 connman_error("Failed to open /dev/net/tun: %s",
1227                                 strerror(errno));
1228                 return i;
1229         }
1230
1231         memset(&ifr, 0, sizeof(ifr));
1232         ifr.ifr_flags = IFF_TUN | IFF_NO_PI;
1233
1234         for (i = 0; i < 256; i++) {
1235                 sprintf(ifr.ifr_name, "tun%d", i);
1236
1237                 if (!ioctl(fd, TUNSETIFF, (void *)&ifr))
1238                         break;
1239         }
1240
1241         if (i == 256) {
1242                 connman_error("Failed to find available tun device");
1243                 close(fd);
1244                 return -ENODEV;
1245         }
1246
1247         *iface = g_strdup(ifr.ifr_name);
1248
1249         return fd;
1250 }
1251
1252 /*
1253  * This callback struct is used when sending router and neighbor
1254  * solicitation and advertisement messages.
1255  */
1256 struct xs_cb_data {
1257         GIOChannel *channel;
1258         void *callback;
1259         struct sockaddr_in6 addr;
1260         guint timeout;
1261         guint watch_id;
1262         void *user_data;
1263 };
1264
1265 #define CMSG_BUF_LEN 512
1266 #define IN6ADDR_ALL_NODES_MC_INIT \
1267         { { { 0xff,0x02,0,0,0,0,0,0,0,0,0,0,0,0,0,0x1 } } } /* ff02::1 */
1268 #define IN6ADDR_ALL_ROUTERS_MC_INIT \
1269         { { { 0xff,0x02,0,0,0,0,0,0,0,0,0,0,0,0,0,0x2 } } } /* ff02::2 */
1270
1271 static const struct in6_addr in6addr_all_nodes_mc = IN6ADDR_ALL_NODES_MC_INIT;
1272 static const struct in6_addr in6addr_all_routers_mc =
1273                                                 IN6ADDR_ALL_ROUTERS_MC_INIT;
1274
1275 static void xs_cleanup(struct xs_cb_data *data)
1276 {
1277         if (data->channel) {
1278                 g_io_channel_shutdown(data->channel, TRUE, NULL);
1279                 g_io_channel_unref(data->channel);
1280                 data->channel = NULL;
1281         }
1282
1283         if (data->timeout > 0)
1284                 g_source_remove(data->timeout);
1285
1286         if (data->watch_id > 0)
1287                 g_source_remove(data->watch_id);
1288
1289         g_free(data);
1290 }
1291
1292 static gboolean rs_timeout_cb(gpointer user_data)
1293 {
1294         struct xs_cb_data *data = user_data;
1295
1296         DBG("user data %p", user_data);
1297
1298         if (!data)
1299                 return FALSE;
1300
1301         if (data->callback) {
1302                 __connman_inet_rs_cb_t cb = data->callback;
1303                 cb(NULL, 0, data->user_data);
1304         }
1305
1306         data->timeout = 0;
1307         xs_cleanup(data);
1308         return FALSE;
1309 }
1310
1311 static int icmpv6_recv(int fd, gpointer user_data)
1312 {
1313         struct msghdr mhdr;
1314         struct iovec iov;
1315         unsigned char chdr[CMSG_BUF_LEN];
1316         unsigned char buf[1540];
1317         struct xs_cb_data *data = user_data;
1318         struct nd_router_advert *hdr;
1319         struct sockaddr_in6 saddr;
1320         ssize_t len;
1321         __connman_inet_rs_cb_t cb = data->callback;
1322
1323         DBG("");
1324
1325         iov.iov_len = sizeof(buf);
1326         iov.iov_base = buf;
1327
1328         mhdr.msg_name = (void *)&saddr;
1329         mhdr.msg_namelen = sizeof(struct sockaddr_in6);
1330         mhdr.msg_flags = 0;
1331         mhdr.msg_iov = &iov;
1332         mhdr.msg_iovlen = 1;
1333         mhdr.msg_control = (void *)chdr;
1334         mhdr.msg_controllen = CMSG_BUF_LEN;
1335
1336         len = recvmsg(fd, &mhdr, 0);
1337         if (len < 0) {
1338                 cb(NULL, 0, data->user_data);
1339                 xs_cleanup(data);
1340                 return -errno;
1341         }
1342
1343 #if defined TIZEN_EXT
1344         /* Set Received Source Address from router as IPv6 Gateway Address */
1345         char src_addr[INET6_ADDRSTRLEN];
1346         if(inet_ntop(AF_INET6, &(saddr.sin6_addr), src_addr, INET6_ADDRSTRLEN)
1347                         == NULL) {
1348                 xs_cleanup(data);
1349                 return -errno;
1350         }
1351         DBG("Received Source Address %s from router", src_addr);
1352
1353         /* icmpv6_recv() function can be called in two scenarios :
1354          * 1. When __connman_inet_ipv6_send_rs() is called from check_dhcpv6()
1355          * 2. When __connman_inet_ipv6_send_rs() is called from
1356          * __connman_6to4_probe()
1357          * In the second case it is not  required to set DHCPv6 Gateway  Address
1358          * as DHCPv6 was not started and  network structure was not passed as
1359          * user_data. If it is tried  to add Source Address as  Gateway Address
1360          * then it will lead to  crash because of  user_data being ip_address
1361          * instead of network structure. So Adding Gateway Address in case 1st
1362          * case only.
1363          */
1364         char *address = data->user_data;
1365         int err = 0;
1366         unsigned char buffer[sizeof(struct in6_addr)] = {0, };
1367         /* Checking if user_data is an ip_address */
1368         err = inet_pton(AF_INET, address, buffer);
1369         /* Setting Received Source Address from
1370          * router as Gateway Address */
1371         if(err <= 0)
1372                 __connman_network_set_auto_ipv6_gateway(src_addr, data->user_data);
1373 #endif
1374         hdr = (struct nd_router_advert *)buf;
1375         DBG("code %d len %zd hdr %zd", hdr->nd_ra_code, len,
1376                                 sizeof(struct nd_router_advert));
1377         if (hdr->nd_ra_code != 0)
1378                 return 0;
1379
1380         cb(hdr, len, data->user_data);
1381         xs_cleanup(data);
1382
1383         return len;
1384 }
1385
1386 static gboolean icmpv6_event(GIOChannel *chan, GIOCondition cond, gpointer data)
1387 {
1388         int fd, ret;
1389
1390         DBG("");
1391
1392         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1393                 return FALSE;
1394
1395         fd = g_io_channel_unix_get_fd(chan);
1396         ret = icmpv6_recv(fd, data);
1397         if (ret == 0)
1398                 return TRUE;
1399
1400         return FALSE;
1401 }
1402
1403 /* Adapted from RFC 1071 "C" Implementation Example */
1404 static uint16_t csum(const void *phdr, const void *data, socklen_t datalen,
1405                 const void *extra_data, socklen_t extra_datalen)
1406 {
1407         register unsigned long sum = 0;
1408         socklen_t count;
1409         uint16_t *addr;
1410         int i;
1411
1412         /* caller must make sure datalen is even */
1413
1414         addr = (uint16_t *)phdr;
1415         for (i = 0; i < 20; i++)
1416                 sum += *addr++;
1417
1418         count = datalen;
1419         addr = (uint16_t *)data;
1420
1421         while (count > 1) {
1422                 sum += *(addr++);
1423                 count -= 2;
1424         }
1425
1426         if (extra_data) {
1427                 count = extra_datalen;
1428                 addr = (uint16_t *)extra_data;
1429
1430                 while (count > 1) {
1431                         sum += *(addr++);
1432                         count -= 2;
1433                 }
1434         }
1435
1436         while (sum >> 16)
1437                 sum = (sum & 0xffff) + (sum >> 16);
1438
1439         return (uint16_t)~sum;
1440 }
1441
1442 static int ndisc_send_unspec(int type, int oif, const struct in6_addr *dest,
1443                         const struct in6_addr *source,
1444                         unsigned char *buf, size_t len, uint16_t lifetime)
1445 {
1446         struct _phdr {
1447                 struct in6_addr src;
1448                 struct in6_addr dst;
1449                 uint32_t plen;
1450                 uint8_t reserved[3];
1451                 uint8_t nxt;
1452         } phdr;
1453
1454         struct {
1455                 struct ip6_hdr ip;
1456                 union {
1457                         struct icmp6_hdr icmp;
1458                         struct nd_neighbor_solicit ns;
1459                         struct nd_router_solicit rs;
1460                         struct nd_router_advert ra;
1461                 } i;
1462         } frame;
1463
1464         struct msghdr msgh;
1465         struct cmsghdr *cmsg;
1466         struct in6_pktinfo *pinfo;
1467         struct sockaddr_in6 dst, src;
1468         char cbuf[CMSG_SPACE(sizeof(*pinfo))];
1469         struct iovec iov[2];
1470         int fd, datalen, ret, iovlen = 1;
1471
1472         DBG("");
1473
1474         fd = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_RAW);
1475         if (fd < 0)
1476                 return -errno;
1477
1478         memset(&frame, 0, sizeof(frame));
1479         memset(&dst, 0, sizeof(dst));
1480
1481         if (type == ND_ROUTER_SOLICIT)
1482                 datalen = sizeof(frame.i.rs); /* 8, csum() safe */
1483         else if (type == ND_ROUTER_ADVERT) {
1484                 datalen = sizeof(frame.i.ra); /* 16, csum() safe */
1485                 frame.i.ra.nd_ra_router_lifetime = htons(lifetime);
1486         } else if (type == ND_NEIGHBOR_SOLICIT) {
1487                 datalen = sizeof(frame.i.ns); /* 24, csum() safe */
1488                 memcpy(&frame.i.ns.nd_ns_target, buf, sizeof(struct in6_addr));
1489         } else {
1490                 close(fd);
1491                 return -EINVAL;
1492         }
1493
1494         dst.sin6_addr = *dest;
1495
1496         if (source)
1497                 src.sin6_addr = *source;
1498         else
1499                 src.sin6_addr = in6addr_any;
1500
1501         /* Fill in the IPv6 header */
1502         frame.ip.ip6_vfc = 0x60;
1503         frame.ip.ip6_plen = htons(datalen + len);
1504         frame.ip.ip6_nxt = IPPROTO_ICMPV6;
1505         frame.ip.ip6_hlim = 255;
1506         frame.ip.ip6_dst = dst.sin6_addr;
1507         frame.ip.ip6_src = src.sin6_addr;
1508         /* all other fields are already set to zero */
1509
1510         /* Prepare pseudo header for csum */
1511         memset(&phdr, 0, sizeof(phdr));
1512         phdr.dst = dst.sin6_addr;
1513         phdr.src = src.sin6_addr;
1514         phdr.plen = htonl(datalen + len);
1515         phdr.nxt = IPPROTO_ICMPV6;
1516
1517         /* Fill in remaining ICMP header fields */
1518         frame.i.icmp.icmp6_type = type;
1519         frame.i.icmp.icmp6_cksum = csum(&phdr, &frame.i, datalen, buf, len);
1520
1521         iov[0].iov_base = &frame;
1522         iov[0].iov_len = sizeof(frame.ip) + datalen;
1523
1524         if (buf) {
1525                 iov[1].iov_base = buf;
1526                 iov[1].iov_len = len;
1527                 iovlen = 2;
1528         }
1529
1530         dst.sin6_family = AF_INET6;
1531         msgh.msg_name = &dst;
1532         msgh.msg_namelen = sizeof(dst);
1533         msgh.msg_iov = iov;
1534         msgh.msg_iovlen = iovlen;
1535         msgh.msg_flags = 0;
1536
1537         memset(cbuf, 0, CMSG_SPACE(sizeof(*pinfo)));
1538         cmsg = (struct cmsghdr *)cbuf;
1539         pinfo = (struct in6_pktinfo *)CMSG_DATA(cmsg);
1540         pinfo->ipi6_ifindex = oif;
1541
1542         cmsg->cmsg_len = CMSG_LEN(sizeof(*pinfo));
1543         cmsg->cmsg_level = IPPROTO_IPV6;
1544         cmsg->cmsg_type = IPV6_PKTINFO;
1545         msgh.msg_control = cmsg;
1546         msgh.msg_controllen = cmsg->cmsg_len;
1547
1548         ret = sendmsg(fd, &msgh, 0);
1549
1550         close(fd);
1551         return ret;
1552 }
1553
1554 static inline void ipv6_addr_set(struct in6_addr *addr,
1555                                 uint32_t w1, uint32_t w2,
1556                                 uint32_t w3, uint32_t w4)
1557 {
1558         addr->s6_addr32[0] = w1;
1559         addr->s6_addr32[1] = w2;
1560         addr->s6_addr32[2] = w3;
1561         addr->s6_addr32[3] = w4;
1562 }
1563
1564 static inline void ipv6_addr_solict_mult(const struct in6_addr *addr,
1565                                         struct in6_addr *solicited)
1566 {
1567         ipv6_addr_set(solicited, htonl(0xFF020000), 0, htonl(0x1),
1568                         htonl(0xFF000000) | addr->s6_addr32[3]);
1569 }
1570
1571 static int if_mc_group(int sock, int ifindex, const struct in6_addr *mc_addr,
1572                                                                 int cmd)
1573 {
1574         unsigned int val = 0;
1575         struct ipv6_mreq mreq;
1576         int ret;
1577
1578         memset(&mreq, 0, sizeof(mreq));
1579         mreq.ipv6mr_interface = ifindex;
1580         mreq.ipv6mr_multiaddr = *mc_addr;
1581
1582         ret = setsockopt(sock, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
1583                         &val, sizeof(int));
1584         if (ret < 0) {
1585                 ret = -errno;
1586                 DBG("Cannot set IPV6_MULTICAST_LOOP %d/%s", ret,
1587                         strerror(-ret));
1588                 return ret;
1589         }
1590
1591         ret = setsockopt(sock, IPPROTO_IPV6, cmd, &mreq, sizeof(mreq));
1592         if (ret < 0) {
1593                 ret = -errno;
1594                 DBG("Cannot set option %d %d/%s", cmd, ret, strerror(-ret));
1595                 return ret;
1596         }
1597
1598         return 0;
1599 }
1600
1601 int __connman_inet_ipv6_send_rs(int index, int timeout,
1602                         __connman_inet_rs_cb_t callback, void *user_data)
1603 {
1604         struct xs_cb_data *data;
1605         struct icmp6_filter filter;
1606         struct in6_addr solicit;
1607         struct in6_addr dst = in6addr_all_routers_mc;
1608         int sk;
1609
1610         if (timeout <= 0)
1611                 return -EINVAL;
1612
1613         data = g_try_malloc0(sizeof(struct xs_cb_data));
1614         if (!data)
1615                 return -ENOMEM;
1616
1617         data->callback = callback;
1618         data->user_data = user_data;
1619         data->timeout = g_timeout_add_seconds(timeout, rs_timeout_cb, data);
1620
1621         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1622         if (sk < 0)
1623                 return -errno;
1624
1625         DBG("sock %d", sk);
1626
1627         ICMP6_FILTER_SETBLOCKALL(&filter);
1628         ICMP6_FILTER_SETPASS(ND_ROUTER_ADVERT, &filter);
1629
1630         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1631                                                 sizeof(struct icmp6_filter));
1632
1633         ipv6_addr_solict_mult(&dst, &solicit);
1634         if_mc_group(sk, index, &in6addr_all_nodes_mc, IPV6_JOIN_GROUP);
1635         if_mc_group(sk, index, &solicit, IPV6_JOIN_GROUP);
1636
1637         data->channel = g_io_channel_unix_new(sk);
1638         g_io_channel_set_close_on_unref(data->channel, TRUE);
1639
1640         g_io_channel_set_encoding(data->channel, NULL, NULL);
1641         g_io_channel_set_buffered(data->channel, FALSE);
1642
1643         data->watch_id = g_io_add_watch(data->channel,
1644                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
1645                         icmpv6_event, data);
1646
1647         ndisc_send_unspec(ND_ROUTER_SOLICIT, index, &dst, NULL, NULL, 0, 0);
1648
1649         return 0;
1650 }
1651
1652 static inline void ipv6_addr_advert_mult(const struct in6_addr *addr,
1653                                         struct in6_addr *advert)
1654 {
1655         ipv6_addr_set(advert, htonl(0xFF020000), 0, htonl(0x2),
1656                         htonl(0xFF000000) | addr->s6_addr32[3]);
1657 }
1658
1659 #define MSG_SIZE_SEND 1452
1660
1661 static int inc_len(int len, int inc)
1662 {
1663         if (len > MSG_SIZE_SEND)
1664                 return -EINVAL;
1665
1666         len += inc;
1667         return len;
1668 }
1669
1670 int __connman_inet_ipv6_send_ra(int index, struct in6_addr *src_addr,
1671                                 GSList *prefixes, int router_lifetime)
1672 {
1673         GSList *list;
1674         struct in6_addr src, *source;
1675         struct in6_addr dst = in6addr_all_nodes_mc;
1676         GDHCPIAPrefix *prefix;
1677         unsigned char buf[MSG_SIZE_SEND];
1678         char addr_str[INET6_ADDRSTRLEN];
1679         int sk, err = 0;
1680         int len, count = 0;
1681
1682         if (!prefixes)
1683                 return -EINVAL;
1684
1685         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1686         if (sk < 0)
1687                 return -errno;
1688
1689         if (!src_addr) {
1690                 __connman_inet_get_interface_ll_address(index, AF_INET6, &src);
1691                 source = &src;
1692         } else
1693                 source = src_addr;
1694
1695         DBG("sock %d index %d prefixes %p src %s lifetime %d", sk, index,
1696                 prefixes, inet_ntop(AF_INET6, source, addr_str,
1697                                 INET6_ADDRSTRLEN),
1698                 router_lifetime);
1699
1700         memset(buf, 0, MSG_SIZE_SEND);
1701         len = 0;
1702
1703         for (list = prefixes; list; list = list->next) {
1704                 struct nd_opt_prefix_info *pinfo;
1705
1706                 prefix = list->data;
1707                 pinfo = (struct nd_opt_prefix_info *)(buf + len);
1708
1709                 len = inc_len(len, sizeof(*pinfo));
1710                 if (len < 0) {
1711                         err = len;
1712                         goto out;
1713                 }
1714
1715                 pinfo->nd_opt_pi_type = ND_OPT_PREFIX_INFORMATION;
1716                 pinfo->nd_opt_pi_len = 4;
1717                 pinfo->nd_opt_pi_prefix_len = prefix->prefixlen;
1718                 pinfo->nd_opt_pi_flags_reserved = ND_OPT_PI_FLAG_ONLINK;
1719                 pinfo->nd_opt_pi_flags_reserved |= ND_OPT_PI_FLAG_AUTO;
1720                 if (router_lifetime > 0) {
1721                         pinfo->nd_opt_pi_valid_time = htonl(prefix->valid);
1722                         pinfo->nd_opt_pi_preferred_time =
1723                                                 htonl(prefix->preferred);
1724                 }
1725                 pinfo->nd_opt_pi_reserved2 = 0;
1726
1727                 memcpy(&pinfo->nd_opt_pi_prefix, &prefix->prefix,
1728                                                 sizeof(struct in6_addr));
1729
1730                 DBG("[%d] index %d prefix %s/%d", count, index,
1731                         inet_ntop(AF_INET6, &prefix->prefix, addr_str,
1732                                 INET6_ADDRSTRLEN), prefix->prefixlen);
1733
1734                 count++;
1735         }
1736
1737         if (count > 0) {
1738                 err = ndisc_send_unspec(ND_ROUTER_ADVERT, index, &dst, source,
1739                                         buf, len, router_lifetime);
1740                 if (err < 0)
1741                         DBG("cannot send RA %d/%s", err, strerror(-err));
1742         }
1743
1744 out:
1745         close(sk);
1746         return err;
1747 }
1748
1749 void __connman_inet_ipv6_stop_recv_rs(void *context)
1750 {
1751         if (!context)
1752                 return;
1753
1754         xs_cleanup(context);
1755 }
1756
1757 static int icmpv6_rs_recv(int fd, gpointer user_data)
1758 {
1759         struct msghdr mhdr;
1760         struct iovec iov;
1761         unsigned char chdr[CMSG_BUF_LEN];
1762         unsigned char buf[1540];
1763         struct xs_cb_data *data = user_data;
1764         struct nd_router_solicit *hdr;
1765         struct sockaddr_in6 saddr;
1766         ssize_t len;
1767         __connman_inet_recv_rs_cb_t cb = data->callback;
1768
1769         DBG("");
1770
1771         iov.iov_len = sizeof(buf);
1772         iov.iov_base = buf;
1773
1774         mhdr.msg_name = (void *)&saddr;
1775         mhdr.msg_namelen = sizeof(struct sockaddr_in6);
1776         mhdr.msg_flags = 0;
1777         mhdr.msg_iov = &iov;
1778         mhdr.msg_iovlen = 1;
1779         mhdr.msg_control = (void *)chdr;
1780         mhdr.msg_controllen = CMSG_BUF_LEN;
1781
1782         len = recvmsg(fd, &mhdr, 0);
1783         if (len < 0) {
1784                 cb(NULL, 0, data->user_data);
1785                 return -errno;
1786         }
1787
1788         hdr = (struct nd_router_solicit *)buf;
1789         DBG("code %d len %zd hdr %zd", hdr->nd_rs_code, len,
1790                                 sizeof(struct nd_router_solicit));
1791         if (hdr->nd_rs_code != 0)
1792                 return 0;
1793
1794         cb(hdr, len, data->user_data);
1795         return len;
1796 }
1797
1798 static gboolean icmpv6_rs_event(GIOChannel *chan, GIOCondition cond,
1799                                                                 gpointer data)
1800 {
1801         int fd, ret;
1802
1803         DBG("");
1804
1805         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1806                 return FALSE;
1807
1808         fd = g_io_channel_unix_get_fd(chan);
1809         ret = icmpv6_rs_recv(fd, data);
1810         if (ret == 0)
1811                 return TRUE;
1812
1813         return FALSE;
1814 }
1815
1816 int __connman_inet_ipv6_start_recv_rs(int index,
1817                                         __connman_inet_recv_rs_cb_t callback,
1818                                         void *user_data,
1819                                         void **context)
1820 {
1821         struct xs_cb_data *data;
1822         struct icmp6_filter filter;
1823         char addr_str[INET6_ADDRSTRLEN];
1824         int sk, err;
1825
1826         data = g_try_malloc0(sizeof(struct xs_cb_data));
1827         if (!data)
1828                 return -ENOMEM;
1829
1830         data->callback = callback;
1831         data->user_data = user_data;
1832
1833         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1834         if (sk < 0) {
1835                 g_free(data);
1836                 return -errno;
1837         }
1838
1839         DBG("sock %d", sk);
1840
1841         ICMP6_FILTER_SETBLOCKALL(&filter);
1842         ICMP6_FILTER_SETPASS(ND_ROUTER_SOLICIT, &filter);
1843
1844         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1845                                                 sizeof(struct icmp6_filter));
1846
1847         err = if_mc_group(sk, index, &in6addr_all_routers_mc, IPV6_JOIN_GROUP);
1848         if (err < 0)
1849                 DBG("Cannot join mc %s %d/%s", inet_ntop(AF_INET6,
1850                         &in6addr_all_routers_mc, addr_str, INET6_ADDRSTRLEN),
1851                         err, strerror(-err));
1852
1853         data->channel = g_io_channel_unix_new(sk);
1854         g_io_channel_set_close_on_unref(data->channel, TRUE);
1855
1856         g_io_channel_set_encoding(data->channel, NULL, NULL);
1857         g_io_channel_set_buffered(data->channel, FALSE);
1858
1859         data->watch_id = g_io_add_watch(data->channel,
1860                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
1861                         icmpv6_rs_event, data);
1862
1863         *context = data;
1864
1865         return 0;
1866 }
1867
1868 static gboolean ns_timeout_cb(gpointer user_data)
1869 {
1870         struct xs_cb_data *data = user_data;
1871
1872         DBG("user data %p", user_data);
1873
1874         if (!data)
1875                 return FALSE;
1876
1877         if (data->callback) {
1878                 __connman_inet_ns_cb_t cb = data->callback;
1879                 cb(NULL, 0, &data->addr.sin6_addr, data->user_data);
1880         }
1881
1882         data->timeout = 0;
1883         xs_cleanup(data);
1884         return FALSE;
1885 }
1886
1887 static int icmpv6_nd_recv(int fd, gpointer user_data)
1888 {
1889         struct msghdr mhdr;
1890         struct iovec iov;
1891         unsigned char chdr[CMSG_BUF_LEN];
1892         unsigned char buf[1540];
1893         struct xs_cb_data *data = user_data;
1894         struct nd_neighbor_advert *hdr;
1895         struct sockaddr_in6 saddr;
1896         ssize_t len;
1897         __connman_inet_ns_cb_t cb = data->callback;
1898
1899         DBG("");
1900
1901         iov.iov_len = sizeof(buf);
1902         iov.iov_base = buf;
1903
1904         mhdr.msg_name = (void *)&saddr;
1905         mhdr.msg_namelen = sizeof(struct sockaddr_in6);
1906         mhdr.msg_flags = 0;
1907         mhdr.msg_iov = &iov;
1908         mhdr.msg_iovlen = 1;
1909         mhdr.msg_control = (void *)chdr;
1910         mhdr.msg_controllen = CMSG_BUF_LEN;
1911
1912         len = recvmsg(fd, &mhdr, 0);
1913         if (len < 0) {
1914                 cb(NULL, 0, &data->addr.sin6_addr, data->user_data);
1915                 xs_cleanup(data);
1916                 return -errno;
1917         }
1918
1919         hdr = (struct nd_neighbor_advert *)buf;
1920         DBG("code %d len %zd hdr %zd", hdr->nd_na_code, len,
1921                                 sizeof(struct nd_neighbor_advert));
1922         if (hdr->nd_na_code != 0)
1923                 return 0;
1924
1925         /*
1926          * We can receive any neighbor advertisement so we need to check if the
1927          * packet was meant for us and ignore the packet otherwise.
1928          */
1929         if (memcmp(&data->addr.sin6_addr, &hdr->nd_na_target,
1930                         sizeof(struct in6_addr)))
1931                 return 0;
1932
1933         cb(hdr, len, &data->addr.sin6_addr, data->user_data);
1934         xs_cleanup(data);
1935
1936         return len;
1937 }
1938
1939 static gboolean icmpv6_nd_event(GIOChannel *chan, GIOCondition cond,
1940                                                                 gpointer data)
1941 {
1942         int fd, ret;
1943
1944         DBG("");
1945
1946         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1947                 return FALSE;
1948
1949         fd = g_io_channel_unix_get_fd(chan);
1950         ret = icmpv6_nd_recv(fd, data);
1951         if (ret == 0)
1952                 return TRUE;
1953
1954         return FALSE;
1955 }
1956
1957 int __connman_inet_ipv6_do_dad(int index, int timeout_ms,
1958                                 struct in6_addr *addr,
1959                                 __connman_inet_ns_cb_t callback,
1960                                 void *user_data)
1961 {
1962         struct xs_cb_data *data;
1963         struct icmp6_filter filter;
1964         struct in6_addr solicit;
1965         int sk, err, val = 1;
1966
1967         if (timeout_ms <= 0)
1968                 return -EINVAL;
1969
1970         data = g_try_malloc0(sizeof(struct xs_cb_data));
1971         if (!data)
1972                 return -ENOMEM;
1973
1974         data->callback = callback;
1975         data->user_data = user_data;
1976         data->timeout = g_timeout_add_full(G_PRIORITY_DEFAULT,
1977                                         (guint)timeout_ms,
1978                                         ns_timeout_cb,
1979                                         data,
1980                                         NULL);
1981         memcpy(&data->addr.sin6_addr, addr, sizeof(struct in6_addr));
1982
1983         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1984         if (sk < 0)
1985                 return -errno;
1986
1987         DBG("sock %d", sk);
1988
1989         ICMP6_FILTER_SETBLOCKALL(&filter);
1990         ICMP6_FILTER_SETPASS(ND_NEIGHBOR_ADVERT, &filter);
1991
1992         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1993                                                 sizeof(struct icmp6_filter));
1994
1995         if (setsockopt(sk, IPPROTO_IPV6, IPV6_RECVPKTINFO,
1996                                                 &val, sizeof(val)) < 0) {
1997                 err = -errno;
1998                 DBG("Cannot set IPV6_RECVPKTINFO %d/%s", err,
1999                                                         strerror(-err));
2000                 close(sk);
2001                 return err;
2002         }
2003
2004         if (setsockopt(sk, IPPROTO_IPV6, IPV6_RECVHOPLIMIT,
2005                                                 &val, sizeof(val)) < 0) {
2006                 err = -errno;
2007                 DBG("Cannot set IPV6_RECVHOPLIMIT %d/%s", err,
2008                                                         strerror(-err));
2009                 close(sk);
2010                 return err;
2011         }
2012
2013         val = 0;
2014         setsockopt(sk, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, &val, sizeof(val));
2015
2016         ipv6_addr_solict_mult(addr, &solicit);
2017         if_mc_group(sk, index, &in6addr_all_nodes_mc, IPV6_JOIN_GROUP);
2018         if_mc_group(sk, index, &solicit, IPV6_JOIN_GROUP);
2019
2020         data->channel = g_io_channel_unix_new(sk);
2021         g_io_channel_set_close_on_unref(data->channel, TRUE);
2022
2023         g_io_channel_set_encoding(data->channel, NULL, NULL);
2024         g_io_channel_set_buffered(data->channel, FALSE);
2025
2026         data->watch_id = g_io_add_watch(data->channel,
2027                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
2028                         icmpv6_nd_event, data);
2029
2030         err = ndisc_send_unspec(ND_NEIGHBOR_SOLICIT, index, &solicit, NULL,
2031                         (unsigned char *)addr, 0, 0);
2032         if (err < 0) {
2033                 DBG("Cannot send NS %d/%s", err, strerror(-err));
2034                 xs_cleanup(data);
2035         }
2036
2037         return err;
2038 }
2039
2040 GSList *__connman_inet_ipv6_get_prefixes(struct nd_router_advert *hdr,
2041                                         unsigned int length)
2042 {
2043         GSList *prefixes = NULL;
2044         uint8_t *pos;
2045         int len;
2046
2047         if (length <= sizeof(struct nd_router_advert))
2048                 return NULL;
2049
2050         len = length - sizeof(struct nd_router_advert);
2051         pos = (uint8_t *)hdr + sizeof(struct nd_router_advert);
2052
2053         while (len > 0) {
2054                 struct nd_opt_prefix_info *pinfo;
2055                 char prefix_str[INET6_ADDRSTRLEN+1], *str;
2056                 const char *prefix;
2057                 int optlen;
2058
2059                 if (len < 2)
2060                         break;
2061
2062                 optlen = pos[1] << 3;
2063                 if (optlen == 0 || optlen > len)
2064                         break;
2065
2066                 switch (pos[0]) {
2067                 case ND_OPT_PREFIX_INFORMATION:
2068                         pinfo = (struct nd_opt_prefix_info *)pos;
2069                         prefix = inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
2070                                         prefix_str, INET6_ADDRSTRLEN);
2071                         if (!prefix)
2072                                 break;
2073
2074                         str = g_strdup_printf("%s/%d", prefix,
2075                                                 pinfo->nd_opt_pi_prefix_len);
2076                         prefixes = g_slist_prepend(prefixes, str);
2077
2078                         DBG("prefix %s", str);
2079
2080                         break;
2081                 }
2082
2083                 len -= optlen;
2084                 pos += optlen;
2085         }
2086
2087         return prefixes;
2088 }
2089
2090 static int get_dest_addr(int family, int index, char *buf, int len)
2091 {
2092         struct ifreq ifr;
2093         void *addr;
2094         int sk;
2095
2096         sk = socket(family, SOCK_DGRAM | SOCK_CLOEXEC, 0);
2097         if (sk < 0)
2098                 return -errno;
2099
2100         memset(&ifr, 0, sizeof(ifr));
2101         ifr.ifr_ifindex = index;
2102
2103         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
2104                 DBG("SIOCGIFNAME (%d/%s)", errno, strerror(errno));
2105                 close(sk);
2106                 return -errno;
2107         }
2108
2109         if (ioctl(sk, SIOCGIFFLAGS, &ifr) < 0) {
2110                 DBG("SIOCGIFFLAGS (%d/%s)", errno, strerror(errno));
2111                 close(sk);
2112                 return -errno;
2113         }
2114
2115         if ((ifr.ifr_flags & IFF_POINTOPOINT) == 0) {
2116                 close(sk);
2117                 errno = EINVAL;
2118                 return -errno;
2119         }
2120
2121         DBG("index %d %s", index, ifr.ifr_name);
2122
2123         if (ioctl(sk, SIOCGIFDSTADDR, &ifr) < 0) {
2124                 connman_error("Get destination address failed (%s)",
2125                                                         strerror(errno));
2126                 close(sk);
2127                 return -errno;
2128         }
2129
2130         close(sk);
2131
2132         switch (family) {
2133         case AF_INET:
2134                 addr = &((struct sockaddr_in *)&ifr.ifr_dstaddr)->sin_addr;
2135                 break;
2136         case AF_INET6:
2137                 addr = &((struct sockaddr_in6 *)&ifr.ifr_dstaddr)->sin6_addr;
2138                 break;
2139         default:
2140                 errno = EINVAL;
2141                 return -errno;
2142         }
2143
2144         if (!inet_ntop(family, addr, buf, len)) {
2145                 DBG("error %d/%s", errno, strerror(errno));
2146                 return -errno;
2147         }
2148
2149         return 0;
2150 }
2151
2152 int connman_inet_get_dest_addr(int index, char **dest)
2153 {
2154         char addr[INET_ADDRSTRLEN];
2155         int ret;
2156
2157         ret = get_dest_addr(PF_INET, index, addr, INET_ADDRSTRLEN);
2158         if (ret < 0)
2159                 return ret;
2160
2161         *dest = g_strdup(addr);
2162
2163         DBG("destination %s", *dest);
2164
2165         return 0;
2166 }
2167
2168 int connman_inet_ipv6_get_dest_addr(int index, char **dest)
2169 {
2170         char addr[INET6_ADDRSTRLEN];
2171         int ret;
2172
2173         ret = get_dest_addr(PF_INET6, index, addr, INET6_ADDRSTRLEN);
2174         if (ret < 0)
2175                 return ret;
2176
2177         *dest = g_strdup(addr);
2178
2179         DBG("destination %s", *dest);
2180
2181         return 0;
2182 }
2183
2184 int __connman_inet_rtnl_open(struct __connman_inet_rtnl_handle *rth)
2185 {
2186         int sndbuf = 1024;
2187         int rcvbuf = 1024 * 4;
2188
2189         rth->fd = socket(AF_NETLINK, SOCK_RAW | SOCK_CLOEXEC, NETLINK_ROUTE);
2190         if (rth->fd < 0) {
2191                 connman_error("Can not open netlink socket: %s",
2192                                                 strerror(errno));
2193                 return -errno;
2194         }
2195
2196         if (setsockopt(rth->fd, SOL_SOCKET, SO_SNDBUF, &sndbuf,
2197                         sizeof(sndbuf)) < 0) {
2198                 connman_error("SO_SNDBUF: %s", strerror(errno));
2199                 return -errno;
2200         }
2201
2202         if (setsockopt(rth->fd, SOL_SOCKET, SO_RCVBUF, &rcvbuf,
2203                         sizeof(rcvbuf)) < 0) {
2204                 connman_error("SO_RCVBUF: %s", strerror(errno));
2205                 return -errno;
2206         }
2207
2208         memset(&rth->local, 0, sizeof(rth->local));
2209         rth->local.nl_family = AF_NETLINK;
2210         rth->local.nl_groups = 0;
2211
2212         if (bind(rth->fd, (struct sockaddr *)&rth->local,
2213                                                 sizeof(rth->local)) < 0) {
2214                 connman_error("Can not bind netlink socket: %s",
2215                                                         strerror(errno));
2216                 return -errno;
2217         }
2218
2219         rth->seq = time(NULL);
2220
2221         DBG("fd %d", rth->fd);
2222
2223         return 0;
2224 }
2225
2226 struct inet_rtnl_cb_data {
2227         GIOChannel *channel;
2228         __connman_inet_rtnl_cb_t callback;
2229         guint rtnl_timeout;
2230         guint watch_id;
2231         struct __connman_inet_rtnl_handle *rtnl;
2232         void *user_data;
2233 };
2234
2235 static void inet_rtnl_cleanup(struct inet_rtnl_cb_data *data)
2236 {
2237         struct __connman_inet_rtnl_handle *rth = data->rtnl;
2238
2239         if (data->channel) {
2240                 g_io_channel_shutdown(data->channel, TRUE, NULL);
2241                 g_io_channel_unref(data->channel);
2242                 data->channel = NULL;
2243         }
2244
2245         DBG("data %p", data);
2246
2247         if (data->rtnl_timeout > 0)
2248                 g_source_remove(data->rtnl_timeout);
2249
2250         if (data->watch_id > 0)
2251                 g_source_remove(data->watch_id);
2252
2253         if (rth) {
2254                 __connman_inet_rtnl_close(rth);
2255                 g_free(rth);
2256         }
2257
2258         g_free(data);
2259 }
2260
2261 static gboolean inet_rtnl_timeout_cb(gpointer user_data)
2262 {
2263         struct inet_rtnl_cb_data *data = user_data;
2264
2265         DBG("user data %p", user_data);
2266
2267         if (!data)
2268                 return FALSE;
2269
2270         if (data->callback)
2271                 data->callback(NULL, data->user_data);
2272
2273         data->rtnl_timeout = 0;
2274         inet_rtnl_cleanup(data);
2275         return FALSE;
2276 }
2277
2278 static int inet_rtnl_recv(GIOChannel *chan, gpointer user_data)
2279 {
2280         struct inet_rtnl_cb_data *rtnl_data = user_data;
2281         struct __connman_inet_rtnl_handle *rth = rtnl_data->rtnl;
2282         struct nlmsghdr *h = NULL;
2283         struct sockaddr_nl nladdr;
2284         socklen_t addr_len = sizeof(nladdr);
2285         unsigned char buf[4096];
2286         void *ptr = buf;
2287         gsize len;
2288         int status, fd;
2289
2290         memset(buf, 0, sizeof(buf));
2291         memset(&nladdr, 0, sizeof(nladdr));
2292
2293         fd = g_io_channel_unix_get_fd(chan);
2294
2295         status = recvfrom(fd, buf, sizeof(buf), 0,
2296                        (struct sockaddr *) &nladdr, &addr_len);
2297         if (status < 0) {
2298                 if (errno == EINTR || errno == EAGAIN)
2299                         return 0;
2300
2301                 return -1;
2302         }
2303
2304         if (status == 0)
2305                 return -1;
2306
2307         if (nladdr.nl_pid != 0) { /* not sent by kernel, ignore */
2308                 DBG("Received msg from %u, ignoring it", nladdr.nl_pid);
2309                 return 0;
2310         }
2311
2312         len = status;
2313
2314         while (len > 0) {
2315                 struct nlmsgerr *err;
2316
2317                 h = ptr;
2318
2319                 if (!NLMSG_OK(h, len))
2320                         return -1;
2321
2322                 if (h->nlmsg_seq != rth->seq) {
2323                         /* Skip this msg */
2324                         DBG("skip %d/%d len %d", rth->seq,
2325                                 h->nlmsg_seq, h->nlmsg_len);
2326
2327                         len -= h->nlmsg_len;
2328                         ptr += h->nlmsg_len;
2329                         continue;
2330                 }
2331
2332                 switch (h->nlmsg_type) {
2333                 case NLMSG_NOOP:
2334                 case NLMSG_OVERRUN:
2335                         return -1;
2336
2337                 case NLMSG_ERROR:
2338                         err = (struct nlmsgerr *)NLMSG_DATA(h);
2339                         connman_error("RTNETLINK answers %s (%d)",
2340                                 strerror(-err->error), -err->error);
2341                         return err->error;
2342                 }
2343
2344                 break;
2345         }
2346
2347         if (h->nlmsg_seq == rth->seq) {
2348                 DBG("received %d seq %d", h->nlmsg_len, h->nlmsg_seq);
2349
2350                 rtnl_data->callback(h, rtnl_data->user_data);
2351
2352                 inet_rtnl_cleanup(rtnl_data);
2353         }
2354
2355         return 0;
2356 }
2357
2358 static gboolean inet_rtnl_event(GIOChannel *chan, GIOCondition cond,
2359                                                         gpointer user_data)
2360 {
2361         int ret;
2362
2363         DBG("");
2364
2365         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
2366                 return FALSE;
2367
2368         ret = inet_rtnl_recv(chan, user_data);
2369         if (ret != 0)
2370                 return TRUE;
2371
2372         return FALSE;
2373 }
2374
2375 int __connman_inet_rtnl_talk(struct __connman_inet_rtnl_handle *rtnl,
2376                         struct nlmsghdr *n, int timeout,
2377                         __connman_inet_rtnl_cb_t callback, void *user_data)
2378 {
2379         struct sockaddr_nl nladdr;
2380         struct inet_rtnl_cb_data *data;
2381         unsigned seq;
2382         int err;
2383
2384         memset(&nladdr, 0, sizeof(nladdr));
2385         nladdr.nl_family = AF_NETLINK;
2386
2387         n->nlmsg_seq = seq = ++rtnl->seq;
2388
2389         if (callback) {
2390                 data = g_try_malloc0(sizeof(struct inet_rtnl_cb_data));
2391                 if (!data)
2392                         return -ENOMEM;
2393
2394                 data->callback = callback;
2395                 data->user_data = user_data;
2396                 data->rtnl = rtnl;
2397                 data->rtnl_timeout = g_timeout_add_seconds(timeout,
2398                                                 inet_rtnl_timeout_cb, data);
2399
2400                 data->channel = g_io_channel_unix_new(rtnl->fd);
2401                 g_io_channel_set_close_on_unref(data->channel, TRUE);
2402
2403                 g_io_channel_set_encoding(data->channel, NULL, NULL);
2404                 g_io_channel_set_buffered(data->channel, FALSE);
2405
2406                 data->watch_id = g_io_add_watch(data->channel,
2407                                 G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
2408                                                 inet_rtnl_event, data);
2409         } else
2410                 n->nlmsg_flags |= NLM_F_ACK;
2411
2412         err = sendto(rtnl->fd, &rtnl->req.n, rtnl->req.n.nlmsg_len, 0,
2413                 (struct sockaddr *) &nladdr, sizeof(nladdr));
2414         DBG("handle %p len %d", rtnl, rtnl->req.n.nlmsg_len);
2415         if (err < 0) {
2416                 connman_error("Can not talk to rtnetlink err %d %s",
2417                         -errno, strerror(errno));
2418                 return -errno;
2419         }
2420
2421         if ((unsigned int)err != rtnl->req.n.nlmsg_len) {
2422                 connman_error("Sent %d bytes, msg truncated", err);
2423                 return -EINVAL;
2424         }
2425
2426         return 0;
2427 }
2428
2429 void __connman_inet_rtnl_close(struct __connman_inet_rtnl_handle *rth)
2430 {
2431         DBG("handle %p", rth);
2432
2433         if (rth->fd >= 0) {
2434                 close(rth->fd);
2435                 rth->fd = -1;
2436         }
2437 }
2438
2439 int __connman_inet_rtnl_addattr32(struct nlmsghdr *n, size_t maxlen, int type,
2440                                 __u32 data)
2441 {
2442         int len = RTA_LENGTH(4);
2443         struct rtattr *rta;
2444
2445         if (NLMSG_ALIGN(n->nlmsg_len) + len > maxlen) {
2446                 DBG("Error! max allowed bound %zd exceeded", maxlen);
2447                 return -1;
2448         }
2449         rta = NLMSG_TAIL(n);
2450         rta->rta_type = type;
2451         rta->rta_len = len;
2452         memcpy(RTA_DATA(rta), &data, 4);
2453         n->nlmsg_len = NLMSG_ALIGN(n->nlmsg_len) + len;
2454
2455         return 0;
2456 }
2457
2458 static int parse_rtattr(struct rtattr *tb[], int max,
2459                         struct rtattr *rta, int len)
2460 {
2461         memset(tb, 0, sizeof(struct rtattr *) * (max + 1));
2462         while (RTA_OK(rta, len)) {
2463                 if ((rta->rta_type <= max) && (!tb[rta->rta_type]))
2464                         tb[rta->rta_type] = rta;
2465                 rta = RTA_NEXT(rta, len);
2466         }
2467         if (len)
2468                 connman_error("Deficit %d, rta_len=%d", len, rta->rta_len);
2469
2470         return 0;
2471 }
2472
2473 struct get_route_cb_data {
2474         connman_inet_addr_cb_t callback;
2475         void *user_data;
2476 };
2477
2478 static void get_route_cb(struct nlmsghdr *answer, void *user_data)
2479 {
2480         struct get_route_cb_data *data = user_data;
2481         struct rtattr *tb[RTA_MAX+1];
2482         struct rtmsg *r = NLMSG_DATA(answer);
2483         int len, index = -1;
2484         char abuf[256];
2485         const char *addr = NULL;
2486
2487         DBG("answer %p data %p", answer, user_data);
2488
2489         if (!answer)
2490                 goto out;
2491
2492         len = answer->nlmsg_len;
2493
2494         if (answer->nlmsg_type != RTM_NEWROUTE &&
2495                                 answer->nlmsg_type != RTM_DELROUTE) {
2496                 connman_error("Not a route: %08x %08x %08x",
2497                         answer->nlmsg_len, answer->nlmsg_type,
2498                         answer->nlmsg_flags);
2499                 goto out;
2500         }
2501
2502         len -= NLMSG_LENGTH(sizeof(*r));
2503         if (len < 0) {
2504                 connman_error("BUG: wrong nlmsg len %d", len);
2505                 goto out;
2506         }
2507
2508         parse_rtattr(tb, RTA_MAX, RTM_RTA(r), len);
2509
2510         if (tb[RTA_OIF])
2511                 index = *(int *)RTA_DATA(tb[RTA_OIF]);
2512
2513         if (tb[RTA_GATEWAY])
2514                 addr = inet_ntop(r->rtm_family,
2515                                 RTA_DATA(tb[RTA_GATEWAY]),
2516                                 abuf, sizeof(abuf));
2517
2518         DBG("addr %s index %d user %p", addr, index, data->user_data);
2519
2520 out:
2521         if (data && data->callback)
2522                 data->callback(addr, index, data->user_data);
2523
2524         g_free(data);
2525
2526         return;
2527 }
2528
2529 /*
2530  * Return the interface index that contains route to host.
2531  */
2532 int __connman_inet_get_route(const char *dest_address,
2533                         connman_inet_addr_cb_t callback, void *user_data)
2534 {
2535         struct get_route_cb_data *data;
2536         struct addrinfo hints, *rp;
2537         struct __connman_inet_rtnl_handle *rth;
2538         int err;
2539
2540         DBG("dest %s", dest_address);
2541
2542         if (!dest_address)
2543                 return -EINVAL;
2544
2545         memset(&hints, 0, sizeof(hints));
2546         hints.ai_family = AF_UNSPEC;
2547         hints.ai_flags = AI_PASSIVE | AI_NUMERICSERV | AI_NUMERICHOST;
2548
2549         err = getaddrinfo(dest_address, NULL, &hints, &rp);
2550         if (err)
2551                 return -EINVAL;
2552
2553         rth = g_try_malloc0(sizeof(struct __connman_inet_rtnl_handle));
2554         if (!rth) {
2555                 freeaddrinfo(rp);
2556                 return -ENOMEM;
2557         }
2558
2559         rth->req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2560         rth->req.n.nlmsg_flags = NLM_F_REQUEST;
2561         rth->req.n.nlmsg_type = RTM_GETROUTE;
2562         rth->req.u.r.rt.rtm_family = rp->ai_family;
2563         rth->req.u.r.rt.rtm_table = 0;
2564         rth->req.u.r.rt.rtm_protocol = 0;
2565         rth->req.u.r.rt.rtm_scope = 0;
2566         rth->req.u.r.rt.rtm_type = 0;
2567         rth->req.u.r.rt.rtm_src_len = 0;
2568         rth->req.u.r.rt.rtm_dst_len = rp->ai_addrlen << 3;
2569         rth->req.u.r.rt.rtm_tos = 0;
2570
2571         __connman_inet_rtnl_addattr_l(&rth->req.n, sizeof(rth->req), RTA_DST,
2572                                 &rp->ai_addr, rp->ai_addrlen);
2573
2574         freeaddrinfo(rp);
2575
2576         err = __connman_inet_rtnl_open(rth);
2577         if (err < 0)
2578                 goto fail;
2579
2580         data = g_try_malloc(sizeof(struct get_route_cb_data));
2581         if (!data) {
2582                 err = -ENOMEM;
2583                 goto done;
2584         }
2585
2586         data->callback = callback;
2587         data->user_data = user_data;
2588
2589 #define GET_ROUTE_TIMEOUT 2
2590         err = __connman_inet_rtnl_talk(rth, &rth->req.n, GET_ROUTE_TIMEOUT,
2591                                 get_route_cb, data);
2592         if (err < 0) {
2593                 g_free(data);
2594                 goto done;
2595         }
2596
2597         return 0;
2598
2599 done:
2600         __connman_inet_rtnl_close(rth);
2601
2602 fail:
2603         g_free(rth);
2604         return err;
2605 }
2606
2607 int connman_inet_check_ipaddress(const char *host)
2608 {
2609         struct addrinfo hints;
2610         struct addrinfo *addr;
2611         int result;
2612
2613         memset(&hints, 0, sizeof(struct addrinfo));
2614         hints.ai_flags = AI_NUMERICHOST;
2615         addr = NULL;
2616
2617         result = getaddrinfo(host, NULL, &hints, &addr);
2618         if (result == 0)
2619                 result = addr->ai_family;
2620         freeaddrinfo(addr);
2621
2622         return result;
2623 }
2624
2625 /* Check routine modified from ics-dhcp 4.2.3-P2 */
2626 bool connman_inet_check_hostname(const char *ptr, size_t len)
2627 {
2628         const char *p;
2629
2630         /*
2631          * Not empty or complete length not over 255 characters.
2632          */
2633         if ((len == 0) || (len > 256))
2634                 return false;
2635
2636         /*
2637          * Consists of [[:alnum:]-]+ labels separated by [.]
2638          * a [_] is against RFC but seems to be "widely used"
2639          */
2640         for (p = ptr; (*p != 0) && (len-- > 0); p++) {
2641
2642                 if ((*p == '-') || (*p == '_')) {
2643                         /*
2644                          * Not allowed at begin or end of a label.
2645                          */
2646                         if (((p - ptr) == 0) || (len == 0) || (p[1] == '.'))
2647                                 return false;
2648
2649                 } else if (*p == '.') {
2650                         /*
2651                          * Each label has to be 1-63 characters;
2652                          * we allow [.] at the end ('foo.bar.')
2653                          */
2654                         size_t d = p - ptr;
2655
2656                         if ((d <= 0) || (d >= 64))
2657                                 return false;
2658
2659                         ptr = p + 1; /* Jump to the next label */
2660
2661                 } else if (isalnum((unsigned char)*p) == 0) {
2662                         /*
2663                          * Also numbers at the begin are fine
2664                          */
2665                         return false;
2666                 }
2667         }
2668
2669         return true;
2670 }
2671
2672 char **__connman_inet_get_running_interfaces(void)
2673 {
2674         char **result;
2675         struct ifconf ifc;
2676         struct ifreq *ifr = NULL;
2677         int sk, i, numif, count = 0;
2678
2679         memset(&ifc, 0, sizeof(ifc));
2680
2681         sk = socket(AF_INET, SOCK_DGRAM, 0);
2682         if (sk < 0)
2683                 return NULL;
2684
2685         if (ioctl(sk, SIOCGIFCONF, &ifc) < 0)
2686                 goto error;
2687
2688         /*
2689          * Allocate some extra bytes just in case there will
2690          * be new interfaces added between two SIOCGIFCONF
2691          * calls.
2692          */
2693         ifr = g_try_malloc0(ifc.ifc_len * 2);
2694         if (!ifr)
2695                 goto error;
2696
2697         ifc.ifc_req = ifr;
2698
2699         if (ioctl(sk, SIOCGIFCONF, &ifc) < 0)
2700                 goto error;
2701
2702         numif = ifc.ifc_len / sizeof(struct ifreq);
2703
2704         result = g_try_malloc0((numif + 1) * sizeof(char *));
2705         if (!result)
2706                 goto error;
2707
2708         close(sk);
2709
2710         for (i = 0; i < numif; i++) {
2711                 struct ifreq *r = &ifr[i];
2712                 struct in6_addr *addr6;
2713                 in_addr_t addr4;
2714
2715                 /*
2716                  * Note that we do not return loopback interfaces here as they
2717                  * are not needed for our purposes.
2718                  */
2719                 switch (r->ifr_addr.sa_family) {
2720                 case AF_INET:
2721                         addr4 = ntohl(((struct sockaddr_in *)
2722                                                 &r->ifr_addr)->sin_addr.s_addr);
2723                         if (((addr4 & 0xff000000) >> 24) == 127)
2724                                 continue;
2725                         break;
2726                 case AF_INET6:
2727                         addr6 = &((struct sockaddr_in6 *)
2728                                                 &r->ifr_addr)->sin6_addr;
2729                         if (IN6_IS_ADDR_LINKLOCAL(addr6))
2730                                 continue;
2731                         break;
2732                 }
2733
2734                 result[count++] = g_strdup(r->ifr_name);
2735         }
2736
2737         g_free(ifr);
2738
2739         if (count < numif)
2740         {
2741                 char **prev_result = result;
2742                 result = g_try_realloc(result, (count + 1) * sizeof(char *));
2743                 if (!result) {
2744                         g_free(prev_result);
2745                         goto error;
2746                 }
2747         }
2748
2749         return result;
2750
2751 error:
2752         close(sk);
2753         g_free(ifr);
2754         return NULL;
2755 }
2756
2757 bool connman_inet_is_ipv6_supported()
2758 {
2759         int sk;
2760
2761         sk = socket(PF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
2762         if (sk < 0)
2763                 return false;
2764
2765         close(sk);
2766         return true;
2767 }
2768
2769 int __connman_inet_get_interface_address(int index, int family, void *address)
2770 {
2771         struct ifaddrs *ifaddr, *ifa;
2772         int err = -ENOENT;
2773         char name[IF_NAMESIZE];
2774
2775         if (!if_indextoname(index, name))
2776                 return -EINVAL;
2777
2778         DBG("index %d interface %s", index, name);
2779
2780         if (getifaddrs(&ifaddr) < 0) {
2781                 err = -errno;
2782                 DBG("Cannot get addresses err %d/%s", err, strerror(-err));
2783                 return err;
2784         }
2785
2786         for (ifa = ifaddr; ifa; ifa = ifa->ifa_next) {
2787                 if (!ifa->ifa_addr)
2788                         continue;
2789
2790                 if (strncmp(ifa->ifa_name, name, IF_NAMESIZE) == 0 &&
2791                                         ifa->ifa_addr->sa_family == family) {
2792                         if (family == AF_INET) {
2793                                 struct sockaddr_in *in4 = (struct sockaddr_in *)
2794                                         ifa->ifa_addr;
2795                                 if (in4->sin_addr.s_addr == INADDR_ANY)
2796                                         continue;
2797                                 memcpy(address, &in4->sin_addr,
2798                                                         sizeof(struct in_addr));
2799                         } else if (family == AF_INET6) {
2800                                 struct sockaddr_in6 *in6 =
2801                                         (struct sockaddr_in6 *)ifa->ifa_addr;
2802                                 if (memcmp(&in6->sin6_addr, &in6addr_any,
2803                                                 sizeof(struct in6_addr)) == 0)
2804                                         continue;
2805                                 memcpy(address, &in6->sin6_addr,
2806                                                 sizeof(struct in6_addr));
2807
2808                         } else {
2809                                 err = -EINVAL;
2810                                 goto out;
2811                         }
2812
2813                         err = 0;
2814                         break;
2815                 }
2816         }
2817
2818 out:
2819         freeifaddrs(ifaddr);
2820         return err;
2821 }
2822
2823 static int iprule_modify(int cmd, int family, uint32_t table_id,
2824                         uint32_t fwmark)
2825 {
2826         struct __connman_inet_rtnl_handle rth;
2827         int ret;
2828
2829         memset(&rth, 0, sizeof(rth));
2830
2831         rth.req.n.nlmsg_type = cmd;
2832         rth.req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2833         rth.req.n.nlmsg_flags = NLM_F_REQUEST;
2834         rth.req.u.r.rt.rtm_family = family;
2835         rth.req.u.r.rt.rtm_protocol = RTPROT_BOOT;
2836         rth.req.u.r.rt.rtm_scope = RT_SCOPE_UNIVERSE;
2837         rth.req.u.r.rt.rtm_table = table_id;
2838         rth.req.u.r.rt.rtm_type = RTN_UNSPEC;
2839         rth.req.u.r.rt.rtm_flags = 0;
2840
2841         if (cmd == RTM_NEWRULE) {
2842                 rth.req.n.nlmsg_flags |= NLM_F_CREATE|NLM_F_EXCL;
2843                 rth.req.u.r.rt.rtm_type = RTN_UNICAST;
2844         }
2845
2846         __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2847                                                         FRA_FWMARK, fwmark);
2848
2849         if (table_id < 256) {
2850                 rth.req.u.r.rt.rtm_table = table_id;
2851         } else {
2852                 rth.req.u.r.rt.rtm_table = RT_TABLE_UNSPEC;
2853                 __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2854                                                 FRA_TABLE, table_id);
2855         }
2856
2857         if (rth.req.u.r.rt.rtm_family == AF_UNSPEC)
2858                 rth.req.u.r.rt.rtm_family = AF_INET;
2859
2860         ret = __connman_inet_rtnl_open(&rth);
2861         if (ret < 0)
2862                 goto done;
2863
2864         ret = __connman_inet_rtnl_send(&rth, &rth.req.n);
2865
2866 done:
2867         __connman_inet_rtnl_close(&rth);
2868
2869         return ret;
2870 }
2871
2872 int __connman_inet_add_fwmark_rule(uint32_t table_id, int family, uint32_t fwmark)
2873 {
2874         /* ip rule add fwmark 9876 table 1234 */
2875
2876         return iprule_modify(RTM_NEWRULE, family, table_id, fwmark);
2877 }
2878
2879 int __connman_inet_del_fwmark_rule(uint32_t table_id, int family, uint32_t fwmark)
2880 {
2881         return iprule_modify(RTM_DELRULE, family, table_id, fwmark);
2882 }
2883
2884 static int iproute_default_modify(int cmd, uint32_t table_id, int ifindex,
2885                         const char *gateway)
2886 {
2887         struct __connman_inet_rtnl_handle rth;
2888         unsigned char buf[sizeof(struct in6_addr)];
2889         int ret, len;
2890         int family = connman_inet_check_ipaddress(gateway);
2891
2892         switch (family) {
2893         case AF_INET:
2894                 len = 4;
2895                 break;
2896         case AF_INET6:
2897                 len = 16;
2898                 break;
2899         default:
2900                 return -EINVAL;
2901         }
2902
2903         ret = inet_pton(family, gateway, buf);
2904         if (ret <= 0)
2905                 return -EINVAL;
2906
2907         memset(&rth, 0, sizeof(rth));
2908
2909         rth.req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2910         rth.req.n.nlmsg_flags = NLM_F_REQUEST | NLM_F_CREATE | NLM_F_EXCL;
2911         rth.req.n.nlmsg_type = cmd;
2912         rth.req.u.r.rt.rtm_family = family;
2913         rth.req.u.r.rt.rtm_table = RT_TABLE_MAIN;
2914         rth.req.u.r.rt.rtm_scope = RT_SCOPE_NOWHERE;
2915         rth.req.u.r.rt.rtm_protocol = RTPROT_BOOT;
2916         rth.req.u.r.rt.rtm_scope = RT_SCOPE_UNIVERSE;
2917         rth.req.u.r.rt.rtm_type = RTN_UNICAST;
2918
2919         __connman_inet_rtnl_addattr_l(&rth.req.n, sizeof(rth.req), RTA_GATEWAY,
2920                                                                 buf, len);
2921         if (table_id < 256) {
2922                 rth.req.u.r.rt.rtm_table = table_id;
2923         } else {
2924                 rth.req.u.r.rt.rtm_table = RT_TABLE_UNSPEC;
2925                 __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2926                                                         RTA_TABLE, table_id);
2927         }
2928
2929         __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2930                                                         RTA_OIF, ifindex);
2931
2932         ret = __connman_inet_rtnl_open(&rth);
2933         if (ret < 0)
2934                 goto done;
2935
2936         ret = __connman_inet_rtnl_send(&rth, &rth.req.n);
2937
2938 done:
2939         __connman_inet_rtnl_close(&rth);
2940
2941         return ret;
2942 }
2943
2944 int __connman_inet_add_default_to_table(uint32_t table_id, int ifindex,
2945                                                 const char *gateway)
2946 {
2947         /* ip route add default via 1.2.3.4 dev wlan0 table 1234 */
2948
2949         return iproute_default_modify(RTM_NEWROUTE, table_id, ifindex, gateway);
2950 }
2951
2952 int __connman_inet_del_default_from_table(uint32_t table_id, int ifindex,
2953                                                 const char *gateway)
2954 {
2955         /* ip route del default via 1.2.3.4 dev wlan0 table 1234 */
2956
2957         return iproute_default_modify(RTM_DELROUTE, table_id, ifindex, gateway);
2958 }
2959
2960 int __connman_inet_get_interface_ll_address(int index, int family,
2961                                                                 void *address)
2962 {
2963         struct ifaddrs *ifaddr, *ifa;
2964         int err = -ENOENT;
2965         char name[IF_NAMESIZE];
2966
2967         if (!if_indextoname(index, name))
2968                 return -EINVAL;
2969
2970         DBG("index %d interface %s", index, name);
2971
2972         if (getifaddrs(&ifaddr) < 0) {
2973                 err = -errno;
2974                 DBG("Cannot get addresses err %d/%s", err, strerror(-err));
2975                 return err;
2976         }
2977
2978         for (ifa = ifaddr; ifa; ifa = ifa->ifa_next) {
2979                 if (!ifa->ifa_addr)
2980                         continue;
2981
2982                 if (strncmp(ifa->ifa_name, name, IF_NAMESIZE) == 0 &&
2983                                         ifa->ifa_addr->sa_family == family) {
2984                         if (family == AF_INET) {
2985                                 struct sockaddr_in *in4 = (struct sockaddr_in *)
2986                                         ifa->ifa_addr;
2987                                 if (in4->sin_addr.s_addr == INADDR_ANY)
2988                                         continue;
2989                                 if ((in4->sin_addr.s_addr & IN_CLASSB_NET) !=
2990                                                 ((in_addr_t) 0xa9fe0000))
2991                                         continue;
2992                                 memcpy(address, &in4->sin_addr,
2993                                                         sizeof(struct in_addr));
2994                         } else if (family == AF_INET6) {
2995                                 struct sockaddr_in6 *in6 =
2996                                         (struct sockaddr_in6 *)ifa->ifa_addr;
2997                                 if (memcmp(&in6->sin6_addr, &in6addr_any,
2998                                                 sizeof(struct in6_addr)) == 0)
2999                                         continue;
3000                                 if (!IN6_IS_ADDR_LINKLOCAL(&in6->sin6_addr))
3001                                         continue;
3002
3003                                 memcpy(address, &in6->sin6_addr,
3004                                                 sizeof(struct in6_addr));
3005                         } else {
3006                                 err = -EINVAL;
3007                                 goto out;
3008                         }
3009
3010                         err = 0;
3011                         break;
3012                 }
3013         }
3014
3015 out:
3016         freeifaddrs(ifaddr);
3017         return err;
3018 }
3019
3020 int __connman_inet_get_address_netmask(int ifindex,
3021                                         struct sockaddr_in *address,
3022                                         struct sockaddr_in *netmask)
3023 {
3024         int sk, ret = -EINVAL;
3025         struct ifreq ifr;
3026
3027         DBG("index %d", ifindex);
3028
3029         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
3030         if (sk < 0)
3031                 return -EINVAL;
3032
3033         memset(&ifr, 0, sizeof(ifr));
3034         ifr.ifr_ifindex = ifindex;
3035
3036         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0)
3037                 goto out;
3038
3039         if (ioctl(sk, SIOCGIFNETMASK, &ifr) < 0)
3040                 goto out;
3041
3042         memcpy(netmask, (struct sockaddr_in *)&ifr.ifr_netmask,
3043                                                 sizeof(struct sockaddr_in));
3044
3045         if (ioctl(sk, SIOCGIFADDR, &ifr) < 0)
3046                 goto out;
3047
3048         memcpy(address, (struct sockaddr_in *)&ifr.ifr_addr,
3049                                                 sizeof(struct sockaddr_in));
3050         ret = 0;
3051
3052 out:
3053         close(sk);
3054         return ret;
3055 }