| /fs/btrfs/ |
| D | async-thread.c | 37 atomic_t pending; member
79 return atomic_read(&wq->normal->pending) > wq->normal->thresh * 2; in btrfs_workqueue_normal_congested()
93 atomic_set(&ret->pending, 0); in __btrfs_alloc_workqueue()
171 atomic_inc(&wq->pending); in thresh_queue_hook()
182 long pending; in thresh_exec_hook() local
188 atomic_dec(&wq->pending); in thresh_exec_hook()
204 pending = atomic_read(&wq->pending); in thresh_exec_hook()
205 if (pending > wq->thresh) in thresh_exec_hook()
207 if (pending < wq->thresh / 2) in thresh_exec_hook()
|
| D | transaction.c | 1392 struct btrfs_pending_snapshot *pending) in create_pending_snapshot() argument
1399 struct btrfs_root *root = pending->root; in create_pending_snapshot()
1416 ASSERT(pending->path); in create_pending_snapshot()
1417 path = pending->path; in create_pending_snapshot()
1419 ASSERT(pending->root_item); in create_pending_snapshot()
1420 new_root_item = pending->root_item; in create_pending_snapshot()
1422 pending->error = btrfs_find_free_objectid(tree_root, &objectid); in create_pending_snapshot()
1423 if (pending->error) in create_pending_snapshot()
1432 btrfs_reloc_pre_snapshot(pending, &to_reserve); in create_pending_snapshot()
1435 pending->error = btrfs_block_rsv_add(root, in create_pending_snapshot()
[all …]
|
| D | relocation.c | 70 unsigned int pending:1; member
100 struct list_head pending[BTRFS_MAX_LEVEL]; member
205 INIT_LIST_HEAD(&cache->pending[i]); in backref_cache_init()
231 ASSERT(list_empty(&cache->pending[i])); in backref_cache_cleanup()
499 BUG_ON(node->pending); in update_backref_cache()
508 list_for_each_entry(node, &cache->pending[level], list) { in update_backref_cache()
509 BUG_ON(!node->pending); in update_backref_cache()
2920 if (!upper->pending) in do_relocation()
2928 if (!err && node->pending) { in do_relocation()
2931 node->pending = 0; in do_relocation()
[all …]
|
| D | raid56.c | 677 struct btrfs_raid_bio *pending; in lock_stripe_add() local
721 list_for_each_entry(pending, &cur->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 | volumes.c | 532 struct bio *pending; in run_scheduled_bios() local
574 pending = pending_bios->head; in run_scheduled_bios()
576 WARN_ON(pending && !tail); in run_scheduled_bios()
600 while (pending) { in run_scheduled_bios()
612 requeue_list(pending_bios, pending, tail); in run_scheduled_bios()
616 cur = pending; in run_scheduled_bios()
617 pending = pending->bi_next; in run_scheduled_bios()
649 if (pending && bdi_write_congested(bdi) && batch_run > 8 && in run_scheduled_bios()
679 requeue_list(pending_bios, pending, tail); in run_scheduled_bios()
|
| D | ctree.h | 3350 void btrfs_reloc_pre_snapshot(struct btrfs_pending_snapshot *pending,
3353 struct btrfs_pending_snapshot *pending);
|
| D | inode.c | 372 atomic_t *pending; member
1205 if (atomic_dec_and_test(async_chunk->pending)) in async_cow_free()
1206 kvfree(async_chunk->pending); in async_cow_free()
1265 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 | 269 sigset_t pending, shpending, blocked, ignored, caught; in task_sig() local
274 sigemptyset(&pending); in task_sig()
281 pending = p->pending.signal; in task_sig()
298 render_sigset_t(m, "\nSigPnd:\t", &pending); in task_sig()
574 seq_put_decimal_ull(m, " ", task->pending.signal.sig[0] & 0x7fffffffUL); in do_task_stat()
|
| /fs/autofs/ |
| D | waitq.c | 52 sigpipe = sigismember(¤t->pending.signal, SIGPIPE); in autofs_write()
69 sigdelset(¤t->pending.signal, SIGPIPE); in autofs_write()
|
| /fs/fuse/ |
| D | dev.c | 228 list_add_tail(&req->list, &fiq->pending); in queue_request_and_unlock()
1009 return !list_empty(&fiq->pending) || !list_empty(&fiq->interrupts) || in request_pending()
1233 if (list_empty(&fiq->pending) || fiq->forget_batch-- > 0) in fuse_dev_do_read()
1240 req = list_entry(fiq->pending.next, struct fuse_req, list); in fuse_dev_do_read()
2134 list_for_each_entry(req, &fiq->pending, list) in fuse_abort_conn()
2136 list_splice_tail_init(&fiq->pending, &to_end); in fuse_abort_conn()
|
| D | virtio_fs.c | 987 WARN_ON(list_empty(&fiq->pending)); in virtio_fs_wake_pending_and_unlock()
988 req = list_last_entry(&fiq->pending, struct fuse_req, list); in virtio_fs_wake_pending_and_unlock()
991 WARN_ON(!list_empty(&fiq->pending)); in virtio_fs_wake_pending_and_unlock()
|
| D | fuse_i.h | 414 struct list_head pending; member
|
| D | inode.c | 584 INIT_LIST_HEAD(&fiq->pending); in fuse_iqueue_init()
|
| /fs/ |
| D | signalfd.c | 69 if (next_signal(¤t->pending, &ctx->sigmask) || in signalfd_poll()
|
| D | userfaultfd.c | 1902 unsigned long pending = 0, total = 0; in userfaultfd_show_fdinfo() local
1906 pending++; in userfaultfd_show_fdinfo()
1920 pending, total, UFFD_API, ctx->features, in userfaultfd_show_fdinfo()
|
| D | namespace.c | 1980 unsigned int mounts = 0, old, pending, sum; in count_mounts() local
1987 pending = ns->pending_mounts; in count_mounts()
1988 sum = old + pending; in count_mounts()
1990 (pending > sum) || in count_mounts()
1995 ns->pending_mounts = pending + mounts; in count_mounts()
|
| D | coredump.c | 351 sigaddset(&t->pending.signal, SIGKILL); in zap_process()
|
| D | binfmt_elf_fdpic.c | 1346 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|
| D | binfmt_elf.c | 1476 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|