X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=io_u.c;h=eed7d9d91c8d12d829321ba8ec01b69e2576a381;hp=29a360a95424a72cbf1c7f0c0b753efdbcf06f18;hb=6cc1a3d1ae6e574ac1773ec5dfa46caea4c3627d;hpb=99952ca7747d2ec56b4ff4771ddfaa03fb0e8407 diff --git a/io_u.c b/io_u.c index 29a360a9..eed7d9d9 100644 --- a/io_u.c +++ b/io_u.c @@ -31,21 +31,24 @@ static bool random_map_free(struct fio_file *f, const uint64_t block) /* * Mark a given offset as used in the map. */ -static void mark_random_map(struct thread_data *td, struct io_u *io_u) +static uint64_t mark_random_map(struct thread_data *td, struct io_u *io_u, + uint64_t offset, uint64_t buflen) { unsigned long long min_bs = td->o.min_bs[io_u->ddir]; struct fio_file *f = io_u->file; unsigned long long nr_blocks; uint64_t block; - block = (io_u->offset - f->file_offset) / (uint64_t) min_bs; - nr_blocks = (io_u->buflen + min_bs - 1) / min_bs; + block = (offset - f->file_offset) / (uint64_t) min_bs; + nr_blocks = (buflen + min_bs - 1) / min_bs; if (!(io_u->flags & IO_U_F_BUSY_OK)) nr_blocks = axmap_set_nr(f->io_axmap, block, nr_blocks); - if ((nr_blocks * min_bs) < io_u->buflen) - io_u->buflen = nr_blocks * min_bs; + if ((nr_blocks * min_bs) < buflen) + buflen = nr_blocks * min_bs; + + return buflen; } static uint64_t last_block(struct thread_data *td, struct fio_file *f, @@ -908,7 +911,8 @@ static int fill_io_u(struct thread_data *td, struct io_u *io_u) * mark entry before potentially trimming io_u */ if (td_random(td) && file_randommap(td, io_u->file)) - mark_random_map(td, io_u); + io_u->buflen = mark_random_map(td, io_u, io_u->offset, + io_u->buflen); out: dprint_io_u(io_u, "fill");