From 3b1b512a9adb056b7d815022609ab6620459b2f6 Mon Sep 17 00:00:00 2001
From: bef0rewind <490285+ronhuafeng@users.noreply.github.com>
Date: Mon, 29 Jun 2026 16:22:29 +0800
Subject: [PATCH] Fix disaggregation receiver ZMQ cleanup (#29570)

---
 python/sglang/srt/disaggregation/common/conn.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/python/sglang/srt/disaggregation/common/conn.py b/python/sglang/srt/disaggregation/common/conn.py
index 2eb2dbc18..607f0b735 100644
--- a/python/sglang/srt/disaggregation/common/conn.py
+++ b/python/sglang/srt/disaggregation/common/conn.py
@@ -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()