qa: wait for daemons to come up via cephadm

Rather than waiting for a set amount of time.

Fixes: https://tracker.ceph.com/issues/49684
Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
(cherry picked from commit d06689e16e3264b21b33326db5e328faef0da799)

diff --git a/qa/suites/fs/cephadm/multivolume/0-start.yaml b/qa/suites/fs/cephadm/multivolume/0-start.yaml
index 4e832878ad2070f81d31fecc54b132f6eb0af9d9..13dc863d2936001a56754815390b6e1837e2fcde 100644 (file)
--- a/qa/suites/fs/cephadm/multivolume/0-start.yaml
+++ b/qa/suites/fs/cephadm/multivolume/0-start.yaml
@@ -35,5 +35,5 @@ tasks:
     host.a:
       - ceph fs volume create foo
       - ceph fs volume create bar
-- sleep:
-    interval: 60
+- fs.ready:
+    timeout: 300

diff --git a/qa/tasks/fs.py b/qa/tasks/fs.py
index 4f7a3e2060b6cb7525a7fdc59ed9dc7448640b67..1a6cfcfb38267645cc13f9f5646e7496e18b621c 100644 (file)
--- a/qa/tasks/fs.py
+++ b/qa/tasks/fs.py
@@ -5,10 +5,29 @@ CephFS sub-tasks.
 import logging
 import re
 
-from tasks.cephfs.filesystem import Filesystem
+from tasks.cephfs.filesystem import Filesystem, MDSCluster
 
 log = logging.getLogger(__name__)
 
+def ready(ctx, config):
+    """
+    That the file system is ready for clients.
+    """
+
+    if config is None:
+        config = {}
+    assert isinstance(config, dict), \
+        'task only accepts a dict for configuration'
+
+    timeout = config.get('timeout', 300)
+
+    mdsc = MDSCluster(ctx)
+    status = mdsc.status()
+
+    for filesystem in status.get_filesystems():
+        fs = Filesystem(ctx, fscid=filesystem['id'])
+        fs.wait_for_daemons(timeout=timeout, status=status)
+
 def clients_evicted(ctx, config):
     """
     Check clients are evicted, unmount (cleanup) if so.