usr/src/cmd/fm/fmd/common/fmd_dispq.h

   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
  37 extern "C" {
  38 #endif
  39
  40 #include <fmd_idspace.h>
  41 #include <fmd_eventq.h>
  42
  43 typedef 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
  48 typedef 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
  57 typedef 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
  64 extern fmd_dispq_t *fmd_dispq_create(void);
  65 extern void fmd_dispq_destroy(fmd_dispq_t *);
  66
  67 extern void fmd_dispq_insert(fmd_dispq_t *, fmd_eventq_t *, const char *);
  68 extern void fmd_dispq_delete(fmd_dispq_t *, fmd_eventq_t *, const char *);
  69 extern void fmd_dispq_dispatch(fmd_dispq_t *, fmd_event_t *, const char *);
  70 extern void fmd_dispq_dispatch_gid(fmd_dispq_t *, fmd_event_t *,
  71     const char *, id_t);
  72
  73 extern id_t fmd_dispq_getgid(fmd_dispq_t *, void *);
  74 extern void fmd_dispq_delgid(fmd_dispq_t *, id_t);
  75
  76 #ifdef  __cplusplus
  77 }
  78 #endif
  79
  80 #endif  /* _FMD_DISPQ_H */