lkml.org 
[lkml]   [2015]   [Apr]   [21]   [last100]   RSS Feed
Views: [wrap][no wrap]   [headers]  [forward] 
 
Messages in this thread
    Patch in this message
    /
    From
    Subject[PATCH 3.16.y-ckt 007/144] dm io: deal with wandering queue limits when handling REQ_DISCARD and REQ_WRITE_SAME
    Date
    3.16.7-ckt10 -stable review patch.  If anyone has any objections, please let me know.

    ------------------

    From: "Darrick J. Wong" <darrick.wong@oracle.com>

    commit e5db29806b99ce2b2640d2e4d4fcb983cea115c5 upstream.

    Since it's possible for the discard and write same queue limits to
    change while the upper level command is being sliced and diced, fix up
    both of them (a) to reject IO if the special command is unsupported at
    the start of the function and (b) read the limits once and let the
    commands error out on their own if the status happens to change.

    Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com>
    Signed-off-by: Mikulas Patocka <mpatocka@redhat.com>
    Signed-off-by: Mike Snitzer <snitzer@redhat.com>
    Signed-off-by: Luis Henriques <luis.henriques@canonical.com>
    ---
    drivers/md/dm-io.c | 15 +++++++++++----
    1 file changed, 11 insertions(+), 4 deletions(-)

    diff --git a/drivers/md/dm-io.c b/drivers/md/dm-io.c
    index d2a8d64f8526..080e767250d3 100644
    --- a/drivers/md/dm-io.c
    +++ b/drivers/md/dm-io.c
    @@ -291,9 +291,16 @@ static void do_region(int rw, unsigned region, struct dm_io_region *where,
    struct request_queue *q = bdev_get_queue(where->bdev);
    unsigned short logical_block_size = queue_logical_block_size(q);
    sector_t num_sectors;
    + unsigned int uninitialized_var(special_cmd_max_sectors);

    - /* Reject unsupported discard requests */
    - if ((rw & REQ_DISCARD) && !blk_queue_discard(q)) {
    + /*
    + * Reject unsupported discard and write same requests.
    + */
    + if (rw & REQ_DISCARD)
    + special_cmd_max_sectors = q->limits.max_discard_sectors;
    + else if (rw & REQ_WRITE_SAME)
    + special_cmd_max_sectors = q->limits.max_write_same_sectors;
    + if ((rw & (REQ_DISCARD | REQ_WRITE_SAME)) && special_cmd_max_sectors == 0) {
    dec_count(io, region, -EOPNOTSUPP);
    return;
    }
    @@ -319,7 +326,7 @@ static void do_region(int rw, unsigned region, struct dm_io_region *where,
    store_io_and_region_in_bio(bio, io, region);

    if (rw & REQ_DISCARD) {
    - num_sectors = min_t(sector_t, q->limits.max_discard_sectors, remaining);
    + num_sectors = min_t(sector_t, special_cmd_max_sectors, remaining);
    bio->bi_iter.bi_size = num_sectors << SECTOR_SHIFT;
    remaining -= num_sectors;
    } else if (rw & REQ_WRITE_SAME) {
    @@ -328,7 +335,7 @@ static void do_region(int rw, unsigned region, struct dm_io_region *where,
    */
    dp->get_page(dp, &page, &len, &offset);
    bio_add_page(bio, page, logical_block_size, offset);
    - num_sectors = min_t(sector_t, q->limits.max_write_same_sectors, remaining);
    + num_sectors = min_t(sector_t, special_cmd_max_sectors, remaining);
    bio->bi_iter.bi_size = num_sectors << SECTOR_SHIFT;

    offset = 0;

    \
     
     \ /
      Last update: 2015-04-21 18:41    [W:4.178 / U:0.900 seconds]
    ©2003-2020 Jasper Spaans|hosted at Digital Ocean and TransIP|Read the blog|Advertise on this site