Home
last modified time | relevance | path

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

1234567

/fs/
A 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 …]
A Dselect.c212 entry = container_of(wait, struct poll_table_entry, wait); in pollwake()
230 entry->wait.private = pwq; in __pollwait()
476 wait->_key |= POLLIN_SET; in select_poll_one()
487 poll_table *wait; in do_select() local
502 wait = &table.pt; in do_select()
504 wait->_qproc = NULL; in do_select()
541 wait->_qproc = NULL; in do_select()
546 wait->_qproc = NULL; in do_select()
551 wait->_qproc = NULL; in do_select()
574 wait->_qproc = NULL; in do_select()
[all …]
A Daio.c154 wait_queue_head_t wait; member
187 struct wait_queue_entry wait; member
865 wake_up_all(&ctx->wait); in kill_ioctx()
879 ctx->rq_wait = wait; in kill_ioctx()
895 struct ctx_rq_wait wait; in exit_aio() local
902 init_completion(&wait.comp); in exit_aio()
922 kill_ioctx(mm, ctx, &wait); in exit_aio()
1455 struct ctx_rq_wait wait; in SYSCALL_DEFINE1() local
1458 init_completion(&wait.comp); in SYSCALL_DEFINE1()
1459 atomic_set(&wait.count, 1); in SYSCALL_DEFINE1()
[all …]
A Deventpoll.c119 wait_queue_entry_t wait; member
676 remove_wait_queue(whead, &pwq->wait); in ep_remove_wait_queue()
984 poll_wait(file, &ep->poll_wait, wait); in __ep_eventpoll_poll()
1428 list_del_init(&wait->entry); in ep_poll_callback()
1467 add_wait_queue(whead, &pwq->wait); in ep_ptable_queue_proc()
2028 wait_queue_entry_t wait; in ep_poll() local
2089 init_wait(&wait); in ep_poll()
2090 wait.func = ep_autoremove_wake_function; in ep_poll()
2126 if (!list_empty_careful(&wait.entry)) { in ep_poll()
2136 eavail = list_empty(&wait.entry); in ep_poll()
[all …]
A 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()
159 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()
/fs/f2fs/
A Dgc.h146 unsigned int *wait) in increase_sleep_time() argument
151 if (*wait == gc_th->no_gc_sleep_time) in increase_sleep_time()
154 if ((long long)*wait + (long long)min_time > (long long)max_time) in increase_sleep_time()
155 *wait = max_time; in increase_sleep_time()
157 *wait += min_time; in increase_sleep_time()
161 unsigned int *wait) in decrease_sleep_time() argument
165 if (*wait == gc_th->no_gc_sleep_time) in decrease_sleep_time()
166 *wait = gc_th->max_sleep_time; in decrease_sleep_time()
168 if ((long long)*wait - (long long)min_time < (long long)min_time) in decrease_sleep_time()
169 *wait = min_time; in decrease_sleep_time()
[all …]
/fs/bcachefs/
A Dthread_with_file.c100 init_waitqueue_head(&buf->wait); in stdio_buf_init()
110 wake_up(&thr->stdio.input.wait); in thread_with_stdio_done()
111 wake_up(&thr->stdio.output.wait); in thread_with_stdio_done()
207 wake_up(&buf->wait); in thread_with_stdio_write()
214 ret = wait_event_interruptible(buf->wait, in thread_with_stdio_write()
229 poll_wait(file, &thr->stdio.output.wait, wait); in thread_with_stdio_poll()
230 poll_wait(file, &thr->stdio.input.wait, wait); in thread_with_stdio_poll()
248 poll_wait(file, &thr->stdio.output.wait, wait); in thread_with_stdout_poll()
361 wake_up(&buf->wait); in bch2_stdio_redirect_read()
419 wake_up(&buf->wait); in bch2_stdio_redirect_readline_timeout()
[all …]
A Dsix.h213 struct six_lock_waiter *wait,
232 struct six_lock_waiter *wait, in six_lock_waiter() argument
235 return six_lock_ip_waiter(lock, type, wait, should_sleep_fn, p, _THIS_IP_); in six_lock_waiter()
253 struct six_lock_waiter wait; in six_lock_ip() local
255 return six_lock_ip_waiter(lock, type, &wait, should_sleep_fn, p, ip); in six_lock_ip()
271 struct six_lock_waiter wait; in six_lock_type() local
273 return six_lock_ip_waiter(lock, type, &wait, should_sleep_fn, p, _THIS_IP_); in six_lock_type()
327 struct six_lock_waiter *wait, \
331 return six_lock_ip_waiter(lock, SIX_LOCK_##type, wait, should_sleep_fn, p, ip);\
A Dsix.c348 struct six_lock_waiter *wait, in six_optimistic_spin() argument
398 struct six_lock_waiter *wait, in six_optimistic_spin() argument
408 struct six_lock_waiter *wait, in six_lock_slowpath() argument
423 wait->task = current; in six_lock_slowpath()
424 wait->lock_want = type; in six_lock_slowpath()
425 wait->lock_acquired = false; in six_lock_slowpath()
435 wait->start_time = local_clock(); in six_lock_slowpath()
486 acquired = wait->lock_acquired; in six_lock_slowpath()
488 list_del(&wait->list); in six_lock_slowpath()
541 struct six_lock_waiter *wait, in six_lock_ip_waiter() argument
[all …]
A Dclock.c62 struct io_clock_wait *wait = container_of(timer, in io_clock_wait_fn() local
65 wait->expired = 1; in io_clock_wait_fn()
66 wake_up_process(wait->task); in io_clock_wait_fn()
71 struct io_clock_wait wait = { in bch2_io_clock_schedule_timeout() local
78 bch2_io_timer_add(clock, &wait.io_timer); in bch2_io_clock_schedule_timeout()
80 bch2_io_timer_del(clock, &wait.io_timer); in bch2_io_clock_schedule_timeout()
87 struct io_clock_wait wait = { in bch2_kthread_io_clock_wait_once() local
94 bch2_io_timer_add(clock, &wait.io_timer); in bch2_kthread_io_clock_wait_once()
103 bch2_io_timer_del(clock, &wait.io_timer); in bch2_kthread_io_clock_wait_once()
A Dmovinggc.c294 u64 wait = U64_MAX; in bch2_copygc_wait_amount() local
298 wait = min(wait, bch2_copygc_dev_wait_amount(ca)); in bch2_copygc_wait_amount()
299 return wait; in bch2_copygc_wait_amount()
351 u64 last, wait; in bch2_copygc_thread() local
394 wait = bch2_copygc_wait_amount(c); in bch2_copygc_thread()
396 if (wait > clock->max_slop) { in bch2_copygc_thread()
398 c->copygc_wait = last + wait; in bch2_copygc_thread()
400 trace_and_count(c, copygc_wait, c, wait, last + wait); in bch2_copygc_thread()
401 bch2_kthread_io_clock_wait(clock, last + wait, in bch2_copygc_thread()
414 if (!wait && !did_work) { in bch2_copygc_thread()
A Dtwo_state_shared_lock.h17 wait_queue_head_t wait; member
23 init_waitqueue_head(&lock->wait); in two_state_lock_init()
33 wake_up_all(&lock->wait); in bch2_two_state_unlock()
A Dmove.h38 wait_queue_head_t wait; member
51 _ret = __wait_event_timeout((_ctxt)->wait, \
68 __wait_event((_ctxt)->wait, \
/fs/squashfs/
A Ddecompressor_multi.c42 wait_queue_head_t wait; member
58 wake_up(&stream->wait); in put_decomp_stream()
75 init_waitqueue_head(&stream->wait); in squashfs_decompressor_create()
148 goto wait; in get_decomp_stream()
153 goto wait; in get_decomp_stream()
159 goto wait; in get_decomp_stream()
167 wait: in get_decomp_stream()
174 wait_event(stream->wait, in get_decomp_stream()
/fs/ceph/
A Dlocks.c77 int cmd, u8 wait, struct file_lock *fl) in ceph_lock_message() argument
98 wait = 0; in ceph_lock_message()
119 fl->fl_start, length, wait, fl->c.flc_type); in ceph_lock_message()
127 req->r_args.filelock_change.wait = wait; in ceph_lock_message()
131 err = ceph_mdsc_wait_request(mdsc, req, wait ? in ceph_lock_message()
155 fl->fl_start, length, wait, fl->c.flc_type, err); in ceph_lock_message()
254 u8 wait = 0; in ceph_lock() local
269 wait = 1; in ceph_lock()
320 u8 wait = 0; in ceph_flock() local
343 wait = 1; in ceph_flock()
[all …]
/fs/ecryptfs/
A 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()
153 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_privileged_open()
/fs/orangefs/
A 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/dlm/
A Dplock.c59 iter->info.wait) { in plock_lookup_waiter()
111 op->info.wait = 0; in do_lock_cancel()
143 op->info.wait = !!(fl->c.flc_flags & FL_SLEEP); in dlm_posix_lock()
173 if (op->info.wait) { in dlm_posix_lock()
204 goto wait; in dlm_posix_lock()
214 wait: in dlm_posix_lock()
545 if (info.wait) { in dev_write()
549 if (!iter->info.wait && in dev_write()
559 if (info.wait) in dev_write()
586 static __poll_t dev_poll(struct file *file, poll_table *wait) in dev_poll() argument
[all …]
/fs/ubifs/
A Dcompress.c95 DECLARE_CRYPTO_WAIT(wait); in ubifs_compress_common()
111 crypto_req_done, &wait); in ubifs_compress_common()
113 err = crypto_wait_req(err, &wait); in ubifs_compress_common()
224 DECLARE_CRYPTO_WAIT(wait); in ubifs_decompress_common()
227 crypto_req_done, &wait); in ubifs_decompress_common()
241 err = crypto_wait_req(err, &wait); in ubifs_decompress_common()
/fs/erofs/
A Ddecompressor_crypto.c11 struct crypto_wait wait; in __z_erofs_crypto_decompress() local
40 crypto_init_wait(&wait); in __z_erofs_crypto_decompress()
42 crypto_req_done, &wait); in __z_erofs_crypto_decompress()
44 ret = crypto_wait_req(crypto_acomp_decompress(req), &wait); in __z_erofs_crypto_decompress()
/fs/jffs2/
A 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/xfs/
A Dxfs_extent_busy.c617 DEFINE_WAIT (wait); in xfs_extent_busy_flush()
638 prepare_to_wait(&eb->eb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_flush()
644 finish_wait(&eb->eb_wait, &wait); in xfs_extent_busy_flush()
652 DEFINE_WAIT (wait); in xfs_extent_busy_wait_group()
656 prepare_to_wait(&eb->eb_wait, &wait, TASK_KILLABLE); in xfs_extent_busy_wait_group()
661 finish_wait(&eb->eb_wait, &wait); in xfs_extent_busy_wait_group()
/fs/jfs/
A 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/coda/
A 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()
207 DECLARE_WAITQUEUE(wait, current); in coda_psdev_read()
217 add_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
235 remove_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
/fs/btrfs/
A Dzstd.c85 wait_queue_head_t wait; member
194 init_waitqueue_head(&wsm.wait); in zstd_init_workspace_manager()
298 DEFINE_WAIT(wait); in zstd_get_workspace()
300 prepare_to_wait(&wsm.wait, &wait, TASK_UNINTERRUPTIBLE); in zstd_get_workspace()
302 finish_wait(&wsm.wait, &wait); in zstd_get_workspace()
348 cond_wake_up(&wsm.wait); in zstd_put_workspace()

Completed in 84 milliseconds

1234567