1f53d15feSStephan Uphoff /*- 2f53d15feSStephan Uphoff * Copyright (c) 2007 Stephan Uphoff <ups@FreeBSD.org> 3f53d15feSStephan Uphoff * All rights reserved. 4f53d15feSStephan Uphoff * 5f53d15feSStephan Uphoff * Redistribution and use in source and binary forms, with or without 6f53d15feSStephan Uphoff * modification, are permitted provided that the following conditions 7f53d15feSStephan Uphoff * are met: 8f53d15feSStephan Uphoff * 1. Redistributions of source code must retain the above copyright 9f53d15feSStephan Uphoff * notice, this list of conditions and the following disclaimer. 10f53d15feSStephan Uphoff * 2. Redistributions in binary form must reproduce the above copyright 11f53d15feSStephan Uphoff * notice, this list of conditions and the following disclaimer in the 12f53d15feSStephan Uphoff * documentation and/or other materials provided with the distribution. 13f53d15feSStephan Uphoff * 3. Neither the name of the author nor the names of any co-contributors 14f53d15feSStephan Uphoff * may be used to endorse or promote products derived from this software 15f53d15feSStephan Uphoff * without specific prior written permission. 16f53d15feSStephan Uphoff * 17f53d15feSStephan Uphoff * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 18f53d15feSStephan Uphoff * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 19f53d15feSStephan Uphoff * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 20f53d15feSStephan Uphoff * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 21f53d15feSStephan Uphoff * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 22f53d15feSStephan Uphoff * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 23f53d15feSStephan Uphoff * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 24f53d15feSStephan Uphoff * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 25f53d15feSStephan Uphoff * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 26f53d15feSStephan Uphoff * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 27f53d15feSStephan Uphoff * SUCH DAMAGE. 28f53d15feSStephan Uphoff * 29f53d15feSStephan Uphoff * $FreeBSD$ 30f53d15feSStephan Uphoff */ 31f53d15feSStephan Uphoff 32f53d15feSStephan Uphoff #ifndef _SYS_RMLOCK_H_ 33f53d15feSStephan Uphoff #define _SYS_RMLOCK_H_ 34f53d15feSStephan Uphoff 35f53d15feSStephan Uphoff #include <sys/mutex.h> 36*36058c09SMax Laier #include <sys/sx.h> 37f53d15feSStephan Uphoff #include <sys/_lock.h> 38f53d15feSStephan Uphoff #include <sys/_rmlock.h> 39f53d15feSStephan Uphoff 40f53d15feSStephan Uphoff #ifdef _KERNEL 41f53d15feSStephan Uphoff 421a109c1cSRobert Watson /* 431a109c1cSRobert Watson * Flags passed to rm_init(9). 441a109c1cSRobert Watson */ 451a109c1cSRobert Watson #define RM_NOWITNESS 0x00000001 461a109c1cSRobert Watson #define RM_RECURSE 0x00000002 47*36058c09SMax Laier #define RM_SLEEPABLE 0x00000004 481a109c1cSRobert Watson 491a109c1cSRobert Watson void rm_init(struct rmlock *rm, const char *name); 501a109c1cSRobert Watson void rm_init_flags(struct rmlock *rm, const char *name, int opts); 51f53d15feSStephan Uphoff void rm_destroy(struct rmlock *rm); 52433ea89aSRobert Watson int rm_wowned(struct rmlock *rm); 53f53d15feSStephan Uphoff void rm_sysinit(void *arg); 541a109c1cSRobert Watson void rm_sysinit_flags(void *arg); 55f53d15feSStephan Uphoff 56f53d15feSStephan Uphoff void _rm_wlock_debug(struct rmlock *rm, const char *file, int line); 57f53d15feSStephan Uphoff void _rm_wunlock_debug(struct rmlock *rm, const char *file, int line); 58*36058c09SMax Laier int _rm_rlock_debug(struct rmlock *rm, struct rm_priotracker *tracker, 59*36058c09SMax Laier int trylock, const char *file, int line); 60f53d15feSStephan Uphoff void _rm_runlock_debug(struct rmlock *rm, struct rm_priotracker *tracker, 61f53d15feSStephan Uphoff const char *file, int line); 62f53d15feSStephan Uphoff 63f53d15feSStephan Uphoff void _rm_wlock(struct rmlock *rm); 64f53d15feSStephan Uphoff void _rm_wunlock(struct rmlock *rm); 65*36058c09SMax Laier int _rm_rlock(struct rmlock *rm, struct rm_priotracker *tracker, 66*36058c09SMax Laier int trylock); 67f53d15feSStephan Uphoff void _rm_runlock(struct rmlock *rm, struct rm_priotracker *tracker); 68f53d15feSStephan Uphoff 69f53d15feSStephan Uphoff /* 70f53d15feSStephan Uphoff * Public interface for lock operations. 71f53d15feSStephan Uphoff */ 72f53d15feSStephan Uphoff #ifndef LOCK_DEBUG 73f53d15feSStephan Uphoff #error LOCK_DEBUG not defined, include <sys/lock.h> before <sys/rmlock.h> 74f53d15feSStephan Uphoff #endif 75f53d15feSStephan Uphoff 76f53d15feSStephan Uphoff #if LOCK_DEBUG > 0 77f53d15feSStephan Uphoff #define rm_wlock(rm) _rm_wlock_debug((rm), LOCK_FILE, LOCK_LINE) 78f53d15feSStephan Uphoff #define rm_wunlock(rm) _rm_wunlock_debug((rm), LOCK_FILE, LOCK_LINE) 79f53d15feSStephan Uphoff #define rm_rlock(rm,tracker) \ 80*36058c09SMax Laier ((void)_rm_rlock_debug((rm),(tracker), 0, LOCK_FILE, LOCK_LINE )) 81*36058c09SMax Laier #define rm_try_rlock(rm,tracker) \ 82*36058c09SMax Laier _rm_rlock_debug((rm),(tracker), 1, LOCK_FILE, LOCK_LINE ) 83f53d15feSStephan Uphoff #define rm_runlock(rm,tracker) \ 84f53d15feSStephan Uphoff _rm_runlock_debug((rm), (tracker), LOCK_FILE, LOCK_LINE ) 85f53d15feSStephan Uphoff #else 86f53d15feSStephan Uphoff #define rm_wlock(rm) _rm_wlock((rm)) 87f53d15feSStephan Uphoff #define rm_wunlock(rm) _rm_wunlock((rm)) 88*36058c09SMax Laier #define rm_rlock(rm,tracker) ((void)_rm_rlock((rm),(tracker), 0)) 89*36058c09SMax Laier #define rm_try_rlock(rm,tracker) _rm_rlock((rm),(tracker), 1) 90f53d15feSStephan Uphoff #define rm_runlock(rm,tracker) _rm_runlock((rm), (tracker)) 91f53d15feSStephan Uphoff #endif 92f53d15feSStephan Uphoff 93f53d15feSStephan Uphoff struct rm_args { 94f53d15feSStephan Uphoff struct rmlock *ra_rm; 95f53d15feSStephan Uphoff const char *ra_desc; 961a109c1cSRobert Watson }; 971a109c1cSRobert Watson 981a109c1cSRobert Watson struct rm_args_flags { 991a109c1cSRobert Watson struct rmlock *ra_rm; 1001a109c1cSRobert Watson const char *ra_desc; 101f53d15feSStephan Uphoff int ra_opts; 102f53d15feSStephan Uphoff }; 103f53d15feSStephan Uphoff 1041a109c1cSRobert Watson #define RM_SYSINIT(name, rm, desc) \ 1051a109c1cSRobert Watson static struct rm_args name##_args = { \ 1061a109c1cSRobert Watson (rm), \ 1071a109c1cSRobert Watson (desc), \ 1081a109c1cSRobert Watson }; \ 1091a109c1cSRobert Watson SYSINIT(name##_rm_sysinit, SI_SUB_LOCK, SI_ORDER_MIDDLE, \ 1101a109c1cSRobert Watson rm_sysinit, &name##_args); \ 1111a109c1cSRobert Watson SYSUNINIT(name##_rm_sysuninit, SI_SUB_LOCK, SI_ORDER_MIDDLE, \ 1121a109c1cSRobert Watson rm_destroy, (rm)) 1131a109c1cSRobert Watson 1141a109c1cSRobert Watson 1151a109c1cSRobert Watson #define RM_SYSINIT_FLAGS(name, rm, desc, opts) \ 116f53d15feSStephan Uphoff static struct rm_args name##_args = { \ 117f53d15feSStephan Uphoff (rm), \ 118f53d15feSStephan Uphoff (desc), \ 119f53d15feSStephan Uphoff (opts), \ 120f53d15feSStephan Uphoff }; \ 121f53d15feSStephan Uphoff SYSINIT(name##_rm_sysinit, SI_SUB_LOCK, SI_ORDER_MIDDLE, \ 1221a109c1cSRobert Watson rm_sysinit_flags, &name##_args); \ 123f53d15feSStephan Uphoff SYSUNINIT(name##_rm_sysuninit, SI_SUB_LOCK, SI_ORDER_MIDDLE, \ 124f53d15feSStephan Uphoff rm_destroy, (rm)) 125f53d15feSStephan Uphoff 126f53d15feSStephan Uphoff #endif /* _KERNEL */ 127f53d15feSStephan Uphoff #endif /* !_SYS_RMLOCK_H_ */ 128