Lines Matching refs:nr_queued
67 unsigned int nr_queued[2]; member
813 if (tg->service_queue.nr_queued[READ]) in tg_update_carryover()
815 if (tg->service_queue.nr_queued[WRITE]) in tg_update_carryover()
922 BUG_ON(tg->service_queue.nr_queued[rw] && in tg_may_dispatch()
940 if (throtl_slice_used(tg, rw) && !(tg->service_queue.nr_queued[rw])) in tg_may_dispatch()
1006 if (!sq->nr_queued[rw]) in throtl_add_bio_tg()
1011 sq->nr_queued[rw]++; in throtl_add_bio_tg()
1066 sq->nr_queued[rw]--; in tg_dispatch_one_bio()
1084 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()
1085 tg->td->nr_queued[rw]--; in tg_dispatch_one_bio()
1148 if (sq->nr_queued[READ] || sq->nr_queued[WRITE]) in throtl_select_dispatch()
1207 sq->nr_queued[READ] + sq->nr_queued[WRITE], in throtl_pending_timer_fn()
1208 sq->nr_queued[READ], sq->nr_queued[WRITE]); in throtl_pending_timer_fn()
1832 if (read_limit && sq->nr_queued[READ] && in throtl_tg_can_upgrade()
1833 (!write_limit || sq->nr_queued[WRITE])) in throtl_tg_can_upgrade()
1835 if (write_limit && sq->nr_queued[WRITE] && in throtl_tg_can_upgrade()
1836 (!read_limit || sq->nr_queued[READ])) in throtl_tg_can_upgrade()
2191 if (sq->nr_queued[rw]) in __blk_throtl_bio()
2240 sq->nr_queued[READ], sq->nr_queued[WRITE]); in __blk_throtl_bio()
2244 td->nr_queued[rw]++; in __blk_throtl_bio()