github/open-cas-linux
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

env: simplify env_rwsem

Browse Source 
Signed-off-by: Michal Mielewczyk <michal.mielewczyk@intel.com>
This commit is contained in:
Michal Mielewczyk 2021-08-17 15:00:47 +02:00
parent a5bcb0796e
commit 39bab9ad87
1 changed files with 9 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
modules/cas_cache/ocf_env.h
View File

@ -220,66 +220,47 @@ static inline void env_rmutex_destroy(env_rmutex *rmutex)
/* *** RW SEMAPHORE *** */ /* *** RW SEMAPHORE *** */
typedef struct typedef struct rw_semaphore env_rwsem;
{
struct rw_semaphore sem;
wait_queue_head_t wq;
} env_rwsem;
static inline int env_rwsem_init(env_rwsem *s) static inline int env_rwsem_init(env_rwsem *s)
{ {
init_rwsem(&s->sem); init_rwsem(s);
init_waitqueue_head(&s->wq);
return 0; return 0;
} }
static inline void env_rwsem_up_read(env_rwsem *s) static inline void env_rwsem_up_read(env_rwsem *s)
{ {
up_read(&s->sem); up_read(s);
wake_up_all(&s->wq);
} }
static inline void env_rwsem_down_read(env_rwsem *s) static inline void env_rwsem_down_read(env_rwsem *s)
{ {
down_read(&s->sem); down_read(s);
}
static inline int env_rwsem_down_read_interruptible(env_rwsem *s)
{
return wait_event_interruptible(s->wq,
down_read_trylock(&s->sem)) ? -OCF_ERR_INTR : 0;
} }
static inline int env_rwsem_down_read_trylock(env_rwsem *s) static inline int env_rwsem_down_read_trylock(env_rwsem *s)
{ {
return down_read_trylock(&s->sem) ? 0 : -OCF_ERR_NO_LOCK; return down_read_trylock(s) ? 0 : -OCF_ERR_NO_LOCK;
} }
static inline void env_rwsem_up_write(env_rwsem *s) static inline void env_rwsem_up_write(env_rwsem *s)
{ {
up_write(&s->sem); up_write(s);
wake_up_all(&s->wq);
} }
static inline void env_rwsem_down_write(env_rwsem *s) static inline void env_rwsem_down_write(env_rwsem *s)
{ {
down_write(&s->sem); down_write(s);
}
static inline int env_rwsem_down_write_interruptible(env_rwsem *s)
{
return wait_event_interruptible(s->wq,
down_write_trylock(&s->sem)) ? -OCF_ERR_INTR : 0;
} }
static inline int env_rwsem_down_write_trylock(env_rwsem *s) static inline int env_rwsem_down_write_trylock(env_rwsem *s)
{ {
return down_write_trylock(&s->sem) ? 0 : -OCF_ERR_NO_LOCK; return down_write_trylock(s) ? 0 : -OCF_ERR_NO_LOCK;
} }
static inline int env_rwsem_is_locked(env_rwsem *s) static inline int env_rwsem_is_locked(env_rwsem *s)
{ {
return rwsem_is_locked(&s->sem); return rwsem_is_locked(s);
} }
static inline int env_rwsem_destroy(env_rwsem *s) static inline int env_rwsem_destroy(env_rwsem *s)