Home | History | Annotate | Line # | Download | only in netinet
tcp_usrreq.c revision 1.173
      1  1.173     rmind /*	$NetBSD: tcp_usrreq.c,v 1.173 2014/05/19 02:51:25 rmind Exp $	*/
      2   1.40    itojun 
      3   1.40    itojun /*
      4   1.40    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
      5   1.40    itojun  * All rights reserved.
      6   1.71    itojun  *
      7   1.40    itojun  * Redistribution and use in source and binary forms, with or without
      8   1.40    itojun  * modification, are permitted provided that the following conditions
      9   1.40    itojun  * are met:
     10   1.40    itojun  * 1. Redistributions of source code must retain the above copyright
     11   1.40    itojun  *    notice, this list of conditions and the following disclaimer.
     12   1.40    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.40    itojun  *    notice, this list of conditions and the following disclaimer in the
     14   1.40    itojun  *    documentation and/or other materials provided with the distribution.
     15   1.40    itojun  * 3. Neither the name of the project nor the names of its contributors
     16   1.40    itojun  *    may be used to endorse or promote products derived from this software
     17   1.40    itojun  *    without specific prior written permission.
     18   1.71    itojun  *
     19   1.40    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     20   1.40    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21   1.40    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22   1.40    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     23   1.40    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24   1.40    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25   1.40    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26   1.40    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27   1.40    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28   1.40    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29   1.40    itojun  * SUCH DAMAGE.
     30   1.40    itojun  */
     31   1.34   thorpej 
     32   1.34   thorpej /*-
     33  1.120    rpaulo  * Copyright (c) 1997, 1998, 2005, 2006 The NetBSD Foundation, Inc.
     34   1.34   thorpej  * All rights reserved.
     35   1.34   thorpej  *
     36   1.34   thorpej  * This code is derived from software contributed to The NetBSD Foundation
     37   1.34   thorpej  * by Jason R. Thorpe and Kevin M. Lahey of the Numerical Aerospace Simulation
     38   1.34   thorpej  * Facility, NASA Ames Research Center.
     39   1.95   mycroft  * This code is derived from software contributed to The NetBSD Foundation
     40   1.95   mycroft  * by Charles M. Hannum.
     41  1.120    rpaulo  * This code is derived from software contributed to The NetBSD Foundation
     42  1.120    rpaulo  * by Rui Paulo.
     43   1.34   thorpej  *
     44   1.34   thorpej  * Redistribution and use in source and binary forms, with or without
     45   1.34   thorpej  * modification, are permitted provided that the following conditions
     46   1.34   thorpej  * are met:
     47   1.34   thorpej  * 1. Redistributions of source code must retain the above copyright
     48   1.34   thorpej  *    notice, this list of conditions and the following disclaimer.
     49   1.34   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     50   1.34   thorpej  *    notice, this list of conditions and the following disclaimer in the
     51   1.34   thorpej  *    documentation and/or other materials provided with the distribution.
     52   1.34   thorpej  *
     53   1.34   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     54   1.34   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     55   1.34   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     56   1.34   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     57   1.34   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     58   1.34   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     59   1.34   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     60   1.34   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     61   1.34   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     62   1.34   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     63   1.34   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     64   1.34   thorpej  */
     65   1.10       cgd 
     66    1.1       cgd /*
     67   1.33   thorpej  * Copyright (c) 1982, 1986, 1988, 1993, 1995
     68    1.9   mycroft  *	The Regents of the University of California.  All rights reserved.
     69    1.1       cgd  *
     70    1.1       cgd  * Redistribution and use in source and binary forms, with or without
     71    1.1       cgd  * modification, are permitted provided that the following conditions
     72    1.1       cgd  * are met:
     73    1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     74    1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     75    1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     76    1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     77    1.1       cgd  *    documentation and/or other materials provided with the distribution.
     78   1.82       agc  * 3. Neither the name of the University nor the names of its contributors
     79    1.1       cgd  *    may be used to endorse or promote products derived from this software
     80    1.1       cgd  *    without specific prior written permission.
     81    1.1       cgd  *
     82    1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     83    1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     84    1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     85    1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     86    1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     87    1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     88    1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     89    1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     90    1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     91    1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     92    1.1       cgd  * SUCH DAMAGE.
     93    1.1       cgd  *
     94   1.33   thorpej  *	@(#)tcp_usrreq.c	8.5 (Berkeley) 6/21/95
     95    1.1       cgd  */
     96   1.67     lukem 
     97  1.173     rmind /*
     98  1.173     rmind  * TCP protocol interface to socket abstraction.
     99  1.173     rmind  */
    100  1.173     rmind 
    101   1.67     lukem #include <sys/cdefs.h>
    102  1.173     rmind __KERNEL_RCSID(0, "$NetBSD: tcp_usrreq.c,v 1.173 2014/05/19 02:51:25 rmind Exp $");
    103    1.1       cgd 
    104   1.40    itojun #include "opt_inet.h"
    105   1.42   thorpej #include "opt_ipsec.h"
    106   1.63       abs #include "opt_tcp_debug.h"
    107   1.77    martin #include "opt_mbuftrace.h"
    108  1.162       tls 
    109    1.5   mycroft #include <sys/param.h>
    110    1.5   mycroft #include <sys/systm.h>
    111   1.13     glass #include <sys/kernel.h>
    112    1.5   mycroft #include <sys/malloc.h>
    113    1.5   mycroft #include <sys/mbuf.h>
    114    1.5   mycroft #include <sys/socket.h>
    115    1.5   mycroft #include <sys/socketvar.h>
    116    1.5   mycroft #include <sys/protosw.h>
    117    1.5   mycroft #include <sys/errno.h>
    118    1.5   mycroft #include <sys/stat.h>
    119   1.20  christos #include <sys/proc.h>
    120   1.40    itojun #include <sys/domain.h>
    121   1.20  christos #include <sys/sysctl.h>
    122  1.117      elad #include <sys/kauth.h>
    123  1.149     pooka #include <sys/uidinfo.h>
    124    1.1       cgd 
    125    1.5   mycroft #include <net/if.h>
    126    1.5   mycroft #include <net/route.h>
    127    1.1       cgd 
    128    1.5   mycroft #include <netinet/in.h>
    129    1.5   mycroft #include <netinet/in_systm.h>
    130   1.14       cgd #include <netinet/in_var.h>
    131    1.5   mycroft #include <netinet/ip.h>
    132    1.5   mycroft #include <netinet/in_pcb.h>
    133    1.5   mycroft #include <netinet/ip_var.h>
    134  1.108      yamt #include <netinet/in_offload.h>
    135   1.40    itojun 
    136   1.40    itojun #ifdef INET6
    137   1.40    itojun #ifndef INET
    138   1.40    itojun #include <netinet/in.h>
    139   1.40    itojun #endif
    140   1.40    itojun #include <netinet/ip6.h>
    141   1.40    itojun #include <netinet6/in6_pcb.h>
    142   1.40    itojun #include <netinet6/ip6_var.h>
    143  1.135  christos #include <netinet6/scope6_var.h>
    144   1.40    itojun #endif
    145   1.40    itojun 
    146    1.5   mycroft #include <netinet/tcp.h>
    147    1.5   mycroft #include <netinet/tcp_fsm.h>
    148    1.5   mycroft #include <netinet/tcp_seq.h>
    149    1.5   mycroft #include <netinet/tcp_timer.h>
    150    1.5   mycroft #include <netinet/tcp_var.h>
    151  1.142   thorpej #include <netinet/tcp_private.h>
    152  1.124    rpaulo #include <netinet/tcp_congctl.h>
    153    1.5   mycroft #include <netinet/tcpip.h>
    154    1.5   mycroft #include <netinet/tcp_debug.h>
    155  1.159    dyoung #include <netinet/tcp_vtw.h>
    156   1.26   thorpej 
    157   1.68     lukem #include "opt_tcp_space.h"
    158    1.1       cgd 
    159    1.1       cgd /*
    160    1.1       cgd  * Process a TCP user request for TCP tb.  If this is a send request
    161    1.1       cgd  * then m is the mbuf chain of send data.  If this is a timer expiration
    162    1.1       cgd  * (called from the software clock routine), then timertype tells which timer.
    163    1.1       cgd  */
    164  1.172     rmind static int
    165  1.172     rmind tcp_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam,
    166  1.172     rmind     struct mbuf *control, struct lwp *l)
    167   1.79   darrenr {
    168   1.49  augustss 	struct inpcb *inp;
    169   1.40    itojun #ifdef INET6
    170   1.49  augustss 	struct in6pcb *in6p;
    171   1.40    itojun #endif
    172   1.49  augustss 	struct tcpcb *tp = NULL;
    173    1.1       cgd 	int s;
    174    1.1       cgd 	int error = 0;
    175   1.74    simonb #ifdef TCP_DEBUG
    176   1.74    simonb 	int ostate = 0;
    177   1.74    simonb #endif
    178   1.40    itojun 	int family;	/* family of the socket */
    179   1.40    itojun 
    180  1.173     rmind 	KASSERT(req != PRU_ATTACH);
    181  1.173     rmind 	KASSERT(req != PRU_DETACH);
    182  1.173     rmind 
    183   1.40    itojun 	family = so->so_proto->pr_domain->dom_family;
    184    1.1       cgd 
    185   1.40    itojun 	if (req == PRU_CONTROL) {
    186   1.40    itojun 		switch (family) {
    187   1.56    itojun #ifdef INET
    188   1.40    itojun 		case PF_INET:
    189  1.131  christos 			return (in_control(so, (long)m, (void *)nam,
    190  1.119        ad 			    (struct ifnet *)control, l));
    191   1.56    itojun #endif
    192   1.40    itojun #ifdef INET6
    193   1.40    itojun 		case PF_INET6:
    194  1.131  christos 			return (in6_control(so, (long)m, (void *)nam,
    195  1.119        ad 			    (struct ifnet *)control, l));
    196   1.40    itojun #endif
    197   1.40    itojun 		default:
    198   1.40    itojun 			return EAFNOSUPPORT;
    199   1.40    itojun 		}
    200   1.45   thorpej 	}
    201   1.45   thorpej 
    202  1.123       tls 	s = splsoftnet();
    203  1.123       tls 
    204   1.46   thorpej 	if (req == PRU_PURGEIF) {
    205  1.144        ad 		mutex_enter(softnet_lock);
    206   1.54     enami 		switch (family) {
    207   1.56    itojun #ifdef INET
    208   1.54     enami 		case PF_INET:
    209   1.62    itojun 			in_pcbpurgeif0(&tcbtable, (struct ifnet *)control);
    210   1.54     enami 			in_purgeif((struct ifnet *)control);
    211   1.54     enami 			in_pcbpurgeif(&tcbtable, (struct ifnet *)control);
    212   1.55     enami 			break;
    213   1.56    itojun #endif
    214   1.46   thorpej #ifdef INET6
    215   1.54     enami 		case PF_INET6:
    216   1.83    itojun 			in6_pcbpurgeif0(&tcbtable, (struct ifnet *)control);
    217   1.54     enami 			in6_purgeif((struct ifnet *)control);
    218   1.83    itojun 			in6_pcbpurgeif(&tcbtable, (struct ifnet *)control);
    219   1.55     enami 			break;
    220   1.46   thorpej #endif
    221   1.54     enami 		default:
    222  1.144        ad 			mutex_exit(softnet_lock);
    223  1.123       tls 			splx(s);
    224   1.54     enami 			return (EAFNOSUPPORT);
    225   1.54     enami 		}
    226  1.144        ad 		mutex_exit(softnet_lock);
    227  1.123       tls 		splx(s);
    228   1.45   thorpej 		return (0);
    229   1.40    itojun 	}
    230   1.22   mycroft 
    231  1.173     rmind 	KASSERT(solocked(so));
    232  1.144        ad 
    233   1.40    itojun 	switch (family) {
    234   1.56    itojun #ifdef INET
    235   1.40    itojun 	case PF_INET:
    236   1.40    itojun 		inp = sotoinpcb(so);
    237   1.40    itojun #ifdef INET6
    238   1.40    itojun 		in6p = NULL;
    239   1.40    itojun #endif
    240   1.40    itojun 		break;
    241   1.56    itojun #endif
    242   1.40    itojun #ifdef INET6
    243   1.40    itojun 	case PF_INET6:
    244   1.40    itojun 		inp = NULL;
    245   1.40    itojun 		in6p = sotoin6pcb(so);
    246   1.40    itojun 		break;
    247   1.40    itojun #endif
    248   1.40    itojun 	default:
    249   1.40    itojun 		splx(s);
    250   1.40    itojun 		return EAFNOSUPPORT;
    251   1.40    itojun 	}
    252   1.40    itojun 
    253   1.57    itojun #ifdef INET6
    254  1.173     rmind 	KASSERT((inp != NULL) ^ (in6p != NULL));
    255   1.23   mycroft #endif
    256  1.173     rmind 	KASSERT(!control || (req == PRU_SEND || req == PRU_SENDOOB));
    257  1.173     rmind 
    258    1.1       cgd 	/*
    259    1.1       cgd 	 * When a TCP is attached to a socket, then there will be
    260    1.1       cgd 	 * a (struct inpcb) pointed at by the socket, and this
    261    1.1       cgd 	 * structure will point at a subsidary (struct tcpcb).
    262    1.1       cgd 	 */
    263  1.173     rmind 	if ((inp == NULL
    264  1.163  christos #ifdef INET6
    265  1.173     rmind 	    && in6p == NULL
    266   1.40    itojun #endif
    267  1.173     rmind 	    ) && req != PRU_SENSE)
    268   1.40    itojun 	{
    269   1.22   mycroft 		error = EINVAL;
    270   1.22   mycroft 		goto release;
    271    1.1       cgd 	}
    272   1.56    itojun #ifdef INET
    273    1.1       cgd 	if (inp) {
    274    1.1       cgd 		tp = intotcpcb(inp);
    275    1.1       cgd 		/* WHAT IF TP IS 0? */
    276    1.1       cgd #ifdef KPROF
    277    1.1       cgd 		tcp_acounts[tp->t_state][req]++;
    278    1.1       cgd #endif
    279   1.74    simonb #ifdef TCP_DEBUG
    280    1.1       cgd 		ostate = tp->t_state;
    281   1.74    simonb #endif
    282   1.40    itojun 	}
    283   1.56    itojun #endif
    284   1.40    itojun #ifdef INET6
    285   1.56    itojun 	if (in6p) {
    286   1.40    itojun 		tp = in6totcpcb(in6p);
    287   1.40    itojun 		/* WHAT IF TP IS 0? */
    288   1.40    itojun #ifdef KPROF
    289   1.40    itojun 		tcp_acounts[tp->t_state][req]++;
    290   1.40    itojun #endif
    291   1.74    simonb #ifdef TCP_DEBUG
    292   1.40    itojun 		ostate = tp->t_state;
    293   1.74    simonb #endif
    294   1.40    itojun 	}
    295   1.40    itojun #endif
    296   1.22   mycroft 
    297    1.1       cgd 	switch (req) {
    298    1.1       cgd 
    299    1.1       cgd 	/*
    300    1.1       cgd 	 * Give the socket an address.
    301    1.1       cgd 	 */
    302    1.1       cgd 	case PRU_BIND:
    303   1.40    itojun 		switch (family) {
    304   1.56    itojun #ifdef INET
    305   1.40    itojun 		case PF_INET:
    306  1.119        ad 			error = in_pcbbind(inp, nam, l);
    307   1.40    itojun 			break;
    308   1.56    itojun #endif
    309   1.40    itojun #ifdef INET6
    310   1.40    itojun 		case PF_INET6:
    311  1.119        ad 			error = in6_pcbbind(in6p, nam, l);
    312   1.58    itojun 			if (!error) {
    313   1.58    itojun 				/* mapped addr case */
    314   1.58    itojun 				if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_laddr))
    315   1.58    itojun 					tp->t_family = AF_INET;
    316   1.58    itojun 				else
    317   1.58    itojun 					tp->t_family = AF_INET6;
    318   1.58    itojun 			}
    319   1.40    itojun 			break;
    320   1.40    itojun #endif
    321   1.40    itojun 		}
    322    1.1       cgd 		break;
    323    1.1       cgd 
    324    1.1       cgd 	/*
    325    1.1       cgd 	 * Prepare to accept connections.
    326    1.1       cgd 	 */
    327    1.1       cgd 	case PRU_LISTEN:
    328   1.56    itojun #ifdef INET
    329   1.40    itojun 		if (inp && inp->inp_lport == 0) {
    330  1.150    dyoung 			error = in_pcbbind(inp, NULL, l);
    331   1.22   mycroft 			if (error)
    332   1.22   mycroft 				break;
    333   1.22   mycroft 		}
    334   1.56    itojun #endif
    335   1.40    itojun #ifdef INET6
    336   1.56    itojun 		if (in6p && in6p->in6p_lport == 0) {
    337  1.154      elad 			error = in6_pcbbind(in6p, NULL, l);
    338   1.40    itojun 			if (error)
    339   1.40    itojun 				break;
    340   1.40    itojun 		}
    341   1.40    itojun #endif
    342   1.22   mycroft 		tp->t_state = TCPS_LISTEN;
    343    1.1       cgd 		break;
    344    1.1       cgd 
    345    1.1       cgd 	/*
    346    1.1       cgd 	 * Initiate connection to peer.
    347    1.1       cgd 	 * Create a template for use in transmissions on this connection.
    348    1.1       cgd 	 * Enter SYN_SENT state, and mark socket as connecting.
    349    1.1       cgd 	 * Start keep-alive timer, and seed output sequence space.
    350    1.1       cgd 	 * Send initial segment on connection.
    351    1.1       cgd 	 */
    352    1.1       cgd 	case PRU_CONNECT:
    353   1.56    itojun #ifdef INET
    354   1.40    itojun 		if (inp) {
    355   1.40    itojun 			if (inp->inp_lport == 0) {
    356  1.150    dyoung 				error = in_pcbbind(inp, NULL, l);
    357   1.40    itojun 				if (error)
    358   1.40    itojun 					break;
    359   1.40    itojun 			}
    360  1.119        ad 			error = in_pcbconnect(inp, nam, l);
    361   1.40    itojun 		}
    362   1.56    itojun #endif
    363   1.40    itojun #ifdef INET6
    364   1.56    itojun 		if (in6p) {
    365   1.40    itojun 			if (in6p->in6p_lport == 0) {
    366  1.154      elad 				error = in6_pcbbind(in6p, NULL, l);
    367   1.40    itojun 				if (error)
    368   1.40    itojun 					break;
    369   1.40    itojun 			}
    370  1.119        ad 			error = in6_pcbconnect(in6p, nam, l);
    371   1.58    itojun 			if (!error) {
    372   1.58    itojun 				/* mapped addr case */
    373   1.58    itojun 				if (IN6_IS_ADDR_V4MAPPED(&in6p->in6p_faddr))
    374   1.58    itojun 					tp->t_family = AF_INET;
    375   1.58    itojun 				else
    376   1.58    itojun 					tp->t_family = AF_INET6;
    377   1.58    itojun 			}
    378    1.1       cgd 		}
    379   1.40    itojun #endif
    380    1.1       cgd 		if (error)
    381    1.1       cgd 			break;
    382    1.1       cgd 		tp->t_template = tcp_template(tp);
    383    1.1       cgd 		if (tp->t_template == 0) {
    384   1.56    itojun #ifdef INET
    385   1.40    itojun 			if (inp)
    386   1.40    itojun 				in_pcbdisconnect(inp);
    387   1.56    itojun #endif
    388   1.40    itojun #ifdef INET6
    389   1.56    itojun 			if (in6p)
    390   1.40    itojun 				in6_pcbdisconnect(in6p);
    391   1.40    itojun #endif
    392    1.1       cgd 			error = ENOBUFS;
    393    1.1       cgd 			break;
    394    1.1       cgd 		}
    395  1.136     rmind 		/*
    396  1.138     rmind 		 * Compute window scaling to request.
    397  1.138     rmind 		 * XXX: This should be moved to tcp_output().
    398  1.136     rmind 		 */
    399    1.9   mycroft 		while (tp->request_r_scale < TCP_MAX_WINSHIFT &&
    400  1.138     rmind 		    (TCP_MAXWIN << tp->request_r_scale) < sb_max)
    401    1.9   mycroft 			tp->request_r_scale++;
    402    1.1       cgd 		soisconnecting(so);
    403  1.142   thorpej 		TCP_STATINC(TCP_STAT_CONNATTEMPT);
    404    1.1       cgd 		tp->t_state = TCPS_SYN_SENT;
    405  1.132  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepinit);
    406   1.61   thorpej 		tp->iss = tcp_new_iss(tp, 0);
    407    1.1       cgd 		tcp_sendseqinit(tp);
    408    1.1       cgd 		error = tcp_output(tp);
    409    1.1       cgd 		break;
    410    1.1       cgd 
    411    1.1       cgd 	/*
    412    1.1       cgd 	 * Create a TCP connection between two sockets.
    413    1.1       cgd 	 */
    414    1.1       cgd 	case PRU_CONNECT2:
    415    1.1       cgd 		error = EOPNOTSUPP;
    416    1.1       cgd 		break;
    417    1.1       cgd 
    418    1.1       cgd 	/*
    419    1.1       cgd 	 * Initiate disconnect from peer.
    420    1.1       cgd 	 * If connection never passed embryonic stage, just drop;
    421    1.1       cgd 	 * else if don't need to let data drain, then can just drop anyways,
    422    1.1       cgd 	 * else have to begin TCP shutdown process: mark socket disconnecting,
    423    1.1       cgd 	 * drain unread data, state switch to reflect user close, and
    424    1.1       cgd 	 * send segment (e.g. FIN) to peer.  Socket will be really disconnected
    425    1.1       cgd 	 * when peer sends FIN and acks ours.
    426    1.1       cgd 	 *
    427    1.1       cgd 	 * SHOULD IMPLEMENT LATER PRU_CONNECT VIA REALLOC TCPCB.
    428    1.1       cgd 	 */
    429    1.1       cgd 	case PRU_DISCONNECT:
    430    1.1       cgd 		tp = tcp_disconnect(tp);
    431    1.1       cgd 		break;
    432    1.1       cgd 
    433    1.1       cgd 	/*
    434    1.1       cgd 	 * Accept a connection.  Essentially all the work is
    435    1.1       cgd 	 * done at higher levels; just return the address
    436    1.1       cgd 	 * of the peer, storing through addr.
    437    1.1       cgd 	 */
    438    1.8   mycroft 	case PRU_ACCEPT:
    439   1.56    itojun #ifdef INET
    440   1.40    itojun 		if (inp)
    441   1.40    itojun 			in_setpeeraddr(inp, nam);
    442   1.56    itojun #endif
    443   1.40    itojun #ifdef INET6
    444   1.56    itojun 		if (in6p)
    445   1.40    itojun 			in6_setpeeraddr(in6p, nam);
    446   1.40    itojun #endif
    447    1.1       cgd 		break;
    448    1.1       cgd 
    449    1.1       cgd 	/*
    450    1.1       cgd 	 * Mark the connection as being incapable of further output.
    451    1.1       cgd 	 */
    452    1.1       cgd 	case PRU_SHUTDOWN:
    453    1.1       cgd 		socantsendmore(so);
    454    1.1       cgd 		tp = tcp_usrclosed(tp);
    455    1.1       cgd 		if (tp)
    456    1.1       cgd 			error = tcp_output(tp);
    457    1.1       cgd 		break;
    458    1.1       cgd 
    459    1.1       cgd 	/*
    460    1.1       cgd 	 * After a receive, possibly send window update to peer.
    461    1.1       cgd 	 */
    462    1.1       cgd 	case PRU_RCVD:
    463   1.60    itojun 		/*
    464   1.60    itojun 		 * soreceive() calls this function when a user receives
    465   1.60    itojun 		 * ancillary data on a listening socket. We don't call
    466   1.60    itojun 		 * tcp_output in such a case, since there is no header
    467   1.60    itojun 		 * template for a listening socket and hence the kernel
    468   1.60    itojun 		 * will panic.
    469   1.60    itojun 		 */
    470   1.60    itojun 		if ((so->so_state & (SS_ISCONNECTED|SS_ISCONNECTING)) != 0)
    471   1.60    itojun 			(void) tcp_output(tp);
    472    1.1       cgd 		break;
    473    1.1       cgd 
    474    1.1       cgd 	/*
    475    1.1       cgd 	 * Do a send by putting data in output queue and updating urgent
    476    1.1       cgd 	 * marker if URG set.  Possibly send more data.
    477    1.1       cgd 	 */
    478    1.1       cgd 	case PRU_SEND:
    479   1.23   mycroft 		if (control && control->m_len) {
    480   1.23   mycroft 			m_freem(control);
    481   1.23   mycroft 			m_freem(m);
    482   1.23   mycroft 			error = EINVAL;
    483   1.23   mycroft 			break;
    484   1.23   mycroft 		}
    485   1.73   thorpej 		sbappendstream(&so->so_snd, m);
    486    1.1       cgd 		error = tcp_output(tp);
    487    1.1       cgd 		break;
    488    1.1       cgd 
    489    1.1       cgd 	/*
    490    1.1       cgd 	 * Abort the TCP.
    491    1.1       cgd 	 */
    492    1.1       cgd 	case PRU_ABORT:
    493    1.1       cgd 		tp = tcp_drop(tp, ECONNABORTED);
    494    1.1       cgd 		break;
    495    1.1       cgd 
    496    1.1       cgd 	case PRU_SENSE:
    497   1.22   mycroft 		/*
    498   1.22   mycroft 		 * stat: don't bother with a blocksize.
    499   1.22   mycroft 		 */
    500   1.22   mycroft 		splx(s);
    501    1.1       cgd 		return (0);
    502    1.1       cgd 
    503    1.1       cgd 	case PRU_RCVOOB:
    504   1.23   mycroft 		if (control && control->m_len) {
    505   1.23   mycroft 			m_freem(control);
    506   1.23   mycroft 			m_freem(m);
    507   1.23   mycroft 			error = EINVAL;
    508   1.23   mycroft 			break;
    509   1.23   mycroft 		}
    510    1.1       cgd 		if ((so->so_oobmark == 0 &&
    511    1.1       cgd 		    (so->so_state & SS_RCVATMARK) == 0) ||
    512    1.1       cgd 		    so->so_options & SO_OOBINLINE ||
    513    1.1       cgd 		    tp->t_oobflags & TCPOOB_HADDATA) {
    514    1.1       cgd 			error = EINVAL;
    515    1.1       cgd 			break;
    516    1.1       cgd 		}
    517    1.1       cgd 		if ((tp->t_oobflags & TCPOOB_HAVEDATA) == 0) {
    518    1.1       cgd 			error = EWOULDBLOCK;
    519    1.1       cgd 			break;
    520    1.1       cgd 		}
    521    1.1       cgd 		m->m_len = 1;
    522  1.131  christos 		*mtod(m, char *) = tp->t_iobc;
    523   1.14       cgd 		if (((long)nam & MSG_PEEK) == 0)
    524    1.1       cgd 			tp->t_oobflags ^= (TCPOOB_HAVEDATA | TCPOOB_HADDATA);
    525    1.1       cgd 		break;
    526    1.1       cgd 
    527    1.1       cgd 	case PRU_SENDOOB:
    528    1.1       cgd 		if (sbspace(&so->so_snd) < -512) {
    529    1.1       cgd 			m_freem(m);
    530    1.1       cgd 			error = ENOBUFS;
    531    1.1       cgd 			break;
    532    1.1       cgd 		}
    533    1.1       cgd 		/*
    534    1.1       cgd 		 * According to RFC961 (Assigned Protocols),
    535    1.1       cgd 		 * the urgent pointer points to the last octet
    536    1.1       cgd 		 * of urgent data.  We continue, however,
    537    1.1       cgd 		 * to consider it to indicate the first octet
    538    1.1       cgd 		 * of data past the urgent section.
    539    1.1       cgd 		 * Otherwise, snd_up should be one lower.
    540    1.1       cgd 		 */
    541   1.73   thorpej 		sbappendstream(&so->so_snd, m);
    542    1.1       cgd 		tp->snd_up = tp->snd_una + so->so_snd.sb_cc;
    543    1.1       cgd 		tp->t_force = 1;
    544    1.1       cgd 		error = tcp_output(tp);
    545    1.1       cgd 		tp->t_force = 0;
    546    1.1       cgd 		break;
    547    1.1       cgd 
    548    1.1       cgd 	case PRU_SOCKADDR:
    549   1.56    itojun #ifdef INET
    550   1.40    itojun 		if (inp)
    551   1.40    itojun 			in_setsockaddr(inp, nam);
    552   1.56    itojun #endif
    553   1.40    itojun #ifdef INET6
    554   1.56    itojun 		if (in6p)
    555   1.40    itojun 			in6_setsockaddr(in6p, nam);
    556   1.40    itojun #endif
    557    1.1       cgd 		break;
    558    1.1       cgd 
    559    1.1       cgd 	case PRU_PEERADDR:
    560   1.56    itojun #ifdef INET
    561   1.40    itojun 		if (inp)
    562   1.40    itojun 			in_setpeeraddr(inp, nam);
    563   1.56    itojun #endif
    564   1.40    itojun #ifdef INET6
    565   1.56    itojun 		if (in6p)
    566   1.40    itojun 			in6_setpeeraddr(in6p, nam);
    567   1.40    itojun #endif
    568    1.1       cgd 		break;
    569    1.1       cgd 
    570    1.1       cgd 	default:
    571    1.1       cgd 		panic("tcp_usrreq");
    572    1.1       cgd 	}
    573   1.63       abs #ifdef TCP_DEBUG
    574    1.1       cgd 	if (tp && (so->so_options & SO_DEBUG))
    575   1.40    itojun 		tcp_trace(TA_USER, ostate, tp, NULL, req);
    576   1.63       abs #endif
    577   1.22   mycroft 
    578   1.22   mycroft release:
    579    1.1       cgd 	splx(s);
    580    1.1       cgd 	return (error);
    581    1.1       cgd }
    582    1.1       cgd 
    583  1.132  christos static void
    584  1.132  christos change_keepalive(struct socket *so, struct tcpcb *tp)
    585  1.132  christos {
    586  1.132  christos 	tp->t_maxidle = tp->t_keepcnt * tp->t_keepintvl;
    587  1.132  christos 	TCP_TIMER_DISARM(tp, TCPT_KEEP);
    588  1.132  christos 	TCP_TIMER_DISARM(tp, TCPT_2MSL);
    589  1.132  christos 
    590  1.132  christos 	if (tp->t_state == TCPS_SYN_RECEIVED ||
    591  1.132  christos 	    tp->t_state == TCPS_SYN_SENT) {
    592  1.132  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepinit);
    593  1.132  christos 	} else if (so->so_options & SO_KEEPALIVE &&
    594  1.132  christos 	    tp->t_state <= TCPS_CLOSE_WAIT) {
    595  1.132  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepintvl);
    596  1.132  christos 	} else {
    597  1.132  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepidle);
    598  1.132  christos 	}
    599  1.132  christos 
    600  1.132  christos 	if ((tp->t_state == TCPS_FIN_WAIT_2) && (tp->t_maxidle > 0))
    601  1.132  christos 		TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_maxidle);
    602  1.132  christos }
    603  1.132  christos 
    604  1.132  christos 
    605    1.6   mycroft int
    606  1.147    plunky tcp_ctloutput(int op, struct socket *so, struct sockopt *sopt)
    607    1.1       cgd {
    608    1.9   mycroft 	int error = 0, s;
    609    1.9   mycroft 	struct inpcb *inp;
    610   1.40    itojun #ifdef INET6
    611   1.49  augustss 	struct in6pcb *in6p;
    612   1.40    itojun #endif
    613   1.49  augustss 	struct tcpcb *tp;
    614  1.132  christos 	u_int ui;
    615   1.40    itojun 	int family;	/* family of the socket */
    616  1.147    plunky 	int level, optname, optval;
    617  1.147    plunky 
    618  1.147    plunky 	level = sopt->sopt_level;
    619  1.147    plunky 	optname = sopt->sopt_name;
    620   1.40    itojun 
    621   1.40    itojun 	family = so->so_proto->pr_domain->dom_family;
    622    1.1       cgd 
    623   1.16   mycroft 	s = splsoftnet();
    624   1.40    itojun 	switch (family) {
    625   1.56    itojun #ifdef INET
    626   1.40    itojun 	case PF_INET:
    627   1.40    itojun 		inp = sotoinpcb(so);
    628   1.40    itojun #ifdef INET6
    629   1.40    itojun 		in6p = NULL;
    630   1.40    itojun #endif
    631   1.40    itojun 		break;
    632   1.56    itojun #endif
    633   1.40    itojun #ifdef INET6
    634   1.40    itojun 	case PF_INET6:
    635   1.40    itojun 		inp = NULL;
    636   1.40    itojun 		in6p = sotoin6pcb(so);
    637   1.40    itojun 		break;
    638   1.40    itojun #endif
    639   1.40    itojun 	default:
    640   1.40    itojun 		splx(s);
    641  1.129      yamt 		panic("%s: af %d", __func__, family);
    642   1.40    itojun 	}
    643   1.40    itojun #ifndef INET6
    644   1.40    itojun 	if (inp == NULL)
    645   1.40    itojun #else
    646   1.40    itojun 	if (inp == NULL && in6p == NULL)
    647   1.40    itojun #endif
    648   1.40    itojun 	{
    649    1.9   mycroft 		splx(s);
    650    1.9   mycroft 		return (ECONNRESET);
    651    1.9   mycroft 	}
    652    1.9   mycroft 	if (level != IPPROTO_TCP) {
    653   1.40    itojun 		switch (family) {
    654   1.56    itojun #ifdef INET
    655   1.40    itojun 		case PF_INET:
    656  1.147    plunky 			error = ip_ctloutput(op, so, sopt);
    657   1.40    itojun 			break;
    658   1.56    itojun #endif
    659   1.40    itojun #ifdef INET6
    660   1.40    itojun 		case PF_INET6:
    661  1.147    plunky 			error = ip6_ctloutput(op, so, sopt);
    662   1.40    itojun 			break;
    663   1.40    itojun #endif
    664   1.40    itojun 		}
    665    1.9   mycroft 		splx(s);
    666    1.9   mycroft 		return (error);
    667    1.9   mycroft 	}
    668   1.40    itojun 	if (inp)
    669   1.40    itojun 		tp = intotcpcb(inp);
    670   1.40    itojun #ifdef INET6
    671   1.40    itojun 	else if (in6p)
    672   1.40    itojun 		tp = in6totcpcb(in6p);
    673   1.40    itojun #endif
    674   1.40    itojun 	else
    675   1.40    itojun 		tp = NULL;
    676    1.1       cgd 
    677    1.1       cgd 	switch (op) {
    678    1.1       cgd 	case PRCO_SETOPT:
    679    1.1       cgd 		switch (optname) {
    680   1.90  jonathan #ifdef TCP_SIGNATURE
    681   1.90  jonathan 		case TCP_MD5SIG:
    682  1.147    plunky 			error = sockopt_getint(sopt, &optval);
    683   1.90  jonathan 			if (error)
    684   1.90  jonathan 				break;
    685  1.147    plunky 			if (optval > 0)
    686   1.90  jonathan 				tp->t_flags |= TF_SIGNATURE;
    687   1.91    itojun 			else
    688   1.90  jonathan 				tp->t_flags &= ~TF_SIGNATURE;
    689   1.90  jonathan 			break;
    690   1.90  jonathan #endif /* TCP_SIGNATURE */
    691   1.90  jonathan 
    692    1.1       cgd 		case TCP_NODELAY:
    693  1.147    plunky 			error = sockopt_getint(sopt, &optval);
    694  1.147    plunky 			if (error)
    695  1.147    plunky 				break;
    696  1.147    plunky 			if (optval)
    697    1.1       cgd 				tp->t_flags |= TF_NODELAY;
    698    1.1       cgd 			else
    699    1.1       cgd 				tp->t_flags &= ~TF_NODELAY;
    700    1.1       cgd 			break;
    701    1.1       cgd 
    702    1.9   mycroft 		case TCP_MAXSEG:
    703  1.147    plunky 			error = sockopt_getint(sopt, &optval);
    704  1.147    plunky 			if (error)
    705  1.147    plunky 				break;
    706  1.147    plunky 			if (optval > 0 && optval <= tp->t_peermss)
    707  1.147    plunky 				tp->t_peermss = optval; /* limit on send size */
    708    1.9   mycroft 			else
    709    1.9   mycroft 				error = EINVAL;
    710    1.9   mycroft 			break;
    711  1.124    rpaulo #ifdef notyet
    712  1.124    rpaulo 		case TCP_CONGCTL:
    713  1.147    plunky 			/* XXX string overflow XXX */
    714  1.147    plunky 			error = tcp_congctl_select(tp, sopt->sopt_data);
    715  1.147    plunky 			break;
    716  1.124    rpaulo #endif
    717    1.9   mycroft 
    718  1.132  christos 		case TCP_KEEPIDLE:
    719  1.147    plunky 			error = sockopt_get(sopt, &ui, sizeof(ui));
    720  1.147    plunky 			if (error)
    721  1.147    plunky 				break;
    722  1.147    plunky 			if (ui > 0) {
    723  1.132  christos 				tp->t_keepidle = ui;
    724  1.132  christos 				change_keepalive(so, tp);
    725  1.132  christos 			} else
    726  1.132  christos 				error = EINVAL;
    727  1.132  christos 			break;
    728  1.132  christos 
    729  1.132  christos 		case TCP_KEEPINTVL:
    730  1.147    plunky 			error = sockopt_get(sopt, &ui, sizeof(ui));
    731  1.147    plunky 			if (error)
    732  1.147    plunky 				break;
    733  1.147    plunky 			if (ui > 0) {
    734  1.132  christos 				tp->t_keepintvl = ui;
    735  1.132  christos 				change_keepalive(so, tp);
    736  1.132  christos 			} else
    737  1.132  christos 				error = EINVAL;
    738  1.132  christos 			break;
    739  1.132  christos 
    740  1.132  christos 		case TCP_KEEPCNT:
    741  1.147    plunky 			error = sockopt_get(sopt, &ui, sizeof(ui));
    742  1.147    plunky 			if (error)
    743  1.147    plunky 				break;
    744  1.147    plunky 			if (ui > 0) {
    745  1.132  christos 				tp->t_keepcnt = ui;
    746  1.132  christos 				change_keepalive(so, tp);
    747  1.132  christos 			} else
    748  1.132  christos 				error = EINVAL;
    749  1.132  christos 			break;
    750  1.132  christos 
    751  1.132  christos 		case TCP_KEEPINIT:
    752  1.147    plunky 			error = sockopt_get(sopt, &ui, sizeof(ui));
    753  1.147    plunky 			if (error)
    754  1.147    plunky 				break;
    755  1.147    plunky 			if (ui > 0) {
    756  1.132  christos 				tp->t_keepinit = ui;
    757  1.132  christos 				change_keepalive(so, tp);
    758  1.132  christos 			} else
    759  1.132  christos 				error = EINVAL;
    760  1.132  christos 			break;
    761  1.132  christos 
    762    1.1       cgd 		default:
    763    1.9   mycroft 			error = ENOPROTOOPT;
    764    1.1       cgd 			break;
    765    1.1       cgd 		}
    766    1.1       cgd 		break;
    767    1.1       cgd 
    768    1.1       cgd 	case PRCO_GETOPT:
    769    1.1       cgd 		switch (optname) {
    770   1.90  jonathan #ifdef TCP_SIGNATURE
    771   1.90  jonathan 		case TCP_MD5SIG:
    772  1.147    plunky 			optval = (tp->t_flags & TF_SIGNATURE) ? 1 : 0;
    773  1.147    plunky 			error = sockopt_set(sopt, &optval, sizeof(optval));
    774   1.90  jonathan 			break;
    775   1.90  jonathan #endif
    776    1.1       cgd 		case TCP_NODELAY:
    777  1.147    plunky 			optval = tp->t_flags & TF_NODELAY;
    778  1.147    plunky 			error = sockopt_set(sopt, &optval, sizeof(optval));
    779    1.1       cgd 			break;
    780    1.1       cgd 		case TCP_MAXSEG:
    781  1.147    plunky 			optval = tp->t_peermss;
    782  1.147    plunky 			error = sockopt_set(sopt, &optval, sizeof(optval));
    783    1.1       cgd 			break;
    784  1.124    rpaulo #ifdef notyet
    785  1.124    rpaulo 		case TCP_CONGCTL:
    786  1.124    rpaulo 			break;
    787  1.124    rpaulo #endif
    788    1.1       cgd 		default:
    789    1.9   mycroft 			error = ENOPROTOOPT;
    790    1.1       cgd 			break;
    791    1.1       cgd 		}
    792    1.1       cgd 		break;
    793    1.1       cgd 	}
    794    1.9   mycroft 	splx(s);
    795    1.1       cgd 	return (error);
    796    1.1       cgd }
    797    1.1       cgd 
    798   1.11   mycroft #ifndef TCP_SENDSPACE
    799   1.84       tls #define	TCP_SENDSPACE	1024*32
    800   1.11   mycroft #endif
    801   1.25   thorpej int	tcp_sendspace = TCP_SENDSPACE;
    802   1.11   mycroft #ifndef TCP_RECVSPACE
    803   1.84       tls #define	TCP_RECVSPACE	1024*32
    804   1.11   mycroft #endif
    805   1.25   thorpej int	tcp_recvspace = TCP_RECVSPACE;
    806    1.1       cgd 
    807    1.1       cgd /*
    808  1.173     rmind  * tcp_attach: attach TCP protocol to socket, allocating internet protocol
    809  1.173     rmind  * control block, TCP control block, buffer space and entering LISTEN state
    810  1.173     rmind  * if to accept connections.
    811    1.1       cgd  */
    812  1.173     rmind static int
    813  1.173     rmind tcp_attach(struct socket *so, int proto)
    814    1.1       cgd {
    815   1.49  augustss 	struct tcpcb *tp;
    816    1.1       cgd 	struct inpcb *inp;
    817   1.40    itojun #ifdef INET6
    818   1.40    itojun 	struct in6pcb *in6p;
    819   1.40    itojun #endif
    820  1.173     rmind 	int s, error, family;
    821  1.173     rmind 
    822  1.173     rmind 	/* Assign the lock (must happen even if we will error out). */
    823  1.173     rmind 	s = splsoftnet();
    824  1.173     rmind 	sosetlock(so);
    825  1.173     rmind 	KASSERT(solocked(so));
    826   1.40    itojun 
    827   1.40    itojun 	family = so->so_proto->pr_domain->dom_family;
    828  1.173     rmind 	switch (family) {
    829  1.173     rmind #ifdef INET
    830  1.173     rmind 	case PF_INET:
    831  1.173     rmind 		inp = sotoinpcb(so);
    832  1.173     rmind #ifdef INET6
    833  1.173     rmind 		in6p = NULL;
    834  1.173     rmind #endif
    835  1.173     rmind 		break;
    836  1.173     rmind #endif
    837  1.173     rmind #ifdef INET6
    838  1.173     rmind 	case PF_INET6:
    839  1.173     rmind 		inp = NULL;
    840  1.173     rmind 		in6p = sotoin6pcb(so);
    841  1.173     rmind 		break;
    842  1.173     rmind #endif
    843  1.173     rmind 	default:
    844  1.173     rmind 		error = EAFNOSUPPORT;
    845  1.173     rmind 		goto out;
    846  1.173     rmind 	}
    847  1.173     rmind 
    848  1.173     rmind 	KASSERT(inp == NULL);
    849  1.173     rmind #ifdef INET6
    850  1.173     rmind 	KASSERT(in6p == NULL);
    851  1.173     rmind #endif
    852    1.1       cgd 
    853   1.75      matt #ifdef MBUFTRACE
    854  1.130      yamt 	so->so_mowner = &tcp_sock_mowner;
    855  1.130      yamt 	so->so_rcv.sb_mowner = &tcp_sock_rx_mowner;
    856  1.130      yamt 	so->so_snd.sb_mowner = &tcp_sock_tx_mowner;
    857   1.75      matt #endif
    858    1.1       cgd 	if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
    859    1.1       cgd 		error = soreserve(so, tcp_sendspace, tcp_recvspace);
    860    1.1       cgd 		if (error)
    861  1.173     rmind 			goto out;
    862    1.1       cgd 	}
    863  1.136     rmind 
    864  1.136     rmind 	so->so_rcv.sb_flags |= SB_AUTOSIZE;
    865  1.136     rmind 	so->so_snd.sb_flags |= SB_AUTOSIZE;
    866  1.136     rmind 
    867   1.40    itojun 	switch (family) {
    868   1.56    itojun #ifdef INET
    869   1.40    itojun 	case PF_INET:
    870   1.40    itojun 		error = in_pcballoc(so, &tcbtable);
    871   1.40    itojun 		if (error)
    872  1.173     rmind 			goto out;
    873   1.40    itojun 		inp = sotoinpcb(so);
    874   1.40    itojun #ifdef INET6
    875   1.40    itojun 		in6p = NULL;
    876   1.40    itojun #endif
    877   1.40    itojun 		break;
    878   1.56    itojun #endif
    879   1.40    itojun #ifdef INET6
    880   1.40    itojun 	case PF_INET6:
    881   1.83    itojun 		error = in6_pcballoc(so, &tcbtable);
    882   1.40    itojun 		if (error)
    883  1.173     rmind 			goto out;
    884   1.40    itojun 		inp = NULL;
    885   1.40    itojun 		in6p = sotoin6pcb(so);
    886   1.40    itojun 		break;
    887   1.40    itojun #endif
    888   1.40    itojun 	default:
    889  1.173     rmind 		error = EAFNOSUPPORT;
    890  1.173     rmind 		goto out;
    891   1.40    itojun 	}
    892   1.40    itojun 	if (inp)
    893   1.40    itojun 		tp = tcp_newtcpcb(family, (void *)inp);
    894   1.40    itojun #ifdef INET6
    895   1.40    itojun 	else if (in6p)
    896   1.40    itojun 		tp = tcp_newtcpcb(family, (void *)in6p);
    897   1.40    itojun #endif
    898   1.41    itojun 	else
    899   1.41    itojun 		tp = NULL;
    900   1.40    itojun 
    901  1.173     rmind 	if (tp == NULL) {
    902    1.1       cgd 		int nofd = so->so_state & SS_NOFDREF;	/* XXX */
    903    1.1       cgd 
    904    1.1       cgd 		so->so_state &= ~SS_NOFDREF;	/* don't free the socket yet */
    905   1.56    itojun #ifdef INET
    906   1.40    itojun 		if (inp)
    907   1.40    itojun 			in_pcbdetach(inp);
    908   1.56    itojun #endif
    909   1.40    itojun #ifdef INET6
    910   1.56    itojun 		if (in6p)
    911   1.40    itojun 			in6_pcbdetach(in6p);
    912   1.40    itojun #endif
    913    1.1       cgd 		so->so_state |= nofd;
    914  1.173     rmind 		error = ENOBUFS;
    915  1.173     rmind 		goto out;
    916    1.1       cgd 	}
    917    1.1       cgd 	tp->t_state = TCPS_CLOSED;
    918  1.173     rmind 	if ((so->so_options & SO_LINGER) && so->so_linger == 0) {
    919  1.173     rmind 		so->so_linger = TCP_LINGERTIME;
    920  1.173     rmind 	}
    921  1.173     rmind out:
    922  1.173     rmind 	KASSERT(solocked(so));
    923  1.173     rmind 	splx(s);
    924  1.173     rmind 	return error;
    925  1.173     rmind }
    926  1.173     rmind 
    927  1.173     rmind static void
    928  1.173     rmind tcp_detach(struct socket *so)
    929  1.173     rmind {
    930  1.173     rmind 	struct inpcb *inp;
    931  1.173     rmind #ifdef INET6
    932  1.173     rmind 	struct in6pcb *in6p;
    933  1.173     rmind #endif
    934  1.173     rmind 	struct tcpcb *tp = NULL;
    935  1.173     rmind 	int s, family;
    936  1.173     rmind 
    937  1.173     rmind 	KASSERT(solocked(so));
    938  1.173     rmind 
    939  1.173     rmind 	s = splsoftnet();
    940  1.173     rmind 	family = so->so_proto->pr_domain->dom_family;
    941  1.173     rmind 	switch (family) {
    942  1.173     rmind #ifdef INET
    943  1.173     rmind 	case PF_INET:
    944  1.173     rmind 		inp = sotoinpcb(so);
    945  1.173     rmind 		tp = intotcpcb(inp);
    946  1.173     rmind 		break;
    947  1.173     rmind #endif
    948  1.173     rmind #ifdef INET6
    949  1.173     rmind 	case PF_INET6:
    950  1.173     rmind 		in6p = sotoin6pcb(so);
    951  1.173     rmind 		tp = in6totcpcb(in6p);
    952  1.173     rmind 		break;
    953  1.173     rmind #endif
    954  1.173     rmind 	default:
    955  1.173     rmind 		splx(s);
    956  1.173     rmind 		return;
    957  1.173     rmind 	}
    958  1.173     rmind 	KASSERT(tp != NULL);
    959  1.173     rmind 	(void)tcp_disconnect(tp);
    960  1.173     rmind 	splx(s);
    961    1.1       cgd }
    962    1.1       cgd 
    963    1.1       cgd /*
    964    1.1       cgd  * Initiate (or continue) disconnect.
    965    1.1       cgd  * If embryonic state, just send reset (once).
    966    1.1       cgd  * If in ``let data drain'' option and linger null, just drop.
    967    1.1       cgd  * Otherwise (hard), mark socket disconnecting and drop
    968    1.1       cgd  * current input data; switch states based on user close, and
    969    1.1       cgd  * send segment to peer (with FIN).
    970    1.1       cgd  */
    971    1.1       cgd struct tcpcb *
    972   1.94     perry tcp_disconnect(struct tcpcb *tp)
    973    1.1       cgd {
    974   1.40    itojun 	struct socket *so;
    975   1.40    itojun 
    976   1.40    itojun 	if (tp->t_inpcb)
    977   1.40    itojun 		so = tp->t_inpcb->inp_socket;
    978   1.40    itojun #ifdef INET6
    979   1.40    itojun 	else if (tp->t_in6pcb)
    980   1.40    itojun 		so = tp->t_in6pcb->in6p_socket;
    981   1.40    itojun #endif
    982   1.40    itojun 	else
    983   1.40    itojun 		so = NULL;
    984    1.1       cgd 
    985   1.12   mycroft 	if (TCPS_HAVEESTABLISHED(tp->t_state) == 0)
    986    1.1       cgd 		tp = tcp_close(tp);
    987    1.1       cgd 	else if ((so->so_options & SO_LINGER) && so->so_linger == 0)
    988    1.1       cgd 		tp = tcp_drop(tp, 0);
    989    1.1       cgd 	else {
    990    1.1       cgd 		soisdisconnecting(so);
    991    1.1       cgd 		sbflush(&so->so_rcv);
    992    1.1       cgd 		tp = tcp_usrclosed(tp);
    993    1.1       cgd 		if (tp)
    994    1.1       cgd 			(void) tcp_output(tp);
    995    1.1       cgd 	}
    996    1.1       cgd 	return (tp);
    997    1.1       cgd }
    998    1.1       cgd 
    999    1.1       cgd /*
   1000    1.1       cgd  * User issued close, and wish to trail through shutdown states:
   1001    1.1       cgd  * if never received SYN, just forget it.  If got a SYN from peer,
   1002    1.1       cgd  * but haven't sent FIN, then go to FIN_WAIT_1 state to send peer a FIN.
   1003    1.1       cgd  * If already got a FIN from peer, then almost done; go to LAST_ACK
   1004    1.1       cgd  * state.  In all other cases, have already sent FIN to peer (e.g.
   1005    1.1       cgd  * after PRU_SHUTDOWN), and just have to play tedious game waiting
   1006    1.1       cgd  * for peer to send FIN or not respond to keep-alives, etc.
   1007    1.1       cgd  * We can let the user exit from the close as soon as the FIN is acked.
   1008    1.1       cgd  */
   1009    1.1       cgd struct tcpcb *
   1010   1.94     perry tcp_usrclosed(struct tcpcb *tp)
   1011    1.1       cgd {
   1012    1.1       cgd 
   1013    1.1       cgd 	switch (tp->t_state) {
   1014    1.1       cgd 
   1015    1.1       cgd 	case TCPS_CLOSED:
   1016    1.1       cgd 	case TCPS_LISTEN:
   1017    1.1       cgd 	case TCPS_SYN_SENT:
   1018    1.1       cgd 		tp->t_state = TCPS_CLOSED;
   1019    1.1       cgd 		tp = tcp_close(tp);
   1020    1.1       cgd 		break;
   1021    1.1       cgd 
   1022    1.1       cgd 	case TCPS_SYN_RECEIVED:
   1023    1.1       cgd 	case TCPS_ESTABLISHED:
   1024    1.1       cgd 		tp->t_state = TCPS_FIN_WAIT_1;
   1025    1.1       cgd 		break;
   1026    1.1       cgd 
   1027    1.1       cgd 	case TCPS_CLOSE_WAIT:
   1028    1.1       cgd 		tp->t_state = TCPS_LAST_ACK;
   1029    1.1       cgd 		break;
   1030    1.1       cgd 	}
   1031   1.18   mycroft 	if (tp && tp->t_state >= TCPS_FIN_WAIT_2) {
   1032   1.40    itojun 		struct socket *so;
   1033   1.40    itojun 		if (tp->t_inpcb)
   1034   1.40    itojun 			so = tp->t_inpcb->inp_socket;
   1035   1.40    itojun #ifdef INET6
   1036   1.40    itojun 		else if (tp->t_in6pcb)
   1037   1.40    itojun 			so = tp->t_in6pcb->in6p_socket;
   1038   1.40    itojun #endif
   1039   1.40    itojun 		else
   1040   1.40    itojun 			so = NULL;
   1041  1.115  christos 		if (so)
   1042  1.115  christos 			soisdisconnected(so);
   1043   1.19   mycroft 		/*
   1044   1.19   mycroft 		 * If we are in FIN_WAIT_2, we arrived here because the
   1045   1.19   mycroft 		 * application did a shutdown of the send side.  Like the
   1046   1.19   mycroft 		 * case of a transition from FIN_WAIT_1 to FIN_WAIT_2 after
   1047   1.19   mycroft 		 * a full close, we start a timer to make sure sockets are
   1048   1.19   mycroft 		 * not left in FIN_WAIT_2 forever.
   1049   1.19   mycroft 		 */
   1050  1.132  christos 		if ((tp->t_state == TCPS_FIN_WAIT_2) && (tp->t_maxidle > 0))
   1051  1.132  christos 			TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_maxidle);
   1052  1.159    dyoung 		else if (tp->t_state == TCPS_TIME_WAIT
   1053  1.159    dyoung 			 && ((tp->t_inpcb
   1054  1.159    dyoung 			      && (tcp4_vtw_enable & 1)
   1055  1.159    dyoung 			      && vtw_add(AF_INET, tp))
   1056  1.159    dyoung 			     ||
   1057  1.159    dyoung 			     (tp->t_in6pcb
   1058  1.159    dyoung 			      && (tcp6_vtw_enable & 1)
   1059  1.159    dyoung 			      && vtw_add(AF_INET6, tp)))) {
   1060  1.159    dyoung 			tp = 0;
   1061  1.159    dyoung 		}
   1062   1.18   mycroft 	}
   1063    1.1       cgd 	return (tp);
   1064   1.17   thorpej }
   1065   1.17   thorpej 
   1066   1.86    atatat /*
   1067   1.86    atatat  * sysctl helper routine for net.inet.ip.mssdflt.  it can't be less
   1068   1.86    atatat  * than 32.
   1069   1.86    atatat  */
   1070   1.86    atatat static int
   1071   1.86    atatat sysctl_net_inet_tcp_mssdflt(SYSCTLFN_ARGS)
   1072   1.86    atatat {
   1073   1.86    atatat 	int error, mssdflt;
   1074   1.86    atatat 	struct sysctlnode node;
   1075   1.86    atatat 
   1076   1.86    atatat 	mssdflt = tcp_mssdflt;
   1077   1.86    atatat 	node = *rnode;
   1078   1.86    atatat 	node.sysctl_data = &mssdflt;
   1079   1.86    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1080   1.86    atatat 	if (error || newp == NULL)
   1081   1.86    atatat 		return (error);
   1082   1.86    atatat 
   1083   1.86    atatat 	if (mssdflt < 32)
   1084   1.86    atatat 		return (EINVAL);
   1085   1.86    atatat 	tcp_mssdflt = mssdflt;
   1086   1.86    atatat 
   1087  1.170    kefren 	mutex_enter(softnet_lock);
   1088  1.170    kefren 	tcp_tcpcb_template();
   1089  1.170    kefren 	mutex_exit(softnet_lock);
   1090  1.170    kefren 
   1091   1.86    atatat 	return (0);
   1092   1.86    atatat }
   1093   1.36      matt 
   1094   1.17   thorpej /*
   1095  1.170    kefren  * sysctl helper for TCP CB template update
   1096  1.170    kefren  */
   1097  1.170    kefren static int
   1098  1.170    kefren sysctl_update_tcpcb_template(SYSCTLFN_ARGS)
   1099  1.170    kefren {
   1100  1.170    kefren 	int t, error;
   1101  1.170    kefren 	struct sysctlnode node;
   1102  1.170    kefren 
   1103  1.170    kefren 	/* follow procedures in sysctl(9) manpage */
   1104  1.170    kefren 	t = *(int *)rnode->sysctl_data;
   1105  1.170    kefren 	node = *rnode;
   1106  1.170    kefren 	node.sysctl_data = &t;
   1107  1.170    kefren 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1108  1.170    kefren 	if (error || newp == NULL)
   1109  1.170    kefren 		return error;
   1110  1.170    kefren 
   1111  1.170    kefren 	if (t < 0)
   1112  1.170    kefren 		return EINVAL;
   1113  1.170    kefren 
   1114  1.170    kefren 	*(int *)rnode->sysctl_data = t;
   1115  1.170    kefren 
   1116  1.170    kefren 	mutex_enter(softnet_lock);
   1117  1.170    kefren 	tcp_tcpcb_template();
   1118  1.170    kefren 	mutex_exit(softnet_lock);
   1119  1.170    kefren 
   1120  1.170    kefren 	return 0;
   1121  1.170    kefren }
   1122  1.170    kefren 
   1123  1.170    kefren /*
   1124   1.86    atatat  * sysctl helper routine for setting port related values under
   1125   1.86    atatat  * net.inet.ip and net.inet6.ip6.  does basic range checking and does
   1126   1.86    atatat  * additional checks for each type.  this code has placed in
   1127   1.86    atatat  * tcp_input.c since INET and INET6 both use the same tcp code.
   1128   1.86    atatat  *
   1129   1.86    atatat  * this helper is not static so that both inet and inet6 can use it.
   1130   1.17   thorpej  */
   1131   1.17   thorpej int
   1132   1.86    atatat sysctl_net_inet_ip_ports(SYSCTLFN_ARGS)
   1133   1.86    atatat {
   1134   1.86    atatat 	int error, tmp;
   1135   1.86    atatat 	int apmin, apmax;
   1136   1.86    atatat #ifndef IPNOPRIVPORTS
   1137   1.86    atatat 	int lpmin, lpmax;
   1138   1.86    atatat #endif /* IPNOPRIVPORTS */
   1139   1.86    atatat 	struct sysctlnode node;
   1140   1.86    atatat 
   1141   1.86    atatat 	if (namelen != 0)
   1142   1.86    atatat 		return (EINVAL);
   1143   1.86    atatat 
   1144   1.86    atatat 	switch (name[-3]) {
   1145   1.86    atatat #ifdef INET
   1146   1.86    atatat 	    case PF_INET:
   1147   1.86    atatat 		apmin = anonportmin;
   1148   1.86    atatat 		apmax = anonportmax;
   1149   1.86    atatat #ifndef IPNOPRIVPORTS
   1150   1.86    atatat 		lpmin = lowportmin;
   1151   1.86    atatat 		lpmax = lowportmax;
   1152   1.86    atatat #endif /* IPNOPRIVPORTS */
   1153   1.86    atatat 		break;
   1154   1.86    atatat #endif /* INET */
   1155   1.86    atatat #ifdef INET6
   1156   1.86    atatat 	    case PF_INET6:
   1157   1.86    atatat 		apmin = ip6_anonportmin;
   1158   1.86    atatat 		apmax = ip6_anonportmax;
   1159   1.86    atatat #ifndef IPNOPRIVPORTS
   1160   1.86    atatat 		lpmin = ip6_lowportmin;
   1161   1.86    atatat 		lpmax = ip6_lowportmax;
   1162   1.86    atatat #endif /* IPNOPRIVPORTS */
   1163   1.86    atatat 		break;
   1164   1.86    atatat #endif /* INET6 */
   1165   1.86    atatat 	    default:
   1166   1.86    atatat 		return (EINVAL);
   1167   1.86    atatat 	}
   1168   1.86    atatat 
   1169   1.86    atatat 	/*
   1170   1.86    atatat 	 * insert temporary copy into node, perform lookup on
   1171   1.86    atatat 	 * temporary, then restore pointer
   1172   1.86    atatat 	 */
   1173   1.86    atatat 	node = *rnode;
   1174   1.86    atatat 	tmp = *(int*)rnode->sysctl_data;
   1175   1.86    atatat 	node.sysctl_data = &tmp;
   1176   1.86    atatat 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1177   1.86    atatat 	if (error || newp == NULL)
   1178   1.86    atatat 		return (error);
   1179   1.86    atatat 
   1180   1.86    atatat 	/*
   1181   1.86    atatat 	 * simple port range check
   1182   1.86    atatat 	 */
   1183   1.86    atatat 	if (tmp < 0 || tmp > 65535)
   1184   1.86    atatat 		return (EINVAL);
   1185   1.86    atatat 
   1186   1.86    atatat 	/*
   1187   1.86    atatat 	 * per-node range checks
   1188   1.86    atatat 	 */
   1189   1.86    atatat 	switch (rnode->sysctl_num) {
   1190   1.86    atatat 	case IPCTL_ANONPORTMIN:
   1191  1.151      yamt 	case IPV6CTL_ANONPORTMIN:
   1192   1.86    atatat 		if (tmp >= apmax)
   1193   1.86    atatat 			return (EINVAL);
   1194   1.86    atatat #ifndef IPNOPRIVPORTS
   1195   1.86    atatat 		if (tmp < IPPORT_RESERVED)
   1196   1.86    atatat                         return (EINVAL);
   1197   1.86    atatat #endif /* IPNOPRIVPORTS */
   1198   1.86    atatat 		break;
   1199   1.86    atatat 
   1200   1.86    atatat 	case IPCTL_ANONPORTMAX:
   1201  1.151      yamt 	case IPV6CTL_ANONPORTMAX:
   1202   1.86    atatat                 if (apmin >= tmp)
   1203   1.86    atatat 			return (EINVAL);
   1204   1.86    atatat #ifndef IPNOPRIVPORTS
   1205   1.86    atatat 		if (tmp < IPPORT_RESERVED)
   1206   1.86    atatat                         return (EINVAL);
   1207   1.86    atatat #endif /* IPNOPRIVPORTS */
   1208   1.86    atatat 		break;
   1209   1.86    atatat 
   1210   1.86    atatat #ifndef IPNOPRIVPORTS
   1211   1.86    atatat 	case IPCTL_LOWPORTMIN:
   1212  1.151      yamt 	case IPV6CTL_LOWPORTMIN:
   1213   1.86    atatat 		if (tmp >= lpmax ||
   1214   1.86    atatat 		    tmp > IPPORT_RESERVEDMAX ||
   1215   1.86    atatat 		    tmp < IPPORT_RESERVEDMIN)
   1216   1.86    atatat 			return (EINVAL);
   1217   1.86    atatat 		break;
   1218   1.86    atatat 
   1219   1.86    atatat 	case IPCTL_LOWPORTMAX:
   1220  1.151      yamt 	case IPV6CTL_LOWPORTMAX:
   1221   1.86    atatat 		if (lpmin >= tmp ||
   1222   1.86    atatat 		    tmp > IPPORT_RESERVEDMAX ||
   1223   1.86    atatat 		    tmp < IPPORT_RESERVEDMIN)
   1224   1.86    atatat 			return (EINVAL);
   1225   1.86    atatat 		break;
   1226   1.86    atatat #endif /* IPNOPRIVPORTS */
   1227   1.86    atatat 
   1228   1.86    atatat 	default:
   1229   1.86    atatat 		return (EINVAL);
   1230   1.86    atatat 	}
   1231   1.86    atatat 
   1232   1.86    atatat 	*(int*)rnode->sysctl_data = tmp;
   1233   1.86    atatat 
   1234   1.86    atatat 	return (0);
   1235   1.86    atatat }
   1236   1.86    atatat 
   1237  1.133  christos static inline int
   1238  1.133  christos copyout_uid(struct socket *sockp, void *oldp, size_t *oldlenp)
   1239  1.133  christos {
   1240  1.168  christos 	if (oldp) {
   1241  1.168  christos 		size_t sz;
   1242  1.168  christos 		uid_t uid;
   1243  1.168  christos 		int error;
   1244  1.168  christos 
   1245  1.168  christos 		if (sockp->so_cred == NULL)
   1246  1.168  christos 			return EPERM;
   1247  1.133  christos 
   1248  1.168  christos 		uid = kauth_cred_geteuid(sockp->so_cred);
   1249  1.133  christos 		sz = MIN(sizeof(uid), *oldlenp);
   1250  1.168  christos 		if ((error = copyout(&uid, oldp, sz)) != 0)
   1251  1.133  christos 			return error;
   1252  1.133  christos 	}
   1253  1.168  christos 	*oldlenp = sizeof(uid_t);
   1254  1.133  christos 	return 0;
   1255  1.133  christos }
   1256  1.133  christos 
   1257  1.133  christos static inline int
   1258  1.133  christos inet4_ident_core(struct in_addr raddr, u_int rport,
   1259  1.133  christos     struct in_addr laddr, u_int lport,
   1260  1.133  christos     void *oldp, size_t *oldlenp,
   1261  1.133  christos     struct lwp *l, int dodrop)
   1262  1.133  christos {
   1263  1.133  christos 	struct inpcb *inp;
   1264  1.133  christos 	struct socket *sockp;
   1265  1.133  christos 
   1266  1.159    dyoung 	inp = in_pcblookup_connect(&tcbtable, raddr, rport, laddr, lport, 0);
   1267  1.133  christos 
   1268  1.133  christos 	if (inp == NULL || (sockp = inp->inp_socket) == NULL)
   1269  1.133  christos 		return ESRCH;
   1270  1.133  christos 
   1271  1.133  christos 	if (dodrop) {
   1272  1.133  christos 		struct tcpcb *tp;
   1273  1.153      elad 		int error;
   1274  1.133  christos 
   1275  1.133  christos 		if (inp == NULL || (tp = intotcpcb(inp)) == NULL ||
   1276  1.133  christos 		    (inp->inp_socket->so_options & SO_ACCEPTCONN) != 0)
   1277  1.133  christos 			return ESRCH;
   1278  1.153      elad 
   1279  1.153      elad 		error = kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
   1280  1.153      elad 		    KAUTH_REQ_NETWORK_SOCKET_DROP, inp->inp_socket, tp, NULL);
   1281  1.153      elad 		if (error)
   1282  1.153      elad 			return (error);
   1283  1.133  christos 
   1284  1.133  christos 		(void)tcp_drop(tp, ECONNABORTED);
   1285  1.133  christos 		return 0;
   1286  1.133  christos 	}
   1287  1.133  christos 	else
   1288  1.133  christos 		return copyout_uid(sockp, oldp, oldlenp);
   1289  1.133  christos }
   1290  1.133  christos 
   1291  1.134   xtraeme #ifdef INET6
   1292  1.133  christos static inline int
   1293  1.133  christos inet6_ident_core(struct in6_addr *raddr, u_int rport,
   1294  1.133  christos     struct in6_addr *laddr, u_int lport,
   1295  1.133  christos     void *oldp, size_t *oldlenp,
   1296  1.133  christos     struct lwp *l, int dodrop)
   1297  1.133  christos {
   1298  1.133  christos 	struct in6pcb *in6p;
   1299  1.133  christos 	struct socket *sockp;
   1300  1.133  christos 
   1301  1.159    dyoung 	in6p = in6_pcblookup_connect(&tcbtable, raddr, rport, laddr, lport, 0, 0);
   1302  1.133  christos 
   1303  1.133  christos 	if (in6p == NULL || (sockp = in6p->in6p_socket) == NULL)
   1304  1.133  christos 		return ESRCH;
   1305  1.133  christos 
   1306  1.133  christos 	if (dodrop) {
   1307  1.133  christos 		struct tcpcb *tp;
   1308  1.153      elad 		int error;
   1309  1.133  christos 
   1310  1.133  christos 		if (in6p == NULL || (tp = in6totcpcb(in6p)) == NULL ||
   1311  1.133  christos 		    (in6p->in6p_socket->so_options & SO_ACCEPTCONN) != 0)
   1312  1.133  christos 			return ESRCH;
   1313  1.133  christos 
   1314  1.153      elad 		error = kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
   1315  1.153      elad 		    KAUTH_REQ_NETWORK_SOCKET_DROP, in6p->in6p_socket, tp, NULL);
   1316  1.153      elad 		if (error)
   1317  1.153      elad 			return (error);
   1318  1.133  christos 
   1319  1.133  christos 		(void)tcp_drop(tp, ECONNABORTED);
   1320  1.133  christos 		return 0;
   1321  1.133  christos 	}
   1322  1.133  christos 	else
   1323  1.133  christos 		return copyout_uid(sockp, oldp, oldlenp);
   1324  1.133  christos }
   1325  1.134   xtraeme #endif
   1326  1.133  christos 
   1327  1.133  christos /*
   1328  1.133  christos  * sysctl helper routine for the net.inet.tcp.drop and
   1329  1.133  christos  * net.inet6.tcp6.drop nodes.
   1330  1.133  christos  */
   1331  1.133  christos #define sysctl_net_inet_tcp_drop sysctl_net_inet_tcp_ident
   1332  1.133  christos 
   1333  1.133  christos /*
   1334   1.86    atatat  * sysctl helper routine for the net.inet.tcp.ident and
   1335   1.86    atatat  * net.inet6.tcp6.ident nodes.  contains backwards compat code for the
   1336   1.86    atatat  * old way of looking up the ident information for ipv4 which involves
   1337   1.86    atatat  * stuffing the port/addr pairs into the mib lookup.
   1338   1.86    atatat  */
   1339   1.86    atatat static int
   1340   1.86    atatat sysctl_net_inet_tcp_ident(SYSCTLFN_ARGS)
   1341   1.86    atatat {
   1342   1.86    atatat #ifdef INET
   1343   1.86    atatat 	struct sockaddr_in *si4[2];
   1344   1.86    atatat #endif /* INET */
   1345   1.86    atatat #ifdef INET6
   1346   1.86    atatat 	struct sockaddr_in6 *si6[2];
   1347   1.86    atatat #endif /* INET6 */
   1348   1.86    atatat 	struct sockaddr_storage sa[2];
   1349  1.148      matt 	int error, pf, dodrop;
   1350   1.86    atatat 
   1351  1.133  christos 	dodrop = name[-1] == TCPCTL_DROP;
   1352  1.133  christos 	if (dodrop) {
   1353  1.133  christos 		if (oldp != NULL || *oldlenp != 0)
   1354  1.133  christos 			return EINVAL;
   1355  1.133  christos 		if (newp == NULL)
   1356  1.133  christos 			return EPERM;
   1357  1.133  christos 		if (newlen < sizeof(sa))
   1358  1.133  christos 			return ENOMEM;
   1359  1.133  christos 	}
   1360   1.86    atatat 	if (namelen != 4 && namelen != 0)
   1361  1.133  christos 		return EINVAL;
   1362   1.86    atatat 	if (name[-2] != IPPROTO_TCP)
   1363  1.133  christos 		return EINVAL;
   1364   1.86    atatat 	pf = name[-3];
   1365   1.86    atatat 
   1366   1.86    atatat 	/* old style lookup, ipv4 only */
   1367   1.86    atatat 	if (namelen == 4) {
   1368   1.86    atatat #ifdef INET
   1369   1.88    atatat 		struct in_addr laddr, raddr;
   1370   1.88    atatat 		u_int lport, rport;
   1371   1.88    atatat 
   1372   1.86    atatat 		if (pf != PF_INET)
   1373  1.133  christos 			return EPROTONOSUPPORT;
   1374   1.86    atatat 		raddr.s_addr = (uint32_t)name[0];
   1375   1.86    atatat 		rport = (u_int)name[1];
   1376   1.86    atatat 		laddr.s_addr = (uint32_t)name[2];
   1377   1.86    atatat 		lport = (u_int)name[3];
   1378  1.133  christos 
   1379  1.148      matt 		mutex_enter(softnet_lock);
   1380  1.133  christos 		error = inet4_ident_core(raddr, rport, laddr, lport,
   1381  1.133  christos 		    oldp, oldlenp, l, dodrop);
   1382  1.148      matt 		mutex_exit(softnet_lock);
   1383  1.133  christos 		return error;
   1384   1.86    atatat #else /* INET */
   1385  1.133  christos 		return EINVAL;
   1386   1.86    atatat #endif /* INET */
   1387   1.86    atatat 	}
   1388   1.86    atatat 
   1389   1.86    atatat 	if (newp == NULL || newlen != sizeof(sa))
   1390  1.133  christos 		return EINVAL;
   1391   1.86    atatat 	error = copyin(newp, &sa, newlen);
   1392   1.86    atatat 	if (error)
   1393  1.133  christos 		return error;
   1394   1.86    atatat 
   1395   1.86    atatat 	/*
   1396   1.86    atatat 	 * requested families must match
   1397   1.86    atatat 	 */
   1398   1.86    atatat 	if (pf != sa[0].ss_family || sa[0].ss_family != sa[1].ss_family)
   1399  1.133  christos 		return EINVAL;
   1400   1.86    atatat 
   1401   1.86    atatat 	switch (pf) {
   1402  1.135  christos #ifdef INET6
   1403  1.135  christos 	case PF_INET6:
   1404  1.135  christos 		si6[0] = (struct sockaddr_in6*)&sa[0];
   1405  1.135  christos 		si6[1] = (struct sockaddr_in6*)&sa[1];
   1406  1.135  christos 		if (si6[0]->sin6_len != sizeof(*si6[0]) ||
   1407  1.135  christos 		    si6[1]->sin6_len != sizeof(*si6[1]))
   1408  1.135  christos 			return EINVAL;
   1409  1.135  christos 
   1410  1.135  christos 		if (!IN6_IS_ADDR_V4MAPPED(&si6[0]->sin6_addr) &&
   1411  1.135  christos 		    !IN6_IS_ADDR_V4MAPPED(&si6[1]->sin6_addr)) {
   1412  1.135  christos 			error = sa6_embedscope(si6[0], ip6_use_defzone);
   1413  1.135  christos 			if (error)
   1414  1.135  christos 				return error;
   1415  1.135  christos 			error = sa6_embedscope(si6[1], ip6_use_defzone);
   1416  1.135  christos 			if (error)
   1417  1.135  christos 				return error;
   1418  1.135  christos 
   1419  1.148      matt 			mutex_enter(softnet_lock);
   1420  1.135  christos 			error = inet6_ident_core(&si6[0]->sin6_addr,
   1421  1.135  christos 			    si6[0]->sin6_port, &si6[1]->sin6_addr,
   1422  1.135  christos 			    si6[1]->sin6_port, oldp, oldlenp, l, dodrop);
   1423  1.148      matt 			mutex_exit(softnet_lock);
   1424  1.135  christos 			return error;
   1425  1.135  christos 		}
   1426  1.135  christos 
   1427  1.135  christos 		if (IN6_IS_ADDR_V4MAPPED(&si6[0]->sin6_addr) !=
   1428  1.135  christos 		    IN6_IS_ADDR_V4MAPPED(&si6[1]->sin6_addr))
   1429  1.135  christos 			return EINVAL;
   1430  1.135  christos 
   1431  1.135  christos 		in6_sin6_2_sin_in_sock((struct sockaddr *)&sa[0]);
   1432  1.135  christos 		in6_sin6_2_sin_in_sock((struct sockaddr *)&sa[1]);
   1433  1.135  christos 		/*FALLTHROUGH*/
   1434  1.135  christos #endif /* INET6 */
   1435   1.86    atatat #ifdef INET
   1436  1.133  christos 	case PF_INET:
   1437   1.86    atatat 		si4[0] = (struct sockaddr_in*)&sa[0];
   1438   1.86    atatat 		si4[1] = (struct sockaddr_in*)&sa[1];
   1439   1.86    atatat 		if (si4[0]->sin_len != sizeof(*si4[0]) ||
   1440  1.135  christos 		    si4[0]->sin_len != sizeof(*si4[1]))
   1441  1.133  christos 			return EINVAL;
   1442  1.133  christos 
   1443  1.148      matt 		mutex_enter(softnet_lock);
   1444  1.133  christos 		error = inet4_ident_core(si4[0]->sin_addr, si4[0]->sin_port,
   1445  1.133  christos 		    si4[1]->sin_addr, si4[1]->sin_port,
   1446  1.133  christos 		    oldp, oldlenp, l, dodrop);
   1447  1.148      matt 		mutex_exit(softnet_lock);
   1448  1.133  christos 		return error;
   1449   1.86    atatat #endif /* INET */
   1450  1.133  christos 	default:
   1451  1.133  christos 		return EPROTONOSUPPORT;
   1452   1.86    atatat 	}
   1453   1.76  christos }
   1454   1.76  christos 
   1455   1.86    atatat /*
   1456   1.97    atatat  * sysctl helper for the inet and inet6 pcblists.  handles tcp/udp and
   1457   1.97    atatat  * inet/inet6, as well as raw pcbs for each.  specifically not
   1458   1.97    atatat  * declared static so that raw sockets and udp/udp6 can use it as
   1459   1.97    atatat  * well.
   1460   1.97    atatat  */
   1461   1.97    atatat int
   1462   1.97    atatat sysctl_inpcblist(SYSCTLFN_ARGS)
   1463   1.97    atatat {
   1464   1.97    atatat #ifdef INET
   1465   1.97    atatat 	struct sockaddr_in *in;
   1466  1.104  christos 	const struct inpcb *inp;
   1467   1.97    atatat #endif
   1468   1.97    atatat #ifdef INET6
   1469   1.97    atatat 	struct sockaddr_in6 *in6;
   1470  1.104  christos 	const struct in6pcb *in6p;
   1471   1.97    atatat #endif
   1472  1.104  christos 	struct inpcbtable *pcbtbl = __UNCONST(rnode->sysctl_data);
   1473  1.104  christos 	const struct inpcb_hdr *inph;
   1474   1.97    atatat 	struct tcpcb *tp;
   1475   1.97    atatat 	struct kinfo_pcb pcb;
   1476   1.97    atatat 	char *dp;
   1477   1.97    atatat 	size_t len, needed, elem_size, out_size;
   1478   1.97    atatat 	int error, elem_count, pf, proto, pf2;
   1479   1.97    atatat 
   1480   1.97    atatat 	if (namelen != 4)
   1481   1.97    atatat 		return (EINVAL);
   1482   1.97    atatat 
   1483  1.114  christos 	if (oldp != NULL) {
   1484  1.114  christos 		    len = *oldlenp;
   1485  1.114  christos 		    elem_size = name[2];
   1486  1.114  christos 		    elem_count = name[3];
   1487  1.114  christos 		    if (elem_size != sizeof(pcb))
   1488  1.114  christos 			    return EINVAL;
   1489  1.114  christos 	} else {
   1490  1.114  christos 		    len = 0;
   1491  1.114  christos 		    elem_count = INT_MAX;
   1492  1.114  christos 		    elem_size = sizeof(pcb);
   1493  1.114  christos 	}
   1494   1.97    atatat 	error = 0;
   1495   1.97    atatat 	dp = oldp;
   1496  1.114  christos 	out_size = elem_size;
   1497   1.97    atatat 	needed = 0;
   1498   1.97    atatat 
   1499   1.97    atatat 	if (namelen == 1 && name[0] == CTL_QUERY)
   1500  1.105    atatat 		return (sysctl_query(SYSCTLFN_CALL(rnode)));
   1501   1.97    atatat 
   1502   1.97    atatat 	if (name - oname != 4)
   1503   1.97    atatat 		return (EINVAL);
   1504   1.97    atatat 
   1505   1.97    atatat 	pf = oname[1];
   1506   1.97    atatat 	proto = oname[2];
   1507  1.116  christos 	pf2 = (oldp != NULL) ? pf : 0;
   1508   1.97    atatat 
   1509  1.148      matt 	mutex_enter(softnet_lock);
   1510  1.148      matt 
   1511  1.169  christos 	TAILQ_FOREACH(inph, &pcbtbl->inpt_queue, inph_queue) {
   1512   1.99    atatat #ifdef INET
   1513  1.104  christos 		inp = (const struct inpcb *)inph;
   1514   1.99    atatat #endif
   1515   1.99    atatat #ifdef INET6
   1516  1.104  christos 		in6p = (const struct in6pcb *)inph;
   1517   1.99    atatat #endif
   1518   1.97    atatat 
   1519   1.99    atatat 		if (inph->inph_af != pf)
   1520   1.97    atatat 			continue;
   1521   1.97    atatat 
   1522  1.125      elad 		if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
   1523  1.125      elad 		    KAUTH_REQ_NETWORK_SOCKET_CANSEE, inph->inph_socket, NULL,
   1524  1.125      elad 		    NULL) != 0)
   1525  1.111      elad 			continue;
   1526  1.111      elad 
   1527   1.97    atatat 		memset(&pcb, 0, sizeof(pcb));
   1528   1.97    atatat 
   1529   1.97    atatat 		pcb.ki_family = pf;
   1530   1.97    atatat 		pcb.ki_type = proto;
   1531   1.97    atatat 
   1532   1.97    atatat 		switch (pf2) {
   1533   1.97    atatat 		case 0:
   1534   1.97    atatat 			/* just probing for size */
   1535   1.97    atatat 			break;
   1536   1.97    atatat #ifdef INET
   1537   1.97    atatat 		case PF_INET:
   1538   1.97    atatat 			pcb.ki_family = inp->inp_socket->so_proto->
   1539   1.97    atatat 			    pr_domain->dom_family;
   1540   1.97    atatat 			pcb.ki_type = inp->inp_socket->so_proto->
   1541   1.97    atatat 			    pr_type;
   1542   1.97    atatat 			pcb.ki_protocol = inp->inp_socket->so_proto->
   1543   1.97    atatat 			    pr_protocol;
   1544   1.97    atatat 			pcb.ki_pflags = inp->inp_flags;
   1545   1.97    atatat 
   1546   1.97    atatat 			pcb.ki_sostate = inp->inp_socket->so_state;
   1547   1.97    atatat 			pcb.ki_prstate = inp->inp_state;
   1548   1.97    atatat 			if (proto == IPPROTO_TCP) {
   1549   1.97    atatat 				tp = intotcpcb(inp);
   1550   1.97    atatat 				pcb.ki_tstate = tp->t_state;
   1551   1.97    atatat 				pcb.ki_tflags = tp->t_flags;
   1552   1.97    atatat 			}
   1553   1.97    atatat 
   1554   1.97    atatat 			pcb.ki_pcbaddr = PTRTOUINT64(inp);
   1555   1.97    atatat 			pcb.ki_ppcbaddr = PTRTOUINT64(inp->inp_ppcb);
   1556   1.97    atatat 			pcb.ki_sockaddr = PTRTOUINT64(inp->inp_socket);
   1557   1.97    atatat 
   1558   1.97    atatat 			pcb.ki_rcvq = inp->inp_socket->so_rcv.sb_cc;
   1559   1.97    atatat 			pcb.ki_sndq = inp->inp_socket->so_snd.sb_cc;
   1560   1.97    atatat 
   1561   1.97    atatat 			in = satosin(&pcb.ki_src);
   1562   1.97    atatat 			in->sin_len = sizeof(*in);
   1563   1.97    atatat 			in->sin_family = pf;
   1564   1.97    atatat 			in->sin_port = inp->inp_lport;
   1565   1.97    atatat 			in->sin_addr = inp->inp_laddr;
   1566   1.97    atatat 			if (pcb.ki_prstate >= INP_CONNECTED) {
   1567   1.97    atatat 				in = satosin(&pcb.ki_dst);
   1568   1.97    atatat 				in->sin_len = sizeof(*in);
   1569   1.97    atatat 				in->sin_family = pf;
   1570   1.97    atatat 				in->sin_port = inp->inp_fport;
   1571   1.97    atatat 				in->sin_addr = inp->inp_faddr;
   1572   1.97    atatat 			}
   1573   1.97    atatat 			break;
   1574   1.97    atatat #endif
   1575   1.97    atatat #ifdef INET6
   1576   1.97    atatat 		case PF_INET6:
   1577   1.97    atatat 			pcb.ki_family = in6p->in6p_socket->so_proto->
   1578   1.97    atatat 			    pr_domain->dom_family;
   1579   1.97    atatat 			pcb.ki_type = in6p->in6p_socket->so_proto->pr_type;
   1580   1.97    atatat 			pcb.ki_protocol = in6p->in6p_socket->so_proto->
   1581   1.97    atatat 			    pr_protocol;
   1582   1.97    atatat 			pcb.ki_pflags = in6p->in6p_flags;
   1583   1.97    atatat 
   1584   1.97    atatat 			pcb.ki_sostate = in6p->in6p_socket->so_state;
   1585   1.97    atatat 			pcb.ki_prstate = in6p->in6p_state;
   1586   1.97    atatat 			if (proto == IPPROTO_TCP) {
   1587   1.97    atatat 				tp = in6totcpcb(in6p);
   1588   1.97    atatat 				pcb.ki_tstate = tp->t_state;
   1589   1.97    atatat 				pcb.ki_tflags = tp->t_flags;
   1590   1.97    atatat 			}
   1591   1.97    atatat 
   1592   1.97    atatat 			pcb.ki_pcbaddr = PTRTOUINT64(in6p);
   1593   1.97    atatat 			pcb.ki_ppcbaddr = PTRTOUINT64(in6p->in6p_ppcb);
   1594   1.97    atatat 			pcb.ki_sockaddr = PTRTOUINT64(in6p->in6p_socket);
   1595   1.97    atatat 
   1596   1.97    atatat 			pcb.ki_rcvq = in6p->in6p_socket->so_rcv.sb_cc;
   1597   1.97    atatat 			pcb.ki_sndq = in6p->in6p_socket->so_snd.sb_cc;
   1598   1.97    atatat 
   1599   1.97    atatat 			in6 = satosin6(&pcb.ki_src);
   1600   1.97    atatat 			in6->sin6_len = sizeof(*in6);
   1601   1.97    atatat 			in6->sin6_family = pf;
   1602   1.97    atatat 			in6->sin6_port = in6p->in6p_lport;
   1603   1.97    atatat 			in6->sin6_flowinfo = in6p->in6p_flowinfo;
   1604   1.97    atatat 			in6->sin6_addr = in6p->in6p_laddr;
   1605   1.97    atatat 			in6->sin6_scope_id = 0; /* XXX? */
   1606   1.97    atatat 
   1607   1.97    atatat 			if (pcb.ki_prstate >= IN6P_CONNECTED) {
   1608   1.97    atatat 				in6 = satosin6(&pcb.ki_dst);
   1609   1.97    atatat 				in6->sin6_len = sizeof(*in6);
   1610   1.97    atatat 				in6->sin6_family = pf;
   1611   1.97    atatat 				in6->sin6_port = in6p->in6p_fport;
   1612   1.97    atatat 				in6->sin6_flowinfo = in6p->in6p_flowinfo;
   1613   1.97    atatat 				in6->sin6_addr = in6p->in6p_faddr;
   1614   1.97    atatat 				in6->sin6_scope_id = 0; /* XXX? */
   1615   1.97    atatat 			}
   1616   1.97    atatat 			break;
   1617   1.97    atatat #endif
   1618   1.97    atatat 		}
   1619   1.97    atatat 
   1620   1.97    atatat 		if (len >= elem_size && elem_count > 0) {
   1621   1.97    atatat 			error = copyout(&pcb, dp, out_size);
   1622  1.155     rmind 			if (error) {
   1623  1.155     rmind 				mutex_exit(softnet_lock);
   1624   1.97    atatat 				return (error);
   1625  1.155     rmind 			}
   1626   1.97    atatat 			dp += elem_size;
   1627   1.97    atatat 			len -= elem_size;
   1628   1.97    atatat 		}
   1629  1.152       mrg 		needed += elem_size;
   1630  1.152       mrg 		if (elem_count > 0 && elem_count != INT_MAX)
   1631  1.152       mrg 			elem_count--;
   1632   1.97    atatat 	}
   1633   1.97    atatat 
   1634   1.97    atatat 	*oldlenp = needed;
   1635   1.97    atatat 	if (oldp == NULL)
   1636   1.97    atatat 		*oldlenp += PCB_SLOP * sizeof(struct kinfo_pcb);
   1637   1.97    atatat 
   1638  1.148      matt 	mutex_exit(softnet_lock);
   1639  1.148      matt 
   1640   1.97    atatat 	return (error);
   1641   1.97    atatat }
   1642   1.97    atatat 
   1643  1.124    rpaulo static int
   1644  1.124    rpaulo sysctl_tcp_congctl(SYSCTLFN_ARGS)
   1645  1.124    rpaulo {
   1646  1.124    rpaulo 	struct sysctlnode node;
   1647  1.148      matt 	int error;
   1648  1.124    rpaulo 	char newname[TCPCC_MAXLEN];
   1649  1.124    rpaulo 
   1650  1.124    rpaulo 	strlcpy(newname, tcp_congctl_global_name, sizeof(newname) - 1);
   1651  1.124    rpaulo 
   1652  1.124    rpaulo 	node = *rnode;
   1653  1.124    rpaulo 	node.sysctl_data = newname;
   1654  1.124    rpaulo 	node.sysctl_size = sizeof(newname);
   1655  1.124    rpaulo 
   1656  1.124    rpaulo 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1657  1.124    rpaulo 
   1658  1.124    rpaulo 	if (error ||
   1659  1.124    rpaulo 	    newp == NULL ||
   1660  1.124    rpaulo 	    strncmp(newname, tcp_congctl_global_name, sizeof(newname)) == 0)
   1661  1.124    rpaulo 		return error;
   1662  1.124    rpaulo 
   1663  1.148      matt 	mutex_enter(softnet_lock);
   1664  1.148      matt 	error = tcp_congctl_select(NULL, newname);
   1665  1.148      matt 	mutex_exit(softnet_lock);
   1666  1.148      matt 
   1667  1.124    rpaulo 	return error;
   1668  1.124    rpaulo }
   1669  1.124    rpaulo 
   1670  1.132  christos static int
   1671  1.166  christos sysctl_tcp_init_win(SYSCTLFN_ARGS)
   1672  1.166  christos {
   1673  1.166  christos 	int error;
   1674  1.166  christos 	u_int iw;
   1675  1.166  christos 	struct sysctlnode node;
   1676  1.166  christos 
   1677  1.166  christos 	iw = *(u_int *)rnode->sysctl_data;
   1678  1.166  christos 	node = *rnode;
   1679  1.166  christos 	node.sysctl_data = &iw;
   1680  1.166  christos 	node.sysctl_size = sizeof(iw);
   1681  1.166  christos 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1682  1.166  christos 	if (error || newp == NULL)
   1683  1.166  christos 		return error;
   1684  1.166  christos 
   1685  1.166  christos 	if (iw >= __arraycount(tcp_init_win_max))
   1686  1.166  christos 		return EINVAL;
   1687  1.166  christos 	*(u_int *)rnode->sysctl_data = iw;
   1688  1.166  christos 	return 0;
   1689  1.166  christos }
   1690  1.166  christos 
   1691  1.166  christos static int
   1692  1.132  christos sysctl_tcp_keep(SYSCTLFN_ARGS)
   1693  1.132  christos {
   1694  1.132  christos 	int error;
   1695  1.132  christos 	u_int tmp;
   1696  1.132  christos 	struct sysctlnode node;
   1697  1.132  christos 
   1698  1.132  christos 	node = *rnode;
   1699  1.132  christos 	tmp = *(u_int *)rnode->sysctl_data;
   1700  1.132  christos 	node.sysctl_data = &tmp;
   1701  1.132  christos 
   1702  1.132  christos 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
   1703  1.132  christos 	if (error || newp == NULL)
   1704  1.132  christos 		return error;
   1705  1.132  christos 
   1706  1.148      matt 	mutex_enter(softnet_lock);
   1707  1.148      matt 
   1708  1.132  christos 	*(u_int *)rnode->sysctl_data = tmp;
   1709  1.132  christos 	tcp_tcpcb_template();	/* update the template */
   1710  1.148      matt 
   1711  1.148      matt 	mutex_exit(softnet_lock);
   1712  1.132  christos 	return 0;
   1713  1.132  christos }
   1714  1.132  christos 
   1715  1.142   thorpej static int
   1716  1.142   thorpej sysctl_net_inet_tcp_stats(SYSCTLFN_ARGS)
   1717  1.142   thorpej {
   1718  1.142   thorpej 
   1719  1.146   thorpej 	return (NETSTAT_SYSCTL(tcpstat_percpu, TCP_NSTATS));
   1720  1.142   thorpej }
   1721  1.132  christos 
   1722   1.97    atatat /*
   1723   1.86    atatat  * this (second stage) setup routine is a replacement for tcp_sysctl()
   1724   1.86    atatat  * (which is currently used for ipv4 and ipv6)
   1725   1.86    atatat  */
   1726   1.86    atatat static void
   1727   1.87    atatat sysctl_net_inet_tcp_setup2(struct sysctllog **clog, int pf, const char *pfname,
   1728   1.87    atatat 			   const char *tcpname)
   1729   1.86    atatat {
   1730  1.128    rpaulo 	const struct sysctlnode *sack_node;
   1731  1.127      yamt 	const struct sysctlnode *abc_node;
   1732  1.128    rpaulo 	const struct sysctlnode *ecn_node;
   1733  1.128    rpaulo 	const struct sysctlnode *congctl_node;
   1734  1.159    dyoung 	const struct sysctlnode *mslt_node;
   1735  1.159    dyoung 	const struct sysctlnode *vtw_node;
   1736  1.109    rpaulo #ifdef TCP_DEBUG
   1737  1.109    rpaulo 	extern struct tcp_debug tcp_debug[TCP_NDEBUG];
   1738  1.109    rpaulo 	extern int tcp_debx;
   1739  1.109    rpaulo #endif
   1740   1.76  christos 
   1741   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1742   1.87    atatat 		       CTLFLAG_PERMANENT,
   1743   1.86    atatat 		       CTLTYPE_NODE, pfname, NULL,
   1744   1.86    atatat 		       NULL, 0, NULL, 0,
   1745   1.86    atatat 		       CTL_NET, pf, CTL_EOL);
   1746   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1747   1.87    atatat 		       CTLFLAG_PERMANENT,
   1748   1.92    atatat 		       CTLTYPE_NODE, tcpname,
   1749   1.92    atatat 		       SYSCTL_DESCR("TCP related settings"),
   1750   1.86    atatat 		       NULL, 0, NULL, 0,
   1751   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, CTL_EOL);
   1752   1.86    atatat 
   1753   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1754   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1755   1.92    atatat 		       CTLTYPE_INT, "rfc1323",
   1756   1.92    atatat 		       SYSCTL_DESCR("Enable RFC1323 TCP extensions"),
   1757  1.170    kefren 		       sysctl_update_tcpcb_template, 0, &tcp_do_rfc1323, 0,
   1758   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_RFC1323, CTL_EOL);
   1759   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1760   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1761   1.92    atatat 		       CTLTYPE_INT, "sendspace",
   1762   1.92    atatat 		       SYSCTL_DESCR("Default TCP send buffer size"),
   1763   1.86    atatat 		       NULL, 0, &tcp_sendspace, 0,
   1764   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SENDSPACE, CTL_EOL);
   1765   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1766   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1767   1.92    atatat 		       CTLTYPE_INT, "recvspace",
   1768   1.92    atatat 		       SYSCTL_DESCR("Default TCP receive buffer size"),
   1769   1.86    atatat 		       NULL, 0, &tcp_recvspace, 0,
   1770   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_RECVSPACE, CTL_EOL);
   1771   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1772   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1773   1.92    atatat 		       CTLTYPE_INT, "mssdflt",
   1774   1.92    atatat 		       SYSCTL_DESCR("Default maximum segment size"),
   1775   1.86    atatat 		       sysctl_net_inet_tcp_mssdflt, 0, &tcp_mssdflt, 0,
   1776   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSSDFLT, CTL_EOL);
   1777   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1778   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1779  1.136     rmind 		       CTLTYPE_INT, "minmss",
   1780  1.136     rmind 		       SYSCTL_DESCR("Lower limit for TCP maximum segment size"),
   1781  1.136     rmind 		       NULL, 0, &tcp_minmss, 0,
   1782  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1783  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   1784  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1785  1.156    darran 		       CTLTYPE_INT, "msl",
   1786  1.156    darran 		       SYSCTL_DESCR("Maximum Segment Life"),
   1787  1.156    darran 		       NULL, 0, &tcp_msl, 0,
   1788  1.156    darran 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSL, CTL_EOL);
   1789  1.156    darran 	sysctl_createv(clog, 0, NULL, NULL,
   1790  1.156    darran 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1791   1.92    atatat 		       CTLTYPE_INT, "syn_cache_limit",
   1792   1.92    atatat 		       SYSCTL_DESCR("Maximum number of entries in the TCP "
   1793   1.92    atatat 				    "compressed state engine"),
   1794   1.86    atatat 		       NULL, 0, &tcp_syn_cache_limit, 0,
   1795   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_CACHE_LIMIT,
   1796   1.86    atatat 		       CTL_EOL);
   1797   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1798   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1799   1.92    atatat 		       CTLTYPE_INT, "syn_bucket_limit",
   1800   1.92    atatat 		       SYSCTL_DESCR("Maximum number of entries per hash "
   1801   1.92    atatat 				    "bucket in the TCP compressed state "
   1802   1.92    atatat 				    "engine"),
   1803   1.86    atatat 		       NULL, 0, &tcp_syn_bucket_limit, 0,
   1804   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_BUCKET_LIMIT,
   1805   1.86    atatat 		       CTL_EOL);
   1806   1.86    atatat #if 0 /* obsoleted */
   1807   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1808   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1809   1.92    atatat 		       CTLTYPE_INT, "syn_cache_interval",
   1810   1.92    atatat 		       SYSCTL_DESCR("TCP compressed state engine's timer interval"),
   1811   1.86    atatat 		       NULL, 0, &tcp_syn_cache_interval, 0,
   1812   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SYN_CACHE_INTER,
   1813   1.86    atatat 		       CTL_EOL);
   1814   1.86    atatat #endif
   1815   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1816   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1817   1.92    atatat 		       CTLTYPE_INT, "init_win",
   1818   1.92    atatat 		       SYSCTL_DESCR("Initial TCP congestion window"),
   1819  1.166  christos 		       sysctl_tcp_init_win, 0, &tcp_init_win, 0,
   1820   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_INIT_WIN, CTL_EOL);
   1821   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1822   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1823   1.92    atatat 		       CTLTYPE_INT, "mss_ifmtu",
   1824   1.92    atatat 		       SYSCTL_DESCR("Use interface MTU for calculating MSS"),
   1825   1.86    atatat 		       NULL, 0, &tcp_mss_ifmtu, 0,
   1826   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_MSS_IFMTU, CTL_EOL);
   1827  1.102  kurahone 	sysctl_createv(clog, 0, NULL, &sack_node,
   1828  1.102  kurahone 		       CTLFLAG_PERMANENT,
   1829  1.102  kurahone 		       CTLTYPE_NODE, "sack",
   1830  1.102  kurahone 		       SYSCTL_DESCR("RFC2018 Selective ACKnowledgement tunables"),
   1831  1.102  kurahone 		       NULL, 0, NULL, 0,
   1832   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_EOL);
   1833  1.128    rpaulo 
   1834  1.128    rpaulo 	/* Congctl subtree */
   1835  1.128    rpaulo 	sysctl_createv(clog, 0, NULL, &congctl_node,
   1836  1.124    rpaulo 		       CTLFLAG_PERMANENT,
   1837  1.124    rpaulo 		       CTLTYPE_NODE, "congctl",
   1838  1.124    rpaulo 		       SYSCTL_DESCR("TCP Congestion Control"),
   1839  1.128    rpaulo 	    	       NULL, 0, NULL, 0,
   1840  1.124    rpaulo 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1841  1.128    rpaulo 	sysctl_createv(clog, 0, &congctl_node, NULL,
   1842  1.124    rpaulo 		       CTLFLAG_PERMANENT,
   1843  1.124    rpaulo 		       CTLTYPE_STRING, "available",
   1844  1.124    rpaulo 		       SYSCTL_DESCR("Available Congestion Control Mechanisms"),
   1845  1.165       dsl 		       NULL, 0, tcp_congctl_avail, 0, CTL_CREATE, CTL_EOL);
   1846  1.128    rpaulo 	sysctl_createv(clog, 0, &congctl_node, NULL,
   1847  1.124    rpaulo 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1848  1.124    rpaulo 		       CTLTYPE_STRING, "selected",
   1849  1.124    rpaulo 		       SYSCTL_DESCR("Selected Congestion Control Mechanism"),
   1850  1.124    rpaulo 		       sysctl_tcp_congctl, 0, NULL, TCPCC_MAXLEN,
   1851  1.124    rpaulo 		       CTL_CREATE, CTL_EOL);
   1852  1.124    rpaulo 
   1853   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1854   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1855   1.92    atatat 		       CTLTYPE_INT, "win_scale",
   1856   1.92    atatat 		       SYSCTL_DESCR("Use RFC1323 window scale options"),
   1857  1.170    kefren 		       sysctl_update_tcpcb_template, 0, &tcp_do_win_scale, 0,
   1858   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_WSCALE, CTL_EOL);
   1859   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1860   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1861   1.92    atatat 		       CTLTYPE_INT, "timestamps",
   1862   1.92    atatat 		       SYSCTL_DESCR("Use RFC1323 time stamp options"),
   1863  1.170    kefren 		       sysctl_update_tcpcb_template, 0, &tcp_do_timestamps, 0,
   1864   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_TSTAMP, CTL_EOL);
   1865   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1866   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1867   1.92    atatat 		       CTLTYPE_INT, "compat_42",
   1868   1.92    atatat 		       SYSCTL_DESCR("Enable workarounds for 4.2BSD TCP bugs"),
   1869   1.86    atatat 		       NULL, 0, &tcp_compat_42, 0,
   1870   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_COMPAT_42, CTL_EOL);
   1871   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1872   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1873   1.92    atatat 		       CTLTYPE_INT, "cwm",
   1874   1.92    atatat 		       SYSCTL_DESCR("Hughes/Touch/Heidemann Congestion Window "
   1875   1.92    atatat 				    "Monitoring"),
   1876   1.86    atatat 		       NULL, 0, &tcp_cwm, 0,
   1877   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_CWM, CTL_EOL);
   1878   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1879   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1880   1.92    atatat 		       CTLTYPE_INT, "cwm_burstsize",
   1881   1.92    atatat 		       SYSCTL_DESCR("Congestion Window Monitoring allowed "
   1882   1.92    atatat 				    "burst count in packets"),
   1883   1.86    atatat 		       NULL, 0, &tcp_cwm_burstsize, 0,
   1884   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_CWM_BURSTSIZE,
   1885   1.86    atatat 		       CTL_EOL);
   1886   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1887   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1888   1.92    atatat 		       CTLTYPE_INT, "ack_on_push",
   1889   1.92    atatat 		       SYSCTL_DESCR("Immediately return ACK when PSH is "
   1890   1.92    atatat 				    "received"),
   1891   1.86    atatat 		       NULL, 0, &tcp_ack_on_push, 0,
   1892   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_ACK_ON_PUSH, CTL_EOL);
   1893   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1894   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1895   1.92    atatat 		       CTLTYPE_INT, "keepidle",
   1896   1.92    atatat 		       SYSCTL_DESCR("Allowed connection idle ticks before a "
   1897   1.92    atatat 				    "keepalive probe is sent"),
   1898  1.132  christos 		       sysctl_tcp_keep, 0, &tcp_keepidle, 0,
   1899   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPIDLE, CTL_EOL);
   1900   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1901   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1902   1.92    atatat 		       CTLTYPE_INT, "keepintvl",
   1903   1.92    atatat 		       SYSCTL_DESCR("Ticks before next keepalive probe is sent"),
   1904  1.132  christos 		       sysctl_tcp_keep, 0, &tcp_keepintvl, 0,
   1905   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPINTVL, CTL_EOL);
   1906   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1907   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1908   1.92    atatat 		       CTLTYPE_INT, "keepcnt",
   1909   1.92    atatat 		       SYSCTL_DESCR("Number of keepalive probes to send"),
   1910  1.132  christos 		       sysctl_tcp_keep, 0, &tcp_keepcnt, 0,
   1911   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_KEEPCNT, CTL_EOL);
   1912   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1913   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_IMMEDIATE,
   1914   1.92    atatat 		       CTLTYPE_INT, "slowhz",
   1915   1.92    atatat 		       SYSCTL_DESCR("Keepalive ticks per second"),
   1916   1.86    atatat 		       NULL, PR_SLOWHZ, NULL, 0,
   1917   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SLOWHZ, CTL_EOL);
   1918   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1919   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1920   1.92    atatat 		       CTLTYPE_INT, "log_refused",
   1921   1.92    atatat 		       SYSCTL_DESCR("Log refused TCP connections"),
   1922   1.86    atatat 		       NULL, 0, &tcp_log_refused, 0,
   1923   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_LOG_REFUSED, CTL_EOL);
   1924   1.86    atatat #if 0 /* obsoleted */
   1925   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1926   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1927   1.86    atatat 		       CTLTYPE_INT, "rstratelimit", NULL,
   1928   1.86    atatat 		       NULL, 0, &tcp_rst_ratelim, 0,
   1929   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_RSTRATELIMIT, CTL_EOL);
   1930   1.86    atatat #endif
   1931   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1932   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1933   1.92    atatat 		       CTLTYPE_INT, "rstppslimit",
   1934   1.92    atatat 		       SYSCTL_DESCR("Maximum number of RST packets to send "
   1935   1.92    atatat 				    "per second"),
   1936   1.86    atatat 		       NULL, 0, &tcp_rst_ppslim, 0,
   1937   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_RSTPPSLIMIT, CTL_EOL);
   1938   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1939   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1940   1.92    atatat 		       CTLTYPE_INT, "delack_ticks",
   1941   1.92    atatat 		       SYSCTL_DESCR("Number of ticks to delay sending an ACK"),
   1942   1.86    atatat 		       NULL, 0, &tcp_delack_ticks, 0,
   1943   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_DELACK_TICKS, CTL_EOL);
   1944   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1945   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1946   1.92    atatat 		       CTLTYPE_INT, "init_win_local",
   1947   1.92    atatat 		       SYSCTL_DESCR("Initial TCP window size (in segments)"),
   1948  1.166  christos 		       sysctl_tcp_init_win, 0, &tcp_init_win_local, 0,
   1949   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_INIT_WIN_LOCAL,
   1950   1.86    atatat 		       CTL_EOL);
   1951   1.87    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1952   1.87    atatat 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1953   1.92    atatat 		       CTLTYPE_STRUCT, "ident",
   1954   1.92    atatat 		       SYSCTL_DESCR("RFC1413 Identification Protocol lookups"),
   1955   1.86    atatat 		       sysctl_net_inet_tcp_ident, 0, NULL, sizeof(uid_t),
   1956   1.86    atatat 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_IDENT, CTL_EOL);
   1957   1.93   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
   1958   1.93   thorpej 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1959   1.93   thorpej 		       CTLTYPE_INT, "do_loopback_cksum",
   1960   1.93   thorpej 		       SYSCTL_DESCR("Perform TCP checksum on loopback"),
   1961   1.93   thorpej 		       NULL, 0, &tcp_do_loopback_cksum, 0,
   1962   1.93   thorpej 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_LOOPBACKCKSUM,
   1963   1.93   thorpej 		       CTL_EOL);
   1964   1.97    atatat 	sysctl_createv(clog, 0, NULL, NULL,
   1965   1.97    atatat 		       CTLFLAG_PERMANENT,
   1966  1.100    atatat 		       CTLTYPE_STRUCT, "pcblist",
   1967   1.97    atatat 		       SYSCTL_DESCR("TCP protocol control block list"),
   1968   1.97    atatat 		       sysctl_inpcblist, 0, &tcbtable, 0,
   1969   1.97    atatat 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE,
   1970   1.97    atatat 		       CTL_EOL);
   1971  1.132  christos 	sysctl_createv(clog, 0, NULL, NULL,
   1972  1.132  christos 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1973  1.132  christos 		       CTLTYPE_INT, "keepinit",
   1974  1.132  christos 		       SYSCTL_DESCR("Ticks before initial tcp connection times out"),
   1975  1.132  christos 		       sysctl_tcp_keep, 0, &tcp_keepinit, 0,
   1976  1.132  christos 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1977  1.102  kurahone 
   1978  1.136     rmind 	/* TCP socket buffers auto-sizing nodes */
   1979  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   1980  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1981  1.136     rmind 		       CTLTYPE_INT, "recvbuf_auto",
   1982  1.136     rmind 		       SYSCTL_DESCR("Enable automatic receive "
   1983  1.136     rmind 		           "buffer sizing (experimental)"),
   1984  1.136     rmind 		       NULL, 0, &tcp_do_autorcvbuf, 0,
   1985  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1986  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   1987  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1988  1.136     rmind 		       CTLTYPE_INT, "recvbuf_inc",
   1989  1.136     rmind 		       SYSCTL_DESCR("Incrementor step size of "
   1990  1.136     rmind 		           "automatic receive buffer"),
   1991  1.136     rmind 		       NULL, 0, &tcp_autorcvbuf_inc, 0,
   1992  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1993  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   1994  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   1995  1.136     rmind 		       CTLTYPE_INT, "recvbuf_max",
   1996  1.136     rmind 		       SYSCTL_DESCR("Max size of automatic receive buffer"),
   1997  1.136     rmind 		       NULL, 0, &tcp_autorcvbuf_max, 0,
   1998  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   1999  1.136     rmind 
   2000  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   2001  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2002  1.136     rmind 		       CTLTYPE_INT, "sendbuf_auto",
   2003  1.136     rmind 		       SYSCTL_DESCR("Enable automatic send "
   2004  1.136     rmind 		           "buffer sizing (experimental)"),
   2005  1.136     rmind 		       NULL, 0, &tcp_do_autosndbuf, 0,
   2006  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2007  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   2008  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2009  1.136     rmind 		       CTLTYPE_INT, "sendbuf_inc",
   2010  1.136     rmind 		       SYSCTL_DESCR("Incrementor step size of "
   2011  1.136     rmind 		           "automatic send buffer"),
   2012  1.136     rmind 		       NULL, 0, &tcp_autosndbuf_inc, 0,
   2013  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2014  1.136     rmind 	sysctl_createv(clog, 0, NULL, NULL,
   2015  1.136     rmind 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2016  1.136     rmind 		       CTLTYPE_INT, "sendbuf_max",
   2017  1.136     rmind 		       SYSCTL_DESCR("Max size of automatic send buffer"),
   2018  1.136     rmind 		       NULL, 0, &tcp_autosndbuf_max, 0,
   2019  1.136     rmind 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2020  1.136     rmind 
   2021  1.128    rpaulo 	/* ECN subtree */
   2022  1.128    rpaulo 	sysctl_createv(clog, 0, NULL, &ecn_node,
   2023  1.128    rpaulo 	    	       CTLFLAG_PERMANENT,
   2024  1.128    rpaulo 		       CTLTYPE_NODE, "ecn",
   2025  1.128    rpaulo 	    	       SYSCTL_DESCR("RFC3168 Explicit Congestion Notification"),
   2026  1.128    rpaulo 	    	       NULL, 0, NULL, 0,
   2027  1.128    rpaulo 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2028  1.128    rpaulo 	sysctl_createv(clog, 0, &ecn_node, NULL,
   2029  1.120    rpaulo 	    	       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2030  1.120    rpaulo 		       CTLTYPE_INT, "enable",
   2031  1.120    rpaulo 		       SYSCTL_DESCR("Enable TCP Explicit Congestion "
   2032  1.120    rpaulo 			   "Notification"),
   2033  1.128    rpaulo 	    	       NULL, 0, &tcp_do_ecn, 0, CTL_CREATE, CTL_EOL);
   2034  1.128    rpaulo 	sysctl_createv(clog, 0, &ecn_node, NULL,
   2035  1.120    rpaulo 	    	       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2036  1.120    rpaulo 		       CTLTYPE_INT, "maxretries",
   2037  1.120    rpaulo 		       SYSCTL_DESCR("Number of times to retry ECN setup "
   2038  1.120    rpaulo 			       "before disabling ECN on the connection"),
   2039  1.128    rpaulo 	    	       NULL, 0, &tcp_ecn_maxretries, 0, CTL_CREATE, CTL_EOL);
   2040  1.128    rpaulo 
   2041  1.102  kurahone 	/* SACK gets it's own little subtree. */
   2042  1.102  kurahone 	sysctl_createv(clog, 0, NULL, &sack_node,
   2043  1.102  kurahone 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2044  1.102  kurahone 		       CTLTYPE_INT, "enable",
   2045  1.102  kurahone 		       SYSCTL_DESCR("Enable RFC2018 Selective ACKnowledgement"),
   2046  1.102  kurahone 		       NULL, 0, &tcp_do_sack, 0,
   2047  1.102  kurahone 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
   2048  1.102  kurahone 	sysctl_createv(clog, 0, NULL, &sack_node,
   2049  1.102  kurahone 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2050  1.102  kurahone 		       CTLTYPE_INT, "maxholes",
   2051  1.102  kurahone 		       SYSCTL_DESCR("Maximum number of TCP SACK holes allowed per connection"),
   2052  1.102  kurahone 		       NULL, 0, &tcp_sack_tp_maxholes, 0,
   2053  1.102  kurahone 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
   2054  1.102  kurahone 	sysctl_createv(clog, 0, NULL, &sack_node,
   2055  1.102  kurahone 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2056  1.102  kurahone 		       CTLTYPE_INT, "globalmaxholes",
   2057  1.102  kurahone 		       SYSCTL_DESCR("Global maximum number of TCP SACK holes"),
   2058  1.102  kurahone 		       NULL, 0, &tcp_sack_globalmaxholes, 0,
   2059  1.102  kurahone 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
   2060  1.102  kurahone 	sysctl_createv(clog, 0, NULL, &sack_node,
   2061  1.102  kurahone 		       CTLFLAG_PERMANENT,
   2062  1.102  kurahone 		       CTLTYPE_INT, "globalholes",
   2063  1.102  kurahone 		       SYSCTL_DESCR("Global number of TCP SACK holes"),
   2064  1.102  kurahone 		       NULL, 0, &tcp_sack_globalholes, 0,
   2065  1.102  kurahone 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_SACK, CTL_CREATE, CTL_EOL);
   2066  1.107      elad 
   2067  1.107      elad 	sysctl_createv(clog, 0, NULL, NULL,
   2068  1.107      elad 		       CTLFLAG_PERMANENT,
   2069  1.107      elad 		       CTLTYPE_STRUCT, "stats",
   2070  1.107      elad 		       SYSCTL_DESCR("TCP statistics"),
   2071  1.142   thorpej 		       sysctl_net_inet_tcp_stats, 0, NULL, 0,
   2072  1.107      elad 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_STATS,
   2073  1.107      elad 		       CTL_EOL);
   2074  1.159    dyoung         sysctl_createv(clog, 0, NULL, NULL,
   2075  1.159    dyoung                        CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2076  1.159    dyoung                        CTLTYPE_INT, "local_by_rtt",
   2077  1.159    dyoung                        SYSCTL_DESCR("Use RTT estimator to decide which hosts "
   2078  1.159    dyoung 				    "are local"),
   2079  1.159    dyoung 		       NULL, 0, &tcp_rttlocal, 0,
   2080  1.159    dyoung 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2081  1.109    rpaulo #ifdef TCP_DEBUG
   2082  1.109    rpaulo 	sysctl_createv(clog, 0, NULL, NULL,
   2083  1.109    rpaulo 		       CTLFLAG_PERMANENT,
   2084  1.109    rpaulo 		       CTLTYPE_STRUCT, "debug",
   2085  1.109    rpaulo 		       SYSCTL_DESCR("TCP sockets debug information"),
   2086  1.109    rpaulo 		       NULL, 0, &tcp_debug, sizeof(tcp_debug),
   2087  1.109    rpaulo 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_DEBUG,
   2088  1.109    rpaulo 		       CTL_EOL);
   2089  1.109    rpaulo 	sysctl_createv(clog, 0, NULL, NULL,
   2090  1.109    rpaulo 		       CTLFLAG_PERMANENT,
   2091  1.109    rpaulo 		       CTLTYPE_INT, "debx",
   2092  1.110    rpaulo 		       SYSCTL_DESCR("Number of TCP debug sockets messages"),
   2093  1.109    rpaulo 		       NULL, 0, &tcp_debx, sizeof(tcp_debx),
   2094  1.109    rpaulo 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_DEBX,
   2095  1.109    rpaulo 		       CTL_EOL);
   2096  1.109    rpaulo #endif
   2097  1.133  christos 	sysctl_createv(clog, 0, NULL, NULL,
   2098  1.133  christos 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2099  1.133  christos 		       CTLTYPE_STRUCT, "drop",
   2100  1.133  christos 		       SYSCTL_DESCR("TCP drop connection"),
   2101  1.133  christos 		       sysctl_net_inet_tcp_drop, 0, NULL, 0,
   2102  1.133  christos 		       CTL_NET, pf, IPPROTO_TCP, TCPCTL_DROP, CTL_EOL);
   2103  1.126    rpaulo 	sysctl_createv(clog, 0, NULL, NULL,
   2104  1.126    rpaulo 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2105  1.126    rpaulo 		       CTLTYPE_INT, "iss_hash",
   2106  1.126    rpaulo 		       SYSCTL_DESCR("Enable RFC 1948 ISS by cryptographic "
   2107  1.126    rpaulo 				    "hash computation"),
   2108  1.126    rpaulo 		       NULL, 0, &tcp_do_rfc1948, sizeof(tcp_do_rfc1948),
   2109  1.126    rpaulo 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE,
   2110  1.126    rpaulo 		       CTL_EOL);
   2111  1.109    rpaulo 
   2112  1.127      yamt 	/* ABC subtree */
   2113  1.127      yamt 
   2114  1.127      yamt 	sysctl_createv(clog, 0, NULL, &abc_node,
   2115  1.127      yamt 		       CTLFLAG_PERMANENT, CTLTYPE_NODE, "abc",
   2116  1.127      yamt 		       SYSCTL_DESCR("RFC3465 Appropriate Byte Counting (ABC)"),
   2117  1.127      yamt 		       NULL, 0, NULL, 0,
   2118  1.127      yamt 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2119  1.127      yamt 	sysctl_createv(clog, 0, &abc_node, NULL,
   2120  1.127      yamt 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2121  1.127      yamt 		       CTLTYPE_INT, "enable",
   2122  1.127      yamt 		       SYSCTL_DESCR("Enable RFC3465 Appropriate Byte Counting"),
   2123  1.127      yamt 		       NULL, 0, &tcp_do_abc, 0, CTL_CREATE, CTL_EOL);
   2124  1.127      yamt 	sysctl_createv(clog, 0, &abc_node, NULL,
   2125  1.127      yamt 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2126  1.127      yamt 		       CTLTYPE_INT, "aggressive",
   2127  1.127      yamt 		       SYSCTL_DESCR("1: L=2*SMSS 0: L=1*SMSS"),
   2128  1.127      yamt 		       NULL, 0, &tcp_abc_aggressive, 0, CTL_CREATE, CTL_EOL);
   2129  1.159    dyoung 
   2130  1.159    dyoung 	/* MSL tuning subtree */
   2131  1.159    dyoung 
   2132  1.159    dyoung 	sysctl_createv(clog, 0, NULL, &mslt_node,
   2133  1.159    dyoung 		       CTLFLAG_PERMANENT, CTLTYPE_NODE, "mslt",
   2134  1.159    dyoung 		       SYSCTL_DESCR("MSL Tuning for TIME_WAIT truncation"),
   2135  1.159    dyoung 		       NULL, 0, NULL, 0,
   2136  1.159    dyoung 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2137  1.159    dyoung 	sysctl_createv(clog, 0, &mslt_node, NULL,
   2138  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2139  1.159    dyoung 		       CTLTYPE_INT, "enable",
   2140  1.159    dyoung 		       SYSCTL_DESCR("Enable TIME_WAIT truncation"),
   2141  1.159    dyoung 		       NULL, 0, &tcp_msl_enable, 0, CTL_CREATE, CTL_EOL);
   2142  1.159    dyoung 	sysctl_createv(clog, 0, &mslt_node, NULL,
   2143  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2144  1.159    dyoung 		       CTLTYPE_INT, "loopback",
   2145  1.159    dyoung 		       SYSCTL_DESCR("MSL value to use for loopback connections"),
   2146  1.159    dyoung 		       NULL, 0, &tcp_msl_loop, 0, CTL_CREATE, CTL_EOL);
   2147  1.159    dyoung 	sysctl_createv(clog, 0, &mslt_node, NULL,
   2148  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2149  1.159    dyoung 		       CTLTYPE_INT, "local",
   2150  1.159    dyoung 		       SYSCTL_DESCR("MSL value to use for local connections"),
   2151  1.159    dyoung 		       NULL, 0, &tcp_msl_local, 0, CTL_CREATE, CTL_EOL);
   2152  1.159    dyoung 	sysctl_createv(clog, 0, &mslt_node, NULL,
   2153  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2154  1.159    dyoung 		       CTLTYPE_INT, "remote",
   2155  1.159    dyoung 		       SYSCTL_DESCR("MSL value to use for remote connections"),
   2156  1.159    dyoung 		       NULL, 0, &tcp_msl_remote, 0, CTL_CREATE, CTL_EOL);
   2157  1.159    dyoung 	sysctl_createv(clog, 0, &mslt_node, NULL,
   2158  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2159  1.159    dyoung 		       CTLTYPE_INT, "remote_threshold",
   2160  1.159    dyoung 		       SYSCTL_DESCR("RTT estimate value to promote local to remote"),
   2161  1.159    dyoung 		       NULL, 0, &tcp_msl_remote_threshold, 0, CTL_CREATE, CTL_EOL);
   2162  1.159    dyoung 
   2163  1.159    dyoung 	/* vestigial TIME_WAIT tuning subtree */
   2164  1.159    dyoung 
   2165  1.159    dyoung 	sysctl_createv(clog, 0, NULL, &vtw_node,
   2166  1.159    dyoung 		       CTLFLAG_PERMANENT, CTLTYPE_NODE, "vtw",
   2167  1.159    dyoung 		       SYSCTL_DESCR("Tuning for Vestigial TIME_WAIT"),
   2168  1.159    dyoung 		       NULL, 0, NULL, 0,
   2169  1.159    dyoung 		       CTL_NET, pf, IPPROTO_TCP, CTL_CREATE, CTL_EOL);
   2170  1.159    dyoung 	sysctl_createv(clog, 0, &vtw_node, NULL,
   2171  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READWRITE,
   2172  1.159    dyoung 		       CTLTYPE_INT, "enable",
   2173  1.159    dyoung 		       SYSCTL_DESCR("Enable Vestigial TIME_WAIT"),
   2174  1.160    dyoung 		       sysctl_tcp_vtw_enable, 0,
   2175  1.159    dyoung 	               (pf == AF_INET) ? &tcp4_vtw_enable : &tcp6_vtw_enable,
   2176  1.159    dyoung 		       0, CTL_CREATE, CTL_EOL);
   2177  1.159    dyoung 	sysctl_createv(clog, 0, &vtw_node, NULL,
   2178  1.159    dyoung 		       CTLFLAG_PERMANENT|CTLFLAG_READONLY,
   2179  1.159    dyoung 		       CTLTYPE_INT, "entries",
   2180  1.159    dyoung 		       SYSCTL_DESCR("Maximum number of vestigial TIME_WAIT entries"),
   2181  1.159    dyoung 		       NULL, 0, &tcp_vtw_entries, 0, CTL_CREATE, CTL_EOL);
   2182   1.86    atatat }
   2183   1.86    atatat 
   2184  1.157     pooka void
   2185  1.157     pooka tcp_usrreq_init(void)
   2186   1.76  christos {
   2187   1.76  christos 
   2188  1.157     pooka #ifdef INET
   2189  1.157     pooka 	sysctl_net_inet_tcp_setup2(NULL, PF_INET, "inet", "tcp");
   2190  1.157     pooka #endif
   2191   1.86    atatat #ifdef INET6
   2192  1.157     pooka 	sysctl_net_inet_tcp_setup2(NULL, PF_INET6, "inet6", "tcp6");
   2193  1.157     pooka #endif
   2194    1.1       cgd }
   2195  1.172     rmind 
   2196  1.172     rmind PR_WRAP_USRREQ(tcp_usrreq)
   2197  1.172     rmind 
   2198  1.172     rmind #define	tcp_usrreq	tcp_usrreq_wrapper
   2199  1.172     rmind 
   2200  1.172     rmind const struct pr_usrreqs tcp_usrreqs = {
   2201  1.173     rmind 	.pr_attach	= tcp_attach,
   2202  1.173     rmind 	.pr_detach	= tcp_detach,
   2203  1.172     rmind 	.pr_generic	= tcp_usrreq,
   2204  1.172     rmind };
   2205