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