Lines Matching refs:waiter
370 rwsem_add_waiter(struct rw_semaphore *sem, struct rwsem_waiter *waiter) in rwsem_add_waiter() argument
373 list_add_tail(&waiter->list, &sem->wait_list); in rwsem_add_waiter()
386 rwsem_del_waiter(struct rw_semaphore *sem, struct rwsem_waiter *waiter) in rwsem_del_waiter() argument
389 list_del(&waiter->list); in rwsem_del_waiter()
415 struct rwsem_waiter *waiter, *tmp; in rwsem_mark_wake() local
425 waiter = rwsem_first_waiter(sem); in rwsem_mark_wake()
427 if (waiter->type == RWSEM_WAITING_FOR_WRITE) { in rwsem_mark_wake()
436 wake_q_add(wake_q, waiter->task); in rwsem_mark_wake()
465 if (time_after(jiffies, waiter->timeout)) { in rwsem_mark_wake()
470 waiter->handoff_set = true; in rwsem_mark_wake()
482 owner = waiter->task; in rwsem_mark_wake()
510 list_for_each_entry_safe(waiter, tmp, &sem->wait_list, list) { in rwsem_mark_wake()
511 if (waiter->type == RWSEM_WAITING_FOR_WRITE) in rwsem_mark_wake()
515 list_move_tail(&waiter->list, &wlist); in rwsem_mark_wake()
549 list_for_each_entry_safe(waiter, tmp, &wlist, list) { in rwsem_mark_wake()
552 tsk = waiter->task; in rwsem_mark_wake()
561 smp_store_release(&waiter->task, NULL); in rwsem_mark_wake()
577 rwsem_del_wake_waiter(struct rw_semaphore *sem, struct rwsem_waiter *waiter, in rwsem_del_wake_waiter() argument
581 bool first = rwsem_first_waiter(sem) == waiter; in rwsem_del_wake_waiter()
590 if (rwsem_del_waiter(sem, waiter) && first) in rwsem_del_wake_waiter()
605 struct rwsem_waiter *waiter) in rwsem_try_write_lock() argument
622 if (first->handoff_set && (waiter != first)) in rwsem_try_write_lock()
634 if (has_handoff || (!rt_task(waiter->task) && in rwsem_try_write_lock()
635 !time_after(jiffies, waiter->timeout))) in rwsem_try_write_lock()
663 list_del(&waiter->list); in rwsem_try_write_lock()
1000 struct rwsem_waiter waiter; in rwsem_down_read_slowpath() local
1035 waiter.task = current; in rwsem_down_read_slowpath()
1036 waiter.type = RWSEM_WAITING_FOR_READ; in rwsem_down_read_slowpath()
1037 waiter.timeout = jiffies + RWSEM_WAIT_TIMEOUT; in rwsem_down_read_slowpath()
1038 waiter.handoff_set = false; in rwsem_down_read_slowpath()
1058 rwsem_add_waiter(sem, &waiter); in rwsem_down_read_slowpath()
1074 if (!smp_load_acquire(&waiter.task)) { in rwsem_down_read_slowpath()
1080 if (waiter.task) in rwsem_down_read_slowpath()
1096 rwsem_del_wake_waiter(sem, &waiter, &wake_q); in rwsem_down_read_slowpath()
1109 struct rwsem_waiter waiter; in rwsem_down_write_slowpath() local
1122 waiter.task = current; in rwsem_down_write_slowpath()
1123 waiter.type = RWSEM_WAITING_FOR_WRITE; in rwsem_down_write_slowpath()
1124 waiter.timeout = jiffies + RWSEM_WAIT_TIMEOUT; in rwsem_down_write_slowpath()
1125 waiter.handoff_set = false; in rwsem_down_write_slowpath()
1128 rwsem_add_waiter(sem, &waiter); in rwsem_down_write_slowpath()
1131 if (rwsem_first_waiter(sem) != &waiter) { in rwsem_down_write_slowpath()
1152 if (rwsem_try_write_lock(sem, &waiter)) { in rwsem_down_write_slowpath()
1170 if (waiter.handoff_set) { in rwsem_down_write_slowpath()
1193 rwsem_del_wake_waiter(sem, &waiter, &wake_q); in rwsem_down_write_slowpath()