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