svghmi/svghmi_server.py
branchsvghmi
changeset 2776 246ae685ab65
parent 2775 3b93409ba22c
child 2777 cdf6584953a0
--- a/svghmi/svghmi_server.py	Mon Sep 16 10:54:15 2019 +0200
+++ b/svghmi/svghmi_server.py	Mon Sep 16 11:44:20 2019 +0200
@@ -35,18 +35,6 @@
     ctypes.POINTER(ctypes.c_void_p)]  # data ptr
 # TODO multiclient : switch to arrays
 
-def SendThreadProc():
-   assert(svghmi_session)
-   size = ctypes.c_uint32()
-   ptr = ctypes.c_void_p()
-   res = 0
-   while svghmi_send_collect(ctypes.byref(size), ctypes.byref(ptr)) == 0 and \
-         svghmi_session is not None and \
-         svghmi_session.sendMessage(ctypes.string_at(ptr,size)) == 0:
-         pass
-
-       # TODO multiclient : dispatch to sessions
-
 class HMISession(object):
     def __init__(self, protocol_instance):
         global svghmi_session
@@ -106,6 +94,18 @@
 svghmi_listener = None
 svghmi_send_thread = None
 
+def SendThreadProc():
+   global svghmi_session
+   size = ctypes.c_uint32()
+   ptr = ctypes.c_void_p()
+   res = 0
+   while svghmi_send_collect(ctypes.byref(size), ctypes.byref(ptr)) == 0 and \
+         svghmi_session is not None and \
+         svghmi_session.sendMessage(ctypes.string_at(ptr,size)) == 0:
+         pass
+
+       # TODO multiclient : dispatch to sessions
+
 
 # Called by PLCObject at start
 def _runtime_svghmi0_start():