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/*
24 * Copyright 2005 Sun Microsystems, Inc.  All rights reserved.
25 * Use is subject to license terms.
26 */
27
28#ifndef	_FMD_DISPQ_H
29#define	_FMD_DISPQ_H
30
31#pragma ident	"%Z%%M%	%I%	%E% SMI"
32
33#include <sys/types.h>
34#include <pthread.h>
35
36#ifdef	__cplusplus
37extern "C" {
38#endif
39
40#include <fmd_idspace.h>
41#include <fmd_eventq.h>
42
43typedef struct fmd_dispqlist {
44	struct fmd_dispqlist *dq_next;	/* link to next subscription object */
45	fmd_eventq_t *dq_eventq;	/* pointer to subscribing eventq */
46} fmd_dispqlist_t;
47
48typedef struct fmd_dispqelem {
49	char *dq_name;			/* name associated with this element */
50	struct fmd_dispqelem *dq_link;	/* link to next element in hash chain */
51	struct fmd_dispqelem **dq_hash;	/* hash bucket array for lower levels */
52	uint_t dq_hashlen;		/* length of dq_hash bucket array */
53	fmd_dispqlist_t *dq_list;	/* head of list of subscribers */
54	uint_t dq_refs;			/* ref count of hash and list elems */
55} fmd_dispqelem_t;
56
57typedef struct fmd_dispq {
58	pthread_rwlock_t dq_lock;	/* lock for event dispatch queue */
59	fmd_dispqelem_t *dq_root;	/* root hash table pointer */
60	fmd_idspace_t *dq_gids;		/* id hash for subscriber group ids */
61	id_t dq_gmax;			/* maximum group id allocated */
62} fmd_dispq_t;
63
64extern fmd_dispq_t *fmd_dispq_create(void);
65extern void fmd_dispq_destroy(fmd_dispq_t *);
66
67extern void fmd_dispq_insert(fmd_dispq_t *, fmd_eventq_t *, const char *);
68extern void fmd_dispq_delete(fmd_dispq_t *, fmd_eventq_t *, const char *);
69extern void fmd_dispq_dispatch(fmd_dispq_t *, fmd_event_t *, const char *);
70extern void fmd_dispq_dispatch_gid(fmd_dispq_t *, fmd_event_t *,
71    const char *, id_t);
72
73extern id_t fmd_dispq_getgid(fmd_dispq_t *, void *);
74extern void fmd_dispq_delgid(fmd_dispq_t *, id_t);
75
76#ifdef	__cplusplus
77}
78#endif
79
80#endif	/* _FMD_DISPQ_H */
81