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