d/numam-spdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

lvol: add vbdev_get_lvs_bdev_by_bdev() function

Browse Source 
Signed-off-by: Maciej Szwed <maciej.szwed@intel.com>
Change-Id: Ie7a6513d45652d4a6420ac52b5ded39581d688c6
Reviewed-on: https://review.gerrithub.io/388944
Tested-by: SPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
This commit is contained in:
Maciej Szwed 2017-11-24 14:23:45 +01:00 committed by Jim Harris
parent f8dcdfa99e
commit 0f1f40deaf
1 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
lib/bdev/lvol/vbdev_lvol.c
View File

@ -62,6 +62,22 @@ vbdev_get_lvs_bdev_by_lvs(struct spdk_lvol_store *lvs_orig)
}
lvs_bdev = vbdev_lvol_store_next(lvs_bdev);
}
return NULL;
}
static struct lvol_store_bdev *
vbdev_get_lvs_bdev_by_bdev(struct spdk_bdev *bdev_orig)
{
struct lvol_store_bdev *lvs_bdev = vbdev_lvol_store_first();
while (lvs_bdev != NULL) {
if (lvs_bdev->bdev == bdev_orig) {
return lvs_bdev;
}
lvs_bdev = vbdev_lvol_store_next(lvs_bdev);
}
return NULL;
}
@ -69,14 +85,11 @@ static void
vbdev_lvs_hotremove_cb(void *ctx)
{
struct spdk_bdev *bdev = ctx;
struct lvol_store_bdev *lvs_bdev, *tmp;
struct lvol_store_bdev *lvs_bdev;
TAILQ_FOREACH_SAFE(lvs_bdev, &g_spdk_lvol_pairs, lvol_stores, tmp) {
if (lvs_bdev) {
if (lvs_bdev->bdev == bdev) {
vbdev_lvs_unload(lvs_bdev->lvs, NULL, NULL);
}
}
lvs_bdev = vbdev_get_lvs_bdev_by_bdev(bdev);
if (lvs_bdev != NULL) {
vbdev_lvs_unload(lvs_bdev->lvs, NULL, NULL);
}
}