Lines Matching refs:queued
173 list_add_tail(&qn->node, &sq->queued[rw]); in throtl_qnode_add_bio()
186 static struct bio *throtl_peek_queued(struct list_head *queued) in throtl_peek_queued() argument
191 if (list_empty(queued)) in throtl_peek_queued()
194 qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_peek_queued()
221 struct list_head *queued = &sq->queued[rw]; in throtl_pop_queued() local
225 if (list_empty(queued)) in throtl_pop_queued()
228 qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_pop_queued()
246 list_move_tail(&qn->node, queued); in throtl_pop_queued()
255 INIT_LIST_HEAD(&sq->queued[READ]); in throtl_service_queue_init()
256 INIT_LIST_HEAD(&sq->queued[WRITE]); in throtl_service_queue_init()
903 bio != throtl_peek_queued(&tg->service_queue.queued[rw])); in tg_dispatch_time()
953 bio == throtl_peek_queued(&sq->queued[rw])) in throtl_add_bio_tg()
965 bio = throtl_peek_queued(&sq->queued[READ]); in tg_update_disptime()
969 bio = throtl_peek_queued(&sq->queued[WRITE]); in tg_update_disptime()
1048 while ((bio = throtl_peek_queued(&sq->queued[READ])) && in throtl_dispatch_tg()
1058 while ((bio = throtl_peek_queued(&sq->queued[WRITE])) && in throtl_dispatch_tg()