Searched refs:nr_pending (Results 1 – 13 of 13) 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()
88 unsigned int nr_pending; /* # queued in the tree */ member622 if (!parent_sq->nr_pending) in throtl_rb_first()637 --parent_sq->nr_pending; in throtl_rb_erase()681 tg->service_queue.parent_sq->nr_pending++; in __throtl_enqueue_tg()744 if (!sq->nr_pending) in throtl_schedule_next_dispatch()
690 pending = atomic_read(&rdev->nr_pending); in read_balance()758 atomic_inc(&rdev->nr_pending); in read_balance()913 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()952 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()985 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()996 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1012 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1019 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1029 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1043 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()964 !atomic_read(&conf->nr_pending) && conf->barrier < RESYNC_DEPTH, in raise_barrier()996 (atomic_read(&conf->nr_pending) && in wait_barrier()1005 atomic_inc(&conf->nr_pending); in wait_barrier()1011 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1035 atomic_read(&conf->nr_pending) == conf->nr_queued+extra, in freeze_array()1372 atomic_inc(&rdev->nr_pending); in raid10_write_request()1377 atomic_inc(&rrdev->nr_pending); in raid10_write_request()1405 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()283 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()291 if (atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
98 atomic_t nr_pending; /* number of pending requests. member761 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1045 atomic_inc(&rdev->nr_pending); in ops_run_io()1049 atomic_inc(&rrdev->nr_pending); in ops_run_io()1080 atomic_inc(&rdev->nr_pending); in ops_run_io()3364 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4462 atomic_inc(&rdev->nr_pending); in analyse_stripe()4500 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4511 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4520 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5258 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()7631 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()[all …]
1903 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1913 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
511 atomic_inc(&rdev->nr_pending); in submit_flushes()512 atomic_inc(&rdev->nr_pending); in submit_flushes()882 atomic_inc(&rdev->nr_pending); in md_super_write()3514 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()8796 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()8816 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
203 atomic_inc(&rdev->nr_pending); in next_active_rdev()
471 unsigned int nr_pending; member
