parameters: added PASSYS_STRING128, its maybe used for PARSYS_SYSNAME; parser: added join_comm_thread and add_callback_and_block

sascha · sascha · commit ef81481f50c0 · 2020-02-26T14:17:16.000Z
git-svn-id: http://isvn/svn/rep_IEP-I000261_LINUX-KERNEL/01_Entwicklung/trunk/10_Entwicklung/28_SW_Komponente_XCOM/30_IMPL/XCOM_Client_Python/dependencies/ixcom-public@12242 fa3a88b2-825e-5648-bb98-bb0d4e3c2968
diff --git a/ixcom/parameters.py b/ixcom/parameters.py
@@ -14,6 +14,11 @@ class PARSYS_STRING64_Payload(DefaultParameterPayload):
         PayloadItem(name = 'str', dimension = 64, datatype = 's')
     ])
 
+class PARSYS_STRING128_Payload(DefaultParameterPayload):
+    parameter_payload = Message([
+        PayloadItem(name = 'str', dimension = 128, datatype = 's')
+    ])
+
 @parameter(0)
 class PARSYS_PRJNUM_Payload(PARSYS_STRING_Payload):
     pass
diff --git a/ixcom/parser.py b/ixcom/parser.py
@@ -165,6 +165,13 @@ def add_subscriber(self, subscriber):
     def add_callback(self, callback):
         self.callbacks += [callback]
 
+    def add_callback_and_block(self, callback):
+        '''Add a callback function and joins the communication thread.
+        Call stop() in a callback function the stop the communication thread and continue.
+        '''
+        self.callbacks += [callback]
+        self.join_comm_thread.join()
+
     def remove_callback(self, callback):
         self.callbacks.remove(callback)
 
@@ -217,12 +224,21 @@ def __init__(self, host, port=GENERAL_PORT, timeout = WAIT_TIME_FOR_RESPONSE):
         
         self.add_subscriber(self)
 
-
     def _create_socket_and_connect(self):
         self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
         self.sock.connect((self.host, self.port))
 
+    def join_comm_thread(self):
+        '''Join the communication thread
+        Blocks the calling location until the communications thread terminates.
+        Can e.g. be used if callbacks have been set up, logs have been requested and we just want to
+        leave the program running like this until the communications with the device stop.
+        Args:
+            self
+        '''
+        self._comm_thread.join()
+
     def stop(self):
         self._stop_event.set()
         self._comm_thread.join()
