Fix disaggregation receiver ZMQ cleanup (#29570)

2026-06-29 16:22:29 +08:00
parent 91cf159696
commit 3b1b512a9a
1 changed files with 2 additions and 0 deletions
@@ -1091,6 +1091,8 @@ class CommonKVReceiver(BaseKVReceiver):
                sock = cls._ctx.socket(zmq.PUSH)
                if is_ipv6:
                    sock.setsockopt(zmq.IPV6, 1)
+                sock.setsockopt(zmq.RECONNECT_IVL, -1)
+                sock.setsockopt(zmq.LINGER, 0)
                sock.connect(endpoint)
                cls._socket_cache[endpoint] = sock
                cls._socket_locks[endpoint] = threading.Lock()