2482 bfq_setup_merge(struct bfq_queue *bfqq, struct bfq_queue *new_bfqq)  in bfq_setup_merge()  argument
2493 	if (!bfqq_process_refs(new_bfqq))  in bfq_setup_merge()
2497 	while ((__bfqq = new_bfqq->new_bfqq)) {  in bfq_setup_merge()
2500 		new_bfqq = __bfqq;  in bfq_setup_merge()
2504 	new_process_refs = bfqq_process_refs(new_bfqq);  in bfq_setup_merge()
2517 	if (new_bfqq->entity.parent != bfqq->entity.parent)  in bfq_setup_merge()
2521 		new_bfqq->pid);  in bfq_setup_merge()
2543 	bfqq->new_bfqq = new_bfqq;  in bfq_setup_merge()
2553 	new_bfqq->ref += process_refs;  in bfq_setup_merge()
2554 	return new_bfqq;  in bfq_setup_merge()
2558 					struct bfq_queue *new_bfqq)  in bfq_may_be_close_cooperator()  argument
2560 	if (bfq_too_late_for_merging(new_bfqq))  in bfq_may_be_close_cooperator()
2563 	if (bfq_class_idle(bfqq) || bfq_class_idle(new_bfqq) ||  in bfq_may_be_close_cooperator()
2564 	    (bfqq->ioprio_class != new_bfqq->ioprio_class))  in bfq_may_be_close_cooperator()
2572 	if (BFQQ_SEEKY(bfqq) || BFQQ_SEEKY(new_bfqq))  in bfq_may_be_close_cooperator()
2580 	if (!bfq_bfqq_sync(bfqq) || !bfq_bfqq_sync(new_bfqq))  in bfq_may_be_close_cooperator()
2610 	struct bfq_queue *in_service_bfqq, *new_bfqq;  in bfq_setup_cooperator()  local
2613 	if (bfqq->new_bfqq)  in bfq_setup_cooperator()
2614 		return bfqq->new_bfqq;  in bfq_setup_cooperator()
2685 		new_bfqq = bfq_setup_merge(bfqq, in_service_bfqq);  in bfq_setup_cooperator()
2686 		if (new_bfqq)  in bfq_setup_cooperator()
2687 			return new_bfqq;  in bfq_setup_cooperator()
2694 	new_bfqq = bfq_find_close_cooperator(bfqd, bfqq,  in bfq_setup_cooperator()
2697 	if (new_bfqq && likely(new_bfqq != &bfqd->oom_bfqq) &&  in bfq_setup_cooperator()
2698 	    bfq_may_be_close_cooperator(bfqq, new_bfqq))  in bfq_setup_cooperator()
2699 		return bfq_setup_merge(bfqq, new_bfqq);  in bfq_setup_cooperator()
2769 		struct bfq_queue *bfqq, struct bfq_queue *new_bfqq)  in bfq_merge_bfqqs()  argument
2772 		(unsigned long)new_bfqq->pid);  in bfq_merge_bfqqs()
2775 	bfq_bfqq_save_state(new_bfqq);  in bfq_merge_bfqqs()
2777 		bfq_mark_bfqq_IO_bound(new_bfqq);  in bfq_merge_bfqqs()
2789 	if (new_bfqq->wr_coeff == 1 && bfqq->wr_coeff > 1) {  in bfq_merge_bfqqs()
2790 		new_bfqq->wr_coeff = bfqq->wr_coeff;  in bfq_merge_bfqqs()
2791 		new_bfqq->wr_cur_max_time = bfqq->wr_cur_max_time;  in bfq_merge_bfqqs()
2792 		new_bfqq->last_wr_start_finish = bfqq->last_wr_start_finish;  in bfq_merge_bfqqs()
2793 		new_bfqq->wr_start_at_switch_to_srt =  in bfq_merge_bfqqs()
2795 		if (bfq_bfqq_busy(new_bfqq))  in bfq_merge_bfqqs()
2797 		new_bfqq->entity.prio_changed = 1;  in bfq_merge_bfqqs()
2807 	bfq_log_bfqq(bfqd, new_bfqq, "merge_bfqqs: wr_busy %d",  in bfq_merge_bfqqs()
2813 	bic_set_bfqq(bic, new_bfqq, 1);  in bfq_merge_bfqqs()
2814 	bfq_mark_bfqq_coop(new_bfqq);  in bfq_merge_bfqqs()
2825 	new_bfqq->bic = NULL;  in bfq_merge_bfqqs()
2835 	new_bfqq->pid = -1;  in bfq_merge_bfqqs()
2845 	struct bfq_queue *bfqq = bfqd->bio_bfqq, *new_bfqq;  in bfq_allow_bio_merge()  local
2864 	new_bfqq = bfq_setup_cooperator(bfqd, bfqq, bio, false);  in bfq_allow_bio_merge()
2865 	if (new_bfqq) {  in bfq_allow_bio_merge()
2874 				new_bfqq);  in bfq_allow_bio_merge()
2880 		bfqq = new_bfqq;  in bfq_allow_bio_merge()
4941 	__bfqq = bfqq->new_bfqq;  in bfq_put_cooperator()
4945 		next = __bfqq->new_bfqq;  in bfq_put_cooperator()
5429 		*new_bfqq = bfq_setup_cooperator(bfqd, bfqq, rq, true);  in __bfq_insert_request()  local
5432 	if (new_bfqq) {  in __bfq_insert_request()
5437 		new_bfqq->allocated++;  in __bfq_insert_request()
5439 		new_bfqq->ref++;  in __bfq_insert_request()
5450 					bfqq, new_bfqq);  in __bfq_insert_request()
5458 		rq->elv.priv[1] = new_bfqq;  in __bfq_insert_request()
5459 		bfqq = new_bfqq;  in __bfq_insert_request()