michaelh/zephyr
1
0
Fork 0
Code Releases Activity

posix: rwlock: Refactor locking using k_timepoint_t

Browse source 
Make use of k_timepoint_t ind the calculation of the remaining time for the
rwlock.

Signed-off-by: Cla Mattia Galliard <clamattia@gmail.com>
This commit is contained in:
Cla Mattia Galliard 2025-03-21 18:08:34 +01:00 • committed by Benjamin Cabé
commit 833eaccfd1
1 changed files with 4 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

18
lib/posix/options/rwlock.c
View file

@ -359,24 +359,14 @@ static uint32_t read_lock_acquire(struct posix_rwlock *rwl, uint32_t timeout)
static uint32_t write_lock_acquire(struct posix_rwlock *rwl, uint32_t timeout) static uint32_t write_lock_acquire(struct posix_rwlock *rwl, uint32_t timeout)
{ {
uint32_t ret = 0U; uint32_t ret = 0U;
int64_t elapsed_time, st_time = k_uptime_get(); k_timepoint_t deadline;
k_timeout_t k_timeout;
k_timeout = SYS_TIMEOUT_MS(timeout); deadline = sys_timepoint_calc(SYS_TIMEOUT_MS(timeout));
/* waiting for release of write lock */ /* waiting for release of write lock */
if (sys_sem_take(&rwl->wr_sem, k_timeout) == 0) { if (sys_sem_take(&rwl->wr_sem, sys_timepoint_timeout(deadline)) == 0) {
/* update remaining timeout time for 2nd sem */
if (timeout != SYS_FOREVER_MS) {
elapsed_time = k_uptime_get() - st_time;
timeout = timeout <= elapsed_time ? 0 :
timeout - elapsed_time;
}
k_timeout = SYS_TIMEOUT_MS(timeout);
/* waiting for reader to complete operation */ /* waiting for reader to complete operation */
if (sys_sem_take(&rwl->reader_active, k_timeout) == 0) { if (sys_sem_take(&rwl->reader_active, sys_timepoint_timeout(deadline)) == 0) {
rwl->wr_owner = k_current_get(); rwl->wr_owner = k_current_get();
} else { } else {
(void)sys_sem_give(&rwl->wr_sem); (void)sys_sem_give(&rwl->wr_sem);