diff options
Diffstat (limited to 'block/elevator.c')
| -rw-r--r-- | block/elevator.c | 55 |
1 files changed, 4 insertions, 51 deletions
diff --git a/block/elevator.c b/block/elevator.c index 91e18f8af9be..f016855a46b0 100644 --- a/block/elevator.c +++ b/block/elevator.c | |||
| @@ -70,39 +70,9 @@ static int elv_iosched_allow_merge(struct request *rq, struct bio *bio) | |||
| 70 | /* | 70 | /* |
| 71 | * can we safely merge with this request? | 71 | * can we safely merge with this request? |
| 72 | */ | 72 | */ |
| 73 | int elv_rq_merge_ok(struct request *rq, struct bio *bio) | 73 | bool elv_rq_merge_ok(struct request *rq, struct bio *bio) |
| 74 | { | 74 | { |
| 75 | if (!rq_mergeable(rq)) | 75 | if (!blk_rq_merge_ok(rq, bio)) |
| 76 | return 0; | ||
| 77 | |||
| 78 | /* | ||
| 79 | * Don't merge file system requests and discard requests | ||
| 80 | */ | ||
| 81 | if ((bio->bi_rw & REQ_DISCARD) != (rq->bio->bi_rw & REQ_DISCARD)) | ||
| 82 | return 0; | ||
| 83 | |||
| 84 | /* | ||
| 85 | * Don't merge discard requests and secure discard requests | ||
| 86 | */ | ||
| 87 | if ((bio->bi_rw & REQ_SECURE) != (rq->bio->bi_rw & REQ_SECURE)) | ||
| 88 | return 0; | ||
| 89 | |||
| 90 | /* | ||
| 91 | * different data direction or already started, don't merge | ||
| 92 | */ | ||
| 93 | if (bio_data_dir(bio) != rq_data_dir(rq)) | ||
| 94 | return 0; | ||
| 95 | |||
| 96 | /* | ||
| 97 | * must be same device and not a special request | ||
| 98 | */ | ||
| 99 | if (rq->rq_disk != bio->bi_bdev->bd_disk || rq->special) | ||
| 100 | return 0; | ||
| 101 | |||
| 102 | /* | ||
| 103 | * only merge integrity protected bio into ditto rq | ||
| 104 | */ | ||
| 105 | if (bio_integrity(bio) != blk_integrity_rq(rq)) | ||
| 106 | return 0; | 76 | return 0; |
| 107 | 77 | ||
| 108 | if (!elv_iosched_allow_merge(rq, bio)) | 78 | if (!elv_iosched_allow_merge(rq, bio)) |
| @@ -112,23 +82,6 @@ int elv_rq_merge_ok(struct request *rq, struct bio *bio) | |||
| 112 | } | 82 | } |
| 113 | EXPORT_SYMBOL(elv_rq_merge_ok); | 83 | EXPORT_SYMBOL(elv_rq_merge_ok); |
| 114 | 84 | ||
| 115 | int elv_try_merge(struct request *__rq, struct bio *bio) | ||
| 116 | { | ||
| 117 | int ret = ELEVATOR_NO_MERGE; | ||
| 118 | |||
| 119 | /* | ||
| 120 | * we can merge and sequence is ok, check if it's possible | ||
| 121 | */ | ||
| 122 | if (elv_rq_merge_ok(__rq, bio)) { | ||
| 123 | if (blk_rq_pos(__rq) + blk_rq_sectors(__rq) == bio->bi_sector) | ||
| 124 | ret = ELEVATOR_BACK_MERGE; | ||
| 125 | else if (blk_rq_pos(__rq) - bio_sectors(bio) == bio->bi_sector) | ||
| 126 | ret = ELEVATOR_FRONT_MERGE; | ||
| 127 | } | ||
| 128 | |||
| 129 | return ret; | ||
| 130 | } | ||
| 131 | |||
| 132 | static struct elevator_type *elevator_find(const char *name) | 85 | static struct elevator_type *elevator_find(const char *name) |
| 133 | { | 86 | { |
| 134 | struct elevator_type *e; | 87 | struct elevator_type *e; |
| @@ -478,8 +431,8 @@ int elv_merge(struct request_queue *q, struct request **req, struct bio *bio) | |||
| 478 | /* | 431 | /* |
| 479 | * First try one-hit cache. | 432 | * First try one-hit cache. |
| 480 | */ | 433 | */ |
| 481 | if (q->last_merge) { | 434 | if (q->last_merge && elv_rq_merge_ok(q->last_merge, bio)) { |
| 482 | ret = elv_try_merge(q->last_merge, bio); | 435 | ret = blk_try_merge(q->last_merge, bio); |
| 483 | if (ret != ELEVATOR_NO_MERGE) { | 436 | if (ret != ELEVATOR_NO_MERGE) { |
| 484 | *req = q->last_merge; | 437 | *req = q->last_merge; |
| 485 | return ret; | 438 | return ret; |
