From d5a8e881abeaeba5037650a0e00d30053f557758 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 7 Jan 2022 09:55:49 -0500 Subject: [PATCH] Defer handler processing This was done in slp, do it also for ssdp. This hopefully does it's best to flush udp buffer more quickly in at scale scenarios. --- confluent_server/confluent/discovery/protocols/ssdp.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/discovery/protocols/ssdp.py b/confluent_server/confluent/discovery/protocols/ssdp.py index fc6485c8..255dbd79 100644 --- a/confluent_server/confluent/discovery/protocols/ssdp.py +++ b/confluent_server/confluent/discovery/protocols/ssdp.py @@ -112,8 +112,8 @@ def _process_snoop(peer, rsp, mac, known_peers, newmacs, peerbymacaddress, byeha if retdata: known_peers.add(peer) newmacs.add(mac) - peerbymacaddress[mac] = peerdata - handler(retdata) + peerbymacaddress[mac] = retdata + machandlers[mac] = handler def snoop(handler, byehandler=None, protocol=None, uuidlookup=None):