1
2#ifndef _DCCP_H
3#define _DCCP_H
4
5
6
7
8
9
10
11
12#include <linux/dccp.h>
13#include <linux/ktime.h>
14#include <net/snmp.h>
15#include <net/sock.h>
16#include <net/tcp.h>
17#include "ackvec.h"
18
19
20
21
22#define DCCP_WARN(fmt, ...) \
23 net_warn_ratelimited("%s: " fmt, __func__, ##__VA_ARGS__)
24#define DCCP_CRIT(fmt, a...) printk(KERN_CRIT fmt " at %s:%d/%s()\n", ##a, \
25 __FILE__, __LINE__, __func__)
26#define DCCP_BUG(a...) do { DCCP_CRIT("BUG: " a); dump_stack(); } while(0)
27#define DCCP_BUG_ON(cond) do { if (unlikely((cond) != 0)) \
28 DCCP_BUG("\"%s\" holds (exception!)", \
29 __stringify(cond)); \
30 } while (0)
31
32#define DCCP_PRINTK(enable, fmt, args...) do { if (enable) \
33 printk(fmt, ##args); \
34 } while(0)
35#define DCCP_PR_DEBUG(enable, fmt, a...) DCCP_PRINTK(enable, KERN_DEBUG \
36 "%s: " fmt, __func__, ##a)
37
38#ifdef CONFIG_IP_DCCP_DEBUG
39extern bool dccp_debug;
40#define dccp_pr_debug(format, a...) DCCP_PR_DEBUG(dccp_debug, format, ##a)
41#define dccp_pr_debug_cat(format, a...) DCCP_PRINTK(dccp_debug, format, ##a)
42#define dccp_debug(fmt, a...) dccp_pr_debug_cat(KERN_DEBUG fmt, ##a)
43#else
44#define dccp_pr_debug(format, a...)
45#define dccp_pr_debug_cat(format, a...)
46#define dccp_debug(format, a...)
47#endif
48
49extern struct inet_hashinfo dccp_hashinfo;
50
51extern struct percpu_counter dccp_orphan_count;
52
53void dccp_time_wait(struct sock *sk, int state, int timeo);
54
55
56
57
58
59
60
61
62
63#define MAX_DCCP_SPECIFIC_HEADER (255 * sizeof(uint32_t))
64#define DCCP_MAX_PACKET_HDR 28
65#define DCCP_MAX_OPT_LEN (MAX_DCCP_SPECIFIC_HEADER - DCCP_MAX_PACKET_HDR)
66#define MAX_DCCP_HEADER (MAX_DCCP_SPECIFIC_HEADER + MAX_HEADER)
67
68
69#define DCCP_FEATNEG_OVERHEAD (32 * sizeof(uint32_t))
70
71#define DCCP_TIMEWAIT_LEN (60 * HZ)
72
73
74
75#define DCCP_TIMEOUT_INIT ((unsigned int)(3 * HZ))
76
77
78
79
80
81
82
83
84#define DCCP_RTO_MAX ((unsigned int)(64 * HZ))
85
86
87
88
89#define DCCP_SANE_RTT_MIN 100
90#define DCCP_FALLBACK_RTT (USEC_PER_SEC / 5)
91#define DCCP_SANE_RTT_MAX (3 * USEC_PER_SEC)
92
93
94extern int sysctl_dccp_request_retries;
95extern int sysctl_dccp_retries1;
96extern int sysctl_dccp_retries2;
97extern int sysctl_dccp_tx_qlen;
98extern int sysctl_dccp_sync_ratelimit;
99
100
101
102
103#define INT48_MIN 0x800000000000LL
104#define UINT48_MAX 0xFFFFFFFFFFFFLL
105#define COMPLEMENT48(x) (0x1000000000000LL - (x))
106#define TO_SIGNED48(x) (((x) < INT48_MIN)? (x) : -COMPLEMENT48( (x)))
107#define TO_UNSIGNED48(x) (((x) >= 0)? (x) : COMPLEMENT48(-(x)))
108#define ADD48(a, b) (((a) + (b)) & UINT48_MAX)
109#define SUB48(a, b) ADD48((a), COMPLEMENT48(b))
110
111static inline void dccp_inc_seqno(u64 *seqno)
112{
113 *seqno = ADD48(*seqno, 1);
114}
115
116
117static inline s64 dccp_delta_seqno(const u64 seqno1, const u64 seqno2)
118{
119 u64 delta = SUB48(seqno2, seqno1);
120
121 return TO_SIGNED48(delta);
122}
123
124
125static inline int before48(const u64 seq1, const u64 seq2)
126{
127 return (s64)((seq2 << 16) - (seq1 << 16)) > 0;
128}
129
130
131#define after48(seq1, seq2) before48(seq2, seq1)
132
133
134static inline int between48(const u64 seq1, const u64 seq2, const u64 seq3)
135{
136 return (seq3 << 16) - (seq2 << 16) >= (seq1 << 16) - (seq2 << 16);
137}
138
139static inline u64 max48(const u64 seq1, const u64 seq2)
140{
141 return after48(seq1, seq2) ? seq1 : seq2;
142}
143
144
145
146
147
148
149
150static inline u64 dccp_loss_count(const u64 s1, const u64 s2, const u64 ndp)
151{
152 s64 delta = dccp_delta_seqno(s1, s2);
153
154 WARN_ON(delta < 0);
155 delta -= ndp + 1;
156
157 return delta > 0 ? delta : 0;
158}
159
160
161
162
163static inline bool dccp_loss_free(const u64 s1, const u64 s2, const u64 ndp)
164{
165 return dccp_loss_count(s1, s2, ndp) == 0;
166}
167
168enum {
169 DCCP_MIB_NUM = 0,
170 DCCP_MIB_ACTIVEOPENS,
171 DCCP_MIB_ESTABRESETS,
172 DCCP_MIB_CURRESTAB,
173 DCCP_MIB_OUTSEGS,
174 DCCP_MIB_OUTRSTS,
175 DCCP_MIB_ABORTONTIMEOUT,
176 DCCP_MIB_TIMEOUTS,
177 DCCP_MIB_ABORTFAILED,
178 DCCP_MIB_PASSIVEOPENS,
179 DCCP_MIB_ATTEMPTFAILS,
180 DCCP_MIB_OUTDATAGRAMS,
181 DCCP_MIB_INERRS,
182 DCCP_MIB_OPTMANDATORYERROR,
183 DCCP_MIB_INVALIDOPT,
184 __DCCP_MIB_MAX
185};
186
187#define DCCP_MIB_MAX __DCCP_MIB_MAX
188struct dccp_mib {
189 unsigned long mibs[DCCP_MIB_MAX];
190};
191
192DECLARE_SNMP_STAT(struct dccp_mib, dccp_statistics);
193#define DCCP_INC_STATS(field) SNMP_INC_STATS(dccp_statistics, field)
194#define __DCCP_INC_STATS(field) __SNMP_INC_STATS(dccp_statistics, field)
195#define DCCP_DEC_STATS(field) SNMP_DEC_STATS(dccp_statistics, field)
196
197
198
199
200static inline unsigned int dccp_csum_coverage(const struct sk_buff *skb)
201{
202 const struct dccp_hdr* dh = dccp_hdr(skb);
203
204 if (dh->dccph_cscov == 0)
205 return skb->len;
206 return (dh->dccph_doff + dh->dccph_cscov - 1) * sizeof(u32);
207}
208
209static inline void dccp_csum_outgoing(struct sk_buff *skb)
210{
211 unsigned int cov = dccp_csum_coverage(skb);
212
213 if (cov >= skb->len)
214 dccp_hdr(skb)->dccph_cscov = 0;
215
216 skb->csum = skb_checksum(skb, 0, (cov > skb->len)? skb->len : cov, 0);
217}
218
219void dccp_v4_send_check(struct sock *sk, struct sk_buff *skb);
220
221int dccp_retransmit_skb(struct sock *sk);
222
223void dccp_send_ack(struct sock *sk);
224void dccp_reqsk_send_ack(const struct sock *sk, struct sk_buff *skb,
225 struct request_sock *rsk);
226
227void dccp_send_sync(struct sock *sk, const u64 seq,
228 const enum dccp_pkt_type pkt_type);
229
230
231
232
233void dccp_qpolicy_push(struct sock *sk, struct sk_buff *skb);
234bool dccp_qpolicy_full(struct sock *sk);
235void dccp_qpolicy_drop(struct sock *sk, struct sk_buff *skb);
236struct sk_buff *dccp_qpolicy_top(struct sock *sk);
237struct sk_buff *dccp_qpolicy_pop(struct sock *sk);
238bool dccp_qpolicy_param_ok(struct sock *sk, __be32 param);
239
240
241
242
243void dccp_write_xmit(struct sock *sk);
244void dccp_write_space(struct sock *sk);
245void dccp_flush_write_queue(struct sock *sk, long *time_budget);
246
247void dccp_init_xmit_timers(struct sock *sk);
248static inline void dccp_clear_xmit_timers(struct sock *sk)
249{
250 inet_csk_clear_xmit_timers(sk);
251}
252
253unsigned int dccp_sync_mss(struct sock *sk, u32 pmtu);
254
255const char *dccp_packet_name(const int type);
256
257void dccp_set_state(struct sock *sk, const int state);
258void dccp_done(struct sock *sk);
259
260int dccp_reqsk_init(struct request_sock *rq, struct dccp_sock const *dp,
261 struct sk_buff const *skb);
262
263int dccp_v4_conn_request(struct sock *sk, struct sk_buff *skb);
264
265struct sock *dccp_create_openreq_child(const struct sock *sk,
266 const struct request_sock *req,
267 const struct sk_buff *skb);
268
269int dccp_v4_do_rcv(struct sock *sk, struct sk_buff *skb);
270
271struct sock *dccp_v4_request_recv_sock(const struct sock *sk, struct sk_buff *skb,
272 struct request_sock *req,
273 struct dst_entry *dst,
274 struct request_sock *req_unhash,
275 bool *own_req);
276struct sock *dccp_check_req(struct sock *sk, struct sk_buff *skb,
277 struct request_sock *req);
278
279int dccp_child_process(struct sock *parent, struct sock *child,
280 struct sk_buff *skb);
281int dccp_rcv_state_process(struct sock *sk, struct sk_buff *skb,
282 struct dccp_hdr *dh, unsigned int len);
283int dccp_rcv_established(struct sock *sk, struct sk_buff *skb,
284 const struct dccp_hdr *dh, const unsigned int len);
285
286int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized);
287void dccp_destroy_sock(struct sock *sk);
288
289void dccp_close(struct sock *sk, long timeout);
290struct sk_buff *dccp_make_response(const struct sock *sk, struct dst_entry *dst,
291 struct request_sock *req);
292
293int dccp_connect(struct sock *sk);
294int dccp_disconnect(struct sock *sk, int flags);
295int dccp_getsockopt(struct sock *sk, int level, int optname,
296 char __user *optval, int __user *optlen);
297int dccp_setsockopt(struct sock *sk, int level, int optname,
298 char __user *optval, unsigned int optlen);
299#ifdef CONFIG_COMPAT
300int compat_dccp_getsockopt(struct sock *sk, int level, int optname,
301 char __user *optval, int __user *optlen);
302int compat_dccp_setsockopt(struct sock *sk, int level, int optname,
303 char __user *optval, unsigned int optlen);
304#endif
305int dccp_ioctl(struct sock *sk, int cmd, unsigned long arg);
306int dccp_sendmsg(struct sock *sk, struct msghdr *msg, size_t size);
307int dccp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, int nonblock,
308 int flags, int *addr_len);
309void dccp_shutdown(struct sock *sk, int how);
310int inet_dccp_listen(struct socket *sock, int backlog);
311__poll_t dccp_poll(struct file *file, struct socket *sock,
312 poll_table *wait);
313int dccp_v4_connect(struct sock *sk, struct sockaddr *uaddr, int addr_len);
314void dccp_req_err(struct sock *sk, u64 seq);
315
316struct sk_buff *dccp_ctl_make_reset(struct sock *sk, struct sk_buff *skb);
317int dccp_send_reset(struct sock *sk, enum dccp_reset_codes code);
318void dccp_send_close(struct sock *sk, const int active);
319int dccp_invalid_packet(struct sk_buff *skb);
320u32 dccp_sample_rtt(struct sock *sk, long delta);
321
322static inline bool dccp_bad_service_code(const struct sock *sk,
323 const __be32 service)
324{
325 const struct dccp_sock *dp = dccp_sk(sk);
326
327 if (dp->dccps_service == service)
328 return false;
329 return !dccp_list_has_service(dp->dccps_service_list, service);
330}
331
332
333
334
335
336
337
338
339
340
341
342
343
344struct dccp_skb_cb {
345 union {
346 struct inet_skb_parm h4;
347#if IS_ENABLED(CONFIG_IPV6)
348 struct inet6_skb_parm h6;
349#endif
350 } header;
351 __u8 dccpd_type:4;
352 __u8 dccpd_ccval:4;
353 __u8 dccpd_reset_code,
354 dccpd_reset_data[3];
355 __u16 dccpd_opt_len;
356 __u64 dccpd_seq;
357 __u64 dccpd_ack_seq;
358};
359
360#define DCCP_SKB_CB(__skb) ((struct dccp_skb_cb *)&((__skb)->cb[0]))
361
362
363static inline int dccp_non_data_packet(const struct sk_buff *skb)
364{
365 const __u8 type = DCCP_SKB_CB(skb)->dccpd_type;
366
367 return type == DCCP_PKT_ACK ||
368 type == DCCP_PKT_CLOSE ||
369 type == DCCP_PKT_CLOSEREQ ||
370 type == DCCP_PKT_RESET ||
371 type == DCCP_PKT_SYNC ||
372 type == DCCP_PKT_SYNCACK;
373}
374
375
376static inline int dccp_data_packet(const struct sk_buff *skb)
377{
378 const __u8 type = DCCP_SKB_CB(skb)->dccpd_type;
379
380 return type == DCCP_PKT_DATA ||
381 type == DCCP_PKT_DATAACK ||
382 type == DCCP_PKT_REQUEST ||
383 type == DCCP_PKT_RESPONSE;
384}
385
386static inline int dccp_packet_without_ack(const struct sk_buff *skb)
387{
388 const __u8 type = DCCP_SKB_CB(skb)->dccpd_type;
389
390 return type == DCCP_PKT_DATA || type == DCCP_PKT_REQUEST;
391}
392
393#define DCCP_PKT_WITHOUT_ACK_SEQ (UINT48_MAX << 2)
394
395static inline void dccp_hdr_set_seq(struct dccp_hdr *dh, const u64 gss)
396{
397 struct dccp_hdr_ext *dhx = (struct dccp_hdr_ext *)((void *)dh +
398 sizeof(*dh));
399 dh->dccph_seq2 = 0;
400 dh->dccph_seq = htons((gss >> 32) & 0xfffff);
401 dhx->dccph_seq_low = htonl(gss & 0xffffffff);
402}
403
404static inline void dccp_hdr_set_ack(struct dccp_hdr_ack_bits *dhack,
405 const u64 gsr)
406{
407 dhack->dccph_reserved1 = 0;
408 dhack->dccph_ack_nr_high = htons(gsr >> 32);
409 dhack->dccph_ack_nr_low = htonl(gsr & 0xffffffff);
410}
411
412static inline void dccp_update_gsr(struct sock *sk, u64 seq)
413{
414 struct dccp_sock *dp = dccp_sk(sk);
415
416 if (after48(seq, dp->dccps_gsr))
417 dp->dccps_gsr = seq;
418
419 dp->dccps_swl = SUB48(ADD48(dp->dccps_gsr, 1), dp->dccps_r_seq_win / 4);
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435 if (before48(dp->dccps_swl, dp->dccps_isr))
436 dp->dccps_swl = dp->dccps_isr;
437 dp->dccps_swh = ADD48(dp->dccps_gsr, (3 * dp->dccps_r_seq_win) / 4);
438}
439
440static inline void dccp_update_gss(struct sock *sk, u64 seq)
441{
442 struct dccp_sock *dp = dccp_sk(sk);
443
444 dp->dccps_gss = seq;
445
446 dp->dccps_awl = SUB48(ADD48(dp->dccps_gss, 1), dp->dccps_l_seq_win);
447
448 if (before48(dp->dccps_awl, dp->dccps_iss))
449 dp->dccps_awl = dp->dccps_iss;
450 dp->dccps_awh = dp->dccps_gss;
451}
452
453static inline int dccp_ackvec_pending(const struct sock *sk)
454{
455 return dccp_sk(sk)->dccps_hc_rx_ackvec != NULL &&
456 !dccp_ackvec_is_empty(dccp_sk(sk)->dccps_hc_rx_ackvec);
457}
458
459static inline int dccp_ack_pending(const struct sock *sk)
460{
461 return dccp_ackvec_pending(sk) || inet_csk_ack_scheduled(sk);
462}
463
464int dccp_feat_signal_nn_change(struct sock *sk, u8 feat, u64 nn_val);
465int dccp_feat_finalise_settings(struct dccp_sock *dp);
466int dccp_feat_server_ccid_dependencies(struct dccp_request_sock *dreq);
467int dccp_feat_insert_opts(struct dccp_sock*, struct dccp_request_sock*,
468 struct sk_buff *skb);
469int dccp_feat_activate_values(struct sock *sk, struct list_head *fn);
470void dccp_feat_list_purge(struct list_head *fn_list);
471
472int dccp_insert_options(struct sock *sk, struct sk_buff *skb);
473int dccp_insert_options_rsk(struct dccp_request_sock *, struct sk_buff *);
474u32 dccp_timestamp(void);
475void dccp_timestamping_init(void);
476int dccp_insert_option(struct sk_buff *skb, unsigned char option,
477 const void *value, unsigned char len);
478
479#ifdef CONFIG_SYSCTL
480int dccp_sysctl_init(void);
481void dccp_sysctl_exit(void);
482#else
483static inline int dccp_sysctl_init(void)
484{
485 return 0;
486}
487
488static inline void dccp_sysctl_exit(void)
489{
490}
491#endif
492
493#endif
494