Searched refs:nr_pending (Results 1 – 14 of 14) sorted by relevance
27 rq->q->nr_pending--; in blk_pm_requeue_request()36 q->nr_pending++; in blk_pm_add_request()44 --rq->q->nr_pending; in blk_pm_put_request()
89 unsigned int nr_pending; /* # queued in the tree */ member654 --parent_sq->nr_pending; in throtl_rb_erase()699 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()753 if (!sq->nr_pending) in throtl_schedule_next_dispatch()1219 if (!parent_sq->nr_pending) in throtl_select_dispatch()
707 pending = atomic_read(&rdev->nr_pending); in read_balance()775 atomic_inc(&rdev->nr_pending); in read_balance()901 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()940 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()973 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()984 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1000 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1007 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1017 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1031 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
800 pending = atomic_read(&rdev->nr_pending); in read_balance()841 atomic_inc(&rdev->nr_pending); in read_balance()939 !atomic_read(&conf->nr_pending) && conf->barrier < RESYNC_DEPTH, in raise_barrier()972 (atomic_read(&conf->nr_pending) && in wait_barrier()988 atomic_inc(&conf->nr_pending); in wait_barrier()994 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1018 atomic_read(&conf->nr_pending) == conf->nr_queued+extra, in freeze_array()1355 atomic_inc(&rdev->nr_pending); in raid10_write_request()1360 atomic_inc(&rrdev->nr_pending); in raid10_write_request()1388 atomic_inc(&rdev->nr_pending); in raid10_write_request()[all …]
101 atomic_t *nr_pending; member
81 atomic_t nr_pending; member
40 atomic_inc(&rdev->nr_pending); in multipath_map()260 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()268 if (atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
108 atomic_t nr_pending; /* number of pending requests. member774 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1122 atomic_inc(&rdev->nr_pending); in ops_run_io()1126 atomic_inc(&rrdev->nr_pending); in ops_run_io()1157 atomic_inc(&rdev->nr_pending); in ops_run_io()3565 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4671 atomic_inc(&rdev->nr_pending); in analyse_stripe()4709 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4720 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4729 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5447 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()7916 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()[all …]
1901 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1911 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
613 atomic_inc(&rdev->nr_pending); in submit_flushes()614 atomic_inc(&rdev->nr_pending); in submit_flushes()998 atomic_inc(&rdev->nr_pending); in md_super_write()3688 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9059 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9079 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
203 atomic_inc(&rdev->nr_pending); in next_active_rdev()
960 int nr_pending; member1019 match->nr_pending++; in io_wqe_cancel_pending_work()1056 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1076 if (match.nr_pending) in io_wq_cancel_cb()
468 unsigned int nr_pending; member
