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