ci: add precise tests to valide daemons are up

Add daemon health check for rgw, mds, mgr, rbd mirror.

Signed-off-by: Guillaume Abrioux <gabrioux@redhat.com>
Co-Authored-by: Guillaume Abrioux <gabrioux@redhat.com>

diff --git a/tests/conftest.py b/tests/conftest.py
index f8b2ec92efb89324d07ffd190ff61a059067b32f..2030b1346686cdfaebbd9e6c1768857cba7ed68d 100644 (file)
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -101,6 +101,10 @@ def pytest_collection_modifyitems(session, config, items):
             item.add_marker(pytest.mark.osds)
         elif "mds" in test_path:
             item.add_marker(pytest.mark.mdss)
+        elif "mgr" in test_path:
+            item.add_marker(pytest.mark.mgrs)
+        elif "rbd-mirror" in test_path:
+            item.add_marker(pytest.mark.rbdmirrors)
         elif "rgw" in test_path:
             item.add_marker(pytest.mark.rgws)
         elif "nfs" in test_path:

diff --git a/tests/functional/tests/mds/__init__.py b/tests/functional/tests/mds/__init__.py
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/tests/functional/tests/mds/test_mds.py b/tests/functional/tests/mds/test_mds.py
new file mode 100644 (file)
index 0000000..a866586
--- /dev/null
+++ b/tests/functional/tests/mds/test_mds.py
@@ -0,0 +1,39 @@
+import pytest
+import json
+
+class TestMDSs(object):
+
+    @pytest.mark.no_docker
+    def test_mds_is_installed(self, node, host):
+        assert host.package("ceph-mds").is_installed
+
+    def test_mds_service_is_running(self, node, host):
+        service_name = "ceph-mds@{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_running
+
+    def test_mds_service_is_enabled(self, node, host):
+        service_name = "ceph-mds@{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_enabled
+
+    @pytest.mark.no_docker
+    def test_mds_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cmd = "sudo ceph --name client.bootstrap-mds --keyring /var/lib/ceph/bootstrap-mds/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(cluster=node['cluster_name'])
+        output = host.check_output(cmd)
+        daemons = json.loads(output)["fsmap"]["by_rank"][0]["name"]
+        assert hostname in daemons
+
+    @pytest.mark.docker
+    def test_docker_mds_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cmd = "sudo docker exec ceph-mds-{hostname} ceph --name client.bootstrap-mds --keyring /var/lib/ceph/bootstrap-mds/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=node["vars"]["inventory_hostname"],
+            cluster=node["cluster_name"]
+        )
+        output = host.check_output(cmd)
+        daemons = json.loads(output)["fsmap"]["by_rank"][0]["name"]
+        assert hostname in daemons

diff --git a/tests/functional/tests/mgr/__init__.py b/tests/functional/tests/mgr/__init__.py
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/tests/functional/tests/mgr/test_mgr.py b/tests/functional/tests/mgr/test_mgr.py
new file mode 100644 (file)
index 0000000..146ac00
--- /dev/null
+++ b/tests/functional/tests/mgr/test_mgr.py
@@ -0,0 +1,44 @@
+import pytest
+import json
+
+class TestMGRs(object):
+
+    @pytest.mark.no_docker
+    def test_mgr_is_installed(self, node, host):
+        assert host.package("ceph-mgr").is_installed
+
+    def test_mgr_service_is_running(self, node, host):
+        service_name = "ceph-mgr@{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_running
+
+    def test_mgr_service_is_enabled(self, node, host):
+        service_name = "ceph-mgr@{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_enabled
+
+    @pytest.mark.no_docker
+    def test_mgr_is_up(self, node, host):
+        hostname=node["vars"]["inventory_hostname"]
+        cluster=node["cluster_name"]
+        cmd = "sudo ceph --name mgr.{hostname} --keyring /var/lib/ceph/mgr/{cluster}-{hostname}/keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=hostname,
+            cluster=cluster
+        )
+        output = host.check_output(cmd)
+        daemons = json.loads(output)["mgrmap"]["active_name"]
+        assert hostname in daemons
+
+    @pytest.mark.docker
+    def test_docker_mgr_is_up(self, node, host):
+        hostname=node["vars"]["inventory_hostname"]
+        cluster=node["cluster_name"]
+        cmd = "sudo docker exec ceph-mgr-{hostname} ceph --name mgr.{hostname} --keyring /var/lib/ceph/mgr/{cluster}-{hostname}/keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=node["vars"]["inventory_hostname"],
+            cluster=node["cluster_name"]
+        )
+        output = host.check_output(cmd)
+        daemons = json.loads(output)["mgrmap"]["active_name"]
+        assert hostname in daemons

