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>
43 #include <linux/if_addr.h>
45 #define IFLA_RTA(r) ((struct rtattr*)(((char*)(r)) + NLMSG_ALIGN(sizeof(struct ifinfomsg))))
49 #define IFA_RTA(r) ((struct rtattr*)(((char*)(r)) + NLMSG_ALIGN(sizeof(struct ifaddrmsg))))
55 static int ifindex = -1;
57 typedef struct Address Address;
61 AVAHI_LLIST_FIELDS(Address, addresses);
64 AVAHI_LLIST_HEAD(Address, addresses) = NULL;
66 int iface_init(int i) {
67 struct sockaddr_nl addr;
69 if ((fd = socket(PF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE)) < 0) {
70 daemon_log(LOG_ERR, "socket(PF_NETLINK): %s", strerror(errno));
74 memset(&addr, 0, sizeof(addr));
75 addr.nl_family = AF_NETLINK;
76 addr.nl_groups = RTMGRP_LINK|RTMGRP_IPV4_IFADDR;
77 addr.nl_pid = getpid();
79 if (bind(fd, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
80 daemon_log(LOG_ERR, "bind(): %s", strerror(errno));
97 static int process_nlmsg(struct nlmsghdr *n) {
100 if (n->nlmsg_type == RTM_NEWLINK || n->nlmsg_type == RTM_DELLINK) {
101 /* A link appeared or was removed */
103 struct ifinfomsg *ifi;
106 if (ifi->ifi_family != AF_UNSPEC || ifi->ifi_index != ifindex)
109 if (n->nlmsg_type == RTM_DELLINK) {
110 daemon_log(LOG_ERR, "Interface vanished.");
114 assert(n->nlmsg_type == RTM_NEWLINK);
116 if ((ifi->ifi_flags & IFF_LOOPBACK) ||
117 (ifi->ifi_flags & IFF_NOARP) ||
118 ifi->ifi_type != ARPHRD_ETHER) {
119 daemon_log(LOG_ERR, "Interface not suitable.");
123 } else if (n->nlmsg_type == RTM_NEWADDR || n->nlmsg_type == RTM_DELADDR) {
125 /* An address was added or removed */
127 struct rtattr *a = NULL;
128 struct ifaddrmsg *ifa;
130 uint32_t address = 0;
135 if (ifa->ifa_family != AF_INET || ifa->ifa_index != ifindex)
138 l = NLMSG_PAYLOAD(n, sizeof(*ifa));
141 while(RTA_OK(a, l)) {
143 switch(a->rta_type) {
146 assert(RTA_PAYLOAD(a) == 4);
147 memcpy(&address, RTA_DATA(a), sizeof(uint32_t));
154 if (!address || is_ll_address(address))
157 for (i = addresses; i; i = i->addresses_next)
158 if (i->address == address)
161 if (n->nlmsg_type == RTM_DELADDR && i) {
162 AVAHI_LLIST_REMOVE(Address, addresses, addresses, i);
164 } if (n->nlmsg_type == RTM_NEWADDR && !i) {
165 i = avahi_new(Address, 1);
166 i->address = address;
167 AVAHI_LLIST_PREPEND(Address, addresses, addresses, i);
174 static int process_response(int wait_for_done, unsigned seq) {
181 struct nlmsghdr *p = (struct nlmsghdr *) replybuf;
183 if ((r = recv(fd, replybuf, sizeof(replybuf), 0)) < 0) {
184 daemon_log(LOG_ERR, "recv() failed: %s", strerror(errno));
190 for (; bytes > 0; p = NLMSG_NEXT(p, bytes)) {
192 if (!NLMSG_OK(p, bytes) || bytes < sizeof(struct nlmsghdr) || bytes < p->nlmsg_len) {
193 daemon_log(LOG_ERR, "Netlink packet too small.");
197 if (p->nlmsg_type == NLMSG_DONE && wait_for_done && p->nlmsg_seq == seq && (pid_t) p->nlmsg_pid == getpid())
200 if (p->nlmsg_type == NLMSG_ERROR) {
201 struct nlmsgerr *e = (struct nlmsgerr *) NLMSG_DATA (p);
204 daemon_log(LOG_ERR, "Netlink error: %s", strerror(-e->error));
209 if (process_nlmsg(p) < 0)
212 } while (wait_for_done);
217 int iface_get_initial_state(State *state) {
219 struct ifinfomsg *ifi;
220 struct ifaddrmsg *ifa;
227 memset(&req, 0, sizeof(req));
228 n = (struct nlmsghdr*) req;
229 n->nlmsg_len = NLMSG_LENGTH(sizeof(*ifi));
230 n->nlmsg_type = RTM_GETLINK;
232 n->nlmsg_flags = NLM_F_MATCH|NLM_F_REQUEST|NLM_F_ACK;
236 ifi->ifi_family = AF_UNSPEC;
237 ifi->ifi_change = -1;
239 if (send(fd, n, n->nlmsg_len, 0) < 0) {
240 daemon_log(LOG_ERR, "send(): %s", strerror(errno));
244 if (process_response(1, 0) < 0)
247 n->nlmsg_type = RTM_GETADDR;
248 n->nlmsg_len = NLMSG_LENGTH(sizeof(*ifa));
249 n->nlmsg_seq = ++seq;
252 ifa->ifa_family = AF_INET;
253 ifa->ifa_index = ifindex;
255 if (send(fd, n, n->nlmsg_len, 0) < 0) {
256 daemon_log(LOG_ERR, "send(): %s", strerror(errno));
260 if (process_response(1, seq) < 0)
263 *state = addresses ? STATE_SLEEPING : STATE_START;
268 int iface_process(Event *event) {
274 if (process_response(0, 0) < 0)
278 *event = EVENT_ROUTABLE_ADDR_UNCONFIGURED;
279 else if (!b && addresses)
280 *event = EVENT_ROUTABLE_ADDR_CONFIGURED;
285 void iface_done(void) {
293 while ((a = addresses)) {
294 AVAHI_LLIST_REMOVE(Address, addresses, addresses, a);