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

examples/bdev_fio_plugin: Use spdk_bdev_open_ext() instead of spdk_bdev_open()

Browse Source 
This is a drop-in replacement.

Signed-off-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Change-Id: Ia858b755718da97e48035b7e7ca4544f6f9b9a63
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/4807
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
This commit is contained in:
Shuhei Matsumoto 2020-10-21 19:06:04 +09:00 committed by Tomasz Zawadzki
parent 65ed603449
commit 1e8fac45ec
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
examples/bdev/fio_plugin/fio_plugin.c
View File

@ -475,6 +475,13 @@ spdk_fio_setup(struct thread_data *td)
return 0; return 0;
} }
static void
fio_bdev_event_cb(enum spdk_bdev_event_type type, struct spdk_bdev *bdev,
void *event_ctx)
{
SPDK_WARNLOG("Unsupported bdev event: type %d\n", type);
}
static void static void
spdk_fio_bdev_open(void *arg) spdk_fio_bdev_open(void *arg)
{ {
@ -500,15 +507,8 @@ spdk_fio_bdev_open(void *arg)
return; return;
} }
target->bdev = spdk_bdev_get_by_name(f->file_name); rc = spdk_bdev_open_ext(f->file_name, true, fio_bdev_event_cb, NULL,
if (!target->bdev) { &target->desc);
SPDK_ERRLOG("Unable to find bdev with name %s\n", f->file_name);
free(target);
fio_thread->failed = true;
return;
}
rc = spdk_bdev_open(target->bdev, true, NULL, NULL, &target->desc);
if (rc) { if (rc) {
SPDK_ERRLOG("Unable to open bdev %s\n", f->file_name); SPDK_ERRLOG("Unable to open bdev %s\n", f->file_name);
free(target); free(target);
@ -516,6 +516,8 @@ spdk_fio_bdev_open(void *arg)
return; return;
} }
target->bdev = spdk_bdev_desc_get_bdev(target->desc);
target->ch = spdk_bdev_get_io_channel(target->desc); target->ch = spdk_bdev_get_io_channel(target->desc);
if (!target->ch) { if (!target->ch) {
SPDK_ERRLOG("Unable to get I/O channel for bdev.\n"); SPDK_ERRLOG("Unable to get I/O channel for bdev.\n");