/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

Revision 94dcbdb0

           clist.append(crdev)
       try:
         device = bdev.Create(disk.dev_type, disk.physical_id, clist, disk.size)
         device = bdev.Create(disk, clist)
       except errors.BlockDeviceError, err:
         _Fail("Can't create block device: %s", err)
-...
           children.append(cdev)
       if as_primary or disk.AssembleOnSecondary():
         r_dev = bdev.Assemble(disk.dev_type, disk.physical_id, children, disk.size)
         r_dev = bdev.Assemble(disk, children)
         result = r_dev
         if as_primary or disk.OpenOnSecondary():
           r_dev.Open()
-...
         for chdisk in disk.children:
           children.append(_RecursiveFindBD(chdisk))
       return bdev.FindDevice(disk.dev_type, disk.physical_id, children, disk.size)
       return bdev.FindDevice(disk, children)
     def _OpenRealBD(disk):

       after assembly we'll have our correct major/minor.
       """
       def __init__(self, unique_id, children, size):
       def __init__(self, unique_id, children, size, params):
         self._children = children
         self.dev_path = None
         self.unique_id = unique_id
-...
         self.minor = None
         self.attached = False
         self.size = size
         self.params = params
       def Assemble(self):
         """Assemble the device from its components.
-...
         raise NotImplementedError
       @classmethod
       def Create(cls, unique_id, children, size):
       def Create(cls, unique_id, children, size, params):
         """Create the device.
         If the device cannot be created, it will return None
-...
       _INVALID_NAMES = frozenset([".", "..", "snapshot", "pvmove"])
       _INVALID_SUBSTRINGS = frozenset(["_mlog", "_mimage"])
       def __init__(self, unique_id, children, size):
       def __init__(self, unique_id, children, size, params):
         """Attaches to a LV device.
         The unique_id is a tuple (vg_name, lv_name)
         """
         super(LogicalVolume, self).__init__(unique_id, children, size)
         super(LogicalVolume, self).__init__(unique_id, children, size, params)
         if not isinstance(unique_id, (tuple, list)) or len(unique_id) != 2:
           raise ValueError("Invalid configuration data %s" % str(unique_id))
         self._vg_name, self._lv_name = unique_id
-...
         self.Attach()
       @classmethod
       def Create(cls, unique_id, children, size):
       def Create(cls, unique_id, children, size, params):
         """Create a new logical volume.
         """
-...
         if result.failed:
           _ThrowError("LV create failed (%s): %s",
                       result.fail_reason, result.output)
         return LogicalVolume(unique_id, children, size)
         return LogicalVolume(unique_id, children, size, params)
       @staticmethod
       def _GetVolumeInfo(lvm_cmd, fields):
-...
         snap_name = self._lv_name + ".snap"
         # remove existing snapshot if found
         snap = LogicalVolume((self._vg_name, snap_name), None, size)
         snap = LogicalVolume((self._vg_name, snap_name), None, size, self.params)
         _IgnoreError(snap.Remove)
         vg_info = self.GetVGInfo([self._vg_name])
-...
       # timeout constants
       _NET_RECONFIG_TIMEOUT = 60
       def __init__(self, unique_id, children, size):
       def __init__(self, unique_id, children, size, params):
         if children and children.count(None) > 0:
           children = []
         if len(children) not in (0, 2):
-...
           if not _CanReadDevice(children[1].dev_path):
             logging.info("drbd%s: Ignoring unreadable meta device", self._aminor)
             children = []
         super(DRBD8, self).__init__(unique_id, children, size)
         super(DRBD8, self).__init__(unique_id, children, size, params)
         self.major = self._DRBD_MAJOR
         version = self._GetVersion(self._GetProcData())
         if version["k_major"] != 8:
-...
         self.Shutdown()
       @classmethod
       def Create(cls, unique_id, children, size):
       def Create(cls, unique_id, children, size, params):
         """Create a new DRBD8 device.
         Since DRBD devices are not created per se, just assembled, this
-...
                       aminor, meta)
         cls._CheckMetaSize(meta.dev_path)
         cls._InitMeta(aminor, meta.dev_path)
         return cls(unique_id, children, size)
         return cls(unique_id, children, size, params)
       def Grow(self, amount, dryrun):
         """Resize the DRBD device and its backing storage.
-...
       The unique_id for the file device is a (file_driver, file_path) tuple.
       """
       def __init__(self, unique_id, children, size):
       def __init__(self, unique_id, children, size, params):
         """Initalizes a file device backend.
         """
         if children:
           raise errors.BlockDeviceError("Invalid setup for file device")
         super(FileStorage, self).__init__(unique_id, children, size)
         super(FileStorage, self).__init__(unique_id, children, size, params)
         if not isinstance(unique_id, (tuple, list)) or len(unique_id) != 2:
           raise ValueError("Invalid configuration data %s" % str(unique_id))
         self.driver = unique_id[0]
