From ee899d9a44f3ab73c8ebbb82720d89364b9bb600 Mon Sep 17 00:00:00 2001 From: Patrick Donnelly Date: Wed, 14 Jul 2021 13:59:48 -0700 Subject: [PATCH] qa: add file system support for dumping epoch Signed-off-by: Patrick Donnelly --- qa/tasks/cephfs/filesystem.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/qa/tasks/cephfs/filesystem.py b/qa/tasks/cephfs/filesystem.py index a84f2bbd57b..eb30eaf5146 100644 --- a/qa/tasks/cephfs/filesystem.py +++ b/qa/tasks/cephfs/filesystem.py @@ -70,9 +70,12 @@ class FSStatus(object): """ Operations on a snapshot of the FSMap. """ - def __init__(self, mon_manager): + def __init__(self, mon_manager, epoch=None): self.mon = mon_manager - self.map = json.loads(self.mon.raw_cluster_cmd("fs", "dump", "--format=json")) + cmd = ["fs", "dump", "--format=json"] + if epoch is not None: + cmd.append(str(epoch)) + self.map = json.loads(self.mon.raw_cluster_cmd(*cmd)) def __str__(self): return json.dumps(self.map, indent = 2, sort_keys = True) @@ -367,8 +370,8 @@ class MDSCluster(CephCluster): def newfs(self, name='cephfs', create=True): return Filesystem(self._ctx, name=name, create=create) - def status(self): - return FSStatus(self.mon_manager) + def status(self, epoch=None): + return FSStatus(self.mon_manager, epoch) def get_standby_daemons(self): return set([s['name'] for s in self.status().get_standbys()]) -- 2.39.5