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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
# Copyright (C) 2020 Red Hat, Inc. <http://www.redhat.com>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License along`
# with this program; if not, write to the Free Software Foundation, Inc.,
# 51 Franklin Street, Fifth Floor, Boston, MA 02110-131 USA.
"""
Description:
Check if parent directory timestamps are restored after an entry heal.
"""
from glusto.core import Glusto as g
from glustolibs.gluster.gluster_base_class import (GlusterBaseClass, runs_on)
from glustolibs.gluster.exceptions import ExecutionError
from glustolibs.gluster.brick_libs import (
bring_bricks_offline,
bring_bricks_online,
are_bricks_offline,
select_volume_bricks_to_bring_offline,
get_all_bricks)
from glustolibs.gluster.heal_ops import trigger_heal
from glustolibs.gluster.glusterdir import (mkdir, rmdir)
from glustolibs.gluster.glusterfile import (get_fattr, get_file_stat)
from glustolibs.gluster.volume_libs import set_volume_options
from glustolibs.gluster.heal_libs import monitor_heal_completion
@runs_on([['replicated'],
['glusterfs']])
class TestDirTimeStampRestore(GlusterBaseClass):
def setUp(self):
self.get_super_method(self, 'setUp')()
ret = self.setup_volume_and_mount_volume(mounts=self.mounts,
volume_create_force=False)
if not ret:
raise ExecutionError("Failed to Setup_Volume and Mount_Volume")
g.log.info("Successful in Setup Volume and Mount Volume")
self.bricks_list = get_all_bricks(self.mnode, self.volname)
def tearDown(self):
ret = self.unmount_volume_and_cleanup_volume(mounts=self.mounts)
if not ret:
raise ExecutionError("Failed to umount the vol & cleanup Volume")
g.log.info("Successful in umounting the volume and Cleanup")
self.get_super_method(self, 'tearDown')()
def are_mdata_xattrs_equal(self):
"""Check if atime/mtime/ctime in glusterfs.mdata xattr are identical"""
timestamps = []
for brick_path in self.bricks_list:
server, brick = brick_path.split(':')
fattr = get_fattr(server, '%s/%s' % (brick, "dir1"),
'trusted.glusterfs.mdata')
self.assertIsNotNone(fattr, 'Unable to get mdata xattr')
timestamps.append(fattr)
g.log.debug("mdata list = %s", ''.join(map(str, timestamps)))
return timestamps.count(timestamps[0]) == len(timestamps)
def are_stat_timestamps_equal(self):
"""Check if atime/mtime/ctime in stat info are identical"""
timestamps = []
for brick_path in self.bricks_list:
server, brick = brick_path.split(':')
stat_data = get_file_stat(server, "%s/dir1" % brick)
ts_string = "{}-{}-{}".format(stat_data['epoch_atime'],
stat_data['epoch_mtime'],
stat_data['epoch_ctime'])
timestamps.append(ts_string)
g.log.debug("stat list = %s", ''.join(map(str, timestamps)))
return timestamps.count(timestamps[0]) == len(timestamps)
def perform_test(self, ctime):
"""
Testcase steps:
1. Enable/disable features,ctime based on function argument.
2. Create a directory on the mount point.
3. Kill a brick and create a file inside the directory.
4. Bring the brick online.
5. Trigger heal and wait for its completion.
6. Verify that the atime, mtime and ctime of the directory are same on
all bricks of the replica.
"""
if ctime:
option = {'features.ctime': 'on'}
else:
option = {'features.ctime': 'off'}
ret = set_volume_options(self.mnode, self.volname, option)
self.assertTrue(ret, 'failed to set option %s on %s'
% (option, self.volume))
client, m_point = (self.mounts[0].client_system,
self.mounts[0].mountpoint)
dirpath = '{}/dir1'.format(m_point)
ret = mkdir(client, dirpath)
self.assertTrue(ret, 'Unable to create a directory from mount point')
bricks_to_bring_offline = select_volume_bricks_to_bring_offline(
self.mnode, self.volname)
self.assertIsNotNone(bricks_to_bring_offline, "List is empty")
ret = bring_bricks_offline(self.volname, bricks_to_bring_offline)
self.assertTrue(ret, 'Failed to bring bricks {} offline'.
format(bricks_to_bring_offline))
ret = are_bricks_offline(self.mnode, self.volname,
bricks_to_bring_offline)
self.assertTrue(ret, 'Bricks {} are not offline'.
format(bricks_to_bring_offline))
cmd = 'touch {}/file1'.format(dirpath)
ret, _, _ = g.run(client, cmd)
self.assertEqual(ret, 0, 'Unable to create file from mount point')
ret = bring_bricks_online(
self.mnode, self.volname,
bricks_to_bring_offline,
bring_bricks_online_methods=['volume_start_force'])
self.assertTrue(ret, 'Failed to bring bricks {} online'.format
(bricks_to_bring_offline))
ret = trigger_heal(self.mnode, self.volname)
self.assertTrue(ret, 'Starting heal failed')
ret = monitor_heal_completion(self.mnode, self.volname)
self.assertTrue(ret, 'Heal has not yet completed')
if ctime:
ret = self.are_mdata_xattrs_equal()
self.assertTrue(ret, "glusterfs.mdata mismatch for {}"
.format(dirpath))
else:
ret = self.are_stat_timestamps_equal()
self.assertTrue(ret, "stat mismatch for {}".format(dirpath))
ret = rmdir(client, dirpath, force=True)
self.assertTrue(ret, 'Unable to delete directory from mount point')
def test_dir_time_stamp_restoration(self):
"""
Create pending entry self-heal on a replica volume and verify that
after the heal is complete, the atime, mtime and ctime of the parent
directory are identical on all bricks of the replica.
The test is run with features.ctime enabled as well as disabled.
"""
self.perform_test(ctime=True)
self.perform_test(ctime=False)
|
