X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-core%2Fiface-pfroute.c;h=6d7de60c9869785d86b256c38af798d6bc2bd5e2;hb=2afb248985218ecb5c3b105ff04a986a506b59f9;hp=17b80d4bf9b7a3afa86e1e023c560d28f0f67695;hpb=8b22b43669d936ab75914732209f93a0b7ee81f4;p=catta diff --git a/avahi-core/iface-pfroute.c b/avahi-core/iface-pfroute.c index 17b80d4..6d7de60 100644 --- a/avahi-core/iface-pfroute.c +++ b/avahi-core/iface-pfroute.c @@ -31,6 +31,7 @@ #include #include +#include #include #include @@ -87,8 +88,8 @@ static void rtm_info(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m) hw->mtu = ifm->ifm_data.ifi_mtu; hw->mac_address_size = sdl->sdl_alen; - if (hw->mac_address_size > AVAHI_MAX_MAC_ADDRESS) - hw->mac_address_size = AVAHI_MAX_MAC_ADDRESS; + if (hw->mac_address_size > AVAHI_MAC_ADDRESS_MAX) + hw->mac_address_size = AVAHI_MAC_ADDRESS_MAX; memcpy(hw->mac_address, sdl->sdl_data + sdl->sdl_nlen, hw->mac_address_size); @@ -118,6 +119,11 @@ static void rtm_addr(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m) int prefixlen = 0; struct sockaddr *sa =NULL; +#if defined(__NetBSD__) || defined(__OpenBSD__) + if(((struct sockaddr *)cp)->sa_family == AF_UNSPEC) + ((struct sockaddr *)cp)->sa_family = AF_INET; +#endif + if(((struct sockaddr *)cp)->sa_family != AF_INET && ((struct sockaddr *)cp)->sa_family != AF_INET6) return; @@ -145,7 +151,18 @@ static void rtm_addr(struct rt_msghdr *rtm, AvahiInterfaceMonitor *m) default: break; } + break; case AF_INET6: + switch (1<sin6_addr.s6_addr); + break; + case RTA_IFA: + memcpy(raddr.data.data, &((struct sockaddr_in6 *)sa)->sin6_addr, sizeof(struct in6_addr)); + raddr_valid = 1; + default: + break; + } break; default: break; @@ -219,15 +236,12 @@ static void socket_event(AvahiWatch *w, int fd, AvahiWatchEvent event,void *user assert(fd == nl->fd); do { - time_t now = time(NULL); if((bytes = recv(nl->fd, msg, 2048, MSG_DONTWAIT)) < 0) { if (errno == EAGAIN || errno == EINTR) return; avahi_log_error(__FILE__": recv() failed: %s", strerror(errno)); return; } - - avahi_log_debug("socket_event: got message of size %d on %s", (int)bytes, ctime(&now)); parse_rtmsg((struct rt_msghdr *)msg, bytes ,m); } while (bytes > 0); @@ -265,7 +279,7 @@ fail: if (m->osdep.pfroute) { if (m->osdep.pfroute->watch) - m->osdep.pfroute->poll_api->watch_free(m->osdep.pfroute->watch); + m->server->poll_api->watch_free(m->osdep.pfroute->watch); if (fd >= 0) close(fd); @@ -281,7 +295,7 @@ void avahi_interface_monitor_free_osdep(AvahiInterfaceMonitor *m) { if (m->osdep.pfroute) { if (m->osdep.pfroute->watch) - m->osdep.pfroute->poll_api->watch_free(m->osdep.pfroute->watch); + m->server->poll_api->watch_free(m->osdep.pfroute->watch); if (m->osdep.pfroute->fd >= 0) close(m->osdep.pfroute->fd); @@ -307,11 +321,20 @@ void avahi_interface_monitor_sync(AvahiInterfaceMonitor *m) { mib[4] = NET_RT_IFLIST; mib[5] = 0; /* no flags */ if (sysctl(mib, 6, NULL, &needed, NULL, 0) < 0) - return; + { + avahi_log_error("sysctl failed: %s", strerror(errno)); + avahi_log_error("route-sysctl-estimate"); + return; + } if ((buf = avahi_malloc(needed)) == NULL) - return; + { + avahi_log_error("malloc failed in avahi_interface_monitor_sync"); + return; + } if (sysctl(mib, 6, buf, &needed, NULL, 0) < 0) { + avahi_log_warn("sysctl failed: %s", strerror(errno)); if (errno == ENOMEM && count++ < 10) { + avahi_log_warn("Routing table grew, retrying"); sleep(1); avahi_free(buf); goto retry2;