xref: /titanic_44/usr/src/uts/common/inet/ipclassifier.h (revision 28167c24ba5be8b7c1d05e02d053f4a55cd21cc9)
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, Version 1.0 only
6  * (the "License").  You may not use this file except in compliance
7  * with the License.
8  *
9  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10  * or http://www.opensolaris.org/os/licensing.
11  * See the License for the specific language governing permissions
12  * and limitations under the License.
13  *
14  * When distributing Covered Code, include this CDDL HEADER in each
15  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16  * If applicable, add the following below this CDDL HEADER, with the
17  * fields enclosed by brackets "[]" replaced with your own identifying
18  * information: Portions Copyright [yyyy] [name of copyright owner]
19  *
20  * CDDL HEADER END
21  */
22 /*
23  * Copyright 2006 Sun Microsystems, Inc.  All rights reserved.
24  * Use is subject to license terms.
25  */
26 
27 #ifndef	_INET_IPCLASSIFIER_H
28 #define	_INET_IPCLASSIFIER_H
29 
30 #pragma ident	"%Z%%M%	%I%	%E% SMI"
31 
32 #ifdef	__cplusplus
33 extern "C" {
34 #endif
35 
36 #include <inet/common.h>
37 #include <inet/ip.h>
38 #include <inet/mi.h>
39 #include <inet/tcp.h>
40 #include <inet/ip6.h>
41 #include <netinet/in.h>		/* for IPPROTO_* constants */
42 #include <sys/sdt.h>
43 
44 typedef void (*edesc_spf)(void *, mblk_t *, void *, int);
45 typedef void (*edesc_rpf)(void *, mblk_t *, void *);
46 
47 /*
48  * ==============================
49  * =	The CONNECTION		=
50  * ==============================
51  */
52 
53 /*
54  * The connection structure contains the common information/flags/ref needed.
55  * Implementation will keep the connection struct, the layers (with their
56  * respective data for event i.e. tcp_t if event was tcp_input) all in one
57  * contiguous memory location.
58  */
59 
60 /* Conn Flags */
61 #define	IPCL_UDPMOD		0x00020000	/* Is UDP module instance */
62 #define	IPCL_TCPMOD		0x00040000	/* Is TCP module instance */
63 #define	IPCL_FULLY_BOUND	0x00080000	/* Bound to correct squeue */
64 #define	IPCL_CHECK_POLICY	0x00100000	/* Needs policy checking */
65 #define	IPCL_SOCKET		0x00200000	/* Sockfs connection */
66 #define	IPCL_ACCEPTOR		0x00400000	/* Sockfs priv acceptor */
67 #define	IPCL_CL_LISTENER	0x00800000	/* Cluster listener */
68 #define	IPCL_EAGER		0x01000000	/* Incoming connection */
69 #define	IPCL_UDP		0x02000000	/* A UDP connection */
70 #define	IPCL_TCP6		0x04000000	/* A TCP6 connection */
71 #define	IPCL_TCP4		0x08000000	/* A TCP connection */
72 #define	IPCL_CONNECTED		0x40000000	/* Conn in connected table */
73 #define	IPCL_BOUND		0x80000000	/* Conn in bind table */
74 
75 /* Flags identifying the type of conn */
76 #define	IPCL_TCPCONN		0x00000001	/* Flag to indicate cache */
77 #define	IPCL_SCTPCONN		0x00000002
78 #define	IPCL_IPCCONN		0x00000004
79 #define	IPCL_ISV6		0x00000008	/* Is a V6 connection */
80 
81 /* Conn Masks */
82 #define	IPCL_TCP		(IPCL_TCP4|IPCL_TCP6)
83 #define	IPCL_REMOVED		0x00000020
84 #define	IPCL_REUSED		0x00000040
85 
86 #define	IPCL_IS_TCP4(connp)						\
87 	(((connp)->conn_flags & IPCL_TCP4))
88 
89 #define	IPCL_IS_TCP4_CONNECTED_NO_POLICY(connp)				\
90 	(((connp)->conn_flags &						\
91 		(IPCL_TCP4|IPCL_CONNECTED|IPCL_CHECK_POLICY|IPCL_TCP6))	\
92 		== (IPCL_TCP4|IPCL_CONNECTED))
93 
94 #define	IPCL_IS_CONNECTED(connp)					\
95 	((connp)->conn_flags & IPCL_CONNECTED)
96 
97 #define	IPCL_IS_BOUND(connp)						\
98 	((connp)->conn_flags & IPCL_BOUND)
99 
100 #define	IPCL_IS_TCP4_BOUND(connp)					\
101 	(((connp)->conn_flags &						\
102 		(IPCL_TCP4|IPCL_BOUND|IPCL_TCP6)) ==			\
103 		(IPCL_TCP4|IPCL_BOUND))
104 
105 #define	IPCL_IS_FULLY_BOUND(connp)					\
106 	((connp)->conn_flags & IPCL_FULLY_BOUND)
107 
108 #define	IPCL_IS_TCP(connp)						\
109 	((connp)->conn_flags & (IPCL_TCP4|IPCL_TCP6))
110 
111 /*
112  * IPCL_UDP is set on the conn when udp is directly above ip;
113  * this flag is cleared the moment udp is popped.
114  */
115 #define	IPCL_IS_UDP(connp)						\
116 	((connp)->conn_flags & IPCL_UDP)
117 
118 #define	IPCL_IS_IPTUN(connp)						\
119 	((connp)->conn_ulp == IPPROTO_ENCAP || \
120 	(connp)->conn_ulp == IPPROTO_IPV6)
121 
122 typedef struct connf_s connf_t;
123 typedef struct
124 {
125 	int	ctb_depth;
126 #define	IP_STACK_DEPTH	15
127 	pc_t	ctb_stack[IP_STACK_DEPTH];
128 } conn_trace_t;
129 
130 struct conn_s {
131 	kmutex_t	conn_lock;
132 	uint32_t	conn_ref;		/* Reference counter */
133 	uint_t		conn_state_flags;	/* IP state flags */
134 	ire_t		*conn_ire_cache; 	/* outbound ire cache */
135 	uint32_t	conn_flags;		/* Conn Flags */
136 	unsigned int
137 		conn_on_sqp : 1,		/* Conn is being processed */
138 		conn_dontroute : 1,		/* SO_DONTROUTE state */
139 		conn_loopback : 1,		/* SO_LOOPBACK state */
140 		conn_broadcast : 1,		/* SO_BROADCAST state */
141 		conn_reuseaddr : 1,		/* SO_REUSEADDR state */
142 
143 		conn_multicast_loop : 1,	/* IP_MULTICAST_LOOP */
144 		conn_multi_router : 1,		/* Wants all multicast pkts */
145 		conn_draining : 1,		/* ip_wsrv running */
146 		conn_did_putbq : 1,		/* ip_wput did a putbq */
147 
148 		conn_unspec_src : 1,		/* IP_UNSPEC_SRC */
149 		conn_policy_cached : 1,		/* Is policy cached/latched ? */
150 		conn_in_enforce_policy : 1,	/* Enforce Policy on inbound */
151 		conn_out_enforce_policy : 1,	/* Enforce Policy on outbound */
152 
153 		conn_af_isv6 : 1,		/* ip address family ver 6 */
154 		conn_pkt_isv6 : 1,		/* ip packet format ver 6 */
155 		conn_ipv6_recvpktinfo : 1,	/* IPV6_RECVPKTINFO option */
156 		conn_ipv6_recvhoplimit : 1,	/* IPV6_RECVHOPLIMIT option */
157 
158 		conn_ipv6_recvhopopts : 1,	/* IPV6_RECVHOPOPTS option */
159 		conn_ipv6_recvdstopts : 1,	/* IPV6_RECVDSTOPTS option */
160 		conn_ipv6_recvrthdr : 1,	/* IPV6_RECVRTHDR option */
161 		conn_ipv6_recvrtdstopts : 1,	/* IPV6_RECVRTHDRDSTOPTS */
162 		conn_ipv6_v6only : 1,		/* IPV6_V6ONLY */
163 		conn_ipv6_recvtclass : 1,	/* IPV6_RECVTCLASS */
164 		conn_ipv6_recvpathmtu : 1,	/* IPV6_RECVPATHMTU */
165 		conn_pathmtu_valid : 1,		/* The cached mtu is valid. */
166 		conn_ipv6_dontfrag : 1,		/* IPV6_DONTFRAG */
167 		/*
168 		 * This option can take on values in [-1, 1] so we store it
169 		 * +1.  Manifest constants IPV6_USE_MIN_MTU_* describe these
170 		 * values.
171 		 */
172 		conn_fully_bound : 1,		/* Fully bound connection */
173 		conn_recvif : 1,		/* IP_RECVIF option */
174 		conn_recvslla : 1,		/* IP_RECVSLLA option */
175 		conn_mdt_ok : 1,		/* MDT is permitted */
176 		conn_nexthop_set : 1,
177 		pad_to_bit_31 : 1;
178 
179 	tcp_t		*conn_tcp;		/* Pointer to the tcp struct */
180 	struct udp_s	*conn_udp;		/* Pointer to the udp struct */
181 
182 	squeue_t	*conn_sqp;		/* Squeue for processing */
183 	edesc_rpf	conn_recv;		/* Pointer to recv routine */
184 	void		*conn_pad1;
185 
186 	ill_t		*conn_xmit_if_ill;	/* Outbound ill */
187 	ill_t		*conn_nofailover_ill;	/* Failover ill */
188 	ipsec_latch_t	*conn_latch;		/* latched state */
189 	ill_t		*conn_outgoing_ill;	/* IP{,V6}_BOUND_IF */
190 	edesc_spf	conn_send;		/* Pointer to send routine */
191 	queue_t		*conn_rq;		/* Read queue */
192 	queue_t		*conn_wq;		/* Write queue */
193 	dev_t		conn_dev;		/* Minor number */
194 
195 	cred_t		*conn_cred;		/* Credentials */
196 	connf_t		*conn_g_fanout;		/* Global Hash bucket head */
197 	struct conn_s	*conn_g_next;		/* Global Hash chain next */
198 	struct conn_s	*conn_g_prev;		/* Global Hash chain prev */
199 	struct ipsec_policy_head_s *conn_policy; /* Configured policy */
200 	in6_addr_t	conn_bound_source_v6;
201 #define	conn_bound_source	V4_PART_OF_V6(conn_bound_source_v6)
202 	void		*conn_void[1];
203 
204 	connf_t		*conn_fanout;		/* Hash bucket we're part of */
205 	struct conn_s	*conn_next;		/* Hash chain next */
206 	struct conn_s	*conn_prev;		/* Hash chain prev */
207 	struct {
208 		in6_addr_t connua_laddr;	/* Local address */
209 		in6_addr_t connua_faddr;	/* Remote address */
210 	} connua_v6addr;
211 #define	conn_src	V4_PART_OF_V6(connua_v6addr.connua_laddr)
212 #define	conn_rem	V4_PART_OF_V6(connua_v6addr.connua_faddr)
213 #define	conn_srcv6	connua_v6addr.connua_laddr
214 #define	conn_remv6	connua_v6addr.connua_faddr
215 	union {
216 		/* Used for classifier match performance */
217 		uint32_t		conn_ports2;
218 		struct {
219 			in_port_t	tcpu_fport;	/* Remote port */
220 			in_port_t	tcpu_lport;	/* Local port */
221 		} tcpu_ports;
222 	} u_port;
223 #define	conn_fport	u_port.tcpu_ports.tcpu_fport
224 #define	conn_lport	u_port.tcpu_ports.tcpu_lport
225 #define	conn_ports	u_port.conn_ports2
226 #define	conn_upq	conn_rq
227 	uint8_t		conn_ulp;		/* protocol type */
228 	uint8_t		conn_unused_byte;
229 	kcondvar_t	conn_cv;
230 
231 	uint_t		conn_proto;		/* SO_PROTOTYPE state */
232 	ill_t		*conn_incoming_ill;	/* IP{,V6}_BOUND_IF */
233 	ill_t		*conn_outgoing_pill;	/* IP{,V6}_BOUND_PIF */
234 	ill_t		*conn_oper_pending_ill; /* pending shared ioctl */
235 	ill_t		*conn_xioctl_pending_ill; /* pending excl ioctl */
236 
237 	/* this is used only when an unbind is in progress.. */
238 	struct sq_s	*conn_pending_sq; /* waiting for ioctl on sq */
239 	ilg_t	*conn_ilg;		/* Group memberships */
240 	int	conn_ilg_allocated;	/* Number allocated */
241 	int	conn_ilg_inuse;		/* Number currently used */
242 	int	conn_ilg_walker_cnt;	/* No of ilg walkers */
243 	/* XXXX get rid of this, once ilg_delete_all is fixed */
244 	kcondvar_t	conn_refcv;
245 
246 	struct ipif_s	*conn_multicast_ipif;	/* IP_MULTICAST_IF */
247 	ill_t		*conn_multicast_ill;	/* IPV6_MULTICAST_IF */
248 	int		conn_orig_bound_ifindex; /* BOUND_IF before MOVE */
249 	int		conn_orig_multicast_ifindex;
250 						/* IPv6 MC IF before MOVE */
251 	int		conn_orig_xmit_ifindex; /* IP_XMIT_IF before move */
252 	struct conn_s 	*conn_drain_next;	/* Next conn in drain list */
253 	struct conn_s	*conn_drain_prev;	/* Prev conn in drain list */
254 	idl_t		*conn_idl;		/* Ptr to the drain list head */
255 	mblk_t		*conn_ipsec_opt_mp;	/* ipsec option mblk */
256 	uint32_t	conn_src_preferences;	/* prefs for src addr select */
257 	/* mtuinfo from IPV6_PACKET_TOO_BIG conditional on conn_pathmtu_valid */
258 	struct ip6_mtuinfo mtuinfo;
259 	zoneid_t	conn_zoneid;		/* zone connection is in */
260 	in6_addr_t	conn_nexthop_v6;	/* nexthop IP address */
261 #define	conn_nexthop_v4	V4_PART_OF_V6(conn_nexthop_v6)
262 #ifdef CONN_DEBUG
263 #define	CONN_TRACE_MAX	10
264 	int		conn_trace_last;	/* ndx of last used tracebuf */
265 	conn_trace_t	conn_trace_buf[CONN_TRACE_MAX];
266 #endif
267 };
268 
269 /*
270  * connf_t - connection fanout data.
271  *
272  * The hash tables and their linkage (conn_t.{hashnextp, hashprevp} are
273  * protected by the per-bucket lock. Each conn_t inserted in the list
274  * points back at the connf_t that heads the bucket.
275  */
276 
277 struct connf_s {
278 	struct conn_s	*connf_head;
279 	kmutex_t	connf_lock;
280 };
281 
282 #define	CONN_INC_REF(connp)	{				\
283 	DTRACE_PROBE1(conn__inc__ref, conn_t *, connp);		\
284 	mutex_enter(&(connp)->conn_lock);			\
285 	ASSERT(conn_trace_ref(connp));				\
286 	(connp)->conn_ref++;					\
287 	ASSERT((connp)->conn_ref != 0);				\
288 	mutex_exit(&(connp)->conn_lock);			\
289 }
290 
291 #define	CONN_INC_REF_LOCKED(connp)	{			\
292 	DTRACE_PROBE1(conn__inc__ref, conn_t *, connp);		\
293 	ASSERT(MUTEX_HELD(&(connp)->conn_lock));	 	\
294 	ASSERT(conn_trace_ref(connp));				\
295 	(connp)->conn_ref++;					\
296 	ASSERT((connp)->conn_ref != 0);				\
297 }
298 
299 #define	CONN_DEC_REF(connp)	{					\
300 	DTRACE_PROBE1(conn__dec__ref, conn_t *, connp);			\
301 	mutex_enter(&(connp)->conn_lock);				\
302 	if ((connp)->conn_ref <= 0)					\
303 		cmn_err(CE_PANIC, "CONN_DEC_REF: connp(%p) has ref "	\
304 			"= %d\n", (void *)(connp), (connp)->conn_ref);	\
305 	ASSERT(conn_untrace_ref(connp));				\
306 	(connp)->conn_ref--;						\
307 	if ((connp)->conn_ref == 0) {					\
308 		/* Refcnt can't increase again, safe to drop lock */	\
309 		mutex_exit(&(connp)->conn_lock);			\
310 		ipcl_conn_destroy(connp);				\
311 	} else {							\
312 		cv_broadcast(&(connp)->conn_cv);			\
313 		mutex_exit(&(connp)->conn_lock);			\
314 	}								\
315 }
316 
317 #define	_IPCL_V4_MATCH(v6addr, v4addr)	\
318 	(V4_PART_OF_V6((v6addr)) == (v4addr) && IN6_IS_ADDR_V4MAPPED(&(v6addr)))
319 
320 #define	_IPCL_V4_MATCH_ANY(addr)	\
321 	(IN6_IS_ADDR_V4MAPPED_ANY(&(addr)) || IN6_IS_ADDR_UNSPECIFIED(&(addr)))
322 
323 /*
324  * IPCL_PROTO_MATCH() only matches conns with the specified zoneid, while
325  * IPCL_PROTO_MATCH_V6() can match other conns in the multicast case, see
326  * ip_fanout_proto().
327  */
328 #define	IPCL_PROTO_MATCH(connp, protocol, ipha, ill,			\
329     fanout_flags, zoneid)						\
330 	((((connp)->conn_src == INADDR_ANY) ||				\
331 	(((connp)->conn_src == ((ipha)->ipha_dst)) &&			\
332 	(((connp)->conn_rem == INADDR_ANY) ||				\
333 	((connp)->conn_rem == ((ipha)->ipha_src))))) &&			\
334 	((connp)->conn_zoneid == (zoneid)) &&				\
335 	(conn_wantpacket((connp), (ill), (ipha),			\
336 	(fanout_flags), (zoneid)) || ((protocol) == IPPROTO_PIM) ||	\
337 	((protocol) == IPPROTO_RSVP)))
338 
339 #define	IPCL_PROTO_MATCH_V6(connp, protocol, ip6h, ill,			   \
340     fanout_flags, zoneid)						   \
341 	((IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_srcv6) ||		   \
342 	(IN6_ARE_ADDR_EQUAL(&(connp)->conn_srcv6, &((ip6h)->ip6_dst)) &&   \
343 	(IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_remv6) ||		   \
344 	IN6_ARE_ADDR_EQUAL(&(connp)->conn_remv6, &((ip6h)->ip6_src))))) && \
345 	(conn_wantpacket_v6((connp), (ill), (ip6h),			   \
346 	(fanout_flags), (zoneid)) || ((protocol) == IPPROTO_RSVP)))
347 
348 #define	IPCL_CONN_HASH(src, ports)					\
349 	((unsigned)(ntohl((src)) ^ ((ports) >> 24) ^ ((ports) >> 16) ^	\
350 	((ports) >> 8) ^ (ports)) % ipcl_conn_fanout_size)
351 
352 #define	IPCL_CONN_HASH_V6(src, ports)			\
353 	IPCL_CONN_HASH(V4_PART_OF_V6((src)), (ports))
354 
355 #define	IPCL_CONN_MATCH(connp, proto, src, dst, ports)			\
356 	((connp)->conn_ulp == (proto) &&				\
357 		(connp)->conn_ports == (ports) &&      			\
358 		_IPCL_V4_MATCH((connp)->conn_remv6, (src)) &&		\
359 		_IPCL_V4_MATCH((connp)->conn_srcv6, (dst)) &&		\
360 		!(connp)->conn_ipv6_v6only)
361 
362 #define	IPCL_CONN_MATCH_V6(connp, proto, src, dst, ports)		\
363 	((connp)->conn_ulp == (proto) &&				\
364 		(connp)->conn_ports == (ports) &&      			\
365 		IN6_ARE_ADDR_EQUAL(&(connp)->conn_remv6, &(src)) &&	\
366 		IN6_ARE_ADDR_EQUAL(&(connp)->conn_srcv6, &(dst)))
367 
368 #define	IPCL_CONN_INIT(connp, protocol, src, rem, ports) {		\
369 	(connp)->conn_ulp = protocol;					\
370 	IN6_IPADDR_TO_V4MAPPED(src, &(connp)->conn_srcv6);		\
371 	IN6_IPADDR_TO_V4MAPPED(rem, &(connp)->conn_remv6);		\
372 	(connp)->conn_ports = ports;					\
373 }
374 
375 #define	IPCL_CONN_INIT_V6(connp, protocol, src, rem, ports) {		\
376 	(connp)->conn_ulp = protocol;					\
377 	(connp)->conn_srcv6 = src;					\
378 	(connp)->conn_remv6 = rem;					\
379 	(connp)->conn_ports = ports;					\
380 }
381 
382 #define	IPCL_BIND_HASH(lport)						\
383 	((unsigned)(((lport) >> 8) ^ (lport)) % ipcl_bind_fanout_size)
384 
385 #define	IPCL_BIND_MATCH(connp, proto, laddr, lport)			\
386 	((connp)->conn_ulp == (proto) &&				\
387 		(connp)->conn_lport == (lport) &&			\
388 		(_IPCL_V4_MATCH_ANY((connp)->conn_srcv6) ||		\
389 		_IPCL_V4_MATCH((connp)->conn_srcv6, (laddr))) &&	\
390 		!(connp)->conn_ipv6_v6only)
391 
392 #define	IPCL_BIND_MATCH_V6(connp, proto, laddr, lport)			\
393 	((connp)->conn_ulp == (proto) &&				\
394 		(connp)->conn_lport == (lport) &&			\
395 		(IN6_ARE_ADDR_EQUAL(&(connp)->conn_srcv6, &(laddr)) ||	\
396 		IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_srcv6)))
397 
398 #define	IPCL_UDP_MATCH(connp, lport, laddr, fport, faddr)		\
399 	(((connp)->conn_lport == (lport)) &&				\
400 	((_IPCL_V4_MATCH_ANY((connp)->conn_srcv6) ||			\
401 	(_IPCL_V4_MATCH((connp)->conn_srcv6, (laddr)) &&		\
402 	(_IPCL_V4_MATCH_ANY((connp)->conn_remv6) ||			\
403 	(_IPCL_V4_MATCH((connp)->conn_remv6, (faddr)) &&		\
404 	(connp)->conn_fport == (fport)))))) &&				\
405 	!(connp)->conn_ipv6_v6only)
406 
407 #define	IPCL_UDP_MATCH_V6(connp, lport, laddr, fport, faddr)	\
408 	(((connp)->conn_lport == (lport)) &&			\
409 	(IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_srcv6) ||	\
410 	(IN6_ARE_ADDR_EQUAL(&(connp)->conn_srcv6, &(laddr)) &&	\
411 	(IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_remv6) ||	\
412 	(IN6_ARE_ADDR_EQUAL(&(connp)->conn_remv6, &(faddr)) &&	\
413 	(connp)->conn_fport == (fport))))))
414 
415 #define	IPCL_TCP_EAGER_INIT(connp, protocol, src, rem, ports) {		\
416 	(connp)->conn_flags |= (IPCL_TCP4|IPCL_EAGER);			\
417 	(connp)->conn_ulp = protocol;					\
418 	IN6_IPADDR_TO_V4MAPPED(src, &(connp)->conn_srcv6);		\
419 	IN6_IPADDR_TO_V4MAPPED(rem, &(connp)->conn_remv6);		\
420 	(connp)->conn_ports = ports;					\
421 	(connp)->conn_send = ip_output;					\
422 	(connp)->conn_sqp = IP_SQUEUE_GET(lbolt);			\
423 }
424 
425 #define	IPCL_TCP_EAGER_INIT_V6(connp, protocol, src, rem, ports) {	\
426 	(connp)->conn_flags |= (IPCL_TCP6|IPCL_EAGER);			\
427 	(connp)->conn_ulp = protocol;					\
428 	(connp)->conn_srcv6 = src;					\
429 	(connp)->conn_remv6 = rem;					\
430 	(connp)->conn_ports = ports;					\
431 	(connp)->conn_send = ip_output_v6;				\
432 	(connp)->conn_sqp = IP_SQUEUE_GET(lbolt);			\
433 }
434 
435 #define	ipcl_proto_search(protocol)					\
436 	(ipcl_proto_fanout[(protocol)].connf_head)
437 
438 #ifdef _BIG_ENDIAN
439 #define	IPCL_UDP_HASH(port)		((port) & 0xFF)
440 #else   /* _BIG_ENDIAN */
441 #define	IPCL_UDP_HASH(port)		(((uint16_t)(port)) >> 8)
442 #endif  /* _BIG_ENDIAN */
443 
444 #define	CONN_G_HASH_SIZE	1024
445 
446 /* Raw socket hash function. */
447 #define	IPCL_RAW_HASH(lport) (((lport) * 31) & (ipcl_raw_fanout_size - 1))
448 
449 /*
450  * This is similar to IPCL_BIND_MATCH except that the local port check
451  * is changed to a wildcard port check.
452  */
453 #define	IPCL_RAW_MATCH(connp, proto, laddr)			\
454 	((connp)->conn_ulp == (proto) &&			\
455 	(connp)->conn_lport == 0 &&				\
456 	(_IPCL_V4_MATCH_ANY((connp)->conn_srcv6) ||		\
457 	_IPCL_V4_MATCH((connp)->conn_srcv6, (laddr))))
458 
459 #define	IPCL_RAW_MATCH_V6(connp, proto, laddr)			\
460 	((connp)->conn_ulp == (proto) &&			\
461 	(connp)->conn_lport == 0 &&				\
462 	(IN6_IS_ADDR_UNSPECIFIED(&(connp)->conn_srcv6) ||	\
463 	IN6_ARE_ADDR_EQUAL(&(connp)->conn_srcv6, &(laddr))))
464 
465 /* hash tables */
466 extern connf_t	rts_clients;
467 extern connf_t	*ipcl_conn_fanout;
468 extern connf_t	*ipcl_bind_fanout;
469 extern connf_t	ipcl_proto_fanout[IPPROTO_MAX + 1];
470 extern connf_t	ipcl_proto_fanout_v6[IPPROTO_MAX + 1];
471 extern connf_t	*ipcl_udp_fanout;
472 extern connf_t	*ipcl_globalhash_fanout;
473 extern connf_t	*ipcl_raw_fanout;
474 extern uint_t	ipcl_conn_fanout_size;
475 extern uint_t	ipcl_bind_fanout_size;
476 extern uint_t	ipcl_udp_fanout_size;
477 extern uint_t	ipcl_raw_fanout_size;
478 
479 /* Function prototypes */
480 extern void ipcl_init(void);
481 extern void ipcl_destroy(void);
482 extern conn_t *ipcl_conn_create(uint32_t, int);
483 extern void ipcl_conn_destroy(conn_t *);
484 
485 void ipcl_hash_insert_connected(connf_t *, conn_t *);
486 void ipcl_hash_insert_bound(connf_t *, conn_t *);
487 void ipcl_hash_insert_wildcard(connf_t *, conn_t *);
488 void ipcl_hash_remove(conn_t *);
489 void ipcl_hash_remove_locked(conn_t *connp, connf_t *connfp);
490 
491 extern int	ipcl_bind_insert(conn_t *, uint8_t, ipaddr_t, uint16_t);
492 extern int	ipcl_bind_insert_v6(conn_t *, uint8_t, const in6_addr_t *,
493 		    uint16_t);
494 extern int	ipcl_conn_insert(conn_t *, uint8_t, ipaddr_t, ipaddr_t,
495 		    uint32_t);
496 extern int	ipcl_conn_insert_v6(conn_t *, uint8_t, const in6_addr_t *,
497 		    const in6_addr_t *, uint32_t, uint_t);
498 extern conn_t	*ipcl_get_next_conn(connf_t *, conn_t *, uint32_t);
499 
500 void ipcl_proto_insert(conn_t *, uint8_t);
501 void ipcl_proto_insert_v6(conn_t *, uint8_t);
502 conn_t *ipcl_classify_v4(mblk_t *, uint8_t, uint_t, zoneid_t);
503 conn_t *ipcl_classify_v6(mblk_t *, uint8_t, uint_t, zoneid_t);
504 conn_t *ipcl_classify(mblk_t *, zoneid_t);
505 conn_t *ipcl_classify_raw(uint8_t, zoneid_t, uint32_t, ipha_t *);
506 void	ipcl_globalhash_insert(conn_t *);
507 void	ipcl_globalhash_remove(conn_t *);
508 void	ipcl_walk(pfv_t, void *);
509 conn_t	*ipcl_tcp_lookup_reversed_ipv4(ipha_t *, tcph_t *, int);
510 conn_t	*ipcl_tcp_lookup_reversed_ipv6(ip6_t *, tcpha_t *, int, uint_t);
511 conn_t	*ipcl_lookup_listener_v4(uint16_t, ipaddr_t, zoneid_t);
512 conn_t	*ipcl_lookup_listener_v6(uint16_t, in6_addr_t *, uint_t, zoneid_t);
513 int	conn_trace_ref(conn_t *);
514 int	conn_untrace_ref(conn_t *);
515 conn_t *ipcl_conn_tcp_lookup_reversed_ipv4(conn_t *, ipha_t *, tcph_t *);
516 conn_t *ipcl_conn_tcp_lookup_reversed_ipv6(conn_t *, ip6_t *, tcph_t *);
517 #ifdef	__cplusplus
518 }
519 #endif
520 
521 #endif	/* _INET_IPCLASSIFIER_H */
522