Lines Matching refs:nr_queued
67 unsigned int nr_queued[2]; member
820 if (tg->service_queue.nr_queued[READ]) in tg_update_carryover()
822 if (tg->service_queue.nr_queued[WRITE]) in tg_update_carryover()
915 BUG_ON(tg->service_queue.nr_queued[rw] && in tg_may_dispatch()
933 if (throtl_slice_used(tg, rw) && !(tg->service_queue.nr_queued[rw])) in tg_may_dispatch()
1000 if (!sq->nr_queued[rw]) in throtl_add_bio_tg()
1005 sq->nr_queued[rw]++; in throtl_add_bio_tg()
1060 sq->nr_queued[rw]--; in tg_dispatch_one_bio()
1078 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()
1079 tg->td->nr_queued[rw]--; in tg_dispatch_one_bio()
1142 if (sq->nr_queued[READ] || sq->nr_queued[WRITE]) in throtl_select_dispatch()
1201 sq->nr_queued[READ] + sq->nr_queued[WRITE], in throtl_pending_timer_fn()
1202 sq->nr_queued[READ], sq->nr_queued[WRITE]); in throtl_pending_timer_fn()
1838 return !limit || sq->nr_queued[rw]; in throtl_low_limit_reached()
2202 if (sq->nr_queued[rw]) in __blk_throtl_bio()
2251 sq->nr_queued[READ], sq->nr_queued[WRITE]); in __blk_throtl_bio()
2255 td->nr_queued[rw]++; in __blk_throtl_bio()