dccp.h 13.8 KB
Newer Older
1 2 3 4 5 6
#ifndef _DCCP_H
#define _DCCP_H
/*
 *  net/dccp/dccp.h
 *
 *  An implementation of the DCCP protocol
I
Ian McDonald 已提交
7
 *  Copyright (c) 2005 Arnaldo Carvalho de Melo <acme@conectiva.com.br>
8
 *  Copyright (c) 2005-6 Ian McDonald <ian.mcdonald@jandi.co.nz>
9 10 11 12 13 14 15
 *
 *	This program is free software; you can redistribute it and/or modify it
 *	under the terms of the GNU General Public License version 2 as
 *	published by the Free Software Foundation.
 */

#include <linux/dccp.h>
16
#include <linux/ktime.h>
17 18 19
#include <net/snmp.h>
#include <net/sock.h>
#include <net/tcp.h>
20
#include "ackvec.h"
21

22 23 24 25
/*
 * 	DCCP - specific warning and debugging macros.
 */
#define DCCP_WARN(fmt, a...) LIMIT_NETDEBUG(KERN_WARNING "%s: " fmt,       \
26
							__FUNCTION__, ##a)
27 28 29 30 31 32
#define DCCP_CRIT(fmt, a...) printk(KERN_CRIT fmt " at %s:%d/%s()\n", ##a, \
					 __FILE__, __LINE__, __FUNCTION__)
#define DCCP_BUG(a...)       do { DCCP_CRIT("BUG: " a); dump_stack(); } while(0)
#define DCCP_BUG_ON(cond)    do { if (unlikely((cond) != 0))		   \
				     DCCP_BUG("\"%s\" holds (exception!)", \
					      __stringify(cond));          \
33 34
			     } while (0)

35 36
#define DCCP_PRINTK(enable, fmt, args...)	do { if (enable)	     \
							printk(fmt, ##args); \
37
						} while(0)
38 39 40
#define DCCP_PR_DEBUG(enable, fmt, a...)	DCCP_PRINTK(enable, KERN_DEBUG \
						  "%s: " fmt, __FUNCTION__, ##a)

41
#ifdef CONFIG_IP_DCCP_DEBUG
42
extern int dccp_debug;
43 44
#define dccp_pr_debug(format, a...)	  DCCP_PR_DEBUG(dccp_debug, format, ##a)
#define dccp_pr_debug_cat(format, a...)   DCCP_PRINTK(dccp_debug, format, ##a)
45 46 47 48 49 50 51 52 53 54 55
#else
#define dccp_pr_debug(format, a...)
#define dccp_pr_debug_cat(format, a...)
#endif

extern struct inet_hashinfo dccp_hashinfo;

extern atomic_t dccp_orphan_count;

extern void dccp_time_wait(struct sock *sk, int state, int timeo);

56 57 58 59 60 61 62 63 64 65 66 67
/*
 *  Set safe upper bounds for header and option length. Since Data Offset is 8
 *  bits (RFC 4340, sec. 5.1), the total header length can never be more than
 *  4 * 255 = 1020 bytes. The largest possible header length is 28 bytes (X=1):
 *    - DCCP-Response with ACK Subheader and 4 bytes of Service code      OR
 *    - DCCP-Reset    with ACK Subheader and 4 bytes of Reset Code fields
 *  Hence a safe upper bound for the maximum option length is 1020-28 = 992
 */
#define MAX_DCCP_SPECIFIC_HEADER (255 * sizeof(int))
#define DCCP_MAX_PACKET_HDR 28
#define DCCP_MAX_OPT_LEN (MAX_DCCP_SPECIFIC_HEADER - DCCP_MAX_PACKET_HDR)
#define MAX_DCCP_HEADER (MAX_DCCP_SPECIFIC_HEADER + MAX_HEADER)
68 69 70 71

#define DCCP_TIMEWAIT_LEN (60 * HZ) /* how long to wait to destroy TIME-WAIT
				     * state, about 60 seconds */

72
/* RFC 1122, 4.2.3.1 initial RTO value */
73 74
#define DCCP_TIMEOUT_INIT ((unsigned)(3 * HZ))

75 76 77 78 79 80
#define DCCP_RTO_MAX ((unsigned)(120 * HZ)) /* FIXME: using TCP value */

