Lines Matching refs:queued

80 	struct list_head	queued[2];	/* throtl_qnode [READ/WRITE] */  member
408 struct list_head *queued) in throtl_qnode_add_bio() argument
412 list_add_tail(&qn->node, queued); in throtl_qnode_add_bio()
421 static struct bio *throtl_peek_queued(struct list_head *queued) in throtl_peek_queued() argument
423 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_peek_queued()
426 if (list_empty(queued)) in throtl_peek_queued()
448 static struct bio *throtl_pop_queued(struct list_head *queued, in throtl_pop_queued() argument
451 struct throtl_qnode *qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_pop_queued()
454 if (list_empty(queued)) in throtl_pop_queued()
467 list_move_tail(&qn->node, queued); in throtl_pop_queued()
476 INIT_LIST_HEAD(&sq->queued[0]); in throtl_service_queue_init()
477 INIT_LIST_HEAD(&sq->queued[1]); in throtl_service_queue_init()
992 bio != throtl_peek_queued(&tg->service_queue.queued[rw])); in tg_may_dispatch()
1084 throtl_qnode_add_bio(bio, qn, &sq->queued[rw]); in throtl_add_bio_tg()
1096 bio = throtl_peek_queued(&sq->queued[READ]); in tg_update_disptime()
1100 bio = throtl_peek_queued(&sq->queued[WRITE]); in tg_update_disptime()
1140 bio = throtl_pop_queued(&sq->queued[rw], &tg_to_put); in tg_dispatch_one_bio()
1157 &parent_sq->queued[rw]); in tg_dispatch_one_bio()
1178 while ((bio = throtl_peek_queued(&sq->queued[READ])) && in throtl_dispatch_tg()
1188 while ((bio = throtl_peek_queued(&sq->queued[WRITE])) && in throtl_dispatch_tg()
1330 while ((bio = throtl_pop_queued(&td_sq->queued[rw], NULL))) in blk_throtl_dispatch_work_fn()
2348 while ((bio = throtl_peek_queued(&sq->queued[READ]))) in tg_drain_bios()
2350 while ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_drain_bios()
2390 while ((bio = throtl_pop_queued(&td->service_queue.queued[rw], in blk_throtl_drain()