thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Pass bitmap in fio_bs

Browse Source
This commit is contained in:
Vitaliy Filippov
2025-12-02 01:52:12 +03:00
parent 852734270e
commit b9713deecd
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/blockstore/fio_engine.cpp
+6
View File
@@ -42,6 +42,7 @@ struct bs_data
bool imm = true; bool imm = true;
bool last_sync = false; bool last_sync = false;
bool trace = false; bool trace = false;
uint8_t *bitmap = NULL;
}; };
struct bs_options struct bs_options
@@ -137,6 +138,7 @@ static void bs_cleanup(struct thread_data *td)
delete bsd->bs; delete bsd->bs;
delete bsd->epmgr; delete bsd->epmgr;
delete bsd->ringloop; delete bsd->ringloop;
free(bsd->bitmap);
delete bsd; delete bsd;
} }
} }
@@ -160,6 +162,8 @@ static int bs_init(struct thread_data *td)
config[p.first] = p.second.dump(); config[p.first] = p.second.dump();
} }
} }
bsd->bitmap = (uint8_t*)malloc_or_die(MAX_DATA_BLOCK_SIZE/512/8);
memset(bsd->bitmap, 0, MAX_DATA_BLOCK_SIZE/512/8);
bsd->ringloop = new ring_loop_t(RINGLOOP_DEFAULT_SIZE); bsd->ringloop = new ring_loop_t(RINGLOOP_DEFAULT_SIZE);
bsd->epmgr = new epoll_manager_t(bsd->ringloop); bsd->epmgr = new epoll_manager_t(bsd->ringloop);
bsd->bs = blockstore_i::create(config, bsd->ringloop, bsd->epmgr->tfd); bsd->bs = blockstore_i::create(config, bsd->ringloop, bsd->epmgr->tfd);
@@ -208,6 +212,7 @@ static enum fio_q_status bs_queue(struct thread_data *td, struct io_u *io)
op->version = UINT64_MAX; // last unstable op->version = UINT64_MAX; // last unstable
op->offset = io->offset % bsd->bs->get_block_size(); op->offset = io->offset % bsd->bs->get_block_size();
op->len = io->xfer_buflen; op->len = io->xfer_buflen;
op->bitmap = bsd->bitmap;
op->callback = [io, n = bsd->op_n](blockstore_op_t *op) op->callback = [io, n = bsd->op_n](blockstore_op_t *op)
{ {
io->error = op->retval < 0 ? -op->retval : 0; io->error = op->retval < 0 ? -op->retval : 0;
@@ -229,6 +234,7 @@ static enum fio_q_status bs_queue(struct thread_data *td, struct io_u *io)
op->version = 0; // assign automatically op->version = 0; // assign automatically
op->offset = io->offset % bsd->bs->get_block_size(); op->offset = io->offset % bsd->bs->get_block_size();
op->len = io->xfer_buflen; op->len = io->xfer_buflen;
op->bitmap = bsd->bitmap;
if (bsd->ec) if (bsd->ec)
{ {
op->callback = [io, n = bsd->op_n](blockstore_op_t *op) op->callback = [io, n = bsd->op_n](blockstore_op_t *op)