Searched refs:nr_pending (Results 1 – 17 of 17) 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 */ member657 --parent_sq->nr_pending; in throtl_rb_erase()702 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()756 if (!sq->nr_pending) in throtl_schedule_next_dispatch()1228 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 …]
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()
101 atomic_t *nr_pending; member
81 atomic_t nr_pending; member
108 atomic_t nr_pending; /* number of pending requests. member773 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1123 atomic_inc(&rdev->nr_pending); in ops_run_io()1127 atomic_inc(&rrdev->nr_pending); in ops_run_io()1158 atomic_inc(&rdev->nr_pending); in ops_run_io()3563 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4669 atomic_inc(&rdev->nr_pending); in analyse_stripe()4707 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4718 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4727 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5445 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()7925 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()
586 atomic_inc(&rdev->nr_pending); in submit_flushes()587 atomic_inc(&rdev->nr_pending); in submit_flushes()995 atomic_inc(&rdev->nr_pending); in md_super_write()3697 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9070 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9090 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
203 atomic_inc(&rdev->nr_pending); in next_active_rdev()
714 event->handle->nr_pending++; in xs_watch_msg()772 watch->nr_pending = 0; in register_xenbus_watch()823 if (watch->nr_pending) { in unregister_xenbus_watch()830 watch->nr_pending = 0; in unregister_xenbus_watch()895 event->handle->nr_pending--; in xenwatch_thread()
186 return watch->nr_pending == 0; in frontend_will_handle()
64 unsigned int nr_pending; member
134 int nr_pending; member1026 match->nr_pending++; in io_acct_cancel_pending_work()1079 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1099 if (match.nr_pending) in io_wq_cancel_cb()
478 unsigned int nr_pending; member