X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fnetifd.git;a=blobdiff_plain;f=system-linux.c;h=f6e1058fa85bccf5d8d5daa9dbd8294e2dd878b7;hp=1dbb651f747f47d805fce4a5e9150f52bb79921a;hb=273eb40f725de67011c092d2ed9f07a2d7f84ac3;hpb=78637a9ca3fd717f347d9b44b3b8ac9cafe6db57

diff --git a/system-linux.c b/system-linux.c
index 1dbb651..f6e1058 100644
--- a/system-linux.c
+++ b/system-linux.c
@@ -5,12 +5,11 @@
 #include <linux/sockios.h>
 #include <linux/if_vlan.h>
 
-#include <stddef.h>
 #include <string.h>
 #include <fcntl.h>
-#include <errno.h>
 
 #include <netlink/msg.h>
+#include <libubox/uloop.h>
 
 #include "netifd.h"
 #include "device.h"
@@ -18,24 +17,94 @@
 
 static int sock_ioctl = -1;
 static struct nl_sock *sock_rtnl = NULL;
+static struct nl_sock *sock_rtnl_event = NULL;
 
-static void __init system_init(void)
+static void handler_rtnl_event(struct uloop_fd *u, unsigned int events);
+static int cb_rtnl_event(struct nl_msg *msg, void *arg);
+static struct uloop_fd rtnl_event = {.cb = handler_rtnl_event};
+static struct nl_cb *nl_cb_rtnl_event;
+
+int system_init(void)
 {
 	sock_ioctl = socket(AF_LOCAL, SOCK_DGRAM, 0);
 	fcntl(sock_ioctl, F_SETFD, fcntl(sock_ioctl, F_GETFD) | FD_CLOEXEC);
 
+	// Prepare socket for routing / address control
 	if ((sock_rtnl = nl_socket_alloc())) {
 		if (nl_connect(sock_rtnl, NETLINK_ROUTE)) {
 			nl_socket_free(sock_rtnl);
 			sock_rtnl = NULL;
 		}
 	}
+
+	// Prepare socket for link events
+	if ((nl_cb_rtnl_event = nl_cb_alloc(NL_CB_DEFAULT)))
+		nl_cb_set(nl_cb_rtnl_event, NL_CB_VALID, NL_CB_CUSTOM,
+							cb_rtnl_event, NULL);
+
+	if (nl_cb_rtnl_event && (sock_rtnl_event = nl_socket_alloc())) {
+		if (nl_connect(sock_rtnl_event, NETLINK_ROUTE)) {
+			nl_socket_free(sock_rtnl_event);
+			sock_rtnl_event = NULL;
+		}
+		// Receive network link events form kernel
+		nl_socket_add_membership(sock_rtnl_event, RTNLGRP_LINK);
+
+		// Synthesize initial link messages
+		struct nl_msg *m = nlmsg_alloc_simple(RTM_GETLINK, NLM_F_DUMP);
+		if (m && nlmsg_reserve(m, sizeof(struct ifinfomsg), 0)) {
+			nl_send_auto_complete(sock_rtnl_event, m);
+			nlmsg_free(m);
+		}
+
+#ifdef NLA_PUT_DATA
+		rtnl_event.fd = nl_socket_get_fd(sock_rtnl_event);
+#else
+		rtnl_event.fd = sock_rtnl_event->s_fd; // libnl-tiny hack...
+#endif
+		uloop_fd_add(&rtnl_event, ULOOP_READ | ULOOP_EDGE_TRIGGER);
+	}
+
+	return -(sock_ioctl < 0 || !sock_rtnl);
+}
+
+// If socket is ready for reading parse netlink events
+static void handler_rtnl_event(struct uloop_fd *u, unsigned int events)
+{
+	nl_recvmsgs(sock_rtnl_event, nl_cb_rtnl_event);
+}
+
+// Evaluate netlink messages
+static int cb_rtnl_event(struct nl_msg *msg, void *arg)
+{
+	struct nlmsghdr *nh = nlmsg_hdr(msg);
+	struct ifinfomsg *ifi = NLMSG_DATA(nh);
+	struct nlattr *nla[__IFLA_MAX];
+
+	if (nh->nlmsg_type != RTM_DELLINK && nh->nlmsg_type != RTM_NEWLINK)
+		goto out;
+
+	nlmsg_parse(nh, sizeof(*ifi), nla, __IFLA_MAX - 1, NULL);
+	if (!nla[IFLA_IFNAME])
+		goto out;
+
+	struct device *dev = device_get(RTA_DATA(nla[IFLA_IFNAME]), false);
+	if (!dev)
+		goto out;
+
+	dev->ifindex = ifi->ifi_index;
+	device_set_present(dev, (nh->nlmsg_type == RTM_NEWLINK));
+
+out:
+	return 0;
 }
 
 static int system_rtnl_call(struct nl_msg *msg)
 {
-	return -!!(!sock_rtnl || nl_send_auto_complete(sock_rtnl, msg)
-					|| nl_wait_for_ack(sock_rtnl));
+	int s = -(nl_send_auto_complete(sock_rtnl, msg)
+			|| nl_wait_for_ack(sock_rtnl));
+	nlmsg_free(msg);
+	return s;
 }
 
 int system_bridge_addbr(struct device *bridge)
@@ -134,7 +203,7 @@ static int system_addr(struct device *dev, struct device_addr *addr, int cmd)
 		return -1;
 
 	nlmsg_append(msg, &ifa, sizeof(ifa), 0);
-	nla_put(msg, IFA_ADDRESS, alen, &addr->addr);
+	nla_put(msg, IFA_LOCAL, alen, &addr->addr);
 	return system_rtnl_call(msg);
 }