File rtslib-fb-rbd-support.patch of Package python-rtslib.1545

Overview Repositories Revisions Requests Users Attributes Meta

File rtslib-fb-rbd-support.patch of Package python-rtslib.1545

rtslib-fb patches backported to SLE12 rtslib, obtained from:
http://permalink.gmane.org/gmane.comp.file-systems.ceph.devel/26263

Index: rtslib-2.2/rtslib/tcm.py
===================================================================
--- rtslib-2.2.orig/rtslib/tcm.py
+++ rtslib-2.2/rtslib/tcm.py
@@ -262,6 +262,41 @@ class IBlockBackstore(Backstore):
         return IBlockStorageObject(self, name=name, dev=dev,
                                    gen_wwn=gen_wwn)
 
+class RBDBackstore(Backstore):
+    '''
+    This is an interface to Ceph RBD backstore plugin objects in configFS.
+    An RBDBackstore object is identified by its backstore index.
+    '''
+
+    # RBDBackstore private stuff
+
+    def __init__(self, index, mode='any'):
+        '''
+        @param index: The backstore index.
+        @type index: int
+        @param mode: An optional string containing the object creation mode:
+            - I{'any'} the configFS object will be either lookupd or created.
+            - I{'lookup'} the object MUST already exist configFS.
+            - I{'create'} the object must NOT already exist in configFS.
+        @type mode:string
+        @return: An RBDBackstore object.
+        '''
+
+        super(RBDBackstore, self).__init__("rbd", RBDStorageObject,
+                                           index, mode)
+
+    # RBDBackstore public stuff
+
+    def storage_object(self, name, dev=None, wwn=None, readonly=False,
+                       write_back=False):
+        '''
+        Same as RBDStorageObject() without specifying the backstore
+        '''
+        self._check_self()
+        return RBDStorageObject(self, name=name, dev=dev, wwn=wwn,
+                                readonly=readonly, write_back=write_back)
+
+
 class StorageObject(CFSNode):
     '''
     This is an interface to storage objects in configFS. A StorageObject is
@@ -954,6 +989,110 @@ class IBlockStorageObject(StorageObject)
     minor = property(_get_minor,
             doc="Get the block device minor number")
 
+class RBDStorageObject(StorageObject):
+    '''
+    An interface to configFS storage objects for RBD backstore.
+    '''
+
+    # RBDStorageObject private stuff
+
+    def __init__(self, backstore, name, dev=None, wwn=None, readonly=False,
+                 write_back=False):
+        '''
+        A RBDIOStorageObject can be instantiated in two ways:
+            - B{Creation mode}: If I{dev} is specified, the underlying configFS
+              object will be created with that parameter.
+              No RBDIOStorageObject with the same I{name} can pre-exist in
+              the parent Backstore in that mode.
+            - B{Lookup mode}: If I{dev} is not set, then the
+              RBDIOStorageObject will be bound to the existing configFS
+              object in the parent Backstore having the specified
+              I{name}. The underlying configFS object must already exist in
+              that mode, or instantiation will fail.
+
+        @param name: The name of the RBDIOStorageObject.
+        @type name: string
+        @param dev: The path to the backend rbd device to be used.
+            - Example: I{dev="/dev/sda"}.
+            - The only device type that is accepted I{TYPE_DISK}.
+              For other device types, use pscsi.
+        @type dev: string
+        @param wwn: T10 WWN Unit Serial, will generate if None
+        @type wwn: string
+        @return: A RBDIOStorageObject object.
+        '''
+
+        if dev is not None:
+            super(RBDStorageObject, self).__init__(backstore,
+                                                   RBDBackstore,
+                                                   name,
+                                                   'create')
+            try:
+                self._configure(dev, wwn, readonly)
+            except:
+                self.delete()
+                raise
+        else:
+            super(RBDStorageObject, self).__init__(backstore,
+                                                   RBDBackstore,
+                                                   name,
+                                                   'lookup')
+
+    def _configure(self, dev, wwn, readonly):
+        self._check_self()
+        if get_block_type(dev) != 0:
+            raise RTSLibError("Device %s is not a TYPE_DISK rbd device" % dev)
+        if is_dev_in_use(dev):
+            raise RTSLibError("Cannot configure StorageObject because "
+                              + "device %s is already in use." % dev)
+        self._set_udev_path(dev)
+        self._control("udev_path=%s" % dev)
+        self._control("readonly=%d" % readonly)
+        self._enable()
+        if wwn:
+            self.wwn = wwn
+        else:
+            self.wwn = generate_wwn('unit_serial')
+
+    def _get_major(self):
+        self._check_self()
+        return int(self._parse_info('Major'))
+
+    def _get_minor(self):
+        self._check_self()
+        return int(self._parse_info('Minor'))
+
+    def _get_wb_enabled(self):
+        self._check_self()
+        return bool(int(self.get_attribute("emulate_write_cache")))
+
+    def _get_readonly(self):
+        self._check_self()
+        # 'readonly' not present before kernel 3.6
+        try:
+            return bool(int(self._parse_info('readonly')))
+        except AttributeError:
+            return False
+
+    # RBDStorageObject public stuff
+
+    major = property(_get_major,
+            doc="Get the block device major number")
+    minor = property(_get_minor,
+            doc="Get the block device minor number")
+    write_back = property(_get_wb_enabled,
+            doc="True if write-back, False if write-through (write cache disabled)")
+    readonly = property(_get_readonly,
+            doc="True if the device is read-only, False if read/write")
+
+    def dump(self):
+        d = super(RBDStorageObject, self).dump()
+        d['write_back'] = self.write_back
+        d['readonly'] = self.readonly
+        d['wwn'] = self.wwn
+        d['dev'] = self.udev_path
+        return d
+
 def _test():
     import doctest
     doctest.testmod()
Index: rtslib-2.2/rtslib/__init__.py
===================================================================
--- rtslib-2.2.orig/rtslib/__init__.py
+++ rtslib-2.2/rtslib/__init__.py
@@ -27,6 +27,7 @@ from tcm import FileIOBackstore, IBlockB
 from tcm import FileIOStorageObject, IBlockStorageObject
 from tcm import PSCSIBackstore, RDMCPBackstore
 from tcm import PSCSIStorageObject, RDMCPStorageObject
+from tcm import RBDBackstore, RBDStorageObject
 
 from config_filters import *
 from config import Config, ConfigError
Index: rtslib-2.2/rtslib/root.py
===================================================================
--- rtslib-2.2.orig/rtslib/root.py
+++ rtslib-2.2/rtslib/root.py
@@ -25,6 +25,7 @@ from node import CFSNode
 from target import Target, FabricModule
 from tcm import FileIOBackstore, IBlockBackstore
 from tcm import PSCSIBackstore, RDMCPBackstore
+from tcm import RBDBackstore
 from utils import RTSLibError, RTSLibBrokenLink, modprobe, mount_configfs
 
 class RTSRoot(CFSNode):
@@ -91,6 +92,8 @@ class RTSRoot(CFSNode):
                         yield IBlockBackstore(int(regex.group(3)), 'lookup')
                     elif regex.group(1) == "rd_mcp":
                         yield RDMCPBackstore(int(regex.group(3)), 'lookup')
+                    elif regex.group(1) == "rbd":
+                        yield RBDBackstore(int(regex.group(3)), 'lookup')
 
     def _list_storage_objects(self):
         self._check_self()
Index: rtslib-2.2/rtslib/config_live.py
===================================================================
--- rtslib-2.2.orig/rtslib/config_live.py
+++ rtslib-2.2/rtslib/config_live.py
@@ -32,7 +32,8 @@ from rtslib import (RTSRoot, Target, Fab
                     FileIOStorageObject, IBlockBackstore,
                     IBlockStorageObject, PSCSIBackstore,
                     PSCSIStorageObject, RDMCPBackstore,
-                    RDMCPStorageObject, RTSLibError)
+                    RDMCPStorageObject, RBDBackstore,
+                    RBDStorageObject, RTSLibError)
 
 # TODO There seems to be a bug in LIO, affecting both this API and rtslib:
 # when a tpg does not contain any objects, it cannot be removed.
@@ -96,7 +97,7 @@ def dump_live_storage():
         dump.append("storage %s disk %s {"
                     % (so.backstore.plugin, so.name))
         attrs = []
-        if so.backstore.plugin in ['fileio', 'pscsi', 'iblock']:
+        if so.backstore.plugin in ['fileio', 'pscsi', 'iblock', 'rbd']:
             attrs.append("%spath %s" % (_indent, so.udev_path))
         if so.backstore.plugin in ['fileio', 'rd_mcp']:
             attrs.append("%ssize %s" % (_indent, _b2h(so.size)))
@@ -509,6 +510,12 @@ def apply_create_obj(obj):
             nullio = obj_attr(obj, "nullio")
             lio_so = lio_bs.storage_object(name, size, True, nullio)
             apply_group_attrs(obj, lio_so)
+        elif plugin == 'rbd':
+            # TODO Add policy for rbd
+            lio_bs = RBDBackstore(idx)
+            dev = obj_attr(obj, "path")
+            lio_so = lio_bs.storage_object(name, dev)
+            apply_group_attrs(obj, lio_so)
         else:
             raise ConfigError("Unknown backend '%s' for backstore '%s'"
                               % (plugin, obj))
Index: rtslib-2.2/policy/backstore_rbd.lio
===================================================================
--- /dev/null
+++ rtslib-2.2/policy/backstore_rbd.lio
@@ -0,0 +1,28 @@
+storage rbd disk %str {
+    path %str
+    attribute {
+        block_size %int(512)
+        emulate_3pc %bool(yes)
+        emulate_caw %bool(yes)
+        emulate_dpo %bool(no)
+        emulate_fua_read %bool(no)
+        emulate_fua_write %bool(yes)
+        emulate_model_alias %bool(no)
+        emulate_rest_reord %bool(no)
+        emulate_tas %bool(yes)
+        emulate_tpu %bool(no)
+        emulate_tpws %bool(no)
+        emulate_ua_intlck_ctrl %bool(no)
+        emulate_write_cache %bool(no)
+        enforce_pr_isids %bool(yes)
+        fabric_max_sectors %int(8192)
+        is_nonrot %bool(yes)
+        max_unmap_block_desc_count %int(0)
+        max_unmap_lba_count %int(0)
+        max_write_same_len %int(65535)
+        optimal_sectors %int(8192)
+        queue_depth %int(128)
+        unmap_granularity %int(0)
+        unmap_granularity_alignment %int(0)
+    }
+}

Places

File rtslib-fb-rbd-support.patch of Package python-rtslib.1545

Places