/* bounds for sampled RTT values from packet exchanges (in usec) */
#define DCCP_SANE_RTT_MIN	100
#define DCCP_SANE_RTT_MAX	(4 * USEC_PER_SEC)

81 82 83
/* Maximal interval between probes for local resources.  */
#define DCCP_RESOURCE_PROBE_INTERVAL ((unsigned)(HZ / 2U))

84 85 86 87
/* sysctl variables for DCCP */
extern int  sysctl_dccp_request_retries;
extern int  sysctl_dccp_retries1;
extern int  sysctl_dccp_retries2;
88 89 90 91 92 93
extern int  sysctl_dccp_feat_sequence_window;
extern int  sysctl_dccp_feat_rx_ccid;
extern int  sysctl_dccp_feat_tx_ccid;
extern int  sysctl_dccp_feat_ack_ratio;
extern int  sysctl_dccp_feat_send_ack_vector;
extern int  sysctl_dccp_feat_send_ndp_count;
94
extern int  sysctl_dccp_tx_qlen;
95

96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116
/*
 *	48-bit sequence number arithmetic (signed and unsigned)
 */
#define INT48_MIN	  0x800000000000LL		/* 2^47	    */
#define UINT48_MAX	  0xFFFFFFFFFFFFLL		/* 2^48 - 1 */
#define COMPLEMENT48(x)	 (0x1000000000000LL - (x))	/* 2^48 - x */
#define TO_SIGNED48(x)	 (((x) < INT48_MIN)? (x) : -COMPLEMENT48( (x)))
#define TO_UNSIGNED48(x) (((x) >= 0)?	     (x) :  COMPLEMENT48(-(x)))
#define ADD48(a, b)	 (((a) + (b)) & UINT48_MAX)
#define SUB48(a, b)	 ADD48((a), COMPLEMENT48(b))

static inline void dccp_set_seqno(u64 *seqno, u64 value)
{
	*seqno = value & UINT48_MAX;
}

static inline void dccp_inc_seqno(u64 *seqno)
{
	*seqno = ADD48(*seqno, 1);
}

117 118
/* signed mod-2^48 distance: pos. if seqno1 < seqno2, neg. if seqno1 > seqno2 */
static inline s64 dccp_delta_seqno(const u64 seqno1, const u64 seqno2)
119
{
120 121 122
	u64 delta = SUB48(seqno2, seqno1);

	return TO_SIGNED48(delta);
123 124
}

125
/* is seq1 < seq2 ? */
P
Patrick McHardy 已提交
126
static inline int before48(const u64 seq1, const u64 seq2)
127
{
128
	return (s64)((seq2 << 16) - (seq1 << 16)) > 0;
129 130 131
}

/* is seq1 > seq2 ? */
132
#define after48(seq1, seq2)	before48(seq2, seq1)
133 134

/* is seq2 <= seq1 <= seq3 ? */
P
Patrick McHardy 已提交
135
static inline int between48(const u64 seq1, const u64 seq2, const u64 seq3)
136 137 138 139 140 141 142 143 144
{
	return (seq3 << 16) - (seq2 << 16) >= (seq1 << 16) - (seq2 << 16);
}

static inline u64 max48(const u64 seq1, const u64 seq2)
{
	return after48(seq1, seq2) ? seq1 : seq2;
}

145 146 147
/* is seq1 next seqno after seq2 */
static inline int follows48(const u64 seq1, const u64 seq2)
{
G
Gerrit Renker 已提交
148
	return dccp_delta_seqno(seq2, seq1) == 1;
149 150
}

151 152 153 154 155
enum {
	DCCP_MIB_NUM = 0,
	DCCP_MIB_ACTIVEOPENS,			/* ActiveOpens */
	DCCP_MIB_ESTABRESETS,			/* EstabResets */
	DCCP_MIB_CURRESTAB,			/* CurrEstab */
156
	DCCP_MIB_OUTSEGS,			/* OutSegs */
157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175
	DCCP_MIB_OUTRSTS,
	DCCP_MIB_ABORTONTIMEOUT,
	DCCP_MIB_TIMEOUTS,
	DCCP_MIB_ABORTFAILED,
	DCCP_MIB_PASSIVEOPENS,
	DCCP_MIB_ATTEMPTFAILS,
	DCCP_MIB_OUTDATAGRAMS,
	DCCP_MIB_INERRS,
	DCCP_MIB_OPTMANDATORYERROR,
	DCCP_MIB_INVALIDOPT,
	__DCCP_MIB_MAX
};

