Home
last modified time | relevance | path

Searched refs:wait (Results 1 – 25 of 156) 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.c132 static __poll_t eventfd_poll(struct file *file, poll_table *wait) in eventfd_poll() argument
138 poll_wait(file, &ctx->wqh, wait); in eventfd_poll()
212 int eventfd_ctx_remove_wait_queue(struct eventfd_ctx *ctx, wait_queue_entry_t *wait, in eventfd_ctx_remove_wait_queue() argument
219 __remove_wait_queue(&ctx->wqh, wait); in eventfd_ctx_remove_wait_queue()
233 DECLARE_WAITQUEUE(wait, current); in eventfd_read()
244 __add_wait_queue(&ctx->wqh, &wait); in eventfd_read()
250 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_read()
259 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_read()
278 DECLARE_WAITQUEUE(wait, current); in eventfd_write()
291 __add_wait_queue(&ctx->wqh, &wait); in eventfd_write()
[all …]
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()
467 static inline void wait_key_set(poll_table *wait, unsigned long in, in wait_key_set() argument
[all …]
Daio.c155 wait_queue_head_t wait; member
188 struct wait_queue_entry wait; member
758 init_waitqueue_head(&ctx->wait); in ioctx_alloc()
829 struct ctx_rq_wait *wait) in kill_ioctx() argument
845 wake_up_all(&ctx->wait); in kill_ioctx()
859 ctx->rq_wait = wait; in kill_ioctx()
875 struct ctx_rq_wait wait; in exit_aio() local
881 atomic_set(&wait.count, table->nr); in exit_aio()
882 init_completion(&wait.comp); in exit_aio()
902 kill_ioctx(mm, ctx, &wait); in exit_aio()
[all …]
Deventpoll.c249 wait_queue_entry_t wait; member
348 return container_of(p, struct eppoll_entry, wait); in ep_pwq_from_wait()
354 return container_of(p, struct eppoll_entry, wait)->base; in ep_item_from_wait()
614 remove_wait_queue(whead, &pwq->wait); in ep_remove_wait_queue()
934 static __poll_t ep_eventpoll_poll(struct file *file, poll_table *wait) in ep_eventpoll_poll() argument
940 poll_wait(file, &ep->poll_wait, wait); in ep_eventpoll_poll()
1215 static int ep_poll_callback(wait_queue_entry_t *wait, unsigned mode, int sync, void *key) in ep_poll_callback() argument
1218 struct epitem *epi = ep_item_from_wait(wait); in ep_poll_callback()
1303 list_del_init(&wait->entry); in ep_poll_callback()
1310 smp_store_release(&ep_pwq_from_wait(wait)->whead, NULL); in ep_poll_callback()
[all …]
Dsignalfd.c51 static __poll_t signalfd_poll(struct file *file, poll_table *wait) in signalfd_poll() argument
56 poll_wait(file, &current->sighand->signalfd_wqh, wait); in signalfd_poll()
160 DECLARE_WAITQUEUE(wait, current); in signalfd_dequeue()
175 add_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
191 remove_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
Ddax.c143 wait_queue_entry_t wait; member
177 static int wake_exceptional_entry_func(wait_queue_entry_t *wait, in wake_exceptional_entry_func() argument
182 container_of(wait, struct wait_exceptional_entry_queue, wait); in wake_exceptional_entry_func()
187 return autoremove_wake_function(wait, mode, sync, NULL); in wake_exceptional_entry_func()
229 init_wait(&ewait.wait); in get_unlocked_entry()
230 ewait.wait.func = wake_exceptional_entry_func; in get_unlocked_entry()
242 prepare_to_wait_exclusive(wq, &ewait.wait, in get_unlocked_entry()
247 finish_wait(wq, &ewait.wait); in get_unlocked_entry()
262 init_wait(&ewait.wait); in wait_entry_unlocked()
263 ewait.wait.func = wake_exceptional_entry_func; in wait_entry_unlocked()
[all …]
/fs/f2fs/
Dgc.h136 unsigned int *wait) in increase_sleep_time() argument
141 if (*wait == gc_th->no_gc_sleep_time) in increase_sleep_time()
144 if ((long long)*wait + (long long)min_time > (long long)max_time) in increase_sleep_time()
145 *wait = max_time; in increase_sleep_time()
147 *wait += min_time; in increase_sleep_time()
151 unsigned int *wait) in decrease_sleep_time() argument
155 if (*wait == gc_th->no_gc_sleep_time) in decrease_sleep_time()
156 *wait = gc_th->max_sleep_time; in decrease_sleep_time()
158 if ((long long)*wait - (long long)min_time < (long long)min_time) in decrease_sleep_time()
159 *wait = min_time; in decrease_sleep_time()
[all …]
/fs/verity/
Dhash_algs.c164 DECLARE_CRYPTO_WAIT(wait); in fsverity_prepare_hash_state()
195 crypto_req_done, &wait); in fsverity_prepare_hash_state()
198 err = crypto_wait_req(crypto_ahash_init(req), &wait); in fsverity_prepare_hash_state()
202 err = crypto_wait_req(crypto_ahash_update(req), &wait); in fsverity_prepare_hash_state()
238 DECLARE_CRYPTO_WAIT(wait); in fsverity_hash_page()
248 crypto_req_done, &wait); in fsverity_hash_page()
263 err = crypto_wait_req(err, &wait); in fsverity_hash_page()
286 DECLARE_CRYPTO_WAIT(wait); in fsverity_hash_buffer()
295 crypto_req_done, &wait); in fsverity_hash_buffer()
298 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.c60 int cmd, u8 wait, struct file_lock *fl) in ceph_lock_message() argument
80 wait = 0; in ceph_lock_message()
100 wait, fl->fl_type); in ceph_lock_message()
108 req->r_args.filelock_change.wait = wait; in ceph_lock_message()
110 if (wait) in ceph_lock_message()
136 length, wait, fl->fl_type, err); in ceph_lock_message()
234 u8 wait = 0; in ceph_lock() local
249 wait = 1; in ceph_lock()
275 err = ceph_lock_message(CEPH_LOCK_FCNTL, op, inode, lock_cmd, wait, fl); in ceph_lock()
299 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.c90 DECLARE_CRYPTO_WAIT(wait); in fscrypt_fname_encrypt()
115 crypto_req_done, &wait); in fscrypt_fname_encrypt()
120 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fscrypt_fname_encrypt()
145 DECLARE_CRYPTO_WAIT(wait); in fname_decrypt()
158 crypto_req_done, &wait); in fname_decrypt()
167 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fname_decrypt()
Dcrypto.c108 DECLARE_CRYPTO_WAIT(wait); in fscrypt_crypt_block()
127 crypto_req_done, &wait); in fscrypt_crypt_block()
135 res = crypto_wait_req(crypto_skcipher_decrypt(req), &wait); in fscrypt_crypt_block()
137 res = crypto_wait_req(crypto_skcipher_encrypt(req), &wait); in fscrypt_crypt_block()
/fs/xfs/
Dxfs_extent_busy.c587 DEFINE_WAIT (wait); in xfs_extent_busy_flush()
595 prepare_to_wait(&pag->pagb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_flush()
601 finish_wait(&pag->pagb_wait, &wait); in xfs_extent_busy_flush()
608 DEFINE_WAIT (wait); in xfs_extent_busy_wait_all()
615 prepare_to_wait(&pag->pagb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_wait_all()
620 finish_wait(&pag->pagb_wait, &wait); in xfs_extent_busy_wait_all()
/fs/btrfs/
Dzstd.c81 wait_queue_head_t wait; member
179 init_waitqueue_head(&wsm.wait); in zstd_init_workspace_manager()
282 DEFINE_WAIT(wait); in zstd_get_workspace()
284 prepare_to_wait(&wsm.wait, &wait, TASK_UNINTERRUPTIBLE); in zstd_get_workspace()
286 finish_wait(&wsm.wait, &wait); in zstd_get_workspace()
331 cond_wake_up(&wsm.wait); in zstd_put_workspace()
Dspace-info.c393 wake_up(&ticket->wait); in btrfs_try_granting_tickets()
837 wake_up(&ticket->wait); in steal_from_global_rsv()
903 wake_up(&ticket->wait); in maybe_fail_all_tickets()
1188 DEFINE_WAIT(wait); in wait_reserve_ticket()
1193 ret = prepare_to_wait_event(&ticket->wait, &wait, TASK_KILLABLE); in wait_reserve_ticket()
1211 finish_wait(&ticket->wait, &wait); in wait_reserve_ticket()
1368 init_waitqueue_head(&ticket.wait); in __reserve_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/dlm/
Dplock.c124 op->info.wait = IS_SETLKW(cmd); in dlm_posix_lock()
453 if (info.wait) { in dev_write()
462 iter->info.wait) { in dev_write()
469 if (!iter->info.wait && in dev_write()
479 if (info.wait) in dev_write()
506 static __poll_t dev_poll(struct file *file, poll_table *wait) in dev_poll() argument
510 poll_wait(file, &send_wq, wait); in dev_poll()
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/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()
Djfs_metapage.c37 wake_up(&mp->wait); in unlock_metapage()
42 DECLARE_WAITQUEUE(wait, current); in __lock_metapage()
44 add_wait_queue_exclusive(&mp->wait, &wait); in __lock_metapage()
54 remove_wait_queue(&mp->wait, &wait); in __lock_metapage()
183 init_waitqueue_head(&mp->wait); in alloc_metapage()
/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