Lines Matching refs:flush_rq
219 static void flush_end_io(struct request *flush_rq, int error) in flush_end_io() argument
221 struct request_queue *q = flush_rq->q; in flush_end_io()
226 struct blk_flush_queue *fq = blk_get_flush_queue(q, flush_rq->mq_ctx); in flush_end_io()
230 flush_rq->tag = -1; in flush_end_io()
240 elv_completed_request(q, flush_rq); in flush_end_io()
289 struct request *flush_rq = fq->flush_rq; in blk_kick_flush() local
307 blk_rq_init(q, flush_rq); in blk_kick_flush()
314 flush_rq->mq_ctx = first_rq->mq_ctx; in blk_kick_flush()
315 flush_rq->tag = first_rq->tag; in blk_kick_flush()
318 flush_rq->cmd_type = REQ_TYPE_FS; in blk_kick_flush()
319 flush_rq->cmd_flags = WRITE_FLUSH | REQ_FLUSH_SEQ; in blk_kick_flush()
320 flush_rq->rq_disk = first_rq->rq_disk; in blk_kick_flush()
321 flush_rq->end_io = flush_end_io; in blk_kick_flush()
323 return blk_flush_queue_rq(flush_rq, false); in blk_kick_flush()
505 fq->flush_rq = kzalloc_node(rq_sz, GFP_KERNEL, node); in blk_alloc_flush_queue()
506 if (!fq->flush_rq) in blk_alloc_flush_queue()
527 kfree(fq->flush_rq); in blk_free_flush_queue()