tcp_timer.c revision 1.87 1 1.87 pooka /* $NetBSD: tcp_timer.c,v 1.87 2014/01/02 18:29:01 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.87 pooka __KERNEL_RCSID(0, "$NetBSD: tcp_timer.c,v 1.87 2014/01/02 18:29:01 pooka Exp $");
97 1.29 scottr
98 1.44 itojun #include "opt_inet.h"
99 1.51 thorpej #include "opt_tcp_debug.h"
100 1.44 itojun
101 1.4 mycroft #include <sys/param.h>
102 1.4 mycroft #include <sys/systm.h>
103 1.4 mycroft #include <sys/malloc.h>
104 1.4 mycroft #include <sys/mbuf.h>
105 1.4 mycroft #include <sys/socket.h>
106 1.4 mycroft #include <sys/socketvar.h>
107 1.4 mycroft #include <sys/protosw.h>
108 1.4 mycroft #include <sys/errno.h>
109 1.49 thorpej #include <sys/kernel.h>
110 1.1 cgd
111 1.4 mycroft #include <net/if.h>
112 1.4 mycroft #include <net/route.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.80 ad mutex_exit(softnet_lock);
659 1.80 ad KERNEL_UNLOCK_ONE(NULL);
660 1.1 cgd }
661