Lines Matching refs:new_cfqq
147 struct cfq_queue *new_cfqq; member
2030 int new_cfqq = 1; in cfq_service_tree_add() local
2058 new_cfqq = 0; in cfq_service_tree_add()
2095 if (add_front || !new_cfqq) in cfq_service_tree_add()
2857 static void cfq_setup_merge(struct cfq_queue *cfqq, struct cfq_queue *new_cfqq) in cfq_setup_merge() argument
2868 if (!cfqq_process_refs(new_cfqq)) in cfq_setup_merge()
2872 while ((__cfqq = new_cfqq->new_cfqq)) { in cfq_setup_merge()
2875 new_cfqq = __cfqq; in cfq_setup_merge()
2879 new_process_refs = cfqq_process_refs(new_cfqq); in cfq_setup_merge()
2891 cfqq->new_cfqq = new_cfqq; in cfq_setup_merge()
2892 new_cfqq->ref += process_refs; in cfq_setup_merge()
2894 new_cfqq->new_cfqq = cfqq; in cfq_setup_merge()
3040 struct cfq_queue *cfqq, *new_cfqq = NULL; in cfq_select_queue() local
3089 new_cfqq = cfq_close_cooperator(cfqd, cfqq); in cfq_select_queue()
3090 if (new_cfqq) { in cfq_select_queue()
3091 if (!cfqq->new_cfqq) in cfq_select_queue()
3092 cfq_setup_merge(cfqq, new_cfqq); in cfq_select_queue()
3141 if (!new_cfqq) in cfq_select_queue()
3144 cfqq = cfq_set_active_queue(cfqd, new_cfqq); in cfq_select_queue()
3405 __cfqq = cfqq->new_cfqq; in cfq_put_cooperator()
3411 next = __cfqq->new_cfqq; in cfq_put_cooperator()
3509 struct cfq_queue *new_cfqq; in check_ioprio_changed() local
3510 new_cfqq = cfq_get_queue(cfqd, BLK_RW_ASYNC, cic, bio, in check_ioprio_changed()
3512 if (new_cfqq) { in check_ioprio_changed()
3513 cic->cfqq[BLK_RW_ASYNC] = new_cfqq; in check_ioprio_changed()
3585 struct cfq_queue *cfqq, *new_cfqq = NULL; in cfq_find_alloc_queue() local
3606 if (new_cfqq) { in cfq_find_alloc_queue()
3607 cfqq = new_cfqq; in cfq_find_alloc_queue()
3608 new_cfqq = NULL; in cfq_find_alloc_queue()
3612 new_cfqq = kmem_cache_alloc_node(cfq_pool, in cfq_find_alloc_queue()
3616 if (new_cfqq) in cfq_find_alloc_queue()
3635 if (new_cfqq) in cfq_find_alloc_queue()
3636 kmem_cache_free(cfq_pool, new_cfqq); in cfq_find_alloc_queue()
3787 cfq_should_preempt(struct cfq_data *cfqd, struct cfq_queue *new_cfqq, in cfq_should_preempt() argument
3796 if (cfq_class_idle(new_cfqq)) in cfq_should_preempt()
3805 if (cfq_class_rt(cfqq) && !cfq_class_rt(new_cfqq)) in cfq_should_preempt()
3815 if (new_cfqq->cfqg != cfqq->cfqg) in cfq_should_preempt()
3823 cfqq_type(new_cfqq) == SYNC_NOIDLE_WORKLOAD && in cfq_should_preempt()
3824 new_cfqq->service_tree->count == 2 && in cfq_should_preempt()
3838 if (cfq_class_rt(new_cfqq) && !cfq_class_rt(cfqq)) in cfq_should_preempt()
4183 cfq_log_cfqq(cfqd, cfqq, "merging with queue %p", cfqq->new_cfqq); in cfq_merge_cfqqs()
4184 cic_set_cfqq(cic, cfqq->new_cfqq, 1); in cfq_merge_cfqqs()
4185 cfq_mark_cfqq_coop(cfqq->new_cfqq); in cfq_merge_cfqqs()
4252 if (cfqq->new_cfqq) in cfq_set_request()