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