/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License, Version 1.0 only
 * (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 2005 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#ifndef _SYS_RWSTLOCK_H
#define _SYS_RWSTLOCK_H

/*
 * Alternate rwlock that is interruptible and can be released by a thread
 * other than the one that acquired the lock.
 */

#ifdef __cplusplus
extern "C" {
#endif

#include <sys/types.h>
#include <sys/ksynch.h>
#include <sys/rwlock.h>

typedef struct rwstlock {
        intptr_t        rwst_count;
        kcondvar_t      rwst_rcv;
        kcondvar_t      rwst_wcv;
        kmutex_t        rwst_lock;
} rwstlock_t;

/*
 * The interfaces below are private to Sun Microsystems,
 * and these might change without notice.
 */

#define RWST_TRYENTER   0x01
#define RWST_SIG        0x02

#define RWST_HELD(l)            ((l)->rwst_count != 0)
#define RWST_READ_HELD(l)       ((l)->rwst_count > 0)
#define RWST_WRITE_HELD(l)      ((l)->rwst_count < 0)
#define RWST_WRITE_OWNER(l)     \
        ((l)->rwst_count == (LONG_MIN | (intptr_t)curthread))
#define RWST_OWNER(l)           (RWST_WRITE_HELD(l) ? \
        ((struct _kthread *)((l)->rwst_count & ~LONG_MIN)) : NULL)
#define RWST_READ_WANTED(l)     CV_HAS_WAITERS(&(l)->rwst_rcv)
#define RWST_WRITE_WANTED(l)    CV_HAS_WAITERS(&(l)->rwst_wcv)
#define RWST_WAIT(cv, lock, f)  \
        ((f) & RWST_SIG ? cv_wait_sig(cv, lock) : (cv_wait(cv, lock), 1))
#define RWST_READ_WAIT(l, f)    RWST_WAIT(&(l)->rwst_rcv, &(l)->rwst_lock, f)
#define RWST_WRITE_WAIT(l, f)   RWST_WAIT(&(l)->rwst_wcv, &(l)->rwst_lock, f)
#define RWST_READ_WAKE_ALL(l)   cv_broadcast(&(l)->rwst_rcv)
#define RWST_WRITE_WAKE_ONE(l)  cv_signal(&(l)->rwst_wcv)
#define RWST_READ_ENTER(l)      (l)->rwst_count++
#define RWST_WRITE_ENTER(l)     (l)->rwst_count = LONG_MIN | (intptr_t)curthread
#define RWST_READ_EXIT(l)       (l)->rwst_count--
#define RWST_WRITE_EXIT(l)      (l)->rwst_count = 0

extern void rwst_enter(rwstlock_t *, krw_t);
extern int rwst_enter_sig(rwstlock_t *, krw_t);
extern void rwst_exit(rwstlock_t *);
extern void rwst_init(rwstlock_t *, char *, krw_type_t, void *);
extern void rwst_destroy(rwstlock_t *);
extern int rwst_lock_held(rwstlock_t *, krw_t);
extern int rwst_tryenter(rwstlock_t *, krw_t);
extern struct _kthread *rwst_owner(rwstlock_t *);

#ifdef __cplusplus
}
#endif

#endif /* _SYS_RWSTLOCK_H */