Home | History | Annotate | Line # | Download | only in netinet
raw_ip.c revision 1.144
      1 /*	$NetBSD: raw_ip.c,v 1.144 2014/08/08 03:05:45 rtr Exp $	*/
      2 
      3 /*
      4  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
      5  * All rights reserved.
      6  *
      7  * Redistribution and use in source and binary forms, with or without
      8  * modification, are permitted provided that the following conditions
      9  * are met:
     10  * 1. Redistributions of source code must retain the above copyright
     11  *    notice, this list of conditions and the following disclaimer.
     12  * 2. Redistributions in binary form must reproduce the above copyright
     13  *    notice, this list of conditions and the following disclaimer in the
     14  *    documentation and/or other materials provided with the distribution.
     15  * 3. Neither the name of the project nor the names of its contributors
     16  *    may be used to endorse or promote products derived from this software
     17  *    without specific prior written permission.
     18  *
     19  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     20  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     23  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29  * SUCH DAMAGE.
     30  */
     31 
     32 /*
     33  * Copyright (c) 1982, 1986, 1988, 1993
     34  *	The Regents of the University of California.  All rights reserved.
     35  *
     36  * Redistribution and use in source and binary forms, with or without
     37  * modification, are permitted provided that the following conditions
     38  * are met:
     39  * 1. Redistributions of source code must retain the above copyright
     40  *    notice, this list of conditions and the following disclaimer.
     41  * 2. Redistributions in binary form must reproduce the above copyright
     42  *    notice, this list of conditions and the following disclaimer in the
     43  *    documentation and/or other materials provided with the distribution.
     44  * 3. Neither the name of the University nor the names of its contributors
     45  *    may be used to endorse or promote products derived from this software
     46  *    without specific prior written permission.
     47  *
     48  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     49  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     50  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     51  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     52  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     53  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     54  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     55  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     56  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     57  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     58  * SUCH DAMAGE.
     59  *
     60  *	@(#)raw_ip.c	8.7 (Berkeley) 5/15/95
     61  */
     62 
     63 /*
     64  * Raw interface to IP protocol.
     65  */
     66 
     67 #include <sys/cdefs.h>
     68 __KERNEL_RCSID(0, "$NetBSD: raw_ip.c,v 1.144 2014/08/08 03:05:45 rtr Exp $");
     69 
     70 #include "opt_inet.h"
     71 #include "opt_compat_netbsd.h"
     72 #include "opt_ipsec.h"
     73 #include "opt_mrouting.h"
     74 
     75 #include <sys/param.h>
     76 #include <sys/sysctl.h>
     77 #include <sys/malloc.h>
     78 #include <sys/mbuf.h>
     79 #include <sys/socket.h>
     80 #include <sys/protosw.h>
     81 #include <sys/socketvar.h>
     82 #include <sys/errno.h>
     83 #include <sys/systm.h>
     84 #include <sys/proc.h>
     85 #include <sys/kauth.h>
     86 
     87 #include <net/if.h>
     88 #include <net/route.h>
     89 
     90 #include <netinet/in.h>
     91 #include <netinet/in_systm.h>
     92 #include <netinet/ip.h>
     93 #include <netinet/ip_var.h>
     94 #include <netinet/ip_private.h>
     95 #include <netinet/ip_mroute.h>
     96 #include <netinet/ip_icmp.h>
     97 #include <netinet/in_pcb.h>
     98 #include <netinet/in_proto.h>
     99 #include <netinet/in_var.h>
    100 
    101 #ifdef IPSEC
    102 #include <netipsec/ipsec.h>
    103 #include <netipsec/ipsec_var.h>
    104 #include <netipsec/ipsec_private.h>
    105 #endif	/* IPSEC */
    106 
    107 #ifdef COMPAT_50
    108 #include <compat/sys/socket.h>
    109 #endif
    110 
    111 struct inpcbtable rawcbtable;
    112 
    113 int	 rip_pcbnotify(struct inpcbtable *, struct in_addr,
    114     struct in_addr, int, int, void (*)(struct inpcb *, int));
    115 int	 rip_connect_pcb(struct inpcb *, struct mbuf *);
    116 static void	 rip_disconnect1(struct inpcb *);
    117 
    118 static void sysctl_net_inet_raw_setup(struct sysctllog **);
    119 
    120 /*
    121  * Nominal space allocated to a raw ip socket.
    122  */
    123 #define	RIPSNDQ		8192
    124 #define	RIPRCVQ		8192
    125 
    126 static u_long		rip_sendspace = RIPSNDQ;
    127 static u_long		rip_recvspace = RIPRCVQ;
    128 
    129 /*
    130  * Raw interface to IP protocol.
    131  */
    132 
    133 /*
    134  * Initialize raw connection block q.
    135  */
    136 void
    137 rip_init(void)
    138 {
    139 
    140 	sysctl_net_inet_raw_setup(NULL);
    141 	in_pcbinit(&rawcbtable, 1, 1);
    142 }
    143 
    144 static void
    145 rip_sbappendaddr(struct inpcb *last, struct ip *ip, const struct sockaddr *sa,
    146     int hlen, struct mbuf *opts, struct mbuf *n)
    147 {
    148 	if (last->inp_flags & INP_NOHEADER)
    149 		m_adj(n, hlen);
    150 	if (last->inp_flags & INP_CONTROLOPTS
    151 #ifdef SO_OTIMESTAMP
    152 	    || last->inp_socket->so_options & SO_OTIMESTAMP
    153 #endif
    154 	    || last->inp_socket->so_options & SO_TIMESTAMP)
    155 		ip_savecontrol(last, &opts, ip, n);
    156 	if (sbappendaddr(&last->inp_socket->so_rcv, sa, n, opts) == 0) {
    157 		/* should notify about lost packet */
    158 		m_freem(n);
    159 		if (opts)
    160 			m_freem(opts);
    161 	} else
    162 		sorwakeup(last->inp_socket);
    163 }
    164 
    165 /*
    166  * Setup generic address and protocol structures
    167  * for raw_input routine, then pass them along with
    168  * mbuf chain.
    169  */
    170 void
    171 rip_input(struct mbuf *m, ...)
    172 {
    173 	int hlen, proto;
    174 	struct ip *ip = mtod(m, struct ip *);
    175 	struct inpcb_hdr *inph;
    176 	struct inpcb *inp;
    177 	struct inpcb *last = NULL;
    178 	struct mbuf *n, *opts = NULL;
    179 	struct sockaddr_in ripsrc;
    180 	va_list ap;
    181 
    182 	va_start(ap, m);
    183 	(void)va_arg(ap, int);		/* ignore value, advance ap */
    184 	proto = va_arg(ap, int);
    185 	va_end(ap);
    186 
    187 	sockaddr_in_init(&ripsrc, &ip->ip_src, 0);
    188 
    189 	/*
    190 	 * XXX Compatibility: programs using raw IP expect ip_len
    191 	 * XXX to have the header length subtracted, and in host order.
    192 	 * XXX ip_off is also expected to be host order.
    193 	 */
    194 	hlen = ip->ip_hl << 2;
    195 	ip->ip_len = ntohs(ip->ip_len) - hlen;
    196 	NTOHS(ip->ip_off);
    197 
    198 	TAILQ_FOREACH(inph, &rawcbtable.inpt_queue, inph_queue) {
    199 		inp = (struct inpcb *)inph;
    200 		if (inp->inp_af != AF_INET)
    201 			continue;
    202 		if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != proto)
    203 			continue;
    204 		if (!in_nullhost(inp->inp_laddr) &&
    205 		    !in_hosteq(inp->inp_laddr, ip->ip_dst))
    206 			continue;
    207 		if (!in_nullhost(inp->inp_faddr) &&
    208 		    !in_hosteq(inp->inp_faddr, ip->ip_src))
    209 			continue;
    210 		if (last == NULL)
    211 			;
    212 #if defined(IPSEC)
    213 		/* check AH/ESP integrity. */
    214 		else if (ipsec_used &&
    215 		    ipsec4_in_reject_so(m, last->inp_socket)) {
    216 			IPSEC_STATINC(IPSEC_STAT_IN_POLVIO);
    217 			/* do not inject data to pcb */
    218 		}
    219 #endif /*IPSEC*/
    220 		else if ((n = m_copypacket(m, M_DONTWAIT)) != NULL) {
    221 			rip_sbappendaddr(last, ip, sintosa(&ripsrc), hlen, opts,
    222 			    n);
    223 			opts = NULL;
    224 		}
    225 		last = inp;
    226 	}
    227 #if defined(IPSEC)
    228 	/* check AH/ESP integrity. */
    229 	if (ipsec_used && last != NULL
    230 	    && ipsec4_in_reject_so(m, last->inp_socket)) {
    231 		m_freem(m);
    232 		IPSEC_STATINC(IPSEC_STAT_IN_POLVIO);
    233 		IP_STATDEC(IP_STAT_DELIVERED);
    234 		/* do not inject data to pcb */
    235 	} else
    236 #endif /*IPSEC*/
    237 	if (last != NULL)
    238 		rip_sbappendaddr(last, ip, sintosa(&ripsrc), hlen, opts, m);
    239 	else if (inetsw[ip_protox[ip->ip_p]].pr_input == rip_input) {
    240 		uint64_t *ips;
    241 
    242 		icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_PROTOCOL,
    243 		    0, 0);
    244 		ips = IP_STAT_GETREF();
    245 		ips[IP_STAT_NOPROTO]++;
    246 		ips[IP_STAT_DELIVERED]--;
    247 		IP_STAT_PUTREF();
    248 	} else
    249 		m_freem(m);
    250 	return;
    251 }
    252 
    253 int
    254 rip_pcbnotify(struct inpcbtable *table,
    255     struct in_addr faddr, struct in_addr laddr, int proto, int errno,
    256     void (*notify)(struct inpcb *, int))
    257 {
    258 	struct inpcb_hdr *inph, *ninph;
    259 	int nmatch;
    260 
    261 	nmatch = 0;
    262 	TAILQ_FOREACH_SAFE(inph, &table->inpt_queue, inph_queue, ninph) {
    263 		struct inpcb *inp = (struct inpcb *)inph;
    264 		if (inp->inp_af != AF_INET)
    265 			continue;
    266 		if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != proto)
    267 			continue;
    268 		if (in_hosteq(inp->inp_faddr, faddr) &&
    269 		    in_hosteq(inp->inp_laddr, laddr)) {
    270 			(*notify)(inp, errno);
    271 			nmatch++;
    272 		}
    273 	}
    274 
    275 	return nmatch;
    276 }
    277 
    278 void *
    279 rip_ctlinput(int cmd, const struct sockaddr *sa, void *v)
    280 {
    281 	struct ip *ip = v;
    282 	void (*notify)(struct inpcb *, int) = in_rtchange;
    283 	int errno;
    284 
    285 	if (sa->sa_family != AF_INET ||
    286 	    sa->sa_len != sizeof(struct sockaddr_in))
    287 		return NULL;
    288 	if ((unsigned)cmd >= PRC_NCMDS)
    289 		return NULL;
    290 	errno = inetctlerrmap[cmd];
    291 	if (PRC_IS_REDIRECT(cmd))
    292 		notify = in_rtchange, ip = 0;
    293 	else if (cmd == PRC_HOSTDEAD)
    294 		ip = 0;
    295 	else if (errno == 0)
    296 		return NULL;
    297 	if (ip) {
    298 		rip_pcbnotify(&rawcbtable, satocsin(sa)->sin_addr,
    299 		    ip->ip_src, ip->ip_p, errno, notify);
    300 
    301 		/* XXX mapped address case */
    302 	} else
    303 		in_pcbnotifyall(&rawcbtable, satocsin(sa)->sin_addr, errno,
    304 		    notify);
    305 	return NULL;
    306 }
    307 
    308 /*
    309  * Generate IP header and pass packet to ip_output.
    310  * Tack on options user may have setup with control call.
    311  */
    312 int
    313 rip_output(struct mbuf *m, ...)
    314 {
    315 	struct inpcb *inp;
    316 	struct ip *ip;
    317 	struct mbuf *opts;
    318 	int flags;
    319 	va_list ap;
    320 
    321 	va_start(ap, m);
    322 	inp = va_arg(ap, struct inpcb *);
    323 	va_end(ap);
    324 
    325 	flags =
    326 	    (inp->inp_socket->so_options & SO_DONTROUTE) | IP_ALLOWBROADCAST
    327 	    | IP_RETURNMTU;
    328 
    329 	/*
    330 	 * If the user handed us a complete IP packet, use it.
    331 	 * Otherwise, allocate an mbuf for a header and fill it in.
    332 	 */
    333 	if ((inp->inp_flags & INP_HDRINCL) == 0) {
    334 		if ((m->m_pkthdr.len + sizeof(struct ip)) > IP_MAXPACKET) {
    335 			m_freem(m);
    336 			return (EMSGSIZE);
    337 		}
    338 		M_PREPEND(m, sizeof(struct ip), M_DONTWAIT);
    339 		if (!m)
    340 			return (ENOBUFS);
    341 		ip = mtod(m, struct ip *);
    342 		ip->ip_tos = 0;
    343 		ip->ip_off = htons(0);
    344 		ip->ip_p = inp->inp_ip.ip_p;
    345 		ip->ip_len = htons(m->m_pkthdr.len);
    346 		ip->ip_src = inp->inp_laddr;
    347 		ip->ip_dst = inp->inp_faddr;
    348 		ip->ip_ttl = MAXTTL;
    349 		opts = inp->inp_options;
    350 	} else {
    351 		if (m->m_pkthdr.len > IP_MAXPACKET) {
    352 			m_freem(m);
    353 			return (EMSGSIZE);
    354 		}
    355 		ip = mtod(m, struct ip *);
    356 
    357 		/*
    358 		 * If the mbuf is read-only, we need to allocate
    359 		 * a new mbuf for the header, since we need to
    360 		 * modify the header.
    361 		 */
    362 		if (M_READONLY(m)) {
    363 			int hlen = ip->ip_hl << 2;
    364 
    365 			m = m_copyup(m, hlen, (max_linkhdr + 3) & ~3);
    366 			if (m == NULL)
    367 				return (ENOMEM);	/* XXX */
    368 			ip = mtod(m, struct ip *);
    369 		}
    370 
    371 		/* XXX userland passes ip_len and ip_off in host order */
    372 		if (m->m_pkthdr.len != ip->ip_len) {
    373 			m_freem(m);
    374 			return (EINVAL);
    375 		}
    376 		HTONS(ip->ip_len);
    377 		HTONS(ip->ip_off);
    378 		if (ip->ip_id != 0 || m->m_pkthdr.len < IP_MINFRAGSIZE)
    379 			flags |= IP_NOIPNEWID;
    380 		opts = NULL;
    381 		/* XXX prevent ip_output from overwriting header fields */
    382 		flags |= IP_RAWOUTPUT;
    383 		IP_STATINC(IP_STAT_RAWOUT);
    384 	}
    385 
    386 	/*
    387 	 * IP output.  Note: if IP_RETURNMTU flag is set, the MTU size
    388 	 * will be stored in inp_errormtu.
    389 	 */
    390 	return ip_output(m, opts, &inp->inp_route, flags, inp->inp_moptions,
    391 	     inp->inp_socket);
    392 }
    393 
    394 /*
    395  * Raw IP socket option processing.
    396  */
    397 int
    398 rip_ctloutput(int op, struct socket *so, struct sockopt *sopt)
    399 {
    400 	struct inpcb *inp = sotoinpcb(so);
    401 	int error = 0;
    402 	int optval;
    403 
    404 	if (sopt->sopt_level == SOL_SOCKET && sopt->sopt_name == SO_NOHEADER) {
    405 		if (op == PRCO_GETOPT) {
    406 			optval = (inp->inp_flags & INP_NOHEADER) ? 1 : 0;
    407 			error = sockopt_set(sopt, &optval, sizeof(optval));
    408 		} else if (op == PRCO_SETOPT) {
    409 			error = sockopt_getint(sopt, &optval);
    410 			if (error)
    411 				goto out;
    412 			if (optval) {
    413 				inp->inp_flags &= ~INP_HDRINCL;
    414 				inp->inp_flags |= INP_NOHEADER;
    415 			} else
    416 				inp->inp_flags &= ~INP_NOHEADER;
    417 		}
    418 		goto out;
    419 	} else if (sopt->sopt_level != IPPROTO_IP)
    420 		return ip_ctloutput(op, so, sopt);
    421 
    422 	switch (op) {
    423 
    424 	case PRCO_SETOPT:
    425 		switch (sopt->sopt_name) {
    426 		case IP_HDRINCL:
    427 			error = sockopt_getint(sopt, &optval);
    428 			if (error)
    429 				break;
    430 			if (optval)
    431 				inp->inp_flags |= INP_HDRINCL;
    432 			else
    433 				inp->inp_flags &= ~INP_HDRINCL;
    434 			break;
    435 
    436 #ifdef MROUTING
    437 		case MRT_INIT:
    438 		case MRT_DONE:
    439 		case MRT_ADD_VIF:
    440 		case MRT_DEL_VIF:
    441 		case MRT_ADD_MFC:
    442 		case MRT_DEL_MFC:
    443 		case MRT_ASSERT:
    444 		case MRT_API_CONFIG:
    445 		case MRT_ADD_BW_UPCALL:
    446 		case MRT_DEL_BW_UPCALL:
    447 			error = ip_mrouter_set(so, sopt);
    448 			break;
    449 #endif
    450 
    451 		default:
    452 			error = ip_ctloutput(op, so, sopt);
    453 			break;
    454 		}
    455 		break;
    456 
    457 	case PRCO_GETOPT:
    458 		switch (sopt->sopt_name) {
    459 		case IP_HDRINCL:
    460 			optval = inp->inp_flags & INP_HDRINCL;
    461 			error = sockopt_set(sopt, &optval, sizeof(optval));
    462 			break;
    463 
    464 #ifdef MROUTING
    465 		case MRT_VERSION:
    466 		case MRT_ASSERT:
    467 		case MRT_API_SUPPORT:
    468 		case MRT_API_CONFIG:
    469 			error = ip_mrouter_get(so, sopt);
    470 			break;
    471 #endif
    472 
    473 		default:
    474 			error = ip_ctloutput(op, so, sopt);
    475 			break;
    476 		}
    477 		break;
    478 	}
    479  out:
    480 	return error;
    481 }
    482 
    483 int
    484 rip_connect_pcb(struct inpcb *inp, struct mbuf *nam)
    485 {
    486 	struct sockaddr_in *addr = mtod(nam, struct sockaddr_in *);
    487 
    488 	if (nam->m_len != sizeof(*addr))
    489 		return (EINVAL);
    490 	if (IFNET_EMPTY())
    491 		return (EADDRNOTAVAIL);
    492 	if (addr->sin_family != AF_INET)
    493 		return (EAFNOSUPPORT);
    494 	inp->inp_faddr = addr->sin_addr;
    495 	return (0);
    496 }
    497 
    498 static void
    499 rip_disconnect1(struct inpcb *inp)
    500 {
    501 
    502 	inp->inp_faddr = zeroin_addr;
    503 }
    504 
    505 static int
    506 rip_attach(struct socket *so, int proto)
    507 {
    508 	struct inpcb *inp;
    509 	int error;
    510 
    511 	KASSERT(sotoinpcb(so) == NULL);
    512 	sosetlock(so);
    513 
    514 	if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
    515 		error = soreserve(so, rip_sendspace, rip_recvspace);
    516 		if (error) {
    517 			return error;
    518 		}
    519 	}
    520 
    521 	error = in_pcballoc(so, &rawcbtable);
    522 	if (error) {
    523 		return error;
    524 	}
    525 	inp = sotoinpcb(so);
    526 	inp->inp_ip.ip_p = proto;
    527 	KASSERT(solocked(so));
    528 
    529 	return 0;
    530 }
    531 
    532 static void
    533 rip_detach(struct socket *so)
    534 {
    535 	struct inpcb *inp;
    536 
    537 	KASSERT(solocked(so));
    538 	inp = sotoinpcb(so);
    539 	KASSERT(inp != NULL);
    540 
    541 #ifdef MROUTING
    542 	extern struct socket *ip_mrouter;
    543 	if (so == ip_mrouter) {
    544 		ip_mrouter_done();
    545 	}
    546 #endif
    547 	in_pcbdetach(inp);
    548 }
    549 
    550 static int
    551 rip_accept(struct socket *so, struct mbuf *nam)
    552 {
    553 	KASSERT(solocked(so));
    554 
    555 	panic("rip_accept");
    556 
    557 	return EOPNOTSUPP;
    558 }
    559 
    560 static int
    561 rip_bind(struct socket *so, struct mbuf *nam, struct lwp *l)
    562 {
    563 	struct inpcb *inp = sotoinpcb(so);
    564 	struct sockaddr_in *addr;
    565 	int error = 0;
    566 	int s;
    567 
    568 	KASSERT(solocked(so));
    569 	KASSERT(inp != NULL);
    570 	KASSERT(nam != NULL);
    571 
    572 	s = splsoftnet();
    573 	addr = mtod(nam, struct sockaddr_in *);
    574 	if (nam->m_len != sizeof(*addr)) {
    575 		error = EINVAL;
    576 		goto release;
    577 	}
    578 	if (IFNET_EMPTY()) {
    579 		error = EADDRNOTAVAIL;
    580 		goto release;
    581 	}
    582 	if (addr->sin_family != AF_INET) {
    583 		error = EAFNOSUPPORT;
    584 		goto release;
    585 	}
    586 	if (!in_nullhost(addr->sin_addr) &&
    587 	    ifa_ifwithaddr(sintosa(addr)) == 0) {
    588 		error = EADDRNOTAVAIL;
    589 		goto release;
    590 	}
    591 	inp->inp_laddr = addr->sin_addr;
    592 
    593 release:
    594 	splx(s);
    595 	return error;
    596 }
    597 
    598 static int
    599 rip_listen(struct socket *so, struct lwp *l)
    600 {
    601 	KASSERT(solocked(so));
    602 
    603 	return EOPNOTSUPP;
    604 }
    605 
    606 static int
    607 rip_connect(struct socket *so, struct mbuf *nam, struct lwp *l)
    608 {
    609 	struct inpcb *inp = sotoinpcb(so);
    610 	int error = 0;
    611 	int s;
    612 
    613 	KASSERT(solocked(so));
    614 	KASSERT(inp != NULL);
    615 	KASSERT(nam != NULL);
    616 
    617 	s = splsoftnet();
    618 	error = rip_connect_pcb(inp, nam);
    619 	if (! error)
    620 		soisconnected(so);
    621 	splx(s);
    622 
    623 	return error;
    624 }
    625 
    626 static int
    627 rip_disconnect(struct socket *so)
    628 {
    629 	struct inpcb *inp = sotoinpcb(so);
    630 	int s;
    631 
    632 	KASSERT(solocked(so));
    633 	KASSERT(inp != NULL);
    634 
    635 	s = splsoftnet();
    636 	soisdisconnected(so);
    637 	rip_disconnect1(inp);
    638 	splx(s);
    639 
    640 	return 0;
    641 }
    642 
    643 static int
    644 rip_shutdown(struct socket *so)
    645 {
    646 	int s;
    647 
    648 	KASSERT(solocked(so));
    649 
    650 	/*
    651 	 * Mark the connection as being incapable of further input.
    652 	 */
    653 	s = splsoftnet();
    654 	socantsendmore(so);
    655 	splx(s);
    656 
    657 	return 0;
    658 }
    659 
    660 static int
    661 rip_abort(struct socket *so)
    662 {
    663 	KASSERT(solocked(so));
    664 
    665 	panic("rip_abort");
    666 
    667 	return EOPNOTSUPP;
    668 }
    669 
    670 static int
    671 rip_ioctl(struct socket *so, u_long cmd, void *nam, struct ifnet *ifp)
    672 {
    673 	return in_control(so, cmd, nam, ifp);
    674 }
    675 
    676 static int
    677 rip_stat(struct socket *so, struct stat *ub)
    678 {
    679 	KASSERT(solocked(so));
    680 
    681 	/* stat: don't bother with a blocksize. */
    682 	return 0;
    683 }
    684 
    685 static int
    686 rip_peeraddr(struct socket *so, struct mbuf *nam)
    687 {
    688 	int s;
    689 
    690 	KASSERT(solocked(so));
    691 	KASSERT(sotoinpcb(so) != NULL);
    692 	KASSERT(nam != NULL);
    693 
    694 	s = splsoftnet();
    695 	in_setpeeraddr(sotoinpcb(so), nam);
    696 	splx(s);
    697 
    698 	return 0;
    699 }
    700 
    701 static int
    702 rip_sockaddr(struct socket *so, struct mbuf *nam)
    703 {
    704 	int s;
    705 
    706 	KASSERT(solocked(so));
    707 	KASSERT(sotoinpcb(so) != NULL);
    708 	KASSERT(nam != NULL);
    709 
    710 	s = splsoftnet();
    711 	in_setsockaddr(sotoinpcb(so), nam);
    712 	splx(s);
    713 
    714 	return 0;
    715 }
    716 
    717 static int
    718 rip_rcvd(struct socket *so, int flags, struct lwp *l)
    719 {
    720 	KASSERT(solocked(so));
    721 
    722 	return EOPNOTSUPP;
    723 }
    724 
    725 static int
    726 rip_recvoob(struct socket *so, struct mbuf *m, int flags)
    727 {
    728 	KASSERT(solocked(so));
    729 
    730 	return EOPNOTSUPP;
    731 }
    732 
    733 static int
    734 rip_send(struct socket *so, struct mbuf *m, struct mbuf *nam,
    735     struct mbuf *control, struct lwp *l)
    736 {
    737 	struct inpcb *inp = sotoinpcb(so);
    738 	int error = 0;
    739 	int s;
    740 
    741 	KASSERT(solocked(so));
    742 	KASSERT(inp != NULL);
    743 	KASSERT(m != NULL);
    744 
    745 	/*
    746 	 * Ship a packet out.  The appropriate raw output
    747 	 * routine handles any massaging necessary.
    748 	 */
    749 	if (control && control->m_len) {
    750 		m_freem(control);
    751 		m_freem(m);
    752 		return EINVAL;
    753 	}
    754 
    755 	s = splsoftnet();
    756 	if (nam) {
    757 		if ((so->so_state & SS_ISCONNECTED) != 0) {
    758 			error = EISCONN;
    759 			goto die;
    760 		}
    761 		error = rip_connect_pcb(inp, nam);
    762 		if (error) {
    763 		die:
    764 			m_freem(m);
    765 			splx(s);
    766 			return error;
    767 		}
    768 	} else {
    769 		if ((so->so_state & SS_ISCONNECTED) == 0) {
    770 			error = ENOTCONN;
    771 			goto die;
    772 		}
    773 	}
    774 	error = rip_output(m, inp);
    775 	if (nam)
    776 		rip_disconnect1(inp);
    777 
    778 	splx(s);
    779 	return error;
    780 }
    781 
    782 static int
    783 rip_sendoob(struct socket *so, struct mbuf *m, struct mbuf *control)
    784 {
    785 	KASSERT(solocked(so));
    786 
    787 	m_freem(m);
    788 	m_freem(control);
    789 
    790 	return EOPNOTSUPP;
    791 }
    792 
    793 int
    794 rip_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
    795     struct mbuf *control, struct lwp *l)
    796 {
    797 	struct inpcb *inp;
    798 	int s, error = 0;
    799 
    800 	KASSERT(req != PRU_ATTACH);
    801 	KASSERT(req != PRU_DETACH);
    802 	KASSERT(req != PRU_ACCEPT);
    803 	KASSERT(req != PRU_BIND);
    804 	KASSERT(req != PRU_LISTEN);
    805 	KASSERT(req != PRU_CONNECT);
    806 	KASSERT(req != PRU_DISCONNECT);
    807 	KASSERT(req != PRU_SHUTDOWN);
    808 	KASSERT(req != PRU_ABORT);
    809 	KASSERT(req != PRU_CONTROL);
    810 	KASSERT(req != PRU_SENSE);
    811 	KASSERT(req != PRU_PEERADDR);
    812 	KASSERT(req != PRU_SOCKADDR);
    813 	KASSERT(req != PRU_RCVD);
    814 	KASSERT(req != PRU_RCVOOB);
    815 	KASSERT(req != PRU_SEND);
    816 	KASSERT(req != PRU_SENDOOB);
    817 
    818 	s = splsoftnet();
    819 	if (req == PRU_PURGEIF) {
    820 		mutex_enter(softnet_lock);
    821 		in_pcbpurgeif0(&rawcbtable, (struct ifnet *)control);
    822 		in_purgeif((struct ifnet *)control);
    823 		in_pcbpurgeif(&rawcbtable, (struct ifnet *)control);
    824 		mutex_exit(softnet_lock);
    825 		splx(s);
    826 		return 0;
    827 	}
    828 
    829 	KASSERT(solocked(so));
    830 	inp = sotoinpcb(so);
    831 
    832 	KASSERT(!control);
    833 	if (inp == NULL) {
    834 		splx(s);
    835 		return EINVAL;
    836 	}
    837 
    838 	switch (req) {
    839 
    840 	case PRU_CONNECT2:
    841 		error = EOPNOTSUPP;
    842 		break;
    843 
    844 	default:
    845 		panic("rip_usrreq");
    846 	}
    847 	splx(s);
    848 
    849 	return error;
    850 }
    851 
    852 PR_WRAP_USRREQS(rip)
    853 #define	rip_attach	rip_attach_wrapper
    854 #define	rip_detach	rip_detach_wrapper
    855 #define	rip_accept	rip_accept_wrapper
    856 #define	rip_bind	rip_bind_wrapper
    857 #define	rip_listen	rip_listen_wrapper
    858 #define	rip_connect	rip_connect_wrapper
    859 #define	rip_disconnect	rip_disconnect_wrapper
    860 #define	rip_shutdown	rip_shutdown_wrapper
    861 #define	rip_abort	rip_abort_wrapper
    862 #define	rip_ioctl	rip_ioctl_wrapper
    863 #define	rip_stat	rip_stat_wrapper
    864 #define	rip_peeraddr	rip_peeraddr_wrapper
    865 #define	rip_sockaddr	rip_sockaddr_wrapper
    866 #define	rip_rcvd	rip_rcvd_wrapper
    867 #define	rip_recvoob	rip_recvoob_wrapper
    868 #define	rip_send	rip_send_wrapper
    869 #define	rip_sendoob	rip_sendoob_wrapper
    870 #define	rip_usrreq	rip_usrreq_wrapper
    871 
    872 const struct pr_usrreqs rip_usrreqs = {
    873 	.pr_attach	= rip_attach,
    874 	.pr_detach	= rip_detach,
    875 	.pr_accept	= rip_accept,
    876 	.pr_bind	= rip_bind,
    877 	.pr_listen	= rip_listen,
    878 	.pr_connect	= rip_connect,
    879 	.pr_disconnect	= rip_disconnect,
    880 	.pr_shutdown	= rip_shutdown,
    881 	.pr_abort	= rip_abort,
    882 	.pr_ioctl	= rip_ioctl,
    883 	.pr_stat	= rip_stat,
    884 	.pr_peeraddr	= rip_peeraddr,
    885 	.pr_sockaddr	= rip_sockaddr,
    886 	.pr_rcvd	= rip_rcvd,
    887 	.pr_recvoob	= rip_recvoob,
    888 	.pr_send	= rip_send,
    889 	.pr_sendoob	= rip_sendoob,
    890 	.pr_generic	= rip_usrreq,
    891 };
    892 
    893 static void
    894 sysctl_net_inet_raw_setup(struct sysctllog **clog)
    895 {
    896 
    897 	sysctl_createv(clog, 0, NULL, NULL,
    898 		       CTLFLAG_PERMANENT,
    899 		       CTLTYPE_NODE, "inet", NULL,
    900 		       NULL, 0, NULL, 0,
    901 		       CTL_NET, PF_INET, CTL_EOL);
    902 	sysctl_createv(clog, 0, NULL, NULL,
    903 		       CTLFLAG_PERMANENT,
    904 		       CTLTYPE_NODE, "raw",
    905 		       SYSCTL_DESCR("Raw IPv4 settings"),
    906 		       NULL, 0, NULL, 0,
    907 		       CTL_NET, PF_INET, IPPROTO_RAW, CTL_EOL);
    908 
    909 	sysctl_createv(clog, 0, NULL, NULL,
    910 		       CTLFLAG_PERMANENT,
    911 		       CTLTYPE_STRUCT, "pcblist",
    912 		       SYSCTL_DESCR("Raw IPv4 control block list"),
    913 		       sysctl_inpcblist, 0, &rawcbtable, 0,
    914 		       CTL_NET, PF_INET, IPPROTO_RAW,
    915 		       CTL_CREATE, CTL_EOL);
    916 }
    917