Skip to content

Commit

Permalink
block: don't check if adjacent bvecs in one bio can be mergeable
Browse files Browse the repository at this point in the history
Now both passthrough and FS IO have supported multi-page bvec, and
bvec merging has been handled actually when adding page to bio, then
adjacent bvecs won't be mergeable any more if they belong to same bio.

So only try to merge bvecs if they are from different bios.

Cc: Omar Sandoval <osandov@fb.com>
Cc: Christoph Hellwig <hch@lst.de>
Signed-off-by: Ming Lei <ming.lei@redhat.com>
  • Loading branch information
Ming Lei committed Mar 4, 2019
1 parent 0e1c3b1 commit e038b3f
Showing 1 changed file with 51 additions and 30 deletions.
81 changes: 51 additions & 30 deletions block/blk-merge.c
Expand Up @@ -354,11 +354,11 @@ static unsigned int __blk_recalc_rq_segments(struct request_queue *q,
struct bio *bio)
{
struct bio_vec bv, bvprv = { NULL };
int prev = 0;
unsigned int seg_size, nr_phys_segs;
unsigned front_seg_size;
struct bio *fbio, *bbio;
struct bvec_iter iter;
bool new_bio;

if (!bio)
return 0;
Expand All @@ -377,17 +377,17 @@ static unsigned int __blk_recalc_rq_segments(struct request_queue *q,
fbio = bio;
seg_size = 0;
nr_phys_segs = 0;
new_bio = false;
for_each_bio(bio) {
bio_for_each_bvec(bv, bio, iter) {
if (prev) {
if (new_bio) {
if (seg_size + bv.bv_len
> queue_max_segment_size(q))
goto new_segment;
if (!biovec_phys_mergeable(q, &bvprv, &bv))
goto new_segment;

seg_size += bv.bv_len;
bvprv = bv;

if (nr_phys_segs == 1 && seg_size >
front_seg_size)
Expand All @@ -396,12 +396,13 @@ static unsigned int __blk_recalc_rq_segments(struct request_queue *q,
continue;
}
new_segment:
bvprv = bv;
prev = 1;
bvec_split_segs(q, &bv, &nr_phys_segs, &seg_size,
&front_seg_size, NULL, UINT_MAX);
new_bio = false;
}
bbio = bio;
bvprv = bv;
new_bio = true;
}

fbio->bi_seg_front_size = front_seg_size;
Expand Down Expand Up @@ -493,31 +494,38 @@ static unsigned blk_bvec_map_sg(struct request_queue *q,
return nsegs;
}

static inline void
__blk_segment_map_sg(struct request_queue *q, struct bio_vec *bvec,
struct scatterlist *sglist, struct bio_vec *bvprv,
struct scatterlist **sg, int *nsegs)
/* only try to merge bvecs into one sg if they are from two bios */
static inline bool
__blk_segment_map_sg_merge(struct request_queue *q, struct bio_vec *bvec,
struct bio_vec *bvprv, struct scatterlist **sg)
{

int nbytes = bvec->bv_len;

if (*sg) {
if ((*sg)->length + nbytes > queue_max_segment_size(q))
goto new_segment;
if (!biovec_phys_mergeable(q, bvprv, bvec))
goto new_segment;
if (!*sg)
return false;

(*sg)->length += nbytes;
} else {
new_segment:
if (bvec->bv_offset + bvec->bv_len <= PAGE_SIZE) {
*sg = blk_next_sg(sg, sglist);
sg_set_page(*sg, bvec->bv_page, nbytes, bvec->bv_offset);
(*nsegs) += 1;
} else
(*nsegs) += blk_bvec_map_sg(q, bvec, sglist, sg);
}
*bvprv = *bvec;
if ((*sg)->length + nbytes > queue_max_segment_size(q))
return false;

if (!biovec_phys_mergeable(q, bvprv, bvec))
return false;

(*sg)->length += nbytes;

return true;
}

static inline void
__blk_segment_map_sg(struct request_queue *q, struct bio_vec *bvec,
struct scatterlist *sglist, struct scatterlist **sg,
int *nsegs)
{
if (bvec->bv_offset + bvec->bv_len <= PAGE_SIZE) {
*sg = blk_next_sg(sg, sglist);
sg_set_page(*sg, bvec->bv_page, bvec->bv_len, bvec->bv_offset);
(*nsegs) += 1;
} else
(*nsegs) += blk_bvec_map_sg(q, bvec, sglist, sg);
}

static inline int __blk_bvec_map_sg(struct request_queue *q, struct bio_vec bv,
Expand All @@ -535,11 +543,24 @@ static int __blk_bios_map_sg(struct request_queue *q, struct bio *bio,
struct bio_vec bvec, bvprv = { NULL };
struct bvec_iter iter;
int nsegs = 0;
bool new_bio = false;

for_each_bio(bio)
bio_for_each_bvec(bvec, bio, iter)
__blk_segment_map_sg(q, &bvec, sglist, &bvprv, sg,
&nsegs);
for_each_bio(bio) {
bio_for_each_bvec(bvec, bio, iter) {
/*
* Only try to merge bvecs from two bios given we
* have done bio internal merge when adding pages
* to bio
*/
if (!new_bio || !__blk_segment_map_sg_merge(q,
&bvec, &bvprv, sg))
__blk_segment_map_sg(q, &bvec, sglist, sg,
&nsegs);
new_bio = false;
}
bvprv = bvec;
new_bio = true;
}

return nsegs;
}
Expand Down

0 comments on commit e038b3f

Please sign in to comment.