Home | History | Annotate | Line # | Download | only in net
route.c revision 1.207
      1  1.207     ozaki /*	$NetBSD: route.c,v 1.207 2018/03/23 04:09:41 ozaki-r 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.149     pooka #ifdef _KERNEL_OPT
     94  1.136       roy #include "opt_inet.h"
     95   1.90    dyoung #include "opt_route.h"
     96  1.175     ozaki #include "opt_net_mpsafe.h"
     97  1.149     pooka #endif
     98   1.90    dyoung 
     99   1.50     lukem #include <sys/cdefs.h>
    100  1.207     ozaki __KERNEL_RCSID(0, "$NetBSD: route.c,v 1.207 2018/03/23 04:09:41 ozaki-r Exp $");
    101    1.2       cgd 
    102    1.5   mycroft #include <sys/param.h>
    103  1.140     ozaki #ifdef RTFLUSH_DEBUG
    104   1.90    dyoung #include <sys/sysctl.h>
    105  1.140     ozaki #endif
    106    1.5   mycroft #include <sys/systm.h>
    107   1.35   thorpej #include <sys/callout.h>
    108    1.5   mycroft #include <sys/proc.h>
    109    1.5   mycroft #include <sys/mbuf.h>
    110    1.5   mycroft #include <sys/socket.h>
    111    1.5   mycroft #include <sys/socketvar.h>
    112    1.5   mycroft #include <sys/domain.h>
    113   1.18       kml #include <sys/kernel.h>
    114    1.5   mycroft #include <sys/ioctl.h>
    115   1.22   thorpej #include <sys/pool.h>
    116  1.119      elad #include <sys/kauth.h>
    117  1.170     ozaki #include <sys/workqueue.h>
    118  1.182     ozaki #include <sys/syslog.h>
    119  1.183     ozaki #include <sys/rwlock.h>
    120  1.183     ozaki #include <sys/mutex.h>
    121  1.183     ozaki #include <sys/cpu.h>
    122    1.1       cgd 
    123    1.5   mycroft #include <net/if.h>
    124  1.114    dyoung #include <net/if_dl.h>
    125    1.5   mycroft #include <net/route.h>
    126  1.196     ozaki #if defined(INET) || defined(INET6)
    127  1.196     ozaki #include <net/if_llatbl.h>
    128  1.196     ozaki #endif
    129    1.1       cgd 
    130    1.5   mycroft #include <netinet/in.h>
    131    1.5   mycroft #include <netinet/in_var.h>
    132    1.1       cgd 
    133   1.90    dyoung #ifdef RTFLUSH_DEBUG
    134   1.90    dyoung #define	rtcache_debug() __predict_false(_rtcache_debug)
    135   1.90    dyoung #else /* RTFLUSH_DEBUG */
    136   1.90    dyoung #define	rtcache_debug() 0
    137   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    138    1.5   mycroft 
    139  1.183     ozaki #ifdef RT_DEBUG
    140  1.183     ozaki #define RT_REFCNT_TRACE(rt)	printf("%s:%d: rt=%p refcnt=%d\n", \
    141  1.183     ozaki 				    __func__, __LINE__, (rt), (rt)->rt_refcnt)
    142  1.183     ozaki #else
    143  1.183     ozaki #define RT_REFCNT_TRACE(rt)	do {} while (0)
    144  1.183     ozaki #endif
    145  1.183     ozaki 
    146  1.204     ozaki #ifdef RT_DEBUG
    147  1.183     ozaki #define dlog(level, fmt, args...)	log(level, fmt, ##args)
    148  1.183     ozaki #else
    149  1.183     ozaki #define dlog(level, fmt, args...)	do {} while (0)
    150  1.183     ozaki #endif
    151  1.183     ozaki 
    152  1.155     ozaki struct rtstat		rtstat;
    153    1.1       cgd 
    154  1.155     ozaki static int		rttrash;	/* routes not in table but not freed */
    155    1.1       cgd 
    156  1.155     ozaki static struct pool	rtentry_pool;
    157  1.155     ozaki static struct pool	rttimer_pool;
    158   1.22   thorpej 
    159  1.155     ozaki static struct callout	rt_timer_ch; /* callout for rt_timer_timer() */
    160  1.177     ozaki static struct workqueue	*rt_timer_wq;
    161  1.177     ozaki static struct work	rt_timer_wk;
    162  1.177     ozaki 
    163  1.177     ozaki static void	rt_timer_init(void);
    164  1.181     ozaki static void	rt_timer_queue_remove_all(struct rttimer_queue *);
    165  1.178     ozaki static void	rt_timer_remove_all(struct rtentry *);
    166  1.177     ozaki static void	rt_timer_timer(void *);
    167   1.35   thorpej 
    168  1.183     ozaki /*
    169  1.183     ozaki  * Locking notes:
    170  1.183     ozaki  * - The routing table is protected by a global rwlock
    171  1.183     ozaki  *   - API: RT_RLOCK and friends
    172  1.200     ozaki  * - rtcaches are NOT protected by the framework
    173  1.200     ozaki  *   - Callers must guarantee a rtcache isn't accessed simultaneously
    174  1.200     ozaki  *   - How the constraint is guranteed in the wild
    175  1.200     ozaki  *     - Protect a rtcache by a mutex (e.g., inp_route)
    176  1.200     ozaki  *     - Make rtcache per-CPU and allow only accesses from softint
    177  1.200     ozaki  *       (e.g., ipforward_rt_percpu)
    178  1.183     ozaki  * - References to a rtentry is managed by reference counting and psref
    179  1.183     ozaki  *   - Reference couting is used for temporal reference when a rtentry
    180  1.183     ozaki  *     is fetched from the routing table
    181  1.183     ozaki  *   - psref is used for temporal reference when a rtentry is fetched
    182  1.183     ozaki  *     from a rtcache
    183  1.183     ozaki  *     - struct route (rtcache) has struct psref, so we cannot obtain
    184  1.183     ozaki  *       a reference twice on the same struct route
    185  1.183     ozaki  *   - Befere destroying or updating a rtentry, we have to wait for
    186  1.183     ozaki  *     all references left (see below for details)
    187  1.183     ozaki  *   - APIs
    188  1.183     ozaki  *     - An obtained rtentry via rtalloc1 or rtrequest* must be
    189  1.183     ozaki  *       unreferenced by rt_unref
    190  1.183     ozaki  *     - An obtained rtentry via rtcache_* must be unreferenced by
    191  1.183     ozaki  *       rtcache_unref
    192  1.183     ozaki  *   - TODO: once we get a lockless routing table, we should use only
    193  1.183     ozaki  *           psref for rtentries
    194  1.183     ozaki  * - rtentry destruction
    195  1.183     ozaki  *   - A rtentry is destroyed (freed) only when we call rtrequest(RTM_DELETE)
    196  1.183     ozaki  *   - If a caller of rtrequest grabs a reference of a rtentry, the caller
    197  1.183     ozaki  *     has a responsibility to destroy the rtentry by itself by calling
    198  1.183     ozaki  *     rt_free
    199  1.183     ozaki  *     - If not, rtrequest itself does that
    200  1.183     ozaki  *   - If rt_free is called in softint, the actual destruction routine is
    201  1.183     ozaki  *     deferred to a workqueue
    202  1.183     ozaki  * - rtentry update
    203  1.183     ozaki  *   - When updating a rtentry, RTF_UPDATING flag is set
    204  1.183     ozaki  *   - If a rtentry is set RTF_UPDATING, fetching the rtentry from
    205  1.183     ozaki  *     the routing table or a rtcache results in either of the following
    206  1.183     ozaki  *     cases:
    207  1.183     ozaki  *     - if the caller runs in softint, the caller fails to fetch
    208  1.183     ozaki  *     - otherwise, the caller waits for the update completed and retries
    209  1.183     ozaki  *       to fetch (probably succeed to fetch for the second time)
    210  1.199     ozaki  * - rtcache invalidation
    211  1.199     ozaki  *   - There is a global generation counter that is incremented when
    212  1.199     ozaki  *     any routes have been added or deleted
    213  1.199     ozaki  *   - When a rtcache caches a rtentry into itself, it also stores
    214  1.199     ozaki  *     a snapshot of the generation counter
    215  1.199     ozaki  *   - If the snapshot equals to the global counter, the cache is valid,
    216  1.199     ozaki  *     otherwise the cache is invalidated
    217  1.183     ozaki  */
    218  1.183     ozaki 
    219  1.183     ozaki /*
    220  1.200     ozaki  * Global lock for the routing table.
    221  1.183     ozaki  */
    222  1.183     ozaki static krwlock_t		rt_lock __cacheline_aligned;
    223  1.183     ozaki #ifdef NET_MPSAFE
    224  1.183     ozaki #define RT_RLOCK()		rw_enter(&rt_lock, RW_READER)
    225  1.183     ozaki #define RT_WLOCK()		rw_enter(&rt_lock, RW_WRITER)
    226  1.183     ozaki #define RT_UNLOCK()		rw_exit(&rt_lock)
    227  1.183     ozaki #define RT_LOCKED()		rw_lock_held(&rt_lock)
    228  1.183     ozaki #define	RT_ASSERT_WLOCK()	KASSERT(rw_write_held(&rt_lock))
    229  1.183     ozaki #else
    230  1.183     ozaki #define RT_RLOCK()		do {} while (0)
    231  1.183     ozaki #define RT_WLOCK()		do {} while (0)
    232  1.183     ozaki #define RT_UNLOCK()		do {} while (0)
    233  1.183     ozaki #define RT_LOCKED()		false
    234  1.183     ozaki #define	RT_ASSERT_WLOCK()	do {} while (0)
    235  1.183     ozaki #endif
    236  1.183     ozaki 
    237  1.199     ozaki static uint64_t rtcache_generation;
    238  1.199     ozaki 
    239  1.183     ozaki /*
    240  1.183     ozaki  * mutex and cv that are used to wait for references to a rtentry left
    241  1.183     ozaki  * before updating the rtentry.
    242  1.183     ozaki  */
    243  1.183     ozaki static struct {
    244  1.183     ozaki 	kmutex_t		lock;
    245  1.183     ozaki 	kcondvar_t		cv;
    246  1.183     ozaki 	bool			ongoing;
    247  1.183     ozaki 	const struct lwp	*lwp;
    248  1.183     ozaki } rt_update_global __cacheline_aligned;
    249  1.183     ozaki 
    250  1.183     ozaki /*
    251  1.183     ozaki  * A workqueue and stuff that are used to defer the destruction routine
    252  1.183     ozaki  * of rtentries.
    253  1.183     ozaki  */
    254  1.183     ozaki static struct {
    255  1.183     ozaki 	struct workqueue	*wq;
    256  1.183     ozaki 	struct work		wk;
    257  1.183     ozaki 	kmutex_t		lock;
    258  1.203  christos 	SLIST_HEAD(, rtentry)	queue;
    259  1.206     ozaki 	bool			enqueued;
    260  1.183     ozaki } rt_free_global __cacheline_aligned;
    261  1.183     ozaki 
    262  1.183     ozaki /* psref for rtentry */
    263  1.183     ozaki static struct psref_class *rt_psref_class __read_mostly;
    264  1.183     ozaki 
    265   1.90    dyoung #ifdef RTFLUSH_DEBUG
    266   1.90    dyoung static int _rtcache_debug = 0;
    267   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    268   1.90    dyoung 
    269  1.119      elad static kauth_listener_t route_listener;
    270  1.119      elad 
    271   1.60      matt static int rtdeletemsg(struct rtentry *);
    272   1.40    itojun 
    273  1.141     ozaki static void rt_maskedcopy(const struct sockaddr *,
    274  1.141     ozaki     struct sockaddr *, const struct sockaddr *);
    275  1.141     ozaki 
    276  1.199     ozaki static void rtcache_invalidate(void);
    277  1.144     ozaki 
    278  1.183     ozaki static void rt_ref(struct rtentry *);
    279  1.183     ozaki 
    280  1.183     ozaki static struct rtentry *
    281  1.195     ozaki     rtalloc1_locked(const struct sockaddr *, int, bool, bool);
    282  1.183     ozaki 
    283  1.183     ozaki static void rtcache_ref(struct rtentry *, struct route *);
    284  1.183     ozaki 
    285  1.188     ozaki #ifdef NET_MPSAFE
    286  1.183     ozaki static void rt_update_wait(void);
    287  1.188     ozaki #endif
    288  1.183     ozaki 
    289  1.183     ozaki static bool rt_wait_ok(void);
    290  1.183     ozaki static void rt_wait_refcnt(const char *, struct rtentry *, int);
    291  1.183     ozaki static void rt_wait_psref(struct rtentry *);
    292  1.183     ozaki 
    293  1.162     ozaki #ifdef DDB
    294  1.162     ozaki static void db_print_sa(const struct sockaddr *);
    295  1.162     ozaki static void db_print_ifa(struct ifaddr *);
    296  1.162     ozaki static int db_show_rtentry(struct rtentry *, void *);
    297  1.162     ozaki #endif
    298  1.162     ozaki 
    299   1.90    dyoung #ifdef RTFLUSH_DEBUG
    300  1.118     pooka static void sysctl_net_rtcache_setup(struct sysctllog **);
    301  1.118     pooka static void
    302  1.118     pooka sysctl_net_rtcache_setup(struct sysctllog **clog)
    303   1.90    dyoung {
    304   1.90    dyoung 	const struct sysctlnode *rnode;
    305   1.90    dyoung 
    306   1.90    dyoung 	if (sysctl_createv(clog, 0, NULL, &rnode, CTLFLAG_PERMANENT,
    307   1.90    dyoung 	    CTLTYPE_NODE,
    308   1.90    dyoung 	    "rtcache", SYSCTL_DESCR("Route cache related settings"),
    309  1.128     pooka 	    NULL, 0, NULL, 0, CTL_NET, CTL_CREATE, CTL_EOL) != 0)
    310   1.90    dyoung 		return;
    311   1.90    dyoung 	if (sysctl_createv(clog, 0, &rnode, &rnode,
    312   1.90    dyoung 	    CTLFLAG_PERMANENT|CTLFLAG_READWRITE, CTLTYPE_INT,
    313   1.90    dyoung 	    "debug", SYSCTL_DESCR("Debug route caches"),
    314   1.90    dyoung 	    NULL, 0, &_rtcache_debug, 0, CTL_CREATE, CTL_EOL) != 0)
    315   1.90    dyoung 		return;
    316   1.90    dyoung }
    317   1.90    dyoung #endif /* RTFLUSH_DEBUG */
    318   1.90    dyoung 
    319  1.144     ozaki static inline void
    320  1.144     ozaki rt_destroy(struct rtentry *rt)
    321  1.144     ozaki {
    322  1.144     ozaki 	if (rt->_rt_key != NULL)
    323  1.144     ozaki 		sockaddr_free(rt->_rt_key);
    324  1.144     ozaki 	if (rt->rt_gateway != NULL)
    325  1.144     ozaki 		sockaddr_free(rt->rt_gateway);
    326  1.144     ozaki 	if (rt_gettag(rt) != NULL)
    327  1.144     ozaki 		sockaddr_free(rt_gettag(rt));
    328  1.144     ozaki 	rt->_rt_key = rt->rt_gateway = rt->rt_tag = NULL;
    329  1.144     ozaki }
    330  1.144     ozaki 
    331  1.144     ozaki static inline const struct sockaddr *
    332  1.144     ozaki rt_setkey(struct rtentry *rt, const struct sockaddr *key, int flags)
    333  1.144     ozaki {
    334  1.144     ozaki 	if (rt->_rt_key == key)
    335  1.144     ozaki 		goto out;
    336  1.144     ozaki 
    337  1.144     ozaki 	if (rt->_rt_key != NULL)
    338  1.144     ozaki 		sockaddr_free(rt->_rt_key);
    339  1.144     ozaki 	rt->_rt_key = sockaddr_dup(key, flags);
    340  1.144     ozaki out:
    341  1.144     ozaki 	rt->rt_nodes->rn_key = (const char *)rt->_rt_key;
    342  1.144     ozaki 	return rt->_rt_key;
    343  1.144     ozaki }
    344  1.144     ozaki 
    345   1.81     joerg struct ifaddr *
    346   1.81     joerg rt_get_ifa(struct rtentry *rt)
    347   1.81     joerg {
    348   1.81     joerg 	struct ifaddr *ifa;
    349   1.81     joerg 
    350   1.81     joerg 	if ((ifa = rt->rt_ifa) == NULL)
    351   1.81     joerg 		return ifa;
    352   1.81     joerg 	else if (ifa->ifa_getifa == NULL)
    353   1.81     joerg 		return ifa;
    354   1.81     joerg #if 0
    355   1.81     joerg 	else if (ifa->ifa_seqno != NULL && *ifa->ifa_seqno == rt->rt_ifa_seqno)
    356   1.81     joerg 		return ifa;
    357   1.81     joerg #endif
    358   1.81     joerg 	else {
    359   1.94    dyoung 		ifa = (*ifa->ifa_getifa)(ifa, rt_getkey(rt));
    360  1.145       roy 		if (ifa == NULL)
    361  1.145       roy 			return NULL;
    362   1.81     joerg 		rt_replace_ifa(rt, ifa);
    363   1.81     joerg 		return ifa;
    364   1.81     joerg 	}
    365   1.81     joerg }
    366   1.81     joerg 
    367   1.80     joerg static void
    368   1.80     joerg rt_set_ifa1(struct rtentry *rt, struct ifaddr *ifa)
    369   1.80     joerg {
    370   1.80     joerg 	rt->rt_ifa = ifa;
    371   1.80     joerg 	if (ifa->ifa_seqno != NULL)
    372   1.80     joerg 		rt->rt_ifa_seqno = *ifa->ifa_seqno;
    373   1.80     joerg }
    374   1.80     joerg 
    375  1.116       roy /*
    376  1.116       roy  * Is this route the connected route for the ifa?
    377  1.116       roy  */
    378  1.116       roy static int
    379  1.116       roy rt_ifa_connected(const struct rtentry *rt, const struct ifaddr *ifa)
    380  1.116       roy {
    381  1.116       roy 	const struct sockaddr *key, *dst, *odst;
    382  1.116       roy 	struct sockaddr_storage maskeddst;
    383  1.116       roy 
    384  1.116       roy 	key = rt_getkey(rt);
    385  1.116       roy 	dst = rt->rt_flags & RTF_HOST ? ifa->ifa_dstaddr : ifa->ifa_addr;
    386  1.116       roy 	if (dst == NULL ||
    387  1.116       roy 	    dst->sa_family != key->sa_family ||
    388  1.116       roy 	    dst->sa_len != key->sa_len)
    389  1.116       roy 		return 0;
    390  1.116       roy 	if ((rt->rt_flags & RTF_HOST) == 0 && ifa->ifa_netmask) {
    391  1.116       roy 		odst = dst;
    392  1.116       roy 		dst = (struct sockaddr *)&maskeddst;
    393  1.116       roy 		rt_maskedcopy(odst, (struct sockaddr *)&maskeddst,
    394  1.116       roy 		    ifa->ifa_netmask);
    395  1.116       roy 	}
    396  1.116       roy 	return (memcmp(dst, key, dst->sa_len) == 0);
    397  1.116       roy }
    398  1.116       roy 
    399   1.80     joerg void
    400   1.80     joerg rt_replace_ifa(struct rtentry *rt, struct ifaddr *ifa)
    401   1.80     joerg {
    402  1.116       roy 	if (rt->rt_ifa &&
    403  1.116       roy 	    rt->rt_ifa != ifa &&
    404  1.116       roy 	    rt->rt_ifa->ifa_flags & IFA_ROUTE &&
    405  1.116       roy 	    rt_ifa_connected(rt, rt->rt_ifa))
    406  1.116       roy 	{
    407  1.116       roy 		RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
    408  1.116       roy 		    "replace deleted IFA_ROUTE\n",
    409  1.116       roy 		    (void *)rt->_rt_key, (void *)rt->rt_ifa);
    410  1.116       roy 		rt->rt_ifa->ifa_flags &= ~IFA_ROUTE;
    411  1.116       roy 		if (rt_ifa_connected(rt, ifa)) {
    412  1.116       roy 			RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
    413  1.116       roy 			    "replace added IFA_ROUTE\n",
    414  1.116       roy 			    (void *)rt->_rt_key, (void *)ifa);
    415  1.116       roy 			ifa->ifa_flags |= IFA_ROUTE;
    416  1.116       roy 		}
    417  1.116       roy 	}
    418  1.116       roy 
    419  1.133     rmind 	ifaref(ifa);
    420  1.133     rmind 	ifafree(rt->rt_ifa);
    421   1.80     joerg 	rt_set_ifa1(rt, ifa);
    422   1.80     joerg }
    423   1.80     joerg 
    424   1.80     joerg static void
    425   1.80     joerg rt_set_ifa(struct rtentry *rt, struct ifaddr *ifa)
    426   1.80     joerg {
    427  1.133     rmind 	ifaref(ifa);
    428   1.80     joerg 	rt_set_ifa1(rt, ifa);
    429   1.80     joerg }
    430   1.80     joerg 
    431  1.119      elad static int
    432  1.119      elad route_listener_cb(kauth_cred_t cred, kauth_action_t action, void *cookie,
    433  1.119      elad     void *arg0, void *arg1, void *arg2, void *arg3)
    434  1.119      elad {
    435  1.119      elad 	struct rt_msghdr *rtm;
    436  1.119      elad 	int result;
    437  1.119      elad 
    438  1.119      elad 	result = KAUTH_RESULT_DEFER;
    439  1.119      elad 	rtm = arg1;
    440  1.119      elad 
    441  1.120      elad 	if (action != KAUTH_NETWORK_ROUTE)
    442  1.120      elad 		return result;
    443  1.120      elad 
    444  1.119      elad 	if (rtm->rtm_type == RTM_GET)
    445  1.119      elad 		result = KAUTH_RESULT_ALLOW;
    446  1.119      elad 
    447  1.119      elad 	return result;
    448  1.119      elad }
    449  1.119      elad 
    450  1.183     ozaki static void rt_free_work(struct work *, void *);
    451  1.183     ozaki 
    452    1.9   mycroft void
    453  1.124      matt rt_init(void)
    454    1.1       cgd {
    455  1.183     ozaki 	int error;
    456   1.22   thorpej 
    457  1.118     pooka #ifdef RTFLUSH_DEBUG
    458  1.118     pooka 	sysctl_net_rtcache_setup(NULL);
    459  1.118     pooka #endif
    460  1.118     pooka 
    461  1.183     ozaki 	mutex_init(&rt_free_global.lock, MUTEX_DEFAULT, IPL_SOFTNET);
    462  1.203  christos 	SLIST_INIT(&rt_free_global.queue);
    463  1.206     ozaki 	rt_free_global.enqueued = false;
    464  1.203  christos 
    465  1.183     ozaki 	rt_psref_class = psref_class_create("rtentry", IPL_SOFTNET);
    466  1.183     ozaki 
    467  1.183     ozaki 	error = workqueue_create(&rt_free_global.wq, "rt_free",
    468  1.183     ozaki 	    rt_free_work, NULL, PRI_SOFTNET, IPL_SOFTNET, WQ_MPSAFE);
    469  1.183     ozaki 	if (error)
    470  1.183     ozaki 		panic("%s: workqueue_create failed (%d)\n", __func__, error);
    471  1.183     ozaki 
    472  1.183     ozaki 	mutex_init(&rt_update_global.lock, MUTEX_DEFAULT, IPL_SOFTNET);
    473  1.183     ozaki 	cv_init(&rt_update_global.cv, "rt_update");
    474  1.183     ozaki 
    475  1.113     pooka 	pool_init(&rtentry_pool, sizeof(struct rtentry), 0, 0, 0, "rtentpl",
    476  1.113     pooka 	    NULL, IPL_SOFTNET);
    477  1.113     pooka 	pool_init(&rttimer_pool, sizeof(struct rttimer), 0, 0, 0, "rttmrpl",
    478  1.113     pooka 	    NULL, IPL_SOFTNET);
    479  1.113     pooka 
    480   1.10   mycroft 	rn_init();	/* initialize all zeroes, all ones, mask table */
    481  1.125    dyoung 	rtbl_init();
    482  1.119      elad 
    483  1.119      elad 	route_listener = kauth_listen_scope(KAUTH_SCOPE_NETWORK,
    484  1.119      elad 	    route_listener_cb, NULL);
    485    1.1       cgd }
    486    1.1       cgd 
    487  1.144     ozaki static void
    488  1.199     ozaki rtcache_invalidate(void)
    489   1.82    dyoung {
    490   1.90    dyoung 
    491  1.201     ozaki 	RT_ASSERT_WLOCK();
    492  1.201     ozaki 
    493   1.90    dyoung 	if (rtcache_debug())
    494   1.90    dyoung 		printf("%s: enter\n", __func__);
    495   1.90    dyoung 
    496  1.199     ozaki 	rtcache_generation++;
    497   1.82    dyoung }
    498   1.82    dyoung 
    499  1.158     ozaki #ifdef RT_DEBUG
    500  1.158     ozaki static void
    501  1.158     ozaki dump_rt(const struct rtentry *rt)
    502  1.158     ozaki {
    503  1.158     ozaki 	char buf[512];
    504  1.158     ozaki 
    505  1.158     ozaki 	aprint_normal("rt: ");
    506  1.158     ozaki 	aprint_normal("p=%p ", rt);
    507  1.158     ozaki 	if (rt->_rt_key == NULL) {
    508  1.158     ozaki 		aprint_normal("dst=(NULL) ");
    509  1.158     ozaki 	} else {
    510  1.158     ozaki 		sockaddr_format(rt->_rt_key, buf, sizeof(buf));
    511  1.158     ozaki 		aprint_normal("dst=%s ", buf);
    512  1.158     ozaki 	}
    513  1.158     ozaki 	if (rt->rt_gateway == NULL) {
    514  1.158     ozaki 		aprint_normal("gw=(NULL) ");
    515  1.158     ozaki 	} else {
    516  1.158     ozaki 		sockaddr_format(rt->_rt_key, buf, sizeof(buf));
    517  1.158     ozaki 		aprint_normal("gw=%s ", buf);
    518  1.158     ozaki 	}
    519  1.158     ozaki 	aprint_normal("flags=%x ", rt->rt_flags);
    520  1.158     ozaki 	if (rt->rt_ifp == NULL) {
    521  1.158     ozaki 		aprint_normal("if=(NULL) ");
    522  1.158     ozaki 	} else {
    523  1.158     ozaki 		aprint_normal("if=%s ", rt->rt_ifp->if_xname);
    524  1.158     ozaki 	}
    525  1.158     ozaki 	aprint_normal("\n");
    526  1.158     ozaki }
    527  1.158     ozaki #endif /* RT_DEBUG */
    528  1.158     ozaki 
    529    1.1       cgd /*
    530  1.146     ozaki  * Packet routing routines. If success, refcnt of a returned rtentry
    531  1.146     ozaki  * will be incremented. The caller has to rtfree it by itself.
    532    1.1       cgd  */
    533    1.1       cgd struct rtentry *
    534  1.195     ozaki rtalloc1_locked(const struct sockaddr *dst, int report, bool wait_ok,
    535  1.195     ozaki     bool wlock)
    536    1.1       cgd {
    537  1.158     ozaki 	rtbl_t *rtbl;
    538   1.36  augustss 	struct rtentry *rt;
    539  1.159  christos 	int s;
    540    1.1       cgd 
    541  1.188     ozaki #ifdef NET_MPSAFE
    542  1.183     ozaki retry:
    543  1.188     ozaki #endif
    544  1.159  christos 	s = splsoftnet();
    545  1.158     ozaki 	rtbl = rt_gettable(dst->sa_family);
    546  1.159  christos 	if (rtbl == NULL)
    547  1.158     ozaki 		goto miss;
    548  1.158     ozaki 
    549  1.158     ozaki 	rt = rt_matchaddr(rtbl, dst);
    550  1.159  christos 	if (rt == NULL)
    551  1.158     ozaki 		goto miss;
    552  1.159  christos 
    553  1.183     ozaki 	if (!ISSET(rt->rt_flags, RTF_UP))
    554  1.183     ozaki 		goto miss;
    555  1.183     ozaki 
    556  1.188     ozaki #ifdef NET_MPSAFE
    557  1.183     ozaki 	if (ISSET(rt->rt_flags, RTF_UPDATING) &&
    558  1.183     ozaki 	    /* XXX updater should be always able to acquire */
    559  1.183     ozaki 	    curlwp != rt_update_global.lwp) {
    560  1.183     ozaki 		if (!wait_ok || !rt_wait_ok())
    561  1.183     ozaki 			goto miss;
    562  1.183     ozaki 		RT_UNLOCK();
    563  1.183     ozaki 		splx(s);
    564  1.183     ozaki 
    565  1.183     ozaki 		/* We can wait until the update is complete */
    566  1.183     ozaki 		rt_update_wait();
    567  1.183     ozaki 
    568  1.195     ozaki 		if (wlock)
    569  1.195     ozaki 			RT_WLOCK();
    570  1.195     ozaki 		else
    571  1.195     ozaki 			RT_RLOCK();
    572  1.183     ozaki 		goto retry;
    573  1.183     ozaki 	}
    574  1.188     ozaki #endif /* NET_MPSAFE */
    575  1.183     ozaki 
    576  1.183     ozaki 	rt_ref(rt);
    577  1.183     ozaki 	RT_REFCNT_TRACE(rt);
    578  1.158     ozaki 
    579  1.159  christos 	splx(s);
    580  1.159  christos 	return rt;
    581  1.158     ozaki miss:
    582  1.159  christos 	rtstat.rts_unreach++;
    583  1.158     ozaki 	if (report) {
    584  1.159  christos 		struct rt_addrinfo info;
    585  1.159  christos 
    586  1.160  christos 		memset(&info, 0, sizeof(info));
    587  1.158     ozaki 		info.rti_info[RTAX_DST] = dst;
    588  1.159  christos 		rt_missmsg(RTM_MISS, &info, 0, 0);
    589    1.1       cgd 	}
    590    1.1       cgd 	splx(s);
    591  1.159  christos 	return NULL;
    592    1.1       cgd }
    593    1.1       cgd 
    594  1.183     ozaki struct rtentry *
    595  1.183     ozaki rtalloc1(const struct sockaddr *dst, int report)
    596  1.183     ozaki {
    597  1.183     ozaki 	struct rtentry *rt;
    598  1.183     ozaki 
    599  1.183     ozaki 	RT_RLOCK();
    600  1.195     ozaki 	rt = rtalloc1_locked(dst, report, true, false);
    601  1.183     ozaki 	RT_UNLOCK();
    602  1.183     ozaki 
    603  1.183     ozaki 	return rt;
    604  1.183     ozaki }
    605  1.183     ozaki 
    606  1.151     ozaki static void
    607  1.183     ozaki rt_ref(struct rtentry *rt)
    608  1.183     ozaki {
    609  1.183     ozaki 
    610  1.183     ozaki 	KASSERT(rt->rt_refcnt >= 0);
    611  1.183     ozaki 	atomic_inc_uint(&rt->rt_refcnt);
    612  1.183     ozaki }
    613  1.183     ozaki 
    614  1.183     ozaki void
    615  1.183     ozaki rt_unref(struct rtentry *rt)
    616  1.183     ozaki {
    617  1.183     ozaki 
    618  1.183     ozaki 	KASSERT(rt != NULL);
    619  1.183     ozaki 	KASSERTMSG(rt->rt_refcnt > 0, "refcnt=%d", rt->rt_refcnt);
    620  1.183     ozaki 
    621  1.183     ozaki 	atomic_dec_uint(&rt->rt_refcnt);
    622  1.183     ozaki 	if (!ISSET(rt->rt_flags, RTF_UP) || ISSET(rt->rt_flags, RTF_UPDATING)) {
    623  1.183     ozaki 		mutex_enter(&rt_free_global.lock);
    624  1.183     ozaki 		cv_broadcast(&rt->rt_cv);
    625  1.183     ozaki 		mutex_exit(&rt_free_global.lock);
    626  1.183     ozaki 	}
    627  1.183     ozaki }
    628  1.183     ozaki 
    629  1.183     ozaki static bool
    630  1.183     ozaki rt_wait_ok(void)
    631  1.151     ozaki {
    632  1.151     ozaki 
    633  1.183     ozaki 	KASSERT(!cpu_intr_p());
    634  1.183     ozaki 	return !cpu_softintr_p();
    635  1.183     ozaki }
    636  1.151     ozaki 
    637  1.183     ozaki void
    638  1.183     ozaki rt_wait_refcnt(const char *title, struct rtentry *rt, int cnt)
    639  1.183     ozaki {
    640  1.183     ozaki 	mutex_enter(&rt_free_global.lock);
    641  1.183     ozaki 	while (rt->rt_refcnt > cnt) {
    642  1.183     ozaki 		dlog(LOG_DEBUG, "%s: %s waiting (refcnt=%d)\n",
    643  1.183     ozaki 		    __func__, title, rt->rt_refcnt);
    644  1.183     ozaki 		cv_wait(&rt->rt_cv, &rt_free_global.lock);
    645  1.183     ozaki 		dlog(LOG_DEBUG, "%s: %s waited (refcnt=%d)\n",
    646  1.183     ozaki 		    __func__, title, rt->rt_refcnt);
    647  1.183     ozaki 	}
    648  1.183     ozaki 	mutex_exit(&rt_free_global.lock);
    649  1.151     ozaki }
    650  1.151     ozaki 
    651    1.9   mycroft void
    652  1.183     ozaki rt_wait_psref(struct rtentry *rt)
    653  1.183     ozaki {
    654  1.183     ozaki 
    655  1.183     ozaki 	psref_target_destroy(&rt->rt_psref, rt_psref_class);
    656  1.183     ozaki 	psref_target_init(&rt->rt_psref, rt_psref_class);
    657  1.183     ozaki }
    658  1.183     ozaki 
    659  1.183     ozaki static void
    660  1.183     ozaki _rt_free(struct rtentry *rt)
    661    1.1       cgd {
    662   1.36  augustss 	struct ifaddr *ifa;
    663   1.10   mycroft 
    664  1.183     ozaki 	/*
    665  1.183     ozaki 	 * Need to avoid a deadlock on rt_wait_refcnt of update
    666  1.183     ozaki 	 * and a conflict on psref_target_destroy of update.
    667  1.183     ozaki 	 */
    668  1.188     ozaki #ifdef NET_MPSAFE
    669  1.183     ozaki 	rt_update_wait();
    670  1.188     ozaki #endif
    671  1.183     ozaki 
    672  1.183     ozaki 	RT_REFCNT_TRACE(rt);
    673  1.183     ozaki 	KASSERTMSG(rt->rt_refcnt >= 0, "refcnt=%d", rt->rt_refcnt);
    674  1.183     ozaki 	rt_wait_refcnt("free", rt, 0);
    675  1.185     ozaki #ifdef NET_MPSAFE
    676  1.183     ozaki 	psref_target_destroy(&rt->rt_psref, rt_psref_class);
    677  1.185     ozaki #endif
    678  1.183     ozaki 
    679  1.183     ozaki 	rt_assert_inactive(rt);
    680  1.183     ozaki 	rttrash--;
    681  1.183     ozaki 	ifa = rt->rt_ifa;
    682  1.183     ozaki 	rt->rt_ifa = NULL;
    683  1.183     ozaki 	ifafree(ifa);
    684  1.183     ozaki 	rt->rt_ifp = NULL;
    685  1.183     ozaki 	cv_destroy(&rt->rt_cv);
    686  1.183     ozaki 	rt_destroy(rt);
    687  1.183     ozaki 	pool_put(&rtentry_pool, rt);
    688  1.183     ozaki }
    689  1.183     ozaki 
    690  1.183     ozaki static void
    691  1.183     ozaki rt_free_work(struct work *wk, void *arg)
    692  1.183     ozaki {
    693  1.183     ozaki 
    694  1.203  christos 	for (;;) {
    695  1.203  christos 		struct rtentry *rt;
    696  1.203  christos 
    697  1.203  christos 		mutex_enter(&rt_free_global.lock);
    698  1.206     ozaki 		rt_free_global.enqueued = false;
    699  1.203  christos 		if ((rt = SLIST_FIRST(&rt_free_global.queue)) == NULL) {
    700  1.203  christos 			mutex_exit(&rt_free_global.lock);
    701  1.203  christos 			return;
    702  1.203  christos 		}
    703  1.203  christos 		SLIST_REMOVE_HEAD(&rt_free_global.queue, rt_free);
    704  1.183     ozaki 		mutex_exit(&rt_free_global.lock);
    705  1.183     ozaki 		atomic_dec_uint(&rt->rt_refcnt);
    706  1.183     ozaki 		_rt_free(rt);
    707  1.183     ozaki 	}
    708  1.183     ozaki }
    709  1.183     ozaki 
    710  1.183     ozaki void
    711  1.183     ozaki rt_free(struct rtentry *rt)
    712  1.183     ozaki {
    713  1.183     ozaki 
    714  1.132     rmind 	KASSERT(rt->rt_refcnt > 0);
    715  1.202  christos 	if (rt_wait_ok()) {
    716  1.183     ozaki 		atomic_dec_uint(&rt->rt_refcnt);
    717  1.183     ozaki 		_rt_free(rt);
    718  1.202  christos 		return;
    719  1.183     ozaki 	}
    720  1.202  christos 
    721  1.202  christos 	mutex_enter(&rt_free_global.lock);
    722  1.202  christos 	rt_ref(rt);
    723  1.203  christos 	SLIST_INSERT_HEAD(&rt_free_global.queue, rt, rt_free);
    724  1.206     ozaki 	if (!rt_free_global.enqueued) {
    725  1.206     ozaki 		workqueue_enqueue(rt_free_global.wq, &rt_free_global.wk, NULL);
    726  1.206     ozaki 		rt_free_global.enqueued = true;
    727  1.206     ozaki 	}
    728  1.202  christos 	mutex_exit(&rt_free_global.lock);
    729  1.183     ozaki }
    730  1.183     ozaki 
    731  1.188     ozaki #ifdef NET_MPSAFE
    732  1.183     ozaki static void
    733  1.183     ozaki rt_update_wait(void)
    734  1.183     ozaki {
    735  1.132     rmind 
    736  1.183     ozaki 	mutex_enter(&rt_update_global.lock);
    737  1.183     ozaki 	while (rt_update_global.ongoing) {
    738  1.183     ozaki 		dlog(LOG_DEBUG, "%s: waiting lwp=%p\n", __func__, curlwp);
    739  1.183     ozaki 		cv_wait(&rt_update_global.cv, &rt_update_global.lock);
    740  1.183     ozaki 		dlog(LOG_DEBUG, "%s: waited lwp=%p\n", __func__, curlwp);
    741    1.1       cgd 	}
    742  1.183     ozaki 	mutex_exit(&rt_update_global.lock);
    743  1.183     ozaki }
    744  1.188     ozaki #endif
    745  1.183     ozaki 
    746  1.183     ozaki int
    747  1.183     ozaki rt_update_prepare(struct rtentry *rt)
    748  1.183     ozaki {
    749  1.183     ozaki 
    750  1.183     ozaki 	dlog(LOG_DEBUG, "%s: updating rt=%p lwp=%p\n", __func__, rt, curlwp);
    751  1.183     ozaki 
    752  1.183     ozaki 	RT_WLOCK();
    753  1.183     ozaki 	/* If the entry is being destroyed, don't proceed the update. */
    754  1.183     ozaki 	if (!ISSET(rt->rt_flags, RTF_UP)) {
    755  1.183     ozaki 		RT_UNLOCK();
    756  1.205     ozaki 		return ESRCH;
    757  1.183     ozaki 	}
    758  1.183     ozaki 	rt->rt_flags |= RTF_UPDATING;
    759  1.183     ozaki 	RT_UNLOCK();
    760  1.183     ozaki 
    761  1.183     ozaki 	mutex_enter(&rt_update_global.lock);
    762  1.183     ozaki 	while (rt_update_global.ongoing) {
    763  1.183     ozaki 		dlog(LOG_DEBUG, "%s: waiting ongoing updating rt=%p lwp=%p\n",
    764  1.183     ozaki 		    __func__, rt, curlwp);
    765  1.183     ozaki 		cv_wait(&rt_update_global.cv, &rt_update_global.lock);
    766  1.183     ozaki 		dlog(LOG_DEBUG, "%s: waited ongoing updating rt=%p lwp=%p\n",
    767  1.183     ozaki 		    __func__, rt, curlwp);
    768  1.183     ozaki 	}
    769  1.183     ozaki 	rt_update_global.ongoing = true;
    770  1.183     ozaki 	/* XXX need it to avoid rt_update_wait by updater itself. */
    771  1.183     ozaki 	rt_update_global.lwp = curlwp;
    772  1.183     ozaki 	mutex_exit(&rt_update_global.lock);
    773  1.183     ozaki 
    774  1.183     ozaki 	rt_wait_refcnt("update", rt, 1);
    775  1.183     ozaki 	rt_wait_psref(rt);
    776  1.183     ozaki 
    777  1.183     ozaki 	return 0;
    778  1.183     ozaki }
    779  1.183     ozaki 
    780  1.183     ozaki void
    781  1.183     ozaki rt_update_finish(struct rtentry *rt)
    782  1.183     ozaki {
    783  1.183     ozaki 
    784  1.183     ozaki 	RT_WLOCK();
    785  1.183     ozaki 	rt->rt_flags &= ~RTF_UPDATING;
    786  1.183     ozaki 	RT_UNLOCK();
    787  1.183     ozaki 
    788  1.183     ozaki 	mutex_enter(&rt_update_global.lock);
    789  1.183     ozaki 	rt_update_global.ongoing = false;
    790  1.183     ozaki 	rt_update_global.lwp = NULL;
    791  1.183     ozaki 	cv_broadcast(&rt_update_global.cv);
    792  1.183     ozaki 	mutex_exit(&rt_update_global.lock);
    793  1.183     ozaki 
    794  1.183     ozaki 	dlog(LOG_DEBUG, "%s: updated rt=%p lwp=%p\n", __func__, rt, curlwp);
    795    1.1       cgd }
    796    1.1       cgd 
    797    1.1       cgd /*
    798    1.1       cgd  * Force a routing table entry to the specified
    799    1.1       cgd  * destination to go through the given gateway.
    800    1.1       cgd  * Normally called as a result of a routing redirect
    801    1.1       cgd  * message from the network layer.
    802    1.1       cgd  *
    803   1.13   mycroft  * N.B.: must be called at splsoftnet
    804    1.1       cgd  */
    805   1.14  christos void
    806   1.60      matt rtredirect(const struct sockaddr *dst, const struct sockaddr *gateway,
    807   1.60      matt 	const struct sockaddr *netmask, int flags, const struct sockaddr *src,
    808   1.60      matt 	struct rtentry **rtp)
    809    1.1       cgd {
    810   1.36  augustss 	struct rtentry *rt;
    811    1.1       cgd 	int error = 0;
    812  1.121    dyoung 	uint64_t *stat = NULL;
    813   1.10   mycroft 	struct rt_addrinfo info;
    814   1.10   mycroft 	struct ifaddr *ifa;
    815  1.173     ozaki 	struct psref psref;
    816    1.1       cgd 
    817    1.1       cgd 	/* verify the gateway is directly reachable */
    818  1.173     ozaki 	if ((ifa = ifa_ifwithnet_psref(gateway, &psref)) == NULL) {
    819    1.1       cgd 		error = ENETUNREACH;
    820    1.8       cgd 		goto out;
    821    1.1       cgd 	}
    822    1.1       cgd 	rt = rtalloc1(dst, 0);
    823    1.1       cgd 	/*
    824    1.1       cgd 	 * If the redirect isn't from our current router for this dst,
    825    1.1       cgd 	 * it's either old or wrong.  If it redirects us to ourselves,
    826    1.1       cgd 	 * we have a routing loop, perhaps as a result of an interface
    827    1.1       cgd 	 * going down recently.
    828    1.1       cgd 	 */
    829   1.10   mycroft 	if (!(flags & RTF_DONE) && rt &&
    830  1.115      yamt 	     (sockaddr_cmp(src, rt->rt_gateway) != 0 || rt->rt_ifa != ifa))
    831    1.1       cgd 		error = EINVAL;
    832  1.173     ozaki 	else {
    833  1.173     ozaki 		int s = pserialize_read_enter();
    834  1.173     ozaki 		struct ifaddr *_ifa;
    835  1.173     ozaki 
    836  1.173     ozaki 		_ifa = ifa_ifwithaddr(gateway);
    837  1.173     ozaki 		if (_ifa != NULL)
    838  1.173     ozaki 			error = EHOSTUNREACH;
    839  1.173     ozaki 		pserialize_read_exit(s);
    840  1.173     ozaki 	}
    841    1.1       cgd 	if (error)
    842    1.1       cgd 		goto done;
    843    1.1       cgd 	/*
    844    1.1       cgd 	 * Create a new entry if we just got back a wildcard entry
    845   1.33     soren 	 * or the lookup failed.  This is necessary for hosts
    846    1.1       cgd 	 * which use routing redirects generated by smart gateways
    847    1.1       cgd 	 * to dynamically build the routing tables.
    848    1.1       cgd 	 */
    849   1.95    dyoung 	if (rt == NULL || (rt_mask(rt) && rt_mask(rt)->sa_len < 2))
    850    1.1       cgd 		goto create;
    851    1.1       cgd 	/*
    852    1.1       cgd 	 * Don't listen to the redirect if it's
    853   1.65     perry 	 * for a route to an interface.
    854    1.1       cgd 	 */
    855    1.1       cgd 	if (rt->rt_flags & RTF_GATEWAY) {
    856    1.1       cgd 		if (((rt->rt_flags & RTF_HOST) == 0) && (flags & RTF_HOST)) {
    857    1.1       cgd 			/*
    858    1.1       cgd 			 * Changing from route to net => route to host.
    859    1.1       cgd 			 * Create new route, rather than smashing route to net.
    860    1.1       cgd 			 */
    861    1.1       cgd 		create:
    862   1.95    dyoung 			if (rt != NULL)
    863  1.183     ozaki 				rt_unref(rt);
    864    1.1       cgd 			flags |=  RTF_GATEWAY | RTF_DYNAMIC;
    865  1.122    kefren 			memset(&info, 0, sizeof(info));
    866   1.39    itojun 			info.rti_info[RTAX_DST] = dst;
    867   1.39    itojun 			info.rti_info[RTAX_GATEWAY] = gateway;
    868   1.39    itojun 			info.rti_info[RTAX_NETMASK] = netmask;
    869   1.39    itojun 			info.rti_ifa = ifa;
    870   1.39    itojun 			info.rti_flags = flags;
    871   1.39    itojun 			rt = NULL;
    872   1.39    itojun 			error = rtrequest1(RTM_ADD, &info, &rt);
    873   1.39    itojun 			if (rt != NULL)
    874   1.39    itojun 				flags = rt->rt_flags;
    875    1.1       cgd 			stat = &rtstat.rts_dynamic;
    876    1.1       cgd 		} else {
    877    1.1       cgd 			/*
    878    1.1       cgd 			 * Smash the current notion of the gateway to
    879    1.1       cgd 			 * this destination.  Should check about netmask!!!
    880    1.1       cgd 			 */
    881  1.190     ozaki #ifdef NET_MPSAFE
    882  1.190     ozaki 			KASSERT(!cpu_softintr_p());
    883  1.190     ozaki 
    884  1.190     ozaki 			error = rt_update_prepare(rt);
    885  1.164     ozaki 			if (error == 0) {
    886  1.190     ozaki #endif
    887  1.190     ozaki 				error = rt_setgate(rt, gateway);
    888  1.190     ozaki 				if (error == 0) {
    889  1.190     ozaki 					rt->rt_flags |= RTF_MODIFIED;
    890  1.190     ozaki 					flags |= RTF_MODIFIED;
    891  1.190     ozaki 				}
    892  1.190     ozaki #ifdef NET_MPSAFE
    893  1.190     ozaki 				rt_update_finish(rt);
    894  1.190     ozaki 			} else {
    895  1.190     ozaki 				/*
    896  1.190     ozaki 				 * If error != 0, the rtentry is being
    897  1.190     ozaki 				 * destroyed, so doing nothing doesn't
    898  1.190     ozaki 				 * matter.
    899  1.190     ozaki 				 */
    900  1.164     ozaki 			}
    901  1.190     ozaki #endif
    902   1.10   mycroft 			stat = &rtstat.rts_newgateway;
    903    1.1       cgd 		}
    904    1.1       cgd 	} else
    905    1.1       cgd 		error = EHOSTUNREACH;
    906    1.1       cgd done:
    907    1.1       cgd 	if (rt) {
    908   1.95    dyoung 		if (rtp != NULL && !error)
    909    1.1       cgd 			*rtp = rt;
    910    1.1       cgd 		else
    911  1.183     ozaki 			rt_unref(rt);
    912    1.1       cgd 	}
    913    1.8       cgd out:
    914    1.1       cgd 	if (error)
    915    1.1       cgd 		rtstat.rts_badredirect++;
    916    1.8       cgd 	else if (stat != NULL)
    917    1.8       cgd 		(*stat)++;
    918   1.95    dyoung 	memset(&info, 0, sizeof(info));
    919   1.10   mycroft 	info.rti_info[RTAX_DST] = dst;
    920   1.10   mycroft 	info.rti_info[RTAX_GATEWAY] = gateway;
    921   1.10   mycroft 	info.rti_info[RTAX_NETMASK] = netmask;
    922   1.10   mycroft 	info.rti_info[RTAX_AUTHOR] = src;
    923   1.10   mycroft 	rt_missmsg(RTM_REDIRECT, &info, flags, error);
    924  1.173     ozaki 	ifa_release(ifa, &psref);
    925    1.1       cgd }
    926    1.1       cgd 
    927    1.1       cgd /*
    928  1.146     ozaki  * Delete a route and generate a message.
    929  1.146     ozaki  * It doesn't free a passed rt.
    930   1.40    itojun  */
    931   1.40    itojun static int
    932   1.60      matt rtdeletemsg(struct rtentry *rt)
    933   1.40    itojun {
    934   1.40    itojun 	int error;
    935   1.40    itojun 	struct rt_addrinfo info;
    936  1.180     ozaki 	struct rtentry *retrt;
    937   1.40    itojun 
    938   1.40    itojun 	/*
    939   1.40    itojun 	 * Request the new route so that the entry is not actually
    940   1.40    itojun 	 * deleted.  That will allow the information being reported to
    941   1.40    itojun 	 * be accurate (and consistent with route_output()).
    942   1.40    itojun 	 */
    943   1.95    dyoung 	memset(&info, 0, sizeof(info));
    944   1.94    dyoung 	info.rti_info[RTAX_DST] = rt_getkey(rt);
    945   1.40    itojun 	info.rti_info[RTAX_NETMASK] = rt_mask(rt);
    946   1.40    itojun 	info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
    947   1.40    itojun 	info.rti_flags = rt->rt_flags;
    948  1.180     ozaki 	error = rtrequest1(RTM_DELETE, &info, &retrt);
    949   1.40    itojun 
    950   1.40    itojun 	rt_missmsg(RTM_DELETE, &info, info.rti_flags, error);
    951   1.40    itojun 
    952   1.95    dyoung 	return error;
    953   1.40    itojun }
    954   1.40    itojun 
    955    1.1       cgd struct ifaddr *
    956  1.173     ozaki ifa_ifwithroute_psref(int flags, const struct sockaddr *dst,
    957  1.173     ozaki 	const struct sockaddr *gateway, struct psref *psref)
    958    1.1       cgd {
    959  1.173     ozaki 	struct ifaddr *ifa = NULL;
    960  1.173     ozaki 
    961    1.1       cgd 	if ((flags & RTF_GATEWAY) == 0) {
    962    1.1       cgd 		/*
    963    1.1       cgd 		 * If we are adding a route to an interface,
    964    1.1       cgd 		 * and the interface is a pt to pt link
    965    1.1       cgd 		 * we should search for the destination
    966    1.1       cgd 		 * as our clue to the interface.  Otherwise
    967    1.1       cgd 		 * we can use the local address.
    968    1.1       cgd 		 */
    969  1.127  christos 		if ((flags & RTF_HOST) && gateway->sa_family != AF_LINK)
    970  1.173     ozaki 			ifa = ifa_ifwithdstaddr_psref(dst, psref);
    971   1.68  christos 		if (ifa == NULL)
    972  1.173     ozaki 			ifa = ifa_ifwithaddr_psref(gateway, psref);
    973    1.1       cgd 	} else {
    974    1.1       cgd 		/*
    975    1.1       cgd 		 * If we are adding a route to a remote net
    976    1.1       cgd 		 * or host, the gateway may still be on the
    977    1.1       cgd 		 * other end of a pt to pt link.
    978    1.1       cgd 		 */
    979  1.173     ozaki 		ifa = ifa_ifwithdstaddr_psref(gateway, psref);
    980    1.1       cgd 	}
    981   1.68  christos 	if (ifa == NULL)
    982  1.173     ozaki 		ifa = ifa_ifwithnet_psref(gateway, psref);
    983   1.68  christos 	if (ifa == NULL) {
    984  1.173     ozaki 		int s;
    985  1.173     ozaki 		struct rtentry *rt;
    986  1.173     ozaki 
    987  1.189     ozaki 		/* XXX we cannot call rtalloc1 if holding the rt lock */
    988  1.189     ozaki 		if (RT_LOCKED())
    989  1.195     ozaki 			rt = rtalloc1_locked(gateway, 0, true, true);
    990  1.189     ozaki 		else
    991  1.194     ozaki 			rt = rtalloc1(gateway, 0);
    992   1.68  christos 		if (rt == NULL)
    993   1.68  christos 			return NULL;
    994  1.194     ozaki 		if (rt->rt_flags & RTF_GATEWAY) {
    995  1.194     ozaki 			rt_unref(rt);
    996  1.194     ozaki 			return NULL;
    997  1.194     ozaki 		}
    998  1.173     ozaki 		/*
    999  1.173     ozaki 		 * Just in case. May not need to do this workaround.
   1000  1.173     ozaki 		 * Revisit when working on rtentry MP-ification.
   1001  1.173     ozaki 		 */
   1002  1.173     ozaki 		s = pserialize_read_enter();
   1003  1.173     ozaki 		IFADDR_READER_FOREACH(ifa, rt->rt_ifp) {
   1004  1.173     ozaki 			if (ifa == rt->rt_ifa)
   1005  1.173     ozaki 				break;
   1006  1.173     ozaki 		}
   1007  1.173     ozaki 		if (ifa != NULL)
   1008  1.173     ozaki 			ifa_acquire(ifa, psref);
   1009  1.173     ozaki 		pserialize_read_exit(s);
   1010  1.183     ozaki 		rt_unref(rt);
   1011  1.146     ozaki 		if (ifa == NULL)
   1012   1.68  christos 			return NULL;
   1013    1.1       cgd 	}
   1014    1.1       cgd 	if (ifa->ifa_addr->sa_family != dst->sa_family) {
   1015  1.173     ozaki 		struct ifaddr *nifa;
   1016  1.173     ozaki 		int s;
   1017  1.173     ozaki 
   1018  1.173     ozaki 		s = pserialize_read_enter();
   1019  1.173     ozaki 		nifa = ifaof_ifpforaddr(dst, ifa->ifa_ifp);
   1020  1.173     ozaki 		if (nifa != NULL) {
   1021  1.173     ozaki 			ifa_release(ifa, psref);
   1022  1.173     ozaki 			ifa_acquire(nifa, psref);
   1023  1.173     ozaki 			ifa = nifa;
   1024  1.173     ozaki 		}
   1025  1.173     ozaki 		pserialize_read_exit(s);
   1026    1.1       cgd 	}
   1027   1.95    dyoung 	return ifa;
   1028    1.1       cgd }
   1029    1.1       cgd 
   1030  1.146     ozaki /*
   1031  1.146     ozaki  * If it suceeds and ret_nrt isn't NULL, refcnt of ret_nrt is incremented.
   1032  1.146     ozaki  * The caller has to rtfree it by itself.
   1033  1.146     ozaki  */
   1034    1.9   mycroft int
   1035   1.60      matt rtrequest(int req, const struct sockaddr *dst, const struct sockaddr *gateway,
   1036   1.60      matt 	const struct sockaddr *netmask, int flags, struct rtentry **ret_nrt)
   1037    1.1       cgd {
   1038   1.39    itojun 	struct rt_addrinfo info;
   1039   1.39    itojun 
   1040   1.44   thorpej 	memset(&info, 0, sizeof(info));
   1041   1.39    itojun 	info.rti_flags = flags;
   1042   1.39    itojun 	info.rti_info[RTAX_DST] = dst;
   1043   1.39    itojun 	info.rti_info[RTAX_GATEWAY] = gateway;
   1044   1.39    itojun 	info.rti_info[RTAX_NETMASK] = netmask;
   1045   1.39    itojun 	return rtrequest1(req, &info, ret_nrt);
   1046   1.39    itojun }
   1047   1.39    itojun 
   1048  1.146     ozaki /*
   1049  1.146     ozaki  * It's a utility function to add/remove a route to/from the routing table
   1050  1.146     ozaki  * and tell user processes the addition/removal on success.
   1051  1.146     ozaki  */
   1052  1.146     ozaki int
   1053  1.146     ozaki rtrequest_newmsg(const int req, const struct sockaddr *dst,
   1054  1.146     ozaki 	const struct sockaddr *gateway, const struct sockaddr *netmask,
   1055  1.146     ozaki 	const int flags)
   1056  1.146     ozaki {
   1057  1.146     ozaki 	int error;
   1058  1.146     ozaki 	struct rtentry *ret_nrt = NULL;
   1059  1.146     ozaki 
   1060  1.146     ozaki 	KASSERT(req == RTM_ADD || req == RTM_DELETE);
   1061  1.146     ozaki 
   1062  1.146     ozaki 	error = rtrequest(req, dst, gateway, netmask, flags, &ret_nrt);
   1063  1.146     ozaki 	if (error != 0)
   1064  1.146     ozaki 		return error;
   1065  1.146     ozaki 
   1066  1.146     ozaki 	KASSERT(ret_nrt != NULL);
   1067  1.146     ozaki 
   1068  1.146     ozaki 	rt_newmsg(req, ret_nrt); /* tell user process */
   1069  1.183     ozaki 	if (req == RTM_DELETE)
   1070  1.183     ozaki 		rt_free(ret_nrt);
   1071  1.183     ozaki 	else
   1072  1.183     ozaki 		rt_unref(ret_nrt);
   1073  1.146     ozaki 
   1074  1.146     ozaki 	return 0;
   1075  1.146     ozaki }
   1076  1.146     ozaki 
   1077  1.173     ozaki struct ifnet *
   1078  1.173     ozaki rt_getifp(struct rt_addrinfo *info, struct psref *psref)
   1079   1.39    itojun {
   1080   1.68  christos 	const struct sockaddr *ifpaddr = info->rti_info[RTAX_IFP];
   1081   1.39    itojun 
   1082  1.173     ozaki 	if (info->rti_ifp != NULL)
   1083  1.173     ozaki 		return NULL;
   1084   1.39    itojun 	/*
   1085   1.39    itojun 	 * ifp may be specified by sockaddr_dl when protocol address
   1086   1.39    itojun 	 * is ambiguous
   1087   1.39    itojun 	 */
   1088  1.173     ozaki 	if (ifpaddr != NULL && ifpaddr->sa_family == AF_LINK) {
   1089  1.173     ozaki 		struct ifaddr *ifa;
   1090  1.173     ozaki 		int s = pserialize_read_enter();
   1091  1.173     ozaki 
   1092  1.173     ozaki 		ifa = ifa_ifwithnet(ifpaddr);
   1093  1.173     ozaki 		if (ifa != NULL)
   1094  1.173     ozaki 			info->rti_ifp = if_get_byindex(ifa->ifa_ifp->if_index,
   1095  1.173     ozaki 			    psref);
   1096  1.173     ozaki 		pserialize_read_exit(s);
   1097   1.39    itojun 	}
   1098  1.173     ozaki 
   1099  1.173     ozaki 	return info->rti_ifp;
   1100  1.173     ozaki }
   1101  1.173     ozaki 
   1102  1.173     ozaki struct ifaddr *
   1103  1.173     ozaki rt_getifa(struct rt_addrinfo *info, struct psref *psref)
   1104  1.173     ozaki {
   1105  1.174     ozaki 	struct ifaddr *ifa = NULL;
   1106  1.173     ozaki 	const struct sockaddr *dst = info->rti_info[RTAX_DST];
   1107  1.173     ozaki 	const struct sockaddr *gateway = info->rti_info[RTAX_GATEWAY];
   1108  1.173     ozaki 	const struct sockaddr *ifaaddr = info->rti_info[RTAX_IFA];
   1109  1.173     ozaki 	int flags = info->rti_flags;
   1110  1.173     ozaki 	const struct sockaddr *sa;
   1111  1.173     ozaki 
   1112  1.173     ozaki 	if (info->rti_ifa == NULL && ifaaddr != NULL) {
   1113  1.173     ozaki 		ifa = ifa_ifwithaddr_psref(ifaaddr, psref);
   1114  1.173     ozaki 		if (ifa != NULL)
   1115  1.173     ozaki 			goto got;
   1116  1.173     ozaki 	}
   1117  1.173     ozaki 
   1118  1.173     ozaki 	sa = ifaaddr != NULL ? ifaaddr :
   1119  1.173     ozaki 	    (gateway != NULL ? gateway : dst);
   1120  1.173     ozaki 	if (sa != NULL && info->rti_ifp != NULL)
   1121  1.173     ozaki 		ifa = ifaof_ifpforaddr_psref(sa, info->rti_ifp, psref);
   1122  1.173     ozaki 	else if (dst != NULL && gateway != NULL)
   1123  1.173     ozaki 		ifa = ifa_ifwithroute_psref(flags, dst, gateway, psref);
   1124  1.173     ozaki 	else if (sa != NULL)
   1125  1.173     ozaki 		ifa = ifa_ifwithroute_psref(flags, sa, sa, psref);
   1126  1.173     ozaki 	if (ifa == NULL)
   1127  1.173     ozaki 		return NULL;
   1128  1.173     ozaki got:
   1129  1.145       roy 	if (ifa->ifa_getifa != NULL) {
   1130  1.191     ozaki 		/* FIXME ifa_getifa is NOMPSAFE */
   1131  1.173     ozaki 		ifa = (*ifa->ifa_getifa)(ifa, dst);
   1132  1.145       roy 		if (ifa == NULL)
   1133  1.173     ozaki 			return NULL;
   1134  1.173     ozaki 		ifa_acquire(ifa, psref);
   1135  1.145       roy 	}
   1136  1.173     ozaki 	info->rti_ifa = ifa;
   1137   1.74    dyoung 	if (info->rti_ifp == NULL)
   1138   1.74    dyoung 		info->rti_ifp = ifa->ifa_ifp;
   1139  1.173     ozaki 	return ifa;
   1140   1.39    itojun }
   1141   1.39    itojun 
   1142  1.146     ozaki /*
   1143  1.146     ozaki  * If it suceeds and ret_nrt isn't NULL, refcnt of ret_nrt is incremented.
   1144  1.146     ozaki  * The caller has to rtfree it by itself.
   1145  1.146     ozaki  */
   1146   1.39    itojun int
   1147   1.60      matt rtrequest1(int req, struct rt_addrinfo *info, struct rtentry **ret_nrt)
   1148   1.39    itojun {
   1149  1.173     ozaki 	int s = splsoftnet(), ss;
   1150  1.125    dyoung 	int error = 0, rc;
   1151  1.158     ozaki 	struct rtentry *rt;
   1152  1.125    dyoung 	rtbl_t *rtbl;
   1153  1.193     ozaki 	struct ifaddr *ifa = NULL;
   1154   1.94    dyoung 	struct sockaddr_storage maskeddst;
   1155   1.68  christos 	const struct sockaddr *dst = info->rti_info[RTAX_DST];
   1156   1.68  christos 	const struct sockaddr *gateway = info->rti_info[RTAX_GATEWAY];
   1157   1.68  christos 	const struct sockaddr *netmask = info->rti_info[RTAX_NETMASK];
   1158   1.68  christos 	int flags = info->rti_flags;
   1159  1.173     ozaki 	struct psref psref_ifp, psref_ifa;
   1160  1.173     ozaki 	int bound = 0;
   1161  1.173     ozaki 	struct ifnet *ifp = NULL;
   1162  1.173     ozaki 	bool need_to_release_ifa = true;
   1163  1.183     ozaki 	bool need_unlock = true;
   1164    1.1       cgd #define senderr(x) { error = x ; goto bad; }
   1165    1.1       cgd 
   1166  1.183     ozaki 	RT_WLOCK();
   1167  1.183     ozaki 
   1168  1.173     ozaki 	bound = curlwp_bind();
   1169  1.125    dyoung 	if ((rtbl = rt_gettable(dst->sa_family)) == NULL)
   1170    1.1       cgd 		senderr(ESRCH);
   1171    1.1       cgd 	if (flags & RTF_HOST)
   1172   1.68  christos 		netmask = NULL;
   1173    1.1       cgd 	switch (req) {
   1174    1.1       cgd 	case RTM_DELETE:
   1175   1.63  christos 		if (netmask) {
   1176   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
   1177   1.94    dyoung 			    netmask);
   1178   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
   1179   1.63  christos 		}
   1180  1.125    dyoung 		if ((rt = rt_lookup(rtbl, dst, netmask)) == NULL)
   1181   1.41    itojun 			senderr(ESRCH);
   1182  1.125    dyoung 		if ((rt = rt_deladdr(rtbl, dst, netmask)) == NULL)
   1183    1.1       cgd 			senderr(ESRCH);
   1184   1.28       erh 		rt->rt_flags &= ~RTF_UP;
   1185  1.116       roy 		if ((ifa = rt->rt_ifa)) {
   1186  1.116       roy 			if (ifa->ifa_flags & IFA_ROUTE &&
   1187  1.116       roy 			    rt_ifa_connected(rt, ifa)) {
   1188  1.116       roy 				RT_DPRINTF("rt->_rt_key = %p, ifa = %p, "
   1189  1.116       roy 				    "deleted IFA_ROUTE\n",
   1190  1.116       roy 				    (void *)rt->_rt_key, (void *)ifa);
   1191  1.116       roy 				ifa->ifa_flags &= ~IFA_ROUTE;
   1192  1.116       roy 			}
   1193  1.116       roy 			if (ifa->ifa_rtrequest)
   1194  1.116       roy 				ifa->ifa_rtrequest(RTM_DELETE, rt, info);
   1195  1.173     ozaki 			ifa = NULL;
   1196  1.116       roy 		}
   1197    1.1       cgd 		rttrash++;
   1198  1.146     ozaki 		if (ret_nrt) {
   1199   1.10   mycroft 			*ret_nrt = rt;
   1200  1.183     ozaki 			rt_ref(rt);
   1201  1.183     ozaki 			RT_REFCNT_TRACE(rt);
   1202  1.183     ozaki 		}
   1203  1.201     ozaki 		rtcache_invalidate();
   1204  1.183     ozaki 		RT_UNLOCK();
   1205  1.183     ozaki 		need_unlock = false;
   1206  1.183     ozaki 		rt_timer_remove_all(rt);
   1207  1.196     ozaki #if defined(INET) || defined(INET6)
   1208  1.196     ozaki 		if (netmask != NULL)
   1209  1.196     ozaki 			lltable_prefix_free(dst->sa_family, dst, netmask, 0);
   1210  1.196     ozaki #endif
   1211  1.183     ozaki 		if (ret_nrt == NULL) {
   1212  1.146     ozaki 			/* Adjust the refcount */
   1213  1.183     ozaki 			rt_ref(rt);
   1214  1.183     ozaki 			RT_REFCNT_TRACE(rt);
   1215  1.183     ozaki 			rt_free(rt);
   1216   1.10   mycroft 		}
   1217    1.1       cgd 		break;
   1218    1.1       cgd 
   1219    1.1       cgd 	case RTM_ADD:
   1220  1.173     ozaki 		if (info->rti_ifa == NULL) {
   1221  1.173     ozaki 			ifp = rt_getifp(info, &psref_ifp);
   1222  1.173     ozaki 			ifa = rt_getifa(info, &psref_ifa);
   1223  1.173     ozaki 			if (ifa == NULL)
   1224  1.173     ozaki 				senderr(ENETUNREACH);
   1225  1.173     ozaki 		} else {
   1226  1.173     ozaki 			/* Caller should have a reference of ifa */
   1227  1.173     ozaki 			ifa = info->rti_ifa;
   1228  1.173     ozaki 			need_to_release_ifa = false;
   1229  1.173     ozaki 		}
   1230   1.22   thorpej 		rt = pool_get(&rtentry_pool, PR_NOWAIT);
   1231   1.68  christos 		if (rt == NULL)
   1232    1.1       cgd 			senderr(ENOBUFS);
   1233  1.109    dyoung 		memset(rt, 0, sizeof(*rt));
   1234   1.10   mycroft 		rt->rt_flags = RTF_UP | flags;
   1235   1.18       kml 		LIST_INIT(&rt->rt_timer);
   1236  1.163     ozaki 
   1237  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1238    1.1       cgd 		if (netmask) {
   1239   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
   1240   1.94    dyoung 			    netmask);
   1241   1.96    dyoung 			rt_setkey(rt, (struct sockaddr *)&maskeddst, M_NOWAIT);
   1242   1.94    dyoung 		} else {
   1243   1.96    dyoung 			rt_setkey(rt, dst, M_NOWAIT);
   1244   1.94    dyoung 		}
   1245  1.163     ozaki 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1246  1.163     ozaki 		if (rt_getkey(rt) == NULL ||
   1247  1.163     ozaki 		    rt_setgate(rt, gateway) != 0) {
   1248  1.163     ozaki 			pool_put(&rtentry_pool, rt);
   1249  1.163     ozaki 			senderr(ENOBUFS);
   1250  1.163     ozaki 		}
   1251  1.163     ozaki 
   1252   1.74    dyoung 		rt_set_ifa(rt, ifa);
   1253  1.164     ozaki 		if (info->rti_info[RTAX_TAG] != NULL) {
   1254  1.164     ozaki 			const struct sockaddr *tag;
   1255  1.164     ozaki 			tag = rt_settag(rt, info->rti_info[RTAX_TAG]);
   1256  1.164     ozaki 			if (tag == NULL)
   1257  1.164     ozaki 				senderr(ENOBUFS);
   1258  1.164     ozaki 		}
   1259  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1260  1.173     ozaki 
   1261  1.173     ozaki 		ss = pserialize_read_enter();
   1262  1.173     ozaki 		if (info->rti_info[RTAX_IFP] != NULL) {
   1263  1.193     ozaki 			struct ifaddr *ifa2;
   1264  1.173     ozaki 			ifa2 = ifa_ifwithnet(info->rti_info[RTAX_IFP]);
   1265  1.173     ozaki 			if (ifa2 != NULL)
   1266  1.173     ozaki 				rt->rt_ifp = ifa2->ifa_ifp;
   1267  1.173     ozaki 			else
   1268  1.173     ozaki 				rt->rt_ifp = ifa->ifa_ifp;
   1269  1.173     ozaki 		} else
   1270  1.122    kefren 			rt->rt_ifp = ifa->ifa_ifp;
   1271  1.173     ozaki 		pserialize_read_exit(ss);
   1272  1.183     ozaki 		cv_init(&rt->rt_cv, "rtentry");
   1273  1.183     ozaki 		psref_target_init(&rt->rt_psref, rt_psref_class);
   1274  1.173     ozaki 
   1275  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1276  1.125    dyoung 		rc = rt_addaddr(rtbl, rt, netmask);
   1277  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1278  1.125    dyoung 		if (rc != 0) {
   1279  1.173     ozaki 			ifafree(ifa); /* for rt_set_ifa above */
   1280  1.183     ozaki 			cv_destroy(&rt->rt_cv);
   1281   1.94    dyoung 			rt_destroy(rt);
   1282   1.40    itojun 			pool_put(&rtentry_pool, rt);
   1283  1.125    dyoung 			senderr(rc);
   1284   1.27      matt 		}
   1285  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1286    1.1       cgd 		if (ifa->ifa_rtrequest)
   1287   1.39    itojun 			ifa->ifa_rtrequest(req, rt, info);
   1288  1.173     ozaki 		if (need_to_release_ifa)
   1289  1.173     ozaki 			ifa_release(ifa, &psref_ifa);
   1290  1.173     ozaki 		ifa = NULL;
   1291  1.173     ozaki 		if_put(ifp, &psref_ifp);
   1292  1.173     ozaki 		ifp = NULL;
   1293  1.110    dyoung 		RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1294    1.1       cgd 		if (ret_nrt) {
   1295    1.1       cgd 			*ret_nrt = rt;
   1296  1.183     ozaki 			rt_ref(rt);
   1297  1.183     ozaki 			RT_REFCNT_TRACE(rt);
   1298   1.41    itojun 		}
   1299  1.201     ozaki 		rtcache_invalidate();
   1300  1.183     ozaki 		RT_UNLOCK();
   1301  1.183     ozaki 		need_unlock = false;
   1302    1.1       cgd 		break;
   1303   1.92    dyoung 	case RTM_GET:
   1304   1.94    dyoung 		if (netmask != NULL) {
   1305   1.94    dyoung 			rt_maskedcopy(dst, (struct sockaddr *)&maskeddst,
   1306   1.94    dyoung 			    netmask);
   1307   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
   1308   1.94    dyoung 		}
   1309  1.125    dyoung 		if ((rt = rt_lookup(rtbl, dst, netmask)) == NULL)
   1310   1.92    dyoung 			senderr(ESRCH);
   1311   1.92    dyoung 		if (ret_nrt != NULL) {
   1312   1.92    dyoung 			*ret_nrt = rt;
   1313  1.183     ozaki 			rt_ref(rt);
   1314  1.183     ozaki 			RT_REFCNT_TRACE(rt);
   1315   1.92    dyoung 		}
   1316   1.92    dyoung 		break;
   1317    1.1       cgd 	}
   1318    1.1       cgd bad:
   1319  1.173     ozaki 	if (need_to_release_ifa)
   1320  1.173     ozaki 		ifa_release(ifa, &psref_ifa);
   1321  1.173     ozaki 	if_put(ifp, &psref_ifp);
   1322  1.173     ozaki 	curlwp_bindx(bound);
   1323  1.183     ozaki 	if (need_unlock)
   1324  1.183     ozaki 		RT_UNLOCK();
   1325    1.1       cgd 	splx(s);
   1326   1.95    dyoung 	return error;
   1327    1.1       cgd }
   1328    1.1       cgd 
   1329   1.10   mycroft int
   1330   1.94    dyoung rt_setgate(struct rtentry *rt, const struct sockaddr *gate)
   1331   1.10   mycroft {
   1332  1.176     ozaki 	struct sockaddr *new, *old;
   1333   1.94    dyoung 
   1334   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
   1335  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1336   1.94    dyoung 
   1337  1.176     ozaki 	new = sockaddr_dup(gate, M_ZERO | M_NOWAIT);
   1338  1.176     ozaki 	if (new == NULL)
   1339   1.94    dyoung 		return ENOMEM;
   1340  1.176     ozaki 
   1341  1.176     ozaki 	old = rt->rt_gateway;
   1342  1.176     ozaki 	rt->rt_gateway = new;
   1343  1.176     ozaki 	if (old != NULL)
   1344  1.176     ozaki 		sockaddr_free(old);
   1345  1.176     ozaki 
   1346   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
   1347  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1348   1.94    dyoung 
   1349   1.10   mycroft 	if (rt->rt_flags & RTF_GATEWAY) {
   1350  1.183     ozaki 		struct rtentry *gwrt;
   1351  1.183     ozaki 
   1352  1.183     ozaki 		/* XXX we cannot call rtalloc1 if holding the rt lock */
   1353  1.183     ozaki 		if (RT_LOCKED())
   1354  1.195     ozaki 			gwrt = rtalloc1_locked(gate, 1, false, true);
   1355  1.183     ozaki 		else
   1356  1.183     ozaki 			gwrt = rtalloc1(gate, 1);
   1357   1.27      matt 		/*
   1358   1.27      matt 		 * If we switched gateways, grab the MTU from the new
   1359   1.47    itojun 		 * gateway route if the current MTU, if the current MTU is
   1360   1.47    itojun 		 * greater than the MTU of gateway.
   1361   1.47    itojun 		 * Note that, if the MTU of gateway is 0, we will reset the
   1362   1.47    itojun 		 * MTU of the route to run PMTUD again from scratch. XXX
   1363   1.27      matt 		 */
   1364  1.166     ozaki 		if (gwrt != NULL) {
   1365  1.166     ozaki 			KASSERT(gwrt->_rt_key != NULL);
   1366  1.166     ozaki 			RT_DPRINTF("gwrt->_rt_key = %p\n", gwrt->_rt_key);
   1367  1.166     ozaki 			if ((rt->rt_rmx.rmx_locks & RTV_MTU) == 0 &&
   1368  1.166     ozaki 			    rt->rt_rmx.rmx_mtu &&
   1369  1.166     ozaki 			    rt->rt_rmx.rmx_mtu > gwrt->rt_rmx.rmx_mtu) {
   1370  1.166     ozaki 				rt->rt_rmx.rmx_mtu = gwrt->rt_rmx.rmx_mtu;
   1371  1.166     ozaki 			}
   1372  1.183     ozaki 			rt_unref(gwrt);
   1373   1.27      matt 		}
   1374   1.10   mycroft 	}
   1375   1.94    dyoung 	KASSERT(rt->_rt_key != NULL);
   1376  1.110    dyoung 	RT_DPRINTF("rt->_rt_key = %p\n", (void *)rt->_rt_key);
   1377   1.10   mycroft 	return 0;
   1378   1.10   mycroft }
   1379   1.10   mycroft 
   1380  1.141     ozaki static void
   1381   1.60      matt rt_maskedcopy(const struct sockaddr *src, struct sockaddr *dst,
   1382   1.60      matt 	const struct sockaddr *netmask)
   1383    1.1       cgd {
   1384   1.94    dyoung 	const char *netmaskp = &netmask->sa_data[0],
   1385   1.94    dyoung 	           *srcp = &src->sa_data[0];
   1386   1.94    dyoung 	char *dstp = &dst->sa_data[0];
   1387  1.126  christos 	const char *maskend = (char *)dst + MIN(netmask->sa_len, src->sa_len);
   1388  1.126  christos 	const char *srcend = (char *)dst + src->sa_len;
   1389   1.94    dyoung 
   1390   1.94    dyoung 	dst->sa_len = src->sa_len;
   1391   1.94    dyoung 	dst->sa_family = src->sa_family;
   1392   1.94    dyoung 
   1393   1.94    dyoung 	while (dstp < maskend)
   1394   1.94    dyoung 		*dstp++ = *srcp++ & *netmaskp++;
   1395   1.94    dyoung 	if (dstp < srcend)
   1396   1.94    dyoung 		memset(dstp, 0, (size_t)(srcend - dstp));
   1397    1.1       cgd }
   1398   1.10   mycroft 
   1399    1.1       cgd /*
   1400  1.135       roy  * Inform the routing socket of a route change.
   1401  1.135       roy  */
   1402  1.135       roy void
   1403  1.154     ozaki rt_newmsg(const int cmd, const struct rtentry *rt)
   1404  1.135       roy {
   1405  1.135       roy 	struct rt_addrinfo info;
   1406  1.135       roy 
   1407  1.135       roy 	memset((void *)&info, 0, sizeof(info));
   1408  1.135       roy 	info.rti_info[RTAX_DST] = rt_getkey(rt);
   1409  1.135       roy 	info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
   1410  1.135       roy 	info.rti_info[RTAX_NETMASK] = rt_mask(rt);
   1411  1.135       roy 	if (rt->rt_ifp) {
   1412  1.135       roy 		info.rti_info[RTAX_IFP] = rt->rt_ifp->if_dl->ifa_addr;
   1413  1.135       roy 		info.rti_info[RTAX_IFA] = rt->rt_ifa->ifa_addr;
   1414  1.135       roy 	}
   1415  1.135       roy 
   1416  1.135       roy 	rt_missmsg(cmd, &info, rt->rt_flags, 0);
   1417  1.135       roy }
   1418  1.135       roy 
   1419  1.135       roy /*
   1420   1.29  sommerfe  * Set up or tear down a routing table entry, normally
   1421    1.1       cgd  * for an interface.
   1422    1.1       cgd  */
   1423    1.9   mycroft int
   1424   1.60      matt rtinit(struct ifaddr *ifa, int cmd, int flags)
   1425    1.1       cgd {
   1426   1.36  augustss 	struct rtentry *rt;
   1427   1.36  augustss 	struct sockaddr *dst, *odst;
   1428   1.94    dyoung 	struct sockaddr_storage maskeddst;
   1429   1.68  christos 	struct rtentry *nrt = NULL;
   1430    1.1       cgd 	int error;
   1431   1.39    itojun 	struct rt_addrinfo info;
   1432    1.1       cgd 
   1433    1.1       cgd 	dst = flags & RTF_HOST ? ifa->ifa_dstaddr : ifa->ifa_addr;
   1434    1.1       cgd 	if (cmd == RTM_DELETE) {
   1435    1.1       cgd 		if ((flags & RTF_HOST) == 0 && ifa->ifa_netmask) {
   1436   1.29  sommerfe 			/* Delete subnet route for this interface */
   1437   1.29  sommerfe 			odst = dst;
   1438   1.94    dyoung 			dst = (struct sockaddr *)&maskeddst;
   1439   1.29  sommerfe 			rt_maskedcopy(odst, dst, ifa->ifa_netmask);
   1440    1.1       cgd 		}
   1441   1.14  christos 		if ((rt = rtalloc1(dst, 0)) != NULL) {
   1442  1.146     ozaki 			if (rt->rt_ifa != ifa) {
   1443  1.183     ozaki 				rt_unref(rt);
   1444   1.85    dyoung 				return (flags & RTF_HOST) ? EHOSTUNREACH
   1445   1.85    dyoung 							: ENETUNREACH;
   1446  1.146     ozaki 			}
   1447  1.183     ozaki 			rt_unref(rt);
   1448    1.1       cgd 		}
   1449    1.1       cgd 	}
   1450   1.44   thorpej 	memset(&info, 0, sizeof(info));
   1451   1.39    itojun 	info.rti_ifa = ifa;
   1452   1.39    itojun 	info.rti_flags = flags | ifa->ifa_flags;
   1453   1.39    itojun 	info.rti_info[RTAX_DST] = dst;
   1454   1.39    itojun 	info.rti_info[RTAX_GATEWAY] = ifa->ifa_addr;
   1455  1.158     ozaki 
   1456   1.39    itojun 	/*
   1457   1.39    itojun 	 * XXX here, it seems that we are assuming that ifa_netmask is NULL
   1458   1.39    itojun 	 * for RTF_HOST.  bsdi4 passes NULL explicitly (via intermediate
   1459   1.39    itojun 	 * variable) when RTF_HOST is 1.  still not sure if i can safely
   1460   1.39    itojun 	 * change it to meet bsdi4 behavior.
   1461   1.39    itojun 	 */
   1462  1.114    dyoung 	if (cmd != RTM_LLINFO_UPD)
   1463  1.114    dyoung 		info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
   1464  1.114    dyoung 	error = rtrequest1((cmd == RTM_LLINFO_UPD) ? RTM_GET : cmd, &info,
   1465  1.114    dyoung 	    &nrt);
   1466  1.153     ozaki 	if (error != 0)
   1467  1.146     ozaki 		return error;
   1468  1.146     ozaki 
   1469  1.153     ozaki 	rt = nrt;
   1470  1.183     ozaki 	RT_REFCNT_TRACE(rt);
   1471  1.146     ozaki 	switch (cmd) {
   1472  1.114    dyoung 	case RTM_DELETE:
   1473  1.146     ozaki 		rt_newmsg(cmd, rt);
   1474  1.183     ozaki 		rt_free(rt);
   1475  1.114    dyoung 		break;
   1476  1.114    dyoung 	case RTM_LLINFO_UPD:
   1477  1.114    dyoung 		if (cmd == RTM_LLINFO_UPD && ifa->ifa_rtrequest != NULL)
   1478  1.114    dyoung 			ifa->ifa_rtrequest(RTM_LLINFO_UPD, rt, &info);
   1479  1.146     ozaki 		rt_newmsg(RTM_CHANGE, rt);
   1480  1.183     ozaki 		rt_unref(rt);
   1481  1.114    dyoung 		break;
   1482  1.114    dyoung 	case RTM_ADD:
   1483  1.183     ozaki 		/*
   1484  1.183     ozaki 		 * XXX it looks just reverting rt_ifa replaced by ifa_rtrequest
   1485  1.183     ozaki 		 * called via rtrequest1. Can we just prevent the replacement
   1486  1.183     ozaki 		 * somehow and remove the following code? And also doesn't
   1487  1.183     ozaki 		 * calling ifa_rtrequest(RTM_ADD) replace rt_ifa again?
   1488  1.183     ozaki 		 */
   1489   1.10   mycroft 		if (rt->rt_ifa != ifa) {
   1490   1.17  christos 			printf("rtinit: wrong ifa (%p) was (%p)\n", ifa,
   1491   1.17  christos 				rt->rt_ifa);
   1492  1.192     ozaki #ifdef NET_MPSAFE
   1493  1.192     ozaki 			KASSERT(!cpu_softintr_p());
   1494  1.192     ozaki 
   1495  1.192     ozaki 			error = rt_update_prepare(rt);
   1496  1.192     ozaki 			if (error == 0) {
   1497  1.192     ozaki #endif
   1498  1.192     ozaki 				if (rt->rt_ifa->ifa_rtrequest != NULL) {
   1499  1.192     ozaki 					rt->rt_ifa->ifa_rtrequest(RTM_DELETE,
   1500  1.192     ozaki 					    rt, &info);
   1501  1.192     ozaki 				}
   1502  1.192     ozaki 				rt_replace_ifa(rt, ifa);
   1503  1.192     ozaki 				rt->rt_ifp = ifa->ifa_ifp;
   1504  1.192     ozaki 				if (ifa->ifa_rtrequest != NULL)
   1505  1.192     ozaki 					ifa->ifa_rtrequest(RTM_ADD, rt, &info);
   1506  1.192     ozaki #ifdef NET_MPSAFE
   1507  1.192     ozaki 				rt_update_finish(rt);
   1508  1.192     ozaki 			} else {
   1509  1.192     ozaki 				/*
   1510  1.192     ozaki 				 * If error != 0, the rtentry is being
   1511  1.192     ozaki 				 * destroyed, so doing nothing doesn't
   1512  1.192     ozaki 				 * matter.
   1513  1.192     ozaki 				 */
   1514  1.114    dyoung 			}
   1515  1.192     ozaki #endif
   1516   1.10   mycroft 		}
   1517  1.146     ozaki 		rt_newmsg(cmd, rt);
   1518  1.183     ozaki 		rt_unref(rt);
   1519  1.183     ozaki 		RT_REFCNT_TRACE(rt);
   1520  1.114    dyoung 		break;
   1521    1.1       cgd 	}
   1522   1.85    dyoung 	return error;
   1523   1.18       kml }
   1524   1.18       kml 
   1525  1.136       roy /*
   1526  1.136       roy  * Create a local route entry for the address.
   1527  1.136       roy  * Announce the addition of the address and the route to the routing socket.
   1528  1.136       roy  */
   1529  1.136       roy int
   1530  1.136       roy rt_ifa_addlocal(struct ifaddr *ifa)
   1531  1.136       roy {
   1532  1.136       roy 	struct rtentry *rt;
   1533  1.136       roy 	int e;
   1534  1.136       roy 
   1535  1.136       roy 	/* If there is no loopback entry, allocate one. */
   1536  1.136       roy 	rt = rtalloc1(ifa->ifa_addr, 0);
   1537  1.158     ozaki #ifdef RT_DEBUG
   1538  1.158     ozaki 	if (rt != NULL)
   1539  1.158     ozaki 		dump_rt(rt);
   1540  1.158     ozaki #endif
   1541  1.136       roy 	if (rt == NULL || (rt->rt_flags & RTF_HOST) == 0 ||
   1542  1.136       roy 	    (rt->rt_ifp->if_flags & IFF_LOOPBACK) == 0)
   1543  1.152       roy 	{
   1544  1.152       roy 		struct rt_addrinfo info;
   1545  1.152       roy 		struct rtentry *nrt;
   1546  1.152       roy 
   1547  1.152       roy 		memset(&info, 0, sizeof(info));
   1548  1.152       roy 		info.rti_flags = RTF_HOST | RTF_LOCAL;
   1549  1.152       roy 		info.rti_info[RTAX_DST] = ifa->ifa_addr;
   1550  1.152       roy 		info.rti_info[RTAX_GATEWAY] =
   1551  1.152       roy 		    (const struct sockaddr *)ifa->ifa_ifp->if_sadl;
   1552  1.152       roy 		info.rti_ifa = ifa;
   1553  1.152       roy 		nrt = NULL;
   1554  1.152       roy 		e = rtrequest1(RTM_ADD, &info, &nrt);
   1555  1.152       roy 		if (nrt && ifa != nrt->rt_ifa)
   1556  1.152       roy 			rt_replace_ifa(nrt, ifa);
   1557  1.152       roy 		rt_newaddrmsg(RTM_ADD, ifa, e, nrt);
   1558  1.158     ozaki 		if (nrt != NULL) {
   1559  1.158     ozaki #ifdef RT_DEBUG
   1560  1.158     ozaki 			dump_rt(nrt);
   1561  1.158     ozaki #endif
   1562  1.183     ozaki 			rt_unref(nrt);
   1563  1.183     ozaki 			RT_REFCNT_TRACE(nrt);
   1564  1.158     ozaki 		}
   1565  1.152       roy 	} else {
   1566  1.136       roy 		e = 0;
   1567  1.136       roy 		rt_newaddrmsg(RTM_NEWADDR, ifa, 0, NULL);
   1568  1.136       roy 	}
   1569  1.136       roy 	if (rt != NULL)
   1570  1.183     ozaki 		rt_unref(rt);
   1571  1.136       roy 	return e;
   1572  1.136       roy }
   1573  1.136       roy 
   1574  1.136       roy /*
   1575  1.136       roy  * Remove the local route entry for the address.
   1576  1.136       roy  * Announce the removal of the address and the route to the routing socket.
   1577  1.136       roy  */
   1578  1.136       roy int
   1579  1.136       roy rt_ifa_remlocal(struct ifaddr *ifa, struct ifaddr *alt_ifa)
   1580  1.136       roy {
   1581  1.136       roy 	struct rtentry *rt;
   1582  1.136       roy 	int e = 0;
   1583  1.136       roy 
   1584  1.136       roy 	rt = rtalloc1(ifa->ifa_addr, 0);
   1585  1.136       roy 
   1586  1.136       roy 	/*
   1587  1.136       roy 	 * Before deleting, check if a corresponding loopbacked
   1588  1.136       roy 	 * host route surely exists.  With this check, we can avoid
   1589  1.136       roy 	 * deleting an interface direct route whose destination is
   1590  1.136       roy 	 * the same as the address being removed.  This can happen
   1591  1.136       roy 	 * when removing a subnet-router anycast address on an
   1592  1.136       roy 	 * interface attached to a shared medium.
   1593  1.136       roy 	 */
   1594  1.136       roy 	if (rt != NULL &&
   1595  1.136       roy 	    (rt->rt_flags & RTF_HOST) &&
   1596  1.136       roy 	    (rt->rt_ifp->if_flags & IFF_LOOPBACK))
   1597  1.136       roy 	{
   1598  1.136       roy 		/* If we cannot replace the route's ifaddr with the equivalent
   1599  1.136       roy 		 * ifaddr of another interface, I believe it is safest to
   1600  1.136       roy 		 * delete the route.
   1601  1.136       roy 		 */
   1602  1.152       roy 		if (alt_ifa == NULL) {
   1603  1.152       roy 			e = rtdeletemsg(rt);
   1604  1.183     ozaki 			if (e == 0) {
   1605  1.183     ozaki 				rt_unref(rt);
   1606  1.183     ozaki 				rt_free(rt);
   1607  1.183     ozaki 				rt = NULL;
   1608  1.183     ozaki 			}
   1609  1.152       roy 			rt_newaddrmsg(RTM_DELADDR, ifa, 0, NULL);
   1610  1.152       roy 		} else {
   1611  1.136       roy 			rt_replace_ifa(rt, alt_ifa);
   1612  1.136       roy 			rt_newmsg(RTM_CHANGE, rt);
   1613  1.136       roy 		}
   1614  1.136       roy 	} else
   1615  1.136       roy 		rt_newaddrmsg(RTM_DELADDR, ifa, 0, NULL);
   1616  1.136       roy 	if (rt != NULL)
   1617  1.183     ozaki 		rt_unref(rt);
   1618  1.136       roy 	return e;
   1619  1.136       roy }
   1620  1.136       roy 
   1621   1.18       kml /*
   1622   1.18       kml  * Route timer routines.  These routes allow functions to be called
   1623   1.18       kml  * for various routes at any time.  This is useful in supporting
   1624   1.18       kml  * path MTU discovery and redirect route deletion.
   1625   1.18       kml  *
   1626   1.18       kml  * This is similar to some BSDI internal functions, but it provides
   1627   1.18       kml  * for multiple queues for efficiency's sake...
   1628   1.18       kml  */
   1629   1.18       kml 
   1630   1.18       kml LIST_HEAD(, rttimer_queue) rttimer_queue_head;
   1631   1.18       kml static int rt_init_done = 0;
   1632   1.18       kml 
   1633   1.65     perry /*
   1634   1.18       kml  * Some subtle order problems with domain initialization mean that
   1635   1.18       kml  * we cannot count on this being run from rt_init before various
   1636   1.18       kml  * protocol initializations are done.  Therefore, we make sure
   1637   1.18       kml  * that this is run when the first queue is added...
   1638   1.18       kml  */
   1639   1.18       kml 
   1640  1.170     ozaki static void rt_timer_work(struct work *, void *);
   1641  1.170     ozaki 
   1642  1.177     ozaki static void
   1643   1.60      matt rt_timer_init(void)
   1644   1.18       kml {
   1645  1.170     ozaki 	int error;
   1646  1.170     ozaki 
   1647   1.18       kml 	assert(rt_init_done == 0);
   1648   1.18       kml 
   1649  1.183     ozaki 	/* XXX should be in rt_init */
   1650  1.183     ozaki 	rw_init(&rt_lock);
   1651  1.183     ozaki 
   1652   1.18       kml 	LIST_INIT(&rttimer_queue_head);
   1653  1.172    martin 	callout_init(&rt_timer_ch, CALLOUT_MPSAFE);
   1654  1.170     ozaki 	error = workqueue_create(&rt_timer_wq, "rt_timer",
   1655  1.170     ozaki 	    rt_timer_work, NULL, PRI_SOFTNET, IPL_SOFTNET, WQ_MPSAFE);
   1656  1.170     ozaki 	if (error)
   1657  1.170     ozaki 		panic("%s: workqueue_create failed (%d)\n", __func__, error);
   1658  1.172    martin 	callout_reset(&rt_timer_ch, hz, rt_timer_timer, NULL);
   1659   1.18       kml 	rt_init_done = 1;
   1660   1.18       kml }
   1661   1.18       kml 
   1662   1.18       kml struct rttimer_queue *
   1663   1.60      matt rt_timer_queue_create(u_int timeout)
   1664   1.18       kml {
   1665   1.18       kml 	struct rttimer_queue *rtq;
   1666   1.18       kml 
   1667   1.18       kml 	if (rt_init_done == 0)
   1668   1.18       kml 		rt_timer_init();
   1669   1.18       kml 
   1670   1.18       kml 	R_Malloc(rtq, struct rttimer_queue *, sizeof *rtq);
   1671   1.18       kml 	if (rtq == NULL)
   1672   1.85    dyoung 		return NULL;
   1673  1.109    dyoung 	memset(rtq, 0, sizeof(*rtq));
   1674   1.18       kml 
   1675   1.18       kml 	rtq->rtq_timeout = timeout;
   1676   1.24   thorpej 	TAILQ_INIT(&rtq->rtq_head);
   1677  1.183     ozaki 	RT_WLOCK();
   1678   1.18       kml 	LIST_INSERT_HEAD(&rttimer_queue_head, rtq, rtq_link);
   1679  1.183     ozaki 	RT_UNLOCK();
   1680   1.18       kml 
   1681   1.85    dyoung 	return rtq;
   1682   1.18       kml }
   1683   1.18       kml 
   1684   1.18       kml void
   1685   1.60      matt rt_timer_queue_change(struct rttimer_queue *rtq, long timeout)
   1686   1.18       kml {
   1687   1.24   thorpej 
   1688   1.18       kml 	rtq->rtq_timeout = timeout;
   1689   1.18       kml }
   1690   1.18       kml 
   1691  1.177     ozaki static void
   1692  1.181     ozaki rt_timer_queue_remove_all(struct rttimer_queue *rtq)
   1693   1.18       kml {
   1694   1.24   thorpej 	struct rttimer *r;
   1695   1.18       kml 
   1696  1.183     ozaki 	RT_ASSERT_WLOCK();
   1697  1.183     ozaki 
   1698   1.24   thorpej 	while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL) {
   1699   1.18       kml 		LIST_REMOVE(r, rtt_link);
   1700   1.24   thorpej 		TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
   1701  1.183     ozaki 		rt_ref(r->rtt_rt); /* XXX */
   1702  1.183     ozaki 		RT_REFCNT_TRACE(r->rtt_rt);
   1703  1.183     ozaki 		RT_UNLOCK();
   1704  1.181     ozaki 		(*r->rtt_func)(r->rtt_rt, r);
   1705   1.22   thorpej 		pool_put(&rttimer_pool, r);
   1706  1.183     ozaki 		RT_WLOCK();
   1707   1.37    itojun 		if (rtq->rtq_count > 0)
   1708   1.37    itojun 			rtq->rtq_count--;
   1709   1.37    itojun 		else
   1710   1.55    itojun 			printf("rt_timer_queue_remove_all: "
   1711   1.55    itojun 			    "rtq_count reached 0\n");
   1712   1.18       kml 	}
   1713   1.55    itojun }
   1714   1.55    itojun 
   1715   1.55    itojun void
   1716  1.181     ozaki rt_timer_queue_destroy(struct rttimer_queue *rtq)
   1717   1.55    itojun {
   1718   1.55    itojun 
   1719  1.183     ozaki 	RT_WLOCK();
   1720  1.181     ozaki 	rt_timer_queue_remove_all(rtq);
   1721   1.18       kml 	LIST_REMOVE(rtq, rtq_link);
   1722  1.183     ozaki 	RT_UNLOCK();
   1723   1.22   thorpej 
   1724   1.22   thorpej 	/*
   1725   1.22   thorpej 	 * Caller is responsible for freeing the rttimer_queue structure.
   1726   1.22   thorpej 	 */
   1727   1.18       kml }
   1728   1.18       kml 
   1729   1.37    itojun unsigned long
   1730   1.60      matt rt_timer_count(struct rttimer_queue *rtq)
   1731   1.37    itojun {
   1732   1.37    itojun 	return rtq->rtq_count;
   1733   1.37    itojun }
   1734   1.37    itojun 
   1735  1.177     ozaki static void
   1736  1.178     ozaki rt_timer_remove_all(struct rtentry *rt)
   1737   1.18       kml {
   1738   1.24   thorpej 	struct rttimer *r;
   1739   1.18       kml 
   1740  1.183     ozaki 	RT_WLOCK();
   1741   1.24   thorpej 	while ((r = LIST_FIRST(&rt->rt_timer)) != NULL) {
   1742   1.18       kml 		LIST_REMOVE(r, rtt_link);
   1743   1.24   thorpej 		TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
   1744   1.37    itojun 		if (r->rtt_queue->rtq_count > 0)
   1745   1.37    itojun 			r->rtt_queue->rtq_count--;
   1746   1.37    itojun 		else
   1747   1.37    itojun 			printf("rt_timer_remove_all: rtq_count reached 0\n");
   1748   1.38    itojun 		pool_put(&rttimer_pool, r);
   1749   1.18       kml 	}
   1750  1.183     ozaki 	RT_UNLOCK();
   1751   1.18       kml }
   1752   1.18       kml 
   1753   1.65     perry int
   1754   1.60      matt rt_timer_add(struct rtentry *rt,
   1755   1.60      matt 	void (*func)(struct rtentry *, struct rttimer *),
   1756   1.60      matt 	struct rttimer_queue *queue)
   1757   1.18       kml {
   1758   1.24   thorpej 	struct rttimer *r;
   1759   1.18       kml 
   1760  1.156     ozaki 	KASSERT(func != NULL);
   1761  1.183     ozaki 	RT_WLOCK();
   1762   1.24   thorpej 	/*
   1763   1.24   thorpej 	 * If there's already a timer with this action, destroy it before
   1764   1.24   thorpej 	 * we add a new one.
   1765   1.24   thorpej 	 */
   1766   1.85    dyoung 	LIST_FOREACH(r, &rt->rt_timer, rtt_link) {
   1767   1.85    dyoung 		if (r->rtt_func == func)
   1768   1.85    dyoung 			break;
   1769   1.85    dyoung 	}
   1770   1.85    dyoung 	if (r != NULL) {
   1771   1.85    dyoung 		LIST_REMOVE(r, rtt_link);
   1772   1.85    dyoung 		TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
   1773   1.85    dyoung 		if (r->rtt_queue->rtq_count > 0)
   1774   1.85    dyoung 			r->rtt_queue->rtq_count--;
   1775   1.85    dyoung 		else
   1776   1.85    dyoung 			printf("rt_timer_add: rtq_count reached 0\n");
   1777   1.85    dyoung 	} else {
   1778   1.85    dyoung 		r = pool_get(&rttimer_pool, PR_NOWAIT);
   1779  1.183     ozaki 		if (r == NULL) {
   1780  1.183     ozaki 			RT_UNLOCK();
   1781   1.85    dyoung 			return ENOBUFS;
   1782  1.183     ozaki 		}
   1783   1.18       kml 	}
   1784   1.18       kml 
   1785   1.85    dyoung 	memset(r, 0, sizeof(*r));
   1786   1.24   thorpej 
   1787   1.24   thorpej 	r->rtt_rt = rt;
   1788   1.70    kardel 	r->rtt_time = time_uptime;
   1789   1.24   thorpej 	r->rtt_func = func;
   1790   1.24   thorpej 	r->rtt_queue = queue;
   1791   1.24   thorpej 	LIST_INSERT_HEAD(&rt->rt_timer, r, rtt_link);
   1792   1.24   thorpej 	TAILQ_INSERT_TAIL(&queue->rtq_head, r, rtt_next);
   1793   1.37    itojun 	r->rtt_queue->rtq_count++;
   1794   1.65     perry 
   1795  1.183     ozaki 	RT_UNLOCK();
   1796  1.183     ozaki 
   1797   1.95    dyoung 	return 0;
   1798   1.18       kml }
   1799   1.18       kml 
   1800  1.170     ozaki static void
   1801  1.170     ozaki rt_timer_work(struct work *wk, void *arg)
   1802   1.18       kml {
   1803   1.24   thorpej 	struct rttimer_queue *rtq;
   1804   1.24   thorpej 	struct rttimer *r;
   1805   1.21       kml 
   1806  1.183     ozaki 	RT_WLOCK();
   1807   1.85    dyoung 	LIST_FOREACH(rtq, &rttimer_queue_head, rtq_link) {
   1808   1.24   thorpej 		while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL &&
   1809   1.70    kardel 		    (r->rtt_time + rtq->rtq_timeout) < time_uptime) {
   1810   1.24   thorpej 			LIST_REMOVE(r, rtt_link);
   1811   1.24   thorpej 			TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
   1812  1.183     ozaki 			rt_ref(r->rtt_rt); /* XXX */
   1813  1.183     ozaki 			RT_REFCNT_TRACE(r->rtt_rt);
   1814  1.183     ozaki 			RT_UNLOCK();
   1815  1.156     ozaki 			(*r->rtt_func)(r->rtt_rt, r);
   1816   1.24   thorpej 			pool_put(&rttimer_pool, r);
   1817  1.183     ozaki 			RT_WLOCK();
   1818   1.37    itojun 			if (rtq->rtq_count > 0)
   1819   1.37    itojun 				rtq->rtq_count--;
   1820   1.37    itojun 			else
   1821   1.37    itojun 				printf("rt_timer_timer: rtq_count reached 0\n");
   1822   1.18       kml 		}
   1823   1.18       kml 	}
   1824  1.183     ozaki 	RT_UNLOCK();
   1825   1.18       kml 
   1826   1.35   thorpej 	callout_reset(&rt_timer_ch, hz, rt_timer_timer, NULL);
   1827    1.1       cgd }
   1828   1.83     joerg 
   1829  1.177     ozaki static void
   1830  1.170     ozaki rt_timer_timer(void *arg)
   1831  1.170     ozaki {
   1832  1.170     ozaki 
   1833  1.170     ozaki 	workqueue_enqueue(rt_timer_wq, &rt_timer_wk, NULL);
   1834  1.170     ozaki }
   1835  1.170     ozaki 
   1836  1.102    dyoung static struct rtentry *
   1837   1.84     joerg _rtcache_init(struct route *ro, int flag)
   1838   1.84     joerg {
   1839  1.183     ozaki 	struct rtentry *rt;
   1840  1.183     ozaki 
   1841  1.114    dyoung 	rtcache_invariants(ro);
   1842   1.99    dyoung 	KASSERT(ro->_ro_rt == NULL);
   1843   1.84     joerg 
   1844   1.90    dyoung 	if (rtcache_getdst(ro) == NULL)
   1845  1.102    dyoung 		return NULL;
   1846  1.183     ozaki 	rt = rtalloc1(rtcache_getdst(ro), flag);
   1847  1.200     ozaki 	if (rt != NULL) {
   1848  1.200     ozaki 		RT_RLOCK();
   1849  1.200     ozaki 		if (ISSET(rt->rt_flags, RTF_UP)) {
   1850  1.200     ozaki 			ro->_ro_rt = rt;
   1851  1.200     ozaki 			ro->ro_rtcache_generation = rtcache_generation;
   1852  1.200     ozaki 			rtcache_ref(rt, ro);
   1853  1.200     ozaki 		}
   1854  1.200     ozaki 		RT_UNLOCK();
   1855  1.183     ozaki 		rt_unref(rt);
   1856  1.200     ozaki 	}
   1857  1.103    dyoung 
   1858  1.114    dyoung 	rtcache_invariants(ro);
   1859  1.102    dyoung 	return ro->_ro_rt;
   1860   1.84     joerg }
   1861   1.84     joerg 
   1862  1.102    dyoung struct rtentry *
   1863   1.83     joerg rtcache_init(struct route *ro)
   1864   1.83     joerg {
   1865  1.200     ozaki 
   1866  1.200     ozaki 	return _rtcache_init(ro, 1);
   1867   1.83     joerg }
   1868   1.83     joerg 
   1869  1.102    dyoung struct rtentry *
   1870   1.83     joerg rtcache_init_noclone(struct route *ro)
   1871   1.83     joerg {
   1872  1.200     ozaki 
   1873  1.200     ozaki 	return _rtcache_init(ro, 0);
   1874   1.83     joerg }
   1875   1.90    dyoung 
   1876  1.102    dyoung struct rtentry *
   1877   1.90    dyoung rtcache_update(struct route *ro, int clone)
   1878   1.90    dyoung {
   1879  1.200     ozaki 
   1880  1.199     ozaki 	ro->_ro_rt = NULL;
   1881  1.200     ozaki 	return _rtcache_init(ro, clone);
   1882   1.90    dyoung }
   1883   1.83     joerg 
   1884   1.83     joerg void
   1885  1.183     ozaki rtcache_copy(struct route *new_ro, struct route *old_ro)
   1886   1.83     joerg {
   1887  1.103    dyoung 	struct rtentry *rt;
   1888  1.183     ozaki 	int ret;
   1889  1.103    dyoung 
   1890  1.103    dyoung 	KASSERT(new_ro != old_ro);
   1891  1.114    dyoung 	rtcache_invariants(new_ro);
   1892  1.114    dyoung 	rtcache_invariants(old_ro);
   1893  1.103    dyoung 
   1894  1.183     ozaki 	rt = rtcache_validate(old_ro);
   1895  1.103    dyoung 
   1896  1.183     ozaki 	if (rtcache_getdst(old_ro) == NULL)
   1897  1.183     ozaki 		goto out;
   1898  1.183     ozaki 	ret = rtcache_setdst(new_ro, rtcache_getdst(old_ro));
   1899  1.183     ozaki 	if (ret != 0)
   1900  1.183     ozaki 		goto out;
   1901  1.103    dyoung 
   1902  1.201     ozaki 	RT_RLOCK();
   1903  1.199     ozaki 	new_ro->_ro_rt = rt;
   1904  1.199     ozaki 	new_ro->ro_rtcache_generation = rtcache_generation;
   1905  1.201     ozaki 	RT_UNLOCK();
   1906  1.114    dyoung 	rtcache_invariants(new_ro);
   1907  1.183     ozaki out:
   1908  1.183     ozaki 	rtcache_unref(rt, old_ro);
   1909  1.183     ozaki 	return;
   1910   1.83     joerg }
   1911   1.83     joerg 
   1912  1.184     ozaki #if defined(RT_DEBUG) && defined(NET_MPSAFE)
   1913  1.183     ozaki static void
   1914  1.183     ozaki rtcache_trace(const char *func, struct rtentry *rt, struct route *ro)
   1915  1.183     ozaki {
   1916  1.183     ozaki 	char dst[64];
   1917  1.183     ozaki 
   1918  1.183     ozaki 	sockaddr_format(ro->ro_sa, dst, 64);
   1919  1.183     ozaki 	printf("trace: %s:\tdst=%s cpu=%d lwp=%p psref=%p target=%p\n", func, dst,
   1920  1.183     ozaki 	    cpu_index(curcpu()), curlwp, &ro->ro_psref, &rt->rt_psref);
   1921  1.183     ozaki }
   1922  1.183     ozaki #define RTCACHE_PSREF_TRACE(rt, ro)	rtcache_trace(__func__, (rt), (ro))
   1923  1.183     ozaki #else
   1924  1.183     ozaki #define RTCACHE_PSREF_TRACE(rt, ro)	do {} while (0)
   1925  1.183     ozaki #endif
   1926  1.183     ozaki 
   1927  1.183     ozaki static void
   1928  1.183     ozaki rtcache_ref(struct rtentry *rt, struct route *ro)
   1929  1.183     ozaki {
   1930  1.183     ozaki 
   1931  1.183     ozaki 	KASSERT(rt != NULL);
   1932  1.183     ozaki 
   1933  1.183     ozaki #ifdef NET_MPSAFE
   1934  1.183     ozaki 	RTCACHE_PSREF_TRACE(rt, ro);
   1935  1.183     ozaki 	ro->ro_bound = curlwp_bind();
   1936  1.183     ozaki 	psref_acquire(&ro->ro_psref, &rt->rt_psref, rt_psref_class);
   1937  1.183     ozaki #endif
   1938  1.183     ozaki }
   1939  1.183     ozaki 
   1940  1.183     ozaki void
   1941  1.183     ozaki rtcache_unref(struct rtentry *rt, struct route *ro)
   1942  1.183     ozaki {
   1943  1.183     ozaki 
   1944  1.183     ozaki 	if (rt == NULL)
   1945  1.183     ozaki 		return;
   1946  1.183     ozaki 
   1947  1.183     ozaki #ifdef NET_MPSAFE
   1948  1.183     ozaki 	psref_release(&ro->ro_psref, &rt->rt_psref, rt_psref_class);
   1949  1.183     ozaki 	curlwp_bindx(ro->ro_bound);
   1950  1.183     ozaki 	RTCACHE_PSREF_TRACE(rt, ro);
   1951  1.183     ozaki #endif
   1952  1.183     ozaki }
   1953  1.183     ozaki 
   1954  1.200     ozaki struct rtentry *
   1955  1.200     ozaki rtcache_validate(struct route *ro)
   1956  1.183     ozaki {
   1957  1.183     ozaki 	struct rtentry *rt = NULL;
   1958  1.183     ozaki 
   1959  1.188     ozaki #ifdef NET_MPSAFE
   1960  1.183     ozaki retry:
   1961  1.188     ozaki #endif
   1962  1.183     ozaki 	rtcache_invariants(ro);
   1963  1.201     ozaki 	RT_RLOCK();
   1964  1.199     ozaki 	if (ro->ro_rtcache_generation != rtcache_generation) {
   1965  1.199     ozaki 		/* The cache is invalidated */
   1966  1.201     ozaki 		rt = NULL;
   1967  1.201     ozaki 		goto out;
   1968  1.200     ozaki 	}
   1969  1.200     ozaki 
   1970  1.200     ozaki 	rt = ro->_ro_rt;
   1971  1.200     ozaki 	if (rt == NULL)
   1972  1.201     ozaki 		goto out;
   1973  1.200     ozaki 
   1974  1.200     ozaki 	if ((rt->rt_flags & RTF_UP) == 0) {
   1975  1.183     ozaki 		rt = NULL;
   1976  1.183     ozaki 		goto out;
   1977  1.183     ozaki 	}
   1978  1.200     ozaki #ifdef NET_MPSAFE
   1979  1.200     ozaki 	if (ISSET(rt->rt_flags, RTF_UPDATING)) {
   1980  1.200     ozaki 		if (rt_wait_ok()) {
   1981  1.200     ozaki 			RT_UNLOCK();
   1982  1.183     ozaki 
   1983  1.200     ozaki 			/* We can wait until the update is complete */
   1984  1.200     ozaki 			rt_update_wait();
   1985  1.200     ozaki 			goto retry;
   1986  1.200     ozaki 		} else {
   1987  1.200     ozaki 			rt = NULL;
   1988  1.200     ozaki 		}
   1989  1.200     ozaki 	} else
   1990  1.188     ozaki #endif
   1991  1.200     ozaki 		rtcache_ref(rt, ro);
   1992  1.200     ozaki out:
   1993  1.183     ozaki 	RT_UNLOCK();
   1994  1.183     ozaki 	return rt;
   1995  1.183     ozaki }
   1996  1.183     ozaki 
   1997   1.90    dyoung struct rtentry *
   1998  1.183     ozaki rtcache_lookup2(struct route *ro, const struct sockaddr *dst,
   1999  1.183     ozaki     int clone, int *hitp)
   2000   1.90    dyoung {
   2001   1.90    dyoung 	const struct sockaddr *odst;
   2002  1.104    dyoung 	struct rtentry *rt = NULL;
   2003   1.90    dyoung 
   2004   1.90    dyoung 	odst = rtcache_getdst(ro);
   2005  1.200     ozaki 	if (odst == NULL)
   2006  1.138     ozaki 		goto miss;
   2007   1.90    dyoung 
   2008  1.138     ozaki 	if (sockaddr_cmp(odst, dst) != 0) {
   2009  1.200     ozaki 		rtcache_free(ro);
   2010  1.138     ozaki 		goto miss;
   2011  1.138     ozaki 	}
   2012  1.138     ozaki 
   2013  1.200     ozaki 	rt = rtcache_validate(ro);
   2014  1.138     ozaki 	if (rt == NULL) {
   2015  1.199     ozaki 		ro->_ro_rt = NULL;
   2016  1.138     ozaki 		goto miss;
   2017  1.138     ozaki 	}
   2018  1.138     ozaki 
   2019  1.138     ozaki 	rtcache_invariants(ro);
   2020   1.90    dyoung 
   2021  1.183     ozaki 	if (hitp != NULL)
   2022  1.183     ozaki 		*hitp = 1;
   2023  1.138     ozaki 	return rt;
   2024  1.138     ozaki miss:
   2025  1.183     ozaki 	if (hitp != NULL)
   2026  1.183     ozaki 		*hitp = 0;
   2027  1.200     ozaki 	if (rtcache_setdst(ro, dst) == 0)
   2028  1.138     ozaki 		rt = _rtcache_init(ro, clone);
   2029   1.90    dyoung 
   2030  1.114    dyoung 	rtcache_invariants(ro);
   2031  1.114    dyoung 
   2032  1.104    dyoung 	return rt;
   2033   1.90    dyoung }
   2034   1.90    dyoung 
   2035  1.200     ozaki void
   2036  1.200     ozaki rtcache_free(struct route *ro)
   2037   1.86    dyoung {
   2038  1.183     ozaki 
   2039  1.199     ozaki 	ro->_ro_rt = NULL;
   2040   1.86    dyoung 	if (ro->ro_sa != NULL) {
   2041   1.86    dyoung 		sockaddr_free(ro->ro_sa);
   2042   1.86    dyoung 		ro->ro_sa = NULL;
   2043   1.86    dyoung 	}
   2044  1.114    dyoung 	rtcache_invariants(ro);
   2045   1.86    dyoung }
   2046   1.86    dyoung 
   2047  1.200     ozaki int
   2048  1.200     ozaki rtcache_setdst(struct route *ro, const struct sockaddr *sa)
   2049   1.83     joerg {
   2050   1.90    dyoung 	KASSERT(sa != NULL);
   2051   1.90    dyoung 
   2052  1.114    dyoung 	rtcache_invariants(ro);
   2053  1.142     ozaki 	if (ro->ro_sa != NULL) {
   2054  1.142     ozaki 		if (ro->ro_sa->sa_family == sa->sa_family) {
   2055  1.199     ozaki 			ro->_ro_rt = NULL;
   2056  1.142     ozaki 			sockaddr_copy(ro->ro_sa, ro->ro_sa->sa_len, sa);
   2057  1.143     ozaki 			rtcache_invariants(ro);
   2058  1.143     ozaki 			return 0;
   2059  1.114    dyoung 		}
   2060  1.143     ozaki 		/* free ro_sa, wrong family */
   2061  1.200     ozaki 		rtcache_free(ro);
   2062  1.142     ozaki 	}
   2063   1.90    dyoung 
   2064  1.107    dyoung 	KASSERT(ro->_ro_rt == NULL);
   2065  1.107    dyoung 
   2066  1.134  christos 	if ((ro->ro_sa = sockaddr_dup(sa, M_ZERO | M_NOWAIT)) == NULL) {
   2067  1.114    dyoung 		rtcache_invariants(ro);
   2068   1.90    dyoung 		return ENOMEM;
   2069  1.107    dyoung 	}
   2070  1.114    dyoung 	rtcache_invariants(ro);
   2071   1.90    dyoung 	return 0;
   2072   1.83     joerg }
   2073   1.92    dyoung 
   2074  1.123    kefren const struct sockaddr *
   2075  1.123    kefren rt_settag(struct rtentry *rt, const struct sockaddr *tag)
   2076  1.123    kefren {
   2077  1.123    kefren 	if (rt->rt_tag != tag) {
   2078  1.123    kefren 		if (rt->rt_tag != NULL)
   2079  1.123    kefren 			sockaddr_free(rt->rt_tag);
   2080  1.134  christos 		rt->rt_tag = sockaddr_dup(tag, M_ZERO | M_NOWAIT);
   2081  1.123    kefren 	}
   2082  1.169   msaitoh 	return rt->rt_tag;
   2083  1.123    kefren }
   2084  1.123    kefren 
   2085  1.123    kefren struct sockaddr *
   2086  1.167     ozaki rt_gettag(const struct rtentry *rt)
   2087  1.123    kefren {
   2088  1.123    kefren 	return rt->rt_tag;
   2089  1.123    kefren }
   2090  1.162     ozaki 
   2091  1.165     ozaki int
   2092  1.167     ozaki rt_check_reject_route(const struct rtentry *rt, const struct ifnet *ifp)
   2093  1.165     ozaki {
   2094  1.165     ozaki 
   2095  1.165     ozaki 	if ((rt->rt_flags & RTF_REJECT) != 0) {
   2096  1.165     ozaki 		/* Mimic looutput */
   2097  1.165     ozaki 		if (ifp->if_flags & IFF_LOOPBACK)
   2098  1.165     ozaki 			return (rt->rt_flags & RTF_HOST) ?
   2099  1.165     ozaki 			    EHOSTUNREACH : ENETUNREACH;
   2100  1.165     ozaki 		else if (rt->rt_rmx.rmx_expire == 0 ||
   2101  1.165     ozaki 		    time_uptime < rt->rt_rmx.rmx_expire)
   2102  1.165     ozaki 			return (rt->rt_flags & RTF_GATEWAY) ?
   2103  1.165     ozaki 			    EHOSTUNREACH : EHOSTDOWN;
   2104  1.165     ozaki 	}
   2105  1.165     ozaki 
   2106  1.165     ozaki 	return 0;
   2107  1.165     ozaki }
   2108  1.165     ozaki 
   2109  1.182     ozaki void
   2110  1.182     ozaki rt_delete_matched_entries(sa_family_t family, int (*f)(struct rtentry *, void *),
   2111  1.182     ozaki     void *v)
   2112  1.182     ozaki {
   2113  1.182     ozaki 
   2114  1.182     ozaki 	for (;;) {
   2115  1.182     ozaki 		int s;
   2116  1.182     ozaki 		int error;
   2117  1.182     ozaki 		struct rtentry *rt, *retrt = NULL;
   2118  1.182     ozaki 
   2119  1.183     ozaki 		RT_RLOCK();
   2120  1.182     ozaki 		s = splsoftnet();
   2121  1.182     ozaki 		rt = rtbl_search_matched_entry(family, f, v);
   2122  1.182     ozaki 		if (rt == NULL) {
   2123  1.182     ozaki 			splx(s);
   2124  1.183     ozaki 			RT_UNLOCK();
   2125  1.182     ozaki 			return;
   2126  1.182     ozaki 		}
   2127  1.182     ozaki 		rt->rt_refcnt++;
   2128  1.182     ozaki 		splx(s);
   2129  1.183     ozaki 		RT_UNLOCK();
   2130  1.182     ozaki 
   2131  1.182     ozaki 		error = rtrequest(RTM_DELETE, rt_getkey(rt), rt->rt_gateway,
   2132  1.182     ozaki 		    rt_mask(rt), rt->rt_flags, &retrt);
   2133  1.182     ozaki 		if (error == 0) {
   2134  1.182     ozaki 			KASSERT(retrt == rt);
   2135  1.182     ozaki 			KASSERT((retrt->rt_flags & RTF_UP) == 0);
   2136  1.182     ozaki 			retrt->rt_ifp = NULL;
   2137  1.183     ozaki 			rt_unref(rt);
   2138  1.183     ozaki 			rt_free(retrt);
   2139  1.182     ozaki 		} else if (error == ESRCH) {
   2140  1.182     ozaki 			/* Someone deleted the entry already. */
   2141  1.183     ozaki 			rt_unref(rt);
   2142  1.182     ozaki 		} else {
   2143  1.182     ozaki 			log(LOG_ERR, "%s: unable to delete rtentry @ %p, "
   2144  1.182     ozaki 			    "error = %d\n", rt->rt_ifp->if_xname, rt, error);
   2145  1.182     ozaki 			/* XXX how to treat this case? */
   2146  1.182     ozaki 		}
   2147  1.182     ozaki 	}
   2148  1.182     ozaki }
   2149  1.182     ozaki 
   2150  1.207     ozaki static int
   2151  1.207     ozaki rt_walktree_locked(sa_family_t family, int (*f)(struct rtentry *, void *),
   2152  1.207     ozaki     void *v)
   2153  1.207     ozaki {
   2154  1.207     ozaki 
   2155  1.207     ozaki 	return rtbl_walktree(family, f, v);
   2156  1.207     ozaki }
   2157  1.207     ozaki 
   2158  1.183     ozaki int
   2159  1.183     ozaki rt_walktree(sa_family_t family, int (*f)(struct rtentry *, void *), void *v)
   2160  1.183     ozaki {
   2161  1.183     ozaki 	int error;
   2162  1.183     ozaki 
   2163  1.183     ozaki 	RT_RLOCK();
   2164  1.207     ozaki 	error = rt_walktree_locked(family, f, v);
   2165  1.183     ozaki 	RT_UNLOCK();
   2166  1.183     ozaki 
   2167  1.183     ozaki 	return error;
   2168  1.183     ozaki }
   2169  1.183     ozaki 
   2170  1.162     ozaki #ifdef DDB
   2171  1.162     ozaki 
   2172  1.162     ozaki #include <machine/db_machdep.h>
   2173  1.162     ozaki #include <ddb/db_interface.h>
   2174  1.162     ozaki #include <ddb/db_output.h>
   2175  1.162     ozaki 
   2176  1.162     ozaki #define	rt_expire rt_rmx.rmx_expire
   2177  1.162     ozaki 
   2178  1.162     ozaki static void
   2179  1.162     ozaki db_print_sa(const struct sockaddr *sa)
   2180  1.162     ozaki {
   2181  1.162     ozaki 	int len;
   2182  1.162     ozaki 	const u_char *p;
   2183  1.162     ozaki 
   2184  1.162     ozaki 	if (sa == NULL) {
   2185  1.162     ozaki 		db_printf("[NULL]");
   2186  1.162     ozaki 		return;
   2187  1.162     ozaki 	}
   2188  1.162     ozaki 
   2189  1.162     ozaki 	p = (const u_char *)sa;
   2190  1.162     ozaki 	len = sa->sa_len;
   2191  1.162     ozaki 	db_printf("[");
   2192  1.162     ozaki 	while (len > 0) {
   2193  1.162     ozaki 		db_printf("%d", *p);
   2194  1.162     ozaki 		p++; len--;
   2195  1.162     ozaki 		if (len) db_printf(",");
   2196  1.162     ozaki 	}
   2197  1.162     ozaki 	db_printf("]\n");
   2198  1.162     ozaki }
   2199  1.162     ozaki 
   2200  1.162     ozaki static void
   2201  1.162     ozaki db_print_ifa(struct ifaddr *ifa)
   2202  1.162     ozaki {
   2203  1.162     ozaki 	if (ifa == NULL)
   2204  1.162     ozaki 		return;
   2205  1.162     ozaki 	db_printf("  ifa_addr=");
   2206  1.162     ozaki 	db_print_sa(ifa->ifa_addr);
   2207  1.162     ozaki 	db_printf("  ifa_dsta=");
   2208  1.162     ozaki 	db_print_sa(ifa->ifa_dstaddr);
   2209  1.162     ozaki 	db_printf("  ifa_mask=");
   2210  1.162     ozaki 	db_print_sa(ifa->ifa_netmask);
   2211  1.162     ozaki 	db_printf("  flags=0x%x,refcnt=%d,metric=%d\n",
   2212  1.162     ozaki 			  ifa->ifa_flags,
   2213  1.162     ozaki 			  ifa->ifa_refcnt,
   2214  1.162     ozaki 			  ifa->ifa_metric);
   2215  1.162     ozaki }
   2216  1.162     ozaki 
   2217  1.162     ozaki /*
   2218  1.162     ozaki  * Function to pass to rt_walktree().
   2219  1.162     ozaki  * Return non-zero error to abort walk.
   2220  1.162     ozaki  */
   2221  1.162     ozaki static int
   2222  1.162     ozaki db_show_rtentry(struct rtentry *rt, void *w)
   2223  1.162     ozaki {
   2224  1.162     ozaki 	db_printf("rtentry=%p", rt);
   2225  1.162     ozaki 
   2226  1.162     ozaki 	db_printf(" flags=0x%x refcnt=%d use=%"PRId64" expire=%"PRId64"\n",
   2227  1.162     ozaki 			  rt->rt_flags, rt->rt_refcnt,
   2228  1.162     ozaki 			  rt->rt_use, (uint64_t)rt->rt_expire);
   2229  1.162     ozaki 
   2230  1.162     ozaki 	db_printf(" key="); db_print_sa(rt_getkey(rt));
   2231  1.162     ozaki 	db_printf(" mask="); db_print_sa(rt_mask(rt));
   2232  1.162     ozaki 	db_printf(" gw="); db_print_sa(rt->rt_gateway);
   2233  1.162     ozaki 
   2234  1.162     ozaki 	db_printf(" ifp=%p ", rt->rt_ifp);
   2235  1.162     ozaki 	if (rt->rt_ifp)
   2236  1.162     ozaki 		db_printf("(%s)", rt->rt_ifp->if_xname);
   2237  1.162     ozaki 	else
   2238  1.162     ozaki 		db_printf("(NULL)");
   2239  1.162     ozaki 
   2240  1.162     ozaki 	db_printf(" ifa=%p\n", rt->rt_ifa);
   2241  1.162     ozaki 	db_print_ifa(rt->rt_ifa);
   2242  1.162     ozaki 
   2243  1.162     ozaki 	db_printf(" gwroute=%p llinfo=%p\n",
   2244  1.162     ozaki 			  rt->rt_gwroute, rt->rt_llinfo);
   2245  1.162     ozaki 
   2246  1.162     ozaki 	return 0;
   2247  1.162     ozaki }
   2248  1.162     ozaki 
   2249  1.162     ozaki /*
   2250  1.162     ozaki  * Function to print all the route trees.
   2251  1.162     ozaki  * Use this from ddb:  "show routes"
   2252  1.162     ozaki  */
   2253  1.162     ozaki void
   2254  1.162     ozaki db_show_routes(db_expr_t addr, bool have_addr,
   2255  1.162     ozaki     db_expr_t count, const char *modif)
   2256  1.162     ozaki {
   2257  1.207     ozaki 
   2258  1.207     ozaki 	/* Taking RT_LOCK will fail if LOCKDEBUG is enabled. */
   2259  1.207     ozaki 	rt_walktree_locked(AF_INET, db_show_rtentry, NULL);
   2260  1.162     ozaki }
   2261  1.162     ozaki #endif
   2262