add_disk.py 文件源码

def add_device(request, device_path, bucket=None):
    ceph.osdize(dev, config('osd-format'),
                get_journal_devices(), config('osd-reformat'),
                config('ignore-device-errors'),
                config('osd-encrypt'),
                config('bluestore'))
    # Make it fast!
    if config('autotune'):
        ceph.tune_dev(dev)
    mounts = filter(lambda disk: device_path
                    in disk.device, psutil.disk_partitions())
    if mounts:
        osd = mounts[0]
        osd_id = osd.mountpoint.split('/')[-1].split('-')[-1]
        request.ops.append({
            'op': 'move-osd-to-bucket',
            'osd': "osd.{}".format(osd_id),
            'bucket': bucket})
    return request