Home | History | Annotate | Line # | Download | only in netinet
tcp_timer.c revision 1.91
      1  1.91  knakahar /*	$NetBSD: tcp_timer.c,v 1.91 2016/07/25 00:10:38 knakahara Exp $	*/
      2  1.44    itojun 
      3  1.44    itojun /*
      4  1.44    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
      5  1.44    itojun  * All rights reserved.
      6  1.59    itojun  *
      7  1.44    itojun  * Redistribution and use in source and binary forms, with or without
      8  1.44    itojun  * modification, are permitted provided that the following conditions
      9  1.44    itojun  * are met:
     10  1.44    itojun  * 1. Redistributions of source code must retain the above copyright
     11  1.44    itojun  *    notice, this list of conditions and the following disclaimer.
     12  1.44    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     13  1.44    itojun  *    notice, this list of conditions and the following disclaimer in the
     14  1.44    itojun  *    documentation and/or other materials provided with the distribution.
     15  1.44    itojun  * 3. Neither the name of the project nor the names of its contributors
     16  1.44    itojun  *    may be used to endorse or promote products derived from this software
     17  1.44    itojun  *    without specific prior written permission.
     18  1.59    itojun  *
     19  1.44    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     20  1.44    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21  1.44    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22  1.44    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     23  1.44    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24  1.44    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25  1.44    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26  1.44    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27  1.44    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28  1.44    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29  1.44    itojun  * SUCH DAMAGE.
     30  1.44    itojun  */
     31  1.30   thorpej 
     32  1.30   thorpej /*-
     33  1.71   mycroft  * Copyright (c) 1997, 1998, 2001, 2005 The NetBSD Foundation, Inc.
     34  1.30   thorpej  * All rights reserved.
     35  1.30   thorpej  *
     36  1.30   thorpej  * This code is derived from software contributed to The NetBSD Foundation
     37  1.30   thorpej  * by Jason R. Thorpe and Kevin M. Lahey of the Numerical Aerospace Simulation
     38  1.30   thorpej  * Facility, NASA Ames Research Center.
     39  1.71   mycroft  * This code is derived from software contributed to The NetBSD Foundation
     40  1.71   mycroft  * by Charles M. Hannum.
     41  1.30   thorpej  *
     42  1.30   thorpej  * Redistribution and use in source and binary forms, with or without
     43  1.30   thorpej  * modification, are permitted provided that the following conditions
     44  1.30   thorpej  * are met:
     45  1.30   thorpej  * 1. Redistributions of source code must retain the above copyright
     46  1.30   thorpej  *    notice, this list of conditions and the following disclaimer.
     47  1.30   thorpej  * 2. Redistributions in binary form must reproduce the above copyright
     48  1.30   thorpej  *    notice, this list of conditions and the following disclaimer in the
     49  1.30   thorpej  *    documentation and/or other materials provided with the distribution.
     50  1.30   thorpej  *
     51  1.30   thorpej  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     52  1.30   thorpej  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     53  1.30   thorpej  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     54  1.30   thorpej  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     55  1.30   thorpej  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     56  1.30   thorpej  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     57  1.30   thorpej  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     58  1.30   thorpej  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     59  1.30   thorpej  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     60  1.30   thorpej  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     61  1.30   thorpej  * POSSIBILITY OF SUCH DAMAGE.
     62  1.30   thorpej  */
     63   1.8       cgd 
     64   1.1       cgd /*
     65  1.28   thorpej  * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995
     66   1.7   mycroft  *	The Regents of the University of California.  All rights reserved.
     67   1.1       cgd  *
     68   1.1       cgd  * Redistribution and use in source and binary forms, with or without
     69   1.1       cgd  * modification, are permitted provided that the following conditions
     70   1.1       cgd  * are met:
     71   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     72   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     73   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     74   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     75   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     76  1.64       agc  * 3. Neither the name of the University nor the names of its contributors
     77   1.1       cgd  *    may be used to endorse or promote products derived from this software
     78   1.1       cgd  *    without specific prior written permission.
     79   1.1       cgd  *
     80   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     81   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     82   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     83   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     84   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     85   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     86   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     87   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     88   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     89   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     90   1.1       cgd  * SUCH DAMAGE.
     91   1.1       cgd  *
     92  1.28   thorpej  *	@(#)tcp_timer.c	8.2 (Berkeley) 5/24/95
     93   1.1       cgd  */
     94  1.57     lukem 
     95  1.57     lukem #include <sys/cdefs.h>
     96  1.91  knakahar __KERNEL_RCSID(0, "$NetBSD: tcp_timer.c,v 1.91 2016/07/25 00:10:38 knakahara Exp $");
     97  1.29    scottr 
     98  1.89     pooka #ifdef _KERNEL_OPT
     99  1.44    itojun #include "opt_inet.h"
    100  1.51   thorpej #include "opt_tcp_debug.h"
    101  1.89     pooka #endif
    102  1.44    itojun 
    103   1.4   mycroft #include <sys/param.h>
    104   1.4   mycroft #include <sys/systm.h>
    105   1.4   mycroft #include <sys/mbuf.h>
    106   1.4   mycroft #include <sys/socket.h>
    107   1.4   mycroft #include <sys/socketvar.h>
    108   1.4   mycroft #include <sys/protosw.h>
    109   1.4   mycroft #include <sys/errno.h>
    110  1.49   thorpej #include <sys/kernel.h>
    111   1.1       cgd 
    112   1.4   mycroft #include <net/if.h>
    113   1.1       cgd 
    114   1.4   mycroft #include <netinet/in.h>
    115   1.4   mycroft #include <netinet/in_systm.h>
    116   1.4   mycroft #include <netinet/ip.h>
    117   1.4   mycroft #include <netinet/in_pcb.h>
    118   1.4   mycroft #include <netinet/ip_var.h>
    119  1.72  christos #include <netinet/ip_icmp.h>
    120  1.44    itojun 
    121  1.44    itojun #ifdef INET6
    122  1.44    itojun #ifndef INET
    123  1.44    itojun #include <netinet/in.h>
    124  1.44    itojun #endif
    125  1.44    itojun #include <netinet/ip6.h>
    126  1.44    itojun #include <netinet6/in6_pcb.h>
    127  1.44    itojun #endif
    128  1.44    itojun 
    129   1.4   mycroft #include <netinet/tcp.h>
    130   1.4   mycroft #include <netinet/tcp_fsm.h>
    131   1.4   mycroft #include <netinet/tcp_seq.h>
    132   1.4   mycroft #include <netinet/tcp_timer.h>
    133   1.4   mycroft #include <netinet/tcp_var.h>
    134  1.79   thorpej #include <netinet/tcp_private.h>
    135  1.76    rpaulo #include <netinet/tcp_congctl.h>
    136   1.4   mycroft #include <netinet/tcpip.h>
    137  1.51   thorpej #ifdef TCP_DEBUG
    138  1.51   thorpej #include <netinet/tcp_debug.h>
    139  1.51   thorpej #endif
    140   1.1       cgd 
    141  1.52   thorpej /*
    142  1.52   thorpej  * Various tunable timer parameters.  These are initialized in tcp_init(),
    143  1.52   thorpej  * unless they are patched.
    144  1.52   thorpej  */
    145  1.77  christos u_int	tcp_keepinit = 0;
    146  1.77  christos u_int	tcp_keepidle = 0;
    147  1.77  christos u_int	tcp_keepintvl = 0;
    148  1.77  christos u_int	tcp_keepcnt = 0;		/* max idle probes */
    149  1.77  christos 
    150  1.52   thorpej int	tcp_maxpersistidle = 0;		/* max idle time in persist */
    151  1.26   thorpej 
    152  1.49   thorpej /*
    153  1.49   thorpej  * Time to delay the ACK.  This is initialized in tcp_init(), unless
    154  1.49   thorpej  * its patched.
    155  1.49   thorpej  */
    156  1.49   thorpej int	tcp_delack_ticks = 0;
    157  1.27   thorpej 
    158  1.51   thorpej void	tcp_timer_rexmt(void *);
    159  1.51   thorpej void	tcp_timer_persist(void *);
    160  1.51   thorpej void	tcp_timer_keep(void *);
    161  1.51   thorpej void	tcp_timer_2msl(void *);
    162  1.51   thorpej 
    163  1.56      matt const tcp_timer_func_t tcp_timer_funcs[TCPT_NTIMERS] = {
    164  1.51   thorpej 	tcp_timer_rexmt,
    165  1.51   thorpej 	tcp_timer_persist,
    166  1.51   thorpej 	tcp_timer_keep,
    167  1.51   thorpej 	tcp_timer_2msl,
    168  1.51   thorpej };
    169  1.52   thorpej 
    170  1.52   thorpej /*
    171  1.52   thorpej  * Timer state initialization, called from tcp_init().
    172  1.52   thorpej  */
    173  1.52   thorpej void
    174  1.52   thorpej tcp_timer_init(void)
    175  1.52   thorpej {
    176  1.52   thorpej 
    177  1.77  christos 	if (tcp_keepinit == 0)
    178  1.77  christos 		tcp_keepinit = TCPTV_KEEP_INIT;
    179  1.77  christos 
    180  1.52   thorpej 	if (tcp_keepidle == 0)
    181  1.52   thorpej 		tcp_keepidle = TCPTV_KEEP_IDLE;
    182  1.52   thorpej 
    183  1.52   thorpej 	if (tcp_keepintvl == 0)
    184  1.52   thorpej 		tcp_keepintvl = TCPTV_KEEPINTVL;
    185  1.52   thorpej 
    186  1.52   thorpej 	if (tcp_keepcnt == 0)
    187  1.52   thorpej 		tcp_keepcnt = TCPTV_KEEPCNT;
    188  1.52   thorpej 
    189  1.52   thorpej 	if (tcp_maxpersistidle == 0)
    190  1.52   thorpej 		tcp_maxpersistidle = TCPTV_KEEP_IDLE;
    191  1.52   thorpej 
    192  1.52   thorpej 	if (tcp_delack_ticks == 0)
    193  1.52   thorpej 		tcp_delack_ticks = TCP_DELACK_TICKS;
    194  1.52   thorpej }
    195  1.51   thorpej 
    196   1.1       cgd /*
    197  1.49   thorpej  * Callout to process delayed ACKs for a TCPCB.
    198   1.1       cgd  */
    199   1.6   mycroft void
    200  1.49   thorpej tcp_delack(void *arg)
    201   1.1       cgd {
    202  1.49   thorpej 	struct tcpcb *tp = arg;
    203   1.1       cgd 
    204  1.49   thorpej 	/*
    205  1.49   thorpej 	 * If tcp_output() wasn't able to transmit the ACK
    206  1.49   thorpej 	 * for whatever reason, it will restart the delayed
    207  1.49   thorpej 	 * ACK callout.
    208  1.49   thorpej 	 */
    209  1.49   thorpej 
    210  1.80        ad 	mutex_enter(softnet_lock);
    211  1.82        ad 	if ((tp->t_flags & (TF_DEAD | TF_DELACK)) != TF_DELACK) {
    212  1.80        ad 		mutex_exit(softnet_lock);
    213  1.63        he 		return;
    214  1.63        he 	}
    215  1.83    bouyer 	if (!callout_expired(&tp->t_delack_ch)) {
    216  1.83    bouyer 		mutex_exit(softnet_lock);
    217  1.83    bouyer 		return;
    218  1.83    bouyer 	}
    219  1.63        he 
    220  1.49   thorpej 	tp->t_flags |= TF_ACKNOW;
    221  1.80        ad 	KERNEL_LOCK(1, NULL);
    222  1.49   thorpej 	(void) tcp_output(tp);
    223  1.80        ad 	KERNEL_UNLOCK_ONE(NULL);
    224  1.80        ad 	mutex_exit(softnet_lock);
    225   1.1       cgd }
    226   1.1       cgd 
    227   1.1       cgd /*
    228   1.1       cgd  * Tcp protocol timeout routine called every 500 ms.
    229   1.1       cgd  * Updates the timers in all active tcb's and
    230   1.1       cgd  * causes finite state machine actions if timers expire.
    231   1.1       cgd  */
    232   1.6   mycroft void
    233  1.87     pooka tcp_slowtimo(void *arg)
    234   1.1       cgd {
    235   1.1       cgd 
    236  1.80        ad 	mutex_enter(softnet_lock);
    237  1.21  explorer 	tcp_iss_seq += TCP_ISSINCR;			/* increment iss */
    238   1.7   mycroft 	tcp_now++;					/* for timestamps */
    239  1.80        ad 	mutex_exit(softnet_lock);
    240  1.87     pooka 
    241  1.87     pooka 	callout_schedule(&tcp_slowtimo_ch, hz / PR_SLOWHZ);
    242   1.1       cgd }
    243   1.1       cgd 
    244   1.1       cgd /*
    245   1.1       cgd  * Cancel all timers for TCP tp.
    246   1.1       cgd  */
    247   1.6   mycroft void
    248  1.69     perry tcp_canceltimers(struct tcpcb *tp)
    249   1.1       cgd {
    250  1.46  augustss 	int i;
    251   1.1       cgd 
    252   1.1       cgd 	for (i = 0; i < TCPT_NTIMERS; i++)
    253  1.36   thorpej 		TCP_TIMER_DISARM(tp, i);
    254   1.1       cgd }
    255   1.1       cgd 
    256  1.56      matt const int	tcp_backoff[TCP_MAXRXTSHIFT + 1] =
    257   1.1       cgd     { 1, 2, 4, 8, 16, 32, 64, 64, 64, 64, 64, 64, 64 };
    258   1.1       cgd 
    259  1.56      matt const int	tcp_totbackoff = 511;	/* sum of tcp_backoff[] */
    260  1.26   thorpej 
    261   1.1       cgd /*
    262   1.1       cgd  * TCP timer processing.
    263   1.1       cgd  */
    264  1.51   thorpej 
    265  1.51   thorpej void
    266  1.51   thorpej tcp_timer_rexmt(void *arg)
    267   1.1       cgd {
    268  1.51   thorpej 	struct tcpcb *tp = arg;
    269  1.51   thorpej 	uint32_t rto;
    270  1.51   thorpej #ifdef TCP_DEBUG
    271  1.65    itojun 	struct socket *so = NULL;
    272  1.51   thorpej 	short ostate;
    273  1.47    itojun #endif
    274  1.47    itojun 
    275  1.80        ad 	mutex_enter(softnet_lock);
    276  1.80        ad 	if ((tp->t_flags & TF_DEAD) != 0) {
    277  1.80        ad 		mutex_exit(softnet_lock);
    278  1.63        he 		return;
    279  1.63        he 	}
    280  1.83    bouyer 	if (!callout_expired(&tp->t_timer[TCPT_REXMT])) {
    281  1.83    bouyer 		mutex_exit(softnet_lock);
    282  1.83    bouyer 		return;
    283  1.83    bouyer 	}
    284  1.84  uebayasi 
    285  1.80        ad 	KERNEL_LOCK(1, NULL);
    286  1.72  christos 	if ((tp->t_flags & TF_PMTUD_PEND) && tp->t_inpcb &&
    287  1.72  christos 	    SEQ_GEQ(tp->t_pmtud_th_seq, tp->snd_una) &&
    288  1.72  christos 	    SEQ_LT(tp->t_pmtud_th_seq, (int)(tp->snd_una + tp->t_ourmss))) {
    289  1.72  christos 		extern struct sockaddr_in icmpsrc;
    290  1.72  christos 		struct icmp icmp;
    291  1.72  christos 
    292  1.72  christos 		tp->t_flags &= ~TF_PMTUD_PEND;
    293  1.72  christos 
    294  1.72  christos 		/* XXX create fake icmp message with relevant entries */
    295  1.72  christos 		icmp.icmp_nextmtu = tp->t_pmtud_nextmtu;
    296  1.72  christos 		icmp.icmp_ip.ip_len = tp->t_pmtud_ip_len;
    297  1.72  christos 		icmp.icmp_ip.ip_hl = tp->t_pmtud_ip_hl;
    298  1.72  christos 		icmpsrc.sin_addr = tp->t_inpcb->inp_faddr;
    299  1.72  christos 		icmp_mtudisc(&icmp, icmpsrc.sin_addr);
    300  1.72  christos 
    301  1.72  christos 		/*
    302  1.72  christos 		 * Notify all connections to the same peer about
    303  1.72  christos 		 * new mss and trigger retransmit.
    304  1.72  christos 		 */
    305  1.72  christos 		in_pcbnotifyall(&tcbtable, icmpsrc.sin_addr, EMSGSIZE,
    306  1.72  christos 		    tcp_mtudisc);
    307  1.80        ad 		KERNEL_UNLOCK_ONE(NULL);
    308  1.80        ad 		mutex_exit(softnet_lock);
    309  1.72  christos  		return;
    310  1.72  christos  	}
    311  1.51   thorpej #ifdef TCP_DEBUG
    312  1.51   thorpej #ifdef INET
    313  1.51   thorpej 	if (tp->t_inpcb)
    314  1.51   thorpej 		so = tp->t_inpcb->inp_socket;
    315  1.51   thorpej #endif
    316  1.51   thorpej #ifdef INET6
    317  1.51   thorpej 	if (tp->t_in6pcb)
    318  1.51   thorpej 		so = tp->t_in6pcb->in6p_socket;
    319  1.51   thorpej #endif
    320  1.51   thorpej 	ostate = tp->t_state;
    321  1.51   thorpej #endif /* TCP_DEBUG */
    322   1.1       cgd 
    323   1.1       cgd 	/*
    324  1.70  jonathan 	 * Clear the SACK scoreboard, reset FACK estimate.
    325  1.70  jonathan 	 */
    326  1.70  jonathan 	tcp_free_sackholes(tp);
    327  1.70  jonathan 	tp->snd_fack = tp->snd_una;
    328  1.70  jonathan 
    329  1.70  jonathan 	/*
    330   1.1       cgd 	 * Retransmission timer went off.  Message has not
    331   1.1       cgd 	 * been acked within retransmit interval.  Back off
    332   1.1       cgd 	 * to a longer retransmit interval and retransmit one segment.
    333   1.1       cgd 	 */
    334  1.51   thorpej 
    335  1.51   thorpej 	if (++tp->t_rxtshift > TCP_MAXRXTSHIFT) {
    336  1.51   thorpej 		tp->t_rxtshift = TCP_MAXRXTSHIFT;
    337  1.79   thorpej 		TCP_STATINC(TCP_STAT_TIMEOUTDROP);
    338  1.51   thorpej 		tp = tcp_drop(tp, tp->t_softerror ?
    339  1.51   thorpej 		    tp->t_softerror : ETIMEDOUT);
    340  1.51   thorpej 		goto out;
    341  1.51   thorpej 	}
    342  1.79   thorpej 	TCP_STATINC(TCP_STAT_REXMTTIMEO);
    343  1.51   thorpej 	rto = TCP_REXMTVAL(tp);
    344  1.51   thorpej 	if (rto < tp->t_rttmin)
    345  1.51   thorpej 		rto = tp->t_rttmin;
    346  1.51   thorpej 	TCPT_RANGESET(tp->t_rxtcur, rto * tcp_backoff[tp->t_rxtshift],
    347  1.51   thorpej 	    tp->t_rttmin, TCPTV_REXMTMAX);
    348  1.51   thorpej 	TCP_TIMER_ARM(tp, TCPT_REXMT, tp->t_rxtcur);
    349  1.58    itojun 
    350  1.59    itojun 	/*
    351  1.51   thorpej 	 * If we are losing and we are trying path MTU discovery,
    352  1.51   thorpej 	 * try turning it off.  This will avoid black holes in
    353  1.51   thorpej 	 * the network which suppress or fail to send "packet
    354  1.51   thorpej 	 * too big" ICMP messages.  We should ideally do
    355  1.51   thorpej 	 * lots more sophisticated searching to find the right
    356  1.51   thorpej 	 * value here...
    357  1.51   thorpej 	 */
    358  1.58    itojun 	if (tp->t_mtudisc && tp->t_rxtshift > TCP_MAXRXTSHIFT / 6) {
    359  1.79   thorpej 		TCP_STATINC(TCP_STAT_PMTUBLACKHOLE);
    360  1.44    itojun 
    361  1.47    itojun #ifdef INET
    362  1.58    itojun 		/* try turning PMTUD off */
    363  1.51   thorpej 		if (tp->t_inpcb)
    364  1.58    itojun 			tp->t_mtudisc = 0;
    365  1.47    itojun #endif
    366  1.44    itojun #ifdef INET6
    367  1.58    itojun 		/* try using IPv6 minimum MTU */
    368  1.51   thorpej 		if (tp->t_in6pcb)
    369  1.58    itojun 			tp->t_mtudisc = 0;
    370  1.44    itojun #endif
    371  1.33       kml 
    372  1.58    itojun 		/* XXX: more sophisticated Black hole recovery code? */
    373  1.51   thorpej 	}
    374  1.58    itojun 
    375  1.51   thorpej 	/*
    376  1.51   thorpej 	 * If losing, let the lower level know and try for
    377  1.51   thorpej 	 * a better route.  Also, if we backed off this far,
    378  1.51   thorpej 	 * our srtt estimate is probably bogus.  Clobber it
    379  1.51   thorpej 	 * so we'll take the next rtt measurement as our srtt;
    380  1.51   thorpej 	 * move the current srtt into rttvar to keep the current
    381  1.51   thorpej 	 * retransmit times until then.
    382  1.51   thorpej 	 */
    383  1.51   thorpej 	if (tp->t_rxtshift > TCP_MAXRXTSHIFT / 4) {
    384  1.51   thorpej #ifdef INET
    385  1.51   thorpej 		if (tp->t_inpcb)
    386  1.51   thorpej 			in_losing(tp->t_inpcb);
    387  1.51   thorpej #endif
    388  1.51   thorpej #ifdef INET6
    389  1.51   thorpej 		if (tp->t_in6pcb)
    390  1.51   thorpej 			in6_losing(tp->t_in6pcb);
    391  1.51   thorpej #endif
    392  1.85       gdt 		/*
    393  1.85       gdt 		 * This operation is not described in RFC2988.  The
    394  1.85       gdt 		 * point is to keep srtt+4*rttvar constant, so we
    395  1.85       gdt 		 * should shift right 2 bits to divide by 4, and then
    396  1.85       gdt 		 * shift right one bit because the storage
    397  1.85       gdt 		 * representation of rttvar is 1/16s vs 1/32s for
    398  1.85       gdt 		 * srtt.
    399  1.85       gdt 		 */
    400  1.51   thorpej 		tp->t_rttvar += (tp->t_srtt >> TCP_RTT_SHIFT);
    401  1.51   thorpej 		tp->t_srtt = 0;
    402  1.51   thorpej 	}
    403  1.51   thorpej 	tp->snd_nxt = tp->snd_una;
    404  1.67   mycroft 	tp->snd_high = tp->snd_max;
    405  1.51   thorpej 	/*
    406  1.51   thorpej 	 * If timing a segment in this window, stop the timer.
    407  1.51   thorpej 	 */
    408  1.51   thorpej 	tp->t_rtttime = 0;
    409  1.51   thorpej 	/*
    410  1.51   thorpej 	 * Remember if we are retransmitting a SYN, because if
    411  1.51   thorpej 	 * we do, set the initial congestion window must be set
    412  1.51   thorpej 	 * to 1 segment.
    413  1.51   thorpej 	 */
    414  1.51   thorpej 	if (tp->t_state == TCPS_SYN_SENT)
    415  1.51   thorpej 		tp->t_flags |= TF_SYN_REXMT;
    416  1.76    rpaulo 
    417  1.51   thorpej 	/*
    418  1.76    rpaulo 	 * Adjust congestion control parameters.
    419  1.76    rpaulo 	 */
    420  1.76    rpaulo 	tp->t_congctl->slow_retransmit(tp);
    421  1.76    rpaulo 
    422  1.51   thorpej 	(void) tcp_output(tp);
    423  1.51   thorpej 
    424  1.51   thorpej  out:
    425  1.51   thorpej #ifdef TCP_DEBUG
    426  1.51   thorpej 	if (tp && so->so_options & SO_DEBUG)
    427  1.51   thorpej 		tcp_trace(TA_USER, ostate, tp, NULL,
    428  1.51   thorpej 		    PRU_SLOWTIMO | (TCPT_REXMT << 8));
    429  1.51   thorpej #endif
    430  1.80        ad 	KERNEL_UNLOCK_ONE(NULL);
    431  1.80        ad 	mutex_exit(softnet_lock);
    432  1.51   thorpej }
    433  1.51   thorpej 
    434  1.51   thorpej void
    435  1.51   thorpej tcp_timer_persist(void *arg)
    436  1.51   thorpej {
    437  1.51   thorpej 	struct tcpcb *tp = arg;
    438  1.51   thorpej 	uint32_t rto;
    439  1.51   thorpej #ifdef TCP_DEBUG
    440  1.65    itojun 	struct socket *so = NULL;
    441  1.51   thorpej 	short ostate;
    442  1.35       kml #endif
    443  1.51   thorpej 
    444  1.80        ad 	mutex_enter(softnet_lock);
    445  1.80        ad 	if ((tp->t_flags & TF_DEAD) != 0) {
    446  1.80        ad 		mutex_exit(softnet_lock);
    447  1.63        he 		return;
    448  1.63        he 	}
    449  1.83    bouyer 	if (!callout_expired(&tp->t_timer[TCPT_PERSIST])) {
    450  1.83    bouyer 		mutex_exit(softnet_lock);
    451  1.83    bouyer 		return;
    452  1.83    bouyer 	}
    453  1.51   thorpej 
    454  1.80        ad 	KERNEL_LOCK(1, NULL);
    455  1.60    simonb #ifdef TCP_DEBUG
    456  1.47    itojun #ifdef INET
    457  1.51   thorpej 	if (tp->t_inpcb)
    458  1.51   thorpej 		so = tp->t_inpcb->inp_socket;
    459  1.47    itojun #endif
    460  1.44    itojun #ifdef INET6
    461  1.51   thorpej 	if (tp->t_in6pcb)
    462  1.51   thorpej 		so = tp->t_in6pcb->in6p_socket;
    463  1.51   thorpej #endif
    464  1.51   thorpej 
    465  1.51   thorpej 	ostate = tp->t_state;
    466  1.60    simonb #endif /* TCP_DEBUG */
    467   1.1       cgd 
    468   1.1       cgd 	/*
    469   1.1       cgd 	 * Persistance timer into zero window.
    470   1.1       cgd 	 * Force a byte to be output, if possible.
    471   1.1       cgd 	 */
    472  1.51   thorpej 
    473  1.51   thorpej 	/*
    474  1.51   thorpej 	 * Hack: if the peer is dead/unreachable, we do not
    475  1.51   thorpej 	 * time out if the window is closed.  After a full
    476  1.51   thorpej 	 * backoff, drop the connection if the idle time
    477  1.51   thorpej 	 * (no responses to probes) reaches the maximum
    478  1.51   thorpej 	 * backoff that we would use if retransmitting.
    479  1.51   thorpej 	 */
    480  1.51   thorpej 	rto = TCP_REXMTVAL(tp);
    481  1.51   thorpej 	if (rto < tp->t_rttmin)
    482  1.51   thorpej 		rto = tp->t_rttmin;
    483  1.51   thorpej 	if (tp->t_rxtshift == TCP_MAXRXTSHIFT &&
    484  1.51   thorpej 	    ((tcp_now - tp->t_rcvtime) >= tcp_maxpersistidle ||
    485  1.51   thorpej 	    (tcp_now - tp->t_rcvtime) >= rto * tcp_totbackoff)) {
    486  1.79   thorpej 		TCP_STATINC(TCP_STAT_PERSISTDROPS);
    487  1.51   thorpej 		tp = tcp_drop(tp, ETIMEDOUT);
    488  1.51   thorpej 		goto out;
    489  1.51   thorpej 	}
    490  1.79   thorpej 	TCP_STATINC(TCP_STAT_PERSISTTIMEO);
    491  1.51   thorpej 	tcp_setpersist(tp);
    492  1.51   thorpej 	tp->t_force = 1;
    493  1.51   thorpej 	(void) tcp_output(tp);
    494  1.51   thorpej 	tp->t_force = 0;
    495  1.51   thorpej 
    496  1.51   thorpej  out:
    497  1.51   thorpej #ifdef TCP_DEBUG
    498  1.51   thorpej 	if (tp && so->so_options & SO_DEBUG)
    499  1.51   thorpej 		tcp_trace(TA_USER, ostate, tp, NULL,
    500  1.51   thorpej 		    PRU_SLOWTIMO | (TCPT_PERSIST << 8));
    501  1.51   thorpej #endif
    502  1.80        ad 	KERNEL_UNLOCK_ONE(NULL);
    503  1.80        ad 	mutex_exit(softnet_lock);
    504  1.51   thorpej }
    505  1.51   thorpej 
    506  1.51   thorpej void
    507  1.51   thorpej tcp_timer_keep(void *arg)
    508  1.51   thorpej {
    509  1.51   thorpej 	struct tcpcb *tp = arg;
    510  1.61       scw 	struct socket *so = NULL;	/* Quell compiler warning */
    511  1.51   thorpej #ifdef TCP_DEBUG
    512  1.51   thorpej 	short ostate;
    513  1.51   thorpej #endif
    514  1.51   thorpej 
    515  1.80        ad 	mutex_enter(softnet_lock);
    516  1.80        ad 	if ((tp->t_flags & TF_DEAD) != 0) {
    517  1.80        ad 		mutex_exit(softnet_lock);
    518  1.63        he 		return;
    519  1.63        he 	}
    520  1.83    bouyer 	if (!callout_expired(&tp->t_timer[TCPT_KEEP])) {
    521  1.83    bouyer 		mutex_exit(softnet_lock);
    522  1.83    bouyer 		return;
    523  1.83    bouyer 	}
    524  1.51   thorpej 
    525  1.80        ad 	KERNEL_LOCK(1, NULL);
    526  1.80        ad 
    527  1.51   thorpej #ifdef TCP_DEBUG
    528  1.51   thorpej 	ostate = tp->t_state;
    529  1.51   thorpej #endif /* TCP_DEBUG */
    530   1.1       cgd 
    531   1.1       cgd 	/*
    532   1.1       cgd 	 * Keep-alive timer went off; send something
    533   1.1       cgd 	 * or drop connection if idle for too long.
    534   1.1       cgd 	 */
    535  1.44    itojun 
    536  1.79   thorpej 	TCP_STATINC(TCP_STAT_KEEPTIMEO);
    537  1.51   thorpej 	if (TCPS_HAVEESTABLISHED(tp->t_state) == 0)
    538  1.51   thorpej 		goto dropit;
    539  1.47    itojun #ifdef INET
    540  1.51   thorpej 	if (tp->t_inpcb)
    541  1.51   thorpej 		so = tp->t_inpcb->inp_socket;
    542  1.47    itojun #endif
    543  1.44    itojun #ifdef INET6
    544  1.51   thorpej 	if (tp->t_in6pcb)
    545  1.51   thorpej 		so = tp->t_in6pcb->in6p_socket;
    546  1.44    itojun #endif
    547  1.74  christos 	KASSERT(so != NULL);
    548  1.51   thorpej 	if (so->so_options & SO_KEEPALIVE &&
    549  1.51   thorpej 	    tp->t_state <= TCPS_CLOSE_WAIT) {
    550  1.77  christos 	    	if ((tp->t_maxidle > 0) &&
    551  1.51   thorpej 		    ((tcp_now - tp->t_rcvtime) >=
    552  1.77  christos 		     tp->t_keepidle + tp->t_maxidle))
    553  1.51   thorpej 			goto dropit;
    554  1.51   thorpej 		/*
    555  1.51   thorpej 		 * Send a packet designed to force a response
    556  1.51   thorpej 		 * if the peer is up and reachable:
    557  1.51   thorpej 		 * either an ACK if the connection is still alive,
    558  1.51   thorpej 		 * or an RST if the peer has closed the connection
    559  1.51   thorpej 		 * due to timeout or reboot.
    560  1.51   thorpej 		 * Using sequence number tp->snd_una-1
    561  1.51   thorpej 		 * causes the transmitted zero-length segment
    562  1.51   thorpej 		 * to lie outside the receive window;
    563  1.51   thorpej 		 * by the protocol spec, this requires the
    564  1.51   thorpej 		 * correspondent TCP to respond.
    565  1.51   thorpej 		 */
    566  1.79   thorpej 		TCP_STATINC(TCP_STAT_KEEPPROBE);
    567  1.51   thorpej 		if (tcp_compat_42) {
    568   1.1       cgd 			/*
    569  1.51   thorpej 			 * The keepalive packet must have nonzero
    570  1.51   thorpej 			 * length to get a 4.2 host to respond.
    571   1.1       cgd 			 */
    572  1.51   thorpej 			(void)tcp_respond(tp, tp->t_template,
    573  1.86    plunky 			    NULL, NULL, tp->rcv_nxt - 1,
    574  1.51   thorpej 			    tp->snd_una - 1, 0);
    575  1.51   thorpej 		} else {
    576  1.51   thorpej 			(void)tcp_respond(tp, tp->t_template,
    577  1.86    plunky 			    NULL, NULL, tp->rcv_nxt,
    578  1.51   thorpej 			    tp->snd_una - 1, 0);
    579  1.51   thorpej 		}
    580  1.77  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepintvl);
    581  1.51   thorpej 	} else
    582  1.77  christos 		TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepidle);
    583  1.51   thorpej 
    584  1.51   thorpej #ifdef TCP_DEBUG
    585  1.51   thorpej 	if (tp && so->so_options & SO_DEBUG)
    586  1.51   thorpej 		tcp_trace(TA_USER, ostate, tp, NULL,
    587  1.51   thorpej 		    PRU_SLOWTIMO | (TCPT_KEEP << 8));
    588  1.51   thorpej #endif
    589  1.80        ad 	KERNEL_UNLOCK_ONE(NULL);
    590  1.80        ad 	mutex_exit(softnet_lock);
    591  1.51   thorpej 	return;
    592  1.51   thorpej 
    593  1.51   thorpej  dropit:
    594  1.79   thorpej 	TCP_STATINC(TCP_STAT_KEEPDROPS);
    595  1.51   thorpej 	(void) tcp_drop(tp, ETIMEDOUT);
    596  1.80        ad 	KERNEL_UNLOCK_ONE(NULL);
    597  1.80        ad 	mutex_exit(softnet_lock);
    598  1.51   thorpej }
    599  1.51   thorpej 
    600  1.51   thorpej void
    601  1.51   thorpej tcp_timer_2msl(void *arg)
    602  1.51   thorpej {
    603  1.51   thorpej 	struct tcpcb *tp = arg;
    604  1.51   thorpej #ifdef TCP_DEBUG
    605  1.65    itojun 	struct socket *so = NULL;
    606  1.51   thorpej 	short ostate;
    607  1.51   thorpej #endif
    608  1.51   thorpej 
    609  1.80        ad 	mutex_enter(softnet_lock);
    610  1.80        ad 	if ((tp->t_flags & TF_DEAD) != 0) {
    611  1.80        ad 		mutex_exit(softnet_lock);
    612  1.63        he 		return;
    613  1.63        he 	}
    614  1.83    bouyer 	if (!callout_expired(&tp->t_timer[TCPT_2MSL])) {
    615  1.83    bouyer 		mutex_exit(softnet_lock);
    616  1.83    bouyer 		return;
    617  1.83    bouyer 	}
    618  1.51   thorpej 
    619  1.70  jonathan 	/*
    620  1.70  jonathan 	 * 2 MSL timeout went off, clear the SACK scoreboard, reset
    621  1.70  jonathan 	 * the FACK estimate.
    622  1.70  jonathan 	 */
    623  1.80        ad 	KERNEL_LOCK(1, NULL);
    624  1.70  jonathan 	tcp_free_sackholes(tp);
    625  1.70  jonathan 	tp->snd_fack = tp->snd_una;
    626  1.70  jonathan 
    627  1.60    simonb #ifdef TCP_DEBUG
    628  1.51   thorpej #ifdef INET
    629  1.51   thorpej 	if (tp->t_inpcb)
    630  1.51   thorpej 		so = tp->t_inpcb->inp_socket;
    631  1.51   thorpej #endif
    632  1.51   thorpej #ifdef INET6
    633  1.51   thorpej 	if (tp->t_in6pcb)
    634  1.51   thorpej 		so = tp->t_in6pcb->in6p_socket;
    635  1.51   thorpej #endif
    636  1.51   thorpej 
    637  1.51   thorpej 	ostate = tp->t_state;
    638  1.60    simonb #endif /* TCP_DEBUG */
    639  1.51   thorpej 
    640  1.51   thorpej 	/*
    641  1.51   thorpej 	 * 2 MSL timeout in shutdown went off.  If we're closed but
    642  1.51   thorpej 	 * still waiting for peer to close and connection has been idle
    643  1.51   thorpej 	 * too long, or if 2MSL time is up from TIME_WAIT, delete connection
    644  1.51   thorpej 	 * control block.  Otherwise, check again in a bit.
    645  1.51   thorpej 	 */
    646  1.51   thorpej 	if (tp->t_state != TCPS_TIME_WAIT &&
    647  1.77  christos 	    ((tp->t_maxidle == 0) ||
    648  1.77  christos 	    ((tcp_now - tp->t_rcvtime) <= tp->t_maxidle)))
    649  1.77  christos 	    TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_keepintvl);
    650  1.51   thorpej 	else
    651  1.51   thorpej 		tp = tcp_close(tp);
    652  1.51   thorpej 
    653  1.51   thorpej #ifdef TCP_DEBUG
    654  1.51   thorpej 	if (tp && so->so_options & SO_DEBUG)
    655  1.51   thorpej 		tcp_trace(TA_USER, ostate, tp, NULL,
    656  1.51   thorpej 		    PRU_SLOWTIMO | (TCPT_2MSL << 8));
    657  1.51   thorpej #endif
    658  1.91  knakahar 	KERNEL_UNLOCK_ONE(NULL);
    659  1.80        ad 	mutex_exit(softnet_lock);
    660   1.1       cgd }
    661