RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-22 02:27:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

qa: Add subvolume group quota tests

Browse Source 
Fixes: https://tracker.ceph.com/issues/53509
Signed-off-by: Kotresh HR <khiremat@redhat.com>
This commit is contained in:
Kotresh HR 2021-12-16 13:43:02 +05:30
parent 3cfcbef284
commit 085700bf19
1 changed files with 52 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
qa/tasks/cephfs/test_volumes.py
View File

@ -213,6 +213,12 @@ class TestVolumesHelper(CephFSTestCase):
# remove the leading '/', and trailing whitespaces
return path[1:].rstrip()
def _get_subvolume_group_info(self, vol_name, group_name):
args = ["subvolumegroup", "info", vol_name, group_name]
args = tuple(args)
group_md = self._fs_cmd(*args)
return group_md
def _get_subvolume_path(self, vol_name, subvol_name, group_name=None):
args = ["subvolume", "getpath", vol_name, subvol_name]
if group_name:
@ -760,6 +766,52 @@ class TestSubvolumeGroups(TestVolumesHelper):
else:
raise RuntimeError("expected the 'fs subvolumegroup create' command to fail")
def test_subvolume_group_create_with_size(self):
# create group with size -- should set quota
group = self._generate_random_group_name()
self._fs_cmd("subvolumegroup", "create", self.volname, group, "1000000000")
# get group metadata
group_info = json.loads(self._get_subvolume_group_info(self.volname, group))
self.assertEqual(group_info["bytes_quota"], 1000000000)
# remove group
self._fs_cmd("subvolumegroup", "rm", self.volname, group)
def test_subvolume_group_info(self):
# tests the 'fs subvolumegroup info' command
group_md = ["atime", "bytes_pcent", "bytes_quota", "bytes_used", "created_at", "ctime",
"data_pool", "gid", "mode", "mon_addrs", "mtime", "uid"]
# create group
group = self._generate_random_group_name()
self._fs_cmd("subvolumegroup", "create", self.volname, group)
# get group metadata
group_info = json.loads(self._get_subvolume_group_info(self.volname, group))
for md in group_md:
self.assertIn(md, group_info, "'{0}' key not present in metadata of group".format(md))
self.assertEqual(group_info["bytes_pcent"], "undefined", "bytes_pcent should be set to undefined if quota is not set")
self.assertEqual(group_info["bytes_quota"], "infinite", "bytes_quota should be set to infinite if quota is not set")
self.assertEqual(group_info["uid"], 0)
self.assertEqual(group_info["gid"], 0)
nsize = self.DEFAULT_FILE_SIZE*1024*1024
self._fs_cmd("subvolumegroup", "resize", self.volname, group, str(nsize))
# get group metadata after quota set
group_info = json.loads(self._get_subvolume_group_info(self.volname, group))
for md in group_md:
self.assertIn(md, group_info, "'{0}' key not present in metadata of subvolume".format(md))
self.assertNotEqual(group_info["bytes_pcent"], "undefined", "bytes_pcent should not be set to undefined if quota is set")
self.assertEqual(group_info["bytes_quota"], nsize, "bytes_quota should be set to '{0}'".format(nsize))
# remove group
self._fs_cmd("subvolumegroup", "rm", self.volname, group)
def test_subvolume_group_ls(self):
# tests the 'fs subvolumegroup ls' command