Skip to content

Commit

Permalink
blk_end_request: cleanup of request completion (take 4)
Browse files Browse the repository at this point in the history
This patch merges complete_request() into end_that_request_last()
for cleanup.

complete_request() was introduced by earlier part of this patch-set,
not to break the existing users of end_that_request_last().

Since all users are converted to blk_end_request interfaces and
end_that_request_last() is no longer exported, the code can be
merged to end_that_request_last().

Cc: Boaz Harrosh <bharrosh@panasas.com>
Signed-off-by: Kiyoshi Ueda <k-ueda@ct.jp.nec.com>
Signed-off-by: Jun'ichi Nomura <j-nomura@ce.jp.nec.com>
Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
  • Loading branch information
Kiyoshi Ueda authored and Jens Axboe committed Jan 28, 2008
1 parent 5450d3e commit b828623
Showing 1 changed file with 14 additions and 17 deletions.
31 changes: 14 additions & 17 deletions block/ll_rw_blk.c
Original file line number Diff line number Diff line change
Expand Up @@ -3638,6 +3638,12 @@ static void end_that_request_last(struct request *req, int error)
{
struct gendisk *disk = req->rq_disk;

if (blk_rq_tagged(req))
blk_queue_end_tag(req->q, req);

if (blk_queued_rq(req))
blkdev_dequeue_request(req);

if (unlikely(laptop_mode) && blk_fs_request(req))
laptop_io_completion();

Expand All @@ -3655,10 +3661,15 @@ static void end_that_request_last(struct request *req, int error)
disk_round_stats(disk);
disk->in_flight--;
}

if (req->end_io)
req->end_io(req, error);
else
else {
if (blk_bidi_rq(req))
__blk_put_request(req->next_rq->q, req->next_rq);

__blk_put_request(req->q, req);
}
}

static inline void __end_request(struct request *rq, int uptodate,
Expand Down Expand Up @@ -3759,20 +3770,6 @@ void end_request(struct request *req, int uptodate)
}
EXPORT_SYMBOL(end_request);

static void complete_request(struct request *rq, int error)
{
if (blk_rq_tagged(rq))
blk_queue_end_tag(rq->q, rq);

if (blk_queued_rq(rq))
blkdev_dequeue_request(rq);

if (blk_bidi_rq(rq) && !rq->end_io)
__blk_put_request(rq->next_rq->q, rq->next_rq);

end_that_request_last(rq, error);
}

/**
* blk_end_io - Generic end_io function to complete a request.
* @rq: the request being processed
Expand Down Expand Up @@ -3815,7 +3812,7 @@ static int blk_end_io(struct request *rq, int error, int nr_bytes,
add_disk_randomness(rq->rq_disk);

spin_lock_irqsave(q->queue_lock, flags);
complete_request(rq, error);
end_that_request_last(rq, error);
spin_unlock_irqrestore(q->queue_lock, flags);

return 0;
Expand Down Expand Up @@ -3863,7 +3860,7 @@ int __blk_end_request(struct request *rq, int error, int nr_bytes)

add_disk_randomness(rq->rq_disk);

complete_request(rq, error);
end_that_request_last(rq, error);

return 0;
}
Expand Down

0 comments on commit b828623

Please sign in to comment.