Home
last modified time | relevance | path

Searched refs:waiter (Results 1 – 25 of 57) sorted by relevance

123

/linux/drivers/gpu/host1x/
A Dintr.c41 u32 thresh = waiter->thresh; in add_waiter_to_queue()
82 list_del(&waiter->list); in remove_completed_waiters()
108 waiter->count, waiter->thresh); in action_submit_complete()
151 list_del(&waiter->list); in run_handlers()
152 handler(waiter); in run_handlers()
218 if (waiter == NULL) { in host1x_intr_add_action()
228 waiter->thresh = thresh; in host1x_intr_add_action()
229 waiter->action = action; in host1x_intr_add_action()
231 waiter->data = data; in host1x_intr_add_action()
232 waiter->count = 1; in host1x_intr_add_action()
[all …]
A Dfence.c28 struct host1x_waitlist *waiter; member
73 sf->waiter, &sf->waiter_ref); in host1x_syncpt_fence_enable_signaling()
81 sf->waiter = NULL; in host1x_syncpt_fence_enable_signaling()
96 if (sf->waiter) in host1x_syncpt_fence_release()
97 kfree(sf->waiter); in host1x_syncpt_fence_release()
154 fence->waiter = kzalloc(sizeof(*fence->waiter), GFP_KERNEL); in host1x_fence_create()
155 if (!fence->waiter) { in host1x_fence_create()
/linux/kernel/locking/
A Drtmutex.c357 if (rt_prio(waiter->prio) || dl_prio(waiter->prio)) in rt_mutex_steal()
502 return waiter != NULL; in rt_mutex_cond_detect_deadlock()
644 if (!waiter) in rt_mutex_adjust_prio_chain()
730 lock = waiter->lock; in rt_mutex_adjust_prio_chain()
866 wake_up_state(waiter->task, waiter->wake_state); in rt_mutex_adjust_prio_chain()
1004 if (waiter) { in try_to_take_rt_mutex()
1011 if (waiter == top_waiter || rt_mutex_steal(waiter, top_waiter)) { in try_to_take_rt_mutex()
1111 waiter->task = task; in task_blocks_on_rt_mutex()
1112 waiter->lock = lock; in task_blocks_on_rt_mutex()
1613 waiter.ww_ctx = ww_ctx; in __rt_mutex_slowlock_locked()
[all …]
A Dmutex-debug.c30 memset(waiter, MUTEX_DEBUG_INIT, sizeof(*waiter)); in debug_mutex_lock_common()
31 waiter->magic = waiter; in debug_mutex_lock_common()
32 INIT_LIST_HEAD(&waiter->list); in debug_mutex_lock_common()
33 waiter->ww_ctx = MUTEX_POISON_WW_CTX; in debug_mutex_lock_common()
40 DEBUG_LOCKS_WARN_ON(waiter->magic != waiter); in debug_mutex_wake_waiter()
41 DEBUG_LOCKS_WARN_ON(list_empty(&waiter->list)); in debug_mutex_wake_waiter()
47 memset(waiter, MUTEX_DEBUG_FREE, sizeof(*waiter)); in debug_mutex_free_waiter()
56 task->blocked_on = waiter; in debug_mutex_add_waiter()
63 DEBUG_LOCKS_WARN_ON(waiter->task != task); in debug_mutex_remove_waiter()
67 INIT_LIST_HEAD(&waiter->list); in debug_mutex_remove_waiter()
[all …]
A Drtmutex_common.h68 struct rt_mutex_waiter *waiter,
71 struct rt_mutex_waiter *waiter,
77 struct rt_mutex_waiter *waiter);
104 struct rt_mutex_waiter *waiter) in rt_mutex_waiter_is_top_waiter() argument
181 memset(waiter, 0x11, sizeof(*waiter)); in debug_rt_mutex_init_waiter()
187 memset(waiter, 0x22, sizeof(*waiter)); in debug_rt_mutex_free_waiter()
192 debug_rt_mutex_init_waiter(waiter); in rt_mutex_init_waiter()
194 RB_CLEAR_NODE(&waiter->tree_entry); in rt_mutex_init_waiter()
195 waiter->wake_state = TASK_NORMAL; in rt_mutex_init_waiter()
196 waiter->task = NULL; in rt_mutex_init_waiter()
[all …]
A Dmutex.c215 list_del(&waiter->list); in __mutex_remove_waiter()
302 struct mutex_waiter *waiter) in ww_mutex_spin_on_owner() argument
336 if (waiter && !__mutex_waiter_is_first(lock, waiter)) in ww_mutex_spin_on_owner()
448 if (!waiter) { in mutex_optimistic_spin()
492 if (!waiter) in mutex_optimistic_spin()
499 if (!waiter) in mutex_optimistic_spin()
577 struct mutex_waiter waiter; in __mutex_lock_common() local
631 waiter.task = current; in __mutex_lock_common()
633 waiter.ww_ctx = ww_ctx; in __mutex_lock_common()
929 struct mutex_waiter *waiter = in __mutex_unlock_slowpath() local
[all …]
A Dmutex.h25 struct mutex_waiter *waiter);
27 struct mutex_waiter *waiter);
28 extern void debug_mutex_free_waiter(struct mutex_waiter *waiter);
30 struct mutex_waiter *waiter,
32 extern void debug_mutex_remove_waiter(struct mutex *lock, struct mutex_waiter *waiter,
38 # define debug_mutex_lock_common(lock, waiter) do { } while (0) argument
39 # define debug_mutex_wake_waiter(lock, waiter) do { } while (0) argument
40 # define debug_mutex_free_waiter(waiter) do { } while (0) argument
41 # define debug_mutex_add_waiter(lock, waiter, ti) do { } while (0) argument
42 # define debug_mutex_remove_waiter(lock, waiter, ti) do { } while (0) argument
A Drwsem.c383 list_del(&waiter->list); in rwsem_del_waiter()
473 owner = waiter->task; in rwsem_mark_wake()
543 tsk = waiter->task; in rwsem_mark_wake()
619 list_del(&waiter->list); in rwsem_try_write_lock()
945 struct rwsem_waiter waiter; in rwsem_down_read_slowpath() local
981 waiter.task = current; in rwsem_down_read_slowpath()
1035 if (waiter.task) in rwsem_down_read_slowpath()
1064 struct rwsem_waiter waiter; in rwsem_down_write_slowpath() local
1077 waiter.task = current; in rwsem_down_write_slowpath()
1080 waiter.handoff_set = false; in rwsem_down_write_slowpath()
[all …]
A Dsemaphore.c211 struct semaphore_waiter waiter; in __down_common() local
213 list_add_tail(&waiter.list, &sem->wait_list); in __down_common()
214 waiter.task = current; in __down_common()
215 waiter.up = false; in __down_common()
226 if (waiter.up) in __down_common()
231 list_del(&waiter.list); in __down_common()
235 list_del(&waiter.list); in __down_common()
261 struct semaphore_waiter *waiter = list_first_entry(&sem->wait_list, in __up() local
263 list_del(&waiter->list); in __up()
264 waiter->up = true; in __up()
[all …]
A Drtmutex_api.c271 struct rt_mutex_waiter *waiter, in __rt_mutex_start_proxy_lock() argument
318 struct rt_mutex_waiter *waiter, in rt_mutex_start_proxy_lock() argument
326 remove_waiter(lock, waiter); in rt_mutex_start_proxy_lock()
351 struct rt_mutex_waiter *waiter) in rt_mutex_wait_proxy_lock() argument
390 struct rt_mutex_waiter *waiter) in rt_mutex_cleanup_proxy_lock() argument
406 try_to_take_rt_mutex(lock, current, waiter); in rt_mutex_cleanup_proxy_lock()
412 remove_waiter(lock, waiter); in rt_mutex_cleanup_proxy_lock()
433 struct rt_mutex_waiter *waiter; in rt_mutex_adjust_pi() local
439 waiter = task->pi_blocked_on; in rt_mutex_adjust_pi()
440 if (!waiter || rt_mutex_waiter_equal(waiter, task_to_waiter(task))) { in rt_mutex_adjust_pi()
[all …]
A Dww_mutex.h53 __ww_waiter_add(struct mutex *lock, struct mutex_waiter *waiter, struct mutex_waiter *pos) in __ww_waiter_add() argument
58 __mutex_add_waiter(lock, waiter, p); in __ww_waiter_add()
277 __ww_mutex_die(struct MUTEX *lock, struct MUTEX_WAITER *waiter, in __ww_mutex_die() argument
283 if (waiter->ww_ctx->acquired > 0 && __ww_ctx_less(waiter->ww_ctx, ww_ctx)) { in __ww_mutex_die()
285 debug_mutex_wake_waiter(lock, waiter); in __ww_mutex_die()
287 wake_up_process(waiter->task); in __ww_mutex_die()
441 __ww_mutex_check_kill(struct MUTEX *lock, struct MUTEX_WAITER *waiter, in __ww_mutex_check_kill() argument
465 for (cur = __ww_waiter_prev(lock, waiter); cur; in __ww_mutex_check_kill()
489 __ww_mutex_add_waiter(struct MUTEX_WAITER *waiter, in __ww_mutex_add_waiter() argument
497 __ww_waiter_add(lock, waiter, NULL); in __ww_mutex_add_waiter()
[all …]
/linux/drivers/tty/
A Dtty_ldsem.c95 tsk = waiter->task; in __ldsem_wake_readers()
121 struct ldsem_waiter *waiter; in __ldsem_wake_writer() local
124 wake_up_process(waiter->task); in __ldsem_wake_writer()
158 struct ldsem_waiter waiter; in down_read_failed() local
183 waiter.task = current; in down_read_failed()
212 if (waiter.task) { in down_read_failed()
215 list_del(&waiter.list); in down_read_failed()
217 put_task_struct(waiter.task); in down_read_failed()
232 struct ldsem_waiter waiter; in down_write_failed() local
255 waiter.task = current; in down_write_failed()
[all …]
/linux/lib/
A Dklist.c185 struct klist_waiter *waiter, *tmp; in klist_release() local
192 if (waiter->node != n) in klist_release()
195 list_del(&waiter->list); in klist_release()
196 waiter->woken = 1; in klist_release()
198 wake_up_process(waiter->process); in klist_release()
240 struct klist_waiter waiter; in klist_remove() local
242 waiter.node = n; in klist_remove()
243 waiter.process = current; in klist_remove()
244 waiter.woken = 0; in klist_remove()
246 list_add(&waiter.list, &klist_remove_waiters); in klist_remove()
[all …]
/linux/tools/testing/selftests/filesystems/epoll/
A Depoll_wakeup_test.c23 pthread_t waiter; member
47 pthread_kill(ctx->waiter, SIGUSR1); in kill_timeout()
495 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
538 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
585 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
634 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
679 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
722 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
769 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
818 ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0); in TEST()
[all …]
/linux/drivers/gpu/drm/amd/amdkfd/
A Dkfd_events.c240 struct kfd_event_waiter *waiter; in destroy_event() local
244 waiter->event = NULL; in destroy_event()
390 struct kfd_event_waiter *waiter; in set_event() local
400 waiter->activated = true; in set_event()
544 struct kfd_event_waiter *waiter, in init_event_waiter_get_status() argument
552 waiter->event = ev; in init_event_waiter_get_status()
553 waiter->activated = ev->signaled; in init_event_waiter_get_status()
566 if (!waiter->activated) in init_event_waiter_add_to_waitlist()
612 struct kfd_event_waiter *waiter; in copy_signaled_event_data() local
617 waiter = &event_waiters[i]; in copy_signaled_event_data()
[all …]
/linux/Documentation/locking/
A Dfutex-requeue-pi.rst20 implementation would wake the highest-priority waiter, and leave the
92 The requeue code cannot simply wake the waiter and leave it to
94 requeue call returning to user space and the waiter waking and
100 of the waiter and to enqueue the waiter on a contended rt_mutex.
104 FUTEX_WAIT_REQUEUE_PI is called by the waiter (pthread_cond_wait()
116 PI futex on behalf of the top waiter. If it can, this waiter is
120 task as a waiter on the underlying rt_mutex. It is possible that
122 waiter is woken to finish the acquisition of the lock.
A Drt-mutex-design.rst100 waiter
101 - A waiter is a struct that is stored on the stack of a blocked
104 the waiter on the process's stack (local variable). This
111 on a mutex. This is the same as waiter->task.
116 top waiter
119 top pi waiter
360 pi waiter to its own normal/deadline priority and take the higher one.
398 is blocked, and a top_task as the top waiter of the mutex.
433 scope of this function. The waiter structure holds the nodes to store
465 the lock's waiter tree and propagate the pi chain of the lock as well
[all …]
A Drt-mutex.rst20 priority waiter until the rt-mutex is released. If the temporarily
32 The enqueueing of the waiters into the rtmutex waiter tree is done in
34 rtmutex, only the top priority waiter is enqueued into the owner's
36 the top priority waiter of a task changes (for example it timed out or
56 NULL 1 lock is free and has waiters and the top waiter
/linux/tools/testing/selftests/futex/functional/
A Dfutex_requeue_pi_signal_restart.c122 pthread_t waiter; in main() local
158 res = create_rt_thread(&waiter, waiterfn, NULL, SCHED_FIFO, 1); in main()
177 pthread_kill(waiter, SIGUSR1); in main()
208 pthread_kill(waiter, SIGUSR1); in main()
210 pthread_join(waiter, NULL); in main()
A Dfutex_wait.c53 pthread_t waiter; in main() local
81 if (pthread_create(&waiter, NULL, waiterfn, (void *) &flags)) in main()
109 if (pthread_create(&waiter, NULL, waiterfn, NULL)) in main()
148 if (pthread_create(&waiter, NULL, waiterfn, NULL)) in main()
A Dfutex_requeue.c43 pthread_t waiter[10]; in main() local
76 if (pthread_create(&waiter[0], NULL, waiterfn, NULL)) in main()
108 if (pthread_create(&waiter[i], NULL, waiterfn, NULL)) in main()
/linux/fs/
A Dlocks.c601 hash_add(blocked_hash, &waiter->fl_link, posix_owner_key(waiter)); in locks_insert_global_blocked()
608 hash_del(&waiter->fl_link); in locks_delete_global_blocked()
625 struct file_lock *waiter; in __locks_wake_up_blocks() local
630 if (waiter->fl_lmops && waiter->fl_lmops->lm_notify) in __locks_wake_up_blocks()
631 waiter->fl_lmops->lm_notify(waiter); in __locks_wake_up_blocks()
633 wake_up(&waiter->fl_wait); in __locks_wake_up_blocks()
680 if (waiter->fl_blocker) in locks_delete_block()
683 __locks_delete_block(waiter); in locks_delete_block()
711 struct file_lock *waiter, in __locks_insert_block() argument
720 if (conflict(fl, waiter)) { in __locks_insert_block()
[all …]
/linux/drivers/staging/vc04_services/interface/vchiq_arm/
A Dvchiq_dev.c304 waiter = kzalloc(sizeof(*waiter), GFP_KERNEL); in vchiq_irq_queue_bulk_tx_rx()
305 if (!waiter) { in vchiq_irq_queue_bulk_tx_rx()
310 userdata = &waiter->bulk_waiter; in vchiq_irq_queue_bulk_tx_rx()
315 if (waiter->pid == current->pid) { in vchiq_irq_queue_bulk_tx_rx()
316 list_del(&waiter->list); in vchiq_irq_queue_bulk_tx_rx()
330 userdata = &waiter->bulk_waiter; in vchiq_irq_queue_bulk_tx_rx()
338 if (!waiter) { in vchiq_irq_queue_bulk_tx_rx()
344 !waiter->bulk_waiter.bulk) { in vchiq_irq_queue_bulk_tx_rx()
345 if (waiter->bulk_waiter.bulk) { in vchiq_irq_queue_bulk_tx_rx()
351 kfree(waiter); in vchiq_irq_queue_bulk_tx_rx()
[all …]
A Dvchiq_arm.c707 list_for_each_entry_safe(waiter, next, in free_bulk_waiter()
709 list_del(&waiter->list); in free_bulk_waiter()
711 waiter, waiter->pid); in free_bulk_waiter()
712 kfree(waiter); in free_bulk_waiter()
924 if (waiter->pid == current->pid) { in vchiq_blocking_bulk_transfer()
925 list_del(&waiter->list); in vchiq_blocking_bulk_transfer()
949 waiter = kzalloc(sizeof(*waiter), GFP_KERNEL); in vchiq_blocking_bulk_transfer()
950 if (!waiter) { in vchiq_blocking_bulk_transfer()
957 &waiter->bulk_waiter, in vchiq_blocking_bulk_transfer()
968 kfree(waiter); in vchiq_blocking_bulk_transfer()
[all …]
/linux/block/
A Dfops.c49 struct task_struct *waiter = bio->bi_private; in blkdev_bio_end_io_simple() local
52 blk_wake_io_task(waiter); in blkdev_bio_end_io_simple()
135 struct task_struct *waiter; member
170 struct task_struct *waiter = dio->waiter; in blkdev_bio_end_io() local
172 WRITE_ONCE(dio->waiter, NULL); in blkdev_bio_end_io()
173 blk_wake_io_task(waiter); in blkdev_bio_end_io()
213 dio->waiter = current; in __blkdev_direct_IO()
271 if (!READ_ONCE(dio->waiter)) in __blkdev_direct_IO()

Completed in 43 milliseconds

123