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