ceph/qa/tasks/cephfs/test_misc.py

   1
   2 from unittest import SkipTest
   3 from tasks.cephfs.fuse_mount import FuseMount
   4 from tasks.cephfs.cephfs_test_case import CephFSTestCase
   5 from teuthology.orchestra.run import CommandFailedError
   6 import errno
   7 import time
   8
   9
  10 class TestMisc(CephFSTestCase):
  11     CLIENTS_REQUIRED = 2
  12
  13     LOAD_SETTINGS = ["mds_session_autoclose"]
  14     mds_session_autoclose = None
  15
  16     def test_getattr_caps(self):
  17         """
  18         Check if MDS recognizes the 'mask' parameter of open request.
  19         The paramter allows client to request caps when opening file
  20         """
  21
  22         if not isinstance(self.mount_a, FuseMount):
  23             raise SkipTest("Require FUSE client")
  24
  25         # Enable debug. Client will requests CEPH_CAP_XATTR_SHARED
  26         # on lookup/open
  27         self.mount_b.umount_wait()
  28         self.set_conf('client', 'client debug getattr caps', 'true')
  29         self.mount_b.mount()
  30         self.mount_b.wait_until_mounted()
  31
  32         # create a file and hold it open. MDS will issue CEPH_CAP_EXCL_*
  33         # to mount_a
  34         p = self.mount_a.open_background("testfile")
  35         self.mount_b.wait_for_visible("testfile")
  36
  37         # this tiggers a lookup request and an open request. The debug
  38         # code will check if lookup/open reply contains xattrs
  39         self.mount_b.run_shell(["cat", "testfile"])
  40
  41         self.mount_a.kill_background(p)
  42
  43     def test_fs_new(self):
  44         data_pool_name = self.fs.get_data_pool_name()
  45
  46         self.fs.mds_stop()
  47         self.fs.mds_fail()
  48
  49         self.fs.mon_manager.raw_cluster_cmd('fs', 'rm', self.fs.name,
  50                                             '--yes-i-really-mean-it')
  51
  52         self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'delete',
  53                                             self.fs.metadata_pool_name,
  54                                             self.fs.metadata_pool_name,
  55                                             '--yes-i-really-really-mean-it')
  56         self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'create',
  57                                             self.fs.metadata_pool_name,
  58                                             self.fs.get_pgs_per_fs_pool().__str__())
  59
  60         dummyfile = '/etc/fstab'
  61
  62         self.fs.put_metadata_object_raw("key", dummyfile)
  63
  64         timeout = 10
  65
  66         get_pool_df = self.fs.get_pool_df
  67         self.wait_until_true(
  68                 lambda: get_pool_df(self.fs.metadata_pool_name)['objects'] > 0,
  69                 timeout=timeout)
  70
  71         try:
  72             self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name,
  73                                                 self.fs.metadata_pool_name,
  74                                                 data_pool_name)
  75         except CommandFailedError as e:
  76             self.assertEqual(e.exitstatus, errno.EINVAL)
  77         else:
  78             raise AssertionError("Expected EINVAL")
  79
  80         self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name,
  81                                             self.fs.metadata_pool_name,
  82                                             data_pool_name, "--force")
  83
  84         self.fs.mon_manager.raw_cluster_cmd('fs', 'rm', self.fs.name,
  85                                             '--yes-i-really-mean-it')
  86
  87
  88         self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'delete',
  89                                             self.fs.metadata_pool_name,
  90                                             self.fs.metadata_pool_name,
  91                                             '--yes-i-really-really-mean-it')
  92         self.fs.mon_manager.raw_cluster_cmd('osd', 'pool', 'create',
  93                                             self.fs.metadata_pool_name,
  94                                             self.fs.get_pgs_per_fs_pool().__str__())
  95         self.fs.mon_manager.raw_cluster_cmd('fs', 'new', self.fs.name,
  96                                             self.fs.metadata_pool_name,
  97                                             data_pool_name)
  98
  99     def test_evict_client(self):
 100         """
 101         Check that a slow client session won't get evicted if it's the
 102         only session
 103         """
 104
 105         self.mount_b.umount_wait()
 106         ls_data = self.fs.mds_asok(['session', 'ls'])
 107         self.assert_session_count(1, ls_data)
 108
 109         self.mount_a.kill()
 110         self.mount_a.kill_cleanup()
 111
 112         time.sleep(self.mds_session_autoclose * 1.5)
 113         ls_data = self.fs.mds_asok(['session', 'ls'])
 114         self.assert_session_count(1, ls_data)
 115
 116         self.mount_a.mount()
 117         self.mount_a.wait_until_mounted()
 118         self.mount_b.mount()
 119         self.mount_b.wait_until_mounted()
 120
 121         ls_data = self._session_list()
 122         self.assert_session_count(2, ls_data)
 123
 124         self.mount_a.kill()
 125         self.mount_a.kill()
 126         self.mount_b.kill_cleanup()
 127         self.mount_b.kill_cleanup()
 128
 129         time.sleep(self.mds_session_autoclose * 1.5)
 130         ls_data = self.fs.mds_asok(['session', 'ls'])
 131         self.assert_session_count(1, ls_data)