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