| /fs/btrfs/ |
| D | async-thread.c | 48 atomic_t pending; member
100 return atomic_read(&wq->normal->pending) > wq->normal->thresh * 2; in btrfs_workqueue_normal_congested()
137 atomic_set(&ret->pending, 0); in __btrfs_alloc_workqueue()
217 atomic_inc(&wq->pending); in thresh_queue_hook()
228 long pending; in thresh_exec_hook() local
234 atomic_dec(&wq->pending); in thresh_exec_hook()
250 pending = atomic_read(&wq->pending); in thresh_exec_hook()
251 if (pending > wq->thresh) in thresh_exec_hook()
253 if (pending < wq->thresh / 2) in thresh_exec_hook()
|
| D | transaction.c | 1409 struct btrfs_pending_snapshot *pending) in create_pending_snapshot() argument
1414 struct btrfs_root *root = pending->root; in create_pending_snapshot()
1431 ASSERT(pending->path); in create_pending_snapshot()
1432 path = pending->path; in create_pending_snapshot()
1434 ASSERT(pending->root_item); in create_pending_snapshot()
1435 new_root_item = pending->root_item; in create_pending_snapshot()
1437 pending->error = btrfs_find_free_objectid(tree_root, &objectid); in create_pending_snapshot()
1438 if (pending->error) in create_pending_snapshot()
1447 btrfs_reloc_pre_snapshot(pending, &to_reserve); in create_pending_snapshot()
1450 pending->error = btrfs_block_rsv_add(root, in create_pending_snapshot()
[all …]
|
| D | relocation.c | 80 unsigned int pending:1; member
110 struct list_head pending[BTRFS_MAX_LEVEL]; member
213 INIT_LIST_HEAD(&cache->pending[i]); in backref_cache_init()
239 ASSERT(list_empty(&cache->pending[i])); in backref_cache_cleanup()
507 BUG_ON(node->pending); in update_backref_cache()
516 list_for_each_entry(node, &cache->pending[level], list) { in update_backref_cache()
517 BUG_ON(!node->pending); in update_backref_cache()
2795 if (!upper->pending)
2803 if (!err && node->pending) {
2806 node->pending = 0;
[all …]
|
| D | raid56.c | 674 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 | 346 struct bio *pending; in run_scheduled_bios() local
393 pending = pending_bios->head; in run_scheduled_bios()
395 WARN_ON(pending && !tail); in run_scheduled_bios()
419 while (pending) { in run_scheduled_bios()
431 requeue_list(pending_bios, pending, tail); in run_scheduled_bios()
435 cur = pending; in run_scheduled_bios()
436 pending = pending->bi_next; in run_scheduled_bios()
475 if (pending && bdi_write_congested(bdi) && batch_run > 8 && in run_scheduled_bios()
505 requeue_list(pending_bios, pending, tail); in run_scheduled_bios()
|
| D | ctree.h | 3626 void btrfs_reloc_pre_snapshot(struct btrfs_pending_snapshot *pending,
3629 struct btrfs_pending_snapshot *pending);
|
| /fs/squashfs/ |
| D | cache.c | 118 entry->pending = 1; in squashfs_cache_get()
131 entry->pending = 0; in squashfs_cache_get()
162 if (entry->pending) { in squashfs_cache_get()
165 wait_event(entry->wait_queue, !entry->pending); in squashfs_cache_get()
|
| D | squashfs_fs_sb.h | 47 int pending; member
|
| /fs/proc/ |
| D | array.c | 273 sigset_t pending, shpending, blocked, ignored, caught; in task_sig() local
278 sigemptyset(&pending); in task_sig()
285 pending = p->pending.signal; in task_sig()
302 render_sigset_t(m, "\nSigPnd:\t", &pending); in task_sig()
532 seq_put_decimal_ull(m, " ", task->pending.signal.sig[0] & 0x7fffffffUL); in do_task_stat()
|
| /fs/autofs4/ |
| D | waitq.c | 62 sigpipe = sigismember(¤t->pending.signal, SIGPIPE); in autofs4_write()
85 sigdelset(¤t->pending.signal, SIGPIPE); in autofs4_write()
|
| /fs/ |
| D | userfaultfd.c | 1256 unsigned long pending = 0, total = 0; in userfaultfd_show_fdinfo() local
1261 pending++; in userfaultfd_show_fdinfo()
1276 pending, total, UFFD_API, UFFD_API_FEATURES, in userfaultfd_show_fdinfo()
|
| D | signalfd.c | 68 if (next_signal(¤t->pending, &ctx->sigmask) || in signalfd_poll()
|
| D | namespace.c | 1910 unsigned int mounts = 0, old, pending, sum; in count_mounts() local
1917 pending = ns->pending_mounts; in count_mounts()
1918 sum = old + pending; in count_mounts()
1920 (pending > sum) || in count_mounts()
1925 ns->pending_mounts = pending + mounts; in count_mounts()
|
| D | coredump.c | 322 sigaddset(&t->pending.signal, SIGKILL); in zap_process()
|
| D | binfmt_elf_fdpic.c | 1336 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|
| D | binfmt_elf.c | 1458 prstatus->pr_sigpend = p->pending.signal.sig[0]; in fill_prstatus()
|
| /fs/fuse/ |
| D | dev.c | 313 list_add_tail(&req->list, &fiq->pending); in queue_request()
1051 return !list_empty(&fiq->pending) || !list_empty(&fiq->interrupts) || in request_pending()
1252 if (list_empty(&fiq->pending) || fiq->forget_batch-- > 0) in fuse_dev_do_read()
1259 req = list_entry(fiq->pending.next, struct fuse_req, list); in fuse_dev_do_read()
2119 list_splice_init(&fiq->pending, &to_end2); in fuse_abort_conn()
|
| D | fuse_i.h | 398 struct list_head pending; member
|
| D | inode.c | 591 INIT_LIST_HEAD(&fiq->pending); in fuse_iqueue_init()
|