From 2ea8715eb3ab45eb09fd5322b0d1c51beb3df2cd Mon Sep 17 00:00:00 2001
From: Ganesh Patil <7030871503ganeshpatil@gmail.com>
Date: Thu, 12 Feb 2026 17:51:08 +0530
Subject: [PATCH] Fix: Reuse PairedTransmitter outside loop to prevent repeated
 ZMQ socket creation (#268)

---
 0mq/funcall.py | 40 +++++++++++++++++++++-------------------
 1 file changed, 21 insertions(+), 19 deletions(-)

diff --git a/0mq/funcall.py b/0mq/funcall.py
index b316ff1..a885ed1 100644
--- a/0mq/funcall.py
+++ b/0mq/funcall.py
@@ -14,24 +14,26 @@
 
 u = concore.initval(init_simtime_u)
 ym = concore2.initval(init_simtime_ym)
-while(concore2.simtime<concore.maxtime):
-    while concore.unchanged():
-        u = concore.read(concore.iport['U'],"u",init_simtime_u)
-    print(u)
-    #concore.write(concore.oport['U1'],"u",u)
-    #old2 = concore2.simtime
-    #while concore2.unchanged() or concore2.simtime <= old2:
-    #    ym = concore2.read(concore.iport['Y1'],"ym",init_simtime_ym)
-    paired_transmitter = PairedTransmitter(
-        remote_host="localhost", exposed_commands=[],  
-        remote_port=2345, listen_port=2346,)
-    paired_transmitter.start_background_sync() 
-    ym = paired_transmitter.request_with_immediate_reply(
-        "fun", timeout=10.0, params={"u": [concore.simtime]+u})
-    concore2.simtime = ym[0]
-    ym = ym[1:]
+paired_transmitter = PairedTransmitter(
+    remote_host="localhost", exposed_commands=[],  
+    remote_port=2345, listen_port=2346,)
+paired_transmitter.start_background_sync()
+try:
+    while(concore2.simtime<concore.maxtime):
+        while concore.unchanged():
+            u = concore.read(concore.iport['U'],"u",init_simtime_u)
+        print(u)
+        #concore.write(concore.oport['U1'],"u",u)
+        #old2 = concore2.simtime
+        #while concore2.unchanged() or concore2.simtime <= old2:
+        #    ym = concore2.read(concore.iport['Y1'],"ym",init_simtime_ym)
+        ym = paired_transmitter.request_with_immediate_reply(
+            "fun", timeout=10.0, params={"u": [concore.simtime]+u})
+        concore2.simtime = ym[0]
+        ym = ym[1:]
+        #print(ym)
+        concore2.write(concore.oport['Y'],"ym",ym)
+        print("funcall 0mq u="+str(u)+" ym="+str(ym)+" time="+str(concore2.simtime))
+finally:
     paired_transmitter.stop_background_sync()
-    #print(ym)
-    concore2.write(concore.oport['Y'],"ym",ym)
-    print("funcall 0mq u="+str(u)+" ym="+str(ym)+" time="+str(concore2.simtime))
 print("retry="+str(concore.retrycount))