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