1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
from tasks.cephfs.cephfs_test_case import CephFSTestCase
class TestMetaInjection(CephFSTestCase):
def test_meta_injection(self):
conf_ori = self.fs.mds_asok(['config', 'show'])
self.fs.mds_asok(['config', 'set', 'mds_log_max_segments', '1'])
self.mount_a.run_shell(["mkdir", "metadir"])
self.mount_a.run_shell(["touch", "metadir/metafile1"])
self.mount_a.run_shell(["touch", "metadir/metafile2"])
self.fs.mds_asok(['flush', 'journal'])
dirino = self.mount_a.path_to_ino("metadir")
ino = self.mount_a.path_to_ino("metadir/metafile1")
# export meta of ino
self.fs.meta_tool(['showm', '-i', str(ino), '-o', '/tmp/meta_out'], 0, True)
out = self.mount_a.run_shell(['grep', str(ino),'/tmp/meta_out']).stdout.getvalue().strip()
# check the metadata of ino
self.assertNotEqual(out.find(u'"ino":'+ str(ino)), -1)
# amend info of ino
self.fs.get_meta_of_fs_file(dirino, "metafile1", "/tmp/meta_obj")
self.fs.meta_tool(['amend', '-i', str(ino), '--in', '/tmp/meta_out', '--yes-i-really-really-mean-it'], 0, True)
self.fs.get_meta_of_fs_file(dirino, "metafile1", "/tmp/meta_obj_chg")
# checkout meta_out after import it
ori_mds5 = self.mount_a.run_shell(["md5sum", "/tmp/meta_obj"]).stdout.getvalue().strip().split()
chg_mds5 = self.mount_a.run_shell(["md5sum", "/tmp/meta_obj_chg"]).stdout.getvalue().strip().split()
print(ori_mds5," ==> ", chg_mds5)
self.assertEqual(len(ori_mds5), 2)
self.assertEqual(len(chg_mds5), 2)
self.assertEqual(ori_mds5[0], chg_mds5[0])
self.mount_a.run_shell(["rm", "metadir", "-rf"])
self.mount_a.run_shell(["rm", "/tmp/meta_obj"])
self.mount_a.run_shell(["rm", "/tmp/meta_obj_chg"])
# restore config of mds_log_max_segments
self.fs.mds_asok(['config', 'set', 'mds_log_max_segments', conf_ori["mds_log_max_segments"]])
|
