rtsock.c revision 1.226 1 1.226 christos /* $NetBSD: rtsock.c,v 1.226 2017/06/30 18:28:31 christos 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.226 christos __KERNEL_RCSID(0, "$NetBSD: rtsock.c,v 1.226 2017/06/30 18:28:31 christos 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.174 rjs #include "opt_sctp.h"
71 1.200 ozaki #include "opt_net_mpsafe.h"
72 1.120 christos #endif
73 1.1 cgd
74 1.5 mycroft #include <sys/param.h>
75 1.5 mycroft #include <sys/systm.h>
76 1.10 mycroft #include <sys/proc.h>
77 1.5 mycroft #include <sys/socket.h>
78 1.5 mycroft #include <sys/socketvar.h>
79 1.5 mycroft #include <sys/domain.h>
80 1.5 mycroft #include <sys/protosw.h>
81 1.17 christos #include <sys/sysctl.h>
82 1.84 elad #include <sys/kauth.h>
83 1.145 rmind #include <sys/kmem.h>
84 1.99 ad #include <sys/intr.h>
85 1.17 christos
86 1.5 mycroft #include <net/if.h>
87 1.178 ozaki #include <net/if_llatbl.h>
88 1.178 ozaki #include <net/if_types.h>
89 1.5 mycroft #include <net/route.h>
90 1.5 mycroft #include <net/raw_cb.h>
91 1.1 cgd
92 1.178 ozaki #include <netinet/in_var.h>
93 1.178 ozaki #include <netinet/if_inarp.h>
94 1.178 ozaki
95 1.129 kefren #include <netmpls/mpls.h>
96 1.129 kefren
97 1.174 rjs #ifdef SCTP
98 1.174 rjs extern void sctp_add_ip_address(struct ifaddr *);
99 1.174 rjs extern void sctp_delete_ip_address(struct ifaddr *);
100 1.174 rjs #endif
101 1.174 rjs
102 1.196 roy #if defined(COMPAT_14) || defined(COMPAT_50) || defined(COMPAT_70)
103 1.120 christos #include <compat/net/if.h>
104 1.133 matt #include <compat/net/route.h>
105 1.133 matt #endif
106 1.133 matt #ifdef COMPAT_RTSOCK
107 1.133 matt #define RTM_XVERSION RTM_OVERSION
108 1.196 roy #define RTM_XNEWADDR RTM_ONEWADDR
109 1.196 roy #define RTM_XDELADDR RTM_ODELADDR
110 1.196 roy #define RTM_XCHGADDR RTM_OCHGADDR
111 1.133 matt #define RT_XADVANCE(a,b) RT_OADVANCE(a,b)
112 1.133 matt #define RT_XROUNDUP(n) RT_OROUNDUP(n)
113 1.133 matt #define PF_XROUTE PF_OROUTE
114 1.133 matt #define rt_xmsghdr rt_msghdr50
115 1.133 matt #define if_xmsghdr if_msghdr /* if_msghdr50 is for RTM_OIFINFO */
116 1.133 matt #define ifa_xmsghdr ifa_msghdr50
117 1.133 matt #define if_xannouncemsghdr if_announcemsghdr50
118 1.133 matt #define COMPATNAME(x) compat_50_ ## x
119 1.133 matt #define DOMAINNAME "oroute"
120 1.133 matt CTASSERT(sizeof(struct ifa_xmsghdr) == 20);
121 1.133 matt DOMAIN_DEFINE(compat_50_routedomain); /* forward declare and add to link set */
122 1.196 roy #undef COMPAT_70
123 1.168 ozaki #else /* COMPAT_RTSOCK */
124 1.133 matt #define RTM_XVERSION RTM_VERSION
125 1.196 roy #define RTM_XNEWADDR RTM_NEWADDR
126 1.196 roy #define RTM_XDELADDR RTM_DELADDR
127 1.196 roy #define RTM_XCHGADDR RTM_CHGADDR
128 1.133 matt #define RT_XADVANCE(a,b) RT_ADVANCE(a,b)
129 1.133 matt #define RT_XROUNDUP(n) RT_ROUNDUP(n)
130 1.133 matt #define PF_XROUTE PF_ROUTE
131 1.133 matt #define rt_xmsghdr rt_msghdr
132 1.133 matt #define if_xmsghdr if_msghdr
133 1.133 matt #define ifa_xmsghdr ifa_msghdr
134 1.133 matt #define if_xannouncemsghdr if_announcemsghdr
135 1.133 matt #define COMPATNAME(x) x
136 1.133 matt #define DOMAINNAME "route"
137 1.196 roy CTASSERT(sizeof(struct ifa_xmsghdr) == 32);
138 1.133 matt #ifdef COMPAT_50
139 1.133 matt #define COMPATCALL(name, args) compat_50_ ## name args
140 1.133 matt #endif
141 1.133 matt DOMAIN_DEFINE(routedomain); /* forward declare and add to link set */
142 1.133 matt #undef COMPAT_50
143 1.133 matt #undef COMPAT_14
144 1.168 ozaki #endif /* COMPAT_RTSOCK */
145 1.133 matt
146 1.133 matt #ifndef COMPATCALL
147 1.133 matt #define COMPATCALL(name, args) do { } while (/*CONSTCOND*/ 0)
148 1.120 christos #endif
149 1.120 christos
150 1.165 christos #ifdef RTSOCK_DEBUG
151 1.188 ozaki #define RT_IN_PRINT(info, b, a) (in_print((b), sizeof(b), \
152 1.188 ozaki &((const struct sockaddr_in *)(info)->rti_info[(a)])->sin_addr), (b))
153 1.165 christos #endif /* RTSOCK_DEBUG */
154 1.165 christos
155 1.133 matt struct route_info COMPATNAME(route_info) = {
156 1.133 matt .ri_dst = { .sa_len = 2, .sa_family = PF_XROUTE, },
157 1.133 matt .ri_src = { .sa_len = 2, .sa_family = PF_XROUTE, },
158 1.133 matt .ri_maxqlen = IFQ_MAXLEN,
159 1.133 matt };
160 1.58 matt
161 1.134 kefren #define PRESERVED_RTF (RTF_UP | RTF_GATEWAY | RTF_HOST | RTF_DONE | RTF_MASK)
162 1.134 kefren
163 1.133 matt static void COMPATNAME(route_init)(void);
164 1.175 riastrad static int COMPATNAME(route_output)(struct mbuf *, struct socket *);
165 1.10 mycroft
166 1.72 christos static int rt_xaddrs(u_char, const char *, const char *, struct rt_addrinfo *);
167 1.78 dyoung static struct mbuf *rt_makeifannouncemsg(struct ifnet *, int, int,
168 1.78 dyoung struct rt_addrinfo *);
169 1.178 ozaki static int rt_msg2(int, struct rt_addrinfo *, void *, struct rt_walkarg *, int *);
170 1.133 matt static void rt_setmetrics(int, const struct rt_xmsghdr *, struct rtentry *);
171 1.133 matt static void rtm_setmetrics(const struct rtentry *, struct rt_xmsghdr *);
172 1.127 pooka static void sysctl_net_route_setup(struct sysctllog **);
173 1.94 dyoung static int sysctl_dumpentry(struct rtentry *, void *);
174 1.120 christos static int sysctl_iflist(int, struct rt_walkarg *, int);
175 1.69 matt static int sysctl_rtable(SYSCTLFN_PROTO);
176 1.123 yamt static void rt_adjustcount(int, int);
177 1.10 mycroft
178 1.175 riastrad static const struct protosw COMPATNAME(route_protosw)[];
179 1.175 riastrad
180 1.212 roy struct routecb {
181 1.212 roy struct rawcb rocb_rcb;
182 1.212 roy unsigned int rocb_msgfilter;
183 1.212 roy #define RTMSGFILTER(m) (1U << (m))
184 1.212 roy };
185 1.212 roy #define sotoroutecb(so) ((struct routecb *)(so)->so_pcb)
186 1.212 roy
187 1.123 yamt static void
188 1.69 matt rt_adjustcount(int af, int cnt)
189 1.27 christos {
190 1.133 matt struct route_cb * const cb = &COMPATNAME(route_info).ri_cb;
191 1.133 matt
192 1.133 matt cb->any_count += cnt;
193 1.133 matt
194 1.27 christos switch (af) {
195 1.27 christos case AF_INET:
196 1.133 matt cb->ip_count += cnt;
197 1.27 christos return;
198 1.30 itojun #ifdef INET6
199 1.30 itojun case AF_INET6:
200 1.133 matt cb->ip6_count += cnt;
201 1.30 itojun return;
202 1.30 itojun #endif
203 1.129 kefren case AF_MPLS:
204 1.133 matt cb->mpls_count += cnt;
205 1.27 christos return;
206 1.27 christos }
207 1.27 christos }
208 1.123 yamt
209 1.145 rmind static int
210 1.212 roy COMPATNAME(route_filter)(struct mbuf *m, struct sockproto *proto,
211 1.212 roy struct rawcb *rp)
212 1.212 roy {
213 1.212 roy struct routecb *rop = (struct routecb *)rp;
214 1.212 roy struct rt_xmsghdr *rtm;
215 1.212 roy
216 1.212 roy KASSERT(m != NULL);
217 1.212 roy KASSERT(proto != NULL);
218 1.212 roy KASSERT(rp != NULL);
219 1.212 roy
220 1.212 roy /* Wrong family for this socket. */
221 1.212 roy if (proto->sp_family != PF_ROUTE)
222 1.212 roy return ENOPROTOOPT;
223 1.212 roy
224 1.212 roy /* If no filter set, just return. */
225 1.212 roy if (rop->rocb_msgfilter == 0)
226 1.212 roy return 0;
227 1.212 roy
228 1.212 roy /* Ensure we can access rtm_type */
229 1.212 roy if (m->m_len <
230 1.212 roy offsetof(struct rt_xmsghdr, rtm_type) + sizeof(rtm->rtm_type))
231 1.212 roy return EINVAL;
232 1.212 roy
233 1.212 roy rtm = mtod(m, struct rt_xmsghdr *);
234 1.212 roy /* If the rtm type is filtered out, return a positive. */
235 1.212 roy if (!(rop->rocb_msgfilter & RTMSGFILTER(rtm->rtm_type)))
236 1.212 roy return EEXIST;
237 1.212 roy
238 1.212 roy /* Passed the filter. */
239 1.212 roy return 0;
240 1.212 roy }
241 1.212 roy
242 1.212 roy static int
243 1.145 rmind COMPATNAME(route_attach)(struct socket *so, int proto)
244 1.1 cgd {
245 1.145 rmind struct rawcb *rp;
246 1.212 roy struct routecb *rop;
247 1.145 rmind int s, error;
248 1.145 rmind
249 1.145 rmind KASSERT(sotorawcb(so) == NULL);
250 1.212 roy rop = kmem_zalloc(sizeof(*rop), KM_SLEEP);
251 1.212 roy rp = &rop->rocb_rcb;
252 1.212 roy rp->rcb_len = sizeof(*rop);
253 1.145 rmind so->so_pcb = rp;
254 1.10 mycroft
255 1.14 mycroft s = splsoftnet();
256 1.145 rmind if ((error = raw_attach(so, proto)) == 0) {
257 1.27 christos rt_adjustcount(rp->rcb_proto.sp_protocol, 1);
258 1.133 matt rp->rcb_laddr = &COMPATNAME(route_info).ri_src;
259 1.133 matt rp->rcb_faddr = &COMPATNAME(route_info).ri_dst;
260 1.212 roy rp->rcb_filter = COMPATNAME(route_filter);
261 1.1 cgd }
262 1.1 cgd splx(s);
263 1.145 rmind
264 1.145 rmind if (error) {
265 1.212 roy kmem_free(rop, sizeof(*rop));
266 1.145 rmind so->so_pcb = NULL;
267 1.145 rmind return error;
268 1.145 rmind }
269 1.145 rmind
270 1.145 rmind soisconnected(so);
271 1.145 rmind so->so_options |= SO_USELOOPBACK;
272 1.145 rmind KASSERT(solocked(so));
273 1.145 rmind
274 1.145 rmind return error;
275 1.145 rmind }
276 1.145 rmind
277 1.145 rmind static void
278 1.145 rmind COMPATNAME(route_detach)(struct socket *so)
279 1.145 rmind {
280 1.145 rmind struct rawcb *rp = sotorawcb(so);
281 1.145 rmind int s;
282 1.145 rmind
283 1.145 rmind KASSERT(rp != NULL);
284 1.145 rmind KASSERT(solocked(so));
285 1.145 rmind
286 1.145 rmind s = splsoftnet();
287 1.145 rmind rt_adjustcount(rp->rcb_proto.sp_protocol, -1);
288 1.145 rmind raw_detach(so);
289 1.145 rmind splx(s);
290 1.145 rmind }
291 1.145 rmind
292 1.145 rmind static int
293 1.169 rtr COMPATNAME(route_accept)(struct socket *so, struct sockaddr *nam)
294 1.155 rtr {
295 1.155 rtr KASSERT(solocked(so));
296 1.155 rtr
297 1.155 rtr panic("route_accept");
298 1.157 rtr
299 1.157 rtr return EOPNOTSUPP;
300 1.157 rtr }
301 1.157 rtr
302 1.157 rtr static int
303 1.167 rtr COMPATNAME(route_bind)(struct socket *so, struct sockaddr *nam, struct lwp *l)
304 1.157 rtr {
305 1.157 rtr KASSERT(solocked(so));
306 1.157 rtr
307 1.157 rtr return EOPNOTSUPP;
308 1.157 rtr }
309 1.157 rtr
310 1.157 rtr static int
311 1.160 rtr COMPATNAME(route_listen)(struct socket *so, struct lwp *l)
312 1.157 rtr {
313 1.157 rtr KASSERT(solocked(so));
314 1.157 rtr
315 1.155 rtr return EOPNOTSUPP;
316 1.155 rtr }
317 1.155 rtr
318 1.155 rtr static int
319 1.171 rtr COMPATNAME(route_connect)(struct socket *so, struct sockaddr *nam, struct lwp *l)
320 1.158 rtr {
321 1.158 rtr KASSERT(solocked(so));
322 1.158 rtr
323 1.158 rtr return EOPNOTSUPP;
324 1.158 rtr }
325 1.158 rtr
326 1.158 rtr static int
327 1.163 rtr COMPATNAME(route_connect2)(struct socket *so, struct socket *so2)
328 1.163 rtr {
329 1.163 rtr KASSERT(solocked(so));
330 1.163 rtr
331 1.163 rtr return EOPNOTSUPP;
332 1.163 rtr }
333 1.163 rtr
334 1.163 rtr static int
335 1.159 rtr COMPATNAME(route_disconnect)(struct socket *so)
336 1.159 rtr {
337 1.159 rtr struct rawcb *rp = sotorawcb(so);
338 1.159 rtr int s;
339 1.159 rtr
340 1.159 rtr KASSERT(solocked(so));
341 1.159 rtr KASSERT(rp != NULL);
342 1.159 rtr
343 1.159 rtr s = splsoftnet();
344 1.159 rtr soisdisconnected(so);
345 1.159 rtr raw_disconnect(rp);
346 1.159 rtr splx(s);
347 1.159 rtr
348 1.159 rtr return 0;
349 1.159 rtr }
350 1.159 rtr
351 1.159 rtr static int
352 1.159 rtr COMPATNAME(route_shutdown)(struct socket *so)
353 1.159 rtr {
354 1.159 rtr int s;
355 1.159 rtr
356 1.159 rtr KASSERT(solocked(so));
357 1.159 rtr
358 1.159 rtr /*
359 1.159 rtr * Mark the connection as being incapable of further input.
360 1.159 rtr */
361 1.159 rtr s = splsoftnet();
362 1.159 rtr socantsendmore(so);
363 1.159 rtr splx(s);
364 1.159 rtr return 0;
365 1.159 rtr }
366 1.159 rtr
367 1.159 rtr static int
368 1.159 rtr COMPATNAME(route_abort)(struct socket *so)
369 1.159 rtr {
370 1.159 rtr KASSERT(solocked(so));
371 1.159 rtr
372 1.159 rtr panic("route_abort");
373 1.159 rtr
374 1.159 rtr return EOPNOTSUPP;
375 1.159 rtr }
376 1.159 rtr
377 1.159 rtr static int
378 1.149 rtr COMPATNAME(route_ioctl)(struct socket *so, u_long cmd, void *nam,
379 1.149 rtr struct ifnet * ifp)
380 1.148 rtr {
381 1.148 rtr return EOPNOTSUPP;
382 1.148 rtr }
383 1.148 rtr
384 1.148 rtr static int
385 1.150 rtr COMPATNAME(route_stat)(struct socket *so, struct stat *ub)
386 1.150 rtr {
387 1.153 rtr KASSERT(solocked(so));
388 1.153 rtr
389 1.152 rtr return 0;
390 1.150 rtr }
391 1.150 rtr
392 1.150 rtr static int
393 1.169 rtr COMPATNAME(route_peeraddr)(struct socket *so, struct sockaddr *nam)
394 1.154 rtr {
395 1.154 rtr struct rawcb *rp = sotorawcb(so);
396 1.154 rtr
397 1.154 rtr KASSERT(solocked(so));
398 1.154 rtr KASSERT(rp != NULL);
399 1.154 rtr KASSERT(nam != NULL);
400 1.154 rtr
401 1.154 rtr if (rp->rcb_faddr == NULL)
402 1.154 rtr return ENOTCONN;
403 1.154 rtr
404 1.154 rtr raw_setpeeraddr(rp, nam);
405 1.154 rtr return 0;
406 1.154 rtr }
407 1.154 rtr
408 1.154 rtr static int
409 1.169 rtr COMPATNAME(route_sockaddr)(struct socket *so, struct sockaddr *nam)
410 1.154 rtr {
411 1.154 rtr struct rawcb *rp = sotorawcb(so);
412 1.154 rtr
413 1.154 rtr KASSERT(solocked(so));
414 1.154 rtr KASSERT(rp != NULL);
415 1.154 rtr KASSERT(nam != NULL);
416 1.154 rtr
417 1.154 rtr if (rp->rcb_faddr == NULL)
418 1.154 rtr return ENOTCONN;
419 1.154 rtr
420 1.154 rtr raw_setsockaddr(rp, nam);
421 1.154 rtr return 0;
422 1.154 rtr }
423 1.154 rtr
424 1.154 rtr static int
425 1.162 rtr COMPATNAME(route_rcvd)(struct socket *so, int flags, struct lwp *l)
426 1.162 rtr {
427 1.162 rtr KASSERT(solocked(so));
428 1.162 rtr
429 1.162 rtr return EOPNOTSUPP;
430 1.162 rtr }
431 1.162 rtr
432 1.162 rtr static int
433 1.156 rtr COMPATNAME(route_recvoob)(struct socket *so, struct mbuf *m, int flags)
434 1.156 rtr {
435 1.156 rtr KASSERT(solocked(so));
436 1.156 rtr
437 1.156 rtr return EOPNOTSUPP;
438 1.156 rtr }
439 1.156 rtr
440 1.156 rtr static int
441 1.161 rtr COMPATNAME(route_send)(struct socket *so, struct mbuf *m,
442 1.171 rtr struct sockaddr *nam, struct mbuf *control, struct lwp *l)
443 1.161 rtr {
444 1.161 rtr int error = 0;
445 1.161 rtr int s;
446 1.161 rtr
447 1.161 rtr KASSERT(solocked(so));
448 1.175 riastrad KASSERT(so->so_proto == &COMPATNAME(route_protosw)[0]);
449 1.161 rtr
450 1.161 rtr s = splsoftnet();
451 1.175 riastrad error = raw_send(so, m, nam, control, l, &COMPATNAME(route_output));
452 1.161 rtr splx(s);
453 1.161 rtr
454 1.161 rtr return error;
455 1.161 rtr }
456 1.161 rtr
457 1.161 rtr static int
458 1.156 rtr COMPATNAME(route_sendoob)(struct socket *so, struct mbuf *m,
459 1.156 rtr struct mbuf *control)
460 1.156 rtr {
461 1.156 rtr KASSERT(solocked(so));
462 1.156 rtr
463 1.156 rtr m_freem(m);
464 1.156 rtr m_freem(control);
465 1.156 rtr
466 1.156 rtr return EOPNOTSUPP;
467 1.156 rtr }
468 1.163 rtr static int
469 1.163 rtr COMPATNAME(route_purgeif)(struct socket *so, struct ifnet *ifp)
470 1.163 rtr {
471 1.163 rtr
472 1.163 rtr panic("route_purgeif");
473 1.163 rtr
474 1.163 rtr return EOPNOTSUPP;
475 1.163 rtr }
476 1.156 rtr
477 1.222 ozaki #if defined(INET) || defined(INET6)
478 1.178 ozaki static int
479 1.178 ozaki route_get_sdl_index(struct rt_addrinfo *info, int *sdl_index)
480 1.178 ozaki {
481 1.178 ozaki struct rtentry *nrt;
482 1.178 ozaki int error;
483 1.178 ozaki
484 1.178 ozaki error = rtrequest1(RTM_GET, info, &nrt);
485 1.178 ozaki if (error != 0)
486 1.178 ozaki return error;
487 1.178 ozaki /*
488 1.178 ozaki * nrt->rt_ifp->if_index may not be correct
489 1.178 ozaki * due to changing to ifplo0.
490 1.178 ozaki */
491 1.178 ozaki *sdl_index = satosdl(nrt->rt_gateway)->sdl_index;
492 1.199 ozaki rt_unref(nrt);
493 1.178 ozaki
494 1.178 ozaki return 0;
495 1.178 ozaki }
496 1.222 ozaki #endif
497 1.178 ozaki
498 1.178 ozaki static void
499 1.178 ozaki route_get_sdl(const struct ifnet *ifp, const struct sockaddr *dst,
500 1.178 ozaki struct sockaddr_dl *sdl, int *flags)
501 1.178 ozaki {
502 1.181 christos struct llentry *la;
503 1.178 ozaki
504 1.178 ozaki KASSERT(ifp != NULL);
505 1.178 ozaki
506 1.178 ozaki IF_AFDATA_RLOCK(ifp);
507 1.178 ozaki switch (dst->sa_family) {
508 1.178 ozaki case AF_INET:
509 1.178 ozaki la = lla_lookup(LLTABLE(ifp), 0, dst);
510 1.178 ozaki break;
511 1.178 ozaki case AF_INET6:
512 1.178 ozaki la = lla_lookup(LLTABLE6(ifp), 0, dst);
513 1.178 ozaki break;
514 1.178 ozaki default:
515 1.181 christos la = NULL;
516 1.178 ozaki KASSERTMSG(0, "Invalid AF=%d\n", dst->sa_family);
517 1.178 ozaki break;
518 1.178 ozaki }
519 1.178 ozaki IF_AFDATA_RUNLOCK(ifp);
520 1.178 ozaki
521 1.181 christos void *a = (LLE_IS_VALID(la) && (la->la_flags & LLE_VALID) == LLE_VALID)
522 1.181 christos ? &la->ll_addr : NULL;
523 1.181 christos
524 1.181 christos a = sockaddr_dl_init(sdl, sizeof(*sdl), ifp->if_index, ifp->if_type,
525 1.182 christos NULL, 0, a, ifp->if_addrlen);
526 1.181 christos KASSERT(a != NULL);
527 1.178 ozaki
528 1.178 ozaki if (la != NULL) {
529 1.178 ozaki *flags = la->la_flags;
530 1.178 ozaki LLE_RUNLOCK(la);
531 1.178 ozaki }
532 1.178 ozaki }
533 1.178 ozaki
534 1.187 ozaki static int
535 1.187 ozaki route_output_report(struct rtentry *rt, struct rt_addrinfo *info,
536 1.187 ozaki struct rt_xmsghdr *rtm, struct rt_xmsghdr **new_rtm)
537 1.187 ozaki {
538 1.187 ozaki int len;
539 1.187 ozaki
540 1.214 ozaki if (rtm->rtm_addrs & (RTA_IFP | RTA_IFA)) {
541 1.187 ozaki const struct ifaddr *rtifa;
542 1.214 ozaki const struct ifnet *ifp = rt->rt_ifp;
543 1.214 ozaki
544 1.187 ozaki info->rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
545 1.187 ozaki /* rtifa used to be simply rt->rt_ifa.
546 1.187 ozaki * If rt->rt_ifa != NULL, then
547 1.187 ozaki * rt_get_ifa() != NULL. So this
548 1.187 ozaki * ought to still be safe. --dyoung
549 1.187 ozaki */
550 1.187 ozaki rtifa = rt_get_ifa(rt);
551 1.187 ozaki info->rti_info[RTAX_IFA] = rtifa->ifa_addr;
552 1.187 ozaki #ifdef RTSOCK_DEBUG
553 1.187 ozaki if (info->rti_info[RTAX_IFA]->sa_family == AF_INET) {
554 1.187 ozaki char ibuf[INET_ADDRSTRLEN];
555 1.187 ozaki char abuf[INET_ADDRSTRLEN];
556 1.187 ozaki printf("%s: copying out RTAX_IFA %s "
557 1.187 ozaki "for info->rti_info[RTAX_DST] %s "
558 1.187 ozaki "ifa_getifa %p ifa_seqno %p\n",
559 1.187 ozaki __func__,
560 1.188 ozaki RT_IN_PRINT(info, ibuf, RTAX_IFA),
561 1.188 ozaki RT_IN_PRINT(info, abuf, RTAX_DST),
562 1.187 ozaki (void *)rtifa->ifa_getifa,
563 1.187 ozaki rtifa->ifa_seqno);
564 1.187 ozaki }
565 1.187 ozaki #endif /* RTSOCK_DEBUG */
566 1.187 ozaki if (ifp->if_flags & IFF_POINTOPOINT)
567 1.187 ozaki info->rti_info[RTAX_BRD] = rtifa->ifa_dstaddr;
568 1.187 ozaki else
569 1.187 ozaki info->rti_info[RTAX_BRD] = NULL;
570 1.187 ozaki rtm->rtm_index = ifp->if_index;
571 1.187 ozaki }
572 1.187 ozaki (void)rt_msg2(rtm->rtm_type, info, NULL, NULL, &len);
573 1.187 ozaki if (len > rtm->rtm_msglen) {
574 1.187 ozaki struct rt_xmsghdr *old_rtm = rtm;
575 1.187 ozaki R_Malloc(*new_rtm, struct rt_xmsghdr *, len);
576 1.187 ozaki if (*new_rtm == NULL)
577 1.187 ozaki return ENOBUFS;
578 1.187 ozaki (void)memcpy(*new_rtm, old_rtm, old_rtm->rtm_msglen);
579 1.187 ozaki rtm = *new_rtm;
580 1.187 ozaki }
581 1.187 ozaki (void)rt_msg2(rtm->rtm_type, info, rtm, NULL, 0);
582 1.187 ozaki rtm->rtm_flags = rt->rt_flags;
583 1.187 ozaki rtm_setmetrics(rt, rtm);
584 1.187 ozaki rtm->rtm_addrs = info->rti_addrs;
585 1.187 ozaki
586 1.187 ozaki return 0;
587 1.187 ozaki }
588 1.187 ozaki
589 1.192 ozaki static struct ifaddr *
590 1.192 ozaki route_output_get_ifa(const struct rt_addrinfo info, const struct rtentry *rt,
591 1.194 ozaki struct ifnet **ifp, struct psref *psref)
592 1.192 ozaki {
593 1.192 ozaki struct ifaddr *ifa = NULL;
594 1.192 ozaki
595 1.192 ozaki *ifp = NULL;
596 1.192 ozaki if (info.rti_info[RTAX_IFP] != NULL) {
597 1.194 ozaki ifa = ifa_ifwithnet_psref(info.rti_info[RTAX_IFP], psref);
598 1.192 ozaki if (ifa == NULL)
599 1.192 ozaki goto next;
600 1.192 ozaki *ifp = ifa->ifa_ifp;
601 1.192 ozaki if (info.rti_info[RTAX_IFA] == NULL &&
602 1.192 ozaki info.rti_info[RTAX_GATEWAY] == NULL)
603 1.192 ozaki goto next;
604 1.192 ozaki if (info.rti_info[RTAX_IFA] == NULL) {
605 1.192 ozaki /* route change <dst> <gw> -ifp <if> */
606 1.194 ozaki ifa = ifaof_ifpforaddr_psref(info.rti_info[RTAX_GATEWAY],
607 1.194 ozaki *ifp, psref);
608 1.192 ozaki } else {
609 1.192 ozaki /* route change <dst> -ifp <if> -ifa <addr> */
610 1.194 ozaki ifa = ifa_ifwithaddr_psref(info.rti_info[RTAX_IFA], psref);
611 1.192 ozaki if (ifa != NULL)
612 1.192 ozaki goto out;
613 1.194 ozaki ifa = ifaof_ifpforaddr_psref(info.rti_info[RTAX_IFA],
614 1.194 ozaki *ifp, psref);
615 1.192 ozaki }
616 1.192 ozaki goto out;
617 1.192 ozaki }
618 1.192 ozaki next:
619 1.192 ozaki if (info.rti_info[RTAX_IFA] != NULL) {
620 1.192 ozaki /* route change <dst> <gw> -ifa <addr> */
621 1.194 ozaki ifa = ifa_ifwithaddr_psref(info.rti_info[RTAX_IFA], psref);
622 1.192 ozaki if (ifa != NULL)
623 1.192 ozaki goto out;
624 1.192 ozaki }
625 1.192 ozaki if (info.rti_info[RTAX_GATEWAY] != NULL) {
626 1.192 ozaki /* route change <dst> <gw> */
627 1.194 ozaki ifa = ifa_ifwithroute_psref(rt->rt_flags, rt_getkey(rt),
628 1.194 ozaki info.rti_info[RTAX_GATEWAY], psref);
629 1.192 ozaki }
630 1.192 ozaki out:
631 1.192 ozaki if (ifa != NULL && *ifp == NULL)
632 1.192 ozaki *ifp = ifa->ifa_ifp;
633 1.192 ozaki return ifa;
634 1.192 ozaki }
635 1.192 ozaki
636 1.198 ozaki static int
637 1.198 ozaki route_output_change(struct rtentry *rt, struct rt_addrinfo *info,
638 1.198 ozaki struct rt_xmsghdr *rtm)
639 1.198 ozaki {
640 1.198 ozaki int error = 0;
641 1.211 ozaki struct ifnet *ifp = NULL, *new_ifp;
642 1.211 ozaki struct ifaddr *ifa = NULL, *new_ifa;
643 1.198 ozaki struct psref psref_ifa, psref_new_ifa, psref_ifp;
644 1.217 ozaki bool newgw, ifp_changed = false;
645 1.198 ozaki
646 1.198 ozaki /*
647 1.210 ozaki * New gateway could require new ifaddr, ifp;
648 1.198 ozaki * flags may also be different; ifp may be specified
649 1.198 ozaki * by ll sockaddr when protocol address is ambiguous
650 1.198 ozaki */
651 1.211 ozaki newgw = info->rti_info[RTAX_GATEWAY] != NULL &&
652 1.211 ozaki sockaddr_cmp(info->rti_info[RTAX_GATEWAY], rt->rt_gateway) != 0;
653 1.211 ozaki
654 1.211 ozaki if (newgw || info->rti_info[RTAX_IFP] != NULL ||
655 1.211 ozaki info->rti_info[RTAX_IFA] != NULL) {
656 1.211 ozaki ifp = rt_getifp(info, &psref_ifp);
657 1.211 ozaki ifa = rt_getifa(info, &psref_ifa);
658 1.211 ozaki if (ifa == NULL) {
659 1.211 ozaki error = ENETUNREACH;
660 1.211 ozaki goto out;
661 1.211 ozaki }
662 1.198 ozaki }
663 1.211 ozaki if (newgw) {
664 1.198 ozaki error = rt_setgate(rt, info->rti_info[RTAX_GATEWAY]);
665 1.198 ozaki if (error != 0)
666 1.198 ozaki goto out;
667 1.198 ozaki }
668 1.198 ozaki if (info->rti_info[RTAX_TAG]) {
669 1.198 ozaki const struct sockaddr *tag;
670 1.198 ozaki tag = rt_settag(rt, info->rti_info[RTAX_TAG]);
671 1.198 ozaki if (tag == NULL) {
672 1.198 ozaki error = ENOBUFS;
673 1.198 ozaki goto out;
674 1.198 ozaki }
675 1.198 ozaki }
676 1.210 ozaki /*
677 1.210 ozaki * New gateway could require new ifaddr, ifp;
678 1.210 ozaki * flags may also be different; ifp may be specified
679 1.210 ozaki * by ll sockaddr when protocol address is ambiguous
680 1.210 ozaki */
681 1.198 ozaki new_ifa = route_output_get_ifa(*info, rt, &new_ifp, &psref_new_ifa);
682 1.198 ozaki if (new_ifa != NULL) {
683 1.198 ozaki ifa_release(ifa, &psref_ifa);
684 1.198 ozaki ifa = new_ifa;
685 1.198 ozaki }
686 1.198 ozaki if (ifa) {
687 1.198 ozaki struct ifaddr *oifa = rt->rt_ifa;
688 1.209 ozaki if (oifa != ifa && !ifa_is_destroying(ifa) &&
689 1.209 ozaki new_ifp != NULL && !if_is_deactivated(new_ifp)) {
690 1.198 ozaki if (oifa && oifa->ifa_rtrequest)
691 1.198 ozaki oifa->ifa_rtrequest(RTM_DELETE, rt, info);
692 1.198 ozaki rt_replace_ifa(rt, ifa);
693 1.198 ozaki rt->rt_ifp = new_ifp;
694 1.217 ozaki ifp_changed = true;
695 1.198 ozaki }
696 1.198 ozaki if (new_ifa == NULL)
697 1.198 ozaki ifa_release(ifa, &psref_ifa);
698 1.198 ozaki }
699 1.198 ozaki ifa_release(new_ifa, &psref_new_ifa);
700 1.217 ozaki if (new_ifp && rt->rt_ifp != new_ifp && !if_is_deactivated(new_ifp)) {
701 1.198 ozaki rt->rt_ifp = new_ifp;
702 1.217 ozaki ifp_changed = true;
703 1.217 ozaki }
704 1.198 ozaki rt_setmetrics(rtm->rtm_inits, rtm, rt);
705 1.210 ozaki if (rt->rt_flags != info->rti_flags) {
706 1.210 ozaki rt->rt_flags = (info->rti_flags & ~PRESERVED_RTF) |
707 1.210 ozaki (rt->rt_flags & PRESERVED_RTF);
708 1.210 ozaki }
709 1.198 ozaki if (rt->rt_ifa && rt->rt_ifa->ifa_rtrequest)
710 1.198 ozaki rt->rt_ifa->ifa_rtrequest(RTM_ADD, rt, info);
711 1.217 ozaki #if defined(INET) || defined(INET6)
712 1.217 ozaki if (ifp_changed && rt_mask(rt) != NULL)
713 1.217 ozaki lltable_prefix_free(rt_getkey(rt)->sa_family, rt_getkey(rt),
714 1.217 ozaki rt_mask(rt), 0);
715 1.218 ozaki #else
716 1.218 ozaki (void)ifp_changed; /* XXX gcc */
717 1.217 ozaki #endif
718 1.198 ozaki out:
719 1.198 ozaki if_put(ifp, &psref_ifp);
720 1.198 ozaki
721 1.198 ozaki return error;
722 1.198 ozaki }
723 1.198 ozaki
724 1.226 christos static socklen_t
725 1.226 christos sa_addrlen(const struct sockaddr *sa)
726 1.226 christos {
727 1.226 christos
728 1.226 christos switch (sa->sa_family) {
729 1.226 christos #ifdef INET
730 1.226 christos case AF_INET:
731 1.226 christos return sizeof(struct sockaddr_in);
732 1.226 christos #endif
733 1.226 christos #ifdef INET6
734 1.226 christos case AF_INET6:
735 1.226 christos return sizeof(struct sockaddr_in6);
736 1.226 christos #endif
737 1.226 christos default:
738 1.226 christos return 0;
739 1.226 christos }
740 1.226 christos }
741 1.226 christos
742 1.1 cgd /*ARGSUSED*/
743 1.9 mycroft int
744 1.175 riastrad COMPATNAME(route_output)(struct mbuf *m, struct socket *so)
745 1.1 cgd {
746 1.133 matt struct sockproto proto = { .sp_family = PF_XROUTE, };
747 1.133 matt struct rt_xmsghdr *rtm = NULL;
748 1.187 ozaki struct rt_xmsghdr *old_rtm = NULL, *new_rtm = NULL;
749 1.95 dyoung struct rtentry *rt = NULL;
750 1.95 dyoung struct rtentry *saved_nrt = NULL;
751 1.10 mycroft struct rt_addrinfo info;
752 1.124 roy int len, error = 0;
753 1.55 christos sa_family_t family;
754 1.178 ozaki struct sockaddr_dl sdl;
755 1.194 ozaki int bound = curlwp_bind();
756 1.199 ozaki bool do_rt_free = false;
757 1.226 christos struct sockaddr_storage netmask;
758 1.17 christos
759 1.56 perry #define senderr(e) do { error = e; goto flush;} while (/*CONSTCOND*/ 0)
760 1.95 dyoung if (m == NULL || ((m->m_len < sizeof(int32_t)) &&
761 1.194 ozaki (m = m_pullup(m, sizeof(int32_t))) == NULL)) {
762 1.194 ozaki error = ENOBUFS;
763 1.194 ozaki goto out;
764 1.194 ozaki }
765 1.1 cgd if ((m->m_flags & M_PKTHDR) == 0)
766 1.133 matt panic("%s", __func__);
767 1.1 cgd len = m->m_pkthdr.len;
768 1.1 cgd if (len < sizeof(*rtm) ||
769 1.133 matt len != mtod(m, struct rt_xmsghdr *)->rtm_msglen) {
770 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
771 1.1 cgd senderr(EINVAL);
772 1.10 mycroft }
773 1.133 matt R_Malloc(rtm, struct rt_xmsghdr *, len);
774 1.95 dyoung if (rtm == NULL) {
775 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
776 1.1 cgd senderr(ENOBUFS);
777 1.10 mycroft }
778 1.112 dyoung m_copydata(m, 0, len, rtm);
779 1.133 matt if (rtm->rtm_version != RTM_XVERSION) {
780 1.114 dyoung info.rti_info[RTAX_DST] = NULL;
781 1.1 cgd senderr(EPROTONOSUPPORT);
782 1.10 mycroft }
783 1.1 cgd rtm->rtm_pid = curproc->p_pid;
784 1.48 thorpej memset(&info, 0, sizeof(info));
785 1.10 mycroft info.rti_addrs = rtm->rtm_addrs;
786 1.112 dyoung if (rt_xaddrs(rtm->rtm_type, (const char *)(rtm + 1), len + (char *)rtm,
787 1.133 matt &info)) {
788 1.42 erh senderr(EINVAL);
789 1.133 matt }
790 1.45 itojun info.rti_flags = rtm->rtm_flags;
791 1.91 dyoung #ifdef RTSOCK_DEBUG
792 1.114 dyoung if (info.rti_info[RTAX_DST]->sa_family == AF_INET) {
793 1.165 christos char abuf[INET_ADDRSTRLEN];
794 1.114 dyoung printf("%s: extracted info.rti_info[RTAX_DST] %s\n", __func__,
795 1.188 ozaki RT_IN_PRINT(&info, abuf, RTAX_DST));
796 1.91 dyoung }
797 1.91 dyoung #endif /* RTSOCK_DEBUG */
798 1.115 christos if (info.rti_info[RTAX_DST] == NULL ||
799 1.133 matt (info.rti_info[RTAX_DST]->sa_family >= AF_MAX)) {
800 1.26 fvdl senderr(EINVAL);
801 1.133 matt }
802 1.115 christos if (info.rti_info[RTAX_GATEWAY] != NULL &&
803 1.133 matt (info.rti_info[RTAX_GATEWAY]->sa_family >= AF_MAX)) {
804 1.1 cgd senderr(EINVAL);
805 1.133 matt }
806 1.23 thorpej
807 1.23 thorpej /*
808 1.23 thorpej * Verify that the caller has the appropriate privilege; RTM_GET
809 1.23 thorpej * is the only operation the non-superuser is allowed.
810 1.23 thorpej */
811 1.88 elad if (kauth_authorize_network(curlwp->l_cred, KAUTH_NETWORK_ROUTE,
812 1.89 elad 0, rtm, NULL, NULL) != 0)
813 1.23 thorpej senderr(EACCES);
814 1.23 thorpej
815 1.225 ozaki /*
816 1.225 ozaki * route(8) passes a sockaddr truncated with prefixlen.
817 1.226 christos * The kernel doesn't expect such sockaddr and need to
818 1.226 christos * use a buffer that is big enough for the sockaddr expected
819 1.226 christos * (padded with 0's). We keep the original length of the sockaddr.
820 1.225 ozaki */
821 1.225 ozaki if (info.rti_info[RTAX_NETMASK]) {
822 1.226 christos socklen_t sa_len = sa_addrlen(info.rti_info[RTAX_NETMASK]);
823 1.226 christos socklen_t masklen = info.rti_info[RTAX_NETMASK]->sa_len;
824 1.226 christos if (sa_len != 0 && sa_len > masklen) {
825 1.226 christos KASSERT(sa_len <= sizeof(netmask));
826 1.226 christos memcpy(&netmask, info.rti_info[RTAX_NETMASK], masklen);
827 1.226 christos memset((char *)&netmask + masklen, 0, sa_len - masklen);
828 1.226 christos info.rti_info[RTAX_NETMASK] = sstocsa(&netmask);
829 1.225 ozaki }
830 1.225 ozaki }
831 1.225 ozaki
832 1.1 cgd switch (rtm->rtm_type) {
833 1.10 mycroft
834 1.1 cgd case RTM_ADD:
835 1.133 matt if (info.rti_info[RTAX_GATEWAY] == NULL) {
836 1.1 cgd senderr(EINVAL);
837 1.133 matt }
838 1.222 ozaki #if defined(INET) || defined(INET6)
839 1.222 ozaki /* support for new ARP/NDP code with keeping backcompat */
840 1.178 ozaki if (info.rti_info[RTAX_GATEWAY]->sa_family == AF_LINK) {
841 1.180 christos const struct sockaddr_dl *sdlp =
842 1.180 christos satocsdl(info.rti_info[RTAX_GATEWAY]);
843 1.178 ozaki
844 1.180 christos /* Allow routing requests by interface index */
845 1.180 christos if (sdlp->sdl_nlen == 0 && sdlp->sdl_alen == 0
846 1.180 christos && sdlp->sdl_slen == 0)
847 1.180 christos goto fallback;
848 1.178 ozaki /*
849 1.178 ozaki * Old arp binaries don't set the sdl_index
850 1.178 ozaki * so we have to complement it.
851 1.178 ozaki */
852 1.180 christos int sdl_index = sdlp->sdl_index;
853 1.178 ozaki if (sdl_index == 0) {
854 1.178 ozaki error = route_get_sdl_index(&info, &sdl_index);
855 1.178 ozaki if (error != 0)
856 1.178 ozaki goto fallback;
857 1.178 ozaki } else if (
858 1.178 ozaki info.rti_info[RTAX_DST]->sa_family == AF_INET) {
859 1.178 ozaki /*
860 1.178 ozaki * XXX workaround for SIN_PROXY case; proxy arp
861 1.178 ozaki * entry should be in an interface that has
862 1.178 ozaki * a network route including the destination,
863 1.178 ozaki * not a local (link) route that may not be a
864 1.178 ozaki * desired place, for example a tap.
865 1.178 ozaki */
866 1.178 ozaki const struct sockaddr_inarp *sina =
867 1.178 ozaki (const struct sockaddr_inarp *)
868 1.178 ozaki info.rti_info[RTAX_DST];
869 1.178 ozaki if (sina->sin_other & SIN_PROXY) {
870 1.178 ozaki error = route_get_sdl_index(&info,
871 1.178 ozaki &sdl_index);
872 1.178 ozaki if (error != 0)
873 1.178 ozaki goto fallback;
874 1.178 ozaki }
875 1.178 ozaki }
876 1.178 ozaki error = lla_rt_output(rtm->rtm_type, rtm->rtm_flags,
877 1.178 ozaki rtm->rtm_rmx.rmx_expire, &info, sdl_index);
878 1.178 ozaki break;
879 1.178 ozaki }
880 1.178 ozaki fallback:
881 1.222 ozaki #endif /* defined(INET) || defined(INET6) */
882 1.45 itojun error = rtrequest1(rtm->rtm_type, &info, &saved_nrt);
883 1.172 ozaki if (error == 0) {
884 1.133 matt rt_setmetrics(rtm->rtm_inits, rtm, saved_nrt);
885 1.199 ozaki rt_unref(saved_nrt);
886 1.1 cgd }
887 1.1 cgd break;
888 1.1 cgd
889 1.1 cgd case RTM_DELETE:
890 1.222 ozaki #if defined(INET) || defined(INET6)
891 1.222 ozaki /* support for new ARP/NDP code */
892 1.178 ozaki if (info.rti_info[RTAX_GATEWAY] &&
893 1.178 ozaki (info.rti_info[RTAX_GATEWAY]->sa_family == AF_LINK) &&
894 1.178 ozaki (rtm->rtm_flags & RTF_LLDATA) != 0) {
895 1.220 ozaki const struct sockaddr_dl *sdlp =
896 1.220 ozaki satocsdl(info.rti_info[RTAX_GATEWAY]);
897 1.178 ozaki error = lla_rt_output(rtm->rtm_type, rtm->rtm_flags,
898 1.220 ozaki rtm->rtm_rmx.rmx_expire, &info, sdlp->sdl_index);
899 1.223 ozaki rtm->rtm_flags &= ~RTF_UP;
900 1.178 ozaki break;
901 1.178 ozaki }
902 1.222 ozaki #endif
903 1.45 itojun error = rtrequest1(rtm->rtm_type, &info, &saved_nrt);
904 1.187 ozaki if (error != 0)
905 1.187 ozaki break;
906 1.187 ozaki
907 1.187 ozaki rt = saved_nrt;
908 1.199 ozaki do_rt_free = true;
909 1.187 ozaki info.rti_info[RTAX_DST] = rt_getkey(rt);
910 1.187 ozaki info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
911 1.187 ozaki info.rti_info[RTAX_NETMASK] = rt_mask(rt);
912 1.187 ozaki info.rti_info[RTAX_TAG] = rt_gettag(rt);
913 1.187 ozaki error = route_output_report(rt, &info, rtm, &new_rtm);
914 1.187 ozaki if (error)
915 1.187 ozaki senderr(error);
916 1.187 ozaki if (new_rtm != NULL) {
917 1.187 ozaki old_rtm = rtm;
918 1.187 ozaki rtm = new_rtm;
919 1.16 cgd }
920 1.1 cgd break;
921 1.1 cgd
922 1.1 cgd case RTM_GET:
923 1.1 cgd case RTM_CHANGE:
924 1.1 cgd case RTM_LOCK:
925 1.115 christos /* XXX This will mask info.rti_info[RTAX_DST] with
926 1.115 christos * info.rti_info[RTAX_NETMASK] before
927 1.95 dyoung * searching. It did not used to do that. --dyoung
928 1.95 dyoung */
929 1.172 ozaki rt = NULL;
930 1.103 dyoung error = rtrequest1(RTM_GET, &info, &rt);
931 1.95 dyoung if (error != 0)
932 1.95 dyoung senderr(error);
933 1.61 itojun if (rtm->rtm_type != RTM_GET) {/* XXX: too grotty */
934 1.115 christos if (memcmp(info.rti_info[RTAX_DST], rt_getkey(rt),
935 1.115 christos info.rti_info[RTAX_DST]->sa_len) != 0)
936 1.61 itojun senderr(ESRCH);
937 1.135 dyoung if (info.rti_info[RTAX_NETMASK] == NULL &&
938 1.135 dyoung rt_mask(rt) != NULL)
939 1.61 itojun senderr(ETOOMANYREFS);
940 1.61 itojun }
941 1.37 itojun
942 1.178 ozaki /*
943 1.178 ozaki * XXX if arp/ndp requests an L2 entry, we have to obtain
944 1.178 ozaki * it from lltable while for the route command we have to
945 1.178 ozaki * return a route as it is. How to distinguish them?
946 1.178 ozaki * For newer arp/ndp, RTF_LLDATA flag set by arp/ndp
947 1.178 ozaki * indicates an L2 entry is requested. For old arp/ndp
948 1.178 ozaki * binaries, we check RTF_UP flag is NOT set; it works
949 1.178 ozaki * by the fact that arp/ndp don't set it while the route
950 1.178 ozaki * command sets it.
951 1.178 ozaki */
952 1.178 ozaki if (((rtm->rtm_flags & RTF_LLDATA) != 0 ||
953 1.178 ozaki (rtm->rtm_flags & RTF_UP) == 0) &&
954 1.178 ozaki rtm->rtm_type == RTM_GET &&
955 1.178 ozaki sockaddr_cmp(rt_getkey(rt), info.rti_info[RTAX_DST]) != 0) {
956 1.187 ozaki int ll_flags = 0;
957 1.178 ozaki route_get_sdl(rt->rt_ifp, info.rti_info[RTAX_DST], &sdl,
958 1.178 ozaki &ll_flags);
959 1.178 ozaki info.rti_info[RTAX_GATEWAY] = sstocsa(&sdl);
960 1.187 ozaki error = route_output_report(rt, &info, rtm, &new_rtm);
961 1.187 ozaki if (error)
962 1.187 ozaki senderr(error);
963 1.187 ozaki if (new_rtm != NULL) {
964 1.187 ozaki old_rtm = rtm;
965 1.187 ozaki rtm = new_rtm;
966 1.187 ozaki }
967 1.187 ozaki rtm->rtm_flags |= RTF_LLDATA;
968 1.216 ozaki rtm->rtm_flags &= ~RTF_CONNECTED;
969 1.187 ozaki rtm->rtm_flags |= (ll_flags & LLE_STATIC) ? RTF_STATIC : 0;
970 1.187 ozaki break;
971 1.178 ozaki }
972 1.178 ozaki
973 1.59 itojun switch (rtm->rtm_type) {
974 1.1 cgd case RTM_GET:
975 1.114 dyoung info.rti_info[RTAX_DST] = rt_getkey(rt);
976 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
977 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
978 1.137 yamt info.rti_info[RTAX_TAG] = rt_gettag(rt);
979 1.187 ozaki error = route_output_report(rt, &info, rtm, &new_rtm);
980 1.187 ozaki if (error)
981 1.187 ozaki senderr(error);
982 1.187 ozaki if (new_rtm != NULL) {
983 1.117 christos old_rtm = rtm;
984 1.187 ozaki rtm = new_rtm;
985 1.178 ozaki }
986 1.1 cgd break;
987 1.1 cgd
988 1.198 ozaki case RTM_CHANGE:
989 1.200 ozaki #ifdef NET_MPSAFE
990 1.199 ozaki error = rt_update_prepare(rt);
991 1.199 ozaki if (error == 0) {
992 1.199 ozaki error = route_output_change(rt, &info, rtm);
993 1.199 ozaki rt_update_finish(rt);
994 1.199 ozaki }
995 1.200 ozaki #else
996 1.200 ozaki error = route_output_change(rt, &info, rtm);
997 1.200 ozaki #endif
998 1.198 ozaki if (error != 0)
999 1.198 ozaki goto flush;
1000 1.115 christos /*FALLTHROUGH*/
1001 1.1 cgd case RTM_LOCK:
1002 1.10 mycroft rt->rt_rmx.rmx_locks &= ~(rtm->rtm_inits);
1003 1.1 cgd rt->rt_rmx.rmx_locks |=
1004 1.21 christos (rtm->rtm_inits & rtm->rtm_rmx.rmx_locks);
1005 1.1 cgd break;
1006 1.1 cgd }
1007 1.10 mycroft break;
1008 1.1 cgd
1009 1.1 cgd default:
1010 1.1 cgd senderr(EOPNOTSUPP);
1011 1.1 cgd }
1012 1.1 cgd
1013 1.1 cgd flush:
1014 1.1 cgd if (rtm) {
1015 1.1 cgd if (error)
1016 1.1 cgd rtm->rtm_errno = error;
1017 1.75 perry else
1018 1.1 cgd rtm->rtm_flags |= RTF_DONE;
1019 1.1 cgd }
1020 1.115 christos family = info.rti_info[RTAX_DST] ? info.rti_info[RTAX_DST]->sa_family :
1021 1.115 christos 0;
1022 1.117 christos /* We cannot free old_rtm until we have stopped using the
1023 1.117 christos * pointers in info, some of which may point to sockaddrs
1024 1.117 christos * in old_rtm.
1025 1.117 christos */
1026 1.117 christos if (old_rtm != NULL)
1027 1.117 christos Free(old_rtm);
1028 1.199 ozaki if (rt) {
1029 1.199 ozaki if (do_rt_free)
1030 1.199 ozaki rt_free(rt);
1031 1.199 ozaki else
1032 1.199 ozaki rt_unref(rt);
1033 1.199 ozaki }
1034 1.1 cgd {
1035 1.95 dyoung struct rawcb *rp = NULL;
1036 1.1 cgd /*
1037 1.1 cgd * Check to see if we don't want our own messages.
1038 1.1 cgd */
1039 1.1 cgd if ((so->so_options & SO_USELOOPBACK) == 0) {
1040 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count <= 1) {
1041 1.1 cgd if (rtm)
1042 1.1 cgd Free(rtm);
1043 1.1 cgd m_freem(m);
1044 1.194 ozaki goto out;
1045 1.1 cgd }
1046 1.1 cgd /* There is another listener, so construct message */
1047 1.1 cgd rp = sotorawcb(so);
1048 1.1 cgd }
1049 1.1 cgd if (rtm) {
1050 1.112 dyoung m_copyback(m, 0, rtm->rtm_msglen, rtm);
1051 1.47 itojun if (m->m_pkthdr.len < rtm->rtm_msglen) {
1052 1.46 itojun m_freem(m);
1053 1.46 itojun m = NULL;
1054 1.47 itojun } else if (m->m_pkthdr.len > rtm->rtm_msglen)
1055 1.46 itojun m_adj(m, rtm->rtm_msglen - m->m_pkthdr.len);
1056 1.1 cgd Free(rtm);
1057 1.1 cgd }
1058 1.1 cgd if (rp)
1059 1.1 cgd rp->rcb_proto.sp_family = 0; /* Avoid us */
1060 1.55 christos if (family)
1061 1.99 ad proto.sp_protocol = family;
1062 1.46 itojun if (m)
1063 1.133 matt raw_input(m, &proto, &COMPATNAME(route_info).ri_src,
1064 1.133 matt &COMPATNAME(route_info).ri_dst);
1065 1.1 cgd if (rp)
1066 1.133 matt rp->rcb_proto.sp_family = PF_XROUTE;
1067 1.1 cgd }
1068 1.194 ozaki out:
1069 1.194 ozaki curlwp_bindx(bound);
1070 1.95 dyoung return error;
1071 1.1 cgd }
1072 1.1 cgd
1073 1.212 roy static int
1074 1.212 roy route_ctloutput(int op, struct socket *so, struct sockopt *sopt)
1075 1.212 roy {
1076 1.212 roy struct routecb *rop = sotoroutecb(so);
1077 1.212 roy int error = 0;
1078 1.212 roy unsigned char *rtm_type;
1079 1.212 roy size_t len;
1080 1.212 roy unsigned int msgfilter;
1081 1.212 roy
1082 1.212 roy KASSERT(solocked(so));
1083 1.212 roy
1084 1.212 roy if (sopt->sopt_level != AF_ROUTE) {
1085 1.212 roy error = ENOPROTOOPT;
1086 1.212 roy } else switch (op) {
1087 1.212 roy case PRCO_SETOPT:
1088 1.212 roy switch (sopt->sopt_name) {
1089 1.212 roy case RO_MSGFILTER:
1090 1.212 roy msgfilter = 0;
1091 1.212 roy for (rtm_type = sopt->sopt_data, len = sopt->sopt_size;
1092 1.212 roy len != 0;
1093 1.212 roy rtm_type++, len -= sizeof(*rtm_type))
1094 1.212 roy {
1095 1.212 roy /* Guard against overflowing our storage. */
1096 1.212 roy if (*rtm_type >= sizeof(msgfilter) * CHAR_BIT) {
1097 1.212 roy error = EOVERFLOW;
1098 1.212 roy break;
1099 1.212 roy }
1100 1.212 roy msgfilter |= RTMSGFILTER(*rtm_type);
1101 1.212 roy }
1102 1.212 roy if (error == 0)
1103 1.212 roy rop->rocb_msgfilter = msgfilter;
1104 1.212 roy break;
1105 1.212 roy default:
1106 1.212 roy error = ENOPROTOOPT;
1107 1.212 roy break;
1108 1.212 roy }
1109 1.212 roy break;
1110 1.212 roy case PRCO_GETOPT:
1111 1.212 roy switch (sopt->sopt_name) {
1112 1.212 roy case RO_MSGFILTER:
1113 1.212 roy error = ENOTSUP;
1114 1.212 roy break;
1115 1.212 roy default:
1116 1.212 roy error = ENOPROTOOPT;
1117 1.212 roy break;
1118 1.212 roy }
1119 1.212 roy }
1120 1.212 roy return error;
1121 1.212 roy }
1122 1.212 roy
1123 1.133 matt static void
1124 1.133 matt rt_setmetrics(int which, const struct rt_xmsghdr *in, struct rtentry *out)
1125 1.1 cgd {
1126 1.133 matt #define metric(f, e) if (which & (f)) out->rt_rmx.e = in->rtm_rmx.e;
1127 1.1 cgd metric(RTV_RPIPE, rmx_recvpipe);
1128 1.1 cgd metric(RTV_SPIPE, rmx_sendpipe);
1129 1.1 cgd metric(RTV_SSTHRESH, rmx_ssthresh);
1130 1.1 cgd metric(RTV_RTT, rmx_rtt);
1131 1.1 cgd metric(RTV_RTTVAR, rmx_rttvar);
1132 1.1 cgd metric(RTV_HOPCOUNT, rmx_hopcount);
1133 1.1 cgd metric(RTV_MTU, rmx_mtu);
1134 1.1 cgd #undef metric
1135 1.173 ozaki if (which & RTV_EXPIRE) {
1136 1.173 ozaki out->rt_rmx.rmx_expire = in->rtm_rmx.rmx_expire ?
1137 1.173 ozaki time_wall_to_mono(in->rtm_rmx.rmx_expire) : 0;
1138 1.173 ozaki }
1139 1.1 cgd }
1140 1.1 cgd
1141 1.133 matt static void
1142 1.133 matt rtm_setmetrics(const struct rtentry *in, struct rt_xmsghdr *out)
1143 1.133 matt {
1144 1.133 matt #define metric(e) out->rtm_rmx.e = in->rt_rmx.e;
1145 1.133 matt metric(rmx_recvpipe);
1146 1.133 matt metric(rmx_sendpipe);
1147 1.133 matt metric(rmx_ssthresh);
1148 1.133 matt metric(rmx_rtt);
1149 1.133 matt metric(rmx_rttvar);
1150 1.133 matt metric(rmx_hopcount);
1151 1.133 matt metric(rmx_mtu);
1152 1.201 ozaki metric(rmx_locks);
1153 1.133 matt #undef metric
1154 1.173 ozaki out->rtm_rmx.rmx_expire = in->rt_rmx.rmx_expire ?
1155 1.173 ozaki time_mono_to_wall(in->rt_rmx.rmx_expire) : 0;
1156 1.133 matt }
1157 1.133 matt
1158 1.42 erh static int
1159 1.115 christos rt_xaddrs(u_char rtmtype, const char *cp, const char *cplim,
1160 1.115 christos struct rt_addrinfo *rtinfo)
1161 1.10 mycroft {
1162 1.69 matt const struct sockaddr *sa = NULL; /* Quell compiler warning */
1163 1.39 augustss int i;
1164 1.10 mycroft
1165 1.112 dyoung for (i = 0; i < RTAX_MAX && cp < cplim; i++) {
1166 1.10 mycroft if ((rtinfo->rti_addrs & (1 << i)) == 0)
1167 1.10 mycroft continue;
1168 1.117 christos rtinfo->rti_info[i] = sa = (const struct sockaddr *)cp;
1169 1.133 matt RT_XADVANCE(cp, sa);
1170 1.10 mycroft }
1171 1.44 enami
1172 1.115 christos /*
1173 1.115 christos * Check for extra addresses specified, except RTM_GET asking
1174 1.115 christos * for interface info.
1175 1.115 christos */
1176 1.72 christos if (rtmtype == RTM_GET) {
1177 1.115 christos if (((rtinfo->rti_addrs &
1178 1.193 martin (~((1 << RTAX_IFP) | (1 << RTAX_IFA)))) & (~0U << i)) != 0)
1179 1.95 dyoung return 1;
1180 1.193 martin } else if ((rtinfo->rti_addrs & (~0U << i)) != 0)
1181 1.114 dyoung return 1;
1182 1.44 enami /* Check for bad data length. */
1183 1.44 enami if (cp != cplim) {
1184 1.112 dyoung if (i == RTAX_NETMASK + 1 && sa != NULL &&
1185 1.133 matt cp - RT_XROUNDUP(sa->sa_len) + sa->sa_len == cplim)
1186 1.44 enami /*
1187 1.114 dyoung * The last sockaddr was info.rti_info[RTAX_NETMASK].
1188 1.44 enami * We accept this for now for the sake of old
1189 1.44 enami * binaries or third party softwares.
1190 1.44 enami */
1191 1.44 enami ;
1192 1.44 enami else
1193 1.95 dyoung return 1;
1194 1.44 enami }
1195 1.95 dyoung return 0;
1196 1.1 cgd }
1197 1.1 cgd
1198 1.132 christos static int
1199 1.132 christos rt_getlen(int type)
1200 1.1 cgd {
1201 1.133 matt #ifndef COMPAT_RTSOCK
1202 1.133 matt CTASSERT(__alignof(struct ifa_msghdr) >= sizeof(uint64_t));
1203 1.133 matt CTASSERT(__alignof(struct if_msghdr) >= sizeof(uint64_t));
1204 1.133 matt CTASSERT(__alignof(struct if_announcemsghdr) >= sizeof(uint64_t));
1205 1.133 matt CTASSERT(__alignof(struct rt_msghdr) >= sizeof(uint64_t));
1206 1.133 matt #endif
1207 1.133 matt
1208 1.10 mycroft switch (type) {
1209 1.196 roy case RTM_ODELADDR:
1210 1.196 roy case RTM_ONEWADDR:
1211 1.196 roy case RTM_OCHGADDR:
1212 1.196 roy #ifdef COMPAT_70
1213 1.196 roy return sizeof(struct ifa_msghdr70);
1214 1.196 roy #else
1215 1.203 ozaki #ifdef RTSOCK_DEBUG
1216 1.203 ozaki printf("%s: unsupported RTM type %d\n", __func__, type);
1217 1.196 roy #endif
1218 1.196 roy return -1;
1219 1.196 roy #endif
1220 1.10 mycroft case RTM_DELADDR:
1221 1.10 mycroft case RTM_NEWADDR:
1222 1.131 roy case RTM_CHGADDR:
1223 1.133 matt return sizeof(struct ifa_xmsghdr);
1224 1.10 mycroft
1225 1.132 christos case RTM_OOIFINFO:
1226 1.32 bouyer #ifdef COMPAT_14
1227 1.132 christos return sizeof(struct if_msghdr14);
1228 1.132 christos #else
1229 1.203 ozaki #ifdef RTSOCK_DEBUG
1230 1.203 ozaki printf("%s: unsupported RTM type RTM_OOIFINFO\n", __func__);
1231 1.132 christos #endif
1232 1.132 christos return -1;
1233 1.120 christos #endif
1234 1.132 christos case RTM_OIFINFO:
1235 1.120 christos #ifdef COMPAT_50
1236 1.132 christos return sizeof(struct if_msghdr50);
1237 1.132 christos #else
1238 1.203 ozaki #ifdef RTSOCK_DEBUG
1239 1.203 ozaki printf("%s: unsupported RTM type RTM_OIFINFO\n", __func__);
1240 1.132 christos #endif
1241 1.132 christos return -1;
1242 1.32 bouyer #endif
1243 1.32 bouyer
1244 1.10 mycroft case RTM_IFINFO:
1245 1.133 matt return sizeof(struct if_xmsghdr);
1246 1.10 mycroft
1247 1.36 thorpej case RTM_IFANNOUNCE:
1248 1.78 dyoung case RTM_IEEE80211:
1249 1.133 matt return sizeof(struct if_xannouncemsghdr);
1250 1.36 thorpej
1251 1.10 mycroft default:
1252 1.133 matt return sizeof(struct rt_xmsghdr);
1253 1.46 itojun }
1254 1.132 christos }
1255 1.132 christos
1256 1.132 christos
1257 1.132 christos struct mbuf *
1258 1.133 matt COMPATNAME(rt_msg1)(int type, struct rt_addrinfo *rtinfo, void *data, int datalen)
1259 1.132 christos {
1260 1.133 matt struct rt_xmsghdr *rtm;
1261 1.132 christos struct mbuf *m;
1262 1.132 christos int i;
1263 1.132 christos const struct sockaddr *sa;
1264 1.132 christos int len, dlen;
1265 1.132 christos
1266 1.132 christos m = m_gethdr(M_DONTWAIT, MT_DATA);
1267 1.132 christos if (m == NULL)
1268 1.132 christos return m;
1269 1.133 matt MCLAIM(m, &COMPATNAME(routedomain).dom_mowner);
1270 1.132 christos
1271 1.132 christos if ((len = rt_getlen(type)) == -1)
1272 1.132 christos goto out;
1273 1.47 itojun if (len > MHLEN + MLEN)
1274 1.133 matt panic("%s: message too long", __func__);
1275 1.47 itojun else if (len > MHLEN) {
1276 1.32 bouyer m->m_next = m_get(M_DONTWAIT, MT_DATA);
1277 1.132 christos if (m->m_next == NULL)
1278 1.132 christos goto out;
1279 1.58 matt MCLAIM(m->m_next, m->m_owner);
1280 1.47 itojun m->m_pkthdr.len = len;
1281 1.47 itojun m->m_len = MHLEN;
1282 1.47 itojun m->m_next->m_len = len - MHLEN;
1283 1.47 itojun } else {
1284 1.47 itojun m->m_pkthdr.len = m->m_len = len;
1285 1.32 bouyer }
1286 1.189 ozaki m_reset_rcvif(m);
1287 1.32 bouyer m_copyback(m, 0, datalen, data);
1288 1.107 christos if (len > datalen)
1289 1.107 christos (void)memset(mtod(m, char *) + datalen, 0, len - datalen);
1290 1.133 matt rtm = mtod(m, struct rt_xmsghdr *);
1291 1.10 mycroft for (i = 0; i < RTAX_MAX; i++) {
1292 1.10 mycroft if ((sa = rtinfo->rti_info[i]) == NULL)
1293 1.10 mycroft continue;
1294 1.10 mycroft rtinfo->rti_addrs |= (1 << i);
1295 1.133 matt dlen = RT_XROUNDUP(sa->sa_len);
1296 1.133 matt m_copyback(m, len, sa->sa_len, sa);
1297 1.133 matt if (dlen != sa->sa_len) {
1298 1.140 christos /*
1299 1.140 christos * Up to 6 + 1 nul's since roundup is to
1300 1.140 christos * sizeof(uint64_t) (8 bytes)
1301 1.140 christos */
1302 1.133 matt m_copyback(m, len + sa->sa_len,
1303 1.133 matt dlen - sa->sa_len, "\0\0\0\0\0\0");
1304 1.133 matt }
1305 1.10 mycroft len += dlen;
1306 1.47 itojun }
1307 1.132 christos if (m->m_pkthdr.len != len)
1308 1.132 christos goto out;
1309 1.1 cgd rtm->rtm_msglen = len;
1310 1.133 matt rtm->rtm_version = RTM_XVERSION;
1311 1.1 cgd rtm->rtm_type = type;
1312 1.95 dyoung return m;
1313 1.132 christos out:
1314 1.132 christos m_freem(m);
1315 1.132 christos return NULL;
1316 1.10 mycroft }
1317 1.10 mycroft
1318 1.29 chopps /*
1319 1.29 chopps * rt_msg2
1320 1.29 chopps *
1321 1.29 chopps * fills 'cp' or 'w'.w_tmem with the routing socket message and
1322 1.29 chopps * returns the length of the message in 'lenp'.
1323 1.29 chopps *
1324 1.29 chopps * if walkarg is 0, cp is expected to be 0 or a buffer large enough to hold
1325 1.29 chopps * the message
1326 1.29 chopps * otherwise walkarg's w_needed is updated and if the user buffer is
1327 1.29 chopps * specified and w_needed indicates space exists the information is copied
1328 1.29 chopps * into the temp space (w_tmem). w_tmem is [re]allocated if necessary,
1329 1.29 chopps * if the allocation fails ENOBUFS is returned.
1330 1.29 chopps */
1331 1.10 mycroft static int
1332 1.120 christos rt_msg2(int type, struct rt_addrinfo *rtinfo, void *cpv, struct rt_walkarg *w,
1333 1.69 matt int *lenp)
1334 1.10 mycroft {
1335 1.39 augustss int i;
1336 1.10 mycroft int len, dlen, second_time = 0;
1337 1.93 christos char *cp0, *cp = cpv;
1338 1.10 mycroft
1339 1.10 mycroft rtinfo->rti_addrs = 0;
1340 1.10 mycroft again:
1341 1.132 christos if ((len = rt_getlen(type)) == -1)
1342 1.132 christos return EINVAL;
1343 1.10 mycroft
1344 1.17 christos if ((cp0 = cp) != NULL)
1345 1.10 mycroft cp += len;
1346 1.10 mycroft for (i = 0; i < RTAX_MAX; i++) {
1347 1.68 matt const struct sockaddr *sa;
1348 1.10 mycroft
1349 1.95 dyoung if ((sa = rtinfo->rti_info[i]) == NULL)
1350 1.10 mycroft continue;
1351 1.10 mycroft rtinfo->rti_addrs |= (1 << i);
1352 1.133 matt dlen = RT_XROUNDUP(sa->sa_len);
1353 1.10 mycroft if (cp) {
1354 1.140 christos int diff = dlen - sa->sa_len;
1355 1.140 christos (void)memcpy(cp, sa, (size_t)sa->sa_len);
1356 1.140 christos cp += sa->sa_len;
1357 1.140 christos if (diff > 0) {
1358 1.140 christos (void)memset(cp, 0, (size_t)diff);
1359 1.140 christos cp += diff;
1360 1.140 christos }
1361 1.10 mycroft }
1362 1.1 cgd len += dlen;
1363 1.1 cgd }
1364 1.95 dyoung if (cp == NULL && w != NULL && !second_time) {
1365 1.120 christos struct rt_walkarg *rw = w;
1366 1.10 mycroft
1367 1.10 mycroft rw->w_needed += len;
1368 1.10 mycroft if (rw->w_needed <= 0 && rw->w_where) {
1369 1.10 mycroft if (rw->w_tmemsize < len) {
1370 1.10 mycroft if (rw->w_tmem)
1371 1.202 ozaki kmem_free(rw->w_tmem, rw->w_tmemsize);
1372 1.202 ozaki rw->w_tmem = kmem_alloc(len, KM_SLEEP);
1373 1.213 chs rw->w_tmemsize = len;
1374 1.10 mycroft }
1375 1.10 mycroft if (rw->w_tmem) {
1376 1.10 mycroft cp = rw->w_tmem;
1377 1.10 mycroft second_time = 1;
1378 1.10 mycroft goto again;
1379 1.29 chopps } else {
1380 1.29 chopps rw->w_tmemneeded = len;
1381 1.95 dyoung return ENOBUFS;
1382 1.29 chopps }
1383 1.10 mycroft }
1384 1.1 cgd }
1385 1.10 mycroft if (cp) {
1386 1.133 matt struct rt_xmsghdr *rtm = (struct rt_xmsghdr *)cp0;
1387 1.10 mycroft
1388 1.133 matt rtm->rtm_version = RTM_XVERSION;
1389 1.10 mycroft rtm->rtm_type = type;
1390 1.10 mycroft rtm->rtm_msglen = len;
1391 1.1 cgd }
1392 1.29 chopps if (lenp)
1393 1.29 chopps *lenp = len;
1394 1.95 dyoung return 0;
1395 1.10 mycroft }
1396 1.10 mycroft
1397 1.178 ozaki #ifndef COMPAT_RTSOCK
1398 1.178 ozaki int
1399 1.178 ozaki rt_msg3(int type, struct rt_addrinfo *rtinfo, void *cpv, struct rt_walkarg *w,
1400 1.178 ozaki int *lenp)
1401 1.178 ozaki {
1402 1.178 ozaki return rt_msg2(type, rtinfo, cpv, w, lenp);
1403 1.178 ozaki }
1404 1.178 ozaki #endif
1405 1.178 ozaki
1406 1.10 mycroft /*
1407 1.10 mycroft * This routine is called to generate a message from the routing
1408 1.51 wiz * socket indicating that a redirect has occurred, a routing lookup
1409 1.10 mycroft * has failed, or that a protocol has detected timeouts to a particular
1410 1.10 mycroft * destination.
1411 1.10 mycroft */
1412 1.10 mycroft void
1413 1.133 matt COMPATNAME(rt_missmsg)(int type, const struct rt_addrinfo *rtinfo, int flags,
1414 1.133 matt int error)
1415 1.10 mycroft {
1416 1.133 matt struct rt_xmsghdr rtm;
1417 1.39 augustss struct mbuf *m;
1418 1.68 matt const struct sockaddr *sa = rtinfo->rti_info[RTAX_DST];
1419 1.133 matt struct rt_addrinfo info = *rtinfo;
1420 1.10 mycroft
1421 1.133 matt COMPATCALL(rt_missmsg, (type, rtinfo, flags, error));
1422 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
1423 1.10 mycroft return;
1424 1.48 thorpej memset(&rtm, 0, sizeof(rtm));
1425 1.185 roy rtm.rtm_pid = curproc->p_pid;
1426 1.32 bouyer rtm.rtm_flags = RTF_DONE | flags;
1427 1.32 bouyer rtm.rtm_errno = error;
1428 1.133 matt m = COMPATNAME(rt_msg1)(type, &info, &rtm, sizeof(rtm));
1429 1.95 dyoung if (m == NULL)
1430 1.1 cgd return;
1431 1.133 matt mtod(m, struct rt_xmsghdr *)->rtm_addrs = info.rti_addrs;
1432 1.133 matt COMPATNAME(route_enqueue)(m, sa ? sa->sa_family : 0);
1433 1.10 mycroft }
1434 1.10 mycroft
1435 1.10 mycroft /*
1436 1.10 mycroft * This routine is called to generate a message from the routing
1437 1.10 mycroft * socket indicating that the status of a network interface has changed.
1438 1.10 mycroft */
1439 1.10 mycroft void
1440 1.133 matt COMPATNAME(rt_ifmsg)(struct ifnet *ifp)
1441 1.10 mycroft {
1442 1.133 matt struct if_xmsghdr ifm;
1443 1.10 mycroft struct mbuf *m;
1444 1.10 mycroft struct rt_addrinfo info;
1445 1.10 mycroft
1446 1.133 matt COMPATCALL(rt_ifmsg, (ifp));
1447 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
1448 1.10 mycroft return;
1449 1.120 christos (void)memset(&info, 0, sizeof(info));
1450 1.120 christos (void)memset(&ifm, 0, sizeof(ifm));
1451 1.32 bouyer ifm.ifm_index = ifp->if_index;
1452 1.32 bouyer ifm.ifm_flags = ifp->if_flags;
1453 1.32 bouyer ifm.ifm_data = ifp->if_data;
1454 1.32 bouyer ifm.ifm_addrs = 0;
1455 1.133 matt m = COMPATNAME(rt_msg1)(RTM_IFINFO, &info, &ifm, sizeof(ifm));
1456 1.95 dyoung if (m == NULL)
1457 1.32 bouyer return;
1458 1.133 matt COMPATNAME(route_enqueue)(m, 0);
1459 1.32 bouyer #ifdef COMPAT_14
1460 1.133 matt compat_14_rt_oifmsg(ifp);
1461 1.120 christos #endif
1462 1.120 christos #ifdef COMPAT_50
1463 1.133 matt compat_50_rt_oifmsg(ifp);
1464 1.32 bouyer #endif
1465 1.1 cgd }
1466 1.1 cgd
1467 1.196 roy #ifndef COMPAT_RTSOCK
1468 1.196 roy static int
1469 1.196 roy if_addrflags(struct ifaddr *ifa)
1470 1.196 roy {
1471 1.196 roy
1472 1.196 roy switch (ifa->ifa_addr->sa_family) {
1473 1.196 roy #ifdef INET
1474 1.196 roy case AF_INET:
1475 1.196 roy return ((struct in_ifaddr *)ifa)->ia4_flags;
1476 1.196 roy #endif
1477 1.196 roy #ifdef INET6
1478 1.196 roy case AF_INET6:
1479 1.196 roy return ((struct in6_ifaddr *)ifa)->ia6_flags;
1480 1.196 roy #endif
1481 1.196 roy default:
1482 1.196 roy return 0;
1483 1.196 roy }
1484 1.196 roy }
1485 1.196 roy #endif
1486 1.120 christos
1487 1.1 cgd /*
1488 1.10 mycroft * This is called to generate messages from the routing socket
1489 1.10 mycroft * indicating a network interface has had addresses associated with it.
1490 1.10 mycroft * if we ever reverse the logic and replace messages TO the routing
1491 1.10 mycroft * socket indicate a request to configure interfaces, then it will
1492 1.10 mycroft * be unnecessary as the routing socket will automatically generate
1493 1.10 mycroft * copies of it.
1494 1.10 mycroft */
1495 1.10 mycroft void
1496 1.133 matt COMPATNAME(rt_newaddrmsg)(int cmd, struct ifaddr *ifa, int error,
1497 1.133 matt struct rtentry *rt)
1498 1.10 mycroft {
1499 1.116 dyoung #define cmdpass(__cmd, __pass) (((__cmd) << 2) | (__pass))
1500 1.10 mycroft struct rt_addrinfo info;
1501 1.116 dyoung const struct sockaddr *sa;
1502 1.10 mycroft int pass;
1503 1.116 dyoung struct mbuf *m;
1504 1.139 christos struct ifnet *ifp;
1505 1.133 matt struct rt_xmsghdr rtm;
1506 1.133 matt struct ifa_xmsghdr ifam;
1507 1.116 dyoung int ncmd;
1508 1.10 mycroft
1509 1.139 christos KASSERT(ifa != NULL);
1510 1.196 roy KASSERT(ifa->ifa_addr != NULL);
1511 1.139 christos ifp = ifa->ifa_ifp;
1512 1.174 rjs #ifdef SCTP
1513 1.174 rjs if (cmd == RTM_ADD) {
1514 1.174 rjs sctp_add_ip_address(ifa);
1515 1.174 rjs } else if (cmd == RTM_DELETE) {
1516 1.174 rjs sctp_delete_ip_address(ifa);
1517 1.174 rjs }
1518 1.174 rjs #endif
1519 1.174 rjs
1520 1.133 matt COMPATCALL(rt_newaddrmsg, (cmd, ifa, error, rt));
1521 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
1522 1.10 mycroft return;
1523 1.10 mycroft for (pass = 1; pass < 3; pass++) {
1524 1.48 thorpej memset(&info, 0, sizeof(info));
1525 1.116 dyoung switch (cmdpass(cmd, pass)) {
1526 1.116 dyoung case cmdpass(RTM_ADD, 1):
1527 1.116 dyoung case cmdpass(RTM_CHANGE, 1):
1528 1.116 dyoung case cmdpass(RTM_DELETE, 2):
1529 1.138 roy case cmdpass(RTM_NEWADDR, 1):
1530 1.138 roy case cmdpass(RTM_DELADDR, 1):
1531 1.138 roy case cmdpass(RTM_CHGADDR, 1):
1532 1.131 roy switch (cmd) {
1533 1.138 roy case RTM_ADD:
1534 1.196 roy ncmd = RTM_XNEWADDR;
1535 1.138 roy break;
1536 1.131 roy case RTM_DELETE:
1537 1.196 roy ncmd = RTM_XDELADDR;
1538 1.131 roy break;
1539 1.131 roy case RTM_CHANGE:
1540 1.196 roy ncmd = RTM_XCHGADDR;
1541 1.196 roy break;
1542 1.196 roy case RTM_NEWADDR:
1543 1.196 roy ncmd = RTM_XNEWADDR;
1544 1.196 roy break;
1545 1.196 roy case RTM_DELADDR:
1546 1.196 roy ncmd = RTM_XDELADDR;
1547 1.196 roy break;
1548 1.196 roy case RTM_CHGADDR:
1549 1.196 roy ncmd = RTM_XCHGADDR;
1550 1.131 roy break;
1551 1.131 roy default:
1552 1.196 roy panic("%s: unknown command %d", __func__, cmd);
1553 1.131 roy }
1554 1.196 roy #ifdef COMPAT_70
1555 1.196 roy compat_70_rt_newaddrmsg1(ncmd, ifa);
1556 1.196 roy #endif
1557 1.114 dyoung info.rti_info[RTAX_IFA] = sa = ifa->ifa_addr;
1558 1.139 christos KASSERT(ifp->if_dl != NULL);
1559 1.114 dyoung info.rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
1560 1.114 dyoung info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
1561 1.114 dyoung info.rti_info[RTAX_BRD] = ifa->ifa_dstaddr;
1562 1.48 thorpej memset(&ifam, 0, sizeof(ifam));
1563 1.32 bouyer ifam.ifam_index = ifp->if_index;
1564 1.32 bouyer ifam.ifam_metric = ifa->ifa_metric;
1565 1.32 bouyer ifam.ifam_flags = ifa->ifa_flags;
1566 1.196 roy #ifndef COMPAT_RTSOCK
1567 1.196 roy ifam.ifam_pid = curproc->p_pid;
1568 1.196 roy ifam.ifam_addrflags = if_addrflags(ifa);
1569 1.196 roy #endif
1570 1.133 matt m = COMPATNAME(rt_msg1)(ncmd, &info, &ifam, sizeof(ifam));
1571 1.32 bouyer if (m == NULL)
1572 1.10 mycroft continue;
1573 1.133 matt mtod(m, struct ifa_xmsghdr *)->ifam_addrs =
1574 1.32 bouyer info.rti_addrs;
1575 1.116 dyoung break;
1576 1.116 dyoung case cmdpass(RTM_ADD, 2):
1577 1.116 dyoung case cmdpass(RTM_CHANGE, 2):
1578 1.116 dyoung case cmdpass(RTM_DELETE, 1):
1579 1.95 dyoung if (rt == NULL)
1580 1.10 mycroft continue;
1581 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
1582 1.114 dyoung info.rti_info[RTAX_DST] = sa = rt_getkey(rt);
1583 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
1584 1.48 thorpej memset(&rtm, 0, sizeof(rtm));
1585 1.185 roy rtm.rtm_pid = curproc->p_pid;
1586 1.32 bouyer rtm.rtm_index = ifp->if_index;
1587 1.32 bouyer rtm.rtm_flags |= rt->rt_flags;
1588 1.32 bouyer rtm.rtm_errno = error;
1589 1.133 matt m = COMPATNAME(rt_msg1)(cmd, &info, &rtm, sizeof(rtm));
1590 1.32 bouyer if (m == NULL)
1591 1.10 mycroft continue;
1592 1.133 matt mtod(m, struct rt_xmsghdr *)->rtm_addrs = info.rti_addrs;
1593 1.116 dyoung break;
1594 1.116 dyoung default:
1595 1.116 dyoung continue;
1596 1.10 mycroft }
1597 1.204 ozaki KASSERTMSG(m != NULL, "called with wrong command");
1598 1.133 matt COMPATNAME(route_enqueue)(m, sa ? sa->sa_family : 0);
1599 1.10 mycroft }
1600 1.116 dyoung #undef cmdpass
1601 1.196 roy
1602 1.36 thorpej }
1603 1.36 thorpej
1604 1.78 dyoung static struct mbuf *
1605 1.78 dyoung rt_makeifannouncemsg(struct ifnet *ifp, int type, int what,
1606 1.78 dyoung struct rt_addrinfo *info)
1607 1.78 dyoung {
1608 1.133 matt struct if_xannouncemsghdr ifan;
1609 1.78 dyoung
1610 1.78 dyoung memset(info, 0, sizeof(*info));
1611 1.78 dyoung memset(&ifan, 0, sizeof(ifan));
1612 1.78 dyoung ifan.ifan_index = ifp->if_index;
1613 1.78 dyoung strlcpy(ifan.ifan_name, ifp->if_xname, sizeof(ifan.ifan_name));
1614 1.78 dyoung ifan.ifan_what = what;
1615 1.133 matt return COMPATNAME(rt_msg1)(type, info, &ifan, sizeof(ifan));
1616 1.78 dyoung }
1617 1.78 dyoung
1618 1.36 thorpej /*
1619 1.36 thorpej * This is called to generate routing socket messages indicating
1620 1.36 thorpej * network interface arrival and departure.
1621 1.36 thorpej */
1622 1.36 thorpej void
1623 1.133 matt COMPATNAME(rt_ifannouncemsg)(struct ifnet *ifp, int what)
1624 1.36 thorpej {
1625 1.36 thorpej struct mbuf *m;
1626 1.36 thorpej struct rt_addrinfo info;
1627 1.36 thorpej
1628 1.133 matt COMPATCALL(rt_ifannouncemsg, (ifp, what));
1629 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
1630 1.36 thorpej return;
1631 1.78 dyoung m = rt_makeifannouncemsg(ifp, RTM_IFANNOUNCE, what, &info);
1632 1.78 dyoung if (m == NULL)
1633 1.78 dyoung return;
1634 1.133 matt COMPATNAME(route_enqueue)(m, 0);
1635 1.78 dyoung }
1636 1.78 dyoung
1637 1.78 dyoung /*
1638 1.78 dyoung * This is called to generate routing socket messages indicating
1639 1.78 dyoung * IEEE80211 wireless events.
1640 1.78 dyoung * XXX we piggyback on the RTM_IFANNOUNCE msg format in a clumsy way.
1641 1.78 dyoung */
1642 1.78 dyoung void
1643 1.133 matt COMPATNAME(rt_ieee80211msg)(struct ifnet *ifp, int what, void *data,
1644 1.133 matt size_t data_len)
1645 1.78 dyoung {
1646 1.78 dyoung struct mbuf *m;
1647 1.78 dyoung struct rt_addrinfo info;
1648 1.78 dyoung
1649 1.133 matt COMPATCALL(rt_ieee80211msg, (ifp, what, data, data_len));
1650 1.133 matt if (COMPATNAME(route_info).ri_cb.any_count == 0)
1651 1.78 dyoung return;
1652 1.78 dyoung m = rt_makeifannouncemsg(ifp, RTM_IEEE80211, what, &info);
1653 1.78 dyoung if (m == NULL)
1654 1.36 thorpej return;
1655 1.78 dyoung /*
1656 1.78 dyoung * Append the ieee80211 data. Try to stick it in the
1657 1.78 dyoung * mbuf containing the ifannounce msg; otherwise allocate
1658 1.78 dyoung * a new mbuf and append.
1659 1.78 dyoung *
1660 1.78 dyoung * NB: we assume m is a single mbuf.
1661 1.78 dyoung */
1662 1.78 dyoung if (data_len > M_TRAILINGSPACE(m)) {
1663 1.78 dyoung struct mbuf *n = m_get(M_NOWAIT, MT_DATA);
1664 1.78 dyoung if (n == NULL) {
1665 1.78 dyoung m_freem(m);
1666 1.78 dyoung return;
1667 1.78 dyoung }
1668 1.78 dyoung (void)memcpy(mtod(n, void *), data, data_len);
1669 1.78 dyoung n->m_len = data_len;
1670 1.78 dyoung m->m_next = n;
1671 1.78 dyoung } else if (data_len > 0) {
1672 1.98 matt (void)memcpy(mtod(m, uint8_t *) + m->m_len, data, data_len);
1673 1.78 dyoung m->m_len += data_len;
1674 1.78 dyoung }
1675 1.78 dyoung if (m->m_flags & M_PKTHDR)
1676 1.78 dyoung m->m_pkthdr.len += data_len;
1677 1.133 matt mtod(m, struct if_xannouncemsghdr *)->ifan_msglen += data_len;
1678 1.133 matt COMPATNAME(route_enqueue)(m, 0);
1679 1.10 mycroft }
1680 1.10 mycroft
1681 1.215 ozaki #ifndef COMPAT_RTSOCK
1682 1.215 ozaki /*
1683 1.215 ozaki * Send a routing message as mimicing that a cloned route is added.
1684 1.215 ozaki */
1685 1.215 ozaki void
1686 1.215 ozaki rt_clonedmsg(const struct sockaddr *dst, const struct ifnet *ifp,
1687 1.215 ozaki const struct rtentry *rt)
1688 1.215 ozaki {
1689 1.215 ozaki struct rt_addrinfo info;
1690 1.215 ozaki /* Mimic flags exactly */
1691 1.215 ozaki #define RTF_LLINFO 0x400
1692 1.215 ozaki #define RTF_CLONED 0x2000
1693 1.215 ozaki int flags = RTF_UP | RTF_HOST | RTF_DONE | RTF_LLINFO | RTF_CLONED;
1694 1.215 ozaki union {
1695 1.215 ozaki struct sockaddr sa;
1696 1.215 ozaki struct sockaddr_storage ss;
1697 1.215 ozaki struct sockaddr_dl sdl;
1698 1.215 ozaki } u;
1699 1.215 ozaki uint8_t namelen = strlen(ifp->if_xname);
1700 1.215 ozaki uint8_t addrlen = ifp->if_addrlen;
1701 1.215 ozaki
1702 1.215 ozaki if (rt == NULL)
1703 1.215 ozaki return; /* XXX */
1704 1.215 ozaki
1705 1.215 ozaki memset(&info, 0, sizeof(info));
1706 1.215 ozaki info.rti_info[RTAX_DST] = dst;
1707 1.215 ozaki sockaddr_dl_init(&u.sdl, sizeof(u.ss), ifp->if_index, ifp->if_type,
1708 1.215 ozaki NULL, namelen, NULL, addrlen);
1709 1.215 ozaki info.rti_info[RTAX_GATEWAY] = &u.sa;
1710 1.215 ozaki
1711 1.215 ozaki rt_missmsg(RTM_ADD, &info, flags, 0);
1712 1.215 ozaki #undef RTF_LLINFO
1713 1.215 ozaki #undef RTF_CLONED
1714 1.215 ozaki }
1715 1.215 ozaki #endif /* COMPAT_RTSOCK */
1716 1.215 ozaki
1717 1.10 mycroft /*
1718 1.10 mycroft * This is used in dumping the kernel table via sysctl().
1719 1.1 cgd */
1720 1.40 simonb static int
1721 1.94 dyoung sysctl_dumpentry(struct rtentry *rt, void *v)
1722 1.1 cgd {
1723 1.120 christos struct rt_walkarg *w = v;
1724 1.10 mycroft int error = 0, size;
1725 1.10 mycroft struct rt_addrinfo info;
1726 1.1 cgd
1727 1.10 mycroft if (w->w_op == NET_RT_FLAGS && !(rt->rt_flags & w->w_arg))
1728 1.10 mycroft return 0;
1729 1.48 thorpej memset(&info, 0, sizeof(info));
1730 1.114 dyoung info.rti_info[RTAX_DST] = rt_getkey(rt);
1731 1.114 dyoung info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
1732 1.114 dyoung info.rti_info[RTAX_NETMASK] = rt_mask(rt);
1733 1.142 kefren info.rti_info[RTAX_TAG] = rt_gettag(rt);
1734 1.16 cgd if (rt->rt_ifp) {
1735 1.91 dyoung const struct ifaddr *rtifa;
1736 1.114 dyoung info.rti_info[RTAX_IFP] = rt->rt_ifp->if_dl->ifa_addr;
1737 1.91 dyoung /* rtifa used to be simply rt->rt_ifa. If rt->rt_ifa != NULL,
1738 1.91 dyoung * then rt_get_ifa() != NULL. So this ought to still be safe.
1739 1.91 dyoung * --dyoung
1740 1.91 dyoung */
1741 1.91 dyoung rtifa = rt_get_ifa(rt);
1742 1.114 dyoung info.rti_info[RTAX_IFA] = rtifa->ifa_addr;
1743 1.16 cgd if (rt->rt_ifp->if_flags & IFF_POINTOPOINT)
1744 1.114 dyoung info.rti_info[RTAX_BRD] = rtifa->ifa_dstaddr;
1745 1.16 cgd }
1746 1.29 chopps if ((error = rt_msg2(RTM_GET, &info, 0, w, &size)))
1747 1.95 dyoung return error;
1748 1.29 chopps if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1749 1.133 matt struct rt_xmsghdr *rtm = (struct rt_xmsghdr *)w->w_tmem;
1750 1.10 mycroft
1751 1.10 mycroft rtm->rtm_flags = rt->rt_flags;
1752 1.10 mycroft rtm->rtm_use = rt->rt_use;
1753 1.133 matt rtm_setmetrics(rt, rtm);
1754 1.83 christos KASSERT(rt->rt_ifp != NULL);
1755 1.10 mycroft rtm->rtm_index = rt->rt_ifp->if_index;
1756 1.10 mycroft rtm->rtm_errno = rtm->rtm_pid = rtm->rtm_seq = 0;
1757 1.10 mycroft rtm->rtm_addrs = info.rti_addrs;
1758 1.21 christos if ((error = copyout(rtm, w->w_where, size)) != 0)
1759 1.10 mycroft w->w_where = NULL;
1760 1.10 mycroft else
1761 1.93 christos w->w_where = (char *)w->w_where + size;
1762 1.10 mycroft }
1763 1.95 dyoung return error;
1764 1.10 mycroft }
1765 1.1 cgd
1766 1.40 simonb static int
1767 1.195 roy sysctl_iflist_if(struct ifnet *ifp, struct rt_walkarg *w,
1768 1.195 roy struct rt_addrinfo *info, size_t len)
1769 1.195 roy {
1770 1.195 roy struct if_xmsghdr *ifm;
1771 1.195 roy int error;
1772 1.195 roy
1773 1.195 roy ifm = (struct if_xmsghdr *)w->w_tmem;
1774 1.195 roy ifm->ifm_index = ifp->if_index;
1775 1.195 roy ifm->ifm_flags = ifp->if_flags;
1776 1.195 roy ifm->ifm_data = ifp->if_data;
1777 1.195 roy ifm->ifm_addrs = info->rti_addrs;
1778 1.195 roy if ((error = copyout(ifm, w->w_where, len)) == 0)
1779 1.195 roy w->w_where = (char *)w->w_where + len;
1780 1.195 roy return error;
1781 1.195 roy }
1782 1.195 roy
1783 1.195 roy static int
1784 1.195 roy sysctl_iflist_addr(struct rt_walkarg *w, struct ifaddr *ifa,
1785 1.195 roy struct rt_addrinfo *info)
1786 1.195 roy {
1787 1.195 roy int len, error;
1788 1.195 roy
1789 1.196 roy if ((error = rt_msg2(RTM_XNEWADDR, info, 0, w, &len)))
1790 1.195 roy return error;
1791 1.195 roy if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1792 1.195 roy struct ifa_xmsghdr *ifam;
1793 1.195 roy
1794 1.195 roy ifam = (struct ifa_xmsghdr *)w->w_tmem;
1795 1.195 roy ifam->ifam_index = ifa->ifa_ifp->if_index;
1796 1.195 roy ifam->ifam_flags = ifa->ifa_flags;
1797 1.195 roy ifam->ifam_metric = ifa->ifa_metric;
1798 1.195 roy ifam->ifam_addrs = info->rti_addrs;
1799 1.196 roy #ifndef COMPAT_RTSOCK
1800 1.196 roy ifam->ifam_pid = 0;
1801 1.196 roy ifam->ifam_addrflags = if_addrflags(ifa);
1802 1.196 roy #endif
1803 1.195 roy if ((error = copyout(w->w_tmem, w->w_where, len)) == 0)
1804 1.195 roy w->w_where = (char *)w->w_where + len;
1805 1.195 roy }
1806 1.195 roy return error;
1807 1.195 roy }
1808 1.195 roy
1809 1.195 roy static int
1810 1.120 christos sysctl_iflist(int af, struct rt_walkarg *w, int type)
1811 1.10 mycroft {
1812 1.39 augustss struct ifnet *ifp;
1813 1.39 augustss struct ifaddr *ifa;
1814 1.10 mycroft struct rt_addrinfo info;
1815 1.195 roy int cmd, len, error = 0;
1816 1.195 roy int (*iflist_if)(struct ifnet *, struct rt_walkarg *,
1817 1.195 roy struct rt_addrinfo *, size_t);
1818 1.196 roy int (*iflist_addr)(struct rt_walkarg *, struct ifaddr *,
1819 1.196 roy struct rt_addrinfo *);
1820 1.186 ozaki int s;
1821 1.186 ozaki struct psref psref;
1822 1.206 ozaki int bound;
1823 1.10 mycroft
1824 1.195 roy switch (type) {
1825 1.195 roy case NET_RT_IFLIST:
1826 1.195 roy cmd = RTM_IFINFO;
1827 1.195 roy iflist_if = sysctl_iflist_if;
1828 1.196 roy iflist_addr = sysctl_iflist_addr;
1829 1.195 roy break;
1830 1.195 roy #ifdef COMPAT_14
1831 1.196 roy case NET_RT_OOOIFLIST:
1832 1.195 roy cmd = RTM_OOIFINFO;
1833 1.195 roy iflist_if = compat_14_iflist;
1834 1.196 roy iflist_addr = compat_70_iflist_addr;
1835 1.195 roy break;
1836 1.195 roy #endif
1837 1.195 roy #ifdef COMPAT_50
1838 1.196 roy case NET_RT_OOIFLIST:
1839 1.195 roy cmd = RTM_OIFINFO;
1840 1.195 roy iflist_if = compat_50_iflist;
1841 1.196 roy iflist_addr = compat_70_iflist_addr;
1842 1.196 roy break;
1843 1.196 roy #endif
1844 1.196 roy #ifdef COMPAT_70
1845 1.196 roy case NET_RT_OIFLIST:
1846 1.196 roy cmd = RTM_IFINFO;
1847 1.196 roy iflist_if = sysctl_iflist_if;
1848 1.196 roy iflist_addr = compat_70_iflist_addr;
1849 1.195 roy break;
1850 1.195 roy #endif
1851 1.195 roy default:
1852 1.203 ozaki #ifdef RTSOCK_DEBUG
1853 1.203 ozaki printf("%s: unsupported IFLIST type %d\n", __func__, type);
1854 1.195 roy #endif
1855 1.195 roy return EINVAL;
1856 1.195 roy }
1857 1.195 roy
1858 1.48 thorpej memset(&info, 0, sizeof(info));
1859 1.186 ozaki
1860 1.206 ozaki bound = curlwp_bind();
1861 1.186 ozaki s = pserialize_read_enter();
1862 1.186 ozaki IFNET_READER_FOREACH(ifp) {
1863 1.205 ozaki int _s;
1864 1.10 mycroft if (w->w_arg && w->w_arg != ifp->if_index)
1865 1.10 mycroft continue;
1866 1.191 ozaki if (IFADDR_READER_EMPTY(ifp))
1867 1.81 rpaulo continue;
1868 1.186 ozaki
1869 1.207 ozaki if_acquire(ifp, &psref);
1870 1.186 ozaki pserialize_read_exit(s);
1871 1.186 ozaki
1872 1.114 dyoung info.rti_info[RTAX_IFP] = ifp->if_dl->ifa_addr;
1873 1.195 roy if ((error = rt_msg2(cmd, &info, NULL, w, &len)) != 0)
1874 1.186 ozaki goto release_exit;
1875 1.114 dyoung info.rti_info[RTAX_IFP] = NULL;
1876 1.29 chopps if (w->w_where && w->w_tmem && w->w_needed <= 0) {
1877 1.195 roy if ((error = iflist_if(ifp, w, &info, len)) != 0)
1878 1.195 roy goto release_exit;
1879 1.10 mycroft }
1880 1.205 ozaki _s = pserialize_read_enter();
1881 1.191 ozaki IFADDR_READER_FOREACH(ifa, ifp) {
1882 1.205 ozaki struct psref _psref;
1883 1.10 mycroft if (af && af != ifa->ifa_addr->sa_family)
1884 1.10 mycroft continue;
1885 1.205 ozaki ifa_acquire(ifa, &_psref);
1886 1.205 ozaki pserialize_read_exit(_s);
1887 1.205 ozaki
1888 1.114 dyoung info.rti_info[RTAX_IFA] = ifa->ifa_addr;
1889 1.114 dyoung info.rti_info[RTAX_NETMASK] = ifa->ifa_netmask;
1890 1.114 dyoung info.rti_info[RTAX_BRD] = ifa->ifa_dstaddr;
1891 1.205 ozaki error = iflist_addr(w, ifa, &info);
1892 1.205 ozaki
1893 1.205 ozaki _s = pserialize_read_enter();
1894 1.205 ozaki ifa_release(ifa, &_psref);
1895 1.208 ozaki if (error != 0) {
1896 1.208 ozaki pserialize_read_exit(_s);
1897 1.186 ozaki goto release_exit;
1898 1.208 ozaki }
1899 1.10 mycroft }
1900 1.205 ozaki pserialize_read_exit(_s);
1901 1.115 christos info.rti_info[RTAX_IFA] = info.rti_info[RTAX_NETMASK] =
1902 1.115 christos info.rti_info[RTAX_BRD] = NULL;
1903 1.186 ozaki
1904 1.186 ozaki s = pserialize_read_enter();
1905 1.207 ozaki if_release(ifp, &psref);
1906 1.10 mycroft }
1907 1.186 ozaki pserialize_read_exit(s);
1908 1.190 ozaki curlwp_bindx(bound);
1909 1.186 ozaki
1910 1.95 dyoung return 0;
1911 1.186 ozaki
1912 1.186 ozaki release_exit:
1913 1.207 ozaki if_release(ifp, &psref);
1914 1.190 ozaki curlwp_bindx(bound);
1915 1.186 ozaki return error;
1916 1.1 cgd }
1917 1.1 cgd
1918 1.40 simonb static int
1919 1.65 atatat sysctl_rtable(SYSCTLFN_ARGS)
1920 1.1 cgd {
1921 1.65 atatat void *where = oldp;
1922 1.65 atatat size_t *given = oldlenp;
1923 1.10 mycroft int i, s, error = EINVAL;
1924 1.10 mycroft u_char af;
1925 1.120 christos struct rt_walkarg w;
1926 1.1 cgd
1927 1.66 atatat if (namelen == 1 && name[0] == CTL_QUERY)
1928 1.95 dyoung return sysctl_query(SYSCTLFN_CALL(rnode));
1929 1.66 atatat
1930 1.164 matt if (newp)
1931 1.95 dyoung return EPERM;
1932 1.10 mycroft if (namelen != 3)
1933 1.95 dyoung return EINVAL;
1934 1.10 mycroft af = name[0];
1935 1.29 chopps w.w_tmemneeded = 0;
1936 1.29 chopps w.w_tmemsize = 0;
1937 1.29 chopps w.w_tmem = NULL;
1938 1.29 chopps again:
1939 1.29 chopps /* we may return here if a later [re]alloc of the t_mem buffer fails */
1940 1.29 chopps if (w.w_tmemneeded) {
1941 1.202 ozaki w.w_tmem = kmem_alloc(w.w_tmemneeded, KM_SLEEP);
1942 1.29 chopps w.w_tmemsize = w.w_tmemneeded;
1943 1.29 chopps w.w_tmemneeded = 0;
1944 1.29 chopps }
1945 1.29 chopps w.w_op = name[1];
1946 1.29 chopps w.w_arg = name[2];
1947 1.10 mycroft w.w_given = *given;
1948 1.1 cgd w.w_needed = 0 - w.w_given;
1949 1.29 chopps w.w_where = where;
1950 1.1 cgd
1951 1.14 mycroft s = splsoftnet();
1952 1.10 mycroft switch (w.w_op) {
1953 1.10 mycroft
1954 1.10 mycroft case NET_RT_DUMP:
1955 1.10 mycroft case NET_RT_FLAGS:
1956 1.219 ozaki #if defined(INET) || defined(INET6)
1957 1.178 ozaki /*
1958 1.178 ozaki * take care of llinfo entries, the caller must
1959 1.178 ozaki * specify an AF
1960 1.178 ozaki */
1961 1.178 ozaki if (w.w_op == NET_RT_FLAGS &&
1962 1.178 ozaki (w.w_arg == 0 || w.w_arg & RTF_LLDATA)) {
1963 1.178 ozaki if (af != 0)
1964 1.219 ozaki error = lltable_sysctl_dump(af, &w);
1965 1.178 ozaki else
1966 1.178 ozaki error = EINVAL;
1967 1.178 ozaki break;
1968 1.178 ozaki }
1969 1.219 ozaki #endif
1970 1.178 ozaki
1971 1.224 ozaki for (i = 1; i <= AF_MAX; i++) {
1972 1.224 ozaki if (af == 0 || af == i) {
1973 1.224 ozaki error = rt_walktree(i, sysctl_dumpentry, &w);
1974 1.224 ozaki if (error != 0)
1975 1.224 ozaki break;
1976 1.224 ozaki #if defined(INET) || defined(INET6)
1977 1.224 ozaki /*
1978 1.224 ozaki * Return ARP/NDP entries too for
1979 1.224 ozaki * backward compatibility.
1980 1.224 ozaki */
1981 1.224 ozaki error = lltable_sysctl_dump(i, &w);
1982 1.224 ozaki if (error != 0)
1983 1.224 ozaki break;
1984 1.224 ozaki #endif
1985 1.224 ozaki }
1986 1.224 ozaki }
1987 1.10 mycroft break;
1988 1.10 mycroft
1989 1.32 bouyer #ifdef COMPAT_14
1990 1.196 roy case NET_RT_OOOIFLIST:
1991 1.196 roy error = sysctl_iflist(af, &w, w.w_op);
1992 1.196 roy break;
1993 1.196 roy #endif
1994 1.196 roy #ifdef COMPAT_50
1995 1.120 christos case NET_RT_OOIFLIST:
1996 1.120 christos error = sysctl_iflist(af, &w, w.w_op);
1997 1.120 christos break;
1998 1.120 christos #endif
1999 1.196 roy #ifdef COMPAT_70
2000 1.32 bouyer case NET_RT_OIFLIST:
2001 1.32 bouyer error = sysctl_iflist(af, &w, w.w_op);
2002 1.32 bouyer break;
2003 1.32 bouyer #endif
2004 1.10 mycroft case NET_RT_IFLIST:
2005 1.32 bouyer error = sysctl_iflist(af, &w, w.w_op);
2006 1.133 matt break;
2007 1.1 cgd }
2008 1.10 mycroft splx(s);
2009 1.29 chopps
2010 1.29 chopps /* check to see if we couldn't allocate memory with NOWAIT */
2011 1.29 chopps if (error == ENOBUFS && w.w_tmem == 0 && w.w_tmemneeded)
2012 1.29 chopps goto again;
2013 1.29 chopps
2014 1.10 mycroft if (w.w_tmem)
2015 1.202 ozaki kmem_free(w.w_tmem, w.w_tmemsize);
2016 1.1 cgd w.w_needed += w.w_given;
2017 1.10 mycroft if (where) {
2018 1.93 christos *given = (char *)w.w_where - (char *)where;
2019 1.10 mycroft if (*given < w.w_needed)
2020 1.95 dyoung return ENOMEM;
2021 1.10 mycroft } else {
2022 1.10 mycroft *given = (11 * w.w_needed) / 10;
2023 1.10 mycroft }
2024 1.95 dyoung return error;
2025 1.1 cgd }
2026 1.1 cgd
2027 1.1 cgd /*
2028 1.99 ad * Routing message software interrupt routine
2029 1.99 ad */
2030 1.99 ad static void
2031 1.133 matt COMPATNAME(route_intr)(void *cookie)
2032 1.99 ad {
2033 1.133 matt struct sockproto proto = { .sp_family = PF_XROUTE, };
2034 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
2035 1.99 ad struct mbuf *m;
2036 1.99 ad
2037 1.101 ad mutex_enter(softnet_lock);
2038 1.101 ad KERNEL_LOCK(1, NULL);
2039 1.197 ozaki for (;;) {
2040 1.197 ozaki IFQ_LOCK(&ri->ri_intrq);
2041 1.133 matt IF_DEQUEUE(&ri->ri_intrq, m);
2042 1.197 ozaki IFQ_UNLOCK(&ri->ri_intrq);
2043 1.99 ad if (m == NULL)
2044 1.99 ad break;
2045 1.100 yamt proto.sp_protocol = M_GETCTX(m, uintptr_t);
2046 1.133 matt raw_input(m, &proto, &ri->ri_src, &ri->ri_dst);
2047 1.99 ad }
2048 1.101 ad KERNEL_UNLOCK_ONE(NULL);
2049 1.101 ad mutex_exit(softnet_lock);
2050 1.99 ad }
2051 1.99 ad
2052 1.99 ad /*
2053 1.99 ad * Enqueue a message to the software interrupt routine.
2054 1.99 ad */
2055 1.120 christos void
2056 1.133 matt COMPATNAME(route_enqueue)(struct mbuf *m, int family)
2057 1.99 ad {
2058 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
2059 1.197 ozaki int wasempty;
2060 1.99 ad
2061 1.197 ozaki IFQ_LOCK(&ri->ri_intrq);
2062 1.133 matt if (IF_QFULL(&ri->ri_intrq)) {
2063 1.133 matt IF_DROP(&ri->ri_intrq);
2064 1.197 ozaki IFQ_UNLOCK(&ri->ri_intrq);
2065 1.99 ad m_freem(m);
2066 1.99 ad } else {
2067 1.133 matt wasempty = IF_IS_EMPTY(&ri->ri_intrq);
2068 1.99 ad M_SETCTX(m, (uintptr_t)family);
2069 1.133 matt IF_ENQUEUE(&ri->ri_intrq, m);
2070 1.197 ozaki IFQ_UNLOCK(&ri->ri_intrq);
2071 1.197 ozaki if (wasempty) {
2072 1.197 ozaki kpreempt_disable();
2073 1.133 matt softint_schedule(ri->ri_sih);
2074 1.197 ozaki kpreempt_enable();
2075 1.197 ozaki }
2076 1.99 ad }
2077 1.99 ad }
2078 1.99 ad
2079 1.133 matt static void
2080 1.133 matt COMPATNAME(route_init)(void)
2081 1.99 ad {
2082 1.133 matt struct route_info * const ri = &COMPATNAME(route_info);
2083 1.133 matt
2084 1.133 matt #ifndef COMPAT_RTSOCK
2085 1.133 matt rt_init();
2086 1.133 matt #endif
2087 1.99 ad
2088 1.127 pooka sysctl_net_route_setup(NULL);
2089 1.133 matt ri->ri_intrq.ifq_maxlen = ri->ri_maxqlen;
2090 1.133 matt ri->ri_sih = softint_establish(SOFTINT_NET | SOFTINT_MPSAFE,
2091 1.133 matt COMPATNAME(route_intr), NULL);
2092 1.197 ozaki IFQ_LOCK_INIT(&ri->ri_intrq);
2093 1.99 ad }
2094 1.99 ad
2095 1.99 ad /*
2096 1.1 cgd * Definitions of protocols supported in the ROUTE domain.
2097 1.1 cgd */
2098 1.133 matt #ifndef COMPAT_RTSOCK
2099 1.146 rmind PR_WRAP_USRREQS(route);
2100 1.133 matt #else
2101 1.146 rmind PR_WRAP_USRREQS(compat_50_route);
2102 1.133 matt #endif
2103 1.1 cgd
2104 1.144 rmind static const struct pr_usrreqs route_usrreqs = {
2105 1.146 rmind .pr_attach = COMPATNAME(route_attach_wrapper),
2106 1.146 rmind .pr_detach = COMPATNAME(route_detach_wrapper),
2107 1.155 rtr .pr_accept = COMPATNAME(route_accept_wrapper),
2108 1.157 rtr .pr_bind = COMPATNAME(route_bind_wrapper),
2109 1.157 rtr .pr_listen = COMPATNAME(route_listen_wrapper),
2110 1.158 rtr .pr_connect = COMPATNAME(route_connect_wrapper),
2111 1.163 rtr .pr_connect2 = COMPATNAME(route_connect2_wrapper),
2112 1.159 rtr .pr_disconnect = COMPATNAME(route_disconnect_wrapper),
2113 1.159 rtr .pr_shutdown = COMPATNAME(route_shutdown_wrapper),
2114 1.159 rtr .pr_abort = COMPATNAME(route_abort_wrapper),
2115 1.148 rtr .pr_ioctl = COMPATNAME(route_ioctl_wrapper),
2116 1.150 rtr .pr_stat = COMPATNAME(route_stat_wrapper),
2117 1.154 rtr .pr_peeraddr = COMPATNAME(route_peeraddr_wrapper),
2118 1.154 rtr .pr_sockaddr = COMPATNAME(route_sockaddr_wrapper),
2119 1.162 rtr .pr_rcvd = COMPATNAME(route_rcvd_wrapper),
2120 1.156 rtr .pr_recvoob = COMPATNAME(route_recvoob_wrapper),
2121 1.161 rtr .pr_send = COMPATNAME(route_send_wrapper),
2122 1.156 rtr .pr_sendoob = COMPATNAME(route_sendoob_wrapper),
2123 1.163 rtr .pr_purgeif = COMPATNAME(route_purgeif_wrapper),
2124 1.144 rmind };
2125 1.144 rmind
2126 1.177 riastrad static const struct protosw COMPATNAME(route_protosw)[] = {
2127 1.92 matt {
2128 1.92 matt .pr_type = SOCK_RAW,
2129 1.133 matt .pr_domain = &COMPATNAME(routedomain),
2130 1.92 matt .pr_flags = PR_ATOMIC|PR_ADDR,
2131 1.92 matt .pr_input = raw_input,
2132 1.92 matt .pr_ctlinput = raw_ctlinput,
2133 1.212 roy .pr_ctloutput = route_ctloutput,
2134 1.144 rmind .pr_usrreqs = &route_usrreqs,
2135 1.92 matt .pr_init = raw_init,
2136 1.92 matt },
2137 1.92 matt };
2138 1.69 matt
2139 1.133 matt struct domain COMPATNAME(routedomain) = {
2140 1.133 matt .dom_family = PF_XROUTE,
2141 1.133 matt .dom_name = DOMAINNAME,
2142 1.133 matt .dom_init = COMPATNAME(route_init),
2143 1.133 matt .dom_protosw = COMPATNAME(route_protosw),
2144 1.177 riastrad .dom_protoswNPROTOSW =
2145 1.177 riastrad &COMPATNAME(route_protosw)[__arraycount(COMPATNAME(route_protosw))],
2146 1.1 cgd };
2147 1.1 cgd
2148 1.127 pooka static void
2149 1.127 pooka sysctl_net_route_setup(struct sysctllog **clog)
2150 1.65 atatat {
2151 1.85 elad const struct sysctlnode *rnode = NULL;
2152 1.85 elad
2153 1.85 elad sysctl_createv(clog, 0, NULL, &rnode,
2154 1.67 atatat CTLFLAG_PERMANENT,
2155 1.133 matt CTLTYPE_NODE, DOMAINNAME,
2156 1.71 atatat SYSCTL_DESCR("PF_ROUTE information"),
2157 1.65 atatat NULL, 0, NULL, 0,
2158 1.133 matt CTL_NET, PF_XROUTE, CTL_EOL);
2159 1.133 matt
2160 1.67 atatat sysctl_createv(clog, 0, NULL, NULL,
2161 1.67 atatat CTLFLAG_PERMANENT,
2162 1.71 atatat CTLTYPE_NODE, "rtable",
2163 1.71 atatat SYSCTL_DESCR("Routing table information"),
2164 1.65 atatat sysctl_rtable, 0, NULL, 0,
2165 1.133 matt CTL_NET, PF_XROUTE, 0 /* any protocol */, CTL_EOL);
2166 1.133 matt
2167 1.85 elad sysctl_createv(clog, 0, &rnode, NULL,
2168 1.85 elad CTLFLAG_PERMANENT,
2169 1.85 elad CTLTYPE_STRUCT, "stats",
2170 1.85 elad SYSCTL_DESCR("Routing statistics"),
2171 1.85 elad NULL, 0, &rtstat, sizeof(rtstat),
2172 1.85 elad CTL_CREATE, CTL_EOL);
2173 1.65 atatat }
2174