rtadvd.c revision 1.11 1 1.11 itojun /* $NetBSD: rtadvd.c,v 1.11 2001/01/15 06:14:05 itojun Exp $ */
2 1.11 itojun /* $KAME: rtadvd.c,v 1.47 2001/01/15 05:50:25 itojun Exp $ */
3 1.2 itojun
4 1.1 itojun /*
5 1.1 itojun * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
6 1.1 itojun * All rights reserved.
7 1.1 itojun *
8 1.1 itojun * Redistribution and use in source and binary forms, with or without
9 1.1 itojun * modification, are permitted provided that the following conditions
10 1.1 itojun * are met:
11 1.1 itojun * 1. Redistributions of source code must retain the above copyright
12 1.1 itojun * notice, this list of conditions and the following disclaimer.
13 1.1 itojun * 2. Redistributions in binary form must reproduce the above copyright
14 1.1 itojun * notice, this list of conditions and the following disclaimer in the
15 1.1 itojun * documentation and/or other materials provided with the distribution.
16 1.1 itojun * 3. Neither the name of the project nor the names of its contributors
17 1.1 itojun * may be used to endorse or promote products derived from this software
18 1.1 itojun * without specific prior written permission.
19 1.1 itojun *
20 1.1 itojun * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
21 1.1 itojun * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22 1.1 itojun * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23 1.1 itojun * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
24 1.1 itojun * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25 1.1 itojun * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26 1.1 itojun * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27 1.1 itojun * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28 1.1 itojun * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29 1.1 itojun * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30 1.1 itojun * SUCH DAMAGE.
31 1.1 itojun */
32 1.1 itojun
33 1.1 itojun #include <sys/param.h>
34 1.1 itojun #include <sys/socket.h>
35 1.1 itojun #include <sys/uio.h>
36 1.1 itojun #include <sys/time.h>
37 1.11 itojun #include <sys/queue.h>
38 1.1 itojun
39 1.1 itojun #include <net/if.h>
40 1.1 itojun #include <net/route.h>
41 1.1 itojun #include <net/if_dl.h>
42 1.1 itojun #include <netinet/in.h>
43 1.1 itojun #include <netinet/ip6.h>
44 1.1 itojun #include <netinet6/ip6_var.h>
45 1.1 itojun #include <netinet/icmp6.h>
46 1.1 itojun
47 1.1 itojun #include <arpa/inet.h>
48 1.1 itojun
49 1.1 itojun #include <time.h>
50 1.1 itojun #include <unistd.h>
51 1.1 itojun #include <stdio.h>
52 1.6 itojun #include <stdlib.h>
53 1.1 itojun #include <err.h>
54 1.1 itojun #include <errno.h>
55 1.1 itojun #include <string.h>
56 1.1 itojun #include <stdlib.h>
57 1.1 itojun #include <syslog.h>
58 1.1 itojun #include "rtadvd.h"
59 1.1 itojun #include "rrenum.h"
60 1.1 itojun #include "advcap.h"
61 1.1 itojun #include "timer.h"
62 1.1 itojun #include "if.h"
63 1.1 itojun #include "config.h"
64 1.9 itojun #include "dump.h"
65 1.1 itojun
66 1.1 itojun struct msghdr rcvmhdr;
67 1.6 itojun static u_char *rcvcmsgbuf;
68 1.6 itojun static size_t rcvcmsgbuflen;
69 1.6 itojun static u_char *sndcmsgbuf = NULL;
70 1.6 itojun static size_t sndcmsgbuflen;
71 1.9 itojun static int do_dump;
72 1.11 itojun static int do_die;
73 1.1 itojun struct msghdr sndmhdr;
74 1.1 itojun struct iovec rcviov[2];
75 1.1 itojun struct iovec sndiov[2];
76 1.1 itojun struct sockaddr_in6 from;
77 1.1 itojun struct sockaddr_in6 sin6_allnodes = {sizeof(sin6_allnodes), AF_INET6};
78 1.11 itojun struct in6_addr in6a_site_allrouters;
79 1.9 itojun static char *dumpfilename = "/var/run/rtadvd.dump"; /* XXX: should be configurable */
80 1.9 itojun static char *pidfilename = "/var/run/rtadvd.pid"; /* should be configurable */
81 1.11 itojun static char *mcastif;
82 1.1 itojun int sock, rtsock;
83 1.7 itojun #ifdef MIP6
84 1.7 itojun int mobileip6 = 0;
85 1.7 itojun #endif
86 1.5 itojun int accept_rr = 0;
87 1.1 itojun int dflag = 0, sflag = 0;
88 1.1 itojun
89 1.1 itojun u_char *conffile = NULL;
90 1.1 itojun
91 1.1 itojun struct rainfo *ralist = NULL;
92 1.1 itojun struct nd_optlist {
93 1.1 itojun struct nd_optlist *next;
94 1.1 itojun struct nd_opt_hdr *opt;
95 1.1 itojun };
96 1.1 itojun union nd_opts {
97 1.1 itojun struct nd_opt_hdr *nd_opt_array[7];
98 1.1 itojun struct {
99 1.1 itojun struct nd_opt_hdr *zero;
100 1.1 itojun struct nd_opt_hdr *src_lladdr;
101 1.1 itojun struct nd_opt_hdr *tgt_lladdr;
102 1.1 itojun struct nd_opt_prefix_info *pi;
103 1.1 itojun struct nd_opt_rd_hdr *rh;
104 1.1 itojun struct nd_opt_mtu *mtu;
105 1.1 itojun struct nd_optlist *list;
106 1.1 itojun } nd_opt_each;
107 1.1 itojun };
108 1.1 itojun #define nd_opts_src_lladdr nd_opt_each.src_lladdr
109 1.1 itojun #define nd_opts_tgt_lladdr nd_opt_each.tgt_lladdr
110 1.1 itojun #define nd_opts_pi nd_opt_each.pi
111 1.1 itojun #define nd_opts_rh nd_opt_each.rh
112 1.1 itojun #define nd_opts_mtu nd_opt_each.mtu
113 1.1 itojun #define nd_opts_list nd_opt_each.list
114 1.1 itojun
115 1.1 itojun #define NDOPT_FLAG_SRCLINKADDR 0x1
116 1.1 itojun #define NDOPT_FLAG_TGTLINKADDR 0x2
117 1.1 itojun #define NDOPT_FLAG_PREFIXINFO 0x4
118 1.1 itojun #define NDOPT_FLAG_RDHDR 0x8
119 1.1 itojun #define NDOPT_FLAG_MTU 0x10
120 1.1 itojun
121 1.1 itojun u_int32_t ndopt_flags[] = {
122 1.1 itojun 0, NDOPT_FLAG_SRCLINKADDR, NDOPT_FLAG_TGTLINKADDR,
123 1.1 itojun NDOPT_FLAG_PREFIXINFO, NDOPT_FLAG_RDHDR, NDOPT_FLAG_MTU
124 1.1 itojun };
125 1.1 itojun
126 1.1 itojun int main __P((int, char *[]));
127 1.11 itojun static void set_die __P((int));
128 1.11 itojun static void die __P((void));
129 1.1 itojun static void sock_open __P((void));
130 1.1 itojun static void rtsock_open __P((void));
131 1.1 itojun static void rtadvd_input __P((void));
132 1.1 itojun static void rs_input __P((int, struct nd_router_solicit *,
133 1.1 itojun struct in6_pktinfo *, struct sockaddr_in6 *));
134 1.1 itojun static void ra_input __P((int, struct nd_router_advert *,
135 1.1 itojun struct in6_pktinfo *, struct sockaddr_in6 *));
136 1.9 itojun static int prefix_check __P((struct nd_opt_prefix_info *, struct rainfo *,
137 1.9 itojun struct sockaddr_in6 *));
138 1.1 itojun static int nd6_options __P((struct nd_opt_hdr *, int,
139 1.1 itojun union nd_opts *, u_int32_t));
140 1.1 itojun static void free_ndopts __P((union nd_opts *));
141 1.1 itojun static void ra_output __P((struct rainfo *));
142 1.1 itojun static void rtmsg_input __P((void));
143 1.9 itojun static void rtadvd_set_dump_file __P((void));
144 1.9 itojun
145 1.1 itojun struct prefix *find_prefix __P((struct rainfo *, struct in6_addr *, int));
146 1.1 itojun
147 1.1 itojun int
148 1.1 itojun main(argc, argv)
149 1.1 itojun int argc;
150 1.1 itojun char *argv[];
151 1.1 itojun {
152 1.1 itojun fd_set fdset;
153 1.1 itojun int maxfd = 0;
154 1.1 itojun struct timeval *timeout;
155 1.1 itojun int i, ch;
156 1.1 itojun int fflag = 0;
157 1.9 itojun FILE *pidfp;
158 1.9 itojun pid_t pid;
159 1.1 itojun
160 1.9 itojun openlog("rtadvd", LOG_NDELAY|LOG_PID, LOG_DAEMON);
161 1.1 itojun
162 1.1 itojun /* get command line options and arguments */
163 1.7 itojun #ifdef MIP6
164 1.11 itojun #define OPTIONS "c:dDfM:mRs"
165 1.7 itojun #else
166 1.11 itojun #define OPTIONS "c:dDfM:Rs"
167 1.7 itojun #endif
168 1.7 itojun while ((ch = getopt(argc, argv, OPTIONS)) != -1) {
169 1.7 itojun #undef OPTIONS
170 1.1 itojun switch(ch) {
171 1.1 itojun case 'c':
172 1.1 itojun conffile = optarg;
173 1.1 itojun break;
174 1.1 itojun case 'd':
175 1.1 itojun dflag = 1;
176 1.1 itojun break;
177 1.1 itojun case 'D':
178 1.1 itojun dflag = 2;
179 1.1 itojun break;
180 1.1 itojun case 'f':
181 1.1 itojun fflag = 1;
182 1.1 itojun break;
183 1.11 itojun case 'M':
184 1.11 itojun mcastif = optarg;
185 1.11 itojun break;
186 1.7 itojun #ifdef MIP6
187 1.7 itojun case 'm':
188 1.7 itojun mobileip6 = 1;
189 1.7 itojun break;
190 1.7 itojun #endif
191 1.5 itojun case 'R':
192 1.5 itojun accept_rr = 1;
193 1.5 itojun break;
194 1.1 itojun case 's':
195 1.1 itojun sflag = 1;
196 1.5 itojun break;
197 1.1 itojun }
198 1.1 itojun }
199 1.1 itojun argc -= optind;
200 1.1 itojun argv += optind;
201 1.1 itojun if (argc == 0) {
202 1.1 itojun fprintf(stderr,
203 1.7 itojun #ifdef MIP6
204 1.11 itojun "usage: rtadvd [-dDfMmRs] [-c conffile] "
205 1.7 itojun #else
206 1.11 itojun "usage: rtadvd [-dDfMRs] [-c conffile] "
207 1.7 itojun #endif
208 1.1 itojun "interfaces...\n");
209 1.1 itojun exit(1);
210 1.1 itojun }
211 1.1 itojun
212 1.1 itojun /* set log level */
213 1.1 itojun if (dflag == 0)
214 1.1 itojun (void)setlogmask(LOG_UPTO(LOG_ERR));
215 1.1 itojun if (dflag == 1)
216 1.1 itojun (void)setlogmask(LOG_UPTO(LOG_INFO));
217 1.1 itojun
218 1.1 itojun /* timer initialization */
219 1.1 itojun rtadvd_timer_init();
220 1.1 itojun
221 1.1 itojun /* random value initialization */
222 1.1 itojun srandom((u_long)time(NULL));
223 1.1 itojun
224 1.1 itojun /* get iflist block from kernel */
225 1.1 itojun init_iflist();
226 1.1 itojun
227 1.1 itojun while (argc--)
228 1.1 itojun getconfig(*argv++);
229 1.1 itojun
230 1.3 itojun if (inet_pton(AF_INET6, ALLNODES, &sin6_allnodes.sin6_addr) != 1) {
231 1.3 itojun fprintf(stderr, "fatal: inet_pton failed\n");
232 1.3 itojun exit(1);
233 1.3 itojun }
234 1.1 itojun sock_open();
235 1.1 itojun
236 1.1 itojun if (!fflag)
237 1.1 itojun daemon(1, 0);
238 1.1 itojun
239 1.9 itojun /* record the current PID */
240 1.9 itojun pid = getpid();
241 1.9 itojun if ((pidfp = fopen(pidfilename, "w")) == NULL)
242 1.9 itojun syslog(LOG_ERR,
243 1.9 itojun "<%s> failed to open a log file(%s), run anyway.",
244 1.9 itojun __FUNCTION__, pidfilename);
245 1.9 itojun else {
246 1.9 itojun fprintf(pidfp, "%d\n", pid);
247 1.9 itojun fclose(pidfp);
248 1.9 itojun }
249 1.9 itojun
250 1.1 itojun FD_ZERO(&fdset);
251 1.1 itojun FD_SET(sock, &fdset);
252 1.1 itojun maxfd = sock;
253 1.10 itojun rtsock_open();
254 1.10 itojun FD_SET(rtsock, &fdset);
255 1.10 itojun if (rtsock > sock)
256 1.11 itojun maxfd = rtsock;
257 1.1 itojun
258 1.11 itojun signal(SIGTERM, (void *)set_die);
259 1.9 itojun signal(SIGUSR1, (void *)rtadvd_set_dump_file);
260 1.5 itojun
261 1.1 itojun while (1) {
262 1.1 itojun struct fd_set select_fd = fdset; /* reinitialize */
263 1.1 itojun
264 1.9 itojun if (do_dump) { /* SIGUSR1 */
265 1.9 itojun do_dump = 0;
266 1.9 itojun rtadvd_dump_file(dumpfilename);
267 1.9 itojun }
268 1.9 itojun
269 1.11 itojun if (do_die) {
270 1.11 itojun die();
271 1.11 itojun /*NOTREACHED*/
272 1.11 itojun }
273 1.11 itojun
274 1.1 itojun /* timer expiration check and reset the timer */
275 1.1 itojun timeout = rtadvd_check_timer();
276 1.1 itojun
277 1.10 itojun if (timeout != NULL) {
278 1.10 itojun syslog(LOG_DEBUG,
279 1.10 itojun "<%s> set timer to %ld:%ld. waiting for "
280 1.10 itojun "inputs or timeout",
281 1.10 itojun __FUNCTION__,
282 1.10 itojun (long int)timeout->tv_sec,
283 1.10 itojun (long int)timeout->tv_usec);
284 1.10 itojun } else {
285 1.10 itojun syslog(LOG_DEBUG,
286 1.10 itojun "<%s> there's no timer. waiting for inputs",
287 1.10 itojun __FUNCTION__);
288 1.10 itojun }
289 1.1 itojun
290 1.1 itojun if ((i = select(maxfd + 1, &select_fd,
291 1.9 itojun NULL, NULL, timeout)) < 0) {
292 1.9 itojun /* EINTR would occur upon SIGUSR1 for status dump */
293 1.9 itojun if (errno != EINTR)
294 1.9 itojun syslog(LOG_ERR, "<%s> select: %s",
295 1.9 itojun __FUNCTION__, strerror(errno));
296 1.1 itojun continue;
297 1.1 itojun }
298 1.1 itojun if (i == 0) /* timeout */
299 1.1 itojun continue;
300 1.1 itojun if (sflag == 0 && FD_ISSET(rtsock, &select_fd))
301 1.1 itojun rtmsg_input();
302 1.1 itojun if (FD_ISSET(sock, &select_fd))
303 1.1 itojun rtadvd_input();
304 1.1 itojun }
305 1.1 itojun exit(0); /* NOTREACHED */
306 1.1 itojun }
307 1.1 itojun
308 1.1 itojun static void
309 1.9 itojun rtadvd_set_dump_file()
310 1.9 itojun {
311 1.9 itojun do_dump = 1;
312 1.9 itojun }
313 1.9 itojun
314 1.9 itojun static void
315 1.11 itojun set_die(sig)
316 1.5 itojun int sig;
317 1.5 itojun {
318 1.11 itojun do_die = 1;
319 1.11 itojun }
320 1.11 itojun
321 1.11 itojun static void
322 1.11 itojun die()
323 1.11 itojun {
324 1.5 itojun struct rainfo *ra;
325 1.5 itojun int i;
326 1.5 itojun const int retrans = MAX_FINAL_RTR_ADVERTISEMENTS;
327 1.5 itojun
328 1.5 itojun if (dflag > 1) {
329 1.5 itojun syslog(LOG_DEBUG, "<%s> cease to be an advertising router\n",
330 1.5 itojun __FUNCTION__);
331 1.5 itojun }
332 1.5 itojun
333 1.5 itojun for (ra = ralist; ra; ra = ra->next) {
334 1.5 itojun ra->lifetime = 0;
335 1.5 itojun make_packet(ra);
336 1.5 itojun }
337 1.5 itojun for (i = 0; i < retrans; i++) {
338 1.5 itojun for (ra = ralist; ra; ra = ra->next)
339 1.5 itojun ra_output(ra);
340 1.5 itojun sleep(MIN_DELAY_BETWEEN_RAS);
341 1.5 itojun }
342 1.5 itojun exit(0);
343 1.5 itojun /*NOTREACHED*/
344 1.5 itojun }
345 1.5 itojun
346 1.5 itojun static void
347 1.1 itojun rtmsg_input()
348 1.1 itojun {
349 1.9 itojun int n, type, ifindex = 0, plen;
350 1.2 itojun size_t len;
351 1.1 itojun char msg[2048], *next, *lim;
352 1.11 itojun u_char ifname[IF_NAMESIZE];
353 1.1 itojun struct prefix *prefix;
354 1.1 itojun struct rainfo *rai;
355 1.1 itojun struct in6_addr *addr;
356 1.1 itojun char addrbuf[INET6_ADDRSTRLEN];
357 1.1 itojun
358 1.11 itojun n = read(rtsock, msg, sizeof(msg));
359 1.1 itojun if (dflag > 1) {
360 1.1 itojun syslog(LOG_DEBUG,
361 1.1 itojun "<%s> received a routing message "
362 1.1 itojun "(type = %d, len = %d)",
363 1.1 itojun __FUNCTION__,
364 1.1 itojun rtmsg_type(msg), n);
365 1.1 itojun }
366 1.1 itojun if (n > rtmsg_len(msg)) {
367 1.1 itojun /*
368 1.1 itojun * This usually won't happen for messages received on
369 1.10 itojun * a routing socket.
370 1.1 itojun */
371 1.1 itojun if (dflag > 1)
372 1.1 itojun syslog(LOG_DEBUG,
373 1.1 itojun "<%s> received data length is larger than"
374 1.1 itojun "1st routing message len. multiple messages?"
375 1.1 itojun " read %d bytes, but 1st msg len = %d",
376 1.1 itojun __FUNCTION__, n, rtmsg_len(msg));
377 1.1 itojun #if 0
378 1.1 itojun /* adjust length */
379 1.1 itojun n = rtmsg_len(msg);
380 1.1 itojun #endif
381 1.1 itojun }
382 1.1 itojun
383 1.1 itojun lim = msg + n;
384 1.1 itojun for (next = msg; next < lim; next += len) {
385 1.10 itojun int oldifflags;
386 1.10 itojun
387 1.1 itojun next = get_next_msg(next, lim, 0, &len,
388 1.1 itojun RTADV_TYPE2BITMASK(RTM_ADD) |
389 1.1 itojun RTADV_TYPE2BITMASK(RTM_DELETE) |
390 1.1 itojun RTADV_TYPE2BITMASK(RTM_NEWADDR) |
391 1.1 itojun RTADV_TYPE2BITMASK(RTM_DELADDR) |
392 1.1 itojun RTADV_TYPE2BITMASK(RTM_IFINFO));
393 1.1 itojun if (len == 0)
394 1.1 itojun break;
395 1.1 itojun type = rtmsg_type(next);
396 1.1 itojun switch (type) {
397 1.1 itojun case RTM_ADD:
398 1.1 itojun case RTM_DELETE:
399 1.1 itojun ifindex = get_rtm_ifindex(next);
400 1.1 itojun break;
401 1.1 itojun case RTM_NEWADDR:
402 1.1 itojun case RTM_DELADDR:
403 1.1 itojun ifindex = get_ifam_ifindex(next);
404 1.1 itojun break;
405 1.1 itojun case RTM_IFINFO:
406 1.1 itojun ifindex = get_ifm_ifindex(next);
407 1.1 itojun break;
408 1.1 itojun default:
409 1.1 itojun /* should not reach here */
410 1.1 itojun if (dflag > 1) {
411 1.1 itojun syslog(LOG_DEBUG,
412 1.1 itojun "<%s:%d> unknown rtmsg %d on %s",
413 1.1 itojun __FUNCTION__, __LINE__, type,
414 1.1 itojun if_indextoname(ifindex, ifname));
415 1.1 itojun }
416 1.10 itojun continue;
417 1.1 itojun }
418 1.1 itojun
419 1.1 itojun if ((rai = if_indextorainfo(ifindex)) == NULL) {
420 1.1 itojun if (dflag > 1) {
421 1.1 itojun syslog(LOG_DEBUG,
422 1.1 itojun "<%s> route changed on "
423 1.1 itojun "non advertising interface(%s)",
424 1.1 itojun __FUNCTION__,
425 1.1 itojun if_indextoname(ifindex, ifname));
426 1.1 itojun }
427 1.10 itojun continue;
428 1.1 itojun }
429 1.10 itojun oldifflags = iflist[ifindex]->ifm_flags;
430 1.1 itojun
431 1.1 itojun switch(type) {
432 1.1 itojun case RTM_ADD:
433 1.10 itojun /* init ifflags because it may have changed */
434 1.1 itojun iflist[ifindex]->ifm_flags =
435 1.1 itojun if_getflags(ifindex,
436 1.1 itojun iflist[ifindex]->ifm_flags);
437 1.1 itojun
438 1.10 itojun if (sflag)
439 1.10 itojun break; /* we aren't interested in prefixes */
440 1.10 itojun
441 1.1 itojun addr = get_addr(msg);
442 1.1 itojun plen = get_prefixlen(msg);
443 1.1 itojun /* sanity check for plen */
444 1.1 itojun if (plen < 4 /* as RFC2373, prefixlen is at least 4 */
445 1.1 itojun || plen > 127) {
446 1.1 itojun syslog(LOG_INFO, "<%s> new interface route's"
447 1.1 itojun "plen %d is invalid for a prefix",
448 1.1 itojun __FUNCTION__, plen);
449 1.10 itojun break;
450 1.1 itojun }
451 1.1 itojun prefix = find_prefix(rai, addr, plen);
452 1.1 itojun if (prefix) {
453 1.1 itojun if (dflag > 1) {
454 1.1 itojun syslog(LOG_DEBUG,
455 1.1 itojun "<%s> new prefix(%s/%d) "
456 1.1 itojun "added on %s, "
457 1.1 itojun "but it was already in list",
458 1.1 itojun __FUNCTION__,
459 1.1 itojun inet_ntop(AF_INET6,
460 1.1 itojun addr, (char *)addrbuf,
461 1.1 itojun INET6_ADDRSTRLEN),
462 1.1 itojun plen,
463 1.1 itojun rai->ifname);
464 1.1 itojun }
465 1.10 itojun break;
466 1.1 itojun }
467 1.1 itojun make_prefix(rai, ifindex, addr, plen);
468 1.1 itojun break;
469 1.1 itojun case RTM_DELETE:
470 1.1 itojun /* init ifflags because it may have changed */
471 1.1 itojun iflist[ifindex]->ifm_flags =
472 1.1 itojun if_getflags(ifindex,
473 1.1 itojun iflist[ifindex]->ifm_flags);
474 1.1 itojun
475 1.10 itojun if (sflag)
476 1.10 itojun break;
477 1.10 itojun
478 1.1 itojun addr = get_addr(msg);
479 1.1 itojun plen = get_prefixlen(msg);
480 1.1 itojun /* sanity check for plen */
481 1.1 itojun if (plen < 4 /* as RFC2373, prefixlen is at least 4 */
482 1.1 itojun || plen > 127) {
483 1.1 itojun syslog(LOG_INFO, "<%s> deleted interface"
484 1.1 itojun "route's"
485 1.1 itojun "plen %d is invalid for a prefix",
486 1.1 itojun __FUNCTION__, plen);
487 1.10 itojun break;
488 1.1 itojun }
489 1.1 itojun prefix = find_prefix(rai, addr, plen);
490 1.1 itojun if (prefix == NULL) {
491 1.1 itojun if (dflag > 1) {
492 1.1 itojun syslog(LOG_DEBUG,
493 1.1 itojun "<%s> prefix(%s/%d) was "
494 1.1 itojun "deleted on %s, "
495 1.1 itojun "but it was not in list",
496 1.1 itojun __FUNCTION__,
497 1.1 itojun inet_ntop(AF_INET6,
498 1.1 itojun addr, (char *)addrbuf,
499 1.1 itojun INET6_ADDRSTRLEN),
500 1.1 itojun plen,
501 1.1 itojun rai->ifname);
502 1.1 itojun }
503 1.10 itojun break;
504 1.1 itojun }
505 1.1 itojun delete_prefix(rai, prefix);
506 1.1 itojun break;
507 1.1 itojun case RTM_NEWADDR:
508 1.1 itojun case RTM_DELADDR:
509 1.1 itojun /* init ifflags because it may have changed */
510 1.1 itojun iflist[ifindex]->ifm_flags =
511 1.1 itojun if_getflags(ifindex,
512 1.1 itojun iflist[ifindex]->ifm_flags);
513 1.1 itojun break;
514 1.1 itojun case RTM_IFINFO:
515 1.1 itojun iflist[ifindex]->ifm_flags = get_ifm_flags(next);
516 1.1 itojun break;
517 1.1 itojun default:
518 1.1 itojun /* should not reach here */
519 1.1 itojun if (dflag > 1) {
520 1.1 itojun syslog(LOG_DEBUG,
521 1.1 itojun "<%s:%d> unknown rtmsg %d on %s",
522 1.1 itojun __FUNCTION__, __LINE__, type,
523 1.1 itojun if_indextoname(ifindex, ifname));
524 1.1 itojun }
525 1.1 itojun return;
526 1.1 itojun }
527 1.10 itojun
528 1.10 itojun /* check if an interface flag is changed */
529 1.10 itojun if ((oldifflags & IFF_UP) != 0 && /* UP to DOWN */
530 1.10 itojun (iflist[ifindex]->ifm_flags & IFF_UP) == 0) {
531 1.10 itojun syslog(LOG_INFO,
532 1.10 itojun "<%s> interface %s becomes down. stop timer.",
533 1.10 itojun __FUNCTION__, rai->ifname);
534 1.10 itojun rtadvd_remove_timer(&rai->timer);
535 1.10 itojun }
536 1.10 itojun else if ((oldifflags & IFF_UP) == 0 && /* DOWN to UP */
537 1.10 itojun (iflist[ifindex]->ifm_flags & IFF_UP) != 0) {
538 1.10 itojun syslog(LOG_INFO,
539 1.10 itojun "<%s> interface %s becomes up. restart timer.",
540 1.10 itojun __FUNCTION__, rai->ifname);
541 1.10 itojun
542 1.10 itojun rai->initcounter = 0; /* reset the counter */
543 1.10 itojun rai->waiting = 0; /* XXX */
544 1.10 itojun rai->timer = rtadvd_add_timer(ra_timeout,
545 1.10 itojun ra_timer_update,
546 1.10 itojun rai, rai);
547 1.10 itojun ra_timer_update((void *)rai, &rai->timer->tm);
548 1.10 itojun rtadvd_set_timer(&rai->timer->tm, rai->timer);
549 1.10 itojun }
550 1.1 itojun }
551 1.1 itojun
552 1.1 itojun return;
553 1.1 itojun }
554 1.1 itojun
555 1.1 itojun void
556 1.1 itojun rtadvd_input()
557 1.1 itojun {
558 1.1 itojun int i;
559 1.1 itojun int *hlimp = NULL;
560 1.1 itojun #ifdef OLDRAWSOCKET
561 1.1 itojun struct ip6_hdr *ip;
562 1.1 itojun #endif
563 1.1 itojun struct icmp6_hdr *icp;
564 1.1 itojun int ifindex = 0;
565 1.1 itojun struct cmsghdr *cm;
566 1.1 itojun struct in6_pktinfo *pi = NULL;
567 1.1 itojun u_char ntopbuf[INET6_ADDRSTRLEN], ifnamebuf[IFNAMSIZ];
568 1.1 itojun struct in6_addr dst = in6addr_any;
569 1.1 itojun
570 1.1 itojun /*
571 1.1 itojun * Get message. We reset msg_controllen since the field could
572 1.1 itojun * be modified if we had received a message before setting
573 1.1 itojun * receive options.
574 1.1 itojun */
575 1.6 itojun rcvmhdr.msg_controllen = rcvcmsgbuflen;
576 1.1 itojun if ((i = recvmsg(sock, &rcvmhdr, 0)) < 0)
577 1.1 itojun return;
578 1.1 itojun
579 1.1 itojun /* extract optional information via Advanced API */
580 1.1 itojun for (cm = (struct cmsghdr *)CMSG_FIRSTHDR(&rcvmhdr);
581 1.1 itojun cm;
582 1.1 itojun cm = (struct cmsghdr *)CMSG_NXTHDR(&rcvmhdr, cm)) {
583 1.1 itojun if (cm->cmsg_level == IPPROTO_IPV6 &&
584 1.1 itojun cm->cmsg_type == IPV6_PKTINFO &&
585 1.1 itojun cm->cmsg_len == CMSG_LEN(sizeof(struct in6_pktinfo))) {
586 1.1 itojun pi = (struct in6_pktinfo *)(CMSG_DATA(cm));
587 1.1 itojun ifindex = pi->ipi6_ifindex;
588 1.1 itojun dst = pi->ipi6_addr;
589 1.1 itojun }
590 1.1 itojun if (cm->cmsg_level == IPPROTO_IPV6 &&
591 1.1 itojun cm->cmsg_type == IPV6_HOPLIMIT &&
592 1.1 itojun cm->cmsg_len == CMSG_LEN(sizeof(int)))
593 1.1 itojun hlimp = (int *)CMSG_DATA(cm);
594 1.1 itojun }
595 1.1 itojun if (ifindex == 0) {
596 1.1 itojun syslog(LOG_ERR,
597 1.1 itojun "<%s> failed to get receiving interface",
598 1.1 itojun __FUNCTION__);
599 1.1 itojun return;
600 1.1 itojun }
601 1.1 itojun if (hlimp == NULL) {
602 1.1 itojun syslog(LOG_ERR,
603 1.1 itojun "<%s> failed to get receiving hop limit",
604 1.1 itojun __FUNCTION__);
605 1.1 itojun return;
606 1.1 itojun }
607 1.1 itojun
608 1.10 itojun /*
609 1.10 itojun * If we happen to receive data on an interface which is now down,
610 1.10 itojun * just discard the data.
611 1.10 itojun */
612 1.10 itojun if ((iflist[pi->ipi6_ifindex]->ifm_flags & IFF_UP) == 0) {
613 1.10 itojun syslog(LOG_INFO,
614 1.10 itojun "<%s> received data on a disabled interface (%s)",
615 1.10 itojun __FUNCTION__,
616 1.10 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
617 1.10 itojun return;
618 1.10 itojun }
619 1.10 itojun
620 1.1 itojun #ifdef OLDRAWSOCKET
621 1.1 itojun if (i < sizeof(struct ip6_hdr) + sizeof(struct icmp6_hdr)) {
622 1.1 itojun syslog(LOG_ERR,
623 1.1 itojun "<%s> packet size(%d) is too short",
624 1.1 itojun __FUNCTION__, i);
625 1.1 itojun return;
626 1.1 itojun }
627 1.1 itojun
628 1.1 itojun ip = (struct ip6_hdr *)rcvmhdr.msg_iov[0].iov_base;
629 1.1 itojun icp = (struct icmp6_hdr *)(ip + 1); /* XXX: ext. hdr? */
630 1.1 itojun #else
631 1.1 itojun if (i < sizeof(struct icmp6_hdr)) {
632 1.1 itojun syslog(LOG_ERR,
633 1.1 itojun "<%s> packet size(%d) is too short",
634 1.1 itojun __FUNCTION__, i);
635 1.1 itojun return;
636 1.1 itojun }
637 1.1 itojun
638 1.1 itojun icp = (struct icmp6_hdr *)rcvmhdr.msg_iov[0].iov_base;
639 1.10 itojun #endif
640 1.1 itojun
641 1.1 itojun switch(icp->icmp6_type) {
642 1.1 itojun case ND_ROUTER_SOLICIT:
643 1.3 itojun /*
644 1.3 itojun * Message verification - RFC-2461 6.1.1
645 1.3 itojun * XXX: these checks must be done in the kernel as well,
646 1.3 itojun * but we can't completely rely on them.
647 1.3 itojun */
648 1.1 itojun if (*hlimp != 255) {
649 1.1 itojun syslog(LOG_NOTICE,
650 1.3 itojun "<%s> RS with invalid hop limit(%d) "
651 1.1 itojun "received from %s on %s",
652 1.1 itojun __FUNCTION__, *hlimp,
653 1.1 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
654 1.1 itojun INET6_ADDRSTRLEN),
655 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
656 1.1 itojun return;
657 1.1 itojun }
658 1.3 itojun if (icp->icmp6_code) {
659 1.3 itojun syslog(LOG_NOTICE,
660 1.3 itojun "<%s> RS with invalid ICMP6 code(%d) "
661 1.3 itojun "received from %s on %s",
662 1.3 itojun __FUNCTION__, icp->icmp6_code,
663 1.3 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
664 1.3 itojun INET6_ADDRSTRLEN),
665 1.3 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
666 1.3 itojun return;
667 1.3 itojun }
668 1.3 itojun if (i < sizeof(struct nd_router_solicit)) {
669 1.3 itojun syslog(LOG_NOTICE,
670 1.3 itojun "<%s> RS from %s on %s does not have enough "
671 1.3 itojun "length (len = %d)",
672 1.3 itojun __FUNCTION__,
673 1.3 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
674 1.3 itojun INET6_ADDRSTRLEN),
675 1.3 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf), i);
676 1.3 itojun return;
677 1.3 itojun }
678 1.1 itojun rs_input(i, (struct nd_router_solicit *)icp, pi, &from);
679 1.1 itojun break;
680 1.1 itojun case ND_ROUTER_ADVERT:
681 1.3 itojun /*
682 1.3 itojun * Message verification - RFC-2461 6.1.2
683 1.3 itojun * XXX: there's a same dilemma as above...
684 1.3 itojun */
685 1.1 itojun if (*hlimp != 255) {
686 1.1 itojun syslog(LOG_NOTICE,
687 1.3 itojun "<%s> RA with invalid hop limit(%d) "
688 1.1 itojun "received from %s on %s",
689 1.1 itojun __FUNCTION__, *hlimp,
690 1.1 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
691 1.1 itojun INET6_ADDRSTRLEN),
692 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
693 1.3 itojun return;
694 1.3 itojun }
695 1.3 itojun if (icp->icmp6_code) {
696 1.3 itojun syslog(LOG_NOTICE,
697 1.3 itojun "<%s> RA with invalid ICMP6 code(%d) "
698 1.3 itojun "received from %s on %s",
699 1.3 itojun __FUNCTION__, icp->icmp6_code,
700 1.3 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
701 1.3 itojun INET6_ADDRSTRLEN),
702 1.3 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
703 1.3 itojun return;
704 1.3 itojun }
705 1.3 itojun if (i < sizeof(struct nd_router_advert)) {
706 1.3 itojun syslog(LOG_NOTICE,
707 1.3 itojun "<%s> RA from %s on %s does not have enough "
708 1.3 itojun "length (len = %d)",
709 1.3 itojun __FUNCTION__,
710 1.3 itojun inet_ntop(AF_INET6, &from.sin6_addr, ntopbuf,
711 1.3 itojun INET6_ADDRSTRLEN),
712 1.3 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf), i);
713 1.1 itojun return;
714 1.1 itojun }
715 1.1 itojun ra_input(i, (struct nd_router_advert *)icp, pi, &from);
716 1.1 itojun break;
717 1.1 itojun case ICMP6_ROUTER_RENUMBERING:
718 1.1 itojun if (accept_rr == 0) {
719 1.1 itojun syslog(LOG_ERR,
720 1.1 itojun "<%s> received a router renumbering "
721 1.1 itojun "message, but not allowed to be accepted",
722 1.1 itojun __FUNCTION__);
723 1.1 itojun break;
724 1.1 itojun }
725 1.1 itojun rr_input(i, (struct icmp6_router_renum *)icp, pi, &from,
726 1.1 itojun &dst);
727 1.1 itojun break;
728 1.1 itojun default:
729 1.1 itojun /*
730 1.1 itojun * Note that this case is POSSIBLE, especially just
731 1.1 itojun * after invocation of the daemon. This is because we
732 1.1 itojun * could receive message after opening the socket and
733 1.1 itojun * before setting ICMP6 type filter(see sock_open()).
734 1.1 itojun */
735 1.1 itojun syslog(LOG_ERR,
736 1.1 itojun "<%s> invalid icmp type(%d)",
737 1.1 itojun __FUNCTION__, icp->icmp6_type);
738 1.1 itojun return;
739 1.1 itojun }
740 1.1 itojun
741 1.1 itojun return;
742 1.1 itojun }
743 1.1 itojun
744 1.1 itojun static void
745 1.1 itojun rs_input(int len, struct nd_router_solicit *rs,
746 1.1 itojun struct in6_pktinfo *pi, struct sockaddr_in6 *from)
747 1.1 itojun {
748 1.1 itojun u_char ntopbuf[INET6_ADDRSTRLEN], ifnamebuf[IFNAMSIZ];
749 1.1 itojun union nd_opts ndopts;
750 1.1 itojun struct rainfo *ra;
751 1.1 itojun
752 1.1 itojun syslog(LOG_DEBUG,
753 1.1 itojun "<%s> RS received from %s on %s",
754 1.1 itojun __FUNCTION__,
755 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
756 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
757 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
758 1.1 itojun
759 1.1 itojun /* ND option check */
760 1.1 itojun memset(&ndopts, 0, sizeof(ndopts));
761 1.1 itojun if (nd6_options((struct nd_opt_hdr *)(rs + 1),
762 1.1 itojun len - sizeof(struct nd_router_solicit),
763 1.1 itojun &ndopts, NDOPT_FLAG_SRCLINKADDR)) {
764 1.1 itojun syslog(LOG_DEBUG,
765 1.1 itojun "<%s> ND option check failed for an RS from %s on %s",
766 1.1 itojun __FUNCTION__,
767 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
768 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
769 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
770 1.1 itojun return;
771 1.1 itojun }
772 1.1 itojun
773 1.1 itojun /*
774 1.1 itojun * If the IP source address is the unspecified address, there
775 1.1 itojun * must be no source link-layer address option in the message.
776 1.1 itojun * (RFC-2461 6.1.1)
777 1.1 itojun */
778 1.1 itojun if (IN6_IS_ADDR_UNSPECIFIED(&from->sin6_addr) &&
779 1.1 itojun ndopts.nd_opts_src_lladdr) {
780 1.1 itojun syslog(LOG_ERR,
781 1.1 itojun "<%s> RS from unspecified src on %s has a link-layer"
782 1.1 itojun " address option",
783 1.1 itojun __FUNCTION__,
784 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
785 1.1 itojun goto done;
786 1.1 itojun }
787 1.1 itojun
788 1.1 itojun ra = ralist;
789 1.1 itojun while (ra != NULL) {
790 1.1 itojun if (pi->ipi6_ifindex == ra->ifindex)
791 1.1 itojun break;
792 1.1 itojun ra = ra->next;
793 1.1 itojun }
794 1.1 itojun if (ra == NULL) {
795 1.1 itojun syslog(LOG_INFO,
796 1.1 itojun "<%s> RS received on non advertising interface(%s)",
797 1.1 itojun __FUNCTION__,
798 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
799 1.1 itojun goto done;
800 1.1 itojun }
801 1.1 itojun
802 1.9 itojun ra->rsinput++; /* increment statistics */
803 1.9 itojun
804 1.1 itojun /*
805 1.1 itojun * Decide whether to send RA according to the rate-limit
806 1.1 itojun * consideration.
807 1.1 itojun */
808 1.1 itojun {
809 1.1 itojun long delay; /* must not be greater than 1000000 */
810 1.1 itojun struct timeval interval, now, min_delay, tm_tmp, *rest;
811 1.10 itojun struct soliciter *sol;
812 1.10 itojun
813 1.10 itojun /*
814 1.10 itojun * record sockaddr waiting for RA, if possible
815 1.10 itojun */
816 1.10 itojun sol = (struct soliciter *)malloc(sizeof(*sol));
817 1.10 itojun if (sol) {
818 1.10 itojun sol->addr = *from;
819 1.10 itojun /*XXX RFC2553 need clarification on flowinfo */
820 1.10 itojun sol->addr.sin6_flowinfo = 0;
821 1.10 itojun sol->next = ra->soliciter;
822 1.10 itojun ra->soliciter = sol->next;
823 1.10 itojun }
824 1.1 itojun
825 1.1 itojun /*
826 1.1 itojun * If there is already a waiting RS packet, don't
827 1.1 itojun * update the timer.
828 1.1 itojun */
829 1.1 itojun if (ra->waiting++)
830 1.1 itojun goto done;
831 1.1 itojun
832 1.1 itojun /*
833 1.1 itojun * Compute a random delay. If the computed value
834 1.1 itojun * corresponds to a time later than the time the next
835 1.1 itojun * multicast RA is scheduled to be sent, ignore the random
836 1.1 itojun * delay and send the advertisement at the
837 1.1 itojun * already-scheduled time. RFC-2461 6.2.6
838 1.1 itojun */
839 1.1 itojun delay = random() % MAX_RA_DELAY_TIME;
840 1.1 itojun interval.tv_sec = 0;
841 1.1 itojun interval.tv_usec = delay;
842 1.1 itojun rest = rtadvd_timer_rest(ra->timer);
843 1.1 itojun if (TIMEVAL_LT(*rest, interval)) {
844 1.1 itojun syslog(LOG_DEBUG,
845 1.1 itojun "<%s> random delay is larger than "
846 1.1 itojun "the rest of normal timer",
847 1.1 itojun __FUNCTION__);
848 1.1 itojun interval = *rest;
849 1.1 itojun }
850 1.1 itojun
851 1.1 itojun /*
852 1.1 itojun * If we sent a multicast Router Advertisement within
853 1.1 itojun * the last MIN_DELAY_BETWEEN_RAS seconds, schedule
854 1.1 itojun * the advertisement to be sent at a time corresponding to
855 1.1 itojun * MIN_DELAY_BETWEEN_RAS plus the random value after the
856 1.1 itojun * previous advertisement was sent.
857 1.1 itojun */
858 1.1 itojun gettimeofday(&now, NULL);
859 1.1 itojun TIMEVAL_SUB(&now, &ra->lastsent, &tm_tmp);
860 1.1 itojun min_delay.tv_sec = MIN_DELAY_BETWEEN_RAS;
861 1.1 itojun min_delay.tv_usec = 0;
862 1.1 itojun if (TIMEVAL_LT(tm_tmp, min_delay)) {
863 1.1 itojun TIMEVAL_SUB(&min_delay, &tm_tmp, &min_delay);
864 1.1 itojun TIMEVAL_ADD(&min_delay, &interval, &interval);
865 1.1 itojun }
866 1.1 itojun rtadvd_set_timer(&interval, ra->timer);
867 1.10 itojun goto done;
868 1.1 itojun }
869 1.1 itojun
870 1.1 itojun done:
871 1.1 itojun free_ndopts(&ndopts);
872 1.1 itojun return;
873 1.1 itojun }
874 1.1 itojun
875 1.1 itojun static void
876 1.1 itojun ra_input(int len, struct nd_router_advert *ra,
877 1.1 itojun struct in6_pktinfo *pi, struct sockaddr_in6 *from)
878 1.1 itojun {
879 1.1 itojun struct rainfo *rai;
880 1.1 itojun u_char ntopbuf[INET6_ADDRSTRLEN], ifnamebuf[IFNAMSIZ];
881 1.1 itojun union nd_opts ndopts;
882 1.1 itojun char *on_off[] = {"OFF", "ON"};
883 1.1 itojun u_int32_t reachabletime, retranstimer, mtu;
884 1.9 itojun int inconsistent = 0;
885 1.1 itojun
886 1.1 itojun syslog(LOG_DEBUG,
887 1.1 itojun "<%s> RA received from %s on %s",
888 1.1 itojun __FUNCTION__,
889 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
890 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
891 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
892 1.1 itojun
893 1.1 itojun /* ND option check */
894 1.1 itojun memset(&ndopts, 0, sizeof(ndopts));
895 1.1 itojun if (nd6_options((struct nd_opt_hdr *)(ra + 1),
896 1.1 itojun len - sizeof(struct nd_router_advert),
897 1.11 itojun &ndopts, NDOPT_FLAG_SRCLINKADDR |
898 1.11 itojun NDOPT_FLAG_PREFIXINFO | NDOPT_FLAG_MTU)) {
899 1.1 itojun syslog(LOG_ERR,
900 1.1 itojun "<%s> ND option check failed for an RA from %s on %s",
901 1.1 itojun __FUNCTION__,
902 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
903 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
904 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
905 1.1 itojun return;
906 1.1 itojun }
907 1.1 itojun
908 1.1 itojun /*
909 1.1 itojun * RA consistency check according to RFC-2461 6.2.7
910 1.1 itojun */
911 1.1 itojun if ((rai = if_indextorainfo(pi->ipi6_ifindex)) == 0) {
912 1.1 itojun syslog(LOG_INFO,
913 1.1 itojun "<%s> received RA from %s on non-advertising"
914 1.1 itojun " interface(%s)",
915 1.1 itojun __FUNCTION__,
916 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
917 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
918 1.1 itojun if_indextoname(pi->ipi6_ifindex, ifnamebuf));
919 1.1 itojun goto done;
920 1.1 itojun }
921 1.9 itojun rai->rainput++; /* increment statistics */
922 1.9 itojun
923 1.1 itojun /* Cur Hop Limit value */
924 1.1 itojun if (ra->nd_ra_curhoplimit && rai->hoplimit &&
925 1.1 itojun ra->nd_ra_curhoplimit != rai->hoplimit) {
926 1.11 itojun syslog(LOG_INFO,
927 1.1 itojun "<%s> CurHopLimit inconsistent on %s:"
928 1.1 itojun " %d from %s, %d from us",
929 1.1 itojun __FUNCTION__,
930 1.1 itojun rai->ifname,
931 1.1 itojun ra->nd_ra_curhoplimit,
932 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
933 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
934 1.1 itojun rai->hoplimit);
935 1.9 itojun inconsistent++;
936 1.1 itojun }
937 1.1 itojun /* M flag */
938 1.1 itojun if ((ra->nd_ra_flags_reserved & ND_RA_FLAG_MANAGED) !=
939 1.1 itojun rai->managedflg) {
940 1.11 itojun syslog(LOG_INFO,
941 1.1 itojun "<%s> M flag inconsistent on %s:"
942 1.1 itojun " %s from %s, %s from us",
943 1.1 itojun __FUNCTION__,
944 1.1 itojun rai->ifname,
945 1.1 itojun on_off[!rai->managedflg],
946 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
947 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
948 1.1 itojun on_off[rai->managedflg]);
949 1.9 itojun inconsistent++;
950 1.1 itojun }
951 1.1 itojun /* O flag */
952 1.1 itojun if ((ra->nd_ra_flags_reserved & ND_RA_FLAG_OTHER) !=
953 1.1 itojun rai->otherflg) {
954 1.11 itojun syslog(LOG_INFO,
955 1.1 itojun "<%s> O flag inconsistent on %s:"
956 1.1 itojun " %s from %s, %s from us",
957 1.1 itojun __FUNCTION__,
958 1.1 itojun rai->ifname,
959 1.1 itojun on_off[!rai->otherflg],
960 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
961 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
962 1.1 itojun on_off[rai->otherflg]);
963 1.9 itojun inconsistent++;
964 1.1 itojun }
965 1.1 itojun /* Reachable Time */
966 1.1 itojun reachabletime = ntohl(ra->nd_ra_reachable);
967 1.1 itojun if (reachabletime && rai->reachabletime &&
968 1.1 itojun reachabletime != rai->reachabletime) {
969 1.11 itojun syslog(LOG_INFO,
970 1.1 itojun "<%s> ReachableTime inconsistent on %s:"
971 1.1 itojun " %d from %s, %d from us",
972 1.1 itojun __FUNCTION__,
973 1.1 itojun rai->ifname,
974 1.1 itojun reachabletime,
975 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
976 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
977 1.1 itojun rai->reachabletime);
978 1.9 itojun inconsistent++;
979 1.1 itojun }
980 1.1 itojun /* Retrans Timer */
981 1.1 itojun retranstimer = ntohl(ra->nd_ra_retransmit);
982 1.1 itojun if (retranstimer && rai->retranstimer &&
983 1.1 itojun retranstimer != rai->retranstimer) {
984 1.11 itojun syslog(LOG_INFO,
985 1.1 itojun "<%s> RetranceTimer inconsistent on %s:"
986 1.1 itojun " %d from %s, %d from us",
987 1.1 itojun __FUNCTION__,
988 1.1 itojun rai->ifname,
989 1.1 itojun retranstimer,
990 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
991 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
992 1.1 itojun rai->retranstimer);
993 1.9 itojun inconsistent++;
994 1.1 itojun }
995 1.1 itojun /* Values in the MTU options */
996 1.1 itojun if (ndopts.nd_opts_mtu) {
997 1.1 itojun mtu = ntohl(ndopts.nd_opts_mtu->nd_opt_mtu_mtu);
998 1.1 itojun if (mtu && rai->linkmtu && mtu != rai->linkmtu) {
999 1.11 itojun syslog(LOG_INFO,
1000 1.1 itojun "<%s> MTU option value inconsistent on %s:"
1001 1.1 itojun " %d from %s, %d from us",
1002 1.1 itojun __FUNCTION__,
1003 1.1 itojun rai->ifname, mtu,
1004 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1005 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
1006 1.1 itojun rai->linkmtu);
1007 1.9 itojun inconsistent++;
1008 1.1 itojun }
1009 1.1 itojun }
1010 1.1 itojun /* Preferred and Valid Lifetimes for prefixes */
1011 1.1 itojun {
1012 1.1 itojun struct nd_optlist *optp = ndopts.nd_opts_list;
1013 1.11 itojun
1014 1.9 itojun if (ndopts.nd_opts_pi) {
1015 1.9 itojun if (prefix_check(ndopts.nd_opts_pi, rai, from))
1016 1.9 itojun inconsistent++;
1017 1.9 itojun }
1018 1.1 itojun while (optp) {
1019 1.9 itojun if (prefix_check((struct nd_opt_prefix_info *)optp->opt,
1020 1.9 itojun rai, from))
1021 1.9 itojun inconsistent++;
1022 1.1 itojun optp = optp->next;
1023 1.1 itojun }
1024 1.1 itojun }
1025 1.9 itojun
1026 1.11 itojun if (inconsistent)
1027 1.9 itojun rai->rainconsistent++;
1028 1.1 itojun
1029 1.1 itojun done:
1030 1.1 itojun free_ndopts(&ndopts);
1031 1.1 itojun return;
1032 1.1 itojun }
1033 1.1 itojun
1034 1.9 itojun /* return a non-zero value if the received prefix is inconsitent with ours */
1035 1.9 itojun static int
1036 1.1 itojun prefix_check(struct nd_opt_prefix_info *pinfo,
1037 1.1 itojun struct rainfo *rai, struct sockaddr_in6 *from)
1038 1.1 itojun {
1039 1.1 itojun u_int32_t preferred_time, valid_time;
1040 1.1 itojun struct prefix *pp;
1041 1.9 itojun int inconsistent = 0;
1042 1.1 itojun u_char ntopbuf[INET6_ADDRSTRLEN], prefixbuf[INET6_ADDRSTRLEN];
1043 1.11 itojun struct timeval now;
1044 1.1 itojun
1045 1.1 itojun #if 0 /* impossible */
1046 1.1 itojun if (pinfo->nd_opt_pi_type != ND_OPT_PREFIX_INFORMATION)
1047 1.9 itojun return(0);
1048 1.1 itojun #endif
1049 1.1 itojun
1050 1.1 itojun /*
1051 1.1 itojun * log if the adveritsed prefix has link-local scope(sanity check?)
1052 1.1 itojun */
1053 1.1 itojun if (IN6_IS_ADDR_LINKLOCAL(&pinfo->nd_opt_pi_prefix)) {
1054 1.1 itojun syslog(LOG_INFO,
1055 1.1 itojun "<%s> link-local prefix %s/%d is advertised "
1056 1.1 itojun "from %s on %s",
1057 1.1 itojun __FUNCTION__,
1058 1.1 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1059 1.1 itojun prefixbuf, INET6_ADDRSTRLEN),
1060 1.1 itojun pinfo->nd_opt_pi_prefix_len,
1061 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1062 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
1063 1.1 itojun rai->ifname);
1064 1.1 itojun }
1065 1.1 itojun
1066 1.1 itojun if ((pp = find_prefix(rai, &pinfo->nd_opt_pi_prefix,
1067 1.1 itojun pinfo->nd_opt_pi_prefix_len)) == NULL) {
1068 1.1 itojun syslog(LOG_INFO,
1069 1.1 itojun "<%s> prefix %s/%d from %s on %s is not in our list",
1070 1.1 itojun __FUNCTION__,
1071 1.1 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1072 1.1 itojun prefixbuf, INET6_ADDRSTRLEN),
1073 1.1 itojun pinfo->nd_opt_pi_prefix_len,
1074 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1075 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
1076 1.1 itojun rai->ifname);
1077 1.9 itojun return(0);
1078 1.1 itojun }
1079 1.1 itojun
1080 1.1 itojun preferred_time = ntohl(pinfo->nd_opt_pi_preferred_time);
1081 1.11 itojun if (pp->pltimeexpire) {
1082 1.11 itojun /*
1083 1.11 itojun * The lifetime is decremented in real time, so we should
1084 1.11 itojun * compare the expiration time.
1085 1.11 itojun * (RFC 2461 Section 6.2.7.)
1086 1.11 itojun * XXX: can we really expect that all routers on the link
1087 1.11 itojun * have synchronized clocks?
1088 1.11 itojun */
1089 1.11 itojun gettimeofday(&now, NULL);
1090 1.11 itojun preferred_time += now.tv_sec;
1091 1.11 itojun
1092 1.11 itojun if (rai->clockskew &&
1093 1.11 itojun abs(preferred_time - pp->pltimeexpire) > rai->clockskew) {
1094 1.11 itojun syslog(LOG_INFO,
1095 1.11 itojun "<%s> prefeerred lifetime for %s/%d"
1096 1.11 itojun " (decr. in real time) inconsistent on %s:"
1097 1.11 itojun " %d from %s, %ld from us",
1098 1.11 itojun __FUNCTION__,
1099 1.11 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1100 1.11 itojun prefixbuf, INET6_ADDRSTRLEN),
1101 1.11 itojun pinfo->nd_opt_pi_prefix_len,
1102 1.11 itojun rai->ifname, preferred_time,
1103 1.11 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1104 1.11 itojun ntopbuf, INET6_ADDRSTRLEN),
1105 1.11 itojun pp->pltimeexpire);
1106 1.11 itojun inconsistent++;
1107 1.11 itojun }
1108 1.11 itojun }
1109 1.11 itojun else if (preferred_time != pp->preflifetime) {
1110 1.11 itojun syslog(LOG_INFO,
1111 1.1 itojun "<%s> prefeerred lifetime for %s/%d"
1112 1.1 itojun " inconsistent on %s:"
1113 1.1 itojun " %d from %s, %d from us",
1114 1.1 itojun __FUNCTION__,
1115 1.1 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1116 1.1 itojun prefixbuf, INET6_ADDRSTRLEN),
1117 1.1 itojun pinfo->nd_opt_pi_prefix_len,
1118 1.1 itojun rai->ifname, preferred_time,
1119 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1120 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
1121 1.1 itojun pp->preflifetime);
1122 1.9 itojun }
1123 1.1 itojun
1124 1.1 itojun valid_time = ntohl(pinfo->nd_opt_pi_valid_time);
1125 1.11 itojun if (pp->vltimeexpire) {
1126 1.11 itojun gettimeofday(&now, NULL);
1127 1.11 itojun valid_time += now.tv_sec;
1128 1.11 itojun
1129 1.11 itojun if (rai->clockskew &&
1130 1.11 itojun abs(valid_time - pp->vltimeexpire) > rai->clockskew) {
1131 1.11 itojun syslog(LOG_INFO,
1132 1.11 itojun "<%s> valid lifetime for %s/%d"
1133 1.11 itojun " (decr. in real time) inconsistent on %s:"
1134 1.11 itojun " %d from %s, %ld from us",
1135 1.11 itojun __FUNCTION__,
1136 1.11 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1137 1.11 itojun prefixbuf, INET6_ADDRSTRLEN),
1138 1.11 itojun pinfo->nd_opt_pi_prefix_len,
1139 1.11 itojun rai->ifname, preferred_time,
1140 1.11 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1141 1.11 itojun ntopbuf, INET6_ADDRSTRLEN),
1142 1.11 itojun pp->vltimeexpire);
1143 1.11 itojun inconsistent++;
1144 1.11 itojun }
1145 1.11 itojun }
1146 1.11 itojun else if (valid_time != pp->validlifetime) {
1147 1.11 itojun syslog(LOG_INFO,
1148 1.1 itojun "<%s> valid lifetime for %s/%d"
1149 1.1 itojun " inconsistent on %s:"
1150 1.1 itojun " %d from %s, %d from us",
1151 1.1 itojun __FUNCTION__,
1152 1.1 itojun inet_ntop(AF_INET6, &pinfo->nd_opt_pi_prefix,
1153 1.1 itojun prefixbuf, INET6_ADDRSTRLEN),
1154 1.1 itojun pinfo->nd_opt_pi_prefix_len,
1155 1.1 itojun rai->ifname, valid_time,
1156 1.1 itojun inet_ntop(AF_INET6, &from->sin6_addr,
1157 1.1 itojun ntopbuf, INET6_ADDRSTRLEN),
1158 1.1 itojun pp->validlifetime);
1159 1.9 itojun inconsistent++;
1160 1.9 itojun }
1161 1.9 itojun
1162 1.9 itojun return(inconsistent);
1163 1.1 itojun }
1164 1.1 itojun
1165 1.1 itojun struct prefix *
1166 1.1 itojun find_prefix(struct rainfo *rai, struct in6_addr *prefix, int plen)
1167 1.1 itojun {
1168 1.1 itojun struct prefix *pp;
1169 1.1 itojun int bytelen, bitlen;
1170 1.1 itojun
1171 1.1 itojun for (pp = rai->prefix.next; pp != &rai->prefix; pp = pp->next) {
1172 1.1 itojun if (plen != pp->prefixlen)
1173 1.1 itojun continue;
1174 1.1 itojun bytelen = plen / 8;
1175 1.1 itojun bitlen = plen % 8;
1176 1.1 itojun if (memcmp((void *)prefix, (void *)&pp->prefix, bytelen))
1177 1.1 itojun continue;
1178 1.1 itojun if (prefix->s6_addr[bytelen] >> (8 - bitlen) ==
1179 1.1 itojun pp->prefix.s6_addr[bytelen] >> (8 - bitlen))
1180 1.1 itojun return(pp);
1181 1.1 itojun }
1182 1.1 itojun
1183 1.1 itojun return(NULL);
1184 1.1 itojun }
1185 1.1 itojun
1186 1.11 itojun /* check if p0/plen0 matches p1/plen1; return 1 if matches, otherwise 0. */
1187 1.11 itojun int
1188 1.11 itojun prefix_match(struct in6_addr *p0, int plen0,
1189 1.11 itojun struct in6_addr *p1, int plen1)
1190 1.11 itojun {
1191 1.11 itojun int bytelen, bitlen;
1192 1.11 itojun
1193 1.11 itojun if (plen0 < plen1)
1194 1.11 itojun return(0);
1195 1.11 itojun bytelen = plen1 / 8;
1196 1.11 itojun bitlen = plen1 % 8;
1197 1.11 itojun if (memcmp((void *)p0, (void *)p1, bytelen))
1198 1.11 itojun return(0);
1199 1.11 itojun if (p0->s6_addr[bytelen] >> (8 - bitlen) ==
1200 1.11 itojun p1->s6_addr[bytelen] >> (8 - bitlen))
1201 1.11 itojun return(1);
1202 1.11 itojun
1203 1.11 itojun return(0);
1204 1.11 itojun }
1205 1.11 itojun
1206 1.1 itojun static int
1207 1.1 itojun nd6_options(struct nd_opt_hdr *hdr, int limit,
1208 1.1 itojun union nd_opts *ndopts, u_int32_t optflags)
1209 1.1 itojun {
1210 1.1 itojun int optlen = 0;
1211 1.1 itojun
1212 1.1 itojun for (; limit > 0; limit -= optlen) {
1213 1.1 itojun hdr = (struct nd_opt_hdr *)((caddr_t)hdr + optlen);
1214 1.1 itojun optlen = hdr->nd_opt_len << 3;
1215 1.1 itojun if (hdr->nd_opt_len == 0) {
1216 1.1 itojun syslog(LOG_ERR,
1217 1.1 itojun "<%s> bad ND option length(0) (type = %d)",
1218 1.1 itojun __FUNCTION__, hdr->nd_opt_type);
1219 1.1 itojun goto bad;
1220 1.1 itojun }
1221 1.1 itojun
1222 1.1 itojun if (hdr->nd_opt_type > ND_OPT_MTU) {
1223 1.1 itojun syslog(LOG_INFO,
1224 1.1 itojun "<%s> unknown ND option(type %d)",
1225 1.1 itojun __FUNCTION__,
1226 1.1 itojun hdr->nd_opt_type);
1227 1.1 itojun continue;
1228 1.1 itojun }
1229 1.1 itojun
1230 1.1 itojun if ((ndopt_flags[hdr->nd_opt_type] & optflags) == 0) {
1231 1.1 itojun syslog(LOG_INFO,
1232 1.1 itojun "<%s> unexpected ND option(type %d)",
1233 1.1 itojun __FUNCTION__,
1234 1.1 itojun hdr->nd_opt_type);
1235 1.1 itojun continue;
1236 1.1 itojun }
1237 1.1 itojun
1238 1.1 itojun switch(hdr->nd_opt_type) {
1239 1.1 itojun case ND_OPT_SOURCE_LINKADDR:
1240 1.1 itojun case ND_OPT_TARGET_LINKADDR:
1241 1.1 itojun case ND_OPT_REDIRECTED_HEADER:
1242 1.1 itojun case ND_OPT_MTU:
1243 1.1 itojun if (ndopts->nd_opt_array[hdr->nd_opt_type]) {
1244 1.1 itojun syslog(LOG_INFO,
1245 1.1 itojun "<%s> duplicated ND option"
1246 1.1 itojun " (type = %d)",
1247 1.1 itojun __FUNCTION__,
1248 1.1 itojun hdr->nd_opt_type);
1249 1.1 itojun }
1250 1.1 itojun ndopts->nd_opt_array[hdr->nd_opt_type] = hdr;
1251 1.1 itojun break;
1252 1.1 itojun case ND_OPT_PREFIX_INFORMATION:
1253 1.1 itojun {
1254 1.1 itojun struct nd_optlist *pfxlist;
1255 1.1 itojun
1256 1.1 itojun if (ndopts->nd_opts_pi == 0) {
1257 1.1 itojun ndopts->nd_opts_pi =
1258 1.1 itojun (struct nd_opt_prefix_info *)hdr;
1259 1.1 itojun continue;
1260 1.1 itojun }
1261 1.1 itojun if ((pfxlist = malloc(sizeof(*pfxlist))) == NULL) {
1262 1.1 itojun syslog(LOG_ERR,
1263 1.1 itojun "<%s> can't allocate memory",
1264 1.1 itojun __FUNCTION__);
1265 1.1 itojun goto bad;
1266 1.1 itojun }
1267 1.1 itojun pfxlist->next = ndopts->nd_opts_list;
1268 1.1 itojun pfxlist->opt = hdr;
1269 1.1 itojun ndopts->nd_opts_list = pfxlist;
1270 1.1 itojun
1271 1.1 itojun break;
1272 1.1 itojun }
1273 1.1 itojun default: /* impossible */
1274 1.1 itojun break;
1275 1.1 itojun }
1276 1.1 itojun }
1277 1.1 itojun
1278 1.1 itojun return(0);
1279 1.1 itojun
1280 1.1 itojun bad:
1281 1.1 itojun free_ndopts(ndopts);
1282 1.1 itojun
1283 1.1 itojun return(-1);
1284 1.1 itojun }
1285 1.1 itojun
1286 1.1 itojun static void
1287 1.1 itojun free_ndopts(union nd_opts *ndopts)
1288 1.1 itojun {
1289 1.1 itojun struct nd_optlist *opt = ndopts->nd_opts_list, *next;
1290 1.1 itojun
1291 1.1 itojun while(opt) {
1292 1.1 itojun next = opt->next;
1293 1.1 itojun free(opt);
1294 1.1 itojun opt = next;
1295 1.1 itojun }
1296 1.1 itojun }
1297 1.1 itojun
1298 1.1 itojun void
1299 1.1 itojun sock_open()
1300 1.1 itojun {
1301 1.1 itojun struct icmp6_filter filt;
1302 1.1 itojun struct ipv6_mreq mreq;
1303 1.1 itojun struct rainfo *ra = ralist;
1304 1.1 itojun int on;
1305 1.1 itojun /* XXX: should be max MTU attached to the node */
1306 1.1 itojun static u_char answer[1500];
1307 1.6 itojun
1308 1.6 itojun rcvcmsgbuflen = CMSG_SPACE(sizeof(struct in6_pktinfo)) +
1309 1.6 itojun CMSG_SPACE(sizeof(int));
1310 1.6 itojun rcvcmsgbuf = (u_char *)malloc(rcvcmsgbuflen);
1311 1.6 itojun if (rcvcmsgbuf == NULL) {
1312 1.6 itojun syslog(LOG_ERR, "<%s> not enough core", __FUNCTION__);
1313 1.6 itojun exit(1);
1314 1.6 itojun }
1315 1.6 itojun
1316 1.6 itojun sndcmsgbuflen = CMSG_SPACE(sizeof(struct in6_pktinfo)) +
1317 1.6 itojun CMSG_SPACE(sizeof(int));
1318 1.6 itojun sndcmsgbuf = (u_char *)malloc(sndcmsgbuflen);
1319 1.6 itojun if (sndcmsgbuf == NULL) {
1320 1.6 itojun syslog(LOG_ERR, "<%s> not enough core", __FUNCTION__);
1321 1.6 itojun exit(1);
1322 1.6 itojun }
1323 1.1 itojun
1324 1.1 itojun if ((sock = socket(AF_INET6, SOCK_RAW, IPPROTO_ICMPV6)) < 0) {
1325 1.1 itojun syslog(LOG_ERR, "<%s> socket: %s", __FUNCTION__,
1326 1.1 itojun strerror(errno));
1327 1.1 itojun exit(1);
1328 1.1 itojun }
1329 1.1 itojun
1330 1.1 itojun /* specify to tell receiving interface */
1331 1.1 itojun on = 1;
1332 1.5 itojun #ifdef IPV6_RECVPKTINFO
1333 1.5 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_RECVPKTINFO, &on,
1334 1.5 itojun sizeof(on)) < 0) {
1335 1.5 itojun syslog(LOG_ERR, "<%s> IPV6_RECVPKTINFO: %s",
1336 1.5 itojun __FUNCTION__, strerror(errno));
1337 1.5 itojun exit(1);
1338 1.5 itojun }
1339 1.5 itojun #else /* old adv. API */
1340 1.1 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_PKTINFO, &on,
1341 1.1 itojun sizeof(on)) < 0) {
1342 1.1 itojun syslog(LOG_ERR, "<%s> IPV6_PKTINFO: %s",
1343 1.1 itojun __FUNCTION__, strerror(errno));
1344 1.1 itojun exit(1);
1345 1.1 itojun }
1346 1.5 itojun #endif
1347 1.1 itojun
1348 1.1 itojun on = 1;
1349 1.1 itojun /* specify to tell value of hoplimit field of received IP6 hdr */
1350 1.5 itojun #ifdef IPV6_RECVHOPLIMIT
1351 1.5 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_RECVHOPLIMIT, &on,
1352 1.5 itojun sizeof(on)) < 0) {
1353 1.5 itojun syslog(LOG_ERR, "<%s> IPV6_RECVHOPLIMIT: %s",
1354 1.5 itojun __FUNCTION__, strerror(errno));
1355 1.5 itojun exit(1);
1356 1.5 itojun }
1357 1.5 itojun #else /* old adv. API */
1358 1.1 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_HOPLIMIT, &on,
1359 1.1 itojun sizeof(on)) < 0) {
1360 1.1 itojun syslog(LOG_ERR, "<%s> IPV6_HOPLIMIT: %s",
1361 1.1 itojun __FUNCTION__, strerror(errno));
1362 1.1 itojun exit(1);
1363 1.1 itojun }
1364 1.11 itojun #endif
1365 1.1 itojun
1366 1.1 itojun ICMP6_FILTER_SETBLOCKALL(&filt);
1367 1.1 itojun ICMP6_FILTER_SETPASS(ND_ROUTER_SOLICIT, &filt);
1368 1.1 itojun ICMP6_FILTER_SETPASS(ND_ROUTER_ADVERT, &filt);
1369 1.1 itojun if (accept_rr)
1370 1.1 itojun ICMP6_FILTER_SETPASS(ICMP6_ROUTER_RENUMBERING, &filt);
1371 1.1 itojun if (setsockopt(sock, IPPROTO_ICMPV6, ICMP6_FILTER, &filt,
1372 1.1 itojun sizeof(filt)) < 0) {
1373 1.1 itojun syslog(LOG_ERR, "<%s> IICMP6_FILTER: %s",
1374 1.1 itojun __FUNCTION__, strerror(errno));
1375 1.1 itojun exit(1);
1376 1.1 itojun }
1377 1.1 itojun
1378 1.1 itojun /*
1379 1.1 itojun * join all routers multicast address on each advertising interface.
1380 1.1 itojun */
1381 1.11 itojun if (inet_pton(AF_INET6, ALLROUTERS_LINK,
1382 1.11 itojun &mreq.ipv6mr_multiaddr.s6_addr)
1383 1.1 itojun != 1) {
1384 1.1 itojun syslog(LOG_ERR, "<%s> inet_pton failed(library bug?)",
1385 1.1 itojun __FUNCTION__);
1386 1.1 itojun exit(1);
1387 1.1 itojun }
1388 1.1 itojun while(ra) {
1389 1.1 itojun mreq.ipv6mr_interface = ra->ifindex;
1390 1.11 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_JOIN_GROUP, &mreq,
1391 1.1 itojun sizeof(mreq)) < 0) {
1392 1.11 itojun syslog(LOG_ERR, "<%s> IPV6_JOIN_GROUP(link) on %s: %s",
1393 1.1 itojun __FUNCTION__, ra->ifname, strerror(errno));
1394 1.1 itojun exit(1);
1395 1.1 itojun }
1396 1.1 itojun ra = ra->next;
1397 1.1 itojun }
1398 1.11 itojun
1399 1.11 itojun /*
1400 1.11 itojun * When attending router renumbering, join all-routers site-local
1401 1.11 itojun * multicast group.
1402 1.11 itojun */
1403 1.11 itojun if (accept_rr) {
1404 1.11 itojun if (inet_pton(AF_INET6, ALLROUTERS_SITE,
1405 1.11 itojun &in6a_site_allrouters) != 1) {
1406 1.11 itojun syslog(LOG_ERR, "<%s> inet_pton failed(library bug?)",
1407 1.11 itojun __FUNCTION__);
1408 1.11 itojun exit(1);
1409 1.11 itojun }
1410 1.11 itojun mreq.ipv6mr_multiaddr = in6a_site_allrouters;
1411 1.11 itojun if (mcastif) {
1412 1.11 itojun if ((mreq.ipv6mr_interface = if_nametoindex(mcastif))
1413 1.11 itojun == 0) {
1414 1.11 itojun syslog(LOG_ERR,
1415 1.11 itojun "<%s> invalid interface: %s",
1416 1.11 itojun __FUNCTION__, mcastif);
1417 1.11 itojun exit(1);
1418 1.11 itojun }
1419 1.11 itojun } else
1420 1.11 itojun mreq.ipv6mr_interface = ralist->ifindex;
1421 1.11 itojun if (setsockopt(sock, IPPROTO_IPV6, IPV6_JOIN_GROUP,
1422 1.11 itojun &mreq, sizeof(mreq)) < 0) {
1423 1.11 itojun syslog(LOG_ERR,
1424 1.11 itojun "<%s> IPV6_JOIN_GROUP(site) on %s: %s",
1425 1.11 itojun __FUNCTION__,
1426 1.11 itojun mcastif ? mcastif : ralist->ifname,
1427 1.11 itojun strerror(errno));
1428 1.11 itojun exit(1);
1429 1.11 itojun }
1430 1.11 itojun }
1431 1.1 itojun
1432 1.1 itojun /* initialize msghdr for receiving packets */
1433 1.1 itojun rcviov[0].iov_base = (caddr_t)answer;
1434 1.1 itojun rcviov[0].iov_len = sizeof(answer);
1435 1.1 itojun rcvmhdr.msg_name = (caddr_t)&from;
1436 1.1 itojun rcvmhdr.msg_namelen = sizeof(from);
1437 1.1 itojun rcvmhdr.msg_iov = rcviov;
1438 1.1 itojun rcvmhdr.msg_iovlen = 1;
1439 1.1 itojun rcvmhdr.msg_control = (caddr_t) rcvcmsgbuf;
1440 1.6 itojun rcvmhdr.msg_controllen = rcvcmsgbuflen;
1441 1.1 itojun
1442 1.1 itojun /* initialize msghdr for sending packets */
1443 1.1 itojun sndmhdr.msg_namelen = sizeof(struct sockaddr_in6);
1444 1.1 itojun sndmhdr.msg_iov = sndiov;
1445 1.1 itojun sndmhdr.msg_iovlen = 1;
1446 1.1 itojun sndmhdr.msg_control = (caddr_t)sndcmsgbuf;
1447 1.6 itojun sndmhdr.msg_controllen = sndcmsgbuflen;
1448 1.1 itojun
1449 1.1 itojun return;
1450 1.1 itojun }
1451 1.1 itojun
1452 1.1 itojun /* open a routing socket to watch the routing table */
1453 1.1 itojun static void
1454 1.1 itojun rtsock_open()
1455 1.1 itojun {
1456 1.1 itojun if ((rtsock = socket(PF_ROUTE, SOCK_RAW, 0)) < 0) {
1457 1.1 itojun syslog(LOG_ERR,
1458 1.1 itojun "<%s> socket: %s", __FUNCTION__, strerror(errno));
1459 1.1 itojun exit(1);
1460 1.1 itojun }
1461 1.1 itojun }
1462 1.1 itojun
1463 1.11 itojun struct rainfo *
1464 1.1 itojun if_indextorainfo(int index)
1465 1.1 itojun {
1466 1.1 itojun struct rainfo *rai = ralist;
1467 1.1 itojun
1468 1.1 itojun for (rai = ralist; rai; rai = rai->next) {
1469 1.1 itojun if (rai->ifindex == index)
1470 1.1 itojun return(rai);
1471 1.1 itojun }
1472 1.1 itojun
1473 1.1 itojun return(NULL); /* search failed */
1474 1.1 itojun }
1475 1.1 itojun
1476 1.1 itojun static void
1477 1.1 itojun ra_output(rainfo)
1478 1.1 itojun struct rainfo *rainfo;
1479 1.1 itojun {
1480 1.1 itojun int i;
1481 1.1 itojun struct cmsghdr *cm;
1482 1.1 itojun struct in6_pktinfo *pi;
1483 1.10 itojun struct soliciter *sol, *nextsol;
1484 1.10 itojun
1485 1.10 itojun if ((iflist[rainfo->ifindex]->ifm_flags & IFF_UP) == 0) {
1486 1.10 itojun syslog(LOG_DEBUG, "<%s> %s is not up, skip sending RA",
1487 1.10 itojun __FUNCTION__, rainfo->ifname);
1488 1.10 itojun return;
1489 1.10 itojun }
1490 1.1 itojun
1491 1.11 itojun make_packet(rainfo); /* XXX: inefficient */
1492 1.11 itojun
1493 1.1 itojun sndmhdr.msg_name = (caddr_t)&sin6_allnodes;
1494 1.1 itojun sndmhdr.msg_iov[0].iov_base = (caddr_t)rainfo->ra_data;
1495 1.1 itojun sndmhdr.msg_iov[0].iov_len = rainfo->ra_datalen;
1496 1.1 itojun
1497 1.1 itojun cm = CMSG_FIRSTHDR(&sndmhdr);
1498 1.1 itojun /* specify the outgoing interface */
1499 1.1 itojun cm->cmsg_level = IPPROTO_IPV6;
1500 1.1 itojun cm->cmsg_type = IPV6_PKTINFO;
1501 1.1 itojun cm->cmsg_len = CMSG_LEN(sizeof(struct in6_pktinfo));
1502 1.1 itojun pi = (struct in6_pktinfo *)CMSG_DATA(cm);
1503 1.1 itojun memset(&pi->ipi6_addr, 0, sizeof(pi->ipi6_addr)); /*XXX*/
1504 1.1 itojun pi->ipi6_ifindex = rainfo->ifindex;
1505 1.1 itojun
1506 1.1 itojun /* specify the hop limit of the packet */
1507 1.1 itojun {
1508 1.1 itojun int hoplimit = 255;
1509 1.1 itojun
1510 1.1 itojun cm = CMSG_NXTHDR(&sndmhdr, cm);
1511 1.1 itojun cm->cmsg_level = IPPROTO_IPV6;
1512 1.1 itojun cm->cmsg_type = IPV6_HOPLIMIT;
1513 1.1 itojun cm->cmsg_len = CMSG_LEN(sizeof(int));
1514 1.1 itojun memcpy(CMSG_DATA(cm), &hoplimit, sizeof(int));
1515 1.1 itojun }
1516 1.1 itojun
1517 1.1 itojun syslog(LOG_DEBUG,
1518 1.1 itojun "<%s> send RA on %s, # of waitings = %d",
1519 1.1 itojun __FUNCTION__, rainfo->ifname, rainfo->waiting);
1520 1.1 itojun
1521 1.1 itojun i = sendmsg(sock, &sndmhdr, 0);
1522 1.1 itojun
1523 1.1 itojun if (i < 0 || i != rainfo->ra_datalen) {
1524 1.1 itojun if (i < 0) {
1525 1.4 itojun syslog(LOG_ERR, "<%s> sendmsg on %s: %s",
1526 1.4 itojun __FUNCTION__, rainfo->ifname,
1527 1.4 itojun strerror(errno));
1528 1.1 itojun }
1529 1.1 itojun }
1530 1.1 itojun
1531 1.10 itojun /*
1532 1.10 itojun * unicast advertisements
1533 1.10 itojun * XXX commented out. reason: though spec does not forbit it, unicast
1534 1.10 itojun * advert does not really help
1535 1.10 itojun */
1536 1.10 itojun for (sol = rainfo->soliciter; sol; sol = nextsol) {
1537 1.10 itojun nextsol = sol->next;
1538 1.10 itojun
1539 1.10 itojun #if 0
1540 1.10 itojun sndmhdr.msg_name = (caddr_t)&sol->addr;
1541 1.10 itojun i = sendmsg(sock, &sndmhdr, 0);
1542 1.10 itojun if (i < 0 || i != rainfo->ra_datalen) {
1543 1.10 itojun if (i < 0) {
1544 1.10 itojun syslog(LOG_ERR,
1545 1.10 itojun "<%s> unicast sendmsg on %s: %s",
1546 1.10 itojun __FUNCTION__, rainfo->ifname,
1547 1.10 itojun strerror(errno));
1548 1.10 itojun }
1549 1.10 itojun }
1550 1.10 itojun #endif
1551 1.10 itojun
1552 1.10 itojun sol->next = NULL;
1553 1.10 itojun free(sol);
1554 1.10 itojun }
1555 1.10 itojun rainfo->soliciter = NULL;
1556 1.10 itojun
1557 1.1 itojun /* update counter */
1558 1.1 itojun if (rainfo->initcounter < MAX_INITIAL_RTR_ADVERTISEMENTS)
1559 1.1 itojun rainfo->initcounter++;
1560 1.9 itojun rainfo->raoutput++;
1561 1.1 itojun
1562 1.1 itojun /* update timestamp */
1563 1.1 itojun gettimeofday(&rainfo->lastsent, NULL);
1564 1.1 itojun
1565 1.1 itojun /* reset waiting conter */
1566 1.1 itojun rainfo->waiting = 0;
1567 1.1 itojun }
1568 1.1 itojun
1569 1.1 itojun /* process RA timer */
1570 1.1 itojun void
1571 1.1 itojun ra_timeout(void *data)
1572 1.1 itojun {
1573 1.1 itojun struct rainfo *rai = (struct rainfo *)data;
1574 1.1 itojun
1575 1.1 itojun #ifdef notyet
1576 1.1 itojun /* if necessary, reconstruct the packet. */
1577 1.1 itojun #endif
1578 1.1 itojun
1579 1.1 itojun syslog(LOG_DEBUG,
1580 1.1 itojun "<%s> RA timer on %s is expired",
1581 1.1 itojun __FUNCTION__, rai->ifname);
1582 1.1 itojun
1583 1.10 itojun ra_output(rai);
1584 1.1 itojun }
1585 1.1 itojun
1586 1.1 itojun /* update RA timer */
1587 1.1 itojun void
1588 1.1 itojun ra_timer_update(void *data, struct timeval *tm)
1589 1.1 itojun {
1590 1.1 itojun struct rainfo *rai = (struct rainfo *)data;
1591 1.1 itojun long interval;
1592 1.1 itojun
1593 1.1 itojun /*
1594 1.1 itojun * Whenever a multicast advertisement is sent from an interface,
1595 1.1 itojun * the timer is reset to a uniformly-distributed random value
1596 1.1 itojun * between the interface's configured MinRtrAdvInterval and
1597 1.11 itojun * MaxRtrAdvInterval (RFC2461 6.2.4).
1598 1.1 itojun */
1599 1.1 itojun interval = rai->mininterval;
1600 1.1 itojun interval += random() % (rai->maxinterval - rai->mininterval);
1601 1.1 itojun
1602 1.1 itojun /*
1603 1.1 itojun * For the first few advertisements (up to
1604 1.1 itojun * MAX_INITIAL_RTR_ADVERTISEMENTS), if the randomly chosen interval
1605 1.1 itojun * is greater than MAX_INITIAL_RTR_ADVERT_INTERVAL, the timer
1606 1.1 itojun * SHOULD be set to MAX_INITIAL_RTR_ADVERT_INTERVAL instead.
1607 1.1 itojun * (RFC-2461 6.2.4)
1608 1.1 itojun */
1609 1.1 itojun if (rai->initcounter < MAX_INITIAL_RTR_ADVERTISEMENTS &&
1610 1.1 itojun interval > MAX_INITIAL_RTR_ADVERT_INTERVAL)
1611 1.1 itojun interval = MAX_INITIAL_RTR_ADVERT_INTERVAL;
1612 1.1 itojun
1613 1.1 itojun tm->tv_sec = interval;
1614 1.1 itojun tm->tv_usec = 0;
1615 1.1 itojun
1616 1.1 itojun syslog(LOG_DEBUG,
1617 1.1 itojun "<%s> RA timer on %s is set to %ld:%ld",
1618 1.8 kleink __FUNCTION__, rai->ifname,
1619 1.8 kleink (long int)tm->tv_sec, (long int)tm->tv_usec);
1620 1.1 itojun
1621 1.1 itojun return;
1622 1.1 itojun }
1623