Return to ifacewatcher.c CVS log

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

Annotation of embedaddon/miniupnpd/bsd/ifacewatcher.c, revision 1.1.1.1

1.1       misho       1: /* $Id: ifacewatcher.c,v 1.3 2011/06/04 16:19:51 nanard 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: