]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
qa: add file system support for dumping epoch
authorPatrick Donnelly <pdonnell@redhat.com>
Wed, 14 Jul 2021 20:59:48 +0000 (13:59 -0700)
committerPatrick Donnelly <pdonnell@redhat.com>
Wed, 28 Jul 2021 14:07:05 +0000 (07:07 -0700)
Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
qa/tasks/cephfs/filesystem.py

index a84f2bbd57b1797d45906377eae9b0825cc3bf31..eb30eaf5146e3c51410178f02538c24eb9c3d86f 100644 (file)
@@ -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()])