tcp_timer.c revision 1.89 1 1.89 pooka /* $NetBSD: tcp_timer.c,v 1.89 2015/08/24 22:21:26 pooka 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.89 pooka __KERNEL_RCSID(0, "$NetBSD: tcp_timer.c,v 1.89 2015/08/24 22:21:26 pooka 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.4 mycroft #include <net/route.h>
114 1.1 cgd
115 1.4 mycroft #include <netinet/in.h>
116 1.4 mycroft #include <netinet/in_systm.h>
117 1.4 mycroft #include <netinet/ip.h>
118 1.4 mycroft #include <netinet/in_pcb.h>
119 1.4 mycroft #include <netinet/ip_var.h>
120 1.72 christos #include <netinet/ip_icmp.h>
121 1.44 itojun
122 1.44 itojun #ifdef INET6
123 1.44 itojun #ifndef INET
124 1.44 itojun #include <netinet/in.h>
125 1.44 itojun #endif
126 1.44 itojun #include <netinet/ip6.h>
127 1.44 itojun #include <netinet6/in6_pcb.h>
128 1.44 itojun #endif
129 1.44 itojun
130 1.4 mycroft #include <netinet/tcp.h>
131 1.4 mycroft #include <netinet/tcp_fsm.h>
132 1.4 mycroft #include <netinet/tcp_seq.h>
133 1.4 mycroft #include <netinet/tcp_timer.h>
134 1.4 mycroft #include <netinet/tcp_var.h>
135 1.79 thorpej #include <netinet/tcp_private.h>
136 1.76 rpaulo #include <netinet/tcp_congctl.h>
137 1.4 mycroft #include <netinet/tcpip.h>
138 1.51 thorpej #ifdef TCP_DEBUG
139 1.51 thorpej #include <netinet/tcp_debug.h>
140 1.51 thorpej #endif
141 1.1 cgd
142 1.52 thorpej /*
143 1.52 thorpej * Various tunable timer parameters. These are initialized in tcp_init(),
144 1.52 thorpej * unless they are patched.
145 1.52 thorpej */
146 1.77 christos u_int tcp_keepinit = 0;
147 1.77 christos u_int tcp_keepidle = 0;
148 1.77 christos u_int tcp_keepintvl = 0;
149 1.77 christos u_int tcp_keepcnt = 0; /* max idle probes */
150 1.77 christos
151 1.52 thorpej int tcp_maxpersistidle = 0; /* max idle time in persist */
152 1.26 thorpej
153 1.49 thorpej /*
154 1.49 thorpej * Time to delay the ACK. This is initialized in tcp_init(), unless
155 1.49 thorpej * its patched.
156 1.49 thorpej */
157 1.49 thorpej int tcp_delack_ticks = 0;
158 1.27 thorpej
159 1.51 thorpej void tcp_timer_rexmt(void *);
160 1.51 thorpej void tcp_timer_persist(void *);
161 1.51 thorpej void tcp_timer_keep(void *);
162 1.51 thorpej void tcp_timer_2msl(void *);
163 1.51 thorpej
164 1.56 matt const tcp_timer_func_t tcp_timer_funcs[TCPT_NTIMERS] = {
165 1.51 thorpej tcp_timer_rexmt,
166 1.51 thorpej tcp_timer_persist,
167 1.51 thorpej tcp_timer_keep,
168 1.51 thorpej tcp_timer_2msl,
169 1.51 thorpej };
170 1.52 thorpej
171 1.52 thorpej /*
172 1.52 thorpej * Timer state initialization, called from tcp_init().
173 1.52 thorpej */
174 1.52 thorpej void
175 1.52 thorpej tcp_timer_init(void)
176 1.52 thorpej {
177 1.52 thorpej
178 1.77 christos if (tcp_keepinit == 0)
179 1.77 christos tcp_keepinit = TCPTV_KEEP_INIT;
180 1.77 christos
181 1.52 thorpej if (tcp_keepidle == 0)
182 1.52 thorpej tcp_keepidle = TCPTV_KEEP_IDLE;
183 1.52 thorpej
184 1.52 thorpej if (tcp_keepintvl == 0)
185 1.52 thorpej tcp_keepintvl = TCPTV_KEEPINTVL;
186 1.52 thorpej
187 1.52 thorpej if (tcp_keepcnt == 0)
188 1.52 thorpej tcp_keepcnt = TCPTV_KEEPCNT;
189 1.52 thorpej
190 1.52 thorpej if (tcp_maxpersistidle == 0)
191 1.52 thorpej tcp_maxpersistidle = TCPTV_KEEP_IDLE;
192 1.52 thorpej
193 1.52 thorpej if (tcp_delack_ticks == 0)
194 1.52 thorpej tcp_delack_ticks = TCP_DELACK_TICKS;
195 1.52 thorpej }
196 1.51 thorpej
197 1.1 cgd /*
198 1.49 thorpej * Callout to process delayed ACKs for a TCPCB.
199 1.1 cgd */
200 1.6 mycroft void
201 1.49 thorpej tcp_delack(void *arg)
202 1.1 cgd {
203 1.49 thorpej struct tcpcb *tp = arg;
204 1.1 cgd
205 1.49 thorpej /*
206 1.49 thorpej * If tcp_output() wasn't able to transmit the ACK
207 1.49 thorpej * for whatever reason, it will restart the delayed
208 1.49 thorpej * ACK callout.
209 1.49 thorpej */
210 1.49 thorpej
211 1.80 ad mutex_enter(softnet_lock);
212 1.82 ad if ((tp->t_flags & (TF_DEAD | TF_DELACK)) != TF_DELACK) {
213 1.80 ad mutex_exit(softnet_lock);
214 1.63 he return;
215 1.63 he }
216 1.83 bouyer if (!callout_expired(&tp->t_delack_ch)) {
217 1.83 bouyer mutex_exit(softnet_lock);
218 1.83 bouyer return;
219 1.83 bouyer }
220 1.63 he
221 1.49 thorpej tp->t_flags |= TF_ACKNOW;
222 1.80 ad KERNEL_LOCK(1, NULL);
223 1.49 thorpej (void) tcp_output(tp);
224 1.80 ad KERNEL_UNLOCK_ONE(NULL);
225 1.80 ad mutex_exit(softnet_lock);
226 1.1 cgd }
227 1.1 cgd
228 1.1 cgd /*
229 1.1 cgd * Tcp protocol timeout routine called every 500 ms.
230 1.1 cgd * Updates the timers in all active tcb's and
231 1.1 cgd * causes finite state machine actions if timers expire.
232 1.1 cgd */
233 1.6 mycroft void
234 1.87 pooka tcp_slowtimo(void *arg)
235 1.1 cgd {
236 1.1 cgd
237 1.80 ad mutex_enter(softnet_lock);
238 1.21 explorer tcp_iss_seq += TCP_ISSINCR; /* increment iss */
239 1.7 mycroft tcp_now++; /* for timestamps */
240 1.80 ad mutex_exit(softnet_lock);
241 1.87 pooka
242 1.87 pooka callout_schedule(&tcp_slowtimo_ch, hz / PR_SLOWHZ);
243 1.1 cgd }
244 1.1 cgd
245 1.1 cgd /*
246 1.1 cgd * Cancel all timers for TCP tp.
247 1.1 cgd */
248 1.6 mycroft void
249 1.69 perry tcp_canceltimers(struct tcpcb *tp)
250 1.1 cgd {
251 1.46 augustss int i;
252 1.1 cgd
253 1.1 cgd for (i = 0; i < TCPT_NTIMERS; i++)
254 1.36 thorpej TCP_TIMER_DISARM(tp, i);
255 1.1 cgd }
256 1.1 cgd
257 1.56 matt const int tcp_backoff[TCP_MAXRXTSHIFT + 1] =
258 1.1 cgd { 1, 2, 4, 8, 16, 32, 64, 64, 64, 64, 64, 64, 64 };
259 1.1 cgd
260 1.56 matt const int tcp_totbackoff = 511; /* sum of tcp_backoff[] */
261 1.26 thorpej
262 1.1 cgd /*
263 1.1 cgd * TCP timer processing.
264 1.1 cgd */
265 1.51 thorpej
266 1.51 thorpej void
267 1.51 thorpej tcp_timer_rexmt(void *arg)
268 1.1 cgd {
269 1.51 thorpej struct tcpcb *tp = arg;
270 1.51 thorpej uint32_t rto;
271 1.51 thorpej #ifdef TCP_DEBUG
272 1.65 itojun struct socket *so = NULL;
273 1.51 thorpej short ostate;
274 1.47 itojun #endif
275 1.47 itojun
276 1.80 ad mutex_enter(softnet_lock);
277 1.80 ad if ((tp->t_flags & TF_DEAD) != 0) {
278 1.80 ad mutex_exit(softnet_lock);
279 1.63 he return;
280 1.63 he }
281 1.83 bouyer if (!callout_expired(&tp->t_timer[TCPT_REXMT])) {
282 1.83 bouyer mutex_exit(softnet_lock);
283 1.83 bouyer return;
284 1.83 bouyer }
285 1.84 uebayasi
286 1.80 ad KERNEL_LOCK(1, NULL);
287 1.72 christos if ((tp->t_flags & TF_PMTUD_PEND) && tp->t_inpcb &&
288 1.72 christos SEQ_GEQ(tp->t_pmtud_th_seq, tp->snd_una) &&
289 1.72 christos SEQ_LT(tp->t_pmtud_th_seq, (int)(tp->snd_una + tp->t_ourmss))) {
290 1.72 christos extern struct sockaddr_in icmpsrc;
291 1.72 christos struct icmp icmp;
292 1.72 christos
293 1.72 christos tp->t_flags &= ~TF_PMTUD_PEND;
294 1.72 christos
295 1.72 christos /* XXX create fake icmp message with relevant entries */
296 1.72 christos icmp.icmp_nextmtu = tp->t_pmtud_nextmtu;
297 1.72 christos icmp.icmp_ip.ip_len = tp->t_pmtud_ip_len;
298 1.72 christos icmp.icmp_ip.ip_hl = tp->t_pmtud_ip_hl;
299 1.72 christos icmpsrc.sin_addr = tp->t_inpcb->inp_faddr;
300 1.72 christos icmp_mtudisc(&icmp, icmpsrc.sin_addr);
301 1.72 christos
302 1.72 christos /*
303 1.72 christos * Notify all connections to the same peer about
304 1.72 christos * new mss and trigger retransmit.
305 1.72 christos */
306 1.72 christos in_pcbnotifyall(&tcbtable, icmpsrc.sin_addr, EMSGSIZE,
307 1.72 christos tcp_mtudisc);
308 1.80 ad KERNEL_UNLOCK_ONE(NULL);
309 1.80 ad mutex_exit(softnet_lock);
310 1.72 christos return;
311 1.72 christos }
312 1.51 thorpej #ifdef TCP_DEBUG
313 1.51 thorpej #ifdef INET
314 1.51 thorpej if (tp->t_inpcb)
315 1.51 thorpej so = tp->t_inpcb->inp_socket;
316 1.51 thorpej #endif
317 1.51 thorpej #ifdef INET6
318 1.51 thorpej if (tp->t_in6pcb)
319 1.51 thorpej so = tp->t_in6pcb->in6p_socket;
320 1.51 thorpej #endif
321 1.51 thorpej ostate = tp->t_state;
322 1.51 thorpej #endif /* TCP_DEBUG */
323 1.1 cgd
324 1.1 cgd /*
325 1.70 jonathan * Clear the SACK scoreboard, reset FACK estimate.
326 1.70 jonathan */
327 1.70 jonathan tcp_free_sackholes(tp);
328 1.70 jonathan tp->snd_fack = tp->snd_una;
329 1.70 jonathan
330 1.70 jonathan /*
331 1.1 cgd * Retransmission timer went off. Message has not
332 1.1 cgd * been acked within retransmit interval. Back off
333 1.1 cgd * to a longer retransmit interval and retransmit one segment.
334 1.1 cgd */
335 1.51 thorpej
336 1.51 thorpej if (++tp->t_rxtshift > TCP_MAXRXTSHIFT) {
337 1.51 thorpej tp->t_rxtshift = TCP_MAXRXTSHIFT;
338 1.79 thorpej TCP_STATINC(TCP_STAT_TIMEOUTDROP);
339 1.51 thorpej tp = tcp_drop(tp, tp->t_softerror ?
340 1.51 thorpej tp->t_softerror : ETIMEDOUT);
341 1.51 thorpej goto out;
342 1.51 thorpej }
343 1.79 thorpej TCP_STATINC(TCP_STAT_REXMTTIMEO);
344 1.51 thorpej rto = TCP_REXMTVAL(tp);
345 1.51 thorpej if (rto < tp->t_rttmin)
346 1.51 thorpej rto = tp->t_rttmin;
347 1.51 thorpej TCPT_RANGESET(tp->t_rxtcur, rto * tcp_backoff[tp->t_rxtshift],
348 1.51 thorpej tp->t_rttmin, TCPTV_REXMTMAX);
349 1.51 thorpej TCP_TIMER_ARM(tp, TCPT_REXMT, tp->t_rxtcur);
350 1.58 itojun
351 1.59 itojun /*
352 1.51 thorpej * If we are losing and we are trying path MTU discovery,
353 1.51 thorpej * try turning it off. This will avoid black holes in
354 1.51 thorpej * the network which suppress or fail to send "packet
355 1.51 thorpej * too big" ICMP messages. We should ideally do
356 1.51 thorpej * lots more sophisticated searching to find the right
357 1.51 thorpej * value here...
358 1.51 thorpej */
359 1.58 itojun if (tp->t_mtudisc && tp->t_rxtshift > TCP_MAXRXTSHIFT / 6) {
360 1.79 thorpej TCP_STATINC(TCP_STAT_PMTUBLACKHOLE);
361 1.44 itojun
362 1.47 itojun #ifdef INET
363 1.58 itojun /* try turning PMTUD off */
364 1.51 thorpej if (tp->t_inpcb)
365 1.58 itojun tp->t_mtudisc = 0;
366 1.47 itojun #endif
367 1.44 itojun #ifdef INET6
368 1.58 itojun /* try using IPv6 minimum MTU */
369 1.51 thorpej if (tp->t_in6pcb)
370 1.58 itojun tp->t_mtudisc = 0;
371 1.44 itojun #endif
372 1.33 kml
373 1.58 itojun /* XXX: more sophisticated Black hole recovery code? */
374 1.51 thorpej }
375 1.58 itojun
376 1.51 thorpej /*
377 1.51 thorpej * If losing, let the lower level know and try for
378 1.51 thorpej * a better route. Also, if we backed off this far,
379 1.51 thorpej * our srtt estimate is probably bogus. Clobber it
380 1.51 thorpej * so we'll take the next rtt measurement as our srtt;
381 1.51 thorpej * move the current srtt into rttvar to keep the current
382 1.51 thorpej * retransmit times until then.
383 1.51 thorpej */
384 1.51 thorpej if (tp->t_rxtshift > TCP_MAXRXTSHIFT / 4) {
385 1.51 thorpej #ifdef INET
386 1.51 thorpej if (tp->t_inpcb)
387 1.51 thorpej in_losing(tp->t_inpcb);
388 1.51 thorpej #endif
389 1.51 thorpej #ifdef INET6
390 1.51 thorpej if (tp->t_in6pcb)
391 1.51 thorpej in6_losing(tp->t_in6pcb);
392 1.51 thorpej #endif
393 1.85 gdt /*
394 1.85 gdt * This operation is not described in RFC2988. The
395 1.85 gdt * point is to keep srtt+4*rttvar constant, so we
396 1.85 gdt * should shift right 2 bits to divide by 4, and then
397 1.85 gdt * shift right one bit because the storage
398 1.85 gdt * representation of rttvar is 1/16s vs 1/32s for
399 1.85 gdt * srtt.
400 1.85 gdt */
401 1.51 thorpej tp->t_rttvar += (tp->t_srtt >> TCP_RTT_SHIFT);
402 1.51 thorpej tp->t_srtt = 0;
403 1.51 thorpej }
404 1.51 thorpej tp->snd_nxt = tp->snd_una;
405 1.67 mycroft tp->snd_high = tp->snd_max;
406 1.51 thorpej /*
407 1.51 thorpej * If timing a segment in this window, stop the timer.
408 1.51 thorpej */
409 1.51 thorpej tp->t_rtttime = 0;
410 1.51 thorpej /*
411 1.51 thorpej * Remember if we are retransmitting a SYN, because if
412 1.51 thorpej * we do, set the initial congestion window must be set
413 1.51 thorpej * to 1 segment.
414 1.51 thorpej */
415 1.51 thorpej if (tp->t_state == TCPS_SYN_SENT)
416 1.51 thorpej tp->t_flags |= TF_SYN_REXMT;
417 1.76 rpaulo
418 1.51 thorpej /*
419 1.76 rpaulo * Adjust congestion control parameters.
420 1.76 rpaulo */
421 1.76 rpaulo tp->t_congctl->slow_retransmit(tp);
422 1.76 rpaulo
423 1.51 thorpej (void) tcp_output(tp);
424 1.51 thorpej
425 1.51 thorpej out:
426 1.51 thorpej #ifdef TCP_DEBUG
427 1.51 thorpej if (tp && so->so_options & SO_DEBUG)
428 1.51 thorpej tcp_trace(TA_USER, ostate, tp, NULL,
429 1.51 thorpej PRU_SLOWTIMO | (TCPT_REXMT << 8));
430 1.51 thorpej #endif
431 1.80 ad KERNEL_UNLOCK_ONE(NULL);
432 1.80 ad mutex_exit(softnet_lock);
433 1.51 thorpej }
434 1.51 thorpej
435 1.51 thorpej void
436 1.51 thorpej tcp_timer_persist(void *arg)
437 1.51 thorpej {
438 1.51 thorpej struct tcpcb *tp = arg;
439 1.51 thorpej uint32_t rto;
440 1.51 thorpej #ifdef TCP_DEBUG
441 1.65 itojun struct socket *so = NULL;
442 1.51 thorpej short ostate;
443 1.35 kml #endif
444 1.51 thorpej
445 1.80 ad mutex_enter(softnet_lock);
446 1.80 ad if ((tp->t_flags & TF_DEAD) != 0) {
447 1.80 ad mutex_exit(softnet_lock);
448 1.63 he return;
449 1.63 he }
450 1.83 bouyer if (!callout_expired(&tp->t_timer[TCPT_PERSIST])) {
451 1.83 bouyer mutex_exit(softnet_lock);
452 1.83 bouyer return;
453 1.83 bouyer }
454 1.51 thorpej
455 1.80 ad KERNEL_LOCK(1, NULL);
456 1.60 simonb #ifdef TCP_DEBUG
457 1.47 itojun #ifdef INET
458 1.51 thorpej if (tp->t_inpcb)
459 1.51 thorpej so = tp->t_inpcb->inp_socket;
460 1.47 itojun #endif
461 1.44 itojun #ifdef INET6
462 1.51 thorpej if (tp->t_in6pcb)
463 1.51 thorpej so = tp->t_in6pcb->in6p_socket;
464 1.51 thorpej #endif
465 1.51 thorpej
466 1.51 thorpej ostate = tp->t_state;
467 1.60 simonb #endif /* TCP_DEBUG */
468 1.1 cgd
469 1.1 cgd /*
470 1.1 cgd * Persistance timer into zero window.
471 1.1 cgd * Force a byte to be output, if possible.
472 1.1 cgd */
473 1.51 thorpej
474 1.51 thorpej /*
475 1.51 thorpej * Hack: if the peer is dead/unreachable, we do not
476 1.51 thorpej * time out if the window is closed. After a full
477 1.51 thorpej * backoff, drop the connection if the idle time
478 1.51 thorpej * (no responses to probes) reaches the maximum
479 1.51 thorpej * backoff that we would use if retransmitting.
480 1.51 thorpej */
481 1.51 thorpej rto = TCP_REXMTVAL(tp);
482 1.51 thorpej if (rto < tp->t_rttmin)
483 1.51 thorpej rto = tp->t_rttmin;
484 1.51 thorpej if (tp->t_rxtshift == TCP_MAXRXTSHIFT &&
485 1.51 thorpej ((tcp_now - tp->t_rcvtime) >= tcp_maxpersistidle ||
486 1.51 thorpej (tcp_now - tp->t_rcvtime) >= rto * tcp_totbackoff)) {
487 1.79 thorpej TCP_STATINC(TCP_STAT_PERSISTDROPS);
488 1.51 thorpej tp = tcp_drop(tp, ETIMEDOUT);
489 1.51 thorpej goto out;
490 1.51 thorpej }
491 1.79 thorpej TCP_STATINC(TCP_STAT_PERSISTTIMEO);
492 1.51 thorpej tcp_setpersist(tp);
493 1.51 thorpej tp->t_force = 1;
494 1.51 thorpej (void) tcp_output(tp);
495 1.51 thorpej tp->t_force = 0;
496 1.51 thorpej
497 1.51 thorpej out:
498 1.51 thorpej #ifdef TCP_DEBUG
499 1.51 thorpej if (tp && so->so_options & SO_DEBUG)
500 1.51 thorpej tcp_trace(TA_USER, ostate, tp, NULL,
501 1.51 thorpej PRU_SLOWTIMO | (TCPT_PERSIST << 8));
502 1.51 thorpej #endif
503 1.80 ad KERNEL_UNLOCK_ONE(NULL);
504 1.80 ad mutex_exit(softnet_lock);
505 1.51 thorpej }
506 1.51 thorpej
507 1.51 thorpej void
508 1.51 thorpej tcp_timer_keep(void *arg)
509 1.51 thorpej {
510 1.51 thorpej struct tcpcb *tp = arg;
511 1.61 scw struct socket *so = NULL; /* Quell compiler warning */
512 1.51 thorpej #ifdef TCP_DEBUG
513 1.51 thorpej short ostate;
514 1.51 thorpej #endif
515 1.51 thorpej
516 1.80 ad mutex_enter(softnet_lock);
517 1.80 ad if ((tp->t_flags & TF_DEAD) != 0) {
518 1.80 ad mutex_exit(softnet_lock);
519 1.63 he return;
520 1.63 he }
521 1.83 bouyer if (!callout_expired(&tp->t_timer[TCPT_KEEP])) {
522 1.83 bouyer mutex_exit(softnet_lock);
523 1.83 bouyer return;
524 1.83 bouyer }
525 1.51 thorpej
526 1.80 ad KERNEL_LOCK(1, NULL);
527 1.80 ad
528 1.51 thorpej #ifdef TCP_DEBUG
529 1.51 thorpej ostate = tp->t_state;
530 1.51 thorpej #endif /* TCP_DEBUG */
531 1.1 cgd
532 1.1 cgd /*
533 1.1 cgd * Keep-alive timer went off; send something
534 1.1 cgd * or drop connection if idle for too long.
535 1.1 cgd */
536 1.44 itojun
537 1.79 thorpej TCP_STATINC(TCP_STAT_KEEPTIMEO);
538 1.51 thorpej if (TCPS_HAVEESTABLISHED(tp->t_state) == 0)
539 1.51 thorpej goto dropit;
540 1.47 itojun #ifdef INET
541 1.51 thorpej if (tp->t_inpcb)
542 1.51 thorpej so = tp->t_inpcb->inp_socket;
543 1.47 itojun #endif
544 1.44 itojun #ifdef INET6
545 1.51 thorpej if (tp->t_in6pcb)
546 1.51 thorpej so = tp->t_in6pcb->in6p_socket;
547 1.44 itojun #endif
548 1.74 christos KASSERT(so != NULL);
549 1.51 thorpej if (so->so_options & SO_KEEPALIVE &&
550 1.51 thorpej tp->t_state <= TCPS_CLOSE_WAIT) {
551 1.77 christos if ((tp->t_maxidle > 0) &&
552 1.51 thorpej ((tcp_now - tp->t_rcvtime) >=
553 1.77 christos tp->t_keepidle + tp->t_maxidle))
554 1.51 thorpej goto dropit;
555 1.51 thorpej /*
556 1.51 thorpej * Send a packet designed to force a response
557 1.51 thorpej * if the peer is up and reachable:
558 1.51 thorpej * either an ACK if the connection is still alive,
559 1.51 thorpej * or an RST if the peer has closed the connection
560 1.51 thorpej * due to timeout or reboot.
561 1.51 thorpej * Using sequence number tp->snd_una-1
562 1.51 thorpej * causes the transmitted zero-length segment
563 1.51 thorpej * to lie outside the receive window;
564 1.51 thorpej * by the protocol spec, this requires the
565 1.51 thorpej * correspondent TCP to respond.
566 1.51 thorpej */
567 1.79 thorpej TCP_STATINC(TCP_STAT_KEEPPROBE);
568 1.51 thorpej if (tcp_compat_42) {
569 1.1 cgd /*
570 1.51 thorpej * The keepalive packet must have nonzero
571 1.51 thorpej * length to get a 4.2 host to respond.
572 1.1 cgd */
573 1.51 thorpej (void)tcp_respond(tp, tp->t_template,
574 1.86 plunky NULL, NULL, tp->rcv_nxt - 1,
575 1.51 thorpej tp->snd_una - 1, 0);
576 1.51 thorpej } else {
577 1.51 thorpej (void)tcp_respond(tp, tp->t_template,
578 1.86 plunky NULL, NULL, tp->rcv_nxt,
579 1.51 thorpej tp->snd_una - 1, 0);
580 1.51 thorpej }
581 1.77 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepintvl);
582 1.51 thorpej } else
583 1.77 christos TCP_TIMER_ARM(tp, TCPT_KEEP, tp->t_keepidle);
584 1.51 thorpej
585 1.51 thorpej #ifdef TCP_DEBUG
586 1.51 thorpej if (tp && so->so_options & SO_DEBUG)
587 1.51 thorpej tcp_trace(TA_USER, ostate, tp, NULL,
588 1.51 thorpej PRU_SLOWTIMO | (TCPT_KEEP << 8));
589 1.51 thorpej #endif
590 1.80 ad KERNEL_UNLOCK_ONE(NULL);
591 1.80 ad mutex_exit(softnet_lock);
592 1.51 thorpej return;
593 1.51 thorpej
594 1.51 thorpej dropit:
595 1.79 thorpej TCP_STATINC(TCP_STAT_KEEPDROPS);
596 1.51 thorpej (void) tcp_drop(tp, ETIMEDOUT);
597 1.80 ad KERNEL_UNLOCK_ONE(NULL);
598 1.80 ad mutex_exit(softnet_lock);
599 1.51 thorpej }
600 1.51 thorpej
601 1.51 thorpej void
602 1.51 thorpej tcp_timer_2msl(void *arg)
603 1.51 thorpej {
604 1.51 thorpej struct tcpcb *tp = arg;
605 1.51 thorpej #ifdef TCP_DEBUG
606 1.65 itojun struct socket *so = NULL;
607 1.51 thorpej short ostate;
608 1.51 thorpej #endif
609 1.51 thorpej
610 1.80 ad mutex_enter(softnet_lock);
611 1.80 ad if ((tp->t_flags & TF_DEAD) != 0) {
612 1.80 ad mutex_exit(softnet_lock);
613 1.63 he return;
614 1.63 he }
615 1.83 bouyer if (!callout_expired(&tp->t_timer[TCPT_2MSL])) {
616 1.83 bouyer mutex_exit(softnet_lock);
617 1.83 bouyer return;
618 1.83 bouyer }
619 1.51 thorpej
620 1.70 jonathan /*
621 1.70 jonathan * 2 MSL timeout went off, clear the SACK scoreboard, reset
622 1.70 jonathan * the FACK estimate.
623 1.70 jonathan */
624 1.80 ad KERNEL_LOCK(1, NULL);
625 1.70 jonathan tcp_free_sackholes(tp);
626 1.70 jonathan tp->snd_fack = tp->snd_una;
627 1.70 jonathan
628 1.60 simonb #ifdef TCP_DEBUG
629 1.51 thorpej #ifdef INET
630 1.51 thorpej if (tp->t_inpcb)
631 1.51 thorpej so = tp->t_inpcb->inp_socket;
632 1.51 thorpej #endif
633 1.51 thorpej #ifdef INET6
634 1.51 thorpej if (tp->t_in6pcb)
635 1.51 thorpej so = tp->t_in6pcb->in6p_socket;
636 1.51 thorpej #endif
637 1.51 thorpej
638 1.51 thorpej ostate = tp->t_state;
639 1.60 simonb #endif /* TCP_DEBUG */
640 1.51 thorpej
641 1.51 thorpej /*
642 1.51 thorpej * 2 MSL timeout in shutdown went off. If we're closed but
643 1.51 thorpej * still waiting for peer to close and connection has been idle
644 1.51 thorpej * too long, or if 2MSL time is up from TIME_WAIT, delete connection
645 1.51 thorpej * control block. Otherwise, check again in a bit.
646 1.51 thorpej */
647 1.51 thorpej if (tp->t_state != TCPS_TIME_WAIT &&
648 1.77 christos ((tp->t_maxidle == 0) ||
649 1.77 christos ((tcp_now - tp->t_rcvtime) <= tp->t_maxidle)))
650 1.77 christos TCP_TIMER_ARM(tp, TCPT_2MSL, tp->t_keepintvl);
651 1.51 thorpej else
652 1.51 thorpej tp = tcp_close(tp);
653 1.51 thorpej
654 1.51 thorpej #ifdef TCP_DEBUG
655 1.51 thorpej if (tp && so->so_options & SO_DEBUG)
656 1.51 thorpej tcp_trace(TA_USER, ostate, tp, NULL,
657 1.51 thorpej PRU_SLOWTIMO | (TCPT_2MSL << 8));
658 1.51 thorpej #endif
659 1.80 ad mutex_exit(softnet_lock);
660 1.80 ad KERNEL_UNLOCK_ONE(NULL);
661 1.1 cgd }
662