/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License (the "License"). * You may not use this file except in compliance with the License. * * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE * or http://www.opensolaris.org/os/licensing. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at usr/src/OPENSOLARIS.LICENSE. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END */ /* * Copyright 2010 Sun Microsystems, Inc. All rights reserved. * Use is subject to license terms. * */ #ifndef _QUEUE_H #define _QUEUE_H #ifdef __cplusplus extern "C" { #endif #include <pthread.h> #include <stddef.h> typedef struct aln audit_link_t; struct aln { audit_link_t *aln_next; }; /* one audit_rec_t per audit record */ typedef struct abq audit_rec_t; struct abq { audit_link_t abq_l; int abq_ref_count; size_t abq_buf_len; /* space allocated */ size_t abq_data_len; /* space used */ char abq_buffer[1]; /* variable length */ }; #define AUDIT_REC_HEADER offsetof(audit_rec_t, abq_buffer[0]) /* one audit_q_t entry per audit record per plugin */ typedef struct aqq audit_q_t; /* plugin queued data */ struct aqq { audit_link_t aqq_l; audit_rec_t *aqq_data; uint64_t aqq_sequence; }; /* queue head */ typedef struct auq au_queue_t; struct auq { void *auq_head; void *auq_tail; int auq_count; pthread_mutex_t auq_lock; }; int audit_dequeue(au_queue_t *, void **); void audit_queue_destroy(au_queue_t *); void audit_enqueue(au_queue_t *, void *); int audit_queue_size(au_queue_t *); void audit_queue_init(au_queue_t *); audit_rec_t *audit_release(pthread_mutex_t *, audit_rec_t *); void audit_incr_ref(pthread_mutex_t *, audit_rec_t *); #ifdef __cplusplus } #endif #endif /* _QUEUE_H */