Home | History | Annotate | Line # | Download | only in rtadvd
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