fmd/common/fmd_dispq.c

98 	fmd_dispq_t *dqp = fmd_alloc(sizeof (fmd_dispq_t), FMD_SLEEP);
100 	(void) pthread_rwlock_init(&dqp->dq_lock, NULL);
101 	dqp->dq_root = fmd_dispqelem_create(NULL);
102 	dqp->dq_gids = fmd_idspace_create("dispq_gids", 1, INT_MAX);
103 	dqp->dq_gmax = 0;
105 	return (dqp);
109 fmd_dispq_destroy(fmd_dispq_t *dqp)
111 	fmd_dispqelem_destroy(dqp->dq_root);
112 	fmd_idspace_destroy(dqp->dq_gids);
113 	fmd_free(dqp, sizeof (fmd_dispq_t));
141 fmd_dispq_insert(fmd_dispq_t *dqp, fmd_eventq_t *eqp, const char *pattern)
149 	(void) pthread_rwlock_wrlock(&dqp->dq_lock);
150 	dep = dqp->dq_root;
162 	(void) pthread_rwlock_unlock(&dqp->dq_lock);
213 fmd_dispq_delete(fmd_dispq_t *dqp, fmd_eventq_t *eqp, const char *pattern)
225 		(void) pthread_rwlock_wrlock(&dqp->dq_lock);
226 		fmd_dispq_delete_one(dqp->dq_root, eqp, patc, patv);
227 		(void) pthread_rwlock_unlock(&dqp->dq_lock);
308 fmd_dispq_dispatch_gid(fmd_dispq_t *dqp,
351 	(void) pthread_rwlock_rdlock(&dqp->dq_lock);
353 	glen = BT_BITOUL(dqp->dq_gmax);
370 			n += fmd_dispq_dispatchv(dqp->dq_root,
376 	n += fmd_dispq_dispatchv(dqp->dq_root, gids, ep, class, cc, cv);
378 	(void) pthread_rwlock_unlock(&dqp->dq_lock);
392 fmd_dispq_dispatch(fmd_dispq_t *dqp, fmd_event_t *ep, const char *class)
394 	fmd_dispq_dispatch_gid(dqp, ep, class, -1);
398 fmd_dispq_getgid(fmd_dispq_t *dqp, void *cookie)
402 	(void) pthread_rwlock_wrlock(&dqp->dq_lock);
404 	gid = fmd_idspace_alloc_min(dqp->dq_gids, cookie);
405 	dqp->dq_gmax = MAX(dqp->dq_gmax, gid);
407 	(void) pthread_rwlock_unlock(&dqp->dq_lock);
413 fmd_dispq_delgid(fmd_dispq_t *dqp, id_t gid)
415 	(void) pthread_rwlock_wrlock(&dqp->dq_lock);
417 	ASSERT(fmd_idspace_contains(dqp->dq_gids, gid));
418 	(void) fmd_idspace_free(dqp->dq_gids, gid);
420 	(void) pthread_rwlock_unlock(&dqp->dq_lock);