From: Rishabh Dave Date: Wed, 5 Mar 2025 11:10:11 +0000 (+0530) Subject: qa/cephfs: separate the tests for "ceph fs volume create" cmd X-Git-Tag: v20.3.0~301^2~3 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=058769c131754539efcb7f46164f7f164ecb1b13;p=ceph.git qa/cephfs: separate the tests for "ceph fs volume create" cmd Signed-off-by: Rishabh Dave --- diff --git a/qa/suites/fs/volumes/tasks/volumes/test/basic.yaml b/qa/suites/fs/volumes/tasks/volumes/test/basic.yaml index 2c026097dba3..49783bcc03bf 100644 --- a/qa/suites/fs/volumes/tasks/volumes/test/basic.yaml +++ b/qa/suites/fs/volumes/tasks/volumes/test/basic.yaml @@ -3,6 +3,7 @@ tasks: fail_on_skip: false modules: - tasks.cephfs.test_volumes.TestVolumes + - tasks.cephfs.test_volumes.TestVolumeCreate - tasks.cephfs.test_volumes.TestSubvolumeGroups - tasks.cephfs.test_volumes.TestSubvolumes - tasks.cephfs.test_subvolume diff --git a/qa/tasks/cephfs/test_volumes.py b/qa/tasks/cephfs/test_volumes.py index adaf0a06b907..662e6e732f60 100644 --- a/qa/tasks/cephfs/test_volumes.py +++ b/qa/tasks/cephfs/test_volumes.py @@ -454,32 +454,6 @@ class TestVolumesHelper(CephFSTestCase): class TestVolumes(TestVolumesHelper): """Tests for FS volume operations.""" - def test_volume_create(self): - """ - That the volume can be created and then cleans up - """ - volname = self._gen_vol_name() - self._fs_cmd("volume", "create", volname) - volumels = json.loads(self._fs_cmd("volume", "ls")) - - if not (volname in ([volume['name'] for volume in volumels])): - raise RuntimeError("Error creating volume '{0}'".format(volname)) - - # check that the pools were created with the correct config - pool_details = json.loads(self._raw_cmd("osd", "pool", "ls", "detail", "--format=json")) - pool_flags = {} - for pool in pool_details: - pool_flags[pool["pool_id"]] = pool["flags_names"].split(",") - - volume_details = json.loads(self._fs_cmd("get", volname, "--format=json")) - for data_pool_id in volume_details['mdsmap']['data_pools']: - self.assertIn("bulk", pool_flags[data_pool_id]) - meta_pool_id = volume_details['mdsmap']['metadata_pool'] - self.assertNotIn("bulk", pool_flags[meta_pool_id]) - - # clean up - self._fs_cmd("volume", "rm", volname, "--yes-i-really-mean-it") - def test_volume_ls(self): """ That the existing and the newly created volumes can be listed and @@ -678,6 +652,37 @@ class TestVolumes(TestVolumesHelper): " of subvolumegroup") +class TestVolumeCreate(TestVolumesHelper): + ''' + Contains test for "ceph fs volume create" command. + ''' + + def test_volume_create(self): + """ + That the volume can be created and then cleans up + """ + volname = self._gen_vol_name() + self._fs_cmd("volume", "create", volname) + volumels = json.loads(self._fs_cmd("volume", "ls")) + + if not (volname in ([volume['name'] for volume in volumels])): + raise RuntimeError("Error creating volume '{0}'".format(volname)) + + # check that the pools were created with the correct config + pool_details = json.loads(self._raw_cmd("osd", "pool", "ls", "detail", "--format=json")) + pool_flags = {} + for pool in pool_details: + pool_flags[pool["pool_id"]] = pool["flags_names"].split(",") + + volume_details = json.loads(self._fs_cmd("get", volname, "--format=json")) + for data_pool_id in volume_details['mdsmap']['data_pools']: + self.assertIn("bulk", pool_flags[data_pool_id]) + meta_pool_id = volume_details['mdsmap']['metadata_pool'] + self.assertNotIn("bulk", pool_flags[meta_pool_id]) + + # clean up + self._fs_cmd("volume", "rm", volname, "--yes-i-really-mean-it") + class TestRenameCmd(TestVolumesHelper): def test_volume_rename(self):