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