Searched refs:nr_pending (Results 1 – 14 of 14) sorted by relevance
669 pending = atomic_read(&rdev->nr_pending); in read_balance()737 atomic_inc(&rdev->nr_pending); in read_balance()889 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()928 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()961 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()972 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()988 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()995 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1005 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1019 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
835 if (geo->near_copies > 1 && !atomic_read(&rdev->nr_pending)) in read_balance()856 atomic_inc(&rdev->nr_pending); in read_balance()979 !atomic_read(&conf->nr_pending) && conf->barrier < RESYNC_DEPTH, in raise_barrier()1011 (atomic_read(&conf->nr_pending) && in wait_barrier()1020 atomic_inc(&conf->nr_pending); in wait_barrier()1026 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1050 atomic_read(&conf->nr_pending) == conf->nr_queued+extra, in freeze_array()1407 atomic_inc(&rdev->nr_pending); in raid10_write_request()1412 atomic_inc(&rrdev->nr_pending); in raid10_write_request()1440 atomic_inc(&rdev->nr_pending); in raid10_write_request()[all …]
101 atomic_t *nr_pending; member
81 atomic_t nr_pending; member
48 atomic_inc(&rdev->nr_pending); in multipath_map()291 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()299 if (atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
105 atomic_t nr_pending; /* number of pending requests. member729 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1050 atomic_inc(&rdev->nr_pending); in ops_run_io()1054 atomic_inc(&rrdev->nr_pending); in ops_run_io()1085 atomic_inc(&rdev->nr_pending); in ops_run_io()3357 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4447 atomic_inc(&rdev->nr_pending); in analyse_stripe()4485 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4496 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4505 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5244 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()7607 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()[all …]
1912 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1922 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
489 atomic_inc(&rdev->nr_pending); in md_flush_request()490 atomic_inc(&rdev->nr_pending); in md_flush_request()820 atomic_inc(&rdev->nr_pending); in md_super_write()3431 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()8665 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()8685 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
202 atomic_inc(&rdev->nr_pending); in next_active_rdev()
89 unsigned int nr_pending; /* # queued in the tree */ member620 if (!parent_sq->nr_pending) in throtl_rb_first()644 --parent_sq->nr_pending; in throtl_rb_erase()690 tg->service_queue.parent_sq->nr_pending++; in __throtl_enqueue_tg()753 if (!sq->nr_pending) in throtl_schedule_next_dispatch()
564 rq->q->nr_pending--; in blk_pm_requeue_request()569 if (q->dev && !(rq->rq_flags & RQF_PM) && q->nr_pending++ == 0 && in blk_pm_add_request()
1732 if (rq->q->dev && !(rq->rq_flags & RQF_PM) && !--rq->q->nr_pending) in blk_pm_put_request()3824 if (q->nr_pending) { in blk_pre_runtime_suspend()
544 unsigned int nr_pending; member
