Searched refs:nr_pending (Results 1 – 17 of 17) sorted by relevance
1043 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1076 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()1447 atomic_inc(&rdev->nr_pending); in wait_blocked_rdev()1536 atomic_inc(&rdev->nr_pending); in raid1_write_request()2430 atomic_inc(&rdev->nr_pending); in fix_read_error()2460 atomic_inc(&rdev->nr_pending); in fix_read_error()2474 atomic_inc(&rdev->nr_pending); in fix_read_error()2931 atomic_inc(&rdev->nr_pending); in raid1_sync_request()3097 if (!conf->nr_pending) in setup_conf()3206 kfree(conf->nr_pending); in setup_conf()[all …]
849 atomic_inc(&rdev->nr_pending); in read_balance()992 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()1025 atomic_inc(&conf->nr_pending); in wait_barrier()1238 atomic_dec(&rdev->nr_pending); in raid10_read_request()1316 atomic_inc(&rdev->nr_pending); in wait_blocked_dev()1323 atomic_inc(&rrdev->nr_pending); in wait_blocked_dev()1471 atomic_inc(&rdev->nr_pending); in raid10_write_request()1768 atomic_inc(&rdev->nr_pending); in raid10_handle_discard()2715 atomic_inc(&rdev->nr_pending); in fix_read_error()2747 atomic_inc(&rdev->nr_pending); in fix_read_error()[all …]
101 atomic_t *nr_pending; member
80 atomic_t nr_pending; member
191 atomic_t nr_pending; /* number of pending requests. member946 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1201 atomic_inc(&rdev->nr_pending); in ops_run_io()1205 atomic_inc(&rrdev->nr_pending); in ops_run_io()1233 atomic_inc(&rdev->nr_pending); in ops_run_io()3606 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4690 atomic_inc(&rdev->nr_pending); in analyse_stripe()4729 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4740 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4749 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5434 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()8190 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()
1890 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1898 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
394 atomic_inc(&rdev->nr_pending); in next_active_rdev()
1006 atomic_inc(&rdev->nr_pending); in md_super_write()3641 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9306 if (atomic_read(&rdev->nr_pending)) in rdev_removeable()
16 size_t __percpu *nr_pending; member
100 this_cpu_dec(*c->btree_key_cache.nr_pending); in __bkey_cached_free()116 this_cpu_inc(*bc->nr_pending); in bkey_cached_free()795 free_percpu(bc->nr_pending); in bch2_fs_btree_key_cache_exit()807 bc->nr_pending = alloc_percpu(size_t); in bch2_fs_btree_key_cache_init()808 if (!bc->nr_pending) in bch2_fs_btree_key_cache_init()849 prt_printf(out, "pending:\t%zu\r\n", per_cpu_sum(bc->nr_pending)); in bch2_btree_key_cache_to_text()
728 event->handle->nr_pending++; in xs_watch_msg()786 watch->nr_pending = 0; in register_xenbus_watch()837 if (watch->nr_pending) { in unregister_xenbus_watch()844 watch->nr_pending = 0; in unregister_xenbus_watch()909 event->handle->nr_pending--; in xenwatch_thread()
186 return watch->nr_pending == 0; in frontend_will_handle()
51 unsigned int nr_pending; /* # queued in the tree */ member
403 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()414 --parent_sq->nr_pending; in throtl_dequeue_tg()461 if (!sq->nr_pending) in throtl_schedule_next_dispatch()974 if (!parent_sq->nr_pending) in throtl_select_dispatch()
63 unsigned int nr_pending; member
144 int nr_pending; member1093 match->nr_pending++; in io_acct_cancel_pending_work()1160 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1169 if (match.nr_pending) in io_wq_cancel_cb()