Lines Matching refs:waiter

271 rt_mutex_enqueue(struct rt_mutex *lock, struct rt_mutex_waiter *waiter)  in rt_mutex_enqueue()  argument
281 if (rt_mutex_waiter_less(waiter, entry)) { in rt_mutex_enqueue()
289 rb_link_node(&waiter->tree_entry, parent, link); in rt_mutex_enqueue()
290 rb_insert_color_cached(&waiter->tree_entry, &lock->waiters, leftmost); in rt_mutex_enqueue()
294 rt_mutex_dequeue(struct rt_mutex *lock, struct rt_mutex_waiter *waiter) in rt_mutex_dequeue() argument
296 if (RB_EMPTY_NODE(&waiter->tree_entry)) in rt_mutex_dequeue()
299 rb_erase_cached(&waiter->tree_entry, &lock->waiters); in rt_mutex_dequeue()
300 RB_CLEAR_NODE(&waiter->tree_entry); in rt_mutex_dequeue()
304 rt_mutex_enqueue_pi(struct task_struct *task, struct rt_mutex_waiter *waiter) in rt_mutex_enqueue_pi() argument
314 if (rt_mutex_waiter_less(waiter, entry)) { in rt_mutex_enqueue_pi()
322 rb_link_node(&waiter->pi_tree_entry, parent, link); in rt_mutex_enqueue_pi()
323 rb_insert_color_cached(&waiter->pi_tree_entry, &task->pi_waiters, leftmost); in rt_mutex_enqueue_pi()
327 rt_mutex_dequeue_pi(struct task_struct *task, struct rt_mutex_waiter *waiter) in rt_mutex_dequeue_pi() argument
329 if (RB_EMPTY_NODE(&waiter->pi_tree_entry)) in rt_mutex_dequeue_pi()
332 rb_erase_cached(&waiter->pi_tree_entry, &task->pi_waiters); in rt_mutex_dequeue_pi()
333 RB_CLEAR_NODE(&waiter->pi_tree_entry); in rt_mutex_dequeue_pi()
361 static bool rt_mutex_cond_detect_deadlock(struct rt_mutex_waiter *waiter, in rt_mutex_cond_detect_deadlock() argument
371 return debug_rt_mutex_detect_deadlock(waiter, chwalk); in rt_mutex_cond_detect_deadlock()
454 struct rt_mutex_waiter *waiter, *top_waiter = orig_waiter; in rt_mutex_adjust_prio_chain() local
506 waiter = task->pi_blocked_on; in rt_mutex_adjust_prio_chain()
517 if (!waiter) in rt_mutex_adjust_prio_chain()
536 if (next_lock != waiter->lock) in rt_mutex_adjust_prio_chain()
568 if (rt_mutex_waiter_equal(waiter, task_to_waiter(task))) { in rt_mutex_adjust_prio_chain()
578 lock = waiter->lock; in rt_mutex_adjust_prio_chain()
662 rt_mutex_dequeue(lock, waiter); in rt_mutex_adjust_prio_chain()
680 waiter->prio = task->prio; in rt_mutex_adjust_prio_chain()
681 waiter->deadline = task->dl.deadline; in rt_mutex_adjust_prio_chain()
683 rt_mutex_enqueue(lock, waiter); in rt_mutex_adjust_prio_chain()
713 if (waiter == rt_mutex_top_waiter(lock)) { in rt_mutex_adjust_prio_chain()
721 rt_mutex_enqueue_pi(task, waiter); in rt_mutex_adjust_prio_chain()
724 } else if (prerequeue_top_waiter == waiter) { in rt_mutex_adjust_prio_chain()
735 rt_mutex_dequeue_pi(task, waiter); in rt_mutex_adjust_prio_chain()
736 waiter = rt_mutex_top_waiter(lock); in rt_mutex_adjust_prio_chain()
737 rt_mutex_enqueue_pi(task, waiter); in rt_mutex_adjust_prio_chain()
782 if (!detect_deadlock && waiter != top_waiter) in rt_mutex_adjust_prio_chain()
806 struct rt_mutex_waiter *waiter) in try_to_take_rt_mutex() argument
840 if (waiter) { in try_to_take_rt_mutex()
845 if (waiter != rt_mutex_top_waiter(lock)) in try_to_take_rt_mutex()
852 rt_mutex_dequeue(lock, waiter); in try_to_take_rt_mutex()
927 struct rt_mutex_waiter *waiter, in task_blocks_on_rt_mutex() argument
932 struct rt_mutex_waiter *top_waiter = waiter; in task_blocks_on_rt_mutex()
951 waiter->task = task; in task_blocks_on_rt_mutex()
952 waiter->lock = lock; in task_blocks_on_rt_mutex()
953 waiter->prio = task->prio; in task_blocks_on_rt_mutex()
954 waiter->deadline = task->dl.deadline; in task_blocks_on_rt_mutex()
959 rt_mutex_enqueue(lock, waiter); in task_blocks_on_rt_mutex()
961 task->pi_blocked_on = waiter; in task_blocks_on_rt_mutex()
969 if (waiter == rt_mutex_top_waiter(lock)) { in task_blocks_on_rt_mutex()
971 rt_mutex_enqueue_pi(owner, waiter); in task_blocks_on_rt_mutex()
976 } else if (rt_mutex_cond_detect_deadlock(waiter, chwalk)) { in task_blocks_on_rt_mutex()
1002 next_lock, waiter, task); in task_blocks_on_rt_mutex()
1018 struct rt_mutex_waiter *waiter; in mark_wakeup_next_waiter() local
1022 waiter = rt_mutex_top_waiter(lock); in mark_wakeup_next_waiter()
1031 rt_mutex_dequeue_pi(current, waiter); in mark_wakeup_next_waiter()
1055 wake_q_add(wake_q, waiter->task); in mark_wakeup_next_waiter()
1066 struct rt_mutex_waiter *waiter) in remove_waiter() argument
1068 bool is_top_waiter = (waiter == rt_mutex_top_waiter(lock)); in remove_waiter()
1075 rt_mutex_dequeue(lock, waiter); in remove_waiter()
1088 rt_mutex_dequeue_pi(owner, waiter); in remove_waiter()
1125 struct rt_mutex_waiter *waiter; in rt_mutex_adjust_pi() local
1131 waiter = task->pi_blocked_on; in rt_mutex_adjust_pi()
1132 if (!waiter || rt_mutex_waiter_equal(waiter, task_to_waiter(task))) { in rt_mutex_adjust_pi()
1136 next_lock = waiter->lock; in rt_mutex_adjust_pi()
1146 void rt_mutex_init_waiter(struct rt_mutex_waiter *waiter) in rt_mutex_init_waiter() argument
1148 debug_rt_mutex_init_waiter(waiter); in rt_mutex_init_waiter()
1149 RB_CLEAR_NODE(&waiter->pi_tree_entry); in rt_mutex_init_waiter()
1150 RB_CLEAR_NODE(&waiter->tree_entry); in rt_mutex_init_waiter()
1151 waiter->task = NULL; in rt_mutex_init_waiter()
1167 struct rt_mutex_waiter *waiter) in __rt_mutex_slowlock() argument
1173 if (try_to_take_rt_mutex(lock, current, waiter)) in __rt_mutex_slowlock()
1192 debug_rt_mutex_print_deadlock(waiter); in __rt_mutex_slowlock()
1232 struct rt_mutex_waiter waiter; in rt_mutex_slowlock() local
1236 rt_mutex_init_waiter(&waiter); in rt_mutex_slowlock()
1260 ret = task_blocks_on_rt_mutex(lock, &waiter, current, chwalk); in rt_mutex_slowlock()
1264 ret = __rt_mutex_slowlock(lock, state, timeout, &waiter); in rt_mutex_slowlock()
1268 remove_waiter(lock, &waiter); in rt_mutex_slowlock()
1269 rt_mutex_handle_deadlock(ret, chwalk, &waiter); in rt_mutex_slowlock()
1284 debug_rt_mutex_free_waiter(&waiter); in rt_mutex_slowlock()
1746 struct rt_mutex_waiter *waiter, in __rt_mutex_start_proxy_lock() argument
1757 ret = task_blocks_on_rt_mutex(lock, waiter, task, in __rt_mutex_start_proxy_lock()
1770 debug_rt_mutex_print_deadlock(waiter); in __rt_mutex_start_proxy_lock()
1795 struct rt_mutex_waiter *waiter, in rt_mutex_start_proxy_lock() argument
1801 ret = __rt_mutex_start_proxy_lock(lock, waiter, task); in rt_mutex_start_proxy_lock()
1803 remove_waiter(lock, waiter); in rt_mutex_start_proxy_lock()
1848 struct rt_mutex_waiter *waiter) in rt_mutex_wait_proxy_lock() argument
1855 ret = __rt_mutex_slowlock(lock, TASK_INTERRUPTIBLE, to, waiter); in rt_mutex_wait_proxy_lock()
1887 struct rt_mutex_waiter *waiter) in rt_mutex_cleanup_proxy_lock() argument
1903 try_to_take_rt_mutex(lock, current, waiter); in rt_mutex_cleanup_proxy_lock()
1909 remove_waiter(lock, waiter); in rt_mutex_cleanup_proxy_lock()