ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bdev/malloc: Add copy IO type support

Browse Source 
Signed-off-by: Evgeniy Kochetov <evgeniik@nvidia.com>
Change-Id: I05bd40eb191d2f70347dee5f1cf4cb87e15809fd
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/14346
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-by: Aleksey Marchuk <alexeymar@nvidia.com>
Reviewed-by: Shuhei Matsumoto <smatsumoto@nvidia.com>
Community-CI: Mellanox Build Bot
This commit is contained in:
Evgeniy Kochetov 2022-08-22 15:39:27 +03:00 committed by Tomasz Zawadzki
parent 6c8702ace9
commit 1f47bbba51
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
module/bdev/malloc/bdev_malloc.c
View File

@ -316,6 +316,27 @@ bdev_malloc_unmap(struct malloc_disk *mdisk,
byte_count, 0, malloc_done, task); byte_count, 0, malloc_done, task);
} }
static void
bdev_malloc_copy(struct malloc_disk *mdisk, struct spdk_io_channel *ch,
struct malloc_task *task,
uint64_t dst_offset, uint64_t src_offset, size_t len)
{
int64_t res = 0;
void *dst = mdisk->malloc_buf + dst_offset;
void *src = mdisk->malloc_buf + src_offset;
SPDK_DEBUGLOG(bdev_malloc, "Copy %zu bytes from offset %#" PRIx64 " to offset %#" PRIx64 "\n",
len, src_offset, dst_offset);
task->status = SPDK_BDEV_IO_STATUS_SUCCESS;
task->num_outstanding = 1;
res = spdk_accel_submit_copy(ch, dst, src, len, 0, malloc_done, task);
if (res != 0) {
malloc_done(task, res);
}
}
static int static int
_bdev_malloc_submit_request(struct malloc_channel *mch, struct spdk_bdev_io *bdev_io) _bdev_malloc_submit_request(struct malloc_channel *mch, struct spdk_bdev_io *bdev_io)
{ {
@ -413,6 +434,15 @@ _bdev_malloc_submit_request(struct malloc_channel *mch, struct spdk_bdev_io *bde
malloc_complete_task((struct malloc_task *)bdev_io->driver_ctx, mch, malloc_complete_task((struct malloc_task *)bdev_io->driver_ctx, mch,
SPDK_BDEV_IO_STATUS_FAILED); SPDK_BDEV_IO_STATUS_FAILED);
return 0; return 0;
case SPDK_BDEV_IO_TYPE_COPY:
bdev_malloc_copy((struct malloc_disk *)bdev_io->bdev->ctxt,
mch->accel_channel,
(struct malloc_task *)bdev_io->driver_ctx,
bdev_io->u.bdev.offset_blocks * block_size,
bdev_io->u.bdev.copy.src_offset_blocks * block_size,
bdev_io->u.bdev.num_blocks * block_size);
return 0;
default: default:
return -1; return -1;
} }
@ -442,6 +472,7 @@ bdev_malloc_io_type_supported(void *ctx, enum spdk_bdev_io_type io_type)
case SPDK_BDEV_IO_TYPE_WRITE_ZEROES: case SPDK_BDEV_IO_TYPE_WRITE_ZEROES:
case SPDK_BDEV_IO_TYPE_ZCOPY: case SPDK_BDEV_IO_TYPE_ZCOPY:
case SPDK_BDEV_IO_TYPE_ABORT: case SPDK_BDEV_IO_TYPE_ABORT:
case SPDK_BDEV_IO_TYPE_COPY:
return true; return true;
default: default:
@ -660,6 +691,7 @@ create_malloc_disk(struct spdk_bdev **bdev, const struct malloc_bdev_opts *opts)
spdk_uuid_generate(&mdisk->disk.uuid); spdk_uuid_generate(&mdisk->disk.uuid);
} }
mdisk->disk.max_copy = 0;
mdisk->disk.ctxt = mdisk; mdisk->disk.ctxt = mdisk;
mdisk->disk.fn_table = &malloc_fn_table; mdisk->disk.fn_table = &malloc_fn_table;
mdisk->disk.module = &malloc_if; mdisk->disk.module = &malloc_if;