diff options
author | Tejun Heo <htejun@gmail.com> | 2006-01-06 03:49:03 -0500 |
---|---|---|
committer | Jens Axboe <axboe@suse.de> | 2006-01-06 03:49:03 -0500 |
commit | 8ffdc6550c47f75ca4e6c9f30a2a89063e035cf2 (patch) | |
tree | a478b9acef5c66242a964154f7ad3a0ea750ef0f /block/ll_rw_blk.c | |
parent | 64100099ed22f71cce656c5c2caecf5c9cf255dc (diff) |
[BLOCK] add @uptodate to end_that_request_last() and @error to rq_end_io_fn()
add @uptodate argument to end_that_request_last() and @error
to rq_end_io_fn(). there's no generic way to pass error code
to request completion function, making generic error handling
of non-fs request difficult (rq->errors is driver-specific and
each driver uses it differently). this patch adds @uptodate
to end_that_request_last() and @error to rq_end_io_fn().
for fs requests, this doesn't really matter, so just using the
same uptodate argument used in the last call to
end_that_request_first() should suffice. imho, this can also
help the generic command-carrying request jens is working on.
Signed-off-by: tejun heo <htejun@gmail.com>
Signed-Off-By: Jens Axboe <axboe@suse.de>
Diffstat (limited to 'block/ll_rw_blk.c')
-rw-r--r-- | block/ll_rw_blk.c | 22 |
1 files changed, 15 insertions, 7 deletions
diff --git a/block/ll_rw_blk.c b/block/ll_rw_blk.c index e02c88ca8fb5..8b1ae69bc5ac 100644 --- a/block/ll_rw_blk.c +++ b/block/ll_rw_blk.c | |||
@@ -344,7 +344,7 @@ EXPORT_SYMBOL(blk_queue_issue_flush_fn); | |||
344 | /* | 344 | /* |
345 | * Cache flushing for ordered writes handling | 345 | * Cache flushing for ordered writes handling |
346 | */ | 346 | */ |
347 | static void blk_pre_flush_end_io(struct request *flush_rq) | 347 | static void blk_pre_flush_end_io(struct request *flush_rq, int error) |
348 | { | 348 | { |
349 | struct request *rq = flush_rq->end_io_data; | 349 | struct request *rq = flush_rq->end_io_data; |
350 | request_queue_t *q = rq->q; | 350 | request_queue_t *q = rq->q; |
@@ -362,7 +362,7 @@ static void blk_pre_flush_end_io(struct request *flush_rq) | |||
362 | } | 362 | } |
363 | } | 363 | } |
364 | 364 | ||
365 | static void blk_post_flush_end_io(struct request *flush_rq) | 365 | static void blk_post_flush_end_io(struct request *flush_rq, int error) |
366 | { | 366 | { |
367 | struct request *rq = flush_rq->end_io_data; | 367 | struct request *rq = flush_rq->end_io_data; |
368 | request_queue_t *q = rq->q; | 368 | request_queue_t *q = rq->q; |
@@ -2317,7 +2317,7 @@ EXPORT_SYMBOL(blk_rq_map_kern); | |||
2317 | */ | 2317 | */ |
2318 | void blk_execute_rq_nowait(request_queue_t *q, struct gendisk *bd_disk, | 2318 | void blk_execute_rq_nowait(request_queue_t *q, struct gendisk *bd_disk, |
2319 | struct request *rq, int at_head, | 2319 | struct request *rq, int at_head, |
2320 | void (*done)(struct request *)) | 2320 | rq_end_io_fn *done) |
2321 | { | 2321 | { |
2322 | int where = at_head ? ELEVATOR_INSERT_FRONT : ELEVATOR_INSERT_BACK; | 2322 | int where = at_head ? ELEVATOR_INSERT_FRONT : ELEVATOR_INSERT_BACK; |
2323 | 2323 | ||
@@ -2521,7 +2521,7 @@ EXPORT_SYMBOL(blk_put_request); | |||
2521 | * blk_end_sync_rq - executes a completion event on a request | 2521 | * blk_end_sync_rq - executes a completion event on a request |
2522 | * @rq: request to complete | 2522 | * @rq: request to complete |
2523 | */ | 2523 | */ |
2524 | void blk_end_sync_rq(struct request *rq) | 2524 | void blk_end_sync_rq(struct request *rq, int error) |
2525 | { | 2525 | { |
2526 | struct completion *waiting = rq->waiting; | 2526 | struct completion *waiting = rq->waiting; |
2527 | 2527 | ||
@@ -3183,9 +3183,17 @@ EXPORT_SYMBOL(end_that_request_chunk); | |||
3183 | /* | 3183 | /* |
3184 | * queue lock must be held | 3184 | * queue lock must be held |
3185 | */ | 3185 | */ |
3186 | void end_that_request_last(struct request *req) | 3186 | void end_that_request_last(struct request *req, int uptodate) |
3187 | { | 3187 | { |
3188 | struct gendisk *disk = req->rq_disk; | 3188 | struct gendisk *disk = req->rq_disk; |
3189 | int error; | ||
3190 | |||
3191 | /* | ||
3192 | * extend uptodate bool to allow < 0 value to be direct io error | ||
3193 | */ | ||
3194 | error = 0; | ||
3195 | if (end_io_error(uptodate)) | ||
3196 | error = !uptodate ? -EIO : uptodate; | ||
3189 | 3197 | ||
3190 | if (unlikely(laptop_mode) && blk_fs_request(req)) | 3198 | if (unlikely(laptop_mode) && blk_fs_request(req)) |
3191 | laptop_io_completion(); | 3199 | laptop_io_completion(); |
@@ -3200,7 +3208,7 @@ void end_that_request_last(struct request *req) | |||
3200 | disk->in_flight--; | 3208 | disk->in_flight--; |
3201 | } | 3209 | } |
3202 | if (req->end_io) | 3210 | if (req->end_io) |
3203 | req->end_io(req); | 3211 | req->end_io(req, error); |
3204 | else | 3212 | else |
3205 | __blk_put_request(req->q, req); | 3213 | __blk_put_request(req->q, req); |
3206 | } | 3214 | } |
@@ -3212,7 +3220,7 @@ void end_request(struct request *req, int uptodate) | |||
3212 | if (!end_that_request_first(req, uptodate, req->hard_cur_sectors)) { | 3220 | if (!end_that_request_first(req, uptodate, req->hard_cur_sectors)) { |
3213 | add_disk_randomness(req->rq_disk); | 3221 | add_disk_randomness(req->rq_disk); |
3214 | blkdev_dequeue_request(req); | 3222 | blkdev_dequeue_request(req); |
3215 | end_that_request_last(req); | 3223 | end_that_request_last(req, uptodate); |
3216 | } | 3224 | } |
3217 | } | 3225 | } |
3218 | 3226 | ||