Commit c8a446ad authored by Christoph Hellwig's avatar Christoph Hellwig Committed by Jens Axboe

blk-mq: rename blk_mq_end_io to blk_mq_end_request

Now that we've changed the driver API on the submission side use the
opportunity to fix up the name on the completion side to fit into the
general scheme.
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarJens Axboe <axboe@fb.com>
parent e2490073
...@@ -202,7 +202,7 @@ static bool blk_flush_complete_seq(struct request *rq, unsigned int seq, ...@@ -202,7 +202,7 @@ static bool blk_flush_complete_seq(struct request *rq, unsigned int seq,
list_del_init(&rq->flush.list); list_del_init(&rq->flush.list);
blk_flush_restore_request(rq); blk_flush_restore_request(rq);
if (q->mq_ops) if (q->mq_ops)
blk_mq_end_io(rq, error); blk_mq_end_request(rq, error);
else else
__blk_end_request_all(rq, error); __blk_end_request_all(rq, error);
break; break;
...@@ -378,7 +378,7 @@ void blk_insert_flush(struct request *rq) ...@@ -378,7 +378,7 @@ void blk_insert_flush(struct request *rq)
*/ */
if (!policy) { if (!policy) {
if (q->mq_ops) if (q->mq_ops)
blk_mq_end_io(rq, 0); blk_mq_end_request(rq, 0);
else else
__blk_end_bidi_request(rq, 0, 0, 0); __blk_end_bidi_request(rq, 0, 0, 0);
return; return;
......
...@@ -300,7 +300,7 @@ void blk_mq_clone_flush_request(struct request *flush_rq, ...@@ -300,7 +300,7 @@ void blk_mq_clone_flush_request(struct request *flush_rq,
hctx->cmd_size); hctx->cmd_size);
} }
inline void __blk_mq_end_io(struct request *rq, int error) inline void __blk_mq_end_request(struct request *rq, int error)
{ {
blk_account_io_done(rq); blk_account_io_done(rq);
...@@ -312,15 +312,15 @@ inline void __blk_mq_end_io(struct request *rq, int error) ...@@ -312,15 +312,15 @@ inline void __blk_mq_end_io(struct request *rq, int error)
blk_mq_free_request(rq); blk_mq_free_request(rq);
} }
} }
EXPORT_SYMBOL(__blk_mq_end_io); EXPORT_SYMBOL(__blk_mq_end_request);
void blk_mq_end_io(struct request *rq, int error) void blk_mq_end_request(struct request *rq, int error)
{ {
if (blk_update_request(rq, error, blk_rq_bytes(rq))) if (blk_update_request(rq, error, blk_rq_bytes(rq)))
BUG(); BUG();
__blk_mq_end_io(rq, error); __blk_mq_end_request(rq, error);
} }
EXPORT_SYMBOL(blk_mq_end_io); EXPORT_SYMBOL(blk_mq_end_request);
static void __blk_mq_complete_request_remote(void *data) static void __blk_mq_complete_request_remote(void *data)
{ {
...@@ -360,7 +360,7 @@ void __blk_mq_complete_request(struct request *rq) ...@@ -360,7 +360,7 @@ void __blk_mq_complete_request(struct request *rq)
struct request_queue *q = rq->q; struct request_queue *q = rq->q;
if (!q->softirq_done_fn) if (!q->softirq_done_fn)
blk_mq_end_io(rq, rq->errors); blk_mq_end_request(rq, rq->errors);
else else
blk_mq_ipi_complete_request(rq); blk_mq_ipi_complete_request(rq);
} }
...@@ -758,7 +758,7 @@ static void __blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx) ...@@ -758,7 +758,7 @@ static void __blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx)
pr_err("blk-mq: bad return on queue: %d\n", ret); pr_err("blk-mq: bad return on queue: %d\n", ret);
case BLK_MQ_RQ_QUEUE_ERROR: case BLK_MQ_RQ_QUEUE_ERROR:
rq->errors = -EIO; rq->errors = -EIO;
blk_mq_end_io(rq, rq->errors); blk_mq_end_request(rq, rq->errors);
break; break;
} }
...@@ -1200,7 +1200,7 @@ static void blk_mq_make_request(struct request_queue *q, struct bio *bio) ...@@ -1200,7 +1200,7 @@ static void blk_mq_make_request(struct request_queue *q, struct bio *bio)
if (ret == BLK_MQ_RQ_QUEUE_ERROR) { if (ret == BLK_MQ_RQ_QUEUE_ERROR) {
rq->errors = -EIO; rq->errors = -EIO;
blk_mq_end_io(rq, rq->errors); blk_mq_end_request(rq, rq->errors);
goto done; goto done;
} }
} }
......
...@@ -247,7 +247,7 @@ static void mtip_async_complete(struct mtip_port *port, ...@@ -247,7 +247,7 @@ static void mtip_async_complete(struct mtip_port *port,
if (unlikely(cmd->unaligned)) if (unlikely(cmd->unaligned))
up(&port->cmd_slot_unal); up(&port->cmd_slot_unal);
blk_mq_end_io(rq, status ? -EIO : 0); blk_mq_end_request(rq, status ? -EIO : 0);
} }
/* /*
...@@ -3739,7 +3739,7 @@ static int mtip_submit_request(struct blk_mq_hw_ctx *hctx, struct request *rq) ...@@ -3739,7 +3739,7 @@ static int mtip_submit_request(struct blk_mq_hw_ctx *hctx, struct request *rq)
int err; int err;
err = mtip_send_trim(dd, blk_rq_pos(rq), blk_rq_sectors(rq)); err = mtip_send_trim(dd, blk_rq_pos(rq), blk_rq_sectors(rq));
blk_mq_end_io(rq, err); blk_mq_end_request(rq, err);
return 0; return 0;
} }
......
...@@ -177,7 +177,7 @@ static void end_cmd(struct nullb_cmd *cmd) ...@@ -177,7 +177,7 @@ static void end_cmd(struct nullb_cmd *cmd)
{ {
switch (queue_mode) { switch (queue_mode) {
case NULL_Q_MQ: case NULL_Q_MQ:
blk_mq_end_io(cmd->rq, 0); blk_mq_end_request(cmd->rq, 0);
return; return;
case NULL_Q_RQ: case NULL_Q_RQ:
INIT_LIST_HEAD(&cmd->rq->queuelist); INIT_LIST_HEAD(&cmd->rq->queuelist);
......
...@@ -135,7 +135,7 @@ static inline void virtblk_request_done(struct request *req) ...@@ -135,7 +135,7 @@ static inline void virtblk_request_done(struct request *req)
req->errors = (error != 0); req->errors = (error != 0);
} }
blk_mq_end_io(req, error); blk_mq_end_request(req, error);
} }
static void virtblk_done(struct virtqueue *vq) static void virtblk_done(struct virtqueue *vq)
......
...@@ -713,7 +713,7 @@ static bool scsi_end_request(struct request *req, int error, ...@@ -713,7 +713,7 @@ static bool scsi_end_request(struct request *req, int error,
if (req->mq_ctx) { if (req->mq_ctx) {
/* /*
* In the MQ case the command gets freed by __blk_mq_end_io, * In the MQ case the command gets freed by __blk_mq_end_request,
* so we have to do all cleanup that depends on it earlier. * so we have to do all cleanup that depends on it earlier.
* *
* We also can't kick the queues from irq context, so we * We also can't kick the queues from irq context, so we
...@@ -721,7 +721,7 @@ static bool scsi_end_request(struct request *req, int error, ...@@ -721,7 +721,7 @@ static bool scsi_end_request(struct request *req, int error,
*/ */
scsi_mq_uninit_cmd(cmd); scsi_mq_uninit_cmd(cmd);
__blk_mq_end_io(req, error); __blk_mq_end_request(req, error);
if (scsi_target(sdev)->single_lun || if (scsi_target(sdev)->single_lun ||
!list_empty(&sdev->host->starved_list)) !list_empty(&sdev->host->starved_list))
......
...@@ -160,8 +160,8 @@ struct blk_mq_hw_ctx *blk_mq_map_queue(struct request_queue *, const int ctx_ind ...@@ -160,8 +160,8 @@ struct blk_mq_hw_ctx *blk_mq_map_queue(struct request_queue *, const int ctx_ind
struct blk_mq_hw_ctx *blk_mq_alloc_single_hw_queue(struct blk_mq_tag_set *, unsigned int, int); struct blk_mq_hw_ctx *blk_mq_alloc_single_hw_queue(struct blk_mq_tag_set *, unsigned int, int);
void blk_mq_start_request(struct request *rq); void blk_mq_start_request(struct request *rq);
void blk_mq_end_io(struct request *rq, int error); void blk_mq_end_request(struct request *rq, int error);
void __blk_mq_end_io(struct request *rq, int error); void __blk_mq_end_request(struct request *rq, int error);
void blk_mq_requeue_request(struct request *rq); void blk_mq_requeue_request(struct request *rq);
void blk_mq_add_to_requeue_list(struct request *rq, bool at_head); void blk_mq_add_to_requeue_list(struct request *rq, bool at_head);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment