rtsock.c revision 1.141.6.2 1 1.141.6.2 rmind /* $NetBSD: rtsock.c,v 1.141.6.2 2013/08/28 23:59:36 rmind Exp $ */
2 1.30 itojun
3 1.30 itojun /*
4 1.30 itojun * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
5 1.30 itojun * All rights reserved.
6 1.75 perry *
7 1.30 itojun * Redistribution and use in source and binary forms, with or without
8 1.30 itojun * modification, are permitted provided that the following conditions
9 1.30 itojun * are met:
10 1.30 itojun * 1. Redistributions of source code must retain the above copyright
11 1.30 itojun * notice, this list of conditions and the following disclaimer.
12 1.30 itojun * 2. Redistributions in binary form must reproduce the above copyright
13 1.30 itojun * notice, this list of conditions and the following disclaimer in the
14 1.30 itojun * documentation and/or other materials provided with the distribution.
15 1.30 itojun * 3. Neither the name of the project nor the names of its contributors
16 1.30 itojun * may be used to endorse or promote products derived from this software
17 1.30 itojun * without specific prior written permission.
18 1.75 perry *
19 1.30 itojun * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
20 1.30 itojun * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.30 itojun * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.30 itojun * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
23 1.30 itojun * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.30 itojun * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.30 itojun * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.30 itojun * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.30 itojun * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.30 itojun * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.30 itojun * SUCH DAMAGE.
30 1.30 itojun */
31 1.11 cgd
32 1.1 cgd /*
33 1.10 mycroft * Copyright (c) 1988, 1991, 1993
34 1.10 mycroft * The Regents of the University of California. All rights reserved.
35 1.1 cgd *
36 1.1 cgd * Redistribution and use in source and binary forms, with or without
37 1.1 cgd * modification, are permitted provided that the following conditions
38 1.1 cgd * are met:
39 1.1 cgd * 1. Redistributions of source code must retain the above copyright
40 1.1 cgd * notice, this list of conditions and the following disclaimer.
41 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
42 1.1 cgd * notice, this list of conditions and the following disclaimer in the
43 1.1 cgd * documentation and/or other materials provided with the distribution.
44 1.64 agc * 3. Neither the name of the University nor the names of its contributors
45 1.1 cgd * may be used to endorse or promote products derived from this software
46 1.1 cgd * without specific prior written permission.
47 1.1 cgd *
48 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
49 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
50 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
51 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
52 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
53 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
54 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
55 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
56 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
57 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
58 1.1 cgd * SUCH DAMAGE.
59 1.1 cgd *
60 1.26 fvdl * @(#)rtsock.c 8.7 (Berkeley) 10/12/95
61 1.1 cgd */
62 1.54 lukem
63 1.54 lukem #include <sys/cdefs.h>
64 1.141.6.2 rmind __KERNEL_RCSID(0, "$NetBSD: rtsock.c,v 1.141.6.2 2013/08/28 23:59:36 rmind Exp $");
65 1.31 thorpej
66 1.133 matt #ifdef _KERNEL_OPT
67 1.31 thorpej #include "opt_inet.h"
68 1.129 kefren #include "opt_mpls.h"
69 1.120 christos #include "opt_compat_netbsd.h"
70 1.120 christos #endif
71 1.1 cgd
72 1.5 mycroft #include <sys/param.h>
73 1.5 mycroft #include <sys/systm.h>
74 1.10 mycroft #include <sys/proc.h>
75 1.5 mycroft #include <sys/socket.h>
76 1.5 mycroft #include <sys/socketvar.h>
77 1.5 mycroft #include <sys/domain.h>
78 1.5 mycroft #include <sys/protosw.h>
79 1.17 christos #include <sys/sysctl.h>
80 1.84 elad #include <sys/kauth.h>
81 1.141.6.1 rmind #include <sys/kmem.h>
82 1.99 ad #include <sys/intr.h>
83 1.91 dyoung #ifdef RTSOCK_DEBUG
84 1.91 dyoung #include <netinet/in.h>
85 1.91 dyoung #endif /* RTSOCK_DEBUG */
86 1.17 christos
87 1.5 mycroft #include <net/if.h>
88 1.5 mycroft #include <net/route.h>
89 1.5 mycroft #include <net/raw_cb.h>
90 1.1 cgd
91 1.129 kefren #include <netmpls/mpls.h>
92 1.129 kefren
93 1.120 christos #if defined(COMPAT_14) || defined(COMPAT_50)
94 1.120 christos #include <compat/net/if.h>
95 1.133 matt #include <compat/net/route.h>
96 1.133 matt #endif
97 1.133 matt #ifdef COMPAT_RTSOCK
98 1.133 matt #define RTM_XVERSION RTM_OVERSION
99 1.133 matt #define RT_XADVANCE(a,b) RT_OADVANCE(a,b)
100 1.133 matt #define RT_XROUNDUP(n) RT_OROUNDUP(n)
101 1.133 matt #define PF_XROUTE PF_OROUTE
102 1.133 matt #define rt_xmsghdr rt_msghdr50
103 1.133 matt #define if_xmsghdr if_msghdr /* if_msghdr50 is for RTM_OIFINFO */
104 1.133 matt #define ifa_xmsghdr ifa_msghdr50
105 1.133 matt #define if_xannouncemsghdr if_announcemsghdr50
106 1.133 matt #define COMPATNAME(x) compat_50_ ## x
107 1.133 matt #define DOMAINNAME "oroute"
108 1.133 matt CTASSERT(sizeof(struct ifa_xmsghdr) == 20);
109 1.133 matt DOMAIN_DEFINE(compat_50_routedomain); /* forward declare and add to link set */
110 1.133 matt #else
111 1.133 matt #define RTM_XVERSION RTM_VERSION
112 1.133 matt #define RT_XADVANCE(a,b) RT_ADVANCE(a,b)
113 1.133 matt #define RT_XROUNDUP(n) RT_ROUNDUP(n)
114 1.133 matt #define PF_XROUTE PF_ROUTE
115 1.133 matt #define rt_xmsghdr rt_msghdr
116 1.133 matt #define if_xmsghdr if_msghdr
117 1.133 matt #define ifa_xmsghdr ifa_msghdr
118 1.133 matt #define if_xannouncemsghdr if_announcemsghdr
119 1.133 matt #define COMPATNAME(x) x
120 1.133 matt #define DOMAINNAME "route"
121 1.133 matt CTASSERT(sizeof(struct ifa_xmsghdr) == 24);
122 1.133 matt #ifdef COMPAT_50
123 1.133 matt #define COMPATCALL(name, args) compat_50_ ## name args
124 1.133 matt #endif
125 1.133 matt DOMAIN_DEFINE(routedomain); /* forward declare and add to link set */
126 1.133 matt #undef COMPAT_50
127 1.133 matt #undef COMPAT_14
128 1.133 matt #endif
129 1.133 matt
130 1.133 matt #ifndef COMPATCALL
131 1.133 matt #define COMPATCALL(name, args) do { } while (/*CONSTCOND*/ 0)
132 1.120 christos #endif
133 1.120 christos
134 1.133 matt struct route_info COMPATNAME(route_info) = {
135 1.133 matt .ri_dst = { .sa_len = 2, .sa_family = PF_XROUTE, },
136 1.133 matt .ri_src = { .sa_len = 2, .sa_family = PF_XROUTE, },
137 1.133 matt .ri_maxqlen = IFQ_MAXLEN,
138 1.133 matt };
139 1.58 matt
140 1.134 kefren #define PRESERVED_RTF (RTF_UP | RTF_GATEWAY | RTF_HOST | RTF_DONE | RTF_MASK)
141 1.134 kefren
142 1.133 matt static void COMPATNAME(route_init)(void);
143 1.133 matt static int COMPATNAME(route_output)(struct mbuf *, ...);
144 1.10 mycroft
145 1.120 christos static int rt_msg2(int, struct rt_addrinfo *, void *, struct rt_walkarg *, int *);
146 1.72 christos static int rt_xaddrs(u_char, const char *, const char *, struct rt_addrinfo *);
147 1.78 dyoung static struct mbuf *rt_makeifannouncemsg(struct ifnet *, int, int,
148 1.78 dyoung struct rt_addrinfo *);
149 1.133 matt static void rt_setmetrics(int, const struct rt_xmsghdr *, struct rtentry *);
150 1.133 matt static void rtm_setmetrics(const struct rtentry *, struct rt_xmsghdr *);
151 1.127 pooka static void sysctl_net_route_setup(struct sysctllog **);
152 1.94 dyoung static int sysctl_dumpentry(struct rtentry *, void *);
153 1.120 christos static int sysctl_iflist(int, struct rt_walkarg *, int);
154 1.69 matt static int sysctl_rtable(SYSCTLFN_PROTO);
155 1.123 yamt static void rt_adjustcount(int, int);
156 1.10 mycroft
157 1.123 yamt static void
158 1.69 matt rt_adjustcount(int af, int cnt)
159 1.27 christos {
160 1.133 matt struct route_cb * const cb = &COMPATNAME(route_info).ri_cb;
161 1.133 matt
162 1.133 matt cb->any_count += cnt;
163 1.133 matt
164 1.27 christos switch (af) {
165 1.27 christos case AF_INET:
166 1.133 matt cb->ip_count += cnt;
167 1.27 christos return;
168 1.30 itojun #ifdef INET6
169 1.30 itojun case AF_INET6:
170 1.133 matt cb->ip6_count += cnt;
171 1.30 itojun return;
172 1.30 itojun #endif
173 1.129 kefren case AF_MPLS:
174 1.133 matt cb->mpls_count += cnt;
175 1.27 christos return;
176 1.27 christos }
177 1.27 christos }
178 1.123 yamt
179 1.141.6.1 rmind static int
180 1.141.6.1 rmind COMPATNAME(route_attach)(struct socket *so, int proto)
181 1.141.6.1 rmind {
182 1.141.6.1 rmind struct rawcb *rp;
183 1.141.6.1 rmind int s, error;
184 1.141.6.1 rmind
185 1.141.6.1 rmind KASSERT(sotorawcb(so) == NULL);
186 1.141.6.1 rmind rp = kmem_zalloc(sizeof(*rp), KM_SLEEP);
187 1.141.6.1 rmind so->so_pcb = rp;
188 1.141.6.1 rmind
189 1.141.6.1 rmind s = splsoftnet();
190 1.141.6.1 rmind rt_adjustcount(rp->rcb_proto.sp_protocol, 1);
191 1.141.6.1 rmind rp->rcb_laddr = &COMPATNAME(route_info).ri_src;
192 1.141.6.1 rmind rp->rcb_faddr = &COMPATNAME(route_info).ri_dst;
193 1.141.6.1 rmind error = raw_attach(so, proto);
194 1.141.6.1 rmind splx(s);
195 1.141.6.1 rmind
196 1.141.6.1 rmind if (error) {
197 1.141.6.1 rmind kmem_free(rp, sizeof(*rp));
198 1.141.6.1 rmind so->so_pcb = NULL;
199 1.141.6.1 rmind return error;
200 1.141.6.1 rmind }
201 1.141.6.1 rmind
202 1.141.6.1 rmind solock(so);
203 1.141.6.1 rmind soisconnected(so);
204 1.141.6.1 rmind so->so_options |= SO_USELOOPBACK;
205 1.141.6.1 rmind sounlock(so);
206 1.141.6.1 rmind
207 1.141.6.1 rmind return error;
208 1.141.6.1 rmind }
209 1.141.6.1 rmind
210 1.141.6.1 rmind static void
211 1.141.6.1 rmind COMPATNAME(route_detach)(struct socket *so)
212 1.1 cgd {
213 1.39 augustss struct rawcb *rp = sotorawcb(so);
214 1.1 cgd int s;
215 1.10 mycroft
216 1.141.6.1 rmind KASSERT(rp != NULL);
217 1.141.6.1 rmind KASSERT(solocked(so));
218 1.141.6.1 rmind
219 1.14 mycroft s = splsoftnet();
220 1.141.6.1 rmind rt_adjustcount(rp->rcb_proto.sp_protocol, -1);
221 1.141.6.1 rmind raw_detach(so);
222 1.141.6.1 rmind splx(s);
223 1.141.6.1 rmind }
224 1.23 thorpej
225 1.141.6.1 rmind static int
226 1.141.6.1 rmind COMPATNAME(route_usrreq)(struct socket *so, int req, struct mbuf *m,
227 1.141.6.1 rmind struct mbuf *nam, struct mbuf *control, struct lwp *l)
228 1.141.6.1 rmind {
229 1.141.6.1 rmind int s, error = 0;
230 1.141.6.1 rmind
231 1.141.6.1 rmind KASSERT(req != PRU_ATTACH);
232 1.141.6.1 rmind KASSERT(req != PRU_DETACH);
233 1.141.6.1 rmind
234 1.141.6.1 rmind s = splsoftnet();
235 1.141.6.1 rmind error = raw_usrreq(so, req, m, nam, control, l);
236 1.1 cgd splx(s);
237 1.141.6.1 rmind
238 1.95 dyoung return error;
239 1.95 dyoung }
240 1.95 dyoung
241 1.1 cgd /*ARGSUSED*/
242 1.9 mycroft int
243 1.133 matt COMPATNAME(route_output)(struct mbuf *m, ...)
244 1.1 cgd {
245 1.133 matt struct sockproto proto = { .sp_family = PF_XROUTE, };
246 1.133 matt struct rt_xmsghdr *rtm = NULL;
247 1.133 matt struct rt_xmsghdr *old_rtm = NULL;
248 1.95 dyoung struct rtentry *rt = NULL;
249 1.95 dyoung struct rtentry *saved_nrt = NULL;
250 1.10 mycroft struct rt_addrinfo info;
251 1.124 roy int len, error = 0;
252 1.95 dyoung struct ifnet *ifp = NULL;
253 1.124 roy struct ifaddr *ifa = NULL;
254 1.17 christos struct socket *so;
255 1.17 christos va_list ap;
256 1.55 christos sa_family_t family;
257 1.17 christos
258 1.17 christos va_start(ap, m);
259 1.17 christos so = va_arg(ap, struct socket *);
260 1.17 christos va_end(ap);
261 1.17 christos
262 1.56 perry #define senderr(e) do { error = e; goto flush;} while (/*CONSTCOND*/ 0)
263 1.95 dyoung if (m == NULL || ((m->m_len < sizeof(int32_t)) &&
264 1.95 dyoung (m = m_pullup(m, sizeof(int32_t))) == NULL))
265 1.95 dyoung return ENOBUFS;
266 1.1 cgd if ((m->m_flags & M_PKTHDR) == 0)
267 1.133 matt panic("%s", __func__);
268 1.1 cgd len = m->m_pkthdr.len;
269 1.1 cgd if (len < sizeof(*rtm) ||
270 1.133 matt len != mtod(m, struct rt_xmsghdr *)->rtm_msglen) {
271 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
272 1.1 cgd senderr(EINVAL);
273 1.10 mycroft }
274 1.133 matt R_Malloc(rtm, struct rt_xmsghdr *, len);
275 1.95 dyoung if (rtm == NULL) {
276 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
277 1.1 cgd senderr(ENOBUFS);
278 1.10 mycroft }
279 1.112 dyoung m_copydata(m, 0, len, rtm);
280 1.133 matt if (rtm->rtm_version != RTM_XVERSION) {
281 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
282 1.1 cgd senderr(EPROTONOSUPPORT);
283 1.10 mycroft }
284 1.1 cgd rtm->rtm_pid = curproc->p_pid;
285 1.48 thorpej memset(&info, 0, sizeof(info));
286 1.10 mycroft info.rti_addrs = rtm->rtm_addrs;
287 1.112 dyoung if (rt_xaddrs(rtm->rtm_type, (const char *)(rtm + 1), len + (char *)rtm,
288 1.133 matt &info)) {
289 1.42 erh senderr(EINVAL);
290 1.133 matt }
291 1.45 itojun info.rti_flags = rtm->rtm_flags;
292 1.91 dyoung #ifdef RTSOCK_DEBUG
293 1.114 dyoung if (info.rti_info[RTAX_DST]->sa_family == AF_INET) {
294 1.114 dyoung printf("%s: extracted info.rti_info[RTAX_DST] %s\n", __func__,
295 1.115 christos inet_ntoa(((const struct sockaddr_in *)
296 1.115 christos info.rti_info[RTAX_DST])->sin_addr));
297 1.91 dyoung }
298 1.91 dyoung #endif /* RTSOCK_DEBUG */
299 1.115 christos if (info.rti_info[RTAX_DST] == NULL ||
300 1.133 matt (info.rti_info[RTAX_DST]->sa_family >= AF_MAX)) {
301 1.26 fvdl senderr(EINVAL);
302 1.133 matt }
303 1.115 christos if (info.rti_info[RTAX_GATEWAY] != NULL &&
304 1.133 matt (info.rti_info[RTAX_GATEWAY]->sa_family >= AF_MAX)) {
305 1.1 cgd senderr(EINVAL);
306 1.133 matt }
307 1.23 thorpej
308 1.23 thorpej /*
309 1.23 thorpej * Verify that the caller has the appropriate privilege; RTM_GET
310 1.23 thorpej * is the only operation the non-superuser is allowed.
311 1.23 thorpej */
312 1.88 elad if (kauth_authorize_network(curlwp->l_cred, KAUTH_NETWORK_ROUTE,
313 1.89 elad 0, rtm, NULL, NULL) != 0)
314 1.23 thorpej senderr(EACCES);
315 1.23 thorpej
316 1.1 cgd switch (rtm->rtm_type) {
317 1.10 mycroft
318 1.1 cgd case RTM_ADD:
319 1.133 matt if (info.rti_info[RTAX_GATEWAY] == NULL) {
320 1.1 cgd senderr(EINVAL);
321 1.133 matt }
322 1.45 itojun error = rtrequest1(rtm->rtm_type, &info, &saved_nrt);
323 1.1 cgd if (error == 0 && saved_nrt) {
324 1.133 matt rt_setmetrics(rtm->rtm_inits, rtm, saved_nrt);
325 1.1 cgd saved_nrt->rt_refcnt--;
326 1.1 cgd }
327 1.1 cgd break;
328 1.1 cgd
329 1.1 cgd case RTM_DELETE:
330 1.45 itojun error = rtrequest1(rtm->rtm_type, &info, &saved_nrt);
331 1.16 cgd if (error == 0) {
332 1.16 cgd (rt = saved_nrt)->rt_refcnt++;
333 1.16 cgd goto report;
334 1.16 cgd }
335 1.1 cgd break;
336 1.1 cgd
337 1.1 cgd case RTM_GET:
338 1.1 cgd case RTM_CHANGE:
339 1.1 cgd case RTM_LOCK:
340 1.115 christos /* XXX This will mask info.rti_info[RTAX_DST] with
341 1.115 christos * info.rti_info[RTAX_NETMASK] before
342 1.95 dyoung * searching. It did not used to do that. --dyoung
343 1.95 dyoung */
344 1.103 dyoung error = rtrequest1(RTM_GET, &info, &rt);
345 1.95 dyoung if (error != 0)
346 1.95 dyoung senderr(error);
347 1.61 itojun if (rtm->rtm_type != RTM_GET) {/* XXX: too grotty */
348 1.115 christos if (memcmp(info.rti_info[RTAX_DST], rt_getkey(rt),
349 1.115 christos info.rti_info[RTAX_DST]->sa_len) != 0)
350 1.61 itojun senderr(ESRCH);
351 1.135 dyoung if (info.rti_info[RTAX_NETMASK] == NULL &&
352 1.135 dyoung rt_mask(rt) != NULL)
353 1.61 itojun senderr(ETOOMANYREFS);
354 1.61 itojun }
355 1.37 itojun
356 1.59 itojun switch (rtm->rtm_type) {
357 1.1 cgd case RTM_GET:
358 1.16 cgd report:
359 1.114 dyoung info.rti_info[RTAX_DST] = rt_getkey(rt);
360 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
361 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
362 1.137 yamt info.rti_info[RTAX_TAG] = rt_gettag(rt);
363 1.91 dyoung if ((rtm->rtm_addrs & (RTA_IFP | RTA_IFA)) == 0)
364 1.91 dyoung ;
365 1.91 dyoung else if ((ifp = rt->rt_ifp) != NULL) {
366 1.91 dyoung const struct ifaddr *rtifa;
367 1.114 dyoung info.rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
368 1.91 dyoung /* rtifa used to be simply rt->rt_ifa.
369 1.91 dyoung * If rt->rt_ifa != NULL, then
370 1.91 dyoung * rt_get_ifa() != NULL. So this
371 1.91 dyoung * ought to still be safe. --dyoung
372 1.91 dyoung */
373 1.91 dyoung rtifa = rt_get_ifa(rt);
374 1.114 dyoung info.rti_info[RTAX_IFA] = rtifa->ifa_addr;
375 1.91 dyoung #ifdef RTSOCK_DEBUG
376 1.115 christos if (info.rti_info[RTAX_IFA]->sa_family ==
377 1.115 christos AF_INET) {
378 1.91 dyoung printf("%s: copying out RTAX_IFA %s ",
379 1.115 christos __func__, inet_ntoa(
380 1.126 tsutsui ((const struct sockaddr_in *)
381 1.126 tsutsui info.rti_info[RTAX_IFA])->sin_addr)
382 1.126 tsutsui );
383 1.115 christos printf("for info.rti_info[RTAX_DST] %s "
384 1.115 christos "ifa_getifa %p ifa_seqno %p\n",
385 1.115 christos inet_ntoa(
386 1.126 tsutsui ((const struct sockaddr_in *)
387 1.115 christos info.rti_info[RTAX_DST])->sin_addr),
388 1.115 christos (void *)rtifa->ifa_getifa,
389 1.115 christos rtifa->ifa_seqno);
390 1.37 itojun }
391 1.91 dyoung #endif /* RTSOCK_DEBUG */
392 1.115 christos if (ifp->if_flags & IFF_POINTOPOINT) {
393 1.115 christos info.rti_info[RTAX_BRD] =
394 1.115 christos rtifa->ifa_dstaddr;
395 1.115 christos } else
396 1.114 dyoung info.rti_info[RTAX_BRD] = NULL;
397 1.91 dyoung rtm->rtm_index = ifp->if_index;
398 1.91 dyoung } else {
399 1.114 dyoung info.rti_info[RTAX_IFP] = NULL;
400 1.114 dyoung info.rti_info[RTAX_IFA] = NULL;
401 1.1 cgd }
402 1.95 dyoung (void)rt_msg2(rtm->rtm_type, &info, NULL, NULL, &len);
403 1.1 cgd if (len > rtm->rtm_msglen) {
404 1.117 christos old_rtm = rtm;
405 1.133 matt R_Malloc(rtm, struct rt_xmsghdr *, len);
406 1.117 christos if (rtm == NULL)
407 1.1 cgd senderr(ENOBUFS);
408 1.117 christos (void)memcpy(rtm, old_rtm, old_rtm->rtm_msglen);
409 1.1 cgd }
410 1.111 christos (void)rt_msg2(rtm->rtm_type, &info, rtm, NULL, 0);
411 1.1 cgd rtm->rtm_flags = rt->rt_flags;
412 1.133 matt rtm_setmetrics(rt, rtm);
413 1.10 mycroft rtm->rtm_addrs = info.rti_addrs;
414 1.1 cgd break;
415 1.1 cgd
416 1.1 cgd case RTM_CHANGE:
417 1.45 itojun /*
418 1.45 itojun * new gateway could require new ifaddr, ifp;
419 1.45 itojun * flags may also be different; ifp may be specified
420 1.45 itojun * by ll sockaddr when protocol address is ambiguous
421 1.45 itojun */
422 1.45 itojun if ((error = rt_getifa(&info)) != 0)
423 1.45 itojun senderr(error);
424 1.115 christos if (info.rti_info[RTAX_GATEWAY] &&
425 1.115 christos rt_setgate(rt, info.rti_info[RTAX_GATEWAY]))
426 1.1 cgd senderr(EDQUOT);
427 1.129 kefren if (info.rti_info[RTAX_TAG])
428 1.129 kefren rt_settag(rt, info.rti_info[RTAX_TAG]);
429 1.35 itojun /* new gateway could require new ifaddr, ifp;
430 1.35 itojun flags may also be different; ifp may be specified
431 1.35 itojun by ll sockaddr when protocol address is ambiguous */
432 1.115 christos if (info.rti_info[RTAX_IFP] &&
433 1.115 christos (ifa = ifa_ifwithnet(info.rti_info[RTAX_IFP])) &&
434 1.115 christos (ifp = ifa->ifa_ifp) && (info.rti_info[RTAX_IFA] ||
435 1.115 christos info.rti_info[RTAX_GATEWAY])) {
436 1.128 kefren if (info.rti_info[RTAX_IFA] == NULL ||
437 1.128 kefren (ifa = ifa_ifwithaddr(
438 1.128 kefren info.rti_info[RTAX_IFA])) == NULL)
439 1.128 kefren ifa = ifaof_ifpforaddr(
440 1.128 kefren info.rti_info[RTAX_IFA] ?
441 1.128 kefren info.rti_info[RTAX_IFA] :
442 1.128 kefren info.rti_info[RTAX_GATEWAY], ifp);
443 1.115 christos } else if ((info.rti_info[RTAX_IFA] &&
444 1.115 christos (ifa = ifa_ifwithaddr(info.rti_info[RTAX_IFA]))) ||
445 1.115 christos (info.rti_info[RTAX_GATEWAY] &&
446 1.115 christos (ifa = ifa_ifwithroute(rt->rt_flags,
447 1.115 christos rt_getkey(rt), info.rti_info[RTAX_GATEWAY])))) {
448 1.35 itojun ifp = ifa->ifa_ifp;
449 1.115 christos }
450 1.35 itojun if (ifa) {
451 1.124 roy struct ifaddr *oifa = rt->rt_ifa;
452 1.35 itojun if (oifa != ifa) {
453 1.90 dyoung if (oifa && oifa->ifa_rtrequest) {
454 1.90 dyoung oifa->ifa_rtrequest(RTM_DELETE,
455 1.90 dyoung rt, &info);
456 1.90 dyoung }
457 1.90 dyoung rt_replace_ifa(rt, ifa);
458 1.90 dyoung rt->rt_ifp = ifp;
459 1.35 itojun }
460 1.35 itojun }
461 1.130 kefren if (ifp && rt->rt_ifp != ifp)
462 1.130 kefren rt->rt_ifp = ifp;
463 1.133 matt rt_setmetrics(rtm->rtm_inits, rtm, rt);
464 1.134 kefren if (rt->rt_flags != info.rti_flags)
465 1.134 kefren rt->rt_flags = (info.rti_flags & ~PRESERVED_RTF)
466 1.134 kefren | (rt->rt_flags & PRESERVED_RTF);
467 1.35 itojun if (rt->rt_ifa && rt->rt_ifa->ifa_rtrequest)
468 1.45 itojun rt->rt_ifa->ifa_rtrequest(RTM_ADD, rt, &info);
469 1.115 christos /*FALLTHROUGH*/
470 1.1 cgd case RTM_LOCK:
471 1.10 mycroft rt->rt_rmx.rmx_locks &= ~(rtm->rtm_inits);
472 1.1 cgd rt->rt_rmx.rmx_locks |=
473 1.21 christos (rtm->rtm_inits & rtm->rtm_rmx.rmx_locks);
474 1.1 cgd break;
475 1.1 cgd }
476 1.10 mycroft break;
477 1.1 cgd
478 1.1 cgd default:
479 1.1 cgd senderr(EOPNOTSUPP);
480 1.1 cgd }
481 1.1 cgd
482 1.1 cgd flush:
483 1.1 cgd if (rtm) {
484 1.1 cgd if (error)
485 1.1 cgd rtm->rtm_errno = error;
486 1.75 perry else
487 1.1 cgd rtm->rtm_flags |= RTF_DONE;
488 1.1 cgd }
489 1.115 christos family = info.rti_info[RTAX_DST] ? info.rti_info[RTAX_DST]->sa_family :
490 1.115 christos 0;
491 1.117 christos /* We cannot free old_rtm until we have stopped using the
492 1.117 christos * pointers in info, some of which may point to sockaddrs
493 1.117 christos * in old_rtm.
494 1.117 christos */
495 1.117 christos if (old_rtm != NULL)
496 1.117 christos Free(old_rtm);
497 1.1 cgd if (rt)
498 1.1 cgd rtfree(rt);
499 1.1 cgd {
500 1.95 dyoung struct rawcb *rp = NULL;
501 1.1 cgd /*
502 1.1 cgd * Check to see if we don't want our own messages.
503 1.1 cgd */
504 1.1 cgd if ((so->so_options & SO_USELOOPBACK) == 0) {
505 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count <= 1) {
506 1.1 cgd if (rtm)
507 1.1 cgd Free(rtm);
508 1.1 cgd m_freem(m);
509 1.95 dyoung return error;
510 1.1 cgd }
511 1.1 cgd /* There is another listener, so construct message */
512 1.1 cgd rp = sotorawcb(so);
513 1.1 cgd }
514 1.1 cgd if (rtm) {
515 1.112 dyoung m_copyback(m, 0, rtm->rtm_msglen, rtm);
516 1.47 itojun if (m->m_pkthdr.len < rtm->rtm_msglen) {
517 1.46 itojun m_freem(m);
518 1.46 itojun m = NULL;
519 1.47 itojun } else if (m->m_pkthdr.len > rtm->rtm_msglen)
520 1.46 itojun m_adj(m, rtm->rtm_msglen - m->m_pkthdr.len);
521 1.1 cgd Free(rtm);
522 1.1 cgd }
523 1.1 cgd if (rp)
524 1.1 cgd rp->rcb_proto.sp_family = 0; /* Avoid us */
525 1.55 christos if (family)
526 1.99 ad proto.sp_protocol = family;
527 1.46 itojun if (m)
528 1.133 matt raw_input(m, &proto, &COMPATNAME(route_info).ri_src,
529 1.133 matt &COMPATNAME(route_info).ri_dst);
530 1.1 cgd if (rp)
531 1.133 matt rp->rcb_proto.sp_family = PF_XROUTE;
532 1.1 cgd }
533 1.95 dyoung return error;
534 1.1 cgd }
535 1.1 cgd
536 1.133 matt static void
537 1.133 matt rt_setmetrics(int which, const struct rt_xmsghdr *in, struct rtentry *out)
538 1.1 cgd {
539 1.133 matt #define metric(f, e) if (which & (f)) out->rt_rmx.e = in->rtm_rmx.e;
540 1.1 cgd metric(RTV_RPIPE, rmx_recvpipe);
541 1.1 cgd metric(RTV_SPIPE, rmx_sendpipe);
542 1.1 cgd metric(RTV_SSTHRESH, rmx_ssthresh);
543 1.1 cgd metric(RTV_RTT, rmx_rtt);
544 1.1 cgd metric(RTV_RTTVAR, rmx_rttvar);
545 1.1 cgd metric(RTV_HOPCOUNT, rmx_hopcount);
546 1.1 cgd metric(RTV_MTU, rmx_mtu);
547 1.1 cgd metric(RTV_EXPIRE, rmx_expire);
548 1.1 cgd #undef metric
549 1.1 cgd }
550 1.1 cgd
551 1.133 matt static void
552 1.133 matt rtm_setmetrics(const struct rtentry *in, struct rt_xmsghdr *out)
553 1.133 matt {
554 1.133 matt #define metric(e) out->rtm_rmx.e = in->rt_rmx.e;
555 1.133 matt metric(rmx_recvpipe);
556 1.133 matt metric(rmx_sendpipe);
557 1.133 matt metric(rmx_ssthresh);
558 1.133 matt metric(rmx_rtt);
559 1.133 matt metric(rmx_rttvar);
560 1.133 matt metric(rmx_hopcount);
561 1.133 matt metric(rmx_mtu);
562 1.133 matt metric(rmx_expire);
563 1.133 matt #undef metric
564 1.133 matt }
565 1.133 matt
566 1.42 erh static int
567 1.115 christos rt_xaddrs(u_char rtmtype, const char *cp, const char *cplim,
568 1.115 christos struct rt_addrinfo *rtinfo)
569 1.10 mycroft {
570 1.69 matt const struct sockaddr *sa = NULL; /* Quell compiler warning */
571 1.39 augustss int i;
572 1.10 mycroft
573 1.112 dyoung for (i = 0; i < RTAX_MAX && cp < cplim; i++) {
574 1.10 mycroft if ((rtinfo->rti_addrs & (1 << i)) == 0)
575 1.10 mycroft continue;
576 1.117 christos rtinfo->rti_info[i] = sa = (const struct sockaddr *)cp;
577 1.133 matt RT_XADVANCE(cp, sa);
578 1.10 mycroft }
579 1.44 enami
580 1.115 christos /*
581 1.115 christos * Check for extra addresses specified, except RTM_GET asking
582 1.115 christos * for interface info.
583 1.115 christos */
584 1.72 christos if (rtmtype == RTM_GET) {
585 1.115 christos if (((rtinfo->rti_addrs &
586 1.115 christos (~((1 << RTAX_IFP) | (1 << RTAX_IFA)))) & (~0 << i)) != 0)
587 1.95 dyoung return 1;
588 1.114 dyoung } else if ((rtinfo->rti_addrs & (~0 << i)) != 0)
589 1.114 dyoung return 1;
590 1.44 enami /* Check for bad data length. */
591 1.44 enami if (cp != cplim) {
592 1.112 dyoung if (i == RTAX_NETMASK + 1 && sa != NULL &&
593 1.133 matt cp - RT_XROUNDUP(sa->sa_len) + sa->sa_len == cplim)
594 1.44 enami /*
595 1.114 dyoung * The last sockaddr was info.rti_info[RTAX_NETMASK].
596 1.44 enami * We accept this for now for the sake of old
597 1.44 enami * binaries or third party softwares.
598 1.44 enami */
599 1.44 enami ;
600 1.44 enami else
601 1.95 dyoung return 1;
602 1.44 enami }
603 1.95 dyoung return 0;
604 1.1 cgd }
605 1.1 cgd
606 1.132 christos static int
607 1.132 christos rt_getlen(int type)
608 1.1 cgd {
609 1.133 matt #ifndef COMPAT_RTSOCK
610 1.133 matt CTASSERT(__alignof(struct ifa_msghdr) >= sizeof(uint64_t));
611 1.133 matt CTASSERT(__alignof(struct if_msghdr) >= sizeof(uint64_t));
612 1.133 matt CTASSERT(__alignof(struct if_announcemsghdr) >= sizeof(uint64_t));
613 1.133 matt CTASSERT(__alignof(struct rt_msghdr) >= sizeof(uint64_t));
614 1.133 matt #endif
615 1.133 matt
616 1.10 mycroft switch (type) {
617 1.10 mycroft case RTM_DELADDR:
618 1.10 mycroft case RTM_NEWADDR:
619 1.131 roy case RTM_CHGADDR:
620 1.133 matt return sizeof(struct ifa_xmsghdr);
621 1.10 mycroft
622 1.132 christos case RTM_OOIFINFO:
623 1.32 bouyer #ifdef COMPAT_14
624 1.132 christos return sizeof(struct if_msghdr14);
625 1.132 christos #else
626 1.132 christos #ifdef DIAGNOSTIC
627 1.132 christos printf("RTM_OOIFINFO\n");
628 1.132 christos #endif
629 1.132 christos return -1;
630 1.120 christos #endif
631 1.132 christos case RTM_OIFINFO:
632 1.120 christos #ifdef COMPAT_50
633 1.132 christos return sizeof(struct if_msghdr50);
634 1.132 christos #else
635 1.132 christos #ifdef DIAGNOSTIC
636 1.132 christos printf("RTM_OIFINFO\n");
637 1.132 christos #endif
638 1.132 christos return -1;
639 1.32 bouyer #endif
640 1.32 bouyer
641 1.10 mycroft case RTM_IFINFO:
642 1.133 matt return sizeof(struct if_xmsghdr);
643 1.10 mycroft
644 1.36 thorpej case RTM_IFANNOUNCE:
645 1.78 dyoung case RTM_IEEE80211:
646 1.133 matt return sizeof(struct if_xannouncemsghdr);
647 1.36 thorpej
648 1.10 mycroft default:
649 1.133 matt return sizeof(struct rt_xmsghdr);
650 1.46 itojun }
651 1.132 christos }
652 1.132 christos
653 1.132 christos
654 1.132 christos struct mbuf *
655 1.133 matt COMPATNAME(rt_msg1)(int type, struct rt_addrinfo *rtinfo, void *data, int datalen)
656 1.132 christos {
657 1.133 matt struct rt_xmsghdr *rtm;
658 1.132 christos struct mbuf *m;
659 1.132 christos int i;
660 1.132 christos const struct sockaddr *sa;
661 1.132 christos int len, dlen;
662 1.132 christos
663 1.132 christos m = m_gethdr(M_DONTWAIT, MT_DATA);
664 1.132 christos if (m == NULL)
665 1.132 christos return m;
666 1.133 matt MCLAIM(m, &COMPATNAME(routedomain).dom_mowner);
667 1.132 christos
668 1.132 christos if ((len = rt_getlen(type)) == -1)
669 1.132 christos goto out;
670 1.47 itojun if (len > MHLEN + MLEN)
671 1.133 matt panic("%s: message too long", __func__);
672 1.47 itojun else if (len > MHLEN) {
673 1.32 bouyer m->m_next = m_get(M_DONTWAIT, MT_DATA);
674 1.132 christos if (m->m_next == NULL)
675 1.132 christos goto out;
676 1.58 matt MCLAIM(m->m_next, m->m_owner);
677 1.47 itojun m->m_pkthdr.len = len;
678 1.47 itojun m->m_len = MHLEN;
679 1.47 itojun m->m_next->m_len = len - MHLEN;
680 1.47 itojun } else {
681 1.47 itojun m->m_pkthdr.len = m->m_len = len;
682 1.32 bouyer }
683 1.95 dyoung m->m_pkthdr.rcvif = NULL;
684 1.32 bouyer m_copyback(m, 0, datalen, data);
685 1.107 christos if (len > datalen)
686 1.107 christos (void)memset(mtod(m, char *) + datalen, 0, len - datalen);
687 1.133 matt rtm = mtod(m, struct rt_xmsghdr *);
688 1.10 mycroft for (i = 0; i < RTAX_MAX; i++) {
689 1.10 mycroft if ((sa = rtinfo->rti_info[i]) == NULL)
690 1.10 mycroft continue;
691 1.10 mycroft rtinfo->rti_addrs |= (1 << i);
692 1.133 matt dlen = RT_XROUNDUP(sa->sa_len);
693 1.133 matt m_copyback(m, len, sa->sa_len, sa);
694 1.133 matt if (dlen != sa->sa_len) {
695 1.140 christos /*
696 1.140 christos * Up to 6 + 1 nul's since roundup is to
697 1.140 christos * sizeof(uint64_t) (8 bytes)
698 1.140 christos */
699 1.133 matt m_copyback(m, len + sa->sa_len,
700 1.133 matt dlen - sa->sa_len, "\0\0\0\0\0\0");
701 1.133 matt }
702 1.10 mycroft len += dlen;
703 1.47 itojun }
704 1.132 christos if (m->m_pkthdr.len != len)
705 1.132 christos goto out;
706 1.1 cgd rtm->rtm_msglen = len;
707 1.133 matt rtm->rtm_version = RTM_XVERSION;
708 1.1 cgd rtm->rtm_type = type;
709 1.95 dyoung return m;
710 1.132 christos out:
711 1.132 christos m_freem(m);
712 1.132 christos return NULL;
713 1.10 mycroft }
714 1.10 mycroft
715 1.29 chopps /*
716 1.29 chopps * rt_msg2
717 1.29 chopps *
718 1.29 chopps * fills 'cp' or 'w'.w_tmem with the routing socket message and
719 1.29 chopps * returns the length of the message in 'lenp'.
720 1.29 chopps *
721 1.29 chopps * if walkarg is 0, cp is expected to be 0 or a buffer large enough to hold
722 1.29 chopps * the message
723 1.29 chopps * otherwise walkarg's w_needed is updated and if the user buffer is
724 1.29 chopps * specified and w_needed indicates space exists the information is copied
725 1.29 chopps * into the temp space (w_tmem). w_tmem is [re]allocated if necessary,
726 1.29 chopps * if the allocation fails ENOBUFS is returned.
727 1.29 chopps */
728 1.10 mycroft static int
729 1.120 christos rt_msg2(int type, struct rt_addrinfo *rtinfo, void *cpv, struct rt_walkarg *w,
730 1.69 matt int *lenp)
731 1.10 mycroft {
732 1.39 augustss int i;
733 1.10 mycroft int len, dlen, second_time = 0;
734 1.93 christos char *cp0, *cp = cpv;
735 1.10 mycroft
736 1.10 mycroft rtinfo->rti_addrs = 0;
737 1.10 mycroft again:
738 1.132 christos if ((len = rt_getlen(type)) == -1)
739 1.132 christos return EINVAL;
740 1.10 mycroft
741 1.17 christos if ((cp0 = cp) != NULL)
742 1.10 mycroft cp += len;
743 1.10 mycroft for (i = 0; i < RTAX_MAX; i++) {
744 1.68 matt const struct sockaddr *sa;
745 1.10 mycroft
746 1.95 dyoung if ((sa = rtinfo->rti_info[i]) == NULL)
747 1.10 mycroft continue;
748 1.10 mycroft rtinfo->rti_addrs |= (1 << i);
749 1.133 matt dlen = RT_XROUNDUP(sa->sa_len);
750 1.10 mycroft if (cp) {
751 1.140 christos int diff = dlen - sa->sa_len;
752 1.140 christos (void)memcpy(cp, sa, (size_t)sa->sa_len);
753 1.140 christos cp += sa->sa_len;
754 1.140 christos if (diff > 0) {
755 1.140 christos (void)memset(cp, 0, (size_t)diff);
756 1.140 christos cp += diff;
757 1.140 christos }
758 1.10 mycroft }
759 1.1 cgd len += dlen;
760 1.1 cgd }
761 1.95 dyoung if (cp == NULL && w != NULL && !second_time) {
762 1.120 christos struct rt_walkarg *rw = w;
763 1.10 mycroft
764 1.10 mycroft rw->w_needed += len;
765 1.10 mycroft if (rw->w_needed <= 0 && rw->w_where) {
766 1.10 mycroft if (rw->w_tmemsize < len) {
767 1.10 mycroft if (rw->w_tmem)
768 1.10 mycroft free(rw->w_tmem, M_RTABLE);
769 1.111 christos rw->w_tmem = malloc(len, M_RTABLE, M_NOWAIT);
770 1.17 christos if (rw->w_tmem)
771 1.10 mycroft rw->w_tmemsize = len;
772 1.111 christos else
773 1.111 christos rw->w_tmemsize = 0;
774 1.10 mycroft }
775 1.10 mycroft if (rw->w_tmem) {
776 1.10 mycroft cp = rw->w_tmem;
777 1.10 mycroft second_time = 1;
778 1.10 mycroft goto again;
779 1.29 chopps } else {
780 1.29 chopps rw->w_tmemneeded = len;
781 1.95 dyoung return ENOBUFS;
782 1.29 chopps }
783 1.10 mycroft }
784 1.1 cgd }
785 1.10 mycroft if (cp) {
786 1.133 matt struct rt_xmsghdr *rtm = (struct rt_xmsghdr *)cp0;
787 1.10 mycroft
788 1.133 matt rtm->rtm_version = RTM_XVERSION;
789 1.10 mycroft rtm->rtm_type = type;
790 1.10 mycroft rtm->rtm_msglen = len;
791 1.1 cgd }
792 1.29 chopps if (lenp)
793 1.29 chopps *lenp = len;
794 1.95 dyoung return 0;
795 1.10 mycroft }
796 1.10 mycroft
797 1.10 mycroft /*
798 1.10 mycroft * This routine is called to generate a message from the routing
799 1.51 wiz * socket indicating that a redirect has occurred, a routing lookup
800 1.10 mycroft * has failed, or that a protocol has detected timeouts to a particular
801 1.10 mycroft * destination.
802 1.10 mycroft */
803 1.10 mycroft void
804 1.133 matt COMPATNAME(rt_missmsg)(int type, const struct rt_addrinfo *rtinfo, int flags,
805 1.133 matt int error)
806 1.10 mycroft {
807 1.133 matt struct rt_xmsghdr rtm;
808 1.39 augustss struct mbuf *m;
809 1.68 matt const struct sockaddr *sa = rtinfo->rti_info[RTAX_DST];
810 1.133 matt struct rt_addrinfo info = *rtinfo;
811 1.10 mycroft
812 1.133 matt COMPATCALL(rt_missmsg, (type, rtinfo, flags, error));
813 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
814 1.10 mycroft return;
815 1.48 thorpej memset(&rtm, 0, sizeof(rtm));
816 1.32 bouyer rtm.rtm_flags = RTF_DONE | flags;
817 1.32 bouyer rtm.rtm_errno = error;
818 1.133 matt m = COMPATNAME(rt_msg1)(type, &info, &rtm, sizeof(rtm));
819 1.95 dyoung if (m == NULL)
820 1.1 cgd return;
821 1.133 matt mtod(m, struct rt_xmsghdr *)->rtm_addrs = info.rti_addrs;
822 1.133 matt COMPATNAME(route_enqueue)(m, sa ? sa->sa_family : 0);
823 1.10 mycroft }
824 1.10 mycroft
825 1.10 mycroft /*
826 1.10 mycroft * This routine is called to generate a message from the routing
827 1.10 mycroft * socket indicating that the status of a network interface has changed.
828 1.10 mycroft */
829 1.10 mycroft void
830 1.133 matt COMPATNAME(rt_ifmsg)(struct ifnet *ifp)
831 1.10 mycroft {
832 1.133 matt struct if_xmsghdr ifm;
833 1.10 mycroft struct mbuf *m;
834 1.10 mycroft struct rt_addrinfo info;
835 1.10 mycroft
836 1.133 matt COMPATCALL(rt_ifmsg, (ifp));
837 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
838 1.10 mycroft return;
839 1.120 christos (void)memset(&info, 0, sizeof(info));
840 1.120 christos (void)memset(&ifm, 0, sizeof(ifm));
841 1.32 bouyer ifm.ifm_index = ifp->if_index;
842 1.32 bouyer ifm.ifm_flags = ifp->if_flags;
843 1.32 bouyer ifm.ifm_data = ifp->if_data;
844 1.32 bouyer ifm.ifm_addrs = 0;
845 1.133 matt m = COMPATNAME(rt_msg1)(RTM_IFINFO, &info, &ifm, sizeof(ifm));
846 1.95 dyoung if (m == NULL)
847 1.32 bouyer return;
848 1.133 matt COMPATNAME(route_enqueue)(m, 0);
849 1.32 bouyer #ifdef COMPAT_14
850 1.133 matt compat_14_rt_oifmsg(ifp);
851 1.120 christos #endif
852 1.120 christos #ifdef COMPAT_50
853 1.133 matt compat_50_rt_oifmsg(ifp);
854 1.32 bouyer #endif
855 1.1 cgd }
856 1.1 cgd
857 1.120 christos
858 1.1 cgd /*
859 1.10 mycroft * This is called to generate messages from the routing socket
860 1.10 mycroft * indicating a network interface has had addresses associated with it.
861 1.10 mycroft * if we ever reverse the logic and replace messages TO the routing
862 1.10 mycroft * socket indicate a request to configure interfaces, then it will
863 1.10 mycroft * be unnecessary as the routing socket will automatically generate
864 1.10 mycroft * copies of it.
865 1.10 mycroft */
866 1.10 mycroft void
867 1.133 matt COMPATNAME(rt_newaddrmsg)(int cmd, struct ifaddr *ifa, int error,
868 1.133 matt struct rtentry *rt)
869 1.10 mycroft {
870 1.116 dyoung #define cmdpass(__cmd, __pass) (((__cmd) << 2) | (__pass))
871 1.10 mycroft struct rt_addrinfo info;
872 1.116 dyoung const struct sockaddr *sa;
873 1.10 mycroft int pass;
874 1.116 dyoung struct mbuf *m;
875 1.139 christos struct ifnet *ifp;
876 1.133 matt struct rt_xmsghdr rtm;
877 1.133 matt struct ifa_xmsghdr ifam;
878 1.116 dyoung int ncmd;
879 1.10 mycroft
880 1.139 christos KASSERT(ifa != NULL);
881 1.139 christos ifp = ifa->ifa_ifp;
882 1.133 matt COMPATCALL(rt_newaddrmsg, (cmd, ifa, error, rt));
883 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
884 1.10 mycroft return;
885 1.10 mycroft for (pass = 1; pass < 3; pass++) {
886 1.48 thorpej memset(&info, 0, sizeof(info));
887 1.116 dyoung switch (cmdpass(cmd, pass)) {
888 1.116 dyoung case cmdpass(RTM_ADD, 1):
889 1.116 dyoung case cmdpass(RTM_CHANGE, 1):
890 1.116 dyoung case cmdpass(RTM_DELETE, 2):
891 1.138 roy case cmdpass(RTM_NEWADDR, 1):
892 1.138 roy case cmdpass(RTM_DELADDR, 1):
893 1.138 roy case cmdpass(RTM_CHGADDR, 1):
894 1.131 roy switch (cmd) {
895 1.138 roy case RTM_ADD:
896 1.138 roy ncmd = RTM_NEWADDR;
897 1.138 roy break;
898 1.131 roy case RTM_DELETE:
899 1.131 roy ncmd = RTM_DELADDR;
900 1.131 roy break;
901 1.131 roy case RTM_CHANGE:
902 1.131 roy ncmd = RTM_CHGADDR;
903 1.131 roy break;
904 1.131 roy default:
905 1.138 roy ncmd = cmd;
906 1.131 roy }
907 1.114 dyoung info.rti_info[RTAX_IFA] = sa = ifa->ifa_addr;
908 1.139 christos KASSERT(ifp->if_dl != NULL);
909 1.114 dyoung info.rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
910 1.114 dyoung info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
911 1.114 dyoung info.rti_info[RTAX_BRD] = ifa->ifa_dstaddr;
912 1.48 thorpej memset(&ifam, 0, sizeof(ifam));
913 1.32 bouyer ifam.ifam_index = ifp->if_index;
914 1.32 bouyer ifam.ifam_metric = ifa->ifa_metric;
915 1.32 bouyer ifam.ifam_flags = ifa->ifa_flags;
916 1.133 matt m = COMPATNAME(rt_msg1)(ncmd, &info, &ifam, sizeof(ifam));
917 1.32 bouyer if (m == NULL)
918 1.10 mycroft continue;
919 1.133 matt mtod(m, struct ifa_xmsghdr *)->ifam_addrs =
920 1.32 bouyer info.rti_addrs;
921 1.116 dyoung break;
922 1.116 dyoung case cmdpass(RTM_ADD, 2):
923 1.116 dyoung case cmdpass(RTM_CHANGE, 2):
924 1.116 dyoung case cmdpass(RTM_DELETE, 1):
925 1.95 dyoung if (rt == NULL)
926 1.10 mycroft continue;
927 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
928 1.114 dyoung info.rti_info[RTAX_DST] = sa = rt_getkey(rt);
929 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
930 1.48 thorpej memset(&rtm, 0, sizeof(rtm));
931 1.32 bouyer rtm.rtm_index = ifp->if_index;
932 1.32 bouyer rtm.rtm_flags |= rt->rt_flags;
933 1.32 bouyer rtm.rtm_errno = error;
934 1.133 matt m = COMPATNAME(rt_msg1)(cmd, &info, &rtm, sizeof(rtm));
935 1.32 bouyer if (m == NULL)
936 1.10 mycroft continue;
937 1.133 matt mtod(m, struct rt_xmsghdr *)->rtm_addrs = info.rti_addrs;
938 1.116 dyoung break;
939 1.116 dyoung default:
940 1.116 dyoung continue;
941 1.10 mycroft }
942 1.104 christos #ifdef DIAGNOSTIC
943 1.104 christos if (m == NULL)
944 1.105 dholland panic("%s: called with wrong command", __func__);
945 1.104 christos #endif
946 1.133 matt COMPATNAME(route_enqueue)(m, sa ? sa->sa_family : 0);
947 1.10 mycroft }
948 1.116 dyoung #undef cmdpass
949 1.36 thorpej }
950 1.36 thorpej
951 1.78 dyoung static struct mbuf *
952 1.78 dyoung rt_makeifannouncemsg(struct ifnet *ifp, int type, int what,
953 1.78 dyoung struct rt_addrinfo *info)
954 1.78 dyoung {
955 1.133 matt struct if_xannouncemsghdr ifan;
956 1.78 dyoung
957 1.78 dyoung memset(info, 0, sizeof(*info));
958 1.78 dyoung memset(&ifan, 0, sizeof(ifan));
959 1.78 dyoung ifan.ifan_index = ifp->if_index;
960 1.78 dyoung strlcpy(ifan.ifan_name, ifp->if_xname, sizeof(ifan.ifan_name));
961 1.78 dyoung ifan.ifan_what = what;
962 1.133 matt return COMPATNAME(rt_msg1)(type, info, &ifan, sizeof(ifan));
963 1.78 dyoung }
964 1.78 dyoung
965 1.36 thorpej /*
966 1.36 thorpej * This is called to generate routing socket messages indicating
967 1.36 thorpej * network interface arrival and departure.
968 1.36 thorpej */
969 1.36 thorpej void
970 1.133 matt COMPATNAME(rt_ifannouncemsg)(struct ifnet *ifp, int what)
971 1.36 thorpej {
972 1.36 thorpej struct mbuf *m;
973 1.36 thorpej struct rt_addrinfo info;
974 1.36 thorpej
975 1.133 matt COMPATCALL(rt_ifannouncemsg, (ifp, what));
976 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
977 1.36 thorpej return;
978 1.78 dyoung m = rt_makeifannouncemsg(ifp, RTM_IFANNOUNCE, what, &info);
979 1.78 dyoung if (m == NULL)
980 1.78 dyoung return;
981 1.133 matt COMPATNAME(route_enqueue)(m, 0);
982 1.78 dyoung }
983 1.78 dyoung
984 1.78 dyoung /*
985 1.78 dyoung * This is called to generate routing socket messages indicating
986 1.78 dyoung * IEEE80211 wireless events.
987 1.78 dyoung * XXX we piggyback on the RTM_IFANNOUNCE msg format in a clumsy way.
988 1.78 dyoung */
989 1.78 dyoung void
990 1.133 matt COMPATNAME(rt_ieee80211msg)(struct ifnet *ifp, int what, void *data,
991 1.133 matt size_t data_len)
992 1.78 dyoung {
993 1.78 dyoung struct mbuf *m;
994 1.78 dyoung struct rt_addrinfo info;
995 1.78 dyoung
996 1.133 matt COMPATCALL(rt_ieee80211msg, (ifp, what, data, data_len));
997 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
998 1.78 dyoung return;
999 1.78 dyoung m = rt_makeifannouncemsg(ifp, RTM_IEEE80211, what, &info);
1000 1.78 dyoung if (m == NULL)
1001 1.36 thorpej return;
1002 1.78 dyoung /*
1003 1.78 dyoung * Append the ieee80211 data. Try to stick it in the
1004 1.78 dyoung * mbuf containing the ifannounce msg; otherwise allocate
1005 1.78 dyoung * a new mbuf and append.
1006 1.78 dyoung *
1007 1.78 dyoung * NB: we assume m is a single mbuf.
1008 1.78 dyoung */
1009 1.78 dyoung if (data_len > M_TRAILINGSPACE(m)) {
1010 1.78 dyoung struct mbuf *n = m_get(M_NOWAIT, MT_DATA);
1011 1.78 dyoung if (n == NULL) {
1012 1.78 dyoung m_freem(m);
1013 1.78 dyoung return;
1014 1.78 dyoung }
1015 1.78 dyoung (void)memcpy(mtod(n, void *), data, data_len);
1016 1.78 dyoung n->m_len = data_len;
1017 1.78 dyoung m->m_next = n;
1018 1.78 dyoung } else if (data_len > 0) {
1019 1.98 matt (void)memcpy(mtod(m, uint8_t *) + m->m_len, data, data_len);
1020 1.78 dyoung m->m_len += data_len;
1021 1.78 dyoung }
1022 1.78 dyoung if (m->m_flags & M_PKTHDR)
1023 1.78 dyoung m->m_pkthdr.len += data_len;
1024 1.133 matt mtod(m, struct if_xannouncemsghdr *)->ifan_msglen += data_len;
1025 1.133 matt COMPATNAME(route_enqueue)(m, 0);
1026 1.10 mycroft }
1027 1.10 mycroft
1028 1.10 mycroft /*
1029 1.10 mycroft * This is used in dumping the kernel table via sysctl().
1030 1.1 cgd */
1031 1.40 simonb static int
1032 1.94 dyoung sysctl_dumpentry(struct rtentry *rt, void *v)
1033 1.1 cgd {
1034 1.120 christos struct rt_walkarg *w = v;
1035 1.10 mycroft int error = 0, size;
1036 1.10 mycroft struct rt_addrinfo info;
1037 1.1 cgd
1038 1.10 mycroft if (w->w_op == NET_RT_FLAGS && !(rt->rt_flags & w->w_arg))
1039 1.10 mycroft return 0;
1040 1.48 thorpej memset(&info, 0, sizeof(info));
1041 1.114 dyoung info.rti_info[RTAX_DST] = rt_getkey(rt);
1042 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
1043 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
1044 1.141.6.2 rmind info.rti_info[RTAX_TAG] = rt_gettag(rt);
1045 1.16 cgd if (rt->rt_ifp) {
1046 1.91 dyoung const struct ifaddr *rtifa;
1047 1.114 dyoung info.rti_info[RTAX_IFP] = rt->rt_ifp->if_dl->ifa_addr;
1048 1.91 dyoung /* rtifa used to be simply rt->rt_ifa. If rt->rt_ifa != NULL,
1049 1.91 dyoung * then rt_get_ifa() != NULL. So this ought to still be safe.
1050 1.91 dyoung * --dyoung
1051 1.91 dyoung */
1052 1.91 dyoung rtifa = rt_get_ifa(rt);
1053 1.114 dyoung info.rti_info[RTAX_IFA] = rtifa->ifa_addr;
1054 1.16 cgd if (rt->rt_ifp->if_flags & IFF_POINTOPOINT)
1055 1.114 dyoung info.rti_info[RTAX_BRD] = rtifa->ifa_dstaddr;
1056 1.16 cgd }
1057 1.29 chopps if ((error = rt_msg2(RTM_GET, &info, 0, w, &size)))
1058 1.95 dyoung return error;
1059 1.29 chopps if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1060 1.133 matt struct rt_xmsghdr *rtm = (struct rt_xmsghdr *)w->w_tmem;
1061 1.10 mycroft
1062 1.10 mycroft rtm->rtm_flags = rt->rt_flags;
1063 1.10 mycroft rtm->rtm_use = rt->rt_use;
1064 1.133 matt rtm_setmetrics(rt, rtm);
1065 1.83 christos KASSERT(rt->rt_ifp != NULL);
1066 1.10 mycroft rtm->rtm_index = rt->rt_ifp->if_index;
1067 1.10 mycroft rtm->rtm_errno = rtm->rtm_pid = rtm->rtm_seq = 0;
1068 1.10 mycroft rtm->rtm_addrs = info.rti_addrs;
1069 1.21 christos if ((error = copyout(rtm, w->w_where, size)) != 0)
1070 1.10 mycroft w->w_where = NULL;
1071 1.10 mycroft else
1072 1.93 christos w->w_where = (char *)w->w_where + size;
1073 1.10 mycroft }
1074 1.95 dyoung return error;
1075 1.10 mycroft }
1076 1.1 cgd
1077 1.40 simonb static int
1078 1.120 christos sysctl_iflist(int af, struct rt_walkarg *w, int type)
1079 1.10 mycroft {
1080 1.39 augustss struct ifnet *ifp;
1081 1.39 augustss struct ifaddr *ifa;
1082 1.10 mycroft struct rt_addrinfo info;
1083 1.10 mycroft int len, error = 0;
1084 1.10 mycroft
1085 1.48 thorpej memset(&info, 0, sizeof(info));
1086 1.74 matt IFNET_FOREACH(ifp) {
1087 1.10 mycroft if (w->w_arg && w->w_arg != ifp->if_index)
1088 1.10 mycroft continue;
1089 1.97 dyoung if (IFADDR_EMPTY(ifp))
1090 1.81 rpaulo continue;
1091 1.114 dyoung info.rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
1092 1.59 itojun switch (type) {
1093 1.32 bouyer case NET_RT_IFLIST:
1094 1.111 christos error = rt_msg2(RTM_IFINFO, &info, NULL, w, &len);
1095 1.32 bouyer break;
1096 1.32 bouyer #ifdef COMPAT_14
1097 1.120 christos case NET_RT_OOIFLIST:
1098 1.120 christos error = rt_msg2(RTM_OOIFINFO, &info, NULL, w, &len);
1099 1.120 christos break;
1100 1.120 christos #endif
1101 1.120 christos #ifdef COMPAT_50
1102 1.32 bouyer case NET_RT_OIFLIST:
1103 1.111 christos error = rt_msg2(RTM_OIFINFO, &info, NULL, w, &len);
1104 1.32 bouyer break;
1105 1.32 bouyer #endif
1106 1.32 bouyer default:
1107 1.32 bouyer panic("sysctl_iflist(1)");
1108 1.32 bouyer }
1109 1.32 bouyer if (error)
1110 1.95 dyoung return error;
1111 1.114 dyoung info.rti_info[RTAX_IFP] = NULL;
1112 1.29 chopps if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1113 1.59 itojun switch (type) {
1114 1.32 bouyer case NET_RT_IFLIST: {
1115 1.133 matt struct if_xmsghdr *ifm;
1116 1.32 bouyer
1117 1.133 matt ifm = (struct if_xmsghdr *)w->w_tmem;
1118 1.32 bouyer ifm->ifm_index = ifp->if_index;
1119 1.32 bouyer ifm->ifm_flags = ifp->if_flags;
1120 1.32 bouyer ifm->ifm_data = ifp->if_data;
1121 1.32 bouyer ifm->ifm_addrs = info.rti_addrs;
1122 1.32 bouyer error = copyout(ifm, w->w_where, len);
1123 1.32 bouyer if (error)
1124 1.95 dyoung return error;
1125 1.93 christos w->w_where = (char *)w->w_where + len;
1126 1.32 bouyer break;
1127 1.32 bouyer }
1128 1.10 mycroft
1129 1.32 bouyer #ifdef COMPAT_14
1130 1.120 christos case NET_RT_OOIFLIST:
1131 1.120 christos error = compat_14_iflist(ifp, w, &info, len);
1132 1.120 christos if (error)
1133 1.120 christos return error;
1134 1.120 christos break;
1135 1.120 christos #endif
1136 1.120 christos #ifdef COMPAT_50
1137 1.120 christos case NET_RT_OIFLIST:
1138 1.120 christos error = compat_50_iflist(ifp, w, &info, len);
1139 1.32 bouyer if (error)
1140 1.95 dyoung return error;
1141 1.32 bouyer break;
1142 1.32 bouyer #endif
1143 1.32 bouyer default:
1144 1.32 bouyer panic("sysctl_iflist(2)");
1145 1.32 bouyer }
1146 1.10 mycroft }
1147 1.97 dyoung IFADDR_FOREACH(ifa, ifp) {
1148 1.10 mycroft if (af && af != ifa->ifa_addr->sa_family)
1149 1.10 mycroft continue;
1150 1.114 dyoung info.rti_info[RTAX_IFA] = ifa->ifa_addr;
1151 1.114 dyoung info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
1152 1.114 dyoung info.rti_info[RTAX_BRD] = ifa->ifa_dstaddr;
1153 1.29 chopps if ((error = rt_msg2(RTM_NEWADDR, &info, 0, w, &len)))
1154 1.95 dyoung return error;
1155 1.29 chopps if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1156 1.133 matt struct ifa_xmsghdr *ifam;
1157 1.10 mycroft
1158 1.133 matt ifam = (struct ifa_xmsghdr *)w->w_tmem;
1159 1.10 mycroft ifam->ifam_index = ifa->ifa_ifp->if_index;
1160 1.10 mycroft ifam->ifam_flags = ifa->ifa_flags;
1161 1.10 mycroft ifam->ifam_metric = ifa->ifa_metric;
1162 1.10 mycroft ifam->ifam_addrs = info.rti_addrs;
1163 1.17 christos error = copyout(w->w_tmem, w->w_where, len);
1164 1.17 christos if (error)
1165 1.95 dyoung return error;
1166 1.93 christos w->w_where = (char *)w->w_where + len;
1167 1.10 mycroft }
1168 1.10 mycroft }
1169 1.115 christos info.rti_info[RTAX_IFA] = info.rti_info[RTAX_NETMASK] =
1170 1.115 christos info.rti_info[RTAX_BRD] = NULL;
1171 1.10 mycroft }
1172 1.95 dyoung return 0;
1173 1.1 cgd }
1174 1.1 cgd
1175 1.40 simonb static int
1176 1.65 atatat sysctl_rtable(SYSCTLFN_ARGS)
1177 1.1 cgd {
1178 1.65 atatat void *where = oldp;
1179 1.65 atatat size_t *given = oldlenp;
1180 1.65 atatat const void *new = newp;
1181 1.10 mycroft int i, s, error = EINVAL;
1182 1.10 mycroft u_char af;
1183 1.120 christos struct rt_walkarg w;
1184 1.1 cgd
1185 1.66 atatat if (namelen == 1 && name[0] == CTL_QUERY)
1186 1.95 dyoung return sysctl_query(SYSCTLFN_CALL(rnode));
1187 1.66 atatat
1188 1.10 mycroft if (new)
1189 1.95 dyoung return EPERM;
1190 1.10 mycroft if (namelen != 3)
1191 1.95 dyoung return EINVAL;
1192 1.10 mycroft af = name[0];
1193 1.29 chopps w.w_tmemneeded = 0;
1194 1.29 chopps w.w_tmemsize = 0;
1195 1.29 chopps w.w_tmem = NULL;
1196 1.29 chopps again:
1197 1.29 chopps /* we may return here if a later [re]alloc of the t_mem buffer fails */
1198 1.29 chopps if (w.w_tmemneeded) {
1199 1.111 christos w.w_tmem = malloc(w.w_tmemneeded, M_RTABLE, M_WAITOK);
1200 1.29 chopps w.w_tmemsize = w.w_tmemneeded;
1201 1.29 chopps w.w_tmemneeded = 0;
1202 1.29 chopps }
1203 1.29 chopps w.w_op = name[1];
1204 1.29 chopps w.w_arg = name[2];
1205 1.10 mycroft w.w_given = *given;
1206 1.1 cgd w.w_needed = 0 - w.w_given;
1207 1.29 chopps w.w_where = where;
1208 1.1 cgd
1209 1.14 mycroft s = splsoftnet();
1210 1.10 mycroft switch (w.w_op) {
1211 1.10 mycroft
1212 1.10 mycroft case NET_RT_DUMP:
1213 1.10 mycroft case NET_RT_FLAGS:
1214 1.10 mycroft for (i = 1; i <= AF_MAX; i++)
1215 1.94 dyoung if ((af == 0 || af == i) &&
1216 1.94 dyoung (error = rt_walktree(i, sysctl_dumpentry, &w)))
1217 1.10 mycroft break;
1218 1.10 mycroft break;
1219 1.10 mycroft
1220 1.32 bouyer #ifdef COMPAT_14
1221 1.120 christos case NET_RT_OOIFLIST:
1222 1.120 christos error = sysctl_iflist(af, &w, w.w_op);
1223 1.120 christos break;
1224 1.120 christos #endif
1225 1.120 christos #ifdef COMPAT_50
1226 1.32 bouyer case NET_RT_OIFLIST:
1227 1.32 bouyer error = sysctl_iflist(af, &w, w.w_op);
1228 1.32 bouyer break;
1229 1.32 bouyer #endif
1230 1.10 mycroft case NET_RT_IFLIST:
1231 1.32 bouyer error = sysctl_iflist(af, &w, w.w_op);
1232 1.133 matt break;
1233 1.1 cgd }
1234 1.10 mycroft splx(s);
1235 1.29 chopps
1236 1.29 chopps /* check to see if we couldn't allocate memory with NOWAIT */
1237 1.29 chopps if (error == ENOBUFS && w.w_tmem == 0 && w.w_tmemneeded)
1238 1.29 chopps goto again;
1239 1.29 chopps
1240 1.10 mycroft if (w.w_tmem)
1241 1.10 mycroft free(w.w_tmem, M_RTABLE);
1242 1.1 cgd w.w_needed += w.w_given;
1243 1.10 mycroft if (where) {
1244 1.93 christos *given = (char *)w.w_where - (char *)where;
1245 1.10 mycroft if (*given < w.w_needed)
1246 1.95 dyoung return ENOMEM;
1247 1.10 mycroft } else {
1248 1.10 mycroft *given = (11 * w.w_needed) / 10;
1249 1.10 mycroft }
1250 1.95 dyoung return error;
1251 1.1 cgd }
1252 1.1 cgd
1253 1.1 cgd /*
1254 1.99 ad * Routing message software interrupt routine
1255 1.99 ad */
1256 1.99 ad static void
1257 1.133 matt COMPATNAME(route_intr)(void *cookie)
1258 1.99 ad {
1259 1.133 matt struct sockproto proto = { .sp_family = PF_XROUTE, };
1260 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
1261 1.99 ad struct mbuf *m;
1262 1.99 ad int s;
1263 1.99 ad
1264 1.101 ad mutex_enter(softnet_lock);
1265 1.101 ad KERNEL_LOCK(1, NULL);
1266 1.133 matt while (!IF_IS_EMPTY(&ri->ri_intrq)) {
1267 1.99 ad s = splnet();
1268 1.133 matt IF_DEQUEUE(&ri->ri_intrq, m);
1269 1.99 ad splx(s);
1270 1.99 ad if (m == NULL)
1271 1.99 ad break;
1272 1.100 yamt proto.sp_protocol = M_GETCTX(m, uintptr_t);
1273 1.133 matt raw_input(m, &proto, &ri->ri_src, &ri->ri_dst);
1274 1.99 ad }
1275 1.101 ad KERNEL_UNLOCK_ONE(NULL);
1276 1.101 ad mutex_exit(softnet_lock);
1277 1.99 ad }
1278 1.99 ad
1279 1.99 ad /*
1280 1.99 ad * Enqueue a message to the software interrupt routine.
1281 1.99 ad */
1282 1.120 christos void
1283 1.133 matt COMPATNAME(route_enqueue)(struct mbuf *m, int family)
1284 1.99 ad {
1285 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
1286 1.99 ad int s, wasempty;
1287 1.99 ad
1288 1.99 ad s = splnet();
1289 1.133 matt if (IF_QFULL(&ri->ri_intrq)) {
1290 1.133 matt IF_DROP(&ri->ri_intrq);
1291 1.99 ad m_freem(m);
1292 1.99 ad } else {
1293 1.133 matt wasempty = IF_IS_EMPTY(&ri->ri_intrq);
1294 1.99 ad M_SETCTX(m, (uintptr_t)family);
1295 1.133 matt IF_ENQUEUE(&ri->ri_intrq, m);
1296 1.99 ad if (wasempty)
1297 1.133 matt softint_schedule(ri->ri_sih);
1298 1.99 ad }
1299 1.99 ad splx(s);
1300 1.99 ad }
1301 1.99 ad
1302 1.133 matt static void
1303 1.133 matt COMPATNAME(route_init)(void)
1304 1.99 ad {
1305 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
1306 1.133 matt
1307 1.133 matt #ifndef COMPAT_RTSOCK
1308 1.133 matt rt_init();
1309 1.133 matt #endif
1310 1.99 ad
1311 1.127 pooka sysctl_net_route_setup(NULL);
1312 1.133 matt ri->ri_intrq.ifq_maxlen = ri->ri_maxqlen;
1313 1.133 matt ri->ri_sih = softint_establish(SOFTINT_NET | SOFTINT_MPSAFE,
1314 1.133 matt COMPATNAME(route_intr), NULL);
1315 1.99 ad }
1316 1.99 ad
1317 1.99 ad /*
1318 1.1 cgd * Definitions of protocols supported in the ROUTE domain.
1319 1.1 cgd */
1320 1.133 matt #ifndef COMPAT_RTSOCK
1321 1.133 matt PR_WRAP_USRREQ(route_usrreq);
1322 1.133 matt #else
1323 1.133 matt PR_WRAP_USRREQ(compat_50_route_usrreq);
1324 1.133 matt #endif
1325 1.1 cgd
1326 1.141.6.1 rmind static const struct pr_usrreqs route_usrreqs = {
1327 1.141.6.1 rmind .pr_attach = COMPATNAME(route_attach),
1328 1.141.6.1 rmind .pr_detach = COMPATNAME(route_detach),
1329 1.141.6.1 rmind .pr_generic = COMPATNAME(route_usrreq_wrapper),
1330 1.141.6.1 rmind };
1331 1.141.6.1 rmind
1332 1.133 matt static const struct protosw COMPATNAME(route_protosw)[] = {
1333 1.92 matt {
1334 1.92 matt .pr_type = SOCK_RAW,
1335 1.133 matt .pr_domain = &COMPATNAME(routedomain),
1336 1.92 matt .pr_flags = PR_ATOMIC|PR_ADDR,
1337 1.92 matt .pr_input = raw_input,
1338 1.133 matt .pr_output = COMPATNAME(route_output),
1339 1.92 matt .pr_ctlinput = raw_ctlinput,
1340 1.141.6.1 rmind .pr_usrreqs = &route_usrreqs,
1341 1.92 matt .pr_init = raw_init,
1342 1.92 matt },
1343 1.92 matt };
1344 1.69 matt
1345 1.133 matt struct domain COMPATNAME(routedomain) = {
1346 1.133 matt .dom_family = PF_XROUTE,
1347 1.133 matt .dom_name = DOMAINNAME,
1348 1.133 matt .dom_init = COMPATNAME(route_init),
1349 1.133 matt .dom_protosw = COMPATNAME(route_protosw),
1350 1.133 matt .dom_protoswNPROTOSW =
1351 1.133 matt &COMPATNAME(route_protosw)[__arraycount(COMPATNAME(route_protosw))],
1352 1.1 cgd };
1353 1.1 cgd
1354 1.127 pooka static void
1355 1.127 pooka sysctl_net_route_setup(struct sysctllog **clog)
1356 1.65 atatat {
1357 1.85 elad const struct sysctlnode *rnode = NULL;
1358 1.85 elad
1359 1.67 atatat sysctl_createv(clog, 0, NULL, NULL,
1360 1.67 atatat CTLFLAG_PERMANENT,
1361 1.65 atatat CTLTYPE_NODE, "net", NULL,
1362 1.65 atatat NULL, 0, NULL, 0,
1363 1.65 atatat CTL_NET, CTL_EOL);
1364 1.65 atatat
1365 1.85 elad sysctl_createv(clog, 0, NULL, &rnode,
1366 1.67 atatat CTLFLAG_PERMANENT,
1367 1.133 matt CTLTYPE_NODE, DOMAINNAME,
1368 1.71 atatat SYSCTL_DESCR("PF_ROUTE information"),
1369 1.65 atatat NULL, 0, NULL, 0,
1370 1.133 matt CTL_NET, PF_XROUTE, CTL_EOL);
1371 1.133 matt
1372 1.67 atatat sysctl_createv(clog, 0, NULL, NULL,
1373 1.67 atatat CTLFLAG_PERMANENT,
1374 1.71 atatat CTLTYPE_NODE, "rtable",
1375 1.71 atatat SYSCTL_DESCR("Routing table information"),
1376 1.65 atatat sysctl_rtable, 0, NULL, 0,
1377 1.133 matt CTL_NET, PF_XROUTE, 0 /* any protocol */, CTL_EOL);
1378 1.133 matt
1379 1.85 elad sysctl_createv(clog, 0, &rnode, NULL,
1380 1.85 elad CTLFLAG_PERMANENT,
1381 1.85 elad CTLTYPE_STRUCT, "stats",
1382 1.85 elad SYSCTL_DESCR("Routing statistics"),
1383 1.85 elad NULL, 0, &rtstat, sizeof(rtstat),
1384 1.85 elad CTL_CREATE, CTL_EOL);
1385 1.65 atatat }
1386