Home
last modified time | relevance | path

Searched refs:waitq (Results 1 – 25 of 91) sorted by relevance

1234

/linux/drivers/md/dm-vdo/
H A Dwait-queue.c21 void vdo_waitq_enqueue_waiter(struct vdo_wait_queue *waitq, struct vdo_waiter *waiter) in vdo_waitq_enqueue_waiter() argument
25 if (waitq->last_waiter == NULL) { in vdo_waitq_enqueue_waiter()
33 waiter->next_waiter = waitq->last_waiter->next_waiter; in vdo_waitq_enqueue_waiter()
34 waitq->last_waiter->next_waiter = waiter; in vdo_waitq_enqueue_waiter()
38 waitq->last_waiter = waiter; in vdo_waitq_enqueue_waiter()
39 waitq->length += 1; in vdo_waitq_enqueue_waiter()
83 void vdo_waitq_notify_all_waiters(struct vdo_wait_queue *waitq, in vdo_waitq_notify_all_waiters() argument
93 vdo_waitq_transfer_all_waiters(waitq, &waiters); in vdo_waitq_notify_all_waiters()
106 struct vdo_waiter *vdo_waitq_get_first_waiter(const struct vdo_wait_queue *waitq) in vdo_waitq_get_first_waiter() argument
108 struct vdo_waiter *last_waiter = waitq->last_waiter; in vdo_waitq_get_first_waiter()
[all …]
H A Dwait-queue.h87 static inline void vdo_waitq_init(struct vdo_wait_queue *waitq) in vdo_waitq_init() argument
89 *waitq = (struct vdo_wait_queue) { in vdo_waitq_init()
101 static inline bool __must_check vdo_waitq_has_waiters(const struct vdo_wait_queue *waitq) in vdo_waitq_has_waiters() argument
103 return (waitq->last_waiter != NULL); in vdo_waitq_has_waiters()
106 void vdo_waitq_enqueue_waiter(struct vdo_wait_queue *waitq,
109 struct vdo_waiter *vdo_waitq_dequeue_waiter(struct vdo_wait_queue *waitq);
111 void vdo_waitq_notify_all_waiters(struct vdo_wait_queue *waitq,
114 bool vdo_waitq_notify_next_waiter(struct vdo_wait_queue *waitq,
120 struct vdo_waiter *vdo_waitq_get_first_waiter(const struct vdo_wait_queue *waitq);
122 void vdo_waitq_dequeue_matching_waiters(struct vdo_wait_queue *waitq,
[all …]
H A Ddump.c152 static void dump_vio_waiters(struct vdo_wait_queue *waitq, char *wait_on) in dump_vio_waiters() argument
154 struct vdo_waiter *waiter, *first = vdo_waitq_get_first_waiter(waitq); in dump_vio_waiters()
/linux/fs/netfs/
H A Dmisc.c346 wake_up(&rreq->waitq); in netfs_wake_collector()
384 prepare_to_wait(&rreq->waitq, &myself, TASK_UNINTERRUPTIBLE); in netfs_wait_for_in_progress_stream()
395 finish_wait(&rreq->waitq, &myself); in netfs_wait_for_in_progress_stream()
460 prepare_to_wait(&rreq->waitq, &myself, TASK_UNINTERRUPTIBLE); in netfs_wait_for_in_progress()
485 finish_wait(&rreq->waitq, &myself); in netfs_wait_for_in_progress()
529 prepare_to_wait(&rreq->waitq, &myself, TASK_UNINTERRUPTIBLE); in netfs_wait_for_pause()
555 finish_wait(&rreq->waitq, &myself); in netfs_wait_for_pause()
577 prepare_to_wait(&rreq->waitq, &myself, TASK_UNINTERRUPTIBLE); in netfs_wait_for_put_ra_refs()
584 finish_wait(&rreq->waitq, &myself); in netfs_wait_for_put_ra_refs()
/linux/drivers/input/serio/
H A Duserio.c47 wait_queue_head_t waitq; member
68 wake_up_interruptible(&userio->waitq); in userio_device_write()
82 init_waitqueue_head(&userio->waitq); in userio_char_open()
165 error = wait_event_interruptible(userio->waitq, in userio_char_read()
284 poll_wait(file, &userio->waitq, wait); in userio_char_poll()
/linux/fs/orangefs/
H A Dwaitqueue.c270 wait_for_completion(&op->waitq); in orangefs_clean_up_interrupted_operation()
298 reinit_completion(&op->waitq); in orangefs_clean_up_interrupted_operation()
334 n = wait_for_completion_io_timeout(&op->waitq, timeout); in wait_for_matching_downcall()
336 n = wait_for_completion_interruptible_timeout(&op->waitq, in wait_for_matching_downcall()
339 n = wait_for_completion_killable_timeout(&op->waitq, timeout); in wait_for_matching_downcall()
/linux/drivers/usb/misc/
H A Dyurex.c65 wait_queue_head_t waitq; member
84 wake_up_interruptible(&dev->waitq); in yurex_control_callback()
179 wake_up_interruptible(&dev->waitq); in yurex_interrupt()
206 init_waitqueue_head(&dev->waitq); in yurex_probe()
327 wake_up_interruptible(&dev->waitq); in yurex_disconnect()
494 prepare_to_wait(&dev->waitq, &wait, TASK_INTERRUPTIBLE); in yurex_write()
500 finish_wait(&dev->waitq, &wait); in yurex_write()
/linux/drivers/mailbox/
H A Dmailbox-test.c42 wait_queue_head_t waitq; member
192 add_wait_queue(&tdev->waitq, &wait); in mbox_test_message_read()
236 remove_wait_queue(&tdev->waitq, &wait); in mbox_test_message_read()
247 poll_wait(filp, &tdev->waitq, wait); in mbox_test_message_poll()
302 wake_up_interruptible(&tdev->waitq); in mbox_test_receive_message()
387 init_waitqueue_head(&tdev->waitq); in mbox_test_probe()
/linux/block/
H A Dblk-iocost.c532 struct wait_queue_head waitq; member
1341 lockdep_assert_held(&iocg->waitq.lock); in iocg_kick_delay()
1404 lockdep_assert_held(&iocg->waitq.lock); in iocg_incur_debt()
1427 lockdep_assert_held(&iocg->waitq.lock); in iocg_pay_debt()
1489 lockdep_assert_held(&iocg->waitq.lock); in iocg_kick_waitq()
1530 __wake_up_locked_key(&iocg->waitq, TASK_NORMAL, &ctx); in iocg_kick_waitq()
1532 if (!waitqueue_active(&iocg->waitq)) { in iocg_kick_waitq()
1574 spin_lock(&iocg->waitq.lock); in iocg_waitq_timer_fn()
1576 spin_unlock(&iocg->waitq.lock); in iocg_waitq_timer_fn()
1579 spin_lock_irqsave(&iocg->waitq.lock, flags); in iocg_waitq_timer_fn()
[all …]
/linux/drivers/char/xillybus/
H A Dxillyusb.c78 wait_queue_head_t waitq; member
415 init_waitqueue_head(&fifo->waitq); in fifo_init()
594 wake_up_interruptible(&chan->in_fifo->waitq); in wakeup_all()
598 wake_up_interruptible(&chan->out_ep->fifo.waitq); in wakeup_all()
607 wake_up_interruptible(&xdev->msg_ep->fifo.waitq); in wakeup_all()
870 wake_up_interruptible(&fifo->waitq); in try_queue_bulk_out()
912 wake_up_interruptible(&chan->in_fifo->waitq); in process_in_opcode()
1012 wake_up_interruptible(&fifo->waitq); in process_bulk_in()
1091 while (wait_event_interruptible(fifo->waitq, in xillyusb_send_opcode()
1573 (fifo->waitq, in xillyusb_read()
[all …]
/linux/drivers/net/wireless/marvell/libertas/
H A Dmain.c209 wait_event(priv->waitq, lbs_command_queue_empty(priv)); in lbs_stop_iface()
259 wake_up(&priv->waitq); in lbs_host_to_card_done()
428 add_wait_queue(&priv->waitq, &wait); in lbs_thread()
471 remove_wait_queue(&priv->waitq, &wait); in lbs_thread()
716 wake_up(&priv->waitq); in lbs_cmd_timeout_handler()
741 wake_up_interruptible(&priv->waitq); in lbs_tx_lockup_handler()
871 init_waitqueue_head(&priv->waitq); in lbs_add_card()
1033 wake_up(&priv->waitq); in lbs_queue_event()
1048 wake_up(&priv->waitq); in lbs_notify_command_response()
/linux/drivers/gpu/drm/amd/amdgpu/
H A Damdgpu_userq_fence.c721 struct amdgpu_usermode_queue *waitq; in amdgpu_userq_wait_return_fence_info() local
838 waitq = amdgpu_userq_get(userq_mgr, wait_info->waitq_id); in amdgpu_userq_wait_return_fence_info()
839 if (!waitq) { in amdgpu_userq_wait_return_fence_info()
869 mutex_lock(&waitq->fence_drv_lock); in amdgpu_userq_wait_return_fence_info()
870 r = xa_alloc(&waitq->fence_drv_xa, &index, fence_drv, in amdgpu_userq_wait_return_fence_info()
872 mutex_unlock(&waitq->fence_drv_lock); in amdgpu_userq_wait_return_fence_info()
878 trace_amdgpu_userq_wait_deps(dev->dev, waitq, userq_fence); in amdgpu_userq_wait_return_fence_info()
897 amdgpu_userq_put(waitq); in amdgpu_userq_wait_return_fence_info()
/linux/drivers/platform/surface/
H A Dsurface_aggregator_cdev.c67 wait_queue_head_t waitq; member
126 wake_up_interruptible(&client->waitq); in ssam_cdev_notifier()
479 init_waitqueue_head(&client->waitq); in ssam_cdev_device_open()
599 status = wait_event_interruptible(client->waitq, in ssam_cdev_read()
649 poll_wait(file, &client->waitq, pt); in ssam_cdev_poll()
741 wake_up_interruptible(&client->waitq); in ssam_dbg_device_remove()
H A Dsurface_dtx.c154 wait_queue_head_t waitq; member
484 status = wait_event_interruptible(ddev->waitq, in surface_dtx_read()
534 poll_wait(file, &client->ddev->waitq, pt); in surface_dtx_poll()
617 wake_up_interruptible(&ddev->waitq); in sdtx_push_event()
966 init_waitqueue_head(&ddev->waitq); in sdtx_device_init()
1090 wake_up_interruptible(&ddev->waitq); in sdtx_device_destroy()
/linux/drivers/scsi/lpfc/
H A Dlpfc_vport.c492 DECLARE_WAIT_QUEUE_HEAD_ONSTACK(waitq); in lpfc_send_npiv_logo()
497 ndlp->logo_waitq = &waitq; in lpfc_send_npiv_logo()
505 wait_event_timeout(waitq, in lpfc_send_npiv_logo()
628 DECLARE_WAIT_QUEUE_HEAD_ONSTACK(waitq); in lpfc_vport_delete()
697 ndlp->da_id_waitq = &waitq; in lpfc_vport_delete()
703 wait_event_timeout(waitq, in lpfc_vport_delete()
/linux/net/sunrpc/
H A Drpc_pipe.c64 static void rpc_purge_list(wait_queue_head_t *waitq, struct list_head *head, in rpc_purge_list() argument
78 if (waitq) in rpc_purge_list()
79 wake_up(waitq); in rpc_purge_list()
99 rpc_purge_list(dentry ? &RPC_I(d_inode(dentry))->waitq : NULL, in rpc_timeout_upcall_queue()
157 wake_up(&RPC_I(d_inode(dentry))->waitq); in rpc_queue_upcall()
187 rpc_purge_list(&RPC_I(inode)->waitq, &free_list, pipe->ops->destroy_msg, -EPIPE); in rpc_close_pipes()
269 rpc_purge_list(&RPC_I(inode)->waitq, &free_list, in rpc_pipe_release()
346 poll_wait(filp, &rpci->waitq, wait); in rpc_pipe_poll()
1227 init_waitqueue_head(&rpci->waitq); in init_once()
/linux/drivers/i2c/busses/
H A Di2c-mv64xxx.c139 wait_queue_head_t waitq; member
417 wake_up(&drv_data->waitq); in mv64xxx_i2c_do_action()
433 wake_up(&drv_data->waitq); in mv64xxx_i2c_do_action()
497 wake_up(&drv_data->waitq); in mv64xxx_i2c_intr_offload()
556 time_left = wait_event_timeout(drv_data->waitq, in mv64xxx_i2c_wait_for_completion()
572 time_left = wait_event_timeout(drv_data->waitq, in mv64xxx_i2c_wait_for_completion()
998 init_waitqueue_head(&drv_data->waitq); in mv64xxx_i2c_probe()
H A Di2c-iop3xx.c116 wake_up_interruptible(&iop3xx_adap->waitq); in iop3xx_i2c_irq_handler()
171 iop3xx_adap->waitq, in iop3xx_i2c_wait_event()
489 init_waitqueue_head(&adapter_data->waitq); in iop3xx_i2c_probe()
H A Di2c-iop3xx.h91 wait_queue_head_t waitq; member
/linux/sound/soc/sof/
H A Dipc.c141 wake_up(&msg->waitq); in snd_sof_ipc_reply()
162 init_waitqueue_head(&msg->waitq); in snd_sof_ipc_init()
/linux/fs/autofs/
H A DMakefile8 autofs4-objs := init.o inode.o root.o symlink.o waitq.o expire.o dev-ioctl.o
/linux/kernel/bpf/
H A Dringbuf.c29 wait_queue_head_t waitq; member
158 wake_up_all(&rb->waitq); in bpf_ringbuf_notify()
182 init_waitqueue_head(&rb->waitq); in bpf_ringbuf_alloc()
342 poll_wait(filp, &rb_map->rb->waitq, pts); in ringbuf_map_poll_kern()
355 poll_wait(filp, &rb_map->rb->waitq, pts); in ringbuf_map_poll_user()
/linux/fs/afs/
H A Drxrpc.c182 init_waitqueue_head(&call->waitq); in afs_alloc_call()
307 init_waitqueue_head(&call->waitq); in afs_alloc_flat_call()
640 add_wait_queue(&call->waitq, &myself); in afs_wait_for_call_to_complete()
665 remove_wait_queue(&call->waitq, &myself); in afs_wait_for_call_to_complete()
692 wake_up(&call->waitq); in afs_wake_up_call_waiter()
762 init_waitqueue_head(&call->waitq); in afs_charge_preallocation()
/linux/include/video/
H A Dmetronomefb.h32 wait_queue_head_t waitq; member
H A Dbroadsheetfb.h51 wait_queue_head_t waitq; member

1234