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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
import os
import time
from textwrap import dedent
from unittest import SkipTest
from tasks.cephfs.fuse_mount import FuseMount
from tasks.cephfs.cephfs_test_case import CephFSTestCase, for_teuthology
class TestCapFlush(CephFSTestCase):
@for_teuthology
def test_replay_create(self):
"""
MDS starts to handle client caps when it enters clientreplay stage.
When handling a client cap in clientreplay stage, it's possible that
corresponding inode does not exist because the client request which
creates inode hasn't been replayed.
"""
if not isinstance(self.mount_a, FuseMount):
raise SkipTest("Require FUSE client to inject client release failure")
dir_path = os.path.join(self.mount_a.mountpoint, "testdir")
py_script = dedent("""
import os
os.mkdir("{0}")
fd = os.open("{0}", os.O_RDONLY)
os.fchmod(fd, 0777)
os.fsync(fd)
""").format(dir_path)
self.mount_a.run_python(py_script)
self.fs.mds_asok(["flush", "journal"])
# client will only get unsafe replay
self.fs.mds_asok(["config", "set", "mds_log_pause", "1"])
file_name = "testfile"
file_path = dir_path + "/" + file_name
# Create a file and modify its mode. ceph-fuse will mark Ax cap dirty
py_script = dedent("""
import os
os.chdir("{0}")
os.setgid(65534)
os.setuid(65534)
fd = os.open("{1}", os.O_CREAT | os.O_RDWR, 0644)
os.fchmod(fd, 0640)
""").format(dir_path, file_name)
self.mount_a.run_python(py_script)
# Modify file mode by different user. ceph-fuse will send a setattr request
self.mount_a.run_shell(["chmod", "600", file_path], wait=False)
time.sleep(10)
# Restart mds. Client will re-send the unsafe request and cap flush
self.fs.mds_stop()
self.fs.mds_fail_restart()
self.fs.wait_for_daemons()
mode = self.mount_a.run_shell(['stat', '-c' '%a', file_path]).stdout.getvalue().strip()
# If the cap flush get dropped, mode should be 0644.
# (Ax cap stays in dirty state, which prevents setattr reply from updating file mode)
self.assertEqual(mode, "600")
|
