import new upstream nautilus stable release 14.2.8

[ceph.git] / ceph / src / ceph-volume / ceph_volume / devices / lvm / strategies / validators.py

from ceph_volume.util import disk
from ceph_volume.api import lvm


def minimum_device_size(devices, osds_per_device=1, min_size=5):
    """
    Ensure that the minimum requirements for this type of scenario is
    met, raise an error if the provided devices would not work
    """
    msg = 'Unable to use device %s %s, LVs would be smaller than {}GB'.format(min_size)
    for device in devices:
        device_size = disk.Size(b=device.lvm_size.b)
        lv_size = device_size / osds_per_device
        if lv_size < disk.Size(gb=min_size):
            raise RuntimeError(msg % (device_size, device.path))


def minimum_device_collocated_size(devices, journal_size, osds_per_device=1):
    """
    Similar to ``minimum_device_size``, but take into account that the size of
    the journal affects the size left of the device
    """
    msg = 'Unable to use device %s %s, LVs would be smaller than 5GB'
    for device in devices:
        device_size = disk.Size(b=device.lvm_size.b)
        lv_size = (device_size / osds_per_device) - journal_size
        if lv_size < disk.Size(gb=5):
            raise RuntimeError(msg % (device_size, device.path))


def no_lvm_membership(devices):
    """
    Do not allow devices that are part of LVM
    """
    msg = 'Unable to use device, already a member of LVM: %s'
    for device in devices:
        if device.is_lvm_member:
            raise RuntimeError(msg % device.abspath)


def has_common_vg(ssd_devices):
    """
    Ensure that devices have a common VG between them
    """
    msg = 'Could not find a common VG between devices: %s'
    ssd_vgs = {}

    for ssd_device in ssd_devices:
        vgs = lvm.get_device_vgs(ssd_device.abspath)
        if not vgs:
            continue
        for vg in vgs:
            try:
                ssd_vgs[vg.name].append(ssd_device.abspath)
            except KeyError:
                ssd_vgs[vg.name] = [ssd_device.abspath]
    # len of 1 means they all have a common vg, and len of 0 means that these
    # are blank
    if len(ssd_vgs) <= 1:
        return
    raise RuntimeError(msg % ', '.join(ssd_vgs.keys()))