diff options
Diffstat (limited to 'src/ceph/qa/tasks/cephfs/test_misc.py')
| -rw-r--r-- | src/ceph/qa/tasks/cephfs/test_misc.py | 149 |
1 files changed, 0 insertions, 149 deletions
diff --git a/src/ceph/qa/tasks/cephfs/test_misc.py b/src/ceph/qa/tasks/cephfs/test_misc.py deleted file mode 100644 index d857cfd..0000000 --- a/src/ceph/qa/tasks/cephfs/test_misc.py +++ /dev/null @@ -1,149 +0,0 @@ - -from unittest import SkipTest -from tasks.cephfs.fuse_mount import FuseMount -from tasks.cephfs.cephfs_test_case import CephFSTestCase -from teuthology.orchestra.run import CommandFailedError -import errno -import time -import json - - -class TestMisc(CephFSTestCase): - CLIENTS_REQUIRED = 2 - - LOAD_SETTINGS = ["mds_session_autoclose"] - mds_session_autoclose = None - - def test_getattr_caps(self): - """ - Check if MDS recognizes the 'mask' parameter of open request. - The paramter allows client to request caps when opening file - """ - - if not isinstance(self.mount_a, FuseMount): - raise SkipTest("Require FUSE client") - - # Enable debug. Client will requests CEPH_CAP_XATTR_SHARED - # on lookup/open - self.mount_b.umount_wait() - self.set_conf('client', 'client debug getattr caps', 'true') - self.mount_b.mount() - self.mount_b.wait_until_mounted() - - # create a file and hold it open. MDS will issue CEPH_CAP_EXCL_* - # to mount_a - p = self.mount_a.open_background("testfile") - self.mount_b.wait_for_visible("testfile") - - # this tiggers a lookup request and an open request. The debug - # code will check if lookup/open reply contains xattrs - self.mount_b.run_shell(["cat", "testfile"]) - - self.mount_a.kill_background(p) - - def test_fs_new(self): - data_pool_name = self.fs.get_data_pool_name() - - self.fs.mds_stop() - self.fs.mds_fail() - - self.fs.mon_manager.raw_cluster_cmd('fs', 'rm', self.fs.name, - '--yes-i-really-mean-it') - - self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'delete', - self.fs.metadata_pool_name, - self.fs.metadata_pool_name, - '--yes-i-really-really-mean-it') - self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'create', - self.fs.metadata_pool_name, - self.fs.get_pgs_per_fs_pool().__str__()) - - dummyfile = '/etc/fstab' - - self.fs.put_metadata_object_raw("key", dummyfile) - - def get_pool_df(fs, name): - try: - return fs.get_pool_df(name)['objects'] > 0 - except RuntimeError as e: - return False - - self.wait_until_true(lambda: get_pool_df(self.fs, self.fs.metadata_pool_name), timeout=30) - - try: - self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name, - self.fs.metadata_pool_name, - data_pool_name) - except CommandFailedError as e: - self.assertEqual(e.exitstatus, errno.EINVAL) - else: - raise AssertionError("Expected EINVAL") - - self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name, - self.fs.metadata_pool_name, - data_pool_name, "--force") - - self.fs.mon_manager.raw_cluster_cmd('fs', 'rm', self.fs.name, - '--yes-i-really-mean-it') - - - self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'delete', - self.fs.metadata_pool_name, - self.fs.metadata_pool_name, - '--yes-i-really-really-mean-it') - self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'create', - self.fs.metadata_pool_name, - self.fs.get_pgs_per_fs_pool().__str__()) - self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name, - self.fs.metadata_pool_name, - data_pool_name) - - def test_evict_client(self): - """ - Check that a slow client session won't get evicted if it's the - only session - """ - - self.mount_b.umount_wait() - ls_data = self.fs.mds_asok(['session', 'ls']) - self.assert_session_count(1, ls_data) - - self.mount_a.kill() - self.mount_a.kill_cleanup() - - time.sleep(self.mds_session_autoclose * 1.5) - ls_data = self.fs.mds_asok(['session', 'ls']) - self.assert_session_count(1, ls_data) - - self.mount_a.mount() - self.mount_a.wait_until_mounted() - self.mount_b.mount() - self.mount_b.wait_until_mounted() - - ls_data = self._session_list() - self.assert_session_count(2, ls_data) - - self.mount_a.kill() - self.mount_a.kill_cleanup() - - time.sleep(self.mds_session_autoclose * 1.5) - ls_data = self.fs.mds_asok(['session', 'ls']) - self.assert_session_count(1, ls_data) - - def test_filtered_df(self): - pool_name = self.fs.get_data_pool_name() - raw_df = self.fs.get_pool_df(pool_name) - raw_avail = float(raw_df["max_avail"]) - out = self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'get', - pool_name, 'size', - '-f', 'json-pretty') - j = json.loads(out) - pool_size = int(j['size']) - - proc = self.mount_a.run_shell(['df', '.']) - output = proc.stdout.getvalue() - fs_avail = output.split('\n')[1].split()[3] - fs_avail = float(fs_avail) * 1024 - - ratio = raw_avail / fs_avail - assert 0.9 < ratio < 1.1 |