Home
last modified time | relevance | path

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

123456

/fs/ecryptfs/
Dkthread.c37 wait_queue_head_t wait; member
58 ecryptfs_kthread_ctl.wait, in ecryptfs_threadfn()
80 wake_up(&req->wait); in ecryptfs_threadfn()
94 init_waitqueue_head(&ecryptfs_kthread_ctl.wait); in ecryptfs_init_kthread()
116 wake_up(&req->wait); in ecryptfs_destroy_kthread()
121 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_destroy_kthread()
165 init_waitqueue_head(&req->wait); in ecryptfs_privileged_open()
178 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_privileged_open()
179 wait_event(req->wait, (req->flags != 0)); in ecryptfs_privileged_open()
/fs/
Dselect.c130 remove_wait_queue(entry->wait_address, &entry->wait); in free_poll_entry()
180 static int __pollwake(wait_queue_t *wait, unsigned mode, int sync, void *key) in __pollwake() argument
182 struct poll_wqueues *pwq = wait->private; in __pollwake()
206 static int pollwake(wait_queue_t *wait, unsigned mode, int sync, void *key) in pollwake() argument
210 entry = container_of(wait, struct poll_table_entry, wait); in pollwake()
213 return __pollwake(wait, mode, sync, key); in pollwake()
228 init_waitqueue_func_entry(&entry->wait, pollwake); in __pollwait()
229 entry->wait.private = pwq; in __pollwait()
230 add_wait_queue(wait_address, &entry->wait); in __pollwait()
388 static inline void wait_key_set(poll_table *wait, unsigned long in, in wait_key_set() argument
[all …]
Deventfd.c119 static unsigned int eventfd_poll(struct file *file, poll_table *wait) in eventfd_poll() argument
125 poll_wait(file, &ctx->wqh, wait); in eventfd_poll()
158 int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_t *wait, in eventfd_ctx_remove_wait_queue() argument
165 __remove_wait_queue(&ctx->wqh, wait); in eventfd_ctx_remove_wait_queue()
191 DECLARE_WAITQUEUE(wait, current); in eventfd_ctx_read()
199 __add_wait_queue(&ctx->wqh, &wait); in eventfd_ctx_read()
214 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_ctx_read()
250 DECLARE_WAITQUEUE(wait, current); in eventfd_write()
263 __add_wait_queue(&ctx->wqh, &wait); in eventfd_write()
278 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_write()
Dsync.c30 static int __sync_filesystem(struct super_block *sb, int wait) in __sync_filesystem() argument
40 sb->s_qcop->quota_sync(sb, -1, wait); in __sync_filesystem()
42 if (wait) in __sync_filesystem()
48 sb->s_op->sync_fs(sb, wait); in __sync_filesystem()
49 return __sync_blockdev(sb->s_bdev, wait); in __sync_filesystem()
89 static void sync_filesystems(int wait) in sync_filesystems() argument
91 iterate_supers(sync_one_sb, &wait); in sync_filesystems()
Deventpoll.c227 wait_queue_t wait; member
332 return container_of(p, struct eppoll_entry, wait); in ep_pwq_from_wait()
338 return container_of(p, struct eppoll_entry, wait)->base; in ep_item_from_wait()
515 remove_wait_queue(whead, &pwq->wait); in ep_remove_wait_queue()
767 static unsigned int ep_eventpoll_poll(struct file *file, poll_table *wait) in ep_eventpoll_poll() argument
773 poll_wait(file, &ep->poll_wait, wait); in ep_eventpoll_poll()
897 static int ep_poll_callback(wait_queue_t *wait, unsigned mode, int sync, void *key) in ep_poll_callback() argument
901 struct epitem *epi = ep_item_from_wait(wait); in ep_poll_callback()
905 ep_pwq_from_wait(wait)->whead = NULL; in ep_poll_callback()
912 list_del_init(&wait->task_list); in ep_poll_callback()
[all …]
Dfifo.c31 wake_up_interruptible(&inode->i_pipe->wait); in wake_up_partner()
126 wake_up_interruptible(&pipe->wait); in fifo_open()
132 wake_up_interruptible(&pipe->wait); in fifo_open()
Dpipe.c93 DEFINE_WAIT(wait); in pipe_wait()
99 prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); in pipe_wait()
102 finish_wait(&pipe->wait, &wait); in pipe_wait()
470 wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM); in pipe_read()
479 wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM); in pipe_read()
655 wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM); in pipe_write()
666 wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM); in pipe_write()
717 pipe_poll(struct file *filp, poll_table *wait) in pipe_poll() argument
724 poll_wait(filp, &pipe->wait, wait); in pipe_poll()
761 …wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLOUT | POLLRDNORM | POLLWRNORM | POLLERR … in pipe_release()
[all …]
Dsignalfd.c58 static unsigned int signalfd_poll(struct file *file, poll_table *wait) in signalfd_poll() argument
63 poll_wait(file, &current->sighand->signalfd_wqh, wait); in signalfd_poll()
160 DECLARE_WAITQUEUE(wait, current); in signalfd_dequeue()
174 add_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
190 remove_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
Daio.c269 init_waitqueue_head(&ctx->wait); in ioctx_alloc()
316 DECLARE_WAITQUEUE(wait, tsk); in kill_ctx()
338 add_wait_queue(&ctx->wait, &wait); in kill_ctx()
347 remove_wait_queue(&ctx->wait, &wait); in kill_ctx()
470 wake_up_all(&ctx->wait); in kiocb_batch_free()
570 wake_up_all(&ctx->wait); in really_put_req()
858 if (waitqueue_active(&ctx->wait)) in aio_queue_work()
1053 if (waitqueue_active(&ctx->wait)) in aio_complete()
1054 wake_up(&ctx->wait); in aio_complete()
1146 DECLARE_WAITQUEUE(wait, tsk); in read_events()
[all …]
Dmbcache.c470 DEFINE_WAIT(wait); in mb_cache_entry_get()
477 prepare_to_wait(&mb_cache_queue, &wait, in mb_cache_entry_get()
484 finish_wait(&mb_cache_queue, &wait); in mb_cache_entry_get()
511 DEFINE_WAIT(wait); in __mb_cache_entry_find()
521 prepare_to_wait(&mb_cache_queue, &wait, in __mb_cache_entry_find()
528 finish_wait(&mb_cache_queue, &wait); in __mb_cache_entry_find()
Dinternal.h26 extern int __sync_blockdev(struct block_device *bdev, int wait);
33 static inline int __sync_blockdev(struct block_device *bdev, int wait) in __sync_blockdev() argument
/fs/ceph/
Dlocks.c14 int cmd, u8 wait, struct file_lock *fl) in ceph_lock_message() argument
38 length, wait, fl->fl_type); in ceph_lock_message()
49 req->r_args.filelock_change.wait = wait; in ceph_lock_message()
75 length, wait, fl->fl_type, err); in ceph_lock_message()
87 u8 wait = 0; in ceph_lock() local
95 wait = 1; in ceph_lock()
106 err = ceph_lock_message(CEPH_LOCK_FCNTL, op, file, lock_cmd, wait, fl); in ceph_lock()
134 u8 wait = 1; in ceph_flock() local
141 wait = 0; in ceph_flock()
153 file, lock_cmd, wait, fl); in ceph_flock()
/fs/jbd/
Dtransaction.c151 DEFINE_WAIT(wait); in start_this_handle()
154 &wait, TASK_UNINTERRUPTIBLE); in start_this_handle()
157 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
175 DEFINE_WAIT(wait); in start_this_handle()
179 prepare_to_wait(&journal->j_wait_transaction_locked, &wait, in start_this_handle()
184 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
441 DEFINE_WAIT(wait); in journal_lock_updates()
443 wait: in journal_lock_updates()
455 goto wait; in journal_lock_updates()
471 prepare_to_wait(&journal->j_wait_updates, &wait, in journal_lock_updates()
[all …]
/fs/jffs2/
Dbackground.c63 int wait = 0; in jffs2_stop_garbage_collect_thread() local
68 wait = 1; in jffs2_stop_garbage_collect_thread()
71 if (wait) in jffs2_stop_garbage_collect_thread()
/fs/btrfs/
Dordered-data.h109 wait_queue_head_t wait; member
163 struct btrfs_ordered_extent *entry, int wait);
173 void btrfs_run_ordered_operations(struct btrfs_root *root, int wait);
Dordered-data.c209 init_waitqueue_head(&entry->wait); in __btrfs_add_ordered_extent()
460 wake_up(&entry->wait); in btrfs_remove_ordered_extent()
528 void btrfs_run_ordered_operations(struct btrfs_root *root, int wait) in btrfs_run_ordered_operations() argument
554 if (!wait && inode) { in btrfs_run_ordered_operations()
561 if (wait) in btrfs_run_ordered_operations()
571 if (wait && !list_empty(&root->fs_info->ordered_operations)) in btrfs_run_ordered_operations()
587 int wait) in btrfs_start_ordered_extent() argument
601 if (wait) { in btrfs_start_ordered_extent()
602 wait_event(entry->wait, test_bit(BTRFS_ORDERED_COMPLETE, in btrfs_start_ordered_extent()
890 wake_up(&ordered->wait); in btrfs_ordered_update_i_size()
Ddelayed-inode.h47 wait_queue_head_t wait; member
91 init_waitqueue_head(&delayed_root->wait); in btrfs_init_delayed_root()
/fs/jfs/
Dinode.c82 int jfs_commit_inode(struct inode *inode, int wait) in jfs_commit_inode() argument
117 rc = txCommit(tid, 1, &inode, wait ? COMMIT_SYNC : 0); in jfs_commit_inode()
126 int wait = wbc->sync_mode == WB_SYNC_ALL; in jfs_write_inode() local
137 jfs_flush_journal(JFS_SBI(inode->i_sb)->log, wait); in jfs_write_inode()
141 if (jfs_commit_inode(inode, wait)) { in jfs_write_inode()
Djfs_metapage.c50 wake_up(&mp->wait); in unlock_metapage()
55 DECLARE_WAITQUEUE(wait, current); in __lock_metapage()
57 add_wait_queue_exclusive(&mp->wait, &wait); in __lock_metapage()
67 remove_wait_queue(&mp->wait, &wait); in __lock_metapage()
197 init_waitqueue_head(&mp->wait); in init_once()
/fs/jbd2/
Dtransaction.c228 DEFINE_WAIT(wait); in start_this_handle()
231 &wait, TASK_UNINTERRUPTIBLE); in start_this_handle()
234 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
252 DEFINE_WAIT(wait); in start_this_handle()
256 prepare_to_wait(&journal->j_wait_transaction_locked, &wait, in start_this_handle()
264 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
538 DEFINE_WAIT(wait); in jbd2_journal_lock_updates()
551 prepare_to_wait(&journal->j_wait_updates, &wait, in jbd2_journal_lock_updates()
555 finish_wait(&journal->j_wait_updates, &wait); in jbd2_journal_lock_updates()
561 finish_wait(&journal->j_wait_updates, &wait); in jbd2_journal_lock_updates()
[all …]
/fs/gfs2/
Dlog.c324 DEFINE_WAIT(wait); in gfs2_log_reserve()
335 prepare_to_wait_exclusive(&sdp->sd_log_waitq, &wait, in gfs2_log_reserve()
343 finish_wait(&sdp->sd_log_waitq, &wait); in gfs2_log_reserve()
497 DEFINE_WAIT(wait); in log_flush_wait()
501 prepare_to_wait(&sdp->sd_log_flush_wait, &wait, in log_flush_wait()
506 finish_wait(&sdp->sd_log_flush_wait, &wait); in log_flush_wait()
856 DEFINE_WAIT(wait); in gfs2_logd()
882 prepare_to_wait(&sdp->sd_logd_waitq, &wait, in gfs2_logd()
891 finish_wait(&sdp->sd_logd_waitq, &wait); in gfs2_logd()
/fs/coda/
Dpsdev.c63 static unsigned int coda_psdev_poll(struct file *file, poll_table * wait) in coda_psdev_poll() argument
68 poll_wait(file, &vcp->vc_waitq, wait); in coda_psdev_poll()
203 DECLARE_WAITQUEUE(wait, current); in coda_psdev_read()
213 add_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
231 remove_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
/fs/dlm/
Duser.c219 wake_up_interruptible(&proc->wait); in dlm_user_add_ast()
645 init_waitqueue_head(&proc->wait); in device_open()
782 DECLARE_WAITQUEUE(wait, current); in device_read()
816 add_wait_queue(&proc->wait, &wait); in device_read()
827 remove_wait_queue(&proc->wait, &wait); in device_read()
888 static unsigned int device_poll(struct file *file, poll_table *wait) in device_poll() argument
892 poll_wait(file, &proc->wait, wait); in device_poll()
/fs/proc/
Dkmsg.c42 static unsigned int kmsg_poll(struct file *file, poll_table *wait) in kmsg_poll() argument
44 poll_wait(file, &log_wait, wait); in kmsg_poll()
/fs/xfs/
Dxfs_iget.c727 DEFINE_WAIT_BIT(wait, &ip->i_flags, __XFS_IFLOCK_BIT); in __xfs_iflock()
730 prepare_to_wait_exclusive(wq, &wait.wait, TASK_UNINTERRUPTIBLE); in __xfs_iflock()
735 finish_wait(wq, &wait.wait); in __xfs_iflock()

123456