miniupnp/miniupnpd/bsd/ifacewatcher.c

117 lines
3.3 KiB
C

/* $Id: ifacewatcher.c,v 1.3 2011/06/04 16:19:51 nanard Exp $ */
/* Project MiniUPnP
* web : http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/
* (c) 2011 Thomas BERNARD
* This software is subject to the conditions detailed
* in the LICENCE file provided within the distribution */
#include "../config.h"
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <net/if.h>
#include <net/route.h>
#include <syslog.h>
#if !defined(SA_LEN)
#define SA_LEN(sa) (sa)->sa_len
#endif
#define SALIGN (sizeof(long) - 1)
#define SA_RLEN(sa) ((sa)->sa_len ? (((sa)->sa_len + SALIGN) & ~SALIGN) : (SALIGN + 1))
#include "../upnputils.h"
#include "../upnpglobalvars.h"
extern volatile int should_send_public_address_change_notif;
int
OpenAndConfInterfaceWatchSocket(void)
{
int s;
/*s = socket(PF_ROUTE, SOCK_RAW, AF_INET);*/
s = socket(PF_ROUTE, SOCK_RAW, AF_UNSPEC);
/* The family parameter may be AF_UNSPEC which will provide routing informa-
* tion for all address families, or can be restricted to a specific address
* family by specifying which one is desired. There can be more than one
* routing socket open per system. */
if(s < 0) {
syslog(LOG_ERR, "OpenAndConfInterfaceWatchSocket socket: %m");
}
return s;
}
void
ProcessInterfaceWatchNotify(int s)
{
char buf[4096];
ssize_t len;
char tmp[64];
struct rt_msghdr * rtm;
struct if_msghdr * ifm;
struct ifa_msghdr * ifam;
#ifdef RTM_IFANNOUNCE
struct if_announcemsghdr * ifanm;
#endif
char * p;
struct sockaddr * sa;
unsigned int ext_if_name_index = 0;
len = recv(s, buf, sizeof(buf), 0);
if(len < 0) {
syslog(LOG_ERR, "ProcessInterfaceWatchNotify recv: %m");
return;
}
if(ext_if_name) {
ext_if_name_index = if_nametoindex(ext_if_name);
}
rtm = (struct rt_msghdr *)buf;
syslog(LOG_DEBUG, "%u rt_msg : msglen=%d version=%d type=%d", (unsigned)len,
rtm->rtm_msglen, rtm->rtm_version, rtm->rtm_type);
switch(rtm->rtm_type) {
case RTM_IFINFO: /* iface going up/down etc. */
ifm = (struct if_msghdr *)buf;
syslog(LOG_DEBUG, " RTM_IFINFO: addrs=%x flags=%x index=%hu",
ifm->ifm_addrs, ifm->ifm_flags, ifm->ifm_index);
break;
#ifdef RTM_IFANNOUNCE
case RTM_IFANNOUNCE: /* iface arrival/departure */
ifanm = (struct if_announcemsghdr *)buf;
syslog(LOG_DEBUG, " RTM_IFANNOUNCE: index=%hu what=%hu ifname=%s",
ifanm->ifan_index, ifanm->ifan_what, ifanm->ifan_name);
break;
#endif
#ifdef RTM_IEEE80211
case RTM_IEEE80211: /* IEEE80211 wireless event */
syslog(LOG_DEBUG, " RTM_IEEE80211");
break;
#endif
case RTM_NEWADDR: /* address being added to iface */
ifam = (struct ifa_msghdr *)buf;
syslog(LOG_DEBUG, " RTM_NEWADDR: addrs=%x flags=%x index=%hu",
ifam->ifam_addrs, ifam->ifam_flags, ifam->ifam_index);
p = buf + sizeof(struct ifa_msghdr);
while(p < buf + len) {
sa = (struct sockaddr *)p;
sockaddr_to_string(sa, tmp, sizeof(tmp));
syslog(LOG_DEBUG, " %s", tmp);
p += SA_RLEN(sa);
}
if(ifam->ifam_index == ext_if_name_index) {
should_send_public_address_change_notif = 1;
}
break;
case RTM_DELADDR: /* address being removed from iface */
ifam = (struct ifa_msghdr *)buf;
if(ifam->ifam_index == ext_if_name_index) {
should_send_public_address_change_notif = 1;
}
break;
default:
syslog(LOG_DEBUG, "unprocessed RTM message type=%d", rtm->rtm_type);
}
}