Lines Matching refs:queued
65 struct list_head queued[2]; /* throtl_qnode [READ/WRITE] */ member
324 struct list_head *queued) in throtl_qnode_add_bio() argument
328 list_add_tail(&qn->node, queued); in throtl_qnode_add_bio()
337 static struct bio *throtl_peek_queued(struct list_head *queued) in throtl_peek_queued() argument
339 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_peek_queued()
342 if (list_empty(queued)) in throtl_peek_queued()
364 static struct bio *throtl_pop_queued(struct list_head *queued, in throtl_pop_queued() argument
367 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_pop_queued()
370 if (list_empty(queued)) in throtl_pop_queued()
383 list_move_tail(&qn->node, queued); in throtl_pop_queued()
393 INIT_LIST_HEAD(&sq->queued[0]); in throtl_service_queue_init()
394 INIT_LIST_HEAD(&sq->queued[1]); in throtl_service_queue_init()
920 bio != throtl_peek_queued(&tg->service_queue.queued[rw])); in tg_may_dispatch()
1038 throtl_qnode_add_bio(bio, qn, &sq->queued[rw]); in throtl_add_bio_tg()
1050 if ((bio = throtl_peek_queued(&sq->queued[READ]))) in tg_update_disptime()
1053 if ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_update_disptime()
1092 bio = throtl_pop_queued(&sq->queued[rw], &tg_to_put); in tg_dispatch_one_bio()
1109 &parent_sq->queued[rw]); in tg_dispatch_one_bio()
1130 while ((bio = throtl_peek_queued(&sq->queued[READ])) && in throtl_dispatch_tg()
1140 while ((bio = throtl_peek_queued(&sq->queued[WRITE])) && in throtl_dispatch_tg()
1276 while ((bio = throtl_pop_queued(&td_sq->queued[rw], NULL))) in blk_throtl_dispatch_work_fn()
1611 while ((bio = throtl_peek_queued(&sq->queued[READ]))) in tg_drain_bios()
1613 while ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_drain_bios()
1653 while ((bio = throtl_pop_queued(&td->service_queue.queued[rw], in blk_throtl_drain()