X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fqa%2Ftasks%2Fcephfs%2Ftest_misc.py;fp=src%2Fceph%2Fqa%2Ftasks%2Fcephfs%2Ftest_misc.py;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=d857cfddf01a47f972957c963318ebf4c5105c1f;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

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