Return to ifacewatcher.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / miniupnpd / bsd

miniupnpd 1.6+patches

    1: /* $Id: ifacewatcher.c,v 1.1.1.1 2012/05/29 12:55:57 misho Exp $ */
    2: /* Project MiniUPnP
    3:  * web : http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/
    4:  * (c) 2011 Thomas BERNARD
    5:  * This software is subject to the conditions detailed
    6:  * in the LICENCE file provided within the distribution */
    7: 
    8: #include "../config.h"
    9: 
   10: #include <sys/types.h>
   11: #include <sys/time.h>
   12: #include <sys/socket.h>
   13: #include <net/if.h>
   14: #include <net/route.h>
   15: #include <syslog.h>
   16: 
   17: #if !defined(SA_LEN)
   18: #define	SA_LEN(sa)	(sa)->sa_len
   19: #endif
   20: 
   21: #define	SALIGN	(sizeof(long) - 1)
   22: #define	SA_RLEN(sa)	((sa)->sa_len ? (((sa)->sa_len + SALIGN) & ~SALIGN) : (SALIGN + 1))
   23: 
   24: #include "../upnputils.h"
   25: #include "../upnpglobalvars.h"
   26: 
   27: extern volatile int should_send_public_address_change_notif;
   28: 
   29: int
   30: OpenAndConfInterfaceWatchSocket(void)
   31: {
   32: 	int s;
   33: 
   34: 	/*s = socket(PF_ROUTE, SOCK_RAW, AF_INET);*/
   35: 	s = socket(PF_ROUTE, SOCK_RAW, AF_UNSPEC);
   36: /* The family parameter may be AF_UNSPEC which will provide routing informa-
   37:  * tion for all address families, or can be restricted to a specific address
   38:  * family by specifying which one is desired.  There can be more than one
   39:  * routing socket open per system. */
   40: 	if(s < 0) {
   41: 		syslog(LOG_ERR, "OpenAndConfInterfaceWatchSocket socket: %m");
   42: 	}
   43: 	return s;
   44: }
   45: 
   46: void
   47: ProcessInterfaceWatchNotify(int s)
   48: {
   49: 	char buf[4096];
   50: 	ssize_t len;
   51: 	char tmp[64];
   52: 	struct rt_msghdr * rtm;
   53: 	struct if_msghdr * ifm;
   54: 	struct ifa_msghdr * ifam;
   55: #ifdef RTM_IFANNOUNCE
   56: 	struct if_announcemsghdr * ifanm;
   57: #endif
   58: 	char * p;
   59: 	struct sockaddr * sa;
   60: 	unsigned int ext_if_name_index = 0;
   61: 
   62: 	len = recv(s, buf, sizeof(buf), 0);
   63: 	if(len < 0) {
   64: 		syslog(LOG_ERR, "ProcessInterfaceWatchNotify recv: %m");
   65: 		return;
   66: 	}
   67: 	if(ext_if_name) {
   68: 		ext_if_name_index = if_nametoindex(ext_if_name);
   69: 	}
   70: 	rtm = (struct rt_msghdr *)buf;
   71: 	syslog(LOG_DEBUG, "%u rt_msg : msglen=%d version=%d type=%d", (unsigned)len,
   72: 	       rtm->rtm_msglen, rtm->rtm_version, rtm->rtm_type);	
   73: 	switch(rtm->rtm_type) {
   74: 	case RTM_IFINFO:	/* iface going up/down etc. */
   75: 		ifm = (struct if_msghdr *)buf;
   76: 		syslog(LOG_DEBUG, " RTM_IFINFO: addrs=%x flags=%x index=%hu",
   77: 		       ifm->ifm_addrs, ifm->ifm_flags, ifm->ifm_index);
   78: 		break;
   79: #ifdef RTM_IFANNOUNCE
   80: 	case RTM_IFANNOUNCE:	/* iface arrival/departure */
   81: 		ifanm = (struct if_announcemsghdr *)buf;
   82: 		syslog(LOG_DEBUG, " RTM_IFANNOUNCE: index=%hu what=%hu ifname=%s",
   83: 		       ifanm->ifan_index, ifanm->ifan_what, ifanm->ifan_name);
   84: 		break;
   85: #endif
   86: #ifdef RTM_IEEE80211
   87: 	case RTM_IEEE80211:	/* IEEE80211 wireless event */
   88: 		syslog(LOG_DEBUG, " RTM_IEEE80211");
   89: 		break;
   90: #endif
   91: 	case RTM_NEWADDR:	/* address being added to iface */
   92: 		ifam = (struct ifa_msghdr *)buf;
   93: 		syslog(LOG_DEBUG, " RTM_NEWADDR: addrs=%x flags=%x index=%hu",
   94: 		       ifam->ifam_addrs, ifam->ifam_flags, ifam->ifam_index);
   95: 		p = buf + sizeof(struct ifa_msghdr);
   96: 		while(p < buf + len) {
   97: 			sa = (struct sockaddr *)p;
   98: 			sockaddr_to_string(sa, tmp, sizeof(tmp));
   99: 			syslog(LOG_DEBUG, "  %s", tmp);
  100: 			p += SA_RLEN(sa);
  101: 		}
  102: 		if(ifam->ifam_index == ext_if_name_index) {
  103: 			should_send_public_address_change_notif = 1;
  104: 		}
  105: 		break;
  106: 	case RTM_DELADDR:	/* address being removed from iface */
  107: 		ifam = (struct ifa_msghdr *)buf;
  108: 		if(ifam->ifam_index == ext_if_name_index) {
  109: 			should_send_public_address_change_notif = 1;
  110: 		}
  111: 		break;
  112: 	default:
  113: 		syslog(LOG_DEBUG, "unprocessed RTM message type=%d", rtm->rtm_type);
  114: 	}
  115: }
  116: