Lines Matching refs:q
95 static bool blk_kick_flush(struct request_queue *q,
135 if (rq->q->mq_ops) { in blk_flush_queue_rq()
136 struct request_queue *q = rq->q; in blk_flush_queue_rq() local
139 blk_mq_kick_requeue_list(q); in blk_flush_queue_rq()
143 list_add(&rq->queuelist, &rq->q->queue_head); in blk_flush_queue_rq()
145 list_add_tail(&rq->queuelist, &rq->q->queue_head); in blk_flush_queue_rq()
170 struct request_queue *q = rq->q; in blk_flush_complete_seq() local
206 if (q->mq_ops) in blk_flush_complete_seq()
216 kicked = blk_kick_flush(q, fq); in blk_flush_complete_seq()
222 struct request_queue *q = flush_rq->q; in flush_end_io() local
227 struct blk_flush_queue *fq = blk_get_flush_queue(q, flush_rq->mq_ctx); in flush_end_io()
229 if (q->mq_ops) { in flush_end_io()
234 hctx = q->mq_ops->map_queue(q, flush_rq->mq_ctx->cpu); in flush_end_io()
245 if (!q->mq_ops) in flush_end_io()
246 elv_completed_request(q, flush_rq); in flush_end_io()
268 WARN_ON(q->mq_ops); in flush_end_io()
269 blk_run_queue_async(q); in flush_end_io()
272 if (q->mq_ops) in flush_end_io()
290 static bool blk_kick_flush(struct request_queue *q, struct blk_flush_queue *fq) in blk_kick_flush() argument
313 blk_rq_init(q, flush_rq); in blk_kick_flush()
320 if (q->mq_ops) { in blk_kick_flush()
327 hctx = q->mq_ops->map_queue(q, first_rq->mq_ctx->cpu); in blk_kick_flush()
341 struct request_queue *q = rq->q; in flush_data_end_io() local
342 struct blk_flush_queue *fq = blk_get_flush_queue(q, NULL); in flush_data_end_io()
349 blk_run_queue_async(q); in flush_data_end_io()
354 struct request_queue *q = rq->q; in mq_flush_data_end_io() local
358 struct blk_flush_queue *fq = blk_get_flush_queue(q, ctx); in mq_flush_data_end_io()
360 hctx = q->mq_ops->map_queue(q, ctx->cpu); in mq_flush_data_end_io()
386 struct request_queue *q = rq->q; in blk_insert_flush() local
387 unsigned int fflags = q->flush_flags; /* may change, cache */ in blk_insert_flush()
389 struct blk_flush_queue *fq = blk_get_flush_queue(q, rq->mq_ctx); in blk_insert_flush()
406 if (q->mq_ops) in blk_insert_flush()
422 if (q->mq_ops) { in blk_insert_flush()
425 list_add_tail(&rq->queuelist, &q->queue_head); in blk_insert_flush()
437 if (q->mq_ops) { in blk_insert_flush()
465 struct request_queue *q; in blkdev_issue_flush() local
472 q = bdev_get_queue(bdev); in blkdev_issue_flush()
473 if (!q) in blkdev_issue_flush()
482 if (!q->make_request_fn) in blkdev_issue_flush()
503 struct blk_flush_queue *blk_alloc_flush_queue(struct request_queue *q, in blk_alloc_flush_queue() argument
513 if (q->mq_ops) { in blk_alloc_flush_queue()