2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-19 22:24:26 +00:00

Reuse recent_peers

To be consistent, reuse this set rather than creating a new one.
This commit is contained in:
Jarrod Johnson
2024-08-09 16:43:27 -04:00
parent 0d8173cbcb
commit db670b695f

View File

@@ -192,7 +192,7 @@ async def snoop(handler, byehandler=None, protocol=None, uuidlookup=None):
machandlers.clear()
timeout = None
srp = await pktq.get()
recent_peers = set([])
recent_peers.clear()
while srp and len(deferrednotifies) < 256:
srp = None
if timeout is None: