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)