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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
from cephfs_test_case import CephFSTestCase
from teuthology.exceptions import CommandFailedError
class TestQuota(CephFSTestCase):
CLIENTS_REQUIRED = 2
MDSS_REQUIRED = 1
def test_remote_update_getfattr(self):
"""
That quota changes made from one client are visible to another
client looking at ceph.quota xattrs
"""
self.mount_a.run_shell(["mkdir", "subdir"])
self.assertEqual(
self.mount_a.getfattr("./subdir", "ceph.quota.max_files"),
None)
self.assertEqual(
self.mount_b.getfattr("./subdir", "ceph.quota.max_files"),
None)
self.mount_a.setfattr("./subdir", "ceph.quota.max_files", "10")
self.assertEqual(
self.mount_a.getfattr("./subdir", "ceph.quota.max_files"),
"10")
# Should be visible as soon as setxattr operation completes on
# mds (we get here sooner because setfattr gets an early reply)
self.wait_until_equal(
lambda: self.mount_b.getfattr("./subdir", "ceph.quota.max_files"),
"10", timeout=10)
def test_remote_update_df(self):
"""
That when a client modifies the quota on a directory used
as another client's root, the other client sees the change
reflected in their statfs output.
"""
self.mount_b.umount_wait()
self.mount_a.run_shell(["mkdir", "subdir"])
size_before = 1024 * 1024 * 128
self.mount_a.setfattr("./subdir", "ceph.quota.max_bytes",
"%s" % size_before)
self.mount_b.mount(mount_path="/subdir")
self.assertDictEqual(
self.mount_b.df(),
{
"total": size_before,
"used": 0,
"available": size_before
})
size_after = 1024 * 1024 * 256
self.mount_a.setfattr("./subdir", "ceph.quota.max_bytes",
"%s" % size_after)
# Should be visible as soon as setxattr operation completes on
# mds (we get here sooner because setfattr gets an early reply)
self.wait_until_equal(
lambda: self.mount_b.df(),
{
"total": size_after,
"used": 0,
"available": size_after
},
timeout=10
)
def test_remote_update_write(self):
"""
That when a client modifies the quota on a directory used
as another client's root, the other client sees the effect
of the change when writing data.
"""
self.mount_a.run_shell(["mkdir", "subdir_files"])
self.mount_a.run_shell(["mkdir", "subdir_data"])
# Set some nice high quotas that mount_b's initial operations
# will be well within
self.mount_a.setfattr("./subdir_files", "ceph.quota.max_files", "100")
self.mount_a.setfattr("./subdir_data", "ceph.quota.max_bytes", "104857600")
# Do some writes within my quota
self.mount_b.create_n_files("subdir_files/file", 20)
self.mount_b.write_n_mb("subdir_data/file", 20)
# Set quotas lower than what mount_b already wrote, it should
# refuse to write more once it's seen them
self.mount_a.setfattr("./subdir_files", "ceph.quota.max_files", "10")
self.mount_a.setfattr("./subdir_data", "ceph.quota.max_bytes", "1048576")
# Do some writes that would have been okay within the old quota,
# but are forbidden under the new quota
with self.assertRaises(CommandFailedError):
self.mount_b.create_n_files("subdir_files/file", 40)
with self.assertRaises(CommandFailedError):
self.mount_b.write_n_mb("subdir_data/file", 40)
|
