diff options
Diffstat (limited to 'lib/libthr/thread/thr_umtx.h')
-rw-r--r-- | lib/libthr/thread/thr_umtx.h | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/lib/libthr/thread/thr_umtx.h b/lib/libthr/thread/thr_umtx.h index 1fbf534..5b62e88 100644 --- a/lib/libthr/thread/thr_umtx.h +++ b/lib/libthr/thread/thr_umtx.h @@ -33,11 +33,21 @@ typedef long umtx_t; +/* simple lock routines.*/ int __thr_umtx_lock(volatile umtx_t *mtx, long id) __hidden; int __thr_umtx_timedlock(volatile umtx_t *mtx, long id, const struct timespec *timeout) __hidden; int __thr_umtx_unlock(volatile umtx_t *mtx, long id) __hidden; +/* POSIX semantic lock routines */ +int __thr_umutex_lock(struct umutex *mtx, uint32_t id) __hidden; +int __thr_umutex_timedlock(struct umutex *mtx, uint32_t id, + const struct timespec *timeout) __hidden; +int __thr_umutex_unlock(struct umutex *mtx, uint32_t id) __hidden; +int __thr_umutex_kern_trylock(struct umutex *mtx) __hidden; +int __thr_umutex_set_ceiling(struct umutex *mtx, uint32_t ceiling, + uint32_t *oldceiling) __hidden; + static inline void _thr_umtx_init(volatile umtx_t *mtx) { @@ -84,4 +94,40 @@ _thr_umtx_unlock(volatile umtx_t *mtx, long id) int _thr_umtx_wait(volatile umtx_t *mtx, umtx_t exp, const struct timespec *timeout) __hidden; int _thr_umtx_wake(volatile umtx_t *mtx, int count) __hidden; + +static inline int +_thr_umutex_trylock(struct umutex *mtx, uint32_t id) +{ + if (atomic_cmpset_acq_32(&mtx->m_owner, UMUTEX_UNOWNED, id)) + return (0); + if ((mtx->m_flags & UMUTEX_PRIO_PROTECT) == 0) + return (EBUSY); + return (__thr_umutex_kern_trylock(mtx)); +} + +static inline int +_thr_umutex_lock(struct umutex *mtx, uint32_t id) +{ + if (atomic_cmpset_acq_32(&mtx->m_owner, UMUTEX_UNOWNED, id)) + return (0); + return (__thr_umutex_lock(mtx, id)); +} + +static inline int +_thr_umutex_timedlock(struct umutex *mtx, uint32_t id, + const struct timespec *timeout) +{ + if (atomic_cmpset_acq_32(&mtx->m_owner, UMUTEX_UNOWNED, id)) + return (0); + return (__thr_umutex_timedlock(mtx, id, timeout)); +} + +static inline int +_thr_umutex_unlock(struct umutex *mtx, uint32_t id) +{ + if (atomic_cmpset_rel_32(&mtx->m_owner, id, UMUTEX_UNOWNED)) + return (0); + return (__thr_umutex_unlock(mtx, id)); +} + #endif |