#define DCCP_MIB_MAX	__DCCP_MIB_MAX
struct dccp_mib {
	unsigned long	mibs[DCCP_MIB_MAX];
} __SNMP_MIB_ALIGN__;

DECLARE_SNMP_STAT(struct dccp_mib, dccp_statistics);
176 177 178 179 180 181 182 183
#define DCCP_INC_STATS(field)	    SNMP_INC_STATS(dccp_statistics, field)
#define DCCP_INC_STATS_BH(field)    SNMP_INC_STATS_BH(dccp_statistics, field)
#define DCCP_INC_STATS_USER(field)  SNMP_INC_STATS_USER(dccp_statistics, field)
#define DCCP_DEC_STATS(field)	    SNMP_DEC_STATS(dccp_statistics, field)
#define DCCP_ADD_STATS_BH(field, val) \
			SNMP_ADD_STATS_BH(dccp_statistics, field, val)
#define DCCP_ADD_STATS_USER(field, val)	\
			SNMP_ADD_STATS_USER(dccp_statistics, field, val)
184

185 186 187
/*
 * 	Checksumming routines
 */
I
Ian McDonald 已提交
188
static inline unsigned int dccp_csum_coverage(const struct sk_buff *skb)
189 190 191 192 193 194 195 196 197 198
{
	const struct dccp_hdr* dh = dccp_hdr(skb);

	if (dh->dccph_cscov == 0)
		return skb->len;
	return (dh->dccph_doff + dh->dccph_cscov - 1) * sizeof(u32);
}

static inline void dccp_csum_outgoing(struct sk_buff *skb)
{
I
Ian McDonald 已提交
199
	unsigned int cov = dccp_csum_coverage(skb);
200 201 202 203 204 205 206 207 208

	if (cov >= skb->len)
		dccp_hdr(skb)->dccph_cscov = 0;

	skb->csum = skb_checksum(skb, 0, (cov > skb->len)? skb->len : cov, 0);
}

extern void dccp_v4_send_check(struct sock *sk, int len, struct sk_buff *skb);

209 210 211
extern int  dccp_retransmit_skb(struct sock *sk, struct sk_buff *skb);

extern void dccp_send_ack(struct sock *sk);
212 213
extern void dccp_reqsk_send_ack(struct sk_buff *sk, struct request_sock *rsk);

214 215
extern void dccp_send_sync(struct sock *sk, const u64 seq,
			   const enum dccp_pkt_type pkt_type);
216

I
Ian McDonald 已提交
217
extern void dccp_write_xmit(struct sock *sk, int block);
218
extern void dccp_write_space(struct sock *sk);
219

220 221 222 223 224 225 226 227 228 229 230
extern void dccp_init_xmit_timers(struct sock *sk);
static inline void dccp_clear_xmit_timers(struct sock *sk)
{
	inet_csk_clear_xmit_timers(sk);
}

extern unsigned int dccp_sync_mss(struct sock *sk, u32 pmtu);

extern const char *dccp_packet_name(const int type);
extern const char *dccp_state_name(const int state);

231 232
extern void dccp_set_state(struct sock *sk, const int state);
extern void dccp_done(struct sock *sk);
233

234
extern void dccp_reqsk_init(struct request_sock *req, struct sk_buff *skb);
235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258

extern int dccp_v4_conn_request(struct sock *sk, struct sk_buff *skb);

extern struct sock *dccp_create_openreq_child(struct sock *sk,
					      const struct request_sock *req,
					      const struct sk_buff *skb);

extern int dccp_v4_do_rcv(struct sock *sk, struct sk_buff *skb);

extern struct sock *dccp_v4_request_recv_sock(struct sock *sk,
					      struct sk_buff *skb,
					      struct request_sock *req,
					      struct dst_entry *dst);
extern struct sock *dccp_check_req(struct sock *sk, struct sk_buff *skb,
				   struct request_sock *req,
				   struct request_sock **prev);

extern int dccp_child_process(struct sock *parent, struct sock *child,
			      struct sk_buff *skb);
