Lines Matching refs:bfqd

227 	if (!(bfqq == ((struct bfq_data *)bfqg->bfqd)->in_service_queue))  in bfqg_stats_update_io_add()
314 bfqq->bfqd->root_group; in bfqq_group()
544 struct bfq_data *bfqd = blkg->q->elevator->elevator_data; in bfq_pd_init() local
554 bfqg->bfqd = bfqd; in bfq_pd_init()
584 static struct bfq_group *bfq_lookup_bfqg(struct bfq_data *bfqd, in bfq_lookup_bfqg() argument
589 blkg = blkg_lookup(blkcg, bfqd->queue); in bfq_lookup_bfqg()
595 struct bfq_group *bfq_find_set_group(struct bfq_data *bfqd, in bfq_find_set_group() argument
601 bfqg = bfq_lookup_bfqg(bfqd, blkcg); in bfq_find_set_group()
615 if (curr_bfqg != bfqd->root_group) { in bfq_find_set_group()
618 parent = bfqd->root_group; in bfq_find_set_group()
640 void bfq_bfqq_move(struct bfq_data *bfqd, struct bfq_queue *bfqq, in bfq_bfqq_move() argument
657 if (bfqq == bfqd->in_service_queue) in bfq_bfqq_move()
658 bfq_bfqq_expire(bfqd, bfqd->in_service_queue, in bfq_bfqq_move()
662 bfq_deactivate_bfqq(bfqd, bfqq, false, false); in bfq_bfqq_move()
673 if (unlikely(!bfqd->nonrot_with_queueing)) in bfq_bfqq_move()
674 bfq_pos_tree_add_move(bfqd, bfqq); in bfq_bfqq_move()
675 bfq_activate_bfqq(bfqd, bfqq); in bfq_bfqq_move()
678 if (!bfqd->in_service_queue && !bfqd->rq_in_driver) in bfq_bfqq_move()
679 bfq_schedule_dispatch(bfqd); in bfq_bfqq_move()
698 static struct bfq_group *__bfq_bic_change_cgroup(struct bfq_data *bfqd, in __bfq_bic_change_cgroup() argument
707 bfqg = bfq_find_set_group(bfqd, blkcg); in __bfq_bic_change_cgroup()
710 bfqg = bfqd->root_group; in __bfq_bic_change_cgroup()
717 bfq_release_process_ref(bfqd, async_bfqq); in __bfq_bic_change_cgroup()
724 bfq_bfqq_move(bfqd, sync_bfqq, bfqg); in __bfq_bic_change_cgroup()
732 struct bfq_data *bfqd = bic_to_bfqd(bic); in bfq_bic_update_cgroup() local
743 if (unlikely(!bfqd) || likely(bic->blkcg_serial_nr == serial_nr)) in bfq_bic_update_cgroup()
746 bfqg = __bfq_bic_change_cgroup(bfqd, bic, __bio_blkcg(bio)); in bfq_bic_update_cgroup()
821 static void bfq_reparent_leaf_entity(struct bfq_data *bfqd, in bfq_reparent_leaf_entity() argument
841 bfq_bfqq_move(bfqd, bfqq, bfqd->root_group); in bfq_reparent_leaf_entity()
850 static void bfq_reparent_active_queues(struct bfq_data *bfqd, in bfq_reparent_active_queues() argument
859 bfq_reparent_leaf_entity(bfqd, entity, ioprio_class); in bfq_reparent_active_queues()
862 bfq_reparent_leaf_entity(bfqd, in bfq_reparent_active_queues()
879 struct bfq_data *bfqd = bfqg->bfqd; in bfq_pd_offline() local
884 spin_lock_irqsave(&bfqd->lock, flags); in bfq_pd_offline()
908 bfq_reparent_active_queues(bfqd, bfqg, st, i); in bfq_pd_offline()
927 bfq_put_async_queues(bfqd, bfqg); in bfq_pd_offline()
929 spin_unlock_irqrestore(&bfqd->lock, flags); in bfq_pd_offline()
939 void bfq_end_wr_async(struct bfq_data *bfqd) in bfq_end_wr_async() argument
943 list_for_each_entry(blkg, &bfqd->queue->blkg_list, q_node) { in bfq_end_wr_async()
946 bfq_end_wr_async_queues(bfqd, bfqg); in bfq_end_wr_async()
948 bfq_end_wr_async_queues(bfqd, bfqd->root_group); in bfq_end_wr_async()
1229 struct bfq_group *bfq_create_group_hierarchy(struct bfq_data *bfqd, int node) in bfq_create_group_hierarchy() argument
1233 ret = blkcg_activate_policy(bfqd->queue, &blkcg_policy_bfq); in bfq_create_group_hierarchy()
1237 return blkg_to_bfqg(bfqd->queue->root_blkg); in bfq_create_group_hierarchy()
1394 void bfq_bfqq_move(struct bfq_data *bfqd, struct bfq_queue *bfqq, in bfq_bfqq_move() argument
1412 void bfq_end_wr_async(struct bfq_data *bfqd) in bfq_end_wr_async() argument
1414 bfq_end_wr_async_queues(bfqd, bfqd->root_group); in bfq_end_wr_async()
1417 struct bfq_group *bfq_find_set_group(struct bfq_data *bfqd, struct blkcg *blkcg) in bfq_find_set_group() argument
1419 return bfqd->root_group; in bfq_find_set_group()
1424 return bfqq->bfqd->root_group; in bfqq_group()
1431 struct bfq_group *bfq_create_group_hierarchy(struct bfq_data *bfqd, int node) in bfq_create_group_hierarchy() argument