]>
git.proxmox.com Git - ceph.git/blob - ceph/qa/tasks/cephfs/test_misc.py
d857cfddf01a47f972957c963318ebf4c5105c1f
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
11 class TestMisc(CephFSTestCase
):
14 LOAD_SETTINGS
= ["mds_session_autoclose"]
15 mds_session_autoclose
= None
17 def test_getattr_caps(self
):
19 Check if MDS recognizes the 'mask' parameter of open request.
20 The paramter allows client to request caps when opening file
23 if not isinstance(self
.mount_a
, FuseMount
):
24 raise SkipTest("Require FUSE client")
26 # Enable debug. Client will requests CEPH_CAP_XATTR_SHARED
28 self
.mount_b
.umount_wait()
29 self
.set_conf('client', 'client debug getattr caps', 'true')
31 self
.mount_b
.wait_until_mounted()
33 # create a file and hold it open. MDS will issue CEPH_CAP_EXCL_*
35 p
= self
.mount_a
.open_background("testfile")
36 self
.mount_b
.wait_for_visible("testfile")
38 # this tiggers a lookup request and an open request. The debug
39 # code will check if lookup/open reply contains xattrs
40 self
.mount_b
.run_shell(["cat", "testfile"])
42 self
.mount_a
.kill_background(p
)
44 def test_fs_new(self
):
45 data_pool_name
= self
.fs
.get_data_pool_name()
50 self
.fs
.mon_manager
.raw_cluster_cmd('fs', 'rm', self
.fs
.name
,
51 '--yes-i-really-mean-it')
53 self
.fs
.mon_manager
.raw_cluster_cmd('osd', 'pool', 'delete',
54 self
.fs
.metadata_pool_name
,
55 self
.fs
.metadata_pool_name
,
56 '--yes-i-really-really-mean-it')
57 self
.fs
.mon_manager
.raw_cluster_cmd('osd', 'pool', 'create',
58 self
.fs
.metadata_pool_name
,
59 self
.fs
.get_pgs_per_fs_pool().__str
__())
61 dummyfile
= '/etc/fstab'
63 self
.fs
.put_metadata_object_raw("key", dummyfile
)
65 def get_pool_df(fs
, name
):
67 return fs
.get_pool_df(name
)['objects'] > 0
68 except RuntimeError as e
:
71 self
.wait_until_true(lambda: get_pool_df(self
.fs
, self
.fs
.metadata_pool_name
), timeout
=30)
74 self
.fs
.mon_manager
.raw_cluster_cmd('fs', 'new', self
.fs
.name
,
75 self
.fs
.metadata_pool_name
,
77 except CommandFailedError
as e
:
78 self
.assertEqual(e
.exitstatus
, errno
.EINVAL
)
80 raise AssertionError("Expected EINVAL")
82 self
.fs
.mon_manager
.raw_cluster_cmd('fs', 'new', self
.fs
.name
,
83 self
.fs
.metadata_pool_name
,
84 data_pool_name
, "--force")
86 self
.fs
.mon_manager
.raw_cluster_cmd('fs', 'rm', self
.fs
.name
,
87 '--yes-i-really-mean-it')
90 self
.fs
.mon_manager
.raw_cluster_cmd('osd', 'pool', 'delete',
91 self
.fs
.metadata_pool_name
,
92 self
.fs
.metadata_pool_name
,
93 '--yes-i-really-really-mean-it')
94 self
.fs
.mon_manager
.raw_cluster_cmd('osd', 'pool', 'create',
95 self
.fs
.metadata_pool_name
,
96 self
.fs
.get_pgs_per_fs_pool().__str
__())
97 self
.fs
.mon_manager
.raw_cluster_cmd('fs', 'new', self
.fs
.name
,
98 self
.fs
.metadata_pool_name
,
101 def test_evict_client(self
):
103 Check that a slow client session won't get evicted if it's the
107 self
.mount_b
.umount_wait()
108 ls_data
= self
.fs
.mds_asok(['session', 'ls'])
109 self
.assert_session_count(1, ls_data
)
112 self
.mount_a
.kill_cleanup()
114 time
.sleep(self
.mds_session_autoclose
* 1.5)
115 ls_data
= self
.fs
.mds_asok(['session', 'ls'])
116 self
.assert_session_count(1, ls_data
)
119 self
.mount_a
.wait_until_mounted()
121 self
.mount_b
.wait_until_mounted()
123 ls_data
= self
._session
_list
()
124 self
.assert_session_count(2, ls_data
)
127 self
.mount_a
.kill_cleanup()
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
)
133 def test_filtered_df(self
):
134 pool_name
= self
.fs
.get_data_pool_name()
135 raw_df
= self
.fs
.get_pool_df(pool_name
)
136 raw_avail
= float(raw_df
["max_avail"])
137 out
= self
.fs
.mon_manager
.raw_cluster_cmd('osd', 'pool', 'get',
141 pool_size
= int(j
['size'])
143 proc
= self
.mount_a
.run_shell(['df', '.'])
144 output
= proc
.stdout
.getvalue()
145 fs_avail
= output
.split('\n')[1].split()[3]
146 fs_avail
= float(fs_avail
) * 1024
148 ratio
= raw_avail
/ fs_avail
149 assert 0.9 < ratio
< 1.1