tmp

Signed-off-by: Ronan Abhamon <ronan.abhamon@vates.tech>

Author: Wescoeur

xcp-storage/.gitignore

@@ -0,0 +1,4 @@
+.mypy_cache
+.pytest_cache
+.ruff_cache
+__pycache__

xcp-storage/pyproject.toml

@@ -39,11 +39,13 @@ ignore = [
     "UP045"  # pyupgrade: non-pep604-annotation-optional
 ]
 select = [
+    "ANN",    # flake8-annotations
     "ARG",    # flake8-unused-arguments
     "B",      # flake8-bugbear
     "C90",    # mccabe
     "F",      # Pyflakes
     "I",      # isort
+    "ICN",    # flake8-import-conventions
     "N",      # pep8-naming
     "PTH",    # flake8-use-pathlib
     "Q",      # flake8-quotes
@@ -52,6 +54,7 @@ select = [
     "SIM",    # flake8-simplify
     "SLF",    # flake8-self
     "T20",    # flake8-print
+    "TID",    # flake8-tidy-imports
     "UP"      # pyupgrade
 ]
 typing-modules = ["xcp_storage.typing"]
@@ -75,3 +78,7 @@ section-order = [
     "local-folder",
     "typing"
 ]
+
+[tool.pytest.ini_options]
+pythonpath = ["src", "stubs"]
+testpaths = ["tests"]

xcp-storage/src/xcp_storage/backends/drbd.py

@@ -37,6 +37,8 @@
 
 DRBD_BY_RES_PATH = "/dev/drbd/by-res/"
 
+DRBD_PORT_RANGE = (7000, 8000)
+
 # ------------------------------------------------------------------------------
 
 _EXEC_PATH_DRBDSETUP = "/usr/sbin/drbdsetup"

xcp-storage/src/xcp_storage/backends/linstor/controller.py

@@ -0,0 +1,67 @@
+#!/usr/bin/env python3
+#
+# Copyright (C) 2026  Vates SAS
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+from xcp_storage.utils.process import run_command
+from xcp_storage.utils.service import (
+    is_service_active,
+    restart_service,
+    start_service,
+    stop_service,
+)
+
+from .satellite import LINSTOR_SATELLITE_PORT_PLAIN, LINSTOR_SATELLITE_PORT_SSL
+
+from xcp_storage.typing import List
+
+# ==============================================================================
+
+LINSTOR_CONTROLLER_PORT_PLAIN = 3370
+LINSTOR_CONTROLLER_PORT_SSL = 3371
+
+# ------------------------------------------------------------------------------
+
+_SERVICE_LINSTOR_CONTROLLER = "linstor-controller"
+
+# ------------------------------------------------------------------------------
+
+def get_controller_addresses() -> List[str]:
+    stdout = run_command([
+        "/usr/sbin/ss", "-tnpH", "state", "established",
+        f"( sport = :{LINSTOR_SATELLITE_PORT_PLAIN} or sport = :{LINSTOR_SATELLITE_PORT_SSL} )"
+    ], expected_ret_code=0)
+    return [
+        line.split()[3].rsplit(":", 1)[0]
+        for line in stdout.splitlines()
+    ]
+
+def get_controller_uri() -> str:
+    # TODO: On caller side, check that an IP address from the current pool is returned.
+    addresses = get_controller_addresses()
+    return "linstor://" + addresses[0] if addresses else ""
+
+# ------------------------------------------------------------------------------
+
+def is_controller_running() -> bool:
+    return is_service_active(_SERVICE_LINSTOR_CONTROLLER)
+
+def start_controller() -> None:
+    start_service(_SERVICE_LINSTOR_CONTROLLER)
+
+def stop_controller() -> None:
+    stop_service(_SERVICE_LINSTOR_CONTROLLER)
+
+def restart_controller() -> None:
+    restart_service(_SERVICE_LINSTOR_CONTROLLER)