| /fs/btrfs/ |
| D | async-thread.c | 37 atomic_t pending; member
77 return atomic_read(&wq->normal->pending) > wq->normal->thresh * 2; in btrfs_workqueue_normal_congested()
91 atomic_set(&ret->pending, 0); in __btrfs_alloc_workqueue()
169 atomic_inc(&wq->pending); in thresh_queue_hook()
180 long pending; in thresh_exec_hook() local
186 atomic_dec(&wq->pending); in thresh_exec_hook()
202 pending = atomic_read(&wq->pending); in thresh_exec_hook()
203 if (pending > wq->thresh) in thresh_exec_hook()
205 if (pending < wq->thresh / 2) in thresh_exec_hook()
|
| D | transaction.c | 1512 struct btrfs_pending_snapshot *pending) in create_pending_snapshot() argument
1519 struct btrfs_root *root = pending->root; in create_pending_snapshot()
1535 ASSERT(pending->path); in create_pending_snapshot()
1536 path = pending->path; in create_pending_snapshot()
1538 ASSERT(pending->root_item); in create_pending_snapshot()
1539 new_root_item = pending->root_item; in create_pending_snapshot()
1541 pending->error = btrfs_find_free_objectid(tree_root, &objectid); in create_pending_snapshot()
1542 if (pending->error) in create_pending_snapshot()
1551 btrfs_reloc_pre_snapshot(pending, &to_reserve); in create_pending_snapshot()
1554 pending->error = btrfs_block_rsv_add(root, in create_pending_snapshot()
[all …]
|
| D | relocation.c | 269 BUG_ON(node->pending); in update_backref_cache()
278 list_for_each_entry(node, &cache->pending[level], list) { in update_backref_cache()
279 BUG_ON(!node->pending); in update_backref_cache()
2362 if (!upper->pending) in do_relocation()
2370 if (!err && node->pending) { in do_relocation()
2373 node->pending = 0; in do_relocation()
2403 while (!list_empty(&cache->pending[level])) { in finish_pending_nodes()
2404 node = list_entry(cache->pending[level].next, in finish_pending_nodes()
2407 BUG_ON(!node->pending); in finish_pending_nodes()
2415 list_splice_init(&list, &cache->pending[level]); in finish_pending_nodes()
[all …]
|
| D | backref.h | 200 unsigned int pending:1; member
241 struct list_head pending[BTRFS_MAX_LEVEL]; member
|
| D | ordered-data.c | 473 bool pending; in btrfs_remove_ordered_extent() local
495 pending = test_and_clear_bit(BTRFS_ORDERED_PENDING, &entry->flags); in btrfs_remove_ordered_extent()
502 if (pending) { in btrfs_remove_ordered_extent()
|
| D | raid56.c | 677 struct btrfs_raid_bio *pending; in lock_stripe_add() local
722 list_for_each_entry(pending, &cur->plug_list, plug_list) { in lock_stripe_add()
723 if (rbio_can_merge(pending, rbio)) { in lock_stripe_add()
724 merge_rbio(pending, rbio); in lock_stripe_add()
|
| D | backref.c | 2550 INIT_LIST_HEAD(&cache->pending[i]);
2653 ASSERT(list_empty(&cache->pending[i]));
|
| D | ctree.h | 3526 void btrfs_reloc_pre_snapshot(struct btrfs_pending_snapshot *pending,
3529 struct btrfs_pending_snapshot *pending);
|
| D | inode.c | 376 atomic_t *pending; member
1232 if (atomic_dec_and_test(async_chunk->pending)) in async_cow_free()
1233 kvfree(async_chunk->pending); in async_cow_free()
1295 async_chunk[i].pending = &ctx->num_chunks; in cow_file_range_async()
|
| /fs/squashfs/ |
| D | cache.c | 105 entry->pending = 1; in squashfs_cache_get()
118 entry->pending = 0; in squashfs_cache_get()
149 if (entry->pending) { in squashfs_cache_get()
152 wait_event(entry->wait_queue, !entry->pending); in squashfs_cache_get()
|
| D | squashfs_fs_sb.h | 34 int pending; member
|
| /fs/proc/ |
| D | array.c | 268 sigset_t pending, shpending, blocked, ignored, caught; in task_sig() local
273 sigemptyset(&pending); in task_sig()
280 pending = p->pending.signal; in task_sig()
297 render_sigset_t(m, "\nSigPnd:\t", &pending); in task_sig()
577 seq_put_decimal_ull(m, " ", task->pending.signal.sig[0] & 0x7fffffffUL); in do_task_stat()
|
| /fs/autofs/ |
| D | waitq.c | 53 sigpipe = sigismember(¤t->pending.signal, SIGPIPE); in autofs_write()
70 sigdelset(¤t->pending.signal, SIGPIPE); in autofs_write()
|
| /fs/fuse/ |
| D | dev.c | 236 list_add_tail(&req->list, &fiq->pending); in queue_request_and_unlock()
1054 return !list_empty(&fiq->pending) || !list_empty(&fiq->interrupts) || in request_pending()
1278 if (list_empty(&fiq->pending) || fiq->forget_batch-- > 0) in fuse_dev_do_read()
1285 req = list_entry(fiq->pending.next, struct fuse_req, list); in fuse_dev_do_read()
2196 list_for_each_entry(req, &fiq->pending, list) in fuse_abort_conn()
2198 list_splice_tail_init(&fiq->pending, &to_end); in fuse_abort_conn()
|
| D | virtio_fs.c | 1241 WARN_ON(list_empty(&fiq->pending)); in virtio_fs_wake_pending_and_unlock()
1242 req = list_last_entry(&fiq->pending, struct fuse_req, list); in virtio_fs_wake_pending_and_unlock()
1245 WARN_ON(!list_empty(&fiq->pending)); in virtio_fs_wake_pending_and_unlock()
|
| D | fuse_i.h | 453 struct list_head pending; member
|
| D | inode.c | 667 INIT_LIST_HEAD(&fiq->pending); in fuse_iqueue_init()
|
| /fs/ |
| D | signalfd.c | 59 if (next_signal(¤t->pending, &ctx->sigmask) || in signalfd_poll()
|
| D | userfaultfd.c | 2069 unsigned long pending = 0, total = 0; in userfaultfd_show_fdinfo() local
2073 pending++; in userfaultfd_show_fdinfo()
2087 pending, total, UFFD_API, ctx->features, in userfaultfd_show_fdinfo()
|
| D | namespace.c | 2053 unsigned int mounts = 0, old, pending, sum; in count_mounts() local
2060 pending = ns->pending_mounts; in count_mounts()
2061 sum = old + pending; in count_mounts()
2063 (pending > sum) || in count_mounts()
2068 ns->pending_mounts = pending + mounts; in count_mounts()
|
| D | coredump.c | 364 sigaddset(&t->pending.signal, SIGKILL); in zap_process()
|
| D | binfmt_elf_fdpic.c | 1308 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|
| D | binfmt_elf.c | 1515 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|