From 8dab330ff659915e3e90f0ff883b77f7f29b2bd7 Mon Sep 17 00:00:00 2001 From: "Hailu, Mikael" Date: Tue, 12 Dec 2023 18:18:52 +0100 Subject: [PATCH] Updated connect_sessionless and connect_socket to start new thread if necessary --- asyncua/sync.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/asyncua/sync.py b/asyncua/sync.py index 9f334839c..b8cde51f5 100644 --- a/asyncua/sync.py +++ b/asyncua/sync.py @@ -263,9 +263,12 @@ def disconnect(self) -> None: if self.close_tloop: self.tloop.stop() - @syncmethod def connect_sessionless(self) -> None: - pass + if not self.tloop.is_alive(): + self.tloop = ThreadLoop() + self.tloop.start() + self.close_tloop = True + self.tloop.post(self.aio_obj.connect_sessionless()) def disconnect_sessionless(self) -> None: try: @@ -274,9 +277,12 @@ def disconnect_sessionless(self) -> None: if self.close_tloop: self.tloop.stop() - @syncmethod def connect_socket(self) -> None: - pass + if not self.tloop.is_alive(): + self.tloop = ThreadLoop() + self.tloop.start() + self.close_tloop = True + self.tloop.post(self.aio_obj.connect_sessionless()) def disconnect_socket(self) -> None: try: