tcp_var.h revision 1.66 1 1.66 itojun /* $NetBSD: tcp_var.h,v 1.66 1999/08/12 16:04:52 itojun Exp $ */
2 1.61 itojun
3 1.61 itojun /*
4 1.61 itojun %%% portions-copyright-nrl-98
5 1.61 itojun Portions of this software are Copyright 1998 by Randall Atkinson,
6 1.61 itojun Ronald Lee, Daniel McDonald, Bao Phan, and Chris Winters. All Rights
7 1.61 itojun Reserved. All rights under this copyright have been assigned to the US
8 1.61 itojun Naval Research Laboratory (NRL). The NRL Copyright Notice and License
9 1.61 itojun Agreement Version 1.1 (January 17, 1995) applies to these portions of the
10 1.61 itojun software.
11 1.61 itojun You should have received a copy of the license with this software. If you
12 1.61 itojun didn't get a copy, you may request one from <license (at) ipv6.nrl.navy.mil>.
13 1.61 itojun
14 1.61 itojun */
15 1.61 itojun
16 1.61 itojun /*
17 1.61 itojun * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
18 1.61 itojun * All rights reserved.
19 1.61 itojun *
20 1.61 itojun * Redistribution and use in source and binary forms, with or without
21 1.61 itojun * modification, are permitted provided that the following conditions
22 1.61 itojun * are met:
23 1.61 itojun * 1. Redistributions of source code must retain the above copyright
24 1.61 itojun * notice, this list of conditions and the following disclaimer.
25 1.61 itojun * 2. Redistributions in binary form must reproduce the above copyright
26 1.61 itojun * notice, this list of conditions and the following disclaimer in the
27 1.61 itojun * documentation and/or other materials provided with the distribution.
28 1.61 itojun * 3. Neither the name of the project nor the names of its contributors
29 1.61 itojun * may be used to endorse or promote products derived from this software
30 1.61 itojun * without specific prior written permission.
31 1.61 itojun *
32 1.61 itojun * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
33 1.61 itojun * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
34 1.61 itojun * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
35 1.61 itojun * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
36 1.61 itojun * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
37 1.61 itojun * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
38 1.61 itojun * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
39 1.61 itojun * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
40 1.61 itojun * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
41 1.61 itojun * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
42 1.61 itojun * SUCH DAMAGE.
43 1.61 itojun */
44 1.35 thorpej
45 1.35 thorpej /*-
46 1.58 thorpej * Copyright (c) 1997, 1998, 1999 The NetBSD Foundation, Inc.
47 1.35 thorpej * All rights reserved.
48 1.35 thorpej *
49 1.35 thorpej * This code is derived from software contributed to The NetBSD Foundation
50 1.35 thorpej * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
51 1.35 thorpej * NASA Ames Research Center.
52 1.35 thorpej *
53 1.35 thorpej * Redistribution and use in source and binary forms, with or without
54 1.35 thorpej * modification, are permitted provided that the following conditions
55 1.35 thorpej * are met:
56 1.35 thorpej * 1. Redistributions of source code must retain the above copyright
57 1.35 thorpej * notice, this list of conditions and the following disclaimer.
58 1.35 thorpej * 2. Redistributions in binary form must reproduce the above copyright
59 1.35 thorpej * notice, this list of conditions and the following disclaimer in the
60 1.35 thorpej * documentation and/or other materials provided with the distribution.
61 1.35 thorpej * 3. All advertising materials mentioning features or use of this software
62 1.35 thorpej * must display the following acknowledgement:
63 1.35 thorpej * This product includes software developed by the NetBSD
64 1.35 thorpej * Foundation, Inc. and its contributors.
65 1.35 thorpej * 4. Neither the name of The NetBSD Foundation nor the names of its
66 1.35 thorpej * contributors may be used to endorse or promote products derived
67 1.35 thorpej * from this software without specific prior written permission.
68 1.35 thorpej *
69 1.35 thorpej * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
70 1.35 thorpej * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
71 1.35 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
72 1.35 thorpej * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
73 1.35 thorpej * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
74 1.35 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
75 1.35 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
76 1.35 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
77 1.35 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
78 1.35 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
79 1.35 thorpej * POSSIBILITY OF SUCH DAMAGE.
80 1.35 thorpej */
81 1.9 cgd
82 1.1 cgd /*
83 1.33 thorpej * Copyright (c) 1982, 1986, 1993, 1994, 1995
84 1.8 mycroft * The Regents of the University of California. All rights reserved.
85 1.1 cgd *
86 1.1 cgd * Redistribution and use in source and binary forms, with or without
87 1.1 cgd * modification, are permitted provided that the following conditions
88 1.1 cgd * are met:
89 1.1 cgd * 1. Redistributions of source code must retain the above copyright
90 1.1 cgd * notice, this list of conditions and the following disclaimer.
91 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
92 1.1 cgd * notice, this list of conditions and the following disclaimer in the
93 1.1 cgd * documentation and/or other materials provided with the distribution.
94 1.1 cgd * 3. All advertising materials mentioning features or use of this software
95 1.1 cgd * must display the following acknowledgement:
96 1.1 cgd * This product includes software developed by the University of
97 1.1 cgd * California, Berkeley and its contributors.
98 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
99 1.1 cgd * may be used to endorse or promote products derived from this software
100 1.1 cgd * without specific prior written permission.
101 1.1 cgd *
102 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
103 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
104 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
105 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
106 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
107 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
108 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
109 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
110 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
111 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
112 1.1 cgd * SUCH DAMAGE.
113 1.1 cgd *
114 1.33 thorpej * @(#)tcp_var.h 8.4 (Berkeley) 5/24/95
115 1.1 cgd */
116 1.1 cgd
117 1.34 perry #ifndef _NETINET_TCP_VAR_H_
118 1.34 perry #define _NETINET_TCP_VAR_H_
119 1.62 thorpej
120 1.65 itojun #if defined(_KERNEL) && !defined(_LKM)
121 1.62 thorpej #include "opt_inet.h"
122 1.65 itojun #endif
123 1.34 perry
124 1.1 cgd /*
125 1.1 cgd * Kernel variables for tcp.
126 1.1 cgd */
127 1.1 cgd
128 1.1 cgd /*
129 1.1 cgd * Tcp control block, one per tcp; fields:
130 1.1 cgd */
131 1.1 cgd struct tcpcb {
132 1.61 itojun int t_family; /* address family on the wire */
133 1.15 cgd struct ipqehead segq; /* sequencing queue */
134 1.48 thorpej u_int t_timer[TCPT_NTIMERS]; /* tcp timers */
135 1.1 cgd short t_state; /* state of this connection */
136 1.1 cgd short t_rxtshift; /* log(2) of rexmt exp. backoff */
137 1.1 cgd short t_rxtcur; /* current retransmit value */
138 1.1 cgd short t_dupacks; /* consecutive dup acks recd */
139 1.26 kml u_short t_peermss; /* peer's maximum segment size */
140 1.23 thorpej u_short t_ourmss; /* our's maximum segment size */
141 1.26 kml u_short t_segsz; /* current segment size in use */
142 1.1 cgd char t_force; /* 1 if forcing out a byte */
143 1.8 mycroft u_short t_flags;
144 1.8 mycroft #define TF_ACKNOW 0x0001 /* ack peer immediately */
145 1.8 mycroft #define TF_DELACK 0x0002 /* ack, but try to delay it */
146 1.8 mycroft #define TF_NODELAY 0x0004 /* don't delay packets to coalesce */
147 1.8 mycroft #define TF_NOOPT 0x0008 /* don't use tcp options */
148 1.8 mycroft #define TF_REQ_SCALE 0x0020 /* have/will request window scaling */
149 1.8 mycroft #define TF_RCVD_SCALE 0x0040 /* other side has requested scaling */
150 1.8 mycroft #define TF_REQ_TSTMP 0x0080 /* have/will request timestamps */
151 1.8 mycroft #define TF_RCVD_TSTMP 0x0100 /* a timestamp was received in SYN */
152 1.8 mycroft #define TF_SACK_PERMIT 0x0200 /* other side said I could SACK */
153 1.37 thorpej #define TF_SYN_REXMT 0x0400 /* rexmit timer fired on SYN */
154 1.43 matt #define TF_WILL_SACK 0x0800 /* try to use SACK */
155 1.43 matt #define TF_CANT_TXSACK 0x1000 /* other side said I could not SACK */
156 1.43 matt #define TF_IGNR_RXSACK 0x2000 /* ignore received SACK blocks */
157 1.56 thorpej #define TF_REASSEMBLING 0x4000 /* we're busy reassembling */
158 1.43 matt
159 1.8 mycroft
160 1.61 itojun struct mbuf *t_template; /* skeletal packet for transmit */
161 1.1 cgd struct inpcb *t_inpcb; /* back pointer to internet pcb */
162 1.61 itojun struct in6pcb *t_in6pcb; /* back pointer to internet pcb */
163 1.32 thorpej LIST_ENTRY(tcpcb) t_delack; /* delayed ACK queue */
164 1.1 cgd /*
165 1.1 cgd * The following fields are used as in the protocol specification.
166 1.1 cgd * See RFC783, Dec. 1981, page 21.
167 1.1 cgd */
168 1.1 cgd /* send sequence variables */
169 1.1 cgd tcp_seq snd_una; /* send unacknowledged */
170 1.1 cgd tcp_seq snd_nxt; /* send next */
171 1.1 cgd tcp_seq snd_up; /* send urgent pointer */
172 1.1 cgd tcp_seq snd_wl1; /* window update seg seq number */
173 1.1 cgd tcp_seq snd_wl2; /* window update seg ack number */
174 1.1 cgd tcp_seq iss; /* initial send sequence number */
175 1.8 mycroft u_long snd_wnd; /* send window */
176 1.54 matt tcp_seq snd_recover; /* for use in fast recovery */
177 1.1 cgd /* receive sequence variables */
178 1.8 mycroft u_long rcv_wnd; /* receive window */
179 1.1 cgd tcp_seq rcv_nxt; /* receive next */
180 1.1 cgd tcp_seq rcv_up; /* receive urgent pointer */
181 1.1 cgd tcp_seq irs; /* initial receive sequence number */
182 1.1 cgd /*
183 1.1 cgd * Additional variables for this implementation.
184 1.1 cgd */
185 1.1 cgd /* receive variables */
186 1.1 cgd tcp_seq rcv_adv; /* advertised window */
187 1.1 cgd /* retransmit variables */
188 1.1 cgd tcp_seq snd_max; /* highest sequence number sent;
189 1.1 cgd * used to recognize retransmits
190 1.1 cgd */
191 1.1 cgd /* congestion control (for slow start, source quench, retransmit after loss) */
192 1.8 mycroft u_long snd_cwnd; /* congestion-controlled window */
193 1.8 mycroft u_long snd_ssthresh; /* snd_cwnd size threshhold for
194 1.1 cgd * for slow start exponential to
195 1.1 cgd * linear switch
196 1.1 cgd */
197 1.1 cgd /*
198 1.1 cgd * transmit timing stuff. See below for scale of srtt and rttvar.
199 1.1 cgd * "Variance" is actually smoothed difference.
200 1.1 cgd */
201 1.1 cgd short t_idle; /* inactivity time */
202 1.1 cgd short t_rtt; /* round trip time */
203 1.1 cgd tcp_seq t_rtseq; /* sequence number being timed */
204 1.1 cgd short t_srtt; /* smoothed round-trip time */
205 1.1 cgd short t_rttvar; /* variance in round-trip time */
206 1.22 gwr short t_rttmin; /* minimum rtt allowed */
207 1.8 mycroft u_long max_sndwnd; /* largest window peer has offered */
208 1.1 cgd
209 1.1 cgd /* out-of-band data */
210 1.1 cgd char t_oobflags; /* have some */
211 1.1 cgd char t_iobc; /* input character */
212 1.1 cgd #define TCPOOB_HAVEDATA 0x01
213 1.1 cgd #define TCPOOB_HADDATA 0x02
214 1.1 cgd short t_softerror; /* possible error not yet reported */
215 1.8 mycroft
216 1.8 mycroft /* RFC 1323 variables */
217 1.8 mycroft u_char snd_scale; /* window scaling for send window */
218 1.8 mycroft u_char rcv_scale; /* window scaling for recv window */
219 1.8 mycroft u_char request_r_scale; /* pending window scaling */
220 1.8 mycroft u_char requested_s_scale;
221 1.11 cgd u_int32_t ts_recent; /* timestamp echo data */
222 1.43 matt u_int32_t ts_recent_age; /* when last updated */
223 1.8 mycroft tcp_seq last_ack_sent;
224 1.8 mycroft
225 1.43 matt /* SACK stuff */
226 1.43 matt struct ipqehead timeq; /* time sequenced queue (for SACK) */
227 1.1 cgd };
228 1.56 thorpej
229 1.56 thorpej #ifdef _KERNEL
230 1.56 thorpej /*
231 1.56 thorpej * TCP reassembly queue locks.
232 1.56 thorpej */
233 1.56 thorpej static __inline int tcp_reass_lock_try __P((struct tcpcb *))
234 1.56 thorpej __attribute__((__unused__));
235 1.56 thorpej static __inline void tcp_reass_unlock __P((struct tcpcb *))
236 1.56 thorpej __attribute__((__unused__));
237 1.56 thorpej
238 1.56 thorpej static __inline int
239 1.56 thorpej tcp_reass_lock_try(tp)
240 1.56 thorpej struct tcpcb *tp;
241 1.56 thorpej {
242 1.56 thorpej int s;
243 1.56 thorpej
244 1.56 thorpej s = splimp();
245 1.56 thorpej if (tp->t_flags & TF_REASSEMBLING) {
246 1.56 thorpej splx(s);
247 1.56 thorpej return (0);
248 1.56 thorpej }
249 1.56 thorpej tp->t_flags |= TF_REASSEMBLING;
250 1.56 thorpej splx(s);
251 1.56 thorpej return (1);
252 1.56 thorpej }
253 1.56 thorpej
254 1.56 thorpej static __inline void
255 1.56 thorpej tcp_reass_unlock(tp)
256 1.56 thorpej struct tcpcb *tp;
257 1.56 thorpej {
258 1.56 thorpej int s;
259 1.56 thorpej
260 1.56 thorpej s = splimp();
261 1.56 thorpej tp->t_flags &= ~TF_REASSEMBLING;
262 1.56 thorpej splx(s);
263 1.56 thorpej }
264 1.56 thorpej
265 1.56 thorpej #ifdef DIAGNOSTIC
266 1.56 thorpej #define TCP_REASS_LOCK(tp) \
267 1.56 thorpej do { \
268 1.56 thorpej if (tcp_reass_lock_try(tp) == 0) { \
269 1.56 thorpej printf("%s:%d: tcpcb %p reass already locked\n", \
270 1.56 thorpej __FILE__, __LINE__, tp); \
271 1.56 thorpej panic("tcp_reass_lock"); \
272 1.56 thorpej } \
273 1.56 thorpej } while (0)
274 1.56 thorpej #define TCP_REASS_LOCK_CHECK(tp) \
275 1.56 thorpej do { \
276 1.56 thorpej if (((tp)->t_flags & TF_REASSEMBLING) == 0) { \
277 1.56 thorpej printf("%s:%d: tcpcb %p reass lock not held\n", \
278 1.56 thorpej __FILE__, __LINE__, tp); \
279 1.56 thorpej panic("tcp reass lock check"); \
280 1.56 thorpej } \
281 1.56 thorpej } while (0)
282 1.56 thorpej #else
283 1.56 thorpej #define TCP_REASS_LOCK(tp) (void) tcp_reass_lock_try((tp))
284 1.56 thorpej #define TCP_REASS_LOCK_CHECK(tp) /* nothing */
285 1.56 thorpej #endif
286 1.56 thorpej
287 1.56 thorpej #define TCP_REASS_UNLOCK(tp) tcp_reass_unlock((tp))
288 1.56 thorpej #endif /* _KERNEL */
289 1.32 thorpej
290 1.32 thorpej /*
291 1.32 thorpej * Queue for delayed ACK processing.
292 1.32 thorpej */
293 1.32 thorpej LIST_HEAD(tcp_delack_head, tcpcb);
294 1.32 thorpej #ifdef _KERNEL
295 1.32 thorpej extern struct tcp_delack_head tcp_delacks;
296 1.32 thorpej
297 1.32 thorpej #define TCP_SET_DELACK(tp) \
298 1.32 thorpej do { \
299 1.32 thorpej if (((tp)->t_flags & TF_DELACK) == 0) { \
300 1.32 thorpej (tp)->t_flags |= TF_DELACK; \
301 1.32 thorpej LIST_INSERT_HEAD(&tcp_delacks, (tp), t_delack); \
302 1.32 thorpej } \
303 1.32 thorpej } while (0)
304 1.32 thorpej
305 1.32 thorpej #define TCP_CLEAR_DELACK(tp) \
306 1.32 thorpej do { \
307 1.32 thorpej if ((tp)->t_flags & TF_DELACK) { \
308 1.32 thorpej (tp)->t_flags &= ~TF_DELACK; \
309 1.32 thorpej LIST_REMOVE((tp), t_delack); \
310 1.32 thorpej } \
311 1.32 thorpej } while (0)
312 1.32 thorpej #endif /* _KERNEL */
313 1.1 cgd
314 1.20 thorpej /*
315 1.20 thorpej * Handy way of passing around TCP option info.
316 1.20 thorpej */
317 1.20 thorpej struct tcp_opt_info {
318 1.20 thorpej int ts_present;
319 1.20 thorpej u_int32_t ts_val;
320 1.20 thorpej u_int32_t ts_ecr;
321 1.20 thorpej u_int16_t maxseg;
322 1.20 thorpej };
323 1.20 thorpej
324 1.20 thorpej /*
325 1.38 thorpej * Data for the TCP compressed state engine.
326 1.20 thorpej */
327 1.61 itojun union syn_cache_sa {
328 1.61 itojun struct sockaddr sa;
329 1.61 itojun struct sockaddr_in sin;
330 1.61 itojun #if 1 /*def INET6*/
331 1.61 itojun struct sockaddr_in6 sin6;
332 1.61 itojun #endif
333 1.61 itojun };
334 1.61 itojun
335 1.20 thorpej struct syn_cache {
336 1.59 thorpej LIST_ENTRY(syn_cache) sc_bucketq; /* link on bucket list */
337 1.59 thorpej TAILQ_ENTRY(syn_cache) sc_timeq; /* link on timer queue */
338 1.61 itojun union { /* cached route */
339 1.61 itojun struct route route4;
340 1.61 itojun #ifdef INET6
341 1.61 itojun struct route_in6 route6;
342 1.61 itojun #endif
343 1.61 itojun } sc_route_u;
344 1.61 itojun #define sc_route4 sc_route_u.route4
345 1.61 itojun #ifdef INET6
346 1.61 itojun #define sc_route6 sc_route_u.route6
347 1.61 itojun #endif
348 1.59 thorpej long sc_win; /* advertised window */
349 1.59 thorpej int sc_bucketidx; /* our bucket index */
350 1.39 thorpej u_int32_t sc_hash;
351 1.59 thorpej u_int32_t sc_timestamp; /* timestamp from SYN */
352 1.61 itojun union syn_cache_sa sc_src;
353 1.61 itojun union syn_cache_sa sc_dst;
354 1.20 thorpej tcp_seq sc_irs;
355 1.20 thorpej tcp_seq sc_iss;
356 1.59 thorpej u_int sc_rexmt; /* retransmit timer */
357 1.59 thorpej u_int sc_rxtcur; /* current rxt timeout */
358 1.59 thorpej u_int sc_rxttot; /* total time spend on queues */
359 1.59 thorpej u_short sc_rxtshift; /* for computing backoff */
360 1.52 thorpej u_short sc_flags;
361 1.37 thorpej
362 1.52 thorpej #define SCF_UNREACH 0x0001 /* we've had an unreach error */
363 1.39 thorpej #define SCF_TIMESTAMP 0x0002 /* peer will do timestamps */
364 1.37 thorpej
365 1.40 thorpej struct mbuf *sc_ipopts; /* IP options */
366 1.20 thorpej u_int16_t sc_peermaxseg;
367 1.23 thorpej u_int16_t sc_ourmaxseg;
368 1.20 thorpej u_int8_t sc_request_r_scale : 4,
369 1.20 thorpej sc_requested_s_scale : 4;
370 1.61 itojun struct socket *sc_so; /* listening socket */
371 1.20 thorpej };
372 1.20 thorpej
373 1.20 thorpej struct syn_cache_head {
374 1.59 thorpej LIST_HEAD(, syn_cache) sch_bucket; /* bucket entries */
375 1.49 thorpej u_short sch_length; /* # entries in bucket */
376 1.20 thorpej };
377 1.20 thorpej
378 1.1 cgd #define intotcpcb(ip) ((struct tcpcb *)(ip)->inp_ppcb)
379 1.61 itojun #ifdef INET6
380 1.61 itojun #define in6totcpcb(ip) ((struct tcpcb *)(ip)->in6p_ppcb)
381 1.61 itojun #endif
382 1.61 itojun #ifndef INET6
383 1.1 cgd #define sototcpcb(so) (intotcpcb(sotoinpcb(so)))
384 1.61 itojun #else
385 1.66 itojun #define sototcpcb(so) (((so)->so_proto->pr_domain->dom_family == AF_INET) \
386 1.66 itojun ? intotcpcb(sotoinpcb(so)) \
387 1.66 itojun : in6totcpcb(sotoin6pcb(so)))
388 1.61 itojun #endif
389 1.1 cgd
390 1.1 cgd /*
391 1.1 cgd * The smoothed round-trip time and estimated variance
392 1.1 cgd * are stored as fixed point numbers scaled by the values below.
393 1.1 cgd * For convenience, these scales are also used in smoothing the average
394 1.1 cgd * (smoothed = (1/scale)sample + ((scale-1)/scale)smoothed).
395 1.1 cgd * With these scales, srtt has 3 bits to the right of the binary point,
396 1.1 cgd * and thus an "ALPHA" of 0.875. rttvar has 2 bits to the right of the
397 1.1 cgd * binary point, and is smoothed with an ALPHA of 0.75.
398 1.1 cgd */
399 1.1 cgd #define TCP_RTT_SHIFT 3 /* shift for srtt; 3 bits frac. */
400 1.1 cgd #define TCP_RTTVAR_SHIFT 2 /* multiplier for rttvar; 2 bits */
401 1.1 cgd
402 1.1 cgd /*
403 1.1 cgd * The initial retransmission should happen at rtt + 4 * rttvar.
404 1.1 cgd * Because of the way we do the smoothing, srtt and rttvar
405 1.1 cgd * will each average +1/2 tick of bias. When we compute
406 1.1 cgd * the retransmit timer, we want 1/2 tick of rounding and
407 1.1 cgd * 1 extra tick because of +-1/2 tick uncertainty in the
408 1.1 cgd * firing of the timer. The bias will give us exactly the
409 1.1 cgd * 1.5 tick we need. But, because the bias is
410 1.1 cgd * statistical, we have to test that we don't drop below
411 1.1 cgd * the minimum feasible timer (which is 2 ticks).
412 1.19 mycroft * This macro assumes that the value of 1<<TCP_RTTVAR_SHIFT
413 1.1 cgd * is the same as the multiplier for rttvar.
414 1.1 cgd */
415 1.1 cgd #define TCP_REXMTVAL(tp) \
416 1.12 mycroft ((((tp)->t_srtt >> TCP_RTT_SHIFT) + (tp)->t_rttvar) >> 2)
417 1.1 cgd
418 1.29 thorpej /*
419 1.29 thorpej * Compute the initial window for slow start.
420 1.29 thorpej */
421 1.37 thorpej #define TCP_INITIAL_WINDOW(iw, segsz) \
422 1.37 thorpej (((iw) == 0) ? (min(4 * (segsz), max(2 * (segsz), 4380))) : \
423 1.37 thorpej ((segsz) * (iw)))
424 1.29 thorpej
425 1.1 cgd /*
426 1.1 cgd * TCP statistics.
427 1.1 cgd * Many of these should be kept per connection,
428 1.1 cgd * but that's inconvenient at the moment.
429 1.1 cgd */
430 1.1 cgd struct tcpstat {
431 1.1 cgd u_long tcps_connattempt; /* connections initiated */
432 1.1 cgd u_long tcps_accepts; /* connections accepted */
433 1.1 cgd u_long tcps_connects; /* connections established */
434 1.1 cgd u_long tcps_drops; /* connections dropped */
435 1.1 cgd u_long tcps_conndrops; /* embryonic connections dropped */
436 1.1 cgd u_long tcps_closed; /* conn. closed (includes drops) */
437 1.1 cgd u_long tcps_segstimed; /* segs where we tried to get rtt */
438 1.1 cgd u_long tcps_rttupdated; /* times we succeeded */
439 1.1 cgd u_long tcps_delack; /* delayed acks sent */
440 1.1 cgd u_long tcps_timeoutdrop; /* conn. dropped in rxmt timeout */
441 1.1 cgd u_long tcps_rexmttimeo; /* retransmit timeouts */
442 1.1 cgd u_long tcps_persisttimeo; /* persist timeouts */
443 1.1 cgd u_long tcps_keeptimeo; /* keepalive timeouts */
444 1.1 cgd u_long tcps_keepprobe; /* keepalive probes sent */
445 1.1 cgd u_long tcps_keepdrops; /* connections dropped in keepalive */
446 1.31 thorpej u_long tcps_persistdrops; /* connections dropped in persist */
447 1.27 thorpej u_long tcps_connsdrained; /* connections drained due to memory
448 1.27 thorpej shortage */
449 1.1 cgd
450 1.1 cgd u_long tcps_sndtotal; /* total packets sent */
451 1.1 cgd u_long tcps_sndpack; /* data packets sent */
452 1.1 cgd u_long tcps_sndbyte; /* data bytes sent */
453 1.1 cgd u_long tcps_sndrexmitpack; /* data packets retransmitted */
454 1.1 cgd u_long tcps_sndrexmitbyte; /* data bytes retransmitted */
455 1.1 cgd u_long tcps_sndacks; /* ack-only packets sent */
456 1.1 cgd u_long tcps_sndprobe; /* window probes sent */
457 1.1 cgd u_long tcps_sndurg; /* packets sent with URG only */
458 1.1 cgd u_long tcps_sndwinup; /* window update-only packets sent */
459 1.1 cgd u_long tcps_sndctrl; /* control (SYN|FIN|RST) packets sent */
460 1.1 cgd
461 1.1 cgd u_long tcps_rcvtotal; /* total packets received */
462 1.1 cgd u_long tcps_rcvpack; /* packets received in sequence */
463 1.1 cgd u_long tcps_rcvbyte; /* bytes received in sequence */
464 1.1 cgd u_long tcps_rcvbadsum; /* packets received with ccksum errs */
465 1.1 cgd u_long tcps_rcvbadoff; /* packets received with bad offset */
466 1.15 cgd u_long tcps_rcvmemdrop; /* packets dropped for lack of memory */
467 1.1 cgd u_long tcps_rcvshort; /* packets received too short */
468 1.1 cgd u_long tcps_rcvduppack; /* duplicate-only packets received */
469 1.1 cgd u_long tcps_rcvdupbyte; /* duplicate-only bytes received */
470 1.1 cgd u_long tcps_rcvpartduppack; /* packets with some duplicate data */
471 1.1 cgd u_long tcps_rcvpartdupbyte; /* dup. bytes in part-dup. packets */
472 1.1 cgd u_long tcps_rcvoopack; /* out-of-order packets received */
473 1.1 cgd u_long tcps_rcvoobyte; /* out-of-order bytes received */
474 1.1 cgd u_long tcps_rcvpackafterwin; /* packets with data after window */
475 1.1 cgd u_long tcps_rcvbyteafterwin; /* bytes rcvd after window */
476 1.1 cgd u_long tcps_rcvafterclose; /* packets rcvd after "close" */
477 1.1 cgd u_long tcps_rcvwinprobe; /* rcvd window probe packets */
478 1.1 cgd u_long tcps_rcvdupack; /* rcvd duplicate acks */
479 1.1 cgd u_long tcps_rcvacktoomuch; /* rcvd acks for unsent data */
480 1.1 cgd u_long tcps_rcvackpack; /* rcvd ack packets */
481 1.1 cgd u_long tcps_rcvackbyte; /* bytes acked by rcvd acks */
482 1.1 cgd u_long tcps_rcvwinupd; /* rcvd window update packets */
483 1.8 mycroft u_long tcps_pawsdrop; /* segments dropped due to PAWS */
484 1.8 mycroft u_long tcps_predack; /* times hdr predict ok for acks */
485 1.8 mycroft u_long tcps_preddat; /* times hdr predict ok for data pkts */
486 1.16 mycroft
487 1.16 mycroft u_long tcps_pcbhashmiss; /* input packets missing pcb hash */
488 1.16 mycroft u_long tcps_noport; /* no socket on port */
489 1.20 thorpej u_long tcps_badsyn; /* received ack for which we have
490 1.20 thorpej no SYN in compressed state */
491 1.20 thorpej
492 1.20 thorpej /* These statistics deal with the SYN cache. */
493 1.20 thorpej u_long tcps_sc_added; /* # of entries added */
494 1.20 thorpej u_long tcps_sc_completed; /* # of connections completed */
495 1.20 thorpej u_long tcps_sc_timed_out; /* # of entries timed out */
496 1.20 thorpej u_long tcps_sc_overflowed; /* # dropped due to overflow */
497 1.20 thorpej u_long tcps_sc_reset; /* # dropped due to RST */
498 1.20 thorpej u_long tcps_sc_unreach; /* # dropped due to ICMP unreach */
499 1.20 thorpej u_long tcps_sc_bucketoverflow; /* # dropped due to bucket overflow */
500 1.20 thorpej u_long tcps_sc_aborted; /* # of entries aborted (no mem) */
501 1.20 thorpej u_long tcps_sc_dupesyn; /* # of duplicate SYNs received */
502 1.20 thorpej u_long tcps_sc_dropped; /* # of SYNs dropped (no route/mem) */
503 1.20 thorpej u_long tcps_sc_collisions; /* # of hash collisions */
504 1.59 thorpej u_long tcps_sc_retransmitted; /* # of retransmissions */
505 1.1 cgd };
506 1.1 cgd
507 1.14 thorpej /*
508 1.14 thorpej * Names for TCP sysctl objects.
509 1.14 thorpej */
510 1.21 thorpej #define TCPCTL_RFC1323 1 /* RFC1323 timestamps/scaling */
511 1.21 thorpej #define TCPCTL_SENDSPACE 2 /* default send buffer */
512 1.21 thorpej #define TCPCTL_RECVSPACE 3 /* default recv buffer */
513 1.21 thorpej #define TCPCTL_MSSDFLT 4 /* default seg size */
514 1.21 thorpej #define TCPCTL_SYN_CACHE_LIMIT 5 /* max size of comp. state engine */
515 1.21 thorpej #define TCPCTL_SYN_BUCKET_LIMIT 6 /* max size of hash bucket */
516 1.21 thorpej #define TCPCTL_SYN_CACHE_INTER 7 /* interval of comp. state timer */
517 1.29 thorpej #define TCPCTL_INIT_WIN 8 /* initial window */
518 1.41 kml #define TCPCTL_MSS_IFMTU 9 /* mss from interface, not in_maxmtu */
519 1.43 matt #define TCPCTL_SACK 10 /* RFC2018 selective acknowledgement */
520 1.43 matt #define TCPCTL_WSCALE 11 /* RFC1323 window scaling */
521 1.43 matt #define TCPCTL_TSTAMP 12 /* RFC1323 timestamps */
522 1.44 thorpej #define TCPCTL_COMPAT_42 13 /* 4.2BSD TCP bug work-arounds */
523 1.45 thorpej #define TCPCTL_CWM 14 /* Congestion Window Monitoring */
524 1.45 thorpej #define TCPCTL_CWM_BURSTSIZE 15 /* burst size allowed by CWM */
525 1.47 thorpej #define TCPCTL_ACK_ON_PUSH 16 /* ACK immediately on PUSH */
526 1.53 mouse #define TCPCTL_KEEPIDLE 17 /* keepalive idle time */
527 1.53 mouse #define TCPCTL_KEEPINTVL 18 /* keepalive probe interval */
528 1.53 mouse #define TCPCTL_KEEPCNT 19 /* keepalive count */
529 1.53 mouse #define TCPCTL_SLOWHZ 20 /* PR_SLOWHZ (read-only) */
530 1.55 matt #define TCPCTL_NEWRENO 21 /* NewReno Congestion Control */
531 1.60 ad #define TCPCTL_LOG_REFUSED 22 /* Log refused connections */
532 1.60 ad #define TCPCTL_MAXID 23
533 1.14 thorpej
534 1.14 thorpej #define TCPCTL_NAMES { \
535 1.14 thorpej { 0, 0 }, \
536 1.14 thorpej { "rfc1323", CTLTYPE_INT }, \
537 1.21 thorpej { "sendspace", CTLTYPE_INT }, \
538 1.21 thorpej { "recvspace", CTLTYPE_INT }, \
539 1.21 thorpej { "mssdflt", CTLTYPE_INT }, \
540 1.21 thorpej { "syn_cache_limit", CTLTYPE_INT }, \
541 1.21 thorpej { "syn_bucket_limit", CTLTYPE_INT }, \
542 1.21 thorpej { "syn_cache_interval", CTLTYPE_INT },\
543 1.29 thorpej { "init_win", CTLTYPE_INT }, \
544 1.41 kml { "mss_ifmtu", CTLTYPE_INT }, \
545 1.43 matt { "sack", CTLTYPE_INT }, \
546 1.43 matt { "win_scale", CTLTYPE_INT }, \
547 1.43 matt { "timestamps", CTLTYPE_INT }, \
548 1.44 thorpej { "compat_42", CTLTYPE_INT }, \
549 1.45 thorpej { "cwm", CTLTYPE_INT }, \
550 1.45 thorpej { "cwm_burstsize", CTLTYPE_INT }, \
551 1.47 thorpej { "ack_on_push", CTLTYPE_INT }, \
552 1.53 mouse { "keepidle", CTLTYPE_INT }, \
553 1.53 mouse { "keepintvl", CTLTYPE_INT }, \
554 1.53 mouse { "keepcnt", CTLTYPE_INT }, \
555 1.53 mouse { "slowhz", CTLTYPE_INT }, \
556 1.55 matt { "newreno", CTLTYPE_INT }, \
557 1.60 ad { "log_refused",CTLTYPE_INT }, \
558 1.14 thorpej }
559 1.14 thorpej
560 1.10 jtc #ifdef _KERNEL
561 1.13 mycroft struct inpcbtable tcbtable; /* head of queue of active tcpcb's */
562 1.61 itojun #ifdef INET6
563 1.61 itojun extern struct in6pcb tcb6;
564 1.61 itojun #endif
565 1.1 cgd struct tcpstat tcpstat; /* tcp statistics */
566 1.11 cgd u_int32_t tcp_now; /* for RFC 1323 timestamps */
567 1.14 thorpej extern int tcp_do_rfc1323; /* enabled/disabled? */
568 1.43 matt extern int tcp_do_sack; /* SACK enabled/disabled? */
569 1.43 matt extern int tcp_do_win_scale; /* RFC1323 window scaling enabled/disabled? */
570 1.43 matt extern int tcp_do_timestamps; /* RFC1323 timestamps enabled/disabled? */
571 1.55 matt extern int tcp_do_newreno; /* Use the New Reno algorithms */
572 1.21 thorpej extern int tcp_mssdflt; /* default seg size */
573 1.29 thorpej extern int tcp_init_win; /* initial window */
574 1.41 kml extern int tcp_mss_ifmtu; /* take MSS from interface, not in_maxmtu */
575 1.42 thorpej extern int tcp_compat_42; /* work around ancient broken TCP peers */
576 1.45 thorpej extern int tcp_cwm; /* enable Congestion Window Monitoring */
577 1.45 thorpej extern int tcp_cwm_burstsize; /* burst size allowed by CWM */
578 1.47 thorpej extern int tcp_ack_on_push; /* ACK immediately on PUSH */
579 1.21 thorpej extern int tcp_syn_cache_limit; /* max entries for compressed state engine */
580 1.21 thorpej extern int tcp_syn_bucket_limit;/* max entries per hash bucket */
581 1.21 thorpej extern int tcp_syn_cache_interval; /* compressed state timer */
582 1.60 ad extern int tcp_log_refused; /* log refused connections */
583 1.21 thorpej
584 1.21 thorpej extern int tcp_syn_cache_size;
585 1.49 thorpej extern struct syn_cache_head tcp_syn_cache[];
586 1.21 thorpej extern u_long syn_cache_count;
587 1.43 matt
588 1.43 matt #define TCPCTL_VARIABLES { \
589 1.53 mouse { 0 }, \
590 1.53 mouse { 1, 0, &tcp_do_rfc1323 }, \
591 1.53 mouse { 1, 0, &tcp_sendspace }, \
592 1.53 mouse { 1, 0, &tcp_recvspace }, \
593 1.53 mouse { 1, 0, &tcp_mssdflt }, \
594 1.53 mouse { 1, 0, &tcp_syn_cache_limit }, \
595 1.53 mouse { 1, 0, &tcp_syn_bucket_limit }, \
596 1.53 mouse { 1, 0, &tcp_syn_cache_interval }, \
597 1.53 mouse { 1, 0, &tcp_init_win }, \
598 1.53 mouse { 1, 0, &tcp_mss_ifmtu }, \
599 1.53 mouse { 1, 0, &tcp_do_sack }, \
600 1.53 mouse { 1, 0, &tcp_do_win_scale }, \
601 1.53 mouse { 1, 0, &tcp_do_timestamps }, \
602 1.53 mouse { 1, 0, &tcp_compat_42 }, \
603 1.53 mouse { 1, 0, &tcp_cwm }, \
604 1.53 mouse { 1, 0, &tcp_cwm_burstsize }, \
605 1.53 mouse { 1, 0, &tcp_ack_on_push }, \
606 1.53 mouse { 1, 0, &tcp_keepidle }, \
607 1.53 mouse { 1, 0, &tcp_keepintvl }, \
608 1.53 mouse { 1, 0, &tcp_keepcnt }, \
609 1.53 mouse { 1, 1, 0, PR_SLOWHZ }, \
610 1.55 matt { 1, 0, &tcp_do_newreno }, \
611 1.60 ad { 1, 0, &tcp_log_refused }, \
612 1.43 matt }
613 1.20 thorpej
614 1.8 mycroft int tcp_attach __P((struct socket *));
615 1.8 mycroft void tcp_canceltimers __P((struct tcpcb *));
616 1.5 mycroft struct tcpcb *
617 1.8 mycroft tcp_close __P((struct tcpcb *));
618 1.61 itojun #if defined(INET6) && !defined(TCP6)
619 1.61 itojun void tcp6_ctlinput __P((int, struct sockaddr *, struct ip6_hdr *,
620 1.61 itojun struct mbuf *, int));
621 1.61 itojun #endif
622 1.17 christos void *tcp_ctlinput __P((int, struct sockaddr *, void *));
623 1.8 mycroft int tcp_ctloutput __P((int, struct socket *, int, int, struct mbuf **));
624 1.5 mycroft struct tcpcb *
625 1.8 mycroft tcp_disconnect __P((struct tcpcb *));
626 1.5 mycroft struct tcpcb *
627 1.8 mycroft tcp_drop __P((struct tcpcb *, int));
628 1.8 mycroft void tcp_dooptions __P((struct tcpcb *,
629 1.61 itojun u_char *, int, struct tcphdr *, struct tcp_opt_info *));
630 1.8 mycroft void tcp_drain __P((void));
631 1.23 thorpej void tcp_established __P((struct tcpcb *));
632 1.8 mycroft void tcp_fasttimo __P((void));
633 1.8 mycroft void tcp_init __P((void));
634 1.61 itojun #if defined(INET6) && !defined(TCP6)
635 1.61 itojun int tcp6_input __P((struct mbuf **, int *, int));
636 1.61 itojun #endif
637 1.17 christos void tcp_input __P((struct mbuf *, ...));
638 1.41 kml u_long tcp_mss_to_advertise __P((const struct ifnet *));
639 1.23 thorpej void tcp_mss_from_peer __P((struct tcpcb *, int));
640 1.25 kml void tcp_mtudisc __P((struct inpcb *, int));
641 1.64 itojun #if defined(INET6) && !defined(TCP6)
642 1.64 itojun void tcp6_mtudisc __P((struct in6pcb *, int));
643 1.64 itojun #endif
644 1.5 mycroft struct tcpcb *
645 1.61 itojun tcp_newtcpcb __P((int, void *));
646 1.8 mycroft void tcp_notify __P((struct inpcb *, int));
647 1.64 itojun #if defined(INET6) && !defined(TCP6)
648 1.64 itojun void tcp6_notify __P((struct in6pcb *, int));
649 1.64 itojun #endif
650 1.36 kml u_int tcp_optlen __P((struct tcpcb *));
651 1.8 mycroft int tcp_output __P((struct tcpcb *));
652 1.8 mycroft void tcp_pulloutofband __P((struct socket *,
653 1.61 itojun struct tcphdr *, struct mbuf *));
654 1.8 mycroft void tcp_quench __P((struct inpcb *, int));
655 1.64 itojun #if defined(INET6) && !defined(TCP6)
656 1.64 itojun void tcp6_quench __P((struct in6pcb *, int));
657 1.64 itojun #endif
658 1.61 itojun int tcp_reass __P((struct tcpcb *, struct tcphdr *, struct mbuf *, int *));
659 1.63 itojun int tcp_respond __P((struct tcpcb *, struct mbuf *, struct mbuf *,
660 1.63 itojun struct tcphdr *, tcp_seq, tcp_seq, int));
661 1.23 thorpej void tcp_rmx_rtt __P((struct tcpcb *));
662 1.8 mycroft void tcp_setpersist __P((struct tcpcb *));
663 1.8 mycroft void tcp_slowtimo __P((void));
664 1.61 itojun struct mbuf *
665 1.8 mycroft tcp_template __P((struct tcpcb *));
666 1.5 mycroft struct tcpcb *
667 1.8 mycroft tcp_timers __P((struct tcpcb *, int));
668 1.61 itojun void tcp_trace __P((int, int, struct tcpcb *, struct mbuf *, int));
669 1.5 mycroft struct tcpcb *
670 1.8 mycroft tcp_usrclosed __P((struct tcpcb *));
671 1.14 thorpej int tcp_sysctl __P((int *, u_int, void *, size_t *, void *, size_t));
672 1.8 mycroft int tcp_usrreq __P((struct socket *,
673 1.18 mycroft int, struct mbuf *, struct mbuf *, struct mbuf *, struct proc *));
674 1.8 mycroft void tcp_xmit_timer __P((struct tcpcb *, int));
675 1.24 explorer tcp_seq tcp_new_iss __P((void *, u_long, tcp_seq));
676 1.20 thorpej
677 1.61 itojun int syn_cache_add __P((struct sockaddr *, struct sockaddr *,
678 1.61 itojun struct tcphdr *, unsigned int, struct socket *,
679 1.61 itojun struct mbuf *, u_char *, int, struct tcp_opt_info *));
680 1.61 itojun void syn_cache_unreach __P((struct sockaddr *, struct sockaddr *,
681 1.61 itojun struct tcphdr *));
682 1.61 itojun struct socket *syn_cache_get __P((struct sockaddr *, struct sockaddr *,
683 1.61 itojun struct tcphdr *, unsigned int, unsigned int,
684 1.61 itojun struct socket *so, struct mbuf *));
685 1.49 thorpej void syn_cache_init __P((void));
686 1.49 thorpej void syn_cache_insert __P((struct syn_cache *));
687 1.61 itojun struct syn_cache *syn_cache_lookup __P((struct sockaddr *, struct sockaddr *,
688 1.61 itojun struct syn_cache_head **));
689 1.61 itojun void syn_cache_reset __P((struct sockaddr *, struct sockaddr *,
690 1.61 itojun struct tcphdr *));
691 1.59 thorpej int syn_cache_respond __P((struct syn_cache *, struct mbuf *));
692 1.49 thorpej void syn_cache_timer __P((void));
693 1.20 thorpej
694 1.61 itojun int tcp_newreno __P((struct tcpcb *, struct tcphdr *));
695 1.1 cgd #endif
696 1.34 perry
697 1.34 perry #endif /* _NETINET_TCP_VAR_H_ */
698