Home
last modified time | relevance | path

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

1234567

/fs/
Dfs_pin.c15 spin_lock_irq(&pin->wait.lock); in pin_remove()
17 wake_up_locked(&pin->wait); in pin_remove()
18 spin_unlock_irq(&pin->wait.lock); in pin_remove()
37 wait_queue_t wait; in pin_kill() local
43 init_wait(&wait); in pin_kill()
44 spin_lock_irq(&p->wait.lock); in pin_kill()
47 spin_unlock_irq(&p->wait.lock); in pin_kill()
53 spin_unlock_irq(&p->wait.lock); in pin_kill()
57 __add_wait_queue(&p->wait, &wait); in pin_kill()
60 spin_unlock_irq(&p->wait.lock); in pin_kill()
[all …]
Dselect.c133 remove_wait_queue(entry->wait_address, &entry->wait); in free_poll_entry()
183 static int __pollwake(wait_queue_t *wait, unsigned mode, int sync, void *key) in __pollwake() argument
185 struct poll_wqueues *pwq = wait->private; in __pollwake()
209 static int pollwake(wait_queue_t *wait, unsigned mode, int sync, void *key) in pollwake() argument
213 entry = container_of(wait, struct poll_table_entry, wait); in pollwake()
216 return __pollwake(wait, mode, sync, key); in pollwake()
230 init_waitqueue_func_entry(&entry->wait, pollwake); in __pollwait()
231 entry->wait.private = pwq; in __pollwait()
232 add_wait_queue(wait_address, &entry->wait); in __pollwait()
393 static inline void wait_key_set(poll_table *wait, unsigned long in, in wait_key_set() argument
[all …]
Deventfd.c117 static unsigned int eventfd_poll(struct file *file, poll_table *wait) in eventfd_poll() argument
123 poll_wait(file, &ctx->wqh, wait); in eventfd_poll()
194 int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_t *wait, in eventfd_ctx_remove_wait_queue() argument
201 __remove_wait_queue(&ctx->wqh, wait); in eventfd_ctx_remove_wait_queue()
227 DECLARE_WAITQUEUE(wait, current); in eventfd_ctx_read()
235 __add_wait_queue(&ctx->wqh, &wait); in eventfd_ctx_read()
250 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_ctx_read()
286 DECLARE_WAITQUEUE(wait, current); in eventfd_write()
299 __add_wait_queue(&ctx->wqh, &wait); in eventfd_write()
314 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_write()
Dpipe.c112 DEFINE_WAIT(wait); in pipe_wait()
118 prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); in pipe_wait()
121 finish_wait(&pipe->wait, &wait); in pipe_wait()
334 wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM); in pipe_read()
343 wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM); in pipe_read()
470 wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM); in pipe_write()
481 wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM); in pipe_write()
518 pipe_poll(struct file *filp, poll_table *wait) in pipe_poll() argument
524 poll_wait(filp, &pipe->wait, wait); in pipe_poll()
575 …wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLOUT | POLLRDNORM | POLLWRNORM | POLLERR … in pipe_release()
[all …]
Dsync.c30 static int __sync_filesystem(struct super_block *sb, int wait) in __sync_filesystem() argument
32 if (wait) in __sync_filesystem()
38 sb->s_op->sync_fs(sb, wait); in __sync_filesystem()
39 return __sync_blockdev(sb->s_bdev, wait); in __sync_filesystem()
109 int nowait = 0, wait = 1; in SYSCALL_DEFINE0() local
114 iterate_supers(sync_fs_one_sb, &wait); in SYSCALL_DEFINE0()
Daio.c145 wait_queue_head_t wait; member
757 init_waitqueue_head(&ctx->wait); in ioctx_alloc()
828 struct ctx_rq_wait *wait) in kill_ioctx() argument
844 wake_up_all(&ctx->wait); in kill_ioctx()
858 ctx->rq_wait = wait; in kill_ioctx()
874 struct ctx_rq_wait wait; in exit_aio() local
880 atomic_set(&wait.count, table->nr); in exit_aio()
881 init_completion(&wait.comp); in exit_aio()
901 kill_ioctx(mm, ctx, &wait); in exit_aio()
904 if (!atomic_sub_and_test(skipped, &wait.count)) { in exit_aio()
[all …]
Deventpoll.c242 wait_queue_t wait; member
347 return container_of(p, struct eppoll_entry, wait); in ep_pwq_from_wait()
353 return container_of(p, struct eppoll_entry, wait)->base; in ep_item_from_wait()
535 remove_wait_queue(whead, &pwq->wait); in ep_remove_wait_queue()
855 static unsigned int ep_eventpoll_poll(struct file *file, poll_table *wait) in ep_eventpoll_poll() argument
865 arg.locked = wait && (wait->_qproc == ep_ptable_queue_proc); in ep_eventpoll_poll()
869 poll_wait(file, &ep->poll_wait, wait); in ep_eventpoll_poll()
1010 static int ep_poll_callback(wait_queue_t *wait, unsigned mode, int sync, void *key) in ep_poll_callback() argument
1014 struct epitem *epi = ep_item_from_wait(wait); in ep_poll_callback()
1108 list_del_init(&wait->task_list); in ep_poll_callback()
[all …]
Dsignalfd.c60 static unsigned int signalfd_poll(struct file *file, poll_table *wait) in signalfd_poll() argument
65 poll_wait(file, &current->sighand->signalfd_wqh, wait); in signalfd_poll()
163 DECLARE_WAITQUEUE(wait, current); in signalfd_dequeue()
177 add_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
193 remove_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
/fs/f2fs/
Dgc.h74 unsigned int *wait) in increase_sleep_time() argument
79 if (*wait == gc_th->no_gc_sleep_time) in increase_sleep_time()
82 if ((long long)*wait + (long long)min_time > (long long)max_time) in increase_sleep_time()
83 *wait = max_time; in increase_sleep_time()
85 *wait += min_time; in increase_sleep_time()
89 unsigned int *wait) in decrease_sleep_time() argument
93 if (*wait == gc_th->no_gc_sleep_time) in decrease_sleep_time()
94 *wait = gc_th->max_sleep_time; in decrease_sleep_time()
96 if ((long long)*wait - (long long)min_time < (long long)min_time) in decrease_sleep_time()
97 *wait = min_time; in decrease_sleep_time()
[all …]
/fs/ceph/
Dlocks.c36 int cmd, u8 wait, struct file_lock *fl) in ceph_lock_message() argument
46 wait = 0; in ceph_lock_message()
66 wait, fl->fl_type); in ceph_lock_message()
74 req->r_args.filelock_change.wait = wait; in ceph_lock_message()
76 if (wait) in ceph_lock_message()
103 length, wait, fl->fl_type, err); in ceph_lock_message()
161 u8 wait = 0; in ceph_lock() local
176 wait = 1; in ceph_lock()
185 err = ceph_lock_message(CEPH_LOCK_FCNTL, op, file, lock_cmd, wait, fl); in ceph_lock()
208 u8 wait = 0; in ceph_flock() local
[all …]
/fs/squashfs/
Ddecompressor_multi.c45 wait_queue_head_t wait; member
61 wake_up(&stream->wait); in put_decomp_stream()
78 init_waitqueue_head(&stream->wait); in squashfs_decompressor_create()
151 goto wait; in get_decomp_stream()
156 goto wait; in get_decomp_stream()
162 goto wait; in get_decomp_stream()
170 wait: in get_decomp_stream()
177 wait_event(stream->wait, in get_decomp_stream()
/fs/ecryptfs/
Dkthread.c42 wait_queue_head_t wait; member
63 ecryptfs_kthread_ctl.wait, in ecryptfs_threadfn()
91 init_waitqueue_head(&ecryptfs_kthread_ctl.wait); in ecryptfs_init_kthread()
117 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_destroy_kthread()
166 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_privileged_open()
/fs/orangefs/
Dorangefs-bufmap.c45 DEFINE_WAIT(wait); in run_down()
49 if (likely(list_empty(&wait.task_list))) in run_down()
50 __add_wait_queue_tail(&m->q, &wait); in run_down()
60 __remove_wait_queue(&m->q, &wait); in run_down()
83 DEFINE_WAIT(wait); in wait_for_free()
87 if (likely(list_empty(&wait.task_list))) in wait_for_free()
88 __add_wait_queue_tail_exclusive(&m->q, &wait); in wait_for_free()
111 if (!list_empty(&wait.task_list)) in wait_for_free()
112 list_del(&wait.task_list); in wait_for_free()
/fs/crypto/
Dfname.c41 DECLARE_CRYPTO_WAIT(wait); in fname_encrypt()
68 crypto_req_done, &wait); in fname_encrypt()
73 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fname_encrypt()
96 DECLARE_CRYPTO_WAIT(wait); in fname_decrypt()
117 crypto_req_done, &wait); in fname_decrypt()
126 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fname_decrypt()
Dcrypto.c146 DECLARE_CRYPTO_WAIT(wait); in fscrypt_do_page_crypto()
174 crypto_req_done, &wait); in fscrypt_do_page_crypto()
182 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fscrypt_do_page_crypto()
184 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fscrypt_do_page_crypto()
/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/jfs/
Dinode.c85 int jfs_commit_inode(struct inode *inode, int wait) in jfs_commit_inode() argument
120 rc = txCommit(tid, 1, &inode, wait ? COMMIT_SYNC : 0); in jfs_commit_inode()
129 int wait = wbc->sync_mode == WB_SYNC_ALL; in jfs_write_inode() local
140 jfs_flush_journal(JFS_SBI(inode->i_sb)->log, wait); in jfs_write_inode()
144 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()
196 init_waitqueue_head(&mp->wait); in alloc_metapage()
/fs/coda/
Dpsdev.c64 static unsigned int coda_psdev_poll(struct file *file, poll_table * wait) in coda_psdev_poll() argument
69 poll_wait(file, &vcp->vc_waitq, wait); in coda_psdev_poll()
206 DECLARE_WAITQUEUE(wait, current); in coda_psdev_read()
216 add_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
234 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()
651 init_waitqueue_head(&proc->wait); in device_open()
781 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/gfs2/
Dlog.c345 DEFINE_WAIT(wait); in gfs2_log_reserve()
356 prepare_to_wait_exclusive(&sdp->sd_log_waitq, &wait, in gfs2_log_reserve()
364 finish_wait(&sdp->sd_log_waitq, &wait); in gfs2_log_reserve()
503 DEFINE_WAIT(wait); in log_flush_wait()
507 prepare_to_wait(&sdp->sd_log_flush_wait, &wait, in log_flush_wait()
512 finish_wait(&sdp->sd_log_flush_wait, &wait); in log_flush_wait()
915 DEFINE_WAIT(wait); in gfs2_logd()
939 prepare_to_wait(&sdp->sd_logd_waitq, &wait, in gfs2_logd()
948 finish_wait(&sdp->sd_logd_waitq, &wait); in gfs2_logd()
/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/btrfs/
Dordered-data.c215 init_waitqueue_head(&entry->wait); in __btrfs_add_ordered_extent()
352 if (waitqueue_active(&entry->wait)) in btrfs_dec_test_first_ordered_pending()
353 wake_up(&entry->wait); in btrfs_dec_test_first_ordered_pending()
419 if (waitqueue_active(&entry->wait)) in btrfs_dec_test_ordered_pending()
420 wake_up(&entry->wait); in btrfs_dec_test_ordered_pending()
510 wait_event(ordered->wait, test_bit(BTRFS_ORDERED_IO_DONE, in btrfs_wait_logged_extents()
648 wake_up(&entry->wait); in btrfs_remove_ordered_extent()
770 int wait) in btrfs_start_ordered_extent() argument
784 if (wait) { in btrfs_start_ordered_extent()
785 wait_event(entry->wait, test_bit(BTRFS_ORDERED_COMPLETE, in btrfs_start_ordered_extent()
Ddelayed-inode.h48 wait_queue_head_t wait; member
96 init_waitqueue_head(&delayed_root->wait); in btrfs_init_delayed_root()
/fs/notify/inotify/
Dinotify_user.c112 static unsigned int inotify_poll(struct file *file, poll_table *wait) in inotify_poll() argument
117 poll_wait(file, &group->notification_waitq, wait); in inotify_poll()
230 DEFINE_WAIT_FUNC(wait, woken_wake_function); in inotify_read()
235 add_wait_queue(&group->notification_waitq, &wait); in inotify_read()
266 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT); in inotify_read()
268 remove_wait_queue(&group->notification_waitq, &wait); in inotify_read()

1234567