Lines Matching refs:q

94 static void blk_kick_flush(struct request_queue *q,
98 blk_get_flush_queue(struct request_queue *q, struct blk_mq_ctx *ctx) in blk_get_flush_queue() argument
100 return blk_mq_map_queue(q, REQ_OP_FLUSH, ctx)->fq; in blk_get_flush_queue()
141 struct block_device *part = rq->q->disk->part0; in blk_account_io_flush()
167 struct request_queue *q = rq->q; in blk_flush_complete_seq() local
191 spin_lock(&q->requeue_lock); in blk_flush_complete_seq()
192 list_move(&rq->queuelist, &q->requeue_list); in blk_flush_complete_seq()
193 spin_unlock(&q->requeue_lock); in blk_flush_complete_seq()
194 blk_mq_kick_requeue_list(q); in blk_flush_complete_seq()
213 blk_kick_flush(q, fq, cmd_flags); in blk_flush_complete_seq()
219 struct request_queue *q = flush_rq->q; in flush_end_io() local
223 struct blk_flush_queue *fq = blk_get_flush_queue(q, flush_rq->mq_ctx); in flush_end_io()
246 if (!q->elevator) { in flush_end_io()
290 static void blk_kick_flush(struct request_queue *q, struct blk_flush_queue *fq, in blk_kick_flush() argument
314 blk_rq_init(q, flush_rq); in blk_kick_flush()
327 if (!q->elevator) { in blk_kick_flush()
352 spin_lock(&q->requeue_lock); in blk_kick_flush()
353 list_add_tail(&flush_rq->queuelist, &q->flush_list); in blk_kick_flush()
354 spin_unlock(&q->requeue_lock); in blk_kick_flush()
356 blk_mq_kick_requeue_list(q); in blk_kick_flush()
362 struct request_queue *q = rq->q; in mq_flush_data_end_io() local
366 struct blk_flush_queue *fq = blk_get_flush_queue(q, ctx); in mq_flush_data_end_io()
368 if (q->elevator) { in mq_flush_data_end_io()
406 struct request_queue *q = rq->q; in blk_insert_flush() local
407 unsigned long fflags = q->queue_flags; /* may change, cache */ in blk_insert_flush()
409 struct blk_flush_queue *fq = blk_get_flush_queue(q, rq->mq_ctx); in blk_insert_flush()