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         hdr = (struct nd_router_advert *)buf;
1344         DBG("code %d len %zd hdr %zd", hdr->nd_ra_code, len,
1345                                 sizeof(struct nd_router_advert));
1346         if (hdr->nd_ra_code != 0)
1347                 return 0;
1348
1349         cb(hdr, len, data->user_data);
1350         xs_cleanup(data);
1351
1352         return len;
1353 }
1354
1355 static gboolean icmpv6_event(GIOChannel *chan, GIOCondition cond, gpointer data)
1356 {
1357         int fd, ret;
1358
1359         DBG("");
1360
1361         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1362                 return FALSE;
1363
1364         fd = g_io_channel_unix_get_fd(chan);
1365         ret = icmpv6_recv(fd, data);
1366         if (ret == 0)
1367                 return TRUE;
1368
1369         return FALSE;
1370 }
1371
1372 /* Adapted from RFC 1071 "C" Implementation Example */
1373 static uint16_t csum(const void *phdr, const void *data, socklen_t datalen,
1374                 const void *extra_data, socklen_t extra_datalen)
1375 {
1376         register unsigned long sum = 0;
1377         socklen_t count;
1378         uint16_t *addr;
1379         int i;
1380
1381         /* caller must make sure datalen is even */
1382
1383         addr = (uint16_t *)phdr;
1384         for (i = 0; i < 20; i++)
1385                 sum += *addr++;
1386
1387         count = datalen;
1388         addr = (uint16_t *)data;
1389
1390         while (count > 1) {
1391                 sum += *(addr++);
1392                 count -= 2;
1393         }
1394
1395         if (extra_data) {
1396                 count = extra_datalen;
1397                 addr = (uint16_t *)extra_data;
1398
1399                 while (count > 1) {
1400                         sum += *(addr++);
1401                         count -= 2;
1402                 }
1403         }
1404
1405         while (sum >> 16)
1406                 sum = (sum & 0xffff) + (sum >> 16);
1407
1408         return (uint16_t)~sum;
1409 }
1410
1411 static int ndisc_send_unspec(int type, int oif, const struct in6_addr *dest,
1412                         const struct in6_addr *source,
1413                         unsigned char *buf, size_t len, uint16_t lifetime)
1414 {
1415         struct _phdr {
1416                 struct in6_addr src;
1417                 struct in6_addr dst;
1418                 uint32_t plen;
1419                 uint8_t reserved[3];
1420                 uint8_t nxt;
1421         } phdr;
1422
1423         struct {
1424                 struct ip6_hdr ip;
1425                 union {
1426                         struct icmp6_hdr icmp;
1427                         struct nd_neighbor_solicit ns;
1428                         struct nd_router_solicit rs;
1429                         struct nd_router_advert ra;
1430                 } i;
1431         } frame;
1432
1433         struct msghdr msgh;
1434         struct cmsghdr *cmsg;
1435         struct in6_pktinfo *pinfo;
1436         struct sockaddr_in6 dst, src;
1437         char cbuf[CMSG_SPACE(sizeof(*pinfo))];
1438         struct iovec iov[2];
1439         int fd, datalen, ret, iovlen = 1;
1440
1441         DBG("");
1442
1443         fd = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_RAW);
1444         if (fd < 0)
1445                 return -errno;
1446
1447         memset(&frame, 0, sizeof(frame));
1448         memset(&dst, 0, sizeof(dst));
1449
1450         if (type == ND_ROUTER_SOLICIT)
1451                 datalen = sizeof(frame.i.rs); /* 8, csum() safe */
1452         else if (type == ND_ROUTER_ADVERT) {
1453                 datalen = sizeof(frame.i.ra); /* 16, csum() safe */
1454                 frame.i.ra.nd_ra_router_lifetime = htons(lifetime);
1455         } else if (type == ND_NEIGHBOR_SOLICIT) {
1456                 datalen = sizeof(frame.i.ns); /* 24, csum() safe */
1457                 memcpy(&frame.i.ns.nd_ns_target, buf, sizeof(struct in6_addr));
1458         } else {
1459                 close(fd);
1460                 return -EINVAL;
1461         }
1462
1463         dst.sin6_addr = *dest;
1464
1465         if (source)
1466                 src.sin6_addr = *source;
1467         else
1468                 src.sin6_addr = in6addr_any;
1469
1470         /* Fill in the IPv6 header */
1471         frame.ip.ip6_vfc = 0x60;
1472         frame.ip.ip6_plen = htons(datalen + len);
1473         frame.ip.ip6_nxt = IPPROTO_ICMPV6;
1474         frame.ip.ip6_hlim = 255;
1475         frame.ip.ip6_dst = dst.sin6_addr;
1476         frame.ip.ip6_src = src.sin6_addr;
1477         /* all other fields are already set to zero */
1478
1479         /* Prepare pseudo header for csum */
1480         memset(&phdr, 0, sizeof(phdr));
1481         phdr.dst = dst.sin6_addr;
1482         phdr.src = src.sin6_addr;
1483         phdr.plen = htonl(datalen + len);
1484         phdr.nxt = IPPROTO_ICMPV6;
1485
1486         /* Fill in remaining ICMP header fields */
1487         frame.i.icmp.icmp6_type = type;
1488         frame.i.icmp.icmp6_cksum = csum(&phdr, &frame.i, datalen, buf, len);
1489
1490         iov[0].iov_base = &frame;
1491         iov[0].iov_len = sizeof(frame.ip) + datalen;
1492
1493         if (buf) {
1494                 iov[1].iov_base = buf;
1495                 iov[1].iov_len = len;
1496                 iovlen = 2;
1497         }
1498
1499         dst.sin6_family = AF_INET6;
1500         msgh.msg_name = &dst;
1501         msgh.msg_namelen = sizeof(dst);
1502         msgh.msg_iov = iov;
1503         msgh.msg_iovlen = iovlen;
1504         msgh.msg_flags = 0;
1505
1506         memset(cbuf, 0, CMSG_SPACE(sizeof(*pinfo)));
1507         cmsg = (struct cmsghdr *)cbuf;
1508         pinfo = (struct in6_pktinfo *)CMSG_DATA(cmsg);
1509         pinfo->ipi6_ifindex = oif;
1510
1511         cmsg->cmsg_len = CMSG_LEN(sizeof(*pinfo));
1512         cmsg->cmsg_level = IPPROTO_IPV6;
1513         cmsg->cmsg_type = IPV6_PKTINFO;
1514         msgh.msg_control = cmsg;
1515         msgh.msg_controllen = cmsg->cmsg_len;
1516
1517         ret = sendmsg(fd, &msgh, 0);
1518
1519         close(fd);
1520         return ret;
1521 }
1522
1523 static inline void ipv6_addr_set(struct in6_addr *addr,
1524                                 uint32_t w1, uint32_t w2,
1525                                 uint32_t w3, uint32_t w4)
1526 {
1527         addr->s6_addr32[0] = w1;
1528         addr->s6_addr32[1] = w2;
1529         addr->s6_addr32[2] = w3;
1530         addr->s6_addr32[3] = w4;
1531 }
1532
1533 static inline void ipv6_addr_solict_mult(const struct in6_addr *addr,
1534                                         struct in6_addr *solicited)
1535 {
1536         ipv6_addr_set(solicited, htonl(0xFF020000), 0, htonl(0x1),
1537                         htonl(0xFF000000) | addr->s6_addr32[3]);
1538 }
1539
1540 static int if_mc_group(int sock, int ifindex, const struct in6_addr *mc_addr,
1541                                                                 int cmd)
1542 {
1543         unsigned int val = 0;
1544         struct ipv6_mreq mreq;
1545         int ret;
1546
1547         memset(&mreq, 0, sizeof(mreq));
1548         mreq.ipv6mr_interface = ifindex;
1549         mreq.ipv6mr_multiaddr = *mc_addr;
1550
1551         ret = setsockopt(sock, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
1552                         &val, sizeof(int));
1553         if (ret < 0) {
1554                 ret = -errno;
1555                 DBG("Cannot set IPV6_MULTICAST_LOOP %d/%s", ret,
1556                         strerror(-ret));
1557                 return ret;
1558         }
1559
1560         ret = setsockopt(sock, IPPROTO_IPV6, cmd, &mreq, sizeof(mreq));
1561         if (ret < 0) {
1562                 ret = -errno;
1563                 DBG("Cannot set option %d %d/%s", cmd, ret, strerror(-ret));
1564                 return ret;
1565         }
1566
1567         return 0;
1568 }
1569
1570 int __connman_inet_ipv6_send_rs(int index, int timeout,
1571                         __connman_inet_rs_cb_t callback, void *user_data)
1572 {
1573         struct xs_cb_data *data;
1574         struct icmp6_filter filter;
1575         struct in6_addr solicit;
1576         struct in6_addr dst = in6addr_all_routers_mc;
1577         int sk;
1578
1579         if (timeout <= 0)
1580                 return -EINVAL;
1581
1582         data = g_try_malloc0(sizeof(struct xs_cb_data));
1583         if (!data)
1584                 return -ENOMEM;
1585
1586         data->callback = callback;
1587         data->user_data = user_data;
1588         data->timeout = g_timeout_add_seconds(timeout, rs_timeout_cb, data);
1589
1590         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1591         if (sk < 0)
1592                 return -errno;
1593
1594         DBG("sock %d", sk);
1595
1596         ICMP6_FILTER_SETBLOCKALL(&filter);
1597         ICMP6_FILTER_SETPASS(ND_ROUTER_ADVERT, &filter);
1598
1599         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1600                                                 sizeof(struct icmp6_filter));
1601
1602         ipv6_addr_solict_mult(&dst, &solicit);
1603         if_mc_group(sk, index, &in6addr_all_nodes_mc, IPV6_JOIN_GROUP);
1604         if_mc_group(sk, index, &solicit, IPV6_JOIN_GROUP);
1605
1606         data->channel = g_io_channel_unix_new(sk);
1607         g_io_channel_set_close_on_unref(data->channel, TRUE);
1608
1609         g_io_channel_set_encoding(data->channel, NULL, NULL);
1610         g_io_channel_set_buffered(data->channel, FALSE);
1611
1612         data->watch_id = g_io_add_watch(data->channel,
1613                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
1614                         icmpv6_event, data);
1615
1616         ndisc_send_unspec(ND_ROUTER_SOLICIT, index, &dst, NULL, NULL, 0, 0);
1617
1618         return 0;
1619 }
1620
1621 static inline void ipv6_addr_advert_mult(const struct in6_addr *addr,
1622                                         struct in6_addr *advert)
1623 {
1624         ipv6_addr_set(advert, htonl(0xFF020000), 0, htonl(0x2),
1625                         htonl(0xFF000000) | addr->s6_addr32[3]);
1626 }
1627
1628 #define MSG_SIZE_SEND 1452
1629
1630 static int inc_len(int len, int inc)
1631 {
1632         if (len > MSG_SIZE_SEND)
1633                 return -EINVAL;
1634
1635         len += inc;
1636         return len;
1637 }
1638
1639 int __connman_inet_ipv6_send_ra(int index, struct in6_addr *src_addr,
1640                                 GSList *prefixes, int router_lifetime)
1641 {
1642         GSList *list;
1643         struct in6_addr src, *source;
1644         struct in6_addr dst = in6addr_all_nodes_mc;
1645         GDHCPIAPrefix *prefix;
1646         unsigned char buf[MSG_SIZE_SEND];
1647         char addr_str[INET6_ADDRSTRLEN];
1648         int sk, err = 0;
1649         int len, count = 0;
1650
1651         if (!prefixes)
1652                 return -EINVAL;
1653
1654         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1655         if (sk < 0)
1656                 return -errno;
1657
1658         if (!src_addr) {
1659                 __connman_inet_get_interface_ll_address(index, AF_INET6, &src);
1660                 source = &src;
1661         } else
1662                 source = src_addr;
1663
1664         DBG("sock %d index %d prefixes %p src %s lifetime %d", sk, index,
1665                 prefixes, inet_ntop(AF_INET6, source, addr_str,
1666                                 INET6_ADDRSTRLEN),
1667                 router_lifetime);
1668
1669         memset(buf, 0, MSG_SIZE_SEND);
1670         len = 0;
1671
1672         for (list = prefixes; list; list = list->next) {
1673                 struct nd_opt_prefix_info *pinfo;
1674
1675                 prefix = list->data;
1676                 pinfo = (struct nd_opt_prefix_info *)(buf + len);
1677
1678                 len = inc_len(len, sizeof(*pinfo));
1679                 if (len < 0) {
1680                         err = len;
1681                         goto out;
1682                 }
1683
1684                 pinfo->nd_opt_pi_type = ND_OPT_PREFIX_INFORMATION;
1685                 pinfo->nd_opt_pi_len = 4;
1686                 pinfo->nd_opt_pi_prefix_len = prefix->prefixlen;
1687                 pinfo->nd_opt_pi_flags_reserved = ND_OPT_PI_FLAG_ONLINK;
1688                 pinfo->nd_opt_pi_flags_reserved |= ND_OPT_PI_FLAG_AUTO;
1689                 if (router_lifetime > 0) {
1690                         pinfo->nd_opt_pi_valid_time = htonl(prefix->valid);
1691                         pinfo->nd_opt_pi_preferred_time =
1692                                                 htonl(prefix->preferred);
1693                 }
1694                 pinfo->nd_opt_pi_reserved2 = 0;
1695
1696                 memcpy(&pinfo->nd_opt_pi_prefix, &prefix->prefix,
1697                                                 sizeof(struct in6_addr));
1698
1699                 DBG("[%d] index %d prefix %s/%d", count, index,
1700                         inet_ntop(AF_INET6, &prefix->prefix, addr_str,
1701                                 INET6_ADDRSTRLEN), prefix->prefixlen);
1702
1703                 count++;
1704         }
1705
1706         if (count > 0) {
1707                 err = ndisc_send_unspec(ND_ROUTER_ADVERT, index, &dst, source,
1708                                         buf, len, router_lifetime);
1709                 if (err < 0)
1710                         DBG("cannot send RA %d/%s", err, strerror(-err));
1711         }
1712
1713 out:
1714         close(sk);
1715         return err;
1716 }
1717
1718 void __connman_inet_ipv6_stop_recv_rs(void *context)
1719 {
1720         if (!context)
1721                 return;
1722
1723         xs_cleanup(context);
1724 }
1725
1726 static int icmpv6_rs_recv(int fd, gpointer user_data)
1727 {
1728         struct msghdr mhdr;
1729         struct iovec iov;
1730         unsigned char chdr[CMSG_BUF_LEN];
1731         unsigned char buf[1540];
1732         struct xs_cb_data *data = user_data;
1733         struct nd_router_solicit *hdr;
1734         struct sockaddr_in6 saddr;
1735         ssize_t len;
1736         __connman_inet_recv_rs_cb_t cb = data->callback;
1737
1738         DBG("");
1739
1740         iov.iov_len = sizeof(buf);
1741         iov.iov_base = buf;
1742
1743         mhdr.msg_name = (void *)&saddr;
1744         mhdr.msg_namelen = sizeof(struct sockaddr_in6);
1745         mhdr.msg_flags = 0;
1746         mhdr.msg_iov = &iov;
1747         mhdr.msg_iovlen = 1;
1748         mhdr.msg_control = (void *)chdr;
1749         mhdr.msg_controllen = CMSG_BUF_LEN;
1750
1751         len = recvmsg(fd, &mhdr, 0);
1752         if (len < 0) {
1753                 cb(NULL, 0, data->user_data);
1754                 return -errno;
1755         }
1756
1757         hdr = (struct nd_router_solicit *)buf;
1758         DBG("code %d len %zd hdr %zd", hdr->nd_rs_code, len,
1759                                 sizeof(struct nd_router_solicit));
1760         if (hdr->nd_rs_code != 0)
1761                 return 0;
1762
1763         cb(hdr, len, data->user_data);
1764         return len;
1765 }
1766
1767 static gboolean icmpv6_rs_event(GIOChannel *chan, GIOCondition cond,
1768                                                                 gpointer data)
1769 {
1770         int fd, ret;
1771
1772         DBG("");
1773
1774         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1775                 return FALSE;
1776
1777         fd = g_io_channel_unix_get_fd(chan);
1778         ret = icmpv6_rs_recv(fd, data);
1779         if (ret == 0)
1780                 return TRUE;
1781
1782         return FALSE;
1783 }
1784
1785 int __connman_inet_ipv6_start_recv_rs(int index,
1786                                         __connman_inet_recv_rs_cb_t callback,
1787                                         void *user_data,
1788                                         void **context)
1789 {
1790         struct xs_cb_data *data;
1791         struct icmp6_filter filter;
1792         char addr_str[INET6_ADDRSTRLEN];
1793         int sk, err;
1794
1795         data = g_try_malloc0(sizeof(struct xs_cb_data));
1796         if (!data)
1797                 return -ENOMEM;
1798
1799         data->callback = callback;
1800         data->user_data = user_data;
1801
1802         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1803         if (sk < 0) {
1804                 g_free(data);
1805                 return -errno;
1806         }
1807
1808         DBG("sock %d", sk);
1809
1810         ICMP6_FILTER_SETBLOCKALL(&filter);
1811         ICMP6_FILTER_SETPASS(ND_ROUTER_SOLICIT, &filter);
1812
1813         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1814                                                 sizeof(struct icmp6_filter));
1815
1816         err = if_mc_group(sk, index, &in6addr_all_routers_mc, IPV6_JOIN_GROUP);
1817         if (err < 0)
1818                 DBG("Cannot join mc %s %d/%s", inet_ntop(AF_INET6,
1819                         &in6addr_all_routers_mc, addr_str, INET6_ADDRSTRLEN),
1820                         err, strerror(-err));
1821
1822         data->channel = g_io_channel_unix_new(sk);
1823         g_io_channel_set_close_on_unref(data->channel, TRUE);
1824
1825         g_io_channel_set_encoding(data->channel, NULL, NULL);
1826         g_io_channel_set_buffered(data->channel, FALSE);
1827
1828         data->watch_id = g_io_add_watch(data->channel,
1829                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
1830                         icmpv6_rs_event, data);
1831
1832         *context = data;
1833
1834         return 0;
1835 }
1836
1837 static gboolean ns_timeout_cb(gpointer user_data)
1838 {
1839         struct xs_cb_data *data = user_data;
1840
1841         DBG("user data %p", user_data);
1842
1843         if (!data)
1844                 return FALSE;
1845
1846         if (data->callback) {
1847                 __connman_inet_ns_cb_t cb = data->callback;
1848                 cb(NULL, 0, &data->addr.sin6_addr, data->user_data);
1849         }
1850
1851         data->timeout = 0;
1852         xs_cleanup(data);
1853         return FALSE;
1854 }
1855
1856 static int icmpv6_nd_recv(int fd, gpointer user_data)
1857 {
1858         struct msghdr mhdr;
1859         struct iovec iov;
1860         unsigned char chdr[CMSG_BUF_LEN];
1861         unsigned char buf[1540];
1862         struct xs_cb_data *data = user_data;
1863         struct nd_neighbor_advert *hdr;
1864         struct sockaddr_in6 saddr;
1865         ssize_t len;
1866         __connman_inet_ns_cb_t cb = data->callback;
1867
1868         DBG("");
1869
1870         iov.iov_len = sizeof(buf);
1871         iov.iov_base = buf;
1872
1873         mhdr.msg_name = (void *)&saddr;
1874         mhdr.msg_namelen = sizeof(struct sockaddr_in6);
1875         mhdr.msg_flags = 0;
1876         mhdr.msg_iov = &iov;
1877         mhdr.msg_iovlen = 1;
1878         mhdr.msg_control = (void *)chdr;
1879         mhdr.msg_controllen = CMSG_BUF_LEN;
1880
1881         len = recvmsg(fd, &mhdr, 0);
1882         if (len < 0) {
1883                 cb(NULL, 0, &data->addr.sin6_addr, data->user_data);
1884                 xs_cleanup(data);
1885                 return -errno;
1886         }
1887
1888         hdr = (struct nd_neighbor_advert *)buf;
1889         DBG("code %d len %zd hdr %zd", hdr->nd_na_code, len,
1890                                 sizeof(struct nd_neighbor_advert));
1891         if (hdr->nd_na_code != 0)
1892                 return 0;
1893
1894         /*
1895          * We can receive any neighbor advertisement so we need to check if the
1896          * packet was meant for us and ignore the packet otherwise.
1897          */
1898         if (memcmp(&data->addr.sin6_addr, &hdr->nd_na_target,
1899                         sizeof(struct in6_addr)))
1900                 return 0;
1901
1902         cb(hdr, len, &data->addr.sin6_addr, data->user_data);
1903         xs_cleanup(data);
1904
1905         return len;
1906 }
1907
1908 static gboolean icmpv6_nd_event(GIOChannel *chan, GIOCondition cond,
1909                                                                 gpointer data)
1910 {
1911         int fd, ret;
1912
1913         DBG("");
1914
1915         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
1916                 return FALSE;
1917
1918         fd = g_io_channel_unix_get_fd(chan);
1919         ret = icmpv6_nd_recv(fd, data);
1920         if (ret == 0)
1921                 return TRUE;
1922
1923         return FALSE;
1924 }
1925
1926 int __connman_inet_ipv6_do_dad(int index, int timeout_ms,
1927                                 struct in6_addr *addr,
1928                                 __connman_inet_ns_cb_t callback,
1929                                 void *user_data)
1930 {
1931         struct xs_cb_data *data;
1932         struct icmp6_filter filter;
1933         struct in6_addr solicit;
1934         int sk, err, val = 1;
1935
1936         if (timeout_ms <= 0)
1937                 return -EINVAL;
1938
1939         data = g_try_malloc0(sizeof(struct xs_cb_data));
1940         if (!data)
1941                 return -ENOMEM;
1942
1943         data->callback = callback;
1944         data->user_data = user_data;
1945         data->timeout = g_timeout_add_full(G_PRIORITY_DEFAULT,
1946                                         (guint)timeout_ms,
1947                                         ns_timeout_cb,
1948                                         data,
1949                                         NULL);
1950         memcpy(&data->addr.sin6_addr, addr, sizeof(struct in6_addr));
1951
1952         sk = socket(AF_INET6, SOCK_RAW | SOCK_CLOEXEC, IPPROTO_ICMPV6);
1953         if (sk < 0)
1954                 return -errno;
1955
1956         DBG("sock %d", sk);
1957
1958         ICMP6_FILTER_SETBLOCKALL(&filter);
1959         ICMP6_FILTER_SETPASS(ND_NEIGHBOR_ADVERT, &filter);
1960
1961         setsockopt(sk, IPPROTO_ICMPV6, ICMP6_FILTER, &filter,
1962                                                 sizeof(struct icmp6_filter));
1963
1964         if (setsockopt(sk, IPPROTO_IPV6, IPV6_RECVPKTINFO,
1965                                                 &val, sizeof(val)) < 0) {
1966                 err = -errno;
1967                 DBG("Cannot set IPV6_RECVPKTINFO %d/%s", err,
1968                                                         strerror(-err));
1969                 close(sk);
1970                 return err;
1971         }
1972
1973         if (setsockopt(sk, IPPROTO_IPV6, IPV6_RECVHOPLIMIT,
1974                                                 &val, sizeof(val)) < 0) {
1975                 err = -errno;
1976                 DBG("Cannot set IPV6_RECVHOPLIMIT %d/%s", err,
1977                                                         strerror(-err));
1978                 close(sk);
1979                 return err;
1980         }
1981
1982         val = 0;
1983         setsockopt(sk, IPPROTO_IPV6, IPV6_MULTICAST_LOOP, &val, sizeof(val));
1984
1985         ipv6_addr_solict_mult(addr, &solicit);
1986         if_mc_group(sk, index, &in6addr_all_nodes_mc, IPV6_JOIN_GROUP);
1987         if_mc_group(sk, index, &solicit, IPV6_JOIN_GROUP);
1988
1989         data->channel = g_io_channel_unix_new(sk);
1990         g_io_channel_set_close_on_unref(data->channel, TRUE);
1991
1992         g_io_channel_set_encoding(data->channel, NULL, NULL);
1993         g_io_channel_set_buffered(data->channel, FALSE);
1994
1995         data->watch_id = g_io_add_watch(data->channel,
1996                         G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
1997                         icmpv6_nd_event, data);
1998
1999         err = ndisc_send_unspec(ND_NEIGHBOR_SOLICIT, index, &solicit, NULL,
2000                         (unsigned char *)addr, 0, 0);
2001         if (err < 0) {
2002                 DBG("Cannot send NS %d/%s", err, strerror(-err));
2003                 xs_cleanup(data);
2004         }
2005
2006         return err;
2007 }
2008
2009 GSList *__connman_inet_ipv6_get_prefixes(struct nd_router_advert *hdr,
2010                                         unsigned int length)
2011 {
2012         GSList *prefixes = NULL;
2013         uint8_t *pos;
2014         int len;
2015
2016         if (length <= sizeof(struct nd_router_advert))
2017                 return NULL;
2018
2019         len = length - sizeof(struct nd_router_advert);
2020         pos = (uint8_t *)hdr + sizeof(struct nd_router_advert);
2021
2022         while (len > 0) {
2023                 struct nd_opt_prefix_info *pinfo;
2024                 char prefix_str[INET6_ADDRSTRLEN+1], *str;
2025                 const char *prefix;
2026                 int optlen;
2027
2028                 if (len < 2)
2029                         break;
2030
2031                 optlen = pos[1] << 3;
2032                 if (optlen == 0 || optlen > len)
2033                         break;
2034
2035                 switch (pos[0]) {
2036                 case ND_OPT_PREFIX_INFORMATION:
2037                         pinfo = (struct nd_opt_prefix_info *)pos;
2038                         prefix = inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
2039                                         prefix_str, INET6_ADDRSTRLEN);
2040                         if (!prefix)
2041                                 break;
2042
2043                         str = g_strdup_printf("%s/%d", prefix,
2044                                                 pinfo->nd_opt_pi_prefix_len);
2045                         prefixes = g_slist_prepend(prefixes, str);
2046
2047                         DBG("prefix %s", str);
2048
2049                         break;
2050                 }
2051
2052                 len -= optlen;
2053                 pos += optlen;
2054         }
2055
2056         return prefixes;
2057 }
2058
2059 static int get_dest_addr(int family, int index, char *buf, int len)
2060 {
2061         struct ifreq ifr;
2062         void *addr;
2063         int sk;
2064
2065         sk = socket(family, SOCK_DGRAM | SOCK_CLOEXEC, 0);
2066         if (sk < 0)
2067                 return -errno;
2068
2069         memset(&ifr, 0, sizeof(ifr));
2070         ifr.ifr_ifindex = index;
2071
2072         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0) {
2073                 DBG("SIOCGIFNAME (%d/%s)", errno, strerror(errno));
2074                 close(sk);
2075                 return -errno;
2076         }
2077
2078         if (ioctl(sk, SIOCGIFFLAGS, &ifr) < 0) {
2079                 DBG("SIOCGIFFLAGS (%d/%s)", errno, strerror(errno));
2080                 close(sk);
2081                 return -errno;
2082         }
2083
2084         if ((ifr.ifr_flags & IFF_POINTOPOINT) == 0) {
2085                 close(sk);
2086                 errno = EINVAL;
2087                 return -errno;
2088         }
2089
2090         DBG("index %d %s", index, ifr.ifr_name);
2091
2092         if (ioctl(sk, SIOCGIFDSTADDR, &ifr) < 0) {
2093                 connman_error("Get destination address failed (%s)",
2094                                                         strerror(errno));
2095                 close(sk);
2096                 return -errno;
2097         }
2098
2099         close(sk);
2100
2101         switch (family) {
2102         case AF_INET:
2103                 addr = &((struct sockaddr_in *)&ifr.ifr_dstaddr)->sin_addr;
2104                 break;
2105         case AF_INET6:
2106                 addr = &((struct sockaddr_in6 *)&ifr.ifr_dstaddr)->sin6_addr;
2107                 break;
2108         default:
2109                 errno = EINVAL;
2110                 return -errno;
2111         }
2112
2113         if (!inet_ntop(family, addr, buf, len)) {
2114                 DBG("error %d/%s", errno, strerror(errno));
2115                 return -errno;
2116         }
2117
2118         return 0;
2119 }
2120
2121 int connman_inet_get_dest_addr(int index, char **dest)
2122 {
2123         char addr[INET_ADDRSTRLEN];
2124         int ret;
2125
2126         ret = get_dest_addr(PF_INET, index, addr, INET_ADDRSTRLEN);
2127         if (ret < 0)
2128                 return ret;
2129
2130         *dest = g_strdup(addr);
2131
2132         DBG("destination %s", *dest);
2133
2134         return 0;
2135 }
2136
2137 int connman_inet_ipv6_get_dest_addr(int index, char **dest)
2138 {
2139         char addr[INET6_ADDRSTRLEN];
2140         int ret;
2141
2142         ret = get_dest_addr(PF_INET6, index, addr, INET6_ADDRSTRLEN);
2143         if (ret < 0)
2144                 return ret;
2145
2146         *dest = g_strdup(addr);
2147
2148         DBG("destination %s", *dest);
2149
2150         return 0;
2151 }
2152
2153 int __connman_inet_rtnl_open(struct __connman_inet_rtnl_handle *rth)
2154 {
2155         int sndbuf = 1024;
2156         int rcvbuf = 1024 * 4;
2157
2158         rth->fd = socket(AF_NETLINK, SOCK_RAW | SOCK_CLOEXEC, NETLINK_ROUTE);
2159         if (rth->fd < 0) {
2160                 connman_error("Can not open netlink socket: %s",
2161                                                 strerror(errno));
2162                 return -errno;
2163         }
2164
2165         if (setsockopt(rth->fd, SOL_SOCKET, SO_SNDBUF, &sndbuf,
2166                         sizeof(sndbuf)) < 0) {
2167                 connman_error("SO_SNDBUF: %s", strerror(errno));
2168                 return -errno;
2169         }
2170
2171         if (setsockopt(rth->fd, SOL_SOCKET, SO_RCVBUF, &rcvbuf,
2172                         sizeof(rcvbuf)) < 0) {
2173                 connman_error("SO_RCVBUF: %s", strerror(errno));
2174                 return -errno;
2175         }
2176
2177         memset(&rth->local, 0, sizeof(rth->local));
2178         rth->local.nl_family = AF_NETLINK;
2179         rth->local.nl_groups = 0;
2180
2181         if (bind(rth->fd, (struct sockaddr *)&rth->local,
2182                                                 sizeof(rth->local)) < 0) {
2183                 connman_error("Can not bind netlink socket: %s",
2184                                                         strerror(errno));
2185                 return -errno;
2186         }
2187
2188         rth->seq = time(NULL);
2189
2190         DBG("fd %d", rth->fd);
2191
2192         return 0;
2193 }
2194
2195 struct inet_rtnl_cb_data {
2196         GIOChannel *channel;
2197         __connman_inet_rtnl_cb_t callback;
2198         guint rtnl_timeout;
2199         guint watch_id;
2200         struct __connman_inet_rtnl_handle *rtnl;
2201         void *user_data;
2202 };
2203
2204 static void inet_rtnl_cleanup(struct inet_rtnl_cb_data *data)
2205 {
2206         struct __connman_inet_rtnl_handle *rth = data->rtnl;
2207
2208         if (data->channel) {
2209                 g_io_channel_shutdown(data->channel, TRUE, NULL);
2210                 g_io_channel_unref(data->channel);
2211                 data->channel = NULL;
2212         }
2213
2214         DBG("data %p", data);
2215
2216         if (data->rtnl_timeout > 0)
2217                 g_source_remove(data->rtnl_timeout);
2218
2219         if (data->watch_id > 0)
2220                 g_source_remove(data->watch_id);
2221
2222         if (rth) {
2223                 __connman_inet_rtnl_close(rth);
2224                 g_free(rth);
2225         }
2226
2227         g_free(data);
2228 }
2229
2230 static gboolean inet_rtnl_timeout_cb(gpointer user_data)
2231 {
2232         struct inet_rtnl_cb_data *data = user_data;
2233
2234         DBG("user data %p", user_data);
2235
2236         if (!data)
2237                 return FALSE;
2238
2239         if (data->callback)
2240                 data->callback(NULL, data->user_data);
2241
2242         data->rtnl_timeout = 0;
2243         inet_rtnl_cleanup(data);
2244         return FALSE;
2245 }
2246
2247 static int inet_rtnl_recv(GIOChannel *chan, gpointer user_data)
2248 {
2249         struct inet_rtnl_cb_data *rtnl_data = user_data;
2250         struct __connman_inet_rtnl_handle *rth = rtnl_data->rtnl;
2251         struct nlmsghdr *h = NULL;
2252         struct sockaddr_nl nladdr;
2253         socklen_t addr_len = sizeof(nladdr);
2254         unsigned char buf[4096];
2255         void *ptr = buf;
2256         gsize len;
2257         int status, fd;
2258
2259         memset(buf, 0, sizeof(buf));
2260         memset(&nladdr, 0, sizeof(nladdr));
2261
2262         fd = g_io_channel_unix_get_fd(chan);
2263
2264         status = recvfrom(fd, buf, sizeof(buf), 0,
2265                        (struct sockaddr *) &nladdr, &addr_len);
2266         if (status < 0) {
2267                 if (errno == EINTR || errno == EAGAIN)
2268                         return 0;
2269
2270                 return -1;
2271         }
2272
2273         if (status == 0)
2274                 return -1;
2275
2276         if (nladdr.nl_pid != 0) { /* not sent by kernel, ignore */
2277                 DBG("Received msg from %u, ignoring it", nladdr.nl_pid);
2278                 return 0;
2279         }
2280
2281         len = status;
2282
2283         while (len > 0) {
2284                 struct nlmsgerr *err;
2285
2286                 h = ptr;
2287
2288                 if (!NLMSG_OK(h, len))
2289                         return -1;
2290
2291                 if (h->nlmsg_seq != rth->seq) {
2292                         /* Skip this msg */
2293                         DBG("skip %d/%d len %d", rth->seq,
2294                                 h->nlmsg_seq, h->nlmsg_len);
2295
2296                         len -= h->nlmsg_len;
2297                         ptr += h->nlmsg_len;
2298                         continue;
2299                 }
2300
2301                 switch (h->nlmsg_type) {
2302                 case NLMSG_NOOP:
2303                 case NLMSG_OVERRUN:
2304                         return -1;
2305
2306                 case NLMSG_ERROR:
2307                         err = (struct nlmsgerr *)NLMSG_DATA(h);
2308                         connman_error("RTNETLINK answers %s (%d)",
2309                                 strerror(-err->error), -err->error);
2310                         return err->error;
2311                 }
2312
2313                 break;
2314         }
2315
2316         if (h->nlmsg_seq == rth->seq) {
2317                 DBG("received %d seq %d", h->nlmsg_len, h->nlmsg_seq);
2318
2319                 rtnl_data->callback(h, rtnl_data->user_data);
2320
2321                 inet_rtnl_cleanup(rtnl_data);
2322         }
2323
2324         return 0;
2325 }
2326
2327 static gboolean inet_rtnl_event(GIOChannel *chan, GIOCondition cond,
2328                                                         gpointer user_data)
2329 {
2330         int ret;
2331
2332         DBG("");
2333
2334         if (cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR))
2335                 return FALSE;
2336
2337         ret = inet_rtnl_recv(chan, user_data);
2338         if (ret != 0)
2339                 return TRUE;
2340
2341         return FALSE;
2342 }
2343
2344 int __connman_inet_rtnl_talk(struct __connman_inet_rtnl_handle *rtnl,
2345                         struct nlmsghdr *n, int timeout,
2346                         __connman_inet_rtnl_cb_t callback, void *user_data)
2347 {
2348         struct sockaddr_nl nladdr;
2349         struct inet_rtnl_cb_data *data;
2350         unsigned seq;
2351         int err;
2352
2353         memset(&nladdr, 0, sizeof(nladdr));
2354         nladdr.nl_family = AF_NETLINK;
2355
2356         n->nlmsg_seq = seq = ++rtnl->seq;
2357
2358         if (callback) {
2359                 data = g_try_malloc0(sizeof(struct inet_rtnl_cb_data));
2360                 if (!data)
2361                         return -ENOMEM;
2362
2363                 data->callback = callback;
2364                 data->user_data = user_data;
2365                 data->rtnl = rtnl;
2366                 data->rtnl_timeout = g_timeout_add_seconds(timeout,
2367                                                 inet_rtnl_timeout_cb, data);
2368
2369                 data->channel = g_io_channel_unix_new(rtnl->fd);
2370                 g_io_channel_set_close_on_unref(data->channel, TRUE);
2371
2372                 g_io_channel_set_encoding(data->channel, NULL, NULL);
2373                 g_io_channel_set_buffered(data->channel, FALSE);
2374
2375                 data->watch_id = g_io_add_watch(data->channel,
2376                                 G_IO_IN | G_IO_NVAL | G_IO_HUP | G_IO_ERR,
2377                                                 inet_rtnl_event, data);
2378         } else
2379                 n->nlmsg_flags |= NLM_F_ACK;
2380
2381         err = sendto(rtnl->fd, &rtnl->req.n, rtnl->req.n.nlmsg_len, 0,
2382                 (struct sockaddr *) &nladdr, sizeof(nladdr));
2383         DBG("handle %p len %d", rtnl, rtnl->req.n.nlmsg_len);
2384         if (err < 0) {
2385                 connman_error("Can not talk to rtnetlink err %d %s",
2386                         -errno, strerror(errno));
2387                 return -errno;
2388         }
2389
2390         if ((unsigned int)err != rtnl->req.n.nlmsg_len) {
2391                 connman_error("Sent %d bytes, msg truncated", err);
2392                 return -EINVAL;
2393         }
2394
2395         return 0;
2396 }
2397
2398 void __connman_inet_rtnl_close(struct __connman_inet_rtnl_handle *rth)
2399 {
2400         DBG("handle %p", rth);
2401
2402         if (rth->fd >= 0) {
2403                 close(rth->fd);
2404                 rth->fd = -1;
2405         }
2406 }
2407
2408 int __connman_inet_rtnl_addattr32(struct nlmsghdr *n, size_t maxlen, int type,
2409                                 __u32 data)
2410 {
2411         int len = RTA_LENGTH(4);
2412         struct rtattr *rta;
2413
2414         if (NLMSG_ALIGN(n->nlmsg_len) + len > maxlen) {
2415                 DBG("Error! max allowed bound %zd exceeded", maxlen);
2416                 return -1;
2417         }
2418         rta = NLMSG_TAIL(n);
2419         rta->rta_type = type;
2420         rta->rta_len = len;
2421         memcpy(RTA_DATA(rta), &data, 4);
2422         n->nlmsg_len = NLMSG_ALIGN(n->nlmsg_len) + len;
2423
2424         return 0;
2425 }
2426
2427 static int parse_rtattr(struct rtattr *tb[], int max,
2428                         struct rtattr *rta, int len)
2429 {
2430         memset(tb, 0, sizeof(struct rtattr *) * (max + 1));
2431         while (RTA_OK(rta, len)) {
2432                 if ((rta->rta_type <= max) && (!tb[rta->rta_type]))
2433                         tb[rta->rta_type] = rta;
2434                 rta = RTA_NEXT(rta, len);
2435         }
2436         if (len)
2437                 connman_error("Deficit %d, rta_len=%d", len, rta->rta_len);
2438
2439         return 0;
2440 }
2441
2442 struct get_route_cb_data {
2443         connman_inet_addr_cb_t callback;
2444         void *user_data;
2445 };
2446
2447 static void get_route_cb(struct nlmsghdr *answer, void *user_data)
2448 {
2449         struct get_route_cb_data *data = user_data;
2450         struct rtattr *tb[RTA_MAX+1];
2451         struct rtmsg *r = NLMSG_DATA(answer);
2452         int len, index = -1;
2453         char abuf[256];
2454         const char *addr = NULL;
2455
2456         DBG("answer %p data %p", answer, user_data);
2457
2458         if (!answer)
2459                 goto out;
2460
2461         len = answer->nlmsg_len;
2462
2463         if (answer->nlmsg_type != RTM_NEWROUTE &&
2464                                 answer->nlmsg_type != RTM_DELROUTE) {
2465                 connman_error("Not a route: %08x %08x %08x",
2466                         answer->nlmsg_len, answer->nlmsg_type,
2467                         answer->nlmsg_flags);
2468                 goto out;
2469         }
2470
2471         len -= NLMSG_LENGTH(sizeof(*r));
2472         if (len < 0) {
2473                 connman_error("BUG: wrong nlmsg len %d", len);
2474                 goto out;
2475         }
2476
2477         parse_rtattr(tb, RTA_MAX, RTM_RTA(r), len);
2478
2479         if (tb[RTA_OIF])
2480                 index = *(int *)RTA_DATA(tb[RTA_OIF]);
2481
2482         if (tb[RTA_GATEWAY])
2483                 addr = inet_ntop(r->rtm_family,
2484                                 RTA_DATA(tb[RTA_GATEWAY]),
2485                                 abuf, sizeof(abuf));
2486
2487         DBG("addr %s index %d user %p", addr, index, data->user_data);
2488
2489 out:
2490         if (data && data->callback)
2491                 data->callback(addr, index, data->user_data);
2492
2493         g_free(data);
2494
2495         return;
2496 }
2497
2498 /*
2499  * Return the interface index that contains route to host.
2500  */
2501 int __connman_inet_get_route(const char *dest_address,
2502                         connman_inet_addr_cb_t callback, void *user_data)
2503 {
2504         struct get_route_cb_data *data;
2505         struct addrinfo hints, *rp;
2506         struct __connman_inet_rtnl_handle *rth;
2507         int err;
2508
2509         DBG("dest %s", dest_address);
2510
2511         if (!dest_address)
2512                 return -EINVAL;
2513
2514         memset(&hints, 0, sizeof(hints));
2515         hints.ai_family = AF_UNSPEC;
2516         hints.ai_flags = AI_PASSIVE | AI_NUMERICSERV | AI_NUMERICHOST;
2517
2518         err = getaddrinfo(dest_address, NULL, &hints, &rp);
2519         if (err)
2520                 return -EINVAL;
2521
2522         rth = g_try_malloc0(sizeof(struct __connman_inet_rtnl_handle));
2523         if (!rth) {
2524                 freeaddrinfo(rp);
2525                 return -ENOMEM;
2526         }
2527
2528         rth->req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2529         rth->req.n.nlmsg_flags = NLM_F_REQUEST;
2530         rth->req.n.nlmsg_type = RTM_GETROUTE;
2531         rth->req.u.r.rt.rtm_family = rp->ai_family;
2532         rth->req.u.r.rt.rtm_table = 0;
2533         rth->req.u.r.rt.rtm_protocol = 0;
2534         rth->req.u.r.rt.rtm_scope = 0;
2535         rth->req.u.r.rt.rtm_type = 0;
2536         rth->req.u.r.rt.rtm_src_len = 0;
2537         rth->req.u.r.rt.rtm_dst_len = rp->ai_addrlen << 3;
2538         rth->req.u.r.rt.rtm_tos = 0;
2539
2540         __connman_inet_rtnl_addattr_l(&rth->req.n, sizeof(rth->req), RTA_DST,
2541                                 &rp->ai_addr, rp->ai_addrlen);
2542
2543         freeaddrinfo(rp);
2544
2545         err = __connman_inet_rtnl_open(rth);
2546         if (err < 0)
2547                 goto fail;
2548
2549         data = g_try_malloc(sizeof(struct get_route_cb_data));
2550         if (!data) {
2551                 err = -ENOMEM;
2552                 goto done;
2553         }
2554
2555         data->callback = callback;
2556         data->user_data = user_data;
2557
2558 #define GET_ROUTE_TIMEOUT 2
2559         err = __connman_inet_rtnl_talk(rth, &rth->req.n, GET_ROUTE_TIMEOUT,
2560                                 get_route_cb, data);
2561         if (err < 0) {
2562                 g_free(data);
2563                 goto done;
2564         }
2565
2566         return 0;
2567
2568 done:
2569         __connman_inet_rtnl_close(rth);
2570
2571 fail:
2572         g_free(rth);
2573         return err;
2574 }
2575
2576 int connman_inet_check_ipaddress(const char *host)
2577 {
2578         struct addrinfo hints;
2579         struct addrinfo *addr;
2580         int result;
2581
2582         memset(&hints, 0, sizeof(struct addrinfo));
2583         hints.ai_flags = AI_NUMERICHOST;
2584         addr = NULL;
2585
2586         result = getaddrinfo(host, NULL, &hints, &addr);
2587         if (result == 0)
2588                 result = addr->ai_family;
2589         freeaddrinfo(addr);
2590
2591         return result;
2592 }
2593
2594 /* Check routine modified from ics-dhcp 4.2.3-P2 */
2595 bool connman_inet_check_hostname(const char *ptr, size_t len)
2596 {
2597         const char *p;
2598
2599         /*
2600          * Not empty or complete length not over 255 characters.
2601          */
2602         if ((len == 0) || (len > 256))
2603                 return false;
2604
2605         /*
2606          * Consists of [[:alnum:]-]+ labels separated by [.]
2607          * a [_] is against RFC but seems to be "widely used"
2608          */
2609         for (p = ptr; (*p != 0) && (len-- > 0); p++) {
2610
2611                 if ((*p == '-') || (*p == '_')) {
2612                         /*
2613                          * Not allowed at begin or end of a label.
2614                          */
2615                         if (((p - ptr) == 0) || (len == 0) || (p[1] == '.'))
2616                                 return false;
2617
2618                 } else if (*p == '.') {
2619                         /*
2620                          * Each label has to be 1-63 characters;
2621                          * we allow [.] at the end ('foo.bar.')
2622                          */
2623                         size_t d = p - ptr;
2624
2625                         if ((d <= 0) || (d >= 64))
2626                                 return false;
2627
2628                         ptr = p + 1; /* Jump to the next label */
2629
2630                 } else if (isalnum((unsigned char)*p) == 0) {
2631                         /*
2632                          * Also numbers at the begin are fine
2633                          */
2634                         return false;
2635                 }
2636         }
2637
2638         return true;
2639 }
2640
2641 char **__connman_inet_get_running_interfaces(void)
2642 {
2643         char **result;
2644         struct ifconf ifc;
2645         struct ifreq *ifr = NULL;
2646         int sk, i, numif, count = 0;
2647
2648         memset(&ifc, 0, sizeof(ifc));
2649
2650         sk = socket(AF_INET, SOCK_DGRAM, 0);
2651         if (sk < 0)
2652                 return NULL;
2653
2654         if (ioctl(sk, SIOCGIFCONF, &ifc) < 0)
2655                 goto error;
2656
2657         /*
2658          * Allocate some extra bytes just in case there will
2659          * be new interfaces added between two SIOCGIFCONF
2660          * calls.
2661          */
2662         ifr = g_try_malloc0(ifc.ifc_len * 2);
2663         if (!ifr)
2664                 goto error;
2665
2666         ifc.ifc_req = ifr;
2667
2668         if (ioctl(sk, SIOCGIFCONF, &ifc) < 0)
2669                 goto error;
2670
2671         numif = ifc.ifc_len / sizeof(struct ifreq);
2672
2673         result = g_try_malloc0((numif + 1) * sizeof(char *));
2674         if (!result)
2675                 goto error;
2676
2677         close(sk);
2678
2679         for (i = 0; i < numif; i++) {
2680                 struct ifreq *r = &ifr[i];
2681                 struct in6_addr *addr6;
2682                 in_addr_t addr4;
2683
2684                 /*
2685                  * Note that we do not return loopback interfaces here as they
2686                  * are not needed for our purposes.
2687                  */
2688                 switch (r->ifr_addr.sa_family) {
2689                 case AF_INET:
2690                         addr4 = ntohl(((struct sockaddr_in *)
2691                                                 &r->ifr_addr)->sin_addr.s_addr);
2692                         if (((addr4 & 0xff000000) >> 24) == 127)
2693                                 continue;
2694                         break;
2695                 case AF_INET6:
2696                         addr6 = &((struct sockaddr_in6 *)
2697                                                 &r->ifr_addr)->sin6_addr;
2698                         if (IN6_IS_ADDR_LINKLOCAL(addr6))
2699                                 continue;
2700                         break;
2701                 }
2702
2703                 result[count++] = g_strdup(r->ifr_name);
2704         }
2705
2706         g_free(ifr);
2707
2708         if (count < numif)
2709                 result = g_try_realloc(result, (count + 1) * sizeof(char *));
2710
2711         return result;
2712
2713 error:
2714         close(sk);
2715         g_free(ifr);
2716         return NULL;
2717 }
2718
2719 bool connman_inet_is_ipv6_supported()
2720 {
2721         int sk;
2722
2723         sk = socket(PF_INET6, SOCK_DGRAM | SOCK_CLOEXEC, 0);
2724         if (sk < 0)
2725                 return false;
2726
2727         close(sk);
2728         return true;
2729 }
2730
2731 int __connman_inet_get_interface_address(int index, int family, void *address)
2732 {
2733         struct ifaddrs *ifaddr, *ifa;
2734         int err = -ENOENT;
2735         char name[IF_NAMESIZE];
2736
2737         if (!if_indextoname(index, name))
2738                 return -EINVAL;
2739
2740         DBG("index %d interface %s", index, name);
2741
2742         if (getifaddrs(&ifaddr) < 0) {
2743                 err = -errno;
2744                 DBG("Cannot get addresses err %d/%s", err, strerror(-err));
2745                 return err;
2746         }
2747
2748         for (ifa = ifaddr; ifa; ifa = ifa->ifa_next) {
2749                 if (!ifa->ifa_addr)
2750                         continue;
2751
2752                 if (strncmp(ifa->ifa_name, name, IF_NAMESIZE) == 0 &&
2753                                         ifa->ifa_addr->sa_family == family) {
2754                         if (family == AF_INET) {
2755                                 struct sockaddr_in *in4 = (struct sockaddr_in *)
2756                                         ifa->ifa_addr;
2757                                 if (in4->sin_addr.s_addr == INADDR_ANY)
2758                                         continue;
2759                                 memcpy(address, &in4->sin_addr,
2760                                                         sizeof(struct in_addr));
2761                         } else if (family == AF_INET6) {
2762                                 struct sockaddr_in6 *in6 =
2763                                         (struct sockaddr_in6 *)ifa->ifa_addr;
2764                                 if (memcmp(&in6->sin6_addr, &in6addr_any,
2765                                                 sizeof(struct in6_addr)) == 0)
2766                                         continue;
2767                                 memcpy(address, &in6->sin6_addr,
2768                                                 sizeof(struct in6_addr));
2769
2770                         } else {
2771                                 err = -EINVAL;
2772                                 goto out;
2773                         }
2774
2775                         err = 0;
2776                         break;
2777                 }
2778         }
2779
2780 out:
2781         freeifaddrs(ifaddr);
2782         return err;
2783 }
2784
2785 static int iprule_modify(int cmd, int family, uint32_t table_id,
2786                         uint32_t fwmark)
2787 {
2788         struct __connman_inet_rtnl_handle rth;
2789         int ret;
2790
2791         memset(&rth, 0, sizeof(rth));
2792
2793         rth.req.n.nlmsg_type = cmd;
2794         rth.req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2795         rth.req.n.nlmsg_flags = NLM_F_REQUEST;
2796         rth.req.u.r.rt.rtm_family = family;
2797         rth.req.u.r.rt.rtm_protocol = RTPROT_BOOT;
2798         rth.req.u.r.rt.rtm_scope = RT_SCOPE_UNIVERSE;
2799         rth.req.u.r.rt.rtm_table = table_id;
2800         rth.req.u.r.rt.rtm_type = RTN_UNSPEC;
2801         rth.req.u.r.rt.rtm_flags = 0;
2802
2803         if (cmd == RTM_NEWRULE) {
2804                 rth.req.n.nlmsg_flags |= NLM_F_CREATE|NLM_F_EXCL;
2805                 rth.req.u.r.rt.rtm_type = RTN_UNICAST;
2806         }
2807
2808         __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2809                                                         FRA_FWMARK, fwmark);
2810
2811         if (table_id < 256) {
2812                 rth.req.u.r.rt.rtm_table = table_id;
2813         } else {
2814                 rth.req.u.r.rt.rtm_table = RT_TABLE_UNSPEC;
2815                 __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2816                                                 FRA_TABLE, table_id);
2817         }
2818
2819         if (rth.req.u.r.rt.rtm_family == AF_UNSPEC)
2820                 rth.req.u.r.rt.rtm_family = AF_INET;
2821
2822         ret = __connman_inet_rtnl_open(&rth);
2823         if (ret < 0)
2824                 goto done;
2825
2826         ret = __connman_inet_rtnl_send(&rth, &rth.req.n);
2827
2828 done:
2829         __connman_inet_rtnl_close(&rth);
2830
2831         return ret;
2832 }
2833
2834 int __connman_inet_add_fwmark_rule(uint32_t table_id, int family, uint32_t fwmark)
2835 {
2836         /* ip rule add fwmark 9876 table 1234 */
2837
2838         return iprule_modify(RTM_NEWRULE, family, table_id, fwmark);
2839 }
2840
2841 int __connman_inet_del_fwmark_rule(uint32_t table_id, int family, uint32_t fwmark)
2842 {
2843         return iprule_modify(RTM_DELRULE, family, table_id, fwmark);
2844 }
2845
2846 static int iproute_default_modify(int cmd, uint32_t table_id, int ifindex,
2847                         const char *gateway)
2848 {
2849         struct __connman_inet_rtnl_handle rth;
2850         unsigned char buf[sizeof(struct in6_addr)];
2851         int ret, len;
2852         int family = connman_inet_check_ipaddress(gateway);
2853
2854         switch (family) {
2855         case AF_INET:
2856                 len = 4;
2857                 break;
2858         case AF_INET6:
2859                 len = 16;
2860                 break;
2861         default:
2862                 return -EINVAL;
2863         }
2864
2865         ret = inet_pton(family, gateway, buf);
2866         if (ret <= 0)
2867                 return -EINVAL;
2868
2869         memset(&rth, 0, sizeof(rth));
2870
2871         rth.req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
2872         rth.req.n.nlmsg_flags = NLM_F_REQUEST | NLM_F_CREATE | NLM_F_EXCL;
2873         rth.req.n.nlmsg_type = cmd;
2874         rth.req.u.r.rt.rtm_family = family;
2875         rth.req.u.r.rt.rtm_table = RT_TABLE_MAIN;
2876         rth.req.u.r.rt.rtm_scope = RT_SCOPE_NOWHERE;
2877         rth.req.u.r.rt.rtm_protocol = RTPROT_BOOT;
2878         rth.req.u.r.rt.rtm_scope = RT_SCOPE_UNIVERSE;
2879         rth.req.u.r.rt.rtm_type = RTN_UNICAST;
2880
2881         __connman_inet_rtnl_addattr_l(&rth.req.n, sizeof(rth.req), RTA_GATEWAY,
2882                                                                 buf, len);
2883         if (table_id < 256) {
2884                 rth.req.u.r.rt.rtm_table = table_id;
2885         } else {
2886                 rth.req.u.r.rt.rtm_table = RT_TABLE_UNSPEC;
2887                 __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2888                                                         RTA_TABLE, table_id);
2889         }
2890
2891         __connman_inet_rtnl_addattr32(&rth.req.n, sizeof(rth.req),
2892                                                         RTA_OIF, ifindex);
2893
2894         ret = __connman_inet_rtnl_open(&rth);
2895         if (ret < 0)
2896                 goto done;
2897
2898         ret = __connman_inet_rtnl_send(&rth, &rth.req.n);
2899
2900 done:
2901         __connman_inet_rtnl_close(&rth);
2902
2903         return ret;
2904 }
2905
2906 int __connman_inet_add_default_to_table(uint32_t table_id, int ifindex,
2907                                                 const char *gateway)
2908 {
2909         /* ip route add default via 1.2.3.4 dev wlan0 table 1234 */
2910
2911         return iproute_default_modify(RTM_NEWROUTE, table_id, ifindex, gateway);
2912 }
2913
2914 int __connman_inet_del_default_from_table(uint32_t table_id, int ifindex,
2915                                                 const char *gateway)
2916 {
2917         /* ip route del default via 1.2.3.4 dev wlan0 table 1234 */
2918
2919         return iproute_default_modify(RTM_DELROUTE, table_id, ifindex, gateway);
2920 }
2921
2922 int __connman_inet_get_interface_ll_address(int index, int family,
2923                                                                 void *address)
2924 {
2925         struct ifaddrs *ifaddr, *ifa;
2926         int err = -ENOENT;
2927         char name[IF_NAMESIZE];
2928
2929         if (!if_indextoname(index, name))
2930                 return -EINVAL;
2931
2932         DBG("index %d interface %s", index, name);
2933
2934         if (getifaddrs(&ifaddr) < 0) {
2935                 err = -errno;
2936                 DBG("Cannot get addresses err %d/%s", err, strerror(-err));
2937                 return err;
2938         }
2939
2940         for (ifa = ifaddr; ifa; ifa = ifa->ifa_next) {
2941                 if (!ifa->ifa_addr)
2942                         continue;
2943
2944                 if (strncmp(ifa->ifa_name, name, IF_NAMESIZE) == 0 &&
2945                                         ifa->ifa_addr->sa_family == family) {
2946                         if (family == AF_INET) {
2947                                 struct sockaddr_in *in4 = (struct sockaddr_in *)
2948                                         ifa->ifa_addr;
2949                                 if (in4->sin_addr.s_addr == INADDR_ANY)
2950                                         continue;
2951                                 if ((in4->sin_addr.s_addr & IN_CLASSB_NET) !=
2952                                                 ((in_addr_t) 0xa9fe0000))
2953                                         continue;
2954                                 memcpy(address, &in4->sin_addr,
2955                                                         sizeof(struct in_addr));
2956                         } else if (family == AF_INET6) {
2957                                 struct sockaddr_in6 *in6 =
2958                                         (struct sockaddr_in6 *)ifa->ifa_addr;
2959                                 if (memcmp(&in6->sin6_addr, &in6addr_any,
2960                                                 sizeof(struct in6_addr)) == 0)
2961                                         continue;
2962                                 if (!IN6_IS_ADDR_LINKLOCAL(&in6->sin6_addr))
2963                                         continue;
2964
2965                                 memcpy(address, &in6->sin6_addr,
2966                                                 sizeof(struct in6_addr));
2967                         } else {
2968                                 err = -EINVAL;
2969                                 goto out;
2970                         }
2971
2972                         err = 0;
2973                         break;
2974                 }
2975         }
2976
2977 out:
2978         freeifaddrs(ifaddr);
2979         return err;
2980 }
2981
2982 int __connman_inet_get_address_netmask(int ifindex,
2983                                         struct sockaddr_in *address,
2984                                         struct sockaddr_in *netmask)
2985 {
2986         int sk, ret = -EINVAL;
2987         struct ifreq ifr;
2988
2989         DBG("index %d", ifindex);
2990
2991         sk = socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0);
2992         if (sk < 0)
2993                 return -EINVAL;
2994
2995         memset(&ifr, 0, sizeof(ifr));
2996         ifr.ifr_ifindex = ifindex;
2997
2998         if (ioctl(sk, SIOCGIFNAME, &ifr) < 0)
2999                 goto out;
3000
3001         if (ioctl(sk, SIOCGIFNETMASK, &ifr) < 0)
3002                 goto out;
3003
3004         memcpy(netmask, (struct sockaddr_in *)&ifr.ifr_netmask,
3005                                                 sizeof(struct sockaddr_in));
3006
3007         if (ioctl(sk, SIOCGIFADDR, &ifr) < 0)
3008                 goto out;
3009
3010         memcpy(address, (struct sockaddr_in *)&ifr.ifr_addr,
3011                                                 sizeof(struct sockaddr_in));
3012         ret = 0;
3013
3014 out:
3015         close(sk);
3016         return ret;
3017 }