From 5967c421ca0c16c3fe4bb812e6aacc0aeadcd3b8 Mon Sep 17 00:00:00 2001 From: ed Date: Sat, 25 Jan 2025 11:29:38 +0000 Subject: [PATCH] zmq tweaks --- copyparty/util.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/copyparty/util.py b/copyparty/util.py index 7ab92976..a0c886f0 100644 --- a/copyparty/util.py +++ b/copyparty/util.py @@ -3519,18 +3519,21 @@ def _zmq_hook( if mode == "pub": sck = ctx.socket(zmq.PUB) + sck.setsockopt(zmq.LINGER, 0) sck.bind(uri) time.sleep(1) # give clients time to connect; avoids losing first msg elif mode == "push": sck = ctx.socket(zmq.PUSH) - sck.bind(uri) if timeout: sck.SNDTIMEO = int(timeout * 1000) + sck.setsockopt(zmq.LINGER, 0) + sck.bind(uri) elif mode == "req": sck = ctx.socket(zmq.REQ) - sck.connect(uri) if timeout: sck.RCVTIMEO = int(timeout * 1000) + sck.setsockopt(zmq.LINGER, 0) + sck.connect(uri) else: raise Exception()