From b875313f7d3e62fe8ad742f773c9c8f6634ec5e6 Mon Sep 17 00:00:00 2001 From: jdl Date: Sun, 14 Jun 2026 09:13:01 +0200 Subject: [PATCH] More audit changes. --- peer/multicast/receiver.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/peer/multicast/receiver.go b/peer/multicast/receiver.go index b5027be..20eca67 100644 --- a/peer/multicast/receiver.go +++ b/peer/multicast/receiver.go @@ -12,16 +12,17 @@ import ( ) func Receiver(selfVPNIP netip.Addr, ch chan<- Packet) { - limiters := map[netip.Addr]*ratelimiter.Limiter{} for { - if err := receiver(selfVPNIP, limiters, ch); err != nil { + if err := receiver(selfVPNIP, ch); err != nil { log.Printf("[MCReader] %v", err) } time.Sleep(errorTimeout) } } -func receiver(selfVPNIP netip.Addr, limiters map[netip.Addr]*ratelimiter.Limiter, ch chan<- Packet) error { +func receiver(selfVPNIP netip.Addr, ch chan<- Packet) error { + limiters := map[netip.Addr]*ratelimiter.Limiter{} + selfIP := selfVPNIP.As4()[3] addr := multicastAddr(selfVPNIP)