Lines Matching refs:queued
65 struct list_head queued[2]; /* throtl_qnode [READ/WRITE] */ member
251 struct list_head *queued) in throtl_qnode_add_bio() argument
255 list_add_tail(&qn->node, queued); in throtl_qnode_add_bio()
264 static struct bio *throtl_peek_queued(struct list_head *queued) in throtl_peek_queued() argument
266 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_peek_queued()
269 if (list_empty(queued)) in throtl_peek_queued()
291 static struct bio *throtl_pop_queued(struct list_head *queued, in throtl_pop_queued() argument
294 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_pop_queued()
297 if (list_empty(queued)) in throtl_pop_queued()
310 list_move_tail(&qn->node, queued); in throtl_pop_queued()
319 INIT_LIST_HEAD(&sq->queued[0]); in throtl_service_queue_init()
320 INIT_LIST_HEAD(&sq->queued[1]); in throtl_service_queue_init()
777 bio != throtl_peek_queued(&tg->service_queue.queued[rw])); in tg_may_dispatch()
861 throtl_qnode_add_bio(bio, qn, &sq->queued[rw]); in throtl_add_bio_tg()
873 if ((bio = throtl_peek_queued(&sq->queued[READ]))) in tg_update_disptime()
876 if ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_update_disptime()
915 bio = throtl_pop_queued(&sq->queued[rw], &tg_to_put); in tg_dispatch_one_bio()
932 &parent_sq->queued[rw]); in tg_dispatch_one_bio()
953 while ((bio = throtl_peek_queued(&sq->queued[READ])) && in throtl_dispatch_tg()
963 while ((bio = throtl_peek_queued(&sq->queued[WRITE])) && in throtl_dispatch_tg()
1099 while ((bio = throtl_pop_queued(&td_sq->queued[rw], NULL))) in blk_throtl_dispatch_work_fn()
1506 while ((bio = throtl_peek_queued(&sq->queued[READ]))) in tg_drain_bios()
1508 while ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_drain_bios()
1548 while ((bio = throtl_pop_queued(&td->service_queue.queued[rw], in blk_throtl_drain()