1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17#ifndef _LINUX_TCP_H
18#define _LINUX_TCP_H
19
20
21#include <linux/skbuff.h>
22#include <linux/win_minmax.h>
23#include <net/sock.h>
24#include <net/inet_connection_sock.h>
25#include <net/inet_timewait_sock.h>
26#include <uapi/linux/tcp.h>
27
28static inline struct tcphdr *tcp_hdr(const struct sk_buff *skb)
29{
30 return (struct tcphdr *)skb_transport_header(skb);
31}
32
33static inline unsigned int __tcp_hdrlen(const struct tcphdr *th)
34{
35 return th->doff * 4;
36}
37
38static inline unsigned int tcp_hdrlen(const struct sk_buff *skb)
39{
40 return __tcp_hdrlen(tcp_hdr(skb));
41}
42
43static inline struct tcphdr *inner_tcp_hdr(const struct sk_buff *skb)
44{
45 return (struct tcphdr *)skb_inner_transport_header(skb);
46}
47
48static inline unsigned int inner_tcp_hdrlen(const struct sk_buff *skb)
49{
50 return inner_tcp_hdr(skb)->doff * 4;
51}
52
53static inline unsigned int tcp_optlen(const struct sk_buff *skb)
54{
55 return (tcp_hdr(skb)->doff - 5) * 4;
56}
57
58
59#define TCP_FASTOPEN_COOKIE_MIN 4
60#define TCP_FASTOPEN_COOKIE_MAX 16
61#define TCP_FASTOPEN_COOKIE_SIZE 8
62
63
64struct tcp_fastopen_cookie {
65 union {
66 u8 val[TCP_FASTOPEN_COOKIE_MAX];
67#if IS_ENABLED(CONFIG_IPV6)
68 struct in6_addr addr;
69#endif
70 };
71 s8 len;
72 bool exp;
73};
74
75
76struct tcp_sack_block_wire {
77 __be32 start_seq;
78 __be32 end_seq;
79};
80
81struct tcp_sack_block {
82 u32 start_seq;
83 u32 end_seq;
84};
85
86
87#define TCP_SACK_SEEN (1 << 0)
88#define TCP_FACK_ENABLED (1 << 1)
89#define TCP_DSACK_SEEN (1 << 2)
90
91struct tcp_options_received {
92
93 long ts_recent_stamp;
94 u32 ts_recent;
95 u32 rcv_tsval;
96 u32 rcv_tsecr;
97 u16 saw_tstamp : 1,
98 tstamp_ok : 1,
99 dsack : 1,
100 wscale_ok : 1,
101 sack_ok : 4,
102 snd_wscale : 4,
103 rcv_wscale : 4;
104 u8 num_sacks;
105 u16 user_mss;
106 u16 mss_clamp;
107};
108
109static inline void tcp_clear_options(struct tcp_options_received *rx_opt)
110{
111 rx_opt->tstamp_ok = rx_opt->sack_ok = 0;
112 rx_opt->wscale_ok = rx_opt->snd_wscale = 0;
113}
114
115
116
117
118
119#define TCP_NUM_SACKS 4
120
121struct tcp_request_sock_ops;
122
123struct tcp_request_sock {
124 struct inet_request_sock req;
125 const struct tcp_request_sock_ops *af_specific;
126 struct skb_mstamp snt_synack;
127 bool tfo_listener;
128 u32 txhash;
129 u32 rcv_isn;
130 u32 snt_isn;
131 u32 ts_off;
132 u32 last_oow_ack_time;
133 u32 rcv_nxt;
134
135
136
137};
138
139static inline struct tcp_request_sock *tcp_rsk(const struct request_sock *req)
140{
141 return (struct tcp_request_sock *)req;
142}
143
144struct tcp_sock {
145
146 struct inet_connection_sock inet_conn;
147 u16 tcp_header_len;
148 u16 gso_segs;
149
150
151
152
153
154 __be32 pred_flags;
155
156
157
158
159
160
161 u64 bytes_received;
162
163
164
165 u32 segs_in;
166
167
168 u32 data_segs_in;
169
170
171 u32 rcv_nxt;
172 u32 copied_seq;
173 u32 rcv_wup;
174 u32 snd_nxt;
175 u32 segs_out;
176
177
178 u32 data_segs_out;
179
180
181 u64 bytes_acked;
182
183
184
185 u32 snd_una;
186 u32 snd_sml;
187 u32 rcv_tstamp;
188 u32 lsndtime;
189 u32 last_oow_ack_time;
190
191 u32 tsoffset;
192
193 struct list_head tsq_node;
194
195
196 struct {
197 struct sk_buff_head prequeue;
198 struct task_struct *task;
199 struct msghdr *msg;
200 int memory;
201 int len;
202 } ucopy;
203
204 u32 snd_wl1;
205 u32 snd_wnd;
206 u32 max_window;
207 u32 mss_cache;
208
209 u32 window_clamp;
210 u32 rcv_ssthresh;
211
212
213 struct tcp_rack {
214 struct skb_mstamp mstamp;
215 u8 advanced;
216 u8 reord;
217 } rack;
218 u16 advmss;
219 u32 chrono_start;
220 u32 chrono_stat[3];
221 u8 chrono_type:2,
222 rate_app_limited:1,
223 unused:5;
224 u8 nonagle : 4,
225 thin_lto : 1,
226 thin_dupack : 1,
227 repair : 1,
228 frto : 1;
229 u8 repair_queue;
230 u8 do_early_retrans:1,
231 syn_data:1,
232 syn_fastopen:1,
233 syn_fastopen_exp:1,
234 syn_data_acked:1,
235 save_syn:1,
236 is_cwnd_limited:1;
237 u32 tlp_high_seq;
238
239
240 u32 srtt_us;
241 u32 mdev_us;
242 u32 mdev_max_us;
243 u32 rttvar_us;
244 u32 rtt_seq;
245 struct minmax rtt_min;
246
247 u32 packets_out;
248 u32 retrans_out;
249 u32 max_packets_out;
250 u32 max_packets_seq;
251
252 u16 urg_data;
253 u8 ecn_flags;
254 u8 keepalive_probes;
255 u32 reordering;
256 u32 snd_up;
257
258
259
260
261 struct tcp_options_received rx_opt;
262
263
264
265
266 u32 snd_ssthresh;
267 u32 snd_cwnd;
268 u32 snd_cwnd_cnt;
269 u32 snd_cwnd_clamp;
270 u32 snd_cwnd_used;
271 u32 snd_cwnd_stamp;
272 u32 prior_cwnd;
273 u32 prr_delivered;
274
275 u32 prr_out;
276 u32 delivered;
277 u32 lost;
278 u32 app_limited;
279 struct skb_mstamp first_tx_mstamp;
280 struct skb_mstamp delivered_mstamp;
281 u32 rate_delivered;
282 u32 rate_interval_us;
283
284 u32 rcv_wnd;
285 u32 write_seq;
286 u32 notsent_lowat;
287 u32 pushed_seq;
288 u32 lost_out;
289 u32 sacked_out;
290 u32 fackets_out;
291
292
293 struct sk_buff* lost_skb_hint;
294 struct sk_buff *retransmit_skb_hint;
295
296
297 struct rb_root out_of_order_queue;
298 struct sk_buff *ooo_last_skb;
299
300
301 struct tcp_sack_block duplicate_sack[1];
302 struct tcp_sack_block selective_acks[4];
303
304 struct tcp_sack_block recv_sack_cache[4];
305
306 struct sk_buff *highest_sack;
307
308
309
310
311
312 int lost_cnt_hint;
313 u32 retransmit_high;
314
315 u32 prior_ssthresh;
316 u32 high_seq;
317
318 u32 retrans_stamp;
319
320
321 u32 undo_marker;
322 int undo_retrans;
323 u32 total_retrans;
324
325 u32 urg_seq;
326 unsigned int keepalive_time;
327 unsigned int keepalive_intvl;
328
329 int linger2;
330
331
332 struct {
333 u32 rtt;
334 u32 seq;
335 u32 time;
336 } rcv_rtt_est;
337
338
339 struct {
340 int space;
341 u32 seq;
342 u32 time;
343 } rcvq_space;
344
345
346 struct {
347 u32 probe_seq_start;
348 u32 probe_seq_end;
349 } mtu_probe;
350 u32 mtu_info;
351
352
353
354#ifdef CONFIG_TCP_MD5SIG
355
356 const struct tcp_sock_af_ops *af_specific;
357
358
359 struct tcp_md5sig_info __rcu *md5sig_info;
360#endif
361
362
363 struct tcp_fastopen_request *fastopen_req;
364
365
366
367 struct request_sock *fastopen_rsk;
368 u32 *saved_syn;
369};
370
371enum tsq_enum {
372 TSQ_THROTTLED,
373 TSQ_QUEUED,
374 TCP_TSQ_DEFERRED,
375 TCP_WRITE_TIMER_DEFERRED,
376 TCP_DELACK_TIMER_DEFERRED,
377 TCP_MTU_REDUCED_DEFERRED,
378
379
380};
381
382enum tsq_flags {
383 TSQF_THROTTLED = (1UL << TSQ_THROTTLED),
384 TSQF_QUEUED = (1UL << TSQ_QUEUED),
385 TCPF_TSQ_DEFERRED = (1UL << TCP_TSQ_DEFERRED),
386 TCPF_WRITE_TIMER_DEFERRED = (1UL << TCP_WRITE_TIMER_DEFERRED),
387 TCPF_DELACK_TIMER_DEFERRED = (1UL << TCP_DELACK_TIMER_DEFERRED),
388 TCPF_MTU_REDUCED_DEFERRED = (1UL << TCP_MTU_REDUCED_DEFERRED),
389};
390
391static inline struct tcp_sock *tcp_sk(const struct sock *sk)
392{
393 return (struct tcp_sock *)sk;
394}
395
396struct tcp_timewait_sock {
397 struct inet_timewait_sock tw_sk;
398#define tw_rcv_nxt tw_sk.__tw_common.skc_tw_rcv_nxt
399#define tw_snd_nxt tw_sk.__tw_common.skc_tw_snd_nxt
400 u32 tw_rcv_wnd;
401 u32 tw_ts_offset;
402 u32 tw_ts_recent;
403
404
405 u32 tw_last_oow_ack_time;
406
407 long tw_ts_recent_stamp;
408#ifdef CONFIG_TCP_MD5SIG
409 struct tcp_md5sig_key *tw_md5_key;
410#endif
411};
412
413static inline struct tcp_timewait_sock *tcp_twsk(const struct sock *sk)
414{
415 return (struct tcp_timewait_sock *)sk;
416}
417
418static inline bool tcp_passive_fastopen(const struct sock *sk)
419{
420 return (sk->sk_state == TCP_SYN_RECV &&
421 tcp_sk(sk)->fastopen_rsk != NULL);
422}
423
424static inline void fastopen_queue_tune(struct sock *sk, int backlog)
425{
426 struct request_sock_queue *queue = &inet_csk(sk)->icsk_accept_queue;
427 int somaxconn = READ_ONCE(sock_net(sk)->core.sysctl_somaxconn);
428
429 queue->fastopenq.max_qlen = min_t(unsigned int, backlog, somaxconn);
430}
431
432static inline void tcp_move_syn(struct tcp_sock *tp,
433 struct request_sock *req)
434{
435 tp->saved_syn = req->saved_syn;
436 req->saved_syn = NULL;
437}
438
439static inline void tcp_saved_syn_free(struct tcp_sock *tp)
440{
441 kfree(tp->saved_syn);
442 tp->saved_syn = NULL;
443}
444
445struct sk_buff *tcp_get_timestamping_opt_stats(const struct sock *sk);
446
447#endif
448