| /fs/autofs4/ |
| D | waitq.c | 29 struct autofs_wait_queue *wq, *nwq; in autofs4_catatonic_mode() local
40 wq = sbi->queues; in autofs4_catatonic_mode()
42 while (wq) { in autofs4_catatonic_mode()
43 nwq = wq->next; in autofs4_catatonic_mode()
44 wq->status = -ENOENT; /* Magic is gone - report failure */ in autofs4_catatonic_mode()
45 kfree(wq->name.name); in autofs4_catatonic_mode()
46 wq->name.name = NULL; in autofs4_catatonic_mode()
47 wq->wait_ctr--; in autofs4_catatonic_mode()
48 wake_up_interruptible(&wq->queue); in autofs4_catatonic_mode()
49 wq = nwq; in autofs4_catatonic_mode()
[all …]
|
| /fs/jfs/ |
| D | jfs_lock.h | 35 #define __SLEEP_COND(wq, cond, lock_cmd, unlock_cmd) \ argument
39 add_wait_queue(&wq, &__wait); \
49 remove_wait_queue(&wq, &__wait); \
|
| /fs/nfs/blocklayout/ |
| D | blocklayoutdm.c | 51 DECLARE_WAITQUEUE(wq, current); in dev_remove()
71 add_wait_queue(&nn->bl_wq, &wq); in dev_remove()
73 remove_wait_queue(&nn->bl_wq, &wq); in dev_remove()
80 remove_wait_queue(&nn->bl_wq, &wq); in dev_remove()
|
| D | blocklayoutdev.c | 108 DECLARE_WAITQUEUE(wq, current); in nfs4_blk_decode_device()
139 add_wait_queue(&nn->bl_wq, &wq); in nfs4_blk_decode_device()
142 remove_wait_queue(&nn->bl_wq, &wq); in nfs4_blk_decode_device()
150 remove_wait_queue(&nn->bl_wq, &wq); in nfs4_blk_decode_device()
|
| /fs/ |
| D | eventpoll.c | 189 wait_queue_head_t wq; member
502 static void ep_poll_safewake(wait_queue_head_t *wq) in ep_poll_safewake() argument
507 ep_poll_wakeup_proc, NULL, wq, (void *) (long) this_cpu); in ep_poll_safewake()
659 if (waitqueue_active(&ep->wq)) in ep_scan_ready_list()
660 wake_up_locked(&ep->wq); in ep_scan_ready_list()
920 init_waitqueue_head(&ep->wq); in ep_alloc()
1040 if (waitqueue_active(&ep->wq)) in ep_poll_callback()
1041 wake_up_locked(&ep->wq); in ep_poll_callback()
1311 if (waitqueue_active(&ep->wq)) in ep_insert()
1312 wake_up_locked(&ep->wq); in ep_insert()
[all …]
|
| D | direct-io.c | 537 struct workqueue_struct *wq = alloc_workqueue("dio/%s", in sb_init_dio_done_wq() local
540 if (!wq) in sb_init_dio_done_wq()
545 cmpxchg(&sb->s_dio_done_wq, NULL, wq); in sb_init_dio_done_wq()
547 if (wq != sb->s_dio_done_wq) in sb_init_dio_done_wq()
548 destroy_workqueue(wq); in sb_init_dio_done_wq()
|
| D | inode.c | 1751 wait_queue_head_t *wq; in __wait_on_freeing_inode() local
1753 wq = bit_waitqueue(&inode->i_state, __I_NEW); in __wait_on_freeing_inode()
1754 prepare_to_wait(wq, &wait.wait, TASK_UNINTERRUPTIBLE); in __wait_on_freeing_inode()
1758 finish_wait(wq, &wait.wait); in __wait_on_freeing_inode()
1897 wait_queue_head_t *wq = bit_waitqueue(&inode->i_state, __I_DIO_WAKEUP); in __inode_dio_wait() local
1901 prepare_to_wait(wq, &q.wait, TASK_UNINTERRUPTIBLE); in __inode_dio_wait()
1905 finish_wait(wq, &q.wait); in __inode_dio_wait()
|
| D | block_dev.c | 690 wait_queue_head_t *wq = bit_waitqueue(&whole->bd_claiming, 0); in bd_prepare_to_claim() local
693 prepare_to_wait(wq, &wait, TASK_UNINTERRUPTIBLE); in bd_prepare_to_claim()
696 finish_wait(wq, &wait); in bd_prepare_to_claim()
|
| /fs/logfs/ |
| D | dev_bdev.c | 65 static DECLARE_WAIT_QUEUE_HEAD(wq);
88 wake_up(&wq); in writeseg_end_io()
182 wake_up(&wq); in erase_end_io()
261 wait_event(wq, atomic_read(&super->s_pending_writes) == 0); in bdev_sync()
|
| /fs/jffs2/ |
| D | os-linux.h | 40 #define sleep_on_spinunlock(wq, s) \ argument
43 add_wait_queue((wq), &__wait); \
47 remove_wait_queue((wq), &__wait); \
|
| /fs/nfs/ |
| D | callback.c | 123 DEFINE_WAIT(wq); in nfs41_callback_svc()
131 prepare_to_wait(&serv->sv_cb_waitq, &wq, TASK_INTERRUPTIBLE); in nfs41_callback_svc()
146 finish_wait(&serv->sv_cb_waitq, &wq); in nfs41_callback_svc()
|
| D | pagelist.c | 106 wait_queue_head_t *wq = bit_waitqueue(&c->flags, NFS_IO_INPROGRESS); in __nfs_iocounter_wait() local
111 prepare_to_wait(wq, &q.wait, TASK_KILLABLE); in __nfs_iocounter_wait()
117 finish_wait(wq, &q.wait); in __nfs_iocounter_wait()
|
| D | inode.c | 1612 struct workqueue_struct *wq; in nfsiod_start() local
1614 wq = alloc_workqueue("nfsiod", WQ_MEM_RECLAIM, 0); in nfsiod_start()
1615 if (wq == NULL) in nfsiod_start()
1617 nfsiod_workqueue = wq; in nfsiod_start()
1626 struct workqueue_struct *wq; in nfsiod_stop() local
1628 wq = nfsiod_workqueue; in nfsiod_stop()
1629 if (wq == NULL) in nfsiod_stop()
1632 destroy_workqueue(wq); in nfsiod_stop()
|
| /fs/xfs/ |
| D | xfs_log_priv.h | 679 static inline void xlog_wait(wait_queue_head_t *wq, spinlock_t *lock) in xlog_wait() argument
683 add_wait_queue_exclusive(wq, &wait); in xlog_wait()
687 remove_wait_queue(wq, &wait); in xlog_wait()
|
| /fs/ocfs2/dlm/ |
| D | dlmmaster.c | 280 init_waitqueue_head(&mle->wq); in dlm_init_mle()
570 init_waitqueue_head(&res->wq); in dlm_init_lockres()
682 wake_up(&res->wq); in dlm_lockres_drop_inflight_ref()
967 wake_up(&res->wq); in dlm_get_lock_resource()
1090 (void)wait_event_timeout(mle->wq, in dlm_wait_for_lock_mastery()
1720 wake_up(&res->wq); in dlm_do_assert_master()
1897 wake_up(&mle->wq); in dlm_assert_master_handler()
1918 wake_up(&res->wq); in dlm_assert_master_handler()
2012 wake_up(&res->wq); in dlm_assert_master_post_handler()
2544 ret = wait_event_interruptible_timeout(mle->wq, in dlm_migrate_lockres()
[all …]
|
| D | dlmconvert.c | 94 wake_up(&res->wq); in dlmconvert_master()
333 wake_up(&res->wq); in dlmconvert_remote()
521 wake_up(&res->wq); in dlm_convert_lock_handler()
|
| D | dlmthread.c | 67 add_wait_queue(&res->wq, &wait); in __dlm_wait_on_lockres_flags()
76 remove_wait_queue(&res->wq, &wait); in __dlm_wait_on_lockres_flags()
219 wake_up(&res->wq); in dlm_purge_lockres()
|
| D | dlmlock.c | 188 wake_up(&res->wq); in dlmlock_master()
293 wake_up(&res->wq); in dlmlock_remote()
|
| /fs/ext4/ |
| D | page-io.c | 219 struct workqueue_struct *wq; in ext4_add_complete_io() local
226 wq = sbi->rsv_conversion_wq; in ext4_add_complete_io()
228 queue_work(wq, &ei->i_rsv_conversion_work); in ext4_add_complete_io()
|
| D | file.c | 62 wait_queue_head_t *wq = ext4_ioend_wq(inode); in ext4_unwritten_wait() local
64 wait_event(*wq, (atomic_read(&EXT4_I(inode)->i_unwritten) == 0)); in ext4_unwritten_wait()
|
| /fs/cachefiles/ |
| D | namei.c | 206 wait_queue_head_t *wq; in cachefiles_mark_object_active() local
223 wq = bit_waitqueue(&xobject->flags, CACHEFILES_OBJECT_ACTIVE); in cachefiles_mark_object_active()
227 prepare_to_wait(wq, &wait, TASK_UNINTERRUPTIBLE); in cachefiles_mark_object_active()
233 finish_wait(wq, &wait); in cachefiles_mark_object_active()
|
| /fs/ncpfs/ |
| D | sock.c | 59 wait_queue_head_t wq; member
81 init_waitqueue_head(&req->wq); in ncp_alloc_req()
139 wake_up_all(&req->wq); in ncp_finish_request()
721 if (wait_event_interruptible(req->wq, req->status == RQ_DONE)) { in do_ncp_rpc_call()
|
| /fs/nilfs2/ |
| D | segment.c | 2058 wait_queue_t wq; member
2070 init_wait(&wait_req.wq); in nilfs_segctor_sync()
2076 init_waitqueue_entry(&wait_req.wq, current); in nilfs_segctor_sync()
2077 add_wait_queue(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2093 finish_wait(&sci->sc_wait_request, &wait_req.wq); in nilfs_segctor_sync()
2104 wq.task_list) { in nilfs_segctor_wakeup()
2111 wrq->wq.func(&wrq->wq, in nilfs_segctor_wakeup()
|
| /fs/exofs/ |
| D | super.c | 452 wait_queue_head_t wq; in exofs_put_super() local
457 init_waitqueue_head(&wq); in exofs_put_super()
458 wait_event_timeout(wq, in exofs_put_super()
|
| /fs/f2fs/ |
| D | gc.c | 32 wait_queue_head_t *wq = &sbi->gc_thread->gc_wait_queue_head; in gc_thread_func() local
41 wait_event_interruptible_timeout(*wq, in gc_thread_func()
|