sm.h 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451
  1. /* SCTP kernel reference Implementation
  2. * (C) Copyright IBM Corp. 2001, 2004
  3. * Copyright (c) 1999-2000 Cisco, Inc.
  4. * Copyright (c) 1999-2001 Motorola, Inc.
  5. * Copyright (c) 2001 Intel Corp.
  6. *
  7. * This file is part of the SCTP kernel reference Implementation
  8. *
  9. * These are definitions needed by the state machine.
  10. *
  11. * The SCTP reference implementation is free software;
  12. * you can redistribute it and/or modify it under the terms of
  13. * the GNU General Public License as published by
  14. * the Free Software Foundation; either version 2, or (at your option)
  15. * any later version.
  16. *
  17. * The SCTP reference implementation is distributed in the hope that it
  18. * will be useful, but WITHOUT ANY WARRANTY; without even the implied
  19. * ************************
  20. * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  21. * See the GNU General Public License for more details.
  22. *
  23. * You should have received a copy of the GNU General Public License
  24. * along with GNU CC; see the file COPYING. If not, write to
  25. * the Free Software Foundation, 59 Temple Place - Suite 330,
  26. * Boston, MA 02111-1307, USA.
  27. *
  28. * Please send any bug reports or fixes you make to the
  29. * email addresses:
  30. * lksctp developers <lksctp-developers@lists.sourceforge.net>
  31. *
  32. * Or submit a bug report through the following website:
  33. * http://www.sf.net/projects/lksctp
  34. *
  35. * Written or modified by:
  36. * La Monte H.P. Yarroll <piggy@acm.org>
  37. * Karl Knutson <karl@athena.chicago.il.us>
  38. * Xingang Guo <xingang.guo@intel.com>
  39. * Jon Grimm <jgrimm@us.ibm.com>
  40. * Dajiang Zhang <dajiang.zhang@nokia.com>
  41. * Sridhar Samudrala <sri@us.ibm.com>
  42. * Daisy Chang <daisyc@us.ibm.com>
  43. * Ardelle Fan <ardelle.fan@intel.com>
  44. * Kevin Gao <kevin.gao@intel.com>
  45. *
  46. * Any bugs reported given to us we will try to fix... any fixes shared will
  47. * be incorporated into the next SCTP release.
  48. */
  49. #include <linux/types.h>
  50. #include <linux/compiler.h>
  51. #include <linux/slab.h>
  52. #include <linux/in.h>
  53. #include <net/sctp/command.h>
  54. #include <net/sctp/sctp.h>
  55. #ifndef __sctp_sm_h__
  56. #define __sctp_sm_h__
  57. /*
  58. * Possible values for the disposition are:
  59. */
  60. typedef enum {
  61. SCTP_DISPOSITION_DISCARD, /* No further processing. */
  62. SCTP_DISPOSITION_CONSUME, /* Process return values normally. */
  63. SCTP_DISPOSITION_NOMEM, /* We ran out of memory--recover. */
  64. SCTP_DISPOSITION_DELETE_TCB, /* Close the association. */
  65. SCTP_DISPOSITION_ABORT, /* Close the association NOW. */
  66. SCTP_DISPOSITION_VIOLATION, /* The peer is misbehaving. */
  67. SCTP_DISPOSITION_NOT_IMPL, /* This entry is not implemented. */
  68. SCTP_DISPOSITION_ERROR, /* This is plain old user error. */
  69. SCTP_DISPOSITION_BUG, /* This is a bug. */
  70. } sctp_disposition_t;
  71. typedef struct {
  72. int name;
  73. int action;
  74. } sctp_sm_command_t;
  75. typedef sctp_disposition_t (sctp_state_fn_t) (const struct sctp_endpoint *,
  76. const struct sctp_association *,
  77. const sctp_subtype_t type,
  78. void *arg,
  79. sctp_cmd_seq_t *);
  80. typedef void (sctp_timer_event_t) (unsigned long);
  81. typedef struct {
  82. sctp_state_fn_t *fn;
  83. const char *name;
  84. } sctp_sm_table_entry_t;
  85. /* A naming convention of "sctp_sf_xxx" applies to all the state functions
  86. * currently in use.
  87. */
  88. /* Prototypes for generic state functions. */
  89. sctp_state_fn_t sctp_sf_not_impl;
  90. sctp_state_fn_t sctp_sf_bug;
  91. /* Prototypes for gener timer state functions. */
  92. sctp_state_fn_t sctp_sf_timer_ignore;
  93. /* Prototypes for chunk state functions. */
  94. sctp_state_fn_t sctp_sf_do_9_1_abort;
  95. sctp_state_fn_t sctp_sf_cookie_wait_abort;
  96. sctp_state_fn_t sctp_sf_cookie_echoed_abort;
  97. sctp_state_fn_t sctp_sf_shutdown_pending_abort;
  98. sctp_state_fn_t sctp_sf_shutdown_sent_abort;
  99. sctp_state_fn_t sctp_sf_shutdown_ack_sent_abort;
  100. sctp_state_fn_t sctp_sf_do_5_1B_init;
  101. sctp_state_fn_t sctp_sf_do_5_1C_ack;
  102. sctp_state_fn_t sctp_sf_do_5_1D_ce;
  103. sctp_state_fn_t sctp_sf_do_5_1E_ca;
  104. sctp_state_fn_t sctp_sf_do_4_C;
  105. sctp_state_fn_t sctp_sf_eat_data_6_2;
  106. sctp_state_fn_t sctp_sf_eat_data_fast_4_4;
  107. sctp_state_fn_t sctp_sf_eat_sack_6_2;
  108. sctp_state_fn_t sctp_sf_operr_notify;
  109. sctp_state_fn_t sctp_sf_t1_init_timer_expire;
  110. sctp_state_fn_t sctp_sf_t1_cookie_timer_expire;
  111. sctp_state_fn_t sctp_sf_t2_timer_expire;
  112. sctp_state_fn_t sctp_sf_t4_timer_expire;
  113. sctp_state_fn_t sctp_sf_t5_timer_expire;
  114. sctp_state_fn_t sctp_sf_sendbeat_8_3;
  115. sctp_state_fn_t sctp_sf_beat_8_3;
  116. sctp_state_fn_t sctp_sf_backbeat_8_3;
  117. sctp_state_fn_t sctp_sf_do_9_2_final;
  118. sctp_state_fn_t sctp_sf_do_9_2_shutdown;
  119. sctp_state_fn_t sctp_sf_do_ecn_cwr;
  120. sctp_state_fn_t sctp_sf_do_ecne;
  121. sctp_state_fn_t sctp_sf_ootb;
  122. sctp_state_fn_t sctp_sf_pdiscard;
  123. sctp_state_fn_t sctp_sf_violation;
  124. sctp_state_fn_t sctp_sf_discard_chunk;
  125. sctp_state_fn_t sctp_sf_do_5_2_1_siminit;
  126. sctp_state_fn_t sctp_sf_do_5_2_2_dupinit;
  127. sctp_state_fn_t sctp_sf_do_5_2_3_initack;
  128. sctp_state_fn_t sctp_sf_do_5_2_4_dupcook;
  129. sctp_state_fn_t sctp_sf_unk_chunk;
  130. sctp_state_fn_t sctp_sf_do_8_5_1_E_sa;
  131. sctp_state_fn_t sctp_sf_cookie_echoed_err;
  132. sctp_state_fn_t sctp_sf_do_asconf;
  133. sctp_state_fn_t sctp_sf_do_asconf_ack;
  134. sctp_state_fn_t sctp_sf_do_9_2_reshutack;
  135. sctp_state_fn_t sctp_sf_eat_fwd_tsn;
  136. sctp_state_fn_t sctp_sf_eat_fwd_tsn_fast;
  137. sctp_state_fn_t sctp_sf_eat_auth;
  138. /* Prototypes for primitive event state functions. */
  139. sctp_state_fn_t sctp_sf_do_prm_asoc;
  140. sctp_state_fn_t sctp_sf_do_prm_send;
  141. sctp_state_fn_t sctp_sf_do_9_2_prm_shutdown;
  142. sctp_state_fn_t sctp_sf_cookie_wait_prm_shutdown;
  143. sctp_state_fn_t sctp_sf_cookie_echoed_prm_shutdown;
  144. sctp_state_fn_t sctp_sf_do_9_1_prm_abort;
  145. sctp_state_fn_t sctp_sf_cookie_wait_prm_abort;
  146. sctp_state_fn_t sctp_sf_cookie_echoed_prm_abort;
  147. sctp_state_fn_t sctp_sf_shutdown_pending_prm_abort;
  148. sctp_state_fn_t sctp_sf_shutdown_sent_prm_abort;
  149. sctp_state_fn_t sctp_sf_shutdown_ack_sent_prm_abort;
  150. sctp_state_fn_t sctp_sf_error_closed;
  151. sctp_state_fn_t sctp_sf_error_shutdown;
  152. sctp_state_fn_t sctp_sf_ignore_primitive;
  153. sctp_state_fn_t sctp_sf_do_prm_requestheartbeat;
  154. sctp_state_fn_t sctp_sf_do_prm_asconf;
  155. /* Prototypes for other event state functions. */
  156. sctp_state_fn_t sctp_sf_do_9_2_start_shutdown;
  157. sctp_state_fn_t sctp_sf_do_9_2_shutdown_ack;
  158. sctp_state_fn_t sctp_sf_ignore_other;
  159. sctp_state_fn_t sctp_sf_cookie_wait_icmp_abort;
  160. /* Prototypes for timeout event state functions. */
  161. sctp_state_fn_t sctp_sf_do_6_3_3_rtx;
  162. sctp_state_fn_t sctp_sf_do_6_2_sack;
  163. sctp_state_fn_t sctp_sf_autoclose_timer_expire;
  164. /* Prototypes for utility support functions. */
  165. __u8 sctp_get_chunk_type(struct sctp_chunk *chunk);
  166. const sctp_sm_table_entry_t *sctp_sm_lookup_event(sctp_event_t,
  167. sctp_state_t,
  168. sctp_subtype_t);
  169. int sctp_chunk_iif(const struct sctp_chunk *);
  170. struct sctp_association *sctp_make_temp_asoc(const struct sctp_endpoint *,
  171. struct sctp_chunk *,
  172. gfp_t gfp);
  173. __u32 sctp_generate_verification_tag(void);
  174. void sctp_populate_tie_tags(__u8 *cookie, __u32 curTag, __u32 hisTag);
  175. /* Prototypes for chunk-building functions. */
  176. struct sctp_chunk *sctp_make_init(const struct sctp_association *,
  177. const struct sctp_bind_addr *,
  178. gfp_t gfp, int vparam_len);
  179. struct sctp_chunk *sctp_make_init_ack(const struct sctp_association *,
  180. const struct sctp_chunk *,
  181. const gfp_t gfp,
  182. const int unkparam_len);
  183. struct sctp_chunk *sctp_make_cookie_echo(const struct sctp_association *,
  184. const struct sctp_chunk *);
  185. struct sctp_chunk *sctp_make_cookie_ack(const struct sctp_association *,
  186. const struct sctp_chunk *);
  187. struct sctp_chunk *sctp_make_cwr(const struct sctp_association *,
  188. const __u32 lowest_tsn,
  189. const struct sctp_chunk *);
  190. struct sctp_chunk * sctp_make_datafrag_empty(struct sctp_association *,
  191. const struct sctp_sndrcvinfo *sinfo,
  192. int len, const __u8 flags,
  193. __u16 ssn);
  194. struct sctp_chunk *sctp_make_ecne(const struct sctp_association *,
  195. const __u32);
  196. struct sctp_chunk *sctp_make_sack(const struct sctp_association *);
  197. struct sctp_chunk *sctp_make_shutdown(const struct sctp_association *asoc,
  198. const struct sctp_chunk *chunk);
  199. struct sctp_chunk *sctp_make_shutdown_ack(const struct sctp_association *asoc,
  200. const struct sctp_chunk *);
  201. struct sctp_chunk *sctp_make_shutdown_complete(const struct sctp_association *,
  202. const struct sctp_chunk *);
  203. void sctp_init_cause(struct sctp_chunk *, __be16 cause, size_t);
  204. struct sctp_chunk *sctp_make_abort(const struct sctp_association *,
  205. const struct sctp_chunk *,
  206. const size_t hint);
  207. struct sctp_chunk *sctp_make_abort_no_data(const struct sctp_association *,
  208. const struct sctp_chunk *,
  209. __u32 tsn);
  210. struct sctp_chunk *sctp_make_abort_user(const struct sctp_association *,
  211. const struct msghdr *, size_t msg_len);
  212. struct sctp_chunk *sctp_make_abort_violation(const struct sctp_association *,
  213. const struct sctp_chunk *,
  214. const __u8 *,
  215. const size_t );
  216. struct sctp_chunk *sctp_make_heartbeat(const struct sctp_association *,
  217. const struct sctp_transport *,
  218. const void *payload,
  219. const size_t paylen);
  220. struct sctp_chunk *sctp_make_heartbeat_ack(const struct sctp_association *,
  221. const struct sctp_chunk *,
  222. const void *payload,
  223. const size_t paylen);
  224. struct sctp_chunk *sctp_make_op_error(const struct sctp_association *,
  225. const struct sctp_chunk *chunk,
  226. __be16 cause_code,
  227. const void *payload,
  228. size_t paylen);
  229. struct sctp_chunk *sctp_make_asconf_update_ip(struct sctp_association *,
  230. union sctp_addr *,
  231. struct sockaddr *,
  232. int, __be16);
  233. struct sctp_chunk *sctp_make_asconf_set_prim(struct sctp_association *asoc,
  234. union sctp_addr *addr);
  235. int sctp_verify_asconf(const struct sctp_association *asoc,
  236. struct sctp_paramhdr *param_hdr, void *chunk_end,
  237. struct sctp_paramhdr **errp);
  238. struct sctp_chunk *sctp_process_asconf(struct sctp_association *asoc,
  239. struct sctp_chunk *asconf);
  240. int sctp_process_asconf_ack(struct sctp_association *asoc,
  241. struct sctp_chunk *asconf_ack);
  242. struct sctp_chunk *sctp_make_fwdtsn(const struct sctp_association *asoc,
  243. __u32 new_cum_tsn, size_t nstreams,
  244. struct sctp_fwdtsn_skip *skiplist);
  245. struct sctp_chunk *sctp_make_auth(const struct sctp_association *asoc);
  246. void sctp_chunk_assign_tsn(struct sctp_chunk *);
  247. void sctp_chunk_assign_ssn(struct sctp_chunk *);
  248. /* Prototypes for statetable processing. */
  249. int sctp_do_sm(sctp_event_t event_type, sctp_subtype_t subtype,
  250. sctp_state_t state,
  251. struct sctp_endpoint *,
  252. struct sctp_association *asoc,
  253. void *event_arg,
  254. gfp_t gfp);
  255. /* 2nd level prototypes */
  256. void sctp_generate_t3_rtx_event(unsigned long peer);
  257. void sctp_generate_heartbeat_event(unsigned long peer);
  258. void sctp_ootb_pkt_free(struct sctp_packet *);
  259. struct sctp_association *sctp_unpack_cookie(const struct sctp_endpoint *,
  260. const struct sctp_association *,
  261. struct sctp_chunk *,
  262. gfp_t gfp, int *err,
  263. struct sctp_chunk **err_chk_p);
  264. int sctp_addip_addr_config(struct sctp_association *, sctp_param_t,
  265. struct sockaddr_storage*, int);
  266. /* 3rd level prototypes */
  267. __u32 sctp_generate_tag(const struct sctp_endpoint *);
  268. __u32 sctp_generate_tsn(const struct sctp_endpoint *);
  269. /* Extern declarations for major data structures. */
  270. extern sctp_timer_event_t *sctp_timer_events[SCTP_NUM_TIMEOUT_TYPES];
  271. /* Get the size of a DATA chunk payload. */
  272. static inline __u16 sctp_data_size(struct sctp_chunk *chunk)
  273. {
  274. __u16 size;
  275. size = ntohs(chunk->chunk_hdr->length);
  276. size -= sizeof(sctp_data_chunk_t);
  277. return size;
  278. }
  279. /* Compare two TSNs */
  280. /* RFC 1982 - Serial Number Arithmetic
  281. *
  282. * 2. Comparison
  283. * Then, s1 is said to be equal to s2 if and only if i1 is equal to i2,
  284. * in all other cases, s1 is not equal to s2.
  285. *
  286. * s1 is said to be less than s2 if, and only if, s1 is not equal to s2,
  287. * and
  288. *
  289. * (i1 < i2 and i2 - i1 < 2^(SERIAL_BITS - 1)) or
  290. * (i1 > i2 and i1 - i2 > 2^(SERIAL_BITS - 1))
  291. *
  292. * s1 is said to be greater than s2 if, and only if, s1 is not equal to
  293. * s2, and
  294. *
  295. * (i1 < i2 and i2 - i1 > 2^(SERIAL_BITS - 1)) or
  296. * (i1 > i2 and i1 - i2 < 2^(SERIAL_BITS - 1))
  297. */
  298. /*
  299. * RFC 2960
  300. * 1.6 Serial Number Arithmetic
  301. *
  302. * Comparisons and arithmetic on TSNs in this document SHOULD use Serial
  303. * Number Arithmetic as defined in [RFC1982] where SERIAL_BITS = 32.
  304. */
  305. enum {
  306. TSN_SIGN_BIT = (1<<31)
  307. };
  308. static inline int TSN_lt(__u32 s, __u32 t)
  309. {
  310. return (((s) - (t)) & TSN_SIGN_BIT);
  311. }
  312. static inline int TSN_lte(__u32 s, __u32 t)
  313. {
  314. return (((s) == (t)) || (((s) - (t)) & TSN_SIGN_BIT));
  315. }
  316. /* Compare two SSNs */
  317. /*
  318. * RFC 2960
  319. * 1.6 Serial Number Arithmetic
  320. *
  321. * Comparisons and arithmetic on Stream Sequence Numbers in this document
  322. * SHOULD use Serial Number Arithmetic as defined in [RFC1982] where
  323. * SERIAL_BITS = 16.
  324. */
  325. enum {
  326. SSN_SIGN_BIT = (1<<15)
  327. };
  328. static inline int SSN_lt(__u16 s, __u16 t)
  329. {
  330. return (((s) - (t)) & SSN_SIGN_BIT);
  331. }
  332. static inline int SSN_lte(__u16 s, __u16 t)
  333. {
  334. return (((s) == (t)) || (((s) - (t)) & SSN_SIGN_BIT));
  335. }
  336. /*
  337. * ADDIP 3.1.1
  338. * The valid range of Serial Number is from 0 to 4294967295 (2**32 - 1). Serial
  339. * Numbers wrap back to 0 after reaching 4294967295.
  340. */
  341. enum {
  342. ADDIP_SERIAL_SIGN_BIT = (1<<31)
  343. };
  344. static inline int ADDIP_SERIAL_gte(__u16 s, __u16 t)
  345. {
  346. return (((s) == (t)) || (((t) - (s)) & ADDIP_SERIAL_SIGN_BIT));
  347. }
  348. /* Run sctp_add_cmd() generating a BUG() if there is a failure. */
  349. static inline void sctp_add_cmd_sf(sctp_cmd_seq_t *seq, sctp_verb_t verb, sctp_arg_t obj)
  350. {
  351. if (unlikely(!sctp_add_cmd(seq, verb, obj)))
  352. BUG();
  353. }
  354. /* Check VTAG of the packet matches the sender's own tag. */
  355. static inline int
  356. sctp_vtag_verify(const struct sctp_chunk *chunk,
  357. const struct sctp_association *asoc)
  358. {
  359. /* RFC 2960 Sec 8.5 When receiving an SCTP packet, the endpoint
  360. * MUST ensure that the value in the Verification Tag field of
  361. * the received SCTP packet matches its own Tag. If the received
  362. * Verification Tag value does not match the receiver's own
  363. * tag value, the receiver shall silently discard the packet...
  364. */
  365. if (ntohl(chunk->sctp_hdr->vtag) == asoc->c.my_vtag)
  366. return 1;
  367. return 0;
  368. }
  369. /* Check VTAG of the packet matches the sender's own tag and the T bit is
  370. * not set, OR its peer's tag and the T bit is set in the Chunk Flags.
  371. */
  372. static inline int
  373. sctp_vtag_verify_either(const struct sctp_chunk *chunk,
  374. const struct sctp_association *asoc)
  375. {
  376. /* RFC 2960 Section 8.5.1, sctpimpguide Section 2.41
  377. *
  378. * B) The receiver of a ABORT MUST accept the packet
  379. * if the Verification Tag field of the packet matches its own tag
  380. * and the T bit is not set
  381. * OR
  382. * it is set to its peer's tag and the T bit is set in the Chunk
  383. * Flags.
  384. * Otherwise, the receiver MUST silently discard the packet
  385. * and take no further action.
  386. *
  387. * C) The receiver of a SHUTDOWN COMPLETE shall accept the packet
  388. * if the Verification Tag field of the packet matches its own tag
  389. * and the T bit is not set
  390. * OR
  391. * it is set to its peer's tag and the T bit is set in the Chunk
  392. * Flags.
  393. * Otherwise, the receiver MUST silently discard the packet
  394. * and take no further action. An endpoint MUST ignore the
  395. * SHUTDOWN COMPLETE if it is not in the SHUTDOWN-ACK-SENT state.
  396. */
  397. if ((!sctp_test_T_bit(chunk) &&
  398. (ntohl(chunk->sctp_hdr->vtag) == asoc->c.my_vtag)) ||
  399. (sctp_test_T_bit(chunk) &&
  400. (ntohl(chunk->sctp_hdr->vtag) == asoc->c.peer_vtag))) {
  401. return 1;
  402. }
  403. return 0;
  404. }
  405. #endif /* __sctp_sm_h__ */