Annotation of embedaddon/miniupnpd/linux/ifacewatcher.c, revision 1.1
1.1 ! misho 1: /* $Id: ifacewatcher.c,v 1.1 2011/05/20 09:33:07 nanard Exp $ */
! 2: /* MiniUPnP project
! 3: * http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/
! 4: * (c) 2006-2009 Thomas Bernard
! 5: *
! 6: * ifacewatcher.c
! 7: *
! 8: * This file implements dynamic serving of new network interfaces
! 9: * which weren't available during daemon start. It also takes care
! 10: * of interfaces which become unavailable.
! 11: *
! 12: * Copyright (c) 2011, Alexey Osipov <simba@lerlan.ru>
! 13: * All rights reserved.
! 14: *
! 15: * Redistribution and use in source and binary forms, with or without
! 16: * modification, are permitted provided that the following conditions are met:
! 17: *
! 18: * * Redistributions of source code must retain the above copyright notice,
! 19: * this list of conditions and the following disclaimer.
! 20: * * Redistributions in binary form must reproduce the above copyright notice,
! 21: * this list of conditions and the following disclaimer in the documentation
! 22: * and/or other materials provided with the distribution.
! 23: * * The name of the author may not be used to endorse or promote products
! 24: * derived from this software without specific prior written permission.
! 25: *
! 26: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
! 27: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
! 28: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
! 29: * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
! 30: * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
! 31: * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
! 32: * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
! 33: * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
! 34: * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
! 35: * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
! 36: * POSSIBILITY OF SUCH DAMAGE. */
! 37:
! 38:
! 39: #include <sys/types.h>
! 40: #include <sys/socket.h>
! 41: #include <linux/netlink.h>
! 42: #include <linux/rtnetlink.h>
! 43: #include <arpa/inet.h>
! 44: #include <net/if.h>
! 45: #include <syslog.h>
! 46: #include <string.h>
! 47: #include <unistd.h>
! 48: #include <stdlib.h>
! 49:
! 50: #include "../config.h"
! 51:
! 52: #ifdef USE_IFACEWATCHER
! 53:
! 54: #include "../ifacewatcher.h"
! 55: #include "../minissdp.h"
! 56: #include "../getifaddr.h"
! 57: #include "../upnpglobalvars.h"
! 58: #include "../natpmp.h"
! 59:
! 60: extern volatile int should_send_public_address_change_notif;
! 61:
! 62:
! 63: int
! 64: OpenAndConfInterfaceWatchSocket(void)
! 65: {
! 66: int s;
! 67: struct sockaddr_nl addr;
! 68:
! 69: s = socket(PF_NETLINK, SOCK_RAW, NETLINK_ROUTE);
! 70: if (s == -1)
! 71: {
! 72: syslog(LOG_ERR, "socket(PF_NETLINK, SOCK_RAW, NETLINK_ROUTE): %m");
! 73: return -1;
! 74: }
! 75:
! 76: memset(&addr, 0, sizeof(addr));
! 77: addr.nl_family = AF_NETLINK;
! 78: addr.nl_groups = RTMGRP_LINK | RTMGRP_IPV4_IFADDR;
! 79:
! 80: if (bind(s, (struct sockaddr *)&addr, sizeof(addr)) < 0)
! 81: {
! 82: syslog(LOG_ERR, "bind(netlink): %m");
! 83: close(s);
! 84: return -1;
! 85: }
! 86:
! 87: return s;
! 88: }
! 89:
! 90: #if 0
! 91: /* disabled at the moment */
! 92: int
! 93: ProcessInterfaceUp(struct ifinfomsg *ifi)
! 94: {
! 95: struct lan_iface_s * lan_iface;
! 96: struct lan_iface_s * lan_iface2;
! 97: struct lan_addr_s * lan_addr;
! 98: char ifname[IFNAMSIZ];
! 99: char ifstraddr[16];
! 100: struct in_addr ifaddr;
! 101:
! 102: /* check if we already have this iface */
! 103: for(lan_iface = lan_ifaces.lh_first; lan_iface != NULL; lan_iface = lan_iface->list.le_next)
! 104: if (lan_iface->iface.index == ifi->ifi_index)
! 105: break;
! 106:
! 107: if (lan_iface != NULL)
! 108: return 0;
! 109:
! 110: if (if_indextoname(ifi->ifi_index, ifname) == NULL)
! 111: {
! 112: syslog(LOG_ERR, "if_indextoname(%d, ifname) failed", ifi->ifi_index);
! 113: return -1;
! 114: }
! 115:
! 116: if (getifaddr(ifname, ifstraddr, 16) < 0)
! 117: {
! 118: syslog(LOG_DEBUG, "getifaddr(%s, ifaddr, 16) failed", ifname);
! 119: return 1;
! 120: }
! 121:
! 122: if (inet_pton(AF_INET, ifstraddr, &ifaddr) != 1)
! 123: {
! 124: syslog(LOG_ERR, "inet_pton(AF_INET, \"%s\", &ifaddr) failed", ifstraddr);
! 125: return -1;
! 126: }
! 127:
! 128: /* check if this new interface has address which we need to listen to */
! 129: for(lan_addr = lan_addrs.lh_first; lan_addr != NULL; lan_addr = lan_addr->list.le_next)
! 130: {
! 131: if (lan_addr->addr.s_addr != ifaddr.s_addr)
! 132: continue;
! 133:
! 134: syslog(LOG_INFO, "Interface up: %s (%s)", ifname, ifstraddr);
! 135:
! 136: /* adding new lan_iface entry */
! 137: lan_iface = (struct lan_iface_s *) malloc(sizeof(struct lan_iface_s));
! 138: if (lan_iface == NULL)
! 139: {
! 140: syslog(LOG_ERR, "malloc(sizeof(struct lan_iface_s): %m");
! 141: continue;
! 142: }
! 143:
! 144: lan_iface->lan_addr = lan_addr;
! 145: strncpy(lan_iface->iface.name, ifname, IFNAMSIZ);
! 146: lan_iface->iface.index = ifi->ifi_index;
! 147: lan_iface->iface.addr = ifaddr;
! 148: lan_iface->snotify = -1;
! 149: #ifdef ENABLE_NATPMP
! 150: lan_iface->snatpmp = -1;
! 151: #endif
! 152:
! 153: LIST_INSERT_HEAD(&lan_ifaces, lan_iface, list);
! 154:
! 155: /* adding multicast membership for SSDP */
! 156: if(AddMulticastMembership(sudp, ifaddr.s_addr, ifi->ifi_index) < 0)
! 157: syslog(LOG_WARNING, "Failed to add multicast membership for interface %s (%s)", ifname, ifstraddr);
! 158: else
! 159: syslog(LOG_INFO, "Multicast membership added for %s (%s)", ifname, ifstraddr);
! 160:
! 161: /* create SSDP notify socket */
! 162: if (OpenAndConfSSDPNotifySocket(lan_iface) < 0)
! 163: syslog(LOG_WARNING, "Failed to open SSDP notify socket for interface %s (%s)", ifname, ifstraddr);
! 164:
! 165: #ifdef ENABLE_NATPMP
! 166: /* create NAT-PMP socket */
! 167: for(lan_iface2 = lan_ifaces.lh_first; lan_iface2 != NULL; lan_iface2 = lan_iface2->list.le_next)
! 168: if (lan_iface2->lan_addr->addr.s_addr == lan_iface->lan_addr->addr.s_addr &&
! 169: lan_iface2->snatpmp >= 0)
! 170: lan_iface->snatpmp = lan_iface2->snatpmp;
! 171:
! 172: if (lan_iface->snatpmp < 0)
! 173: {
! 174: lan_iface->snatpmp = OpenAndConfNATPMPSocket(ifaddr.s_addr);
! 175: if (lan_iface->snatpmp < 0)
! 176: syslog(LOG_ERR, "OpenAndConfNATPMPSocket(ifaddr.s_addr) failed for %s (%s)", ifname, ifstraddr);
! 177: else
! 178: syslog(LOG_INFO, "Listening for NAT-PMP connection on %s:%d", ifstraddr, NATPMP_PORT);
! 179: }
! 180: #endif
! 181: }
! 182:
! 183: return 0;
! 184: }
! 185:
! 186: int
! 187: ProcessInterfaceDown(struct ifinfomsg *ifi)
! 188: {
! 189: struct lan_iface_s * lan_iface;
! 190: struct lan_iface_s * lan_iface2;
! 191:
! 192: /* check if we have this iface */
! 193: for(lan_iface = lan_ifaces.lh_first; lan_iface != NULL; lan_iface = lan_iface->list.le_next)
! 194: if (lan_iface->iface.index == ifi->ifi_index)
! 195: break;
! 196:
! 197: if (lan_iface == NULL)
! 198: return 0;
! 199:
! 200: /* one of our interfaces is going down, clean up */
! 201: syslog(LOG_INFO, "Interface down: %s", lan_iface->iface.name);
! 202:
! 203: /* remove multicast membership for SSDP */
! 204: if(DropMulticastMembership(sudp, lan_iface->lan_addr->addr.s_addr, lan_iface->iface.index) < 0)
! 205: syslog(LOG_WARNING, "Failed to drop multicast membership for interface %s (%s)", lan_iface->iface.name, lan_iface->lan_addr->str);
! 206: else
! 207: syslog(LOG_INFO, "Multicast membership dropped for %s (%s)", lan_iface->iface.name, lan_iface->lan_addr->str);
! 208:
! 209: /* closing SSDP notify socket */
! 210: close(lan_iface->snotify);
! 211:
! 212: #ifdef ENABLE_NATPMP
! 213: /* closing NAT-PMP socket if it's not used anymore */
! 214: for(lan_iface2 = lan_ifaces.lh_first; lan_iface2 != NULL; lan_iface2 = lan_iface2->list.le_next)
! 215: if (lan_iface2 != lan_iface && lan_iface2->snatpmp == lan_iface->snatpmp)
! 216: break;
! 217:
! 218: if (lan_iface2 == NULL)
! 219: close(lan_iface->snatpmp);
! 220: #endif
! 221:
! 222: /* del corresponding lan_iface entry */
! 223: LIST_REMOVE(lan_iface, list);
! 224: free(lan_iface);
! 225:
! 226: return 0;
! 227: }
! 228: #endif
! 229:
! 230: void
! 231: ProcessInterfaceWatchNotify(int s)
! 232: {
! 233: char buffer[4096];
! 234: struct iovec iov;
! 235: struct msghdr hdr;
! 236: struct nlmsghdr *nlhdr;
! 237: struct ifinfomsg *ifi;
! 238: struct ifaddrmsg *ifa;
! 239: int len;
! 240:
! 241: struct rtattr *rth; //
! 242: int rtl;
! 243:
! 244: unsigned int ext_if_name_index = 0;
! 245:
! 246: iov.iov_base = buffer;
! 247: iov.iov_len = sizeof(buffer);
! 248:
! 249: memset(&hdr, 0, sizeof(hdr));
! 250: hdr.msg_iov = &iov;
! 251: hdr.msg_iovlen = 1;
! 252:
! 253: len = recvmsg(s, &hdr, 0);
! 254: if (len < 0)
! 255: {
! 256: syslog(LOG_ERR, "recvmsg(s, &hdr, 0): %m");
! 257: return;
! 258: }
! 259:
! 260: if(ext_if_name) {
! 261: ext_if_name_index = if_nametoindex(ext_if_name);
! 262: }
! 263:
! 264: for (nlhdr = (struct nlmsghdr *) buffer;
! 265: NLMSG_OK (nlhdr, len);
! 266: nlhdr = NLMSG_NEXT (nlhdr, len))
! 267: {
! 268: if (nlhdr->nlmsg_type == NLMSG_DONE)
! 269: break;
! 270: switch(nlhdr->nlmsg_type) {
! 271: case RTM_DELLINK:
! 272: ifi = (struct ifinfomsg *) NLMSG_DATA(nlhdr);
! 273: /*if (ProcessInterfaceDown(ifi) < 0)
! 274: syslog(LOG_ERR, "ProcessInterfaceDown(ifi) failed");*/
! 275: break;
! 276: case RTM_NEWLINK:
! 277: ifi = (struct ifinfomsg *) NLMSG_DATA(nlhdr);
! 278: /*if (ProcessInterfaceUp(ifi) < 0)
! 279: syslog(LOG_ERR, "ProcessInterfaceUp(ifi) failed");*/
! 280: break;
! 281: case RTM_NEWADDR:
! 282: /* see /usr/include/linux/netlink.h
! 283: * and /usr/include/linux/rtnetlink.h */
! 284: ifa = (struct ifaddrmsg *) NLMSG_DATA(nlhdr);
! 285: syslog(LOG_DEBUG, "ProcessInterfaceWatchNotify RTM_NEWADDR");
! 286: for(rth = IFA_RTA(ifa), rtl = IFA_PAYLOAD(nlhdr);
! 287: rtl && RTA_OK(rth, rtl);
! 288: rth = RTA_NEXT(rth, rtl)) {
! 289: syslog(LOG_DEBUG, " - %u - %s type=%d",
! 290: ifa->ifa_index, inet_ntoa(*((struct in_addr *)RTA_DATA(rth))),
! 291: rth->rta_type);
! 292: }
! 293: if(ifa->ifa_index == ext_if_name_index) {
! 294: should_send_public_address_change_notif = 1;
! 295: }
! 296: break;
! 297: case RTM_DELADDR:
! 298: ifa = (struct ifaddrmsg *) NLMSG_DATA(nlhdr);
! 299: syslog(LOG_DEBUG, "ProcessInterfaceWatchNotify RTM_DELADDR");
! 300: if(ifa->ifa_index == ext_if_name_index) {
! 301: should_send_public_address_change_notif = 1;
! 302: }
! 303: break;
! 304: default:
! 305: syslog(LOG_DEBUG, "ProcessInterfaceWatchNotify type %d ignored", nlhdr->nlmsg_type);
! 306: }
! 307: }
! 308:
! 309: }
! 310:
! 311: #endif
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ifacewatcher.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / miniupnpd / linux