Home | History | Annotate | Line # | Download | only in net
route.c revision 1.30
      1  1.30   thorpej /*	$NetBSD: route.c,v 1.30 2000/02/01 22:52:05 thorpej Exp $	*/
      2  1.18       kml 
      3  1.18       kml /*-
      4  1.18       kml  * Copyright (c) 1998 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  * 3. All advertising materials mentioning features or use of this software
     20  1.18       kml  *    must display the following acknowledgement:
     21  1.18       kml  *	This product includes software developed by the NetBSD
     22  1.18       kml  *	Foundation, Inc. and its contributors.
     23  1.18       kml  * 4. Neither the name of The NetBSD Foundation nor the names of its
     24  1.18       kml  *    contributors may be used to endorse or promote products derived
     25  1.18       kml  *    from this software without specific prior written permission.
     26  1.18       kml  *
     27  1.18       kml  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     28  1.18       kml  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     29  1.18       kml  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     30  1.18       kml  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     31  1.18       kml  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     32  1.18       kml  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     33  1.18       kml  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     34  1.18       kml  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     35  1.18       kml  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     36  1.18       kml  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     37  1.18       kml  * POSSIBILITY OF SUCH DAMAGE.
     38  1.18       kml  */
     39  1.11       cgd 
     40   1.1       cgd /*
     41  1.25    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
     42  1.25    itojun  * All rights reserved.
     43  1.25    itojun  *
     44  1.25    itojun  * Redistribution and use in source and binary forms, with or without
     45  1.25    itojun  * modification, are permitted provided that the following conditions
     46  1.25    itojun  * are met:
     47  1.25    itojun  * 1. Redistributions of source code must retain the above copyright
     48  1.25    itojun  *    notice, this list of conditions and the following disclaimer.
     49  1.25    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     50  1.25    itojun  *    notice, this list of conditions and the following disclaimer in the
     51  1.25    itojun  *    documentation and/or other materials provided with the distribution.
     52  1.25    itojun  * 3. Neither the name of the project nor the names of its contributors
     53  1.25    itojun  *    may be used to endorse or promote products derived from this software
     54  1.25    itojun  *    without specific prior written permission.
     55  1.25    itojun  *
     56  1.25    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     57  1.25    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     58  1.25    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     59  1.25    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     60  1.25    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     61  1.25    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     62  1.25    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     63  1.25    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     64  1.25    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     65  1.25    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     66  1.25    itojun  * SUCH DAMAGE.
     67  1.25    itojun  */
     68  1.25    itojun 
     69  1.25    itojun /*
     70  1.10   mycroft  * Copyright (c) 1980, 1986, 1991, 1993
     71  1.10   mycroft  *	The Regents of the University of California.  All rights reserved.
     72   1.1       cgd  *
     73   1.1       cgd  * Redistribution and use in source and binary forms, with or without
     74   1.1       cgd  * modification, are permitted provided that the following conditions
     75   1.1       cgd  * are met:
     76   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     77   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     78   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     79   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     80   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     81   1.1       cgd  * 3. All advertising materials mentioning features or use of this software
     82   1.1       cgd  *    must display the following acknowledgement:
     83   1.1       cgd  *	This product includes software developed by the University of
     84   1.1       cgd  *	California, Berkeley and its contributors.
     85   1.1       cgd  * 4. Neither the name of the University nor the names of its contributors
     86   1.1       cgd  *    may be used to endorse or promote products derived from this software
     87   1.1       cgd  *    without specific prior written permission.
     88   1.1       cgd  *
     89   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     90   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     91   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     92   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     93   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     94   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     95   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     96   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     97   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     98   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     99   1.1       cgd  * SUCH DAMAGE.
    100   1.1       cgd  *
    101  1.17  christos  *	@(#)route.c	8.3 (Berkeley) 1/9/95
    102   1.1       cgd  */
    103  1.19  jonathan 
    104  1.19  jonathan #include "opt_ns.h"
    105   1.2       cgd 
    106   1.5   mycroft #include <sys/param.h>
    107   1.5   mycroft #include <sys/systm.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.5   mycroft #include <sys/protosw.h>
    114  1.18       kml #include <sys/kernel.h>
    115   1.5   mycroft #include <sys/ioctl.h>
    116  1.22   thorpej #include <sys/pool.h>
    117   1.1       cgd 
    118   1.5   mycroft #include <net/if.h>
    119   1.5   mycroft #include <net/route.h>
    120   1.5   mycroft #include <net/raw_cb.h>
    121   1.1       cgd 
    122   1.5   mycroft #include <netinet/in.h>
    123   1.5   mycroft #include <netinet/in_var.h>
    124   1.1       cgd 
    125   1.1       cgd #ifdef NS
    126   1.5   mycroft #include <netns/ns.h>
    127   1.1       cgd #endif
    128   1.5   mycroft 
    129   1.1       cgd #define	SA(p) ((struct sockaddr *)(p))
    130   1.1       cgd 
    131   1.1       cgd int	rttrash;		/* routes not in table but not freed */
    132   1.1       cgd struct	sockaddr wildcard;	/* zero valued cookie for wildcard searches */
    133   1.1       cgd 
    134  1.22   thorpej struct pool rtentry_pool;	/* pool for rtentry structures */
    135  1.22   thorpej struct pool rttimer_pool;	/* pool for rttimer structures */
    136  1.22   thorpej 
    137  1.10   mycroft void
    138  1.10   mycroft rtable_init(table)
    139  1.10   mycroft 	void **table;
    140  1.10   mycroft {
    141  1.10   mycroft 	struct domain *dom;
    142  1.10   mycroft 	for (dom = domains; dom; dom = dom->dom_next)
    143  1.10   mycroft 		if (dom->dom_rtattach)
    144  1.10   mycroft 			dom->dom_rtattach(&table[dom->dom_family],
    145  1.10   mycroft 			    dom->dom_rtoffset);
    146  1.10   mycroft }
    147   1.1       cgd 
    148   1.9   mycroft void
    149  1.10   mycroft route_init()
    150   1.1       cgd {
    151  1.22   thorpej 
    152  1.22   thorpej 	pool_init(&rtentry_pool, sizeof(struct rtentry), 0, 0, 0, "rtentpl",
    153  1.22   thorpej 	    0, NULL, NULL, M_RTABLE);
    154  1.22   thorpej 
    155  1.10   mycroft 	rn_init();	/* initialize all zeroes, all ones, mask table */
    156  1.10   mycroft 	rtable_init((void **)rt_tables);
    157   1.1       cgd }
    158   1.1       cgd 
    159   1.1       cgd /*
    160   1.1       cgd  * Packet routing routines.
    161   1.1       cgd  */
    162   1.9   mycroft void
    163   1.1       cgd rtalloc(ro)
    164   1.1       cgd 	register struct route *ro;
    165   1.1       cgd {
    166   1.1       cgd 	if (ro->ro_rt && ro->ro_rt->rt_ifp && (ro->ro_rt->rt_flags & RTF_UP))
    167   1.1       cgd 		return;				 /* XXX */
    168   1.1       cgd 	ro->ro_rt = rtalloc1(&ro->ro_dst, 1);
    169   1.1       cgd }
    170  1.25    itojun 
    171   1.1       cgd struct rtentry *
    172   1.1       cgd rtalloc1(dst, report)
    173   1.1       cgd 	register struct sockaddr *dst;
    174  1.10   mycroft 	int report;
    175   1.1       cgd {
    176  1.10   mycroft 	register struct radix_node_head *rnh = rt_tables[dst->sa_family];
    177   1.1       cgd 	register struct rtentry *rt;
    178   1.1       cgd 	register struct radix_node *rn;
    179   1.1       cgd 	struct rtentry *newrt = 0;
    180  1.10   mycroft 	struct rt_addrinfo info;
    181  1.13   mycroft 	int  s = splsoftnet(), err = 0, msgtype = RTM_MISS;
    182   1.1       cgd 
    183  1.10   mycroft 	if (rnh && (rn = rnh->rnh_matchaddr((caddr_t)dst, rnh)) &&
    184   1.1       cgd 	    ((rn->rn_flags & RNF_ROOT) == 0)) {
    185   1.1       cgd 		newrt = rt = (struct rtentry *)rn;
    186   1.1       cgd 		if (report && (rt->rt_flags & RTF_CLONING)) {
    187   1.8       cgd 			err = rtrequest(RTM_RESOLVE, dst, SA(0),
    188  1.10   mycroft 					      SA(0), 0, &newrt);
    189   1.8       cgd 			if (err) {
    190   1.8       cgd 				newrt = rt;
    191   1.8       cgd 				rt->rt_refcnt++;
    192   1.8       cgd 				goto miss;
    193   1.8       cgd 			}
    194   1.8       cgd 			if ((rt = newrt) && (rt->rt_flags & RTF_XRESOLVE)) {
    195   1.8       cgd 				msgtype = RTM_RESOLVE;
    196   1.8       cgd 				goto miss;
    197   1.8       cgd 			}
    198   1.1       cgd 		} else
    199   1.1       cgd 			rt->rt_refcnt++;
    200   1.1       cgd 	} else {
    201   1.1       cgd 		rtstat.rts_unreach++;
    202  1.10   mycroft 	miss:	if (report) {
    203  1.10   mycroft 			bzero((caddr_t)&info, sizeof(info));
    204  1.10   mycroft 			info.rti_info[RTAX_DST] = dst;
    205  1.10   mycroft 			rt_missmsg(msgtype, &info, 0, err);
    206  1.10   mycroft 		}
    207   1.1       cgd 	}
    208   1.1       cgd 	splx(s);
    209   1.1       cgd 	return (newrt);
    210   1.1       cgd }
    211   1.1       cgd 
    212   1.9   mycroft void
    213   1.1       cgd rtfree(rt)
    214   1.1       cgd 	register struct rtentry *rt;
    215   1.1       cgd {
    216   1.1       cgd 	register struct ifaddr *ifa;
    217  1.10   mycroft 
    218   1.1       cgd 	if (rt == 0)
    219   1.1       cgd 		panic("rtfree");
    220   1.1       cgd 	rt->rt_refcnt--;
    221   1.1       cgd 	if (rt->rt_refcnt <= 0 && (rt->rt_flags & RTF_UP) == 0) {
    222   1.1       cgd 		if (rt->rt_nodes->rn_flags & (RNF_ACTIVE | RNF_ROOT))
    223   1.1       cgd 			panic ("rtfree 2");
    224  1.10   mycroft 		rttrash--;
    225  1.10   mycroft 		if (rt->rt_refcnt < 0) {
    226  1.16  christos 			printf("rtfree: %p not freed (neg refs)\n", rt);
    227  1.10   mycroft 			return;
    228  1.10   mycroft 		}
    229  1.18       kml 		rt_timer_remove_all(rt);
    230  1.10   mycroft 		ifa = rt->rt_ifa;
    231  1.10   mycroft 		IFAFREE(ifa);
    232  1.10   mycroft 		Free(rt_key(rt));
    233  1.22   thorpej 		pool_put(&rtentry_pool, rt);
    234   1.1       cgd 	}
    235   1.1       cgd }
    236   1.1       cgd 
    237  1.10   mycroft void
    238  1.10   mycroft ifafree(ifa)
    239  1.10   mycroft 	register struct ifaddr *ifa;
    240  1.10   mycroft {
    241  1.30   thorpej 
    242  1.30   thorpej #ifdef DIAGNOSTIC
    243  1.10   mycroft 	if (ifa == NULL)
    244  1.30   thorpej 		panic("ifafree: null ifa");
    245  1.30   thorpej 	if (ifa->ifa_refcnt != 0)
    246  1.30   thorpej 		panic("ifafree: ifa_refcnt != 0 (%d)", ifa->ifa_refcnt);
    247  1.30   thorpej #endif
    248  1.30   thorpej printf("ifafree: freeing ifaddr %p\n", ifa);
    249  1.30   thorpej 	free(ifa, M_IFADDR);
    250  1.10   mycroft }
    251  1.10   mycroft 
    252   1.1       cgd /*
    253   1.1       cgd  * Force a routing table entry to the specified
    254   1.1       cgd  * destination to go through the given gateway.
    255   1.1       cgd  * Normally called as a result of a routing redirect
    256   1.1       cgd  * message from the network layer.
    257   1.1       cgd  *
    258  1.13   mycroft  * N.B.: must be called at splsoftnet
    259   1.1       cgd  */
    260  1.14  christos void
    261   1.1       cgd rtredirect(dst, gateway, netmask, flags, src, rtp)
    262   1.1       cgd 	struct sockaddr *dst, *gateway, *netmask, *src;
    263   1.1       cgd 	int flags;
    264   1.1       cgd 	struct rtentry **rtp;
    265   1.1       cgd {
    266  1.10   mycroft 	register struct rtentry *rt;
    267   1.1       cgd 	int error = 0;
    268   1.1       cgd 	short *stat = 0;
    269  1.10   mycroft 	struct rt_addrinfo info;
    270  1.10   mycroft 	struct ifaddr *ifa;
    271   1.1       cgd 
    272   1.1       cgd 	/* verify the gateway is directly reachable */
    273  1.10   mycroft 	if ((ifa = ifa_ifwithnet(gateway)) == 0) {
    274   1.1       cgd 		error = ENETUNREACH;
    275   1.8       cgd 		goto out;
    276   1.1       cgd 	}
    277   1.1       cgd 	rt = rtalloc1(dst, 0);
    278   1.1       cgd 	/*
    279   1.1       cgd 	 * If the redirect isn't from our current router for this dst,
    280   1.1       cgd 	 * it's either old or wrong.  If it redirects us to ourselves,
    281   1.1       cgd 	 * we have a routing loop, perhaps as a result of an interface
    282   1.1       cgd 	 * going down recently.
    283   1.1       cgd 	 */
    284   1.1       cgd #define	equal(a1, a2) (bcmp((caddr_t)(a1), (caddr_t)(a2), (a1)->sa_len) == 0)
    285  1.10   mycroft 	if (!(flags & RTF_DONE) && rt &&
    286  1.10   mycroft 	     (!equal(src, rt->rt_gateway) || rt->rt_ifa != ifa))
    287   1.1       cgd 		error = EINVAL;
    288   1.1       cgd 	else if (ifa_ifwithaddr(gateway))
    289   1.1       cgd 		error = EHOSTUNREACH;
    290   1.1       cgd 	if (error)
    291   1.1       cgd 		goto done;
    292   1.1       cgd 	/*
    293   1.1       cgd 	 * Create a new entry if we just got back a wildcard entry
    294   1.1       cgd 	 * or the the lookup failed.  This is necessary for hosts
    295   1.1       cgd 	 * which use routing redirects generated by smart gateways
    296   1.1       cgd 	 * to dynamically build the routing tables.
    297   1.1       cgd 	 */
    298   1.1       cgd 	if ((rt == 0) || (rt_mask(rt) && rt_mask(rt)->sa_len < 2))
    299   1.1       cgd 		goto create;
    300   1.1       cgd 	/*
    301   1.1       cgd 	 * Don't listen to the redirect if it's
    302   1.1       cgd 	 * for a route to an interface.
    303   1.1       cgd 	 */
    304   1.1       cgd 	if (rt->rt_flags & RTF_GATEWAY) {
    305   1.1       cgd 		if (((rt->rt_flags & RTF_HOST) == 0) && (flags & RTF_HOST)) {
    306   1.1       cgd 			/*
    307   1.1       cgd 			 * Changing from route to net => route to host.
    308   1.1       cgd 			 * Create new route, rather than smashing route to net.
    309   1.1       cgd 			 */
    310   1.1       cgd 		create:
    311   1.1       cgd 			flags |=  RTF_GATEWAY | RTF_DYNAMIC;
    312   1.1       cgd 			error = rtrequest((int)RTM_ADD, dst, gateway,
    313  1.10   mycroft 				    netmask, flags,
    314   1.1       cgd 				    (struct rtentry **)0);
    315   1.1       cgd 			stat = &rtstat.rts_dynamic;
    316   1.1       cgd 		} else {
    317   1.1       cgd 			/*
    318   1.1       cgd 			 * Smash the current notion of the gateway to
    319   1.1       cgd 			 * this destination.  Should check about netmask!!!
    320   1.1       cgd 			 */
    321  1.10   mycroft 			rt->rt_flags |= RTF_MODIFIED;
    322  1.10   mycroft 			flags |= RTF_MODIFIED;
    323  1.10   mycroft 			stat = &rtstat.rts_newgateway;
    324  1.10   mycroft 			rt_setgate(rt, rt_key(rt), gateway);
    325   1.1       cgd 		}
    326   1.1       cgd 	} else
    327   1.1       cgd 		error = EHOSTUNREACH;
    328   1.1       cgd done:
    329   1.1       cgd 	if (rt) {
    330   1.1       cgd 		if (rtp && !error)
    331   1.1       cgd 			*rtp = rt;
    332   1.1       cgd 		else
    333   1.1       cgd 			rtfree(rt);
    334   1.1       cgd 	}
    335   1.8       cgd out:
    336   1.1       cgd 	if (error)
    337   1.1       cgd 		rtstat.rts_badredirect++;
    338   1.8       cgd 	else if (stat != NULL)
    339   1.8       cgd 		(*stat)++;
    340  1.10   mycroft 	bzero((caddr_t)&info, sizeof(info));
    341  1.10   mycroft 	info.rti_info[RTAX_DST] = dst;
    342  1.10   mycroft 	info.rti_info[RTAX_GATEWAY] = gateway;
    343  1.10   mycroft 	info.rti_info[RTAX_NETMASK] = netmask;
    344  1.10   mycroft 	info.rti_info[RTAX_AUTHOR] = src;
    345  1.10   mycroft 	rt_missmsg(RTM_REDIRECT, &info, flags, error);
    346   1.1       cgd }
    347   1.1       cgd 
    348   1.1       cgd /*
    349  1.22   thorpej  * Routing table ioctl interface.
    350  1.22   thorpej  */
    351   1.9   mycroft int
    352   1.1       cgd rtioctl(req, data, p)
    353  1.12       cgd 	u_long req;
    354   1.1       cgd 	caddr_t data;
    355   1.1       cgd 	struct proc *p;
    356   1.1       cgd {
    357   1.1       cgd 	return (EOPNOTSUPP);
    358   1.1       cgd }
    359   1.1       cgd 
    360   1.1       cgd struct ifaddr *
    361   1.1       cgd ifa_ifwithroute(flags, dst, gateway)
    362  1.10   mycroft 	int flags;
    363  1.10   mycroft 	struct sockaddr	*dst, *gateway;
    364   1.1       cgd {
    365   1.1       cgd 	register struct ifaddr *ifa;
    366   1.1       cgd 	if ((flags & RTF_GATEWAY) == 0) {
    367   1.1       cgd 		/*
    368   1.1       cgd 		 * If we are adding a route to an interface,
    369   1.1       cgd 		 * and the interface is a pt to pt link
    370   1.1       cgd 		 * we should search for the destination
    371   1.1       cgd 		 * as our clue to the interface.  Otherwise
    372   1.1       cgd 		 * we can use the local address.
    373   1.1       cgd 		 */
    374   1.1       cgd 		ifa = 0;
    375   1.1       cgd 		if (flags & RTF_HOST)
    376   1.1       cgd 			ifa = ifa_ifwithdstaddr(dst);
    377   1.1       cgd 		if (ifa == 0)
    378   1.1       cgd 			ifa = ifa_ifwithaddr(gateway);
    379   1.1       cgd 	} else {
    380   1.1       cgd 		/*
    381   1.1       cgd 		 * If we are adding a route to a remote net
    382   1.1       cgd 		 * or host, the gateway may still be on the
    383   1.1       cgd 		 * other end of a pt to pt link.
    384   1.1       cgd 		 */
    385   1.1       cgd 		ifa = ifa_ifwithdstaddr(gateway);
    386   1.1       cgd 	}
    387   1.1       cgd 	if (ifa == 0)
    388   1.1       cgd 		ifa = ifa_ifwithnet(gateway);
    389   1.1       cgd 	if (ifa == 0) {
    390   1.1       cgd 		struct rtentry *rt = rtalloc1(dst, 0);
    391   1.1       cgd 		if (rt == 0)
    392   1.1       cgd 			return (0);
    393   1.1       cgd 		rt->rt_refcnt--;
    394   1.1       cgd 		if ((ifa = rt->rt_ifa) == 0)
    395   1.1       cgd 			return (0);
    396   1.1       cgd 	}
    397   1.1       cgd 	if (ifa->ifa_addr->sa_family != dst->sa_family) {
    398  1.10   mycroft 		struct ifaddr *oifa = ifa;
    399   1.1       cgd 		ifa = ifaof_ifpforaddr(dst, ifa->ifa_ifp);
    400   1.1       cgd 		if (ifa == 0)
    401   1.1       cgd 			ifa = oifa;
    402   1.1       cgd 	}
    403   1.1       cgd 	return (ifa);
    404   1.1       cgd }
    405   1.1       cgd 
    406   1.1       cgd #define ROUNDUP(a) (a>0 ? (1 + (((a) - 1) | (sizeof(long) - 1))) : sizeof(long))
    407   1.1       cgd 
    408   1.9   mycroft int
    409   1.1       cgd rtrequest(req, dst, gateway, netmask, flags, ret_nrt)
    410   1.1       cgd 	int req, flags;
    411   1.1       cgd 	struct sockaddr *dst, *gateway, *netmask;
    412   1.1       cgd 	struct rtentry **ret_nrt;
    413   1.1       cgd {
    414  1.13   mycroft 	int s = splsoftnet(); int error = 0;
    415   1.1       cgd 	register struct rtentry *rt;
    416   1.1       cgd 	register struct radix_node *rn;
    417   1.1       cgd 	register struct radix_node_head *rnh;
    418  1.10   mycroft 	struct ifaddr *ifa;
    419   1.1       cgd 	struct sockaddr *ndst;
    420   1.1       cgd #define senderr(x) { error = x ; goto bad; }
    421   1.1       cgd 
    422  1.10   mycroft 	if ((rnh = rt_tables[dst->sa_family]) == 0)
    423   1.1       cgd 		senderr(ESRCH);
    424   1.1       cgd 	if (flags & RTF_HOST)
    425   1.1       cgd 		netmask = 0;
    426   1.1       cgd 	switch (req) {
    427   1.1       cgd 	case RTM_DELETE:
    428  1.10   mycroft 		if ((rn = rnh->rnh_deladdr(dst, netmask, rnh)) == 0)
    429   1.1       cgd 			senderr(ESRCH);
    430   1.1       cgd 		if (rn->rn_flags & (RNF_ACTIVE | RNF_ROOT))
    431   1.1       cgd 			panic ("rtrequest delete");
    432   1.1       cgd 		rt = (struct rtentry *)rn;
    433  1.10   mycroft 		if (rt->rt_gwroute) {
    434  1.10   mycroft 			rt = rt->rt_gwroute; RTFREE(rt);
    435  1.10   mycroft 			(rt = (struct rtentry *)rn)->rt_gwroute = 0;
    436  1.10   mycroft 		}
    437  1.28       erh 		rt->rt_flags &= ~RTF_UP;
    438   1.1       cgd 		if ((ifa = rt->rt_ifa) && ifa->ifa_rtrequest)
    439   1.1       cgd 			ifa->ifa_rtrequest(RTM_DELETE, rt, SA(0));
    440   1.1       cgd 		rttrash++;
    441  1.10   mycroft 		if (ret_nrt)
    442  1.10   mycroft 			*ret_nrt = rt;
    443  1.10   mycroft 		else if (rt->rt_refcnt <= 0) {
    444  1.10   mycroft 			rt->rt_refcnt++;
    445   1.1       cgd 			rtfree(rt);
    446  1.10   mycroft 		}
    447   1.1       cgd 		break;
    448   1.1       cgd 
    449   1.1       cgd 	case RTM_RESOLVE:
    450   1.1       cgd 		if (ret_nrt == 0 || (rt = *ret_nrt) == 0)
    451   1.1       cgd 			senderr(EINVAL);
    452   1.1       cgd 		ifa = rt->rt_ifa;
    453   1.1       cgd 		flags = rt->rt_flags & ~RTF_CLONING;
    454   1.1       cgd 		gateway = rt->rt_gateway;
    455   1.1       cgd 		if ((netmask = rt->rt_genmask) == 0)
    456   1.1       cgd 			flags |= RTF_HOST;
    457   1.1       cgd 		goto makeroute;
    458   1.1       cgd 
    459   1.1       cgd 	case RTM_ADD:
    460   1.1       cgd 		if ((ifa = ifa_ifwithroute(flags, dst, gateway)) == 0)
    461   1.1       cgd 			senderr(ENETUNREACH);
    462  1.25    itojun 
    463  1.25    itojun 		/* The interface found in the previous statement may
    464  1.25    itojun 		 * be overridden later by rt_setif.  See the code
    465  1.25    itojun 		 * for case RTM_ADD in rtsock.c:route_output.
    466  1.25    itojun 		 */
    467   1.1       cgd 	makeroute:
    468  1.22   thorpej 		rt = pool_get(&rtentry_pool, PR_NOWAIT);
    469   1.1       cgd 		if (rt == 0)
    470   1.1       cgd 			senderr(ENOBUFS);
    471  1.10   mycroft 		Bzero(rt, sizeof(*rt));
    472  1.10   mycroft 		rt->rt_flags = RTF_UP | flags;
    473  1.18       kml 		LIST_INIT(&rt->rt_timer);
    474  1.10   mycroft 		if (rt_setgate(rt, dst, gateway)) {
    475  1.22   thorpej 			pool_put(&rtentry_pool, rt);
    476  1.10   mycroft 			senderr(ENOBUFS);
    477  1.10   mycroft 		}
    478  1.10   mycroft 		ndst = rt_key(rt);
    479   1.1       cgd 		if (netmask) {
    480   1.1       cgd 			rt_maskedcopy(dst, ndst, netmask);
    481   1.1       cgd 		} else
    482   1.1       cgd 			Bcopy(dst, ndst, dst->sa_len);
    483  1.10   mycroft 		rn = rnh->rnh_addaddr((caddr_t)ndst, (caddr_t)netmask,
    484  1.10   mycroft 					rnh, rt->rt_nodes);
    485   1.1       cgd 		if (rn == 0) {
    486  1.10   mycroft 			if (rt->rt_gwroute)
    487  1.10   mycroft 				rtfree(rt->rt_gwroute);
    488  1.10   mycroft 			Free(rt_key(rt));
    489  1.22   thorpej 			pool_put(&rtentry_pool, rt);
    490   1.1       cgd 			senderr(EEXIST);
    491   1.1       cgd 		}
    492  1.30   thorpej 		IFAREF(ifa);
    493   1.1       cgd 		rt->rt_ifa = ifa;
    494   1.1       cgd 		rt->rt_ifp = ifa->ifa_ifp;
    495  1.27      matt 		if (req == RTM_RESOLVE) {
    496   1.1       cgd 			rt->rt_rmx = (*ret_nrt)->rt_rmx; /* copy metrics */
    497  1.27      matt 		} else if (rt->rt_rmx.rmx_mtu == 0
    498  1.27      matt 			    && !(rt->rt_rmx.rmx_locks & RTV_MTU)) { /* XXX */
    499  1.27      matt 			if (rt->rt_gwroute != NULL) {
    500  1.27      matt 				rt->rt_rmx.rmx_mtu = rt->rt_gwroute->rt_rmx.rmx_mtu;
    501  1.27      matt 			} else {
    502  1.27      matt 				rt->rt_rmx.rmx_mtu = ifa->ifa_ifp->if_mtu;
    503  1.27      matt 			}
    504  1.27      matt 		}
    505   1.1       cgd 		if (ifa->ifa_rtrequest)
    506   1.1       cgd 			ifa->ifa_rtrequest(req, rt, SA(ret_nrt ? *ret_nrt : 0));
    507   1.1       cgd 		if (ret_nrt) {
    508   1.1       cgd 			*ret_nrt = rt;
    509   1.1       cgd 			rt->rt_refcnt++;
    510   1.1       cgd 		}
    511   1.1       cgd 		break;
    512   1.1       cgd 	}
    513   1.1       cgd bad:
    514   1.1       cgd 	splx(s);
    515   1.1       cgd 	return (error);
    516   1.1       cgd }
    517   1.1       cgd 
    518  1.10   mycroft int
    519  1.10   mycroft rt_setgate(rt0, dst, gate)
    520  1.10   mycroft 	struct rtentry *rt0;
    521  1.10   mycroft 	struct sockaddr *dst, *gate;
    522  1.10   mycroft {
    523  1.10   mycroft 	caddr_t new, old;
    524  1.10   mycroft 	int dlen = ROUNDUP(dst->sa_len), glen = ROUNDUP(gate->sa_len);
    525  1.10   mycroft 	register struct rtentry *rt = rt0;
    526  1.10   mycroft 
    527  1.10   mycroft 	if (rt->rt_gateway == 0 || glen > ROUNDUP(rt->rt_gateway->sa_len)) {
    528  1.10   mycroft 		old = (caddr_t)rt_key(rt);
    529  1.10   mycroft 		R_Malloc(new, caddr_t, dlen + glen);
    530  1.10   mycroft 		if (new == 0)
    531  1.10   mycroft 			return 1;
    532  1.10   mycroft 		rt->rt_nodes->rn_key = new;
    533  1.10   mycroft 	} else {
    534  1.10   mycroft 		new = rt->rt_nodes->rn_key;
    535  1.10   mycroft 		old = 0;
    536  1.10   mycroft 	}
    537  1.10   mycroft 	Bcopy(gate, (rt->rt_gateway = (struct sockaddr *)(new + dlen)), glen);
    538  1.10   mycroft 	if (old) {
    539  1.10   mycroft 		Bcopy(dst, new, dlen);
    540  1.10   mycroft 		Free(old);
    541  1.10   mycroft 	}
    542  1.10   mycroft 	if (rt->rt_gwroute) {
    543  1.10   mycroft 		rt = rt->rt_gwroute; RTFREE(rt);
    544  1.10   mycroft 		rt = rt0; rt->rt_gwroute = 0;
    545  1.10   mycroft 	}
    546  1.10   mycroft 	if (rt->rt_flags & RTF_GATEWAY) {
    547  1.10   mycroft 		rt->rt_gwroute = rtalloc1(gate, 1);
    548  1.27      matt 		/*
    549  1.27      matt 		 * If we switched gateways, grab the MTU from the new
    550  1.27      matt 		 * gateway route if the current MTU is 0 or greater
    551  1.27      matt 		 * than the MTU of gateway.
    552  1.27      matt 		 */
    553  1.27      matt 		if (rt->rt_gwroute
    554  1.27      matt 		    && !(rt->rt_rmx.rmx_locks & RTV_MTU)
    555  1.27      matt 		    && (rt->rt_rmx.rmx_mtu == 0
    556  1.27      matt 		    || rt->rt_rmx.rmx_mtu > rt->rt_gwroute->rt_rmx.rmx_mtu)) { /* XXX */
    557  1.27      matt 			rt->rt_rmx.rmx_mtu = rt->rt_gwroute->rt_rmx.rmx_mtu;
    558  1.27      matt 		}
    559  1.10   mycroft 	}
    560  1.10   mycroft 	return 0;
    561  1.10   mycroft }
    562  1.10   mycroft 
    563   1.9   mycroft void
    564   1.1       cgd rt_maskedcopy(src, dst, netmask)
    565   1.9   mycroft 	struct sockaddr *src, *dst, *netmask;
    566   1.1       cgd {
    567   1.1       cgd 	register u_char *cp1 = (u_char *)src;
    568   1.1       cgd 	register u_char *cp2 = (u_char *)dst;
    569   1.1       cgd 	register u_char *cp3 = (u_char *)netmask;
    570   1.1       cgd 	u_char *cplim = cp2 + *cp3;
    571   1.1       cgd 	u_char *cplim2 = cp2 + *cp1;
    572   1.1       cgd 
    573   1.1       cgd 	*cp2++ = *cp1++; *cp2++ = *cp1++; /* copies sa_len & sa_family */
    574   1.1       cgd 	cp3 += 2;
    575   1.1       cgd 	if (cplim > cplim2)
    576   1.1       cgd 		cplim = cplim2;
    577   1.1       cgd 	while (cp2 < cplim)
    578   1.1       cgd 		*cp2++ = *cp1++ & *cp3++;
    579   1.1       cgd 	if (cp2 < cplim2)
    580   1.1       cgd 		bzero((caddr_t)cp2, (unsigned)(cplim2 - cp2));
    581   1.1       cgd }
    582  1.10   mycroft 
    583   1.1       cgd /*
    584  1.29  sommerfe  * Set up or tear down a routing table entry, normally
    585   1.1       cgd  * for an interface.
    586   1.1       cgd  */
    587   1.9   mycroft int
    588   1.1       cgd rtinit(ifa, cmd, flags)
    589   1.1       cgd 	register struct ifaddr *ifa;
    590   1.1       cgd 	int cmd, flags;
    591   1.1       cgd {
    592   1.1       cgd 	register struct rtentry *rt;
    593  1.29  sommerfe 	register struct sockaddr *dst, *odst;
    594  1.29  sommerfe 	struct sockaddr_storage deldst;
    595  1.10   mycroft 	struct rtentry *nrt = 0;
    596   1.1       cgd 	int error;
    597   1.1       cgd 
    598   1.1       cgd 	dst = flags & RTF_HOST ? ifa->ifa_dstaddr : ifa->ifa_addr;
    599   1.1       cgd 	if (cmd == RTM_DELETE) {
    600   1.1       cgd 		if ((flags & RTF_HOST) == 0 && ifa->ifa_netmask) {
    601  1.29  sommerfe 			/* Delete subnet route for this interface */
    602  1.29  sommerfe 			odst = dst;
    603  1.29  sommerfe 			dst = (struct sockaddr *)&deldst;
    604  1.29  sommerfe 			rt_maskedcopy(odst, dst, ifa->ifa_netmask);
    605   1.1       cgd 		}
    606  1.14  christos 		if ((rt = rtalloc1(dst, 0)) != NULL) {
    607   1.1       cgd 			rt->rt_refcnt--;
    608  1.29  sommerfe 			if (rt->rt_ifa != ifa)
    609   1.1       cgd 				return (flags & RTF_HOST ? EHOSTUNREACH
    610   1.1       cgd 							: ENETUNREACH);
    611   1.1       cgd 		}
    612   1.1       cgd 	}
    613   1.1       cgd 	error = rtrequest(cmd, dst, ifa->ifa_addr, ifa->ifa_netmask,
    614  1.10   mycroft 			flags | ifa->ifa_flags, &nrt);
    615  1.10   mycroft 	if (cmd == RTM_DELETE && error == 0 && (rt = nrt)) {
    616  1.10   mycroft 		rt_newaddrmsg(cmd, ifa, error, nrt);
    617  1.10   mycroft 		if (rt->rt_refcnt <= 0) {
    618  1.10   mycroft 			rt->rt_refcnt++;
    619  1.10   mycroft 			rtfree(rt);
    620  1.10   mycroft 		}
    621  1.10   mycroft 	}
    622  1.10   mycroft 	if (cmd == RTM_ADD && error == 0 && (rt = nrt)) {
    623  1.10   mycroft 		rt->rt_refcnt--;
    624  1.10   mycroft 		if (rt->rt_ifa != ifa) {
    625  1.17  christos 			printf("rtinit: wrong ifa (%p) was (%p)\n", ifa,
    626  1.17  christos 				rt->rt_ifa);
    627  1.10   mycroft 			if (rt->rt_ifa->ifa_rtrequest)
    628  1.10   mycroft 			    rt->rt_ifa->ifa_rtrequest(RTM_DELETE, rt, SA(0));
    629  1.10   mycroft 			IFAFREE(rt->rt_ifa);
    630  1.10   mycroft 			rt->rt_ifa = ifa;
    631  1.10   mycroft 			rt->rt_ifp = ifa->ifa_ifp;
    632  1.25    itojun 			rt->rt_rmx.rmx_mtu = ifa->ifa_ifp->if_mtu;	/*XXX*/
    633  1.30   thorpej 			IFAREF(ifa);
    634  1.10   mycroft 			if (ifa->ifa_rtrequest)
    635  1.10   mycroft 			    ifa->ifa_rtrequest(RTM_ADD, rt, SA(0));
    636  1.10   mycroft 		}
    637  1.10   mycroft 		rt_newaddrmsg(cmd, ifa, error, nrt);
    638   1.1       cgd 	}
    639   1.1       cgd 	return (error);
    640  1.18       kml }
    641  1.18       kml 
    642  1.18       kml /*
    643  1.18       kml  * Route timer routines.  These routes allow functions to be called
    644  1.18       kml  * for various routes at any time.  This is useful in supporting
    645  1.18       kml  * path MTU discovery and redirect route deletion.
    646  1.18       kml  *
    647  1.18       kml  * This is similar to some BSDI internal functions, but it provides
    648  1.18       kml  * for multiple queues for efficiency's sake...
    649  1.18       kml  */
    650  1.18       kml 
    651  1.18       kml LIST_HEAD(, rttimer_queue) rttimer_queue_head;
    652  1.18       kml static int rt_init_done = 0;
    653  1.18       kml 
    654  1.18       kml #define RTTIMER_CALLOUT(r)	{				\
    655  1.18       kml 	if (r->rtt_func != NULL) {				\
    656  1.20   thorpej 		(*r->rtt_func)(r->rtt_rt, r);			\
    657  1.18       kml 	} else {						\
    658  1.18       kml 		rtrequest((int) RTM_DELETE,			\
    659  1.18       kml 			  (struct sockaddr *)rt_key(r->rtt_rt),	\
    660  1.18       kml 			  0, 0, 0, 0);				\
    661  1.18       kml 	}							\
    662  1.18       kml }
    663  1.18       kml 
    664  1.18       kml /*
    665  1.18       kml  * Some subtle order problems with domain initialization mean that
    666  1.18       kml  * we cannot count on this being run from rt_init before various
    667  1.18       kml  * protocol initializations are done.  Therefore, we make sure
    668  1.18       kml  * that this is run when the first queue is added...
    669  1.18       kml  */
    670  1.18       kml 
    671  1.18       kml void
    672  1.18       kml rt_timer_init()
    673  1.18       kml {
    674  1.18       kml 	assert(rt_init_done == 0);
    675  1.18       kml 
    676  1.23     veego 	pool_init(&rttimer_pool, sizeof(struct rttimer), 0, 0, 0, "rttmrpl",
    677  1.22   thorpej 	    0, NULL, NULL, M_RTABLE);
    678  1.22   thorpej 
    679  1.18       kml 	LIST_INIT(&rttimer_queue_head);
    680  1.18       kml 	timeout(rt_timer_timer, NULL, hz);  /* every second */
    681  1.18       kml 	rt_init_done = 1;
    682  1.18       kml }
    683  1.18       kml 
    684  1.18       kml struct rttimer_queue *
    685  1.18       kml rt_timer_queue_create(timeout)
    686  1.18       kml 	u_int	timeout;
    687  1.18       kml {
    688  1.18       kml 	struct rttimer_queue *rtq;
    689  1.18       kml 
    690  1.18       kml 	if (rt_init_done == 0)
    691  1.18       kml 		rt_timer_init();
    692  1.18       kml 
    693  1.18       kml 	R_Malloc(rtq, struct rttimer_queue *, sizeof *rtq);
    694  1.18       kml 	if (rtq == NULL)
    695  1.24   thorpej 		return (NULL);
    696  1.18       kml 
    697  1.18       kml 	rtq->rtq_timeout = timeout;
    698  1.24   thorpej 	TAILQ_INIT(&rtq->rtq_head);
    699  1.18       kml 	LIST_INSERT_HEAD(&rttimer_queue_head, rtq, rtq_link);
    700  1.18       kml 
    701  1.24   thorpej 	return (rtq);
    702  1.18       kml }
    703  1.18       kml 
    704  1.18       kml void
    705  1.18       kml rt_timer_queue_change(rtq, timeout)
    706  1.18       kml 	struct rttimer_queue *rtq;
    707  1.18       kml 	long timeout;
    708  1.18       kml {
    709  1.24   thorpej 
    710  1.18       kml 	rtq->rtq_timeout = timeout;
    711  1.18       kml }
    712  1.18       kml 
    713  1.18       kml 
    714  1.18       kml void
    715  1.18       kml rt_timer_queue_destroy(rtq, destroy)
    716  1.18       kml 	struct rttimer_queue *rtq;
    717  1.18       kml 	int destroy;
    718  1.18       kml {
    719  1.24   thorpej 	struct rttimer *r;
    720  1.18       kml 
    721  1.24   thorpej 	while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL) {
    722  1.18       kml 		LIST_REMOVE(r, rtt_link);
    723  1.24   thorpej 		TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
    724  1.24   thorpej 		if (destroy)
    725  1.18       kml 			RTTIMER_CALLOUT(r);
    726  1.22   thorpej 		pool_put(&rttimer_pool, r);
    727  1.18       kml 	}
    728  1.18       kml 
    729  1.18       kml 	LIST_REMOVE(rtq, rtq_link);
    730  1.22   thorpej 
    731  1.22   thorpej 	/*
    732  1.22   thorpej 	 * Caller is responsible for freeing the rttimer_queue structure.
    733  1.22   thorpej 	 */
    734  1.18       kml }
    735  1.18       kml 
    736  1.18       kml void
    737  1.18       kml rt_timer_remove_all(rt)
    738  1.18       kml 	struct rtentry *rt;
    739  1.18       kml {
    740  1.24   thorpej 	struct rttimer *r;
    741  1.18       kml 
    742  1.24   thorpej 	while ((r = LIST_FIRST(&rt->rt_timer)) != NULL) {
    743  1.18       kml 		LIST_REMOVE(r, rtt_link);
    744  1.24   thorpej 		TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
    745  1.22   thorpej 		pool_put(&rttimer_pool, r);
    746  1.18       kml 	}
    747  1.18       kml }
    748  1.18       kml 
    749  1.18       kml int
    750  1.18       kml rt_timer_add(rt, func, queue)
    751  1.18       kml 	struct rtentry *rt;
    752  1.18       kml 	void(*func) __P((struct rtentry *, struct rttimer *));
    753  1.18       kml 	struct rttimer_queue *queue;
    754  1.18       kml {
    755  1.24   thorpej 	struct rttimer *r;
    756  1.24   thorpej 	long current_time;
    757  1.18       kml 	int s;
    758  1.18       kml 
    759  1.18       kml 	s = splclock();
    760  1.18       kml 	current_time = mono_time.tv_sec;
    761  1.18       kml 	splx(s);
    762  1.18       kml 
    763  1.24   thorpej 	/*
    764  1.24   thorpej 	 * If there's already a timer with this action, destroy it before
    765  1.24   thorpej 	 * we add a new one.
    766  1.24   thorpej 	 */
    767  1.24   thorpej 	for (r = LIST_FIRST(&rt->rt_timer); r != NULL;
    768  1.24   thorpej 	     r = LIST_NEXT(r, rtt_link)) {
    769  1.18       kml 		if (r->rtt_func == func) {
    770  1.18       kml 			LIST_REMOVE(r, rtt_link);
    771  1.24   thorpej 			TAILQ_REMOVE(&r->rtt_queue->rtq_head, r, rtt_next);
    772  1.22   thorpej 			pool_put(&rttimer_pool, r);
    773  1.18       kml 			break;  /* only one per list, so we can quit... */
    774  1.18       kml 		}
    775  1.18       kml 	}
    776  1.18       kml 
    777  1.24   thorpej 	r = pool_get(&rttimer_pool, PR_NOWAIT);
    778  1.24   thorpej 	if (r == NULL)
    779  1.24   thorpej 		return (ENOBUFS);
    780  1.24   thorpej 
    781  1.24   thorpej 	r->rtt_rt = rt;
    782  1.24   thorpej 	r->rtt_time = current_time;
    783  1.24   thorpej 	r->rtt_func = func;
    784  1.24   thorpej 	r->rtt_queue = queue;
    785  1.24   thorpej 	LIST_INSERT_HEAD(&rt->rt_timer, r, rtt_link);
    786  1.24   thorpej 	TAILQ_INSERT_TAIL(&queue->rtq_head, r, rtt_next);
    787  1.24   thorpej 
    788  1.24   thorpej 	return (0);
    789  1.18       kml }
    790  1.18       kml 
    791  1.18       kml /* ARGSUSED */
    792  1.18       kml void
    793  1.18       kml rt_timer_timer(arg)
    794  1.18       kml 	void *arg;
    795  1.18       kml {
    796  1.24   thorpej 	struct rttimer_queue *rtq;
    797  1.24   thorpej 	struct rttimer *r;
    798  1.18       kml 	long current_time;
    799  1.24   thorpej 	int s;
    800  1.21       kml 
    801  1.24   thorpej 	s = splclock();
    802  1.18       kml 	current_time = mono_time.tv_sec;
    803  1.24   thorpej 	splx(s);
    804  1.18       kml 
    805  1.24   thorpej 	s = splsoftnet();
    806  1.18       kml 	for (rtq = LIST_FIRST(&rttimer_queue_head); rtq != NULL;
    807  1.18       kml 	     rtq = LIST_NEXT(rtq, rtq_link)) {
    808  1.24   thorpej 		while ((r = TAILQ_FIRST(&rtq->rtq_head)) != NULL &&
    809  1.24   thorpej 		    (r->rtt_time + rtq->rtq_timeout) < current_time) {
    810  1.24   thorpej 			LIST_REMOVE(r, rtt_link);
    811  1.24   thorpej 			TAILQ_REMOVE(&rtq->rtq_head, r, rtt_next);
    812  1.24   thorpej 			RTTIMER_CALLOUT(r);
    813  1.24   thorpej 			pool_put(&rttimer_pool, r);
    814  1.18       kml 		}
    815  1.18       kml 	}
    816  1.24   thorpej 	splx(s);
    817  1.18       kml 
    818  1.18       kml 	timeout(rt_timer_timer, NULL, hz);  /* every second */
    819   1.1       cgd }
    820