Home
last modified time | relevance | path

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

12345

/fs/qnx4/
Dfsync.c31 static int sync_block(struct inode *inode, unsigned short *block, int wait) in sync_block() argument
46 if (wait && buffer_req(bh) && !buffer_uptodate(bh)) { in sync_block()
50 if (wait || !buffer_uptodate(bh) || !buffer_dirty(bh)) { in sync_block()
61 struct buffer_head **bh, int wait) in sync_iblock() argument
70 rc = sync_block(inode, iblock, wait); in sync_iblock()
85 static int sync_direct(struct inode *inode, int wait) in sync_direct() argument
92 (unsigned short *) qnx4_raw_inode(inode)->di_first_xtnt.xtnt_blk + i, wait); in sync_direct()
102 static int sync_indirect(struct inode *inode, unsigned short *iblock, int wait) in sync_indirect() argument
108 rc = sync_iblock(inode, iblock, &ind_bh, wait); in sync_indirect()
115 wait); in sync_indirect()
[all …]
/fs/ecryptfs/
Dkthread.c36 wait_queue_head_t wait; member
57 ecryptfs_kthread_ctl.wait, in ecryptfs_threadfn()
79 wake_up(&req->wait); in ecryptfs_threadfn()
93 init_waitqueue_head(&ecryptfs_kthread_ctl.wait); in ecryptfs_init_kthread()
115 wake_up(&req->wait); in ecryptfs_destroy_kthread()
120 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_destroy_kthread()
159 init_waitqueue_head(&req->wait); in ecryptfs_privileged_open()
172 wake_up(&ecryptfs_kthread_ctl.wait); in ecryptfs_privileged_open()
173 wait_event(req->wait, (req->flags != 0)); in ecryptfs_privileged_open()
/fs/btrfs/
Dlocking.c130 static int btrfs_wake_function(wait_queue_t *wait, unsigned mode, in btrfs_wake_function() argument
133 autoremove_wake_function(wait, mode, sync, key); in btrfs_wake_function()
148 DEFINE_WAIT(wait); in btrfs_tree_lock()
149 wait.func = btrfs_wake_function; in btrfs_tree_lock()
171 prepare_to_wait_exclusive(&eb->lock_wq, &wait, in btrfs_tree_lock()
177 finish_wait(&eb->lock_wq, &wait); in btrfs_tree_lock()
Dtransaction.c142 DEFINE_WAIT(wait); in wait_current_trans()
145 prepare_to_wait(&root->fs_info->transaction_wait, &wait, in wait_current_trans()
152 &wait); in wait_current_trans()
155 &wait); in wait_current_trans()
164 int num_blocks, int wait) in start_transaction() argument
172 ((wait == 1 && !root->fs_info->open_ioctl_trans) || wait == 2)) in start_transaction()
211 DEFINE_WAIT(wait); in wait_for_commit()
214 prepare_to_wait(&commit->commit_wait, &wait, in wait_for_commit()
223 finish_wait(&commit->commit_wait, &wait); in wait_for_commit()
238 DEFINE_WAIT(wait); in throttle_on_drops()
[all …]
Dordered-data.h101 wait_queue_head_t wait; member
146 struct btrfs_ordered_extent *entry, int wait);
/fs/
Deventfd.c65 static unsigned int eventfd_poll(struct file *file, poll_table *wait) in eventfd_poll() argument
71 poll_wait(file, &ctx->wqh, wait); in eventfd_poll()
91 DECLARE_WAITQUEUE(wait, current); in eventfd_read()
101 __add_wait_queue(&ctx->wqh, &wait); in eventfd_read()
117 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_read()
138 DECLARE_WAITQUEUE(wait, current); in eventfd_write()
151 __add_wait_queue(&ctx->wqh, &wait); in eventfd_write()
166 __remove_wait_queue(&ctx->wqh, &wait); in eventfd_write()
Dfs-writeback.c273 int wait = wbc->sync_mode == WB_SYNC_ALL; in __sync_single_inode() local
290 int err = write_inode(inode, wait); in __sync_single_inode()
295 if (wait) { in __sync_single_inode()
642 void sync_inodes_sb(struct super_block *sb, int wait) in sync_inodes_sb() argument
645 .sync_mode = wait ? WB_SYNC_ALL : WB_SYNC_NONE, in sync_inodes_sb()
650 if (!wait) { in sync_inodes_sb()
681 static void __sync_inodes(int wait) in __sync_inodes() argument
692 sync_inodes_sb(sb, wait); in __sync_inodes()
703 void sync_inodes(int wait) in sync_inodes() argument
707 if (wait) in sync_inodes()
Dselect.c121 remove_wait_queue(entry->wait_address, &entry->wait); in free_poll_entry()
171 static int pollwake(wait_queue_t *wait, unsigned mode, int sync, void *key) in pollwake() argument
173 struct poll_wqueues *pwq = wait->private; in pollwake()
208 init_waitqueue_func_entry(&entry->wait, pollwake); in __pollwait()
209 entry->wait.private = pwq; in __pollwait()
210 add_wait_queue(wait_address, &entry->wait); in __pollwait()
369 poll_table *wait; in do_select() local
382 wait = &table.pt; in do_select()
384 wait = NULL; in do_select()
422 mask = (*f_op->poll)(file, retval ? NULL : wait); in do_select()
[all …]
Dpipe.c43 DEFINE_WAIT(wait); in pipe_wait()
49 prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); in pipe_wait()
53 finish_wait(&pipe->wait, &wait); in pipe_wait()
377 wake_up_interruptible_sync(&pipe->wait); in pipe_read()
386 wake_up_interruptible_sync(&pipe->wait); in pipe_read()
548 wake_up_interruptible_sync(&pipe->wait); in pipe_write()
559 wake_up_interruptible_sync(&pipe->wait); in pipe_write()
607 pipe_poll(struct file *filp, poll_table *wait) in pipe_poll() argument
614 poll_wait(filp, &pipe->wait, wait); in pipe_poll()
651 wake_up_interruptible_sync(&pipe->wait); in pipe_release()
[all …]
Deventpoll.c222 wait_queue_t wait; member
299 return container_of(p, struct eppoll_entry, wait)->base; in ep_item_from_wait()
394 remove_wait_queue(pwq->whead, &pwq->wait); in ep_unregister_pollwait()
499 static unsigned int ep_eventpoll_poll(struct file *file, poll_table *wait) in ep_eventpoll_poll() argument
506 poll_wait(file, &ep->poll_wait, wait); in ep_eventpoll_poll()
635 static int ep_poll_callback(wait_queue_t *wait, unsigned mode, int sync, void *key) in ep_poll_callback() argument
639 struct epitem *epi = ep_item_from_wait(wait); in ep_poll_callback()
707 init_waitqueue_func_entry(&pwq->wait, ep_poll_callback); in ep_ptable_queue_proc()
710 add_wait_queue(whead, &pwq->wait); in ep_ptable_queue_proc()
1031 wait_queue_t wait; in ep_poll() local
[all …]
Daio.c266 init_waitqueue_head(&ctx->wait); in ioctx_alloc()
348 DECLARE_WAITQUEUE(wait, tsk); in wait_for_all_aios()
354 add_wait_queue(&ctx->wait, &wait); in wait_for_all_aios()
363 remove_wait_queue(&ctx->wait, &wait); in wait_for_all_aios()
496 wake_up(&ctx->wait); in really_put_req()
825 if (waitqueue_active(&ctx->wait)) in aio_queue_work()
1044 if (waitqueue_active(&ctx->wait)) in aio_complete()
1045 wake_up(&ctx->wait); in aio_complete()
1136 DECLARE_WAITQUEUE(wait, tsk); in read_events()
1195 add_wait_queue_exclusive(&ctx->wait, &wait); in read_events()
[all …]
Dfifo.c31 wake_up_interruptible(&inode->i_pipe->wait); in wake_up_partner()
129 wake_up_interruptible(&pipe->wait); in fifo_open()
135 wake_up_interruptible(&pipe->wait); in fifo_open()
Dsignalfd.c42 static unsigned int signalfd_poll(struct file *file, poll_table *wait) in signalfd_poll() argument
47 poll_wait(file, &current->sighand->signalfd_wqh, wait); in signalfd_poll()
132 DECLARE_WAITQUEUE(wait, current); in signalfd_dequeue()
146 add_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
162 remove_wait_queue(&current->sighand->signalfd_wqh, &wait); in signalfd_dequeue()
Dsync.c24 static void do_sync(unsigned long wait) in do_sync() argument
31 sync_filesystems(wait); /* Waitingly sync the filesystems */ in do_sync()
32 sync_inodes(wait); /* Mappings, inodes and blockdevs, again. */ in do_sync()
33 if (!wait) in do_sync()
Dtimerfd.c90 static unsigned int timerfd_poll(struct file *file, poll_table *wait) in timerfd_poll() argument
96 poll_wait(file, &ctx->wqh, wait); in timerfd_poll()
112 DECLARE_WAITQUEUE(wait, current); in timerfd_read()
119 __add_wait_queue(&ctx->wqh, &wait); in timerfd_read()
134 __remove_wait_queue(&ctx->wqh, &wait); in timerfd_read()
Dmbcache.c522 DEFINE_WAIT(wait); in mb_cache_entry_get()
529 prepare_to_wait(&mb_cache_queue, &wait, in mb_cache_entry_get()
536 finish_wait(&mb_cache_queue, &wait); in mb_cache_entry_get()
564 DEFINE_WAIT(wait); in __mb_cache_entry_find()
574 prepare_to_wait(&mb_cache_queue, &wait, in __mb_cache_entry_find()
581 finish_wait(&mb_cache_queue, &wait); in __mb_cache_entry_find()
/fs/xfs/linux-2.6/
Dsv.h37 DECLARE_WAITQUEUE(wait, current); in _sv_wait()
39 add_wait_queue_exclusive(&sv->waiters, &wait); in _sv_wait()
45 remove_wait_queue(&sv->waiters, &wait); in _sv_wait()
/fs/jffs2/
Dbackground.c58 int wait = 0; in jffs2_stop_garbage_collect_thread() local
63 wait = 1; in jffs2_stop_garbage_collect_thread()
66 if (wait) in jffs2_stop_garbage_collect_thread()
/fs/jfs/
Dinode.c81 int jfs_commit_inode(struct inode *inode, int wait) in jfs_commit_inode() argument
116 rc = txCommit(tid, 1, &inode, wait ? COMMIT_SYNC : 0); in jfs_commit_inode()
123 int jfs_write_inode(struct inode *inode, int wait) in jfs_write_inode() argument
134 jfs_flush_journal(JFS_SBI(inode->i_sb)->log, wait); in jfs_write_inode()
138 if (jfs_commit_inode(inode, wait)) { in jfs_write_inode()
/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()
211 DECLARE_WAITQUEUE(wait, current); in coda_psdev_read()
221 add_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
237 remove_wait_queue(&vcp->vc_waitq, &wait); in coda_psdev_read()
/fs/jbd/
Dtransaction.c150 DEFINE_WAIT(wait); in start_this_handle()
153 &wait, TASK_UNINTERRUPTIBLE); in start_this_handle()
156 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
174 DEFINE_WAIT(wait); in start_this_handle()
178 prepare_to_wait(&journal->j_wait_transaction_locked, &wait, in start_this_handle()
183 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
437 DEFINE_WAIT(wait); in journal_lock_updates()
454 prepare_to_wait(&journal->j_wait_updates, &wait, in journal_lock_updates()
459 finish_wait(&journal->j_wait_updates, &wait); in journal_lock_updates()
648 DEFINE_WAIT_BIT(wait, &bh->b_state, BH_Unshadow); in do_get_write_access()
[all …]
/fs/jbd2/
Dtransaction.c154 DEFINE_WAIT(wait); in start_this_handle()
157 &wait, TASK_UNINTERRUPTIBLE); in start_this_handle()
160 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
178 DEFINE_WAIT(wait); in start_this_handle()
182 prepare_to_wait(&journal->j_wait_transaction_locked, &wait, in start_this_handle()
187 finish_wait(&journal->j_wait_transaction_locked, &wait); in start_this_handle()
447 DEFINE_WAIT(wait); in jbd2_journal_lock_updates()
464 prepare_to_wait(&journal->j_wait_updates, &wait, in jbd2_journal_lock_updates()
469 finish_wait(&journal->j_wait_updates, &wait); in jbd2_journal_lock_updates()
658 DEFINE_WAIT_BIT(wait, &bh->b_state, BH_Unshadow); in do_get_write_access()
[all …]
/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/dlm/
Duser.c217 wake_up_interruptible(&proc->wait); in dlm_user_add_ast()
657 init_waitqueue_head(&proc->wait); in device_open()
794 DECLARE_WAITQUEUE(wait, current); in device_read()
825 add_wait_queue(&proc->wait, &wait); in device_read()
836 remove_wait_queue(&proc->wait, &wait); in device_read()
876 static unsigned int device_poll(struct file *file, poll_table *wait) in device_poll() argument
880 poll_wait(file, &proc->wait, wait); in device_poll()
/fs/fat/
Dfile.c171 int err, wait, free_start, i_start, i_logstart; in fat_free() local
178 wait = IS_DIRSYNC(inode); in fat_free()
189 if (wait) { in fat_free()
221 err = fat_ent_write(inode, &fatent, FAT_ENT_EOF, wait); in fat_free()

12345