/openbmc/linux/fs/ |
H A D | eventfd.c | 32 wait_queue_head_t wqh; member 66 if (waitqueue_active(&ctx->wqh)) in eventfd_signal_mask() 136 poll_wait(file, &ctx->wqh, wait); in eventfd_poll() 234 spin_lock_irq(&ctx->wqh.lock); in eventfd_read() 249 if (waitqueue_active(&ctx->wqh)) in eventfd_read() 252 spin_unlock_irq(&ctx->wqh.lock); in eventfd_read() 272 spin_lock_irq(&ctx->wqh.lock); in eventfd_write() 289 spin_unlock_irq(&ctx->wqh.lock); in eventfd_write() 299 spin_lock_irq(&ctx->wqh.lock); in eventfd_show_fdinfo() 302 spin_unlock_irq(&ctx->wqh.lock); in eventfd_show_fdinfo() [all …]
|
H A D | timerfd.c | 38 wait_queue_head_t wqh; member 255 poll_wait(file, &ctx->wqh, wait); in timerfd_poll() 274 spin_lock_irq(&ctx->wqh.lock); in timerfd_read() 314 spin_unlock_irq(&ctx->wqh.lock); in timerfd_read() 326 spin_lock_irq(&ctx->wqh.lock); in timerfd_show() 329 spin_unlock_irq(&ctx->wqh.lock); in timerfd_show() 364 spin_lock_irq(&ctx->wqh.lock); in timerfd_ioctl() 432 init_waitqueue_head(&ctx->wqh); in SYSCALL_DEFINE2() 483 spin_lock_irq(&ctx->wqh.lock); in do_timerfd_settime() 521 spin_unlock_irq(&ctx->wqh.lock); in do_timerfd_settime() [all …]
|
H A D | fs-writeback.c | 1489 wait_queue_head_t *wqh; in __inode_wait_for_writeback() local 1491 wqh = bit_waitqueue(&inode->i_state, __I_SYNC); in __inode_wait_for_writeback() 1494 __wait_on_bit(wqh, &wq, bit_wait, in __inode_wait_for_writeback() 1519 wait_queue_head_t *wqh = bit_waitqueue(&inode->i_state, __I_SYNC); in inode_sleep_on_writeback() local 1522 prepare_to_wait(wqh, &wait, TASK_UNINTERRUPTIBLE); in inode_sleep_on_writeback() 1527 finish_wait(wqh, &wait); in inode_sleep_on_writeback()
|
H A D | userfaultfd.c | 967 wait_queue_head_t *wqh) in find_userfault_in() argument 972 lockdep_assert_held(&wqh->lock); in find_userfault_in() 975 if (!waitqueue_active(wqh)) in find_userfault_in() 978 wq = list_last_entry(&wqh->head, typeof(*wq), entry); in find_userfault_in()
|
/openbmc/linux/arch/powerpc/platforms/pseries/ |
H A D | rtas-work-area.c | 44 struct wait_queue_head wqh; member 49 .wqh = __WAIT_QUEUE_HEAD_INITIALIZER(rwa_state.wqh), 103 wait_event(rwa_state.wqh, in __rtas_work_area_alloc() 123 wake_up(&rwa_state.wqh); in rtas_work_area_free()
|
/openbmc/linux/kernel/locking/ |
H A D | rtmutex.c | 526 WARN_ON_ONCE(wqh->rtlock_task); in rt_mutex_wake_q_add_task() 528 wqh->rtlock_task = task; in rt_mutex_wake_q_add_task() 530 wake_q_add(&wqh->head, task); in rt_mutex_wake_q_add_task() 544 put_task_struct(wqh->rtlock_task); in rt_mutex_wake_up_q() 545 wqh->rtlock_task = NULL; in rt_mutex_wake_up_q() 548 if (!wake_q_empty(&wqh->head)) in rt_mutex_wake_up_q() 549 wake_up_q(&wqh->head); in rt_mutex_wake_up_q() 1330 rt_mutex_wake_q_add(wqh, waiter); in mark_wakeup_next_waiter() 1389 DEFINE_RT_WAKE_Q(wqh); in rt_mutex_slowunlock() 1442 mark_wakeup_next_waiter(&wqh, lock); in rt_mutex_slowunlock() [all …]
|
H A D | rtmutex_api.c | 166 struct rt_wake_q_head *wqh) in __rt_mutex_futex_unlock() argument 183 mark_wakeup_next_waiter(wqh, lock); in __rt_mutex_futex_unlock() 190 DEFINE_RT_WAKE_Q(wqh); in rt_mutex_futex_unlock() 195 postunlock = __rt_mutex_futex_unlock(lock, &wqh); in rt_mutex_futex_unlock() 199 rt_mutex_postunlock(&wqh); in rt_mutex_futex_unlock() 479 void __sched rt_mutex_postunlock(struct rt_wake_q_head *wqh) in rt_mutex_postunlock() argument 481 rt_mutex_wake_up_q(wqh); in rt_mutex_postunlock()
|
H A D | rwbase_rt.c | 145 DEFINE_RT_WAKE_Q(wqh); in __rwbase_read_unlock() 156 rt_mutex_wake_q_add_task(&wqh, owner, state); in __rwbase_read_unlock() 161 rt_mutex_wake_up_q(&wqh); in __rwbase_read_unlock()
|
H A D | rtmutex_common.h | 101 struct rt_wake_q_head *wqh); 103 extern void rt_mutex_postunlock(struct rt_wake_q_head *wqh);
|
/openbmc/linux/drivers/vfio/ |
H A D | virqfd.c | 79 wait_queue_head_t *wqh, poll_table *pt) in virqfd_ptable_queue_proc() argument 82 add_wait_queue(wqh, &virqfd->wait); in virqfd_ptable_queue_proc()
|
/openbmc/linux/drivers/virt/acrn/ |
H A D | irqfd.c | 96 static void hsm_irqfd_poll_func(struct file *file, wait_queue_head_t *wqh, in hsm_irqfd_poll_func() argument 102 add_wait_queue(wqh, &irqfd->wait); in hsm_irqfd_poll_func()
|
/openbmc/linux/kernel/ |
H A D | seccomp.c | 236 wait_queue_head_t wqh; member 534 if (waitqueue_active(&orig->wqh)) in __seccomp_filter_orphan() 535 wake_up_poll(&orig->wqh, EPOLLHUP); in __seccomp_filter_orphan() 689 init_waitqueue_head(&sfilter->wqh); in seccomp_prepare_filter() 1130 wake_up_poll_on_current_cpu(&match->wqh, EPOLLIN | EPOLLRDNORM); in seccomp_do_user_notification() 1132 wake_up_poll(&match->wqh, EPOLLIN | EPOLLRDNORM); in seccomp_do_user_notification() 1483 ret = prepare_to_wait_event(&filter->wqh, &wait, TASK_INTERRUPTIBLE); in recv_wait_event() 1493 finish_wait(&filter->wqh, &wait); in recv_wait_event() 1540 wake_up_poll(&filter->wqh, EPOLLOUT | EPOLLWRNORM); in seccomp_notify_recv() 1562 wake_up_poll(&filter->wqh, EPOLLIN | EPOLLRDNORM); in seccomp_notify_recv() [all …]
|
/openbmc/linux/mm/ |
H A D | internal.h | 99 wait_queue_head_t *wqh; in wake_throttle_isolated() local 101 wqh = &pgdat->reclaim_wait[VMSCAN_THROTTLE_ISOLATED]; in wake_throttle_isolated() 102 if (waitqueue_active(wqh)) in wake_throttle_isolated() 103 wake_up(wqh); in wake_throttle_isolated()
|
H A D | vmscan.c | 1196 wait_queue_head_t *wqh = &pgdat->reclaim_wait[reason]; in reclaim_throttle() local 1251 prepare_to_wait(wqh, &wait, TASK_UNINTERRUPTIBLE); in reclaim_throttle() 1253 finish_wait(wqh, &wait); in reclaim_throttle() 6707 wait_queue_head_t *wqh; in consider_reclaim_throttle() local 6709 wqh = &pgdat->reclaim_wait[VMSCAN_THROTTLE_NOPROGRESS]; in consider_reclaim_throttle() 6710 if (waitqueue_active(wqh)) in consider_reclaim_throttle() 6711 wake_up(wqh); in consider_reclaim_throttle()
|
H A D | memcontrol.c | 166 wait_queue_head_t *wqh; member 4789 remove_wait_queue(event->wqh, &event->wait); in memcg_event_remove() 4840 wait_queue_head_t *wqh, poll_table *pt) in memcg_event_ptable_queue_proc() argument 4845 event->wqh = wqh; in memcg_event_ptable_queue_proc() 4846 add_wait_queue(wqh, &event->wait); in memcg_event_ptable_queue_proc()
|
/openbmc/linux/kernel/futex/ |
H A D | pi.c | 618 DEFINE_RT_WAKE_Q(wqh); in wake_futex_pi() 671 postunlock = __rt_mutex_futex_unlock(&pi_state->pi_mutex, &wqh); in wake_futex_pi() 678 rt_mutex_postunlock(&wqh); in wake_futex_pi()
|
/openbmc/linux/drivers/vhost/ |
H A D | vhost.c | 154 static void vhost_poll_func(struct file *file, wait_queue_head_t *wqh, in vhost_poll_func() argument 160 poll->wqh = wqh; in vhost_poll_func() 161 add_wait_queue(wqh, &poll->wait); in vhost_poll_func() 197 poll->wqh = NULL; in vhost_poll_init() 210 if (poll->wqh) in vhost_poll_start() 229 if (poll->wqh) { in vhost_poll_stop() 230 remove_wait_queue(poll->wqh, &poll->wait); in vhost_poll_stop() 231 poll->wqh = NULL; in vhost_poll_stop()
|
H A D | vhost.h | 43 wait_queue_head_t *wqh; member
|
/openbmc/linux/virt/kvm/ |
H A D | eventfd.c | 248 irqfd_ptable_queue_proc(struct file *file, wait_queue_head_t *wqh, in irqfd_ptable_queue_proc() argument 253 add_wait_queue_priority(wqh, &irqfd->wait); in irqfd_ptable_queue_proc()
|
/openbmc/linux/Documentation/RCU/ |
H A D | listRCU.rst | 458 spin_lock_irqsave(&ctx->wqh.lock, flags); 462 wake_up_locked_poll(&ctx->wqh, EPOLLIN); 464 spin_unlock_irqrestore(&ctx->wqh.lock, flags);
|
/openbmc/linux/drivers/xen/ |
H A D | privcmd.c | 917 irqfd_poll_func(struct file *file, wait_queue_head_t *wqh, poll_table *pt) in irqfd_poll_func() argument 922 add_wait_queue_priority(wqh, &kirqfd->wait); in irqfd_poll_func()
|
/openbmc/linux/kernel/rcu/ |
H A D | tree.c | 1018 struct swait_queue_head *wqh = arg; in swake_up_one_online_ipi() local 1020 swake_up_one(wqh); in swake_up_one_online_ipi() 1023 static void swake_up_one_online(struct swait_queue_head *wqh) in swake_up_one_online() argument 1040 wqh, 0); in swake_up_one_online() 1044 swake_up_one(wqh); in swake_up_one_online()
|