Lines Matching refs:rwb

53 static __always_inline int rwbase_read_trylock(struct rwbase_rt *rwb)  in rwbase_read_trylock()  argument
61 for (r = atomic_read(&rwb->readers); r < 0;) { in rwbase_read_trylock()
63 if (likely(atomic_try_cmpxchg(&rwb->readers, &r, r + 1))) in rwbase_read_trylock()
69 static int __sched __rwbase_read_lock(struct rwbase_rt *rwb, in __rwbase_read_lock() argument
72 struct rt_mutex_base *rtm = &rwb->rtmutex; in __rwbase_read_lock()
80 if (atomic_read(&rwb->readers) != WRITER_BIAS) { in __rwbase_read_lock()
81 atomic_inc(&rwb->readers); in __rwbase_read_lock()
130 atomic_inc(&rwb->readers); in __rwbase_read_lock()
137 static __always_inline int rwbase_read_lock(struct rwbase_rt *rwb, in rwbase_read_lock() argument
140 if (rwbase_read_trylock(rwb)) in rwbase_read_lock()
143 return __rwbase_read_lock(rwb, state); in rwbase_read_lock()
146 static void __sched __rwbase_read_unlock(struct rwbase_rt *rwb, in __rwbase_read_unlock() argument
149 struct rt_mutex_base *rtm = &rwb->rtmutex; in __rwbase_read_unlock()
166 static __always_inline void rwbase_read_unlock(struct rwbase_rt *rwb, in rwbase_read_unlock() argument
175 if (unlikely(atomic_dec_and_test(&rwb->readers))) in rwbase_read_unlock()
176 __rwbase_read_unlock(rwb, state); in rwbase_read_unlock()
179 static inline void __rwbase_write_unlock(struct rwbase_rt *rwb, int bias, in __rwbase_write_unlock() argument
182 struct rt_mutex_base *rtm = &rwb->rtmutex; in __rwbase_write_unlock()
188 (void)atomic_add_return_release(READER_BIAS - bias, &rwb->readers); in __rwbase_write_unlock()
193 static inline void rwbase_write_unlock(struct rwbase_rt *rwb) in rwbase_write_unlock() argument
195 struct rt_mutex_base *rtm = &rwb->rtmutex; in rwbase_write_unlock()
199 __rwbase_write_unlock(rwb, WRITER_BIAS, flags); in rwbase_write_unlock()
202 static inline void rwbase_write_downgrade(struct rwbase_rt *rwb) in rwbase_write_downgrade() argument
204 struct rt_mutex_base *rtm = &rwb->rtmutex; in rwbase_write_downgrade()
209 __rwbase_write_unlock(rwb, WRITER_BIAS - 1, flags); in rwbase_write_downgrade()
212 static inline bool __rwbase_write_trylock(struct rwbase_rt *rwb) in __rwbase_write_trylock() argument
215 lockdep_assert_held(&rwb->rtmutex.wait_lock); in __rwbase_write_trylock()
221 if (!atomic_read_acquire(&rwb->readers)) { in __rwbase_write_trylock()
222 atomic_set(&rwb->readers, WRITER_BIAS); in __rwbase_write_trylock()
229 static int __sched rwbase_write_lock(struct rwbase_rt *rwb, in rwbase_write_lock() argument
232 struct rt_mutex_base *rtm = &rwb->rtmutex; in rwbase_write_lock()
240 atomic_sub(READER_BIAS, &rwb->readers); in rwbase_write_lock()
243 if (__rwbase_write_trylock(rwb)) in rwbase_write_lock()
251 __rwbase_write_unlock(rwb, 0, flags); in rwbase_write_lock()
255 if (__rwbase_write_trylock(rwb)) in rwbase_write_lock()
271 static inline int rwbase_write_trylock(struct rwbase_rt *rwb) in rwbase_write_trylock() argument
273 struct rt_mutex_base *rtm = &rwb->rtmutex; in rwbase_write_trylock()
279 atomic_sub(READER_BIAS, &rwb->readers); in rwbase_write_trylock()
282 if (__rwbase_write_trylock(rwb)) { in rwbase_write_trylock()
286 __rwbase_write_unlock(rwb, 0, flags); in rwbase_write_trylock()