94 static bool blk_kick_flush(struct request_queue *q,
134 	if (rq->q->mq_ops) {  in blk_flush_queue_rq()
135 		struct request_queue *q = rq->q;  in blk_flush_queue_rq()  local
138 		blk_mq_kick_requeue_list(q);  in blk_flush_queue_rq()
142 			list_add(&rq->queuelist, &rq->q->queue_head);  in blk_flush_queue_rq()
144 			list_add_tail(&rq->queuelist, &rq->q->queue_head);  in blk_flush_queue_rq()
169 	struct request_queue *q = rq->q;  in blk_flush_complete_seq()  local
205 		if (q->mq_ops)  in blk_flush_complete_seq()
215 	kicked = blk_kick_flush(q, fq);  in blk_flush_complete_seq()
221 	struct request_queue *q = flush_rq->q;  in flush_end_io()  local
226 	struct blk_flush_queue *fq = blk_get_flush_queue(q, flush_rq->mq_ctx);  in flush_end_io()
228 	if (q->mq_ops) {  in flush_end_io()
239 	if (!q->mq_ops)  in flush_end_io()
240 		elv_completed_request(q, flush_rq);  in flush_end_io()
262 		WARN_ON(q->mq_ops);  in flush_end_io()
263 		blk_run_queue_async(q);  in flush_end_io()
266 	if (q->mq_ops)  in flush_end_io()
284 static bool blk_kick_flush(struct request_queue *q, struct blk_flush_queue *fq)  in blk_kick_flush()  argument
307 	blk_rq_init(q, flush_rq);  in blk_kick_flush()
313 	if (q->mq_ops) {  in blk_kick_flush()
328 	struct request_queue *q = rq->q;  in flush_data_end_io()  local
329 	struct blk_flush_queue *fq = blk_get_flush_queue(q, NULL);  in flush_data_end_io()
336 		blk_run_queue_async(q);  in flush_data_end_io()
341 	struct request_queue *q = rq->q;  in mq_flush_data_end_io()  local
345 	struct blk_flush_queue *fq = blk_get_flush_queue(q, ctx);  in mq_flush_data_end_io()
347 	hctx = q->mq_ops->map_queue(q, ctx->cpu);  in mq_flush_data_end_io()
373 	struct request_queue *q = rq->q;  in blk_insert_flush()  local
374 	unsigned int fflags = q->flush_flags;	/* may change, cache */  in blk_insert_flush()
376 	struct blk_flush_queue *fq = blk_get_flush_queue(q, rq->mq_ctx);  in blk_insert_flush()
393 		if (q->mq_ops)  in blk_insert_flush()
409 		if (q->mq_ops) {  in blk_insert_flush()
412 			list_add_tail(&rq->queuelist, &q->queue_head);  in blk_insert_flush()
424 	if (q->mq_ops) {  in blk_insert_flush()
452 	struct request_queue *q;  in blkdev_issue_flush()  local
459 	q = bdev_get_queue(bdev);  in blkdev_issue_flush()
460 	if (!q)  in blkdev_issue_flush()
469 	if (!q->make_request_fn)  in blkdev_issue_flush()
490 struct blk_flush_queue *blk_alloc_flush_queue(struct request_queue *q,  in blk_alloc_flush_queue()  argument
500 	if (q->mq_ops) {  in blk_alloc_flush_queue()