xref: /freebsd/sys/netinet6/raw_ip6.c (revision 6af83ee0d2941d18880b6aaa2b4facd1d30c6106)
1 /*-
2  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. Neither the name of the project nor the names of its contributors
14  *    may be used to endorse or promote products derived from this software
15  *    without specific prior written permission.
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
21  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27  * SUCH DAMAGE.
28  *
29  * $FreeBSD$
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  * 4. 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.2 (Berkeley) 1/4/94
61  */
62 
63 #include "opt_ipsec.h"
64 #include "opt_inet6.h"
65 
66 #include <sys/param.h>
67 #include <sys/errno.h>
68 #include <sys/lock.h>
69 #include <sys/malloc.h>
70 #include <sys/mbuf.h>
71 #include <sys/proc.h>
72 #include <sys/protosw.h>
73 #include <sys/signalvar.h>
74 #include <sys/socket.h>
75 #include <sys/socketvar.h>
76 #include <sys/sx.h>
77 #include <sys/systm.h>
78 
79 #include <net/if.h>
80 #include <net/if_types.h>
81 #include <net/route.h>
82 
83 #include <netinet/in.h>
84 #include <netinet/in_var.h>
85 #include <netinet/in_systm.h>
86 #include <netinet/icmp6.h>
87 #include <netinet/in_pcb.h>
88 #include <netinet/ip6.h>
89 #include <netinet6/ip6protosw.h>
90 #include <netinet6/ip6_mroute.h>
91 #include <netinet6/in6_pcb.h>
92 #include <netinet6/ip6_var.h>
93 #include <netinet6/nd6.h>
94 #include <netinet6/raw_ip6.h>
95 #ifdef ENABLE_DEFAULT_SCOPE
96 #include <netinet6/scope6_var.h>
97 #endif
98 
99 #ifdef IPSEC
100 #include <netinet6/ipsec.h>
101 #include <netinet6/ipsec6.h>
102 #endif /*IPSEC*/
103 
104 #ifdef FAST_IPSEC
105 #include <netipsec/ipsec.h>
106 #include <netipsec/ipsec6.h>
107 #endif /* FAST_IPSEC */
108 
109 #include <machine/stdarg.h>
110 
111 #define	satosin6(sa)	((struct sockaddr_in6 *)(sa))
112 #define	ifatoia6(ifa)	((struct in6_ifaddr *)(ifa))
113 
114 /*
115  * Raw interface to IP6 protocol.
116  */
117 
118 extern struct	inpcbhead ripcb;
119 extern struct	inpcbinfo ripcbinfo;
120 extern u_long	rip_sendspace;
121 extern u_long	rip_recvspace;
122 
123 struct rip6stat rip6stat;
124 
125 /*
126  * Setup generic address and protocol structures
127  * for raw_input routine, then pass them along with
128  * mbuf chain.
129  */
130 int
131 rip6_input(mp, offp, proto)
132 	struct	mbuf **mp;
133 	int	*offp, proto;
134 {
135 	struct mbuf *m = *mp;
136 	register struct ip6_hdr *ip6 = mtod(m, struct ip6_hdr *);
137 	register struct inpcb *in6p;
138 	struct inpcb *last = 0;
139 	struct mbuf *opts = NULL;
140 	struct sockaddr_in6 fromsa;
141 
142 	rip6stat.rip6s_ipackets++;
143 
144 	if (faithprefix_p != NULL && (*faithprefix_p)(&ip6->ip6_dst)) {
145 		/* XXX send icmp6 host/port unreach? */
146 		m_freem(m);
147 		return IPPROTO_DONE;
148 	}
149 
150 	init_sin6(&fromsa, m); /* general init */
151 
152 	INP_INFO_RLOCK(&ripcbinfo);
153 	LIST_FOREACH(in6p, &ripcb, inp_list) {
154 		INP_LOCK(in6p);
155 		if ((in6p->in6p_vflag & INP_IPV6) == 0) {
156 docontinue:
157 			INP_UNLOCK(in6p);
158 			continue;
159 		}
160 		if (in6p->in6p_ip6_nxt &&
161 		    in6p->in6p_ip6_nxt != proto)
162 			goto docontinue;
163 		if (!IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr) &&
164 		    !IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, &ip6->ip6_dst))
165 			goto docontinue;
166 		if (!IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_faddr) &&
167 		    !IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr, &ip6->ip6_src))
168 			goto docontinue;
169 		if (in6p->in6p_cksum != -1) {
170 			rip6stat.rip6s_isum++;
171 			if (in6_cksum(m, ip6->ip6_nxt, *offp,
172 			    m->m_pkthdr.len - *offp)) {
173 				rip6stat.rip6s_badsum++;
174 				goto docontinue;
175 			}
176 		}
177 		if (last) {
178 			struct mbuf *n = m_copy(m, 0, (int)M_COPYALL);
179 
180 #if defined(IPSEC) || defined(FAST_IPSEC)
181 			/*
182 			 * Check AH/ESP integrity.
183 			 */
184 			if (n && ipsec6_in_reject(n, last)) {
185 				m_freem(n);
186 #ifdef IPSEC
187 				ipsec6stat.in_polvio++;
188 #endif /*IPSEC*/
189 				/* do not inject data into pcb */
190 			} else
191 #endif /*IPSEC || FAST_IPSEC*/
192 			if (n) {
193 				if (last->in6p_flags & IN6P_CONTROLOPTS ||
194 				    last->in6p_socket->so_options & SO_TIMESTAMP)
195 					ip6_savecontrol(last, n, &opts);
196 				/* strip intermediate headers */
197 				m_adj(n, *offp);
198 				if (sbappendaddr(&last->in6p_socket->so_rcv,
199 						(struct sockaddr *)&fromsa,
200 						 n, opts) == 0) {
201 					m_freem(n);
202 					if (opts)
203 						m_freem(opts);
204 					rip6stat.rip6s_fullsock++;
205 				} else
206 					sorwakeup(last->in6p_socket);
207 				opts = NULL;
208 			}
209 			INP_UNLOCK(last);
210 		}
211 		last = in6p;
212 	}
213 #if defined(IPSEC) || defined(FAST_IPSEC)
214 	/*
215 	 * Check AH/ESP integrity.
216 	 */
217 	if (last && ipsec6_in_reject(m, last)) {
218 		m_freem(m);
219 #ifdef IPSEC
220 		ipsec6stat.in_polvio++;
221 #endif /*IPSEC*/
222 		ip6stat.ip6s_delivered--;
223 		/* do not inject data into pcb */
224 	} else
225 #endif /*IPSEC || FAST_IPSEC*/
226 	if (last) {
227 		if (last->in6p_flags & IN6P_CONTROLOPTS ||
228 		    last->in6p_socket->so_options & SO_TIMESTAMP)
229 			ip6_savecontrol(last, m, &opts);
230 		/* strip intermediate headers */
231 		m_adj(m, *offp);
232 		if (sbappendaddr(&last->in6p_socket->so_rcv,
233 				(struct sockaddr *)&fromsa, m, opts) == 0) {
234 			m_freem(m);
235 			if (opts)
236 				m_freem(opts);
237 			rip6stat.rip6s_fullsock++;
238 		} else
239 			sorwakeup(last->in6p_socket);
240 		INP_UNLOCK(last);
241 	} else {
242 		rip6stat.rip6s_nosock++;
243 		if (m->m_flags & M_MCAST)
244 			rip6stat.rip6s_nosockmcast++;
245 		if (proto == IPPROTO_NONE)
246 			m_freem(m);
247 		else {
248 			char *prvnxtp = ip6_get_prevhdr(m, *offp); /* XXX */
249 			icmp6_error(m, ICMP6_PARAM_PROB,
250 				    ICMP6_PARAMPROB_NEXTHEADER,
251 				    prvnxtp - mtod(m, char *));
252 		}
253 		ip6stat.ip6s_delivered--;
254 	}
255 	INP_INFO_RUNLOCK(&ripcbinfo);
256 	return IPPROTO_DONE;
257 }
258 
259 void
260 rip6_ctlinput(cmd, sa, d)
261 	int cmd;
262 	struct sockaddr *sa;
263 	void *d;
264 {
265 	struct ip6_hdr *ip6;
266 	struct mbuf *m;
267 	int off = 0;
268 	struct ip6ctlparam *ip6cp = NULL;
269 	const struct sockaddr_in6 *sa6_src = NULL;
270 	void *cmdarg;
271 	struct inpcb *(*notify) __P((struct inpcb *, int)) = in6_rtchange;
272 
273 	if (sa->sa_family != AF_INET6 ||
274 	    sa->sa_len != sizeof(struct sockaddr_in6))
275 		return;
276 
277 	if ((unsigned)cmd >= PRC_NCMDS)
278 		return;
279 	if (PRC_IS_REDIRECT(cmd))
280 		notify = in6_rtchange, d = NULL;
281 	else if (cmd == PRC_HOSTDEAD)
282 		d = NULL;
283 	else if (inet6ctlerrmap[cmd] == 0)
284 		return;
285 
286 	/* if the parameter is from icmp6, decode it. */
287 	if (d != NULL) {
288 		ip6cp = (struct ip6ctlparam *)d;
289 		m = ip6cp->ip6c_m;
290 		ip6 = ip6cp->ip6c_ip6;
291 		off = ip6cp->ip6c_off;
292 		cmdarg = ip6cp->ip6c_cmdarg;
293 		sa6_src = ip6cp->ip6c_src;
294 	} else {
295 		m = NULL;
296 		ip6 = NULL;
297 		cmdarg = NULL;
298 		sa6_src = &sa6_any;
299 	}
300 
301 	(void) in6_pcbnotify(&ripcbinfo, sa, 0,
302 			     (const struct sockaddr *)sa6_src,
303 			     0, cmd, cmdarg, notify);
304 }
305 
306 /*
307  * Generate IPv6 header and pass packet to ip6_output.
308  * Tack on options user may have setup with control call.
309  */
310 int
311 #if __STDC__
312 rip6_output(struct mbuf *m, ...)
313 #else
314 rip6_output(m, va_alist)
315 	struct mbuf *m;
316 	va_dcl
317 #endif
318 {
319 	struct mbuf *control;
320 	struct socket *so;
321 	struct sockaddr_in6 *dstsock;
322 	struct in6_addr *dst;
323 	struct ip6_hdr *ip6;
324 	struct inpcb *in6p;
325 	u_int	plen = m->m_pkthdr.len;
326 	int error = 0;
327 	struct ip6_pktopts opt, *stickyopt = NULL;
328 	struct ifnet *oifp = NULL;
329 	int type = 0, code = 0;		/* for ICMPv6 output statistics only */
330 	int priv = 0;
331 	struct in6_addr *in6a;
332 	va_list ap;
333 
334 	va_start(ap, m);
335 	so = va_arg(ap, struct socket *);
336 	dstsock = va_arg(ap, struct sockaddr_in6 *);
337 	control = va_arg(ap, struct mbuf *);
338 	va_end(ap);
339 
340 	in6p = sotoin6pcb(so);
341 	INP_LOCK(in6p);
342 	stickyopt = in6p->in6p_outputopts;
343 
344 	priv = 0;
345 	if (so->so_cred->cr_uid == 0)
346 		priv = 1;
347 	dst = &dstsock->sin6_addr;
348 	if (control) {
349 		if ((error = ip6_setpktoptions(control, &opt,
350 					       stickyopt, priv, 0,
351 					       so->so_proto->pr_protocol))
352 		    != 0) {
353 			goto bad;
354 		}
355 		in6p->in6p_outputopts = &opt;
356 	}
357 
358 	/*
359 	 * For an ICMPv6 packet, we should know its type and code
360 	 * to update statistics.
361 	 */
362 	if (so->so_proto->pr_protocol == IPPROTO_ICMPV6) {
363 		struct icmp6_hdr *icmp6;
364 		if (m->m_len < sizeof(struct icmp6_hdr) &&
365 		    (m = m_pullup(m, sizeof(struct icmp6_hdr))) == NULL) {
366 			error = ENOBUFS;
367 			goto bad;
368 		}
369 		icmp6 = mtod(m, struct icmp6_hdr *);
370 		type = icmp6->icmp6_type;
371 		code = icmp6->icmp6_code;
372 	}
373 
374 	M_PREPEND(m, sizeof(*ip6), M_DONTWAIT);
375 	if (m == NULL) {
376 		error = ENOBUFS;
377 		goto bad;
378 	}
379 	ip6 = mtod(m, struct ip6_hdr *);
380 
381 	/*
382 	 * Next header might not be ICMP6 but use its pseudo header anyway.
383 	 */
384 	ip6->ip6_dst = *dst;
385 
386 	/*
387 	 * If the scope of the destination is link-local, embed the interface
388 	 * index in the address.
389 	 *
390 	 * XXX advanced-api value overrides sin6_scope_id
391 	 */
392 	if (IN6_IS_SCOPE_LINKLOCAL(&ip6->ip6_dst)) {
393 		struct in6_pktinfo *pi;
394 
395 		/*
396 		 * XXX Boundary check is assumed to be already done in
397 		 * ip6_setpktoptions().
398 		 */
399 		if (in6p->in6p_outputopts &&
400 		    (pi = in6p->in6p_outputopts->ip6po_pktinfo) &&
401 		    pi->ipi6_ifindex) {
402 			ip6->ip6_dst.s6_addr16[1] = htons(pi->ipi6_ifindex);
403 			oifp = ifnet_byindex(pi->ipi6_ifindex);
404 		} else if (IN6_IS_ADDR_MULTICAST(&ip6->ip6_dst) &&
405 			 in6p->in6p_moptions &&
406 			 in6p->in6p_moptions->im6o_multicast_ifp) {
407 			oifp = in6p->in6p_moptions->im6o_multicast_ifp;
408 			ip6->ip6_dst.s6_addr16[1] = htons(oifp->if_index);
409 		} else if (dstsock->sin6_scope_id) {
410 			/* boundary check */
411 			if (dstsock->sin6_scope_id < 0 ||
412 			    if_index < dstsock->sin6_scope_id) {
413 				error = ENXIO;  /* XXX EINVAL? */
414 				goto bad;
415 			}
416 			ip6->ip6_dst.s6_addr16[1] =
417 			    htons(dstsock->sin6_scope_id & 0xffff); /* XXX */
418 		}
419 	}
420 
421 	/*
422 	 * Source address selection.
423 	 */
424 	if ((in6a = in6_selectsrc(dstsock, in6p->in6p_outputopts,
425 	    in6p->in6p_moptions, NULL, &in6p->in6p_laddr, &error)) == 0) {
426 		if (error == 0)
427 			error = EADDRNOTAVAIL;
428 		goto bad;
429 	}
430 	ip6->ip6_src = *in6a;
431 	ip6->ip6_flow = (ip6->ip6_flow & ~IPV6_FLOWINFO_MASK) |
432 		(in6p->in6p_flowinfo & IPV6_FLOWINFO_MASK);
433 	ip6->ip6_vfc = (ip6->ip6_vfc & ~IPV6_VERSION_MASK) |
434 		(IPV6_VERSION & IPV6_VERSION_MASK);
435 	/* ip6_plen will be filled in ip6_output, so not fill it here. */
436 	ip6->ip6_nxt = in6p->in6p_ip6_nxt;
437 	ip6->ip6_hlim = in6_selecthlim(in6p, oifp);
438 
439 	if (so->so_proto->pr_protocol == IPPROTO_ICMPV6 ||
440 	    in6p->in6p_cksum != -1) {
441 		struct mbuf *n;
442 		int off;
443 		u_int16_t *p;
444 
445 		/* compute checksum */
446 		if (so->so_proto->pr_protocol == IPPROTO_ICMPV6)
447 			off = offsetof(struct icmp6_hdr, icmp6_cksum);
448 		else
449 			off = in6p->in6p_cksum;
450 		if (plen < off + 1) {
451 			error = EINVAL;
452 			goto bad;
453 		}
454 		off += sizeof(struct ip6_hdr);
455 
456 		n = m;
457 		while (n && n->m_len <= off) {
458 			off -= n->m_len;
459 			n = n->m_next;
460 		}
461 		if (!n)
462 			goto bad;
463 		p = (u_int16_t *)(mtod(n, caddr_t) + off);
464 		*p = 0;
465 		*p = in6_cksum(m, ip6->ip6_nxt, sizeof(*ip6), plen);
466 	}
467 
468 	error = ip6_output(m, in6p->in6p_outputopts, NULL, 0,
469 			   in6p->in6p_moptions, &oifp, in6p);
470 	if (so->so_proto->pr_protocol == IPPROTO_ICMPV6) {
471 		if (oifp)
472 			icmp6_ifoutstat_inc(oifp, type, code);
473 		icmp6stat.icp6s_outhist[type]++;
474 	} else
475 		rip6stat.rip6s_opackets++;
476 
477 	goto freectl;
478 
479  bad:
480 	if (m)
481 		m_freem(m);
482 
483  freectl:
484 	if (control) {
485 		ip6_clearpktopts(in6p->in6p_outputopts, -1);
486 		in6p->in6p_outputopts = stickyopt;
487 		m_freem(control);
488 	}
489 	INP_UNLOCK(in6p);
490 	return (error);
491 }
492 
493 /*
494  * Raw IPv6 socket option processing.
495  */
496 int
497 rip6_ctloutput(so, sopt)
498 	struct socket *so;
499 	struct sockopt *sopt;
500 {
501 	int error;
502 
503 	if (sopt->sopt_level == IPPROTO_ICMPV6)
504 		/*
505 		 * XXX: is it better to call icmp6_ctloutput() directly
506 		 * from protosw?
507 		 */
508 		return (icmp6_ctloutput(so, sopt));
509 	else if (sopt->sopt_level != IPPROTO_IPV6)
510 		return (EINVAL);
511 
512 	error = 0;
513 
514 	switch (sopt->sopt_dir) {
515 	case SOPT_GET:
516 		switch (sopt->sopt_name) {
517 		case MRT6_INIT:
518 		case MRT6_DONE:
519 		case MRT6_ADD_MIF:
520 		case MRT6_DEL_MIF:
521 		case MRT6_ADD_MFC:
522 		case MRT6_DEL_MFC:
523 		case MRT6_PIM:
524 			error = ip6_mrouter_get(so, sopt);
525 			break;
526 		case IPV6_CHECKSUM:
527 			error = ip6_raw_ctloutput(so, sopt);
528 			break;
529 		default:
530 			error = ip6_ctloutput(so, sopt);
531 			break;
532 		}
533 		break;
534 
535 	case SOPT_SET:
536 		switch (sopt->sopt_name) {
537 		case MRT6_INIT:
538 		case MRT6_DONE:
539 		case MRT6_ADD_MIF:
540 		case MRT6_DEL_MIF:
541 		case MRT6_ADD_MFC:
542 		case MRT6_DEL_MFC:
543 		case MRT6_PIM:
544 			error = ip6_mrouter_set(so, sopt);
545 			break;
546 		case IPV6_CHECKSUM:
547 			error = ip6_raw_ctloutput(so, sopt);
548 			break;
549 		default:
550 			error = ip6_ctloutput(so, sopt);
551 			break;
552 		}
553 		break;
554 	}
555 
556 	return (error);
557 }
558 
559 static int
560 rip6_attach(struct socket *so, int proto, struct thread *td)
561 {
562 	struct inpcb *inp;
563 	int error, s;
564 
565 	INP_INFO_WLOCK(&ripcbinfo);
566 	inp = sotoinpcb(so);
567 	if (inp) {
568 		INP_INFO_WUNLOCK(&ripcbinfo);
569 		panic("rip6_attach");
570 	}
571 	if (td && (error = suser(td)) != 0) {
572 		INP_INFO_WUNLOCK(&ripcbinfo);
573 		return error;
574 	}
575 	error = soreserve(so, rip_sendspace, rip_recvspace);
576 	if (error) {
577 		INP_INFO_WUNLOCK(&ripcbinfo);
578 		return error;
579 	}
580 	s = splnet();
581 	error = in_pcballoc(so, &ripcbinfo, "raw6inp");
582 	splx(s);
583 	if (error) {
584 		INP_INFO_WUNLOCK(&ripcbinfo);
585 		return error;
586 	}
587 	inp = (struct inpcb *)so->so_pcb;
588 	INP_LOCK(inp);
589 	INP_INFO_WUNLOCK(&ripcbinfo);
590 	inp->inp_vflag |= INP_IPV6;
591 	inp->in6p_ip6_nxt = (long)proto;
592 	inp->in6p_hops = -1;	/* use kernel default */
593 	inp->in6p_cksum = -1;
594 	MALLOC(inp->in6p_icmp6filt, struct icmp6_filter *,
595 	       sizeof(struct icmp6_filter), M_PCB, M_NOWAIT);
596 	ICMP6_FILTER_SETPASSALL(inp->in6p_icmp6filt);
597 	INP_UNLOCK(inp);
598 	return 0;
599 }
600 
601 static int
602 rip6_detach(struct socket *so)
603 {
604 	struct inpcb *inp;
605 
606 	INP_INFO_WLOCK(&ripcbinfo);
607 	inp = sotoinpcb(so);
608 	if (inp == 0) {
609 		INP_INFO_WUNLOCK(&ripcbinfo);
610 		panic("rip6_detach");
611 	}
612 	/* xxx: RSVP */
613 	if (so == ip6_mrouter)
614 		ip6_mrouter_done();
615 	if (inp->in6p_icmp6filt) {
616 		FREE(inp->in6p_icmp6filt, M_PCB);
617 		inp->in6p_icmp6filt = NULL;
618 	}
619 	INP_LOCK(inp);
620 	in6_pcbdetach(inp);
621 	INP_INFO_WUNLOCK(&ripcbinfo);
622 	return 0;
623 }
624 
625 static int
626 rip6_abort(struct socket *so)
627 {
628 	soisdisconnected(so);
629 	return rip6_detach(so);
630 }
631 
632 static int
633 rip6_disconnect(struct socket *so)
634 {
635 	struct inpcb *inp = sotoinpcb(so);
636 
637 	if ((so->so_state & SS_ISCONNECTED) == 0)
638 		return ENOTCONN;
639 	inp->in6p_faddr = in6addr_any;
640 	return rip6_abort(so);
641 }
642 
643 static int
644 rip6_bind(struct socket *so, struct sockaddr *nam, struct thread *td)
645 {
646 	struct inpcb *inp = sotoinpcb(so);
647 	struct sockaddr_in6 *addr = (struct sockaddr_in6 *)nam;
648 	struct ifaddr *ia = NULL;
649 
650 	if (nam->sa_len != sizeof(*addr))
651 		return EINVAL;
652 	if (TAILQ_EMPTY(&ifnet) || addr->sin6_family != AF_INET6)
653 		return EADDRNOTAVAIL;
654 #ifdef ENABLE_DEFAULT_SCOPE
655 	if (addr->sin6_scope_id == 0) {	/* not change if specified  */
656 		addr->sin6_scope_id = scope6_addr2default(&addr->sin6_addr);
657 	}
658 #endif
659 	if (!IN6_IS_ADDR_UNSPECIFIED(&addr->sin6_addr) &&
660 	    (ia = ifa_ifwithaddr((struct sockaddr *)addr)) == 0)
661 		return EADDRNOTAVAIL;
662 	if (ia &&
663 	    ((struct in6_ifaddr *)ia)->ia6_flags &
664 	    (IN6_IFF_ANYCAST|IN6_IFF_NOTREADY|
665 	     IN6_IFF_DETACHED|IN6_IFF_DEPRECATED)) {
666 		return (EADDRNOTAVAIL);
667 	}
668 	INP_INFO_WLOCK(&ripcbinfo);
669 	INP_LOCK(inp);
670 	inp->in6p_laddr = addr->sin6_addr;
671 	INP_UNLOCK(inp);
672 	INP_INFO_WUNLOCK(&ripcbinfo);
673 	return 0;
674 }
675 
676 static int
677 rip6_connect(struct socket *so, struct sockaddr *nam, struct thread *td)
678 {
679 	struct inpcb *inp = sotoinpcb(so);
680 	struct sockaddr_in6 *addr = (struct sockaddr_in6 *)nam;
681 	struct in6_addr *in6a = NULL;
682 	int error = 0;
683 #ifdef ENABLE_DEFAULT_SCOPE
684 	struct sockaddr_in6 tmp;
685 #endif
686 
687 	if (nam->sa_len != sizeof(*addr))
688 		return EINVAL;
689 	if (TAILQ_EMPTY(&ifnet))
690 		return EADDRNOTAVAIL;
691 	if (addr->sin6_family != AF_INET6)
692 		return EAFNOSUPPORT;
693 #ifdef ENABLE_DEFAULT_SCOPE
694 	if (addr->sin6_scope_id == 0) {	/* not change if specified  */
695 		/* avoid overwrites */
696 		tmp = *addr;
697 		addr = &tmp;
698 		addr->sin6_scope_id = scope6_addr2default(&addr->sin6_addr);
699 	}
700 #endif
701 	INP_INFO_WLOCK(&ripcbinfo);
702 	INP_LOCK(inp);
703 	/* Source address selection. XXX: need pcblookup? */
704 	in6a = in6_selectsrc(addr, inp->in6p_outputopts,
705 			     inp->in6p_moptions, NULL,
706 			     &inp->in6p_laddr, &error);
707 	if (in6a == NULL) {
708 		INP_UNLOCK(inp);
709 		INP_INFO_WUNLOCK(&ripcbinfo);
710 		return (error ? error : EADDRNOTAVAIL);
711 	}
712 	inp->in6p_laddr = *in6a;
713 	inp->in6p_faddr = addr->sin6_addr;
714 	soisconnected(so);
715 	INP_UNLOCK(inp);
716 	INP_INFO_WUNLOCK(&ripcbinfo);
717 	return 0;
718 }
719 
720 static int
721 rip6_shutdown(struct socket *so)
722 {
723 	struct inpcb *inp;
724 
725 	INP_INFO_RLOCK(&ripcbinfo);
726 	inp = sotoinpcb(so);
727 	INP_LOCK(inp);
728 	INP_INFO_RUNLOCK(&ripcbinfo);
729 	socantsendmore(so);
730 	INP_UNLOCK(inp);
731 	return 0;
732 }
733 
734 static int
735 rip6_send(struct socket *so, int flags, struct mbuf *m, struct sockaddr *nam,
736 	 struct mbuf *control, struct thread *td)
737 {
738 	struct inpcb *inp = sotoinpcb(so);
739 	struct sockaddr_in6 tmp;
740 	struct sockaddr_in6 *dst;
741 	int ret;
742 
743 	INP_INFO_WLOCK(&ripcbinfo);
744 	/* always copy sockaddr to avoid overwrites */
745 	/* Unlocked read. */
746 	if (so->so_state & SS_ISCONNECTED) {
747 		if (nam) {
748 			INP_INFO_WUNLOCK(&ripcbinfo);
749 			m_freem(m);
750 			return EISCONN;
751 		}
752 		/* XXX */
753 		bzero(&tmp, sizeof(tmp));
754 		tmp.sin6_family = AF_INET6;
755 		tmp.sin6_len = sizeof(struct sockaddr_in6);
756 		bcopy(&inp->in6p_faddr, &tmp.sin6_addr,
757 		      sizeof(struct in6_addr));
758 		dst = &tmp;
759 	} else {
760 		if (nam == NULL) {
761 			INP_INFO_WUNLOCK(&ripcbinfo);
762 			m_freem(m);
763 			return ENOTCONN;
764 		}
765 		tmp = *(struct sockaddr_in6 *)nam;
766 		dst = &tmp;
767 	}
768 #ifdef ENABLE_DEFAULT_SCOPE
769 	if (dst->sin6_scope_id == 0) {	/* not change if specified  */
770 		dst->sin6_scope_id = scope6_addr2default(&dst->sin6_addr);
771 	}
772 #endif
773 	ret = rip6_output(m, so, dst, control);
774 	INP_INFO_WUNLOCK(&ripcbinfo);
775 	return (ret);
776 }
777 
778 struct pr_usrreqs rip6_usrreqs = {
779 	.pru_abort =		rip6_abort,
780 	.pru_attach =		rip6_attach,
781 	.pru_bind =		rip6_bind,
782 	.pru_connect =		rip6_connect,
783 	.pru_control =		in6_control,
784 	.pru_detach =		rip6_detach,
785 	.pru_disconnect =	rip6_disconnect,
786 	.pru_peeraddr =		in6_setpeeraddr,
787 	.pru_send =		rip6_send,
788 	.pru_shutdown =		rip6_shutdown,
789 	.pru_sockaddr =		in6_setsockaddr,
790 };
791