extern int dccp_rcv_state_process(struct sock *sk, struct sk_buff *skb,
				  struct dccp_hdr *dh, unsigned len);
extern int dccp_rcv_established(struct sock *sk, struct sk_buff *skb,
				const struct dccp_hdr *dh, const unsigned len);

259
extern int dccp_init_sock(struct sock *sk, const __u8 ctl_sock_initialized);
260
extern int dccp_destroy_sock(struct sock *sk);
261

262 263 264 265 266 267 268
extern void		dccp_close(struct sock *sk, long timeout);
extern struct sk_buff	*dccp_make_response(struct sock *sk,
					    struct dst_entry *dst,
					    struct request_sock *req);

extern int	   dccp_connect(struct sock *sk);
extern int	   dccp_disconnect(struct sock *sk, int flags);
269
extern void	   dccp_hash(struct sock *sk);
270
extern void	   dccp_unhash(struct sock *sk);
271
extern int	   dccp_getsockopt(struct sock *sk, int level, int optname,
272 273 274
				   char __user *optval, int __user *optlen);
extern int	   dccp_setsockopt(struct sock *sk, int level, int optname,
				   char __user *optval, int optlen);
275 276 277 278 279 280 281 282
#ifdef CONFIG_COMPAT
extern int	   compat_dccp_getsockopt(struct sock *sk,
				int level, int optname,
				char __user *optval, int __user *optlen);
extern int	   compat_dccp_setsockopt(struct sock *sk,
				int level, int optname,
				char __user *optval, int optlen);
#endif
283
extern int	   dccp_ioctl(struct sock *sk, int cmd, unsigned long arg);
284 285
extern int	   dccp_sendmsg(struct kiocb *iocb, struct sock *sk,
				struct msghdr *msg, size_t size);
286 287 288 289
extern int	   dccp_recvmsg(struct kiocb *iocb, struct sock *sk,
				struct msghdr *msg, size_t len, int nonblock,
				int flags, int *addr_len);
extern void	   dccp_shutdown(struct sock *sk, int how);
290 291 292 293 294
extern int	   inet_dccp_listen(struct socket *sock, int backlog);
extern unsigned int dccp_poll(struct file *file, struct socket *sock,
			     poll_table *wait);
extern int	   dccp_v4_connect(struct sock *sk, struct sockaddr *uaddr,
				   int addr_len);
295

296
extern int	   dccp_send_reset(struct sock *sk, enum dccp_reset_codes code);
297
extern void	   dccp_send_close(struct sock *sk, const int active);
298
extern int	   dccp_invalid_packet(struct sk_buff *skb);
299
extern u32	   dccp_sample_rtt(struct sock *sk, long delta);
300 301

static inline int dccp_bad_service_code(const struct sock *sk,
302
					const __be32 service)
303 304 305 306 307 308 309
{
	const struct dccp_sock *dp = dccp_sk(sk);

	if (dp->dccps_service == service)
		return 0;
	return !dccp_list_has_service(dp->dccps_service_list, service);
}
310

311 312 313 314 315 316 317 318 319 320 321
/**
 * dccp_skb_cb  -  DCCP per-packet control information
 * @dccpd_type: one of %dccp_pkt_type (or unknown)
 * @dccpd_ccval: CCVal field (5.1), see e.g. RFC 4342, 8.1
 * @dccpd_reset_code: one of %dccp_reset_codes
 * @dccpd_reset_data: Data1..3 fields (depend on @dccpd_reset_code)
 * @dccpd_opt_len: total length of all options (5.8) in the packet
 * @dccpd_seq: sequence number
 * @dccpd_ack_seq: acknowledgment number subheader field value
 * This is used for transmission as well as for reception.
 */
322
struct dccp_skb_cb {
323 324
	__u8  dccpd_type:4;
	__u8  dccpd_ccval:4;
325 326
	__u8  dccpd_reset_code,
	      dccpd_reset_data[3];
327
	__u16 dccpd_opt_len;
328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352
	__u64 dccpd_seq;
	__u64 dccpd_ack_seq;
};

#define DCCP_SKB_CB(__skb) ((struct dccp_skb_cb *)&((__skb)->cb[0]))

