Home | History | Annotate | Line # | Download | only in netinet
in_pcb.c revision 1.119.14.1
      1  1.119.14.1    bouyer /*	$NetBSD: in_pcb.c,v 1.119.14.1 2008/01/02 21:57:19 bouyer Exp $	*/
      2        1.59    itojun 
      3        1.59    itojun /*
      4        1.59    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
      5        1.59    itojun  * All rights reserved.
      6        1.78    itojun  *
      7        1.59    itojun  * Redistribution and use in source and binary forms, with or without
      8        1.59    itojun  * modification, are permitted provided that the following conditions
      9        1.59    itojun  * are met:
     10        1.59    itojun  * 1. Redistributions of source code must retain the above copyright
     11        1.59    itojun  *    notice, this list of conditions and the following disclaimer.
     12        1.59    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     13        1.59    itojun  *    notice, this list of conditions and the following disclaimer in the
     14        1.59    itojun  *    documentation and/or other materials provided with the distribution.
     15        1.59    itojun  * 3. Neither the name of the project nor the names of its contributors
     16        1.59    itojun  *    may be used to endorse or promote products derived from this software
     17        1.59    itojun  *    without specific prior written permission.
     18        1.78    itojun  *
     19        1.59    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     20        1.59    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21        1.59    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22        1.59    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     23        1.59    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24        1.59    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25        1.59    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26        1.59    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27        1.59    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28        1.59    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29        1.59    itojun  * SUCH DAMAGE.
     30        1.59    itojun  */
     31        1.57   thorpej 
     32        1.57   thorpej /*-
     33        1.57   thorpej  * Copyright (c) 1998 The NetBSD Foundation, Inc.
     34        1.57   thorpej  * All rights reserved.
     35        1.57   thorpej  *
     36        1.57   thorpej  * This code is derived from software contributed to The NetBSD Foundation
     37        1.57   thorpej  * by Public Access Networks Corporation ("Panix").  It was developed under
     38        1.57   thorpej  * contract to Panix by Eric Haszlakiewicz and Thor Lancelot Simon.
     39        1.57   thorpej  *
     40        1.57   thorpej  * Redistribution and use in source and binary forms, with or without
     41        1.57   thorpej  * modification, are permitted provided that the following conditions
     42        1.57   thorpej  * are met:
     43        1.57   thorpej  * 1. Redistributions of source code must retain the above copyright
     44        1.57   thorpej  *    notice, this list of conditions and the following disclaimer.
     45        1.57   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     46        1.57   thorpej  *    notice, this list of conditions and the following disclaimer in the
     47        1.57   thorpej  *    documentation and/or other materials provided with the distribution.
     48        1.57   thorpej  * 3. All advertising materials mentioning features or use of this software
     49        1.57   thorpej  *    must display the following acknowledgement:
     50        1.57   thorpej  *	This product includes software developed by the NetBSD
     51        1.57   thorpej  *	Foundation, Inc. and its contributors.
     52        1.57   thorpej  * 4. Neither the name of The NetBSD Foundation nor the names of its
     53        1.57   thorpej  *    contributors may be used to endorse or promote products derived
     54        1.57   thorpej  *    from this software without specific prior written permission.
     55        1.57   thorpej  *
     56        1.57   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     57        1.57   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     58        1.57   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     59        1.57   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     60        1.57   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     61        1.57   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     62        1.57   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     63        1.57   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     64        1.57   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     65        1.57   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     66        1.57   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     67        1.57   thorpej  */
     68        1.11       cgd 
     69         1.1       cgd /*
     70        1.44   thorpej  * Copyright (c) 1982, 1986, 1991, 1993, 1995
     71        1.10   mycroft  *	The Regents of the University of California.  All rights reserved.
     72         1.1       cgd  *
     73         1.1       cgd  * Redistribution and use in source and binary forms, with or without
     74         1.1       cgd  * modification, are permitted provided that the following conditions
     75         1.1       cgd  * are met:
     76         1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     77         1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     78         1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     79         1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     80         1.1       cgd  *    documentation and/or other materials provided with the distribution.
     81        1.86       agc  * 3. Neither the name of the University nor the names of its contributors
     82         1.1       cgd  *    may be used to endorse or promote products derived from this software
     83         1.1       cgd  *    without specific prior written permission.
     84         1.1       cgd  *
     85         1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     86         1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     87         1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     88         1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     89         1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     90         1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     91         1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     92         1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     93         1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     94         1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     95         1.1       cgd  * SUCH DAMAGE.
     96         1.1       cgd  *
     97        1.44   thorpej  *	@(#)in_pcb.c	8.4 (Berkeley) 5/24/95
     98         1.1       cgd  */
     99        1.73     lukem 
    100        1.73     lukem #include <sys/cdefs.h>
    101  1.119.14.1    bouyer __KERNEL_RCSID(0, "$NetBSD: in_pcb.c,v 1.119.14.1 2008/01/02 21:57:19 bouyer Exp $");
    102        1.60   thorpej 
    103        1.88    itojun #include "opt_inet.h"
    104        1.60   thorpej #include "opt_ipsec.h"
    105         1.1       cgd 
    106         1.7   mycroft #include <sys/param.h>
    107         1.7   mycroft #include <sys/systm.h>
    108         1.7   mycroft #include <sys/malloc.h>
    109         1.7   mycroft #include <sys/mbuf.h>
    110         1.7   mycroft #include <sys/protosw.h>
    111         1.7   mycroft #include <sys/socket.h>
    112         1.7   mycroft #include <sys/socketvar.h>
    113         1.7   mycroft #include <sys/ioctl.h>
    114        1.10   mycroft #include <sys/errno.h>
    115        1.10   mycroft #include <sys/time.h>
    116        1.52   thorpej #include <sys/pool.h>
    117        1.10   mycroft #include <sys/proc.h>
    118       1.102      elad #include <sys/kauth.h>
    119         1.1       cgd 
    120         1.7   mycroft #include <net/if.h>
    121         1.7   mycroft #include <net/route.h>
    122         1.1       cgd 
    123         1.7   mycroft #include <netinet/in.h>
    124         1.7   mycroft #include <netinet/in_systm.h>
    125         1.7   mycroft #include <netinet/ip.h>
    126         1.7   mycroft #include <netinet/in_pcb.h>
    127         1.7   mycroft #include <netinet/in_var.h>
    128         1.7   mycroft #include <netinet/ip_var.h>
    129         1.1       cgd 
    130        1.88    itojun #ifdef INET6
    131        1.88    itojun #include <netinet/ip6.h>
    132        1.88    itojun #include <netinet6/ip6_var.h>
    133        1.88    itojun #include <netinet6/in6_pcb.h>
    134        1.88    itojun #endif
    135        1.88    itojun 
    136        1.59    itojun #ifdef IPSEC
    137        1.59    itojun #include <netinet6/ipsec.h>
    138        1.59    itojun #include <netkey/key.h>
    139        1.87  jonathan #elif FAST_IPSEC
    140        1.87  jonathan #include <netipsec/ipsec.h>
    141        1.87  jonathan #include <netipsec/key.h>
    142        1.59    itojun #endif /* IPSEC */
    143        1.59    itojun 
    144         1.1       cgd struct	in_addr zeroin_addr;
    145         1.1       cgd 
    146        1.90    provos #define	INPCBHASH_PORT(table, lport) \
    147        1.92    itojun 	&(table)->inpt_porthashtbl[ntohs(lport) & (table)->inpt_porthash]
    148        1.33   mycroft #define	INPCBHASH_BIND(table, laddr, lport) \
    149        1.33   mycroft 	&(table)->inpt_bindhashtbl[ \
    150        1.33   mycroft 	    ((ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_bindhash]
    151        1.33   mycroft #define	INPCBHASH_CONNECT(table, faddr, fport, laddr, lport) \
    152        1.33   mycroft 	&(table)->inpt_connecthashtbl[ \
    153        1.33   mycroft 	    ((ntohl((faddr).s_addr) + ntohs(fport)) + \
    154        1.33   mycroft 	     (ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_connecthash]
    155        1.33   mycroft 
    156        1.43     lukem int	anonportmin = IPPORT_ANONMIN;
    157        1.43     lukem int	anonportmax = IPPORT_ANONMAX;
    158        1.67      tron int	lowportmin  = IPPORT_RESERVEDMIN;
    159        1.67      tron int	lowportmax  = IPPORT_RESERVEDMAX;
    160        1.43     lukem 
    161       1.116        ad POOL_INIT(inpcb_pool, sizeof(struct inpcb), 0, 0, 0, "inpcbpl", NULL,
    162       1.116        ad     IPL_NET);
    163        1.52   thorpej 
    164        1.18   mycroft void
    165        1.98     perry in_pcbinit(struct inpcbtable *table, int bindhashsize, int connecthashsize)
    166        1.18   mycroft {
    167        1.18   mycroft 
    168        1.21       cgd 	CIRCLEQ_INIT(&table->inpt_queue);
    169        1.90    provos 	table->inpt_porthashtbl = hashinit(bindhashsize, HASH_LIST, M_PCB,
    170        1.90    provos 	    M_WAITOK, &table->inpt_porthash);
    171        1.68        ad 	table->inpt_bindhashtbl = hashinit(bindhashsize, HASH_LIST, M_PCB,
    172        1.68        ad 	    M_WAITOK, &table->inpt_bindhash);
    173        1.68        ad 	table->inpt_connecthashtbl = hashinit(connecthashsize, HASH_LIST,
    174        1.68        ad 	    M_PCB, M_WAITOK, &table->inpt_connecthash);
    175        1.47     lukem 	table->inpt_lastlow = IPPORT_RESERVEDMAX;
    176        1.47     lukem 	table->inpt_lastport = (u_int16_t)anonportmax;
    177        1.18   mycroft }
    178        1.18   mycroft 
    179        1.10   mycroft int
    180        1.98     perry in_pcballoc(struct socket *so, void *v)
    181         1.1       cgd {
    182        1.25  christos 	struct inpcbtable *table = v;
    183        1.64  augustss 	struct inpcb *inp;
    184        1.24   mycroft 	int s;
    185        1.87  jonathan #if defined(IPSEC) || defined(FAST_IPSEC)
    186        1.70    itojun 	int error;
    187        1.70    itojun #endif
    188         1.1       cgd 
    189       1.106       tls 	s = splnet();
    190        1.52   thorpej 	inp = pool_get(&inpcb_pool, PR_NOWAIT);
    191       1.106       tls 	splx(s);
    192        1.10   mycroft 	if (inp == NULL)
    193         1.1       cgd 		return (ENOBUFS);
    194       1.115  christos 	bzero((void *)inp, sizeof(*inp));
    195        1.88    itojun 	inp->inp_af = AF_INET;
    196        1.18   mycroft 	inp->inp_table = table;
    197         1.1       cgd 	inp->inp_socket = so;
    198        1.39      matt 	inp->inp_errormtu = -1;
    199        1.87  jonathan #if defined(IPSEC) || defined(FAST_IPSEC)
    200        1.79    itojun 	error = ipsec_init_pcbpolicy(so, &inp->inp_sp);
    201        1.70    itojun 	if (error != 0) {
    202       1.106       tls 		s = splnet();
    203        1.70    itojun 		pool_put(&inpcb_pool, inp);
    204       1.106       tls 		splx(s);
    205        1.70    itojun 		return error;
    206        1.70    itojun 	}
    207        1.70    itojun #endif
    208        1.33   mycroft 	so->so_pcb = inp;
    209        1.24   mycroft 	s = splnet();
    210        1.88    itojun 	CIRCLEQ_INSERT_HEAD(&table->inpt_queue, &inp->inp_head,
    211        1.88    itojun 	    inph_queue);
    212        1.90    provos 	LIST_INSERT_HEAD(INPCBHASH_PORT(table, inp->inp_lport), &inp->inp_head,
    213        1.90    provos 	    inph_lhash);
    214        1.33   mycroft 	in_pcbstate(inp, INP_ATTACHED);
    215        1.24   mycroft 	splx(s);
    216         1.1       cgd 	return (0);
    217         1.1       cgd }
    218         1.8   mycroft 
    219        1.10   mycroft int
    220       1.103        ad in_pcbbind(void *v, struct mbuf *nam, struct lwp *l)
    221         1.1       cgd {
    222        1.82      matt 	struct in_ifaddr *ia = NULL;
    223        1.64  augustss 	struct inpcb *inp = v;
    224        1.64  augustss 	struct socket *so = inp->inp_socket;
    225        1.64  augustss 	struct inpcbtable *table = inp->inp_table;
    226       1.104      elad 	struct sockaddr_in *sin = NULL; /* XXXGCC */
    227        1.13       cgd 	u_int16_t lport = 0;
    228        1.10   mycroft 	int wild = 0, reuseport = (so->so_options & SO_REUSEPORT);
    229  1.119.14.1    bouyer 	kauth_cred_t cred = l->l_cred;
    230         1.1       cgd 
    231        1.88    itojun 	if (inp->inp_af != AF_INET)
    232        1.88    itojun 		return (EINVAL);
    233        1.88    itojun 
    234        1.91  jonathan 	if (TAILQ_FIRST(&in_ifaddrhead) == 0)
    235         1.1       cgd 		return (EADDRNOTAVAIL);
    236        1.32   mycroft 	if (inp->inp_lport || !in_nullhost(inp->inp_laddr))
    237         1.1       cgd 		return (EINVAL);
    238        1.55     lukem 	if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0)
    239        1.54     lukem 		wild = 1;
    240        1.28   mycroft 	if (nam == 0)
    241        1.28   mycroft 		goto noname;
    242        1.28   mycroft 	sin = mtod(nam, struct sockaddr_in *);
    243        1.28   mycroft 	if (nam->m_len != sizeof (*sin))
    244        1.28   mycroft 		return (EINVAL);
    245        1.28   mycroft 	if (sin->sin_family != AF_INET)
    246        1.28   mycroft 		return (EAFNOSUPPORT);
    247        1.28   mycroft 	lport = sin->sin_port;
    248        1.28   mycroft 	if (IN_MULTICAST(sin->sin_addr.s_addr)) {
    249        1.10   mycroft 		/*
    250        1.28   mycroft 		 * Treat SO_REUSEADDR as SO_REUSEPORT for multicast;
    251        1.28   mycroft 		 * allow complete duplication of binding if
    252        1.28   mycroft 		 * SO_REUSEPORT is set, or if SO_REUSEADDR is set
    253        1.28   mycroft 		 * and a multicast address is bound on both
    254        1.28   mycroft 		 * new and duplicated sockets.
    255        1.10   mycroft 		 */
    256        1.28   mycroft 		if (so->so_options & SO_REUSEADDR)
    257        1.28   mycroft 			reuseport = SO_REUSEADDR|SO_REUSEPORT;
    258        1.32   mycroft 	} else if (!in_nullhost(sin->sin_addr)) {
    259        1.28   mycroft 		sin->sin_port = 0;		/* yech... */
    260        1.82      matt 		INADDR_TO_IA(sin->sin_addr, ia);
    261        1.85    itojun 		/* check for broadcast addresses */
    262        1.85    itojun 		if (ia == NULL)
    263        1.85    itojun 			ia = ifatoia(ifa_ifwithaddr(sintosa(sin)));
    264        1.82      matt 		if (ia == NULL)
    265        1.28   mycroft 			return (EADDRNOTAVAIL);
    266        1.28   mycroft 	}
    267        1.28   mycroft 	if (lport) {
    268        1.28   mycroft 		struct inpcb *t;
    269        1.88    itojun #ifdef INET6
    270        1.88    itojun 		struct in6pcb *t6;
    271        1.88    itojun 		struct in6_addr mapped;
    272        1.88    itojun #endif
    273        1.31     perry #ifndef IPNOPRIVPORTS
    274        1.28   mycroft 		/* GROSS */
    275        1.28   mycroft 		if (ntohs(lport) < IPPORT_RESERVED &&
    276  1.119.14.1    bouyer 		    kauth_authorize_network(cred,
    277       1.104      elad 		    KAUTH_NETWORK_BIND,
    278       1.105      elad 		    KAUTH_REQ_NETWORK_BIND_PRIVPORT, so, sin,
    279  1.119.14.1    bouyer 		    NULL))
    280        1.28   mycroft 			return (EACCES);
    281        1.31     perry #endif
    282        1.88    itojun #ifdef INET6
    283        1.88    itojun 		memset(&mapped, 0, sizeof(mapped));
    284        1.88    itojun 		mapped.s6_addr16[5] = 0xffff;
    285        1.88    itojun 		memcpy(&mapped.s6_addr32[3], &sin->sin_addr,
    286        1.88    itojun 		    sizeof(mapped.s6_addr32[3]));
    287        1.88    itojun 		t6 = in6_pcblookup_port(table, &mapped, lport, wild);
    288        1.88    itojun 		if (t6 && (reuseport & t6->in6p_socket->so_options) == 0)
    289        1.88    itojun 			return (EADDRINUSE);
    290        1.88    itojun #endif
    291        1.99  christos 		if (so->so_uidinfo->ui_uid && !IN_MULTICAST(sin->sin_addr.s_addr)) {
    292        1.58     lukem 			t = in_pcblookup_port(table, sin->sin_addr, lport, 1);
    293        1.58     lukem 		/*
    294        1.58     lukem 		 * XXX:	investigate ramifications of loosening this
    295        1.58     lukem 		 *	restriction so that as long as both ports have
    296        1.58     lukem 		 *	SO_REUSEPORT allow the bind
    297        1.58     lukem 		 */
    298        1.58     lukem 			if (t &&
    299        1.58     lukem 			    (!in_nullhost(sin->sin_addr) ||
    300        1.58     lukem 			     !in_nullhost(t->inp_laddr) ||
    301        1.58     lukem 			     (t->inp_socket->so_options & SO_REUSEPORT) == 0)
    302        1.99  christos 			    && (so->so_uidinfo->ui_uid != t->inp_socket->so_uidinfo->ui_uid)) {
    303        1.58     lukem 				return (EADDRINUSE);
    304        1.58     lukem 			}
    305        1.58     lukem 		}
    306        1.33   mycroft 		t = in_pcblookup_port(table, sin->sin_addr, lport, wild);
    307        1.28   mycroft 		if (t && (reuseport & t->inp_socket->so_options) == 0)
    308        1.28   mycroft 			return (EADDRINUSE);
    309         1.1       cgd 	}
    310        1.28   mycroft 	inp->inp_laddr = sin->sin_addr;
    311        1.45     lukem 
    312        1.28   mycroft noname:
    313        1.36   mycroft 	if (lport == 0) {
    314        1.46     lukem 		int	   cnt;
    315       1.100  christos 		u_int16_t  mymin, mymax;
    316        1.45     lukem 		u_int16_t *lastport;
    317        1.45     lukem 
    318        1.45     lukem 		if (inp->inp_flags & INP_LOWPORT) {
    319        1.45     lukem #ifndef IPNOPRIVPORTS
    320  1.119.14.1    bouyer 			if (kauth_authorize_network(cred,
    321       1.104      elad 			    KAUTH_NETWORK_BIND,
    322       1.105      elad 			    KAUTH_REQ_NETWORK_BIND_PRIVPORT, so,
    323       1.104      elad 			    sin, NULL))
    324        1.45     lukem 				return (EACCES);
    325        1.45     lukem #endif
    326       1.100  christos 			mymin = lowportmin;
    327       1.100  christos 			mymax = lowportmax;
    328        1.45     lukem 			lastport = &table->inpt_lastlow;
    329        1.45     lukem 		} else {
    330       1.100  christos 			mymin = anonportmin;
    331       1.100  christos 			mymax = anonportmax;
    332        1.45     lukem 			lastport = &table->inpt_lastport;
    333        1.45     lukem 		}
    334       1.100  christos 		if (mymin > mymax) {	/* sanity check */
    335        1.45     lukem 			u_int16_t swp;
    336        1.45     lukem 
    337       1.100  christos 			swp = mymin;
    338       1.100  christos 			mymin = mymax;
    339       1.100  christos 			mymax = swp;
    340        1.45     lukem 		}
    341        1.43     lukem 
    342        1.47     lukem 		lport = *lastport - 1;
    343       1.100  christos 		for (cnt = mymax - mymin + 1; cnt; cnt--, lport--) {
    344       1.100  christos 			if (lport < mymin || lport > mymax)
    345       1.100  christos 				lport = mymax;
    346        1.36   mycroft 			if (!in_pcblookup_port(table, inp->inp_laddr,
    347        1.54     lukem 			    htons(lport), 1))
    348        1.36   mycroft 				goto found;
    349        1.42     lukem 		}
    350        1.89   mycroft 		if (!in_nullhost(inp->inp_laddr))
    351        1.40   thorpej 			inp->inp_laddr.s_addr = INADDR_ANY;
    352        1.36   mycroft 		return (EAGAIN);
    353        1.36   mycroft 	found:
    354        1.45     lukem 		inp->inp_flags |= INP_ANONPORT;
    355        1.45     lukem 		*lastport = lport;
    356        1.36   mycroft 		lport = htons(lport);
    357        1.36   mycroft 	}
    358         1.1       cgd 	inp->inp_lport = lport;
    359        1.90    provos 	LIST_REMOVE(&inp->inp_head, inph_lhash);
    360        1.90    provos 	LIST_INSERT_HEAD(INPCBHASH_PORT(table, inp->inp_lport), &inp->inp_head,
    361        1.90    provos 	    inph_lhash);
    362        1.33   mycroft 	in_pcbstate(inp, INP_BOUND);
    363         1.1       cgd 	return (0);
    364         1.1       cgd }
    365         1.1       cgd 
    366         1.1       cgd /*
    367         1.1       cgd  * Connect from a socket to a specified address.
    368         1.1       cgd  * Both address and port must be specified in argument sin.
    369         1.1       cgd  * If don't have a local address for this socket yet,
    370         1.1       cgd  * then pick one.
    371         1.1       cgd  */
    372        1.10   mycroft int
    373       1.103        ad in_pcbconnect(void *v, struct mbuf *nam, struct lwp *l)
    374         1.1       cgd {
    375        1.64  augustss 	struct inpcb *inp = v;
    376        1.82      matt 	struct in_ifaddr *ia = NULL;
    377        1.25  christos 	struct sockaddr_in *ifaddr = NULL;
    378        1.64  augustss 	struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
    379        1.40   thorpej 	int error;
    380         1.1       cgd 
    381        1.88    itojun 	if (inp->inp_af != AF_INET)
    382        1.88    itojun 		return (EINVAL);
    383        1.88    itojun 
    384         1.1       cgd 	if (nam->m_len != sizeof (*sin))
    385         1.1       cgd 		return (EINVAL);
    386         1.1       cgd 	if (sin->sin_family != AF_INET)
    387         1.1       cgd 		return (EAFNOSUPPORT);
    388         1.1       cgd 	if (sin->sin_port == 0)
    389         1.1       cgd 		return (EADDRNOTAVAIL);
    390        1.91  jonathan 	if (TAILQ_FIRST(&in_ifaddrhead) != 0) {
    391         1.1       cgd 		/*
    392         1.1       cgd 		 * If the destination address is INADDR_ANY,
    393        1.49       tls 		 * use any local address (likely loopback).
    394         1.1       cgd 		 * If the supplied address is INADDR_BROADCAST,
    395        1.49       tls 		 * use the broadcast address of an interface
    396        1.49       tls 		 * which supports broadcast. (loopback does not)
    397         1.1       cgd 		 */
    398        1.49       tls 
    399        1.72      matt 		if (in_nullhost(sin->sin_addr)) {
    400        1.72      matt 			sin->sin_addr =
    401        1.91  jonathan 			    TAILQ_FIRST(&in_ifaddrhead)->ia_addr.sin_addr;
    402        1.72      matt 		} else if (sin->sin_addr.s_addr == INADDR_BROADCAST) {
    403        1.91  jonathan 			TAILQ_FOREACH(ia, &in_ifaddrhead, ia_list) {
    404        1.72      matt 				if (ia->ia_ifp->if_flags & IFF_BROADCAST) {
    405        1.72      matt 					sin->sin_addr =
    406        1.72      matt 					    ia->ia_broadaddr.sin_addr;
    407        1.72      matt 					break;
    408        1.72      matt 				}
    409        1.49       tls 			}
    410        1.72      matt 		}
    411         1.1       cgd 	}
    412        1.32   mycroft 	/*
    413        1.32   mycroft 	 * If we haven't bound which network number to use as ours,
    414        1.32   mycroft 	 * we will use the number of the outgoing interface.
    415        1.32   mycroft 	 * This depends on having done a routing lookup, which
    416        1.32   mycroft 	 * we will probably have to do anyway, so we might
    417        1.32   mycroft 	 * as well do it now.  On the other hand if we are
    418        1.32   mycroft 	 * sending to multiple destinations we may have already
    419        1.32   mycroft 	 * done the lookup, so see if we can use the route
    420        1.32   mycroft 	 * from before.  In any case, we only
    421        1.32   mycroft 	 * chose a port number once, even if sending to multiple
    422        1.32   mycroft 	 * destinations.
    423        1.32   mycroft 	 */
    424        1.32   mycroft 	if (in_nullhost(inp->inp_laddr)) {
    425       1.100  christos 		int xerror;
    426        1.59    itojun 		ifaddr = in_selectsrc(sin, &inp->inp_route,
    427       1.100  christos 		    inp->inp_socket->so_options, inp->inp_moptions, &xerror);
    428        1.59    itojun 		if (ifaddr == NULL) {
    429       1.100  christos 			if (xerror == 0)
    430       1.100  christos 				xerror = EADDRNOTAVAIL;
    431       1.100  christos 			return xerror;
    432        1.59    itojun 		}
    433        1.82      matt 		INADDR_TO_IA(ifaddr->sin_addr, ia);
    434        1.83    itojun 		if (ia == NULL)
    435        1.83    itojun 			return (EADDRNOTAVAIL);
    436         1.1       cgd 	}
    437        1.33   mycroft 	if (in_pcblookup_connect(inp->inp_table, sin->sin_addr, sin->sin_port,
    438        1.32   mycroft 	    !in_nullhost(inp->inp_laddr) ? inp->inp_laddr : ifaddr->sin_addr,
    439        1.24   mycroft 	    inp->inp_lport) != 0)
    440         1.1       cgd 		return (EADDRINUSE);
    441        1.32   mycroft 	if (in_nullhost(inp->inp_laddr)) {
    442        1.40   thorpej 		if (inp->inp_lport == 0) {
    443       1.103        ad 			error = in_pcbbind(inp, NULL, l);
    444        1.40   thorpej 			/*
    445        1.40   thorpej 			 * This used to ignore the return value
    446        1.40   thorpej 			 * completely, but we need to check for
    447        1.40   thorpej 			 * ephemeral port shortage.
    448       1.101       dsl 			 * And attempts to request low ports if not root.
    449        1.40   thorpej 			 */
    450       1.101       dsl 			if (error != 0)
    451        1.40   thorpej 				return (error);
    452        1.40   thorpej 		}
    453         1.1       cgd 		inp->inp_laddr = ifaddr->sin_addr;
    454         1.1       cgd 	}
    455         1.1       cgd 	inp->inp_faddr = sin->sin_addr;
    456         1.1       cgd 	inp->inp_fport = sin->sin_port;
    457        1.33   mycroft 	in_pcbstate(inp, INP_CONNECTED);
    458        1.94   thorpej #if defined(IPSEC) || defined(FAST_IPSEC)
    459        1.71    itojun 	if (inp->inp_socket->so_type == SOCK_STREAM)
    460        1.71    itojun 		ipsec_pcbconn(inp->inp_sp);
    461        1.71    itojun #endif
    462         1.1       cgd 	return (0);
    463         1.1       cgd }
    464         1.1       cgd 
    465        1.25  christos void
    466        1.98     perry in_pcbdisconnect(void *v)
    467         1.1       cgd {
    468        1.25  christos 	struct inpcb *inp = v;
    469         1.1       cgd 
    470        1.88    itojun 	if (inp->inp_af != AF_INET)
    471        1.88    itojun 		return;
    472        1.88    itojun 
    473        1.32   mycroft 	inp->inp_faddr = zeroin_addr;
    474         1.1       cgd 	inp->inp_fport = 0;
    475        1.33   mycroft 	in_pcbstate(inp, INP_BOUND);
    476        1.94   thorpej #if defined(IPSEC) || defined(FAST_IPSEC)
    477        1.71    itojun 	ipsec_pcbdisconn(inp->inp_sp);
    478        1.71    itojun #endif
    479        1.93    itojun 	if (inp->inp_socket->so_state & SS_NOFDREF)
    480        1.93    itojun 		in_pcbdetach(inp);
    481         1.1       cgd }
    482         1.1       cgd 
    483        1.25  christos void
    484        1.98     perry in_pcbdetach(void *v)
    485         1.1       cgd {
    486        1.25  christos 	struct inpcb *inp = v;
    487         1.1       cgd 	struct socket *so = inp->inp_socket;
    488        1.24   mycroft 	int s;
    489         1.1       cgd 
    490        1.88    itojun 	if (inp->inp_af != AF_INET)
    491        1.88    itojun 		return;
    492        1.88    itojun 
    493        1.87  jonathan #if defined(IPSEC) || defined(FAST_IPSEC)
    494        1.59    itojun 	ipsec4_delete_pcbpolicy(inp);
    495        1.59    itojun #endif /*IPSEC*/
    496         1.1       cgd 	so->so_pcb = 0;
    497         1.1       cgd 	sofree(so);
    498         1.1       cgd 	if (inp->inp_options)
    499         1.1       cgd 		(void)m_free(inp->inp_options);
    500       1.112     joerg 	rtcache_free(&inp->inp_route);
    501         1.6   hpeyerl 	ip_freemoptions(inp->inp_moptions);
    502        1.24   mycroft 	s = splnet();
    503        1.33   mycroft 	in_pcbstate(inp, INP_ATTACHED);
    504        1.90    provos 	LIST_REMOVE(&inp->inp_head, inph_lhash);
    505        1.88    itojun 	CIRCLEQ_REMOVE(&inp->inp_table->inpt_queue, &inp->inp_head,
    506        1.88    itojun 	    inph_queue);
    507       1.106       tls 	pool_put(&inpcb_pool, inp);
    508        1.24   mycroft 	splx(s);
    509         1.1       cgd }
    510         1.1       cgd 
    511        1.25  christos void
    512        1.98     perry in_setsockaddr(struct inpcb *inp, struct mbuf *nam)
    513         1.1       cgd {
    514        1.64  augustss 	struct sockaddr_in *sin;
    515        1.78    itojun 
    516        1.88    itojun 	if (inp->inp_af != AF_INET)
    517        1.88    itojun 		return;
    518        1.88    itojun 
    519         1.1       cgd 	sin = mtod(nam, struct sockaddr_in *);
    520       1.119    dyoung 	sockaddr_in_init(sin, &inp->inp_laddr, inp->inp_lport);
    521       1.119    dyoung 	nam->m_len = sin->sin_len;
    522         1.1       cgd }
    523         1.1       cgd 
    524        1.25  christos void
    525        1.98     perry in_setpeeraddr(struct inpcb *inp, struct mbuf *nam)
    526         1.1       cgd {
    527        1.64  augustss 	struct sockaddr_in *sin;
    528        1.78    itojun 
    529        1.88    itojun 	if (inp->inp_af != AF_INET)
    530        1.88    itojun 		return;
    531        1.88    itojun 
    532         1.1       cgd 	sin = mtod(nam, struct sockaddr_in *);
    533       1.119    dyoung 	sockaddr_in_init(sin, &inp->inp_faddr, inp->inp_fport);
    534       1.119    dyoung 	nam->m_len = sin->sin_len;
    535         1.1       cgd }
    536         1.1       cgd 
    537         1.1       cgd /*
    538         1.1       cgd  * Pass some notification to all connections of a protocol
    539         1.1       cgd  * associated with address dst.  The local address and/or port numbers
    540         1.1       cgd  * may be specified to limit the search.  The "usual action" will be
    541         1.1       cgd  * taken, depending on the ctlinput cmd.  The caller must filter any
    542         1.1       cgd  * cmds that are uninteresting (e.g., no error in the map).
    543         1.1       cgd  * Call the protocol specific routine (if any) to report
    544         1.1       cgd  * any errors for each matching socket.
    545         1.1       cgd  *
    546        1.22   mycroft  * Must be called at splsoftnet.
    547         1.1       cgd  */
    548        1.37   thorpej int
    549        1.98     perry in_pcbnotify(struct inpcbtable *table, struct in_addr faddr, u_int fport_arg,
    550        1.98     perry     struct in_addr laddr, u_int lport_arg, int errno,
    551        1.98     perry     void (*notify)(struct inpcb *, int))
    552         1.1       cgd {
    553        1.33   mycroft 	struct inpcbhead *head;
    554        1.64  augustss 	struct inpcb *inp, *ninp;
    555        1.13       cgd 	u_int16_t fport = fport_arg, lport = lport_arg;
    556        1.37   thorpej 	int nmatch;
    557         1.1       cgd 
    558        1.33   mycroft 	if (in_nullhost(faddr) || notify == 0)
    559        1.37   thorpej 		return (0);
    560         1.1       cgd 
    561        1.37   thorpej 	nmatch = 0;
    562        1.33   mycroft 	head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
    563        1.88    itojun 	for (inp = (struct inpcb *)LIST_FIRST(head); inp != NULL; inp = ninp) {
    564        1.88    itojun 		ninp = (struct inpcb *)LIST_NEXT(inp, inp_hash);
    565        1.88    itojun 		if (inp->inp_af != AF_INET)
    566        1.88    itojun 			continue;
    567        1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr) &&
    568        1.33   mycroft 		    inp->inp_fport == fport &&
    569        1.33   mycroft 		    inp->inp_lport == lport &&
    570        1.37   thorpej 		    in_hosteq(inp->inp_laddr, laddr)) {
    571        1.33   mycroft 			(*notify)(inp, errno);
    572        1.37   thorpej 			nmatch++;
    573        1.37   thorpej 		}
    574         1.1       cgd 	}
    575        1.37   thorpej 	return (nmatch);
    576        1.18   mycroft }
    577        1.18   mycroft 
    578        1.20   mycroft void
    579        1.98     perry in_pcbnotifyall(struct inpcbtable *table, struct in_addr faddr, int errno,
    580        1.98     perry     void (*notify)(struct inpcb *, int))
    581        1.18   mycroft {
    582        1.64  augustss 	struct inpcb *inp, *ninp;
    583        1.18   mycroft 
    584        1.33   mycroft 	if (in_nullhost(faddr) || notify == 0)
    585        1.18   mycroft 		return;
    586        1.18   mycroft 
    587        1.88    itojun 	for (inp = (struct inpcb *)CIRCLEQ_FIRST(&table->inpt_queue);
    588        1.72      matt 	    inp != (void *)&table->inpt_queue;
    589        1.33   mycroft 	    inp = ninp) {
    590        1.88    itojun 		ninp = (struct inpcb *)CIRCLEQ_NEXT(inp, inp_queue);
    591        1.88    itojun 		if (inp->inp_af != AF_INET)
    592        1.88    itojun 			continue;
    593        1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr))
    594        1.33   mycroft 			(*notify)(inp, errno);
    595        1.63   thorpej 	}
    596        1.63   thorpej }
    597        1.63   thorpej 
    598        1.63   thorpej void
    599        1.98     perry in_pcbpurgeif0(struct inpcbtable *table, struct ifnet *ifp)
    600        1.63   thorpej {
    601        1.64  augustss 	struct inpcb *inp, *ninp;
    602        1.65     enami 	struct ip_moptions *imo;
    603        1.65     enami 	int i, gap;
    604        1.63   thorpej 
    605        1.88    itojun 	for (inp = (struct inpcb *)CIRCLEQ_FIRST(&table->inpt_queue);
    606        1.72      matt 	    inp != (void *)&table->inpt_queue;
    607        1.63   thorpej 	    inp = ninp) {
    608        1.88    itojun 		ninp = (struct inpcb *)CIRCLEQ_NEXT(inp, inp_queue);
    609        1.88    itojun 		if (inp->inp_af != AF_INET)
    610        1.88    itojun 			continue;
    611        1.65     enami 		imo = inp->inp_moptions;
    612        1.65     enami 		if (imo != NULL) {
    613        1.65     enami 			/*
    614        1.65     enami 			 * Unselect the outgoing interface if it is being
    615        1.65     enami 			 * detached.
    616        1.65     enami 			 */
    617        1.65     enami 			if (imo->imo_multicast_ifp == ifp)
    618        1.65     enami 				imo->imo_multicast_ifp = NULL;
    619        1.65     enami 
    620        1.65     enami 			/*
    621        1.65     enami 			 * Drop multicast group membership if we joined
    622        1.65     enami 			 * through the interface being detached.
    623        1.65     enami 			 */
    624        1.65     enami 			for (i = 0, gap = 0; i < imo->imo_num_memberships;
    625        1.65     enami 			    i++) {
    626        1.65     enami 				if (imo->imo_membership[i]->inm_ifp == ifp) {
    627        1.65     enami 					in_delmulti(imo->imo_membership[i]);
    628        1.65     enami 					gap++;
    629        1.65     enami 				} else if (gap != 0)
    630        1.65     enami 					imo->imo_membership[i - gap] =
    631        1.65     enami 					    imo->imo_membership[i];
    632        1.65     enami 			}
    633        1.65     enami 			imo->imo_num_memberships -= gap;
    634        1.65     enami 		}
    635        1.69    itojun 	}
    636        1.69    itojun }
    637        1.69    itojun 
    638        1.69    itojun void
    639        1.98     perry in_pcbpurgeif(struct inpcbtable *table, struct ifnet *ifp)
    640        1.69    itojun {
    641  1.119.14.1    bouyer 	struct rtentry *rt;
    642        1.69    itojun 	struct inpcb *inp, *ninp;
    643        1.69    itojun 
    644        1.88    itojun 	for (inp = (struct inpcb *)CIRCLEQ_FIRST(&table->inpt_queue);
    645        1.72      matt 	    inp != (void *)&table->inpt_queue;
    646        1.69    itojun 	    inp = ninp) {
    647        1.88    itojun 		ninp = (struct inpcb *)CIRCLEQ_NEXT(inp, inp_queue);
    648        1.88    itojun 		if (inp->inp_af != AF_INET)
    649        1.88    itojun 			continue;
    650  1.119.14.1    bouyer 		if ((rt = rtcache_getrt(&inp->inp_route)) != NULL &&
    651  1.119.14.1    bouyer 		    rt->rt_ifp == ifp)
    652        1.69    itojun 			in_rtchange(inp, 0);
    653         1.1       cgd 	}
    654         1.1       cgd }
    655         1.1       cgd 
    656         1.1       cgd /*
    657         1.1       cgd  * Check for alternatives when higher level complains
    658         1.1       cgd  * about service problems.  For now, invalidate cached
    659         1.1       cgd  * routing information.  If the route was created dynamically
    660         1.1       cgd  * (by a redirect), time to try a default gateway again.
    661         1.1       cgd  */
    662        1.25  christos void
    663        1.98     perry in_losing(struct inpcb *inp)
    664         1.1       cgd {
    665        1.64  augustss 	struct rtentry *rt;
    666        1.10   mycroft 	struct rt_addrinfo info;
    667         1.1       cgd 
    668        1.88    itojun 	if (inp->inp_af != AF_INET)
    669        1.88    itojun 		return;
    670        1.88    itojun 
    671  1.119.14.1    bouyer 	if ((rt = rtcache_getrt(&inp->inp_route)) != NULL) {
    672       1.114    dyoung 		memset(&info, 0, sizeof(info));
    673       1.114    dyoung 		info.rti_info[RTAX_DST] = rtcache_getdst(&inp->inp_route);
    674        1.10   mycroft 		info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
    675        1.10   mycroft 		info.rti_info[RTAX_NETMASK] = rt_mask(rt);
    676        1.10   mycroft 		rt_missmsg(RTM_LOSING, &info, rt->rt_flags, 0);
    677         1.1       cgd 		if (rt->rt_flags & RTF_DYNAMIC)
    678       1.118    dyoung 			(void) rtrequest(RTM_DELETE, rt_getkey(rt),
    679        1.78    itojun 				rt->rt_gateway, rt_mask(rt), rt->rt_flags,
    680       1.111    dyoung 				NULL);
    681         1.1       cgd 		/*
    682         1.1       cgd 		 * A new route can be allocated
    683         1.1       cgd 		 * the next time output is attempted.
    684         1.1       cgd 		 */
    685       1.112     joerg 		rtcache_free(&inp->inp_route);
    686         1.1       cgd 	}
    687         1.1       cgd }
    688         1.1       cgd 
    689         1.1       cgd /*
    690       1.111    dyoung  * After a routing change, flush old routing.  A new route can be
    691       1.111    dyoung  * allocated the next time output is attempted.
    692         1.1       cgd  */
    693        1.10   mycroft void
    694       1.109  christos in_rtchange(struct inpcb *inp, int errno)
    695         1.1       cgd {
    696        1.32   mycroft 
    697        1.88    itojun 	if (inp->inp_af != AF_INET)
    698        1.88    itojun 		return;
    699        1.88    itojun 
    700       1.112     joerg 	rtcache_free(&inp->inp_route);
    701       1.112     joerg 
    702        1.49       tls 	/* XXX SHOULD NOTIFY HIGHER-LEVEL PROTOCOLS */
    703         1.1       cgd }
    704         1.1       cgd 
    705         1.1       cgd struct inpcb *
    706        1.98     perry in_pcblookup_port(struct inpcbtable *table, struct in_addr laddr,
    707        1.98     perry     u_int lport_arg, int lookup_wildcard)
    708         1.1       cgd {
    709        1.90    provos 	struct inpcbhead *head;
    710        1.88    itojun 	struct inpcb_hdr *inph;
    711        1.64  augustss 	struct inpcb *inp, *match = 0;
    712         1.1       cgd 	int matchwild = 3, wildcard;
    713        1.33   mycroft 	u_int16_t lport = lport_arg;
    714         1.1       cgd 
    715        1.90    provos 	head = INPCBHASH_PORT(table, lport);
    716        1.90    provos 	LIST_FOREACH(inph, head, inph_lhash) {
    717        1.88    itojun 		inp = (struct inpcb *)inph;
    718        1.88    itojun 		if (inp->inp_af != AF_INET)
    719        1.88    itojun 			continue;
    720        1.88    itojun 
    721         1.1       cgd 		if (inp->inp_lport != lport)
    722         1.1       cgd 			continue;
    723         1.1       cgd 		wildcard = 0;
    724        1.33   mycroft 		if (!in_nullhost(inp->inp_faddr))
    725        1.33   mycroft 			wildcard++;
    726        1.32   mycroft 		if (in_nullhost(inp->inp_laddr)) {
    727        1.32   mycroft 			if (!in_nullhost(laddr))
    728         1.1       cgd 				wildcard++;
    729         1.1       cgd 		} else {
    730        1.32   mycroft 			if (in_nullhost(laddr))
    731         1.1       cgd 				wildcard++;
    732        1.32   mycroft 			else {
    733        1.32   mycroft 				if (!in_hosteq(inp->inp_laddr, laddr))
    734        1.32   mycroft 					continue;
    735        1.32   mycroft 			}
    736         1.1       cgd 		}
    737        1.54     lukem 		if (wildcard && !lookup_wildcard)
    738         1.1       cgd 			continue;
    739         1.1       cgd 		if (wildcard < matchwild) {
    740         1.1       cgd 			match = inp;
    741         1.1       cgd 			matchwild = wildcard;
    742         1.1       cgd 			if (matchwild == 0)
    743         1.1       cgd 				break;
    744         1.1       cgd 		}
    745         1.1       cgd 	}
    746         1.1       cgd 	return (match);
    747        1.24   mycroft }
    748        1.24   mycroft 
    749        1.24   mycroft #ifdef DIAGNOSTIC
    750        1.24   mycroft int	in_pcbnotifymiss = 0;
    751        1.24   mycroft #endif
    752        1.24   mycroft 
    753        1.24   mycroft struct inpcb *
    754        1.98     perry in_pcblookup_connect(struct inpcbtable *table,
    755        1.98     perry     struct in_addr faddr, u_int fport_arg,
    756        1.98     perry     struct in_addr laddr, u_int lport_arg)
    757        1.24   mycroft {
    758        1.24   mycroft 	struct inpcbhead *head;
    759        1.88    itojun 	struct inpcb_hdr *inph;
    760        1.64  augustss 	struct inpcb *inp;
    761        1.24   mycroft 	u_int16_t fport = fport_arg, lport = lport_arg;
    762        1.24   mycroft 
    763        1.33   mycroft 	head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
    764        1.88    itojun 	LIST_FOREACH(inph, head, inph_hash) {
    765        1.88    itojun 		inp = (struct inpcb *)inph;
    766        1.88    itojun 		if (inp->inp_af != AF_INET)
    767        1.88    itojun 			continue;
    768        1.88    itojun 
    769        1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr) &&
    770        1.33   mycroft 		    inp->inp_fport == fport &&
    771        1.33   mycroft 		    inp->inp_lport == lport &&
    772        1.33   mycroft 		    in_hosteq(inp->inp_laddr, laddr))
    773        1.33   mycroft 			goto out;
    774        1.24   mycroft 	}
    775        1.24   mycroft #ifdef DIAGNOSTIC
    776        1.33   mycroft 	if (in_pcbnotifymiss) {
    777        1.35  christos 		printf("in_pcblookup_connect: faddr=%08x fport=%d laddr=%08x lport=%d\n",
    778        1.24   mycroft 		    ntohl(faddr.s_addr), ntohs(fport),
    779        1.24   mycroft 		    ntohl(laddr.s_addr), ntohs(lport));
    780        1.24   mycroft 	}
    781        1.24   mycroft #endif
    782        1.33   mycroft 	return (0);
    783        1.33   mycroft 
    784        1.33   mycroft out:
    785        1.33   mycroft 	/* Move this PCB to the head of hash chain. */
    786        1.88    itojun 	inph = &inp->inp_head;
    787        1.88    itojun 	if (inph != LIST_FIRST(head)) {
    788        1.88    itojun 		LIST_REMOVE(inph, inph_hash);
    789        1.88    itojun 		LIST_INSERT_HEAD(head, inph, inph_hash);
    790        1.33   mycroft 	}
    791        1.33   mycroft 	return (inp);
    792        1.33   mycroft }
    793        1.33   mycroft 
    794        1.33   mycroft struct inpcb *
    795        1.98     perry in_pcblookup_bind(struct inpcbtable *table,
    796        1.98     perry     struct in_addr laddr, u_int lport_arg)
    797        1.33   mycroft {
    798        1.33   mycroft 	struct inpcbhead *head;
    799        1.88    itojun 	struct inpcb_hdr *inph;
    800        1.64  augustss 	struct inpcb *inp;
    801        1.33   mycroft 	u_int16_t lport = lport_arg;
    802        1.33   mycroft 
    803        1.33   mycroft 	head = INPCBHASH_BIND(table, laddr, lport);
    804        1.88    itojun 	LIST_FOREACH(inph, head, inph_hash) {
    805        1.88    itojun 		inp = (struct inpcb *)inph;
    806        1.88    itojun 		if (inp->inp_af != AF_INET)
    807        1.88    itojun 			continue;
    808        1.88    itojun 
    809        1.33   mycroft 		if (inp->inp_lport == lport &&
    810        1.33   mycroft 		    in_hosteq(inp->inp_laddr, laddr))
    811        1.33   mycroft 			goto out;
    812        1.33   mycroft 	}
    813        1.33   mycroft 	head = INPCBHASH_BIND(table, zeroin_addr, lport);
    814        1.88    itojun 	LIST_FOREACH(inph, head, inph_hash) {
    815        1.88    itojun 		inp = (struct inpcb *)inph;
    816        1.88    itojun 		if (inp->inp_af != AF_INET)
    817        1.88    itojun 			continue;
    818        1.88    itojun 
    819        1.33   mycroft 		if (inp->inp_lport == lport &&
    820        1.33   mycroft 		    in_hosteq(inp->inp_laddr, zeroin_addr))
    821        1.33   mycroft 			goto out;
    822        1.33   mycroft 	}
    823        1.33   mycroft #ifdef DIAGNOSTIC
    824        1.33   mycroft 	if (in_pcbnotifymiss) {
    825        1.35  christos 		printf("in_pcblookup_bind: laddr=%08x lport=%d\n",
    826        1.33   mycroft 		    ntohl(laddr.s_addr), ntohs(lport));
    827        1.33   mycroft 	}
    828        1.33   mycroft #endif
    829        1.33   mycroft 	return (0);
    830        1.33   mycroft 
    831        1.33   mycroft out:
    832        1.33   mycroft 	/* Move this PCB to the head of hash chain. */
    833        1.88    itojun 	inph = &inp->inp_head;
    834        1.88    itojun 	if (inph != LIST_FIRST(head)) {
    835        1.88    itojun 		LIST_REMOVE(inph, inph_hash);
    836        1.88    itojun 		LIST_INSERT_HEAD(head, inph, inph_hash);
    837        1.33   mycroft 	}
    838        1.24   mycroft 	return (inp);
    839        1.33   mycroft }
    840        1.33   mycroft 
    841        1.33   mycroft void
    842        1.98     perry in_pcbstate(struct inpcb *inp, int state)
    843        1.33   mycroft {
    844        1.33   mycroft 
    845        1.88    itojun 	if (inp->inp_af != AF_INET)
    846        1.88    itojun 		return;
    847        1.88    itojun 
    848        1.33   mycroft 	if (inp->inp_state > INP_ATTACHED)
    849        1.88    itojun 		LIST_REMOVE(&inp->inp_head, inph_hash);
    850        1.33   mycroft 
    851        1.33   mycroft 	switch (state) {
    852        1.33   mycroft 	case INP_BOUND:
    853        1.33   mycroft 		LIST_INSERT_HEAD(INPCBHASH_BIND(inp->inp_table,
    854        1.88    itojun 		    inp->inp_laddr, inp->inp_lport), &inp->inp_head,
    855        1.88    itojun 		    inph_hash);
    856        1.33   mycroft 		break;
    857        1.33   mycroft 	case INP_CONNECTED:
    858        1.33   mycroft 		LIST_INSERT_HEAD(INPCBHASH_CONNECT(inp->inp_table,
    859        1.33   mycroft 		    inp->inp_faddr, inp->inp_fport,
    860        1.88    itojun 		    inp->inp_laddr, inp->inp_lport), &inp->inp_head,
    861        1.88    itojun 		    inph_hash);
    862        1.33   mycroft 		break;
    863        1.33   mycroft 	}
    864        1.33   mycroft 
    865        1.33   mycroft 	inp->inp_state = state;
    866        1.38   thorpej }
    867        1.38   thorpej 
    868        1.38   thorpej struct rtentry *
    869        1.98     perry in_pcbrtentry(struct inpcb *inp)
    870        1.38   thorpej {
    871        1.38   thorpej 	struct route *ro;
    872       1.117    dyoung 	union {
    873       1.117    dyoung 		struct sockaddr		dst;
    874       1.117    dyoung 		struct sockaddr_in	dst4;
    875       1.117    dyoung 	} u;
    876        1.88    itojun 
    877        1.88    itojun 	if (inp->inp_af != AF_INET)
    878        1.88    itojun 		return (NULL);
    879        1.38   thorpej 
    880        1.38   thorpej 	ro = &inp->inp_route;
    881        1.38   thorpej 
    882       1.117    dyoung 	sockaddr_in_init(&u.dst4, &inp->inp_faddr, 0);
    883       1.117    dyoung 	return rtcache_lookup(ro, &u.dst);
    884        1.59    itojun }
    885        1.59    itojun 
    886        1.59    itojun struct sockaddr_in *
    887        1.98     perry in_selectsrc(struct sockaddr_in *sin, struct route *ro,
    888        1.98     perry     int soopts, struct ip_moptions *mopts, int *errorp)
    889        1.59    itojun {
    890  1.119.14.1    bouyer 	struct rtentry *rt;
    891       1.113    dyoung 	struct in_ifaddr *ia = NULL;
    892        1.59    itojun 
    893        1.78    itojun 	/*
    894       1.117    dyoung          * If route is known or can be allocated now, take the
    895       1.117    dyoung          * source address from the interface.  Otherwise, punt.
    896        1.59    itojun 	 */
    897       1.117    dyoung 	if ((soopts & SO_DONTROUTE) != 0)
    898       1.112     joerg 		rtcache_free(ro);
    899       1.117    dyoung 	else {
    900       1.117    dyoung 		union {
    901       1.117    dyoung 			struct sockaddr		dst;
    902       1.117    dyoung 			struct sockaddr_in	dst4;
    903       1.117    dyoung 		} u;
    904       1.117    dyoung 
    905       1.117    dyoung 		sockaddr_in_init(&u.dst4, &sin->sin_addr, 0);
    906       1.117    dyoung 		(void)rtcache_lookup(ro, &u.dst);
    907        1.59    itojun 	}
    908        1.59    itojun 	/*
    909        1.59    itojun 	 * If we found a route, use the address
    910        1.59    itojun 	 * corresponding to the outgoing interface
    911        1.59    itojun 	 * unless it is the loopback (in case a route
    912        1.59    itojun 	 * to our address on another net goes to loopback).
    913        1.78    itojun 	 *
    914        1.59    itojun 	 * XXX Is this still true?  Do we care?
    915        1.59    itojun 	 */
    916  1.119.14.1    bouyer 	if ((rt = rtcache_getrt(ro)) != NULL &&
    917  1.119.14.1    bouyer 	    !(rt->rt_ifp->if_flags & IFF_LOOPBACK))
    918  1.119.14.1    bouyer 		ia = ifatoia(rt->rt_ifa);
    919        1.62   thorpej 	if (ia == NULL) {
    920        1.59    itojun 		u_int16_t fport = sin->sin_port;
    921        1.59    itojun 
    922        1.59    itojun 		sin->sin_port = 0;
    923        1.59    itojun 		ia = ifatoia(ifa_ifwithladdr(sintosa(sin)));
    924        1.59    itojun 		sin->sin_port = fport;
    925       1.117    dyoung 		if (ia == NULL) {
    926        1.59    itojun 			/* Find 1st non-loopback AF_INET address */
    927        1.91  jonathan 			TAILQ_FOREACH(ia, &in_ifaddrhead, ia_list) {
    928        1.59    itojun 				if (!(ia->ia_ifp->if_flags & IFF_LOOPBACK))
    929        1.59    itojun 					break;
    930        1.62   thorpej 			}
    931        1.59    itojun 		}
    932        1.62   thorpej 		if (ia == NULL) {
    933        1.59    itojun 			*errorp = EADDRNOTAVAIL;
    934        1.59    itojun 			return NULL;
    935        1.59    itojun 		}
    936        1.59    itojun 	}
    937        1.59    itojun 	/*
    938        1.59    itojun 	 * If the destination address is multicast and an outgoing
    939        1.59    itojun 	 * interface has been set as a multicast option, use the
    940        1.59    itojun 	 * address of that interface as our source address.
    941        1.59    itojun 	 */
    942        1.59    itojun 	if (IN_MULTICAST(sin->sin_addr.s_addr) && mopts != NULL) {
    943        1.59    itojun 		struct ip_moptions *imo;
    944        1.59    itojun 		struct ifnet *ifp;
    945        1.59    itojun 
    946        1.59    itojun 		imo = mopts;
    947        1.59    itojun 		if (imo->imo_multicast_ifp != NULL) {
    948        1.59    itojun 			ifp = imo->imo_multicast_ifp;
    949        1.59    itojun 			IFP_TO_IA(ifp, ia);		/* XXX */
    950        1.59    itojun 			if (ia == 0) {
    951        1.59    itojun 				*errorp = EADDRNOTAVAIL;
    952        1.59    itojun 				return NULL;
    953        1.59    itojun 			}
    954        1.59    itojun 		}
    955        1.59    itojun 	}
    956       1.108    dyoung 	if (ia->ia_ifa.ifa_getifa != NULL) {
    957       1.108    dyoung 		ia = ifatoia((*ia->ia_ifa.ifa_getifa)(&ia->ia_ifa,
    958       1.108    dyoung 		                                      sintosa(sin)));
    959       1.108    dyoung 	}
    960       1.108    dyoung #ifdef GETIFA_DEBUG
    961       1.108    dyoung 	else
    962       1.108    dyoung 		printf("%s: missing ifa_getifa\n", __func__);
    963       1.108    dyoung #endif
    964        1.59    itojun 	return satosin(&ia->ia_addr);
    965         1.1       cgd }
    966