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 <sys/socket.h>
30 #include <arpa/inet.h>
32 #include <linux/types.h>
33 #include <linux/netlink.h>
34 #include <linux/rtnetlink.h>
36 #include <linux/if_arp.h>
38 #include <libdaemon/dlog.h>
40 #include <avahi-common/llist.h>
41 #include <avahi-common/malloc.h>
46 static int ifindex = -1;
48 typedef struct Address Address;
52 AVAHI_LLIST_FIELDS(Address, addresses);
55 AVAHI_LLIST_HEAD(Address, addresses) = NULL;
57 int iface_init(int i) {
58 struct sockaddr_nl addr;
60 if ((fd = socket(PF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE)) < 0) {
61 daemon_log(LOG_ERR, "socket(PF_NETLINK): %s", strerror(errno));
65 memset(&addr, 0, sizeof(addr));
66 addr.nl_family = AF_NETLINK;
67 addr.nl_groups = RTMGRP_LINK|RTMGRP_IPV4_IFADDR;
68 addr.nl_pid = getpid();
70 if (bind(fd, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
71 daemon_log(LOG_ERR, "bind(): %s", strerror(errno));
88 static int process_nlmsg(struct nlmsghdr *n) {
91 if (n->nlmsg_type == RTM_NEWLINK || n->nlmsg_type == RTM_DELLINK) {
92 /* A link appeared or was removed */
94 struct ifinfomsg *ifi;
97 if (ifi->ifi_family != AF_UNSPEC || ifi->ifi_index != ifindex)
100 if (n->nlmsg_type == RTM_DELLINK) {
101 daemon_log(LOG_ERR, "Interface vanished.");
105 assert(n->nlmsg_type == RTM_NEWLINK);
107 if ((ifi->ifi_flags & IFF_LOOPBACK) ||
108 (ifi->ifi_flags & IFF_NOARP) ||
109 !(ifi->ifi_flags & IFF_UP) ||
110 ifi->ifi_type != ARPHRD_ETHER) {
111 daemon_log(LOG_ERR, "Interface not suitable.");
115 } else if (n->nlmsg_type == RTM_NEWADDR || n->nlmsg_type == RTM_DELADDR) {
117 /* An address was added or removed */
119 struct rtattr *a = NULL;
120 struct ifaddrmsg *ifa;
122 uint32_t address = 0;
128 if (ifa->ifa_family != AF_INET || ifa->ifa_index != ifindex)
131 l = NLMSG_PAYLOAD(n, sizeof(*ifa));
134 while(RTA_OK(a, l)) {
136 switch(a->rta_type) {
139 assert(RTA_PAYLOAD(a) == 4);
140 memcpy(&address, RTA_DATA(a), sizeof(uint32_t));
147 daemon_log(LOG_INFO, "%s", inet_ntop(AF_INET, &address, buf, sizeof(buf)));
149 if (!address || is_ll_address(address))
152 for (i = addresses; i; i = i->addresses_next)
153 if (i->address == address)
156 if (n->nlmsg_type == RTM_DELADDR && i) {
157 AVAHI_LLIST_REMOVE(Address, addresses, addresses, i);
159 } if (n->nlmsg_type == RTM_NEWADDR && !i) {
160 i = avahi_new(Address, 1);
161 i->address = address;
162 AVAHI_LLIST_PREPEND(Address, addresses, addresses, i);
169 static int process_response(int wait_for_done, unsigned seq) {
176 struct nlmsghdr *p = (struct nlmsghdr *) replybuf;
178 if ((r = recv(fd, replybuf, sizeof(replybuf), 0)) < 0) {
179 daemon_log(LOG_ERR, "recv() failed: %s", strerror(errno));
185 for (; bytes > 0; p = NLMSG_NEXT(p, bytes)) {
187 if (!NLMSG_OK(p, bytes) || bytes < sizeof(struct nlmsghdr) || bytes < p->nlmsg_len) {
188 daemon_log(LOG_ERR, "Netlink packet too small.");
192 if (p->nlmsg_type == NLMSG_DONE && wait_for_done && p->nlmsg_seq == seq)
195 if (p->nlmsg_type == NLMSG_ERROR) {
196 struct nlmsgerr *e = (struct nlmsgerr *) NLMSG_DATA (p);
199 daemon_log(LOG_ERR, "Netlink error: %s", strerror(-e->error));
204 if ((pid_t) p->nlmsg_pid != getpid())
207 if (process_nlmsg(p) < 0)
210 } while (wait_for_done);
215 int iface_get_initial_state(State *state) {
217 struct ifinfomsg *ifi;
218 struct ifaddrmsg *ifa;
225 memset(&req, 0, sizeof(req));
226 n = (struct nlmsghdr*) req;
227 n->nlmsg_len = NLMSG_LENGTH(sizeof(*ifi));
228 n->nlmsg_type = RTM_GETLINK;
230 n->nlmsg_flags = NLM_F_MATCH|NLM_F_REQUEST|NLM_F_ACK;
234 ifi->ifi_family = AF_UNSPEC;
235 ifi->ifi_change = -1;
237 if (send(fd, n, n->nlmsg_len, 0) < 0) {
238 daemon_log(LOG_ERR, "send(): %s", strerror(errno));
242 if (process_response(1, 0) < 0)
245 n->nlmsg_type = RTM_GETADDR;
246 n->nlmsg_len = NLMSG_LENGTH(sizeof(*ifa));
247 n->nlmsg_seq = ++seq;
250 ifa->ifa_family = AF_INET;
251 ifa->ifa_index = ifindex;
253 if (send(fd, n, n->nlmsg_len, 0) < 0) {
254 daemon_log(LOG_ERR, "send(): %s", strerror(errno));
258 if (process_response(1, seq) < 0)
261 *state = addresses ? STATE_SLEEPING : STATE_START;
266 int iface_process(Event *event) {
272 if (process_response(0, 0) < 0)
275 if (b && !!addresses)
276 *event = EVENT_ROUTABLE_ADDR_UNCONFIGURED;
277 else if (!b && addresses)
278 *event = EVENT_ROUTABLE_ADDR_CONFIGURED;
283 void iface_done(void) {
291 while ((a = addresses)) {
292 AVAHI_LLIST_REMOVE(Address, addresses, addresses, a);