blob: 1b0a737a7b9c91d66dbd1098175c94735b7bb93c (
plain)
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
|
"""
Upgrade cluster snap format.
"""
import logging
import time
from tasks.cephfs.filesystem import Filesystem
log = logging.getLogger(__name__)
def task(ctx, config):
"""
Upgrade CephFS file system snap format.
"""
if config is None:
config = {}
assert isinstance(config, dict), \
'snap-upgrade task only accepts a dict for configuration'
fs = Filesystem(ctx)
mds_map = fs.get_mds_map()
assert(mds_map['max_mds'] == 1)
json = fs.run_scrub(["start", "/", "force", "recursive", "repair"])
if not json or json['return_code'] == 0:
assert(fs.wait_until_scrub_complete(tag=json["scrub_tag"]) == True)
log.info("scrub / completed")
else:
log.info("scrub / failed: {}".format(json))
json = fs.run_scrub(["start", "~mdsdir", "force", "recursive", "repair"])
if not json or json['return_code'] == 0:
assert(fs.wait_until_scrub_complete(tag=json["scrub_tag"]) == True)
log.info("scrub ~mdsdir completed")
else:
log.info("scrub / failed: {}".format(json))
for i in range(0, 10):
mds_map = fs.get_mds_map()
if (mds_map['flags'] & (1<<1)) != 0 and (mds_map['flags'] & (1<<4)) != 0:
break
time.sleep(10)
assert((mds_map['flags'] & (1<<1)) != 0) # Test CEPH_MDSMAP_ALLOW_SNAPS
assert((mds_map['flags'] & (1<<4)) != 0) # Test CEPH_MDSMAP_ALLOW_MULTIMDS_SNAPS
|