-...
           _ThrowError("Can't stat %s: %s", self.dev_path, err)
       @classmethod
       def Create(cls, unique_id, children, size):
       def Create(cls, unique_id, children, size, params):
         """Create a new file.
         @param size: the size of file in MiB
-...
             _ThrowError("File already existing: %s", dev_path)
           _ThrowError("Error in file creation: %", str(err))
         return FileStorage(unique_id, children, size)
         return FileStorage(unique_id, children, size, params)
     class PersistentBlockDevice(BlockDev):
-...
       For the time being, pathnames are required to lie under /dev.
       """
       def __init__(self, unique_id, children, size):
       def __init__(self, unique_id, children, size, params):
         """Attaches to a static block device.
         The unique_id is a path under /dev.
         """
         super(PersistentBlockDevice, self).__init__(unique_id, children, size)
         super(PersistentBlockDevice, self).__init__(unique_id, children, size,
                                                     params)
         if not isinstance(unique_id, (tuple, list)) or len(unique_id) != 2:
           raise ValueError("Invalid configuration data %s" % str(unique_id))
         self.dev_path = unique_id[1]
-...
         self.Attach()
       @classmethod
       def Create(cls, unique_id, children, size):
       def Create(cls, unique_id, children, size, params):
         """Create a new device
         This is a noop, we only return a PersistentBlockDevice instance
         """
         return PersistentBlockDevice(unique_id, children, 0)
         return PersistentBlockDevice(unique_id, children, 0, params)
       def Remove(self):
         """Remove a device
-...
       DEV_MAP[constants.LD_FILE] = FileStorage
     def FindDevice(dev_type, unique_id, children, size):
     def _VerifyDiskType(dev_type):
       if dev_type not in DEV_MAP:
         raise errors.ProgrammerError("Invalid block device type '%s'" % dev_type)
     def FindDevice(disk, children):
       """Search for an existing, assembled device.
       This will succeed only if the device exists and is assembled, but it
       does not do any actions in order to activate the device.
       @type disk: L{objects.Disk}
       @param disk: the disk object to find
       @type children: list of L{bdev.BlockDev}
       @param children: the list of block devices that are children of the device
                       represented by the disk parameter
       """
       if dev_type not in DEV_MAP:
         raise errors.ProgrammerError("Invalid block device type '%s'" % dev_type)
       device = DEV_MAP[dev_type](unique_id, children, size)
       _VerifyDiskType(disk.dev_type)
       dev_params = objects.FillDict(constants.DISK_LD_DEFAULTS[disk.dev_type],
                                     disk.params)
       device = DEV_MAP[disk.dev_type](disk.physical_id, children, disk.size,
                                       dev_params)
       if not device.attached:
         return None
       return device
     def Assemble(dev_type, unique_id, children, size):
     def Assemble(disk, children):
       """Try to attach or assemble an existing device.
       This will attach to assemble the device, as needed, to bring it
       fully up. It must be safe to run on already-assembled devices.
       @type disk: L{objects.Disk}
       @param disk: the disk object to assemble
       @type children: list of L{bdev.BlockDev}
       @param children: the list of block devices that are children of the device
                       represented by the disk parameter
       """
       if dev_type not in DEV_MAP:
         raise errors.ProgrammerError("Invalid block device type '%s'" % dev_type)
       device = DEV_MAP[dev_type](unique_id, children, size)
       _VerifyDiskType(disk.dev_type)
       dev_params = objects.FillDict(constants.DISK_LD_DEFAULTS[disk.dev_type],
                                     disk.params)
       device = DEV_MAP[disk.dev_type](disk.physical_id, children, disk.size,
                                       dev_params)
       device.Assemble()
       return device
     def Create(dev_type, unique_id, children, size):
     def Create(disk, children):
       """Create a device.
       @type disk: L{objects.Disk}
       @param disk: the disk object to create
       @type children: list of L{bdev.BlockDev}
       @param children: the list of block devices that are children of the device
                       represented by the disk parameter
       """
       if dev_type not in DEV_MAP:
         raise errors.ProgrammerError("Invalid block device type '%s'" % dev_type)
       device = DEV_MAP[dev_type].Create(unique_id, children, size)
       _VerifyDiskType(disk.dev_type)
       dev_params = objects.FillDict(constants.DISK_LD_DEFAULTS[disk.dev_type],
                                     disk.params)
       device = DEV_MAP[disk.dev_type].Create(disk.physical_id, children, disk.size,
                                              dev_params)
       return device

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 94dcbdb0