diff --git a/tests/functional/tests/rbd-mirror/__init__.py b/tests/functional/tests/rbd-mirror/__init__.py
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/tests/functional/tests/rbd-mirror/test_rbd_mirror.py b/tests/functional/tests/rbd-mirror/test_rbd_mirror.py
new file mode 100644 (file)
index 0000000..92b5b8c
--- /dev/null
+++ b/tests/functional/tests/rbd-mirror/test_rbd_mirror.py
@@ -0,0 +1,44 @@
+import pytest
+import json
+
+class TestRbdMirrors(object):
+
+    @pytest.mark.no_docker
+    def test_rbd_mirror_is_installed(self, node, host):
+        assert host.package("rbd-mirror").is_installed
+
+    def test_rbd_mirror_service_is_running(self, node, host):
+        service_name = "ceph-rbd-mirror@rbd-mirror.{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_running
+
+    def test_rbd_mirror_service_is_enabled(self, node, host):
+        service_name = "ceph-rbd-mirror@rbd-mirror.{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_enabled
+
+    @pytest.mark.no_docker
+    def test_rbd_mirror_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cluster = node['cluster_name']
+        cmd = "sudo ceph --name client.bootstrap-rbd --keyring /var/lib/ceph/bootstrap-rbd/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=hostname,
+            cluster=cluster
+        )
+        output = host.check_output(cmd)
+        daemons = [i for i in json.loads(output)["servicemap"]["services"]["rbd-mirror"]["daemons"]]
+        assert hostname in daemons
+
+    @pytest.mark.docker
+    def test_docker_rbd_mirror_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cluster = node['cluster_name']
+        cmd = "sudo docker exec ceph-rbd-mirror-{hostname} ceph --name client.bootstrap-rbd --keyring /var/lib/ceph/bootstrap-rbd/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=hostname,
+            cluster=cluster
+        )
+        output = host.check_output(cmd)
+        daemons = [i for i in json.loads(output)["servicemap"]["services"]["rbd-mirror"]["daemons"]]
+        assert hostname in daemons

diff --git a/tests/functional/tests/rgw/__init__.py b/tests/functional/tests/rgw/__init__.py
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/tests/functional/tests/rgw/test_rgw.py b/tests/functional/tests/rgw/test_rgw.py
new file mode 100644 (file)
index 0000000..653ee9a
--- /dev/null
+++ b/tests/functional/tests/rgw/test_rgw.py
@@ -0,0 +1,47 @@
+import pytest
+import json
+
+class TestRGWs(object):
+
+    @pytest.mark.no_docker
+    def test_rgw_is_installed(self, node, host):
+        result = host.package("radosgw").is_installed
+        if not result:
+            result = host.package("ceph-radosgw").is_installed
+        assert result
+
+    def test_rgw_service_is_running(self, node, host):
+        service_name = "ceph-radosgw@rgw.{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_running
+
+    def test_rgw_service_is_enabled(self, node, host):
+        service_name = "ceph-radosgw@rgw.{hostname}".format(
+            hostname=node["vars"]["inventory_hostname"]
+        )
+        assert host.service(service_name).is_enabled
+
+    @pytest.mark.no_docker
+    def test_rgw_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cluster = node['cluster_name']
+        cmd = "sudo ceph --name client.bootstrap-rgw --keyring /var/lib/ceph/bootstrap-rgw/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=hostname,
+            cluster=cluster
+        )
+        output = host.check_output(cmd)
+        daemons = [i for i in json.loads(output)["servicemap"]["services"]["rgw"]["daemons"]]
+        assert hostname in daemons
+
+    @pytest.mark.docker
+    def test_docker_rgw_is_up(self, node, host):
+        hostname = node["vars"]["inventory_hostname"]
+        cluster = node['cluster_name']
+        cmd = "sudo docker exec ceph-rgw-{hostname} ceph --name client.bootstrap-rgw --keyring /var/lib/ceph/bootstrap-rgw/{cluster}.keyring --cluster={cluster} --connect-timeout 5 -f json -s".format(
+            hostname=hostname,
+            cluster=cluster
+        )
+        output = host.check_output(cmd)
+        daemons = [i for i in json.loads(output)["servicemap"]["services"]["rgw"]["daemons"]]
+        assert hostname in daemons