in6_pcb.c revision 1.85 1 /* $NetBSD: in6_pcb.c,v 1.85 2007/03/12 18:18:36 ad Exp $ */
2 /* $KAME: in6_pcb.c,v 1.84 2001/02/08 18:02:08 itojun Exp $ */
3
4 /*
5 * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
6 * All rights reserved.
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. Neither the name of the project nor the names of its contributors
17 * may be used to endorse or promote products derived from this software
18 * without specific prior written permission.
19 *
20 * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
21 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23 * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
24 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30 * SUCH DAMAGE.
31 */
32
33 /*
34 * Copyright (c) 1982, 1986, 1991, 1993
35 * The Regents of the University of California. All rights reserved.
36 *
37 * Redistribution and use in source and binary forms, with or without
38 * modification, are permitted provided that the following conditions
39 * are met:
40 * 1. Redistributions of source code must retain the above copyright
41 * notice, this list of conditions and the following disclaimer.
42 * 2. Redistributions in binary form must reproduce the above copyright
43 * notice, this list of conditions and the following disclaimer in the
44 * documentation and/or other materials provided with the distribution.
45 * 3. Neither the name of the University nor the names of its contributors
46 * may be used to endorse or promote products derived from this software
47 * without specific prior written permission.
48 *
49 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
50 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
51 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
52 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
53 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
54 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
55 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
56 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
57 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
58 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
59 * SUCH DAMAGE.
60 *
61 * @(#)in_pcb.c 8.2 (Berkeley) 1/4/94
62 */
63
64 #include <sys/cdefs.h>
65 __KERNEL_RCSID(0, "$NetBSD: in6_pcb.c,v 1.85 2007/03/12 18:18:36 ad Exp $");
66
67 #include "opt_inet.h"
68 #include "opt_ipsec.h"
69
70 #include <sys/param.h>
71 #include <sys/systm.h>
72 #include <sys/malloc.h>
73 #include <sys/mbuf.h>
74 #include <sys/protosw.h>
75 #include <sys/socket.h>
76 #include <sys/socketvar.h>
77 #include <sys/ioctl.h>
78 #include <sys/errno.h>
79 #include <sys/time.h>
80 #include <sys/proc.h>
81 #include <sys/kauth.h>
82
83 #include <net/if.h>
84 #include <net/route.h>
85
86 #include <netinet/in.h>
87 #include <netinet/in_var.h>
88 #include <netinet/in_systm.h>
89 #include <netinet/ip.h>
90 #include <netinet/in_pcb.h>
91 #include <netinet/ip6.h>
92 #include <netinet6/ip6_var.h>
93 #include <netinet6/in6_pcb.h>
94 #include <netinet6/scope6_var.h>
95 #include <netinet6/nd6.h>
96
97 #include "faith.h"
98
99 #ifdef IPSEC
100 #include <netinet6/ipsec.h>
101 #include <netkey/key.h>
102 #endif /* IPSEC */
103
104 #ifdef FAST_IPSEC
105 #include <netipsec/ipsec.h>
106 #include <netipsec/ipsec6.h>
107 #include <netipsec/key.h>
108 #endif /* FAST_IPSEC */
109
110 struct in6_addr zeroin6_addr;
111
112 #define IN6PCBHASH_PORT(table, lport) \
113 &(table)->inpt_porthashtbl[ntohs(lport) & (table)->inpt_porthash]
114 #define IN6PCBHASH_BIND(table, laddr, lport) \
115 &(table)->inpt_bindhashtbl[ \
116 (((laddr)->s6_addr32[0] ^ (laddr)->s6_addr32[1] ^ \
117 (laddr)->s6_addr32[2] ^ (laddr)->s6_addr32[3]) + ntohs(lport)) & \
118 (table)->inpt_bindhash]
119 #define IN6PCBHASH_CONNECT(table, faddr, fport, laddr, lport) \
120 &(table)->inpt_bindhashtbl[ \
121 ((((faddr)->s6_addr32[0] ^ (faddr)->s6_addr32[1] ^ \
122 (faddr)->s6_addr32[2] ^ (faddr)->s6_addr32[3]) + ntohs(fport)) + \
123 (((laddr)->s6_addr32[0] ^ (laddr)->s6_addr32[1] ^ \
124 (laddr)->s6_addr32[2] ^ (laddr)->s6_addr32[3]) + \
125 ntohs(lport))) & (table)->inpt_bindhash]
126
127 int ip6_anonportmin = IPV6PORT_ANONMIN;
128 int ip6_anonportmax = IPV6PORT_ANONMAX;
129 int ip6_lowportmin = IPV6PORT_RESERVEDMIN;
130 int ip6_lowportmax = IPV6PORT_RESERVEDMAX;
131
132 POOL_INIT(in6pcb_pool, sizeof(struct in6pcb), 0, 0, 0, "in6pcbpl", NULL,
133 IPL_SOFTNET);
134
135 void
136 in6_pcbinit(table, bindhashsize, connecthashsize)
137 struct inpcbtable *table;
138 int bindhashsize, connecthashsize;
139 {
140
141 in_pcbinit(table, bindhashsize, connecthashsize);
142 table->inpt_lastport = (u_int16_t)ip6_anonportmax;
143 }
144
145 int
146 in6_pcballoc(so, v)
147 struct socket *so;
148 void *v;
149 {
150 struct inpcbtable *table = v;
151 struct in6pcb *in6p;
152 int s;
153 #if defined(IPSEC) || defined(FAST_IPSEC)
154 int error;
155 #endif
156
157 s = splnet();
158 in6p = pool_get(&in6pcb_pool, PR_NOWAIT);
159 splx(s);
160 if (in6p == NULL)
161 return (ENOBUFS);
162 bzero((void *)in6p, sizeof(*in6p));
163 in6p->in6p_af = AF_INET6;
164 in6p->in6p_table = table;
165 in6p->in6p_socket = so;
166 in6p->in6p_hops = -1; /* use kernel default */
167 in6p->in6p_icmp6filt = NULL;
168 #if defined(IPSEC) || defined(FAST_IPSEC)
169 error = ipsec_init_pcbpolicy(so, &in6p->in6p_sp);
170 if (error != 0) {
171 s = splnet();
172 pool_put(&in6pcb_pool, in6p);
173 splx(s);
174 return error;
175 }
176 #endif /* IPSEC */
177 s = splnet();
178 CIRCLEQ_INSERT_HEAD(&table->inpt_queue, (struct inpcb_hdr*)in6p,
179 inph_queue);
180 LIST_INSERT_HEAD(IN6PCBHASH_PORT(table, in6p->in6p_lport),
181 &in6p->in6p_head, inph_lhash);
182 in6_pcbstate(in6p, IN6P_ATTACHED);
183 splx(s);
184 if (ip6_v6only)
185 in6p->in6p_flags |= IN6P_IPV6_V6ONLY;
186 so->so_pcb = (void *)in6p;
187 return (0);
188 }
189
190 int
191 in6_pcbbind(v, nam, l)
192 void *v;
193 struct mbuf *nam;
194 struct lwp *l;
195 {
196 struct in6pcb *in6p = v;
197 struct socket *so = in6p->in6p_socket;
198 struct inpcbtable *table = in6p->in6p_table;
199 struct sockaddr_in6 *sin6 = (struct sockaddr_in6 *)NULL;
200 u_int16_t lport = 0;
201 int wild = 0, reuseport = (so->so_options & SO_REUSEPORT);
202
203 if (in6p->in6p_af != AF_INET6)
204 return (EINVAL);
205
206 if (in6p->in6p_lport || !IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr))
207 return (EINVAL);
208 if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0 &&
209 ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
210 (so->so_options & SO_ACCEPTCONN) == 0))
211 wild = 1;
212 if (nam) {
213 int error;
214
215 sin6 = mtod(nam, struct sockaddr_in6 *);
216 if (nam->m_len != sizeof(*sin6))
217 return (EINVAL);
218 /*
219 * We should check the family, but old programs
220 * incorrectly fail to intialize it.
221 */
222 if (sin6->sin6_family != AF_INET6)
223 return (EAFNOSUPPORT);
224
225 #ifndef INET
226 if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr))
227 return (EADDRNOTAVAIL);
228 #endif
229
230 if ((error = sa6_embedscope(sin6, ip6_use_defzone)) != 0)
231 return (error);
232
233 lport = sin6->sin6_port;
234 if (IN6_IS_ADDR_MULTICAST(&sin6->sin6_addr)) {
235 /*
236 * Treat SO_REUSEADDR as SO_REUSEPORT for multicast;
237 * allow compepte duplication of binding if
238 * SO_REUSEPORT is set, or if SO_REUSEADDR is set
239 * and a multicast address is bound on both
240 * new and duplicated sockets.
241 */
242 if (so->so_options & SO_REUSEADDR)
243 reuseport = SO_REUSEADDR|SO_REUSEPORT;
244 } else if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) {
245 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
246 return (EINVAL);
247 if (sin6->sin6_addr.s6_addr32[3]) {
248 struct sockaddr_in sin;
249
250 bzero(&sin, sizeof(sin));
251 sin.sin_len = sizeof(sin);
252 sin.sin_family = AF_INET;
253 bcopy(&sin6->sin6_addr.s6_addr32[3],
254 &sin.sin_addr, sizeof(sin.sin_addr));
255 if (ifa_ifwithaddr((struct sockaddr *)&sin) == 0)
256 return EADDRNOTAVAIL;
257 }
258 } else if (!IN6_IS_ADDR_UNSPECIFIED(&sin6->sin6_addr)) {
259 struct ifaddr *ia = NULL;
260
261 sin6->sin6_port = 0; /* yech... */
262 if ((in6p->in6p_flags & IN6P_FAITH) == 0 &&
263 (ia = ifa_ifwithaddr((struct sockaddr *)sin6)) == 0)
264 return (EADDRNOTAVAIL);
265
266 /*
267 * bind to an anycast address might accidentally
268 * cause sending a packet with an anycast source
269 * address, so we forbid it.
270 *
271 * We should allow to bind to a deprecated address,
272 * since the application dare to use it.
273 * But, can we assume that they are careful enough
274 * to check if the address is deprecated or not?
275 * Maybe, as a safeguard, we should have a setsockopt
276 * flag to control the bind(2) behavior against
277 * deprecated addresses (default: forbid bind(2)).
278 */
279 if (ia &&
280 ((struct in6_ifaddr *)ia)->ia6_flags &
281 (IN6_IFF_ANYCAST|IN6_IFF_NOTREADY|IN6_IFF_DETACHED))
282 return (EADDRNOTAVAIL);
283 }
284 if (lport) {
285 #ifndef IPNOPRIVPORTS
286 int priv;
287
288 /*
289 * NOTE: all operating systems use suser() for
290 * privilege check! do not rewrite it into SS_PRIV.
291 */
292 priv = (l && !kauth_authorize_generic(l->l_cred,
293 KAUTH_GENERIC_ISSUSER, NULL)) ? 1 : 0;
294 /* GROSS */
295 if (ntohs(lport) < IPV6PORT_RESERVED && !priv)
296 return (EACCES);
297 #endif
298
299 if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) {
300 #ifdef INET
301 struct inpcb *t;
302
303 t = in_pcblookup_port(table,
304 *(struct in_addr *)&sin6->sin6_addr.s6_addr32[3],
305 lport, wild);
306 if (t && (reuseport & t->inp_socket->so_options) == 0)
307 return (EADDRINUSE);
308 #else
309 return (EADDRNOTAVAIL);
310 #endif
311 }
312
313 {
314 struct in6pcb *t;
315
316 t = in6_pcblookup_port(table, &sin6->sin6_addr,
317 lport, wild);
318 if (t && (reuseport & t->in6p_socket->so_options) == 0)
319 return (EADDRINUSE);
320 }
321 }
322 in6p->in6p_laddr = sin6->sin6_addr;
323 }
324
325 if (lport == 0) {
326 int e;
327 e = in6_pcbsetport(&in6p->in6p_laddr, in6p, l);
328 if (e != 0)
329 return (e);
330 } else {
331 in6p->in6p_lport = lport;
332 in6_pcbstate(in6p, IN6P_BOUND);
333 }
334
335 LIST_REMOVE(&in6p->in6p_head, inph_lhash);
336 LIST_INSERT_HEAD(IN6PCBHASH_PORT(table, in6p->in6p_lport),
337 &in6p->in6p_head, inph_lhash);
338
339 #if 0
340 in6p->in6p_flowinfo = 0; /* XXX */
341 #endif
342 return (0);
343 }
344
345 /*
346 * Connect from a socket to a specified address.
347 * Both address and port must be specified in argument sin6.
348 * If don't have a local address for this socket yet,
349 * then pick one.
350 */
351 int
352 in6_pcbconnect(v, nam, l)
353 void *v;
354 struct mbuf *nam;
355 struct lwp *l;
356 {
357 struct in6pcb *in6p = v;
358 struct in6_addr *in6a = NULL;
359 struct sockaddr_in6 *sin6 = mtod(nam, struct sockaddr_in6 *);
360 struct ifnet *ifp = NULL; /* outgoing interface */
361 int error = 0;
362 int scope_ambiguous = 0;
363 #ifdef INET
364 struct in6_addr mapped;
365 #endif
366 struct sockaddr_in6 tmp;
367
368 (void)&in6a; /* XXX fool gcc */
369
370 if (in6p->in6p_af != AF_INET6)
371 return (EINVAL);
372
373 if (nam->m_len != sizeof(*sin6))
374 return (EINVAL);
375 if (sin6->sin6_family != AF_INET6)
376 return (EAFNOSUPPORT);
377 if (sin6->sin6_port == 0)
378 return (EADDRNOTAVAIL);
379
380 if (sin6->sin6_scope_id == 0 && !ip6_use_defzone)
381 scope_ambiguous = 1;
382 if ((error = sa6_embedscope(sin6, ip6_use_defzone)) != 0)
383 return(error);
384
385 /* sanity check for mapped address case */
386 if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr)) {
387 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
388 return EINVAL;
389 if (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr))
390 in6p->in6p_laddr.s6_addr16[5] = htons(0xffff);
391 if (!IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr))
392 return EINVAL;
393 } else
394 {
395 if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr))
396 return EINVAL;
397 }
398
399 /* protect *sin6 from overwrites */
400 tmp = *sin6;
401 sin6 = &tmp;
402
403 /* Source address selection. */
404 if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr) &&
405 in6p->in6p_laddr.s6_addr32[3] == 0) {
406 #ifdef INET
407 struct sockaddr_in sin, *sinp;
408
409 bzero(&sin, sizeof(sin));
410 sin.sin_len = sizeof(sin);
411 sin.sin_family = AF_INET;
412 bcopy(&sin6->sin6_addr.s6_addr32[3], &sin.sin_addr,
413 sizeof(sin.sin_addr));
414 sinp = in_selectsrc(&sin, (struct route *)&in6p->in6p_route,
415 in6p->in6p_socket->so_options, NULL, &error);
416 if (sinp == 0) {
417 if (error == 0)
418 error = EADDRNOTAVAIL;
419 return (error);
420 }
421 bzero(&mapped, sizeof(mapped));
422 mapped.s6_addr16[5] = htons(0xffff);
423 bcopy(&sinp->sin_addr, &mapped.s6_addr32[3], sizeof(sinp->sin_addr));
424 in6a = &mapped;
425 #else
426 return EADDRNOTAVAIL;
427 #endif
428 } else {
429 /*
430 * XXX: in6_selectsrc might replace the bound local address
431 * with the address specified by setsockopt(IPV6_PKTINFO).
432 * Is it the intended behavior?
433 */
434 in6a = in6_selectsrc(sin6, in6p->in6p_outputopts,
435 in6p->in6p_moptions,
436 (struct route *)&in6p->in6p_route,
437 &in6p->in6p_laddr, &ifp, &error);
438 if (ifp && scope_ambiguous &&
439 (error = in6_setscope(&sin6->sin6_addr, ifp, NULL)) != 0) {
440 return(error);
441 }
442
443 if (in6a == 0) {
444 if (error == 0)
445 error = EADDRNOTAVAIL;
446 return (error);
447 }
448 }
449 if (ifp == NULL && in6p->in6p_route.ro_rt != NULL)
450 ifp = in6p->in6p_route.ro_rt->rt_ifp;
451
452 in6p->in6p_ip6.ip6_hlim = (u_int8_t)in6_selecthlim(in6p, ifp);
453
454 if (in6_pcblookup_connect(in6p->in6p_table, &sin6->sin6_addr,
455 sin6->sin6_port,
456 IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr) ? in6a : &in6p->in6p_laddr,
457 in6p->in6p_lport, 0))
458 return (EADDRINUSE);
459 if (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr) ||
460 (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr) &&
461 in6p->in6p_laddr.s6_addr32[3] == 0))
462 {
463 if (in6p->in6p_lport == 0) {
464 error = in6_pcbbind(in6p, (struct mbuf *)0, l);
465 if (error != 0)
466 return error;
467 }
468 in6p->in6p_laddr = *in6a;
469 }
470 in6p->in6p_faddr = sin6->sin6_addr;
471 in6p->in6p_fport = sin6->sin6_port;
472 in6_pcbstate(in6p, IN6P_CONNECTED);
473 in6p->in6p_flowinfo &= ~IPV6_FLOWLABEL_MASK;
474 if (ip6_auto_flowlabel)
475 in6p->in6p_flowinfo |=
476 (htonl(ip6_randomflowlabel()) & IPV6_FLOWLABEL_MASK);
477 #if defined(IPSEC) || defined(FAST_IPSEC)
478 if (in6p->in6p_socket->so_type == SOCK_STREAM)
479 ipsec_pcbconn(in6p->in6p_sp);
480 #endif
481 return (0);
482 }
483
484 void
485 in6_pcbdisconnect(in6p)
486 struct in6pcb *in6p;
487 {
488 bzero((void *)&in6p->in6p_faddr, sizeof(in6p->in6p_faddr));
489 in6p->in6p_fport = 0;
490 in6_pcbstate(in6p, IN6P_BOUND);
491 in6p->in6p_flowinfo &= ~IPV6_FLOWLABEL_MASK;
492 #if defined(IPSEC) || defined(FAST_IPSEC)
493 ipsec_pcbdisconn(in6p->in6p_sp);
494 #endif
495 if (in6p->in6p_socket->so_state & SS_NOFDREF)
496 in6_pcbdetach(in6p);
497 }
498
499 void
500 in6_pcbdetach(in6p)
501 struct in6pcb *in6p;
502 {
503 struct socket *so = in6p->in6p_socket;
504 int s;
505
506 if (in6p->in6p_af != AF_INET6)
507 return;
508
509 #if defined(IPSEC) || defined(FAST_IPSEC)
510 ipsec6_delete_pcbpolicy(in6p);
511 #endif /* IPSEC */
512 so->so_pcb = 0;
513 sofree(so);
514 if (in6p->in6p_options)
515 m_freem(in6p->in6p_options);
516 if (in6p->in6p_outputopts) {
517 if (in6p->in6p_outputopts->ip6po_rthdr != NULL)
518 rtcache_free((struct route *)&in6p->in6p_outputopts->ip6po_route);
519 if (in6p->in6p_outputopts->ip6po_m)
520 (void)m_free(in6p->in6p_outputopts->ip6po_m);
521 free(in6p->in6p_outputopts, M_IP6OPT);
522 }
523 rtcache_free((struct route *)&in6p->in6p_route);
524 ip6_freemoptions(in6p->in6p_moptions);
525 s = splnet();
526 in6_pcbstate(in6p, IN6P_ATTACHED);
527 LIST_REMOVE(&in6p->in6p_head, inph_lhash);
528 CIRCLEQ_REMOVE(&in6p->in6p_table->inpt_queue, &in6p->in6p_head,
529 inph_queue);
530 pool_put(&in6pcb_pool, in6p);
531 splx(s);
532 }
533
534 void
535 in6_setsockaddr(in6p, nam)
536 struct in6pcb *in6p;
537 struct mbuf *nam;
538 {
539 struct sockaddr_in6 *sin6;
540
541 if (in6p->in6p_af != AF_INET6)
542 return;
543
544 nam->m_len = sizeof(*sin6);
545 sin6 = mtod(nam, struct sockaddr_in6 *);
546 bzero((void *)sin6, sizeof(*sin6));
547 sin6->sin6_family = AF_INET6;
548 sin6->sin6_len = sizeof(struct sockaddr_in6);
549 sin6->sin6_port = in6p->in6p_lport;
550 sin6->sin6_addr = in6p->in6p_laddr;
551 (void)sa6_recoverscope(sin6); /* XXX: should catch errors */
552 }
553
554 void
555 in6_setpeeraddr(in6p, nam)
556 struct in6pcb *in6p;
557 struct mbuf *nam;
558 {
559 struct sockaddr_in6 *sin6;
560
561 if (in6p->in6p_af != AF_INET6)
562 return;
563
564 nam->m_len = sizeof(*sin6);
565 sin6 = mtod(nam, struct sockaddr_in6 *);
566 bzero((void *)sin6, sizeof(*sin6));
567 sin6->sin6_family = AF_INET6;
568 sin6->sin6_len = sizeof(struct sockaddr_in6);
569 sin6->sin6_port = in6p->in6p_fport;
570 sin6->sin6_addr = in6p->in6p_faddr;
571 (void)sa6_recoverscope(sin6); /* XXX: should catch errors */
572 }
573
574 /*
575 * Pass some notification to all connections of a protocol
576 * associated with address dst. The local address and/or port numbers
577 * may be specified to limit the search. The "usual action" will be
578 * taken, depending on the ctlinput cmd. The caller must filter any
579 * cmds that are uninteresting (e.g., no error in the map).
580 * Call the protocol specific routine (if any) to report
581 * any errors for each matching socket.
582 *
583 * Must be called at splsoftnet.
584 *
585 * Note: src (4th arg) carries the flowlabel value on the original IPv6
586 * header, in sin6_flowinfo member.
587 */
588 int
589 in6_pcbnotify(struct inpcbtable *table, const struct sockaddr *dst,
590 u_int fport_arg, const struct sockaddr *src, u_int lport_arg, int cmd,
591 void *cmdarg, void (*notify)(struct in6pcb *, int))
592 {
593 struct in6pcb *in6p, *nin6p;
594 struct sockaddr_in6 sa6_src;
595 const struct sockaddr_in6 *sa6_dst;
596 u_int16_t fport = fport_arg, lport = lport_arg;
597 int errno;
598 int nmatch = 0;
599 u_int32_t flowinfo;
600
601 if ((unsigned)cmd >= PRC_NCMDS || dst->sa_family != AF_INET6)
602 return 0;
603
604 sa6_dst = (const struct sockaddr_in6 *)dst;
605 if (IN6_IS_ADDR_UNSPECIFIED(&sa6_dst->sin6_addr))
606 return 0;
607
608 /*
609 * note that src can be NULL when we get notify by local fragmentation.
610 */
611 sa6_src = (src == NULL) ? sa6_any : *(const struct sockaddr_in6 *)src;
612 flowinfo = sa6_src.sin6_flowinfo;
613
614 /*
615 * Redirects go to all references to the destination,
616 * and use in6_rtchange to invalidate the route cache.
617 * Dead host indications: also use in6_rtchange to invalidate
618 * the cache, and deliver the error to all the sockets.
619 * Otherwise, if we have knowledge of the local port and address,
620 * deliver only to that socket.
621 */
622 if (PRC_IS_REDIRECT(cmd) || cmd == PRC_HOSTDEAD) {
623 fport = 0;
624 lport = 0;
625 bzero((void *)&sa6_src.sin6_addr, sizeof(sa6_src.sin6_addr));
626
627 if (cmd != PRC_HOSTDEAD)
628 notify = in6_rtchange;
629 }
630
631 errno = inet6ctlerrmap[cmd];
632 for (in6p = (struct in6pcb *)CIRCLEQ_FIRST(&table->inpt_queue);
633 in6p != (void *)&table->inpt_queue;
634 in6p = nin6p) {
635 nin6p = (struct in6pcb *)CIRCLEQ_NEXT(in6p, in6p_queue);
636
637 if (in6p->in6p_af != AF_INET6)
638 continue;
639
640 /*
641 * Under the following condition, notify of redirects
642 * to the pcb, without making address matches against inpcb.
643 * - redirect notification is arrived.
644 * - the inpcb is unconnected.
645 * - the inpcb is caching !RTF_HOST routing entry.
646 * - the ICMPv6 notification is from the gateway cached in the
647 * inpcb. i.e. ICMPv6 notification is from nexthop gateway
648 * the inpcb used very recently.
649 *
650 * This is to improve interaction between netbsd/openbsd
651 * redirect handling code, and inpcb route cache code.
652 * without the clause, !RTF_HOST routing entry (which carries
653 * gateway used by inpcb right before the ICMPv6 redirect)
654 * will be cached forever in unconnected inpcb.
655 *
656 * There still is a question regarding to what is TRT:
657 * - On bsdi/freebsd, RTF_HOST (cloned) routing entry will be
658 * generated on packet output. inpcb will always cache
659 * RTF_HOST routing entry so there's no need for the clause
660 * (ICMPv6 redirect will update RTF_HOST routing entry,
661 * and inpcb is caching it already).
662 * However, bsdi/freebsd are vulnerable to local DoS attacks
663 * due to the cloned routing entries.
664 * - Specwise, "destination cache" is mentioned in RFC2461.
665 * Jinmei says that it implies bsdi/freebsd behavior, itojun
666 * is not really convinced.
667 * - Having hiwat/lowat on # of cloned host route (redirect/
668 * pmtud) may be a good idea. netbsd/openbsd has it. see
669 * icmp6_mtudisc_update().
670 */
671 if ((PRC_IS_REDIRECT(cmd) || cmd == PRC_HOSTDEAD) &&
672 IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr) &&
673 in6p->in6p_route.ro_rt != NULL &&
674 !(in6p->in6p_route.ro_rt->rt_flags & RTF_HOST)) {
675 const struct sockaddr_in6 *dst6;
676
677 dst6 = (const struct sockaddr_in6 *)
678 rtcache_getdst((struct route *)&in6p->in6p_route);
679 if (IN6_ARE_ADDR_EQUAL(&dst6->sin6_addr,
680 &sa6_dst->sin6_addr))
681 goto do_notify;
682 }
683
684 /*
685 * If the error designates a new path MTU for a destination
686 * and the application (associated with this socket) wanted to
687 * know the value, notify. Note that we notify for all
688 * disconnected sockets if the corresponding application
689 * wanted. This is because some UDP applications keep sending
690 * sockets disconnected.
691 * XXX: should we avoid to notify the value to TCP sockets?
692 */
693 if (cmd == PRC_MSGSIZE && (in6p->in6p_flags & IN6P_MTU) != 0 &&
694 (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_faddr) ||
695 IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr, &sa6_dst->sin6_addr))) {
696 ip6_notify_pmtu(in6p, (const struct sockaddr_in6 *)dst,
697 (u_int32_t *)cmdarg);
698 }
699
700 /*
701 * Detect if we should notify the error. If no source and
702 * destination ports are specified, but non-zero flowinfo and
703 * local address match, notify the error. This is the case
704 * when the error is delivered with an encrypted buffer
705 * by ESP. Otherwise, just compare addresses and ports
706 * as usual.
707 */
708 if (lport == 0 && fport == 0 && flowinfo &&
709 in6p->in6p_socket != NULL &&
710 flowinfo == (in6p->in6p_flowinfo & IPV6_FLOWLABEL_MASK) &&
711 IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, &sa6_src.sin6_addr))
712 goto do_notify;
713 else if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr,
714 &sa6_dst->sin6_addr) ||
715 in6p->in6p_socket == 0 ||
716 (lport && in6p->in6p_lport != lport) ||
717 (!IN6_IS_ADDR_UNSPECIFIED(&sa6_src.sin6_addr) &&
718 !IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr,
719 &sa6_src.sin6_addr)) ||
720 (fport && in6p->in6p_fport != fport))
721 continue;
722
723 do_notify:
724 if (notify)
725 (*notify)(in6p, errno);
726 nmatch++;
727 }
728 return nmatch;
729 }
730
731 void
732 in6_pcbpurgeif0(table, ifp)
733 struct inpcbtable *table;
734 struct ifnet *ifp;
735 {
736 struct in6pcb *in6p, *nin6p;
737 struct ip6_moptions *im6o;
738 struct in6_multi_mship *imm, *nimm;
739
740 for (in6p = (struct in6pcb *)CIRCLEQ_FIRST(&table->inpt_queue);
741 in6p != (void *)&table->inpt_queue;
742 in6p = nin6p) {
743 nin6p = (struct in6pcb *)CIRCLEQ_NEXT(in6p, in6p_queue);
744 if (in6p->in6p_af != AF_INET6)
745 continue;
746
747 im6o = in6p->in6p_moptions;
748 if (im6o) {
749 /*
750 * Unselect the outgoing interface if it is being
751 * detached.
752 */
753 if (im6o->im6o_multicast_ifp == ifp)
754 im6o->im6o_multicast_ifp = NULL;
755
756 /*
757 * Drop multicast group membership if we joined
758 * through the interface being detached.
759 * XXX controversial - is it really legal for kernel
760 * to force this?
761 */
762 for (imm = im6o->im6o_memberships.lh_first;
763 imm != NULL; imm = nimm) {
764 nimm = imm->i6mm_chain.le_next;
765 if (imm->i6mm_maddr->in6m_ifp == ifp) {
766 LIST_REMOVE(imm, i6mm_chain);
767 in6_leavegroup(imm);
768 }
769 }
770 }
771 }
772 }
773
774 void
775 in6_pcbpurgeif(table, ifp)
776 struct inpcbtable *table;
777 struct ifnet *ifp;
778 {
779 struct in6pcb *in6p, *nin6p;
780
781 for (in6p = (struct in6pcb *)CIRCLEQ_FIRST(&table->inpt_queue);
782 in6p != (void *)&table->inpt_queue;
783 in6p = nin6p) {
784 nin6p = (struct in6pcb *)CIRCLEQ_NEXT(in6p, in6p_queue);
785 if (in6p->in6p_af != AF_INET6)
786 continue;
787 if (in6p->in6p_route.ro_rt != NULL &&
788 in6p->in6p_route.ro_rt->rt_ifp == ifp)
789 in6_rtchange(in6p, 0);
790 }
791 }
792
793 /*
794 * Check for alternatives when higher level complains
795 * about service problems. For now, invalidate cached
796 * routing information. If the route was created dynamically
797 * (by a redirect), time to try a default gateway again.
798 */
799 void
800 in6_losing(in6p)
801 struct in6pcb *in6p;
802 {
803 struct rtentry *rt;
804 struct rt_addrinfo info;
805
806 if (in6p->in6p_af != AF_INET6)
807 return;
808
809 if ((rt = in6p->in6p_route.ro_rt) != NULL) {
810 memset(&info, 0, sizeof(info));
811 info.rti_info[RTAX_DST] =
812 rtcache_getdst((struct route *)&in6p->in6p_route);
813 info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
814 info.rti_info[RTAX_NETMASK] = rt_mask(rt);
815 rt_missmsg(RTM_LOSING, &info, rt->rt_flags, 0);
816 if (rt->rt_flags & RTF_DYNAMIC) {
817 (void)rtrequest(RTM_DELETE, rt_key(rt), rt->rt_gateway,
818 rt_mask(rt), rt->rt_flags, NULL);
819 }
820 rtcache_free((struct route *)&in6p->in6p_route);
821 /*
822 * A new route can be allocated
823 * the next time output is attempted.
824 */
825 }
826 }
827
828 /*
829 * After a routing change, flush old routing. A new route can be
830 * allocated the next time output is attempted.
831 */
832 void
833 in6_rtchange(struct in6pcb *in6p, int errno)
834 {
835 if (in6p->in6p_af != AF_INET6)
836 return;
837
838 rtcache_free((struct route *)&in6p->in6p_route);
839 /*
840 * A new route can be allocated the next time
841 * output is attempted.
842 */
843 }
844
845 struct in6pcb *
846 in6_pcblookup_port(table, laddr6, lport_arg, lookup_wildcard)
847 struct inpcbtable *table;
848 struct in6_addr *laddr6;
849 u_int lport_arg;
850 int lookup_wildcard;
851 {
852 struct inpcbhead *head;
853 struct inpcb_hdr *inph;
854 struct in6pcb *in6p, *match = 0;
855 int matchwild = 3, wildcard;
856 u_int16_t lport = lport_arg;
857
858 head = IN6PCBHASH_PORT(table, lport);
859 LIST_FOREACH(inph, head, inph_lhash) {
860 in6p = (struct in6pcb *)inph;
861 if (in6p->in6p_af != AF_INET6)
862 continue;
863
864 if (in6p->in6p_lport != lport)
865 continue;
866 wildcard = 0;
867 if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_faddr)) {
868 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
869 continue;
870 }
871 if (!IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_faddr))
872 wildcard++;
873 if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr)) {
874 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
875 continue;
876 if (!IN6_IS_ADDR_V4MAPPED(laddr6))
877 continue;
878
879 /* duplicate of IPv4 logic */
880 wildcard = 0;
881 if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_faddr) &&
882 in6p->in6p_faddr.s6_addr32[3])
883 wildcard++;
884 if (!in6p->in6p_laddr.s6_addr32[3]) {
885 if (laddr6->s6_addr32[3])
886 wildcard++;
887 } else {
888 if (!laddr6->s6_addr32[3])
889 wildcard++;
890 else {
891 if (in6p->in6p_laddr.s6_addr32[3] !=
892 laddr6->s6_addr32[3])
893 continue;
894 }
895 }
896 } else if (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr)) {
897 if (IN6_IS_ADDR_V4MAPPED(laddr6)) {
898 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
899 continue;
900 }
901 if (!IN6_IS_ADDR_UNSPECIFIED(laddr6))
902 wildcard++;
903 } else {
904 if (IN6_IS_ADDR_V4MAPPED(laddr6)) {
905 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
906 continue;
907 }
908 if (IN6_IS_ADDR_UNSPECIFIED(laddr6))
909 wildcard++;
910 else {
911 if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr,
912 laddr6))
913 continue;
914 }
915 }
916 if (wildcard && !lookup_wildcard)
917 continue;
918 if (wildcard < matchwild) {
919 match = in6p;
920 matchwild = wildcard;
921 if (matchwild == 0)
922 break;
923 }
924 }
925 return (match);
926 }
927 #undef continue
928
929 /*
930 * WARNING: return value (rtentry) could be IPv4 one if in6pcb is connected to
931 * IPv4 mapped address.
932 */
933 struct rtentry *
934 in6_pcbrtentry(in6p)
935 struct in6pcb *in6p;
936 {
937 struct route_in6 *ro;
938 const struct sockaddr_in6 *cdst;
939
940 ro = &in6p->in6p_route;
941
942 if (in6p->in6p_af != AF_INET6)
943 return (NULL);
944
945 cdst = (const struct sockaddr_in6 *)rtcache_getdst((struct route *)ro);
946 if (!IN6_ARE_ADDR_EQUAL(&cdst->sin6_addr, &in6p->in6p_faddr))
947 rtcache_free((struct route *)ro);
948 else
949 rtcache_check((struct route *)ro);
950 #ifdef INET
951 if (ro->ro_rt == NULL && IN6_IS_ADDR_V4MAPPED(&in6p->in6p_faddr)) {
952 struct sockaddr_in *dst = (struct sockaddr_in *)&ro->ro_dst;
953
954 memset(dst, 0, sizeof(*dst));
955 dst->sin_family = AF_INET;
956 dst->sin_len = sizeof(struct sockaddr_in);
957 dst->sin_addr.s_addr = in6p->in6p_faddr.s6_addr32[3];
958 rtcache_init((struct route *)ro);
959 } else
960 #endif
961 if (ro->ro_rt == NULL && !IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_faddr)) {
962 struct sockaddr_in6 *dst6;
963
964 dst6 = (struct sockaddr_in6 *)&ro->ro_dst;
965 memset(dst6, 0, sizeof(*dst6));
966 dst6->sin6_family = AF_INET6;
967 dst6->sin6_len = sizeof(struct sockaddr_in6);
968 dst6->sin6_addr = in6p->in6p_faddr;
969 rtcache_init((struct route *)ro);
970 }
971 return ro->ro_rt;
972 }
973
974 struct in6pcb *
975 in6_pcblookup_connect(struct inpcbtable *table, const struct in6_addr *faddr6,
976 u_int fport_arg, const struct in6_addr *laddr6, u_int lport_arg,
977 int faith)
978 {
979 struct inpcbhead *head;
980 struct inpcb_hdr *inph;
981 struct in6pcb *in6p;
982 u_int16_t fport = fport_arg, lport = lport_arg;
983
984 head = IN6PCBHASH_CONNECT(table, faddr6, fport, laddr6, lport);
985 LIST_FOREACH(inph, head, inph_hash) {
986 in6p = (struct in6pcb *)inph;
987 if (in6p->in6p_af != AF_INET6)
988 continue;
989
990 /* find exact match on both source and dest */
991 if (in6p->in6p_fport != fport)
992 continue;
993 if (in6p->in6p_lport != lport)
994 continue;
995 if (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_faddr))
996 continue;
997 if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr, faddr6))
998 continue;
999 if (IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr))
1000 continue;
1001 if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, laddr6))
1002 continue;
1003 if ((IN6_IS_ADDR_V4MAPPED(laddr6) ||
1004 IN6_IS_ADDR_V4MAPPED(faddr6)) &&
1005 (in6p->in6p_flags & IN6P_IPV6_V6ONLY))
1006 continue;
1007 return in6p;
1008 }
1009 return NULL;
1010 }
1011
1012 struct in6pcb *
1013 in6_pcblookup_bind(table, laddr6, lport_arg, faith)
1014 struct inpcbtable *table;
1015 const struct in6_addr *laddr6;
1016 u_int lport_arg;
1017 int faith;
1018 {
1019 struct inpcbhead *head;
1020 struct inpcb_hdr *inph;
1021 struct in6pcb *in6p;
1022 u_int16_t lport = lport_arg;
1023 #ifdef INET
1024 struct in6_addr zero_mapped;
1025 #endif
1026
1027 head = IN6PCBHASH_BIND(table, laddr6, lport);
1028 LIST_FOREACH(inph, head, inph_hash) {
1029 in6p = (struct in6pcb *)inph;
1030 if (in6p->in6p_af != AF_INET6)
1031 continue;
1032
1033 if (faith && (in6p->in6p_flags & IN6P_FAITH) == 0)
1034 continue;
1035 if (in6p->in6p_fport != 0)
1036 continue;
1037 if (in6p->in6p_lport != lport)
1038 continue;
1039 if (IN6_IS_ADDR_V4MAPPED(laddr6) &&
1040 (in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
1041 continue;
1042 if (IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, laddr6))
1043 goto out;
1044 }
1045 #ifdef INET
1046 if (IN6_IS_ADDR_V4MAPPED(laddr6)) {
1047 memset(&zero_mapped, 0, sizeof(zero_mapped));
1048 zero_mapped.s6_addr16[5] = 0xffff;
1049 head = IN6PCBHASH_BIND(table, &zero_mapped, lport);
1050 LIST_FOREACH(inph, head, inph_hash) {
1051 in6p = (struct in6pcb *)inph;
1052 if (in6p->in6p_af != AF_INET6)
1053 continue;
1054
1055 if (faith && (in6p->in6p_flags & IN6P_FAITH) == 0)
1056 continue;
1057 if (in6p->in6p_fport != 0)
1058 continue;
1059 if (in6p->in6p_lport != lport)
1060 continue;
1061 if ((in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
1062 continue;
1063 if (IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, &zero_mapped))
1064 goto out;
1065 }
1066 }
1067 #endif
1068 head = IN6PCBHASH_BIND(table, &zeroin6_addr, lport);
1069 LIST_FOREACH(inph, head, inph_hash) {
1070 in6p = (struct in6pcb *)inph;
1071 if (in6p->in6p_af != AF_INET6)
1072 continue;
1073
1074 if (faith && (in6p->in6p_flags & IN6P_FAITH) == 0)
1075 continue;
1076 if (in6p->in6p_fport != 0)
1077 continue;
1078 if (in6p->in6p_lport != lport)
1079 continue;
1080 if (IN6_IS_ADDR_V4MAPPED(laddr6) &&
1081 (in6p->in6p_flags & IN6P_IPV6_V6ONLY) != 0)
1082 continue;
1083 if (IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, &zeroin6_addr))
1084 goto out;
1085 }
1086 return (NULL);
1087
1088 out:
1089 inph = &in6p->in6p_head;
1090 if (inph != LIST_FIRST(head)) {
1091 LIST_REMOVE(inph, inph_hash);
1092 LIST_INSERT_HEAD(head, inph, inph_hash);
1093 }
1094 return in6p;
1095 }
1096
1097 void
1098 in6_pcbstate(in6p, state)
1099 struct in6pcb *in6p;
1100 int state;
1101 {
1102
1103 if (in6p->in6p_af != AF_INET6)
1104 return;
1105
1106 if (in6p->in6p_state > IN6P_ATTACHED)
1107 LIST_REMOVE(&in6p->in6p_head, inph_hash);
1108
1109 switch (state) {
1110 case IN6P_BOUND:
1111 LIST_INSERT_HEAD(IN6PCBHASH_BIND(in6p->in6p_table,
1112 &in6p->in6p_laddr, in6p->in6p_lport), &in6p->in6p_head,
1113 inph_hash);
1114 break;
1115 case IN6P_CONNECTED:
1116 LIST_INSERT_HEAD(IN6PCBHASH_CONNECT(in6p->in6p_table,
1117 &in6p->in6p_faddr, in6p->in6p_fport,
1118 &in6p->in6p_laddr, in6p->in6p_lport), &in6p->in6p_head,
1119 inph_hash);
1120 break;
1121 }
1122
1123 in6p->in6p_state = state;
1124 }
1125