2 * Copyright 2000, International Business Machines Corporation and others.
5 * This software has been released under the terms of the IBM Public
6 * License. For details, see the LICENSE file in the top-level source
7 * directory or online at http://www.openafs.org/dl/license10.html
11 * rx_kmutex.h - mutex and condition variable macros for kernel environment.
13 * MACOS implementation.
20 #include <kern/thread.h>
23 #define RX_ENABLE_LOCKS 1
24 #define AFS_GLOBAL_RXLOCK_KERNEL
29 * In Digital Unix (OSF/1), we use something akin to the ancient sleep/wakeup
30 * mechanism. The condition variable itself plays no role; we just use its
31 * address as a convenient unique number.
33 * XXX in darwin, both mach and bsd facilities are available. Should really
34 * stick to one or the other (but mach locks don't have a _try.....)
36 #define CV_INIT(cv,a,b,c)
37 #define CV_DESTROY(cv)
38 #define CV_WAIT(cv, lck) { \
39 int isGlockOwner = ISAFS_GLOCK(); \
40 if (isGlockOwner) AFS_GUNLOCK(); \
41 assert_wait((event_t)(cv), 0); \
44 if (isGlockOwner) AFS_GLOCK(); \
48 #define CV_TIMEDWAIT(cv,lck,t) { \
49 int isGlockOwner = ISAFS_GLOCK(); \
50 if (isGlockOwner) AFS_GUNLOCK(); \
51 assert_wait((event_t)(cv), 0); \
52 thread_set_timer(t, NSEC_PER_SEC/hz); \
55 if (isGlockOwner) AFS_GLOCK(); \
59 #define CV_SIGNAL(cv) thread_wakeup_one((event_t)(cv))
60 #define CV_BROADCAST(cv) thread_wakeup((event_t)(cv))
63 struct lock__bsd__ lock;
66 typedef int afs_kcondvar_t;
68 #define osi_rxWakeup(cv) thread_wakeup((event_t)(cv))
70 #define LOCK_INIT(a,b) \
72 lockinit(&(a)->lock,PSOCK, "afs rx lock", 0, 0); \
73 (a)->owner = (thread_t)0; \
75 #define MUTEX_INIT(a,b,c,d) \
77 lockinit(&(a)->lock,PSOCK, "afs rx mutex", 0, 0); \
78 (a)->owner = (thread_t)0; \
80 #define MUTEX_DESTROY(a) \
82 (a)->owner = (thread_t)-1; \
84 #define MUTEX_ENTER(a) \
86 lockmgr(&(a)->lock, LK_EXCLUSIVE, 0, current_proc()); \
87 osi_Assert((a)->owner == (thread_t)0); \
88 (a)->owner = current_thread(); \
90 #define MUTEX_TRYENTER(a) \
91 ( lockmgr(&(a)->lock, LK_EXCLUSIVE|LK_NOWAIT, 0, current_proc()) ? 0 : ((a)->owner = current_thread(), 1) )
92 #define xMUTEX_TRYENTER(a) \
93 ( osi_Assert((a)->owner == (thread_t)0), (a)->owner = current_thread(), 1)
94 #define MUTEX_EXIT(a) \
96 osi_Assert((a)->owner == current_thread()); \
97 (a)->owner = (thread_t)0; \
98 lockmgr(&(a)->lock, LK_RELEASE, 0, current_proc()); \
102 #define MUTEX_ISMINE(a) (((afs_kmutex_t *)(a))->owner == current_thread())
104 #undef osirx_AssertMine
105 extern void osirx_AssertMine(afs_kmutex_t * lockaddr, char *msg);
107 #endif /* _RX_KMUTEX_H_ */