X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fodhcpd.git;a=blobdiff_plain;f=src%2Fndp.c;h=f9e04051c73c3018c3b9197a51e2ab2148f88b3c;hp=7f63f96099c1b34c8cc22459074e4156ad4f3d8b;hb=c8ac572154981ca833dad92d7ee7aa62b88087cc;hpb=0ff39e3a124125914d2142d7127eab3a485ab34a

diff --git a/src/ndp.c b/src/ndp.c
index 7f63f96..f9e0405 100644
--- a/src/ndp.c
+++ b/src/ndp.c
@@ -38,10 +38,11 @@ static void handle_solicit(void *addr, void *data, size_t len,
 		struct interface *iface, void *dest);
 static void handle_rtnetlink(void *addr, void *data, size_t len,
 		struct interface *iface, void *dest);
+static void catch_rtnetlink(int error);
 
 static uint32_t rtnl_seqid = 0;
 static int ping_socket = -1;
-static struct odhcpd_event rtnl_event = {{.fd = -1}, handle_rtnetlink};
+static struct odhcpd_event rtnl_event = {{.fd = -1}, handle_rtnetlink, catch_rtnetlink};
 
 
 // Filter ICMPv6 messages of type neighbor soliciation
@@ -60,10 +61,15 @@ static const struct sock_fprog bpf_prog = {sizeof(bpf) / sizeof(*bpf), bpf};
 // Initialize NDP-proxy
 int init_ndp(void)
 {
+	int val = 256 * 1024;
+
 	// Setup netlink socket
 	if ((rtnl_event.uloop.fd = odhcpd_open_rtnl()) < 0)
 		return -1;
 
+	if (setsockopt(rtnl_event.uloop.fd, SOL_SOCKET, SO_RCVBUF, &val, sizeof(val)))
+		setsockopt(rtnl_event.uloop.fd, SOL_SOCKET, SO_RCVBUFFORCE, &val, sizeof(val));
+
 	// Receive netlink neighbor and ip-address events
 	uint32_t group = RTNLGRP_IPV6_IFADDR;
 	setsockopt(rtnl_event.uloop.fd, SOL_NETLINK,
@@ -81,7 +87,7 @@ int init_ndp(void)
 			return -1;
 	}
 
-	int val = 2;
+	val = 2;
 	setsockopt(ping_socket, IPPROTO_RAW, IPV6_CHECKSUM, &val, sizeof(val));
 
 	// This is required by RFC 4861
@@ -352,11 +358,13 @@ static void handle_rtnetlink(_unused void *addr, void *data, size_t len,
 				|| ndm->ndm_family != AF_INET6)
 			continue;
 
-		// Inform about a change in default route
-		if (is_route && rtm->rtm_dst_len == 0)
-			raise(SIGUSR1);
-		else if (is_route)
+		if (is_route) {
+			// Inform about a change in default route
+			if (rtm->rtm_dst_len == 0)
+				raise(SIGUSR1);
+
 			continue;
+		}
 
 		// Data to retrieve
 		size_t rta_offset = (is_addr) ?	sizeof(struct ifaddrmsg) : sizeof(*ndm);
@@ -491,3 +499,18 @@ static void handle_rtnetlink(_unused void *addr, void *data, size_t len,
 	if (dump_neigh)
 		dump_neigh_table(false);
 }
+
+static void catch_rtnetlink(int error)
+{
+	if (error == ENOBUFS) {
+		struct {
+			struct nlmsghdr nh;
+			struct ifaddrmsg ifa;
+		} req2 = {
+			{sizeof(req2), RTM_GETADDR, NLM_F_REQUEST | NLM_F_DUMP,
+					++rtnl_seqid, 0},
+			{.ifa_family = AF_INET6}
+		};
+		send(rtnl_event.uloop.fd, &req2, sizeof(req2), MSG_DONTWAIT);
+	}
+}