2077 bfq_setup_merge(struct bfq_queue *bfqq, struct bfq_queue *new_bfqq)  in bfq_setup_merge()  argument
2088 	if (!bfqq_process_refs(new_bfqq))  in bfq_setup_merge()
2092 	while ((__bfqq = new_bfqq->new_bfqq)) {  in bfq_setup_merge()
2095 		new_bfqq = __bfqq;  in bfq_setup_merge()
2099 	new_process_refs = bfqq_process_refs(new_bfqq);  in bfq_setup_merge()
2108 		new_bfqq->pid);  in bfq_setup_merge()
2130 	bfqq->new_bfqq = new_bfqq;  in bfq_setup_merge()
2131 	new_bfqq->ref += process_refs;  in bfq_setup_merge()
2132 	return new_bfqq;  in bfq_setup_merge()
2136 					struct bfq_queue *new_bfqq)  in bfq_may_be_close_cooperator()  argument
2138 	if (bfq_too_late_for_merging(new_bfqq))  in bfq_may_be_close_cooperator()
2141 	if (bfq_class_idle(bfqq) || bfq_class_idle(new_bfqq) ||  in bfq_may_be_close_cooperator()
2142 	    (bfqq->ioprio_class != new_bfqq->ioprio_class))  in bfq_may_be_close_cooperator()
2150 	if (BFQQ_SEEKY(bfqq) || BFQQ_SEEKY(new_bfqq))  in bfq_may_be_close_cooperator()
2158 	if (!bfq_bfqq_sync(bfqq) || !bfq_bfqq_sync(new_bfqq))  in bfq_may_be_close_cooperator()
2188 	struct bfq_queue *in_service_bfqq, *new_bfqq;  in bfq_setup_cooperator()  local
2204 	if (bfqq->new_bfqq)  in bfq_setup_cooperator()
2205 		return bfqq->new_bfqq;  in bfq_setup_cooperator()
2221 		new_bfqq = bfq_setup_merge(bfqq, in_service_bfqq);  in bfq_setup_cooperator()
2222 		if (new_bfqq)  in bfq_setup_cooperator()
2223 			return new_bfqq;  in bfq_setup_cooperator()
2230 	new_bfqq = bfq_find_close_cooperator(bfqd, bfqq,  in bfq_setup_cooperator()
2233 	if (new_bfqq && likely(new_bfqq != &bfqd->oom_bfqq) &&  in bfq_setup_cooperator()
2234 	    bfq_may_be_close_cooperator(bfqq, new_bfqq))  in bfq_setup_cooperator()
2235 		return bfq_setup_merge(bfqq, new_bfqq);  in bfq_setup_cooperator()
2283 		struct bfq_queue *bfqq, struct bfq_queue *new_bfqq)  in bfq_merge_bfqqs()  argument
2286 		(unsigned long)new_bfqq->pid);  in bfq_merge_bfqqs()
2289 	bfq_bfqq_save_state(new_bfqq);  in bfq_merge_bfqqs()
2291 		bfq_mark_bfqq_IO_bound(new_bfqq);  in bfq_merge_bfqqs()
2303 	if (new_bfqq->wr_coeff == 1 && bfqq->wr_coeff > 1) {  in bfq_merge_bfqqs()
2304 		new_bfqq->wr_coeff = bfqq->wr_coeff;  in bfq_merge_bfqqs()
2305 		new_bfqq->wr_cur_max_time = bfqq->wr_cur_max_time;  in bfq_merge_bfqqs()
2306 		new_bfqq->last_wr_start_finish = bfqq->last_wr_start_finish;  in bfq_merge_bfqqs()
2307 		new_bfqq->wr_start_at_switch_to_srt =  in bfq_merge_bfqqs()
2309 		if (bfq_bfqq_busy(new_bfqq))  in bfq_merge_bfqqs()
2311 		new_bfqq->entity.prio_changed = 1;  in bfq_merge_bfqqs()
2321 	bfq_log_bfqq(bfqd, new_bfqq, "merge_bfqqs: wr_busy %d",  in bfq_merge_bfqqs()
2327 	bic_set_bfqq(bic, new_bfqq, 1);  in bfq_merge_bfqqs()
2328 	bfq_mark_bfqq_coop(new_bfqq);  in bfq_merge_bfqqs()
2339 	new_bfqq->bic = NULL;  in bfq_merge_bfqqs()
2350 	struct bfq_queue *bfqq = bfqd->bio_bfqq, *new_bfqq;  in bfq_allow_bio_merge()  local
2369 	new_bfqq = bfq_setup_cooperator(bfqd, bfqq, bio, false);  in bfq_allow_bio_merge()
2370 	if (new_bfqq) {  in bfq_allow_bio_merge()
2379 				new_bfqq);  in bfq_allow_bio_merge()
2385 		bfqq = new_bfqq;  in bfq_allow_bio_merge()
4078 	__bfqq = bfqq->new_bfqq;  in bfq_put_cooperator()
4082 		next = __bfqq->new_bfqq;  in bfq_put_cooperator()
4487 		*new_bfqq = bfq_setup_cooperator(bfqd, bfqq, rq, true);  in __bfq_insert_request()  local
4490 	if (new_bfqq) {  in __bfq_insert_request()
4492 			new_bfqq = bic_to_bfqq(RQ_BIC(rq), 1);  in __bfq_insert_request()
4497 		new_bfqq->allocated++;  in __bfq_insert_request()
4499 		new_bfqq->ref++;  in __bfq_insert_request()
4510 					bfqq, new_bfqq);  in __bfq_insert_request()
4518 		rq->elv.priv[1] = new_bfqq;  in __bfq_insert_request()
4519 		bfqq = new_bfqq;  in __bfq_insert_request()