ceph-volume lvm.batch allow extra flags for bluestore

Signed-off-by: Alfredo Deza <adeza@redhat.com>

diff --git a/src/ceph-volume/ceph_volume/devices/lvm/strategies/bluestore.py b/src/ceph-volume/ceph_volume/devices/lvm/strategies/bluestore.py
index bb3d6be4fe320374c49aeb77584e45895b9e1e16..03fd92f65366828ee699c3922b2a8eed57b221db 100644 (file)
--- a/src/ceph-volume/ceph_volume/devices/lvm/strategies/bluestore.py
+++ b/src/ceph-volume/ceph_volume/devices/lvm/strategies/bluestore.py
@@ -124,11 +124,16 @@ class SingleType(object):
             lvs = lvm.create_lvs(create['vg'], parts=create['parts'], name_prefix='osd-data')
             vg_name = create['vg'].name
             for lv in lvs:
-                # FIXME: no support for dmcrypt, crush class, etc...
-                Create([
-                    '--bluestore',
-                    '--data', "%s/%s" % (vg_name, lv.name),
-                ]).main()
+                command = ['--bluestore', '--data']
+                command.append('%s/%s' % (vg_name, lv.name))
+                if self.args.dmcrypt:
+                    command.append('--dmcrypt')
+                if self.args.no_systemd:
+                    command.append('--no-systemd')
+                if self.args.crush_device_class:
+                    command.extend(['--crush-device-class', self.args.crush_device_class])
+
+                Create(command).main()
 
 
 class MixedType(object):
@@ -232,12 +237,19 @@ class MixedType(object):
             from uuid import uuid4
             data_lv = lvm.create_lv('osd-data-%s' % str(uuid4()), vg.name)
             db_lv = db_lvs.pop()
-            # FIXME: no support for dmcrypt, crush class, etc...
-            Create([
+            command = [
                 '--bluestore',
                 '--data', "%s/%s" % (data_lv.vg_name, data_lv.name),
                 '--block.db', '%s/%s' % (db_lv.vg_name, db_lv.name)
-            ]).main()
+            ]
+            if self.args.dmcrypt:
+                command.append('--dmcrypt')
+            if self.args.no_systemd:
+                command.append('--no-systemd')
+            if self.args.crush_device_class:
+                command.extend(['--crush-device-class', self.args.crush_device_class])
+
+            Create(command).main()
 
     def validate(self):
         """