From c8fcb716fbe9d603a3ce1dc729eafc95e118eac7 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 2 Mar 2026 08:33:34 -0500 Subject: [PATCH] Fix socket being in blocking mode before async calls. --- confluent_server/confluent/netutil.py | 1 + 1 file changed, 1 insertion(+) diff --git a/confluent_server/confluent/netutil.py b/confluent_server/confluent/netutil.py index 41fb3354..375a1222 100644 --- a/confluent_server/confluent/netutil.py +++ b/confluent_server/confluent/netutil.py @@ -776,6 +776,7 @@ async def get_my_addresses(idx=0, family=0, matchlla=None): ifaddrmsg = struct.pack('BBBBI', family, 0, 0, 0, idx) s = socket.socket(socket.AF_NETLINK, socket.SOCK_RAW, socket.NETLINK_ROUTE) s.bind((0, 0)) + s.setblocking(False) await asyncio.get_event_loop().sock_sendall(s, nlhdr + ifaddrmsg) addrs = [] while True: