diff --git a/alink_gs b/alink_gs index fce3f62..d2bd5af 100644 --- a/alink_gs +++ b/alink_gs @@ -310,6 +310,10 @@ def connect_and_receive_msgpack(): udp_ip = config['Settings']['udp_ip'] udp_port = int(config['Settings']['udp_port']) retry_interval = int(config['Settings']['retry_interval']) # Get retry interval from config + + # Start UDP sending in a separate thread + udp_thread = threading.Thread(target=generate_package, daemon=True) # Change here to call generate_package + udp_thread.start() while True: try: @@ -322,10 +326,6 @@ def connect_and_receive_msgpack(): if verbose_mode: print(f"Connected to {host}:{port}") - # Start UDP sending in a separate thread - udp_thread = threading.Thread(target=generate_package, daemon=True) # Change here to call generate_package - udp_thread.start() - while True: # First, read 4 bytes for the length prefix length_prefix = client_socket.recv(4)