Commit 1d1068ce authored by Christoph Hellwig's avatar Christoph Hellwig Committed by Jens Axboe

dm: retun the clone bio from alloc_tio

Return the clone bio embedded into the tio as that is what the callers
actually want.  Similar for the free side.
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarMike Snitzer <snitzer@redhat.com>
Link: https://lore.kernel.org/r/20220202160109.108149-8-hch@lst.deSigned-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent 1561b396
...@@ -544,7 +544,7 @@ static void free_io(struct mapped_device *md, struct dm_io *io) ...@@ -544,7 +544,7 @@ static void free_io(struct mapped_device *md, struct dm_io *io)
bio_put(&io->tio.clone); bio_put(&io->tio.clone);
} }
static struct dm_target_io *alloc_tio(struct clone_info *ci, struct dm_target *ti, static struct bio *alloc_tio(struct clone_info *ci, struct dm_target *ti,
unsigned target_bio_nr, unsigned *len, gfp_t gfp_mask) unsigned target_bio_nr, unsigned *len, gfp_t gfp_mask)
{ {
struct dm_target_io *tio; struct dm_target_io *tio;
...@@ -569,14 +569,14 @@ static struct dm_target_io *alloc_tio(struct clone_info *ci, struct dm_target *t ...@@ -569,14 +569,14 @@ static struct dm_target_io *alloc_tio(struct clone_info *ci, struct dm_target *t
tio->target_bio_nr = target_bio_nr; tio->target_bio_nr = target_bio_nr;
tio->len_ptr = len; tio->len_ptr = len;
return tio; return &tio->clone;
} }
static void free_tio(struct dm_target_io *tio) static void free_tio(struct bio *clone)
{ {
if (tio->inside_dm_io) if (clone_to_tio(clone)->inside_dm_io)
return; return;
bio_put(&tio->clone); bio_put(clone);
} }
/* /*
...@@ -932,7 +932,7 @@ static void clone_endio(struct bio *bio) ...@@ -932,7 +932,7 @@ static void clone_endio(struct bio *bio)
up(&md->swap_bios_semaphore); up(&md->swap_bios_semaphore);
} }
free_tio(tio); free_tio(bio);
dm_io_dec_pending(io, error); dm_io_dec_pending(io, error);
} }
...@@ -1166,7 +1166,7 @@ static void __map_bio(struct bio *clone) ...@@ -1166,7 +1166,7 @@ static void __map_bio(struct bio *clone)
struct mapped_device *md = io->md; struct mapped_device *md = io->md;
up(&md->swap_bios_semaphore); up(&md->swap_bios_semaphore);
} }
free_tio(tio); free_tio(clone);
dm_io_dec_pending(io, BLK_STS_IOERR); dm_io_dec_pending(io, BLK_STS_IOERR);
break; break;
case DM_MAPIO_REQUEUE: case DM_MAPIO_REQUEUE:
...@@ -1174,7 +1174,7 @@ static void __map_bio(struct bio *clone) ...@@ -1174,7 +1174,7 @@ static void __map_bio(struct bio *clone)
struct mapped_device *md = io->md; struct mapped_device *md = io->md;
up(&md->swap_bios_semaphore); up(&md->swap_bios_semaphore);
} }
free_tio(tio); free_tio(clone);
dm_io_dec_pending(io, BLK_STS_DM_REQUEUE); dm_io_dec_pending(io, BLK_STS_DM_REQUEUE);
break; break;
default: default:
...@@ -1196,17 +1196,17 @@ static int __clone_and_map_data_bio(struct clone_info *ci, struct dm_target *ti, ...@@ -1196,17 +1196,17 @@ static int __clone_and_map_data_bio(struct clone_info *ci, struct dm_target *ti,
sector_t sector, unsigned *len) sector_t sector, unsigned *len)
{ {
struct bio *bio = ci->bio, *clone; struct bio *bio = ci->bio, *clone;
struct dm_target_io *tio;
int r; int r;
tio = alloc_tio(ci, ti, 0, len, GFP_NOIO); clone = alloc_tio(ci, ti, 0, len, GFP_NOIO);
clone = &tio->clone;
r = bio_crypt_clone(clone, bio, GFP_NOIO); r = bio_crypt_clone(clone, bio, GFP_NOIO);
if (r < 0) if (r < 0)
goto free_tio; goto free_tio;
if (bio_integrity(bio)) { if (bio_integrity(bio)) {
struct dm_target_io *tio = clone_to_tio(clone);
if (unlikely(!dm_target_has_integrity(tio->ti->type) && if (unlikely(!dm_target_has_integrity(tio->ti->type) &&
!dm_target_passes_integrity(tio->ti->type))) { !dm_target_passes_integrity(tio->ti->type))) {
DMWARN("%s: the target %s doesn't support integrity data.", DMWARN("%s: the target %s doesn't support integrity data.",
...@@ -1230,7 +1230,7 @@ static int __clone_and_map_data_bio(struct clone_info *ci, struct dm_target *ti, ...@@ -1230,7 +1230,7 @@ static int __clone_and_map_data_bio(struct clone_info *ci, struct dm_target *ti,
__map_bio(clone); __map_bio(clone);
return 0; return 0;
free_tio: free_tio:
free_tio(tio); free_tio(clone);
return r; return r;
} }
...@@ -1238,31 +1238,30 @@ static void alloc_multiple_bios(struct bio_list *blist, struct clone_info *ci, ...@@ -1238,31 +1238,30 @@ static void alloc_multiple_bios(struct bio_list *blist, struct clone_info *ci,
struct dm_target *ti, unsigned num_bios, struct dm_target *ti, unsigned num_bios,
unsigned *len) unsigned *len)
{ {
struct dm_target_io *tio; struct bio *bio;
int try; int try;
if (!num_bios) if (!num_bios)
return; return;
if (num_bios == 1) { if (num_bios == 1) {
tio = alloc_tio(ci, ti, 0, len, GFP_NOIO); bio = alloc_tio(ci, ti, 0, len, GFP_NOIO);
bio_list_add(blist, &tio->clone); bio_list_add(blist, bio);
return; return;
} }
for (try = 0; try < 2; try++) { for (try = 0; try < 2; try++) {
int bio_nr; int bio_nr;
struct bio *bio;
if (try) if (try)
mutex_lock(&ci->io->md->table_devices_lock); mutex_lock(&ci->io->md->table_devices_lock);
for (bio_nr = 0; bio_nr < num_bios; bio_nr++) { for (bio_nr = 0; bio_nr < num_bios; bio_nr++) {
tio = alloc_tio(ci, ti, bio_nr, len, bio = alloc_tio(ci, ti, bio_nr, len,
try ? GFP_NOIO : GFP_NOWAIT); try ? GFP_NOIO : GFP_NOWAIT);
if (!tio) if (!bio)
break; break;
bio_list_add(blist, &tio->clone); bio_list_add(blist, bio);
} }
if (try) if (try)
mutex_unlock(&ci->io->md->table_devices_lock); mutex_unlock(&ci->io->md->table_devices_lock);
...@@ -1270,7 +1269,7 @@ static void alloc_multiple_bios(struct bio_list *blist, struct clone_info *ci, ...@@ -1270,7 +1269,7 @@ static void alloc_multiple_bios(struct bio_list *blist, struct clone_info *ci,
return; return;
while ((bio = bio_list_pop(blist))) while ((bio = bio_list_pop(blist)))
free_tio(clone_to_tio(bio)); free_tio(bio);
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment