Home
last modified time | relevance | path

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

123456

/linux/drivers/md/dm-vdo/
H A Dwait-queue.c25 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()
93 vdo_waitq_transfer_all_waiters(waitq, &waiters); in vdo_waitq_notify_all_waiters()
108 struct vdo_waiter *last_waiter = waitq->last_waiter; in vdo_waitq_get_first_waiter()
141 matched_waitq : waitq), waiter); in vdo_waitq_dequeue_matching_waiters()
157 struct vdo_waiter *last_waiter = waitq->last_waiter; in vdo_waitq_dequeue_waiter()
164 waitq->last_waiter = NULL; in vdo_waitq_dequeue_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 …]
/linux/drivers/leds/
H A Duleds.c32 wait_queue_head_t waitq; member
48 wake_up_interruptible(&udev->waitq); in uleds_brightness_set()
64 init_waitqueue_head(&udev->waitq); in uleds_open()
162 retval = wait_event_interruptible(udev->waitq, in uleds_read()
174 poll_wait(file, &udev->waitq, wait); in uleds_poll()
/linux/drivers/input/serio/
H A Duserio.c47 wait_queue_head_t waitq; member
71 wake_up_interruptible(&userio->waitq); in userio_device_write()
86 init_waitqueue_head(&userio->waitq); in userio_char_open()
166 error = wait_event_interruptible(userio->waitq, in userio_char_read()
255 poll_wait(file, &userio->waitq, wait); in userio_char_poll()
/linux/drivers/spi/
H A Dspi-coldfire-qspi.c65 wait_queue_head_t waitq; member
148 wake_up(&mcfqspi->waitq); in mcfqspi_irq_handler()
179 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg8()
199 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg8()
212 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg8()
246 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg16()
266 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg16()
279 wait_event(mcfqspi->waitq, !mcfqspi_qdlyr_spe(mcfqspi)); in mcfqspi_transfer_msg16()
401 init_waitqueue_head(&mcfqspi->waitq); in mcfqspi_probe()
/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()
H A Dorangefs-kernel.h127 struct completion waitq; member
141 complete(&op->waitq); in set_op_state_serviced()
169 complete(&op->waitq); in set_op_state_purged()
/linux/drivers/usb/misc/
H A Dyurex.c67 wait_queue_head_t waitq; member
86 wake_up_interruptible(&dev->waitq); in yurex_control_callback()
181 wake_up_interruptible(&dev->waitq); in yurex_interrupt()
208 init_waitqueue_head(&dev->waitq); in yurex_probe()
329 wake_up_interruptible(&dev->waitq); in yurex_disconnect()
495 prepare_to_wait(&dev->waitq, &wait, TASK_INTERRUPTIBLE); in yurex_write()
501 finish_wait(&dev->waitq, &wait); in yurex_write()
/linux/drivers/mailbox/
H A Dmailbox-test.c44 wait_queue_head_t waitq; member
193 add_wait_queue(&tdev->waitq, &wait); in mbox_test_message_read()
237 remove_wait_queue(&tdev->waitq, &wait); in mbox_test_message_read()
248 poll_wait(filp, &tdev->waitq, wait); in mbox_test_message_poll()
303 wake_up_interruptible(&tdev->waitq); in mbox_test_receive_message()
415 init_waitqueue_head(&tdev->waitq); in mbox_test_probe()
/linux/drivers/media/pci/netup_unidvb/
H A Dnetup_unidvb_spi.c42 wait_queue_head_t waitq; member
89 wake_up(&spi->waitq); in netup_spi_interrupt()
137 wait_event_timeout(spi->waitq, in netup_spi_transfer()
192 init_waitqueue_head(&nspi->waitq); in netup_spi_init()
/linux/drivers/char/xillybus/
H A Dxillyusb.c77 wait_queue_head_t waitq; member
414 init_waitqueue_head(&fifo->waitq); in fifo_init()
597 wake_up_interruptible(&chan->in_fifo->waitq); in wakeup_all()
873 wake_up_interruptible(&fifo->waitq); in try_queue_bulk_out()
915 wake_up_interruptible(&chan->in_fifo->waitq); in process_in_opcode()
1015 wake_up_interruptible(&fifo->waitq); in process_bulk_in()
1094 while (wait_event_interruptible(fifo->waitq, in xillyusb_send_opcode()
1576 (fifo->waitq, in xillyusb_read()
1587 (fifo->waitq, in xillyusb_read()
1679 (fifo->waitq, in xillyusb_write()
[all …]
/linux/drivers/net/wireless/marvell/libertas/
H A Dmain.c229 wait_event(priv->waitq, lbs_command_queue_empty(priv)); in lbs_stop_iface()
280 wake_up(&priv->waitq); in lbs_host_to_card_done()
449 add_wait_queue(&priv->waitq, &wait); in lbs_thread()
493 remove_wait_queue(&priv->waitq, &wait); in lbs_thread()
747 wake_up(&priv->waitq); in lbs_cmd_timeout_handler()
771 wake_up_interruptible(&priv->waitq); in lbs_tx_lockup_handler()
954 init_waitqueue_head(&priv->waitq); in lbs_add_card()
1116 wake_up(&priv->waitq); in lbs_queue_event()
1131 wake_up(&priv->waitq); in lbs_notify_command_response()
/linux/arch/arm/mach-pxa/
H A Dam200epd.c287 wake_up_interruptible(&par->waitq); in am200_handle_irq()
315 return wait_event_timeout(par->waitq, gpio_get_value(RDY_GPIO_PIN), HZ); in am200_wait_event()
320 return wait_event_interruptible_timeout(par->waitq, in am200_wait_event_intr()
/linux/block/
H A Dblk-iocost.c532 struct wait_queue_head waitq; member
734 spin_lock(&iocg->waitq.lock); in iocg_lock()
743 spin_unlock(&iocg->waitq.lock); in iocg_unlock()
1755 if (waitqueue_active(&iocg->waitq) || in hweight_after_donation()
2136 spin_lock(&iocg->waitq.lock); in ioc_forgive_debts()
2152 spin_unlock(&iocg->waitq.lock); in ioc_forgive_debts()
2176 spin_lock(&iocg->waitq.lock); in ioc_check_iocgs()
2227 spin_unlock(&iocg->waitq.lock); in ioc_check_iocgs()
2778 spin_lock(&iocg->waitq.lock); in ioc_rqos_merge()
2789 spin_unlock(&iocg->waitq.lock); in ioc_rqos_merge()
[all …]
/linux/include/linux/
H A Dbacking-dev-defs.h65 wait_queue_head_t *waitq; member
69 (struct wb_completion){ .cnt = ATOMIC_INIT(1), .waitq = (_waitq) }
/linux/sound/soc/intel/common/
H A Dsst-ipc.c52 ret = wait_event_timeout(msg->waitq, msg->complete, in tx_wait_done()
135 init_waitqueue_head(&ipc->msg[i].waitq); in msg_empty_list_init()
253 wake_up(&msg->waitq); in sst_ipc_tx_msg_reply_complete()
/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()
742 wake_up_interruptible(&client->waitq); in ssam_dbg_device_remove()
/linux/drivers/media/pci/cx18/
H A Dcx18-mailbox.c321 wake_up(&s->waitq); in epu_dma_done()
586 wait_queue_head_t *waitq; in cx18_api_call() local
612 waitq = &cx->mb_apu_waitq; in cx18_api_call()
618 waitq = &cx->mb_cpu_waitq; in cx18_api_call()
641 ret = wait_event_timeout(*waitq, in cx18_api_call()
672 prepare_to_wait(waitq, &w, TASK_UNINTERRUPTIBLE); in cx18_api_call()
685 finish_wait(waitq, &w); in cx18_api_call()
/linux/drivers/staging/olpc_dcon/
H A Dolpc_dcon.c294 wait_event_timeout(dcon->waitq, dcon->switched, HZ); in dcon_source_switch()
333 wait_event_timeout(dcon->waitq, dcon->switched, HZ / 2); in dcon_source_switch()
595 init_waitqueue_head(&dcon->waitq); in dcon_probe()
740 wake_up(&dcon->waitq); in dcon_interrupt()
754 wake_up(&dcon->waitq); in dcon_interrupt()
/linux/fs/autofs/
H A DMakefile8 autofs4-objs := init.o inode.o root.o symlink.o waitq.o expire.o dev-ioctl.o
/linux/sound/soc/sof/
H A Dipc.c143 wake_up(&msg->waitq); in snd_sof_ipc_reply()
164 init_waitqueue_head(&msg->waitq); in snd_sof_ipc_init()
/linux/kernel/bpf/
H A Dringbuf.c27 wait_queue_head_t waitq; member
152 wake_up_all(&rb->waitq); in bpf_ringbuf_notify()
176 init_waitqueue_head(&rb->waitq); in bpf_ringbuf_alloc()
316 poll_wait(filp, &rb_map->rb->waitq, pts); in ringbuf_map_poll_kern()
329 poll_wait(filp, &rb_map->rb->waitq, pts); in ringbuf_map_poll_user()
/linux/fs/afs/
H A Drxrpc.c152 init_waitqueue_head(&call->waitq); in afs_alloc_call()
260 init_waitqueue_head(&call->waitq); in afs_alloc_flat_call()
587 add_wait_queue(&call->waitq, &myself); in afs_wait_for_call_to_complete()
612 remove_wait_queue(&call->waitq, &myself); in afs_wait_for_call_to_complete()
639 wake_up(&call->waitq); in afs_wake_up_call_waiter()
708 init_waitqueue_head(&call->waitq); in afs_charge_preallocation()
/linux/drivers/i2c/busses/
H A Di2c-mv64xxx.c140 wait_queue_head_t waitq; member
423 wake_up(&drv_data->waitq); in mv64xxx_i2c_do_action()
439 wake_up(&drv_data->waitq); in mv64xxx_i2c_do_action()
503 wake_up(&drv_data->waitq); in mv64xxx_i2c_intr_offload()
562 time_left = wait_event_timeout(drv_data->waitq, in mv64xxx_i2c_wait_for_completion()
578 time_left = wait_event_timeout(drv_data->waitq, in mv64xxx_i2c_wait_for_completion()
1005 init_waitqueue_head(&drv_data->waitq); in mv64xxx_i2c_probe()
/linux/fs/fuse/
H A Ddev.c47 init_waitqueue_head(&req->waitq); in fuse_request_init()
213 wake_up(&fiq->waitq); in fuse_dev_wake_and_unlock()
324 wake_up(&req->waitq); in fuse_request_end()
616 spin_lock(&req->waitq.lock); in lock_request()
621 spin_unlock(&req->waitq.lock); in lock_request()
634 spin_lock(&req->waitq.lock); in unlock_request()
639 spin_unlock(&req->waitq.lock); in unlock_request()
857 spin_lock(&cs->req->waitq.lock); in fuse_try_move_page()
862 spin_unlock(&cs->req->waitq.lock); in fuse_try_move_page()
2207 spin_lock(&req->waitq.lock); in fuse_abort_conn()
[all …]

123456