usr/src/cmd/syslogd/dataq.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  * Copyright 1996-2002 Sun Microsystems, Inc.  All rights reserved.
  24  * Use is subject to license terms.
  25  */
  26
  27 #ifndef _DATAQ_H
  28 #define _DATAQ_H
  29
  30 #pragma ident   "%Z%%M% %I%     %E% SMI"
  31
  32 #include "llt.h"
  33
  34 typedef struct dataq_data {
  35         ll_t list;
  36         void *data;
  37 } dataq_data_t;
  38
  39 typedef struct dataq_waiter {
  40         ll_t list;
  41         pthread_cond_t cv;
  42         int wakeup;
  43 } dataq_waiter_t;
  44
  45 typedef struct dataq {
  46         pthread_mutex_t lock;
  47         int num_data;
  48         int num_waiters;
  49         llh_t data;
  50         llh_t waiters;
  51 } dataq_t;
  52
  53 int dataq_init(dataq_t *ptr);
  54 int dataq_enqueue(dataq_t *dataq, void *in);
  55 int dataq_dequeue(dataq_t *dataq, void **outptr, int);
  56 int dataq_destroy(dataq_t *dataq);
  57
  58 #endif  /* _DATAQ_H */