diff --git a/src/revpi_middleware/dbus_ios1/bus_provider_ios1.py b/src/revpi_middleware/dbus_ios1/bus_provider_ios1.py index a3052fe..c6c475f 100644 --- a/src/revpi_middleware/dbus_ios1/bus_provider_ios1.py +++ b/src/revpi_middleware/dbus_ios1/bus_provider_ios1.py @@ -4,7 +4,7 @@ """D-Bus bus provider for revpi_middleware.""" from logging import getLogger -from threading import Thread +from threading import Thread, Event from typing import Union import revpimodio2 @@ -47,6 +47,7 @@ class BusProviderIos1(Thread): ) self.picontrol_device = picontrol_device + self.published = Event() self.config_rsc = config_rsc def run(self): @@ -90,6 +91,7 @@ class BusProviderIos1(Thread): InterfaceIoManager(self._lst_io_interfaces, self._modio), *lst_interfaces, ) + self.published.set() except Exception as e: log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}") diff --git a/src/revpi_middleware/dbus_middleware1/bus_provider_middleware1.py b/src/revpi_middleware/dbus_middleware1/bus_provider_middleware1.py index 9f98f7e..17d640d 100644 --- a/src/revpi_middleware/dbus_middleware1/bus_provider_middleware1.py +++ b/src/revpi_middleware/dbus_middleware1/bus_provider_middleware1.py @@ -4,7 +4,7 @@ """D-Bus bus provider for revpi_middleware.""" from logging import getLogger -from threading import Thread +from threading import Thread, Event from typing import Union from gi.repository import GLib @@ -32,6 +32,7 @@ class BusProviderMiddleware1(Thread): self._loop = GLib.MainLoop() self.picontrol_device = picontrol_device + self.published = Event() self.config_rsc = config_rsc def run(self): @@ -53,6 +54,7 @@ class BusProviderMiddleware1(Thread): REVPI_DBUS_NAME, *lst_interfaces, ) + self.published.set() except Exception as e: log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}")