/*
 * 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 2008 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#ifndef _ISNS_MSGQ_H
#define _ISNS_MSGQ_H

#include <pthread.h>
#include <synch.h>

#ifdef __cplusplus
extern "C" {
#endif

#define TEST_CLI_STOPPED        (0x0001)
#define DD_SERVICE_STOPPED      (0x0002)
#define SCN_STOPPED             (0x0004)
#define ESI_STOPPED             (0x0008)

typedef enum msg_id {
        DATA_ADD = 1,
        DATA_UPDATE,
        DATA_DELETE,
        DATA_DELETE_ASSOC,
        DATA_COMMIT,
        DATA_RETREAT,
        REG_EXP,
        DEAD_PORTAL,
        SYS_QUIT_OK,
        SCN_ADD = 100,
        SCN_REMOVE,
        SCN_REMOVE_P,
        SCN_SET,
        SCN_TRIGGER,
        SCN_IGNORE,
        SCN_STOP,
        SERVER_EXIT,
        CONFIG_RELOAD
} msg_id_t;

typedef struct msg_text {
        struct msg_text *prev;
        struct msg_text *next;
        msg_id_t         id;
        void            *data;
} msg_text_t;

typedef struct msg_queue {
        msg_text_t      *q_head;
        msg_text_t      *q_tail;
        pthread_mutex_t  q_mutex;
        sema_t           q_sema;
} msg_queue_t;

/* function prototypes */
msg_queue_t *queue_calloc();
int queue_msg_set(msg_queue_t *, msg_id_t, void *);
msg_text_t *queue_msg_get(msg_queue_t *);
void queue_msg_free(msg_text_t *);

#ifdef __cplusplus
}
#endif

#endif /* _ISNS_MSGQ_H */