dccp.h 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538
  1. #ifndef _LINUX_DCCP_H
  2. #define _LINUX_DCCP_H
  3. #include <linux/types.h>
  4. #include <asm/byteorder.h>
  5. /**
  6. * struct dccp_hdr - generic part of DCCP packet header
  7. *
  8. * @dccph_sport - Relevant port on the endpoint that sent this packet
  9. * @dccph_dport - Relevant port on the other endpoint
  10. * @dccph_doff - Data Offset from the start of the DCCP header, in 32-bit words
  11. * @dccph_ccval - Used by the HC-Sender CCID
  12. * @dccph_cscov - Parts of the packet that are covered by the Checksum field
  13. * @dccph_checksum - Internet checksum, depends on dccph_cscov
  14. * @dccph_x - 0 = 24 bit sequence number, 1 = 48
  15. * @dccph_type - packet type, see DCCP_PKT_ prefixed macros
  16. * @dccph_seq - sequence number high or low order 24 bits, depends on dccph_x
  17. */
  18. struct dccp_hdr {
  19. __be16 dccph_sport,
  20. dccph_dport;
  21. __u8 dccph_doff;
  22. #if defined(__LITTLE_ENDIAN_BITFIELD)
  23. __u8 dccph_cscov:4,
  24. dccph_ccval:4;
  25. #elif defined(__BIG_ENDIAN_BITFIELD)
  26. __u8 dccph_ccval:4,
  27. dccph_cscov:4;
  28. #else
  29. #error "Adjust your <asm/byteorder.h> defines"
  30. #endif
  31. __sum16 dccph_checksum;
  32. #if defined(__LITTLE_ENDIAN_BITFIELD)
  33. __u8 dccph_x:1,
  34. dccph_type:4,
  35. dccph_reserved:3;
  36. #elif defined(__BIG_ENDIAN_BITFIELD)
  37. __u8 dccph_reserved:3,
  38. dccph_type:4,
  39. dccph_x:1;
  40. #else
  41. #error "Adjust your <asm/byteorder.h> defines"
  42. #endif
  43. __u8 dccph_seq2;
  44. __be16 dccph_seq;
  45. };
  46. /**
  47. * struct dccp_hdr_ext - the low bits of a 48 bit seq packet
  48. *
  49. * @dccph_seq_low - low 24 bits of a 48 bit seq packet
  50. */
  51. struct dccp_hdr_ext {
  52. __be32 dccph_seq_low;
  53. };
  54. /**
  55. * struct dccp_hdr_request - Conection initiation request header
  56. *
  57. * @dccph_req_service - Service to which the client app wants to connect
  58. * @dccph_req_options - list of options (must be a multiple of 32 bits
  59. */
  60. struct dccp_hdr_request {
  61. __be32 dccph_req_service;
  62. };
  63. /**
  64. * struct dccp_hdr_ack_bits - acknowledgment bits common to most packets
  65. *
  66. * @dccph_resp_ack_nr_high - 48 bit ack number high order bits, contains GSR
  67. * @dccph_resp_ack_nr_low - 48 bit ack number low order bits, contains GSR
  68. */
  69. struct dccp_hdr_ack_bits {
  70. __be16 dccph_reserved1;
  71. __be16 dccph_ack_nr_high;
  72. __be32 dccph_ack_nr_low;
  73. };
  74. /**
  75. * struct dccp_hdr_response - Conection initiation response header
  76. *
  77. * @dccph_resp_ack_nr_high - 48 bit ack number high order bits, contains GSR
  78. * @dccph_resp_ack_nr_low - 48 bit ack number low order bits, contains GSR
  79. * @dccph_resp_service - Echoes the Service Code on a received DCCP-Request
  80. * @dccph_resp_options - list of options (must be a multiple of 32 bits
  81. */
  82. struct dccp_hdr_response {
  83. struct dccp_hdr_ack_bits dccph_resp_ack;
  84. __be32 dccph_resp_service;
  85. };
  86. /**
  87. * struct dccp_hdr_reset - Unconditionally shut down a connection
  88. *
  89. * @dccph_reset_service - Echoes the Service Code on a received DCCP-Request
  90. * @dccph_reset_options - list of options (must be a multiple of 32 bits
  91. */
  92. struct dccp_hdr_reset {
  93. struct dccp_hdr_ack_bits dccph_reset_ack;
  94. __u8 dccph_reset_code,
  95. dccph_reset_data[3];
  96. };
  97. enum dccp_pkt_type {
  98. DCCP_PKT_REQUEST = 0,
  99. DCCP_PKT_RESPONSE,
  100. DCCP_PKT_DATA,
  101. DCCP_PKT_ACK,
  102. DCCP_PKT_DATAACK,
  103. DCCP_PKT_CLOSEREQ,
  104. DCCP_PKT_CLOSE,
  105. DCCP_PKT_RESET,
  106. DCCP_PKT_SYNC,
  107. DCCP_PKT_SYNCACK,
  108. DCCP_PKT_INVALID,
  109. };
  110. #define DCCP_NR_PKT_TYPES DCCP_PKT_INVALID
  111. static inline unsigned int dccp_packet_hdr_len(const __u8 type)
  112. {
  113. if (type == DCCP_PKT_DATA)
  114. return 0;
  115. if (type == DCCP_PKT_DATAACK ||
  116. type == DCCP_PKT_ACK ||
  117. type == DCCP_PKT_SYNC ||
  118. type == DCCP_PKT_SYNCACK ||
  119. type == DCCP_PKT_CLOSE ||
  120. type == DCCP_PKT_CLOSEREQ)
  121. return sizeof(struct dccp_hdr_ack_bits);
  122. if (type == DCCP_PKT_REQUEST)
  123. return sizeof(struct dccp_hdr_request);
  124. if (type == DCCP_PKT_RESPONSE)
  125. return sizeof(struct dccp_hdr_response);
  126. return sizeof(struct dccp_hdr_reset);
  127. }
  128. enum dccp_reset_codes {
  129. DCCP_RESET_CODE_UNSPECIFIED = 0,
  130. DCCP_RESET_CODE_CLOSED,
  131. DCCP_RESET_CODE_ABORTED,
  132. DCCP_RESET_CODE_NO_CONNECTION,
  133. DCCP_RESET_CODE_PACKET_ERROR,
  134. DCCP_RESET_CODE_OPTION_ERROR,
  135. DCCP_RESET_CODE_MANDATORY_ERROR,
  136. DCCP_RESET_CODE_CONNECTION_REFUSED,
  137. DCCP_RESET_CODE_BAD_SERVICE_CODE,
  138. DCCP_RESET_CODE_TOO_BUSY,
  139. DCCP_RESET_CODE_BAD_INIT_COOKIE,
  140. DCCP_RESET_CODE_AGGRESSION_PENALTY,
  141. };
  142. /* DCCP options */
  143. enum {
  144. DCCPO_PADDING = 0,
  145. DCCPO_MANDATORY = 1,
  146. DCCPO_MIN_RESERVED = 3,
  147. DCCPO_MAX_RESERVED = 31,
  148. DCCPO_CHANGE_L = 32,
  149. DCCPO_CONFIRM_L = 33,
  150. DCCPO_CHANGE_R = 34,
  151. DCCPO_CONFIRM_R = 35,
  152. DCCPO_NDP_COUNT = 37,
  153. DCCPO_ACK_VECTOR_0 = 38,
  154. DCCPO_ACK_VECTOR_1 = 39,
  155. DCCPO_TIMESTAMP = 41,
  156. DCCPO_TIMESTAMP_ECHO = 42,
  157. DCCPO_ELAPSED_TIME = 43,
  158. DCCPO_MAX = 45,
  159. DCCPO_MIN_CCID_SPECIFIC = 128,
  160. DCCPO_MAX_CCID_SPECIFIC = 255,
  161. };
  162. /* DCCP CCIDS */
  163. enum {
  164. DCCPC_CCID2 = 2,
  165. DCCPC_CCID3 = 3,
  166. };
  167. /* DCCP features (RFC 4340 section 6.4) */
  168. enum {
  169. DCCPF_RESERVED = 0,
  170. DCCPF_CCID = 1,
  171. DCCPF_SHORT_SEQNOS = 2, /* XXX: not yet implemented */
  172. DCCPF_SEQUENCE_WINDOW = 3,
  173. DCCPF_ECN_INCAPABLE = 4, /* XXX: not yet implemented */
  174. DCCPF_ACK_RATIO = 5,
  175. DCCPF_SEND_ACK_VECTOR = 6,
  176. DCCPF_SEND_NDP_COUNT = 7,
  177. DCCPF_MIN_CSUM_COVER = 8,
  178. DCCPF_DATA_CHECKSUM = 9, /* XXX: not yet implemented */
  179. /* 10-127 reserved */
  180. DCCPF_MIN_CCID_SPECIFIC = 128,
  181. DCCPF_MAX_CCID_SPECIFIC = 255,
  182. };
  183. /* this structure is argument to DCCP_SOCKOPT_CHANGE_X */
  184. struct dccp_so_feat {
  185. __u8 dccpsf_feat;
  186. __u8 __user *dccpsf_val;
  187. __u8 dccpsf_len;
  188. };
  189. /* DCCP socket options */
  190. #define DCCP_SOCKOPT_PACKET_SIZE 1 /* XXX deprecated, without effect */
  191. #define DCCP_SOCKOPT_SERVICE 2
  192. #define DCCP_SOCKOPT_CHANGE_L 3
  193. #define DCCP_SOCKOPT_CHANGE_R 4
  194. #define DCCP_SOCKOPT_SEND_CSCOV 10
  195. #define DCCP_SOCKOPT_RECV_CSCOV 11
  196. #define DCCP_SOCKOPT_CCID_RX_INFO 128
  197. #define DCCP_SOCKOPT_CCID_TX_INFO 192
  198. /* maximum number of services provided on the same listening port */
  199. #define DCCP_SERVICE_LIST_MAX_LEN 32
  200. #ifdef __KERNEL__
  201. #include <linux/in.h>
  202. #include <linux/list.h>
  203. #include <linux/uio.h>
  204. #include <linux/workqueue.h>
  205. #include <net/inet_connection_sock.h>
  206. #include <net/inet_sock.h>
  207. #include <net/inet_timewait_sock.h>
  208. #include <net/tcp_states.h>
  209. enum dccp_state {
  210. DCCP_OPEN = TCP_ESTABLISHED,
  211. DCCP_REQUESTING = TCP_SYN_SENT,
  212. DCCP_PARTOPEN = TCP_FIN_WAIT1, /* FIXME:
  213. This mapping is horrible, but TCP has
  214. no matching state for DCCP_PARTOPEN,
  215. as TCP_SYN_RECV is already used by
  216. DCCP_RESPOND, why don't stop using TCP
  217. mapping of states? OK, now we don't use
  218. sk_stream_sendmsg anymore, so doesn't
  219. seem to exist any reason for us to
  220. do the TCP mapping here */
  221. DCCP_LISTEN = TCP_LISTEN,
  222. DCCP_RESPOND = TCP_SYN_RECV,
  223. DCCP_CLOSING = TCP_CLOSING,
  224. DCCP_TIME_WAIT = TCP_TIME_WAIT,
  225. DCCP_CLOSED = TCP_CLOSE,
  226. DCCP_MAX_STATES = TCP_MAX_STATES,
  227. };
  228. #define DCCP_STATE_MASK 0xf
  229. #define DCCP_ACTION_FIN (1<<7)
  230. enum {
  231. DCCPF_OPEN = TCPF_ESTABLISHED,
  232. DCCPF_REQUESTING = TCPF_SYN_SENT,
  233. DCCPF_PARTOPEN = TCPF_FIN_WAIT1,
  234. DCCPF_LISTEN = TCPF_LISTEN,
  235. DCCPF_RESPOND = TCPF_SYN_RECV,
  236. DCCPF_CLOSING = TCPF_CLOSING,
  237. DCCPF_TIME_WAIT = TCPF_TIME_WAIT,
  238. DCCPF_CLOSED = TCPF_CLOSE,
  239. };
  240. static inline struct dccp_hdr *dccp_hdr(const struct sk_buff *skb)
  241. {
  242. return (struct dccp_hdr *)skb->h.raw;
  243. }
  244. static inline struct dccp_hdr *dccp_zeroed_hdr(struct sk_buff *skb, int headlen)
  245. {
  246. skb->h.raw = skb_push(skb, headlen);
  247. memset(skb->h.raw, 0, headlen);
  248. return dccp_hdr(skb);
  249. }
  250. static inline struct dccp_hdr_ext *dccp_hdrx(const struct sk_buff *skb)
  251. {
  252. return (struct dccp_hdr_ext *)(skb->h.raw + sizeof(struct dccp_hdr));
  253. }
  254. static inline unsigned int __dccp_basic_hdr_len(const struct dccp_hdr *dh)
  255. {
  256. return sizeof(*dh) + (dh->dccph_x ? sizeof(struct dccp_hdr_ext) : 0);
  257. }
  258. static inline unsigned int dccp_basic_hdr_len(const struct sk_buff *skb)
  259. {
  260. const struct dccp_hdr *dh = dccp_hdr(skb);
  261. return __dccp_basic_hdr_len(dh);
  262. }
  263. static inline __u64 dccp_hdr_seq(const struct sk_buff *skb)
  264. {
  265. const struct dccp_hdr *dh = dccp_hdr(skb);
  266. __u64 seq_nr = ntohs(dh->dccph_seq);
  267. if (dh->dccph_x != 0)
  268. seq_nr = (seq_nr << 32) + ntohl(dccp_hdrx(skb)->dccph_seq_low);
  269. else
  270. seq_nr += (u32)dh->dccph_seq2 << 16;
  271. return seq_nr;
  272. }
  273. static inline struct dccp_hdr_request *dccp_hdr_request(struct sk_buff *skb)
  274. {
  275. return (struct dccp_hdr_request *)(skb->h.raw + dccp_basic_hdr_len(skb));
  276. }
  277. static inline struct dccp_hdr_ack_bits *dccp_hdr_ack_bits(const struct sk_buff *skb)
  278. {
  279. return (struct dccp_hdr_ack_bits *)(skb->h.raw + dccp_basic_hdr_len(skb));
  280. }
  281. static inline u64 dccp_hdr_ack_seq(const struct sk_buff *skb)
  282. {
  283. const struct dccp_hdr_ack_bits *dhack = dccp_hdr_ack_bits(skb);
  284. return ((u64)ntohs(dhack->dccph_ack_nr_high) << 32) + ntohl(dhack->dccph_ack_nr_low);
  285. }
  286. static inline struct dccp_hdr_response *dccp_hdr_response(struct sk_buff *skb)
  287. {
  288. return (struct dccp_hdr_response *)(skb->h.raw + dccp_basic_hdr_len(skb));
  289. }
  290. static inline struct dccp_hdr_reset *dccp_hdr_reset(struct sk_buff *skb)
  291. {
  292. return (struct dccp_hdr_reset *)(skb->h.raw + dccp_basic_hdr_len(skb));
  293. }
  294. static inline unsigned int __dccp_hdr_len(const struct dccp_hdr *dh)
  295. {
  296. return __dccp_basic_hdr_len(dh) +
  297. dccp_packet_hdr_len(dh->dccph_type);
  298. }
  299. static inline unsigned int dccp_hdr_len(const struct sk_buff *skb)
  300. {
  301. return __dccp_hdr_len(dccp_hdr(skb));
  302. }
  303. /* initial values for each feature */
  304. #define DCCPF_INITIAL_SEQUENCE_WINDOW 100
  305. #define DCCPF_INITIAL_ACK_RATIO 2
  306. #define DCCPF_INITIAL_CCID DCCPC_CCID2
  307. #define DCCPF_INITIAL_SEND_ACK_VECTOR 1
  308. /* FIXME: for now we're default to 1 but it should really be 0 */
  309. #define DCCPF_INITIAL_SEND_NDP_COUNT 1
  310. #define DCCP_NDP_LIMIT 0xFFFFFF
  311. /**
  312. * struct dccp_minisock - Minimal DCCP connection representation
  313. *
  314. * Will be used to pass the state from dccp_request_sock to dccp_sock.
  315. *
  316. * @dccpms_sequence_window - Sequence Window Feature (section 7.5.2)
  317. * @dccpms_ccid - Congestion Control Id (CCID) (section 10)
  318. * @dccpms_send_ack_vector - Send Ack Vector Feature (section 11.5)
  319. * @dccpms_send_ndp_count - Send NDP Count Feature (7.7.2)
  320. * @dccpms_ack_ratio - Ack Ratio Feature (section 11.3)
  321. * @dccpms_pending - List of features being negotiated
  322. * @dccpms_conf -
  323. */
  324. struct dccp_minisock {
  325. __u64 dccpms_sequence_window;
  326. __u8 dccpms_rx_ccid;
  327. __u8 dccpms_tx_ccid;
  328. __u8 dccpms_send_ack_vector;
  329. __u8 dccpms_send_ndp_count;
  330. __u8 dccpms_ack_ratio;
  331. struct list_head dccpms_pending;
  332. struct list_head dccpms_conf;
  333. };
  334. struct dccp_opt_conf {
  335. __u8 *dccpoc_val;
  336. __u8 dccpoc_len;
  337. };
  338. struct dccp_opt_pend {
  339. struct list_head dccpop_node;
  340. __u8 dccpop_type;
  341. __u8 dccpop_feat;
  342. __u8 *dccpop_val;
  343. __u8 dccpop_len;
  344. int dccpop_conf;
  345. struct dccp_opt_conf *dccpop_sc;
  346. };
  347. extern void __dccp_minisock_init(struct dccp_minisock *dmsk);
  348. extern void dccp_minisock_init(struct dccp_minisock *dmsk);
  349. extern int dccp_parse_options(struct sock *sk, struct sk_buff *skb);
  350. struct dccp_request_sock {
  351. struct inet_request_sock dreq_inet_rsk;
  352. __u64 dreq_iss;
  353. __u64 dreq_isr;
  354. __be32 dreq_service;
  355. };
  356. static inline struct dccp_request_sock *dccp_rsk(const struct request_sock *req)
  357. {
  358. return (struct dccp_request_sock *)req;
  359. }
  360. extern struct inet_timewait_death_row dccp_death_row;
  361. struct dccp_options_received {
  362. u32 dccpor_ndp; /* only 24 bits */
  363. u32 dccpor_timestamp;
  364. u32 dccpor_timestamp_echo;
  365. u32 dccpor_elapsed_time;
  366. };
  367. struct ccid;
  368. enum dccp_role {
  369. DCCP_ROLE_UNDEFINED,
  370. DCCP_ROLE_LISTEN,
  371. DCCP_ROLE_CLIENT,
  372. DCCP_ROLE_SERVER,
  373. };
  374. struct dccp_service_list {
  375. __u32 dccpsl_nr;
  376. __be32 dccpsl_list[0];
  377. };
  378. #define DCCP_SERVICE_INVALID_VALUE htonl((__u32)-1)
  379. #define DCCP_SERVICE_CODE_IS_ABSENT 0
  380. static inline int dccp_list_has_service(const struct dccp_service_list *sl,
  381. const __be32 service)
  382. {
  383. if (likely(sl != NULL)) {
  384. u32 i = sl->dccpsl_nr;
  385. while (i--)
  386. if (sl->dccpsl_list[i] == service)
  387. return 1;
  388. }
  389. return 0;
  390. }
  391. struct dccp_ackvec;
  392. /**
  393. * struct dccp_sock - DCCP socket state
  394. *
  395. * @dccps_swl - sequence number window low
  396. * @dccps_swh - sequence number window high
  397. * @dccps_awl - acknowledgement number window low
  398. * @dccps_awh - acknowledgement number window high
  399. * @dccps_iss - initial sequence number sent
  400. * @dccps_isr - initial sequence number received
  401. * @dccps_osr - first OPEN sequence number received
  402. * @dccps_gss - greatest sequence number sent
  403. * @dccps_gsr - greatest valid sequence number received
  404. * @dccps_gar - greatest valid ack number received on a non-Sync; initialized to %dccps_iss
  405. * @dccps_service - first (passive sock) or unique (active sock) service code
  406. * @dccps_service_list - second .. last service code on passive socket
  407. * @dccps_timestamp_time - time of latest TIMESTAMP option
  408. * @dccps_timestamp_echo - latest timestamp received on a TIMESTAMP option
  409. * @dccps_l_ack_ratio -
  410. * @dccps_r_ack_ratio -
  411. * @dccps_pcslen - sender partial checksum coverage (via sockopt)
  412. * @dccps_pcrlen - receiver partial checksum coverage (via sockopt)
  413. * @dccps_ndp_count - number of Non Data Packets since last data packet
  414. * @dccps_mss_cache -
  415. * @dccps_minisock -
  416. * @dccps_hc_rx_ackvec - rx half connection ack vector
  417. * @dccps_hc_rx_ccid -
  418. * @dccps_hc_tx_ccid -
  419. * @dccps_options_received -
  420. * @dccps_epoch -
  421. * @dccps_role - Role of this sock, one of %dccp_role
  422. * @dccps_hc_rx_insert_options -
  423. * @dccps_hc_tx_insert_options -
  424. * @dccps_xmit_timer - timer for when CCID is not ready to send
  425. */
  426. struct dccp_sock {
  427. /* inet_connection_sock has to be the first member of dccp_sock */
  428. struct inet_connection_sock dccps_inet_connection;
  429. __u64 dccps_swl;
  430. __u64 dccps_swh;
  431. __u64 dccps_awl;
  432. __u64 dccps_awh;
  433. __u64 dccps_iss;
  434. __u64 dccps_isr;
  435. __u64 dccps_osr;
  436. __u64 dccps_gss;
  437. __u64 dccps_gsr;
  438. __u64 dccps_gar;
  439. __be32 dccps_service;
  440. struct dccp_service_list *dccps_service_list;
  441. struct timeval dccps_timestamp_time;
  442. __u32 dccps_timestamp_echo;
  443. __u16 dccps_l_ack_ratio;
  444. __u16 dccps_r_ack_ratio;
  445. __u16 dccps_pcslen;
  446. __u16 dccps_pcrlen;
  447. unsigned long dccps_ndp_count;
  448. __u32 dccps_mss_cache;
  449. struct dccp_minisock dccps_minisock;
  450. struct dccp_ackvec *dccps_hc_rx_ackvec;
  451. struct ccid *dccps_hc_rx_ccid;
  452. struct ccid *dccps_hc_tx_ccid;
  453. struct dccp_options_received dccps_options_received;
  454. struct timeval dccps_epoch;
  455. enum dccp_role dccps_role:2;
  456. __u8 dccps_hc_rx_insert_options:1;
  457. __u8 dccps_hc_tx_insert_options:1;
  458. struct timer_list dccps_xmit_timer;
  459. };
  460. static inline struct dccp_sock *dccp_sk(const struct sock *sk)
  461. {
  462. return (struct dccp_sock *)sk;
  463. }
  464. static inline struct dccp_minisock *dccp_msk(const struct sock *sk)
  465. {
  466. return (struct dccp_minisock *)&dccp_sk(sk)->dccps_minisock;
  467. }
  468. static inline const char *dccp_role(const struct sock *sk)
  469. {
  470. switch (dccp_sk(sk)->dccps_role) {
  471. case DCCP_ROLE_UNDEFINED: return "undefined";
  472. case DCCP_ROLE_LISTEN: return "listen";
  473. case DCCP_ROLE_SERVER: return "server";
  474. case DCCP_ROLE_CLIENT: return "client";
  475. }
  476. return NULL;
  477. }
  478. #endif /* __KERNEL__ */
  479. #endif /* _LINUX_DCCP_H */