Commit 356b68a7 authored by Karol Latecki's avatar Karol Latecki Committed by Jim Harris
Browse files

spdkcli: add Ceph rbd bdev create option 



Add option to create Ceph RBD bdevs in configuration.

Change-Id: I55268151e13d5c9785433a64d00eb2f4e2c8306b
Signed-off-by: default avatarKarol Latecki <karol.latecki@intel.com>
Reviewed-on: https://review.gerrithub.io/415761


Tested-by: default avatarSPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: default avatarTomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: default avatarPawel Kaminski <pawelx.kaminski@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarDaniel Verkamp <daniel.verkamp@intel.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
parent 19dd8ea5

scripts/spdkcli/ui_node.py

+17 −0
Original line number Diff line number Diff line
@@ -56,6 +56,7 @@ class UIBdevs(UINode): 
        UIErrorBdev(self)

        UISplitBdev(self)

        UIPmemBdev(self)

        UIRbdBdev(self)



    def ui_command_delete(self, name):

        """
@@ -374,6 +375,22 @@ class UIPmemBdev(UIBdev): 
        self.refresh()





class UIRbdBdev(UIBdev):

    def __init__(self, parent):

        UIBdev.__init__(self, "Rbd", parent)



    def ui_command_create(self, pool_name, rbd_name, block_size, name=None):

        block_size = self.ui_eval_param(block_size, "number", None)



        ret_name = self.get_root().create_rbd_bdev(pool_name=pool_name,

                                                   rbd_name=rbd_name,

                                                   block_size=block_size,

                                                   name=name)

        self.shell.log.info(ret_name)

        self.get_root().refresh()

        self.refresh()





class UIBdevObj(UINode):

    def __init__(self, bdev, parent):

        self.bdev = bdev

scripts/spdkcli/ui_root.py

+4 −0
Original line number Diff line number Diff line
@@ -107,6 +107,10 @@ class UIRoot(UINode): 
        response = rpc.bdev.construct_pmem_bdev(self.client, **kwargs)

        return response



    def create_rbd_bdev(self, **kwargs):

        response = rpc.bdev.construct_rbd_bdev(self.client, **kwargs)

        return response





class Bdev(object):

    def __init__(self, bdev_info):