1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 22 /* 23 * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 24 * Use is subject to license terms. 25 */ 26 27 #ifndef _INET_SCTP_SCTP_IMPL_H 28 #define _INET_SCTP_SCTP_IMPL_H 29 30 #include <sys/inttypes.h> 31 #include <sys/taskq.h> 32 #include <sys/list.h> 33 #include <sys/strsun.h> 34 #include <sys/zone.h> 35 #include <netinet/ip6.h> 36 #include <inet/optcom.h> 37 #include <netinet/sctp.h> 38 #include <inet/sctp_itf.h> 39 #include "sctp_stack.h" 40 41 #ifdef __cplusplus 42 extern "C" { 43 #endif 44 45 /* Streams device identifying info and version */ 46 #define SCTP_DEV_IDINFO "SCTP Streams device 1.0" 47 48 #define SSN_GT(a, b) ((int16_t)((a)-(b)) > 0) 49 #define SSN_GE(a, b) ((int16_t)((a)-(b)) >= 0) 50 51 /* Default buffer size and flow control wake up threshold. */ 52 #define SCTP_XMIT_LOWATER 8192 53 #define SCTP_XMIT_HIWATER 102400 54 #define SCTP_RECV_LOWATER 8192 55 #define SCTP_RECV_HIWATER 102400 56 57 /* SCTP Timer control structure */ 58 typedef struct sctpt_s { 59 pfv_t sctpt_pfv; /* The routine we are to call */ 60 struct sctp_s *sctpt_sctp; /* The parameter we are to pass in */ 61 struct sctp_faddr_s *sctpt_faddr; 62 } sctpt_t; 63 64 /* 65 * Maximum number of duplicate TSNs we can report. This is currently 66 * static, and governs the size of the mblk used to hold the duplicate 67 * reports. The use of duplcate TSN reports is currently experimental, 68 * so for now a static limit should suffice. 69 */ 70 #define SCTP_DUP_MBLK_SZ 64 71 72 #define SCTP_IS_ADDR_UNSPEC(isv4, addr) \ 73 ((isv4) ? IN6_IS_ADDR_V4MAPPED_ANY(&(addr)) : \ 74 IN6_IS_ADDR_UNSPECIFIED(&(addr))) 75 76 /* 77 * SCTP parameters 78 */ 79 /* Named Dispatch Parameter Management Structure */ 80 typedef struct sctpparam_s { 81 uint32_t sctp_param_min; 82 uint32_t sctp_param_max; 83 uint32_t sctp_param_val; 84 char *sctp_param_name; 85 } sctpparam_t; 86 87 #define sctps_max_init_retr sctps_params[0].sctp_param_val 88 #define sctps_max_init_retr_high sctps_params[0].sctp_param_max 89 #define sctps_max_init_retr_low sctps_params[0].sctp_param_min 90 #define sctps_pa_max_retr sctps_params[1].sctp_param_val 91 #define sctps_pa_max_retr_high sctps_params[1].sctp_param_max 92 #define sctps_pa_max_retr_low sctps_params[1].sctp_param_min 93 #define sctps_pp_max_retr sctps_params[2].sctp_param_val 94 #define sctps_pp_max_retr_high sctps_params[2].sctp_param_max 95 #define sctps_pp_max_retr_low sctps_params[2].sctp_param_min 96 #define sctps_cwnd_max_ sctps_params[3].sctp_param_val 97 #define __sctps_not_used1 sctps_params[4].sctp_param_val 98 #define sctps_smallest_nonpriv_port sctps_params[5].sctp_param_val 99 #define sctps_ipv4_ttl sctps_params[6].sctp_param_val 100 #define sctps_heartbeat_interval sctps_params[7].sctp_param_val 101 #define sctps_heartbeat_interval_high sctps_params[7].sctp_param_max 102 #define sctps_heartbeat_interval_low sctps_params[7].sctp_param_min 103 #define sctps_initial_mtu sctps_params[8].sctp_param_val 104 #define sctps_mtu_probe_interval sctps_params[9].sctp_param_val 105 #define sctps_new_secret_interval sctps_params[10].sctp_param_val 106 #define sctps_deferred_ack_interval sctps_params[11].sctp_param_val 107 #define sctps_snd_lowat_fraction sctps_params[12].sctp_param_val 108 #define sctps_ignore_path_mtu sctps_params[13].sctp_param_val 109 #define sctps_initial_ssthresh sctps_params[14].sctp_param_val 110 #define sctps_smallest_anon_port sctps_params[15].sctp_param_val 111 #define sctps_largest_anon_port sctps_params[16].sctp_param_val 112 #define sctps_xmit_hiwat sctps_params[17].sctp_param_val 113 #define sctps_xmit_lowat sctps_params[18].sctp_param_val 114 #define sctps_recv_hiwat sctps_params[19].sctp_param_val 115 #define sctps_max_buf sctps_params[20].sctp_param_val 116 #define sctps_rtt_updates sctps_params[21].sctp_param_val 117 #define sctps_ipv6_hoplimit sctps_params[22].sctp_param_val 118 #define sctps_rto_ming sctps_params[23].sctp_param_val 119 #define sctps_rto_ming_high sctps_params[23].sctp_param_max 120 #define sctps_rto_ming_low sctps_params[23].sctp_param_min 121 #define sctps_rto_maxg sctps_params[24].sctp_param_val 122 #define sctps_rto_maxg_high sctps_params[24].sctp_param_max 123 #define sctps_rto_maxg_low sctps_params[24].sctp_param_min 124 #define sctps_rto_initialg sctps_params[25].sctp_param_val 125 #define sctps_rto_initialg_high sctps_params[25].sctp_param_max 126 #define sctps_rto_initialg_low sctps_params[25].sctp_param_min 127 #define sctps_cookie_life sctps_params[26].sctp_param_val 128 #define sctps_cookie_life_high sctps_params[26].sctp_param_max 129 #define sctps_cookie_life_low sctps_params[26].sctp_param_min 130 #define sctps_max_in_streams sctps_params[27].sctp_param_val 131 #define sctps_max_in_streams_high sctps_params[27].sctp_param_max 132 #define sctps_max_in_streams_low sctps_params[27].sctp_param_min 133 #define sctps_initial_out_streams sctps_params[28].sctp_param_val 134 #define sctps_initial_out_streams_high sctps_params[28].sctp_param_max 135 #define sctps_initial_out_streams_low sctps_params[28].sctp_param_min 136 #define sctps_shutack_wait_bound sctps_params[29].sctp_param_val 137 #define sctps_maxburst sctps_params[30].sctp_param_val 138 #define sctps_addip_enabled sctps_params[31].sctp_param_val 139 #define sctps_recv_hiwat_minmss sctps_params[32].sctp_param_val 140 #define sctps_slow_start_initial sctps_params[33].sctp_param_val 141 #define sctps_slow_start_after_idle sctps_params[34].sctp_param_val 142 #define sctps_prsctp_enabled sctps_params[35].sctp_param_val 143 #define sctps_fast_rxt_thresh sctps_params[36].sctp_param_val 144 #define sctps_deferred_acks_max sctps_params[37].sctp_param_val 145 146 /* 147 * sctp_wroff_xtra is the extra space in front of SCTP/IP header for link 148 * layer header. It has to be a multiple of 4. 149 */ 150 #define sctps_wroff_xtra sctps_wroff_xtra_param->sctp_param_val 151 152 /* 153 * Retransmission timer start and stop macro for a given faddr. 154 */ 155 #define SCTP_FADDR_TIMER_RESTART(sctp, fp, intvl) \ 156 { \ 157 dprint(3, ("faddr_timer_restart: fp=%p %x:%x:%x:%x %d\n", \ 158 (void *)(fp), SCTP_PRINTADDR((fp)->faddr), (int)(intvl))); \ 159 sctp_timer((sctp), (fp)->timer_mp, (intvl)); \ 160 (fp)->timer_running = 1; \ 161 } 162 163 #define SCTP_FADDR_TIMER_STOP(fp) \ 164 ASSERT((fp)->timer_mp != NULL); \ 165 if ((fp)->timer_running) { \ 166 sctp_timer_stop((fp)->timer_mp); \ 167 (fp)->timer_running = 0; \ 168 } 169 170 /* For per endpoint association statistics */ 171 #define SCTP_MAX_RTO(sctp, fp) { \ 172 /* \ 173 * Record the maximum observed RTO, \ 174 * sctp_maxrto is zeroed elsewhere \ 175 * at the end of each stats request. \ 176 */ \ 177 (sctp)->sctp_maxrto = \ 178 MAX((sctp)->sctp_maxrto, (fp)->rto); \ 179 DTRACE_PROBE2(sctp__maxrto, sctp_t *, \ 180 sctp, struct sctp_faddr_s, fp); \ 181 } 182 183 #define SCTP_CALC_RXT(sctp, fp) \ 184 { \ 185 if (((fp)->rto <<= 1) > (sctp)->sctp_rto_max) \ 186 (fp)->rto = (sctp)->sctp_rto_max; \ 187 SCTP_MAX_RTO(sctp, fp); \ 188 } 189 190 191 #define SCTP_MAX_COMBINED_HEADER_LENGTH (60 + 12) /* Maxed out ip + sctp */ 192 #define SCTP_MAX_IP_OPTIONS_LENGTH (60 - IP_SIMPLE_HDR_LENGTH) 193 #define SCTP_MAX_HDR_LENGTH 60 194 #define ICMP_MIN_SCTP_HDR_LEN (ICMP_MIN_TP_HDR_LEN + sizeof (sctp_hdr_t)) 195 196 #define SCTP_SECRET_LEN 16 197 198 #define SCTP_REFHOLD(sctp) { \ 199 mutex_enter(&(sctp)->sctp_reflock); \ 200 (sctp)->sctp_refcnt++; \ 201 ASSERT((sctp)->sctp_refcnt != 0); \ 202 mutex_exit(&(sctp)->sctp_reflock); \ 203 } 204 205 #define SCTP_REFRELE(sctp) { \ 206 mutex_enter(&(sctp)->sctp_reflock); \ 207 ASSERT((sctp)->sctp_refcnt != 0); \ 208 if (--(sctp)->sctp_refcnt == 0) { \ 209 mutex_exit(&(sctp)->sctp_reflock); \ 210 CONN_DEC_REF((sctp)->sctp_connp); \ 211 } else { \ 212 mutex_exit(&(sctp)->sctp_reflock); \ 213 } \ 214 } 215 216 #define SCTP_G_Q_REFHOLD(sctps) { \ 217 atomic_add_32(&(sctps)->sctps_g_q_ref, 1); \ 218 ASSERT((sctps)->sctps_g_q_ref != 0); \ 219 DTRACE_PROBE1(sctp__g__q__refhold, sctp_stack_t, sctps); \ 220 } 221 222 /* 223 * Decrement the reference count on sctp_g_q 224 * In architectures e.g sun4u, where atomic_add_32_nv is just 225 * a cas, we need to maintain the right memory barrier semantics 226 * as that of mutex_exit i.e all the loads and stores should complete 227 * before the cas is executed. membar_exit() does that here. 228 */ 229 #define SCTP_G_Q_REFRELE(sctps) { \ 230 ASSERT((sctps)->sctps_g_q_ref != 0); \ 231 membar_exit(); \ 232 DTRACE_PROBE1(sctp__g__q__refrele, sctp_stack_t, sctps); \ 233 if (atomic_add_32_nv(&(sctps)->sctps_g_q_ref, -1) == 0) \ 234 sctp_g_q_inactive(sctps); \ 235 } 236 237 #define SCTP_PRINTADDR(a) (a).s6_addr32[0], (a).s6_addr32[1],\ 238 (a).s6_addr32[2], (a).s6_addr32[3] 239 240 #define CONN2SCTP(conn) ((sctp_t *)(&((conn_t *)conn)[1])) 241 242 /* 243 * Outbound data, flags and macros for per-message, per-chunk info 244 */ 245 typedef struct { 246 int64_t smh_ttl; /* Time to Live */ 247 int64_t smh_tob; /* Time of Birth */ 248 uint32_t smh_context; 249 uint16_t smh_sid; 250 uint16_t smh_ssn; 251 uint32_t smh_ppid; 252 uint16_t smh_flags; 253 uint32_t smh_msglen; 254 } sctp_msg_hdr_t; 255 256 #define SCTP_CHUNK_FLAG_SENT 0x01 257 #define SCTP_CHUNK_FLAG_REXMIT 0x02 258 #define SCTP_CHUNK_FLAG_ACKED 0x04 259 #define SCTP_MSG_FLAG_CHUNKED 0x08 260 #define SCTP_MSG_FLAG_ABANDONED 0x10 261 #define SCTP_CHUNK_FLAG_ABANDONED 0x20 262 263 #define SCTP_CHUNK_CLEAR_FLAGS(mp) ((mp)->b_flag = 0) 264 /* 265 * If we are transmitting the chunk for the first time we assign the TSN and 266 * SSN here. The reason we assign the SSN here (as opposed to doing it in 267 * sctp_chunkify()) is that the chunk may expire, if PRSCTP is enabled, before 268 * we get a chance to send it out. If we assign the SSN in sctp_chunkify() 269 * and this happens, then we need to send a Forward TSN to the peer, which 270 * will be expecting this SSN, assuming ordered. If we assign it here we 271 * can just take out the chunk from the transmit list without having to 272 * send a Forward TSN chunk. While assigning the SSN we use (meta)->b_cont 273 * to determine if it needs a new SSN (i.e. the next SSN for the stream), 274 * since (meta)->b_cont signifies the first chunk of a message (if the message 275 * is unordered, then the SSN is 0). 276 * 277 */ 278 #define SCTP_CHUNK_SENT(sctp, mp, sdc, fp, chunkdata, meta) { \ 279 if (!SCTP_CHUNK_ISSENT(mp)) { \ 280 sctp_msg_hdr_t *mhdr = (sctp_msg_hdr_t *)(meta)->b_rptr; \ 281 ASSERT(!SCTP_CHUNK_ABANDONED(mp)); \ 282 (mp)->b_flag = SCTP_CHUNK_FLAG_SENT; \ 283 (sdc)->sdh_tsn = htonl((sctp)->sctp_ltsn++); \ 284 if ((mhdr)->smh_flags & MSG_UNORDERED) { \ 285 (sdc)->sdh_ssn = 0; \ 286 SCTP_DATA_SET_UBIT(sdc); \ 287 BUMP_LOCAL((sctp)->sctp_oudchunks); \ 288 } else { \ 289 BUMP_LOCAL((sctp)->sctp_odchunks); \ 290 if ((mp) == (meta)->b_cont) { \ 291 mhdr->smh_ssn = htons( \ 292 (sctp)->sctp_ostrcntrs[mhdr->smh_sid]++); \ 293 } \ 294 (sdc)->sdh_ssn = mhdr->smh_ssn; \ 295 } \ 296 (sctp)->sctp_unacked += (chunkdata); \ 297 (sctp)->sctp_unsent -= (chunkdata); \ 298 (sctp)->sctp_frwnd -= (chunkdata); \ 299 } else { \ 300 if (SCTP_CHUNK_ISACKED(mp)) { \ 301 (sctp)->sctp_unacked += (chunkdata); \ 302 } else { \ 303 ASSERT(SCTP_CHUNK_DEST(mp)->suna >= ((chunkdata) + \ 304 sizeof (*sdc))); \ 305 SCTP_CHUNK_DEST(mp)->suna -= ((chunkdata) + \ 306 sizeof (*sdc)); \ 307 } \ 308 (mp)->b_flag &= ~(SCTP_CHUNK_FLAG_REXMIT | \ 309 SCTP_CHUNK_FLAG_ACKED); \ 310 SCTP_CHUNK_SET_SACKCNT(mp, 0); \ 311 BUMP_LOCAL(sctp->sctp_rxtchunks); \ 312 BUMP_LOCAL((sctp)->sctp_T3expire); \ 313 BUMP_LOCAL((fp)->T3expire); \ 314 } \ 315 SCTP_SET_CHUNK_DEST(mp, fp); \ 316 (fp)->suna += ((chunkdata) + sizeof (*sdc)); \ 317 } 318 319 #define SCTP_CHUNK_ISSENT(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_SENT) 320 #define SCTP_CHUNK_CANSEND(mp) \ 321 (!(SCTP_CHUNK_ABANDONED(mp)) && \ 322 (((mp)->b_flag & (SCTP_CHUNK_FLAG_REXMIT|SCTP_CHUNK_FLAG_SENT)) != \ 323 SCTP_CHUNK_FLAG_SENT)) 324 325 #define SCTP_CHUNK_DEST(mp) ((sctp_faddr_t *)(mp)->b_queue) 326 #define SCTP_SET_CHUNK_DEST(mp, fp) ((mp)->b_queue = (queue_t *)fp) 327 328 #define SCTP_CHUNK_REXMIT(mp) ((mp)->b_flag |= SCTP_CHUNK_FLAG_REXMIT) 329 #define SCTP_CHUNK_CLEAR_REXMIT(mp) ((mp)->b_flag &= ~SCTP_CHUNK_FLAG_REXMIT) 330 #define SCTP_CHUNK_WANT_REXMIT(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_REXMIT) 331 332 #define SCTP_CHUNK_ACKED(mp) \ 333 ((mp)->b_flag = (SCTP_CHUNK_FLAG_SENT|SCTP_CHUNK_FLAG_ACKED)) 334 #define SCTP_CHUNK_ISACKED(mp) ((mp)->b_flag & SCTP_CHUNK_FLAG_ACKED) 335 #define SCTP_CHUNK_CLEAR_ACKED(mp) ((mp)->b_flag &= ~SCTP_CHUNK_FLAG_ACKED) 336 337 #define SCTP_CHUNK_SACKCNT(mp) ((intptr_t)((mp)->b_prev)) 338 #define SCTP_CHUNK_SET_SACKCNT(mp, val) ((mp)->b_prev = \ 339 (mblk_t *)(uintptr_t)(val)) 340 341 #define SCTP_MSG_SET_CHUNKED(mp) ((mp)->b_flag |= SCTP_MSG_FLAG_CHUNKED) 342 #define SCTP_MSG_CLEAR_CHUNKED(mp)((mp)->b_flag &= ~SCTP_MSG_FLAG_CHUNKED) 343 #define SCTP_IS_MSG_CHUNKED(mp) ((mp)->b_flag & SCTP_MSG_FLAG_CHUNKED) 344 345 /* For PR-SCTP */ 346 #define SCTP_ABANDON_CHUNK(mp) ((mp)->b_flag |= SCTP_CHUNK_FLAG_ABANDONED) 347 #define SCTP_CHUNK_ABANDONED(mp) \ 348 ((mp)->b_flag & SCTP_CHUNK_FLAG_ABANDONED) 349 350 #define SCTP_MSG_SET_ABANDONED(mp) \ 351 ((mp)->b_flag |= SCTP_MSG_FLAG_ABANDONED) 352 #define SCTP_MSG_CLEAR_ABANDONED(mp)((mp)->b_flag &= ~SCTP_MSG_FLAG_ABANDONED) 353 #define SCTP_IS_MSG_ABANDONED(mp) ((mp)->b_flag & SCTP_MSG_FLAG_ABANDONED) 354 355 /* 356 * Check if a message has expired. A message is expired if 357 * 1. It has a non-zero time to live value and has not been sent before 358 * that time expires. 359 * 2. It is sent using PRSCTP and it has not been SACK'ed before 360 * its lifetime expires. 361 */ 362 #define SCTP_MSG_TO_BE_ABANDONED(meta, mhdr, sctp) \ 363 (((!SCTP_CHUNK_ISSENT((meta)->b_cont) && (mhdr)->smh_ttl > 0) || \ 364 ((sctp)->sctp_prsctp_aware && ((mhdr)->smh_flags & MSG_PR_SCTP))) && \ 365 ((lbolt64 - (mhdr)->smh_tob) > (mhdr)->smh_ttl)) 366 367 /* SCTP association hash function. */ 368 #define SCTP_CONN_HASH(sctps, ports) \ 369 ((((ports) ^ ((ports) >> 16)) * 31) & \ 370 ((sctps)->sctps_conn_hash_size - 1)) 371 372 /* 373 * Bind hash array size and hash function. The size must be a power 374 * of 2 and lport must be in host byte order. 375 */ 376 #define SCTP_BIND_FANOUT_SIZE 2048 377 #define SCTP_BIND_HASH(lport) (((lport) * 31) & (SCTP_BIND_FANOUT_SIZE - 1)) 378 379 /* options that SCTP negotiates during association establishment */ 380 #define SCTP_PRSCTP_OPTION 0x01 381 382 /* 383 * Listener hash array size and hash function. The size must be a power 384 * of 2 and lport must be in host byte order. 385 */ 386 #define SCTP_LISTEN_FANOUT_SIZE 512 387 #define SCTP_LISTEN_HASH(lport) (((lport) * 31) & (SCTP_LISTEN_FANOUT_SIZE - 1)) 388 389 typedef struct sctp_tf_s { 390 struct sctp_s *tf_sctp; 391 kmutex_t tf_lock; 392 } sctp_tf_t; 393 394 /* Round up the value to the nearest mss. */ 395 #define MSS_ROUNDUP(value, mss) ((((value) - 1) / (mss) + 1) * (mss)) 396 397 extern sin_t sctp_sin_null; /* Zero address for quick clears */ 398 extern sin6_t sctp_sin6_null; /* Zero address for quick clears */ 399 400 #define SCTP_IS_DETACHED(sctp) ((sctp)->sctp_detached) 401 402 /* 403 * Object to represent database of options to search passed to 404 * {sock,tpi}optcom_req() interface routine to take care of option 405 * management and associated methods. 406 * XXX These and other externs should ideally move to a SCTP header 407 */ 408 extern optdb_obj_t sctp_opt_obj; 409 extern uint_t sctp_max_optbuf_len; 410 411 /* Data structure used to track received TSNs */ 412 typedef struct sctp_set_s { 413 struct sctp_set_s *next; 414 struct sctp_set_s *prev; 415 uint32_t begin; 416 uint32_t end; 417 } sctp_set_t; 418 419 /* Data structure used to track TSNs for PR-SCTP */ 420 typedef struct sctp_ftsn_set_s { 421 struct sctp_ftsn_set_s *next; 422 ftsn_entry_t ftsn_entries; 423 } sctp_ftsn_set_t; 424 425 /* Data structure used to track incoming SCTP streams */ 426 typedef struct sctp_instr_s { 427 mblk_t *istr_msgs; 428 int istr_nmsgs; 429 uint16_t nextseq; 430 struct sctp_s *sctp; 431 mblk_t *istr_reass; 432 } sctp_instr_t; 433 434 /* Reassembly data structure (per-stream) */ 435 typedef struct sctp_reass_s { 436 uint16_t ssn; 437 uint16_t needed; 438 uint16_t got; 439 uint16_t msglen; /* len of consecutive fragments */ 440 /* from the begining (B-bit) */ 441 mblk_t *tail; 442 boolean_t hasBchunk; /* If the fragment list begins with */ 443 /* a B-bit set chunk */ 444 uint32_t nexttsn; /* TSN of the next fragment we */ 445 /* are expecting */ 446 boolean_t partial_delivered; 447 } sctp_reass_t; 448 449 /* debugging */ 450 #undef dprint 451 #ifdef DEBUG 452 extern int sctpdebug; 453 #define dprint(level, args) { if (sctpdebug > (level)) printf args; } 454 #else 455 #define dprint(level, args) {} 456 #endif 457 458 459 /* Peer address tracking */ 460 461 /* 462 * States for peer addresses 463 * 464 * SCTP_FADDRS_UNCONFIRMED: we have not communicated with this peer address 465 * before, mark it as unconfirmed so that we will not send data to it. 466 * All addresses initially are in unconfirmed state and required 467 * validation. SCTP sends a heartbeat to each of them and when it gets 468 * back a heartbeat ACK, the address will be marked as alive. This 469 * validation fixes a security issue with multihoming. If an attacker 470 * establishes an association with us and tells us that it has addresses 471 * belonging to another host A, this will prevent A from communicating 472 * with us. This is fixed by peer address validation. In the above case, 473 * A will respond with an abort. 474 * 475 * SCTP_FADDRS_ALIVE: this peer address is alive and we can communicate with 476 * it with no problem. 477 * 478 * SCTP_FADDRS_DOWN: we have exceeded the retransmission limit to this 479 * peer address. Once an address is marked down, we will only send 480 * a heartbeat to it every hb_interval in case it becomes alive now. 481 * 482 * SCTP_FADDRS_UNREACH: there is no suitable source address to send to 483 * this peer address. For example, the peer address is v6 but we only 484 * have v4 addresses. It is marked unreachable until there is an 485 * address configuration change. At that time, mark these addresses 486 * as unconfirmed and try again to see if those unreachable addresses 487 * are OK as we may have more source addresses. 488 */ 489 typedef enum { 490 SCTP_FADDRS_UNREACH, 491 SCTP_FADDRS_DOWN, 492 SCTP_FADDRS_ALIVE, 493 SCTP_FADDRS_UNCONFIRMED 494 } faddr_state_t; 495 496 typedef struct sctp_faddr_s { 497 struct sctp_faddr_s *next; 498 faddr_state_t state; 499 500 in6_addr_t faddr; 501 in6_addr_t saddr; 502 503 int64_t hb_expiry; /* time to retransmit heartbeat */ 504 uint32_t hb_interval; /* the heartbeat interval */ 505 506 int rto; /* RTO in tick */ 507 int srtt; /* Smoothed RTT in tick */ 508 int rttvar; /* RTT variance in tick */ 509 uint32_t rtt_updates; 510 int strikes; 511 int max_retr; 512 uint32_t sfa_pmss; 513 uint32_t cwnd; 514 uint32_t ssthresh; 515 uint32_t suna; /* sent - unack'ed */ 516 uint32_t pba; /* partial bytes acked */ 517 uint32_t acked; 518 int64_t lastactive; 519 mblk_t *timer_mp; /* retransmission timer control */ 520 uint32_t 521 hb_pending : 1, 522 timer_running : 1, 523 df : 1, 524 pmtu_discovered : 1, 525 526 rc_timer_running : 1, 527 isv4 : 1, 528 hb_enabled : 1; 529 530 mblk_t *rc_timer_mp; /* reliable control chunk timer */ 531 ire_t *ire; /* cached IRE */ 532 uint32_t T3expire; /* # of times T3 timer expired */ 533 534 uint64_t hb_secret; /* per addr "secret" in heartbeat */ 535 uint32_t rxt_unacked; /* # unack'ed retransmitted bytes */ 536 } sctp_faddr_t; 537 538 /* Flags to indicate supported address type in the PARM_SUP_ADDRS. */ 539 #define PARM_SUPP_V6 0x1 540 #define PARM_SUPP_V4 0x2 541 542 /* 543 * Set heartbeat interval plus jitter. The jitter is supposed to be random, 544 * up to +/- 50% of the RTO. We use gethrtime() here for performance reason 545 * as the jitter does not really need to be "very" random. 546 */ 547 #define SET_HB_INTVL(fp) \ 548 ((fp)->hb_interval + (fp)->rto + ((fp)->rto >> 1) - \ 549 (uint_t)gethrtime() % (fp)->rto) 550 551 #define SCTP_IPIF_HASH 16 552 553 typedef struct sctp_ipif_hash_s { 554 list_t sctp_ipif_list; 555 int ipif_count; 556 } sctp_ipif_hash_t; 557 558 559 /* 560 * Initialize cwnd according to RFC 3390. def_max_init_cwnd is 561 * either sctp_slow_start_initial or sctp_slow_start_after idle 562 * depending on the caller. 563 */ 564 #define SET_CWND(fp, mss, def_max_init_cwnd) \ 565 { \ 566 (fp)->cwnd = MIN(def_max_init_cwnd * (mss), \ 567 MIN(4 * (mss), MAX(2 * (mss), 4380 / (mss) * (mss)))); \ 568 } 569 570 571 struct sctp_s; 572 573 /* 574 * Control structure for each open SCTP stream, 575 * defined only within the kernel or for a kmem user. 576 * NOTE: sctp_reinit_values MUST have a line for each field in this structure! 577 */ 578 #if (defined(_KERNEL) || defined(_KMEMUSER)) 579 580 typedef struct sctp_s { 581 582 /* 583 * The following is shared with (and duplicated) in IP, so if you 584 * make changes, make sure you also change things in ip_sctp.c. 585 */ 586 struct sctp_s *sctp_conn_hash_next; 587 struct sctp_s *sctp_conn_hash_prev; 588 589 struct sctp_s *sctp_listen_hash_next; 590 struct sctp_s *sctp_listen_hash_prev; 591 592 sctp_tf_t *sctp_listen_tfp; /* Ptr to tf */ 593 sctp_tf_t *sctp_conn_tfp; /* Ptr to tf */ 594 595 /* Global list of sctp */ 596 list_node_t sctp_list; 597 598 sctp_faddr_t *sctp_faddrs; 599 int sctp_nfaddrs; 600 sctp_ipif_hash_t sctp_saddrs[SCTP_IPIF_HASH]; 601 int sctp_nsaddrs; 602 603 /* 604 * These fields contain the same information as sctp_sctph->th_*port. 605 * However, the lookup functions can not use the header fields 606 * since during IP option manipulation the sctp_sctph pointer 607 * changes. 608 */ 609 union { 610 struct { 611 in_port_t sctpu_fport; /* Remote port */ 612 in_port_t sctpu_lport; /* Local port */ 613 } sctpu_ports1; 614 uint32_t sctpu_ports2; /* Rem port, */ 615 /* local port */ 616 /* Used for SCTP_MATCH performance */ 617 } sctp_sctpu; 618 #define sctp_fport sctp_sctpu.sctpu_ports1.sctpu_fport 619 #define sctp_lport sctp_sctpu.sctpu_ports1.sctpu_lport 620 #define sctp_ports sctp_sctpu.sctpu_ports2 621 622 kmutex_t sctp_lock; 623 kcondvar_t sctp_cv; 624 boolean_t sctp_running; 625 626 #define sctp_ulpd sctp_connp->conn_upper_handle 627 #define sctp_upcalls sctp_connp->conn_upcalls 628 629 #define sctp_ulp_newconn sctp_upcalls->su_newconn 630 #define sctp_ulp_connected sctp_upcalls->su_connected 631 #define sctp_ulp_disconnected sctp_upcalls->su_disconnected 632 #define sctp_ulp_opctl sctp_upcalls->su_opctl 633 #define sctp_ulp_recv sctp_upcalls->su_recv 634 #define sctp_ulp_xmitted sctp_upcalls->su_txq_full 635 #define sctp_ulp_prop sctp_upcalls->su_set_proto_props 636 637 int32_t sctp_state; 638 639 conn_t *sctp_connp; /* conn_t stuff */ 640 #define sctp_zoneid sctp_connp->conn_zoneid 641 #define sctp_allzones sctp_connp->conn_allzones 642 #define sctp_mac_exempt sctp_connp->conn_mac_exempt 643 #define sctp_credp sctp_connp->conn_cred 644 #define sctp_reuseaddr sctp_connp->conn_reuseaddr 645 646 sctp_stack_t *sctp_sctps; 647 648 /* Peer address tracking */ 649 sctp_faddr_t *sctp_lastfaddr; /* last faddr in list */ 650 sctp_faddr_t *sctp_primary; /* primary faddr */ 651 sctp_faddr_t *sctp_current; /* current faddr */ 652 sctp_faddr_t *sctp_lastdata; /* last data seen from this */ 653 654 /* Outbound data tracking */ 655 mblk_t *sctp_xmit_head; 656 mblk_t *sctp_xmit_tail; 657 mblk_t *sctp_xmit_unsent; 658 mblk_t *sctp_xmit_unsent_tail; 659 mblk_t *sctp_xmit_unacked; 660 661 int32_t sctp_unacked; /* # of unacked bytes */ 662 int32_t sctp_unsent; /* # of unsent bytes in hand */ 663 664 uint32_t sctp_ltsn; /* Local instance TSN */ 665 uint32_t sctp_lastack_rxd; /* Last rx'd cumtsn */ 666 uint32_t sctp_recovery_tsn; /* Exit from fast recovery */ 667 uint32_t sctp_adv_pap; /* Adv. Peer Ack Point */ 668 669 uint16_t sctp_num_ostr; 670 uint16_t *sctp_ostrcntrs; 671 672 mblk_t *sctp_pad_mp; /* pad unaligned data chunks */ 673 674 /* sendmsg() default parameters */ 675 uint16_t sctp_def_stream; /* default stream id */ 676 uint16_t sctp_def_flags; /* default xmit flags */ 677 uint32_t sctp_def_ppid; /* default payload id */ 678 uint32_t sctp_def_context; /* default context */ 679 uint32_t sctp_def_timetolive; /* default msg TTL */ 680 681 /* Inbound data tracking */ 682 sctp_set_t *sctp_sack_info; /* Sack tracking */ 683 mblk_t *sctp_ack_mp; /* Delayed ACK timer block */ 684 sctp_instr_t *sctp_instr; /* Instream trackers */ 685 mblk_t *sctp_uo_frags; /* Un-ordered msg. fragments */ 686 uint32_t sctp_ftsn; /* Peer's TSN */ 687 uint32_t sctp_lastacked; /* last cumtsn SACKd */ 688 uint16_t sctp_num_istr; /* No. of instreams */ 689 int32_t sctp_istr_nmsgs; /* No. of chunks in instreams */ 690 int32_t sctp_sack_gaps; /* No. of received gaps */ 691 int32_t sctp_sack_toggle; /* SACK every other pkt */ 692 693 /* RTT calculation */ 694 uint32_t sctp_rtt_tsn; 695 int64_t sctp_out_time; 696 697 /* Stats can be reset by snmp users kstat, netstat and snmp agents */ 698 uint64_t sctp_opkts; /* sent pkts */ 699 uint64_t sctp_obchunks; /* sent control chunks */ 700 uint64_t sctp_odchunks; /* sent ordered data chunks */ 701 uint64_t sctp_oudchunks; /* sent unord data chunks */ 702 uint64_t sctp_rxtchunks; /* retransmitted chunks */ 703 uint64_t sctp_ipkts; /* recv pkts */ 704 uint64_t sctp_ibchunks; /* recv control chunks */ 705 uint64_t sctp_idchunks; /* recv ordered data chunks */ 706 uint64_t sctp_iudchunks; /* recv unord data chunks */ 707 uint64_t sctp_fragdmsgs; 708 uint64_t sctp_reassmsgs; 709 uint32_t sctp_T1expire; /* # of times T1timer expired */ 710 uint32_t sctp_T2expire; /* # of times T2timer expired */ 711 uint32_t sctp_T3expire; /* # of times T3timer expired */ 712 uint32_t sctp_assoc_start_time; /* time when assoc was est. */ 713 714 /* Outbound flow control */ 715 int32_t sctp_xmit_hiwater; /* Send high water mark */ 716 int32_t sctp_xmit_lowater; /* Send low water mark */ 717 uint32_t sctp_frwnd; /* Peer RWND */ 718 uint32_t sctp_cwnd_max; 719 720 /* Inbound flow control */ 721 int32_t sctp_rwnd; /* Current receive window */ 722 int32_t sctp_irwnd; /* Initial receive window */ 723 int32_t sctp_rxqueued; /* No. of bytes in RX q's */ 724 725 /* Pre-initialized composite headers */ 726 char *sctp_iphc; /* v4 sctp/ip hdr template buffer */ 727 char *sctp_iphc6; /* v6 sctp/ip hdr template buffer */ 728 729 int32_t sctp_iphc_len; /* actual allocated v4 buffer size */ 730 int32_t sctp_iphc6_len; /* actual allocated v6 buffer size */ 731 732 int32_t sctp_hdr_len; /* len of combined SCTP/IP v4 hdr */ 733 int32_t sctp_hdr6_len; /* len of combined SCTP/IP v6 hdr */ 734 735 ipha_t *sctp_ipha; /* IPv4 header in the buffer */ 736 ip6_t *sctp_ip6h; /* IPv6 header in the buffer */ 737 738 int32_t sctp_ip_hdr_len; /* Byte len of our current v4 hdr */ 739 int32_t sctp_ip_hdr6_len; /* Byte len of our current v6 hdr */ 740 741 sctp_hdr_t *sctp_sctph; /* sctp header in combined v4 hdr */ 742 sctp_hdr_t *sctp_sctph6; /* sctp header in combined v6 hdr */ 743 744 uint32_t sctp_lvtag; /* local SCTP instance verf tag */ 745 uint32_t sctp_fvtag; /* Peer's SCTP verf tag */ 746 747 /* Path MTU Discovery */ 748 int64_t sctp_last_mtu_probe; 749 clock_t sctp_mtu_probe_intvl; 750 uint32_t sctp_mss; /* Max send size (not TCP MSS!) */ 751 752 /* structs sctp_bits, sctp_events are for clearing all bits at once */ 753 struct { 754 uint32_t 755 756 sctp_understands_asconf : 1, /* Peer handles ASCONF chunks */ 757 sctp_debug : 1, /* SO_DEBUG "socket" option. */ 758 sctp_cchunk_pend : 1, /* Control chunk in flight. */ 759 sctp_dgram_errind : 1, /* SO_DGRAM_ERRIND option */ 760 761 sctp_linger : 1, /* SO_LINGER turned on */ 762 sctp_lingering : 1, /* Lingering in close */ 763 sctp_loopback: 1, /* src and dst are the same machine */ 764 sctp_force_sack : 1, 765 766 sctp_ack_timer_running: 1, /* Delayed ACK timer running */ 767 sctp_recvdstaddr : 1, /* return T_EXTCONN_IND with dstaddr */ 768 sctp_hwcksum : 1, /* The NIC is capable of hwcksum */ 769 sctp_understands_addip : 1, 770 771 sctp_bound_to_all : 1, 772 sctp_cansleep : 1, /* itf routines can sleep */ 773 sctp_detached : 1, /* If we're detached from a stream */ 774 sctp_send_adaptation : 1, /* send adaptation layer ind */ 775 776 sctp_recv_adaptation : 1, /* recv adaptation layer ind */ 777 sctp_ndelay : 1, /* turn off Nagle */ 778 sctp_condemned : 1, /* this sctp is about to disappear */ 779 sctp_chk_fast_rexmit : 1, /* check for fast rexmit message */ 780 781 sctp_prsctp_aware : 1, /* is peer PR-SCTP aware? */ 782 sctp_linklocal : 1, /* is linklocal assoc. */ 783 sctp_rexmitting : 1, /* SCTP is retransmitting */ 784 sctp_zero_win_probe : 1, /* doing zero win probe */ 785 786 sctp_txq_full : 1, /* the tx queue is full */ 787 sctp_ulp_discon_done : 1, /* ulp_disconnecting done */ 788 sctp_dummy : 6; 789 } sctp_bits; 790 struct { 791 uint32_t 792 793 sctp_recvsndrcvinfo : 1, 794 sctp_recvassocevnt : 1, 795 sctp_recvpathevnt : 1, 796 sctp_recvsendfailevnt : 1, 797 798 sctp_recvpeererr : 1, 799 sctp_recvshutdownevnt : 1, 800 sctp_recvpdevnt : 1, 801 sctp_recvalevnt : 1; 802 } sctp_events; 803 #define sctp_priv_stream sctp_bits.sctp_priv_stream 804 #define sctp_understands_asconf sctp_bits.sctp_understands_asconf 805 #define sctp_debug sctp_bits.sctp_debug 806 #define sctp_cchunk_pend sctp_bits.sctp_cchunk_pend 807 #define sctp_dgram_errind sctp_bits.sctp_dgram_errind 808 #define sctp_linger sctp_bits.sctp_linger 809 #define sctp_lingering sctp_bits.sctp_lingering 810 #define sctp_loopback sctp_bits.sctp_loopback 811 #define sctp_force_sack sctp_bits.sctp_force_sack 812 #define sctp_ack_timer_running sctp_bits.sctp_ack_timer_running 813 #define sctp_recvdstaddr sctp_bits.sctp_recvdstaddr 814 #define sctp_hwcksum sctp_bits.sctp_hwcksum 815 #define sctp_understands_addip sctp_bits.sctp_understands_addip 816 #define sctp_bound_to_all sctp_bits.sctp_bound_to_all 817 #define sctp_cansleep sctp_bits.sctp_cansleep 818 #define sctp_detached sctp_bits.sctp_detached 819 #define sctp_send_adaptation sctp_bits.sctp_send_adaptation 820 #define sctp_recv_adaptation sctp_bits.sctp_recv_adaptation 821 #define sctp_ndelay sctp_bits.sctp_ndelay 822 #define sctp_condemned sctp_bits.sctp_condemned 823 #define sctp_chk_fast_rexmit sctp_bits.sctp_chk_fast_rexmit 824 #define sctp_prsctp_aware sctp_bits.sctp_prsctp_aware 825 #define sctp_linklocal sctp_bits.sctp_linklocal 826 #define sctp_rexmitting sctp_bits.sctp_rexmitting 827 #define sctp_zero_win_probe sctp_bits.sctp_zero_win_probe 828 #define sctp_txq_full sctp_bits.sctp_txq_full 829 #define sctp_ulp_discon_done sctp_bits.sctp_ulp_discon_done 830 831 #define sctp_recvsndrcvinfo sctp_events.sctp_recvsndrcvinfo 832 #define sctp_recvassocevnt sctp_events.sctp_recvassocevnt 833 #define sctp_recvpathevnt sctp_events.sctp_recvpathevnt 834 #define sctp_recvsendfailevnt sctp_events.sctp_recvsendfailevnt 835 #define sctp_recvpeererr sctp_events.sctp_recvpeererr 836 #define sctp_recvshutdownevnt sctp_events.sctp_recvshutdownevnt 837 #define sctp_recvpdevnt sctp_events.sctp_recvpdevnt 838 #define sctp_recvalevnt sctp_events.sctp_recvalevnt 839 840 /* Retransmit info */ 841 mblk_t *sctp_cookie_mp; /* cookie chunk, if rxt needed */ 842 int32_t sctp_strikes; /* Total number of assoc strikes */ 843 int32_t sctp_max_init_rxt; 844 int32_t sctp_pa_max_rxt; /* Max per-assoc retransmit cnt */ 845 int32_t sctp_pp_max_rxt; /* Max per-path retransmit cnt */ 846 uint32_t sctp_rto_max; 847 uint32_t sctp_init_rto_max; 848 uint32_t sctp_rto_min; 849 uint32_t sctp_rto_initial; 850 851 int64_t sctp_last_secret_update; 852 uint8_t sctp_secret[SCTP_SECRET_LEN]; /* for cookie auth */ 853 uint8_t sctp_old_secret[SCTP_SECRET_LEN]; 854 uint32_t sctp_cookie_lifetime; /* cookie lifetime in tick */ 855 856 /* 857 * Address family that app wishes returned addrsses to be in. 858 * Currently taken from address family used in T_BIND_REQ, but 859 * should really come from family used in original socket() call. 860 * Value can be AF_INET or AF_INET6. 861 */ 862 uint_t sctp_family; 863 ushort_t sctp_ipversion; 864 865 /* Bind hash tables */ 866 kmutex_t *sctp_bind_lockp; /* Ptr to tf_lock */ 867 struct sctp_s *sctp_bind_hash; 868 struct sctp_s **sctp_ptpbhn; 869 870 /* Shutdown / cleanup */ 871 sctp_faddr_t *sctp_shutdown_faddr; /* rotate faddr during shutd */ 872 int32_t sctp_client_errno; /* How the client screwed up */ 873 int sctp_lingertime; /* Close linger time (in seconds) */ 874 kmutex_t sctp_reflock; /* Protects sctp_refcnt & timer mp */ 875 ushort_t sctp_refcnt; /* No. of pending upstream msg */ 876 mblk_t *sctp_timer_mp; /* List of fired timers. */ 877 878 /* Misc */ 879 uint_t sctp_bound_if; /* IPV6_BOUND_IF */ 880 881 mblk_t *sctp_heartbeat_mp; /* Timer block for heartbeats */ 882 uint32_t sctp_hb_interval; /* Default hb_interval */ 883 884 int32_t sctp_autoclose; /* Auto disconnect in ticks */ 885 int64_t sctp_active; /* Last time data/sack on this conn */ 886 uint32_t sctp_tx_adaptation_code; /* TX adaptation code */ 887 uint32_t sctp_rx_adaptation_code; /* RX adaptation code */ 888 889 /* Reliable control chunks */ 890 mblk_t *sctp_cxmit_list; /* Xmit list for control chunks */ 891 uint32_t sctp_lcsn; /* Our serial number */ 892 uint32_t sctp_fcsn; /* Peer serial number */ 893 894 /* Per association receive queue */ 895 kmutex_t sctp_recvq_lock; 896 mblk_t *sctp_recvq; 897 mblk_t *sctp_recvq_tail; 898 taskq_t *sctp_recvq_tq; 899 900 /* Send queue to IP */ 901 kmutex_t sctp_sendq_lock; 902 mblk_t *sctp_sendq; 903 mblk_t *sctp_sendq_tail; 904 boolean_t sctp_sendq_sending; 905 906 /* IPv6 ancillary data */ 907 uint_t sctp_ipv6_recvancillary; /* flags */ 908 #define SCTP_IPV6_RECVPKTINFO 0x01 /* IPV6_RECVPKTINFO opt */ 909 #define SCTP_IPV6_RECVHOPLIMIT 0x02 /* IPV6_RECVHOPLIMIT opt */ 910 #define SCTP_IPV6_RECVHOPOPTS 0x04 /* IPV6_RECVHOPOPTS opt */ 911 #define SCTP_IPV6_RECVDSTOPTS 0x08 /* IPV6_RECVDSTOPTS opt */ 912 #define SCTP_IPV6_RECVRTHDR 0x10 /* IPV6_RECVRTHDR opt */ 913 #define SCTP_IPV6_RECVRTDSTOPTS 0x20 /* IPV6_RECVRTHDRDSTOPTS opt */ 914 915 uint_t sctp_recvifindex; /* last rcvd IPV6_RCVPKTINFO */ 916 uint_t sctp_recvhops; /* " IPV6_RECVHOPLIMIT */ 917 ip6_hbh_t *sctp_hopopts; /* " IPV6_RECVHOPOPTS */ 918 ip6_dest_t *sctp_dstopts; /* " IPV6_RECVDSTOPTS */ 919 ip6_dest_t *sctp_rtdstopts; /* " IPV6_RECVRTHDRDSTOPTS */ 920 ip6_rthdr_t *sctp_rthdr; /* " IPV6_RECVRTHDR */ 921 uint_t sctp_hopoptslen; 922 uint_t sctp_dstoptslen; 923 uint_t sctp_rtdstoptslen; 924 uint_t sctp_rthdrlen; 925 926 ip6_pkt_t sctp_sticky_ipp; /* Sticky options */ 927 #define sctp_ipp_fields sctp_sticky_ipp.ipp_fields 928 #define sctp_ipp_ifindex sctp_sticky_ipp.ipp_ifindex 929 #define sctp_ipp_addr sctp_sticky_ipp.ipp_addr 930 #define sctp_ipp_hoplimit sctp_sticky_ipp.ipp_hoplimit 931 #define sctp_ipp_hopoptslen sctp_sticky_ipp.ipp_hopoptslen 932 #define sctp_ipp_rtdstoptslen sctp_sticky_ipp.ipp_rtdstoptslen 933 #define sctp_ipp_rthdrlen sctp_sticky_ipp.ipp_rthdrlen 934 #define sctp_ipp_dstoptslen sctp_sticky_ipp.ipp_dstoptslen 935 #define sctp_ipp_hopopts sctp_sticky_ipp.ipp_hopopts 936 #define sctp_ipp_rtdstopts sctp_sticky_ipp.ipp_rtdstopts 937 #define sctp_ipp_rthdr sctp_sticky_ipp.ipp_rthdr 938 #define sctp_ipp_dstopts sctp_sticky_ipp.ipp_dstopts 939 #define sctp_ipp_pathmtu sctp_sticky_ipp.ipp_pathmtu 940 #define sctp_ipp_nexthop sctp_sticky_ipp.ipp_nexthop 941 /* Stats */ 942 uint64_t sctp_msgcount; 943 uint64_t sctp_prsctpdrop; 944 945 uint_t sctp_v4label_len; /* length of cached v4 label */ 946 uint_t sctp_v6label_len; /* length of cached v6 label */ 947 uint32_t sctp_rxt_nxttsn; /* Next TSN to be rexmitted */ 948 uint32_t sctp_rxt_maxtsn; /* Max TSN sent at time out */ 949 950 int sctp_pd_point; /* Partial delivery point */ 951 mblk_t *sctp_err_chunks; /* Error chunks */ 952 uint32_t sctp_err_len; /* Total error chunks length */ 953 954 pid_t sctp_cpid; /* Process id when this was opened */ 955 uint64_t sctp_open_time; /* time when this was opened */ 956 957 /* additional source data for per endpoint association statistics */ 958 uint64_t sctp_outseqtsns; /* TSN rx > expected TSN */ 959 uint64_t sctp_osacks; /* total sacks sent */ 960 uint64_t sctp_isacks; /* total sacks received */ 961 uint64_t sctp_idupchunks; /* rx dups, ord or unord */ 962 uint64_t sctp_gapcnt; /* total gap acks rx */ 963 /* 964 * Add the current data from the counters which are reset by snmp 965 * to these cumulative counters to use in per endpoint statistics. 966 */ 967 uint64_t sctp_cum_obchunks; /* sent control chunks */ 968 uint64_t sctp_cum_odchunks; /* sent ordered data chunks */ 969 uint64_t sctp_cum_oudchunks; /* sent unord data chunks */ 970 uint64_t sctp_cum_rxtchunks; /* retransmitted chunks */ 971 uint64_t sctp_cum_ibchunks; /* recv control chunks */ 972 uint64_t sctp_cum_idchunks; /* recv ordered data chunks */ 973 uint64_t sctp_cum_iudchunks; /* recv unord data chunks */ 974 975 /* 976 * When non-zero, this is the maximum observed RTO since assoc stats 977 * were last requested. When zero, no RTO update has occurred since 978 * the previous user request for stats on this endpoint. 979 */ 980 int sctp_maxrto; 981 /* 982 * The stored value of sctp_maxrto passed to user during the previous 983 * user request for stats on this endpoint. 984 */ 985 int sctp_prev_maxrto; 986 } sctp_t; 987 988 #define SCTP_TXQ_LEN(sctp) ((sctp)->sctp_unsent + (sctp)->sctp_unacked) 989 #define SCTP_TXQ_UPDATE(sctp) \ 990 if ((sctp)->sctp_txq_full && SCTP_TXQ_LEN(sctp) <= \ 991 (sctp)->sctp_xmit_lowater) { \ 992 (sctp)->sctp_txq_full = 0; \ 993 (sctp)->sctp_ulp_xmitted((sctp)->sctp_ulpd, \ 994 B_FALSE); \ 995 } 996 997 #endif /* (defined(_KERNEL) || defined(_KMEMUSER)) */ 998 999 extern void sctp_ack_timer(sctp_t *); 1000 extern size_t sctp_adaptation_code_param(sctp_t *, uchar_t *); 1001 extern void sctp_adaptation_event(sctp_t *); 1002 extern void sctp_add_err(sctp_t *, uint16_t, void *, size_t, 1003 sctp_faddr_t *); 1004 extern int sctp_add_faddr(sctp_t *, in6_addr_t *, int, boolean_t); 1005 extern boolean_t sctp_add_ftsn_set(sctp_ftsn_set_t **, sctp_faddr_t *, mblk_t *, 1006 uint_t *, uint32_t *); 1007 extern boolean_t sctp_add_recvq(sctp_t *, mblk_t *, boolean_t); 1008 extern void sctp_add_sendq(sctp_t *, mblk_t *); 1009 extern void sctp_add_unrec_parm(sctp_parm_hdr_t *, mblk_t **, boolean_t); 1010 extern size_t sctp_addr_params(sctp_t *, int, uchar_t *, boolean_t); 1011 extern mblk_t *sctp_add_proto_hdr(sctp_t *, sctp_faddr_t *, mblk_t *, int, 1012 int *); 1013 extern void sctp_addr_req(sctp_t *, mblk_t *); 1014 extern sctp_t *sctp_addrlist2sctp(mblk_t *, sctp_hdr_t *, sctp_chunk_hdr_t *, 1015 zoneid_t, sctp_stack_t *); 1016 extern void sctp_add_hdr(sctp_t *, uchar_t *, size_t); 1017 extern void sctp_check_adv_ack_pt(sctp_t *, mblk_t *, mblk_t *); 1018 extern void sctp_assoc_event(sctp_t *, uint16_t, uint16_t, 1019 sctp_chunk_hdr_t *); 1020 1021 extern void sctp_bind_hash_insert(sctp_tf_t *, sctp_t *, int); 1022 extern void sctp_bind_hash_remove(sctp_t *); 1023 extern int sctp_bindi(sctp_t *, in_port_t, boolean_t, int, in_port_t *); 1024 extern int sctp_bind_add(sctp_t *, const void *, uint32_t, boolean_t, 1025 in_port_t); 1026 extern int sctp_bind_del(sctp_t *, const void *, uint32_t, boolean_t); 1027 extern int sctp_build_hdrs(sctp_t *); 1028 1029 extern int sctp_check_abandoned_msg(sctp_t *, mblk_t *); 1030 extern void sctp_clean_death(sctp_t *, int); 1031 extern void sctp_close_eager(sctp_t *); 1032 extern int sctp_compare_faddrsets(sctp_faddr_t *, sctp_faddr_t *); 1033 extern void sctp_congest_reset(sctp_t *); 1034 extern void sctp_conn_hash_insert(sctp_tf_t *, sctp_t *, int); 1035 extern void sctp_conn_hash_remove(sctp_t *); 1036 extern void sctp_conn_init(conn_t *); 1037 extern sctp_t *sctp_conn_match(in6_addr_t *, in6_addr_t *, uint32_t, 1038 zoneid_t, sctp_stack_t *); 1039 extern sctp_t *sctp_conn_request(sctp_t *, mblk_t *, uint_t, uint_t, 1040 sctp_init_chunk_t *, mblk_t *); 1041 extern int sctp_conprim_opt_process(queue_t *, mblk_t *, int *, int *, 1042 int *); 1043 extern uint32_t sctp_cumack(sctp_t *, uint32_t, mblk_t **); 1044 extern sctp_t *sctp_create_eager(sctp_t *); 1045 1046 extern void sctp_dispatch_rput(queue_t *, sctp_t *, sctp_hdr_t *, mblk_t *, 1047 uint_t, uint_t, in6_addr_t); 1048 extern char *sctp_display(sctp_t *, char *); 1049 extern void sctp_display_all(sctp_stack_t *); 1050 1051 extern void sctp_error_event(sctp_t *, sctp_chunk_hdr_t *); 1052 1053 extern void sctp_faddr_alive(sctp_t *, sctp_faddr_t *); 1054 extern int sctp_faddr_dead(sctp_t *, sctp_faddr_t *, int); 1055 extern void sctp_faddr_fini(void); 1056 extern void sctp_faddr_init(void); 1057 extern void sctp_fast_rexmit(sctp_t *); 1058 extern void sctp_fill_sack(sctp_t *, unsigned char *, int); 1059 extern void sctp_free_faddr_timers(sctp_t *); 1060 extern void sctp_free_ftsn_set(sctp_ftsn_set_t *); 1061 extern void sctp_free_msg(mblk_t *); 1062 extern void sctp_free_reass(sctp_instr_t *); 1063 extern void sctp_free_set(sctp_set_t *); 1064 extern void sctp_ftsn_sets_fini(void); 1065 extern void sctp_ftsn_sets_init(void); 1066 1067 extern int sctp_get_addrlist(sctp_t *, const void *, uint32_t *, 1068 uchar_t **, int *, size_t *); 1069 extern void sctp_g_q_inactive(sctp_stack_t *); 1070 extern int sctp_get_addrparams(sctp_t *, sctp_t *, mblk_t *, 1071 sctp_chunk_hdr_t *, uint_t *); 1072 extern void sctp_get_ire(sctp_t *, sctp_faddr_t *); 1073 extern void sctp_get_faddr_list(sctp_t *, uchar_t *, size_t); 1074 extern mblk_t *sctp_get_first_sent(sctp_t *); 1075 extern mblk_t *sctp_get_msg_to_send(sctp_t *, mblk_t **, mblk_t *, int *, 1076 int32_t, uint32_t, sctp_faddr_t *); 1077 extern void sctp_get_saddr_list(sctp_t *, uchar_t *, size_t); 1078 1079 extern int sctp_handle_error(sctp_t *, sctp_hdr_t *, sctp_chunk_hdr_t *, 1080 mblk_t *); 1081 extern void sctp_hash_destroy(sctp_stack_t *); 1082 extern void sctp_hash_init(sctp_stack_t *); 1083 extern int sctp_header_init_ipv4(sctp_t *, int); 1084 extern int sctp_header_init_ipv6(sctp_t *, int); 1085 extern void sctp_heartbeat_timer(sctp_t *); 1086 1087 extern void sctp_icmp_error(sctp_t *, mblk_t *); 1088 extern void sctp_inc_taskq(sctp_stack_t *); 1089 extern void sctp_info_req(sctp_t *, mblk_t *); 1090 extern mblk_t *sctp_init_mp(sctp_t *); 1091 extern boolean_t sctp_initialize_params(sctp_t *, sctp_init_chunk_t *, 1092 sctp_init_chunk_t *); 1093 extern uint32_t sctp_init2vtag(sctp_chunk_hdr_t *); 1094 extern void sctp_intf_event(sctp_t *, in6_addr_t, int, int); 1095 extern void sctp_input_data(sctp_t *, mblk_t *, mblk_t *); 1096 extern void sctp_instream_cleanup(sctp_t *, boolean_t); 1097 extern int sctp_is_a_faddr_clean(sctp_t *); 1098 1099 extern void *sctp_kstat_init(netstackid_t); 1100 extern void sctp_kstat_fini(netstackid_t, kstat_t *); 1101 extern void *sctp_kstat2_init(netstackid_t, sctp_kstat_t *); 1102 extern void sctp_kstat2_fini(netstackid_t, kstat_t *); 1103 1104 extern ssize_t sctp_link_abort(mblk_t *, uint16_t, char *, size_t, int, 1105 boolean_t); 1106 extern void sctp_listen_hash_insert(sctp_tf_t *, sctp_t *); 1107 extern void sctp_listen_hash_remove(sctp_t *); 1108 extern sctp_t *sctp_lookup(sctp_t *, in6_addr_t *, sctp_tf_t *, uint32_t *, 1109 int); 1110 extern sctp_faddr_t *sctp_lookup_faddr(sctp_t *, in6_addr_t *); 1111 1112 extern mblk_t *sctp_make_err(sctp_t *, uint16_t, void *, size_t); 1113 extern mblk_t *sctp_make_ftsn_chunk(sctp_t *, sctp_faddr_t *, 1114 sctp_ftsn_set_t *, uint_t, uint32_t); 1115 extern void sctp_make_ftsns(sctp_t *, mblk_t *, mblk_t *, mblk_t **, 1116 sctp_faddr_t *, uint32_t *); 1117 extern mblk_t *sctp_make_mp(sctp_t *, sctp_faddr_t *, int); 1118 extern mblk_t *sctp_make_sack(sctp_t *, sctp_faddr_t *, mblk_t *); 1119 extern void sctp_maxpsz_set(sctp_t *); 1120 extern void sctp_move_faddr_timers(queue_t *, sctp_t *); 1121 1122 extern void sctp_nd_free(sctp_stack_t *); 1123 extern int sctp_nd_getset(queue_t *, MBLKP); 1124 extern boolean_t sctp_nd_init(sctp_stack_t *); 1125 extern sctp_parm_hdr_t *sctp_next_parm(sctp_parm_hdr_t *, ssize_t *); 1126 1127 extern void sctp_ootb_shutdown_ack(sctp_t *, mblk_t *, uint_t); 1128 extern size_t sctp_options_param(const sctp_t *, void *, int); 1129 extern size_t sctp_options_param_len(const sctp_t *, int); 1130 extern void sctp_output(sctp_t *, uint_t); 1131 1132 extern boolean_t sctp_param_register(IDP *, sctpparam_t *, int, sctp_stack_t *); 1133 extern void sctp_partial_delivery_event(sctp_t *); 1134 extern int sctp_process_cookie(sctp_t *, sctp_chunk_hdr_t *, mblk_t *, 1135 sctp_init_chunk_t **, sctp_hdr_t *, int *, in6_addr_t *); 1136 extern void sctp_process_err(sctp_t *); 1137 extern void sctp_process_heartbeat(sctp_t *, sctp_chunk_hdr_t *); 1138 extern void sctp_process_sendq(sctp_t *); 1139 extern void sctp_process_timer(sctp_t *); 1140 1141 extern void sctp_redo_faddr_srcs(sctp_t *); 1142 extern void sctp_regift_xmitlist(sctp_t *); 1143 extern void sctp_return_heartbeat(sctp_t *, sctp_chunk_hdr_t *, mblk_t *); 1144 extern void sctp_rexmit(sctp_t *, sctp_faddr_t *); 1145 extern mblk_t *sctp_rexmit_packet(sctp_t *, mblk_t **, mblk_t **, 1146 sctp_faddr_t *, uint_t *); 1147 extern void sctp_rexmit_timer(sctp_t *, sctp_faddr_t *); 1148 extern sctp_faddr_t *sctp_rotate_faddr(sctp_t *, sctp_faddr_t *); 1149 1150 extern boolean_t sctp_sack(sctp_t *, mblk_t *); 1151 extern int sctp_secure_restart_check(mblk_t *, sctp_chunk_hdr_t *, 1152 uint32_t, int, sctp_stack_t *); 1153 extern void sctp_send_abort(sctp_t *, uint32_t, uint16_t, char *, size_t, 1154 mblk_t *, int, boolean_t); 1155 extern void sctp_send_cookie_ack(sctp_t *); 1156 extern void sctp_send_cookie_echo(sctp_t *, sctp_chunk_hdr_t *, mblk_t *); 1157 extern void sctp_send_initack(sctp_t *, sctp_hdr_t *, sctp_chunk_hdr_t *, 1158 mblk_t *); 1159 extern void sctp_send_shutdown(sctp_t *, int); 1160 extern void sctp_send_heartbeat(sctp_t *, sctp_faddr_t *); 1161 extern void sctp_sendfail_event(sctp_t *, mblk_t *, int, boolean_t); 1162 extern void sctp_set_faddr_current(sctp_t *, sctp_faddr_t *); 1163 extern int sctp_set_hdraddrs(sctp_t *); 1164 extern void sctp_set_saddr(sctp_t *, sctp_faddr_t *); 1165 extern void sctp_sets_init(void); 1166 extern void sctp_sets_fini(void); 1167 extern void sctp_shutdown_event(sctp_t *); 1168 extern void sctp_stop_faddr_timers(sctp_t *); 1169 extern int sctp_shutdown_received(sctp_t *, sctp_chunk_hdr_t *, boolean_t, 1170 boolean_t, sctp_faddr_t *); 1171 extern void sctp_shutdown_complete(sctp_t *); 1172 extern void sctp_set_if_mtu(sctp_t *); 1173 extern void sctp_set_iplen(sctp_t *, mblk_t *); 1174 extern void sctp_set_ulp_prop(sctp_t *); 1175 extern void sctp_ss_rexmit(sctp_t *); 1176 extern size_t sctp_supaddr_param_len(sctp_t *); 1177 extern size_t sctp_supaddr_param(sctp_t *, uchar_t *); 1178 1179 extern void sctp_timer(sctp_t *, mblk_t *, clock_t); 1180 extern mblk_t *sctp_timer_alloc(sctp_t *, pfv_t, int); 1181 extern void sctp_timer_call(sctp_t *sctp, mblk_t *); 1182 extern void sctp_timer_free(mblk_t *); 1183 extern void sctp_timer_stop(mblk_t *); 1184 extern void sctp_unlink_faddr(sctp_t *, sctp_faddr_t *); 1185 1186 extern void sctp_update_ire(sctp_t *sctp); 1187 extern in_port_t sctp_update_next_port(in_port_t, zone_t *zone, sctp_stack_t *); 1188 extern void sctp_update_rtt(sctp_t *, sctp_faddr_t *, clock_t); 1189 extern void sctp_user_abort(sctp_t *, mblk_t *); 1190 1191 extern void sctp_validate_peer(sctp_t *); 1192 1193 extern void sctp_wput_ioctl(queue_t *, mblk_t *); 1194 1195 extern int sctp_xmit_list_clean(sctp_t *, ssize_t); 1196 1197 extern void sctp_zap_addrs(sctp_t *); 1198 extern void sctp_zap_faddrs(sctp_t *, int); 1199 1200 /* Contract private interface between SCTP and Clustering - PSARC/2005/602 */ 1201 1202 extern void (*cl_sctp_listen)(sa_family_t, uchar_t *, uint_t, in_port_t); 1203 extern void (*cl_sctp_unlisten)(sa_family_t, uchar_t *, uint_t, in_port_t); 1204 extern void (*cl_sctp_connect)(sa_family_t, uchar_t *, uint_t, in_port_t, 1205 uchar_t *, uint_t, in_port_t, boolean_t, cl_sctp_handle_t); 1206 extern void (*cl_sctp_disconnect)(sa_family_t, cl_sctp_handle_t); 1207 extern void (*cl_sctp_assoc_change)(sa_family_t, uchar_t *, size_t, uint_t, 1208 uchar_t *, size_t, uint_t, int, cl_sctp_handle_t); 1209 extern void (*cl_sctp_check_addrs)(sa_family_t, in_port_t, uchar_t **, 1210 size_t, uint_t *, boolean_t); 1211 1212 /* Send a mp to IP. */ 1213 #define IP_PUT(mp, conn, isv4) \ 1214 { \ 1215 sctp_stack_t *sctps = conn->conn_netstack->netstack_sctp; \ 1216 \ 1217 if ((isv4)) \ 1218 ip_output((conn), (mp), WR(sctps->sctps_g_q), IP_WPUT); \ 1219 else \ 1220 ip_output_v6((conn), (mp), WR(sctps->sctps_g_q), IP_WPUT);\ 1221 } 1222 1223 #define RUN_SCTP(sctp) \ 1224 { \ 1225 mutex_enter(&(sctp)->sctp_lock); \ 1226 while ((sctp)->sctp_running) \ 1227 cv_wait(&(sctp)->sctp_cv, &(sctp)->sctp_lock); \ 1228 (sctp)->sctp_running = B_TRUE; \ 1229 mutex_exit(&(sctp)->sctp_lock); \ 1230 } 1231 1232 /* Wake up recvq taskq */ 1233 #define WAKE_SCTP(sctp) \ 1234 { \ 1235 mutex_enter(&(sctp)->sctp_lock); \ 1236 if ((sctp)->sctp_timer_mp != NULL) \ 1237 sctp_process_timer(sctp); \ 1238 (sctp)->sctp_running = B_FALSE; \ 1239 cv_broadcast(&(sctp)->sctp_cv); \ 1240 mutex_exit(&(sctp)->sctp_lock); \ 1241 } 1242 1243 #ifdef __cplusplus 1244 } 1245 #endif 1246 1247 #endif /* _INET_SCTP_SCTP_IMPL_H */ 1248