squeue.h revision 11042:2d6e217af1b4 
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 * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
23 * Use is subject to license terms.
24 */
25
26#ifndef	_SYS_SQUEUE_H
27#define	_SYS_SQUEUE_H
28
29#ifdef	__cplusplus
30extern "C" {
31#endif
32
33#include <sys/types.h>
34#include <sys/processor.h>
35#include <sys/stream.h>
36
37struct squeue_s;
38typedef struct squeue_s squeue_t;
39
40#define	SET_SQUEUE(mp, proc, arg) {				\
41	ASSERT((mp)->b_prev == NULL);				\
42	ASSERT((mp)->b_next == NULL);				\
43	(mp)->b_queue = (queue_t *)(proc);			\
44	(mp)->b_prev = (mblk_t *)(arg);				\
45}
46
47#define	SQ_FILL		0x0001
48#define	SQ_NODRAIN	0x0002
49#define	SQ_PROCESS	0x0004
50
51#define	SQUEUE_ENTER(sqp, head, tail, cnt, ira, flag, tag) {	\
52	sqp->sq_enter(sqp, head, tail, cnt, ira, flag, tag);	\
53}
54
55#define	SQUEUE_ENTER_ONE(sqp, mp, proc, arg, ira, flag, tag) {	\
56	ASSERT(mp->b_next == NULL);				\
57	ASSERT(mp->b_prev == NULL);				\
58	SET_SQUEUE(mp, proc, arg);				\
59	SQUEUE_ENTER(sqp, mp, mp, 1, ira, flag, tag);		\
60}
61
62/*
63 * May be called only by a thread executing in the squeue. The thread must
64 * not continue to execute any code needing squeue protection after calling
65 * this macro. Please see the comments in squeue.c for more details.
66 */
67#define	SQUEUE_SWITCH(connp, new_sqp)				\
68	(connp)->conn_sqp = new_sqp;
69
70/*
71 * Facility-special private data in squeues.
72 */
73typedef enum {
74	SQPRIVATE_TCP,
75	SQPRIVATE_MAX
76} sqprivate_t;
77
78struct ip_recv_attr_s;
79extern void squeue_init(void);
80extern squeue_t *squeue_create(clock_t, pri_t);
81extern void squeue_bind(squeue_t *, processorid_t);
82extern void squeue_unbind(squeue_t *);
83extern void squeue_enter(squeue_t *, mblk_t *, mblk_t *,
84    uint32_t, struct ip_recv_attr_s *, int, uint8_t);
85extern uintptr_t *squeue_getprivate(squeue_t *, sqprivate_t);
86
87struct conn_s;
88extern int squeue_synch_enter(squeue_t *, struct conn_s *, mblk_t *);
89extern void squeue_synch_exit(squeue_t *, struct conn_s *);
90
91#ifdef	__cplusplus
92}
93#endif
94
95#endif	/* _SYS_SQUEUE_H */
96