X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-core%2Fiface.c;h=d5fe5b134644be589ef1d7e757f58a86d8eb979e;hb=3664c9f0cd50481ecff36b296065418df24620e1;hp=ba232e6f358dfc15d044dedb2d24ed4ab82c0f2d;hpb=1665d23538c5ed2128b6063d8445013f085ad234;p=catta diff --git a/avahi-core/iface.c b/avahi-core/iface.c index ba232e6..d5fe5b1 100644 --- a/avahi-core/iface.c +++ b/avahi-core/iface.c @@ -47,7 +47,9 @@ static void update_address_rr(AvahiInterfaceMonitor *m, AvahiInterfaceAddress *a assert(m); assert(a); - if (avahi_interface_address_relevant(a) && + if (a->interface->announcing && + m->list == LIST_DONE && + avahi_interface_address_relevant(a) && !remove_rrs && m->server->config.publish_addresses && (m->server->state == AVAHI_SERVER_RUNNING || @@ -112,7 +114,8 @@ static void update_hw_interface_rr(AvahiInterfaceMonitor *m, AvahiHwInterface *h for (i = hw->interfaces; i; i = i->by_hardware_next) update_interface_rr(m, i, remove_rrs); - if (!remove_rrs && + if (m->list == LIST_DONE && + !remove_rrs && m->server->config.publish_workstation && (m->server->state == AVAHI_SERVER_RUNNING || m->server->state == AVAHI_SERVER_REGISTERING)) { @@ -302,8 +305,8 @@ static void check_interface_relevant(AvahiInterfaceMonitor *m, AvahiInterface *i b = avahi_interface_relevant(i); - if (b && !i->announcing) { - avahi_log_debug("New relevant interface %s.%i (#%i)", i->hardware->name, i->protocol, i->hardware->index); + if (m->list == LIST_DONE && b && !i->announcing) { + avahi_log_info("New relevant interface %s.%i.", i->hardware->name, i->protocol); if (i->protocol == AVAHI_PROTO_INET) avahi_mdns_mcast_join_ipv4(m->server->fd_ipv4, i->hardware->index); @@ -314,7 +317,7 @@ static void check_interface_relevant(AvahiInterfaceMonitor *m, AvahiInterface *i avahi_announce_interface(m->server, i); avahi_browser_new_interface(m->server, i); } else if (!b && i->announcing) { - avahi_log_debug("Interface %s.%i no longer relevant", i->hardware->name, i->protocol); + avahi_log_info("Interface %s.%i no longer relevant.", i->hardware->name, i->protocol); if (i->protocol == AVAHI_PROTO_INET) avahi_mdns_mcast_leave_ipv4(m->server->fd_ipv4, i->hardware->index); @@ -341,6 +344,14 @@ static void check_hw_interface_relevant(AvahiInterfaceMonitor *m, AvahiHwInterfa check_interface_relevant(m, i); } +static void check_all_interfaces_relevant(AvahiInterfaceMonitor *m) { + AvahiInterface *i; + assert(m); + + for (i = m->interfaces; i; i = i->interface_next) + check_interface_relevant(m, i); +} + static void netlink_callback(AvahiNetlink *nl, struct nlmsghdr *n, void* userdata) { AvahiInterfaceMonitor *m = userdata; @@ -414,8 +425,8 @@ static void netlink_callback(AvahiNetlink *nl, struct nlmsghdr *n, void* userdat a = RTA_NEXT(a, l); } - update_hw_interface_rr(m, hw, 0); check_hw_interface_relevant(m, hw); + update_hw_interface_rr(m, hw, 0); } else if (n->nlmsg_type == RTM_DELLINK) { struct ifinfomsg *ifinfomsg = NLMSG_DATA(n); @@ -427,7 +438,6 @@ static void netlink_callback(AvahiNetlink *nl, struct nlmsghdr *n, void* userdat if (!(hw = avahi_interface_monitor_get_hw_interface(m, (AvahiIfIndex) ifinfomsg->ifi_index))) return; - update_hw_interface_rr(m, hw, 1); free_hw_interface(m, hw, 0); } else if (n->nlmsg_type == RTM_NEWADDR || n->nlmsg_type == RTM_DELADDR) { @@ -491,32 +501,36 @@ static void netlink_callback(AvahiNetlink *nl, struct nlmsghdr *n, void* userdat addr->flags = ifaddrmsg->ifa_flags; addr->scope = ifaddrmsg->ifa_scope; addr->prefix_len = ifaddrmsg->ifa_prefixlen; - - update_address_rr(m, addr, 0); } else { AvahiInterfaceAddress *addr; if (!(addr = get_address(m, i, &raddr))) return; - update_address_rr(m, addr, 1); free_address(m, addr); } check_interface_relevant(m, i); + update_interface_rr(m, i, 0); } else if (n->nlmsg_type == NLMSG_DONE) { if (m->list == LIST_IFACE) { - m->list = LIST_DONE; - if (netlink_list_items(m->netlink, RTM_GETADDR, &m->query_addr_seq) < 0) + if (netlink_list_items(m->netlink, RTM_GETADDR, &m->query_addr_seq) < 0) { avahi_log_warn("NETLINK: Failed to list addrs: %s", strerror(errno)); - else + m->list = LIST_DONE; + } else m->list = LIST_ADDR; - } else { + + } else + /* We're through */ m->list = LIST_DONE; - avahi_log_debug("Network interface enumeration completed"); + + if (m->list == LIST_DONE) { + check_all_interfaces_relevant(m); + avahi_update_host_rrs(m, 0); + avahi_log_info("Network interface enumeration completed."); } } else if (n->nlmsg_type == NLMSG_ERROR && (n->nlmsg_seq == m->query_link_seq || n->nlmsg_seq == m->query_addr_seq)) { @@ -712,12 +726,32 @@ int avahi_interface_relevant(AvahiInterface *i) { relevant_address; } -int avahi_interface_address_relevant(AvahiInterfaceAddress *a) { +int avahi_interface_address_relevant(AvahiInterfaceAddress *a) { + AvahiInterfaceAddress *b; assert(a); - return a->scope == RT_SCOPE_UNIVERSE; -} + /* Publish public IP addresses */ + if (a->scope == RT_SCOPE_UNIVERSE || + a->scope == RT_SCOPE_SITE) + return 1; + + if (a->scope == RT_SCOPE_LINK) { + + /* Publish link local IP addresses if they are the only ones on the link */ + for (b = a->interface->addresses; b; b = b->address_next) { + if (b == a) + continue; + + if (b->scope == RT_SCOPE_UNIVERSE || + b->scope == RT_SCOPE_SITE) + return 0; + } + + return 1; + } + return 0; +} int avahi_interface_match(AvahiInterface *i, AvahiIfIndex idx, AvahiProtocol protocol) { assert(i);