4 This file is part of avahi.
6 avahi is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 avahi is distributed in the hope that it will be useful, but WITHOUT
12 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
13 or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General
14 Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with avahi; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
26 #include <avahi-common/malloc.h>
32 #include <sys/types.h>
33 #include <sys/socket.h>
34 #include <sys/param.h>
35 #ifdef HAVE_SYS_SYSCTL_H
36 #include <sys/sysctl.h>
38 #include <sys/sockio.h>
41 #include <net/route.h>
43 #include <net/if_dl.h>
44 #include <netinet/in.h>
48 #include "iface-pfroute.h"
51 static int bitcount (unsigned int n)
62 static void rtm_info(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m)
65 struct if_msghdr *ifm = (struct if_msghdr *)rtm;
66 struct sockaddr_dl *sdl = (struct sockaddr_dl *)(ifm + 1);
68 if (sdl->sdl_family != AF_LINK)
71 if (ifm->ifm_addrs == 0 && ifm->ifm_index > 0) {
72 if (!(hw = avahi_interface_monitor_get_hw_interface(m, (AvahiIfIndex) ifm->ifm_index)))
74 avahi_hw_interface_free(hw, 0);
78 if (!(hw = avahi_interface_monitor_get_hw_interface(m, ifm->ifm_index)))
79 if (!(hw = avahi_hw_interface_new(m, (AvahiIfIndex) ifm->ifm_index)))
83 (ifm->ifm_flags & IFF_UP) &&
84 (!m->server->config.use_iff_running || (ifm->ifm_flags & IFF_RUNNING)) &&
85 !(ifm->ifm_flags & IFF_LOOPBACK) &&
86 (ifm->ifm_flags & IFF_MULTICAST) &&
87 (m->server->config.allow_point_to_point || !(ifm->ifm_flags & IFF_POINTOPOINT));
90 hw->name = avahi_strndup(sdl->sdl_data, sdl->sdl_nlen);
92 hw->mtu = ifm->ifm_data.ifi_mtu;
94 hw->mac_address_size = sdl->sdl_alen;
95 if (hw->mac_address_size > AVAHI_MAC_ADDRESS_MAX)
96 hw->mac_address_size = AVAHI_MAC_ADDRESS_MAX;
98 memcpy(hw->mac_address, sdl->sdl_data + sdl->sdl_nlen, hw->mac_address_size);
102 /* avahi_log_debug("======\n name: %s\n index:%d\n mtu:%d\n mac:%s\n flags_ok:%d\n======", */
103 /* hw->name, hw->index, */
105 /* avahi_format_mac_address(mac, sizeof(mac), hw->mac_address, hw->mac_address_size), */
109 avahi_hw_interface_check_relevant(hw);
110 avahi_hw_interface_update_rrs(hw, 0);
114 ((a) > 0 ? (1 + (((a) - 1) | (sizeof(long) - 1))) : sizeof(long))
115 #ifdef HAVE_SYS_SYSCTL_H
116 #define ADVANCE(x, n) (x += ROUNDUP((n)->sa_len))
118 #define ADVANCE(x, n) (x += ROUNDUP(sizeof(struct sockaddr)))
121 static void rtm_addr(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m)
123 AvahiInterface *iface;
126 struct ifa_msghdr *ifam = (struct ifa_msghdr *) rtm;
127 char *cp = (char *)(ifam + 1);
128 int addrs = ifam->ifam_addrs;
131 struct sockaddr *sa =NULL;
133 #if defined(__NetBSD__) || defined(__OpenBSD__)
134 if(((struct sockaddr *)cp)->sa_family == AF_UNSPEC)
135 ((struct sockaddr *)cp)->sa_family = AF_INET;
138 if(((struct sockaddr *)cp)->sa_family != AF_INET && ((struct sockaddr *)cp)->sa_family != AF_INET6)
141 if (!(iface = avahi_interface_monitor_get_interface(m, (AvahiIfIndex) ifam->ifam_index, avahi_af_to_proto(((struct sockaddr *)cp)->sa_family))))
144 raddr.proto = avahi_af_to_proto(((struct sockaddr *)cp)->sa_family);
146 for(i = 0; addrs != 0 && i < RTAX_MAX; addrs &= ~(1<<i), i++)
150 sa = (struct sockaddr *)cp;
151 #ifdef HAVE_SYS_SYSCTL_H
155 switch(sa->sa_family) {
159 prefixlen = bitcount((unsigned int)((struct sockaddr_in *)sa)->sin_addr.s_addr);
162 memcpy(raddr.data.data, &((struct sockaddr_in *)sa)->sin_addr, sizeof(struct in_addr));
171 prefixlen = bitcount((unsigned int)((struct sockaddr_in6 *)sa)->sin6_addr.s6_addr);
174 memcpy(raddr.data.data, &((struct sockaddr_in6 *)sa)->sin6_addr, sizeof(struct in6_addr));
193 if(rtm->rtm_type == RTM_NEWADDR)
195 AvahiInterfaceAddress *addriface;
196 if (!(addriface = avahi_interface_monitor_get_address(m, iface, &raddr)))
197 if (!(addriface = avahi_interface_address_new(m, iface, &raddr, prefixlen)))
200 /* addriface->global_scope = ifaddrmsg->ifa_scope == RT_SCOPE_UNIVERSE || ifaddrmsg->ifa_scope == RT_SCOPE_SITE; */
201 addriface->global_scope = 1;
205 AvahiInterfaceAddress *addriface;
206 assert(rtm->rtm_type == RTM_DELADDR);
207 if (!(addriface = avahi_interface_monitor_get_address(m, iface, &raddr)))
209 avahi_interface_address_free(addriface);
212 avahi_interface_check_relevant(iface);
213 avahi_interface_update_rrs(iface, 0);
216 static void parse_rtmsg(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m)
221 if (rtm->rtm_version != RTM_VERSION) {
222 avahi_log_warn("routing message version %d not understood",
227 switch (rtm->rtm_type) {
240 static void socket_event(AvahiWatch *w, int fd, AVAHI_GCC_UNUSED AvahiWatchEvent event,void *userdata) {
241 AvahiInterfaceMonitor *m = (AvahiInterfaceMonitor *)userdata;
242 AvahiPfRoute *nl = m->osdep.pfroute;
249 assert(fd == nl->fd);
252 if((bytes = recv(nl->fd, msg, 2048, MSG_DONTWAIT)) < 0) {
253 if (errno == EAGAIN || errno == EINTR)
255 avahi_log_error(__FILE__": recv() failed: %s", strerror(errno));
258 parse_rtmsg((struct rt_msghdr *)msg, m);
263 int avahi_interface_monitor_init_osdep(AvahiInterfaceMonitor *m) {
268 m->osdep.pfroute = NULL;
270 if ((fd = socket(PF_ROUTE, SOCK_RAW, AF_UNSPEC)) < 0) {
271 avahi_log_error(__FILE__": socket(PF_ROUTE): %s", strerror(errno));
275 if (!(m->osdep.pfroute = avahi_new(AvahiPfRoute , 1))) {
276 avahi_log_error(__FILE__": avahi_new() failed.");
279 m->osdep.pfroute->fd = fd;
281 if (!(m->osdep.pfroute->watch = m->server->poll_api->watch_new(m->server->poll_api,
282 m->osdep.pfroute->fd,
286 avahi_log_error(__FILE__": Failed to create watch.");
294 if (m->osdep.pfroute) {
295 if (m->osdep.pfroute->watch)
296 m->server->poll_api->watch_free(m->osdep.pfroute->watch);
301 m->osdep.pfroute = NULL;
307 void avahi_interface_monitor_free_osdep(AvahiInterfaceMonitor *m) {
310 if (m->osdep.pfroute) {
311 if (m->osdep.pfroute->watch)
312 m->server->poll_api->watch_free(m->osdep.pfroute->watch);
314 if (m->osdep.pfroute->fd >= 0)
315 close(m->osdep.pfroute->fd);
317 avahi_free(m->osdep.pfroute);
318 m->osdep.pfroute = NULL;
322 #if defined (SIOCGLIFNUM) && defined(HAVE_STRUCT_LIFCONF) /* Solaris 8 and later; Sol 7? */
324 * I got this function from GNU zsbra
326 static int ip6_masklen (struct in6_addr netmask) {
331 pnt = (unsigned char *) & netmask;
333 while ((*pnt == 0xff) && len < 128) {
348 static void if_add_interface(struct lifreq *lifreq, AvahiInterfaceMonitor *m, int fd, int count)
350 AvahiHwInterface *hw;
352 struct lifreq lifrcopy;
357 AvahiInterfaceAddress *addriface;
358 AvahiInterface *iface;
359 struct sockaddr_in mask;
360 struct sockaddr_in6 mask6;
361 char caddr[AVAHI_ADDRESS_STR_MAX];
365 if (ioctl(fd, SIOCGLIFFLAGS, &lifrcopy) < 0) {
366 avahi_log_error(__FILE__": ioctl(SIOCGLIFFLAGS) %s", strerror(errno));
369 flags = lifrcopy.lifr_flags;
371 if (ioctl(fd, SIOCGLIFMTU, &lifrcopy) < 0) {
372 avahi_log_error(__FILE__": ioctl(SIOCGLIFMTU) %s", strerror(errno));
375 mtu = lifrcopy.lifr_metric;
377 if (ioctl(fd, SIOCGLIFADDR, &lifrcopy) < 0) {
378 avahi_log_error(__FILE__": ioctl(SIOCGLIFADDR) %s", strerror(errno));
381 addr.proto = avahi_af_to_proto(lifreq->lifr_addr.ss_family);
382 if (ioctl(fd, SIOCGLIFNETMASK, &lifrcopy) < 0) {
383 avahi_log_error(__FILE__": ioctl(SIOCGLIFNETMASK) %s", strerror(errno));
386 switch (lifreq->lifr_addr.ss_family) {
388 memcpy(addr.data.data, &((struct sockaddr_in *)&lifreq->lifr_addr)->sin_addr, sizeof(struct in_addr));
389 memcpy(&mask, &((struct sockaddr_in *)&lifrcopy.lifr_addr)->sin_addr, sizeof(struct in_addr));
390 prefixlen = bitcount((unsigned int) mask.sin_addr.s_addr);
393 memcpy(addr.data.data, &((struct sockaddr_in6 *)&lifreq->lifr_addr)->sin6_addr, sizeof(struct in6_addr));
394 memcpy(&mask6, &((struct sockaddr_in6 *)&lifrcopy.lifr_addr)->sin6_addr, sizeof(struct in6_addr));
395 prefixlen = lifrcopy.lifr_addrlen;
400 index = if_nametoindex(lifreq->lifr_name);
402 if (!(hw = avahi_interface_monitor_get_hw_interface(m, (AvahiIfIndex) index))) {
403 if (!(hw = avahi_hw_interface_new(m, (AvahiIfIndex) index)))
408 (!m->server->config.use_iff_running || (flags & IFF_RUNNING)) &&
409 !(flags & IFF_LOOPBACK) &&
410 (flags & IFF_MULTICAST) &&
411 (m->server->config.allow_point_to_point || !(flags & IFF_POINTOPOINT));
412 hw->name = avahi_strdup(lifreq->lifr_name);
414 /* TODO get mac address */
417 if (!(iface = avahi_interface_monitor_get_interface(m, (AvahiIfIndex)index, addr.proto)))
420 if (!(addriface = avahi_interface_monitor_get_address(m, iface, &addr)))
421 if (!(addriface = avahi_interface_address_new(m, iface, &addr, prefixlen)))
424 addriface->global_scope = 1;
426 avahi_hw_interface_check_relevant(hw);
427 avahi_hw_interface_update_rrs(hw, 0);
431 void avahi_interface_monitor_sync(AvahiInterfaceMonitor *m) {
432 #ifndef HAVE_STRUCT_LIFCONF
435 char *buf, *lim, *next, count = 0;
436 struct rt_msghdr *rtm;
443 mib[2] = 0; /* protocol */
444 mib[3] = 0; /* wildcard address family */
445 mib[4] = NET_RT_IFLIST;
446 mib[5] = 0; /* no flags */
447 if (sysctl(mib, 6, NULL, &needed, NULL, 0) < 0)
449 avahi_log_error("sysctl failed: %s", strerror(errno));
450 avahi_log_error("route-sysctl-estimate");
453 if ((buf = avahi_malloc(needed)) == NULL)
455 avahi_log_error("malloc failed in avahi_interface_monitor_sync");
458 if (sysctl(mib, 6, buf, &needed, NULL, 0) < 0) {
459 avahi_log_warn("sysctl failed: %s", strerror(errno));
460 if (errno == ENOMEM && count++ < 10) {
461 avahi_log_warn("Routing table grew, retrying");
468 for (next = buf; next < lim; next += rtm->rtm_msglen) {
469 rtm = (struct rt_msghdr *)next;
473 m->list_complete = 1;
474 avahi_interface_monitor_check_relevant(m);
475 avahi_interface_monitor_update_rrs(m, 0);
476 avahi_log_info("Network interface enumeration completed.");
477 #elif defined (SIOCGLIFNUM) && defined(HAVE_STRUCT_LIFCONF) /* Solaris 8 and later; Sol 7? */
483 struct lifreq *lifreq;
485 if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
486 avahi_log_error(__FILE__": socket(PFROUTE): %s", strerror(errno));
489 lifc.lifc_buf = NULL;
490 lifn.lifn_family = AF_UNSPEC;
492 if (ioctl(sockfd, SIOCGLIFNUM, &lifn) < 0) {
493 avahi_log_error(__FILE__": ioctl(SIOCGLIFNUM): %s", strerror(errno));
496 lifc.lifc_len = lifn.lifn_count * sizeof (struct lifreq);
497 if ((lifc.lifc_buf = avahi_malloc(lifc.lifc_len)) == NULL) {
498 avahi_log_error("malloc failed in avahi_interface_monitor_sync");
501 lifc.lifc_family = NULL;
503 if(ioctl(sockfd, SIOCGLIFCONF, &lifc) < 0) {
504 avahi_log_error(__FILE__": ioctl(SIOCGLIFCONF): %s", strerror(errno));
507 lifreq = lifc.lifc_req;
509 for (n = 0; n < lifc.lifc_len; n += sizeof(struct lifreq)) {
510 if_add_interface(lifreq, m, sockfd, lifn.lifn_count);
513 m->list_complete = 1;
514 avahi_interface_monitor_check_relevant(m);
515 avahi_interface_monitor_update_rrs(m, 0);
518 avahi_free(lifc.lifc_buf);
520 avahi_log_info("Network interface enumeration completed.");