static inline int dccp_non_data_packet(const struct sk_buff *skb)
{
	const __u8 type = DCCP_SKB_CB(skb)->dccpd_type;

	return type == DCCP_PKT_ACK	 ||
	       type == DCCP_PKT_CLOSE	 ||
	       type == DCCP_PKT_CLOSEREQ ||
	       type == DCCP_PKT_RESET	 ||
	       type == DCCP_PKT_SYNC	 ||
	       type == DCCP_PKT_SYNCACK;
}

static inline int dccp_packet_without_ack(const struct sk_buff *skb)
{
	const __u8 type = DCCP_SKB_CB(skb)->dccpd_type;

	return type == DCCP_PKT_DATA || type == DCCP_PKT_REQUEST;
}

353
#define DCCP_PKT_WITHOUT_ACK_SEQ (UINT48_MAX << 2)
354 355 356

static inline void dccp_hdr_set_seq(struct dccp_hdr *dh, const u64 gss)
{
357 358
	struct dccp_hdr_ext *dhx = (struct dccp_hdr_ext *)((void *)dh +
							   sizeof(*dh));
359 360
	dh->dccph_seq2 = 0;
	dh->dccph_seq = htons((gss >> 32) & 0xfffff);
361 362 363
	dhx->dccph_seq_low = htonl(gss & 0xffffffff);
}

364 365
static inline void dccp_hdr_set_ack(struct dccp_hdr_ack_bits *dhack,
				    const u64 gsr)
366
{
367 368
	dhack->dccph_reserved1 = 0;
	dhack->dccph_ack_nr_high = htons(gsr >> 32);
369 370 371 372 373 374
	dhack->dccph_ack_nr_low  = htonl(gsr & 0xffffffff);
}

static inline void dccp_update_gsr(struct sock *sk, u64 seq)
{
	struct dccp_sock *dp = dccp_sk(sk);
375
	const struct dccp_minisock *dmsk = dccp_msk(sk);
376

377 378
	dp->dccps_gsr = seq;
	dccp_set_seqno(&dp->dccps_swl,
379
		       dp->dccps_gsr + 1 - (dmsk->dccpms_sequence_window / 4));
380
	dccp_set_seqno(&dp->dccps_swh,
381
		       dp->dccps_gsr + (3 * dmsk->dccpms_sequence_window) / 4);
382 383 384 385 386 387
}

static inline void dccp_update_gss(struct sock *sk, u64 seq)
{
	struct dccp_sock *dp = dccp_sk(sk);

388 389
	dp->dccps_awh = dp->dccps_gss = seq;
	dccp_set_seqno(&dp->dccps_awl,
390
		       (dp->dccps_gss -
391
			dccp_msk(sk)->dccpms_sequence_window + 1));
392
}
393

394 395 396 397 398
static inline int dccp_ack_pending(const struct sock *sk)
{
	const struct dccp_sock *dp = dccp_sk(sk);
	return dp->dccps_timestamp_echo != 0 ||
#ifdef CONFIG_IP_DCCP_ACKVEC
399
	       (dccp_msk(sk)->dccpms_send_ack_vector &&
400 401 402 403
		dccp_ackvec_pending(dp->dccps_hc_rx_ackvec)) ||
#endif
	       inet_csk_ack_scheduled(sk);
}
404

405 406
extern int dccp_insert_options(struct sock *sk, struct sk_buff *skb);
extern int dccp_insert_option_elapsed_time(struct sock *sk,
407 408
					    struct sk_buff *skb,
					    u32 elapsed_time);
409 410
extern u32 dccp_timestamp(void);
extern void dccp_timestamping_init(void);
411
extern int dccp_insert_option_timestamp(struct sock *sk,
412
					 struct sk_buff *skb);
413
extern int dccp_insert_option(struct sock *sk, struct sk_buff *skb,
414 415 416
			       unsigned char option,
			       const void *value, unsigned char len);

417 418 419 420 421 422 423 424 425 426 427 428 429 430
#ifdef CONFIG_SYSCTL
extern int dccp_sysctl_init(void);
extern void dccp_sysctl_exit(void);
#else
static inline int dccp_sysctl_init(void)
{
	return 0;
}

static inline void dccp_sysctl_exit(void)
{
}
#endif

431
#endif /* _DCCP_H */