Home | History | Annotate | Line # | Download | only in net
route.c revision 1.122
      1  1.122    kefren /*	$NetBSD: route.c,v 1.122 2010/05/02 19:17:56 kefren Exp $	*/
      2   1.18       kml 
      3   1.18       kml /*-
      4  1.106        ad  * Copyright (c) 1998, 2008 The NetBSD Foundation, Inc.
      5   1.18       kml  * All rights reserved.
      6   1.18       kml  *
      7   1.18       kml  * This code is derived from software contributed to The NetBSD Foundation
      8   1.18       kml  * by Kevin M. Lahey of the Numerical Aerospace Simulation Facility,
      9   1.18       kml  * NASA Ames Research Center.
     10   1.18       kml  *
     11   1.18       kml  * Redistribution and use in source and binary forms, with or without
     12   1.18       kml  * modification, are permitted provided that the following conditions
     13   1.18       kml  * are met:
     14   1.18       kml  * 1. Redistributions of source code must retain the above copyright
     15   1.18       kml  *    notice, this list of conditions and the following disclaimer.
     16   1.18       kml  * 2. Redistributions in binary form must reproduce the above copyright
     17   1.18       kml  *    notice, this list of conditions and the following disclaimer in the
     18   1.18       kml  *    documentation and/or other materials provided with the distribution.
     19   1.18       kml  *
     20   1.18       kml  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21   1.18       kml  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22   1.18       kml  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23   1.18       kml  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24   1.18       kml  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25   1.18       kml  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26   1.18       kml  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27   1.18       kml  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28   1.18       kml  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29   1.18       kml  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30   1.18       kml  * POSSIBILITY OF SUCH DAMAGE.
     31   1.18       kml  */
     32   1.11       cgd 
     33    1.1       cgd /*
     34   1.25    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
     35   1.25    itojun  * All rights reserved.
     36   1.65     perry  *
     37   1.25    itojun  * Redistribution and use in source and binary forms, with or without
     38   1.25    itojun  * modification, are permitted provided that the following conditions
     39   1.25    itojun  * are met:
     40   1.25    itojun  * 1. Redistributions of source code must retain the above copyright
     41   1.25    itojun  *    notice, this list of conditions and the following disclaimer.
     42   1.25    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     43   1.25    itojun  *    notice, this list of conditions and the following disclaimer in the
     44   1.25    itojun  *    documentation and/or other materials provided with the distribution.
     45   1.25    itojun  * 3. Neither the name of the project nor the names of its contributors
     46   1.25    itojun  *    may be used to endorse or promote products derived from this software
     47   1.25    itojun  *    without specific prior written permission.
     48   1.65     perry  *
     49   1.25    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     50   1.25    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     51   1.25    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     52   1.25    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     53   1.25    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     54   1.25    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     55   1.25    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     56   1.25    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     57   1.25    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     58   1.25    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     59   1.25    itojun  * SUCH DAMAGE.
     60   1.25    itojun  */
     61   1.25    itojun 
     62   1.25    itojun /*
     63   1.10   mycroft  * Copyright (c) 1980, 1986, 1991, 1993
     64   1.10   mycroft  *	The Regents of the University of California.  All rights reserved.
     65    1.1       cgd  *
     66    1.1       cgd  * Redistribution and use in source and binary forms, with or without
     67    1.1       cgd  * modification, are permitted provided that the following conditions
     68    1.1       cgd  * are met:
     69    1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     70    1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     71    1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     72    1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     73    1.1       cgd  *    documentation and/or other materials provided with the distribution.
     74   1.58       agc  * 3. Neither the name of the University nor the names of its contributors
     75    1.1       cgd  *    may be used to endorse or promote products derived from this software
     76    1.1       cgd  *    without specific prior written permission.
     77    1.1       cgd  *
     78    1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     79    1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     80    1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     81    1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     82    1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     83    1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     84    1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     85    1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     86    1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     87    1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     88    1.1       cgd  * SUCH DAMAGE.
     89    1.1       cgd  *
     90   1.17  christos  *	@(#)route.c	8.3 (Berkeley) 1/9/95
     91    1.1       cgd  */
     92   1.50     lukem 
     93   1.90    dyoung #include "opt_route.h"
     94   1.90    dyoung 
     95   1.50     lukem #include <sys/cdefs.h>
     96  1.122    kefren __KERNEL_RCSID(0, "$NetBSD: route.c,v 1.122 2010/05/02 19:17:56 kefren Exp $");
     97    1.2       cgd 
     98    1.5   mycroft #include <sys/param.h>
     99   1.90    dyoung #include <sys/sysctl.h>
    100    1.5   mycroft #include <sys/systm.h>
    101   1.35   thorpej #include <sys/callout.h>
    102    1.5   mycroft #include <sys/proc.h>
    103    1.5   mycroft #include <sys/mbuf.h>
    104    1.5   mycroft #include <sys/socket.h>
    105    1.5   mycroft #include <sys/socketvar.h>
    106    1.5   mycroft #include <sys/domain.h>
    107    1.5   mycroft #include <sys/protosw.h>
    108   1.18       kml #include <sys/kernel.h>
    109    1.5   mycroft #include <sys/ioctl.h>
    110   1.22   thorpej #include <sys/pool.h>
    111  1.119      elad #include <sys/kauth.h>
    112    1.1       cgd 
    113    1.5   mycroft #include <net/if.h>
    114  1.114    dyoung #include <net/if_dl.h>
    115    1.5   mycroft #include <net/route.h>
    116    1.5   mycroft #include <net/raw_cb.h>
    117    1.1       cgd 
    118    1.5   mycroft #include <netinet/in.h>
    119    1.5   mycroft #include <netinet/in_var.h>
    120    1.1       cgd 
    121   1.90    dyoung #ifdef RTFLUSH_DEBUG
    122   1.90    dyoung #define	rtcache_debug() __predict_false(_rtcache_debug)
    123   1.90    dyoung #else /* RTFLUSH_DEBUG */
    124   1.90    dyoung #define	rtcache_debug() 0
    125   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    126    1.5   mycroft 
    127   1.52      matt struct	route_cb route_cb;
    128   1.52      matt struct	rtstat	rtstat;
    129   1.52      matt struct	radix_node_head *rt_tables[AF_MAX+1];
    130    1.1       cgd 
    131    1.1       cgd int	rttrash;		/* routes not in table but not freed */
    132    1.1       cgd 
    133  1.113     pooka struct pool rtentry_pool;
    134  1.113     pooka struct pool rttimer_pool;
    135   1.22   thorpej 
    136   1.35   thorpej struct callout rt_timer_ch; /* callout for rt_timer_timer() */
    137   1.35   thorpej 
    138   1.90    dyoung #ifdef RTFLUSH_DEBUG
    139   1.90    dyoung static int _rtcache_debug = 0;
    140   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    141   1.90    dyoung 
    142  1.119      elad static kauth_listener_t route_listener;
    143  1.119      elad 
    144   1.60      matt static int rtdeletemsg(struct rtentry *);
    145   1.92    dyoung static int rtflushclone1(struct rtentry *, void *);
    146   1.92    dyoung static void rtflushclone(sa_family_t family, struct rtentry *);
    147   1.40    itojun 
    148   1.90    dyoung #ifdef RTFLUSH_DEBUG
    149  1.118     pooka static void sysctl_net_rtcache_setup(struct sysctllog **);
    150  1.118     pooka static void
    151  1.118     pooka sysctl_net_rtcache_setup(struct sysctllog **clog)
    152   1.90    dyoung {
    153   1.90    dyoung 	const struct sysctlnode *rnode;
    154   1.90    dyoung 
    155   1.90    dyoung 	/* XXX do not duplicate */
    156   1.90    dyoung 	if (sysctl_createv(clog, 0, NULL, &rnode, CTLFLAG_PERMANENT,
    157   1.90    dyoung 	    CTLTYPE_NODE, "net", NULL, NULL, 0, NULL, 0, CTL_NET, CTL_EOL) != 0)
    158   1.90    dyoung 		return;
    159   1.90    dyoung 	if (sysctl_createv(clog, 0, &rnode, &rnode, CTLFLAG_PERMANENT,
    160   1.90    dyoung 	    CTLTYPE_NODE,
    161   1.90    dyoung 	    "rtcache", SYSCTL_DESCR("Route cache related settings"),
    162   1.90    dyoung 	    NULL, 0, NULL, 0, CTL_CREATE, CTL_EOL) != 0)
    163   1.90    dyoung 		return;
    164   1.90    dyoung 	if (sysctl_createv(clog, 0, &rnode, &rnode,
    165   1.90    dyoung 	    CTLFLAG_PERMANENT|CTLFLAG_READWRITE, CTLTYPE_INT,
    166   1.90    dyoung 	    "debug", SYSCTL_DESCR("Debug route caches"),
    167   1.90    dyoung 	    NULL, 0, &_rtcache_debug, 0, CTL_CREATE, CTL_EOL) != 0)
    168   1.90    dyoung 		return;
    169   1.90    dyoung }
    170   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    171   1.90    dyoung 
    172   1.81     joerg struct ifaddr *
    173   1.81     joerg rt_get_ifa(struct rtentry *rt)
    174   1.81     joerg {
    175   1.81     joerg 	struct ifaddr *ifa;
    176   1.81     joerg 
    177   1.81     joerg 	if ((ifa = rt->rt_ifa) == NULL)
    178   1.81     joerg 		return ifa;
    179   1.81     joerg 	else if (ifa->ifa_getifa == NULL)
    180   1.81     joerg 		return ifa;
    181   1.81     joerg #if 0
    182   1.81     joerg 	else if (ifa->ifa_seqno != NULL && *ifa->ifa_seqno == rt->rt_ifa_seqno)
    183   1.81     joerg 		return ifa;
    184   1.81     joerg #endif
    185   1.81     joerg 	else {
    186   1.94    dyoung 		ifa = (*ifa->ifa_getifa)(ifa, rt_getkey(rt));
    187   1.81     joerg 		rt_replace_ifa(rt, ifa);
    188   1.81     joerg 		return ifa;
    189   1.81     joerg 	}
    190   1.81     joerg }
    191   1.81     joerg 
    192   1.80     joerg static void
    193   1.80     joerg rt_set_ifa1(struct rtentry *rt, struct ifaddr *ifa)
    194   1.80     joerg {
    195   1.80     joerg 	rt->rt_ifa = ifa;
    196   1.80     joerg 	if (ifa->ifa_seqno != NULL)
    197   1.80     joerg 		rt->rt_ifa_seqno = *ifa->ifa_seqno;
    198   1.80     joerg }
    199   1.80     joerg 
    200  1.116       roy /*
    201  1.116       roy  * Is this route the connected route for the ifa?
    202  1.116       roy  */
    203  1.116       roy static int
    204  1.116       roy rt_ifa_connected(const struct rtentry *rt, const struct ifaddr *ifa)
    205  1.116       roy {
    206  1.116       roy 	const struct sockaddr *key, *dst, *odst;
    207  1.116       roy 	struct sockaddr_storage maskeddst;
    208  1.116       roy 
    209  1.116       roy 	key = rt_getkey(rt);
    210  1.116       roy 	dst = rt->rt_flags & RTF_HOST ? ifa->ifa_dstaddr : ifa->ifa_addr;
    211  1.116       roy 	if (dst == NULL ||
    212  1.116       roy 	    dst->sa_family != key->sa_family ||
    213  1.116       roy 	    dst->sa_len != key->sa_len)
    214  1.116       roy 		return 0;
    215  1.116       roy 	if ((rt->rt_flags & RTF_HOST) == 0 && ifa->ifa_netmask) {
    216  1.116       roy 		odst = dst;
    217  1.116       roy 		dst = (struct sockaddr *)&maskeddst;
    218  1.116       roy 		rt_maskedcopy(odst, (struct sockaddr *)&maskeddst,
    219  1.116       roy 		    ifa->ifa_netmask);
    220  1.116       roy 	}
    221  1.116       roy 	return (memcmp(dst, key, dst->sa_len) == 0);
    222  1.116       roy }
    223  1.116       roy 
    224   1.80     joerg void
    225   1.80     joerg rt_replace_ifa(struct rtentry *rt, struct ifaddr *ifa)
    226   1.80     joerg {
    227  1.116       roy 	if (rt->rt_ifa &&
    228  1.116       roy 	    rt->rt_ifa != ifa &&
    229  1.116       roy 	    rt->rt_ifa->ifa_flags & IFA_ROUTE &&
    230  1.116       roy 	    rt_ifa_connected(rt, rt->rt_ifa))
    231  1.116       roy 	{
    232  1.116       roy 		RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
    233  1.116       roy 		    "replace deleted IFA_ROUTE\n",
    234  1.116       roy 		    (void *)rt->_rt_key, (void *)rt->rt_ifa);
    235  1.116       roy 		rt->rt_ifa->ifa_flags &= ~IFA_ROUTE;
    236  1.116       roy 		if (rt_ifa_connected(rt, ifa)) {
    237  1.116       roy 			RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
    238  1.116       roy 			    "replace added IFA_ROUTE\n",
    239  1.116       roy 			    (void *)rt->_rt_key, (void *)ifa);
    240  1.116       roy 			ifa->ifa_flags |= IFA_ROUTE;
    241  1.116       roy 		}
    242  1.116       roy 	}
    243  1.116       roy 
    244   1.80     joerg 	IFAREF(ifa);
    245   1.80     joerg 	IFAFREE(rt->rt_ifa);
    246   1.80     joerg 	rt_set_ifa1(rt, ifa);
    247   1.80     joerg }
    248   1.80     joerg 
    249   1.80     joerg static void
    250   1.80     joerg rt_set_ifa(struct rtentry *rt, struct ifaddr *ifa)
    251   1.80     joerg {
    252   1.80     joerg 	IFAREF(ifa);
    253   1.80     joerg 	rt_set_ifa1(rt, ifa);
    254   1.80     joerg }
    255   1.80     joerg 
    256   1.10   mycroft void
    257   1.60      matt rtable_init(void **table)
    258   1.10   mycroft {
    259   1.10   mycroft 	struct domain *dom;
    260   1.64      matt 	DOMAIN_FOREACH(dom)
    261   1.10   mycroft 		if (dom->dom_rtattach)
    262   1.10   mycroft 			dom->dom_rtattach(&table[dom->dom_family],
    263   1.10   mycroft 			    dom->dom_rtoffset);
    264   1.10   mycroft }
    265    1.1       cgd 
    266  1.119      elad static int
    267  1.119      elad route_listener_cb(kauth_cred_t cred, kauth_action_t action, void *cookie,
    268  1.119      elad     void *arg0, void *arg1, void *arg2, void *arg3)
    269  1.119      elad {
    270  1.119      elad 	struct rt_msghdr *rtm;
    271  1.119      elad 	int result;
    272  1.119      elad 
    273  1.119      elad 	result = KAUTH_RESULT_DEFER;
    274  1.119      elad 	rtm = arg1;
    275  1.119      elad 
    276  1.120      elad 	if (action != KAUTH_NETWORK_ROUTE)
    277  1.120      elad 		return result;
    278  1.120      elad 
    279  1.119      elad 	if (rtm->rtm_type == RTM_GET)
    280  1.119      elad 		result = KAUTH_RESULT_ALLOW;
    281  1.119      elad 
    282  1.119      elad 	return result;
    283  1.119      elad }
    284  1.119      elad 
    285    1.9   mycroft void
    286   1.60      matt route_init(void)
    287    1.1       cgd {
    288   1.22   thorpej 
    289  1.118     pooka #ifdef RTFLUSH_DEBUG
    290  1.118     pooka 	sysctl_net_rtcache_setup(NULL);
    291  1.118     pooka #endif
    292  1.118     pooka 
    293  1.113     pooka 	pool_init(&rtentry_pool, sizeof(struct rtentry), 0, 0, 0, "rtentpl",
    294  1.113     pooka 	    NULL, IPL_SOFTNET);
    295  1.113     pooka 	pool_init(&rttimer_pool, sizeof(struct rttimer), 0, 0, 0, "rttmrpl",
    296  1.113     pooka 	    NULL, IPL_SOFTNET);
    297  1.113     pooka 
    298  1.106        ad 	rt_init();
    299   1.10   mycroft 	rn_init();	/* initialize all zeroes, all ones, mask table */
    300   1.10   mycroft 	rtable_init((void **)rt_tables);
    301  1.119      elad 
    302  1.119      elad 	route_listener = kauth_listen_scope(KAUTH_SCOPE_NETWORK,
    303  1.119      elad 	    route_listener_cb, NULL);
    304    1.1       cgd }
    305    1.1       cgd 
    306   1.82    dyoung void
    307   1.82    dyoung rtflushall(int family)
    308   1.82    dyoung {
    309   1.90    dyoung 	struct domain *dom;
    310   1.90    dyoung 
    311   1.90    dyoung 	if (rtcache_debug())
    312   1.90    dyoung 		printf("%s: enter\n", __func__);
    313   1.90    dyoung 
    314   1.90    dyoung 	if ((dom = pffinddomain(family)) == NULL)
    315   1.90    dyoung 		return;
    316   1.82    dyoung 
    317  1.105    dyoung 	rtcache_invalidate(&dom->dom_rtcache);
    318   1.82    dyoung }
    319   1.82    dyoung 
    320   1.82    dyoung void
    321   1.82    dyoung rtcache(struct route *ro)
    322   1.82    dyoung {
    323   1.90    dyoung 	struct domain *dom;
    324   1.82    dyoung 
    325  1.114    dyoung 	rtcache_invariants(ro);
    326   1.99    dyoung 	KASSERT(ro->_ro_rt != NULL);
    327  1.105    dyoung 	KASSERT(ro->ro_invalid == false);
    328   1.90    dyoung 	KASSERT(rtcache_getdst(ro) != NULL);
    329   1.82    dyoung 
    330   1.90    dyoung 	if ((dom = pffinddomain(rtcache_getdst(ro)->sa_family)) == NULL)
    331   1.90    dyoung 		return;
    332   1.90    dyoung 
    333   1.90    dyoung 	LIST_INSERT_HEAD(&dom->dom_rtcache, ro, ro_rtcache_next);
    334  1.114    dyoung 	rtcache_invariants(ro);
    335   1.82    dyoung }
    336   1.82    dyoung 
    337    1.1       cgd /*
    338    1.1       cgd  * Packet routing routines.
    339    1.1       cgd  */
    340    1.1       cgd struct rtentry *
    341   1.60      matt rtalloc1(const struct sockaddr *dst, int report)
    342    1.1       cgd {
    343   1.36  augustss 	struct radix_node_head *rnh = rt_tables[dst->sa_family];
    344   1.36  augustss 	struct rtentry *rt;
    345   1.36  augustss 	struct radix_node *rn;
    346   1.68  christos 	struct rtentry *newrt = NULL;
    347   1.10   mycroft 	struct rt_addrinfo info;
    348   1.13   mycroft 	int  s = splsoftnet(), err = 0, msgtype = RTM_MISS;
    349    1.1       cgd 
    350   1.66  christos 	if (rnh && (rn = rnh->rnh_matchaddr(dst, rnh)) &&
    351    1.1       cgd 	    ((rn->rn_flags & RNF_ROOT) == 0)) {
    352    1.1       cgd 		newrt = rt = (struct rtentry *)rn;
    353    1.1       cgd 		if (report && (rt->rt_flags & RTF_CLONING)) {
    354   1.68  christos 			err = rtrequest(RTM_RESOLVE, dst, NULL, NULL, 0,
    355   1.68  christos 			    &newrt);
    356    1.8       cgd 			if (err) {
    357    1.8       cgd 				newrt = rt;
    358    1.8       cgd 				rt->rt_refcnt++;
    359    1.8       cgd 				goto miss;
    360    1.8       cgd 			}
    361   1.69  christos 			KASSERT(newrt != NULL);
    362    1.8       cgd 			if ((rt = newrt) && (rt->rt_flags & RTF_XRESOLVE)) {
    363    1.8       cgd 				msgtype = RTM_RESOLVE;
    364    1.8       cgd 				goto miss;
    365    1.8       cgd 			}
    366   1.39    itojun 			/* Inform listeners of the new route */
    367   1.44   thorpej 			memset(&info, 0, sizeof(info));
    368   1.94    dyoung 			info.rti_info[RTAX_DST] = rt_getkey(rt);
    369   1.39    itojun 			info.rti_info[RTAX_NETMASK] = rt_mask(rt);
    370   1.39    itojun 			info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
    371   1.39    itojun 			if (rt->rt_ifp != NULL) {
    372   1.65     perry 				info.rti_info[RTAX_IFP] =
    373   1.99    dyoung 				    rt->rt_ifp->if_dl->ifa_addr;
    374   1.39    itojun 				info.rti_info[RTAX_IFA] = rt->rt_ifa->ifa_addr;
    375   1.39    itojun 			}
    376   1.39    itojun 			rt_missmsg(RTM_ADD, &info, rt->rt_flags, 0);
    377    1.1       cgd 		} else
    378    1.1       cgd 			rt->rt_refcnt++;
    379    1.1       cgd 	} else {
    380    1.1       cgd 		rtstat.rts_unreach++;
    381   1.10   mycroft 	miss:	if (report) {
    382   1.87  christos 			memset((void *)&info, 0, sizeof(info));
    383   1.10   mycroft 			info.rti_info[RTAX_DST] = dst;
    384   1.10   mycroft 			rt_missmsg(msgtype, &info, 0, err);
    385   1.10   mycroft 		}
    386    1.1       cgd 	}
    387    1.1       cgd 	splx(s);
    388   1.95    dyoung 	return newrt;
    389    1.1       cgd }
    390    1.1       cgd 
    391    1.9   mycroft void
    392   1.60      matt rtfree(struct rtentry *rt)
    393    1.1       cgd {
    394   1.36  augustss 	struct ifaddr *ifa;
    395   1.10   mycroft 
    396   1.68  christos 	if (rt == NULL)
    397    1.1       cgd 		panic("rtfree");
    398    1.1       cgd 	rt->rt_refcnt--;
    399    1.1       cgd 	if (rt->rt_refcnt <= 0 && (rt->rt_flags & RTF_UP) == 0) {
    400    1.1       cgd 		if (rt->rt_nodes->rn_flags & (RNF_ACTIVE | RNF_ROOT))
    401    1.1       cgd 			panic ("rtfree 2");
    402   1.10   mycroft 		rttrash--;
    403   1.10   mycroft 		if (rt->rt_refcnt < 0) {
    404   1.16  christos 			printf("rtfree: %p not freed (neg refs)\n", rt);
    405   1.10   mycroft 			return;
    406   1.10   mycroft 		}
    407   1.54    itojun 		rt_timer_remove_all(rt, 0);
    408   1.10   mycroft 		ifa = rt->rt_ifa;
    409   1.78    dyoung 		rt->rt_ifa = NULL;
    410   1.10   mycroft 		IFAFREE(ifa);
    411   1.78    dyoung 		rt->rt_ifp = NULL;
    412   1.94    dyoung 		rt_destroy(rt);
    413   1.22   thorpej 		pool_put(&rtentry_pool, rt);
    414    1.1       cgd 	}
    415    1.1       cgd }
    416    1.1       cgd 
    417   1.10   mycroft void
    418   1.60      matt ifafree(struct ifaddr *ifa)
    419   1.10   mycroft {
    420   1.30   thorpej 
    421   1.30   thorpej #ifdef DIAGNOSTIC
    422   1.10   mycroft 	if (ifa == NULL)
    423   1.30   thorpej 		panic("ifafree: null ifa");
    424   1.30   thorpej 	if (ifa->ifa_refcnt != 0)
    425   1.30   thorpej 		panic("ifafree: ifa_refcnt != 0 (%d)", ifa->ifa_refcnt);
    426   1.30   thorpej #endif
    427   1.31   thorpej #ifdef IFAREF_DEBUG
    428   1.31   thorpej 	printf("ifafree: freeing ifaddr %p\n", ifa);
    429   1.31   thorpej #endif
    430   1.30   thorpej 	free(ifa, M_IFADDR);
    431   1.10   mycroft }
    432   1.10   mycroft 
    433    1.1       cgd /*
    434    1.1       cgd  * Force a routing table entry to the specified
    435    1.1       cgd  * destination to go through the given gateway.
    436    1.1       cgd  * Normally called as a result of a routing redirect
    437    1.1       cgd  * message from the network layer.
    438    1.1       cgd  *
    439   1.13   mycroft  * N.B.: must be called at splsoftnet
    440    1.1       cgd  */
    441   1.14  christos void
    442   1.60      matt rtredirect(const struct sockaddr *dst, const struct sockaddr *gateway,
    443   1.60      matt 	const struct sockaddr *netmask, int flags, const struct sockaddr *src,
    444   1.60      matt 	struct rtentry **rtp)
    445    1.1       cgd {
    446   1.36  augustss 	struct rtentry *rt;
    447    1.1       cgd 	int error = 0;
    448  1.121    dyoung 	uint64_t *stat = NULL;
    449   1.10   mycroft 	struct rt_addrinfo info;
    450   1.10   mycroft 	struct ifaddr *ifa;
    451    1.1       cgd 
    452    1.1       cgd 	/* verify the gateway is directly reachable */
    453   1.68  christos 	if ((ifa = ifa_ifwithnet(gateway)) == NULL) {
    454    1.1       cgd 		error = ENETUNREACH;
    455    1.8       cgd 		goto out;
    456    1.1       cgd 	}
    457    1.1       cgd 	rt = rtalloc1(dst, 0);
    458    1.1       cgd 	/*
    459    1.1       cgd 	 * If the redirect isn't from our current router for this dst,
    460    1.1       cgd 	 * it's either old or wrong.  If it redirects us to ourselves,
    461    1.1       cgd 	 * we have a routing loop, perhaps as a result of an interface
    462    1.1       cgd 	 * going down recently.
    463    1.1       cgd 	 */
    464   1.10   mycroft 	if (!(flags & RTF_DONE) && rt &&
    465  1.115      yamt 	     (sockaddr_cmp(src, rt->rt_gateway) != 0 || rt->rt_ifa != ifa))
    466    1.1       cgd 		error = EINVAL;
    467    1.1       cgd 	else if (ifa_ifwithaddr(gateway))
    468    1.1       cgd 		error = EHOSTUNREACH;
    469    1.1       cgd 	if (error)
    470    1.1       cgd 		goto done;
    471    1.1       cgd 	/*
    472    1.1       cgd 	 * Create a new entry if we just got back a wildcard entry
    473   1.33     soren 	 * or the lookup failed.  This is necessary for hosts
    474    1.1       cgd 	 * which use routing redirects generated by smart gateways
    475    1.1       cgd 	 * to dynamically build the routing tables.
    476    1.1       cgd 	 */
    477   1.95    dyoung 	if (rt == NULL || (rt_mask(rt) && rt_mask(rt)->sa_len < 2))
    478    1.1       cgd 		goto create;
    479    1.1       cgd 	/*
    480    1.1       cgd 	 * Don't listen to the redirect if it's
    481   1.65     perry 	 * for a route to an interface.
    482    1.1       cgd 	 */
    483    1.1       cgd 	if (rt->rt_flags & RTF_GATEWAY) {
    484    1.1       cgd 		if (((rt->rt_flags & RTF_HOST) == 0) && (flags & RTF_HOST)) {
    485    1.1       cgd 			/*
    486    1.1       cgd 			 * Changing from route to net => route to host.
    487    1.1       cgd 			 * Create new route, rather than smashing route to net.
    488    1.1       cgd 			 */
    489    1.1       cgd 		create:
    490   1.95    dyoung 			if (rt != NULL)
    491   1.39    itojun 				rtfree(rt);
    492    1.1       cgd 			flags |=  RTF_GATEWAY | RTF_DYNAMIC;
    493  1.122    kefren 			memset(&info, 0, sizeof(info));
    494   1.39    itojun 			info.rti_info[RTAX_DST] = dst;
    495   1.39    itojun 			info.rti_info[RTAX_GATEWAY] = gateway;
    496   1.39    itojun 			info.rti_info[RTAX_NETMASK] = netmask;
    497   1.39    itojun 			info.rti_ifa = ifa;
    498   1.39    itojun 			info.rti_flags = flags;
    499   1.39    itojun 			rt = NULL;
    500   1.39    itojun 			error = rtrequest1(RTM_ADD, &info, &rt);
    501   1.39    itojun 			if (rt != NULL)
    502   1.39    itojun 				flags = rt->rt_flags;
    503    1.1       cgd 			stat = &rtstat.rts_dynamic;
    504    1.1       cgd 		} else {
    505    1.1       cgd 			/*
    506    1.1       cgd 			 * Smash the current notion of the gateway to
    507    1.1       cgd 			 * this destination.  Should check about netmask!!!
    508    1.1       cgd 			 */
    509   1.10   mycroft 			rt->rt_flags |= RTF_MODIFIED;
    510   1.10   mycroft 			flags |= RTF_MODIFIED;
    511   1.10   mycroft 			stat = &rtstat.rts_newgateway;
    512   1.94    dyoung 			rt_setgate(rt, gateway);
    513    1.1       cgd 		}
    514    1.1       cgd 	} else
    515    1.1       cgd 		error = EHOSTUNREACH;
    516    1.1       cgd done:
    517    1.1       cgd 	if (rt) {
    518   1.95    dyoung 		if (rtp != NULL && !error)
    519    1.1       cgd 			*rtp = rt;
    520    1.1       cgd 		else
    521    1.1       cgd 			rtfree(rt);
    522    1.1       cgd 	}
    523    1.8       cgd out:
    524    1.1       cgd 	if (error)
    525    1.1       cgd 		rtstat.rts_badredirect++;
    526    1.8       cgd 	else if (stat != NULL)
    527    1.8       cgd 		(*stat)++;
    528   1.95    dyoung 	memset(&info, 0, sizeof(info));
    529   1.10   mycroft 	info.rti_info[RTAX_DST] = dst;
    530   1.10   mycroft 	info.rti_info[RTAX_GATEWAY] = gateway;
    531   1.10   mycroft 	info.rti_info[RTAX_NETMASK] = netmask;
    532   1.10   mycroft 	info.rti_info[RTAX_AUTHOR] = src;
    533   1.10   mycroft 	rt_missmsg(RTM_REDIRECT, &info, flags, error);
    534    1.1       cgd }
    535    1.1       cgd 
    536    1.1       cgd /*
    537   1.40    itojun  * Delete a route and generate a message
    538   1.40    itojun  */
    539   1.40    itojun static int
    540   1.60      matt rtdeletemsg(struct rtentry *rt)
    541   1.40    itojun {
    542   1.40    itojun 	int error;
    543   1.40    itojun 	struct rt_addrinfo info;
    544   1.40    itojun 
    545   1.40    itojun 	/*
    546   1.40    itojun 	 * Request the new route so that the entry is not actually
    547   1.40    itojun 	 * deleted.  That will allow the information being reported to
    548   1.40    itojun 	 * be accurate (and consistent with route_output()).
    549   1.40    itojun 	 */
    550   1.95    dyoung 	memset(&info, 0, sizeof(info));
    551   1.94    dyoung 	info.rti_info[RTAX_DST] = rt_getkey(rt);
    552   1.40    itojun 	info.rti_info[RTAX_NETMASK] = rt_mask(rt);
    553   1.40    itojun 	info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
    554   1.40    itojun 	info.rti_flags = rt->rt_flags;
    555   1.40    itojun 	error = rtrequest1(RTM_DELETE, &info, &rt);
    556   1.40    itojun 
    557   1.40    itojun 	rt_missmsg(RTM_DELETE, &info, info.rti_flags, error);
    558   1.40    itojun 
    559   1.40    itojun 	/* Adjust the refcount */
    560   1.40    itojun 	if (error == 0 && rt->rt_refcnt <= 0) {
    561   1.40    itojun 		rt->rt_refcnt++;
    562   1.40    itojun 		rtfree(rt);
    563   1.40    itojun 	}
    564   1.95    dyoung 	return error;
    565   1.40    itojun }
    566   1.40    itojun 
    567   1.41    itojun static int
    568   1.92    dyoung rtflushclone1(struct rtentry *rt, void *arg)
    569   1.41    itojun {
    570   1.92    dyoung 	struct rtentry *parent;
    571   1.41    itojun 
    572   1.41    itojun 	parent = (struct rtentry *)arg;
    573   1.41    itojun 	if ((rt->rt_flags & RTF_CLONED) != 0 && rt->rt_parent == parent)
    574   1.41    itojun 		rtdeletemsg(rt);
    575   1.41    itojun 	return 0;
    576   1.41    itojun }
    577   1.41    itojun 
    578   1.41    itojun static void
    579   1.92    dyoung rtflushclone(sa_family_t family, struct rtentry *parent)
    580   1.41    itojun {
    581   1.41    itojun 
    582   1.41    itojun #ifdef DIAGNOSTIC
    583   1.41    itojun 	if (!parent || (parent->rt_flags & RTF_CLONING) == 0)
    584   1.41    itojun 		panic("rtflushclone: called with a non-cloning route");
    585   1.41    itojun #endif
    586   1.92    dyoung 	rt_walktree(family, rtflushclone1, (void *)parent);
    587   1.41    itojun }
    588   1.41    itojun 
    589   1.40    itojun /*
    590   1.22   thorpej  * Routing table ioctl interface.
    591   1.22   thorpej  */
    592    1.9   mycroft int
    593   1.87  christos rtioctl(u_long req, void *data, struct lwp *l)
    594    1.1       cgd {
    595   1.95    dyoung 	return EOPNOTSUPP;
    596    1.1       cgd }
    597    1.1       cgd 
    598    1.1       cgd struct ifaddr *
    599   1.60      matt ifa_ifwithroute(int flags, const struct sockaddr *dst,
    600   1.60      matt 	const struct sockaddr *gateway)
    601    1.1       cgd {
    602   1.36  augustss 	struct ifaddr *ifa;
    603    1.1       cgd 	if ((flags & RTF_GATEWAY) == 0) {
    604    1.1       cgd 		/*
    605    1.1       cgd 		 * If we are adding a route to an interface,
    606    1.1       cgd 		 * and the interface is a pt to pt link
    607    1.1       cgd 		 * we should search for the destination
    608    1.1       cgd 		 * as our clue to the interface.  Otherwise
    609    1.1       cgd 		 * we can use the local address.
    610    1.1       cgd 		 */
    611   1.68  christos 		ifa = NULL;
    612   1.65     perry 		if (flags & RTF_HOST)
    613    1.1       cgd 			ifa = ifa_ifwithdstaddr(dst);
    614   1.68  christos 		if (ifa == NULL)
    615    1.1       cgd 			ifa = ifa_ifwithaddr(gateway);
    616    1.1       cgd 	} else {
    617    1.1       cgd 		/*
    618    1.1       cgd 		 * If we are adding a route to a remote net
    619    1.1       cgd 		 * or host, the gateway may still be on the
    620    1.1       cgd 		 * other end of a pt to pt link.
    621    1.1       cgd 		 */
    622    1.1       cgd 		ifa = ifa_ifwithdstaddr(gateway);
    623    1.1       cgd 	}
    624   1.68  christos 	if (ifa == NULL)
    625    1.1       cgd 		ifa = ifa_ifwithnet(gateway);
    626   1.68  christos 	if (ifa == NULL) {
    627    1.1       cgd 		struct rtentry *rt = rtalloc1(dst, 0);
    628   1.68  christos 		if (rt == NULL)
    629   1.68  christos 			return NULL;
    630    1.1       cgd 		rt->rt_refcnt--;
    631   1.68  christos 		if ((ifa = rt->rt_ifa) == NULL)
    632   1.68  christos 			return NULL;
    633    1.1       cgd 	}
    634    1.1       cgd 	if (ifa->ifa_addr->sa_family != dst->sa_family) {
    635   1.10   mycroft 		struct ifaddr *oifa = ifa;
    636    1.1       cgd 		ifa = ifaof_ifpforaddr(dst, ifa->ifa_ifp);
    637    1.1       cgd 		if (ifa == 0)
    638    1.1       cgd 			ifa = oifa;
    639    1.1       cgd 	}
    640   1.95    dyoung 	return ifa;
    641    1.1       cgd }
    642    1.1       cgd 
    643    1.9   mycroft int
    644   1.60      matt rtrequest(int req, const struct sockaddr *dst, const struct sockaddr *gateway,
    645   1.60      matt 	const struct sockaddr *netmask, int flags, struct rtentry **ret_nrt)
    646    1.1       cgd {
    647   1.39    itojun 	struct rt_addrinfo info;
    648   1.39    itojun 
    649   1.44   thorpej 	memset(&info, 0, sizeof(info));
    650   1.39    itojun 	info.rti_flags = flags;
    651   1.39    itojun 	info.rti_info[RTAX_DST] = dst;
    652   1.39    itojun 	info.rti_info[RTAX_GATEWAY] = gateway;
    653   1.39    itojun 	info.rti_info[RTAX_NETMASK] = netmask;
    654   1.39    itojun 	return rtrequest1(req, &info, ret_nrt);
    655   1.39    itojun }
    656   1.39    itojun 
    657   1.39    itojun int
    658   1.60      matt rt_getifa(struct rt_addrinfo *info)
    659   1.39    itojun {
    660   1.39    itojun 	struct ifaddr *ifa;
    661   1.68  christos 	const struct sockaddr *dst = info->rti_info[RTAX_DST];
    662   1.68  christos 	const struct sockaddr *gateway = info->rti_info[RTAX_GATEWAY];
    663   1.68  christos 	const struct sockaddr *ifaaddr = info->rti_info[RTAX_IFA];
    664   1.68  christos 	const struct sockaddr *ifpaddr = info->rti_info[RTAX_IFP];
    665   1.68  christos 	int flags = info->rti_flags;
    666   1.39    itojun 
    667   1.39    itojun 	/*
    668   1.39    itojun 	 * ifp may be specified by sockaddr_dl when protocol address
    669   1.39    itojun 	 * is ambiguous
    670   1.39    itojun 	 */
    671   1.39    itojun 	if (info->rti_ifp == NULL && ifpaddr != NULL
    672   1.39    itojun 	    && ifpaddr->sa_family == AF_LINK &&
    673  1.101    dyoung 	    (ifa = ifa_ifwithnet(ifpaddr)) != NULL)
    674   1.39    itojun 		info->rti_ifp = ifa->ifa_ifp;
    675   1.39    itojun 	if (info->rti_ifa == NULL && ifaaddr != NULL)
    676   1.39    itojun 		info->rti_ifa = ifa_ifwithaddr(ifaaddr);
    677   1.39    itojun 	if (info->rti_ifa == NULL) {
    678   1.59      matt 		const struct sockaddr *sa;
    679   1.39    itojun 
    680   1.39    itojun 		sa = ifaaddr != NULL ? ifaaddr :
    681   1.39    itojun 		    (gateway != NULL ? gateway : dst);
    682   1.39    itojun 		if (sa != NULL && info->rti_ifp != NULL)
    683   1.39    itojun 			info->rti_ifa = ifaof_ifpforaddr(sa, info->rti_ifp);
    684   1.39    itojun 		else if (dst != NULL && gateway != NULL)
    685   1.39    itojun 			info->rti_ifa = ifa_ifwithroute(flags, dst, gateway);
    686   1.39    itojun 		else if (sa != NULL)
    687   1.39    itojun 			info->rti_ifa = ifa_ifwithroute(flags, sa, sa);
    688   1.39    itojun 	}
    689   1.74    dyoung 	if ((ifa = info->rti_ifa) == NULL)
    690   1.74    dyoung 		return ENETUNREACH;
    691   1.74    dyoung 	if (ifa->ifa_getifa != NULL)
    692   1.74    dyoung 		info->rti_ifa = ifa = (*ifa->ifa_getifa)(ifa, dst);
    693   1.74    dyoung 	if (info->rti_ifp == NULL)
    694   1.74    dyoung 		info->rti_ifp = ifa->ifa_ifp;
    695   1.74    dyoung 	return 0;
    696   1.39    itojun }
    697   1.39    itojun 
    698   1.39    itojun int
    699   1.60      matt rtrequest1(int req, struct rt_addrinfo *info, struct rtentry **ret_nrt)
    700   1.39    itojun {
    701   1.60      matt 	int s = splsoftnet();
    702   1.60      matt 	int error = 0;
    703   1.40    itojun 	struct rtentry *rt, *crt;
    704   1.36  augustss 	struct radix_node *rn;
    705   1.36  augustss 	struct radix_node_head *rnh;
    706  1.122    kefren 	struct ifaddr *ifa, *ifa2;
    707   1.94    dyoung 	struct sockaddr_storage maskeddst;
    708   1.68  christos 	const struct sockaddr *dst = info->rti_info[RTAX_DST];
    709   1.68  christos 	const struct sockaddr *gateway = info->rti_info[RTAX_GATEWAY];
    710   1.68  christos 	const struct sockaddr *netmask = info->rti_info[RTAX_NETMASK];
    711   1.68  christos 	int flags = info->rti_flags;
    712    1.1       cgd #define senderr(x) { error = x ; goto bad; }
    713    1.1       cgd 
    714   1.68  christos 	if ((rnh = rt_tables[dst->sa_family]) == NULL)
    715    1.1       cgd 		senderr(ESRCH);
    716    1.1       cgd 	if (flags & RTF_HOST)
    717   1.68  christos 		netmask = NULL;
    718    1.1       cgd 	switch (req) {
    719    1.1       cgd 	case RTM_DELETE:
    720   1.63  christos 		if (netmask) {
    721   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
    722   1.94    dyoung 			    netmask);
    723   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
    724   1.63  christos 		}
    725   1.68  christos 		if ((rn = rnh->rnh_lookup(dst, netmask, rnh)) == NULL)
    726   1.41    itojun 			senderr(ESRCH);
    727   1.41    itojun 		rt = (struct rtentry *)rn;
    728   1.41    itojun 		if ((rt->rt_flags & RTF_CLONING) != 0) {
    729   1.41    itojun 			/* clean up any cloned children */
    730   1.92    dyoung 			rtflushclone(dst->sa_family, rt);
    731   1.41    itojun 		}
    732   1.68  christos 		if ((rn = rnh->rnh_deladdr(dst, netmask, rnh)) == NULL)
    733    1.1       cgd 			senderr(ESRCH);
    734    1.1       cgd 		if (rn->rn_flags & (RNF_ACTIVE | RNF_ROOT))
    735    1.1       cgd 			panic ("rtrequest delete");
    736    1.1       cgd 		rt = (struct rtentry *)rn;
    737   1.10   mycroft 		if (rt->rt_gwroute) {
    738   1.68  christos 			RTFREE(rt->rt_gwroute);
    739   1.68  christos 			rt->rt_gwroute = NULL;
    740   1.48    itojun 		}
    741   1.48    itojun 		if (rt->rt_parent) {
    742   1.48    itojun 			rt->rt_parent->rt_refcnt--;
    743   1.48    itojun 			rt->rt_parent = NULL;
    744   1.10   mycroft 		}
    745   1.28       erh 		rt->rt_flags &= ~RTF_UP;
    746  1.116       roy 		if ((ifa = rt->rt_ifa)) {
    747  1.116       roy 			if (ifa->ifa_flags & IFA_ROUTE &&
    748  1.116       roy 			    rt_ifa_connected(rt, ifa)) {
    749  1.116       roy 				RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
    750  1.116       roy 				    "deleted IFA_ROUTE\n",
    751  1.116       roy 				    (void *)rt->_rt_key, (void *)ifa);
    752  1.116       roy 				ifa->ifa_flags &= ~IFA_ROUTE;
    753  1.116       roy 			}
    754  1.116       roy 			if (ifa->ifa_rtrequest)
    755  1.116       roy 				ifa->ifa_rtrequest(RTM_DELETE, rt, info);
    756  1.116       roy 		}
    757    1.1       cgd 		rttrash++;
    758   1.10   mycroft 		if (ret_nrt)
    759   1.10   mycroft 			*ret_nrt = rt;
    760   1.10   mycroft 		else if (rt->rt_refcnt <= 0) {
    761   1.10   mycroft 			rt->rt_refcnt++;
    762    1.1       cgd 			rtfree(rt);
    763   1.10   mycroft 		}
    764    1.1       cgd 		break;
    765    1.1       cgd 
    766    1.1       cgd 	case RTM_RESOLVE:
    767   1.68  christos 		if (ret_nrt == NULL || (rt = *ret_nrt) == NULL)
    768    1.1       cgd 			senderr(EINVAL);
    769   1.40    itojun 		if ((rt->rt_flags & RTF_CLONING) == 0)
    770   1.40    itojun 			senderr(EINVAL);
    771    1.1       cgd 		ifa = rt->rt_ifa;
    772   1.40    itojun 		flags = rt->rt_flags & ~(RTF_CLONING | RTF_STATIC);
    773   1.40    itojun 		flags |= RTF_CLONED;
    774    1.1       cgd 		gateway = rt->rt_gateway;
    775   1.94    dyoung 		flags |= RTF_HOST;
    776    1.1       cgd 		goto makeroute;
    777    1.1       cgd 
    778    1.1       cgd 	case RTM_ADD:
    779   1.68  christos 		if (info->rti_ifa == NULL && (error = rt_getifa(info)))
    780   1.39    itojun 			senderr(error);
    781   1.39    itojun 		ifa = info->rti_ifa;
    782    1.1       cgd 	makeroute:
    783   1.72       tls 		/* Already at splsoftnet() so pool_get/pool_put are safe */
    784   1.22   thorpej 		rt = pool_get(&rtentry_pool, PR_NOWAIT);
    785   1.68  christos 		if (rt == NULL)
    786    1.1       cgd 			senderr(ENOBUFS);
    787  1.109    dyoung 		memset(rt, 0, sizeof(*rt));
    788   1.10   mycroft 		rt->rt_flags = RTF_UP | flags;
    789   1.18       kml 		LIST_INIT(&rt->rt_timer);
    790  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    791   1.96    dyoung 		if (rt_setkey(rt, dst, M_NOWAIT) == NULL ||
    792   1.94    dyoung 		    rt_setgate(rt, gateway) != 0) {
    793   1.22   thorpej 			pool_put(&rtentry_pool, rt);
    794   1.10   mycroft 			senderr(ENOBUFS);
    795   1.10   mycroft 		}
    796  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    797    1.1       cgd 		if (netmask) {
    798   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
    799   1.94    dyoung 			    netmask);
    800   1.96    dyoung 			rt_setkey(rt, (struct sockaddr *)&maskeddst, M_NOWAIT);
    801  1.110    dyoung 			RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    802   1.94    dyoung 		} else {
    803   1.96    dyoung 			rt_setkey(rt, dst, M_NOWAIT);
    804  1.110    dyoung 			RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    805   1.94    dyoung 		}
    806   1.74    dyoung 		rt_set_ifa(rt, ifa);
    807  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    808  1.122    kefren 		if (info->rti_info[RTAX_IFP] != NULL &&
    809  1.122    kefren 		    (ifa2 = ifa_ifwithnet(info->rti_info[RTAX_IFP])) != NULL &&
    810  1.122    kefren 		    ifa2->ifa_ifp != NULL)
    811  1.122    kefren 			rt->rt_ifp = ifa2->ifa_ifp;
    812  1.122    kefren 		else
    813  1.122    kefren 			rt->rt_ifp = ifa->ifa_ifp;
    814   1.27      matt 		if (req == RTM_RESOLVE) {
    815    1.1       cgd 			rt->rt_rmx = (*ret_nrt)->rt_rmx; /* copy metrics */
    816   1.41    itojun 			rt->rt_parent = *ret_nrt;
    817   1.41    itojun 			rt->rt_parent->rt_refcnt++;
    818   1.40    itojun 		}
    819  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    820   1.94    dyoung 		rn = rnh->rnh_addaddr(rt_getkey(rt), netmask, rnh,
    821   1.94    dyoung 		    rt->rt_nodes);
    822  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    823   1.94    dyoung 		if (rn == NULL && (crt = rtalloc1(rt_getkey(rt), 0)) != NULL) {
    824   1.40    itojun 			/* overwrite cloned route */
    825   1.40    itojun 			if ((crt->rt_flags & RTF_CLONED) != 0) {
    826   1.40    itojun 				rtdeletemsg(crt);
    827   1.94    dyoung 				rn = rnh->rnh_addaddr(rt_getkey(rt),
    828   1.66  christos 				    netmask, rnh, rt->rt_nodes);
    829   1.40    itojun 			}
    830   1.40    itojun 			RTFREE(crt);
    831  1.110    dyoung 			RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    832   1.40    itojun 		}
    833  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    834   1.68  christos 		if (rn == NULL) {
    835   1.40    itojun 			IFAFREE(ifa);
    836   1.41    itojun 			if ((rt->rt_flags & RTF_CLONED) != 0 && rt->rt_parent)
    837   1.41    itojun 				rtfree(rt->rt_parent);
    838   1.40    itojun 			if (rt->rt_gwroute)
    839   1.40    itojun 				rtfree(rt->rt_gwroute);
    840   1.94    dyoung 			rt_destroy(rt);
    841   1.40    itojun 			pool_put(&rtentry_pool, rt);
    842   1.40    itojun 			senderr(EEXIST);
    843   1.27      matt 		}
    844  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    845    1.1       cgd 		if (ifa->ifa_rtrequest)
    846   1.39    itojun 			ifa->ifa_rtrequest(req, rt, info);
    847  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    848    1.1       cgd 		if (ret_nrt) {
    849    1.1       cgd 			*ret_nrt = rt;
    850    1.1       cgd 			rt->rt_refcnt++;
    851   1.41    itojun 		}
    852   1.41    itojun 		if ((rt->rt_flags & RTF_CLONING) != 0) {
    853   1.41    itojun 			/* clean up any cloned children */
    854   1.92    dyoung 			rtflushclone(dst->sa_family, rt);
    855    1.1       cgd 		}
    856   1.82    dyoung 		rtflushall(dst->sa_family);
    857    1.1       cgd 		break;
    858   1.92    dyoung 	case RTM_GET:
    859   1.94    dyoung 		if (netmask != NULL) {
    860   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
    861   1.94    dyoung 			    netmask);
    862   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
    863   1.94    dyoung 		}
    864   1.92    dyoung 		rn = rnh->rnh_lookup(dst, netmask, rnh);
    865   1.92    dyoung 		if (rn == NULL || (rn->rn_flags & RNF_ROOT) != 0)
    866   1.92    dyoung 			senderr(ESRCH);
    867   1.92    dyoung 		if (ret_nrt != NULL) {
    868   1.92    dyoung 			rt = (struct rtentry *)rn;
    869   1.92    dyoung 			*ret_nrt = rt;
    870   1.92    dyoung 			rt->rt_refcnt++;
    871   1.92    dyoung 		}
    872   1.92    dyoung 		break;
    873    1.1       cgd 	}
    874    1.1       cgd bad:
    875    1.1       cgd 	splx(s);
    876   1.95    dyoung 	return error;
    877    1.1       cgd }
    878    1.1       cgd 
    879   1.10   mycroft int
    880   1.94    dyoung rt_setgate(struct rtentry *rt, const struct sockaddr *gate)
    881   1.10   mycroft {
    882   1.94    dyoung 	KASSERT(rt != rt->rt_gwroute);
    883   1.94    dyoung 
    884   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
    885  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    886   1.94    dyoung 
    887   1.10   mycroft 	if (rt->rt_gwroute) {
    888   1.68  christos 		RTFREE(rt->rt_gwroute);
    889   1.68  christos 		rt->rt_gwroute = NULL;
    890   1.10   mycroft 	}
    891   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
    892  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    893   1.94    dyoung 	if (rt->rt_gateway != NULL)
    894   1.94    dyoung 		sockaddr_free(rt->rt_gateway);
    895   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
    896  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    897   1.96    dyoung 	if ((rt->rt_gateway = sockaddr_dup(gate, M_NOWAIT)) == NULL)
    898   1.94    dyoung 		return ENOMEM;
    899   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
    900  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    901   1.94    dyoung 
    902   1.10   mycroft 	if (rt->rt_flags & RTF_GATEWAY) {
    903   1.94    dyoung 		KASSERT(rt->_rt_key != NULL);
    904  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    905   1.10   mycroft 		rt->rt_gwroute = rtalloc1(gate, 1);
    906   1.27      matt 		/*
    907   1.27      matt 		 * If we switched gateways, grab the MTU from the new
    908   1.47    itojun 		 * gateway route if the current MTU, if the current MTU is
    909   1.47    itojun 		 * greater than the MTU of gateway.
    910   1.47    itojun 		 * Note that, if the MTU of gateway is 0, we will reset the
    911   1.47    itojun 		 * MTU of the route to run PMTUD again from scratch. XXX
    912   1.27      matt 		 */
    913   1.94    dyoung 		KASSERT(rt->_rt_key != NULL);
    914  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    915   1.27      matt 		if (rt->rt_gwroute
    916   1.27      matt 		    && !(rt->rt_rmx.rmx_locks & RTV_MTU)
    917   1.47    itojun 		    && rt->rt_rmx.rmx_mtu
    918   1.47    itojun 		    && rt->rt_rmx.rmx_mtu > rt->rt_gwroute->rt_rmx.rmx_mtu) {
    919   1.27      matt 			rt->rt_rmx.rmx_mtu = rt->rt_gwroute->rt_rmx.rmx_mtu;
    920   1.27      matt 		}
    921   1.10   mycroft 	}
    922   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
    923  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
    924   1.10   mycroft 	return 0;
    925   1.10   mycroft }
    926   1.10   mycroft 
    927    1.9   mycroft void
    928   1.60      matt rt_maskedcopy(const struct sockaddr *src, struct sockaddr *dst,
    929   1.60      matt 	const struct sockaddr *netmask)
    930    1.1       cgd {
    931   1.94    dyoung 	const char *netmaskp = &netmask->sa_data[0],
    932   1.94    dyoung 	           *srcp = &src->sa_data[0];
    933   1.94    dyoung 	char *dstp = &dst->sa_data[0];
    934   1.94    dyoung 	const char *maskend = dstp + MIN(netmask->sa_len, src->sa_len);
    935   1.94    dyoung 	const char *srcend = dstp + src->sa_len;
    936   1.94    dyoung 
    937   1.94    dyoung 	dst->sa_len = src->sa_len;
    938   1.94    dyoung 	dst->sa_family = src->sa_family;
    939   1.94    dyoung 
    940   1.94    dyoung 	while (dstp < maskend)
    941   1.94    dyoung 		*dstp++ = *srcp++ & *netmaskp++;
    942   1.94    dyoung 	if (dstp < srcend)
    943   1.94    dyoung 		memset(dstp, 0, (size_t)(srcend - dstp));
    944    1.1       cgd }
    945   1.10   mycroft 
    946    1.1       cgd /*
    947   1.29  sommerfe  * Set up or tear down a routing table entry, normally
    948    1.1       cgd  * for an interface.
    949    1.1       cgd  */
    950    1.9   mycroft int
    951   1.60      matt rtinit(struct ifaddr *ifa, int cmd, int flags)
    952    1.1       cgd {
    953   1.36  augustss 	struct rtentry *rt;
    954   1.36  augustss 	struct sockaddr *dst, *odst;
    955   1.94    dyoung 	struct sockaddr_storage maskeddst;
    956   1.68  christos 	struct rtentry *nrt = NULL;
    957    1.1       cgd 	int error;
    958   1.39    itojun 	struct rt_addrinfo info;
    959  1.114    dyoung 	struct sockaddr_dl *sdl;
    960  1.114    dyoung 	const struct sockaddr_dl *ifsdl;
    961    1.1       cgd 
    962    1.1       cgd 	dst = flags & RTF_HOST ? ifa->ifa_dstaddr : ifa->ifa_addr;
    963    1.1       cgd 	if (cmd == RTM_DELETE) {
    964    1.1       cgd 		if ((flags & RTF_HOST) == 0 && ifa->ifa_netmask) {
    965   1.29  sommerfe 			/* Delete subnet route for this interface */
    966   1.29  sommerfe 			odst = dst;
    967   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
    968   1.29  sommerfe 			rt_maskedcopy(odst, dst, ifa->ifa_netmask);
    969    1.1       cgd 		}
    970   1.14  christos 		if ((rt = rtalloc1(dst, 0)) != NULL) {
    971    1.1       cgd 			rt->rt_refcnt--;
    972   1.29  sommerfe 			if (rt->rt_ifa != ifa)
    973   1.85    dyoung 				return (flags & RTF_HOST) ? EHOSTUNREACH
    974   1.85    dyoung 							: ENETUNREACH;
    975    1.1       cgd 		}
    976    1.1       cgd 	}
    977   1.44   thorpej 	memset(&info, 0, sizeof(info));
    978   1.39    itojun 	info.rti_ifa = ifa;
    979   1.39    itojun 	info.rti_flags = flags | ifa->ifa_flags;
    980   1.39    itojun 	info.rti_info[RTAX_DST] = dst;
    981   1.39    itojun 	info.rti_info[RTAX_GATEWAY] = ifa->ifa_addr;
    982   1.39    itojun 	/*
    983   1.39    itojun 	 * XXX here, it seems that we are assuming that ifa_netmask is NULL
    984   1.39    itojun 	 * for RTF_HOST.  bsdi4 passes NULL explicitly (via intermediate
    985   1.39    itojun 	 * variable) when RTF_HOST is 1.  still not sure if i can safely
    986   1.39    itojun 	 * change it to meet bsdi4 behavior.
    987   1.39    itojun 	 */
    988  1.114    dyoung 	if (cmd != RTM_LLINFO_UPD)
    989  1.114    dyoung 		info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
    990  1.114    dyoung 	error = rtrequest1((cmd == RTM_LLINFO_UPD) ? RTM_GET : cmd, &info,
    991  1.114    dyoung 	    &nrt);
    992  1.114    dyoung 	if (error != 0 || (rt = nrt) == NULL)
    993  1.114    dyoung 		;
    994  1.114    dyoung 	else switch (cmd) {
    995  1.114    dyoung 	case RTM_DELETE:
    996   1.10   mycroft 		rt_newaddrmsg(cmd, ifa, error, nrt);
    997   1.10   mycroft 		if (rt->rt_refcnt <= 0) {
    998   1.10   mycroft 			rt->rt_refcnt++;
    999   1.10   mycroft 			rtfree(rt);
   1000   1.10   mycroft 		}
   1001  1.114    dyoung 		break;
   1002  1.114    dyoung 	case RTM_LLINFO_UPD:
   1003  1.114    dyoung 		rt->rt_refcnt--;
   1004  1.114    dyoung 		RT_DPRINTF("%s: updating%s\n", __func__,
   1005  1.114    dyoung 		    ((rt->rt_flags & RTF_LLINFO) == 0) ? " (no llinfo)" : "");
   1006  1.114    dyoung 
   1007  1.114    dyoung 		ifsdl = ifa->ifa_ifp->if_sadl;
   1008  1.114    dyoung 
   1009  1.114    dyoung 		if ((rt->rt_flags & RTF_LLINFO) != 0 &&
   1010  1.114    dyoung 		    (sdl = satosdl(rt->rt_gateway)) != NULL &&
   1011  1.114    dyoung 		    sdl->sdl_family == AF_LINK &&
   1012  1.114    dyoung 		    sockaddr_dl_setaddr(sdl, sdl->sdl_len, CLLADDR(ifsdl),
   1013  1.114    dyoung 		                        ifa->ifa_ifp->if_addrlen) == NULL) {
   1014  1.114    dyoung 			error = EINVAL;
   1015  1.114    dyoung 			break;
   1016  1.114    dyoung 		}
   1017  1.114    dyoung 
   1018  1.114    dyoung 		if (cmd == RTM_LLINFO_UPD && ifa->ifa_rtrequest != NULL)
   1019  1.114    dyoung 			ifa->ifa_rtrequest(RTM_LLINFO_UPD, rt, &info);
   1020  1.114    dyoung 		rt_newaddrmsg(RTM_CHANGE, ifa, error, nrt);
   1021  1.114    dyoung 		break;
   1022  1.114    dyoung 	case RTM_ADD:
   1023   1.10   mycroft 		rt->rt_refcnt--;
   1024   1.10   mycroft 		if (rt->rt_ifa != ifa) {
   1025   1.17  christos 			printf("rtinit: wrong ifa (%p) was (%p)\n", ifa,
   1026   1.17  christos 				rt->rt_ifa);
   1027  1.114    dyoung 			if (rt->rt_ifa->ifa_rtrequest != NULL) {
   1028  1.114    dyoung 				rt->rt_ifa->ifa_rtrequest(RTM_DELETE, rt,
   1029  1.114    dyoung 				    &info);
   1030  1.114    dyoung 			}
   1031   1.74    dyoung 			rt_replace_ifa(rt, ifa);
   1032   1.10   mycroft 			rt->rt_ifp = ifa->ifa_ifp;
   1033  1.114    dyoung 			if (ifa->ifa_rtrequest != NULL)
   1034  1.114    dyoung 				ifa->ifa_rtrequest(RTM_ADD, rt, &info);
   1035   1.10   mycroft 		}
   1036   1.10   mycroft 		rt_newaddrmsg(cmd, ifa, error, nrt);
   1037  1.114    dyoung 		break;
   1038    1.1       cgd 	}
   1039   1.85    dyoung 	return error;
   1040   1.18       kml }
   1041   1.18       kml 
   1042   1.18       kml /*
   1043   1.18       kml  * Route timer routines.  These routes allow functions to be called
   1044   1.18       kml  * for various routes at any time.  This is useful in supporting
   1045   1.18       kml  * path MTU discovery and redirect route deletion.
   1046   1.18       kml  *
   1047   1.18       kml  * This is similar to some BSDI internal functions, but it provides
   1048   1.18       kml  * for multiple queues for efficiency's sake...
   1049   1.18       kml  */
   1050   1.18       kml 
   1051   1.18       kml LIST_HEAD(, rttimer_queue) rttimer_queue_head;
   1052   1.18       kml static int rt_init_done = 0;
   1053   1.18       kml 
   1054   1.60      matt #define RTTIMER_CALLOUT(r)	do {					\
   1055   1.60      matt 		if (r->rtt_func != NULL) {				\
   1056   1.60      matt 			(*r->rtt_func)(r->rtt_rt, r);			\
   1057   1.60      matt 		} else {						\
   1058   1.60      matt 			rtrequest((int) RTM_DELETE,			\
   1059   1.94    dyoung 				  rt_getkey(r->rtt_rt),			\
   1060   1.60      matt 				  0, 0, 0, 0);				\
   1061   1.60      matt 		}							\
   1062   1.60      matt 	} while (/*CONSTCOND*/0)
   1063   1.18       kml 
   1064   1.65     perry /*
   1065   1.18       kml  * Some subtle order problems with domain initialization mean that
   1066   1.18       kml  * we cannot count on this being run from rt_init before various
   1067   1.18       kml  * protocol initializations are done.  Therefore, we make sure
   1068   1.18       kml  * that this is run when the first queue is added...
   1069   1.18       kml  */
   1070   1.18       kml 
   1071   1.65     perry void
   1072   1.60      matt rt_timer_init(void)
   1073   1.18       kml {
   1074   1.18       kml 	assert(rt_init_done == 0);
   1075   1.18       kml 
   1076   1.18       kml 	LIST_INIT(&rttimer_queue_head);
   1077   1.93        ad 	callout_init(&rt_timer_ch, 0);
   1078   1.35   thorpej 	callout_reset(&rt_timer_ch, hz, rt_timer_timer, NULL);
   1079   1.18       kml 	rt_init_done = 1;
   1080   1.18       kml }
   1081   1.18       kml 
   1082   1.18       kml struct rttimer_queue *
   1083   1.60      matt rt_timer_queue_create(u_int timeout)
   1084   1.18       kml {
   1085   1.18       kml 	struct rttimer_queue *rtq;
   1086   1.18       kml 
   1087   1.18       kml 	if (rt_init_done == 0)
   1088   1.18       kml 		rt_timer_init();
   1089   1.18       kml 
   1090   1.18       kml 	R_Malloc(rtq, struct rttimer_queue *, sizeof *rtq);
   1091   1.18       kml 	if (rtq == NULL)
   1092   1.85    dyoung 		return NULL;
   1093  1.109    dyoung 	memset(rtq, 0, sizeof(*rtq));
   1094   1.18       kml 
   1095   1.18       kml 	rtq->rtq_timeout = timeout;
   1096   1.24   thorpej 	TAILQ_INIT(&rtq->rtq_head);
   1097   1.18       kml 	LIST_INSERT_HEAD(&rttimer_queue_head, rtq, rtq_link);
   1098   1.18       kml 
   1099   1.85    dyoung 	return rtq;
   1100   1.18       kml }
   1101   1.18       kml 
   1102   1.18       kml void
   1103   1.60      matt rt_timer_queue_change(struct rttimer_queue *rtq, long timeout)
   1104   1.18       kml {
   1105   1.24   thorpej 
   1106   1.18       kml 	rtq->rtq_timeout = timeout;
   1107   1.18       kml }
   1108   1.18       kml 
   1109   1.18       kml void
   1110   1.60      matt rt_timer_queue_remove_all(struct rttimer_queue *rtq, int destroy)
   1111   1.18       kml {
   1112   1.24   thorpej 	struct rttimer *r;
   1113   1.18       kml 
   1114   1.24   thorpej 	while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL) {
   1115   1.18       kml 		LIST_REMOVE(r, rtt_link);
   1116   1.24   thorpej 		TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
   1117   1.24   thorpej 		if (destroy)
   1118   1.18       kml 			RTTIMER_CALLOUT(r);
   1119   1.72       tls 		/* we are already at splsoftnet */
   1120   1.22   thorpej 		pool_put(&rttimer_pool, r);
   1121   1.37    itojun 		if (rtq->rtq_count > 0)
   1122   1.37    itojun 			rtq->rtq_count--;
   1123   1.37    itojun 		else
   1124   1.55    itojun 			printf("rt_timer_queue_remove_all: "
   1125   1.55    itojun 			    "rtq_count reached 0\n");
   1126   1.18       kml 	}
   1127   1.55    itojun }
   1128   1.55    itojun 
   1129   1.55    itojun void
   1130   1.60      matt rt_timer_queue_destroy(struct rttimer_queue *rtq, int destroy)
   1131   1.55    itojun {
   1132   1.55    itojun 
   1133   1.55    itojun 	rt_timer_queue_remove_all(rtq, destroy);
   1134   1.18       kml 
   1135   1.18       kml 	LIST_REMOVE(rtq, rtq_link);
   1136   1.22   thorpej 
   1137   1.22   thorpej 	/*
   1138   1.22   thorpej 	 * Caller is responsible for freeing the rttimer_queue structure.
   1139   1.22   thorpej 	 */
   1140   1.18       kml }
   1141   1.18       kml 
   1142   1.37    itojun unsigned long
   1143   1.60      matt rt_timer_count(struct rttimer_queue *rtq)
   1144   1.37    itojun {
   1145   1.37    itojun 	return rtq->rtq_count;
   1146   1.37    itojun }
   1147   1.37    itojun 
   1148   1.65     perry void
   1149   1.60      matt rt_timer_remove_all(struct rtentry *rt, int destroy)
   1150   1.18       kml {
   1151   1.24   thorpej 	struct rttimer *r;
   1152   1.18       kml 
   1153   1.24   thorpej 	while ((r = LIST_FIRST(&rt->rt_timer)) != NULL) {
   1154   1.18       kml 		LIST_REMOVE(r, rtt_link);
   1155   1.24   thorpej 		TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
   1156   1.54    itojun 		if (destroy)
   1157   1.54    itojun 			RTTIMER_CALLOUT(r);
   1158   1.37    itojun 		if (r->rtt_queue->rtq_count > 0)
   1159   1.37    itojun 			r->rtt_queue->rtq_count--;
   1160   1.37    itojun 		else
   1161   1.37    itojun 			printf("rt_timer_remove_all: rtq_count reached 0\n");
   1162   1.72       tls 		/* we are already at splsoftnet */
   1163   1.38    itojun 		pool_put(&rttimer_pool, r);
   1164   1.18       kml 	}
   1165   1.18       kml }
   1166   1.18       kml 
   1167   1.65     perry int
   1168   1.60      matt rt_timer_add(struct rtentry *rt,
   1169   1.60      matt 	void (*func)(struct rtentry *, struct rttimer *),
   1170   1.60      matt 	struct rttimer_queue *queue)
   1171   1.18       kml {
   1172   1.24   thorpej 	struct rttimer *r;
   1173   1.72       tls 	int s;
   1174   1.18       kml 
   1175   1.24   thorpej 	/*
   1176   1.24   thorpej 	 * If there's already a timer with this action, destroy it before
   1177   1.24   thorpej 	 * we add a new one.
   1178   1.24   thorpej 	 */
   1179   1.85    dyoung 	LIST_FOREACH(r, &rt->rt_timer, rtt_link) {
   1180   1.85    dyoung 		if (r->rtt_func == func)
   1181   1.85    dyoung 			break;
   1182   1.85    dyoung 	}
   1183   1.85    dyoung 	if (r != NULL) {
   1184   1.85    dyoung 		LIST_REMOVE(r, rtt_link);
   1185   1.85    dyoung 		TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
   1186   1.85    dyoung 		if (r->rtt_queue->rtq_count > 0)
   1187   1.85    dyoung 			r->rtt_queue->rtq_count--;
   1188   1.85    dyoung 		else
   1189   1.85    dyoung 			printf("rt_timer_add: rtq_count reached 0\n");
   1190   1.85    dyoung 	} else {
   1191   1.85    dyoung 		s = splsoftnet();
   1192   1.85    dyoung 		r = pool_get(&rttimer_pool, PR_NOWAIT);
   1193   1.85    dyoung 		splx(s);
   1194   1.85    dyoung 		if (r == NULL)
   1195   1.85    dyoung 			return ENOBUFS;
   1196   1.18       kml 	}
   1197   1.18       kml 
   1198   1.85    dyoung 	memset(r, 0, sizeof(*r));
   1199   1.24   thorpej 
   1200   1.24   thorpej 	r->rtt_rt = rt;
   1201   1.70    kardel 	r->rtt_time = time_uptime;
   1202   1.24   thorpej 	r->rtt_func = func;
   1203   1.24   thorpej 	r->rtt_queue = queue;
   1204   1.24   thorpej 	LIST_INSERT_HEAD(&rt->rt_timer, r, rtt_link);
   1205   1.24   thorpej 	TAILQ_INSERT_TAIL(&queue->rtq_head, r, rtt_next);
   1206   1.37    itojun 	r->rtt_queue->rtq_count++;
   1207   1.65     perry 
   1208   1.95    dyoung 	return 0;
   1209   1.18       kml }
   1210   1.18       kml 
   1211   1.18       kml /* ARGSUSED */
   1212   1.18       kml void
   1213   1.76  christos rt_timer_timer(void *arg)
   1214   1.18       kml {
   1215   1.24   thorpej 	struct rttimer_queue *rtq;
   1216   1.24   thorpej 	struct rttimer *r;
   1217   1.24   thorpej 	int s;
   1218   1.21       kml 
   1219   1.24   thorpej 	s = splsoftnet();
   1220   1.85    dyoung 	LIST_FOREACH(rtq, &rttimer_queue_head, rtq_link) {
   1221   1.24   thorpej 		while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL &&
   1222   1.70    kardel 		    (r->rtt_time + rtq->rtq_timeout) < time_uptime) {
   1223   1.24   thorpej 			LIST_REMOVE(r, rtt_link);
   1224   1.24   thorpej 			TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
   1225   1.24   thorpej 			RTTIMER_CALLOUT(r);
   1226   1.24   thorpej 			pool_put(&rttimer_pool, r);
   1227   1.37    itojun 			if (rtq->rtq_count > 0)
   1228   1.37    itojun 				rtq->rtq_count--;
   1229   1.37    itojun 			else
   1230   1.37    itojun 				printf("rt_timer_timer: rtq_count reached 0\n");
   1231   1.18       kml 		}
   1232   1.18       kml 	}
   1233   1.24   thorpej 	splx(s);
   1234   1.18       kml 
   1235   1.35   thorpej 	callout_reset(&rt_timer_ch, hz, rt_timer_timer, NULL);
   1236    1.1       cgd }
   1237   1.83     joerg 
   1238  1.102    dyoung static struct rtentry *
   1239   1.84     joerg _rtcache_init(struct route *ro, int flag)
   1240   1.84     joerg {
   1241  1.114    dyoung 	rtcache_invariants(ro);
   1242   1.99    dyoung 	KASSERT(ro->_ro_rt == NULL);
   1243   1.84     joerg 
   1244   1.90    dyoung 	if (rtcache_getdst(ro) == NULL)
   1245  1.102    dyoung 		return NULL;
   1246  1.105    dyoung 	ro->ro_invalid = false;
   1247  1.105    dyoung 	if ((ro->_ro_rt = rtalloc1(rtcache_getdst(ro), flag)) != NULL)
   1248  1.105    dyoung 		rtcache(ro);
   1249  1.103    dyoung 
   1250  1.114    dyoung 	rtcache_invariants(ro);
   1251  1.102    dyoung 	return ro->_ro_rt;
   1252   1.84     joerg }
   1253   1.84     joerg 
   1254  1.102    dyoung struct rtentry *
   1255   1.83     joerg rtcache_init(struct route *ro)
   1256   1.83     joerg {
   1257  1.102    dyoung 	return _rtcache_init(ro, 1);
   1258   1.83     joerg }
   1259   1.83     joerg 
   1260  1.102    dyoung struct rtentry *
   1261   1.83     joerg rtcache_init_noclone(struct route *ro)
   1262   1.83     joerg {
   1263  1.102    dyoung 	return _rtcache_init(ro, 0);
   1264   1.83     joerg }
   1265   1.90    dyoung 
   1266  1.102    dyoung struct rtentry *
   1267   1.90    dyoung rtcache_update(struct route *ro, int clone)
   1268   1.90    dyoung {
   1269   1.90    dyoung 	rtcache_clear(ro);
   1270  1.102    dyoung 	return _rtcache_init(ro, clone);
   1271   1.90    dyoung }
   1272   1.83     joerg 
   1273   1.83     joerg void
   1274   1.90    dyoung rtcache_copy(struct route *new_ro, const struct route *old_ro)
   1275   1.83     joerg {
   1276  1.103    dyoung 	struct rtentry *rt;
   1277  1.103    dyoung 
   1278  1.103    dyoung 	KASSERT(new_ro != old_ro);
   1279  1.114    dyoung 	rtcache_invariants(new_ro);
   1280  1.114    dyoung 	rtcache_invariants(old_ro);
   1281  1.103    dyoung 
   1282  1.104    dyoung 	if ((rt = rtcache_validate(old_ro)) != NULL)
   1283  1.103    dyoung 		rt->rt_refcnt++;
   1284  1.103    dyoung 
   1285   1.90    dyoung 	if (rtcache_getdst(old_ro) == NULL ||
   1286   1.90    dyoung 	    rtcache_setdst(new_ro, rtcache_getdst(old_ro)) != 0)
   1287   1.90    dyoung 		return;
   1288  1.103    dyoung 
   1289  1.105    dyoung 	new_ro->ro_invalid = false;
   1290  1.103    dyoung 	if ((new_ro->_ro_rt = rt) != NULL)
   1291   1.86    dyoung 		rtcache(new_ro);
   1292  1.114    dyoung 	rtcache_invariants(new_ro);
   1293   1.83     joerg }
   1294   1.83     joerg 
   1295  1.105    dyoung static struct dom_rtlist invalid_routes = LIST_HEAD_INITIALIZER(dom_rtlist);
   1296  1.105    dyoung 
   1297   1.89   xtraeme void
   1298  1.105    dyoung rtcache_invalidate(struct dom_rtlist *rtlist)
   1299   1.83     joerg {
   1300  1.105    dyoung 	struct route *ro;
   1301   1.99    dyoung 
   1302  1.105    dyoung 	while ((ro = LIST_FIRST(rtlist)) != NULL) {
   1303  1.114    dyoung 		rtcache_invariants(ro);
   1304  1.105    dyoung 		KASSERT(ro->_ro_rt != NULL);
   1305  1.105    dyoung 		ro->ro_invalid = true;
   1306   1.99    dyoung 		LIST_REMOVE(ro, ro_rtcache_next);
   1307  1.105    dyoung 		LIST_INSERT_HEAD(&invalid_routes, ro, ro_rtcache_next);
   1308  1.114    dyoung 		rtcache_invariants(ro);
   1309   1.84     joerg 	}
   1310  1.105    dyoung }
   1311  1.105    dyoung 
   1312  1.105    dyoung void
   1313  1.105    dyoung rtcache_clear(struct route *ro)
   1314  1.105    dyoung {
   1315  1.114    dyoung 	rtcache_invariants(ro);
   1316  1.105    dyoung 	if (ro->_ro_rt == NULL)
   1317  1.105    dyoung 		return;
   1318  1.105    dyoung 
   1319  1.105    dyoung 	LIST_REMOVE(ro, ro_rtcache_next);
   1320  1.105    dyoung 
   1321  1.105    dyoung 	RTFREE(ro->_ro_rt);
   1322  1.105    dyoung 	ro->_ro_rt = NULL;
   1323  1.114    dyoung 	ro->ro_invalid = false;
   1324  1.114    dyoung 	rtcache_invariants(ro);
   1325   1.83     joerg }
   1326   1.83     joerg 
   1327   1.90    dyoung struct rtentry *
   1328   1.91    dyoung rtcache_lookup2(struct route *ro, const struct sockaddr *dst, int clone,
   1329   1.91    dyoung     int *hitp)
   1330   1.90    dyoung {
   1331   1.90    dyoung 	const struct sockaddr *odst;
   1332  1.104    dyoung 	struct rtentry *rt = NULL;
   1333   1.90    dyoung 
   1334  1.114    dyoung 	rtcache_invariants(ro);
   1335  1.114    dyoung 
   1336   1.90    dyoung 	odst = rtcache_getdst(ro);
   1337   1.90    dyoung 
   1338   1.90    dyoung 	if (odst == NULL)
   1339   1.90    dyoung 		;
   1340   1.90    dyoung 	else if (sockaddr_cmp(odst, dst) != 0)
   1341   1.90    dyoung 		rtcache_free(ro);
   1342  1.104    dyoung 	else if ((rt = rtcache_validate(ro)) == NULL)
   1343   1.91    dyoung 		rtcache_clear(ro);
   1344   1.90    dyoung 
   1345  1.104    dyoung 	if (rt == NULL) {
   1346   1.91    dyoung 		*hitp = 0;
   1347  1.104    dyoung 		if (rtcache_setdst(ro, dst) == 0)
   1348  1.104    dyoung 			rt = _rtcache_init(ro, clone);
   1349   1.91    dyoung 	} else
   1350   1.91    dyoung 		*hitp = 1;
   1351   1.90    dyoung 
   1352  1.114    dyoung 	rtcache_invariants(ro);
   1353  1.114    dyoung 
   1354  1.104    dyoung 	return rt;
   1355   1.90    dyoung }
   1356   1.90    dyoung 
   1357   1.83     joerg void
   1358   1.86    dyoung rtcache_free(struct route *ro)
   1359   1.86    dyoung {
   1360   1.86    dyoung 	rtcache_clear(ro);
   1361   1.86    dyoung 	if (ro->ro_sa != NULL) {
   1362   1.86    dyoung 		sockaddr_free(ro->ro_sa);
   1363   1.86    dyoung 		ro->ro_sa = NULL;
   1364   1.86    dyoung 	}
   1365  1.114    dyoung 	rtcache_invariants(ro);
   1366   1.86    dyoung }
   1367   1.86    dyoung 
   1368   1.90    dyoung int
   1369   1.90    dyoung rtcache_setdst(struct route *ro, const struct sockaddr *sa)
   1370   1.83     joerg {
   1371   1.90    dyoung 	KASSERT(sa != NULL);
   1372   1.90    dyoung 
   1373  1.114    dyoung 	rtcache_invariants(ro);
   1374   1.90    dyoung 	if (ro->ro_sa != NULL && ro->ro_sa->sa_family == sa->sa_family) {
   1375   1.90    dyoung 		rtcache_clear(ro);
   1376  1.114    dyoung 		if (sockaddr_copy(ro->ro_sa, ro->ro_sa->sa_len, sa) != NULL) {
   1377  1.114    dyoung 			rtcache_invariants(ro);
   1378   1.96    dyoung 			return 0;
   1379  1.114    dyoung 		}
   1380   1.96    dyoung 		sockaddr_free(ro->ro_sa);
   1381   1.90    dyoung 	} else if (ro->ro_sa != NULL)
   1382   1.90    dyoung 		rtcache_free(ro);	/* free ro_sa, wrong family */
   1383   1.90    dyoung 
   1384  1.107    dyoung 	KASSERT(ro->_ro_rt == NULL);
   1385  1.107    dyoung 
   1386  1.107    dyoung 	if ((ro->ro_sa = sockaddr_dup(sa, M_NOWAIT)) == NULL) {
   1387  1.114    dyoung 		rtcache_invariants(ro);
   1388   1.90    dyoung 		return ENOMEM;
   1389  1.107    dyoung 	}
   1390  1.114    dyoung 	rtcache_invariants(ro);
   1391   1.90    dyoung 	return 0;
   1392   1.83     joerg }
   1393   1.92    dyoung 
   1394   1.92    dyoung static int
   1395   1.92    dyoung rt_walktree_visitor(struct radix_node *rn, void *v)
   1396   1.92    dyoung {
   1397   1.92    dyoung 	struct rtwalk *rw = (struct rtwalk *)v;
   1398   1.92    dyoung 
   1399   1.92    dyoung 	return (*rw->rw_f)((struct rtentry *)rn, rw->rw_v);
   1400   1.92    dyoung }
   1401   1.92    dyoung 
   1402   1.92    dyoung int
   1403   1.92    dyoung rt_walktree(sa_family_t family, int (*f)(struct rtentry *, void *), void *v)
   1404   1.92    dyoung {
   1405   1.92    dyoung 	struct radix_node_head *rnh = rt_tables[family];
   1406   1.92    dyoung 	struct rtwalk rw;
   1407   1.92    dyoung 
   1408   1.92    dyoung 	if (rnh == NULL)
   1409   1.92    dyoung 		return 0;
   1410   1.92    dyoung 
   1411   1.92    dyoung 	rw.rw_f = f;
   1412   1.92    dyoung 	rw.rw_v = v;
   1413   1.92    dyoung 
   1414   1.92    dyoung 	return rn_walktree(rnh, rt_walktree_visitor, &rw);
   1415   1.92    dyoung }
   1416