Home
last modified time | relevance | path

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

1234567

/fs/
Dfs_pin.c16 spin_lock_irq(&pin->wait.lock); in pin_remove()
18 wake_up_locked(&pin->wait); in pin_remove()
19 spin_unlock_irq(&pin->wait.lock); in pin_remove()
32 wait_queue_entry_t wait; in pin_kill() local
38 init_wait(&wait); in pin_kill()
39 spin_lock_irq(&p->wait.lock); in pin_kill()
42 spin_unlock_irq(&p->wait.lock); in pin_kill()
48 spin_unlock_irq(&p->wait.lock); in pin_kill()
52 __add_wait_queue(&p->wait, &wait); in pin_kill()
55 spin_unlock_irq(&p->wait.lock); in pin_kill()
[all …]
Deventfd.c111 static __poll_t eventfd_poll(struct file *file, poll_table *wait) in eventfd_poll() argument
117 poll_wait(file, &ctx->wqh, wait); in eventfd_poll()
188 int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_entry_t *wait, in eventfd_ctx_remove_wait_queue() argument
195 __remove_wait_queue(&ctx->wqh, wait); in eventfd_ctx_remove_wait_queue()
210 DECLARE_WAITQUEUE(wait, current); in eventfd_read()
220 __add_wait_queue(&ctx->wqh, &wait); in eventfd_read()
235 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_read()
257 DECLARE_WAITQUEUE(wait, current); in eventfd_write()
270 __add_wait_queue(&ctx->wqh, &wait); in eventfd_write()
285 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_write()
Dselect.c134 remove_wait_queue(entry->wait_address, &entry->wait); in free_poll_entry()
184 static int __pollwake(wait_queue_entry_t *wait, unsigned mode, int sync, void *key) in __pollwake() argument
186 struct poll_wqueues *pwq = wait->private; in __pollwake()
210 static int pollwake(wait_queue_entry_t *wait, unsigned mode, int sync, void *key) in pollwake() argument
214 entry = container_of(wait, struct poll_table_entry, wait); in pollwake()
217 return __pollwake(wait, mode, sync, key); in pollwake()
231 init_waitqueue_func_entry(&entry->wait, pollwake); in __pollwait()
232 entry->wait.private = pwq; in __pollwait()
233 add_wait_queue(wait_address, &entry->wait); in __pollwait()
465 static inline void wait_key_set(poll_table *wait, unsigned long in, in wait_key_set() argument
[all …]
Dpipe.c109 DEFINE_WAIT(wait); in pipe_wait()
115 prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); in pipe_wait()
118 finish_wait(&pipe->wait, &wait); in pipe_wait()
356 wake_up_interruptible_sync_poll(&pipe->wait, EPOLLOUT | EPOLLWRNORM); in pipe_read()
365 wake_up_interruptible_sync_poll(&pipe->wait, EPOLLOUT | EPOLLWRNORM); in pipe_read()
492 wake_up_interruptible_sync_poll(&pipe->wait, EPOLLIN | EPOLLRDNORM); in pipe_write()
503 wake_up_interruptible_sync_poll(&pipe->wait, EPOLLIN | EPOLLRDNORM); in pipe_write()
540 pipe_poll(struct file *filp, poll_table *wait) in pipe_poll() argument
546 poll_wait(filp, &pipe->wait, wait); in pipe_poll()
597 …wake_up_interruptible_sync_poll(&pipe->wait, EPOLLIN | EPOLLOUT | EPOLLRDNORM | EPOLLWRNORM | EPOL… in pipe_release()
[all …]
Daio.c156 wait_queue_head_t wait; member
187 struct wait_queue_entry wait; member
746 init_waitqueue_head(&ctx->wait); in ioctx_alloc()
817 struct ctx_rq_wait *wait) in kill_ioctx() argument
833 wake_up_all(&ctx->wait); in kill_ioctx()
847 ctx->rq_wait = wait; in kill_ioctx()
863 struct ctx_rq_wait wait; in exit_aio() local
869 atomic_set(&wait.count, table->nr); in exit_aio()
870 init_completion(&wait.comp); in exit_aio()
890 kill_ioctx(mm, ctx, &wait); in exit_aio()
[all …]
Dsync.c31 static int __sync_filesystem(struct super_block *sb, int wait) in __sync_filesystem() argument
33 if (wait) in __sync_filesystem()
39 sb->s_op->sync_fs(sb, wait); in __sync_filesystem()
40 return __sync_blockdev(sb->s_bdev, wait); in __sync_filesystem()
110 int nowait = 0, wait = 1; in ksys_sync() local
115 iterate_supers(sync_fs_one_sb, &wait); in ksys_sync()
Deventpoll.c243 wait_queue_entry_t wait; member
343 return container_of(p, struct eppoll_entry, wait); in ep_pwq_from_wait()
349 return container_of(p, struct eppoll_entry, wait)->base; in ep_item_from_wait()
601 remove_wait_queue(whead, &pwq->wait); in ep_remove_wait_queue()
931 static __poll_t ep_eventpoll_poll(struct file *file, poll_table *wait) in ep_eventpoll_poll() argument
937 poll_wait(file, &ep->poll_wait, wait); in ep_eventpoll_poll()
1208 static int ep_poll_callback(wait_queue_entry_t *wait, unsigned mode, int sync, void *key) in ep_poll_callback() argument
1211 struct epitem *epi = ep_item_from_wait(wait); in ep_poll_callback()
1300 list_del_init(&wait->entry); in ep_poll_callback()
1307 smp_store_release(&ep_pwq_from_wait(wait)->whead, NULL); in ep_poll_callback()
[all …]
Dsignalfd.c61 static __poll_t signalfd_poll(struct file *file, poll_table *wait) in signalfd_poll() argument
66 poll_wait(file, &current->sighand->signalfd_wqh, wait); in signalfd_poll()
170 DECLARE_WAITQUEUE(wait, current); in signalfd_dequeue()
185 add_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
201 remove_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
Ddax.c143 wait_queue_entry_t wait; member
167 static int wake_exceptional_entry_func(wait_queue_entry_t *wait, in wake_exceptional_entry_func() argument
172 container_of(wait, struct wait_exceptional_entry_queue, wait); in wake_exceptional_entry_func()
177 return autoremove_wake_function(wait, mode, sync, NULL); in wake_exceptional_entry_func()
218 init_wait(&ewait.wait); in get_unlocked_entry()
219 ewait.wait.func = wake_exceptional_entry_func; in get_unlocked_entry()
231 prepare_to_wait_exclusive(wq, &ewait.wait, in get_unlocked_entry()
236 finish_wait(wq, &ewait.wait); in get_unlocked_entry()
251 init_wait(&ewait.wait); in wait_entry_unlocked()
252 ewait.wait.func = wake_exceptional_entry_func; in wait_entry_unlocked()
[all …]
/fs/f2fs/
Dgc.h69 unsigned int *wait) in increase_sleep_time() argument
74 if (*wait == gc_th->no_gc_sleep_time) in increase_sleep_time()
77 if ((long long)*wait + (long long)min_time > (long long)max_time) in increase_sleep_time()
78 *wait = max_time; in increase_sleep_time()
80 *wait += min_time; in increase_sleep_time()
84 unsigned int *wait) in decrease_sleep_time() argument
88 if (*wait == gc_th->no_gc_sleep_time) in decrease_sleep_time()
89 *wait = gc_th->max_sleep_time; in decrease_sleep_time()
91 if ((long long)*wait - (long long)min_time < (long long)min_time) in decrease_sleep_time()
92 *wait = min_time; in decrease_sleep_time()
[all …]
/fs/verity/
Dhash_algs.c112 DECLARE_CRYPTO_WAIT(wait); in fsverity_prepare_hash_state()
146 crypto_req_done, &wait); in fsverity_prepare_hash_state()
149 err = crypto_wait_req(crypto_ahash_init(req), &wait); in fsverity_prepare_hash_state()
153 err = crypto_wait_req(crypto_ahash_update(req), &wait); in fsverity_prepare_hash_state()
189 DECLARE_CRYPTO_WAIT(wait); in fsverity_hash_page()
199 crypto_req_done, &wait); in fsverity_hash_page()
214 err = crypto_wait_req(err, &wait); in fsverity_hash_page()
237 DECLARE_CRYPTO_WAIT(wait); in fsverity_hash_buffer()
247 crypto_req_done, &wait); in fsverity_hash_buffer()
250 err = crypto_wait_req(crypto_ahash_digest(req), &wait); in fsverity_hash_buffer()
/fs/squashfs/
Ddecompressor_multi.c43 wait_queue_head_t wait; member
59 wake_up(&stream->wait); in put_decomp_stream()
76 init_waitqueue_head(&stream->wait); in squashfs_decompressor_create()
149 goto wait; in get_decomp_stream()
154 goto wait; in get_decomp_stream()
160 goto wait; in get_decomp_stream()
168 wait: in get_decomp_stream()
175 wait_event(stream->wait, in get_decomp_stream()
/fs/ceph/
Dlocks.c64 int cmd, u8 wait, struct file_lock *fl) in ceph_lock_message() argument
84 wait = 0; in ceph_lock_message()
104 wait, fl->fl_type); in ceph_lock_message()
112 req->r_args.filelock_change.wait = wait; in ceph_lock_message()
114 if (wait) in ceph_lock_message()
140 length, wait, fl->fl_type, err); in ceph_lock_message()
223 u8 wait = 0; in ceph_lock() local
238 wait = 1; in ceph_lock()
258 err = ceph_lock_message(CEPH_LOCK_FCNTL, op, inode, lock_cmd, wait, fl); in ceph_lock()
282 u8 wait = 0; in ceph_flock() local
[all …]
/fs/ecryptfs/
Dkthread.c28 wait_queue_head_t wait; member
49 ecryptfs_kthread_ctl.wait, in ecryptfs_threadfn()
77 init_waitqueue_head(&ecryptfs_kthread_ctl.wait); in ecryptfs_init_kthread()
103 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_destroy_kthread()
152 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_privileged_open()
/fs/orangefs/
Dorangefs-bufmap.c46 DEFINE_WAIT(wait); in run_down()
50 if (likely(list_empty(&wait.entry))) in run_down()
51 __add_wait_queue_entry_tail(&m->q, &wait); in run_down()
61 __remove_wait_queue(&m->q, &wait); in run_down()
84 DEFINE_WAIT(wait); in wait_for_free()
88 if (likely(list_empty(&wait.entry))) in wait_for_free()
89 __add_wait_queue_entry_tail_exclusive(&m->q, &wait); in wait_for_free()
112 if (!list_empty(&wait.entry)) in wait_for_free()
113 list_del(&wait.entry); in wait_for_free()
/fs/crypto/
Dfname.c41 DECLARE_CRYPTO_WAIT(wait); in fname_encrypt()
66 crypto_req_done, &wait); in fname_encrypt()
71 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fname_encrypt()
93 DECLARE_CRYPTO_WAIT(wait); in fname_decrypt()
106 crypto_req_done, &wait); in fname_decrypt()
115 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fname_decrypt()
Dcrypto.c97 DECLARE_CRYPTO_WAIT(wait); in fscrypt_crypt_block()
116 crypto_req_done, &wait); in fscrypt_crypt_block()
124 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fscrypt_crypt_block()
126 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fscrypt_crypt_block()
/fs/xfs/
Dxfs_extent_busy.c601 DEFINE_WAIT (wait); in xfs_extent_busy_flush()
609 prepare_to_wait(&pag->pagb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_flush()
615 finish_wait(&pag->pagb_wait, &wait); in xfs_extent_busy_flush()
622 DEFINE_WAIT (wait); in xfs_extent_busy_wait_all()
629 prepare_to_wait(&pag->pagb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_wait_all()
634 finish_wait(&pag->pagb_wait, &wait); in xfs_extent_busy_wait_all()
/fs/btrfs/
Dzstd.c81 wait_queue_head_t wait; member
180 init_waitqueue_head(&wsm.wait); in zstd_init_workspace_manager()
283 DEFINE_WAIT(wait); in zstd_get_workspace()
285 prepare_to_wait(&wsm.wait, &wait, TASK_UNINTERRUPTIBLE); in zstd_get_workspace()
287 finish_wait(&wsm.wait, &wait); in zstd_get_workspace()
332 cond_wake_up(&wsm.wait); in zstd_put_workspace()
Dspace-info.c61 init_waitqueue_head(&space_info->wait); in create_space_info()
239 wake_up(&ticket->wait); in btrfs_try_granting_tickets()
739 wake_up(&ticket->wait); in maybe_fail_all_tickets()
889 DEFINE_WAIT(wait); in wait_reserve_ticket()
894 ret = prepare_to_wait_event(&ticket->wait, &wait, TASK_KILLABLE); in wait_reserve_ticket()
912 finish_wait(&ticket->wait, &wait); in wait_reserve_ticket()
1035 init_waitqueue_head(&ticket.wait); in __reserve_metadata_bytes()
/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/coda/
Dpsdev.c58 static __poll_t coda_psdev_poll(struct file *file, poll_table * wait) in coda_psdev_poll() argument
63 poll_wait(file, &vcp->vc_waitq, wait); in coda_psdev_poll()
211 DECLARE_WAITQUEUE(wait, current); in coda_psdev_read()
221 add_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
239 remove_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
/fs/jfs/
Dinode.c73 int jfs_commit_inode(struct inode *inode, int wait) in jfs_commit_inode() argument
108 rc = txCommit(tid, 1, &inode, wait ? COMMIT_SYNC : 0); in jfs_commit_inode()
117 int wait = wbc->sync_mode == WB_SYNC_ALL; in jfs_write_inode() local
128 jfs_flush_journal(JFS_SBI(inode->i_sb)->log, wait); in jfs_write_inode()
132 if (jfs_commit_inode(inode, wait)) { in jfs_write_inode()
/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 __poll_t 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.c43 static __poll_t kmsg_poll(struct file *file, poll_table *wait) in kmsg_poll() argument
45 poll_wait(file, &log_wait, wait); in kmsg_poll()

1234567