2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-14 03:37:49 +00:00

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.
This commit is contained in:
Jarrod Johnson 2022-01-07 09:55:49 -05:00
parent c475e4801f
commit d5a8e881ab

View File

@ -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):