Home | History | Annotate | Line # | Download | only in netinet
in_pcb.c revision 1.39.2.4
      1  1.39.2.4       cgd /*	$NetBSD: in_pcb.c,v 1.39.2.4 1999/01/18 03:22:58 cgd Exp $	*/
      2      1.11       cgd 
      3       1.1       cgd /*
      4      1.10   mycroft  * Copyright (c) 1982, 1986, 1991, 1993
      5      1.10   mycroft  *	The Regents of the University of California.  All rights reserved.
      6       1.1       cgd  *
      7       1.1       cgd  * Redistribution and use in source and binary forms, with or without
      8       1.1       cgd  * modification, are permitted provided that the following conditions
      9       1.1       cgd  * are met:
     10       1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     11       1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     12       1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     13       1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     14       1.1       cgd  *    documentation and/or other materials provided with the distribution.
     15       1.1       cgd  * 3. All advertising materials mentioning features or use of this software
     16       1.1       cgd  *    must display the following acknowledgement:
     17       1.1       cgd  *	This product includes software developed by the University of
     18       1.1       cgd  *	California, Berkeley and its contributors.
     19       1.1       cgd  * 4. Neither the name of the University nor the names of its contributors
     20       1.1       cgd  *    may be used to endorse or promote products derived from this software
     21       1.1       cgd  *    without specific prior written permission.
     22       1.1       cgd  *
     23       1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     24       1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     25       1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     26       1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     27       1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     28       1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     29       1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     30       1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     31       1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     32       1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     33       1.1       cgd  * SUCH DAMAGE.
     34       1.1       cgd  *
     35      1.11       cgd  *	@(#)in_pcb.c	8.2 (Berkeley) 1/4/94
     36       1.1       cgd  */
     37       1.1       cgd 
     38  1.39.2.3       cgd /*-
     39  1.39.2.3       cgd  * Copyright (c) 1998 The NetBSD Foundation, Inc.
     40  1.39.2.3       cgd  * All rights reserved.
     41  1.39.2.3       cgd  *
     42  1.39.2.3       cgd  * This code is derived from software contributed to The NetBSD Foundation
     43  1.39.2.3       cgd  * by Public Access Networks Corporation ("Panix").  It was developed under
     44  1.39.2.3       cgd  * contract to Panix by Eric Haszlakiewicz and Thor Lancelot Simon.
     45  1.39.2.3       cgd  *
     46  1.39.2.3       cgd  * Redistribution and use in source and binary forms, with or without
     47  1.39.2.3       cgd  * modification, are permitted provided that the following conditions
     48  1.39.2.3       cgd  * are met:
     49  1.39.2.3       cgd  * 1. Redistributions of source code must retain the above copyright
     50  1.39.2.3       cgd  *    notice, this list of conditions and the following disclaimer.
     51  1.39.2.3       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     52  1.39.2.3       cgd  *    notice, this list of conditions and the following disclaimer in the
     53  1.39.2.3       cgd  *    documentation and/or other materials provided with the distribution.
     54  1.39.2.3       cgd  * 3. All advertising materials mentioning features or use of this software
     55  1.39.2.3       cgd  *    must display the following acknowledgement:
     56  1.39.2.3       cgd  *      This product includes software developed by the NetBSD
     57  1.39.2.3       cgd  *      Foundation, Inc. and its contributors.
     58  1.39.2.3       cgd  * 4. Neither the name of The NetBSD Foundation nor the names of its
     59  1.39.2.3       cgd  *    contributors may be used to endorse or promote products derived
     60  1.39.2.3       cgd  *    from this software without specific prior written permission.
     61  1.39.2.3       cgd  *
     62  1.39.2.3       cgd  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     63  1.39.2.3       cgd  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     64  1.39.2.3       cgd  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     65  1.39.2.3       cgd  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     66  1.39.2.3       cgd  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     67  1.39.2.3       cgd  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     68  1.39.2.3       cgd  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     69  1.39.2.3       cgd  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     70  1.39.2.3       cgd  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     71  1.39.2.3       cgd  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     72  1.39.2.3       cgd  * POSSIBILITY OF SUCH DAMAGE.
     73  1.39.2.3       cgd  */
     74  1.39.2.3       cgd 
     75       1.7   mycroft #include <sys/param.h>
     76       1.7   mycroft #include <sys/systm.h>
     77       1.7   mycroft #include <sys/malloc.h>
     78       1.7   mycroft #include <sys/mbuf.h>
     79       1.7   mycroft #include <sys/protosw.h>
     80       1.7   mycroft #include <sys/socket.h>
     81       1.7   mycroft #include <sys/socketvar.h>
     82       1.7   mycroft #include <sys/ioctl.h>
     83      1.10   mycroft #include <sys/errno.h>
     84      1.10   mycroft #include <sys/time.h>
     85      1.10   mycroft #include <sys/proc.h>
     86       1.1       cgd 
     87       1.7   mycroft #include <net/if.h>
     88       1.7   mycroft #include <net/route.h>
     89       1.1       cgd 
     90       1.7   mycroft #include <netinet/in.h>
     91       1.7   mycroft #include <netinet/in_systm.h>
     92       1.7   mycroft #include <netinet/ip.h>
     93       1.7   mycroft #include <netinet/in_pcb.h>
     94       1.7   mycroft #include <netinet/in_var.h>
     95       1.7   mycroft #include <netinet/ip_var.h>
     96       1.1       cgd 
     97       1.1       cgd struct	in_addr zeroin_addr;
     98       1.1       cgd 
     99      1.33   mycroft #define	INPCBHASH_BIND(table, laddr, lport) \
    100      1.33   mycroft 	&(table)->inpt_bindhashtbl[ \
    101      1.33   mycroft 	    ((ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_bindhash]
    102      1.33   mycroft #define	INPCBHASH_CONNECT(table, faddr, fport, laddr, lport) \
    103      1.33   mycroft 	&(table)->inpt_connecthashtbl[ \
    104      1.33   mycroft 	    ((ntohl((faddr).s_addr) + ntohs(fport)) + \
    105      1.33   mycroft 	     (ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_connecthash]
    106      1.33   mycroft 
    107      1.33   mycroft struct inpcb *
    108      1.33   mycroft 	in_pcblookup_port __P((struct inpcbtable *,
    109      1.33   mycroft 	    struct in_addr, u_int, int));
    110      1.24   mycroft 
    111      1.18   mycroft void
    112      1.33   mycroft in_pcbinit(table, bindhashsize, connecthashsize)
    113      1.18   mycroft 	struct inpcbtable *table;
    114      1.33   mycroft 	int bindhashsize, connecthashsize;
    115      1.18   mycroft {
    116      1.18   mycroft 
    117      1.21       cgd 	CIRCLEQ_INIT(&table->inpt_queue);
    118      1.33   mycroft 	table->inpt_bindhashtbl =
    119      1.33   mycroft 	    hashinit(bindhashsize, M_PCB, &table->inpt_bindhash);
    120      1.33   mycroft 	table->inpt_connecthashtbl =
    121      1.33   mycroft 	    hashinit(connecthashsize, M_PCB, &table->inpt_connecthash);
    122      1.36   mycroft 	table->inpt_lastport = IPPORT_RESERVED;
    123      1.18   mycroft }
    124      1.18   mycroft 
    125      1.10   mycroft int
    126      1.25  christos in_pcballoc(so, v)
    127       1.1       cgd 	struct socket *so;
    128      1.25  christos 	void *v;
    129       1.1       cgd {
    130      1.25  christos 	struct inpcbtable *table = v;
    131       1.1       cgd 	register struct inpcb *inp;
    132      1.24   mycroft 	int s;
    133       1.1       cgd 
    134      1.10   mycroft 	MALLOC(inp, struct inpcb *, sizeof(*inp), M_PCB, M_WAITOK);
    135      1.10   mycroft 	if (inp == NULL)
    136       1.1       cgd 		return (ENOBUFS);
    137      1.10   mycroft 	bzero((caddr_t)inp, sizeof(*inp));
    138      1.18   mycroft 	inp->inp_table = table;
    139       1.1       cgd 	inp->inp_socket = so;
    140      1.39      matt 	inp->inp_errormtu = -1;
    141      1.33   mycroft 	so->so_pcb = inp;
    142      1.24   mycroft 	s = splnet();
    143      1.21       cgd 	CIRCLEQ_INSERT_HEAD(&table->inpt_queue, inp, inp_queue);
    144      1.33   mycroft 	in_pcbstate(inp, INP_ATTACHED);
    145      1.24   mycroft 	splx(s);
    146       1.1       cgd 	return (0);
    147       1.1       cgd }
    148       1.8   mycroft 
    149      1.10   mycroft int
    150      1.28   mycroft in_pcbbind(v, nam, p)
    151      1.28   mycroft 	void *v;
    152       1.1       cgd 	struct mbuf *nam;
    153      1.28   mycroft 	struct proc *p;
    154       1.1       cgd {
    155      1.25  christos 	register struct inpcb *inp = v;
    156       1.1       cgd 	register struct socket *so = inp->inp_socket;
    157      1.18   mycroft 	register struct inpcbtable *table = inp->inp_table;
    158       1.1       cgd 	register struct sockaddr_in *sin;
    159      1.13       cgd 	u_int16_t lport = 0;
    160      1.10   mycroft 	int wild = 0, reuseport = (so->so_options & SO_REUSEPORT);
    161  1.39.2.2    mellon #ifndef IPNOPRIVPORTS
    162      1.10   mycroft 	int error;
    163  1.39.2.2    mellon #endif
    164       1.1       cgd 
    165      1.18   mycroft 	if (in_ifaddr.tqh_first == 0)
    166       1.1       cgd 		return (EADDRNOTAVAIL);
    167      1.32   mycroft 	if (inp->inp_lport || !in_nullhost(inp->inp_laddr))
    168       1.1       cgd 		return (EINVAL);
    169      1.10   mycroft 	if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0 &&
    170       1.4   deraadt 	    ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
    171       1.4   deraadt 	     (so->so_options & SO_ACCEPTCONN) == 0))
    172       1.4   deraadt 		wild = INPLOOKUP_WILDCARD;
    173      1.28   mycroft 	if (nam == 0)
    174      1.28   mycroft 		goto noname;
    175      1.28   mycroft 	sin = mtod(nam, struct sockaddr_in *);
    176      1.28   mycroft 	if (nam->m_len != sizeof (*sin))
    177      1.28   mycroft 		return (EINVAL);
    178      1.10   mycroft #ifdef notdef
    179      1.28   mycroft 	/*
    180      1.28   mycroft 	 * We should check the family, but old programs
    181      1.28   mycroft 	 * incorrectly fail to initialize it.
    182      1.28   mycroft 	 */
    183      1.28   mycroft 	if (sin->sin_family != AF_INET)
    184      1.28   mycroft 		return (EAFNOSUPPORT);
    185      1.28   mycroft #endif
    186      1.28   mycroft 	lport = sin->sin_port;
    187      1.28   mycroft 	if (IN_MULTICAST(sin->sin_addr.s_addr)) {
    188      1.10   mycroft 		/*
    189      1.28   mycroft 		 * Treat SO_REUSEADDR as SO_REUSEPORT for multicast;
    190      1.28   mycroft 		 * allow complete duplication of binding if
    191      1.28   mycroft 		 * SO_REUSEPORT is set, or if SO_REUSEADDR is set
    192      1.28   mycroft 		 * and a multicast address is bound on both
    193      1.28   mycroft 		 * new and duplicated sockets.
    194      1.10   mycroft 		 */
    195      1.28   mycroft 		if (so->so_options & SO_REUSEADDR)
    196      1.28   mycroft 			reuseport = SO_REUSEADDR|SO_REUSEPORT;
    197      1.32   mycroft 	} else if (!in_nullhost(sin->sin_addr)) {
    198      1.28   mycroft 		sin->sin_port = 0;		/* yech... */
    199      1.28   mycroft 		if (ifa_ifwithaddr(sintosa(sin)) == 0)
    200      1.28   mycroft 			return (EADDRNOTAVAIL);
    201      1.28   mycroft 	}
    202      1.28   mycroft 	if (lport) {
    203      1.28   mycroft 		struct inpcb *t;
    204      1.31     perry #ifndef IPNOPRIVPORTS
    205      1.28   mycroft 		/* GROSS */
    206      1.28   mycroft 		if (ntohs(lport) < IPPORT_RESERVED &&
    207      1.28   mycroft 		    (p == 0 || (error = suser(p->p_ucred, &p->p_acflag))))
    208      1.28   mycroft 			return (EACCES);
    209      1.31     perry #endif
    210      1.33   mycroft 		t = in_pcblookup_port(table, sin->sin_addr, lport, wild);
    211      1.28   mycroft 		if (t && (reuseport & t->inp_socket->so_options) == 0)
    212      1.28   mycroft 			return (EADDRINUSE);
    213       1.1       cgd 	}
    214      1.28   mycroft 	inp->inp_laddr = sin->sin_addr;
    215      1.28   mycroft noname:
    216      1.36   mycroft 	if (lport == 0) {
    217      1.36   mycroft 		for (lport = table->inpt_lastport + 1;
    218      1.36   mycroft 		    lport < IPPORT_USERRESERVED; lport++)
    219      1.36   mycroft 			if (!in_pcblookup_port(table, inp->inp_laddr,
    220      1.36   mycroft 			    htons(lport), wild))
    221      1.36   mycroft 				goto found;
    222      1.36   mycroft 		for (lport = IPPORT_RESERVED;
    223      1.36   mycroft 		    lport <= table->inpt_lastport; lport++)
    224      1.36   mycroft 			if (!in_pcblookup_port(table, inp->inp_laddr,
    225      1.36   mycroft 			    htons(lport), wild))
    226      1.36   mycroft 				goto found;
    227  1.39.2.1   thorpej 		if (!in_nullhost(inp->inp_laddr))
    228  1.39.2.1   thorpej 			inp->inp_laddr.s_addr = INADDR_ANY;
    229      1.36   mycroft 		return (EAGAIN);
    230      1.36   mycroft 	found:
    231      1.36   mycroft 		table->inpt_lastport = lport;
    232      1.36   mycroft 		lport = htons(lport);
    233      1.36   mycroft 	}
    234       1.1       cgd 	inp->inp_lport = lport;
    235      1.33   mycroft 	in_pcbstate(inp, INP_BOUND);
    236       1.1       cgd 	return (0);
    237       1.1       cgd }
    238       1.1       cgd 
    239       1.1       cgd /*
    240       1.1       cgd  * Connect from a socket to a specified address.
    241       1.1       cgd  * Both address and port must be specified in argument sin.
    242       1.1       cgd  * If don't have a local address for this socket yet,
    243       1.1       cgd  * then pick one.
    244       1.1       cgd  */
    245      1.10   mycroft int
    246      1.25  christos in_pcbconnect(v, nam)
    247      1.25  christos 	register void *v;
    248       1.1       cgd 	struct mbuf *nam;
    249       1.1       cgd {
    250      1.25  christos 	register struct inpcb *inp = v;
    251       1.1       cgd 	struct in_ifaddr *ia;
    252      1.25  christos 	struct sockaddr_in *ifaddr = NULL;
    253       1.1       cgd 	register struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
    254  1.39.2.1   thorpej 	int error;
    255       1.1       cgd 
    256       1.1       cgd 	if (nam->m_len != sizeof (*sin))
    257       1.1       cgd 		return (EINVAL);
    258       1.1       cgd 	if (sin->sin_family != AF_INET)
    259       1.1       cgd 		return (EAFNOSUPPORT);
    260       1.1       cgd 	if (sin->sin_port == 0)
    261       1.1       cgd 		return (EADDRNOTAVAIL);
    262      1.18   mycroft 	if (in_ifaddr.tqh_first != 0) {
    263       1.1       cgd 		/*
    264       1.1       cgd 		 * If the destination address is INADDR_ANY,
    265  1.39.2.3       cgd 		 * use any local address (likely loopback).
    266       1.1       cgd 		 * If the supplied address is INADDR_BROADCAST,
    267  1.39.2.3       cgd 		 * use the broadcast address of an interface
    268  1.39.2.3       cgd 		 * which supports broadcast. (loopback does not)
    269       1.1       cgd 		 */
    270  1.39.2.3       cgd 
    271      1.32   mycroft 		if (in_nullhost(sin->sin_addr))
    272  1.39.2.4       cgd 			sin->sin_addr = in_ifaddr.tqh_first->ia_addr.sin_addr;
    273  1.39.2.3       cgd 		else if (sin->sin_addr.s_addr == INADDR_BROADCAST)
    274  1.39.2.3       cgd 		    for (ia = in_ifaddr.tqh_first; ia != NULL;
    275  1.39.2.3       cgd 		      ia = ia->ia_list.tqe_next)
    276  1.39.2.3       cgd 			if (ia->ia_ifp->if_flags & IFF_BROADCAST) {
    277  1.39.2.3       cgd 			    sin->sin_addr = ia->ia_broadaddr.sin_addr;
    278  1.39.2.3       cgd 			    break;
    279  1.39.2.3       cgd 			}
    280       1.1       cgd 	}
    281      1.32   mycroft 	/*
    282      1.32   mycroft 	 * If we haven't bound which network number to use as ours,
    283      1.32   mycroft 	 * we will use the number of the outgoing interface.
    284      1.32   mycroft 	 * This depends on having done a routing lookup, which
    285      1.32   mycroft 	 * we will probably have to do anyway, so we might
    286      1.32   mycroft 	 * as well do it now.  On the other hand if we are
    287      1.32   mycroft 	 * sending to multiple destinations we may have already
    288      1.32   mycroft 	 * done the lookup, so see if we can use the route
    289      1.32   mycroft 	 * from before.  In any case, we only
    290      1.32   mycroft 	 * chose a port number once, even if sending to multiple
    291      1.32   mycroft 	 * destinations.
    292      1.32   mycroft 	 */
    293      1.32   mycroft 	if (in_nullhost(inp->inp_laddr)) {
    294       1.1       cgd 		register struct route *ro;
    295       1.1       cgd 
    296       1.1       cgd 		ia = (struct in_ifaddr *)0;
    297      1.10   mycroft 		/*
    298       1.1       cgd 		 * If route is known or can be allocated now,
    299       1.1       cgd 		 * our src addr is taken from the i/f, else punt.
    300       1.1       cgd 		 */
    301       1.1       cgd 		ro = &inp->inp_route;
    302       1.1       cgd 		if (ro->ro_rt &&
    303      1.32   mycroft 		    (!in_hosteq(satosin(&ro->ro_dst)->sin_addr,
    304      1.32   mycroft 			sin->sin_addr) ||
    305       1.1       cgd 		    inp->inp_socket->so_options & SO_DONTROUTE)) {
    306       1.1       cgd 			RTFREE(ro->ro_rt);
    307       1.1       cgd 			ro->ro_rt = (struct rtentry *)0;
    308       1.1       cgd 		}
    309       1.1       cgd 		if ((inp->inp_socket->so_options & SO_DONTROUTE) == 0 && /*XXX*/
    310       1.1       cgd 		    (ro->ro_rt == (struct rtentry *)0 ||
    311       1.1       cgd 		    ro->ro_rt->rt_ifp == (struct ifnet *)0)) {
    312       1.1       cgd 			/* No route yet, so try to acquire one */
    313       1.1       cgd 			ro->ro_dst.sa_family = AF_INET;
    314       1.1       cgd 			ro->ro_dst.sa_len = sizeof(struct sockaddr_in);
    315      1.15   mycroft 			satosin(&ro->ro_dst)->sin_addr = sin->sin_addr;
    316       1.1       cgd 			rtalloc(ro);
    317       1.1       cgd 		}
    318       1.1       cgd 		/*
    319       1.1       cgd 		 * If we found a route, use the address
    320       1.1       cgd 		 * corresponding to the outgoing interface
    321       1.1       cgd 		 * unless it is the loopback (in case a route
    322       1.1       cgd 		 * to our address on another net goes to loopback).
    323  1.39.2.3       cgd 		 *
    324  1.39.2.3       cgd 		 * XXX Is this still true?  Do we care?
    325       1.1       cgd 		 */
    326      1.10   mycroft 		if (ro->ro_rt && !(ro->ro_rt->rt_ifp->if_flags & IFF_LOOPBACK))
    327      1.10   mycroft 			ia = ifatoia(ro->ro_rt->rt_ifa);
    328       1.1       cgd 		if (ia == 0) {
    329  1.39.2.3       cgd 		    u_int16_t fport = sin->sin_port;
    330       1.1       cgd 
    331  1.39.2.3       cgd 		    sin->sin_port = 0;
    332  1.39.2.3       cgd 		    ia = ifatoia(ifa_ifwithladdr(sintosa(sin)));
    333  1.39.2.3       cgd 		    sin->sin_port = fport;
    334  1.39.2.3       cgd 		    if (ia == 0)
    335  1.39.2.3       cgd 			/* Find 1st non-loopback AF_INET address */
    336  1.39.2.3       cgd 			for (ia = in_ifaddr.tqh_first ; ia != NULL ;
    337  1.39.2.3       cgd 				ia = ia->ia_list.tqe_next)
    338  1.39.2.3       cgd 			    if (!(ia->ia_ifp->if_flags & IFF_LOOPBACK))
    339  1.39.2.3       cgd 				break;
    340  1.39.2.3       cgd 		    if (ia == 0)
    341  1.39.2.3       cgd 			return (EADDRNOTAVAIL);
    342       1.1       cgd 		}
    343       1.6   hpeyerl 		/*
    344       1.6   hpeyerl 		 * If the destination address is multicast and an outgoing
    345       1.6   hpeyerl 		 * interface has been set as a multicast option, use the
    346       1.6   hpeyerl 		 * address of that interface as our source address.
    347       1.6   hpeyerl 		 */
    348      1.14   mycroft 		if (IN_MULTICAST(sin->sin_addr.s_addr) &&
    349       1.6   hpeyerl 		    inp->inp_moptions != NULL) {
    350       1.6   hpeyerl 			struct ip_moptions *imo;
    351       1.6   hpeyerl 			struct ifnet *ifp;
    352       1.8   mycroft 
    353       1.6   hpeyerl 			imo = inp->inp_moptions;
    354       1.6   hpeyerl 			if (imo->imo_multicast_ifp != NULL) {
    355       1.6   hpeyerl 				ifp = imo->imo_multicast_ifp;
    356  1.39.2.3       cgd 				IFP_TO_IA(ifp, ia);		/* XXX */
    357       1.6   hpeyerl 				if (ia == 0)
    358       1.6   hpeyerl 					return (EADDRNOTAVAIL);
    359       1.6   hpeyerl 			}
    360       1.6   hpeyerl 		}
    361      1.15   mycroft 		ifaddr = satosin(&ia->ia_addr);
    362       1.1       cgd 	}
    363      1.33   mycroft 	if (in_pcblookup_connect(inp->inp_table, sin->sin_addr, sin->sin_port,
    364      1.32   mycroft 	    !in_nullhost(inp->inp_laddr) ? inp->inp_laddr : ifaddr->sin_addr,
    365      1.24   mycroft 	    inp->inp_lport) != 0)
    366       1.1       cgd 		return (EADDRINUSE);
    367      1.32   mycroft 	if (in_nullhost(inp->inp_laddr)) {
    368  1.39.2.1   thorpej 		if (inp->inp_lport == 0) {
    369  1.39.2.1   thorpej 			error = in_pcbbind(inp, (struct mbuf *)0,
    370      1.28   mycroft 			    (struct proc *)0);
    371  1.39.2.1   thorpej 			/*
    372  1.39.2.1   thorpej 			 * This used to ignore the return value
    373  1.39.2.1   thorpej 			 * completely, but we need to check for
    374  1.39.2.1   thorpej 			 * ephemeral port shortage.
    375  1.39.2.1   thorpej 			 * XXX Should we check for other errors, too?
    376  1.39.2.1   thorpej 			 */
    377  1.39.2.1   thorpej 			if (error == EAGAIN)
    378  1.39.2.1   thorpej 				return (error);
    379  1.39.2.1   thorpej 		}
    380       1.1       cgd 		inp->inp_laddr = ifaddr->sin_addr;
    381       1.1       cgd 	}
    382       1.1       cgd 	inp->inp_faddr = sin->sin_addr;
    383       1.1       cgd 	inp->inp_fport = sin->sin_port;
    384      1.33   mycroft 	in_pcbstate(inp, INP_CONNECTED);
    385       1.1       cgd 	return (0);
    386       1.1       cgd }
    387       1.1       cgd 
    388      1.25  christos void
    389      1.25  christos in_pcbdisconnect(v)
    390      1.25  christos 	void *v;
    391       1.1       cgd {
    392      1.25  christos 	struct inpcb *inp = v;
    393       1.1       cgd 
    394      1.32   mycroft 	inp->inp_faddr = zeroin_addr;
    395       1.1       cgd 	inp->inp_fport = 0;
    396      1.33   mycroft 	in_pcbstate(inp, INP_BOUND);
    397       1.1       cgd 	if (inp->inp_socket->so_state & SS_NOFDREF)
    398       1.1       cgd 		in_pcbdetach(inp);
    399       1.1       cgd }
    400       1.1       cgd 
    401      1.25  christos void
    402      1.25  christos in_pcbdetach(v)
    403      1.25  christos 	void *v;
    404       1.1       cgd {
    405      1.25  christos 	struct inpcb *inp = v;
    406       1.1       cgd 	struct socket *so = inp->inp_socket;
    407      1.24   mycroft 	int s;
    408       1.1       cgd 
    409       1.1       cgd 	so->so_pcb = 0;
    410       1.1       cgd 	sofree(so);
    411       1.1       cgd 	if (inp->inp_options)
    412       1.1       cgd 		(void)m_free(inp->inp_options);
    413       1.1       cgd 	if (inp->inp_route.ro_rt)
    414       1.1       cgd 		rtfree(inp->inp_route.ro_rt);
    415       1.6   hpeyerl 	ip_freemoptions(inp->inp_moptions);
    416      1.24   mycroft 	s = splnet();
    417      1.33   mycroft 	in_pcbstate(inp, INP_ATTACHED);
    418      1.21       cgd 	CIRCLEQ_REMOVE(&inp->inp_table->inpt_queue, inp, inp_queue);
    419      1.24   mycroft 	splx(s);
    420      1.10   mycroft 	FREE(inp, M_PCB);
    421       1.1       cgd }
    422       1.1       cgd 
    423      1.25  christos void
    424       1.1       cgd in_setsockaddr(inp, nam)
    425       1.1       cgd 	register struct inpcb *inp;
    426       1.1       cgd 	struct mbuf *nam;
    427       1.1       cgd {
    428       1.1       cgd 	register struct sockaddr_in *sin;
    429      1.10   mycroft 
    430       1.1       cgd 	nam->m_len = sizeof (*sin);
    431       1.1       cgd 	sin = mtod(nam, struct sockaddr_in *);
    432       1.1       cgd 	bzero((caddr_t)sin, sizeof (*sin));
    433       1.1       cgd 	sin->sin_family = AF_INET;
    434       1.1       cgd 	sin->sin_len = sizeof(*sin);
    435       1.1       cgd 	sin->sin_port = inp->inp_lport;
    436       1.1       cgd 	sin->sin_addr = inp->inp_laddr;
    437       1.1       cgd }
    438       1.1       cgd 
    439      1.25  christos void
    440       1.1       cgd in_setpeeraddr(inp, nam)
    441       1.1       cgd 	struct inpcb *inp;
    442       1.1       cgd 	struct mbuf *nam;
    443       1.1       cgd {
    444       1.1       cgd 	register struct sockaddr_in *sin;
    445      1.10   mycroft 
    446       1.1       cgd 	nam->m_len = sizeof (*sin);
    447       1.1       cgd 	sin = mtod(nam, struct sockaddr_in *);
    448       1.1       cgd 	bzero((caddr_t)sin, sizeof (*sin));
    449       1.1       cgd 	sin->sin_family = AF_INET;
    450       1.1       cgd 	sin->sin_len = sizeof(*sin);
    451       1.1       cgd 	sin->sin_port = inp->inp_fport;
    452       1.1       cgd 	sin->sin_addr = inp->inp_faddr;
    453       1.1       cgd }
    454       1.1       cgd 
    455       1.1       cgd /*
    456       1.1       cgd  * Pass some notification to all connections of a protocol
    457       1.1       cgd  * associated with address dst.  The local address and/or port numbers
    458       1.1       cgd  * may be specified to limit the search.  The "usual action" will be
    459       1.1       cgd  * taken, depending on the ctlinput cmd.  The caller must filter any
    460       1.1       cgd  * cmds that are uninteresting (e.g., no error in the map).
    461       1.1       cgd  * Call the protocol specific routine (if any) to report
    462       1.1       cgd  * any errors for each matching socket.
    463       1.1       cgd  *
    464      1.22   mycroft  * Must be called at splsoftnet.
    465       1.1       cgd  */
    466      1.37   thorpej int
    467      1.32   mycroft in_pcbnotify(table, faddr, fport_arg, laddr, lport_arg, errno, notify)
    468      1.18   mycroft 	struct inpcbtable *table;
    469      1.32   mycroft 	struct in_addr faddr, laddr;
    470      1.10   mycroft 	u_int fport_arg, lport_arg;
    471      1.19   mycroft 	int errno;
    472      1.10   mycroft 	void (*notify) __P((struct inpcb *, int));
    473       1.1       cgd {
    474      1.33   mycroft 	struct inpcbhead *head;
    475      1.33   mycroft 	register struct inpcb *inp, *ninp;
    476      1.13       cgd 	u_int16_t fport = fport_arg, lport = lport_arg;
    477      1.37   thorpej 	int nmatch;
    478       1.1       cgd 
    479      1.33   mycroft 	if (in_nullhost(faddr) || notify == 0)
    480      1.37   thorpej 		return (0);
    481       1.1       cgd 
    482      1.37   thorpej 	nmatch = 0;
    483      1.33   mycroft 	head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
    484      1.33   mycroft 	for (inp = head->lh_first; inp != NULL; inp = ninp) {
    485      1.33   mycroft 		ninp = inp->inp_hash.le_next;
    486      1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr) &&
    487      1.33   mycroft 		    inp->inp_fport == fport &&
    488      1.33   mycroft 		    inp->inp_lport == lport &&
    489      1.37   thorpej 		    in_hosteq(inp->inp_laddr, laddr)) {
    490      1.33   mycroft 			(*notify)(inp, errno);
    491      1.37   thorpej 			nmatch++;
    492      1.37   thorpej 		}
    493       1.1       cgd 	}
    494      1.37   thorpej 	return (nmatch);
    495      1.18   mycroft }
    496      1.18   mycroft 
    497      1.20   mycroft void
    498      1.32   mycroft in_pcbnotifyall(table, faddr, errno, notify)
    499      1.18   mycroft 	struct inpcbtable *table;
    500      1.32   mycroft 	struct in_addr faddr;
    501      1.19   mycroft 	int errno;
    502      1.18   mycroft 	void (*notify) __P((struct inpcb *, int));
    503      1.18   mycroft {
    504      1.33   mycroft 	register struct inpcb *inp, *ninp;
    505      1.18   mycroft 
    506      1.33   mycroft 	if (in_nullhost(faddr) || notify == 0)
    507      1.18   mycroft 		return;
    508      1.18   mycroft 
    509      1.21       cgd 	for (inp = table->inpt_queue.cqh_first;
    510      1.33   mycroft 	    inp != (struct inpcb *)&table->inpt_queue;
    511      1.33   mycroft 	    inp = ninp) {
    512      1.33   mycroft 		ninp = inp->inp_queue.cqe_next;
    513      1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr))
    514      1.33   mycroft 			(*notify)(inp, errno);
    515       1.1       cgd 	}
    516       1.1       cgd }
    517       1.1       cgd 
    518       1.1       cgd /*
    519       1.1       cgd  * Check for alternatives when higher level complains
    520       1.1       cgd  * about service problems.  For now, invalidate cached
    521       1.1       cgd  * routing information.  If the route was created dynamically
    522       1.1       cgd  * (by a redirect), time to try a default gateway again.
    523       1.1       cgd  */
    524      1.25  christos void
    525       1.1       cgd in_losing(inp)
    526       1.1       cgd 	struct inpcb *inp;
    527       1.1       cgd {
    528       1.1       cgd 	register struct rtentry *rt;
    529      1.10   mycroft 	struct rt_addrinfo info;
    530       1.1       cgd 
    531       1.1       cgd 	if ((rt = inp->inp_route.ro_rt)) {
    532      1.10   mycroft 		inp->inp_route.ro_rt = 0;
    533      1.10   mycroft 		bzero((caddr_t)&info, sizeof(info));
    534      1.17   mycroft 		info.rti_info[RTAX_DST] = &inp->inp_route.ro_dst;
    535      1.10   mycroft 		info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
    536      1.10   mycroft 		info.rti_info[RTAX_NETMASK] = rt_mask(rt);
    537      1.10   mycroft 		rt_missmsg(RTM_LOSING, &info, rt->rt_flags, 0);
    538       1.1       cgd 		if (rt->rt_flags & RTF_DYNAMIC)
    539       1.1       cgd 			(void) rtrequest(RTM_DELETE, rt_key(rt),
    540      1.10   mycroft 				rt->rt_gateway, rt_mask(rt), rt->rt_flags,
    541       1.1       cgd 				(struct rtentry **)0);
    542      1.10   mycroft 		else
    543       1.1       cgd 		/*
    544       1.1       cgd 		 * A new route can be allocated
    545       1.1       cgd 		 * the next time output is attempted.
    546       1.1       cgd 		 */
    547      1.10   mycroft 			rtfree(rt);
    548       1.1       cgd 	}
    549       1.1       cgd }
    550       1.1       cgd 
    551       1.1       cgd /*
    552       1.1       cgd  * After a routing change, flush old routing
    553       1.1       cgd  * and allocate a (hopefully) better one.
    554       1.1       cgd  */
    555      1.10   mycroft void
    556      1.10   mycroft in_rtchange(inp, errno)
    557       1.1       cgd 	register struct inpcb *inp;
    558      1.10   mycroft 	int errno;
    559       1.1       cgd {
    560      1.32   mycroft 
    561       1.1       cgd 	if (inp->inp_route.ro_rt) {
    562       1.1       cgd 		rtfree(inp->inp_route.ro_rt);
    563       1.1       cgd 		inp->inp_route.ro_rt = 0;
    564       1.1       cgd 		/*
    565       1.1       cgd 		 * A new route can be allocated the next time
    566       1.1       cgd 		 * output is attempted.
    567       1.1       cgd 		 */
    568       1.1       cgd 	}
    569  1.39.2.3       cgd 	/* XXX SHOULD NOTIFY HIGHER-LEVEL PROTOCOLS */
    570       1.1       cgd }
    571       1.1       cgd 
    572       1.1       cgd struct inpcb *
    573      1.33   mycroft in_pcblookup_port(table, laddr, lport_arg, flags)
    574      1.18   mycroft 	struct inpcbtable *table;
    575      1.33   mycroft 	struct in_addr laddr;
    576      1.33   mycroft 	u_int lport_arg;
    577       1.1       cgd 	int flags;
    578       1.1       cgd {
    579       1.1       cgd 	register struct inpcb *inp, *match = 0;
    580       1.1       cgd 	int matchwild = 3, wildcard;
    581      1.33   mycroft 	u_int16_t lport = lport_arg;
    582       1.1       cgd 
    583      1.21       cgd 	for (inp = table->inpt_queue.cqh_first;
    584      1.21       cgd 	    inp != (struct inpcb *)&table->inpt_queue;
    585      1.21       cgd 	    inp = inp->inp_queue.cqe_next) {
    586       1.1       cgd 		if (inp->inp_lport != lport)
    587       1.1       cgd 			continue;
    588       1.1       cgd 		wildcard = 0;
    589      1.33   mycroft 		if (!in_nullhost(inp->inp_faddr))
    590      1.33   mycroft 			wildcard++;
    591      1.32   mycroft 		if (in_nullhost(inp->inp_laddr)) {
    592      1.32   mycroft 			if (!in_nullhost(laddr))
    593       1.1       cgd 				wildcard++;
    594       1.1       cgd 		} else {
    595      1.32   mycroft 			if (in_nullhost(laddr))
    596       1.1       cgd 				wildcard++;
    597      1.32   mycroft 			else {
    598      1.32   mycroft 				if (!in_hosteq(inp->inp_laddr, laddr))
    599      1.32   mycroft 					continue;
    600      1.32   mycroft 			}
    601       1.1       cgd 		}
    602       1.1       cgd 		if (wildcard && (flags & INPLOOKUP_WILDCARD) == 0)
    603       1.1       cgd 			continue;
    604       1.1       cgd 		if (wildcard < matchwild) {
    605       1.1       cgd 			match = inp;
    606       1.1       cgd 			matchwild = wildcard;
    607       1.1       cgd 			if (matchwild == 0)
    608       1.1       cgd 				break;
    609       1.1       cgd 		}
    610       1.1       cgd 	}
    611       1.1       cgd 	return (match);
    612      1.24   mycroft }
    613      1.24   mycroft 
    614      1.24   mycroft #ifdef DIAGNOSTIC
    615      1.24   mycroft int	in_pcbnotifymiss = 0;
    616      1.24   mycroft #endif
    617      1.24   mycroft 
    618      1.24   mycroft struct inpcb *
    619      1.33   mycroft in_pcblookup_connect(table, faddr, fport_arg, laddr, lport_arg)
    620      1.24   mycroft 	struct inpcbtable *table;
    621      1.24   mycroft 	struct in_addr faddr, laddr;
    622      1.24   mycroft 	u_int fport_arg, lport_arg;
    623      1.24   mycroft {
    624      1.24   mycroft 	struct inpcbhead *head;
    625      1.24   mycroft 	register struct inpcb *inp;
    626      1.24   mycroft 	u_int16_t fport = fport_arg, lport = lport_arg;
    627      1.24   mycroft 
    628      1.33   mycroft 	head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
    629      1.24   mycroft 	for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
    630      1.33   mycroft 		if (in_hosteq(inp->inp_faddr, faddr) &&
    631      1.33   mycroft 		    inp->inp_fport == fport &&
    632      1.33   mycroft 		    inp->inp_lport == lport &&
    633      1.33   mycroft 		    in_hosteq(inp->inp_laddr, laddr))
    634      1.33   mycroft 			goto out;
    635      1.24   mycroft 	}
    636      1.24   mycroft #ifdef DIAGNOSTIC
    637      1.33   mycroft 	if (in_pcbnotifymiss) {
    638      1.35  christos 		printf("in_pcblookup_connect: faddr=%08x fport=%d laddr=%08x lport=%d\n",
    639      1.24   mycroft 		    ntohl(faddr.s_addr), ntohs(fport),
    640      1.24   mycroft 		    ntohl(laddr.s_addr), ntohs(lport));
    641      1.24   mycroft 	}
    642      1.24   mycroft #endif
    643      1.33   mycroft 	return (0);
    644      1.33   mycroft 
    645      1.33   mycroft out:
    646      1.33   mycroft 	/* Move this PCB to the head of hash chain. */
    647      1.33   mycroft 	if (inp != head->lh_first) {
    648      1.33   mycroft 		LIST_REMOVE(inp, inp_hash);
    649      1.33   mycroft 		LIST_INSERT_HEAD(head, inp, inp_hash);
    650      1.33   mycroft 	}
    651      1.33   mycroft 	return (inp);
    652      1.33   mycroft }
    653      1.33   mycroft 
    654      1.33   mycroft struct inpcb *
    655      1.33   mycroft in_pcblookup_bind(table, laddr, lport_arg)
    656      1.33   mycroft 	struct inpcbtable *table;
    657      1.33   mycroft 	struct in_addr laddr;
    658      1.33   mycroft 	u_int lport_arg;
    659      1.33   mycroft {
    660      1.33   mycroft 	struct inpcbhead *head;
    661      1.33   mycroft 	register struct inpcb *inp;
    662      1.33   mycroft 	u_int16_t lport = lport_arg;
    663      1.33   mycroft 
    664      1.33   mycroft 	head = INPCBHASH_BIND(table, laddr, lport);
    665      1.33   mycroft 	for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
    666      1.33   mycroft 		if (inp->inp_lport == lport &&
    667      1.33   mycroft 		    in_hosteq(inp->inp_laddr, laddr))
    668      1.33   mycroft 			goto out;
    669      1.33   mycroft 	}
    670      1.33   mycroft 	head = INPCBHASH_BIND(table, zeroin_addr, lport);
    671      1.33   mycroft 	for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
    672      1.33   mycroft 		if (inp->inp_lport == lport &&
    673      1.33   mycroft 		    in_hosteq(inp->inp_laddr, zeroin_addr))
    674      1.33   mycroft 			goto out;
    675      1.33   mycroft 	}
    676      1.33   mycroft #ifdef DIAGNOSTIC
    677      1.33   mycroft 	if (in_pcbnotifymiss) {
    678      1.35  christos 		printf("in_pcblookup_bind: laddr=%08x lport=%d\n",
    679      1.33   mycroft 		    ntohl(laddr.s_addr), ntohs(lport));
    680      1.33   mycroft 	}
    681      1.33   mycroft #endif
    682      1.33   mycroft 	return (0);
    683      1.33   mycroft 
    684      1.33   mycroft out:
    685      1.33   mycroft 	/* Move this PCB to the head of hash chain. */
    686      1.33   mycroft 	if (inp != head->lh_first) {
    687      1.33   mycroft 		LIST_REMOVE(inp, inp_hash);
    688      1.33   mycroft 		LIST_INSERT_HEAD(head, inp, inp_hash);
    689      1.33   mycroft 	}
    690      1.24   mycroft 	return (inp);
    691      1.33   mycroft }
    692      1.33   mycroft 
    693      1.33   mycroft void
    694      1.33   mycroft in_pcbstate(inp, state)
    695      1.33   mycroft 	struct inpcb *inp;
    696      1.33   mycroft 	int state;
    697      1.33   mycroft {
    698      1.33   mycroft 
    699      1.33   mycroft 	if (inp->inp_state > INP_ATTACHED)
    700      1.33   mycroft 		LIST_REMOVE(inp, inp_hash);
    701      1.33   mycroft 
    702      1.33   mycroft 	switch (state) {
    703      1.33   mycroft 	case INP_BOUND:
    704      1.33   mycroft 		LIST_INSERT_HEAD(INPCBHASH_BIND(inp->inp_table,
    705      1.33   mycroft 		    inp->inp_laddr, inp->inp_lport), inp, inp_hash);
    706      1.33   mycroft 		break;
    707      1.33   mycroft 	case INP_CONNECTED:
    708      1.33   mycroft 		LIST_INSERT_HEAD(INPCBHASH_CONNECT(inp->inp_table,
    709      1.33   mycroft 		    inp->inp_faddr, inp->inp_fport,
    710      1.33   mycroft 		    inp->inp_laddr, inp->inp_lport), inp, inp_hash);
    711      1.33   mycroft 		break;
    712      1.33   mycroft 	}
    713      1.33   mycroft 
    714      1.33   mycroft 	inp->inp_state = state;
    715      1.38   thorpej }
    716      1.38   thorpej 
    717      1.38   thorpej struct rtentry *
    718      1.38   thorpej in_pcbrtentry(inp)
    719      1.38   thorpej 	struct inpcb *inp;
    720      1.38   thorpej {
    721      1.38   thorpej 	struct route *ro;
    722      1.38   thorpej 
    723      1.38   thorpej 	ro = &inp->inp_route;
    724      1.38   thorpej 
    725      1.38   thorpej 	if (ro->ro_rt == NULL) {
    726      1.38   thorpej 		/*
    727      1.38   thorpej 		 * No route yet, so try to acquire one.
    728      1.38   thorpej 		 */
    729      1.38   thorpej 		if (!in_nullhost(inp->inp_faddr)) {
    730      1.38   thorpej 			ro->ro_dst.sa_family = AF_INET;
    731      1.38   thorpej 			ro->ro_dst.sa_len = sizeof(ro->ro_dst);
    732      1.38   thorpej 			satosin(&ro->ro_dst)->sin_addr = inp->inp_faddr;
    733      1.38   thorpej 			rtalloc(ro);
    734      1.38   thorpej 		}
    735      1.38   thorpej 	}
    736      1.38   thorpej 	return (ro->ro_rt);
    737       1.1       cgd }
    738